Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions .msggen.json
Original file line number Diff line number Diff line change
Expand Up @@ -1552,6 +1552,9 @@
"DelInvoice.status": 7,
"DelInvoice.updated_index": 13
},
"DelnetworkeventRequest": {
"DelNetworkEvent.created_index": 1
},
"DelpayPayments": {
"DelPay.payments[].amount_msat": 8,
"DelPay.payments[].amount_sent_msat": 5,
Expand Down Expand Up @@ -6841,6 +6844,14 @@
"added": "v23.08",
"deprecated": null
},
"DelNetworkEvent": {
"added": "v25.12",
"deprecated": null
},
"DelNetworkEvent.created_index": {
"added": "v25.12",
"deprecated": null
},
"DelPay": {
"added": "pre-v0.10.1",
"deprecated": null
Expand Down
8 changes: 8 additions & 0 deletions cln-grpc/proto/node.proto

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

26 changes: 26 additions & 0 deletions cln-grpc/src/convert.rs

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

32 changes: 32 additions & 0 deletions cln-grpc/src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4594,6 +4594,38 @@ impl Node for Server

}

async fn del_network_event(
&self,
request: tonic::Request<pb::DelnetworkeventRequest>,
) -> Result<tonic::Response<pb::DelnetworkeventResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::DelnetworkeventRequest = req.into();
debug!("Client asked for del_network_event");
trace!("del_network_event request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::DelNetworkEvent(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method DelNetworkEvent: {:?}", e)))?;
match result {
Response::DelNetworkEvent(r) => {
trace!("del_network_event response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call DelNetworkEvent",
r
)
)),
}

}



type SubscribeBlockAddedStream = NotificationStream<pb::BlockAddedNotification>;
Expand Down
39 changes: 39 additions & 0 deletions cln-rpc/src/model.rs

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions contrib/msggen/msggen/schema.json
Original file line number Diff line number Diff line change
Expand Up @@ -10786,6 +10786,7 @@
"type": "object",
"rpc": "delnetworkevent",
"title": "Command for removing a listnetworkevents entry",
"added": "v25.12",
"description": [
"The **delnetworkevent** RPC command removes a single event from **listnetworkevents**, using the uniquely-identifying *created_index*.",
"",
Expand Down
2 changes: 1 addition & 1 deletion contrib/msggen/msggen/utils/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@
"ListChannelMoves",
"ListChainMoves",
"ListNetworkEvents",
# "DelNetworkEvent",
"DelNetworkEvent",
]

grpc_notification_names = [
Expand Down
74 changes: 39 additions & 35 deletions contrib/pyln-grpc-proto/pyln/grpc/node_pb2.py

Large diffs are not rendered by default.

43 changes: 43 additions & 0 deletions contrib/pyln-grpc-proto/pyln/grpc/node_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -739,6 +739,11 @@ def __init__(self, channel):
request_serializer=node__pb2.ListnetworkeventsRequest.SerializeToString,
response_deserializer=node__pb2.ListnetworkeventsResponse.FromString,
_registered_method=True)
self.DelNetworkEvent = channel.unary_unary(
'/cln.Node/DelNetworkEvent',
request_serializer=node__pb2.DelnetworkeventRequest.SerializeToString,
response_deserializer=node__pb2.DelnetworkeventResponse.FromString,
_registered_method=True)
self.SubscribeBlockAdded = channel.unary_stream(
'/cln.Node/SubscribeBlockAdded',
request_serializer=node__pb2.StreamBlockAddedRequest.SerializeToString,
Expand Down Expand Up @@ -1620,6 +1625,12 @@ def ListNetworkEvents(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def DelNetworkEvent(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 SubscribeBlockAdded(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
Expand Down Expand Up @@ -2364,6 +2375,11 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.ListnetworkeventsRequest.FromString,
response_serializer=node__pb2.ListnetworkeventsResponse.SerializeToString,
),
'DelNetworkEvent': grpc.unary_unary_rpc_method_handler(
servicer.DelNetworkEvent,
request_deserializer=node__pb2.DelnetworkeventRequest.FromString,
response_serializer=node__pb2.DelnetworkeventResponse.SerializeToString,
),
'SubscribeBlockAdded': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBlockAdded,
request_deserializer=node__pb2.StreamBlockAddedRequest.FromString,
Expand Down Expand Up @@ -6212,6 +6228,33 @@ def ListNetworkEvents(request,
metadata,
_registered_method=True)

@staticmethod
def DelNetworkEvent(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/DelNetworkEvent',
node__pb2.DelnetworkeventRequest.SerializeToString,
node__pb2.DelnetworkeventResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def SubscribeBlockAdded(request,
target,
Expand Down
5 changes: 5 additions & 0 deletions contrib/pyln-testing/pyln/testing/grpc2py.py
Original file line number Diff line number Diff line change
Expand Up @@ -3371,6 +3371,11 @@ def listnetworkevents2py(m):
})


def delnetworkevent2py(m):
return remove_default({
})


def decodekeysend_routes2py(m): # manual override
return remove_default({
"expirydelta": m.expirydelta,
Expand Down
1 change: 1 addition & 0 deletions doc/Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ MARKDOWNPAGES := doc/addgossip.7 \
doc/deldatastore.7 \
doc/delforward.7 \
doc/delinvoice.7 \
doc/delnetworkevent.7 \
doc/delpay.7 \
doc/deprecations.7 \
doc/dev-forget-channel.7 \
Expand Down
1 change: 1 addition & 0 deletions doc/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ Core Lightning Documentation
deldatastore <deldatastore.7.md>
delforward <delforward.7.md>
delinvoice <delinvoice.7.md>
delnetworkevent <delnetworkevent.7.md>
delpay <delpay.7.md>
deprecations <deprecations.7.md>
dev-forget-channel <dev-forget-channel.7.md>
Expand Down
1 change: 1 addition & 0 deletions doc/schemas/delnetworkevent.json
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
"type": "object",
"rpc": "delnetworkevent",
"title": "Command for removing a listnetworkevents entry",
"added": "v25.12",
"description": [
"The **delnetworkevent** RPC command removes a single event from **listnetworkevents**, using the uniquely-identifying *created_index*.",
"",
Expand Down
Loading