[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","rezar","name","universal-dubber-rebuild-source","path","source/live-service.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/rezar/universal-dubber-rebuild-source/code/source/live-service.ts","extension","id","7dfe65fe-e0b5-4891-ba5f-58a6b2c4d5ab","live-service.ts","fileId","18596d90-a160-11f1-9df6-1607ee4eb77e","parentId","f93768a0-a15e-11f1-a662-1607ee4eb77e","branchId","ca61a1bb-1dc0-482d-9003-97052432673a","branchVersion",156,"latest",true,"createdAt",["D",1787784497768],"version",14,"fileType","script","content","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","deleted",false,"label",[47,24],"source","b765f307-b19b-4e98-b8f5-d6685575cc35",["D",1787751663785],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Source package for verified Android rebuild","imageUrl","userId","62d63139-fff1-474c-957e-0de43711ef38","pinnedFileId","c836b9e6-a153-11f1-9541-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fe29f-d21a-769b-b052-ec8f0e83c092","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_58":59,"_103":104,"_105":44},"branch",{"_37":89,"_11":90,"_22":30,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",192,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Reza Rahaeifard","avatar","https://lh3.googleusercontent.com/a/ACg8ocLSq53iQZbkEu7APkCBMoGsId1S_CbUp8pbglW1kMZZ96gL_JYF=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":44,"_147":44,"_148":44,"_149":34,"_150":-5,"_151":-7,"_152":-7,"_153":66,"_154":44,"_155":44,"_156":-5,"_157":44,"_158":44,"_159":44,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]