import { Database } from 'bun:sqlite'

const PORT_HTTP = 4101

// Inicializar base de datos
const db = new Database('agent-ui.db')

db.run(`
  CREATE TABLE IF NOT EXISTS history (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
    tool_name TEXT NOT NULL,
    args TEXT,
    result TEXT
  )
`)

db.run(`
  CREATE TABLE IF NOT EXISTS config (
    key TEXT PRIMARY KEY,
    value TEXT
  )
`)

console.log('[DB] SQLite inicializado: agent-ui.db')

// API HTTP solamente - WebSocket lo maneja webmcp
Bun.serve({
  port: PORT_HTTP,
  async fetch(req) {
    const url = new URL(req.url)

    // CORS headers
    const corsHeaders = {
      'Access-Control-Allow-Origin': '*',
      'Access-Control-Allow-Methods': 'GET, POST, PUT, DELETE, OPTIONS',
      'Access-Control-Allow-Headers': 'Content-Type'
    }

    if (req.method === 'OPTIONS') {
      return new Response(null, { headers: corsHeaders })
    }

    // API Routes
    if (url.pathname === '/api/history') {
      if (req.method === 'GET') {
        const limit = parseInt(url.searchParams.get('limit') || '50')
        const rows = db.query('SELECT * FROM history ORDER BY id DESC LIMIT ?').all(limit)
        return Response.json(rows, { headers: corsHeaders })
      }

      if (req.method === 'POST') {
        const body = await req.json()
        const stmt = db.prepare('INSERT INTO history (tool_name, args, result) VALUES (?, ?, ?)')
        stmt.run(body.tool_name, JSON.stringify(body.args), body.result)
        return Response.json({ success: true }, { headers: corsHeaders })
      }

      if (req.method === 'DELETE') {
        db.run('DELETE FROM history')
        return Response.json({ success: true }, { headers: corsHeaders })
      }
    }

    if (url.pathname === '/api/config') {
      if (req.method === 'GET') {
        const key = url.searchParams.get('key')
        if (key) {
          const row = db.query('SELECT value FROM config WHERE key = ?').get(key) as { value: string } | null
          return Response.json({ value: row?.value || null }, { headers: corsHeaders })
        }
        const rows = db.query('SELECT * FROM config').all()
        return Response.json(rows, { headers: corsHeaders })
      }

      if (req.method === 'POST') {
        const body = await req.json()
        const stmt = db.prepare('INSERT OR REPLACE INTO config (key, value) VALUES (?, ?)')
        stmt.run(body.key, body.value)
        return Response.json({ success: true }, { headers: corsHeaders })
      }
    }

    if (url.pathname === '/api/health') {
      return Response.json({ status: 'ok', timestamp: new Date().toISOString() }, { headers: corsHeaders })
    }

    return new Response('Not Found', { status: 404, headers: corsHeaders })
  }
})

console.log(`[HTTP] API corriendo en http://localhost:${PORT_HTTP}`)
console.log('')
console.log('='.repeat(50))
console.log('Agent UI API Server iniciado')
console.log(`  API: http://localhost:${PORT_HTTP}`)
console.log('')
console.log('WebMCP se inicia por separado con Claude Code MCP')
console.log('='.repeat(50))