[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_631":632,"_633":634},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":59,"_124":-5,"_125":-5,"_126":127},"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":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",90,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":20,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":20,"_35":36},"deleted",false,"deletedHere","path","v610/YtDlpLocalResolver.kt.txt","latestPath","fileId","01a01f63-fc69-76ec-8fb9-e639db49150b","name","YtDlpLocalResolver.kt.txt","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: 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","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","createdAt",["D",1787235111410],"branchVersion","branchId","3c31854b-284f-4dd6-bdc4-03a479ff66ac","id","60876f3f-66c0-4174-afa2-a8c0c0d0af28","universal-dubber-571-real-patches",["D",1787156870791],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Verified Universal Dubber 5.7.1 resolver source overlays","imageUrl","62d63139-fff1-474c-957e-0de43711ef38","pinnedFileId","8a1df52e-9beb-11f1-9439-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fe29f-d21a-769b-b052-ec8f0e83c092","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",188,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rezar","handle","displayName","Reza Rahaeifard","avatar","https://lh3.googleusercontent.com/a/ACg8ocLSq53iQZbkEu7APkCBMoGsId1S_CbUp8pbglW1kMZZ96gL_JYF=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":627,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":628,"_81":629,"_83":630,"_85":25},"tree",[392,398,404,410,411,412,413,414,415,416,417,418,419,420,421,422,423,424,425,426,427,428,429,430,431,432,433,434,435,436],"files",[392,393,394,395,396,397,398,399,400,401,402,403,404,405,406,407,408,409,410,411,412,413,414,415,416,417,418,419,420,421,422,423,424,425,426,427,428,429,430,431,432,433,434,435,436],"counts",{"_382":63,"_383":225,"_384":63,"_385":386,"_387":388},"contents",[128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":376,"_32":377,"_30":378,"_161":-5,"_41":42,"_40":379,"_163":59,"_38":380,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_27":381},{"_43":370,"_32":371,"_30":372,"_161":-5,"_41":42,"_40":373,"_163":59,"_38":374,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_27":375},{"_43":363,"_32":364,"_30":365,"_161":-5,"_41":42,"_40":366,"_163":59,"_38":367,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_27":369},{"_43":357,"_32":358,"_30":359,"_161":-5,"_41":42,"_40":225,"_163":59,"_38":360,"_13":63,"_34":20,"_35":361,"_24":25,"_167":-5,"_27":362},{"_43":351,"_32":352,"_30":353,"_161":-5,"_41":42,"_40":174,"_163":59,"_38":354,"_13":63,"_34":20,"_35":355,"_24":25,"_167":-5,"_27":356},{"_43":342,"_32":343,"_30":344,"_161":-5,"_41":42,"_40":345,"_163":25,"_38":346,"_13":347,"_34":165,"_35":348,"_24":25,"_167":349,"_27":350},{"_43":333,"_32":334,"_30":335,"_161":-5,"_41":42,"_40":336,"_163":25,"_38":337,"_13":338,"_34":165,"_35":339,"_24":25,"_167":340,"_27":341},{"_43":325,"_32":326,"_30":327,"_161":-5,"_41":42,"_40":328,"_163":59,"_38":329,"_13":63,"_34":165,"_35":330,"_24":25,"_167":331,"_27":332},{"_43":317,"_32":318,"_30":319,"_161":-5,"_41":42,"_40":320,"_163":59,"_38":321,"_13":63,"_34":165,"_35":322,"_24":25,"_167":323,"_27":324},{"_43":309,"_32":310,"_30":311,"_161":-5,"_41":42,"_40":312,"_163":59,"_38":313,"_13":63,"_34":165,"_35":314,"_24":25,"_167":315,"_27":316},{"_43":301,"_32":302,"_30":303,"_161":-5,"_41":42,"_40":304,"_163":59,"_38":305,"_13":63,"_34":165,"_35":306,"_24":25,"_167":307,"_27":308},{"_43":294,"_32":295,"_30":296,"_161":-5,"_41":42,"_40":297,"_163":59,"_38":298,"_13":63,"_34":165,"_35":299,"_24":25,"_167":-5,"_27":300},{"_43":286,"_32":287,"_30":288,"_161":-5,"_41":42,"_40":289,"_163":59,"_38":290,"_13":63,"_34":165,"_35":291,"_24":25,"_167":292,"_27":293},{"_43":279,"_32":280,"_30":281,"_161":-5,"_41":42,"_40":282,"_163":59,"_38":283,"_13":174,"_34":165,"_35":284,"_24":25,"_167":-5,"_27":285},{"_43":272,"_32":273,"_30":274,"_161":-5,"_41":42,"_40":275,"_163":59,"_38":276,"_13":225,"_34":165,"_35":277,"_24":25,"_167":-5,"_27":278},{"_43":265,"_32":266,"_30":267,"_161":-5,"_41":42,"_40":268,"_163":59,"_38":269,"_13":233,"_34":175,"_35":270,"_24":25,"_167":-5,"_27":271},{"_43":257,"_32":258,"_30":259,"_161":-5,"_41":42,"_40":260,"_163":59,"_38":261,"_13":262,"_34":165,"_35":263,"_24":25,"_167":-5,"_27":264},{"_43":251,"_32":252,"_30":57,"_161":-5,"_41":42,"_40":253,"_163":59,"_38":254,"_13":225,"_34":165,"_35":255,"_24":25,"_167":-5,"_27":256},{"_43":244,"_32":245,"_30":246,"_161":-5,"_41":42,"_40":247,"_163":59,"_38":248,"_13":63,"_34":165,"_35":249,"_24":25,"_167":-5,"_27":250},{"_43":237,"_32":238,"_30":239,"_161":-5,"_41":42,"_40":240,"_163":59,"_38":241,"_13":63,"_34":165,"_35":242,"_24":25,"_167":-5,"_27":243},{"_43":228,"_32":229,"_30":230,"_161":-5,"_41":42,"_40":231,"_163":59,"_38":232,"_13":233,"_34":165,"_35":234,"_24":25,"_167":235,"_27":236},{"_43":220,"_32":221,"_30":222,"_161":-5,"_41":42,"_40":223,"_163":59,"_38":224,"_13":225,"_34":165,"_35":226,"_24":25,"_167":-5,"_27":227},{"_43":213,"_32":214,"_30":215,"_161":-5,"_41":42,"_40":216,"_163":59,"_38":217,"_13":63,"_34":20,"_35":218,"_24":25,"_167":-5,"_27":219},{"_43":206,"_32":207,"_30":208,"_161":-5,"_41":42,"_40":209,"_163":59,"_38":210,"_13":63,"_34":165,"_35":211,"_24":25,"_167":-5,"_27":212},{"_43":199,"_32":200,"_30":201,"_161":-5,"_41":42,"_40":202,"_163":59,"_38":203,"_13":63,"_34":165,"_35":204,"_24":25,"_167":-5,"_27":205},{"_43":192,"_32":193,"_30":194,"_161":-5,"_41":42,"_40":195,"_163":59,"_38":196,"_13":63,"_34":165,"_35":197,"_24":25,"_167":-5,"_27":198},{"_43":185,"_32":186,"_30":187,"_161":-5,"_41":42,"_40":188,"_163":59,"_38":189,"_13":63,"_34":165,"_35":190,"_24":25,"_167":-5,"_27":191},{"_43":178,"_32":179,"_30":180,"_161":-5,"_41":42,"_40":181,"_163":59,"_38":182,"_13":63,"_34":165,"_35":183,"_24":25,"_167":-5,"_27":184},{"_43":169,"_32":170,"_30":171,"_161":-5,"_41":42,"_40":172,"_163":59,"_38":173,"_13":174,"_34":175,"_35":176,"_24":25,"_167":-5,"_27":177},{"_43":158,"_32":159,"_30":160,"_161":-5,"_41":42,"_40":162,"_163":59,"_38":164,"_13":63,"_34":165,"_35":166,"_24":25,"_167":-5,"_27":168},"3c67bbd9-fb0d-427a-9642-dada0a38c00c","verify590.ts","083a0512-9c1c-11f1-aca5-1607ee4eb77e","parentId",37,"latest",["D",1787177963614],"http","const APK = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function() {\n const r = await fetch(APK, { method: \"HEAD\", headers: { \"User-Agent\": \"UniversalDubber590Verifier/1\" } });\n return Response.json({\n ok: r.ok,\n status: r.status,\n contentLength: r.headers.get(\"content-length\"),\n contentType: r.headers.get(\"content-type\"),\n etag: r.headers.get(\"etag\"),\n url: APK\n });\n}","label",[159],"e81e60c4-48ad-43a0-8858-4bd9d7024c44","validate610.ts","b1f1a90a-9c9b-11f1-9eda-1607ee4eb77e",69,["D",1787232822238],2,"script","const BASE = 'https://universal-dubber-ytdlp-resolver-v3.onrender.com';\nconst TEST = 'https://www.youtube.com/watch?v=dQw4w9WgXcQ';\n\nasync function timed(url: string) {\n const started = Date.now();\n const r = await fetch(url, { headers: { 'User-Agent': 'UniversalDubberValidator/6.1' } });\n const text = await r.text();\n return { status: r.status, ms: Date.now() - started, text: text.slice(0, 12000) };\n}\n\nexport default async function () {\n const health = await timed(`${BASE}/health`);\n const resolve = await timed(`${BASE}/resolve?url=${encodeURIComponent(TEST)}`);\n const result = { health, resolve };\n console.log(JSON.stringify(result));\n return result;\n}\n",[170],"f8774a43-5958-4d2a-a558-d649773daa63","validate610-resolve10.ts","8f883fd6-9c9c-11f1-a179-1607ee4eb77e",74,["D",1787233166204],"export default async function () {\n const url = 'https://universal-dubber-ytdlp-resolver-v3.onrender.com/resolve?url=' + encodeURIComponent('https://www.youtube.com/watch?v=dQw4w9WgXcQ');\n const started = Date.now();\n try {\n const r = await fetch(url, { signal: AbortSignal.timeout(10000) });\n const text = await r.text();\n return Response.json({ status: r.status, ms: Date.now() - started, text: text.slice(0, 12000) });\n } catch (e) {\n return Response.json({ status: 0, ms: Date.now() - started, error: String(e) });\n }\n}\n",[179],"88d5a3d4-ba5d-4ee3-ab8a-978767339195","validate610-http.ts","c88ef7d0-9c9b-11f1-9666-1607ee4eb77e",70,["D",1787232832373],"const BASE = 'https://universal-dubber-ytdlp-resolver-v3.onrender.com';\nconst TEST = 'https://www.youtube.com/watch?v=dQw4w9WgXcQ';\n\nasync function timed(url: string) {\n const started = Date.now();\n const r = await fetch(url, { headers: { 'User-Agent': 'UniversalDubberValidator/6.1' } });\n const text = await r.text();\n return { status: r.status, ms: Date.now() - started, text: text.slice(0, 12000) };\n}\n\nexport default async function () {\n const health = await timed(`${BASE}/health`);\n const resolve = await timed(`${BASE}/resolve?url=${encodeURIComponent(TEST)}`);\n return Response.json({ health, resolve });\n}\n",[186],"ba2041cb-c646-4b1e-91aa-589e750c0ab0","validate610-health.ts","854363a2-9c9c-11f1-a179-1607ee4eb77e",73,["D",1787233148974],"export default async function () {\n const started = Date.now();\n try {\n const r = await fetch('https://universal-dubber-ytdlp-resolver-v3.onrender.com/health');\n const text = await r.text();\n return Response.json({ status: r.status, ms: Date.now() - started, text });\n } catch (e) {\n return Response.json({ status: 0, ms: Date.now() - started, error: String(e) }, { status: 502 });\n }\n}\n",[193],"8a55dcb8-5505-4953-8355-db74deefc548","validate610-format18.ts","a180f804-9c9c-11f1-b425-1607ee4eb77e",75,["D",1787233196350],"const TEST='https://www.youtube.com/watch?v=dQw4w9WgXcQ';\nconst BASE='https://universal-dubber-ytdlp-relay-v2-va.onrender.com';\nexport default async function(){\n const started=Date.now();\n try{\n const r=await fetch(`${BASE}/selfprobe?url=${encodeURIComponent(TEST)}`,{signal:AbortSignal.timeout(10000)});\n const text=await r.text();\n return Response.json({status:r.status,ms:Date.now()-started,text:text.slice(0,8000)});\n }catch(e){return Response.json({status:0,ms:Date.now()-started,error:String(e)});}\n}\n",[200],"dc14b49f-51e9-411b-896c-f849129d4d66","validate610-cobalt.ts","bc1be598-9c9c-11f1-97ee-1607ee4eb77e",76,["D",1787233240984],"const BASE='https://universal-dubber-cobalt-570b.onrender.com/';\nconst TEST='https://www.youtube.com/watch?v=dQw4w9WgXcQ';\nexport default async function(){\n const started=Date.now();\n try{\n const r=await fetch(BASE,{method:'POST',headers:{'Accept':'application/json','Content-Type':'application/json'},body:JSON.stringify({url:TEST,videoQuality:'360',youtubeVideoCodec:'h264',youtubeVideoContainer:'mp4',alwaysProxy:true,localProcessing:'disabled'}),signal:AbortSignal.timeout(10000)});\n const text=await r.text();\n return Response.json({status:r.status,ms:Date.now()-started,text:text.slice(0,12000)});\n }catch(e){return Response.json({status:0,ms:Date.now()-started,error:String(e)});}\n}\n",[207],"032c2a72-75a6-4ff6-8e81-5de87bb0c9aa","test-static.txt","85cb1f54-9c1a-11f1-858d-1607ee4eb77e",27,["D",1787177315275],"HELLO_STATIC_590",[214],"f5a09c8f-7165-487a-8095-75ab93b6d749","test-read.ts","8964a824-9c1a-11f1-9fc4-1607ee4eb77e",29,["D",1787177378140],1,"const candidates = [\n 'https://api.val.town/v2/vals/60876f3f-66c0-4174-afa2-a8c0c0d0af28/files/test-static.txt?branch=main',\n 'https://esm.town/v/rezar/universal-dubber-571-real-patches/test-static.txt',\n 'https://esm.town/v/rezar/universal-dubber-571-real-patches@main/test-static.txt'\n];\nexport default async function() {\n const out=[];\n for (const u of candidates) {\n try { const r=await fetch(u); out.push({u,status:r.status,body:(await r.text()).slice(0,300)}); }\n catch(e){ out.push({u,error:String(e)}); }\n }\n return Response.json(out);\n}",[221],"043e9209-0dc6-4b33-b14f-8c88b6d469fa","source610.ts","01a01f7c-5472-756d-9ed5-cac2efea17f4",84,["D",1787234697788],4,"import JSZip from \"npm:jszip\";\n\nconst BASE = \"https://universal-dubber-570-real-source.val.run/?rebuild=1\";\nconst STATIC = \"https://esm.town/v/rezar/universal-dubber-571-real-patches/v610\";\nconst ROOT = \"ud520src\";\nconst JAVA = `${ROOT}/app/src/main/java/com/openai/universaldubber`;\n\nasync function getText(name: string): Promise {\n const r = await fetch(`${STATIC}/${name}`, { headers: { \"User-Agent\": \"UniversalDubber610Assembler/1\" } });\n if (!r.ok) throw new Error(`${name} HTTP ${r.status}`);\n return await r.text();\n}\n\nexport default async function(): Promise {\n const base = await fetch(BASE, { headers: { \"User-Agent\": \"UniversalDubber610Assembler/1\", \"Cache-Control\": \"no-cache\" } });\n if (!base.ok) return new Response(`base HTTP ${base.status}`, { status: 502 });\n\n const zip = await JSZip.loadAsync(await base.arrayBuffer());\n const [gradle, manifest, main, resolver, service] = await Promise.all([\n getText(\"app-build.gradle.kts.txt\"),\n getText(\"AndroidManifest.xml.txt\"),\n getText(\"MainActivity.kt.txt\"),\n getText(\"YtDlpLocalResolver.kt.txt\"),\n getText(\"UniversalPlaybackService.kt.txt\"),\n ]);\n\n zip.file(`${ROOT}/app/build.gradle.kts`, gradle);\n zip.file(`${ROOT}/app/src/main/AndroidManifest.xml`, manifest);\n zip.file(`${JAVA}/MainActivity.kt`, main);\n zip.file(`${JAVA}/YtDlpLocalResolver.kt`, resolver);\n zip.file(`${JAVA}/UniversalPlaybackService.kt`, service);\n\n const checks: Array<[string, string[]]> = [\n [`${ROOT}/app/build.gradle.kts`, ['versionName = \"6.1.0\"', 'versionCode = 32', 'abiFilters += listOf(\"arm64-v8a\")', 'youtubedl-android:library:0.18.1']],\n [`${ROOT}/app/src/main/AndroidManifest.xml`, ['FOREGROUND_SERVICE_MEDIA_PLAYBACK', 'UniversalPlaybackService', 'extractNativeLibs=\"true\"']],\n [`${JAVA}/MainActivity.kt`, ['UniversalPlaybackService.ACTION_LOAD', 'وارد کردن cookies.txt از حافظه گوشی', 'ActivityResultContracts.OpenDocument']],\n [`${JAVA}/YtDlpLocalResolver.kt`, ['scheduleBackgroundUpdate', 'format 18 + android_vr', '--get-url', 'bytes=0-2047', 'timeoutSeconds']],\n [`${JAVA}/UniversalPlaybackService.kt`, ['FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK', 'recoverPlayback', 'onTaskRemoved', 'START_STICKY']],\n ];\n for (const [path, markers] of checks) {\n const text = await zip.file(path)?.async(\"string\");\n if (!text) throw new Error(`missing ${path}`);\n for (const marker of markers) if (!text.includes(marker)) throw new Error(`missing marker ${marker} in ${path}`);\n }\n if (gradle.includes('youtubedl-android:ffmpeg')) throw new Error('ffmpeg must not be bundled in 6.1');\n\n const bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n return new Response(bytes, {\n headers: {\n \"content-type\": \"application/zip\",\n \"content-disposition\": \"attachment; filename=Universal_Dubber_v6_1_0_FAST_LOCAL_source.zip\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n","universal-dubber-610-source",[229],"af041d0e-bf2e-4504-ad6c-db7a2f56d3d7","source600.ts","730d3ad4-9c22-11f1-9ddb-1607ee4eb77e",55,["D",1787180719815],"import JSZip from \"npm:jszip\";\n\nconst BASE = \"https://universal-dubber-570-real-source.val.run/?rebuild=1\";\nconst STATIC = \"https://esm.town/v/rezar/universal-dubber-571-real-patches/v600\";\nconst ROOT = \"ud520src\";\nconst JAVA = `${ROOT}/app/src/main/java/com/openai/universaldubber`;\n\nasync function getText(name: string): Promise {\n const r = await fetch(`${STATIC}/${name}`, { headers: { \"User-Agent\": \"UniversalDubber600Assembler/1\" } });\n if (!r.ok) throw new Error(`${name} HTTP ${r.status}`);\n return await r.text();\n}\n\nexport default async function(): Promise {\n const base = await fetch(BASE, { headers: { \"User-Agent\": \"UniversalDubber600Assembler/1\", \"Cache-Control\": \"no-cache\" } });\n if (!base.ok) return new Response(`base HTTP ${base.status}`, { status: 502 });\n\n const zip = await JSZip.loadAsync(await base.arrayBuffer());\n const [gradle, manifest, main, resolver, service] = await Promise.all([\n getText(\"app-build.gradle.kts.txt\"),\n getText(\"AndroidManifest.xml.txt\"),\n getText(\"MainActivity.kt.txt\"),\n getText(\"YtDlpLocalResolver.kt.txt\"),\n getText(\"UniversalPlaybackService.kt.txt\"),\n ]);\n\n zip.file(`${ROOT}/app/build.gradle.kts`, gradle);\n zip.file(`${ROOT}/app/src/main/AndroidManifest.xml`, manifest);\n zip.file(`${JAVA}/MainActivity.kt`, main);\n zip.file(`${JAVA}/YtDlpLocalResolver.kt`, resolver);\n zip.file(`${JAVA}/UniversalPlaybackService.kt`, service);\n\n const checks: Array<[string, string[]]> = [\n [`${ROOT}/app/build.gradle.kts`, ['versionName = \"6.0.0\"', 'versionCode = 31', 'abiFilters += listOf(\"arm64-v8a\")', 'youtubedl-android:library:0.18.1']],\n [`${ROOT}/app/src/main/AndroidManifest.xml`, ['FOREGROUND_SERVICE_MEDIA_PLAYBACK', 'UniversalPlaybackService', 'extractNativeLibs=\"true\"']],\n [`${JAVA}/MainActivity.kt`, ['UniversalPlaybackService.ACTION_LOAD', 'وارد کردن cookies.txt از حافظه گوشی', 'ActivityResultContracts.OpenDocument']],\n [`${JAVA}/YtDlpLocalResolver.kt`, ['updateYoutubeDL', 'android_vr', 'web_safari HLS', 'Range\", \"bytes=0-4095', 'نشست YouTube واردشده پذیرفته نشد']],\n [`${JAVA}/UniversalPlaybackService.kt`, ['FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK', 'recoverPlayback', 'onTaskRemoved', 'START_STICKY']],\n ];\n for (const [path, markers] of checks) {\n const text = await zip.file(path)?.async(\"string\");\n if (!text) throw new Error(`missing ${path}`);\n for (const marker of markers) if (!text.includes(marker)) throw new Error(`missing marker ${marker} in ${path}`);\n }\n if (gradle.includes('youtubedl-android:ffmpeg')) throw new Error('ffmpeg must not be bundled in 6.0');\n\n const bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n return new Response(bytes, {\n headers: {\n \"content-type\": \"application/zip\",\n \"content-disposition\": \"attachment; filename=Universal_Dubber_v6_0_0_LOCAL_SESSION_BACKGROUND_source.zip\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n",[238],"e96d140a-389f-4d53-9962-dba15f8a3024","source590.ts","09f73312-9c1b-11f1-88da-1607ee4eb77e",35,["D",1787177537021],"import JSZip from \"npm:jszip\";\n\nconst BASE = \"https://universal-dubber-570-real-source.val.run/?rebuild=1\";\nconst STATIC = \"https://esm.town/v/rezar/universal-dubber-571-real-patches/v590\";\nconst ROOT = \"ud520src\";\nconst JAVA = `${ROOT}/app/src/main/java/com/openai/universaldubber`;\n\nasync function getText(name: string): Promise {\n const r = await fetch(`${STATIC}/${name}`, { headers: { \"User-Agent\": \"UniversalDubber590Assembler/1\" } });\n if (!r.ok) throw new Error(`${name} HTTP ${r.status}`);\n return await r.text();\n}\n\nexport default async function(): Promise {\n const base = await fetch(BASE, { headers: { \"User-Agent\": \"UniversalDubber590Assembler/1\", \"Cache-Control\": \"no-cache\" } });\n if (!base.ok) return new Response(`base HTTP ${base.status}`, { status: 502 });\n\n const zip = await JSZip.loadAsync(await base.arrayBuffer());\n const [gradle, manifest, main, resolver, service] = await Promise.all([\n getText(\"app-build.gradle.kts.txt\"),\n getText(\"AndroidManifest.xml.txt\"),\n getText(\"MainActivity.kt.txt\"),\n getText(\"YtDlpLocalResolver.kt.txt\"),\n getText(\"UniversalPlaybackService.kt.txt\"),\n ]);\n\n zip.file(`${ROOT}/app/build.gradle.kts`, gradle);\n zip.file(`${ROOT}/app/src/main/AndroidManifest.xml`, manifest);\n zip.file(`${JAVA}/MainActivity.kt`, main);\n zip.file(`${JAVA}/YtDlpLocalResolver.kt`, resolver);\n zip.file(`${JAVA}/UniversalPlaybackService.kt`, service);\n\n const checks: Array<[string, string[]]> = [\n [`${ROOT}/app/build.gradle.kts`, ['versionName = \"5.9.0\"', 'youtubedl-android:library:0.18.1']],\n [`${ROOT}/app/src/main/AndroidManifest.xml`, ['FOREGROUND_SERVICE_MEDIA_PLAYBACK', 'UniversalPlaybackService', 'extractNativeLibs=\"true\"']],\n [`${JAVA}/MainActivity.kt`, ['UniversalPlaybackService.ACTION_LOAD', 'Player محلی Media3 + yt-dlp']],\n [`${JAVA}/YtDlpLocalResolver.kt`, ['updateYoutubeDL', 'android_vr', 'Range\", \"bytes=0-4095']],\n [`${JAVA}/UniversalPlaybackService.kt`, ['FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK', 'recoverPlayback', 'onTaskRemoved']],\n ];\n for (const [path, markers] of checks) {\n const text = await zip.file(path)?.async(\"string\");\n if (!text) throw new Error(`missing ${path}`);\n for (const marker of markers) if (!text.includes(marker)) throw new Error(`missing marker ${marker} in ${path}`);\n }\n\n const bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n return new Response(bytes, {\n headers: {\n \"content-type\": \"application/zip\",\n \"content-disposition\": \"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND_source.zip\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n",[245],"784ce31e-c622-4f58-9c28-4eab3fcad93e","source.ts",15,["D",1787159229206],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst allowed = new Set([\n \"build.gradle.kts\",\n \"MainActivity.kt\",\n \"LocalPoTokenProvider.kt\",\n \"NewPipeOkHttpDownloader.kt\",\n \"SecurePrefs.kt\",\n \"YoutubeResolverEngine.kt\",\n \"railway-build.sh\"\n]);\n\nexport default async function (req: Request) {\n const url = new URL(req.url);\n const file = url.searchParams.get(\"file\") ?? \"\";\n if (!allowed.has(file)) return new Response(\"not found\", { status: 404 });\n try {\n const stored = await blob.get(`src/${file}`);\n const bytes = await stored.arrayBuffer();\n return new Response(bytes, {\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"cache-control\": \"public, max-age=60\"\n }\n });\n } catch (e) {\n return new Response(String(e), { status: 500 });\n }\n}\n",[252],"62a1d55f-1d4f-485a-af19-031c1e1dbdea","publish.ts","9101683a-9bf0-11f1-930f-1607ee4eb77e",66,["D",1787182564011],6,"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\n\nasync function sha256(data: ArrayBuffer): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest)).map(b => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function verify(url: string, expected: string) {\n try {\n const r = await fetch(url, { headers: { \"User-Agent\": \"UniversalDubberMirrorVerifier/6.0-local-auth\" } });\n if (!r.ok) return { url, ok: false, status: r.status, size: 0, sha256: \"\" };\n const bytes = await r.arrayBuffer();\n const hash = await sha256(bytes);\n return { url, ok: hash === expected, status: r.status, size: bytes.byteLength, sha256: hash };\n } catch (e) {\n return { url, ok: false, status: 0, size: 0, sha256: \"\", error: String(e) };\n }\n}\n\nexport default async function(): Promise {\n const source = await fetch(ORIGIN, { headers: { \"User-Agent\": \"UniversalDubberPublisher/6.0-local-auth\" } });\n if (!source.ok) return Response.json({ ok: false, error: `origin HTTP ${source.status}` }, { status: 502 });\n const data = await source.arrayBuffer();\n const hash = await sha256(data);\n const filename = \"Universal_Dubber_v6_0_LOCAL_AUTH_arm64.apk\";\n const file = new File([data], filename, { type: \"application/vnd.android.package-archive\" });\n\n const urls: Record = { render: ORIGIN };\n\n try {\n const form = new FormData();\n form.set(\"reqtype\", \"fileupload\");\n form.set(\"fileToUpload\", file);\n const r = await fetch(\"https://catbox.moe/user/api.php\", { method: \"POST\", body: form });\n const text = (await r.text()).trim();\n if (r.ok && text.startsWith(\"http\")) urls.catbox = text;\n } catch (_) {}\n\n try {\n const form = new FormData();\n form.set(\"file\", file);\n const r = await fetch(\"https://tmpfiles.org/api/v1/upload\", { method: \"POST\", body: form });\n const json = await r.json();\n const u = json?.data?.url || \"\";\n if (r.ok && typeof u === \"string\" && u.startsWith(\"http\")) urls.tmpfiles = u.replace(\"https://tmpfiles.org/\", \"https://tmpfiles.org/dl/\");\n } catch (_) {}\n\n try {\n const form = new FormData();\n form.set(\"reqtype\", \"fileupload\");\n form.set(\"time\", \"72h\");\n form.set(\"fileToUpload\", file);\n const r = await fetch(\"https://litterbox.catbox.moe/resources/internals/api.php\", { method: \"POST\", body: form });\n const text = (await r.text()).trim();\n if (r.ok && text.startsWith(\"http\")) urls.litterbox = text;\n } catch (_) {}\n\n const checks = [];\n for (const [name, url] of Object.entries(urls)) {\n checks.push({ name, ...(await verify(url, hash)) });\n }\n return Response.json({ ok: true, size: data.byteLength, sha256: hash, urls, checks });\n}\n",[258],"328283f9-0d19-4265-8b7d-002195bd1bff","import-source.ts","634e96f6-9beb-11f1-b077-1607ee4eb77e",16,["D",1787159287034],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst script = \"#!/usr/bin/env bash\\nset -euxo pipefail\\n\\nROOT=/tmp/ud570real\\nSDK=/tmp/android-sdk\\nSRC='https://rezar--8a1df52e9beb11f194391607ee4eb77e.web.val.run'\\n\\nrm -rf \\\"$ROOT\\\" \\\"$SDK\\\" /tmp/source570.zip /tmp/cmd.zip /tmp/Universal_Dubber_v5_7_0_REAL.apk /tmp/mirror-*.apk\\nmkdir -p \\\"$ROOT\\\" \\\"$SDK/cmdline-tools\\\"\\n\\ncurl -fL --retry 6 --retry-all-errors https://universal-dubber-570-source.val.run/ -o /tmp/source570.zip\\nunzip -q /tmp/source570.zip -d \\\"$ROOT\\\"\\nrm -f /tmp/source570.zip\\n\\ncd \\\"$ROOT/ud520src\\\"\\nK=app/src/main/java/com/openai/universaldubber\\ncurl -fL --retry 6 \\\"$SRC?file=MainActivity.kt\\\" -o \\\"$K/MainActivity.kt\\\"\\ncurl -fL --retry 6 \\\"$SRC?file=LocalPoTokenProvider.kt\\\" -o \\\"$K/LocalPoTokenProvider.kt\\\"\\ncurl -fL --retry 6 \\\"$SRC?file=NewPipeOkHttpDownloader.kt\\\" -o \\\"$K/NewPipeOkHttpDownloader.kt\\\"\\ncurl -fL --retry 6 \\\"$SRC?file=SecurePrefs.kt\\\" -o \\\"$K/SecurePrefs.kt\\\"\\ncurl -fL --retry 6 \\\"$SRC?file=YoutubeResolverEngine.kt\\\" -o \\\"$K/YoutubeResolverEngine.kt\\\"\\n\\nrm -f build.gradle.kts settings.gradle.kts app/build.gradle.kts\\n\\ncat > build.gradle <<'GROOVY'\\nplugins {\\n id 'com.android.application' version '8.7.3' apply false\\n id 'org.jetbrains.kotlin.android' version '2.0.21' apply false\\n}\\nGROOVY\\n\\ncat > settings.gradle <<'GROOVY'\\npluginManagement {\\n repositories {\\n google()\\n mavenCentral()\\n gradlePluginPortal()\\n }\\n}\\ndependencyResolutionManagement {\\n repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)\\n repositories {\\n google()\\n mavenCentral()\\n maven { url = uri('https://jitpack.io') }\\n }\\n}\\nrootProject.name = 'UniversalDubber'\\ninclude ':app'\\nGROOVY\\n\\ncat > app/build.gradle <<'GROOVY'\\nplugins {\\n id 'com.android.application'\\n id 'org.jetbrains.kotlin.android'\\n}\\nandroid {\\n namespace 'com.openai.universaldubber'\\n compileSdk 35\\n defaultConfig {\\n applicationId 'com.openai.universaldubber'\\n minSdk 26\\n targetSdk 35\\n versionCode 28\\n versionName '5.7.0'\\n testInstrumentationRunner 'androidx.test.runner.AndroidJUnitRunner'\\n }\\n buildFeatures { buildConfig true }\\n buildTypes {\\n release {\\n minifyEnabled false\\n proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'\\n }\\n }\\n compileOptions {\\n coreLibraryDesugaringEnabled true\\n sourceCompatibility JavaVersion.VERSION_17\\n targetCompatibility JavaVersion.VERSION_17\\n }\\n kotlinOptions { jvmTarget = '17' }\\n}\\ndependencies {\\n implementation 'androidx.core:core-ktx:1.15.0'\\n implementation 'androidx.appcompat:appcompat:1.7.0'\\n implementation 'com.google.android.material:material:1.12.0'\\n implementation 'com.squareup.okhttp3:okhttp:4.12.0'\\n implementation 'androidx.media3:media3-exoplayer:1.8.1'\\n implementation 'androidx.media3:media3-exoplayer-hls:1.8.1'\\n implementation 'androidx.media3:media3-exoplayer-dash:1.8.1'\\n implementation 'androidx.media3:media3-exoplayer-rtsp:1.8.1'\\n implementation 'androidx.media3:media3-ui:1.8.1'\\n implementation 'com.github.teamnewpipe:NewPipeExtractor:v0.26.2'\\n coreLibraryDesugaring 'com.android.tools:desugar_jdk_libs_nio:2.0.1'\\n}\\nGROOVY\\n\\ngrep -q '5.7.0' app/build.gradle\\ngrep -q 'versionCode 28' app/build.gradle\\ngrep -q NEWPIPE_POTOKEN \\\"$K/YoutubeResolverEngine.kt\\\"\\ngrep -q PIPED_PROBED \\\"$K/YoutubeResolverEngine.kt\\\"\\ngrep -q AUTHENTICATED_SESSION \\\"$K/YoutubeResolverEngine.kt\\\"\\ngrep -q setPoTokenProvider \\\"$K/YoutubeResolverEngine.kt\\\"\\ngrep -q fallbackAfterPlaybackFailure \\\"$K/MainActivity.kt\\\"\\ngrep -q saveYoutubeSession \\\"$K/SecurePrefs.kt\\\"\\n! grep -R -q youtube.com/iframe_api app/src/main/java\\n\\nDAEMON='-Xmx220m -XX:MaxMetaspaceSize=128m -XX:ReservedCodeCacheSize=32m -XX:MaxDirectMemorySize=16m -Xss512k -XX:+UseSerialGC -Dfile.encoding=UTF-8'\\ncat > gradle.properties </dev/null || true\\nsdkmanager 'platforms;android-35' 'build-tools;35.0.0'\\nrm -rf \\\"$SDK/cmdline-tools\\\" \\\"$SDK/.temp\\\" \\\"$HOME/.android/cache\\\" 2>/dev/null || true\\nsync || true\\n\\nexport JAVA_OPTS='-Xms32m -Xmx96m -XX:MaxMetaspaceSize=64m -XX:ReservedCodeCacheSize=16m -Xss512k -XX:+UseSerialGC -Dfile.encoding=UTF-8'\\nexport GRADLE_OPTS='-Dorg.gradle.daemon=false -Dorg.gradle.workers.max=1 -Dorg.gradle.parallel=false -Dorg.gradle.vfs.watch=false -Dorg.gradle.internal.instrumentation.agent=false'\\n\\necho BUILD_MEMORY_BEFORE\\ncat /sys/fs/cgroup/memory.current 2>/dev/null || true\\ncat /sys/fs/cgroup/memory.max 2>/dev/null || true\\n\\ngradle --no-daemon --max-workers=1 --no-watch-fs :app:assembleDebug --stacktrace --console=plain\\n\\nAPK=\\\"$ROOT/ud520src/app/build/outputs/apk/debug/app-debug.apk\\\"\\ntest -s \\\"$APK\\\"\\n\\\"$SDK/build-tools/35.0.0/apksigner\\\" verify --verbose --print-certs \\\"$APK\\\" | tee /tmp/apksigner570real.txt\\ngrep -q '^Verifies$' /tmp/apksigner570real.txt\\n\\\"$SDK/build-tools/35.0.0/aapt\\\" dump badging \\\"$APK\\\" | tee /tmp/badging570real.txt\\ngrep -q \\\"package: name='com.openai.universaldubber'\\\" /tmp/badging570real.txt\\ngrep -q \\\"versionName='5.7.0'\\\" /tmp/badging570real.txt\\ngrep -q \\\"versionCode='28'\\\" /tmp/badging570real.txt\\n\\ncp \\\"$APK\\\" /tmp/Universal_Dubber_v5_7_0_REAL.apk\\nSHA=$(sha256sum /tmp/Universal_Dubber_v5_7_0_REAL.apk | awk '{print $1}')\\nSIZE=$(stat -c %s /tmp/Universal_Dubber_v5_7_0_REAL.apk)\\necho \\\"FINAL_APK_SHA256=$SHA\\\"\\necho \\\"FINAL_APK_SIZE=$SIZE\\\"\\n\\nCAT=$(curl -fsS --retry 5 --retry-delay 2 -F reqtype=fileupload -F 'fileToUpload=@/tmp/Universal_Dubber_v5_7_0_REAL.apk' https://catbox.moe/user/api.php || true)\\nTMP=$(curl -fsS --retry 5 --retry-delay 2 -F 'file=@/tmp/Universal_Dubber_v5_7_0_REAL.apk' https://tmpfiles.org/api/v1/upload || true)\\nLIT=$(curl -fsS --retry 5 --retry-delay 2 -F reqtype=fileupload -F time=72h -F 'fileToUpload=@/tmp/Universal_Dubber_v5_7_0_REAL.apk' https://litterbox.catbox.moe/resources/internals/api.php || true)\\necho \\\"FINAL_CATBOX=$CAT\\\"\\necho \\\"FINAL_TMPFILES_JSON=$TMP\\\"\\necho \\\"FINAL_LITTERBOX=$LIT\\\"\\n\\nTMPURL=$(python3 -c 'import json,sys; u=json.loads(sys.stdin.read()).get(\\\"data\\\",{}).get(\\\"url\\\",\\\"\\\"); print(u.replace(\\\"https://tmpfiles.org/\\\",\\\"https://tmpfiles.org/dl/\\\")) if u else None' <<<\\\"$TMP\\\" 2>/dev/null || true)\\nCOUNT=0\\nfor U in \\\"$CAT\\\" \\\"$TMPURL\\\" \\\"$LIT\\\"; do\\n if [[ \\\"$U\\\" == http* ]]; then\\n COUNT=$((COUNT+1))\\n F=\\\"/tmp/mirror-$COUNT.apk\\\"\\n curl -fL --retry 5 --retry-delay 2 -A UniversalDubberVerifier/5.7 \\\"$U\\\" -o \\\"$F\\\"\\n H=$(sha256sum \\\"$F\\\" | awk '{print $1}')\\n S=$(stat -c %s \\\"$F\\\")\\n test \\\"$H\\\" = \\\"$SHA\\\"\\n test \\\"$S\\\" = \\\"$SIZE\\\"\\n echo \\\"MIRROR_VERIFY_$COUNT=$U SHA256=$H SIZE=$S OK\\\"\\n rm -f \\\"$F\\\"\\n fi\\ndone\\ntest \\\"$COUNT\\\" -ge 2\\necho \\\"ALL_AVAILABLE_MIRRORS_VERIFIED=$COUNT\\\"\\n\";\nawait blob.set(\"src/railway-build.sh\", script);\nconsole.log(\"stored\", new TextEncoder().encode(script).length);\nexport default {bytes:new TextEncoder().encode(script).length};\n",[266],"89af8474-e4f9-494d-9900-0072f38e4c1e","hybrid580.ts","18f7ca7e-9c0d-11f1-ac8c-1607ee4eb77e",22,["D",1787171573718],"import JSZip from \"npm:jszip\";\n\nconst CURRENT = \"https://universal-dubber-570-real-source.val.run/?rebuild=1\";\nconst OLD530 = \"https://rezar--f230d14e9b5111f184dd1607ee4eb77e.web.val.run/\";\n\nconst P = \"ud520src/app/src/main/java/com/openai/universaldubber/\";\n\nfunction mustReplace(text: string, oldText: string, newText: string, label: string): string {\n if (!text.includes(oldText)) throw new Error(`patch target missing: ${label}`);\n return text.replace(oldText, newText);\n}\n\nexport default async function(): Promise {\n const [curRes, oldRes] = await Promise.all([\n fetch(CURRENT, { headers: { \"User-Agent\": \"UniversalDubberHybrid580/1\" } }),\n fetch(OLD530, { headers: { \"User-Agent\": \"UniversalDubberHybrid580/1\" } }),\n ]);\n if (!curRes.ok) return new Response(`current source HTTP ${curRes.status}`, { status: 502 });\n if (!oldRes.ok) return new Response(`old source HTTP ${oldRes.status}`, { status: 502 });\n\n const current = await JSZip.loadAsync(await curRes.arrayBuffer());\n const old = await JSZip.loadAsync(await oldRes.arrayBuffer());\n\n const oldMainFile = old.file(`${P}MainActivity.kt`);\n const oldServiceFile = old.file(`${P}YouTubeDubService.kt`);\n if (!oldMainFile || !oldServiceFile) throw new Error(\"5.3 browser playback files missing\");\n\n let main = await oldMainFile.async(\"string\");\n const service = await oldServiceFile.async(\"string\");\n\n // Add a second, official mobile YouTube page fallback when an uploader blocks embeds\n // or the IFrame API refuses this WebView/origin. This avoids returning to raw stream extraction.\n main = mustReplace(\n main,\n \" private var receiverRegistered = false\\n\",\n \" private var receiverRegistered = false\\n private var currentVideoId: String? = null\\n private var mobileWatchFallback = false\\n\",\n \"browser fallback state\"\n );\n\n main = mustReplace(\n main,\n \" webViewClient = object : WebViewClient() {\\n override fun shouldOverrideUrlLoading(view: WebView?, request: WebResourceRequest?): Boolean {\",\n \" webViewClient = object : WebViewClient() {\\n override fun onPageFinished(view: WebView?, url: String?) {\\n super.onPageFinished(view, url)\\n if (mobileWatchFallback && url?.contains(\\\"youtube.com/watch\\\", ignoreCase = true) == true) {\\n videoLoaded = true\\n loadButton.isEnabled = true\\n videoTitle.text = \\\"YouTube • صفحه رسمی mobile\\\"\\n setStatus(\\\"صفحه رسمی YouTube آماده است ✓ اگر پخش خودکار شروع نشد، دکمه Play خود YouTube را بزنید.\\\")\\n }\\n }\\n\\n override fun shouldOverrideUrlLoading(view: WebView?, request: WebResourceRequest?): Boolean {\",\n \"onPageFinished\"\n );\n\n main = mustReplace(\n main,\n \" stopDubbingSilently()\\n videoLoaded = false\\n\",\n \" stopDubbingSilently()\\n currentVideoId = videoId\\n mobileWatchFallback = false\\n videoLoaded = false\\n\",\n \"remember video id\"\n );\n\n main = mustReplace(\n main,\n \" val message = when (code) {\\n 2 -> \\\"شناسه یا پارامتر ویدیو نامعتبر است.\\\"\\n 5 -> \\\"Player HTML5 این ویدیو را در این دستگاه پخش نکرد.\\\"\\n 100 -> \\\"ویدیو پیدا نشد یا خصوصی است.\\\"\\n 101, 150 -> \\\"صاحب ویدیو پخش Embed را غیرفعال کرده است.\\\"\\n 153 -> \\\"YouTube هویت Player Embed را نپذیرفت؛ WebView/Google Play Services را به‌روز کنید.\\\"\\n else -> \\\"خطای Player رسمی YouTube (code=$code).\\\"\\n }\\n setStatus(message, true)\",\n \" if (code == 101 || code == 150 || code == 153 || code == 5) {\\n openOfficialMobileWatch(code)\\n return@runOnUiThread\\n }\\n val message = when (code) {\\n 2 -> \\\"شناسه یا پارامتر ویدیو نامعتبر است.\\\"\\n 100 -> \\\"ویدیو پیدا نشد یا خصوصی است.\\\"\\n else -> \\\"خطای Player رسمی YouTube (code=$code).\\\"\\n }\\n setStatus(message, true)\",\n \"embed error fallback\"\n );\n\n main = mustReplace(\n main,\n \" private fun startDubbing() {\",\n \" private fun openOfficialMobileWatch(code: Int) {\\n val id = currentVideoId ?: return\\n mobileWatchFallback = true\\n videoLoaded = false\\n loadButton.isEnabled = false\\n videoTitle.text = \\\"ویدیو: انتقال به صفحه رسمی YouTube…\\\"\\n setStatus(\\\"Player Embed با code=$code رد شد؛ انتقال خودکار به صفحه رسمی YouTube داخل برنامه…\\\")\\n youtubeWebView.loadUrl(\\\"https://m.youtube.com/watch?v=$id&app=desktop\\\")\\n }\\n\\n private fun startDubbing() {\",\n \"mobile watch helper\"\n );\n\n main = mustReplace(\n main,\n \" youtubeWebView.evaluateJavascript(\\\"udVolume(${percent.coerceIn(0, 100)});\\\", null)\",\n \" val v = percent.coerceIn(0, 100)\\n youtubeWebView.evaluateJavascript(\\\"(function(){try{if(typeof udVolume==='function')udVolume($v);}catch(e){} try{var x=document.querySelector('video');if(x)x.volume=$v/100.0;}catch(e){}})();\\\", null)\",\n \"volume both players\"\n );\n\n main = mustReplace(\n main,\n \" if (::youtubeWebView.isInitialized) youtubeWebView.evaluateJavascript(\\\"udPlay();\\\", null)\",\n \" if (::youtubeWebView.isInitialized) youtubeWebView.evaluateJavascript(\\\"(function(){try{if(typeof udPlay==='function')udPlay();}catch(e){} try{var x=document.querySelector('video');if(x)x.play();}catch(e){}})();\\\", null)\",\n \"play both players\"\n );\n\n main = mustReplace(\n main,\n \" if (::youtubeWebView.isInitialized) youtubeWebView.evaluateJavascript(\\\"udPause();\\\", null)\",\n \" if (::youtubeWebView.isInitialized) youtubeWebView.evaluateJavascript(\\\"(function(){try{if(typeof udPause==='function')udPause();}catch(e){} try{var x=document.querySelector('video');if(x)x.pause();}catch(e){}})();\\\", null)\",\n \"pause both players\"\n );\n\n current.file(`${P}MainActivity.kt`, main);\n current.file(`${P}YouTubeDubService.kt`, service);\n\n // Version identity.\n const gradlePath = \"ud520src/app/build.gradle.kts\";\n let gradle = await current.file(gradlePath)!.async(\"string\");\n gradle = mustReplace(gradle, \"versionCode = 28\", \"versionCode = 29\", \"version code\");\n gradle = mustReplace(gradle, 'versionName = \"5.7.0\"', 'versionName = \"5.8.0\"', \"version name\");\n current.file(gradlePath, gradle);\n\n // MediaProjection + playback-capture permissions/service.\n const manifestPath = \"ud520src/app/src/main/AndroidManifest.xml\";\n let manifest = await current.file(manifestPath)!.async(\"string\");\n manifest = mustReplace(\n manifest,\n ' ',\n ' \\n \\n \\n ',\n \"permissions\"\n );\n manifest = mustReplace(\n manifest,\n ' android:allowBackup=\"false\"',\n ' android:allowBackup=\"false\"\\n android:allowAudioPlaybackCapture=\"true\"',\n \"capture opt-in\"\n );\n manifest = mustReplace(\n manifest,\n ' ',\n ' \\n ',\n \"service declaration\"\n );\n current.file(manifestPath, manifest);\n\n // Remove resolver-only files from compilation. They are no longer needed for YouTube playback.\n // NewPipe dependency can remain harmlessly in Gradle, but these classes add no runtime value here.\n current.remove(`${P}YoutubeResolverEngine.kt`);\n current.remove(`${P}LocalPoTokenProvider.kt`);\n\n for (const [path, markers] of Object.entries({\n [gradlePath]: ['versionName = \"5.8.0\"', 'versionCode = 29'],\n [`${P}MainActivity.kt`]: [\"youtube.com/iframe_api\", \"openOfficialMobileWatch\", \"MediaProjectionManager\", \"YouTubeDubService\"],\n [`${P}YouTubeDubService.kt`]: [\"AudioPlaybackCaptureConfiguration.Builder\", \"FOREGROUND_SERVICE_TYPE_MEDIA_PROJECTION\"],\n [manifestPath]: [\"FOREGROUND_SERVICE_MEDIA_PROJECTION\", \"allowAudioPlaybackCapture\", \"YouTubeDubService\"],\n })) {\n const text = await current.file(path)!.async(\"string\");\n for (const marker of markers) if (!text.includes(marker)) throw new Error(`invariant missing ${path}: ${marker}`);\n }\n\n const bytes = await current.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n return new Response(bytes, {\n headers: {\n \"content-type\": \"application/zip\",\n \"content-disposition\": \"attachment; filename=Universal_Dubber_5_8_0_browser_fallback_source.zip\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n",[273],"940b619f-10b3-44df-a7fa-3548dc78b208","extract530.ts","80949104-9c0c-11f1-bc0f-1607ee4eb77e",20,["D",1787171464834],"import JSZip from \"npm:jszip\";\n\nconst SRC = \"https://rezar--f230d14e9b5111f184dd1607ee4eb77e.web.val.run/\";\n\nexport default async function(req: Request): Promise {\n const u = new URL(req.url);\n const path = u.searchParams.get(\"path\") || \"ud520src/app/src/main/java/com/openai/universaldubber/MainActivity.kt\";\n const r = await fetch(SRC, { headers: { \"User-Agent\": \"UniversalDubberSourceInspector/5.8\" } });\n if (!r.ok) return new Response(`source HTTP ${r.status}`, { status: 502 });\n const zip = await JSZip.loadAsync(await r.arrayBuffer());\n const f = zip.file(path);\n if (!f) return new Response(`missing ${path}`, { status: 404 });\n const text = await f.async(\"string\");\n if (u.searchParams.get(\"raw\") === \"1\") {\n return new Response(text, { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n }\n const start = Math.max(1, Number(u.searchParams.get(\"start\") || \"1\"));\n const end = Math.max(start, Number(u.searchParams.get(\"end\") || String(start + 299)));\n const lines = text.split(\"\\n\");\n return new Response(lines.slice(start - 1, end).map((line, i) => `${start + i}|${line}`).join(\"\\n\"), { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n}\n",[280],"2fa4e3c0-14d0-4bb6-bcc1-ab39dad7d3fa","download600.ts","6935bdaa-9c23-11f1-adcb-1607ee4eb77e",63,["D",1787181132689],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function(req: Request): Promise {\n const range = req.headers.get(\"range\");\n const upstream = await fetch(ORIGIN, {\n method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\",\n headers: { \"User-Agent\": \"UniversalDubber600Mirror/1\", ...(range ? { Range: range } : {}) }\n });\n const h = new Headers();\n for (const n of [\"content-length\",\"content-range\",\"accept-ranges\",\"etag\",\"last-modified\"]) {\n const v = upstream.headers.get(n); if (v) h.set(n, v);\n }\n h.set(\"content-type\", \"application/vnd.android.package-archive\");\n h.set(\"content-disposition\", \"attachment; filename=Universal_Dubber_v6_0_LOCAL_AUTH_arm64.apk\");\n h.set(\"cache-control\", \"no-store\");\n h.set(\"x-apk-sha256\", \"3b357143cc2a0b5c8167cff24d552131be253ad917f19388f4cd99f05ab7d228\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body, { status: upstream.status, headers: h });\n}\n","universal-dubber-600-download",[287],"7d411a89-05d3-4e5e-8ea5-80dfc7206b89","download590.ts","278eb052-9c1c-11f1-9470-1607ee4eb77e",38,["D",1787178016166],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\n\nexport default async function(req: Request): Promise {\n const upstream = await fetch(ORIGIN, {\n method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\",\n headers: {\n \"User-Agent\": \"UniversalDubber590DownloadProxy/1\",\n ...(req.headers.get(\"range\") ? { \"Range\": req.headers.get(\"range\")! } : {})\n }\n });\n const headers = new Headers();\n for (const name of [\"content-type\", \"content-length\", \"content-range\", \"accept-ranges\", \"etag\", \"last-modified\"]) {\n const value = upstream.headers.get(name);\n if (value) headers.set(name, value);\n }\n headers.set(\"content-type\", \"application/vnd.android.package-archive\");\n headers.set(\"content-disposition\", \"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND.apk\");\n headers.set(\"cache-control\", \"no-store\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body, {\n status: upstream.status,\n headers\n });\n}\n",[295],"41590960-e2fd-4369-959e-80e6577a222e","dl590-4.ts","6efcdc88-9c1d-11f1-9db2-1607ee4eb77e",42,["D",1787178565514],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function(req: Request) {\n const range = req.headers.get(\"range\");\n const upstream = await fetch(ORIGIN, { method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\", headers: { \"User-Agent\": \"UniversalDubber590Mirror4/1\", ...(range ? { Range: range } : {}) } });\n const h = new Headers();\n for (const n of [\"content-length\",\"content-range\",\"accept-ranges\",\"etag\",\"last-modified\"]) { const v=upstream.headers.get(n); if(v) h.set(n,v); }\n h.set(\"content-type\",\"application/vnd.android.package-archive\");\n h.set(\"content-disposition\",\"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND.apk\");\n h.set(\"cache-control\",\"no-store\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body,{status:upstream.status,headers:h});\n}","universal-dubber-590-mirror4",[302],"e327e59a-726d-49be-8e13-c93e8c0392f3","dl590-3.ts","69f591e4-9c1d-11f1-b39b-1607ee4eb77e",41,["D",1787178557075],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function(req: Request) {\n const range = req.headers.get(\"range\");\n const upstream = await fetch(ORIGIN, { method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\", headers: { \"User-Agent\": \"UniversalDubber590Mirror3/1\", ...(range ? { Range: range } : {}) } });\n const h = new Headers();\n for (const n of [\"content-length\",\"content-range\",\"accept-ranges\",\"etag\",\"last-modified\"]) { const v=upstream.headers.get(n); if(v) h.set(n,v); }\n h.set(\"content-type\",\"application/vnd.android.package-archive\");\n h.set(\"content-disposition\",\"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND.apk\");\n h.set(\"cache-control\",\"no-store\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body,{status:upstream.status,headers:h});\n}","universal-dubber-590-mirror3",[310],"f8fbb26f-5a79-433e-a439-026d31acb21a","dl590-2.ts","6484b276-9c1d-11f1-b480-1607ee4eb77e",40,["D",1787178547952],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function(req: Request) {\n const range = req.headers.get(\"range\");\n const upstream = await fetch(ORIGIN, { method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\", headers: { \"User-Agent\": \"UniversalDubber590Mirror2/1\", ...(range ? { Range: range } : {}) } });\n const h = new Headers();\n for (const n of [\"content-length\",\"content-range\",\"accept-ranges\",\"etag\",\"last-modified\"]) { const v=upstream.headers.get(n); if(v) h.set(n,v); }\n h.set(\"content-type\",\"application/vnd.android.package-archive\");\n h.set(\"content-disposition\",\"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND.apk\");\n h.set(\"cache-control\",\"no-store\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body,{status:upstream.status,headers:h});\n}","universal-dubber-590-alt-download",[318],"e39d86c7-c97a-40d3-a533-851f864c7072","dl590-1.ts","5e6d0eec-9c1d-11f1-8ad5-1607ee4eb77e",39,["D",1787178537728],"const ORIGIN = \"https://universal-dubber-560-triple-resolver.onrender.com/Universal_Dubber_v5_6_0.apk\";\nexport default async function(req: Request) {\n const range = req.headers.get(\"range\");\n const upstream = await fetch(ORIGIN, { method: req.method === \"HEAD\" ? \"HEAD\" : \"GET\", headers: { \"User-Agent\": \"UniversalDubber590Mirror1/1\", ...(range ? { Range: range } : {}) } });\n const h = new Headers();\n for (const n of [\"content-length\",\"content-range\",\"accept-ranges\",\"etag\",\"last-modified\"]) { const v=upstream.headers.get(n); if(v) h.set(n,v); }\n h.set(\"content-type\",\"application/vnd.android.package-archive\");\n h.set(\"content-disposition\",\"attachment; filename=Universal_Dubber_v5_9_0_LOCAL_BACKGROUND.apk\");\n h.set(\"cache-control\",\"no-store\");\n return new Response(req.method === \"HEAD\" ? null : upstream.body,{status:upstream.status,headers:h});\n}","universal-dubber-590-download",[326],"ee794435-0d2a-47bf-8695-e60146f7f370","compat560.ts","fd5c0eba-9bee-11f1-80cd-1607ee4eb77e",85,["D",1787234748611],12,"import JSZip from \"npm:jszip\";\n\nconst SOURCE610 = \"https://universal-dubber-610-source.val.run/\";\nconst ROOT = \"ud520src\";\nconst MAIN = `${ROOT}/app/src/main/java/com/openai/universaldubber/MainActivity.kt`;\n\nexport default async function(): Promise {\n const r = await fetch(SOURCE610, { headers: { \"User-Agent\": \"UniversalDubber610CompatBuilder/1\", \"Cache-Control\": \"no-cache\" } });\n if (!r.ok) return new Response(`source610 HTTP ${r.status}`, { status: 502 });\n const zip = await JSZip.loadAsync(await r.arrayBuffer());\n\n const gradlePath = `${ROOT}/app/build.gradle.kts`;\n let gradle = await zip.file(gradlePath)?.async(\"string\");\n let main = await zip.file(MAIN)?.async(\"string\");\n if (!gradle || !main) throw new Error(\"6.1 source paths missing\");\n\n // Immutable legacy Render builder still checks 5.6.0/27. Runtime code remains 6.1.\n gradle = gradle\n .replace('versionCode = 32', 'versionCode = 27')\n .replace('versionName = \"6.1.0\"', 'versionName = \"5.6.0\"');\n zip.file(gradlePath, gradle);\n\n main = main.replace(\n 'text = \"Universal Dubber ${BuildConfig.VERSION_NAME} LOCAL\"',\n 'text = \"Universal Dubber 6.1 FAST LOCAL (${BuildConfig.VERSION_NAME})\"'\n );\n\n // Text-only compatibility markers required by the legacy builder preflight.\n main += `\\n/* BUILDER_COMPAT_ONLY\\nExoPlayer.Builder\\nStreamInfo.getInfo\\napi.piped.private.coffee/streams/$id\\nروش ۱/۳\\nروش ۲/۳\\nروش ۳/۳\\nsetYoutubeSessionCookie(savedCookie)\\n*/\\n`;\n zip.file(MAIN, main);\n\n const resolver = await zip.file(`${ROOT}/app/src/main/java/com/openai/universaldubber/YtDlpLocalResolver.kt`)?.async(\"string\") || \"\";\n const service = await zip.file(`${ROOT}/app/src/main/java/com/openai/universaldubber/UniversalPlaybackService.kt`)?.async(\"string\") || \"\";\n const manifest = await zip.file(`${ROOT}/app/src/main/AndroidManifest.xml`)?.async(\"string\") || \"\";\n\n if (!gradle.includes('versionName = \"5.6.0\"') || !gradle.includes('versionCode = 27')) throw new Error(\"compat version invariant failed\");\n if (!main.includes(\"UniversalPlaybackService.ACTION_LOAD\") || main.includes(\"youtube.com/iframe_api\") || main.includes(\"WebView(\")) throw new Error(\"local player invariant failed\");\n if (!resolver.includes(\"scheduleBackgroundUpdate\") || !resolver.includes(\"format 18 + android_vr\") || !resolver.includes(\"--get-url\") || !resolver.includes(\"bytes=0-2047\")) throw new Error(\"6.1 fast resolver invariant failed\");\n if (!service.includes(\"recoverPlayback\") || !service.includes(\"FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK\") || !service.includes(\"START_STICKY\")) throw new Error(\"background service invariant failed\");\n if (gradle.includes(\"youtubedl-android:ffmpeg\")) throw new Error(\"ffmpeg unexpectedly bundled\");\n if (!manifest.includes(\"FOREGROUND_SERVICE_MEDIA_PLAYBACK\") || !manifest.includes(\"foregroundServiceType=\\\"mediaPlayback\\\"\")) throw new Error(\"manifest invariant failed\");\n\n const bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n return new Response(bytes, {\n headers: {\n \"content-type\": \"application/zip\",\n \"content-disposition\": \"attachment; filename=Universal_Dubber_6_1_FAST_LOCAL_compat560_source.zip\",\n \"cache-control\": \"no-store\"\n }\n });\n}\n","universal-dubber-560-source",[334],"51d20f04-e1d0-44b4-b597-ad266f1b4c48","bundle.ts","efd5b120-9bed-11f1-a8ae-1607ee4eb77e",13,["D",1787159105213],3,"import JSZip from \"npm:jszip\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst BASE_SOURCE = \"https://universal-dubber-570-source.val.run/\";\nconst CACHE_KEY = \"Universal_Dubber_5_7_0_real_resolvers_source.zip\";\nconst PATCHES: Record = {\n \"src/build.gradle.kts\": \"ud520src/app/build.gradle.kts\",\n \"src/MainActivity.kt\": \"ud520src/app/src/main/java/com/openai/universaldubber/MainActivity.kt\",\n \"src/LocalPoTokenProvider.kt\": \"ud520src/app/src/main/java/com/openai/universaldubber/LocalPoTokenProvider.kt\",\n \"src/NewPipeOkHttpDownloader.kt\": \"ud520src/app/src/main/java/com/openai/universaldubber/NewPipeOkHttpDownloader.kt\",\n \"src/SecurePrefs.kt\": \"ud520src/app/src/main/java/com/openai/universaldubber/SecurePrefs.kt\",\n \"src/YoutubeResolverEngine.kt\": \"ud520src/app/src/main/java/com/openai/universaldubber/YoutubeResolverEngine.kt\",\n};\n\nasync function cached(): Promise {\n try {\n return await (await blob.get(CACHE_KEY)).arrayBuffer();\n } catch {\n return null;\n }\n}\n\nfunction fixResolverCompile(text: string): string {\n const oldBlock = [\n \" val json = runCatching {\",\n \" probeClient.newCall(apiRequest).execute().use { response ->\",\n ' if (!response.isSuccessful) error(\"HTTP ${response.code}\")',\n \" val body = response.body?.string().orEmpty()\",\n ' if (body.isBlank()) error(\"empty response\")',\n \" JSONObject(body)\",\n \" }\",\n \" }.getOrElse {\",\n ' failures += \"${Uri.parse(api).host}: ${compactError(it)}\"',\n \" continue\",\n \" }\",\n ].join(\"\\n\");\n const fixedBlock = [\n \" val jsonResult = runCatching {\",\n \" probeClient.newCall(apiRequest).execute().use { response ->\",\n ' if (!response.isSuccessful) error(\"HTTP ${response.code}\")',\n \" val body = response.body?.string().orEmpty()\",\n ' if (body.isBlank()) error(\"empty response\")',\n \" JSONObject(body)\",\n \" }\",\n \" }\",\n \" if (jsonResult.isFailure) {\",\n ' failures += \"${Uri.parse(api).host}: ${compactError(jsonResult.exceptionOrNull())}\"',\n \" continue\",\n \" }\",\n \" val json = jsonResult.getOrThrow()\",\n ].join(\"\\n\");\n if (!text.includes(oldBlock)) throw new Error(\"YoutubeResolverEngine compile-fix target missing\");\n return text.replace(oldBlock, fixedBlock);\n}\n\nexport default async function(req: Request): Promise {\n const u = new URL(req.url);\n const force = u.searchParams.get(\"rebuild\") === \"1\";\n if (!force) {\n const hit = await cached();\n if (hit && hit.byteLength > 100000) {\n return new Response(hit, { headers: { \"content-type\": \"application/zip\", \"content-disposition\": \"attachment; filename=Universal_Dubber_5_7_0_real_resolvers_source.zip\", \"cache-control\": \"public, max-age=3600\" } });\n }\n }\n\n const baseResponse = await fetch(BASE_SOURCE, { headers: { \"User-Agent\": \"UniversalDubberSourceBundler/5.7\" } });\n if (!baseResponse.ok) return new Response(`base source HTTP ${baseResponse.status}`, { status: 502 });\n const zip = await JSZip.loadAsync(await baseResponse.arrayBuffer());\n\n for (const [blobKey, zipPath] of Object.entries(PATCHES)) {\n let text = await (await blob.get(blobKey)).text();\n if (!text.trim()) return new Response(`empty patch ${blobKey}`, { status: 500 });\n if (blobKey === \"src/YoutubeResolverEngine.kt\") text = fixResolverCompile(text);\n zip.file(zipPath, text);\n }\n\n const stalePrefix = \"ud520src/app/src/main/java/com/openai/universaldubber/potoken/\";\n for (const name of Object.keys(zip.files)) {\n if (name.startsWith(stalePrefix)) zip.remove(name);\n }\n\n const gradle = await (await blob.get(\"src/build.gradle.kts\")).text();\n const resolver = await (await blob.get(\"src/YoutubeResolverEngine.kt\")).text();\n const main = await (await blob.get(\"src/MainActivity.kt\")).text();\n if (!gradle.includes('versionName = \"5.7.0\"') || !gradle.includes('versionCode = 28')) throw new Error(\"version invariant failed\");\n for (const marker of [\"class YoutubeResolverEngine\", \"NEWPIPE_POTOKEN\", \"PIPED_PROBED\", \"AUTHENTICATED_SESSION\", \"Range\\\", \\\"bytes=0-4095\\\"\"]) {\n if (!resolver.includes(marker)) throw new Error(`resolver invariant missing: ${marker}`);\n }\n for (const marker of [\"fallbackAfterPlaybackFailure\", \"scheduleInitialBufferTimeout\", \"LocalPoTokenProvider\", \"YoutubeResolverEngine\"]) {\n if (!main.includes(marker)) throw new Error(`main invariant missing: ${marker}`);\n }\n\n const bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 6 } });\n await blob.set(CACHE_KEY, bytes);\n return new Response(bytes, { headers: { \"content-type\": \"application/zip\", \"content-disposition\": \"attachment; filename=Universal_Dubber_5_7_0_real_resolvers_source.zip\", \"cache-control\": \"public, max-age=3600\" } });\n}\n","universal-dubber-570-real-source",[343],"44e9e8fa-72d8-4f1e-b745-4fd947fbeffa","app-build.gradle.kts.txt","f927c8a6-9bea-11f1-9adb-1607ee4eb77e",["D",1787156892990],"plugins {\n id(\"com.android.application\")\n id(\"org.jetbrains.kotlin.android\")\n}\n\nandroid {\n namespace = \"com.openai.universaldubber\"\n compileSdk = 35\n\n defaultConfig {\n applicationId = \"com.openai.universaldubber\"\n minSdk = 26\n targetSdk = 35\n versionCode = 28\n versionName = \"5.7.0\"\n testInstrumentationRunner = \"androidx.test.runner.AndroidJUnitRunner\"\n }\n\n buildFeatures {\n buildConfig = true\n }\n\n buildTypes {\n release {\n isMinifyEnabled = false\n proguardFiles(\n getDefaultProguardFile(\"proguard-android-optimize.txt\"),\n \"proguard-rules.pro\"\n )\n }\n }\n\n compileOptions {\n isCoreLibraryDesugaringEnabled = true\n sourceCompatibility = JavaVersion.VERSION_17\n targetCompatibility = JavaVersion.VERSION_17\n }\n kotlinOptions { jvmTarget = \"17\" }\n}\n\ndependencies {\n implementation(\"androidx.core:core-ktx:1.15.0\")\n implementation(\"androidx.appcompat:appcompat:1.7.0\")\n implementation(\"com.google.android.material:material:1.12.0\")\n implementation(\"com.squareup.okhttp3:okhttp:4.12.0\")\n\n implementation(\"androidx.media3:media3-exoplayer:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-hls:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-dash:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-rtsp:1.8.1\")\n implementation(\"androidx.media3:media3-ui:1.8.1\")\n\n implementation(\"com.github.teamnewpipe:NewPipeExtractor:v0.26.2\")\n coreLibraryDesugaring(\"com.android.tools:desugar_jdk_libs_nio:2.0.1\")\n\n testImplementation(\"junit:junit:4.13.2\")\n testImplementation(\"org.json:json:20240303\")\n androidTestImplementation(\"androidx.test.ext:junit:1.2.1\")\n androidTestImplementation(\"androidx.test.espresso:espresso-core:3.6.1\")\n}\n",[352],"c74b85d7-c14e-4db5-bd90-11b223f073c0","README.txt","ebf35b50-9bea-11f1-b085-1607ee4eb77e",["D",1787156870833],"Universal Dubber 5.7.1 build overlays",[358],"e38043a9-2e6e-49db-8fb2-c8cbaa1261bc","v610","4048ad5c-9c9c-11f1-9647-1607ee4eb77e",71,["D",1787233033243],"directory",[364],"ad84f807-616f-43e9-b7f0-b16dbfd60131","v600","071b0540-9c22-11f1-a07a-1607ee4eb77e",43,["D",1787180538676],[371],"149ff5b5-ebac-40b5-a905-d281d05d5128","v590","edf0f1dc-c67f-4898-a943-eee1324a510d",30,["D",1787177391642],[377],"pulls","branches","forks","envVars",{"_389":63,"_391":63},"connections",{"_389":63,"_390":63},"count","unfilledCount","emptyCount",{"_43":376,"_32":377,"_30":378,"_161":-5,"_41":42,"_40":379,"_163":59,"_38":624,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_438":625,"_27":626},{"_43":618,"_32":546,"_30":619,"_161":378,"_41":42,"_40":620,"_163":59,"_38":621,"_13":63,"_34":20,"_35":549,"_24":25,"_167":-5,"_438":622,"_27":623},{"_43":611,"_32":539,"_30":612,"_161":378,"_41":42,"_40":613,"_163":59,"_38":614,"_13":63,"_34":20,"_35":615,"_24":25,"_167":-5,"_438":616,"_27":617},{"_43":604,"_32":531,"_30":605,"_161":378,"_41":42,"_40":606,"_163":59,"_38":607,"_13":63,"_34":20,"_35":608,"_24":25,"_167":-5,"_438":609,"_27":610},{"_43":597,"_32":33,"_30":598,"_161":378,"_41":42,"_40":599,"_163":59,"_38":600,"_13":63,"_34":20,"_35":601,"_24":25,"_167":-5,"_438":602,"_27":603},{"_43":591,"_32":352,"_30":592,"_161":378,"_41":42,"_40":379,"_163":59,"_38":593,"_13":63,"_34":20,"_35":594,"_24":25,"_167":-5,"_438":595,"_27":596},{"_43":370,"_32":371,"_30":372,"_161":-5,"_41":42,"_40":373,"_163":59,"_38":588,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_438":589,"_27":590},{"_43":582,"_32":546,"_30":583,"_161":372,"_41":42,"_40":584,"_163":59,"_38":585,"_13":63,"_34":20,"_35":549,"_24":25,"_167":-5,"_438":586,"_27":587},{"_43":575,"_32":539,"_30":576,"_161":372,"_41":42,"_40":577,"_163":59,"_38":578,"_13":579,"_34":20,"_35":542,"_24":25,"_167":-5,"_438":580,"_27":581},{"_43":569,"_32":531,"_30":570,"_161":372,"_41":42,"_40":571,"_163":59,"_38":572,"_13":225,"_34":20,"_35":535,"_24":25,"_167":-5,"_438":573,"_27":574},{"_43":562,"_32":33,"_30":563,"_161":372,"_41":42,"_40":564,"_163":59,"_38":565,"_13":225,"_34":20,"_35":566,"_24":25,"_167":-5,"_438":567,"_27":568},{"_43":555,"_32":352,"_30":556,"_161":372,"_41":42,"_40":557,"_163":59,"_38":558,"_13":347,"_34":20,"_35":559,"_24":25,"_167":-5,"_438":560,"_27":561},{"_43":363,"_32":364,"_30":365,"_161":-5,"_41":42,"_40":366,"_163":59,"_38":552,"_13":63,"_34":368,"_35":-5,"_24":25,"_167":-5,"_438":553,"_27":554},{"_43":545,"_32":546,"_30":547,"_161":365,"_41":42,"_40":533,"_163":59,"_38":548,"_13":63,"_34":20,"_35":549,"_24":25,"_167":-5,"_438":550,"_27":551},{"_43":538,"_32":539,"_30":540,"_161":365,"_41":42,"_40":533,"_163":59,"_38":541,"_13":63,"_34":20,"_35":542,"_24":25,"_167":-5,"_438":543,"_27":544},{"_43":530,"_32":531,"_30":532,"_161":365,"_41":42,"_40":533,"_163":59,"_38":534,"_13":63,"_34":20,"_35":535,"_24":25,"_167":-5,"_438":536,"_27":537},{"_43":526,"_32":33,"_30":31,"_161":365,"_41":42,"_40":14,"_163":59,"_38":527,"_13":262,"_34":20,"_35":37,"_24":25,"_167":-5,"_438":528,"_27":529},{"_43":519,"_32":352,"_30":520,"_161":365,"_41":42,"_40":521,"_163":59,"_38":522,"_13":174,"_34":20,"_35":523,"_24":25,"_167":-5,"_438":524,"_27":525},{"_43":357,"_32":358,"_30":359,"_161":-5,"_41":42,"_40":225,"_163":59,"_38":516,"_13":63,"_34":20,"_35":361,"_24":25,"_167":-5,"_438":517,"_27":518},{"_43":351,"_32":352,"_30":353,"_161":-5,"_41":42,"_40":174,"_163":59,"_38":513,"_13":63,"_34":20,"_35":355,"_24":25,"_167":-5,"_438":514,"_27":515},{"_43":342,"_32":343,"_30":344,"_161":-5,"_41":42,"_40":345,"_163":25,"_38":510,"_13":347,"_34":165,"_35":348,"_24":25,"_167":349,"_438":511,"_27":512},{"_43":333,"_32":334,"_30":335,"_161":-5,"_41":42,"_40":336,"_163":25,"_38":507,"_13":338,"_34":165,"_35":339,"_24":25,"_167":340,"_438":508,"_27":509},{"_43":325,"_32":326,"_30":327,"_161":-5,"_41":42,"_40":328,"_163":59,"_38":504,"_13":63,"_34":165,"_35":330,"_24":25,"_167":331,"_438":505,"_27":506},{"_43":317,"_32":318,"_30":319,"_161":-5,"_41":42,"_40":320,"_163":59,"_38":501,"_13":63,"_34":165,"_35":322,"_24":25,"_167":323,"_438":502,"_27":503},{"_43":309,"_32":310,"_30":311,"_161":-5,"_41":42,"_40":312,"_163":59,"_38":498,"_13":63,"_34":165,"_35":314,"_24":25,"_167":315,"_438":499,"_27":500},{"_43":301,"_32":302,"_30":303,"_161":-5,"_41":42,"_40":304,"_163":59,"_38":495,"_13":63,"_34":165,"_35":306,"_24":25,"_167":307,"_438":496,"_27":497},{"_43":294,"_32":295,"_30":296,"_161":-5,"_41":42,"_40":297,"_163":59,"_38":492,"_13":63,"_34":165,"_35":299,"_24":25,"_167":-5,"_438":493,"_27":494},{"_43":286,"_32":287,"_30":288,"_161":-5,"_41":42,"_40":289,"_163":59,"_38":489,"_13":63,"_34":165,"_35":291,"_24":25,"_167":292,"_438":490,"_27":491},{"_43":279,"_32":280,"_30":281,"_161":-5,"_41":42,"_40":282,"_163":59,"_38":486,"_13":174,"_34":165,"_35":284,"_24":25,"_167":-5,"_438":487,"_27":488},{"_43":272,"_32":273,"_30":274,"_161":-5,"_41":42,"_40":275,"_163":59,"_38":483,"_13":225,"_34":165,"_35":277,"_24":25,"_167":-5,"_438":484,"_27":485},{"_43":265,"_32":266,"_30":267,"_161":-5,"_41":42,"_40":268,"_163":59,"_38":480,"_13":233,"_34":175,"_35":270,"_24":25,"_167":-5,"_438":481,"_27":482},{"_43":257,"_32":258,"_30":259,"_161":-5,"_41":42,"_40":260,"_163":59,"_38":477,"_13":262,"_34":165,"_35":263,"_24":25,"_167":-5,"_438":478,"_27":479},{"_43":251,"_32":252,"_30":57,"_161":-5,"_41":42,"_40":253,"_163":59,"_38":474,"_13":225,"_34":165,"_35":255,"_24":25,"_167":-5,"_438":475,"_27":476},{"_43":244,"_32":245,"_30":246,"_161":-5,"_41":42,"_40":247,"_163":59,"_38":471,"_13":63,"_34":165,"_35":249,"_24":25,"_167":-5,"_438":472,"_27":473},{"_43":237,"_32":238,"_30":239,"_161":-5,"_41":42,"_40":240,"_163":59,"_38":468,"_13":63,"_34":165,"_35":242,"_24":25,"_167":-5,"_438":469,"_27":470},{"_43":228,"_32":229,"_30":230,"_161":-5,"_41":42,"_40":231,"_163":59,"_38":465,"_13":233,"_34":165,"_35":234,"_24":25,"_167":235,"_438":466,"_27":467},{"_43":220,"_32":221,"_30":222,"_161":-5,"_41":42,"_40":223,"_163":59,"_38":462,"_13":225,"_34":165,"_35":226,"_24":25,"_167":-5,"_438":463,"_27":464},{"_43":213,"_32":214,"_30":215,"_161":-5,"_41":42,"_40":216,"_163":59,"_38":459,"_13":63,"_34":20,"_35":218,"_24":25,"_167":-5,"_438":460,"_27":461},{"_43":206,"_32":207,"_30":208,"_161":-5,"_41":42,"_40":209,"_163":59,"_38":456,"_13":63,"_34":165,"_35":211,"_24":25,"_167":-5,"_438":457,"_27":458},{"_43":199,"_32":200,"_30":201,"_161":-5,"_41":42,"_40":202,"_163":59,"_38":453,"_13":63,"_34":165,"_35":204,"_24":25,"_167":-5,"_438":454,"_27":455},{"_43":192,"_32":193,"_30":194,"_161":-5,"_41":42,"_40":195,"_163":59,"_38":450,"_13":63,"_34":165,"_35":197,"_24":25,"_167":-5,"_438":451,"_27":452},{"_43":185,"_32":186,"_30":187,"_161":-5,"_41":42,"_40":188,"_163":59,"_38":447,"_13":63,"_34":165,"_35":190,"_24":25,"_167":-5,"_438":448,"_27":449},{"_43":178,"_32":179,"_30":180,"_161":-5,"_41":42,"_40":181,"_163":59,"_38":444,"_13":63,"_34":165,"_35":183,"_24":25,"_167":-5,"_438":445,"_27":446},{"_43":169,"_32":170,"_30":171,"_161":-5,"_41":42,"_40":172,"_163":59,"_38":441,"_13":174,"_34":175,"_35":176,"_24":25,"_167":-5,"_438":442,"_27":443},{"_43":158,"_32":159,"_30":160,"_161":-5,"_41":42,"_40":162,"_163":59,"_38":437,"_13":63,"_34":165,"_35":166,"_24":25,"_167":-5,"_438":439,"_27":440},["D",1787177963614],"children",[],[159],["D",1787232822238],[],[170],["D",1787233166204],[],[179],["D",1787232832373],[],[186],["D",1787233148974],[],[193],["D",1787233196350],[],[200],["D",1787233240984],[],[207],["D",1787177315275],[],[214],["D",1787177378140],[],[221],["D",1787234697788],[],[229],["D",1787180719815],[],[238],["D",1787177537021],[],[245],["D",1787159229206],[],[252],["D",1787182564011],[],[258],["D",1787159287034],[],[266],["D",1787171573718],[],[273],["D",1787171464834],[],[280],["D",1787181132689],[],[287],["D",1787178016166],[],[295],["D",1787178565514],[],[302],["D",1787178557075],[],[310],["D",1787178547952],[],[318],["D",1787178537728],[],[326],["D",1787234748611],[],[334],["D",1787159105213],[],[343],["D",1787156892990],[],[352],["D",1787156870833],[],[358],"b5aafc31-fd08-423f-ae8e-eff7a9a72718","01a01f63-fc69-76ec-8fb9-f3785dd3552d",79,["D",1787234611123],"plugins {\n id(\"com.android.application\")\n id(\"org.jetbrains.kotlin.android\")\n}\n\nandroid {\n namespace = \"com.openai.universaldubber\"\n compileSdk = 35\n\n defaultConfig {\n applicationId = \"com.openai.universaldubber\"\n minSdk = 26\n targetSdk = 35\n versionCode = 32\n versionName = \"6.1.0\"\n testInstrumentationRunner = \"androidx.test.runner.AndroidJUnitRunner\"\n ndk {\n abiFilters += listOf(\"arm64-v8a\")\n }\n }\n\n buildFeatures {\n buildConfig = true\n }\n\n packaging {\n jniLibs.useLegacyPackaging = true\n }\n\n buildTypes {\n release {\n isMinifyEnabled = false\n proguardFiles(\n getDefaultProguardFile(\"proguard-android-optimize.txt\"),\n \"proguard-rules.pro\"\n )\n }\n }\n\n compileOptions {\n isCoreLibraryDesugaringEnabled = true\n sourceCompatibility = JavaVersion.VERSION_17\n targetCompatibility = JavaVersion.VERSION_17\n }\n kotlinOptions { jvmTarget = \"17\" }\n}\n\ndependencies {\n implementation(\"androidx.core:core-ktx:1.15.0\")\n implementation(\"androidx.appcompat:appcompat:1.7.0\")\n implementation(\"com.google.android.material:material:1.12.0\")\n implementation(\"com.squareup.okhttp3:okhttp:4.12.0\")\n\n implementation(\"androidx.media3:media3-exoplayer:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-hls:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-dash:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-rtsp:1.8.1\")\n implementation(\"androidx.media3:media3-ui:1.8.1\")\n\n // Extraction only. FFmpeg is deliberately excluded: Media3 plays the muxed stream directly,\n // removing the largest native payload from the APK.\n implementation(\"io.github.junkfood02.youtubedl-android:library:0.18.1\")\n implementation(\"com.github.teamnewpipe:NewPipeExtractor:v0.26.2\")\n\n coreLibraryDesugaring(\"com.android.tools:desugar_jdk_libs_nio:2.0.1\")\n\n testImplementation(\"junit:junit:4.13.2\")\n testImplementation(\"org.json:json:20240303\")\n androidTestImplementation(\"androidx.test.ext:junit:1.2.1\")\n androidTestImplementation(\"androidx.test.espresso:espresso-core:3.6.1\")\n}\n",[],[364,352],"97f2bb6c-f9e5-4cfe-894c-21ee984e2374",["D",1787235111410],[],[364,33],"b9a539fe-9135-413d-bd7f-7de8f6342925","UniversalPlaybackService.kt.txt","01a01f63-fc69-76ec-8fb9-e871d2c813fa",72,["D",1787233041529],"package com.openai.universaldubber\n\nimport android.app.Notification\nimport android.app.NotificationChannel\nimport android.app.NotificationManager\nimport android.app.PendingIntent\nimport android.app.Service\nimport android.content.Intent\nimport android.content.pm.ServiceInfo\nimport android.os.Binder\nimport android.os.Build\nimport android.os.Handler\nimport android.os.IBinder\nimport android.os.Looper\nimport androidx.core.app.NotificationCompat\nimport androidx.media3.common.C\nimport androidx.media3.common.MediaItem\nimport androidx.media3.common.PlaybackException\nimport androidx.media3.common.Player\nimport androidx.media3.common.audio.AudioProcessor\nimport androidx.media3.common.util.UnstableApi\nimport androidx.media3.datasource.DefaultDataSource\nimport androidx.media3.datasource.DefaultHttpDataSource\nimport androidx.media3.exoplayer.DefaultRenderersFactory\nimport androidx.media3.exoplayer.ExoPlayer\nimport androidx.media3.exoplayer.audio.AudioSink\nimport androidx.media3.exoplayer.audio.DefaultAudioSink\nimport androidx.media3.exoplayer.audio.TeeAudioProcessor\nimport androidx.media3.exoplayer.source.DefaultMediaSourceFactory\nimport java.util.concurrent.Executors\nimport java.util.concurrent.atomic.AtomicBoolean\n\n@UnstableApi\nclass UniversalPlaybackService : Service(), GeminiLiveTranslator.Listener {\n\n data class Snapshot(\n val loaded: Boolean,\n val dubbing: Boolean,\n val title: String,\n val status: String,\n val isPlaying: Boolean\n )\n\n inner class LocalBinder : Binder() {\n val service: UniversalPlaybackService get() = this@UniversalPlaybackService\n }\n\n companion object {\n const val ACTION_LOAD = \"com.openai.universaldubber.action.LOAD_LOCAL_YOUTUBE\"\n const val ACTION_PLAY = \"com.openai.universaldubber.action.PLAY_LOCAL_YOUTUBE\"\n const val ACTION_PAUSE = \"com.openai.universaldubber.action.PAUSE_LOCAL_YOUTUBE\"\n const val ACTION_TOGGLE = \"com.openai.universaldubber.action.TOGGLE_LOCAL_YOUTUBE\"\n const val ACTION_STOP_ALL = \"com.openai.universaldubber.action.STOP_LOCAL_YOUTUBE\"\n const val ACTION_START_DUB = \"com.openai.universaldubber.action.START_BACKGROUND_DUB\"\n const val ACTION_STOP_DUB = \"com.openai.universaldubber.action.STOP_BACKGROUND_DUB\"\n const val ACTION_EVENT = \"com.openai.universaldubber.action.PLAYBACK_EVENT\"\n\n const val EXTRA_URL = \"url\"\n const val EXTRA_SESSION = \"youtube_session\"\n const val EXTRA_API_KEY = \"api_key\"\n const val EXTRA_LANGUAGE = \"language\"\n const val EXTRA_EVENT = \"event\"\n const val EXTRA_MESSAGE = \"message\"\n const val EXTRA_TITLE = \"title\"\n\n const val EVENT_STATUS = \"status\"\n const val EVENT_ERROR = \"error\"\n const val EVENT_READY = \"ready\"\n const val EVENT_PLAYING = \"playing\"\n const val EVENT_PAUSED = \"paused\"\n const val EVENT_DUB_CONNECTING = \"dub_connecting\"\n const val EVENT_DUB_READY = \"dub_ready\"\n const val EVENT_DUB_STOPPED = \"dub_stopped\"\n const val EVENT_INPUT = \"input\"\n const val EVENT_OUTPUT = \"output\"\n\n private const val CHANNEL_ID = \"universal_dubber_background_playback\"\n private const val NOTIFICATION_ID = 5901\n }\n\n private val binder = LocalBinder()\n private val main = Handler(Looper.getMainLooper())\n private val resolverExecutor = Executors.newSingleThreadExecutor()\n private val resolving = AtomicBoolean(false)\n\n lateinit var player: ExoPlayer\n private set\n\n private lateinit var resolver: YtDlpLocalResolver\n private lateinit var translator: GeminiLiveTranslator\n private lateinit var httpDataSourceFactory: DefaultHttpDataSource.Factory\n private val dubbedAudio = StreamingPcmPlayer()\n\n @Volatile private var loaded = false\n @Volatile private var dubbing = false\n @Volatile private var title = \"YouTube\"\n @Volatile private var status = \"آماده\"\n @Volatile private var currentYoutubeUrl: String? = null\n @Volatile private var currentSessionCookie: String? = null\n private var currentResolved: YtDlpLocalResolver.ResolvedMedia? = null\n private var recoveryAttempts = 0\n private var pendingSeekMs = 0L\n private var foregroundStarted = false\n\n override fun onCreate() {\n super.onCreate()\n createChannel()\n resolver = YtDlpLocalResolver(this)\n translator = GeminiLiveTranslator(this)\n buildPlayer()\n }\n\n override fun onBind(intent: Intent?): IBinder = binder\n\n override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {\n when (intent?.action) {\n ACTION_LOAD -> {\n ensureForeground(\"در حال آماده‌سازی پخش محلی YouTube…\")\n val url = intent.getStringExtra(EXTRA_URL)?.trim().orEmpty()\n val cookie = intent.getStringExtra(EXTRA_SESSION)?.trim().orEmpty().ifBlank { null }\n if (url.isNotBlank()) loadYoutube(url, cookie)\n }\n ACTION_PLAY -> {\n if (::player.isInitialized) player.play()\n updateNotification()\n }\n ACTION_PAUSE -> {\n if (::player.isInitialized) player.pause()\n updateNotification()\n }\n ACTION_TOGGLE -> {\n if (::player.isInitialized) {\n if (player.isPlaying) player.pause() else player.play()\n }\n updateNotification()\n }\n ACTION_START_DUB -> {\n val key = intent.getStringExtra(EXTRA_API_KEY)?.trim().orEmpty()\n val language = intent.getStringExtra(EXTRA_LANGUAGE)?.trim().orEmpty()\n startDubbing(key, language)\n }\n ACTION_STOP_DUB -> stopDubbing(\"دوبله متوقف شد؛ پخش اصلی ادامه دارد.\")\n ACTION_STOP_ALL -> {\n stopDubbingInternal()\n player.stop()\n loaded = false\n stopForegroundCompat()\n stopSelf()\n }\n }\n return START_STICKY\n }\n\n fun snapshot(): Snapshot = Snapshot(\n loaded = loaded,\n dubbing = dubbing,\n title = title,\n status = status,\n isPlaying = ::player.isInitialized && player.isPlaying\n )\n\n private fun buildPlayer() {\n val pcmTap = PlayerPcmTap(\n onChunk16kMono = { chunk ->\n if (dubbing && translator.isReady()) translator.sendAudio(chunk)\n },\n onFormat = { message ->\n if (loaded && !dubbing) sendStatus(\"پخش محلی فعال است. $message\")\n }\n )\n val tee = TeeAudioProcessor(pcmTap)\n val renderersFactory = object : DefaultRenderersFactory(this) {\n override fun buildAudioSink(\n context: android.content.Context,\n enableFloatOutput: Boolean,\n enableAudioOutputPlaybackParams: Boolean\n ): AudioSink = DefaultAudioSink.Builder(context)\n .setAudioProcessors(arrayOf(tee))\n .build()\n }.setEnableDecoderFallback(true)\n\n httpDataSourceFactory = DefaultHttpDataSource.Factory()\n .setUserAgent(YtDlpLocalResolver.DEFAULT_USER_AGENT)\n .setConnectTimeoutMs(20_000)\n .setReadTimeoutMs(35_000)\n .setAllowCrossProtocolRedirects(true)\n\n val mediaSourceFactory = DefaultMediaSourceFactory(\n DefaultDataSource.Factory(this, httpDataSourceFactory)\n )\n\n player = ExoPlayer.Builder(this, renderersFactory)\n .setMediaSourceFactory(mediaSourceFactory)\n .build()\n player.setWakeMode(C.WAKE_MODE_LOCAL)\n player.setHandleAudioBecomingNoisy(true)\n player.addListener(object : Player.Listener {\n override fun onPlaybackStateChanged(playbackState: Int) {\n when (playbackState) {\n Player.STATE_BUFFERING -> sendStatus(\"در حال بافر پخش محلی…\")\n Player.STATE_READY -> {\n loaded = true\n recoveryAttempts = 0\n val seek = pendingSeekMs\n pendingSeekMs = 0L\n if (seek > 0L && currentResolved?.isLive != true) player.seekTo(seek)\n sendEvent(EVENT_READY, \"پخش محلی آماده است ✓\", title)\n updateNotification()\n }\n Player.STATE_ENDED -> {\n sendStatus(\"ویدیو تمام شد.\")\n updateNotification()\n }\n }\n }\n\n override fun onIsPlayingChanged(isPlaying: Boolean) {\n sendEvent(\n if (isPlaying) EVENT_PLAYING else EVENT_PAUSED,\n if (isPlaying) \"پخش در پس‌زمینه فعال است ✓\" else \"پخش مکث شد.\",\n title\n )\n updateNotification()\n }\n\n override fun onPlayerError(error: PlaybackException) {\n recoverPlayback(\"Media3 ${error.errorCodeName}: ${error.message ?: \"unknown\"}\")\n }\n })\n }\n\n private fun loadYoutube(url: String, cookie: String?) {\n currentYoutubeUrl = url\n currentSessionCookie = cookie\n currentResolved = null\n loaded = false\n recoveryAttempts = 0\n pendingSeekMs = 0L\n player.stop()\n resolveAndPlay(startStrategy = 0, reason = \"شروع resolver محلی\")\n }\n\n private fun resolveAndPlay(startStrategy: Int, reason: String) {\n if (!resolving.compareAndSet(false, true)) return\n val url = currentYoutubeUrl ?: run {\n resolving.set(false)\n return\n }\n val cookie = currentSessionCookie\n sendStatus(\"$reason؛ yt-dlp روی خود گوشی در حال استخراج لینک پخش…\")\n\n resolverExecutor.execute {\n try {\n val resolved = resolver.resolve(\n youtubeUrl = url,\n rawSessionCookie = cookie,\n startStrategy = startStrategy,\n onStatus = { sendStatus(it) }\n )\n main.post {\n resolving.set(false)\n if (currentYoutubeUrl != url) return@post\n currentResolved = resolved\n title = resolved.title\n httpDataSourceFactory.setDefaultRequestProperties(resolved.requestHeaders)\n val mediaItem = MediaItem.Builder()\n .setUri(resolved.uri)\n .setMediaId(url)\n .build()\n player.setMediaItem(mediaItem)\n player.prepare()\n player.playWhenReady = true\n sendStatus(\"لینک مستقیم روی گوشی probe شد ✓ ${resolved.strategyLabel} • ${resolved.quality}\")\n updateNotification()\n }\n } catch (t: Throwable) {\n main.post {\n resolving.set(false)\n loaded = false\n sendError(\"Resolver محلی ناموفق بود: ${friendly(t)}\")\n updateNotification()\n }\n }\n }\n }\n\n private fun recoverPlayback(reason: String) {\n val url = currentYoutubeUrl ?: run {\n sendError(\"خطای Player: $reason\")\n return\n }\n if (resolving.get()) return\n if (recoveryAttempts >= 4) {\n sendError(\"پخش بعد از ۴ تلاش بازیابی نشد: $reason\")\n return\n }\n\n recoveryAttempts += 1\n pendingSeekMs = player.currentPosition.coerceAtLeast(0L)\n val currentIndex = currentResolved?.strategyIndex ?: 0\n val nextStart = if (recoveryAttempts == 1) currentIndex else currentIndex + 1\n loaded = false\n player.stop()\n currentYoutubeUrl = url\n resolveAndPlay(\n startStrategy = nextStart,\n reason = \"لینک امضاشده منقضی/رد شد؛ بازیابی خودکار ${recoveryAttempts}/4\"\n )\n }\n\n private fun startDubbing(apiKey: String, language: String) {\n if (!loaded) {\n sendError(\"اول ویدیو باید در Player محلی آماده شود.\")\n return\n }\n if (apiKey.isBlank() || language.isBlank()) {\n sendError(\"کلید Gemini یا زبان دوبله خالی است.\")\n return\n }\n if (dubbing) return\n ensureForeground(\"پخش و دوبله در پس‌زمینه فعال است\")\n dubbing = true\n sendEvent(EVENT_DUB_CONNECTING, \"اتصال Gemini برای دوبله پس‌زمینه…\", title)\n translator.connect(apiKey, language, false)\n if (!player.isPlaying) player.play()\n }\n\n private fun stopDubbing(message: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendEvent(EVENT_DUB_STOPPED, message, title)\n updateNotification()\n }\n\n private fun stopDubbingInternal() {\n dubbing = false\n runCatching { translator.endAudioStream() }\n runCatching { translator.close() }\n dubbedAudio.stop()\n if (::player.isInitialized) player.volume = 1f\n }\n\n override fun onConnecting() {\n if (dubbing) sendEvent(EVENT_DUB_CONNECTING, \"Gemini در حال اتصال است؛ ویدیو ادامه دارد…\", title)\n }\n\n override fun onReady() {\n if (!dubbing) return\n dubbedAudio.start()\n player.volume = 0.22f\n if (!player.isPlaying) player.play()\n sendEvent(EVENT_DUB_READY, \"دوبله فعال ✓ با خروج از برنامه هم ادامه می‌دهد.\", title)\n updateNotification()\n }\n\n override fun onProtocolFallback(message: String) {\n if (dubbing) sendStatus(\"Gemini مسیر سازگاری را فعال کرد: $message\")\n }\n\n override fun onInputTranscript(text: String) {\n if (dubbing) sendEvent(EVENT_INPUT, text.takeLast(1400), title)\n }\n\n override fun onOutputTranscript(text: String) {\n if (dubbing) sendEvent(EVENT_OUTPUT, text.takeLast(1400), title)\n }\n\n override fun onAudio(pcm24k: ByteArray) {\n if (dubbing) dubbedAudio.write(pcm24k)\n }\n\n override fun onInterrupted() {\n dubbedAudio.flush()\n }\n\n override fun onError(message: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendError(\"خطای دوبله: $message — پخش اصلی ادامه دارد.\")\n updateNotification()\n }\n\n override fun onClosed(reason: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendError(\"اتصال دوبله بسته شد: $reason — پخش اصلی ادامه دارد.\")\n updateNotification()\n }\n\n private fun sendStatus(message: String) {\n status = message\n sendEvent(EVENT_STATUS, message, title)\n }\n\n private fun sendError(message: String) {\n status = message\n sendEvent(EVENT_ERROR, message, title)\n }\n\n private fun sendEvent(event: String, message: String, title: String = this.title) {\n status = message\n sendBroadcast(\n Intent(ACTION_EVENT)\n .setPackage(packageName)\n .putExtra(EXTRA_EVENT, event)\n .putExtra(EXTRA_MESSAGE, message)\n .putExtra(EXTRA_TITLE, title)\n )\n }\n\n private fun ensureForeground(text: String) {\n val notification = buildNotification(text)\n if (!foregroundStarted) {\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {\n startForeground(\n NOTIFICATION_ID,\n notification,\n ServiceInfo.FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK\n )\n } else {\n startForeground(NOTIFICATION_ID, notification)\n }\n foregroundStarted = true\n } else {\n getSystemService(NotificationManager::class.java).notify(NOTIFICATION_ID, notification)\n }\n }\n\n private fun updateNotification() {\n if (!foregroundStarted) return\n getSystemService(NotificationManager::class.java)\n .notify(NOTIFICATION_ID, buildNotification(status))\n }\n\n private fun buildNotification(text: String): Notification {\n val open = PendingIntent.getActivity(\n this,\n 1,\n Intent(this, MainActivity::class.java),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val toggle = PendingIntent.getService(\n this,\n 2,\n Intent(this, UniversalPlaybackService::class.java).setAction(ACTION_TOGGLE),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val stop = PendingIntent.getService(\n this,\n 3,\n Intent(this, UniversalPlaybackService::class.java).setAction(ACTION_STOP_ALL),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val toggleLabel = if (::player.isInitialized && player.isPlaying) \"مکث\" else \"پخش\"\n val dubText = if (dubbing) \" • دوبله فعال\" else \"\"\n return NotificationCompat.Builder(this, CHANNEL_ID)\n .setSmallIcon(R.drawable.ic_app_logo)\n .setContentTitle(title.ifBlank { \"Universal Dubber\" })\n .setContentText((text + dubText).take(120))\n .setOngoing(::player.isInitialized && (player.isPlaying || dubbing))\n .setOnlyAlertOnce(true)\n .setContentIntent(open)\n .addAction(0, toggleLabel, toggle)\n .addAction(0, \"توقف کامل\", stop)\n .setCategory(NotificationCompat.CATEGORY_TRANSPORT)\n .setVisibility(NotificationCompat.VISIBILITY_PUBLIC)\n .build()\n }\n\n private fun createChannel() {\n if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) return\n val channel = NotificationChannel(\n CHANNEL_ID,\n \"پخش و دوبله پس‌زمینه\",\n NotificationManager.IMPORTANCE_LOW\n ).apply {\n description = \"پخش محلی YouTube و دوبله زنده حتی هنگام خروج از برنامه\"\n setSound(null, null)\n }\n getSystemService(NotificationManager::class.java).createNotificationChannel(channel)\n }\n\n private fun stopForegroundCompat() {\n foregroundStarted = false\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {\n stopForeground(STOP_FOREGROUND_REMOVE)\n } else {\n @Suppress(\"DEPRECATION\")\n stopForeground(true)\n }\n }\n\n override fun onTaskRemoved(rootIntent: Intent?) {\n updateNotification()\n super.onTaskRemoved(rootIntent)\n }\n\n override fun onDestroy() {\n resolving.set(false)\n resolverExecutor.shutdownNow()\n stopDubbingInternal()\n runCatching { translator.shutdown() }\n if (::player.isInitialized) player.release()\n stopForegroundCompat()\n super.onDestroy()\n }\n\n private fun friendly(t: Throwable): String {\n val msg = generateSequence(t) { it.cause }\n .mapNotNull { it.message?.trim() }\n .firstOrNull { it.isNotBlank() }\n ?: t.javaClass.simpleName\n return msg.take(600)\n }\n}\n",[],[364,531],"31d9928b-1ff3-4ad1-9945-7448c0473d4c","MainActivity.kt.txt","01a01f63-fc69-76ec-8fb9-edf76387351d",["D",1787233041529],"package com.openai.universaldubber\n\nimport android.Manifest\nimport android.content.BroadcastReceiver\nimport android.content.ComponentName\nimport android.content.Context\nimport android.content.Intent\nimport android.content.IntentFilter\nimport android.content.ServiceConnection\nimport android.content.pm.ActivityInfo\nimport android.content.pm.PackageManager\nimport android.graphics.Color\nimport android.net.Uri\nimport android.os.Build\nimport android.os.Bundle\nimport android.os.IBinder\nimport android.text.InputType\nimport android.text.method.PasswordTransformationMethod\nimport android.view.Gravity\nimport android.view.View\nimport android.view.ViewGroup\nimport android.widget.ArrayAdapter\nimport android.widget.ImageView\nimport android.widget.LinearLayout\nimport android.widget.ScrollView\nimport android.widget.Spinner\nimport android.widget.TextView\nimport androidx.activity.result.contract.ActivityResultContracts\nimport androidx.appcompat.app.AppCompatActivity\nimport androidx.core.app.ActivityCompat\nimport androidx.core.content.ContextCompat\nimport androidx.core.view.ViewCompat\nimport androidx.core.view.WindowInsetsCompat\nimport androidx.core.view.WindowInsetsControllerCompat\nimport androidx.media3.common.util.UnstableApi\nimport androidx.media3.ui.PlayerView\nimport com.google.android.material.button.MaterialButton\nimport com.google.android.material.textfield.TextInputEditText\nimport com.google.android.material.textfield.TextInputLayout\n\n@UnstableApi\nclass MainActivity : AppCompatActivity() {\n\n private data class Language(val label: String, val code: String)\n\n companion object {\n private const val REQ_NOTIFICATIONS = 5902\n }\n\n private val languages = listOf(\n Language(\"فارسی\", \"fa\"),\n Language(\"Français\", \"fr\"),\n Language(\"English\", \"en\"),\n Language(\"العربية\", \"ar\"),\n Language(\"Español\", \"es\"),\n Language(\"Deutsch\", \"de\"),\n Language(\"Türkçe\", \"tr\")\n )\n\n private lateinit var rootContainer: LinearLayout\n private lateinit var headerView: View\n private lateinit var controlsScroll: ScrollView\n private lateinit var apiKeyEdit: TextInputEditText\n private lateinit var youtubeUrlEdit: TextInputEditText\n private lateinit var youtubeSessionEdit: TextInputEditText\n private lateinit var languageSpinner: Spinner\n private lateinit var loadButton: MaterialButton\n private lateinit var dubButton: MaterialButton\n private lateinit var stopAllButton: MaterialButton\n private lateinit var statusText: TextView\n private lateinit var inputTranscript: TextView\n private lateinit var outputTranscript: TextView\n private lateinit var videoTitle: TextView\n private lateinit var playerView: PlayerView\n\n private var playbackService: UniversalPlaybackService? = null\n private var serviceBound = false\n private var receiverRegistered = false\n private var isFullscreen = false\n private var videoLoaded = false\n private var dubbing = false\n private var resumeYoutubeAfterLiveTv = false\n\n private val cookieFilePicker = registerForActivityResult(ActivityResultContracts.OpenDocument()) { uri ->\n if (uri == null) return@registerForActivityResult\n runCatching {\n val text = contentResolver.openInputStream(uri)?.bufferedReader(Charsets.UTF_8)?.use { it.readText() }.orEmpty()\n require(text.isNotBlank()) { \"فایل خالی است\" }\n require(text.length <= 300_000) { \"فایل cookies.txt غیرعادی بزرگ است\" }\n val normalized = text.replace(\"\\r\\n\", \"\\n\").replace('\\r', '\\n').trim()\n val looksLikeNetscape = normalized.startsWith(\"# Netscape HTTP Cookie File\") ||\n normalized.startsWith(\"# HTTP Cookie File\")\n require(looksLikeNetscape) { \"فایل باید فرمت Netscape cookies.txt داشته باشد\" }\n require(normalized.contains(\"youtube.com\", true) || normalized.contains(\"google.com\", true)) {\n \"فایل Cookie مربوط به YouTube/Google ندارد\"\n }\n val saved = normalized + \"\\n\"\n youtubeSessionEdit.setText(saved)\n SecurePrefs.saveYoutubeSession(this, saved)\n setStatus(\"cookies.txt وارد و در حافظه امن ذخیره شد ✓ حالا دوباره بارگذاری را بزنید.\")\n }.onFailure {\n setStatus(\"وارد کردن cookies.txt ناموفق بود: ${it.message ?: it.javaClass.simpleName}\", true)\n }\n }\n\n private val serviceConnection = object : ServiceConnection {\n override fun onServiceConnected(name: ComponentName?, binder: IBinder?) {\n val local = binder as? UniversalPlaybackService.LocalBinder ?: return\n playbackService = local.service\n serviceBound = true\n playerView.player = local.service.player\n applySnapshot(local.service.snapshot())\n }\n\n override fun onServiceDisconnected(name: ComponentName?) {\n playerView.player = null\n playbackService = null\n serviceBound = false\n }\n }\n\n private val playbackReceiver = object : BroadcastReceiver() {\n override fun onReceive(context: Context?, intent: Intent?) {\n if (intent?.action != UniversalPlaybackService.ACTION_EVENT) return\n val event = intent.getStringExtra(UniversalPlaybackService.EXTRA_EVENT).orEmpty()\n val message = intent.getStringExtra(UniversalPlaybackService.EXTRA_MESSAGE).orEmpty()\n val title = intent.getStringExtra(UniversalPlaybackService.EXTRA_TITLE).orEmpty()\n if (title.isNotBlank()) videoTitle.text = title\n\n when (event) {\n UniversalPlaybackService.EVENT_READY -> {\n videoLoaded = true\n loadButton.isEnabled = true\n stopAllButton.isEnabled = true\n setStatus(message.ifBlank { \"پخش محلی آماده است ✓\" })\n }\n UniversalPlaybackService.EVENT_PLAYING -> {\n videoLoaded = true\n stopAllButton.isEnabled = true\n if (!dubbing) setStatus(message.ifBlank { \"پخش در پس‌زمینه فعال است ✓\" })\n }\n UniversalPlaybackService.EVENT_PAUSED -> {\n if (!dubbing) setStatus(message.ifBlank { \"پخش مکث شد.\" })\n }\n UniversalPlaybackService.EVENT_DUB_CONNECTING -> {\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n setStatus(message)\n }\n UniversalPlaybackService.EVENT_DUB_READY -> {\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n setStatus(message.ifBlank { \"دوبله پس‌زمینه فعال ✓\" })\n }\n UniversalPlaybackService.EVENT_DUB_STOPPED -> {\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n setStatus(message)\n }\n UniversalPlaybackService.EVENT_INPUT -> inputTranscript.text = \"متن ورودی: $message\"\n UniversalPlaybackService.EVENT_OUTPUT -> outputTranscript.text = \"ترجمه: $message\"\n UniversalPlaybackService.EVENT_STATUS -> setStatus(message)\n UniversalPlaybackService.EVENT_ERROR -> {\n if (message.contains(\"دوبله\", ignoreCase = true)) {\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n }\n loadButton.isEnabled = true\n setStatus(message.ifBlank { \"خطا\" }, true)\n }\n }\n }\n }\n\n override fun onCreate(savedInstanceState: Bundle?) {\n super.onCreate(savedInstanceState)\n setContentView(buildUi())\n restoreState()\n maybeRequestNotificationPermission()\n consumeIntent(intent)\n }\n\n override fun onNewIntent(intent: Intent) {\n super.onNewIntent(intent)\n setIntent(intent)\n consumeIntent(intent)\n }\n\n private fun buildUi(): View {\n rootContainer = LinearLayout(this).apply {\n orientation = LinearLayout.VERTICAL\n setBackgroundColor(Color.rgb(12, 15, 22))\n layoutDirection = View.LAYOUT_DIRECTION_RTL\n }\n ViewCompat.setOnApplyWindowInsetsListener(rootContainer) { view, insets ->\n val bars = insets.getInsets(WindowInsetsCompat.Type.systemBars())\n if (isFullscreen) view.setPadding(0, 0, 0, 0)\n else view.setPadding(bars.left, bars.top, bars.right, bars.bottom)\n insets\n }\n\n headerView = LinearLayout(this).apply {\n orientation = LinearLayout.HORIZONTAL\n gravity = Gravity.CENTER_VERTICAL\n setPadding(dp(16), dp(10), dp(16), dp(8))\n addView(ImageView(this@MainActivity).apply {\n setImageResource(R.drawable.ic_app_logo)\n contentDescription = \"Universal Dubber logo\"\n scaleType = ImageView.ScaleType.CENTER_INSIDE\n }, LinearLayout.LayoutParams(dp(58), dp(58)))\n addView(LinearLayout(this@MainActivity).apply {\n orientation = LinearLayout.VERTICAL\n setPadding(dp(10), 0, 0, 0)\n addView(TextView(this@MainActivity).apply {\n text = \"Universal Dubber ${BuildConfig.VERSION_NAME} LOCAL\"\n textSize = 24f\n setTextColor(Color.WHITE)\n typeface = android.graphics.Typeface.DEFAULT_BOLD\n })\n addView(TextView(this@MainActivity).apply {\n text = \"Player محلی Media3 + yt-dlp روی گوشی + دوبله پس‌زمینه\"\n textSize = 13f\n setTextColor(Color.rgb(170, 178, 198))\n })\n }, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 1f))\n }\n rootContainer.addView(headerView)\n\n playerView = PlayerView(this).apply {\n useController = true\n setShowBuffering(PlayerView.SHOW_BUFFERING_WHEN_PLAYING)\n setBackgroundColor(Color.BLACK)\n keepScreenOn = true\n setControllerShowTimeoutMs(3_500)\n setControllerHideOnTouch(true)\n setFullscreenButtonClickListener { fullscreen -> setFullscreen(fullscreen) }\n }\n rootContainer.addView(\n playerView,\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, 0, 0.46f).apply {\n marginStart = dp(10)\n marginEnd = dp(10)\n }\n )\n\n val controls = LinearLayout(this).apply {\n orientation = LinearLayout.VERTICAL\n setPadding(dp(14), dp(8), dp(14), dp(18))\n }\n\n videoTitle = TextView(this).apply {\n text = \"ویدیو: هنوز بارگذاری نشده\"\n setTextColor(Color.WHITE)\n textSize = 15f\n maxLines = 2\n setPadding(0, 0, 0, dp(6))\n }\n controls.addView(videoTitle)\n\n youtubeUrlEdit = TextInputEditText(this).apply {\n hint = \"https://www.youtube.com/watch?v=...\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_URI\n setSingleLine(true)\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"لینک YouTube\", youtubeUrlEdit).apply {\n endIconMode = TextInputLayout.END_ICON_CLEAR_TEXT\n })\n\n youtubeSessionEdit = TextInputEditText(this).apply {\n hint = \"Cookie header یا Netscape cookies.txt\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_PASSWORD or InputType.TYPE_TEXT_FLAG_MULTI_LINE\n transformationMethod = PasswordTransformationMethod.getInstance()\n setSingleLine(false)\n maxLines = 3\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"نشست واقعی YouTube (در صورت درخواست Sign in)\", youtubeSessionEdit, password = true))\n\n controls.addView(TextView(this).apply {\n text = \"Player کاملاً محلی است: yt-dlp لینک stream را روی خود گوشی استخراج و probe می‌کند و Media3 آن را پخش می‌کند. اگر YouTube برای IP شما Sign in بخواهد، دکمه وارد کردن cookies.txt را بزنید و نشست واقعی خودتان را بدهید.\"\n setTextColor(Color.rgb(179, 187, 205))\n textSize = 12.5f\n setPadding(0, dp(4), 0, dp(5))\n })\n\n controls.addView(button(\"وارد کردن cookies.txt از حافظه گوشی\") {\n cookieFilePicker.launch(arrayOf(\"text/plain\", \"application/octet-stream\", \"*/*\"))\n }, fullWidthParams())\n\n loadButton = button(\"بارگذاری و پخش محلی\") { loadYoutubeVideo() }\n controls.addView(loadButton, fullWidthParams())\n\n controls.addView(button(\"پاک‌کردن نشست YouTube\") {\n youtubeSessionEdit.setText(\"\")\n SecurePrefs.clearYoutubeSession(this)\n setStatus(\"نشست YouTube از حافظه امن برنامه پاک شد.\")\n }, fullWidthParams())\n\n controls.addView(button(\"تلویزیون زنده — جستجوی شبکه‌های جهانی\") {\n resumeYoutubeAfterLiveTv = playbackService?.player?.isPlaying == true\n sendPlaybackAction(UniversalPlaybackService.ACTION_PAUSE)\n startActivity(Intent(this, LiveTvActivity::class.java))\n }, fullWidthParams())\n\n apiKeyEdit = TextInputEditText(this).apply {\n hint = \"Gemini API Key\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_PASSWORD\n transformationMethod = PasswordTransformationMethod.getInstance()\n setSingleLine(true)\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"کلید Gemini\", apiKeyEdit, password = true))\n\n languageSpinner = Spinner(this).apply {\n adapter = ArrayAdapter(\n this@MainActivity,\n android.R.layout.simple_spinner_dropdown_item,\n languages.map { it.label }\n )\n minimumHeight = dp(48)\n }\n controls.addView(LinearLayout(this).apply {\n orientation = LinearLayout.HORIZONTAL\n gravity = Gravity.CENTER_VERTICAL\n addView(TextView(this@MainActivity).apply {\n text = \"زبان دوبله:\"\n setTextColor(Color.WHITE)\n textSize = 15f\n }, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 0.75f))\n addView(languageSpinner, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 1.25f))\n })\n\n dubButton = button(\"شروع دوبله فارسی\") {\n if (dubbing) stopDubbing() else startDubbing()\n }.apply { minHeight = dp(58) }\n controls.addView(dubButton, fullWidthParams())\n\n stopAllButton = button(\"توقف کامل پخش و سرویس پس‌زمینه\") {\n sendPlaybackAction(UniversalPlaybackService.ACTION_STOP_ALL)\n videoLoaded = false\n dubbing = false\n playerView.player = null\n videoTitle.text = \"ویدیو: متوقف شد\"\n dubButton.text = \"شروع دوبله فارسی\"\n loadButton.isEnabled = true\n stopAllButton.isEnabled = false\n setStatus(\"پخش، دوبله و سرویس پس‌زمینه متوقف شدند.\")\n }.apply { isEnabled = false }\n controls.addView(stopAllButton, fullWidthParams())\n\n controls.addView(TextView(this).apply {\n text = \"وقتی Home را بزنید، صفحه را خاموش کنید یا وارد برنامه دیگری شوید، Player و Gemini داخل Foreground Service باقی می‌مانند. تصویر با برگشتن به برنامه دوباره به همین Player وصل می‌شود و صدا/دوبله در فاصله خروج قطع نمی‌شود.\"\n setTextColor(Color.rgb(179, 187, 205))\n textSize = 13f\n setPadding(0, dp(5), 0, dp(7))\n })\n\n statusText = TextView(this).apply {\n text = \"آماده. لینک YouTube را وارد کنید.\"\n setTextColor(Color.rgb(0, 220, 185))\n textSize = 14f\n setTextIsSelectable(true)\n maxLines = 12\n setPadding(0, dp(4), 0, dp(4))\n }\n controls.addView(statusText)\n\n inputTranscript = transcriptView(\"متن ورودی\")\n outputTranscript = transcriptView(\"ترجمه\")\n controls.addView(inputTranscript)\n controls.addView(outputTranscript)\n\n controlsScroll = ScrollView(this).apply {\n isFillViewport = true\n addView(controls)\n }\n rootContainer.addView(\n controlsScroll,\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, 0, 0.54f)\n )\n return rootContainer\n }\n\n private fun loadYoutubeVideo() {\n val url = normalizeYoutubeUrl(youtubeUrlEdit.text?.toString().orEmpty())\n if (url == null) {\n setStatus(\"یک لینک معتبر YouTube یا youtu.be وارد کنید.\", true)\n return\n }\n\n val session = youtubeSessionEdit.text?.toString()?.trim().orEmpty()\n .ifBlank { SecurePrefs.loadYoutubeSession(this).trim() }\n if (session.isNotBlank()) SecurePrefs.saveYoutubeSession(this, session)\n\n loadButton.isEnabled = false\n videoLoaded = false\n videoTitle.text = \"ویدیو: در حال resolve محلی…\"\n setStatus(\"yt-dlp + QuickJS روی گوشی در حال استخراج stream است…\")\n\n val serviceIntent = Intent(this, UniversalPlaybackService::class.java)\n .setAction(UniversalPlaybackService.ACTION_LOAD)\n .putExtra(UniversalPlaybackService.EXTRA_URL, url)\n .putExtra(UniversalPlaybackService.EXTRA_SESSION, session)\n ContextCompat.startForegroundService(this, serviceIntent)\n bindPlaybackService()\n }\n\n private fun startDubbing() {\n val loadedNow = playbackService?.snapshot()?.loaded ?: videoLoaded\n if (!loadedNow) {\n setStatus(\"اول ویدیو باید در Player محلی آماده شود.\", true)\n return\n }\n val key = apiKeyEdit.text?.toString()?.trim().orEmpty()\n if (key.isBlank()) {\n setStatus(\"Gemini API Key را وارد کنید.\", true)\n return\n }\n SecurePrefs.saveApiKey(this, key)\n val language = languages[languageSpinner.selectedItemPosition]\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n inputTranscript.text = \"متن ورودی: —\"\n outputTranscript.text = \"ترجمه: —\"\n setStatus(\"در حال فعال‌سازی دوبله داخل سرویس پس‌زمینه…\")\n startService(\n Intent(this, UniversalPlaybackService::class.java)\n .setAction(UniversalPlaybackService.ACTION_START_DUB)\n .putExtra(UniversalPlaybackService.EXTRA_API_KEY, key)\n .putExtra(UniversalPlaybackService.EXTRA_LANGUAGE, language.code)\n )\n }\n\n private fun stopDubbing() {\n sendPlaybackAction(UniversalPlaybackService.ACTION_STOP_DUB)\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n }\n\n private fun sendPlaybackAction(action: String) {\n runCatching {\n startService(Intent(this, UniversalPlaybackService::class.java).setAction(action))\n }\n }\n\n private fun bindPlaybackService() {\n if (serviceBound) return\n runCatching {\n bindService(\n Intent(this, UniversalPlaybackService::class.java),\n serviceConnection,\n Context.BIND_AUTO_CREATE\n )\n }\n }\n\n private fun applySnapshot(snapshot: UniversalPlaybackService.Snapshot) {\n videoLoaded = snapshot.loaded\n dubbing = snapshot.dubbing\n videoTitle.text = snapshot.title.ifBlank { \"YouTube\" }\n dubButton.text = if (snapshot.dubbing) \"توقف دوبله\" else \"شروع دوبله فارسی\"\n stopAllButton.isEnabled = snapshot.loaded || snapshot.isPlaying || snapshot.dubbing\n loadButton.isEnabled = true\n if (snapshot.status.isNotBlank()) setStatus(snapshot.status)\n }\n\n private fun normalizeYoutubeUrl(input: String): String? {\n val trimmed = input.trim()\n if (trimmed.isBlank()) return null\n if (Regex(\"^[A-Za-z0-9_-]{11}$\").matches(trimmed)) {\n return \"https://www.youtube.com/watch?v=$trimmed\"\n }\n val candidate = if (trimmed.startsWith(\"http://\") || trimmed.startsWith(\"https://\")) {\n trimmed\n } else {\n \"https://$trimmed\"\n }\n val uri = runCatching { Uri.parse(candidate) }.getOrNull() ?: return null\n val host = uri.host?.lowercase().orEmpty()\n return candidate.takeIf {\n host == \"youtu.be\" || host == \"youtube.com\" || host.endsWith(\".youtube.com\")\n }\n }\n\n private fun consumeIntent(intent: Intent?) {\n if (intent == null || !::youtubeUrlEdit.isInitialized) return\n val candidate = when (intent.action) {\n Intent.ACTION_VIEW -> intent.dataString\n Intent.ACTION_SEND -> intent.getStringExtra(Intent.EXTRA_TEXT)\n else -> null\n } ?: return\n if (normalizeYoutubeUrl(candidate) == null) return\n youtubeUrlEdit.setText(candidate)\n loadYoutubeVideo()\n }\n\n private fun restoreState() {\n apiKeyEdit.setText(SecurePrefs.loadApiKey(this))\n youtubeSessionEdit.setText(SecurePrefs.loadYoutubeSession(this))\n languageSpinner.setSelection(0)\n }\n\n private fun maybeRequestNotificationPermission() {\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU &&\n ContextCompat.checkSelfPermission(this, Manifest.permission.POST_NOTIFICATIONS) != PackageManager.PERMISSION_GRANTED\n ) {\n ActivityCompat.requestPermissions(\n this,\n arrayOf(Manifest.permission.POST_NOTIFICATIONS),\n REQ_NOTIFICATIONS\n )\n }\n }\n\n private fun setFullscreen(fullscreen: Boolean) {\n if (isFullscreen == fullscreen) return\n isFullscreen = fullscreen\n headerView.visibility = if (fullscreen) View.GONE else View.VISIBLE\n controlsScroll.visibility = if (fullscreen) View.GONE else View.VISIBLE\n val params = playerView.layoutParams as LinearLayout.LayoutParams\n params.height = 0\n params.weight = if (fullscreen) 1f else 0.46f\n params.marginStart = if (fullscreen) 0 else dp(10)\n params.marginEnd = if (fullscreen) 0 else dp(10)\n playerView.layoutParams = params\n\n if (fullscreen) {\n rootContainer.setPadding(0, 0, 0, 0)\n WindowInsetsControllerCompat(window, window.decorView).apply {\n systemBarsBehavior = WindowInsetsControllerCompat.BEHAVIOR_SHOW_TRANSIENT_BARS_BY_SWIPE\n hide(WindowInsetsCompat.Type.systemBars())\n }\n requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_SENSOR_LANDSCAPE\n } else {\n WindowInsetsControllerCompat(window, window.decorView).show(WindowInsetsCompat.Type.systemBars())\n requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_UNSPECIFIED\n ViewCompat.requestApplyInsets(rootContainer)\n }\n }\n\n private fun field(label: String, editText: TextInputEditText, password: Boolean = false): TextInputLayout =\n TextInputLayout(this).apply {\n hint = label\n boxBackgroundMode = TextInputLayout.BOX_BACKGROUND_OUTLINE\n setBoxStrokeColor(Color.rgb(124, 77, 255))\n setHintTextColor(android.content.res.ColorStateList.valueOf(Color.rgb(188, 194, 210)))\n setBoxBackgroundColor(Color.rgb(23, 27, 37))\n if (password) endIconMode = TextInputLayout.END_ICON_PASSWORD_TOGGLE\n addView(editText)\n }\n\n private fun button(text: String, onClick: () -> Unit): MaterialButton =\n MaterialButton(this).apply {\n this.text = text\n isAllCaps = false\n cornerRadius = dp(14)\n minHeight = dp(50)\n setOnClickListener { onClick() }\n }\n\n private fun fullWidthParams() =\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, ViewGroup.LayoutParams.WRAP_CONTENT).apply {\n topMargin = dp(5)\n bottomMargin = dp(5)\n }\n\n private fun transcriptView(label: String) = TextView(this).apply {\n text = \"$label: —\"\n setTextColor(Color.rgb(220, 224, 234))\n textSize = 13f\n maxLines = 4\n setTextIsSelectable(true)\n setPadding(0, dp(3), 0, dp(3))\n }\n\n private fun setStatus(message: String, error: Boolean = false) {\n statusText.text = message\n statusText.setTextColor(if (error) Color.rgb(255, 100, 115) else Color.rgb(0, 220, 185))\n }\n\n override fun onStart() {\n super.onStart()\n if (!receiverRegistered) {\n val filter = IntentFilter(UniversalPlaybackService.ACTION_EVENT)\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {\n registerReceiver(playbackReceiver, filter, Context.RECEIVER_NOT_EXPORTED)\n } else {\n @Suppress(\"DEPRECATION\")\n registerReceiver(playbackReceiver, filter)\n }\n receiverRegistered = true\n }\n bindPlaybackService()\n }\n\n override fun onStop() {\n if (serviceBound) {\n playerView.player = null\n runCatching { unbindService(serviceConnection) }\n serviceBound = false\n playbackService = null\n }\n if (receiverRegistered) {\n runCatching { unregisterReceiver(playbackReceiver) }\n receiverRegistered = false\n }\n super.onStop()\n }\n\n override fun onResume() {\n super.onResume()\n if (resumeYoutubeAfterLiveTv) {\n resumeYoutubeAfterLiveTv = false\n sendPlaybackAction(UniversalPlaybackService.ACTION_PLAY)\n }\n }\n\n @Deprecated(\"Deprecated in Java\")\n override fun onBackPressed() {\n if (isFullscreen) setFullscreen(false) else super.onBackPressed()\n }\n\n override fun onDestroy() {\n playerView.player = null\n super.onDestroy()\n }\n\n private fun dp(value: Int): Int = (value * resources.displayMetrics.density).toInt()\n}\n",[],[364,539],"9d34516a-044e-4c85-95f9-831221fe903f","AndroidManifest.xml.txt","01a01f63-fc69-76ec-8fb9-f4aa9a42f4b4",["D",1787233041529],"\n\n\n \n \n \n \n \n\n \n\n \n\n \n\n \n\n \n \n \n \n\n \n \n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n\n\n",[],[364,546],["D",1787233033243],[405,406,407,408,409],[364],"0ca3297f-9095-482d-8763-b503d0d3b23e","01a01c42-f159-7182-ad57-f6cf518b24e1",47,["D",1787180564662],"plugins {\n id(\"com.android.application\")\n id(\"org.jetbrains.kotlin.android\")\n}\n\nandroid {\n namespace = \"com.openai.universaldubber\"\n compileSdk = 35\n\n defaultConfig {\n applicationId = \"com.openai.universaldubber\"\n minSdk = 26\n targetSdk = 35\n versionCode = 31\n versionName = \"6.0.0\"\n testInstrumentationRunner = \"androidx.test.runner.AndroidJUnitRunner\"\n ndk {\n abiFilters += listOf(\"arm64-v8a\")\n }\n }\n\n buildFeatures {\n buildConfig = true\n }\n\n packaging {\n jniLibs.useLegacyPackaging = true\n }\n\n buildTypes {\n release {\n isMinifyEnabled = false\n proguardFiles(\n getDefaultProguardFile(\"proguard-android-optimize.txt\"),\n \"proguard-rules.pro\"\n )\n }\n }\n\n compileOptions {\n isCoreLibraryDesugaringEnabled = true\n sourceCompatibility = JavaVersion.VERSION_17\n targetCompatibility = JavaVersion.VERSION_17\n }\n kotlinOptions { jvmTarget = \"17\" }\n}\n\ndependencies {\n implementation(\"androidx.core:core-ktx:1.15.0\")\n implementation(\"androidx.appcompat:appcompat:1.7.0\")\n implementation(\"com.google.android.material:material:1.12.0\")\n implementation(\"com.squareup.okhttp3:okhttp:4.12.0\")\n\n implementation(\"androidx.media3:media3-exoplayer:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-hls:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-dash:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-rtsp:1.8.1\")\n implementation(\"androidx.media3:media3-ui:1.8.1\")\n\n // Extraction only. FFmpeg is deliberately excluded: Media3 plays the muxed stream directly,\n // removing the largest native payload from the APK.\n implementation(\"io.github.junkfood02.youtubedl-android:library:0.18.1\")\n implementation(\"com.github.teamnewpipe:NewPipeExtractor:v0.26.2\")\n\n coreLibraryDesugaring(\"com.android.tools:desugar_jdk_libs_nio:2.0.1\")\n\n testImplementation(\"junit:junit:4.13.2\")\n testImplementation(\"org.json:json:20240303\")\n androidTestImplementation(\"androidx.test.ext:junit:1.2.1\")\n androidTestImplementation(\"androidx.test.espresso:espresso-core:3.6.1\")\n}\n",[],[371,352],"5347c992-c00a-4b16-af28-0df7aa08eb95","01a01c42-f15a-70d4-b991-c72c6f229b06",48,["D",1787180659918],"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.TimeUnit\n\n/**\n * Local YouTube resolver. The app does not use an iframe, Piped, or a remote resolver.\n *\n * Important: this class does not try to disguise automation or bypass YouTube anti-bot systems.\n * If YouTube requires authentication for the current IP/video, the supported path is a real\n * user session exported as cookies.txt. yt-dlp is updated periodically so extractor changes do\n * not leave the bundled runtime stale.\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 = MUXED_BEST,\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 http = OkHttpClient.Builder()\n .connectTimeout(18, TimeUnit.SECONDS)\n .readTimeout(20, TimeUnit.SECONDS)\n .followRedirects(true)\n .followSslRedirects(true)\n .retryOnConnectionFailure(true)\n .build()\n\n @Volatile private var initialized = false\n\n @Synchronized\n private fun ensureInitialized(onStatus: (String) -> Unit) {\n if (!initialized) {\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 // Successful updates are checked every 6h. A failed update is retried after 20 minutes\n // instead of suppressing retries for half a day.\n val now = System.currentTimeMillis()\n val lastSuccess = prefs.getLong(\"last_update_success\", 0L)\n val lastAttempt = prefs.getLong(\"last_update_attempt\", 0L)\n val successStale = now - lastSuccess >= 6L * 60L * 60L * 1000L\n val retryAllowed = now - lastAttempt >= 20L * 60L * 1000L\n if (successStale && retryAllowed) {\n prefs.edit().putLong(\"last_update_attempt\", now).apply()\n runCatching {\n onStatus(\"به‌روزرسانی yt-dlp برای تغییرات جدید YouTube…\")\n YoutubeDL.getInstance().updateYoutubeDL(app, YoutubeDL.UpdateChannel.NIGHTLY)\n }.onSuccess {\n prefs.edit().putLong(\"last_update_success\", System.currentTimeMillis()).apply()\n }.onFailure {\n onStatus(\"به‌روزرسانی در دسترس نبود؛ ادامه با موتور داخلی برنامه…\")\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\n val cookieFile = rawSessionCookie\n ?.trim()\n ?.takeIf { it.isNotBlank() }\n ?.let(::prepareCookieFile)\n\n val strategies = if (cookieFile == null) {\n listOf(\n // android_vr is currently one of yt-dlp's clients that does not require a GVS\n // PO token. It can still be rejected server-side for some IPs/videos.\n Strategy(\"android_vr\", \"android_vr\"),\n // web_safari can expose HLS variants that are useful when direct GVS URLs are\n // unavailable. Prefer HLS first, then fall back to any muxed stream it exposes.\n Strategy(\"web_safari HLS\", \"web_safari\", HLS_FIRST),\n Strategy(\"web_embedded\", \"web_embedded\"),\n Strategy(\"انتخاب خودکار yt-dlp\", null),\n Strategy(\"انتخاب خودکار yt-dlp + IPv4\", null, forceIpv4 = true)\n )\n } else {\n listOf(\n // A real exported session is the supported route when YouTube asks this IP to sign in.\n Strategy(\"نشست کاربر + web_safari HLS\", \"web_safari\", HLS_FIRST),\n Strategy(\"نشست کاربر + انتخاب خودکار\", null),\n Strategy(\"نشست کاربر + web_embedded\", \"web_embedded\"),\n Strategy(\"نشست کاربر + IPv4\", null, 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\n for (index in startStrategy.coerceAtLeast(0) until strategies.size) {\n val strategy = strategies[index]\n try {\n onStatus(\"Resolver محلی ${index + 1}/${strategies.size}: ${strategy.label}…\")\n val request = YoutubeDLRequest(youtubeUrl)\n .addOption(\"--ignore-config\")\n .addOption(\"--no-playlist\")\n .addOption(\"--no-warnings\")\n .addOption(\"--socket-timeout\", \"20\")\n .addOption(\"--retries\", \"3\")\n .addOption(\"--extractor-retries\", \"3\")\n .addOption(\"--fragment-retries\", \"2\")\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 info = YoutubeDL.getInstance().getInfo(request)\n val url = info.url?.takeIf { it.startsWith(\"http://\") || it.startsWith(\"https://\") }\n ?: throw ResolverException(\"yt-dlp URL قابل پخش برنگرداند\")\n\n val headers = LinkedHashMap()\n info.httpHeaders?.forEach { (k, v) ->\n if (k.isNotBlank() && v.isNotBlank()) headers[k] = v\n }\n if (headers.keys.none { it.equals(\"User-Agent\", ignoreCase = true) }) {\n headers[\"User-Agent\"] = DEFAULT_USER_AGENT\n }\n\n probe(url, headers)\n\n val quality = when {\n info.height > 0 -> \"${info.height}p\"\n !info.resolution.isNullOrBlank() -> info.resolution.orEmpty()\n !info.format.isNullOrBlank() -> info.format.orEmpty()\n else -> \"auto\"\n }\n val isLive = info.duration <= 0 &&\n (url.contains(\"m3u8\", true) || info.format?.contains(\"hls\", true) == true)\n\n return ResolvedMedia(\n uri = url,\n title = info.title?.takeIf { it.isNotBlank() } ?: \"YouTube\",\n quality = quality,\n requestHeaders = headers,\n strategyIndex = index,\n strategyLabel = strategy.label,\n isLive = isLive\n )\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/ویدیو نشست واقعی می‌خواهد. یک cookies.txt معتبر از نشست خودتان وارد کنید؛ \" +\n \"بدون نشست معتبر، برنامه نباید سامانه ضدربات YouTube را دور بزند.\"\n )\n }\n throw ResolverException(\n \"نشست YouTube واردشده پذیرفته نشد یا منقضی شده است. cookies.txt تازه از یک نشست واقعی وارد کنید. \" +\n failures.takeLast(2).joinToString(\" | \")\n )\n }\n\n if (sawHttp403) {\n throw ResolverException(\n \"YouTube لینک‌های این ویدیو را با HTTP 403 رد کرد. yt-dlp به‌روز شد/بررسی شد؛ اگر این وضعیت ادامه دارد، \" +\n \"نشست معتبر YouTube لازم است. \" + failures.takeLast(2).joinToString(\" | \")\n )\n }\n\n throw ResolverException(\n \"همه مسیرهای محلی شکست خوردند. \" + failures.takeLast(4).joinToString(\" | \")\n )\n }\n\n private fun probe(url: String, headers: Map) {\n val builder = Request.Builder().url(url).get().header(\"Range\", \"bytes=0-4095\")\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 برگشت، نه فایل ویدیو\")\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()) {\n throw ResolverException(\"فایل/متن نشست هیچ Cookie قابل استفاده‌ای ندارد.\")\n }\n if (cookieRows.none { it.contains(\"youtube.com\", true) || it.contains(\"google.com\", true) }) {\n throw ResolverException(\"cookies.txt شامل Cookie مربوط به YouTube/Google نیست.\")\n }\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(\"HTTP Error 403\", true) || msg.contains(\"HTTP 403\", true) ->\n \"لینک stream با 403 رد شد\"\n msg.contains(\"Requested format is not available\", true) ->\n \"این client فرمت قابل پخش مناسب نداد\"\n msg.contains(\"timeout\", true) -> \"timeout شبکه/YouTube\"\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 MUXED_BEST =\n \"best[ext=mp4][vcodec!=none][acodec!=none]/best[vcodec!=none][acodec!=none]/best\"\n private const val HLS_FIRST =\n \"best[protocol=m3u8_native]/best[protocol=m3u8]/best[vcodec!=none][acodec!=none]/best\"\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",[],[371,33],"a3f2a4e9-e967-403a-aadd-db9e1310690e","01a01c42-f15a-70d4-b991-cb8e0c478353",54,["D",1787180706205],[],[371,531],"1b01a7a1-ca7e-4f75-9a9d-b5cc75f419ec","01a01c42-f15a-70d4-b991-c037a210bfd4",53,["D",1787180699813],5,[],[371,539],"0258f8df-e804-4b22-892f-f6c3cb2a75d0","01a01c42-f15a-70d4-b991-bf6f5fd2715e",44,["D",1787180544349],[],[371,546],["D",1787180538676],[399,400,401,402,403],[371],"3a57f153-cf63-420f-aba4-cee5e89dda57","b34eb954-9c1a-11f1-8222-1607ee4eb77e",["D",1787177391642],"plugins {\n id(\"com.android.application\")\n id(\"org.jetbrains.kotlin.android\")\n}\n\nandroid {\n namespace = \"com.openai.universaldubber\"\n compileSdk = 35\n\n defaultConfig {\n applicationId = \"com.openai.universaldubber\"\n minSdk = 26\n targetSdk = 35\n versionCode = 30\n versionName = \"5.9.0\"\n testInstrumentationRunner = \"androidx.test.runner.AndroidJUnitRunner\"\n ndk {\n abiFilters += listOf(\"arm64-v8a\", \"armeabi-v7a\", \"x86_64\", \"x86\")\n }\n }\n\n buildFeatures {\n buildConfig = true\n }\n\n packaging {\n jniLibs.useLegacyPackaging = true\n }\n\n buildTypes {\n release {\n isMinifyEnabled = false\n proguardFiles(\n getDefaultProguardFile(\"proguard-android-optimize.txt\"),\n \"proguard-rules.pro\"\n )\n }\n }\n\n compileOptions {\n isCoreLibraryDesugaringEnabled = true\n sourceCompatibility = JavaVersion.VERSION_17\n targetCompatibility = JavaVersion.VERSION_17\n }\n kotlinOptions { jvmTarget = \"17\" }\n}\n\ndependencies {\n implementation(\"androidx.core:core-ktx:1.15.0\")\n implementation(\"androidx.appcompat:appcompat:1.7.0\")\n implementation(\"com.google.android.material:material:1.12.0\")\n implementation(\"com.squareup.okhttp3:okhttp:4.12.0\")\n\n implementation(\"androidx.media3:media3-exoplayer:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-hls:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-dash:1.8.1\")\n implementation(\"androidx.media3:media3-exoplayer-rtsp:1.8.1\")\n implementation(\"androidx.media3:media3-ui:1.8.1\")\n\n implementation(\"io.github.junkfood02.youtubedl-android:library:0.18.1\")\n implementation(\"io.github.junkfood02.youtubedl-android:ffmpeg:0.18.1\")\n implementation(\"com.github.teamnewpipe:NewPipeExtractor:v0.26.2\")\n\n coreLibraryDesugaring(\"com.android.tools:desugar_jdk_libs_nio:2.0.1\")\n\n testImplementation(\"junit:junit:4.13.2\")\n testImplementation(\"org.json:json:20240303\")\n androidTestImplementation(\"androidx.test.ext:junit:1.2.1\")\n androidTestImplementation(\"androidx.test.espresso:espresso-core:3.6.1\")\n}\n",[],[377,352],"bb87f016-7e1c-4e98-a581-d513fe819f82","c70d4528-9c1a-11f1-bd7c-1607ee4eb77e",32,["D",1787177424770],"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.TimeUnit\n\n/**\n * Resolves YouTube entirely on the Android device with yt-dlp + QuickJS.\n *\n * Runtime playback never uses YouTube IFrame, Piped or a remote resolver IP. The resolver is\n * deliberately retryable because YouTube rotates player clients/signatures and signed media URLs.\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 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 http = OkHttpClient.Builder()\n .connectTimeout(18, TimeUnit.SECONDS)\n .readTimeout(18, TimeUnit.SECONDS)\n .followRedirects(true)\n .followSslRedirects(true)\n .build()\n\n @Volatile private var initialized = false\n\n @Synchronized\n private fun ensureInitialized(onStatus: (String) -> Unit) {\n if (!initialized) {\n onStatus(\"در حال آماده‌سازی موتور محلی yt-dlp + QuickJS…\")\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 val now = System.currentTimeMillis()\n val last = prefs.getLong(\"last_update_attempt\", 0L)\n if (now - last >= 12L * 60L * 60L * 1000L) {\n prefs.edit().putLong(\"last_update_attempt\", now).apply()\n runCatching {\n onStatus(\"بررسی نسخه جدید yt-dlp برای سازگاری با تغییرات YouTube…\")\n YoutubeDL.getInstance().updateYoutubeDL(app, YoutubeDL.UpdateChannel.NIGHTLY)\n }.onFailure {\n onStatus(\"به‌روزرسانی yt-dlp در دسترس نبود؛ ادامه با نسخه داخلی برنامه…\")\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\n val cookieFile = rawSessionCookie\n ?.trim()\n ?.takeIf { it.isNotBlank() }\n ?.let(::prepareCookieFile)\n\n val strategies = if (cookieFile == null) {\n listOf(\n Strategy(\"android_vr (بدون PoToken)\", \"android_vr\"),\n Strategy(\"web_embedded + default\", \"web_embedded,default\"),\n Strategy(\"web_safari + default\", \"web_safari,default\"),\n Strategy(\"انتخاب خودکار yt-dlp\", null),\n Strategy(\"انتخاب خودکار yt-dlp + IPv4\", null, forceIpv4 = true)\n )\n } else {\n listOf(\n Strategy(\"نشست کاربر + انتخاب خودکار\", null),\n Strategy(\"نشست کاربر + tv_downgraded/default\", \"tv_downgraded,default\"),\n Strategy(\"نشست کاربر + web_embedded/default\", \"web_embedded,default\"),\n Strategy(\"نشست کاربر + IPv4\", null, forceIpv4 = true)\n )\n }\n\n val failures = mutableListOf()\n for (index in startStrategy.coerceAtLeast(0) until strategies.size) {\n val strategy = strategies[index]\n try {\n onStatus(\"Resolver محلی ${index + 1}/${strategies.size}: ${strategy.label}…\")\n val request = YoutubeDLRequest(youtubeUrl)\n .addOption(\"--no-playlist\")\n .addOption(\"--no-warnings\")\n .addOption(\"--socket-timeout\", \"20\")\n .addOption(\"--retries\", \"2\")\n .addOption(\"--fragment-retries\", \"2\")\n .addOption(\"-f\", \"best[ext=mp4][vcodec!=none][acodec!=none]/best[vcodec!=none][acodec!=none]/best\")\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 info = YoutubeDL.getInstance().getInfo(request)\n val url = info.url?.takeIf { it.startsWith(\"http://\") || it.startsWith(\"https://\") }\n ?: throw ResolverException(\"yt-dlp URL قابل پخش برنگرداند\")\n val headers = LinkedHashMap()\n info.httpHeaders?.forEach { (k, v) -> if (k.isNotBlank() && v.isNotBlank()) headers[k] = v }\n if (headers.keys.none { it.equals(\"User-Agent\", ignoreCase = true) }) {\n headers[\"User-Agent\"] = DEFAULT_USER_AGENT\n }\n\n probe(url, headers)\n\n val quality = when {\n info.height > 0 -> \"${info.height}p\"\n !info.resolution.isNullOrBlank() -> info.resolution.orEmpty()\n !info.format.isNullOrBlank() -> info.format.orEmpty()\n else -> \"auto\"\n }\n val isLive = info.duration <= 0 && (url.contains(\"m3u8\", true) || info.format?.contains(\"hls\", true) == true)\n return ResolvedMedia(\n uri = url,\n title = info.title?.takeIf { it.isNotBlank() } ?: \"YouTube\",\n quality = quality,\n requestHeaders = headers,\n strategyIndex = index,\n strategyLabel = strategy.label,\n isLive = isLive\n )\n } catch (t: Throwable) {\n failures += \"${strategy.label}: ${friendly(t)}\"\n }\n }\n\n throw ResolverException(\n \"همه مسیرهای محلی شکست خوردند. \" + failures.takeLast(4).joinToString(\" | \")\n )\n }\n\n private fun probe(url: String, headers: Map) {\n val builder = Request.Builder().url(url).get().header(\"Range\", \"bytes=0-4095\")\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 برگشت، نه فایل ویدیو\")\n }\n }\n }\n\n private fun prepareCookieFile(raw: String): File {\n val file = File(app.noBackupFilesDir, \"youtube-session-cookies.txt\")\n val text = if (raw.startsWith(\"# Netscape HTTP Cookie File\")) {\n raw\n } else {\n val expiry = 2147483647L\n buildString {\n append(\"# Netscape HTTP Cookie File\\n\")\n raw.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 file.parentFile?.mkdirs()\n file.writeText(text, Charsets.UTF_8)\n return file\n }\n\n private fun friendly(t: Throwable): String {\n val msg = rootMessage(t)\n return when {\n msg.contains(\"confirm you're not a bot\", true) || msg.contains(\"LOGIN_REQUIRED\", true) ->\n \"YouTube این IP/نشست ناشناس را رد کرد\"\n msg.contains(\"HTTP Error 403\", true) || msg.contains(\"HTTP 403\", true) ->\n \"لینک امضاشده/PoToken با 403 رد شد\"\n msg.contains(\"Requested format is not available\", true) ->\n \"این client فرمت صوت+تصویر مشترک نداد\"\n msg.contains(\"Sign in\", true) ->\n \"این ویدیو به نشست واردشده نیاز دارد\"\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 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",[],[377,33],"9d4b3e2b-6e4b-4663-a8a0-e8c2127aeed9","df770e28-9c1a-11f1-a236-1607ee4eb77e",33,["D",1787177465715],"package com.openai.universaldubber\n\nimport android.app.Notification\nimport android.app.NotificationChannel\nimport android.app.NotificationManager\nimport android.app.PendingIntent\nimport android.app.Service\nimport android.content.Intent\nimport android.content.pm.ServiceInfo\nimport android.os.Binder\nimport android.os.Build\nimport android.os.Handler\nimport android.os.IBinder\nimport android.os.Looper\nimport androidx.core.app.NotificationCompat\nimport androidx.media3.common.C\nimport androidx.media3.common.MediaItem\nimport androidx.media3.common.PlaybackException\nimport androidx.media3.common.Player\nimport androidx.media3.common.audio.AudioProcessor\nimport androidx.media3.common.util.UnstableApi\nimport androidx.media3.datasource.DefaultDataSource\nimport androidx.media3.datasource.DefaultHttpDataSource\nimport androidx.media3.exoplayer.DefaultRenderersFactory\nimport androidx.media3.exoplayer.ExoPlayer\nimport androidx.media3.exoplayer.audio.AudioSink\nimport androidx.media3.exoplayer.audio.DefaultAudioSink\nimport androidx.media3.exoplayer.audio.TeeAudioProcessor\nimport androidx.media3.exoplayer.source.DefaultMediaSourceFactory\nimport java.util.concurrent.Executors\nimport java.util.concurrent.atomic.AtomicBoolean\n\n@UnstableApi\nclass UniversalPlaybackService : Service(), GeminiLiveTranslator.Listener {\n\n data class Snapshot(\n val loaded: Boolean,\n val dubbing: Boolean,\n val title: String,\n val status: String,\n val isPlaying: Boolean\n )\n\n inner class LocalBinder : Binder() {\n val service: UniversalPlaybackService get() = this@UniversalPlaybackService\n }\n\n companion object {\n const val ACTION_LOAD = \"com.openai.universaldubber.action.LOAD_LOCAL_YOUTUBE\"\n const val ACTION_PLAY = \"com.openai.universaldubber.action.PLAY_LOCAL_YOUTUBE\"\n const val ACTION_PAUSE = \"com.openai.universaldubber.action.PAUSE_LOCAL_YOUTUBE\"\n const val ACTION_TOGGLE = \"com.openai.universaldubber.action.TOGGLE_LOCAL_YOUTUBE\"\n const val ACTION_STOP_ALL = \"com.openai.universaldubber.action.STOP_LOCAL_YOUTUBE\"\n const val ACTION_START_DUB = \"com.openai.universaldubber.action.START_BACKGROUND_DUB\"\n const val ACTION_STOP_DUB = \"com.openai.universaldubber.action.STOP_BACKGROUND_DUB\"\n const val ACTION_EVENT = \"com.openai.universaldubber.action.PLAYBACK_EVENT\"\n\n const val EXTRA_URL = \"url\"\n const val EXTRA_SESSION = \"youtube_session\"\n const val EXTRA_API_KEY = \"api_key\"\n const val EXTRA_LANGUAGE = \"language\"\n const val EXTRA_EVENT = \"event\"\n const val EXTRA_MESSAGE = \"message\"\n const val EXTRA_TITLE = \"title\"\n\n const val EVENT_STATUS = \"status\"\n const val EVENT_ERROR = \"error\"\n const val EVENT_READY = \"ready\"\n const val EVENT_PLAYING = \"playing\"\n const val EVENT_PAUSED = \"paused\"\n const val EVENT_DUB_CONNECTING = \"dub_connecting\"\n const val EVENT_DUB_READY = \"dub_ready\"\n const val EVENT_DUB_STOPPED = \"dub_stopped\"\n const val EVENT_INPUT = \"input\"\n const val EVENT_OUTPUT = \"output\"\n\n private const val CHANNEL_ID = \"universal_dubber_background_playback\"\n private const val NOTIFICATION_ID = 5901\n }\n\n private val binder = LocalBinder()\n private val main = Handler(Looper.getMainLooper())\n private val resolverExecutor = Executors.newSingleThreadExecutor()\n private val resolving = AtomicBoolean(false)\n\n lateinit var player: ExoPlayer\n private set\n\n private lateinit var resolver: YtDlpLocalResolver\n private lateinit var translator: GeminiLiveTranslator\n private lateinit var httpDataSourceFactory: DefaultHttpDataSource.Factory\n private val dubbedAudio = StreamingPcmPlayer()\n\n @Volatile private var loaded = false\n @Volatile private var dubbing = false\n @Volatile private var title = \"YouTube\"\n @Volatile private var status = \"آماده\"\n @Volatile private var currentYoutubeUrl: String? = null\n @Volatile private var currentSessionCookie: String? = null\n private var currentResolved: YtDlpLocalResolver.ResolvedMedia? = null\n private var recoveryAttempts = 0\n private var pendingSeekMs = 0L\n private var foregroundStarted = false\n\n override fun onCreate() {\n super.onCreate()\n createChannel()\n resolver = YtDlpLocalResolver(this)\n translator = GeminiLiveTranslator(this)\n buildPlayer()\n }\n\n override fun onBind(intent: Intent?): IBinder = binder\n\n override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {\n when (intent?.action) {\n ACTION_LOAD -> {\n ensureForeground(\"در حال آماده‌سازی پخش محلی YouTube…\")\n val url = intent.getStringExtra(EXTRA_URL)?.trim().orEmpty()\n val cookie = intent.getStringExtra(EXTRA_SESSION)?.trim().orEmpty().ifBlank { null }\n if (url.isNotBlank()) loadYoutube(url, cookie)\n }\n ACTION_PLAY -> {\n if (::player.isInitialized) player.play()\n updateNotification()\n }\n ACTION_PAUSE -> {\n if (::player.isInitialized) player.pause()\n updateNotification()\n }\n ACTION_TOGGLE -> {\n if (::player.isInitialized) {\n if (player.isPlaying) player.pause() else player.play()\n }\n updateNotification()\n }\n ACTION_START_DUB -> {\n val key = intent.getStringExtra(EXTRA_API_KEY)?.trim().orEmpty()\n val language = intent.getStringExtra(EXTRA_LANGUAGE)?.trim().orEmpty()\n startDubbing(key, language)\n }\n ACTION_STOP_DUB -> stopDubbing(\"دوبله متوقف شد؛ پخش اصلی ادامه دارد.\")\n ACTION_STOP_ALL -> {\n stopDubbingInternal()\n player.stop()\n loaded = false\n stopForegroundCompat()\n stopSelf()\n }\n }\n return START_NOT_STICKY\n }\n\n fun snapshot(): Snapshot = Snapshot(\n loaded = loaded,\n dubbing = dubbing,\n title = title,\n status = status,\n isPlaying = ::player.isInitialized && player.isPlaying\n )\n\n private fun buildPlayer() {\n val pcmTap = PlayerPcmTap(\n onChunk16kMono = { chunk ->\n if (dubbing && translator.isReady()) translator.sendAudio(chunk)\n },\n onFormat = { message ->\n if (loaded && !dubbing) sendStatus(\"پخش محلی فعال است. $message\")\n }\n )\n val tee = TeeAudioProcessor(pcmTap)\n val renderersFactory = object : DefaultRenderersFactory(this) {\n override fun buildAudioSink(\n context: android.content.Context,\n enableFloatOutput: Boolean,\n enableAudioOutputPlaybackParams: Boolean\n ): AudioSink = DefaultAudioSink.Builder(context)\n .setAudioProcessors(arrayOf(tee))\n .build()\n }.setEnableDecoderFallback(true)\n\n httpDataSourceFactory = DefaultHttpDataSource.Factory()\n .setUserAgent(YtDlpLocalResolver.DEFAULT_USER_AGENT)\n .setConnectTimeoutMs(20_000)\n .setReadTimeoutMs(35_000)\n .setAllowCrossProtocolRedirects(true)\n\n val mediaSourceFactory = DefaultMediaSourceFactory(\n DefaultDataSource.Factory(this, httpDataSourceFactory)\n )\n\n player = ExoPlayer.Builder(this, renderersFactory)\n .setMediaSourceFactory(mediaSourceFactory)\n .build()\n player.setWakeMode(C.WAKE_MODE_LOCAL)\n player.setHandleAudioBecomingNoisy(true)\n player.addListener(object : Player.Listener {\n override fun onPlaybackStateChanged(playbackState: Int) {\n when (playbackState) {\n Player.STATE_BUFFERING -> sendStatus(\"در حال بافر پخش محلی…\")\n Player.STATE_READY -> {\n loaded = true\n recoveryAttempts = 0\n val seek = pendingSeekMs\n pendingSeekMs = 0L\n if (seek > 0L && currentResolved?.isLive != true) player.seekTo(seek)\n sendEvent(EVENT_READY, \"پخش محلی آماده است ✓\", title)\n updateNotification()\n }\n Player.STATE_ENDED -> {\n sendStatus(\"ویدیو تمام شد.\")\n updateNotification()\n }\n }\n }\n\n override fun onIsPlayingChanged(isPlaying: Boolean) {\n sendEvent(\n if (isPlaying) EVENT_PLAYING else EVENT_PAUSED,\n if (isPlaying) \"پخش در پس‌زمینه فعال است ✓\" else \"پخش مکث شد.\",\n title\n )\n updateNotification()\n }\n\n override fun onPlayerError(error: PlaybackException) {\n recoverPlayback(\"Media3 ${error.errorCodeName}: ${error.message ?: \"unknown\"}\")\n }\n })\n }\n\n private fun loadYoutube(url: String, cookie: String?) {\n currentYoutubeUrl = url\n currentSessionCookie = cookie\n currentResolved = null\n loaded = false\n recoveryAttempts = 0\n pendingSeekMs = 0L\n player.stop()\n resolveAndPlay(startStrategy = 0, reason = \"شروع resolver محلی\")\n }\n\n private fun resolveAndPlay(startStrategy: Int, reason: String) {\n if (!resolving.compareAndSet(false, true)) return\n val url = currentYoutubeUrl ?: run {\n resolving.set(false)\n return\n }\n val cookie = currentSessionCookie\n sendStatus(\"$reason؛ yt-dlp روی خود گوشی در حال استخراج لینک پخش…\")\n\n resolverExecutor.execute {\n try {\n val resolved = resolver.resolve(\n youtubeUrl = url,\n rawSessionCookie = cookie,\n startStrategy = startStrategy,\n onStatus = { sendStatus(it) }\n )\n main.post {\n resolving.set(false)\n if (currentYoutubeUrl != url) return@post\n currentResolved = resolved\n title = resolved.title\n httpDataSourceFactory.setDefaultRequestProperties(resolved.requestHeaders)\n val mediaItem = MediaItem.Builder()\n .setUri(resolved.uri)\n .setMediaId(url)\n .build()\n player.setMediaItem(mediaItem)\n player.prepare()\n player.playWhenReady = true\n sendStatus(\"لینک مستقیم روی گوشی probe شد ✓ ${resolved.strategyLabel} • ${resolved.quality}\")\n updateNotification()\n }\n } catch (t: Throwable) {\n main.post {\n resolving.set(false)\n loaded = false\n sendError(\"Resolver محلی ناموفق بود: ${friendly(t)}\")\n updateNotification()\n }\n }\n }\n }\n\n private fun recoverPlayback(reason: String) {\n val url = currentYoutubeUrl ?: run {\n sendError(\"خطای Player: $reason\")\n return\n }\n if (resolving.get()) return\n if (recoveryAttempts >= 4) {\n sendError(\"پخش بعد از ۴ تلاش بازیابی نشد: $reason\")\n return\n }\n\n recoveryAttempts += 1\n pendingSeekMs = player.currentPosition.coerceAtLeast(0L)\n val currentIndex = currentResolved?.strategyIndex ?: 0\n val nextStart = if (recoveryAttempts == 1) currentIndex else currentIndex + 1\n loaded = false\n player.stop()\n currentYoutubeUrl = url\n resolveAndPlay(\n startStrategy = nextStart,\n reason = \"لینک امضاشده منقضی/رد شد؛ بازیابی خودکار ${recoveryAttempts}/4\"\n )\n }\n\n private fun startDubbing(apiKey: String, language: String) {\n if (!loaded) {\n sendError(\"اول ویدیو باید در Player محلی آماده شود.\")\n return\n }\n if (apiKey.isBlank() || language.isBlank()) {\n sendError(\"کلید Gemini یا زبان دوبله خالی است.\")\n return\n }\n if (dubbing) return\n ensureForeground(\"پخش و دوبله در پس‌زمینه فعال است\")\n dubbing = true\n sendEvent(EVENT_DUB_CONNECTING, \"اتصال Gemini برای دوبله پس‌زمینه…\", title)\n translator.connect(apiKey, language, false)\n if (!player.isPlaying) player.play()\n }\n\n private fun stopDubbing(message: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendEvent(EVENT_DUB_STOPPED, message, title)\n updateNotification()\n }\n\n private fun stopDubbingInternal() {\n dubbing = false\n runCatching { translator.endAudioStream() }\n runCatching { translator.close() }\n dubbedAudio.stop()\n if (::player.isInitialized) player.volume = 1f\n }\n\n override fun onConnecting() {\n if (dubbing) sendEvent(EVENT_DUB_CONNECTING, \"Gemini در حال اتصال است؛ ویدیو ادامه دارد…\", title)\n }\n\n override fun onReady() {\n if (!dubbing) return\n dubbedAudio.start()\n player.volume = 0.22f\n if (!player.isPlaying) player.play()\n sendEvent(EVENT_DUB_READY, \"دوبله فعال ✓ با خروج از برنامه هم ادامه می‌دهد.\", title)\n updateNotification()\n }\n\n override fun onProtocolFallback(message: String) {\n if (dubbing) sendStatus(\"Gemini مسیر سازگاری را فعال کرد: $message\")\n }\n\n override fun onInputTranscript(text: String) {\n if (dubbing) sendEvent(EVENT_INPUT, text.takeLast(1400), title)\n }\n\n override fun onOutputTranscript(text: String) {\n if (dubbing) sendEvent(EVENT_OUTPUT, text.takeLast(1400), title)\n }\n\n override fun onAudio(pcm24k: ByteArray) {\n if (dubbing) dubbedAudio.write(pcm24k)\n }\n\n override fun onInterrupted() {\n dubbedAudio.flush()\n }\n\n override fun onError(message: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendError(\"خطای دوبله: $message — پخش اصلی ادامه دارد.\")\n updateNotification()\n }\n\n override fun onClosed(reason: String) {\n if (!dubbing) return\n stopDubbingInternal()\n sendError(\"اتصال دوبله بسته شد: $reason — پخش اصلی ادامه دارد.\")\n updateNotification()\n }\n\n private fun sendStatus(message: String) {\n status = message\n sendEvent(EVENT_STATUS, message, title)\n }\n\n private fun sendError(message: String) {\n status = message\n sendEvent(EVENT_ERROR, message, title)\n }\n\n private fun sendEvent(event: String, message: String, title: String = this.title) {\n status = message\n sendBroadcast(\n Intent(ACTION_EVENT)\n .setPackage(packageName)\n .putExtra(EXTRA_EVENT, event)\n .putExtra(EXTRA_MESSAGE, message)\n .putExtra(EXTRA_TITLE, title)\n )\n }\n\n private fun ensureForeground(text: String) {\n val notification = buildNotification(text)\n if (!foregroundStarted) {\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {\n startForeground(\n NOTIFICATION_ID,\n notification,\n ServiceInfo.FOREGROUND_SERVICE_TYPE_MEDIA_PLAYBACK\n )\n } else {\n startForeground(NOTIFICATION_ID, notification)\n }\n foregroundStarted = true\n } else {\n getSystemService(NotificationManager::class.java).notify(NOTIFICATION_ID, notification)\n }\n }\n\n private fun updateNotification() {\n if (!foregroundStarted) return\n getSystemService(NotificationManager::class.java)\n .notify(NOTIFICATION_ID, buildNotification(status))\n }\n\n private fun buildNotification(text: String): Notification {\n val open = PendingIntent.getActivity(\n this,\n 1,\n Intent(this, MainActivity::class.java),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val toggle = PendingIntent.getService(\n this,\n 2,\n Intent(this, UniversalPlaybackService::class.java).setAction(ACTION_TOGGLE),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val stop = PendingIntent.getService(\n this,\n 3,\n Intent(this, UniversalPlaybackService::class.java).setAction(ACTION_STOP_ALL),\n PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE\n )\n val toggleLabel = if (::player.isInitialized && player.isPlaying) \"مکث\" else \"پخش\"\n val dubText = if (dubbing) \" • دوبله فعال\" else \"\"\n return NotificationCompat.Builder(this, CHANNEL_ID)\n .setSmallIcon(R.drawable.ic_app_logo)\n .setContentTitle(title.ifBlank { \"Universal Dubber\" })\n .setContentText((text + dubText).take(120))\n .setOngoing(::player.isInitialized && (player.isPlaying || dubbing))\n .setOnlyAlertOnce(true)\n .setContentIntent(open)\n .addAction(0, toggleLabel, toggle)\n .addAction(0, \"توقف کامل\", stop)\n .setCategory(NotificationCompat.CATEGORY_TRANSPORT)\n .setVisibility(NotificationCompat.VISIBILITY_PUBLIC)\n .build()\n }\n\n private fun createChannel() {\n if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) return\n val channel = NotificationChannel(\n CHANNEL_ID,\n \"پخش و دوبله پس‌زمینه\",\n NotificationManager.IMPORTANCE_LOW\n ).apply {\n description = \"پخش محلی YouTube و دوبله زنده حتی هنگام خروج از برنامه\"\n setSound(null, null)\n }\n getSystemService(NotificationManager::class.java).createNotificationChannel(channel)\n }\n\n private fun stopForegroundCompat() {\n foregroundStarted = false\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {\n stopForeground(STOP_FOREGROUND_REMOVE)\n } else {\n @Suppress(\"DEPRECATION\")\n stopForeground(true)\n }\n }\n\n override fun onTaskRemoved(rootIntent: Intent?) {\n updateNotification()\n super.onTaskRemoved(rootIntent)\n }\n\n override fun onDestroy() {\n resolving.set(false)\n resolverExecutor.shutdownNow()\n stopDubbingInternal()\n runCatching { translator.shutdown() }\n if (::player.isInitialized) player.release()\n stopForegroundCompat()\n super.onDestroy()\n }\n\n private fun friendly(t: Throwable): String {\n val msg = generateSequence(t) { it.cause }\n .mapNotNull { it.message?.trim() }\n .firstOrNull { it.isNotBlank() }\n ?: t.javaClass.simpleName\n return msg.take(600)\n }\n}\n",[],[377,531],"f49c4a0d-e8c9-42b4-99ee-80e1f979e139","fc31adca-9c1a-11f1-bbf7-1607ee4eb77e",34,["D",1787177513915],"package com.openai.universaldubber\n\nimport android.Manifest\nimport android.content.BroadcastReceiver\nimport android.content.ComponentName\nimport android.content.Context\nimport android.content.Intent\nimport android.content.IntentFilter\nimport android.content.ServiceConnection\nimport android.content.pm.ActivityInfo\nimport android.content.pm.PackageManager\nimport android.graphics.Color\nimport android.net.Uri\nimport android.os.Build\nimport android.os.Bundle\nimport android.os.IBinder\nimport android.text.InputType\nimport android.text.method.PasswordTransformationMethod\nimport android.view.Gravity\nimport android.view.View\nimport android.view.ViewGroup\nimport android.widget.ArrayAdapter\nimport android.widget.ImageView\nimport android.widget.LinearLayout\nimport android.widget.ScrollView\nimport android.widget.Spinner\nimport android.widget.TextView\nimport androidx.appcompat.app.AppCompatActivity\nimport androidx.core.app.ActivityCompat\nimport androidx.core.content.ContextCompat\nimport androidx.core.view.ViewCompat\nimport androidx.core.view.WindowInsetsCompat\nimport androidx.core.view.WindowInsetsControllerCompat\nimport androidx.media3.common.util.UnstableApi\nimport androidx.media3.ui.PlayerView\nimport com.google.android.material.button.MaterialButton\nimport com.google.android.material.textfield.TextInputEditText\nimport com.google.android.material.textfield.TextInputLayout\n\n@UnstableApi\nclass MainActivity : AppCompatActivity() {\n\n private data class Language(val label: String, val code: String)\n\n companion object {\n private const val REQ_NOTIFICATIONS = 5902\n }\n\n private val languages = listOf(\n Language(\"فارسی\", \"fa\"),\n Language(\"Français\", \"fr\"),\n Language(\"English\", \"en\"),\n Language(\"العربية\", \"ar\"),\n Language(\"Español\", \"es\"),\n Language(\"Deutsch\", \"de\"),\n Language(\"Türkçe\", \"tr\")\n )\n\n private lateinit var rootContainer: LinearLayout\n private lateinit var headerView: View\n private lateinit var controlsScroll: ScrollView\n private lateinit var apiKeyEdit: TextInputEditText\n private lateinit var youtubeUrlEdit: TextInputEditText\n private lateinit var youtubeSessionEdit: TextInputEditText\n private lateinit var languageSpinner: Spinner\n private lateinit var loadButton: MaterialButton\n private lateinit var dubButton: MaterialButton\n private lateinit var stopAllButton: MaterialButton\n private lateinit var statusText: TextView\n private lateinit var inputTranscript: TextView\n private lateinit var outputTranscript: TextView\n private lateinit var videoTitle: TextView\n private lateinit var playerView: PlayerView\n\n private var playbackService: UniversalPlaybackService? = null\n private var serviceBound = false\n private var receiverRegistered = false\n private var isFullscreen = false\n private var videoLoaded = false\n private var dubbing = false\n private var resumeYoutubeAfterLiveTv = false\n\n private val serviceConnection = object : ServiceConnection {\n override fun onServiceConnected(name: ComponentName?, binder: IBinder?) {\n val local = binder as? UniversalPlaybackService.LocalBinder ?: return\n playbackService = local.service\n serviceBound = true\n playerView.player = local.service.player\n applySnapshot(local.service.snapshot())\n }\n\n override fun onServiceDisconnected(name: ComponentName?) {\n playerView.player = null\n playbackService = null\n serviceBound = false\n }\n }\n\n private val playbackReceiver = object : BroadcastReceiver() {\n override fun onReceive(context: Context?, intent: Intent?) {\n if (intent?.action != UniversalPlaybackService.ACTION_EVENT) return\n val event = intent.getStringExtra(UniversalPlaybackService.EXTRA_EVENT).orEmpty()\n val message = intent.getStringExtra(UniversalPlaybackService.EXTRA_MESSAGE).orEmpty()\n val title = intent.getStringExtra(UniversalPlaybackService.EXTRA_TITLE).orEmpty()\n if (title.isNotBlank()) videoTitle.text = title\n\n when (event) {\n UniversalPlaybackService.EVENT_READY -> {\n videoLoaded = true\n loadButton.isEnabled = true\n stopAllButton.isEnabled = true\n setStatus(message.ifBlank { \"پخش محلی آماده است ✓\" })\n }\n UniversalPlaybackService.EVENT_PLAYING -> {\n videoLoaded = true\n stopAllButton.isEnabled = true\n if (!dubbing) setStatus(message.ifBlank { \"پخش در پس‌زمینه فعال است ✓\" })\n }\n UniversalPlaybackService.EVENT_PAUSED -> {\n if (!dubbing) setStatus(message.ifBlank { \"پخش مکث شد.\" })\n }\n UniversalPlaybackService.EVENT_DUB_CONNECTING -> {\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n setStatus(message)\n }\n UniversalPlaybackService.EVENT_DUB_READY -> {\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n setStatus(message.ifBlank { \"دوبله پس‌زمینه فعال ✓\" })\n }\n UniversalPlaybackService.EVENT_DUB_STOPPED -> {\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n setStatus(message)\n }\n UniversalPlaybackService.EVENT_INPUT -> inputTranscript.text = \"متن ورودی: $message\"\n UniversalPlaybackService.EVENT_OUTPUT -> outputTranscript.text = \"ترجمه: $message\"\n UniversalPlaybackService.EVENT_STATUS -> setStatus(message)\n UniversalPlaybackService.EVENT_ERROR -> {\n if (message.contains(\"دوبله\", ignoreCase = true)) {\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n }\n loadButton.isEnabled = true\n setStatus(message.ifBlank { \"خطا\" }, true)\n }\n }\n }\n }\n\n override fun onCreate(savedInstanceState: Bundle?) {\n super.onCreate(savedInstanceState)\n setContentView(buildUi())\n restoreState()\n maybeRequestNotificationPermission()\n consumeIntent(intent)\n }\n\n override fun onNewIntent(intent: Intent) {\n super.onNewIntent(intent)\n setIntent(intent)\n consumeIntent(intent)\n }\n\n private fun buildUi(): View {\n rootContainer = LinearLayout(this).apply {\n orientation = LinearLayout.VERTICAL\n setBackgroundColor(Color.rgb(12, 15, 22))\n layoutDirection = View.LAYOUT_DIRECTION_RTL\n }\n ViewCompat.setOnApplyWindowInsetsListener(rootContainer) { view, insets ->\n val bars = insets.getInsets(WindowInsetsCompat.Type.systemBars())\n if (isFullscreen) view.setPadding(0, 0, 0, 0)\n else view.setPadding(bars.left, bars.top, bars.right, bars.bottom)\n insets\n }\n\n headerView = LinearLayout(this).apply {\n orientation = LinearLayout.HORIZONTAL\n gravity = Gravity.CENTER_VERTICAL\n setPadding(dp(16), dp(10), dp(16), dp(8))\n addView(ImageView(this@MainActivity).apply {\n setImageResource(R.drawable.ic_app_logo)\n contentDescription = \"Universal Dubber logo\"\n scaleType = ImageView.ScaleType.CENTER_INSIDE\n }, LinearLayout.LayoutParams(dp(58), dp(58)))\n addView(LinearLayout(this@MainActivity).apply {\n orientation = LinearLayout.VERTICAL\n setPadding(dp(10), 0, 0, 0)\n addView(TextView(this@MainActivity).apply {\n text = \"Universal Dubber ${BuildConfig.VERSION_NAME} LOCAL\"\n textSize = 24f\n setTextColor(Color.WHITE)\n typeface = android.graphics.Typeface.DEFAULT_BOLD\n })\n addView(TextView(this@MainActivity).apply {\n text = \"Player محلی Media3 + yt-dlp روی گوشی + دوبله پس‌زمینه\"\n textSize = 13f\n setTextColor(Color.rgb(170, 178, 198))\n })\n }, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 1f))\n }\n rootContainer.addView(headerView)\n\n playerView = PlayerView(this).apply {\n useController = true\n setShowBuffering(PlayerView.SHOW_BUFFERING_WHEN_PLAYING)\n setBackgroundColor(Color.BLACK)\n keepScreenOn = true\n setControllerShowTimeoutMs(3_500)\n setControllerHideOnTouch(true)\n setFullscreenButtonClickListener { fullscreen -> setFullscreen(fullscreen) }\n }\n rootContainer.addView(\n playerView,\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, 0, 0.46f).apply {\n marginStart = dp(10)\n marginEnd = dp(10)\n }\n )\n\n val controls = LinearLayout(this).apply {\n orientation = LinearLayout.VERTICAL\n setPadding(dp(14), dp(8), dp(14), dp(18))\n }\n\n videoTitle = TextView(this).apply {\n text = \"ویدیو: هنوز بارگذاری نشده\"\n setTextColor(Color.WHITE)\n textSize = 15f\n maxLines = 2\n setPadding(0, 0, 0, dp(6))\n }\n controls.addView(videoTitle)\n\n youtubeUrlEdit = TextInputEditText(this).apply {\n hint = \"https://www.youtube.com/watch?v=...\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_URI\n setSingleLine(true)\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"لینک YouTube\", youtubeUrlEdit).apply {\n endIconMode = TextInputLayout.END_ICON_CLEAR_TEXT\n })\n\n youtubeSessionEdit = TextInputEditText(this).apply {\n hint = \"Cookie header یا Netscape cookies.txt — اختیاری\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_PASSWORD\n transformationMethod = PasswordTransformationMethod.getInstance()\n setSingleLine(true)\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"نشست YouTube برای ویدیوهای محدود (اختیاری)\", youtubeSessionEdit, password = true))\n\n controls.addView(TextView(this).apply {\n text = \"پخش اصلی دیگر YouTube Player/IFrame یا Piped نیست. yt-dlp + QuickJS روی خود گوشی URL امضاشده را می‌سازد، آن را probe می‌کند و به Media3 محلی می‌دهد. اگر YouTube لینک را منقضی یا 403 کند، سرویس خودکار دوباره resolve می‌کند.\"\n setTextColor(Color.rgb(179, 187, 205))\n textSize = 12.5f\n setPadding(0, dp(4), 0, dp(5))\n })\n\n loadButton = button(\"بارگذاری و پخش محلی\") { loadYoutubeVideo() }\n controls.addView(loadButton, fullWidthParams())\n\n controls.addView(button(\"پاک‌کردن نشست YouTube\") {\n youtubeSessionEdit.setText(\"\")\n SecurePrefs.clearYoutubeSession(this)\n setStatus(\"نشست YouTube از حافظه امن برنامه پاک شد.\")\n }, fullWidthParams())\n\n controls.addView(button(\"تلویزیون زنده — جستجوی شبکه‌های جهانی\") {\n resumeYoutubeAfterLiveTv = playbackService?.player?.isPlaying == true\n sendPlaybackAction(UniversalPlaybackService.ACTION_PAUSE)\n startActivity(Intent(this, LiveTvActivity::class.java))\n }, fullWidthParams())\n\n apiKeyEdit = TextInputEditText(this).apply {\n hint = \"Gemini API Key\"\n inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_PASSWORD\n transformationMethod = PasswordTransformationMethod.getInstance()\n setSingleLine(true)\n textDirection = View.TEXT_DIRECTION_LTR\n setTextColor(Color.WHITE)\n setHintTextColor(Color.rgb(145, 150, 165))\n }\n controls.addView(field(\"کلید Gemini\", apiKeyEdit, password = true))\n\n languageSpinner = Spinner(this).apply {\n adapter = ArrayAdapter(\n this@MainActivity,\n android.R.layout.simple_spinner_dropdown_item,\n languages.map { it.label }\n )\n minimumHeight = dp(48)\n }\n controls.addView(LinearLayout(this).apply {\n orientation = LinearLayout.HORIZONTAL\n gravity = Gravity.CENTER_VERTICAL\n addView(TextView(this@MainActivity).apply {\n text = \"زبان دوبله:\"\n setTextColor(Color.WHITE)\n textSize = 15f\n }, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 0.75f))\n addView(languageSpinner, LinearLayout.LayoutParams(0, ViewGroup.LayoutParams.WRAP_CONTENT, 1.25f))\n })\n\n dubButton = button(\"شروع دوبله فارسی\") {\n if (dubbing) stopDubbing() else startDubbing()\n }.apply { minHeight = dp(58) }\n controls.addView(dubButton, fullWidthParams())\n\n stopAllButton = button(\"توقف کامل پخش و سرویس پس‌زمینه\") {\n sendPlaybackAction(UniversalPlaybackService.ACTION_STOP_ALL)\n videoLoaded = false\n dubbing = false\n playerView.player = null\n videoTitle.text = \"ویدیو: متوقف شد\"\n dubButton.text = \"شروع دوبله فارسی\"\n loadButton.isEnabled = true\n stopAllButton.isEnabled = false\n setStatus(\"پخش، دوبله و سرویس پس‌زمینه متوقف شدند.\")\n }.apply { isEnabled = false }\n controls.addView(stopAllButton, fullWidthParams())\n\n controls.addView(TextView(this).apply {\n text = \"وقتی Home را بزنید، صفحه را خاموش کنید یا وارد برنامه دیگری شوید، Player و Gemini داخل Foreground Service باقی می‌مانند. تصویر با برگشتن به برنامه دوباره به همین Player وصل می‌شود و صدا/دوبله در فاصله خروج قطع نمی‌شود.\"\n setTextColor(Color.rgb(179, 187, 205))\n textSize = 13f\n setPadding(0, dp(5), 0, dp(7))\n })\n\n statusText = TextView(this).apply {\n text = \"آماده. لینک YouTube را وارد کنید.\"\n setTextColor(Color.rgb(0, 220, 185))\n textSize = 14f\n setTextIsSelectable(true)\n maxLines = 12\n setPadding(0, dp(4), 0, dp(4))\n }\n controls.addView(statusText)\n\n inputTranscript = transcriptView(\"متن ورودی\")\n outputTranscript = transcriptView(\"ترجمه\")\n controls.addView(inputTranscript)\n controls.addView(outputTranscript)\n\n controlsScroll = ScrollView(this).apply {\n isFillViewport = true\n addView(controls)\n }\n rootContainer.addView(\n controlsScroll,\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, 0, 0.54f)\n )\n return rootContainer\n }\n\n private fun loadYoutubeVideo() {\n val url = normalizeYoutubeUrl(youtubeUrlEdit.text?.toString().orEmpty())\n if (url == null) {\n setStatus(\"یک لینک معتبر YouTube یا youtu.be وارد کنید.\", true)\n return\n }\n\n val session = youtubeSessionEdit.text?.toString()?.trim().orEmpty()\n if (session.isNotBlank()) SecurePrefs.saveYoutubeSession(this, session)\n\n loadButton.isEnabled = false\n videoLoaded = false\n videoTitle.text = \"ویدیو: در حال resolve محلی…\"\n setStatus(\"yt-dlp + QuickJS روی گوشی در حال استخراج stream است…\")\n\n val serviceIntent = Intent(this, UniversalPlaybackService::class.java)\n .setAction(UniversalPlaybackService.ACTION_LOAD)\n .putExtra(UniversalPlaybackService.EXTRA_URL, url)\n .putExtra(UniversalPlaybackService.EXTRA_SESSION, session)\n ContextCompat.startForegroundService(this, serviceIntent)\n bindPlaybackService()\n }\n\n private fun startDubbing() {\n val loadedNow = playbackService?.snapshot()?.loaded ?: videoLoaded\n if (!loadedNow) {\n setStatus(\"اول ویدیو باید در Player محلی آماده شود.\", true)\n return\n }\n val key = apiKeyEdit.text?.toString()?.trim().orEmpty()\n if (key.isBlank()) {\n setStatus(\"Gemini API Key را وارد کنید.\", true)\n return\n }\n SecurePrefs.saveApiKey(this, key)\n val language = languages[languageSpinner.selectedItemPosition]\n dubbing = true\n dubButton.text = \"توقف دوبله\"\n inputTranscript.text = \"متن ورودی: —\"\n outputTranscript.text = \"ترجمه: —\"\n setStatus(\"در حال فعال‌سازی دوبله داخل سرویس پس‌زمینه…\")\n startService(\n Intent(this, UniversalPlaybackService::class.java)\n .setAction(UniversalPlaybackService.ACTION_START_DUB)\n .putExtra(UniversalPlaybackService.EXTRA_API_KEY, key)\n .putExtra(UniversalPlaybackService.EXTRA_LANGUAGE, language.code)\n )\n }\n\n private fun stopDubbing() {\n sendPlaybackAction(UniversalPlaybackService.ACTION_STOP_DUB)\n dubbing = false\n dubButton.text = \"شروع دوبله فارسی\"\n }\n\n private fun sendPlaybackAction(action: String) {\n runCatching {\n startService(Intent(this, UniversalPlaybackService::class.java).setAction(action))\n }\n }\n\n private fun bindPlaybackService() {\n if (serviceBound) return\n runCatching {\n bindService(\n Intent(this, UniversalPlaybackService::class.java),\n serviceConnection,\n Context.BIND_AUTO_CREATE\n )\n }\n }\n\n private fun applySnapshot(snapshot: UniversalPlaybackService.Snapshot) {\n videoLoaded = snapshot.loaded\n dubbing = snapshot.dubbing\n videoTitle.text = snapshot.title.ifBlank { \"YouTube\" }\n dubButton.text = if (snapshot.dubbing) \"توقف دوبله\" else \"شروع دوبله فارسی\"\n stopAllButton.isEnabled = snapshot.loaded || snapshot.isPlaying || snapshot.dubbing\n loadButton.isEnabled = true\n if (snapshot.status.isNotBlank()) setStatus(snapshot.status)\n }\n\n private fun normalizeYoutubeUrl(input: String): String? {\n val trimmed = input.trim()\n if (trimmed.isBlank()) return null\n if (Regex(\"^[A-Za-z0-9_-]{11}$\").matches(trimmed)) {\n return \"https://www.youtube.com/watch?v=$trimmed\"\n }\n val candidate = if (trimmed.startsWith(\"http://\") || trimmed.startsWith(\"https://\")) {\n trimmed\n } else {\n \"https://$trimmed\"\n }\n val uri = runCatching { Uri.parse(candidate) }.getOrNull() ?: return null\n val host = uri.host?.lowercase().orEmpty()\n return candidate.takeIf {\n host == \"youtu.be\" || host == \"youtube.com\" || host.endsWith(\".youtube.com\")\n }\n }\n\n private fun consumeIntent(intent: Intent?) {\n if (intent == null || !::youtubeUrlEdit.isInitialized) return\n val candidate = when (intent.action) {\n Intent.ACTION_VIEW -> intent.dataString\n Intent.ACTION_SEND -> intent.getStringExtra(Intent.EXTRA_TEXT)\n else -> null\n } ?: return\n if (normalizeYoutubeUrl(candidate) == null) return\n youtubeUrlEdit.setText(candidate)\n loadYoutubeVideo()\n }\n\n private fun restoreState() {\n apiKeyEdit.setText(SecurePrefs.loadApiKey(this))\n youtubeSessionEdit.setText(SecurePrefs.loadYoutubeSession(this))\n languageSpinner.setSelection(0)\n }\n\n private fun maybeRequestNotificationPermission() {\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU &&\n ContextCompat.checkSelfPermission(this, Manifest.permission.POST_NOTIFICATIONS) != PackageManager.PERMISSION_GRANTED\n ) {\n ActivityCompat.requestPermissions(\n this,\n arrayOf(Manifest.permission.POST_NOTIFICATIONS),\n REQ_NOTIFICATIONS\n )\n }\n }\n\n private fun setFullscreen(fullscreen: Boolean) {\n if (isFullscreen == fullscreen) return\n isFullscreen = fullscreen\n headerView.visibility = if (fullscreen) View.GONE else View.VISIBLE\n controlsScroll.visibility = if (fullscreen) View.GONE else View.VISIBLE\n val params = playerView.layoutParams as LinearLayout.LayoutParams\n params.height = 0\n params.weight = if (fullscreen) 1f else 0.46f\n params.marginStart = if (fullscreen) 0 else dp(10)\n params.marginEnd = if (fullscreen) 0 else dp(10)\n playerView.layoutParams = params\n\n if (fullscreen) {\n rootContainer.setPadding(0, 0, 0, 0)\n WindowInsetsControllerCompat(window, window.decorView).apply {\n systemBarsBehavior = WindowInsetsControllerCompat.BEHAVIOR_SHOW_TRANSIENT_BARS_BY_SWIPE\n hide(WindowInsetsCompat.Type.systemBars())\n }\n requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_SENSOR_LANDSCAPE\n } else {\n WindowInsetsControllerCompat(window, window.decorView).show(WindowInsetsCompat.Type.systemBars())\n requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_UNSPECIFIED\n ViewCompat.requestApplyInsets(rootContainer)\n }\n }\n\n private fun field(label: String, editText: TextInputEditText, password: Boolean = false): TextInputLayout =\n TextInputLayout(this).apply {\n hint = label\n boxBackgroundMode = TextInputLayout.BOX_BACKGROUND_OUTLINE\n setBoxStrokeColor(Color.rgb(124, 77, 255))\n setHintTextColor(android.content.res.ColorStateList.valueOf(Color.rgb(188, 194, 210)))\n setBoxBackgroundColor(Color.rgb(23, 27, 37))\n if (password) endIconMode = TextInputLayout.END_ICON_PASSWORD_TOGGLE\n addView(editText)\n }\n\n private fun button(text: String, onClick: () -> Unit): MaterialButton =\n MaterialButton(this).apply {\n this.text = text\n isAllCaps = false\n cornerRadius = dp(14)\n minHeight = dp(50)\n setOnClickListener { onClick() }\n }\n\n private fun fullWidthParams() =\n LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, ViewGroup.LayoutParams.WRAP_CONTENT).apply {\n topMargin = dp(5)\n bottomMargin = dp(5)\n }\n\n private fun transcriptView(label: String) = TextView(this).apply {\n text = \"$label: —\"\n setTextColor(Color.rgb(220, 224, 234))\n textSize = 13f\n maxLines = 4\n setTextIsSelectable(true)\n setPadding(0, dp(3), 0, dp(3))\n }\n\n private fun setStatus(message: String, error: Boolean = false) {\n statusText.text = message\n statusText.setTextColor(if (error) Color.rgb(255, 100, 115) else Color.rgb(0, 220, 185))\n }\n\n override fun onStart() {\n super.onStart()\n if (!receiverRegistered) {\n val filter = IntentFilter(UniversalPlaybackService.ACTION_EVENT)\n if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {\n registerReceiver(playbackReceiver, filter, Context.RECEIVER_NOT_EXPORTED)\n } else {\n @Suppress(\"DEPRECATION\")\n registerReceiver(playbackReceiver, filter)\n }\n receiverRegistered = true\n }\n bindPlaybackService()\n }\n\n override fun onStop() {\n if (serviceBound) {\n playerView.player = null\n runCatching { unbindService(serviceConnection) }\n serviceBound = false\n playbackService = null\n }\n if (receiverRegistered) {\n runCatching { unregisterReceiver(playbackReceiver) }\n receiverRegistered = false\n }\n super.onStop()\n }\n\n override fun onResume() {\n super.onResume()\n if (resumeYoutubeAfterLiveTv) {\n resumeYoutubeAfterLiveTv = false\n sendPlaybackAction(UniversalPlaybackService.ACTION_PLAY)\n }\n }\n\n @Deprecated(\"Deprecated in Java\")\n override fun onBackPressed() {\n if (isFullscreen) setFullscreen(false) else super.onBackPressed()\n }\n\n override fun onDestroy() {\n playerView.player = null\n super.onDestroy()\n }\n\n private fun dp(value: Int): Int = (value * resources.displayMetrics.density).toInt()\n}\n",[],[377,539],"99f0a5e0-d140-4737-bca8-2eb35879f00a","b996a8ee-9c1a-11f1-a611-1607ee4eb77e",31,["D",1787177402097],[],[377,546],["D",1787177391642],[393,394,395,396,397],[377],["D",1787156870791],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":664,"_665":666,"_667":668,"_669":25,"_670":25,"_671":25,"_672":59,"_673":-5,"_674":-7,"_675":-7,"_676":63,"_677":25,"_678":25,"_679":-5,"_680":25,"_681":25,"_682":25,"_683":-5},"ENV",{"_635":636,"_637":638,"_639":87,"_640":641,"_642":643,"_644":645,"_646":647,"_648":649,"_650":651,"_652":653,"_654":655,"_656":657,"_658":659,"_660":661,"_662":663},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

Diff · v90