[core] message.ack.group

This commit is contained in:
devlikepro committed 2025-12-17 16:15:37 +07:00
1 parent 1a91e7d722
commit b71d83ce48
6 files changed
+14 -11

No files matched your search

+3 -4
View File
@@ -548,9 +548,8 @@ export class WhatsappSessionGoWSCore extends WhatsappSession {
onlyEvent(WhatsMeowEvent.RECEIPT),
filter((r: any) => this.jids.include(r?.Chat)),
);
const [receiptGroups$, receiptContacts$] = partition(
receipt$,
(r: any) => isJidGroup(r?.Chat || r?.Info?.Chat),
const [receiptGroups$, receiptContacts$] = partition(receipt$, (r: any) =>
isJidGroup(r?.Chat || r?.Info?.Chat),
);
const messageAckGroups$ = receiptGroups$.pipe(
mergeMap(this.receiptToMessageAck.bind(this)),
@@ -560,7 +559,7 @@ export class WhatsappSessionGoWSCore extends WhatsappSession {
mergeMap(this.receiptToMessageAck.bind(this)),
DistinctAck(),
);
this.events2.get(WAHAEvents.GROUP_ACK).switch(messageAckGroups$);
this.events2.get(WAHAEvents.MESSAGE_ACK_GROUP).switch(messageAckGroups$);
this.events2.get(WAHAEvents.MESSAGE_ACK).switch(messageAckContacts$);
const messageReactions$ = messages$.pipe(
+3 -1
View File
@@ -2078,7 +2078,9 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
const messageAckGroupsFinal$ = messageAckGroups$.pipe(DistinctAck());
this.events2.get(WAHAEvents.MESSAGE_ACK).switch(messageAckDirectFinal$);
this.events2.get(WAHAEvents.GROUP_ACK).switch(messageAckGroupsFinal$);
this.events2
.get(WAHAEvents.MESSAGE_ACK_GROUP)
.switch(messageAckGroupsFinal$);
//
// Other
+3 -1
View File
@@ -1703,7 +1703,9 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
const messageAckGroupsFinal$ = messageAckGroups$.pipe(DistinctAck());
this.events2.get(WAHAEvents.MESSAGE_ACK).switch(messageAckDMFinal$);
this.events2.get(WAHAEvents.GROUP_ACK).switch(messageAckGroupsFinal$);
this.events2
.get(WAHAEvents.MESSAGE_ACK_GROUP)
.switch(messageAckGroupsFinal$);
//
// Others
+1 -1
View File
@@ -6,6 +6,7 @@ export enum WAHAEvents {
MESSAGE_REACTION = 'message.reaction',
MESSAGE_ANY = 'message.any',
MESSAGE_ACK = 'message.ack',
MESSAGE_ACK_GROUP = 'message.ack.group',
MESSAGE_WAITING = 'message.waiting',
MESSAGE_REVOKED = 'message.revoked',
MESSAGE_EDITED = 'message.edited',
@@ -16,7 +17,6 @@ export enum WAHAEvents {
GROUP_V2_LEAVE = 'group.v2.leave',
GROUP_V2_UPDATE = 'group.v2.update',
GROUP_V2_PARTICIPANTS = 'group.v2.participants',
GROUP_ACK = 'group.ack',
PRESENCE_UPDATE = 'presence.update',
POLL_VOTE = 'poll.vote',
POLL_VOTE_FAILED = 'poll.vote.failed',
+2 -2
View File
@@ -214,12 +214,12 @@ export class WAHAWebhookMessageAck extends WAHAWebhook {
payload: WAMessageAckBody;
}
export class WAHAWebhookGroupAck extends WAHAWebhook {
export class WAHAWebhookMessageAckGroup extends WAHAWebhook {
@ApiProperty({
description:
'Receive events when participants in a group read or play messages.',
})
event = WAHAEvents.GROUP_ACK;
event = WAHAEvents.MESSAGE_ACK_GROUP;
payload: WAMessageAckBody;
}
+2 -2
View File
@@ -21,7 +21,7 @@ import {
WAHAWebhookMessage,
WAHAWebhookMessageAck,
WAHAWebhookMessageAny,
WAHAWebhookGroupAck,
WAHAWebhookMessageAckGroup,
WAHAWebhookMessageEdited,
WAHAWebhookMessageReaction,
WAHAWebhookMessageRevoked,
@@ -38,7 +38,7 @@ const WAHA_WEBHOOKS = [
WAHAWebhookMessageReaction,
WAHAWebhookMessageAny,
WAHAWebhookMessageAck,
WAHAWebhookGroupAck,
WAHAWebhookMessageAckGroup,
WAHAWebhookMessageRevoked,
WAHAWebhookMessageEdited,
WebhookGroupV2Join,