Update epoch_notification_persistence.py

Aymanhki · Apr 9, 2024 · 66de6a6 · 66de6a6
1 parent b54d1f0
commit 66de6a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/epoch_backend/persistence/epoch/epoch_notification_persistence.py b/epoch_backend/persistence/epoch/epoch_notification_persistence.py
@@ -11,7 +11,7 @@ def get_user_notifications(self, user_id: int, limit: int, offset: int):
         conn = get_db_connection()
         curr = conn.cursor()
 
-        curr.execute("SELECT * FROM notifications WHERE user_id = %s ORDER BY created_at DESC LIMIT %s OFFSET %s", (user_id, limit, offset))
+        curr.execute("SELECT * FROM notifications WHERE user_id = %s AND created_at > now() ORDER BY created_at DESC LIMIT %s OFFSET %s", (user_id, limit, offset))
         notifs = curr.fetchall()
 
         for i in range(len(notifs)):