From fc2e2add4facccf006dee2c5d2b9a64a58773ca9 Mon Sep 17 00:00:00 2001 From: core Date: Thu, 25 Aug 2022 21:20:49 +0300 Subject: [PATCH] mongo update fix --- site/server/app.js | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/site/server/app.js b/site/server/app.js index 3f0f44dee..7973cb478 100644 --- a/site/server/app.js +++ b/site/server/app.js @@ -12,6 +12,7 @@ const cors = require('@koa/cors'); const { v4: uuidv4 } = require('uuid'); const {connectMongo, setMongo, getMongo} = require('./src/mongo'); +const ONE_HOUR_IN_MS = 1000 * 60 * 60; const {runTs} = require('./src/runTs'); const {publishJsonUpdate, subscribeJsonUpdate, unsubscribeJsonUpdate} = require('./src/redis'); @@ -144,7 +145,10 @@ router.get('/api/json', async ctx => { if (item) { ctx.body = item.json; - await setMongo(uuid, {}); + if (Date.now() - item.ts > ONE_HOUR_IN_MS) { + // update timestamp + await setMongo(uuid, {}); + } } else { ctx.status = 404; } @@ -170,7 +174,10 @@ router.get('/api/source', async ctx => { language: item.language || 'json' }; - await setMongo(uuid, {}); + if (Date.now() - item.ts > ONE_HOUR_IN_MS) { + // update timestamp + await setMongo(uuid, {}); + } } else { ctx.status = 404; }