Function insert_channel_mvt

wallet/wallet.c:6890–6936

}

static u64 insert_channel_mvt(struct lightningd *ld,
			      struct db *db,
			      const struct channel_coin_mvt *chan_mvt)
{
	struct db_stmt *stmt;
	u64 id;

	stmt = db_prepare_v2(db,
			     SQL("INSERT INTO channel_moves ("
				 " id,"
				 " account_channel_id,"
				 " account_nonchannel_id,"
				 " credit_or_debit,"
				 " tag_bitmap,"
				 " timestamp,"
				 " payment_hash,"
				 " payment_part_id,"
				 " payment_group_id,"
				 " fees) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?);"));
	id = channel_mvt_index_created(ld, db,
				       &chan_mvt->account,
				       chan_mvt->credit, chan_mvt->debit);
	db_bind_u64(stmt, id);
	db_bind_mvt_account_id(stmt, db, &chan_mvt->account);
	db_bind_credit_debit(stmt, chan_mvt->credit, chan_mvt->debit);
	db_bind_mvt_tags(stmt, chan_mvt->tags);
	db_bind_u64(stmt, chan_mvt->timestamp);
	/* push funding / leases don't have a payment_hash */
	if (chan_mvt->payment_hash)
		db_bind_sha256(stmt, chan_mvt->payment_hash);
	else
		db_bind_null(stmt);
	if (chan_mvt->part_and_group) {
		db_bind_u64(stmt, chan_mvt->part_and_group->part_id);
		db_bind_u64(stmt, chan_mvt->part_and_group->group_id);
	} else {
		db_bind_null(stmt);
		db_bind_null(stmt);
	}
	db_bind_amount_msat(stmt, chan_mvt->fees);
	db_exec_prepared_v2(take(stmt));

	notify_channel_mvt(ld, chan_mvt, id);
	tal_free_if_taken(chan_mvt);

	return id;
}

void wallet_save_channel_mvt(struct lightningd *ld,
			     const struct channel_coin_mvt *chan_mvt)