Transcript & summary

\n {error&&

{error}

}\n {!data&&!error&&

Loading…

}\n {data&&<>\n

Speechmatics · {data.language.toUpperCase()} · {data.status.replaceAll(\"_\",\" \")}

\n {[\"submitting\",\"queued\",\"running\"].includes(data.status)&&

Transcription is in progress. This view updates automatically; you can also return from the library later.

}\n {data.error&&

{data.error}

}\n {data.status===\"submission_unknown\"&&

Submission status is uncertain. A second paid job will not be started automatically. Check Speechmatics using the saved job reference.

}\n {data.status===\"done\"&&<>\n

Summary

{data.summary||(data.summaryStatus===\"no_speech\"?\"No speech was detected.\":\"Speechmatics did not return a summary for this recording.\")}

Full transcript

\n setQuery(e.target.value)} className=\"w-full rounded-lg border p-3 mt-4\"/>\n

{data.segments?.length?data.segments.map((s:any,i:number)=>

{s.speaker} · {Math.floor(s.start/60)}:{String(Math.floor(s.start%60)).padStart(2,\"0\")}{highlighted(s.text)}

{highlighted(data.transcript||\"No speech detected.\")}

}

\n }\n }\n

;\n}\n","label",[159,160,65],"frontend","components","pulls","branches",1,"forks","envVars",{"_169":163,"_171":26},"connections",{"_169":26,"_170":26},"count","unfilledCount","emptyCount",{"_32":365,"_13":159,"_63":305,"_42":-5,"_34":35,"_152":163,"_153":87,"_36":366,"_38":26,"_66":362,"_155":-5,"_68":24,"_157":-5,"_201":367,"_17":368},{"_32":360,"_13":160,"_63":151,"_42":305,"_34":35,"_152":163,"_153":87,"_36":361,"_38":26,"_66":362,"_155":-5,"_68":24,"_157":-5,"_201":363,"_17":364},{"_32":351,"_13":352,"_63":353,"_42":151,"_34":35,"_152":354,"_153":87,"_36":355,"_38":356,"_66":67,"_155":357,"_68":24,"_157":-5,"_201":358,"_17":359},{"_32":344,"_13":345,"_63":346,"_42":151,"_34":35,"_152":163,"_153":87,"_36":347,"_38":26,"_66":67,"_155":348,"_68":24,"_157":-5,"_201":349,"_17":350},{"_32":336,"_13":337,"_63":338,"_42":151,"_34":35,"_152":339,"_153":87,"_36":340,"_38":267,"_66":67,"_155":341,"_68":24,"_157":-5,"_201":342,"_17":343},{"_32":328,"_13":329,"_63":330,"_42":151,"_34":35,"_152":331,"_153":87,"_36":332,"_38":258,"_66":67,"_155":333,"_68":24,"_157":-5,"_201":334,"_17":335},{"_32":150,"_13":65,"_63":64,"_42":151,"_34":35,"_152":39,"_153":87,"_36":325,"_38":26,"_66":67,"_155":156,"_68":24,"_157":-5,"_201":326,"_17":327},{"_32":318,"_13":319,"_63":320,"_42":305,"_34":35,"_152":163,"_153":87,"_36":321,"_38":26,"_66":21,"_155":322,"_68":24,"_157":-5,"_201":323,"_17":324},{"_32":311,"_13":312,"_63":313,"_42":305,"_34":35,"_152":163,"_153":87,"_36":314,"_38":26,"_66":67,"_155":315,"_68":24,"_157":-5,"_201":316,"_17":317},{"_32":302,"_13":303,"_63":304,"_42":305,"_34":35,"_152":306,"_153":87,"_36":307,"_38":163,"_66":67,"_155":308,"_68":24,"_157":-5,"_201":309,"_17":310},{"_32":295,"_13":296,"_63":297,"_42":-5,"_34":35,"_152":163,"_153":87,"_36":298,"_38":26,"_66":21,"_155":299,"_68":24,"_157":-5,"_201":300,"_17":301},{"_32":288,"_13":289,"_63":290,"_42":-5,"_34":35,"_152":114,"_153":87,"_36":291,"_38":267,"_66":21,"_155":292,"_68":24,"_157":-5,"_201":293,"_17":294},{"_32":280,"_13":281,"_63":282,"_42":-5,"_34":35,"_152":283,"_153":87,"_36":284,"_38":258,"_66":67,"_155":285,"_68":24,"_157":-5,"_201":286,"_17":287},{"_32":271,"_13":272,"_63":85,"_42":-5,"_34":35,"_152":273,"_153":87,"_36":274,"_38":275,"_66":276,"_155":277,"_68":24,"_157":-5,"_201":278,"_17":279},{"_32":262,"_13":263,"_63":264,"_42":-5,"_34":35,"_152":265,"_153":87,"_36":266,"_38":267,"_66":67,"_155":268,"_68":24,"_157":-5,"_201":269,"_17":270},{"_32":253,"_13":254,"_63":255,"_42":-5,"_34":35,"_152":256,"_153":87,"_36":257,"_38":258,"_66":67,"_155":259,"_68":24,"_157":-5,"_201":260,"_17":261},{"_32":245,"_13":246,"_63":247,"_42":-5,"_34":35,"_152":248,"_153":87,"_36":249,"_38":26,"_66":67,"_155":250,"_68":24,"_157":-5,"_201":251,"_17":252},{"_32":237,"_13":238,"_63":239,"_42":-5,"_34":35,"_152":240,"_153":87,"_36":241,"_38":26,"_66":67,"_155":242,"_68":24,"_157":-5,"_201":243,"_17":244},{"_32":229,"_13":230,"_63":231,"_42":-5,"_34":35,"_152":232,"_153":87,"_36":233,"_38":163,"_66":67,"_155":234,"_68":24,"_157":-5,"_201":235,"_17":236},{"_32":221,"_13":222,"_63":223,"_42":-5,"_34":35,"_152":224,"_153":87,"_36":225,"_38":163,"_66":67,"_155":226,"_68":24,"_157":-5,"_201":227,"_17":228},{"_32":213,"_13":214,"_63":215,"_42":-5,"_34":35,"_152":216,"_153":87,"_36":217,"_38":26,"_66":67,"_155":218,"_68":24,"_157":-5,"_201":219,"_17":220},{"_32":204,"_13":205,"_63":206,"_42":-5,"_34":35,"_152":207,"_153":87,"_36":208,"_38":209,"_66":67,"_155":210,"_68":24,"_157":-5,"_201":211,"_17":212},{"_32":195,"_13":196,"_63":197,"_42":-5,"_34":35,"_152":198,"_153":87,"_36":199,"_38":163,"_66":67,"_155":200,"_68":24,"_157":-5,"_201":202,"_17":203},"6fe1d29d-c962-44e4-972e-eb02dedac3e4","uploader-tests.ts","f4901ed2-abef-11f1-a6fb-1607ee4eb77e",48,["D",1788918274528],"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","children",[],[196],"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",[],[205],"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",[],[214],"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",[],[222],"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;",[],[230],"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",[],[238],"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",[],[246],"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",[],[254],"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",[],[263],"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",[],[272],"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.

Transcript & summary

Summary

Full transcript

A one-second test tone

Audio referenced in JSON-LD

History · TranscriptReader.tsx