NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-12-09 01:49:37 -06:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix: lint

Browse Source 
Descartei as mudanças nos arquivos que não me pertencem, dá uma folga aí, botinho
This commit is contained in:
moothz 2025-10-30 16:18:33 -03:00 committed by GitHub
parent a1393b679c
commit 8d1151d0a0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 20 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/utils/onWhatsappCache.ts
View File

@ -85,7 +85,7 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
} }
const altJidNormalized = normalizeJid(item.remoteJidAlt); const altJidNormalized = normalizeJid(item.remoteJidAlt);
const lidAltJid = (altJidNormalized && altJidNormalized.includes('@lid')) ? altJidNormalized : null; const lidAltJid = altJidNormalized && altJidNormalized.includes('@lid') ? altJidNormalized : null;
const baseJids = [remoteJid]; // Garante que o remoteJid esteja na lista inicial const baseJids = [remoteJid]; // Garante que o remoteJid esteja na lista inicial
if (lidAltJid) { if (lidAltJid) {
@ -107,17 +107,19 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
}, },
}); });
logger.verbose(`[saveOnWhatsappCache] Register exists for [${expandedJids.join(",")}]? => ${existingRecord ? existingRecord.remoteJid : 'Not found'}`); logger.verbose(
`[saveOnWhatsappCache] Register exists for [${expandedJids.join(',')}]? => ${existingRecord ? existingRecord.remoteJid : 'Not found'}`,
);
// 2. Unifica todos os JIDs usando um Set para garantir valores únicos // 2. Unifica todos os JIDs usando um Set para garantir valores únicos
const finalJidOptions = new Set(expandedJids); const finalJidOptions = new Set(expandedJids);
if (lidAltJid) { if (lidAltJid) {
finalJidOptions.add(lidAltJid); finalJidOptions.add(lidAltJid);
} }
if (existingRecord?.jidOptions) { if (existingRecord?.jidOptions) {
existingRecord.jidOptions.split(',').forEach(jid => finalJidOptions.add(jid)); existingRecord.jidOptions.split(',').forEach((jid) => finalJidOptions.add(jid));
} }
// 3. Prepara o payload final // 3. Prepara o payload final
@ -135,34 +137,37 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
// 4. Decide entre Criar ou Atualizar // 4. Decide entre Criar ou Atualizar
if (existingRecord) { if (existingRecord) {
// Compara a string de JIDs ordenada existente com a nova // Compara a string de JIDs ordenada existente com a nova
const existingJidOptionsString = existingRecord.jidOptions const existingJidOptionsString = existingRecord.jidOptions
? existingRecord.jidOptions.split(',').sort().join(',') ? existingRecord.jidOptions.split(',').sort().join(',')
: ''; : '';
const isDataSame = existingRecord.remoteJid === dataPayload.remoteJid && const isDataSame =
existingJidOptionsString === dataPayload.jidOptions && existingRecord.remoteJid === dataPayload.remoteJid &&
existingRecord.lid === dataPayload.lid; existingJidOptionsString === dataPayload.jidOptions &&
existingRecord.lid === dataPayload.lid;
if (isDataSame) { if (isDataSame) {
logger.verbose(`[saveOnWhatsappCache] Data for ${remoteJid} is already up-to-date. Skipping update.`); logger.verbose(`[saveOnWhatsappCache] Data for ${remoteJid} is already up-to-date. Skipping update.`);
return; // Pula para o próximo item return; // Pula para o próximo item
} }
// Os dados são diferentes, então atualiza // Os dados são diferentes, então atualiza
logger.verbose(`[saveOnWhatsappCache] Register exists, updating: remoteJid=${remoteJid}, jidOptions=${dataPayload.jidOptions}, lid=${dataPayload.lid}`); logger.verbose(
`[saveOnWhatsappCache] Register exists, updating: remoteJid=${remoteJid}, jidOptions=${dataPayload.jidOptions}, lid=${dataPayload.lid}`,
);
await prismaRepository.isOnWhatsapp.update({ await prismaRepository.isOnWhatsapp.update({
where: { id: existingRecord.id }, where: { id: existingRecord.id },
data: dataPayload, data: dataPayload,
}); });
} else { } else {
// Cria nova entrada // Cria nova entrada
logger.verbose(`[saveOnWhatsappCache] Register does not exist, creating: remoteJid=${remoteJid}, jidOptions=${dataPayload.jidOptions}, lid=${dataPayload.lid}`); logger.verbose(
`[saveOnWhatsappCache] Register does not exist, creating: remoteJid=${remoteJid}, jidOptions=${dataPayload.jidOptions}, lid=${dataPayload.lid}`,
);
await prismaRepository.isOnWhatsapp.create({ await prismaRepository.isOnWhatsapp.create({
data: dataPayload, data: dataPayload,
}); });
} }
} catch (e) { } catch (e) {
// Loga o erro mas não para a execução dos outros promises // Loga o erro mas não para a execução dos outros promises
logger.error(`[saveOnWhatsappCache] Error processing item for ${item.remoteJid}: `, e); logger.error(`[saveOnWhatsappCache] Error processing item for ${item.remoteJid}: `, e);