Andreas/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2025-12-18 17:30:16 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

chore: clear timeouts

Browse source
This commit is contained in:
Danny Avila 2023-03-23 13:16:07 -04:00
parent bff33c79b3
commit 7afe09fa02
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
api/lib/db/indexSync.js
View file

@ -2,6 +2,7 @@ const mongoose = require('mongoose');
const Conversation = mongoose.models.Conversation; const Conversation = mongoose.models.Conversation;
const Message = mongoose.models.Message; const Message = mongoose.models.Message;
const { MeiliSearch } = require('meilisearch'); const { MeiliSearch } = require('meilisearch');
let currentTimeout = null;
// eslint-disable-next-line no-unused-vars // eslint-disable-next-line no-unused-vars
async function indexSync(req, res, next) { async function indexSync(req, res, next) {
@ -46,7 +47,7 @@ async function indexSync(req, res, next) {
// console.log('in index sync'); // console.log('in index sync');
if (err.message.includes('not found')) { if (err.message.includes('not found')) {
console.log('Creating indices...'); console.log('Creating indices...');
setTimeout(async () => { currentTimeout = setTimeout(async () => {
try { try {
await Message.syncWithMeili(); await Message.syncWithMeili();
await Conversation.syncWithMeili(); await Conversation.syncWithMeili();
@ -61,4 +62,9 @@ async function indexSync(req, res, next) {
} }
} }
process.on('exit', () => {
console.log('Clearing sync timeouts before exiting...');
clearTimeout(currentTimeout);
});
module.exports = indexSync; module.exports = indexSync;