Function migrate_setup_coinmoves

wallet/wallet.c:7689–7817

An existing node without accounting. Fill in what we have so far. */

/* An existing node without accounting.  Fill in what we have so far. */
void migrate_setup_coinmoves(struct lightningd *ld, struct db *db)
{
	struct utxo **utxos = db_get_unspent_utxos(tmpctx, db);
	struct db_stmt *stmt;
	u64 base_timestamp = clock_time().ts.tv_sec - 2;

	for (size_t i = 0; i < tal_count(utxos); i++) {
		struct chain_coin_mvt *mvt;

		/* Only confirmed ones */
		if (!utxos[i]->blockheight)
			continue;
		mvt = new_coin_wallet_deposit(tmpctx,
					       &utxos[i]->outpoint,
					       *utxos[i]->blockheight,
					       utxos[i]->amount,
					       mk_mvt_tags(MVT_DEPOSIT));
		insert_chain_mvt(ld, db, mvt);
	}

	/* Now channels.  We create the open event, and then pushed/leased,
	 * the finally fixup with a journal entry. */
	stmt = db_prepare_v2(db, SQL("SELECT"
				     "  p.node_id"
				     ", scid"
				     ", full_channel_id"
				     ", funding_tx_id"
				     ", funding_tx_outnum"
				     ", funder"
				     ", push_msatoshi"
				     ", lease_commit_sig"
				     ", funding_satoshi"
				     ", our_funding_satoshi"
				     ", msatoshi_local"
				     " FROM channels c"
				     " JOIN peers p ON c.peer_id = p.id"
				     " WHERE c.scid IS NOT NULL"
				     "   AND c.state != ?;"));
	db_bind_int(stmt, CLOSED);
	db_query_prepared(stmt);

	while (db_step(stmt)) {
		struct chain_coin_mvt *mvt;
		struct bitcoin_outpoint funding;
		struct channel_id cid;
		struct node_id peerid;
		struct amount_sat funding_sat, our_funding_sat;
		struct amount_msat start_balance, our_msat, push_msat;
		struct short_channel_id scid;
		enum side opener;
		bool is_leased;

		db_col_node_id(stmt, "p.node_id", &peerid);
		scid = db_col_short_channel_id(stmt, "scid");
		db_col_txid(stmt, "funding_tx_id", &funding.txid);
		funding.n = db_col_int(stmt, "funding_tx_outnum");
		db_col_channel_id(stmt, "full_channel_id", &cid);
		opener = db_col_int(stmt, "funder");