[enh] Watch ww and ww2 diff

src/lib/dwatch.ts

@@ -4,6 +4,7 @@ import * as fs from 'fs';
 import {ws2pWatcher} from "./watchers/ws2p/ws2p-watcher";
 import {bmaWatcher} from "./watchers/bma/bma-watcher";
 import {dprobeHeartbeat} from './watchers/dprobe/dprobe-heartbeat-watcher'
+import {webDiffWatcher} from "./watchers/webdiff/webdiff-watcher";
 
 export async function dwatch(confFile: string) {
 
@@ -13,4 +14,5 @@ export async function dwatch(confFile: string) {
   await Promise.all((conf.ws2pServers || []).map(ws2pWatcher(conf)))
   await Promise.all((conf.bmaServers || []).map(bmaWatcher(conf)))
   await Promise.all((conf.dprobeHeartbeats || []).map(dprobeHeartbeat(conf)))
+  await Promise.all((conf.webDiffServers || []).map(webDiffWatcher(conf)))
 }

src/lib/mail.ts

@@ -31,40 +31,40 @@ export async function sendMail(conf: ConfMail, subject: string, html: string) {
 
 export const mail = {
 
-  onEstablished: (conf: Conf, target: string) => {
-    return async () => {
-      console.log('Connection established for %s', target)
-      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] Connection established`, `
+  onEstablished: (conf: Conf, target: string, message = `Connection established for ${target}`, getHtml: () => string = () => `
       <p>
         Connection from [${os.hostname}] to ${target} established on ${moment().format('DD-MM-YYYY HH:mm:ss')}.
       </p>
-    `)
+    `) => {
+    return async () => {
+      console.log(`${message}`)
+      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] ${message}`, getHtml())
     }
   },
 
-  onDisconnect: (conf: Conf, target: string) => {
-    return async (waitingDelay: number) => {
-      console.log('Connection closed for %s', target)
-      console.log('Waiting %s seconds...', (waitingDelay / 1000).toFixed(0))
-      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] Connection closed`, `
+  onDisconnect: (conf: Conf, target: string, message = `Connection closed for ${target}`, getHtml: (waitingDelay: number) => string = (waitingDelay: number) => `
       <p>
         Connection from [${os.hostname}] to ${target} was lost on ${moment().format('dd-MM-YYYY HH:mm:ss')}.
       </p>
       <p>
         Waiting ${(waitingDelay / 1000).toFixed(0)} seconds before trying to reconnect.
       </p>
-  `)
+  `) => {
+    return async (waitingDelay: number) => {
+      console.log(`${message}`)
+      console.log('Waiting %s seconds...', (waitingDelay / 1000).toFixed(0))
+      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] ${message}`, getHtml(waitingDelay))
     }
   },
 
-  onRestartSuccess: (conf: Conf, target: string) => {
-    return async () => {
-      console.log('Connection recovered for %s', target)
-      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] Connection recovered`, `
+  onRestartSuccess: (conf: Conf, target: string, message = `Connection recovered for ${target}`, getHtml: () => string = () => `
       <p>
         Connection from [${os.hostname}] to ${target} was recovered on ${moment().format('dd-MM-YYYY HH:mm:ss')}.
       </p>
-    `)
+    `) => {
+    return async () => {
+      console.log(`${message}`)
+      await sendMail(conf.mail, `[dwatcher] [${os.hostname}] ${message}`, getHtml())
     }
   },
 

src/lib/types/conf.ts

@@ -4,6 +4,7 @@ export interface Conf {
   ws2pServers: ConfWS2P[]
   bmaServers: ConfBMA[]
   dprobeHeartbeats: ConfDprobeHeartbeat[]
+  webDiffServers: ConfWebDiff[]
   mail: ConfMail
 }
 
@@ -20,6 +21,12 @@ export interface ConfURL {
   frequency: number
 }
 
+export interface ConfWebDiff {
+  file1: string
+  file2: string
+  frequency: number
+}
+
 export interface ConfBMA extends ConfURL {
   maxLate?: number
 }

src/lib/watchers/webdiff/webdiff-watcher.ts

@@ -0,0 +1,90 @@
+import {watcherLoop} from "../../watcherLoop";
+import {Conf, ConfBMA, ConfWebDiff} from "../../types/conf";
+import Axios from "axios";
+import {mail} from "../../mail";
+import {diffChars} from "diff";
+import * as fs from "fs";
+import * as path from "path";
+import {moment} from "duniter/app/lib/common-libs/moment";
+
+export function webDiffWatcher(conf: Conf) {
+
+  return async (webDiffConf: ConfWebDiff) => {
+
+    const target = `${webDiffConf.file1} <-> ${webDiffConf.file2}`
+    let nodeDownRes: () => void
+    let nodeDownPromise: Promise<void> = new Promise(res => nodeDownRes = res)
+    let htmlDiff = ''
+
+    function handleData(data1: { data: any }, data2: { data: any }) {
+      const json1 = JSON.stringify(data1.data, null, ' ')
+      const json2 = JSON.stringify(data2.data, null, ' ')
+      if (json1 !== json2) {
+        const diff = diffChars(json1, json2)
+
+        htmlDiff = ''
+        diff.forEach(function (part) {
+          // green for additions, red for deletions
+          // grey for common parts
+          const htmlStripped = part.value
+            .replace(/\n/g, '<br/>')
+            .replace(/ /g, '&nbsp;')
+          const color = part.added ? 'green' :
+            part.removed ? 'red' : 'grey';
+
+          htmlDiff += `<span style="color: ${color};">${htmlStripped}</span>`
+        });
+
+        if (htmlDiff) {
+          fs.writeFileSync(path.join(__dirname, 'diff.html'), htmlDiff, 'utf8')
+        }
+        console.log('Diff done')
+      }
+    }
+
+    await watcherLoop(
+      async () => {
+        const data1 = await Axios.get(webDiffConf.file1)
+        const data2 = await Axios.get(webDiffConf.file2)
+        handleData(data1, data2)
+        let interval = setInterval(async () => {
+          try {
+            const data1 = await Axios.get(webDiffConf.file1)
+            const data2 = await Axios.get(webDiffConf.file2)
+            handleData(data1, data2)
+          } catch (e) {
+            clearInterval(interval)
+            nodeDownRes()
+            // Re-create down promise for future connection trial
+            nodeDownPromise = new Promise(res => nodeDownRes = res)
+          }
+        }, webDiffConf.frequency)
+      },
+
+      () => nodeDownPromise,
+
+      conf.reconnectionDelays,
+
+      mail.onEstablished(conf, target, 'webdiff successfully started'),
+
+      // When a disconnection is detected
+      mail.onDisconnect(conf, target, 'Diff detected', (waitingDelay: number) => `
+        ${htmlDiff}
+        <p>
+          Waiting ${(waitingDelay / 1000).toFixed(0)} seconds before trying to reconnect.
+        </p>
+    `),
+
+      async () => {
+        console.log('Trying to connect to %s', target)
+      },
+
+      mail.onRestartSuccess(conf, target),
+
+      async (e) => {
+        console.error(e.message)
+      }
+    )
+
+  }
+}