3.0.1

.gitignore

@@ -1,4 +1,20 @@
-node_modules/
+.nogit/
+
+# artifacts
 coverage/
-pages/
 public/
+pages/
+
+# installs
+node_modules/
+
+# caches
+.yarn/
+.cache/
+.rpt2_cache
+
+# builds
+dist/
+dist_*/
+
+# custom

.gitlab-ci.yml

@@ -1,49 +1,128 @@
-image: hosttoday/ht-docker-node:npmts
+# gitzone ci_default
+image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+
+cache:
+  paths:
+    - .npmci_cache/
+  key: '$CI_BUILD_STAGE'
 
 stages:
-- test
-- release
-- page
+  - security
+  - test
+  - release
+  - metadata
 
-testLEGACY:
+before_script:
+  - npm install -g @shipzone/npmci
+
+# ====================
+# security stage
+# ====================
+auditProductionDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  stage: security
+  script:
+    - npmci npm prepare
+    - npmci command npm install --production --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=prod --production
+  tags:
+    - docker
+  allow_failure: true
+
+auditDevDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  stage: security
+  script:
+    - npmci npm prepare
+    - npmci command npm install --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=dev
+  tags:
+    - docker
+  allow_failure: true
+
+# ====================
+# test stage
+# ====================
+
+testStable:
   stage: test
   script:
-    - npmci test legacy
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci npm test
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
 
-testLTS:
+testBuild:
   stage: test
   script:
-    - npmci test lts
-  tags:
-    - docker
-    
-testSTABLE:
-  stage: test
-  script:
-    - npmci test stable
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci command npm run build
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
 
 release:
   stage: release
-  environment: npmjs-com_registry
   script:
-    - npmci publish
+    - npmci node install stable
+    - npmci npm publish
   only:
     - tags
   tags:
+    - lossless
     - docker
+    - notpriv
+
+# ====================
+# metadata stage
+# ====================
+codequality:
+  stage: metadata
+  allow_failure: true
+  only:
+    - tags
+  script:
+    - npmci command npm install -g typescript
+    - npmci npm prepare
+    - npmci npm install
+  tags:
+    - lossless
+    - docker
+    - priv
+
+trigger:
+  stage: metadata
+  script:
+    - npmci trigger
+  only:
+    - tags
+  tags:
+    - lossless
+    - docker
+    - notpriv
 
 pages:
-  image: hosttoday/ht-docker-node:npmpage
-  stage: page
+  stage: metadata
   script:
-    - npmci command npmpage --host gitlab
+    - npmci node install stable 
+    - npmci npm prepare
+    - npmci npm install
+    - npmci command npm run buildDocs
+  tags:
+    - lossless
+    - docker
+    - notpriv
   only:
     - tags
   artifacts:
     expire_in: 1 week
     paths:
-    - public
+      - public
+  allow_failure: true

.vscode/launch.json

@@ -0,0 +1,11 @@
+{
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "command": "npm test",
+      "name": "Run npm test",
+      "request": "launch",
+      "type": "node-terminal"
+    }
+  ]
+}

.vscode/settings.json

@@ -0,0 +1,26 @@
+{
+  "json.schemas": [
+    {
+      "fileMatch": ["/npmextra.json"],
+      "schema": {
+        "type": "object",
+        "properties": {
+          "npmci": {
+            "type": "object",
+            "description": "settings for npmci"
+          },
+          "gitzone": {
+            "type": "object",
+            "description": "settings for gitzone",
+            "properties": {
+              "projectType": {
+                "type": "string",
+                "enum": ["website", "element", "service", "npm", "wcc"]
+              }
+            }
+          }
+        }
+      }
+    }
+  ]
+}

README.md

