Team and AI API

const response = await fetch('/api/manage-analysis?kind=cities&page=1&pageSize=25&sort=name', {
  credentials: 'same-origin',
  cache: 'no-store',
})
const result = await response.json()
if (!response.ok) throw new Error(result.error ?? 'Request failed')
console.log(result.items, result.summary)

{
  "items": [
    {
      "id": 1,
      "slug": "example-city",
      "name": "Example City",
      "center_lng": 17.11,
      "center_lat": 48.15,
      "default_zoom": 13,
      "crosswalkCount": 42
    }
  ],
  "total": 1,
  "summary": {
    "total": 1,
    "crosswalks": 42,
    "withRecords": 1
  }
}

GET /api/manage-analysis?kind=compliance&onlyLegal=true&page=1&pageSize=10
GET /api/manage-analysis?kind=quality&city=1&locale=en
GET /api/manage-analysis?kind=inspections&urgency=overdue&page=1&pageSize=25

{
  "error": "Invalid pagination parameters."
}

const response = await fetch('/api/manage/contacts?status=new&page=0', {
  credentials: 'same-origin',
  cache: 'no-store',
})
const result = await response.json()
if (!response.ok) throw new Error(result.error)
console.log(result.items, result.total)

{
  "items": [
    {
      "id": "00000000-0000-4000-8000-000000000001",
      "name": "Alex Example",
      "email": "alex@example.com",
      "organization": "Example City",
      "topic": "demo",
      "message": "We would like a demonstration for our city team.",
      "locale": "en",
      "status": "new",
      "admin_notes": "",
      "created_at": "2026-10-01T09:00:00+00:00",
      "updated_at": "2026-10-01T09:00:00+00:00",
      "privacy_accepted_at": "2026-10-01T09:00:00+00:00"
    }
  ],
  "total": 1,
  "page": 0,
  "pageSize": 20
}

const response = await fetch('/api/manage/contacts', {
  method: 'PATCH',
  credentials: 'same-origin',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    id: '00000000-0000-4000-8000-000000000001',
    status: 'in_progress',
    admin_notes: 'Demo request assigned for follow-up.',
  }),
})
const result = await response.json()
if (!response.ok) throw new Error(result.error)

{
  "ok": true
}

{
  "error": "not_found"
}

const id = '00000000-0000-4000-8000-000000000001'
const response = await fetch('/api/manage/contacts?id=' + encodeURIComponent(id), {
  method: 'DELETE',
  credentials: 'same-origin',
})
const result = await response.json()
if (!response.ok) throw new Error(result.error)

{
  "ok": true
}

const response = await fetch('/api/ai/providers', { credentials: 'same-origin' })
const result = await response.json()
if (!response.ok) throw new Error(result.error)
console.log(result.providers)

{
  "providers": [
    "claude",
    "openai"
  ]
}

const response = await fetch('/api/ai/test', {
  method: 'POST',
  credentials: 'same-origin',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({ provider: 'openai' }),
})
const result = await response.json()
if (!response.ok || !result.ok) throw new Error(result.error ?? 'Connection failed')

{
  "ok": true
}

{
  "ok": false,
  "error": "No API key configured for this provider."
}

const dataResponse = await fetch('/api/crosswalks')
const data = await dataResponse.json()
if (!dataResponse.ok || data.error) throw new Error(data.error ?? 'Data unavailable')
const crosswalk = data.crosswalks[0]
if (!crosswalk) throw new Error('No crossing is available')

const candidate = {
  "custom": true,
  "id": "example-site-review",
  "title": "Review the crossing on site",
  "description": "Confirm the recorded conditions before commissioning work.",
  "category": "audit",
  "costTier": "low",
  "costRange": [
    200,
    400
  ],
  "baseEffectiveness": 0,
  "priorityScore": 60,
  "triggers": [
    "Local review requested"
  ],
  "legalRefs": []
}
const response = await fetch('/api/ai/suggestions', {
  method: 'POST',
  credentials: 'same-origin',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    provider: 'openai', crosswalk,
    existingSuggestions: [candidate], locale: 'en',
  }),
})
const result = await response.json()
if (!response.ok || result.error) throw new Error(result.error ?? 'Request failed')
console.log(result.suggestions)

