Skip to content

Commit 7f29501

Browse files
KocannnKocannn
committed
feat(blog): add soft delete and created_at fields
Introduce `is_deleted` and `created_at` columns to the `blog_posts` table with a migration. Refactor repository and usecase logic to support soft deletes by updating `is_deleted` instead of hard deleting records. Update domain model and API DTOs to use pointer types for `PublishedAt`, `UpdatedAt`, and new `CreatedAt` fields. Adjust create and update flows to handle these changes and ensure soft-deleted posts are excluded from queries.
1 parent fb03bc0 commit 7f29501

File tree

5 files changed

+93
-60
lines changed

5 files changed

+93
-60
lines changed

‎app/blog_post/delivery/http/http.go‎

Lines changed: 18 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ func (h Handler) CreateBlogPost(w http.ResponseWriter, r *http.Request) {
4444
return
4545
}
4646

47-
data, err := h.usecase.CreateBlogPost(r.Context(), BlogPost, token)
47+
err = h.usecase.CreateBlogPost(r.Context(), BlogPost, token)
4848
if err != nil {
4949
resp := utils.CustomErrorResponse(err)
5050
utils.Response(resp, w)
@@ -54,7 +54,6 @@ func (h Handler) CreateBlogPost(w http.ResponseWriter, r *http.Request) {
5454
utils.Response(domain.HttpResponse{
5555
Code: http.StatusCreated,
5656
Message: "Blog post created successfully",
57-
Data: data,
5857
}, w)
5958

6059
}
@@ -118,12 +117,13 @@ func (h Handler) GetAllBlogPosts(w http.ResponseWriter, r *http.Request) {
118117
Excerpt string `json:"excerpt"`
119118
Author domain.Author `json:"author" gorm:"foreignKey:AuthorID;references:UserId"`
120119
AuthorID int `json:"author_id" gorm:"column:author_id"`
121-
PublishedAt time.Time `json:"published_at"`
122-
UpdatedAt time.Time `json:"updated_at"`
123120
Tags []string `json:"tags" gorm:"-"`
124121
Category string `json:"category"`
125122
Status string `json:"status" gorm:"type:enum('draft', 'published', 'archived')"`
126123
Slug string `json:"slug"`
124+
PublishedAt *time.Time `json:"published_at"`
125+
UpdatedAt *time.Time `json:"updated_at"`
126+
CreatedAt *time.Time `json:"created_at"`
127127
}
128128

129129
responseDTO := []response{}
@@ -134,12 +134,13 @@ func (h Handler) GetAllBlogPosts(w http.ResponseWriter, r *http.Request) {
134134
Excerpt: post.Excerpt,
135135
Author: post.Author,
136136
AuthorID: post.AuthorID,
137-
PublishedAt: post.PublishedAt,
138-
UpdatedAt: post.PublishedAt,
139137
Tags: post.Tags,
140138
Category: post.Category,
141139
Status: post.Status,
142140
Slug: post.Slug,
141+
PublishedAt: post.PublishedAt,
142+
UpdatedAt: post.UpdatedAt,
143+
CreatedAt: post.CreatedAt,
143144
}
144145
responseDTO = append(responseDTO, resp)
145146
}
@@ -236,6 +237,15 @@ func (h Handler) UpdateBlogPost(w http.ResponseWriter, r *http.Request) {
236237
if status, ok := patchData["status"].(string); ok {
237238
updatedPost.Status = status
238239
}
240+
if patchData["status"] == "published" {
241+
if updatedPost.PublishedAt == nil {
242+
timeNow := time.Now()
243+
updatedPost.PublishedAt = &timeNow
244+
}
245+
} else {
246+
updatedPost.PublishedAt = nil
247+
}
248+
239249
if tags, ok := patchData["tags"].([]interface{}); ok {
240250
updatedPost.Tags = make([]string, len(tags))
241251
for i, tag := range tags {
@@ -249,7 +259,8 @@ func (h Handler) UpdateBlogPost(w http.ResponseWriter, r *http.Request) {
249259
}
250260
}
251261

252-
updatedPost.UpdatedAt = time.Now()
262+
timeNow := time.Now()
263+
updatedPost.UpdatedAt = &timeNow
253264

254265
err = h.usecase.UpdateBlogPost(r.Context(), updatedPost, uint(id))
255266
if err != nil {
@@ -264,7 +275,6 @@ func (h Handler) UpdateBlogPost(w http.ResponseWriter, r *http.Request) {
264275
utils.Response(domain.HttpResponse{
265276
Code: http.StatusOK,
266277
Message: "Blog post updated successfully",
267-
Data: updatedPost,
268278
}, w)
269279
}
270280

‎app/blog_post/repository/repository.go‎

Lines changed: 29 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -15,23 +15,22 @@ type repository struct {
1515

1616
// GetDetailBlogPost implements domain.BlogPostRepository.
1717
func (r *repository) GetDetailBlogPost(ctx context.Context, slug, typeFind string, id uint) (data domain.BlogPost, err error) {
18-
db := r.db.DB(ctx).Preload("Author").Model(&domain.BlogPost{})
18+
db := r.db.DB(ctx).Preload("Author").Model(&domain.BlogPost{}).Where("is_deleted = ?", false)
1919

20-
if typeFind == "slug" {
21-
err = db.First(&data, "slug = ?", slug).
22-
Error
20+
switch typeFind {
21+
case "slug":
22+
err = db.First(&data, "slug = ?", slug).Error
2323
if err != nil {
2424
logrus.Error("failed to get blog post detail: ", err)
2525
return data, err
2626
}
27-
} else if typeFind == "id" {
28-
err = db.First(&data, "id = ?", id).
29-
Error
27+
case "id":
28+
err = db.First(&data, "id = ?", id).Error
3029
if err != nil {
3130
logrus.Error("failed to get blog post detail: ", err)
3231
return data, err
3332
}
34-
} else {
33+
default:
3534
return domain.BlogPost{}, errors.New("invalid typeFind parameter, must be 'slug' or 'id'")
3635
}
3736

@@ -106,12 +105,9 @@ func (r *repository) UpdateBlogPost(ctx context.Context, data domain.BlogPost, i
106105
}
107106

108107
// CreateBlogPost implements domain.BlogPostRepository.
109-
func (r *repository) CreateBlogPost(ctx context.Context, data domain.BlogPost) (domain.BlogPost, error) {
110-
var result domain.BlogPost
111-
var err error
112-
108+
func (r *repository) CreateBlogPost(ctx context.Context, data domain.BlogPost) error {
113109
// Menggunakan StartTransaction yang sudah ada
114-
err = r.db.StartTransaction(ctx, func(txCtx context.Context) error {
110+
err := r.db.StartTransaction(ctx, func(txCtx context.Context) error {
115111
// 1. Periksa/Buat Author jika belum ada
116112
var authorExists int64
117113
if err := r.db.DB(txCtx).Model(&domain.Author{}).
@@ -130,18 +126,16 @@ func (r *repository) CreateBlogPost(ctx context.Context, data domain.BlogPost) (
130126
}
131127
}
132128

129+
data.UpdatedAt = nil
133130
// Set AuthorID untuk relasi
134131
data.AuthorID = data.Author.UserId
135132

136133
// 2. Insert Blog Post
137-
if err := r.db.DB(txCtx).Create(&data).Error; err != nil {
134+
if err := r.db.DB(txCtx).Omit("updated_at").Create(&data).Error; err != nil {
138135
logrus.Error("failed to create blog post: ", err)
139136
return err
140137
}
141138

142-
// Update result dengan data yang sudah memiliki ID
143-
result = data
144-
145139
// 3. Insert Tags jika ada
146140
if len(data.Tags) > 0 {
147141
for _, tag := range data.Tags {
@@ -164,19 +158,29 @@ func (r *repository) CreateBlogPost(ctx context.Context, data domain.BlogPost) (
164158
})
165159

166160
if err != nil {
167-
return domain.BlogPost{}, err
161+
return err
168162
}
169163

170-
return result, nil
164+
return nil
171165
}
172166

173167
// DeleteBlogPost implements domain.BlogPostRepository.
174168
func (r *repository) DeleteBlogPost(ctx context.Context, id uint) error {
175169
db := r.db.DB(ctx).Model(&domain.BlogPost{})
176-
err := db.Delete(&domain.BlogPost{}, "id = ?", id).Error
177-
if err != nil {
178-
logrus.Error("failed to delete blog post: ", err)
179-
return err
170+
171+
// Perform soft delete by updating is_deleted field
172+
result := db.Where("id = ?", id).Updates(map[string]interface{}{
173+
"is_deleted": true,
174+
})
175+
176+
if result.Error != nil {
177+
logrus.Error("failed to soft delete blog post: ", result.Error)
178+
return result.Error
179+
}
180+
181+
if result.RowsAffected == 0 {
182+
logrus.Warn("no blog post found to delete with id: ", id)
183+
return errors.New("blog post not found")
180184
}
181185
return nil
182186
}
@@ -186,7 +190,7 @@ func (r *repository) GetAllBlogPosts(ctx context.Context, pagination domain.Filt
186190
var data []domain.BlogPost
187191
var totalCount int64
188192

189-
if err := r.db.DB(ctx).Model(&domain.BlogPost{}).Count(&totalCount).Error; err != nil {
193+
if err := r.db.DB(ctx).Model(&domain.BlogPost{}).Where("is_deleted = ?", false).Count(&totalCount).Error; err != nil {
190194
logrus.Error("failed to count blog posts: ", err)
191195
return nil, 0, err
192196
}
@@ -195,7 +199,7 @@ func (r *repository) GetAllBlogPosts(ctx context.Context, pagination domain.Filt
195199
limit := pagination.GetLimit()
196200
orderBy := pagination.GetOrderBy()
197201

198-
query := r.db.DB(ctx).Preload("Author")
202+
query := r.db.DB(ctx).Preload("Author").Where("is_deleted = ?", false)
199203

200204
if orderBy != "" {
201205
query = query.Order(orderBy)

‎app/blog_post/usecase/usecase.go‎

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
11
package usecase
22

33
import (
4-
"crypto/rand"
5-
"encoding/hex"
4+
"time"
65

76
"github.com/hammer-code/lms-be/domain"
87
"github.com/hammer-code/lms-be/pkg/jwt"
@@ -16,31 +15,33 @@ type usecase struct {
1615
}
1716

1817
// CreateBlogPost implements domain.BlogPostUsecase.
19-
func (uc *usecase) CreateBlogPost(ctx context.Context, data domain.BlogPost, token string) (domain.BlogPost, error) {
18+
func (uc *usecase) CreateBlogPost(ctx context.Context, data domain.BlogPost, token string) error {
2019

2120
jwtData, err := uc.jwt.VerifyToken(token)
2221
if err != nil {
2322
logrus.Error("failed to verify token: ", err)
24-
return domain.BlogPost{}, err
25-
}
26-
27-
slugBytes := make([]byte, 32)
28-
if _, err := rand.Read(slugBytes); err != nil {
29-
return domain.BlogPost{}, err
23+
return err
3024
}
3125

3226
data.Author.UserId = jwtData.ID
3327
data.Author.Name = jwtData.UserName
34-
data.Slug = hex.EncodeToString(slugBytes)
28+
data.UpdatedAt = nil
3529

36-
blogPost, err := uc.repo.CreateBlogPost(ctx, data)
30+
if data.Status == "published" {
31+
timeNow := time.Now()
32+
data.PublishedAt = &timeNow
33+
} else {
34+
data.PublishedAt = nil
35+
}
36+
37+
err = uc.repo.CreateBlogPost(ctx, data)
3738
if err != nil {
3839
logrus.Error("failed to create blog post: ", err)
39-
return domain.BlogPost{}, err
40+
return err
4041

4142
}
4243

43-
return blogPost, nil
44+
return nil
4445

4546
}
4647

‎database/migration/20250709055337_table_add_column_created_at_and_isdeleted.sql‎

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
-- +goose Up
2+
-- +goose StatementBegin
3+
SELECT 'up SQL query';
4+
5+
ALTER TABLE blog_posts
6+
ADD COLUMN created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
7+
ADD COLUMN is_deleted BOOLEAN DEFAULT FALSE;
8+
9+
10+
11+
-- +goose StatementEnd
12+
13+
-- +goose Down
14+
-- +goose StatementBegin
15+
DROP TABLE IF EXISTS blog_posts CASCADE;
16+
-- +goose StatementEnd

‎domain/blog_post.go‎

Lines changed: 16 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -16,34 +16,36 @@ type BlogPostHandler interface {
1616
}
1717

1818
type BlogPostUsecase interface {
19-
CreateBlogPost(ctx context.Context, data BlogPost, token string) (BlogPost, error)
19+
CreateBlogPost(ctx context.Context, data BlogPost, token string) error
2020
UpdateBlogPost(ctx context.Context, data BlogPost, id uint) error
2121
DeleteBlogPost(ctx context.Context, id uint) error
2222
GetAllBlogPosts(ctx context.Context, pagination FilterPagination) ([]BlogPost, Pagination, error)
2323
GetDetailBlogPost(ctx context.Context, slug string, id uint) (BlogPost, error)
2424
}
2525

2626
type BlogPostRepository interface {
27-
CreateBlogPost(ctx context.Context, data BlogPost) (BlogPost, error)
27+
CreateBlogPost(ctx context.Context, data BlogPost) error
2828
UpdateBlogPost(ctx context.Context, data BlogPost, id uint) error
2929
DeleteBlogPost(ctx context.Context, id uint) error
3030
GetAllBlogPosts(ctx context.Context, pagination FilterPagination) ([]BlogPost, int, error)
3131
GetDetailBlogPost(ctx context.Context, slug, typeFind string, id uint) (BlogPost, error)
3232
}
3333

3434
type BlogPost struct {
35-
Id int `json:"id" gorm:"primaryKey"`
36-
Title string `json:"title"`
37-
Content string `json:"content"`
38-
Excerpt string `json:"excerpt"`
39-
Author Author `json:"author" gorm:"foreignKey:AuthorID;references:UserId"`
40-
AuthorID int `json:"author_id" gorm:"column:author_id"`
41-
PublishedAt time.Time `json:"published_at"`
42-
UpdatedAt time.Time `json:"updated_at"`
43-
Tags []string `json:"tags" gorm:"-"`
44-
Category string `json:"category"`
45-
Status string `json:"status" gorm:"type:enum('draft', 'published', 'archived')"`
46-
Slug string `json:"slug"`
35+
Id int `json:"id" gorm:"primaryKey"`
36+
Title string `json:"title"`
37+
Content string `json:"content"`
38+
Excerpt string `json:"excerpt"`
39+
Author Author `json:"author" gorm:"foreignKey:AuthorID;references:UserId"`
40+
AuthorID int `json:"author_id" gorm:"column:author_id"`
41+
Tags []string `json:"tags" gorm:"-"`
42+
Category string `json:"category"`
43+
Status string `json:"status" gorm:"type:enum('draft', 'published', 'archived')"`
44+
Slug string `json:"slug"`
45+
PublishedAt *time.Time `json:"published_at"`
46+
UpdatedAt *time.Time `json:"updated_at"`
47+
CreatedAt *time.Time `json:"created_at"`
48+
IsDeleted bool `json:"-"`
4749
}
4850

4951
type Author struct {

0 commit comments

Comments
 (0)