win support

.eslintrc.js

@@ -172,6 +172,7 @@ module.exports =
 		'spaced-comment': [ 2, 'always' ],
 		'strict': 2,
 		'valid-typeof': 2,
-		'yoda': 2
+		'yoda': 2,
+		'linebreak-style': 0
 	}
 };

.gitignore

@@ -8,6 +8,10 @@
 # gyp generated stuff.
 /worker/out/
 /worker/**/*.xcodeproj/
+/worker/**/*.sln
+/worker/**/*.vcxproj
+/worker/**/*.vcxproj.filters
+/worker/**/*.vcxproj.user
 
 # clang-fuzzer stuff is too big.
 /worker/deps/clang-fuzzer
@@ -22,3 +26,13 @@
 
 # Mac Stuff.
 .DS_Store
+
+# python win generated Stuff.
+/worker/scripts/configure.pyc
+
+# vistual studio generated Stuff.
+/worker/**/Debug/
+/worker/**/Release/
+
+# VS stuff.
+/worker/.vs/

gulpfile.js

@@ -1,5 +1,7 @@
 const gulp = require('gulp');
+const shell = require('gulp-shell');
 const clangFormat = require('gulp-clang-format');
+const os = require('os');
 
 const workerFiles =
 [
@@ -37,3 +39,39 @@ gulp.task('format:worker', () =>
 		.pipe(clangFormat.format('file'))
 		.pipe(gulp.dest('.'));
 });
+
+gulp.task('win:build', shell.task(
+	[
+		'echo build for windows',
+		'python ./worker/scripts/configure.py --format=msvs',
+		`MSBuild ./worker/mediasoup-worker.sln /p:Configuration=${process.env.MEDIASOUP_BUILDTYPE === 'Debug' ?'Debug' : 'Release'} -t:mediasoup-worker `
+	],
+	{
+		verbose : true
+	}
+));
+
+gulp.task('make:build', shell.task(
+	[
+		'make -C worker'
+	],
+	{
+		verbose : true
+	}
+));
+
+gulp.task('build', gulp.series(os.platform() === 'win32'? 'win:build' : 'make:build'));
+
+gulp.task('test:win:worker', shell.task(
+	[
+		'echo not support yet!!! run test in visual studio!!!'
+	]
+));
+
+gulp.task('test:make:worker', shell.task(
+	[
+		'make test -C worker'
+	]
+));
+
+gulp.task('test:worker', gulp.series(os.platform() === 'win32'? 'test:win:worker' : 'test:make:worker'));

lib/Channel.js

@@ -12,7 +12,7 @@ class Channel extends EnhancedEventEmitter
 	/**
 	 * @private
 	 */
-	constructor({ socket, pid })
+	constructor({ producerSocket, consumerSocket, pid })
 	{
 		const logger = new Logger(`Channel[pid:${pid}]`);
 		const workerLogger = new Logger(`worker[pid:${pid}]`);
@@ -30,7 +30,8 @@ class Channel extends EnhancedEventEmitter
 
 		// Unix Socket instance.
 		// @type {net.Socket}
-		this._socket = socket;
+		this._producerSocket = producerSocket;
+		this._consumerSocket = consumerSocket;
 
 		// Next request id.
 		// @type {Number}
@@ -45,7 +46,7 @@ class Channel extends EnhancedEventEmitter
 		this._recvBuffer = null;
 
 		// Read Channel responses/notifications from the worker.
-		this._socket.on('data', (buffer) =>
+		this._consumerSocket.on('data', (buffer) =>
 		{
 			if (!this._recvBuffer)
 			{
@@ -147,8 +148,11 @@ class Channel extends EnhancedEventEmitter
 			}
 		});
 
-		this._socket.on('end', () => this._logger.debug('Channel ended by the worker process'));
-		this._socket.on('error', (error) => this._logger.error('Channel error: %s', String(error)));
+		this._consumerSocket.on('end', () => this._logger.debug('Consumer Channel ended by the worker process'));
+		this._consumerSocket.on('error', (error) => this._logger.error('Consumer Channel error: %s', String(error)));
+
+		this._producerSocket.on('end', () => this._logger.debug('Producer Channel ended by the worker process'));
+		this._producerSocket.on('error', (error) => this._logger.error('Producer Channel error: %s', String(error)));
 	}
 
 	/**
@@ -171,14 +175,20 @@ class Channel extends EnhancedEventEmitter
 
 		// Remove event listeners but leave a fake 'error' hander to avoid
 		// propagation.
-		this._socket.removeAllListeners('end');
-		this._socket.removeAllListeners('error');
-		this._socket.on('error', () => {});
+		this._consumerSocket.removeAllListeners('end');
+		this._consumerSocket.removeAllListeners('error');
+		this._consumerSocket.on('error', () => {});
+
+		this._producerSocket.removeAllListeners('end');
+		this._producerSocket.removeAllListeners('error');
+		this._producerSocket.on('error', () => {});
 
 		// Destroy the socket after a while to allow pending incoming messages.
 		setTimeout(() =>
 		{
-			try { this._socket.destroy(); }
+			try { this._producerSocket.destroy(); }
+			catch (error) {}
+			try { this._consumerSocket.destroy(); }
 			catch (error) {}
 		}, 200);
 	}
@@ -206,7 +216,7 @@ class Channel extends EnhancedEventEmitter
 			throw new Error('Channel request too big');
 
 		// This may throw if closed or remote side ended.
-		this._socket.write(ns);
+		this._producerSocket.write(ns);
 
 		return new Promise((pResolve, pReject) =>
 		{

lib/Worker.js

@@ -90,9 +90,10 @@ class Worker extends EnhancedEventEmitter
 				 * fd 0 (stdin)   : Just ignore it.
 				 * fd 1 (stdout)  : Pipe it for 3rd libraries that log their own stuff.
 				 * fd 2 (stderr)  : Same as stdout.
-				 * fd 3 (channel) : Channel fd.
+				 * fd 3 (channel) : Producer Channel fd.
+				 * fd 4 (channel) : Consumer Channel fd.
 				 */
-				stdio : [ 'ignore', 'pipe', 'pipe', 'pipe' ]
+				stdio : [ 'ignore', 'pipe', 'pipe', 'pipe', 'pipe' ]
 			});
 
 		this._workerLogger = new Logger(`worker[pid:${this._child.pid}]`);
