Script the sign-in, hand the rest to an agent

import type { Page } from 'playwright';
import { Outcrawl } from '@outcrawl/sdk';

const oc = new Outcrawl();
const PORTAL = 'https://portal.northgate-3pl.example';

interface Exception {
  shipment: string;
  carrier: string;
  flaggedOn: string;
  trackingUrl: string;
}

interface Finding {
  whatHappened: string;
  lastScan: string;
  newEstimate?: string;
  askedOfUs?: string;
}

const findingSchema = {
  type: 'object',
  properties: {
    whatHappened: { type: 'string', description: 'the exception in one sentence' },
    lastScan: { type: 'string', description: 'the most recent carrier scan: place, time and event' },
    newEstimate: { type: 'string', description: "the carrier's current delivery estimate, YYYY-MM-DD" },
    askedOfUs: { type: 'string', description: 'what the carrier or the warehouse asks us to do, if anything' },
  },
  required: ['whatHappened', 'lastScan'],
};

// The profile keeps the portal's login between runs, and is what the agent inherits.
const [existing] = await oc.profiles.list({ label: 'northgate-ops' });
const profile = existing ?? (await oc.profiles.create({ label: 'northgate-ops' }));

// 1. The known part, scripted: sign in if needed and read the exceptions table.
const exceptions: Exception[] = [];
const browser = await oc.browser({ profile: profile.id });
try {
  const page = await browser.newPage();
  const pw = page.raw as unknown as Page; // page.raw is the real Playwright page

  await page.goto(`${PORTAL}/shipments?status=exception`);
  if (pw.url().includes('/login')) {
    await page.fill('#email', process.env.NORTHGATE_EMAIL!);
    await page.fill('#password', process.env.NORTHGATE_PASSWORD!);
    await page.click('button[type=submit]');
    await pw.waitForURL('**/shipments**');
  }

  await pw.waitForSelector('table.shipments');
  for (const row of await pw.locator('table.shipments tbody tr').all()) {
    const [shipment = '', carrier = '', flaggedOn = ''] = await row.locator('td').allInnerTexts();
    const trackingUrl = (await row.locator('a.tracking').getAttribute('href')) ?? '';
    exceptions.push({ shipment: shipment.trim(), carrier: carrier.trim(), flaggedOn: flaggedOn.trim(), trackingUrl });
  }
} finally {
  // Closing frees the browser slot and the profile. The login stays in the profile.
  await browser.close();
}
console.log(`${exceptions.length} shipments flagged`);

// 2. The messy part, one agent run per shipment, in the same signed-in profile.
const report = [];
for (const exception of exceptions) {
  const run = await oc.agent({
    task:
      `Open ${PORTAL}/shipments/${exception.shipment} and read the exception note and the message thread. ` +
      `Then open the ${exception.carrier} tracking page at ${exception.trackingUrl} and read the most recent scan. ` +
      "Report what went wrong, the last scan, the carrier's new delivery estimate, and anything we are asked to do.",
    profile: profile.id,
    schema: findingSchema,
    caps: { budget: '25.00' },
    rules: ['Never send a message, file a claim, or change, cancel or reship a shipment.'],
  });
  const finding = run.data as Finding | undefined;
  report.push({
    shipment: exception.shipment,
    carrier: exception.carrier,
    lastScan: finding?.lastScan ?? `(run ${run.status})`,
    newEstimate: finding?.newEstimate ?? '',
    askedOfUs: finding?.askedOfUs ?? '',
    credits: run.credits,
  });
}

console.table(report);