Speed up CBOR decoding

Author: SupernaviX

ui/bun.lockb

@@ -10,7 +10,7 @@
     "preview": "vite preview"
   },
   "dependencies": {
-    "cbor": "^10.0.3",
+    "cborg": "^4.2.10",
     "classnames": "^2.5.1",
     "debounce": "^2.2.0",
     "react": "^19.1.0",

ui/package.json

@@ -1,5 +1,5 @@
 import { ISimulationAggregatedDataState, ISimulationIntermediateDataState } from '@/contexts/SimContext/types';
-import * as cbor from 'cbor';
+import * as cbor from 'cborg';
 import type { ReadableStream } from 'stream/web';
 import { IServerMessage } from '../types';
 import { processMessage } from './utils';
@@ -49,11 +49,11 @@ const createCborTransformer = <T>(): TransformStream<Uint8Array, T> => {
       buffer = buffer ? Buffer.concat([buffer, chunk]) : Buffer.from(chunk);
       while (buffer != null) {
         try {
-          const { value, unused } = cbor.decodeFirstSync(buffer, { extendedResults: true });
+          const [value, unused] = cbor.decodeFirst(buffer);
           buffer = unused as Buffer;
           controller.enqueue(value);
         } catch (error: any) {
-          if (error.message === 'Insufficient data') {
+          if (error.message.startsWith('CBOR decode error:')) {
             break;
           } else {
             throw error;

ui/src/components/Sim/hooks/useStreamMessagesHandler.tsx renamed to ui/src/components/Sim/hooks/useStreamMessagesHandler.ts

@@ -26,7 +26,7 @@ export const defaultState: ISimContextState = {
   blocks: {},
   activeTab: Tab.Graph,
   batchSize: 5000,
-  speedMultiplier: 1,
+  speedMultiplier: 10,
   aggregatedData: defaultAggregatedData,
   maxTime: 0,
   tracePath: '',

ui/src/components/Sim/hooks/worker.ts

@@ -1,6 +1,6 @@
 # THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
 # yarn lockfile v1
-# bun ./bun.lockb --hash: 5B922A279112C0FF-408c96441b5fc012-CD1616088D21BE3E-2e50fde5513a0644
+# bun ./bun.lockb --hash: 96870DF7D5AEDD4A-709a51daa2d05e8b-432F0DD73F35DFE5-c96677935b3e8261
 
 
 "@ampproject/remapping@^2.2.0":
@@ -1104,12 +1104,10 @@ caniuse-lite@^1.0.30001688:
   resolved "https://registry.npmjs.org/caniuse-lite/-/caniuse-lite-1.0.30001713.tgz"
   integrity sha512-wCIWIg+A4Xr7NfhTuHdX+/FKh3+Op3LBbSp2N5Pfx6T/LhdQy3GTyoTg48BReaW/MyMNZAkTadsBtai3ldWK0Q==
 
-cbor@^10.0.3:
-  version "10.0.3"
-  resolved "https://registry.npmjs.org/cbor/-/cbor-10.0.3.tgz"
-  integrity sha512-72Jnj81xMsqepqdcSdf2+fflz/UDsThOHy5hj2MW5F5xzHL8Oa0KQ6I6V9CwVUPxg5pf+W9xp6W2KilaRXWWtw==
-  dependencies:
-    nofilter "^3.0.2"
+cborg@^4.2.10:
+  version "4.2.10"
+  resolved "https://registry.npmjs.org/cborg/-/cborg-4.2.10.tgz"
+  integrity sha512-ZVA0xrVn8uBfDJYgfKKZzB/93z/Uiz7YtRdBPsZi/gyHNyqFdHMLHURVEk9dejOHepaX0zhcMyNva2/vF972SA==
 
 chalk@^4.0.0:
   version "4.1.2"
@@ -2225,11 +2223,6 @@ node-stdlib-browser@^1.2.0:
     util "^0.12.4"
     vm-browserify "^1.0.1"
 
-nofilter@^3.0.2:
-  version "3.1.0"
-  resolved "https://registry.npmjs.org/nofilter/-/nofilter-3.1.0.tgz"
-  integrity sha512-l2NNj07e9afPnhAhvgVrCD/oy2Ai1yfLpuo3EpiO1jFTsB4sFz6oIfAfSZyQzVpkZQ9xS8ZS5g1jCBgq4Hwo0g==
-
 object-assign@^4.1.1:
   version "4.1.1"
   resolved "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz"