- {activities.map((activity) => (
-
-
-
-
{icons[activity.type]}
-
-
- {activity.type}
- •
- {activity.timestamp}
-
-
{activity.item}
-
{activity.message}
-
- {activity.confidence && (
-
-
- Confidence
- {activity.confidence}%
-
-
-
80 ? "bg-success" :
- activity.confidence > 40 ? "bg-warning" : "bg-destructive"
- )}
- style={{ width: `${activity.confidence}%` }}
- />
-
-
- )}
-
-
-
-
- ))}
-
- );
-}
diff --git a/logistics-sentry/src/components/DecisionReasoning.js b/logistics-sentry/src/components/DecisionReasoning.js
deleted file mode 100644
index 500855555..000000000
--- a/logistics-sentry/src/components/DecisionReasoning.js
+++ /dev/null
@@ -1,68 +0,0 @@
-"use client";
-import { motion } from "framer-motion";
-import { Check, AlertCircle, ShieldAlert, ArrowRight } from "lucide-react";
-import { cn } from "@/lib/utils";
-
-export function DecisionReasoning({ result }) {
- if (!result) return null;
-
- const steps = [
- { label: "Intended Update", value: "Verified Source", status: "success" },
- { label: "Stock Consistency", value: result.audit_trail_valid ? "Valid Trail" : "Log Mismatch", status: result.audit_trail_valid ? "success" : "error" },
- { label: "Market Velocity", value: result.sales_velocity, status: "success" },
- { label: "Risk Evaluation", value: result.recommended_action, status: result.recommended_action === "PROCEED" ? "success" : "warning" }
- ];
-
- return (
-
-
-
-
-
-
Agent Reasoning Path
-
-
-
- {/* Connection Lines */}
-
-
- {steps.map((step, i) => (
-
-
- {step.status === "success" ?
:
- step.status === "error" ?
:
-
}
-
-
{step.label}
-
{step.value}
-
- ))}
-
-
-
-
- Verdict:
- {result.reasoning}
-
-
-
- );
-}
diff --git a/logistics-sentry/src/components/InventoryAlert.js b/logistics-sentry/src/components/InventoryAlert.js
deleted file mode 100644
index 32acbadb8..000000000
--- a/logistics-sentry/src/components/InventoryAlert.js
+++ /dev/null
@@ -1,118 +0,0 @@
-"use client";
-import {
- AlertTriangle,
- ArrowUpRight,
- Clock,
- Check,
- Pause,
- ShieldAlert
-} from "lucide-react";
-import { cn } from "@/lib/utils";
-
-export function InventoryAlert({
- id,
- type,
- severity,
- itemName,
- itemSku,
- message,
- currentStock,
- expectedStock,
- detectedAt,
- onProceed,
- onPause,
- onEscalate
-}) {
- const severityColors = {
- critical: "bg-destructive/10 border-destructive/20 text-destructive",
- high: "bg-warning/10 border-warning/20 text-warning",
- medium: "bg-info/10 border-info/20 text-info",
- };
-
- const variance = expectedStock ? Math.round(((currentStock - expectedStock) / expectedStock) * 100) : 0;
- const isPositive = variance > 0;
-
- return (
-
-
-
-
-
-
-
-
-
-
- {severity}
-
- {type.replace("-", " ")}
-
-
{itemName}
-
SKU: {itemSku}
-
-
-
-
Detected At
-
-
- {detectedAt}
-
-
-
-
-
- {message}
-
-
-
-
-
Recorded
-
{currentStock}
-
-
-
Audited
-
{expectedStock}
-
-
-
Variance
-
- {isPositive ? "+" : ""}{variance}%
-
-
-
-
-
-
-
-
-
-
-
- );
-}
diff --git a/logistics-sentry/src/components/InventoryInput.js b/logistics-sentry/src/components/InventoryInput.js
deleted file mode 100644
index 626b591d6..000000000
--- a/logistics-sentry/src/components/InventoryInput.js
+++ /dev/null
@@ -1,222 +0,0 @@
-"use client";
-import { useState, useCallback } from "react";
-import { useDropzone } from "react-dropzone";
-import { UploadCloud, Link as LinkIcon, FileSpreadsheet, CheckCircle2, AlertCircle, Globe, X } from "lucide-react";
-import { motion, AnimatePresence } from "framer-motion";
-import { cn } from "@/lib/utils";
-import { toast } from "@/hooks/use-toast";
-
-export function InventoryInput({ onInventoryLoaded }) {
- const [mode, setMode] = useState("file"); // 'file' or 'url'
- const [url, setUrl] = useState("");
- const [isConnecting, setIsConnecting] = useState(false);
- const [activeSource, setActiveSource] = useState(null); // { type: 'file' | 'url', name: '...' }
-
- // --- File Upload Logic ---
- const onDrop = useCallback((acceptedFiles) => {
- const file = acceptedFiles[0];
- if (!file) return;
-
- const reader = new FileReader();
-
- reader.onload = () => {
- try {
- // Simple pseudo-parsing for demo authenticity
- // In production, use a library like PapaParse
- const text = reader.result;
- const lineCount = text.split('\n').filter(line => line.trim().length > 0).length;
- const estimatedCount = Math.max(0, lineCount - 1); // Subtract header if CSV
-
- const sourceData = {
- type: 'file',
- name: file.name,
- count: estimatedCount,
- timestamp: new Date().toLocaleTimeString()
- };
-
- setActiveSource(sourceData);
- onInventoryLoaded(sourceData);
- toast({
- title: "Manifest Loaded",
- description: `Successfully parsed ${estimatedCount} items from ${file.name}`
- });
- } catch (err) {
- toast({ title: "Parse Error", description: "Could not read file format.", variant: "destructive" });
- }
- };
-
- reader.onerror = () => {
- toast({
- title: "File Read Error",
- description: "Failed to read the file. Please try again.",
- variant: "destructive"
- });
- };
-
- // Unified read call
- reader.readAsText(file);
- }, [onInventoryLoaded]);
-
- const { getRootProps, getInputProps, isDragActive } = useDropzone({
- onDrop,
- accept: {
- 'text/csv': ['.csv'],
- 'application/json': ['.json']
- },
- maxFiles: 1,
- maxSize: 10 * 1024 * 1024, // 10MB
- });
-
- // --- URL Logic ---
- const handleConnectUrl = (e) => {
- e.preventDefault();
- if (!url) return;
-
- setIsConnecting(true);
-
- // Simulate a legitimate connection check
- const timer = setTimeout(() => {
- setIsConnecting(false);
- const sourceData = {
- type: 'url',
- name: url,
- count: Math.floor(Math.random() * 5000) + 500, // Mock count
- inventory: [] // In real app, would fetch
- };
- onInventoryLoaded(sourceData);
- toast({
- title: "Connection Successful",
- description: `Successfully indexed ${sourceData.count} items from ${new URL(url).hostname}`,
- });
- }, 1500);
-
- return () => clearTimeout(timer);
- };
-
- const handleClear = () => {
- setActiveSource(null);
- setUrl("");
- onInventoryLoaded(null);
- };
-
- return (
-
- {/* Header / Tabs */}
-
-
-
-
-
-
-
-
- {activeSource ? (
-
-
-
- {activeSource.type === 'file' ? (
-
- ) : (
-
- )}
-
-
-
{activeSource.name}
-
- Status: Active Source • {activeSource.type === 'file' ? `${activeSource.count} items` : 'Live Stream'}
-
-
-
-
-
-
-
-
- {isDragActive ? "Drop manifest here" : "Drag & drop inventory file"}
-
-
- Support for .CSV, .JSON (Max 50MB)
-
-
-
-
- );
-}
diff --git a/logistics-sentry/src/components/LiveStream.js b/logistics-sentry/src/components/LiveStream.js
deleted file mode 100644
index bc5552541..000000000
--- a/logistics-sentry/src/components/LiveStream.js
+++ /dev/null
@@ -1,106 +0,0 @@
-"use client";
-import { useEffect, useRef } from "react";
-import { Terminal, Cpu, Info, AlertCircle, Bot } from "lucide-react";
-import { cn } from "@/lib/utils";
-
-import { motion, AnimatePresence } from "framer-motion";
-
-const PHASES = [
- { id: "SURFACE_SCAN", label: "Dashboard Scan" },
- { id: "SOURCE_VERIFICATION", label: "Audit Logs" },
- { id: "BUSINESS_CONTEXT", label: "Sales Analysis" },
- { id: "SYNTHESIS", label: "Final Synthesis" }
-];
-
-export function LiveStream({ events = [], isRunning, currentPhase }) {
- const scrollRef = useRef(null);
-
- useEffect(() => {
- if (scrollRef.current) {
- scrollRef.current.scrollTop = scrollRef.current.scrollHeight;
- }
- }, [events]);
-
- const getEventIcon = (type) => {
- switch (type) {
- case "observation": return
;
- case "action": return
;
- case "error": return
;
- case "phase_start": return
;
- default: return
;
- }
- };
-
- return (
-
-
-
-
- Audit Mission Log
-
-
-
- {phases.map((p) => (
-
e.message?.includes(p.id) && e.type === "phase_complete") ? "bg-success" : "bg-primary/10"
- )}
- title={p.label}
- />
- ))}
-
-
-
-
-
- {events.map((event, i) => (
-
-
- {getEventIcon(event.type)}
-
-
-
-
- {event.type}
-
- {event.timestamp}
-
-
- {event.message}
-
-
-
- {isRunning && events.length > 0 && (
-
- )}
-
-
- );
-}
diff --git a/logistics-sentry/src/components/MetricCard.js b/logistics-sentry/src/components/MetricCard.js
deleted file mode 100644
index 5c37ed1d6..000000000
--- a/logistics-sentry/src/components/MetricCard.js
+++ /dev/null
@@ -1,50 +0,0 @@
-import { cn } from "@/lib/utils";
-import { TrendingUp, TrendingDown } from "lucide-react";
-
-export function MetricCard({ title, value, subtitle, icon: Icon, trend, variant = "default" }) {
- const variants = {
- default: "border-white/5 bg-white/[0.02]",
- success: "border-success/20 bg-success/5",
- warning: "border-warning/20 bg-warning/5",
- info: "border-info/10 bg-info/5",
- };
-
- const iconColors = {
- default: "text-muted-foreground",
- success: "text-success",
- warning: "text-warning",
- info: "text-info",
- };
-
- return (
-
-
-
-
{subtitle}
- {trend && (
-
- {trend.isPositive ? : }
- {trend.value ?? 0}%
-
- )}
-
-
- );
-}
diff --git a/logistics-sentry/src/components/RiskAssessment.js b/logistics-sentry/src/components/RiskAssessment.js
deleted file mode 100644
index dd2c7d488..000000000
--- a/logistics-sentry/src/components/RiskAssessment.js
+++ /dev/null
@@ -1,72 +0,0 @@
-import { Shield, ChevronRight } from "lucide-react";
-import { cn } from "@/lib/utils";
-
-export function RiskAssessment({ items }) {
- return (
-
- {items.map((item) => (
-
-
-
-
- {item.category}
- 75 ? "bg-destructive text-destructive-foreground" :
- item.riskScore > 50 ? "bg-warning text-warning-foreground" : "bg-success text-success-foreground"
- )}>
- {item.riskScore > 75 ? "High Risk" : item.riskScore > 50 ? "Med Risk" : "Low Risk"}
-
-
-
{item.name}
-
-
75 ? "text-destructive" :
- item.riskScore > 50 ? "text-warning" : "text-success"
- )}>
-
-
-
-
-
-
-
- Risk Score
- {item.riskScore}
-
-
-
75 ? "bg-destructive" :
- item.riskScore > 50 ? "bg-warning" : "bg-success"
- )}
- style={{ width: `${item.riskScore}%` }}
- />
-
-
-
-
- {item.factors.map((factor, i) => (
-
- {factor}
-
- ))}
-
-
-
- Rec: {item.recommendation}
-
-
-
-
- ))}
-
- );
-}
diff --git a/logistics-sentry/src/lib/decision-engine.js b/logistics-sentry/src/lib/decision-engine.js
index c4937caae..312ff80f1 100644
--- a/logistics-sentry/src/lib/decision-engine.js
+++ b/logistics-sentry/src/lib/decision-engine.js
@@ -6,7 +6,6 @@ export function evaluateRisk(agentOutput) {
// Combine agent output with business logic rules
if (agentOutput.confidence_score < 40) return "ESCALATE";
- if (agentOutput.recommended_action === "ESCALATE") return "ESCALATE"; // Explicit strict check
if (agentOutput.recommended_action === "ESCALATE") return "ESCALATE";
if (agentOutput.recommended_action === "PAUSE") return "PAUSE";
diff --git a/logistics-sentry/src/lib/logistics/agent.js b/logistics-sentry/src/lib/logistics/agent.js
index d5e8039ac..85d6b4f92 100644
--- a/logistics-sentry/src/lib/logistics/agent.js
+++ b/logistics-sentry/src/lib/logistics/agent.js
@@ -1,4 +1,5 @@
import { runGenericAgent } from "../tinyfish";
+import { TinyFish } from "@tiny-fish/sdk";
// --- STAGE 1: SOURCE DISCOVERY (KNOWLEDGE BASE) ---
// In a production system, this would be an LLM or specific search agent.
@@ -58,74 +59,46 @@ const SOURCE_KNOWLEDGE_BASE = {
// Contextual sources like Weather or Labor generic sites could be added
};
-function buildDiscoverySources(origin_port, carrier) {
+async function buildDiscoverySources(origin_port, carrier) {
+ const client = new TinyFish({ apiKey: process.env.TINYFISH_API_KEY });
const sources = [];
- if (origin_port) {
- const portQuery = encodeURIComponent(`${origin_port} port authority operations status`);
- sources.push({
- name: `Discovery: ${origin_port} Port Authority`,
- url: `https://duckduckgo.com/html/?q=${portQuery}`,
- type: "custom_discovery",
- goal: `
-### MISSION: PORT AUTHORITY INTELLIGENCE DISCOVERY
-TARGET: ${origin_port}
-
-You are a Logistics Intelligence Scout. Your job is to locate the official port authority or terminal operations page for ${origin_port}, then extract operational status signals.
-
-### INSTRUCTIONS:
-1. Search for the official port authority or terminal operations page for ${origin_port}.
-2. Navigate to the official source and look for operational updates, advisories, or congestion metrics.
-3. Extract specific metrics/quotes with dates where possible.
-### REQUIRED OUTPUT (JSON ONLY):
-{
- "scan_status": "completed",
- "operational_status": "NORMAL" | "DISRUPTED" | "UNKNOWN",
- "signals": [
- {
- "summary": "Detailed finding with numbers/quotes if available",
- "severity": "LOW" | "MEDIUM" | "HIGH",
- "date": "YYYY-MM-DD",
- "category": "METRIC" | "QUOTE" | "STATUS"
- }
- ]
-}
-`
- });
+ if (origin_port) {
+ try {
+ const res = await client.search.query({
+ query: `${origin_port} port authority operations status advisories`,
+ });
+ const top = res.results?.slice(0, 2) || [];
+ top.forEach((r) => {
+ sources.push({
+ name: r.title || `Discovery: ${origin_port}`,
+ url: r.url,
+ type: "port_authority",
+ });
+ });
+ } catch (e) {
+ console.error(`[Search] Port discovery failed for ${origin_port}:`, e.message);
+ }
}
- if (carrier) {
- const carrierQuery = encodeURIComponent(`${carrier} customer advisories`);
- sources.push({
- name: `Discovery: ${carrier} Advisories`,
- url: `https://duckduckgo.com/html/?q=${carrierQuery}`,
- type: "custom_discovery",
- goal: `
-### MISSION: CARRIER ADVISORY INTELLIGENCE DISCOVERY
-TARGET: ${carrier}
-You are a Logistics Intelligence Scout. Your job is to locate ${carrier}'s official customer advisories or operations updates page, then extract operational signals.
-
-### INSTRUCTIONS:
-1. Find the official ${carrier} advisories/alerts/newsroom page.
-2. Navigate to the most recent advisories and extract concrete metrics or dates.
-3. Prefer official carrier sources over third-party news.
-
-### REQUIRED OUTPUT (JSON ONLY):
-{
- "scan_status": "completed",
- "operational_status": "NORMAL" | "DISRUPTED" | "UNKNOWN",
- "signals": [
- {
- "summary": "Detailed finding with numbers/quotes if available",
- "severity": "LOW" | "MEDIUM" | "HIGH",
- "date": "YYYY-MM-DD",
- "category": "METRIC" | "QUOTE" | "STATUS"
- }
- ]
-}
-`
- });
+ if (carrier) {
+ try {
+ const res = await client.search.query({
+ query: `${carrier} shipping customer advisories operational updates`,
+ });
+ const top = res.results?.slice(0, 2) || [];
+ top.forEach((r) => {
+ sources.push({
+ name: r.title || `Discovery: ${carrier}`,
+ url: r.url,
+ type: "carrier_advisory",
+ });
+ });
+ } catch (e) {
+ console.error(`[Search] Carrier discovery failed for ${carrier}:`, e.message);
+ }
}
+
return sources;
}
@@ -447,7 +420,7 @@ export async function assessDelayRisk(context) {
let discoveryUsed = false;
if (sources.length === 0) {
- sources = buildDiscoverySources(origin_port, carrier);
+ sources = await buildDiscoverySources(origin_port, carrier);
discoveryUsed = sources.length > 0;
if (!discoveryUsed) {
return {
diff --git a/logistics-sentry/src/lib/pricing-intelligence.js b/logistics-sentry/src/lib/pricing-intelligence.js
index a3bc46f8c..591833cdb 100644
--- a/logistics-sentry/src/lib/pricing-intelligence.js
+++ b/logistics-sentry/src/lib/pricing-intelligence.js
@@ -1,13 +1,18 @@
"use server";
-const TINYFISH_API_URL = "https://tinyfish.ai/v1/automation/run-sse";
-const TINYFISH_API_KEY = process.env.TINYFISH_API_KEY;
+import { TinyFish, EventType, RunStatus } from "@tiny-fish/sdk";
+
+let _client;
+function getClient() {
+ if (!_client) _client = new TinyFish({ apiKey: process.env.TINYFISH_API_KEY });
+ return _client;
+}
export async function runPricingAnalysis(competitorUrl, options = {}) {
- if (!TINYFISH_API_KEY) throw new Error("Missing TINYFISH_API_KEY environment variable");
- if (!competitorUrl) throw new Error("Missing competitorUrl");
+ if (!process.env.TINYFISH_API_KEY) throw new Error("Missing TINYFISH_API_KEY environment variable");
+ if (!competitorUrl) throw new Error("Missing competitorUrl");
- const goal = `
+ const goal = `
### MISSION: COMPETITIVE PRICING INTELLIGENCE (Target: ${competitorUrl})
You are a senior Strategic Pricing Analyst. Your mission is to extract the exact pricing and packaging model for the specified competitor.
@@ -61,28 +66,39 @@ You are a senior Strategic Pricing Analyst. Your mission is to extract the exact
}
`;
- try {
- const response = await fetch(TINYFISH_API_URL, {
- method: "POST",
- headers: {
- "X-API-Key": TINYFISH_API_KEY,
- "Content-Type": "application/json",
- },
- signal: options.signal,
- body: JSON.stringify({
- url: competitorUrl,
- goal: goal,
- browser_profile: "stealth"
- }),
- });
+ const encoder = new TextEncoder();
- if (!response.ok) {
- throw new Error(`TinyFish API error for ${competitorUrl}: ${response.statusText}`);
- }
+ // Return a ReadableStream compatible with the existing pricing/run/route.js
+ // SSE parser — it reads raw "data: ..." lines and looks for final_result.
+ return new ReadableStream({
+ async start(controller) {
+ const sendEvent = (data) => {
+ controller.enqueue(encoder.encode(`data: ${JSON.stringify(data)}\n\n`));
+ };
- return response.body;
- } catch (error) {
- console.error(`Agent execution failed for ${competitorUrl}:`, error);
- throw error;
- }
+ try {
+ const stream = await getClient().agent.stream(
+ { url: competitorUrl, goal, browser_profile: "stealth" },
+ { signal: options.signal }
+ );
+
+ for await (const event of stream) {
+ sendEvent(event);
+
+ if (event.type === EventType.COMPLETE) {
+ if (event.status === RunStatus.COMPLETED) {
+ // TypeScript SDK: event.result (not event.result_json)
+ sendEvent({ final_result: event.result ?? null });
+ }
+ break; // always break after COMPLETE
+ }
+ }
+ } catch (error) {
+ console.error(`Agent execution failed for ${competitorUrl}:`, error);
+ sendEvent({ type: "error", message: error.message });
+ } finally {
+ controller.close();
+ }
+ },
+ });
}
diff --git a/logistics-sentry/src/lib/tinyfish.js b/logistics-sentry/src/lib/tinyfish.js
index e6c3cda7e..6f8c0bb96 100644
--- a/logistics-sentry/src/lib/tinyfish.js
+++ b/logistics-sentry/src/lib/tinyfish.js
@@ -1,17 +1,24 @@
"use server";
-const TINYFISH_API_URL = "https://tinyfish.ai/v1/automation/run-sse";
-const TINYFISH_API_KEY = process.env.TINYFISH_API_KEY;
+import { TinyFish, EventType, RunStatus } from "@tiny-fish/sdk";
+
+let _client;
+function getClient() {
+ if (!_client) _client = new TinyFish({ apiKey: process.env.TINYFISH_API_KEY });
+ return _client;
+}
export async function runAgent(sku, intendedUpdate, contextUrl, options = {}) {
const targetUrl = contextUrl || "https://inventory-demo-dashboard.com";
- const missionType = intendedUpdate ? `cross-verify the safety of an intended stock update ("${intendedUpdate}")` : `perform a general integrity audit to ensure data consistency across sources`;
+ const missionType = intendedUpdate
+ ? `cross-verify the safety of an intended stock update ("${intendedUpdate}")`
+ : `perform a general integrity audit to ensure data consistency across sources`;
const goal = `
### MISSION: DEEP INTEGRITY AUDIT (SKU: ${sku})
You are a senior Autonomous Inventory Auditor. Your mission is to ${missionType} by investigating multiple data sources.
-${contextUrl ? `\n**CRITICAL CONTEXT**: The user has provided a specific Source of Truth URL: ${contextUrl}. You MUST navigate to this URL to verify the "Actual Stock" against the dashboard's "Reported Stock".\n` : ''}
+${contextUrl ? `\n**CRITICAL CONTEXT**: The user has provided a specific Source of Truth URL: ${contextUrl}. You MUST navigate to this URL to verify the "Actual Stock" against the dashboard's "Reported Stock".\n` : ""}
### AUDIT PHASES
1. **PHASE_1: SURFACE_SCAN (Dashboard)**
@@ -20,12 +27,16 @@ ${contextUrl ? `\n**CRITICAL CONTEXT**: The user has provided a specific Source
- Report: {"phase": "SURFACE_SCAN", "status": "completed", "findings": "Extracted reported stock"}
2. **PHASE_2: SOURCE_VERIFICATION (Audit Logs / External Source)**
- ${contextUrl ? `- **Navigate to the provided Source URL**: ${contextUrl}\n - Search for ${sku} in the external sheet/feed.\n - Compare the "Stock" value there with the Dashboard value.` : `- Find and navigate to the "Audit Logs" or "History" section.\n - Search for ${sku} and check the last 5 manual entries.\n - Identify if the "User ID" or "Source" of recent changes looks suspicious or anomalous.`}
+ ${contextUrl
+ ? `- **Navigate to the provided Source URL**: ${contextUrl}\n - Search for ${sku} in the external sheet/feed.\n - Compare the "Stock" value there with the Dashboard value.`
+ : `- Find and navigate to the "Audit Logs" or "History" section.\n - Search for ${sku} and check the last 5 manual entries.\n - Identify if the "User ID" or "Source" of recent changes looks suspicious or anomalous.`}
- Report: {"phase": "SOURCE_VERIFICATION", "status": "completed", "findings": "Verified log/source integrity"}
3. **PHASE_3: BUSINESS_CONTEXT (Sales Analytics)**
- Navigate to "Sales Analytics" or "Orders" view.
- ${intendedUpdate ? `- Determine if the "Sales Velocity" for ${sku} justifies the intended update: "${intendedUpdate}".\n - Check for pending shipments that might conflict with this update.` : `- Analyze "Sales Velocity" for ${sku} to detect any anomalies vs reported stock.\n - Identify if current stock levels are dangerously low or high based on sales trends.`}
+ ${intendedUpdate
+ ? `- Determine if the "Sales Velocity" for ${sku} justifies the intended update: "${intendedUpdate}".\n - Check for pending shipments that might conflict with this update.`
+ : `- Analyze "Sales Velocity" for ${sku} to detect any anomalies vs reported stock.\n - Identify if current stock levels are dangerously low or high based on sales trends.`}
- Report: {"phase": "BUSINESS_CONTEXT", "status": "completed", "findings": "Analyzed sales alignment"}
4. **PHASE_4: SYNTHESIS & VERDICT**
@@ -50,56 +61,76 @@ ${contextUrl ? `\n**CRITICAL CONTEXT**: The user has provided a specific Source
}
`;
- try {
- const response = await fetch(TINYFISH_API_URL, {
- method: "POST",
- headers: {
- "X-API-Key": TINYFISH_API_KEY,
- "Content-Type": "application/json",
- },
- signal: options.signal,
- body: JSON.stringify({
- url: targetUrl,
- goal: goal,
- browser_profile: "stealth"
- }),
- });
-
- if (!response.ok) {
- throw new Error(`TinyFish API error: ${response.statusText}`);
- }
-
- // Since this is SSE, we return the stream or a reader
- return response.body;
- } catch (error) {
- console.error("Agent execution failed:", error);
- throw error;
- }
+ // Return a ReadableStream that mirrors SDK SSE events so the existing
+ // API route can pass it through unchanged to the browser.
+ const encoder = new TextEncoder();
+
+ return new ReadableStream({
+ async start(controller) {
+ const sendEvent = (data) => {
+ controller.enqueue(encoder.encode(`data: ${JSON.stringify(data)}\n\n`));
+ };
+
+ try {
+ const stream = await getClient().agent.stream(
+ { url: targetUrl, goal, browser_profile: "stealth" },
+ { signal: options.signal }
+ );
+
+ for await (const event of stream) {
+ sendEvent(event);
+
+ if (event.type === EventType.COMPLETE) {
+ // COMPLETED only means the browser ran without crashing —
+ // always validate result content, not just the status.
+ if (event.status === RunStatus.COMPLETED) {
+ // TypeScript SDK: event.result (not event.result_json)
+ sendEvent({ final_result: event.result ?? null });
+ }
+ break; // always break after COMPLETE
+ }
+ }
+ } catch (error) {
+ console.error("Agent execution failed:", error);
+ sendEvent({ type: "error", message: error.message });
+ } finally {
+ controller.close();
+ }
+ },
+ });
}
export async function runGenericAgent(url, goal, options = {}) {
- try {
- const response = await fetch(TINYFISH_API_URL, {
- method: "POST",
- headers: {
- "X-API-Key": TINYFISH_API_KEY,
- "Content-Type": "application/json",
- },
- signal: options.signal,
- body: JSON.stringify({
- url: url,
- goal: goal,
- browser_profile: "stealth"
- }),
- });
-
- if (!response.ok) {
- throw new Error(`TinyFish API error: ${response.statusText}`);
- }
-
- return response.body;
- } catch (error) {
- console.error("Agent execution failed:", error);
- throw error;
- }
+ const encoder = new TextEncoder();
+
+ return new ReadableStream({
+ async start(controller) {
+ const sendEvent = (data) => {
+ controller.enqueue(encoder.encode(`data: ${JSON.stringify(data)}\n\n`));
+ };
+
+ try {
+ const stream = await getClient().agent.stream(
+ { url, goal, browser_profile: "stealth" },
+ { signal: options.signal }
+ );
+
+ for await (const event of stream) {
+ sendEvent(event);
+
+ if (event.type === EventType.COMPLETE) {
+ if (event.status === RunStatus.COMPLETED) {
+ sendEvent({ final_result: event.result ?? null });
+ }
+ break; // always break after COMPLETE
+ }
+ }
+ } catch (error) {
+ console.error("Agent execution failed:", error);
+ sendEvent({ type: "error", message: error.message });
+ } finally {
+ controller.close();
+ }
+ },
+ });
}