From e9808b4fb39de51d7a53c5794d434b3841318379 Mon Sep 17 00:00:00 2001
From: Yanislav Igonin <yanislavdabest@gmail.com>
Date: Sat, 20 Nov 2021 18:20:42 +0200
Subject: [PATCH] feat: add get oldest updated at thread

---
 repositories/posts_repository.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/repositories/posts_repository.go b/repositories/posts_repository.go
index 6574b85..5d3786f 100644
--- a/repositories/posts_repository.go
+++ b/repositories/posts_repository.go
@@ -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
+}
+