From fe51c371f312d35d4a929aa9381bc52689025ab3 Mon Sep 17 00:00:00 2001 From: fredericcarre Date: Thu, 10 Apr 2025 01:54:09 +0200 Subject: [PATCH 1/4] remove some logs --- src/communication/WebSocketSubscriber.ts | 3 +-- src/communication/xcomponentMessages.ts | 4 +--- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/src/communication/WebSocketSubscriber.ts b/src/communication/WebSocketSubscriber.ts index b409048..2971b36 100644 --- a/src/communication/WebSocketSubscriber.ts +++ b/src/communication/WebSocketSubscriber.ts @@ -256,7 +256,6 @@ export class WebSocketSubscriber { } public getJsonDataFromSnapshot(data: string, topic?: string): Array { - this.logger.debug('JsonData received from snapshot: ', { data: data, topic: topic }, 2); let jsonData = this.deserializer.getJsonData(data); let b64Data = JSON.parse(jsonData.JsonMessage).Items; let items; @@ -286,7 +285,7 @@ export class WebSocketSubscriber { } public getJsonDataFromEvent(data: string, topic?: string): StateMachineInstance { - this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2); + // this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2); let jsonData = this.deserializer.getJsonData(data); let stateMachineRef = this.getStateMachineRef( jsonData.Header.StateMachineId, diff --git a/src/communication/xcomponentMessages.ts b/src/communication/xcomponentMessages.ts index 9a7e7c2..67bfcf0 100644 --- a/src/communication/xcomponentMessages.ts +++ b/src/communication/xcomponentMessages.ts @@ -71,17 +71,15 @@ export let getHeaderWithIncomingType = (): Header => { }; export class Serializer { - private logger = Logger.getLogger('Serializer'); + // private logger = Logger.getLogger('Serializer'); public convertToWebsocketInputFormat(data: Data): string { let input = `${data.RoutingKey} ${data.ComponentCode} ${JSON.stringify(data.Event)}`; - this.logger.debug('Message send : ', input); return input; } public convertCommandDataToWebsocketInputFormat(commandData: CommandData): string { let input = `${commandData.Command} ${JSON.stringify(commandData.Data)}`; - this.logger.debug('Message send : ', input); return input; } } From d3a21347cacd3f0df72c06d0b028e9e479ecbc91 Mon Sep 17 00:00:00 2001 From: fredericcarre Date: Thu, 10 Apr 2025 01:54:51 +0200 Subject: [PATCH 2/4] remove some logs --- package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/package.json b/package.json index 3c4a11a..902c7f1 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "reactivexcomponent.js", - "version": "7.0.8", + "version": "7.0.9", "description": "Javascript reactive client API for XComponent", "module": "dist/index.js", "main": "dist/index.js", From ade7c5c2f54c36d1fc019fa04b84fed491a4e697 Mon Sep 17 00:00:00 2001 From: fredericcarre Date: Thu, 10 Apr 2025 01:57:05 +0200 Subject: [PATCH 3/4] remove some logs --- src/communication/WebSocketSubscriber.ts | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/communication/WebSocketSubscriber.ts b/src/communication/WebSocketSubscriber.ts index 2971b36..920a19c 100644 --- a/src/communication/WebSocketSubscriber.ts +++ b/src/communication/WebSocketSubscriber.ts @@ -19,11 +19,11 @@ import { StateMachineInstance } from '../interfaces/StateMachineInstance'; import { StateMachineRef } from '../interfaces/StateMachineRef'; import { StateMachineUpdateListener } from '../interfaces/StateMachineUpdateListener'; import { generateUUID } from '../utils/uuid'; -import { Logger } from '../utils/Logger'; +// import { Logger } from '../utils/Logger'; import { WebSocketWrapper } from './WebSocketWrapper'; export class WebSocketSubscriber { - private logger = Logger.getLogger('WebSocketSubscriber'); + // private logger = Logger.getLogger('WebSocketSubscriber'); private stateMachineRefSendPublisher: WebSocketPublisher; private subscribedStateMachines: { [componentName: string]: Array }; private updates$: Observable; @@ -263,10 +263,9 @@ export class WebSocketSubscriber { const raw = JSON.parse(this.deserializer.decodeServerMessage(b64Data)!); if (raw.$values) { items = raw.$values; + } else { + items = raw; } - else { - items = raw; - } } catch (e) { items = b64Data; } @@ -285,7 +284,7 @@ export class WebSocketSubscriber { } public getJsonDataFromEvent(data: string, topic?: string): StateMachineInstance { - // this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2); + // this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2); let jsonData = this.deserializer.getJsonData(data); let stateMachineRef = this.getStateMachineRef( jsonData.Header.StateMachineId, From 04e9ced7cde4e24f94127890ff9d29f09ee1d0aa Mon Sep 17 00:00:00 2001 From: fredericcarre Date: Thu, 10 Apr 2025 01:58:29 +0200 Subject: [PATCH 4/4] remove some logs --- src/communication/xcomponentMessages.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/communication/xcomponentMessages.ts b/src/communication/xcomponentMessages.ts index 67bfcf0..1d98206 100644 --- a/src/communication/xcomponentMessages.ts +++ b/src/communication/xcomponentMessages.ts @@ -1,4 +1,4 @@ -import { Logger } from '../utils/Logger'; +// import { Logger } from '../utils/Logger'; import * as pako from 'pako';