msggen: Add ListClosedChannels and overrides

This commit is contained in:
Christian Decker
2023-05-02 13:36:15 +02:00
committed by Rusty Russell
parent 318f35b243
commit bff3b1ca8c
12 changed files with 680 additions and 84 deletions

View File

@@ -847,6 +847,53 @@ def listpeerchannels2py(m):
})
def listclosedchannels_closedchannels_alias2py(m):
return remove_default({
"local": m.local, # PrimitiveField in generate_composite
"remote": m.remote, # PrimitiveField in generate_composite
})
def listclosedchannels_closedchannels_channel_type2py(m):
return remove_default({
"bits": [m.bits for i in m.bits], # ArrayField[primitive] in generate_composite
"names": [str(i) for i in m.names], # ArrayField[composite] in generate_composite
})
def listclosedchannels_closedchannels2py(m):
return remove_default({
"peer_id": hexlify(m.peer_id), # PrimitiveField in generate_composite
"channel_id": hexlify(m.channel_id), # PrimitiveField in generate_composite
"short_channel_id": m.short_channel_id, # PrimitiveField in generate_composite
"opener": str(m.opener), # EnumField in generate_composite
"closer": str(m.closer), # EnumField in generate_composite
"private": m.private, # PrimitiveField in generate_composite
"total_local_commitments": m.total_local_commitments, # PrimitiveField in generate_composite
"total_remote_commitments": m.total_remote_commitments, # PrimitiveField in generate_composite
"total_htlcs_sent": m.total_htlcs_sent, # PrimitiveField in generate_composite
"funding_txid": hexlify(m.funding_txid), # PrimitiveField in generate_composite
"funding_outnum": m.funding_outnum, # PrimitiveField in generate_composite
"leased": m.leased, # PrimitiveField in generate_composite
"funding_fee_paid_msat": amount2msat(m.funding_fee_paid_msat), # PrimitiveField in generate_composite
"funding_fee_rcvd_msat": amount2msat(m.funding_fee_rcvd_msat), # PrimitiveField in generate_composite
"funding_pushed_msat": amount2msat(m.funding_pushed_msat), # PrimitiveField in generate_composite
"total_msat": amount2msat(m.total_msat), # PrimitiveField in generate_composite
"final_to_us_msat": amount2msat(m.final_to_us_msat), # PrimitiveField in generate_composite
"min_to_us_msat": amount2msat(m.min_to_us_msat), # PrimitiveField in generate_composite
"max_to_us_msat": amount2msat(m.max_to_us_msat), # PrimitiveField in generate_composite
"last_commitment_txid": hexlify(m.last_commitment_txid), # PrimitiveField in generate_composite
"last_commitment_fee_msat": amount2msat(m.last_commitment_fee_msat), # PrimitiveField in generate_composite
"close_cause": str(m.close_cause), # EnumField in generate_composite
})
def listclosedchannels2py(m):
return remove_default({
"closedchannels": [listclosedchannels_closedchannels2py(i) for i in m.closedchannels], # ArrayField[composite] in generate_composite
})
def disconnect2py(m):
return remove_default({
})

File diff suppressed because one or more lines are too long

View File

@@ -204,6 +204,11 @@ class NodeStub(object):
request_serializer=node__pb2.ListpeerchannelsRequest.SerializeToString,
response_deserializer=node__pb2.ListpeerchannelsResponse.FromString,
)
self.ListClosedChannels = channel.unary_unary(
'/cln.Node/ListClosedChannels',
request_serializer=node__pb2.ListclosedchannelsRequest.SerializeToString,
response_deserializer=node__pb2.ListclosedchannelsResponse.FromString,
)
self.Disconnect = channel.unary_unary(
'/cln.Node/Disconnect',
request_serializer=node__pb2.DisconnectRequest.SerializeToString,
@@ -497,6 +502,12 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListClosedChannels(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Disconnect(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -762,6 +773,11 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.ListpeerchannelsRequest.FromString,
response_serializer=node__pb2.ListpeerchannelsResponse.SerializeToString,
),
'ListClosedChannels': grpc.unary_unary_rpc_method_handler(
servicer.ListClosedChannels,
request_deserializer=node__pb2.ListclosedchannelsRequest.FromString,
response_serializer=node__pb2.ListclosedchannelsResponse.SerializeToString,
),
'Disconnect': grpc.unary_unary_rpc_method_handler(
servicer.Disconnect,
request_deserializer=node__pb2.DisconnectRequest.FromString,
@@ -1478,6 +1494,23 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ListClosedChannels(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/ListClosedChannels',
node__pb2.ListclosedchannelsRequest.SerializeToString,
node__pb2.ListclosedchannelsResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Disconnect(request,
target,