packages/shared/lib/pow/wasmWorker.ts

   1 interface WasmApi {
   2     instance: {
   3         exports: {
   4             b64_output: {
   5                 value: number;
   6             };
   7             solve: () => number;
   8             memory: {
   9                 buffer: Uint8Array;
  10             };
  11         };
  12     };
  13 }
  14
  15 self.onmessage = async function (event) {
  16     const { b64Source } = event.data;
  17
  18     const decodeBase64 = (base64: string) => {
  19         return atob(base64);
  20     };
  21
  22     const decodeWasmBinary = (base64: string) => {
  23         const text = decodeBase64(base64);
  24         const binary = new Uint8Array(new ArrayBuffer(text.length));
  25         for (let i = 0; i < text.length; i++) {
  26             binary[i] = text.charCodeAt(i);
  27         }
  28         return binary;
  29     };
  30
  31     const loadWasmModule = async (source: string) => {
  32         const wasmBinary = decodeWasmBinary(source);
  33         const result = await WebAssembly.instantiate(wasmBinary);
  34         return result as typeof result & WasmApi;
  35     };
  36
  37     const result = await loadWasmModule(b64Source);
  38     const b64OutputPtr = result.instance.exports.b64_output.value;
  39     const startTime = Date.now();
  40     const b64OutputLen = result.instance.exports.solve();
  41     const endTime = Date.now();
  42     const duration = endTime - startTime;
  43     const b64Output = new Uint8Array(result.instance.exports.memory.buffer, b64OutputPtr, b64OutputLen);
  44     const b64 = new TextDecoder().decode(b64Output);
  45     self.postMessage(b64 + `, ${duration}`);
  46 };