Move trace unzip logic to JS parser (#178)

* move unzipping logic to trace_parser

* use DecompressionStream as default

* merge

Author: Fluzko

dial9-tokio-telemetry/tests/js_parser.rs

@@ -143,23 +143,24 @@ fn test_js_parser_resolves_symbols_past_event_cap() {
         r#"
 const {{ parseTrace }} = require("{viewer}/trace_parser.js");
 const fs = require("fs");
-const buf = fs.readFileSync("{trace}");
-const ab = buf.buffer.slice(buf.byteOffset, buf.byteOffset + buf.byteLength);
-const result = parseTrace(ab, {{ maxEvents: 5 }});
-if (result.events.length > 5) {{
-    console.error("expected at most 5 events, got " + result.events.length);
-    process.exit(1);
+async function main() {{
+    const result = await parseTrace(fs.readFileSync("{trace}"), {{ maxEvents: 5 }});
+    if (result.events.length > 5) {{
+        console.error("expected at most 5 events, got " + result.events.length);
+        process.exit(1);
+    }}
+    if (!result.truncated) {{
+        console.error("expected truncated=true");
+        process.exit(1);
+    }}
+    const sym = result.callframeSymbols.get("0x1234");
+    if (!sym || sym.symbol !== "my_function") {{
+        console.error("symbol not resolved: " + JSON.stringify(sym));
+        process.exit(1);
+    }}
+    console.log("OK: " + result.events.length + " events, symbol resolved");
 }}
-if (!result.truncated) {{
-    console.error("expected truncated=true");
-    process.exit(1);
-}}
-const sym = result.callframeSymbols.get("0x1234");
-if (!sym || sym.symbol !== "my_function") {{
-    console.error("symbol not resolved: " + JSON.stringify(sym));
-    process.exit(1);
-}}
-console.log("OK: " + result.events.length + " events, symbol resolved");
+main().catch((e) => {{ console.error(e); process.exit(1); }});
 "#,
         viewer = std::path::Path::new(&manifest_dir)
             .parent()

dial9-viewer/ui/index.html

@@ -663,19 +663,11 @@ <h3>⌨ Keyboard</h3>
                     resetDropZone();
                 });
 
-            async function maybeGunzip(buf) {
-                const b = new Uint8Array(buf);
-                if (b[0] === 0x1f && b[1] === 0x8b) {
-                    return await new Response(new Blob([b]).stream().pipeThrough(new DecompressionStream('gzip'))).arrayBuffer();
-                }
-                return buf;
-            }
-
             function loadFile(file) {
                 const reader = new FileReader();
                 reader.onload = async (e) => {
                     try {
-                        trace = parseTrace(await maybeGunzip(e.target.result));
+                        trace = await parseTrace(e.target.result);
                         processTrace();
                         showViewer(file.name);
                     } catch (err) {
@@ -730,8 +722,7 @@ <h3>⌨ Keyboard</h3>
                     if (!response.ok) throw new Error(`HTTP ${response.status}`);
                     const arrayBuffer = await response.arrayBuffer();
                     loadAbortController = null;
-                    const gunzipped = await maybeGunzip(arrayBuffer);
-                    trace = parseTrace(gunzipped);
+                    trace = await parseTrace(arrayBuffer);
                     processTrace();
                     showViewer(url.split('/').pop() || 'trace.bin');
                 } catch (err) {

dial9-viewer/ui/test_parser.js

@@ -4,7 +4,7 @@
 const fs = require("fs");
 const { parseTrace } = require("./trace_parser.js");
 
-function main() {
+async function main() {
     const args = process.argv.slice(2);
     if (args.length < 2) {
         console.error("Usage: node test_parser.js <trace.bin> <expected.jsonl>");
@@ -15,9 +15,7 @@ function main() {
 
     // Parse binary trace with JS parser
     console.log(`Parsing ${tracePath}...`);
-    const rawBuf = fs.readFileSync(tracePath);
-    const buffer = rawBuf.buffer.slice(rawBuf.byteOffset, rawBuf.byteOffset + rawBuf.byteLength);
-    const trace = parseTrace(buffer);
+    const trace = await parseTrace(fs.readFileSync(tracePath));
 
     console.log(`Parsed ${trace.events.length} events (version ${trace.version})`);
     console.log(`  - ${trace.spawnLocations.size} spawn locations`);
@@ -124,4 +122,4 @@ function main() {
     console.log("\n✓ All checks passed!");
 }
 
-main();
+main().catch((e) => { console.error(e); process.exit(1); });