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

chore: increase app state sync timeout

Browse Source
This commit is contained in:
Adhiraj Singh
2022-06-24 11:53:01 +05:30
parent ee7ed1d4e5
commit 4ff858ab82
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -9,6 +9,8 @@ import { areJidsSameUser, BinaryNode, BinaryNodeAttributes, getAllBinaryNodeChil
import { makeChatsSocket } from './chats' import { makeChatsSocket } from './chats'
import { extractGroupMetadata } from './groups' import { extractGroupMetadata } from './groups'
const APP_STATE_SYNC_TIMEOUT_MS = 10_000
export const makeMessagesRecvSocket = (config: SocketConfig) => { export const makeMessagesRecvSocket = (config: SocketConfig) => {
const { const {
logger, logger,
@@ -38,11 +40,12 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
/** this mutex ensures that each retryRequest will wait for the previous one to finish */ /** this mutex ensures that each retryRequest will wait for the previous one to finish */
const retryMutex = makeMutex() const retryMutex = makeMutex()
/** cache to ensure new history sync events do not have duplicate items */
const historyCache = new Set<string>() const historyCache = new Set<string>()
let recvChats: InitialReceivedChatsState = { } let recvChats: InitialReceivedChatsState = { }
const appStateSyncTimeout = debouncedTimeout( const appStateSyncTimeout = debouncedTimeout(
6_000, APP_STATE_SYNC_TIMEOUT_MS,
async() => { async() => {
logger.info( logger.info(
{ recvChats: Object.keys(recvChats).length }, { recvChats: Object.keys(recvChats).length },