@silenteer/natsu-port-server
Advanced tools
Comparing version 0.0.39 to 0.0.40
@@ -113,2 +113,3 @@ "use strict"; | ||
connection.socket.on('message', (message) => tslib_1.__awaiter(this, void 0, void 0, function* () { | ||
var _a; | ||
let wsRequest; | ||
@@ -133,4 +134,4 @@ try { | ||
const getNamespaceResult = yield getNamespace({ | ||
httpRequest: request, | ||
natsAuthResponse: authenticationResult.authResponse, | ||
subject: wsRequest.subject, | ||
headers: Object.assign({}, (((_a = authenticationResult.authResponse) === null || _a === void 0 ? void 0 : _a['headers']) || {})), | ||
}); | ||
@@ -233,4 +234,3 @@ if (getNamespaceResult.code !== 'OK') { | ||
return tslib_1.__awaiter(this, void 0, void 0, function* () { | ||
const { httpRequest, natsAuthResponse } = params; | ||
const subject = httpRequest.headers['nats-subject']; | ||
const { subject, headers } = params; | ||
let result; | ||
@@ -240,5 +240,3 @@ const shouldSetNamespace = (_a = configuration_1.default.natsNamespaceSubjects) === null || _a === void 0 ? void 0 : _a.includes(subject); | ||
const natsRequest = { | ||
headers: natsAuthResponse | ||
? natsAuthResponse.headers | ||
: httpRequest.headers, | ||
headers, | ||
body: { subject }, | ||
@@ -245,0 +243,0 @@ }; |
{ | ||
"name": "@silenteer/natsu-port-server", | ||
"version": "0.0.39", | ||
"version": "0.0.40", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "private": false, |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
51719
789