/**
 * TESTE DO FIO (obrigatório, além da função pura).
 *
 * Prova que `handleStasisStart` (workers/voice-agent/index.ts) USA
 * `deveRecusarChamada`, com dublês para `hangupChannel`, `continueDialplan`
 * e `garantirLeadDaConversa`:
 * - bloqueado → `hangupChannel` UMA vez, `continueDialplan` e
 *   `garantirLeadDaConversa` NUNCA;
 * - não bloqueado → fluxo idêntico ao de hoje;
 * - falha ao resolver o contato → segue + log (fail-open).
 *
 * SABOTAGEM DO FIO (prova no CI, sem rodar nada local): remover a chamada a
 * `deveRecusarChamada` dentro do worker (manter a função pura existindo mas
 * sem uso) = caso "bloqueado" vermelho (`hangupChannel` nunca chamado,
 * `continueDialplan` chamado).
 */
import { beforeEach, describe, expect, it, vi } from "vitest";

const fakes = vi.hoisted(() => ({
  inseridas: [] as Array<Record<string, unknown>>,
  contato: null as null | { id: string; is_blocked: boolean } | Error,
  roteamento: {
    organization_id: "org-do-fio",
    routing_mode: "ai",
    default_ai_agent_id: null,
    fallback_user_id: null,
  },
  hangup: vi.fn<(...a: Array<unknown>) => unknown>(),
  setVar: vi.fn<(...a: Array<unknown>) => unknown>(),
  continuar: vi.fn<(...a: Array<unknown>) => unknown>(),
  garantir: vi.fn<(...a: Array<unknown>) => unknown>(async () => ({ criado: false, motivo: "ja_existe" })),
}));

vi.mock("@/lib/supabase/admin", () => ({
  createAdminClient: () => ({
    from: (_tabela: string) => ({
      insert: (linha: Record<string, unknown>) => {
        fakes.inseridas.push(linha);
        const resultado = { data: { id: "chamada-do-fio" }, error: null };
        return {
          select: () => ({ single: async () => resultado }),
          then: (ok: (r: unknown) => unknown) => Promise.resolve(resultado).then(ok),
        };
      },
    }),
    rpc: () => ({ single: async () => ({ data: fakes.roteamento, error: null }) }),
  }),
}));

vi.mock("@/lib/voip/ariClient", () => ({
  connectAriEvents: () => undefined,
  hangupChannel: (...args: Array<unknown>) => fakes.hangup(...args),
  setChannelVariable: (...args: Array<unknown>) => fakes.setVar(...args),
  continueDialplan: (...args: Array<unknown>) => fakes.continuar(...args),
}));

vi.mock("@/lib/voip/resolve-caller", () => ({
  resolveOrCreateCallerContact: async () => {
    if (fakes.contato instanceof Error) throw fakes.contato;
    return fakes.contato;
  },
}));

vi.mock("@/lib/leads/nascimento-do-lead", () => ({
  garantirLeadDaConversa: (...args: Array<unknown>) => fakes.garantir(...args),
}));

vi.mock("@/lib/ai/agents", () => ({ getActiveVoiceAgent: async () => null }));
vi.mock("@/lib/ai/knowledge/busca", () => ({
  buscarConhecimento: async () => ({ trechos: [] }),
  resolverAcervoDoAgente: async () => [],
}));
vi.mock("@/lib/organizacao/operante", () => ({ ehOperante: () => true }));

import { handleStasisStart } from "./index";

function eventoDeEntrada(numero: string) {
  return {
    type: "StasisStart",
    channel: { id: "canal-do-fio", dialplan: { exten: "5511999999999" }, caller: { number: numero } },
  };
}

beforeEach(() => {
  fakes.inseridas = [];
  fakes.contato = null;
  vi.clearAllMocks();
  fakes.garantir.mockResolvedValue({ criado: false, motivo: "ja_existe" });
});

describe("fio da recusa de bloqueado", () => {
  it('bloqueado desliga UMA vez, sem negócio, sem IA, e grava como Cancelada', async () => {
    fakes.contato = { id: "contato-bloq", is_blocked: true };
    await handleStasisStart(eventoDeEntrada("+5532984793302"));
    expect(fakes.hangup).toHaveBeenCalledTimes(1);
    expect(fakes.continuar).not.toHaveBeenCalled();
    expect(fakes.garantir).not.toHaveBeenCalled();
    expect(fakes.inseridas).toHaveLength(1);
    const linha = fakes.inseridas[0]!;
    expect(linha).toMatchObject({
      status: "ended",
      end_reason: "contact_blocked",
      answered_at: null,
      contact_id: "contato-bloq",
    });
    expect(typeof linha.ended_at).toBe("string");
  });

  it("não bloqueado segue exatamente igual a hoje", async () => {
    fakes.contato = { id: "contato-ok", is_blocked: false };
    await handleStasisStart(eventoDeEntrada("+5532984793302"));
    expect(fakes.hangup).not.toHaveBeenCalled();
    expect(fakes.continuar).toHaveBeenCalledTimes(1);
    expect(fakes.garantir).toHaveBeenCalledTimes(1);
    expect(fakes.inseridas[0]).toMatchObject({ status: "ringing", contact_id: "contato-ok" });
  });

  it("falha ao resolver o contato segue + loga (fail-open, nunca recusa no escuro)", async () => {
    fakes.contato = new Error("banco fora do ar");
    const erro = vi.spyOn(console, "error").mockImplementation(() => undefined);
    try {
      await handleStasisStart(eventoDeEntrada("+5532984793302"));
      // mockRestore() limpa o histórico do spy — por isso os expects vêm
      // ANTES do finally: depois de restaurar, a contagem zera.
      expect(erro).toHaveBeenCalledTimes(1);
      expect(fakes.hangup).not.toHaveBeenCalled();
      expect(fakes.continuar).toHaveBeenCalledTimes(1);
    } finally {
      erro.mockRestore();
    }
    expect(fakes.inseridas[0]).toMatchObject({ status: "ringing", contact_id: null });
  });
});