feat: add file watcher

postlight · Jun 12, 2016 · 6bc225a · 6bc225a
1 parent 5425c51
commit 6bc225a
Show file tree

Hide file tree

Showing 3 changed files with 43 additions and 35 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "lux-framework",
-  "version": "0.0.1-beta.10",
+  "version": "0.0.1-beta.11",
   "description": "A MVC style Node.js framework for building lightning fast JSON APIs",
   "repository": "https://github.com/postlight/lux",
   "keywords": [

diff --git a/src/packages/cli/index.js b/src/packages/cli/index.js
@@ -68,38 +68,43 @@ export default function CLI() {
     .option('-e, --environment [env]', '(Default: development)')
     .option('-p, --port [port]', '(Default: 4000)')
     .action(async ({ environment = 'development', port = 4000 } = {}) => {
-      const rescue = (err) => {
-        console.error(err);
-        exit(1);
-      };
-
-      await tryCatch(async () => {
-        const compiler = await createCompiler(PWD, environment);
-        let isRunning = false;
-
-        compiler.watch({
-          poll: false,
-          aggregateTimeout: 300
-        }, async (err, stats) => {
-          if (err) {
-            return rescue(err);
-          }
+      process.env.NODE_ENV = environment;
+
+      if (isMaster) {
+        const rescue = (err) => {
+          console.error(err);
+          exit(1);
+        };
+
+        await tryCatch(async () => {
+          const compiler = await createCompiler(PWD, environment);
+          let isRunning = false;
+
+          compiler.watch({
+            poll: false,
+            aggregateTimeout: 300
+          }, async (err, stats) => {
+            if (err) {
+              return rescue(err);
+            }
 
-          if (isMaster) {
-            displayStats(stats, isRunning);
+            if (isMaster) {
+              displayStats(stats, isRunning);
 
-            if (isRunning) {
-              process.emit('update');
+              if (isRunning) {
+                process.emit('update');
+              }
             }
-          }
 
-          if (!isRunning) {
-            process.env.NODE_ENV = environment;
-            await serve(port);
-            isRunning = true;
-          }
-        });
-      }, rescue);
+            if (!isRunning) {
+              await serve(port);
+              isRunning = true;
+            }
+          });
+        }, rescue);
+      } else {
+        await serve(port);
+      }
     });
 
   cli
@@ -156,12 +161,14 @@ export default function CLI() {
         const compiler = await createCompiler(PWD, NODE_ENV);
 
         compiler.run(async (err) => {
-          if (err) {
-            rescue(err);
-          } else {
-            await dbCreate();
-            exit(0);
-          }
+          tryCatch(async () => {
+            if (err) {
+              rescue(err);
+            } else {
+              await dbCreate();
+              exit(0);
+            }
+          }, rescue);
         });
       }, rescue);
     });

diff --git a/test/helper.js b/test/helper.js
@@ -1,4 +1,5 @@
 import path from 'path';
+
 import Logger from '../src/packages/logger';
 import loader from '../src/packages/loader';
 import { createCompiler } from '../src/packages/compiler';