feature: new changes!

packages/backend/src/pipelines/recommendation.ts

@@ -6,6 +6,7 @@ import { runRetrieval } from '../agents/retrieval.js';
 import { runRanking } from '../agents/ranking.js';
 import { runCurator } from '../agents/curator.js';
 import type { CuratorOutput, SSEEvent } from '../types/agents.js';
+import { generateTitle } from '../agents/titleGenerator.js';
 
 /* -- Agent pipeline --
 [1] Interpreter -> gets user input, transforms into structured data
@@ -69,7 +70,7 @@ export async function runPipeline(
     log(rec.id, 'Retrieval: start');
     sseWrite({ stage: 'retrieval', status: 'start' });
     const t1 = Date.now();
-    const retrievalOutput = await runRetrieval(interpreterOutput);
+    const retrievalOutput = await runRetrieval(interpreterOutput, rec.brainstorm_count);
     log(rec.id, `Retrieval: done (${Date.now() - t1}ms) — ${retrievalOutput.candidates.length} candidates`, {
       titles: retrievalOutput.candidates.map((c) => c.title),
     });
@@ -98,11 +99,21 @@ export async function runPipeline(
     log(rec.id, `Curator: done (${Date.now() - t3}ms) — ${curatorOutput.length} shows curated`);
     sseWrite({ stage: 'curator', status: 'done', data: curatorOutput });
 
+    // Generate AI title
+    let aiTitle: string = rec.title;
+    try {
+      log(rec.id, 'Title generation: start');
+      aiTitle = await generateTitle(interpreterOutput);
+      log(rec.id, `Title generation: done — "${aiTitle}"`);
+    } catch (err) {
+      log(rec.id, `Title generation failed, keeping initial title: ${String(err)}`);
+    }
+
     // Save results to DB
     log(rec.id, 'Saving results to DB');
     await db
       .update(recommendations)
-      .set({ recommendations: curatorOutput, status: 'done' })
+      .set({ recommendations: curatorOutput, status: 'done', title: aiTitle })
       .where(eq(recommendations.id, rec.id));
 
     sseWrite({ stage: 'complete', status: 'done' });