nicdex/node-eventstore-client
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #94 from jwulf/https

Browse Source 
Support https for projections
This commit is contained in:
Nicolas Dextraze 2022-10-19 13:48:32 -04:00 committed by GitHub
commit 6159cd56b8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/projections/projectionsClient.js
View File

@ -1,4 +1,5 @@
const http = require('http'); const http = require('http');
const https = require('https');
const url = require('url'); const url = require('url');
const util = require('util'); const util = require('util');
const ProjectionCommandFailedError = require('../errors/projectionCommandFailedError'); const ProjectionCommandFailedError = require('../errors/projectionCommandFailedError');
@ -112,6 +113,7 @@ ProjectionsClient.prototype.delete = function(httpEndPoint, name, deleteEmittedS
ProjectionsClient.prototype.request = function(method, _url, data, userCredentials, expectedCode) { ProjectionsClient.prototype.request = function(method, _url, data, userCredentials, expectedCode) {
const options = url.parse(_url); const options = url.parse(_url);
const httplib = options.protocol === 'https:' ? https : http;
options.method = method; options.method = method;
if (userCredentials) { if (userCredentials) {
options.auth = [userCredentials.username, userCredentials.password].join(':'); options.auth = [userCredentials.username, userCredentials.password].join(':');
@ -121,7 +123,7 @@ ProjectionsClient.prototype.request = function(method, _url, data, userCredentia
const timeout = setTimeout(function () { const timeout = setTimeout(function () {
reject(new Error(util.format('Request timed out for %s on %s', method, _url))) reject(new Error(util.format('Request timed out for %s on %s', method, _url)))
}, self._operationTimeout); }, self._operationTimeout);
const req = http.request(options, function (res) { const req = httplib.request(options, function (res) {
const hasExpectedCode = res.statusCode === expectedCode; const hasExpectedCode = res.statusCode === expectedCode;
var result = ''; var result = '';
res.setEncoding('utf8'); res.setEncoding('utf8');