From 3a5bbeaa9898ebcb53dcc88ea7f0bf783e55bdbf Mon Sep 17 00:00:00 2001
From: Steven Vandevelde <steven@tokono.ma>
Date: Thu, 29 May 2025 11:28:06 +0200
Subject: [PATCH] fix: use different method to process blob metadata

---
 deno.lock                                     |  1 +
 .../processor/metadata-fetcher/_applet.astro  | 28 ++++++++++++++-----
 2 files changed, 22 insertions(+), 7 deletions(-)

diff --git a/deno.lock b/deno.lock
index d9dd8da..53cdce2 100644
--- a/deno.lock
+++ b/deno.lock
@@ -21,6 +21,7 @@
     ],
     "packageJson": {
       "dependencies": [
+        "npm:98.css@~0.1.21",
         "npm:@jsr/bradenmacdonald__s3-lite-client@0.9",
         "npm:@jsr/std__media-types@^1.1.0",
         "npm:@picocss/pico@^2.1.1",
diff --git a/src/pages/processor/metadata-fetcher/_applet.astro b/src/pages/processor/metadata-fetcher/_applet.astro
index 0ecbca8..638cfed 100644
--- a/src/pages/processor/metadata-fetcher/_applet.astro
+++ b/src/pages/processor/metadata-fetcher/_applet.astro
@@ -1,6 +1,6 @@
 <script>
   import { applets } from "@web-applets/sdk";
-  import { parseFromTokenizer } from "music-metadata";
+  import { parseFromTokenizer, parseWebStream } from "music-metadata";
   import { contentType } from "@std/media-types";
   import * as URI from "uri-js";
   import * as HTTP_TOKENIZER from "@tokenizer/http";
@@ -32,16 +32,30 @@
 
   // 🛠️
   async function musicMetadataTags(urls: Urls, covers: boolean = false): Promise<Extraction> {
-    const httpClient = new HTTP_TOKENIZER.HttpClient(urls.head, { resolveUrl: false });
-    httpClient.resolvedUrl = urls.get;
-
-    const tokenizer = await RANGE_TOKENIZER.tokenizer(httpClient);
-    const meta = await parseFromTokenizer(tokenizer, { skipCovers: covers });
-
     const uri = URI.parse(urls.get);
     const pathParts = uri.path?.split("/");
     const filename = pathParts?.[pathParts.length - 1];
 
+    let meta;
+
+    if (urls.get.startsWith("blob:")) {
+      const mimeType = filename?.includes(".")
+        ? contentType(filename.split(".").reverse()[0])
+        : undefined;
+
+      const resp = await fetch(urls.get);
+      const stream = resp.body;
+
+      meta = await parseWebStream(stream, { mimeType });
+    } else {
+      const httpClient = new HTTP_TOKENIZER.HttpClient(urls.head, { resolveUrl: false });
+      httpClient.resolvedUrl = urls.get;
+
+      const tokenizer = await RANGE_TOKENIZER.tokenizer(httpClient);
+
+      meta = await parseFromTokenizer(tokenizer, { skipCovers: covers });
+    }
+
     const stats: TrackStats = {
       duration: meta.format.duration,
     };
-- 
2.51.2