fixup! improve error handling

Signed-off-by: Miroslav Bajtoš <oss@bajtos.net>

lib/miner-lookup.js

@@ -5,8 +5,13 @@ import { RPC_REQUEST } from './constants.js'
  * @returns {Promise<string>} Miner's PeerId, e.g. `12D3KooWMsPmAA65yHAHgbxgh7CPkEctJHZMeM3rAvoW8CZKxtpG`
  */
 export async function lookupMinerPeerId (minerId) {
-  const res = await rpc('Filecoin.StateMinerInfo', minerId, null)
-  return res.PeerId
+  try {
+    const res = await rpc('Filecoin.StateMinerInfo', minerId, null)
+    return res.PeerId
+  } catch (err) {
+    err.message = `Cannot lookup miner ${minerId}: ${err.message}`
+    throw err
+  }
 }
 
 /**

lib/spark.js

@@ -48,7 +48,23 @@ export default class Spark {
       stats.providerId = peerId
     } catch (err) {
       console.error(err)
-      this.#activity.onError()
+      // There are three common error cases:
+      //  1. We are offline
+      //  2. The JSON RPC provider is down
+      //  3. JSON RPC errors like when Miner ID is not a known actor
+      // There isn't much we can do in the first two cases. We can notify the user that we are not
+      // performing any jobs and wait until the problem is resolved.
+      // The third case should not happen unless we made a mistake, so we want to learn about it
+      if (err.name === 'FilecoinRpcError') {
+        // TODO: report the error to Sentry
+        console.error('The error printed above was not expected, please report it on GitHub:')
+        console.error('https://github.com/filecoin-station/spark/issues/new')
+      } else {
+        this.#activity.onError()
+      }
+      err.reported = true
+      // Abort the check, no measurement should be recorded
+      throw err
     }
 
     console.log(`Querying IPNI to find retrieval providers for ${retrieval.cid}`)
@@ -200,12 +216,7 @@ export default class Spark {
         await this.nextRetrieval()
         this.#activity.onHealthy()
       } catch (err) {
-        if (err.statusCode === 400 && err.serverMessage === 'OUTDATED CLIENT') {
-          this.#activity.onOutdatedClient()
-        } else {
-          this.#activity.onError()
-        }
-        console.error(err)
+        this.handleRunError(err)
       }
       const duration = Date.now() - started
       const baseDelay = APPROX_ROUND_LENGTH_IN_MS / this.#maxTasksPerNode
@@ -216,6 +227,17 @@ export default class Spark {
       }
     }
   }
+
+  handleRunError (err) {
+    if (err.reported) return
+
+    if (err.statusCode === 400 && err.serverMessage === 'OUTDATED CLIENT') {
+      this.#activity.onOutdatedClient()
+    } else {
+      this.#activity.onError()
+    }
+    console.error(err)
+  }
 }
 
 async function assertOkResponse (res, errorMsg) {

test/miner-lookup.test.js

@@ -16,6 +16,6 @@ test('lookup peer id of a miner that does not exist', async () => {
       `Expected "lookupMinerPeerId()" to fail, but it resolved with "${result}" instead.`
     )
   } catch (err) {
-    assertMatch(err.toString(), /actor code is not miner/)
+    assertMatch(err.toString(), /\bf010\b.*\bactor code is not miner/)
   }
 })