v.0.0.3.6 Не отправляем пустое сообщение в stream

2025-08-18 14:30:43 +03:00 · 2025-08-18 14:30:43 +03:00 · 33952dd83b
commit 33952dd83b
parent 5286a534cf
1 changed files with 5 additions and 0 deletions
--- a/server.go
+++ b/server.go
@ -539,6 +539,11 @@ func (s *server) runStream(req *proto.StreamMessagesRequest, stream proto.Messag
 				continue
 			}

+			if msg.Id == 0 || msg.Content == "" {
+				d.Ack(false) // Подтверждаем, но не отправляем в стрим
+				continue
+			}
+
 			s.logger.Printf("Sending message to stream for user %d: %+v", req.UserId, msg)
 			if err := stream.Send(&proto.MessageResponse{Message: &msg}); err != nil {
 				s.logger.Printf("Failed to send message to stream: %v", err)