Some correction repo. It didn't write in BD when SendMessage and Delete

mchekalov · Mar 20, 2024 · 5247f04 · 5247f04
1 parent 229fd02
commit 5247f04
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git 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
@@ -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
 }