56 Commits
v1.0.5 ... main

Author SHA1 Message Date
ua1zbe
fcaf7355b5 Bump version to 1.0.15 (17) 2026-10-09 14:31:26 +03:00
ua1zbe
78bac27175 MainActivity: кнопка «Назад» сворачивает приложение в фон
onBackPressed -> moveTaskToBack(true): задача уходит в фон (как Home),
активность и сервис не завершаются.
2026-10-09 14:29:37 +03:00
ua1zbe
2d332f10bb Splash: не создавать дубликат при тапе по иконке
Если приложение уже запущено (есть задача), launcher-активность добавляется
поверх неё. Добавлен guard isTaskRoot: в этом случае SplashActivity сразу
закрывается, текущий экран просто разворачивается — без splash и перезапуска.
Холодный старт (задача отсутствует) работает как прежде.
2026-10-09 14:25:04 +03:00
ua1zbe
96ab5c76e2 Stats: считать только холодный запуск; время по Москве
Засчитываем запуск лишь когда процесс создан заново (приложение было
выгружено), через флаг SvxApp.coldStart из SplashActivity. Выход из фона
и повторный тап по иконке (процесс жив) больше не учитываются. Время
последнего запуска пишем по Москве (формат ISO с офсетом +03:00).
Убрана зависимость lifecycle-process.
2026-10-09 14:11:56 +03:00
ua1zbe
4e7bf86f37 Stats: считать запуском каждый выход на передний план
SvxApp.onCreate вызывается один раз на процесс, поэтому при живом
фоне повторные открытия не учитывались. Теперь считаем onStart
ProcessLifecycleOwner (холодный старт и каждое открытие приложения).
2026-10-09 14:03:25 +03:00
ua1zbe
b6e4fb7e3a Add launch stats reporting per callsign
При старте приложения обновляет запись своего позывного во внешнем
документе: версия ПО, время последнего запуска и число запусков.
Записи других позывных не изменяются.
2026-10-09 13:51:37 +03:00
ua1zbe
0a24a6f6c0 Bump version to 1.0.14 (16) 2026-10-09 13:20:28 +03:00
ua1zbe
b847320360 reconnect: соблюдать паузу между попытками (backoff)
tryConnectOnce игнорировала результат runTcpLoop и всегда возвращала true,
из-за чего reconnectLoop не делал паузу и переподключался заново каждые
~30 мс, заваливая сервер MSG_ERROR 'Access denied'. Теперь возвращаем
!running, поэтому после разрыва/отказа выдерживается RECONNECT_DELAY_MS.
2026-10-09 13:17:50 +03:00
ua1zbe
203e5f6ed5 reconnect: не уходить в «ошибку авторизации» при коротком обрыве
После короткого обрыва сервер ещё держит старую сессию и на рукопожатии
присылает MSG_ERROR. Клиент трактовал любую ошибку до STATE_READY как
фатальную (stopFatal → STATE_AUTH_FAILED) и прекращал переподключения.

Теперь ошибки рукопожатия (MSG_ERROR, протокольные сбои, слишком большой
кадр) считаются временными, если успешная сессия уже была (everReady):
показываем STATE_ERROR и продолжаем автопереподключение. Фатально — только
до первой успешной авторизации (реально неверные креды).
2026-10-09 13:05:05 +03:00
ua1zbe
491dff03db 1.0.13 (versionCode 15) 2026-09-16 16:09:40 +03:00
ua1zbe
fe6560e494 RuStore Push: автоподписка устройств на топик svxhomyak при старте 2026-09-16 09:38:16 +03:00
ua1zbe
fac8192499 RuStore Push SDK: получение и отображение пуш-уведомлений
- Подключён ru.rustore.sdk:pushclient:7.4.0 (репозиторий Rustore).
- SvxApp: канал svx_push и инициализация RuStorePushClient с project_id;
  push-токен устройства сохраняется в настройках.
- PushMessagingService (RuStoreMessagingService): onNewToken, onMessageReceived
  (data-only пуши показываем сами), onDeletedMessages, onError.
- Манифест: сервис, значок/канал по умолчанию, android.useAndroidX=true
  (зависимость тянет androidx).
- README: как рассылать пуши через vkpns.rustore.ru API.
2026-09-16 08:35:42 +03:00
ua1zbe
1af9bfda80 Audio: reduce RX startup clipping 2026-08-26 08:11:04 +03:00
ua1zbe
f6c37d4fc0 README: описан функционал — запись в OGG, скрытые настройки звука, мониторинг, PTT в стиле Zello, строка говорящего 2026-08-21 12:34:52 +03:00
ua1zbe
f23d8e35bb 1.0.12: UI — убрана HOLD TO TALK, PTT крупнее, строка говорящего между блоками
- Удалена надпись HOLD TO TALK (lbl_ptt_hint).
- PTT-кнопка увеличена 130→170 dp.
- Строка говорящего перенесена между блоками «на связи» и
  индикаторами; единый формат: «Говорит UA1ZBE TG12» при приёме,
  «UA1ZBE TG12» когда приёма нет (шрифт прежний).
