database/ads_model.go

@@ -1,11 +0,0 @@
-package database
-
-import "time"
-
-type Ads struct {
-	ID        string    `gorm:"primaryKey;not null" json:"id"`
-	ImageUrl  string    `gorm:"not null" json:"image_url"`
-	Url       string    `gorm:"not null" json:"url"`
-	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
-	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
-}

database/new_db.go

@@ -54,6 +54,5 @@ func (db *DB) Migrate() error {
 		&News{},
 		&Tag{},
 		&Category{},
-		&Ads{},
 	)
 }

internal/accessor/ads/create.go

@@ -1,14 +0,0 @@
-package adsrepository
-
-import (
-	"fmt"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-)
-
-func (a *accessor) Create(spec adsdomain.Ads) error {
-	if err := a.db.Create(&spec).Error; err != nil {
-		return fmt.Errorf("failed to create ads: %v", err)
-	}
-
-	return nil
-}

internal/accessor/ads/get-all.go

@@ -1,15 +0,0 @@
-package adsrepository
-
-import (
-	"fmt"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-)
-
-func (a *accessor) GetAll() ([]adsdomain.Ads, error) {
-	var ads []adsdomain.Ads
-	if err := a.db.Find(&ads).Error; err != nil {
-		return ads, fmt.Errorf("failed to get all ads: %v", err)
-	}
-
-	return ads, nil
-}

internal/accessor/ads/impl.go

@@ -1,21 +0,0 @@
-package adsrepository
-
-import (
-	"legalgo-BE-go/database"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-)
-
-type accessor struct {
-	db *database.DB
-}
-
-type Ads interface {
-	Create(adsdomain.Ads) error
-	GetAll() ([]adsdomain.Ads, error)
-}
-
-func New(
-	db *database.DB,
-) Ads {
-	return &accessor{db}
-}

internal/accessor/module.go

@@ -1,14 +1,13 @@
 package repository
 
 import (
-	adsrepository "legalgo-BE-go/internal/accessor/ads"
 	categoryrepository "legalgo-BE-go/internal/accessor/category"
 	newsrepository "legalgo-BE-go/internal/accessor/news"
 	"legalgo-BE-go/internal/accessor/oss"
 	redisaccessor "legalgo-BE-go/internal/accessor/redis"
 	staffrepository "legalgo-BE-go/internal/accessor/staff"
 	subscriberepository "legalgo-BE-go/internal/accessor/subscribe"
-	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribe_plan"
+	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribeplan"
 	tagrepository "legalgo-BE-go/internal/accessor/tag"
 	userrepository "legalgo-BE-go/internal/accessor/user"
 
@@ -25,5 +24,4 @@ var Module = fx.Module("repository", fx.Provide(
 	categoryrepository.New,
 	newsrepository.New,
 	oss.New,
-	adsrepository.New,
 ))

internal/accessor/oss/oss.go

@@ -68,19 +68,3 @@ func (r *OssRepositoryImpl) GetPublicURL(fileName string) string {
 	}
 	return fmt.Sprintf("%s:%s%s", r.cfg.GetPublicURL(), r.cfg.GetBucketName(), fileName)
 }
-
-func (r *OssRepositoryImpl) DeleteObject(ctx context.Context, fileName string) error {
-	if fileName == "" {
-		return fmt.Errorf("file name is not provided")
-	}
-
-	_, err := r.s3.DeleteObject(&s3.DeleteObjectInput{
-		Key: aws.String(fileName),
-	})
-
-	if err != nil {
-		return fmt.Errorf("failed to delete object %s from bucket: %v", fileName, err)
-	}
-
-	return nil
-}

internal/accessor/oss/upload.go

