From 9f28b4bcbad09c38f3d6a7c9b29729dd64bf5a20 Mon Sep 17 00:00:00 2001 From: optclblast Date: Sun, 5 May 2024 21:28:34 +0300 Subject: [PATCH] tmp --- .../usecase/repository/users/repository.go | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/backend/internal/usecase/repository/users/repository.go b/backend/internal/usecase/repository/users/repository.go index 33340e0..537de4d 100644 --- a/backend/internal/usecase/repository/users/repository.go +++ b/backend/internal/usecase/repository/users/repository.go @@ -3,8 +3,10 @@ package users import ( "context" "database/sql" + "fmt" "github.com/emochka2007/block-accounting/internal/pkg/models" + sqltools "github.com/emochka2007/block-accounting/internal/pkg/sqlutils" "github.com/google/uuid" ) @@ -28,11 +30,21 @@ type repositorySQL struct { } func NewRepository(db *sql.DB) Repository { - return nil + return &repositorySQL{ + db: db, + } } func (r *repositorySQL) Get(ctx context.Context, params GetParams) (*models.User, error) { + var user *models.User + if err := sqltools.Transaction(ctx, r.db, func(ctx context.Context) error { + return nil + }); err != nil { + return nil, fmt.Errorf("error execute transactional operation. %w", err) + } + + return user, nil } func (r *repositorySQL) Create(ctx context.Context, user *models.User) error {