Merge pull request #8145 from Agoric/execa-proto

Porting upgrade tests to Javascript

.eslintrc.cjs

@@ -145,5 +145,13 @@ module.exports = {
         project: false,
       },
     },
+    {
+      files: ['packages/**/upgrade-test-scripts/**/*.*js'],
+      rules: {
+        // NOTE: This rule is enabled for the repository in general.  We turn it
+        // off for test code for now.
+        '@jessie.js/safe-await-separator': 'off',
+      },
+    },
   ],
 };

packages/deployment/upgrade-test/Dockerfile

@@ -60,10 +60,10 @@ ARG DEST_IMAGE
 #this is agoric-upgrade-10 / vaults
 FROM ghcr.io/agoric/agoric-sdk:35 as agoric-upgrade-10
 ARG BOOTSTRAP_MODE
-ENV THIS_NAME=agoric-upgrade-10 BOOTSTRAP_MODE=${BOOTSTRAP_MODE}
+ENV THIS_NAME=agoric-upgrade-10 USE_JS=1 BOOTSTRAP_MODE=${BOOTSTRAP_MODE}
 
 WORKDIR /usr/src/agoric-sdk/
-COPY ./bash_entrypoint.sh ./env_setup.sh ./start_to_to.sh ./upgrade-test-scripts/
+COPY ./bash_entrypoint.sh ./env_setup.sh ./start_to_to.sh ./package.json ./*.mjs ./upgrade-test-scripts/
 COPY ./${THIS_NAME} ./upgrade-test-scripts/${THIS_NAME}/
 COPY --from=agoric-upgrade-9 /root/.agoric /root/.agoric
 RUN chmod +x ./upgrade-test-scripts/*.sh

packages/deployment/upgrade-test/upgrade-test-scripts/agoric-upgrade-10/actions.mjs

@@ -0,0 +1,342 @@
+import { promises as fs } from 'fs';
+import assert from 'assert';
+
+import {
+  waitForBlock,
+  provisionSmartWallet,
+  getUser,
+  executeOffer,
+} from './upgradeHelpers.mjs';
+import {
+  agd,
+  agoric,
+  agops,
+  agopsLocation,
+  executeCommand,
+} from '../cliHelper.mjs';
+import {
+  HOME,
+  ATOM_DENOM,
+  GOV1ADDR,
+  GOV2ADDR,
+  GOV3ADDR,
+} from '../constants.mjs';
+
+const govAccounts = [GOV1ADDR, GOV2ADDR, GOV3ADDR];
+
+const acceptEC = async () => {
+  console.log('ACTIONS Tickling the wallets so they are revived');
+
+  let voter = 0;
+  for (const account of govAccounts) {
+    console.log(`${account}: 1: Accepting EC Committee`);
+
+    try {
+      const params = ['ec', 'committee', '--send-from', account];
+      await executeCommand(agopsLocation, params, {
+        timeout: 30000,
+      });
+    } catch (error) {
+      console.warn(error.message);
+    }
+
+    await waitForBlock(3);
+
+    console.log(`${account}: 2: Accepting EC Committee`);
+
+    try {
+      await agops.ec('committee', '--send-from', account, '--voter', voter);
+    } catch (error) {
+      console.warn(error.message);
+    }
+
+    voter += 1;
+
+    await waitForBlock(3);
+
+    console.log(`${account}: Accepting EC Charter`);
+
+    try {
+      await agops.ec('charter', '--send-from', account);
+    } catch (error) {
+      console.warn(error.message);
+    }
+  }
+};
+
+const acceptOracles = oracles => {
+  const promiseArray = [];
+
+  for (const oracle of oracles) {
+    console.log(`${oracle.address}: Accept oracle invitations`);
+    promiseArray.push(
+      executeOffer(
+        oracle.address,
+        agops.oracle('accept', '--offerId', oracle.id),
+      ),
+    );
+  }
+
+  return Promise.all(promiseArray);
+};
+
+const proposeNewAuctionParams = async (
+  address,
+  startFequency,
+  clockStep,
+  priceLockPeriod,
+) => {
+  const charterAcceptOfferId = await agops.ec(
+    'find-continuing-id',
+    '--for',
+    `${'charter\\ member\\ invitation'}`,
+    '--from',
+    address,
+  );
+
+  return executeOffer(
+    address,
+    agops.auctioneer(
+      'proposeParamChange',
+      '--charterAcceptOfferId',
+      charterAcceptOfferId,
+      '--start-frequency',
+      startFequency,
+      '--clock-step',
+      clockStep,
+      '--price-lock-period',
+      priceLockPeriod,
+    ),
+  );
+};
+
+const voteForNewParams = (accounts, position) => {
+  return Promise.all(
+    accounts.map(account =>
+      agops.ec('vote', '--forPosition', position, '--send-from', account),
+    ),
+  );
+};
+
+const paramChangeOfferGeneration = async (
+  previousOfferId,
+  voteDur,
+  debtLimit,
+) => {
+  const ISTunit = 1_000_000n; // aka displayInfo: { decimalPlaces: 6 }
+  const voteDurSec = BigInt(voteDur);
+  const debtLimitValue = BigInt(debtLimit) * ISTunit;
+  const toSec = ms => BigInt(Math.round(ms / 1000));
+
+  const id = `propose-${Date.now()}`;
+  const deadline = toSec(Date.now()) + voteDurSec;
+
+  const zip = (xs, ys) => xs.map((x, i) => [x, ys[i]]);
+  const fromSmallCapsEntries = txt => {
+    const { body, slots } = JSON.parse(txt);
+    const theEntries = zip(JSON.parse(body.slice(1)), slots).map(
+      ([[name, ref], boardID]) => {
+        const iface = ref.replace(/^\$\d+\./, '');
+        return [name, { iface, boardID }];
+      },
+    );
+    return Object.fromEntries(theEntries);
+  };
+
+  const slots = []; // XXX global mutable state
+  const smallCaps = {
+    Nat: n => `+${n}`,
+    // XXX mutates obj
+    ref: obj => {
+      if (obj.ix) return obj.ix;
+      const ix = slots.length;
+      slots.push(obj.boardID);
+      obj.ix = `$${ix}.Alleged: ${obj.iface}`;
+      return obj.ix;
+    },
+  };
+
+  const instance = fromSmallCapsEntries(
+    await agoric.follow('-lF', ':published.agoricNames.instance', '-o', 'text'),
+  );
+  assert(instance.VaultFactory);
+
+  const brand = fromSmallCapsEntries(
+    await agoric.follow('-lF', ':published.agoricNames.brand', '-o', 'text'),
+  );
+  assert(brand.IST);
+  assert(brand.ATOM);
+
+  const body = {
+    method: 'executeOffer',
+    offer: {
+      id,
+      invitationSpec: {
+        invitationMakerName: 'VoteOnParamChange',
+        previousOffer: previousOfferId,
+        source: 'continuing',
+      },
+      offerArgs: {
+        deadline: smallCaps.Nat(deadline),
+        instance: smallCaps.ref(instance.VaultFactory),
+        params: {
+          DebtLimit: {
+            brand: smallCaps.ref(brand.IST),
+            value: smallCaps.Nat(debtLimitValue),
+          },
+        },
+        path: {
+          paramPath: {
+            key: {
+              collateralBrand: smallCaps.ref(brand.ATOM),
+            },
+          },
+        },
+      },
+      proposal: {},
+    },
+  };
+
+  const capData = { body: `#${JSON.stringify(body)}`, slots };
+  return JSON.stringify(capData);
+};
+
+export const provisionWallet = async user => {
+  const userKeyData = await agd.keys('add', user, '--keyring-backend=test');
+  await fs.writeFile(`${HOME}/.agoric/${user}.key`, userKeyData.mnemonic);
+
+  const userAddress = await getUser(user);
+
+  await provisionSmartWallet(
+    userAddress,
+    `20000000ubld,100000000${ATOM_DENOM}`,
+  );
+  await waitForBlock();
+};
+
+export const implementNewAuctionParams = async (
+  address,
+  oracles,
+  startFequency,
+  clockStep,
+  priceLockPeriod,
+) => {
+  await acceptEC();
+  await waitForBlock(3);
+
+  await acceptOracles(oracles);
+
+  await proposeNewAuctionParams(
+    address,
+    startFequency,
+    clockStep,
+    priceLockPeriod,
+  );
+
+  console.log('ACTIONS voting for new auction params');
+  await voteForNewParams(govAccounts, 0);
+
+  console.log('ACTIONS wait for the vote deadline to pass');
+  await new Promise(r => setTimeout(r, 65000));
+};
+
+export const proposeNewDebtCeiling = async address => {
+  const charterAcceptOfferId = await agops.ec(
+    'find-continuing-id',
+    '--for',
+    `${'charter\\ member\\ invitation'}`,
+    '--from',
+    address,
+  );
+
+  return executeOffer(
+    address,
+    paramChangeOfferGeneration(charterAcceptOfferId, 30, 123000000),
+  );
+};
+
+export const raiseDebtCeiling = async address => {
+  console.log('ACTIONS Raising debt limit');
+
+  await proposeNewDebtCeiling(address);
+  await voteForNewParams(govAccounts, 0);
+
+  console.log('ACTIONS wait for the vote to pass');
+  await new Promise(r => setTimeout(r, 65000));
+};
+
+export const openVault = (address, mint, collateral) => {
+  return executeOffer(
+    address,
+    agops.vaults('open', '--wantMinted', mint, '--giveCollateral', collateral),
+  );
+};
+
+export const adjustVault = (address, vaultId, vaultParams) => {
+  let params = [
+    'adjust',
+    '--vaultId',
+    vaultId,
+    '--from',
+    address,
+    ' --keyring-backend=test',
+  ];
+
+  if ('wantCollateral' in vaultParams) {
+    params = [...params, '--wantCollateral', vaultParams.wantCollateral];
+  }
+
+  if ('wantMinted' in vaultParams) {
+    params = [...params, '--wantMinted', vaultParams.wantMinted];
+  }
+
+  if ('giveCollateral' in vaultParams) {
+    params = [...params, '--giveCollateral', vaultParams.giveCollateral];
+  }
+
+  if ('giveMinted' in vaultParams) {
+    params = [...params, '--giveMinted', vaultParams.giveMinted];
+  }
+
+  return executeOffer(address, agops.vaults(...params));
+};
+
+export const closeVault = (address, vaultId, mint) => {
+  return executeOffer(
+    address,
+    agops.vaults(
+      'close',
+      '--vaultId',
+      vaultId,
+      '--giveMinted',
+      mint,
+      '--from',
+      address,
+      '--keyring-backend=test',
+    ),
+  );
+};
+
+export const pushPrice = (oracles, price = 10.0) => {
+  console.log(`ACTIONS pushPrice ${price}`);
+  const promiseArray = [];
+
+  for (const oracle of oracles) {
+    console.log(`Pushing Price from oracle ${oracle.address}`);
+
+    promiseArray.push(
+      executeOffer(
+        oracle.address,
+        agops.oracle(
+          'pushPriceRound',
+          '--price',
+          price,
+          '--oracleAdminAcceptOfferId',
+          oracle.id,
+        ),
+      ),
+    );
+  }
+
+  return Promise.all(promiseArray);
+};