2026-08-21 11:54:44 +03:00
ua1zbe
587d46578e 1.0.12: PTT-кнопка в стиле Zello (градиент, тень, глянец, ободок) 2026-08-21 11:39:46 +03:00
ua1zbe
7342dddd0b 1.0.12: читаемое имя записи (дата/время вместо hex)
rec_YYYY-MM-DD_HH-mm-SS.ogg вместо rec_<hex>.ogg.
2026-08-21 11:31:58 +03:00
ua1zbe
e32d6967aa 1.0.12: список записей по долгому тапу на кнопку записи
- Long-press (3 с) кнопки записи открывает диалог со списком
  файлов recordings/*.ogg.
- В диалоге: воспроизведение (MediaPlayer, переключатель
  play/stop) и удаление с подтверждением.
- Пустой список — тост «Нет записей».
- Иконки ic_play/ic_stop/ic_delete, разметка dialog_recording_item.
2026-08-21 11:28:51 +03:00
ua1zbe
99a867df6f 1.0.12: запись приёма в OGG с пропуском тишины
- RxRecorder: MediaCodec(Opus) + MediaMuxer(OGG), пишет декодированный
  RX PCM 48 кГц; pts не продвигается во время тишины, поэтому паузы
  в эфире не попадают в файл.
- OpusEngine.rxTap: перехват PCM из выхода декодера.
- SvxService: startRecording()/stopRecording()/isRecording().
- MainActivity: кнопка btn_record между позывным и монитором,
  индикация (иконка краснеет), тосты о старте/сохранении.
- Файлы: Android/data/ru.ua1zbe.svxremote/files/recordings/rec_*.ogg.
  Пустой файл (весь сеанс — тишина) удаляется.
2026-08-21 11:09:01 +03:00
ua1zbe
29734e6203 Секции с фоном: блок индикаторов и блок APRS/статуса 2026-08-21 08:29:41 +03:00
ua1zbe
af9bb48f7e Bump to 1.0.11 2026-08-19 09:40:48 +03:00
ua1zbe
c8daa276fc Фикс подсчёта потерь: повторы/инверсии seq говорящего и паузы не считаются потерями 2026-08-19 09:37:44 +03:00
ua1zbe
1bfac034cd RX-статистика включена по умолчанию 2026-08-19 09:08:32 +03:00
ua1zbe
7b8e897e8a RX-статистика (потери/джиттер) на главном экране, галочка в скрытых настройках 2026-08-19 08:57:39 +03:00
ua1zbe
c279982778 Bump to 1.0.10 2026-08-19 08:36:59 +03:00
ua1zbe
3b2a31e133 1.0.10: выбор скорости передачи Opus + авто-адаптация; фикс подрыва в начале приёма 2026-08-19 08:35:20 +03:00
ua1zbe
f5f51bce0c Bump to 1.0.9 2026-08-18 16:31:51 +03:00
ua1zbe
fbded33b67 Enlarge RX/TX indicator to 24sp 2026-08-18 16:26:11 +03:00
ua1zbe
6cee5999b8 Show 'Говорит TG..' + callsign + RX/TX duplex indicator 2026-08-18 16:22:41 +03:00
ua1zbe
2d85b0587b Fix talker label in normal mode; keep base group during own TX 2026-08-18 16:10:32 +03:00
ua1zbe
43890117b2 Monitoring toast: 'Мониторинг выбранных групп!' 2026-08-18 16:02:15 +03:00
ua1zbe
e5f964dff7 Toggle monitoring over live connection without reconnect 2026-08-18 15:58:09 +03:00
ua1zbe
05ba30e0c6 Enable PTT in monitoring mode; don't switch group while transmitting 2026-08-18 15:50:13 +03:00
ua1zbe
e53186ea52 Fix group monitoring: per-group 15s idle timeout, drop priority lock 2026-08-18 15:42:52 +03:00
ua1zbe
b0bf837a92 Force RX meter to zero 600ms after signal ends; silence threshold 2026-08-18 15:21:29 +03:00
ua1zbe
88739f17a9 Replace RX/MIC bars with S-meter (S1-S9, +20..+60, peak-hold) 2026-08-18 15:15:34 +03:00
ua1zbe
b63ef121f9 Sound meter preview dialog (hold on 'На связи'): S-meter, clipping, jitter/loss demo 2026-08-18 15:07:53 +03:00
ua1zbe
b45f871544 Bump to 1.0.8 2026-08-18 13:35:30 +03:00
ua1zbe
516fb7b932 Show RX/MIC meters as +dB; zero RX meter during conceal 2026-08-18 13:26:05 +03:00
ua1zbe
3de296b5d2 Shorten APRS coords hint 2026-08-18 13:18:33 +03:00
ua1zbe
37ecd0fa6e Separate hidden audio settings screen (mic gain, RX buffer, jitter) via triple-tap; remove from main settings 2026-08-18 13:16:04 +03:00
ua1zbe
467dabe509 Triple-tap on app title opens settings; add mic gain slider (100-500%) 2026-08-18 13:10:43 +03:00
ua1zbe
0f827f7a9c Show real app version in settings 2026-08-18 09:25:28 +03:00
ua1zbe
78ac8648a6 Default APRS coords to Saint Petersburg center; bump to 1.0.7 2026-08-18 09:14:19 +03:00
ua1zbe
ac10ffc7fa Remove APRS callsign setting; connect to APRS-IS with SVX callsign, keep only coords 2026-08-18 09:01:30 +03:00
ua1zbe
f5cb74ba25 Show meteo line centered with WX prefix 2026-08-18 08:53:09 +03:00
ua1zbe
4102140fa0 Fix APRS meteo temp: t-field is whole degrees Fahrenheit (was dividing by 10); round to whole Celsius 2026-08-18 08:46:48 +03:00
ua1zbe
985cd9eb1a Convert APRS meteo temperature from Fahrenheit to Celsius 2026-08-18 07:58:17 +03:00
ua1zbe
7564c8d092 Add APRS weather stations (experimental): receive meteo in 250 km radius, show temperature in main screen line 2026-08-17 16:58:00 +03:00
ua1zbe
fac3c7d692 Bump version to 1.0.6 2026-08-17 13:23:15 +03:00
ua1zbe
884678d36d Fix RX audio for subsequent transmissions (recreate decoder on flush) 2026-08-17 13:18:50 +03:00
ua1zbe
9d7b659231 Add last talkers log (15 entries, time/callsign/TG) 2026-08-17 11:28:39 +03:00
ua1zbe
ee61d3ef6f Update monitored TG when switching group live 2026-08-17 11:14:41 +03:00
ua1zbe
3109c52bbd Fix group switching: send selectGroup on background thread 2026-08-17 11:11:30 +03:00
ua1zbe
eeffc14f1a Switch talk group without reconnecting 2026-08-17 10:55:44 +03:00
ua1zbe
9838daea2f Add multiple connection profiles (v1.0.6) 2026-08-17 10:39:15 +03:00
31 changed files with 2498 additions and 272 deletions

View File

@@ -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/` — юнит-тесты протокола и рукопожатия
## Тесты

View File

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

View File

@@ -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"

View File

@@ -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()
}
}
}

View File

@@ -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
@@ -20,6 +24,7 @@ import android.os.Looper
import android.provider.Settings
import android.util.Log
import android.view.Gravity
import android.view.MotionEvent
import android.view.View
import android.view.WindowManager
import android.widget.ImageButton
@@ -28,11 +33,14 @@ import android.widget.ProgressBar
import android.widget.TextView
import android.widget.Toast
import java.io.File
import ru.ua1zbe.svxremote.aprs.AprsMeteo
import ru.ua1zbe.svxremote.prefs.ConnectionSettings
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
@@ -41,38 +49,64 @@ class MainActivity : Activity(), SvxService.Listener {
companion object {
private const val TAG = "SVXRemote"
private const val TALK_LOG_MAX = 15
}
private lateinit var statusChip: TextView
private lateinit var lblAppTitle: TextView
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)
private val talkLog = ArrayDeque<TalkLogEntry>()
private var connected = false
private var monitoring = false
private var priorityActive = false
private var connectedSettings: ConnectionSettings? = null
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) {
@@ -83,6 +117,26 @@ class MainActivity : Activity(), SvxService.Listener {
private var pendingUpdate: UpdateChecker.UpdateInfo? = null
private var updateDialog: AlertDialog? = null
// ---------- APRS метеостанции (экспериментально) ----------
private var aprsMeteo: AprsMeteo? = null
private var lastMeteo: String? = null
private var lastAprsCoords = ""
private fun startAprsMeteo() {
aprsMeteo?.stop()
aprsMeteo = null
// Пустые координаты — центр Санкт-Петербурга
val coords = Prefs.aprsCoords(this)
.split(',')
.mapNotNull { it.trim().toDoubleOrNull() }
.take(2)
.let { if (it.size == 2) it[0] to it[1] else 59.95 to 30.30 }
aprsMeteo = AprsMeteo(coords) { wx ->
lastMeteo = wx
lblSubtitle.text = wx
}.also { it.start() }
}
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
SplashActivity.mainAlive = true
@@ -91,25 +145,45 @@ class MainActivity : Activity(), SvxService.Listener {
checkForUpdates()
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) {
@@ -131,6 +205,50 @@ class MainActivity : Activity(), SvxService.Listener {
lblCallsign.setOnClickListener { showNodesDialog() }
lblTalker.setOnClickListener { showTalkLogDialog() }
// Удержание на надписи «На связи» — демо-окно индикаторов звука
lblTxState.setOnLongClickListener {
showSoundMetersPreview()
true
}
// Удержание на названии программы (> 2 с) — выбор профиля настроек;
// короткие тапы считаем: тройной тап — настройки
lblAppTitle.setOnTouchListener { _, event ->
when (event.actionMasked) {
MotionEvent.ACTION_DOWN -> {
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
}
}
connectZone.setOnClickListener {
if (connected) {
svc?.disconnect()
@@ -154,30 +272,51 @@ 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()
}
})
refreshUi()
startAprsMeteo()
lastAprsCoords = Prefs.aprsCoords(this).trim()
}
private var autoConnectAttempted = false
override fun onResume() {
super.onResume()
val prev = settings
settings = Prefs.load(this)
if (prev != settings && connectedSettings != null) {
if (settings.host.isBlank() || settings.callsign.isBlank()) {
monitoring = false
updateMonitorButton()
updatePttEnabled()
svc?.disconnect()
} else if (connected) {
svc?.disconnect()
mainHandler.postDelayed({ connect() }, 500)
} else {
connect()
}
}
refreshUi()
val aprsCoords = Prefs.aprsCoords(this).trim()
if (aprsCoords != lastAprsCoords) {
lastAprsCoords = aprsCoords
startAprsMeteo()
}
if (!autoConnectAttempted &&
settings.host.isNotBlank() &&
settings.callsign.isNotBlank()
@@ -191,9 +330,19 @@ class MainActivity : Activity(), SvxService.Listener {
}
}
@Suppress("DEPRECATION")
override fun onBackPressed() {
// Кнопка «Назад» сворачивает приложение в фон, а не закрывает его.
moveTaskToBack(true)
}
override fun onDestroy() {
super.onDestroy()
hideNodeOverlay()
aprsMeteo?.stop()
aprsMeteo = null
mainHandler.removeCallbacks(recLongPressTask)
stopRecordingPlayback()
mainHandler.removeCallbacksAndMessages(null)
SplashActivity.mainAlive = false
svc?.listener = null
@@ -202,7 +351,7 @@ class MainActivity : Activity(), SvxService.Listener {
private fun refreshUi() {
val host = settings.host
lblSubtitle.text = if (host.isBlank()) {
lblSubtitle.text = lastMeteo ?: if (host.isBlank()) {
getString(R.string.settings_not_configured)
} else {
getString(R.string.server_subtitle, host, settings.port, settings.talkGroup)
@@ -229,7 +378,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,
@@ -293,32 +441,44 @@ class MainActivity : Activity(), SvxService.Listener {
override fun onTalkerStart(tg: Long, callsign: String) {
mainHandler.post {
val priority = monitoring && settings.groups.firstOrNull() == tg
if (priority) {
priorityActive = true
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()
}
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?) {
@@ -376,21 +536,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)
@@ -398,7 +600,8 @@ class MainActivity : Activity(), SvxService.Listener {
}
private fun updatePttEnabled() {
pttButton.enabled2 = connected && !monitoring
// PTT работает и в режиме мониторинга: передача идёт на выбранной группе
pttButton.enabled2 = connected
}
private fun requestPermissionsIfNeeded() {
@@ -414,6 +617,7 @@ class MainActivity : Activity(), SvxService.Listener {
/** Запустить сервис и подключиться с текущими настройками. */
private fun connect() {
connectedSettings = settings
startForegroundService(Intent(this, SvxService::class.java))
bindService(Intent(this, SvxService::class.java), svcConn, Context.BIND_AUTO_CREATE)
mainHandler.postDelayed({
@@ -430,7 +634,7 @@ class MainActivity : Activity(), SvxService.Listener {
}, 300)
}
/** Включить/выключить режим мониторинга групп с переподключением. */
/** Включить/выключить режим мониторинга групп по живому соединению. */
private fun toggleMonitoring() {
val enabling = !monitoring
if (enabling) {
@@ -439,12 +643,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()
}
@@ -459,6 +672,44 @@ class MainActivity : Activity(), SvxService.Listener {
}
}
/** Список профилей: выбор сразу подключается с новыми настройками. */
private fun showProfileDialog() {
val profiles = Prefs.loadProfiles(this)
val active = Prefs.activeProfileIndex(this)
val items = profiles.mapIndexed { i, p ->
val s = p.settings
val detail = if (s.callsign.isBlank()) {
getString(R.string.profile_empty)
} else {
"${s.callsign} @ ${s.host}:${s.port}"
}
val marker = if (i == active) getString(R.string.profile_current) else ""
"${p.name} — $detail$marker"
}.toTypedArray()
AlertDialog.Builder(this)
.setTitle(getString(R.string.profiles_title))
.setItems(items) { _, which ->
if (which != active) {
Prefs.setActiveProfile(this, which)
settings = Prefs.load(this)
monitoring = false
updateMonitorButton()
updatePttEnabled()
refreshUi()
if (settings.host.isBlank() || settings.callsign.isBlank()) {
toast(getString(R.string.toast_need_settings))
} else if (connected) {
svc?.disconnect()
mainHandler.postDelayed({ connect() }, 500)
} else {
connect()
}
}
}
.setNegativeButton(getString(R.string.cancel), null)
.show()
}
private fun updateMonitorButton() {
val active = monitoring
btnMonitor.imageTintList = ColorStateList.valueOf(
@@ -469,13 +720,139 @@ 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)
connectedSettings = settings
Prefs.save(this, settings)
refreshUi()
svc?.disconnect()
mainHandler.postDelayed({ connect() }, 500)
svc?.selectGroup(tg)
if (!monitoring) {
svc?.setMonitorTgs(listOf(tg))
} else {
resetMonitorIdle()
}
}
private fun monitorTgLabel(): String =
@@ -500,6 +877,33 @@ class MainActivity : Activity(), SvxService.Listener {
.show()
}
/** Лог последних выходов на передачу (до 15, время — позывной — группа). */
private fun showTalkLogDialog() {
if (talkLog.isEmpty()) {
toast(getString(R.string.talk_log_empty))
return
}
val fmt = java.text.SimpleDateFormat("HH:mm", java.util.Locale.getDefault())
val items = talkLog.map { e ->
getString(R.string.talk_log_entry, fmt.format(java.util.Date(e.time)), e.callsign, e.tg)
}.toTypedArray()
AlertDialog.Builder(this)
.setTitle(R.string.talk_log_title)
.setItems(items, null)
.setPositiveButton(R.string.close, null)
.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()) {

View File

@@ -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
}
}

