lightningd: notification for onionmessage_forward_fail.

Changelog-Added: Plugins: new notification `onionmessage_forward_fail`.
Signed-off-by: Rusty Russell <[email protected]>

Author: rustyrussell

lightningd/connect_control.c

@@ -369,7 +369,31 @@ static void handle_custommsg_in(struct lightningd *ld, const u8 *msg)
 
 static void handle_onionmsg_forward_fail(struct lightningd *ld, const u8 *msg)
 {
-	/* FIXME: Do something! */
+	struct node_id source;
+	u8 *incoming;
+	struct pubkey path_key;
+	u8 *outgoing;
+	struct sciddir_or_pubkey *next;
+
+	if (!fromwire_connectd_onionmsg_forward_fail(tmpctx, msg,
+						     &source,
+						     &incoming,
+						     &path_key,
+						     &outgoing,
+						     &next)) {
+		log_broken(ld->log, "Malformed onionmsg_forward_fail: %s",
+			   tal_hex(tmpctx, msg));
+		return;
+	}
+
+	if (tal_count(outgoing) && !next) {
+		log_broken(ld->log, "onionmsg_forward_fail missing next: %s",
+			   tal_hex(tmpctx, msg));
+		return;
+	}
+
+	notify_onionmessage_forward_fail(ld, &source, incoming,
+					 &path_key, outgoing, next);
 }
 
 static void connectd_start_shutdown_reply(struct subd *connectd,

lightningd/notification.c

@@ -176,6 +176,45 @@ void notify_custommsg(struct lightningd *ld,
 	notify_send(ld, n);
 }
 
+static void onionmessage_forward_fail_serialize(struct json_stream *stream,
+						const struct node_id *source,
+						const u8 *incoming,
+						const struct pubkey *path_key,
+						const u8 *outgoing,
+						const struct sciddir_or_pubkey *next_node)
+{
+	json_add_node_id(stream, "source", source);
+	json_add_hex_talarr(stream, "incoming", incoming);
+	json_add_pubkey(stream, "path_key", path_key);
+	if (tal_count(outgoing) != 0) {
+		json_add_hex_talarr(stream, "outgoing", outgoing);
+		if (next_node->is_pubkey)
+			json_add_pubkey(stream, "next_node_id", &next_node->pubkey);
+		else
+			json_add_short_channel_id_dir(stream, "next_short_channel_id_dir",
+						      next_node->scidd);
+	}
+}
+
+REGISTER_NOTIFICATION(onionmessage_forward_fail);
+
+void notify_onionmessage_forward_fail(struct lightningd *ld,
+				      const struct node_id *source,
+				      const u8 *incoming,
+				      const struct pubkey *path_key,
+				      const u8 *outgoing,
+				      const struct sciddir_or_pubkey *next_node)
+{
+	struct jsonrpc_notification *n = notify_start("onionmessage_forward_fail");
+	onionmessage_forward_fail_serialize(n->stream,
+					    source,
+					    incoming,
+					    path_key,
+					    outgoing,
+					    next_node);
+	notify_send(ld, n);
+}
+
 static void invoice_payment_notification_serialize(struct json_stream *stream,
 						   struct amount_msat amount,
 						   const struct preimage *preimage,

lightningd/notification.h

@@ -99,6 +99,13 @@ void notify_openchannel_peer_sigs(struct lightningd *ld,
 void notify_channel_open_failed(struct lightningd *ld,
                                 const struct channel_id *cid);
 
+void notify_onionmessage_forward_fail(struct lightningd *ld,
+				      const struct node_id *source,
+				      const u8 *incoming,
+				      const struct pubkey *path_key,
+				      const u8 *outgoing,
+				      const struct sciddir_or_pubkey *next_node);
+
 /* Tell this plugin about deprecated flag for next: returns false
  * if doesn't subscribe */
 bool notify_deprecated_oneshot(struct lightningd *ld,