diff --git a/apps/cf-ai-backend/src/routes/queue.ts b/apps/cf-ai-backend/src/routes/queue.ts index a7c8a630..5368543d 100644 --- a/apps/cf-ai-backend/src/routes/queue.ts +++ b/apps/cf-ai-backend/src/routes/queue.ts @@ -66,6 +66,8 @@ export const queue = async (batch: MessageBatch, env: Env): Promise => { }); }); + console.log(collectedDocsUUIDs); + await store.addDocuments( collectedDocsUUIDs.map(({ document }) => document), { @@ -81,7 +83,10 @@ export const queue = async (batch: MessageBatch, env: Env): Promise => { body: JSON.stringify(messages), }); + console.log(res.status, res.statusText); + if (res.status !== 200) { + console.log(await res.json()); console.error('Error adding tweets to db'); } diff --git a/apps/web/src/app/api/vectorizeTweets/route.ts b/apps/web/src/app/api/vectorizeTweets/route.ts index 5dfb22f1..63aa38f0 100644 --- a/apps/web/src/app/api/vectorizeTweets/route.ts +++ b/apps/web/src/app/api/vectorizeTweets/route.ts @@ -43,6 +43,8 @@ export async function POST(req: NextRequest) { const body = (await req.json()) as TweetData[]; + console.log(body); + const resp = await fetch( `https://cf-ai-backend.dhravya.workers.dev/batchUploadTweets`, {