Function createAgentRoute

packages/cli/src/agent.ts:117–396

(projectCwd: string, targetPort: number, isFresh?: () => boolean)

 * @param isFresh - Getter for whether the project is in creation mode
 */
export function createAgentRoute(projectCwd: string, targetPort: number, isFresh?: () => boolean) {
    const agent = new Hono();

    // ─── Model Catalog ───────────────────────────────────────

    agent.get('/api/models', (c) => {
        return c.json({ providers: getProviderCatalog() });
    });

    // ─── Chat (trigger LLM) ─────────────────────────────────

    agent.post('/api/chat', async (c) => {
        let body: unknown;
        try {
            body = await c.req.json();
        } catch {
            return c.json({ success: false, error: 'Invalid request body' }, 400);
        }

        const parsed = ChatRequestSchema.safeParse(body);
        if (!parsed.success) {
            const message = parsed.error.issues.map(i => `${i.path.join('.')}: ${i.message}`).join('; ');
            return c.json({ success: false, error: message }, 400);
        }

        const { prompt, model, modelProvider, consoleEntries, images, pageContext, language } = parsed.data;
        const modelId = model ?? DEFAULT_MODEL;

        // Prepend context blocks to the prompt
        let augmentedPrompt = prompt;
        if (pageContext) {
            augmentedPrompt = formatPageContext(pageContext) + augmentedPrompt;
        }
        if (consoleEntries && consoleEntries.length > 0) {
            const context = formatConsoleContext(consoleEntries);
            if (context) {
                augmentedPrompt = context + augmentedPrompt;
            }
        }

        // Build user content — multipart if images are present
        const hasImages = images && images.length > 0;
        const userContent = hasImages
            ? [
                { type: 'text' as const, text: augmentedPrompt },
                ...images.map(dataUrl => ({ type: 'image' as const, image: dataUrl })),
            ]
            : augmentedPrompt;

        // Cancel any in-flight stream before starting a new one
        activeStreamAbort?.abort();
        const abortController = new AbortController();
        activeStreamAbort = abortController;
        const { signal } = abortController;

        // Adapter stream that emits events through the bus
        const adapter = {
            writeSSE: async (msg: { event?: string; data: string; id?: string }) => {