Function wallet_peer_save

wallet/wallet.c:2970–3015

}

static void wallet_peer_save(struct wallet *w, struct peer *peer)
{
	const char *addr =
	    fmt_wireaddr_internal(tmpctx, &peer->addr);
	struct db_stmt *stmt =
	    db_prepare_v2(w->db, SQL("SELECT id FROM peers WHERE node_id = ?"));

	db_bind_node_id(stmt, &peer->id);
	db_query_prepared(stmt);

	if (db_step(stmt)) {
		/* So we already knew this peer, just return its dbid */
		peer_set_dbid(peer, db_col_u64(stmt, "id"));
		tal_free(stmt);

		/* Since we're at it update the wireaddr, feature bits */
		stmt = db_prepare_v2(
		    w->db, SQL("UPDATE peers SET address = ?, feature_bits = ? WHERE id = ?"));
		db_bind_text(stmt, addr);
		db_bind_talarr(stmt, peer->their_features);
		db_bind_u64(stmt, peer->dbid);
		db_exec_prepared_v2(take(stmt));

	} else {
		/* Unknown peer, create it from scratch */
		tal_free(stmt);
		stmt = db_prepare_v2(w->db,
				     SQL("INSERT INTO peers (node_id, address, feature_bits) VALUES (?, ?, ?);")
			);
		db_bind_node_id(stmt, &peer->id);
		db_bind_text(stmt, addr);
		db_bind_talarr(stmt, peer->their_features);
		db_exec_prepared_v2(stmt);
		peer_set_dbid(peer, db_last_insert_id_v2(take(stmt)));
	}

	if (peer->last_known_addr) {
		u8 *wire = tal_arr(tmpctx, u8, 0);
		towire_wireaddr(&wire, peer->last_known_addr);
		stmt = db_prepare_v2(w->db,
				     SQL("UPDATE peers SET last_known_address = ? WHERE id = ?;"));
		db_bind_talarr(stmt, wire);
		db_bind_u64(stmt, peer->dbid);
		db_exec_prepared_v2(take(stmt));
	}
}

bool channel_exists_by_id(struct wallet *w, u64 dbid) {
	struct db_stmt *stmt;