add read scheduled rewards from spark-rewards

lib/rewards.js

@@ -11,10 +11,13 @@ export const runUpdateRewardsLoop = async ({ contracts, ethAddress, onMetrics })
     while (!contracts.length) {
       await timers.setTimeout(1000)
     }
-    const contractRewards = await Promise.all(contracts.map(async contract => {
-      return getScheduledRewardsWithFallback(contract, ethAddress)
-    }))
-    const totalRewards = contractRewards.reduce((a, b) => a + b, 0n)
+    const rewards = await Promise.all([
+      ...contracts.map(async contract => {
+        return getContractScheduledRewardsWithFallback(contract, ethAddress)
+      }),
+      getSparkRewardsScheduledRewardsWithFallback(ethAddress)
+    ])
+    const totalRewards = rewards.reduce((a, b) => a + b, 0n)
     onMetrics({ rewardsScheduledForAddress: totalRewards })
 
     const delay = 10 * 60 * 1000 // 10 minutes
@@ -23,7 +26,22 @@ export const runUpdateRewardsLoop = async ({ contracts, ethAddress, onMetrics })
   }
 }
 
-async function getScheduledRewardsWithFallback (contract, ethAddress) {
+async function getSparkRewardsScheduledRewardsWithFallback (ethAddress) {
+  try {
+    const res = await fetch(
+      `https://spark-rewards.fly.dev/scheduled-rewards/${ethAddress}`
+    )
+    const json = await res.json()
+    return typeof json === 'string'
+      ? BigInt(json)
+      : 0n // json can be `null`
+  } catch (err) {
+    console.error('Failed to get scheduled rewards:', err.stack)
+    return 0n
+  }
+}
+
+async function getContractScheduledRewardsWithFallback (contract, ethAddress) {
   try {
     return await contract.rewardsScheduledFor(ethAddress)
   } catch (err) {