blackroad-os-web/app/api/analytics/route.ts

import { NextResponse } from 'next/server'
import { execSync } from 'child_process'

export const runtime = 'nodejs'
export const dynamic = 'force-dynamic'

export async function GET() {
  const token = process.env.CLOUDFLARE_API_TOKEN || ''
  const accountId = process.env.CLOUDFLARE_ACCOUNT_ID || '848cf0b18d51e0170e0d1537aec3505a'

  let workerCount = 499
  if (token) {
    try {
      const r = await fetch(
        `https://api.cloudflare.com/client/v4/accounts/${accountId}/workers/scripts`,
        { headers: { Authorization: `Bearer ${token}` }, signal: AbortSignal.timeout(4000) }
      )
      const d = await r.json()
      if (d?.result) workerCount = d.result.length
    } catch {}
  }

  let meshMessages = 0, agentCount = 9, memoryEntries = 0
  try {
    agentCount = parseInt(execSync('ls /Users/alexa/blackroad/shared/inbox/ 2>/dev/null | wc -l', { encoding: 'utf8', timeout: 2000 }).trim()) || 9
    meshMessages = parseInt(execSync('find /Users/alexa/blackroad/shared/inbox/ -name "*.json" 2>/dev/null | wc -l', { encoding: 'utf8', timeout: 2000 }).trim()) || 0
    memoryEntries = parseInt(execSync('wc -l < /Users/alexa/.blackroad/memory/ledger/memory-ledger.jsonl 2>/dev/null || echo 0', { encoding: 'utf8', timeout: 2000 }).trim()) || 0
  } catch {}

  // Pi fleet pings
  const piNodes = [
    { name: 'aria64', ip: '192.168.4.38' },
    { name: 'blackroad-pi', ip: '192.168.4.64' },
    { name: 'alice', ip: '192.168.4.49' },
    { name: 'cecilia', ip: '192.168.4.89' },
  ]
  const piResults = await Promise.all(piNodes.map(async node => {
    const start = Date.now()
    try {
      const r = await fetch(`http://${node.ip}:11434/api/tags`, { signal: AbortSignal.timeout(1500) })
      return { ...node, online: r.ok, latency: Date.now() - start }
    } catch {
      return { ...node, online: false, latency: null }
    }
  }))
  const piOnline = piResults.filter(p => p.online).length

  return NextResponse.json({
    workers: { total: workerCount },
    agents: { total: 30000, fleet: piOnline * 7500, meshAgents: agentCount, meshMessages },
    memory: { ledgerEntries: memoryEntries, sessions: 16 },
    fleet: { total: piNodes.length, online: piOnline, nodes: piResults },
    timestamp: new Date().toISOString(),
  })
}