feat(sync-tools): add method to wait until offer exited

rel: Agoric/BytePitchPartnerEng#38

packages/client-utils/src/sync-tools.js

@@ -9,6 +9,7 @@
  *  - operation: query dest account's balance
  *  - condition: dest account has a balance >= sent token
  * - Making sure an offer resulted successfully
+ * - Making sure an offer was exited successfully
  *
  */
 
@@ -287,3 +288,46 @@ export const waitUntilInvitationReceived = (addr, io, options) => {
     { reusePromise: true, setTimeout, ...resolvedOptions },
   );
 };
+
+/// ////////// Making sure an offer was exited successfully /////////////
+
+const makeQueryWalletCurrent = follow => async (/** @type {string} */ addr) => {
+  const update = await follow('-lF', `:published.wallet.${addr}.current`);
+
+  return update;
+};
+
+/**
+ *
+ * @param {object} update
+ * @param {string} offerId
+ * @returns {boolean}
+ */
+const checkLiveOffers = (update, offerId) => {
+  const liveOffers = update.liveOffers;
+  if (!liveOffers) {
+    return false;
+  }
+  return !liveOffers.some(element => element.includes(offerId));
+};
+
+/**
+ *
+ * @param {string} addr
+ * @param {string} offerId
+ * @param {{ follow: () => object, log: typeof console.log, setTimeout: typeof global.setTimeout}} io
+ * @param {WaitUntilOptions} options
+ * @returns
+ */
+export const waitUntilOfferExited = async (addr, offerId, io, options) => {
+  const { follow, setTimeout } = io;
+  const queryWalletCurrent = makeQueryWalletCurrent(follow);
+  const { errorMessage, ...resolvedOptions } = overrideDefaultOptions(options);
+
+  return retryUntilCondition(
+    async () => queryWalletCurrent(addr),
+    update => checkLiveOffers(update, offerId),
+    errorMessage,
+    { setTimeout, ...resolvedOptions },
+  );
+};

packages/client-utils/test/sync-tools.test.js

@@ -6,6 +6,7 @@ import {
   waitUntilAccountFunded,
   waitUntilContractDeployed,
   waitUntilInvitationReceived,
+  waitUntilOfferExited,
   waitUntilOfferResult,
 } from '../src/sync-tools.js';
 
@@ -403,3 +404,21 @@ test.serial('wait until invitation recevied', async t => {
 
   await t.notThrowsAsync(waitP);
 });
+
+test.serial('wait until offer exited', async t => {
+  const { setValue, follow } = makeFakeFollow();
+  setValue({});
+
+  const waitP = waitUntilOfferExited(
+    'agoric12345',
+    'my-offer',
+    { follow, log: t.log, setTimeout },
+    {
+      maxRetries: 5,
+      retryIntervalMs,
+      errorMessage: 'Offer not exited',
+    },
+  );
+
+  await t.throwsAsync(waitP);
+});