{
  "suggestions": [
    {
      "custom": true,
      "id": "example-site-review",
      "title": "Review the crossing on site",
      "description": "A site review can confirm the conditions behind this request. Check the latest crossing observations with the local team before commissioning work.",
      "category": "audit",
      "costTier": "low",
      "costRange": [
        200,
        400
      ],
      "baseEffectiveness": 0,
      "priorityScore": 60,
      "triggers": [
        "Local review requested"
      ],
      "legalRefs": []
    }
  ]
}

{
  "suggestions": [],
  "error": "Invalid request."
}

const dataResponse = await fetch('/api/crosswalks')
const data = await dataResponse.json()
if (!dataResponse.ok || data.error) throw new Error(data.error ?? 'Data unavailable')
const crosswalk = data.crosswalks[0]
if (!crosswalk) throw new Error('No crossing is available')

const plan = {
  budget: 5000,
  items: [{
    crosswalkId: crosswalk.crosswalk_id,
    suggestionId: 'example-site-review',
    title: 'Review the crossing on site',
    category: 'audit', estimatedCost: 300, costRange: [200, 400],
    costTier: 'low', priorityScore: 60, baseEffectiveness: 0,
    crosswalkStreet: crosswalk.street,
    crosswalkCity: crosswalk.city,
    crosswalkSafetyClass: crosswalk.last_safety_class,
  }],
}
const response = await fetch('/api/ai/budget-insights', {
  method: 'POST',
  credentials: 'same-origin',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    provider: 'openai', plan, crosswalks: [crosswalk],
    options: { locale: 'en', focus: 'delivery' },
  }),
})
const result = await response.json()
if (!response.ok || result.error) throw new Error(result.error ?? 'Request failed')
console.log(result.content)

{
  "content": "## Delivery review\nThe selected review has an illustrative cost of €300, leaving €4,700 of the €5,000 budget. Confirm the scope and obtain a local quotation; the supplied €200–€400 range is an unverified estimate. No changes have been applied to the plan."
}

{
  "content": "",
  "error": "No API key configured for this provider."
}

{
  "provider": "openai",
  "locale": "en",
  "messages": [
    {
      "role": "user",
      "content": "What crossing observations should our team collect before a review?",
      "timestamp": 1790845200000,
      "selectedCrosswalkId": null
    }
  ],
  "crosswalks": []
}

{"t":"d","v":"Start with the recorded crossing attributes"}
{"t":"d","v":" and the date of the latest inspection."}

{
  "error": "No API key configured for this provider."
}

async function askAI(question, onText, signal) {
  const response = await fetch('/api/ai/chat', {
    method: 'POST',
    credentials: 'same-origin',
    headers: { 'Content-Type': 'application/json' },
    signal,
    body: JSON.stringify({
      provider: 'openai', locale: 'en', crosswalks: [],
      messages: [{
        role: 'user', content: question,
        timestamp: Date.now(), selectedCrosswalkId: null,
      }],
    }),
  })
  if (!response.ok) {
    const body = await response.json().catch(() => ({}))
    throw new Error(body.error ?? 'HTTP ' + response.status)
  }
  if (!response.headers.get('content-type')?.includes('application/x-ndjson')) {
    throw new Error('Expected an NDJSON response')
  }
  if (!response.body) throw new Error('No response stream')

  const reader = response.body.getReader()
  const decoder = new TextDecoder()
  let pending = ''
  let answer = ''
  const consume = (line) => {
    if (!line.trim()) return
    const frame = JSON.parse(line)
    if (frame.t === 'e') throw new Error(frame.v)
    if (frame.t !== 'd' || typeof frame.v !== 'string') {
      throw new Error('Unexpected stream frame')
    }
    answer += frame.v
    onText(answer)
  }

  try {
    while (true) {
      const { done, value } = await reader.read()
      pending += done ? decoder.decode() : decoder.decode(value, { stream: true })
      let newline
      while ((newline = pending.indexOf('\n')) !== -1) {
        consume(pending.slice(0, newline))
        pending = pending.slice(newline + 1)
      }
      if (done) break
    }
    if (pending.trim()) consume(pending)
    return answer
  } catch (error) {
    await reader.cancel().catch(() => {})
    throw error
  } finally {
    reader.releaseLock()
  }
}

const controller = new AbortController()
try {
  await askAI('What should a crossing review record?', console.log, controller.signal)
} catch (error) {
  console.error(error)
}
// Call controller.abort() to cancel.

{"t":"d","v":"The available data suggests"}
{"t":"e","v":"The AI service is temporarily unavailable."}