channeld: provide alt-addr to peer upon channel establish

Author: maxrantil

channeld/channeld.c

@@ -539,6 +539,17 @@ static void handle_peer_splice_locked(struct peer *peer, const u8 *msg)
 	check_mutual_splice_locked(peer);
 }
 
+static void send_peer_my_alt_addr(struct peer *peer)
+{
+	/* Send my alt addr to peer db */
+	u8 *peer_msg = towire_peer_alt_addr(peer, peer->my_alt_addr);
+	peer_write(peer->pps, take(peer_msg));
+
+	/* We need the addrs in my own db too for later whitelist confirmation */
+	u8 *msg = towire_channeld_my_alt_addr(tmpctx, peer->my_alt_addr);
+	wire_sync_write(MASTER_FD, take(msg));
+}
+
 static void handle_peer_channel_ready(struct peer *peer, const u8 *msg)
 {
 	struct channel_id chanid;
@@ -4164,6 +4175,9 @@ static void peer_in(struct peer *peer, const u8 *msg)
 
 	check_tx_abort(peer, msg);
 
+	if (peer->my_alt_addr)
+		send_peer_my_alt_addr(peer);
+
 	/* If we're in STFU mode and aren't waiting for a STFU mode
 	 * specific message, the only valid message was tx_abort */
 	if (is_stfu_active(peer) && !peer->stfu_wait_single_msg) {
@@ -4296,6 +4310,7 @@ static void peer_in(struct peer *peer, const u8 *msg)
 	case WIRE_ONION_MESSAGE:
 	case WIRE_PEER_STORAGE:
 	case WIRE_YOUR_PEER_STORAGE:
+	case WIRE_PEER_ALT_ADDR:
 		abort();
 	}
 
@@ -5666,6 +5681,18 @@ static void handle_dev_quiesce(struct peer *peer, const u8 *msg)
 	maybe_send_stfu(peer);
 }
 
+static void handle_channeld_peer_alt_addr(struct peer *peer, const u8 *msg)
+{
+	u8 *my_alt_addr;
+
+	if (!fromwire_channeld_peer_alt_addr(peer, msg, &my_alt_addr))
+		master_badmsg(WIRE_CHANNELD_PEER_ALT_ADDR, msg);
+
+	u8 *peer_msg = towire_peer_alt_addr(peer, my_alt_addr);
+	peer_write(peer->pps, take(peer_msg));
+	tal_free(my_alt_addr);
+}
+
 static void req_in(struct peer *peer, const u8 *msg)
 {
 	enum channeld_wire t = fromwire_peektype(msg);
@@ -5705,6 +5732,9 @@ static void req_in(struct peer *peer, const u8 *msg)
 	case WIRE_CHANNELD_SEND_ERROR:
 		handle_send_error(peer, msg);
 		return;
+	case WIRE_CHANNELD_PEER_ALT_ADDR:
+		handle_channeld_peer_alt_addr(peer, msg);
+		return;
 	case WIRE_CHANNELD_SPLICE_INIT:
 		handle_splice_init(peer, msg);
 		return;
@@ -5768,6 +5798,7 @@ static void req_in(struct peer *peer, const u8 *msg)
 	case WIRE_CHANNELD_SPLICE_STATE_ERROR:
 	case WIRE_CHANNELD_LOCAL_ANCHOR_INFO:
 	case WIRE_CHANNELD_REESTABLISHED:
+	case WIRE_CHANNELD_MY_ALT_ADDR:
 		break;
 	}
 	master_badmsg(-1, msg);

channeld/channeld_wire.csv

@@ -350,3 +350,13 @@ msgdata,channeld_upgraded,new_type,channel_type,
 # Tell peer about our latest and greatest blockheight.
 msgtype,channeld_blockheight,1012
 msgdata,channeld_blockheight,blockheight,u32,
+
+# master -> channeld: send peer our alternative addresses
+msgtype,channeld_peer_alt_addr,1035
+msgdata,channeld_peer_alt_addr,alt_addr_len,u16,
+msgdata,channeld_peer_alt_addr,alt_addr,u8,alt_addr_len,
+
+# channeld -> master: send our alternative addresses to our db
+msgtype,channeld_my_alt_addr,1037
+msgdata,channeld_my_alt_addr,alt_addr_len,u16,
+msgdata,channeld_my_alt_addr,alt_addr,u8,alt_addr_len,

common/gossmap.c

@@ -1619,6 +1619,7 @@ const void *gossmap_stream_next(const tal_t *ctx,
 		case WIRE_REPLY_CHANNEL_RANGE:
 		case WIRE_GOSSIP_TIMESTAMP_FILTER:
 		case WIRE_ONION_MESSAGE:
+		case WIRE_PEER_ALT_ADDR:
 			break;
 		}
 	}

common/interactivetx.c

