From 92373812c122f51908e7f7d2ef62c1e1dff746a4 Mon Sep 17 00:00:00 2001 From: Felipe Medeiros Date: Fri, 20 Sep 2024 17:37:37 -0300 Subject: [PATCH] =?UTF-8?q?refactor:=20simplifica=20fun=C3=A7=C3=A3o=20sen?= =?UTF-8?q?dMessage=20no=20Baileys?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Remove lógica duplicada de salvar mensagens no banco de dados e upload de mídia para o S3 - Padroniza o retorno da função, utilizando "messageRaw" - Simplifica a validação da instância - Elimina a verificação de configuração do S3 para envio de mídias --- .../whatsapp/whatsapp.baileys.service.ts | 51 +------------------ 1 file changed, 1 insertion(+), 50 deletions(-) diff --git a/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts b/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts index 6546db6e..17ad028f 100644 --- a/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts +++ b/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts @@ -1982,56 +1982,7 @@ export class BaileysStartupService extends ChannelStartupService { delete messageRaw.message.extendedTextMessage; } - if (this.configService.get('DATABASE').SAVE_DATA.NEW_MESSAGE) { - const msg = await this.prismaRepository.message.create({ - data: messageRaw, - }); - - if (isMedia && this.configService.get('S3').ENABLE) { - try { - const message: any = messageSent; - const media = await this.getBase64FromMediaMessage( - { - message, - }, - true, - ); - - const { buffer, mediaType, fileName, size } = media; - - const mimetype = mime.getType(fileName).toString(); - - const fullName = join(`${this.instance.id}`, messageSent.key.remoteJid, mediaType, fileName); - - await s3Service.uploadFile(fullName, buffer, size.fileLength?.low, { - 'Content-Type': mimetype, - }); - - await this.prismaRepository.media.create({ - data: { - messageId: msg.id, - instanceId: this.instanceId, - type: mediaType, - fileName: fullName, - mimetype, - }, - }); - - const mediaUrl = await s3Service.getObjectUrl(fullName); - - messageRaw.message.mediaUrl = mediaUrl; - - await this.prismaRepository.message.update({ - where: { id: msg.id }, - data: messageRaw, - }); - } catch (error) { - this.logger.error(['Error on upload file to minio', error?.message, error?.stack]); - } - } - } - - if (isMedia && !this.configService.get('S3').ENABLE) { + if (isMedia) { const buffer = await downloadMediaMessage( { key: messageSent.key, message: messageSent?.message }, 'buffer',