diff --git a/src/Defaults/index.ts b/src/Defaults/index.ts index 498216d..aea5621 100644 --- a/src/Defaults/index.ts +++ b/src/Defaults/index.ts @@ -99,4 +99,11 @@ export const MEDIA_KEYS = Object.keys(MEDIA_PATH_MAP) as MediaType[] export const MIN_PREKEY_COUNT = 5 -export const INITIAL_PREKEY_COUNT = 30 \ No newline at end of file +export const INITIAL_PREKEY_COUNT = 30 + +export const DEFAULT_CACHE_TTLS = { + SIGNAL_STORE: 5 * 60, // 5 minutes + MSG_RETRY: 60 * 60, // 1 hour + CALL_OFFER: 5 * 60, // 5 minutes + USER_DEVICES: 5 * 60, // 5 minutes +} \ No newline at end of file diff --git a/src/Socket/messages-recv.ts b/src/Socket/messages-recv.ts index ce1fc11..e580ca2 100644 --- a/src/Socket/messages-recv.ts +++ b/src/Socket/messages-recv.ts @@ -1,7 +1,7 @@ import NodeCache from 'node-cache' import { proto } from '../../WAProto' -import { KEY_BUNDLE_TYPE, MIN_PREKEY_COUNT } from '../Defaults' +import { DEFAULT_CACHE_TTLS, KEY_BUNDLE_TYPE, MIN_PREKEY_COUNT } from '../Defaults' import { MessageReceiptType, MessageRelayOptions, MessageUserReceipt, SocketConfig, WACallEvent, WAMessageKey, WAMessageStubType, WAPatchName } from '../Types' import { decodeMediaRetryNode, decryptMessageNode, delay, encodeBigEndian, encodeSignedDeviceIdentity, getCallStatusFromNode, getHistoryMsg, getNextPreKeys, getStatusFromReceiptType, unixTimestampSeconds, xmppPreKey, xmppSignedPreKey } from '../Utils' import { makeMutex } from '../Utils/make-mutex' @@ -38,11 +38,11 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { const retryMutex = makeMutex() const msgRetryCache = config.msgRetryCounterCache || new NodeCache({ - stdTTL: 60 * 60, // 1 hour + stdTTL: DEFAULT_CACHE_TTLS.MSG_RETRY, // 1 hour useClones: false }) const callOfferCache = config.callOfferCache || new NodeCache({ - stdTTL: 5 * 60, // 5 mins + stdTTL: DEFAULT_CACHE_TTLS.CALL_OFFER, // 5 mins useClones: false }) diff --git a/src/Socket/messages-send.ts b/src/Socket/messages-send.ts index 8f14ecd..e2daaca 100644 --- a/src/Socket/messages-send.ts +++ b/src/Socket/messages-send.ts @@ -2,7 +2,7 @@ import { Boom } from '@hapi/boom' import NodeCache from 'node-cache' import { proto } from '../../WAProto' -import { WA_DEFAULT_EPHEMERAL } from '../Defaults' +import { DEFAULT_CACHE_TTLS, WA_DEFAULT_EPHEMERAL } from '../Defaults' import { AnyMessageContent, MediaConnInfo, MessageReceiptType, MessageRelayOptions, MiscMessageGenerationOptions, SocketConfig, WAMessageKey } from '../Types' import { aggregateMessageKeysNotFromMe, assertMediaContent, bindWaitForEvent, decryptMediaRetryData, encodeSignedDeviceIdentity, encodeWAMessage, encryptMediaRetryRequest, encryptSenderKeyMsgSignalProto, encryptSignalProto, extractDeviceJids, generateMessageID, generateWAMessage, getStatusCodeForMediaRetry, getUrlFromDirectPath, getWAUploadToServer, jidToSignalProtocolAddress, parseAndInjectE2ESessions, unixTimestampSeconds } from '../Utils' import { getUrlInfo } from '../Utils/link-preview' @@ -32,7 +32,7 @@ export const makeMessagesSocket = (config: SocketConfig) => { } = sock const userDevicesCache = config.userDevicesCache || new NodeCache({ - stdTTL: 300, // 5 minutes + stdTTL: DEFAULT_CACHE_TTLS.USER_DEVICES, // 5 minutes useClones: false })