import { z } from 'zod';
import { camaraAPI } from '../../api/client.js';
import { cacheManager, createCacheKey } from '../../core/cache.js';
import { createPaginacaoResposta, IdSchema, DateSchema } from '../../core/schemas.js';
import { logToolCall } from '../../core/logging.js';
import { metricsCollector } from '../../core/metrics.js';
const BuscarOrgaosSchema = z.object({
sigla: z.string().optional(),
nome: z.string().optional(),
idTipoOrgao: IdSchema.optional(),
dataInicio: DateSchema.optional(),
dataFim: DateSchema.optional(),
pagina: z.number().int().positive().default(1).optional(),
itens: z.number().int().min(1).max(100).default(25).optional(),
ordem: z.enum(['ASC', 'DESC']).optional(),
ordenarPor: z.enum(['id', 'sigla', 'nome']).optional()
});
export type BuscarOrgaosParams = z.infer<typeof BuscarOrgaosSchema>;
export async function buscarOrgaos(params: BuscarOrgaosParams = {}) {
const startTime = Date.now();
try {
const validated = BuscarOrgaosSchema.parse(params);
const cacheKey = createCacheKey(validated);
const cached = cacheManager.get<any>('orgaos', cacheKey);
if (cached) return { ...cached, _metadata: { ...cached._metadata, cache: true } };
// A API da Câmara NÃO suporta o parâmetro 'nome' (retorna erro 400)
// Por isso, extraímos o 'nome' e filtramos localmente após a busca
const { nome, ...apiParams } = validated;
// Se apenas 'nome' foi passado, buscar mais itens para ter resultados para filtrar
// A Câmara tem mais de 1000 órgãos, então precisamos buscar mais para encontrar comissões específicas
const searchParams = nome && !validated.sigla
? { ...apiParams, itens: 500 } // Buscar mais para filtrar (CCTI está além dos 100 primeiros)
: apiParams;
const response = await camaraAPI.getWithPagination('/orgaos', searchParams);
// Filtrar por nome localmente (case-insensitive, busca parcial)
let orgaosFiltrados = response.dados;
if (nome) {
const nomeNormalizado = nome.toLowerCase().normalize('NFD').replace(/[\u0300-\u036f]/g, '');
orgaosFiltrados = response.dados.filter((orgao: any) => {
const nomeOrgao = (orgao.nome || '').toLowerCase().normalize('NFD').replace(/[\u0300-\u036f]/g, '');
const apelidoOrgao = (orgao.apelido || '').toLowerCase().normalize('NFD').replace(/[\u0300-\u036f]/g, '');
return nomeOrgao.includes(nomeNormalizado) || apelidoOrgao.includes(nomeNormalizado);
});
}
const result = {
paginacao: createPaginacaoResposta(validated.pagina || 1, validated.itens || 25, orgaosFiltrados.length),
orgaos: orgaosFiltrados,
_metadata: {
cache: false,
latencyMs: Date.now() - startTime,
apiVersion: 'v2',
...(nome ? { filteredByName: true, originalCount: response.dados.length } : {})
}
};
cacheManager.set('orgaos', cacheKey, result);
metricsCollector.incrementToolCall('buscar_orgaos');
logToolCall('buscar_orgaos', validated, Date.now() - startTime);
return result;
} catch (error) {
metricsCollector.incrementError('buscar_orgaos');
throw error;
}
}
export const buscarOrgaosTool = {
name: 'buscar_orgaos',
description: 'Busca órgãos da Câmara (comissões, mesas, conselhos, etc). Aceita busca por sigla (ex: CE para Comissão de Educação) ou por nome/apelido (busca parcial, ex: "educação" encontra "Comissão de Educação")',
inputSchema: {
type: 'object',
properties: {
sigla: { type: 'string', description: 'Sigla do órgão (ex: CE, CCJC, CFT). PREFERENCIAL se conhecida' },
nome: { type: 'string', description: 'Nome ou parte do nome do órgão (busca parcial case-insensitive, ex: "educação", "direitos humanos")' },
idTipoOrgao: { type: 'number', description: 'ID do tipo de órgão' },
dataInicio: { type: 'string', description: 'Data de início (YYYY-MM-DD)' },
dataFim: { type: 'string', description: 'Data de fim (YYYY-MM-DD)' },
pagina: { type: 'number', description: 'Número da página' },
itens: { type: 'number', description: 'Itens por página (1-100)' },
ordem: { type: 'string', enum: ['ASC', 'DESC'], description: 'Ordem de listagem' },
ordenarPor: { type: 'string', enum: ['id', 'sigla', 'nome'], description: 'Campo para ordenação' }
}
},
handler: buscarOrgaos
};
