Typescriptify the main process code (12/N)

Summary: Converted static/watchman.js to typescript Reviewed By: passy Differential Revision: D20071220 fbshipit-source-id: 7d86ffa8dd728246eeac8a01e2573564e8fd6bbe
2020-02-27 05:28:02 -08:00
parent aff433c8ad
commit 8d66c3aba7
3 changed files with 40 additions and 37 deletions
--- a/static/watchman.ts
+++ b/static/watchman.ts
@@ -0,0 +1,111 @@
+/**
+ * Copyright (c) Facebook, Inc. and its affiliates.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE file in the root directory of this source tree.
+ *
+ * @format
+ */
+
+import {Client} from 'fb-watchman';
+import uuid from 'uuid';
+import path from 'path';
+
+export default class Watchman {
+  constructor(private rootDir: string) {}
+
+  private client?: Client;
+  private watch?: any;
+  private relativeRoot?: string;
+
+  async initialize(): Promise<void> {
+    if (this.client) {
+      return;
+    }
+    this.client = new Client();
+    this.client.setMaxListeners(250);
+    await new Promise((resolve, reject) => {
+      const onError = (err: Error) => {
+        this.client!.removeAllListeners('error');
+        reject(err);
+        this.client!.end();
+        delete this.client;
+      };
+      this.client!.once('error', onError);
+      this.client!.capabilityCheck(
+        {optional: [], required: ['relative_root']},
+        error => {
+          if (error) {
+            onError(error);
+            return;
+          }
+          this.client!.command(
+            ['watch-project', this.rootDir],
+            (error, resp) => {
+              if (error) {
+                onError(error);
+                return;
+              }
+              if ('warning' in resp) {
+                console.warn(resp.warning);
+              }
+              this.watch = resp.watch;
+              this.relativeRoot = resp.relative_path;
+              resolve();
+            },
+          );
+        },
+      );
+    });
+  }
+
+  async startWatchFiles(
+    relativeDir: string,
+    handler: (resp: any) => void,
+    options: {excludes: string[]},
+  ): Promise<void> {
+    if (!this.watch) {
+      throw new Error(
+        'Watchman is not initialized, please call "initialize" function and wait for the returned promise completion before calling "startWatchFiles".',
+      );
+    }
+    options = Object.assign({excludes: []}, options);
+    return new Promise((resolve, reject) => {
+      this.client!.command(['clock', this.watch], (error, resp) => {
+        if (error) {
+          return reject(error);
+        }
+
+        const {clock} = resp;
+
+        const sub = {
+          expression: [
+            'allof',
+            ['not', ['type', 'd']],
+            ...options!.excludes.map(e => ['not', ['match', e, 'wholename']]),
+          ],
+          fields: ['name'],
+          since: clock,
+          relative_root: this.relativeRoot
+            ? path.join(this.relativeRoot, relativeDir)
+            : relativeDir,
+        };
+
+        const id = uuid.v4();
+
+        this.client!.command(['subscribe', this.watch, id, sub], error => {
+          if (error) {
+            return reject(error);
+          }
+          this.client!.on('subscription', resp => {
+            if (resp.subscription !== id || !resp.files) {
+              return;
+            }
+            handler(resp);
+          });
+          resolve();
+        });
+      });
+    });
+  }
+}