legalgonews/legalgo-BE-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: update and delete tags and categories

Browse Source
This commit is contained in:
ericprd
2025-03-05 23:13:24 +08:00
parent 5c699dfa53
commit 299fcf949b
22 changed files with 283 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/accessor/category/delete.go
+14
View File
@@ -0,0 +1,14 @@
package categoryrepository
import (
"fmt"
categorydomain "legalgo-BE-go/internal/domain/category"
)
func (a *accessor) Delete(id string) error {
if err := a.DB.Delete(&categorydomain.Category{}, "id = ?", id).Error; err != nil {
return fmt.Errorf("failed to delete category %s : %v", id, err)
}
return nil
}
internal/accessor/category/impl.go
+3 -3
View File
@@ -10,11 +10,11 @@ type accessor struct {
}
type Category interface {
CreateModel(categorydomain.CategoryReq) error
Update(categorydomain.Category) error
GetAllModel() ([]categorydomain.Category, error)
GetByIDs([]string) ([]categorydomain.Category, error)
CreateModel(categorydomain.CategoryReq) error
Update(categorydomain.Category) error
Delete(string) error
}
func New(
internal/accessor/category/update.go
+1 -1
View File
@@ -11,7 +11,7 @@ func (a *accessor) Update(spec categorydomain.Category) error {
if err := a.DB.Clauses(clause.OnConflict{
Columns: []clause.Column{{Name: "id"}},
DoUpdates: clause.AssignmentColumns([]string{"name", "code", "updated_at"}),
}).Save(&spec).Error; err != nil {
}).Select("name", "code", "updated_at").Save(&spec).Error; err != nil {
return fmt.Errorf("failed to update category: %v", err)
}
internal/accessor/tag/create_model.go
-22
View File
@@ -1,22 +0,0 @@
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.Tag{
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/delete.go
+14
View File
@@ -0,0 +1,14 @@
package tagrepository
import (
"fmt"
tagdomain "legalgo-BE-go/internal/domain/tag"
)
func (a *accessor) Delete(id string) error {
if err := a.DB.Delete(&tagdomain.Tag{}, "id = ?", id).Error; err != nil {
return fmt.Errorf("failed to delete category %s : %v", id, err)
}
return nil
}
internal/accessor/tag/get_bulk.go → internal/accessor/tag/get_by_ids.go
View File
internal/accessor/tag/impl.go
+2 -1
View File
@@ -11,9 +11,10 @@ type accessor struct {
type TagAccessor interface {
Create(tagdomain.TagReq) error
CreateModel(tagdomain.TagReq) error
GetAll() ([]tagdomain.Tag, error)
GetByIDs([]string) ([]tagdomain.Tag, error)
Update(tagdomain.Tag) error
Delete(string) error
}
func New(
internal/accessor/tag/update.go
+23
View File
@@ -0,0 +1,23 @@
package tagrepository
import (
"fmt"
tagdomain "legalgo-BE-go/internal/domain/tag"
"gorm.io/gorm/clause"
)
func (a *accessor) Update(spec tagdomain.Tag) 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/api/http/category/delete.go
+53
View File
@@ -0,0 +1,53 @@
package categoryhttp
import (
"fmt"
authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
categorysvc "legalgo-BE-go/internal/services/category"
"legalgo-BE-go/internal/utilities/response"
"net/http"
"github.com/go-chi/chi/v5"
)
func Delete(
router chi.Router,
categorySvc categorysvc.Category,
) {
router.
With(authmiddleware.Authorize()).
Delete("/category/{category_id}/delete", func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
categoryID := chi.URLParam(r, "category_id")
if categoryID == "" {
response.RespondJsonErrorWithCode(
ctx,
w,
fmt.Errorf("category id is not provided"),
response.ErrBadRequest.Code,
response.ErrBadRequest.HttpCode,
"category id is not provided",
)
return
}
if err := categorySvc.Delete(categoryID); err != nil {
response.RespondJsonErrorWithCode(
ctx,
w,
err,
response.ErrBadRequest.Code,
response.ErrBadRequest.HttpCode,
err.Error(),
)
return
}
response.RespondJsonSuccess(ctx, w, struct {
Message string
}{
Message: "category has been deleted",
})
})
}
internal/api/http/category/module.go
+1
View File
@@ -6,4 +6,5 @@ var Module = fx.Module("categories", fx.Invoke(
Create,
GetAll,
Update,
Delete,
))
internal/api/http/tag/delete.go
+53
View File
@@ -0,0 +1,53 @@
package taghttp
import (
"fmt"
authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
tagsvc "legalgo-BE-go/internal/services/tag"
"legalgo-BE-go/internal/utilities/response"
"net/http"
"github.com/go-chi/chi/v5"
)
func Delete(
router chi.Router,
tagSvc tagsvc.Tag,
) {
router.
With(authmiddleware.Authorize()).
Delete("/tag/{category_id}/delete", func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
categoryID := chi.URLParam(r, "category_id")
if categoryID == "" {
response.RespondJsonErrorWithCode(
ctx,
w,
fmt.Errorf("category id is not provided"),
response.ErrBadRequest.Code,
response.ErrBadRequest.HttpCode,
"category id is not provided",
)
return
}
if err := tagSvc.Delete(categoryID); err != nil {
response.RespondJsonErrorWithCode(
ctx,
w,
err,
response.ErrBadRequest.Code,
response.ErrBadRequest.HttpCode,
err.Error(),
)
return
}
response.RespondJsonSuccess(ctx, w, struct {
Message string
}{
Message: "tag has been deleted",
})
})
}
internal/api/http/tag/module.go
+2
View File
@@ -5,4 +5,6 @@ import "go.uber.org/fx"
var Module = fx.Module("tag", fx.Invoke(
Create,
GetAll,
Update,
Delete,
))
internal/api/http/tag/update.go
+82
View File
@@ -0,0 +1,82 @@
package taghttp
import (
"fmt"
authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
tagdomain "legalgo-BE-go/internal/domain/tag"
tagsvc "legalgo-BE-go/internal/services/tag"
"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,
tagSvc tagsvc.Tag,
) {
router.
With(authmiddleware.Authorize()).
Put("/tag/{tag_id}/update", func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
tagID := chi.URLParam(r, "tag_id")
if tagID == "" {
response.RespondJsonErrorWithCode(
ctx,
w,
fmt.Errorf("tag id is not provided"),
response.ErrBadRequest.Code,
response.ErrBadRequest.HttpCode,
"tag id is not provided",
)
return
}
var spec tagdomain.TagReq
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 := tagSvc.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 tag success",
})
})
}
internal/services/category/delete.go
+5
View File
@@ -0,0 +1,5 @@
package categorysvc
func (i *impl) Delete(id string) error {
return i.categoryRepo.Delete(id)
}
internal/services/category/impl.go
+1
View File
@@ -13,6 +13,7 @@ type Category interface {
Create(categorydomain.CategoryReq) error
GetAll() ([]categorydomain.Category, error)
Update(string, categorydomain.CategoryReq) error
Delete(string) error
}
func New(
internal/services/tag/create.go
+1 -1
View File
@@ -4,5 +4,5 @@ import tagdomain "legalgo-BE-go/internal/domain/tag"
func (i *impl) Create(spec tagdomain.TagReq) error {
// return i.tagRepo.Create(spec)
return i.tagRepo.CreateModel(spec)
return i.tagRepo.Create(spec)
}
internal/services/tag/delete.go
+5
View File
@@ -0,0 +1,5 @@
package tagsvc
func (i *impl) Delete(id string) error {
return i.tagRepo.Delete(id)
}
internal/services/tag/impl.go
+2
View File
@@ -13,6 +13,8 @@ type Tag interface {
Create(tagdomain.TagReq) error
GetAll() ([]tagdomain.Tag, error)
GetAllModel() ([]tagdomain.Tag, error)
Update(string, tagdomain.TagReq) error
Delete(string) error
}
func New(
internal/services/tag/update.go
+16
View File
@@ -0,0 +1,16 @@
package tagsvc
import (
tagdomain "legalgo-BE-go/internal/domain/tag"
timeutils "legalgo-BE-go/internal/utilities/time_utils"
)
func (i *impl) Update(id string, spec tagdomain.TagReq) error {
newData := tagdomain.Tag{
ID: id,
Code: spec.Code,
Name: spec.Name,
UpdatedAt: timeutils.Now(),
}
return i.tagRepo.Update(newData)
}