mirror of
https://git.unlock-music.dev/um/web.git
synced 2025-11-05 11:51:24 +00:00
use wasm in npm packages
This commit is contained in:
@@ -1,4 +1,5 @@
|
||||
import KgmCryptoModule from '@/KgmWasm/KgmWasmBundle';
|
||||
import { KgmCrypto } from '@xhacker/kgmwasm/KgmWasmBundle';
|
||||
import KgmCryptoModule from '@xhacker/kgmwasm/KgmWasmBundle';
|
||||
import { MergeUint8Array } from '@/utils/MergeUint8Array';
|
||||
|
||||
// 每次处理 2M 的数据
|
||||
@@ -20,26 +21,26 @@ export async function DecryptKgmWasm(kgmBlob: ArrayBuffer, ext: string): Promise
|
||||
const result: KGMDecryptionResult = { success: false, data: new Uint8Array(), error: '' };
|
||||
|
||||
// 初始化模组
|
||||
let KgmCrypto: any;
|
||||
let KgmCryptoObj: KgmCrypto;
|
||||
|
||||
try {
|
||||
KgmCrypto = await KgmCryptoModule();
|
||||
KgmCryptoObj = await KgmCryptoModule();
|
||||
} catch (err: any) {
|
||||
result.error = err?.message || 'wasm 加载失败';
|
||||
return result;
|
||||
}
|
||||
if (!KgmCrypto) {
|
||||
if (!KgmCryptoObj) {
|
||||
result.error = 'wasm 加载失败';
|
||||
return result;
|
||||
}
|
||||
|
||||
// 申请内存块,并文件末端数据到 WASM 的内存堆
|
||||
let kgmBuf = new Uint8Array(kgmBlob);
|
||||
const pQmcBuf = KgmCrypto._malloc(DECRYPTION_BUF_SIZE);
|
||||
KgmCrypto.writeArrayToMemory(kgmBuf.slice(0, DECRYPTION_BUF_SIZE), pQmcBuf);
|
||||
const pQmcBuf = KgmCryptoObj._malloc(DECRYPTION_BUF_SIZE);
|
||||
KgmCryptoObj.writeArrayToMemory(kgmBuf.slice(0, DECRYPTION_BUF_SIZE), pQmcBuf);
|
||||
|
||||
// 进行解密初始化
|
||||
const headerSize = KgmCrypto.preDec(pQmcBuf, DECRYPTION_BUF_SIZE, ext);
|
||||
const headerSize = KgmCryptoObj.preDec(pQmcBuf, DECRYPTION_BUF_SIZE, ext);
|
||||
console.log(headerSize);
|
||||
kgmBuf = kgmBuf.slice(headerSize);
|
||||
|
||||
@@ -51,14 +52,14 @@ export async function DecryptKgmWasm(kgmBlob: ArrayBuffer, ext: string): Promise
|
||||
|
||||
// 解密一些片段
|
||||
const blockData = new Uint8Array(kgmBuf.slice(offset, offset + blockSize));
|
||||
KgmCrypto.writeArrayToMemory(blockData, pQmcBuf);
|
||||
KgmCrypto.decBlob(pQmcBuf, blockSize, offset);
|
||||
decryptedParts.push(KgmCrypto.HEAPU8.slice(pQmcBuf, pQmcBuf + blockSize));
|
||||
KgmCryptoObj.writeArrayToMemory(blockData, pQmcBuf);
|
||||
KgmCryptoObj.decBlob(pQmcBuf, blockSize, offset);
|
||||
decryptedParts.push(KgmCryptoObj.HEAPU8.slice(pQmcBuf, pQmcBuf + blockSize));
|
||||
|
||||
offset += blockSize;
|
||||
bytesToDecrypt -= blockSize;
|
||||
}
|
||||
KgmCrypto._free(pQmcBuf);
|
||||
KgmCryptoObj._free(pQmcBuf);
|
||||
|
||||
result.data = MergeUint8Array(decryptedParts);
|
||||
result.success = true;
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
import QmcCryptoModule from '@/QmcWasm/QmcWasmBundle';
|
||||
import { QmcCrypto } from '@xhacker/qmcwasm/QmcWasmBundle';
|
||||
import QmcCryptoModule from '@xhacker/qmcwasm/QmcWasmBundle';
|
||||
import { MergeUint8Array } from '@/utils/MergeUint8Array';
|
||||
|
||||
// 每次处理 2M 的数据
|
||||
@@ -21,32 +22,32 @@ export async function DecryptQmcWasm(qmcBlob: ArrayBuffer, ext: string): Promise
|
||||
const result: QMCDecryptionResult = { success: false, data: new Uint8Array(), songId: 0, error: '' };
|
||||
|
||||
// 初始化模组
|
||||
let QmcCrypto: any;
|
||||
let QmcCryptoObj: QmcCrypto;
|
||||
|
||||
try {
|
||||
QmcCrypto = await QmcCryptoModule();
|
||||
QmcCryptoObj = await QmcCryptoModule();
|
||||
} catch (err: any) {
|
||||
result.error = err?.message || 'wasm 加载失败';
|
||||
return result;
|
||||
}
|
||||
if (!QmcCrypto) {
|
||||
if (!QmcCryptoObj) {
|
||||
result.error = 'wasm 加载失败';
|
||||
return result;
|
||||
}
|
||||
|
||||
// 申请内存块,并文件末端数据到 WASM 的内存堆
|
||||
const qmcBuf = new Uint8Array(qmcBlob);
|
||||
const pQmcBuf = QmcCrypto._malloc(DECRYPTION_BUF_SIZE);
|
||||
QmcCrypto.writeArrayToMemory(qmcBuf.slice(-DECRYPTION_BUF_SIZE), pQmcBuf);
|
||||
const pQmcBuf = QmcCryptoObj._malloc(DECRYPTION_BUF_SIZE);
|
||||
QmcCryptoObj.writeArrayToMemory(qmcBuf.slice(-DECRYPTION_BUF_SIZE), pQmcBuf);
|
||||
|
||||
// 进行解密初始化
|
||||
ext = '.' + ext;
|
||||
const tailSize = QmcCrypto.preDec(pQmcBuf, DECRYPTION_BUF_SIZE, ext);
|
||||
const tailSize = QmcCryptoObj.preDec(pQmcBuf, DECRYPTION_BUF_SIZE, ext);
|
||||
if (tailSize == -1) {
|
||||
result.error = QmcCrypto.getError();
|
||||
result.error = QmcCryptoObj.getErr();
|
||||
return result;
|
||||
} else {
|
||||
result.songId = QmcCrypto.getSongId();
|
||||
result.songId = QmcCryptoObj.getSongId();
|
||||
result.songId = result.songId == "0" ? 0 : result.songId;
|
||||
}
|
||||
|
||||
@@ -58,13 +59,13 @@ export async function DecryptQmcWasm(qmcBlob: ArrayBuffer, ext: string): Promise
|
||||
|
||||
// 解密一些片段
|
||||
const blockData = new Uint8Array(qmcBuf.slice(offset, offset + blockSize));
|
||||
QmcCrypto.writeArrayToMemory(blockData, pQmcBuf);
|
||||
decryptedParts.push(QmcCrypto.HEAPU8.slice(pQmcBuf, pQmcBuf + QmcCrypto.decBlob(pQmcBuf, blockSize, offset)));
|
||||
QmcCryptoObj.writeArrayToMemory(blockData, pQmcBuf);
|
||||
decryptedParts.push(QmcCryptoObj.HEAPU8.slice(pQmcBuf, pQmcBuf + QmcCryptoObj.decBlob(pQmcBuf, blockSize, offset)));
|
||||
|
||||
offset += blockSize;
|
||||
bytesToDecrypt -= blockSize;
|
||||
}
|
||||
QmcCrypto._free(pQmcBuf);
|
||||
QmcCryptoObj._free(pQmcBuf);
|
||||
|
||||
result.data = MergeUint8Array(decryptedParts);
|
||||
result.success = true;
|
||||
|
||||
Reference in New Issue
Block a user