From e57cc2587cae107da97c112a86b99e2e97c877e7 Mon Sep 17 00:00:00 2001
From: devlikepro <waha@devlike.pro>
Date: Mon, 14 Jul 2025 11:31:50 +0700
Subject: [PATCH] [core] WEBJS - share media properly

---
 src/core/engines/webjs/session.webjs.core.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/core/engines/webjs/session.webjs.core.ts b/src/core/engines/webjs/session.webjs.core.ts
index 06a91205..4db4af16 100644
--- a/src/core/engines/webjs/session.webjs.core.ts
+++ b/src/core/engines/webjs/session.webjs.core.ts
@@ -1426,12 +1426,14 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
     const messageReceived$ = fromEvent(this.whatsapp, Events.MESSAGE_RECEIVED);
     const messagesFromOthers$ = messageReceived$.pipe(
       mergeMap((msg: any) => this.processIncomingMessage(msg, true)),
+      share(),
     );
     this.events2.get(WAHAEvents.MESSAGE).switch(messagesFromOthers$);
 
     const messageCreate$ = fromEvent(this.whatsapp, Events.MESSAGE_CREATE);
     const messagesFromAll$ = messageCreate$.pipe(
       mergeMap((msg: any) => this.processIncomingMessage(msg, true)),
+      share(),
     );
     this.events2.get(WAHAEvents.MESSAGE_ANY).switch(messagesFromAll$);
 
@@ -1440,7 +1442,8 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
       Events.MESSAGE_CIPHERTEXT,
     );
     const messagesWaiting$ = messageCiphertext$.pipe(
-      mergeMap((msg: any) => this.processIncomingMessage(msg, true)),
+      mergeMap((msg: any) => this.processIncomingMessage(msg, false)),
+      share(),
     );
     this.events2.get(WAHAEvents.MESSAGE_WAITING).switch(messagesWaiting$);