Update transformers logic

Author: keithwhor

cli/local_http.js

@@ -1,8 +1,8 @@
-const fs = require('fs');
 const path = require('path');
 
 const { Daemon, FunctionParser } = require('functionscript');
 const LocalGateway = require('./local_gateway');
+const Transformers = require('./transformers');
 const chalk = require('chalk');
 
 const processArgs = process.argv.slice(2).reduce((processArgs, val) => {
@@ -40,33 +40,8 @@ if (cluster.isMaster) {
     process.exit(1);
   }
 
-  // Load transformers
-  let transformers = [];
-  if (stdlib.transformers) {
-    if (!Array.isArray(stdlib.transformers)) {
-      throw new Error(`"stdlib.json": "transformers" must be an array`);
-    }
-    transformers = stdlib.transformers.map(transformerData => {
-      let Transformer;
-      let transformer;
-      if (!transformerData.pathname) {
-        throw new Error(`"stdlib.json": "transformers" object must contain "pathname"`);
-      }
-      try {
-        Transformer = require(path.join(process.cwd(), transformerData.pathname));
-        let config = transformerData.config || {};
-        if (!config || typeof config !== 'object') {
-          throw new Error(`"stdlib.json": "transformers[].config" must be empty or contain an object`);
-        }
-        transformer = new Transformer(config);
-        transformer.config = transformerData.config;
-      } catch (e) {
-        console.error(e);
-        throw new Error(`Could not load transformer: "${transformerData.pathname}"`);
-      }
-      return transformer;
-    });
-  }
+  const transformers = new Transformers(env, stdlib, 'local');
+  transformers.load();
 
   // Cluster to Gateway
   let gateway = new LocalGateway({
@@ -76,23 +51,7 @@ if (cluster.isMaster) {
   });
   let functionParser = new FunctionParser();
   try {
-    let preloadFiles = {};
-    transformers.forEach(transformer => {
-      let name = transformer.name || transformer.constructor.name;
-      let t = new Date().valueOf();
-      console.log(`\n[Transformer: ${name}] Execution starting`);
-      console.log(`[Transformer: ${name}] Using config ${JSON.stringify(transformer.config)}`);
-      let files = transformer.compile(process.cwd(), env.local);
-      Object.keys(files).forEach(pathname => {
-        if (preloadFiles[pathname]) {
-          throw new Error(`[Transformer: ${name}]: Previous Transformer has already defined "${pathname}"`);
-        } else {
-          preloadFiles[pathname] = files[pathname];
-        }
-      });
-      let t0 = new Date().valueOf() - t;
-      console.log(`[Transformer: ${name}] Executed in ${t0} ms`);
-    });
+    let preloadFiles = transformers.compile();
     gateway.service(ROUTE);
     gateway.environment(env.local || {});
     gateway.define(

cli/transformers.js

@@ -0,0 +1,74 @@
+const path = require('path');
+
+class Transformers {
+
+  constructor (env, stdlib, environment) {
+    this.env = env;
+    this.stdlib = stdlib;
+    this.environment = environment;
+    this.list = [];
+  }
+
+  load () {
+    let stdlib = this.stdlib;
+    let transformers = [];
+    if (stdlib.transformers) {
+      if (!Array.isArray(stdlib.transformers)) {
+        throw new Error(`"stdlib.json": "transformers" must be an array`);
+      }
+      transformers = stdlib.transformers.map(transformerData => {
+        let Transformer;
+        let transformer;
+        if (!transformerData.pathname) {
+          throw new Error(`"stdlib.json": "transformers" object must contain "pathname"`);
+        }
+        try {
+          Transformer = require(path.join(process.cwd(), transformerData.pathname));
+          let config = transformerData.config || {};
+          if (!config || typeof config !== 'object') {
+            throw new Error(`"stdlib.json": "transformers[].config" must be empty or contain an object`);
+          }
+          let configEnv = config[this.environment] || {};
+          if (!config[this.environment] || typeof config[this.environment] !== 'object') {
+            throw new Error(`"stdlib.json": "transformers[].config['${this.environment}']" must be empty or contain an object`);
+          }
+          transformer = new Transformer(config[this.environment]);
+          transformer.config = transformerData.config[this.environment];
+        } catch (e) {
+          console.error(e);
+          throw new Error(`Could not load transformer: "${transformerData.pathname}"`);
+        }
+        return transformer;
+      });
+    }
+    return this.list = transformers;
+  }
+
+  compile () {
+    let preloadFiles = {};
+    this.list.forEach(transformer => {
+      let name = transformer.name || transformer.constructor.name;
+      let t = new Date().valueOf();
+      console.log(`\n[Transformer: ${name}] Execution starting`);
+      console.log(
+        `[Transformer: ${name}] Using config from stdlib.json: ` +
+        `transformers[].config.local\n` +
+        `${JSON.stringify(transformer.config, null, 2)}`
+      );
+      let files = transformer.compile(process.cwd(), this.env[this.environment]);
+      Object.keys(files).forEach(pathname => {
+        if (preloadFiles[pathname]) {
+          throw new Error(`[Transformer: ${name}]: Previous Transformer has already defined "${pathname}"`);
+        } else {
+          preloadFiles[pathname] = files[pathname];
+        }
+      });
+      let t0 = new Date().valueOf() - t;
+      console.log(`[Transformer: ${name}] Executed in ${t0} ms`);
+    });
+    return preloadFiles;
+  }
+
+}
+
+module.exports = Transformers;