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

fix(chat): melhora fixLegacySessions para buscar todas sessoes

Browse source 
- Busca todas as sessoes, nao apenas por index
- Corrige sessoes encerradas que tambem nao tem o campo
- Adiciona log das sessoes problematicas encontradas

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

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
rever-tecnologia 2025-12-15 16:30:45 -03:00
parent 0f3ba07a5e
commit f1833be1ea
1 changed files with 27 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

44
convex/liveChat.ts
View file

@ -902,28 +902,38 @@ export const fixLegacySessions = mutation({
handler: async (ctx) => { handler: async (ctx) => {
const now = Date.now() const now = Date.now()
// Buscar sessoes ativas que podem ter campos faltando // Buscar TODAS as sessoes (nao so por index) para garantir que pegamos as problematicas
const activeSessions = await ctx.db const allSessions = await ctx.db
.query("liveChatSessions") .query("liveChatSessions")
.withIndex("by_status_lastActivity", (q) => q.eq("status", "ACTIVE")) .take(500)
.take(100)
let fixed = 0 let fixed = 0
let ended = 0 let ended = 0
const problematic: string[] = []
for (const session of activeSessions) { for (const session of allSessions) {
// Se sessao nao tem lastAgentMessageAt, adiciona o valor de startedAt // Se sessao nao tem lastAgentMessageAt, adiciona o valor
if (session.lastAgentMessageAt === undefined) { if (session.lastAgentMessageAt === undefined) {
// Sessao muito antiga (mais de 24h) - encerrar problematic.push(session._id)
if (now - session.startedAt > 24 * 60 * 60 * 1000) {
await ctx.db.patch(session._id, { if (session.status === "ACTIVE") {
status: "ENDED", // Sessao ativa muito antiga (mais de 24h) - encerrar
endedAt: now, if (now - session.startedAt > 24 * 60 * 60 * 1000) {
lastAgentMessageAt: session.lastActivityAt ?? session.startedAt, await ctx.db.patch(session._id, {
}) status: "ENDED",
ended++ endedAt: now,
lastAgentMessageAt: session.lastActivityAt ?? session.startedAt,
})
ended++
} else {
// Sessao recente - apenas corrigir o campo
await ctx.db.patch(session._id, {
lastAgentMessageAt: session.lastActivityAt ?? session.startedAt,
})
fixed++
}
} else { } else {
// Sessao recente - apenas corrigir o campo // Sessao ja encerrada - apenas adicionar o campo
await ctx.db.patch(session._id, { await ctx.db.patch(session._id, {
lastAgentMessageAt: session.lastActivityAt ?? session.startedAt, lastAgentMessageAt: session.lastActivityAt ?? session.startedAt,
}) })
@ -932,8 +942,8 @@ export const fixLegacySessions = mutation({
} }
} }
console.log(`fixLegacySessions: fixed=${fixed}, ended=${ended}`) console.log(`fixLegacySessions: fixed=${fixed}, ended=${ended}, problematic=${problematic.join(",")}`)
return { fixed, ended, total: activeSessions.length } return { fixed, ended, total: allSessions.length, problematic }
}, },
}) })