win support

.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,14 @@
 
 # Mac Stuff.
 .DS_Store
+
+# Python generated stuff in Windows.
+/worker/scripts/configure.pyc
+
+# Vistual Studio generated Stuff.
+/worker/**/Debug/
+/worker/**/Release/
+/worker/.vs/
+
+# Vistual Studio Code stuff.
+/.vscode/

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,27 @@
     "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:node": "eslint -c .eslintrc.js gulpfile.js lib test worker/win-tasks.js",
+    "lint:worker": "run-script-os",
+    "lint:worker:win32": "\"\"%NODE%\"\" ./worker/win-tasks.js lint",
+    "lint:worker:default": "make lint -C worker",
+    "format:worker": "run-script-os",
+    "format:worker:win32": "\"\"%NODE%\"\" ./worker/win-tasks.js format",
+    "format:worker:default": "make format -C 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": "npm run postinstall && jest",
+    "test:worker": "run-script-os",
+    "test:worker:win32": "\"\"%NODE%\"\" ./worker/win-tasks.js test",
+    "test:worker:default": "make test -C worker",
+    "coverage:node": "npm run postinstall && jest --coverage && open-cli coverage/lcov-report/index.html",
+    "postinstall": "run-script-os",
+    "postinstall:win32": "\"\"%NODE%\"\" ./worker/win-tasks.js make",
+    "postinstall:default": "make -C worker"
   },
   "jest": {
     "verbose": true,
@@ -46,6 +51,7 @@
     "h264-profile-level-id": "^1.0.0",
     "netstring": "^0.3.0",
     "random-number": "^0.0.9",
+    "@dr.amaton/run-script-os": "^1.1.2",
     "uuid": "^3.3.3"
   },
   "devDependencies": {

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,11 @@ test('Worker emits "died" if worker process died unexpectedly', async () =>
 
 test('worker process ignores PIPE, HUP, ALRM, USR1 and USR2 signals', async () =>
 {
+	// Windows doesn't have some signals such as SIGPIPE, SIGALRM, SIGUSR1, SIGUSR2
+	// so we just skip this test in Windows.
+	if (os.platform() === 'win32') 
+		return;
+
 	worker = await createWorker({ logLevel: 'warn' });
 
 	await new Promise((resolve, reject) =>

worker/deps/getopt/getopt.gyp

@@ -0,0 +1,22 @@
+{
+  'targets': 
+  [
+    {
+      'target_name': 'getopt',
+      'type': 'static_library',
+      'sources':
+      [
+        'getopt/src/getopt.h',
+        'getopt/src/getopt.c'
+      ],
+      'include_dirs': 
+      [
+        'getopt/src/'
+      ],
+      'direct_dependent_settings':
+      {
+        'include_dirs': ['getopt/src/']
+      },
+    }
+  ]
+}

worker/deps/getopt/getopt/.gitignore

@@ -0,0 +1,8 @@
+CMakeCache.txt
+CMakeFiles
+Makefile
+cmake_install.cmake
+install_manifest.txt
+build
+*.lib
+*.pdb

worker/deps/getopt/getopt/CMakeLists.txt

@@ -0,0 +1,23 @@
+PROJECT(wingetopt)
+cmake_minimum_required(VERSION 2.8)
+
+option(BUILD_SHARED_LIBS "Build the shared library" OFF)
+
+include_directories(${CMAKE_CURRENT_SOURCE_DIR}/src)
+
+add_definitions(-D_CRT_SECURE_NO_WARNINGS)
+
+if(BUILD_SHARED_LIBS)
+  set(CMAKE_WINDOWS_EXPORT_ALL_SYMBOLS ON)
+  add_definitions(-DBUILDING_WINGETOPT_DLL -DWINGETOPT_SHARED_LIB)
+endif()
+
+add_library(wingetopt src/getopt.c src/getopt.h)
+
+install(FILES src/getopt.h DESTINATION include)
+
+install(TARGETS wingetopt
+    RUNTIME DESTINATION bin
+	LIBRARY DESTINATION lib
+	ARCHIVE DESTINATION lib)
+

worker/deps/getopt/getopt/LICENSE

@@ -0,0 +1,54 @@
+#### AUTHORS:
+
+* Todd C. Miller <[email protected]>
+* The NetBSD Foundation, Inc.
+* Alexei Kasatkin is the author of trivial CMakeLists.txt, build script itself is Public Domain
+
+#### LICENSE
+
+    Copyright (c) 2002 Todd C. Miller <[email protected]>
+
+    Permission to use, copy, modify, and distribute this software for any
+    purpose with or without fee is hereby granted, provided that the above
+    copyright notice and this permission notice appear in all copies.
+
+    THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+    WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+    MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+    ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+    WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+    ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+    OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+
+    Sponsored in part by the Defense Advanced Research Projects
+    Agency (DARPA) and Air Force Research Laboratory, Air Force
+    Materiel Command, USAF, under agreement number F39502-99-1-0512.
+
+***
+
+    Copyright (c) 2000 The NetBSD Foundation, Inc.
+    All rights reserved.
+
+    This code is derived from software contributed to The NetBSD Foundation
+    by Dieter Baron and Thomas Klausner.
+
+    Redistribution and use in source and binary forms, with or without
+    modification, are permitted provided that the following conditions
+    are met:
+    1. Redistributions of source code must retain the above copyright
+       notice, this list of conditions and the following disclaimer.
+    2. Redistributions in binary form must reproduce the above copyright
+       notice, this list of conditions and the following disclaimer in the
+       documentation and/or other materials provided with the distribution.
+
+    THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
+    ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
+    TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+    PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
+    BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+    CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+    SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+    INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+    CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+    ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+    POSSIBILITY OF SUCH DAMAGE.

worker/deps/getopt/getopt/README.md

@@ -0,0 +1,63 @@
+# wingetopt
+
+getopt library for Windows compilers
+
+
+This library was created to allow compilation linux-based software on Windows.
+http://en.wikipedia.org/wiki/Getopt
+
+The sources were taken from MinGW-runtime project.
+
+#### AUTHORS:
+
+* Todd C. Miller <[email protected]>
+* The NetBSD Foundation, Inc.
+
+#### LICENSE
+
+    Copyright (c) 2002 Todd C. Miller <[email protected]>
+
+    Permission to use, copy, modify, and distribute this software for any
+    purpose with or without fee is hereby granted, provided that the above
+    copyright notice and this permission notice appear in all copies.
+
+    THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+    WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+    MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+    ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+    WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+    ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+    OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+
+    Sponsored in part by the Defense Advanced Research Projects
+    Agency (DARPA) and Air Force Research Laboratory, Air Force
+    Materiel Command, USAF, under agreement number F39502-99-1-0512.
+
+***
+
+    Copyright (c) 2000 The NetBSD Foundation, Inc.
+    All rights reserved.
+
+    This code is derived from software contributed to The NetBSD Foundation
+    by Dieter Baron and Thomas Klausner.
+
+    Redistribution and use in source and binary forms, with or without
+    modification, are permitted provided that the following conditions
+    are met:
+    1. Redistributions of source code must retain the above copyright
+       notice, this list of conditions and the following disclaimer.
+    2. Redistributions in binary form must reproduce the above copyright
+       notice, this list of conditions and the following disclaimer in the
+       documentation and/or other materials provided with the distribution.
+
+    THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
+    ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
+    TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+    PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
+    BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+    CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+    SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+    INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+    CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+    ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+    POSSIBILITY OF SUCH DAMAGE.