Add watcher

Author: 0x2b3bfa0

package-lock.json

@@ -74,6 +74,7 @@
     "@octokit/plugin-throttling": "^3.5.2",
     "@octokit/rest": "18.0.0",
     "colors": "1.4.0",
+    "cross-platform-file-watch": "^3.5.2",
     "ec2-spot-notification": "^2.0.3",
     "exponential-backoff": "^3.1.0",
     "form-data": "^3.0.1",

package.json

@@ -5,6 +5,7 @@ const globby = require('globby');
 const git = require('simple-git')('./');
 const path = require('path');
 const fs = require('fs');
+const chokidar = require('chokidar');
 
 const winston = require('winston');
 
@@ -22,8 +23,6 @@ const GITHUB = 'github';
 const GITLAB = 'gitlab';
 const BB = 'bitbucket';
 
-const paths = new Set();
-
 const uriNoTrailingSlash = (uri) => {
   return uri.endsWith('/') ? uri.substr(0, uri.length - 1) : uri;
 };
@@ -171,7 +170,21 @@ class CML {
     const { remark } = await import('remark');
     const { visit } = await import('unist-util-visit');
 
-    paths.add(markdownfile);
+    const watcher = chokidar.watch(markdownfile, {
+      persistent: true,
+
+      awaitWriteFinish: {
+        stabilityThreshold: 2000,
+        pollInterval: 100
+      }
+    });
+
+    if (watch) {
+      watcher.on('all', () => {
+        console.log('updating report...');
+        this.commentCreate({ ...opts, update: true, watch: false });
+      });
+    }
 
     const publishLocalFiles = () => async (tree) => {
       const nodes = [];
@@ -186,7 +199,7 @@ class CML {
             return;
           }
           node.url = await this.publish({ ...opts, path: node.url });
-          paths.add(node.url);
+          watcher.add(node.url);
         }
       };
 
@@ -196,12 +209,6 @@ class CML {
     if (publish)
       report = String(await remark().use(publishLocalFiles).process(report));
 
-    if (watch)
-      setInterval(() => {
-        console.log('updating report...');
-        this.commentCreate({ ...opts, update: true, watch: false });
-      }, 16384); // TODO: use a proper file watcher on the `paths` set
-
     let comment;
     const updatableComment = (comments) => {
       return comments.reverse().find(({ body }) => {