Implemented cronjob for message deletion (#207)

* Cronjob works now

* Made requested changes

* Switched to publish subscribe model for messages (#208)

* added pubsub for messages

* test

* finished pub sub

* testing empty secret

* Delete server/firebase-secrets.json

* added pubsub for messages

* test

* rebased

---------

Co-authored-by: AlexanderWangY <[email protected]>

* packages!

* Cronjob works now

* Made requested changes

* packages!

* Commented out deleter by default for testing purposes

* Removed interface imports

---------

Co-authored-by: Alexander Wang <[email protected]>
Co-authored-by: AlexanderWangY <[email protected]>

server/.gitignore

@@ -138,3 +138,6 @@ build
 # Other
 .env
 build/
+
+# Firebase Secrets
+.firebase-secrets.json

server/package.json

@@ -31,6 +31,7 @@
     "firebase-admin": "^12.0.0",
     "geofire-common": "^6.0.0",
     "mailgun.js": "^3.7.2",
+    "node-cron": "^3.0.3",
     "socket.io": "^4.7.4",
     "uuid": "^9.0.1"
   },

server/src/actions/deleter.ts

@@ -0,0 +1,29 @@
+import { messagesCollection } from '../utilities/firebaseInit'
+const cron = require('node-cron')
+
+//Schedule tasks to be run on the server
+export const scheduleCron = () => {
+    cron.schedule('*/30 * * * * *', function() {
+        console.log('Deleting old messages every 30s.')
+
+        //Deleter action, takes in a unix timestamp and deletes
+        //everything older than that
+        const expiryTime = Number(process.env.message_duration) //Set to 1 minute for testing purposes
+
+        const q = messagesCollection.orderByChild('timeSent').endAt(Date.now() - expiryTime)
+
+        q.on('value', (querySnapshot)=> {
+            querySnapshot.forEach(async (doc) => {
+                //Delete the doc here
+                console.log(doc.uid)
+                await doc.ref.delete().then(() => {
+                    console.log("Document successfully deleted!")
+                }).catch((error) => {
+                    console.error("Error removing document:", error)
+                })
+            })
+        })
+    })
+}
+
+

server/src/index.ts

@@ -13,6 +13,7 @@ import { getAuth } from 'firebase-admin/auth';
 import Mailgun from "mailgun.js";
 import { messagesCollection } from './utilities/firebaseInit';
 import { calculateDistanceInMeters } from './actions/calculateDistance';
+import { scheduleCron } from './actions/deleter';
 
 const { createServer } = require("http");
 const { Server } = require("socket.io");
@@ -333,6 +334,11 @@ app.listen(express_port, () => {
   );
 });
 
+
+//Remove the comments if you want to use the deleter !!!!!!
+//scheduleCron(); // Begin searching and collecting Garbage (old messages)
+
+
 // Some old API routes are commented out for now due to breaking type changes.
 
 // REST functions