[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_818":819,"_820":821},"routes/_app.x.$handle.$name",{"_95":94,"_31":43,"_104":85,"_26":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":24,"_119":120,"_121":57,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",112,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","v620/potoken/PoTokenWebView.kt.txt","latestPath","fileId","1cafe502-9cad-11f1-8e5e-1607ee4eb77e","name","PoTokenWebView.kt.txt","fileType","content","package com.openai.universaldubber.potoken\n\nimport android.annotation.SuppressLint\nimport android.content.Context\nimport android.util.Log\nimport android.webkit.ConsoleMessage\nimport android.webkit.JavascriptInterface\nimport android.webkit.WebChromeClient\nimport android.webkit.WebView\nimport androidx.webkit.WebSettingsCompat\nimport androidx.webkit.WebViewFeature\nimport kotlinx.coroutines.CoroutineScope\nimport kotlinx.coroutines.Dispatchers\nimport kotlinx.coroutines.SupervisorJob\nimport kotlinx.coroutines.cancel\nimport kotlinx.coroutines.launch\nimport kotlinx.coroutines.suspendCancellableCoroutine\nimport kotlinx.coroutines.withContext\nimport okhttp3.MediaType.Companion.toMediaType\nimport okhttp3.OkHttpClient\nimport okhttp3.Request\nimport okhttp3.RequestBody.Companion.toRequestBody\nimport java.util.concurrent.TimeUnit\nimport kotlin.coroutines.Continuation\nimport kotlin.coroutines.resume\nimport kotlin.coroutines.resumeWithException\n\n@SuppressLint(\"SetJavaScriptEnabled\")\nclass PoTokenWebView private constructor(context: Context) : PoTokenGenerator {\n private val webView = WebView(context)\n private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Main.immediate)\n private val httpClient = OkHttpClient.Builder()\n .connectTimeout(20, TimeUnit.SECONDS)\n .readTimeout(20, TimeUnit.SECONDS)\n .callTimeout(25, TimeUnit.SECONDS)\n .build()\n\n private val poTokenContinuations = mutableListOf>>()\n private var initContinuation: Continuation? = null\n private var expirationTimeMs: Long = 0L\n\n init {\n webView.settings.javaScriptEnabled = true\n if (WebViewFeature.isFeatureSupported(WebViewFeature.SAFE_BROWSING_ENABLE)) {\n WebSettingsCompat.setSafeBrowsingEnabled(webView.settings, false)\n }\n webView.settings.userAgentString = USER_AGENT\n webView.settings.blockNetworkLoads = true\n webView.addJavascriptInterface(this, JS_INTERFACE)\n webView.webChromeClient = object : WebChromeClient() {\n override fun onConsoleMessage(message: ConsoleMessage): Boolean {\n if (message.message().contains(\"Uncaught\")) {\n val text = \"${message.message()} @ ${message.sourceId()}:${message.lineNumber()}\"\n onInitializationError(BadWebViewException(text))\n popAllPoTokenContinuations().forEach { (_, cont) -> cont.resumeWithException(BadWebViewException(text)) }\n }\n return true\n }\n }\n }\n\n private suspend fun loadHtmlAndObtainBotguard(context: Context): PoTokenWebView =\n suspendCancellableCoroutine { cont ->\n initContinuation = cont\n scope.launch {\n try {\n val html = withContext(Dispatchers.IO) {\n context.assets.open(\"po_token.html\").bufferedReader().use { it.readText() }\n }\n webView.loadDataWithBaseURL(\n \"https://www.youtube.com\",\n html.replaceFirst(\"\", \"\\n$JS_INTERFACE.downloadAndRunBotguard()\"),\n \"text/html\",\n \"utf-8\",\n null,\n )\n } catch (e: Exception) {\n onInitializationError(e)\n }\n }\n cont.invokeOnCancellation { close() }\n }\n\n @JavascriptInterface\n fun downloadAndRunBotguard() {\n scope.launch {\n try {\n val responseBody = postBotguard(\n \"https://www.youtube.com/api/jnn/v1/Create\",\n \"[ \\\"$REQUEST_KEY\\\" ]\",\n )\n val parsedChallengeData = parseChallengeData(responseBody)\n webView.evaluateJavascript(\n \"\"\"try {\n data = $parsedChallengeData;\n runBotGuard(data).then(function(result) {\n this.webPoSignalOutput = result.webPoSignalOutput;\n $JS_INTERFACE.onRunBotguardResult(result.botguardResponse);\n }, function(error) {\n $JS_INTERFACE.onJsInitializationError(error + \"\\\\n\" + error.stack);\n });\n } catch (error) {\n $JS_INTERFACE.onJsInitializationError(error + \"\\\\n\" + error.stack);\n }\"\"\",\n null,\n )\n } catch (e: Exception) {\n onInitializationError(e)\n }\n }\n }\n\n @JavascriptInterface\n fun onJsInitializationError(error: String) {\n Log.e(TAG, \"BotGuard JS init failed: $error\")\n onInitializationError(buildExceptionForJsError(error))\n }\n\n @JavascriptInterface\n fun onRunBotguardResult(botguardResponse: String) {\n scope.launch {\n try {\n val responseBody = postBotguard(\n \"https://www.youtube.com/api/jnn/v1/GenerateIT\",\n \"[ \\\"$REQUEST_KEY\\\", \\\"$botguardResponse\\\" ]\",\n )\n val (integrityToken, expirationSeconds) = parseIntegrityTokenData(responseBody)\n expirationTimeMs = System.currentTimeMillis() + (expirationSeconds - 600L).coerceAtLeast(60L) * 1000L\n webView.evaluateJavascript(\"this.integrityToken = $integrityToken\") {\n initContinuation?.resume(this@PoTokenWebView)\n initContinuation = null\n }\n } catch (e: Exception) {\n onInitializationError(e)\n }\n }\n }\n\n private fun onInitializationError(error: Throwable) {\n scope.launch {\n initContinuation?.resumeWithException(error)\n initContinuation = null\n }\n }\n\n override suspend fun generatePoToken(identifier: String): String =\n withContext(Dispatchers.Main.immediate) {\n suspendCancellableCoroutine { cont ->\n addPoTokenContinuation(identifier, cont)\n val u8Identifier = stringToU8(identifier)\n webView.evaluateJavascript(\n \"\"\"try {\n identifier = \"$identifier\";\n u8Identifier = $u8Identifier;\n poTokenU8 = obtainPoToken(webPoSignalOutput, integrityToken, u8Identifier);\n poTokenU8String = \"\";\n for (i = 0; i < poTokenU8.length; i++) {\n if (i != 0) poTokenU8String += \",\";\n poTokenU8String += poTokenU8[i];\n }\n $JS_INTERFACE.onObtainPoTokenResult(identifier, poTokenU8String);\n } catch (error) {\n $JS_INTERFACE.onObtainPoTokenError(identifier, error + \"\\\\n\" + error.stack);\n }\"\"\",\n null,\n )\n }\n }\n\n @JavascriptInterface\n fun onObtainPoTokenError(identifier: String, error: String) {\n popPoTokenContinuation(identifier)?.resumeWithException(buildExceptionForJsError(error))\n }\n\n @JavascriptInterface\n fun onObtainPoTokenResult(identifier: String, poTokenU8: String) {\n val token = try { u8ToBase64(poTokenU8) } catch (t: Throwable) {\n popPoTokenContinuation(identifier)?.resumeWithException(t)\n return\n }\n popPoTokenContinuation(identifier)?.resume(token)\n }\n\n override fun isExpired(): Boolean = System.currentTimeMillis() >= expirationTimeMs\n\n override fun close() {\n runCatching {\n scope.cancel()\n webView.clearHistory()\n webView.clearCache(true)\n webView.loadUrl(\"about:blank\")\n webView.onPause()\n webView.removeAllViews()\n webView.destroy()\n }\n }\n\n private suspend fun postBotguard(url: String, data: String): String = withContext(Dispatchers.IO) {\n val request = Request.Builder()\n .url(url)\n .header(\"User-Agent\", USER_AGENT)\n .header(\"Accept\", \"application/json\")\n .header(\"Content-Type\", \"application/json+protobuf\")\n .header(\"x-goog-api-key\", GOOGLE_API_KEY)\n .header(\"x-user-agent\", \"grpc-web-javascript/0.1\")\n .post(data.toRequestBody(\"application/json+protobuf\".toMediaType()))\n .build()\n httpClient.newCall(request).execute().use { response ->\n if (!response.isSuccessful) throw PoTokenException(\"BotGuard HTTP ${response.code}\")\n response.body?.string() ?: throw PoTokenException(\"BotGuard empty response\")\n }\n }\n\n private fun addPoTokenContinuation(identifier: String, cont: Continuation) {\n synchronized(poTokenContinuations) { poTokenContinuations.add(identifier to cont) }\n }\n\n private fun popPoTokenContinuation(identifier: String): Continuation? = synchronized(poTokenContinuations) {\n val index = poTokenContinuations.indexOfFirst { it.first == identifier }\n if (index < 0) null else poTokenContinuations.removeAt(index).second\n }\n\n private fun popAllPoTokenContinuations(): List>> = synchronized(poTokenContinuations) {\n val copy = poTokenContinuations.toList()\n poTokenContinuations.clear()\n copy\n }\n\n companion object : PoTokenGenerator.Factory {\n private const val TAG = \"PoTokenWebView\"\n private const val GOOGLE_API_KEY = \"AIzaSyDyT5W0Jh49F30Pqqtyfdf7pDLFKLJoAnw\"\n private const val REQUEST_KEY = \"O43z0dpjhgX20SCx4KAo\"\n private const val USER_AGENT = \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36\"\n private const val JS_INTERFACE = \"PoTokenWebView\"\n\n override suspend fun newPoTokenGenerator(context: Context): PoTokenGenerator =\n withContext(Dispatchers.Main.immediate) {\n PoTokenWebView(context).loadHtmlAndObtainBotguard(context)\n }\n }\n}\n","createdAt",["D",1787240274933],"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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":53,"_100":101,"_102":24},"branch",{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"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",{"_41":42,"_31":43,"_36":814,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":815,"_79":816,"_81":817,"_83":24},"tree",[461,467,473,479,490,491,492,493,494,495,496,497,498,499,500,501,502,503,504,505,506,507,508,509,510,511,512,513,514,515,516,517,518,519,520,521,522,523,524],"files",[461,462,463,464,465,466,467,468,469,470,471,472,473,474,475,476,477,478,479,480,481,482,483,484,485,486,487,488,489,490,491,492,493,494,495,496,497,498,499,500,501,502,503,504,505,506,507,508,509,510,511,512,513,514,515,516,517,518,519,520,521,522,523,524],"counts",{"_451":61,"_452":288,"_453":61,"_454":455,"_456":457},"contents",[126,127,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,158,159,160,161,162,163,164],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":445,"_31":446,"_29":447,"_168":-5,"_39":40,"_38":448,"_170":57,"_36":449,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_26":450},{"_41":439,"_31":440,"_29":441,"_168":-5,"_39":40,"_38":442,"_170":57,"_36":443,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_26":444},{"_41":433,"_31":434,"_29":435,"_168":-5,"_39":40,"_38":436,"_170":57,"_36":437,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_26":438},{"_41":426,"_31":427,"_29":428,"_168":-5,"_39":40,"_38":429,"_170":57,"_36":430,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_26":432},{"_41":420,"_31":421,"_29":422,"_168":-5,"_39":40,"_38":288,"_170":57,"_36":423,"_13":61,"_33":20,"_34":424,"_23":24,"_174":-5,"_26":425},{"_41":414,"_31":415,"_29":416,"_168":-5,"_39":40,"_38":237,"_170":57,"_36":417,"_13":61,"_33":20,"_34":418,"_23":24,"_174":-5,"_26":419},{"_41":405,"_31":406,"_29":407,"_168":-5,"_39":40,"_38":408,"_170":24,"_36":409,"_13":410,"_33":172,"_34":411,"_23":24,"_174":412,"_26":413},{"_41":396,"_31":397,"_29":398,"_168":-5,"_39":40,"_38":399,"_170":24,"_36":400,"_13":401,"_33":172,"_34":402,"_23":24,"_174":403,"_26":404},{"_41":388,"_31":389,"_29":390,"_168":-5,"_39":40,"_38":391,"_170":57,"_36":392,"_13":61,"_33":172,"_34":393,"_23":24,"_174":394,"_26":395},{"_41":380,"_31":381,"_29":382,"_168":-5,"_39":40,"_38":383,"_170":57,"_36":384,"_13":61,"_33":172,"_34":385,"_23":24,"_174":386,"_26":387},{"_41":372,"_31":373,"_29":374,"_168":-5,"_39":40,"_38":375,"_170":57,"_36":376,"_13":61,"_33":172,"_34":377,"_23":24,"_174":378,"_26":379},{"_41":364,"_31":365,"_29":366,"_168":-5,"_39":40,"_38":367,"_170":57,"_36":368,"_13":61,"_33":172,"_34":369,"_23":24,"_174":370,"_26":371},{"_41":357,"_31":358,"_29":359,"_168":-5,"_39":40,"_38":360,"_170":57,"_36":361,"_13":61,"_33":172,"_34":362,"_23":24,"_174":-5,"_26":363},{"_41":349,"_31":350,"_29":351,"_168":-5,"_39":40,"_38":352,"_170":57,"_36":353,"_13":61,"_33":172,"_34":354,"_23":24,"_174":355,"_26":356},{"_41":342,"_31":343,"_29":344,"_168":-5,"_39":40,"_38":345,"_170":57,"_36":346,"_13":237,"_33":172,"_34":347,"_23":24,"_174":-5,"_26":348},{"_41":335,"_31":336,"_29":337,"_168":-5,"_39":40,"_38":338,"_170":57,"_36":339,"_13":288,"_33":172,"_34":340,"_23":24,"_174":-5,"_26":341},{"_41":328,"_31":329,"_29":330,"_168":-5,"_39":40,"_38":331,"_170":57,"_36":332,"_13":296,"_33":238,"_34":333,"_23":24,"_174":-5,"_26":334},{"_41":320,"_31":321,"_29":322,"_168":-5,"_39":40,"_38":323,"_170":57,"_36":324,"_13":325,"_33":172,"_34":326,"_23":24,"_174":-5,"_26":327},{"_41":314,"_31":315,"_29":55,"_168":-5,"_39":40,"_38":316,"_170":57,"_36":317,"_13":288,"_33":172,"_34":318,"_23":24,"_174":-5,"_26":319},{"_41":307,"_31":308,"_29":309,"_168":-5,"_39":40,"_38":310,"_170":57,"_36":311,"_13":61,"_33":172,"_34":312,"_23":24,"_174":-5,"_26":313},{"_41":300,"_31":301,"_29":302,"_168":-5,"_39":40,"_38":303,"_170":57,"_36":304,"_13":61,"_33":172,"_34":305,"_23":24,"_174":-5,"_26":306},{"_41":291,"_31":292,"_29":293,"_168":-5,"_39":40,"_38":294,"_170":57,"_36":295,"_13":296,"_33":172,"_34":297,"_23":24,"_174":298,"_26":299},{"_41":283,"_31":284,"_29":285,"_168":-5,"_39":40,"_38":286,"_170":57,"_36":287,"_13":288,"_33":172,"_34":289,"_23":24,"_174":-5,"_26":290},{"_41":276,"_31":277,"_29":278,"_168":-5,"_39":40,"_38":279,"_170":57,"_36":280,"_13":61,"_33":20,"_34":281,"_23":24,"_174":-5,"_26":282},{"_41":269,"_31":270,"_29":271,"_168":-5,"_39":40,"_38":272,"_170":57,"_36":273,"_13":61,"_33":172,"_34":274,"_23":24,"_174":-5,"_26":275},{"_41":262,"_31":263,"_29":264,"_168":-5,"_39":40,"_38":265,"_170":57,"_36":266,"_13":61,"_33":172,"_34":267,"_23":24,"_174":-5,"_26":268},{"_41":255,"_31":256,"_29":257,"_168":-5,"_39":40,"_38":258,"_170":57,"_36":259,"_13":61,"_33":172,"_34":260,"_23":24,"_174":-5,"_26":261},{"_41":248,"_31":249,"_29":250,"_168":-5,"_39":40,"_38":251,"_170":57,"_36":252,"_13":61,"_33":172,"_34":253,"_23":24,"_174":-5,"_26":254},{"_41":241,"_31":242,"_29":243,"_168":-5,"_39":40,"_38":244,"_170":57,"_36":245,"_13":61,"_33":172,"_34":246,"_23":24,"_174":-5,"_26":247},{"_41":232,"_31":233,"_29":234,"_168":-5,"_39":40,"_38":235,"_170":57,"_36":236,"_13":237,"_33":238,"_34":239,"_23":24,"_174":-5,"_26":240},{"_41":225,"_31":226,"_29":227,"_168":-5,"_39":40,"_38":228,"_170":57,"_36":229,"_13":61,"_33":172,"_34":230,"_23":24,"_174":-5,"_26":231},{"_41":218,"_31":219,"_29":220,"_168":-5,"_39":40,"_38":221,"_170":57,"_36":222,"_13":61,"_33":172,"_34":223,"_23":24,"_174":-5,"_26":224},{"_41":211,"_31":212,"_29":213,"_168":-5,"_39":40,"_38":214,"_170":57,"_36":215,"_13":61,"_33":172,"_34":216,"_23":24,"_174":-5,"_26":217},{"_41":204,"_31":205,"_29":206,"_168":-5,"_39":40,"_38":207,"_170":57,"_36":208,"_13":61,"_33":172,"_34":209,"_23":24,"_174":-5,"_26":210},{"_41":197,"_31":198,"_29":199,"_168":-5,"_39":40,"_38":200,"_170":57,"_36":201,"_13":61,"_33":172,"_34":202,"_23":24,"_174":-5,"_26":203},{"_41":190,"_31":191,"_29":192,"_168":-5,"_39":40,"_38":193,"_170":57,"_36":194,"_13":61,"_33":172,"_34":195,"_23":24,"_174":-5,"_26":196},{"_41":183,"_31":184,"_29":185,"_168":-5,"_39":40,"_38":186,"_170":57,"_36":187,"_13":61,"_33":172,"_34":188,"_23":24,"_174":-5,"_26":189},{"_41":176,"_31":177,"_29":178,"_168":-5,"_39":40,"_38":179,"_170":57,"_36":180,"_13":61,"_33":172,"_34":181,"_23":24,"_174":-5,"_26":182},{"_41":165,"_31":166,"_29":167,"_168":-5,"_39":40,"_38":169,"_170":57,"_36":171,"_13":61,"_33":172,"_34":173,"_23":24,"_174":-5,"_26":175},"9af2b9d5-12ca-4799-b587-a40518499954","ytjs620-proxy.ts","574b9a2a-9ca4-11f1-9e24-1607ee4eb77e","parentId",94,"latest",["D",1787236507820],"http","import { Innertube } from 'npm:youtubei.js@17.0.1';\n\nlet ytPromise: Promise | null = null;\nfunction yt(){ return ytPromise ??= Innertube.create({ generate_session_locally: true }); }\nfunction videoId(raw:string){ try{ const u=new URL(raw); if(u.hostname==='youtu.be') return u.pathname.split('/').filter(Boolean)[0]||''; if(u.hostname.endsWith('youtube.com')) return u.searchParams.get('v')||u.pathname.match(/\\/(?:shorts|live|embed)\\/([\\w-]{6,})/)?.[1]||''; }catch{} return /^[\\w-]{6,}$/.test(raw)?raw:''; }\nasync function getFormat(id:string){ const api=await yt(); const fmt=await api.getStreamingData(id,{itag:18,client:'ANDROID_VR'}); if(!fmt?.url) throw new Error('no streaming url'); return fmt; }\nasync function probe(id:string){ const s=Date.now(); const fmt=await getFormat(id); const resolveMs=Date.now()-s; const p0=Date.now(); const r=await fetch(fmt.url,{headers:{Range:'bytes=0-4095','User-Agent':'com.google.android.apps.youtube.vr.oculus/1.65.10 (Linux; U; Android 12L) gzip'},signal:AbortSignal.timeout(5000)}); const b=new Uint8Array(await r.arrayBuffer()); return {ok:(r.status===200||r.status===206)&&b.length>0,resolveMs,probeMs:Date.now()-p0,totalMs:Date.now()-s,status:r.status,bytes:b.length,type:r.headers.get('content-type'),prefix:Array.from(b.slice(0,16))}; }\nexport default async function(req:Request){ const u=new URL(req.url); if(u.pathname==='/health') return Response.json({ok:true,service:'ytjs620'}); const id=videoId(u.searchParams.get('url')||u.searchParams.get('id')||''); if(!id) return Response.json({ok:false,error:'invalid youtube url'},{status:400}); try{ if(u.pathname==='/probe') return Response.json(await probe(id)); if(u.pathname==='/stream'){ const fmt=await getFormat(id); const headers=new Headers({'User-Agent':'com.google.android.apps.youtube.vr.oculus/1.65.10 (Linux; U; Android 12L) gzip'}); const range=req.headers.get('range'); if(range) headers.set('Range',range); const up=await fetch(fmt.url,{headers,signal:req.signal}); const out=new Headers(); for(const h of ['content-type','content-length','content-range','accept-ranges','etag','last-modified']){ const v=up.headers.get(h); if(v) out.set(h,v); } out.set('cache-control','no-store'); return new Response(req.method==='HEAD'?null:up.body,{status:up.status,headers:out}); } const fmt=await getFormat(id); return Response.json({ok:true,id,itag:fmt.itag,mime:fmt.mime_type||fmt.mimeType||null,url:'/stream?id='+encodeURIComponent(id)}); }catch(e){ return Response.json({ok:false,error:String(e)},{status:502}); } }\n","label",[166],"b5b3c2a3-4fe7-4be0-8101-f4ff5c73f166","ytjs620-download-probe.ts","67ca8fbe-9ca4-11f1-8975-1607ee4eb77e",95,["D",1787236535494],"import { Innertube } from 'npm:youtubei.js@17.0.1';\nlet p:Promise|null=null; const yt=()=>p??=Innertube.create({generate_session_locally:true});\nexport default async function(){const s=Date.now();try{const api=await yt();const t=Date.now();const stream=await api.download('dQw4w9WgXcQ',{itag:18,client:'ANDROID_VR',range:{start:0,end:4095}});const reader=stream.getReader();let total=0;const prefix:number[]=[];for(;;){const {done,value}=await reader.read();if(done)break;if(value){total+=value.length;for(const b of value.slice(0,Math.max(0,16-prefix.length)))prefix.push(b);if(total>=4096){try{await reader.cancel()}catch{}break;}}}return Response.json({ok:total>0,initMs:t-s,downloadMs:Date.now()-t,totalMs:Date.now()-s,bytes:total,prefix});}catch(e){return Response.json({ok:false,totalMs:Date.now()-s,error:String(e),stack:String((e as any)?.stack||'').slice(0,2000)});}}\n",[177],"4bfb6851-e5ff-4920-bcb8-00822bab5a2e","ytjs620-client-matrix.ts","7aee4a5e-9ca4-11f1-b39f-1607ee4eb77e",96,["D",1787236567609],"import { Innertube } from 'npm:youtubei.js@17.0.1';\nconst clients=['WEB_EMBEDDED','WEB_EMBEDDED_PLAYER','TV','TV_EMBEDDED','WEB_SAFARI','MWEB','ANDROID_VR','IOS'];\nexport default async function(){const api=await Innertube.create({generate_session_locally:true});const out=[];for(const client of clients){const s=Date.now();try{const fmt=await api.getStreamingData('dQw4w9WgXcQ',{itag:18,client:client as any});const rr=await fetch(fmt.url,{headers:{Range:'bytes=0-1023'},signal:AbortSignal.timeout(3500)});const b=new Uint8Array(await rr.arrayBuffer());out.push({client,ok:(rr.status===200||rr.status===206)&&b.length>0,status:rr.status,bytes:b.length,ms:Date.now()-s,c:new URL(fmt.url).searchParams.get('c')});}catch(e){out.push({client,ok:false,ms:Date.now()-s,error:String(e).slice(0,260)});}}return Response.json(out);}\n",[184],"3c67bbd9-fb0d-427a-9642-dada0a38c00c","verify590.ts","083a0512-9c1c-11f1-aca5-1607ee4eb77e",37,["D",1787177963614],"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}",[191],"af731585-bc59-4575-8720-83f6650af679","validate620-selfprobe.ts","9c3418f6-9ca4-11f1-b491-1607ee4eb77e",97,["D",1787236623432],"const U='https://universal-dubber-ytdlp-relay-v2-va.onrender.com/selfprobe?url='+encodeURIComponent('https://www.youtube.com/watch?v=dQw4w9WgXcQ');export default async function(){const s=Date.now();try{const r=await fetch(U,{signal:AbortSignal.timeout(12000)});return Response.json({status:r.status,ms:Date.now()-s,body:(await r.text()).slice(0,3000)});}catch(e){return Response.json({status:0,ms:Date.now()-s,error:String(e)});}}",[198],"e81bef0b-ffb7-42bf-9497-e6228b5dae39","validate620-relays.ts","76eeae18-9ca3-11f1-bc1b-1607ee4eb77e",91,["D",1787236131405],"const TEST='https://www.youtube.com/watch?v=dQw4w9WgXcQ';\nconst targets=[\n ['relay-v2-va','https://universal-dubber-ytdlp-relay-v2-va.onrender.com/resolve?url='],\n ['relay-fra','https://universal-dubber-ytdlp-relay-fra.onrender.com/resolve?url='],\n ['resolver-va','https://universal-dubber-ytdlp-virginia.onrender.com/resolve?url='],\n ['resolver-fra','https://universal-dubber-ytdlp-frankfurt.onrender.com/resolve?url='],\n ['resolver-v3','https://universal-dubber-ytdlp-resolver-v3.onrender.com/resolve?url=']\n];\nasync function one([name,base]:string[]){const s=Date.now();try{const r=await fetch(base+encodeURIComponent(TEST),{signal:AbortSignal.timeout(12000)});const text=await r.text();return {name,status:r.status,ms:Date.now()-s,text:text.slice(0,2200)}}catch(e){return {name,status:0,ms:Date.now()-s,error:String(e)}}}\nexport default async function(){return Response.json(await Promise.all(targets.map(one)));}\n",[205],"b9a74589-23a8-4d6c-9caa-1f00fbfaf579","validate620-pot-e2e.ts","ad1b80a0-9ca4-11f1-9752-1607ee4eb77e",98,["D",1787236651790],"const B='https://universal-dubber-ytdlp-resolver-v3.onrender.com/resolve?url='+encodeURIComponent('https://www.youtube.com/watch?v=dQw4w9WgXcQ');export default async function(){const s=Date.now();try{const r=await fetch(B,{signal:AbortSignal.timeout(45000)});const j=await r.json();const resolveMs=Date.now()-s;const u=j?.candidates?.[0]?.url;if(!r.ok||!j?.ok||!u)return Response.json({ok:false,stage:'resolve',resolveMs,status:r.status,j});const p0=Date.now();const p=await fetch(u,{headers:{Range:'bytes=0-4095'},signal:AbortSignal.timeout(8000)});const b=new Uint8Array(await p.arrayBuffer());return Response.json({ok:(p.status===200||p.status===206)&&b.length>0,resolveMs,probeMs:Date.now()-p0,totalMs:Date.now()-s,probeStatus:p.status,bytes:b.length,type:p.headers.get('content-type'),urlHasPot:new URL(u).searchParams.has('pot'),client:new URL(u).searchParams.get('c'),prefix:Array.from(b.slice(0,16)),stderr:String(j?.stderr||'').slice(-1800)});}catch(e){return Response.json({ok:false,totalMs:Date.now()-s,error:String(e)});}}",[212],"007b2c3b-b3ed-491a-b55f-a6eeaa18e47d","validate620-e2e.ts","97c7d5ce-9ca3-11f1-9f30-1607ee4eb77e",92,["D",1787236186493],"const BASE='https://universal-dubber-ytdlp-relay-v2-va.onrender.com';\nconst TEST='https://www.youtube.com/watch?v=dQw4w9WgXcQ';\nexport default async function(){\n const start=Date.now();\n try{\n const r=await fetch(BASE+'/resolve?url='+encodeURIComponent(TEST),{signal:AbortSignal.timeout(9500)});\n const j=await r.json();\n const resolvedMs=Date.now()-start;\n const u=j?.formats?.[0]?.url;\n if(!r.ok||!j?.ok||!u) return Response.json({ok:false,stage:'resolve',status:r.status,resolvedMs,j});\n const p0=Date.now();\n const p=await fetch(u,{headers:{Range:'bytes=0-4095'},signal:AbortSignal.timeout(5000)});\n const b=new Uint8Array(await p.arrayBuffer());\n return Response.json({ok:p.ok&&b.length>0,resolveMs:resolvedMs,firstByteProbeMs:Date.now()-p0,totalMs:Date.now()-start,probeStatus:p.status,bytes:b.length,contentType:p.headers.get('content-type'),prefix:Array.from(b.slice(0,16)),mediaUrl:u});\n }catch(e){return Response.json({ok:false,totalMs:Date.now()-start,error:String(e)});}\n}\n",[219],"9c36476c-f189-4bab-8487-72715a2681b7","validate620-direct-e2e.ts","20b92e5a-9ca4-11f1-864a-1607ee4eb77e",93,["D",1787236416264],"const BASE='https://universal-dubber-ytdlp-virginia.onrender.com';\nconst TEST='https://www.youtube.com/watch?v=dQw4w9WgXcQ';\nexport default async function(){\n const start=Date.now();\n try{\n const r=await fetch(BASE+'/resolve?url='+encodeURIComponent(TEST),{signal:AbortSignal.timeout(9500)});\n const j=await r.json(); const resolveMs=Date.now()-start;\n const u=j?.formats?.[0]?.url; if(!r.ok||!j?.ok||!u) return Response.json({ok:false,stage:'resolve',status:r.status,resolveMs,j});\n const p0=Date.now(); const p=await fetch(u,{headers:{Range:'bytes=0-4095','User-Agent':'Mozilla/5.0 (Linux; Android 16) AppleWebKit/537.36 Chrome/140 Mobile Safari/537.36'},signal:AbortSignal.timeout(5000)}); const b=new Uint8Array(await p.arrayBuffer());\n return Response.json({ok:(p.status===200||p.status===206)&&b.length>0,resolveMs,probeMs:Date.now()-p0,totalMs:Date.now()-start,probeStatus:p.status,bytes:b.length,contentType:p.headers.get('content-type'),prefix:Array.from(b.slice(0,16))});\n }catch(e){return Response.json({ok:false,totalMs:Date.now()-start,error:String(e)});}\n}\n",[226],"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",[233],"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",[242],"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",[249],"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",[256],"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",[263],"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",[270],"032c2a72-75a6-4ff6-8e81-5de87bb0c9aa","test-static.txt","85cb1f54-9c1a-11f1-858d-1607ee4eb77e",27,["D",1787177315275],"HELLO_STATIC_590",[277],"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}",[284],"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",[292],"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",[301],"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",[308],"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",[315],"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",[321],"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",[329],"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",[336],"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",[343],"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",[350],"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",[358],"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",[365],"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",[373],"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",[381],"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",[389],"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",[397],"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",[406],"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",[415],"c74b85d7-c14e-4db5-bd90-11b223f073c0","README.txt","ebf35b50-9bea-11f1-b085-1607ee4eb77e",["D",1787156870833],"Universal Dubber 5.7.1 build overlays",[421],"f7a7e378-bb84-424d-b315-969b523489f4","v620","6443cc8c-9ca6-11f1-b642-1607ee4eb77e",99,["D",1787237388571],"directory",[427],"e38043a9-2e6e-49db-8fb2-c8cbaa1261bc","v610","4048ad5c-9c9c-11f1-9647-1607ee4eb77e",71,["D",1787233033243],[434],"ad84f807-616f-43e9-b7f0-b16dbfd60131","v600","071b0540-9c22-11f1-a07a-1607ee4eb77e",43,["D",1787180538676],[440],"149ff5b5-ebac-40b5-a905-d281d05d5128","v590","edf0f1dc-c67f-4898-a943-eee1324a510d",30,["D",1787177391642],[446],"pulls","branches","forks","envVars",{"_458":61,"_460":61},"connections",{"_458":61,"_459":61},"count","unfilledCount","emptyCount",{"_41":445,"_31":446,"_29":447,"_168":-5,"_39":40,"_38":448,"_170":57,"_36":811,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_526":812,"_26":813},{"_41":805,"_31":656,"_29":806,"_168":447,"_39":40,"_38":807,"_170":57,"_36":808,"_13":61,"_33":20,"_34":659,"_23":24,"_174":-5,"_526":809,"_26":810},{"_41":798,"_31":647,"_29":799,"_168":447,"_39":40,"_38":800,"_170":57,"_36":801,"_13":61,"_33":20,"_34":802,"_23":24,"_174":-5,"_526":803,"_26":804},{"_41":791,"_31":639,"_29":792,"_168":447,"_39":40,"_38":793,"_170":57,"_36":794,"_13":61,"_33":20,"_34":795,"_23":24,"_174":-5,"_526":796,"_26":797},{"_41":784,"_31":716,"_29":785,"_168":447,"_39":40,"_38":786,"_170":57,"_36":787,"_13":61,"_33":20,"_34":788,"_23":24,"_174":-5,"_526":789,"_26":790},{"_41":778,"_31":415,"_29":779,"_168":447,"_39":40,"_38":448,"_170":57,"_36":780,"_13":61,"_33":20,"_34":781,"_23":24,"_174":-5,"_526":782,"_26":783},{"_41":439,"_31":440,"_29":441,"_168":-5,"_39":40,"_38":442,"_170":57,"_36":775,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_526":776,"_26":777},{"_41":769,"_31":656,"_29":770,"_168":441,"_39":40,"_38":771,"_170":57,"_36":772,"_13":61,"_33":20,"_34":659,"_23":24,"_174":-5,"_526":773,"_26":774},{"_41":763,"_31":647,"_29":764,"_168":441,"_39":40,"_38":765,"_170":57,"_36":766,"_13":651,"_33":20,"_34":732,"_23":24,"_174":-5,"_526":767,"_26":768},{"_41":757,"_31":639,"_29":758,"_168":441,"_39":40,"_38":759,"_170":57,"_36":760,"_13":288,"_33":20,"_34":643,"_23":24,"_174":-5,"_526":761,"_26":762},{"_41":750,"_31":716,"_29":751,"_168":441,"_39":40,"_38":752,"_170":57,"_36":753,"_13":288,"_33":20,"_34":754,"_23":24,"_174":-5,"_526":755,"_26":756},{"_41":743,"_31":415,"_29":744,"_168":441,"_39":40,"_38":745,"_170":57,"_36":746,"_13":410,"_33":20,"_34":747,"_23":24,"_174":-5,"_526":748,"_26":749},{"_41":433,"_31":434,"_29":435,"_168":-5,"_39":40,"_38":436,"_170":57,"_36":740,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_526":741,"_26":742},{"_41":735,"_31":656,"_29":736,"_168":435,"_39":40,"_38":725,"_170":57,"_36":737,"_13":61,"_33":20,"_34":659,"_23":24,"_174":-5,"_526":738,"_26":739},{"_41":729,"_31":647,"_29":730,"_168":435,"_39":40,"_38":725,"_170":57,"_36":731,"_13":61,"_33":20,"_34":732,"_23":24,"_174":-5,"_526":733,"_26":734},{"_41":723,"_31":639,"_29":724,"_168":435,"_39":40,"_38":725,"_170":57,"_36":726,"_13":61,"_33":20,"_34":643,"_23":24,"_174":-5,"_526":727,"_26":728},{"_41":715,"_31":716,"_29":717,"_168":435,"_39":40,"_38":718,"_170":57,"_36":719,"_13":325,"_33":20,"_34":720,"_23":24,"_174":-5,"_526":721,"_26":722},{"_41":708,"_31":415,"_29":709,"_168":435,"_39":40,"_38":710,"_170":57,"_36":711,"_13":237,"_33":20,"_34":712,"_23":24,"_174":-5,"_526":713,"_26":714},{"_41":426,"_31":427,"_29":428,"_168":-5,"_39":40,"_38":429,"_170":57,"_36":705,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_526":706,"_26":707},{"_41":700,"_31":667,"_29":663,"_168":428,"_39":40,"_38":701,"_170":57,"_36":702,"_13":61,"_33":431,"_34":-5,"_23":24,"_174":-5,"_526":703,"_26":704},{"_41":692,"_31":693,"_29":694,"_168":663,"_39":40,"_38":695,"_170":57,"_36":696,"_13":61,"_33":20,"_34":697,"_23":24,"_174":-5,"_526":698,"_26":699},{"_41":684,"_31":685,"_29":686,"_168":663,"_39":40,"_38":687,"_170":57,"_36":688,"_13":61,"_33":20,"_34":689,"_23":24,"_174":-5,"_526":690,"_26":691},{"_41":676,"_31":677,"_29":678,"_168":663,"_39":40,"_38":679,"_170":57,"_36":680,"_13":61,"_33":20,"_34":681,"_23":24,"_174":-5,"_526":682,"_26":683},{"_41":668,"_31":669,"_29":670,"_168":663,"_39":40,"_38":671,"_170":57,"_36":672,"_13":61,"_33":20,"_34":673,"_23":24,"_174":-5,"_526":674,"_26":675},{"_41":662,"_31":32,"_29":30,"_168":663,"_39":40,"_38":14,"_170":57,"_36":664,"_13":61,"_33":20,"_34":35,"_23":24,"_174":-5,"_526":665,"_26":666},{"_41":655,"_31":656,"_29":657,"_168":428,"_39":40,"_38":641,"_170":57,"_36":658,"_13":61,"_33":20,"_34":659,"_23":24,"_174":-5,"_526":660,"_26":661},{"_41":646,"_31":647,"_29":648,"_168":428,"_39":40,"_38":649,"_170":24,"_36":650,"_13":651,"_33":20,"_34":652,"_23":24,"_174":-5,"_526":653,"_26":654},{"_41":638,"_31":639,"_29":640,"_168":428,"_39":40,"_38":641,"_170":24,"_36":642,"_13":61,"_33":20,"_34":643,"_23":24,"_174":-5,"_526":644,"_26":645},{"_41":631,"_31":415,"_29":632,"_168":428,"_39":40,"_38":633,"_170":24,"_36":634,"_13":288,"_33":20,"_34":635,"_23":24,"_174":-5,"_526":636,"_26":637},{"_41":420,"_31":421,"_29":422,"_168":-5,"_39":40,"_38":288,"_170":57,"_36":628,"_13":61,"_33":20,"_34":424,"_23":24,"_174":-5,"_526":629,"_26":630},{"_41":414,"_31":415,"_29":416,"_168":-5,"_39":40,"_38":237,"_170":57,"_36":625,"_13":61,"_33":20,"_34":418,"_23":24,"_174":-5,"_526":626,"_26":627},{"_41":405,"_31":406,"_29":407,"_168":-5,"_39":40,"_38":408,"_170":24,"_36":622,"_13":410,"_33":172,"_34":411,"_23":24,"_174":412,"_526":623,"_26":624},{"_41":396,"_31":397,"_29":398,"_168":-5,"_39":40,"_38":399,"_170":24,"_36":619,"_13":401,"_33":172,"_34":402,"_23":24,"_174":403,"_526":620,"_26":621},{"_41":388,"_31":389,"_29":390,"_168":-5,"_39":40,"_38":391,"_170":57,"_36":616,"_13":61,"_33":172,"_34":393,"_23":24,"_174":394,"_526":617,"_26":618},{"_41":380,"_31":381,"_29":382,"_168":-5,"_39":40,"_38":383,"_170":57,"_36":613,"_13":61,"_33":172,"_34":385,"_23":24,"_174":386,"_526":614,"_26":615},{"_41":372,"_31":373,"_29":374,"_168":-5,"_39":40,"_38":375,"_170":57,"_36":610,"_13":61,"_33":172,"_34":377,"_23":24,"_174":378,"_526":611,"_26":612},{"_41":364,"_31":365,"_29":366,"_168":-5,"_39":40,"_38":367,"_170":57,"_36":607,"_13":61,"_33":172,"_34":369,"_23":24,"_174":370,"_526":608,"_26":609},{"_41":357,"_31":358,"_29":359,"_168":-5,"_39":40,"_38":360,"_170":57,"_36":604,"_13":61,"_33":172,"_34":362,"_23":24,"_174":-5,"_526":605,"_26":606},{"_41":349,"_31":350,"_29":351,"_168":-5,"_39":40,"_38":352,"_170":57,"_36":601,"_13":61,"_33":172,"_34":354,"_23":24,"_174":355,"_526":602,"_26":603},{"_41":342,"_31":343,"_29":344,"_168":-5,"_39":40,"_38":345,"_170":57,"_36":598,"_13":237,"_33":172,"_34":347,"_23":24,"_174":-5,"_526":599,"_26":600},{"_41":335,"_31":336,"_29":337,"_168":-5,"_39":40,"_38":338,"_170":57,"_36":595,"_13":288,"_33":172,"_34":340,"_23":24,"_174":-5,"_526":596,"_26":597},{"_41":328,"_31":329,"_29":330,"_168":-5,"_39":40,"_38":331,"_170":57,"_36":592,"_13":296,"_33":238,"_34":333,"_23":24,"_174":-5,"_526":593,"_26":594},{"_41":320,"_31":321,"_29":322,"_168":-5,"_39":40,"_38":323,"_170":57,"_36":589,"_13":325,"_33":172,"_34":326,"_23":24,"_174":-5,"_526":590,"_26":591},{"_41":314,"_31":315,"_29":55,"_168":-5,"_39":40,"_38":316,"_170":57,"_36":586,"_13":288,"_33":172,"_34":318,"_23":24,"_174":-5,"_526":587,"_26":588},{"_41":307,"_31":308,"_29":309,"_168":-5,"_39":40,"_38":310,"_170":57,"_36":583,"_13":61,"_33":172,"_34":312,"_23":24,"_174":-5,"_526":584,"_26":585},{"_41":300,"_31":301,"_29":302,"_168":-5,"_39":40,"_38":303,"_170":57,"_36":580,"_13":61,"_33":172,"_34":305,"_23":24,"_174":-5,"_526":581,"_26":582},{"_41":291,"_31":292,"_29":293,"_168":-5,"_39":40,"_38":294,"_170":57,"_36":577,"_13":296,"_33":172,"_34":297,"_23":24,"_174":298,"_526":578,"_26":579},{"_41":283,"_31":284,"_29":285,"_168":-5,"_39":40,"_38":286,"_170":57,"_36":574,"_13":288,"_33":172,"_34":289,"_23":24,"_174":-5,"_526":575,"_26":576},{"_41":276,"_31":277,"_29":278,"_168":-5,"_39":40,"_38":279,"_170":57,"_36":571,"_13":61,"_33":20,"_34":281,"_23":24,"_174":-5,"_526":572,"_26":573},{"_41":269,"_31":270,"_29":271,"_168":-5,"_39":40,"_38":272,"_170":57,"_36":568,"_13":61,"_33":172,"_34":274,"_23":24,"_174":-5,"_526":569,"_26":570},{"_41":262,"_31":263,"_29":264,"_168":-5,"_39":40,"_38":265,"_170":57,"_36":565,"_13":61,"_33":172,"_34":267,"_23":24,"_174":-5,"_526":566,"_26":567},{"_41":255,"_31":256,"_29":257,"_168":-5,"_39":40,"_38":258,"_170":57,"_36":562,"_13":61,"_33":172,"_34":260,"_23":24,"_174":-5,"_526":563,"_26":564},{"_41":248,"_31":249,"_29":250,"_168":-5,"_39":40,"_38":251,"_170":57,"_36":559,"_13":61,"_33":172,"_34":253,"_23":24,"_174":-5,"_526":560,"_26":561},{"_41":241,"_31":242,"_29":243,"_168":-5,"_39":40,"_38":244,"_170":57,"_36":556,"_13":61,"_33":172,"_34":246,"_23":24,"_174":-5,"_526":557,"_26":558},{"_41":232,"_31":233,"_29":234,"_168":-5,"_39":40,"_38":235,"_170":57,"_36":553,"_13":237,"_33":238,"_34":239,"_23":24,"_174":-5,"_526":554,"_26":555},{"_41":225,"_31":226,"_29":227,"_168":-5,"_39":40,"_38":228,"_170":57,"_36":550,"_13":61,"_33":172,"_34":230,"_23":24,"_174":-5,"_526":551,"_26":552},{"_41":218,"_31":219,"_29":220,"_168":-5,"_39":40,"_38":221,"_170":57,"_36":547,"_13":61,"_33":172,"_34":223,"_23":24,"_174":-5,"_526":548,"_26":549},{"_41":211,"_31":212,"_29":213,"_168":-5,"_39":40,"_38":214,"_170":57,"_36":544,"_13":61,"_33":172,"_34":216,"_23":24,"_174":-5,"_526":545,"_26":546},{"_41":204,"_31":205,"_29":206,"_168":-5,"_39":40,"_38":207,"_170":57,"_36":541,"_13":61,"_33":172,"_34":209,"_23":24,"_174":-5,"_526":542,"_26":543},{"_41":197,"_31":198,"_29":199,"_168":-5,"_39":40,"_38":200,"_170":57,"_36":538,"_13":61,"_33":172,"_34":202,"_23":24,"_174":-5,"_526":539,"_26":540},{"_41":190,"_31":191,"_29":192,"_168":-5,"_39":40,"_38":193,"_170":57,"_36":535,"_13":61,"_33":172,"_34":195,"_23":24,"_174":-5,"_526":536,"_26":537},{"_41":183,"_31":184,"_29":185,"_168":-5,"_39":40,"_38":186,"_170":57,"_36":532,"_13":61,"_33":172,"_34":188,"_23":24,"_174":-5,"_526":533,"_26":534},{"_41":176,"_31":177,"_29":178,"_168":-5,"_39":40,"_38":179,"_170":57,"_36":529,"_13":61,"_33":172,"_34":181,"_23":24,"_174":-5,"_526":530,"_26":531},{"_41":165,"_31":166,"_29":167,"_168":-5,"_39":40,"_38":169,"_170":57,"_36":525,"_13":61,"_33":172,"_34":173,"_23":24,"_174":-5,"_526":527,"_26":528},["D",1787236507820],"children",[],[166],["D",1787236535494],[],[177],["D",1787236567609],[],[184],["D",1787177963614],[],[191],["D",1787236623432],[],[198],["D",1787236131405],[],[205],["D",1787236651790],[],[212],["D",1787236186493],[],[219],["D",1787236416264],[],[226],["D",1787232822238],[],[233],["D",1787233166204],[],[242],["D",1787232832373],[],[249],["D",1787233148974],[],[256],["D",1787233196350],[],[263],["D",1787233240984],[],[270],["D",1787177315275],[],[277],["D",1787177378140],[],[284],["D",1787234697788],[],[292],["D",1787180719815],[],[301],["D",1787177537021],[],[308],["D",1787159229206],[],[315],["D",1787182564011],[],[321],["D",1787159287034],[],[329],["D",1787171573718],[],[336],["D",1787171464834],[],[343],["D",1787181132689],[],[350],["D",1787178016166],[],[358],["D",1787178565514],[],[365],["D",1787178557075],[],[373],["D",1787178547952],[],[381],["D",1787178537728],[],[389],["D",1787234748611],[],[397],["D",1787159105213],[],[406],["D",1787156892990],[],[415],["D",1787156870833],[],[421],"c474c8e1-a01e-44c0-91bf-0c4389ccf706","01a01fa6-7138-77eb-a2e5-b40dc7a53e97",106,["D",1787240168549],"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 = 33\n versionName = \"6.2.0\"\n testInstrumentationRunner = \"androidx.test.runner.AndroidJUnitRunner\"\n ndk { abiFilters += listOf(\"arm64-v8a\") }\n }\n\n buildFeatures { buildConfig = true }\n packaging { jniLibs.useLegacyPackaging = true }\n\n buildTypes {\n release {\n isMinifyEnabled = false\n proguardFiles(getDefaultProguardFile(\"proguard-android-optimize.txt\"), \"proguard-rules.pro\")\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(\"androidx.webkit:webkit:1.12.1\")\n implementation(\"com.google.android.material:material:1.12.0\")\n implementation(\"com.squareup.okhttp3:okhttp:4.12.0\")\n implementation(\"org.jetbrains.kotlinx:kotlinx-coroutines-android:1.9.0\")\n implementation(\"org.jetbrains.kotlinx:kotlinx-serialization-json:1.7.3\")\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-ui:1.8.1\")\n\n // Current NewPipe fork with the modern PoToken/BotGuard API and YouTube fixes.\n implementation(\"com.github.raveuk:NewPipeExtractor:a79e606285\")\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",[],[427,415],"c2ba0e11-d417-42cb-8809-b76f0b5b03fd","UniversalPlaybackService.kt.txt","01a01fa6-7138-77eb-a2e5-b095f2c02951",100,["D",1787237396804],"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",[],[427,639],"6e37da40-6127-4521-b308-588a36b5a6eb","MainActivity.kt.txt","01a01fa6-7138-77eb-a2e5-ad279ad11a6a",105,["D",1787237458418],5,"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 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 PO\"\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 controls.addView(TextView(this).apply {\n text = \"پخش YouTube بدون Cookie و بدون Player رسمی انجام می‌شود: BotGuard/PoToken در WebView مخفی فقط برای دریافت Proof-of-Origin اجرا می‌شود؛ لینک stream سپس توسط NewPipe استخراج، Range-probe و مستقیماً در Media3 محلی پخش می‌شود.\"\n setTextColor(Color.rgb(179, 187, 205))\n textSize = 12.5f\n setPadding(0, dp(4), 0, dp(5))\n })\n\n loadButton = button(\"بارگذاری و پخش محلی YouTube\") { loadYoutubeVideo() }\n controls.addView(loadButton, 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",[],[427,647],"19fb6fff-293f-4e87-a6ed-2d7bce457303","AndroidManifest.xml.txt","01a01fa6-7138-77eb-a2e5-b874bb91b484",["D",1787237396804],"\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",[],[427,656],"5a7d99b3-7681-49eb-97b1-c35cf5abf8ab","e70fa3ec-9cac-11f1-ab32-1607ee4eb77e",["D",1787240274933],[],[427,667,32],"potoken","927fd8c9-9620-47d3-8a78-fc816cab1a5b","PoTokenProviderImpl.kt.txt","0af5a5c2-9cad-11f1-a9f9-1607ee4eb77e",111,["D",1787240245221],"package com.openai.universaldubber.potoken\n\nimport android.content.Context\nimport android.util.Log\nimport kotlinx.coroutines.Dispatchers\nimport kotlinx.coroutines.launch\nimport kotlinx.coroutines.runBlocking\nimport org.schabi.newpipe.extractor.NewPipe\nimport org.schabi.newpipe.extractor.services.youtube.InnertubeClientRequestInfo\nimport org.schabi.newpipe.extractor.services.youtube.PoTokenProvider\nimport org.schabi.newpipe.extractor.services.youtube.PoTokenResult\nimport org.schabi.newpipe.extractor.services.youtube.YoutubeParsingHelper\n\nclass PoTokenProviderImpl(private val context: Context) : PoTokenProvider {\n companion object { private const val TAG = \"PoTokenProvider\" }\n\n private val lock = Any()\n @Volatile private var webViewBadImpl = false\n private var webPoTokenGenerator: PoTokenGenerator? = null\n private var webPoTokenVisitorData: String? = null\n private var webPoTokenStreamingPot: String? = null\n\n override fun getWebClientPoToken(videoId: String): PoTokenResult? = getPoToken(videoId)\n override fun getAndroidClientPoToken(videoId: String): PoTokenResult? = getPoToken(videoId)\n override fun getIosClientPoToken(videoId: String): PoTokenResult? = getPoToken(videoId)\n override fun getWebEmbedClientPoToken(videoId: String): PoTokenResult? = null\n\n private fun getPoToken(videoId: String): PoTokenResult? {\n if (webViewBadImpl) return null\n return try {\n getWebClientPoTokenBlocking(videoId, forceRecreate = false)\n } catch (e: BadWebViewException) {\n Log.e(TAG, \"System WebView cannot run BotGuard\", e)\n webViewBadImpl = true\n null\n } catch (e: Exception) {\n Log.e(TAG, \"PoToken generation failed\", e)\n null\n }\n }\n\n private fun getWebClientPoTokenBlocking(videoId: String, forceRecreate: Boolean): PoTokenResult {\n data class State(\n val generator: PoTokenGenerator,\n val visitorData: String,\n val streamingPot: String,\n val recreated: Boolean,\n )\n\n val state = synchronized(lock) {\n val shouldRecreate = webPoTokenGenerator == null || forceRecreate || webPoTokenGenerator!!.isExpired()\n if (shouldRecreate) {\n val requestInfo = InnertubeClientRequestInfo.ofWebClient()\n requestInfo.clientInfo.clientVersion = YoutubeParsingHelper.getClientVersion()\n webPoTokenVisitorData = YoutubeParsingHelper.getVisitorDataFromInnertube(\n requestInfo,\n NewPipe.getPreferredLocalization(),\n NewPipe.getPreferredContentCountry(),\n YoutubeParsingHelper.getYouTubeHeaders(),\n YoutubeParsingHelper.YOUTUBEI_V1_URL,\n null,\n false,\n )\n\n val previous = webPoTokenGenerator\n webPoTokenGenerator = runBlocking(Dispatchers.Main.immediate) {\n previous?.let { launch { it.close() } }\n PoTokenWebView.newPoTokenGenerator(context)\n }\n webPoTokenStreamingPot = runBlocking(Dispatchers.Main.immediate) {\n webPoTokenGenerator!!.generatePoToken(webPoTokenVisitorData!!)\n }\n }\n State(webPoTokenGenerator!!, webPoTokenVisitorData!!, webPoTokenStreamingPot!!, shouldRecreate)\n }\n\n val playerPot = try {\n runBlocking(Dispatchers.Main.immediate) { state.generator.generatePoToken(videoId) }\n } catch (e: Exception) {\n if (state.recreated) throw e\n return getWebClientPoTokenBlocking(videoId, forceRecreate = true)\n }\n return PoTokenResult(state.visitorData, playerPot, state.streamingPot)\n }\n}\n",[],[427,667,669],"3c64bb45-26a1-4141-980c-39e12014a4be","PoTokenGenerator.kt.txt","f463f19c-9cac-11f1-b5f5-1607ee4eb77e",109,["D",1787240207358],"package com.openai.universaldubber.potoken\n\nimport android.content.Context\nimport java.io.Closeable\n\ninterface PoTokenGenerator : Closeable {\n suspend fun generatePoToken(identifier: String): String\n fun isExpired(): Boolean\n\n interface Factory {\n suspend fun newPoTokenGenerator(context: Context): PoTokenGenerator\n }\n}\n",[],[427,667,677],"8920bbae-6fbe-454d-a29e-3f8edcfccdbe","PoTokenException.kt.txt","eb923b3c-9cac-11f1-8dc9-1607ee4eb77e",108,["D",1787240192564],"package com.openai.universaldubber.potoken\n\nclass PoTokenException(message: String) : Exception(message)\nclass BadWebViewException(message: String) : Exception(message)\n\nfun buildExceptionForJsError(error: String): Exception =\n if (error.contains(\"SyntaxError\")) BadWebViewException(error) else PoTokenException(error)\n",[],[427,667,685],"8aa9a47c-6a53-4133-9da5-63c194abf51c","JavaScriptUtil.kt.txt","0145791c-9cad-11f1-8765-1607ee4eb77e",110,["D",1787240228965],"package com.openai.universaldubber.potoken\n\nimport android.util.Base64\nimport kotlinx.serialization.json.Json\nimport kotlinx.serialization.json.JsonArray\nimport kotlinx.serialization.json.JsonElement\nimport kotlinx.serialization.json.JsonNull\nimport kotlinx.serialization.json.JsonObject\nimport kotlinx.serialization.json.JsonObjectBuilder\nimport kotlinx.serialization.json.JsonPrimitive\nimport kotlinx.serialization.json.buildJsonObject\nimport kotlinx.serialization.json.jsonArray\nimport kotlinx.serialization.json.jsonPrimitive\n\nprivate val json = Json { ignoreUnknownKeys = true }\n\nfun parseChallengeData(rawChallengeData: String): String {\n val scrambled = json.parseToJsonElement(rawChallengeData).jsonArray\n val challengeData = if (scrambled.size > 1 && scrambled[1].let { it is JsonPrimitive && it.isString }) {\n val descrambled = descramble(scrambled[1].jsonPrimitive.content)\n json.parseToJsonElement(descrambled).jsonArray\n } else {\n scrambled[0].jsonArray\n }\n\n val messageId = challengeData.getOrNull(0)?.jsonPrimitive?.content\n val interpreterHash = challengeData.getOrNull(3)?.jsonPrimitive?.content\n val program = challengeData.getOrNull(4)?.jsonPrimitive?.content\n val globalName = challengeData.getOrNull(5)?.jsonPrimitive?.content\n val clientExperimentsStateBlob = challengeData.getOrNull(7)?.jsonPrimitive?.content\n val safeScriptValue = findFirstString(challengeData.getOrNull(1))\n val trustedResourceUrlValue = findFirstString(challengeData.getOrNull(2))\n\n val result = buildJsonObject {\n putNullableString(\"messageId\", messageId)\n put(\"interpreterJavascript\", buildJsonObject {\n putNullableString(\"privateDoNotAccessOrElseSafeScriptWrappedValue\", safeScriptValue)\n putNullableString(\"privateDoNotAccessOrElseTrustedResourceUrlWrappedValue\", trustedResourceUrlValue)\n })\n putNullableString(\"interpreterHash\", interpreterHash)\n putNullableString(\"program\", program)\n putNullableString(\"globalName\", globalName)\n putNullableString(\"clientExperimentsStateBlob\", clientExperimentsStateBlob)\n }\n return json.encodeToString(JsonObject.serializer(), result)\n}\n\nprivate fun JsonObjectBuilder.putNullableString(key: String, value: String?) {\n put(key, if (value == null) JsonNull else JsonPrimitive(value))\n}\n\nprivate fun findFirstString(element: JsonElement?): String? {\n val array = element as? JsonArray ?: return null\n return array.firstOrNull { it is JsonPrimitive && it.isString }?.jsonPrimitive?.content\n}\n\nfun parseIntegrityTokenData(rawIntegrityTokenData: String): Pair {\n val integrityTokenData = json.parseToJsonElement(rawIntegrityTokenData).jsonArray\n val token = base64ToU8(integrityTokenData[0].jsonPrimitive.content)\n val expiration = integrityTokenData[1].jsonPrimitive.content.toLong()\n return token to expiration\n}\n\nfun stringToU8(identifier: String): String = newUint8Array(identifier.toByteArray(Charsets.UTF_8))\n\nfun u8ToBase64(poToken: String): String {\n val bytes = poToken.split(\",\").map { it.trim().toInt().toByte() }.toByteArray()\n return Base64.encodeToString(bytes, Base64.NO_WRAP).replace(\"+\", \"-\").replace(\"/\", \"_\")\n}\n\nprivate fun descramble(scrambledChallenge: String): String {\n val bytes = base64ToByteArray(scrambledChallenge)\n val descrambled = ByteArray(bytes.size) { (bytes[it] + 97).toByte() }\n return String(descrambled, Charsets.UTF_8)\n}\n\nprivate fun base64ToU8(base64: String): String = newUint8Array(base64ToByteArray(base64))\n\nprivate fun newUint8Array(contents: ByteArray): String =\n \"new Uint8Array([\" + contents.joinToString(separator = \",\") { (it.toInt() and 0xFF).toString() } + \"])\"\n\nprivate fun base64ToByteArray(base64: String): ByteArray {\n val base64Mod = base64.replace('-', '+').replace('_', '/').replace('.', '=')\n return try {\n Base64.decode(base64Mod, Base64.DEFAULT)\n } catch (e: IllegalArgumentException) {\n throw PoTokenException(\"Cannot base64 decode: ${e.message}\")\n }\n}\n",[],[427,667,693],"da562373-5fba-47e6-a06f-d59c563e0f88",107,["D",1787240184995],[481,482,483,484,485],[427,667],["D",1787237388571],[480,486,487,488,489],[427],"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",[],[434,415],"97f2bb6c-f9e5-4cfe-894c-21ee984e2374","YtDlpLocalResolver.kt.txt","01a01f63-fc69-76ec-8fb9-e639db49150b",90,["D",1787235111410],"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",[],[434,716],"b9a539fe-9135-413d-bd7f-7de8f6342925","01a01f63-fc69-76ec-8fb9-e871d2c813fa",72,["D",1787233041529],[],[434,639],"31d9928b-1ff3-4ad1-9945-7448c0473d4c","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",[],[434,647],"9d34516a-044e-4c85-95f9-831221fe903f","01a01f63-fc69-76ec-8fb9-f4aa9a42f4b4",["D",1787233041529],[],[434,656],["D",1787233033243],[474,475,476,477,478],[434],"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",[],[440,415],"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",[],[440,716],"a3f2a4e9-e967-403a-aadd-db9e1310690e","01a01c42-f15a-70d4-b991-cb8e0c478353",54,["D",1787180706205],[],[440,639],"1b01a7a1-ca7e-4f75-9a9d-b5cc75f419ec","01a01c42-f15a-70d4-b991-c037a210bfd4",53,["D",1787180699813],[],[440,647],"0258f8df-e804-4b22-892f-f6c3cb2a75d0","01a01c42-f15a-70d4-b991-bf6f5fd2715e",44,["D",1787180544349],[],[440,656],["D",1787180538676],[468,469,470,471,472],[440],"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",[],[446,415],"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",[],[446,716],"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",[],[446,639],"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",[],[446,647],"99f0a5e0-d140-4737-bca8-2eb35879f00a","b996a8ee-9c1a-11f1-a611-1607ee4eb77e",31,["D",1787177402097],[],[446,656],["D",1787177391642],[462,463,464,465,466],[446],["D",1787156870791],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":53,"_100":101,"_102":24},{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"ctx",{"_77":-5,"_123":851,"_852":853,"_854":855,"_856":24,"_857":24,"_858":24,"_859":57,"_860":-5,"_861":-7,"_862":-7,"_863":61,"_864":24,"_865":24,"_866":-5,"_867":24,"_868":24,"_869":24,"_870":-5},"ENV",{"_822":823,"_824":825,"_826":85,"_827":828,"_829":830,"_831":832,"_833":834,"_835":836,"_837":838,"_839":840,"_841":842,"_843":844,"_845":846,"_847":848,"_849":850},"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 · v112