msggen: add channel_state_changed notification

Changelog-None

Author: daywalker90

.msggen.json

@@ -24,6 +24,14 @@
             "channel": 2,
             "onchain_fee": 0
         },
+        "Channel_state_changedCause": {
+            "local": 1,
+            "onchain": 5,
+            "protocol": 4,
+            "remote": 3,
+            "unknown": 0,
+            "user": 2
+        },
         "CloseType": {
             "mutual": 0,
             "unilateral": 1,
@@ -1016,6 +1024,16 @@
             "channel_opened.funding_txid": 3,
             "channel_opened.id": 1
         },
+        "ChannelStateChangedNotification": {
+            "channel_state_changed.cause": 7,
+            "channel_state_changed.channel_id": 2,
+            "channel_state_changed.message": 8,
+            "channel_state_changed.new_state": 6,
+            "channel_state_changed.old_state": 5,
+            "channel_state_changed.peer_id": 1,
+            "channel_state_changed.short_channel_id": 3,
+            "channel_state_changed.timestamp": 4
+        },
         "CheckmessageRequest": {
             "CheckMessage.message": 1,
             "CheckMessage.pubkey": 3,
@@ -13091,6 +13109,42 @@
             "added": "pre-v0.10.1",
             "deprecated": null
         },
+        "channel_state_changed": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.cause": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.channel_id": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.message": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.new_state": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.old_state": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.peer_id": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.short_channel_id": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
+        "channel_state_changed.timestamp": {
+            "added": "pre-v0.10.1",
+            "deprecated": null
+        },
         "connect": {
             "added": "pre-v0.10.1",
             "deprecated": null

cln-grpc/proto/node.proto

@@ -37,6 +37,8 @@ enum ChannelState {
 	DualopendOpenInit = 9;
 	DualopendAwaitingLockin = 10;
 	ChanneldAwaitingSplice = 11;
+	DualopendOpenCommitted = 12;
+	DualopendOpenCommittReady = 13;
 }
 
 enum HtlcState {
@@ -62,8 +64,6 @@ enum HtlcState {
 	SentRemoveAckRevocation = 19;
 }
 
-message ChannelStateChangeCause {}
-
 message Outpoint {
 	bytes txid = 1;
 	uint32 outnum = 2;

cln-grpc/proto/primitives.proto

@@ -4463,4 +4463,29 @@ impl Node for Server
         };
         Ok(tonic::Response::new(result))
     }
+
+
+    type SubscribeChannelStateChangedStream = NotificationStream<pb::ChannelStateChangedNotification>;
+
+    async fn subscribe_channel_state_changed(
+        &self,
+        _request : tonic::Request<pb::StreamChannelStateChangedRequest>
+    ) -> Result<tonic::Response<Self::SubscribeChannelStateChangedStream>, tonic::Status> {
+        let receiver = self.events.subscribe();
+        let stream = BroadcastStream::new(receiver);
+        let boxed = Box::pin(stream);
+
+        let result = NotificationStream {
+            inner : boxed,
+            fn_filter_map : |x| {
+                match x {
+                    Notification::ChannelStateChanged(x) => {
+                        Some(x.into())
+                    }
+                    _ => None
+                }
+            }
+        };
+        Ok(tonic::Response::new(result))
+    }
 }