File tree Expand file tree Collapse file tree 2 files changed +10
-6
lines changed
Expand file tree Collapse file tree 2 files changed +10
-6
lines changed Original file line number Diff line number Diff line change @@ -74,6 +74,7 @@ export class HomebridgePrincessHeaterPlatform implements DynamicPlatformPlugin {
7474 const client = new WsClient ( this . log ) ;
7575
7676 client . on ( 'message' , ( message : WsIncomingMessage ) => {
77+ this . log . debug ( 'platform message' , message ) ;
7778 if (
7879 helloMessage &&
7980 message . type === 'response' &&
Original file line number Diff line number Diff line change 11import WebSocket from 'ws' ;
22import { WsOutgoingMessage } from './types' ;
3- import { MessageType , WS_URL } from './const' ;
3+ import { WS_URL } from './const' ;
44import { EventEmitter } from 'events' ;
55import { Logger } from 'homebridge' ;
66
@@ -75,19 +75,22 @@ export class WsClient extends EventEmitter {
7575
7676 const ws = await wsPromise ;
7777
78+ const messageId = ++ this . lastMessageId ;
79+ const fullMessage = {
80+ ...message ,
81+ message_id : messageId ,
82+ } as M ;
83+ this . log . debug ( 'Sending WS message -> ' , fullMessage ) ;
84+
7885 return new Promise ( ( res , rej ) => {
79- const messageId = ++ this . lastMessageId ;
80- const fullMessage = {
81- ...message ,
82- message_id : messageId ,
83- } as M ;
8486 ws . send (
8587 JSON . stringify ( fullMessage ) ,
8688 ( err ) => {
8789 if ( err ) {
8890 this . log . warn ( 'Failed to send message ->' , fullMessage , err ) ;
8991 rej ( err ) ;
9092 } else {
93+ this . log . debug ( 'WS message sent ->' , fullMessage ) ;
9194 res ( fullMessage ) ;
9295 }
9396 } ,
You can’t perform that action at this time.
0 commit comments