[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_839":840,"_841":842},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":59,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",118,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":20,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":20,"_35":36},"deleted",false,"deletedHere","path","v620/UniversalPlaybackService.kt.txt","latestPath","fileId","01a01fa6-7138-77eb-a2e5-b095f2c02951","name","UniversalPlaybackService.kt.txt","fileType","content","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","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 androidx.media3.exoplayer.source.MergingMediaSource\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","createdAt",["D",1787240378235],"branchVersion","branchId","3c31854b-284f-4dd6-bdc4-03a479ff66ac","id","60876f3f-66c0-4174-afa2-a8c0c0d0af28","universal-dubber-571-real-patches",["D",1787156870791],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Verified Universal Dubber 5.7.1 resolver source overlays","imageUrl","62d63139-fff1-474c-957e-0de43711ef38","pinnedFileId","8a1df52e-9beb-11f1-9439-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fe29f-d21a-769b-b052-ec8f0e83c092","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",188,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rezar","handle","displayName","Reza Rahaeifard","avatar","https://lh3.googleusercontent.com/a/ACg8ocLSq53iQZbkEu7APkCBMoGsId1S_CbUp8pbglW1kMZZ96gL_JYF=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":835,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":836,"_81":837,"_83":838,"_85":25},"tree",[463,469,475,481,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,525,526,527,528],"files",[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,525,526,527,528],"counts",{"_453":63,"_454":290,"_455":63,"_456":457,"_458":459},"contents",[128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":447,"_32":448,"_30":449,"_170":-5,"_41":42,"_40":450,"_172":59,"_38":451,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_27":452},{"_43":441,"_32":442,"_30":443,"_170":-5,"_41":42,"_40":444,"_172":59,"_38":445,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_27":446},{"_43":435,"_32":436,"_30":437,"_170":-5,"_41":42,"_40":438,"_172":59,"_38":439,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_27":440},{"_43":428,"_32":429,"_30":430,"_170":-5,"_41":42,"_40":431,"_172":59,"_38":432,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_27":434},{"_43":422,"_32":423,"_30":424,"_170":-5,"_41":42,"_40":290,"_172":59,"_38":425,"_13":63,"_34":20,"_35":426,"_24":25,"_176":-5,"_27":427},{"_43":416,"_32":417,"_30":418,"_170":-5,"_41":42,"_40":239,"_172":59,"_38":419,"_13":63,"_34":20,"_35":420,"_24":25,"_176":-5,"_27":421},{"_43":407,"_32":408,"_30":409,"_170":-5,"_41":42,"_40":410,"_172":25,"_38":411,"_13":412,"_34":174,"_35":413,"_24":25,"_176":414,"_27":415},{"_43":398,"_32":399,"_30":400,"_170":-5,"_41":42,"_40":401,"_172":25,"_38":402,"_13":403,"_34":174,"_35":404,"_24":25,"_176":405,"_27":406},{"_43":390,"_32":391,"_30":392,"_170":-5,"_41":42,"_40":393,"_172":59,"_38":394,"_13":63,"_34":174,"_35":395,"_24":25,"_176":396,"_27":397},{"_43":382,"_32":383,"_30":384,"_170":-5,"_41":42,"_40":385,"_172":59,"_38":386,"_13":63,"_34":174,"_35":387,"_24":25,"_176":388,"_27":389},{"_43":374,"_32":375,"_30":376,"_170":-5,"_41":42,"_40":377,"_172":59,"_38":378,"_13":63,"_34":174,"_35":379,"_24":25,"_176":380,"_27":381},{"_43":366,"_32":367,"_30":368,"_170":-5,"_41":42,"_40":369,"_172":59,"_38":370,"_13":63,"_34":174,"_35":371,"_24":25,"_176":372,"_27":373},{"_43":359,"_32":360,"_30":361,"_170":-5,"_41":42,"_40":362,"_172":59,"_38":363,"_13":63,"_34":174,"_35":364,"_24":25,"_176":-5,"_27":365},{"_43":351,"_32":352,"_30":353,"_170":-5,"_41":42,"_40":354,"_172":59,"_38":355,"_13":63,"_34":174,"_35":356,"_24":25,"_176":357,"_27":358},{"_43":344,"_32":345,"_30":346,"_170":-5,"_41":42,"_40":347,"_172":59,"_38":348,"_13":239,"_34":174,"_35":349,"_24":25,"_176":-5,"_27":350},{"_43":337,"_32":338,"_30":339,"_170":-5,"_41":42,"_40":340,"_172":59,"_38":341,"_13":290,"_34":174,"_35":342,"_24":25,"_176":-5,"_27":343},{"_43":330,"_32":331,"_30":332,"_170":-5,"_41":42,"_40":333,"_172":59,"_38":334,"_13":298,"_34":240,"_35":335,"_24":25,"_176":-5,"_27":336},{"_43":322,"_32":323,"_30":324,"_170":-5,"_41":42,"_40":325,"_172":59,"_38":326,"_13":327,"_34":174,"_35":328,"_24":25,"_176":-5,"_27":329},{"_43":316,"_32":317,"_30":57,"_170":-5,"_41":42,"_40":318,"_172":59,"_38":319,"_13":290,"_34":174,"_35":320,"_24":25,"_176":-5,"_27":321},{"_43":309,"_32":310,"_30":311,"_170":-5,"_41":42,"_40":312,"_172":59,"_38":313,"_13":63,"_34":174,"_35":314,"_24":25,"_176":-5,"_27":315},{"_43":302,"_32":303,"_30":304,"_170":-5,"_41":42,"_40":305,"_172":59,"_38":306,"_13":63,"_34":174,"_35":307,"_24":25,"_176":-5,"_27":308},{"_43":293,"_32":294,"_30":295,"_170":-5,"_41":42,"_40":296,"_172":59,"_38":297,"_13":298,"_34":174,"_35":299,"_24":25,"_176":300,"_27":301},{"_43":285,"_32":286,"_30":287,"_170":-5,"_41":42,"_40":288,"_172":59,"_38":289,"_13":290,"_34":174,"_35":291,"_24":25,"_176":-5,"_27":292},{"_43":278,"_32":279,"_30":280,"_170":-5,"_41":42,"_40":281,"_172":59,"_38":282,"_13":63,"_34":20,"_35":283,"_24":25,"_176":-5,"_27":284},{"_43":271,"_32":272,"_30":273,"_170":-5,"_41":42,"_40":274,"_172":59,"_38":275,"_13":63,"_34":174,"_35":276,"_24":25,"_176":-5,"_27":277},{"_43":264,"_32":265,"_30":266,"_170":-5,"_41":42,"_40":267,"_172":59,"_38":268,"_13":63,"_34":174,"_35":269,"_24":25,"_176":-5,"_27":270},{"_43":257,"_32":258,"_30":259,"_170":-5,"_41":42,"_40":260,"_172":59,"_38":261,"_13":63,"_34":174,"_35":262,"_24":25,"_176":-5,"_27":263},{"_43":250,"_32":251,"_30":252,"_170":-5,"_41":42,"_40":253,"_172":59,"_38":254,"_13":63,"_34":174,"_35":255,"_24":25,"_176":-5,"_27":256},{"_43":243,"_32":244,"_30":245,"_170":-5,"_41":42,"_40":246,"_172":59,"_38":247,"_13":63,"_34":174,"_35":248,"_24":25,"_176":-5,"_27":249},{"_43":234,"_32":235,"_30":236,"_170":-5,"_41":42,"_40":237,"_172":59,"_38":238,"_13":239,"_34":240,"_35":241,"_24":25,"_176":-5,"_27":242},{"_43":227,"_32":228,"_30":229,"_170":-5,"_41":42,"_40":230,"_172":59,"_38":231,"_13":63,"_34":174,"_35":232,"_24":25,"_176":-5,"_27":233},{"_43":220,"_32":221,"_30":222,"_170":-5,"_41":42,"_40":223,"_172":59,"_38":224,"_13":63,"_34":174,"_35":225,"_24":25,"_176":-5,"_27":226},{"_43":213,"_32":214,"_30":215,"_170":-5,"_41":42,"_40":216,"_172":59,"_38":217,"_13":63,"_34":174,"_35":218,"_24":25,"_176":-5,"_27":219},{"_43":206,"_32":207,"_30":208,"_170":-5,"_41":42,"_40":209,"_172":59,"_38":210,"_13":63,"_34":174,"_35":211,"_24":25,"_176":-5,"_27":212},{"_43":199,"_32":200,"_30":201,"_170":-5,"_41":42,"_40":202,"_172":59,"_38":203,"_13":63,"_34":174,"_35":204,"_24":25,"_176":-5,"_27":205},{"_43":192,"_32":193,"_30":194,"_170":-5,"_41":42,"_40":195,"_172":59,"_38":196,"_13":63,"_34":174,"_35":197,"_24":25,"_176":-5,"_27":198},{"_43":185,"_32":186,"_30":187,"_170":-5,"_41":42,"_40":188,"_172":59,"_38":189,"_13":63,"_34":174,"_35":190,"_24":25,"_176":-5,"_27":191},{"_43":178,"_32":179,"_30":180,"_170":-5,"_41":42,"_40":181,"_172":59,"_38":182,"_13":63,"_34":174,"_35":183,"_24":25,"_176":-5,"_27":184},{"_43":167,"_32":168,"_30":169,"_170":-5,"_41":42,"_40":171,"_172":59,"_38":173,"_13":63,"_34":174,"_35":175,"_24":25,"_176":-5,"_27":177},"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",[168],"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",[179],"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",[186],"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}",[193],"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)});}}",[200],"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",[207],"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)});}}",[214],"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",[221],"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",[228],"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",[235],"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",[244],"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",[251],"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",[258],"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",[265],"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",[272],"032c2a72-75a6-4ff6-8e81-5de87bb0c9aa","test-static.txt","85cb1f54-9c1a-11f1-858d-1607ee4eb77e",27,["D",1787177315275],"HELLO_STATIC_590",[279],"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}",[286],"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",[294],"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",[303],"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",[310],"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",[317],"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",[323],"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",[331],"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",[338],"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",[345],"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",[352],"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",[360],"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",[367],"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",[375],"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",[383],"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",[391],"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",[399],"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",[408],"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",[417],"c74b85d7-c14e-4db5-bd90-11b223f073c0","README.txt","ebf35b50-9bea-11f1-b085-1607ee4eb77e",["D",1787156870833],"Universal Dubber 5.7.1 build overlays",[423],"f7a7e378-bb84-424d-b315-969b523489f4","v620","6443cc8c-9ca6-11f1-b642-1607ee4eb77e",99,["D",1787237388571],"directory",[429],"e38043a9-2e6e-49db-8fb2-c8cbaa1261bc","v610","4048ad5c-9c9c-11f1-9647-1607ee4eb77e",71,["D",1787233033243],[436],"ad84f807-616f-43e9-b7f0-b16dbfd60131","v600","071b0540-9c22-11f1-a07a-1607ee4eb77e",43,["D",1787180538676],[442],"149ff5b5-ebac-40b5-a905-d281d05d5128","v590","edf0f1dc-c67f-4898-a943-eee1324a510d",30,["D",1787177391642],[448],"pulls","branches","forks","envVars",{"_460":63,"_462":63},"connections",{"_460":63,"_461":63},"count","unfilledCount","emptyCount",{"_43":447,"_32":448,"_30":449,"_170":-5,"_41":42,"_40":450,"_172":59,"_38":832,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_530":833,"_27":834},{"_43":826,"_32":672,"_30":827,"_170":449,"_41":42,"_40":828,"_172":59,"_38":829,"_13":63,"_34":20,"_35":676,"_24":25,"_176":-5,"_530":830,"_27":831},{"_43":819,"_32":663,"_30":820,"_170":449,"_41":42,"_40":821,"_172":59,"_38":822,"_13":63,"_34":20,"_35":823,"_24":25,"_176":-5,"_530":824,"_27":825},{"_43":812,"_32":33,"_30":813,"_170":449,"_41":42,"_40":814,"_172":59,"_38":815,"_13":63,"_34":20,"_35":816,"_24":25,"_176":-5,"_530":817,"_27":818},{"_43":805,"_32":651,"_30":806,"_170":449,"_41":42,"_40":807,"_172":59,"_38":808,"_13":63,"_34":20,"_35":809,"_24":25,"_176":-5,"_530":810,"_27":811},{"_43":799,"_32":417,"_30":800,"_170":449,"_41":42,"_40":450,"_172":59,"_38":801,"_13":63,"_34":20,"_35":802,"_24":25,"_176":-5,"_530":803,"_27":804},{"_43":441,"_32":442,"_30":443,"_170":-5,"_41":42,"_40":444,"_172":59,"_38":796,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_530":797,"_27":798},{"_43":790,"_32":672,"_30":791,"_170":443,"_41":42,"_40":792,"_172":59,"_38":793,"_13":63,"_34":20,"_35":676,"_24":25,"_176":-5,"_530":794,"_27":795},{"_43":783,"_32":663,"_30":784,"_170":443,"_41":42,"_40":785,"_172":59,"_38":786,"_13":787,"_34":20,"_35":752,"_24":25,"_176":-5,"_530":788,"_27":789},{"_43":777,"_32":33,"_30":778,"_170":443,"_41":42,"_40":779,"_172":59,"_38":780,"_13":290,"_34":20,"_35":36,"_24":25,"_176":-5,"_530":781,"_27":782},{"_43":770,"_32":651,"_30":771,"_170":443,"_41":42,"_40":772,"_172":59,"_38":773,"_13":290,"_34":20,"_35":774,"_24":25,"_176":-5,"_530":775,"_27":776},{"_43":763,"_32":417,"_30":764,"_170":443,"_41":42,"_40":765,"_172":59,"_38":766,"_13":412,"_34":20,"_35":767,"_24":25,"_176":-5,"_530":768,"_27":769},{"_43":435,"_32":436,"_30":437,"_170":-5,"_41":42,"_40":438,"_172":59,"_38":760,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_530":761,"_27":762},{"_43":755,"_32":672,"_30":756,"_170":437,"_41":42,"_40":745,"_172":59,"_38":757,"_13":63,"_34":20,"_35":676,"_24":25,"_176":-5,"_530":758,"_27":759},{"_43":749,"_32":663,"_30":750,"_170":437,"_41":42,"_40":745,"_172":59,"_38":751,"_13":63,"_34":20,"_35":752,"_24":25,"_176":-5,"_530":753,"_27":754},{"_43":743,"_32":33,"_30":744,"_170":437,"_41":42,"_40":745,"_172":59,"_38":746,"_13":63,"_34":20,"_35":36,"_24":25,"_176":-5,"_530":747,"_27":748},{"_43":736,"_32":651,"_30":737,"_170":437,"_41":42,"_40":738,"_172":59,"_38":739,"_13":327,"_34":20,"_35":740,"_24":25,"_176":-5,"_530":741,"_27":742},{"_43":729,"_32":417,"_30":730,"_170":437,"_41":42,"_40":731,"_172":59,"_38":732,"_13":239,"_34":20,"_35":733,"_24":25,"_176":-5,"_530":734,"_27":735},{"_43":428,"_32":429,"_30":430,"_170":-5,"_41":42,"_40":431,"_172":59,"_38":726,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_530":727,"_27":728},{"_43":721,"_32":688,"_30":682,"_170":430,"_41":42,"_40":722,"_172":59,"_38":723,"_13":63,"_34":433,"_35":-5,"_24":25,"_176":-5,"_530":724,"_27":725},{"_43":713,"_32":714,"_30":715,"_170":682,"_41":42,"_40":716,"_172":59,"_38":717,"_13":63,"_34":20,"_35":718,"_24":25,"_176":-5,"_530":719,"_27":720},{"_43":705,"_32":706,"_30":707,"_170":682,"_41":42,"_40":708,"_172":59,"_38":709,"_13":63,"_34":20,"_35":710,"_24":25,"_176":-5,"_530":711,"_27":712},{"_43":697,"_32":698,"_30":699,"_170":682,"_41":42,"_40":700,"_172":59,"_38":701,"_13":63,"_34":20,"_35":702,"_24":25,"_176":-5,"_530":703,"_27":704},{"_43":689,"_32":690,"_30":691,"_170":682,"_41":42,"_40":692,"_172":59,"_38":693,"_13":63,"_34":20,"_35":694,"_24":25,"_176":-5,"_530":695,"_27":696},{"_43":679,"_32":680,"_30":681,"_170":682,"_41":42,"_40":683,"_172":59,"_38":684,"_13":63,"_34":20,"_35":685,"_24":25,"_176":-5,"_530":686,"_27":687},{"_43":671,"_32":672,"_30":673,"_170":430,"_41":42,"_40":674,"_172":59,"_38":675,"_13":63,"_34":20,"_35":676,"_24":25,"_176":-5,"_530":677,"_27":678},{"_43":662,"_32":663,"_30":664,"_170":430,"_41":42,"_40":665,"_172":59,"_38":666,"_13":667,"_34":20,"_35":668,"_24":25,"_176":-5,"_530":669,"_27":670},{"_43":658,"_32":33,"_30":31,"_170":430,"_41":42,"_40":14,"_172":25,"_38":659,"_13":290,"_34":20,"_35":37,"_24":25,"_176":-5,"_530":660,"_27":661},{"_43":650,"_32":651,"_30":652,"_170":430,"_41":42,"_40":653,"_172":59,"_38":654,"_13":63,"_34":20,"_35":655,"_24":25,"_176":-5,"_530":656,"_27":657},{"_43":643,"_32":417,"_30":644,"_170":430,"_41":42,"_40":645,"_172":25,"_38":646,"_13":290,"_34":20,"_35":647,"_24":25,"_176":-5,"_530":648,"_27":649},{"_43":635,"_32":636,"_30":637,"_170":430,"_41":42,"_40":638,"_172":59,"_38":639,"_13":63,"_34":20,"_35":640,"_24":25,"_176":-5,"_530":641,"_27":642},{"_43":422,"_32":423,"_30":424,"_170":-5,"_41":42,"_40":290,"_172":59,"_38":632,"_13":63,"_34":20,"_35":426,"_24":25,"_176":-5,"_530":633,"_27":634},{"_43":416,"_32":417,"_30":418,"_170":-5,"_41":42,"_40":239,"_172":59,"_38":629,"_13":63,"_34":20,"_35":420,"_24":25,"_176":-5,"_530":630,"_27":631},{"_43":407,"_32":408,"_30":409,"_170":-5,"_41":42,"_40":410,"_172":25,"_38":626,"_13":412,"_34":174,"_35":413,"_24":25,"_176":414,"_530":627,"_27":628},{"_43":398,"_32":399,"_30":400,"_170":-5,"_41":42,"_40":401,"_172":25,"_38":623,"_13":403,"_34":174,"_35":404,"_24":25,"_176":405,"_530":624,"_27":625},{"_43":390,"_32":391,"_30":392,"_170":-5,"_41":42,"_40":393,"_172":59,"_38":620,"_13":63,"_34":174,"_35":395,"_24":25,"_176":396,"_530":621,"_27":622},{"_43":382,"_32":383,"_30":384,"_170":-5,"_41":42,"_40":385,"_172":59,"_38":617,"_13":63,"_34":174,"_35":387,"_24":25,"_176":388,"_530":618,"_27":619},{"_43":374,"_32":375,"_30":376,"_170":-5,"_41":42,"_40":377,"_172":59,"_38":614,"_13":63,"_34":174,"_35":379,"_24":25,"_176":380,"_530":615,"_27":616},{"_43":366,"_32":367,"_30":368,"_170":-5,"_41":42,"_40":369,"_172":59,"_38":611,"_13":63,"_34":174,"_35":371,"_24":25,"_176":372,"_530":612,"_27":613},{"_43":359,"_32":360,"_30":361,"_170":-5,"_41":42,"_40":362,"_172":59,"_38":608,"_13":63,"_34":174,"_35":364,"_24":25,"_176":-5,"_530":609,"_27":610},{"_43":351,"_32":352,"_30":353,"_170":-5,"_41":42,"_40":354,"_172":59,"_38":605,"_13":63,"_34":174,"_35":356,"_24":25,"_176":357,"_530":606,"_27":607},{"_43":344,"_32":345,"_30":346,"_170":-5,"_41":42,"_40":347,"_172":59,"_38":602,"_13":239,"_34":174,"_35":349,"_24":25,"_176":-5,"_530":603,"_27":604},{"_43":337,"_32":338,"_30":339,"_170":-5,"_41":42,"_40":340,"_172":59,"_38":599,"_13":290,"_34":174,"_35":342,"_24":25,"_176":-5,"_530":600,"_27":601},{"_43":330,"_32":331,"_30":332,"_170":-5,"_41":42,"_40":333,"_172":59,"_38":596,"_13":298,"_34":240,"_35":335,"_24":25,"_176":-5,"_530":597,"_27":598},{"_43":322,"_32":323,"_30":324,"_170":-5,"_41":42,"_40":325,"_172":59,"_38":593,"_13":327,"_34":174,"_35":328,"_24":25,"_176":-5,"_530":594,"_27":595},{"_43":316,"_32":317,"_30":57,"_170":-5,"_41":42,"_40":318,"_172":59,"_38":590,"_13":290,"_34":174,"_35":320,"_24":25,"_176":-5,"_530":591,"_27":592},{"_43":309,"_32":310,"_30":311,"_170":-5,"_41":42,"_40":312,"_172":59,"_38":587,"_13":63,"_34":174,"_35":314,"_24":25,"_176":-5,"_530":588,"_27":589},{"_43":302,"_32":303,"_30":304,"_170":-5,"_41":42,"_40":305,"_172":59,"_38":584,"_13":63,"_34":174,"_35":307,"_24":25,"_176":-5,"_530":585,"_27":586},{"_43":293,"_32":294,"_30":295,"_170":-5,"_41":42,"_40":296,"_172":59,"_38":581,"_13":298,"_34":174,"_35":299,"_24":25,"_176":300,"_530":582,"_27":583},{"_43":285,"_32":286,"_30":287,"_170":-5,"_41":42,"_40":288,"_172":59,"_38":578,"_13":290,"_34":174,"_35":291,"_24":25,"_176":-5,"_530":579,"_27":580},{"_43":278,"_32":279,"_30":280,"_170":-5,"_41":42,"_40":281,"_172":59,"_38":575,"_13":63,"_34":20,"_35":283,"_24":25,"_176":-5,"_530":576,"_27":577},{"_43":271,"_32":272,"_30":273,"_170":-5,"_41":42,"_40":274,"_172":59,"_38":572,"_13":63,"_34":174,"_35":276,"_24":25,"_176":-5,"_530":573,"_27":574},{"_43":264,"_32":265,"_30":266,"_170":-5,"_41":42,"_40":267,"_172":59,"_38":569,"_13":63,"_34":174,"_35":269,"_24":25,"_176":-5,"_530":570,"_27":571},{"_43":257,"_32":258,"_30":259,"_170":-5,"_41":42,"_40":260,"_172":59,"_38":566,"_13":63,"_34":174,"_35":262,"_24":25,"_176":-5,"_530":567,"_27":568},{"_43":250,"_32":251,"_30":252,"_170":-5,"_41":42,"_40":253,"_172":59,"_38":563,"_13":63,"_34":174,"_35":255,"_24":25,"_176":-5,"_530":564,"_27":565},{"_43":243,"_32":244,"_30":245,"_170":-5,"_41":42,"_40":246,"_172":59,"_38":560,"_13":63,"_34":174,"_35":248,"_24":25,"_176":-5,"_530":561,"_27":562},{"_43":234,"_32":235,"_30":236,"_170":-5,"_41":42,"_40":237,"_172":59,"_38":557,"_13":239,"_34":240,"_35":241,"_24":25,"_176":-5,"_530":558,"_27":559},{"_43":227,"_32":228,"_30":229,"_170":-5,"_41":42,"_40":230,"_172":59,"_38":554,"_13":63,"_34":174,"_35":232,"_24":25,"_176":-5,"_530":555,"_27":556},{"_43":220,"_32":221,"_30":222,"_170":-5,"_41":42,"_40":223,"_172":59,"_38":551,"_13":63,"_34":174,"_35":225,"_24":25,"_176":-5,"_530":552,"_27":553},{"_43":213,"_32":214,"_30":215,"_170":-5,"_41":42,"_40":216,"_172":59,"_38":548,"_13":63,"_34":174,"_35":218,"_24":25,"_176":-5,"_530":549,"_27":550},{"_43":206,"_32":207,"_30":208,"_170":-5,"_41":42,"_40":209,"_172":59,"_38":545,"_13":63,"_34":174,"_35":211,"_24":25,"_176":-5,"_530":546,"_27":547},{"_43":199,"_32":200,"_30":201,"_170":-5,"_41":42,"_40":202,"_172":59,"_38":542,"_13":63,"_34":174,"_35":204,"_24":25,"_176":-5,"_530":543,"_27":544},{"_43":192,"_32":193,"_30":194,"_170":-5,"_41":42,"_40":195,"_172":59,"_38":539,"_13":63,"_34":174,"_35":197,"_24":25,"_176":-5,"_530":540,"_27":541},{"_43":185,"_32":186,"_30":187,"_170":-5,"_41":42,"_40":188,"_172":59,"_38":536,"_13":63,"_34":174,"_35":190,"_24":25,"_176":-5,"_530":537,"_27":538},{"_43":178,"_32":179,"_30":180,"_170":-5,"_41":42,"_40":181,"_172":59,"_38":533,"_13":63,"_34":174,"_35":183,"_24":25,"_176":-5,"_530":534,"_27":535},{"_43":167,"_32":168,"_30":169,"_170":-5,"_41":42,"_40":171,"_172":59,"_38":529,"_13":63,"_34":174,"_35":175,"_24":25,"_176":-5,"_530":531,"_27":532},["D",1787236507820],"children",[],[168],["D",1787236535494],[],[179],["D",1787236567609],[],[186],["D",1787177963614],[],[193],["D",1787236623432],[],[200],["D",1787236131405],[],[207],["D",1787236651790],[],[214],["D",1787236186493],[],[221],["D",1787236416264],[],[228],["D",1787232822238],[],[235],["D",1787233166204],[],[244],["D",1787232832373],[],[251],["D",1787233148974],[],[258],["D",1787233196350],[],[265],["D",1787233240984],[],[272],["D",1787177315275],[],[279],["D",1787177378140],[],[286],["D",1787234697788],[],[294],["D",1787180719815],[],[303],["D",1787177537021],[],[310],["D",1787159229206],[],[317],["D",1787182564011],[],[323],["D",1787159287034],[],[331],["D",1787171573718],[],[338],["D",1787171464834],[],[345],["D",1787181132689],[],[352],["D",1787178016166],[],[360],["D",1787178565514],[],[367],["D",1787178557075],[],[375],["D",1787178547952],[],[383],["D",1787178537728],[],[391],["D",1787234748611],[],[399],["D",1787159105213],[],[408],["D",1787156892990],[],[417],["D",1787156870833],[],[423],"15f5135f-835f-40f7-964f-a76ae09346c3","po_token.html","25d3714e-9cad-11f1-8c25-1607ee4eb77e",113,["D",1787240290278],"",[],[429,636],"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",[],[429,417],"75e92f90-c262-4de0-b456-09d996d270fa","YtDlpLocalResolver.kt.txt","3ce6d2e0-9cad-11f1-a818-1607ee4eb77e",114,["D",1787240329013],"package com.openai.universaldubber\n\nimport android.content.Context\nimport com.openai.universaldubber.potoken.PoTokenProviderImpl\nimport okhttp3.OkHttpClient\nimport okhttp3.Request\nimport org.schabi.newpipe.extractor.NewPipe\nimport org.schabi.newpipe.extractor.ServiceList\nimport org.schabi.newpipe.extractor.services.youtube.YoutubeService\nimport org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeStreamExtractor\nimport org.schabi.newpipe.extractor.stream.StreamInfo\nimport java.util.concurrent.TimeUnit\n\n/**\n * 6.2 local YouTube resolver.\n *\n * There is intentionally no yt-dlp, cookie file, Piped, iframe or YouTube player here. NewPipe's\n * WEB extractor receives real BotGuard/PoToken values from [PoTokenProviderImpl], then every\n * googlevideo candidate is Range-probed on the same Android device before Media3 sees it.\n */\nclass YtDlpLocalResolver(context: Context) {\n\n data class ResolvedMedia(\n val uri: String,\n val audioUri: String? = null,\n val requestHeaders: Map,\n val title: String,\n val quality: String,\n val isLive: Boolean,\n val strategyIndex: Int,\n val strategyLabel: String,\n )\n\n companion object {\n const val DEFAULT_USER_AGENT =\n \"Mozilla/5.0 (Linux; Android 16; Mobile) AppleWebKit/537.36 \" +\n \"(KHTML, like Gecko) Chrome/139.0 Mobile Safari/537.36\"\n\n private val initLock = Any()\n @Volatile private var initialized = false\n }\n\n private val appContext = context.applicationContext\n private val downloader = NewPipeOkHttpDownloader()\n private val poTokenProvider = PoTokenProviderImpl(appContext)\n private val probeClient = OkHttpClient.Builder()\n .connectTimeout(5, TimeUnit.SECONDS)\n .readTimeout(6, TimeUnit.SECONDS)\n .callTimeout(7, TimeUnit.SECONDS)\n .followRedirects(true)\n .followSslRedirects(true)\n .retryOnConnectionFailure(true)\n .build()\n\n init { ensureInitialized() }\n\n @Suppress(\"UNUSED_PARAMETER\")\n fun resolve(\n youtubeUrl: String,\n rawSessionCookie: String?,\n startStrategy: Int = 0,\n onStatus: (String) -> Unit = {},\n ): ResolvedMedia {\n ensureInitialized()\n onStatus(\"BotGuard/PoToken در حال ساخت Proof-of-Origin محلی…\")\n\n val service = NewPipe.getService(ServiceList.YouTube.serviceId) as YoutubeService\n val started = System.nanoTime()\n val info = StreamInfo.getInfo(service, youtubeUrl)\n val extractMs = (System.nanoTime() - started) / 1_000_000L\n onStatus(\"YouTube استخراج شد (${extractMs}ms)؛ در حال Range-probe واقعی stream…\")\n\n val headers = mapOf(\n \"User-Agent\" to DEFAULT_USER_AGENT,\n \"Referer\" to \"https://www.youtube.com/\",\n \"Origin\" to \"https://www.youtube.com\",\n )\n\n val combined = info.videoStreams.orEmpty()\n .filter { it.content?.startsWith(\"http\") == true }\n .sortedWith(\n compareByDescending {\n resolutionNumber(it.resolution)\n }.thenByDescending {\n if (it.format?.name?.contains(\"MPEG\", ignoreCase = true) == true) 1 else 0\n }\n )\n\n // Progressive streams are ideal for fast startup because one URL contains video + audio.\n for ((index, stream) in combined.withIndex()) {\n val url = stream.content ?: continue\n if (probe(url, headers)) {\n return ResolvedMedia(\n uri = url,\n requestHeaders = headers,\n title = info.name?.takeIf { it.isNotBlank() } ?: \"YouTube\",\n quality = stream.resolution ?: \"progressive\",\n isLive = false,\n strategyIndex = index,\n strategyLabel = \"NewPipe WEB + BotGuard PoToken • progressive\",\n )\n }\n }\n\n // If no progressive stream survived, probe a video-only + audio pair and let Media3 merge them.\n val videos = info.videoOnlyStreams.orEmpty()\n .filter { it.content?.startsWith(\"http\") == true }\n .sortedByDescending { resolutionNumber(it.resolution) }\n val audios = info.audioStreams.orEmpty()\n .filter { it.content?.startsWith(\"http\") == true }\n .sortedByDescending { it.averageBitrate }\n\n var audioUrl: String? = null\n for (audio in audios) {\n val candidate = audio.content ?: continue\n if (probe(candidate, headers)) {\n audioUrl = candidate\n break\n }\n }\n if (audioUrl != null) {\n for ((index, video) in videos.withIndex()) {\n val candidate = video.content ?: continue\n if (probe(candidate, headers)) {\n return ResolvedMedia(\n uri = candidate,\n audioUri = audioUrl,\n requestHeaders = headers,\n title = info.name?.takeIf { it.isNotBlank() } ?: \"YouTube\",\n quality = video.resolution ?: \"adaptive\",\n isLive = false,\n strategyIndex = combined.size + index,\n strategyLabel = \"NewPipe WEB + BotGuard PoToken • adaptive A/V\",\n )\n }\n }\n }\n\n val details = info.errors.orEmpty().joinToString(\" | \") { it.message ?: it.javaClass.simpleName }.take(700)\n throw IllegalStateException(\n if (details.isBlank()) \"YouTube هیچ stream قابل خواندن پس از PoToken برنگرداند\"\n else \"همه streamها پس از PoToken در Range-probe رد شدند: $details\"\n )\n }\n\n private fun ensureInitialized() {\n if (initialized) return\n synchronized(initLock) {\n if (initialized) return\n NewPipe.init(downloader)\n YoutubeStreamExtractor.setPoTokenProvider(poTokenProvider)\n initialized = true\n }\n }\n\n private fun probe(url: String, headers: Map): Boolean {\n return runCatching {\n val builder = Request.Builder().url(url).get().header(\"Range\", \"bytes=0-2047\")\n headers.forEach { (k, v) -> builder.header(k, v) }\n probeClient.newCall(builder.build()).execute().use { response ->\n if (response.code != 200 && response.code != 206) return@use false\n val contentType = response.header(\"Content-Type\").orEmpty().lowercase()\n if (contentType.contains(\"text/html\")) return@use false\n val source = response.body?.source() ?: return@use false\n val bytes = source.readByteArray(64)\n bytes.isNotEmpty()\n }\n }.getOrDefault(false)\n }\n\n private fun resolutionNumber(value: String?): Int =\n value?.replace(Regex(\"[^0-9]\"), \"\")?.toIntOrNull() ?: 0\n}\n",[],[429,651],"5e771eae-95b7-4716-b129-2455ea2d21e6",["D",1787240378235],[],[429,33],"7556a9cd-0d51-4ef9-a9ca-4a42dcd08b7a","MainActivity.kt.txt","01a01fa6-7138-77eb-a2e5-ad279ad11a6a",117,["D",1787240367031],8,"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 = \"Media3 محلی + NewPipe BotGuard/PoToken + دوبله پس‌زمینه\"\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 loadButton.isEnabled = false\n videoLoaded = false\n videoTitle.text = \"ویدیو: در حال resolve محلی PoToken…\"\n setStatus(\"NewPipe + BotGuard/PoToken روی گوشی در حال استخراج و probe واقعی stream است…\")\n\n val serviceIntent = Intent(this, UniversalPlaybackService::class.java)\n .setAction(UniversalPlaybackService.ACTION_LOAD)\n .putExtra(UniversalPlaybackService.EXTRA_URL, url)\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 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",[],[429,663],"19fb6fff-293f-4e87-a6ed-2d7bce457303","AndroidManifest.xml.txt","01a01fa6-7138-77eb-a2e5-b874bb91b484",100,["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",[],[429,672],"5a7d99b3-7681-49eb-97b1-c35cf5abf8ab","PoTokenWebView.kt.txt","1cafe502-9cad-11f1-8e5e-1607ee4eb77e","e70fa3ec-9cac-11f1-ab32-1607ee4eb77e",112,["D",1787240274933],"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",[],[429,688,680],"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",[],[429,688,690],"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",[],[429,688,698],"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",[],[429,688,706],"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",[],[429,688,714],"da562373-5fba-47e6-a06f-d59c563e0f88",107,["D",1787240184995],[483,484,485,486,487],[429,688],["D",1787237388571],[482,488,489,490,491,492,493],[429],"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",[],[436,417],"97f2bb6c-f9e5-4cfe-894c-21ee984e2374","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",[],[436,651],"b9a539fe-9135-413d-bd7f-7de8f6342925","01a01f63-fc69-76ec-8fb9-e871d2c813fa",72,["D",1787233041529],[],[436,33],"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",[],[436,663],"9d34516a-044e-4c85-95f9-831221fe903f","01a01f63-fc69-76ec-8fb9-f4aa9a42f4b4",["D",1787233041529],[],[436,672],["D",1787233033243],[476,477,478,479,480],[436],"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",[],[442,417],"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",[],[442,651],"a3f2a4e9-e967-403a-aadd-db9e1310690e","01a01c42-f15a-70d4-b991-cb8e0c478353",54,["D",1787180706205],[],[442,33],"1b01a7a1-ca7e-4f75-9a9d-b5cc75f419ec","01a01c42-f15a-70d4-b991-c037a210bfd4",53,["D",1787180699813],5,[],[442,663],"0258f8df-e804-4b22-892f-f6c3cb2a75d0","01a01c42-f15a-70d4-b991-bf6f5fd2715e",44,["D",1787180544349],[],[442,672],["D",1787180538676],[470,471,472,473,474],[442],"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",[],[448,417],"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",[],[448,651],"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",[],[448,33],"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",[],[448,663],"99f0a5e0-d140-4737-bca8-2eb35879f00a","b996a8ee-9c1a-11f1-a611-1607ee4eb77e",31,["D",1787177402097],[],[448,672],["D",1787177391642],[464,465,466,467,468],[448],["D",1787156870791],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":872,"_873":874,"_875":876,"_877":25,"_878":25,"_879":25,"_880":59,"_881":-5,"_882":-7,"_883":-7,"_884":63,"_885":25,"_886":25,"_887":-5,"_888":25,"_889":25,"_890":25,"_891":-5},"ENV",{"_843":844,"_845":846,"_847":87,"_848":849,"_850":851,"_852":853,"_854":855,"_856":857,"_858":859,"_860":861,"_862":863,"_864":865,"_866":867,"_868":869,"_870":871},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v118