From b836c344d49a8d3ad8f7d164bf0425b59df51384 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Mon, 16 Jan 2023 09:21:49 +0300
Subject: email: cleanup expired auth codes

---
 src/main/java/com/juick/service/EmailServiceImpl.java | 11 +++++++++++
 1 file changed, 11 insertions(+)

(limited to 'src/main/java/com/juick/service/EmailServiceImpl.java')

diff --git a/src/main/java/com/juick/service/EmailServiceImpl.java b/src/main/java/com/juick/service/EmailServiceImpl.java
index 977d9a75..7f358533 100644
--- a/src/main/java/com/juick/service/EmailServiceImpl.java
+++ b/src/main/java/com/juick/service/EmailServiceImpl.java
@@ -24,6 +24,10 @@ import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.sql.Types;
+import java.time.Instant;
+import java.time.ZoneOffset;
+import java.time.temporal.ChronoUnit;
 import java.util.List;
 
 /**
@@ -110,4 +114,11 @@ public class EmailServiceImpl extends BaseJdbcService implements EmailService {
         getJdbcTemplate().update("DELETE FROM auth WHERE authcode=?", code);
     }
 
+    @Override
+    public Integer cleanupAuthCodes() {
+        Instant day = Instant.now().minus(1, ChronoUnit.DAYS);
+        return getNamedParameterJdbcTemplate().update("DELETE FROM auth WHERE ts < :day",
+                new MapSqlParameterSource()
+                        .addValue("day", day.atOffset(ZoneOffset.UTC), Types.TIMESTAMP_WITH_TIMEZONE));
+    }
 }
-- 
cgit v1.2.3