Renato Alcara
d233a7856f
fix: eliminate 40s message delivery delay caused by libsignal console dumps
111 lines
3.8 KiB
TypeScript
111 lines
3.8 KiB
TypeScript
// ============================================
|
|
// Format session error logs from libsignal BEFORE any imports
|
|
// This MUST be at the very top to intercept console before libsignal loads
|
|
// ============================================
|
|
const _origConsoleError = console.error
|
|
const _origConsoleLog = console.log
|
|
const _origConsoleInfo = console.info
|
|
|
|
// Suppress libsignal session lifecycle dumps from console.log / console.info.
|
|
// libsignal's session_record.js uses console.info("Removing old closed session:", obj)
|
|
// and console.log("Closing session:", obj) which dump full session objects (~500ms I/O each).
|
|
const _SESSION_LIFECYCLE_RE = /^(Closing session|Removing old closed session)/
|
|
console.log = function (...args: unknown[]) {
|
|
if (args.length > 0 && typeof args[0] === 'string' && _SESSION_LIFECYCLE_RE.test(args[0])) {
|
|
return
|
|
}
|
|
|
|
_origConsoleLog.apply(console, args)
|
|
}
|
|
|
|
console.info = function (...args: unknown[]) {
|
|
if (args.length > 0 && typeof args[0] === 'string' && _SESSION_LIFECYCLE_RE.test(args[0])) {
|
|
return
|
|
}
|
|
|
|
_origConsoleInfo.apply(console, args)
|
|
}
|
|
|
|
// Track errors by type + JID to avoid duplicates (using Map for better performance)
|
|
const _errorTimestamps = new Map<string, number>()
|
|
const DEDUP_WINDOW_MS = 150
|
|
|
|
console.error = function (...args: unknown[]) {
|
|
if (args.length > 0 && typeof args[0] === 'string') {
|
|
const msg = args[0]
|
|
const stack = new Error().stack || ''
|
|
const isFromLibsignal = stack.includes('libsignal') || stack.includes('session_cipher')
|
|
|
|
if (isFromLibsignal) {
|
|
// Suppress session lifecycle logs
|
|
if (msg.startsWith('Closing session')) {
|
|
return
|
|
}
|
|
|
|
// Format session errors cleanly
|
|
if (
|
|
msg.includes('Session error') ||
|
|
msg.includes('Bad MAC') ||
|
|
msg.includes('MessageCounterError') ||
|
|
msg.includes('Key used already') ||
|
|
msg.includes('Failed to decrypt')
|
|
) {
|
|
// Extract error type
|
|
let errorType = '⚠️ Session Error'
|
|
if (msg.includes('Bad MAC')) errorType = '🔐 Bad MAC Error'
|
|
else if (msg.includes('MessageCounterError') || msg.includes('Key used already')) errorType = '🔢 Counter Error'
|
|
else if (msg.includes('Failed to decrypt')) errorType = '🔌 Decryption Failed'
|
|
|
|
// Extract JID from stack trace or message
|
|
const jidMatch = (msg + String(args[1] ?? '')).match(/(\d{10,}(?:_\d+\.\d+)?)/)
|
|
const jid = jidMatch ? jidMatch[1] : null
|
|
const maskedJid = jid && jid.length > 8 ? `${jid.substring(0, 4)}****${jid.substring(jid.length - 4)}` : jid
|
|
|
|
// Format clean message
|
|
const cleanMsg = maskedJid ? `${errorType} | JID: ${maskedJid}` : errorType
|
|
|
|
// Deduplication key: type + ORIGINAL JID (use unmasked to prevent collisions)
|
|
const dedupeKey = `${errorType}:${jid || 'unknown'}`
|
|
const now = Date.now()
|
|
const lastTime = _errorTimestamps.get(dedupeKey)
|
|
|
|
if (lastTime && now - lastTime < DEDUP_WINDOW_MS) {
|
|
return // Skip duplicate within 150ms window
|
|
}
|
|
|
|
_errorTimestamps.set(dedupeKey, now)
|
|
|
|
// Cleanup old entries (keep only last 50 to prevent memory leak)
|
|
if (_errorTimestamps.size > 50) {
|
|
const oldestKey = _errorTimestamps.keys().next().value
|
|
if (oldestKey) _errorTimestamps.delete(oldestKey)
|
|
}
|
|
|
|
_origConsoleError(cleanMsg)
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
_origConsoleError.apply(console, args)
|
|
}
|
|
|
|
import makeWASocket, { makeWASocketAutoVersion } from './Socket/index'
|
|
|
|
export * from '../WAProto/index.js'
|
|
export * from './Utils/index'
|
|
export * from './Types/index'
|
|
export * from './Defaults/index'
|
|
export * from './WABinary/index'
|
|
export * from './WAM/index'
|
|
export * from './WAUSync/index'
|
|
|
|
export type WASocket = ReturnType<typeof makeWASocket>
|
|
export { makeWASocket, makeWASocketAutoVersion }
|
|
|
|
// Alias de compatibilidade para zpro.io
|
|
// isJidUser é um alias para isPersonJid (mantém retrocompatibilidade)
|
|
export { isPersonJid as isJidUser } from './Utils/history'
|
|
|
|
export default makeWASocket
|