akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

lncli: switch to routerrpc.SendToRouteV2

Browse Source
This commit is contained in:
Joost Jager 2019-03-14 16:31:58 +01:00
parent b6170788ea
commit 0f6eacb4fa
No known key found for this signature in database
GPG Key ID: A61B9D4C393C59C7
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
cmd/lncli/cmd_pay.go
View File

@ -836,7 +836,7 @@ func sendToRoute(ctx *cli.Context) error {
route = routes.Route route = routes.Route
} }
req := &lnrpc.SendToRouteRequest{ req := &routerrpc.SendToRouteRequest{
PaymentHash: rHash, PaymentHash: rHash,
Route: route, Route: route,
} }
@ -844,20 +844,13 @@ func sendToRoute(ctx *cli.Context) error {
return sendToRouteRequest(ctx, req) return sendToRouteRequest(ctx, req)
} }
func sendToRouteRequest(ctx *cli.Context, req *lnrpc.SendToRouteRequest) error { func sendToRouteRequest(ctx *cli.Context, req *routerrpc.SendToRouteRequest) error {
client, cleanUp := getClient(ctx) conn := getClientConn(ctx, false)
defer cleanUp() defer conn.Close()
paymentStream, err := client.SendToRoute(context.Background()) client := routerrpc.NewRouterClient(conn)
if err != nil {
return err
}
if err := paymentStream.Send(req); err != nil { resp, err := client.SendToRouteV2(context.Background(), req)
return err
}
resp, err := paymentStream.Recv()
if err != nil { if err != nil {
return err return err
} }