test(vow): test unhandled vow rejection machinery

Run `yarn test:rejection` to test unhandled rejection reporting.

CAVEAT: AVA has no way to expect unhandled rejections and so will
fail the tests with this setting.

packages/orchestration/package.json

@@ -13,7 +13,8 @@
     "codegen": "scripts/fetch-chain-info.ts",
     "prepack": "tsc --build tsconfig.build.json",
     "postpack": "git clean -f '*.d.ts*' '*.tsbuildinfo'",
-    "test": "ava",
+    "test": "SINK_UNHANDLED_VOW_REJECTIONS=1 ava",
+    "test:rejection": "ava",
     "test:c8": "c8 --all $C8_OPTIONS ava",
     "test:xs": "exit 0",
     "lint": "run-s --continue-on-error lint:*",

packages/vow/package.json

@@ -11,7 +11,8 @@
     "build": "exit 0",
     "prepack": "tsc --build tsconfig.build.json",
     "postpack": "git clean -f '*.d.ts*' '*.tsbuildinfo'",
-    "test": "ava",
+    "test": "SINK_UNHANDLED_VOW_REJECTIONS=1 ava",
+    "test:rejection": "ava",
     "test:xs": "exit 0",
     "lint-fix": "yarn lint:eslint --fix",
     "lint": "run-s --continue-on-error lint:*",

packages/vow/test/retryable.test.js

@@ -9,6 +9,7 @@ import { eventLoopIteration } from '@agoric/internal/src/testing-utils.js';
 import { prepareVowKit } from '../src/vow.js';
 import { isVow } from '../src/vow-utils.js';
 import { prepareRetryableTools } from '../src/retryable.js';
+import { prepareVowRejectionTracker } from '../src/rejection-tracker.js';
 import { makeWhen } from '../src/when.js';
 
 /**
@@ -21,7 +22,8 @@ import { makeWhen } from '../src/when.js';
  */
 const makeTestTools = ({ isRetryableReason = () => false } = {}) => {
   const zone = makeHeapZone();
-  const makeVowKit = prepareVowKit(zone);
+  const makeVowRejectionTracker = prepareVowRejectionTracker(zone);
+  const makeVowKit = prepareVowKit(zone, makeVowRejectionTracker());
   const when = makeWhen(isRetryableReason);
 
   const { retryable, adminRetryableFlow } = prepareRetryableTools(zone, {

packages/vow/test/watch-upgrade.test.js

@@ -11,7 +11,7 @@ import { prepareVowTools } from '../vat.js';
 test.serial('vow resolve across upgrade', async t => {
   annihilate();
 
-  t.plan(1);
+  t.plan(3);
 
   await startLife(async baggage => {
     const zone = makeDurableZone(baggage, 'durableRoot');
@@ -29,9 +29,29 @@ test.serial('vow resolve across upgrade', async t => {
       },
     });
 
+    const watcher2 = zone.exo('DurableVowTestWatcher2', undefined, {
+      onFulfilled(value) {
+        t.is(value, 42);
+        throw Error(`Error in handler ${value}`);
+      },
+    });
+
     const testVowKit = zone.makeOnce('testVowKit', () => vowTools.makeVowKit());
+    const testVowKit2 = zone.makeOnce('testVowKit2', () =>
+      vowTools.makeVowKit(),
+    );
+    const testVowKit3 = zone.makeOnce('testVowKit3', () =>
+      vowTools.makeVowKit(),
+    );
 
     vowTools.watch(testVowKit.vow, watcher);
+
+    vowTools.watch(testVowKit2.vow, watcher2);
+    const abandoned = new Promise(() => {});
+    testVowKit2.resolver.resolve(abandoned);
+
+    vowTools.watch(testVowKit3.vow, watcher2);
+    testVowKit3.resolver.resolve(42);
   });
 
   await startLife(
@@ -51,6 +71,22 @@ test.serial('vow resolve across upgrade', async t => {
         },
       });
 
+      zone.exo('DurableVowTestWatcher2', undefined, {
+        onFulfilled(value) {
+          t.fail(
+            `Second incarnation watcher2 onFulfilled triggered with value ${value}`,
+          );
+        },
+        onRejected(value) {
+          t.deepEqual(value, {
+            name: 'vatUpgraded',
+            upgradeMessage: 'vat upgraded',
+            incarnationNumber: 1,
+          });
+          return Promise.reject(Error('rejection from watcher2.onRejected'));
+        },
+      });
+
       /** @type {import('../src/types.js').VowResolver} */
       const testVowKitResolver = zone.makeOnce('testVowKit', () => {
         t.fail('testVowKit maker called');