@@ -2776,7 +2776,7 @@ private async Task _parseDelta(JToken m)
27762776
27772777 var mid = metadata ? . get ( "messageId" ) ? . Value < string > ( ) ;
27782778 var author_id = metadata ? . get ( "actorFbId" ) ? . Value < string > ( ) ;
2779- var ts = long . Parse ( metadata ? . get ( "timestamp" ) ? . Value < string > ( ) ) ;
2779+ long . TryParse ( metadata ? . get ( "timestamp" ) ? . Value < string > ( ) , out long ts ) ;
27802780
27812781 // Added participants
27822782 if ( delta . get ( "addedParticipants" ) != null )
@@ -3209,9 +3209,10 @@ await this.onPlanParticipation(
32093209 // Client payload (that weird numbers)
32103210 else if ( delta_class == "ClientPayload" )
32113211 {
3212- var payload = JToken . Parse ( string . Join ( "" , delta . get ( "payload" ) ? . Value < string > ( ) ) ) ;
3212+ var json = string . Join ( "" , delta . get ( "payload" ) ? . Value < string > ( ) ) ;
3213+ var payload = JToken . Parse ( json ) ;
32133214 ts = m . get ( "ofd_ts" ) ? . Value < long > ( ) ?? 0 ;
3214- foreach ( var d in payload . get ( "deltas" ) ?? new JObject ( ) )
3215+ foreach ( var d in payload . get ( "deltas" ) ?? new JArray ( ) )
32153216 {
32163217 // Message reaction
32173218 if ( d . get ( "deltaMessageReaction" ) != null )
@@ -3720,7 +3721,7 @@ private async Task _parse_mqtt(string event_type, JToken event_data)
37203721 // event_data.get("lastIssuedSeqId")?.Value<int>() ?? event_data.get("deltas")?.LastOrDefault()?.get("irisSeqId")?.Value<int>() ?? _mqtt_sequence_id);
37213722 }
37223723
3723- foreach ( var delta in event_data . get ( "deltas" ) ?? new JObject ( ) )
3724+ foreach ( var delta in event_data . get ( "deltas" ) ?? new JArray ( ) )
37243725 await this . _parseDelta ( new JObject ( ) { { "delta" , delta } } ) ;
37253726 }
37263727 }
0 commit comments