@@ -1,68 +0,0 @@
-# smartipc
-smart subprocess handling
-
-## Availabililty
-[![npm](https://push.rocks/assets/repo-button-npm.svg)](https://www.npmjs.com/package/smartipc)
-[![git](https://push.rocks/assets/repo-button-git.svg)](https://gitlab.com/pushrocks/smartipc)
-[![git](https://push.rocks/assets/repo-button-mirror.svg)](https://github.com/pushrocks/smartipc)
-[![docs](https://push.rocks/assets/repo-button-docs.svg)](https://pushrocks.gitlab.io/smartipc/)
-
-## Status for master
-[![build status](https://gitlab.com/pushrocks/smartipc/badges/master/build.svg)](https://gitlab.com/pushrocks/smartipc/commits/master)
-[![coverage report](https://gitlab.com/pushrocks/smartipc/badges/master/coverage.svg)](https://gitlab.com/pushrocks/smartipc/commits/master)
-[![Dependency Status](https://david-dm.org/pushrocks/smartipc.svg)](https://david-dm.org/pushrocks/smartipc)
-[![bitHound Dependencies](https://www.bithound.io/github/pushrocks/smartipc/badges/dependencies.svg)](https://www.bithound.io/github/pushrocks/smartipc/master/dependencies/npm)
-[![bitHound Code](https://www.bithound.io/github/pushrocks/smartipc/badges/code.svg)](https://www.bithound.io/github/pushrocks/smartipc)
-[![TypeScript](https://img.shields.io/badge/TypeScript-2.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
-[![node](https://img.shields.io/badge/node->=%206.x.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
-[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-standard-brightgreen.svg)](http://standardjs.com/)
-
-## The purpose
-smartipc makes it easy to spawn tasks into subprocesses without loosing control over what those processes do.
-You can transparently call functions and expect returned data using promises.
-
-## Usage
-
-Server:
-```typescript
-import {Ipcserver} from 'smartipc'
-import * as q from 'q'
-
-let myIpcserver = new Ipcserver({
-    appspace: 'mymodule'
-})
-
-// The subprocess js file cannot have any cli arguments
-// since this mechanism is used by IpcServer to setup the connection
-myIpcServer.spawnProcess('./myFile','mySubProcessNameAlias') // nameAlias identifies the subprocess and will prefix any logs from child Process
-
-let someData = {
-    key1: 'value1',
-    key2: 'value2'
-}
-
-myIpcServer.call('mySubProcessNameAlias','myAwesomeFunction',someData).then(someAnswerData => {
-    console.log(someAnswerData.key1)
-})
-
-```
-
-Client:
-```typescript
-import { Ipcclient } from './smartipc'
-import * as q from 'q'
-
-let localIpc = new Ipcclient() // gets its connection information automatically using CLI args internally
-
-let myAwesomeFunction = (dataArg) => {
-    let done = plugins.q.defer()
-    console.log('awesome') // this will log transparently in the same console stream as the host process
-    let someAnswerData = {key1: 'this is an answer'}
-    done.resolve(someAnswerData)
-    return done.promise
-}
-
-localIpc.register([myAwesomeFunction])
-```
-
-[![npm](https://push.rocks/assets/repo-header.svg)](https://push.rocks)

assets/typescriptwrap.js

@@ -0,0 +1,2 @@
+require('@gitzone/tsrun');
+require('spawn-wrap').runMain()

dist/index.d.ts

@@ -1,2 +0,0 @@
-export * from './smartipc.classes.thread';
-export * from './smartipc.classes.threadfunction';

dist/index.js

@@ -1,7 +0,0 @@
-"use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
-__export(require("./smartipc.classes.thread"));
-__export(require("./smartipc.classes.threadfunction"));
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBQUEsK0NBQXlDO0FBQ3pDLHVEQUFpRCJ9

dist/smartipc.classes.thread.d.ts

@@ -1,10 +0,0 @@
-export declare let setWorkerBasePath: (basePathArg: string) => void;
-export declare class Thread {
-    thread: any;
-    constructor(filePathArg: string);
-    /**
-     * sends a message to the spawned process
-     */
-    send<T>(message: any): Promise<T>;
-    kill(): void;
-}

dist/smartipc.classes.thread.js

@@ -1,32 +0,0 @@
-"use strict";
-const plugins = require("./smartipc.plugins");
-const q = require("smartq");
-exports.setWorkerBasePath = (basePathArg) => {
-    plugins.threads.config.set({
-        basepath: {
-            node: basePathArg
-        }
-    });
-};
-class Thread {
-    constructor(filePathArg) {
-        this.thread = plugins.threads.spawn(filePathArg);
-    }
-    /**
-     * sends a message to the spawned process
-     */
-    send(message) {
-        let done = q.defer();
-        this.thread.send(message).on('message', (message) => {
-            done.resolve(message);
-        }).on('error', err => {
-            done.reject(err);
-        });
-        return done.promise;
-    }
-    kill() {
-        this.thread.kill();
-    }
-}
-exports.Thread = Thread;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWQuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGlwYy5jbGFzc2VzLnRocmVhZC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsOENBQTZDO0FBQzdDLDRCQUEyQjtBQUVoQixRQUFBLGlCQUFpQixHQUFHLENBQUMsV0FBbUI7SUFDL0MsT0FBTyxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDO1FBQ3ZCLFFBQVEsRUFBRTtZQUNOLElBQUksRUFBRSxXQUFXO1NBQ3BCO0tBQ0osQ0FBQyxDQUFBO0FBQ04sQ0FBQyxDQUFBO0FBRUQ7SUFFSSxZQUFZLFdBQW1CO1FBQzNCLElBQUksQ0FBQyxNQUFNLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsV0FBVyxDQUFDLENBQUE7SUFDcEQsQ0FBQztJQUVEOztPQUVHO0lBQ0gsSUFBSSxDQUFJLE9BQVk7UUFDaEIsSUFBSSxJQUFJLEdBQUcsQ0FBQyxDQUFDLEtBQUssRUFBSyxDQUFBO1FBQ3ZCLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDLEVBQUUsQ0FBQyxTQUFTLEVBQUUsQ0FBQyxPQUFVO1lBQy9DLElBQUksQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLENBQUE7UUFDekIsQ0FBQyxDQUFDLENBQUMsRUFBRSxDQUFDLE9BQU8sRUFBRSxHQUFHO1lBQ2QsSUFBSSxDQUFDLE1BQU0sQ0FBQyxHQUFHLENBQUMsQ0FBQTtRQUNwQixDQUFDLENBQUMsQ0FBQTtRQUNGLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFBO0lBQ3ZCLENBQUM7SUFFRCxJQUFJO1FBQ0EsSUFBSSxDQUFDLE1BQU0sQ0FBQyxJQUFJLEVBQUUsQ0FBQTtJQUN0QixDQUFDO0NBQ0o7QUF0QkQsd0JBc0JDIn0=

dist/smartipc.classes.threadfunction.d.ts

@@ -1,13 +0,0 @@
-import 'typings-global';
-export interface IThreadFunction {
-    (input: any, done: any): void;
-}
-export declare class ThreadFunction {
-    thread: any;
-    constructor(functionArg: IThreadFunction);
-    /**
-     * sends a message to the spawned process
-     */
-    send<T>(message: any): Promise<T>;
-    kill(): void;
-}

dist/smartipc.classes.threadfunction.js

@@ -1,26 +0,0 @@
-"use strict";
-require("typings-global");
-const plugins = require("./smartipc.plugins");
-const q = require("smartq");
-class ThreadFunction {
-    constructor(functionArg) {
-        this.thread = plugins.threads.spawn(functionArg);
-    }
-    /**
-     * sends a message to the spawned process
-     */
-    send(message) {
-        let done = q.defer();
-        this.thread.send(message).on('message', (message) => {
-            done.resolve(message);
-        }).on('error', err => {
-            done.reject(err);
-        });
-        return done.promise;
-    }
-    kill() {
-        this.thread.kill();
-    }
-}
-exports.ThreadFunction = ThreadFunction;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWRmdW5jdGlvbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0aXBjLmNsYXNzZXMudGhyZWFkZnVuY3Rpb24udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLDBCQUF1QjtBQUN2Qiw4Q0FBNkM7QUFDN0MsNEJBQTJCO0FBTTNCO0lBRUksWUFBWSxXQUE0QjtRQUNwQyxJQUFJLENBQUMsTUFBTSxHQUFHLE9BQU8sQ0FBQyxPQUFPLENBQUMsS0FBSyxDQUFDLFdBQVcsQ0FBQyxDQUFBO0lBQ3BELENBQUM7SUFFRDs7T0FFRztJQUNILElBQUksQ0FBSSxPQUFZO1FBQ2hCLElBQUksSUFBSSxHQUFHLENBQUMsQ0FBQyxLQUFLLEVBQUssQ0FBQTtRQUN2QixJQUFJLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQyxFQUFFLENBQUMsU0FBUyxFQUFFLENBQUMsT0FBVTtZQUMvQyxJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ3pCLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUUsR0FBRztZQUNkLElBQUksQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLENBQUE7UUFDcEIsQ0FBQyxDQUFDLENBQUE7UUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtJQUN2QixDQUFDO0lBRUQsSUFBSTtRQUNBLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxFQUFFLENBQUE7SUFDdEIsQ0FBQztDQUNKO0FBdEJELHdDQXNCQyJ9

dist/smartipc.plugins.d.ts

@@ -1,4 +0,0 @@
-import 'typings-global';
-declare let threads: any;
-import * as smartq from 'smartq';
-export { smartq, threads };

dist/smartipc.plugins.js

@@ -1,7 +0,0 @@
-"use strict";
-require("typings-global");
-let threads = require('threads');
-exports.threads = threads;
-const smartq = require("smartq");
-exports.smartq = smartq;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMucGx1Z2lucy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0aXBjLnBsdWdpbnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLDBCQUF1QjtBQUN2QixJQUFJLE9BQU8sR0FBRyxPQUFPLENBQUMsU0FBUyxDQUFDLENBQUE7QUFLNUIsMEJBQU87QUFKWCxpQ0FBZ0M7QUFHNUIsd0JBQU0ifQ==

dist/smartipc.pool.js

@@ -1 +0,0 @@
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMucG9vbC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0aXBjLnBvb2wudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IiJ9

npmextra.json

@@ -1,7 +1,22 @@
 {
-    "npmts": {
-        "testTs": {
-            "./test/*.ts": "./test/"
-        }
+  "npmts": {
+    "testTs": {
+      "./test/*.ts": "./test/"
     }
+  },
+  "npmci": {
+    "npmGlobalTools": [],
+    "npmAccessLevel": "public"
+  },
+  "gitzone": {
+    "projectType": "npm",
+    "module": {
+      "githost": "gitlab.com",
+      "gitscope": "pushrocks",
+      "gitrepo": "smartspawn",
+      "description": "smart subprocess handling",
+      "npmPackagename": "@pushrocks/smartspawn",
+      "license": "MIT"
+    }
+  }
 }

package.json

@@ -1,11 +1,15 @@
 {
-  "name": "smartipc",
-  "version": "1.0.1",
+  "name": "@pushrocks/smartspawn",
+  "version": "3.0.1",
+  "private": false,
   "description": "smart subprocess handling",
-  "main": "dist/index.js",
-  "typings": "dist/index.d.ts",
+  "main": "dist_ts/index.js",
+  "typings": "dist_ts/index.d.ts",
+  "type": "module",
   "scripts": {
-    "test": "(npmts)"
+    "test": "(tstest test/)",
+    "build": "(tsbuild --web)",
+    "buildDocs": "tsdoc"
   },
   "repository": {
     "type": "git",
@@ -18,16 +22,31 @@
   },
   "homepage": "https://gitlab.com/pushrocks/smartipc#README",
   "dependencies": {
-    "@types/lodash": "^4.14.50",
-    "beautylog": "^6.0.0",
-    "lodash": "^4.17.4",
-    "smartq": "^1.1.0",
-    "threads": "^0.7.2",
-    "typings-global": "^1.0.14"
+    "@pushrocks/smartpromise": "^3.0.2",
+    "spawn-wrap": "^2.0.0",
+    "threads": "1.7.0",
+    "tiny-worker": "^2.2.0"
   },
   "devDependencies": {
-    "@types/should": "^8.1.30",
-    "should": "^11.1.2",
-    "typings-test": "^1.0.3"
-  }
+    "@gitzone/tsbuild": "^2.1.11",
+    "@gitzone/tsrun": "^1.2.8",
+    "@gitzone/tstest": "^1.0.24",
+    "@pushrocks/tapbundle": "^5.0.4",
+    "@types/node": "^18.6.2"
+  },
+  "files": [
+    "ts/**/*",
+    "ts_web/**/*",
+    "dist/**/*",
+    "dist_*/**/*",
+    "dist_ts/**/*",
+    "dist_ts_web/**/*",
+    "assets/**/*",
+    "cli.js",
+    "npmextra.json",
+    "readme.md"
+  ],
+  "browserslist": [
+    "last 1 chrome versions"
+  ]
 }

readme.md

@@ -0,0 +1,64 @@
+# @pushrocks/smartspawn
+smart subprocess handling
+
+## Availabililty and Links
+* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartspawn)
+* [gitlab.com (source)](https://gitlab.com/pushrocks/smartspawn)
+* [github.com (source mirror)](https://github.com/pushrocks/smartspawn)
+* [docs (typedoc)](https://pushrocks.gitlab.io/smartspawn/)
+
+## Status for master
+
+Status Category | Status Badge
+-- | --
+GitLab Pipelines | [![pipeline status](https://gitlab.com/pushrocks/smartspawn/badges/master/pipeline.svg)](https://lossless.cloud)
+GitLab Pipline Test Coverage | [![coverage report](https://gitlab.com/pushrocks/smartspawn/badges/master/coverage.svg)](https://lossless.cloud)
+npm | [![npm downloads per month](https://badgen.net/npm/dy/@pushrocks/smartspawn)](https://lossless.cloud)
+Snyk | [![Known Vulnerabilities](https://badgen.net/snyk/pushrocks/smartspawn)](https://lossless.cloud)
+TypeScript Support | [![TypeScript](https://badgen.net/badge/TypeScript/>=%203.x/blue?icon=typescript)](https://lossless.cloud)
+node Support | [![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
+Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](https://lossless.cloud)
+PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/smartspawn)](https://lossless.cloud)
+PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/smartspawn)](https://lossless.cloud)
+BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/smartspawn)](https://lossless.cloud)
+Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)
+
+## Usage
+
+Use TypeScript for best in class instellisense.
+
+### Understand the Purpose
+
+smartipc makes it easy to spawn tasks into subprocesses without loosing control over what those processes do.
+You can transparently call functions and expect returned data using promises.
+
+### How To
+
+**Master.ts:**
+
+```javascript
+import * as smartspawn from 'smartspawn';
+smartspawn.setBasePathArg(__dirname); // if you want to avoid typings out full paths every time
+
+let myThread = new smartspawn.Thread('worker');
+myThread.send('someMessageOrObject').then((messageResponse) => {
+  console.log(messageResponse);
+});
+```
+
+**worker.ts**
+
+```javascript
+
+```
+
+## Contribution
+
+We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
+
+For further information read the linked docs at the top of this readme.
+
+> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
+| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
+
+[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com)

test/child.d.ts

@@ -1,2 +0,0 @@
-import 'typings-global';
-import 'smartq';

test/child.js

@@ -1,7 +0,0 @@
-"use strict";
-require("typings-global");
-require("smartq");
-module.exports = (input, done) => {
-    done('hi');
-};
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY2hpbGQuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJjaGlsZC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXVCO0FBQ3ZCLGtCQUFlO0FBQ2YsTUFBTSxDQUFDLE9BQU8sR0FBRyxDQUFDLEtBQUssRUFBRSxJQUFJO0lBQ3pCLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQTtBQUNkLENBQUMsQ0FBQSJ9

test/child.ts

@@ -1,5 +0,0 @@
-import 'typings-global'
-import 'smartq'
-module.exports = (input, done) => {
-    done('hi')
-}

test/test.d.ts

@@ -1 +0,0 @@
-import 'typings-test';

test/test.js

@@ -1,26 +0,0 @@
-"use strict";
-require("typings-test");
-const smartipc = require("../dist/index");
-let testThreadFunction;
-let testThread;
-describe('smartipc', function () {
-    it('should create an instance of ThreadFunction', function () {
-        testThreadFunction = new smartipc.ThreadFunction((input, done) => {
-            let url = require('url');
-            done(url.parse(input));
-        });
-        testThreadFunction.send('https://google.com').then(message => {
-            console.log(message);
-            testThreadFunction.kill();
-        });
-    });
-    it('should create an instance of Thread', function () {
-        smartipc.setWorkerBasePath(__dirname);
-        testThread = new smartipc.Thread('child.js');
-        testThread.send('https://google.com').then(message => {
-            console.log(message);
-            testThread.kill();
-        });
-    });
-});
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHdCQUFxQjtBQUVyQiwwQ0FBeUM7QUFFekMsSUFBSSxrQkFBMkMsQ0FBQTtBQUMvQyxJQUFJLFVBQTJCLENBQUE7QUFFL0IsUUFBUSxDQUFDLFVBQVUsRUFBQztJQUNoQixFQUFFLENBQUMsNkNBQTZDLEVBQUM7UUFDN0Msa0JBQWtCLEdBQUcsSUFBSSxRQUFRLENBQUMsY0FBYyxDQUFDLENBQUMsS0FBSyxFQUFFLElBQUk7WUFDekQsSUFBSSxHQUFHLEdBQUcsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFBO1lBQ3hCLElBQUksQ0FBQyxHQUFHLENBQUMsS0FBSyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUE7UUFDMUIsQ0FBQyxDQUFDLENBQUE7UUFDRixrQkFBa0IsQ0FBQyxJQUFJLENBQUMsb0JBQW9CLENBQUMsQ0FBQyxJQUFJLENBQUMsT0FBTztZQUN0RCxPQUFPLENBQUMsR0FBRyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1lBQ3BCLGtCQUFrQixDQUFDLElBQUksRUFBRSxDQUFBO1FBQzdCLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUE7SUFDRixFQUFFLENBQUMscUNBQXFDLEVBQUM7UUFDckMsUUFBUSxDQUFDLGlCQUFpQixDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBQ3JDLFVBQVUsR0FBRyxJQUFJLFFBQVEsQ0FBQyxNQUFNLENBQUMsVUFBVSxDQUFDLENBQUE7UUFDNUMsVUFBVSxDQUFDLElBQUksQ0FBQyxvQkFBb0IsQ0FBQyxDQUFDLElBQUksQ0FBQyxPQUFPO1lBQzlDLE9BQU8sQ0FBQyxHQUFHLENBQUMsT0FBTyxDQUFDLENBQUE7WUFDcEIsVUFBVSxDQUFDLElBQUksRUFBRSxDQUFBO1FBQ3JCLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUE7QUFDTixDQUFDLENBQUMsQ0FBQSJ9

test/test.ts

@@ -1,27 +1,7 @@
-import 'typings-test'
+import { expect, tap } from '@pushrocks/tapbundle';
 
-import * as smartipc from '../dist/index'
+import * as smartspawn from '../ts/index.js';
 
-let testThreadFunction: smartipc.ThreadFunction
-let testThread: smartipc.Thread
+tap.test('should create a simple test function', async () => {});
 
-describe('smartipc',function(){
-    it('should create an instance of ThreadFunction',function(){
-        testThreadFunction = new smartipc.ThreadFunction((input, done) => {
-            let url = require('url')
-            done(url.parse(input))
-        })
-        testThreadFunction.send('https://google.com').then(message => {
-            console.log(message)
-            testThreadFunction.kill()
-        })
-    })
-    it('should create an instance of Thread',function(){
-        smartipc.setWorkerBasePath(__dirname)
-        testThread = new smartipc.Thread('child.js')
-        testThread.send('https://google.com').then(message => {
-            console.log(message)
-            testThread.kill()
-        })
-    })
-})
+tap.start();

testassets/child.ts

@@ -0,0 +1,3 @@
+module.exports = (input, done) => {
+  done(input);
+};

ts/00_commitinfo_data.ts

@@ -0,0 +1,8 @@
+/**
+ * autocreated commitinfo by @pushrocks/commitinfo
+ */
+export const commitinfo = {
+  name: '@pushrocks/smartspawn',
+  version: '3.0.1',
+  description: 'smart subprocess handling'
+}

ts/index.ts

@@ -1,2 +1,4 @@
-export * from './smartipc.classes.thread'
-export * from './smartipc.classes.threadfunction'
+export * from './smartspawn.classes.threadsimple.js';
+export * from './smartspawn.wrap.js';
+
+export * from 'threads';

ts/smartipc.classes.thread.ts

@@ -1,34 +0,0 @@
-import * as plugins from './smartipc.plugins'
-import * as q from 'smartq'
-
-export let setWorkerBasePath = (basePathArg: string) => {
-    plugins.threads.config.set({
-        basepath: {
-            node: basePathArg
-        }
-    })
-}
-
-export class Thread {
-    thread
-    constructor(filePathArg: string) {
-        this.thread = plugins.threads.spawn(filePathArg)
-    }
-
-    /**
-     * sends a message to the spawned process
-     */
-    send<T>(message: any): Promise<T> {
-        let done = q.defer<T>()
-        this.thread.send(message).on('message', (message: T) => {
-            done.resolve(message)
-        }).on('error', err => {
-            done.reject(err)
-        })
-        return done.promise
-    }
-
-    kill() {
-        this.thread.kill()
-    }
-}

ts/smartipc.classes.threadfunction.ts

@@ -1,31 +0,0 @@
-import 'typings-global'
-import * as plugins from './smartipc.plugins'
-import * as q from 'smartq'
-
-export interface IThreadFunction {
-    (input, done): void
-}
-
-export class ThreadFunction {
-    thread
-    constructor(functionArg: IThreadFunction) {
-        this.thread = plugins.threads.spawn(functionArg)
-    }
-
-    /**
-     * sends a message to the spawned process
-     */
-    send<T>(message: any): Promise<T> {
-        let done = q.defer<T>()
-        this.thread.send(message).on('message', (message: T) => {
-            done.resolve(message)
-        }).on('error', err => {
-            done.reject(err)
-        })
-        return done.promise
-    }
-
-    kill() {
-        this.thread.kill()
-    }
-}

ts/smartipc.plugins.ts

@@ -1,8 +0,0 @@
-import 'typings-global'
-let threads = require('threads')
-import * as smartq from 'smartq'
-
-export {
-    smartq,
-    threads
-}

ts/smartspawn.classes.threadsimple.ts

@@ -0,0 +1,29 @@
+import * as plugins from './smartspawn.plugins.js';
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as childProcess from 'child_process';
+
+export class ThreadSimple {
+  public workerPath: string;
+  public threadChildProcess: childProcess.ChildProcess;
+  public forkOptions: childProcess.ForkOptions;
+  public argvArgs: string[];
+  constructor(
+    filePathArg: string,
+    argvArgs: string[] = [],
+    forkOptionsArg: childProcess.ForkOptions = {}
+  ) {
+    this.workerPath = filePathArg;
+    this.forkOptions = forkOptionsArg;
+    this.argvArgs = argvArgs;
+  }
+
+  public async start() {
+    const forkPath = this.workerPath;
+    this.threadChildProcess = childProcess.fork(forkPath, this.argvArgs, this.forkOptions);
+    return this.threadChildProcess;
+  }
+
+  public async stop() {
+    this.threadChildProcess.kill();
+  }
+}

ts/smartspawn.paths.ts

@@ -0,0 +1,4 @@
+import * as plugins from './smartspawn.plugins.js';
+
+export const packageBase = plugins.path.join(__dirname, '../');
+export const typescriptwrapJs = plugins.path.join(packageBase, 'assets/typescriptwrap.js');

ts/smartspawn.plugins.ts

@@ -0,0 +1,5 @@
+import * as path from 'path';
+import * as threads from 'threads';
+import * as smartpromise from '@pushrocks/smartpromise';
+
+export { path, smartpromise, threads };

ts/smartspawn.wrap.ts

@@ -0,0 +1,18 @@
+import * as spawnWrap from 'spawn-wrap';
+
+let unwrap: any = null;
+
+export const startSpawnWrap = (filePath: string, cliArgs: string[] = [], envArgs: any = {}) => {
+  const spawnArray = [filePath];
+  for (const cliArg of cliArgs) {
+    spawnArray.push(cliArg);
+  }
+  unwrap = spawnWrap(spawnArray, envArgs);
+};
+
+export const endSpawnWrap = () => {
+  if (unwrap) {
+    unwrap();
+    unwrap = null;
+  }
+};

tslint.json

@@ -1,3 +0,0 @@
-{
-    "extends": "tslint-config-standard"
-}