\";\n }\n\n private void stopYoutubePlayback() {\n try { webView.evaluateJavascript(\"stopVideoNow();\", null); } catch (Throwable ignored) {}\n try { webView.loadUrl(\"about:blank\"); } catch (Throwable ignored) {}\n }\n\n private void togglePlay() {\n if (youtubeMode) {\n setStatus(\"کنترل YouTube روی خود ویدیو قرار دارد.\", false);\n return;\n }\n if (mediaPlayer == null || !localPrepared) {\n setStatus(\"ابتدا یک فایل ویدیویی باز کنید.\", true);\n return;\n }\n try {\n if (mediaPlayer.isPlaying()) mediaPlayer.pause(); else mediaPlayer.start();\n updatePlaybackUi();\n } catch (Throwable t) {\n setStatus(\"کنترل پخش ناموفق بود: \" + concise(t), true);\n }\n }\n\n private void seekDelta(int deltaMs) {\n if (youtubeMode || mediaPlayer == null || !localPrepared) return;\n try {\n int duration = safeDuration();\n int target = Math.max(0, mediaPlayer.getCurrentPosition() + deltaMs);\n if (duration > 0) target = Math.min(duration, target);\n mediaPlayer.seekTo(target);\n } catch (Throwable ignored) {}\n }\n\n private void updatePlaybackUi() {\n if (youtubeMode) {\n if (timeText != null) timeText.setText(\"YouTube\");\n if (playButton != null) playButton.setText(\"کنترل روی ویدیو\");\n return;\n }\n if (mediaPlayer == null || !localPrepared) {\n if (timeText != null) timeText.setText(\"00:00 / --:--\");\n if (playButton != null) playButton.setText(\"پخش\");\n return;\n }\n try {\n int duration = safeDuration();\n int pos = mediaPlayer.getCurrentPosition();\n if (!seeking && duration > 0) seekBar.setProgress((int) Math.min(1000L, pos * 1000L / duration));\n timeText.setText(formatMs(pos) + \" / \" + (duration > 0 ? formatMs(duration) : \"--:--\"));\n playButton.setText(mediaPlayer.isPlaying() ? \"مکث\" : \"پخش\");\n } catch (Throwable ignored) {}\n }\n\n private void onDubPressed() {\n if (dubActive || dubStarting) {\n stopDub();\n return;\n }\n String key = apiKeyEdit.getText() == null ? \"\" : apiKeyEdit.getText().toString().trim();\n if (key.isEmpty()) {\n setStatus(\"ابتدا Gemini API Key را وارد کنید.\", true);\n return;\n }\n if (!youtubeMode && (mediaPlayer == null || !localPrepared)) {\n setStatus(\"ابتدا فایل ویدیویی یا YouTube را باز کنید.\", true);\n return;\n }\n if (youtubeMode && !youtubeReady) {\n setStatus(\"پلیر YouTube هنوز آماده نشده است.\", true);\n return;\n }\n if (!youtubeMode) {\n try { if (!mediaPlayer.isPlaying()) mediaPlayer.start(); } catch (Throwable ignored) {}\n }\n prefs.edit().putString(\"gemini_api_key\", key).apply();\n dubStarting = true;\n updateDubButton();\n inputTranscript.setText(\"متن ورودی: —\");\n outputTranscript.setText(\"ترجمه: —\");\n if (checkSelfPermission(Manifest.permission.RECORD_AUDIO) != PackageManager.PERMISSION_GRANTED) {\n requestPermissions(new String[]{Manifest.permission.RECORD_AUDIO}, REQ_RECORD_AUDIO);\n } else {\n requestProjection();\n }\n }\n\n private void requestProjection() {\n setStatus(\"اجازه Android برای گرفتن صدای همین ویدیو را تأیید کنید…\", false);\n MediaProjectionManager m = (MediaProjectionManager) getSystemService(MEDIA_PROJECTION_SERVICE);\n startActivityForResult(m.createScreenCaptureIntent(), REQ_PROJECTION);\n }\n\n private void startDub(int resultCode, Intent resultData) {\n Language language = (Language) languageSpinner.getSelectedItem();\n String key = apiKeyEdit.getText() == null ? \"\" : apiKeyEdit.getText().toString().trim();\n Intent service = new Intent(this, LiveDubService.class)\n .setAction(LiveDubService.ACTION_START)\n .putExtra(LiveDubService.EXTRA_RESULT_CODE, resultCode)\n .putExtra(LiveDubService.EXTRA_RESULT_DATA, resultData)\n .putExtra(LiveDubService.EXTRA_API_KEY, key)\n .putExtra(LiveDubService.EXTRA_LANGUAGE, language == null ? \"fa\" : language.code);\n if (Build.VERSION.SDK_INT >= 26) startForegroundService(service); else startService(service);\n setStatus(\"در حال اتصال به Gemini Live Translate…\", false);\n }\n\n private void stopDub() {\n setOriginalVolume(1f);\n Intent service = new Intent(this, LiveDubService.class).setAction(LiveDubService.ACTION_STOP);\n try { startService(service); } catch (Throwable ignored) { stopService(new Intent(this, LiveDubService.class)); }\n dubStarting = false;\n dubActive = false;\n updateDubButton();\n setStatus(\"دوبله متوقف شد؛ ویدیو ادامه دارد.\", false);\n }\n\n private void stopDubForSourceChange() {\n if (dubActive || dubStarting) stopDub();\n setOriginalVolume(1f);\n }\n\n @Override protected void onActivityResult(int requestCode, int resultCode, Intent data) {\n super.onActivityResult(requestCode, resultCode, data);\n if (requestCode == REQ_OPEN_VIDEO && resultCode == RESULT_OK && data != null) {\n loadLocal(data.getData());\n } else if (requestCode == REQ_PROJECTION) {\n if (resultCode == RESULT_OK && data != null) {\n startDub(resultCode, data);\n } else {\n dubStarting = false;\n updateDubButton();\n setStatus(\"اجازه گرفتن صدای پخش داده نشد.\", true);\n }\n }\n }\n\n @Override public void onRequestPermissionsResult(int requestCode, String[] permissions, int[] results) {\n super.onRequestPermissionsResult(requestCode, permissions, results);\n if (requestCode == REQ_RECORD_AUDIO) {\n if (results.length > 0 && results[0] == PackageManager.PERMISSION_GRANTED) {\n requestProjection();\n } else {\n dubStarting = false;\n updateDubButton();\n setStatus(\"مجوز RECORD_AUDIO برای دوبله زنده لازم است.\", true);\n }\n }\n }\n\n private void registerDubEvents() {\n IntentFilter f = new IntentFilter(LiveDubService.ACTION_EVENT);\n if (Build.VERSION.SDK_INT >= 33) registerReceiver(dubReceiver, f, Context.RECEIVER_NOT_EXPORTED);\n else registerReceiver(dubReceiver, f);\n receiverRegistered = true;\n }\n\n @Override protected void onNewIntent(Intent intent) {\n super.onNewIntent(intent);\n setIntent(intent);\n consumeIncomingIntent(intent);\n }\n\n private void consumeIncomingIntent(Intent i) {\n if (i == null) return;\n if (Intent.ACTION_VIEW.equals(i.getAction()) && i.getData() != null) {\n loadLocal(i.getData());\n return;\n }\n if (!Intent.ACTION_SEND.equals(i.getAction())) return;\n String type = i.getType();\n if (type != null && type.startsWith(\"video/\")) {\n Uri u;\n if (Build.VERSION.SDK_INT >= 33) u = i.getParcelableExtra(Intent.EXTRA_STREAM, Uri.class);\n else u = i.getParcelableExtra(Intent.EXTRA_STREAM);\n if (u != null) loadLocal(u);\n } else {\n String t = i.getStringExtra(Intent.EXTRA_TEXT);\n if (t != null) {\n youtubeEdit.setText(t);\n openYoutube();\n }\n }\n }\n\n private void toggleFullscreen() {\n if (fullscreen) exitFullscreen(); else enterFullscreen();\n }\n\n private void enterFullscreen() {\n fullscreen = true;\n setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_SENSOR_LANDSCAPE);\n header.setVisibility(View.GONE);\n controlsScroll.setVisibility(View.GONE);\n root.setPadding(0, 0, 0, 0);\n LinearLayout.LayoutParams lp = (LinearLayout.LayoutParams) playerCard.getLayoutParams();\n lp.width = ViewGroup.LayoutParams.MATCH_PARENT;\n lp.height = 0;\n lp.weight = 1f;\n playerCard.setLayoutParams(lp);\n playerCard.setBackgroundColor(Color.BLACK);\n fullscreenButton.setText(\"✕\");\n hideSystemBars();\n playerHost.postDelayed(() -> updateTextureScale(playerHost.getWidth(), playerHost.getHeight()), 200);\n }\n\n private void exitFullscreen() {\n fullscreen = false;\n setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_SENSOR_PORTRAIT);\n header.setVisibility(View.VISIBLE);\n controlsScroll.setVisibility(View.VISIBLE);\n root.setPadding(dp(12), dp(8), dp(12), dp(8));\n LinearLayout.LayoutParams lp = (LinearLayout.LayoutParams) playerCard.getLayoutParams();\n lp.width = ViewGroup.LayoutParams.MATCH_PARENT;\n lp.height = dp(260);\n lp.weight = 0f;\n playerCard.setLayoutParams(lp);\n playerCard.setBackground(round(Color.BLACK, 18, BORDER, 1));\n fullscreenButton.setText(\"⛶\");\n showSystemBars();\n playerHost.postDelayed(() -> updateTextureScale(playerHost.getWidth(), playerHost.getHeight()), 200);\n }\n\n @Override public void onConfigurationChanged(Configuration newConfig) {\n super.onConfigurationChanged(newConfig);\n if (fullscreen) {\n header.setVisibility(View.GONE);\n controlsScroll.setVisibility(View.GONE);\n hideSystemBars();\n }\n playerHost.postDelayed(() -> updateTextureScale(playerHost.getWidth(), playerHost.getHeight()), 120);\n }\n\n private void hideSystemBars() {\n Window w = getWindow();\n if (Build.VERSION.SDK_INT >= 30) {\n WindowInsetsController c = w.getInsetsController();\n if (c != null) {\n c.hide(WindowInsets.Type.systemBars());\n c.setSystemBarsBehavior(WindowInsetsController.BEHAVIOR_SHOW_TRANSIENT_BARS_BY_SWIPE);\n }\n } else {\n w.getDecorView().setSystemUiVisibility(\n View.SYSTEM_UI_FLAG_IMMERSIVE_STICKY |\n View.SYSTEM_UI_FLAG_FULLSCREEN |\n View.SYSTEM_UI_FLAG_HIDE_NAVIGATION |\n View.SYSTEM_UI_FLAG_LAYOUT_FULLSCREEN |\n View.SYSTEM_UI_FLAG_LAYOUT_HIDE_NAVIGATION |\n View.SYSTEM_UI_FLAG_LAYOUT_STABLE);\n }\n }\n\n private void showSystemBars() {\n Window w = getWindow();\n if (Build.VERSION.SDK_INT >= 30) {\n WindowInsetsController c = w.getInsetsController();\n if (c != null) c.show(WindowInsets.Type.systemBars());\n } else {\n w.getDecorView().setSystemUiVisibility(View.SYSTEM_UI_FLAG_VISIBLE);\n }\n }\n\n @Override public void onBackPressed() {\n if (fullscreen) {\n exitFullscreen();\n return;\n }\n super.onBackPressed();\n }\n\n private void updateDubButton() {\n if (dubStarting) {\n dubButton.setText(\"در حال فعال‌سازی دوبله…\");\n dubButton.setBackground(round(PRIMARY_DARK, 15, PRIMARY_DARK, 0));\n } else if (dubActive) {\n dubButton.setText(\"توقف دوبله\");\n dubButton.setBackground(round(Color.rgb(210, 61, 84), 15, Color.rgb(210, 61, 84), 0));\n } else {\n dubButton.setText(\"شروع دوبله زنده\");\n dubButton.setBackground(round(PRIMARY, 15, PRIMARY, 0));\n }\n dubButton.setEnabled(true);\n }\n\n private void setOriginalVolume(float volume) {\n float clamped = Math.max(0f, Math.min(1f, volume));\n if (youtubeMode) {\n int percent = Math.round(clamped * 100f);\n try { webView.evaluateJavascript(\"setDubVolume(\" + percent + \");\", null); } catch (Throwable ignored) {}\n } else if (mediaPlayer != null) {\n try { mediaPlayer.setVolume(clamped, clamped); } catch (Throwable ignored) {}\n }\n }\n\n private void updateTextureScale(int viewWidth, int viewHeight) {\n if (viewWidth <= 0 || viewHeight <= 0 || videoWidth <= 0 || videoHeight <= 0) return;\n float viewAspect = viewWidth / (float) viewHeight;\n float videoAspect = videoWidth / (float) videoHeight;\n textureView.setPivotX(viewWidth / 2f);\n textureView.setPivotY(viewHeight / 2f);\n if (videoAspect > viewAspect) {\n textureView.setScaleX(1f);\n textureView.setScaleY(viewAspect / videoAspect);\n } else {\n textureView.setScaleX(videoAspect / viewAspect);\n textureView.setScaleY(1f);\n }\n }\n\n private void setStatus(String value, boolean error) {\n statusText.setText(safe(value));\n statusText.setTextColor(error ? ERROR : TEAL);\n }\n\n private LinearLayout card() {\n LinearLayout c = new LinearLayout(this);\n c.setOrientation(LinearLayout.VERTICAL);\n c.setLayoutDirection(View.LAYOUT_DIRECTION_RTL);\n c.setPadding(dp(14), dp(12), dp(14), dp(12));\n c.setBackground(round(SURFACE, 18, BORDER, 1));\n return c;\n }\n\n private LinearLayout row() {\n LinearLayout r = new LinearLayout(this);\n r.setOrientation(LinearLayout.HORIZONTAL);\n r.setGravity(Gravity.CENTER_VERTICAL);\n return r;\n }\n\n private Button button(String value, boolean primary, View.OnClickListener listener) {\n Button b = new Button(this);\n b.setText(value);\n b.setAllCaps(false);\n b.setTextSize(15);\n b.setTextColor(TEXT);\n b.setGravity(Gravity.CENTER);\n b.setMinHeight(0);\n b.setMinWidth(0);\n b.setPadding(dp(10), 0, dp(10), 0);\n b.setBackground(round(primary ? PRIMARY : SURFACE_2, 14, primary ? PRIMARY : BORDER, primary ? 0 : 1));\n b.setOnClickListener(listener);\n return b;\n }\n\n private EditText edit(String hint, boolean password) {\n EditText e = new EditText(this);\n e.setHint(hint);\n e.setTextSize(15);\n e.setTextColor(TEXT);\n e.setHintTextColor(MUTED);\n e.setSingleLine(true);\n e.setTextDirection(View.TEXT_DIRECTION_LTR);\n e.setPadding(dp(14), 0, dp(14), 0);\n e.setBackground(round(SURFACE_2, 14, BORDER, 1));\n e.setMinimumHeight(dp(54));\n if (password) e.setInputType(InputType.TYPE_CLASS_TEXT | InputType.TYPE_TEXT_VARIATION_PASSWORD);\n return e;\n }\n\n private TextView text(String value, int sp, int color, boolean bold) {\n TextView v = new TextView(this);\n v.setText(value);\n v.setTextSize(sp);\n v.setTextColor(color);\n v.setGravity(Gravity.START | Gravity.CENTER_VERTICAL);\n v.setLineSpacing(0, 1.08f);\n if (bold) v.setTypeface(Typeface.DEFAULT, Typeface.BOLD);\n return v;\n }\n\n private GradientDrawable round(int color, int radiusDp, int strokeColor, int strokeDp) {\n GradientDrawable g = new GradientDrawable();\n g.setColor(color);\n g.setCornerRadius(dp(radiusDp));\n if (strokeDp > 0) g.setStroke(dp(strokeDp), strokeColor);\n return g;\n }\n\n private View space(int size) {\n View v = new View(this);\n v.setMinimumWidth(size);\n return v;\n }\n\n private LinearLayout.LayoutParams wrap() { return new LinearLayout.LayoutParams(-1, -2); }\n private LinearLayout.LayoutParams full() { return new LinearLayout.LayoutParams(-1, -2); }\n private LinearLayout.LayoutParams weighted(int height) { return new LinearLayout.LayoutParams(0, height, 1f); }\n private LinearLayout.LayoutParams top(int top) { LinearLayout.LayoutParams p = new LinearLayout.LayoutParams(-1, -2); p.topMargin = dp(top); return p; }\n private int dp(int x) { return (int) (x * getResources().getDisplayMetrics().density + .5f); }\n\n private int safeDuration() {\n try { return mediaPlayer == null ? 0 : Math.max(0, mediaPlayer.getDuration()); }\n catch (Throwable ignored) { return 0; }\n }\n\n private void releaseMediaPlayer() {\n localPrepared = false;\n MediaPlayer p = mediaPlayer;\n mediaPlayer = null;\n if (p != null) {\n try { p.setSurface(null); } catch (Throwable ignored) {}\n try { p.stop(); } catch (Throwable ignored) {}\n try { p.reset(); } catch (Throwable ignored) {}\n try { p.release(); } catch (Throwable ignored) {}\n }\n }\n\n private void releaseSurface() {\n Surface s = mediaSurface;\n mediaSurface = null;\n if (s != null) try { s.release(); } catch (Throwable ignored) {}\n }\n\n private static String safe(String s) { return s == null ? \"\" : s; }\n private static String concise(Throwable t) {\n if (t == null) return \"unknown\";\n String m = t.getMessage();\n return m == null || m.trim().isEmpty() ? t.getClass().getSimpleName() : m.trim();\n }\n\n private static String formatMs(long ms) {\n long total = Math.max(0, ms / 1000);\n long hours = total / 3600;\n long minutes = (total % 3600) / 60;\n long seconds = total % 60;\n return hours > 0\n ? String.format(Locale.US, \"%d:%02d:%02d\", hours, minutes, seconds)\n : String.format(Locale.US, \"%02d:%02d\", minutes, seconds);\n }\n\n @Override protected void onDestroy() {\n handler.removeCallbacks(progressTick);\n if (receiverRegistered) {\n try { unregisterReceiver(dubReceiver); } catch (Throwable ignored) {}\n }\n if (dubActive || dubStarting) {\n try { stopService(new Intent(this, LiveDubService.class)); } catch (Throwable ignored) {}\n }\n if (webView != null) {\n try { stopYoutubePlayback(); } catch (Throwable ignored) {}\n try { webView.removeAllViews(); webView.destroy(); } catch (Throwable ignored) {}\n }\n releaseMediaPlayer();\n releaseSurface();\n super.onDestroy();\n }\n}\n`;\n",[],[371,527],"7dfe65fe-e0b5-4891-ba5f-58a6b2c4d5ab","live-service.ts","18596d90-a160-11f1-9df6-1607ee4eb77e",156,["D",1787784497768],14,"export const LIVE_SERVICE = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport android.app.Notification;\nimport android.app.NotificationChannel;\nimport android.app.NotificationManager;\nimport android.app.Service;\nimport android.content.Context;\nimport android.content.Intent;\nimport android.content.pm.ServiceInfo;\nimport android.media.AudioAttributes;\nimport android.media.AudioFormat;\nimport android.media.AudioPlaybackCaptureConfiguration;\nimport android.media.AudioRecord;\nimport android.media.AudioTrack;\nimport android.media.projection.MediaProjection;\nimport android.media.projection.MediaProjectionManager;\nimport android.os.Build;\nimport android.os.Handler;\nimport android.os.IBinder;\nimport android.os.Looper;\n\nimport java.net.URLEncoder;\nimport java.util.Arrays;\nimport java.util.List;\nimport java.util.concurrent.ArrayBlockingQueue;\nimport java.util.concurrent.ExecutorService;\nimport java.util.concurrent.Executors;\nimport java.util.concurrent.TimeUnit;\n\nimport okhttp3.OkHttpClient;\nimport okhttp3.Request;\nimport okhttp3.Response;\nimport okhttp3.WebSocket;\nimport okhttp3.WebSocketListener;\n\npublic final class LiveDubService extends Service {\n public static final String ACTION_START = \"com.openai.universaldubber.rebuilt.START_DUB\";\n public static final String ACTION_STOP = \"com.openai.universaldubber.rebuilt.STOP_DUB\";\n public static final String ACTION_EVENT = \"com.openai.universaldubber.rebuilt.DUB_EVENT\";\n\n public static final String EXTRA_RESULT_CODE = \"result_code\";\n public static final String EXTRA_RESULT_DATA = \"result_data\";\n public static final String EXTRA_API_KEY = \"api_key\";\n public static final String EXTRA_LANGUAGE = \"language\";\n public static final String EXTRA_KIND = \"kind\";\n public static final String EXTRA_TEXT = \"text\";\n\n private static final String CHANNEL_ID = \"universal_dubber_live\";\n private static final int NOTIFICATION_ID = 4107;\n private static final int DIRECT_INPUT_RATE = 16_000;\n private static final int FALLBACK_INPUT_RATE = 48_000;\n private static final int OUTPUT_RATE = 24_000;\n private static final int CHUNK_MS = 100;\n private static final int MAX_RECONNECTS = 3;\n private static final long MAX_SOCKET_QUEUE_BYTES = 1_048_576L;\n private static final String WS_BASE = \"wss://generativelanguage.googleapis.com/ws/\" +\n \"google.ai.generativelanguage.v1beta.GenerativeService.BidiGenerateContent?key=\";\n\n private static final class CaptureSource {\n final AudioRecord record;\n final int sampleRate;\n final int channels;\n CaptureSource(AudioRecord record, int sampleRate, int channels) {\n this.record = record;\n this.sampleRate = sampleRate;\n this.channels = channels;\n }\n }\n\n private final Handler main = new Handler(Looper.getMainLooper());\n private final Object lock = new Object();\n private final ArrayBlockingQueue outputQueue = new ArrayBlockingQueue<>(24);\n\n private OkHttpClient httpClient;\n private volatile WebSocket webSocket;\n private MediaProjection mediaProjection;\n private MediaProjection.Callback projectionCallback;\n private volatile AudioRecord audioRecord;\n private volatile AudioTrack audioTrack;\n private ExecutorService captureExecutor;\n private ExecutorService playbackExecutor;\n\n private String apiKey = \"\";\n private String targetLanguage = \"fa\";\n private volatile boolean running;\n private volatile boolean setupReady;\n private volatile boolean terminating;\n private volatile boolean silenceWarningSent;\n private volatile boolean backpressureWarningSent;\n private volatile boolean outputDropWarningSent;\n private volatile int inputSampleRate = DIRECT_INPUT_RATE;\n private int socketGeneration;\n private int setupVariant;\n private int reconnectAttempts;\n\n @Override public void onCreate() {\n super.onCreate();\n createNotificationChannel();\n httpClient = new OkHttpClient.Builder()\n .connectTimeout(20, TimeUnit.SECONDS)\n .readTimeout(0, TimeUnit.MILLISECONDS)\n .writeTimeout(20, TimeUnit.SECONDS)\n .pingInterval(20, TimeUnit.SECONDS)\n .retryOnConnectionFailure(true)\n .build();\n }\n\n @Override public int onStartCommand(Intent intent, int flags, int startId) {\n if (intent == null) return START_NOT_STICKY;\n String action = intent.getAction();\n if (ACTION_STOP.equals(action)) {\n stopSession(\"دوبله متوقف شد.\", true);\n return START_NOT_STICKY;\n }\n if (!ACTION_START.equals(action)) return START_NOT_STICKY;\n\n startProjectionForeground();\n stopSession(null, false);\n terminating = false;\n\n apiKey = value(intent.getStringExtra(EXTRA_API_KEY));\n targetLanguage = GeminiWire.safeLanguageCode(intent.getStringExtra(EXTRA_LANGUAGE));\n int resultCode = intent.getIntExtra(EXTRA_RESULT_CODE, 0);\n Intent resultData = getProjectionIntent(intent);\n\n if (apiKey.isEmpty() || resultCode == 0 || resultData == null) {\n fatal(\"اطلاعات شروع دوبله ناقص است. دوباره اجازه ضبط صدای صفحه را بدهید.\");\n return START_NOT_STICKY;\n }\n\n running = true;\n try {\n MediaProjectionManager manager = (MediaProjectionManager) getSystemService(Context.MEDIA_PROJECTION_SERVICE);\n mediaProjection = manager.getMediaProjection(resultCode, resultData);\n if (mediaProjection == null) throw new IllegalStateException(\"MediaProjection is null\");\n projectionCallback = new MediaProjection.Callback() {\n @Override public void onStop() {\n if (running) fatal(\"Android دسترسی ضبط صدای پخش را متوقف کرد.\");\n }\n };\n mediaProjection.registerCallback(projectionCallback, main);\n } catch (Throwable t) {\n fatal(\"شروع AudioPlaybackCapture ناموفق بود: \" + concise(t));\n return START_NOT_STICKY;\n }\n\n setupReady = false;\n setupVariant = GeminiWire.VARIANT_SIBLING_TRANSCRIPTS;\n reconnectAttempts = 0;\n silenceWarningSent = false;\n backpressureWarningSent = false;\n outputDropWarningSent = false;\n broadcast(\"status\", \"در حال اتصال امن به Gemini Live Translate…\");\n connectWebSocket(setupVariant);\n return START_NOT_STICKY;\n }\n\n private void connectWebSocket(int variant) {\n if (!running || terminating) return;\n final int generation;\n synchronized (lock) {\n generation = ++socketGeneration;\n setupReady = false;\n setupVariant = variant;\n }\n final String url;\n try {\n url = WS_BASE + URLEncoder.encode(apiKey, \"UTF-8\");\n } catch (Exception e) {\n fatal(\"کلید Gemini معتبر نیست.\");\n return;\n }\n Request request = new Request.Builder().url(url).build();\n httpClient.newWebSocket(request, new WebSocketListener() {\n @Override public void onOpen(WebSocket socket, Response response) {\n if (!isCurrent(generation)) {\n socket.cancel();\n return;\n }\n webSocket = socket;\n boolean ok = socket.send(GeminiWire.setupMessage(targetLanguage, variant));\n if (!ok) scheduleReconnect(generation, \"ارسال تنظیمات اولیه انجام نشد.\");\n }\n\n @Override public void onMessage(WebSocket socket, String text) {\n if (!isCurrent(generation)) return;\n String serverError = GeminiProtocol.errorMessage(text);\n if (serverError != null) {\n if (GeminiWire.looksLikeSetupSchemaError(serverError) && variant + 1 < GeminiWire.VARIANT_COUNT) {\n retryNextSetupVariant(generation, socket, variant + 1);\n } else if (GeminiWire.looksLikeAuthError(serverError)) {\n fatal(\"کلید Gemini رد شد: \" + serverError);\n } else if (GeminiWire.looksLikeQuotaError(serverError)) {\n fatal(\"سهمیه/محدودیت Gemini اجازه دوبله نمی‌دهد: \" + serverError);\n } else if (GeminiWire.looksLikeModelAccessError(serverError)) {\n fatal(\"مدل Live Translate برای این کلید/حساب در دسترس نیست: \" + serverError);\n } else {\n fatal(\"Gemini: \" + serverError);\n }\n return;\n }\n\n if (GeminiProtocol.isSetupComplete(text) && !setupReady) {\n setupReady = true;\n reconnectAttempts = 0;\n if (startAudioPipeline()) {\n String suffix = variant == GeminiWire.VARIANT_SIBLING_TRANSCRIPTS ? \"\" : \" (حالت سازگار API)\";\n broadcast(\"active\", \"دوبله زنده فعال شد ✓\" + suffix);\n }\n return;\n }\n\n String input = GeminiProtocol.inputTranscript(text);\n if (input != null) broadcast(\"input\", input);\n String output = GeminiProtocol.outputTranscript(text);\n if (output != null) broadcast(\"output\", output);\n\n List chunks = GeminiProtocol.extractOutputAudio(text);\n for (byte[] chunk : chunks) enqueueOutput(chunk);\n }\n\n @Override public void onClosed(WebSocket socket, int code, String reason) {\n if (!isCurrent(generation) || !running || terminating) return;\n String detail = reason == null ? \"\" : reason;\n if (GeminiWire.looksLikeSetupSchemaError(detail) && variant + 1 < GeminiWire.VARIANT_COUNT) {\n retryNextSetupVariant(generation, socket, variant + 1);\n } else {\n scheduleReconnect(generation, \"اتصال بسته شد (\" + code + \"): \" + detail);\n }\n }\n\n @Override public void onFailure(WebSocket socket, Throwable t, Response response) {\n if (!isCurrent(generation) || !running || terminating) return;\n int code = response == null ? -1 : response.code();\n String detail = concise(t);\n if (code == 400 && variant + 1 < GeminiWire.VARIANT_COUNT) {\n retryNextSetupVariant(generation, socket, variant + 1);\n } else if (code == 401 || code == 403) {\n fatal(\"کلید Gemini مجاز نیست (HTTP \" + code + \").\");\n } else if (code == 429) {\n fatal(\"محدودیت سهمیه Gemini (HTTP 429). کمی بعد دوباره امتحان کنید.\");\n } else if (code == 404) {\n fatal(\"مدل Gemini Live Translate برای این حساب پیدا نشد.\");\n } else {\n scheduleReconnect(generation, \"خطای شبکه Gemini: \" + detail);\n }\n }\n });\n }\n\n private void retryNextSetupVariant(int generation, WebSocket socket, int nextVariant) {\n if (!isCurrent(generation) || !running || terminating) return;\n broadcast(\"status\", \"قالب تنظیمات این سرور متفاوت است؛ اتصال با حالت سازگار دوباره برقرار می‌شود…\");\n stopAudioPipeline();\n invalidateSocket();\n try { socket.close(1000, \"schema compatibility retry\"); } catch (Throwable ignored) { socket.cancel(); }\n main.postDelayed(() -> connectWebSocket(nextVariant), 250);\n }\n\n private void scheduleReconnect(int generation, String reason) {\n main.post(() -> {\n if (!isCurrent(generation) || !running || terminating) return;\n if (reconnectAttempts >= MAX_RECONNECTS) {\n fatal(\"اتصال Gemini پس از چند تلاش برقرار نشد: \" + reason);\n return;\n }\n reconnectAttempts++;\n long delay = Math.min(4000L, 650L << (reconnectAttempts - 1));\n int variant = setupVariant;\n stopAudioPipeline();\n WebSocket old = webSocket;\n webSocket = null;\n invalidateSocket();\n if (old != null) try { old.cancel(); } catch (Throwable ignored) {}\n broadcast(\"status\", \"اتصال قطع شد؛ تلاش مجدد \" + reconnectAttempts + \"/\" + MAX_RECONNECTS + \"…\");\n main.postDelayed(() -> connectWebSocket(variant), delay);\n });\n }\n\n private boolean isCurrent(int generation) {\n synchronized (lock) { return generation == socketGeneration; }\n }\n\n private void invalidateSocket() {\n synchronized (lock) { socketGeneration++; }\n }\n\n private boolean startAudioPipeline() {\n if (!running || mediaProjection == null || audioRecord != null) return audioRecord != null;\n try {\n CaptureSource source = tryCreateAudioRecord(FALLBACK_INPUT_RATE, AudioFormat.CHANNEL_IN_STEREO, 2);\n if (source == null) source = tryCreateAudioRecord(FALLBACK_INPUT_RATE, AudioFormat.CHANNEL_IN_MONO, 1);\n if (source == null) source = tryCreateAudioRecord(DIRECT_INPUT_RATE, AudioFormat.CHANNEL_IN_STEREO, 2);\n if (source == null) source = tryCreateAudioRecord(DIRECT_INPUT_RATE, AudioFormat.CHANNEL_IN_MONO, 1);\n if (source == null) throw new IllegalStateException(\"AudioPlaybackCapture unsupported at 48k/16k stereo or mono\");\n AudioRecord recorder = source.record;\n audioRecord = recorder;\n inputSampleRate = source.sampleRate;\n recorder.startRecording();\n if (recorder.getRecordingState() != AudioRecord.RECORDSTATE_RECORDING) {\n throw new IllegalStateException(\"AudioRecord did not enter recording state\");\n }\n if (!ensureOutputTrack()) return false;\n final int captureRate = source.sampleRate;\n final int captureChannels = source.channels;\n final int chunkBytes = captureRate * CHUNK_MS / 1000 * 2 * captureChannels;\n captureExecutor = Executors.newSingleThreadExecutor(r -> new Thread(r, \"DubCapture\"));\n captureExecutor.execute(() -> captureLoop(chunkBytes, captureRate, captureChannels));\n broadcast(\"status\", captureRate == FALLBACK_INPUT_RATE\n ? (captureChannels == 2 ? \"صدای ویدیو با 48k stereo گرفته و به 16k mono تبدیل می‌شود…\" : \"صدای ویدیو با 48k mono گرفته و به 16k تبدیل می‌شود…\")\n : \"صدای ویدیو مستقیم با 16k mono گرفته می‌شود…\");\n return true;\n } catch (Throwable t) {\n fatal(\"گرفتن صدای ویدیو ناموفق بود: \" + concise(t));\n return false;\n }\n }\n\n private CaptureSource tryCreateAudioRecord(int sampleRate, int channelMask, int channels) {\n AudioRecord recorder = null;\n try {\n AudioPlaybackCaptureConfiguration captureConfig =\n new AudioPlaybackCaptureConfiguration.Builder(mediaProjection)\n .addMatchingUsage(AudioAttributes.USAGE_MEDIA)\n .build();\n AudioFormat format = new AudioFormat.Builder()\n .setEncoding(AudioFormat.ENCODING_PCM_16BIT)\n .setSampleRate(sampleRate)\n .setChannelMask(channelMask)\n .build();\n int chunkBytes = sampleRate * CHUNK_MS / 1000 * 2 * channels;\n int min = AudioRecord.getMinBufferSize(sampleRate, channelMask, AudioFormat.ENCODING_PCM_16BIT);\n if (min <= 0) return null;\n int buffer = Math.max(chunkBytes * 8, min * 2);\n recorder = new AudioRecord.Builder()\n .setAudioFormat(format)\n .setBufferSizeInBytes(buffer)\n .setAudioPlaybackCaptureConfig(captureConfig)\n .build();\n if (recorder.getState() != AudioRecord.STATE_INITIALIZED) {\n recorder.release();\n return null;\n }\n return new CaptureSource(recorder, sampleRate, channels);\n } catch (Throwable ignored) {\n if (recorder != null) try { recorder.release(); } catch (Throwable ignored2) {}\n return null;\n }\n }\n\n private void captureLoop(int chunkBytes, int rate, int channels) {\n byte[] buffer = new byte[chunkBytes];\n int silentChunks = 0;\n boolean firstSpeechReported = false;\n while (running && setupReady && !Thread.currentThread().isInterrupted()) {\n AudioRecord recorder = audioRecord;\n WebSocket socket = webSocket;\n if (recorder == null || socket == null) break;\n int n;\n try {\n n = recorder.read(buffer, 0, buffer.length, AudioRecord.READ_BLOCKING);\n } catch (Throwable t) {\n if (running) fatal(\"خواندن صدای پخش متوقف شد: \" + concise(t));\n break;\n }\n if (n == AudioRecord.ERROR_DEAD_OBJECT || n == AudioRecord.ERROR_INVALID_OPERATION) {\n if (running) fatal(\"AudioPlaybackCapture از دسترس خارج شد (\" + n + \").\");\n break;\n }\n if (n <= 0) continue;\n int frameBytes = 2 * channels;\n int usable = n - (n % frameBytes);\n if (usable < frameBytes) continue;\n byte[] raw = Arrays.copyOf(buffer, usable);\n byte[] pcm16k = PcmResampler.to16kMono(raw, rate, channels);\n if (pcm16k.length == 0) continue;\n boolean silent = PcmResampler.isMostlySilent(pcm16k, 18);\n if (silent) {\n silentChunks++;\n } else {\n silentChunks = 0;\n silenceWarningSent = false;\n if (!firstSpeechReported) {\n firstSpeechReported = true;\n broadcast(\"status\", \"صدای گفتار دریافت شد؛ در حال ترجمه زنده…\");\n }\n }\n if (silentChunks >= 50 && !silenceWarningSent) {\n silenceWarningSent = true;\n broadcast(\"status\", \"هشدار: ۵ ثانیه صدای قابل‌تشخیص Capture نشد؛ ویدیو باید در حال پخش و صدادار باشد.\");\n }\n if (socket.queueSize() > MAX_SOCKET_QUEUE_BYTES) {\n if (!backpressureWarningSent) {\n backpressureWarningSent = true;\n broadcast(\"status\", \"اینترنت کند است؛ برای جلوگیری از تأخیر، چند قطعه صوتی قدیمی حذف می‌شود.\");\n }\n continue;\n }\n backpressureWarningSent = false;\n if (!socket.send(GeminiWire.audioMessage(pcm16k))) {\n scheduleReconnectCurrent(\"صف ارسال صوت بسته شد.\");\n break;\n }\n }\n }\n\n private void scheduleReconnectCurrent(String reason) {\n int generation;\n synchronized (lock) { generation = socketGeneration; }\n scheduleReconnect(generation, reason);\n }\n\n private boolean ensureOutputTrack() {\n if (audioTrack != null && playbackExecutor != null) return true;\n try {\n AudioAttributes attributes = new AudioAttributes.Builder()\n .setUsage(AudioAttributes.USAGE_ASSISTANCE_ACCESSIBILITY)\n .setContentType(AudioAttributes.CONTENT_TYPE_SPEECH)\n .setAllowedCapturePolicy(AudioAttributes.ALLOW_CAPTURE_BY_NONE)\n .build();\n AudioFormat format = new AudioFormat.Builder()\n .setEncoding(AudioFormat.ENCODING_PCM_16BIT)\n .setSampleRate(OUTPUT_RATE)\n .setChannelMask(AudioFormat.CHANNEL_OUT_MONO)\n .build();\n int min = AudioTrack.getMinBufferSize(OUTPUT_RATE, AudioFormat.CHANNEL_OUT_MONO,\n AudioFormat.ENCODING_PCM_16BIT);\n if (min <= 0) throw new IllegalStateException(\"AudioTrack buffer unsupported\");\n AudioTrack track = null;\n try {\n track = new AudioTrack.Builder()\n .setAudioAttributes(attributes)\n .setAudioFormat(format)\n .setTransferMode(AudioTrack.MODE_STREAM)\n .setBufferSizeInBytes(Math.max(min * 2, OUTPUT_RATE))\n .setPerformanceMode(AudioTrack.PERFORMANCE_MODE_LOW_LATENCY)\n .build();\n if (track.getState() != AudioTrack.STATE_INITIALIZED) {\n track.release();\n track = null;\n }\n } catch (Throwable ignored) {\n if (track != null) try { track.release(); } catch (Throwable ignored2) {}\n track = null;\n }\n if (track == null) {\n track = new AudioTrack.Builder()\n .setAudioAttributes(attributes)\n .setAudioFormat(format)\n .setTransferMode(AudioTrack.MODE_STREAM)\n .setBufferSizeInBytes(Math.max(min * 4, OUTPUT_RATE * 2))\n .build();\n }\n if (track.getState() != AudioTrack.STATE_INITIALIZED) {\n track.release();\n throw new IllegalStateException(\"AudioTrack not initialized\");\n }\n track.play();\n audioTrack = track;\n outputQueue.clear();\n playbackExecutor = Executors.newSingleThreadExecutor(r -> new Thread(r, \"DubPlayback\"));\n playbackExecutor.execute(this::playbackLoop);\n return true;\n } catch (Throwable t) {\n fatal(\"راه‌اندازی خروجی صدای دوبله ناموفق بود: \" + concise(t));\n return false;\n }\n }\n\n private void enqueueOutput(byte[] data) {\n if (!running || !setupReady || data == null || data.length == 0) return;\n if (!outputQueue.offer(data)) {\n outputQueue.poll();\n outputQueue.offer(data);\n if (!outputDropWarningSent) {\n outputDropWarningSent = true;\n broadcast(\"status\", \"خروجی صوتی عقب افتاد؛ یک قطعه قدیمی حذف شد تا دوبله همزمان بماند.\");\n }\n } else if (outputQueue.size() < 8) {\n outputDropWarningSent = false;\n }\n }\n\n private void playbackLoop() {\n while (running && setupReady && !Thread.currentThread().isInterrupted()) {\n try {\n byte[] data = outputQueue.poll(500, TimeUnit.MILLISECONDS);\n if (data == null) continue;\n AudioTrack track = audioTrack;\n if (track == null) break;\n int offset = 0;\n while (offset < data.length && running && setupReady) {\n int written = track.write(data, offset, data.length - offset, AudioTrack.WRITE_BLOCKING);\n if (written <= 0) throw new IllegalStateException(\"AudioTrack.write=\" + written);\n offset += written;\n }\n } catch (InterruptedException interrupted) {\n Thread.currentThread().interrupt();\n break;\n } catch (Throwable t) {\n if (running) fatal(\"پخش صدای دوبله شکست خورد: \" + concise(t));\n break;\n }\n }\n }\n\n private void stopAudioPipeline() {\n setupReady = false;\n\n AudioRecord recorder = audioRecord;\n audioRecord = null;\n if (recorder != null) {\n try { recorder.stop(); } catch (Throwable ignored) {}\n try { recorder.release(); } catch (Throwable ignored) {}\n }\n shutdown(captureExecutor);\n captureExecutor = null;\n\n shutdown(playbackExecutor);\n playbackExecutor = null;\n outputQueue.clear();\n AudioTrack track = audioTrack;\n audioTrack = null;\n if (track != null) {\n try { track.pause(); } catch (Throwable ignored) {}\n try { track.flush(); } catch (Throwable ignored) {}\n try { track.release(); } catch (Throwable ignored) {}\n }\n }\n\n private void startProjectionForeground() {\n Notification.Builder builder = Build.VERSION.SDK_INT >= 26\n ? new Notification.Builder(this, CHANNEL_ID)\n : new Notification.Builder(this);\n Notification notification = builder\n .setSmallIcon(R.drawable.ic_notification)\n .setContentTitle(\"Universal Dubber Rebuilt\")\n .setContentText(\"دوبله زنده در حال اجراست\")\n .setOngoing(true)\n .setOnlyAlertOnce(true)\n .build();\n if (Build.VERSION.SDK_INT >= 29) {\n startForeground(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_MEDIA_PROJECTION);\n } else {\n startForeground(NOTIFICATION_ID, notification);\n }\n }\n\n private void createNotificationChannel() {\n if (Build.VERSION.SDK_INT < 26) return;\n NotificationManager nm = getSystemService(NotificationManager.class);\n if (nm == null) return;\n NotificationChannel channel = new NotificationChannel(\n CHANNEL_ID,\n getString(R.string.notification_channel),\n NotificationManager.IMPORTANCE_LOW);\n channel.setDescription(\"وضعیت دوبله زنده و AudioPlaybackCapture\");\n nm.createNotificationChannel(channel);\n }\n\n private void fatal(String message) {\n main.post(() -> {\n if (terminating) return;\n terminating = true;\n broadcast(\"error\", message);\n stopSession(null, true);\n });\n }\n\n private void stopSession(String message, boolean stopService) {\n running = false;\n stopAudioPipeline();\n invalidateSocket();\n\n WebSocket socket = webSocket;\n webSocket = null;\n if (socket != null) {\n try { socket.close(1000, \"stopped\"); } catch (Throwable ignored) { socket.cancel(); }\n }\n\n MediaProjection projection = mediaProjection;\n mediaProjection = null;\n if (projection != null) {\n try {\n if (projectionCallback != null) projection.unregisterCallback(projectionCallback);\n } catch (Throwable ignored) {}\n try { projection.stop(); } catch (Throwable ignored) {}\n }\n projectionCallback = null;\n\n apiKey = \"\";\n reconnectAttempts = 0;\n if (message != null) broadcast(\"stopped\", message);\n if (stopService) {\n try { stopForeground(STOP_FOREGROUND_REMOVE); } catch (Throwable ignored) {}\n stopSelf();\n }\n }\n\n private static void shutdown(ExecutorService executor) {\n if (executor == null) return;\n executor.shutdownNow();\n }\n\n private void broadcast(String kind, String text) {\n Intent event = new Intent(ACTION_EVENT)\n .setPackage(getPackageName())\n .putExtra(EXTRA_KIND, kind)\n .putExtra(EXTRA_TEXT, text == null ? \"\" : text);\n sendBroadcast(event);\n }\n\n private static String concise(Throwable t) {\n if (t == null) return \"unknown\";\n String msg = t.getMessage();\n return (msg == null || msg.trim().isEmpty()) ? t.getClass().getSimpleName() : msg.trim();\n }\n\n private static String value(String s) { return s == null ? \"\" : s.trim(); }\n\n @SuppressWarnings(\"deprecation\")\n private static Intent getProjectionIntent(Intent source) {\n if (Build.VERSION.SDK_INT >= 33) {\n return source.getParcelableExtra(EXTRA_RESULT_DATA, Intent.class);\n }\n return source.getParcelableExtra(EXTRA_RESULT_DATA);\n }\n\n @Override public IBinder onBind(Intent intent) { return null; }\n\n @Override public void onDestroy() {\n stopSession(null, false);\n if (httpClient != null) {\n try { httpClient.dispatcher().executorService().shutdown(); } catch (Throwable ignored) {}\n try { httpClient.connectionPool().evictAll(); } catch (Throwable ignored) {}\n }\n super.onDestroy();\n }\n}\n`;\n",[],[371,536],["D",1787756470524],[388,389,390,391],[371],["D",1787751663785],{"_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":584,"_585":586,"_587":588,"_589":25,"_590":25,"_591":25,"_592":59,"_593":-5,"_594":-7,"_595":-7,"_596":63,"_597":25,"_598":25,"_599":-5,"_600":25,"_601":25,"_602":25,"_603":-5},"ENV",{"_555":556,"_557":558,"_559":87,"_560":561,"_562":563,"_564":565,"_566":567,"_568":569,"_570":571,"_572":573,"_574":575,"_576":577,"_578":579,"_580":581,"_582":583},"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 · v171