Agent Search Provider Health Check Workflow

import requests, os, time, json

H = {'x-api-key': os.environ['SCAVIO_API_KEY']}

TESTS = [
    {'query': 'python programming', 'platform': 'google', 'min_results': 5},
    {'query': 'wireless headphones', 'platform': 'amazon', 'min_results': 3},
    {'query': 'javascript tutorial', 'platform': 'youtube', 'min_results': 3},
    {'query': 'programming advice', 'platform': 'reddit', 'min_results': 3},
]
SLA_LATENCY_MS = 3000

def run_health_check(test):
    start = time.time()
    try:
        r = requests.post('https://api.scavio.dev/api/v1/search', headers=H,
            json={'platform': test['platform'], 'query': test['query']},
            timeout=10).json()
        latency_ms = int((time.time() - start) * 1000)
        organic = r.get('organic', [])
        checks = {
            'has_results': len(organic) > 0,
            'meets_min': len(organic) >= test['min_results'],
            'has_titles': all(o.get('title') for o in organic[:3]),
            'has_links': all(o.get('link') for o in organic[:3]),
            'under_sla': latency_ms < SLA_LATENCY_MS,
        }
        return {
            'platform': test['platform'], 'query': test['query'],
            'status': 'OK' if all(checks.values()) else 'DEGRADED',
            'latency_ms': latency_ms, 'result_count': len(organic), 'checks': checks,
        }
    except Exception as e:
        return {'platform': test['platform'], 'query': test['query'],
                'status': 'DOWN', 'error': str(e)}

for test in TESTS:
    result = run_health_check(test)
    print(f"[{result['status']}] {result['platform']}/{result['query']} | "
          f"{result.get('latency_ms', 'N/A')}ms | {result.get('result_count', 0)} results")

const H = {"x-api-key": process.env.SCAVIO_API_KEY, "Content-Type": "application/json"};

const TESTS = [
  {query: "python programming", platform: "google", minResults: 5},
  {query: "wireless headphones", platform: "amazon", minResults: 3},
  {query: "javascript tutorial", platform: "youtube", minResults: 3},
  {query: "programming advice", platform: "reddit", minResults: 3},
];
const SLA_LATENCY_MS = 3000;

async function runHealthCheck(test) {
  const start = Date.now();
  try {
    const r = await fetch("https://api.scavio.dev/api/v1/search", {
      method: "POST", headers: H,
      body: JSON.stringify({platform: test.platform, query: test.query})
    }).then(r => r.json());
    const latencyMs = Date.now() - start;
    const organic = r.organic || [];
    const checks = {
      hasResults: organic.length > 0,
      meetsMin: organic.length >= test.minResults,
      hasTitles: organic.slice(0, 3).every(o => o.title),
      hasLinks: organic.slice(0, 3).every(o => o.link),
      underSla: latencyMs < SLA_LATENCY_MS,
    };
    return {
      platform: test.platform, query: test.query,
      status: Object.values(checks).every(Boolean) ? "OK" : "DEGRADED",
      latencyMs, resultCount: organic.length, checks,
    };
  } catch (e) {
    return {platform: test.platform, query: test.query, status: "DOWN", error: e.message};
  }
}

(async () => {
  for (const test of TESTS) {
    const r = await runHealthCheck(test);
    console.log(`[${r.status}] ${r.platform}/${r.query} | ${r.latencyMs || "N/A"}ms | ${r.resultCount || 0} results`);
  }
})();