From 52e3f9ae908e854f9086e975dc78e0ff672e9bdd Mon Sep 17 00:00:00 2001
From: Yanislav Igonin <yanislavdabest@gmail.com>
Date: Sat, 20 Nov 2021 18:21:17 +0200
Subject: [PATCH] feat: add archivation method for oldest threads

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

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