@@ -105,8 +106,9 @@ class Worker extends EnhancedEventEmitter
 		// @type {Channel}
 		this._channel = new Channel(
 			{
-				socket : this._child.stdio[3],
-				pid    : this._pid
+				producerSocket : this._child.stdio[3],
+				consumerSocket : this._child.stdio[4],
+				pid            : this._pid
 			});
 
 		// Closed flag.

package.json

@@ -19,22 +19,19 @@
     "sfu",
     "nodejs"
   ],
-  "os": [
-    "!win32"
-  ],
   "engines": {
     "node": ">=8.6.0"
   },
   "scripts": {
     "lint": "npm run lint:node && npm run lint:worker",
     "lint:node": "eslint -c .eslintrc.js gulpfile.js lib test",
-    "lint:worker": "make lint -C worker",
-    "format:worker": "make format -C worker",
+    "lint:worker": "gulp lint:worker",
+    "format:worker": "gulp format:worker",
     "test": "npm run test:node && npm run test:worker",
-    "test:node": "make -C worker && jest",
-    "test:worker": "make test -C worker",
-    "coverage:node": "make -C worker && jest --coverage && open-cli coverage/lcov-report/index.html",
-    "postinstall": "make -C worker"
+    "test:node": "gulp build && jest",
+    "test:worker": "gulp test:worker",
+    "coverage:node": "gulp build && jest --coverage && open-cli coverage/lcov-report/index.html",
+    "postinstall": "gulp build"
   },
   "jest": {
     "verbose": true,
@@ -46,13 +43,14 @@
     "h264-profile-level-id": "^1.0.0",
     "netstring": "^0.3.0",
     "random-number": "^0.0.9",
-    "uuid": "^3.3.2"
+    "uuid": "^3.3.2",
+    "gulp": "^4.0.2",
+    "gulp-clang-format": "^1.0.27",    
+    "gulp-shell": "^0.6.5"
   },
   "devDependencies": {
     "eslint": "^6.1.0",
     "eslint-plugin-jest": "^22.13.6",
-    "gulp": "^4.0.2",
-    "gulp-clang-format": "^1.0.27",
     "jest": "^24.8.0",
     "jest-tobetype": "^1.2.3",
     "open-cli": "^5.0.0",

test/test-Worker.js

@@ -1,3 +1,4 @@
+const os = require('os');
 const process = require('process');
 const { toBeType } = require('jest-tobetype');
 const mediasoup = require('../');
@@ -194,6 +195,9 @@ test('Worker emits "died" if worker process died unexpectedly', async () =>
 
 test('worker process ignores PIPE, HUP, ALRM, USR1 and USR2 signals', async () =>
 {
+	if (os.platform() === 'win32') 
+		return;
+
 	worker = await createWorker({ logLevel: 'warn' });
 
 	await new Promise((resolve, reject) =>