Move desktop-related code to "desktop" subfolder (#872)

Summary: Pull Request resolved: https://github.com/facebook/flipper/pull/872 Move all the JS code related to desktop app to "desktop" subfolder. The structure of "desktop" folder: - `src` - JS code of Flipper desktop app executing in Electron Renderer (Chrome) process. This folder also contains all the Flipper plugins in subfolder "src/plugins". - `static` - JS code of Flipper desktop app bootstrapping executing in Electron Main (Node.js) process - `pkg` - Flipper packaging lib and CLI tool - `doctor` - Flipper diagnostics lib and CLI tool - `scripts` - Build scripts for Flipper desktop app - `headless` - Headless version of Flipper app - `headless-tests` - Integration tests running agains Flipper headless version Reviewed By: passy Differential Revision: D20249304 fbshipit-source-id: 9a51c63b51b92b758a02fc8ebf7d3d116770efe9
2020-03-14 14:26:07 -07:00
parent a60e6fee87
commit 85c13bb1f3
607 changed files with 103 additions and 142 deletions
--- a/desktop/static/watchman.ts
+++ b/desktop/static/watchman.ts
@@ -0,0 +1,115 @@
+/**
+ * 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 {v4 as 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);
+        }
+
+        try {
+          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();
+
+          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();
+          });
+        } catch (err) {
+          reject(err);
+        }
+      });
+    });
+  }
+}