Function wallet_transactions_get

wallet/wallet.c:4765–4872

}

struct wallet_transaction *wallet_transactions_get(struct wallet *w, const tal_t *ctx)
{
	struct db_stmt *stmt;
	size_t count;
	struct wallet_transaction *cur = NULL, *txs = tal_arr(ctx, struct wallet_transaction, 0);
	struct bitcoin_txid last;

	/* Make sure we can check for changing txids */
	memset(&last, 0, sizeof(last));

	stmt = db_prepare_v2(
	    w->db,
	    SQL("SELECT"
		"  t.id"
		", t.rawtx"
		", t.blockheight"
		", t.txindex"
		", t.type as txtype"
		", c2.scid as txchan"
		", a.location"
		", a.idx as ann_idx"
		", a.type as annotation_type"
		", c.scid"
		" FROM"
		"  transactions t LEFT JOIN"
		"  transaction_annotations a ON (a.txid = t.id) LEFT JOIN"
		"  channels c ON (a.channel = c.id) LEFT JOIN"
		"  channels c2 ON (t.channel_id = c2.id) "
		"ORDER BY t.blockheight, t.txindex ASC"));
	db_query_prepared(stmt);

	for (count = 0; db_step(stmt); count++) {
		struct bitcoin_txid curtxid;
		db_col_txid(stmt, "t.id", &curtxid);

		/* If this is a new entry, allocate it in the array and set
		 * the common fields (all fields from the transactions table. */
		if (!bitcoin_txid_eq(&last, &curtxid)) {
			last = curtxid;
			tal_resize(&txs, tal_count(txs) + 1);
			cur = &txs[tal_count(txs) - 1];
			db_col_txid(stmt, "t.id", &cur->id);
			cur->tx = db_col_tx(txs, stmt, "t.rawtx");
			cur->rawtx = db_col_arr(txs, stmt, "t.rawtx", u8);
			/* TX may be unconfirmed. */
			if (!db_col_is_null(stmt, "t.blockheight")) {
				cur->blockheight
					= db_col_int(stmt, "t.blockheight");
				if (!db_col_is_null(stmt, "t.txindex")) {
					cur->txindex
						= db_col_int(stmt, "t.txindex");
				} else {
					cur->txindex = 0;
				}
			} else {
				db_col_ignore(stmt, "t.txindex");
				cur->blockheight = 0;
				cur->txindex = 0;