Q: Half implemented queue cleanup

GothenburgBitFactory · May 13, 2018 · 57ba5f3 · 57ba5f3
1 parent 8c6c907
commit 57ba5f3
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 0 deletions.
diff --git a/src/Q.cpp b/src/Q.cpp
@@ -26,6 +26,7 @@
 
 #include <cmake.h>
 #include <Q.h>
+#include <Datetime.h>
 #include <shared.h>
 #include <sstream>
 #include <iomanip>
@@ -201,3 +202,28 @@ std::vector <std::string> Q::events (const std::string& path) const
 }
 
 ////////////////////////////////////////////////////////////////////////////////
+// Scans the queue for events to remove.
+int Q::cleanup () const
+{
+  // Count the removals.
+  int count = 0;
+
+  // Calculate epoch 30 days ago.
+  Datetime now;
+  now -= 30 * 86400;
+  auto one_month_ago = now.toEpoch ();
+
+  for (const auto& entry : archive ())
+  {
+    File item (entry);
+    if (item.mtime () < one_month_ago)
+    {
+      //item.remove ();
+      ++count;
+    }
+  }
+
+  return count;
+}
+
+////////////////////////////////////////////////////////////////////////////////
diff --git a/src/Q.h b/src/Q.h
@@ -41,6 +41,7 @@ class Q
   bool destroy (bool force = false);
   bool scan (std::string&);
   void post (const std::string&) const;
+  int cleanup () const;
 
   std::string activateEvent (const std::string&) const;
   void archiveEvent (const std::string&) const;