lightnind: add connectd's reported events to the db.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>

Author: rustyrussell

lightningd/connect_control.c

@@ -262,6 +262,14 @@ static void connect_failed(struct lightningd *ld,
 {
 	struct connect *c;
 
+	/* Don't record twice. */
+	if (errcode != CONNECT_DISCONNECTED_DURING)
+		wallet_save_network_event(ld, id,
+					  NETWORK_EVENT_CONNECTFAIL,
+					  errmsg,
+					  connect_nsec,
+					  connect_attempted);
+
 	/* We can have multiple connect commands: fail them all */
 	while ((c = find_connect(ld, id)) != NULL) {
 		/* They delete themselves from list */
@@ -490,6 +498,12 @@ static void handle_ping_latency(struct lightningd *ld, const u8 *msg)
 
 	log_peer_trace(ld->log, &id, "Ping latency: %"PRIu64"nsec",
 		       nsec);
+
+	wallet_save_network_event(ld, &id,
+				  NETWORK_EVENT_PING,
+				  NULL,
+				  nsec,
+				  false);
 }
 
 static unsigned connectd_msg(struct subd *connectd, const u8 *msg, const int *fds)

lightningd/peer_control.c

@@ -1744,6 +1744,12 @@ void handle_peer_connected(struct lightningd *ld, const u8 *msg)
 		connect_nsec = 0;
 	}
 
+	wallet_save_network_event(ld, &id,
+				  NETWORK_EVENT_CONNECT,
+				  hook_payload->incoming ? NULL : connect_reason,
+				  connect_nsec,
+				  false);
+
 	/* If we connected, and it's a normal address */
 	if (!hook_payload->incoming
 	    && hook_payload->addr.itype == ADDR_INTERNAL_WIREADDR
@@ -2089,6 +2095,10 @@ static void peer_disconnected(struct lightningd *ld,
 	struct disconnect_command *i, *next;
 	struct peer *p;
 
+	wallet_save_network_event(ld, id,
+				  NETWORK_EVENT_DISCONNECT,
+				  NULL, connected_time_nsec, false);
+
 	/* If we still have peer, it's disconnected now */
 	p = peer_by_id(ld, id);
 	if (p) {

lightningd/test/run-invoice-select-inchan.c

@@ -687,6 +687,14 @@ char *wallet_offer_find(const tal_t *ctx UNNEEDED,
 			enum offer_status *status)
 
 { fprintf(stderr, "wallet_offer_find called!\n"); abort(); }
+/* Generated stub for wallet_save_network_event */
+void wallet_save_network_event(struct lightningd *ld UNNEEDED,
+			       const struct node_id *peer_id UNNEEDED,
+			       enum network_event etype UNNEEDED,
+			       const char *reason UNNEEDED,
+			       u64 duration_nsec UNNEEDED,
+			       bool connect_attempted UNNEEDED)
+{ fprintf(stderr, "wallet_save_network_event called!\n"); abort(); }
 /* Generated stub for wallet_total_forward_fees */
 struct amount_msat wallet_total_forward_fees(struct wallet *w UNNEEDED)
 { fprintf(stderr, "wallet_total_forward_fees called!\n"); abort(); }