From 60c8c8e7bbd75b2f5ba52250a402599aa09bebc0 Mon Sep 17 00:00:00 2001
From: madipo2611 <klimov.aka@yandex.ru>
Date: Sun, 17 Aug 2025 21:27:15 +0300
Subject: [PATCH] =?UTF-8?q?v0.0.18.3=20=D0=94=D0=BE=D0=B1=D0=B0=D0=B2?=
 =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D0=B8=D0=B8=20=D0=BC=D0=B8=D0=B3=D1=80=D0=B0?=
 =?UTF-8?q?=D1=86=D0=B8=D0=B8=20=D0=B4=D0=BB=D1=8F=20=D0=BF=D0=BE=D0=B4?=
 =?UTF-8?q?=D0=BF=D0=B8=D1=81=D0=BE=D0=BA/=D0=BF=D0=BE=D0=B4=D0=BF=D0=B8?=
 =?UTF-8?q?=D1=81=D1=87=D0=B8=D0=BA=D0=BE=D0=B2.=20=D0=94=D0=BE=D0=B1?=
 =?UTF-8?q?=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD=D0=B0=20=D0=BF=D1=80=D0=BE=D0=B2?=
 =?UTF-8?q?=D0=B5=D1=80=D0=BA=D0=B0=20=D0=BD=D0=B0=20userID=20=3D=200=20?=
 =?UTF-8?q?=D0=B4=D0=BB=D1=8F=20MessageStream?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/http/graph/messages_resolvers.go |  5 +++++
 migrations/0002_initial_schema.down.sql   |  2 ++
 migrations/0002_initial_schema.up.sql     | 21 +++++++++++++++++++++
 3 files changed, 28 insertions(+)
 create mode 100644 migrations/0002_initial_schema.down.sql
 create mode 100644 migrations/0002_initial_schema.up.sql

diff --git a/internal/http/graph/messages_resolvers.go b/internal/http/graph/messages_resolvers.go
index dbedac2..8f61d5b 100644
--- a/internal/http/graph/messages_resolvers.go
+++ b/internal/http/graph/messages_resolvers.go
@@ -120,6 +120,11 @@ func (r *queryResolver) GetUserChats(ctx context.Context, userID int) ([]*domain
 
 // MessageStream реализация подписки на новые сообщения
 func (r *subscriptionResolver) MessageStream(ctx context.Context, userID int) (<-chan *domain.Message, error) {
+
+	if userID == 0 {
+		return nil, fmt.Errorf("user not authenticated")
+	}
+
 	stream, err := r.MessageClient.StreamMessages(ctx, &proto.StreamMessagesRequest{
 		UserId: int32(userID),
 	})
diff --git a/migrations/0002_initial_schema.down.sql b/migrations/0002_initial_schema.down.sql
new file mode 100644
index 0000000..3c75c1a
--- /dev/null
+++ b/migrations/0002_initial_schema.down.sql
@@ -0,0 +1,2 @@
+DROP TABLE IF EXISTS subscription_notifications CASCADE;
+DROP TABLE IF EXISTS subscriptions CASCADE;
\ No newline at end of file
diff --git a/migrations/0002_initial_schema.up.sql b/migrations/0002_initial_schema.up.sql
new file mode 100644
index 0000000..150d1b5
--- /dev/null
+++ b/migrations/0002_initial_schema.up.sql
@@ -0,0 +1,21 @@
+CREATE TABLE subscriptions (
+                               id SERIAL PRIMARY KEY,
+                               follower_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,  -- Кто подписывается
+                               following_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE, -- На кого подписываются
+                               created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+                               UNIQUE(follower_id, following_id),  -- Уникальная подписка
+                               CHECK (follower_id <> following_id)  -- Запрет подписки на самого себя
+);
+
+-- Уведомления о подписках
+CREATE TABLE subscription_notifications (
+                                            id SERIAL PRIMARY KEY,
+                                            subscription_id INTEGER NOT NULL REFERENCES subscriptions(id) ON DELETE CASCADE,
+                                            is_read BOOLEAN NOT NULL DEFAULT FALSE,
+                                            created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
+);
+
+-- Индексы для улучшения производительности
+CREATE INDEX idx_subscriptions_follower_id ON subscriptions(follower_id);
+CREATE INDEX idx_subscriptions_following_id ON subscriptions(following_id);
+CREATE INDEX idx_subscription_notifications_subscription_id ON subscription_notifications(subscription_id);
\ No newline at end of file