feat: callback fires only once, remove extra first

securesecrets · Apr 18, 2024 · ccee193 · ccee193
1 parent 431d547
commit ccee193
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/contracts/services/batchQuery.ts b/src/contracts/services/batchQuery.ts
@@ -93,15 +93,16 @@ const batchQuerySingleBatch$ = ({
           && response.batch.block_height < minBlockHeightValidationOptions.minBlockHeight
         ) {
         // callback for when stale node is detected. Useful for error logging.
-          if (typeof minBlockHeightValidationOptions.onStaleNodeDetected === 'function') {
+        // check the retryCount to ensure that this only fires one time
+          if (retryCount === 0
+            && typeof minBlockHeightValidationOptions.onStaleNodeDetected === 'function') {
             minBlockHeightValidationOptions.onStaleNodeDetected();
           }
           return throwError(() => new Error('Stale node detected'));
         }
         return of(response);
       }),
       map(parseBatchQuery),
-      first(),
     )),
     first(),
     catchError((error, caught) => {