@@ -156,6 +156,7 @@ import {
156156import { createProxyAgents } from '../../utils/proxy' ;
157157import { fetchLatestBaileysVersionV2 } from '../../utils/wa-version' ;
158158import { getJidUser , getUserGroup } from '../../utils/extract-id' ;
159+ import { getObjectUrl } from '../../integrations/minio/minio.utils' ;
159160
160161type InstanceQrCode = {
161162 count : number ;
@@ -1009,13 +1010,6 @@ export class WAStartupService {
10091010
10101011 messageRaw [ 'info' ] = { type } ;
10111012
1012- this . logger . log ( 'Type: ' + type ) ;
1013- console . log ( messageRaw ) ;
1014-
1015- this . ws . send ( this . instance . name , 'messages.upsert' , messageRaw ) ;
1016-
1017- await this . sendDataWebhook ( 'messagesUpsert' , messageRaw ) ;
1018-
10191013 if ( s3Service . BUCKET ?. ENABLE ) {
10201014 try {
10211015 const media = await this . getMediaMessage ( messageRaw , true ) ;
@@ -1038,14 +1032,15 @@ export class WAStartupService {
10381032 'custom-header-messageId' : messageRaw . keyId ,
10391033 } ) ;
10401034
1041- await this . repository . media . create ( {
1035+ const created = await this . repository . media . create ( {
10421036 data : {
10431037 messageId : messageRaw . id ,
10441038 type : mediaType ,
10451039 fileName : fullName ,
10461040 mimetype,
10471041 } ,
10481042 } ) ;
1043+ messageRaw . content [ 'mediaUrl' ] = await getObjectUrl ( created . fileName ) ;
10491044 }
10501045 } catch ( error ) {
10511046 this . logger . error ( [
@@ -1061,6 +1056,12 @@ export class WAStartupService {
10611056 } ) ;
10621057 }
10631058 }
1059+
1060+ this . ws . send ( this . instance . name , 'messages.upsert' , messageRaw ) ;
1061+ await this . sendDataWebhook ( 'messagesUpsert' , messageRaw ) ;
1062+
1063+ this . logger . log ( 'Type: ' + type ) ;
1064+ console . log ( messageRaw ) ;
10641065 }
10651066 } ,
10661067
0 commit comments