v.0.0.3.1 Фикс соединения rabbit

server.go

@@ -8,6 +8,7 @@ import (
 	"github.com/jackc/pgx/v4/pgxpool"
 	amqp "github.com/rabbitmq/amqp091-go"
 	"google.golang.org/grpc"
+	protobuf "google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/timestamppb"
 	"log"
 	"net"
@@ -170,6 +171,24 @@ func (s *server) SendMessage(ctx context.Context, req *proto.SendMessageRequest)
 	return nil, fmt.Errorf("failed to publish message after 3 attempts: %v", lastErr)
 }
 
+func mustMarshal(msg protobuf.Message) []byte {
+	data, err := protobuf.Marshal(msg)
+	if err != nil {
+		log.Fatalf("failed to marshal message: %v", err)
+	}
+	return data
+}
+func protoMessageToMap(msg *proto.Message) map[string]interface{} {
+	return map[string]interface{}{
+		"id":         msg.Id,
+		"chatId":     msg.ChatId,
+		"senderId":   msg.SenderId,
+		"receiverId": msg.ReceiverId,
+		"content":    msg.Content,
+		"status":     msg.Status,
+		"createdAt":  msg.CreatedAt.AsTime().Format(time.RFC3339Nano),
+	}
+}
 func (s *server) GetChat(ctx context.Context, req *proto.GetChatRequest) (*proto.ChatResponse, error) {
 	var chat proto.Chat
 	var createdAt, updatedAt time.Time
@@ -352,7 +371,7 @@ func (s *server) runStream(req *proto.StreamMessagesRequest, stream proto.Messag
 	_, err = ch.QueueDeclare(
 		queueName,
 		true,  // durable
-		true,  // autoDelete
+		false, // autoDelete
 		false, // exclusive
 		false, // noWait
 		amqp.Table{