NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-25 01:48:39 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: writing over 20s now loops until finished

Browse Source
This commit is contained in:
Davidson Gomes 2024-02-28 13:47:32 -03:00
parent e2c67d7dae
commit bca5ec6482
1 changed files with 29 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/whatsapp/services/whatsapp.baileys.service.ts
View File

@ -32,6 +32,7 @@ import makeWASocket, {
WAMediaUpload, WAMediaUpload,
WAMessage, WAMessage,
WAMessageUpdate, WAMessageUpdate,
WAPresence,
WASocket, WASocket,
} from '@whiskeysockets/baileys'; } from '@whiskeysockets/baileys';
import { Label } from '@whiskeysockets/baileys/lib/Types/Label'; import { Label } from '@whiskeysockets/baileys/lib/Types/Label';
@ -1622,17 +1623,37 @@ export class BaileysStartupService extends WAStartupService {
if (options?.delay) { if (options?.delay) {
this.logger.verbose('Delaying message'); this.logger.verbose('Delaying message');
await this.client.presenceSubscribe(sender); if (options.delay > 20000) {
this.logger.verbose('Subscribing to presence'); let remainingDelay = options.delay;
while (remainingDelay > 20000) {
await this.client.presenceSubscribe(sender);
await this.client.sendPresenceUpdate(options?.presence ?? 'composing', sender); await this.client.sendPresenceUpdate((options.presence as WAPresence) ?? 'composing', sender);
this.logger.verbose('Sending presence update: ' + options?.presence ?? 'composing');
await delay(options.delay); await delay(20000);
this.logger.verbose('Set delay: ' + options.delay);
await this.client.sendPresenceUpdate('paused', sender); await this.client.sendPresenceUpdate('paused', sender);
this.logger.verbose('Sending presence update: paused');
remainingDelay -= 20000;
}
if (remainingDelay > 0) {
await this.client.presenceSubscribe(sender);
await this.client.sendPresenceUpdate((options.presence as WAPresence) ?? 'composing', sender);
await delay(remainingDelay);
await this.client.sendPresenceUpdate('paused', sender);
}
} else {
await this.client.presenceSubscribe(sender);
await this.client.sendPresenceUpdate((options.presence as WAPresence) ?? 'composing', sender);
await delay(options.delay);
await this.client.sendPresenceUpdate('paused', sender);
}
} }
const linkPreview = options?.linkPreview != false ? undefined : false; const linkPreview = options?.linkPreview != false ? undefined : false;