@@ -85,7 +85,7 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
8585 }
8686
8787 const altJidNormalized = normalizeJid ( item . remoteJidAlt ) ;
88- const lidAltJid = ( altJidNormalized && altJidNormalized . includes ( '@lid' ) ) ? altJidNormalized : null ;
88+ const lidAltJid = altJidNormalized && altJidNormalized . includes ( '@lid' ) ? altJidNormalized : null ;
8989
9090 const baseJids = [ remoteJid ] ; // Garante que o remoteJid esteja na lista inicial
9191 if ( lidAltJid ) {
@@ -107,17 +107,19 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
107107 } ,
108108 } ) ;
109109
110- logger . verbose ( `[saveOnWhatsappCache] Register exists for [${ expandedJids . join ( "," ) } ]? => ${ existingRecord ? existingRecord . remoteJid : 'Not found' } ` ) ;
111-
110+ logger . verbose (
111+ `[saveOnWhatsappCache] Register exists for [${ expandedJids . join ( ',' ) } ]? => ${ existingRecord ? existingRecord . remoteJid : 'Not found' } ` ,
112+ ) ;
113+
112114 // 2. Unifica todos os JIDs usando um Set para garantir valores únicos
113115 const finalJidOptions = new Set ( expandedJids ) ;
114116
115117 if ( lidAltJid ) {
116118 finalJidOptions . add ( lidAltJid ) ;
117119 }
118-
120+
119121 if ( existingRecord ?. jidOptions ) {
120- existingRecord . jidOptions . split ( ',' ) . forEach ( jid => finalJidOptions . add ( jid ) ) ;
122+ existingRecord . jidOptions . split ( ',' ) . forEach ( ( jid ) => finalJidOptions . add ( jid ) ) ;
121123 }
122124
123125 // 3. Prepara o payload final
@@ -135,34 +137,37 @@ export async function saveOnWhatsappCache(data: ISaveOnWhatsappCacheParams[]) {
135137 // 4. Decide entre Criar ou Atualizar
136138 if ( existingRecord ) {
137139 // Compara a string de JIDs ordenada existente com a nova
138- const existingJidOptionsString = existingRecord . jidOptions
139- ? existingRecord . jidOptions . split ( ',' ) . sort ( ) . join ( ',' )
140+ const existingJidOptionsString = existingRecord . jidOptions
141+ ? existingRecord . jidOptions . split ( ',' ) . sort ( ) . join ( ',' )
140142 : '' ;
141143
142- const isDataSame = existingRecord . remoteJid === dataPayload . remoteJid &&
143- existingJidOptionsString === dataPayload . jidOptions &&
144- existingRecord . lid === dataPayload . lid ;
144+ const isDataSame =
145+ existingRecord . remoteJid === dataPayload . remoteJid &&
146+ existingJidOptionsString === dataPayload . jidOptions &&
147+ existingRecord . lid === dataPayload . lid ;
145148
146149 if ( isDataSame ) {
147150 logger . verbose ( `[saveOnWhatsappCache] Data for ${ remoteJid } is already up-to-date. Skipping update.` ) ;
148151 return ; // Pula para o próximo item
149152 }
150-
153+
151154 // Os dados são diferentes, então atualiza
152- logger . verbose ( `[saveOnWhatsappCache] Register exists, updating: remoteJid=${ remoteJid } , jidOptions=${ dataPayload . jidOptions } , lid=${ dataPayload . lid } ` ) ;
155+ logger . verbose (
156+ `[saveOnWhatsappCache] Register exists, updating: remoteJid=${ remoteJid } , jidOptions=${ dataPayload . jidOptions } , lid=${ dataPayload . lid } ` ,
157+ ) ;
153158 await prismaRepository . isOnWhatsapp . update ( {
154159 where : { id : existingRecord . id } ,
155160 data : dataPayload ,
156161 } ) ;
157-
158162 } else {
159163 // Cria nova entrada
160- logger . verbose ( `[saveOnWhatsappCache] Register does not exist, creating: remoteJid=${ remoteJid } , jidOptions=${ dataPayload . jidOptions } , lid=${ dataPayload . lid } ` ) ;
164+ logger . verbose (
165+ `[saveOnWhatsappCache] Register does not exist, creating: remoteJid=${ remoteJid } , jidOptions=${ dataPayload . jidOptions } , lid=${ dataPayload . lid } ` ,
166+ ) ;
161167 await prismaRepository . isOnWhatsapp . create ( {
162168 data : dataPayload ,
163169 } ) ;
164170 }
165-
166171 } catch ( e ) {
167172 // Loga o erro mas não para a execução dos outros promises
168173 logger . error ( `[saveOnWhatsappCache] Error processing item for ${ item . remoteJid } : ` , e ) ;
0 commit comments