feat: implement binary node wasm

package.json

@@ -49,6 +49,7 @@
     "p-queue": "^9.0.0",
     "pino": "^9.6",
     "protobufjs": "^7.2.4",
+    "whatsapp-rust-bridge": "^0.4.0",
     "ws": "^8.13.0"
   },
   "devDependencies": {

src/Socket/socket.ts

@@ -58,7 +58,6 @@
  * - listen to messages and emit events
  * - query phone connection
  */
-
 export const makeSocket = (config: SocketConfig) => {
 	const {
 		waWebSocketUrl,
@@ -192,7 +191,7 @@
 
 		const msgId = node.attrs.id
 
 		const result = await promiseTimeout<any>(timeoutMs, async (resolve, reject) => {
 			const result = waitForMessage(msgId, timeoutMs).catch(reject)
 			sendNode(node)
 				.then(async () => resolve(await result))
@@ -576,7 +575,7 @@
 			anyTriggered = ws.emit('frame', frame)
 			// if it's a binary node
 			if (!(frame instanceof Uint8Array)) {
-				const msgId = frame.attrs.id
+				const msgId = frame.attrs?.id
 
 				if (logger.level === 'trace') {
 					logger.trace({ xml: binaryNodeToString(frame), msg: 'recv xml' })
@@ -826,7 +825,7 @@
 	ws.on('open', async () => {
 		try {
 			await validateConnection()
 		} catch (err: any) {
 			logger.error({ err }, 'error in validating connection')
 			end(err)
 		}
@@ -867,10 +866,12 @@
 				return
 			}
 
-			const ref = (refNode.content as Buffer).toString('utf-8')
-			const qr = [ref, noiseKeyB64, identityKeyB64, advB64].join(',')
+			if (refNode.content instanceof Uint8Array) {
+				const ref = Buffer.from(refNode.content).toString('utf-8')
+				const qr = [ref, noiseKeyB64, identityKeyB64, advB64].join(',')
 
-			ev.emit('connection.update', { qr })
+				ev.emit('connection.update', { qr })
+			}
 
 			qrTimer = setTimeout(genPairQR, qrMs)
 			qrMs = qrTimeout || 20_000 // shorter subsequent qrs
@@ -894,7 +895,7 @@
 			ev.emit('connection.update', { isNewLogin: true, qr: undefined })
 
 			await sendNode(reply)
 		} catch (error: any) {
 			logger.info({ trace: error.stack }, 'error in pairing')
 			end(error)
 		}

src/Utils/chat-utils.ts

@@ -326,7 +326,7 @@ export const extractSyncdPatches = async (result: BinaryNode, options: RequestIn
 					snapshotNode.content = Buffer.from(Object.values(snapshotNode.content))
 				}
 
-				const blobRef = proto.ExternalBlobReference.decode(snapshotNode.content as Buffer)
+				const blobRef = proto.ExternalBlobReference.decode(snapshotNode.content as Uint8Array)
 				const data = await downloadExternalBlob(blobRef, options)
 				snapshot = proto.SyncdSnapshot.decode(data)
 			}

src/Utils/decode-wa-message.ts

@@ -280,15 +280,15 @@ export const decryptMessageNode = (
 								msgBuffer = await repository.decryptGroupMessage({
 									group: sender,
 									authorJid: author,
-									msg: content
+									msg: Buffer.from(content)
 								})
 								break
 							case 'pkmsg':
 							case 'msg':
 								msgBuffer = await repository.decryptMessage({
 									jid: decryptionJid,
 									type: e2eType,
-									ciphertext: content
+									ciphertext: Buffer.from(content)
 								})
 								break
 							case 'plaintext':

src/Utils/noise-handler.ts

@@ -158,7 +158,7 @@ export const makeNoiseHandler = ({
 
 			return frame
 		},
-		decodeFrame: async (newData: Buffer | Uint8Array, onFrame: (buff: Uint8Array | BinaryNode) => void) => {
+		decodeFrame: (newData: Buffer | Uint8Array, onFrame: (buff: Uint8Array | BinaryNode) => void) => {
 			// the binary protocol uses its own framing mechanism
 			// on top of the WS frames
 			// so we get this data and separate out the frames
@@ -179,7 +179,7 @@ export const makeNoiseHandler = ({
 
 				if (isFinished) {
 					const result = decrypt(frame)
-					frame = await decodeBinaryNode(result)
+					frame = decodeBinaryNode(result)
 				}
 
 				logger.trace({ msg: (frame as BinaryNode)?.attrs?.id }, 'recv frame')

src/Utils/validate-connection.ts

@@ -169,7 +169,9 @@ export const configureSuccessfulPairing = (
 	const jid = deviceNode.attrs.jid
 	const lid = deviceNode.attrs.lid
 
-	const { details, hmac, accountType } = proto.ADVSignedDeviceIdentityHMAC.decode(deviceIdentityNode.content as Buffer)
+	const { details, hmac, accountType } = proto.ADVSignedDeviceIdentityHMAC.decode(
+		deviceIdentityNode.content as Uint8Array
+	)
 
 	let hmacPrefix = Buffer.from([])
 	if (accountType !== undefined && accountType === proto.ADVEncryptionType.HOSTED) {