remi/Perplexica
1
0
Fork 0
mirror of https://github.com/ItzCrazyKns/Perplexica.git synced 2025-04-30 08:12:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'pr/538'

Browse Source
This commit is contained in:
ItzCrazyKns
2025-01-05 14:15:58 +05:30
parent 5a648f34b8 d18e88acc9
commit 0f6b3c2e69
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/websocket/messageHandler.ts
View File

@ -5,7 +5,7 @@ import type { Embeddings } from '@langchain/core/embeddings';
import logger from '../utils/logger'; import logger from '../utils/logger';
import db from '../db'; import db from '../db';
import { chats, messages as messagesSchema } from '../db/schema'; import { chats, messages as messagesSchema } from '../db/schema';
import { eq, asc, gt } from 'drizzle-orm'; import { eq, asc, gt, and } from 'drizzle-orm';
import crypto from 'crypto'; import crypto from 'crypto';
import { getFileDetails } from '../utils/files'; import { getFileDetails } from '../utils/files';
import MetaSearchAgent, { import MetaSearchAgent, {
@ -238,7 +238,7 @@ export const handleMessage = async (
} else { } else {
await db await db
.delete(messagesSchema) .delete(messagesSchema)
.where(gt(messagesSchema.id, messageExists.id)) .where(and(gt(messagesSchema.id, messageExists.id), eq(messagesSchema.chatId, parsedMessage.chatId)))
.execute(); .execute();
} }
} catch (err) { } catch (err) {