highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-07-28 13:52:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

rpcserver: fix formatting and grammar issues

Browse Source
This commit is contained in:
Oliver Gugger
2024-11-06 15:30:29 +01:00
parent 870e845a1e
commit 0e5c724b64
1 changed files with 15 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
rpcserver.go
View File

@@ -1806,18 +1806,15 @@ func (r *rpcServer) ConnectPeer(ctx context.Context,
// request. // request.
if in.Timeout != 0 { if in.Timeout != 0 {
timeout = time.Duration(in.Timeout) * time.Second timeout = time.Duration(in.Timeout) * time.Second
rpcsLog.Debugf( rpcsLog.Debugf("[connectpeer] connection timeout is set to %v",
"[connectpeer] connection timeout is set to %v", timeout)
timeout,
)
} }
if err := r.server.ConnectToPeer( if err := r.server.ConnectToPeer(
peerAddr, in.Perm, timeout, peerAddr, in.Perm, timeout,
); err != nil { ); err != nil {
rpcsLog.Errorf( rpcsLog.Errorf("[connectpeer]: error connecting to peer: %v",
"[connectpeer]: error connecting to peer: %v", err, err)
)
return nil, err return nil, err
} }
@@ -8821,8 +8818,9 @@ func (r *rpcServer) RegisterRPCMiddleware(
} }
// SendCustomMessage sends a custom peer message. // SendCustomMessage sends a custom peer message.
func (r *rpcServer) SendCustomMessage(ctx context.Context, req *lnrpc.SendCustomMessageRequest) ( func (r *rpcServer) SendCustomMessage(_ context.Context,
*lnrpc.SendCustomMessageResponse, error) { req *lnrpc.SendCustomMessageRequest) (*lnrpc.SendCustomMessageResponse,
error) {
peer, err := route.NewVertexFromBytes(req.Peer) peer, err := route.NewVertexFromBytes(req.Peer)
if err != nil { if err != nil {
@@ -8833,7 +8831,7 @@ func (r *rpcServer) SendCustomMessage(ctx context.Context, req *lnrpc.SendCustom
peer, lnwire.MessageType(req.Type), req.Data, peer, lnwire.MessageType(req.Type), req.Data,
) )
switch { switch {
case err == ErrPeerNotConnected: case errors.Is(err, ErrPeerNotConnected):
return nil, status.Error(codes.NotFound, err.Error()) return nil, status.Error(codes.NotFound, err.Error())
case err != nil: case err != nil:
return nil, err return nil, err
@@ -8846,7 +8844,8 @@ func (r *rpcServer) SendCustomMessage(ctx context.Context, req *lnrpc.SendCustom
// SubscribeCustomMessages subscribes to a stream of incoming custom peer // SubscribeCustomMessages subscribes to a stream of incoming custom peer
// messages. // messages.
func (r *rpcServer) SubscribeCustomMessages(req *lnrpc.SubscribeCustomMessagesRequest, func (r *rpcServer) SubscribeCustomMessages(
_ *lnrpc.SubscribeCustomMessagesRequest,
server lnrpc.Lightning_SubscribeCustomMessagesServer) error { server lnrpc.Lightning_SubscribeCustomMessagesServer) error {
client, err := r.server.SubscribeCustomMessages() client, err := r.server.SubscribeCustomMessages()
@@ -8879,17 +8878,17 @@ func (r *rpcServer) SubscribeCustomMessages(req *lnrpc.SubscribeCustomMessagesRe
} }
// ListAliases returns the set of all aliases we have ever allocated along with // ListAliases returns the set of all aliases we have ever allocated along with
// their base SCID's and possibly a separate confirmed SCID in the case of // their base SCIDs and possibly a separate confirmed SCID in the case of
// zero-conf. // zero-conf.
func (r *rpcServer) ListAliases(ctx context.Context, func (r *rpcServer) ListAliases(_ context.Context,
in *lnrpc.ListAliasesRequest) (*lnrpc.ListAliasesResponse, error) { _ *lnrpc.ListAliasesRequest) (*lnrpc.ListAliasesResponse, error) {
// Fetch the map of all aliases. // Fetch the map of all aliases.
mapAliases := r.server.aliasMgr.ListAliases() mapAliases := r.server.aliasMgr.ListAliases()
// Fill out the response. This does not include the zero-conf confirmed // Fill out the response. This does not include the zero-conf confirmed
// SCID. Doing so would require more database lookups and it can be // SCID. Doing so would require more database lookups, and it can be
// cross-referenced with the output of listchannels/closedchannels. // cross-referenced with the output of ListChannels/ClosedChannels.
resp := &lnrpc.ListAliasesResponse{ resp := &lnrpc.ListAliasesResponse{
AliasMaps: make([]*lnrpc.AliasMap, 0), AliasMaps: make([]*lnrpc.AliasMap, 0),
} }