jamesf/Perplexica
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Delete msgs only belonging to the chat

Browse source
This commit is contained in:
Sainadh Devireddy 2024-12-27 20:55:55 -08:00
parent 409c811a42
commit d18e88acc9
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) {