lnrpc: display remote peer features via rpc
This commit is contained in:
4 files changed
+597
-572
No files matched your search
+582
-572
File diff suppressed because it is too large.
Load diff
@@ -1449,6 +1449,9 @@ message Peer {
|
|||||||
|
|
||||||
// The type of sync we are currently performing with this peer.
|
// The type of sync we are currently performing with this peer.
|
||||||
SyncType sync_type = 10 [json_name = "sync_type"];
|
SyncType sync_type = 10 [json_name = "sync_type"];
|
||||||
|
|
||||||
|
/// Features advertised by the remote peer in their init message.
|
||||||
|
repeated Feature features = 11 [json_name = "features"];
|
||||||
}
|
}
|
||||||
|
|
||||||
message ListPeersRequest {
|
message ListPeersRequest {
|
||||||
|
|||||||
@@ -3437,6 +3437,13 @@
|
|||||||
"sync_type": {
|
"sync_type": {
|
||||||
"$ref": "#/definitions/PeerSyncType",
|
"$ref": "#/definitions/PeerSyncType",
|
||||||
"description": "The type of sync we are currently performing with this peer."
|
"description": "The type of sync we are currently performing with this peer."
|
||||||
|
},
|
||||||
|
"features": {
|
||||||
|
"type": "array",
|
||||||
|
"items": {
|
||||||
|
"$ref": "#/definitions/lnrpcFeature"
|
||||||
|
},
|
||||||
|
"description": "/ Features advertised by the remote peer in their init message."
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -2258,6 +2258,10 @@ func (r *rpcServer) ListPeers(ctx context.Context,
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
features := invoicesrpc.CreateRPCFeatures(
|
||||||
|
serverPeer.RemoteFeatures(),
|
||||||
|
)
|
||||||
|
|
||||||
peer := &lnrpc.Peer{
|
peer := &lnrpc.Peer{
|
||||||
PubKey: hex.EncodeToString(nodePub[:]),
|
PubKey: hex.EncodeToString(nodePub[:]),
|
||||||
Address: serverPeer.conn.RemoteAddr().String(),
|
Address: serverPeer.conn.RemoteAddr().String(),
|
||||||
@@ -2268,6 +2272,7 @@ func (r *rpcServer) ListPeers(ctx context.Context,
|
|||||||
SatRecv: satRecv,
|
SatRecv: satRecv,
|
||||||
PingTime: serverPeer.PingTime(),
|
PingTime: serverPeer.PingTime(),
|
||||||
SyncType: lnrpcSyncType,
|
SyncType: lnrpcSyncType,
|
||||||
|
Features: features,
|
||||||
}
|
}
|
||||||
|
|
||||||
resp.Peers = append(resp.Peers, peer)
|
resp.Peers = append(resp.Peers, peer)
|
||||||
|
|||||||
Reference in new issue
Block a user