chore(notifier): Annote subscriber rejections that follow disconnection

Agoric · Apr 13, 2023 · 36ee17b · 36ee17b
1 parent c022a5d
commit 36ee17b
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/packages/notifier/src/subscribe.js b/packages/notifier/src/subscribe.js
@@ -3,6 +3,7 @@ import { isUpgradeDisconnection } from '@agoric/internal/src/upgrade-api.js';
 
 import './types-ambient.js';
 
+const { details: X } = assert;
 const sink = () => {};
 
 /**
@@ -14,6 +15,7 @@ const sink = () => {};
  * @returns {Promise<T>}
  */
 const reconnectAsNeeded = async thunk => {
+  let initialDisconnection;
   let lastVersion = -Infinity;
   // End synchronous prelude.
   await null;
@@ -24,6 +26,9 @@ const reconnectAsNeeded = async thunk => {
       return result;
     } catch (err) {
       if (isUpgradeDisconnection(err)) {
+        if (!initialDisconnection) {
+          initialDisconnection = err;
+        }
         const { incarnationNumber: version } = err;
         if (version > lastVersion) {
           // We don't expect another upgrade in between receiving
@@ -33,6 +38,12 @@ const reconnectAsNeeded = async thunk => {
           continue;
         }
       }
+      if (initialDisconnection && initialDisconnection !== err) {
+        assert.note(
+          err,
+          X`Attempting to recover from disconnection: ${initialDisconnection}`,
+        );
+      }
       throw err;
     }
   }