From a65d2d52def511a16fa3813d98c95b17c0b89ee1 Mon Sep 17 00:00:00 2001
From: Mashintime <awh@brainless.us>
Date: Wed, 14 Jun 2023 18:03:10 -0400
Subject: [PATCH] Clean old beacons and compact DB.

---
 gui/preload-chat.js      | 46 +++++++++++++++++++++++++++++++++++++---
 gui/src/chat-module.html | 11 +++++++---
 2 files changed, 51 insertions(+), 6 deletions(-)

diff --git a/gui/preload-chat.js b/gui/preload-chat.js
index 7506fbbf..deaf3568 100644
--- a/gui/preload-chat.js
+++ b/gui/preload-chat.js
@@ -165,7 +165,9 @@ window.addEventListener("DOMContentLoaded", () => {
     "user_info_website",
     "user_info_comments",
   ];
-
+  document.getElementById("btndbClean").addEventListener("click", () => {
+    dbClean();
+  });
   users
     .find({
       selector: {
@@ -819,7 +821,7 @@ ipcRenderer.on("action-new-msg-received", (event, arg) => {
       add_obj_to_database(obj);
       update_chat_obj_by_uuid(obj.uuid);
 
-      // handle beacon
+      // handle ping-ack
     } else if (item.ping == "acknowledge") {
       obj.timestamp = parseInt(item.timestamp);
       obj.dxcallsign = item.dxcallsign;
@@ -2847,4 +2849,42 @@ function showOsPopUp(title, message)
   const NOTIFICATION_TITLE = title;
   const NOTIFICATION_BODY = message;
   new Notification(NOTIFICATION_TITLE, { body: NOTIFICATION_BODY });
-}
\ No newline at end of file
+}
+
+//Function to clean old beacons and optimize database
+async function dbClean()
+{
+  //Only keep the most x latest days of beacons
+  let beaconKeep = 7;
+  let timestampPurge =  Math.floor((Date.now()- beaconKeep * 24*60*60*1000) / 1000) ;
+  if (confirm("Delete beacons older than " + beaconKeep + " days and compact database?")) {
+  } else {
+    return;
+  }
+  
+  await db.find({
+    selector: {
+      timestamp: {$lt: timestampPurge},
+      type: "beacon",
+    }
+  })
+    .then(async function (result) {
+      console.log("Purging " + result.docs.length + " beacons received before " + timestampPurge);
+      result.docs.forEach(async function (item) {
+          await db.get(item._id)
+          .then(async function (doc) {
+            await db.remove(doc)
+          })
+          .catch(function (err) {
+            console.log(err);
+          });
+        });
+    })
+    .catch(function (err) {
+      console.log(err);
+    });
+
+    //Compact database
+    await db.compact();
+    window.alert("Database maintenance is complete.");
+}
diff --git a/gui/src/chat-module.html b/gui/src/chat-module.html
index 3447b6e6..e2d8ba57 100644
--- a/gui/src/chat-module.html
+++ b/gui/src/chat-module.html
@@ -264,9 +264,14 @@
                     Help
                   </button>
                 </li>
-
-
-
+                <li>
+                  <button
+                    class="dropdown-item"
+                    id="btndbClean"
+                  >
+                    Clean Database
+                  </button>
+                </li>
               </ul>
 
               <span