@@ -381,7 +381,7 @@ export class BaileysStartupService extends ChannelStartupService {
381381 qrcodeTerminal . generate ( qr , { small : true } , ( qrcode ) =>
382382 this . logger . log (
383383 `\n{ instance: ${ this . instance . name } pairingCode: ${ this . instance . qrcode . pairingCode } , qrcodeCount: ${ this . instance . qrcode . count } }\n` +
384- qrcode ,
384+ qrcode ,
385385 ) ,
386386 ) ;
387387
@@ -978,16 +978,16 @@ export class BaileysStartupService extends ChannelStartupService {
978978
979979 const messagesRepository : Set < string > = new Set (
980980 chatwootImport . getRepositoryMessagesCache ( instance ) ??
981- (
982- await this . prismaRepository . message . findMany ( {
983- select : { key : true } ,
984- where : { instanceId : this . instanceId } ,
985- } )
986- ) . map ( ( message ) => {
987- const key = message . key as { id : string } ;
988-
989- return key . id ;
990- } ) ,
981+ (
982+ await this . prismaRepository . message . findMany ( {
983+ select : { key : true } ,
984+ where : { instanceId : this . instanceId } ,
985+ } )
986+ ) . map ( ( message ) => {
987+ const key = message . key as { id : string } ;
988+
989+ return key . id ;
990+ } ) ,
991991 ) ;
992992
993993 if ( chatwootImport . getRepositoryMessagesCache ( instance ) === null ) {
@@ -4726,12 +4726,7 @@ export class BaileysStartupService extends ChannelStartupService {
47264726 }
47274727
47284728 public async fetchMessages ( query : Query < Message > ) {
4729- const keyFilters = query ?. where ?. key as {
4730- id ?: string ;
4731- fromMe ?: boolean ;
4732- remoteJid ?: string ;
4733- participants ?: string ;
4734- } ;
4729+ const keyFilters = query ?. where ?. key as ExtendedIMessageKey ;
47354730
47364731 const timestampFilter = { } ;
47374732 if ( query ?. where ?. messageTimestamp ) {
@@ -4754,7 +4749,13 @@ export class BaileysStartupService extends ChannelStartupService {
47544749 keyFilters ?. id ? { key : { path : [ 'id' ] , equals : keyFilters ?. id } } : { } ,
47554750 keyFilters ?. fromMe ? { key : { path : [ 'fromMe' ] , equals : keyFilters ?. fromMe } } : { } ,
47564751 keyFilters ?. remoteJid ? { key : { path : [ 'remoteJid' ] , equals : keyFilters ?. remoteJid } } : { } ,
4757- keyFilters ?. participants ? { key : { path : [ 'participants' ] , equals : keyFilters ?. participants } } : { } ,
4752+ keyFilters ?. participant ? { key : { path : [ 'participant' ] , equals : keyFilters ?. participant } } : { } ,
4753+ {
4754+ OR : [
4755+ keyFilters ?. remoteJid ? { key : { path : [ 'remoteJid' ] , equals : keyFilters ?. remoteJid } } : { } ,
4756+ keyFilters ?. senderPn ? { key : { path : [ 'senderPn' ] , equals : keyFilters ?. senderPn } } : { } ,
4757+ ] ,
4758+ } ,
47584759 ] ,
47594760 } ,
47604761 } ) ;
@@ -4778,7 +4779,13 @@ export class BaileysStartupService extends ChannelStartupService {
47784779 keyFilters ?. id ? { key : { path : [ 'id' ] , equals : keyFilters ?. id } } : { } ,
47794780 keyFilters ?. fromMe ? { key : { path : [ 'fromMe' ] , equals : keyFilters ?. fromMe } } : { } ,
47804781 keyFilters ?. remoteJid ? { key : { path : [ 'remoteJid' ] , equals : keyFilters ?. remoteJid } } : { } ,
4781- keyFilters ?. participants ? { key : { path : [ 'participants' ] , equals : keyFilters ?. participants } } : { } ,
4782+ keyFilters ?. participant ? { key : { path : [ 'participant' ] , equals : keyFilters ?. participant } } : { } ,
4783+ {
4784+ OR : [
4785+ keyFilters ?. remoteJid ? { key : { path : [ 'remoteJid' ] , equals : keyFilters ?. remoteJid } } : { } ,
4786+ keyFilters ?. senderPn ? { key : { path : [ 'senderPn' ] , equals : keyFilters ?. senderPn } } : { } ,
4787+ ] ,
4788+ } ,
47824789 ] ,
47834790 } ,
47844791 orderBy : { messageTimestamp : 'desc' } ,
0 commit comments