refactor getScheduledRewardsWithFallback

filecoin-station · Nov 20, 2023 · 8e51944 · 8e51944
1 parent 9242446
commit 8e51944
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/lib/zinnia.js b/lib/zinnia.js
@@ -151,7 +151,7 @@ async function handleEvents ({
           onMetrics({
             totalJobsCompleted: event.total,
             rewardsScheduledForAddress:
-              await contract.rewardsScheduledFor(ethAddress)
+              await getScheduledRewardsWithFallback(contract, ethAddress)
           })
           break
 
@@ -163,3 +163,12 @@ async function handleEvents ({
     }
   }
 }
+
+async function getScheduledRewardsWithFallback (contract, ethAddress) {
+  try {
+    return await contract.rewardsScheduledFor(ethAddress)
+  } catch (err) {
+    console.error('Failed to get scheduled rewards:', err.stack)
+    return 0n
+  }
+}