Bump version to 1.0.14 (16)

tryConnectOnce игнорировала результат runTcpLoop и всегда возвращала true,
из-за чего reconnectLoop не делал паузу и переподключался заново каждые
~30 мс, заваливая сервер MSG_ERROR 'Access denied'. Теперь возвращаем
!running, поэтому после разрыва/отказа выдерживается RECONNECT_DELAY_MS.

README.md

@@ -7,17 +7,69 @@ Android-клиент для подключения к рефлекторам **S
 - Подключение к рефлектору SVXLink по протоколу v2 с авторизацией по AUTH_KEY
 - Выбор группы вещания (TG) — по умолчанию 11
 - Голосовая связь в формате **Opus** (8 кГц, моно) через UDP
-- Кнопка PTT (Push-To-Talk) — удерживайте, чтобы говорить
-- Индикаторы уровня передачи и приёма
-- Отображение текущего говорящего
+- Кнопка PTT (Push-To-Talk) в стиле Zello — крупная, с градиентом и тенью; удерживайте, чтобы говорить
+- Индикаторы уровня передачи (микрофон) и приёма (S-метры)
+- **Статистика приёма** (потери, %, и джиттер, мс) — включается в скрытых настройках звука
+- **Выбор битрейта передачи** — Авто (адаптация под качество канала) либо фиксированный 6–32 кбит/с (скрытые настройки звука)
+- **Мониторинг групп** — кнопка наушников: прослушивание выбранных групп с автоматическим возвратом к базовой после паузы
+- **Запись приёма в OGG** с пропуском тишины (подробности ниже)
+- Строка текущего говорящего между блоками экрана:
+  - при приёме — `Говорит UA1ZBE-M TG12`
+  - без приёма — `UA1ZBE-M TG12` (последний говоривший)
 - Автоматическое переподключение при обрыве связи
+- Уведомления о входе/выходе участников (опционально)
 - Позывной регистронезависимый: `ua1zbe-m` автоматически преобразуется в `UA1ZBE-M` для отправки на сервер
 
+## Запись приёма
+
+- Кнопка записи расположена между позывным и кнопкой мониторинга групп.
+- **Короткое нажатие** — начать/остановить запись. Файл сохраняется в
+  `Android/data/ru.ua1zbe.svxremote/files/recordings/rec_ГГГГ-ММ-ДД_ЧЧ-ММ-СС.ogg`.
+- Записывается только реальный приём: паузы в эфире (тишина) в файл не попадают,
+  реплики склеиваются без разрывов.
+- **Удержание кнопки 3 секунды** — открывается список записей: воспроизведение
+  (повторный тап останавливает) и удаление с подтверждением. Если записей нет —
+  выводится подсказка.
+
+## Скрытые настройки звука
+
+Открываются тройным тапом по заголовку «SVXHomyak» на главном экране. Позволяют:
+
+- включить/выключить отображение статистики приёма (потери/джиттер);
+- выбрать битрейт передачи (Авто или 6–32 кбит/с).
+
 ## Требования
 
 - Android 8.0 (API 26) и выше
 - Доступ к сети и микрофону
 - Рефлектор SVXLink с включённой поддержкой протокола v2 (AUTH_KEY)
