feat: add more env SENDMESSAGE_ONE_PROCESS

.travis.yml

@@ -1,6 +1,6 @@
 language: node_js
 node_js:
-  - '0.11'
-  - '0.10'
+  - '4'
+  - '6'
 script: "npm run test-travis"
 after_script: "npm install coveralls@2 && cat ./coverage/lcov.info | coveralls"

README.md

@@ -67,6 +67,8 @@ If a process is not child process, this will just call `process.emit('message',
 sendmessage(process, {hello: 'this is a message to master'});
 ```
 
+You can switch to `process.emit('message', message)` using `process.env.SENDMESSAGE_ONE_PROCESS`
+
 ## Test
 
 ```bash

index.js

@@ -25,7 +25,7 @@ module.exports = function send(child, message) {
     return setImmediate(child.emit.bind(child, 'message', message));
   }
 
-  if (IS_NODE_DEV_RUNNER) {
+  if (IS_NODE_DEV_RUNNER || process.env.SENDMESSAGE_ONE_PROCESS) {
     // run with node-dev, only one process
     // https://github.com/node-modules/sendmessage/issues/1
     return setImmediate(child.emit.bind(child, 'message', message));

package.json

@@ -15,16 +15,15 @@
     "cnpm": "npm install --registry=https://registry.npm.taobao.org",
     "contributors": "contributors -f plain -o AUTHORS"
   },
-  "dependencies": {
-
-  },
+  "dependencies": {},
   "devDependencies": {
     "autod": "*",
     "contributors": "*",
-    "should": "*",
-    "jshint": "*",
     "istanbul": "*",
-    "mocha": "*"
+    "jshint": "*",
+    "mm": "^1.5.1",
+    "mocha": "*",
+    "should": "*"
   },
   "homepage": "https://github.com/node-modules/sendmessage",
   "repository": {
@@ -37,7 +36,11 @@
     "email": "fengmk2@gmail.com"
   },
   "keywords": [
-    "sendmessage", "send", "cluster", "message", "channel closed"
+    "sendmessage",
+    "send",
+    "cluster",
+    "message",
+    "channel closed"
   ],
   "engines": {
     "node": ">= 0.10.0"

test/sendmessage.test.js

@@ -18,9 +18,12 @@ var path = require('path');
 var should = require('should');
 var childprocess = require('child_process');
 var cluster = require('cluster');
+var mm = require('mm');
 var sendmessage = require('../');
 
 describe('sendmessage.test.js', function () {
+  afterEach(mm.restore);
+
   describe('single process', function () {
     it('should emit message when process is not child process', function (done) {
       process.once('message', function (message) {
@@ -146,4 +149,30 @@ describe('sendmessage.test.js', function () {
       });
     });
   });
+
+  it('should emit when SENDMESSAGE_ONE_PROCESS = true', function(done) {
+    var childfile = path.join(__dirname, 'child.js');
+    var child = childprocess.fork(childfile);
+    mm(process.env, 'SENDMESSAGE_ONE_PROCESS', 'true');
+    var msg;
+    child.once('message', function (message) {
+      message.should.eql({
+        from: 'child',
+        hi: 'this is a message send to master'
+      });
+
+      sendmessage(child, {
+        from: 'master',
+        reply: 'this is a reply message send to child'
+      });
+
+      child.once('message', function(msg) {
+        msg.should.eql({
+          from: 'master',
+          reply: 'this is a reply message send to child',
+        });
+        done();
+      });
+    });
+  })
 });