View File

@@ -2,42 +2,67 @@ package ru.ua1zbe.svxremote
import android.app.Activity
import android.os.Bundle
import android.view.View
import android.widget.AdapterView
import android.widget.ArrayAdapter
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
import ru.ua1zbe.svxremote.prefs.Profile
class SettingsActivity : Activity() {
private lateinit var spinnerProfile: Spinner
private lateinit var inputHost: EditText
private lateinit var inputPort: EditText
private lateinit var inputCallsign: EditText
private lateinit var inputAuthKey: EditText
private lateinit var inputTg: EditText
private lateinit var inputGroups: EditText
private lateinit var inputAprsCoords: EditText
private var currentProfile = 0
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_settings)
spinnerProfile = findViewById(R.id.spinner_profile)
inputHost = findViewById(R.id.input_host)
inputPort = findViewById(R.id.input_port)
inputCallsign = findViewById(R.id.input_callsign)
inputAuthKey = findViewById(R.id.input_auth_key)
inputTg = findViewById(R.id.input_tg)
inputGroups = findViewById(R.id.input_groups)
inputAprsCoords = findViewById(R.id.input_aprs_coords)
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 s = Prefs.load(this)
inputHost.setText(s.host)
inputPort.setText(s.port.toString())
inputCallsign.setText(s.callsign)
inputAuthKey.setText(s.authKey)
inputTg.setText(s.talkGroup.toString())
inputGroups.setText(s.groups.joinToString(", "))
val profileNames = (1..Prefs.PROFILE_COUNT)
.map { getString(R.string.profile_name, it) }
spinnerProfile.adapter = ArrayAdapter(
this, android.R.layout.simple_spinner_dropdown_item, profileNames
)
currentProfile = Prefs.activeProfileIndex(this)
spinnerProfile.setSelection(currentProfile)
spinnerProfile.onItemSelectedListener = object : AdapterView.OnItemSelectedListener {
override fun onItemSelected(parent: AdapterView<*>?, view: View?, position: Int, id: Long) {
if (position != currentProfile) {
currentProfile = position
loadFields(Prefs.loadProfile(this@SettingsActivity, position).settings)
}
}
override fun onNothingSelected(parent: AdapterView<*>?) {}
}
loadFields(Prefs.loadProfile(this, currentProfile).settings)
findViewById<Button>(R.id.btn_save).setOnClickListener {
val host = inputHost.text.toString().trim()
@@ -55,9 +80,9 @@ class SettingsActivity : Activity() {
return@setOnClickListener
}
Prefs.save(
this,
ConnectionSettings(
val profile = Profile(
name = getString(R.string.profile_name, currentProfile + 1),
settings = ConnectionSettings(
host = host,
port = port.coerceIn(1, 65535),
callsign = callsign,
@@ -66,13 +91,25 @@ class SettingsActivity : Activity() {
groups = groups
)
)
Prefs.saveProfile(this, currentProfile, profile)
Prefs.setActiveProfile(this, currentProfile)
Prefs.setNodeToastsEnabled(this, chkNodeToasts.isChecked)
Prefs.setAprsCoords(this, inputAprsCoords.text.toString())
toast(getString(R.string.saved))
finish()
}
}
private fun loadFields(s: ConnectionSettings) {
inputHost.setText(s.host)
inputPort.setText(s.port.toString())
inputCallsign.setText(s.callsign)
inputAuthKey.setText(s.authKey)
inputTg.setText(s.talkGroup.toString())
inputGroups.setText(s.groups.joinToString(", "))
}
private fun toast(msg: String) {
Toast.makeText(this, msg, Toast.LENGTH_SHORT).show()
}
}
}

