[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_316":317,"_318":319},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":59,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",34,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","source-v2-download.ts","latestPath","fileId","838a04b2-a160-11f1-828b-1607ee4eb77e","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst KEY = \"UniversalDubberRebuiltSource-v1.1.zip\";\nconst SHA = \"c609b7a11e3660c50600096d048796b898628610ae1ee222e3ef0c9b6289720a\";\nexport default async function (req: Request): Promise {\n const stored = await blob.get(KEY);\n if (!stored) return new Response(\"source not found\", { status: 404 });\n const headers = new Headers({\n \"Content-Type\": \"application/zip\",\n \"Content-Disposition\": \"attachment; filename=UniversalDubberRebuiltSource-v1.1.zip\",\n \"Cache-Control\": \"no-store\",\n \"X-Source-SHA256\": SHA,\n \"Content-Length\": \"25929\"\n });\n if (req.method === \"HEAD\") return new Response(null, { status: 200, headers });\n return new Response(stored.stream(), { status: 200, headers });\n}\n","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst KEY = \"UniversalDubberRebuiltSource-v1.1.zip\";\nconst SHA = \"c609b7a11e3660c50600096d048796b898628610ae1ee222e3ef0c9b6289720a\";\nexport default async function (req: Request): Promise {\n const stored = await blob.get(KEY);\n if (!stored) return new Response(\"source not found\", { status: 404 });\n const headers = new Headers({\n \"Content-Type\": \"application/zip\",\n \"Content-Disposition\": \"attachment; filename=UniversalDubberRebuiltSource-v1.1.zip\",\n \"Cache-Control\": \"no-store\",\n \"X-Source-SHA256\": SHA,\n \"Content-Length\": \"25942\"\n });\n if (req.method === \"HEAD\") return new Response(null, { status: 200, headers });\n return new Response(stored.stream(), { status: 200, headers });\n}\n","createdAt",["D",1787758668313],"branchVersion","branchId","ca61a1bb-1dc0-482d-9003-97052432673a","id","b765f307-b19b-4e98-b8f5-d6685575cc35","universal-dubber-rebuild-source",["D",1787751663785],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Source package for verified Android rebuild","imageUrl","62d63139-fff1-474c-957e-0de43711ef38","pinnedFileId","c836b9e6-a153-11f1-9541-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fe29f-d21a-769b-b052-ec8f0e83c092","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",192,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rezar","handle","displayName","Reza Rahaeifard","avatar","https://lh3.googleusercontent.com/a/ACg8ocLSq53iQZbkEu7APkCBMoGsId1S_CbUp8pbglW1kMZZ96gL_JYF=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":312,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":313,"_81":314,"_83":315,"_85":25},"tree",[231,236,237,238,239,240,241,242,243,244,245],"files",[231,232,233,234,235,236,237,238,239,240,241,242,243,244,245],"counts",{"_221":63,"_222":204,"_223":63,"_224":225,"_226":227},"contents",[128,129,130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":214,"_32":215,"_30":216,"_142":-5,"_41":42,"_40":217,"_144":59,"_38":218,"_13":63,"_33":219,"_35":-5,"_24":25,"_147":-5,"_27":220},{"_43":207,"_32":208,"_30":209,"_142":-5,"_41":42,"_40":210,"_144":25,"_38":211,"_13":63,"_33":174,"_35":212,"_24":25,"_147":-5,"_27":213},{"_43":199,"_32":200,"_30":201,"_142":-5,"_41":42,"_40":202,"_144":59,"_38":203,"_13":204,"_33":174,"_35":205,"_24":25,"_147":-5,"_27":206},{"_43":191,"_32":192,"_30":193,"_142":-5,"_41":42,"_40":194,"_144":25,"_38":195,"_13":63,"_33":34,"_35":196,"_24":25,"_147":197,"_27":198},{"_43":184,"_32":185,"_30":186,"_142":-5,"_41":42,"_40":187,"_144":59,"_38":188,"_13":63,"_33":174,"_35":189,"_24":25,"_147":-5,"_27":190},{"_43":177,"_32":178,"_30":179,"_142":-5,"_41":42,"_40":180,"_144":59,"_38":181,"_13":63,"_33":174,"_35":182,"_24":25,"_147":-5,"_27":183},{"_43":169,"_32":170,"_30":171,"_142":-5,"_41":42,"_40":172,"_144":59,"_38":173,"_13":63,"_33":174,"_35":175,"_24":25,"_147":-5,"_27":176},{"_43":162,"_32":163,"_30":57,"_142":-5,"_41":42,"_40":164,"_144":59,"_38":165,"_13":166,"_33":34,"_35":167,"_24":25,"_147":-5,"_27":168},{"_43":154,"_32":155,"_30":156,"_142":-5,"_41":42,"_40":157,"_144":25,"_38":158,"_13":159,"_33":34,"_35":160,"_24":25,"_147":-5,"_27":161},{"_43":149,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_144":25,"_38":150,"_13":151,"_33":34,"_35":37,"_24":25,"_147":152,"_27":153},{"_43":139,"_32":140,"_30":141,"_142":-5,"_41":42,"_40":143,"_144":25,"_38":145,"_13":63,"_33":34,"_35":146,"_24":25,"_147":-5,"_27":148},"76886541-4b36-4633-b4a7-12fe7595d219","upload-apk-v11.ts","010c82ea-a164-11f1-b989-1607ee4eb77e","parentId",32,"latest",["D",1787758631138],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport JSZip from \"npm:jszip\";\n\nconst KEY = \"Universal_Dubber_Rebuilt_1_1_RELEASE.apk\";\n\nexport default async function(req: Request): Promise {\n if (req.method !== \"PUT\") return new Response(\"PUT only\", { status: 405 });\n const bytes = new Uint8Array(await req.arrayBuffer());\n if (bytes.length < 100_000 || bytes.length > 30_000_000) return new Response(\"bad size\", { status: 400 });\n if (bytes[0] !== 0x50 || bytes[1] !== 0x4b) return new Response(\"not zip/apk\", { status: 400 });\n try {\n const zip = await JSZip.loadAsync(bytes);\n if (!zip.file(\"AndroidManifest.xml\") || !zip.file(\"classes.dex\")) return new Response(\"not apk\", { status: 400 });\n } catch { return new Response(\"invalid zip\", { status: 400 }); }\n const digest = new Uint8Array(await crypto.subtle.digest(\"SHA-256\", bytes));\n const sha256 = Array.from(digest, b => b.toString(16).padStart(2,\"0\")).join(\"\");\n await blob.set(KEY, new Blob([bytes], { type: \"application/vnd.android.package-archive\" }));\n await blob.set(KEY + \".json\", JSON.stringify({ sha256, size: bytes.length, uploadedAt: new Date().toISOString() }));\n return Response.json({ ok: true, sha256, size: bytes.length });\n}\n","label",[140],"7f0b2bb3-c000-4a38-98f2-d104e119ae5c",["D",1787758668313],2,"universal-dubber-source-11",[28],"b5c6f915-419f-46c5-a96a-303da22acc63","railway-build.ts","fef94600-a154-11f1-b4e6-1607ee4eb77e",30,["D",1787757351539],11,"const SCRIPT = `#!/usr/bin/env bash\nset -euo pipefail\nexport DEBIAN_FRONTEND=noninteractive\nexport HOME=/work/home\nmkdir -p \"$HOME\" /work/src /work/public /work/tools /work/android-sdk/cmdline-tools\napt-get update -y >/dev/null\napt-get install -y --no-install-recommends ca-certificates curl unzip python3 openjdk-17-jdk-headless >/dev/null\napt-get clean\nrm -rf /var/lib/apt/lists/*\n\nSOURCE_URL='https://universal-dubber-source-11.val.run/'\nSOURCE_SHA='cefcc28ae48d72a690287796666f1cc51611f342c1ad8fa8e9d9917c9ac3046d'\ncurl -fL --retry 8 --retry-all-errors --connect-timeout 20 --max-time 240 \"$SOURCE_URL\" -o /work/source.zip\necho \"$SOURCE_SHA /work/source.zip\" | sha256sum -c -\nunzip -q /work/source.zip -d /work/src\nrm -f /work/source.zip\nPROJECT=/work/src\n\n# Source-level regression gates for the defects reported in chat.\ngrep -q \"applicationId 'com.openai.universaldubber.rebuilt'\" \"$PROJECT/app/build.gradle\"\ngrep -q \"versionName '1.1-rebuilt'\" \"$PROJECT/app/build.gradle\"\ngrep -q \"media3-exoplayer:1.11.0\" \"$PROJECT/app/build.gradle\"\ngrep -q \"media3-ui:1.11.0\" \"$PROJECT/app/build.gradle\"\ngrep -q 'new PlayerView(this)' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\"\ngrep -q 'onNewIntent' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\"\ngrep -q 'setDubVolume' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\"\ngrep -q 'VARIANT_COUNT = 3' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/GeminiWire.java\"\ngrep -q 'VARIANT_TOP_LEVEL_TRANSCRIPTS' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/GeminiWire.java\"\ngrep -q '.addMatchingUsage(AudioAttributes.USAGE_MEDIA)' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"\ngrep -q 'ArrayBlockingQueue' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"\ngrep -q 'ALLOW_CAPTURE_BY_NONE' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"\ngrep -q 'DIRECT_INPUT_RATE = 16_000' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"\ngrep -q 'MAX_RECONNECTS = 3' \"$PROJECT/app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"\ngrep -q 'android:allowBackup=\"false\"' \"$PROJECT/app/src/main/AndroidManifest.xml\"\ngrep -q 'android:usesCleartextTraffic=\"false\"' \"$PROJECT/app/src/main/AndroidManifest.xml\"\n! grep -R -q 'Theme.MaterialComponents' \"$PROJECT/app/src/main/res\"\n! grep -R -q 'excludeUid' \"$PROJECT/app/src/main/java\"\n! grep -R -E -q 'AIza[0-9A-Za-z_-]{20,}' \"$PROJECT/app/src\"\n\n# Stable private release signing identity (stored only as Railway secrets).\ntest -n \"\\${UD_KEYSTORE_B64:-}\"\ntest -n \"\\${UD_KEYSTORE_PASSWORD:-}\"\ntest -n \"\\${UD_KEY_ALIAS:-}\"\ntest -n \"\\${UD_KEY_PASSWORD:-}\"\nprintf '%s' \"$UD_KEYSTORE_B64\" | base64 -d > /work/ud-release.jks\nchmod 600 /work/ud-release.jks\nexport UD_KEYSTORE_PATH=/work/ud-release.jks\nkeytool -list -keystore \"$UD_KEYSTORE_PATH\" -storepass \"$UD_KEYSTORE_PASSWORD\" -alias \"$UD_KEY_ALIAS\" >/dev/null\n\ncurl -fL --retry 8 --retry-all-errors 'https://services.gradle.org/distributions/gradle-8.9-bin.zip' -o /work/gradle.zip\nunzip -q /work/gradle.zip -d /work/tools\nrm -f /work/gradle.zip\ncurl -fL --retry 8 --retry-all-errors 'https://dl.google.com/android/repository/commandlinetools-linux-11076708_latest.zip' -o /work/cmd.zip\nunzip -q /work/cmd.zip -d /work/android-sdk/cmdline-tools\nmv /work/android-sdk/cmdline-tools/cmdline-tools /work/android-sdk/cmdline-tools/latest\nrm -f /work/cmd.zip\n\nexport JAVA_HOME=/usr/lib/jvm/java-17-openjdk-amd64\nexport ANDROID_HOME=/work/android-sdk\nexport ANDROID_SDK_ROOT=/work/android-sdk\nexport PATH=\"$JAVA_HOME/bin:/work/tools/gradle-8.9/bin:/work/android-sdk/cmdline-tools/latest/bin:$PATH\"\nexport GRADLE_USER_HOME=/work/gradle-cache\nexport JAVA_OPTS='-Xmx256m -XX:MaxMetaspaceSize=192m -XX:ReservedCodeCacheSize=64m -XX:+UseSerialGC -Dfile.encoding=UTF-8'\nmkdir -p \"$GRADLE_USER_HOME\"\nyes | sdkmanager --licenses >/dev/null || true\nsdkmanager 'platforms;android-35' 'build-tools;35.0.0' 'build-tools;34.0.0' 'platform-tools' >/dev/null\n\ncat > \"$PROJECT/gradle.properties\" <<'EOF'\norg.gradle.jvmargs=-Xmx256m -XX:MaxMetaspaceSize=192m -XX:ReservedCodeCacheSize=64m -XX:+UseSerialGC -Dfile.encoding=UTF-8\norg.gradle.daemon=false\norg.gradle.parallel=false\norg.gradle.workers.max=1\norg.gradle.caching=false\norg.gradle.vfs.watch=false\norg.gradle.daemon.performance.disable-logging=true\nandroid.useAndroidX=true\nandroid.nonTransitiveRClass=true\nandroid.enableJetifier=false\nEOF\n\ncd \"$PROJECT\"\ngradle --no-daemon --max-workers=1 --console=plain :app:testDebugUnitTest :app:assembleRelease 2>&1 | tee /work/public/GRADLE_BUILD.txt\nAPK=\"$PROJECT/app/build/outputs/apk/release/app-release.apk\"\ntest -s \"$APK\"\n\nAAPT=/work/android-sdk/build-tools/35.0.0/aapt\nSIGNER=/work/android-sdk/build-tools/35.0.0/apksigner\nZIPALIGN=/work/android-sdk/build-tools/35.0.0/zipalign\n\"$AAPT\" dump badging \"$APK\" | tee /work/public/APK_BADGING.txt\n\"$SIGNER\" verify --verbose --print-certs \"$APK\" | tee /work/public/APKSIGNER_VERIFY.txt\n\"$ZIPALIGN\" -c -v 4 \"$APK\" > /work/public/ZIPALIGN_VERIFY.txt\nunzip -t \"$APK\" > /work/public/ZIP_VERIFY.txt\n\ngrep -q \"package: name='com.openai.universaldubber.rebuilt'\" /work/public/APK_BADGING.txt\ngrep -q \"versionCode='110'\" /work/public/APK_BADGING.txt\ngrep -q \"versionName='1.1-rebuilt'\" /work/public/APK_BADGING.txt\n! grep -q '^application-debuggable' /work/public/APK_BADGING.txt\ngrep -q 'Verified using v2 scheme (APK Signature Scheme v2): true' /work/public/APKSIGNER_VERIFY.txt\ngrep -q 'Verification successful' /work/public/ZIPALIGN_VERIFY.txt\ngrep -q 'No errors detected in compressed data' /work/public/ZIP_VERIFY.txt\n\nFINAL=/work/public/Universal_Dubber_Rebuilt_1_1_RELEASE.apk\ncp \"$APK\" \"$FINAL\"\nsha256sum \"$FINAL\" | tee /work/public/SHA256SUMS.txt\nstat -c 'APK_SIZE=%s' \"$FINAL\" | tee /work/public/SIZE.txt\n\n# Lint is run as an additional independent gate after the APK is already built.\nLINT_STATUS=PASS\nif ! timeout 240s gradle --no-daemon --max-workers=1 --console=plain :app:lintRelease > /work/public/LINT.txt 2>&1; then\n LINT_STATUS=FAILED_OR_RESOURCE_LIMIT\nfi\n\nprintf 'BUILD=PASS\\nUNIT_TESTS=PASS\\nCOMPILE=PASS\\nRELEASE_APK=PASS\\nAPK_SIGNATURE=PASS\\nZIPALIGN=PASS\\nZIP_INTEGRITY=PASS\\nSOURCE_GATES=PASS\\nSOURCE_SHA256=%s\\nPACKAGE=com.openai.universaldubber.rebuilt\\nVERSION=1.1-rebuilt\\nLINT=%s\\n' \"$SOURCE_SHA\" \"$LINT_STATUS\" | tee /work/public/VERIFICATION.txt\nrm -f /work/ud-release.jks\nexec python3 -m http.server \"\\${PORT:-8080}\" --bind 0.0.0.0 --directory /work/public\n`;\n\nexport default function () {\n return new Response(SCRIPT, { headers: { \"content-type\": \"text/plain; charset=utf-8\", \"cache-control\": \"no-store\" } });\n}\n",[155],"8956b342-5c1e-47ff-9274-15b05b40c5f5","main.ts",7,["D",1787754341554],4,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst PARTS = [\"lean-b64-1\", \"lean-b64-2\", \"lean-b64-3\", \"lean4-1\", \"lean4-2\", \"lean4-3\", \"lean4-4\", \"lean4-5\", \"lean4-6\", \"lean4-7\", \"lean4-8\"];\n\nexport default async function (): Promise {\n try {\n const chunks = await Promise.all(PARTS.map(async (key) => (await blob.get(key)).text()));\n const binary = atob(chunks.join(\"\"));\n const bytes = Uint8Array.from(binary, (ch) => ch.charCodeAt(0));\n return new Response(bytes, {\n status: 200,\n headers: {\n \"Content-Type\": \"application/zip\",\n \"Content-Length\": String(bytes.byteLength),\n \"Content-Disposition\": \"attachment; filename=UniversalDubberRebuiltSource.zip\",\n \"Cache-Control\": \"no-store\",\n \"X-Source-SHA256\": \"824c6e83d1ae63caa6bc2bd5be7875fb5747005c6183812372c8561739f7b53e\"\n }\n });\n } catch (error) {\n return new Response(`source not ready: ${error instanceof Error ? error.message : String(error)}`, { status: 500 });\n }\n}",[163],"3024fe11-f222-46f4-b897-0ee6919e31dc","inspect-source.ts","ffac94cc-a15d-11f1-be40-1607ee4eb77e",15,["D",1787756051839],"script","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport JSZip from \"npm:jszip\";\n\nconst PARTS = [\"lean-b64-1\", \"lean-b64-2\", \"lean-b64-3\", \"lean4-1\", \"lean4-2\", \"lean4-3\", \"lean4-4\", \"lean4-5\", \"lean4-6\", \"lean4-7\", \"lean4-8\"];\nconst chunks = await Promise.all(PARTS.map(async (key) => (await blob.get(key)).text()));\nconst binary = atob(chunks.join(\"\"));\nconst bytes = Uint8Array.from(binary, ch => ch.charCodeAt(0));\nconst zip = await JSZip.loadAsync(bytes);\nconst wanted = Object.keys(zip.files).filter(p => /\\.(java|gradle|xml|properties)$/.test(p) && !zip.files[p].dir).sort();\nfor (const p of wanted) {\n const text = await zip.files[p].async(\"text\");\n console.log(`\\n===== ${p} =====\\n${text}`);\n}\n",[170],"a23b89e9-0aa4-4c7d-b325-1c52c199a7cd","inspect-core.ts","0bae0a08-a15e-11f1-b5c5-1607ee4eb77e",16,["D",1787756071978],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport JSZip from \"npm:jszip\";\nconst PARTS=[\"lean-b64-1\",\"lean-b64-2\",\"lean-b64-3\",\"lean4-1\",\"lean4-2\",\"lean4-3\",\"lean4-4\",\"lean4-5\",\"lean4-6\",\"lean4-7\",\"lean4-8\"];\nconst chunks=await Promise.all(PARTS.map(async k=>(await blob.get(k)).text()));\nconst binary=atob(chunks.join(\"\")); const bytes=Uint8Array.from(binary,c=>c.charCodeAt(0));\nconst zip=await JSZip.loadAsync(bytes);\nfor (const p of [\"app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\",\"app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"]) console.log(`===== ${p} =====\\n${await zip.files[p].async(\"text\")}`);\n",[178],"058492ff-90be-4dd1-b7db-39301935947e","inspect-core-sections.ts","18afb364-a15e-11f1-9b78-1607ee4eb77e",17,["D",1787756093823],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport JSZip from \"npm:jszip\";\nconst PARTS=[\"lean-b64-1\",\"lean-b64-2\",\"lean-b64-3\",\"lean4-1\",\"lean4-2\",\"lean4-3\",\"lean4-4\",\"lean4-5\",\"lean4-6\",\"lean4-7\",\"lean4-8\"];\nconst chunks=await Promise.all(PARTS.map(async k=>(await blob.get(k)).text()));\nconst bytes=Uint8Array.from(atob(chunks.join(\"\")),c=>c.charCodeAt(0));\nconst zip=await JSZip.loadAsync(bytes);\nfor (const p of [\"app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\",\"app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\"]) {\n const lines=(await zip.files[p].async(\"text\")).split(\"\\n\"); console.log(`${p} lines=${lines.length}`);\n for(let s=0;s`${s+i+1}|${x}`).join(\"\\n\"));\n}\n",[185],"3bdc86a8-c969-4ca3-ba27-3cf582f81caa","download-final-apk.ts","35a2d5d8-a15d-11f1-a827-1607ee4eb77e",14,["D",1787755712901],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst KEY = \"Universal_Dubber_Rebuilt_1_0.apk\";\n\nexport default async function (req: Request): Promise {\n const stored = await blob.get(KEY);\n if (!stored) return new Response(\"APK not found\", { status: 404 });\n const headers = new Headers({\n \"Content-Type\": \"application/vnd.android.package-archive\",\n \"Content-Disposition\": \"attachment; filename=Universal_Dubber_Rebuilt_1_0.apk\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n \"X-APK-SHA256\": \"952bb10d00ad56f95512642b42edbbcbf84570d5ffa76579e58a6a5136a3ab99\",\n \"Content-Length\": \"9668481\"\n });\n if (req.method === \"HEAD\") return new Response(null, { status: 200, headers });\n return new Response(stored.stream(), { status: 200, headers });\n}","universal-dubber-rebuilt-10",[192],"5db9fdcb-048e-42f4-b218-7d62d3c97022","cache-final-apk.ts","0981f6e6-a15d-11f1-89de-1607ee4eb77e",13,["D",1787755693723],1,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst APK_URL = \"https://universal-dubber-apk-builder-ubuntu-production.up.railway.app/Universal_Dubber_Rebuilt_1_0.apk\";\nconst EXPECTED_SHA256 = \"952bb10d00ad56f95512642b42edbbcbf84570d5ffa76579e58a6a5136a3ab99\";\n\nfunction hex(bytes: Uint8Array): string {\n return Array.from(bytes, b => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nconst res = await fetch(APK_URL, { cache: \"no-store\" });\nif (!res.ok) throw new Error(`APK fetch failed: ${res.status}`);\nconst bytes = new Uint8Array(await res.arrayBuffer());\nif (bytes.byteLength < 1_000_000) throw new Error(`APK unexpectedly small: ${bytes.byteLength}`);\nconst digest = hex(new Uint8Array(await crypto.subtle.digest(\"SHA-256\", bytes)));\nif (digest !== EXPECTED_SHA256) throw new Error(`SHA-256 mismatch: ${digest}`);\nawait blob.set(\"Universal_Dubber_Rebuilt_1_0.apk\", new Blob([bytes], { type: \"application/vnd.android.package-archive\" }));\nconsole.log(JSON.stringify({ ok: true, size: bytes.byteLength, sha256: digest }));",[200],"e247a4f9-9ef0-44bb-92ba-6b9c0402ee1c","build-source-v2.ts","76d6e780-a160-11f1-8d73-1607ee4eb77e",23,["D",1787757110779],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport JSZip from \"npm:jszip\";\nimport { MAIN_ACTIVITY } from \"./source/main-activity.ts\";\nimport { LIVE_SERVICE } from \"./source/live-service.ts\";\nimport { GEMINI_WIRE, GEMINI_PROTOCOL, PCM_RESAMPLER, YOUTUBE_URL, GEMINI_WIRE_TEST, YOUTUBE_URL_TEST, PCM_RESAMPLER_TEST } from \"./source/other.ts\";\nimport { ROOT_BUILD, SETTINGS, GRADLE_PROPERTIES, APP_BUILD, MANIFEST, COLORS, THEMES, STRINGS, ICON, PROGUARD } from \"./source/project-files.ts\";\n\nconst files: Record = {\n \"build.gradle\": ROOT_BUILD,\n \"settings.gradle\": SETTINGS,\n \"gradle.properties\": GRADLE_PROPERTIES,\n \"app/build.gradle\": APP_BUILD,\n \"app/proguard-rules.pro\": PROGUARD,\n \"app/src/main/AndroidManifest.xml\": MANIFEST,\n \"app/src/main/res/values/colors.xml\": COLORS,\n \"app/src/main/res/values/themes.xml\": THEMES,\n \"app/src/main/res/values/strings.xml\": STRINGS,\n \"app/src/main/res/drawable/ic_notification.xml\": ICON,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/MainActivity.java\": MAIN_ACTIVITY,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/LiveDubService.java\": LIVE_SERVICE,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/GeminiWire.java\": GEMINI_WIRE,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/GeminiProtocol.java\": GEMINI_PROTOCOL,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/PcmResampler.java\": PCM_RESAMPLER,\n \"app/src/main/java/com/openai/universaldubber/rebuilt/YoutubeUrl.java\": YOUTUBE_URL,\n \"app/src/test/java/com/openai/universaldubber/rebuilt/GeminiWireTest.java\": GEMINI_WIRE_TEST,\n \"app/src/test/java/com/openai/universaldubber/rebuilt/YoutubeUrlTest.java\": YOUTUBE_URL_TEST,\n \"app/src/test/java/com/openai/universaldubber/rebuilt/PcmResamplerTest.java\": PCM_RESAMPLER_TEST,\n};\n\nconst zip = new JSZip();\nfor (const [path, content] of Object.entries(files)) zip.file(path, content.replace(/\\r\\n/g, \"\\n\"));\nconst bytes = await zip.generateAsync({ type: \"uint8array\", compression: \"DEFLATE\", compressionOptions: { level: 9 } });\nconst digestBytes = new Uint8Array(await crypto.subtle.digest(\"SHA-256\", bytes));\nconst sha256 = Array.from(digestBytes, b => b.toString(16).padStart(2, \"0\")).join(\"\");\nawait blob.set(\"UniversalDubberRebuiltSource-v1.1.zip\", new Blob([bytes], { type: \"application/zip\" }));\nawait blob.set(\"UniversalDubberRebuiltSource-v1.1.json\", JSON.stringify({ sha256, size: bytes.length, files: Object.keys(files).length, version: \"1.1-rebuilt\" }, null, 2));\nconsole.log(JSON.stringify({ ok: true, sha256, size: bytes.length, files: Object.keys(files).length }));\n",[208],"ef7a216b-58c6-4462-bf7c-51889ca4b8a0","source","f93768a0-a15e-11f1-a662-1607ee4eb77e",18,["D",1787756470524],"directory",[215],"pulls","branches","forks","envVars",{"_228":63,"_230":63},"connections",{"_228":63,"_229":63},"count","unfilledCount","emptyCount",{"_43":214,"_32":215,"_30":216,"_142":-5,"_41":42,"_40":217,"_144":59,"_38":309,"_13":63,"_33":219,"_35":-5,"_24":25,"_147":-5,"_247":310,"_27":311},{"_43":301,"_32":302,"_30":303,"_142":216,"_41":42,"_40":304,"_144":25,"_38":305,"_13":63,"_33":174,"_35":306,"_24":25,"_147":-5,"_247":307,"_27":308},{"_43":293,"_32":294,"_30":295,"_142":216,"_41":42,"_40":296,"_144":25,"_38":297,"_13":204,"_33":174,"_35":298,"_24":25,"_147":-5,"_247":299,"_27":300},{"_43":285,"_32":286,"_30":287,"_142":216,"_41":42,"_40":288,"_144":25,"_38":289,"_13":63,"_33":174,"_35":290,"_24":25,"_147":-5,"_247":291,"_27":292},{"_43":277,"_32":278,"_30":279,"_142":216,"_41":42,"_40":280,"_144":25,"_38":281,"_13":63,"_33":174,"_35":282,"_24":25,"_147":-5,"_247":283,"_27":284},{"_43":207,"_32":208,"_30":209,"_142":-5,"_41":42,"_40":210,"_144":25,"_38":274,"_13":63,"_33":174,"_35":212,"_24":25,"_147":-5,"_247":275,"_27":276},{"_43":199,"_32":200,"_30":201,"_142":-5,"_41":42,"_40":202,"_144":59,"_38":271,"_13":204,"_33":174,"_35":205,"_24":25,"_147":-5,"_247":272,"_27":273},{"_43":191,"_32":192,"_30":193,"_142":-5,"_41":42,"_40":194,"_144":25,"_38":268,"_13":63,"_33":34,"_35":196,"_24":25,"_147":197,"_247":269,"_27":270},{"_43":184,"_32":185,"_30":186,"_142":-5,"_41":42,"_40":187,"_144":59,"_38":265,"_13":63,"_33":174,"_35":189,"_24":25,"_147":-5,"_247":266,"_27":267},{"_43":177,"_32":178,"_30":179,"_142":-5,"_41":42,"_40":180,"_144":59,"_38":262,"_13":63,"_33":174,"_35":182,"_24":25,"_147":-5,"_247":263,"_27":264},{"_43":169,"_32":170,"_30":171,"_142":-5,"_41":42,"_40":172,"_144":59,"_38":259,"_13":63,"_33":174,"_35":175,"_24":25,"_147":-5,"_247":260,"_27":261},{"_43":162,"_32":163,"_30":57,"_142":-5,"_41":42,"_40":164,"_144":59,"_38":256,"_13":166,"_33":34,"_35":167,"_24":25,"_147":-5,"_247":257,"_27":258},{"_43":154,"_32":155,"_30":156,"_142":-5,"_41":42,"_40":157,"_144":25,"_38":253,"_13":159,"_33":34,"_35":160,"_24":25,"_147":-5,"_247":254,"_27":255},{"_43":149,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_144":25,"_38":250,"_13":151,"_33":34,"_35":37,"_24":25,"_147":152,"_247":251,"_27":252},{"_43":139,"_32":140,"_30":141,"_142":-5,"_41":42,"_40":143,"_144":25,"_38":246,"_13":63,"_33":34,"_35":146,"_24":25,"_147":-5,"_247":248,"_27":249},["D",1787758631138],"children",[],[140],["D",1787758668313],[],[28],["D",1787757351539],[],[155],["D",1787754341554],[],[163],["D",1787756051839],[],[170],["D",1787756071978],[],[178],["D",1787756093823],[],[185],["D",1787755712901],[],[192],["D",1787755693723],[],[200],["D",1787757110779],[],[208],"631203ab-8456-42ca-a917-0d9022bafd28","project-files.ts","6a565c2a-a160-11f1-92a1-1607ee4eb77e",22,["D",1787757089787],"export const ROOT_BUILD = String.raw`plugins {\n id 'com.android.application' version '8.7.3' apply false\n}\n`;\n\nexport const SETTINGS = String.raw`pluginManagement {\n repositories {\n google()\n mavenCentral()\n gradlePluginPortal()\n }\n}\ndependencyResolutionManagement {\n repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)\n repositories {\n google()\n mavenCentral()\n }\n}\nrootProject.name = 'UniversalDubberRebuilt'\ninclude ':app'\n`;\n\nexport const GRADLE_PROPERTIES = String.raw`org.gradle.jvmargs=-Xmx768m -Dfile.encoding=UTF-8\norg.gradle.daemon=false\norg.gradle.parallel=false\norg.gradle.workers.max=1\nandroid.useAndroidX=true\nandroid.nonTransitiveRClass=true\n`;\n\nexport const APP_BUILD = String.raw`plugins {\n id 'com.android.application'\n}\n\nandroid {\n namespace 'com.openai.universaldubber.rebuilt'\n compileSdk 35\n\n defaultConfig {\n applicationId 'com.openai.universaldubber.rebuilt'\n minSdk 29\n targetSdk 35\n versionCode 110\n versionName '1.1-rebuilt'\n testInstrumentationRunner 'androidx.test.runner.AndroidJUnitRunner'\n }\n\n signingConfigs {\n release {\n def ks = System.getenv('UD_KEYSTORE_PATH')\n if (ks != null && !ks.isEmpty()) {\n storeFile file(ks)\n storePassword System.getenv('UD_KEYSTORE_PASSWORD')\n keyAlias System.getenv('UD_KEY_ALIAS')\n keyPassword System.getenv('UD_KEY_PASSWORD')\n }\n }\n }\n\n buildTypes {\n debug {\n debuggable true\n }\n release {\n debuggable false\n minifyEnabled false\n signingConfig signingConfigs.release\n proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'\n }\n }\n\n compileOptions {\n sourceCompatibility JavaVersion.VERSION_17\n targetCompatibility JavaVersion.VERSION_17\n }\n\n packaging {\n resources {\n excludes += ['/META-INF/{AL2.0,LGPL2.1}']\n }\n }\n}\n\ndependencies {\n implementation 'androidx.media3:media3-exoplayer:1.11.0'\n implementation 'androidx.media3:media3-ui:1.11.0'\n implementation 'androidx.annotation:annotation:1.9.1'\n implementation 'com.squareup.okhttp3:okhttp:3.14.9'\n testImplementation 'junit:junit:4.13.2'\n}\n`;\n\nexport const MANIFEST = String.raw`\n\n \n \n \n \n \n\n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n \n \n\n`;\n\nexport const COLORS = String.raw`\n #0E1117\n #FFFFFFFF\n #00BFA5\n #FF6B7A\n\n`;\n\nexport const THEMES = String.raw`\n \n\n`;\n\nexport const STRINGS = String.raw`\n Universal Dubber Rebuilt\n Universal Dubber Live\n\n`;\n\nexport const ICON = String.raw`\n \n \n\n`;\n\nexport const PROGUARD = String.raw`# No shrinking in the current release build. Kept for future release hardening.\n`;\n",[],[215,278],"b877c2e4-d3ab-4eb9-a5cb-fa13853a62b6","other.ts","4331cde6-a160-11f1-aeb4-1607ee4eb77e",21,["D",1787757024136],"export const GEMINI_WIRE = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport java.util.Base64;\n\nfinal class GeminiWire {\n static final String MODEL = \"gemini-3.5-live-translate-preview\";\n static final int VARIANT_TRANSLATE_GUIDE = 0;\n static final int VARIANT_TOP_LEVEL_TRANSCRIPTS = 1;\n static final int VARIANT_NO_TRANSCRIPTS = 2;\n static final int VARIANT_COUNT = 3;\n\n private GeminiWire() {}\n\n static String setupMessage(String targetLanguageCode, int variant) {\n String code = safeLanguageCode(targetLanguageCode);\n String generationBase = \"\\\"responseModalities\\\":[\\\"AUDIO\\\"],\" +\n \"\\\"translationConfig\\\":{\" +\n \"\\\"targetLanguageCode\\\":\\\"\" + code + \"\\\",\" +\n \"\\\"echoTargetLanguage\\\":false}\";\n if (variant == VARIANT_TRANSLATE_GUIDE) {\n return \"{\\\"setup\\\":{\" +\n \"\\\"model\\\":\\\"models/\" + MODEL + \"\\\",\" +\n \"\\\"generationConfig\\\":{\" +\n \"\\\"responseModalities\\\":[\\\"AUDIO\\\"],\" +\n \"\\\"inputAudioTranscription\\\":{},\" +\n \"\\\"outputAudioTranscription\\\":{},\" +\n \"\\\"translationConfig\\\":{\" +\n \"\\\"targetLanguageCode\\\":\\\"\" + code + \"\\\",\" +\n \"\\\"echoTargetLanguage\\\":false}\" +\n \"}}}\";\n }\n if (variant == VARIANT_TOP_LEVEL_TRANSCRIPTS) {\n return \"{\\\"setup\\\":{\" +\n \"\\\"model\\\":\\\"models/\" + MODEL + \"\\\",\" +\n \"\\\"generationConfig\\\":{\" + generationBase + \"},\" +\n \"\\\"inputAudioTranscription\\\":{},\" +\n \"\\\"outputAudioTranscription\\\":{}\" +\n \"}}\";\n }\n return \"{\\\"setup\\\":{\" +\n \"\\\"model\\\":\\\"models/\" + MODEL + \"\\\",\" +\n \"\\\"generationConfig\\\":{\" + generationBase + \"}\" +\n \"}}\";\n }\n\n static String audioMessage(byte[] pcm16le16k) {\n String b64 = Base64.getEncoder().encodeToString(pcm16le16k);\n return \"{\\\"realtimeInput\\\":{\" +\n \"\\\"audio\\\":{\" +\n \"\\\"data\\\":\\\"\" + b64 + \"\\\",\" +\n \"\\\"mimeType\\\":\\\"audio/pcm;rate=16000\\\"\" +\n \"}}}\";\n }\n\n static boolean looksLikeSetupSchemaError(String text) {\n if (text == null) return false;\n String lower = text.toLowerCase();\n return lower.contains(\"invalid json payload\")\n || lower.contains(\"cannot find field\")\n || lower.contains(\"unknown name\")\n || lower.contains(\"inputaudiotranscription\")\n || lower.contains(\"outputaudiotranscription\")\n || lower.contains(\"translationconfig\")\n || lower.contains(\"generation_config\");\n }\n\n static boolean looksLikeModelAccessError(String text) {\n if (text == null) return false;\n String lower = text.toLowerCase();\n return lower.contains(\"model\") && (lower.contains(\"not found\")\n || lower.contains(\"not available\")\n || lower.contains(\"unsupported\")\n || lower.contains(\"permission\"));\n }\n\n static boolean looksLikeAuthError(String text) {\n if (text == null) return false;\n String lower = text.toLowerCase();\n return lower.contains(\"api key\") && (lower.contains(\"invalid\") || lower.contains(\"not valid\") || lower.contains(\"permission\"))\n || lower.contains(\"unauthenticated\")\n || lower.contains(\"permission denied\");\n }\n\n static boolean looksLikeQuotaError(String text) {\n if (text == null) return false;\n String lower = text.toLowerCase();\n return lower.contains(\"quota\") || lower.contains(\"resource exhausted\") || lower.contains(\"rate limit\");\n }\n\n static String safeLanguageCode(String value) {\n if (value == null || !value.matches(\"[A-Za-z]{2,3}(-[A-Za-z0-9]{2,8})*\")) return \"fa\";\n return value;\n }\n}\n`;\n\nexport const GEMINI_PROTOCOL = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport org.json.JSONArray;\nimport org.json.JSONException;\nimport org.json.JSONObject;\n\nimport java.util.ArrayList;\nimport java.util.Base64;\nimport java.util.List;\n\nfinal class GeminiProtocol {\n private GeminiProtocol() {}\n\n static boolean isSetupComplete(String json) {\n try { return new JSONObject(json).has(\"setupComplete\"); }\n catch (JSONException ignored) { return false; }\n }\n\n static String errorMessage(String json) {\n try {\n JSONObject root = new JSONObject(json);\n JSONObject error = root.optJSONObject(\"error\");\n if (error == null) return null;\n String message = error.optString(\"message\", \"\").trim();\n return message.isEmpty() ? error.toString() : message;\n } catch (JSONException ignored) {\n return null;\n }\n }\n\n static String inputTranscript(String json) { return transcript(json, \"inputTranscription\"); }\n static String outputTranscript(String json) { return transcript(json, \"outputTranscription\"); }\n\n private static String transcript(String json, String field) {\n try {\n JSONObject content = new JSONObject(json).optJSONObject(\"serverContent\");\n if (content == null) return null;\n JSONObject transcript = content.optJSONObject(field);\n if (transcript == null) return null;\n String text = transcript.optString(\"text\", \"\").trim();\n return text.isEmpty() ? null : text;\n } catch (JSONException ignored) {\n return null;\n }\n }\n\n static List extractOutputAudio(String json) {\n List out = new ArrayList<>();\n try {\n JSONObject content = new JSONObject(json).optJSONObject(\"serverContent\");\n if (content == null) return out;\n JSONObject modelTurn = content.optJSONObject(\"modelTurn\");\n if (modelTurn == null) return out;\n JSONArray parts = modelTurn.optJSONArray(\"parts\");\n if (parts == null) return out;\n for (int i = 0; i < parts.length(); i++) {\n JSONObject part = parts.optJSONObject(i);\n JSONObject inlineData = part == null ? null : part.optJSONObject(\"inlineData\");\n if (inlineData == null) continue;\n String mime = inlineData.optString(\"mimeType\", \"\");\n if (!mime.isEmpty() && !mime.toLowerCase().startsWith(\"audio/\")) continue;\n String data = inlineData.optString(\"data\", \"\");\n if (!data.isEmpty()) out.add(Base64.getDecoder().decode(data));\n }\n } catch (Exception ignored) {\n // Malformed or partial server messages must never crash playback.\n }\n return out;\n }\n}\n`;\n\nexport const PCM_RESAMPLER = String.raw`package com.openai.universaldubber.rebuilt;\n\nfinal class PcmResampler {\n private PcmResampler() {}\n\n static byte[] downsample48kTo16k(byte[] input) {\n if (input == null || input.length < 6) return new byte[0];\n int inputSamples = input.length / 2;\n int outputSamples = inputSamples / 3;\n byte[] output = new byte[outputSamples * 2];\n for (int out = 0; out < outputSamples; out++) {\n int base = out * 3;\n int a = read16(input, base * 2);\n int b = read16(input, (base + 1) * 2);\n int c = read16(input, (base + 2) * 2);\n int mixed = (a + b + c) / 3;\n write16(output, out * 2, mixed);\n }\n return output;\n }\n\n static boolean isMostlySilent(byte[] pcm16le, int threshold) {\n if (pcm16le == null || pcm16le.length < 2) return true;\n long sum = 0;\n int samples = pcm16le.length / 2;\n for (int i = 0; i < samples; i++) sum += Math.abs(read16(pcm16le, i * 2));\n return samples == 0 || (sum / samples) < Math.max(0, threshold);\n }\n\n static int read16ForTest(byte[] data, int offset) { return read16(data, offset); }\n\n private static int read16(byte[] data, int offset) {\n int lo = data[offset] & 0xff;\n int hi = data[offset + 1];\n return (short) ((hi << 8) | lo);\n }\n\n private static void write16(byte[] data, int offset, int sample) {\n short s = (short) Math.max(Short.MIN_VALUE, Math.min(Short.MAX_VALUE, sample));\n data[offset] = (byte) (s & 0xff);\n data[offset + 1] = (byte) ((s >>> 8) & 0xff);\n }\n}\n`;\n\nexport const YOUTUBE_URL = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport java.net.URI;\nimport java.net.URLDecoder;\nimport java.util.Locale;\n\nfinal class YoutubeUrl {\n private YoutubeUrl() {}\n\n static String extract(String value) {\n if (value == null) return null;\n String text = value.trim();\n if (isId(text)) return text;\n try {\n URI uri = new URI(text);\n String scheme = uri.getScheme();\n if (scheme == null || !(\"http\".equalsIgnoreCase(scheme) || \"https\".equalsIgnoreCase(scheme))) return null;\n String host = uri.getHost();\n if (host == null) return null;\n host = host.toLowerCase(Locale.US);\n if (host.startsWith(\"www.\")) host = host.substring(4);\n if (host.startsWith(\"m.\")) host = host.substring(2);\n\n String path = uri.getPath() == null ? \"\" : uri.getPath();\n String[] parts = path.split(\"/\");\n if (\"youtu.be\".equals(host)) {\n for (String part : parts) if (!part.isEmpty()) return isId(part) ? part : null;\n return null;\n }\n if (!(\"youtube.com\".equals(host) || \"music.youtube.com\".equals(host) || \"youtube-nocookie.com\".equals(host))) return null;\n\n String queryId = queryParameter(uri.getRawQuery(), \"v\");\n if (isId(queryId)) return queryId;\n for (int i = 0; i + 1 < parts.length; i++) {\n String kind = parts[i];\n if ((\"embed\".equals(kind) || \"shorts\".equals(kind) || \"live\".equals(kind)) && isId(parts[i + 1])) {\n return parts[i + 1];\n }\n }\n } catch (Exception ignored) {}\n return null;\n }\n\n private static String queryParameter(String rawQuery, String name) {\n if (rawQuery == null) return null;\n for (String item : rawQuery.split(\"&\")) {\n int eq = item.indexOf('=');\n String rawKey = eq >= 0 ? item.substring(0, eq) : item;\n String rawValue = eq >= 0 ? item.substring(eq + 1) : \"\";\n try {\n String key = URLDecoder.decode(rawKey, \"UTF-8\");\n if (name.equals(key)) return URLDecoder.decode(rawValue, \"UTF-8\");\n } catch (Exception ignored) {}\n }\n return null;\n }\n\n private static boolean isId(String value) {\n return value != null && value.matches(\"[A-Za-z0-9_-]{11}\");\n }\n}\n`;\n\nexport const GEMINI_WIRE_TEST = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport org.junit.Test;\nimport static org.junit.Assert.*;\n\npublic class GeminiWireTest {\n @Test public void canonicalVariantUsesTranslateGuideShape() {\n String json = GeminiWire.setupMessage(\"fa\", GeminiWire.VARIANT_TRANSLATE_GUIDE);\n assertTrue(json.contains(\"gemini-3.5-live-translate-preview\"));\n assertTrue(json.contains(\"\\\"targetLanguageCode\\\":\\\"fa\\\"\"));\n assertTrue(json.contains(\"\\\"generationConfig\\\":{\\\"responseModalities\\\":[\\\"AUDIO\\\"],\\\"inputAudioTranscription\\\":{}\"));\n assertTrue(json.contains(\"\\\"outputAudioTranscription\\\":{}\"));\n }\n\n @Test public void compatibilityVariantMovesTranscriptFieldsToSetup() {\n String json = GeminiWire.setupMessage(\"fa\", GeminiWire.VARIANT_TOP_LEVEL_TRANSCRIPTS);\n int closeGeneration = json.indexOf(\"},\\\"inputAudioTranscription\\\"\");\n assertTrue(closeGeneration > 0);\n assertTrue(json.contains(\"\\\"inputAudioTranscription\\\":{}\"));\n assertTrue(json.contains(\"\\\"outputAudioTranscription\\\":{}\"));\n }\n\n @Test public void finalFallbackOmitsTranscriptionFields() {\n String json = GeminiWire.setupMessage(\"fa\", GeminiWire.VARIANT_NO_TRANSCRIPTS);\n assertFalse(json.contains(\"inputAudioTranscription\"));\n assertFalse(json.contains(\"outputAudioTranscription\"));\n assertTrue(json.contains(\"translationConfig\"));\n }\n\n @Test public void invalidLanguageFallsBackToPersian() {\n assertEquals(\"fa\", GeminiWire.safeLanguageCode(\"../../bad\"));\n }\n\n @Test public void detectsOriginalScreenshotSchemaFailure() {\n assertTrue(GeminiWire.looksLikeSetupSchemaError(\"Invalid JSON payload received. Unknown name inputAudioTranscription at setup.generation_config: Cannot find field\"));\n }\n\n @Test public void audioMessageUsesOfficialPcmRate() {\n String json = GeminiWire.audioMessage(new byte[]{0, 1, 2, 3});\n assertTrue(json.contains(\"audio/pcm;rate=16000\"));\n assertTrue(json.contains(\"realtimeInput\"));\n }\n}\n`;\n\nexport const YOUTUBE_URL_TEST = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport org.junit.Test;\nimport static org.junit.Assert.*;\n\npublic class YoutubeUrlTest {\n private static final String ID = \"eiALJiCk_VU\";\n\n @Test public void acceptsDirectIdAndCommonUrls() {\n assertEquals(ID, YoutubeUrl.extract(ID));\n assertEquals(ID, YoutubeUrl.extract(\"https://youtu.be/\" + ID + \"?si=test\"));\n assertEquals(ID, YoutubeUrl.extract(\"https://www.youtube.com/watch?v=\" + ID));\n assertEquals(ID, YoutubeUrl.extract(\"https://youtube.com/shorts/\" + ID + \"?feature=share\"));\n assertEquals(ID, YoutubeUrl.extract(\"https://www.youtube.com/embed/\" + ID));\n assertEquals(ID, YoutubeUrl.extract(\"https://youtube.com/live/\" + ID));\n assertEquals(ID, YoutubeUrl.extract(\"https://music.youtube.com/watch?v=\" + ID));\n }\n\n @Test public void rejectsLookalikeHostsAndBadIds() {\n assertNull(YoutubeUrl.extract(\"https://youtube.com.evil.example/watch?v=\" + ID));\n assertNull(YoutubeUrl.extract(\"https://notyoutube.example/watch?v=\" + ID));\n assertNull(YoutubeUrl.extract(\"too-short\"));\n assertNull(YoutubeUrl.extract(\"javascript:alert(1)\"));\n }\n}\n`;\n\nexport const PCM_RESAMPLER_TEST = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport org.junit.Test;\nimport static org.junit.Assert.*;\n\npublic class PcmResamplerTest {\n @Test public void downsampleProducesOneThirdSamples() {\n byte[] in = new byte[4800 * 2];\n byte[] out = PcmResampler.downsample48kTo16k(in);\n assertEquals(1600 * 2, out.length);\n assertTrue(PcmResampler.isMostlySilent(out, 10));\n }\n\n @Test public void constantSignalKeepsAmplitude() {\n byte[] in = new byte[300 * 2];\n for (int i = 0; i < 300; i++) {\n short sample = 1200;\n in[i * 2] = (byte) (sample & 0xff);\n in[i * 2 + 1] = (byte) ((sample >>> 8) & 0xff);\n }\n byte[] out = PcmResampler.downsample48kTo16k(in);\n assertEquals(100 * 2, out.length);\n assertEquals(1200, PcmResampler.read16ForTest(out, 0));\n assertFalse(PcmResampler.isMostlySilent(out, 100));\n }\n\n @Test public void shortInputIsHandledSafely() {\n assertEquals(0, PcmResampler.downsample48kTo16k(new byte[]{1, 2}).length);\n }\n}\n`;\n",[],[215,286],"73dea7cf-1c24-48d7-94ad-9ed1d1c16d86","main-activity.ts","e7306bba-a15f-11f1-96b3-1607ee4eb77e",31,["D",1787757545757],"export const MAIN_ACTIVITY = String.raw`package com.openai.universaldubber.rebuilt;\n\nimport android.Manifest;\nimport android.annotation.SuppressLint;\nimport android.app.Activity;\nimport android.content.BroadcastReceiver;\nimport android.content.Context;\nimport android.content.Intent;\nimport android.content.IntentFilter;\nimport android.content.pm.PackageManager;\nimport android.database.Cursor;\nimport android.graphics.Color;\nimport android.media.projection.MediaProjectionManager;\nimport android.net.Uri;\nimport android.os.Build;\nimport android.os.Bundle;\nimport android.text.InputType;\nimport android.view.Gravity;\nimport android.view.View;\nimport android.view.ViewGroup;\nimport android.view.Window;\nimport android.view.WindowInsets;\nimport android.view.WindowInsetsController;\nimport android.webkit.CookieManager;\nimport android.webkit.WebChromeClient;\nimport android.webkit.WebSettings;\nimport android.webkit.WebView;\nimport android.webkit.WebViewClient;\nimport android.widget.ArrayAdapter;\nimport android.widget.Button;\nimport android.widget.EditText;\nimport android.widget.FrameLayout;\nimport android.widget.LinearLayout;\nimport android.widget.ScrollView;\nimport android.widget.SeekBar;\nimport android.widget.Spinner;\nimport android.widget.TextView;\n\nimport androidx.media3.common.AudioAttributes;\nimport androidx.media3.common.C;\nimport androidx.media3.common.MediaItem;\nimport androidx.media3.common.Player;\nimport androidx.media3.exoplayer.ExoPlayer;\nimport androidx.media3.ui.PlayerView;\n\nimport java.util.Arrays;\nimport java.util.List;\nimport java.util.Locale;\n\npublic final class MainActivity extends Activity {\n private static final int REQ_OPEN_VIDEO = 1001;\n private static final int REQ_RECORD_AUDIO = 1002;\n private static final int REQ_PROJECTION = 1003;\n private static final int DUB_ORIGINAL_VOLUME_PERCENT = 35;\n\n private static final class Language {\n final String label;\n final String code;\n Language(String label, String code) { this.label = label; this.code = code; }\n @Override public String toString() { return label; }\n }\n\n private final List languages = Arrays.asList(\n new Language(\"فارسی\", \"fa\"), new Language(\"English\", \"en\"),\n new Language(\"العربية\", \"ar\"), new Language(\"Français\", \"fr\"),\n new Language(\"Deutsch\", \"de\"), new Language(\"Español\", \"es\"),\n new Language(\"Türkçe\", \"tr\"), new Language(\"Italiano\", \"it\"),\n new Language(\"Português\", \"pt\"), new Language(\"Русский\", \"ru\"),\n new Language(\"日本語\", \"ja\"), new Language(\"한국어\", \"ko\"),\n new Language(\"中文\", \"zh\"), new Language(\"हिन्दी\", \"hi\")\n );\n\n private LinearLayout root;\n private ScrollView controlsScroll;\n private FrameLayout playerHost;\n private PlayerView playerView;\n private WebView webView;\n private ExoPlayer exoPlayer;\n private EditText apiKeyEdit;\n private EditText youtubeEdit;\n private Spinner languageSpinner;\n private TextView statusText;\n private TextView selectedFileText;\n private TextView inputTranscript;\n private TextView outputTranscript;\n private TextView timeText;\n private Button dubButton;\n private Button playButton;\n private SeekBar seekBar;\n private Uri localVideo;\n private boolean youtubeMode;\n private boolean youtubeReady;\n private boolean dubActive;\n private boolean dubStarting;\n private boolean fullscreen;\n private boolean seeking;\n private boolean receiverRegistered;\n\n private final Runnable progressTick = new Runnable() {\n @Override public void run() {\n if (exoPlayer != null && !youtubeMode) {\n long duration = exoPlayer.getDuration();\n long pos = exoPlayer.getCurrentPosition();\n if (!seeking && duration > 0) {\n seekBar.setProgress((int) Math.min(1000, pos * 1000L / duration));\n }\n timeText.setText(formatMs(pos) + \" / \" + (duration > 0 ? formatMs(duration) : \"--:--\"));\n playButton.setText(exoPlayer.isPlaying() ? \"توقف موقت\" : \"پخش\");\n }\n if (root != null) root.postDelayed(this, 400);\n }\n };\n\n private final BroadcastReceiver dubReceiver = new BroadcastReceiver() {\n @Override public void onReceive(Context context, Intent intent) {\n if (!LiveDubService.ACTION_EVENT.equals(intent.getAction())) return;\n String kind = intent.getStringExtra(LiveDubService.EXTRA_KIND);\n String text = intent.getStringExtra(LiveDubService.EXTRA_TEXT);\n if (\"input\".equals(kind)) {\n inputTranscript.setText(\"متن ورودی: \" + safe(text));\n } else if (\"output\".equals(kind)) {\n outputTranscript.setText(\"ترجمه: \" + safe(text));\n } else if (\"active\".equals(kind)) {\n dubActive = true;\n dubStarting = false;\n setOriginalVolume(DUB_ORIGINAL_VOLUME_PERCENT);\n updateDubButton();\n setStatus(text, false);\n } else if (\"error\".equals(kind)) {\n dubActive = false;\n dubStarting = false;\n setOriginalVolume(100);\n updateDubButton();\n setStatus(text, true);\n } else if (\"stopped\".equals(kind)) {\n dubActive = false;\n dubStarting = false;\n setOriginalVolume(100);\n updateDubButton();\n setStatus(text, false);\n } else {\n setStatus(text, false);\n }\n }\n };\n\n @Override protected void onCreate(Bundle state) {\n super.onCreate(state);\n buildUi();\n initPlayers();\n registerEvents();\n consumeIncomingIntent(getIntent());\n progressTick.run();\n }\n\n private void buildUi() {\n root = new LinearLayout(this);\n root.setOrientation(LinearLayout.VERTICAL);\n root.setPadding(dp(10), dp(8), dp(10), dp(8));\n root.setBackgroundColor(Color.rgb(14, 17, 23));\n setContentView(root);\n\n TextView title = text(\"Universal Dubber Rebuilt\", 24, Color.WHITE);\n title.setGravity(Gravity.CENTER_HORIZONTAL);\n root.addView(title, fullWrap());\n\n playerHost = new FrameLayout(this);\n playerHost.setBackgroundColor(Color.BLACK);\n root.addView(playerHost, new LinearLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, dp(270)));\n\n playerView = new PlayerView(this);\n playerView.setUseController(true);\n playerView.setControllerAutoShow(true);\n playerView.setControllerShowTimeoutMs(3500);\n playerView.setShowBuffering(PlayerView.SHOW_BUFFERING_WHEN_PLAYING);\n playerView.setKeepScreenOn(true);\n playerHost.addView(playerView, new FrameLayout.LayoutParams(-1, -1));\n\n webView = new WebView(this);\n webView.setBackgroundColor(Color.BLACK);\n webView.setVisibility(View.GONE);\n playerHost.addView(webView, new FrameLayout.LayoutParams(-1, -1));\n\n Button full = button(\"⛶\", v -> toggleFullscreen());\n FrameLayout.LayoutParams fullLp = new FrameLayout.LayoutParams(dp(56), dp(48), Gravity.TOP | Gravity.END);\n fullLp.setMargins(0, dp(5), dp(5), 0);\n playerHost.addView(full, fullLp);\n\n controlsScroll = new ScrollView(this);\n LinearLayout controls = new LinearLayout(this);\n controls.setOrientation(LinearLayout.VERTICAL);\n controls.setPadding(dp(2), dp(8), dp(2), dp(28));\n controlsScroll.addView(controls);\n root.addView(controlsScroll, new LinearLayout.LayoutParams(-1, 0, 1f));\n\n LinearLayout sourceRow = new LinearLayout(this);\n sourceRow.setOrientation(LinearLayout.HORIZONTAL);\n sourceRow.addView(button(\"فایل ویدیویی\", v -> chooseVideo()), weighted());\n sourceRow.addView(button(\"بازکردن YouTube\", v -> openYoutube()), weighted());\n controls.addView(sourceRow, fullWrap());\n\n selectedFileText = text(\"فایل محلی: انتخاب نشده\", 13, Color.LTGRAY);\n controls.addView(selectedFileText, fullWrap());\n youtubeEdit = edit(\"لینک YouTube یا شناسه ویدیو\");\n controls.addView(youtubeEdit, top(6));\n\n LinearLayout transport = new LinearLayout(this);\n transport.setOrientation(LinearLayout.HORIZONTAL);\n transport.addView(button(\"−10s\", v -> seekDelta(-10_000)), weighted());\n playButton = button(\"پخش\", v -> togglePlay());\n transport.addView(playButton, weighted());\n transport.addView(button(\"+10s\", v -> seekDelta(10_000)), weighted());\n controls.addView(transport, top(6));\n\n seekBar = new SeekBar(this);\n seekBar.setMax(1000);\n seekBar.setOnSeekBarChangeListener(new SeekBar.OnSeekBarChangeListener() {\n @Override public void onProgressChanged(SeekBar bar, int progress, boolean fromUser) {}\n @Override public void onStartTrackingTouch(SeekBar bar) { seeking = true; }\n @Override public void onStopTrackingTouch(SeekBar bar) {\n seeking = false;\n if (exoPlayer != null && !youtubeMode && exoPlayer.getDuration() > 0) {\n exoPlayer.seekTo(exoPlayer.getDuration() * bar.getProgress() / 1000L);\n }\n }\n });\n controls.addView(seekBar, fullWrap());\n timeText = text(\"00:00 / --:--\", 13, Color.LTGRAY);\n timeText.setGravity(Gravity.CENTER_HORIZONTAL);\n controls.addView(timeText, fullWrap());\n\n apiKeyEdit = edit(\"Gemini API Key\");\n apiKeyEdit.setInputType(InputType.TYPE_CLASS_TEXT | InputType.TYPE_TEXT_VARIATION_PASSWORD);\n apiKeyEdit.setSaveEnabled(false);\n if (Build.VERSION.SDK_INT >= 26) {\n apiKeyEdit.setImportantForAutofill(View.IMPORTANT_FOR_AUTOFILL_NO_EXCLUDE_DESCENDANTS);\n }\n controls.addView(apiKeyEdit, top(10));\n\n LinearLayout langRow = new LinearLayout(this);\n langRow.setOrientation(LinearLayout.HORIZONTAL);\n TextView langLabel = text(\"زبان دوبله:\", 16, Color.WHITE);\n langRow.addView(langLabel, new LinearLayout.LayoutParams(0, -2, .45f));\n languageSpinner = new Spinner(this);\n ArrayAdapter adapter = new ArrayAdapter<>(this, android.R.layout.simple_spinner_dropdown_item, languages);\n languageSpinner.setAdapter(adapter);\n langRow.addView(languageSpinner, new LinearLayout.LayoutParams(0, -2, .55f));\n controls.addView(langRow, top(8));\n\n dubButton = button(\"شروع دوبله زنده\", v -> onDubPressed());\n controls.addView(dubButton, top(8));\n\n statusText = text(\"آماده\", 14, Color.rgb(190, 200, 220));\n controls.addView(statusText, top(8));\n inputTranscript = text(\"متن ورودی: —\", 13, Color.LTGRAY);\n outputTranscript = text(\"ترجمه: —\", 13, Color.LTGRAY);\n controls.addView(inputTranscript, top(8));\n controls.addView(outputTranscript, top(4));\n }\n\n @SuppressLint(\"SetJavaScriptEnabled\")\n private void initPlayers() {\n exoPlayer = new ExoPlayer.Builder(this).build();\n playerView.setPlayer(exoPlayer);\n exoPlayer.setAudioAttributes(new AudioAttributes.Builder()\n .setUsage(C.USAGE_MEDIA)\n .setContentType(C.AUDIO_CONTENT_TYPE_MOVIE)\n .build(), true);\n exoPlayer.addListener(new Player.Listener() {\n @Override public void onPlayerError(androidx.media3.common.PlaybackException error) {\n setStatus(\"خطای پخش فایل: \" + error.getErrorCodeName(), true);\n }\n });\n\n WebSettings s = webView.getSettings();\n s.setJavaScriptEnabled(true);\n s.setDomStorageEnabled(true);\n s.setMediaPlaybackRequiresUserGesture(false);\n s.setAllowFileAccess(false);\n s.setAllowContentAccess(false);\n if (Build.VERSION.SDK_INT >= 21) s.setMixedContentMode(WebSettings.MIXED_CONTENT_NEVER_ALLOW);\n if (Build.VERSION.SDK_INT >= 26) s.setSafeBrowsingEnabled(true);\n CookieManager.getInstance().setAcceptCookie(true);\n if (Build.VERSION.SDK_INT >= 21) CookieManager.getInstance().setAcceptThirdPartyCookies(webView, true);\n webView.setWebViewClient(new WebViewClient());\n webView.setWebChromeClient(new WebChromeClient());\n }\n\n private void chooseVideo() {\n Intent i = new Intent(Intent.ACTION_OPEN_DOCUMENT)\n .addCategory(Intent.CATEGORY_OPENABLE)\n .setType(\"video/*\")\n .addFlags(Intent.FLAG_GRANT_READ_URI_PERMISSION | Intent.FLAG_GRANT_PERSISTABLE_URI_PERMISSION);\n startActivityForResult(i, REQ_OPEN_VIDEO);\n }\n\n private void loadLocal(Uri uri) {\n if (uri == null) return;\n stopDubForSourceChange();\n localVideo = uri;\n youtubeMode = false;\n youtubeReady = false;\n try {\n getContentResolver().takePersistableUriPermission(uri, Intent.FLAG_GRANT_READ_URI_PERMISSION);\n } catch (Throwable ignored) {}\n stopYoutubePlayback();\n webView.setVisibility(View.GONE);\n playerView.setVisibility(View.VISIBLE);\n exoPlayer.setMediaItem(MediaItem.fromUri(uri));\n exoPlayer.prepare();\n exoPlayer.play();\n String name = uri.getLastPathSegment();\n selectedFileText.setText(\"فایل محلی: \" + (name == null ? \"ویدیو\" : name));\n setStatus(\"فایل با Media3/ExoPlayer آماده شد.\", false);\n }\n\n private void openYoutube() {\n String id = YoutubeUrl.extract(youtubeEdit.getText().toString());\n if (id == null) {\n setStatus(\"لینک یا شناسه YouTube معتبر نیست.\", true);\n return;\n }\n stopDubForSourceChange();\n youtubeMode = true;\n youtubeReady = false;\n exoPlayer.pause();\n playerView.setVisibility(View.GONE);\n webView.setVisibility(View.VISIBLE);\n webView.loadDataWithBaseURL(\"https://www.youtube.com\", youtubeHtml(id), \"text/html\", \"UTF-8\", null);\n selectedFileText.setText(\"YouTube: \" + id);\n setStatus(\"YouTube در پلیر داخلی باز شد.\", false);\n youtubeReady = true;\n }\n\n private String youtubeHtml(String id) {\n return \"\" +\n \"\" +\n \"

\";\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",[],[215,294],"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",[],[215,302],["D",1787756470524],[232,233,234,235],[215],["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":349,"_350":351,"_352":353,"_354":25,"_355":25,"_356":25,"_357":59,"_358":-5,"_359":-7,"_360":-7,"_361":63,"_362":25,"_363":25,"_364":-5,"_365":25,"_366":25,"_367":25,"_368":-5},"ENV",{"_320":321,"_322":323,"_324":87,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348},"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 · v34