Dependencies/micrach
1
0
Fork 1
mirror of https://github.com/yanislav-igonin/micrach synced 2025-07-01 17:01:14 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add archivation method for oldest threads

Browse Source
This commit is contained in:
Yanislav Igonin 2021-11-20 18:21:17 +02:00
parent e9808b4fb3
commit 52e3f9ae90
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
repositories/posts_repository.go
View File

@ -230,3 +230,17 @@ func (r *PostsRepository) GetOldestThreadUpdateAt() (time.Time, error) {
return updatedAt, nil
}
func (r *PostsRepository) ArchiveThreadsFrom(t time.Time) error {
sql := `
UPDATE posts
SET is_archived = true
WHERE
is_parent = true
AND is_deleted != true
AND is_archived != true
AND updated_at > $1
`
_, err := Db.Pool.Exec(context.TODO(), sql, t)
return err
}