@testring/http-api
Advanced tools
+4
-10
@@ -23,3 +23,3 @@ "use strict"; | ||
| this.request = request; | ||
| this.loggerInstance = null; | ||
| this.logger = logger_1.loggerClient.withPrefix('[http-server]'); | ||
| this.isKilled = false; | ||
@@ -37,9 +37,2 @@ this.unsubscribeTransport = this.transportInstance.on("sendHttpRequest" /* send */, (data, src) => { | ||
| } | ||
| get logger() { | ||
| if (this.loggerInstance) { | ||
| return this.loggerInstance; | ||
| } | ||
| this.loggerInstance = logger_1.loggerClient.withPrefix('[http-server]'); | ||
| return this.loggerInstance; | ||
| } | ||
| makeRequest(data, src) { | ||
@@ -49,3 +42,3 @@ if (this.isKilled) { | ||
| } | ||
| setImmediate(() => __awaiter(this, void 0, void 0, function* () { | ||
| const send = (data, src) => __awaiter(this, void 0, void 0, function* () { | ||
| let uid; | ||
@@ -82,3 +75,4 @@ try { | ||
| } | ||
| })); | ||
| }); | ||
| setImmediate(() => send(data, src).catch(err => this.logger.error(err))); | ||
| } | ||
@@ -85,0 +79,0 @@ sendResponse(source, messageType, payload) { |
+7
-7
| { | ||
| "name": "@testring/http-api", | ||
| "version": "0.5.15", | ||
| "version": "0.5.16", | ||
| "main": "./dist/index.js", | ||
@@ -13,8 +13,8 @@ "types": "./src/index.ts", | ||
| "dependencies": { | ||
| "@testring/logger": "0.5.15", | ||
| "@testring/pluggable-module": "0.5.15", | ||
| "@testring/test-utils": "0.5.15", | ||
| "@testring/transport": "0.5.15", | ||
| "@testring/types": "0.5.15", | ||
| "@testring/utils": "0.5.15", | ||
| "@testring/logger": "0.5.16", | ||
| "@testring/pluggable-module": "0.5.16", | ||
| "@testring/test-utils": "0.5.16", | ||
| "@testring/transport": "0.5.16", | ||
| "@testring/types": "0.5.16", | ||
| "@testring/utils": "0.5.16", | ||
| "@types/node": "12.12.21", | ||
@@ -21,0 +21,0 @@ "@types/request-promise-native": "1.0.15", |
+7
-15
@@ -1,2 +0,2 @@ | ||
| import { IHttpRequest, IHttpResponse } from '@testring/types'; | ||
| import { IHttpRequest, IHttpResponse, IHttpServerController } from '@testring/types'; | ||
| import { PluggableModule } from '@testring/pluggable-module'; | ||
@@ -15,6 +15,6 @@ import { LoggerClient, loggerClient } from '@testring/logger'; | ||
| export class HttpServer extends PluggableModule { | ||
| export class HttpServer extends PluggableModule implements IHttpServerController { | ||
| private unsubscribeTransport: Function; | ||
| private loggerInstance: LoggerClient | null = null; | ||
| private logger: LoggerClient = loggerClient.withPrefix('[http-server]'); | ||
@@ -50,12 +50,2 @@ private isKilled = false; | ||
| private get logger(): LoggerClient { | ||
| if (this.loggerInstance) { | ||
| return this.loggerInstance; | ||
| } | ||
| this.loggerInstance = loggerClient.withPrefix('[http-server]'); | ||
| return this.loggerInstance; | ||
| } | ||
| private makeRequest(data: IHttpRequestMessage, src: string): void { | ||
@@ -66,3 +56,3 @@ if (this.isKilled) { | ||
| setImmediate(async () => { | ||
| const send = async (data: IHttpRequestMessage, src: string) => { | ||
| let uid; | ||
@@ -110,3 +100,5 @@ | ||
| } | ||
| }); | ||
| }; | ||
| setImmediate(() => send(data, src).catch(err => this.logger.error(err))); | ||
| } | ||
@@ -113,0 +105,0 @@ |
27250
-0.53%638
-1.85%+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
Updated
Updated
Updated
Updated
Updated