franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: correctly handle retry from own devices

Browse Source
This commit is contained in:
Adhiraj Singh
2021-12-14 00:31:29 +05:30
parent d15dd6e1d2
commit ef1b01b6df
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/Socket/messages-recv.ts
View File

@@ -494,9 +494,11 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
const handleReceipt = async(node: BinaryNode) => { const handleReceipt = async(node: BinaryNode) => {
let shouldAck = true let shouldAck = true
const { attrs, content } = node const { attrs, content } = node
const isNodeFromMe = areJidsSameUser(attrs.from, authState.creds.me?.id)
const remoteJid = attrs.recipient || attrs.from const remoteJid = attrs.recipient || attrs.from
const fromMe = attrs.recipient ? false : true const fromMe = isNodeFromMe || (attrs.recipient ? false : true)
const ids = [attrs.id] const ids = [attrs.id]
if(Array.isArray(content)) { if(Array.isArray(content)) {
@@ -512,7 +514,7 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
} }
const status = getStatusFromReceiptType(attrs.type) const status = getStatusFromReceiptType(attrs.type)
if(typeof status !== 'undefined' && !areJidsSameUser(attrs.from, authState.creds.me?.id)) { if(typeof status !== 'undefined' && !isNodeFromMe) {
ev.emit('messages.update', ids.map(id => ({ ev.emit('messages.update', ids.map(id => ({
key: { ...key, id }, key: { ...key, id },
update: { status } update: { status }
@@ -520,6 +522,8 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
} }
if(attrs.type === 'retry') { if(attrs.type === 'retry') {
// correctly set who is asking for the retry
key.participant = key.participant || attrs.from
if(key.fromMe) { if(key.fromMe) {
try { try {
logger.debug({ attrs }, 'recv retry request') logger.debug({ attrs }, 'recv retry request')