// @requires config.js cache.js
// Instancia bloqueia $env em Code nodes -- config vem do node "Config - Coordenador GLPI v2".
const config = parseConfig($('Config - Coordenador GLPI v2').first().json);
const now = Date.now();

// $input vem do Merge - Aguardar Memoria (so existe para GARANTIR que os candidatos e a
// memoria ja foram buscados antes deste node rodar); os dados de verdade sao lidos por nome.
const items = $('Code - Mesclar Contexto e Calcular Hash').all().map((item) => item.json); // { ticket, contextHash }
const memoryRows = $('Data Table - Buscar Memoria').all().map((item) => item.json);
const memoryByTicket = {};
for (const row of memoryRows) memoryByTicket[String(row.ticket_id)] = row;

const withDecision = items.map((item) => {
  const memory = memoryByTicket[String(item.ticket.id)] || null;
  const analysis = needsReanalysis({ memory, currentHash: item.contextHash, now });
  return { ticket: item.ticket, contextHash: item.contextHash, memory, needsAiReason: analysis.reason, needsAiRaw: analysis.needsAi };
});

const needingAi = withDecision
  .filter((item) => item.needsAiRaw)
  .sort((a, b) => (Number(b.ticket.score_criticidade) || 0) - (Number(a.ticket.score_criticidade) || 0));

const allowedIds = new Set(needingAi.slice(0, config.aiMaxCandidates).map((item) => item.ticket.id));

return withDecision.map((item) => {
  let resolucao;
  if (!item.needsAiRaw) {
    resolucao = 'cache';
  } else if (allowedIds.has(item.ticket.id)) {
    resolucao = 'ia';
  } else {
    resolucao = 'fallback_cap';
  }
  return {
    json: {
      ticket: item.ticket,
      contextHash: item.contextHash,
      memory: item.memory,
      needsAiReason: item.needsAiReason,
      resolucao,
      precisa_ia: resolucao === 'ia',
      config,
      now,
    },
  };
});