add report errors to influxdb

Author: juliangruber

lib/contracts.js

@@ -3,6 +3,7 @@ import pRetry from 'p-retry'
 import * as Name from 'w3name'
 import { ethers } from 'ethers'
 import * as SparkImpactEvaluator from '@filecoin-station/spark-impact-evaluator'
+import { reportW3NameError } from './telemetry.js'
 
 const {
   // https://github.com/filecoin-station/contract-addresses
@@ -65,6 +66,7 @@ async function getContractAddresses () {
   try {
     revision = await Name.resolve(name)
   } catch (err) {
+    reportW3NameError()
     // These errors aren't actionable
     err.reportToSentry = false
     throw err

lib/modules.js

@@ -12,6 +12,7 @@ import { CarReader } from '@ipld/car'
 import { validateBlock } from '@web3-storage/car-block-validator'
 import { recursive as exporter } from 'ipfs-unixfs-exporter'
 import * as tar from 'tar'
+import { reportW3NameError } from './telemetry.js'
 
 /** @typedef {import('unzip-stream').UnzipStreamEntry} UnzipStreamEntry */
 
@@ -110,6 +111,7 @@ async function getLatestCID (ipnsKey) {
   try {
     revision = await Name.resolve(name)
   } catch (err) {
+    reportW3NameError()
     // These errors aren't actionable
     err.reportToSentry = false
     throw err

lib/telemetry.js

@@ -102,3 +102,10 @@ export const runMachinesLoop = async ({ STATION_ID }) => {
     await timers.setTimeout(24 * 3600 * 1000) // 1 day
   }
 }
+
+export const reportW3NameError = () => {
+  const point = new Point('w3name-error')
+  point.stringField('version', pkg.version)
+  writeClient.writePoint(point)
+  writeClient.flush().catch(handleFlushError)
+}