Version 1.0.1

.travis.yml

@@ -1,8 +1,6 @@
 language: node_js
 node_js:
   - "node"
-  - "9"
-  - "8"
 script:
   - npm test
 after_success:

README.md

@@ -1 +1,8 @@
 # liqd-ipc
+
+[![NPM version](https://img.shields.io/npm/v/liqd-ipc.svg)](https://www.npmjs.com/package/liqd-ipc)
+[![Build Status](https://travis-ci.org/radixxko/liqd-ipc.svg?branch=master)](https://travis-ci.org/radixxko/liqd-ipc)
+[![Coverage Status](https://coveralls.io/repos/github/radixxko/liqd-ipc/badge.svg?branch=master)](https://coveralls.io/github/radixxko/liqd-ipc?branch=master)
+[![NPM downloads](https://img.shields.io/npm/dm/liqd-ipc.svg)](https://www.npmjs.com/package/liqd-ipc)
+[![Known Vulnerabilities](https://snyk.io/test/github/radixxko/liqd-ipc/badge.svg?targetFile=package.json)](https://snyk.io/test/github/radixxko/liqd-ipc?targetFile=package.json)
+[![MIT License](https://img.shields.io/badge/license-MIT-blue.svg)](LICENSE)

lib/ipc.js

@@ -1,5 +1,6 @@
 'use strict';
 
+//const Flow = require('liqd-flow');
 const Listeners = require('./listeners');
 const Replies = require('./replies');
 const Request = require('./request');
@@ -19,7 +20,21 @@ module.exports = class IPC
 			{
 				if( msg.__liqd_ipc.hasOwnProperty('reply') )
 				{
-					if( msg.__liqd_ipc.hasOwnProperty('error') )
+					/*if( msg.__liqd_ipc.flow )
+					{
+						const Flow = require('liqd-flow');
+
+						Flow.start(() =>
+						{
+							for( let key in msg.__liqd_ipc.flow )
+							{
+								Flow.set( key, msg.__liqd_ipc.flow[key].value, msg.__liqd_ipc.flow[key].frozen );
+							}
+
+							this._replies.resolve( msg.__liqd_ipc.reply, msg.__liqd_ipc );
+						});
+					}
+					else */if( msg.__liqd_ipc.hasOwnProperty('error') )
 					{
 						this._replies.reject( msg.__liqd_ipc.reply, msg.__liqd_ipc.error );
 					}
@@ -37,18 +52,38 @@ module.exports = class IPC
 						if( listener( request ) !== false ){ return; }
 					}
 
-					request.reject( 'IPC_UNHANDELED_CALL' );
+					request.reject( 'IPC_UNHANDLED_CALL' );
 				}
 				else if( msg.__liqd_ipc.hasOwnProperty('message') )
 				{
-					const topic = msg.__liqd_ipc.topic, message = new Message( this, msg.__liqd_ipc );
+					const listeners = this._listeners.get( 'message', msg.__liqd_ipc.topic ), message = new Message( this, msg.__liqd_ipc );
 
-					for( let listener of this._listeners.get( 'message', topic ))
+					if( listeners )
 					{
-						if( listener( message ) !== false ){ return; }
+						/*if( msg.__liqd_ipc.flow )
+						{
+							const Flow = require('liqd-flow');
+
+							Flow.start(() =>
+							{
+								for( let key in msg.__liqd_ipc.flow )
+								{
+									Flow.set( key, msg.__liqd_ipc.flow[key].value, msg.__liqd_ipc.flow[key].frozen );
+								}
+
+								for( let listener of listeners )
+								{
+									if( listener( message ) !== false ){ return; }
+								}
+							});
+						}
+						else */for( let listener of listeners )
+						{
+							if( listener( message ) !== false ){ return; }
+						}
 					}
 
-					message.reject( 'IPC_UNHANDELED_MESSAGE' );
+					message.reject( 'IPC_UNHANDLED_MESSAGE' );
 				}
 				else if( msg.__liqd_ipc.hasOwnProperty('event') )
 				{
@@ -70,6 +105,11 @@ module.exports = class IPC
 
 	_ipc_send( msg )
 	{
+		/*if( LIQD_FLOW && LIQD_FLOW.started )
+		{
+			msg.flow = LIQD_FLOW.scope();
+		}*/
+
 		this._port.postMessage ? this._port.postMessage({ __liqd_ipc: msg }) : this._port.send({ __liqd_ipc: msg });
 	}
 

lib/replies.js

@@ -1,5 +1,6 @@
 'use strict';
 
+//const Flow = require('liqd-flow');
 const Cache = require('liqd-cache');
 const TimedPromise = require('liqd-timed-promise');
 
@@ -13,11 +14,13 @@ module.exports = class Replies
 
 	create( callback )
 	{
+		//const flow = Flow.save();
+
 		return new TimedPromise(( resolve, reject, timeout ) =>
 		{
 			let id = ( this._iterator = ( this._iterator % Number.MAX_SAFE_INTEGER ) + 1 );
 
-			this._replies.set( id, { resolve, reject }, timeout );
+			this._replies.set( id, { resolve, reject/*, flow*/ }, timeout );
 
 			callback( id, timeout );
 		});
@@ -32,6 +35,19 @@ module.exports = class Replies
 			this._replies.delete( id );
 
 			handler.resolve( value );
+			/*
+			let scope = Flow.scope();
+
+			console.log( 'Restorujem', scope );
+			handler.flow.restore( () =>
+			{
+				for( let key in scope )
+				{
+					Flow.set( key, scope[key].value, scope[key].frozen );
+				}
+
+				handler.resolve( value );
+			});*/
 		}
 
 		return Boolean( handler );

package.json

@@ -1,15 +1,15 @@
 {
   "name": "liqd-ipc",
   "description": "NodeJS Cluster/WorkerThread IPC",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "author": "radixxko",
   "license": "MIT",
   "main": "lib/ipc.js",
   "files": [
     "lib/"
   ],
   "scripts": {
-    "test": "nyc mocha",
+    "test": "export NODE_OPTIONS=\"--experimental-worker\" && nyc mocha",
     "coverage": "nyc report --reporter=text-lcov | coveralls"
   },
   "repository": {
@@ -24,8 +24,9 @@
     "liqd"
   ],
   "dependencies": {
-    "liqd-cache": "^1.0.0",
-    "liqd-timed-promise": "^1.2.0"
+    "liqd-cache": "^1.0.2",
+    "liqd-flow": "^1.2.5",
+    "liqd-timed-promise": "^1.2.1"
   },
   "devDependencies": {
     "coveralls": "^3.0.2",