/**
 * Ler o estado de elegibilidade de uma conversa via pool `pg` (o transporte do
 * agent-engine). Uma query, três tabelas: o modo do gate do canal, as travas do
 * contato, o silêncio da conversa.
 *
 * O drain (decide ENFILEIRAR) e o turno (decide RODAR) chamam isto e passam o
 * resultado para `decidirElegibilidade` — a MESMA regra pura.
 */
import type pg from "pg";

import {
  decidirElegibilidade,
  montarEstadoDeElegibilidade,
  type DecisaoDaConversa,
} from "./gate";

interface LinhaDeElegibilidade {
  channel_metadata: Record<string, unknown> | null;
  force_human: boolean;
  ai_opt_out: boolean;
  assignee_kind: string | null;
  /** `conversations.metadata` — o modo "IA com o dono" (#3967) mora aqui. */
  conversation_metadata: unknown;
  bot_silenced_until: Date | string | null;
  ai_authorized_at: Date | string | null;
  phone_number: string | null;
  org_status: string | null;
  /** `contacts.tags` — a régua de contato interno (#2353) e a da equipe (#3534). */
  contact_tags: string[] | null;
  /** `organizations.settings` — as listas moram em `.crm.internal_contact_tags` e `.crm.team_contact_tags`. */
  org_settings: unknown;
}

/**
 * Roda a query e a regra. `null` = conversa não encontrada (deixe o chamador
 * decidir; o drain trata como "sem gate", segue o fluxo antigo).
 */
export async function decidirElegibilidadeDaConversa(
  pool: pg.Pool,
  input: { organizationId: string; conversationId: string; agora: Date; ttlMs: number },
): Promise<DecisaoDaConversa | null> {
  const { rows } = await pool.query<LinhaDeElegibilidade>(
    `select
       cs.metadata                  as channel_metadata,
       ct.force_human               as force_human,
       ct.ai_opt_out                as ai_opt_out,
       cv.assignee_kind             as assignee_kind,
       cv.metadata                  as conversation_metadata,
       cv.bot_silenced_until        as bot_silenced_until,
       ct.ai_authorized_at          as ai_authorized_at,
       ct.phone_number              as phone_number,
       ct.tags                      as contact_tags,
       o.status                     as org_status,
       o.settings                   as org_settings
     from conversations cv
     join organizations o on o.id = cv.organization_id
     join contacts ct
       on ct.id = cv.contact_id and ct.organization_id = cv.organization_id
     join channel_sessions cs
       on cs.id = cv.channel_session_id and cs.organization_id = cv.organization_id
     where cv.organization_id = $1 and cv.id = $2`,
    [input.organizationId, input.conversationId],
  );
  const r = rows[0];
  if (r === undefined) return null;

  const estado = montarEstadoDeElegibilidade({
    orgStatus: r.org_status,
    canalDesativado: r.channel_metadata?.disabled,
    aiGate: r.channel_metadata?.ai_gate,
    aiGateMode: r.channel_metadata?.ai_gate_mode,
    aiTestPhoneNumbers: r.channel_metadata?.ai_test_phone_numbers,
    contactPhoneNumber: r.phone_number,
    forceHuman: r.force_human,
    contactTags: r.contact_tags,
    orgSettings: r.org_settings,
    aiOptOut: r.ai_opt_out,
    assigneeKind: r.assignee_kind,
    metadataDaConversa: r.conversation_metadata,
    botSilencedUntil: r.bot_silenced_until,
    aiAuthorizedAt: r.ai_authorized_at,
    agora: input.agora,
    ttlMs: input.ttlMs,
  });
  // #3534: a decisão viaja com o fato que o medidor de clima precisa — a mesma
  // régua de equipe que o turno lê aqui, no mesmo `contact_tags`/`org_settings`.
  return { ...decidirElegibilidade(estado), contatoDaEquipe: estado.contatoDaEquipe };
}