Function find_duplicate_chain_move

wallet/wallet.c:7014–7084

}

static bool find_duplicate_chain_move(struct db *db,
				      const char *nonchannel_acctname,
				      /* 0 if none */
				      u64 channel_dbid,
				      const struct bitcoin_outpoint *outpoint,
				      /* optional */
				      const struct bitcoin_txid *spending_txid,
				      struct mvt_tags tags,
				      u64 id_ceiling)
{
	struct db_stmt *stmt;
	u64 nonchannel_id;

	nonchannel_id = move_accounts_id(db, nonchannel_acctname, false);

	stmt = db_prepare_v2(db,
			     SQL("SELECT"
				 "  spending_txid, tag_bitmap, account_channel_id, account_nonchannel_id"
				 " FROM chain_moves"
				 " WHERE "
				 "  utxo = ?"
				 " AND "
				 "  id < ?"));
	db_bind_outpoint(stmt, outpoint);
	db_bind_u64(stmt, id_ceiling);
	db_query_prepared(stmt);

	/* Check that spending_txid and primary_tag match.  We could
	 * probably just match on spending_txid, but this is robust. */
	while (db_step(stmt)) {
		struct mvt_tags these_tags;
		u64 this_nonchannel_id, this_channel_id;
		bool have_spending_txid;

		/* Access this now so it never complains we don't */
		these_tags = db_col_mvt_tags(stmt, "tag_bitmap");
		have_spending_txid = !db_col_is_null(stmt, "spending_txid");
		this_nonchannel_id = db_col_is_null(stmt, "account_nonchannel_id") ? 0 : db_col_u64(stmt, "account_nonchannel_id");
		this_channel_id = db_col_is_null(stmt, "account_channel_id") ? 0 : db_col_u64(stmt, "account_channel_id");

		/* Either nonchannel id, or channel id must match */
		if (nonchannel_id != this_nonchannel_id
		    && channel_dbid != this_channel_id) {
			continue;
		}

		/* spending_txid must match */
		if (spending_txid) {
			struct bitcoin_txid txid;
			if (!have_spending_txid)
				continue;
			db_col_txid(stmt, "spending_txid", &txid);
			/* This would only happen for reorgs */
			if (!bitcoin_txid_eq(&txid, spending_txid))
				continue;
		} else {
			if (have_spending_txid)
				continue;