diff --git a/lib/service/pipeline.js b/lib/service/pipeline.js index 76b7b8e..3e5e427 100644 --- a/lib/service/pipeline.js +++ b/lib/service/pipeline.js @@ -60,7 +60,7 @@ exports.initRemoteService = superpipe() ['injectAssetInfo', 'proxyAsset', 'attachRoutes', 'proxyWebsocket']) .pipe('makeProxyHandlers', - ['getProxyHandler', 'scheduler', 'webServer', 'upgradeUrl'], + ['getProxyHandler', 'scheduler', 'httpServer', 'upgradeUrl'], ['proxyHandler', 'wsProxyHandler']) .pipe('injectAssetInfo?', ['assetInfo']) .pipe('addProxyHandlerToRoutes?', ['routes', 'proxyHandler']) diff --git a/lib/service/remote.js b/lib/service/remote.js index da09ff1..a0181c3 100644 --- a/lib/service/remote.js +++ b/lib/service/remote.js @@ -52,12 +52,12 @@ exports.prepareFrameworkForRemote = function(framework, setDep) { setDep(framework, ['injectAssetInfo', 'proxyAsset', 'attachRoutes', 'proxyWebsocket']) } -exports.makeProxyHandlers = function(getProxyHandler, scheduler, webServer, upgradeUrl) { +exports.makeProxyHandlers = function(getProxyHandler, scheduler, httpServer, upgradeUrl) { var proxyHandler = getProxyHandler(scheduler) var wsProxyHandler if (upgradeUrl) { - wsProxyHandler = getProxyHandler(scheduler, webServer, upgradeUrl) + wsProxyHandler = getProxyHandler(scheduler, httpServer, upgradeUrl) } return { diff --git a/lib/web/router.js b/lib/web/router.js index 4afc8b4..94955dc 100644 --- a/lib/web/router.js +++ b/lib/web/router.js @@ -231,9 +231,10 @@ exports.rebuildRemoteMiddlewares = function(middlewares, service) { * * @param {String} baseUrl The base url for the target endpoint of the service. * @param {String} allowUpgrade The url for upgrade request (websockets). + * @param {Object} httpServer * @return {Function} The proxy handler function. */ -exports.getProxyHandler = function(scheduler, webServer, allowUpgrade) { +exports.getProxyHandler = function(scheduler, httpServer, allowUpgrade) { var proxy = httpProxy.createProxyServer() proxy.on('error', function(err, req, res) { @@ -247,7 +248,7 @@ exports.getProxyHandler = function(scheduler, webServer, allowUpgrade) { }) if (allowUpgrade) { - webServer.on('upgrade', function(req, socket, head) { + httpServer.on('upgrade', function(req, socket, head) { var provider = scheduler.get() if (!provider) { exports.noProviderAvailable(req, socket) diff --git a/package.json b/package.json index e2ac280..7a739c4 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "micromono", - "version": "0.1.101", + "version": "0.1.102", "description": "Monolithic micro-services framework", "main": "lib/index.js", "bin": {