feat: relay prints federation peering config on startup

On startup, the relay detects its outbound IP (via UDP socket trick) and prints a ready-to-copy YAML snippet for other relays to federate: federation: to peer with this relay, add to peers config: - url: "193.180.213.68:4433" fingerprint: "a5d6:e3c6:..." Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
docs: PRD for relay federation (multi-relay mesh) + identity fix
2026-04-07 21:37:10 +04:00 · 2026-04-07 21:33:05 +04:00 · 2026-04-07 21:25:33 +04:00 · 2026-04-07 21:22:24 +04:00 · 2026-04-07 19:39:31 +04:00 · 2026-04-07 19:17:33 +04:00
26 changed files with 2180 additions and 161 deletions
--- a/.agents/skills/caveman/SKILL.md
+++ b/.agents/skills/caveman/SKILL.md
@@ -0,0 +1,72 @@
 ---
 name: caveman
 description: >
  Ultra-compressed communication mode. Slash token usage ~75% by speaking like caveman
  while keeping full technical accuracy. Use when user says "caveman mode", "talk like caveman",
  "use caveman", "less tokens", "be brief", or invokes /caveman. Also auto-triggers
  when token efficiency is requested.
 ---
 # Caveman Mode
 ## Core Rule
 Respond like smart caveman. Cut articles, filler, pleasantries. Keep all technical substance.
 ## Grammar
 - Drop articles (a, an, the)
 - Drop filler (just, really, basically, actually, simply)
 - Drop pleasantries (sure, certainly, of course, happy to)
 - Short synonyms (big not extensive, fix not "implement a solution for")
 - No hedging (skip "it might be worth considering")
 - Fragments fine. No need full sentence
 - Technical terms stay exact. "Polymorphism" stays "polymorphism"
 - Code blocks unchanged. Caveman speak around code, not in code
 - Error messages quoted exact. Caveman only for explanation
 ## Pattern
 ```
 [thing] [action] [reason]. [next step].
 ```
 Not:
 > Sure! I'd be happy to help you with that. The issue you're experiencing is likely caused by...
 Yes:
 > Bug in auth middleware. Token expiry check use `<` not `<=`. Fix:
 ## Examples
 **User:** Why is my React component re-rendering?
 **Normal (69 tokens):** "The reason your React component is re-rendering is likely because you're creating a new object reference on each render cycle. When you pass an inline object as a prop, React's shallow comparison sees it as a different object every time, which triggers a re-render. I'd recommend using useMemo to memoize the object."
 **Caveman (19 tokens):** "New object ref each render. Inline object prop = new ref = re-render. Wrap in `useMemo`."
 ---
 **User:** How do I set up a PostgreSQL connection pool?
 **Caveman:**
 ```
 Use `pg` pool:
 ```
 ```js
 const pool = new Pool({
  max: 20,
  idleTimeoutMillis: 30000,
  connectionTimeoutMillis: 2000,
 })
 ```
 ```
 max = concurrent connections. Keep under DB limit. idleTimeout kill stale conn.
 ```
 ## Boundaries
 - Code: write normal. Caveman English only
 - Git commits: normal
 - PR descriptions: normal
 - User say "stop caveman" or "normal mode": revert immediately
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -297,6 +297,12 @@ dependencies = [
 "tower-service",
 ]
 [[package]]
 name = "base16ct"
 version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "4c7f02d4ea65f2c1853089ffd8d2787bdbc63de2f0d29dedbcf8ccdfa0ccd4cf"
 [[package]]
 name = "base64"
 version = "0.22.1"
@@ -467,6 +473,7 @@ dependencies = [
 "iana-time-zone",
 "js-sys",
 "num-traits",
 "serde",
 "wasm-bindgen",
 "windows-link",
 ]
@@ -627,6 +634,24 @@ dependencies = [
 "libc",
 ]
 [[package]]
 name = "crunchy"
 version = "0.2.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "460fbee9c2c2f33933d720630a6a0bac33ba7053db5344fac858d4b8952d77d5"
 [[package]]
 name = "crypto-bigint"
 version = "0.5.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "0dc92fb57ca44df6db8059111ab3af99a63d5d0f8375d9972e319a379c6bab76"
 dependencies = [
 "generic-array",
 "rand_core 0.6.4",
 "subtle",
 "zeroize",
 ]
 [[package]]
 name = "crypto-common"
 version = "0.1.7"
@@ -650,6 +675,7 @@ dependencies = [
 "digest",
 "fiat-crypto",
 "rustc_version",
 "serde",
 "subtle",
 "zeroize",
 ]
@@ -816,10 +842,32 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9ed9a281f7bc9b7576e61468ba615a66a5c8cfdff42420a70aa82701a3b1e292"
 dependencies = [
 "block-buffer",
 "const-oid",
 "crypto-common",
 "subtle",
 ]
 [[package]]
 name = "dirs"
 version = "6.0.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c3e8aa94d75141228480295a7d0e7feb620b1a5ad9f12bc40be62411e38cce4e"
 dependencies = [
 "dirs-sys",
 ]
 [[package]]
 name = "dirs-sys"
 version = "0.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e01a3366d27ee9890022452ee61b2b63a67e6f13f58900b651ff5665f0bb1fab"
 dependencies = [
 "libc",
 "option-ext",
 "redox_users",
 "windows-sys 0.61.2",
 ]
 [[package]]
 name = "displaydoc"
 version = "0.2.5"
@@ -850,6 +898,21 @@ dependencies = [
 "rustfft",
 ]
 [[package]]
 name = "ecdsa"
 version = "0.16.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ee27f32b5c5292967d2d4a9d7f1e0b0aed2c15daded5a60300e4abb9d8020bca"
 dependencies = [
 "der",
 "digest",
 "elliptic-curve",
 "rfc6979",
 "serdect",
 "signature",
 "spki",
 ]
 [[package]]
 name = "ed25519"
 version = "2.2.3"
@@ -857,6 +920,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "115531babc129696a58c64a4fef0a8bf9e9698629fb97e9e40767d235cfbcd53"
 dependencies = [
 "pkcs8",
 "serde",
 "signature",
 ]
@@ -881,6 +945,26 @@ version = "1.15.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "48c757948c5ede0e46177b7add2e67155f70e33c07fea8284df6576da70b3719"
 [[package]]
 name = "elliptic-curve"
 version = "0.13.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b5e6043086bf7973472e0c7dff2142ea0b680d30e18d9cc40f267efbf222bd47"
 dependencies = [
 "base16ct",
 "crypto-bigint",
 "digest",
 "ff",
 "generic-array",
 "group",
 "pkcs8",
 "rand_core 0.6.4",
 "sec1",
 "serdect",
 "subtle",
 "zeroize",
 ]
 [[package]]
 name = "encoding_rs"
 version = "0.8.35"
@@ -924,6 +1008,16 @@ version = "2.3.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be"
 [[package]]
 name = "ff"
 version = "0.13.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c0b50bfb653653f9ca9095b427bed08ab8d75a137839d9ad64eb11810d5b6393"
 dependencies = [
 "rand_core 0.6.4",
 "subtle",
 ]
 [[package]]
 name = "fiat-crypto"
 version = "0.2.9"
@@ -1084,6 +1178,7 @@ checksum = "85649ca51fd72272d7821adaf274ad91c288277713d9c18820d8499a7ff69e9a"
 dependencies = [
 "typenum",
 "version_check",
 "zeroize",
 ]
 [[package]]
@@ -1143,6 +1238,17 @@ version = "0.3.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "0cc23270f6e1808e30a928bdc84dea0b9b4136a8bc82338574f23baf47bbd280"
 [[package]]
 name = "group"
 version = "0.13.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f0f9ef7462f7c099f518d754361858f86d8a07af53ba9af0fe635bbccb151a63"
 dependencies = [
 "ff",
 "rand_core 0.6.4",
 "subtle",
 ]
 [[package]]
 name = "h2"
 version = "0.4.13"
@@ -1626,6 +1732,21 @@ dependencies = [
 "wasm-bindgen",
 ]
 [[package]]
 name = "k256"
 version = "0.13.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f6e3919bbaa2945715f0bb6d3934a173d1e9a59ac23767fbaaef277265a7411b"
 dependencies = [
 "cfg-if",
 "ecdsa",
 "elliptic-curve",
 "once_cell",
 "serdect",
 "sha2",
 "signature",
 ]
 [[package]]
 name = "lazy_static"
 version = "1.5.0"
@@ -1660,6 +1781,15 @@ version = "0.2.16"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b6d2cec3eae94f9f509c767b45932f1ada8350c4bdb85af2fcab4a3c14807981"
 [[package]]
 name = "libredox"
 version = "0.1.15"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7ddbf48fd451246b1f8c2610bd3b4ac0cc6e149d89832867093ab69a17194f08"
 dependencies = [
 "libc",
 ]
 [[package]]
 name = "linux-raw-sys"
 version = "0.12.1"
@@ -1702,6 +1832,15 @@ dependencies = [
 "libc",
 ]
 [[package]]
 name = "matchers"
 version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d1525a2a28c7f4fa0fc98bb91ae755d1e2d1505079e05539e35bc876b5d65ae9"
 dependencies = [
 "regex-automata",
 ]
 [[package]]
 name = "matchit"
 version = "0.7.3"
@@ -1980,6 +2119,12 @@ dependencies = [
 "vcpkg",
 ]
 [[package]]
 name = "option-ext"
 version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "04744f49eae99ab78e0d5c0b603ab218f515ea8cfe5a456d7629ad883a3b6e7d"
 [[package]]
 name = "os_str_bytes"
 version = "6.6.1"
@@ -2320,6 +2465,17 @@ dependencies = [
 "bitflags 2.11.0",
 ]
 [[package]]
 name = "redox_users"
 version = "0.5.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a4e608c6638b9c18977b00b475ac1f28d14e84b27d8d42f70e0bf1e3dec127ac"
 dependencies = [
 "getrandom 0.2.17",
 "libredox",
 "thiserror 2.0.18",
 ]
 [[package]]
 name = "regex"
 version = "1.12.3"
@@ -2389,6 +2545,16 @@ dependencies = [
 "web-sys",
 ]
 [[package]]
 name = "rfc6979"
 version = "0.4.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f8dd2a808d456c4a54e300a23e9f5a67e122c3024119acbfd73e3bf664491cb2"
 dependencies = [
 "hmac",
 "subtle",
 ]
 [[package]]
 name = "ring"
 version = "0.17.14"
@@ -2567,6 +2733,21 @@ version = "1.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
 [[package]]
 name = "sec1"
 version = "0.7.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d3e97a565f76233a6003f9f5c54be1d9c5bdfa3eccfb189469f11ec4901c47dc"
 dependencies = [
 "base16ct",
 "der",
 "generic-array",
 "pkcs8",
 "serdect",
 "subtle",
 "zeroize",
 ]
 [[package]]
 name = "security-framework"
 version = "3.7.0"
@@ -2671,6 +2852,16 @@ dependencies = [
 "serde",
 ]
 [[package]]
 name = "serdect"
 version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a84f14a19e9a014bb9f4512488d9829a68e04ecabffb0f9904cd1ace94598177"
 dependencies = [
 "base16ct",
 "serde",
 ]
 [[package]]
 name = "sha1"
 version = "0.10.6"
@@ -2724,6 +2915,7 @@ version = "2.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "77549399552de45a898a580c1b41d445bf730df867cc44e6c0233bbc4b8329de"
 dependencies = [
 "digest",
 "rand_core 0.6.4",
 ]
@@ -2937,6 +3129,15 @@ version = "0.1.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7694e1cfe791f8d31026952abf09c69ca6f6fa4e1a1229e18988f06a04a12dca"
 [[package]]
 name = "tiny-keccak"
 version = "2.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "2c9d3793400a45f954c52e73d068316d76b6f4e36977e3fcebb13a2721e80237"
 dependencies = [
 "crunchy",
 ]
 [[package]]
 name = "tinystr"
 version = "0.8.2"
@@ -3235,10 +3436,14 @@ version = "0.3.23"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "cb7f578e5945fb242538965c2d0b04418d38ec25c79d160cd279bf0731c8d319"
 dependencies = [
 "matchers",
 "nu-ansi-term",
 "once_cell",
 "regex-automata",
 "sharded-slab",
 "smallvec",
 "thread_local",
 "tracing",
 "tracing-core",
 "tracing-log",
 ]
@@ -3367,6 +3572,18 @@ version = "1.0.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be"
 [[package]]
 name = "uuid"
 version = "1.23.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "5ac8b6f42ead25368cf5b098aeb3dc8a1a2c05a3eee8a9a1a68c640edbfc79d9"
 dependencies = [
 "getrandom 0.4.2",
 "js-sys",
 "serde_core",
 "wasm-bindgen",
 ]
 [[package]]
 name = "valuable"
 version = "0.1.1"
