houseassassin/twenty
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix typecheck on messaging (#16477)

Browse Source 
As per title
This commit is contained in:
Charles Bochet
2025-12-10 17:59:45 +01:00
committed by GitHub
parent b760e6df46
commit 2948880a0b
1 changed files with 21 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-group-email-messages.service.ts
+21 -20
View File
@@ -67,26 +67,27 @@ export class MessagingDeleteGroupEmailMessagesService {
let totalDeletedCount = 0;
while (isDefined(cursorId)) {
const batch = await messageChannelMessageAssociationRepository
.createQueryBuilder('mcma')
.select('mcma.id', 'mcmaId')
.addSelect('mcma.messageId', 'messageId')
.addSelect('mcma.messageExternalId', 'messageExternalId')
.addSelect('participant.handle', 'participantHandle')
.innerJoin('mcma.message', 'message')
.innerJoin(
'message.messageParticipants',
'participant',
'participant.role = :role',
{ role: MessageParticipantRole.FROM },
)
.where('mcma.messageChannelId = :messageChannelId', {
messageChannelId,
})
.andWhere('mcma.id >= :cursorId', { cursorId })
.orderBy('mcma.id', 'ASC')
.take(MESSAGE_CHANNEL_MESSAGE_ASSOCIATION_BATCH_SIZE)
.getRawMany<MessageBatchRawResult>();
const batch: MessageBatchRawResult[] =
await messageChannelMessageAssociationRepository
.createQueryBuilder('mcma')
.select('mcma.id', 'mcmaId')
.addSelect('mcma.messageId', 'messageId')
.addSelect('mcma.messageExternalId', 'messageExternalId')
.addSelect('participant.handle', 'participantHandle')
.innerJoin('mcma.message', 'message')
.innerJoin(
'message.messageParticipants',
'participant',
'participant.role = :role',
{ role: MessageParticipantRole.FROM },
)
.where('mcma.messageChannelId = :messageChannelId', {
messageChannelId,
})
.andWhere('mcma.id >= :cursorId', { cursorId })
.orderBy('mcma.id', 'ASC')
.take(MESSAGE_CHANNEL_MESSAGE_ASSOCIATION_BATCH_SIZE)
.getRawMany<MessageBatchRawResult>();
if (batch.length === 0) {
break;