Mux Transfer

⚡ Fast Mux Transfer (Fresh Token Engine)

\n \n

`,\n { status: 200, headers: { \"Content-Type\": \"text/html\" } }\n );\n }\n\n const folderPrefix = `transcoded_${videoId}_mux`;\n const masterUrl = `https://stream.mux.com/${playbackId}.m3u8`;\n\n console.log(`[🚀 Start Transfer] Mux Playback: ${playbackId}`);\n\n // Step 1: Master Playlist Fetch\n const masterRes = await fetch(masterUrl, { headers: BROWSER_HEADERS });\n if (!masterRes.ok) {\n return new Response(JSON.stringify({ error: `Invalid Mux Playback ID: ${masterRes.status}` }), { status: 400 });\n }\n const masterText = await masterRes.text();\n\n // Step 2: Separate Audio & Video Tracks\n const lines = masterText.split(\"\\n\").map((l) => l.trim());\n const tracksToProcess: { url: string; prefix: string; isAudio: boolean }[] = [];\n \n let audioCounter = 0;\n let videoCounter = 0;\n\n for (const l of lines) {\n if (l.startsWith(\"#EXT-X-MEDIA\") && l.includes(\"TYPE=AUDIO\") && l.includes('URI=\"')) {\n const match = l.match(/URI=\"([^\"]+)\"/);\n if (match) {\n tracksToProcess.push({\n url: match[1],\n prefix: `audio_${audioCounter}`,\n isAudio: true,\n });\n audioCounter++;\n }\n } else if (l.startsWith(\"https://\") || l.startsWith(\"http://\")) {\n tracksToProcess.push({\n url: l,\n prefix: `rendition_${videoCounter}`,\n isAudio: false,\n });\n videoCounter++;\n }\n }\n\n console.log(`Found ${audioCounter} Audio Track(s) and ${videoCounter} Video Rendition(s).`);\n\n // Step 3: Upload Master Playlist to S3\n const masterUploadPromise = uploadToS3(\n `${folderPrefix}/master.m3u8`,\n new TextEncoder().encode(masterText),\n \"application/x-mpegURL\"\n );\n\n // Step 4: Streamlined Rendition Processing with Fresh Live Manifests\n let totalChunksSaved = 0;\n let failedChunks = 0;\n\n const renditionTasks = tracksToProcess.map(async (track) => {\n // Fetch fresh live rendition manifest\n const rRes = await fetch(track.url, { headers: BROWSER_HEADERS });\n if (!rRes.ok) return;\n\n const rText = await rRes.text();\n const renditionPrefix = track.prefix;\n\n // Upload Rendition M3U8\n const manifestUpload = uploadToS3(\n `${folderPrefix}/${renditionPrefix}.m3u8`,\n new TextEncoder().encode(rText),\n \"application/x-mpegURL\"\n );\n\n // Parse fresh segments\n const rLines = rText.split(\"\\n\").map((l) => l.trim());\n const chunkItems: { url: string; s3Key: string; isMap: boolean; isAudio: boolean }[] = [];\n let segCount = 0;\n\n for (const line of rLines) {\n if (line.startsWith(\"#EXT-X-MAP:URI=\")) {\n const mapUrl = line.replace('#EXT-X-MAP:URI=\"', \"\").replace('\"', \"\");\n chunkItems.push({\n url: mapUrl,\n s3Key: `${folderPrefix}/map_${renditionPrefix}_0.m4s`,\n isMap: true,\n isAudio: track.isAudio,\n });\n } else if (line.startsWith(\"https://\") || line.startsWith(\"http://\")) {\n chunkItems.push({\n url: line,\n s3Key: `${folderPrefix}/chunk_${renditionPrefix}_${segCount}.m4s`,\n isMap: false,\n isAudio: track.isAudio,\n });\n segCount++;\n }\n }\n\n console.log(`[${renditionPrefix}] Transferring ${chunkItems.length} fresh segments...`);\n\n // Parallel download segments for this rendition while tokens are 100% active\n await Promise.all([\n manifestUpload,\n runWithConcurrency(chunkItems, 12, async (item) => {\n const data = await fetchChunkWithRetry(item.url, track.url);\n if (data) {\n await uploadToS3(item.s3Key, data, item.isMap ? \"video/mp4\" : item.isAudio ? \"video/mp4\" : \"video/iso.segment\");\n totalChunksSaved++;\n } else {\n console.error(`❌ Missed chunk: ${item.s3Key}`);\n failedChunks++;\n }\n }),\n ]);\n });\n\n await Promise.all([masterUploadPromise, ...renditionTasks]);\n\n const durationSec = ((Date.now() - startTime) / 1000).toFixed(1);\n console.log(`[✅ COMPLETE] Total Chunks: ${totalChunksSaved}, Failed: ${failedChunks} in ${durationSec}s`);\n\n return new Response(\n JSON.stringify({\n success: failedChunks === 0,\n duration: `${durationSec}s`,\n folder: folderPrefix,\n masterUrl: `/api/storage/filone/${folderPrefix}/master.m3u8`,\n audioTracks: audioCounter,\n videoRenditions: videoCounter,\n totalChunksSaved,\n failedChunks,\n }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } }\n );\n } catch (err: any) {\n console.error(\"Val Town Error:\", err);\n return new Response(JSON.stringify({ error: err.message }), { status: 500 });\n }\n}",["D",1788267478830],"branchVersion","label",[18],"pulls","branches","forks","envVars",{"_319":112,"_321":26},"connections",{"_319":26,"_320":26},"count","unfilledCount","emptyCount",{"_52":305,"_13":18,"_80":81,"_62":-5,"_54":55,"_309":226,"_323":244,"_56":324,"_58":218,"_82":95,"_306":307,"_84":24,"_310":-5,"_325":326,"_17":327},"latest",["D",1788267478830],"children",[],[18],["D",1787494877730],["D",1789452068287],{"_11":12,"_283":87},{"_11":12,"_278":279,"_86":87,"_30":85,"_280":281,"_282":24},{"_58":226,"_13":16,"_52":55,"_270":232,"_271":-5,"_272":-5,"_273":-5,"_274":-5,"_275":-5,"_276":14,"_277":12},"ctx",{"_70":-5,"_302":366,"_367":368,"_369":370,"_371":24,"_372":24,"_373":24,"_374":244,"_375":-5,"_376":-7,"_377":-7,"_378":26,"_379":24,"_380":24,"_381":-5,"_382":24,"_383":24,"_384":24,"_385":-5},"ENV",{"_337":338,"_339":340,"_341":16,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365},"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"]

History · main.ts