([^<]+)<\\/title>/);\n if (match) {\n let raw = match[1].replace(/ on TIDAL$/, '').trim();\n const byIdx = raw.lastIndexOf(' by ');\n if (byIdx > -1) {\n let tName = raw.substring(0, byIdx).trim();\n let aName = raw.substring(byIdx + 4).trim();\n tName = tName.replace(/"/g, '\"').replace(/&/g, '&').replace(/'/g, \"'\");\n aName = aName.replace(/"/g, '\"').replace(/&/g, '&').replace(/'/g, \"'\");\n return { trackName: tName, artistName: aName };\n } else {\n return { trackName: raw.trim(), artistName: 'Unknown Artist' };\n }\n }\n }\n throw new Error('Tidal HTML metadata failed');\n })());\n\n let artistName = 'Unknown Artist';\n let trackName = 'Unknown Track';\n\n try {\n const result = await Promise.any(promises);\n trackName = result.trackName;\n artistName = result.artistName;\n } catch (e) { }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, '').trim() || 'Track';\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, '').trim() || 'Artist';\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Main Handler ────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === 'OPTIONS') return new Response(null, { status: 204, headers: corsHeaders() });\n\n const url = new URL(req.url);\n const pathParts = url.pathname.split('/').filter(Boolean);\n const valBaseUrl = url.origin;\n\n let isStream = false;\n let isDownload = false;\n let trackId = '';\n let service = '';\n let apiKey = '';\n let quality = 'MAX';\n let downloadUuid = '';\n\n // Route: /stream/{trackId}/(oc|rd)/{apiKey}[/{quality}]\n if (pathParts[0] === 'stream' && pathParts[1] && (pathParts[2] === 'oc' || pathParts[2] === 'rd') && pathParts[3]) {\n isStream = true;\n trackId = pathParts[1].replace(/^track:/, '').replace(/\\.json$/, '');\n service = pathParts[2];\n apiKey = pathParts[3];\n if (pathParts[4]) quality = pathParts[4].toUpperCase();\n } else if (pathParts[0] === 'download' && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n }\n\n if (isDownload) {\n let data;\n try { data = JSON.parse(b64Decode(downloadUuid)); }\n catch { return new Response('Invalid UUID', { status: 400 }); }\n\n if (!data.isDash) return new Response(null, { status: 302, headers: { Location: data.url } });\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 try {\n dashXml = await getCachedDashXml(manifestUrl);\n } catch (e) {\n return new Response('Failed to fetch DASH XML', { status: 502 });\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf('?');\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(0, manifestUrlBase.lastIndexOf('/') + 1);\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) manifestUrlBase = baseMatch[1].trim().replace(/&/g, '&');\n\n let parsingContext = dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] || dashXml;\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 ? mediaMatch[1].replace(/&/g, '&') : '';\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++) segments.push(mediaTemplate.replace('$Number$', startNumber + i));\n }\n\n const uniqueSegments = [...new Set(segments)].map(seg => seg.startsWith('http') ? seg : new URL(seg, manifestUrlBase).toString());\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map(s => { const cur = current; current += s; return cur; });\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('?')) segUrl += manifestUrl.substring(manifestUrl.indexOf('?'));\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''${encodeURIComponent(data.filename)}`,\n 'Content-Type': contentType,\n 'Accept-Ranges': 'bytes',\n 'Connection': 'keep-alive'\n });\n\n if (rangeHeader) {\n responseHeaders.set('Content-Range', `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`);\n responseHeaders.set('Content-Length', (resolvedEnd - rangeStart + 1).toString());\n } else {\n responseHeaders.set('Content-Length', totalSize.toString());\n }\n\n if (req.method === 'HEAD') return new Response(null, { status: rangeHeader ? 206 : 200, headers: responseHeaders });\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(batch, CONCURRENCY);\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(flacMagic.length + metaBlock.length);\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') || 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(outSize, outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)));\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, { status: rangeHeader ? 206 : 200, headers: responseHeaders });\n }\n\n if (isStream) {\n const startTime = performance.now();\n const serviceName = service === 'oc' ? 'Offcloud' : 'RealDebrid';\n console.log(`[${serviceName} Stream] Requesting track ${trackId}`);\n\n const tMetaStart = performance.now();\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n const tMetaDuration = Math.round(performance.now() - tMetaStart);\n\n if (service === 'oc') {\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', ext: 'flac' },\n LOSSLESS: { label: 'HiFi CD', 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 candidates = [];\n\n const tHashStart = performance.now();\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const sha1 = await sha1Hash(fn);\n candidates.push({ formatKey, filename: fn, hash: sha1, label: info.label, ext: info.ext });\n }\n const tHashDuration = Math.round(performance.now() - tHashStart);\n\n let finalCdnUrl = null;\n let selectedFormat = candidates[0];\n\n const tCacheStart = performance.now();\n for (const candidate of candidates) {\n const magnetUrl = `magnet:?xt=urn:btih:${candidate.hash}`;\n try {\n const cacheRes = await fetch('https://offcloud.com/api/cache/download', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/json'\n },\n body: JSON.stringify({ url: magnetUrl })\n });\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return jsonResp({ error: 'Invalid Offcloud API Key' }, 401);\n }\n\n if (cacheRes.ok) {\n const files = await cacheRes.json();\n if (Array.isArray(files) && files.length > 0 && files[0].url) {\n finalCdnUrl = files[0].url;\n selectedFormat = candidate;\n console.log(`[Offcloud] Hit cache for ${candidate.filename}`);\n break;\n }\n }\n } catch (err) {\n console.error(`[Offcloud] Cache check failed for ${candidate.hash}:`, err.message);\n }\n }\n const tCacheDuration = Math.round(performance.now() - tCacheStart);\n\n let tDashDuration = 0, tCloudAddDuration = 0, tPollDuration = 0, tExploreDuration = 0;\n\n if (!finalCdnUrl) {\n const tDashStart = performance.now();\n let formats = (quality === 'LOSSLESS') ? 'FLAC' : 'FLAC_HIRES';\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } catch (e) {\n if (formats !== 'FLAC') {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } else throw e;\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n const uri = attributes?.uri;\n if (!uri) throw new Error(\"Missing URI in manifest response from HiFi API\");\n\n const returnedFormats = Array.isArray(attributes?.formats) ? attributes.formats : [];\n let actualQuality = 'FLAC';\n if (returnedFormats.includes('FLAC_HIRES')) actualQuality = 'FLAC_HIRES';\n else if (returnedFormats.includes('FLAC')) actualQuality = 'FLAC';\n\n const finalQualityLabel = actualQuality === 'FLAC_HIRES' ? 'Hi-Res' : (actualQuality.includes('FLAC') ? 'HiFi CD' : actualQuality);\n const isFlac = actualQuality.includes('FLAC');\n const ext = isFlac ? 'flac' : 'm4a';\n\n const filename = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n const streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const torrentBuffer = await generateTorrentBuffer({ streamData, filename }, valBaseUrl);\n tDashDuration = Math.round(performance.now() - tDashStart);\n\n const formData = new FormData();\n formData.append('file', new Blob([torrentBuffer], { type: 'application/x-bittorrent' }), `${filename}.torrent`);\n\n const tAddStart = performance.now();\n let requestId = null;\n try {\n const addRes = await fetch('https://offcloud.com/api/cloud', {\n method: 'POST',\n headers: { 'Authorization': `Bearer ${apiKey}` },\n body: formData\n });\n const resText = await addRes.text();\n if (addRes.ok) {\n try {\n const addData = JSON.parse(resText);\n requestId = addData.requestId || addData.id || null;\n } catch (err) { }\n } else {\n console.error(`[Offcloud] CloudAdd Failed HTTP ${addRes.status}: ${resText}`);\n }\n } catch (err) {\n console.error('[Offcloud] Cloud submit error:', err.message);\n }\n tCloudAddDuration = Math.round(performance.now() - tAddStart);\n\n if (requestId) {\n const tPollStart = performance.now();\n let isDownloaded = false;\n let attempts = 0;\n while (!isDownloaded && attempts < 15) {\n await new Promise(resolve => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch('https://offcloud.com/api/cloud/status', {\n method: 'POST',\n headers: { 'Authorization': `Bearer ${apiKey}`, 'Content-Type': 'application/json' },\n body: JSON.stringify({ requestId })\n });\n if (statusRes.ok) {\n const statusJson = await statusRes.json();\n const state = statusJson.status?.status;\n if (state === 'downloaded') isDownloaded = true;\n else if (state === 'error') break;\n }\n } catch (e) { }\n attempts++;\n }\n tPollDuration = Math.round(performance.now() - tPollStart);\n\n if (isDownloaded) {\n const tExploreStart = performance.now();\n try {\n const exploreRes = await fetch(`https://offcloud.com/api/cloud/explore/${requestId}?format=detailed`, {\n headers: { 'Authorization': `Bearer ${apiKey}` }\n });\n if (exploreRes.ok) {\n const exploreData = await exploreRes.json();\n if (exploreData.files && exploreData.files.length > 0) {\n finalCdnUrl = exploreData.files[0].url;\n }\n }\n } catch (e) { }\n tExploreDuration = Math.round(performance.now() - tExploreStart);\n }\n }\n }\n\n const totalDuration = Math.round(performance.now() - startTime);\n console.log(`[OFFCLOUD TIMING] Track ${trackId} Total: ${totalDuration}ms | Meta: ${tMetaDuration}ms | HashGen: ${tHashDuration}ms | CacheCheck: ${tCacheDuration}ms | DashGen: ${tDashDuration}ms | CloudAdd: ${tCloudAddDuration}ms | Poll: ${tPollDuration}ms | Explore: ${tExploreDuration}ms`);\n\n if (!finalCdnUrl) {\n return jsonResp({ error: 'Track not available on Offcloud cache yet.' }, 503);\n }\n return jsonResp({ url: finalCdnUrl, format: selectedFormat.ext, quality: selectedFormat.label, expiresAt: Math.floor(Date.now() / 1000) + 86400 });\n\n } else if (service === 'rd') {\n\n let tDashDuration = 0, tAddDuration = 0, tSelectDuration = 0, tPollDuration = 0, tUnrestrictDuration = 0;\n\n const tDashStart = performance.now();\n let formats = (quality === 'LOSSLESS') ? 'FLAC' : 'FLAC_HIRES';\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } catch (e) {\n if (formats !== 'FLAC') {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } else throw e;\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n const uri = attributes?.uri;\n if (!uri) throw new Error(\"Missing URI in manifest response from HiFi API\");\n\n const returnedFormats = Array.isArray(attributes?.formats) ? attributes.formats : [];\n let actualQuality = 'FLAC';\n if (returnedFormats.includes('FLAC_HIRES')) actualQuality = 'FLAC_HIRES';\n else if (returnedFormats.includes('FLAC')) actualQuality = 'FLAC';\n\n const finalQualityLabel = actualQuality === 'FLAC_HIRES' ? 'Hi-Res' : (actualQuality.includes('FLAC') ? 'HiFi CD' : actualQuality);\n const isFlac = actualQuality.includes('FLAC');\n const ext = isFlac ? 'flac' : 'm4a';\n\n const filename = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n const streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const torrentBuffer = await generateTorrentBuffer({ streamData, filename }, valBaseUrl);\n tDashDuration = Math.round(performance.now() - tDashStart);\n\n let finalCdnUrl = null;\n let torrentId = null;\n\n const tAddStart = performance.now();\n try {\n const addRes = await fetch('https://api.real-debrid.com/rest/1.0/torrents/addTorrent', {\n method: 'PUT',\n headers: { 'Authorization': `Bearer ${apiKey}` },\n body: torrentBuffer\n });\n if (addRes.ok) {\n const addData = await addRes.json();\n torrentId = addData.id;\n } else {\n console.error('[RealDebrid] Add HTTP Status:', addRes.status, await addRes.text());\n }\n } catch (err) {\n console.error('[RealDebrid] addTorrent error:', err.message);\n }\n tAddDuration = Math.round(performance.now() - tAddStart);\n\n if (torrentId) {\n const tSelectStart = performance.now();\n try {\n await fetch(`https://api.real-debrid.com/rest/1.0/torrents/selectFiles/${torrentId}`, {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/x-www-form-urlencoded'\n },\n body: 'files=all'\n });\n } catch (e) { }\n tSelectDuration = Math.round(performance.now() - tSelectStart);\n\n const tPollStart = performance.now();\n let isDownloaded = false;\n let linkToUnrestrict = null;\n let attempts = 0;\n\n while (!isDownloaded && attempts < 15) {\n await new Promise(resolve => setTimeout(resolve, 2000));\n try {\n const infoRes = await fetch(`https://api.real-debrid.com/rest/1.0/torrents/info/${torrentId}`, {\n headers: { 'Authorization': `Bearer ${apiKey}` }\n });\n if (infoRes.ok) {\n const infoJson = await infoRes.json();\n if (infoJson.status === 'downloaded' && infoJson.links && infoJson.links.length > 0) {\n isDownloaded = true;\n linkToUnrestrict = infoJson.links[0];\n } else if (infoJson.status === 'error' || infoJson.status === 'dead' || infoJson.status === 'magnet_error') {\n console.error('[RealDebrid] Torrent failed with status:', infoJson.status);\n break;\n }\n }\n } catch (e) { }\n attempts++;\n }\n tPollDuration = Math.round(performance.now() - tPollStart);\n\n if (linkToUnrestrict) {\n const tUnrestrictStart = performance.now();\n try {\n const unRes = await fetch('https://api.real-debrid.com/rest/1.0/unrestrict/link', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/x-www-form-urlencoded'\n },\n body: `link=${encodeURIComponent(linkToUnrestrict)}`\n });\n if (unRes.ok) {\n const unJson = await unRes.json();\n finalCdnUrl = unJson.download;\n } else {\n console.error('[RealDebrid] unrestrict error:', unRes.status, await unRes.text());\n }\n } catch (e) { }\n tUnrestrictDuration = Math.round(performance.now() - tUnrestrictStart);\n }\n }\n\n const totalDuration = Math.round(performance.now() - startTime);\n console.log(`[RD TIMING] Track ${trackId} Total: ${totalDuration}ms | Meta: ${tMetaDuration}ms | DashGen: ${tDashDuration}ms | Add: ${tAddDuration}ms | Select: ${tSelectDuration}ms | Poll: ${tPollDuration}ms | Unrestrict: ${tUnrestrictDuration}ms`);\n\n if (!finalCdnUrl) {\n return jsonResp({ error: 'Failed to process and unrestrict torrent on Real-Debrid.' }, 503);\n }\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: Math.floor(Date.now() / 1000) + 86400\n });\n }\n }\n\n return new Response(\"NullBeat Unified Debrid Proxy Online\", { status: 200 });\n\n } catch (err) {\n console.error('Unhandled unified backend error:', err.message);\n return jsonResp({ error: 'Internal Server Error', message: err.message }, 500);\n }\n}","deleted",false,"label",[14],"66e46240-e929-4b11-98f0-186884b4f6ff",["D",1787824538014],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","5f176305-db17-4c4c-9e0d-a3887128495f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1f78-ba2f-754d-b681-41787f593d34","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_101":97},"org",{"_9":10,"_94":95,"_96":97,"_55":56,"_98":99,"_100":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","The Volecitor","avatar","https://lh3.googleusercontent.com/a/ACg8ocJDSk1v8A-JR-j9BixGbkpDFxDEwDLvb547SIx-wABVv2vdTw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_135":136,"_137":138,"_139":140,"_141":42,"_142":42,"_143":42,"_144":32,"_145":-5,"_146":-7,"_147":-7,"_148":62,"_149":42,"_150":42,"_151":-5,"_152":42,"_153":42,"_154":42,"_155":-5},"ENV",{"_106":107,"_108":109,"_110":85,"_111":112,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134},"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","orgs",[],"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},"actionData","errors","root",{"_102":103,"_104":105},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","thevolecitor","name","offlcoudbenchmark","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/thevolecitor/offlcoudbenchmark/code/main.ts","extension","id","131193b9-131e-4061-9082-f1ddde3cba2f","fileId","749ccf0a-a1fd-11f1-8094-1607ee4eb77e","parentId","branchId","10b710d5-98c7-425c-97bf-68a18bc35965","branchVersion",11,"latest",true,"createdAt",["D",1787834358528],"version",10,"fileType","http","content","// ─── Unified Debrid Backend Proxy (Offcloud & Real-Debrid) ────────────────────\n// Routes: \n// - /stream/{trackId}/oc/{apiKey}[/{quality}] -> Offcloud Proxy\n// - /stream/{trackId}/rd/{apiKey}[/{quality}] -> Real-Debrid Proxy\n// - /download/{uuid} -> DASH-to-Torrent WebSeed Chunk Streamer\n\nfunction cleanUrlString(str) {\n if (!str) return '';\n return str.trim().replace(/^[\"']|[\"']$/g, '').trim();\n}\n\nconst DEFAULT_HIFI_BACKENDS = [\n 'https://hifi-api.thevolecitor.qzz.io/',\n 'https://lol.samidy.workers.dev/',\n];\n\nconst dashXmlCache = new Map(); // manifestUrl -> { timestamp, xml }\n\nasync function getCachedDashXml(url) {\n if (url.startsWith('data:')) return b64Decode(url.split(',')[1]);\n const cached = dashXmlCache.get(url);\n if (cached && Date.now() - cached.timestamp < 300000) return cached.xml; // 5 min cache\n\n const xmlRes = await fetch(url);\n if (!xmlRes.ok) throw new Error(`Failed to fetch DASH XML: ${xmlRes.status}`);\n const dashXml = await xmlRes.text();\n\n dashXmlCache.set(url, { timestamp: Date.now(), xml: dashXml });\n if (dashXmlCache.size > 500) {\n const now = Date.now();\n for (const [k, v] of dashXmlCache.entries()) {\n if (now - v.timestamp > 300000) dashXmlCache.delete(k);\n }\n }\n return dashXml;\n}\n\nfunction getHifiBackends() { return DEFAULT_HIFI_BACKENDS; }\nfunction getHifiSearchBackends() { return DEFAULT_HIFI_BACKENDS; }\n\nasync function fetchHifiApi(path, options = {}, isSearch = false) {\n const sourceList = isSearch ? getHifiSearchBackends() : getHifiBackends();\n const backends = [...sourceList].sort(() => Math.random() - 0.5);\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, { ...options, signal: AbortSignal.timeout(8000) });\n if (res.ok) return res;\n lastError = new Error(`HTTP ${res.status} from ${base}`);\n } catch (e) {\n lastError = e;\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\nfunction extractBoxData(buffer, boxType) {\n let offset = 0;\n while (offset + 8 <= buffer.length) {\n const size = new DataView(buffer.buffer, buffer.byteOffset, buffer.byteLength).getUint32(offset, false);\n if (size < 8) break;\n const type = new TextDecoder().decode(buffer.subarray(offset + 4, offset + 8));\n if (type === boxType) return buffer.subarray(offset + 8, offset + size);\n if (['moov', 'trak', 'mdia', 'minf', 'stbl', 'stsd', 'fLaC'].includes(type)) {\n let innerStart = offset + 8;\n if (type === 'stsd') innerStart += 8;\n if (type === 'fLaC') innerStart += 28;\n if (innerStart < offset + size) {\n const found = extractBoxData(buffer.subarray(innerStart, offset + size), 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}\n\nfunction bencodeString(strOrArr) {\n const buf = typeof strOrArr === 'string' ? textEnc.encode(strOrArr) : strOrArr;\n return concatU8([textEnc.encode(buf.length + ':'), buf]);\n}\nfunction bencodeInt(n) { return textEnc.encode(`i${n}e`); }\nfunction bencodeList(list) { return concatU8([textEnc.encode('l'), ...list, textEnc.encode('e')]); }\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\nasync function fetchSegmentsConcurrently(urls, concurrency = 20) {\n const results = new Array(urls.length);\n const queue = urls.map((url, i) => ({ url, i }));\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 await Promise.all(workers);\n return results;\n}\n\n// ─── WebSeed Torrent Generator ───────────────────────────────────────────────\n\nasync function generateTorrentBuffer(info, valBaseUrl) {\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(data.subarray(valCursor, valCursor + dataToCopy), currentPieceCursor);\n currentPieceCursor += dataToCopy;\n valCursor += dataToCopy;\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 let manifestUrl = streamData.url;\n let dashXml = await getCachedDashXml(manifestUrl);\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf('?');\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(0, manifestUrlBase.lastIndexOf('/') + 1);\n\n const baseMatch = dashXml.match(/([^<]+)<\\/BaseURL>/);\n if (baseMatch) {\n manifestUrlBase = baseMatch[1].trim().replace(/&/g, '&');\n if (!manifestUrlBase.startsWith('http')) manifestUrlBase = new URL(manifestUrlBase, manifestUrl).toString();\n }\n\n let parsingContext = dashXml;\n const templateMatch = dashXml.match(//);\n if (templateMatch) parsingContext = templateMatch[0];\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 ? mediaMatch[1].replace(/&/g, '&') : '';\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++) segments.push(mediaTemplate.replace('$Number$', startNumber + i));\n }\n\n const uniqueSegments = [...new Set(segments)].map(seg => {\n try { return seg.startsWith('http') ? seg : new URL(seg, manifestUrlBase).toString(); }\n catch { return seg; }\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('SHA-1', currentPiece.slice(0, currentPieceCursor));\n pieceHashes.push(new Uint8Array(hashBuffer));\n }\n\n const concatenatedHashes = concatU8(pieceHashes);\n const payloadStr = JSON.stringify({ url: streamData.url, isDash: streamData.isDash, filename, sizes });\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 return bencodeDict({\n encoding: bencodeString('UTF-8'),\n info: bencodeDict(infoTorrent),\n 'url-list': bencodeList(webseedUrls.map(u => bencodeString(u)))\n });\n}\n\nasync function sha1Hash(text) {\n const msgUint8 = new TextEncoder().encode(text);\n const hashBuffer = await crypto.subtle.digest('SHA-1', msgUint8);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map(b => b.toString(16).padStart(2, '0')).join('');\n}\n\nlet tidalAccessToken = null;\nlet tidalTokenExpiresAt = 0;\n\nasync function getTidalAccessToken() {\n const clientId = 'L2H5PcaE0cPHJyXK';\n const clientSecret = '7V46vpuRSpZ6wmY4aMhFIYemoU255eBbW3fZrsuJiOI=';\n if (!clientId || !clientSecret) return null;\n\n if (tidalAccessToken && Date.now() < tidalTokenExpiresAt) {\n return tidalAccessToken;\n }\n\n const credentials = btoa(`${clientId}:${clientSecret}`);\n try {\n const res = await fetch('https://auth.tidal.com/v1/oauth2/token', {\n method: 'POST',\n headers: {\n 'Authorization': `Basic ${credentials}`,\n 'Content-Type': 'application/x-www-form-urlencoded'\n },\n body: 'grant_type=client_credentials'\n });\n if (res.ok) {\n const data = await res.json();\n tidalAccessToken = data.access_token;\n tidalTokenExpiresAt = Date.now() + (data.expires_in * 1000) - 60000;\n return tidalAccessToken;\n }\n } catch (e) { }\n return null;\n}\n\nasync function getTrackMeta(trackId) {\n const promises = [];\n\n // 1. Official Tidal API\n promises.push((async () => {\n const token = await getTidalAccessToken();\n if (!token) throw new Error('No Tidal credentials');\n\n const res = await fetch(`https://openapi.tidal.com/v2/tracks/${trackId}?countryCode=US&include=artists`, {\n headers: {\n 'Authorization': `Bearer ${token}`,\n 'accept': 'application/vnd.api+json'\n },\n signal: AbortSignal.timeout(3000)\n });\n if (!res.ok) throw new Error('Tidal API error');\n\n const data = await res.json();\n const attrs = data?.data?.attributes || {};\n if (attrs.title) {\n let aName = 'Unknown Artist';\n if (Array.isArray(data.included)) {\n const artist = data.included.find(inc => inc.type === 'artists' || inc.type === 'artist');\n if (artist && artist.attributes && artist.attributes.name) {\n aName = artist.attributes.name;\n }\n }\n return { trackName: attrs.title, artistName: aName };\n }\n throw new Error('Invalid Tidal API response');\n })());\n\n // 2. HiFi API Lookup\n promises.push((async () => {\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 const tName = item.title;\n const aName = item.artist?.name || item.artists?.find(a => a?.type === 'MAIN')?.name || item.artists?.[0]?.name || 'Unknown Artist';\n return { trackName: tName, artistName: aName };\n }\n throw new Error('HiFi API metadata invalid');\n })());\n\n // 3. Tidal HTML Lookup\n promises.push((async () => {\n const tRes = await fetch(`https://tidal.com/browse/track/${trackId}`, {\n headers: { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36' },\n signal: AbortSignal.timeout(3000)\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 let tName = raw.substring(0, byIdx).trim();\n let aName = raw.substring(byIdx + 4).trim();\n tName = tName.replace(/"/g, '\"').replace(/&/g, '&').replace(/'/g, \"'\");\n aName = aName.replace(/"/g, '\"').replace(/&/g, '&').replace(/'/g, \"'\");\n return { trackName: tName, artistName: aName };\n } else {\n return { trackName: raw.trim(), artistName: 'Unknown Artist' };\n }\n }\n }\n throw new Error('Tidal HTML metadata failed');\n })());\n\n let artistName = 'Unknown Artist';\n let trackName = 'Unknown Track';\n\n try {\n const result = await Promise.any(promises);\n trackName = result.trackName;\n artistName = result.artistName;\n } catch (e) { }\n\n const cleanTrackName = trackName.replace(/[\\/\\\\?%*:|\"<>]/g, '').trim() || 'Track';\n const cleanArtistName = artistName.replace(/[\\/\\\\?%*:|\"<>]/g, '').trim() || 'Artist';\n return { cleanTrackName, cleanArtistName };\n}\n\n// ─── Main Handler ────────────────────────────────────────────────────────────\n\nexport default async function (req) {\n try {\n if (req.method === 'OPTIONS') return new Response(null, { status: 204, headers: corsHeaders() });\n\n const url = new URL(req.url);\n const pathParts = url.pathname.split('/').filter(Boolean);\n const valBaseUrl = url.origin;\n\n let isStream = false;\n let isDownload = false;\n let trackId = '';\n let service = '';\n let apiKey = '';\n let quality = 'MAX';\n let downloadUuid = '';\n\n // Route: /stream/{trackId}/(oc|rd)/{apiKey}[/{quality}]\n if (pathParts[0] === 'stream' && pathParts[1] && (pathParts[2] === 'oc' || pathParts[2] === 'rd') && pathParts[3]) {\n isStream = true;\n trackId = pathParts[1].replace(/^track:/, '').replace(/\\.json$/, '');\n service = pathParts[2];\n apiKey = pathParts[3];\n if (pathParts[4]) quality = pathParts[4].toUpperCase();\n } else if (pathParts[0] === 'download' && pathParts[1]) {\n isDownload = true;\n downloadUuid = pathParts[1];\n }\n\n if (isDownload) {\n let data;\n try { data = JSON.parse(b64Decode(downloadUuid)); }\n catch { return new Response('Invalid UUID', { status: 400 }); }\n\n if (!data.isDash) return new Response(null, { status: 302, headers: { Location: data.url } });\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 try {\n dashXml = await getCachedDashXml(manifestUrl);\n } catch (e) {\n return new Response('Failed to fetch DASH XML', { status: 502 });\n }\n\n let manifestUrlBase = manifestUrl;\n const qIndex = manifestUrlBase.indexOf('?');\n if (qIndex > -1) manifestUrlBase = manifestUrlBase.substring(0, qIndex);\n manifestUrlBase = manifestUrlBase.substring(0, manifestUrlBase.lastIndexOf('/') + 1);\n\n const baseMatch = dashXml.match(/<BaseURL>([^<]+)<\\/BaseURL>/);\n if (baseMatch) manifestUrlBase = baseMatch[1].trim().replace(/&/g, '&');\n\n let parsingContext = dashXml.match(/<SegmentTemplate[\\s\\S]*?<\\/SegmentTemplate>/)?.[0] || dashXml;\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 ? mediaMatch[1].replace(/&/g, '&') : '';\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++) segments.push(mediaTemplate.replace('$Number$', startNumber + i));\n }\n\n const uniqueSegments = [...new Set(segments)].map(seg => seg.startsWith('http') ? seg : new URL(seg, manifestUrlBase).toString());\n\n let current = 0;\n let segmentOffsetsMap = data.sizes.map(s => { const cur = current; current += s; return cur; });\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('?')) segUrl += manifestUrl.substring(manifestUrl.indexOf('?'));\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''${encodeURIComponent(data.filename)}`,\n 'Content-Type': contentType,\n 'Accept-Ranges': 'bytes',\n 'Connection': 'keep-alive'\n });\n\n if (rangeHeader) {\n responseHeaders.set('Content-Range', `bytes ${rangeStart}-${resolvedEnd}/${totalSize}`);\n responseHeaders.set('Content-Length', (resolvedEnd - rangeStart + 1).toString());\n } else {\n responseHeaders.set('Content-Length', totalSize.toString());\n }\n\n if (req.method === 'HEAD') return new Response(null, { status: rangeHeader ? 206 : 200, headers: responseHeaders });\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(batch, CONCURRENCY);\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(flacMagic.length + metaBlock.length);\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') || 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(outSize, outSize - Math.max(0, currentEndOffset - (resolvedEnd + 1)));\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, { status: rangeHeader ? 206 : 200, headers: responseHeaders });\n }\n\n if (isStream) {\n const startTime = performance.now();\n const serviceName = service === 'oc' ? 'Offcloud' : 'RealDebrid';\n console.log(`[${serviceName} Stream] Requesting track ${trackId}`);\n\n const tMetaStart = performance.now();\n const { cleanTrackName, cleanArtistName } = await getTrackMeta(trackId);\n const tMetaDuration = Math.round(performance.now() - tMetaStart);\n\n if (service === 'oc') {\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', ext: 'flac' },\n LOSSLESS: { label: 'HiFi CD', 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 candidates = [];\n\n const tHashStart = performance.now();\n for (const formatKey of chain) {\n const info = metaMap[formatKey];\n if (!info) continue;\n const fn = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${info.label}].${info.ext}`;\n const sha1 = await sha1Hash(fn);\n candidates.push({ formatKey, filename: fn, hash: sha1, label: info.label, ext: info.ext });\n }\n const tHashDuration = Math.round(performance.now() - tHashStart);\n\n let finalCdnUrl = null;\n let selectedFormat = candidates[0];\n\n const tCacheStart = performance.now();\n for (const candidate of candidates) {\n const magnetUrl = `magnet:?xt=urn:btih:${candidate.hash}`;\n try {\n const cacheRes = await fetch('https://offcloud.com/api/cache/download', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/json'\n },\n body: JSON.stringify({ url: magnetUrl })\n });\n\n if (cacheRes.status === 401 || cacheRes.status === 403) {\n return jsonResp({ error: 'Invalid Offcloud API Key' }, 401);\n }\n\n if (cacheRes.ok) {\n const files = await cacheRes.json();\n if (Array.isArray(files) && files.length > 0 && files[0].url) {\n finalCdnUrl = files[0].url;\n selectedFormat = candidate;\n console.log(`[Offcloud] Hit cache for ${candidate.filename}`);\n break;\n }\n }\n } catch (err) {\n console.error(`[Offcloud] Cache check failed for ${candidate.hash}:`, err.message);\n }\n }\n const tCacheDuration = Math.round(performance.now() - tCacheStart);\n\n let tDashDuration = 0, tCloudAddDuration = 0, tPollDuration = 0, tExploreDuration = 0;\n\n if (!finalCdnUrl) {\n const tDashStart = performance.now();\n let formats = (quality === 'LOSSLESS') ? 'FLAC' : 'FLAC_HIRES';\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } catch (e) {\n if (formats !== 'FLAC') {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } else throw e;\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n const uri = attributes?.uri;\n if (!uri) throw new Error(\"Missing URI in manifest response from HiFi API\");\n\n const returnedFormats = Array.isArray(attributes?.formats) ? attributes.formats : [];\n let actualQuality = 'FLAC';\n if (returnedFormats.includes('FLAC_HIRES')) actualQuality = 'FLAC_HIRES';\n else if (returnedFormats.includes('FLAC')) actualQuality = 'FLAC';\n\n const finalQualityLabel = actualQuality === 'FLAC_HIRES' ? 'Hi-Res' : (actualQuality.includes('FLAC') ? 'HiFi CD' : actualQuality);\n const isFlac = actualQuality.includes('FLAC');\n const ext = isFlac ? 'flac' : 'm4a';\n\n const filename = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n const streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const torrentBuffer = await generateTorrentBuffer({ streamData, filename }, valBaseUrl);\n tDashDuration = Math.round(performance.now() - tDashStart);\n\n const formData = new FormData();\n formData.append('file', new Blob([torrentBuffer], { type: 'application/x-bittorrent' }), `${filename}.torrent`);\n\n const tAddStart = performance.now();\n let requestId = null;\n try {\n const addRes = await fetch('https://offcloud.com/api/cloud', {\n method: 'POST',\n headers: { 'Authorization': `Bearer ${apiKey}` },\n body: formData\n });\n const resText = await addRes.text();\n if (addRes.ok) {\n try {\n const addData = JSON.parse(resText);\n requestId = addData.requestId || addData.id || null;\n } catch (err) { }\n } else {\n console.error(`[Offcloud] CloudAdd Failed HTTP ${addRes.status}: ${resText}`);\n }\n } catch (err) {\n console.error('[Offcloud] Cloud submit error:', err.message);\n }\n tCloudAddDuration = Math.round(performance.now() - tAddStart);\n\n if (requestId) {\n const tPollStart = performance.now();\n let isDownloaded = false;\n let attempts = 0;\n while (!isDownloaded && attempts < 15) {\n await new Promise(resolve => setTimeout(resolve, 2000));\n try {\n const statusRes = await fetch('https://offcloud.com/api/cloud/status', {\n method: 'POST',\n headers: { 'Authorization': `Bearer ${apiKey}`, 'Content-Type': 'application/json' },\n body: JSON.stringify({ requestId })\n });\n if (statusRes.ok) {\n const statusJson = await statusRes.json();\n const state = statusJson.status?.status;\n if (state === 'downloaded') isDownloaded = true;\n else if (state === 'error') break;\n }\n } catch (e) { }\n attempts++;\n }\n tPollDuration = Math.round(performance.now() - tPollStart);\n\n if (isDownloaded) {\n const tExploreStart = performance.now();\n try {\n const exploreRes = await fetch(`https://offcloud.com/api/cloud/explore/${requestId}?format=detailed`, {\n headers: { 'Authorization': `Bearer ${apiKey}` }\n });\n if (exploreRes.ok) {\n const exploreData = await exploreRes.json();\n if (exploreData.files && exploreData.files.length > 0) {\n finalCdnUrl = exploreData.files[0].url;\n }\n }\n } catch (e) { }\n tExploreDuration = Math.round(performance.now() - tExploreStart);\n }\n }\n }\n\n const totalDuration = Math.round(performance.now() - startTime);\n console.log(`[OFFCLOUD TIMING] Track ${trackId} Total: ${totalDuration}ms | Meta: ${tMetaDuration}ms | HashGen: ${tHashDuration}ms | CacheCheck: ${tCacheDuration}ms | DashGen: ${tDashDuration}ms | CloudAdd: ${tCloudAddDuration}ms | Poll: ${tPollDuration}ms | Explore: ${tExploreDuration}ms`);\n\n if (!finalCdnUrl) {\n return jsonResp({ error: 'Track not available on Offcloud cache yet.' }, 503);\n }\n return jsonResp({ url: finalCdnUrl, format: selectedFormat.ext, quality: selectedFormat.label, expiresAt: Math.floor(Date.now() / 1000) + 86400 });\n\n } else if (service === 'rd') {\n\n let tDashDuration = 0, tAddDuration = 0, tSelectDuration = 0, tPollDuration = 0, tUnrestrictDuration = 0;\n\n const tDashStart = performance.now();\n let formats = (quality === 'LOSSLESS') ? 'FLAC' : 'FLAC_HIRES';\n let streamApiRes;\n try {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=${formats}&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } catch (e) {\n if (formats !== 'FLAC') {\n streamApiRes = await fetchHifiApi(`/trackManifests/?id=${trackId}&formats=FLAC&manifestType=MPEG_DASH&uriScheme=HTTPS&usage=PLAYBACK`);\n } else throw e;\n }\n\n const streamApiJson = await streamApiRes.json();\n const attributes = streamApiJson?.data?.data?.attributes;\n const uri = attributes?.uri;\n if (!uri) throw new Error(\"Missing URI in manifest response from HiFi API\");\n\n const returnedFormats = Array.isArray(attributes?.formats) ? attributes.formats : [];\n let actualQuality = 'FLAC';\n if (returnedFormats.includes('FLAC_HIRES')) actualQuality = 'FLAC_HIRES';\n else if (returnedFormats.includes('FLAC')) actualQuality = 'FLAC';\n\n const finalQualityLabel = actualQuality === 'FLAC_HIRES' ? 'Hi-Res' : (actualQuality.includes('FLAC') ? 'HiFi CD' : actualQuality);\n const isFlac = actualQuality.includes('FLAC');\n const ext = isFlac ? 'flac' : 'm4a';\n\n const filename = `${cleanTrackName} - ${cleanArtistName} [NullBeat ${trackId} - ${finalQualityLabel}].${ext}`;\n const streamData = { url: uri, isDash: true, ext, quality: actualQuality };\n\n const torrentBuffer = await generateTorrentBuffer({ streamData, filename }, valBaseUrl);\n tDashDuration = Math.round(performance.now() - tDashStart);\n\n let finalCdnUrl = null;\n let torrentId = null;\n\n const tAddStart = performance.now();\n try {\n const addRes = await fetch('https://api.real-debrid.com/rest/1.0/torrents/addTorrent', {\n method: 'PUT',\n headers: { 'Authorization': `Bearer ${apiKey}` },\n body: torrentBuffer\n });\n if (addRes.ok) {\n const addData = await addRes.json();\n torrentId = addData.id;\n } else {\n console.error('[RealDebrid] Add HTTP Status:', addRes.status, await addRes.text());\n }\n } catch (err) {\n console.error('[RealDebrid] addTorrent error:', err.message);\n }\n tAddDuration = Math.round(performance.now() - tAddStart);\n\n if (torrentId) {\n const tSelectStart = performance.now();\n try {\n await fetch(`https://api.real-debrid.com/rest/1.0/torrents/selectFiles/${torrentId}`, {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/x-www-form-urlencoded'\n },\n body: 'files=all'\n });\n } catch (e) { }\n tSelectDuration = Math.round(performance.now() - tSelectStart);\n\n const tPollStart = performance.now();\n let isDownloaded = false;\n let linkToUnrestrict = null;\n let attempts = 0;\n\n while (!isDownloaded && attempts < 15) {\n await new Promise(resolve => setTimeout(resolve, 2000));\n try {\n const infoRes = await fetch(`https://api.real-debrid.com/rest/1.0/torrents/info/${torrentId}`, {\n headers: { 'Authorization': `Bearer ${apiKey}` }\n });\n if (infoRes.ok) {\n const infoJson = await infoRes.json();\n if (infoJson.status === 'downloaded' && infoJson.links && infoJson.links.length > 0) {\n isDownloaded = true;\n linkToUnrestrict = infoJson.links[0];\n } else if (infoJson.status === 'error' || infoJson.status === 'dead' || infoJson.status === 'magnet_error') {\n console.error('[RealDebrid] Torrent failed with status:', infoJson.status);\n break;\n }\n }\n } catch (e) { }\n attempts++;\n }\n tPollDuration = Math.round(performance.now() - tPollStart);\n\n if (linkToUnrestrict) {\n const tUnrestrictStart = performance.now();\n try {\n const unRes = await fetch('https://api.real-debrid.com/rest/1.0/unrestrict/link', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${apiKey}`,\n 'Content-Type': 'application/x-www-form-urlencoded'\n },\n body: `link=${encodeURIComponent(linkToUnrestrict)}`\n });\n if (unRes.ok) {\n const unJson = await unRes.json();\n finalCdnUrl = unJson.download;\n } else {\n console.error('[RealDebrid] unrestrict error:', unRes.status, await unRes.text());\n }\n } catch (e) { }\n tUnrestrictDuration = Math.round(performance.now() - tUnrestrictStart);\n }\n }\n\n const totalDuration = Math.round(performance.now() - startTime);\n console.log(`[RD TIMING] Track ${trackId} Total: ${totalDuration}ms | Meta: ${tMetaDuration}ms | DashGen: ${tDashDuration}ms | Add: ${tAddDuration}ms | Select: ${tSelectDuration}ms | Poll: ${tPollDuration}ms | Unrestrict: ${tUnrestrictDuration}ms`);\n\n if (!finalCdnUrl) {\n return jsonResp({ error: 'Failed to process and unrestrict torrent on Real-Debrid.' }, 503);\n }\n\n return jsonResp({\n url: finalCdnUrl,\n format: ext,\n quality: finalQualityLabel,\n expiresAt: Math.floor(Date.now() / 1000) + 86400\n });\n }\n }\n\n return new Response(\"NullBeat Unified Debrid Proxy Online\", { status: 200 });\n\n } catch (err) {\n console.error('Unhandled unified backend error:', err.message);\n return jsonResp({ error: 'Internal Server Error', message: err.message }, 500);\n }\n}","deleted",false,"label",[14],"66e46240-e929-4b11-98f0-186884b4f6ff",["D",1787824538014],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","5f176305-db17-4c4c-9e0d-a3887128495f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1f78-ba2f-754d-b681-41787f593d34","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_101":97},"org",{"_9":10,"_94":95,"_96":97,"_55":56,"_98":99,"_100":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","The Volecitor","avatar","https://lh3.googleusercontent.com/a/ACg8ocJDSk1v8A-JR-j9BixGbkpDFxDEwDLvb547SIx-wABVv2vdTw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_135":136,"_137":138,"_139":140,"_141":42,"_142":42,"_143":42,"_144":32,"_145":-5,"_146":-7,"_147":-7,"_148":62,"_149":42,"_150":42,"_151":-5,"_152":42,"_153":42,"_154":42,"_155":-5},"ENV",{"_106":107,"_108":109,"_110":85,"_111":112,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>