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 get oldest updated at thread

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

23
repositories/posts_repository.go
View File

@ -207,3 +207,26 @@ func (r *PostsRepository) CreateInTx(tx pgx.Tx, p Post) (int, error) {
return createdPost.ID, nil
}
func (r *PostsRepository) GetOldestThreadUpdateAt() (time.Time, error) {
sql := `
SELECT updated_at
FROM posts
WHERE
is_parent = true
AND is_deleted != true
AND is_archived != true
ORDER BY updated_at DESC
OFFSET $1 - 1
LIMIT 1
`
row := Db.Pool.QueryRow(context.TODO(), sql, Config.App.ThreadsMaxCount)
var updatedAt time.Time
err := row.Scan(&updatedAt)
if err != nil {
return time.Time{}, err
}
return updatedAt, nil
}