feat: owner create and update endpoints

Author: naingminkhant16

backend/cms-sys/cmd/main.go

@@ -23,9 +23,10 @@ import (
 )
 
 type DISection struct {
-	repo    repository.AuthRepository
-	srv     service.AuthService
-	handler handler.AuthHandle
+	repo         repository.AuthRepository
+	srv          service.AuthService
+	handler      handler.AuthHandle
+	ownerHandler handler.OwnerHandle
 }
 
 func main() {
@@ -145,6 +146,7 @@ func main() {
 
 	di := DependencyInjectionSection(appLogger, dbConnection.DB)
 	routes.SetupRoutes(app, di.handler)
+	routes.SetupOwnerRoutes(app, di.ownerHandler)
 
 	port := utils.GetEnv("PORT", "8080")
 
@@ -175,11 +177,17 @@ func main() {
 func DependencyInjectionSection(logger *logrus.Logger, db *gorm.DB) *DISection {
 	repo := repository.NewRepo(logger, db)
 	srv := service.NewService(logger, repo)
-	handler := handler.NewHandler(srv)
+	authHandler := handler.NewHandler(srv)
+
+	// Owner
+	ownerRepo := repository.NewOwnerRepository(logger, db)
+	ownerService := service.NewOwnerService(logger, ownerRepo, repo)
+	ownerHandler := handler.NewOwnerHandler(ownerService)
 
 	return &DISection{
-		repo:    repo,
-		srv:     srv,
-		handler: handler,
+		repo:         repo,
+		srv:          srv,
+		handler:      authHandler,
+		ownerHandler: ownerHandler,
 	}
 }

backend/cms-sys/internal/handler/owner_handler.go

@@ -0,0 +1,61 @@
+package handler
+
+import (
+	"github.com/go-playground/validator/v10"
+	"github.com/gofiber/fiber/v2"
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/service"
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/types"
+	"github.com/multi-tenants-cms-golang/cms-sys/pkg/utils"
+)
+
+type OwnerHandle interface {
+	Create(c *fiber.Ctx) error
+	Update(c *fiber.Ctx) error
+}
+type OwnerHandler struct {
+	service   service.OwnerService
+	validator *validator.Validate
+}
+
+var _ OwnerHandle = (*OwnerHandler)(nil)
+
+func NewOwnerHandler(service service.OwnerService) OwnerHandle {
+	return &OwnerHandler{service: service, validator: validator.New()}
+}
+
+func (o OwnerHandler) Create(c *fiber.Ctx) error {
+	var req types.OwnerCreateRequest
+	if err := c.BodyParser(&req); err != nil {
+		return utils.BadRequestResponse(c, "Invalid request body", err.Error())
+	}
+
+	if err := o.validator.Struct(req); err != nil {
+		return utils.BadRequestResponse(c, "Validation failed!", err.Error())
+	}
+
+	ownerResponse, err := o.service.Create(req)
+	if err != nil {
+		return utils.InternalServerErrorResponse(c, "Failed to create owner", err.Error())
+	}
+
+	return utils.CreatedResponse(c, "Owner created", ownerResponse)
+}
+
+func (o OwnerHandler) Update(c *fiber.Ctx) error {
+	id := c.Params("id")
+	var req types.OwnerUpdateRequest
+
+	if err := c.BodyParser(&req); err != nil {
+		return utils.BadRequestResponse(c, "Invalid request body", err.Error())
+	}
+	if err := o.validator.Struct(req); err != nil {
+		return utils.BadRequestResponse(c, "Validation failed!", err.Error())
+	}
+
+	ownerResponse, err := o.service.Update(id, req)
+	if err != nil {
+		return utils.InternalServerErrorResponse(c, "Failed to update owner", err.Error())
+	}
+
+	return utils.SuccessResponse(c, "Owner updated", ownerResponse)
+}

backend/cms-sys/internal/repository/owner_repo.go

@@ -0,0 +1,45 @@
+package repository
+
+import (
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/types"
+	"github.com/sirupsen/logrus"
+	"gorm.io/gorm"
+)
+
+type OwnerRepository interface {
+	CreateOwner(owner *types.CMSUser) error
+	GeyById(id string) (*types.CMSUser, error)
+	UpdateOwner(owner *types.CMSUser) error
+}
+
+type OwnerRepositoryImpl struct {
+	logger *logrus.Logger
+	db     *gorm.DB
+}
+
+var _ OwnerRepository = (*OwnerRepositoryImpl)(nil)
+
+func NewOwnerRepository(logger *logrus.Logger, db *gorm.DB) OwnerRepository {
+	return &OwnerRepositoryImpl{logger: logger, db: db}
+}
+
+func (r *OwnerRepositoryImpl) CreateOwner(owner *types.CMSUser) error {
+	if err := r.db.Create(owner).Error; err != nil {
+		r.logger.WithError(err).Error("Failed to create owner")
+		return err
+	}
+	return nil
+}
+
+func (r *OwnerRepositoryImpl) GeyById(id string) (*types.CMSUser, error) {
+	var owner types.CMSUser
+	err := r.db.Where("cms_user_id", id).First(&owner).Error
+	return &owner, err
+}
+
+func (r *OwnerRepositoryImpl) UpdateOwner(owner *types.CMSUser) error {
+	if err := r.db.Save(owner).Error; err != nil {
+		r.logger.WithError(err).Error("Failed to update owner")
+	}
+	return nil
+}

backend/cms-sys/internal/routes/owner_route.go

@@ -0,0 +1,12 @@
+package routes
+
+import (
+	"github.com/gofiber/fiber/v2"
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/handler"
+)
+
+func SetupOwnerRoutes(app *fiber.App, handler handler.OwnerHandle) {
+	ownerRoute := app.Group("/owners")
+	ownerRoute.Post("/create", handler.Create)
+	ownerRoute.Put("/update/:id", handler.Update)
+}

backend/cms-sys/internal/service/owner_service.go

@@ -0,0 +1,99 @@
+package service
+
+import (
+	"errors"
+	"github.com/google/uuid"
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/repository"
+	"github.com/multi-tenants-cms-golang/cms-sys/internal/types"
+	"github.com/multi-tenants-cms-golang/cms-sys/pkg/utils"
+	"github.com/sirupsen/logrus"
+	"time"
+)
+
+type OwnerService interface {
+	Create(req types.OwnerCreateRequest) (*types.OwnerResponse, error)
+	Update(id string, req types.OwnerUpdateRequest) (*types.OwnerResponse, error)
+}
+
+type OwnerServiceImpl struct {
+	log      *logrus.Logger
+	repo     repository.OwnerRepository
+	authRepo repository.AuthRepository
+}
+
+var _ OwnerService = (*OwnerServiceImpl)(nil)
+
+func NewOwnerService(log *logrus.Logger, repo repository.OwnerRepository, authRepo repository.AuthRepository) OwnerService {
+	return &OwnerServiceImpl{
+		log:      log,
+		repo:     repo,
+		authRepo: authRepo,
+	}
+}
+
+func (os *OwnerServiceImpl) Create(req types.OwnerCreateRequest) (*types.OwnerResponse, error) {
+	exists, err := os.authRepo.EmailExists(req.Email)
+	if err != nil {
+		os.log.WithError(err).Error("Failed to check email exists!")
+	}
+
+	if exists {
+		return nil, errors.New("email already exists")
+	}
+
+	hashedPassword, err := utils.HashPassword(req.Password)
+	if err != nil {
+		os.log.WithError(err).Error("Failed to hash password!")
+		return nil, errors.New("filed to process password")
+	}
+
+	owner := &types.CMSUser{
+		CMSUserID:    uuid.New(),
+		CMSUserName:  req.Name,
+		CMSUserEmail: req.Email,
+		CMSNameSpace: &req.NameSpace, // TODO : Gotta fix it later as business logic
+		Password:     hashedPassword,
+		CMSUserRole:  string(types.CMSCustomer),
+		Verified:     false,
+		CreatedAt:    time.Now(),
+		UpdatedAt:    time.Now(),
+	}
+
+	if err := os.repo.CreateOwner(owner); err != nil {
+		os.log.WithError(err).Error("Failed to create owner")
+		return nil, errors.New("failed to create owner")
+	}
+
+	return &types.OwnerResponse{
+		ID:        owner.CMSUserID,
+		Name:      owner.CMSUserName,
+		Email:     owner.CMSUserEmail,
+		Role:      owner.CMSUserRole,
+		NameSpace: *owner.CMSNameSpace,
+		Verified:  owner.Verified,
+	}, nil
+}
+
+func (os *OwnerServiceImpl) Update(id string, req types.OwnerUpdateRequest) (*types.OwnerResponse, error) {
+	owner, err := os.repo.GeyById(id)
+	if err != nil {
+		os.log.WithError(err).Error("Failed to get owner with id ", id)
+		return nil, errors.New("failed to get owner")
+	}
+	owner.CMSUserName = req.Name
+	// TODO : Gotta fix it later as business logic
+	owner.CMSNameSpace = &req.NameSpace
+	if err := os.repo.UpdateOwner(owner); err != nil {
+		os.log.WithError(err).Error("Failed to update owner")
+		return nil, errors.New("failed to update owner")
+	}
+
+	return &types.OwnerResponse{
+		ID:        owner.CMSUserID,
+		Name:      owner.CMSUserName,
+		Email:     owner.CMSUserEmail,
+		Role:      owner.CMSUserRole,
+		NameSpace: *owner.CMSNameSpace,
+		Verified:  owner.Verified,
+	}, nil
+}

backend/cms-sys/internal/types/request.go

@@ -15,3 +15,14 @@ type RegisterRequest struct {
 type RefreshTokenRequest struct {
 	RefreshToken string `json:"refresh_token" validate:"required"`
 }
+
+type OwnerCreateRequest struct {
+	Name      string `json:"name" validate:"required,min=2"`
+	Email     string `json:"email" validate:"required,email"`
+	NameSpace string `json:"namespace" validate:"required,min=3"` // TODO : Gotta remove namespace later
+	Password  string `json:"password" validate:"required,min=6"`
+}
+type OwnerUpdateRequest struct {
+	Name      string `json:"name" validate:"required,min=2"`
+	NameSpace string `json:"namespace" validate:"required,min=3"` // TODO : Gotta remove namespace later
+}

backend/cms-sys/internal/types/response.go

@@ -27,3 +27,12 @@ type TokenResponse struct {
 	RefreshToken string    `json:"refresh_token"`
 	ExpiresAt    time.Time `json:"expires_at"`
 }
+
+type OwnerResponse struct {
+	ID        uuid.UUID `json:"id"`
+	Name      string    `json:"name"`
+	Email     string    `json:"email"`
+	Role      string    `json:"role"`
+	NameSpace string    `json:"name_space"`
+	Verified  bool      `json:"verified"`
+}