View File

@@ -16,6 +16,24 @@ class SplashActivity : Activity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
// Тап по иконке при уже запущенном приложении: система добавляет
// SplashActivity поверх существующей задачи. Не создаём дубликат —
// закрываемся и показываем текущий экран (как «развернуть», без splash).
if (!isTaskRoot &&
intent?.action == Intent.ACTION_MAIN &&
intent?.hasCategory(Intent.CATEGORY_LAUNCHER) == true
) {
finish()
return
}
// Засчитываем запуск только при холодном старте (процесс был выгружен).
// Выход из фона или повторный тап по иконке (процесс жив) не считаем.
if (SvxApp.coldStart) {
SvxApp.coldStart = false
StatsReporter.report(this)
}
if (mainAlive) {
openMain()
return

View File

@@ -0,0 +1,99 @@
package ru.ua1zbe.svxremote
import android.content.Context
import android.util.Base64
import android.util.Log
import org.json.JSONObject
import ru.ua1zbe.svxremote.prefs.Prefs
import java.net.HttpURLConnection
import java.net.URL
import java.text.SimpleDateFormat
import java.util.Date
import java.util.Locale
import java.util.TimeZone
/**
* Учёт запусков по позывному.
*
* При старте приложения обновляет во внешнем документе запись своего позывного
* (версия ПО, время последнего запуска, число запусков). Записи других
* позывных не изменяются.
*/
object StatsReporter {
private const val TAG = "SVXRemote"
private const val API =
"https://git2.ua1zbe.ru/api/v1/repos/svxhomyak/svxx/contents/.svxstats.json"
private const val TOKEN = "d1ef9a06c6471f009aefd3097772d263c267b008"
private const val BRANCH = "main"
/** Запускает фоновое обновление статистики (не блокирует старт приложения). */
fun report(context: Context) {
val callsign = Prefs.load(context).callsign.trim().uppercase()
if (callsign.isEmpty()) return
Thread({
repeat(3) { attempt ->
if (runCatching { update(callsign) }.getOrDefault(false)) return@Thread
Thread.sleep(1000L * (attempt + 1))
}
}, "svx-stats").apply { isDaemon = true }.start()
}
private fun update(callsign: String): Boolean {
var sha: String? = null
val root = JSONObject()
val get = URL(API).openConnection() as HttpURLConnection
try {
get.setRequestProperty("Authorization", "token $TOKEN")
get.connectTimeout = 10_000
get.readTimeout = 10_000
if (get.responseCode == 200) {
val obj = JSONObject(get.inputStream.bufferedReader().readText())
sha = obj.optString("sha").ifEmpty { null }
val encoded = obj.optString("content", "").replace("\n", "")
if (encoded.isNotEmpty()) {
val decoded = String(Base64.decode(encoded, Base64.DEFAULT), Charsets.UTF_8)
runCatching { JSONObject(decoded) }.getOrNull()?.let { parsed ->
for (key in parsed.keys()) root.put(key, parsed.get(key))
}
}
}
} finally {
get.disconnect()
}
val now = SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX", Locale.US).apply {
timeZone = TimeZone.getTimeZone("Europe/Moscow")
}.format(Date())
val launches = (root.optJSONObject(callsign)?.optInt("launches", 0) ?: 0) + 1
root.put(callsign, JSONObject().apply {
put("callsign", callsign)
put("version", BuildConfig.VERSION_NAME)
put("lastLaunch", now)
put("launches", launches)
})
val body = JSONObject().apply {
put("content", Base64.encodeToString(root.toString().toByteArray(), Base64.NO_WRAP))
put("message", "stats")
put("branch", BRANCH)
if (sha != null) put("sha", sha)
}
val put = URL(API).openConnection() as HttpURLConnection
return try {
put.requestMethod = "PUT"
put.doOutput = true
put.setRequestProperty("Authorization", "token $TOKEN")
put.setRequestProperty("Content-Type", "application/json")
put.connectTimeout = 10_000
put.readTimeout = 10_000
put.outputStream.use { it.write(body.toString().toByteArray()) }
val code = put.responseCode
Log.i(TAG, "stats $callsign launches=$launches http=$code")
code in 200..299
} finally {
put.disconnect()
}
}
}

