From 7cbf0715328522e4e3937ec8dbcdd859eefda3ff Mon Sep 17 00:00:00 2001
From: madipo2611 <klimov.aka@yandex.ru>
Date: Sun, 17 Aug 2025 22:14:15 +0300
Subject: [PATCH] =?UTF-8?q?v0.0.18.5=20=D0=94=D0=BE=D0=B1=D0=B0=D0=B2?=
 =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BB=D0=BE=D0=B3=D0=B8=D1=80?=
 =?UTF-8?q?=D0=BE=D0=B2=D0=B0=D0=BD=D0=B8=D0=B5=20=D0=B4=D0=BB=D1=8F=20ws?=
 =?UTF-8?q?=20=D0=B8=20stream?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/http/graph/messages_resolvers.go | 4 ++++
 internal/http/middleware/ws_auth.go       | 2 ++
 internal/http/server.go                   | 1 +
 3 files changed, 7 insertions(+)

diff --git a/internal/http/graph/messages_resolvers.go b/internal/http/graph/messages_resolvers.go
index 8f61d5b..982c96b 100644
--- a/internal/http/graph/messages_resolvers.go
+++ b/internal/http/graph/messages_resolvers.go
@@ -3,6 +3,7 @@ package graph
 import (
 	"context"
 	"fmt"
+	"log"
 	"tailly_back_v2/internal/domain"
 	"tailly_back_v2/proto"
 	"time"
@@ -128,15 +129,18 @@ func (r *subscriptionResolver) MessageStream(ctx context.Context, userID int) (<
 	stream, err := r.MessageClient.StreamMessages(ctx, &proto.StreamMessagesRequest{
 		UserId: int32(userID),
 	})
+	log.Printf("stream messages: %v", stream)
 	if err != nil {
 		return nil, fmt.Errorf("failed to stream messages: %w", err)
 	}
 
 	messageChan := make(chan *domain.Message)
+	log.Printf("messageChan: %d", messageChan)
 	go func() {
 		defer close(messageChan)
 		for {
 			msg, err := stream.Recv()
+			log.Printf("recv message: %v", msg)
 			if err != nil {
 				return
 			}
diff --git a/internal/http/middleware/ws_auth.go b/internal/http/middleware/ws_auth.go
index 4926a82..67d366a 100644
--- a/internal/http/middleware/ws_auth.go
+++ b/internal/http/middleware/ws_auth.go
@@ -2,6 +2,7 @@ package middleware
 
 import (
 	"context"
+	"log"
 	"net/http"
 	"tailly_back_v2/pkg/auth"
 )
@@ -14,6 +15,7 @@ func WSAuthMiddleware(tokenAuth *auth.TokenAuth) func(http.Handler) http.Handler
 			if r.Header.Get("Upgrade") == "websocket" {
 				// Извлекаем токен из query параметров или заголовков
 				token := extractTokenFromRequest(r)
+				log.Printf("token ws: %s", token)
 
 				if token != "" {
 					userID, err := tokenAuth.ValidateAccessToken(token)
diff --git a/internal/http/server.go b/internal/http/server.go
index 943548e..2bfde71 100644
--- a/internal/http/server.go
+++ b/internal/http/server.go
@@ -76,6 +76,7 @@ func (s *Server) configureRouter() {
 		Upgrader: websocket.Upgrader{
 			CheckOrigin: func(r *http.Request) bool {
 				origin := r.Header.Get("Origin")
+				log.Printf("origin: %s", origin)
 				for _, allowed := range allowedOrigins {
 					if origin == allowed {
 						return true