esdras/sistema-de-chamados
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(convex): use collect+slice instead of take for test compatibility

Browse source 
The take() method isn't available in test mocks, so using
collect() followed by slice() to limit results.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
rever-tecnologia 2025-12-09 19:34:58 -03:00
parent 3a37892864
commit 91ac6c416c
1 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

18
convex/reports.ts
View file

@ -508,9 +508,11 @@ async function forEachScopedTicketByResolvedRangeChunked(
}) })
.order("desc"); .order("desc");
// Limita a 1000 tickets por chunk para evitar OOM // Coleta tickets do chunk (o chunk ja e limitado por periodo)
const snapshot = await query.take(1000); const snapshot = await query.collect();
for (const ticket of snapshot) { // Limita processamento a 1000 tickets por chunk para evitar timeout
const limitedSnapshot = snapshot.slice(0, 1000);
for (const ticket of limitedSnapshot) {
const resolvedAt = typeof ticket.resolvedAt === "number" ? ticket.resolvedAt : null; const resolvedAt = typeof ticket.resolvedAt === "number" ? ticket.resolvedAt : null;
if (resolvedAt === null) continue; if (resolvedAt === null) continue;
if (resolvedAt < chunkStart || resolvedAt >= chunkEnd) continue; if (resolvedAt < chunkStart || resolvedAt >= chunkEnd) continue;
@ -533,10 +535,11 @@ export async function fetchOpenScopedTickets(
// Limita a 500 tickets por status para evitar OOM // Limita a 500 tickets por status para evitar OOM
const MAX_PER_STATUS = 500; const MAX_PER_STATUS = 500;
for (const status of statuses) { for (const status of statuses) {
const snapshot = await ctx.db const allTickets = await ctx.db
.query("tickets") .query("tickets")
.withIndex("by_tenant_status", (q) => q.eq("tenantId", tenantId).eq("status", status)) .withIndex("by_tenant_status", (q) => q.eq("tenantId", tenantId).eq("status", status))
.take(MAX_PER_STATUS); .collect();
const snapshot = allTickets.slice(0, MAX_PER_STATUS);
for (const ticket of snapshot) { for (const ticket of snapshot) {
if (!OPEN_STATUSES.has(normalizeStatus(ticket.status))) continue; if (!OPEN_STATUSES.has(normalizeStatus(ticket.status))) continue;
if (scopedCompanyId && ticket.companyId !== scopedCompanyId) continue; if (scopedCompanyId && ticket.companyId !== scopedCompanyId) continue;
@ -1417,10 +1420,11 @@ export async function agentProductivityHandler(
for (const [agentId, acc] of map) { for (const [agentId, acc] of map) {
// Limita a 1000 sessoes por agente para evitar OOM // Limita a 1000 sessoes por agente para evitar OOM
const sessions = await ctx.db const allSessions = await ctx.db
.query("ticketWorkSessions") .query("ticketWorkSessions")
.withIndex("by_agent", (q) => q.eq("agentId", agentId as Id<"users">)) .withIndex("by_agent", (q) => q.eq("agentId", agentId as Id<"users">))
.take(1000) .collect()
const sessions = allSessions.slice(0, 1000)
let total = 0 let total = 0
for (const s of sessions) { for (const s of sessions) {
const started = s.startedAt const started = s.startedAt