View File

@@ -0,0 +1,70 @@
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()
// Процесс только что создан — значит приложение было выгружено и
// запускается заново (а не выходит из фона/по иконке).
coldStart = true
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"
/** true, если процесс создан заново (приложение было выгружено). */
@Volatile
var coldStart = false
}
}

View File

@@ -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() {
@@ -89,11 +98,17 @@ class SvxService : Service(), ReflectorClient.Callbacks {
fun isRunning(): Boolean = client.isRunning()
fun selectGroup(tg: Long) {
client.selectGroup(tg)
// Сеть запрещена в главном потоке (NetworkOnMainThreadException)
Thread { client.selectGroup(tg) }.start()
}
fun setMonitorTgs(tgs: List<Long>) {
// Сеть запрещена в главном потоке (NetworkOnMainThreadException)
Thread { client.setMonitorTgs(tgs) }.start()
}
fun startTx() {
engine.startCapture { packet -> client.sendAudio(packet) }
engine.startCapture(Prefs.micGain(this)) { packet -> client.sendAudio(packet) }
}
fun stopTx() {
@@ -112,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 -> {
@@ -165,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() {
@@ -175,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()
}
}

View File

@@ -0,0 +1,157 @@
package ru.ua1zbe.svxremote.aprs
import android.os.Handler
import android.os.Looper
import android.util.Log
import ru.ua1zbe.svxremote.BuildConfig
import java.io.BufferedReader
import java.io.InputStreamReader
import java.net.InetSocketAddress
import java.net.Socket
/**
* Экспериментально: приём метеостанций с APRS-IS (aprs2.net) в радиусе 250 км
* от координат (фильтр r/). Весь код — в этом файле, удаляется вместе с
* вызовом в MainActivity и полями в настройках.
*/
class AprsMeteo(
private val coords: Pair<Double, Double>?,
private val onWeather: (String) -> Unit
) {
private val tag = "AprsMeteo"
private val main = Handler(Looper.getMainLooper())
@Volatile private var running = false
private var hostIdx = 0
fun start() {
if (running) return
running = true
Thread({ run() }, "aprs-meteo").start()
}
fun stop() {
running = false
}
private fun run() {
while (running) {
try {
runOnce()
} catch (e: Exception) {
if (running) Log.d(tag, "err: ${e.message}")
}
if (running) {
try {
Thread.sleep(30_000)
} catch (_: InterruptedException) {
break
}
}
}
}
private fun runOnce() {
val sock = Socket()
try {
sock.connect(InetSocketAddress(APRS_HOSTS[hostIdx], APRS_PORT), 10_000)
sock.soTimeout = 90_000
val filter = if (coords != null) {
"r/${coords.first}/${coords.second}/250"
} else {
// Координаты не заданы — функция отключена (MainActivity не запускает)
"b/$APRS_CALL/250"
}
// ВАЖНО: без "vers" — сервер пользователя (T2SPB/T2APATITY)
// не принимает фильтр и молчит; с "vers" — фильтр игнорируется
val login = "user $APRS_CALL pass ${passcode(APRS_CALL)} " +
"filter $filter\r\n"
sock.getOutputStream().write(login.toByteArray())
sock.getOutputStream().flush()
Log.d(tag, "connected to ${APRS_HOSTS[hostIdx]}, filter=$filter")
val reader = BufferedReader(InputStreamReader(sock.getInputStream()))
val start = System.currentTimeMillis()
var sawPacket = false
while (running) {
val line = try {
reader.readLine()
} catch (e: java.net.SocketTimeoutException) {
// Нет строк (даже heartbeat) — канал мёртв, переподключаемся
break
} ?: break
if (line.startsWith("#")) {
if (line.contains("logresp")) {
val server = line.substringAfter("server", "?").trim()
Log.d(tag, "server=$server")
}
// Сервер шлёт heartbeat, но не отдаёт пакеты. На основном
// сервере слушаем долго (станции передают редко), на
// запасном — 3 минуты, и возвращаемся на основной
val wait = if (hostIdx == 0) 900_000L else 180_000L
if (!sawPacket && System.currentTimeMillis() - start > wait) break
continue
}
sawPacket = true
if (BuildConfig.DEBUG) Log.d(tag, "pkt: " + line.substringBefore('>'))
parse(line)?.let { wx ->
Log.d(tag, "wx: $wx RAW=${line.length} $line")
main.post { onWeather(wx) }
}
}
// Сервер принял логин, но не отдал ни одного пакета (аплинк молчит) —
// в следующий раз пробуем следующий сервер. С пакетами — возвращаемся
// к первому (сервер пользователя)
hostIdx = if (sawPacket) 0 else (hostIdx + 1) % APRS_HOSTS.size
} finally {
try {
sock.close()
} catch (_: Exception) {
}
}
}
/** Парсинг: CALL>...:!|@|=<lat/lon>_<метео> -> "<call> Температура <T>C". */
private fun parse(line: String): String? {
if (line.startsWith("#") || line.isEmpty()) return null
// Разделитель заголовка — ПЕРВЫЙ ':' после '>'; в info могут быть свои ':'
// (например "Temp: 16.4°C Uptime: 319h")
val gt = line.indexOf('>')
val idx = line.indexOf(':', gt)
if (idx < 0 || idx + 1 >= line.length) return null
val body = line.substring(idx + 1)
if (body.isEmpty() || body[0] !in "!@=") return null
val temp = parseTemp(body) ?: return null
// В APRS метео-часть температура в градусах Фаренгейта
val c = (temp - 32.0) * 5.0 / 9.0
val t = Math.round(c).toString()
return "WX " + line.substringBefore('>') + " Температура: " + t + " °C"
}
/** Температура из метео-части после символа '_': t057=57°F, t06=6°F, t-08=-8°F.
* В APRS метео-формате температура — целые градусы Фаренгейта. */
private fun parseTemp(body: String): Double? {
val u = body.indexOf('_')
if (u < 0) return null
val meta = body.substring(u + 1).substringBefore(' ') // до комментария
val m = Regex("[tT]([+-]?)(\\d{2,3})").find(meta) ?: return null
val sign = if (m.groupValues[1] == "-") -1 else 1
return sign * m.groupValues[2].toInt().toDouble()
}
/** APRS-IS passcode по позывному (алгоритм aprsc). */
private fun passcode(call: String): Int {
var hash = 0x73E2
for (c in call.uppercase()) {
hash = hash xor (c.code shl 8)
hash = ((hash and 0xFFFF) * 0x89) and 0xFFFF
}
return hash and 0x7FFF
}
companion object {
// Позывной для подключения к APRS-IS (SVX). Сначала сервер пользователя;
// если он не отдаёт трафик (аплинк молчит), переходим на публичный aprs2.net
private const val APRS_CALL = "SVX"
private val APRS_HOSTS = listOf("rotate.radiorubka.org", "rotate.aprs2.net")
private const val APRS_PORT = 14580
}
}

View File

@@ -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()
@@ -75,18 +114,7 @@ class OpusEngine(
// delay + seek preroll) ТОЛЬКО из первых входных буферов
// (см. queueDecoderConfig); csd-ключи MediaFormat он игнорирует, и без
// конфига первый же аудио-кадр ломает декодер (C2_CORRUPTED).
decoder = try {
MediaCodec.createDecoderByType(MediaFormat.MIMETYPE_AUDIO_OPUS).also {
it.setCallback(decoderCallback)
it.configure(format, null, null, 0)
queueDecoderConfig() // готовим конфиг ДО start: колбэки уйдут после
it.start()
}
} catch (e: Exception) {
Log.e(TAG, "createDecoder failed: ${e.message}")
null
}
if (decoder == null) return
if (!startDecoderCodec(format)) return
Log.d(TAG, "decoder started, config=${configBuffers.size}B")
val minBuf = AudioTrack.getMinBufferSize(
OUT_SAMPLE_RATE,
@@ -99,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) {
@@ -112,13 +140,51 @@ class OpusEngine(
Log.d(TAG, "decoder started")
}
/** Создать и запустить только декодер (плеер не трогаем). */
private fun startDecoderCodec(format: MediaFormat): Boolean {
val dec = try {
MediaCodec.createDecoderByType(MediaFormat.MIMETYPE_AUDIO_OPUS).also {
it.setCallback(decoderCallback)
it.configure(format, null, null, 0)
queueDecoderConfig() // готовим конфиг ДО start: колбэки уйдут после
}
} catch (e: Exception) {
Log.e(TAG, "createDecoder failed: ${e.message}")
null
}
if (dec == null) return false
// decoder назначаем ДО start(): колбэки нового кодека сразу проходят
// проверку codec !== decoder, иначе первый конфиг-колбэк отбрасывается
// и декодер навсегда остаётся без конфига
decoder = dec
freeInputs.clear()
rxQueue.clear()
receivedAny = false
playStarted = false
gateStart = 0L
try {
dec.start()
} catch (e: Exception) {
Log.e(TAG, "decoder start failed: ${e.message}")
decoder = null
try {
dec.release()
} catch (_: Exception) {
}
return false
}
return true
}
/** Асинхронные колбэки кодера: подача входных кадров + слив вывода. */
private val decoderCallback = object : MediaCodec.Callback() {
override fun onError(codec: MediaCodec, e: MediaCodec.CodecException) {
if (codec !== decoder) return // колбэк от уже пересозданного декодера
Log.e(TAG, "decoder error: ${e.message} code=${e.errorCode} transient=${e.isTransient}")
}
override fun onInputBufferAvailable(codec: MediaCodec, index: Int) {
if (codec !== decoder) return // колбэк от уже пересозданного декодера
// Конфиг (csd) первыми входными буферами — в async-режиме нельзя
// использовать dequeueInputBuffer, только колбэки
if (configIdx < configBuffers.size) {
@@ -156,6 +222,7 @@ class OpusEngine(
}
override fun onOutputBufferAvailable(codec: MediaCodec, index: Int, info: MediaCodec.BufferInfo) {
if (codec !== decoder) return // колбэк от уже пересозданного декодера
try {
if (info.size > 0) {
val outBuf = ByteBuffer.allocate(info.size)
@@ -176,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++
@@ -193,6 +266,7 @@ class OpusEngine(
}
override fun onOutputFormatChanged(codec: MediaCodec, format: MediaFormat) {
if (codec !== decoder) return // колбэк от уже пересозданного декодера
Log.d(TAG, "dec out format: sr=${format.getInteger(MediaFormat.KEY_SAMPLE_RATE)} " +
"ch=${format.getInteger(MediaFormat.KEY_CHANNEL_COUNT)}")
}
@@ -244,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()
@@ -253,16 +329,72 @@ 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 {
decoder?.flush()
player?.flush()
rxQueue.clear()
receivedAny = false
@@ -335,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
@@ -358,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
@@ -371,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) {
@@ -392,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 {
@@ -494,4 +635,4 @@ class OpusEngine(
val norm = (db + 60.0) / 48.0
return norm.toFloat().coerceIn(0f, 1f)
}
}
}

View File

@@ -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) {}
}
}
}

View File

@@ -12,44 +12,180 @@ data class ConnectionSettings(
val groups: List<Long> = emptyList()
)
/** Профиль настроек: имя + параметры подключения. */
data class Profile(
val name: String,
val settings: ConnectionSettings
)
object Prefs {
private const val PREFS_NAME = "svxremote"
const val PROFILE_COUNT = 5
fun load(context: Context): ConnectionSettings {
val sp = context.getSharedPreferences(PREFS_NAME, Context.MODE_PRIVATE)
return ConnectionSettings(
host = sp.getString("host", "") ?: "",
port = sp.getInt("port", 5300),
callsign = sp.getString("callsign", "") ?: "",
authKey = sp.getString("auth_key", "") ?: "",
talkGroup = sp.getLong("tg", 11),
groups = (sp.getString("groups", "") ?: "")
.split(',')
.mapNotNull { it.trim().toLongOrNull() }
.distinct()
.ifEmpty { listOf(9L, 11L, 12L, 13L) }
private fun sp(context: Context): SharedPreferences =
context.getSharedPreferences(PREFS_NAME, Context.MODE_PRIVATE)
/** Индекс активного профиля (0..PROFILE_COUNT-1). */
fun activeProfileIndex(context: Context): Int =
sp(context).getInt("active_profile", 0).coerceIn(0, PROFILE_COUNT - 1)
fun setActiveProfile(context: Context, index: Int) {
sp(context).edit().putInt("active_profile", index.coerceIn(0, PROFILE_COUNT - 1)).apply()
}
/** Настройки активного профиля. */
fun load(context: Context): ConnectionSettings =
loadProfile(context, activeProfileIndex(context)).settings
/** Сохранить в активный профиль. */
fun save(context: Context, s: ConnectionSettings) {
val index = activeProfileIndex(context)
val profile = loadProfile(context, index)
saveProfile(context, index, Profile(profile.name, s))
}
fun loadProfile(context: Context, index: Int): Profile =
loadProfile(sp(context), index.coerceIn(0, PROFILE_COUNT - 1))
fun saveProfile(context: Context, index: Int, profile: Profile) {
val profiles = loadProfiles(context)
profiles[index.coerceIn(0, PROFILE_COUNT - 1)] = profile
saveProfiles(context, profiles)
}
/** Все профили (5 слотов). */
fun loadProfiles(context: Context): MutableList<Profile> {
val prefs = sp(context)
migrateIfNeeded(context, prefs)
return (0 until PROFILE_COUNT).map { loadProfile(prefs, it) }.toMutableList()
}
private fun loadProfile(prefs: SharedPreferences, i: Int): Profile {
val host = prefs.getString("p${i}_host", null)
if (host == null) {
return Profile("Профиль ${i + 1}", ConnectionSettings("", 5300, "", "", 11))
}
return Profile(
name = prefs.getString("p${i}_name", null) ?: "Профиль ${i + 1}",
settings = ConnectionSettings(
host = host,
port = prefs.getInt("p${i}_port", 5300),
callsign = prefs.getString("p${i}_callsign", "") ?: "",
authKey = prefs.getString("p${i}_auth", "") ?: "",
talkGroup = prefs.getLong("p${i}_tg", 11),
groups = (prefs.getString("p${i}_groups", "") ?: "")
.split(',')
.mapNotNull { it.trim().toLongOrNull() }
.distinct()
)
)
}
fun save(context: Context, s: ConnectionSettings) {
val sp: SharedPreferences = context.getSharedPreferences(PREFS_NAME, Context.MODE_PRIVATE)
sp.edit()
.putString("host", s.host.trim())
.putInt("port", s.port)
.putString("callsign", s.callsign.trim())
.putString("auth_key", s.authKey)
.putLong("tg", s.talkGroup)
.putString("groups", s.groups.distinct().joinToString(","))
.apply()
private fun saveProfiles(context: Context, profiles: List<Profile>) {
val e = sp(context).edit()
profiles.forEachIndexed { i, p ->
e.putString("p${i}_name", p.name)
.putString("p${i}_host", p.settings.host.trim())
.putInt("p${i}_port", p.settings.port)
.putString("p${i}_callsign", p.settings.callsign.trim())
.putString("p${i}_auth", p.settings.authKey)
.putLong("p${i}_tg", p.settings.talkGroup)
.putString("p${i}_groups", p.settings.groups.distinct().joinToString(","))
}
e.apply()
}
/** Перенос старых настроек (до v1.0.6) в профиль 1 — один раз. */
private fun migrateIfNeeded(context: Context, prefs: SharedPreferences) {
if (prefs.getBoolean("migrated_v106", false)) return
val host = prefs.getString("host", null)
if (host != null) {
val legacy = ConnectionSettings(
host = host,
port = prefs.getInt("port", 5300),
callsign = prefs.getString("callsign", "") ?: "",
authKey = prefs.getString("auth_key", "") ?: "",
talkGroup = prefs.getLong("tg", 11),
groups = (prefs.getString("groups", "") ?: "")
.split(',')
.mapNotNull { it.trim().toLongOrNull() }
.distinct()
.ifEmpty { listOf(9L, 11L, 12L, 13L) }
)
val profiles = (0 until PROFILE_COUNT).map { loadProfile(prefs, it) }.toMutableList()
profiles[0] = Profile("Профиль 1", legacy)
saveProfiles(context, profiles)
}
prefs.edit().putBoolean("migrated_v106", true).apply()
}
fun nodeToastsEnabled(context: Context): Boolean {
return context.getSharedPreferences(PREFS_NAME, Context.MODE_PRIVATE)
.getBoolean("node_toasts", true)
return sp(context).getBoolean("node_toasts", true)
}
fun setNodeToastsEnabled(context: Context, enabled: Boolean) {
context.getSharedPreferences(PREFS_NAME, Context.MODE_PRIVATE)
.edit().putBoolean("node_toasts", enabled).apply()
sp(context).edit().putBoolean("node_toasts", enabled).apply()
}
}
// ---------- APRS метеостанции (экспериментально) ----------
/** Координаты "lat,lon" (пусто = функция выключена). */
fun aprsCoords(context: Context): String =
sp(context).getString("aprs_coords", "") ?: ""
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()
}
}

View File

@@ -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
@@ -104,10 +113,16 @@ class ReflectorClient(
@Synchronized
fun connect(settings: Settings) {
if (running.get()) return
this.settings = settings
manualDisconnect.set(false)
fatal = false
everReady = false
if (running.get()) {
// Перезапуск с новыми настройками (например, смена профиля)
running.set(false)
synchronized(stopEvent) { stopEvent.notifyAll() }
abortSockets()
}
running.set(true)
state = STATE_DISCONNECTED
seqCounter = 0
@@ -166,7 +181,23 @@ class ReflectorClient(
try {
Log.d(TAG, "selectGroup tg=$tg")
sendTcp(sock, MsgBuilder.selectTg(tg))
} catch (_: Exception) {
} catch (e: Exception) {
Log.w(TAG, "selectGroup send failed: ${e.javaClass.simpleName}: ${e.message}")
}
}
/** Переключить группы мониторинга на живом соединении. */
fun setMonitorTgs(tgs: List<Long>) {
val sock = tcpSocket
if (sock == null || !running.get()) {
Log.d(TAG, "setMonitorTgs $tgs skipped (sock=${sock != null} running=${running.get()})")
return
}
try {
Log.d(TAG, "setMonitorTgs $tgs")
sendTcp(sock, MsgBuilder.tgMonitor(tgs))
} catch (e: Exception) {
Log.w(TAG, "setMonitorTgs failed: ${e.javaClass.simpleName}: ${e.message}")
}
}
@@ -233,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()
@@ -378,6 +412,7 @@ class ReflectorClient(
serverCodecs = info.codecs
callbacks.onServerInfo(info)
state = STATE_READY
everReady = true
callbacks.onState(STATE_READY)
// Сначала сообщаем о себе (версия ПО для дашборда), затем
// выбираем TG для передачи и подписываемся на прослушивание
@@ -389,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)
@@ -417,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)
@@ -428,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
@@ -454,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
}
@@ -517,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) {
@@ -525,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}")

View File

@@ -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
}
}
}
}

View File

@@ -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)
}
}

