Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
fcdcd4b929 | |||
c2f7e98481 | |||
a2242105a1 | |||
44431e7d25 | |||
3999015b23 | |||
77ad483a8a | |||
904309564a | |||
d8c03fd9ca |
22
.gitignore
vendored
22
.gitignore
vendored
@ -1,4 +1,22 @@
|
|||||||
node_modules/
|
.nogit/
|
||||||
|
|
||||||
|
# artifacts
|
||||||
coverage/
|
coverage/
|
||||||
pages/
|
|
||||||
public/
|
public/
|
||||||
|
pages/
|
||||||
|
|
||||||
|
# installs
|
||||||
|
node_modules/
|
||||||
|
|
||||||
|
# caches
|
||||||
|
.yarn/
|
||||||
|
.cache/
|
||||||
|
.rpt2_cache
|
||||||
|
|
||||||
|
# builds
|
||||||
|
dist/
|
||||||
|
dist_web/
|
||||||
|
dist_serve/
|
||||||
|
dist_ts_web/
|
||||||
|
|
||||||
|
# custom
|
@ -1,5 +1,7 @@
|
|||||||
# gitzone standard
|
# gitzone ci_default
|
||||||
image: hosttoday/ht-docker-node:npmci
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
|
variables:
|
||||||
|
GIT_STRATEGY: clone
|
||||||
|
|
||||||
cache:
|
cache:
|
||||||
paths:
|
paths:
|
||||||
@ -26,6 +28,7 @@ mirror:
|
|||||||
snyk:
|
snyk:
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
- npmci command npm install -g snyk
|
- npmci command npm install -g snyk
|
||||||
- npmci command npm install --ignore-scripts
|
- npmci command npm install --ignore-scripts
|
||||||
- npmci command snyk test
|
- npmci command snyk test
|
||||||
@ -36,35 +39,26 @@ snyk:
|
|||||||
# ====================
|
# ====================
|
||||||
# test stage
|
# test stage
|
||||||
# ====================
|
# ====================
|
||||||
testLEGACY:
|
|
||||||
stage: test
|
|
||||||
script:
|
|
||||||
- npmci node install legacy
|
|
||||||
- npmci npm install
|
|
||||||
- npmci npm test
|
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
|
||||||
tags:
|
|
||||||
- docker
|
|
||||||
- notpriv
|
|
||||||
allow_failure: true
|
|
||||||
|
|
||||||
testLTS:
|
testLTS:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
- npmci node install lts
|
- npmci node install lts
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
- priv
|
||||||
|
|
||||||
testSTABLE:
|
testBuild:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci node install stable
|
- npmci npm prepare
|
||||||
|
- npmci node install lts
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci command npm run build
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
@ -73,7 +67,7 @@ testSTABLE:
|
|||||||
release:
|
release:
|
||||||
stage: release
|
stage: release
|
||||||
script:
|
script:
|
||||||
- npmci node install stable
|
- npmci node install lts
|
||||||
- npmci npm publish
|
- npmci npm publish
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
@ -86,19 +80,11 @@ release:
|
|||||||
# ====================
|
# ====================
|
||||||
codequality:
|
codequality:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
image: docker:stable
|
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
services:
|
|
||||||
- docker:stable-dind
|
|
||||||
script:
|
script:
|
||||||
- export SP_VERSION=$(echo "$CI_SERVER_VERSION" | sed 's/^\([0-9]*\)\.\([0-9]*\).*/\1-\2-stable/')
|
- npmci command npm install -g tslint typescript
|
||||||
- docker run
|
- npmci npm install
|
||||||
--env SOURCE_CODE="$PWD"
|
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
||||||
--volume "$PWD":/code
|
|
||||||
--volume /var/run/docker.sock:/var/run/docker.sock
|
|
||||||
"registry.gitlab.com/gitlab-org/security-products/codequality:$SP_VERSION" /code
|
|
||||||
artifacts:
|
|
||||||
paths: [codeclimate.json]
|
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- priv
|
- priv
|
||||||
@ -114,12 +100,15 @@ trigger:
|
|||||||
- notpriv
|
- notpriv
|
||||||
|
|
||||||
pages:
|
pages:
|
||||||
image: hosttoday/ht-docker-node:npmci
|
image: hosttoday/ht-docker-dbase:npmci
|
||||||
|
services:
|
||||||
|
- docker:18-dind
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g typedoc typescript
|
- npmci command npm install -g @gitzone/tsdoc
|
||||||
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command typedoc --module "commonjs" --target "ES2016" --out public/ ts/
|
- npmci command tsdoc
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
- notpriv
|
||||||
@ -130,13 +119,3 @@ pages:
|
|||||||
paths:
|
paths:
|
||||||
- public
|
- public
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
|
||||||
windowsCompatibility:
|
|
||||||
image: stefanscherer/node-windows:10-build-tools
|
|
||||||
stage: metadata
|
|
||||||
script:
|
|
||||||
- npm install & npm test
|
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
|
||||||
tags:
|
|
||||||
- windows
|
|
||||||
allow_failure: true
|
|
||||||
|
35
README.md
35
README.md
@ -1,25 +1,20 @@
|
|||||||
# @pushrocks/smartspawn
|
# @pushrocks/smartspawn
|
||||||
|
|
||||||
smart subprocess handling
|
smart subprocess handling
|
||||||
|
|
||||||
## Availabililty
|
## Availabililty and Links
|
||||||
|
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartspawn)
|
||||||
[](https://www.npmjs.com/package/smartipc)
|
* [gitlab.com (source)](https://gitlab.com/pushrocks/smartspawn)
|
||||||
[](https://GitLab.com/pushrocks/smartipc)
|
* [github.com (source mirror)](https://github.com/pushrocks/smartspawn)
|
||||||
[](https://github.com/pushrocks/smartipc)
|
* [docs (typedoc)](https://pushrocks.gitlab.io/smartspawn/)
|
||||||
[](https://pushrocks.gitlab.io/smartipc/)
|
|
||||||
|
|
||||||
## Status for master
|
## Status for master
|
||||||
|
[](https://gitlab.com/pushrocks/smartspawn/commits/master)
|
||||||
[](https://GitLab.com/pushrocks/smartipc/commits/master)
|
[](https://gitlab.com/pushrocks/smartspawn/commits/master)
|
||||||
[](https://GitLab.com/pushrocks/smartipc/commits/master)
|
[](https://www.npmjs.com/package/@pushrocks/smartspawn)
|
||||||
[](https://www.npmjs.com/package/smartipc)
|
[](https://snyk.io/test/npm/@pushrocks/smartspawn)
|
||||||
[](https://david-dm.org/pushrocks/smartipc)
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartipc/master/dependencies/npm)
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartipc)
|
[](https://prettier.io/)
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
|
||||||
[](http://standardjs.com/)
|
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
@ -49,9 +44,9 @@ myThread.send('someMessageOrObject').then(messageResponse => {
|
|||||||
```javascript
|
```javascript
|
||||||
```
|
```
|
||||||
|
|
||||||
For further information read the linked docs at the top of this README.
|
For further information read the linked docs at the top of this readme.
|
||||||
|
|
||||||
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
> | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
|
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
|
||||||
|
|
||||||
[](https://push.rocks)
|
[](https://maintainedby.lossless.com)
|
||||||
|
@ -7,5 +7,15 @@
|
|||||||
"npmci": {
|
"npmci": {
|
||||||
"npmGlobalTools": [],
|
"npmGlobalTools": [],
|
||||||
"npmAccessLevel": "public"
|
"npmAccessLevel": "public"
|
||||||
|
},
|
||||||
|
"gitzone": {
|
||||||
|
"module": {
|
||||||
|
"githost": "gitlab.com",
|
||||||
|
"gitscope": "pushrocks",
|
||||||
|
"gitrepo": "smartspawn",
|
||||||
|
"shortDescription": "smart subprocess handling",
|
||||||
|
"npmPackagename": "@pushrocks/smartspawn",
|
||||||
|
"license": "MIT"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
1440
package-lock.json
generated
1440
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
34
package.json
34
package.json
@ -1,13 +1,13 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartspawn",
|
"name": "@pushrocks/smartspawn",
|
||||||
"version": "2.0.2",
|
"version": "2.0.6",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "smart subprocess handling",
|
"description": "smart subprocess handling",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist/index.d.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "tstest test/",
|
"test": "(tstest test/)",
|
||||||
"build": "echo \"Not needed for now\""
|
"build": "(tsbuild)"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -20,14 +20,28 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://gitlab.com/pushrocks/smartipc#README",
|
"homepage": "https://gitlab.com/pushrocks/smartipc#README",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@pushrocks/smartpromise": "^2.0.5",
|
"@pushrocks/smartpromise": "^3.0.2",
|
||||||
"spawn-wrap": "^1.4.2",
|
"spawn-wrap": "^1.4.2",
|
||||||
"threads": "^0.8.1"
|
"threads": "^0.12.1"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsrun": "^1.1.9",
|
"@gitzone/tsbuild": "^2.1.11",
|
||||||
"@gitzone/tstest": "^1.0.12",
|
"@gitzone/tsrun": "^1.2.8",
|
||||||
"@pushrocks/tapbundle": "^3.0.1",
|
"@gitzone/tstest": "^1.0.24",
|
||||||
"@types/node": "^10.5.5"
|
"@pushrocks/tapbundle": "^3.0.11",
|
||||||
}
|
"@types/node": "^12.7.2",
|
||||||
|
"tslint": "^5.19.0",
|
||||||
|
"tslint-config-prettier": "^1.18.0"
|
||||||
|
},
|
||||||
|
"files": [
|
||||||
|
"ts/*",
|
||||||
|
"ts_web/*",
|
||||||
|
"dist/*",
|
||||||
|
"dist_web/*",
|
||||||
|
"dist_ts_web/*",
|
||||||
|
"assets/*",
|
||||||
|
"cli.js",
|
||||||
|
"npmextra.json",
|
||||||
|
"readme.md"
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
import * as plugins from './smartspawn.plugins';
|
import * as plugins from './smartspawn.plugins';
|
||||||
import * as paths from './smartspawn.paths';
|
import * as paths from './smartspawn.paths';
|
||||||
import * as q from 'smartq';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
|
||||||
import { Pool } from './smartspawn.classes.pool';
|
import { Pool } from './smartspawn.classes.pool';
|
||||||
import { startSpawnWrap, endSpawnWrap } from './smartspawn.wrap';
|
import { startSpawnWrap, endSpawnWrap } from './smartspawn.wrap';
|
||||||
@ -30,7 +30,7 @@ export class Thread {
|
|||||||
* spawns it and keeps running
|
* spawns it and keeps running
|
||||||
*/
|
*/
|
||||||
send<T>(message: any): Promise<T> {
|
send<T>(message: any): Promise<T> {
|
||||||
let done = q.defer<T>();
|
let done = smartpromise.defer<T>();
|
||||||
this._checkSpawn();
|
this._checkSpawn();
|
||||||
this.thread.send(message);
|
this.thread.send(message);
|
||||||
this.thread.on('message', (message: T) => {
|
this.thread.on('message', (message: T) => {
|
||||||
@ -49,7 +49,7 @@ export class Thread {
|
|||||||
* sends a command once and then kills the child process
|
* sends a command once and then kills the child process
|
||||||
*/
|
*/
|
||||||
sendOnce<T>(message): Promise<T> {
|
sendOnce<T>(message): Promise<T> {
|
||||||
let done = q.defer<T>();
|
let done = smartpromise.defer<T>();
|
||||||
this.send<T>(message).then(message => {
|
this.send<T>(message).then(message => {
|
||||||
done.resolve(message);
|
done.resolve(message);
|
||||||
this.kill();
|
this.kill();
|
||||||
@ -69,7 +69,7 @@ export class Thread {
|
|||||||
this.assignedPool = poolArg;
|
this.assignedPool = poolArg;
|
||||||
}
|
}
|
||||||
|
|
||||||
enableTypeScript () {
|
enableTypeScript() {
|
||||||
// TODO:
|
// TODO:
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,6 +1,5 @@
|
|||||||
import 'typings-global';
|
|
||||||
import * as plugins from './smartspawn.plugins';
|
import * as plugins from './smartspawn.plugins';
|
||||||
import * as q from 'smartq';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
|
||||||
export interface IThreadFunction {
|
export interface IThreadFunction {
|
||||||
(input, done): void;
|
(input, done): void;
|
||||||
@ -16,7 +15,7 @@ export class ThreadFunction {
|
|||||||
* sends a message to the spawned process
|
* sends a message to the spawned process
|
||||||
*/
|
*/
|
||||||
send<T>(message: any): Promise<T> {
|
send<T>(message: any): Promise<T> {
|
||||||
let done = q.defer<T>();
|
let done = smartpromise.defer<T>();
|
||||||
this.thread
|
this.thread
|
||||||
.send(message)
|
.send(message)
|
||||||
.on('message', (message: T) => {
|
.on('message', (message: T) => {
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
import * as plugins from './smartspawn.plugins';
|
import * as plugins from './smartspawn.plugins';
|
||||||
import * as smartq from 'smartq';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
import * as childProcess from 'child_process';
|
import * as childProcess from 'child_process';
|
||||||
|
|
||||||
import { workerBasePath } from './smartspawn.classes.thread';
|
import { workerBasePath } from './smartspawn.classes.thread';
|
||||||
@ -20,7 +20,7 @@ export class ThreadSimple {
|
|||||||
}
|
}
|
||||||
|
|
||||||
run() {
|
run() {
|
||||||
let done = smartq.defer<childProcess.ChildProcess>();
|
let done = smartpromise.defer<childProcess.ChildProcess>();
|
||||||
let forkPath = (() => {
|
let forkPath = (() => {
|
||||||
if (workerBasePath) {
|
if (workerBasePath) {
|
||||||
return plugins.path.join(workerBasePath, this.workerPath);
|
return plugins.path.join(workerBasePath, this.workerPath);
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
import * as plugins from './smartspawn.plugins'
|
import * as plugins from './smartspawn.plugins';
|
||||||
|
|
||||||
export const packageBase = plugins.path.join(__dirname, '../');
|
export const packageBase = plugins.path.join(__dirname, '../');
|
||||||
export const typescriptwrapJs = plugins.path.join(packageBase, 'assets/typescriptwrap.js');
|
export const typescriptwrapJs = plugins.path.join(packageBase, 'assets/typescriptwrap.js');
|
@ -1,5 +1,5 @@
|
|||||||
import * as path from 'path';
|
import * as path from 'path';
|
||||||
let threads = require('threads');
|
const threads = require('threads');
|
||||||
import * as smartpromise from '@pushrocks/smartpromise';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
|
||||||
export { path, smartpromise, threads };
|
export { path, smartpromise, threads };
|
||||||
|
16
tslint.json
16
tslint.json
@ -1,3 +1,17 @@
|
|||||||
{
|
{
|
||||||
"extends": "tslint-config-standard"
|
"extends": ["tslint:latest", "tslint-config-prettier"],
|
||||||
|
"rules": {
|
||||||
|
"semicolon": [true, "always"],
|
||||||
|
"no-console": false,
|
||||||
|
"ordered-imports": false,
|
||||||
|
"object-literal-sort-keys": false,
|
||||||
|
"member-ordering": {
|
||||||
|
"options":{
|
||||||
|
"order": [
|
||||||
|
"static-method"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"defaultSeverity": "warning"
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user