@@ -186,6 +186,7 @@ static u8 *read_next_msg(const tal_t *ctx,
 		case WIRE_SPLICE:
 		case WIRE_SPLICE_ACK:
 		case WIRE_SPLICE_LOCKED:
+		case WIRE_PEER_ALT_ADDR:
 		*error = tal_fmt(ctx,
 				 "Received invalid message from peer: %d", t);
 		return NULL;
@@ -736,6 +737,7 @@ char *process_interactivetx_updates(const tal_t *ctx,
 		case WIRE_SPLICE_ACK:
 		case WIRE_STFU:
 		case WIRE_SPLICE_LOCKED:
+		case WIRE_PEER_ALT_ADDR:
 			return tal_fmt(ctx, "Unexpected wire message %s",
 				       tal_hex(ctx, msg));
 		}

connectd/connectd.c

@@ -50,6 +50,7 @@
 #include <sys/types.h>
 #include <sys/wait.h>
 #include <unistd.h>
+#include <wire/peer_wiregen.h>
 #include <wire/wire_io.h>
 #include <wire/wire_sync.h>
 
@@ -518,6 +519,18 @@ static struct io_plan *connection_in(struct io_conn *conn,
 	return conn_in(conn, &conn_in_arg);
 }
 
+void handle_peer_alt_addr_in(struct peer *peer, const u8 *msg)
+{
+	u8 *p_alt_addr;
+
+	if (!fromwire_peer_alt_addr(peer, msg, &p_alt_addr))
+		master_badmsg(WIRE_PEER_ALT_ADDR, msg);
+
+	u8 *fwd_msg = towire_connectd_peer_alt_addr(tmpctx, &peer->id, p_alt_addr);
+	daemon_conn_send(peer->daemon->master, take(fwd_msg));
+	tal_free(p_alt_addr);
+}
+
 /*~ <hello>I speak web socket</hello>.
  *
  * Actually that's dumb, websocket (aka rfc6455) looks nothing like that. */
@@ -2249,6 +2262,7 @@ static struct io_plan *recv_req(struct io_conn *conn,
 	case WIRE_CONNECTD_PEER_DISCONNECT_DONE:
 	case WIRE_CONNECTD_START_SHUTDOWN_REPLY:
 	case WIRE_CONNECTD_INJECT_ONIONMSG_REPLY:
+	case WIRE_CONNECTD_PEER_ALT_ADDR:
 		break;
 	}
 

connectd/connectd.h

@@ -336,6 +336,9 @@ void update_recent_timestamp(struct daemon *daemon, struct gossmap *gossmap);
 /* add erros to error list */
 void add_errors_to_error_list(struct connecting *connect, const char *error);
 
+/* Handles alternative address message from peer. */
+void handle_peer_alt_addr_in(struct peer *peer, const u8 *msg);
+
 /* Called by peer_exchange_initmsg if successful. */
 struct io_plan *peer_connected(struct io_conn *conn,
 			       struct daemon *daemon,

connectd/connectd_wire.csv

@@ -187,3 +187,9 @@ msgtype,connectd_dev_exhaust_fds,2036
 # master -> connect: set artificial maximum reply_channel_range size.
 msgtype,connectd_dev_set_max_scids_encode_size,2035
 msgdata,connectd_dev_set_max_scids_encode_size,max,u32,
+
+# connectd -> master: incoming alternative connection address from peer
+msgtype,connectd_peer_alt_addr,2037
+msgdata,connectd_peer_alt_addr,id,node_id,
+msgdata,connectd_peer_alt_addr,addr_len,u8,
+msgdata,connectd_peer_alt_addr,addr,byte,addr_len,

connectd/gossip_rcvd_filter.c

@@ -95,6 +95,7 @@ static bool is_msg_gossip_broadcast(const u8 *cursor)
 	case WIRE_SPLICE:
 	case WIRE_SPLICE_ACK:
 	case WIRE_SPLICE_LOCKED:
+	case WIRE_PEER_ALT_ADDR:
 		break;
 	}
 	return false;

connectd/gossip_store.c

@@ -98,6 +98,7 @@ static bool public_msg_type(enum peer_wire type)
 	case WIRE_SPLICE:
 	case WIRE_SPLICE_ACK:
 	case WIRE_SPLICE_LOCKED:
+	case WIRE_PEER_ALT_ADDR:
 		return false;
 	case WIRE_CHANNEL_ANNOUNCEMENT:
 	case WIRE_NODE_ANNOUNCEMENT:

connectd/multiplex.c

@@ -326,6 +326,7 @@ static bool is_urgent(enum peer_wire type)
 	case WIRE_SPLICE:
 	case WIRE_SPLICE_ACK:
 	case WIRE_SPLICE_LOCKED:
+	case WIRE_PEER_ALT_ADDR:
 		return false;
 
 	/* These are time-sensitive, and so send without delay. */
@@ -754,6 +755,9 @@ static bool handle_message_locally(struct peer *peer, const u8 *msg)
  	} else if (type == WIRE_QUERY_SHORT_CHANNEL_IDS) {
 		handle_query_short_channel_ids(peer, msg);
 		return true;
+	} else if (type == WIRE_PEER_ALT_ADDR) {
+		handle_peer_alt_addr_in(peer, msg);
+		return true;
 	} else if (handle_custommsg(peer->daemon, peer, msg)) {
 		return true;
 	}