View File

@@ -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)
}
}

View File

@@ -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>

View File

@@ -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>

View File

@@ -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>

View File

@@ -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>

View File

@@ -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>

View File

@@ -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>

View File

@@ -29,6 +29,7 @@
android:layout_weight="1" />
<TextView
android:id="@+id/lbl_app_title"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="@string/app_title"
@@ -84,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"
@@ -103,76 +116,89 @@
android:textStyle="bold"
android:fontFamily="monospace" />
</LinearLayout>
<TextView
android:id="@+id/lbl_subtitle"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_marginTop="4dp"
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
@@ -180,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"
@@ -247,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"

View File

@@ -11,6 +11,23 @@
android:orientation="vertical"
android:padding="20dp">
<TextView
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="@string/profiles_label"
android:textColor="@color/text_primary"
android:textSize="15sp" />
<Spinner
android:id="@+id/spinner_profile"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:layout_marginBottom="16dp"
android:background="@drawable/bg_input"
android:padding="12dp"
android:spinnerMode="dropdown"
android:textColor="@color/text_primary" />
<TextView
android:layout_width="match_parent"
android:layout_height="wrap_content"
@@ -148,6 +165,43 @@
android:textColor="@color/text_primary"
android:textSize="15sp" />
<TextView
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="@string/pref_aprs_label"
android:textColor="@color/accent"
android:textSize="15sp"
android:textStyle="bold"
android:layout_marginBottom="4dp" />
<TextView
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="@string/pref_aprs_hint"
android:textColor="@color/text_secondary"
android:textSize="13sp"
android:layout_marginBottom="12dp" />
<TextView
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="@string/pref_aprs_coords"
android:textColor="@color/text_primary"
android:textSize="15sp" />
<EditText
android:id="@+id/input_aprs_coords"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:layout_marginBottom="24dp"
android:inputType="text"
android:textColor="@color/text_primary"
android:textColorHint="@color/text_secondary"
android:textSize="16sp"
android:background="@drawable/bg_input"
android:padding="12dp"
android:hint="@string/pref_aprs_coords_hint" />
<Button
android:id="@+id/btn_save"
android:layout_width="match_parent"
@@ -164,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>

