ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2026-08-23 08:30:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix support for proxy credentials in proxy URL and fix error when there are more than 10 outstanding requests

Browse Source
This commit is contained in:
Chris Clark
2015-11-25 12:53:50 -08:00
parent d8f967d2b8
commit 0990ad4a6f
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/common/connection.js
View File

@@ -15,6 +15,7 @@ function isStreamMessageType(type) {
class Connection extends EventEmitter {
constructor(url, options = {}) {
super();
this.setMaxListeners(Infinity);
this._url = url;
this._trace = options.trace;
if (this._trace) {
@@ -111,8 +112,10 @@ class Connection extends EventEmitter {
const proxyOptions = parseURL(proxyURL);
proxyOptions.secureEndpoint = (parsedURL.protocol === 'wss:');
proxyOptions.secureProxy = (proxyOptions.protocol === 'https:');
proxyOptions.auth = proxyAuthorization;
if (trustedCertificates) {
if (proxyAuthorization !== undefined) {
proxyOptions.auth = proxyAuthorization;
}
if (trustedCertificates !== undefined) {
proxyOptions.ca = trustedCertificates;
}
let HttpsProxyAgent;
@@ -127,7 +130,11 @@ class Connection extends EventEmitter {
const base64 = new Buffer(authorization).toString('base64');
options.headers = {Authorization: `Basic ${base64}`};
}
return new WebSocket(url, options);
const websocket = new WebSocket(url, options);
// we will have a listener for each outstanding request,
// so we have to raise the limit (the default is 10)
websocket.setMaxListeners(Infinity);
return websocket;
}
connect() {