diff --git a/app/lib/streams/multicaster.js b/app/lib/streams/multicaster.js index 2a7e024bde603106e3daa7ef1d1940bf56e725af..250bac781d06e0dc5df7de533c01906ba46c705b 100644 --- a/app/lib/streams/multicaster.js +++ b/app/lib/streams/multicaster.js @@ -180,7 +180,7 @@ function Multicaster (conf, timeout) { } return Q.Promise(function(resolve, reject){ const postReq = request.post({ - "uri": 'http://' + peer.getURL() + uri, + "uri": protocol(peer.getPort()) + '://' + peer.getURL() + uri, "timeout": timeout || constants.NETWORK.DEFAULT_TIMEOUT }, function (err, res) { if (err) { @@ -197,4 +197,8 @@ function Multicaster (conf, timeout) { } } +function protocol(port) { + return port == 443 ? 'https' : 'http'; +} + util.inherits(Multicaster, stream.Transform);