feat: news router

internal/accessor/category/create_model.go

@@ -0,0 +1,22 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+	categorydomain "legalgo-BE-go/internal/domain/category"
+
+	"github.com/google/uuid"
+)
+
+func (a *accessor) CreateModel(spec categorydomain.CategoryReq) error {
+	data := database.CategoryModel{
+		ID:   uuid.NewString(),
+		Name: spec.Name,
+		Code: spec.Code,
+	}
+
+	if err := a.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/category/get_all_model.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) GetAllModel() ([]database.CategoryModel, error) {
+	var categories []database.CategoryModel
+
+	if err := a.DB.Find(&categories).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/get_bulk.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+)
+
+func (a *accessor) GetByIDs(ids []string) ([]categorydomain.Category, error) {
+	var categories []categorydomain.Category
+
+	if err := a.DB.Find(&categories, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/get_bulk_model.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) GetBulks(ids []string) ([]database.CategoryModel, error) {
+	var categories []database.CategoryModel
+
+	if err := a.DB.Find(&categories, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/impl.go

@@ -11,7 +11,13 @@ type accessor struct {
 
 type Category interface {
 	Create(categorydomain.CategoryReq) error
+	CreateModel(categorydomain.CategoryReq) error
+
 	GetAll() ([]categorydomain.Category, error)
+	GetAllModel() ([]database.CategoryModel, error)
+
+	GetByIDs([]string) ([]categorydomain.Category, error)
+	GetBulks([]string) ([]database.CategoryModel, error)
 }
 
 func New(

internal/accessor/module.go

@@ -2,6 +2,7 @@ package repository
 
 import (
 	categoryrepository "legalgo-BE-go/internal/accessor/category"
+	newsrepository "legalgo-BE-go/internal/accessor/news"
 	redisaccessor "legalgo-BE-go/internal/accessor/redis"
 	staffrepository "legalgo-BE-go/internal/accessor/staff"
 	subscriberepository "legalgo-BE-go/internal/accessor/subscribe"
@@ -20,4 +21,5 @@ var Module = fx.Module("repository", fx.Provide(
 	subscriberepository.New,
 	tagrepository.New,
 	categoryrepository.New,
+	newsrepository.New,
 ))

internal/accessor/news/create.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import (
+	"fmt"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+func (a *accessor) Create(spec *newsdomain.News) error {
+	if err := a.db.Create(&spec).Error; err != nil {
+		return fmt.Errorf("failed to create news: %w", err)
+	}
+	return nil
+}

internal/accessor/news/create_model.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import (
+	"fmt"
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) CreateModel(spec database.NewsModel) error {
+	if err := a.db.Create(&spec).Error; err != nil {
+		return fmt.Errorf("failed to create news: %w", err)
+	}
+	return nil
+}

internal/accessor/news/get_all.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import newsdomain "legalgo-BE-go/internal/domain/news"
+
+func (a *accessor) GetAll() ([]newsdomain.News, error) {
+	var news []newsdomain.News
+
+	if err := a.db.Preload("Tags").Preload("Categories").Find(&news).Error; err != nil {
+		return nil, err
+	}
+
+	return news, nil
+}

internal/accessor/news/get_all_model.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import "legalgo-BE-go/database"
+
+func (a *accessor) GetAllModel() ([]database.NewsModel, error) {
+	var news []database.NewsModel
+
+	if err := a.db.Preload("Tags").Preload("Categories").Find(&news).Error; err != nil {
+		return nil, err
+	}
+
+	return news, nil
+}

internal/accessor/news/impl.go

@@ -0,0 +1,21 @@
+package newsrepository
+
+import (
+	"legalgo-BE-go/database"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+type accessor struct {
+	db *database.DB
+}
+
+type News interface {
+	GetAll() ([]newsdomain.News, error)
+	GetAllModel() ([]database.NewsModel, error)
+	Create(*newsdomain.News) error
+	CreateModel(database.NewsModel) error
+}
+
+func New(db *database.DB) News {
+	return &accessor{db}
+}

internal/accessor/tag/create_model.go

@@ -0,0 +1,22 @@
+package tagrepository
+
+import (
+	"legalgo-BE-go/database"
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+
+	"github.com/google/uuid"
+)
+
+func (acc *accessor) CreateModel(spec tagdomain.TagReq) error {
+	data := &database.TagModel{
+		ID:   uuid.NewString(),
+		Code: spec.Code,
+		Name: spec.Name,
+	}
+
+	if err := acc.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/tag/get_all_model.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import "legalgo-BE-go/database"
+
+func (acc *accessor) GetAllModel() ([]database.TagModel, error) {
+	var tags []database.TagModel
+
+	if err := acc.DB.Find(&tags).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/get_bulk.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import tagdomain "legalgo-BE-go/internal/domain/tag"
+
+func (a *accessor) GetByIDs(ids []string) ([]tagdomain.Tag, error) {
+	var tags []tagdomain.Tag
+
+	if err := a.DB.Find(&tags, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/get_bulk_model.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import "legalgo-BE-go/database"
+
+func (a *accessor) GetBulks(ids []string) ([]database.TagModel, error) {
+	var tags []database.TagModel
+
+	if err := a.DB.Find(&tags, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/impl.go

@@ -11,7 +11,11 @@ type accessor struct {
 
 type TagAccessor interface {
 	Create(tagdomain.TagReq) error
+	CreateModel(tagdomain.TagReq) error
 	GetAll() ([]tagdomain.Tag, error)
+	GetAllModel() ([]database.TagModel, error)
+	GetByIDs([]string) ([]tagdomain.Tag, error)
+	GetBulks(ids []string) ([]database.TagModel, error)
 }
 
 func New(

internal/accessor/user_repository/get_user_by_email.go

@@ -15,7 +15,7 @@ func (ur *UserRepository) GetUserByEmail(email string) (*authdomain.User, error)
 		return nil, errors.New("email is empty")
 	}
 
-	if err := ur.DB.First(&user, "email = ?", email).Error; err != nil {
+	if err := ur.DB.Find(&user, "email = ?", email).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, errors.New("user not found")
 		}

internal/api/http/auth/profile.go

@@ -1,12 +1,10 @@
 package authhttp
 
 import (
-	"errors"
 	authsvc "legalgo-BE-go/internal/services/auth"
 	"legalgo-BE-go/internal/utilities/response"
 	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
-	"strings"
 
 	"github.com/go-chi/chi/v5"
 )
@@ -17,46 +15,7 @@ func GetStaffProfile(
 ) {
 	router.Get("/staff/profile", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-		authHeader := r.Header.Get("Authorization")
-
-		if authHeader == "" {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("provided auth is empty"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"required params is not provided",
-			)
-			return
-		}
-
-		if !strings.HasPrefix(authHeader, "Bearer") {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("invalid authorization token"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"invalid required token",
-			)
-			return
-		}
-
-		token := strings.Split(authHeader, " ")
-		if len(token) < 2 {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("invalid authorization"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"invalid required token",
-			)
-			return
-		}
-
-		destructedToken, err := utils.DestructToken(token[1])
+		destructedToken, err := utils.GetTokenDetail(r)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,
@@ -92,46 +51,7 @@ func GetUserProfile(
 ) {
 	router.Get("/user/profile", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-		authHeader := r.Header.Get("Authorization")
-
-		if authHeader == "" {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("provided auth is empty"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"required params is not provided",
-			)
-			return
-		}
-
-		if !strings.HasPrefix(authHeader, "Bearer") {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("invalid authorization token"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"invalid required token",
-			)
-			return
-		}
-
-		token := strings.Split(authHeader, " ")
-		if len(token) < 2 {
-			response.ResponseWithErrorCode(
-				ctx,
-				w,
-				errors.New("invalid authorization"),
-				response.ErrBadRequest.Code,
-				response.ErrBadRequest.HttpCode,
-				"invalid required token",
-			)
-			return
-		}
-
-		destructedToken, err := utils.DestructToken(token[1])
+		destructedToken, err := utils.GetTokenDetail(r)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,

internal/api/http/category/get_all.go

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

internal/api/http/news/create.go

@@ -0,0 +1,93 @@
+package newshttp
+
+import (
+	staffrepository "legalgo-BE-go/internal/accessor/staff"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	newssvc "legalgo-BE-go/internal/services/news"
+	"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 Create(
+	validate *validator.Validate,
+	newsSvc newssvc.News,
+	staffRepo staffrepository.StaffIntf,
+	router chi.Router,
+) {
+	router.Post("/news/create", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		var spec newsdomain.NewsReq
+
+		if err := utils.UnmarshalBody(r, &spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		if err := validate.Struct(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.(validator.ValidationErrors).Error(),
+			)
+			return
+		}
+
+		destructedToken, err := utils.GetTokenDetail(r)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		staffProfile, err := staffRepo.GetStaffByEmail(destructedToken.Email)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		if err := newsSvc.CreateModel(spec, staffProfile.ID); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, struct {
+			Message string
+		}{
+			Message: "news created successfully.",
+		})
+	})
+}

internal/api/http/news/get_all.go

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

internal/api/http/news/module.go

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

internal/api/http/router.go

@@ -3,6 +3,7 @@ package internalhttp
 import (
 	authhttp "legalgo-BE-go/internal/api/http/auth"
 	categoryhttp "legalgo-BE-go/internal/api/http/category"
+	newshttp "legalgo-BE-go/internal/api/http/news"
 	subscribeplanhttp "legalgo-BE-go/internal/api/http/subscribe_plan"
 	taghttp "legalgo-BE-go/internal/api/http/tag"
 
@@ -23,6 +24,7 @@ var Module = fx.Module("router",
 	subscribeplanhttp.Module,
 	taghttp.Module,
 	categoryhttp.Module,
+	newshttp.Module,
 )
 
 func initRouter() chi.Router {

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()
-		subsPlan, err := tagSvc.GetAll()
+		tags, err := tagSvc.GetAllModel()
+		// tags, err := tagSvc.GetAll()
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,
@@ -27,6 +28,6 @@ func GetAll(
 			return
 		}
 
-		response.RespondJsonSuccess(ctx, w, subsPlan)
+		response.RespondJsonSuccess(ctx, w, tags)
 	})
 }

internal/domain/category/spec.go

@@ -1,7 +1,7 @@
 package categorydomain
 
 type Category struct {
-	ID   string `json:"id"`
+	ID   string `json:"id" gorm:"primaryKey"`
 	Name string `json:"name"`
 	Code string `json:"code"`
 }

internal/domain/news/request.go

@@ -1,12 +0,0 @@
-package newsdomain
-
-type News struct {
-	Title         string   `json:"title"`
-	Content       string   `json:"content"`
-	FeaturedImage string   `json:"featured_image"`
-	Tags          []string `json:"tags"`
-	Categories    []string `json:"categories"`
-	IsPremium     bool     `json:"is_premium"`
-	Slug          string   `json:"slug"`
-	Author        string   `json:"author"`
-}

internal/domain/news/spec.go

@@ -0,0 +1,32 @@
+package newsdomain
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+	"time"
+)
+
+type NewsReq struct {
+	Title         string   `json:"title" validate:"required"`
+	Content       string   `json:"content"`
+	FeaturedImage string   `json:"featured_image"`
+	Tags          []string `json:"tags"`
+	Categories    []string `json:"categories"`
+	IsPremium     bool     `json:"is_premium"`
+	LiveAt        string   `json:"live_at" validate:"required"`
+}
+
+type News struct {
+	ID            string                    `json:"id"`
+	Title         string                    `json:"title"`
+	Content       string                    `json:"content"`
+	FeaturedImage string                    `json:"featured_image"`
+	Tags          []tagdomain.Tag           `json:"tags"`
+	Categories    []categorydomain.Category `json:"categories"`
+	IsPremium     bool                      `json:"is_premium"`
+	Slug          string                    `json:"slug"`
+	AuthorID      string                    `json:"author_id"`
+	LiveAt        time.Time                 `json:"live_at"`
+	CreatedAt     time.Time                 `json:"created_at"`
+	UpdatedAt     time.Time                 `json:"updated_at"`
+}

internal/domain/tag/spec.go

@@ -6,7 +6,7 @@ type TagReq struct {
 }
 
 type Tag struct {
-	ID   string `json:"id"`
+	ID   string `json:"id" gorm:"primaryKey"`
 	Code string `json:"code"`
 	Name string `json:"name"`
 }

internal/services/category/create.go

@@ -3,5 +3,6 @@ package categorysvc
 import categorydomain "legalgo-BE-go/internal/domain/category"
 
 func (i *impl) Create(spec categorydomain.CategoryReq) error {
-	return i.categoryRepo.Create(spec)
+	return i.categoryRepo.CreateModel(spec)
+	// return i.categoryRepo.Create(spec)
 }

internal/services/category/get_all_model.go

@@ -0,0 +1,9 @@
+package categorysvc
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (i *impl) GetAllModel() ([]database.CategoryModel, error) {
+	return i.categoryRepo.GetAllModel()
+}

internal/services/category/impl.go

@@ -1,6 +1,7 @@
 package categorysvc
 
 import (
+	"legalgo-BE-go/database"
 	categoryrepository "legalgo-BE-go/internal/accessor/category"
 	categorydomain "legalgo-BE-go/internal/domain/category"
 )
@@ -12,6 +13,7 @@ type impl struct {
 type Category interface {
 	Create(categorydomain.CategoryReq) error
 	GetAll() ([]categorydomain.Category, error)
+	GetAllModel() ([]database.CategoryModel, error)
 }
 
 func New(

internal/services/module.go

@@ -3,6 +3,7 @@ package services
 import (
 	serviceauth "legalgo-BE-go/internal/services/auth"
 	categorysvc "legalgo-BE-go/internal/services/category"
+	newssvc "legalgo-BE-go/internal/services/news"
 	subscribesvc "legalgo-BE-go/internal/services/subscribe"
 	subscribeplansvc "legalgo-BE-go/internal/services/subscribe_plan"
 	tagsvc "legalgo-BE-go/internal/services/tag"
@@ -17,5 +18,6 @@ var Module = fx.Module("services",
 		subscribesvc.New,
 		tagsvc.New,
 		categorysvc.New,
+		newssvc.New,
 	),
 )

internal/services/news/create.go

@@ -0,0 +1,47 @@
+package newssvc
+
+import (
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	"strings"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+func (i *impl) Create(spec newsdomain.NewsReq, staffId string) error {
+	slug := strings.ToLower(strings.ReplaceAll(spec.Title, " ", "-"))
+
+	tags, err := i.tagRepo.GetByIDs(spec.Tags)
+	if err != nil {
+		return err
+	}
+
+	categories, err := i.categoryRepo.GetByIDs(spec.Categories)
+	if err != nil {
+		return err
+	}
+
+	parsedTime, err := time.Parse(time.RFC3339, spec.LiveAt)
+	if err != nil {
+		return err
+	}
+
+	newSpec := &newsdomain.News{
+		ID:            uuid.NewString(),
+		Title:         spec.Title,
+		Content:       spec.Content,
+		FeaturedImage: spec.FeaturedImage,
+		IsPremium:     spec.IsPremium,
+		Slug:          slug,
+		LiveAt:        parsedTime,
+		AuthorID:      staffId,
+		Tags:          tags,
+		Categories:    categories,
+	}
+
+	if err := i.newsRepo.Create(newSpec); err != nil {
+		return err
+	}
+
+	return nil
+}

internal/services/news/create_model.go

@@ -0,0 +1,48 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	"strings"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+func (i *impl) CreateModel(spec newsdomain.NewsReq, staffId string) error {
+	slug := strings.ToLower(strings.ReplaceAll(spec.Title, " ", "-"))
+
+	tags, err := i.tagRepo.GetBulks(spec.Tags)
+	if err != nil {
+		return err
+	}
+
+	categories, err := i.categoryRepo.GetBulks(spec.Categories)
+	if err != nil {
+		return err
+	}
+
+	parsedTime, err := time.Parse(time.RFC3339, spec.LiveAt)
+	if err != nil {
+		return err
+	}
+
+	newSpec := database.NewsModel{
+		ID:            uuid.NewString(),
+		Title:         spec.Title,
+		Content:       spec.Content,
+		FeaturedImage: spec.FeaturedImage,
+		IsPremium:     spec.IsPremium,
+		Slug:          slug,
+		LiveAt:        parsedTime,
+		AuthorID:      staffId,
+		Tags:          tags,
+		Categories:    categories,
+	}
+
+	if err := i.newsRepo.CreateModel(newSpec); err != nil {
+		return err
+	}
+
+	return nil
+}

internal/services/news/get_all.go

@@ -0,0 +1,7 @@
+package newssvc
+
+import newsdomain "legalgo-BE-go/internal/domain/news"
+
+func (i *impl) GetAll() ([]newsdomain.News, error) {
+	return i.newsRepo.GetAll()
+}

internal/services/news/get_all_model.go

@@ -0,0 +1,9 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (i *impl) GetAllModel() ([]database.NewsModel, error) {
+	return i.newsRepo.GetAllModel()
+}

internal/services/news/impl.go

@@ -0,0 +1,34 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+	categoryrepository "legalgo-BE-go/internal/accessor/category"
+	newsrepository "legalgo-BE-go/internal/accessor/news"
+	tagrepository "legalgo-BE-go/internal/accessor/tag"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+type impl struct {
+	newsRepo     newsrepository.News
+	tagRepo      tagrepository.TagAccessor
+	categoryRepo categoryrepository.Category
+}
+
+type News interface {
+	GetAll() ([]newsdomain.News, error)
+	GetAllModel() ([]database.NewsModel, error)
+	Create(newsdomain.NewsReq, string) error
+	CreateModel(newsdomain.NewsReq, string) error
+}
+
+func New(
+	newsRepo newsrepository.News,
+	tagRepo tagrepository.TagAccessor,
+	categoryRepo categoryrepository.Category,
+) News {
+	return &impl{
+		newsRepo,
+		tagRepo,
+		categoryRepo,
+	}
+}

internal/services/tag/create.go

@@ -3,5 +3,6 @@ package tagsvc
 import tagdomain "legalgo-BE-go/internal/domain/tag"
 
 func (i *impl) Create(spec tagdomain.TagReq) error {
-	return i.tagRepo.Create(spec)
+	// return i.tagRepo.Create(spec)
+	return i.tagRepo.CreateModel(spec)
 }

internal/services/tag/get_all_model.go

@@ -0,0 +1,9 @@
+package tagsvc
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (i *impl) GetAllModel() ([]database.TagModel, error) {
+	return i.tagRepo.GetAllModel()
+}

internal/services/tag/impl.go

@@ -1,6 +1,7 @@
 package tagsvc
 
 import (
+	"legalgo-BE-go/database"
 	tagrepository "legalgo-BE-go/internal/accessor/tag"
 	tagdomain "legalgo-BE-go/internal/domain/tag"
 )
@@ -12,6 +13,7 @@ type impl struct {
 type TagIntf interface {
 	Create(tagdomain.TagReq) error
 	GetAll() ([]tagdomain.Tag, error)
+	GetAllModel() ([]database.TagModel, error)
 }
 
 func New(

internal/utilities/utils/get_token_detail.go

@@ -0,0 +1,34 @@
+package utils
+
+import (
+	"errors"
+	authdomain "legalgo-BE-go/internal/domain/auth"
+	"net/http"
+	"strings"
+)
+
+func GetTokenDetail(r *http.Request) (authdomain.AuthToken, error) {
+	authHeader := r.Header.Get("Authorization")
+
+	var data authdomain.AuthToken
+
+	if authHeader == "" {
+		return data, errors.New("unauthorized")
+	}
+
+	if !strings.HasPrefix(authHeader, "Bearer") {
+		return data, errors.New("invalid token")
+	}
+
+	token := strings.Split(authHeader, " ")
+	if len(token) < 2 {
+		return data, errors.New("invalid token")
+	}
+
+	data, err := DestructToken(token[1])
+	if err != nil {
+		return data, err
+	}
+
+	return data, nil
+}