Differential D19800 Diff 58999 modules/ecash-wallet/src/wallet.test.ts

Changeset View

Standalone View

modules/ecash-wallet/src/wallet.test.ts

This file is larger than 256 KB, so syntax highlighting is disabled by default.

Show All 37 Lines	import {
Token,		Token,
TokenType,		TokenType,
Tx as ChronikTx,		Tx as ChronikTx,
TokenStatus,		TokenStatus,
} from 'chronik-client';		} from 'chronik-client';
import { MockChronikClient } from 'mock-chronik-client';		import { MockChronikClient } from 'mock-chronik-client';
import {		import {
Wallet,		Wallet,
		CONSOLIDATE_UTXOS_BATCHSIZE,
		MAX_TX_SERSIZE_ERROR_CODE,
		MaxTxSersizeError,
validateTokenActions,		validateTokenActions,
getActionTotals,		getActionTotals,
getTokenType,		getTokenType,
finalizeOutputs,		finalizeOutputs,
selectUtxos,		selectUtxos,
SatsSelectionStrategy,		SatsSelectionStrategy,
paymentOutputsToTxOutputs,		paymentOutputsToTxOutputs,
getNftChildGenesisInput,		getNftChildGenesisInput,
▲ Show 20 Lines • Show All 7,574 Lines • ▼ Show 20 Lines	describe('getMaxP2pkhOutputs', () => {
context('Edge cases', () => {		context('Edge cases', () => {
it('Handles zero inputs correctly, tho in practice this tx is not happening', () => {		it('Handles zero inputs correctly, tho in practice this tx is not happening', () => {
expect(getMaxP2pkhOutputs(0, 100)).to.equal(2937);		expect(getMaxP2pkhOutputs(0, 100)).to.equal(2937);
});		});
});		});

context('Error cases', () => {		context('Error cases', () => {
it('Throws error when inputs (just) exceeds MAX_TX_SERSIZE', () => {		it('Throws error when inputs (just) exceeds MAX_TX_SERSIZE', () => {
expect(() => getMaxP2pkhOutputs(709, 0)).to.throw(		let caught: unknown;
`Total inputs exceed maxTxSersize of ${MAX_TX_SERSIZE} bytes. You must consolidate utxos to fulfill this action.`,		try {
);		getMaxP2pkhOutputs(709, 0);
		} catch (e) {
		caught = e;
		}
		expect(caught).to.be.instanceOf(MaxTxSersizeError);
		const mx = caught as MaxTxSersizeError;
		expect(mx.code).to.equal(MAX_TX_SERSIZE_ERROR_CODE);
		expect(mx.reason).to.equal('TOTAL_INPUTS_EXCEED');
		expect(mx.maxTxSersize).to.equal(MAX_TX_SERSIZE);
});		});

it('Does not throw when inputs are less than MAX_TX_SERSIZE', () => {		it('Does not throw when inputs are less than MAX_TX_SERSIZE', () => {
// 709 p2pkh inputs is 99,969 bytes, leaving room for 31 p2pkh outputs		// 709 p2pkh inputs is 99,969 bytes, leaving room for 31 p2pkh outputs
// Enough to build a chained tx since you really only need 2 for chainedTxAlpha		// Enough to build a chained tx since you really only need 2 for chainedTxAlpha
expect(() => getMaxP2pkhOutputs(708, 0)).to.not.throw();		expect(() => getMaxP2pkhOutputs(708, 0)).to.not.throw();
});		});
});		});
Show All 16 Lines	context('Custom maxTxSersize parameter', () => {

expect(resultWithDefault).to.equal(2936);		expect(resultWithDefault).to.equal(2936);
// Lower size gives lower result		// Lower size gives lower result
expect(resultWithLower).to.equal(1466);		expect(resultWithLower).to.equal(1466);
});		});
});		});
});		});

		describe('WalletAction.build auto-consolidate for maxTxSersize', () => {
		it('prepends consolidation when a token SEND requires more than CONSOLIDATE_UTXOS_BATCHSIZE inputs', async () => {
		const mockChronik = new MockChronikClient();
		const testWallet = Wallet.fromSk(
		DUMMY_SK,
		mockChronik as unknown as ChronikClient,
		);
		mockChronik.setBlockchainInfo({
		tipHash: DUMMY_TIPHASH,
		tipHeight: DUMMY_TIPHEIGHT,
		});
		const inputCount = CONSOLIDATE_UTXOS_BATCHSIZE + 42;
		const tokenUtxos: WalletUtxo[] = Array.from(
		{ length: inputCount },
		(_, i) => ({
		...getDummySlpUtxo(1n),
		outpoint: {
		txid: i.toString(16).padStart(64, '0'),
		outIdx: 0,
		},
		sats: 546n,
		}),
		);
		const fuel: WalletUtxo = {
		...DUMMY_UTXO,
		sats: 10_000_000n,
		outpoint: { txid: 'ee'.repeat(32), outIdx: 0 },
		};
		mockChronik.setUtxosByAddress(DUMMY_ADDRESS, [...tokenUtxos, fuel]);
		await testWallet.sync();

		const built = testWallet
		.action({
		outputs: [
		{ sats: 0n },
		{
		sats: 546n,
		script: MOCK_DESTINATION_SCRIPT,
		tokenId: DUMMY_TOKENID_SLP_TOKEN_TYPE_FUNGIBLE,
		atoms: BigInt(inputCount),
		isMintBaton: false,
		},
		],
		tokenActions: [
		{
		type: 'SEND',
		tokenId: DUMMY_TOKENID_SLP_TOKEN_TYPE_FUNGIBLE,
		tokenType: SLP_TOKEN_TYPE_FUNGIBLE,
		},
		],
		})
		.build();

		expect(built.txs).to.have.length(4);

		// The first consolidation tx maxes out p2pkh inputs
		expect(built.txs[0].inputs).to.have.length(CONSOLIDATE_UTXOS_BATCHSIZE);
		expect(built.txs[0].serSize()).to.equal(99972);

		expect(built.txs[1].inputs).to.have.length(43);
		expect(built.txs[1].serSize()).to.equal(6205);

		expect(built.txs[2].inputs).to.have.length(3);
		expect(built.txs[2].serSize()).to.equal(467);

		// And now we only need 1 token utxo for the actual action ... and also an XEC utxo
		expect(built.txs[3].inputs).to.have.length(2);
		expect(built.txs[3].serSize()).to.equal(424);
		});

		it('prepends consolidation when an XEC send hits maxTxSersize from too many inputs', async () => {
		const mockChronik = new MockChronikClient();
		const testWallet = Wallet.fromSk(
		DUMMY_SK,
		mockChronik as unknown as ChronikClient,
		);
		mockChronik.setBlockchainInfo({
		tipHash: DUMMY_TIPHASH,
		tipHeight: DUMMY_TIPHEIGHT,
		});
		const inputCount = CONSOLIDATE_UTXOS_BATCHSIZE + 50;
		const perUtxo = 10000n;
		const xecUtxos: WalletUtxo[] = Array.from(
		{ length: inputCount },
		(_, i) => ({
		...DUMMY_UTXO,
		sats: perUtxo,
		outpoint: {
		txid: i.toString(16).padStart(64, '0'),
		outIdx: 0,
		},
		}),
		);
		mockChronik.setUtxosByAddress(DUMMY_ADDRESS, xecUtxos);
		await testWallet.sync();
		const sendSats = perUtxo * BigInt(inputCount) - 500000n;
		const built = testWallet
		.action({
		outputs: [{ sats: sendSats, script: MOCK_DESTINATION_SCRIPT }],
		})
		.build();

		// We have 2 consolidation txs for this case
		expect(built.txs).to.have.length(3);

		// The first consolidation tx maxes out p2pkh inputs
		expect(built.txs[0].inputs).to.have.length(CONSOLIDATE_UTXOS_BATCHSIZE);
		expect(built.txs[0].serSize()).to.equal(99874);

		// Change from prev consolidation tx and the 50 utxos on top
		expect(built.txs[1].inputs).to.have.length(51);
		expect(built.txs[1].serSize()).to.equal(7235);

		// Now we only need 1 utxo for the actual action
		expect(built.txs[2].inputs).to.have.length(1);
		// Which is accordingly quite small indeed
		expect(built.txs[2].serSize()).to.equal(219);
		});
		});

describe('removeSpentUtxos', () => {		describe('removeSpentUtxos', () => {
let mockChronik: MockChronikClient;		let mockChronik: MockChronikClient;
let testWallet: Wallet;		let testWallet: Wallet;

beforeEach(() => {		beforeEach(() => {
mockChronik = new MockChronikClient();		mockChronik = new MockChronikClient();
testWallet = Wallet.fromSk(		testWallet = Wallet.fromSk(
DUMMY_SK,		DUMMY_SK,
▲ Show 20 Lines • Show All 2,363 Lines • Show Last 20 Lines