Skip to content

Commit

Permalink
Merge pull request #14 from nikolenkoanton92/master
Browse files Browse the repository at this point in the history
fixed httpServer dependency, update version
  • Loading branch information
lsm committed Jan 14, 2016
2 parents a6ded79 + 0d57d78 commit 0d76a33
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 6 deletions.
2 changes: 1 addition & 1 deletion lib/service/pipeline.js
Original file line number Diff line number Diff line change
Expand Up @@ -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'])
Expand Down
4 changes: 2 additions & 2 deletions lib/service/remote.js
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
5 changes: 3 additions & 2 deletions lib/web/router.js
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand All @@ -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)
Expand Down
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "micromono",
"version": "0.1.101",
"version": "0.1.102",
"description": "Monolithic micro-services framework",
"main": "lib/index.js",
"bin": {
Expand Down

0 comments on commit 0d76a33

Please sign in to comment.