lightningd/notifications: Add notify_we_lost_state to tell the recove…

…r plugin to start finding ways to recover the node because we have corrupt data.

lightningd/notification.c

@@ -327,6 +327,38 @@ void notify_channel_state_changed(struct lightningd *ld,
 	plugins_notify(ld->plugins, take(n));
 }
 
+static void we_lost_state_notification_serialize(struct json_stream *stream,
+						const struct channel_id *cid,
+						const struct short_channel_id *scid)
+{
+	json_object_start(stream, "we_lost_state");
+	json_add_channel_id(stream, "channel_id", cid);
+	if (scid)
+		json_add_short_channel_id(stream, "short_channel_id", scid);
+	else
+		json_add_null(stream, "short_channel_id");
+	json_add_bool(stream, "unrecoverable", true);
+	json_object_end(stream);
+}
+
+
+REGISTER_NOTIFICATION(we_lost_state,
+		      we_lost_state_notification_serialize);
+
+void notify_we_lost_state(struct lightningd *ld,
+			  const struct channel_id *cid,
+			  const struct short_channel_id *scid)
+{
+	void (*serialize)(struct json_stream *,
+			  const struct channel_id *,
+			  const struct short_channel_id *) = we_lost_state_notification_gen.serialize;
+	struct jsonrpc_notification *n
+		= jsonrpc_notification_start(NULL, we_lost_state_notification_gen.topic);
+	serialize(n->stream, cid, scid);
+	jsonrpc_notification_end(n);
+	plugins_notify(ld->plugins, take(n));
+}
+
 static void forward_event_notification_serialize(struct json_stream *stream,
 						 const struct htlc_in *in,
 						 const struct short_channel_id *scid_out,

lightningd/notification.h

@@ -61,6 +61,10 @@ void notify_channel_state_changed(struct lightningd *ld,
 				  enum state_change cause,
 				  const char *message);
 
+void notify_we_lost_state(struct lightningd *ld,
+			  const struct channel_id *cid,
+			  const struct short_channel_id *scid);
+
 void notify_forward_event(struct lightningd *ld,
 			  const struct htlc_in *in,
 			  /* May be NULL if we don't know. */