import Redis from 'ioredis'
import { execSync } from 'child_process'
const redis = new Redis({ host: 'redis', port: 6379, lazyConnect: true })
const QUEUE = 'dev-tasks'
const LOG   = 'dev-logs'

function log(level, msg) {
  const line = JSON.stringify({ ts: new Date().toISOString(), level, msg })
  redis.publish(LOG, line).catch(() => {})
  console.log(`[${level}] ${msg}`)
}

function exec(cmd) {
  try { return execSync(cmd, { encoding: 'utf8', timeout: 30000 }).trim() }
  catch(e) { return `ERROR: ${e.message}` }
}

async function processTask(task) {
  task.status   = 'in_progress'
  task.assignee = 'agent-devops'
  await redis.set(`task:${task.id}`, JSON.stringify(task))
  log('AGENT', `▶️  Processando: ${task.title}`)
  const result = exec(task.command || `echo "${task.title}"`)
  task.result   = result
  task.status   = 'done'
  task.done_at  = new Date().toISOString()
  await redis.set(`task:${task.id}`, JSON.stringify(task))
  log('AGENT', `✔️  Concluído: ${task.title}`)
  return result
}

async function run() {
  await redis.connect()
  await redis.set('agent:agent-devops', JSON.stringify({
    id: 'agent-devops', role: 'devops', status: 'online',
    started_at: new Date().toISOString(), tasks_done: 0,
  }))
  log('AGENT', 'DevOps Agent online — aguardando tarefas')
  while (true) {
    const [_, tid] = await redis.blpop(QUEUE, 60)
    if (!tid) { await new Promise(r => setTimeout(r, 1000)); continue }
    const raw = await redis.get(`task:${tid}`)
    if (!raw) continue
    const task = JSON.parse(raw)
    if (task.domain !== 'devops') {
      await redis.rpush(QUEUE, tid); continue
    }
    await processTask(task)
    await redis.hincrby('agent:agent-devops', 'tasks_done', 1)
  }
}
run().catch(e => { console.error(e); process.exit(1) })