Base de Agentes
para WhatsApp

interface AgentPlugin {
  id: string                     // "builtin.handoff" | "crm.update"
  name: string
  capabilities: AgentCapability[]  // capabilities que o plugin habilita
  tools?: AgentTool[]            // ferramentas disponíveis
  policies?: AgentPolicy[]       // guardas de execução
  metadata?: Record<string, unknown>
}

interface AgentTool<TInput, TOutput> {
  name: string         // usado pelo modelo para invocar
  description: string  // o modelo lê isso para decidir quando usar
  kind: "query" | "mutation" | "notification"
  provider: string     // "vittal-hub" | "crm" | "openai"
  capabilities: AgentCapability[]
  inputSchema: ZodSchema   // validado antes de executar
  execute(input: TInput, ctx: AgentToolContext): Promise<TOutput>
}

// Contexto disponível em todo execute()
interface AgentToolContext {
  level: AgentLevel
  capabilities: AgentCapability[]
  conversationId: string
  senderPhone: string
  services: { conversationRepo, publisher, featureFlags, attendantSelector }
  logger: Logger
}

export function createCRMPlugin(config: { apiUrl: string }): AgentPlugin {
  return {
    id: "crm.update-lead",
    name: "CRM Lead Updater",
    capabilities: ["crm_update"],

    tools: [{
      name: "update_lead",
      description: "Atualiza status do lead no CRM após qualificação",
      kind: "mutation",
      provider: "crm",
      capabilities: ["crm_update"],
      inputSchema: z.object({
        leadId: z.string(),
        status: z.enum(["qualificado", "descartado", "em_negociacao"]),
        notes: z.string().optional(),
      }),
      async execute(input, ctx) {
        const res = await fetch(`${config.apiUrl}/leads/${input.leadId}`, {
          method: "PATCH",
          body: JSON.stringify(input),
        })
        ctx.logger.info({ leadId: input.leadId }, "lead atualizado")
        return { updated: res.ok }
      },
    }],

    policies: [{
      id: "crm.scope-check",
      name: "CRM Scope Check",
      async evaluate(command, ctx) {
        if (!ctx.capabilities.includes("crm_update")) {
          return { allowed: false, reason: "Agente sem permissão de CRM" }
        }
        return { allowed: true }
      },
    }],
  }
}