refactor ConcatMultiple (typescript), remove generateBrokerWatch

examples/empty-broker/package.json

@@ -6,15 +6,16 @@
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
     "build": "tsc",
-    "dev:watch": "ts-node src/dev.watch.ts",
+    "dev:watch": "ts-node src/bin/dev.watch.ts",
+    "dev:broker:gen": "ts-node src/bin/dev.broker.gen.ts",
     "postinstall": "ts-patch install"
   },
   "author": "",
   "license": "ISC",
   "dependencies": {
     "moleculer": "^0.13.11",
     "moleculer-decorators": "^1.1.1",
-    "moleculer-ts": "^1.0.5"
+    "moleculer-ts": "file:../.."
   },
   "devDependencies": {
     "prettier": "^1.18.2",

examples/empty-broker/src/bin/dev.broker.gen.ts

@@ -0,0 +1,43 @@
+import { generateBroker } from 'moleculer-ts';
+import watch from 'glob-watcher';
+
+const brokers = ['empty-broker'];
+
+export function isWatchMode() {
+  return process.argv.length >= 2 && process.argv[2] === '--watch';
+}
+
+brokers.forEach(async broker => {
+  let brokerRootDir = `${process.cwd()}/src/${broker}`;
+  const generateBrokerOptions = {
+    serviceTypesPattern: `${brokerRootDir}/**/*.service.types.ts`,
+    outputDir: `${brokerRootDir}/types`,
+  };
+
+  if (isWatchMode()) {
+    const watcher = watch(
+      generateBrokerOptions.serviceTypesPattern,
+      async done => {
+        try {
+          await generateBroker(generateBrokerOptions);
+        } catch (err) {
+          console.error(err);
+        } finally {
+          done();
+        }
+      },
+    );
+    watcher.on('change', filename => {
+      console.log(`Generate broker ${broker}, file changed: `, filename);
+    });
+  }
+  console.log(`Generate broker ${broker}`);
+  await generateBroker(generateBrokerOptions);
+});
+
+process.on('unhandledRejection', (reason, promise) => {
+  console.error('Unhandled Rejection at:', promise, 'reason:', reason);
+  if (!isWatchMode()) {
+    process.exit(1);
+  }
+});

examples/empty-broker/src/bin/dev.watch.ts

@@ -0,0 +1 @@
+require('./dev.broker.gen');