[add] json-watcher

app.yml

@@ -29,6 +29,11 @@ headServers:
     maxLateBlocks: 3
     observedPubkey: A5LQXCkx8b6rzppfqdqeHbKPDGmKZtRcqwxP4BSeag5r
 
+wwMeta:
+  - address: https://wot-wizard.duniter.org
+    frequency: 60000 # 1'
+    maxLate: 14400 # 4h
+
 mail:
   enabled: false
   host: smtp.sparkpostmail.com

src/lib/types/conf.ts

@@ -6,6 +6,7 @@ export interface Conf {
   dprobeHeartbeats: ConfDprobeHeartbeat[]
   webDiffServers: ConfWebDiff[]
   headServers: ConfHead[]
+  wwMeta: ConfWWMeta[]
   mail: ConfMail
 }
 
@@ -39,6 +40,10 @@ export interface ConfHead extends ConfURL {
   maxLateBlocks: number
 }
 
+export interface ConfWWMeta extends ConfURL {
+  maxLate: number
+}
+
 export interface ConfDprobeHeartbeat extends ConfURL{
   lastBeat: number
 }

src/lib/watchers/wotwizard/json-watcher.ts

@@ -0,0 +1,32 @@
+import {Conf, ConfWWMeta} from "../../types/conf";
+import {urlWatcher} from '../abstract/url-watcher'
+
+function handleLateness(confHead: ConfWWMeta, data: WWMetaJson) {
+  const diff = Math.round(Date.now()/1000 - data.now)
+  if (diff >= confHead.maxLate) {
+    throw `WWMeta.json is late by ${diff}s (>= ${confHead.maxLate})`
+  }
+}
+
+export function jsonWatcher(conf: Conf) {
+
+  const URL_PATH = '/WWMeta.json'
+
+  return async (confWWMeta: ConfWWMeta) => {
+
+    return urlWatcher(conf, async (data) => {
+      handleLateness(confWWMeta, data)
+    })({
+      name: `WWMeta.json watcher ${confWWMeta.address}`,
+      address: confWWMeta.address + URL_PATH,
+      frequency: confWWMeta.frequency
+    })
+  }
+}
+
+interface WWMetaJson {
+  dossNb: number
+  block: number
+  now: number
+  computation_duration: number
+}