fix: open new cdp on browser fail

Author: meirk-brd

src/lib/agent/browser-utils.ts

@@ -6,7 +6,7 @@ import type {
 } from "playwright-core";
 
 const SCREENSHOT_TIMEOUT_MS = 5_000;
-export const NAVIGATION_TIMEOUT_MS = 90_000;
+export const NAVIGATION_TIMEOUT_MS = 120_000;
 const CAPTCHA_SOLVE_TIMEOUT_MS = 45_000;
 const CAPTCHA_POLL_MS = 500;
 const CAPTCHA_SETTLE_MS = 1_500;

src/lib/agent/nodes/browser-pipeline.ts

@@ -17,7 +17,7 @@ import { extractTicketsWithOpenRouter } from "@/lib/openrouter-client";
 import type { TicketResult } from "@/lib/types";
 
 const VIEWPORT = { width: 1280, height: 800 };
-const PER_SOURCE_TIMEOUT_MS = 120_000;
+const PER_SOURCE_TIMEOUT_MS = 150_000;
 
 function withSource(platform: string, message: string): string {
   return `[${platform}] ${message}`;
@@ -130,8 +130,8 @@ export async function browserPipelineNode(
   try {
     logStatus(`Connecting browser to ${taskState.url}`);
     browser = await chromium.connectOverCDP(cdpUrl);
-    const context = browser.contexts()[0] ?? (await browser.newContext());
-    const page = context.pages()[0] ?? (await context.newPage());
+    let context = browser.contexts()[0] ?? (await browser.newContext());
+    let page = context.pages()[0] ?? (await context.newPage());
 
     applyNavigationTimeouts(context, page);
     await installSingleTabNavigation(context);
@@ -141,6 +141,18 @@ export async function browserPipelineNode(
       () => page.goto(taskState.url, { waitUntil: "domcontentloaded" }),
       {
         onStatus: (message) => logStatus(message),
+        signal,
+        async recoverPage({ attempt }) {
+          logStatus(`Opening fresh browser session (attempt ${attempt + 2})...`);
+          await browser?.close().catch(() => {});
+          browser = await chromium.connectOverCDP(cdpUrl);
+          context = browser.contexts()[0] ?? (await browser.newContext());
+          page = context.pages()[0] ?? (await context.newPage());
+          applyNavigationTimeouts(context, page);
+          await installSingleTabNavigation(context);
+          await page.setViewportSize(VIEWPORT);
+          return page;
+        },
       },
     );
 
@@ -194,15 +206,11 @@ export async function browserPipelineNode(
       };
     }
 
-    if (signal.aborted) {
-      logStatus("Timeout reached after browse loop; skipping ticket extraction.");
-      return {
-        tickets: [buildFallbackResult(platform, fallbackUrl, finalAnswer)],
-        statusLog,
-      };
-    }
-
+    // Always attempt structured extraction if we have a finalAnswer,
+    // even after timeout — the OpenRouter call is a fast API request
+    // that doesn't need the browser.
     try {
+      logStatus("Extracting structured ticket data from browse results...");
       const tickets = await extractTicketsWithOpenRouter({
         query: taskState.query,
         finalAnswer,

src/lib/agent/nodes/n1-browse-core.ts

@@ -20,6 +20,8 @@ const SYSTEM_PROMPT = [
   "",
   "IMPORTANT: Do NOT give up after a single 'wait' action. If you don't see ticket prices yet, scroll down, click on ticket sections, or interact with the page to reveal them.",
   "",
+  "CRITICAL: Do NOT navigate away from the current page to a different event or URL. Stay on this page and extract ticket information from it. If a navigation fails, do NOT retry — just continue gathering data from the current page.",
+  "",
   "When you provide your final findings, include event metadata: event name, event date, venue, and city.",
   "For each ticket option, include ticket type, section, row, seats, quantity, price, currency, platform, URL, and notes.",
   "If any field is unavailable, explicitly write Unknown.",
@@ -149,14 +151,32 @@ export async function runN1BrowseLoop(
         }
 
         const actionDescription = describeToolCall(toolCall);
-        activePage = await executeN1Action(activePage, toolCall, VIEWPORT, {
-          onStatus: (message) =>
-            emitAgentEvent({
-              type: "status",
-              message,
-              source,
-            }),
-        });
+        let actionError: string | null = null;
+        try {
+          activePage = await executeN1Action(activePage, toolCall, VIEWPORT, {
+            onStatus: (message) =>
+              emitAgentEvent({
+                type: "status",
+                message,
+                source,
+              }),
+            signal,
+          });
+        } catch (navError) {
+          if (
+            navError instanceof Error &&
+            navError.name === "NavigationAbortedError"
+          ) {
+            break;
+          }
+          actionError =
+            navError instanceof Error ? navError.message : String(navError);
+          emitAgentEvent({
+            type: "status",
+            message: `Action "${actionDescription}" failed: ${actionError}. Continuing browse loop.`,
+            source,
+          });
+        }
         activePage = await ensureUsablePage(activePage);
         stepCount += 1;
         currentUrl = activePage.url();
@@ -169,8 +189,15 @@ export async function runN1BrowseLoop(
             role: "tool",
             tool_call_id: toolCallId,
             content: JSON.stringify({
-              status: "ok",
+              status: actionError ? "error" : "ok",
               current_url: currentUrl,
+              ...(actionError
+                ? {
+                    error: actionError,
+                    instruction:
+                      "Navigation failed. Do NOT retry this URL. Continue gathering ticket information from the current page instead.",
+                  }
+                : {}),
             }),
           });
         }
@@ -216,27 +243,34 @@ export async function runN1BrowseLoop(
       }
     }
 
-    if (!finalAnswer && stepCount >= taskState.maxSteps && !signal?.aborted) {
-      const finalizeResponse = await callN1([
-        ...messages,
-        {
-          role: "user",
-          content:
-            "[Steps remaining: 0] Stop browsing now and provide your final ticket findings.",
-        },
-      ]);
+    if (!finalAnswer && (stepCount >= taskState.maxSteps || signal?.aborted)) {
+      try {
+        const finalizeResponse = await callN1([
+          ...messages,
+          {
+            role: "user",
+            content:
+              "[Steps remaining: 0] Stop browsing now and provide your final ticket findings based on everything you have seen so far.",
+          },
+        ]);
 
-      messages.push({
-        role: "assistant",
-        content: finalizeResponse.content,
-        tool_calls: finalizeResponse.tool_calls,
-      });
+        messages.push({
+          role: "assistant",
+          content: finalizeResponse.content,
+          tool_calls: finalizeResponse.tool_calls,
+        });
 
-      finalAnswer =
-        finalizeResponse.content ||
-        "Maximum step limit reached before a final answer was produced.";
-      status = `Reached max browsing steps (${taskState.maxSteps}). Finalized response.`;
-      emitAgentEvent({ type: "status", message: status, source });
+        finalAnswer =
+          finalizeResponse.content ||
+          "Maximum step limit reached before a final answer was produced.";
+        const reason = signal?.aborted ? "timeout" : "max steps";
+        status = `Finalized response due to ${reason} after ${stepCount} steps.`;
+        emitAgentEvent({ type: "status", message: status, source });
+      } catch (finalizeError) {
+        const msg = finalizeError instanceof Error ? finalizeError.message : "Unknown error";
+        status = `Failed to finalize after ${stepCount} steps: ${msg}`;
+        emitAgentEvent({ type: "status", message: status, source });
+      }
     }
 
     return {

src/lib/agent/tools.ts

@@ -8,6 +8,7 @@ export interface ViewportSize {
 
 interface NavigationStatusOptions {
   onStatus?: (message: string) => void;
+  signal?: AbortSignal;
 }
 
 const N1_COORDINATE_SPACE = 1000;
@@ -380,7 +381,7 @@ async function resolveActivePageAfterPopup(
         await navigateWithRecovery(
           page,
           () => page.goto(popupUrl, { waitUntil: "domcontentloaded" }),
-          { onStatus: options?.onStatus },
+          { onStatus: options?.onStatus, signal: options?.signal, retries: 0 },
         );
       }
       await popup.close().catch(() => {});
@@ -478,7 +479,7 @@ async function clickInCurrentPage(
       usablePage,
       () =>
         usablePage.goto(anchorCandidate.href, { waitUntil: "domcontentloaded" }),
-      { onStatus: options.onStatus },
+      { onStatus: options.onStatus, signal: options.signal, retries: 0 },
     );
     return ensureUsablePage(usablePage);
   }
@@ -504,6 +505,7 @@ async function clickInCurrentPage(
     if (popup) {
       return resolveActivePageAfterPopup(usablePage, popup, {
         onStatus: options.onStatus,
+        signal: options.signal,
       });
     }
     return ensureUsablePage(usablePage);
@@ -704,7 +706,7 @@ export async function executeN1Action(
     await navigateWithRecovery(
       activePage,
       () => activePage.goto(url, { waitUntil: "domcontentloaded" }),
-      { onStatus: options?.onStatus },
+      { onStatus: options?.onStatus, signal: options?.signal, retries: 0 },
     );
     return ensureUsablePage(activePage);
   }
@@ -713,7 +715,7 @@ export async function executeN1Action(
     await navigateWithRecovery(
       activePage,
       () => activePage.goBack({ waitUntil: "domcontentloaded" }),
-      { onStatus: options?.onStatus },
+      { onStatus: options?.onStatus, signal: options?.signal, retries: 0 },
     );
     return ensureUsablePage(activePage);
   }
@@ -722,7 +724,7 @@ export async function executeN1Action(
     await navigateWithRecovery(
       activePage,
       () => activePage.reload({ waitUntil: "domcontentloaded" }),
-      { onStatus: options?.onStatus },
+      { onStatus: options?.onStatus, signal: options?.signal, retries: 0 },
     );
     return ensureUsablePage(activePage);
   }