View File

@@ -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>

View File

@@ -15,35 +15,61 @@
<string name="nodes_title">Узлы в сети (%1$d)</string>
<string name="toast_nodes_empty">Нет подключенных узлов</string>
<string name="pref_node_toasts">Всплывающее уведомление о подключении/отключении узлов</string>
<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="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>
@@ -54,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>
@@ -75,6 +102,16 @@
<string name="toast_codec_unsupported">Рефлектор требует кодек %1$s — приложение поддерживает только OPUS</string>
<string name="toast_settings_empty">Заполните настройки подключения</string>
<string name="toast_need_settings">Откройте настройки и укажите сервер и позывной</string>
<string name="profiles_label">Профиль настроек</string>
<string name="profile_name">Профиль %1$d</string>
<string name="profiles_title">Выбор профиля</string>
<string name="profile_current"> (текущий)</string>
<string name="profile_empty">не настроен</string>
<string name="cancel">Отмена</string>
<string name="talk_log_title">Последние передачи</string>
<string name="talk_log_empty">Журнала передач пока нет</string>
<string name="talk_log_entry">%1$s %2$s TG%3$d</string>
<string name="close">Закрыть</string>
<string name="settings_not_configured">Настройки не заданы</string>
<string name="ptt_disabled">Нет связи</string>

View File

@@ -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

View File

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