diff --git a/package.json b/package.json index cda0ecaa..6b8fb2ee 100644 --- a/package.json +++ b/package.json @@ -50,6 +50,7 @@ "p-queue": "^9.0.0", "pino": "^9.6", "protobufjs": "^7.2.4", + "whatsapp-rust-bridge": "0.5.2", "ws": "^8.13.0" }, "devDependencies": { diff --git a/src/Socket/messages-recv.ts b/src/Socket/messages-recv.ts index 15c4c545..9bedbd26 100644 --- a/src/Socket/messages-recv.ts +++ b/src/Socket/messages-recv.ts @@ -818,7 +818,7 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { ) const random = randomBytes(32) const linkCodeSalt = randomBytes(32) - const linkCodePairingExpanded = await hkdf(companionSharedKey, 32, { + const linkCodePairingExpanded = hkdf(companionSharedKey, 32, { salt: linkCodeSalt, info: 'link_code_pairing_key_bundle_encryption_key' }) @@ -832,7 +832,7 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { const encryptedPayload = Buffer.concat([linkCodeSalt, encryptIv, encrypted]) const identitySharedKey = Curve.sharedKey(authState.creds.signedIdentityKey.private, primaryIdentityPublicKey) const identityPayload = Buffer.concat([companionSharedKey, identitySharedKey, random]) - authState.creds.advSecretKey = (await hkdf(identityPayload, 32, { info: 'adv_secret' })).toString('base64') + authState.creds.advSecretKey = Buffer.from(hkdf(identityPayload, 32, { info: 'adv_secret' })).toString('base64') await query({ tag: 'iq', attrs: { diff --git a/src/Socket/messages-send.ts b/src/Socket/messages-send.ts index b6177ede..4e90c459 100644 --- a/src/Socket/messages-send.ts +++ b/src/Socket/messages-send.ts @@ -1159,7 +1159,7 @@ export const makeMessagesSocket = (config: SocketConfig) => { const content = assertMediaContent(message.message) const mediaKey = content.mediaKey! const meId = authState.creds.me!.id - const node = await encryptMediaRetryRequest(message.key, mediaKey, meId) + const node = encryptMediaRetryRequest(message.key, mediaKey, meId) let error: Error | undefined = undefined await Promise.all([ @@ -1171,7 +1171,7 @@ export const makeMessagesSocket = (config: SocketConfig) => { error = result.error } else { try { - const media = await decryptMediaRetryData(result.media!, mediaKey, result.key.id!) + const media = decryptMediaRetryData(result.media!, mediaKey, result.key.id!) if (media.result !== proto.MediaRetryNotification.ResultType.SUCCESS) { const resultStr = proto.MediaRetryNotification.ResultType[media.result!] throw new Boom(`Media re-upload failed by device (${resultStr})`, { diff --git a/src/Socket/socket.ts b/src/Socket/socket.ts index 87c65a5a..cd39f13a 100644 --- a/src/Socket/socket.ts +++ b/src/Socket/socket.ts @@ -429,7 +429,7 @@ export const makeSocket = (config: SocketConfig) => { logger.trace({ handshake }, 'handshake recv from WA') - const keyEnc = await noise.processHandshake(handshake, creds.noiseKey) + const keyEnc = noise.processHandshake(handshake, creds.noiseKey) let node: proto.IClientPayload if (!creds.me) { diff --git a/src/Types/Message.ts b/src/Types/Message.ts index dc8d7dfd..32e279e6 100644 --- a/src/Types/Message.ts +++ b/src/Types/Message.ts @@ -372,9 +372,9 @@ export type WAMessageCursor = { before: WAMessageKey | undefined } | { after: WA export type MessageUserReceiptUpdate = { key: WAMessageKey; receipt: MessageUserReceipt } export type MediaDecryptionKeyInfo = { - iv: Buffer - cipherKey: Buffer - macKey?: Buffer + iv: Uint8Array + cipherKey: Uint8Array + macKey?: Uint8Array } export type MinimalMessage = Pick diff --git a/src/Utils/chat-utils.ts b/src/Utils/chat-utils.ts index 0b8787de..daeb1a9a 100644 --- a/src/Utils/chat-utils.ts +++ b/src/Utils/chat-utils.ts @@ -1,4 +1,5 @@ import { Boom } from '@hapi/boom' +import { expandAppStateKeys } from 'whatsapp-rust-bridge' import { proto } from '../../WAProto/index.js' import type { BaileysEventEmitter, @@ -19,7 +20,7 @@ import { type MessageLabelAssociation } from '../Types/LabelAssociation' import { type BinaryNode, getBinaryNodeChild, getBinaryNodeChildren, isJidGroup, jidNormalizedUser } from '../WABinary' -import { aesDecrypt, aesEncrypt, hkdf, hmacSign } from './crypto' +import { aesDecrypt, aesEncrypt, hmacSign } from './crypto' import { toNumber } from './generics' import type { ILogger } from './logger' import { LT_HASH_ANTI_TAMPERING } from './lt-hash' @@ -30,47 +31,39 @@ type FetchAppStateSyncKey = (keyId: string) => Promise { - const expanded = await hkdf(keydata, 160, { info: 'WhatsApp Mutation Keys' }) +const mutationKeys = (keydata: Uint8Array) => { + const keys = expandAppStateKeys(keydata) return { - indexKey: expanded.slice(0, 32), - valueEncryptionKey: expanded.slice(32, 64), - valueMacKey: expanded.slice(64, 96), - snapshotMacKey: expanded.slice(96, 128), - patchMacKey: expanded.slice(128, 160) + indexKey: keys.indexKey, + valueEncryptionKey: keys.valueEncryptionKey, + valueMacKey: keys.valueMacKey, + snapshotMacKey: keys.snapshotMacKey, + patchMacKey: keys.patchMacKey } } const generateMac = ( operation: proto.SyncdMutation.SyncdOperation, - data: Buffer, + data: Uint8Array, keyId: Uint8Array | string, - key: Buffer + key: Uint8Array ) => { - const getKeyData = () => { - let r: number - switch (operation) { - case proto.SyncdMutation.SyncdOperation.SET: - r = 0x01 - break - case proto.SyncdMutation.SyncdOperation.REMOVE: - r = 0x02 - break - } + const opByte = operation === proto.SyncdMutation.SyncdOperation.SET ? 0x01 : 0x02 + const keyIdBuffer = typeof keyId === 'string' ? Buffer.from(keyId, 'base64') : keyId + const keyData = new Uint8Array(1 + keyIdBuffer.length) + keyData[0] = opByte + keyData.set(keyIdBuffer, 1) - const buff = Buffer.from([r]) - return Buffer.concat([buff, Buffer.from(keyId as string, 'base64')]) - } + const last = new Uint8Array(8) + last[7] = keyData.length - const keyData = getKeyData() + const total = new Uint8Array(keyData.length + data.length + last.length) + total.set(keyData, 0) + total.set(data, keyData.length) + total.set(last, keyData.length + data.length) - const last = Buffer.alloc(8) // 8 bytes - last.set([keyData.length], last.length - 1) - - const total = Buffer.concat([keyData, data, last]) const hmac = hmacSign(total, key, 'sha512') - - return hmac.slice(0, 32) + return hmac.subarray(0, 32) } const to64BitNetworkOrder = (e: number) => { @@ -83,8 +76,8 @@ type Mac = { indexMac: Uint8Array; valueMac: Uint8Array; operation: proto.SyncdM const makeLtHashGenerator = ({ indexValueMap, hash }: Pick) => { indexValueMap = { ...indexValueMap } - const addBuffs: ArrayBuffer[] = [] - const subBuffs: ArrayBuffer[] = [] + const addBuffs: Uint8Array[] = [] + const subBuffs: Uint8Array[] = [] return { mix: ({ indexMac, valueMac, operation }: Mac) => { @@ -98,29 +91,27 @@ const makeLtHashGenerator = ({ indexValueMap, hash }: Pick { - const hashArrayBuffer = new Uint8Array(hash).buffer - const result = await LT_HASH_ANTI_TAMPERING.subtractThenAdd(hashArrayBuffer, addBuffs, subBuffs) - const buffer = Buffer.from(result) + finish: () => { + const result = LT_HASH_ANTI_TAMPERING.subtractThenAdd(hash, subBuffs, addBuffs) return { - hash: buffer, + hash: Buffer.from(result), indexValueMap } } } } -const generateSnapshotMac = (lthash: Uint8Array, version: number, name: WAPatchName, key: Buffer) => { +const generateSnapshotMac = (lthash: Uint8Array, version: number, name: WAPatchName, key: Uint8Array) => { const total = Buffer.concat([lthash, to64BitNetworkOrder(version), Buffer.from(name, 'utf-8')]) return hmacSign(total, key, 'sha256') } @@ -130,7 +121,7 @@ const generatePatchMac = ( valueMacs: Uint8Array[], version: number, type: WAPatchName, - key: Buffer + key: Uint8Array ) => { const total = Buffer.concat([snapshotMac, ...valueMacs, to64BitNetworkOrder(version), Buffer.from(type, 'utf-8')]) return hmacSign(total, key) @@ -162,7 +153,7 @@ export const encodeSyncdPatch = async ( }) const encoded = proto.SyncActionData.encode(dataProto).finish() - const keyValue = await mutationKeys(key.keyData!) + const keyValue = mutationKeys(key.keyData!) const encValue = aesEncrypt(encoded, keyValue.valueEncryptionKey) const valueMac = generateMac(operation, encValue, encKeyId, keyValue.valueMacKey) @@ -171,7 +162,7 @@ export const encodeSyncdPatch = async ( // update LT hash const generator = makeLtHashGenerator(state) generator.mix({ indexMac, valueMac, operation }) - Object.assign(state, await generator.finish()) + Object.assign(state, generator.finish()) state.version += 1 @@ -211,6 +202,8 @@ export const decodeSyncdMutations = async ( validateMacs: boolean ) => { const ltGenerator = makeLtHashGenerator(initialState) + const derivedKeyCache = new Map>() + // indexKey used to HMAC sign record.index.blob // valueEncryptionKey used to AES-256-CBC encrypt record.value.blob[0:-32] // the remaining record.value.blob[0:-32] is the mac, it the HMAC sign of key.keyId + decoded proto data + length of bytes in keyId @@ -222,9 +215,9 @@ export const decodeSyncdMutations = async ( 'record' in msgMutation && !!msgMutation.record ? msgMutation.record : (msgMutation as proto.ISyncdRecord) const key = await getKey(record.keyId!.id!) - const content = Buffer.from(record.value!.blob!) - const encContent = content.slice(0, -32) - const ogValueMac = content.slice(-32) + const content = record.value!.blob! + const encContent = content.subarray(0, -32) + const ogValueMac = content.subarray(-32) if (validateMacs) { const contentHmac = generateMac(operation!, encContent, record.keyId!.id!, key.valueMacKey) if (Buffer.compare(contentHmac, ogValueMac) !== 0) { @@ -252,10 +245,16 @@ export const decodeSyncdMutations = async ( }) } - return await ltGenerator.finish() + return ltGenerator.finish() async function getKey(keyId: Uint8Array) { const base64Key = Buffer.from(keyId).toString('base64') + + const cached = derivedKeyCache.get(base64Key) + if (cached) { + return cached + } + const keyEnc = await getAppStateSyncKey(base64Key) if (!keyEnc) { throw new Boom(`failed to find key "${base64Key}" to decode mutation`, { @@ -264,7 +263,9 @@ export const decodeSyncdMutations = async ( }) } - return mutationKeys(keyEnc.keyData!) + const keys = mutationKeys(keyEnc.keyData!) + derivedKeyCache.set(base64Key, keys) + return keys } } @@ -283,7 +284,7 @@ export const decodeSyncdPatch = async ( throw new Boom(`failed to find key "${base64Key}" to decode patch`, { statusCode: 404, data: { msg } }) } - const mainKey = await mutationKeys(mainKeyObj.keyData!) + const mainKey = mutationKeys(mainKeyObj.keyData!) const mutationmacs = msg.mutations!.map(mutation => mutation.record!.value!.blob!.slice(-32)) const patchMac = generatePatchMac( @@ -405,7 +406,7 @@ export const decodeSyncdSnapshot = async ( throw new Boom(`failed to find key "${base64Key}" to decode mutation`) } - const result = await mutationKeys(keyEnc.keyData!) + const result = mutationKeys(keyEnc.keyData!) const computedSnapshotMac = generateSnapshotMac(newState.hash, newState.version, name, result.snapshotMacKey) if (Buffer.compare(snapshot.mac!, computedSnapshotMac) !== 0) { throw new Boom(`failed to verify LTHash at ${newState.version} of ${name} from snapshot`) @@ -473,7 +474,7 @@ export const decodePatches = async ( throw new Boom(`failed to find key "${base64Key}" to decode mutation`) } - const result = await mutationKeys(keyEnc.keyData!) + const result = mutationKeys(keyEnc.keyData!) const computedSnapshotMac = generateSnapshotMac(newState.hash, newState.version, name, result.snapshotMacKey) if (Buffer.compare(snapshotMac!, computedSnapshotMac) !== 0) { throw new Boom(`failed to verify LTHash at ${newState.version} of ${name}`) diff --git a/src/Utils/crypto.ts b/src/Utils/crypto.ts index 0e0dc2a1..8bc87c30 100644 --- a/src/Utils/crypto.ts +++ b/src/Utils/crypto.ts @@ -2,6 +2,7 @@ import { createCipheriv, createDecipheriv, createHash, createHmac, randomBytes } import * as curve from 'libsignal/src/curve' import { KEY_BUNDLE_TYPE } from '../Defaults' import type { KeyPair } from '../Types' +export { md5, hkdf } from 'whatsapp-rust-bridge' // insure browser & node compatibility const { subtle } = globalThis.crypto @@ -82,18 +83,18 @@ export function aesDecryptCTR(ciphertext: Uint8Array, key: Uint8Array, iv: Uint8 } /** decrypt AES 256 CBC; where the IV is prefixed to the buffer */ -export function aesDecrypt(buffer: Buffer, key: Buffer) { - return aesDecryptWithIV(buffer.slice(16, buffer.length), key, buffer.slice(0, 16)) +export function aesDecrypt(buffer: Uint8Array, key: Uint8Array) { + return aesDecryptWithIV(buffer.subarray(16), key, buffer.subarray(0, 16)) } /** decrypt AES 256 CBC */ -export function aesDecryptWithIV(buffer: Buffer, key: Buffer, IV: Buffer) { +export function aesDecryptWithIV(buffer: Uint8Array, key: Uint8Array, IV: Uint8Array) { const aes = createDecipheriv('aes-256-cbc', key, IV) return Buffer.concat([aes.update(buffer), aes.final()]) } // encrypt AES 256 CBC; where a random IV is prefixed to the buffer -export function aesEncrypt(buffer: Buffer | Uint8Array, key: Buffer) { +export function aesEncrypt(buffer: Uint8Array, key: Uint8Array) { const IV = randomBytes(16) const aes = createCipheriv('aes-256-cbc', key, IV) return Buffer.concat([IV, aes.update(buffer), aes.final()]) // prefix IV to the buffer @@ -118,44 +119,6 @@ export function sha256(buffer: Buffer) { return createHash('sha256').update(buffer).digest() } -export function md5(buffer: Buffer) { - return createHash('md5').update(buffer).digest() -} - -// HKDF key expansion -export async function hkdf( - buffer: Uint8Array | Buffer, - expandedLength: number, - info: { salt?: Buffer; info?: string } -): Promise { - // Normalize to a Uint8Array whose underlying buffer is a regular ArrayBuffer (not ArrayBufferLike) - // Cloning via new Uint8Array(...) guarantees the generic parameter is ArrayBuffer which satisfies WebCrypto types. - const inputKeyMaterial = new Uint8Array(buffer instanceof Uint8Array ? buffer : new Uint8Array(buffer)) - - // Set default values if not provided - const salt = info.salt ? new Uint8Array(info.salt) : new Uint8Array(0) - const infoBytes = info.info ? new TextEncoder().encode(info.info) : new Uint8Array(0) - - // Import the input key material (cast to BufferSource to appease TS DOM typings) - const importedKey = await subtle.importKey('raw', inputKeyMaterial as BufferSource, { name: 'HKDF' }, false, [ - 'deriveBits' - ]) - - // Derive bits using HKDF - const derivedBits = await subtle.deriveBits( - { - name: 'HKDF', - hash: 'SHA-256', - salt: salt, - info: infoBytes - }, - importedKey, - expandedLength * 8 // Convert bytes to bits - ) - - return Buffer.from(derivedBits) -} - export async function derivePairingCodeKey(pairingCode: string, salt: Buffer): Promise { // Convert inputs to formats Web Crypto API can work with const encoder = new TextEncoder() diff --git a/src/Utils/lt-hash.ts b/src/Utils/lt-hash.ts index a673eba9..1ebd82b0 100644 --- a/src/Utils/lt-hash.ts +++ b/src/Utils/lt-hash.ts @@ -1,65 +1,8 @@ -import { hkdf } from './crypto' +import { LTHashAntiTampering } from 'whatsapp-rust-bridge' /** * LT Hash is a summation based hash algorithm that maintains the integrity of a piece of data * over a series of mutations. You can add/remove mutations and it'll return a hash equal to * if the same series of mutations was made sequentially. */ -const o = 128 - -class LTHash { - salt: string - - constructor(e: string) { - this.salt = e - } - - async add(e: ArrayBuffer, t: ArrayBuffer[]): Promise { - for (const item of t) { - e = await this._addSingle(e, item) - } - - return e - } - - async subtract(e: ArrayBuffer, t: ArrayBuffer[]): Promise { - for (const item of t) { - e = await this._subtractSingle(e, item) - } - - return e - } - - async subtractThenAdd(e: ArrayBuffer, addList: ArrayBuffer[], subtractList: ArrayBuffer[]): Promise { - const subtracted = await this.subtract(e, subtractList) - return this.add(subtracted, addList) - } - - private async _addSingle(e: ArrayBuffer, t: ArrayBuffer): Promise { - const derived = new Uint8Array(await hkdf(Buffer.from(t), o, { info: this.salt })).buffer - return this.performPointwiseWithOverflow(e, derived, (a, b) => a + b) - } - - private async _subtractSingle(e: ArrayBuffer, t: ArrayBuffer): Promise { - const derived = new Uint8Array(await hkdf(Buffer.from(t), o, { info: this.salt })).buffer - return this.performPointwiseWithOverflow(e, derived, (a, b) => a - b) - } - - private performPointwiseWithOverflow( - e: ArrayBuffer, - t: ArrayBuffer, - op: (a: number, b: number) => number - ): ArrayBuffer { - const n = new DataView(e) - const i = new DataView(t) - const out = new ArrayBuffer(n.byteLength) - const s = new DataView(out) - - for (let offset = 0; offset < n.byteLength; offset += 2) { - s.setUint16(offset, op(n.getUint16(offset, true), i.getUint16(offset, true)), true) - } - - return out - } -} -export const LT_HASH_ANTI_TAMPERING = new LTHash('WhatsApp Patch Integrity') +export const LT_HASH_ANTI_TAMPERING = new LTHashAntiTampering() diff --git a/src/Utils/messages-media.ts b/src/Utils/messages-media.ts index d2cbe7d3..8086242d 100644 --- a/src/Utils/messages-media.ts +++ b/src/Utils/messages-media.ts @@ -106,7 +106,7 @@ export async function getMediaKeys( } // expand using HKDF to 112 bytes, also pass in the relevant app info - const expandedMediaKey = await hkdf(buffer, 112, { info: hkdfInfoKey(mediaType) }) + const expandedMediaKey = hkdf(buffer, 112, { info: hkdfInfoKey(mediaType) }) return { iv: expandedMediaKey.slice(0, 16), cipherKey: expandedMediaKey.slice(16, 48), @@ -888,12 +888,12 @@ const getMediaRetryKey = (mediaKey: Buffer | Uint8Array) => { /** * Generate a binary node that will request the phone to re-upload the media & return the newly uploaded URL */ -export const encryptMediaRetryRequest = async (key: WAMessageKey, mediaKey: Buffer | Uint8Array, meId: string) => { +export const encryptMediaRetryRequest = (key: WAMessageKey, mediaKey: Buffer | Uint8Array, meId: string) => { const recp: proto.IServerErrorReceipt = { stanzaId: key.id } const recpBuffer = proto.ServerErrorReceipt.encode(recp).finish() const iv = Crypto.randomBytes(12) - const retryKey = await getMediaRetryKey(mediaKey) + const retryKey = getMediaRetryKey(mediaKey) const ciphertext = aesEncryptGCM(recpBuffer, retryKey, iv, Buffer.from(key.id!)) const req: BinaryNode = { @@ -963,12 +963,12 @@ export const decodeMediaRetryNode = (node: BinaryNode) => { return event } -export const decryptMediaRetryData = async ( +export const decryptMediaRetryData = ( { ciphertext, iv }: { ciphertext: Uint8Array; iv: Uint8Array }, mediaKey: Uint8Array, msgId: string ) => { - const retryKey = await getMediaRetryKey(mediaKey) + const retryKey = getMediaRetryKey(mediaKey) const plaintext = aesDecryptGCM(ciphertext, retryKey, iv, Buffer.from(msgId)) return proto.MediaRetryNotification.decode(plaintext) } diff --git a/src/Utils/noise-handler.ts b/src/Utils/noise-handler.ts index 02db94d3..76e1d712 100644 --- a/src/Utils/noise-handler.ts +++ b/src/Utils/noise-handler.ts @@ -24,8 +24,8 @@ class TransportState { private readonly iv = new Uint8Array(IV_LENGTH) constructor( - private readonly encKey: Buffer, - private readonly decKey: Buffer + private readonly encKey: Uint8Array, + private readonly decKey: Uint8Array ) {} encrypt(plaintext: Uint8Array): Uint8Array { @@ -64,9 +64,9 @@ export const makeNoiseHandler = ({ const data = Buffer.from(NOISE_MODE) let hash = data.byteLength === 32 ? data : sha256(data) - let salt: Buffer = hash - let encKey: Buffer = hash - let decKey: Buffer = hash + let salt: Uint8Array = hash + let encKey: Uint8Array = hash + let decKey: Uint8Array = hash let counter = 0 let sentIntro = false @@ -116,13 +116,13 @@ export const makeNoiseHandler = ({ return result } - const localHKDF = async (data: Uint8Array): Promise<[Buffer, Buffer]> => { - const key = await hkdf(Buffer.from(data), 64, { salt, info: '' }) + const localHKDF = (data: Uint8Array): [Uint8Array, Uint8Array] => { + const key = hkdf(Buffer.from(data), 64, { salt, info: '' }) return [key.subarray(0, 32), key.subarray(32)] } - const mixIntoKey = async (data: Uint8Array) => { - const [write, read] = await localHKDF(data) + const mixIntoKey = (data: Uint8Array) => { + const [write, read] = localHKDF(data) salt = write encKey = read decKey = read @@ -131,7 +131,7 @@ export const makeNoiseHandler = ({ const finishInit = async () => { isWaitingForTransport = true - const [write, read] = await localHKDF(new Uint8Array(0)) + const [write, read] = localHKDF(new Uint8Array(0)) transport = new TransportState(write, read) isWaitingForTransport = false @@ -179,12 +179,12 @@ export const makeNoiseHandler = ({ authenticate, mixIntoKey, finishInit, - processHandshake: async ({ serverHello }: proto.HandshakeMessage, noiseKey: KeyPair) => { + processHandshake: ({ serverHello }: proto.HandshakeMessage, noiseKey: KeyPair) => { authenticate(serverHello!.ephemeral!) - await mixIntoKey(Curve.sharedKey(privateKey, serverHello!.ephemeral!)) + mixIntoKey(Curve.sharedKey(privateKey, serverHello!.ephemeral!)) const decStaticContent = decrypt(serverHello!.static!) - await mixIntoKey(Curve.sharedKey(privateKey, decStaticContent)) + mixIntoKey(Curve.sharedKey(privateKey, decStaticContent)) const certDecoded = decrypt(serverHello!.payload!) @@ -223,7 +223,7 @@ export const makeNoiseHandler = ({ } const keyEnc = encrypt(noiseKey.public) - await mixIntoKey(Curve.sharedKey(noiseKey.private, serverHello!.ephemeral!)) + mixIntoKey(Curve.sharedKey(noiseKey.private, serverHello!.ephemeral!)) return keyEnc }, diff --git a/src/Utils/reporting-utils.ts b/src/Utils/reporting-utils.ts index 2c45ca56..6a839ca8 100644 --- a/src/Utils/reporting-utils.ts +++ b/src/Utils/reporting-utils.ts @@ -102,7 +102,7 @@ export const shouldIncludeReportingToken = (message: proto.IMessage): boolean => !message.encEventResponseMessage && !message.pollUpdateMessage -const generateMsgSecretKey = async ( +const generateMsgSecretKey = ( modificationType: string, origMsgId: string, origMsgSender: string, @@ -321,7 +321,7 @@ export const getMessageReportingToken = async ( const from = key.fromMe ? key.remoteJid! : key.participant || key.remoteJid! const to = key.fromMe ? key.participant || key.remoteJid! : key.remoteJid! - const reportingSecret = await generateMsgSecretKey(ENC_SECRET_REPORT_TOKEN, key.id, from, to, msgSecret) + const reportingSecret = generateMsgSecretKey(ENC_SECRET_REPORT_TOKEN, key.id, from, to, msgSecret) const content = extractReportingTokenContent(msgProtobuf, compiledReportingFields) if (!content || content.length === 0) { diff --git a/yarn.lock b/yarn.lock index 13b75cc1..504716e6 100644 --- a/yarn.lock +++ b/yarn.lock @@ -3025,6 +3025,7 @@ __metadata: typedoc: "npm:^0.27.9" typedoc-plugin-markdown: "npm:4.4.2" typescript: "npm:^5.8.2" + whatsapp-rust-bridge: "npm:0.5.2" ws: "npm:^8.13.0" peerDependencies: audio-decode: ^2.1.3 @@ -10184,6 +10185,13 @@ __metadata: languageName: node linkType: hard +"whatsapp-rust-bridge@npm:0.5.2": + version: 0.5.2 + resolution: "whatsapp-rust-bridge@npm:0.5.2" + checksum: 10c0/022bff4659398144afe6834c279a9fc617a7cbc9177212874150ff2b39019044d2833af85d8ad8d5a40887ad84e7584edead15333e3acce58f989ef7cfd1e6f9 + languageName: node + linkType: hard + "whatwg-url@npm:^5.0.0": version: 5.0.0 resolution: "whatwg-url@npm:5.0.0"