SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add error if user not found

Browse Source
This commit is contained in:
Pavel 2024-05-24 21:36:50 +03:00
parent 24f2998eac
commit e0caf399c6
3 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/controllers/user.go
View File

@ -1,6 +1,8 @@
package controllers package controllers
import ( import (
"amocrm/internal/service_errors"
"errors"
"github.com/gofiber/fiber/v2" "github.com/gofiber/fiber/v2"
"go.uber.org/zap" "go.uber.org/zap"
"penahub.gitlab.yandexcloud.net/backend/quiz/core.git/middleware" "penahub.gitlab.yandexcloud.net/backend/quiz/core.git/middleware"
@ -63,6 +65,9 @@ func (c *Controller) GetCurrentAccount(ctx *fiber.Ctx) error {
response, err := c.service.GetCurrentAccount(ctx.Context(), accountID) response, err := c.service.GetCurrentAccount(ctx.Context(), accountID)
if err != nil { if err != nil {
if errors.Is(err, service_errors.ErrUserNotFound) {
return ctx.Status(fiber.StatusNotFound).SendString("user not found")
}
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error") return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
} }

5
internal/service/user.go
View File

@ -2,7 +2,9 @@ package service
import ( import (
"amocrm/internal/models" "amocrm/internal/models"
"amocrm/internal/service_errors"
"context" "context"
"database/sql"
"go.uber.org/zap" "go.uber.org/zap"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/model" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/model"
) )
@ -43,6 +45,9 @@ func (s *Service) SoftDeleteAccount(ctx context.Context, accountID string) error
func (s *Service) GetCurrentAccount(ctx context.Context, accountID string) (*model.User, error) { func (s *Service) GetCurrentAccount(ctx context.Context, accountID string) (*model.User, error) {
user, err := s.repository.AmoRepo.GetCurrentAccount(ctx, accountID) user, err := s.repository.AmoRepo.GetCurrentAccount(ctx, accountID)
if err != nil { if err != nil {
if err == sql.ErrNoRows {
return nil, service_errors.ErrUserNotFound
}
s.logger.Error("error getting current account in getCurrentAccount service", zap.Error(err)) s.logger.Error("error getting current account in getCurrentAccount service", zap.Error(err))
return nil, err return nil, err
} }

5
internal/service_errors/pg_error.go Normal file
View File

@ -0,0 +1,5 @@
package service_errors
import "errors"
var ErrUserNotFound = errors.New("user not found")