\";\n }\n\n private void stopYoutubePlayback() {\n if (webView == null) return;\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 (localVideo == null) {\n setStatus(\"ابتدا یک فایل ویدیویی انتخاب کنید.\", true);\n return;\n }\n if (exoPlayer.isPlaying()) exoPlayer.pause(); else exoPlayer.play();\n }\n\n private void seekDelta(long delta) {\n if (youtubeMode || localVideo == null) return;\n long duration = exoPlayer.getDuration();\n long target = Math.max(0, exoPlayer.getCurrentPosition() + delta);\n if (duration > 0) target = Math.min(duration, target);\n exoPlayer.seekTo(target);\n }\n\n private void onDubPressed() {\n if (dubActive || dubStarting) {\n stopDub();\n return;\n }\n String key = apiKeyEdit.getText().toString().trim();\n if (key.isEmpty()) {\n setStatus(\"ابتدا Gemini API Key را وارد کنید.\", true);\n return;\n }\n if (!youtubeMode && localVideo == null) {\n setStatus(\"ابتدا فایل ویدیویی یا YouTube را باز کنید.\", true);\n return;\n }\n if (youtubeMode && !youtubeReady) {\n setStatus(\"پلیر YouTube هنوز آماده نشده است.\", true);\n return;\n }\n dubStarting = true;\n updateDubButton();\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 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 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, apiKeyEdit.getText().toString().trim())\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(100);\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 }\n\n private void stopDubForSourceChange() {\n if (dubActive || dubStarting) stopDub();\n setOriginalVolume(100);\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 registerEvents() {\n IntentFilter f = new IntentFilter(LiveDubService.ACTION_EVENT);\n if (Build.VERSION.SDK_INT >= 33) {\n registerReceiver(dubReceiver, f, Context.RECEIVER_NOT_EXPORTED);\n } else {\n registerReceiver(dubReceiver, f);\n }\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) {\n u = i.getParcelableExtra(Intent.EXTRA_STREAM, Uri.class);\n } else {\n u = i.getParcelableExtra(Intent.EXTRA_STREAM);\n }\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 fullscreen = !fullscreen;\n controlsScroll.setVisibility(fullscreen ? View.GONE : View.VISIBLE);\n View title = root.getChildAt(0);\n if (title != null) title.setVisibility(fullscreen ? View.GONE : View.VISIBLE);\n LinearLayout.LayoutParams lp = (LinearLayout.LayoutParams) playerHost.getLayoutParams();\n lp.height = fullscreen ? 0 : dp(270);\n lp.weight = fullscreen ? 1f : 0f;\n playerHost.setLayoutParams(lp);\n Window w = getWindow();\n if (Build.VERSION.SDK_INT >= 30) {\n WindowInsetsController c = w.getInsetsController();\n if (c != null) {\n if (fullscreen) c.hide(WindowInsets.Type.systemBars()); else c.show(WindowInsets.Type.systemBars());\n }\n } else {\n w.getDecorView().setSystemUiVisibility(fullscreen ? 5894 : View.SYSTEM_UI_FLAG_VISIBLE);\n }\n }\n\n @Override public void onBackPressed() {\n if (fullscreen) {\n toggleFullscreen();\n return;\n }\n super.onBackPressed();\n }\n\n private void updateDubButton() {\n dubButton.setText((dubActive || dubStarting) ? \"توقف دوبله\" : \"شروع دوبله زنده\");\n dubButton.setEnabled(true);\n }\n\n private void setOriginalVolume(int percent) {\n int clamped = Math.max(0, Math.min(100, percent));\n if (youtubeMode) {\n if (webView != null) {\n try { webView.evaluateJavascript(\"setDubVolume(\" + clamped + \");\", null); } catch (Throwable ignored) {}\n }\n } else if (exoPlayer != null) {\n exoPlayer.setVolume(clamped / 100f);\n }\n }\n\n private void setStatus(String value, boolean error) {\n if (statusText == null) return;\n statusText.setText(safe(value));\n statusText.setTextColor(error ? Color.rgb(255, 110, 120) : Color.rgb(180, 220, 205));\n }\n\n private Button button(String label, View.OnClickListener listener) {\n Button b = new Button(this);\n b.setText(label);\n b.setAllCaps(false);\n b.setOnClickListener(listener);\n b.setTextSize(15);\n return b;\n }\n\n private EditText edit(String hint) {\n EditText e = new EditText(this);\n e.setHint(hint);\n e.setTextColor(Color.WHITE);\n e.setHintTextColor(Color.GRAY);\n e.setSingleLine(true);\n return e;\n }\n\n private TextView text(String value, int sp, int color) {\n TextView v = new TextView(this);\n v.setText(value);\n v.setTextSize(sp);\n v.setTextColor(color);\n v.setPadding(dp(3), dp(3), dp(3), dp(3));\n return v;\n }\n\n private LinearLayout.LayoutParams weighted() { return new LinearLayout.LayoutParams(0, dp(52), 1f); }\n private LinearLayout.LayoutParams fullWrap() { return new LinearLayout.LayoutParams(-1, -2); }\n private LinearLayout.LayoutParams top(int top) { LinearLayout.LayoutParams p = fullWrap(); p.topMargin = dp(top); return p; }\n private int dp(int x) { return (int) (x * getResources().getDisplayMetrics().density + .5f); }\n private static String safe(String s) { return s == null ? \"\" : s; }\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 if (root != null) root.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 (apiKeyEdit != null) apiKeyEdit.setText(\"\");\n if (webView != null) {\n try { stopYoutubePlayback(); } catch (Throwable ignored) {}\n try { webView.removeAllViews(); webView.destroy(); } catch (Throwable ignored) {}\n webView = null;\n }\n if (playerView != null) playerView.setPlayer(null);\n if (exoPlayer != null) {\n exoPlayer.release();\n exoPlayer = null;\n }\n super.onDestroy();\n }\n}\n`;\n",[],[229,316],"39dd5aa9-f755-4088-9d4e-94cd874cce56","live-service.ts","18596d90-a160-11f1-9df6-1607ee4eb77e",20,["D",1787756952256],"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 final Handler main = new Handler(Looper.getMainLooper());\n private final Object lock = new Object();\n private final ArrayBlockingQueue outputQueue = new ArrayBlockingQueue<>(64);\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_TRANSLATE_GUIDE;\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_TRANSLATE_GUIDE ? \"\" : \" (حالت سازگار 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 == 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 AudioRecord recorder = tryCreateAudioRecord(DIRECT_INPUT_RATE);\n int rate = DIRECT_INPUT_RATE;\n if (recorder == null) {\n recorder = tryCreateAudioRecord(FALLBACK_INPUT_RATE);\n rate = FALLBACK_INPUT_RATE;\n }\n if (recorder == null) throw new IllegalStateException(\"AudioRecord unsupported at 16/48 kHz\");\n audioRecord = recorder;\n inputSampleRate = rate;\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 int chunkBytes = rate * CHUNK_MS / 1000 * 2;\n captureExecutor = Executors.newSingleThreadExecutor(r -> new Thread(r, \"DubCapture\"));\n captureExecutor.execute(() -> captureLoop(chunkBytes, rate));\n broadcast(\"status\", rate == DIRECT_INPUT_RATE\n ? \"صدای ویدیو با 16 kHz گرفته می‌شود؛ ترجمهٔ صوتی فعال است…\"\n : \"صدای ویدیو با مسیر سازگار 48→16 kHz گرفته می‌شود…\");\n return true;\n } catch (Throwable t) {\n fatal(\"گرفتن صدای ویدیو ناموفق بود: \" + concise(t));\n return false;\n }\n }\n\n private AudioRecord tryCreateAudioRecord(int sampleRate) {\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(AudioFormat.CHANNEL_IN_MONO)\n .build();\n int chunkBytes = sampleRate * CHUNK_MS / 1000 * 2;\n int min = AudioRecord.getMinBufferSize(sampleRate, AudioFormat.CHANNEL_IN_MONO,\n AudioFormat.ENCODING_PCM_16BIT);\n if (min <= 0) return null;\n int buffer = Math.max(chunkBytes * 6, 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 recorder;\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) {\n byte[] buffer = new byte[chunkBytes];\n int silentChunks = 0;\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 even = n & ~1;\n if (even < 2) continue;\n byte[] raw = Arrays.copyOf(buffer, even);\n byte[] pcm16k = rate == DIRECT_INPUT_RATE ? raw : PcmResampler.downsample48kTo16k(raw);\n boolean silent = PcmResampler.isMostlySilent(pcm16k, 18);\n if (silent) {\n silentChunks++;\n } else {\n silentChunks = 0;\n silenceWarningSent = false;\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 = 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 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",[],[229,324],["D",1787756470524],[246,247,248,249],[229],["D",1787751663785],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":53,"_100":101,"_102":24},{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"ctx",{"_77":-5,"_123":371,"_372":373,"_374":375,"_376":24,"_377":24,"_378":24,"_379":57,"_380":-5,"_381":-7,"_382":-7,"_383":61,"_384":24,"_385":24,"_386":-5,"_387":24,"_388":24,"_389":24,"_390":-5},"ENV",{"_342":343,"_344":345,"_346":85,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370},"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 · v38