@@ -3406,7 +3623,28 @@ dependencies = [
 [[package]]
 name = "warzone-protocol"
-version = "0.1.0"
+version = "0.0.38"
 dependencies = [
 "base64",
 "bincode",
 "bip39",
 "chacha20poly1305",
 "chrono",
 "curve25519-dalek",
 "ed25519-dalek",
 "hex",
 "hkdf",
 "k256",
 "rand 0.8.5",
 "serde",
 "serde_json",
 "sha2",
 "thiserror 2.0.18",
 "tiny-keccak",
 "uuid",
 "x25519-dalek",
 "zeroize",
 ]
 [[package]]
 name = "wasi"
@@ -4132,6 +4370,7 @@ dependencies = [
 "async-trait",
 "axum 0.7.9",
 "bytes",
 "dirs",
 "futures-util",
 "prometheus",
 "quinn",
--- a/android/app/src/main/java/com/wzp/audio/AudioPipeline.kt
+++ b/android/app/src/main/java/com/wzp/audio/AudioPipeline.kt
@@ -57,7 +57,7 @@ class AudioPipeline(private val context: Context) {
    /** Whether to attach hardware AEC. Must be set before start(). */
    var aecEnabled: Boolean = true
    /** Enable debug recording of PCM + RMS histogram to cache dir. */
-    var debugRecording: Boolean = true
+    var debugRecording: Boolean = false
    private var captureThread: Thread? = null
    private var playoutThread: Thread? = null
--- a/android/app/src/main/java/com/wzp/data/SettingsRepository.kt
+++ b/android/app/src/main/java/com/wzp/data/SettingsRepository.kt
@@ -28,6 +28,7 @@ class SettingsRepository(context: Context) {
        private const val KEY_PREFER_IPV6 = "prefer_ipv6"
        private const val KEY_IDENTITY_SEED = "identity_seed_hex"
        private const val KEY_AEC_ENABLED = "aec_enabled"
        private const val KEY_DEBUG_RECORDING = "debug_recording"
        private const val KEY_RECENT_ROOMS = "recent_rooms"
        private const val TOFU_PREFIX = "tofu_"
    }
@@ -120,6 +121,16 @@ class SettingsRepository(context: Context) {
    fun saveAecEnabled(enabled: Boolean) { prefs.edit().putBoolean(KEY_AEC_ENABLED, enabled).apply() }
    fun loadAecEnabled(): Boolean = prefs.getBoolean(KEY_AEC_ENABLED, true)
    // --- Debug recording ---
    fun saveDebugRecording(enabled: Boolean) { prefs.edit().putBoolean(KEY_DEBUG_RECORDING, enabled).apply() }
    fun loadDebugRecording(): Boolean = prefs.getBoolean(KEY_DEBUG_RECORDING, false)
    // --- Codec choice ---
    // 0 = Opus (GOOD), 1 = Opus Low (DEGRADED), 2 = Codec2 (CATASTROPHIC)
    fun saveCodecChoice(choice: Int) { prefs.edit().putInt("codec_choice", choice).apply() }
    fun loadCodecChoice(): Int = prefs.getInt("codec_choice", 0)
    // --- Identity seed ---
    /**
@@ -179,4 +190,14 @@ class SettingsRepository(context: Context) {
    fun loadServerFingerprint(address: String): String? {
        return prefs.getString("$TOFU_PREFIX$address", null)
    }
    // --- Ping RTT cache ---
    fun savePingRtt(address: String, rttMs: Int) {
        prefs.edit().putInt("ping_rtt_$address", rttMs).apply()
    }
    fun loadPingRtt(address: String): Int {
        return prefs.getInt("ping_rtt_$address", -1)
    }
 }
--- a/android/app/src/main/java/com/wzp/engine/WzpEngine.kt
+++ b/android/app/src/main/java/com/wzp/engine/WzpEngine.kt
@@ -38,9 +38,12 @@ class WzpEngine(private val callback: WzpCallback) {
     * @param alias     display name sent to relay for room participant list
     * @return 0 on success, negative error code on failure
     */
-    fun startCall(relayAddr: String, room: String, seedHex: String = "", token: String = "", alias: String = ""): Int {
+    /**
     * @param profile 0 = Opus GOOD, 1 = Opus DEGRADED, 2 = Codec2 CATASTROPHIC
     */
    fun startCall(relayAddr: String, room: String, seedHex: String = "", token: String = "", alias: String = "", profile: Int = 0): Int {
        check(nativeHandle != 0L) { "Engine not initialized" }
-        val result = nativeStartCall(nativeHandle, relayAddr, room, seedHex, token, alias)
+        val result = nativeStartCall(nativeHandle, relayAddr, room, seedHex, token, alias, profile)
        if (result == 0) {
            callback.onCallStateChanged(CallStateConstants.CONNECTING)
        } else {
@@ -141,7 +144,7 @@ class WzpEngine(private val callback: WzpCallback) {
    private external fun nativeInit(): Long
    private external fun nativeStartCall(
-        handle: Long, relay: String, room: String, seed: String, token: String, alias: String
+        handle: Long, relay: String, room: String, seed: String, token: String, alias: String, profile: Int
    ): Int
    private external fun nativeStopCall(handle: Long)
    private external fun nativeSetMute(handle: Long, muted: Boolean)
@@ -153,20 +156,21 @@ class WzpEngine(private val callback: WzpCallback) {
    private external fun nativeWriteAudioDirect(handle: Long, buffer: java.nio.ByteBuffer, sampleCount: Int): Int
    private external fun nativeReadAudioDirect(handle: Long, buffer: java.nio.ByteBuffer, maxSamples: Int): Int
    private external fun nativeDestroy(handle: Long)
    private external fun nativePingRelay(handle: Long, relay: String): String?
    /**
     * Ping a relay server. Requires engine to be initialized.
     * Returns JSON `{"rtt_ms":N,"server_fingerprint":"hex"}` or null.
     */
    fun pingRelay(address: String): String? {
        if (nativeHandle == 0L) return null
        return nativePingRelay(nativeHandle, address)
    }
    companion object {
        init {
            System.loadLibrary("wzp_android")
        }
        /**
         * Ping a relay server. Returns JSON `{"rtt_ms":N,"server_fingerprint":"hex"}`
         * or null if unreachable. Does not require an engine instance.
         */
        fun pingRelay(address: String): String? = nativePingRelay(address)
        @JvmStatic
        private external fun nativePingRelay(relay: String): String?
    }
 }
--- a/android/app/src/main/java/com/wzp/net/RelayPinger.kt
+++ b/android/app/src/main/java/com/wzp/net/RelayPinger.kt
@@ -0,0 +1,12 @@
 package com.wzp.net
 // Relay pinging is now done via WzpEngine.pingRelay() (instance method).
 // This file kept for the data class only.
 object RelayPinger {
    data class PingResult(
        val rttMs: Int,
        val reachable: Boolean,
        val serverFingerprint: String = "",
    )
 }
--- a/android/app/src/main/java/com/wzp/ui/call/CallViewModel.kt
+++ b/android/app/src/main/java/com/wzp/ui/call/CallViewModel.kt
@@ -31,7 +31,8 @@ data class ServerEntry(val address: String, val label: String)
 data class PingResult(
    val rttMs: Int,
-    val serverFingerprint: String,
+    val serverFingerprint: String = "",
    val reachable: Boolean = rttMs > 0,
 )
 enum class LockStatus { UNKNOWN, OFFLINE, NEW, VERIFIED, CHANGED }
@@ -105,6 +106,18 @@ class CallViewModel : ViewModel(), WzpCallback {
    private val _aecEnabled = MutableStateFlow(true)
    val aecEnabled: StateFlow<Boolean> = _aecEnabled.asStateFlow()
    private val _debugRecording = MutableStateFlow(false)
    val debugRecording: StateFlow<Boolean> = _debugRecording.asStateFlow()
    // Quality profile index (matches JNI bridge profile_from_int)
    private val _codecChoice = MutableStateFlow(0)
    val codecChoice: StateFlow<Int> = _codecChoice.asStateFlow()
    /** Key-change warning dialog state. */
    data class KeyWarningInfo(val address: String, val oldFp: String, val newFp: String)
    private val _keyWarning = MutableStateFlow<KeyWarningInfo?>(null)
    val keyWarning: StateFlow<KeyWarningInfo?> = _keyWarning.asStateFlow()
    /** True when a call just ended and debug report can be sent. */
    private val _debugReportAvailable = MutableStateFlow(false)
    val debugReportAvailable: StateFlow<Boolean> = _debugReportAvailable.asStateFlow()
@@ -159,6 +172,8 @@ class CallViewModel : ViewModel(), WzpCallback {
        _captureGainDb.value = s.loadCaptureGain()
        _seedHex.value = s.getOrCreateSeedHex()
        _aecEnabled.value = s.loadAecEnabled()
        _debugRecording.value = s.loadDebugRecording()
        _codecChoice.value = s.loadCodecChoice()
        _recentRooms.value = s.loadRecentRooms()
    }
@@ -203,35 +218,43 @@ class CallViewModel : ViewModel(), WzpCallback {
        settings?.saveSelectedServer(_selectedServer.value)
    }
-    /** Ping all servers in background, update results. */
+    /**
     * Ping all servers via native QUIC. Requires engine to be initialized.
     * Creates engine if needed, pings, keeps engine alive for subsequent Connect.
     */
    fun pingAllServers() {
        viewModelScope.launch {
            // Ensure engine exists
            if (engine == null || engine?.isInitialized != true) {
                try {
                    engine = WzpEngine(this@CallViewModel).also { it.init() }
                    engineInitialized = true
                } catch (e: Exception) {
                    Log.w(TAG, "engine init for ping failed: $e")
                    return@launch
                }
            }
            val eng = engine ?: return@launch
            val results = mutableMapOf<String, PingResult>()
            val known = mutableMapOf<String, String>()
            _servers.value.forEach { server ->
-                val pr = withContext(Dispatchers.IO) {
+                val json = withContext(Dispatchers.IO) {
-                    try {
+                    eng.pingRelay(server.address)
                        val json = WzpEngine.pingRelay(server.address) ?: return@withContext null
                        val obj = JSONObject(json)
                        PingResult(
                            rttMs = obj.getInt("rtt_ms"),
                            serverFingerprint = obj.optString("server_fingerprint", ""),
                        )
                    } catch (e: Exception) {
                        Log.w(TAG, "ping ${server.address} failed: ${e.message}")
                        null
                    }
                }
-                if (pr != null) {
+                if (json != null) {
-                    results[server.address] = pr
+                    try {
-                    // TOFU: save fingerprint on first contact
+                        val obj = JSONObject(json)
-                    if (pr.serverFingerprint.isNotEmpty()) {
+                        val rtt = obj.getInt("rtt_ms")
-                        val saved = settings?.loadServerFingerprint(server.address)
+                        val fp = obj.optString("server_fingerprint", "")
-                        if (saved == null) {
+                        results[server.address] = PingResult(rttMs = rtt, serverFingerprint = fp)
-                            settings?.saveServerFingerprint(server.address, pr.serverFingerprint)
+                        // TOFU
                        if (fp.isNotEmpty()) {
                            val saved = settings?.loadServerFingerprint(server.address)
                            if (saved == null) settings?.saveServerFingerprint(server.address, fp)
                            known[server.address] = saved ?: fp
                        }
-                        known[server.address] = saved ?: pr.serverFingerprint
+                    } catch (_: Exception) {}
                    }
                }
            }
            _pingResults.value = results
@@ -239,12 +262,23 @@ class CallViewModel : ViewModel(), WzpCallback {
        }
    }
    /** Load saved TOFU fingerprints. */
    fun loadSavedFingerprints() {
        val known = mutableMapOf<String, String>()
        _servers.value.forEach { server ->
            settings?.loadServerFingerprint(server.address)?.let {
                known[server.address] = it
            }
        }
        _knownFingerprints.value = known
    }
    /** Get lock status for a server. */
    fun lockStatus(address: String): LockStatus {
        val pr = _pingResults.value[address] ?: return LockStatus.UNKNOWN
-        val known = _knownFingerprints.value[address]
+        if (!pr.reachable) return LockStatus.OFFLINE
        val known = _knownFingerprints.value[address] ?: return LockStatus.NEW
        if (pr.serverFingerprint.isEmpty()) return LockStatus.NEW
        if (known == null) return LockStatus.NEW
        return if (pr.serverFingerprint == known) LockStatus.VERIFIED else LockStatus.CHANGED
    }
@@ -280,6 +314,16 @@ class CallViewModel : ViewModel(), WzpCallback {
        settings?.saveAecEnabled(enabled)
    }
    fun setDebugRecording(enabled: Boolean) {
        _debugRecording.value = enabled
        settings?.saveDebugRecording(enabled)
    }
    fun setCodecChoice(choice: Int) {
        _codecChoice.value = choice
        settings?.saveCodecChoice(choice)
    }
    /**
     * Resolve DNS hostname to IP address on the Kotlin/Android side,
     * since Rust's DNS resolution may not work on Android.
@@ -346,7 +390,35 @@ class CallViewModel : ViewModel(), WzpCallback {
        Log.i(TAG, "teardown: done")
    }
    /** Accept the new server key and proceed with the call. */
    fun acceptNewFingerprint() {
        val info = _keyWarning.value ?: return
        _knownFingerprints.value = _knownFingerprints.value.toMutableMap().also {
            it[info.address] = info.newFp
        }
        settings?.saveServerFingerprint(info.address, info.newFp)
        _keyWarning.value = null
        startCallInternal()
    }
    fun dismissKeyWarning() {
        _keyWarning.value = null
    }
    fun startCall() {
        val serverEntry = _servers.value[_selectedServer.value]
        // Check for key change before connecting
        val ls = lockStatus(serverEntry.address)
        if (ls == LockStatus.CHANGED) {
            val known = _knownFingerprints.value[serverEntry.address] ?: ""
            val current = _pingResults.value[serverEntry.address]?.serverFingerprint ?: ""
            _keyWarning.value = KeyWarningInfo(serverEntry.address, known, current)
            return
        }
        startCallInternal()
    }
    private fun startCallInternal() {
        val serverEntry = _servers.value[_selectedServer.value]
        val room = _roomName.value
        Log.i(TAG, "startCall: server=${serverEntry.address} room=$room")
@@ -377,7 +449,7 @@ class CallViewModel : ViewModel(), WzpCallback {
                    val seed = _seedHex.value
                    val name = _alias.value
                    Log.i(TAG, "startCall: resolved=$relay, alias=$name, calling engine.startCall")
-                    val result = engine?.startCall(relay, room, seedHex = seed, alias = name) ?: -1
+                    val result = engine?.startCall(relay, room, seedHex = seed, alias = name, profile = _codecChoice.value) ?: -1
                    Log.i(TAG, "startCall: engine returned $result")
                    // Only wire up notification callback after engine is running
                    CallService.onStopFromNotification = { stopCall() }
@@ -468,6 +540,7 @@ class CallViewModel : ViewModel(), WzpCallback {
            it.playoutGainDb = _playoutGainDb.value
            it.captureGainDb = _captureGainDb.value
            it.aecEnabled = _aecEnabled.value
            it.debugRecording = _debugRecording.value
            it.start(e)
        }
        audioRouteManager?.register()
--- a/android/app/src/main/java/com/wzp/ui/call/InCallScreen.kt
+++ b/android/app/src/main/java/com/wzp/ui/call/InCallScreen.kt
@@ -89,9 +89,60 @@ fun InCallScreen(
    val pingResults by viewModel.pingResults.collectAsState()
    var showManageRelays by remember { mutableStateOf(false) }
    val keyWarning by viewModel.keyWarning.collectAsState()
-    // Auto-ping on first display
+    // Key-change warning dialog
-    LaunchedEffect(Unit) { viewModel.pingAllServers() }
+    keyWarning?.let { info ->
        AlertDialog(
            onDismissRequest = { viewModel.dismissKeyWarning() },
            title = {
                Column(horizontalAlignment = Alignment.CenterHorizontally, modifier = Modifier.fillMaxWidth()) {
                    Text("\u26A0\uFE0F", fontSize = 40.sp)
                    Spacer(modifier = Modifier.height(8.dp))
                    Text("Server Key Changed", fontWeight = FontWeight.Bold)
                }
            },
            text = {
                Column {
                    Text(
                        "The relay's identity has changed since you last connected. " +
                        "This usually happens when the server was restarted.",
                        style = MaterialTheme.typography.bodySmall,
                        color = MaterialTheme.colorScheme.onSurfaceVariant
                    )
                    Spacer(modifier = Modifier.height(12.dp))
                    Text("Previously known", style = MaterialTheme.typography.labelSmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
                    Text(info.oldFp, fontFamily = FontFamily.Monospace, style = MaterialTheme.typography.bodySmall)
                    Spacer(modifier = Modifier.height(8.dp))
                    Text("New key", style = MaterialTheme.typography.labelSmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
                    Text(info.newFp, fontFamily = FontFamily.Monospace, style = MaterialTheme.typography.bodySmall)
                }
            },
            confirmButton = {
                Button(
                    onClick = { viewModel.acceptNewFingerprint() },
                    colors = ButtonDefaults.buttonColors(containerColor = Color(0xFFFACC15))
                ) {
                    Text("Accept New Key", color = Color.Black, fontWeight = FontWeight.Bold)
                }
            },
            dismissButton = {
                TextButton(onClick = { viewModel.dismissKeyWarning() }) {
                    Text("Cancel")
                }
            }
        )
    }
    // Ping once on launch, then every 5 minutes
    LaunchedEffect(Unit) {
        viewModel.loadSavedFingerprints()
        viewModel.pingAllServers()
        while (true) {
            kotlinx.coroutines.delay(300_000) // 5 minutes
            viewModel.pingAllServers()
        }
    }
    Surface(
        modifier = Modifier.fillMaxSize(),
@@ -434,6 +485,7 @@ fun InCallScreen(
            onSelect = { idx -> viewModel.selectServer(idx) },
            onDelete = { idx -> viewModel.removeServer(idx) },
            onAdd = { addr, label -> viewModel.addServer(addr, label) },
            onRefresh = { viewModel.pingAllServers() },
            onDismiss = { showManageRelays = false }
        )
    }
@@ -462,6 +514,7 @@ private fun ManageRelaysDialog(
    onSelect: (Int) -> Unit,
    onDelete: (Int) -> Unit,
    onAdd: (String, String) -> Unit,
    onRefresh: () -> Unit,
    onDismiss: () -> Unit
 ) {
    var addName by remember { mutableStateOf("") }
@@ -477,14 +530,26 @@ private fun ManageRelaysDialog(
                verticalAlignment = Alignment.CenterVertically
            ) {
                Text("Manage Relays", color = Color.White, fontWeight = FontWeight.Bold)
-                Surface(
+                Row(horizontalArrangement = Arrangement.spacedBy(6.dp)) {
-                    onClick = onDismiss,
+                    Surface(
-                    shape = RoundedCornerShape(8.dp),
+                        onClick = onRefresh,
-                    color = DarkSurface2,
+                        shape = RoundedCornerShape(8.dp),
-                    modifier = Modifier.size(32.dp)
+                        color = DarkSurface2,
-                ) {
+                        modifier = Modifier.size(32.dp)
-                    Box(contentAlignment = Alignment.Center) {
+                    ) {
-                        Text("\u00D7", color = TextDim, fontSize = 18.sp)
+                        Box(contentAlignment = Alignment.Center) {
                            Text("\u21BB", color = TextDim, fontSize = 16.sp)
                        }
                    }
                    Surface(
                        onClick = onDismiss,
                        shape = RoundedCornerShape(8.dp),
                        color = DarkSurface2,
                        modifier = Modifier.size(32.dp)
                    ) {
                        Box(contentAlignment = Alignment.Center) {
                            Text("\u00D7", color = TextDim, fontSize = 18.sp)
                        }
                    }
                }
            }
@@ -539,13 +604,17 @@ private fun ManageRelaysDialog(
                                    )
                                }
                            }
-                            Spacer(modifier = Modifier.width(8.dp))
+                            Spacer(modifier = Modifier.width(4.dp))
-                            Text(
+                            Surface(
-                                "\u00D7",
+                                onClick = { onDelete(idx) },
-                                color = TextDim,
+                                shape = RoundedCornerShape(4.dp),
-                                fontSize = 18.sp,
+                                color = Color.Transparent,
-                                modifier = Modifier.clickable { onDelete(idx) }
+                                modifier = Modifier.size(32.dp)
-                            )
+                            ) {
                                Box(contentAlignment = Alignment.Center) {
                                    Text("\u00D7", color = TextDim, fontSize = 18.sp)
                                }
                            }
                        }
                    }
                }
--- a/android/app/src/main/java/com/wzp/ui/settings/SettingsScreen.kt
+++ b/android/app/src/main/java/com/wzp/ui/settings/SettingsScreen.kt
@@ -1,5 +1,6 @@
 package com.wzp.ui.settings
 import androidx.compose.foundation.clickable
 import android.content.ClipData
 import android.content.ClipboardManager
 import android.content.Context
@@ -22,6 +23,7 @@ import androidx.compose.material3.AlertDialog
 import androidx.compose.material3.Button
 import androidx.compose.material3.ButtonDefaults
 import androidx.compose.material3.Divider
 import androidx.compose.material3.RadioButton
 import androidx.compose.material3.FilledTonalButton
 import androidx.compose.material3.FilledTonalIconButton
 import androidx.compose.material3.IconButtonDefaults
@@ -241,6 +243,51 @@ fun SettingsScreen(
                )
            }
            Spacer(modifier = Modifier.height(12.dp))
            // Quality selection — slider from best (studio 64k) to worst (codec2 1.2k) + auto
            val qualityLabels = listOf(
                "Studio 64k", "Studio 48k", "Studio 32k", "Auto",
                "Opus 24k", "Opus 6k", "Codec2 3.2k", "Codec2 1.2k"
            )
            // Map slider position to JNI profile int:
            // 0=Studio64k(6), 1=Studio48k(5), 2=Studio32k(4), 3=Auto(7),
            // 4=Opus24k(0), 5=Opus6k(1), 6=Codec2_3.2k(3), 7=Codec2_1.2k(2)
            val sliderToProfile = intArrayOf(6, 5, 4, 7, 0, 1, 3, 2)
            val profileToSlider = mapOf(6 to 0, 5 to 1, 4 to 2, 7 to 3, 0 to 4, 1 to 5, 3 to 6, 2 to 7)
            val qualityColors = listOf(
                Color(0xFF22C55E), Color(0xFF4ADE80), Color(0xFF86EFAC), Color(0xFFA3E635),
                Color(0xFFA3E635), Color(0xFFFACC15), Color(0xFFE97320), Color(0xFF991B1B)
            )
            val currentCodec by viewModel.codecChoice.collectAsState()
            val sliderPos = profileToSlider[currentCodec] ?: 3
            Text("Quality", style = MaterialTheme.typography.bodyMedium)
            Text(
                text = "Decode always accepts all codecs",
                style = MaterialTheme.typography.bodySmall,
                color = MaterialTheme.colorScheme.onSurfaceVariant
            )
            Spacer(modifier = Modifier.height(4.dp))
            Text(
                text = qualityLabels[sliderPos],
                style = MaterialTheme.typography.titleMedium.copy(fontWeight = FontWeight.Bold),
                color = qualityColors[sliderPos]
            )
            Slider(
                value = sliderPos.toFloat(),
                onValueChange = { viewModel.setCodecChoice(sliderToProfile[it.toInt()]) },
                valueRange = 0f..7f,
                steps = 6,
                modifier = Modifier.fillMaxWidth()
            )
            Row(
                modifier = Modifier.fillMaxWidth(),
                horizontalArrangement = Arrangement.SpaceBetween
            ) {
                Text("Best", style = MaterialTheme.typography.labelSmall, color = Color(0xFF22C55E))
                Text("Lowest", style = MaterialTheme.typography.labelSmall, color = Color(0xFF991B1B))
            }
            Spacer(modifier = Modifier.height(24.dp))
            Divider()
            Spacer(modifier = Modifier.height(16.dp))
--- a/crates/wzp-android/Cargo.toml
+++ b/crates/wzp-android/Cargo.toml
@@ -17,6 +17,7 @@ wzp-crypto = { workspace = true }
 wzp-transport = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }
 tracing-subscriber = { workspace = true, features = ["env-filter"] }
 bytes = { workspace = true }
 serde = { workspace = true }
 serde_json = "1"
@@ -27,9 +28,7 @@ libc = "0.2"
 jni = { version = "0.21", default-features = false }
 rand = { workspace = true }
 rustls = { version = "0.23", default-features = false, features = ["ring"] }
-android_logger = "0.14"
+tracing-android = "0.2"
 log = "0.4"
 tracing-log = "0.2"
 [build-dependencies]
 cc = "1"
--- a/crates/wzp-android/src/engine.rs
+++ b/crates/wzp-android/src/engine.rs
@@ -16,8 +16,6 @@ use std::time::Instant;
 use bytes::Bytes;
 use tracing::{error, info, warn};
 use wzp_codec::agc::AutoGainControl;
 use wzp_codec::opus_dec::OpusDecoder;
 use wzp_codec::opus_enc::OpusEncoder;
 use wzp_crypto::{KeyExchange, WarzoneKeyExchange};
 use wzp_fec::{RaptorQFecDecoder, RaptorQFecEncoder};
 use wzp_proto::{
@@ -29,12 +27,19 @@ use crate::audio_ring::AudioRing;
 use crate::commands::EngineCommand;
 use crate::stats::{CallState, CallStats};
-/// Opus frame size at 48kHz mono, 20ms = 960 samples.
+/// Max frame size at 48kHz mono (40ms = 1920 samples, for Codec2/Opus6k).
-const FRAME_SAMPLES: usize = 960;
+const MAX_FRAME_SAMPLES: usize = 1920;
 /// Compute frame samples at 48kHz for a given profile.
 fn frame_samples_for(profile: &QualityProfile) -> usize {
    (profile.frame_duration_ms as usize) * 48 // 48000 / 1000
 }
 /// Configuration to start a call.
 pub struct CallStartConfig {
    pub profile: QualityProfile,
    /// When true, use the relay's chosen_profile from CallAnswer instead of local profile.
    pub auto_profile: bool,
    pub relay_addr: String,
    pub room: String,
    pub auth_token: Vec<u8>,
@@ -46,6 +51,7 @@ impl Default for CallStartConfig {
    fn default() -> Self {
        Self {
            profile: QualityProfile::GOOD,
            auto_profile: false,
            relay_addr: String::new(),
            room: String::new(),
            auth_token: Vec::new(),
@@ -123,6 +129,7 @@ impl WzpEngine {
        let room = config.room.clone();
        let identity_seed = config.identity_seed;
        let profile = config.profile;
        let auto_profile = config.auto_profile;
        let alias = config.alias.clone();
        let state = self.state.clone();
@@ -131,7 +138,7 @@ impl WzpEngine {
        let state_clone = state.clone();
        runtime.block_on(async move {
-            if let Err(e) = run_call(relay_addr, &room, &identity_seed, profile, alias.as_deref(), state_clone).await
+            if let Err(e) = run_call(relay_addr, &room, &identity_seed, profile, auto_profile, alias.as_deref(), state_clone).await
            {
                error!("call failed: {e}");
            }
@@ -169,6 +176,53 @@ impl WzpEngine {
        info!("stop_call: done");
    }
    /// Ping a relay — same pattern as start_call (creates runtime on calling thread).
    /// Returns JSON `{"rtt_ms":N,"server_fingerprint":"hex"}` or error.
    pub fn ping_relay(&self, address: &str) -> Result<String, anyhow::Error> {
        let addr: SocketAddr = address.parse()?;
        let _ = rustls::crypto::ring::default_provider().install_default();
        let rt = tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()?;
        let result = rt.block_on(async {
            let bind: SocketAddr = "0.0.0.0:0".parse().unwrap();
            let endpoint = wzp_transport::create_endpoint(bind, None)?;
            let client_cfg = wzp_transport::client_config();
            let start = Instant::now();
            let conn_result = tokio::time::timeout(
                std::time::Duration::from_secs(3),
                wzp_transport::connect(&endpoint, addr, "ping", client_cfg),
            )
            .await;
            // Always close endpoint to prevent resource leaks
            endpoint.close(0u32.into(), b"done");
            let conn = conn_result.map_err(|_| anyhow::anyhow!("timeout"))??;
            let rtt_ms = start.elapsed().as_millis() as u64;
            let server_fp = conn
                .peer_identity()
                .and_then(|id| id.downcast::<Vec<rustls::pki_types::CertificateDer>>().ok())
                .and_then(|certs| certs.first().map(|c| {
                    use std::hash::{Hash, Hasher};
                    let mut h = std::collections::hash_map::DefaultHasher::new();
                    c.as_ref().hash(&mut h);
                    format!("{:016x}", h.finish())
                }))
                .unwrap_or_default();
            conn.close(0u32.into(), b"ping");
            Ok::<_, anyhow::Error>(format!(r#"{{"rtt_ms":{},"server_fingerprint":"{}"}}"#, rtt_ms, server_fp))
        });
        // Shutdown runtime cleanly with timeout
        rt.shutdown_timeout(std::time::Duration::from_millis(500));
        result
    }
    pub fn set_mute(&self, muted: bool) {
        self.state.muted.store(muted, Ordering::Relaxed);
    }
@@ -227,6 +281,7 @@ async fn run_call(
    room: &str,
    identity_seed: &[u8; 32],
    profile: QualityProfile,
    auto_profile: bool,
    alias: Option<&str>,
    state: Arc<EngineState>,
 ) -> Result<(), anyhow::Error> {
@@ -261,6 +316,9 @@ async fn run_call(
        ephemeral_pub,
        signature,
        supported_profiles: vec![
            QualityProfile::STUDIO_64K,
            QualityProfile::STUDIO_48K,
            QualityProfile::STUDIO_32K,
            QualityProfile::GOOD,
            QualityProfile::DEGRADED,
            QualityProfile::CATASTROPHIC,
@@ -275,8 +333,8 @@ async fn run_call(
        .await?
        .ok_or_else(|| anyhow::anyhow!("connection closed before CallAnswer"))?;
-    let relay_ephemeral_pub = match answer {
+    let (relay_ephemeral_pub, chosen_profile) = match answer {
-        SignalMessage::CallAnswer { ephemeral_pub, .. } => ephemeral_pub,
+        SignalMessage::CallAnswer { ephemeral_pub, chosen_profile, .. } => (ephemeral_pub, chosen_profile),
        other => {
            return Err(anyhow::anyhow!(
                "expected CallAnswer, got {:?}",
@@ -285,19 +343,25 @@ async fn run_call(
        }
    };
    // Auto mode: use the relay's chosen profile instead of the local preference
    let profile = if auto_profile {
        info!(chosen = ?chosen_profile.codec, "auto mode: using relay's chosen profile");
        chosen_profile
    } else {
        profile
    };
    let _session = kx.derive_session(&relay_ephemeral_pub)?;
-    info!("handshake complete, call active");
+    info!(codec = ?profile.codec, "handshake complete, call active");
    {
        let mut stats = state.stats.lock().unwrap();
        stats.state = CallState::Active;
    }
-    // Initialize Opus codec
+    // Initialize codec (Opus or Codec2 based on profile)
-    let mut encoder =
+    let mut encoder = wzp_codec::create_encoder(profile);
-        OpusEncoder::new(profile).map_err(|e| anyhow::anyhow!("opus encoder init: {e}"))?;
+    let mut decoder = wzp_codec::create_decoder(profile);
    let mut decoder =
        OpusDecoder::new(profile).map_err(|e| anyhow::anyhow!("opus decoder init: {e}"))?;
    // Initialize FEC encoder/decoder
    let mut fec_enc = wzp_fec::create_encoder(&profile);
@@ -307,18 +371,22 @@ async fn run_call(
    let mut capture_agc = AutoGainControl::new();
    let mut playout_agc = AutoGainControl::new();
    let frame_samples = frame_samples_for(&profile);
    info!(
        codec = ?profile.codec,
        fec_ratio = profile.fec_ratio,
        frames_per_block = profile.frames_per_block,
-        "codec + FEC + AGC initialized (48kHz mono, 20ms frames)"
+        frame_ms = profile.frame_duration_ms,
        frame_samples,
        "codec + FEC + AGC initialized"
    );
    let seq = AtomicU16::new(0);
    let ts = AtomicU32::new(0);
    let transport_recv = transport.clone();
-    // Pre-allocate buffers
+    // Pre-allocate buffers (sized for current profile)
-    let mut capture_buf = vec![0i16; FRAME_SAMPLES];
+    let mut capture_buf = vec![0i16; frame_samples];
    let mut encode_buf = vec![0u8; encoder.max_frame_bytes()];
    let mut frame_in_block: u8 = 0;
    let mut block_id: u8 = 0;
@@ -348,13 +416,13 @@ async fn run_call(
            }
            let avail = state.capture_ring.available();
-            if avail < FRAME_SAMPLES {
+            if avail < frame_samples {
                tokio::time::sleep(std::time::Duration::from_millis(5)).await;
                continue;
            }
            let read = state.capture_ring.read(&mut capture_buf);
-            if read < FRAME_SAMPLES {
+            if read < frame_samples {
                continue;
            }
@@ -383,7 +451,7 @@ async fn run_call(
            // Build source packet
            let s = seq.fetch_add(1, Ordering::Relaxed);
-            let t = ts.fetch_add(FRAME_SAMPLES as u32, Ordering::Relaxed);
+            let t = ts.fetch_add(frame_samples as u32, Ordering::Relaxed);
            let source_pkt = MediaPacket {
                header: MediaHeader {
@@ -511,8 +579,8 @@ async fn run_call(
        info!(frames_sent, frames_dropped, send_errors, "send task ended");
    };
-    // Pre-allocate decode buffer
+    // Pre-allocate decode buffer (max size to handle any incoming codec)
-    let mut decode_buf = vec![0i16; FRAME_SAMPLES];
+    let mut decode_buf = vec![0i16; MAX_FRAME_SAMPLES];
    // Recv task: MediaPackets → FEC decode → Opus decode → playout ring
    let recv_task = async {
@@ -557,7 +625,27 @@ async fn run_call(
                    );
                    // Source packets: decode directly
-                    if !is_repair {
+                    if !is_repair && pkt.header.codec_id != CodecId::ComfortNoise {
                        // Switch decoder to match incoming codec if different
                        if pkt.header.codec_id != decoder.codec_id() {
                            let switch_profile = match pkt.header.codec_id {
                                CodecId::Opus24k => QualityProfile::GOOD,
                                CodecId::Opus6k => QualityProfile::DEGRADED,
                                CodecId::Opus32k => QualityProfile::STUDIO_32K,
                                CodecId::Opus48k => QualityProfile::STUDIO_48K,
                                CodecId::Opus64k => QualityProfile::STUDIO_64K,
                                CodecId::Codec2_1200 => QualityProfile::CATASTROPHIC,
                                CodecId::Codec2_3200 => QualityProfile {
                                    codec: CodecId::Codec2_3200,
                                    fec_ratio: 0.5,
                                    frame_duration_ms: 20,
                                    frames_per_block: 5,
                                },
                                other => QualityProfile { codec: other, ..QualityProfile::GOOD },
                            };
                            info!(from = ?decoder.codec_id(), to = ?pkt.header.codec_id, "recv: switching decoder");
                            let _ = decoder.set_profile(switch_profile);
                        }
                        match decoder.decode(&pkt.payload, &mut decode_buf) {
                            Ok(samples) => {
                                playout_agc.process_frame(&mut decode_buf[..samples]);
--- a/crates/wzp-android/src/jni_bridge.rs
+++ b/crates/wzp-android/src/jni_bridge.rs
@@ -21,11 +21,24 @@ unsafe fn handle_ref(handle: jlong) -> &'static mut EngineHandle {
    unsafe { &mut *(handle as *mut EngineHandle) }
 }
 /// 7 = auto (use relay's chosen profile)
 const PROFILE_AUTO: jint = 7;
 fn profile_from_int(value: jint) -> QualityProfile {
    match value {
-        1 => QualityProfile::DEGRADED,
+        0 => QualityProfile::GOOD,            // Opus 24k
-        2 => QualityProfile::CATASTROPHIC,
+        1 => QualityProfile::DEGRADED,        // Opus 6k
-        _ => QualityProfile::GOOD,
+        2 => QualityProfile::CATASTROPHIC,    // Codec2 1.2k
        3 => QualityProfile {                 // Codec2 3.2k
            codec: wzp_proto::CodecId::Codec2_3200,
            fec_ratio: 0.5,
            frame_duration_ms: 20,
            frames_per_block: 5,
        },
        4 => QualityProfile::STUDIO_32K,      // Opus 32k
        5 => QualityProfile::STUDIO_48K,      // Opus 48k
        6 => QualityProfile::STUDIO_64K,      // Opus 64k
        _ => QualityProfile::GOOD,            // auto falls back to GOOD
    }
 }
@@ -35,17 +48,24 @@ static INIT_LOGGING: Once = Once::new();
 /// Safe to call multiple times — only the first call takes effect.
 fn init_logging() {
    INIT_LOGGING.call_once(|| {
-        // Use android_logger directly — tracing_subscriber::registry() allocates
+        // Wrap in catch_unwind — sharded_slab allocation inside
-        // a sharded_slab which causes SIGSEGV on Android 16 MTE devices.
+        // tracing_subscriber::registry() can crash on some Android
-        // android_logger is lightweight and doesn't trigger scudo crashes.
+        // devices if scudo malloc fails during early initialization.
        let _ = std::panic::catch_unwind(|| {
-            android_logger::init_once(
+            use tracing_subscriber::layer::SubscriberExt;
-                android_logger::Config::default()
+            use tracing_subscriber::util::SubscriberInitExt;
-                    .with_max_level(log::LevelFilter::Info)
+            use tracing_subscriber::EnvFilter;
-                    .with_tag("wzp"),
+            if let Ok(layer) = tracing_android::layer("wzp_android") {
-            );
+                // Filter: INFO for our crates, WARN for everything else.
-            // Bridge tracing → log so our tracing::info! macros work
+                // The jni crate emits VERBOSE logs for every method lookup
-            let _ = tracing_log::LogTracer::init();
+                // (~10 lines per JNI call, 100+ calls/sec) which floods logcat
                // and causes the system to kill the app.
                let filter = EnvFilter::new("warn,wzp_android=info,wzp_proto=info,wzp_transport=info,wzp_codec=info,wzp_fec=info,wzp_crypto=info");
                let _ = tracing_subscriber::registry()
                    .with(layer)
                    .with(filter)
                    .try_init();
            }
        });
    });
 }
@@ -78,6 +98,7 @@ pub unsafe extern "system" fn Java_com_wzp_engine_WzpEngine_nativeStartCall(
    seed_hex_j: JString,
    token_j: JString,
    alias_j: JString,
    profile_j: jint,
 ) -> jint {
    let result = panic::catch_unwind(panic::AssertUnwindSafe(|| {
        let relay_addr: String = env.get_string(&relay_addr_j).map(|s| s.into()).unwrap_or_default();
@@ -103,7 +124,8 @@ pub unsafe extern "system" fn Java_com_wzp_engine_WzpEngine_nativeStartCall(
        }
        let config = CallStartConfig {
-            profile: QualityProfile::GOOD,
+            profile: profile_from_int(profile_j),
            auto_profile: profile_j == PROFILE_AUTO,
            relay_addr,
            room,
            auth_token: if token.is_empty() { Vec::new() } else { token.into_bytes() },
@@ -311,71 +333,22 @@ pub unsafe extern "system" fn Java_com_wzp_engine_WzpEngine_nativeDestroy(
    }));
 }
-/// Ping a relay server — returns JSON `{"rtt_ms":N,"server_fingerprint":"hex"}` or null on failure.
+/// Ping a relay server — instance method, requires engine handle.
-/// Does NOT require an engine handle — creates a temporary QUIC connection.
+/// Returns JSON `{"rtt_ms":N,"server_fingerprint":"hex"}` or null on failure.
 #[unsafe(no_mangle)]
 pub unsafe extern "system" fn Java_com_wzp_engine_WzpEngine_nativePingRelay<'a>(
    mut env: JNIEnv<'a>,
    _class: JClass,
    handle: jlong,
    relay_j: JString,
 ) -> jstring {
    let result = panic::catch_unwind(panic::AssertUnwindSafe(|| {
        let h = unsafe { handle_ref(handle) };
        let relay: String = env.get_string(&relay_j).map(|s| s.into()).unwrap_or_default();
-        let addr: std::net::SocketAddr = match relay.parse() {
+        match h.engine.ping_relay(&relay) {
-            Ok(a) => a,
+            Ok(json) => Some(json),
-            Err(_) => return None,
+            Err(_) => None,
-        };
+        }
        let _ = rustls::crypto::ring::default_provider().install_default();
        let rt = match tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
        {
            Ok(rt) => rt,
            Err(_) => return None,
        };
        rt.block_on(async {
            let bind: std::net::SocketAddr = "0.0.0.0:0".parse().unwrap();
            let endpoint = match wzp_transport::create_endpoint(bind, None) {
                Ok(e) => e,
                Err(_) => return None,
            };
            let client_cfg = wzp_transport::client_config();
            let start = std::time::Instant::now();
            match tokio::time::timeout(
                std::time::Duration::from_secs(3),
                wzp_transport::connect(&endpoint, addr, "ping", client_cfg),
            )
            .await
            {
                Ok(Ok(conn)) => {
                    let rtt_ms = start.elapsed().as_millis() as u64;
                    let server_fp = conn
                        .peer_identity()
                        .and_then(|id| {
                            id.downcast::<Vec<rustls::pki_types::CertificateDer>>().ok()
                        })
                        .and_then(|certs| {
                            certs.first().map(|c| {
                                use std::hash::{Hash, Hasher};
                                let mut h = std::collections::hash_map::DefaultHasher::new();
                                c.as_ref().hash(&mut h);
                                format!("{:016x}", h.finish())
                            })
                        })
                        .unwrap_or_default();
                    conn.close(0u32.into(), b"ping");
                    Some(format!(
                        r#"{{"rtt_ms":{},"server_fingerprint":"{}"}}"#,
                        rtt_ms, server_fp
                    ))
                }
                _ => None,
            }
        })
    }));
    let json = match result {
--- a/crates/wzp-client/src/handshake.rs
+++ b/crates/wzp-client/src/handshake.rs
@@ -38,6 +38,9 @@ pub async fn perform_handshake(
        ephemeral_pub,
        signature,
        supported_profiles: vec![
            QualityProfile::STUDIO_64K,
            QualityProfile::STUDIO_48K,
            QualityProfile::STUDIO_32K,
            QualityProfile::GOOD,
            QualityProfile::DEGRADED,
            QualityProfile::CATASTROPHIC,
--- a/crates/wzp-codec/src/opus_dec.rs
+++ b/crates/wzp-codec/src/opus_dec.rs
@@ -79,7 +79,7 @@ impl AudioDecoder for OpusDecoder {
    fn set_profile(&mut self, profile: QualityProfile) -> Result<(), CodecError> {
        match profile.codec {
-            CodecId::Opus24k | CodecId::Opus16k | CodecId::Opus6k => {
+            c if c.is_opus() => {
                self.codec_id = profile.codec;
                self.frame_duration_ms = profile.frame_duration_ms;
                Ok(())
--- a/crates/wzp-codec/src/opus_enc.rs
+++ b/crates/wzp-codec/src/opus_enc.rs
@@ -100,7 +100,7 @@ impl AudioEncoder for OpusEncoder {
    fn set_profile(&mut self, profile: QualityProfile) -> Result<(), CodecError> {
        match profile.codec {
-            CodecId::Opus24k | CodecId::Opus16k | CodecId::Opus6k => {
+            c if c.is_opus() => {
                self.codec_id = profile.codec;
                self.frame_duration_ms = profile.frame_duration_ms;
                self.apply_bitrate(profile.codec)?;
--- a/crates/wzp-proto/src/codec_id.rs
+++ b/crates/wzp-proto/src/codec_id.rs
@@ -18,6 +18,12 @@ pub enum CodecId {
    Codec2_1200 = 4,
    /// Comfort noise descriptor (silence suppression)
    ComfortNoise = 5,
    /// Opus at 32kbps (studio low)
    Opus32k = 6,
    /// Opus at 48kbps (studio)
    Opus48k = 7,
    /// Opus at 64kbps (studio high)
    Opus64k = 8,
 }
 impl CodecId {
@@ -27,6 +33,9 @@ impl CodecId {
            Self::Opus24k => 24_000,
            Self::Opus16k => 16_000,
            Self::Opus6k => 6_000,
            Self::Opus32k => 32_000,
            Self::Opus48k => 48_000,
            Self::Opus64k => 64_000,
            Self::Codec2_3200 => 3_200,
            Self::Codec2_1200 => 1_200,
            Self::ComfortNoise => 0,
@@ -36,8 +45,7 @@ impl CodecId {
    /// Preferred frame duration in milliseconds.
    pub const fn frame_duration_ms(self) -> u8 {
        match self {
-            Self::Opus24k => 20,
+            Self::Opus24k | Self::Opus16k | Self::Opus32k | Self::Opus48k | Self::Opus64k => 20,
            Self::Opus16k => 20,
            Self::Opus6k => 40,
            Self::Codec2_3200 => 20,
            Self::Codec2_1200 => 40,
@@ -48,7 +56,8 @@ impl CodecId {
    /// Sample rate expected by this codec.
    pub const fn sample_rate_hz(self) -> u32 {
        match self {
-            Self::Opus24k | Self::Opus16k | Self::Opus6k => 48_000,
+            Self::Opus24k | Self::Opus16k | Self::Opus6k
            | Self::Opus32k | Self::Opus48k | Self::Opus64k => 48_000,
            Self::Codec2_3200 | Self::Codec2_1200 => 8_000,
            Self::ComfortNoise => 48_000,
        }
@@ -63,6 +72,9 @@ impl CodecId {
            3 => Some(Self::Codec2_3200),
            4 => Some(Self::Codec2_1200),
            5 => Some(Self::ComfortNoise),
            6 => Some(Self::Opus32k),
            7 => Some(Self::Opus48k),
            8 => Some(Self::Opus64k),
            _ => None,
        }
    }
@@ -71,6 +83,12 @@ impl CodecId {
    pub const fn to_wire(self) -> u8 {
        self as u8
    }
    /// Returns true if this is an Opus variant.
    pub const fn is_opus(self) -> bool {
        matches!(self, Self::Opus6k | Self::Opus16k | Self::Opus24k
            | Self::Opus32k | Self::Opus48k | Self::Opus64k)
    }
 }
 /// Describes the complete quality configuration for a call session.
@@ -111,6 +129,30 @@ impl QualityProfile {
        frames_per_block: 8,
    };
    /// Studio low: Opus 32kbps, minimal FEC.
    pub const STUDIO_32K: Self = Self {
        codec: CodecId::Opus32k,
        fec_ratio: 0.1,
        frame_duration_ms: 20,
        frames_per_block: 5,
    };
    /// Studio: Opus 48kbps, minimal FEC.
    pub const STUDIO_48K: Self = Self {
        codec: CodecId::Opus48k,
        fec_ratio: 0.1,
        frame_duration_ms: 20,
        frames_per_block: 5,
    };
    /// Studio high: Opus 64kbps, minimal FEC.
    pub const STUDIO_64K: Self = Self {
        codec: CodecId::Opus64k,
        fec_ratio: 0.1,
        frame_duration_ms: 20,
        frames_per_block: 5,
    };
    /// Estimated total bandwidth in kbps including FEC overhead.
    pub fn total_bitrate_kbps(&self) -> f32 {
        let base = self.codec.bitrate_bps() as f32 / 1000.0;
--- a/crates/wzp-relay/Cargo.toml
+++ b/crates/wzp-relay/Cargo.toml
@@ -28,6 +28,7 @@ prometheus = "0.13"
 axum = { version = "0.7", default-features = false, features = ["tokio", "http1", "ws"] }
 tower-http = { version = "0.6", features = ["fs"] }
 futures-util = "0.3"
 dirs = "6"
 [[bin]]
 name = "wzp-relay"
--- a/crates/wzp-relay/src/main.rs
+++ b/crates/wzp-relay/src/main.rs
@@ -13,7 +13,7 @@ use std::sync::Arc;
 use std::time::Duration;
 use tokio::sync::Mutex;
-use tracing::{error, info};
+use tracing::{error, info, warn};
 use wzp_proto::MediaTransport;
 use wzp_relay::config::RelayConfig;
@@ -184,6 +184,21 @@ async fn run_downstream(
    }
 }
 /// Detect a non-loopback IP address from local interfaces.
 /// Prefers public IPs over private (10.x, 172.16-31.x, 192.168.x).
 fn detect_public_ip() -> Option<String> {
    use std::net::UdpSocket;
    // Connect to a public address to find our outbound IP (doesn't actually send anything)
    if let Ok(socket) = UdpSocket::bind("0.0.0.0:0") {
        if socket.connect("8.8.8.8:80").is_ok() {
            if let Ok(addr) = socket.local_addr() {
                return Some(addr.ip().to_string());
            }
        }
    }
    None
 }
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
    let config = parse_args();
@@ -207,11 +222,51 @@ async fn main() -> anyhow::Result<()> {
        tokio::spawn(wzp_relay::metrics::serve_metrics(port, m, p, rr));
    }
-    // Generate ephemeral relay identity for crypto handshake
+    // Load or generate relay identity — persisted in ~/.wzp/relay-identity
-    let relay_seed = wzp_crypto::Seed::generate();
+    let relay_seed = {
        let config_dir = dirs::home_dir()
            .unwrap_or_else(|| std::path::PathBuf::from("."))
            .join(".wzp");
        let identity_path = config_dir.join("relay-identity");
        if identity_path.exists() {
            if let Ok(hex) = std::fs::read_to_string(&identity_path) {
                if let Ok(s) = wzp_crypto::Seed::from_hex(hex.trim()) {
                    info!("loaded relay identity from {}", identity_path.display());
                    s
                } else {
                    warn!("corrupt relay identity file, generating new");
                    let s = wzp_crypto::Seed::generate();
                    let hex: String = s.0.iter().map(|b| format!("{b:02x}")).collect();
                    let _ = std::fs::write(&identity_path, &hex);
                    s
                }
            } else {
                let s = wzp_crypto::Seed::generate();
                let hex: String = s.0.iter().map(|b| format!("{b:02x}")).collect();
                let _ = std::fs::write(&identity_path, &hex);
                s
            }
        } else {
            let s = wzp_crypto::Seed::generate();
            let _ = std::fs::create_dir_all(&config_dir);
            let hex: String = s.0.iter().map(|b| format!("{b:02x}")).collect();
            let _ = std::fs::write(&identity_path, &hex);
            info!("generated relay identity at {}", identity_path.display());
            s
        }
    };
    let relay_fp = relay_seed.derive_identity().public_identity().fingerprint;
    info!(addr = %config.listen_addr, fingerprint = %relay_fp, "WarzonePhone relay starting");
    // Print federation hint with our public IP + listen port
    let listen_port = config.listen_addr.port();
    let public_ip = detect_public_ip();
    if let Some(ip) = &public_ip {
        info!("federation: to peer with this relay, add to peers config:");
        info!("  - url: \"{ip}:{listen_port}\"");
        info!("    fingerprint: \"{relay_fp}\"");
    }
    let (server_config, _cert) = wzp_transport::server_config();
    let endpoint = wzp_transport::create_endpoint(config.listen_addr, Some(server_config))?;
@@ -299,6 +354,13 @@ async fn main() -> anyhow::Result<()> {
            let transport = Arc::new(wzp_transport::QuinnTransport::new(connection));
            // Ping connections: client just measures QUIC connect RTT.
            // No handshake, no streams — client closes immediately after connecting.
            if room_name == "ping" {
                info!(%addr, "ping connection (RTT probe)");
                return;
            }
            // Probe connections use SNI "_probe" to identify themselves.
            // They skip auth + handshake and just do Ping->Pong + presence gossip.
            if room_name == "_probe" {
--- a/docs/PRD-adaptive-quality.md
+++ b/docs/PRD-adaptive-quality.md
@@ -0,0 +1,201 @@
 # PRD: Adaptive Quality Control (Auto Codec)
 ## Problem
 When a user selects "Auto" quality, the system currently just starts at Opus 24k (GOOD) and never changes. There is no runtime adaptation — if the network degrades mid-call, audio breaks up instead of gracefully stepping down to a lower bitrate codec. Conversely, if the network is excellent, the user stays on 24k when they could have studio-quality 64k.
 The relay already sends `QualityReport` messages with loss % and RTT, and a `QualityAdapter` exists in `call.rs` that classifies network conditions into GOOD/DEGRADED/CATASTROPHIC — but none of this is wired into the Android or desktop engines.
 ## Solution
 Wire the existing `QualityAdapter` into both engines so that "Auto" mode continuously monitors network quality and switches codecs mid-call. The full quality range should be used:
 ```
 Excellent network  →  Studio 64k (best quality)
 Good network       →  Opus 24k (default)
 Degraded network   →  Opus 6k (lower bitrate, more FEC)
 Poor network       →  Codec2 3.2k (vocoder, heavy FEC)
 Catastrophic       →  Codec2 1.2k (minimum viable voice)
 ```
 ## Architecture
 ```
                    ┌─────────────────────┐
  Relay ──────────► │  QualityReport      │  loss %, RTT, jitter
                    │  (every ~1s)        │
                    └────────┬────────────┘
                             │
                             ▼
                    ┌─────────────────────┐
                    │  QualityAdapter     │  classify + hysteresis
                    │  (3-report window)  │
                    └────────┬────────────┘
                             │ recommend new profile
                             ▼
              ┌──────────────┴──────────────┐
              │                             │
              ▼                             ▼
     ┌────────────────┐           ┌────────────────┐
     │  Encoder        │           │  Decoder        │
     │  set_profile()  │           │  (auto-switch   │
     │  + FEC update   │           │   already works)│
     └────────────────┘           └────────────────┘
 ```
 ## Existing Infrastructure
 ### What already exists (in `crates/wzp-client/src/call.rs`)
 1. **`QualityAdapter`** (lines 97-196):
   - Sliding window of `QualityReport` messages
   - `classify()`: loss > 15% or RTT > 200ms → CATASTROPHIC, loss > 5% or RTT > 100ms → DEGRADED, else → GOOD
   - `should_switch()`: hysteresis — requires 3 consecutive reports recommending the same profile before switching
   - Prevents oscillation between profiles
 2. **`QualityReport`** (in `wzp-proto/src/packet.rs`):
   - Sent by relay piggy-backed on media packets
   - Fields: `loss_pct` (u8, 0-255 scaled), `rtt_4ms` (u8, RTT in 4ms units), `jitter_ms`, `bitrate_cap_kbps`
 3. **`CallEncoder::set_profile()`** / **`CallDecoder` auto-switch**:
   - Encoder can switch codec mid-stream
   - Decoder already auto-detects incoming codec from packet headers
 ### What's missing
 1. **QualityReport ingestion** — neither Android engine nor desktop engine reads quality reports from the relay
 2. **Profile switch loop** — no periodic check that feeds reports to `QualityAdapter` and applies recommended switches
 3. **Upward adaptation** — `QualityAdapter` only classifies into 3 tiers (GOOD/DEGRADED/CATASTROPHIC). Needs extension to recommend studio tiers when conditions are excellent (loss < 1%, RTT < 50ms)
 4. **Notification to UI** — when quality changes, the UI should show the current active codec
 ## Requirements
 ### Phase 1: Basic Adaptive (3-tier)
 **Both Android and Desktop:**
 1. **Ingest QualityReports**: In the recv loop, extract `quality_report` from incoming `MediaPacket`s when present. Feed to `QualityAdapter`.
 2. **Periodic quality check**: Every 1 second (or on each QualityReport), call `adapter.should_switch(&current_profile)`. If it returns `Some(new_profile)`:
   - Switch the encoder: `encoder.set_profile(new_profile)`
   - Update FEC encoder: `fec_enc = create_encoder(&new_profile)`
   - Update frame size if changed (e.g., 20ms → 40ms)
   - Log the switch
 3. **Frame size adaptation on switch**: When switching from 20ms to 40ms frames (or vice versa):
   - Android: update `frame_samples` variable, resize `capture_buf`
   - Desktop: same — the send loop reads `frame_samples` dynamically
 4. **UI indicator**: Show current active codec in the call screen stats line.
   - Android: add to `CallStats` and display in stats text
   - Desktop: add to `get_status` response and display in stats div
 5. **Only in Auto mode**: Adaptive switching should only happen when the user selected "Auto". If they manually selected a profile, respect their choice.
 ### Phase 2: Extended Range (5-tier)
 Extend `QualityAdapter::classify()` to use the full codec range:
 | Condition | Profile | Codec |
 |-----------|---------|-------|
 | loss < 1% AND RTT < 30ms | STUDIO_64K | Opus 64k |
 | loss < 1% AND RTT < 50ms | STUDIO_48K | Opus 48k |
 | loss < 2% AND RTT < 80ms | STUDIO_32K | Opus 32k |
 | loss < 5% AND RTT < 100ms | GOOD | Opus 24k |
 | loss < 15% AND RTT < 200ms | DEGRADED | Opus 6k |
 | loss >= 15% OR RTT >= 200ms | CATASTROPHIC | Codec2 1.2k |
 With hysteresis:
 - **Downgrade**: 3 consecutive reports (fast reaction to degradation)
 - **Upgrade**: 5 consecutive reports (slow, cautious improvement)
 - **Studio upgrade**: 10 consecutive reports (very conservative — avoid bouncing to 64k on brief good patches)
 ### Phase 3: Bandwidth Probing
 Rather than relying solely on loss/RTT:
 1. Start at GOOD
 2. After 10 seconds of stable call, probe upward by switching to STUDIO_32K
 3. If no quality degradation after 5 seconds, probe to STUDIO_48K
 4. If degradation detected, immediately fall back
 5. This discovers the true available bandwidth rather than guessing from loss stats
 ## Implementation Plan
 ### Android (`crates/wzp-android/src/engine.rs`)
 ```rust
 // In the recv loop, after decoding:
 if let Some(ref qr) = pkt.quality_report {
    quality_adapter.ingest(qr);
 }
 // Periodic check (every 50 frames ≈ 1 second):
 if auto_profile && frames_decoded % 50 == 0 {
    if let Some(new_profile) = quality_adapter.should_switch(&current_profile) {
        info!(from = ?current_profile.codec, to = ?new_profile.codec, "auto: switching quality");
        let _ = encoder_ref.lock().set_profile(new_profile);
        fec_enc_ref.lock() = create_encoder(&new_profile);
        current_profile = new_profile;
        frame_samples = frame_samples_for(&new_profile);
        // Resize capture buffer if needed
    }
 }
 ```
 **Challenge**: The encoder is in the send task and the quality reports arrive in the recv task. Need shared state (AtomicU8 for profile index, or a channel).
 **Recommended approach**: Use an `AtomicU8` that the recv task writes and the send task reads:
 ```rust
 let pending_profile = Arc::new(AtomicU8::new(0xFF)); // 0xFF = no change
 // Recv task: when adapter recommends switch
 pending_profile.store(new_profile_index, Ordering::Release);
 // Send task: check at frame boundary
 let p = pending_profile.swap(0xFF, Ordering::Acquire);
 if p != 0xFF { /* apply switch */ }
 ```
 ### Desktop (`desktop/src-tauri/src/engine.rs`)
 Same pattern. The desktop engine already has separate send/recv tasks with shared atomics for mic_muted, etc. Add a `pending_profile: Arc<AtomicU8>` following the same pattern.
 ### Desktop CLI (`crates/wzp-client/src/call.rs`)
 The `CallEncoder` already has `set_profile()`. The `CallDecoder` already auto-switches. Just need to:
 1. Add `QualityAdapter` to `CallDecoder`
 2. Feed quality reports in `ingest()`
 3. Check `should_switch()` in `decode_next()`
 4. Emit the recommendation via a callback or return value
 ## Testing
 1. **Local test with tc/netem**: Use Linux traffic control to simulate loss/latency:
   ```bash
   # Simulate 10% loss, 150ms RTT
   tc qdisc add dev lo root netem loss 10% delay 75ms
   # Run 2 clients in auto mode, verify they switch to DEGRADED
   ```
 2. **CLI test**: Run `wzp-client --profile auto` between two instances with simulated network conditions
 3. **Relay quality reports**: Verify the relay actually sends QualityReport messages. If it doesn't yet, that needs to be implemented first (check relay code).
 ## Open Questions
 1. **Does the relay currently send QualityReports?** If not, Phase 1 is blocked until the relay implements per-client loss/RTT tracking and report generation. The relay sees all packets and can compute loss % per sender.
 2. **Codec2 3.2k placement**: Should auto mode use Codec2 3.2k between DEGRADED and CATASTROPHIC? It's 20ms frames (lower latency than Opus 6k's 40ms) but speech-only quality.
 3. **Cross-client adaptation**: If client A is on GOOD and client B auto-adapts to CATASTROPHIC, client A still sends Opus 24k. Client B can decode it fine (auto-switch on recv). But should A also be told to lower quality to save B's bandwidth? This requires signaling between clients.
 ## Milestones
 | Phase | Scope | Effort | Dependency |
 |-------|-------|--------|------------|
 | 0 | Verify relay sends QualityReports | 0.5 day | None |
 | 1a | Wire QualityAdapter in Android engine | 1 day | Phase 0 |
 | 1b | Wire QualityAdapter in desktop engine | 1 day | Phase 0 |
 | 1c | UI indicator (current codec) | 0.5 day | Phase 1a/1b |
 | 2 | Extended 5-tier classification | 0.5 day | Phase 1 |
 | 3 | Bandwidth probing | 2 days | Phase 2 |
--- a/docs/PRD-relay-federation.md
+++ b/docs/PRD-relay-federation.md
@@ -0,0 +1,170 @@
 # PRD: Relay Federation (Multi-Relay Mesh)
 ## Problem
 Currently all participants in a call must connect to the same relay. This creates:
 - **Single point of failure** — if the relay goes down, the entire call drops
 - **Geographic latency** — users far from the relay get high RTT
 - **Capacity limits** — one relay handles all traffic
 Users should be able to connect to their nearest/preferred relay and still talk to users on other relays, as long as the relays are federated.
 ## Prerequisite: Fix Relay Identity Persistence
 ### Bug: TLS certificate regenerates on every restart
 **Root cause:** `wzp-transport/src/config.rs:17` calls `rcgen::generate_simple_self_signed()` which creates a new keypair every time. The relay's Ed25519 identity seed IS persisted to `~/.wzp/relay-identity`, but the TLS certificate is not derived from it.
 **Impact:** Clients see a different server fingerprint after every relay restart, triggering the "Server Key Changed" warning. This also breaks federation since relays identify each other by certificate fingerprint.
 **Fix:** Derive the TLS certificate from the persisted relay seed:
 1. Add `server_config_from_seed(seed: &[u8; 32])` to `wzp-transport`
 2. Use the seed to create a deterministic keypair (e.g., derive an ECDSA key via HKDF from the Ed25519 seed)
 3. Generate a self-signed cert with that keypair — same seed = same cert = same fingerprint
 4. The relay passes its loaded seed to `server_config_from_seed()` instead of `server_config()`
 **Effort:** 0.5 day
 ## Federation Design
 ### Core Concept
 Two or more relays form a **federation mesh**. Each relay is an independent SFU. When relays are configured to trust each other, they bridge rooms with matching names — participants on relay A in room "podcast" hear participants on relay B in room "podcast" as if everyone were on the same relay.
 ### Configuration
 Each relay reads a YAML config file (e.g., `~/.wzp/relay.yaml` or `--config relay.yaml`):
 ```yaml
 # Relay identity (auto-generated if missing)
 listen: 0.0.0.0:4433
 # Federation peers — other relays we trust and bridge rooms with
 # Both sides must configure each other for federation to work
 peers:
  - url: "193.180.213.68:4433"
    fingerprint: "a5d6:e3c6:5ae7:185c:4eb1:af89:daed:4a43"
    label: "Pangolin EU"
  - url: "10.0.0.5:4433"
    fingerprint: "7f2a:b391:0c44:..."
    label: "Office LAN"
 ```
 **Key rules:**
 - Both relays must configure each other — **mutual trust** required
 - A relay that receives a connection from an unknown peer logs: `"Relay a5d6:e3c6:... (193.180.213.68) wants to federate. To accept, add to peers config: url: 193.180.213.68:4433, fingerprint: a5d6:e3c6:..."`
 - Fingerprints are verified via the TLS certificate (requires the identity fix above)
 ### Protocol
 #### Peer Connection
 1. On startup, each relay attempts QUIC connections to all configured peers
 2. The connection uses SNI `"_federation"` (reserved room name prefix) to distinguish from client connections
 3. After QUIC handshake, verify the peer's certificate fingerprint matches the configured fingerprint
 4. If fingerprint mismatch → reject, log warning
 5. If peer connects but isn't in our config → log the helpful "add to config" message, reject
 #### Room Bridging
 Once two relays are connected:
 1. **Room discovery**: When a local participant joins room "T", the relay sends a `FederationRoomJoin { room: "T" }` signal to all connected peers
 2. **Room leave**: When the last local participant leaves room "T", send `FederationRoomLeave { room: "T" }`
 3. **Media forwarding**: For each room that exists on both relays:
   - Relay A forwards all media packets from its local participants to relay B
   - Relay B forwards all media packets from its local participants to relay A
   - Each relay then fans out received federated media to its local participants (same as local SFU forwarding)
 4. **Participant presence**: `RoomUpdate` signals are merged — local participants + federated participants from all peers
 ```
 Relay A (2 local users)          Relay B (1 local user)
 ┌─────────────────────┐          ┌─────────────────────┐
 │ Room "T"            │          │ Room "T"            │
 │  Alice (local)  ────┼──media──►│  Charlie (local)    │
 │  Bob   (local)  ────┼──media──►│                     │
 │                     │◄──media──┼── Charlie           │
 │  Charlie (federated)│          │  Alice (federated)  │
 │                     │          │  Bob   (federated)  │
 └─────────────────────┘          └─────────────────────┘
 ```
 #### Signal Messages (new)
 ```rust
 enum FederationSignal {
    /// A room exists on this relay with active participants
    RoomJoin { room: String, participants: Vec<ParticipantInfo> },
    /// Room is empty on this relay
    RoomLeave { room: String },
    /// Participant update for a federated room
    ParticipantUpdate { room: String, participants: Vec<ParticipantInfo> },
 }
 ```
 #### Media Forwarding
 Federated media is forwarded as raw QUIC datagrams — the relay doesn't decode/re-encode. Each packet is prefixed with a room identifier so the receiving relay knows which room to fan it out to:
 ```
 [room_hash: 8 bytes][original_media_packet]
 ```
 The 8-byte room hash is computed once when the federation room bridge is established.
 ### What Relays DON'T Do
 - **No transcoding** — media passes through as-is. If Alice sends Opus 64k, Charlie receives Opus 64k
 - **No re-encryption** — packets are already encrypted end-to-end between participants. Relays just forward opaque bytes
 - **No central coordinator** — each relay independently connects to its configured peers. No master/slave, no consensus protocol
 - **No automatic peer discovery** — peers must be explicitly configured in YAML
 ### Failure Handling
 - If a peer relay goes down, the federation link drops. Local rooms continue to work. Federated participants disappear from presence.
 - Reconnection: attempt every 30 seconds with exponential backoff up to 5 minutes
 - If a peer relay restarts with a new identity (bug not fixed), the fingerprint check fails and federation is rejected with a clear error log
 ## Implementation Plan
 ### Phase 0: Fix Relay Identity (prerequisite)
 - Derive TLS cert from persisted seed
 - Same seed → same cert → same fingerprint across restarts
 ### Phase 1: YAML Config + Peer Connection
 - Add `--config relay.yaml` CLI flag
 - Parse peers config
 - On startup, connect to all configured peers via QUIC
 - Verify certificate fingerprints
 - Log helpful message for unconfigured peers
 - Reconnect on disconnect
 ### Phase 2: Room Bridging
 - Track which rooms exist on each peer
 - Forward media for shared rooms
 - Merge participant presence across peers
 - Handle room join/leave signals
 ### Phase 3: Resilience
 - Graceful handling of peer disconnect/reconnect
 - Don't duplicate packets if a participant is reachable via multiple paths
 - Rate limiting on federation links (prevent amplification)
 - Metrics: federated rooms, packets forwarded, peer latency
 ## Effort Estimates
 | Phase | Scope | Effort |
 |-------|-------|--------|
 | 0 | Fix relay TLS identity from seed | 0.5 day |
 | 1 | YAML config + peer QUIC connections | 2 days |
 | 2 | Room bridging + media forwarding + presence merge | 3-4 days |
 | 3 | Resilience + metrics | 2 days |
 ## Non-Goals (v1)
 - Automatic peer discovery (mDNS, DHT, etc.)
 - Cascading federation (relay A ↔ B ↔ C where A doesn't know C)
 - Load balancing across relays
 - Encryption between relays (QUIC provides transport encryption; e2e encryption between participants is orthogonal)
 - Different rooms on different relays (all federated rooms are bridged by name)
--- a/scripts/Dockerfile.android-builder
+++ b/scripts/Dockerfile.android-builder
@@ -0,0 +1,75 @@
 # =============================================================================
 # WZ Phone — Android build environment (Debian 12 / Bookworm)
 #
 # Matches the bare-metal build-android.sh environment:
 #   - Debian 12 (cmake 3.25, no Android cross-compilation bugs)
 #   - JDK 17 (Gradle 8.5 + AGP 8.2.0 compatible)
 #   - NDK 26.1 (last stable before scudo/MTE crash on NDK 27+)
 #   - Rust stable with aarch64-linux-android target + cargo-ndk
 #
 # Build:  docker build -t wzp-android-builder -f Dockerfile.android-builder .
 # =============================================================================
 FROM debian:bookworm
 ARG NDK_VERSION=26.1.10909125
 ARG ANDROID_API=34
 ENV DEBIAN_FRONTEND=noninteractive \
    ANDROID_HOME=/opt/android-sdk \
    JAVA_HOME=/usr/lib/jvm/java-17-openjdk-amd64
 ENV ANDROID_NDK_HOME=$ANDROID_HOME/ndk/$NDK_VERSION \
    ANDROID_NDK=$ANDROID_HOME/ndk/$NDK_VERSION
 # ── System packages ──────────────────────────────────────────────────────────
 RUN apt-get update && apt-get install -y --no-install-recommends \
        build-essential \
        cmake \
        curl \
        git \
        libssl-dev \
        pkg-config \
        unzip \
        wget \
        zip \
        openjdk-17-jdk-headless \
        ca-certificates \
        libasound2-dev \
    && rm -rf /var/lib/apt/lists/*
 # ── Android SDK + NDK 26.1 ──────────────────────────────────────────────────
 RUN mkdir -p $ANDROID_HOME/cmdline-tools \
    && cd /tmp \
    && wget -q https://dl.google.com/android/repository/commandlinetools-linux-11076708_latest.zip -O cmdtools.zip \
    && unzip -qo cmdtools.zip -d $ANDROID_HOME/cmdline-tools \
    && mv $ANDROID_HOME/cmdline-tools/cmdline-tools $ANDROID_HOME/cmdline-tools/latest \
    && rm cmdtools.zip
 RUN yes | $ANDROID_HOME/cmdline-tools/latest/bin/sdkmanager --licenses > /dev/null 2>&1 \
    && $ANDROID_HOME/cmdline-tools/latest/bin/sdkmanager --install \
        "platforms;android-${ANDROID_API}" \
        "build-tools;${ANDROID_API}.0.0" \
        "ndk;${NDK_VERSION}" \
        "platform-tools" \
        2>&1 | grep -v '^\[' > /dev/null
 # Make SDK world-readable so builder user can access it
 RUN chmod -R a+rX $ANDROID_HOME
 # ── Builder user (1000:1000) ─────────────────────────────────────────────────
 RUN groupadd -g 1000 builder \
    && useradd -m -u 1000 -g 1000 -s /bin/bash builder
 USER builder
 WORKDIR /home/builder
 # ── Rust toolchain ───────────────────────────────────────────────────────────
 RUN curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs \
        | sh -s -- -y --default-toolchain stable \
    && . $HOME/.cargo/env \
    && rustup target add aarch64-linux-android \
    && cargo install cargo-ndk
 ENV PATH="/home/builder/.cargo/bin:$ANDROID_HOME/cmdline-tools/latest/bin:$ANDROID_HOME/platform-tools:$JAVA_HOME/bin:$PATH"
 WORKDIR /build/source
--- a/scripts/build-and-notify.sh
+++ b/scripts/build-and-notify.sh
@@ -0,0 +1,159 @@
 #!/usr/bin/env bash
 set -euo pipefail
 # Build Android APK via Docker on SepehrHomeserverdk, upload to rustypaste,
 # notify via ntfy.sh/wzp. Fire and forget.
 #
 # Usage:
 #   ./scripts/build-and-notify.sh              Build + upload + notify
 #   ./scripts/build-and-notify.sh --rust       Force Rust rebuild
 #   ./scripts/build-and-notify.sh --pull       Git pull before building
 #   ./scripts/build-and-notify.sh --install    Also download + adb install locally
 REMOTE_HOST="SepehrHomeserverdk"
 BASE_DIR="/mnt/storage/manBuilder"
 NTFY_TOPIC="https://ntfy.sh/wzp"
 LOCAL_OUTPUT="target/android-apk"
 SSH_OPTS="-o ConnectTimeout=15 -o ServerAliveInterval=15 -o ServerAliveCountMax=4 -o LogLevel=ERROR"
 REBUILD_RUST=0
 DO_PULL=0
 DO_INSTALL=0
 for arg in "$@"; do
    case "$arg" in
        --rust) REBUILD_RUST=1 ;;
        --pull) DO_PULL=1 ;;
        --install) DO_INSTALL=1 ;;
    esac
 done
 log() { echo -e "\033[1;36m>>> $*\033[0m"; }
 ssh_cmd() { ssh -A $SSH_OPTS "$REMOTE_HOST" "$@"; }
 # Upload the remote build script
 log "Uploading build script to remote..."
 ssh_cmd "cat > /tmp/wzp-docker-build.sh" <<'REMOTE_SCRIPT'
 #!/usr/bin/env bash
 set -euo pipefail
 BASE_DIR="/mnt/storage/manBuilder"
 NTFY_TOPIC="https://ntfy.sh/wzp"
 REBUILD_RUST="${1:-0}"
 DO_PULL="${2:-0}"
 notify() { curl -s -d "$1" "$NTFY_TOPIC" > /dev/null 2>&1 || true; }
 trap 'notify "WZP Android build FAILED! Check /tmp/wzp-build.log"' ERR
 # Pull if requested
 if [ "$DO_PULL" = "1" ]; then
    echo ">>> Pulling latest..."
    cd "$BASE_DIR/data/source"
    git checkout -- . 2>/dev/null || true
    git pull origin feat/android-voip-client 2>&1 | tail -3
 fi
 # Clean Rust if requested
 if [ "$REBUILD_RUST" = "1" ]; then
    echo ">>> Cleaning Rust target..."
    rm -rf "$BASE_DIR/data/cache/target/aarch64-linux-android/release"
 fi
 # Fix perms
 find "$BASE_DIR/data/source" "$BASE_DIR/data/cache" \
    ! -user 1000 -o ! -group 1000 2>/dev/null | \
    xargs -r chown 1000:1000 2>/dev/null || true
 # Clean jniLibs
 rm -rf "$BASE_DIR/data/source/android/app/src/main/jniLibs/arm64-v8a"
 notify "WZP build started..."
 echo ">>> Building in Docker..."
 docker run --rm --user 1000:1000 \
    -v "$BASE_DIR/data/source:/build/source" \
    -v "$BASE_DIR/data/cache/cargo-registry:/home/builder/.cargo/registry" \
    -v "$BASE_DIR/data/cache/cargo-git:/home/builder/.cargo/git" \
    -v "$BASE_DIR/data/cache/target:/build/source/target" \
    -v "$BASE_DIR/data/cache/gradle:/home/builder/.gradle" \
    wzp-android-builder bash -c '
 set -euo pipefail
 cd /build/source
 echo ">>> Rust build..."
 cargo ndk -t arm64-v8a -o android/app/src/main/jniLibs build --release -p wzp-android 2>&1 | tail -5
 echo ">>> Checking .so files..."
 # cargo-ndk may not copy libc++_shared.so — grab it from the NDK if missing
 if [ ! -f android/app/src/main/jniLibs/arm64-v8a/libc++_shared.so ]; then
    echo ">>> libc++_shared.so missing, copying from NDK..."
    NDK_LIBCXX=$(find "$ANDROID_NDK_HOME" -name "libc++_shared.so" -path "*/aarch64-linux-android/*" | head -1)
    if [ -n "$NDK_LIBCXX" ]; then
        cp "$NDK_LIBCXX" android/app/src/main/jniLibs/arm64-v8a/
        echo "Copied from: $NDK_LIBCXX"
    else
        echo "WARNING: libc++_shared.so not found in NDK, APK may crash at runtime"
    fi
 fi
 ls -lh android/app/src/main/jniLibs/arm64-v8a/
 [ -f android/app/src/main/jniLibs/arm64-v8a/libwzp_android.so ] || { echo "ERROR: libwzp_android.so missing!"; exit 1; }
 echo ">>> APK build..."
 cd android && chmod +x gradlew
 ./gradlew clean assembleDebug --no-daemon --warning-mode=none 2>&1 | tail -3
 echo "APK_BUILT"
 '
 # Upload to rustypaste
 echo ">>> Uploading to rustypaste..."
 source "$BASE_DIR/.env"
 APK=$(find "$BASE_DIR/data/source/android" -name "app-debug*.apk" -path "*/outputs/apk/*" | head -1)
 if [ -n "$APK" ]; then
    URL=$(curl -s -F "file=@$APK" -H "Authorization: $rusty_auth_token" "$rusty_address")
    echo "UPLOAD_URL=$URL"
    notify "WZP build done! APK: $URL"
    echo ">>> Done! APK at: $URL"
 else
    notify "WZP build FAILED - no APK"
    echo "ERROR: No APK found"
    exit 1
 fi
 REMOTE_SCRIPT
 ssh_cmd "chmod +x /tmp/wzp-docker-build.sh"
 # Run in tmux
 log "Starting build in tmux..."
 ssh_cmd "tmux kill-session -t wzp-build 2>/dev/null; true"
 ssh_cmd "tmux new-session -d -s wzp-build '/tmp/wzp-docker-build.sh $REBUILD_RUST $DO_PULL 2>&1 | tee /tmp/wzp-build.log'"
 log "Build running! You'll get a notification on ntfy.sh/wzp with the download URL."
 echo ""
 echo "  Monitor:  ssh $REMOTE_HOST 'tail -f /tmp/wzp-build.log'"
 echo "  Status:   ssh $REMOTE_HOST 'tail -5 /tmp/wzp-build.log'"
 echo ""
 # Optionally wait and install locally
 if [ "$DO_INSTALL" = "1" ]; then
    log "Waiting for build to finish..."
    while true; do
        sleep 15
        if ssh_cmd "grep -q 'UPLOAD_URL\|ERROR' /tmp/wzp-build.log 2>/dev/null"; then
            break
        fi
    done
    URL=$(ssh_cmd "grep UPLOAD_URL /tmp/wzp-build.log | tail -1 | cut -d= -f2")
    if [ -n "$URL" ]; then
        log "Downloading APK..."
        mkdir -p "$LOCAL_OUTPUT"
        curl -s -o "$LOCAL_OUTPUT/wzp-debug.apk" "$URL"
        log "Installing..."
        adb uninstall com.wzp.phone 2>/dev/null || true
        adb install "$LOCAL_OUTPUT/wzp-debug.apk"
        log "Done!"
    else
        err "Build failed"
    fi
 fi
--- a/scripts/build-android-docker.sh
+++ b/scripts/build-android-docker.sh
@@ -0,0 +1,416 @@
 #!/usr/bin/env bash
 set -euo pipefail
 # =============================================================================
 # WZ Phone — Android APK build via Docker on remote host
 #
 # Replaces Hetzner Cloud VMs with a Docker container on SepehrHomeserverdk.
 # Persistent storage at /mnt/storage/manBuilder/data/{source,cache,keystore}.
 # Uploads APKs to rustypaste, then SCPs them back locally.
 #
 # Prerequisites:
 #   - SSH config has "SepehrHomeserverdk" host entry
 #   - SSH agent running with keys for both remote host and git.manko.yoga
 #   - Docker installed on remote host
 #   - /mnt/storage/manBuilder/.env with rusty_address and rusty_auth_token
 #
 # Usage:
 #   ./scripts/build-android-docker.sh              Full: prepare+pull+build+upload+transfer
 #   ./scripts/build-android-docker.sh --prepare    Build Docker image + sync keystores
 #   ./scripts/build-android-docker.sh --pull       Clone/update source from Gitea
 #   ./scripts/build-android-docker.sh --build      Build debug APK inside Docker
 #   ./scripts/build-android-docker.sh --upload     Upload APKs to rustypaste
 #   ./scripts/build-android-docker.sh --transfer   SCP APKs back to local machine
 #   ./scripts/build-android-docker.sh --all        pull+build+upload+transfer (image ready)
 #
 #   Add --release to also build release APK:
 #   ./scripts/build-android-docker.sh --build --release
 #   ./scripts/build-android-docker.sh --all --release
 #   ./scripts/build-android-docker.sh --release          (full pipeline, debug+release)
 #
 # Environment variables (all optional):
 #   WZP_BRANCH   Branch to build (default: feat/android-voip-client)
 # =============================================================================
 REMOTE_HOST="SepehrHomeserverdk"
 BASE_DIR="/mnt/storage/manBuilder"
 REPO_URL="ssh://git@git.manko.yoga:222/manawenuz/wz-phone.git"
 BRANCH="${WZP_BRANCH:-feat/android-voip-client}"
 DOCKER_IMAGE="wzp-android-builder"
 LOCAL_OUTPUT_DIR="target/android-apk"
 PROJECT_DIR="$(cd "$(dirname "$0")/.." && pwd)"
 LOCAL_KEYSTORE_DIR="$PROJECT_DIR/android/keystore"
 SSH_OPTS="-o ConnectTimeout=10 -o LogLevel=ERROR -o ServerAliveInterval=15 -o ServerAliveCountMax=4"
 # ---------------------------------------------------------------------------
 # Helpers
 # ---------------------------------------------------------------------------
 log()  { echo -e "\n\033[1;36m>>> $*\033[0m"; }
 err()  { echo -e "\033[1;31mERROR: $*\033[0m" >&2; }
 ssh_cmd() {
    ssh -A $SSH_OPTS "$REMOTE_HOST" "$@"
 }
 push_reminder() {
    echo ""
    echo "  ┌──────────────────────────────────────────────────────────────────┐"
    echo "  │  IMPORTANT: Push your changes to origin (Gitea) before build!   │"
    echo "  │                                                                  │"
    echo "  │  The build fetches from:                                         │"
    echo "  │    ssh://git@git.manko.yoga:222/manawenuz/wz-phone.git          │"
    echo "  │                                                                  │"
    echo "  │  Run:  git push origin $BRANCH"
    echo "  └──────────────────────────────────────────────────────────────────┘"
    echo ""
    read -r -p "Press Enter to continue (Ctrl-C to abort)... "
 }
 # ---------------------------------------------------------------------------
 # --prepare: Create remote dirs, build Docker image, sync keystores
 # ---------------------------------------------------------------------------
 do_prepare() {
    log "Preparing remote environment..."
    ssh_cmd "mkdir -p $BASE_DIR/data/{source,cache/cargo-registry,cache/cargo-git,cache/target,cache/gradle,keystore}"
    # Sync keystores (gitignored — won't exist after clone)
    REMOTE_HAS_KEYSTORE=$(ssh_cmd "[ -f $BASE_DIR/data/keystore/wzp-debug.jks ] && echo yes || echo no")
    if [ "$REMOTE_HAS_KEYSTORE" = "no" ]; then
        if [ -f "$LOCAL_KEYSTORE_DIR/wzp-debug.jks" ]; then
            log "Uploading keystores to remote persistent storage..."
            scp $SSH_OPTS \
                "$LOCAL_KEYSTORE_DIR/wzp-debug.jks" \
                "$LOCAL_KEYSTORE_DIR/wzp-release.jks" \
                "$REMOTE_HOST:$BASE_DIR/data/keystore/"
            echo "  Keystores uploaded to $BASE_DIR/data/keystore/"
        else
            err "No keystores found locally at $LOCAL_KEYSTORE_DIR/"
            err "Build will generate a temporary debug keystore instead."
        fi
    else
        echo "  Keystores already on remote."
    fi
    # Upload Dockerfile from local (always use local version — no git dependency)
    log "Uploading Dockerfile to remote..."
    ssh_cmd "mkdir -p $BASE_DIR/data/source/scripts"
    scp $SSH_OPTS \
        "$PROJECT_DIR/scripts/Dockerfile.android-builder" \
        "$REMOTE_HOST:$BASE_DIR/data/source/scripts/Dockerfile.android-builder"
    # Build Docker image
    log "Building Docker image (Debian 12 + Rust + Android SDK/NDK)..."
    ssh_cmd bash <<IMAGE_EOF
 set -euo pipefail
 docker build -t "$DOCKER_IMAGE" - < "$BASE_DIR/data/source/scripts/Dockerfile.android-builder"
 echo "  Docker image '$DOCKER_IMAGE' ready."
 IMAGE_EOF
 }
 # ---------------------------------------------------------------------------
 # --pull: Clone or update source from Gitea
 # ---------------------------------------------------------------------------
 do_pull() {
    push_reminder
    log "Updating source (branch: $BRANCH)..."
    ssh_cmd bash <<PULL_EOF
 set -euo pipefail
 mkdir -p "$BASE_DIR/data/source" \
         "$BASE_DIR/data/cache/cargo-registry" \
         "$BASE_DIR/data/cache/cargo-git" \
         "$BASE_DIR/data/cache/target" \
         "$BASE_DIR/data/cache/gradle" \
         "$BASE_DIR/data/keystore"
 cd "$BASE_DIR/data/source"
 if [ -d .git ]; then
    echo "  Fetching origin..."
    git fetch origin
    git checkout "$BRANCH" 2>/dev/null || git checkout -b "$BRANCH" "origin/$BRANCH"
    git reset --hard "origin/$BRANCH"
 else
    echo "  Cloning repo..."
    cd "$BASE_DIR/data"
    rm -rf source
    git clone --branch "$BRANCH" "$REPO_URL" source
    cd source
 fi
 git submodule update --init || true
 echo "  HEAD:   \$(git log --oneline -1)"
 echo "  Branch: \$(git branch --show-current)"
 PULL_EOF
    # Inject keystores into source tree
    log "Injecting keystores into source tree..."
    ssh_cmd bash <<KS_EOF
 set -euo pipefail
 mkdir -p "$BASE_DIR/data/source/android/keystore"
 if [ -f "$BASE_DIR/data/keystore/wzp-debug.jks" ]; then
    cp "$BASE_DIR/data/keystore/wzp-debug.jks"   "$BASE_DIR/data/source/android/keystore/"
    cp "$BASE_DIR/data/keystore/wzp-release.jks"  "$BASE_DIR/data/source/android/keystore/"
    echo "  Keystores ready (wzp-debug.jks + wzp-release.jks)"
 else
    echo "  WARNING: No keystores in persistent storage — build will generate temporary ones"
 fi
 KS_EOF
 }
 # ---------------------------------------------------------------------------
 # --build: Build APK inside Docker container
 #   $1 = "1" to also build release APK (default: debug only)
 # ---------------------------------------------------------------------------
 do_build() {
    local build_release="${1:-0}"
    if [ "$build_release" = "1" ]; then
        log "Building debug + release APKs inside Docker container..."
    else
        log "Building debug APK inside Docker container..."
    fi
    ssh_cmd bash <<BUILD_EOF
 set -euo pipefail
 # Ensure uid 1000 can write to mounted volumes
 # Use find to only chown files not already 1000:1000, ignore errors on stubborn files
 find "$BASE_DIR/data/source" "$BASE_DIR/data/cache" \
    ! -user 1000 -o ! -group 1000 2>/dev/null | \
    xargs -r chown 1000:1000 2>/dev/null || true
 docker run --rm \
    --user 1000:1000 \
    -e BUILD_RELEASE="$build_release" \
    -v "$BASE_DIR/data/source:/build/source" \
    -v "$BASE_DIR/data/cache/cargo-registry:/home/builder/.cargo/registry" \
    -v "$BASE_DIR/data/cache/cargo-git:/home/builder/.cargo/git" \
    -v "$BASE_DIR/data/cache/target:/build/source/target" \
    -v "$BASE_DIR/data/cache/gradle:/home/builder/.gradle" \
    "$DOCKER_IMAGE" \
    bash -c '
 set -euo pipefail
 cd /build/source
 echo ">>> Building Rust native library (arm64-v8a, release)..."
 # Clean stale jniLibs so cargo-ndk re-copies libc++_shared.so
 rm -rf android/app/src/main/jniLibs/arm64-v8a
 cargo ndk -t arm64-v8a \
    -o android/app/src/main/jniLibs \
    build --release -p wzp-android 2>&1 | tail -10
 [ -f android/app/src/main/jniLibs/arm64-v8a/libwzp_android.so ] || {
    echo "ERROR: libwzp_android.so not found after build"; exit 1;
 }
 echo "  .so size: \$(du -h android/app/src/main/jniLibs/arm64-v8a/libwzp_android.so | cut -f1)"
 # Verify keystores exist (should have been injected by --pull)
 if [ -f android/keystore/wzp-debug.jks ] && [ -f android/keystore/wzp-release.jks ]; then
    echo "  Keystores: wzp-debug.jks + wzp-release.jks (from persistent storage)"
 else
    echo "WARNING: Keystores missing — generating temporary debug keystore..."
    mkdir -p android/keystore
    keytool -genkey -v \
        -keystore android/keystore/wzp-debug.jks \
        -keyalg RSA -keysize 2048 -validity 10000 \
        -alias wzp-debug -storepass android -keypass android \
        -dname "CN=WZP Debug" 2>&1 | tail -1
    cp android/keystore/wzp-debug.jks android/keystore/wzp-release.jks
 fi
 cd android
 chmod +x ./gradlew
 echo ">>> Building debug APK..."
 ./gradlew assembleDebug --no-daemon --warning-mode=none 2>&1 | tail -5
 if [ "\${BUILD_RELEASE}" = "1" ]; then
    echo ">>> Building release APK..."
    ./gradlew assembleRelease --no-daemon --warning-mode=none 2>&1 | tail -5 || \
        echo "  (release build failed — debug APK still available)"
 fi
 echo ""
 echo ">>> Build artifacts:"
 find . -name "*.apk" -path "*/outputs/apk/*" -exec ls -lh {} \;
 '
 BUILD_EOF
 }
 # ---------------------------------------------------------------------------
 # --upload: Upload APKs to rustypaste
 # ---------------------------------------------------------------------------
 do_upload() {
    log "Uploading APKs to rustypaste..."
    UPLOAD_RESULT=$(ssh_cmd bash <<'UPLOAD_EOF'
 set -euo pipefail
 BASE_DIR="/mnt/storage/manBuilder"
 ENV_FILE="$BASE_DIR/.env"
 if [ ! -f "$ENV_FILE" ]; then
    echo "ERROR: $ENV_FILE not found — create it with rusty_address and rusty_auth_token" >&2
    exit 1
 fi
 source "$ENV_FILE"
 if [ -z "${rusty_address:-}" ] || [ -z "${rusty_auth_token:-}" ]; then
    echo "ERROR: rusty_address or rusty_auth_token not set in $ENV_FILE" >&2
    exit 1
 fi
 upload_apk() {
    local apk="$1" label="$2"
    if [ -f "$apk" ]; then
        local url
        url=$(curl -s -F "file=@$apk" -H "Authorization: $rusty_auth_token" "$rusty_address")
        echo "$label: $url"
    fi
 }
 DEBUG_APK=$(find "$BASE_DIR/data/source/android" -name "app-debug*.apk" -path "*/outputs/apk/*" 2>/dev/null | head -1)
 RELEASE_APK=$(find "$BASE_DIR/data/source/android" -name "app-release*.apk" -path "*/outputs/apk/*" 2>/dev/null | head -1)
 upload_apk "${DEBUG_APK:-}" "debug"
 upload_apk "${RELEASE_APK:-}" "release"
 UPLOAD_EOF
    )
    echo "$UPLOAD_RESULT"
 }
 # ---------------------------------------------------------------------------
 # --transfer: SCP APKs back to local machine
 # ---------------------------------------------------------------------------
 do_transfer() {
    log "Downloading APKs to local machine..."
    mkdir -p "$LOCAL_OUTPUT_DIR"
    # Debug APK
    DEBUG_REMOTE=$(ssh_cmd "find $BASE_DIR/data/source/android -name 'app-debug*.apk' -path '*/outputs/apk/*' 2>/dev/null | head -1" || true)
    if [ -n "$DEBUG_REMOTE" ]; then
        scp $SSH_OPTS "$REMOTE_HOST:$DEBUG_REMOTE" "$LOCAL_OUTPUT_DIR/wzp-debug.apk"
        echo "  debug:   $LOCAL_OUTPUT_DIR/wzp-debug.apk ($(du -h "$LOCAL_OUTPUT_DIR/wzp-debug.apk" | cut -f1))"
    fi
    # Release APK
    RELEASE_REMOTE=$(ssh_cmd "find $BASE_DIR/data/source/android -name 'app-release*.apk' -path '*/outputs/apk/*' 2>/dev/null | head -1" || true)
    if [ -n "$RELEASE_REMOTE" ]; then
        scp $SSH_OPTS "$REMOTE_HOST:$RELEASE_REMOTE" "$LOCAL_OUTPUT_DIR/wzp-release.apk"
        echo "  release: $LOCAL_OUTPUT_DIR/wzp-release.apk ($(du -h "$LOCAL_OUTPUT_DIR/wzp-release.apk" | cut -f1))"
    fi
    # Also grab the .so
    scp $SSH_OPTS "$REMOTE_HOST:$BASE_DIR/data/source/android/app/src/main/jniLibs/arm64-v8a/libwzp_android.so" \
        "$LOCAL_OUTPUT_DIR/libwzp_android.so" 2>/dev/null \
        && echo "  .so:     $LOCAL_OUTPUT_DIR/libwzp_android.so" || true
 }
 # ---------------------------------------------------------------------------
 # Summary banner
 # ---------------------------------------------------------------------------
 show_summary() {
    log "All done!"
    echo ""
    echo "  ┌──────────────────────────────────────────────────────────────┐"
    [ -f "$LOCAL_OUTPUT_DIR/wzp-debug.apk" ] && \
    echo "  │ Debug APK:   $LOCAL_OUTPUT_DIR/wzp-debug.apk"
    [ -f "$LOCAL_OUTPUT_DIR/wzp-release.apk" ] && \
    echo "  │ Release APK: $LOCAL_OUTPUT_DIR/wzp-release.apk"
    echo "  │"
    if [ -n "${UPLOAD_RESULT:-}" ]; then
    echo "  │ Rustypaste:"
    echo "$UPLOAD_RESULT" | while read -r line; do
    echo "  │   $line"
    done
    echo "  │"
    fi
    echo "  │ Install: adb install -r $LOCAL_OUTPUT_DIR/wzp-debug.apk"
    echo "  └──────────────────────────────────────────────────────────────┘"
 }
 # ---------------------------------------------------------------------------
 # Parse arguments
 # ---------------------------------------------------------------------------
 ACTION=""
 BUILD_RELEASE=0
 for arg in "$@"; do
    case "$arg" in
        --release)  BUILD_RELEASE=1 ;;
        --prepare|--pull|--build|--upload|--transfer|--all)
            if [ -n "$ACTION" ]; then
                err "Multiple actions specified: $ACTION and $arg"
                exit 1
            fi
            ACTION="$arg"
            ;;
        *)
            echo "Usage: $0 [--prepare|--pull|--build|--upload|--transfer|--all] [--release]"
            echo ""
            echo "Actions:"
            echo "  (no action)  Full pipeline: pull → prepare → build → upload → transfer"
            echo "  --prepare    Build Docker image + sync keystores to remote"
            echo "  --pull       Clone/update source from Gitea + inject keystores"
            echo "  --build      Build debug APK inside Docker container"
            echo "  --upload     Upload APKs to rustypaste"
            echo "  --transfer   SCP APKs + .so back to local machine"
            echo "  --all        pull → build → upload → transfer (Docker image ready)"
            echo ""
            echo "Flags:"
            echo "  --release    Also build release APK (default: debug only)"
            echo ""
            echo "Examples:"
            echo "  $0                       # full pipeline, debug only"
            echo "  $0 --release             # full pipeline, debug + release"
            echo "  $0 --build               # debug APK only"
            echo "  $0 --build --release     # debug + release APKs"
            echo "  $0 --all                 # iterate: pull+build+upload+transfer (debug)"
            echo "  $0 --all --release       # iterate with release too"
            echo ""
            echo "Environment:"
            echo "  WZP_BRANCH=$BRANCH"
            exit 1
            ;;
    esac
 done
 # ---------------------------------------------------------------------------
 # Dispatch
 # ---------------------------------------------------------------------------
 case "${ACTION:-}" in
    --prepare)
        do_prepare
        ;;
    --pull)
        do_pull
        ;;
    --build)
        do_build "$BUILD_RELEASE"
        ;;
    --upload)
        do_upload
        ;;
    --transfer)
        do_transfer
        ;;
    --all)
        do_pull
        do_build "$BUILD_RELEASE"
        do_upload
        do_transfer
        show_summary
        ;;
    "")
        do_pull
        do_prepare
        do_build "$BUILD_RELEASE"
        do_upload
        do_transfer
        show_summary
        ;;
 esac
--- a/scripts/build-linux-docker.sh
+++ b/scripts/build-linux-docker.sh
@@ -0,0 +1,161 @@
 #!/usr/bin/env bash
 set -euo pipefail
 # Build WarzonePhone Linux x86_64 binaries via Docker on SepehrHomeserverdk.
 # Reuses same Docker image as Android build (has Rust + cmake + build tools).
 # Fire and forget — notifies via ntfy.sh/wzp with rustypaste URL.
 #
 # Usage:
 #   ./scripts/build-linux-docker.sh              Build + upload + notify
 #   ./scripts/build-linux-docker.sh --pull       Git pull before building
 #   ./scripts/build-linux-docker.sh --clean      Clean Rust target cache
 #   ./scripts/build-linux-docker.sh --install    Download binaries locally after build
 REMOTE_HOST="SepehrHomeserverdk"
 BASE_DIR="/mnt/storage/manBuilder"
 NTFY_TOPIC="https://ntfy.sh/wzp"
 LOCAL_OUTPUT="target/linux-x86_64"
 SSH_OPTS="-o ConnectTimeout=15 -o ServerAliveInterval=15 -o ServerAliveCountMax=4 -o LogLevel=ERROR"
 DO_PULL=0
 DO_CLEAN=0
 DO_INSTALL=0
 for arg in "$@"; do
    case "$arg" in
        --pull) DO_PULL=1 ;;
        --clean) DO_CLEAN=1 ;;
        --install) DO_INSTALL=1 ;;
    esac
 done
 log() { echo -e "\033[1;36m>>> $*\033[0m"; }
 err() { echo -e "\033[1;31mERROR: $*\033[0m" >&2; }
 ssh_cmd() { ssh $SSH_OPTS "$REMOTE_HOST" "$@"; }
 # Upload build script to remote
 log "Uploading build script..."
 ssh_cmd "cat > /tmp/wzp-linux-build.sh" <<'REMOTE_SCRIPT'
 #!/usr/bin/env bash
 set -euo pipefail
 BASE_DIR="/mnt/storage/manBuilder"
 NTFY_TOPIC="https://ntfy.sh/wzp"
 DO_PULL="${1:-0}"
 DO_CLEAN="${2:-0}"
 notify() { curl -s -d "$1" "$NTFY_TOPIC" > /dev/null 2>&1 || true; }
 trap 'notify "WZP Linux build FAILED! Check /tmp/wzp-linux-build.log"' ERR
 if [ "$DO_PULL" = "1" ]; then
    echo ">>> Pulling latest..."
    cd "$BASE_DIR/data/source"
    git checkout -- . 2>/dev/null || true
    git pull origin feat/android-voip-client 2>&1 | tail -3
 fi
 if [ "$DO_CLEAN" = "1" ]; then
    echo ">>> Cleaning Linux target cache..."
    rm -rf "$BASE_DIR/data/cache-linux/target"
 fi
 # Ensure cache dirs exist (separate from Android cache)
 mkdir -p "$BASE_DIR/data/cache-linux/target" \
         "$BASE_DIR/data/cache-linux/cargo-registry" \
         "$BASE_DIR/data/cache-linux/cargo-git"
 # Fix perms
 find "$BASE_DIR/data/source" "$BASE_DIR/data/cache-linux" \
    ! -user 1000 -o ! -group 1000 2>/dev/null | \
    xargs -r chown 1000:1000 2>/dev/null || true
 notify "WZP Linux x86_64 build started..."
 echo ">>> Building in Docker..."
 docker run --rm --user 1000:1000 \
    -v "$BASE_DIR/data/source:/build/source" \
    -v "$BASE_DIR/data/cache-linux/cargo-registry:/home/builder/.cargo/registry" \
    -v "$BASE_DIR/data/cache-linux/cargo-git:/home/builder/.cargo/git" \
    -v "$BASE_DIR/data/cache-linux/target:/build/source/target" \
    wzp-android-builder bash -c '
 set -euo pipefail
 cd /build/source
 echo ">>> Building relay + client + web + bench..."
 cargo build --release --bin wzp-relay --bin wzp-client --bin wzp-web --bin wzp-bench 2>&1 | tail -5
 echo ">>> Building audio client..."
 cargo build --release --bin wzp-client --features audio 2>&1 | tail -3
 cp target/release/wzp-client target/release/wzp-client-audio
 cargo build --release --bin wzp-client 2>&1 | tail -3
 echo ">>> Binaries:"
 ls -lh target/release/wzp-relay target/release/wzp-client target/release/wzp-client-audio target/release/wzp-web target/release/wzp-bench
 echo ">>> Packaging..."
 tar czf /tmp/wzp-linux-x86_64.tar.gz \
    -C target/release wzp-relay wzp-client wzp-client-audio wzp-web wzp-bench
 echo "BINARIES_BUILT"
 '
 # Upload to rustypaste
 echo ">>> Uploading to rustypaste..."
 source "$BASE_DIR/.env"
 TARBALL="$BASE_DIR/data/cache-linux/target/release/../../../wzp-linux-x86_64.tar.gz"
 # Docker wrote to /tmp inside container, copy from target mount
 docker run --rm \
    -v "$BASE_DIR/data/cache-linux/target:/build/target" \
    wzp-android-builder bash -c \
    "cp /build/target/release/wzp-relay /build/target/release/wzp-client /build/target/release/wzp-client-audio /build/target/release/wzp-web /build/target/release/wzp-bench /tmp/ && tar czf /tmp/wzp-linux-x86_64.tar.gz -C /tmp wzp-relay wzp-client wzp-client-audio wzp-web wzp-bench && cat /tmp/wzp-linux-x86_64.tar.gz" \
    > /tmp/wzp-linux-x86_64.tar.gz
 URL=$(curl -s -F "file=@/tmp/wzp-linux-x86_64.tar.gz" -H "Authorization: $rusty_auth_token" "$rusty_address")
 if [ -n "$URL" ]; then
    echo "UPLOAD_URL=$URL"
    notify "WZP Linux x86_64 binaries ready! $URL"
    echo ">>> Done! Binaries at: $URL"
 else
    notify "WZP Linux build FAILED - upload error"
    echo "ERROR: upload failed"
    exit 1
 fi
 REMOTE_SCRIPT
 ssh_cmd "chmod +x /tmp/wzp-linux-build.sh"
 # Run in tmux
 log "Starting Linux build in tmux..."
 ssh_cmd "tmux kill-session -t wzp-linux 2>/dev/null; true"
 ssh_cmd "tmux new-session -d -s wzp-linux '/tmp/wzp-linux-build.sh $DO_PULL $DO_CLEAN 2>&1 | tee /tmp/wzp-linux-build.log'"
 log "Build running! Notification on ntfy.sh/wzp when done."
 echo ""
 echo "  Monitor:  ssh $REMOTE_HOST 'tail -f /tmp/wzp-linux-build.log'"
 echo "  Status:   ssh $REMOTE_HOST 'tail -5 /tmp/wzp-linux-build.log'"
 echo ""
 # Optionally wait and download
 if [ "$DO_INSTALL" = "1" ]; then
    log "Waiting for build..."
    while true; do
        sleep 15
        if ssh_cmd "grep -q 'UPLOAD_URL\|ERROR' /tmp/wzp-linux-build.log 2>/dev/null"; then
            break
        fi
    done
    URL=$(ssh_cmd "grep UPLOAD_URL /tmp/wzp-linux-build.log | tail -1 | cut -d= -f2")
    if [ -n "$URL" ]; then
        log "Downloading binaries..."
        mkdir -p "$LOCAL_OUTPUT"
        curl -s -o "$LOCAL_OUTPUT/wzp-linux-x86_64.tar.gz" "$URL"
        tar xzf "$LOCAL_OUTPUT/wzp-linux-x86_64.tar.gz" -C "$LOCAL_OUTPUT/"
        rm "$LOCAL_OUTPUT/wzp-linux-x86_64.tar.gz"
        ls -lh "$LOCAL_OUTPUT"/wzp-*
        log "Done! Binaries in $LOCAL_OUTPUT/"
    else
        err "Build failed"
    fi
 fi
--- a/scripts/build-linux-notify.sh
+++ b/scripts/build-linux-notify.sh
@@ -0,0 +1,122 @@
 #!/usr/bin/env bash
 set -euo pipefail
 # Build WarzonePhone Linux x86_64 binaries via Hetzner Cloud VPS.
 # Fire and forget — notifies via ntfy.sh/wzp with rustypaste URL.
 #
 # Usage:
 #   ./scripts/build-linux-notify.sh              Full: create VM → build → upload → notify → destroy
 #   ./scripts/build-linux-notify.sh --keep       Keep VM after build
 #   ./scripts/build-linux-notify.sh --pull       Git pull (for existing VM)
 SSH_KEY_NAME="wz"
 SSH_KEY_PATH="/Users/manwe/CascadeProjects/wzp"
 SERVER_TYPE="cx33"
 IMAGE="debian-12"
 SERVER_NAME="wzp-linux-builder"
 NTFY_TOPIC="https://ntfy.sh/wzp"
 LOCAL_OUTPUT="target/linux-x86_64"
 PROJECT_DIR="$(cd "$(dirname "$0")/.." && pwd)"
 SSH_OPTS="-o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null -o ConnectTimeout=15 -o ServerAliveInterval=15 -o LogLevel=ERROR"
 KEEP_VM=0
 DO_PULL=0
 for arg in "$@"; do
    case "$arg" in
        --keep) KEEP_VM=1 ;;
        --pull) DO_PULL=1 ;;
    esac
 done
 log() { echo -e "\033[1;36m>>> $*\033[0m"; }
 err() { echo -e "\033[1;31mERROR: $*\033[0m" >&2; }
 get_vm_ip() {
    hcloud server list -o columns=name,ipv4 -o noheader 2>/dev/null | grep "$SERVER_NAME" | awk '{print $2}' | tr -d ' '
 }
 ssh_cmd() {
    local ip=$(get_vm_ip)
    [ -n "$ip" ] || { err "No VM found"; exit 1; }
    ssh $SSH_OPTS -i "$SSH_KEY_PATH" "root@$ip" "$@"
 }
 notify() { curl -s -d "$1" "$NTFY_TOPIC" > /dev/null 2>&1 || true; }
 # --- Create VM if needed ---
 existing=$(hcloud server list -o columns=name -o noheader 2>/dev/null | grep "$SERVER_NAME" | tr -d ' ' || true)
 if [ -z "$existing" ]; then
    log "Creating Hetzner VM ($SERVER_TYPE, $IMAGE)..."
    hcloud server create --name "$SERVER_NAME" --type "$SERVER_TYPE" --image "$IMAGE" --ssh-key "$SSH_KEY_NAME" --location fsn1 --quiet
    log "Waiting for SSH..."
    ip=$(get_vm_ip)
    for i in $(seq 1 30); do
        ssh $SSH_OPTS -i "$SSH_KEY_PATH" "root@$ip" "echo ok" &>/dev/null && break
        sleep 2
    done
    log "Installing deps..."
    ssh_cmd "apt-get update -qq && apt-get install -y -qq build-essential cmake pkg-config libasound2-dev libssl-dev curl git > /dev/null 2>&1"
    ssh_cmd "curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh -s -- -y --default-toolchain stable > /dev/null 2>&1"
 fi
 # --- Upload source ---
 log "Uploading source..."
 ip=$(get_vm_ip)
 rsync -az --delete \
    --exclude='target' --exclude='.git' --exclude='.claude' \
    --exclude='node_modules' --exclude='dist' --exclude='android/app/build' \
    -e "ssh $SSH_OPTS -i $SSH_KEY_PATH" \
    "$PROJECT_DIR/" "root@$ip:/root/wzp-build/"
 # --- Build ---
 log "Building all binaries..."
 notify "WZP Linux build started..."
 ssh_cmd "source ~/.cargo/env && cd /root/wzp-build && \
    cargo build --release --bin wzp-relay --bin wzp-client --bin wzp-web --bin wzp-bench 2>&1 | tail -5 && \
    echo '--- audio client ---' && \
    cargo build --release --bin wzp-client --features audio 2>&1 | tail -3 && \
    cp target/release/wzp-client target/release/wzp-client-audio && \
    cargo build --release --bin wzp-client 2>&1 | tail -3 && \
    echo 'BUILD_DONE' && \
    ls -lh target/release/wzp-relay target/release/wzp-client target/release/wzp-client-audio target/release/wzp-web target/release/wzp-bench"
 # --- Package + upload to rustypaste ---
 log "Packaging and uploading..."
 UPLOAD_URL=$(ssh_cmd "cd /root/wzp-build && \
    tar czf /tmp/wzp-linux-x86_64.tar.gz \
        -C target/release wzp-relay wzp-client wzp-client-audio wzp-web wzp-bench \
        -C /root/wzp-build/crates/wzp-web/static index.html audio-processor.js 2>/dev/null && \
    curl -s -F 'file=@/tmp/wzp-linux-x86_64.tar.gz' \
        -H 'Authorization: DAxAAGghkn1WKv1+RpPKkg==' \
        https://paste.dk.manko.yoga")
 if [ -n "$UPLOAD_URL" ]; then
    notify "WZP Linux binaries ready! $UPLOAD_URL"
    log "Uploaded: $UPLOAD_URL"
 else
    notify "WZP Linux build FAILED"
    err "Upload failed"
 fi
 # --- Transfer locally ---
 log "Downloading binaries..."
 mkdir -p "$LOCAL_OUTPUT"
 for bin in wzp-relay wzp-client wzp-client-audio wzp-web wzp-bench; do
    scp $SSH_OPTS -i "$SSH_KEY_PATH" "root@$ip:/root/wzp-build/target/release/$bin" "$LOCAL_OUTPUT/$bin" 2>/dev/null
 done
 ls -lh "$LOCAL_OUTPUT"/wzp-*
 # --- Cleanup ---
 if [ "$KEEP_VM" = "1" ]; then
    log "VM kept alive. Destroy: hcloud server delete $SERVER_NAME"
 else
    log "Destroying VM..."
    hcloud server delete "$SERVER_NAME"
 fi
 log "Done!"
 echo "  Deploy: scp $LOCAL_OUTPUT/wzp-relay user@server:~/wzp/"
--- a/skills-lock.json
+++ b/skills-lock.json
@@ -0,0 +1,10 @@
 {
  "version": 1,
  "skills": {
    "caveman": {
      "source": "JuliusBrussee/caveman",
      "sourceType": "github",
      "computedHash": "aa7939fc4d1fe31484090290da77f2d21e026aa4b34b329d00e6630feb985d75"
    }
  }
 }
Author	SHA1	Message	Date
Siavash Sameni	0a05e62c7f	feat: relay prints federation peering config on startup Some checks failed Mirror to GitHub / mirror (push) Failing after 37s Details Build Release Binaries / build-amd64 (push) Failing after 1m50s Details On startup, the relay detects its outbound IP (via UDP socket trick) and prints a ready-to-copy YAML snippet for other relays to federate: federation: to peer with this relay, add to peers config: - url: "193.180.213.68:4433" fingerprint: "a5d6:e3c6:..." Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 21:37:10 +04:00
Siavash Sameni	b97f32ce46	docs: PRD for relay federation (multi-relay mesh) + identity fix Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 1m53s Details Documents the relay TLS identity bug (cert regenerates on restart because server_config() creates a new keypair every time, ignoring the persisted Ed25519 seed) and the full federation design: - YAML config with mutual peer trust (url + fingerprint) - QUIC connections between peers, fingerprint verification - Room bridging: media forwarding for shared room names - Merged participant presence across relays - Helpful log message for unconfigured peer connection attempts - No transcoding, no re-encryption, no central coordinator Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 21:33:05 +04:00
Siavash Sameni	d66d583583	docs: PRD for adaptive quality control (auto codec) Some checks failed Mirror to GitHub / mirror (push) Failing after 38s Details Build Release Binaries / build-amd64 (push) Failing after 1m55s Details Covers the full design for runtime codec switching based on network conditions: 3-tier basic (GOOD/DEGRADED/CATASTROPHIC), extended 5-tier with studio levels, and bandwidth probing. Details the existing QualityAdapter infrastructure, what's missing (report ingestion, profile switch loop, cross-task signaling via AtomicU8), and implementation plan for both Android and desktop engines. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 21:25:33 +04:00
Siavash Sameni	d06cf66538	fix: auto codec, force-ping button, relay delete button Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 1m57s Details 1. Auto codec: new "Auto" position on quality slider (JNI index 7). When selected, the engine uses the relay's chosen_profile from CallAnswer instead of the local preference. Slider now has 8 positions: Studio 64k → Auto → Codec2 1.2k. 2. Force ping: added refresh button (↻) in Manage Relays dialog header. Calls pingAllServers() to re-check all relays on demand. 3. Delete relay fix: the X button was inside a Surface(onClick=...) which swallowed the touch event. Replaced with a separate Surface that properly intercepts the click. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 21:22:24 +04:00
Siavash Sameni	c8bcc5c974	fix: advertise studio profiles in handshake supported_profiles Some checks failed Build Release Binaries / build-amd64 (push) Failing after 2m7s Details Mirror to GitHub / mirror (push) Failing after 35s Details The CallOffer only advertised GOOD/DEGRADED/CATASTROPHIC. When a client uses a studio profile, the relay's choose_profile couldn't pick it. Now advertises all 6 profiles (studio 64k/48k/32k + good + degraded + catastrophic) in both Android engine and shared handshake. Also: the relay MUST be rebuilt with the new CodecId variants, otherwise it will fail to deserialize CallOffer messages containing studio QualityProfiles in supported_profiles. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 19:39:31 +04:00
Siavash Sameni	760126b6ab	fix: remove duplicate Kotlin imports causing build failure Some checks failed Mirror to GitHub / mirror (push) Failing after 39s Details Build Release Binaries / build-amd64 (push) Failing after 2m5s Details Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 19:17:33 +04:00
Siavash Sameni	53f8bf8fff	feat: full quality tiers + slider UI + key-change warning on Android Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 1m52s Details 1. Wire protocol: add Opus 32k/48k/64k (CodecId 6/7/8) + STUDIO profiles with is_opus() helper. Opus enc/dec accept all Opus variants. 2. JNI bridge: expand profile_from_int to 7 levels (0-6) mapping to GOOD, DEGRADED, CATASTROPHIC, Codec2_3200, STUDIO_32K/48K/64K. 3. Settings UI: replace radio buttons with Material3 Slider — 7 stops from Studio 64k (green) to Codec2 1.2k (dark red), matching desktop. 4. Key-change warning: AlertDialog on connect when server fingerprint has changed. Shows old vs new fingerprint, Accept New Key or Cancel. Accepting saves the new fingerprint and proceeds with the call. 5. Engine recv: handle studio codec IDs in auto-switch path. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 19:11:29 +04:00
Siavash Sameni	b3cdad0c75	fix: copy libc++_shared.so from NDK when cargo-ndk skips it Some checks failed Mirror to GitHub / mirror (push) Failing after 37s Details Build Release Binaries / build-amd64 (push) Failing after 1m58s Details cargo-ndk doesn't always copy libc++_shared.so into jniLibs. The build script now finds it in the NDK and copies it manually if missing, preventing the build check from failing. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 18:06:28 +04:00
Siavash Sameni	fa3c7f1cef	fix: dynamic frame sizing for non-default quality profiles on Android Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 1m58s Details The send loop was hardcoded to 960 samples (20ms/Opus24k), causing DEGRADED (Opus 6k, 40ms) and CATASTROPHIC (Codec2 1200, 40ms) to fail — the encoder needed 1920 samples but only got 960. Changes: - capture_buf, ring read threshold, and timestamp increment are now computed from profile.frame_duration_ms (960 for 20ms, 1920 for 40ms) - decode_buf sized to MAX_FRAME_SAMPLES (1920) to handle any incoming codec - recv codec switch now uses correct QualityProfile per codec (was inheriting original profile's frame_duration_ms, breaking cross-codec) - added ComfortNoise guard on recv path Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 18:00:27 +04:00
Siavash Sameni	68b56d9172	fix: ping every 5min (was 5s), clean endpoint on failure, never block connect Some checks failed Mirror to GitHub / mirror (push) Failing after 39s Details Build Release Binaries / build-amd64 (push) Failing after 3m45s Details - Ping interval: 5 minutes (was 5 seconds — too aggressive) - Rust ping_relay: explicitly close endpoint + shutdown runtime on failure - Connect button works regardless of ping status (never blocked) - Ping failure doesn't corrupt engine state Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:40:14 +04:00
Siavash Sameni	7973c8c6a3	fix: ntfy failure notification on build error (trap ERR) Some checks failed Mirror to GitHub / mirror (push) Failing after 38s Details Build Release Binaries / build-amd64 (push) Failing after 3m58s Details Both Android and Linux build scripts now send ntfy notification when build fails, not just on success. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:23:32 +04:00
Siavash Sameni	3e9539e5da	fix: add libasound2-dev to Docker image for Linux audio builds Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 4m16s Details Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:16:39 +04:00
Siavash Sameni	a1ccb3f390	feat: Linux x86_64 fire-and-forget Docker build on SepehrHomeserverdk Some checks failed Mirror to GitHub / mirror (push) Failing after 41s Details Build Release Binaries / build-amd64 (push) Failing after 4m2s Details Same Docker image as Android build. Separate cache dirs (cache-linux/) to avoid conflicts when running both builds simultaneously. Builds: wzp-relay, wzp-client, wzp-client-audio, wzp-web, wzp-bench Uploads tar.gz to rustypaste, notifies ntfy.sh/wzp. Usage: ./scripts/build-linux-docker.sh --pull # fire and forget ./scripts/build-linux-docker.sh --pull --install # wait + download Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:09:01 +04:00
Siavash Sameni	7751439e2b	feat: relay identity persistence + Linux build script Some checks failed Mirror to GitHub / mirror (push) Failing after 40s Details Build Release Binaries / build-amd64 (push) Has been cancelled Details Relay identity: - Stored in ~/.wzp/relay-identity (hex-encoded 32-byte seed) - Generated on first run, reused on restart - Fingerprint stays consistent across relay restarts Linux build script (scripts/build-linux-notify.sh): - Fire and forget: Hetzner VM → build all binaries → upload to rustypaste → ntfy notify → destroy VM - Builds: wzp-relay, wzp-client, wzp-client-audio, wzp-web, wzp-bench - Packages as tar.gz, uploads to rustypaste - --keep flag to preserve VM Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:05:49 +04:00
Siavash Sameni	20bc290c18	fix: relay handles ping connections gracefully (no timeout errors) Some checks failed Mirror to GitHub / mirror (push) Failing after 36s Details Build Release Binaries / build-amd64 (push) Failing after 4m0s Details Relay recognizes SNI "ping" and returns immediately — no handshake, no stream accept, no timeout error logs. Client closes after QUIC connect for RTT measurement. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 11:01:03 +04:00
Siavash Sameni	a8dc350a65	feat: codec selection in settings (Opus / Opus Low / Codec2) Some checks failed Mirror to GitHub / mirror (push) Failing after 41s Details Build Release Binaries / build-amd64 (push) Failing after 3m41s Details - Settings UI: radio buttons for encode codec selection - Persisted via SettingsRepository - Passed through WzpEngine.startCall(profile=) → JNI → Rust CallStartConfig - Decode always accepts all codecs (per-packet codec_id switch) - 0 = Opus 24k (GOOD), 1 = Opus 6k (DEGRADED), 2 = Codec2 1.2k (CATASTROPHIC) Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 10:50:01 +04:00
Siavash Sameni	00fa109f07	feat: codec2 support — adaptive encoder/decoder, per-packet codec switch Some checks failed Mirror to GitHub / mirror (push) Failing after 33s Details Build Release Binaries / build-amd64 (push) Failing after 3m57s Details Android engine: - Use wzp_codec::create_encoder/create_decoder (factory) instead of hardcoded OpusEncoder/OpusDecoder - Recv path: auto-switch decoder based on incoming packet's codec_id - Supports mixed-codec rooms (one client Opus, another Codec2) Desktop client already uses factory functions — no changes needed. Codec selection via QualityProfile: - GOOD: Opus 24kbps - DEGRADED: Opus 6kbps - CATASTROPHIC: Codec2 1200bps Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 10:34:14 +04:00
Siavash Sameni	1e40dec468	feat: periodic server ping every 5s while app is open Some checks failed Mirror to GitHub / mirror (push) Failing after 40s Details Build Release Binaries / build-amd64 (push) Failing after 3m53s Details Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 10:13:51 +04:00
Siavash Sameni	aecef0905d	feat: fire-and-forget build script with ntfy + rustypaste Some checks failed Mirror to GitHub / mirror (push) Failing after 37s Details Build Release Binaries / build-amd64 (push) Failing after 3m59s Details - Uploads build script to remote, runs in tmux (survives SSH drop) - Builds Rust + APK in Docker - Validates both .so files present before APK build - Uploads APK to rustypaste - Sends ntfy.sh/wzp notification with download URL - --install flag: waits + downloads + adb installs locally - --rust flag: force clean Rust rebuild - --pull flag: git pull before building Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 10:00:49 +04:00
Siavash Sameni	18f7faa279	fix: ping as engine instance method — same lifecycle as call Some checks failed Mirror to GitHub / mirror (push) Failing after 7s Details Build Release Binaries / build-amd64 (push) Failing after 19s Details Ping was a static JNI method that loaded the .so before nativeInit, crashing jemalloc. Now ping is an instance method on WzpEngine: - Engine is created once (nativeInit), reused for both ping and call - pingRelay() uses same tokio runtime pattern as startCall() - Auto-pings all servers on app launch (after engine init) - No process restart needed - TOFU fingerprints saved on first successful ping Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 09:49:33 +04:00
Siavash Sameni	eeb85aeac2	feat: ping-and-exit for server RTT, remove broken UDP ping Some checks failed Mirror to GitHub / mirror (push) Failing after 38s Details Build Release Binaries / build-amd64 (push) Failing after 3m38s Details - Ping button: pings all servers via native QUIC, saves RTT + fingerprint to SharedPreferences, then exits process (System.exit) - On restart: loads saved ping results (no native .so loading needed) - Avoids jemalloc crash: native lib only loaded once per process lifetime - Removed broken UDP probe (QUIC servers don't respond to it) - SettingsRepository: savePingRtt/loadPingRtt for cached results - PingResult: added reachable field Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 09:31:02 +04:00
Siavash Sameni	00b405aa87	feat: debug recording off by default, toggle in settings Some checks failed Mirror to GitHub / mirror (push) Failing after 38s Details Build Release Binaries / build-amd64 (push) Failing after 3m57s Details - AudioPipeline.debugRecording defaults to false (was true) - SettingsRepository: persist debug_recording preference - CallViewModel: debugRecording StateFlow + setter, wired to AudioPipeline - Only records PCM + RMS when explicitly enabled in settings Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 09:01:43 +04:00
Siavash Sameni	d09e21965e	feat: pure Kotlin UDP ping — periodic every 5s, no JNI crash Some checks failed Mirror to GitHub / mirror (push) Failing after 38s Details Build Release Binaries / build-amd64 (push) Failing after 3m35s Details Replace WzpEngine.pingRelay() (JNI, loads native .so, crashes jemalloc on Android 16 MTE) with pure Kotlin DatagramSocket UDP probe. - RelayPinger: sends QUIC Version Negotiation trigger packet, measures RTT from response. No native lib, no JNI, zero crash risk. - Periodic: pings all servers every 5 seconds via coroutine - Server fingerprint: filled lazily on first real QUIC connection (TOFU still works, just delayed) - Lock status: OFFLINE when ping fails, NEW until first connection Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 08:57:27 +04:00
Siavash Sameni	97bcc79f9b	feat: desktop-style UI + docker build scripts, fix ping crash Some checks failed Mirror to GitHub / mirror (push) Failing after 39s Details Build Release Binaries / build-amd64 (push) Failing after 4m3s Details - InCallScreen rewrite matching desktop dark theme layout - Removed auto-ping LaunchedEffect (loading native .so early via pingRelay crashes jemalloc on Android 16 MTE) - Added Docker build scripts (Dockerfile.android-builder + build-android-docker.sh) Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-04-07 08:19:45 +04:00