elias/core
1
0
Fork 0
mirror of https://github.com/eliasstepanik/core.git synced 2026-01-27 19:28:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: use document id for the flow

Browse Source
This commit is contained in:
Manoj K 2025-09-03 09:14:25 +05:30
parent 38f069a6dc
commit b701a11016
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apps/webapp/app/lib/ingest.server.ts
View File

@ -37,11 +37,16 @@ export const addToQueue = async (
}, },
}); });
let ingestionType = EpisodeType.CONVERSATION;
if (body.documentId) {
ingestionType = EpisodeType.DOCUMENT;
}
let handler; let handler;
if (body.type === EpisodeType.DOCUMENT) { if (ingestionType === EpisodeType.DOCUMENT) {
handler = await ingestDocumentTask.trigger( handler = await ingestDocumentTask.trigger(
{ {
body, body: { ...body, type: ingestionType },
userId, userId,
workspaceId: user.Workspace.id, workspaceId: user.Workspace.id,
queueId: queuePersist.id, queueId: queuePersist.id,
@ -52,10 +57,10 @@ export const addToQueue = async (
tags: [user.id, queuePersist.id], tags: [user.id, queuePersist.id],
}, },
); );
} else if (body.type === EpisodeType.CONVERSATION) { } else if (ingestionType === EpisodeType.CONVERSATION) {
handler = await ingestTask.trigger( handler = await ingestTask.trigger(
{ {
body, body: { ...body, type: ingestionType },
userId, userId,
workspaceId: user.Workspace.id, workspaceId: user.Workspace.id,
queueId: queuePersist.id, queueId: queuePersist.id,