@@ -768,8 +768,7 @@ func (s *Service) handleNewConnection(ctx context.Context, clientConn *websocket
768768					slog .String ("message_type" , messageType ),
769769					slog .Bool ("has_final_report" , msg .FinalReport  !=  "" ),
770770					slog .Int ("client_count" , clientCount ),
771- 					slog .Bool ("broadcast_success" , broadcastErr  ==  nil ),
772- 					slog .String ("raw_message" , string (message )))
771+ 					slog .Bool ("broadcast_success" , broadcastErr  ==  nil ))
773772
774773				// Store message with sent status 
775774				if  err  :=  s .storage .AddMessage (userID , chatID , string (message ), messageSent , messageType ); err  !=  nil  {
@@ -887,8 +886,7 @@ func (s *Service) handleNewConnection(ctx context.Context, clientConn *websocket
887886					slog .String ("chat_id" , chatID ),
888887					slog .String ("message_type" , messageType ),
889888					slog .Bool ("has_final_report" , msg .FinalReport  !=  "" ),
890- 					slog .Bool ("broadcast_success" , broadcastErr  ==  nil ),
891- 					slog .String ("raw_message" , string (message )))
889+ 					slog .Bool ("broadcast_success" , broadcastErr  ==  nil ))
892890				if  broadcastErr  !=  nil  {
893891					log .Warn ("failed to broadcast message without storage" ,
894892						slog .String ("user_id" , userID ),
0 commit comments