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

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

Author: rustyrussell

lightningd/connect_control.c

@@ -270,6 +270,13 @@ 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);
+
 	/* We can have multiple connect commands: fail them all */
 	while ((c = find_connect(ld, id)) != NULL) {
 		/* They delete themselves from list */
@@ -494,6 +501,11 @@ 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);
 }
 
 static unsigned connectd_msg(struct subd *connectd, const u8 *msg, const int *fds)

lightningd/peer_control.c

@@ -1750,6 +1750,11 @@ void peer_connected(struct lightningd *ld, const u8 *msg)
 		fatal("Connectd gave bad CONNECT_PEER_CONNECTED message %s",
 		      tal_hex(msg, msg));
 
+	wallet_save_network_event(ld, &id,
+				  NETWORK_EVENT_CONNECT,
+				  hook_payload->incoming ? NULL : connect_reason,
+				  connect_nsec);
+
 	/* If we connected, and it's a normal address */
 	if (!hook_payload->incoming
 	    && hook_payload->addr.itype == ADDR_INTERNAL_WIREADDR
@@ -2098,6 +2103,10 @@ void peer_disconnect_done(struct lightningd *ld, const u8 *msg)
 		fatal("Connectd gave bad PEER_DISCONNECT_DONE message %s",
 		      tal_hex(msg, msg));
 
+	wallet_save_network_event(ld, &id,
+				  NETWORK_EVENT_DISCONNECT,
+				  NULL, duration_nsec);
+
 	/* If we still have peer, it's disconnected now */
 	/* FIXME: We should keep peers until it tells us they're disconnected,
 	 * and not free when no more channels. */

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

@@ -1093,6 +1093,13 @@ 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)
+{ 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(); }