[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22},"handle","rezar","name","universal-dubber-571-real-patches","path","v610/YtDlpLocalResolver.kt.txt","project",{"_23":48,"_11":12,"_36":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":35,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":44},"file",{"_23":24,"_11":25,"_26":27,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":39,"_40":17,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/rezar/universal-dubber-571-real-patches/code/v610/YtDlpLocalResolver.kt.txt","extension","txt","id","97f2bb6c-f9e5-4cfe-894c-21ee984e2374","YtDlpLocalResolver.kt.txt","fileId","01a01f63-fc69-76ec-8fb9-e639db49150b","parentId","4048ad5c-9c9c-11f1-9647-1607ee4eb77e","branchId","3c31854b-284f-4dd6-bdc4-03a479ff66ac","branchVersion",90,"latest",true,"createdAt",["D",1787235111410],"version",6,"fileType","content","package com.openai.universaldubber\n\nimport android.content.Context\nimport com.yausername.youtubedl_android.YoutubeDL\nimport com.yausername.youtubedl_android.YoutubeDLRequest\nimport okhttp3.OkHttpClient\nimport okhttp3.Request\nimport java.io.File\nimport java.util.concurrent.ExecutorCompletionService\nimport java.util.concurrent.Executors\nimport java.util.concurrent.TimeUnit\nimport java.util.concurrent.TimeoutException\n\n/**\n * Fast local YouTube resolver for Media3. No iframe/WebView player is used.\n *\n * The playback-critical path never performs a yt-dlp update and never asks yt-dlp to dump the\n * complete format JSON. It races through bounded single-URL strategies, probes the returned URL,\n * and lets the foreground playback service recover with the next strategy if a URL expires.\n */\nclass YtDlpLocalResolver(private val context: Context) {\n\n data class ResolvedMedia(\n val uri: String,\n val title: String,\n val quality: String,\n val requestHeaders: Map,\n val strategyIndex: Int,\n val strategyLabel: String,\n val isLive: Boolean\n )\n\n class ResolverException(message: String, cause: Throwable? = null) : Exception(message, cause)\n\n private data class Strategy(\n val label: String,\n val playerClients: String?,\n val formatSelector: String,\n val timeoutSeconds: Long,\n val forceIpv4: Boolean = false\n )\n\n private val app = context.applicationContext\n private val prefs = app.getSharedPreferences(\"yt_dlp_runtime\", Context.MODE_PRIVATE)\n private val worker = Executors.newCachedThreadPool()\n private val http = OkHttpClient.Builder()\n .connectTimeout(3, TimeUnit.SECONDS)\n .readTimeout(3, TimeUnit.SECONDS)\n .callTimeout(3, TimeUnit.SECONDS)\n .followRedirects(true)\n .followSslRedirects(true)\n .retryOnConnectionFailure(true)\n .build()\n\n @Volatile private var initialized = false\n @Volatile private var updateInFlight = false\n\n @Synchronized\n private fun ensureInitialized(onStatus: (String) -> Unit) {\n if (initialized) return\n onStatus(\"در حال آماده‌سازی موتور محلی yt-dlp…\")\n try {\n YoutubeDL.getInstance().init(app)\n } catch (t: Throwable) {\n throw ResolverException(\"موتور yt-dlp روی گوشی راه‌اندازی نشد: ${rootMessage(t)}\", t)\n }\n initialized = true\n }\n\n /** Update only in the background. It must never block opening a video. */\n private fun scheduleBackgroundUpdate() {\n val now = System.currentTimeMillis()\n val lastSuccess = prefs.getLong(\"last_update_success\", 0L)\n val lastAttempt = prefs.getLong(\"last_update_attempt\", 0L)\n if (now - lastSuccess < 6L * 60L * 60L * 1000L) return\n if (now - lastAttempt < 20L * 60L * 1000L) return\n synchronized(this) {\n if (updateInFlight) return\n updateInFlight = true\n prefs.edit().putLong(\"last_update_attempt\", now).apply()\n }\n worker.execute {\n try {\n YoutubeDL.getInstance().updateYoutubeDL(app, YoutubeDL.UpdateChannel.NIGHTLY)\n prefs.edit().putLong(\"last_update_success\", System.currentTimeMillis()).apply()\n } catch (_: Throwable) {\n // Playback continues with the bundled/previously updated executable.\n } finally {\n updateInFlight = false\n }\n }\n }\n\n fun resolve(\n youtubeUrl: String,\n rawSessionCookie: String?,\n startStrategy: Int = 0,\n onStatus: (String) -> Unit = {}\n ): ResolvedMedia {\n ensureInitialized(onStatus)\n scheduleBackgroundUpdate()\n\n val cookieFile = rawSessionCookie\n ?.trim()\n ?.takeIf { it.isNotBlank() }\n ?.let(::prepareCookieFile)\n\n val strategies = if (cookieFile == null) {\n listOf(\n // Fastest low-complexity progressive path. Keep format 18 explicit instead of\n // enumerating every adaptive format.\n Strategy(\"format 18 + android_vr\", \"android_vr\", FORMAT_18, 6),\n Strategy(\"format 18 + yt-dlp\", null, FORMAT_18, 6),\n // HLS is useful when a progressive URL is unavailable.\n Strategy(\"web_safari HLS\", \"web_safari\", HLS_FIRST, 8),\n Strategy(\"web_embedded muxed\", \"web_embedded\", MUXED_360, 8),\n Strategy(\"yt-dlp muxed + IPv4\", null, MUXED_360, 8, forceIpv4 = true)\n )\n } else {\n listOf(\n Strategy(\"نشست کاربر + format 18\", null, FORMAT_18, 6),\n Strategy(\"نشست کاربر + web_safari HLS\", \"web_safari\", HLS_FIRST, 8),\n Strategy(\"نشست کاربر + web_embedded\", \"web_embedded\", MUXED_360, 8),\n Strategy(\"نشست کاربر + IPv4\", null, MUXED_360, 8, forceIpv4 = true)\n )\n }\n\n if (startStrategy >= strategies.size) {\n throw ResolverException(\"مسیر جایگزین دیگری برای این ویدیو باقی نمانده است.\")\n }\n\n val failures = mutableListOf()\n var sawAuthRequired = false\n var sawHttp403 = false\n var loopStart = startStrategy.coerceAtLeast(0)\n\n // On the first load, race the two fastest candidates instead of serially waiting for one\n // to time out before starting the other. This keeps the primary startup budget bounded.\n if (loopStart == 0 && strategies.size >= 2) {\n onStatus(\"Resolver سریع: دو مسیر اصلی هم‌زمان در حال آزمایش…\")\n val raced = raceStrategies(youtubeUrl, cookieFile, strategies, intArrayOf(0, 1))\n raced.media?.let { return it }\n raced.failures.forEach { (index, error) ->\n val raw = rootMessage(error)\n sawAuthRequired = sawAuthRequired || isAuthRequired(raw)\n sawHttp403 = sawHttp403 || raw.contains(\"403\", true)\n failures += \"${strategies[index].label}: ${friendly(error)}\"\n }\n loopStart = 2\n }\n\n for (index in loopStart until strategies.size) {\n val strategy = strategies[index]\n try {\n onStatus(\"Resolver محلی ${index + 1}/${strategies.size}: ${strategy.label}…\")\n return resolveStrategy(youtubeUrl, cookieFile, index, strategy)\n } catch (t: Throwable) {\n val raw = rootMessage(t)\n sawAuthRequired = sawAuthRequired || isAuthRequired(raw)\n sawHttp403 = sawHttp403 || raw.contains(\"403\", true)\n failures += \"${strategy.label}: ${friendly(t)}\"\n }\n }\n\n if (sawAuthRequired) {\n if (cookieFile == null) {\n throw ResolverException(\n \"YouTube برای این IP/ویدیو نشست معتبر یا Proof-of-Origin معتبر می‌خواهد. \" +\n \"مسیرهای سریع محلی بدون جعل هویت شکست خوردند.\"\n )\n }\n throw ResolverException(\n \"نشست YouTube واردشده پذیرفته نشد یا منقضی شده است. \" +\n failures.takeLast(3).joinToString(\" | \")\n )\n }\n\n if (sawHttp403) {\n throw ResolverException(\n \"YouTube URLهای استخراج‌شده را با HTTP 403 رد کرد. \" + failures.takeLast(3).joinToString(\" | \")\n )\n }\n\n throw ResolverException(\"همه مسیرهای محلی شکست خوردند. \" + failures.takeLast(4).joinToString(\" | \"))\n }\n\n private data class RaceResult(\n val media: ResolvedMedia?,\n val failures: List>\n )\n\n private data class StrategyAttempt(\n val index: Int,\n val media: ResolvedMedia?,\n val error: Throwable?\n )\n\n private fun raceStrategies(\n youtubeUrl: String,\n cookieFile: File?,\n strategies: List,\n indices: IntArray\n ): RaceResult {\n val completion = ExecutorCompletionService(worker)\n val submitted = indices.map { index ->\n completion.submit {\n try {\n StrategyAttempt(index, resolveStrategy(youtubeUrl, cookieFile, index, strategies[index]), null)\n } catch (t: Throwable) {\n StrategyAttempt(index, null, t)\n }\n }\n }\n val failures = mutableListOf>()\n val deadline = System.nanoTime() + TimeUnit.SECONDS.toNanos(9)\n var remaining = submitted.size\n while (remaining > 0) {\n val left = deadline - System.nanoTime()\n if (left <= 0L) break\n val done = completion.poll(left, TimeUnit.NANOSECONDS) ?: break\n remaining--\n val attempt = runCatching { done.get() }.getOrElse { t ->\n StrategyAttempt(-1, null, t.cause ?: t)\n }\n if (attempt.media != null) {\n submitted.forEach { future -> if (!future.isDone) future.cancel(true) }\n return RaceResult(attempt.media, failures)\n }\n if (attempt.index >= 0 && attempt.error != null) failures += attempt.index to attempt.error\n }\n submitted.forEach { future -> if (!future.isDone) future.cancel(true) }\n indices.forEach { index ->\n if (failures.none { it.first == index }) {\n failures += index to ResolverException(\"timeout مسیر موازی در بودجه 9s\")\n }\n }\n return RaceResult(null, failures)\n }\n\n private fun resolveStrategy(\n youtubeUrl: String,\n cookieFile: File?,\n index: Int,\n strategy: Strategy\n ): ResolvedMedia {\n val request = YoutubeDLRequest(youtubeUrl)\n .addOption(\"--ignore-config\")\n .addOption(\"--no-playlist\")\n .addOption(\"--no-warnings\")\n .addOption(\"--socket-timeout\", \"5\")\n .addOption(\"--retries\", \"0\")\n .addOption(\"--extractor-retries\", \"1\")\n .addOption(\"--fragment-retries\", \"0\")\n .addOption(\"--skip-download\")\n .addOption(\"--get-url\")\n .addOption(\"-f\", strategy.formatSelector)\n\n strategy.playerClients?.let {\n request.addOption(\"--extractor-args\", \"youtube:player_client=$it\")\n }\n if (strategy.forceIpv4) request.addOption(\"--force-ipv4\")\n if (cookieFile != null) request.addOption(\"--cookies\", cookieFile.absolutePath)\n\n val url = executeForSingleUrl(request, index, strategy.timeoutSeconds)\n val headers = linkedMapOf(\"User-Agent\" to DEFAULT_USER_AGENT)\n probe(url, headers)\n val isLive = url.contains(\"m3u8\", ignoreCase = true)\n val quality = when {\n strategy.formatSelector == FORMAT_18 -> \"360p\"\n isLive -> \"HLS\"\n else -> \"≤360p\"\n }\n return ResolvedMedia(\n uri = url,\n title = \"YouTube\",\n quality = quality,\n requestHeaders = headers,\n strategyIndex = index,\n strategyLabel = strategy.label,\n isLive = isLive\n )\n }\n\n\n private fun executeForSingleUrl(\n request: YoutubeDLRequest,\n strategyIndex: Int,\n timeoutSeconds: Long\n ): String {\n val processId = \"ud-url-${strategyIndex}-${System.nanoTime()}\"\n val future = worker.submit {\n val response = YoutubeDL.getInstance().execute(request, processId)\n response.out.lineSequence()\n .map { it.trim() }\n .firstOrNull { it.startsWith(\"https://\") || it.startsWith(\"http://\") }\n ?: throw ResolverException(\"yt-dlp URL قابل پخش برنگرداند\")\n }\n return try {\n future.get(timeoutSeconds, TimeUnit.SECONDS)\n } catch (t: TimeoutException) {\n YoutubeDL.getInstance().destroyProcessById(processId)\n future.cancel(true)\n throw ResolverException(\"timeout ${timeoutSeconds}s در استخراج URL\", t)\n } catch (t: InterruptedException) {\n YoutubeDL.getInstance().destroyProcessById(processId)\n future.cancel(true)\n Thread.currentThread().interrupt()\n throw ResolverException(\"استخراج URL لغو شد\", t)\n } catch (t: Throwable) {\n future.cancel(true)\n val cause = t.cause ?: t\n throw ResolverException(rootMessage(cause), cause)\n }\n }\n\n private fun probe(url: String, headers: Map) {\n val builder = Request.Builder().url(url).get().header(\"Range\", \"bytes=0-2047\")\n headers.forEach { (name, value) ->\n if (!name.equals(\"Range\", true) && name.isNotBlank()) builder.header(name, value)\n }\n http.newCall(builder.build()).execute().use { response ->\n if (response.code !in 200..299 && response.code != 416) {\n throw ResolverException(\"URL خروجی در probe پاسخ HTTP ${response.code} داد\")\n }\n val contentType = response.header(\"Content-Type\").orEmpty().lowercase()\n if (contentType.contains(\"text/html\")) {\n throw ResolverException(\"URL خروجی به صفحه HTML برگشت، نه media\")\n }\n }\n }\n\n private fun prepareCookieFile(raw: String): File {\n val file = File(app.noBackupFilesDir, \"youtube-session-cookies.txt\")\n val normalized = raw.replace(\"\\r\\n\", \"\\n\").replace('\\r', '\\n').trim()\n val text = if (\n normalized.startsWith(\"# Netscape HTTP Cookie File\") ||\n normalized.startsWith(\"# HTTP Cookie File\")\n ) {\n normalized + \"\\n\"\n } else {\n val expiry = 2147483647L\n buildString {\n append(\"# Netscape HTTP Cookie File\\n\")\n normalized.split(';').forEach { token ->\n val part = token.trim()\n val eq = part.indexOf('=')\n if (eq > 0) {\n val name = part.substring(0, eq).trim()\n val value = part.substring(eq + 1).trim()\n if (name.isNotBlank()) {\n append(\".youtube.com\\tTRUE\\t/\\tTRUE\\t\")\n .append(expiry).append('\\t')\n .append(name).append('\\t').append(value).append('\\n')\n }\n }\n }\n }\n }\n\n val cookieRows = text.lineSequence()\n .map { it.trim() }\n .filter { it.isNotEmpty() && !it.startsWith(\"#\") }\n .toList()\n if (cookieRows.isEmpty()) throw ResolverException(\"فایل نشست هیچ Cookie قابل استفاده‌ای ندارد.\")\n if (cookieRows.none { it.contains(\"youtube.com\", true) || it.contains(\"google.com\", true) }) {\n throw ResolverException(\"cookies.txt شامل Cookie مربوط به YouTube/Google نیست.\")\n }\n file.parentFile?.mkdirs()\n file.writeText(text, Charsets.UTF_8)\n return file\n }\n\n private fun isAuthRequired(message: String): Boolean =\n message.contains(\"LOGIN_REQUIRED\", true) ||\n message.contains(\"sign in\", true) ||\n message.contains(\"confirm you're not a bot\", true) ||\n message.contains(\"confirm you’re not a bot\", true) ||\n message.contains(\"authentication\", true)\n\n private fun friendly(t: Throwable): String {\n val msg = rootMessage(t)\n return when {\n isAuthRequired(msg) -> \"YouTube نشست/تأیید معتبر می‌خواهد\"\n msg.contains(\"403\", true) -> \"stream با 403 رد شد\"\n msg.contains(\"Requested format is not available\", true) -> \"فرمت انتخابی موجود نیست\"\n msg.contains(\"timeout\", true) -> msg.take(120)\n else -> msg.take(260)\n }\n }\n\n private fun rootMessage(t: Throwable): String =\n generateSequence(t) { it.cause }\n .mapNotNull { it.message?.trim() }\n .firstOrNull { it.isNotBlank() }\n ?: t.javaClass.simpleName\n\n companion object {\n private const val FORMAT_18 = \"18\"\n private const val MUXED_360 =\n \"best[ext=mp4][vcodec!=none][acodec!=none][height<=360]/best[vcodec!=none][acodec!=none][height<=360]/18\"\n private const val HLS_FIRST =\n \"best[protocol=m3u8_native][height<=720]/best[protocol=m3u8][height<=720]/18\"\n const val DEFAULT_USER_AGENT =\n \"Mozilla/5.0 (Linux; Android 16; Mobile) AppleWebKit/537.36 Chrome/140.0.0.0 Mobile Safari/537.36\"\n }\n}\n","deleted",false,"label",[47,25],"v610","60876f3f-66c0-4174-afa2-a8c0c0d0af28",["D",1787156870791],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Verified Universal Dubber 5.7.1 resolver source overlays","imageUrl","userId","62d63139-fff1-474c-957e-0de43711ef38","pinnedFileId","8a1df52e-9beb-11f1-9439-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fe29f-d21a-769b-b052-ec8f0e83c092","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_58":59,"_103":104,"_105":44},"branch",{"_38":89,"_11":90,"_23":31,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",188,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Reza Rahaeifard","avatar","https://lh3.googleusercontent.com/a/ACg8ocLSq53iQZbkEu7APkCBMoGsId1S_CbUp8pbglW1kMZZ96gL_JYF=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":44,"_147":44,"_148":44,"_149":35,"_150":-5,"_151":-7,"_152":-7,"_153":66,"_154":44,"_155":44,"_156":-5,"_157":44,"_158":44,"_159":44,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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"]