Check sync status of attestation service

packages/attestation-service/src/db.ts

@@ -1,5 +1,6 @@
 import { ContractKit, newKit } from '@celo/contractkit'
 import { FindOptions, Sequelize } from 'sequelize'
+import { Block } from 'web3/eth/types'
 import { fetchEnv } from './env'
 import { rootLogger } from './logger'
 import Attestation, { AttestationModel, AttestationStatic } from './models/attestation'
@@ -22,11 +23,31 @@ export let kit: ContractKit
 export async function initializeKit() {
   if (kit === undefined) {
     kit = newKit(fetchEnv('CELO_PROVIDER'))
-    const blockNumber = await kit.web3.eth.getBlockNumber()
-    if (blockNumber === 0) {
-      throw new Error(
-        'Could not fetch latest block from web3 provider ' + fetchEnv('CELO_PROVIDER')
+    // Copied from @celo/cli/src/utils/helpers
+    try {
+      const syncProgress = await kit.web3.eth.isSyncing()
+      if (typeof syncProgress === 'boolean' && !syncProgress) {
+        const latestBlock: Block = await kit.web3.eth.getBlock('latest')
+        if (latestBlock && latestBlock.number > 0) {
+          // To catch the case in which syncing has happened in the past,
+          // has stopped, and hasn't started again, check for an old timestamp
+          // on the latest block
+          const ageOfBlock = Date.now() / 1000 - latestBlock.timestamp
+          if (ageOfBlock > 120) {
+            throw new Error(
+              `Latest block is ${ageOfBlock} seconds old, and syncing is not currently in progress`
+            )
+          }
+        }
+      } else {
+        throw new Error('Node is not syncing')
+      }
+    } catch (error) {
+      rootLogger.error(
+        'Initializing Kit failed, are you running your node and specified it with the "CELO_PROVIDER" env var?. It\' currently set as ' +
+          fetchEnv('CELO_PROVIDER')
       )
+      throw error
     }
   }
 }

packages/attestation-service/src/logger.ts

@@ -4,18 +4,18 @@ import { createStream } from 'bunyan-gke-stackdriver'
 import { fetchEnvOrDefault } from './env'
 
 const logLevel = fetchEnvOrDefault('LOG_LEVEL', 'info') as LogLevelString
-const logFormat = fetchEnvOrDefault('LOG_FORMAT', 'json')
+const logFormat = fetchEnvOrDefault('LOG_FORMAT', 'human')
 
 let stream: any
 switch (logFormat) {
   case 'stackdriver':
     stream = createStream(levelFromName[logLevel])
     break
-  case 'human':
-    stream = { level: logLevel, stream: bunyanDebugStream() }
+  case 'json':
+    stream = { stream: process.stdout, level: logLevel }
     break
   default:
-    stream = { stream: process.stdout, level: logLevel }
+    stream = { level: logLevel, stream: bunyanDebugStream() }
     break
 }