Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 27b942f03c | |||
| 0eae108ba4 | |||
| cb80febba5 |
@@ -1,7 +1,7 @@
|
|||||||
syntax = "proto3";
|
syntax = "proto3";
|
||||||
package proto;
|
package proto;
|
||||||
|
|
||||||
/// WhatsApp Version: 2.3000.1034302344
|
/// WhatsApp Version: 2.3000.1034293476
|
||||||
|
|
||||||
message ADVDeviceIdentity {
|
message ADVDeviceIdentity {
|
||||||
optional uint32 rawId = 1;
|
optional uint32 rawId = 1;
|
||||||
|
|||||||
@@ -1 +1 @@
|
|||||||
{"version":[2,3000,1034382497]}
|
{"version":[2,3000,1034300341]}
|
||||||
|
|||||||
@@ -69,7 +69,7 @@ import {
|
|||||||
recordMessageReceived,
|
recordMessageReceived,
|
||||||
recordMessageRetry
|
recordMessageRetry
|
||||||
} from '../Utils/prometheus-metrics.js'
|
} from '../Utils/prometheus-metrics.js'
|
||||||
import { isTcTokenExpired, resolveTcTokenJid, storeTcTokensFromIqResult } from '../Utils/tc-token-utils'
|
import { isTcTokenExpired, resolveTcTokenJid } from '../Utils/tc-token-utils'
|
||||||
import {
|
import {
|
||||||
areJidsSameUser,
|
areJidsSameUser,
|
||||||
type BinaryNode,
|
type BinaryNode,
|
||||||
@@ -1453,7 +1453,6 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
// When a session is refreshed (identity change), re-issue tctoken fire-and-forget
|
// When a session is refreshed (identity change), re-issue tctoken fire-and-forget
|
||||||
// WABA Android: reissue stores senderTimestamp + realIssueTimestamp after IQ success
|
|
||||||
if (result.action === 'session_refreshed') {
|
if (result.action === 'session_refreshed') {
|
||||||
const normalizedJid = jidNormalizedUser(from)
|
const normalizedJid = jidNormalizedUser(from)
|
||||||
resolveTcTokenJid(normalizedJid, getLIDForPN)
|
resolveTcTokenJid(normalizedJid, getLIDForPN)
|
||||||
@@ -1463,36 +1462,9 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
if (entry?.token?.length && !isTcTokenExpired(entry.timestamp)) {
|
if (entry?.token?.length && !isTcTokenExpired(entry.timestamp)) {
|
||||||
const senderTs = unixTimestampSeconds()
|
const senderTs = unixTimestampSeconds()
|
||||||
logTcToken('reissue', { jid: normalizedJid, reason: 'session_refreshed' })
|
logTcToken('reissue', { jid: normalizedJid, reason: 'session_refreshed' })
|
||||||
getPrivacyTokens([normalizedJid], senderTs)
|
getPrivacyTokens([normalizedJid], senderTs).catch(err => {
|
||||||
.then(async (iqResult) => {
|
logTcToken('reissue_fail', { jid: normalizedJid, error: err?.message })
|
||||||
await storeTcTokensFromIqResult({
|
})
|
||||||
result: iqResult,
|
|
||||||
fallbackJid: normalizedJid,
|
|
||||||
keys: authState.keys,
|
|
||||||
getLIDForPN,
|
|
||||||
onNewJidStored: (storedJid) => {
|
|
||||||
tcTokenKnownJids.add(storedJid)
|
|
||||||
scheduleTcTokenIndexSave()
|
|
||||||
}
|
|
||||||
})
|
|
||||||
// Persist senderTimestamp + realIssueTimestamp after IQ success
|
|
||||||
const currentData = await authState.keys.get('tctoken', [tcJid])
|
|
||||||
const currentEntry = currentData[tcJid]
|
|
||||||
await authState.keys.set({
|
|
||||||
tctoken: {
|
|
||||||
[tcJid]: {
|
|
||||||
...currentEntry,
|
|
||||||
token: currentEntry?.token ?? Buffer.alloc(0),
|
|
||||||
senderTimestamp: senderTs,
|
|
||||||
realIssueTimestamp: 0
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
logTcToken('reissue_ok', { jid: normalizedJid, reason: 'session_refreshed' })
|
|
||||||
})
|
|
||||||
.catch(err => {
|
|
||||||
logTcToken('reissue_fail', { jid: normalizedJid, error: err?.message })
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.catch(() => {
|
.catch(() => {
|
||||||
@@ -1940,10 +1912,7 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
[storageJid]: {
|
[storageJid]: {
|
||||||
...existing,
|
...existing,
|
||||||
token: Buffer.from(content),
|
token: Buffer.from(content),
|
||||||
timestamp,
|
timestamp
|
||||||
// WABA Android: resets real_issue_timestamp when a new incoming token arrives
|
|
||||||
// (UPDATE wa_trusted_contacts_send SET real_issue_timestamp=null)
|
|
||||||
realIssueTimestamp: null
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
@@ -2854,24 +2823,6 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
const jid = jidNormalizedUser(attrs.from)
|
const jid = jidNormalizedUser(attrs.from)
|
||||||
logTcToken('error_463', { jid, msgId })
|
logTcToken('error_463', { jid, msgId })
|
||||||
|
|
||||||
// WABA Android: error 463 triggers getPrivacyTokens() fire-and-forget
|
|
||||||
// to ensure token is available for the retry below
|
|
||||||
getPrivacyTokens([jid])
|
|
||||||
.then(async (result) => {
|
|
||||||
await storeTcTokensFromIqResult({
|
|
||||||
result,
|
|
||||||
fallbackJid: jid,
|
|
||||||
keys: authState.keys,
|
|
||||||
getLIDForPN,
|
|
||||||
onNewJidStored: (storedJid) => {
|
|
||||||
tcTokenKnownJids.add(storedJid)
|
|
||||||
scheduleTcTokenIndexSave()
|
|
||||||
}
|
|
||||||
})
|
|
||||||
logTcToken('fetched', { jid, reason: 'error_463' })
|
|
||||||
})
|
|
||||||
.catch(() => { /* fire-and-forget */ })
|
|
||||||
|
|
||||||
// Single-retry: wait 1.5s for the server's tctoken notification to arrive,
|
// Single-retry: wait 1.5s for the server's tctoken notification to arrive,
|
||||||
// then resend. A Set prevents infinite retry loops.
|
// then resend. A Set prevents infinite retry loops.
|
||||||
// Composite key (jid:msgId) ensures retries are isolated per destination.
|
// Composite key (jid:msgId) ensures retries are isolated per destination.
|
||||||
@@ -2907,24 +2858,7 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
} else if (attrs.error === SERVER_ERROR_CODES.SmaxInvalid) {
|
} else if (attrs.error === SERVER_ERROR_CODES.SmaxInvalid) {
|
||||||
const jid479 = jidNormalizedUser(attrs.from)
|
logTcToken('error_479', { jid: attrs.from, msgId: attrs.id })
|
||||||
logTcToken('error_479', { jid: jid479, msgId: attrs.id })
|
|
||||||
// WABA Android: error 479 (SmaxInvalid) also triggers token re-fetch
|
|
||||||
getPrivacyTokens([jid479])
|
|
||||||
.then(async (result) => {
|
|
||||||
await storeTcTokensFromIqResult({
|
|
||||||
result,
|
|
||||||
fallbackJid: jid479,
|
|
||||||
keys: authState.keys,
|
|
||||||
getLIDForPN,
|
|
||||||
onNewJidStored: (storedJid) => {
|
|
||||||
tcTokenKnownJids.add(storedJid)
|
|
||||||
scheduleTcTokenIndexSave()
|
|
||||||
}
|
|
||||||
})
|
|
||||||
logTcToken('fetched', { jid: jid479, reason: 'error_479' })
|
|
||||||
})
|
|
||||||
.catch(() => { /* fire-and-forget */ })
|
|
||||||
} else {
|
} else {
|
||||||
logger.warn({ attrs }, 'received error in ack')
|
logger.warn({ attrs }, 'received error in ack')
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1611,8 +1611,6 @@ export const makeMessagesSocket = (config: SocketConfig) => {
|
|||||||
|
|
||||||
// Persist senderTimestamp unconditionally — WA Web stores it in the chat table
|
// Persist senderTimestamp unconditionally — WA Web stores it in the chat table
|
||||||
// regardless of whether a token exists. Spread preserves token+timestamp if present.
|
// regardless of whether a token exists. Spread preserves token+timestamp if present.
|
||||||
// WABA Android: INSERT INTO wa_trusted_contacts_send (jid, sent_tc_token_timestamp, real_issue_timestamp)
|
|
||||||
// VALUES (?, ?, 0) — realIssueTimestamp=0 means issued but not yet confirmed by server
|
|
||||||
const currentData = await authState.keys.get('tctoken', [tcTokenJid])
|
const currentData = await authState.keys.get('tctoken', [tcTokenJid])
|
||||||
const currentEntry = currentData[tcTokenJid]
|
const currentEntry = currentData[tcTokenJid]
|
||||||
await authState.keys.set({
|
await authState.keys.set({
|
||||||
@@ -1620,8 +1618,7 @@ export const makeMessagesSocket = (config: SocketConfig) => {
|
|||||||
[tcTokenJid]: {
|
[tcTokenJid]: {
|
||||||
...currentEntry,
|
...currentEntry,
|
||||||
token: currentEntry?.token ?? Buffer.alloc(0),
|
token: currentEntry?.token ?? Buffer.alloc(0),
|
||||||
senderTimestamp: issueTimestamp,
|
senderTimestamp: issueTimestamp
|
||||||
realIssueTimestamp: 0
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|||||||
+4
-13
@@ -1351,23 +1351,14 @@ export const makeSocket = (config: SocketConfig) => {
|
|||||||
name: '~'
|
name: '~'
|
||||||
}
|
}
|
||||||
|
|
||||||
// Pair code companion_platform_id must be Chrome (1) when using Android
|
// Pair code with Android browser doesn't work (WA server rejects the
|
||||||
// browser preset. ANDROID_PHONE (16) causes silent timeout (server ignores),
|
// companion registration). When Android is detected, fall back to the
|
||||||
// UWP (21) causes "cannot connect device" rejection. Only Chrome (1) works
|
// Chrome/macOS platform values that are known to work.
|
||||||
// for pair code via web protocol (WA\x06\x03). The device still appears as
|
|
||||||
// "Android" in linked devices because DeviceProps.platformType=ANDROID_PHONE
|
|
||||||
// is set separately in the registration node.
|
|
||||||
const isAndroid = isAndroidBrowser(browser)
|
const isAndroid = isAndroidBrowser(browser)
|
||||||
const pairPlatformId = isAndroid ? getPlatformId('Chrome') : getPlatformId(browser[1])
|
const pairPlatformId = isAndroid ? getPlatformId('Chrome') : getPlatformId(browser[1])
|
||||||
const pairPlatformDisplay = isAndroid ? 'Chrome (Mac OS)' : `${browser[1]} (${browser[0]})`
|
const pairPlatformDisplay = isAndroid ? 'Chrome (Mac OS)' : `${browser[1]} (${browser[0]})`
|
||||||
|
|
||||||
logger.info({
|
logger.info(`\uD83D\uDD17 Pair code requested | companion: ${pairPlatformDisplay} | ${isAndroid ? 'android override \u2192 Chrome' : 'native platform'}`)
|
||||||
pairCode: pairingCode,
|
|
||||||
jid: authState.creds.me.id,
|
|
||||||
companionPlatformId: pairPlatformId,
|
|
||||||
companionPlatformDisplay: pairPlatformDisplay,
|
|
||||||
isAndroid,
|
|
||||||
}, `pair code requested | companion: ${pairPlatformDisplay} | ${isAndroid ? 'android override -> Chrome' : 'native platform'}`)
|
|
||||||
|
|
||||||
ev.emit('creds.update', authState.creds)
|
ev.emit('creds.update', authState.creds)
|
||||||
await sendNode({
|
await sendNode({
|
||||||
|
|||||||
+1
-1
@@ -80,7 +80,7 @@ export type SignalDataTypeMap = {
|
|||||||
'app-state-sync-version': LTHashState
|
'app-state-sync-version': LTHashState
|
||||||
'lid-mapping': string
|
'lid-mapping': string
|
||||||
'device-list': string[]
|
'device-list': string[]
|
||||||
tctoken: { token: Buffer; timestamp?: string; senderTimestamp?: number; realIssueTimestamp?: number | null }
|
tctoken: { token: Buffer; timestamp?: string; senderTimestamp?: number }
|
||||||
/** Identity key for Signal Protocol - used for detecting contact reinstalls */
|
/** Identity key for Signal Protocol - used for detecting contact reinstalls */
|
||||||
'identity-key': Uint8Array
|
'identity-key': Uint8Array
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -54,14 +54,12 @@ export type WAMediaUpload = Buffer | WAMediaPayloadStream | WAMediaPayloadURL
|
|||||||
* Individual sticker in a sticker pack
|
* Individual sticker in a sticker pack
|
||||||
*/
|
*/
|
||||||
export type Sticker = {
|
export type Sticker = {
|
||||||
/** Buffer, Stream or URL of the sticker image (WebP or Lottie/WAS format) */
|
/** Buffer, Stream or URL of the sticker image (will be converted to WebP if needed) */
|
||||||
data: WAMediaUpload
|
data: WAMediaUpload
|
||||||
/** Array of emojis associated with this sticker (max 3 recommended per WhatsApp standards) */
|
/** Array of emojis associated with this sticker (max 3 recommended per WhatsApp standards) */
|
||||||
emojis?: string[]
|
emojis?: string[]
|
||||||
/** Accessibility label for screen readers (max 125 chars for static, 255 for animated) */
|
/** Accessibility label for screen readers (max 125 chars for static, 255 for animated) */
|
||||||
accessibilityLabel?: string
|
accessibilityLabel?: string
|
||||||
/** Force Lottie format detection (auto-detected if omitted) */
|
|
||||||
isLottie?: boolean
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
+19
-120
@@ -2,7 +2,6 @@ import { Boom } from '@hapi/boom'
|
|||||||
import { createHash } from 'crypto'
|
import { createHash } from 'crypto'
|
||||||
import { zipSync } from 'fflate'
|
import { zipSync } from 'fflate'
|
||||||
import { promises as fs } from 'fs'
|
import { promises as fs } from 'fs'
|
||||||
import { gzipSync, gunzipSync } from 'zlib'
|
|
||||||
import { proto } from '../../WAProto/index.js'
|
import { proto } from '../../WAProto/index.js'
|
||||||
import type { MediaType } from '../Defaults/index.js'
|
import type { MediaType } from '../Defaults/index.js'
|
||||||
import type { StickerPack, WAMediaUpload, WAMediaUploadFunction } from '../Types/Message.js'
|
import type { StickerPack, WAMediaUpload, WAMediaUploadFunction } from '../Types/Message.js'
|
||||||
@@ -102,49 +101,6 @@ export const isAnimatedWebP = (buffer: Buffer): boolean => {
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Detecta se um buffer é Lottie JSON (raw ou gzip-compressed/WAS)
|
|
||||||
*
|
|
||||||
* WABA usa mimetype `application/was` para stickers Lottie.
|
|
||||||
* WAS (WhatsApp Animated Sticker) = gzip-compressed Lottie JSON.
|
|
||||||
*
|
|
||||||
* Detecção:
|
|
||||||
* - Gzip (0x1f 0x8b): descomprime e verifica se é Lottie JSON
|
|
||||||
* - JSON bruto: verifica campos Lottie obrigatórios (v, ip, op, layers)
|
|
||||||
*
|
|
||||||
* @param buffer - Buffer to check
|
|
||||||
* @returns true if buffer is Lottie/WAS format
|
|
||||||
*/
|
|
||||||
export const isLottieBuffer = (buffer: Buffer): boolean => {
|
|
||||||
if (buffer.length < 2) return false
|
|
||||||
|
|
||||||
let jsonBuffer: Buffer
|
|
||||||
|
|
||||||
// Check if gzip-compressed (WAS format)
|
|
||||||
if (buffer[0] === 0x1f && buffer[1] === 0x8b) {
|
|
||||||
try {
|
|
||||||
// SECURITY: Limit decompressed output to 50MB to prevent decompression bombs
|
|
||||||
jsonBuffer = gunzipSync(buffer, { maxOutputLength: 50 * 1024 * 1024 }) as Buffer
|
|
||||||
} catch {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
} else if (buffer[0] === 0x7b) {
|
|
||||||
// Starts with '{' - could be raw Lottie JSON
|
|
||||||
jsonBuffer = buffer
|
|
||||||
} else {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
// Validate Lottie JSON structure: must have v, ip, op, AND layers
|
|
||||||
try {
|
|
||||||
const str = jsonBuffer.toString('utf8', 0, Math.min(jsonBuffer.length, 4096))
|
|
||||||
// Quick check for ALL required Lottie fields
|
|
||||||
return str.includes('"v"') && str.includes('"layers"') && str.includes('"ip"') && str.includes('"op"')
|
|
||||||
} catch {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converte uma imagem para WebP usando Sharp
|
* Converte uma imagem para WebP usando Sharp
|
||||||
* Preserva o buffer original se já for WebP para manter EXIF e animações
|
* Preserva o buffer original se já for WebP para manter EXIF e animações
|
||||||
@@ -158,25 +114,12 @@ export const isLottieBuffer = (buffer: Buffer): boolean => {
|
|||||||
const convertToWebP = async (
|
const convertToWebP = async (
|
||||||
buffer: Buffer,
|
buffer: Buffer,
|
||||||
logger?: ILogger
|
logger?: ILogger
|
||||||
): Promise<{ webpBuffer: Buffer; isAnimated: boolean; isLottie: boolean }> => {
|
): Promise<{ webpBuffer: Buffer; isAnimated: boolean }> => {
|
||||||
// Lottie/WAS: ensure gzip-compressed format (WAS = gzip Lottie JSON)
|
|
||||||
if (isLottieBuffer(buffer)) {
|
|
||||||
let wasBuffer = buffer
|
|
||||||
// Raw Lottie JSON (starts with '{') must be gzipped to produce valid WAS
|
|
||||||
if (buffer[0] === 0x7b) {
|
|
||||||
logger?.trace('Raw Lottie JSON detected, gzip-compressing to WAS format')
|
|
||||||
wasBuffer = gzipSync(buffer) as Buffer
|
|
||||||
}
|
|
||||||
|
|
||||||
logger?.trace('Input is Lottie/WAS format')
|
|
||||||
return { webpBuffer: wasBuffer, isAnimated: true, isLottie: true }
|
|
||||||
}
|
|
||||||
|
|
||||||
// Se já é WebP, preserva o buffer original (mantém EXIF e animações)
|
// Se já é WebP, preserva o buffer original (mantém EXIF e animações)
|
||||||
if (isWebPBuffer(buffer)) {
|
if (isWebPBuffer(buffer)) {
|
||||||
const isAnimated = isAnimatedWebP(buffer)
|
const isAnimated = isAnimatedWebP(buffer)
|
||||||
logger?.trace({ isAnimated }, 'Input is already WebP, preserving original buffer')
|
logger?.trace({ isAnimated }, 'Input is already WebP, preserving original buffer')
|
||||||
return { webpBuffer: buffer, isAnimated, isLottie: false }
|
return { webpBuffer: buffer, isAnimated }
|
||||||
}
|
}
|
||||||
|
|
||||||
// Tenta usar Sharp para converter
|
// Tenta usar Sharp para converter
|
||||||
@@ -192,7 +135,7 @@ const convertToWebP = async (
|
|||||||
logger?.trace('Converting image to WebP using Sharp')
|
logger?.trace('Converting image to WebP using Sharp')
|
||||||
const webpBuffer = await lib.sharp.default(buffer).webp().toBuffer()
|
const webpBuffer = await lib.sharp.default(buffer).webp().toBuffer()
|
||||||
|
|
||||||
return { webpBuffer, isAnimated: false, isLottie: false }
|
return { webpBuffer, isAnimated: false }
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -395,11 +338,9 @@ export type PrepareStickerPackMessageOptions = {
|
|||||||
*
|
*
|
||||||
* **Especificações WhatsApp:**
|
* **Especificações WhatsApp:**
|
||||||
* - 3-30 stickers por pack (oficial)
|
* - 3-30 stickers por pack (oficial)
|
||||||
* - WebP ou Lottie/WAS (application/was)
|
* - WebP obrigatório
|
||||||
* - Stickers: 512x512 pixels (auto-resize)
|
|
||||||
* - Recomendado: 100KB por sticker estático, 500KB animado
|
* - Recomendado: 100KB por sticker estático, 500KB animado
|
||||||
* - Tray icon: 96x96 pixels (PNG no ZIP)
|
* - Tray icon: 252x252 pixels
|
||||||
* - Thumbnail: 252x252 pixels (JPEG, upload separado)
|
|
||||||
*
|
*
|
||||||
* @param stickerPack - Sticker pack data with stickers, cover, name, publisher
|
* @param stickerPack - Sticker pack data with stickers, cover, name, publisher
|
||||||
* @param options - Upload function and optional logger
|
* @param options - Upload function and optional logger
|
||||||
@@ -523,36 +464,9 @@ export const prepareStickerPackMessage = async (
|
|||||||
// Obtém buffer do sticker
|
// Obtém buffer do sticker
|
||||||
const buffer = await mediaToBuffer(sticker.data, `sticker ${i + 1}`)
|
const buffer = await mediaToBuffer(sticker.data, `sticker ${i + 1}`)
|
||||||
|
|
||||||
// Detecta formato e converte se necessário
|
// Converte para WebP
|
||||||
// eslint-disable-next-line prefer-const
|
// eslint-disable-next-line prefer-const
|
||||||
let { webpBuffer, isAnimated, isLottie } = await convertToWebP(buffer, logger)
|
let { webpBuffer, isAnimated } = await convertToWebP(buffer, logger)
|
||||||
|
|
||||||
// Validate explicit isLottie flag — must match detected format
|
|
||||||
if (sticker.isLottie !== undefined && sticker.isLottie !== isLottie) {
|
|
||||||
throw new Boom(
|
|
||||||
`Sticker ${i + 1}: explicit isLottie=${sticker.isLottie} does not match detected format (detected=${isLottie})`,
|
|
||||||
{ statusCode: 400 }
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
// WABA: Enforce 512x512 dimensions for WebP stickers (Lottie is vector, skip)
|
|
||||||
if (!isLottie && isWebPBuffer(webpBuffer)) {
|
|
||||||
const lib = await getImageProcessingLibrary()
|
|
||||||
if (lib?.sharp) {
|
|
||||||
const metadata = await lib.sharp.default(webpBuffer).metadata()
|
|
||||||
if (metadata.width !== 512 || metadata.height !== 512) {
|
|
||||||
logger?.trace(
|
|
||||||
{ index: i, width: metadata.width, height: metadata.height },
|
|
||||||
'Resizing sticker to 512x512 (WABA standard)'
|
|
||||||
)
|
|
||||||
webpBuffer = await lib.sharp
|
|
||||||
.default(webpBuffer)
|
|
||||||
.resize(512, 512, { fit: 'contain', background: { r: 0, g: 0, b: 0, alpha: 0 } })
|
|
||||||
.webp()
|
|
||||||
.toBuffer()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// ENHANCEMENT: Auto-compression if exceeds 1MB (try quality 70, then 50)
|
// ENHANCEMENT: Auto-compression if exceeds 1MB (try quality 70, then 50)
|
||||||
const MAX_STICKER_SIZE = 1024 * 1024 // 1MB
|
const MAX_STICKER_SIZE = 1024 * 1024 // 1MB
|
||||||
@@ -569,7 +483,7 @@ export const prepareStickerPackMessage = async (
|
|||||||
if (lib?.sharp) {
|
if (lib?.sharp) {
|
||||||
// Try quality 70
|
// Try quality 70
|
||||||
try {
|
try {
|
||||||
const compressed70 = await lib.sharp.default(webpBuffer).webp({ quality: 70 }).toBuffer()
|
const compressed70 = await lib.sharp.default(buffer).webp({ quality: 70 }).toBuffer()
|
||||||
|
|
||||||
// eslint-disable-next-line max-depth
|
// eslint-disable-next-line max-depth
|
||||||
if (compressed70.length <= MAX_STICKER_SIZE) {
|
if (compressed70.length <= MAX_STICKER_SIZE) {
|
||||||
@@ -584,7 +498,7 @@ export const prepareStickerPackMessage = async (
|
|||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
// Try quality 50
|
// Try quality 50
|
||||||
const compressed50 = await lib.sharp.default(webpBuffer).webp({ quality: 50 }).toBuffer()
|
const compressed50 = await lib.sharp.default(buffer).webp({ quality: 50 }).toBuffer()
|
||||||
|
|
||||||
// eslint-disable-next-line max-depth
|
// eslint-disable-next-line max-depth
|
||||||
if (compressed50.length <= MAX_STICKER_SIZE) {
|
if (compressed50.length <= MAX_STICKER_SIZE) {
|
||||||
@@ -633,13 +547,12 @@ export const prepareStickerPackMessage = async (
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Gera nome do arquivo: hash.webp ou hash.was (WABA: plain_file_hash.ext)
|
// Gera nome do arquivo: hash.webp (deduplicação automática)
|
||||||
const sha256Hash = generateSha256Hash(webpBuffer)
|
const sha256Hash = generateSha256Hash(webpBuffer)
|
||||||
const extension = isLottie ? 'was' : 'webp'
|
const fileName = `${sha256Hash}.webp`
|
||||||
const fileName = `${sha256Hash}.${extension}`
|
|
||||||
|
|
||||||
logger?.trace(
|
logger?.trace(
|
||||||
{ index: i, fileName, sizeKB: finalSizeKB.toFixed(2), isAnimated, isLottie },
|
{ index: i, fileName, sizeKB: finalSizeKB.toFixed(2), isAnimated },
|
||||||
'Sticker processed successfully'
|
'Sticker processed successfully'
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -647,7 +560,6 @@ export const prepareStickerPackMessage = async (
|
|||||||
fileName,
|
fileName,
|
||||||
webpBuffer,
|
webpBuffer,
|
||||||
isAnimated,
|
isAnimated,
|
||||||
isLottie,
|
|
||||||
emojis: sticker.emojis || [],
|
emojis: sticker.emojis || [],
|
||||||
accessibilityLabel: sticker.accessibilityLabel
|
accessibilityLabel: sticker.accessibilityLabel
|
||||||
}
|
}
|
||||||
@@ -666,7 +578,7 @@ export const prepareStickerPackMessage = async (
|
|||||||
for (const result of processedStickers) {
|
for (const result of processedStickers) {
|
||||||
if (!result) continue
|
if (!result) continue
|
||||||
|
|
||||||
const { fileName, webpBuffer, isAnimated, isLottie, emojis, accessibilityLabel } = result
|
const { fileName, webpBuffer, isAnimated, emojis, accessibilityLabel } = result
|
||||||
|
|
||||||
// SECURITY FIX #7: Check if this hash already exists (duplicate sticker)
|
// SECURITY FIX #7: Check if this hash already exists (duplicate sticker)
|
||||||
const existingMetadata = metadataByHash.get(fileName)
|
const existingMetadata = metadataByHash.get(fileName)
|
||||||
@@ -693,14 +605,13 @@ export const prepareStickerPackMessage = async (
|
|||||||
// New sticker - add to ZIP and create metadata
|
// New sticker - add to ZIP and create metadata
|
||||||
stickerData[fileName] = [new Uint8Array(webpBuffer), { level: 0 as 0 }]
|
stickerData[fileName] = [new Uint8Array(webpBuffer), { level: 0 as 0 }]
|
||||||
|
|
||||||
// WABA: mimetype é 'application/was' para Lottie, 'image/webp' para WebP
|
|
||||||
const metadata: proto.Message.StickerPackMessage.ISticker = {
|
const metadata: proto.Message.StickerPackMessage.ISticker = {
|
||||||
fileName,
|
fileName,
|
||||||
isAnimated,
|
isAnimated,
|
||||||
emojis,
|
emojis,
|
||||||
accessibilityLabel,
|
accessibilityLabel,
|
||||||
isLottie,
|
isLottie: false,
|
||||||
mimetype: isLottie ? 'application/was' : 'image/webp'
|
mimetype: 'image/webp'
|
||||||
}
|
}
|
||||||
|
|
||||||
metadataByHash.set(fileName, metadata)
|
metadataByHash.set(fileName, metadata)
|
||||||
@@ -725,22 +636,10 @@ export const prepareStickerPackMessage = async (
|
|||||||
logger?.trace('Processing cover image')
|
logger?.trace('Processing cover image')
|
||||||
coverBuffer = await mediaToBuffer(cover, 'cover image')
|
coverBuffer = await mediaToBuffer(cover, 'cover image')
|
||||||
|
|
||||||
// Tray icon uses PNG format, 96x96 pixels (official client standard)
|
// Converte cover para WebP e adiciona ao ZIP
|
||||||
const lib = await getImageProcessingLibrary()
|
const result = await convertToWebP(coverBuffer, logger)
|
||||||
if (!lib?.sharp) {
|
coverWebP = result.webpBuffer
|
||||||
throw new Boom(
|
coverFileName = `${stickerPackId}.webp`
|
||||||
'Sharp library is required for cover/tray icon processing. Install with: yarn add sharp',
|
|
||||||
{ statusCode: 400 }
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
coverWebP = await lib.sharp
|
|
||||||
.default(coverBuffer)
|
|
||||||
.resize(96, 96, { fit: 'contain', background: { r: 0, g: 0, b: 0, alpha: 0 } })
|
|
||||||
.png()
|
|
||||||
.toBuffer()
|
|
||||||
|
|
||||||
coverFileName = `${stickerPackId}.png`
|
|
||||||
stickerData[coverFileName] = [new Uint8Array(coverWebP), { level: 0 as 0 }]
|
stickerData[coverFileName] = [new Uint8Array(coverWebP), { level: 0 as 0 }]
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
throw new Boom(`Failed to process cover image: ${(error as Error).message}`, {
|
throw new Boom(`Failed to process cover image: ${(error as Error).message}`, {
|
||||||
|
|||||||
@@ -159,10 +159,7 @@ export async function storeTcTokensFromIqResult({
|
|||||||
[storageJid]: {
|
[storageJid]: {
|
||||||
...existingEntry,
|
...existingEntry,
|
||||||
token: Buffer.from(tokenNode.content),
|
token: Buffer.from(tokenNode.content),
|
||||||
timestamp: tokenNode.attrs.t,
|
timestamp: tokenNode.attrs.t
|
||||||
// WABA Android: resets real_issue_timestamp to null when storing a new token
|
|
||||||
// (UPDATE wa_trusted_contacts_send SET real_issue_timestamp=null)
|
|
||||||
realIssueTimestamp: null
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -9,27 +9,25 @@ import {
|
|||||||
} from '../Defaults'
|
} from '../Defaults'
|
||||||
import type { AuthenticationCreds, SignalCreds, SocketConfig } from '../Types'
|
import type { AuthenticationCreds, SignalCreds, SocketConfig } from '../Types'
|
||||||
import { type BinaryNode, getBinaryNodeChild, jidDecode, S_WHATSAPP_NET } from '../WABinary'
|
import { type BinaryNode, getBinaryNodeChild, jidDecode, S_WHATSAPP_NET } from '../WABinary'
|
||||||
|
import { isAndroidBrowser } from './browser-utils'
|
||||||
import { Curve, hmacSign } from './crypto'
|
import { Curve, hmacSign } from './crypto'
|
||||||
import { encodeBigEndian } from './generics'
|
import { encodeBigEndian } from './generics'
|
||||||
import { createSignalIdentity } from './signal'
|
import { createSignalIdentity } from './signal'
|
||||||
|
|
||||||
const getUserAgent = (config: SocketConfig): proto.ClientPayload.IUserAgent => {
|
const getUserAgent = (config: SocketConfig): proto.ClientPayload.IUserAgent => {
|
||||||
// Always use MACOS/Desktop identity for UserAgent — we connect via web
|
const isAndroid = isAndroidBrowser(config.browser)
|
||||||
// protocol (WA\x06\x03) so the server expects a web-like UserAgent.
|
|
||||||
// Using SMB_ANDROID here causes pair code registration to fail with
|
|
||||||
// "não é possível conectar" even though the phone shows the confirmation.
|
|
||||||
// Android identity is only set in DeviceProps (registration node) which
|
|
||||||
// determines the display name in "Linked Devices".
|
|
||||||
return {
|
return {
|
||||||
appVersion: {
|
appVersion: {
|
||||||
primary: config.version[0],
|
primary: config.version[0],
|
||||||
secondary: config.version[1],
|
secondary: config.version[1],
|
||||||
tertiary: config.version[2]
|
tertiary: config.version[2]
|
||||||
},
|
},
|
||||||
platform: proto.ClientPayload.UserAgent.Platform.MACOS,
|
platform: isAndroid
|
||||||
|
? proto.ClientPayload.UserAgent.Platform.SMB_ANDROID
|
||||||
|
: proto.ClientPayload.UserAgent.Platform.MACOS,
|
||||||
releaseChannel: proto.ClientPayload.UserAgent.ReleaseChannel.RELEASE,
|
releaseChannel: proto.ClientPayload.UserAgent.ReleaseChannel.RELEASE,
|
||||||
osVersion: '0.1',
|
osVersion: isAndroid ? config.browser[0] : '0.1',
|
||||||
device: 'Desktop',
|
device: isAndroid ? 'Android' : 'Desktop',
|
||||||
osBuildNumber: '0.1',
|
osBuildNumber: '0.1',
|
||||||
localeLanguageIso6391: 'en',
|
localeLanguageIso6391: 'en',
|
||||||
mnc: '000',
|
mnc: '000',
|
||||||
@@ -60,8 +58,11 @@ const getClientPayload = (config: SocketConfig) => {
|
|||||||
const payload: proto.IClientPayload = {
|
const payload: proto.IClientPayload = {
|
||||||
connectType: proto.ClientPayload.ConnectType.WIFI_UNKNOWN,
|
connectType: proto.ClientPayload.ConnectType.WIFI_UNKNOWN,
|
||||||
connectReason: proto.ClientPayload.ConnectReason.USER_ACTIVATED,
|
connectReason: proto.ClientPayload.ConnectReason.USER_ACTIVATED,
|
||||||
userAgent: getUserAgent(config),
|
userAgent: getUserAgent(config)
|
||||||
webInfo: getWebInfo(config)
|
}
|
||||||
|
|
||||||
|
if (!isAndroidBrowser(config.browser)) {
|
||||||
|
payload.webInfo = getWebInfo(config)
|
||||||
}
|
}
|
||||||
|
|
||||||
return payload
|
return payload
|
||||||
|
|||||||
Reference in New Issue
Block a user