+- Для push-уведомлений: установить и авторизоваться в приложении **RuStore** на устройстве (оно является дистрибьютором пуша)
+
+## Push-уведомления (RuStore)
+
+Приложение интегрировано с [RuStore Push SDK](https://www.rustore.ru/help/sdk/push-notifications) (аналог Firebase Cloud Messaging). Для доставки на устройстве должен быть установлен и авторизован RuStore (или приложение-дистрибьютор экосистемы VK).
+
+Рассылка выполняется с сервера через API RuStore:
+
+```
+POST https://vkpns.rustore.ru/v1/projects/{project_id}/messages:send
+Authorization: Bearer {service-token}
+Content-Type: application/json
+
+{
+  "message": {
+    "token": "{push-token устройства}",
+    "notification": {
+      "title": "Говорит UA1ZBE1 TG12",
+      "body": "..."
+    }
+  }
+}
+```
+
+- `project_id` и `service-token` берутся в консоли RuStore: **Push-уведомления > Проекты**.
+- `push-token` устройства приходит в callback `onNewToken` (лог `RuStorePush`), сохраняется в настройках приложения.
+- Если в запросе есть секция `notification` — уведомление отображает сам SDK; если переданы только `data` (`title`/`body`) — приложение показывает его самостоятельно.
 
 ## Установка
 
@@ -43,16 +95,24 @@ Android-клиент для подключения к рефлекторам **S
 
 APK появится в `app/build/outputs/apk/debug/app-debug.apk`.
 
+Для сборки релизного (подписанного) APK:
+
+```bash
+./gradlew :app:assembleRelease
+# далее выровнять и подписать через build-tools (zipalign + apksigner)
+```
+
 Требования: JDK 17, Android SDK (compileSdk 34).
 
 ## Структура проекта
 
-- `app/src/main/java/ru/ua1zbe/svxremote/MainActivity.kt` — основной экран
+- `app/src/main/java/ru/ua1zbe/svxremote/MainActivity.kt` — основной экран и логика UI
 - `app/src/main/java/ru/ua1zbe/svxremote/SettingsActivity.kt` — настройки подключения
 - `app/src/main/java/ru/ua1zbe/svxremote/proto/ReflectorClient.kt` — клиент рефлектора (TCP + UDP)
 - `app/src/main/java/ru/ua1zbe/svxremote/proto/ReflectorProtocol.kt` — бинарный протокол svxreflector v2
 - `app/src/main/java/ru/ua1zbe/svxremote/audio/OpusEngine.kt` — кодирование/декодирование Opus через MediaCodec
-- `app/src/main/java/ru/ua1zbe/svxremote/ui/` — кнопка PTT и индикатор уровня
+- `app/src/main/java/ru/ua1zbe/svxremote/audio/RxRecorder.kt` — запись приёма в OGG (MediaCodec + MediaMuxer)
+- `app/src/main/java/ru/ua1zbe/svxremote/ui/` — кнопка PTT (стиль Zello), S-метр, индикатор уровня
 - `app/src/test/java/ru/ua1zbe/svxremote/` — юнит-тесты протокола и рукопожатия
 
 ## Тесты

app/build.gradle.kts

@@ -11,8 +11,8 @@ android {
         applicationId = "ru.ua1zbe.svxremote"
         minSdk = 26
         targetSdk = 34
-        versionCode = 9
-        versionName = "1.0.7"
+        versionCode = 16
+        versionName = "1.0.14"
     }
 
     buildTypes {
@@ -43,6 +43,7 @@ kotlin {
 }
 
 dependencies {
+    implementation("ru.rustore.sdk:pushclient:7.4.0")
     testImplementation("junit:junit:4.13.2")
 }
 

app/src/main/AndroidManifest.xml

@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
-<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools">
 
     <uses-permission android:name="android.permission.INTERNET" />
     <uses-permission android:name="android.permission.RECORD_AUDIO" />
@@ -9,6 +10,7 @@
     <uses-permission android:name="android.permission.REQUEST_INSTALL_PACKAGES" />
 
     <application
+        android:name=".SvxApp"
         android:label="@string/app_name"
         android:icon="@mipmap/ic_launcher"
         android:usesCleartextTraffic="true"
@@ -20,11 +22,33 @@
             android:exported="false"
             android:foregroundServiceType="mediaPlayback" />
 
+        <service
+            android:name=".PushMessagingService"
+            android:exported="true"
+            tools:ignore="ExportedService">
+            <intent-filter>
+                <action android:name="ru.rustore.sdk.pushclient.MESSAGING_EVENT" />
+            </intent-filter>
+        </service>
+
+        <meta-data
+            android:name="ru.rustore.sdk.pushclient.default_notification_icon"
+            android:resource="@drawable/ic_launcher_fg" />
+        <meta-data
+            android:name="ru.rustore.sdk.pushclient.default_notification_channel_id"
+            android:value="@string/push_channel_id" />
+
         <activity
             android:name=".SettingsActivity"
             android:exported="false"
             android:label="@string/settings_title" />
 
+        <activity
+            android:name=".AudioSettingsActivity"
+            android:exported="false"
+            android:label="@string/audio_settings_title"
+            android:screenOrientation="portrait" />
+
         <activity
             android:name=".SplashActivity"
             android:exported="true"

app/src/main/java/ru/ua1zbe/svxremote/AudioSettingsActivity.kt

@@ -0,0 +1,95 @@
+package ru.ua1zbe.svxremote
+
+import android.app.Activity
+import android.os.Bundle
+import android.widget.ArrayAdapter
+import android.widget.Button
+import android.widget.CheckBox
+import android.widget.SeekBar
+import android.widget.Spinner
+import android.widget.TextView
+import android.widget.Toast
+import ru.ua1zbe.svxremote.prefs.Prefs
+
+/**
+ * Скрытые настройки звука (тройной тап по названию программы на главном
+ * экране): усиление микрофона, буфер воспроизведения (джиттер), накопление
+ * перед стартом. Применяются при следующем подключении/передаче.
+ */
+class AudioSettingsActivity : Activity() {
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+        setContentView(R.layout.activity_audio_settings)
+
+        val seekMicGain = findViewById<SeekBar>(R.id.seek_mic_gain)
+        val lblMicGain = findViewById<TextView>(R.id.lbl_mic_gain_value)
+        val seekRxBuffer = findViewById<SeekBar>(R.id.seek_rx_buffer)
+        val lblRxBuffer = findViewById<TextView>(R.id.lbl_rx_buffer_value)
+        val seekJitter = findViewById<SeekBar>(R.id.seek_jitter)
+        val lblJitter = findViewById<TextView>(R.id.lbl_jitter_value)
+        val spinBitrate = findViewById<Spinner>(R.id.spin_tx_bitrate)
+
+        // Скорость передачи Opus: Авто + фиксированные 6..32 кбит/с.
+        // SvxLink: Opus 8 кГц, кадр 20 мс; декодер принимает любой битрейт,
+        // поэтому выбор — на стороне клиента. Авто = адаптация под интернет.
+        val bitrates = intArrayOf(0, 6, 8, 10, 12, 16, 20, 24, 32)
+        val bitrateLabels = bitrates.map {
+            if (it == 0) getString(R.string.audio_tx_bitrate_auto)
+            else getString(R.string.audio_tx_bitrate_fmt, it)
+        }
+        spinBitrate.adapter = ArrayAdapter(
+            this, android.R.layout.simple_spinner_item, bitrateLabels
+        ).apply {
+            setDropDownViewResource(android.R.layout.simple_spinner_dropdown_item)
+        }
+        val savedBitrate = Prefs.txBitrateKbps(this)
+        spinBitrate.setSelection(bitrates.indexOfFirst { it == savedBitrate }.coerceAtLeast(0))
+
+        fun updateMicGainLabel() {
+            lblMicGain.text = "${100 + seekMicGain.progress * 10}%"
+        }
+
+        fun updateRxBufferLabel() {
+            lblRxBuffer.text = "${100 + seekRxBuffer.progress * 20} мс"
+        }
+
+        fun updateJitterLabel() {
+            lblJitter.text = "${seekJitter.progress * 20} мс"
+        }
+
+        seekMicGain.progress = ((Prefs.micGain(this) - 1.0f) * 10).toInt().coerceIn(0, 40)
+        seekRxBuffer.progress = ((Prefs.rxBufferMs(this) - 100) / 20).coerceIn(0, 25)
+        seekJitter.progress = (Prefs.rxJitterMs(this) / 20).coerceIn(0, 20)
+        updateMicGainLabel()
+        updateRxBufferLabel()
+        updateJitterLabel()
+
+        val listener = object : SeekBar.OnSeekBarChangeListener {
+            override fun onProgressChanged(seekBar: SeekBar, progress: Int, fromUser: Boolean) {
+                updateMicGainLabel()
+                updateRxBufferLabel()
+                updateJitterLabel()
+            }
+
+            override fun onStartTrackingTouch(seekBar: SeekBar) {}
+            override fun onStopTrackingTouch(seekBar: SeekBar) {}
+        }
+        seekMicGain.setOnSeekBarChangeListener(listener)
+        seekRxBuffer.setOnSeekBarChangeListener(listener)
+        seekJitter.setOnSeekBarChangeListener(listener)
+
+        val chkRxStats = findViewById<CheckBox>(R.id.chk_rx_stats)
+        chkRxStats.isChecked = Prefs.rxStatsEnabled(this)
+
+        findViewById<Button>(R.id.btn_audio_save).setOnClickListener {
+            Prefs.setMicGain(this, 1.0f + seekMicGain.progress * 0.1f)
+            Prefs.setRxBufferMs(this, 100 + seekRxBuffer.progress * 20)
+            Prefs.setRxJitterMs(this, seekJitter.progress * 20)
+            Prefs.setTxBitrateKbps(this, bitrates[spinBitrate.selectedItemPosition])
+            Prefs.setRxStatsEnabled(this, chkRxStats.isChecked)
+            Toast.makeText(this, getString(R.string.saved), Toast.LENGTH_SHORT).show()
+            finish()
+        }
+    }
+}

app/src/main/java/ru/ua1zbe/svxremote/MainActivity.kt

@@ -8,7 +8,11 @@ import android.content.Context
 import android.content.Intent
 import android.content.ServiceConnection
 import android.content.pm.PackageManager
+import android.media.MediaPlayer
 import android.net.Uri
+import android.view.ViewGroup
+import android.widget.ArrayAdapter
+import android.widget.ListView
 import android.content.res.ColorStateList
 import android.graphics.Color
 import android.graphics.PixelFormat
@@ -35,6 +39,8 @@ import ru.ua1zbe.svxremote.prefs.Prefs
 import ru.ua1zbe.svxremote.proto.MsgParser
 import ru.ua1zbe.svxremote.proto.ReflectorClient
 import ru.ua1zbe.svxremote.ui.PttButton
+import ru.ua1zbe.svxremote.ui.SMeterView
+import ru.ua1zbe.svxremote.ui.SoundMeterPreviewView
 
 private const val REQ_MIC = 1001
 private const val REQ_NOTIF = 1002
@@ -51,22 +57,35 @@ class MainActivity : Activity(), SvxService.Listener {
     private lateinit var lblSubtitle: TextView
     private lateinit var lblCallsign: TextView
     private lateinit var lblTg: TextView
-    private lateinit var lblTalkerTitle: TextView
     private lateinit var lblTalker: TextView
-    private lateinit var lblPttHint: TextView
+    private lateinit var lblDuplex: TextView
+    private var lastTalkerCs = ""
+    private var lastTalkerTg = -1L
     private lateinit var lblTxState: TextView
     private lateinit var lblConnectHint: TextView
     private lateinit var connectZone: View
-    private lateinit var rxBarFill: View
-    private lateinit var rxDb: TextView
-    private lateinit var micBarFill: View
-    private lateinit var micDb: TextView
+    private lateinit var rxMeter: SMeterView
+    private lateinit var micMeter: SMeterView
+    private lateinit var lblRxStats: TextView
     private lateinit var pttButton: PttButton
     private lateinit var btnSettings: ImageButton
     private lateinit var btnMonitor: ImageButton
+    private lateinit var btnRecord: ImageButton
+    // Список записей: воспроизведение/удаление
+    private var recPlayer: MediaPlayer? = null
+    private var recPlayingPath: String? = null
+    private var recLongPressFired = false
+    private var recListAdapter: ArrayAdapter<File>? = null
+    private val recLongPressTask = Runnable {
+        recLongPressFired = true
+        Log.d(TAG, "recBtn long-press FIRED")
+        openRecordingsList()
+    }
 
     private val mainHandler = Handler(Looper.getMainLooper())
     private var titleHoldRunnable: Runnable? = null
+    private var titleResetRunnable: Runnable? = null
+    private var titleTaps = 0
 
     private data class TalkLogEntry(val time: Long, val callsign: String, val tg: Long)
 
@@ -75,14 +94,19 @@ class MainActivity : Activity(), SvxService.Listener {
     private var connected = false
     private var monitoring = false
     private var connectedSettings: ConnectionSettings? = null
-    private var priorityActive = false
     private var settings: ConnectionSettings = ConnectionSettings("", 5300, "", "", 11)
 
+    // Динамический мониторинг: если на группе нет голоса 15 секунд,
+    // возвращаемся к мониторингу всех групп (базовая группа).
+    private val MONITOR_IDLE_MS = 15_000L
+    private var monitorIdleTask: Runnable? = null
+
     private var svc: SvxService? = null
     private val svcConn = object : ServiceConnection {
         override fun onServiceConnected(name: ComponentName, binder: IBinder) {
             svc = (binder as SvxService.LocalBinder).service()
             svc?.listener = this@MainActivity
+            updateRecordUi(svc?.isRecording() ?: false)
         }
 
         override fun onServiceDisconnected(name: ComponentName) {
@@ -123,24 +147,43 @@ class MainActivity : Activity(), SvxService.Listener {
         statusChip = findViewById(R.id.status_chip)
         lblAppTitle = findViewById(R.id.lbl_app_title)
         lblSubtitle = findViewById(R.id.lbl_subtitle)
-        lblTalkerTitle = findViewById(R.id.lbl_talker_title)
         lblTalker = findViewById(R.id.lbl_talker)
-        lblPttHint = findViewById(R.id.lbl_ptt_hint)
+        lblDuplex = findViewById(R.id.lbl_duplex)
         lblTxState = findViewById(R.id.lbl_tx_state)
         lblConnectHint = findViewById(R.id.lbl_connect_hint)
         connectZone = findViewById(R.id.connect_zone)
         lblCallsign = findViewById(R.id.lbl_callsign)
         lblTg = findViewById(R.id.lbl_tg)
-        rxBarFill = findViewById(R.id.rx_bar_fill)
-        rxDb = findViewById(R.id.rx_db)
-        micBarFill = findViewById(R.id.mic_bar_fill)
-        micDb = findViewById(R.id.mic_db)
+        rxMeter = findViewById(R.id.rx_meter)
+        micMeter = findViewById(R.id.mic_meter)
+        micMeter.setColor(0xFFF85149.toInt())
+        lblRxStats = findViewById(R.id.lbl_rx_stats)
+        lblRxStats.visibility = if (Prefs.rxStatsEnabled(this)) View.VISIBLE else View.GONE
         pttButton = findViewById(R.id.ptt_button)
         btnSettings = findViewById(R.id.btn_settings)
         btnMonitor = findViewById(R.id.btn_monitor)
+        btnRecord = findViewById(R.id.btn_record)
         pttButton.enabled2 = false
 
         btnMonitor.setOnClickListener { toggleMonitoring() }
+        btnRecord.setOnClickListener { toggleRecording() }
+        btnRecord.setOnTouchListener { _, event ->
+            when (event.action) {
+                MotionEvent.ACTION_DOWN -> {
+                    recLongPressFired = false
+                    Log.d(TAG, "recBtn DOWN, scheduling long-press")
+                    mainHandler.postDelayed(recLongPressTask, 3000)
+                    false
+                }
+                MotionEvent.ACTION_UP, MotionEvent.ACTION_CANCEL -> {
+                    Log.d(TAG, "recBtn UP/CANCEL, longFired=$recLongPressFired")
+                    mainHandler.removeCallbacks(recLongPressTask)
+                    // Если сработал долгий тап — гасим клик (иначе переключит запись)
+                    recLongPressFired
+                }
+                else -> false
+            }
+        }
         updateMonitorButton()
         val testText = intent?.getStringExtra("node_toast_test")
         if (testText != null) {
@@ -164,18 +207,42 @@ class MainActivity : Activity(), SvxService.Listener {
 
         lblTalker.setOnClickListener { showTalkLogDialog() }
 
-        // Удержание на названии программы (> 2 с) — выбор профиля настроек
+        // Удержание на надписи «На связи» — демо-окно индикаторов звука
+        lblTxState.setOnLongClickListener {
+            showSoundMetersPreview()
+            true
+        }
+
+        // Удержание на названии программы (> 2 с) — выбор профиля настроек;
+        // короткие тапы считаем: тройной тап — настройки
         lblAppTitle.setOnTouchListener { _, event ->
             when (event.actionMasked) {
                 MotionEvent.ACTION_DOWN -> {
-                    val r = Runnable { showProfileDialog() }
+                    val r = Runnable {
+                        titleHoldRunnable = null
+                        showProfileDialog()
+                    }
                     titleHoldRunnable = r
                     mainHandler.postDelayed(r, 2000)
                     true
                 }
                 MotionEvent.ACTION_UP, MotionEvent.ACTION_CANCEL -> {
+                    val wasHold = titleHoldRunnable == null
                     titleHoldRunnable?.let { mainHandler.removeCallbacks(it) }
                     titleHoldRunnable = null
+                    if (!wasHold) {
+                        titleTaps++
+                        // Скользящее окно: сброс от последнего тапа
+                        titleResetRunnable?.let { mainHandler.removeCallbacks(it) }
+                        val reset = Runnable { titleTaps = 0 }
+                        titleResetRunnable = reset
+                        mainHandler.postDelayed(reset, 2000)
+                        if (titleTaps >= 3) {
+                            titleTaps = 0
+                            titleResetRunnable?.let { mainHandler.removeCallbacks(it) }
+                            startActivity(Intent(this, AudioSettingsActivity::class.java))
+                        }
+                    }
                     true
                 }
                 else -> true
@@ -205,18 +272,18 @@ class MainActivity : Activity(), SvxService.Listener {
                     toast(getString(R.string.perm_mic))
                     return
                 }
-                lblPttHint.text = getString(R.string.ptt_talking)
                 lblTxState.text = getString(R.string.status_big_talking)
+                showDuplex(getString(R.string.duplex_tx), R.color.danger, null)
                 svc?.startTx()
             }
 
             override fun onPttUp() {
                 Log.d("SVXRemote", "PTT up")
                 svc?.stopTx()
-                lblPttHint.text = getString(R.string.hold_to_talk)
                 lblTxState.text =
                     if (connected) getString(R.string.status_big_connected)
                     else getString(R.string.status_big_disconnected)
+                hideDuplex()
             }
         })
 
@@ -234,7 +301,6 @@ class MainActivity : Activity(), SvxService.Listener {
         if (prev != settings && connectedSettings != null) {
             if (settings.host.isBlank() || settings.callsign.isBlank()) {
                 monitoring = false
-                priorityActive = false
                 updateMonitorButton()
                 updatePttEnabled()
                 svc?.disconnect()
@@ -269,6 +335,8 @@ class MainActivity : Activity(), SvxService.Listener {
         hideNodeOverlay()
         aprsMeteo?.stop()
         aprsMeteo = null
+        mainHandler.removeCallbacks(recLongPressTask)
+        stopRecordingPlayback()
         mainHandler.removeCallbacksAndMessages(null)
         SplashActivity.mainAlive = false
         svc?.listener = null
@@ -304,7 +372,6 @@ class MainActivity : Activity(), SvxService.Listener {
                     lblTxState.text = getString(R.string.status_big_disconnected)
                     lblTxState.setTextColor(getColor(R.color.danger))
                     lblConnectHint.text = getString(R.string.hint_connect)
-                    lblPttHint.text = getString(R.string.hold_to_talk)
                 }
 
                 ReflectorClient.STATE_CONNECTING,
@@ -368,36 +435,44 @@ class MainActivity : Activity(), SvxService.Listener {
 
     override fun onTalkerStart(tg: Long, callsign: String) {
         mainHandler.post {
+            Log.d("SVXRemote", "talkerStart tg=$tg cs=$callsign monitoring=$monitoring ptt=${pttButton.isPressed2}")
             talkLog.addLast(TalkLogEntry(System.currentTimeMillis(), callsign, tg))
             while (talkLog.size > TALK_LOG_MAX) {
                 talkLog.removeFirst()
             }
-            val priority = monitoring && settings.groups.firstOrNull() == tg
-            if (priority) {
-                priorityActive = true
-            }
-            if (priority || !priorityActive) {
-                svc?.selectGroup(tg)
-                lblTalkerTitle.text = when {
-                    priority -> getString(R.string.talker_mon_priority, callsign, tg)
-                    monitoring -> getString(R.string.talker_mon, callsign, tg)
-                    else -> getString(R.string.talker_now, callsign)
+            if (monitoring) {
+                // Переключаемся на группу, где началась передача, и даём ей
+                // 15 секунд; после тишины вернёмся ко всем группам.
+                // Во время своей передачи группу не меняем.
+                if (!pttButton.isPressed2) {
+                    svc?.selectGroup(tg)
                 }
-                lblTalkerTitle.setTextColor(
-                    if (priority) getColor(R.color.danger) else getColor(R.color.text_secondary)
-                )
-                lblTalker.text = callsign
+                resetMonitorIdle()
+            }
+            lastTalkerCs = callsign
+            lastTalkerTg = tg
+            updateTalkerLine(active = true)
+            if (!pttButton.isPressed2) {
+                showDuplex(getString(R.string.duplex_rx), R.color.accent, DUPLEX_RX_HIDE_MS)
             }
         }
     }
 
     override fun onTalkerStop(tg: Long, callsign: String) {
-        // последний говоривший остаётся на экране
-        mainHandler.post {
-            if (monitoring && settings.groups.firstOrNull() == tg) {
-                priorityActive = false
-            }
+        // последний говоривший остаётся на экране, но без префикса «Говорит»
+        mainHandler.post { updateTalkerLine(active = false) }
+    }
+
+    /** Единая строка говорящего: «Говорит …» при приёме, иначе позывной+TG. */
+    private fun updateTalkerLine(active: Boolean) {
+        if (lastTalkerCs.isEmpty()) {
+            lblTalker.text = ""
+            return
         }
+        lblTalker.text = if (active)
+            getString(R.string.talker_active_fmt, lastTalkerCs, lastTalkerTg)
+        else
+            getString(R.string.talker_idle_fmt, lastTalkerCs, lastTalkerTg)
     }
 
     override fun onNodeJoined(callsign: String, tg: Long?) {
@@ -455,21 +530,63 @@ class MainActivity : Activity(), SvxService.Listener {
 
     override fun onLevel(source: Int, level: Float) {
         mainHandler.post {
-            val db = if (level <= 0.001f) {
-                getString(R.string.meter_idle)
-            } else {
-                getString(R.string.meter_db, (level * 60).toInt().coerceIn(1, 60))
-            }
             if (source == 0) { // SRC_MIC
-                micBarFill.scaleX = level.coerceIn(0f, 1f)
-                micDb.text = db
+                micMeter.setLevel(level)
             } else { // SRC_SPEAKER
-                rxBarFill.scaleX = level.coerceIn(0f, 1f)
-                rxDb.text = db
+                rxMeter.setLevel(level)
+                // «RX» пока идёт голос; при своей передаче не показываем
+                if (!pttButton.isPressed2 && level > 0.03f) {
+                    showDuplex(getString(R.string.duplex_rx), R.color.accent, DUPLEX_RX_HIDE_MS)
+                }
+                // Голос на текущей группе — откладываем возврат ко всем группам
+                if (monitoring && connected && level > 0.03f) {
+                    resetMonitorIdle()
+                }
             }
         }
     }
 
+    override fun onRxStats(lossPct: Double, jitterMs: Double) {
+        mainHandler.post {
+            if (!Prefs.rxStatsEnabled(this)) return@post
+            lblRxStats.visibility = View.VISIBLE
+            lblRxStats.text = getString(R.string.rx_stats_fmt, lossPct, jitterMs.toInt())
+        }
+    }
+
+    /** Сбросить таймер молчания: группа жива — продолжаем её слушать. */
+    private fun resetMonitorIdle() {
+        monitorIdleTask?.let { mainHandler.removeCallbacks(it) }
+        val task = Runnable {
+            // Во время своей передачи на базу не возвращаемся
+            if (monitoring && connected && !pttButton.isPressed2) {
+                svc?.selectGroup(settings.talkGroup)
+            }
+        }
+        monitorIdleTask = task
+        mainHandler.postDelayed(task, MONITOR_IDLE_MS)
+    }
+
+    // ---------- Индикатор RX/TX ----------
+    private val DUPLEX_RX_HIDE_MS = 1500L
+    private var duplexHideTask: Runnable? = null
+
+    private fun showDuplex(text: String, colorRes: Int, hideAfterMs: Long?) {
+        lblDuplex.text = text
+        lblDuplex.setTextColor(getColor(colorRes))
+        lblDuplex.visibility = View.VISIBLE
+        duplexHideTask?.let { mainHandler.removeCallbacks(it) }
+        if (hideAfterMs != null) {
+            val t = Runnable { lblDuplex.visibility = View.INVISIBLE }
+            duplexHideTask = t
+            mainHandler.postDelayed(t, hideAfterMs)
+        }
+    }
+
+    private fun hideDuplex() {
+        duplexHideTask?.let { mainHandler.removeCallbacks(it) }
+        lblDuplex.visibility = View.INVISIBLE
+    }
     override fun onError(detail: String) {
         mainHandler.post {
             toast(detail)
@@ -477,7 +594,8 @@ class MainActivity : Activity(), SvxService.Listener {
     }
 
     private fun updatePttEnabled() {
-        pttButton.enabled2 = connected && !monitoring
+        // PTT работает и в режиме мониторинга: передача идёт на выбранной группе
+        pttButton.enabled2 = connected
     }
 
     private fun requestPermissionsIfNeeded() {
@@ -510,7 +628,7 @@ class MainActivity : Activity(), SvxService.Listener {
         }, 300)
     }
 
-    /** Включить/выключить режим мониторинга групп с переподключением. */
+    /** Включить/выключить режим мониторинга групп по живому соединению. */
     private fun toggleMonitoring() {
         val enabling = !monitoring
         if (enabling) {
@@ -519,12 +637,21 @@ class MainActivity : Activity(), SvxService.Listener {
             showToast(R.string.monitor_off)
         }
         monitoring = enabling
-        priorityActive = false
         updateMonitorButton()
         updatePttEnabled()
         if (connected) {
-            svc?.disconnect()
-            mainHandler.postDelayed({ connect() }, 500)
+            monitorIdleTask?.let { mainHandler.removeCallbacks(it) }
+            if (enabling) {
+                // Без переподключения: сервер начнёт присылать уведомления
+                // со всех групп, сами сидим на базовой.
+                svc?.setMonitorTgs(settings.groups)
+                svc?.selectGroup(settings.talkGroup)
+                statusChip.text = getString(R.string.status_monitoring, monitorTgLabel())
+            } else {
+                svc?.selectGroup(settings.talkGroup)
+                svc?.setMonitorTgs(listOf(settings.talkGroup))
+                statusChip.text = getString(R.string.status_connected)
+            }
         } else {
             connect()
         }
@@ -560,7 +687,6 @@ class MainActivity : Activity(), SvxService.Listener {
                     Prefs.setActiveProfile(this, which)
                     settings = Prefs.load(this)
                     monitoring = false
-                    priorityActive = false
                     updateMonitorButton()
                     updatePttEnabled()
                     refreshUi()
@@ -588,6 +714,127 @@ class MainActivity : Activity(), SvxService.Listener {
             getString(if (active) R.string.btn_monitor_on else R.string.btn_monitor)
     }
 
+    private fun toggleRecording() {
+        val s = svc ?: return
+        if (s.isRecording()) {
+            val path = s.stopRecording()
+            updateRecordUi(false)
+            toast(getString(R.string.record_saved, path ?: ""))
+        } else {
+            val path = s.startRecording()
+            if (path != null) {
+                updateRecordUi(true)
+                toast(getString(R.string.record_started))
+            } else {
+                toast(getString(R.string.record_failed))
+            }
+        }
+    }
+
+    private fun updateRecordUi(active: Boolean) {
+        btnRecord.imageTintList = ColorStateList.valueOf(
+            if (active) Color.parseColor("#F85149") else Color.parseColor("#8B949E")
+        )
+        btnRecord.contentDescription = getString(R.string.btn_record)
+    }
+
+    // ---------- Список записей: воспроизведение / удаление ----------
+
+    private fun recordingsDir(): File =
+        File(getExternalFilesDir(null) ?: filesDir, "recordings")
+
+    private fun openRecordingsList() {
+        Log.d(TAG, "openRecordingsList")
+        val dir = recordingsDir()
+        Log.d(TAG, "recordings dir exists=${dir.exists()} path=${dir.absolutePath}")
+        val files = (dir.listFiles { f -> f.extension.equals("ogg", true) }
+            ?: emptyArray()).toMutableList()
+            .apply { sortByDescending { it.name } }
+        Log.d(TAG, "recordings count=${files.size}")
+        if (files.isEmpty()) {
+            toast("Нет записей")
+            return
+        }
+        val dialog = AlertDialog.Builder(this)
+            .setTitle(R.string.recordings_title)
+            .create()
+        val listView = ListView(this).apply {
+            val adapter = object : ArrayAdapter<File>(this@MainActivity, 0, files) {
+                override fun getView(pos: Int, convertView: View?, parent: ViewGroup): View {
+                    val file = getItem(pos)!!
+                    val row = convertView
+                        ?: layoutInflater.inflate(R.layout.dialog_recording_item, parent, false)
+                    row.findViewById<TextView>(R.id.rec_name).text = file.name
+                    val playBtn = row.findViewById<ImageButton>(R.id.rec_play)
+                    val delBtn = row.findViewById<ImageButton>(R.id.rec_delete)
+                    val playing = recPlayingPath == file.absolutePath && recPlayer?.isPlaying == true
+                    playBtn.setImageResource(if (playing) R.drawable.ic_stop else R.drawable.ic_play)
+                    playBtn.setOnClickListener { togglePlayRecording(file.absolutePath) }
+                    delBtn.setOnClickListener { confirmDeleteRecording(file, this, dialog) }
+                    return row
+                }
+            }
+            recListAdapter = adapter
+            this.adapter = adapter
+            layoutParams = ViewGroup.LayoutParams(
+                ViewGroup.LayoutParams.MATCH_PARENT,
+                (resources.displayMetrics.heightPixels * 0.6).toInt()
+            )
+        }
+        dialog.setView(listView)
+        dialog.setOnDismissListener { stopRecordingPlayback() }
+        dialog.show()
+    }
+
+    private fun togglePlayRecording(path: String) {
+        if (recPlayingPath == path && recPlayer?.isPlaying == true) {
+            stopRecordingPlayback()
+            refreshRecordingList()
+            return
+        }
+        stopRecordingPlayback()
+        try {
+            val mp = MediaPlayer().apply {
+                setDataSource(path)
+                setOnCompletionListener { stopRecordingPlayback(); refreshRecordingList() }
+                prepare()
+                start()
+            }
+            recPlayer = mp
+            recPlayingPath = path
+            refreshRecordingList()
+        } catch (e: Exception) {
+            toast(getString(R.string.record_play_failed))
+        }
+    }
+
+    private fun stopRecordingPlayback() {
+        try { recPlayer?.stop() } catch (_: Exception) {}
+        try { recPlayer?.release() } catch (_: Exception) {}
+        recPlayer = null
+        recPlayingPath = null
+    }
+
+    private fun refreshRecordingList() {
+        recListAdapter?.notifyDataSetChanged()
+    }
+
+    private fun confirmDeleteRecording(file: File, adapter: ArrayAdapter<File>, dialog: AlertDialog) {
+        AlertDialog.Builder(this)
+            .setTitle(R.string.record_delete_title)
+            .setMessage(file.name)
+            .setPositiveButton(R.string.record_delete_yes) { _, _ ->
+                if (recPlayingPath == file.absolutePath) stopRecordingPlayback()
+                file.delete()
+                adapter.remove(file)
+                adapter.notifyDataSetChanged()
+                toast(getString(R.string.record_deleted))
+                if (adapter.count == 0) dialog.dismiss()
+            }
+            .setNegativeButton(R.string.cancel, null)
+            .show()
+    }
+
     /** Переключиться на другую группу: отправить серверу по живому соединению. */
     private fun switchGroup(tg: Long) {
         settings = settings.copy(talkGroup = tg)
@@ -597,6 +844,8 @@ class MainActivity : Activity(), SvxService.Listener {
         svc?.selectGroup(tg)
         if (!monitoring) {
             svc?.setMonitorTgs(listOf(tg))
+        } else {
+            resetMonitorIdle()
         }
     }
 
@@ -639,6 +888,16 @@ class MainActivity : Activity(), SvxService.Listener {
             .show()
     }
 
+    /** Демо-окно с примерами индикаторов звука (удержание на «На связи»). */
+    private fun showSoundMetersPreview() {
+        AlertDialog.Builder(this)
+            .setTitle(R.string.meter_preview_title)
+            .setMessage(R.string.meter_preview_hint)
+            .setView(SoundMeterPreviewView(this))
+            .setPositiveButton(R.string.close, null)
+            .show()
+    }
+
     private fun showGroupsDialog() {
         val groups = (settings.groups + settings.talkGroup).distinct()
         if (groups.isEmpty()) {

app/src/main/java/ru/ua1zbe/svxremote/PushMessagingService.kt

@@ -0,0 +1,60 @@
+package ru.ua1zbe.svxremote
+
+import android.app.Notification
+import android.app.NotificationManager
+import android.util.Log
+import ru.rustore.sdk.pushclient.messaging.exception.RuStorePushClientException
+import ru.rustore.sdk.pushclient.messaging.model.RemoteMessage
+import ru.rustore.sdk.pushclient.messaging.service.RuStoreMessagingService
+import ru.ua1zbe.svxremote.prefs.Prefs
+
+/**
+ * Приём пуш-уведомлений RuStore.
+ *
+ * Если сервер прислал секцию `notification` — SDK сам отображает уведомление.
+ * Если присланы только `data` (title/body) — отображаем уведомление сами.
+ */
+class PushMessagingService : RuStoreMessagingService() {
+
+    override fun onNewToken(token: String) {
+        Log.i(TAG, "onNewToken: $token")
+        Prefs.setPushToken(this, token)
+    }
+
+    override fun onMessageReceived(message: RemoteMessage) {
+        if (message.notification != null) {
+            Log.i(TAG, "push displayed by SDK: ${message.data}")
+            return
+        }
+        val title = message.data["title"] ?: getString(R.string.app_name)
+        val body = message.data["body"] ?: ""
+        if (title.isNotEmpty() || body.isNotEmpty()) {
+            showPush(title, body)
+        }
+    }
+
+    override fun onDeletedMessages() {
+        Log.i(TAG, "onDeletedMessages")
+    }
+
+    override fun onError(errors: List<RuStorePushClientException>) {
+        errors.forEach { Log.w(TAG, "error", it) }
+    }
+
+    private fun showPush(title: String, body: String) {
+        val nm = getSystemService(NotificationManager::class.java)
+        val n = Notification.Builder(this, CHANNEL_ID)
+            .setContentTitle(title)
+            .setContentText(body)
+            .setSmallIcon(R.drawable.ic_launcher_fg)
+            .setAutoCancel(true)
+            .build()
+        nm.notify(NOTIFICATION_ID, n)
+    }
+
+    companion object {
+        private const val TAG = "RuStorePush"
+        const val CHANNEL_ID = "svx_push"
+        private const val NOTIFICATION_ID = 2
+    }
+}

app/src/main/java/ru/ua1zbe/svxremote/SettingsActivity.kt

@@ -9,6 +9,7 @@ import android.widget.Button
 import android.widget.CheckBox
 import android.widget.EditText
 import android.widget.Spinner
+import android.widget.TextView
 import android.widget.Toast
 import ru.ua1zbe.svxremote.prefs.ConnectionSettings
 import ru.ua1zbe.svxremote.prefs.Prefs
@@ -41,6 +42,8 @@ class SettingsActivity : Activity() {
         val chkNodeToasts = findViewById<CheckBox>(R.id.chk_node_toasts)
         chkNodeToasts.isChecked = Prefs.nodeToastsEnabled(this)
         inputAprsCoords.setText(Prefs.aprsCoords(this))
+        findViewById<TextView>(R.id.lbl_version).text =
+            getString(R.string.app_version_fmt, BuildConfig.VERSION_NAME)
 
         val profileNames = (1..Prefs.PROFILE_COUNT)
             .map { getString(R.string.profile_name, it) }

app/src/main/java/ru/ua1zbe/svxremote/SvxApp.kt

@@ -0,0 +1,63 @@
+package ru.ua1zbe.svxremote
+
+import android.app.Application
+import android.app.NotificationChannel
+import android.app.NotificationManager
+import android.util.Log
+import ru.rustore.sdk.pushclient.RuStorePushClient
+import ru.ua1zbe.svxremote.prefs.Prefs
+
+/**
+ * Приложение: создаём канал пуша и инициализируем RuStore Push SDK.
+ * project_id берём из консоли RuStore (Push-уведомления > Проекты).
+ */
+class SvxApp : Application() {
+
+    override fun onCreate() {
+        super.onCreate()
+        createPushChannel()
+        initRuStorePush()
+    }
+
+    private fun createPushChannel() {
+        getSystemService(NotificationManager::class.java).createNotificationChannel(
+            NotificationChannel(
+                PushMessagingService.CHANNEL_ID,
+                getString(R.string.push_channel_name),
+                NotificationManager.IMPORTANCE_HIGH
+            )
+        )
+    }
+
+    private fun initRuStorePush() {
+        try {
+            RuStorePushClient.init(
+                application = this,
+                projectId = RUSTORE_PROJECT_ID
+            )
+            RuStorePushClient.getToken()
+                .addOnSuccessListener { token ->
+                    Log.i(TAG, "push token: $token")
+                    Prefs.setPushToken(this, token)
+                    RuStorePushClient.subscribeToTopic(PUSH_TOPIC)
+                        .addOnSuccessListener {
+                            Log.i(TAG, "subscribed to $PUSH_TOPIC")
+                        }
+                        .addOnFailureListener { e ->
+                            Log.w(TAG, "subscribe to $PUSH_TOPIC failed", e)
+                        }
+                }
+                .addOnFailureListener { e ->
+                    Log.w(TAG, "getToken failed", e)
+                }
+        } catch (e: Exception) {
+            Log.w(TAG, "init failed", e)
+        }
+    }
+
+    companion object {
+        private const val TAG = "RuStorePush"
+        private const val RUSTORE_PROJECT_ID = "Yd7tDjVDHqsnTJwHNYN08cYIvy8fsWU-"
+        private const val PUSH_TOPIC = "svxhomyak"
+    }
+}

app/src/main/java/ru/ua1zbe/svxremote/SvxService.kt

@@ -10,6 +10,8 @@ import android.os.Binder
 import android.os.IBinder
 import android.util.Log
 import ru.ua1zbe.svxremote.audio.OpusEngine
+import ru.ua1zbe.svxremote.audio.RxRecorder
+import ru.ua1zbe.svxremote.prefs.Prefs
 import ru.ua1zbe.svxremote.proto.MsgParser
 import ru.ua1zbe.svxremote.proto.ReflectorClient
 
@@ -30,15 +32,22 @@ class SvxService : Service(), ReflectorClient.Callbacks {
         fun onAudioFlush()
         fun onError(detail: String)
         fun onLevel(source: Int, level: Float)
+        fun onRxStats(lossPct: Double, jitterMs: Double)
     }
 
     var listener: Listener? = null
 
     private val engine by lazy {
-        OpusEngine { source, level -> listener?.onLevel(source, level) }
+        OpusEngine(
+            onLevel = { source, level -> listener?.onLevel(source, level) },
+            onRxStats = { lossPct, jitterMs -> listener?.onRxStats(lossPct, jitterMs) }
+        ).also { it.rxTap = { pcm, real -> recorder.feed(pcm, real) } }
     }
     val client: ReflectorClient by lazy { ReflectorClient(this) }
 
+    /** Запись приёма в OGG (управляется из UI). */
+    private val recorder = RxRecorder()
+
     private val binder = LocalBinder()
 
     inner class LocalBinder : Binder() {
@@ -99,7 +108,7 @@ class SvxService : Service(), ReflectorClient.Callbacks {
     }
 
     fun startTx() {
-        engine.startCapture { packet -> client.sendAudio(packet) }
+        engine.startCapture(Prefs.micGain(this)) { packet -> client.sendAudio(packet) }
     }
 
     fun stopTx() {
@@ -118,6 +127,9 @@ class SvxService : Service(), ReflectorClient.Callbacks {
         when (state) {
             ReflectorClient.STATE_READY -> {
                 updateNotification(getString(R.string.notif_connected))
+                engine.rxBufferMs = Prefs.rxBufferMs(this)
+                engine.jitterFrames = (Prefs.rxJitterMs(this) / 20).coerceAtLeast(1)
+                engine.txBitrateKbps = Prefs.txBitrateKbps(this)
                 engine.startDecoder()
             }
             ReflectorClient.STATE_DISCONNECTED -> {
@@ -171,7 +183,7 @@ class SvxService : Service(), ReflectorClient.Callbacks {
     }
 
     override fun onAudioPacket(packet: ByteArray, seq: Int) {
-        engine.onAudioPacket(packet)
+        engine.onAudioPacket(packet, seq)
     }
 
     override fun onAudioFlush() {
@@ -181,4 +193,27 @@ class SvxService : Service(), ReflectorClient.Callbacks {
     override fun onError(detail: String) {
         listener?.onError(detail)
     }
+
+    // ---------- Запись приёма в файл ----------
+
+    fun isRecording(): Boolean = recorder.isRecording()
+
+    /** Начать запись. Возвращает путь к файлу или null при ошибке. */
+    fun startRecording(): String? {
+        if (recorder.isRecording()) return recorder.getFilePath()
+        val dir = getExternalFilesDir(null) ?: filesDir
+        return if (recorder.start(dir)) recorder.getFilePath() else null
+    }
+
+    /** Остановить запись. Возвращает путь к сохранённому файлу или null. */
+    fun stopRecording(): String? {
+        if (!recorder.isRecording()) return null
+        recorder.stop()
+        return recorder.getFilePath()
+    }
+
+    override fun onDestroy() {
+        recorder.stop()
+        super.onDestroy()
+    }
 }

app/src/main/java/ru/ua1zbe/svxremote/audio/OpusEngine.kt

@@ -20,7 +20,8 @@ import kotlin.math.log10
  * SVXLink: моно, 8 кГц, 16 бит PCM, кадры 20 мс. Поток уровня сигнала 0..1.
  */
 class OpusEngine(
-    private val onLevel: (source: Int, level: Float) -> Unit
+    private val onLevel: (source: Int, level: Float) -> Unit,
+    private val onRxStats: ((lossPct: Double, jitterMs: Double) -> Unit)? = null
 ) {
 
     companion object {
@@ -30,6 +31,11 @@ class OpusEngine(
         const val CHANNELS = 1
         const val FRAME_SIZE = 160 // 20 мс в 8 кГц
         const val BIT_RATE = 20000
+        private const val GATE_MIN_WAIT_MS = 100L
+        // Авто-адаптация битрейта TX (0 = авто включено в настройках)
+        const val AUTO_BITRATE_MIN = 8
+        const val AUTO_BITRATE_MAX = 24
+        const val AUTO_BITRATE_STEP = 4
 
         const val SRC_MIC = 0
         const val SRC_SPEAKER = 1
@@ -58,10 +64,43 @@ class OpusEngine(
     private var dbgOut = 0
     private var playStarted = false
     private var gateStart = 0L
-    private val jitterTarget = 6 // ≈ 120 мс накапливаем до первого слива
+    private var lastRealPacketTime = 0L
+    // Настраивается из скрытых настроек звука (AudioSettingsActivity)
+    @Volatile
+    var rxBufferMs = 417 // буфер AudioTrack, мс (40000 байт ≈ 417 мс при 48 кГц)
+    @Volatile
+    var jitterFrames = 10 // сколько кадров накопить до первого слива (кадр = 20 мс)
+    // Скорость передачи Opus, кбит/с. 0 = Авто (адаптация под интернет).
+    @Volatile
+    var txBitrateKbps = 0
+    // Перехват декодированного RX PCM (для записи в файл). Аргументы: PCM, реальный приём?
+    @Volatile
+    var rxTap: ((pcm: ByteArray, isReal: Boolean) -> Unit)? = null
+    // Текущий битрейт в режиме Авто (пересчитывается по статистике приёма)
+    @Volatile
+    private var autoKbps = 16
     private val configBuffers = ArrayList<ByteArray>()
     private var configIdx = 0
 
+    // ---------- Статистика приёма для авто-битрейта ----------
+    private var lastSeq = -1
+    private var lastPktTime = 0L
+    private var lossCount = 0L
+    private var pktCount = 0L
+    private var jitterAccum = 0.0
+    private var jitterN = 0
+    private var lastEvalTime = 0L
+    private var goodWindows = 0
+
+    /** Размер пакета при 20 мс кадре: bitrate * 0.02 / 8 байт. */
+    fun bitrateBytes(kbps: Int): Int = (kbps * 20) / 8
+
+    /** Эффективный битрейт для следующей передачи, бит/с. */
+    fun effectiveBitrate(): Int {
+        val kbps = if (txBitrateKbps > 0) txBitrateKbps else autoKbps
+        return kbps * 1000
+    }
+
     fun startDecoder() {
         if (decoder != null) return
         val format = MediaFormat()
@@ -88,7 +127,7 @@ class OpusEngine(
                 OUT_SAMPLE_RATE,
                 AudioFormat.CHANNEL_OUT_MONO,
                 AudioFormat.ENCODING_PCM_16BIT,
-                maxOf(minBuf, 20000), // ~208 мс — буфер AudioTrack и есть джиттер-буфер
+                maxOf(minBuf, rxBufferMs * 96), // 96 байт/мс при 48 кГц моно 16 бит
                 AudioTrack.MODE_STREAM
             ) // play() включаем на первом выходном кадре — буфер успевает накопиться
         } catch (e: Exception) {
@@ -204,7 +243,13 @@ class OpusEngine(
                         }
                     }
                     player?.write(pcm, 0, pcm.size)
-                    onLevel(SRC_SPEAKER, pcmLevel(pcm))
+                    // Уровень показываем только для реальных пакетов: во время
+                    // скрытия потерь (conceal) шкала должна быть в нуле
+                    val real = System.currentTimeMillis() - lastRealPacketTime < 400
+                    rxTap?.invoke(pcm, real)
+                    val lvl = if (real) pcmLevel(pcm) else 0f
+                    // Порог тишины: шум декодера и паузы речи — в ноль
+                    onLevel(SRC_SPEAKER, if (lvl < 0.02f) 0f else lvl)
                     if (dbgOut < 5) {
                         Log.d(TAG, "out ${pcm.size}B")
                         dbgOut++
@@ -273,7 +318,9 @@ class OpusEngine(
         ByteBuffer.allocate(8).order(ByteOrder.LITTLE_ENDIAN).putLong(v).array()
 
     /** Подача одного Opus-пакета на декодер (с UDP-потока). */
-    fun onAudioPacket(packet: ByteArray) {
+    fun onAudioPacket(packet: ByteArray, seq: Int) {
+        updateRxStats(seq)
+        lastRealPacketTime = System.currentTimeMillis()
         rxQueue.add(packet)
         receivedAny = true
         if (gateStart == 0L) gateStart = System.currentTimeMillis()
@@ -282,56 +329,82 @@ class OpusEngine(
         decoder?.let { feedDecoder(it, idx, rxQueue.poll() ?: packet) }
     }
 
-    /** Джиттер-гейт открыт: накопили кадры или вышло 80 мс с первого пакета. */
+    /**
+     * Статистика приёма (потери по seq, джиттер по интервалам пакетов).
+     * Раз в 5 секунд корректирует autoKbps: плохо — ниже, стабильно — выше.
+     */
+    private fun updateRxStats(seq: Int) {
+        val now = System.currentTimeMillis()
+        if (lastSeq >= 0) {
+            val dt = now - lastPktTime
+            // seq — счётчик ГОВОРЯЩЕГО: при повторах кадров он может
+            // повторяться или идти назад — это не потери. Пауза > 200 мс
+            // между пакетами — смена реплики/говорящего, тоже не потери.
+            if (dt <= 200) {
+                val gap = (seq - lastSeq - 1).toLong()
+                if (gap in 1..50000) lossCount += gap
+            }
+            pktCount++
+            val j = abs(dt - 20).toDouble()
+            if (j < 100) {
+                jitterAccum += j
+                jitterN++
+            }
+        }
+        lastSeq = seq
+        lastPktTime = now
+        if (lastEvalTime == 0L) {
+            lastEvalTime = now
+            return
+        }
+        if (now - lastEvalTime < 5000 || pktCount < 30) return
+        val lossPct = lossCount * 100.0 / pktCount
+        val jitterMs = if (jitterN > 0) jitterAccum / jitterN else 0.0
+        Log.d(TAG, "stats window: pkt=$pktCount loss=$lossCount pct=$lossPct j=$jitterMs lastSeq=$lastSeq")
+        if (lossPct > 3.0 || jitterMs > 60.0) {
+            if (autoKbps > AUTO_BITRATE_MIN) {
+                autoKbps -= AUTO_BITRATE_STEP
+                Log.d(TAG, "auto bitrate down: ${autoKbps}kbps (loss=${"%.1f".format(lossPct)}% jitter=${"%.0f".format(jitterMs)}ms)")
+            }
+            goodWindows = 0
+        } else if (lossPct < 0.5 && jitterMs < 25.0) {
+            goodWindows++
+            if (goodWindows >= 2 && autoKbps < AUTO_BITRATE_MAX) {
+                autoKbps += AUTO_BITRATE_STEP
+                Log.d(TAG, "auto bitrate up: ${autoKbps}kbps")
+                goodWindows = 0
+            }
+        } else {
+            goodWindows = 0
+        }
+        lossCount = 0
+        pktCount = 0
+        jitterAccum = 0.0
+        jitterN = 0
+        lastEvalTime = now
+        onRxStats?.invoke(lossPct, jitterMs)
+    }
+
+    /** Джиттер-гейт открыт: накопили кадры или вышел короткий таймаут. */
     private fun gateOpen(): Boolean {
         if (playStarted) return true
-        if (rxQueue.size >= jitterTarget) return true
-        return gateStart != 0L && System.currentTimeMillis() - gateStart >= 80
+        if (rxQueue.size >= jitterFrames) return true
+        val waitMs = maxOf(GATE_MIN_WAIT_MS, jitterFrames * 20L)
+        return gateStart != 0L && System.currentTimeMillis() - gateStart >= waitMs
     }
 
     fun onAudioFlush() {
         try {
-            // MediaCodec.flush() возвращает входные буферы, но уже выданные индексы
-            // остаются у нас в freeInputs и дублируются колбэками «повторной выдачи» —
-            // queueInputBuffer падает (index not owned by client) и кадры теряются.
-            // Надёжнее пересоздать декодер: колбэки старого отсекаются проверкой
-            // codec !== decoder.
             player?.flush()
             rxQueue.clear()
             receivedAny = false
             playStarted = false
             gateStart = 0L
             onLevel(SRC_SPEAKER, 0f)
-            restartDecoder()
         } catch (_: Exception) {
         }
     }
 
-    /** Пересоздать только декодер (плеер и джиттер-буфер сохраняем). */
-    private fun restartDecoder() {
-        val dec = decoder
-        decoder = null
-        if (dec != null) {
-            try {
-                dec.stop()
-            } catch (_: Exception) {
-            }
-            try {
-                dec.release()
-            } catch (_: Exception) {
-            }
-        }
-        val format = MediaFormat()
-        format.setString(MediaFormat.KEY_MIME, MediaFormat.MIMETYPE_AUDIO_OPUS)
-        format.setInteger(MediaFormat.KEY_SAMPLE_RATE, OUT_SAMPLE_RATE)
-        format.setInteger(MediaFormat.KEY_CHANNEL_COUNT, CHANNELS)
-        if (startDecoderCodec(format)) {
-            concealLogs = 0
-            dbgOut = 0
-            ptsCounter = 20_000L
-        }
-    }
-
     /**
      * Один кадр тишины (20 мс) для скрытия потерь вместо паузы в звуке.
      * Сгенерирован opuslib: 8 кГц, моно, 20 кбит/с, нули PCM.
@@ -394,7 +467,7 @@ class OpusEngine(
     // ---------- Захват (TX) ----------
 
     /** Начать PTT: запустить запись и кодирование. */
-    fun startCapture(onPacket: (ByteArray) -> Unit) {
+    fun startCapture(micGain: Float = 1.0f, onPacket: (ByteArray) -> Unit) {
         if (encoding) return
         val enc = createEncoder()
         encoder = enc
@@ -417,7 +490,7 @@ class OpusEngine(
         rec.startRecording()
         encoding = true
         val t = Thread({
-            captureLoop(enc, rec, onPacket)
+            captureLoop(enc, rec, micGain, onPacket)
         }, "svx-capture")
         t.isDaemon = true
         recThread = t
@@ -430,18 +503,19 @@ class OpusEngine(
             fmt.setString(MediaFormat.KEY_MIME, MediaFormat.MIMETYPE_AUDIO_OPUS)
             fmt.setInteger(MediaFormat.KEY_SAMPLE_RATE, SAMPLE_RATE)
             fmt.setInteger(MediaFormat.KEY_CHANNEL_COUNT, CHANNELS)
-            fmt.setInteger(MediaFormat.KEY_BIT_RATE, BIT_RATE)
+            fmt.setInteger(MediaFormat.KEY_BIT_RATE, effectiveBitrate())
             fmt.setInteger(MediaFormat.KEY_MAX_INPUT_SIZE, FRAME_SIZE * 2)
             val codec = MediaCodec.createEncoderByType(MediaFormat.MIMETYPE_AUDIO_OPUS)
             codec.configure(fmt, null, null, MediaCodec.CONFIGURE_FLAG_ENCODE)
             codec.start()
+            Log.d(TAG, "encoder started, bitrate=${effectiveBitrate() / 1000}kbps")
             codec
         } catch (e: Exception) {
             null
         }
     }
 
-    private fun captureLoop(enc: MediaCodec, rec: AudioRecord, onPacket: (ByteArray) -> Unit) {
+    private fun captureLoop(enc: MediaCodec, rec: AudioRecord, micGain: Float, onPacket: (ByteArray) -> Unit) {
         val pcmBuf = ByteBuffer.allocateDirect(FRAME_SIZE * 2).order(ByteOrder.LITTLE_ENDIAN)
         val micLevel = FloatArray(1)
         while (encoding) {
@@ -451,6 +525,14 @@ class OpusEngine(
             pcmBuf.limit(n)
             val pcm = ByteArray(n)
             pcmBuf.get(pcm)
+            if (micGain != 1.0f) {
+                for (i in 0 until n step 2) {
+                    val s = ((pcm[i + 1].toInt() shl 8) or (pcm[i].toInt() and 0xFF)).toShort()
+                    val g = (s * micGain).toInt().coerceIn(-32768, 32767)
+                    pcm[i] = (g and 0xFF).toByte()
+                    pcm[i + 1] = ((g shr 8) and 0xFF).toByte()
+                }
+            }
             micLevel[0] = pcmLevel(pcm)
             onLevel(SRC_MIC, micLevel[0])
             try {
@@ -553,4 +635,4 @@ class OpusEngine(
         val norm = (db + 60.0) / 48.0
         return norm.toFloat().coerceIn(0f, 1f)
     }
-}
+}

app/src/main/java/ru/ua1zbe/svxremote/audio/RxRecorder.kt

@@ -0,0 +1,183 @@
+package ru.ua1zbe.svxremote.audio
+
+import android.media.MediaCodec
+import android.media.MediaCodecInfo
+import android.media.MediaFormat
+import android.media.MediaMuxer
+import android.util.Log
+import java.io.File
+import java.nio.ByteBuffer
+import java.time.LocalDateTime
+import java.time.format.DateTimeFormatter
+import java.util.concurrent.LinkedBlockingQueue
+import java.util.concurrent.atomic.AtomicBoolean
+
+/**
+ * Запись декодированного RX-аудио (PCM 48 кГц моно 16 бит) в OGG/Opus.
+ * Тишина (отсутствие приёма) не пишется: во время пауз pts не продвигается,
+ * поэтому речь в файле склеивается без пропусков/пустых участков.
+ */
+class RxRecorder {
+
+    companion object {
+        const val TAG = "SVXRemote"
+        const val SAMPLE_RATE = 48000
+        const val CHANNELS = 1
+    }
+
+    @Volatile
+    private var muxer: MediaMuxer? = null
+    @Volatile
+    private var encoder: MediaCodec? = null
+    private val recording = AtomicBoolean(false)
+    private val queue = LinkedBlockingQueue<ByteArray>()
+    private var worker: Thread? = null
+    private var filePath = ""
+    // Накопленный pts (мкс). Растёт только при подаче реального аудио (без тишины).
+    private var ptsUs = 0L
+    private var trackIndex = -1
+    private var muxStarted = false
+    private var wroteAny = false
+    private val info = MediaCodec.BufferInfo()
+
+    fun isRecording(): Boolean = recording.get()
+
+    fun getFilePath(): String = filePath
+
+    /** Начать запись. dir — базовая директория (используется подкаталог recordings). */
+    fun start(dir: File): Boolean {
+        if (recording.get()) return true
+        val outDir = File(dir, "recordings")
+        if (!outDir.exists()) outDir.mkdirs()
+        val ts = LocalDateTime.now()
+            .format(DateTimeFormatter.ofPattern("yyyy-MM-dd_HH-mm-ss"))
+        val f = File(outDir, "rec_$ts.ogg")
+        filePath = f.absolutePath
+        val mux = try {
+            MediaMuxer(filePath, MediaMuxer.OutputFormat.MUXER_OUTPUT_OGG)
+        } catch (e: Exception) {
+            Log.e(TAG, "recorder muxer create failed: ${e.message}")
+            return false
+        }
+        val fmt = MediaFormat()
+        fmt.setString(MediaFormat.KEY_MIME, MediaFormat.MIMETYPE_AUDIO_OPUS)
+        fmt.setInteger(MediaFormat.KEY_SAMPLE_RATE, SAMPLE_RATE)
+        fmt.setInteger(MediaFormat.KEY_CHANNEL_COUNT, CHANNELS)
+        fmt.setInteger(MediaFormat.KEY_BIT_RATE, 32000)
+        fmt.setInteger(MediaFormat.KEY_MAX_INPUT_SIZE, 1920)
+        val enc = try {
+            MediaCodec.createEncoderByType(MediaFormat.MIMETYPE_AUDIO_OPUS).also {
+                it.configure(fmt, null, null, MediaCodec.CONFIGURE_FLAG_ENCODE)
+                it.start()
+            }
+        } catch (e: Exception) {
+            Log.e(TAG, "recorder encoder create failed: ${e.message}")
+            try { mux.release() } catch (_: Exception) {}
+            return false
+        }
+        muxer = mux
+        encoder = enc
+        trackIndex = -1
+        muxStarted = false
+        ptsUs = 0L
+        queue.clear()
+        recording.set(true)
+        worker = Thread({ workerLoop() }, "rx-recorder").also { it.isDaemon = true; it.start() }
+        Log.d(TAG, "recorder started -> $filePath")
+        return true
+    }
+
+    /** Подача декодированного PCM. isReal == false (тишина/скрытие потерь) — не пишем. */
+    fun feed(pcm: ByteArray, isReal: Boolean) {
+        if (!recording.get() || !isReal) return
+        queue.offer(pcm)
+    }
+
+    private fun workerLoop() {
+        val enc = encoder ?: return
+        val mux = muxer ?: return
+        val timeout = 1000L
+        try {
+            while (recording.get() || queue.isNotEmpty()) {
+                val pcm = queue.poll()
+                if (pcm != null) {
+                    var inIdx = enc.dequeueInputBuffer(timeout)
+                    if (inIdx >= 0) {
+                        val buf = enc.getInputBuffer(inIdx) ?: continue
+                        buf.clear()
+                        buf.put(pcm)
+                        val pts = ptsUs
+                        enc.queueInputBuffer(inIdx, 0, pcm.size, pts, 0)
+                        // Продвигаем pts только для реального аудио (без тишины)
+                        ptsUs += (pcm.size / 2) * 1_000_000L / SAMPLE_RATE
+                    } else {
+                        queue.offer(pcm)
+                        Thread.sleep(2)
+                    }
+                }
+                drainEncoder(enc, mux, false)
+                if (!recording.get() && queue.isEmpty()) break
+            }
+        } catch (e: Exception) {
+            Log.e(TAG, "recorder worker error: ${e.message}")
+        } finally {
+            // Дренаж остатков после остановки
+            try {
+                drainEncoder(enc, mux, true)
+            } catch (_: Exception) {
+            }
+            try { enc.stop() } catch (_: Exception) {}
+            try { enc.release() } catch (_: Exception) {}
+            if (muxStarted) {
+                try { mux.stop() } catch (_: Exception) {}
+            }
+            try { mux.release() } catch (_: Exception) {}
+            encoder = null
+            muxer = null
+            Log.d(TAG, "recorder stopped -> $filePath")
+        }
+    }
+
+    private fun drainEncoder(enc: MediaCodec, mux: MediaMuxer, drainAll: Boolean) {
+        val timeout = if (drainAll) 0L else 1000L
+        var outIdx = enc.dequeueOutputBuffer(info, timeout)
+        while (outIdx >= 0) {
+            if (info.size > 0) {
+                if (trackIndex < 0) {
+                    trackIndex = mux.addTrack(enc.outputFormat)
+                    mux.start()
+                    muxStarted = true
+                    Log.d(TAG, "recorder muxer track added, started")
+                }
+                val outBuf = enc.getOutputBuffer(outIdx) ?: run {
+                    enc.releaseOutputBuffer(outIdx, false)
+                    outIdx = enc.dequeueOutputBuffer(info, timeout)
+                    continue
+                }
+                outBuf.position(info.offset)
+                outBuf.limit(info.offset + info.size)
+                mux.writeSampleData(trackIndex, outBuf, info)
+                wroteAny = true
+            }
+            enc.releaseOutputBuffer(outIdx, false)
+            outIdx = enc.dequeueOutputBuffer(info, timeout)
+        }
+    }
+
+    fun stop() {
+        if (!recording.get()) return
+        recording.set(false)
+        val w = worker
+        if (w != null && w.isAlive) {
+            try { w.join(4000) } catch (_: InterruptedException) {}
+        }
+        worker = null
+        // Если ни одного кадра не записалось (весь сеанс — тишина) — удаляем пустой файл.
+        if (!wroteAny) {
+            try {
+                val f = File(filePath)
+                if (f.exists()) f.delete()
+            } catch (_: Exception) {}
+        }
+    }
+}

app/src/main/java/ru/ua1zbe/svxremote/prefs/Prefs.kt

@@ -136,4 +136,56 @@ object Prefs {
     fun setAprsCoords(context: Context, coords: String) {
         sp(context).edit().putString("aprs_coords", coords.trim()).apply()
     }
+
+    /** Усиление микрофона (1.0 = без усиления). */
+    fun micGain(context: Context): Float =
+        sp(context).getFloat("mic_gain", 1.0f)
+
+    fun setMicGain(context: Context, gain: Float) {
+        sp(context).edit().putFloat("mic_gain", gain.coerceIn(0.5f, 5.0f)).apply()
+    }
+
+    // ---------- Скрытые настройки звука (AudioSettingsActivity) ----------
+
+    /** Буфер воспроизведения RX, мс. */
+    fun rxBufferMs(context: Context): Int =
+        sp(context).getInt("rx_buffer_ms", 417)
+
+    fun setRxBufferMs(context: Context, ms: Int) {
+        sp(context).edit().putInt("rx_buffer_ms", ms.coerceIn(100, 600)).apply()
+    }
+
+    /** Накопление перед стартом воспроизведения, мс (кратно 20). */
+    fun rxJitterMs(context: Context): Int =
+        sp(context).getInt("rx_jitter_ms", 200)
+
+    fun setRxJitterMs(context: Context, ms: Int) {
+        sp(context).edit().putInt("rx_jitter_ms", ms.coerceIn(0, 400)).apply()
+    }
+
+    /** Скорость передачи Opus, кбит/с. 0 = Авто (адаптация под интернет). */
+    fun txBitrateKbps(context: Context): Int =
+        sp(context).getInt("tx_bitrate_kbps", 0)
+
+    fun setTxBitrateKbps(context: Context, kbps: Int) {
+        sp(context).edit().putInt("tx_bitrate_kbps", kbps.coerceIn(0, 32)).apply()
+    }
+
+    /** Показывать строку статистики приёма (потери/джиттер) на главном экране. */
+    fun rxStatsEnabled(context: Context): Boolean =
+        sp(context).getBoolean("rx_stats_enabled", true)
+
+    fun setRxStatsEnabled(context: Context, enabled: Boolean) {
+        sp(context).edit().putBoolean("rx_stats_enabled", enabled).apply()
+    }
+
+    // ---------- RuStore Push ----------
+
+    /** Пуш-токен устройства RuStore (для серверной рассылки). */
+    fun pushToken(context: Context): String =
+        sp(context).getString("push_token", "") ?: ""
+
+    fun setPushToken(context: Context, token: String) {
+        sp(context).edit().putString("push_token", token).apply()
+    }
 }

app/src/main/java/ru/ua1zbe/svxremote/proto/ReflectorClient.kt

@@ -85,6 +85,15 @@ class ReflectorClient(
     @Volatile
     private var fatal = false
 
+    /**
+     * Была ли хотя бы одна успешная сессия за текущее подключение.
+     * Если да — креды уже проверены, поэтому ошибки на рукопожатии считаем
+     * временными (сервер мог ещё держать старую сессию после обрыва) и
+     * продолжаем автопереподключение вместо показа «ошибки авторизации».
+     */
+    @Volatile
+    private var everReady = false
+
     @Volatile
     private var tcpSocket: Socket? = null
     private var udpSocket: DatagramSocket? = null
@@ -107,6 +116,7 @@ class ReflectorClient(
         this.settings = settings
         manualDisconnect.set(false)
         fatal = false
+        everReady = false
         if (running.get()) {
             // Перезапуск с новыми настройками (например, смена профиля)
             running.set(false)
@@ -254,7 +264,10 @@ class ReflectorClient(
             callbacks.onState(STATE_TCP_CONNECTED)
             startTcpSenderThread(socket, s)
             runTcpLoop(socket, s)
-            true
+            // runTcpLoop завершилась: если всё ещё должны работать — значит
+            // соединение разорвано/отклонено, вернём false, чтобы reconnectLoop
+            // выдержал RECONNECT_DELAY_MS и не бомбил сервер переподключениями.
+            !running.get()
         } catch (e: Exception) {
             try {
                 socket.close()
@@ -399,6 +412,7 @@ class ReflectorClient(
                     serverCodecs = info.codecs
                     callbacks.onServerInfo(info)
                     state = STATE_READY
+                    everReady = true
                     callbacks.onState(STATE_READY)
                     // Сначала сообщаем о себе (версия ПО для дашборда), затем
                     // выбираем TG для передачи и подписываемся на прослушивание
@@ -410,7 +424,10 @@ class ReflectorClient(
                         sendTcp(socket, MsgBuilder.selectTg(s.talkGroup))
                         sendTcp(socket, MsgBuilder.tgMonitor(listOf(s.talkGroup)))
                     } else {
-                        sendTcp(socket, MsgBuilder.selectTg(monitor.first()))
+                        // Мониторинг: сидим на базовой группе и слушаем
+                        // уведомления обо всех группах (аудио идёт только
+                        // с выбранной, поэтому переключение — в MainActivity).
+                        sendTcp(socket, MsgBuilder.selectTg(s.talkGroup))
                         sendTcp(socket, MsgBuilder.tgMonitor(monitor))
                     }
                     openUdp(s)
@@ -438,9 +455,17 @@ class ReflectorClient(
 
                 ReflectorProtocol.MSG_ERROR -> {
                     val err = MsgParser.errorMessage(msg.fields)
-                    Log.w(TAG, "MSG_ERROR: $err")
+                    Log.w(TAG, "MSG_ERROR: $err (state=$state, everReady=$everReady)")
                     if (state < STATE_READY) {
-                        stopFatal(err.ifEmpty { "Access denied" })
+                        if (everReady) {
+                            // Креды проверены ранее: ошибка на рукопожатии почти
+                            // всегда временная (сервер ещё держит старую сессию
+                            // после короткого обрыва) — переподключаемся заново.
+                            callbacks.onState(STATE_ERROR, err.ifEmpty { "Переподключение" })
+                            abortSockets()
+                        } else {
+                            stopFatal(err.ifEmpty { "Access denied" })
+                        }
                         return false
                     }
                     callbacks.onError(err)
@@ -449,7 +474,13 @@ class ReflectorClient(
                 else -> Unit // неизвестные сообщения игнорируются
             }
         } catch (e: Exception) {
-            stopFatal("Ошибка протокола: ${e.message}")
+            if (everReady) {
+                // Сбой после успешного подключения — не фатально, переподключаемся.
+                callbacks.onState(STATE_ERROR, "Ошибка протокола: ${e.message}")
+                abortSockets()
+            } else {
+                stopFatal("Ошибка протокола: ${e.message}")
+            }
             return false
         }
         return true
@@ -475,7 +506,12 @@ class ReflectorClient(
     }
 
     private fun protocolError(detail: String): Boolean {
-        stopFatal(detail)
+        if (everReady) {
+            callbacks.onState(STATE_ERROR, detail)
+            abortSockets()
+        } else {
+            stopFatal(detail)
+        }
         return false
     }
 
@@ -538,7 +574,7 @@ class ReflectorClient(
         if (data.size < 6) return
         val r = BinReader(data)
         val type = r.u16()
-        r.u16() // client id
+        val cid = r.u16() // client id
         val seq = r.u16()
         val payload = data.copyOfRange(6, data.size)
         when (type) {
@@ -546,7 +582,7 @@ class ReflectorClient(
             ReflectorProtocol.MSG_UDP_AUDIO -> {
                 val audio = MsgParser.udpAudio(payload)
                 if (audio != null && audio.isNotEmpty()) {
-                    Log.d(TAG, "UDP RX audio seq=$seq len=${audio.size}")
+                    Log.d(TAG, "UDP RX audio seq=$seq cid=$cid len=${audio.size}")
                     callbacks.onAudioPacket(audio, seq)
                 } else {
                     Log.w(TAG, "UDP RX audio empty/null len=${payload.size}")

app/src/main/java/ru/ua1zbe/svxremote/ui/PttButton.kt

@@ -3,15 +3,18 @@ package ru.ua1zbe.svxremote.ui
 import android.content.Context
 import android.graphics.Canvas
 import android.graphics.Color
+import android.graphics.LinearGradient
 import android.graphics.Paint
 import android.graphics.Path
+import android.graphics.Shader
 import android.util.AttributeSet
 import android.view.MotionEvent
 import android.view.View
 import ru.ua1zbe.svxremote.R
 
 /**
- * Большая круглая кнопка PTT. Удерживание — передача.
+ * Большая круглая кнопка PTT в стиле Zello: градиентная заливка с глянцем,
+ * мягкая тень (плавающая кнопка) и тонкий ободок.
  * Состояния: idle (синяя), нажата (красная), отключена (серая).
  */
 class PttButton @JvmOverloads constructor(
@@ -19,8 +22,11 @@ class PttButton @JvmOverloads constructor(
     attrs: AttributeSet? = null
 ) : View(context, attrs) {
 
-    private val paint = Paint(Paint.ANTI_ALIAS_FLAG)
+    private val fillPaint = Paint(Paint.ANTI_ALIAS_FLAG)
     private val ringPaint = Paint(Paint.ANTI_ALIAS_FLAG)
+    private val glossPaint = Paint(Paint.ANTI_ALIAS_FLAG)
+    private val micPaint = Paint(Paint.ANTI_ALIAS_FLAG)
+    private val clip = Path()
 
     private var radius = 0f
     private var centerX = 0f
@@ -31,7 +37,6 @@ class PttButton @JvmOverloads constructor(
         set(value) {
             field = value
             if (!value) setPressed(false)
-            refreshColors()
             invalidate()
         }
 
@@ -50,22 +55,28 @@ class PttButton @JvmOverloads constructor(
     }
 
     init {
+        fillPaint.style = Paint.Style.FILL
+        fillPaint.setShadowLayer(dp(8).toFloat(), 0f, dp(4).toFloat(), Color.argb(80, 0, 0, 0))
         ringPaint.style = Paint.Style.STROKE
-        ringPaint.strokeWidth = dp(3).toFloat()
-        ringPaint.color = Color.parseColor("#3D444D")
-        paint.style = Paint.Style.FILL
-        refreshColors()
+        ringPaint.strokeWidth = dp(2).toFloat()
+        glossPaint.style = Paint.Style.FILL
+        micPaint.style = Paint.Style.FILL
+        micPaint.color = Color.WHITE
         isClickable = true
         isFocusable = true
     }
 
-    private fun refreshColors() {
-        paint.color = when {
-            !enabled2 -> Color.parseColor("#484F58")
-            isPressed -> Color.parseColor("#F85149")
-            else -> Color.parseColor("#1F6FEB")
-        }
-        invalidate()
+    /** (верхний цвет, нижний цвет) градиента заливки. */
+    private fun fillColors(): Pair<Int, Int> = when {
+        !enabled2 -> 0x565E68 to 0x3C424B
+        isPressed -> 0xFF8A80 to 0xDB3A30
+        else -> 0x4A9BFF to 0x1561D6
+    }
+
+    private fun ringColor(): Int = when {
+        !enabled2 -> 0x6B727B
+        isPressed -> 0xFFA79F
+        else -> 0x6FB0FF
     }
 
     private fun dp(v: Int): Int = (v * resources.displayMetrics.density).toInt()
@@ -74,32 +85,51 @@ class PttButton @JvmOverloads constructor(
         super.onSizeChanged(w, h, oldw, oldh)
         centerX = w / 2f
         centerY = h / 2f
-        radius = minOf(w, h) / 2f - dp(16)
-        refreshColors()
+        radius = minOf(w, h) / 2f - dp(18)
     }
 
     override fun onDraw(canvas: Canvas) {
         super.onDraw(canvas)
         val r = radius / (1f + if (isPressed) 0.06f else 0f)
-        canvas.drawCircle(centerX, centerY, r, paint)
-        canvas.drawCircle(centerX, centerY, r, ringPaint)
+        val cx = centerX
+        val cy = centerY
+        val (top, bottom) = fillColors()
 
-        // Иконка микрофона (как icons8: капсула + чашка + ножка + основание)
-        val micPaint = Paint(Paint.ANTI_ALIAS_FLAG)
-        micPaint.color = Color.WHITE
-        micPaint.style = Paint.Style.FILL
+        // Заливка с вертикальным градиентом (глянец)
+        fillPaint.shader = LinearGradient(
+            cx, cy - r, cx, cy + r, top, bottom, Shader.TileMode.CLAMP
+        )
+        canvas.drawCircle(cx, cy, r, fillPaint)
 
-        val x = centerX
-        val y = centerY
-        val s = r * 0.5f
+        // Тонкий ободок по краю
+        ringPaint.color = ringColor()
+        canvas.drawCircle(cx, cy, r - dp(1).toFloat(), ringPaint)
 
+        // Верхний глянец (белое затухание сверху)
+        glossPaint.shader = LinearGradient(
+            cx, cy - r, cx, cy + r * 0.18f,
+            Color.argb(70, 255, 255, 255), Color.TRANSPARENT, Shader.TileMode.CLAMP
+        )
+        clip.reset()
+        clip.addCircle(cx, cy, r, Path.Direction.CW)
+        canvas.save()
+        canvas.clipPath(clip)
+        canvas.drawRect(cx - r, cy - r, cx + r, cy + r, glossPaint)
+        canvas.restore()
+        glossPaint.shader = null
+
+        drawMic(canvas, cx, cy, r * 0.5f)
+    }
+
+    /** Иконка микрофона (капсула + держатель + ножка + основание). */
+    private fun drawMic(canvas: Canvas, x: Float, y: Float, s: Float) {
         // корпус-капсула
         val halfW = s * 0.34f
         canvas.drawRoundRect(
             x - halfW, y - s * 0.85f, x + halfW, y + s * 0.10f,
             halfW, halfW, micPaint
         )
-        // чашка-держатель (U-образная, заполненная)
+        // чашка-держатель (U-образная)
         val cup = Path()
         cup.fillType = Path.FillType.EVEN_ODD
         cup.moveTo(x - s * 0.52f, y + s * 0.06f)
@@ -147,4 +177,4 @@ class PttButton @JvmOverloads constructor(
             else -> true
         }
     }
-}
+}

app/src/main/java/ru/ua1zbe/svxremote/ui/SMeterView.kt

@@ -0,0 +1,128 @@
+package ru.ua1zbe.svxremote.ui
+
+import android.content.Context
+import android.graphics.Canvas
+import android.graphics.Paint
+import android.os.Handler
+import android.os.Looper
+import android.util.AttributeSet
+import android.view.View
+import kotlin.math.roundToInt
+
+/**
+ * S-метр: полоса со шкалой S1–S9, +20…+60, заливкой уровня, белой пик-меткой
+ * (peak-hold) и цифрой текущего уровня справа («S9», «+43» или «---»).
+ * Уровень 0..1; S9 = 55% пути, +60 = 88%.
+ */
+class SMeterView @JvmOverloads constructor(
+    context: Context,
+    attrs: AttributeSet? = null
+) : View(context, attrs) {
+
+    private var fillColor = 0xFF58A6FF.toInt()
+    private val track = Paint().apply { color = 0xFF21262D.toInt() }
+    private val fill = Paint().apply { color = fillColor }
+    private val tick = Paint().apply { color = 0xFF8B949E.toInt(); strokeWidth = dp(1f) }
+    private val tickMajor = Paint().apply { color = 0xFF8B949E.toInt(); strokeWidth = dp(1.5f) }
+    private val peakPaint = Paint().apply { color = 0xFFFFFFFF.toInt(); strokeWidth = dp(2f) }
+    private val label = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFF8B949E.toInt()
+        textSize = sp(9)
+    }
+    private val valuePaint = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFFE6EDF3.toInt()
+        textSize = sp(12)
+        textAlign = Paint.Align.RIGHT
+    }
+    private val idlePaint = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFF8B949E.toInt()
+        textSize = sp(12)
+        textAlign = Paint.Align.RIGHT
+    }
+
+    @Volatile
+    private var target = 0f
+    private var shown = 0f
+    private var peak = 0f
+    private var lastActive = 0L
+
+    private val handler = Handler(Looper.getMainLooper())
+    private val ticker = object : Runnable {
+        override fun run() {
+            // Гарантированный сброс: если сигнала не было 600 мс — в ноль
+            if (System.currentTimeMillis() - lastActive > 600 && target != 0f) target = 0f
+            // Сглаживание уровня и медленный спад пика
+            shown += (target - shown) * 0.35f
+            if (Math.abs(target - shown) < 0.002f) shown = target
+            peak = maxOf(peak * 0.985f, shown)
+            if (peak < 0.003f) peak = 0f
+            invalidate()
+            handler.postDelayed(this, 100)
+        }
+    }
+
+    fun setColor(color: Int) {
+        fillColor = color
+        fill.color = color
+    }
+
+    fun setLevel(level: Float) {
+        if (level > 0.01f) lastActive = System.currentTimeMillis()
+        target = level.coerceIn(0f, 1f)
+    }
+
+    override fun onAttachedToWindow() {
+        super.onAttachedToWindow()
+        handler.post(ticker)
+    }
+
+    override fun onDetachedFromWindow() {
+        handler.removeCallbacksAndMessages(null)
+        super.onDetachedFromWindow()
+    }
+
+    private fun dp(v: Float): Float = v * resources.displayMetrics.density
+    private fun sp(v: Int): Float = v * resources.displayMetrics.scaledDensity
+
+    private fun levelText(level: Float): String = when {
+        level < 0.005f -> "---"
+        level < 0.55f -> "S${(level / 0.55f * 9f).roundToInt().coerceIn(1, 9)}"
+        else -> "+${(((level - 0.55f) / 0.45f) * 60f).roundToInt().coerceIn(1, 99)}"
+    }
+
+    override fun onDraw(canvas: Canvas) {
+        val w = width.toFloat()
+        val h = height.toFloat()
+        val left = dp(2f)
+        val right = w - dp(2f)
+        val bandTop = dp(4f)
+        val bandH = dp(14f)
+
+        // полоса
+        canvas.drawRect(left, bandTop, right, bandTop + bandH, track)
+        val lvl = shown.coerceIn(0f, 1f)
+        if (lvl > 0.002f) {
+            canvas.drawRect(left, bandTop, left + lvl * (right - left), bandTop + bandH, fill)
+        }
+
+        // деления: S1..S9, +20..+60
+        val marks = listOf("S1" to 0.11f, "S3" to 0.22f, "S5" to 0.33f, "S7" to 0.44f,
+            "S9" to 0.55f, "+20" to 0.66f, "+40" to 0.77f, "+60" to 0.88f)
+        for ((text, pos) in marks) {
+            val mx = left + pos * (right - left)
+            val major = pos == 0.55f || pos == 0.88f
+            canvas.drawLine(mx, bandTop, mx, bandTop + bandH, if (major) tickMajor else tick)
+            canvas.drawText(text, mx - dp(8f), bandTop + bandH + dp(11f), label)
+        }
+
+        // пик-метка
+        if (peak > 0.003f) {
+            val px = left + peak.coerceIn(0f, 1f) * (right - left)
+            canvas.drawLine(px, bandTop - dp(3f), px, bandTop + bandH + dp(3f), peakPaint)
+        }
+
+        // цифра уровня справа от полосы (и чуть выше делений)
+        val p = if (target < 0.005f) idlePaint else valuePaint
+        canvas.drawText(levelText(target), right, bandTop + bandH - dp(3f), p)
+    }
+}

app/src/main/java/ru/ua1zbe/svxremote/ui/SoundMeterPreviewView.kt

@@ -0,0 +1,156 @@
+package ru.ua1zbe.svxremote.ui
+
+import android.content.Context
+import android.graphics.Canvas
+import android.graphics.Color
+import android.graphics.Paint
+import android.graphics.RectF
+import android.os.Handler
+import android.os.Looper
+import android.util.AttributeSet
+import android.view.View
+import kotlin.random.Random
+
+/**
+ * Временное демо-окно с примерами индикаторов звука (S-метр, клиппинг,
+ * джиттер/потери). Открывается удержанием на надписи «На связи».
+ * Уровни симулируются, чтобы было видно, как индикаторы работают.
+ */
+class SoundMeterPreviewView @JvmOverloads constructor(
+    context: Context,
+    attrs: AttributeSet? = null
+) : View(context, attrs) {
+
+    private val bg = Paint().apply { color = 0xFF0D1117.toInt() }
+    private val track = Paint().apply { color = 0xFF21262D.toInt() }
+    private val fill = Paint().apply { color = 0xFF58A6FF.toInt() }
+    private val fillHot = Paint().apply { color = 0xFFF85149.toInt() }
+    private val peakPaint = Paint().apply { color = 0xFFFFFFFF.toInt(); strokeWidth = dp(2) }
+    private val tick = Paint().apply { color = 0xFF8B949E.toInt(); strokeWidth = dp(1) }
+    private val label = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFF8B949E.toInt()
+        textSize = sp(11)
+    }
+    private val labelSmall = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFF8B949E.toInt()
+        textSize = sp(9)
+    }
+    private val clipDot = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFFF85149.toInt()
+    }
+    private val clipDotOff = Paint(Paint.ANTI_ALIAS_FLAG).apply {
+        color = 0xFF30363D.toInt()
+    }
+
+    private val handler = Handler(Looper.getMainLooper())
+    private var simLevel = 0.0f
+    private var simPeak = 0.0f
+    private var simJitter = 30.0f
+    private var simLoss = 0.1f
+    private var t = 0.0
+
+    private val anim = object : Runnable {
+        override fun run() {
+            t += 0.08
+            val wave = ((Math.sin(t) + Math.sin(t * 2.3)) / 2 + 1) / 2
+            simLevel = (wave * 0.62 + Random.nextFloat() * 0.12).toFloat()
+            // Периодически «перегруз» — клиппинг и пики
+            if (Random.nextFloat() > 0.92f) simLevel = 0.98f
+            simPeak = maxOf(simLevel, simPeak - 0.02f)
+            simJitter = 25 + Random.nextFloat() * 120
+            simLoss = (Random.nextFloat() * 0.5f).coerceAtLeast(0.03f)
+            invalidate()
+            handler.postDelayed(this, 50)
+        }
+    }
+
+    override fun onAttachedToWindow() {
+        super.onAttachedToWindow()
+        handler.post(anim)
+    }
+
+    override fun onDetachedFromWindow() {
+        handler.removeCallbacksAndMessages(null)
+        super.onDetachedFromWindow()
+    }
+
+    private fun dp(v: Int): Float = v * resources.displayMetrics.density
+    private fun sp(v: Int): Float = v * resources.displayMetrics.scaledDensity
+
+    override fun onDraw(canvas: Canvas) {
+        val w = width.toFloat()
+        val h = height.toFloat()
+        canvas.drawRect(0f, 0f, w, h, bg)
+
+        // --- S-метр ---
+        var y = dp(18)
+        canvas.drawText("S-метр (peak-hold)", dp(16), y, label)
+        y += dp(8)
+        drawSMeter(canvas, w, y)
+
+        // --- Уровень + клиппинг ---
+        y += dp(58)
+        canvas.drawText("Уровень + клиппинг", dp(16), y, label)
+        y += dp(8)
+        drawVUMeter(canvas, w, y)
+
+        // --- Джиттер / потери ---
+        y += dp(58)
+        canvas.drawText("Джиттер и потери пакетов", dp(16), y, label)
+        y += dp(18)
+        canvas.drawText(
+            "джиттер %d мс · потери %.1f%%".format(simJitter.toInt(), simLoss),
+            dp(16), y, label
+        )
+        val bar = RectF(dp(16), y + dp(6), w - dp(16), y + dp(16))
+        canvas.drawRect(bar, track)
+        val jw = (simJitter / 250f).coerceIn(0f, 1f) * bar.width()
+        canvas.drawRect(bar.left, bar.top, bar.left + jw, bar.bottom, fill)
+    }
+
+    /** S-метр: полоса со шкалой S1..S9, +20..+60 и пик-меткой. */
+    private fun drawSMeter(canvas: Canvas, w: Float, top: Float) {
+        val left = dp(16)
+        val right = w - dp(16)
+        val bandTop = top + dp(2)
+        val bandH = dp(14)
+        canvas.drawRect(left, bandTop, right, bandTop + bandH, track)
+        val level = (simLevel).coerceIn(0f, 1f)
+        val fw = level * (right - left)
+        canvas.drawRect(left, bandTop, left + fw, bandTop + bandH, if (level > 0.85f) fillHot else fill)
+        // пик-метка
+        val px = left + simPeak.coerceIn(0f, 1f) * (right - left)
+        canvas.drawLine(px, bandTop - dp(3), px, bandTop + bandH + dp(3), peakPaint)
+        // деления и шкала
+        val marks = listOf("S1" to 0.11f, "S3" to 0.22f, "S5" to 0.33f, "S7" to 0.44f,
+            "S9" to 0.55f, "+20" to 0.66f, "+40" to 0.77f, "+60" to 0.88f)
+        for ((text, pos) in marks) {
+            val mx = left + pos * (right - left)
+            canvas.drawLine(mx, bandTop, mx, bandTop + bandH, tick)
+            canvas.drawText(text, mx - dp(10), bandTop + bandH + dp(12), labelSmall)
+        }
+        canvas.drawText("+%.0f".format(level * 60), left, bandTop - dp(4), labelSmall)
+    }
+
+    /** VU-полоса с зоной перегрузки и красной точкой клиппинга. */
+    private fun drawVUMeter(canvas: Canvas, w: Float, top: Float) {
+        val left = dp(16)
+        val right = w - dp(52)
+        val bandTop = top + dp(2)
+        val bandH = dp(14)
+        canvas.drawRect(left, bandTop, right, bandTop + bandH, track)
+        val level = simLevel.coerceIn(0f, 1f)
+        val fw = level * (right - left)
+        canvas.drawRect(left, bandTop, left + fw, bandTop + bandH, fill)
+        // красная зона последних 15%
+        canvas.drawRect(
+            right - (right - left) * 0.15f, bandTop, right, bandTop + bandH,
+            if (level > 0.85f) fillHot else track
+        )
+        // клиппинг-точка
+        val cxp = w - dp(24)
+        val cyp = bandTop + bandH / 2
+        canvas.drawCircle(cxp, cyp, dp(7), if (level > 0.92f) clipDot else clipDotOff)
+        canvas.drawText("CLIP", cxp - dp(20), cyp + dp(10), labelSmall)
+    }
+}

app/src/main/res/drawable/bg_section.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="utf-8"?>
+<shape xmlns:android="http://schemas.android.com/apk/res/android" android:shape="rectangle">
+    <solid android:color="@color/surface" />
+    <corners android:radius="14dp" />
+    <stroke android:width="1dp" android:color="@color/surface_light" />
+</shape>

app/src/main/res/drawable/ic_delete.xml

@@ -0,0 +1,9 @@
+<vector xmlns:android="http://schemas.android.com/apk/res/android"
+    android:width="24dp"
+    android:height="24dp"
+    android:viewportWidth="24"
+    android:viewportHeight="24">
+    <path
+        android:fillColor="#FFFFFF"
+        android:pathData="M6,7h12v12a1,1 0,0 1,-1 1H7a1,1 0,0 1,-1 -1V7zM9,9v9h1V9H9zM14,9v9h1V9h-1zM4,5h16v2H4V5z" />
+</vector>

app/src/main/res/drawable/ic_play.xml

@@ -0,0 +1,9 @@
+<vector xmlns:android="http://schemas.android.com/apk/res/android"
+    android:width="24dp"
+    android:height="24dp"
+    android:viewportWidth="24"
+    android:viewportHeight="24">
+    <path
+        android:fillColor="#FFFFFF"
+        android:pathData="M8,5v14l11,-7z" />
+</vector>

app/src/main/res/drawable/ic_record.xml

@@ -0,0 +1,9 @@
+<vector xmlns:android="http://schemas.android.com/apk/res/android"
+    android:width="24dp"
+    android:height="24dp"
+    android:viewportWidth="24"
+    android:viewportHeight="24">
+    <path
+        android:fillColor="#8B949E"
+        android:pathData="M12,12m-7,0a7,7 0,1 1,14 0a7,7 0,1 1,-14 0" />
+</vector>

app/src/main/res/drawable/ic_stop.xml

@@ -0,0 +1,9 @@
+<vector xmlns:android="http://schemas.android.com/apk/res/android"
+    android:width="24dp"
+    android:height="24dp"
+    android:viewportWidth="24"
+    android:viewportHeight="24">
+    <path
+        android:fillColor="#FFFFFF"
+        android:pathData="M7,7h10v10h-10z" />
+</vector>

app/src/main/res/layout/activity_audio_settings.xml

@@ -0,0 +1,157 @@
+<?xml version="1.0" encoding="utf-8"?>
+<ScrollView xmlns:android="http://schemas.android.com/apk/res/android"
+    android:layout_width="match_parent"
+    android:layout_height="match_parent"
+    android:background="@color/bg">
+
+    <LinearLayout
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:orientation="vertical"
+        android:padding="20dp">
+
+        <TextView
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:text="@string/audio_settings_title"
+            android:textColor="@color/text_primary"
+            android:textSize="20sp"
+            android:textStyle="bold"
+            android:layout_marginBottom="4dp" />
+
+        <TextView
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:text="@string/audio_settings_hint"
+            android:textColor="@color/text_secondary"
+            android:textSize="13sp"
+            android:layout_marginBottom="20dp" />
+
+        <LinearLayout
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:orientation="horizontal"
+            android:gravity="center_vertical">
+
+            <TextView
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:text="@string/audio_mic_gain"
+                android:textColor="@color/text_primary"
+                android:textSize="15sp" />
+
+            <TextView
+                android:id="@+id/lbl_mic_gain_value"
+                android:layout_width="wrap_content"
+                android:layout_height="wrap_content"
+                android:textColor="@color/text_secondary"
+                android:textSize="14sp" />
+        </LinearLayout>
+
+        <SeekBar
+            android:id="@+id/seek_mic_gain"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:max="40"
+            android:layout_marginBottom="20dp" />
+
+        <LinearLayout
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:orientation="horizontal"
+            android:gravity="center_vertical">
+
+            <TextView
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:text="@string/audio_rx_buffer"
+                android:textColor="@color/text_primary"
+                android:textSize="15sp" />
+
+            <TextView
+                android:id="@+id/lbl_rx_buffer_value"
+                android:layout_width="wrap_content"
+                android:layout_height="wrap_content"
+                android:textColor="@color/text_secondary"
+                android:textSize="14sp" />
+        </LinearLayout>
+
+        <SeekBar
+            android:id="@+id/seek_rx_buffer"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:max="25"
+            android:layout_marginBottom="20dp" />
+
+        <LinearLayout
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:orientation="horizontal"
+            android:gravity="center_vertical">
+
+            <TextView
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:text="@string/audio_jitter"
+                android:textColor="@color/text_primary"
+                android:textSize="15sp" />
+
+            <TextView
+                android:id="@+id/lbl_jitter_value"
+                android:layout_width="wrap_content"
+                android:layout_height="wrap_content"
+                android:textColor="@color/text_secondary"
+                android:textSize="14sp" />
+        </LinearLayout>
+
+        <SeekBar
+            android:id="@+id/seek_jitter"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:max="20"
+            android:layout_marginBottom="20dp" />
+
+        <LinearLayout
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:orientation="horizontal"
+            android:gravity="center_vertical">
+
+            <TextView
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:text="@string/audio_tx_bitrate"
+                android:textColor="@color/text_primary"
+                android:textSize="15sp" />
+        </LinearLayout>
+
+        <Spinner
+            android:id="@+id/spin_tx_bitrate"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:layout_marginBottom="24dp" />
+
+        <CheckBox
+            android:id="@+id/chk_rx_stats"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:layout_marginBottom="24dp"
+            android:text="@string/audio_rx_stats"
+            android:textColor="@color/text_primary"
+            android:textSize="15sp" />
+
+        <Button
+            android:id="@+id/btn_audio_save"
+            android:layout_width="match_parent"
+            android:layout_height="52dp"
+            android:text="@string/btn_save"
+            android:textColor="#0D1117"
+            android:background="@drawable/bg_primary_btn"
+            android:textSize="16sp"
+            android:textStyle="bold" />
+    </LinearLayout>
+</ScrollView>

app/src/main/res/layout/activity_main.xml

@@ -85,10 +85,22 @@
                     android:ellipsize="end"
                     android:text="@string/settings_not_configured" />
 
+                <ImageButton
+                    android:id="@+id/btn_record"
+                    android:layout_width="44dp"
+                    android:layout_height="44dp"
+                    android:layout_marginStart="8dp"
+                    android:src="@drawable/ic_record"
+                    android:background="?android:attr/selectableItemBackgroundBorderless"
+                    android:contentDescription="@string/btn_record"
+                    android:scaleType="centerInside"
+                    android:tint="@color/text_secondary" />
+
                 <ImageButton
                     android:id="@+id/btn_monitor"
                     android:layout_width="44dp"
                     android:layout_height="44dp"
+                    android:layout_marginStart="8dp"
                     android:src="@drawable/ic_headset"
                     android:background="?android:attr/selectableItemBackgroundBorderless"
                     android:contentDescription="@string/btn_monitor"
@@ -104,77 +116,89 @@
                     android:textStyle="bold"
                     android:fontFamily="monospace" />
             </LinearLayout>
-
-            <TextView
-                android:id="@+id/lbl_subtitle"
-                android:layout_width="match_parent"
-                android:layout_height="wrap_content"
-                android:layout_marginTop="4dp"
-                android:gravity="center"
-                android:textColor="@color/text_secondary"
-                android:textSize="14sp"
-                android:singleLine="true"
-                android:ellipsize="end" />
         </LinearLayout>
     </LinearLayout>
 
-    <!-- Статус соединения -->
-    <TextView
-        android:id="@+id/status_chip"
+    <!-- Секция: APRS/подключение + статус -->
+    <LinearLayout
         android:layout_width="match_parent"
         android:layout_height="wrap_content"
-        android:layout_marginTop="20dp"
+        android:layout_marginTop="12dp"
+        android:orientation="vertical"
+        android:background="@drawable/bg_section"
+        android:paddingStart="14dp"
+        android:paddingEnd="14dp"
+        android:paddingTop="10dp"
+        android:paddingBottom="10dp">
+
+        <TextView
+            android:id="@+id/lbl_subtitle"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:gravity="center"
+            android:textColor="@color/text_secondary"
+            android:textSize="14sp"
+            android:singleLine="true"
+            android:ellipsize="end" />
+
+        <!-- Статус соединения -->
+        <TextView
+            android:id="@+id/status_chip"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:layout_marginTop="8dp"
+            android:gravity="center"
+            android:textColor="@color/danger"
+            android:textSize="18sp"
+            android:textStyle="bold"
+            android:text="@string/status_disconnected" />
+    </LinearLayout>
+
+    <!-- Говорящий (единая строка): «Говорит …» при приёме, иначе позывной+TG -->
+    <TextView
+        android:id="@+id/lbl_talker"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:layout_marginTop="14dp"
         android:gravity="center"
-        android:textColor="@color/danger"
-        android:textSize="18sp"
+        android:textColor="@color/accent"
+        android:textSize="22sp"
         android:textStyle="bold"
-        android:text="@string/status_disconnected" />
+        android:singleLine="true"
+        android:ellipsize="end" />
 
     <!-- S-метры -->
     <LinearLayout
         android:layout_width="match_parent"
         android:layout_height="wrap_content"
-        android:layout_marginTop="28dp"
-        android:orientation="vertical">
+        android:layout_marginTop="16dp"
+        android:orientation="vertical"
+        android:background="@drawable/bg_section"
+        android:paddingStart="14dp"
+        android:paddingEnd="14dp"
+        android:paddingTop="12dp"
+        android:paddingBottom="12dp">
 
         <LinearLayout
             android:layout_width="match_parent"
             android:layout_height="wrap_content"
             android:orientation="horizontal"
-            android:gravity="center_vertical">
+            android:gravity="top">
 
             <TextView
                 android:layout_width="34dp"
                 android:layout_height="wrap_content"
+                android:layout_marginTop="6dp"
                 android:text="@string/meter_rx"
                 android:textColor="@color/text_secondary"
                 android:textSize="13sp"
                 android:textStyle="bold" />
 
-            <FrameLayout
+            <ru.ua1zbe.svxremote.ui.SMeterView
+                android:id="@+id/rx_meter"
                 android:layout_width="0dp"
-                android:layout_height="16dp"
-                android:layout_weight="1"
-                android:background="@drawable/bg_meter">
-
-                <View
-                    android:id="@+id/rx_bar_fill"
-                    android:layout_width="match_parent"
-                    android:layout_height="match_parent"
-                    android:background="@drawable/bg_meter_fill_rx"
-                    android:pivotX="0"
-                    android:scaleX="0" />
-            </FrameLayout>
-
-            <TextView
-                android:id="@+id/rx_db"
-                android:layout_width="64dp"
-                android:layout_height="wrap_content"
-                android:gravity="end"
-                android:fontFamily="monospace"
-                android:text="@string/meter_idle"
-                android:textColor="@color/text_primary"
-                android:textSize="13sp" />
+                android:layout_height="52dp"
+                android:layout_weight="1" />
         </LinearLayout>
 
         <LinearLayout
@@ -182,64 +206,46 @@
             android:layout_height="wrap_content"
             android:layout_marginTop="10dp"
             android:orientation="horizontal"
-            android:gravity="center_vertical">
+            android:gravity="top">
 
             <TextView
                 android:layout_width="34dp"
                 android:layout_height="wrap_content"
+                android:layout_marginTop="6dp"
                 android:text="@string/meter_mic"
                 android:textColor="@color/text_secondary"
                 android:textSize="13sp"
                 android:textStyle="bold" />
 
-            <FrameLayout
+            <ru.ua1zbe.svxremote.ui.SMeterView
+                android:id="@+id/mic_meter"
                 android:layout_width="0dp"
-                android:layout_height="16dp"
-                android:layout_weight="1"
-                android:background="@drawable/bg_meter">
-
-                <View
-                    android:id="@+id/mic_bar_fill"
-                    android:layout_width="match_parent"
-                    android:layout_height="match_parent"
-                    android:background="@drawable/bg_meter_fill_mic"
-                    android:pivotX="0"
-                    android:scaleX="0" />
-            </FrameLayout>
-
-            <TextView
-                android:id="@+id/mic_db"
-                android:layout_width="64dp"
-                android:layout_height="wrap_content"
-                android:gravity="end"
-                android:fontFamily="monospace"
-                android:text="@string/meter_idle"
-                android:textColor="@color/text_primary"
-                android:textSize="13sp" />
+                android:layout_height="52dp"
+                android:layout_weight="1" />
         </LinearLayout>
+
+        <!-- Статистика приёма (скрытые настройки, по умолчанию выключено) -->
+        <TextView
+            android:id="@+id/lbl_rx_stats"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:layout_marginTop="8dp"
+            android:gravity="center"
+            android:textColor="@color/text_secondary"
+            android:textSize="13sp"
+            android:visibility="gone" />
     </LinearLayout>
 
-    <!-- Последний говоривший -->
+    <!-- Индикация направления: RX (приём) / TX (передача) -->
     <TextView
-        android:id="@+id/lbl_talker_title"
-        android:layout_width="match_parent"
+        android:id="@+id/lbl_duplex"
+        android:layout_width="wrap_content"
         android:layout_height="wrap_content"
-        android:layout_marginTop="24dp"
+        android:layout_marginTop="2dp"
         android:gravity="center"
-        android:textColor="@color/text_secondary"
-        android:textSize="13sp"
-        android:text="@string/talker_last_none" />
-
-    <TextView
-        android:id="@+id/lbl_talker"
-        android:layout_width="match_parent"
-        android:layout_height="wrap_content"
-        android:gravity="center"
-        android:textColor="@color/accent"
-        android:textSize="22sp"
+        android:textSize="24sp"
         android:textStyle="bold"
-        android:singleLine="true"
-        android:ellipsize="end" />
+        android:visibility="invisible" />
 
     <Space
         android:layout_width="match_parent"
@@ -249,19 +255,8 @@
     <!-- Кнопка PTT -->
     <ru.ua1zbe.svxremote.ui.PttButton
         android:id="@+id/ptt_button"
-        android:layout_width="130dp"
-        android:layout_height="130dp" />
-
-    <TextView
-        android:id="@+id/lbl_ptt_hint"
-        android:layout_width="wrap_content"
-        android:layout_height="wrap_content"
-        android:layout_marginTop="14dp"
-        android:gravity="center"
-        android:textColor="@color/text_secondary"
-        android:textSize="14sp"
-        android:textStyle="bold"
-        android:text="@string/hold_to_talk" />
+        android:layout_width="170dp"
+        android:layout_height="170dp" />
 
     <Space
         android:layout_width="match_parent"

app/src/main/res/layout/activity_settings.xml

@@ -218,7 +218,6 @@
             android:layout_height="wrap_content"
             android:layout_marginTop="24dp"
             android:gravity="center"
-            android:text="@string/app_version"
             android:textColor="@color/text_secondary"
             android:textSize="12sp" />
     </LinearLayout>

app/src/main/res/layout/dialog_recording_item.xml

@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    android:layout_width="match_parent"
+    android:layout_height="wrap_content"
+    android:orientation="horizontal"
+    android:gravity="center_vertical"
+    android:paddingStart="16dp"
+    android:paddingEnd="8dp"
+    android:paddingTop="10dp"
+    android:paddingBottom="10dp">
+
+    <TextView
+        android:id="@+id/rec_name"
+        android:layout_width="0dp"
+        android:layout_weight="1"
+        android:layout_height="wrap_content"
+        android:textColor="@color/text_primary"
+        android:textSize="14sp"
+        android:singleLine="true"
+        android:ellipsize="middle" />
+
+    <ImageButton
+        android:id="@+id/rec_play"
+        android:layout_width="40dp"
+        android:layout_height="40dp"
+        android:src="@drawable/ic_play"
+        android:tint="@color/accent"
+        android:background="?android:attr/selectableItemBackgroundBorderless"
+        android:scaleType="centerInside"
+        android:contentDescription="Воспроизвести" />
+
+    <ImageButton
+        android:id="@+id/rec_delete"
+        android:layout_width="40dp"
+        android:layout_height="40dp"
+        android:src="@drawable/ic_delete"
+        android:tint="@color/danger"
+        android:background="?android:attr/selectableItemBackgroundBorderless"
+        android:scaleType="centerInside"
+        android:contentDescription="Удалить" />
+</LinearLayout>

app/src/main/res/values/strings.xml

@@ -18,36 +18,58 @@
     <string name="pref_aprs_label">Метеостанции (APRS)</string>
     <string name="pref_aprs_hint">Экспериментально: принимает метеостанции в радиусе 250 км. Последняя станция показывается вместо строки сервера на главном экране.</string>
     <string name="pref_aprs_coords">Координаты (широта, долгота)</string>
-    <string name="pref_aprs_coords_hint">пусто = центр Санкт-Петербурга, например 59.95, 30.30</string>
+    <string name="pref_aprs_coords_hint">пусто = СПб, напр. 59.95, 30.30</string>
+    <string name="audio_settings_title">Настройки звука</string>
+    <string name="audio_settings_hint">Скрытые настройки: применяются при следующем подключении/передаче.</string>
+    <string name="audio_mic_gain">Усиление микрофона</string>
+    <string name="audio_rx_buffer">Буфер воспроизведения</string>
+    <string name="audio_jitter">Накопление перед стартом</string>
+    <string name="audio_tx_bitrate">Скорость передачи (Opus)</string>
+    <string name="audio_tx_bitrate_auto">Авто</string>
+    <string name="audio_tx_bitrate_fmt">%1$d кбит/с</string>
+    <string name="audio_rx_stats">Показывать статистику приёма (потери/джиттер)</string>
+    <string name="rx_stats_fmt">RX: потери %1$.1f%%, джиттер %2$d мс</string>
     <string name="toast_node_joined">Подключился: %1$s%2$s</string>
     <string name="toast_node_left">Отключился: %1$s%2$s</string>
     <string name="node_tg_suffix"> (группа %1$d)</string>
     <string name="node_with_tg">%1$s — TG%2$d</string>
     <string name="btn_save">Сохранить</string>
-    <string name="app_version">SVXhomyak — v1.0.5</string>
+    <string name="app_version_fmt">SVXhomyak — v%1$s</string>
     <string name="saved">Сохранено</string>
     <string name="pref_callsign_hint">например UA1ZBE</string>
 
     <string name="status_disconnected">Отключено</string>
     <string name="app_title">SVXHomyak</string>
     <string name="btn_power">Выключить: отключиться и закрыть</string>
+    <string name="btn_record">Запись приёма в файл (нажмите, чтобы начать/остановить)</string>
     <string name="btn_monitor">Мониторинг групп (нажмите, чтобы включить)</string>
-    <string name="monitoring_dev_warning">Функция находится в разработке. Может работать некорректно!</string>
+    <string name="monitoring_dev_warning">Мониторинг выбранных групп!</string>
     <string name="monitor_off">Обычный режим</string>
     <string name="btn_monitor_on">Мониторинг групп включен (нажмите, чтобы выключить)</string>
+    <string name="record_started">Запись приёма начата</string>
+    <string name="record_saved">Сохранено: %1$s</string>
+    <string name="record_failed">Не удалось начать запись (формат OGG недоступен)</string>
+    <string name="recordings_title">Записи приёма</string>
+    <string name="record_play_failed">Не удалось воспроизвести запись</string>
+    <string name="record_delete_title">Удалить запись?</string>
+    <string name="record_delete_yes">Удалить</string>
+    <string name="record_deleted">Удалено</string>
     <string name="status_monitoring">Мониторинг: %1$s</string>
-    <string name="talker_mon">Говорит: %1$s · TG%2$d</string>
-    <string name="talker_mon_priority">ПРИОРИТЕТ: %1$s · TG%2$d</string>
+    <string name="talker_active_fmt">Говорит %1$s TG%2$d</string>
+    <string name="talker_idle_fmt">%1$s TG%2$d</string>
+    <string name="duplex_rx">RX</string>
+    <string name="duplex_tx">TX</string>
     <string name="status_big_disconnected">DISCONNECTED</string>
     <string name="status_big_connected">CONNECTED</string>
     <string name="status_big_talking">ПЕРЕДАЧА</string>
     <string name="hint_connect">Нажмите, чтобы подключиться</string>
     <string name="hint_disconnect">Нажмите, чтобы отключиться</string>
-    <string name="hold_to_talk">HOLD TO TALK</string>
     <string name="meter_rx">RX</string>
     <string name="meter_mic">MIC</string>
     <string name="meter_idle">---</string>
-    <string name="meter_db">-%1$d dB</string>
+    <string name="meter_db">+%1$d dB</string>
+    <string name="meter_preview_title">Примеры индикаторов звука</string>
+    <string name="meter_preview_hint">Временное демо (уровни симулируются). Скажи, что реализовать по-настоящему.</string>
     <string name="tg_badge">TG%1$d ▾</string>
     <string name="talker_last_none">Последний: —</string>
     <string name="status_connecting">Подключение…</string>
@@ -58,12 +80,13 @@
     <string name="notif_connected">Соединение с рефлектором активно</string>
     <string name="notif_talking">Говорит: %1$s</string>
     <string name="notif_last_talker">Последний: %1$s</string>
+    <string name="push_channel_id">svx_push</string>
+    <string name="push_channel_name">Пуш-уведомления</string>
 
     <string name="btn_connect">Подключиться</string>
     <string name="btn_disconnect">Отключиться</string>
 
     <string name="talker_none">—</string>
-    <string name="talker_now">Последний: %1$s</string>
     <string name="talker_on_tg">группа %1$d</string>
 
     <string name="ptt_hint">Удерживайте кнопку, чтобы говорить</string>

gradle.properties

@@ -5,4 +5,5 @@ org.gradle.daemon=false
 org.gradle.parallel=false
 org.gradle.caching=false
 kotlin.compiler.execution.strategy=in-process
-android.nonTransitiveRClass=true
+android.nonTransitiveRClass=true
+android.useAndroidX=true

settings.gradle.kts

@@ -11,6 +11,7 @@ dependencyResolutionManagement {
     repositories {
         google()
         mavenCentral()
+        maven("https://nexus-external.rustore.ru/repository/maven-rustore-exposed/")
     }
 }