From 8d8820be05d0f6b9d7c09a74369a5f0c729d0bbe Mon Sep 17 00:00:00 2001 From: 0xPatrick Date: Wed, 10 Jul 2024 01:28:06 -0400 Subject: [PATCH] test: e2e test of basic-flows.contract.js - tests a contract that uses orchestrate/async-flow in the multichain-testing environment --- multichain-testing/.gitignore | 2 +- multichain-testing/test/basic-flows.test.ts | 121 ++++++++++++++++++++ multichain-testing/test/stake-ica.test.ts | 2 +- multichain-testing/test/support.ts | 20 ++++ multichain-testing/tools/agd-tools.ts | 2 +- 5 files changed, 144 insertions(+), 3 deletions(-) create mode 100644 multichain-testing/test/basic-flows.test.ts diff --git a/multichain-testing/.gitignore b/multichain-testing/.gitignore index 353e7ea6469..ee0e3626500 100644 --- a/multichain-testing/.gitignore +++ b/multichain-testing/.gitignore @@ -2,4 +2,4 @@ .yarn/* !.yarn/patches/* revise-chain-info* -start-* +start* diff --git a/multichain-testing/test/basic-flows.test.ts b/multichain-testing/test/basic-flows.test.ts new file mode 100644 index 00000000000..40a037a5045 --- /dev/null +++ b/multichain-testing/test/basic-flows.test.ts @@ -0,0 +1,121 @@ +import anyTest from '@endo/ses-ava/prepare-endo.js'; +import type { TestFn } from 'ava'; +import { commonSetup, SetupContextWithWallets } from './support.js'; +import { makeDoOffer } from '../tools/e2e-tools.js'; +import { chainConfig, chainNames } from './support.js'; + +const test = anyTest as TestFn; + +const accounts = ['user1', 'user2', 'user3']; // one account for each scenario + +const contractName = 'basicFlows'; +const contractBuilder = + '../packages/builders/scripts/orchestration/init-basic-flows.js'; + +test.before(async t => { + const { deleteTestKeys, setupTestKeys, ...rest } = await commonSetup(t); + deleteTestKeys(accounts).catch(); + const wallets = await setupTestKeys(accounts); + t.context = { ...rest, wallets, deleteTestKeys }; + + t.log('bundle and install contract', contractName); + await t.context.deployBuilder(contractBuilder); + const vstorageClient = t.context.makeQueryTool(); + await t.context.retryUntilCondition( + () => vstorageClient.queryData(`published.agoricNames.instance`), + res => contractName in Object.fromEntries(res), + `${contractName} instance is available`, + ); +}); + +test.after(async t => { + const { deleteTestKeys } = t.context; + deleteTestKeys(accounts); +}); + +const makeAccountScenario = test.macro({ + title: (_, chainName: string) => `Create account on ${chainName}`, + exec: async (t, chainName: string) => { + const config = chainConfig[chainName]; + if (!config) return t.fail(`Unknown chain: ${chainName}`); + + const { + wallets, + provisionSmartWallet, + makeQueryTool, + retryUntilCondition, + } = t.context; + + const vstorageClient = makeQueryTool(); + + const wallet = accounts[chainNames.indexOf(chainName)]; + const wdUser1 = await provisionSmartWallet(wallets[wallet], { + BLD: 100n, + IST: 100n, + }); + t.log(`provisioning agoric smart wallet for ${wallets[wallet]}`); + + const doOffer = makeDoOffer(wdUser1); + t.log(`${chainName} makeAccount offer`); + const offerId = `${chainName}-makeAccount-${Date.now()}`; + + // FIXME we get payouts but not an offer result; it times out + // https://github.com/Agoric/agoric-sdk/issues/9643 + // chain logs shows an UNPUBLISHED result + const _offerResult = await doOffer({ + id: offerId, + invitationSpec: { + source: 'agoricContract', + instancePath: [contractName], + callPipe: [['makeOrchAccountInvitation']], + }, + offerArgs: { chainName }, + proposal: {}, + }); + t.true(_offerResult); + // t.is(await _offerResult, 'UNPUBLISHED', 'representation of continuing offer'); + + // TODO fix above so we don't have to poll for the offer result to be published + // https://github.com/Agoric/agoric-sdk/issues/9643 + const currentWalletRecord = await retryUntilCondition( + () => + vstorageClient.queryData(`published.wallet.${wallets[wallet]}.current`), + ({ offerToPublicSubscriberPaths }) => + Object.fromEntries(offerToPublicSubscriberPaths)[offerId], + `${offerId} continuing invitation is in vstorage`, + ); + + const offerToPublicSubscriberMap = Object.fromEntries( + currentWalletRecord.offerToPublicSubscriberPaths, + ); + + const address = offerToPublicSubscriberMap[offerId]?.account + .split('.') + .pop(); + t.log('Got address:', address); + t.regex( + address, + new RegExp(`^${config.expectedAddressPrefix}1`), + `address for ${chainName} is valid`, + ); + + const latestWalletUpdate = await vstorageClient.queryData( + `published.wallet.${wallets[wallet]}`, + ); + t.log('latest wallet update', latestWalletUpdate); + t.like( + latestWalletUpdate.status, + { + id: offerId, + numWantsSatisfied: 1, + result: 'UNPUBLISHED', + error: undefined, + }, + 'wallet offer satisfied without errors', + ); + }, +}); + +test.serial(makeAccountScenario, 'agoric'); +test.serial(makeAccountScenario, 'cosmoshub'); +test.serial(makeAccountScenario, 'osmosis'); diff --git a/multichain-testing/test/stake-ica.test.ts b/multichain-testing/test/stake-ica.test.ts index 12f0e0bffe7..1746e4f0194 100644 --- a/multichain-testing/test/stake-ica.test.ts +++ b/multichain-testing/test/stake-ica.test.ts @@ -114,7 +114,7 @@ const stakeScenario = test.macro(async (t, scenario: StakeIcaScenario) => { const queryClient = makeQueryClient(getRestEndpoint()); t.log('Requesting faucet funds'); - // XXX fails intermitently until https://github.com/cosmology-tech/starship/issues/417 + // XXX fails intermittently until https://github.com/cosmology-tech/starship/issues/417 await creditFromFaucet(address); const { balances } = await retryUntilCondition( diff --git a/multichain-testing/test/support.ts b/multichain-testing/test/support.ts index ef095ead9d1..d54f3f226bc 100644 --- a/multichain-testing/test/support.ts +++ b/multichain-testing/test/support.ts @@ -12,6 +12,26 @@ import { makeDeployBuilder } from '../tools/deploy.js'; const setupRegistry = makeSetupRegistry(makeGetFile({ dirname, join })); +export const chainConfig = { + cosmoshub: { + chainId: 'gaialocal', + denom: 'uatom', + expectedAddressPrefix: 'cosmos', + }, + osmosis: { + chainId: 'osmosislocal', + denom: 'uosmo', + expectedAddressPrefix: 'osmo', + }, + agoric: { + chainId: 'agoriclocal', + denom: 'ubld', + expectedAddressPrefix: 'agoric', + }, +}; + +export const chainNames = Object.keys(chainConfig); + const makeKeyring = async ( e2eTools: Pick, ) => { diff --git a/multichain-testing/tools/agd-tools.ts b/multichain-testing/tools/agd-tools.ts index a7b62f5380a..5b87be3e1ea 100644 --- a/multichain-testing/tools/agd-tools.ts +++ b/multichain-testing/tools/agd-tools.ts @@ -8,7 +8,7 @@ export const makeAgdTools = async ( execFileSync, }: Pick, ) => { - const bundleCache = unsafeMakeBundleCache('bundles'); + const bundleCache = await unsafeMakeBundleCache('bundles'); const tools = await makeE2ETools(log, bundleCache, { execFileSync, execFile,