From c90aa07ace96a9706f417c722ce82e5849e90e56 Mon Sep 17 00:00:00 2001 From: Philipp Kunz Date: Tue, 29 Mar 2022 14:50:39 +0200 Subject: [PATCH] fix(core): update --- ts/typedrequest.classes.typedrouter.ts | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/ts/typedrequest.classes.typedrouter.ts b/ts/typedrequest.classes.typedrouter.ts index d7acb05..f4d2013 100644 --- a/ts/typedrequest.classes.typedrouter.ts +++ b/ts/typedrequest.classes.typedrouter.ts @@ -23,7 +23,7 @@ export class TypedRouter { * adds the handler to the routing map * @param typedHandlerArg */ - public addTypedHandler( + public addTypedHandler ( typedHandlerArg: TypedHandler ) { // lets check for deduplication @@ -41,7 +41,7 @@ export class TypedRouter { * adds another sub typedRouter * @param typedRequest */ - public addTypedRouter(typedRouterArg: TypedRouter) { + public addTypedRouter (typedRouterArg: TypedRouter) { const routerExists = this.routerMap.findSync(routerArg => routerArg === typedRouterArg) if (!routerExists) { this.routerMap.add(typedRouterArg); @@ -49,7 +49,7 @@ export class TypedRouter { } } - public checkForTypedHandler(methodArg: string): boolean { + public checkForTypedHandler (methodArg: string): boolean { return !!this.getTypedHandlerForMethod(methodArg); } @@ -58,7 +58,7 @@ export class TypedRouter { * @param methodArg * @param checkUpstreamRouter */ - public getTypedHandlerForMethod( + public getTypedHandlerForMethod ( methodArg: string, checkedRouters: TypedRouter[] = [] ): TypedHandler { @@ -69,7 +69,7 @@ export class TypedRouter { typedHandler = this.handlerMap.findSync((handler) => { return handler.method === methodArg; }); - + if (!typedHandler) { this.routerMap.getArray().forEach((typedRouterArg) => { if (!typedHandler && !checkedRouters.includes(typedRouterArg)) { @@ -86,7 +86,7 @@ export class TypedRouter { * if typedrequest object has correlation.phase === 'response' -> routes a typed request object to request fire event * @param typedRequestArg */ - public async routeAndAddResponse(typedRequestArg: T): Promise { + public async routeAndAddResponse (typedRequestArg: T): Promise { if (typedRequestArg?.correlation?.phase === 'request') { const typedHandler = this.getTypedHandlerForMethod(typedRequestArg.method); @@ -106,6 +106,7 @@ export class TypedRouter { this.fireEventInterestMap .findInterest(typedRequestArg.correlation.id) ?.fullfillInterest(typedRequestArg); + return null; } else { console.log('received weirdly shaped request'); console.log(typedRequestArg);