Function wallet_peer_load

wallet/wallet.c:1276–1330

}

static struct peer *wallet_peer_load(struct wallet *w, const u64 dbid)
{
	const char *addrstr, *err;
	struct peer *peer = NULL;
	struct node_id id;
	struct wireaddr_internal addr;
	struct wireaddr *last_known_addr;
	struct db_stmt *stmt;

	stmt = db_prepare_v2(
	    w->db, SQL("SELECT id, node_id, address, feature_bits, last_known_address FROM peers WHERE id=?;"));
	db_bind_u64(stmt, dbid);
	db_query_prepared(stmt);

	if (!db_step(stmt))
		goto done;

	if (db_col_is_null(stmt, "node_id")) {
		db_col_ignore(stmt, "address");
		db_col_ignore(stmt, "id");
		db_col_ignore(stmt, "feature_bits");
		db_col_ignore(stmt, "last_known_address");
		goto done;
	}

	db_col_node_id(stmt, "node_id", &id);

	/* This can happen for peers last seen on Torv2! */
	addrstr = db_col_strdup(tmpctx, stmt, "address");
	err = parse_wireaddr_internal(tmpctx, addrstr, chainparams_get_ln_port(chainparams), true, &addr);
	if (err) {
		log_unusual(w->log, "Unparsable peer address %s (%s): replacing",
			    addrstr, err);
		err = parse_wireaddr_internal(tmpctx, "127.0.0.1:1", chainparams_get_ln_port(chainparams),
					      false, &addr);
		assert(!err);
	}

	if (db_col_is_null(stmt, "last_known_address")) {
		last_known_addr = NULL;
	} else {
		last_known_addr = db_col_wireaddr(tmpctx, stmt, "last_known_address");
		if (!last_known_addr) {
			log_broken(w->log, "Unparsable lastknown address %s: ignoring",
				   tal_hex(tmpctx, db_col_arr(tmpctx, stmt, "last_known_address", u8)));
		}
	}

	peer = new_peer(w->ld, db_col_u64(stmt, "id"), &id, &addr, last_known_addr,
			db_col_arr(stmt, stmt, "feature_bits", u8), false);

done:
	tal_free(stmt);
	return peer;
}

static struct bitcoin_signature *
wallet_htlc_sigs_load(const tal_t *ctx, struct wallet *w, u64 channelid,