fix(api): connect openai job with correct resource (#1874)

lies-exposed · Dec 14, 2024 · bfecea8 · bfecea8
1 parent 8a8ea31
commit bfecea8
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/services/api/src/flows/tg/__tests__/createFromTGMessage.flow.e2e.ts b/services/api/src/flows/tg/__tests__/createFromTGMessage.flow.e2e.ts
@@ -19,10 +19,8 @@ import {
 } from "../../../../test/arbitraries/TGMessage.arb.js";
 import { saveUser, type UserTest } from "../../../../test/user.utils.js";
 import { createFromTGMessage } from "../createFromTGMessage.flow.js";
-import { EventSuggestionEntity } from "#entities/EventSuggestion.entity.js";
 import { LinkEntity } from "#entities/Link.entity.js";
 import { MediaEntity } from "#entities/Media.entity.js";
-import { UserEntity } from "#entities/User.entity.js";
 
 const tempDir = path.resolve(__dirname, `../../../../temp/tg/media`);
 

diff --git a/services/api/src/flows/tg/parseDocument.flow.ts b/services/api/src/flows/tg/parseDocument.flow.ts
@@ -54,7 +54,7 @@ export const parseDocument =
       }),
       TE.chainFirst((m) =>
         ctx.queue.queue(OpenAIEmbeddingQueueType.value).addJob({
-          id: uuid(),
+          id: m.id,
           resource: MEDIA.value,
           type: OpenAIEmbeddingQueueType.value,
           status: PendingStatus.value,

diff --git a/services/api/src/flows/tg/parseURL.flow.ts b/services/api/src/flows/tg/parseURL.flow.ts
@@ -1,7 +1,6 @@
 import { pipe } from "@liexp/core/lib/fp/index.js";
 import { isExcludedURL } from "@liexp/shared/lib/helpers/link.helper.js";
 import { URL } from "@liexp/shared/lib/io/http/Common/URL.js";
-import { uuid } from "@liexp/shared/lib/io/http/Common/UUID.js";
 import { LINKS } from "@liexp/shared/lib/io/http/Link.js";
 import {
   OpenAIEmbeddingQueueType,
@@ -62,7 +61,7 @@ export const parseURLs =
               ),
               TE.chainFirst((l) =>
                 ctx.queue.queue(OpenAIEmbeddingQueueType.value).addJob({
-                  id: uuid(),
+                  id: l.id,
                   status: PendingStatus.value,
                   type: OpenAIEmbeddingQueueType.value,
                   resource: LINKS.value,