diff --git a/src/core/engines/noweb/session.noweb.core.ts b/src/core/engines/noweb/session.noweb.core.ts index b0ab0351..6d5d9e6a 100644 --- a/src/core/engines/noweb/session.noweb.core.ts +++ b/src/core/engines/noweb/session.noweb.core.ts @@ -1471,7 +1471,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession { protected downloadMedia(message) { const processor = new EngineMediaProcessor(this); - return this.mediaManager.processMedia(processor, message); + return this.mediaManager.processMedia(processor, message, this.name); } } diff --git a/src/core/engines/venom/session.venom.core.ts b/src/core/engines/venom/session.venom.core.ts index a03c6ac4..c9bf6d1a 100644 --- a/src/core/engines/venom/session.venom.core.ts +++ b/src/core/engines/venom/session.venom.core.ts @@ -248,7 +248,7 @@ export class WhatsappSessionVenomCore extends WhatsappSession { protected downloadMedia(message: Message) { const processor = new EngineMediaProcessor(this); - return this.mediaManager.processMedia(processor, message); + return this.mediaManager.processMedia(processor, message, this.name); } private processIncomingMessage(message: Message) { diff --git a/src/core/engines/webjs/session.webjs.core.ts b/src/core/engines/webjs/session.webjs.core.ts index 1ce08bc8..ffa1865a 100644 --- a/src/core/engines/webjs/session.webjs.core.ts +++ b/src/core/engines/webjs/session.webjs.core.ts @@ -971,7 +971,7 @@ export class WhatsappSessionWebJSCore extends WhatsappSession { protected downloadMedia(message: Message) { const processor = new EngineMediaProcessor(); - return this.mediaManager.processMedia(processor, message); + return this.mediaManager.processMedia(processor, message, this.name); } } diff --git a/src/core/media/IMediaManager.ts b/src/core/media/IMediaManager.ts index 5e3c31cb..9770e36d 100644 --- a/src/core/media/IMediaManager.ts +++ b/src/core/media/IMediaManager.ts @@ -8,6 +8,7 @@ interface IMediaManager { processMedia( processor: IMediaEngineProcessor, message: Message, + session: string, ): Promise; } diff --git a/src/core/media/IMediaStorage.ts b/src/core/media/IMediaStorage.ts index 8603a19f..e03a4739 100644 --- a/src/core/media/IMediaStorage.ts +++ b/src/core/media/IMediaStorage.ts @@ -13,6 +13,7 @@ interface File { } export interface MediaData { + session: string; message: Message; file: File; } diff --git a/src/core/media/MediaManagerCore.ts b/src/core/media/MediaManagerCore.ts index f0c6d64d..7dcc48b3 100644 --- a/src/core/media/MediaManagerCore.ts +++ b/src/core/media/MediaManagerCore.ts @@ -13,12 +13,14 @@ export class MediaManagerCore implements IMediaManager { async processMedia( processor: IMediaEngineProcessor, message: Message, + session: string, ): Promise { if (!processor.hasMedia(message)) { return message; } const mimetype = ''; const mediaData: MediaData = { + session: session, message: { id: '', },