updates for purging calls periodically

app.js

@@ -9,7 +9,12 @@ const cors = require('cors');
 const passport = require('passport');
 const authStrategy = require('./lib/auth')(logger);
 const routes = require('./lib/routes');
-const {retrieveCall, deleteCall, listCalls} = require('jambonz-realtimedb-helpers')(config.get('redis'), logger);
+const {
+  retrieveCall,
+  deleteCall,
+  listCalls,
+  purgeCalls
+} = require('jambonz-realtimedb-helpers')(config.get('redis'), logger);
 const PORT = process.env.HTTP_PORT || 3000;
 
 passport.use(authStrategy);
@@ -19,7 +24,8 @@ Object.assign(app.locals, {
   logger,
   retrieveCall,
   deleteCall,
-  listCalls
+  listCalls,
+  purgeCalls
 });
 
 app.use(cors());
@@ -34,4 +40,16 @@ app.use((err, req, res, next) => {
 logger.info(`listening for HTTP traffic on port ${PORT}`);
 app.listen(PORT);
 
+// purge old calls from active call set every 10 mins
+async function purge() {
+  try {
+    const count = await purgeCalls();
+    logger.info(`purged ${count} calls from realtimedb`);
+  } catch (err) {
+    logger.error(err, 'Error purging calls');
+  }
+  setTimeout(purge, 10 * 60 * 1000);
+}
+purge();
+
 module.exports = app;