([^<]+)<\\/title>/);\n if (match) {\n let raw = match[1].replace(/ on TIDAL$/, \"\").trim();\n const byIdx = raw.lastIndexOf(\" by \");\n if (byIdx > -1) {\n trackName = raw.substring(0, byIdx).trim();\n artistName = raw.substring(byIdx + 4).trim();\n } else {\n trackName = raw.trim();\n }\n trackName = trackName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n artistName = artistName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n }\n }\n } catch (err) {}\n }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Track\";\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Artist\";\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Handlers ────────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n const url = new URL(req.url);\n const valBaseUrl = url.origin;\n const pathParts = url.pathname.split(\"/\").filter(Boolean);\n\n let isStream = false;\n let isDownload = false;\n let encParam = \"\";\n let trackId = \"\";\n let downloadUuid = \"\";\n\n if (pathParts[0] === \"stream\" && pathParts[1]) {\n isStream = true;\n encParam = pathParts[1];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[1] === \"stream\" && pathParts[2]) {\n isStream = true;\n encParam = pathParts[0];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[0] === \"download\" && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n } else if (pathParts[1] === \"download\" && pathParts[2]) {\n isDownload = true;\n downloadUuid = pathParts[2];\n }\n\n if (isStream) {\n const { torboxApiKey, quality } = decodeToken(encParam);\n if (!trackId || !torboxApiKey) {\n return new Response(\n JSON.stringify({ error: \"Missing trackId or API key\" }),\n { status: 400, headers: corsHeaders() },\n );\n }\n\n console.log(`[Stream] Requesting track ${trackId}`);\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n\n const FALLBACK_CHAINS = {\n MAX: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIRES: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n LOSSLESS: [\"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIGH: [\"HIGH\", \"LOW\"],\n LOW: [\"LOW\"],\n };\n const metaMap = {\n HI_RES_LOSSLESS: { label: \"Hi-Res FLAC\", ext: \"flac\" },\n LOSSLESS: { label: \"HiFi FLAC\", ext: \"flac\" },\n HIGH: { label: \"320kbps\", ext: \"m4a\" },\n LOW: { label: \"96kbps\", ext: \"m4a\" },\n };\n\n const chain = FALLBACK_CHAINS[quality] || FALLBACK_CHAINS[\"MAX\"];\n let hashes = {};\n\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const md5 = await md5Hash(fn);\n hashes[md5] = {\n formatKey,\n filename: fn,\n label: info.label,\n ext: info.ext,\n };\n }\n\n const hashList = Object.keys(hashes).join(\",\");\n let cachedHashes = {};\n\n try {\n const cacheRes = await fetch(\n `https://api.torbox.app/v1/api/torrents/checkcached?hash=${hashList}&format=object&list_files=false`,\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return new Response(\n JSON.stringify({ error: \"Invalid Torbox API Key\" }),\n { status: 401, headers: corsHeaders() },\n );\n }\n\n if (cacheRes.ok) {\n const cacheData = await cacheRes.json();\n if (cacheData.success && cacheData.data) {\n const cachedItems = Object.values(cacheData.data);\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const expectedBase =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}]`;\n const match = cachedItems.find((item) =>\n item &&\n (item.name === expectedBase ||\n item.name?.startsWith(expectedBase))\n );\n if (match && match.hash) {\n cachedHashes[formatKey] = match.hash;\n }\n }\n }\n }\n } catch (err) {\n console.error(\"[Torbox] Cache check error:\", err.message);\n }\n\n const topFormatKey = chain[0];\n let isCached = false;\n let cachedHash = null;\n let finalQualityLabel = metaMap[topFormatKey]?.label || quality;\n let filename = \"\";\n\n if (cachedHashes[topFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[topFormatKey];\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${\n metaMap[topFormatKey].ext\n }`;\n }\n\n let uri = \"\";\n let streamData = null;\n\n if (!isCached) {\n // Enforce 2-minute deduplication lock for uncached tracks currently in queue/processing\n const trackLockKey = `${torboxApiKey}_${trackId}`;\n if (!checkTrackLock(trackLockKey, 120000)) {\n return new Response(\n JSON.stringify({\n error:\n \"Already in queue. Please wait a moment before requesting this track again.\",\n }),\n { status: 429, headers: corsHeaders() },\n );\n }\n\n let formats = (quality === \"LOSSLESS\") ? \"FLAC\" : \"FLAC_HIRES,FLAC\";\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } catch (e) {\n if (formats !== \"FLAC\") {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } else {\n throw e;\n }\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n uri = attributes?.uri;\n if (!uri) {\n throw new Error(\"Missing URI in manifest response from HiFi API\");\n }\n\n const returnedFormats = Array.isArray(attributes?.formats)\n ? attributes.formats\n : [];\n let actualQuality = \"FLAC\";\n if (returnedFormats.includes(\"FLAC_HIRES\")) {\n actualQuality = \"FLAC_HIRES\";\n } else if (returnedFormats.includes(\"FLAC\")) actualQuality = \"FLAC\";\n else if (returnedFormats.length > 0) actualQuality = returnedFormats[0];\n\n let dashXml;\n try {\n if (uri.startsWith(\"data:\")) {\n dashXml = b64Decode(uri.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(uri);\n if (xmlRes.ok) dashXml = await xmlRes.text();\n }\n } catch (e) {}\n\n if (dashXml) {\n if (\n dashXml.includes('id=\"FLAC_HIRES') ||\n dashXml.includes(\"FLAC_HIRES,\")\n ) actualQuality = \"FLAC_HIRES\";\n else if (dashXml.includes('id=\"FLAC') || dashXml.includes(\"FLAC,\")) {\n actualQuality = \"FLAC\";\n }\n }\n\n finalQualityLabel = actualQuality === \"FLAC_HIRES\"\n ? \"Hi-Res FLAC\"\n : (actualQuality.includes(\"FLAC\") ? \"HiFi FLAC\" : actualQuality);\n const isFlac = actualQuality.includes(\"FLAC\");\n const ext = isFlac ? \"flac\" : \"m4a\";\n\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const actualFormatKey = actualQuality === \"FLAC_HIRES\"\n ? \"HI_RES_LOSSLESS\"\n : \"LOSSLESS\";\n if (cachedHashes[actualFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[actualFormatKey];\n }\n }\n\n const formData = new FormData();\n formData.append(\"seed\", \"3\");\n formData.append(\"allow_zip\", \"false\");\n formData.append(\"name\", filename);\n\n if (isCached && cachedHash) {\n formData.append(\"magnet\", `magnet:?xt=urn:btih:${cachedHash}`);\n } else {\n const torrentBuffer = await generateTorrentBuffer(\n { streamData, filename },\n valBaseUrl,\n encParam,\n );\n formData.append(\n \"file\",\n new Blob([torrentBuffer], { type: \"application/x-bittorrent\" }),\n `${filename}.torrent`,\n );\n }\n\n const addRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/createtorrent\",\n {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n body: formData,\n },\n );\n\n const addData = await addRes.json();\n if (addData.success && addData.data?.torrent_id) {\n const torrentId = addData.data.torrent_id;\n\n // Verify that the track is fully cached and playable before serving URL\n if (!isCached) {\n console.log(\n `[Torbox] Waiting for WebSeed caching to complete for Torrent ID: ${torrentId}...`,\n );\n let isFullyCached = false;\n let attempts = 0;\n const maxAttempts = 15; // 30 seconds max\n\n while (!isFullyCached && attempts < maxAttempts) {\n await new Promise((resolve) => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/mylist?bypass_cache=true\",\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n if (statusRes.ok) {\n const statusData = await statusRes.json();\n if (statusData.success && Array.isArray(statusData.data)) {\n const torrentInfo = statusData.data.find((t) =>\n t.id === torrentId\n );\n const state = String(\n torrentInfo?.download_state || torrentInfo?.status || \"\",\n ).toLowerCase();\n if (\n torrentInfo &&\n (state === \"cached\" || torrentInfo.cached === true)\n ) {\n console.log(\n `[Torbox] WebSeed caching completed successfully! State: ${state}`,\n );\n isFullyCached = true;\n }\n }\n }\n } catch (e) {\n console.error(\"[Torbox] Status polling error:\", e.message);\n }\n attempts++;\n }\n\n if (!isFullyCached) {\n return new Response(\n JSON.stringify({\n error:\n \"Track is currently caching on Torbox. Please try again in 15 seconds.\",\n }),\n { status: 503, headers: corsHeaders() },\n );\n }\n }\n\n // Edit torrent item on Torbox (Name, NullBeat tag, Airlocked) - async\n fetch(\"https://api.torbox.app/v1/api/torrents/edittorrent\", {\n method: \"PUT\",\n headers: {\n \"Authorization\": `Bearer ${torboxApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n torrent_id: torrentId,\n name: filename,\n tags: [\"NullBeat\"],\n airlocked: true,\n }),\n }).catch((e) =>\n console.error(\"[Torbox] Edit torrent error:\", e.message)\n );\n\n const requestdlUrl =\n `https://api.torbox.app/v1/api/torrents/requestdl?token=${torboxApiKey}&torrent_id=${torrentId}&redirect=true`;\n\n let finalCdnUrl = requestdlUrl;\n try {\n const headRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"manual\",\n });\n const loc = headRes.headers.get(\"location\") ||\n headRes.headers.get(\"Location\");\n if (loc) {\n finalCdnUrl = loc.startsWith(\"http\")\n ? loc\n : new URL(loc, requestdlUrl).toString();\n } else {\n const followRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"follow\",\n });\n if (followRes.url) finalCdnUrl = followRes.url;\n }\n } catch (e) {\n console.error(\"[Torbox] Error resolving CDN URL:\", e.message);\n }\n\n const ext = filename.endsWith(\".flac\")\n ? \"flac\"\n : (filename.endsWith(\".m4a\") ? \"m4a\" : \"mp3\");\n const expiresAt = Math.floor(Date.now() / 1000) + 86400;\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: expiresAt,\n });\n } else {\n console.error(\"[Torbox Error]:\", addData);\n return new Response(\n JSON.stringify({\n error: \"Failed to submit to Torbox\",\n details: addData,\n }),\n { status: 502, headers: corsHeaders() },\n );\n }\n }\n\n if (isDownload) {\n console.log(\n `[Download] Serving request for ${downloadUuid.slice(0, 10)}...`,\n );\n const uuid = downloadUuid;\n let data;\n try {\n data = JSON.parse(b64Decode(uuid));\n } catch {\n return new Response(\"Invalid UUID\", { status: 400 });\n }\n\n if (!data.isDash) {\n return new Response(null, {\n status: 302,\n headers: { Location: data.url },\n });\n }\n\n const rangeHeader = req.headers.get(\"Range\");\n let rangeStart = 0, rangeEnd = Infinity;\n if (rangeHeader) {\n const match = rangeHeader.match(/bytes=(\\d+)-(.*)/);\n if (match) {\n rangeStart = parseInt(match[1], 10);\n if (match[2]) rangeEnd = parseInt(match[2], 10);\n }\n }\n\n const isFlac = data.filename.endsWith(\".flac\");\n const totalSize = data.sizes.reduce((a, b) => a + b, 0);\n const resolvedEnd = rangeEnd !== Infinity ? rangeEnd : totalSize - 1;\n\n let dashXml;\n let manifestUrl = data.url;\n if (data.url.startsWith(\"data:\")) {\n dashXml = b64Decode(data.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) {\n return new Response(\"Failed to fetch DASH XML\", { status: 502 });\n }\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n }\n\n let parsingContext =\n dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] ||\n dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/)?.[0] || dashXml;\n\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n\n let segments = [];\n if (initMatch) segments.push(initMatch[1].replace(/&/g, \"&\"));\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = startMatch ? parseInt(startMatch[1], 10) : 1;\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) =>\n seg.startsWith(\"http\") ? seg : new URL(seg, manifestUrlBase).toString()\n );\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map((s) => {\n const cur = current;\n current += s;\n return cur;\n });\n\n let segmentsToFetch = [];\n let segmentOffsets = [];\n let segmentIndices = [];\n\n for (let i = 0; i < uniqueSegments.length; i++) {\n const segStart = segmentOffsetsMap[i];\n const segEnd = segStart + data.sizes[i] - 1;\n if (segStart <= resolvedEnd && segEnd >= rangeStart) {\n let segUrl = uniqueSegments[i];\n if (manifestUrl.includes(\"?\") && !segUrl.includes(\"?\")) {\n segUrl += manifestUrl.substring(manifestUrl.indexOf(\"?\"));\n }\n segmentsToFetch.push(segUrl);\n segmentOffsets.push(segStart);\n segmentIndices.push(i);\n }\n }\n\n const contentType = isFlac ? \"audio/flac\" : \"audio/mp4\";\n const responseHeaders = new Headers({\n \"Content-Disposition\": `attachment; filename=\"${data.filename}\"`,\n \"Content-Type\": contentType,\n \"Accept-Ranges\": \"bytes\",\n });\n\n if (rangeHeader) {\n responseHeaders.set(\n \"Content-Range\",\n `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`,\n );\n responseHeaders.set(\n \"Content-Length\",\n (resolvedEnd - rangeStart + 1).toString(),\n );\n } else {\n responseHeaders.set(\"Content-Length\", totalSize.toString());\n }\n\n if (req.method === \"HEAD\") {\n return new Response(null, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n const { readable, writable } = new TransformStream();\n const writer = writable.getWriter();\n\n (async () => {\n try {\n const CONCURRENCY = 20;\n for (let i = 0; i < segmentsToFetch.length; i += CONCURRENCY) {\n const batch = segmentsToFetch.slice(i, i + CONCURRENCY);\n const chunkDataArr = await fetchSegmentsConcurrently(\n batch,\n CONCURRENCY,\n );\n\n for (let j = 0; j < batch.length; j++) {\n let outData = chunkDataArr[j];\n const originalIndex = segmentIndices[i + j];\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(outData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n const newOut = new Uint8Array(\n flacMagic.length + metaBlock.length,\n );\n newOut.set(flacMagic);\n newOut.set(metaBlock, flacMagic.length);\n outData = newOut;\n } else outData = new Uint8Array(0);\n } else {\n outData = extractBoxData(outData, \"mdat\") ||\n new Uint8Array(0);\n }\n }\n\n const currentSegOffset = segmentOffsets[i + j];\n const outSize = outData.length;\n const startInChunk = Math.max(0, rangeStart - currentSegOffset);\n const currentEndOffset = currentSegOffset + outSize;\n\n if (startInChunk > 0 || currentEndOffset > resolvedEnd + 1) {\n const endInChunk = Math.min(\n outSize,\n outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)),\n );\n outData = outData.slice(startInChunk, endInChunk);\n }\n\n if (outData.length > 0) await writer.write(outData);\n }\n }\n } catch (e) {\n console.error(`[WebSeed] Stream Error:`, e.message);\n } finally {\n writer.close();\n }\n })();\n\n return new Response(readable, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n return new Response(\"NullBeat Val.town Proxy Online\", { status: 200 });\n } catch (err) {\n console.error(\"Unhandled server error:\", err.message);\n return new Response(\n JSON.stringify({\n error: \"Internal Server Error\",\n message: err.message,\n }),\n { status: 500, headers: corsHeaders() },\n );\n }\n}","const trackRequestLockMap = new Map();\n\nfunction checkTrackLock(key, lockWindowMs = 120000) {\n const now = Date.now();\n const lastTime = trackRequestLockMap.get(key);\n if (lastTime && (now - lastTime < lockWindowMs)) {\n return false; // Already locked / in queue\n }\n trackRequestLockMap.set(key, now);\n if (trackRequestLockMap.size > 2000) {\n for (const [k, t] of trackRequestLockMap.entries()) {\n if (now - t > lockWindowMs) trackRequestLockMap.delete(k);\n }\n }\n return true;\n}\n\nfunction cleanUrlString(str) {\n if (!str) return \"\";\n return str.trim().replace(/^[\"']|[\"']$/g, \"\").trim();\n}\n\nfunction getHifiBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? (Deno.env.get(\"HIFI_BACKENDS\") || Deno.env.get(\"HIFI_BACKEND\"))\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return [];\n}\n\nfunction getHifiSearchBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"HIFI_SEARCH\")\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return getHifiBackends();\n}\n\nasync function fetchHifiApi(path, options = {}, isSearch = false) {\n const sourceList = isSearch ? getHifiSearchBackends() : getHifiBackends();\n const backends = [...sourceList].sort(() => Math.random() - 0.5);\n if (backends.length === 0) {\n const varName = isSearch\n ? \"HIFI_SEARCH (or HIFI_BACKENDS)\"\n : \"HIFI_BACKENDS\";\n throw new Error(\n `No HiFi API backends configured. Please set the ${varName} environment variable.`,\n );\n }\n let lastError = null;\n\n for (let base of backends) {\n base = cleanUrlString(base);\n if (!base.startsWith(\"http\")) continue;\n const cleanBase = base.endsWith(\"/\") ? base.slice(0, -1) : base;\n const url = `${cleanBase}${path.startsWith(\"/\") ? path : \"/\" + path}`;\n try {\n const res = await fetch(url, {\n ...options,\n signal: AbortSignal.timeout(8000),\n });\n if (res.ok) return res;\n lastError = new Error(`HTTP ${res.status} from ${base}`);\n } catch (e) {\n lastError = e;\n }\n }\n\n throw lastError || new Error(\"All HiFi API backends failed\");\n}\n\nfunction corsHeaders() {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n };\n}\n\nfunction jsonResp(data, status = 200, cacheAge = 0) {\n const headers = new Headers(corsHeaders());\n headers.set(\"Content-Type\", \"application/json\");\n if (cacheAge > 0) headers.set(\"Cache-Control\", `public, max-age=${cacheAge}`);\n return new Response(JSON.stringify(data), { status, headers });\n}\n\nconst textEnc = new TextEncoder();\nconst textDec = new TextDecoder();\n\nfunction b64Decode(str) {\n try {\n str = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n while (str.length % 4) str += \"=\";\n const binary = atob(str);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) {\n bytes[i] = binary.charCodeAt(i);\n }\n return textDec.decode(bytes);\n } catch {\n return \"\";\n }\n}\n\nfunction b64Encode(str) {\n const bytes = textEnc.encode(str);\n let binary = \"\";\n for (let i = 0; i < bytes.byteLength; i++) {\n binary += String.fromCharCode(bytes[i]);\n }\n return btoa(binary).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(\n /=+$/,\n \"\",\n );\n}\n\nfunction decodeToken(enc) {\n try {\n const raw = b64Decode(enc);\n const parts = raw.split(\"|||\");\n const torboxApiKey = parts[0] || \"\";\n let q = parts[1] ? parts[1].toUpperCase() : \"MAX\";\n return { torboxApiKey, quality: q };\n } catch {\n return { torboxApiKey: \"\", quality: \"MAX\" };\n }\n}\n\nfunction extractBoxData(buffer, boxType) {\n let offset = 0;\n while (offset + 8 <= buffer.length) {\n const size = new DataView(\n buffer.buffer,\n buffer.byteOffset,\n buffer.byteLength,\n ).getUint32(offset, false);\n if (size < 8) break;\n\n const type = new TextDecoder().decode(\n buffer.subarray(offset + 4, offset + 8),\n );\n\n if (type === boxType) {\n return buffer.subarray(offset + 8, offset + size);\n }\n\n if (\n [\"moov\", \"trak\", \"mdia\", \"minf\", \"stbl\", \"stsd\", \"fLaC\"].includes(type)\n ) {\n let innerStart = offset + 8;\n if (type === \"stsd\") innerStart += 8;\n if (type === \"fLaC\") innerStart += 28;\n\n if (innerStart < offset + size) {\n const innerData = buffer.subarray(innerStart, offset + size);\n const found = extractBoxData(innerData, boxType);\n if (found) return found;\n }\n }\n offset += size;\n }\n return null;\n}\n\nfunction concatU8(arrays) {\n let totalLength = arrays.reduce((acc, value) => acc + value.length, 0);\n let result = new Uint8Array(totalLength);\n let length = 0;\n for (let array of arrays) {\n result.set(array, length);\n length += array.length;\n }\n return result;\n}\nfunction bencodeString(strOrArr) {\n const buf = typeof strOrArr === \"string\"\n ? textEnc.encode(strOrArr)\n : strOrArr;\n return concatU8([textEnc.encode(buf.length + \":\"), buf]);\n}\nfunction bencodeInt(n) {\n return textEnc.encode(`i${n}e`);\n}\nfunction bencodeList(list) {\n return concatU8([textEnc.encode(\"l\"), ...list, textEnc.encode(\"e\")]);\n}\nfunction bencodeDict(dict) {\n const keys = Object.keys(dict).sort();\n const parts = [textEnc.encode(\"d\")];\n for (const k of keys) {\n parts.push(bencodeString(k));\n parts.push(dict[k]);\n }\n parts.push(textEnc.encode(\"e\"));\n return concatU8(parts);\n}\n\n// ─── Concurrent Downloader ───────────────────────────────────────────────────\n\nasync function fetchSegmentsConcurrently(urls, concurrency = 20) {\n const results = new Array(urls.length);\n const queue = urls.map((url, i) => ({ url, i }));\n\n const workers = Array(concurrency).fill(null).map(async () => {\n while (queue.length > 0) {\n const task = queue.shift();\n const res = await fetch(task.url);\n if (!res.ok) throw new Error(`Segment fetch failed: ${res.status}`);\n results[task.i] = new Uint8Array(await res.arrayBuffer());\n }\n });\n\n await Promise.all(workers);\n return results;\n}\n\n// ─── Stream Generator ────────────────────────────────────────────────────────\n\nasync function generateTorrentBuffer(info, valBaseUrl, encParam) {\n const { streamData, filename } = info;\n let sizes = [];\n let pieceHashes = [];\n const pieceLength = 524288;\n let totalLength = 0;\n let currentPiece = new Uint8Array(pieceLength);\n let currentPieceCursor = 0;\n\n async function pushData(data) {\n if (data.length === 0) return;\n totalLength += data.length;\n let valCursor = 0;\n while (valCursor < data.length) {\n const remainingSpace = pieceLength - currentPieceCursor;\n const dataToCopy = Math.min(remainingSpace, data.length - valCursor);\n currentPiece.set(\n data.subarray(valCursor, valCursor + dataToCopy),\n currentPieceCursor,\n );\n currentPieceCursor += dataToCopy;\n valCursor += dataToCopy;\n\n if (currentPieceCursor === pieceLength) {\n const hashBuffer = await crypto.subtle.digest(\"SHA-1\", currentPiece);\n pieceHashes.push(new Uint8Array(hashBuffer));\n currentPieceCursor = 0;\n }\n }\n }\n\n if (!streamData.isDash) {\n const res = await fetch(streamData.url);\n if (!res.ok) throw new Error(\"Failed to fetch direct stream\");\n const reader = res.body.getReader();\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n await pushData(value);\n }\n } else {\n // 1. Fetch Manifest XML\n let dashXml;\n let manifestUrl = streamData.url;\n if (streamData.url.startsWith(\"data:\")) {\n dashXml = b64Decode(streamData.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) throw new Error(\"Failed to fetch DASH XML\");\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n if (!manifestUrlBase.startsWith(\"http\")) {\n manifestUrlBase = new URL(manifestUrlBase, manifestUrl).toString();\n }\n }\n\n let parsingContext = dashXml;\n const templateMatch = dashXml.match(\n /<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/,\n );\n if (templateMatch) parsingContext = templateMatch[0];\n else {\n const listMatch = dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/);\n if (listMatch) parsingContext = listMatch[0];\n }\n\n let initSegment = \"\";\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n if (initMatch) initSegment = initMatch[1].replace(/&/g, \"&\");\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = 1;\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n if (startMatch) startNumber = parseInt(startMatch[1], 10);\n\n let segments = [];\n if (initSegment) segments.push(initSegment);\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) => {\n try {\n return seg.startsWith(\"http\")\n ? seg\n : new URL(seg, manifestUrlBase).toString();\n } catch {\n return seg;\n }\n });\n\n const isFlac = filename.endsWith(\".flac\");\n\n for (let i = 0; i < uniqueSegments.length; i += 20) {\n const chunkUrls = uniqueSegments.slice(i, i + 20);\n const chunkDataArr = await fetchSegmentsConcurrently(chunkUrls, 20);\n\n for (let j = 0; j < chunkUrls.length; j++) {\n let chunkData = chunkDataArr[j];\n let outData = chunkData;\n const originalIndex = i + j;\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(chunkData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n outData = new Uint8Array(flacMagic.length + metaBlock.length);\n outData.set(flacMagic);\n outData.set(metaBlock, flacMagic.length);\n } else {\n outData = new Uint8Array(0);\n }\n } else {\n const mdat = extractBoxData(chunkData, \"mdat\");\n outData = mdat || new Uint8Array(0);\n }\n }\n\n sizes.push(outData.length);\n await pushData(outData);\n }\n }\n }\n\n if (currentPieceCursor > 0) {\n const hashBuffer = await crypto.subtle.digest(\n \"SHA-1\",\n currentPiece.slice(0, currentPieceCursor),\n );\n pieceHashes.push(new Uint8Array(hashBuffer));\n }\n\n const concatenatedHashes = concatU8(pieceHashes);\n const payloadStr = JSON.stringify({\n url: streamData.url,\n isDash: streamData.isDash,\n filename,\n sizes,\n });\n const torrentPayload = b64Encode(payloadStr);\n const webseedUrls = [\n `${valBaseUrl}/download/${torrentPayload}`,\n `${valBaseUrl}/download/${torrentPayload}?ws=1`,\n `${valBaseUrl}/download/${torrentPayload}?ws=2`,\n ];\n\n const infoTorrent = {\n length: bencodeInt(totalLength),\n name: bencodeString(filename),\n \"name.utf-8\": bencodeString(filename),\n \"piece length\": bencodeInt(pieceLength),\n pieces: bencodeString(concatenatedHashes),\n };\n\n const torrent = bencodeDict({\n encoding: bencodeString(\"UTF-8\"),\n info: bencodeDict(infoTorrent),\n \"url-list\": bencodeList(webseedUrls.map((u) => bencodeString(u))),\n });\n\n return torrent;\n}\n\nasync function md5Hash(text) {\n try {\n const { createHash } = await import(\"node:crypto\");\n return createHash(\"md5\").update(text).digest(\"hex\");\n } catch (e) {\n const msgUint8 = new TextEncoder().encode(text);\n const hashBuffer = await crypto.subtle.digest(\"MD5\", msgUint8);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n }\n}\n\nasync function getTrackMeta(trackId) {\n let artistName = \"Unknown Artist\";\n let trackName = \"Unknown Track\";\n\n // 1. Primary: Direct /info/?id= lookup from HiFi API backends\n try {\n const infoRes = await fetchHifiApi(`/info/?id=${trackId}`, {}, true);\n const infoJson = await infoRes.json();\n const item = infoJson?.data || infoJson;\n if (item && item.title) {\n trackName = item.title;\n artistName = item.artist?.name || item.artists?.find((a) =>\n a?.type === \"MAIN\"\n )?.name || item.artists?.[0]?.name || artistName;\n }\n } catch (e) {}\n\n // 2. Fallback: Tidal browse page lookup if HiFi API /info/ failed\n if (trackName === \"Unknown Track\") {\n try {\n const tRes = await fetch(`https://tidal.com/browse/track/${trackId}`, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n if (tRes.ok) {\n const text = await tRes.text();\n const match = text.match(/<title>([^<]+)<\\/title>/);\n if (match) {\n let raw = match[1].replace(/ on TIDAL$/, \"\").trim();\n const byIdx = raw.lastIndexOf(\" by \");\n if (byIdx > -1) {\n trackName = raw.substring(0, byIdx).trim();\n artistName = raw.substring(byIdx + 4).trim();\n } else {\n trackName = raw.trim();\n }\n trackName = trackName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n artistName = artistName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n }\n }\n } catch (err) {}\n }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Track\";\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Artist\";\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Handlers ────────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n const url = new URL(req.url);\n const valBaseUrl = url.origin;\n const pathParts = url.pathname.split(\"/\").filter(Boolean);\n\n let isStream = false;\n let isDownload = false;\n let encParam = \"\";\n let trackId = \"\";\n let downloadUuid = \"\";\n\n if (pathParts[0] === \"stream\" && pathParts[1]) {\n isStream = true;\n encParam = pathParts[1];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[1] === \"stream\" && pathParts[2]) {\n isStream = true;\n encParam = pathParts[0];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[0] === \"download\" && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n } else if (pathParts[1] === \"download\" && pathParts[2]) {\n isDownload = true;\n downloadUuid = pathParts[2];\n }\n\n if (isStream) {\n const { torboxApiKey, quality } = decodeToken(encParam);\n if (!trackId || !torboxApiKey) {\n return new Response(\n JSON.stringify({ error: \"Missing trackId or API key\" }),\n { status: 400, headers: corsHeaders() },\n );\n }\n\n console.log(`[Stream] Requesting track ${trackId}`);\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n\n const FALLBACK_CHAINS = {\n MAX: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIRES: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n LOSSLESS: [\"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIGH: [\"HIGH\", \"LOW\"],\n LOW: [\"LOW\"],\n };\n const metaMap = {\n HI_RES_LOSSLESS: { label: \"Hi-Res FLAC\", ext: \"flac\" },\n LOSSLESS: { label: \"HiFi FLAC\", ext: \"flac\" },\n HIGH: { label: \"320kbps\", ext: \"m4a\" },\n LOW: { label: \"96kbps\", ext: \"m4a\" },\n };\n\n const chain = FALLBACK_CHAINS[quality] || FALLBACK_CHAINS[\"MAX\"];\n let hashes = {};\n\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const md5 = await md5Hash(fn);\n hashes[md5] = {\n formatKey,\n filename: fn,\n label: info.label,\n ext: info.ext,\n };\n }\n\n const hashList = Object.keys(hashes).join(\",\");\n let cachedHashes = {};\n\n try {\n const cacheRes = await fetch(\n `https://api.torbox.app/v1/api/torrents/checkcached?hash=${hashList}&format=object&list_files=false`,\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return new Response(\n JSON.stringify({ error: \"Invalid Torbox API Key\" }),\n { status: 401, headers: corsHeaders() },\n );\n }\n\n if (cacheRes.ok) {\n const cacheData = await cacheRes.json();\n if (cacheData.success && cacheData.data) {\n const cachedItems = Object.values(cacheData.data);\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const expectedBase =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}]`;\n const match = cachedItems.find((item) =>\n item &&\n (item.name === expectedBase ||\n item.name?.startsWith(expectedBase))\n );\n if (match && match.hash) {\n cachedHashes[formatKey] = match.hash;\n }\n }\n }\n }\n } catch (err) {\n console.error(\"[Torbox] Cache check error:\", err.message);\n }\n\n const topFormatKey = chain[0];\n let isCached = false;\n let cachedHash = null;\n let finalQualityLabel = metaMap[topFormatKey]?.label || quality;\n let filename = \"\";\n\n if (cachedHashes[topFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[topFormatKey];\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${\n metaMap[topFormatKey].ext\n }`;\n }\n\n let uri = \"\";\n let streamData = null;\n\n if (!isCached) {\n // Enforce 2-minute deduplication lock for uncached tracks currently in queue/processing\n const trackLockKey = `${torboxApiKey}_${trackId}`;\n if (!checkTrackLock(trackLockKey, 120000)) {\n return new Response(\n JSON.stringify({\n error:\n \"Already in queue. Please wait a moment before requesting this track again.\",\n }),\n { status: 429, headers: corsHeaders() },\n );\n }\n\n let formats = (quality === \"LOSSLESS\") ? \"FLAC\" : \"FLAC_HIRES,FLAC\";\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } catch (e) {\n if (formats !== \"FLAC\") {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } else {\n throw e;\n }\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n uri = attributes?.uri;\n if (!uri) {\n throw new Error(\"Missing URI in manifest response from HiFi API\");\n }\n\n const returnedFormats = Array.isArray(attributes?.formats)\n ? attributes.formats\n : [];\n let actualQuality = \"FLAC\";\n if (returnedFormats.includes(\"FLAC_HIRES\")) {\n actualQuality = \"FLAC_HIRES\";\n } else if (returnedFormats.includes(\"FLAC\")) actualQuality = \"FLAC\";\n else if (returnedFormats.length > 0) actualQuality = returnedFormats[0];\n\n let dashXml;\n try {\n if (uri.startsWith(\"data:\")) {\n dashXml = b64Decode(uri.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(uri);\n if (xmlRes.ok) dashXml = await xmlRes.text();\n }\n } catch (e) {}\n\n if (dashXml) {\n if (\n dashXml.includes('id=\"FLAC_HIRES') ||\n dashXml.includes(\"FLAC_HIRES,\")\n ) actualQuality = \"FLAC_HIRES\";\n else if (dashXml.includes('id=\"FLAC') || dashXml.includes(\"FLAC,\")) {\n actualQuality = \"FLAC\";\n }\n }\n\n finalQualityLabel = actualQuality === \"FLAC_HIRES\"\n ? \"Hi-Res FLAC\"\n : (actualQuality.includes(\"FLAC\") ? \"HiFi FLAC\" : actualQuality);\n const isFlac = actualQuality.includes(\"FLAC\");\n const ext = isFlac ? \"flac\" : \"m4a\";\n\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const actualFormatKey = actualQuality === \"FLAC_HIRES\"\n ? \"HI_RES_LOSSLESS\"\n : \"LOSSLESS\";\n if (cachedHashes[actualFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[actualFormatKey];\n }\n }\n\n const formData = new FormData();\n formData.append(\"seed\", \"3\");\n formData.append(\"allow_zip\", \"false\");\n formData.append(\"name\", filename);\n\n if (isCached && cachedHash) {\n formData.append(\"magnet\", `magnet:?xt=urn:btih:${cachedHash}`);\n } else {\n const torrentBuffer = await generateTorrentBuffer(\n { streamData, filename },\n valBaseUrl,\n encParam,\n );\n formData.append(\n \"file\",\n new Blob([torrentBuffer], { type: \"application/x-bittorrent\" }),\n `${filename}.torrent`,\n );\n }\n\n const addRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/createtorrent\",\n {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n body: formData,\n },\n );\n\n const addData = await addRes.json();\n if (addData.success && addData.data?.torrent_id) {\n const torrentId = addData.data.torrent_id;\n\n // Verify that the track is fully cached and playable before serving URL\n if (!isCached) {\n console.log(\n `[Torbox] Waiting for WebSeed caching to complete for Torrent ID: ${torrentId}...`,\n );\n let isFullyCached = false;\n let attempts = 0;\n const maxAttempts = 15; // 30 seconds max\n\n while (!isFullyCached && attempts < maxAttempts) {\n await new Promise((resolve) => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/mylist?bypass_cache=true\",\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n if (statusRes.ok) {\n const statusData = await statusRes.json();\n if (statusData.success && Array.isArray(statusData.data)) {\n const torrentInfo = statusData.data.find((t) =>\n t.id === torrentId\n );\n const state = String(\n torrentInfo?.download_state || torrentInfo?.status || \"\",\n ).toLowerCase();\n if (\n torrentInfo &&\n (state === \"cached\" || torrentInfo.cached === true)\n ) {\n console.log(\n `[Torbox] WebSeed caching completed successfully! State: ${state}`,\n );\n isFullyCached = true;\n }\n }\n }\n } catch (e) {\n console.error(\"[Torbox] Status polling error:\", e.message);\n }\n attempts++;\n }\n\n if (!isFullyCached) {\n return new Response(\n JSON.stringify({\n error:\n \"Track is currently caching on Torbox. Please try again in 15 seconds.\",\n }),\n { status: 503, headers: corsHeaders() },\n );\n }\n }\n\n // Edit torrent item on Torbox (Name, NullBeat tag, Airlocked) - async\n fetch(\"https://api.torbox.app/v1/api/torrents/edittorrent\", {\n method: \"PUT\",\n headers: {\n \"Authorization\": `Bearer ${torboxApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n torrent_id: torrentId,\n name: filename,\n tags: [\"NullBeat\"],\n airlocked: true,\n }),\n }).catch((e) =>\n console.error(\"[Torbox] Edit torrent error:\", e.message)\n );\n\n const requestdlUrl =\n `https://api.torbox.app/v1/api/torrents/requestdl?token=${torboxApiKey}&torrent_id=${torrentId}&redirect=true`;\n\n let finalCdnUrl = requestdlUrl;\n try {\n const headRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"manual\",\n });\n const loc = headRes.headers.get(\"location\") ||\n headRes.headers.get(\"Location\");\n if (loc) {\n finalCdnUrl = loc.startsWith(\"http\")\n ? loc\n : new URL(loc, requestdlUrl).toString();\n } else {\n const followRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"follow\",\n });\n if (followRes.url) finalCdnUrl = followRes.url;\n }\n } catch (e) {\n console.error(\"[Torbox] Error resolving CDN URL:\", e.message);\n }\n\n const ext = filename.endsWith(\".flac\")\n ? \"flac\"\n : (filename.endsWith(\".m4a\") ? \"m4a\" : \"mp3\");\n const expiresAt = Math.floor(Date.now() / 1000) + 86400;\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: expiresAt,\n });\n } else {\n console.error(\"[Torbox Error]:\", addData);\n return new Response(\n JSON.stringify({\n error: \"Failed to submit to Torbox\",\n details: addData,\n }),\n { status: 502, headers: corsHeaders() },\n );\n }\n }\n\n if (isDownload) {\n console.log(\n `[Download] Serving request for ${downloadUuid.slice(0, 10)}...`,\n );\n const uuid = downloadUuid;\n let data;\n try {\n data = JSON.parse(b64Decode(uuid));\n } catch {\n return new Response(\"Invalid UUID\", { status: 400 });\n }\n\n if (!data.isDash) {\n return new Response(null, {\n status: 302,\n headers: { Location: data.url },\n });\n }\n\n const rangeHeader = req.headers.get(\"Range\");\n let rangeStart = 0, rangeEnd = Infinity;\n if (rangeHeader) {\n const match = rangeHeader.match(/bytes=(\\d+)-(.*)/);\n if (match) {\n rangeStart = parseInt(match[1], 10);\n if (match[2]) rangeEnd = parseInt(match[2], 10);\n }\n }\n\n const isFlac = data.filename.endsWith(\".flac\");\n const totalSize = data.sizes.reduce((a, b) => a + b, 0);\n const resolvedEnd = rangeEnd !== Infinity ? rangeEnd : totalSize - 1;\n\n let dashXml;\n let manifestUrl = data.url;\n if (data.url.startsWith(\"data:\")) {\n dashXml = b64Decode(data.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) {\n return new Response(\"Failed to fetch DASH XML\", { status: 502 });\n }\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n }\n\n let parsingContext =\n dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] ||\n dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/)?.[0] || dashXml;\n\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n\n let segments = [];\n if (initMatch) segments.push(initMatch[1].replace(/&/g, \"&\"));\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = startMatch ? parseInt(startMatch[1], 10) : 1;\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) =>\n seg.startsWith(\"http\") ? seg : new URL(seg, manifestUrlBase).toString()\n );\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map((s) => {\n const cur = current;\n current += s;\n return cur;\n });\n\n let segmentsToFetch = [];\n let segmentOffsets = [];\n let segmentIndices = [];\n\n for (let i = 0; i < uniqueSegments.length; i++) {\n const segStart = segmentOffsetsMap[i];\n const segEnd = segStart + data.sizes[i] - 1;\n if (segStart <= resolvedEnd && segEnd >= rangeStart) {\n let segUrl = uniqueSegments[i];\n if (manifestUrl.includes(\"?\") && !segUrl.includes(\"?\")) {\n segUrl += manifestUrl.substring(manifestUrl.indexOf(\"?\"));\n }\n segmentsToFetch.push(segUrl);\n segmentOffsets.push(segStart);\n segmentIndices.push(i);\n }\n }\n\n const contentType = isFlac ? \"audio/flac\" : \"audio/mp4\";\n const responseHeaders = new Headers({\n \"Content-Disposition\": `attachment; filename*=UTF-8''${\n encodeURIComponent(data.filename)\n }`,\n \"Content-Type\": contentType,\n \"Accept-Ranges\": \"bytes\",\n \"Connection\": \"keep-alive\",\n });\n\n if (rangeHeader) {\n responseHeaders.set(\n \"Content-Range\",\n `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`,\n );\n responseHeaders.set(\n \"Content-Length\",\n (resolvedEnd - rangeStart + 1).toString(),\n );\n } else {\n responseHeaders.set(\"Content-Length\", totalSize.toString());\n }\n\n if (req.method === \"HEAD\") {\n return new Response(null, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n const { readable, writable } = new TransformStream();\n const writer = writable.getWriter();\n\n (async () => {\n try {\n const CONCURRENCY = 20;\n for (let i = 0; i < segmentsToFetch.length; i += CONCURRENCY) {\n const batch = segmentsToFetch.slice(i, i + CONCURRENCY);\n const chunkDataArr = await fetchSegmentsConcurrently(\n batch,\n CONCURRENCY,\n );\n\n for (let j = 0; j < batch.length; j++) {\n let outData = chunkDataArr[j];\n const originalIndex = segmentIndices[i + j];\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(outData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n const newOut = new Uint8Array(\n flacMagic.length + metaBlock.length,\n );\n newOut.set(flacMagic);\n newOut.set(metaBlock, flacMagic.length);\n outData = newOut;\n } else outData = new Uint8Array(0);\n } else {\n outData = extractBoxData(outData, \"mdat\") ||\n new Uint8Array(0);\n }\n }\n\n const currentSegOffset = segmentOffsets[i + j];\n const outSize = outData.length;\n const startInChunk = Math.max(0, rangeStart - currentSegOffset);\n const currentEndOffset = currentSegOffset + outSize;\n\n if (startInChunk > 0 || currentEndOffset > resolvedEnd + 1) {\n const endInChunk = Math.min(\n outSize,\n outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)),\n );\n outData = outData.slice(startInChunk, endInChunk);\n }\n\n if (outData.length > 0) await writer.write(outData);\n }\n }\n } catch (e) {\n console.error(`[WebSeed] Stream Error:`, e.message);\n } finally {\n writer.close();\n }\n })();\n\n return new Response(readable, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n return new Response(\"NullBeat Val.town Proxy Online\", { status: 200 });\n } catch (err) {\n console.error(\"Unhandled server error:\", err.message);\n return new Response(\n JSON.stringify({\n error: \"Internal Server Error\",\n message: err.message,\n }),\n { status: 500, headers: corsHeaders() },\n );\n }\n}","createdAt",["D",1787723404918],"branchVersion","branchId","bb96142c-a8ee-4480-9f21-d8c8176be5d8","id","40158b88-3bf8-4ab2-9767-3c8adf980aa8","nullbeatStreamProxy",["D",1787588563935],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","5f176305-db17-4c4c-9e0d-a3887128495f","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1f78-ba2f-754d-b681-41787f593d34","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",67,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","thevolecitor","handle","displayName","The Volecitor","avatar","https://lh3.googleusercontent.com/a/ACg8ocJDSk1v8A-JR-j9BixGbkpDFxDEwDLvb547SIx-wABVv2vdTw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_27":134},"58cc5f5e-344a-4198-82aa-a246606a5425","parentId","latest",["D",1787723404918],39,"label","nullbeat",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",4,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":148,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_149":150,"_27":151},["D",1787723404918],"children",[],[28],["D",1787588563935],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":57,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":85,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":57,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",40,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","fb6ca8a6-9fd8-11f1-81e6-1607ee4eb77e","name","fileType","http","content","const trackRequestLockMap = new Map();\n\nfunction checkTrackLock(key, lockWindowMs = 120000) {\n const now = Date.now();\n const lastTime = trackRequestLockMap.get(key);\n if (lastTime && (now - lastTime < lockWindowMs)) {\n return false; // Already locked / in queue\n }\n trackRequestLockMap.set(key, now);\n if (trackRequestLockMap.size > 2000) {\n for (const [k, t] of trackRequestLockMap.entries()) {\n if (now - t > lockWindowMs) trackRequestLockMap.delete(k);\n }\n }\n return true;\n}\n\nfunction cleanUrlString(str) {\n if (!str) return \"\";\n return str.trim().replace(/^[\"']|[\"']$/g, \"\").trim();\n}\n\nfunction getHifiBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? (Deno.env.get(\"HIFI_BACKENDS\") || Deno.env.get(\"HIFI_BACKEND\"))\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return [];\n}\n\nfunction getHifiSearchBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"HIFI_SEARCH\")\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return getHifiBackends();\n}\n\nasync function fetchHifiApi(path, options = {}, isSearch = false) {\n const sourceList = isSearch ? getHifiSearchBackends() : getHifiBackends();\n const backends = [...sourceList].sort(() => Math.random() - 0.5);\n if (backends.length === 0) {\n const varName = isSearch\n ? \"HIFI_SEARCH (or HIFI_BACKENDS)\"\n : \"HIFI_BACKENDS\";\n throw new Error(\n `No HiFi API backends configured. Please set the ${varName} environment variable.`,\n );\n }\n let lastError = null;\n\n for (let base of backends) {\n base = cleanUrlString(base);\n if (!base.startsWith(\"http\")) continue;\n const cleanBase = base.endsWith(\"/\") ? base.slice(0, -1) : base;\n const url = `${cleanBase}${path.startsWith(\"/\") ? path : \"/\" + path}`;\n try {\n const res = await fetch(url, {\n ...options,\n signal: AbortSignal.timeout(8000),\n });\n if (res.ok) return res;\n lastError = new Error(`HTTP ${res.status} from ${base}`);\n } catch (e) {\n lastError = e;\n }\n }\n\n throw lastError || new Error(\"All HiFi API backends failed\");\n}\n\nfunction corsHeaders() {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n };\n}\n\nfunction jsonResp(data, status = 200, cacheAge = 0) {\n const headers = new Headers(corsHeaders());\n headers.set(\"Content-Type\", \"application/json\");\n if (cacheAge > 0) headers.set(\"Cache-Control\", `public, max-age=${cacheAge}`);\n return new Response(JSON.stringify(data), { status, headers });\n}\n\nconst textEnc = new TextEncoder();\nconst textDec = new TextDecoder();\n\nfunction b64Decode(str) {\n try {\n str = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n while (str.length % 4) str += \"=\";\n const binary = atob(str);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) {\n bytes[i] = binary.charCodeAt(i);\n }\n return textDec.decode(bytes);\n } catch {\n return \"\";\n }\n}\n\nfunction b64Encode(str) {\n const bytes = textEnc.encode(str);\n let binary = \"\";\n for (let i = 0; i < bytes.byteLength; i++) {\n binary += String.fromCharCode(bytes[i]);\n }\n return btoa(binary).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(\n /=+$/,\n \"\",\n );\n}\n\nfunction decodeToken(enc) {\n try {\n const raw = b64Decode(enc);\n const parts = raw.split(\"|||\");\n const torboxApiKey = parts[0] || \"\";\n let q = parts[1] ? parts[1].toUpperCase() : \"MAX\";\n return { torboxApiKey, quality: q };\n } catch {\n return { torboxApiKey: \"\", quality: \"MAX\" };\n }\n}\n\nfunction extractBoxData(buffer, boxType) {\n let offset = 0;\n while (offset + 8 <= buffer.length) {\n const size = new DataView(\n buffer.buffer,\n buffer.byteOffset,\n buffer.byteLength,\n ).getUint32(offset, false);\n if (size < 8) break;\n\n const type = new TextDecoder().decode(\n buffer.subarray(offset + 4, offset + 8),\n );\n\n if (type === boxType) {\n return buffer.subarray(offset + 8, offset + size);\n }\n\n if (\n [\"moov\", \"trak\", \"mdia\", \"minf\", \"stbl\", \"stsd\", \"fLaC\"].includes(type)\n ) {\n let innerStart = offset + 8;\n if (type === \"stsd\") innerStart += 8;\n if (type === \"fLaC\") innerStart += 28;\n\n if (innerStart < offset + size) {\n const innerData = buffer.subarray(innerStart, offset + size);\n const found = extractBoxData(innerData, boxType);\n if (found) return found;\n }\n }\n offset += size;\n }\n return null;\n}\n\nfunction concatU8(arrays) {\n let totalLength = arrays.reduce((acc, value) => acc + value.length, 0);\n let result = new Uint8Array(totalLength);\n let length = 0;\n for (let array of arrays) {\n result.set(array, length);\n length += array.length;\n }\n return result;\n}\nfunction bencodeString(strOrArr) {\n const buf = typeof strOrArr === \"string\"\n ? textEnc.encode(strOrArr)\n : strOrArr;\n return concatU8([textEnc.encode(buf.length + \":\"), buf]);\n}\nfunction bencodeInt(n) {\n return textEnc.encode(`i${n}e`);\n}\nfunction bencodeList(list) {\n return concatU8([textEnc.encode(\"l\"), ...list, textEnc.encode(\"e\")]);\n}\nfunction bencodeDict(dict) {\n const keys = Object.keys(dict).sort();\n const parts = [textEnc.encode(\"d\")];\n for (const k of keys) {\n parts.push(bencodeString(k));\n parts.push(dict[k]);\n }\n parts.push(textEnc.encode(\"e\"));\n return concatU8(parts);\n}\n\n// ─── Concurrent Downloader ───────────────────────────────────────────────────\n\nasync function fetchSegmentsConcurrently(urls, concurrency = 20) {\n const results = new Array(urls.length);\n const queue = urls.map((url, i) => ({ url, i }));\n\n const workers = Array(concurrency).fill(null).map(async () => {\n while (queue.length > 0) {\n const task = queue.shift();\n const res = await fetch(task.url);\n if (!res.ok) throw new Error(`Segment fetch failed: ${res.status}`);\n results[task.i] = new Uint8Array(await res.arrayBuffer());\n }\n });\n\n await Promise.all(workers);\n return results;\n}\n\n// ─── Stream Generator ────────────────────────────────────────────────────────\n\nasync function generateTorrentBuffer(info, valBaseUrl, encParam) {\n const { streamData, filename } = info;\n let sizes = [];\n let pieceHashes = [];\n const pieceLength = 524288;\n let totalLength = 0;\n let currentPiece = new Uint8Array(pieceLength);\n let currentPieceCursor = 0;\n\n async function pushData(data) {\n if (data.length === 0) return;\n totalLength += data.length;\n let valCursor = 0;\n while (valCursor < data.length) {\n const remainingSpace = pieceLength - currentPieceCursor;\n const dataToCopy = Math.min(remainingSpace, data.length - valCursor);\n currentPiece.set(\n data.subarray(valCursor, valCursor + dataToCopy),\n currentPieceCursor,\n );\n currentPieceCursor += dataToCopy;\n valCursor += dataToCopy;\n\n if (currentPieceCursor === pieceLength) {\n const hashBuffer = await crypto.subtle.digest(\"SHA-1\", currentPiece);\n pieceHashes.push(new Uint8Array(hashBuffer));\n currentPieceCursor = 0;\n }\n }\n }\n\n if (!streamData.isDash) {\n const res = await fetch(streamData.url);\n if (!res.ok) throw new Error(\"Failed to fetch direct stream\");\n const reader = res.body.getReader();\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n await pushData(value);\n }\n } else {\n // 1. Fetch Manifest XML\n let dashXml;\n let manifestUrl = streamData.url;\n if (streamData.url.startsWith(\"data:\")) {\n dashXml = b64Decode(streamData.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) throw new Error(\"Failed to fetch DASH XML\");\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n if (!manifestUrlBase.startsWith(\"http\")) {\n manifestUrlBase = new URL(manifestUrlBase, manifestUrl).toString();\n }\n }\n\n let parsingContext = dashXml;\n const templateMatch = dashXml.match(\n //,\n );\n if (templateMatch) parsingContext = templateMatch[0];\n else {\n const listMatch = dashXml.match(//);\n if (listMatch) parsingContext = listMatch[0];\n }\n\n let initSegment = \"\";\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n if (initMatch) initSegment = initMatch[1].replace(/&/g, \"&\");\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = 1;\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n if (startMatch) startNumber = parseInt(startMatch[1], 10);\n\n let segments = [];\n if (initSegment) segments.push(initSegment);\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) => {\n try {\n return seg.startsWith(\"http\")\n ? seg\n : new URL(seg, manifestUrlBase).toString();\n } catch {\n return seg;\n }\n });\n\n const isFlac = filename.endsWith(\".flac\");\n\n for (let i = 0; i < uniqueSegments.length; i += 20) {\n const chunkUrls = uniqueSegments.slice(i, i + 20);\n const chunkDataArr = await fetchSegmentsConcurrently(chunkUrls, 20);\n\n for (let j = 0; j < chunkUrls.length; j++) {\n let chunkData = chunkDataArr[j];\n let outData = chunkData;\n const originalIndex = i + j;\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(chunkData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n outData = new Uint8Array(flacMagic.length + metaBlock.length);\n outData.set(flacMagic);\n outData.set(metaBlock, flacMagic.length);\n } else {\n outData = new Uint8Array(0);\n }\n } else {\n const mdat = extractBoxData(chunkData, \"mdat\");\n outData = mdat || new Uint8Array(0);\n }\n }\n\n sizes.push(outData.length);\n await pushData(outData);\n }\n }\n }\n\n if (currentPieceCursor > 0) {\n const hashBuffer = await crypto.subtle.digest(\n \"SHA-1\",\n currentPiece.slice(0, currentPieceCursor),\n );\n pieceHashes.push(new Uint8Array(hashBuffer));\n }\n\n const concatenatedHashes = concatU8(pieceHashes);\n const payloadStr = JSON.stringify({\n url: streamData.url,\n isDash: streamData.isDash,\n filename,\n sizes,\n });\n const torrentPayload = b64Encode(payloadStr);\n const webseedUrls = [\n `${valBaseUrl}/download/${torrentPayload}`,\n `${valBaseUrl}/download/${torrentPayload}?ws=1`,\n `${valBaseUrl}/download/${torrentPayload}?ws=2`,\n `${valBaseUrl}/download/${torrentPayload}?ws=3`,\n `${valBaseUrl}/download/${torrentPayload}?ws=4`,\n ];\n\n const infoTorrent = {\n length: bencodeInt(totalLength),\n name: bencodeString(filename),\n \"name.utf-8\": bencodeString(filename),\n \"piece length\": bencodeInt(pieceLength),\n pieces: bencodeString(concatenatedHashes),\n };\n\n const torrent = bencodeDict({\n encoding: bencodeString(\"UTF-8\"),\n info: bencodeDict(infoTorrent),\n \"url-list\": bencodeList(webseedUrls.map((u) => bencodeString(u))),\n });\n\n return torrent;\n}\n\nasync function md5Hash(text) {\n try {\n const { createHash } = await import(\"node:crypto\");\n return createHash(\"md5\").update(text).digest(\"hex\");\n } catch (e) {\n const msgUint8 = new TextEncoder().encode(text);\n const hashBuffer = await crypto.subtle.digest(\"MD5\", msgUint8);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n }\n}\n\nasync function getTrackMeta(trackId) {\n let artistName = \"Unknown Artist\";\n let trackName = \"Unknown Track\";\n\n // 1. Primary: Direct /info/?id= lookup from HiFi API backends\n try {\n const infoRes = await fetchHifiApi(`/info/?id=${trackId}`, {}, true);\n const infoJson = await infoRes.json();\n const item = infoJson?.data || infoJson;\n if (item && item.title) {\n trackName = item.title;\n artistName = item.artist?.name || item.artists?.find((a) =>\n a?.type === \"MAIN\"\n )?.name || item.artists?.[0]?.name || artistName;\n }\n } catch (e) {}\n\n // 2. Fallback: Tidal browse page lookup if HiFi API /info/ failed\n if (trackName === \"Unknown Track\") {\n try {\n const tRes = await fetch(`https://tidal.com/browse/track/${trackId}`, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n if (tRes.ok) {\n const text = await tRes.text();\n const match = text.match(/([^<]+)<\\/title>/);\n if (match) {\n let raw = match[1].replace(/ on TIDAL$/, \"\").trim();\n const byIdx = raw.lastIndexOf(\" by \");\n if (byIdx > -1) {\n trackName = raw.substring(0, byIdx).trim();\n artistName = raw.substring(byIdx + 4).trim();\n } else {\n trackName = raw.trim();\n }\n trackName = trackName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n artistName = artistName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n }\n }\n } catch (err) {}\n }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Track\";\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Artist\";\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Handlers ────────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n const url = new URL(req.url);\n const valBaseUrl = url.origin;\n const pathParts = url.pathname.split(\"/\").filter(Boolean);\n\n let isStream = false;\n let isDownload = false;\n let encParam = \"\";\n let trackId = \"\";\n let downloadUuid = \"\";\n\n if (pathParts[0] === \"stream\" && pathParts[1]) {\n isStream = true;\n encParam = pathParts[1];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[1] === \"stream\" && pathParts[2]) {\n isStream = true;\n encParam = pathParts[0];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[0] === \"download\" && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n } else if (pathParts[1] === \"download\" && pathParts[2]) {\n isDownload = true;\n downloadUuid = pathParts[2];\n }\n\n if (isStream) {\n const { torboxApiKey, quality } = decodeToken(encParam);\n if (!trackId || !torboxApiKey) {\n return new Response(\n JSON.stringify({ error: \"Missing trackId or API key\" }),\n { status: 400, headers: corsHeaders() },\n );\n }\n\n console.log(`[Stream] Requesting track ${trackId}`);\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n\n const FALLBACK_CHAINS = {\n MAX: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIRES: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n LOSSLESS: [\"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIGH: [\"HIGH\", \"LOW\"],\n LOW: [\"LOW\"],\n };\n const metaMap = {\n HI_RES_LOSSLESS: { label: \"Hi-Res FLAC\", ext: \"flac\" },\n LOSSLESS: { label: \"HiFi FLAC\", ext: \"flac\" },\n HIGH: { label: \"320kbps\", ext: \"m4a\" },\n LOW: { label: \"96kbps\", ext: \"m4a\" },\n };\n\n const chain = FALLBACK_CHAINS[quality] || FALLBACK_CHAINS[\"MAX\"];\n let hashes = {};\n\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const md5 = await md5Hash(fn);\n hashes[md5] = {\n formatKey,\n filename: fn,\n label: info.label,\n ext: info.ext,\n };\n }\n\n const hashList = Object.keys(hashes).join(\",\");\n let cachedHashes = {};\n\n try {\n const cacheRes = await fetch(\n `https://api.torbox.app/v1/api/torrents/checkcached?hash=${hashList}&format=object&list_files=false`,\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return new Response(\n JSON.stringify({ error: \"Invalid Torbox API Key\" }),\n { status: 401, headers: corsHeaders() },\n );\n }\n\n if (cacheRes.ok) {\n const cacheData = await cacheRes.json();\n if (cacheData.success && cacheData.data) {\n const cachedItems = Object.values(cacheData.data);\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const expectedBase =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}]`;\n const match = cachedItems.find((item) =>\n item &&\n (item.name === expectedBase ||\n item.name?.startsWith(expectedBase))\n );\n if (match && match.hash) {\n cachedHashes[formatKey] = match.hash;\n }\n }\n }\n }\n } catch (err) {\n console.error(\"[Torbox] Cache check error:\", err.message);\n }\n\n const topFormatKey = chain[0];\n let isCached = false;\n let cachedHash = null;\n let finalQualityLabel = metaMap[topFormatKey]?.label || quality;\n let filename = \"\";\n\n if (cachedHashes[topFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[topFormatKey];\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${\n metaMap[topFormatKey].ext\n }`;\n }\n\n let uri = \"\";\n let streamData = null;\n\n if (!isCached) {\n // Enforce 2-minute deduplication lock for uncached tracks currently in queue/processing\n const trackLockKey = `${torboxApiKey}_${trackId}`;\n if (!checkTrackLock(trackLockKey, 120000)) {\n return new Response(\n JSON.stringify({\n error:\n \"Already in queue. Please wait a moment before requesting this track again.\",\n }),\n { status: 429, headers: corsHeaders() },\n );\n }\n\n let formats = (quality === \"LOSSLESS\") ? \"FLAC\" : \"FLAC_HIRES,FLAC\";\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } catch (e) {\n if (formats !== \"FLAC\") {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } else {\n throw e;\n }\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n uri = attributes?.uri;\n if (!uri) {\n throw new Error(\"Missing URI in manifest response from HiFi API\");\n }\n\n const returnedFormats = Array.isArray(attributes?.formats)\n ? attributes.formats\n : [];\n let actualQuality = \"FLAC\";\n if (returnedFormats.includes(\"FLAC_HIRES\")) {\n actualQuality = \"FLAC_HIRES\";\n } else if (returnedFormats.includes(\"FLAC\")) actualQuality = \"FLAC\";\n else if (returnedFormats.length > 0) actualQuality = returnedFormats[0];\n\n let dashXml;\n try {\n if (uri.startsWith(\"data:\")) {\n dashXml = b64Decode(uri.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(uri);\n if (xmlRes.ok) dashXml = await xmlRes.text();\n }\n } catch (e) {}\n\n if (dashXml) {\n if (\n dashXml.includes('id=\"FLAC_HIRES') ||\n dashXml.includes(\"FLAC_HIRES,\")\n ) actualQuality = \"FLAC_HIRES\";\n else if (dashXml.includes('id=\"FLAC') || dashXml.includes(\"FLAC,\")) {\n actualQuality = \"FLAC\";\n }\n }\n\n finalQualityLabel = actualQuality === \"FLAC_HIRES\"\n ? \"Hi-Res FLAC\"\n : (actualQuality.includes(\"FLAC\") ? \"HiFi FLAC\" : actualQuality);\n const isFlac = actualQuality.includes(\"FLAC\");\n const ext = isFlac ? \"flac\" : \"m4a\";\n\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const actualFormatKey = actualQuality === \"FLAC_HIRES\"\n ? \"HI_RES_LOSSLESS\"\n : \"LOSSLESS\";\n if (cachedHashes[actualFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[actualFormatKey];\n }\n }\n\n const formData = new FormData();\n formData.append(\"seed\", \"3\");\n formData.append(\"allow_zip\", \"false\");\n formData.append(\"name\", filename);\n\n if (isCached && cachedHash) {\n formData.append(\"magnet\", `magnet:?xt=urn:btih:${cachedHash}`);\n } else {\n const torrentBuffer = await generateTorrentBuffer(\n { streamData, filename },\n valBaseUrl,\n encParam,\n );\n formData.append(\n \"file\",\n new Blob([torrentBuffer], { type: \"application/x-bittorrent\" }),\n `${filename}.torrent`,\n );\n }\n\n const addRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/createtorrent\",\n {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n body: formData,\n },\n );\n\n const addData = await addRes.json();\n if (addData.success && addData.data?.torrent_id) {\n const torrentId = addData.data.torrent_id;\n\n // Verify that the track is fully cached and playable before serving URL\n if (!isCached) {\n console.log(\n `[Torbox] Waiting for WebSeed caching to complete for Torrent ID: ${torrentId}...`,\n );\n let isFullyCached = false;\n let attempts = 0;\n const maxAttempts = 15; // 30 seconds max\n\n while (!isFullyCached && attempts < maxAttempts) {\n await new Promise((resolve) => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/mylist?bypass_cache=true\",\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n if (statusRes.ok) {\n const statusData = await statusRes.json();\n if (statusData.success && Array.isArray(statusData.data)) {\n const torrentInfo = statusData.data.find((t) =>\n t.id === torrentId\n );\n const state = String(\n torrentInfo?.download_state || torrentInfo?.status || \"\",\n ).toLowerCase();\n if (\n torrentInfo &&\n (state === \"cached\" || torrentInfo.cached === true)\n ) {\n console.log(\n `[Torbox] WebSeed caching completed successfully! State: ${state}`,\n );\n isFullyCached = true;\n }\n }\n }\n } catch (e) {\n console.error(\"[Torbox] Status polling error:\", e.message);\n }\n attempts++;\n }\n\n if (!isFullyCached) {\n return new Response(\n JSON.stringify({\n error:\n \"Track is currently caching on Torbox. Please try again in 15 seconds.\",\n }),\n { status: 503, headers: corsHeaders() },\n );\n }\n }\n\n // Edit torrent item on Torbox (Name, NullBeat tag, Airlocked) - async\n fetch(\"https://api.torbox.app/v1/api/torrents/edittorrent\", {\n method: \"PUT\",\n headers: {\n \"Authorization\": `Bearer ${torboxApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n torrent_id: torrentId,\n name: filename,\n tags: [\"NullBeat\"],\n airlocked: true,\n }),\n }).catch((e) =>\n console.error(\"[Torbox] Edit torrent error:\", e.message)\n );\n\n const requestdlUrl =\n `https://api.torbox.app/v1/api/torrents/requestdl?token=${torboxApiKey}&torrent_id=${torrentId}&redirect=true`;\n\n let finalCdnUrl = requestdlUrl;\n try {\n const headRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"manual\",\n });\n const loc = headRes.headers.get(\"location\") ||\n headRes.headers.get(\"Location\");\n if (loc) {\n finalCdnUrl = loc.startsWith(\"http\")\n ? loc\n : new URL(loc, requestdlUrl).toString();\n } else {\n const followRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"follow\",\n });\n if (followRes.url) finalCdnUrl = followRes.url;\n }\n } catch (e) {\n console.error(\"[Torbox] Error resolving CDN URL:\", e.message);\n }\n\n const ext = filename.endsWith(\".flac\")\n ? \"flac\"\n : (filename.endsWith(\".m4a\") ? \"m4a\" : \"mp3\");\n const expiresAt = Math.floor(Date.now() / 1000) + 86400;\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: expiresAt,\n });\n } else {\n console.error(\"[Torbox Error]:\", addData);\n return new Response(\n JSON.stringify({\n error: \"Failed to submit to Torbox\",\n details: addData,\n }),\n { status: 502, headers: corsHeaders() },\n );\n }\n }\n\n if (isDownload) {\n console.log(\n `[Download] Serving request for ${downloadUuid.slice(0, 10)}...`,\n );\n const uuid = downloadUuid;\n let data;\n try {\n data = JSON.parse(b64Decode(uuid));\n } catch {\n return new Response(\"Invalid UUID\", { status: 400 });\n }\n\n if (!data.isDash) {\n return new Response(null, {\n status: 302,\n headers: { Location: data.url },\n });\n }\n\n const rangeHeader = req.headers.get(\"Range\");\n let rangeStart = 0, rangeEnd = Infinity;\n if (rangeHeader) {\n const match = rangeHeader.match(/bytes=(\\d+)-(.*)/);\n if (match) {\n rangeStart = parseInt(match[1], 10);\n if (match[2]) rangeEnd = parseInt(match[2], 10);\n }\n }\n\n const isFlac = data.filename.endsWith(\".flac\");\n const totalSize = data.sizes.reduce((a, b) => a + b, 0);\n const resolvedEnd = rangeEnd !== Infinity ? rangeEnd : totalSize - 1;\n\n let dashXml;\n let manifestUrl = data.url;\n if (data.url.startsWith(\"data:\")) {\n dashXml = b64Decode(data.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) {\n return new Response(\"Failed to fetch DASH XML\", { status: 502 });\n }\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n }\n\n let parsingContext =\n dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] ||\n dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/)?.[0] || dashXml;\n\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n\n let segments = [];\n if (initMatch) segments.push(initMatch[1].replace(/&/g, \"&\"));\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = startMatch ? parseInt(startMatch[1], 10) : 1;\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) =>\n seg.startsWith(\"http\") ? seg : new URL(seg, manifestUrlBase).toString()\n );\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map((s) => {\n const cur = current;\n current += s;\n return cur;\n });\n\n let segmentsToFetch = [];\n let segmentOffsets = [];\n let segmentIndices = [];\n\n for (let i = 0; i < uniqueSegments.length; i++) {\n const segStart = segmentOffsetsMap[i];\n const segEnd = segStart + data.sizes[i] - 1;\n if (segStart <= resolvedEnd && segEnd >= rangeStart) {\n let segUrl = uniqueSegments[i];\n if (manifestUrl.includes(\"?\") && !segUrl.includes(\"?\")) {\n segUrl += manifestUrl.substring(manifestUrl.indexOf(\"?\"));\n }\n segmentsToFetch.push(segUrl);\n segmentOffsets.push(segStart);\n segmentIndices.push(i);\n }\n }\n\n const contentType = isFlac ? \"audio/flac\" : \"audio/mp4\";\n const responseHeaders = new Headers({\n \"Content-Disposition\": `attachment; filename=\"${data.filename}\"`,\n \"Content-Type\": contentType,\n \"Accept-Ranges\": \"bytes\",\n });\n\n if (rangeHeader) {\n responseHeaders.set(\n \"Content-Range\",\n `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`,\n );\n responseHeaders.set(\n \"Content-Length\",\n (resolvedEnd - rangeStart + 1).toString(),\n );\n } else {\n responseHeaders.set(\"Content-Length\", totalSize.toString());\n }\n\n if (req.method === \"HEAD\") {\n return new Response(null, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n const { readable, writable } = new TransformStream();\n const writer = writable.getWriter();\n\n (async () => {\n try {\n const CONCURRENCY = 20;\n for (let i = 0; i < segmentsToFetch.length; i += CONCURRENCY) {\n const batch = segmentsToFetch.slice(i, i + CONCURRENCY);\n const chunkDataArr = await fetchSegmentsConcurrently(\n batch,\n CONCURRENCY,\n );\n\n for (let j = 0; j < batch.length; j++) {\n let outData = chunkDataArr[j];\n const originalIndex = segmentIndices[i + j];\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(outData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n const newOut = new Uint8Array(\n flacMagic.length + metaBlock.length,\n );\n newOut.set(flacMagic);\n newOut.set(metaBlock, flacMagic.length);\n outData = newOut;\n } else outData = new Uint8Array(0);\n } else {\n outData = extractBoxData(outData, \"mdat\") ||\n new Uint8Array(0);\n }\n }\n\n const currentSegOffset = segmentOffsets[i + j];\n const outSize = outData.length;\n const startInChunk = Math.max(0, rangeStart - currentSegOffset);\n const currentEndOffset = currentSegOffset + outSize;\n\n if (startInChunk > 0 || currentEndOffset > resolvedEnd + 1) {\n const endInChunk = Math.min(\n outSize,\n outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)),\n );\n outData = outData.slice(startInChunk, endInChunk);\n }\n\n if (outData.length > 0) await writer.write(outData);\n }\n }\n } catch (e) {\n console.error(`[WebSeed] Stream Error:`, e.message);\n } finally {\n writer.close();\n }\n })();\n\n return new Response(readable, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n return new Response(\"NullBeat Val.town Proxy Online\", { status: 200 });\n } catch (err) {\n console.error(\"Unhandled server error:\", err.message);\n return new Response(\n JSON.stringify({\n error: \"Internal Server Error\",\n message: err.message,\n }),\n { status: 500, headers: corsHeaders() },\n );\n }\n}","const trackRequestLockMap = new Map();\n\nfunction checkTrackLock(key, lockWindowMs = 120000) {\n const now = Date.now();\n const lastTime = trackRequestLockMap.get(key);\n if (lastTime && (now - lastTime < lockWindowMs)) {\n return false; // Already locked / in queue\n }\n trackRequestLockMap.set(key, now);\n if (trackRequestLockMap.size > 2000) {\n for (const [k, t] of trackRequestLockMap.entries()) {\n if (now - t > lockWindowMs) trackRequestLockMap.delete(k);\n }\n }\n return true;\n}\n\nfunction cleanUrlString(str) {\n if (!str) return \"\";\n return str.trim().replace(/^[\"']|[\"']$/g, \"\").trim();\n}\n\nfunction getHifiBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? (Deno.env.get(\"HIFI_BACKENDS\") || Deno.env.get(\"HIFI_BACKEND\"))\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return [];\n}\n\nfunction getHifiSearchBackends() {\n const envVal = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"HIFI_SEARCH\")\n : null;\n if (envVal) {\n const list = envVal.split(\",\").map((s) => cleanUrlString(s)).filter(\n Boolean,\n );\n if (list.length > 0) return list;\n }\n return getHifiBackends();\n}\n\nasync function fetchHifiApi(path, options = {}, isSearch = false) {\n const sourceList = isSearch ? getHifiSearchBackends() : getHifiBackends();\n const backends = [...sourceList].sort(() => Math.random() - 0.5);\n if (backends.length === 0) {\n const varName = isSearch\n ? \"HIFI_SEARCH (or HIFI_BACKENDS)\"\n : \"HIFI_BACKENDS\";\n throw new Error(\n `No HiFi API backends configured. Please set the ${varName} environment variable.`,\n );\n }\n let lastError = null;\n\n for (let base of backends) {\n base = cleanUrlString(base);\n if (!base.startsWith(\"http\")) continue;\n const cleanBase = base.endsWith(\"/\") ? base.slice(0, -1) : base;\n const url = `${cleanBase}${path.startsWith(\"/\") ? path : \"/\" + path}`;\n try {\n const res = await fetch(url, {\n ...options,\n signal: AbortSignal.timeout(8000),\n });\n if (res.ok) return res;\n lastError = new Error(`HTTP ${res.status} from ${base}`);\n } catch (e) {\n lastError = e;\n }\n }\n\n throw lastError || new Error(\"All HiFi API backends failed\");\n}\n\nfunction corsHeaders() {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n };\n}\n\nfunction jsonResp(data, status = 200, cacheAge = 0) {\n const headers = new Headers(corsHeaders());\n headers.set(\"Content-Type\", \"application/json\");\n if (cacheAge > 0) headers.set(\"Cache-Control\", `public, max-age=${cacheAge}`);\n return new Response(JSON.stringify(data), { status, headers });\n}\n\nconst textEnc = new TextEncoder();\nconst textDec = new TextDecoder();\n\nfunction b64Decode(str) {\n try {\n str = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n while (str.length % 4) str += \"=\";\n const binary = atob(str);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) {\n bytes[i] = binary.charCodeAt(i);\n }\n return textDec.decode(bytes);\n } catch {\n return \"\";\n }\n}\n\nfunction b64Encode(str) {\n const bytes = textEnc.encode(str);\n let binary = \"\";\n for (let i = 0; i < bytes.byteLength; i++) {\n binary += String.fromCharCode(bytes[i]);\n }\n return btoa(binary).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(\n /=+$/,\n \"\",\n );\n}\n\nfunction decodeToken(enc) {\n try {\n const raw = b64Decode(enc);\n const parts = raw.split(\"|||\");\n const torboxApiKey = parts[0] || \"\";\n let q = parts[1] ? parts[1].toUpperCase() : \"MAX\";\n return { torboxApiKey, quality: q };\n } catch {\n return { torboxApiKey: \"\", quality: \"MAX\" };\n }\n}\n\nfunction extractBoxData(buffer, boxType) {\n let offset = 0;\n while (offset + 8 <= buffer.length) {\n const size = new DataView(\n buffer.buffer,\n buffer.byteOffset,\n buffer.byteLength,\n ).getUint32(offset, false);\n if (size < 8) break;\n\n const type = new TextDecoder().decode(\n buffer.subarray(offset + 4, offset + 8),\n );\n\n if (type === boxType) {\n return buffer.subarray(offset + 8, offset + size);\n }\n\n if (\n [\"moov\", \"trak\", \"mdia\", \"minf\", \"stbl\", \"stsd\", \"fLaC\"].includes(type)\n ) {\n let innerStart = offset + 8;\n if (type === \"stsd\") innerStart += 8;\n if (type === \"fLaC\") innerStart += 28;\n\n if (innerStart < offset + size) {\n const innerData = buffer.subarray(innerStart, offset + size);\n const found = extractBoxData(innerData, boxType);\n if (found) return found;\n }\n }\n offset += size;\n }\n return null;\n}\n\nfunction concatU8(arrays) {\n let totalLength = arrays.reduce((acc, value) => acc + value.length, 0);\n let result = new Uint8Array(totalLength);\n let length = 0;\n for (let array of arrays) {\n result.set(array, length);\n length += array.length;\n }\n return result;\n}\nfunction bencodeString(strOrArr) {\n const buf = typeof strOrArr === \"string\"\n ? textEnc.encode(strOrArr)\n : strOrArr;\n return concatU8([textEnc.encode(buf.length + \":\"), buf]);\n}\nfunction bencodeInt(n) {\n return textEnc.encode(`i${n}e`);\n}\nfunction bencodeList(list) {\n return concatU8([textEnc.encode(\"l\"), ...list, textEnc.encode(\"e\")]);\n}\nfunction bencodeDict(dict) {\n const keys = Object.keys(dict).sort();\n const parts = [textEnc.encode(\"d\")];\n for (const k of keys) {\n parts.push(bencodeString(k));\n parts.push(dict[k]);\n }\n parts.push(textEnc.encode(\"e\"));\n return concatU8(parts);\n}\n\n// ─── Concurrent Downloader ───────────────────────────────────────────────────\n\nasync function fetchSegmentsConcurrently(urls, concurrency = 20) {\n const results = new Array(urls.length);\n const queue = urls.map((url, i) => ({ url, i }));\n\n const workers = Array(concurrency).fill(null).map(async () => {\n while (queue.length > 0) {\n const task = queue.shift();\n const res = await fetch(task.url);\n if (!res.ok) throw new Error(`Segment fetch failed: ${res.status}`);\n results[task.i] = new Uint8Array(await res.arrayBuffer());\n }\n });\n\n await Promise.all(workers);\n return results;\n}\n\n// ─── Stream Generator ────────────────────────────────────────────────────────\n\nasync function generateTorrentBuffer(info, valBaseUrl, encParam) {\n const { streamData, filename } = info;\n let sizes = [];\n let pieceHashes = [];\n const pieceLength = 524288;\n let totalLength = 0;\n let currentPiece = new Uint8Array(pieceLength);\n let currentPieceCursor = 0;\n\n async function pushData(data) {\n if (data.length === 0) return;\n totalLength += data.length;\n let valCursor = 0;\n while (valCursor < data.length) {\n const remainingSpace = pieceLength - currentPieceCursor;\n const dataToCopy = Math.min(remainingSpace, data.length - valCursor);\n currentPiece.set(\n data.subarray(valCursor, valCursor + dataToCopy),\n currentPieceCursor,\n );\n currentPieceCursor += dataToCopy;\n valCursor += dataToCopy;\n\n if (currentPieceCursor === pieceLength) {\n const hashBuffer = await crypto.subtle.digest(\"SHA-1\", currentPiece);\n pieceHashes.push(new Uint8Array(hashBuffer));\n currentPieceCursor = 0;\n }\n }\n }\n\n if (!streamData.isDash) {\n const res = await fetch(streamData.url);\n if (!res.ok) throw new Error(\"Failed to fetch direct stream\");\n const reader = res.body.getReader();\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n await pushData(value);\n }\n } else {\n // 1. Fetch Manifest XML\n let dashXml;\n let manifestUrl = streamData.url;\n if (streamData.url.startsWith(\"data:\")) {\n dashXml = b64Decode(streamData.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) throw new Error(\"Failed to fetch DASH XML\");\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n if (!manifestUrlBase.startsWith(\"http\")) {\n manifestUrlBase = new URL(manifestUrlBase, manifestUrl).toString();\n }\n }\n\n let parsingContext = dashXml;\n const templateMatch = dashXml.match(\n /<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/,\n );\n if (templateMatch) parsingContext = templateMatch[0];\n else {\n const listMatch = dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/);\n if (listMatch) parsingContext = listMatch[0];\n }\n\n let initSegment = \"\";\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n if (initMatch) initSegment = initMatch[1].replace(/&/g, \"&\");\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = 1;\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n if (startMatch) startNumber = parseInt(startMatch[1], 10);\n\n let segments = [];\n if (initSegment) segments.push(initSegment);\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) => {\n try {\n return seg.startsWith(\"http\")\n ? seg\n : new URL(seg, manifestUrlBase).toString();\n } catch {\n return seg;\n }\n });\n\n const isFlac = filename.endsWith(\".flac\");\n\n for (let i = 0; i < uniqueSegments.length; i += 20) {\n const chunkUrls = uniqueSegments.slice(i, i + 20);\n const chunkDataArr = await fetchSegmentsConcurrently(chunkUrls, 20);\n\n for (let j = 0; j < chunkUrls.length; j++) {\n let chunkData = chunkDataArr[j];\n let outData = chunkData;\n const originalIndex = i + j;\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(chunkData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n outData = new Uint8Array(flacMagic.length + metaBlock.length);\n outData.set(flacMagic);\n outData.set(metaBlock, flacMagic.length);\n } else {\n outData = new Uint8Array(0);\n }\n } else {\n const mdat = extractBoxData(chunkData, \"mdat\");\n outData = mdat || new Uint8Array(0);\n }\n }\n\n sizes.push(outData.length);\n await pushData(outData);\n }\n }\n }\n\n if (currentPieceCursor > 0) {\n const hashBuffer = await crypto.subtle.digest(\n \"SHA-1\",\n currentPiece.slice(0, currentPieceCursor),\n );\n pieceHashes.push(new Uint8Array(hashBuffer));\n }\n\n const concatenatedHashes = concatU8(pieceHashes);\n const payloadStr = JSON.stringify({\n url: streamData.url,\n isDash: streamData.isDash,\n filename,\n sizes,\n });\n const torrentPayload = b64Encode(payloadStr);\n const webseedUrls = [\n `${valBaseUrl}/download/${torrentPayload}`,\n `${valBaseUrl}/download/${torrentPayload}?ws=1`,\n `${valBaseUrl}/download/${torrentPayload}?ws=2`,\n ];\n\n const infoTorrent = {\n length: bencodeInt(totalLength),\n name: bencodeString(filename),\n \"name.utf-8\": bencodeString(filename),\n \"piece length\": bencodeInt(pieceLength),\n pieces: bencodeString(concatenatedHashes),\n };\n\n const torrent = bencodeDict({\n encoding: bencodeString(\"UTF-8\"),\n info: bencodeDict(infoTorrent),\n \"url-list\": bencodeList(webseedUrls.map((u) => bencodeString(u))),\n });\n\n return torrent;\n}\n\nasync function md5Hash(text) {\n try {\n const { createHash } = await import(\"node:crypto\");\n return createHash(\"md5\").update(text).digest(\"hex\");\n } catch (e) {\n const msgUint8 = new TextEncoder().encode(text);\n const hashBuffer = await crypto.subtle.digest(\"MD5\", msgUint8);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n }\n}\n\nasync function getTrackMeta(trackId) {\n let artistName = \"Unknown Artist\";\n let trackName = \"Unknown Track\";\n\n // 1. Primary: Direct /info/?id= lookup from HiFi API backends\n try {\n const infoRes = await fetchHifiApi(`/info/?id=${trackId}`, {}, true);\n const infoJson = await infoRes.json();\n const item = infoJson?.data || infoJson;\n if (item && item.title) {\n trackName = item.title;\n artistName = item.artist?.name || item.artists?.find((a) =>\n a?.type === \"MAIN\"\n )?.name || item.artists?.[0]?.name || artistName;\n }\n } catch (e) {}\n\n // 2. Fallback: Tidal browse page lookup if HiFi API /info/ failed\n if (trackName === \"Unknown Track\") {\n try {\n const tRes = await fetch(`https://tidal.com/browse/track/${trackId}`, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n if (tRes.ok) {\n const text = await tRes.text();\n const match = text.match(/<title>([^<]+)<\\/title>/);\n if (match) {\n let raw = match[1].replace(/ on TIDAL$/, \"\").trim();\n const byIdx = raw.lastIndexOf(\" by \");\n if (byIdx > -1) {\n trackName = raw.substring(0, byIdx).trim();\n artistName = raw.substring(byIdx + 4).trim();\n } else {\n trackName = raw.trim();\n }\n trackName = trackName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n artistName = artistName.replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/'/g, \"'\");\n }\n }\n } catch (err) {}\n }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Track\";\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, \"\").trim() ||\n \"Artist\";\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Handlers ────────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n const url = new URL(req.url);\n const valBaseUrl = url.origin;\n const pathParts = url.pathname.split(\"/\").filter(Boolean);\n\n let isStream = false;\n let isDownload = false;\n let encParam = \"\";\n let trackId = \"\";\n let downloadUuid = \"\";\n\n if (pathParts[0] === \"stream\" && pathParts[1]) {\n isStream = true;\n encParam = pathParts[1];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[1] === \"stream\" && pathParts[2]) {\n isStream = true;\n encParam = pathParts[0];\n trackId = (pathParts[2] || \"\").replace(/^track:/, \"\").replace(\n /\\.json$/,\n \"\",\n );\n } else if (pathParts[0] === \"download\" && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n } else if (pathParts[1] === \"download\" && pathParts[2]) {\n isDownload = true;\n downloadUuid = pathParts[2];\n }\n\n if (isStream) {\n const { torboxApiKey, quality } = decodeToken(encParam);\n if (!trackId || !torboxApiKey) {\n return new Response(\n JSON.stringify({ error: \"Missing trackId or API key\" }),\n { status: 400, headers: corsHeaders() },\n );\n }\n\n console.log(`[Stream] Requesting track ${trackId}`);\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n\n const FALLBACK_CHAINS = {\n MAX: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIRES: [\"HI_RES_LOSSLESS\", \"LOSSLESS\", \"HIGH\", \"LOW\"],\n LOSSLESS: [\"LOSSLESS\", \"HIGH\", \"LOW\"],\n HIGH: [\"HIGH\", \"LOW\"],\n LOW: [\"LOW\"],\n };\n const metaMap = {\n HI_RES_LOSSLESS: { label: \"Hi-Res FLAC\", ext: \"flac\" },\n LOSSLESS: { label: \"HiFi FLAC\", ext: \"flac\" },\n HIGH: { label: \"320kbps\", ext: \"m4a\" },\n LOW: { label: \"96kbps\", ext: \"m4a\" },\n };\n\n const chain = FALLBACK_CHAINS[quality] || FALLBACK_CHAINS[\"MAX\"];\n let hashes = {};\n\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const md5 = await md5Hash(fn);\n hashes[md5] = {\n formatKey,\n filename: fn,\n label: info.label,\n ext: info.ext,\n };\n }\n\n const hashList = Object.keys(hashes).join(\",\");\n let cachedHashes = {};\n\n try {\n const cacheRes = await fetch(\n `https://api.torbox.app/v1/api/torrents/checkcached?hash=${hashList}&format=object&list_files=false`,\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return new Response(\n JSON.stringify({ error: \"Invalid Torbox API Key\" }),\n { status: 401, headers: corsHeaders() },\n );\n }\n\n if (cacheRes.ok) {\n const cacheData = await cacheRes.json();\n if (cacheData.success && cacheData.data) {\n const cachedItems = Object.values(cacheData.data);\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const expectedBase =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}]`;\n const match = cachedItems.find((item) =>\n item &&\n (item.name === expectedBase ||\n item.name?.startsWith(expectedBase))\n );\n if (match && match.hash) {\n cachedHashes[formatKey] = match.hash;\n }\n }\n }\n }\n } catch (err) {\n console.error(\"[Torbox] Cache check error:\", err.message);\n }\n\n const topFormatKey = chain[0];\n let isCached = false;\n let cachedHash = null;\n let finalQualityLabel = metaMap[topFormatKey]?.label || quality;\n let filename = \"\";\n\n if (cachedHashes[topFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[topFormatKey];\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${\n metaMap[topFormatKey].ext\n }`;\n }\n\n let uri = \"\";\n let streamData = null;\n\n if (!isCached) {\n // Enforce 2-minute deduplication lock for uncached tracks currently in queue/processing\n const trackLockKey = `${torboxApiKey}_${trackId}`;\n if (!checkTrackLock(trackLockKey, 120000)) {\n return new Response(\n JSON.stringify({\n error:\n \"Already in queue. Please wait a moment before requesting this track again.\",\n }),\n { status: 429, headers: corsHeaders() },\n );\n }\n\n let formats = (quality === \"LOSSLESS\") ? \"FLAC\" : \"FLAC_HIRES,FLAC\";\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } catch (e) {\n if (formats !== \"FLAC\") {\n streamApiRes = await fetchHifiApi(\n `/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`,\n );\n } else {\n throw e;\n }\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n uri = attributes?.uri;\n if (!uri) {\n throw new Error(\"Missing URI in manifest response from HiFi API\");\n }\n\n const returnedFormats = Array.isArray(attributes?.formats)\n ? attributes.formats\n : [];\n let actualQuality = \"FLAC\";\n if (returnedFormats.includes(\"FLAC_HIRES\")) {\n actualQuality = \"FLAC_HIRES\";\n } else if (returnedFormats.includes(\"FLAC\")) actualQuality = \"FLAC\";\n else if (returnedFormats.length > 0) actualQuality = returnedFormats[0];\n\n let dashXml;\n try {\n if (uri.startsWith(\"data:\")) {\n dashXml = b64Decode(uri.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(uri);\n if (xmlRes.ok) dashXml = await xmlRes.text();\n }\n } catch (e) {}\n\n if (dashXml) {\n if (\n dashXml.includes('id=\"FLAC_HIRES') ||\n dashXml.includes(\"FLAC_HIRES,\")\n ) actualQuality = \"FLAC_HIRES\";\n else if (dashXml.includes('id=\"FLAC') || dashXml.includes(\"FLAC,\")) {\n actualQuality = \"FLAC\";\n }\n }\n\n finalQualityLabel = actualQuality === \"FLAC_HIRES\"\n ? \"Hi-Res FLAC\"\n : (actualQuality.includes(\"FLAC\") ? \"HiFi FLAC\" : actualQuality);\n const isFlac = actualQuality.includes(\"FLAC\");\n const ext = isFlac ? \"flac\" : \"m4a\";\n\n filename =\n `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const actualFormatKey = actualQuality === \"FLAC_HIRES\"\n ? \"HI_RES_LOSSLESS\"\n : \"LOSSLESS\";\n if (cachedHashes[actualFormatKey]) {\n isCached = true;\n cachedHash = cachedHashes[actualFormatKey];\n }\n }\n\n const formData = new FormData();\n formData.append(\"seed\", \"3\");\n formData.append(\"allow_zip\", \"false\");\n formData.append(\"name\", filename);\n\n if (isCached && cachedHash) {\n formData.append(\"magnet\", `magnet:?xt=urn:btih:${cachedHash}`);\n } else {\n const torrentBuffer = await generateTorrentBuffer(\n { streamData, filename },\n valBaseUrl,\n encParam,\n );\n formData.append(\n \"file\",\n new Blob([torrentBuffer], { type: \"application/x-bittorrent\" }),\n `${filename}.torrent`,\n );\n }\n\n const addRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/createtorrent\",\n {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n body: formData,\n },\n );\n\n const addData = await addRes.json();\n if (addData.success && addData.data?.torrent_id) {\n const torrentId = addData.data.torrent_id;\n\n // Verify that the track is fully cached and playable before serving URL\n if (!isCached) {\n console.log(\n `[Torbox] Waiting for WebSeed caching to complete for Torrent ID: ${torrentId}...`,\n );\n let isFullyCached = false;\n let attempts = 0;\n const maxAttempts = 15; // 30 seconds max\n\n while (!isFullyCached && attempts < maxAttempts) {\n await new Promise((resolve) => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch(\n \"https://api.torbox.app/v1/api/torrents/mylist?bypass_cache=true\",\n {\n headers: { \"Authorization\": `Bearer ${torboxApiKey}` },\n },\n );\n if (statusRes.ok) {\n const statusData = await statusRes.json();\n if (statusData.success && Array.isArray(statusData.data)) {\n const torrentInfo = statusData.data.find((t) =>\n t.id === torrentId\n );\n const state = String(\n torrentInfo?.download_state || torrentInfo?.status || \"\",\n ).toLowerCase();\n if (\n torrentInfo &&\n (state === \"cached\" || torrentInfo.cached === true)\n ) {\n console.log(\n `[Torbox] WebSeed caching completed successfully! State: ${state}`,\n );\n isFullyCached = true;\n }\n }\n }\n } catch (e) {\n console.error(\"[Torbox] Status polling error:\", e.message);\n }\n attempts++;\n }\n\n if (!isFullyCached) {\n return new Response(\n JSON.stringify({\n error:\n \"Track is currently caching on Torbox. Please try again in 15 seconds.\",\n }),\n { status: 503, headers: corsHeaders() },\n );\n }\n }\n\n // Edit torrent item on Torbox (Name, NullBeat tag, Airlocked) - async\n fetch(\"https://api.torbox.app/v1/api/torrents/edittorrent\", {\n method: \"PUT\",\n headers: {\n \"Authorization\": `Bearer ${torboxApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n torrent_id: torrentId,\n name: filename,\n tags: [\"NullBeat\"],\n airlocked: true,\n }),\n }).catch((e) =>\n console.error(\"[Torbox] Edit torrent error:\", e.message)\n );\n\n const requestdlUrl =\n `https://api.torbox.app/v1/api/torrents/requestdl?token=${torboxApiKey}&torrent_id=${torrentId}&redirect=true`;\n\n let finalCdnUrl = requestdlUrl;\n try {\n const headRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"manual\",\n });\n const loc = headRes.headers.get(\"location\") ||\n headRes.headers.get(\"Location\");\n if (loc) {\n finalCdnUrl = loc.startsWith(\"http\")\n ? loc\n : new URL(loc, requestdlUrl).toString();\n } else {\n const followRes = await fetch(requestdlUrl, {\n method: \"HEAD\",\n redirect: \"follow\",\n });\n if (followRes.url) finalCdnUrl = followRes.url;\n }\n } catch (e) {\n console.error(\"[Torbox] Error resolving CDN URL:\", e.message);\n }\n\n const ext = filename.endsWith(\".flac\")\n ? \"flac\"\n : (filename.endsWith(\".m4a\") ? \"m4a\" : \"mp3\");\n const expiresAt = Math.floor(Date.now() / 1000) + 86400;\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: expiresAt,\n });\n } else {\n console.error(\"[Torbox Error]:\", addData);\n return new Response(\n JSON.stringify({\n error: \"Failed to submit to Torbox\",\n details: addData,\n }),\n { status: 502, headers: corsHeaders() },\n );\n }\n }\n\n if (isDownload) {\n console.log(\n `[Download] Serving request for ${downloadUuid.slice(0, 10)}...`,\n );\n const uuid = downloadUuid;\n let data;\n try {\n data = JSON.parse(b64Decode(uuid));\n } catch {\n return new Response(\"Invalid UUID\", { status: 400 });\n }\n\n if (!data.isDash) {\n return new Response(null, {\n status: 302,\n headers: { Location: data.url },\n });\n }\n\n const rangeHeader = req.headers.get(\"Range\");\n let rangeStart = 0, rangeEnd = Infinity;\n if (rangeHeader) {\n const match = rangeHeader.match(/bytes=(\\d+)-(.*)/);\n if (match) {\n rangeStart = parseInt(match[1], 10);\n if (match[2]) rangeEnd = parseInt(match[2], 10);\n }\n }\n\n const isFlac = data.filename.endsWith(\".flac\");\n const totalSize = data.sizes.reduce((a, b) => a + b, 0);\n const resolvedEnd = rangeEnd !== Infinity ? rangeEnd : totalSize - 1;\n\n let dashXml;\n let manifestUrl = data.url;\n if (data.url.startsWith(\"data:\")) {\n dashXml = b64Decode(data.url.split(\",\")[1]);\n } else {\n const xmlRes = await fetch(manifestUrl);\n if (!xmlRes.ok) {\n return new Response(\"Failed to fetch DASH XML\", { status: 502 });\n }\n dashXml = await xmlRes.text();\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf(\"?\");\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(\n 0,\n manifestUrlBase.lastIndexOf(\"/\") + 1,\n );\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, \"&\");\n }\n\n let parsingContext =\n dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] ||\n dashXml.match(/<SegmentList[\\s\\S]*?<\\/SegmentList>/)?.[0] || dashXml;\n\n const initMatch = parsingContext.match(/initialization=\"([^\"]+)\"/);\n const mediaMatch = parsingContext.match(/media=\"([^\"]+)\"/);\n const startMatch = parsingContext.match(/startNumber=\"(\\d+)\"/);\n\n let segments = [];\n if (initMatch) segments.push(initMatch[1].replace(/&/g, \"&\"));\n const mediaTemplate = mediaMatch\n ? mediaMatch[1].replace(/&/g, \"&\")\n : \"\";\n let startNumber = startMatch ? parseInt(startMatch[1], 10) : 1;\n let totalSegments = 0;\n for (const tag of [...parsingContext.matchAll(/<S\\s+([^>]+)>/g)]) {\n const rMatch = tag[1].match(/r=\"(\\d+)\"/);\n totalSegments += 1 + (rMatch ? parseInt(rMatch[1], 10) : 0);\n }\n\n if (mediaTemplate && totalSegments > 0) {\n for (let i = 0; i < totalSegments; i++) {\n segments.push(mediaTemplate.replace(\"$Number$\", startNumber + i));\n }\n } else {\n parsingContext.match(/media=\"([^\"]+)\"/g)?.forEach((s) => {\n const u = s.replace(/media=\"/, \"\").replace(/\"$/, \"\").trim();\n if (u) segments.push(u.replace(/&/g, \"&\"));\n });\n }\n\n const uniqueSegments = [...new Set(segments)].map((seg) =>\n seg.startsWith(\"http\") ? seg : new URL(seg, manifestUrlBase).toString()\n );\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map((s) => {\n const cur = current;\n current += s;\n return cur;\n });\n\n let segmentsToFetch = [];\n let segmentOffsets = [];\n let segmentIndices = [];\n\n for (let i = 0; i < uniqueSegments.length; i++) {\n const segStart = segmentOffsetsMap[i];\n const segEnd = segStart + data.sizes[i] - 1;\n if (segStart <= resolvedEnd && segEnd >= rangeStart) {\n let segUrl = uniqueSegments[i];\n if (manifestUrl.includes(\"?\") && !segUrl.includes(\"?\")) {\n segUrl += manifestUrl.substring(manifestUrl.indexOf(\"?\"));\n }\n segmentsToFetch.push(segUrl);\n segmentOffsets.push(segStart);\n segmentIndices.push(i);\n }\n }\n\n const contentType = isFlac ? \"audio/flac\" : \"audio/mp4\";\n const responseHeaders = new Headers({\n \"Content-Disposition\": `attachment; filename*=UTF-8''${\n encodeURIComponent(data.filename)\n }`,\n \"Content-Type\": contentType,\n \"Accept-Ranges\": \"bytes\",\n \"Connection\": \"keep-alive\",\n });\n\n if (rangeHeader) {\n responseHeaders.set(\n \"Content-Range\",\n `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`,\n );\n responseHeaders.set(\n \"Content-Length\",\n (resolvedEnd - rangeStart + 1).toString(),\n );\n } else {\n responseHeaders.set(\"Content-Length\", totalSize.toString());\n }\n\n if (req.method === \"HEAD\") {\n return new Response(null, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n const { readable, writable } = new TransformStream();\n const writer = writable.getWriter();\n\n (async () => {\n try {\n const CONCURRENCY = 20;\n for (let i = 0; i < segmentsToFetch.length; i += CONCURRENCY) {\n const batch = segmentsToFetch.slice(i, i + CONCURRENCY);\n const chunkDataArr = await fetchSegmentsConcurrently(\n batch,\n CONCURRENCY,\n );\n\n for (let j = 0; j < batch.length; j++) {\n let outData = chunkDataArr[j];\n const originalIndex = segmentIndices[i + j];\n\n if (isFlac) {\n if (originalIndex === 0) {\n const dfLa = extractBoxData(outData, \"dfLa\");\n if (dfLa && dfLa.length > 4) {\n const metaBlock = dfLa.slice(4);\n metaBlock[0] |= 0x80;\n const flacMagic = textEnc.encode(\"fLaC\");\n const newOut = new Uint8Array(\n flacMagic.length + metaBlock.length,\n );\n newOut.set(flacMagic);\n newOut.set(metaBlock, flacMagic.length);\n outData = newOut;\n } else outData = new Uint8Array(0);\n } else {\n outData = extractBoxData(outData, \"mdat\") ||\n new Uint8Array(0);\n }\n }\n\n const currentSegOffset = segmentOffsets[i + j];\n const outSize = outData.length;\n const startInChunk = Math.max(0, rangeStart - currentSegOffset);\n const currentEndOffset = currentSegOffset + outSize;\n\n if (startInChunk > 0 || currentEndOffset > resolvedEnd + 1) {\n const endInChunk = Math.min(\n outSize,\n outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)),\n );\n outData = outData.slice(startInChunk, endInChunk);\n }\n\n if (outData.length > 0) await writer.write(outData);\n }\n }\n } catch (e) {\n console.error(`[WebSeed] Stream Error:`, e.message);\n } finally {\n writer.close();\n }\n })();\n\n return new Response(readable, {\n status: rangeHeader ? 206 : 200,\n headers: responseHeaders,\n });\n }\n\n return new Response(\"NullBeat Val.town Proxy Online\", { status: 200 });\n } catch (err) {\n console.error(\"Unhandled server error:\", err.message);\n return new Response(\n JSON.stringify({\n error: \"Internal Server Error\",\n message: err.message,\n }),\n { status: 500, headers: corsHeaders() },\n );\n }\n}","createdAt",["D",1787723404918],"branchVersion","branchId","bb96142c-a8ee-4480-9f21-d8c8176be5d8","id","40158b88-3bf8-4ab2-9767-3c8adf980aa8","nullbeatStreamProxy",["D",1787588563935],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","5f176305-db17-4c4c-9e0d-a3887128495f","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1f78-ba2f-754d-b681-41787f593d34","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",67,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","thevolecitor","handle","displayName","The Volecitor","avatar","https://lh3.googleusercontent.com/a/ACg8ocJDSk1v8A-JR-j9BixGbkpDFxDEwDLvb547SIx-wABVv2vdTw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_27":134},"58cc5f5e-344a-4198-82aa-a246606a5425","parentId","latest",["D",1787723404918],39,"label","nullbeat",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",4,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":148,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_149":150,"_27":151},["D",1787723404918],"children",[],[28],["D",1787588563935],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":57,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":85,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

Diff · v40