grpc client tests

lnrpc/graphrpc/graph.proto

@@ -43,10 +43,10 @@ message BetweennessCentrality {
     bytes node = 1;
 
     // The normalized betweenness centrality of the node.
-    float normalized = 2;
+    double normalized = 2;
 
     // The non-normalized betweenness centrality of the node.
-    float non_normalized = 3;
+    double non_normalized = 3;
 }
 
 message BootstrapAddrsReq {

lnrpc/graphrpc/graph.swagger.json

@@ -131,12 +131,12 @@
         },
         "normalized": {
           "type": "number",
-          "format": "float",
+          "format": "double",
           "description": "The normalized betweenness centrality of the node."
         },
         "non_normalized": {
           "type": "number",
-          "format": "float",
+          "format": "double",
           "description": "The non-normalized betweenness centrality of the node."
         }
       }

lnrpc/graphrpc/graph_client.go

@@ -25,7 +25,8 @@ import (
 )
 
 // Client is a wrapper that implements the sources.GraphSource interface using a
-// grpc connection to a grpc GraphClient client.
+// grpc connection which it uses to communicate with a grpc GraphClient client
+// along with an lnrpc.LightningClient.
 type Client struct {
 	// graphConn is a grpc client that implements the GraphClient service.
 	graphConn GraphClient
@@ -65,8 +66,8 @@ func (r *Client) BetweennessCentrality(ctx context.Context) (
 		var id autopilot.NodeID
 		copy(id[:], node.Node)
 		centrality[id] = &models.BetweennessCentrality{
-			Normalized:    float64(node.Normalized),
-			NonNormalized: float64(node.NonNormalized),
+			Normalized:    node.Normalized,
+			NonNormalized: node.NonNormalized,
 		}
 	}
 
@@ -722,15 +723,15 @@ func unmarshalChannelInfo(info *lnrpc.ChannelEdge) (*models.ChannelEdgeInfo,
 	)
 	if info.Node1Policy != nil {
 		policy1, err = unmarshalPolicy(
-			info.ChannelId, info.Node1Policy, true,
+			info.ChannelId, info.Node1Policy, true, info.Node2Pub,
 		)
 		if err != nil {
 			return nil, nil, nil, err
 		}
 	}
 	if info.Node2Policy != nil {
 		policy2, err = unmarshalPolicy(
-			info.ChannelId, info.Node2Policy, false,
+			info.ChannelId, info.Node2Policy, false, info.Node1Pub,
 		)
 		if err != nil {
 			return nil, nil, nil, err
@@ -741,7 +742,7 @@ func unmarshalChannelInfo(info *lnrpc.ChannelEdge) (*models.ChannelEdgeInfo,
 }
 
 func unmarshalPolicy(channelID uint64, rpcPolicy *lnrpc.RoutingPolicy,
-	node1 bool) (*models.ChannelEdgePolicy, error) {
+	node1 bool, toNodeStr string) (*models.ChannelEdgePolicy, error) {
 
 	var chanFlags lnwire.ChanUpdateChanFlags
 	if !node1 {
@@ -756,6 +757,15 @@ func unmarshalPolicy(channelID uint64, rpcPolicy *lnrpc.RoutingPolicy,
 		return nil, err
 	}
 
+	toNodeB, err := hex.DecodeString(toNodeStr)
+	if err != nil {
+		return nil, err
+	}
+	toNode, err := route.NewVertexFromBytes(toNodeB)
+	if err != nil {
+		return nil, err
+	}
+
 	return &models.ChannelEdgePolicy{
 		ChannelID:     channelID,
 		TimeLockDelta: uint16(rpcPolicy.TimeLockDelta),
@@ -773,6 +783,7 @@ func unmarshalPolicy(channelID uint64, rpcPolicy *lnrpc.RoutingPolicy,
 		),
 		LastUpdate:      time.Unix(int64(rpcPolicy.LastUpdate), 0),
 		ChannelFlags:    chanFlags,
+		ToNode:          toNode,
 		ExtraOpaqueData: extra,
 	}, nil
 }