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

feat: replace async crypto with sync Rust WASM for app state sync (#2315)

Browse Source 
* feat: replace async crypto with sync Rust WASM for app state sync

* fix: remove unecessary buffer copying

* fix: update whatsapp-rust-bridge to version 0.5.2 and refactor async calls to sync. HKDF and MD5 in rust
This commit is contained in:
João Lucas
2026-02-05 11:06:47 -03:00
committed by GitHub
parent fa2a837a4a
commit b5c174111f
12 changed files with 97 additions and 181 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Utils/noise-handler.ts
+14 -14
View File
@@ -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
},