From 5247f04a1130437c698e0fbaae4215d2beca28d5 Mon Sep 17 00:00:00 2001
From: mchekalov <mchekalov@gmail.com>
Date: Wed, 20 Mar 2024 14:47:14 +0500
Subject: [PATCH] Some correction repo. It didn't write in BD when SendMessage
 and Delete

---
 internal/client/db/pg/pg.go            | 10 +++++-----
 internal/repository/chat/repository.go |  8 ++++----
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/internal/client/db/pg/pg.go b/internal/client/db/pg/pg.go
index 2b2aa5b..d750e24 100644
--- a/internal/client/db/pg/pg.go
+++ b/internal/client/db/pg/pg.go
@@ -26,11 +26,11 @@ type pg struct {
 }
 
 // NewDB creates a new PostgreSQL database client.
-func NewDB(dbc *pgxpool.Pool) db.DB {
-	return &pg{
-		dbc: dbc,
-	}
-}
+//func NewDB(dbc *pgxpool.Pool) db.DB {
+//	return &pg{
+//		dbc: dbc,
+//	}
+//}
 
 func (p *pg) ScanOneContext(ctx context.Context, dest interface{}, q db.Query, args ...interface{}) error {
 	logQuery(ctx, q, args...)
diff --git a/internal/repository/chat/repository.go b/internal/repository/chat/repository.go
index fe2930f..ca4858f 100644
--- a/internal/repository/chat/repository.go
+++ b/internal/repository/chat/repository.go
@@ -14,7 +14,7 @@ import (
 
 const (
 	tableName      = "chats"
-	chatnameColumn = "chat_name"
+	chatNameColumn = "chat_name"
 	chatIDColumn   = "chat_id"
 )
 
@@ -41,7 +41,7 @@ func (r *repo) Create(ctx context.Context, chat *model.Chat) (int64, error) {
 	chatRepo := converter.FromChatToRepo(chat)
 
 	builder := r.sq.Insert(tableName).
-		Columns(chatnameColumn).
+		Columns(chatNameColumn).
 		Values(chatRepo.ChatName).
 		Suffix(fmt.Sprintf("RETURNING %v", chatIDColumn))
 
@@ -66,7 +66,7 @@ func (r *repo) Create(ctx context.Context, chat *model.Chat) (int64, error) {
 
 func (r *repo) Delete(ctx context.Context, id *model.ChatDelete) error {
 	builder := r.sq.Delete(tableName).
-		Where(squirrel.Eq{chatIDColumn: id})
+		Where(squirrel.Eq{chatIDColumn: id.ChatID})
 
 	query, args, err := builder.ToSql()
 	if err != nil {
@@ -98,7 +98,7 @@ func (r *repo) SaveMessage(ctx context.Context, message *model.Message) error {
 		QueryRaw: query,
 	}
 
-	r.db.DB().QueryRowContext(ctx, q, args)
+	r.db.DB().QueryRowContext(ctx, q, args...)
 
 	return nil
 }