[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_392":393,"_394":395},"routes/_app.x.$handle.$name",{"_98":97,"_32":44,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",52,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","01a0839c-dfb7-737a-b44f-53cb30ef4ace","name","fileType","content","# Audio to Insight\n\n[Open the app](url:index.ts)\n\nAudio files are saved in val-scoped Blob storage; processing records, transcripts, summaries and speaker paragraphs are in val-scoped SQLite.\n\n## Quick transcription\n\nSign in as **scoot**. At the top, use **Transcribe now**:\n- Paste a direct MP3 URL or episode webpage (saves the first verified MP3).\n- Or upload MP3, WAV, M4A, AAC, OGG or FLAC, up to 8 MiB.\n- Choose the language, then **Transcribe & summarize**.\n- Read the summary, search the transcript, copy it, or download a text file.\n\nIn **Saved audio & transcripts**, choose a language and transcribe a previous file, or open **Read transcript / status**.\n\n## Speechmatics\n\nThe configured `SPEECHMATICS_API_KEY` is read only in server code with `Deno.env.get`. It authenticated successfully against the US1 Batch API. No key is sent to the browser.\n\nUses the enhanced model, speaker diarization and Speechmatics summarization. English is the default; Spanish, French, German, Italian, Portuguese and Dutch are also available in the UI. Audio is sent to Speechmatics and uses the connected account's credits/pricing.\n\nJobs are asynchronous. A per-job authenticated callback retrieves and saves results even if the browser is closed. Open readers refresh pending jobs every six seconds as a fallback. Reopening a pending transcript also checks its current status.\n\nThe `transcripts` table stores the provider job ID, language, asset hash, status, full transcript, summary/status, and timestamped speaker paragraphs. The same audio hash plus language reuses its job, even across different saved source URLs. Failed or uncertain submissions are not automatically resubmitted, avoiding duplicate paid jobs; uncertain submissions require checking Speechmatics first.\n\nIf no speech or no summary is returned, the reader says so; it does not fabricate a substitute.\n\n## Access and limits\n\nPublic inspection remains available. Saving, uploading, transcription, history, reading transcripts, and downloading audio require the scoot owner session. The app browser login is separate from MCP authorization.\n\n8 MiB per file, 9 MiB app Blob budget. Existing MP3s and history are preserved. Inspection-only mode does not save data. URL discovery does not execute remote JavaScript or bypass login/DRM. URLs download MP3 only; uploads support additional formats without conversion.\n\n## API additions\n\nOwner session required:\n- POST `/api/transcribe` with JSON `{ \"url\": \"https://…\", \"language\": \"en\" }` or `{ \"audioId\": \"...\", \"language\": \"en\" }`\n- POST `/api/upload` with multipart fields `file` and `language`\n- GET `/api/transcripts`: compact index\n- GET `/api/transcripts/:id`: saved text, summary and status\n- POST `/api/transcripts/:id/refresh`: synchronize the existing provider job\n\nPOST `/api/speechmatics/callback/:id` requires a unique per-job credential and verifies results by fetching them directly from Speechmatics.\n\n## Verified\n\nThe official Speechmatics welcome audio was uploaded and transcribed. Its callback saved both the full transcript and summary; duplicate submission reused the same job. Find `speechmatics-welcome.wav` in your private library. The previous MP3 sample and webpage records remain available for on-demand transcription.","# Audio to Insight\n\n[Open the app](url:index.ts)\n\nAudio files are saved in val-scoped Blob storage; processing records, transcripts, summaries and speaker paragraphs are in val-scoped SQLite.\n\n## Quick transcription\n\nSign in as **scoot**. At the top, use **Transcribe now**:\n- Paste a direct MP3 URL or episode webpage (saves the first verified MP3).\n- Or upload MP3, WAV, M4A, AAC, OGG or FLAC, up to 8 MiB.\n- Choose the language, then **Transcribe & summarize**.\n- Read the summary, search the transcript, copy it, or download a text file.\n\nIn **Saved audio & transcripts**, choose a language and transcribe a previous file, or open **Read transcript / status**.\n\n## Speechmatics\n\nThe configured `SPEECHMATICS_API_KEY` is read only in server code with `Deno.env.get`. It authenticated successfully against the US1 Batch API. No key is sent to the browser.\n\nUses the enhanced model, speaker diarization and Speechmatics summarization. English is the default; Spanish, French, German, Italian, Portuguese and Dutch are also available in the UI. Audio is sent to Speechmatics and uses the connected account's credits/pricing.\n\nJobs are asynchronous. A per-job authenticated callback retrieves and saves results even if the browser is closed. Open readers refresh pending jobs every six seconds as a fallback. Reopening a pending transcript also checks its current status.\n\nThe `transcripts` table stores the provider job ID, language, asset hash, status, full transcript, summary/status, and timestamped speaker paragraphs. The same audio hash plus language reuses its job, even across different saved source URLs. Failed or uncertain submissions are not automatically resubmitted, avoiding duplicate paid jobs; uncertain submissions require checking Speechmatics first.\n\nIf no speech or no summary is returned, the reader says so; it does not fabricate a substitute.\n\n## Access and limits\n\nPublic inspection remains available. Saving, uploading, transcription, history, reading transcripts, and downloading audio require a signed-in Val Town session; all signed-in users share the library and the configured Speechmatics credits. The app browser login is separate from MCP authorization.\n\n8 MiB per file, 9 MiB app Blob budget. Existing MP3s and history are preserved. Inspection-only mode does not save data. URL discovery does not execute remote JavaScript or bypass login/DRM. URLs download MP3 only; uploads support additional formats without conversion.\n\n## API additions\n\nVal Town sign-in required:\n- POST `/api/transcribe` with JSON `{ \"url\": \"https://…\", \"language\": \"en\" }` or `{ \"audioId\": \"...\", \"language\": \"en\" }`\n- POST `/api/upload` with multipart fields `file` and `language`\n- GET `/api/transcripts`: compact index\n- GET `/api/transcripts/:id`: saved text, summary and status\n- POST `/api/transcripts/:id/refresh`: synchronize the existing provider job\n\nPOST `/api/speechmatics/callback/:id` requires a unique per-job credential and verifies results by fetching them directly from Speechmatics.\n\n## Verified\n\nThe official Speechmatics welcome audio was uploaded and transcribed. Its callback saved both the full transcript and summary; duplicate submission reused the same job. Find `speechmatics-welcome.wav` in your private library. The previous MP3 sample and webpage records remain available for on-demand transcription.","createdAt",["D",1788919007025],"branchVersion","branchId","28a047d3-5295-4f5c-942b-0a5bf4f378ce","id","bdedbd3b-32ac-408c-b811-167ee9493295","audio-url-inspector",["D",1788914491210],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Resolve audio from URLs and inspect metadata. No transcription.","imageUrl","22d9499e-268b-4d84-b877-2162e7b516e0","pinnedFileId","01a0839c-dfb7-737a-b44f-56735981b04d","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a083cf-8df7-773b-acea-1b3fc2faed11","tursoName","bdedbd3b32ac408cb811167ee9493295","tursoHostname","bdedbd3b32ac408cb811167ee9493295-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":-5},"org",{"_98":97,"_99":100,"_101":-5,"_18":-5,"_102":103,"_104":25},"branch",{"_13":14,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","scott_mike","handle","displayName","scott-mike","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":387,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":388,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":389,"_83":390,"_85":391,"_87":25},"tree",[253,263,264,265,266,267,268,269,270,271,272,273,274,275],"files",[253,254,255,256,257,258,259,260,261,262,263,264,265,266,267,268,269,270,271,272,273,274,275],"counts",{"_243":62,"_244":149,"_245":62,"_246":247,"_248":249},"contents",[128,129,130,131,132,133,134,135,136,137,138,139,140,141],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":237,"_32":238,"_30":239,"_145":-5,"_40":41,"_39":149,"_147":58,"_37":240,"_13":62,"_33":241,"_34":-5,"_24":25,"_152":-5,"_27":242},{"_42":231,"_32":232,"_30":233,"_145":-5,"_40":41,"_39":149,"_147":58,"_37":234,"_13":62,"_33":20,"_34":235,"_24":25,"_152":-5,"_27":236},{"_42":228,"_32":28,"_30":31,"_145":-5,"_40":41,"_39":14,"_147":58,"_37":229,"_13":210,"_33":20,"_34":36,"_24":25,"_152":-5,"_27":230},{"_42":221,"_32":222,"_30":223,"_145":-5,"_40":41,"_39":224,"_147":58,"_37":225,"_13":202,"_33":150,"_34":226,"_24":25,"_152":-5,"_27":227},{"_42":213,"_32":214,"_30":56,"_145":-5,"_40":41,"_39":215,"_147":58,"_37":216,"_13":217,"_33":218,"_34":219,"_24":25,"_152":-5,"_27":220},{"_42":205,"_32":206,"_30":207,"_145":-5,"_40":41,"_39":208,"_147":58,"_37":209,"_13":210,"_33":150,"_34":211,"_24":25,"_152":-5,"_27":212},{"_42":197,"_32":198,"_30":199,"_145":-5,"_40":41,"_39":200,"_147":58,"_37":201,"_13":202,"_33":150,"_34":203,"_24":25,"_152":-5,"_27":204},{"_42":190,"_32":191,"_30":192,"_145":-5,"_40":41,"_39":193,"_147":58,"_37":194,"_13":62,"_33":150,"_34":195,"_24":25,"_152":-5,"_27":196},{"_42":183,"_32":184,"_30":185,"_145":-5,"_40":41,"_39":186,"_147":58,"_37":187,"_13":62,"_33":150,"_34":188,"_24":25,"_152":-5,"_27":189},{"_42":176,"_32":177,"_30":178,"_145":-5,"_40":41,"_39":179,"_147":58,"_37":180,"_13":149,"_33":150,"_34":181,"_24":25,"_152":-5,"_27":182},{"_42":169,"_32":170,"_30":171,"_145":-5,"_40":41,"_39":172,"_147":58,"_37":173,"_13":149,"_33":150,"_34":174,"_24":25,"_152":-5,"_27":175},{"_42":162,"_32":163,"_30":164,"_145":-5,"_40":41,"_39":165,"_147":58,"_37":166,"_13":62,"_33":150,"_34":167,"_24":25,"_152":-5,"_27":168},{"_42":154,"_32":155,"_30":156,"_145":-5,"_40":41,"_39":157,"_147":58,"_37":158,"_13":159,"_33":150,"_34":160,"_24":25,"_152":-5,"_27":161},{"_42":142,"_32":143,"_30":144,"_145":-5,"_40":41,"_39":146,"_147":58,"_37":148,"_13":149,"_33":150,"_34":151,"_24":25,"_152":-5,"_27":153},"6fe1d29d-c962-44e4-972e-eb02dedac3e4","uploader-tests.ts","f4901ed2-abef-11f1-a6fb-1607ee4eb77e","parentId",48,"latest",["D",1788918274528],1,"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { init, recordUploader, history } from \"./storage.ts\";\nasync function verify() {\n await init();\n const audioId=\"uploader-test:\"+crypto.randomUUID();\n const check=(ok:boolean,message:string)=>{if(!ok)throw new Error(message);};\n try {\n await recordUploader(audioId,{id:\"test-a\",username:\"Alice\"});\n await recordUploader(audioId,{id:\"test-a\",username:\"AliceUpdated\"});\n await recordUploader(audioId,{id:\"test-b\",username:\"Bob\"});\n await recordUploader(audioId);\n const rows=(await sqlite.execute({sql:\"SELECT user_id,username FROM audio_uploaders WHERE audio_id=? ORDER BY user_id\",args:[audioId]})).rows;\n check(rows.length===2,\"Duplicate uploads should retain two unique users.\");\n check(rows[0].username===\"AliceUpdated\"&&rows[1].username===\"Bob\",\"Usernames should persist and update.\");\n const h=await history();\n check(h.records.every(r=>Array.isArray(r.uploaders)),\"History must include uploader arrays for legacy records too.\");\n return {ok:true,checks:[\"persistent attribution\",\"duplicate-user upsert\",\"multiple uploaders\",\"legacy history compatibility\"]};\n } finally {\n await sqlite.execute({sql:\"DELETE FROM audio_uploaders WHERE audio_id=?\",args:[audioId]});\n }\n}\n\nconsole.log(JSON.stringify(await verify()));\n","label",[143],"fe2fcdfa-32c8-45f2-93e6-13fadde9ffef","storage.ts","29e8b1c2-abe9-11f1-8145-1607ee4eb77e",42,["D",1788918203263],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { inspect, validate, safeFetch, InspectError } from \"./inspector.ts\";\nconst MAX_FILE=8*1024*1024, APP_BUDGET=9*1024*1024;\nexport async function init() {\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS audio_jobs (\n id TEXT PRIMARY KEY, source_url TEXT NOT NULL UNIQUE, resolved_url TEXT, status TEXT NOT NULL,\n filename TEXT, blob_key TEXT, size_bytes INTEGER, sha256 TEXT, content_type TEXT,\n result_json TEXT, error TEXT, attempts INTEGER NOT NULL DEFAULT 1,\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL)`,args:[]},\n {sql:\"CREATE TABLE IF NOT EXISTS audio_assets (resolved_url TEXT PRIMARY KEY, blob_key TEXT NOT NULL, size_bytes INTEGER NOT NULL, sha256 TEXT NOT NULL, filename TEXT NOT NULL)\",args:[]},\n {sql:\"CREATE TABLE IF NOT EXISTS audio_uploaders (audio_id TEXT NOT NULL, user_id TEXT NOT NULL, username TEXT NOT NULL, PRIMARY KEY(audio_id,user_id))\",args:[]},\n {sql:\"CREATE TABLE IF NOT EXISTS audio_mutex (id INTEGER PRIMARY KEY, token TEXT, expires_at INTEGER NOT NULL)\",args:[]},\n {sql:\"INSERT OR IGNORE INTO audio_mutex(id,expires_at) VALUES(1,0)\",args:[]}\n ]);\n}\nfunction publicJob(row:any) {\n if(!row)return null;\n return {id:row.id,sourceUrl:row.source_url,resolvedUrl:row.resolved_url,status:row.status,filename:row.filename,\n sizeBytes:row.size_bytes,sha256:row.sha256,contentType:row.content_type,error:row.error,attempts:row.attempts,\n createdAt:row.created_at,updatedAt:row.updated_at,downloadUrl:row.status===\"saved\"?\"/api/files/\"+row.id:null};\n}\nasync function getJob(url:string) {\n return (await sqlite.execute({sql:\"SELECT * FROM audio_jobs WHERE source_url=?\",args:[url]})).rows[0];\n}\nfunction response(row:any,reused=false) {\n return {ok:row.status===\"saved\",reused,record:publicJob(row),inspection:row.result_json?JSON.parse(row.result_json):null};\n}\nexport async function history(offset=0) {\n await init();\n const rows=await sqlite.execute({sql:\"SELECT * FROM audio_jobs ORDER BY updated_at DESC LIMIT 25 OFFSET ?\",args:[offset]});\n const totals=await sqlite.execute(\"SELECT status,COUNT(*) AS count FROM audio_jobs GROUP BY status\");\n const used=(await blob.list(\"audio:\")).reduce((n:any,b:any)=>n+b.size,0);\n const uploaders=rows.rows.length?(await sqlite.execute({sql:\"SELECT audio_id,username FROM audio_uploaders WHERE audio_id IN (\"+rows.rows.map(()=>\"?\").join(\",\")+\") ORDER BY username\",args:rows.rows.map(r=>r.id)})).rows:[];\n return {records:rows.rows.map(row=>({...publicJob(row),uploaders:uploaders.filter(u=>u.audio_id===row.id).map(u=>String(u.username))})),offset,hasMore:rows.rows.length===25,counts:totals.rows,\n storage:{usedBytes:used,appBudgetBytes:APP_BUDGET,maxFileBytes:MAX_FILE},publicLibrary:false};\n}\nasync function fullMp3(url:string) {\n const {response:r,url:resolvedUrl}=await safeFetch(url,AbortSignal.timeout(25000),true);\n const len=r.headers.get(\"content-length\"), type=(r.headers.get(\"content-type\")||\"\").split(\";\")[0].toLowerCase();\n if(r.status!==200) {await r.body?.cancel();throw new Error(\"Full download returned HTTP \"+r.status+\"; partial files will not be saved.\");}\n if(len && Number(len)>MAX_FILE) {await r.body?.cancel();throw new Error(\"MP3 exceeds the 8 MiB per-file limit.\");}\n const reader=r.body?.getReader();if(!reader)throw new Error(\"Source returned no body.\");\n let size=0;const chunks:Uint8Array[]=[];\n try {while(true) {const {done,value}=await reader.read();if(done)break;size+=value.length;\n if(size>MAX_FILE)throw new Error(\"MP3 exceeds the 8 MiB per-file limit.\");chunks.push(value);}}\n finally{await reader.cancel().catch(()=>{});}\n if(!size)throw new Error(\"Source returned an empty file.\");\n // Content-Length refers to encoded bytes when compression is enabled.\n if(len && !r.headers.get(\"content-encoding\") && size!==Number(len))throw new Error(\"Incomplete download; nothing was saved.\");\n const bytes=new Uint8Array(size);let offset=0;for(const part of chunks){bytes.set(part,offset);offset+=part.length;}\n const head=new TextDecoder().decode(bytes.subarray(0,256)).trimStart();\n const id3=bytes[0]===73&&bytes[1]===68&&bytes[2]===51;\n // MPEG Layer III frame sync; excludes AAC ADTS and other MPEG layers.\n const frame=bytes[0]===255&&(bytes[1]&224)===224&&(bytes[1]&6)===2;\n if(/html|xml|json/.test(type)||head.startsWith(\"<\")||(!id3&&!frame))throw new Error(\"Downloaded bytes do not have an MP3 signature. No conversion is performed.\");\n const hash=Array.from(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes))).map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");\n return {bytes,size,hash,resolvedUrl};\n}\nexport type Uploader = { id: string; username: string };\nexport async function recordUploader(audioId:string,uploader?:Uploader) {\n if(!uploader?.id || !uploader.username)return;\n await sqlite.execute({sql:\"INSERT INTO audio_uploaders(audio_id,user_id,username) VALUES(?,?,?) ON CONFLICT(audio_id,user_id) DO UPDATE SET username=excluded.username\",args:[audioId,uploader.id,uploader.username]});\n}\nexport async function processUrl(raw:unknown,uploader?:Uploader) {\n const result=await processUrlInternal(raw);\n if(result.record?.status===\"saved\")await recordUploader(String(result.record.id),uploader);\n return result;\n}\nasync function processUrlInternal(raw:unknown) {\n if(typeof raw!==\"string\"||raw.length>4096)throw new InspectError(\"Provide a URL of at most 4096 characters.\",400);\n const url=validate(raw.trim()).href;await init();\n let previous=await getJob(url);\n if(previous && [\"saved\",\"no_audio\",\"unsupported\"].includes(String(previous.status)))return response(previous,true);\n const token=crypto.randomUUID(), now=Date.now();\n const lock=await sqlite.execute({sql:\"UPDATE audio_mutex SET token=?,expires_at=? WHERE id=1 AND expires_ata.format===\"MP3 (ID3)\" || (a.format===\"MPEG audio\" && (a.contentType===\"audio/mpeg\" || /\\.mp3(?:$|[?#])/i.test(a.resolvedUrl))));\n if(!chosen) {\n const status=result.audio.length?\"unsupported\":\"no_audio\";\n const error=status===\"unsupported\"?\"Audio was found, but this download POC saves MP3 only. No conversion is performed.\":\"No accessible audio found.\";\n await sqlite.execute({sql:\"UPDATE audio_jobs SET status=?,error=?,updated_at=? WHERE id=?\",args:[status,error,new Date().toISOString(),id]});\n return response(await getJob(url));\n }\n let asset=(await sqlite.execute({sql:\"SELECT * FROM audio_assets WHERE resolved_url=?\",args:[chosen.resolvedUrl]})).rows[0];\n let duplicateAsset=!!asset;\n if(!asset) {\n const data=await fullMp3(chosen.resolvedUrl);\n const key=\"audio:\"+data.hash+\".mp3\";\n let filename=(chosen.filename||\"audio.mp3\").replace(/[^a-zA-Z0-9._-]/g,\"_\").slice(0,150);\n if(!filename.toLowerCase().endsWith(\".mp3\"))filename+=\".mp3\";\n const entries=await blob.list(\"audio:\");\n if(!entries.some((b:any)=>b.key===key)){\n const used=entries.reduce((n:any,b:any)=>n+b.size,0);\n if(used+data.size>APP_BUDGET)throw new Error(\"This app's 9 MiB storage budget is full. Existing saved files were kept.\");\n await blob.set(key,data.bytes);\n }else duplicateAsset=true;\n asset={resolved_url:data.resolvedUrl,blob_key:key,size_bytes:data.size,sha256:data.hash,filename};\n await sqlite.execute({sql:\"INSERT OR REPLACE INTO audio_assets(resolved_url,blob_key,size_bytes,sha256,filename) VALUES(?,?,?,?,?)\",args:[chosen.resolvedUrl,key,data.size,data.hash,filename]});\n }\n await sqlite.execute({sql:`UPDATE audio_jobs SET status='saved',resolved_url=?,filename=?,blob_key=?,size_bytes=?,sha256=?,content_type='audio/mpeg',error=NULL,updated_at=? WHERE id=?`,\n args:[chosen.resolvedUrl,asset.filename,asset.blob_key,asset.size_bytes,asset.sha256,new Date().toISOString(),id]});\n return {...response(await getJob(url)),duplicateAsset};\n }catch(e) {\n const message=(e as Error).message||\"Download failed.\";\n await sqlite.execute({sql:\"UPDATE audio_jobs SET status='failed',error=?,updated_at=? WHERE id=?\",args:[message,new Date().toISOString(),id]});\n return response(await getJob(url));\n }\n }finally{\n await sqlite.execute({sql:\"UPDATE audio_mutex SET expires_at=0,token=NULL WHERE id=1 AND token=?\",args:[token]});\n }\n}\nexport async function download(id:string) {\n await init();\n const row=(await sqlite.execute({sql:\"SELECT * FROM audio_jobs WHERE id=? AND status='saved'\",args:[id]})).rows[0];\n if(!row)return Response.json({error:\"Saved file not found.\"},{status:404});\n try{\n const stored=await blob.get(String(row.blob_key));\n return new Response(stored.body,{headers:{\"Content-Type\":String(row.content_type||\"audio/mpeg\"),\"Content-Length\":String(row.size_bytes),\"Content-Disposition\":'attachment; filename=\"'+row.filename+'\"',\"Cache-Control\":\"private, no-store\",\"X-Content-Type-Options\":\"nosniff\",\"X-Audio-SHA256\":String(row.sha256)}});\n }catch{return Response.json({error:\"The saved blob is unavailable.\"},{status:404});}\n}\n",[155],"898b8c5b-de6b-4a06-a1c8-e41308c5714a","storage-tests.ts","9cb9ed6a-abe9-11f1-9273-1607ee4eb77e",26,["D",1788915527024],"import { processUrl, history, download } from \"./storage.ts\";\nconst url=\"https://samplelib.com/mp3/sample-3s.mp3\";\nconst first=await processUrl(url), again=await processUrl(url);\nconst page=await processUrl(\"https://samplelib.com/sample-mp3.html\");\nconst file=await download(first.record.id);\nconst bytes=new Uint8Array(await file.arrayBuffer());\nconst digest=Array.from(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes))).map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");\nconst list=await history();\nconst tests={\n saved:first.record.status===\"saved\",\n sameUrlReused:again.reused&&again.record.id===first.record.id&&again.record.attempts===first.record.attempts,\n webpageReusesBlob:page.record.status===\"saved\"&&page.duplicateAsset&&page.record.sha256===first.record.sha256,\n fullBlobDownload:file.status===200&&bytes.length===first.record.sizeBytes,\n checksumMatches:digest===first.record.sha256,\n persistentHistory:list.records.some(r=>r.id===first.record.id)&&list.records.some(r=>r.id===page.record.id),\n oneStoredBlob:list.storage.usedBytes===first.record.sizeBytes,\n};\nconsole.log(JSON.stringify({tests,passed:Object.values(tests).every(Boolean),bytes:bytes.length}));\nexport default tests;\n",[163],"850c9b6e-8cc1-43da-baeb-14b7334a3c8c","speechmatics.ts","8fdd2b40-abec-11f1-8dca-1607ee4eb77e",43,["D",1788918211580],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { init as initStorage, recordUploader, type Uploader } from \"./storage.ts\";\nconst BASE=\"https://us1.asr.api.speechmatics.com/v2\";\nconst APP=\"https://scoot--01a0839cdfb7737ab44f56735981b04d.web.val.run\";\nexport async function initTranscripts(){\n await initStorage();\n await sqlite.execute(\"CREATE TABLE IF NOT EXISTS transcripts (id TEXT PRIMARY KEY, asset_hash TEXT NOT NULL, language TEXT NOT NULL, audio_id TEXT NOT NULL, provider_id TEXT, status TEXT NOT NULL, transcript TEXT, summary TEXT, summary_status TEXT, segments_json TEXT, error TEXT, callback_token TEXT NOT NULL, created_at TEXT NOT NULL, updated_at TEXT NOT NULL, UNIQUE(asset_hash,language))\");\n}\nasync function api(path:string,options:RequestInit={}){\n const key=Deno.env.get(\"SPEECHMATICS_API_KEY\");if(!key)throw new Error(\"Speechmatics API key is missing.\");\n const r=await fetch(BASE+path,{...options,headers:{...options.headers,Authorization:\"Bearer \"+key},signal:AbortSignal.timeout(25000),redirect:\"error\"});\n if(!r.ok){let detail=\"\";try{const b=await r.json();detail=JSON.stringify(b).slice(0,450);}catch{}\n throw new Error(\"Speechmatics HTTP \"+r.status+(detail?\": \"+detail:\"\"));}\n return r;\n}\nfunction view(r:any){if(!r)return null;return {id:r.id,audioId:r.audio_id,language:r.language,status:r.status,providerId:r.provider_id,transcript:r.transcript,summary:r.summary,summaryStatus:r.summary_status,error:r.error,segments:r.segments_json?JSON.parse(r.segments_json):[],createdAt:r.created_at,updatedAt:r.updated_at};}\nexport async function readTranscript(id:string){await initTranscripts();const r=(await sqlite.execute({sql:\"SELECT * FROM transcripts WHERE id=?\",args:[id]})).rows[0];if(!r)throw new Error(\"Transcript not found.\");return view(r);}\nexport async function startTranscript(audioId:string,language=\"en\"){\n await initTranscripts();\n if(![\"en\",\"es\",\"fr\",\"de\",\"it\",\"pt\",\"nl\"].includes(language))throw new Error(\"Unsupported language selection.\");\n const audio=(await sqlite.execute({sql:\"SELECT * FROM audio_jobs WHERE id=? AND status='saved'\",args:[audioId]})).rows[0];\n if(!audio)throw new Error(\"Save an audio file before transcribing.\");\n const id=crypto.randomUUID(), now=new Date().toISOString(), token=crypto.randomUUID()+crypto.randomUUID();\n const added=await sqlite.execute({sql:\"INSERT OR IGNORE INTO transcripts(id,asset_hash,language,audio_id,status,callback_token,created_at,updated_at) VALUES(?,?,?,?,'submitting',?,?,?) RETURNING id\",args:[id,audio.sha256,language,audioId,token,now,now]});\n if(!added.rows.length){\n const old=(await sqlite.execute({sql:\"SELECT * FROM transcripts WHERE asset_hash=? AND language=?\",args:[audio.sha256,language]})).rows[0];\n return {...view(old),reused:true};\n }\n let submitted=false;\n try{\n const stored=await blob.get(String(audio.blob_key));\n const file=await stored.blob();\n const form=new FormData();form.append(\"data_file\",file,String(audio.filename));\n form.append(\"config\",JSON.stringify({type:\"transcription\",transcription_config:{language,model:\"enhanced\",diarization:\"speaker\"},\n summarization_config:{content_type:\"auto\",summary_length:\"brief\",summary_type:\"paragraphs\"},\n tracking:{reference:id},notification_config:[{url:APP+\"/api/speechmatics/callback/\"+id,contents:[],auth_headers:[\"X-Callback-Token: \"+token]}]}));\n submitted=true;\n const response=await api(\"/jobs/\",{method:\"POST\",body:form});const data=await response.json();\n if(!data.id)throw new Error(\"Speechmatics returned no job ID.\");\n await sqlite.execute({sql:\"UPDATE transcripts SET provider_id=?,status='queued',updated_at=? WHERE id=?\",args:[data.id,new Date().toISOString(),id]});\n }catch(e){\n // Do not retry ambiguous POSTs: the provider may already have accepted a billable job.\n const msg=(e as Error).message;\n const uncertain=submitted&&!/Speechmatics HTTP (400|401|403|422|429)/.test(msg);\n await sqlite.execute({sql:\"UPDATE transcripts SET status=?,error=?,updated_at=? WHERE id=?\",args:[uncertain?\"submission_unknown\":\"failed\",msg,new Date().toISOString(),id]});\n }\n return readTranscript(id);\n}\nexport function transcriptText(results:any[]){\n const groups:{speaker:string;start:number;text:string}[]=[];\n for(const item of results||[]){\n const alt=item.alternatives?.[0];if(!alt?.content||![\"word\",\"punctuation\"].includes(item.type))continue;\n const speaker=alt.speaker||groups[groups.length-1]?.speaker||\"Speaker\";\n let group=groups[groups.length-1];\n if(!group||speaker!==group.speaker||group.text.length>900){group={speaker,start:item.start_time||0,text:\"\"};groups.push(group);}\n group.text+=(item.type===\"punctuation\"||!group.text?\"\":\" \")+alt.content;\n }\n return {segments:groups,text:groups.map(g=>g.speaker+\": \"+g.text).join(\"\\n\\n\")};\n}\nexport async function refreshTranscript(id:string){\n await initTranscripts();\n const row=(await sqlite.execute({sql:\"SELECT * FROM transcripts WHERE id=?\",args:[id]})).rows[0];if(!row)throw new Error(\"Transcript not found.\");\n if([\"done\",\"failed\",\"submission_unknown\"].includes(String(row.status))||!row.provider_id)return view(row);\n const provider=await (await api(\"/jobs/\"+encodeURIComponent(String(row.provider_id))+\"?wait=0\")).json();\n if(provider.job?.status===\"done\"){\n const data=await (await api(\"/jobs/\"+encodeURIComponent(String(row.provider_id))+\"/transcript?format=json-v2&wait=0\")).json();\n const parsed=transcriptText(data.results);\n const summary=typeof data.summary?.content===\"string\"?data.summary.content:null;\n await sqlite.execute({sql:\"UPDATE transcripts SET status='done',transcript=?,segments_json=?,summary=?,summary_status=?,error=NULL,updated_at=? WHERE id=?\",args:[parsed.text,JSON.stringify(parsed.segments),summary,summary?\"ready\":parsed.text?\"unavailable\":\"no_speech\",new Date().toISOString(),id]});\n }else if([\"rejected\",\"failed\",\"expired\"].includes(provider.job?.status)){\n await sqlite.execute({sql:\"UPDATE transcripts SET status='failed',error=?,updated_at=? WHERE id=?\",args:[JSON.stringify(provider.job.errors||provider.job.error||\"Speechmatics rejected this audio.\").slice(0,800),new Date().toISOString(),id]});\n }else{\n await sqlite.execute({sql:\"UPDATE transcripts SET status='running',updated_at=? WHERE id=?\",args:[new Date().toISOString(),id]});\n }\n return readTranscript(id);\n}\nexport async function callback(id:string,token:string|null){\n await initTranscripts();\n const row=(await sqlite.execute({sql:\"SELECT * FROM transcripts WHERE id=?\",args:[id]})).rows[0];\n if(!row||!token||token!==row.callback_token)return new Response(\"Unauthorized\",{status:401});\n if(!row.provider_id)return new Response(\"Submission not yet recorded\",{status:503});\n await refreshTranscript(id);return new Response(\"OK\");\n}\nexport async function transcriptIndex(){\n await initTranscripts();\n return (await sqlite.execute(\"SELECT t.id,t.asset_hash,t.language,t.status,t.updated_at,t.summary_status FROM transcripts t ORDER BY t.updated_at DESC LIMIT 500\")).rows;\n}\nexport async function saveUpload(file:File,uploader?:Uploader){\n const id=await saveUploadInternal(file);\n await recordUploader(id,uploader);\n return id;\n}\nasync function saveUploadInternal(file:File){\n await initStorage();\n if(!file.size||file.size>8*1024*1024)throw new Error(\"Choose a nonempty audio file up to 8 MiB.\");\n const ext=file.name.split(\".\").pop()?.toLowerCase();\n if(![\"mp3\",\"wav\",\"m4a\",\"aac\",\"ogg\",\"flac\"].includes(ext||\"\"))throw new Error(\"Choose MP3, WAV, M4A, AAC, OGG or FLAC.\");\n const bytes=await file.arrayBuffer();\n const hash=Array.from(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes))).map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");\n const old=(await sqlite.execute({sql:\"SELECT id FROM audio_jobs WHERE sha256=? AND status='saved' LIMIT 1\",args:[hash]})).rows[0];if(old)return String(old.id);\n const lock=crypto.randomUUID(),now=Date.now();\n const claimed=await sqlite.execute({sql:\"UPDATE audio_mutex SET token=?,expires_at=? WHERE id=1 AND expires_atb.key===key)){\n if(entries.reduce((n:any,b:any)=>n+b.size,0)+file.size>9*1024*1024)throw new Error(\"The 9 MiB app storage budget is full.\");\n await blob.set(key,bytes);\n }\n const id=crypto.randomUUID(),stamp=new Date().toISOString(),filename=file.name.replace(/[^a-zA-Z0-9._-]/g,\"_\").slice(0,150);\n const mime=({mp3:\"audio/mpeg\",wav:\"audio/wav\",m4a:\"audio/mp4\",aac:\"audio/aac\",ogg:\"audio/ogg\",flac:\"audio/flac\"} as any)[ext!];\n await sqlite.execute({sql:\"INSERT OR IGNORE INTO audio_jobs(id,source_url,status,filename,blob_key,size_bytes,sha256,content_type,created_at,updated_at) VALUES(?,?,'saved',?,?,?,?,?,?,?)\",args:[id,\"upload:\"+hash,filename,key,file.size,hash,mime,stamp,stamp]});\n return String((await sqlite.execute({sql:\"SELECT id FROM audio_jobs WHERE source_url=?\",args:[\"upload:\"+hash]})).rows[0].id);\n }finally{await sqlite.execute({sql:\"UPDATE audio_mutex SET token=NULL,expires_at=0 WHERE id=1 AND token=?\",args:[lock]});}\n}\n",[170],"4da44377-06be-401b-991c-941d29feaa70","speechmatics-result-test.ts","f140c7c0-abec-11f1-9398-1607ee4eb77e",39,["D",1788917023032],"import { readTranscript } from \"./speechmatics.ts\";\nconst r=await readTranscript(\"0b5414bd-4c59-4b40-92a2-0779173776b4\");\nconsole.log(JSON.stringify({status:r.status,hasTranscript:!!r.transcript,hasSummary:!!r.summary,segmentCount:r.segments.length}));\nexport default r.status;",[177],"93493a3f-466f-446b-866b-5ae5b3fcf28b","speechmatics-live-test.ts","a5f62936-abec-11f1-859b-1607ee4eb77e",32,["D",1788916830980],"import {saveUpload,startTranscript} from \"./speechmatics.ts\";\nconst res=await fetch(\"https://github.com/speechmatics/speechmatics-js-sdk/raw/7d219bfee9166736e6aa21598535a194387b84be/examples/nodejs/example.wav\");\nif(!res.ok)throw new Error(\"Speech sample unavailable: \"+res.status);\nconst file=new File([await res.arrayBuffer()],\"speechmatics-welcome.wav\",{type:\"audio/wav\"});\nconst audioId=await saveUpload(file);\nconst result=await startTranscript(audioId,\"en\");\nconsole.log(JSON.stringify({audioId,id:result.id,status:result.status,providerId:result.providerId,error:result.error}));\nexport default result.id;\n",[184],"95e8f9a8-765f-431e-8500-a90c8be94e4d","speechmatics-connection-test.ts","46364b8e-abec-11f1-8b1d-1607ee4eb77e",29,["D",1788916670366],"const apiKey=Deno.env.get(\"SPEECHMATICS_API_KEY\");\nif(!apiKey) throw new Error(\"SPEECHMATICS_API_KEY is missing in this val.\");\nconst response=await fetch(\"https://us1.asr.api.speechmatics.com/v2/jobs/\",{\n headers:{Authorization:\"Bearer \"+apiKey},signal:AbortSignal.timeout(15000),redirect:\"error\"\n});\nawait response.body?.cancel();\nconst result={keyPresent:true,endpoint:\"us1\",connected:response.ok,httpStatus:response.status};\nconsole.log(JSON.stringify(result));\nexport default result;\n",[191],"b9def2e5-0df9-4ee5-bcae-3da98c6116e7","smoke-tests.ts","36060fbe-abe8-11f1-ad79-1607ee4eb77e",16,["D",1788914953743],2,"import { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nasync function run() {\n const base=\"https://scoot--01a0839cdfb7737ab44f56735981b04d.web.val.run\";\n const cases=[\n {name:\"Direct MP3\",url:\"https://www.soundhelix.com/examples/mp3/SoundHelix-Song-1.mp3\",check:(b:any,s:number)=>s===200&&b.ok&&b.inputType===\"direct_audio\"&&b.audio[0].sizeBytes>1000000},\n {name:\"Real webpage\",url:\"https://samplelib.com/sample-mp3.html\",check:(b:any,s:number)=>s===200&&b.ok&&b.audio.length>0&&b.inputType===\"webpage_or_feed\"},\n {name:\"Relative WAV source\",url:base+\"/demo/episode\",check:(b:any,s:number)=>s===200&&b.ok&&b.audio[0].wav.durationSeconds===1},\n {name:\"Redirect\",url:base+\"/demo/redirect\",check:(b:any,s:number)=>s===200&&b.ok&&b.audio[0].redirects.length===1},\n {name:\"JSON-LD\",url:base+\"/demo/metadata\",check:(b:any,s:number)=>s===200&&b.ok&&b.audio[0].discoveredBy===\"JSON-LD\"},\n {name:\"RSS enclosure\",url:base+\"/demo/feed.xml\",check:(b:any,s:number)=>s===200&&b.ok&&b.audio[0].discoveredBy===\"RSS enclosure\"},\n {name:\"HTML masquerading as MP3\",url:base+\"/demo/not-audio.mp3\",check:(b:any,s:number)=>s===200&&b.inputType===\"webpage_or_feed\"},\n {name:\"No audio\",url:base,check:(b:any,s:number)=>s===200&&!b.ok&&b.audio.length===0},\n {name:\"Invalid URL\",url:\"not a url\",check:(b:any,s:number)=>s===400&&!b.ok},\n {name:\"Local address blocked\",url:\"http://127.0.0.1/\",check:(b:any,s:number)=>s===400&&!b.ok},\n {name:\"Unsupported protocol\",url:\"file:///etc/passwd\",check:(b:any,s:number)=>s===400&&!b.ok}\n ];\n const results=[];\n for(const t of cases) {\n try {\n const r=await fetch(base+\"/api/inspect\",{method:\"POST\",headers:{\"Content-Type\":\"application/json\"},body:JSON.stringify({url:t.url})});\n const b=await r.json();results.push({name:t.name,pass:t.check(b,r.status),status:r.status,error:b.error||null});\n }catch(e){results.push({name:t.name,pass:false,error:String(e)});}\n }\n console.log(JSON.stringify({passed:results.filter(r=>r.pass).length,total:results.length,results}));\n return results;\n}\n\nexport default await run();\n",[198],"ead9bbca-507f-4ec4-a1cd-6279d5ae269f","inspector.ts","7fcbc78e-abe7-11f1-9cb5-1607ee4eb77e",19,["D",1788915329299],4,"import * as cheerio from \"npm:cheerio@1.0.0\";\nconst EXT = /\\.(mp3|m4a|wav|ogg|oga|opus|aac|flac|aiff)(?:$|[?#])/i;\nexport class InspectError extends Error {\n constructor(message: string, public status = 422) { super(message); }\n}\nexport function validate(raw: string) {\n let u: URL;\n try { u = new URL(raw); } catch { throw new InspectError(\"Enter a complete public http:// or https:// URL.\", 400); }\n if (![\"https:\", \"http:\"].includes(u.protocol) || u.username || u.password || (u.port && ![\"80\", \"443\"].includes(u.port))) throw new InspectError(\"Only public HTTP(S) URLs on standard ports are supported.\", 400);\n const h = u.hostname.toLowerCase().replace(/\\.$/, \"\");\n if (!h.includes(\".\") || h.includes(\":\") || /(^|\\.)(localhost|local|internal|test|invalid)$/.test(h)) throw new InspectError(\"Local and private network URLs are not supported.\", 400);\n if (/^\\d+\\.\\d+\\.\\d+\\.\\d+$/.test(h) && !publicV4(h)) throw new InspectError(\"Private IP addresses are not supported.\", 400);\n u.hash = \"\";\n return u;\n}\nfunction publicV4(ip: string) {\n const [a,b] = ip.split(\".\").map(Number);\n return !(a === 0 || a === 10 || a === 127 || a >= 224 || (a === 169 && b === 254) || (a === 172 && b >= 16 && b <= 31) || (a === 192 && (b === 168 || b === 0)) || (a === 100 && b >= 64 && b <= 127) || (a === 198 && (b === 18 || b === 19)));\n}\nexport async function safeFetch(raw: string, signal: AbortSignal, full = false) {\n let u = validate(raw);\n const redirects: string[] = [];\n for (let i=0; i<6; i++) {\n signal.throwIfAborted();\n // Validate DNS answers as well as literal hosts before each redirect hop.\n if (!/^\\d+\\.\\d+\\.\\d+\\.\\d+$/.test(u.hostname)) {\n const answers = await Promise.all([\"A\",\"AAAA\"].map(async type => {\n const res=await fetch(\"https://cloudflare-dns.com/dns-query?name=\"+encodeURIComponent(u.hostname)+\"&type=\"+type,{headers:{Accept:\"application/dns-json\"},signal});\n if(!res.ok)throw new InspectError(\"DNS lookup failed.\");\n const data=await res.json();\n return (data.Answer||[]).filter((a:any)=>a.type===1||a.type===28).map((a:any)=>a.data as string);\n }));\n const ips: string[] = answers.flat();\n if (!ips.length) throw new InspectError(\"Could not resolve the source hostname.\");\n if (ips.some(ip => ip.includes(\":\") ? !/^[23][0-9a-f]{3}:/i.test(ip) : !publicV4(ip))) throw new InspectError(\"Source resolves to a non-public network address.\",400);\n }\n const response = await fetch(u, { redirect:\"manual\", signal, headers: !full && EXT.test(u.href) ? {Range:\"bytes=0-65535\", Accept:\"*/*\"} : {Accept:\"*/*\"} });\n if ([301,302,303,307,308].includes(response.status)) {\n await response.body?.cancel();\n const location = response.headers.get(\"location\");\n if (!location) throw new InspectError(\"Source returned a redirect without a destination.\");\n u = validate(new URL(location,u).href); redirects.push(u.href); continue;\n }\n if (!response.ok) { await response.body?.cancel(); throw new InspectError(\"Source returned HTTP \"+response.status+\". It may block automated access.\"); }\n return {response, url:u.href, redirects};\n }\n throw new InspectError(\"Source exceeded the five-redirect limit.\");\n}\nasync function sample(response: Response, limit: number) {\n const reader = response.body?.getReader();\n if (!reader) return new Uint8Array();\n const chunks: Uint8Array[] = []; let total=0;\n try {\n while (total{}); }\n const data=new Uint8Array(total); let offset=0;\n for(const chunk of chunks) {data.set(chunk,offset);offset+=chunk.length;}\n return data;\n}\nfunction signature(data: Uint8Array) {\n const s = new TextDecoder(\"latin1\").decode(data.subarray(0,32));\n if(s.startsWith(\"RIFF\") && s.slice(8,12)===\"WAVE\") return \"WAV\";\n if(s.startsWith(\"fLaC\")) return \"FLAC\";\n if(s.startsWith(\"OggS\")) return \"Ogg\";\n if(s.startsWith(\"ID3\")) return \"MP3 (ID3)\";\n if(data[0]===255 && (data[1]&246)===240) return \"AAC\";\n if(data[0]===255 && (data[1]&224)===224) return \"MPEG audio\";\n if(s.slice(4,8)===\"ftyp\") return \"MP4/M4A container\";\n if(s.startsWith(\"FORM\") && /AIFF|AIFC/.test(s.slice(8,12))) return \"AIFF\";\n return null;\n}\nfunction wavMetadata(data: Uint8Array) {\n if(signature(data)!==\"WAV\") return null;\n const v=new DataView(data.buffer,data.byteOffset,data.byteLength); const decode=new TextDecoder();\n let channels: number|null=null, sampleRate: number|null=null, bitsPerSample: number|null=null, byteRate=0, dataBytes: number|null=null;\n for(let pos=12; pos+8<=data.length;) {\n const id=decode.decode(data.subarray(pos,pos+4)); const size=v.getUint32(pos+4,true);\n if(id===\"fmt \" && size>=16 && pos+24<=data.length) {\n channels=v.getUint16(pos+10,true); sampleRate=v.getUint32(pos+12,true);\n byteRate=v.getUint32(pos+16,true); bitsPerSample=v.getUint16(pos+22,true);\n }\n if(id===\"data\") {dataBytes=size; break;}\n pos+=8+size+(size%2);\n }\n return {channels,sampleRate,bitsPerSample,durationSeconds:byteRate && dataBytes!=null ? dataBytes/byteRate : null};\n}\nasync function inspectResource(raw: string, signal: AbortSignal) {\n const fetched=await safeFetch(raw,signal);\n const h=fetched.response.headers;\n const contentType=(h.get(\"content-type\")||\"\").split(\";\")[0].toLowerCase();\n const looksAudio=contentType.startsWith(\"audio/\") || EXT.test(fetched.url);\n const bytes=await sample(fetched.response,looksAudio?65536:1048576);\n const detected=signature(bytes);\n const textPrefix=new TextDecoder().decode(bytes.subarray(0,256)).trimStart();\n const isMarkup=/^(0 && !isMarkup && (contentType.startsWith(\"audio/\") || (!!detected && (!containerOnly || /\\.(m4a|oga|opus)(?:$|[?#])/i.test(fetched.url))));\n const totalMatch=h.get(\"content-range\")?.match(/\\/(\\d+)$/);\n const length=totalMatch?Number(totalMatch[1]):fetched.response.status===200 && h.get(\"content-length\")?Number(h.get(\"content-length\")):null;\n return {\n fetched, bytes, isAudio,\n metadata: {\n url:raw, resolvedUrl:fetched.url, httpStatus:fetched.response.status, contentType:contentType||null,\n sizeBytes:length, sizeSource:totalMatch?\"Content-Range\":length!=null?\"Content-Length\":null,\n format:detected || (contentType.startsWith(\"audio/\")?contentType:null),\n evidence:detected?\"file signature\":isAudio?\"audio Content-Type\":\"not verified as audio\",\n filename:new URL(fetched.url).pathname.split(\"/\").pop()||null,\n supportsRanges:fetched.response.status===206 || h.get(\"accept-ranges\")===\"bytes\",\n inspectedBytes:bytes.length, redirects:fetched.redirects,\n lastModified:h.get(\"last-modified\"), wav:wavMetadata(bytes),\n }\n };\n}\nfunction discover(text: string, base: string) {\n const $=cheerio.load(text,{xmlMode:/^\\s*<\\?xml|]|]/i.test(text)});\n const candidates: {url:string;source:string;label:string|null}[]=[];\n const feeds:string[]=[];\n let pageBase=base;\n try {const b=$(\"base[href]\").first().attr(\"href\");if(b)pageBase=new URL(b,base).href;} catch{}\n const add=(raw:string|undefined,source:string,label?:string)=>{\n if(!raw || candidates.length>=30)return;\n try {const url=validate(new URL(raw,pageBase).href).href;if(!candidates.some(c=>c.url===url))candidates.push({url,source,label:label?.slice(0,240)||null});}catch{}\n };\n $(\"audio[src], audio source[src], source[type^='audio/']\").each((_,e)=>add($(e).attr(\"src\"),\"audio/source tag\"));\n $(\"meta[property], meta[name]\").each((_,e)=>{\n const key=$(e).attr(\"property\")||$(e).attr(\"name\")||\"\";\n if(/^(og:audio(?::url|:secure_url)?|twitter:player:stream)$/.test(key)) add($(e).attr(\"content\"),key);\n });\n $(\"enclosure[url], link[rel='enclosure']\").each((_,e)=>{\n const raw=$(e).attr(\"url\")||$(e).attr(\"href\");if(($(e).attr(\"type\")||\"\").startsWith(\"audio/\")||EXT.test(raw||\"\"))add(raw,\"RSS enclosure\",$(e).parent().find(\"title\").first().text());\n });\n $(\"a[href], link[href]\").each((_,e)=>{\n const href=$(e).attr(\"href\")||\"\";\n if(EXT.test(href))add(href,\"audio link\",$(e).text().trim());\n if(e.tagName===\"link\" && /rss|atom/.test($(e).attr(\"type\")||\"\") && feeds.length<2)try{feeds.push(validate(new URL(href,pageBase).href).href);}catch{}\n });\n function walk(o: any, depth=0) {\n if(!o || typeof o!==\"object\" || depth>12)return;\n if(Array.isArray(o)){o.slice(0,100).forEach(x=>walk(x,depth+1));return;}\n for(const [key,value] of Object.entries(o)) {\n if(typeof value===\"string\" && ([\"contentUrl\",\"audio\",\"associatedMedia\"].includes(key) || ([\"url\",\"embedUrl\"].includes(key)&&EXT.test(value)))) add(value,\"JSON-LD\");\n else if(typeof value===\"object\")walk(value,depth+1);\n }\n }\n $(\"script[type='application/ld+json']\").each((_,e)=>{try{walk(JSON.parse($(e).text()));}catch{}});\n return {title:$(\"title\").first().text().trim().slice(0,300)||null,candidates,feeds};\n}\nexport async function inspect(raw: unknown) {\n if(typeof raw!==\"string\" || raw.length>4096) throw new InspectError(\"Provide a URL string of at most 4096 characters.\",400);\n const input=validate(raw.trim()).href, started=Date.now(), signal=AbortSignal.timeout(22000);\n const first=await inspectResource(input,signal);\n const limits={timeBudgetSeconds:22,maxPageBytes:1048576,maxAudioSampleBytes:65536,maxCandidatesInspected:5,maxFeeds:2};\n if(first.isAudio)return {ok:true,inputUrl:input,inputType:\"direct_audio\",page:null,audio:[{...first.metadata,discoveredBy:\"input URL\"}],candidates:[],warnings:[],limits,elapsedMs:Date.now()-started};\n if(!/text|html|xml|json/.test(first.metadata.contentType||\"\") && !new TextDecoder().decode(first.bytes.subarray(0,100)).trimStart().startsWith(\"<\")) throw new InspectError(\"The URL did not return recognizable audio or a webpage/feed.\");\n const page=discover(new TextDecoder().decode(first.bytes),first.fetched.url);\n const warnings:string[]=[];\n if(first.bytes.length>=1048576)warnings.push(\"Page inspection stopped at 1 MiB; links beyond that may be missed.\");\n let candidates=page.candidates;\n if(!candidates.length) for(const feed of page.feeds) {\n try {\n const f=await inspectResource(feed,signal);\n const found=discover(new TextDecoder().decode(f.bytes),f.fetched.url);\n candidates.push(...found.candidates.map(c=>({...c,source:\"linked feed: \"+c.source})));\n warnings.push(\"Audio candidates came from a linked podcast feed and may include other episodes.\");\n } catch(e) {warnings.push(\"Linked feed: \"+(e as Error).message);}\n }\n candidates=Array.from(new Map(candidates.map(c=>[c.url,c])).values()).slice(0,30);\n const audio:any[]=[]; const checked:any[]=[];\n for(const candidate of candidates.slice(0,5)) {\n try{\n const r=await inspectResource(candidate.url,signal);\n checked.push({...candidate,verified:r.isAudio,error:r.isAudio?null:\"Resource did not return audio.\"});\n if(r.isAudio)audio.push({...r.metadata,discoveredBy:candidate.source,label:candidate.label});\n }catch(e){checked.push({...candidate,verified:false,error:(e as Error).message});}\n }\n if(!audio.length)warnings.push(\"No accessible audio verified. JavaScript-only players, authenticated media, DRM and embedded platforms are not resolved by this POC.\");\n if(candidates.length>5)warnings.push(\"Only the first five audio candidates were inspected.\");\n return {ok:audio.length>0,inputUrl:input,inputType:\"webpage_or_feed\",page:{title:page.title,resolvedUrl:first.fetched.url,contentType:first.metadata.contentType,redirects:first.fetched.redirects},audio,candidates:checked,discoveredCandidateCount:candidates.length,warnings,limits,elapsedMs:Date.now()-started};\n}\n",[206],"5d99b60e-ba36-4457-9398-bba5e1359f6a","index.ts",49,["D",1788918992726],8,"http","import { startTranscript, refreshTranscript, readTranscript, transcriptIndex, saveUpload, callback } from \"./speechmatics.ts\";\nimport { parseVal, serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono@4\";\nimport { Root } from \"./frontend/root.tsx\";\nimport { inspect, InspectError } from \"./inspector.ts\";\nimport { Demo, tone, MetadataDemo, FeedDemo } from \"./demo.tsx\";\nimport { bodyLimit } from \"npm:hono@4/body-limit\";\nimport { processUrl, history, download } from \"./storage.ts\";\nimport { getOAuthUserData, oauthMiddleware } from \"https://esm.town/v/std/oauth/middleware.ts\";\nconst app = new Hono<{ Variables: { uploader: {id:string;username:string} } }>();\napp.get(\"/api/session\",async c=>{const s=await getOAuthUserData(c.req.raw);c.header(\"Cache-Control\",\"no-store\");return c.json({canSave:!!s?.user?.id});});\nconst requireSignedIn=async(c:any,next:any)=>{\n c.header(\"Cache-Control\",\"no-store\");\n const s=await getOAuthUserData(c.req.raw);\n if(!s?.user?.id)return c.json({ok:false,error:\"Sign in with Val Town to access the shared library.\",loginUrl:\"/auth/login\"},401);\n if(c.req.method===\"POST\"){\n const origin=c.req.header(\"Origin\");\n if(origin && origin!==new URL(c.req.url).origin)return c.json({ok:false,error:\"Cross-origin writes are not allowed.\"},403);\n }\n c.set(\"uploader\",{id:s.user.id,username:s.user.username||\"Val Town user\"});\n await next();\n};\napp.use(\"/api/process\",requireSignedIn);\napp.use(\"/api/history\",requireSignedIn);\napp.use(\"/api/files/*\",requireSignedIn);\napp.use(\"/api/transcripts\",requireSignedIn);\napp.use(\"/api/transcripts/*\",requireSignedIn);\napp.use(\"/api/transcribe\",requireSignedIn);\napp.use(\"/api/upload\",requireSignedIn);\napp.use(\"/api/transcribe\",bodyLimit({maxSize:8192}));\napp.use(\"/api/upload\",bodyLimit({maxSize:9*1024*1024}));\napp.post(\"/api/speechmatics/callback/:id\",c=>callback(c.req.param(\"id\"),c.req.header(\"X-Callback-Token\")||null));\napp.get(\"/api/transcripts\",async c=>c.json({transcripts:await transcriptIndex()}));\napp.get(\"/api/transcripts/:id\",async c=>c.json(await readTranscript(c.req.param(\"id\"))));\napp.post(\"/api/transcripts/:id/refresh\",async c=>{try{return c.json(await refreshTranscript(c.req.param(\"id\")));}catch(e){return c.json({error:(e as Error).message},502);}});\napp.post(\"/api/transcribe\",async c=>{\n try{\n const body=await c.req.json();\n let audioId=body.audioId;\n if(!audioId){const saved=await processUrl(body.url,c.get(\"uploader\"));if(saved.record?.status!==\"saved\")return c.json({error:saved.record?.error||\"Could not save MP3.\"},422);audioId=saved.record.id;}\n return c.json(await startTranscript(audioId,body.language||\"en\"));\n }catch(e){return c.json({error:(e as Error).message},422);}\n});\napp.post(\"/api/upload\",async c=>{\n try{const form=await c.req.formData();const file=form.get(\"file\");if(!(file instanceof File))return c.json({error:\"Choose an audio file.\"},400);\n const id=await saveUpload(file,c.get(\"uploader\"));return c.json(await startTranscript(id,String(form.get(\"language\")||\"en\")));\n }catch(e){return c.json({error:(e as Error).message},422);}\n});\napp.use(\"/api/process\",bodyLimit({maxSize:8192,onError:c=>c.json({ok:false,error:\"Request body too large.\"},413)}));\napp.post(\"/api/process\",async c=>{\n c.header(\"Cache-Control\",\"no-store\");\n let input;try{input=await c.req.json();}catch{return c.json({ok:false,error:\"Send JSON with a url field.\"},400);}\n try{return c.json(await processUrl(input?.url,c.get(\"uploader\")));}catch(e){return c.json({ok:false,error:(e as Error).message},e instanceof InspectError?e.status:500);}\n});\napp.get(\"/api/history\",async c=>{c.header(\"Cache-Control\",\"no-store\");const n=Number(c.req.query(\"offset\")||0);return c.json(await history(Number.isSafeInteger(n)&&n>=0?n:0));});\napp.get(\"/api/files/:id\",c=>download(c.req.param(\"id\")));\napp.use(\"/api/inspect\",bodyLimit({maxSize:8192,onError:c=>c.json({ok:false,error:\"Request body too large.\"},413)}));\napp.get(\"/demo/metadata\",c=>c.html(MetadataDemo()));\napp.get(\"/demo/feed.xml\",c=>c.body(FeedDemo().toString(),200,{\"Content-Type\":\"application/rss+xml\"}));\napp.get(\"/demo/not-audio.mp3\",c=>c.html(MetadataDemo()));\napp.get(\"/demo/episode\", c=>c.html(Demo()));\napp.get(\"/demo/tone.wav\", ()=>tone());\napp.get(\"/demo/redirect\",c=>c.redirect(\"/demo/tone.wav\"));\napp.get(\"/\", c => c.html(Root()));\napp.get(\"/__immutable/*\", c => serveImmutableFile(c.req.path));\napp.get(\"/source\", c => c.redirect(parseVal().links.self.val));\napp.get(\"/api/health\", c => c.json({ok:true, service:\"audio-url-inspector\",transcription:false}));\nasync function handle(c: any) {\n c.header(\"Cache-Control\",\"no-store\");\n try {\n let url;\n if(c.req.method===\"GET\") url=c.req.query(\"url\");\n else {\n const text=await c.req.text();\n if(text.length>8192)return c.json({ok:false,error:\"Request body too large.\"},413);\n try {url=JSON.parse(text).url;}catch{return c.json({ok:false,error:'Send JSON with a \"url\" field.'},400);}\n }\n return c.json(await inspect(url));\n } catch(e) {\n const err=e as Error;\n const status=e instanceof InspectError?e.status:err.name===\"TimeoutError\"||err.name===\"AbortError\"?504:502;\n return c.json({ok:false,error:status===504?\"Source inspection timed out. Try a direct audio URL.\":err.message},status);\n }\n}\napp.get(\"/api/inspect\",handle);\napp.post(\"/api/inspect\",handle);\napp.onError(err=>Promise.reject(err));\nexport default oauthMiddleware(app.fetch);\n",[214],"5961fb6e-d7ff-4e21-9a67-eba41f3308a7","demo.tsx","f24e739c-abe7-11f1-9c86-1607ee4eb77e",17,["D",1788915000654],"/** @jsxImportSource npm:hono@4/jsx */\nimport { raw } from \"npm:hono@4/html\";\nexport function Demo() {\n return Demo podcast episode · Audio Inspector

A one-second test tone

This public demonstration page contains a relative audio source. The WAV is generated by this Val Town app.

A one-second test tone

Audio referenced in JSON-LD

Diff · v52