ruicesar/InfiniteAPI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(messages): fix inbound message latency by making LID mapping async

Browse Source 
perf(messages): fix inbound message latency by making LID mapping async
This commit is contained in:
Renato Alcara
2026-02-02 21:43:13 -03:00
committed by GitHub
parent b3db6e3472 d73cd28d39
commit 075cf9f000
1 changed files with 22 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Socket/messages-recv.ts
+22 -8
View File
@@ -1216,19 +1216,33 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
} = decryptMessageNode(node, authState.creds.me!.id, authState.creds.me!.lid || '', signalRepository, logger)
const alt = msg.key.participantAlt || msg.key.remoteJidAlt
// store new mappings we didn't have before
// Store LID/PN mappings asynchronously (fire-and-forget) to avoid blocking message delivery
// This improves inbound message latency by moving non-critical operations to background
if (!!alt) {
const altServer = jidDecode(alt)?.server
const primaryJid = msg.key.participant || msg.key.remoteJid!
if (altServer === 'lid') {
if (!(await signalRepository.lidMapping.getPNForLID(alt))) {
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: alt, pn: primaryJid }])
await signalRepository.migrateSession(primaryJid, alt)
// Execute mapping operations in background without blocking message delivery
const processMappingAsync = async () => {
try {
if (altServer === 'lid') {
if (!(await signalRepository.lidMapping.getPNForLID(alt))) {
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: alt, pn: primaryJid }])
await signalRepository.migrateSession(primaryJid, alt)
}
} else {
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: primaryJid, pn: alt }])
await signalRepository.migrateSession(alt, primaryJid)
}
} catch (error) {
logger.warn({ error, alt, primaryJid }, 'Background LID mapping operation failed')
}
} else {
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: primaryJid, pn: alt }])
await signalRepository.migrateSession(alt, primaryJid)
}
// Fire and forget - don't await
processMappingAsync().catch(error => {
logger.error({ error, alt, primaryJid }, 'Fatal error in background LID mapping')
})
}
if (msg.key?.remoteJid && msg.key?.id && messageRetryManager) {