lightning.e2e.js

import BitcoinJsonRpc from 'bitcoin-json-rpc';
import createLndRpc from '@radar/lnrpc';

import {
	sleep,
	checkComplete,
	markComplete,
	launchAndWait,
	completeOnboarding,
	bitcoinURL,
	electrumHost,
	electrumPort,
} from './helpers';
import initWaitForElectrumToSync from '../__tests__/utils/wait-for-electrum';

const __DEV__ = process.env.DEV === 'true';

d = checkComplete('lighting-1') ? describe.skip : describe;

d('Lightning', () => {
	let waitForElectrum;
	const rpc = new BitcoinJsonRpc(bitcoinURL);

	beforeAll(async () => {
		let balance = await rpc.getBalance();
		const address = await rpc.getNewAddress();

		while (balance < 10) {
			await rpc.generateToAddress(10, address);
			balance = await rpc.getBalance();
		}

		waitForElectrum = await initWaitForElectrumToSync(
			{ host: electrumHost, port: electrumPort },
			bitcoinURL,
		);

		await completeOnboarding();
	});

	beforeEach(async () => {
		await launchAndWait();
		await waitForElectrum();
	});

	afterEach(() => {
		waitForElectrum?.close();
	});

	d('Receive and Send', () => {
		// Test plan:
		// - connect to LND node
		// - receive funds
		// - send funds
		// - check balances, tx history and notes
		// - restore wallet
		// - check balances, tx history and notes
		// - close channel

		it('Can receive and send LN payments', async () => {
			if (checkComplete('lighting-1')) {
				return;
			}

			// send funds to LND node and open a channel
			const lnd = await createLndRpc({
				server: 'localhost:10009',
				tls: `${__dirname}/../docker/lnd/tls.cert`,
				macaroonPath: `${__dirname}/../docker/lnd/data/chain/bitcoin/regtest/admin.macaroon`,
			});
			const { address: lndAddress } = await lnd.newAddress();
			await rpc.sendToAddress(lndAddress, '1');
			await rpc.generateToAddress(1, await rpc.getNewAddress());
			await waitForElectrum();
			const { identityPubkey: lndNodeID } = await lnd.getInfo();

			// get LDK Node id
			await element(by.id('Settings')).tap();
			if (!__DEV__) {
				await element(by.id('DevOptions')).multiTap(5); // enable dev mode
			}
			await element(by.id('AdvancedSettings')).tap();
			// wait for LDK to start
			await sleep(5000);
			await element(by.id('LightningNodeInfo')).tap();
			await waitFor(element(by.id('LDKNodeID')))
				.toBeVisible()
				.withTimeout(60000);
			let { label: ldkNodeID } = await element(
				by.id('LDKNodeID'),
			).getAttributes();
			await element(by.id('NavigationBack')).tap();

			// connect to LND
			await element(by.id('Channels')).tap();
			await element(by.id('AddPeerInput')).replaceText(
				`${lndNodeID}@127.0.0.1:9735`,
			);
			await element(by.id('AddPeerInput')).tapReturnKey();
			await element(by.id('AddPeerButton')).tap();

			// wait for peer to be connected
			let n = 0;
			while (n < 20) {
				await sleep(1000);
				const { peers } = await lnd.listPeers();
				if (peers.some((p) => p.pubKey === ldkNodeID)) {
					break;
				}
				n++;
				if (n === 0) {
					throw new Error('Peer not connected');
				}
			}

			// open a channel
			await lnd.openChannelSync({
				nodePubkeyString: ldkNodeID,
				localFundingAmount: '100000',
				private: true,
			});
			await rpc.generateToAddress(6, await rpc.getNewAddress());
			await waitForElectrum();

			// wait for channel to be active
			let m = 0;
			while (m < 20) {
				await sleep(1000);
				const { channels } = await lnd.listChannels({
					peer: Buffer.from(ldkNodeID, 'hex'),
					activeOnly: true,
				});
				if (channels?.length > 0) {
					break;
				}
				m++;
				if (m === 0) {
					throw new Error('Channel not active');
				}
			}

			// check channel status
			await sleep(500);
			await element(by.id('NavigationBack')).tap();
			await element(by.id('Channels')).tap();
			await element(by.id('Channel')).atIndex(0).tap();
			await expect(
				element(by.id('MoneyText').withAncestor(by.id('TotalSize'))),
			).toHaveText('100 000');
			await element(by.id('ChannelScrollView')).scrollTo('bottom');
			await expect(element(by.id('IsReadyYes'))).toBeVisible();
			await element(by.id('NavigationClose')).tap();

			// send funds to LDK, 0 invoice
			await element(by.id('Receive')).tap();
			let { label: invoice1 } = await element(by.id('QRCode')).getAttributes();
			invoice1 = invoice1.replaceAll(/bitcoin.*=/gi, '').toLowerCase();
			await lnd.sendPaymentSync({ paymentRequest: invoice1, amt: 50000 });
			await waitFor(element(by.id('NewTxPrompt')))
				.toBeVisible()
				.withTimeout(10000);
			await element(by.id('NewTxPrompt')).swipe('down');
			await waitFor(
				element(by.id('MoneyText').withAncestor(by.id('TotalBalance'))),
			)
				.toHaveText('49 000')
				.withTimeout(10000);

			// send funds to LDK, 111 sats invoice
			await element(by.id('Receive')).tap();
			await element(by.id('SpecifyInvoiceButton')).tap();
			await element(by.id('ReceiveNumberPadTextField')).tap();
			await element(
				by.id('N1').withAncestor(by.id('ReceiveNumberPad')),
			).multiTap(3);
			await element(by.id('ReceiveNumberPadSubmit')).tap();
			const note1 = 'note 111';
			await element(by.id('ReceiveNote')).typeText(note1);
			await element(by.id('ReceiveNote')).tapReturnKey();
			await element(by.id('TagsAdd')).tap();
			await element(by.id('TagInputReceive')).typeText('rtag');
			await element(by.id('TagInputReceive')).tapReturnKey();
			await element(by.id('ShowQrReceive')).tap();
			await element(by.id('QRCode')).swipe('left');
			const { label: invoice2 } = await element(
				by.id('ReceiveLightningInvoice'),
			).getAttributes();
			await lnd.sendPaymentSync({ paymentRequest: invoice2 });
			await waitFor(element(by.id('NewTxPrompt')))
				.toBeVisible()
				.withTimeout(10000);
			await element(by.id('NewTxPrompt')).swipe('down');
			await waitFor(
				element(by.id('MoneyText').withAncestor(by.id('TotalBalance'))),
			)
				.toHaveText('49 111')
				.withTimeout(10000);

			// send funds to LND, 0 invoice
			const note2 = 'zero';
			const { paymentRequest: invoice3 } = await lnd.addInvoice({
				memo: note2,
			});
			await element(by.id('Send')).tap();
			await element(by.id('RecipientManual')).tap();
			await element(by.id('RecipientInput')).replaceText(invoice3);
			await element(by.id('RecipientInput')).tapReturnKey();
			await sleep(1000); // wait for keyboard to hide
			await element(by.id('AddressContinue')).tap();
			await element(
				by.id('N1').withAncestor(by.id('SendAmountNumberPad')),
			).multiTap(3);
			await element(by.id('ContinueAmount')).tap();
			await element(by.id('GRAB')).swipe('right'); // Swipe to confirm
			await waitFor(element(by.id('SendSuccess')))
				.toBeVisible()
				.withTimeout(10000);
			await element(by.id('Close')).tap();
			await waitFor(
				element(by.id('MoneyText').withAncestor(by.id('TotalBalance'))),
			)
				.toHaveText('49 000')
				.withTimeout(10000);

			// send funds to LND, 10000 invoice
			const { paymentRequest: invoice4 } = await lnd.addInvoice({
				value: '1000',
			});
			await element(by.id('Send')).tap();
			await element(by.id('RecipientManual')).tap();
			await element(by.id('RecipientInput')).replaceText(invoice4);
			await element(by.id('RecipientInput')).tapReturnKey();
			await sleep(1000); // wait for keyboard to hide
			await element(by.id('AddressContinue')).tap();

			// Review & Send
			await expect(element(by.id('TagsAddSend'))).toBeVisible();
			await element(by.id('TagsAddSend')).tap(); // add tag
			await element(by.id('TagInputSend')).typeText('stag');
			await element(by.id('TagInputSend')).tapReturnKey();
			await element(by.id('GRAB')).swipe('right'); // Swipe to confirm
			await waitFor(element(by.id('SendSuccess')))
				.toBeVisible()
				.withTimeout(10000);
			await element(by.id('Close')).tap();
			await waitFor(
				element(by.id('MoneyText').withAncestor(by.id('TotalBalance'))),
			)
				.toHaveText('48 000')
				.withTimeout(10000);

			// check tx history
			await element(by.id('TransferButton')).swipe('up');
			await expect(
				element(by.text('1 000').withAncestor(by.id('ActivityShort-1'))),
			).toBeVisible();
			await expect(
				element(by.text('111').withAncestor(by.id('ActivityShort-2'))),
			).toBeVisible();
			await expect(
				element(by.text('111').withAncestor(by.id('ActivityShort-3'))),
			).toBeVisible();
			await element(by.id('ActivityShort-2')).tap();
			await expect(element(by.id('InvoiceNote'))).toHaveText(note2);
			await element(by.id('NavigationClose')).tap();
			await element(by.id('ActivityShort-3')).tap();
			await expect(element(by.id('InvoiceNote'))).toHaveText(note1);
			await element(by.id('NavigationClose')).tap();

			// check activity filters & tags
			await element(by.id('ActivityShowAll')).tap();

			// All, 4 transactions
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-1'))),
			).toHaveText('-');
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-2'))),
			).toHaveText('-');
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-3'))),
			).toHaveText('+');
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-4'))),
			).toHaveText('+');
			await expect(element(by.id('Activity-5'))).not.toExist();

			// Sent, 2 transactions
			await element(by.id('Tab-sent')).tap();
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-1'))),
			).toHaveText('-');
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-2'))),
			).toHaveText('-');
			await expect(element(by.id('Activity-3'))).not.toExist();

			// Received, 2 transactions
			await element(by.id('Tab-received')).tap();
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-1'))),
			).toHaveText('+');
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-2'))),
			).toHaveText('+');
			await expect(element(by.id('Activity-3'))).not.toExist();

			// Other, 0 transactions
			await element(by.id('Tab-other')).tap();
			await expect(element(by.id('Activity-1'))).not.toExist();

			// filter by receive tag
			await element(by.id('Tab-all')).tap();
			await element(by.id('TagsPrompt')).tap();
			await element(by.id('Tag-rtag')).tap();
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-1'))),
			).toHaveText('+');
			await expect(element(by.id('Activity-2'))).not.toExist();
			await element(by.id('Tag-rtag-delete')).tap();

			// filter by send tag
			await element(by.id('TagsPrompt')).tap();
			await element(by.id('Tag-stag')).tap();
			await expect(
				element(by.id('MoneySign').withAncestor(by.id('Activity-1'))),
			).toHaveText('-');
			await expect(element(by.id('Activity-2'))).not.toExist();
			await element(by.id('Tag-stag-delete')).tap();
			await element(by.id('NavigationClose')).tap();

			// get seed
			await element(by.id('Settings')).tap();
			await element(by.id('BackupSettings')).tap();
			await element(by.id('BackupWallet')).tap();
			await sleep(1000); // animation
			await element(by.id('TapToReveal')).tap();

			// get the seed from SeedContaider
			const { label: seed } = await element(
				by.id('SeedContaider'),
			).getAttributes();
			await element(by.id('SeedContaider')).swipe('down');
			await sleep(1000); // animation
			await element(by.id('NavigationClose')).tap();

			await sleep(5000); // make sure everything is saved to cloud storage TODO: improve this
			console.info('seed: ', seed);

			// restore wallet
			await device.launchApp({ delete: true });

			await waitFor(element(by.id('Check1'))).toBeVisible();
			await element(by.id('Check1')).tap();
			await element(by.id('Check2')).tap();
			await element(by.id('Continue')).tap();
			await waitFor(element(by.id('SkipIntro'))).toBeVisible();
			await element(by.id('SkipIntro')).tap();
			await element(by.id('RestoreWallet')).tap();
			await element(by.id('MultipleDevices-button')).tap();
			await element(by.id('Word-0')).replaceText(seed);
			await element(by.id('WordIndex-4')).swipe('up');
			await element(by.id('RestoreButton')).tap();

			await waitFor(element(by.id('GetStartedButton')))
				.toBeVisible()
				.withTimeout(300000); // 5 min
			await element(by.id('GetStartedButton')).tap();

			// wait for SuggestionsLabel to appear and be accessible
			for (let i = 0; i < 60; i++) {
				await sleep(1000);
				try {
					await element(by.id('SuggestionsLabel')).tap();
					break;
				} catch (e) {}
			}

			// check balance
			await waitFor(
				element(by.id('MoneyText').withAncestor(by.id('TotalBalance'))),
			)
				.toHaveText('48 000')
				.withTimeout(10000);

			// check tx history
			await element(by.id('TransferButton')).swipe('up');
			await expect(
				element(by.text('111').withAncestor(by.id('ActivityShort-2'))),
			).toBeVisible();
			await element(by.id('ActivityShort-2')).tap();
			await expect(element(by.id('InvoiceNote'))).toHaveText(note2);
			await element(by.id('NavigationClose')).tap();

			// check channel status
			await element(by.id('Settings')).tap();
			await element(by.id('AdvancedSettings')).tap();
			await element(by.id('Channels')).tap();
			await element(by.id('Channel')).atIndex(0).tap();
			await element(by.id('ChannelScrollView')).scrollTo('bottom');
			await expect(element(by.id('IsReadyYes'))).toBeVisible();

			// close channel
			await element(by.id('CloseConnection')).tap();
			await element(by.id('CloseConnectionButton')).tap();
			await rpc.generateToAddress(6, await rpc.getNewAddress());
			await waitForElectrum();
			await expect(element(by.id('Channel')).atIndex(0)).not.toExist();
			await element(by.id('NavigationBack')).tap();
			await element(by.id('NavigationClose')).tap();

			// TODO: for some reason this doen't work on github actions
			// wait for onchain payment to arrive
			// await waitFor(element(by.id('NewTxPrompt')))
			// 	.toBeVisible()
			// 	.withTimeout(60000);
			// await element(by.id('NewTxPrompt')).swipe('down');
			// await expect(
			// 	element(by.id('MoneySign').withAncestor(by.id('ActivityShort-1'))),
			// ).toHaveText('+');

			markComplete('lighting-1');
		});
	});
});