@@ -21,6 +21,7 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
2121Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2222exports . SubscriptionManager = void 0 ;
2323const utils_1 = require ( "../utils" ) ;
24+ const subscribe_1 = require ( "../endpoints/subscribe" ) ;
2425const reconnection_manager_1 = require ( "./reconnection_manager" ) ;
2526const categories_1 = __importDefault ( require ( "../constants/categories" ) ) ;
2627const deduping_manager_1 = require ( "./deduping_manager" ) ;
@@ -320,10 +321,12 @@ class SubscriptionManager {
320321 region : this . region ? this . region : undefined ,
321322 } ;
322323 this . configuration . logger ( ) . debug ( this . constructor . name , ( ) => {
323- const hashedEvents = messages . map ( ( event ) => ( {
324- type : event . type ,
325- data : Object . assign ( Object . assign ( { } , event . data ) , { pn_mfp : ( 0 , utils_1 . messageFingerprint ) ( event . data ) } ) ,
326- } ) ) ;
324+ const hashedEvents = messages . map ( ( event ) => {
325+ const pn_mfp = event . type === subscribe_1 . PubNubEventType . Message || event . type === subscribe_1 . PubNubEventType . Signal
326+ ? ( 0 , utils_1 . messageFingerprint ) ( event . data . message )
327+ : undefined ;
328+ return pn_mfp ? { type : event . type , data : Object . assign ( Object . assign ( { } , event . data ) , { pn_mfp } ) } : event ;
329+ } ) ;
327330 return { messageType : 'object' , message : hashedEvents , details : 'Received events:' } ;
328331 } ) ;
329332 messages . forEach ( ( message ) => {
0 commit comments