@@ -19,11 +19,11 @@ import { StateMachineInstance } from '../interfaces/StateMachineInstance';
1919import { StateMachineRef } from '../interfaces/StateMachineRef' ;
2020import { StateMachineUpdateListener } from '../interfaces/StateMachineUpdateListener' ;
2121import { generateUUID } from '../utils/uuid' ;
22- import { Logger } from '../utils/Logger' ;
22+ // import { Logger } from '../utils/Logger';
2323import { WebSocketWrapper } from './WebSocketWrapper' ;
2424
2525export class WebSocketSubscriber {
26- private logger = Logger . getLogger ( 'WebSocketSubscriber' ) ;
26+ // private logger = Logger.getLogger('WebSocketSubscriber');
2727 private stateMachineRefSendPublisher : WebSocketPublisher ;
2828 private subscribedStateMachines : { [ componentName : string ] : Array < String > } ;
2929 private updates$ : Observable < DeserializedData > ;
@@ -263,10 +263,9 @@ export class WebSocketSubscriber {
263263 const raw = JSON . parse ( this . deserializer . decodeServerMessage ( b64Data ) ! ) ;
264264 if ( raw . $values ) {
265265 items = raw . $values ;
266+ } else {
267+ items = raw ;
266268 }
267- else {
268- items = raw ;
269- }
270269 } catch ( e ) {
271270 items = b64Data ;
272271 }
@@ -285,7 +284,7 @@ export class WebSocketSubscriber {
285284 }
286285
287286 public getJsonDataFromEvent ( data : string , topic ?: string ) : StateMachineInstance {
288- // this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2);
287+ // this.logger.debug('JsonData received from event: ', { data: data, topic: topic }, 2);
289288 let jsonData = this . deserializer . getJsonData ( data ) ;
290289 let stateMachineRef = this . getStateMachineRef (
291290 jsonData . Header . StateMachineId ,
0 commit comments