Added function to purge stale cache documents

2025-12-11 14:42:18 +00:00 · 2011-09-06 17:37:18 +01:00
parent e01fd630ba
commit 267b9153a3
1 changed files with 9 additions and 0 deletions
--- a/apishiv/cache.py
+++ b/apishiv/cache.py
@@ -75,3 +75,12 @@ class DbCacheHandler:
            self.disconnect()
        except sqlite3.Error as e:
            self.log.error("Error storing document: %s", e.args[0])
+
+    def purge_stale(self):
+        self.log.info("Purging stale cached documents")
+        try:
+            self.cursor.execute("DELETE FROM api_cache WHERE datetime(cacheduntil, 'unixepoch') >= current_timestamp")
+            self.conn.commit()
+            self.disconnect()
+        except sqlite3.Error as e:
+            self.log.error("Error purging document cache: %s", e.args[0])