@@ -7,5 +7,4 @@ import (
 type OSSRepository interface {
 	UploadFile(ctx context.Context, fileName string, fileContent []byte) (fileUrl string, err error)
 	GetPublicURL(fileName string) string
-	DeleteObject(ctx context.Context, fileName string) error
 }

internal/accessor/subscribe/create.go

@@ -6,13 +6,13 @@ import (
 	"github.com/google/uuid"
 )
 
-func (s *accessor) Create(subsPlanId string) (string, error) {
+func (s *SubsAccs) Create(subsPlanId string) (string, error) {
 	spec := &subscribedomain.Subscribe{
 		ID:              uuid.NewString(),
 		SubscribePlanID: subsPlanId,
 	}
 
-	if err := s.db.Create(&spec).Error; err != nil {
+	if err := s.DB.Create(&spec).Error; err != nil {
 		return "", err
 	}
 

internal/accessor/subscribe/get_by_id.go

@@ -3,15 +3,15 @@ package subscriberepository
 import (
 	"errors"
 	"fmt"
-	subscribedomain "legalgo-BE-go/internal/domain/subscribe"
+	"legalgo-BE-go/database"
 
 	"gorm.io/gorm"
 )
 
-func (s *accessor) GetByID(id string) (subscribedomain.Subscribe, error) {
+func (s *SubsAccs) GetByID(id string) (database.Subscribe, error) {
-	var subscribe subscribedomain.Subscribe
+	var subscribe database.Subscribe
 
-	if err := s.db.First(&subscribe, "id = ?", id).Error; err != nil {
+	if err := s.DB.First(&subscribe, "id = ?", id).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return subscribe, fmt.Errorf("subscribe data not found: %v", err)
 		}

internal/accessor/subscribe/impl.go

@@ -1,20 +1,17 @@
 package subscriberepository
 
-import (
+import "legalgo-BE-go/database"
-	"legalgo-BE-go/database"
-	subscribedomain "legalgo-BE-go/internal/domain/subscribe"
-)
 
-type accessor struct {
+type SubsAccs struct {
-	db *database.DB
+	DB *database.DB
 }
 
-type Subscribe interface {
+type SubsIntf interface {
 	Create(string) (string, error)
-	GetByID(string) (subscribedomain.Subscribe, error)
+	GetByID(string) (database.Subscribe, error)
-	Update(subscribedomain.Subscribe) error
+	UpdateSubscribeStatus(database.Subscribe) error
 }
 
-func New(db *database.DB) Subscribe {
+func New(db *database.DB) SubsIntf {
-	return &accessor{db}
+	return &SubsAccs{db}
 }

internal/accessor/subscribe/update.go

@@ -1,19 +0,0 @@
-package subscriberepository
-
-import (
-	"fmt"
-	subscribedomain "legalgo-BE-go/internal/domain/subscribe"
-
-	"gorm.io/gorm/clause"
-)
-
-func (a *accessor) Update(spec subscribedomain.Subscribe) error {
-	if err := a.db.Clauses(clause.OnConflict{
-		Columns:   []clause.Column{{Name: "id"}},
-		DoUpdates: clause.AssignmentColumns([]string{"status", "subscribe_plan_id", "start_date"}),
-	}).Create(&spec).Error; err != nil {
-		return fmt.Errorf("failed to update status: %v", err)
-	}
-
-	return nil
-}

internal/accessor/subscribe/update_subscribe_status.go

@@ -0,0 +1,19 @@
+package subscriberepository
+
+import (
+	"fmt"
+	"legalgo-BE-go/database"
+
+	"gorm.io/gorm/clause"
+)
+
+func (a *SubsAccs) UpdateSubscribeStatus(spec database.Subscribe) error {
+	if err := a.DB.Clauses(clause.OnConflict{
+		Columns:   []clause.Column{{Name: "id"}},
+		DoUpdates: clause.AssignmentColumns([]string{"status"}),
+	}).Create(&spec).Error; err != nil {
+		return fmt.Errorf("failed to update status: %v", err)
+	}
+
+	return nil
+}

internal/accessor/subscribe_plan/create.go

@@ -1,13 +0,0 @@
-package subscribeplanrepository
-
-import (
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-)
-
-func (s *accessor) Create(spec subscribeplandomain.SubscribePlan) error {
-	if err := s.db.Create(&spec).Error; err != nil {
-		return err
-	}
-
-	return nil
-}

internal/accessor/subscribe_plan/delete.go

@@ -1,30 +0,0 @@
-package subscribeplanrepository
-
-import (
-	"fmt"
-	"legalgo-BE-go/database"
-	subscribedomain "legalgo-BE-go/internal/domain/subscribe"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-)
-
-func (a *accessor) Delete(id string) error {
-	var subsPlan database.SubscribePlan
-	var basicPlan subscribeplandomain.SubscribePlan
-
-	if err := a.db.First(&basicPlan, "code = ?", "basic").Error; err != nil {
-		return fmt.Errorf("failed to find basic plan: %v", err)
-	}
-
-	if err := a.db.
-		Model(&subscribedomain.Subscribe{}).
-		Where("subscribe_plan_id = ?", id).
-		Update("subscribe_plan_id", basicPlan.ID); err != nil {
-		return fmt.Errorf("failed to change subscribe plan: %v", err)
-	}
-
-	if err := a.db.Where("id = ?", id).Delete(&subsPlan).Error; err != nil {
-		return fmt.Errorf("failed to delete subscribe plan %s : %v", id, err)
-	}
-
-	return nil
-}

internal/accessor/subscribe_plan/get_by_id.go

@@ -1,21 +0,0 @@
-package subscribeplanrepository
-
-import (
-	"errors"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-
-	"gorm.io/gorm"
-)
-
-func (s *accessor) GetByID(id string) (*subscribeplandomain.SubscribePlan, error) {
-	var subscribePlan *subscribeplandomain.SubscribePlan
-
-	if err := s.db.First(&subscribePlan, "id = ? ", id).Error; err != nil {
-		if errors.Is(err, gorm.ErrRecordNotFound) {
-			return subscribePlan, errors.New("subscribe plan not found")
-		}
-		return subscribePlan, err
-	}
-
-	return subscribePlan, nil
-}

internal/accessor/subscribe_plan/get_default.go

@@ -1,22 +0,0 @@
-package subscribeplanrepository
-
-import (
-	"legalgo-BE-go/database"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-
-	"github.com/google/uuid"
-)
-
-func (s *accessor) GetDefault() (*subscribeplandomain.SubscribePlan, error) {
-	var subscribePlan *subscribeplandomain.SubscribePlan
-
-	if err := s.db.First(&subscribePlan, "code = ?", "basic").Error; err != nil {
-		s.db.Create(&database.SubscribePlan{
-			ID:   uuid.NewString(),
-			Code: "basic",
-			Name: "Basic",
-		})
-	}
-
-	return subscribePlan, nil
-}

internal/accessor/subscribe_plan/impl.go

@@ -1,25 +0,0 @@
-package subscribeplanrepository
-
-import (
-	"legalgo-BE-go/database"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-)
-
-type accessor struct {
-	db *database.DB
-}
-
-type SubscribePlan interface {
-	Create(subscribeplandomain.SubscribePlan) error
-	GetAll() ([]subscribeplandomain.SubscribePlan, error)
-	GetByID(string) (*subscribeplandomain.SubscribePlan, error)
-	GetDefault() (*subscribeplandomain.SubscribePlan, error)
-	Update(subscribeplandomain.SubscribePlan) error
-	Delete(string) error
-}
-
-func New(
-	db *database.DB,
-) SubscribePlan {
-	return &accessor{db}
-}

internal/accessor/subscribe_plan/update.go

@@ -1,23 +0,0 @@
-package subscribeplanrepository
-
-import (
-	"fmt"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-
-	"gorm.io/gorm/clause"
-)
-
-func (a *accessor) Update(spec subscribeplandomain.SubscribePlan) error {
-	if err := a.db.Clauses(clause.OnConflict{
-		Columns: []clause.Column{{Name: "id"}},
-		DoUpdates: clause.AssignmentColumns([]string{
-			"name",
-			"code",
-			"updated_at",
-		}),
-	}).Select("name", "code", "updated_at").Save(&spec).Error; err != nil {
-		return fmt.Errorf("failed to update tag: %v", err)
-	}
-
-	return nil
-}

internal/accessor/subscribeplan/create.go

@@ -0,0 +1,21 @@
+package subscribeplanrepository
+
+import (
+	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
+
+	"github.com/google/uuid"
+)
+
+func (s *SubsPlan) Create(spec subscribeplandomain.SubscribePlanReq) error {
+	data := &subscribeplandomain.SubscribePlan{
+		ID:   uuid.NewString(),
+		Code: spec.Code,
+		Name: spec.Name,
+	}
+
+	if err := s.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/subscribeplan/get_all.go

@@ -4,10 +4,10 @@ import (
 	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
 )
 
-func (s *accessor) GetAll() ([]subscribeplandomain.SubscribePlan, error) {
+func (s *SubsPlan) GetAll() ([]subscribeplandomain.SubscribePlan, error) {
 	var subscribePlans []subscribeplandomain.SubscribePlan
 
-	if err := s.db.Find(&subscribePlans).Error; err != nil {
+	if err := s.DB.Find(&subscribePlans).Error; err != nil {
 		return nil, err
 	}
 

internal/accessor/subscribeplan/get_by_id.go

@@ -0,0 +1,21 @@
+package subscribeplanrepository
+
+import (
+	"errors"
+	"legalgo-BE-go/database"
+
+	"gorm.io/gorm"
+)
+
+func (s *SubsPlan) GetByID(id string) (*database.SubscribePlan, error) {
+	var subscribePlan *database.SubscribePlan
+
+	if err := s.DB.First(&subscribePlan, "id = ? ", id).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return subscribePlan, errors.New("subscribe plan not found")
+		}
+		return subscribePlan, err
+	}
+
+	return subscribePlan, nil
+}

internal/accessor/subscribeplan/get_default.go

@@ -0,0 +1,21 @@
+package subscribeplanrepository
+
+import (
+	"legalgo-BE-go/database"
+
+	"github.com/google/uuid"
+)
+
+func (s *SubsPlan) GetDefault() (*database.SubscribePlan, error) {
+	var subscribePlan *database.SubscribePlan
+
+	if err := s.DB.First(&subscribePlan, "code = ?", "basic").Error; err != nil {
+		s.DB.Create(&database.SubscribePlan{
+			ID:   uuid.NewString(),
+			Code: "basic",
+			Name: "Basic",
+		})
+	}
+
+	return subscribePlan, nil
+}

internal/accessor/subscribeplan/impl.go

@@ -0,0 +1,23 @@
+package subscribeplanrepository
+
+import (
+	"legalgo-BE-go/database"
+	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
+)
+
+type SubsPlan struct {
+	DB *database.DB
+}
+
+type SubsPlanIntf interface {
+	Create(subscribeplandomain.SubscribePlanReq) error
+	GetAll() ([]subscribeplandomain.SubscribePlan, error)
+	GetByID(string) (*database.SubscribePlan, error)
+	GetDefault() (*database.SubscribePlan, error)
+}
+
+func New(
+	db *database.DB,
+) SubsPlanIntf {
+	return &SubsPlan{db}
+}

internal/api/http/ads/create.go

@@ -1,106 +0,0 @@
-package adshttp
-
-import (
-	"fmt"
-	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-	"legalgo-BE-go/internal/domain/oss"
-	adssvc "legalgo-BE-go/internal/services/ads"
-	"legalgo-BE-go/internal/utilities/response"
-	"net/http"
-
-	"github.com/go-chi/chi/v5"
-)
-
-const _oneMB = 1 << 20
-const _maxUploadSize = 2 * _oneMB
-const _folderName = "/file"
-
-func Create(
-	router chi.Router,
-	adsSvc adssvc.Ads,
-) {
-	router.With(authmiddleware.Authorize()).Post("/ads/create", func(w http.ResponseWriter, r *http.Request) {
-		ctx := r.Context()
-
-		err := r.ParseMultipartForm(10 << 20) // 10 MB
-		if err != nil {
-			response.RespondJsonErrorWithCode(
-				ctx,
-				w,
-				err,
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"unable to parse form",
-			)
-			return
-		}
-
-		url := r.FormValue("url")
-		if url == "" {
-			response.RespondJsonErrorWithCode(
-				ctx,
-				w,
-				err,
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"URL is missing",
-			)
-			return
-		}
-
-		file, header, err := r.FormFile("image")
-		if err != nil {
-			response.RespondJsonErrorWithCode(
-				ctx,
-				w,
-				err,
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"unable to retrieve image",
-			)
-			return
-		}
-		defer file.Close()
-
-		if header.Size > int64(_maxUploadSize) {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				fmt.Errorf("file too big"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				fmt.Sprintf("The file is too big. The maximum size is %d MB", _maxUploadSize/_oneMB),
-			)
-			return
-		}
-
-		imageRequest := &oss.UploadFileRequest{
-			FileHeader: header,
-			FolderName: _folderName,
-		}
-
-		adsReq := adsdomain.AdsReq{
-			Image: imageRequest,
-			Url:   url,
-		}
-
-		if err := adsSvc.Create(ctx, adsReq); err != nil {
-			response.RespondJsonErrorWithCode(
-				ctx,
-				w,
-				err,
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				err.Error(),
-			)
-			return
-		}
-
-		response.RespondJsonSuccess(ctx, w, struct {
-			Message string
-		}{
-			Message: "ads created successfully",
-		})
-	})
-}

internal/api/http/ads/get_all.go

@@ -1,32 +0,0 @@
-package adshttp
-
-import (
-	adssvc "legalgo-BE-go/internal/services/ads"
-	"legalgo-BE-go/internal/utilities/response"
-	"net/http"
-
-	"github.com/go-chi/chi/v5"
-)
-
-func GetAll(
-	router chi.Router,
-	adsSvc adssvc.Ads,
-) {
-	router.Get("/ads", func(w http.ResponseWriter, r *http.Request) {
-		ctx := r.Context()
-		subsPlan, err := adsSvc.GetAll()
-		if err != nil {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				err,
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				err.Error(),
-			)
-			return
-		}
-
-		response.RespondJsonSuccess(ctx, w, subsPlan)
-	})
-}

internal/api/http/ads/module.go

@@ -1,8 +0,0 @@
-package adshttp
-
-import "go.uber.org/fx"
-
-var Module = fx.Module("ads-http", fx.Invoke(
-	Create,
-	GetAll,
-))

internal/api/http/router.go

@@ -1,12 +1,10 @@
 package internalhttp
 
 import (
-	adshttp "legalgo-BE-go/internal/api/http/ads"
 	categoryhttp "legalgo-BE-go/internal/api/http/category"
 	newshttp "legalgo-BE-go/internal/api/http/news"
 	osshttp "legalgo-BE-go/internal/api/http/oss"
 	staffhttp "legalgo-BE-go/internal/api/http/staffhttp"
-	subscribehttp "legalgo-BE-go/internal/api/http/subscribe"
 	subscribeplanhttp "legalgo-BE-go/internal/api/http/subscribe_plan"
 	taghttp "legalgo-BE-go/internal/api/http/tag"
 	userhttp "legalgo-BE-go/internal/api/http/user"
@@ -31,8 +29,6 @@ var Module = fx.Module("router",
 	newshttp.Module,
 	osshttp.Module,
 	userhttp.Module,
-	subscribehttp.Module,
-	adshttp.Module,
 )
 
 func initRouter() chi.Router {

internal/api/http/subscribe/module.go

@@ -2,6 +2,4 @@ package subscribehttp
 
 import "go.uber.org/fx"
 
-var Module = fx.Module("subscribe", fx.Invoke(
+var Module = fx.Module("subscribe", fx.Invoke())
-	Update,
-))

internal/api/http/subscribe/update.go

@@ -1,9 +1,9 @@
 package subscribehttp
 
 import (
-	userrepository "legalgo-BE-go/internal/accessor/user"
 	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
 	userdomain "legalgo-BE-go/internal/domain/user"
+	authsvc "legalgo-BE-go/internal/services/auth"
 	subscribesvc "legalgo-BE-go/internal/services/subscribe"
 	"legalgo-BE-go/internal/utilities/response"
 	"legalgo-BE-go/internal/utilities/utils"
@@ -14,7 +14,7 @@ import (
 
 func Update(
 	router chi.Router,
-	userRepo userrepository.User,
+	authSvc authsvc.Auth,
 	subSvc subscribesvc.Subscribe,
 ) {
 	router.
@@ -60,11 +60,9 @@ func Update(
 				return
 			}
 
-			user, err := userRepo.GetUserProfile(detail.Email)
+			user, err := authSvc.GetUserProfile(detail.Email)
 
-			body.ID = user.Subscribe.ID
+			if err := subSvc.Update(user.ID, body); err != nil {
-
-			if err := subSvc.Update(body); err != nil {
 				response.ResponseWithErrorCode(
 					ctx,
 					w,
@@ -75,11 +73,5 @@ func Update(
 				)
 				return
 			}
-
-			response.RespondJsonSuccess(ctx, w, struct {
-				Message string
-			}{
-				Message: "update user plan success",
-			})
 		})
 }

internal/api/http/subscribe_plan/create.go

@@ -49,7 +49,7 @@ func CreateSubscribePlan(
 				return
 			}
 
-			if err := subsSvc.Create(spec); err != nil {
+			if err := subsSvc.CreatePlan(spec); err != nil {
 				response.ResponseWithErrorCode(
 					ctx,
 					w,

internal/api/http/subscribe_plan/delete.go

@@ -1,53 +0,0 @@
-package subscribeplanhttp
-
-import (
-	"fmt"
-	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
-	subscribeplansvc "legalgo-BE-go/internal/services/subscribe_plan"
-	"legalgo-BE-go/internal/utilities/response"
-	"net/http"
-
-	"github.com/go-chi/chi/v5"
-)
-
-func Delete(
-	router chi.Router,
-	subscribePlanSvc subscribeplansvc.SubscribePlan,
-) {
-	router.
-		With(authmiddleware.Authorize()).
-		Delete("/subscribe-plan/{subsplan_id}/delete", func(w http.ResponseWriter, r *http.Request) {
-			ctx := r.Context()
-			subsPlanID := chi.URLParam(r, "subsplan_id")
-
-			if subsPlanID == "" {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					fmt.Errorf("subscribe plan id is not provided"),
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					"subscribe plan id is not provided",
-				)
-				return
-			}
-
-			if err := subscribePlanSvc.Delete(subsPlanID); err != nil {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					err,
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					err.Error(),
-				)
-				return
-			}
-
-			response.RespondJsonSuccess(ctx, w, struct {
-				Message string
-			}{
-				Message: "subscribe plan has been deleted",
-			})
-		})
-}

internal/api/http/subscribe_plan/module.go

@@ -6,7 +6,5 @@ var Module = fx.Module("subscribe-plan",
 	fx.Invoke(
 		CreateSubscribePlan,
 		GetAllPlan,
-		Update,
-		Delete,
 	),
 )

internal/api/http/subscribe_plan/update.go

@@ -1,82 +0,0 @@
-package subscribeplanhttp
-
-import (
-	"fmt"
-	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-	subscribeplansvc "legalgo-BE-go/internal/services/subscribe_plan"
-	"legalgo-BE-go/internal/utilities/response"
-	"legalgo-BE-go/internal/utilities/utils"
-	"net/http"
-
-	"github.com/go-chi/chi/v5"
-	"github.com/go-playground/validator/v10"
-)
-
-func Update(
-	router chi.Router,
-	validate *validator.Validate,
-	subsPlanSvc subscribeplansvc.SubscribePlan,
-) {
-	router.
-		With(authmiddleware.Authorize()).
-		Put("/subscribe-plan/{subsplan_id}/update", func(w http.ResponseWriter, r *http.Request) {
-			ctx := r.Context()
-			tagID := chi.URLParam(r, "subsplan_id")
-
-			if tagID == "" {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					fmt.Errorf("subscribe plan id is not provided"),
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					"subscribe plan id is not provided",
-				)
-				return
-			}
-
-			var spec subscribeplandomain.SubscribePlanUpdate
-			if err := utils.UnmarshalBody(r, &spec); err != nil {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					err,
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					"failed to unmarshal body",
-				)
-				return
-			}
-
-			if err := validate.Struct(spec); err != nil {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					err,
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					err.(validator.ValidationErrors).Error(),
-				)
-				return
-			}
-
-			if err := subsPlanSvc.Update(tagID, spec); err != nil {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					err,
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					err.Error(),
-				)
-				return
-			}
-
-			response.RespondJsonSuccess(ctx, w, struct {
-				Message string
-			}{
-				Message: "update subscribe plan success",
-			})
-		})
-}

internal/api/http/tag/delete.go

@@ -16,23 +16,23 @@ func Delete(
 ) {
 	router.
 		With(authmiddleware.Authorize()).
-		Delete("/tag/{tag_id}/delete", func(w http.ResponseWriter, r *http.Request) {
+		Delete("/tag/{category_id}/delete", func(w http.ResponseWriter, r *http.Request) {
 			ctx := r.Context()
-			tagID := chi.URLParam(r, "tag_id")
+			categoryID := chi.URLParam(r, "category_id")
 
-			if tagID == "" {
+			if categoryID == "" {
 				response.RespondJsonErrorWithCode(
 					ctx,
 					w,
-					fmt.Errorf("tag id is not provided"),
+					fmt.Errorf("category id is not provided"),
 					response.ErrBadRequest.Code,
 					response.ErrBadRequest.HttpCode,
-					"tag id is not provided",
+					"category id is not provided",
 				)
 				return
 			}
 
-			if err := tagSvc.Delete(tagID); err != nil {
+			if err := tagSvc.Delete(categoryID); err != nil {
 				response.RespondJsonErrorWithCode(
 					ctx,
 					w,

internal/api/http/tag/get_all.go

@@ -14,7 +14,8 @@ func GetAll(
 ) {
 	router.Get("/tag", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-		tags, err := tagSvc.GetAll()
+		tags, err := tagSvc.GetAllModel()
+		// tags, err := tagSvc.GetAll()
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,

internal/api/http/user/login.go

@@ -3,7 +3,7 @@ package userhttp
 import (
 	responsedomain "legalgo-BE-go/internal/domain/reponse"
 	userdomain "legalgo-BE-go/internal/domain/user"
-	usersvc "legalgo-BE-go/internal/services/user"
+	authsvc "legalgo-BE-go/internal/services/auth"
 	"legalgo-BE-go/internal/utilities/response"
 	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
@@ -15,7 +15,7 @@ import (
 
 func Login(
 	router chi.Router,
-	userSvc usersvc.User,
+	authSvc authsvc.Auth,
 	validate *validator.Validate,
 	rdb *redis.Client,
 ) {
@@ -48,7 +48,7 @@ func Login(
 			return
 		}
 
-		token, err := userSvc.LoginAsUser(spec)
+		token, err := authSvc.LoginAsUser(spec)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,

internal/api/http/user/profile.go

@@ -1,7 +1,7 @@
 package userhttp
 
 import (
-	usersvc "legalgo-BE-go/internal/services/user"
+	authsvc "legalgo-BE-go/internal/services/auth"
 	"legalgo-BE-go/internal/utilities/response"
 	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
@@ -11,7 +11,7 @@ import (
 
 func GetProfile(
 	router chi.Router,
-	userSvc usersvc.User,
+	authSvc authsvc.Auth,
 ) {
 	router.Get("/user/profile", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
@@ -28,7 +28,7 @@ func GetProfile(
 			return
 		}
 
-		userProfile, err := userSvc.GetUserProfile(destructedToken.Email)
+		userProfile, err := authSvc.GetUserProfile(destructedToken.Email)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,

internal/api/http/user/register.go

@@ -3,7 +3,7 @@ package userhttp
 import (
 	responsedomain "legalgo-BE-go/internal/domain/reponse"
 	userdomain "legalgo-BE-go/internal/domain/user"
-	usersvc "legalgo-BE-go/internal/services/user"
+	authsvc "legalgo-BE-go/internal/services/auth"
 	"legalgo-BE-go/internal/utilities/response"
 	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
@@ -16,7 +16,7 @@ import (
 func Register(
 	router chi.Router,
 	validate *validator.Validate,
-	authSvc usersvc.User,
+	authSvc authsvc.Auth,
 	rdb *redis.Client,
 ) {
 	router.Post("/user/register", func(w http.ResponseWriter, r *http.Request) {

internal/domain/ads/spec.go

@@ -1,19 +0,0 @@
-package adsdomain
-
-import (
-	"legalgo-BE-go/internal/domain/oss"
-	"time"
-)
-
-type Ads struct {
-	ID        string    `gorm:"primaryKey;not null" json:"id"`
-	ImageUrl  string    `gorm:"not null" json:"image_url"`
-	Url       string    `gorm:"not null" json:"url"`
-	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
-	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
-}
-
-type AdsReq struct {
-	Image *oss.UploadFileRequest `json:"image"`
-	Url   string                 `json:"url"`
-}

internal/domain/subscribe/spec.go

@@ -1,18 +1,28 @@
 package subscribedomain
 
 import (
-	subscribeplan "legalgo-BE-go/internal/domain/subscribe_plan"
+	subscribeplandm "legalgo-BE-go/internal/domain/subscribe_plan_model"
 	"time"
 )
 
-type Subscribe struct {
+type SubscribeDepecrate struct {
-	ID              string     `json:"id"`
+	ID              string `json:"id"`
-	SubscribePlanID string     `json:"subscribe_plan_id"`
+	SubscribePlanID string `json:"subscribe_plan_id"`
-	StartDate       time.Time  `json:"start_date"`
+}
-	EndDate         *time.Time `json:"end_date"`
+
-	Status          string     `json:"status"`
+type SubscribeUpdateReqDepecrate struct {
-	AutoRenew       bool       `json:"auto_renew"`
+	ID     string `json:"id"`
-	UpdatedAt       time.Time  `json:"updated_at"`
+	Status string `json:"status"`
-
+}
-	SubscribePlan subscribeplan.SubscribePlan `gorm:"foreignKey:SubscribePlanID" json:"subscribe_plan"`
+
+// refactored
+type Subscribe struct {
+	ID              string    `gorm:"primaryKey" json:"id"`
+	SubscribePlanID string    `gorm:"not null" json:"subscribe_plan_id"`
+	StartDate       time.Time `gorm:"default:CURRENT_TIMESTAMP"`
+	EndDate         time.Time `gorm:"default:null"`
+	Status          string    `gorm:"default:'inactive'"`
+	AutoRenew       bool      `gorm:"default:true"`
+
+	SubscribePlan subscribeplandm.SubscribePlan `gorm:"foreignKey:SubscribePlanID;constraint:OnDelete:CASCADE" json:"subscribe_plan"`
 }

internal/domain/subscribe_model/response.go

@@ -0,0 +1,17 @@
+package subscribedm
+
+import (
+	subscribeplandm "legalgo-BE-go/internal/domain/subscribe_plan_model"
+	"time"
+)
+
+type Subscribe struct {
+	ID              string     `json:"id"`
+	SubscribePlanID string     `json:"subscribe_plan_id"`
+	StartDate       time.Time  `json:"start_date"`
+	EndDate         *time.Time `json:"end_date"`
+	Status          string     `json:"status"`
+	AutoRenew       bool       `json:"auto_renew"`
+
+	SubscribePlan subscribeplandm.SubscribePlan `gorm:"foreignKey:SubscribePlanID" json:"subscribe_plan"`
+}

internal/domain/subscribe_plan/spec.go

@@ -1,22 +1,12 @@
 package subscribeplandomain
 
-import "time"
-
-type SubscribePlan struct {
-	ID        string    `json:"id"`
-	Code      string    `json:"code"`
-	Name      string    `json:"name"`
-	CreatedAt time.Time `json:"created_at"`
-	UpdatedAt time.Time `json:"updated_at"`
-}
-
-type SubscribePlanUpdate struct {
-	Code      string    `json:"code" validate:"required"`
-	Name      string    `json:"name" validate:"required"`
-	UpdatedAt time.Time `json:"updated_at"`
-}
-
 type SubscribePlanReq struct {
 	Code string `json:"code" validate:"required"`
 	Name string `json:"name" validate:"required"`
 }
+
+type SubscribePlan struct {
+	ID   string `json:"id"`
+	Code string `json:"code"`
+	Name string `json:"name"`
+}

internal/domain/subscribe_plan_model/response.go

@@ -0,0 +1,8 @@
+package subscribeplandm
+
+// refactored
+type SubscribePlan struct {
+	ID   string `json:"id"`
+	Code string `json:"code"`
+	Name string `json:"name"`
+}

internal/domain/user/spec.go

@@ -1,9 +1,6 @@
 package userdomain
 
-import (
+import subscribedm "legalgo-BE-go/internal/domain/subscribe_model"
-	subscribe "legalgo-BE-go/internal/domain/subscribe"
-	"time"
-)
 
 type User struct {
 	ID          string `json:"id"`
@@ -12,7 +9,7 @@ type User struct {
 	Email       string `json:"email"`
 	Phone       string `json:"phone"`
 
-	Subscribe subscribe.Subscribe `gorm:"foreignKey:SubscribeID" json:"subscribe"`
+	Subscribe subscribedm.Subscribe `gorm:"foreignKey:SubscribeID" json:"subscribe"`
 }
 
 type UserRegister struct {
@@ -27,7 +24,7 @@ type UserProfile struct {
 	Email string `json:"email"`
 	Phone string `json:"phone"`
 
-	Subscribe subscribe.Subscribe `gorm:"foreignKey:SubscribeID" json:"subscribe"`
+	Subscribe subscribedm.Subscribe `gorm:"foreignKey:SubscribeID" json:"subscribe"`
 }
 
 type UserLogin struct {
@@ -36,10 +33,5 @@ type UserLogin struct {
 }
 
 type UserSubsUpdate struct {
-	ID              string     `json:"id"`
+	Status string `json:"status"`
-	Status          string     `json:"status"`
-	SubscribePlanID string     `json:"subscribe_plan_id"`
-	AutoRenew       bool       `json:"auto_renew"`
-	StartDate       time.Time  `json:"start_date"`
-	EndDate         *time.Time `json:"end_date"`
 }

internal/services/ads/create.go

@@ -1,56 +0,0 @@
-package adssvc
-
-import (
-	"context"
-	"fmt"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-	"path"
-
-	"github.com/google/uuid"
-)
-
-func (i *impl) Create(ctx context.Context, spec adsdomain.AdsReq) error {
-	id := uuid.NewString()
-
-	file := spec.Image.FileHeader
-	spec.Image.FileSize = file.Size
-	spec.Image.Ext = path.Ext(file.Filename)
-
-	if err := i.validate.Struct(spec); err != nil {
-		return err
-	}
-
-	// Open the file and read its content
-	srcFile, err := file.Open()
-	if err != nil {
-		return err
-	}
-	defer srcFile.Close()
-
-	fileContent := make([]byte, file.Size)
-	_, err = srcFile.Read(fileContent)
-	if err != nil {
-		return err
-	}
-
-	filePath := fmt.Sprintf("%v/%v%v", spec.Image.FolderName, id, spec.Image.Ext)
-	fileUrl, err := i.ossRepo.UploadFile(ctx, filePath, fileContent)
-	if err != nil {
-		return err
-	}
-
-	newSpec := adsdomain.Ads{
-		ID:       id,
-		ImageUrl: fileUrl,
-		Url:      spec.Url,
-	}
-
-	if err := i.adsRepo.Create(newSpec); err != nil {
-		if err := i.ossRepo.DeleteObject(ctx, id); err != nil {
-			return err
-		}
-		return err
-	}
-
-	return nil
-}

internal/services/ads/get_all.go

@@ -1,7 +0,0 @@
-package adssvc
-
-import adsdomain "legalgo-BE-go/internal/domain/ads"
-
-func (i *impl) GetAll() ([]adsdomain.Ads, error) {
-	return i.adsRepo.GetAll()
-}

internal/services/ads/impl.go

@@ -1,33 +0,0 @@
-package adssvc
-
-import (
-	"context"
-	adsrepository "legalgo-BE-go/internal/accessor/ads"
-	"legalgo-BE-go/internal/accessor/oss"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-
-	"github.com/go-playground/validator/v10"
-)
-
-type impl struct {
-	ossRepo  oss.OSSRepository
-	adsRepo  adsrepository.Ads
-	validate *validator.Validate
-}
-
-type Ads interface {
-	Create(context.Context, adsdomain.AdsReq) error
-	GetAll() ([]adsdomain.Ads, error)
-}
-
-func New(
-	ossRepo oss.OSSRepository,
-	adsRepo adsrepository.Ads,
-	validate *validator.Validate,
-) Ads {
-	return &impl{
-		ossRepo,
-		adsRepo,
-		validate,
-	}
-}

internal/services/auth/get_user.go

@@ -0,0 +1,14 @@
+package authsvc
+
+import (
+	userdomain "legalgo-BE-go/internal/domain/user"
+)
+
+func (as *impl) GetUserProfile(email string) (*userdomain.UserProfile, error) {
+	user, err := as.userRepo.GetUserProfile(email)
+	if err != nil {
+		return nil, err
+	}
+
+	return user, nil
+}

internal/services/auth/impl.go

@@ -3,7 +3,7 @@ package authsvc
 import (
 	staffrepository "legalgo-BE-go/internal/accessor/staff"
 	subscriberepository "legalgo-BE-go/internal/accessor/subscribe"
-	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribe_plan"
+	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribeplan"
 	userrepository "legalgo-BE-go/internal/accessor/user"
 	staffdomain "legalgo-BE-go/internal/domain/staff"
 	userdomain "legalgo-BE-go/internal/domain/user"
@@ -12,8 +12,8 @@ import (
 type impl struct {
 	staffRepo    staffrepository.Staff
 	userRepo     userrepository.User
-	subsRepo     subscriberepository.Subscribe
+	subsRepo     subscriberepository.SubsIntf
-	subsPlanRepo subscribeplanrepository.SubscribePlan
+	subsPlanRepo subscribeplanrepository.SubsPlanIntf
 }
 
 type Auth interface {
@@ -22,13 +22,17 @@ type Auth interface {
 	GetStaffProfile(string) (*staffdomain.StaffProfile, error)
 	GetUsers() ([]userdomain.UserProfile, error)
 	UpdateStaff(staffdomain.Staff) error
+
+	LoginAsUser(userdomain.UserLogin) (string, error)
+	RegisterUser(userdomain.UserRegister) (string, error)
+	GetUserProfile(string) (*userdomain.UserProfile, error)
 }
 
 func New(
 	staffRepo staffrepository.Staff,
 	userRepo userrepository.User,
-	subsRepo subscriberepository.Subscribe,
+	subsRepo subscriberepository.SubsIntf,
-	subsPlanRepo subscribeplanrepository.SubscribePlan,
+	subsPlanRepo subscribeplanrepository.SubsPlanIntf,
 ) Auth {
 	return &impl{
 		staffRepo:    staffRepo,

internal/services/auth/login_as_staff.go

@@ -16,7 +16,7 @@ func (sv *impl) LoginAsStaff(spec staffdomain.StaffLogin) (string, error) {
 		return "", errors.New(err.Error())
 	}
 
-	matchPassword := utils.ComparePassword(staff.Password, spec.Password)
+	matchPassword := ComparePassword(staff.Password, spec.Password)
 	if !matchPassword {
 		return "", errors.New("wrong password")
 	}

internal/services/auth/login_as_user.go

@@ -1,4 +1,4 @@
-package usersvc
+package authsvc
 
 import (
 	"errors"
@@ -10,13 +10,13 @@ import (
 	"github.com/google/uuid"
 )
 
-func (i *impl) LoginAsUser(spec userdomain.UserLogin) (string, error) {
+func (a *impl) LoginAsUser(spec userdomain.UserLogin) (string, error) {
-	user, err := i.userRepo.GetUserByEmail(spec.Email)
+	user, err := a.userRepo.GetUserByEmail(spec.Email)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}
 
-	matchPassword := utils.ComparePassword(user.Password, spec.Password)
+	matchPassword := ComparePassword(user.Password, spec.Password)
 	if !matchPassword {
 		return "", errors.New("wrong password")
 	}

internal/services/auth/register_staff.go

@@ -15,7 +15,7 @@ func (a *impl) RegisterStaff(spec staffdomain.StaffRegister) (string, error) {
 	if err == nil {
 		return "", errors.New("this email address is already in use")
 	}
-	hashedPwd, err := utils.HashPassword(spec.Password)
+	hashedPwd, err := HashPassword(spec.Password)
 	if err != nil {
 		return "", err
 	}

internal/services/auth/register_user.go

@@ -1,4 +1,4 @@
-package usersvc
+package authsvc
 
 import (
 	"errors"
@@ -10,15 +10,15 @@ import (
 	"github.com/google/uuid"
 )
 
-func (i *impl) RegisterUser(spec userdomain.UserRegister) (string, error) {
+func (a *impl) RegisterUser(spec userdomain.UserRegister) (string, error) {
-	_, err := i.userRepo.GetUserByEmail(spec.Email)
+	_, err := a.userRepo.GetUserByEmail(spec.Email)
 
 	if err == nil {
 		return "", errors.New("this email address is already in use")
 	}
 
 	if spec.SubscribePlanID == "" {
-		subsPlan, err := i.subsPlanRepo.GetDefault()
+		subsPlan, err := a.subsPlanRepo.GetDefault()
 		if err != nil {
 			return "", err
 		}
@@ -26,17 +26,17 @@ func (i *impl) RegisterUser(spec userdomain.UserRegister) (string, error) {
 		spec.SubscribePlanID = subsPlan.ID
 	}
 
-	_, err = i.subsPlanRepo.GetByID(spec.SubscribePlanID)
+	_, err = a.subsPlanRepo.GetByID(spec.SubscribePlanID)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}
 
-	subsId, err := i.subsRepo.Create(spec.SubscribePlanID)
+	subsId, err := a.subsRepo.Create(spec.SubscribePlanID)
 	if err != nil {
 		return "", err
 	}
 
-	hashedPwd, err := utils.HashPassword(spec.Password)
+	hashedPwd, err := HashPassword(spec.Password)
 	if err != nil {
 		return "", err
 	}
@@ -49,7 +49,7 @@ func (i *impl) RegisterUser(spec userdomain.UserRegister) (string, error) {
 		Phone:       spec.Phone,
 	}
 
-	err = i.userRepo.CreateUser(user)
+	err = a.userRepo.CreateUser(user)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}

internal/services/auth/utils.go

@@ -1,4 +1,4 @@
-package utils
+package authsvc
 
 import (
 	"fmt"

internal/services/module.go

@@ -1,7 +1,6 @@
 package services
 
 import (
-	adssvc "legalgo-BE-go/internal/services/ads"
 	serviceauth "legalgo-BE-go/internal/services/auth"
 	categorysvc "legalgo-BE-go/internal/services/category"
 	newssvc "legalgo-BE-go/internal/services/news"
@@ -9,7 +8,6 @@ import (
 	subscribesvc "legalgo-BE-go/internal/services/subscribe"
 	subscribeplansvc "legalgo-BE-go/internal/services/subscribe_plan"
 	tagsvc "legalgo-BE-go/internal/services/tag"
-	usersvc "legalgo-BE-go/internal/services/user"
 
 	"go.uber.org/fx"
 )
@@ -23,7 +21,5 @@ var Module = fx.Module("services",
 		categorysvc.New,
 		newssvc.New,
 		oss.NewOSSService,
-		usersvc.New,
-		adssvc.New,
 	),
 )

internal/services/subscribe/impl.go

@@ -6,14 +6,14 @@ import (
 )
 
 type impl struct {
-	subsRepo subscriberepository.Subscribe
+	subsRepo subscriberepository.SubsIntf
 }
 
 type Subscribe interface {
 	Create(string) (string, error)
-	Update(userdomain.UserSubsUpdate) error
+	Update(string, userdomain.UserSubsUpdate) error
 }
 
-func New(subsRepo subscriberepository.Subscribe) Subscribe {
+func New(subsRepo subscriberepository.SubsIntf) Subscribe {
 	return &impl{subsRepo}
 }

internal/services/subscribe/update.go

@@ -1,20 +1,9 @@
 package subscribesvc
 
 import (
-	subscribedomain "legalgo-BE-go/internal/domain/subscribe"
 	userdomain "legalgo-BE-go/internal/domain/user"
-	timeutils "legalgo-BE-go/internal/utilities/time_utils"
 )
 
-func (i *impl) Update(spec userdomain.UserSubsUpdate) error {
+func (i *impl) Update(id string, spec userdomain.UserSubsUpdate) error {
-	newSpec := subscribedomain.Subscribe{
+	return nil
-		ID:              spec.ID,
-		AutoRenew:       spec.AutoRenew,
-		StartDate:       timeutils.Now(),
-		EndDate:         spec.EndDate,
-		Status:          spec.Status,
-		SubscribePlanID: spec.SubscribePlanID,
-		UpdatedAt:       timeutils.Now(),
-	}
-	return i.subsRepo.Update(newSpec)
 }

internal/services/subscribe_plan/create.go

@@ -1,16 +0,0 @@
-package subscribeplansvc
-
-import (
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-
-	"github.com/google/uuid"
-)
-
-func (sb *impl) Create(spec subscribeplandomain.SubscribePlanReq) error {
-	data := subscribeplandomain.SubscribePlan{
-		ID:   uuid.NewString(),
-		Code: spec.Code,
-		Name: spec.Name,
-	}
-	return sb.subsRepo.Create(data)
-}

internal/services/subscribe_plan/create_plan.go

@@ -0,0 +1,7 @@
+package subscribeplansvc
+
+import subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
+
+func (sb *impl) CreatePlan(spec subscribeplandomain.SubscribePlanReq) error {
+	return sb.subsAccs.Create(spec)
+}

internal/services/subscribe_plan/delete.go

@@ -1,5 +0,0 @@
-package subscribeplansvc
-
-func (i *impl) Delete(id string) error {
-	return i.subsRepo.Delete(id)
-}

internal/services/subscribe_plan/get_all_plan.go

@@ -5,5 +5,5 @@ import (
 )
 
 func (s *impl) GetAllPlan() ([]subscribeplandomain.SubscribePlan, error) {
-	return s.subsRepo.GetAll()
+	return s.subsAccs.GetAll()
 }

internal/services/subscribe_plan/impl.go

@@ -1,23 +1,21 @@
 package subscribeplansvc
 
 import (
-	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribe_plan"
+	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribeplan"
 	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
 )
 
 type impl struct {
-	subsRepo subscribeplanrepository.SubscribePlan
+	subsAccs subscribeplanrepository.SubsPlanIntf
 }
 
 type SubscribePlan interface {
-	Create(subscribeplandomain.SubscribePlanReq) error
+	CreatePlan(subscribeplandomain.SubscribePlanReq) error
-	Update(string, subscribeplandomain.SubscribePlanUpdate) error
 	GetAllPlan() ([]subscribeplandomain.SubscribePlan, error)
-	Delete(string) error
 }
 
 func New(
-	subsAccs subscribeplanrepository.SubscribePlan,
+	subsAccs subscribeplanrepository.SubsPlanIntf,
 ) SubscribePlan {
 	return &impl{subsAccs}
 }

internal/services/subscribe_plan/update.go

@@ -1,16 +0,0 @@
-package subscribeplansvc
-
-import (
-	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
-	timeutils "legalgo-BE-go/internal/utilities/time_utils"
-)
-
-func (i *impl) Update(id string, spec subscribeplandomain.SubscribePlanUpdate) error {
-	newData := subscribeplandomain.SubscribePlan{
-		ID:        id,
-		Code:      spec.Code,
-		Name:      spec.Name,
-		UpdatedAt: timeutils.Now(),
-	}
-	return i.subsRepo.Update(newData)
-}

internal/services/tag/get_all_model.go

@@ -0,0 +1,9 @@
+package tagsvc
+
+import (
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+)
+
+func (i *impl) GetAllModel() ([]tagdomain.Tag, error) {
+	return i.tagRepo.GetAll()
+}

internal/services/tag/impl.go

@@ -12,6 +12,7 @@ type impl struct {
 type Tag interface {
 	Create(tagdomain.TagReq) error
 	GetAll() ([]tagdomain.Tag, error)
+	GetAllModel() ([]tagdomain.Tag, error)
 	Update(string, tagdomain.TagReq) error
 	Delete(string) error
 }

internal/services/user/get_user.go

@@ -1,14 +0,0 @@
-package usersvc
-
-import (
-	userdomain "legalgo-BE-go/internal/domain/user"
-)
-
-func (i *impl) GetUserProfile(email string) (*userdomain.UserProfile, error) {
-	user, err := i.userRepo.GetUserProfile(email)
-	if err != nil {
-		return nil, err
-	}
-
-	return user, nil
-}

internal/services/user/impl.go

@@ -1,32 +0,0 @@
-package usersvc
-
-import (
-	subscriberepository "legalgo-BE-go/internal/accessor/subscribe"
-	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribe_plan"
-	userrepository "legalgo-BE-go/internal/accessor/user"
-	userdomain "legalgo-BE-go/internal/domain/user"
-)
-
-type impl struct {
-	subsRepo     subscriberepository.Subscribe
-	userRepo     userrepository.User
-	subsPlanRepo subscribeplanrepository.SubscribePlan
-}
-
-type User interface {
-	GetUserProfile(string) (*userdomain.UserProfile, error)
-	LoginAsUser(userdomain.UserLogin) (string, error)
-	RegisterUser(userdomain.UserRegister) (string, error)
-}
-
-func New(
-	subsRepo subscriberepository.Subscribe,
-	userRepo userrepository.User,
-	subsPlanRepo subscribeplanrepository.SubscribePlan,
-) User {
-	return &impl{
-		subsRepo,
-		userRepo,
-		subsPlanRepo,
-	}
-}