Skip to content
This repository was archived by the owner on Mar 10, 2024. It is now read-only.

Commit 180fd36

Browse files
delete old documents
1 parent 41fcdb4 commit 180fd36

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

src/db/MongoDB.js

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,11 @@ class MongoDB {
158158
this.changeParam(documentLink, 'lastViewedDate', Date.now());
159159
}
160160

161+
async deleteOldDocuments(days=2) {
162+
const oldTimestamp = Date.now() - 1000 * 60 * 60 * 24 * days;
163+
this.documentsCollection.deleteMany({'lastViewedDate': {$lt : oldTimestamp} });
164+
}
165+
161166
async applyRequests (documentLink, requests) {
162167
// TODO look to use bulk write
163168
try {

src/socket/socket.js

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,5 +156,10 @@ module.exports = function (wss) {
156156
prom.connected.set(wss.clients.size);
157157
}, 5000);
158158

159+
// delete old documents
160+
setInterval(() => {
161+
db.deleteOldDocuments();
162+
}, 1000 * 60 * 60 * 24);
163+
159164

160165
}

0 commit comments

Comments
 (0)