Cronjob works now

server/.gitignore

@@ -138,3 +138,4 @@ build
 # Other
 .env
 build/
+.firebase-secrets.json

server/src/actions/deleter.ts

@@ -0,0 +1,25 @@
+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.id)
+                await doc.ref.delete()
+            })
+        })
+    })
+}
+
+

server/src/index.ts

@@ -11,6 +11,7 @@ import {geohashForLocation} from 'geofire-common';
 import { ConnectedUser } from './types/User';
 import { getAuth } from 'firebase-admin/auth';
 import Mailgun from "mailgun.js";
+import { scheduleCron } from './actions/deleter';
 
 const { createServer } = require("http");
 const { Server } = require("socket.io");
@@ -31,6 +32,9 @@ const io = new Server(socketServer, {
   },
 });
 
+// Begin searching and collecting Garbage (old messages)
+scheduleCron();
+
 // Firebase JWT Authorization Custom Middleware
 io.use(async (socket, next) => {
   const token = socket.handshake.auth.token;