call: две фазы исходящего вызова — индикация + разные гудки (desktop/Android)

doc/chat_call_arch.md

@@ -127,6 +127,14 @@ API: `ajb_create / ajb_push / ajb_pull / ajb_stats / ajb_destroy`.
 
 ## 8. Тоны и диагностика
 
+- **Исходящий звонок — две фазы с разными гудками** (у вызывающего):
+  - фаза 1 «пытаемся связаться» (`OUTGOING`: INVITE отправлен/ретранслируется, маршрут
+    устанавливается) — гудок «соединение» (короткие бипы);
+  - фаза 2 «звоним» (`RINGING`: получен RINGING, у пира идёт вызов) — длинные гудки (ringback).
+  Гудки генерируются платформенно-нативно: desktop — цикличные MP3 через `SoundManager`
+  (`call_connecting`/`call_ringing`), Android — `ToneGenerator`
+  (`TONE_SUP_DIAL`/`TONE_SUP_RINGTONE`). Переключение — по `CHAT_EVT_CALL_RINGING`,
+  остановка — по `CALL_ACCEPTED`/`CALL_ENDED`/`CALL_ERROR`/hangup.
 - **Сталл >500мс** (нет входящих медиа) → в `call_pull_pcm` микшируется
   `CALL_TONE_GLITCH`: `пи-пи (2×150мс, gap 100мс) … тишина до 1.0с … пи(200мс)
   пауза(200мс) пи(200мс)`, 1000 Гц, цикл пока длится сталл.

doc/tasks.md

@@ -68,6 +68,19 @@
     [ ] **DM-звонки** (fallback `group_id==0`) — не сделано: `call_is_online`/`call_start`
         требуют реальную группу (`topo_groups_find`), для DM (group_id==0) маршрута нет.
 
+## Звонок: две фазы исходящего вызова (индикация + гудки)
+
+[+] **Две фазы вызова** — сделано. Исходящий звонок разбит на 2 фазы с индикацией
+    в окне вызова и разными гудками:
+    - фаза 1 «Пытаемся связаться…» (`OUTGOING` — INVITE/маршрут) — гудок «соединение»;
+    - фаза 2 «Звоним…» (`RINGING` — у пира идёт вызов) — длинные гудки (ringback).
+    Desktop: `CallWindow::Ringing` + `SoundManager` loop `call_connecting`/`call_ringing`
+    (MP3 в qrc), переключение по `onCallRinging`, остановка по accepted/ended/error;
+    добавлена обработка `GUI_EVT_CALL_ERROR` (40) — раньше при «пир офлайн» окно/гудок
+    зависали навсегда. Android: `CallRingback` (`ToneGenerator` DIAL/RINGTONE),
+    подписи `OUTGOING`/`RINGING` в CallScreen + ActiveCallBanner.
+    Звуковые события добавлены в SoundSettingsPage (call_connecting/call_ringing).
+
 ## Рефакторинг: per-instance chat/dm (однопоточный test_dm_e2e)
 
 Сделано (глобальные синглтоны переведены на `UTUN_INSTANCE`):

tools/chatgui-android/app/src/main/java/com/utun/chat/MainActivity.kt

@@ -113,7 +113,7 @@ class MainActivity : ComponentActivity() {
                         if (screen != Screen.Call) screenBeforeCall = screen
                         screen = Screen.Call
                     }
-                    null -> if (screen == Screen.Call) screen = Screen.ChannelList
+                    null -> if (screen == Screen.Call) screen = screenBeforeCall ?: Screen.ChannelList
                     else -> {}
                 }
             }
@@ -254,7 +254,7 @@ class MainActivity : ComponentActivity() {
                         Screen.Logs -> LogScreen(onBack = { screen = Screen.ChannelList })
                         Screen.Call -> CallScreen(
                             viewModel = vm,
-                            onClose = { vm.dismissCall(); screen = Screen.ChannelList },
+                            onClose = { vm.dismissCall(); screen = screenBeforeCall ?: Screen.ChannelList },
                             onMinimize = { screen = screenBeforeCall ?: Screen.ChannelList }
                         )
                         Screen.QrScan -> {

tools/chatgui-android/app/src/main/java/com/utun/chat/data/CallRingback.kt

@@ -0,0 +1,72 @@
+package com.utun.chat.data
+
+import android.media.AudioAttributes
+import android.media.MediaPlayer
+import com.utun.chat.ChatApplication
+import com.utun.chat.R
+
+/**
+ * Гудки исходящего звонка (ringback) для вызывающего через зацикленный MediaPlayer.
+ *
+ * Две фазы с разными гудками:
+ *  - фаза 1 «пытаемся связаться» — call_connecting (короткие бипы 425 Гц);
+ *  - фаза 2 «звоним» (пир принял вызов, у него звонит) — call_ringing (длинные гудки).
+ *
+ * ToneGenerator для call-тонов на современном Android (API 31+) молчит, поэтому
+ * гудки — готовые MP3 из res/raw, как входящая мелодия (RingtonePlayer).
+ * На ACCEPTED/ENDED/hangup вызывающий останавливает гудок. Идемпотентный stop.
+ */
+object CallRingback {
+
+    @Volatile private var player: MediaPlayer? = null
+
+    /** Фаза 1: короткие бипы «устанавливаем соединение». Идемпотентно. */
+    fun startConnecting() {
+        start(R.raw.call_connecting, "connecting")
+    }
+
+    /** Фаза 2: длинные гудки (у пира идёт вызов). Идемпотентно. */
+    fun startRinging() {
+        start(R.raw.call_ringing, "ringing")
+    }
+
+    /** Остановить текущий гудок. Идемпотентно. */
+    fun stop() {
+        release()
+        LogManager.addLog("INFO", "Ringback", "stopped")
+    }
+
+    private fun start(resId: Int, tag: String) {
+        release()
+        val ctx = ChatApplication.instance
+        val mp = try {
+            MediaPlayer.create(ctx, resId)
+        } catch (e: Exception) {
+            LogManager.addLog("ERROR", "Ringback", "MediaPlayer.create failed ($tag): ${e.message}")
+            null
+        } ?: return
+        try {
+            mp.setAudioAttributes(
+                AudioAttributes.Builder()
+                    .setUsage(AudioAttributes.USAGE_MEDIA)
+                    .setContentType(AudioAttributes.CONTENT_TYPE_MUSIC)
+                    .build()
+            )
+            mp.isLooping = true
+            mp.start()
+        } catch (e: Exception) {
+            LogManager.addLog("ERROR", "Ringback", "MediaPlayer start failed ($tag): ${e.message}")
+            try { mp.release() } catch (_: Exception) {}
+            return
+        }
+        player = mp
+        LogManager.addLog("INFO", "Ringback", "started $tag")
+    }
+
+    private fun release() {
+        val p = player ?: return
+        player = null
+        try { p.stop() } catch (_: Exception) {}
+        try { p.release() } catch (_: Exception) {}
+    }
+}

tools/chatgui-android/app/src/main/java/com/utun/chat/ui/components/ActiveCallBanner.kt

@@ -44,8 +44,8 @@ fun ActiveCallBanner(
     val name = st.peerName.ifEmpty { "0x%016x".format(st.peerNodeId) }
     val status = when (phase) {
         CallPhase.ACTIVE -> "Разговор " + fmtDuration(st.durationMs)
-        CallPhase.RINGING -> "Гудки…"
-        else -> "Звоним…"
+        CallPhase.RINGING -> "Звоним…"
+        else -> "Пытаемся связаться…"
     }
 
     Row(

tools/chatgui-android/app/src/main/java/com/utun/chat/ui/screens/CallScreen.kt

@@ -40,8 +40,8 @@ private fun fmtDuration(sec: Int): String {
 }
 
 private fun callStatusText(phase: CallPhase): String = when (phase) {
-    CallPhase.OUTGOING -> "Звоним…"
-    CallPhase.RINGING  -> "Гудки…"
+    CallPhase.OUTGOING -> "Пытаемся связаться…"
+    CallPhase.RINGING  -> "Звоним…"
     CallPhase.ACTIVE   -> "Разговор"
     CallPhase.ENDED    -> "Завершён"
     else               -> ""

tools/chatgui-android/app/src/main/java/com/utun/chat/viewmodel/ChatViewModel.kt

@@ -574,6 +574,7 @@ class ChatViewModel : ViewModel() {
                 val st = _callState.value
                 if (st != null && st.callId == callId) {
                     _callState.value = st.copy(phase = CallPhase.RINGING)
+                    CallRingback.startRinging()
                     LogManager.addLog("INFO", "VM", "CALL_RINGING id=0x%016x".format(callId))
                 }
             }
@@ -583,6 +584,7 @@ class ChatViewModel : ViewModel() {
                 val st = _callState.value
                 if (st != null && st.callId == callId) {
                     LogManager.addLog("INFO", "VM", "CALL_ACCEPTED id=0x%016x".format(callId))
+                    CallRingback.stop()
                     callAudio.router.setPreferredRoute(
                         ChatApplication.instance.configProvider.getCallAudioRoute())
                     if (!callAudio.start(callId)) {
@@ -666,6 +668,7 @@ class ChatViewModel : ViewModel() {
         LogManager.addLog("INFO", "VM", "CALL_$tag id=0x%016x reason=$reason".format(callId))
         if (st == null || st.callId != callId) return
         callAudio.stop()
+        CallRingback.stop()
         IncomingCallManager.stopRinging()
         callIncomingAtMs = 0L
         _muted.value = false
@@ -691,6 +694,7 @@ class ChatViewModel : ViewModel() {
         _callState.value = CallState(callId = callId, channelId = channelId, peerNodeId = peerNodeId,
             peerName = name, phase = CallPhase.OUTGOING)
         NativeLib.callStart(channelId, peerNodeId, callId)
+        CallRingback.startConnecting()
         LogManager.addLog("INFO", "VM", "startCall ch=$channelId peer=0x%016x id=0x%016x".format(peerNodeId, callId))
     }
 
@@ -727,6 +731,7 @@ class ChatViewModel : ViewModel() {
 
     fun dismissCall() {
         callAudio.stop()
+        CallRingback.stop()
         callIncomingAtMs = 0L
         _callState.value = null
     }

tools/chatgui/resources/chatgui.qrc

@@ -11,6 +11,8 @@
         <file>icons/send.png</file>
         <file>sounds/msg_incoming.mp3</file>
         <file>sounds/call_incoming.mp3</file>
+        <file>sounds/call_connecting.mp3</file>
+        <file>sounds/call_ringing.mp3</file>
         <file>bg.jpg</file>
     </qresource>
 </RCC>

tools/chatgui/src/callwindow.cpp

@@ -229,6 +229,10 @@ void CallWindow::setState(State s) {
     m_state = s;
     switch (s) {
     case Outgoing:
+        m_statusLabel->setText(QStringLiteral("Пытаемся связаться…"));
+        m_durationLabel->hide();
+        break;
+    case Ringing:
         m_statusLabel->setText(QStringLiteral("Звоним…"));
         m_durationLabel->hide();
         break;
@@ -273,7 +277,7 @@ void CallWindow::populateDeviceCombo() {
 void CallWindow::updateButtons() {
     m_acceptCell->setVisible(m_state == Incoming);
     m_declineCell->setVisible(m_state == Incoming);
-    m_hangupCell->setVisible(m_state == Outgoing || m_state == Active);
+    m_hangupCell->setVisible(m_state == Outgoing || m_state == Ringing || m_state == Active);
     m_muteCell->setVisible(m_state == Active);
     m_deviceCombo->setVisible(m_state == Active);
 }
@@ -314,7 +318,8 @@ void CallWindow::onDeviceChanged(int index) {
 }
 
 void CallWindow::closeEvent(QCloseEvent* event) {
-    if (m_state == Active) postCallFn(call_hangup_trampoline, m_callId);
+    if (m_state == Outgoing || m_state == Ringing || m_state == Active)
+        postCallFn(call_hangup_trampoline, m_callId);
     emit closed(m_callId);
     event->accept();
 }

tools/chatgui/src/callwindow.h

@@ -8,12 +8,12 @@ class QPushButton;
 class QComboBox;
 class QTimer;
 
-/* Окно звонка: состояния Outgoing (звоним), Incoming (принять/отклонить),
- * Active (идёт разговор, таймер), Ended (завершён). */
+/* Окно звонка: состояния Outgoing (пытаемся связаться), Ringing (звоним),
+ * Incoming (принять/отклонить), Active (идёт разговор, таймер), Ended (завершён). */
 class CallWindow : public QWidget {
     Q_OBJECT
 public:
-    enum State { Outgoing, Incoming, Active, Ended };
+    enum State { Outgoing, Ringing, Incoming, Active, Ended };
 
     explicit CallWindow(QWidget* parent = nullptr);
     ~CallWindow() override;

tools/chatgui/src/mainwindow.cpp

@@ -328,16 +328,20 @@ void MainWindow::setupSoundFromConfig() {
     else
         sm->loadSound("call_incoming", resolvePath(callInFile));
 
+    sm->loadSound("call_connecting", ":/sounds/call_connecting.mp3");
+    sm->loadSound("call_ringing", ":/sounds/call_ringing.mp3");
+
     if (!msgOutFile.isEmpty())  sm->loadSound("msg_outgoing", resolvePath(msgOutFile));
     if (!connectFile.isEmpty()) sm->loadSound("connect", resolvePath(connectFile));
     if (!disconnectFile.isEmpty()) sm->loadSound("disconnect", resolvePath(disconnectFile));
     if (m_db && m_db->isOpen()) {
         sm->setEnabled(m_db->getUiStateInt("sound_enabled", 1));
         sm->setVolume(m_db->getUiStateInt("sound_volume", 80) / 100.0f);
-        QString se[] = {"msg_incoming", "msg_outgoing", "connect", "disconnect", "call_incoming"};
-        for (int i = 0; i < 5; i++) {
+        QString se[] = {"msg_incoming", "msg_outgoing", "connect", "disconnect",
+                        "call_incoming", "call_connecting", "call_ringing"};
+        for (int i = 0; i < 7; i++) {
             const QString& ek = se[i];
-            sm->setEvent(ek, m_db->getUiStateInt(QStringLiteral("sound_%1_on").arg(ek), (i == 0 || i == 4) ? 1 : 0),
+            sm->setEvent(ek, m_db->getUiStateInt(QStringLiteral("sound_%1_on").arg(ek), (i == 0 || i >= 4) ? 1 : 0),
                          m_db->getUiStateInt(QStringLiteral("sound_%1_vol").arg(ek), 80) / 100.0f);
         }
     }
@@ -448,6 +452,10 @@ void MainWindow::setupBridgeCallbacks() {
     gui_bridge_set_call_declined_cb([](uint64_t call_id, uint8_t reason) {
         if (s_mainWindow) s_mainWindow->onCallEnded(call_id, reason);
     });
+    gui_bridge_set_call_error_cb([](uint64_t call_id, uint8_t err, const char* text, int len) {
+        Q_UNUSED(text); Q_UNUSED(len);
+        if (s_mainWindow) s_mainWindow->onCallError(call_id, err);
+    });
     gui_bridge_set_call_path_cb([](uint64_t call_id, const char* text, int len) {
         if (s_mainWindow) s_mainWindow->onCallPath(call_id, QString::fromUtf8(text, len));
     });
@@ -537,6 +545,8 @@ void MainWindow::onCallRequested(const QString& chId, quint64 nodeId, const QStr
     connect(w, &CallWindow::closed, this, &MainWindow::closeCallWindow);
     m_activeCalls.insert(callId, w);
     w->show();
+
+    SoundManager::instance()->playLoop("call_connecting");
 }
 
 void MainWindow::onCallIncoming(const QString& chId, quint64 caller, quint64 callId) {
@@ -563,8 +573,11 @@ void MainWindow::onCallIncoming(const QString& chId, quint64 caller, quint64 cal
 }
 
 void MainWindow::onCallRinging(quint64 callId) {
-    /* caller слышит гудок — окно уже показано в Outgoing */
-    Q_UNUSED(callId);
+    /* caller: INVITE доставлен, у пира идёт вызов — фаза 2 (гудки) */
+    CallWindow* w = m_activeCalls.value(callId, nullptr);
+    if (w && w->state() == CallWindow::Outgoing)
+        w->setState(CallWindow::Ringing);
+    SoundManager::instance()->playLoop("call_ringing");
 }
 
 void MainWindow::onCallAccepted(quint64 callId) {
@@ -584,6 +597,12 @@ void MainWindow::onCallEnded(quint64 callId, uint8_t reason) {
     closeCallWindow(callId);
 }
 
+void MainWindow::onCallError(quint64 callId, uint8_t err) {
+    /* пир офлайн / нет маршрута — звонок не состоялся */
+    DEBUG_INFO(DEBUG_CATEGORY_DEBUG, "MainWindow: call error id=%016llx err=%u", (unsigned long long)callId, (unsigned)err);
+    closeCallWindow(callId);
+}
+
 void MainWindow::onCallPath(quint64 callId, const QString& path) {
     CallWindow* w = m_activeCalls.value(callId, nullptr);
     if (w) w->setBgpPath(path);

tools/chatgui/src/mainwindow.h

@@ -72,6 +72,7 @@ public:
     void onCallRinging(quint64 callId);
     void onCallAccepted(quint64 callId);
     void onCallEnded(quint64 callId, uint8_t reason);
+    void onCallError(quint64 callId, uint8_t err);
     void onCallPath(quint64 callId, const QString& path);
     void closeCallWindow(quint64 callId);
 

tools/chatgui/src/sound_manager.cpp

@@ -164,6 +164,9 @@ void SoundManager::playLoop(const QString& name) {
     if (!m_enabled) return;
     if (!m_initialized) { DEBUG_WARN(DEBUG_CATEGORY_DEBUG, "SoundManager::playLoop: not initialized"); return; }
 
+    /* остановить предыдущий цикл (иначе call_connecting + call_ringing звучат вместе) */
+    stopLoop();
+
     EventSettings es = m_eventSettings.value(name);
     if (!es.enabled) return;
 

tools/chatgui/src/soundsettingspage.cpp

@@ -60,8 +60,10 @@ SoundSettingsPage::SoundSettingsPage(DbManager* db, QWidget* parent)
     m_events[2] = {"connect",     "Peer connected",  nullptr, nullptr, nullptr};
     m_events[3] = {"disconnect",  "Peer disconnected", nullptr, nullptr, nullptr};
     m_events[4] = {"call_incoming", "Incoming call", nullptr, nullptr, nullptr};
+    m_events[5] = {"call_connecting", "Call: connecting", nullptr, nullptr, nullptr};
+    m_events[6] = {"call_ringing", "Call: ringback", nullptr, nullptr, nullptr};
 
-    for (int i = 0; i < 5; i++) {
+    for (int i = 0; i < 7; i++) {
         auto& e = m_events[i];
         auto* row = new QHBoxLayout();
         row->setSpacing(8);
@@ -119,11 +121,11 @@ void SoundSettingsPage::loadFromDb() {
     m_volumeLabel->setEnabled(enabled);
     m_volumeLabel->setText(QString::number(vol) + "%");
 
-    for (int i = 0; i < 5; i++) {
+    for (int i = 0; i < 7; i++) {
         auto& e = m_events[i];
         QString onKey  = QStringLiteral("sound_%1_on").arg(e.key);
         QString volKey = QStringLiteral("sound_%1_vol").arg(e.key);
-        bool on = m_db->getUiStateInt(onKey, (i == 0 || i == 4) ? 1 : 0);  // msg_incoming и call_incoming on by default
+        bool on = m_db->getUiStateInt(onKey, (i == 0 || i >= 4) ? 1 : 0);  // msg_incoming и звонковые on by default
         int ev = m_db->getUiStateInt(volKey, 80);
         e.check->setChecked(on);
         e.slider->setValue(ev);
@@ -139,7 +141,7 @@ void SoundSettingsPage::applyAndSave() {
     sm->setEnabled(enabled);
     sm->setVolume(masterVol);
 
-    for (int i = 0; i < 5; i++) {
+    for (int i = 0; i < 7; i++) {
         auto& e = m_events[i];
         bool on = e.check->isChecked();
         float ev = e.slider->value() / 100.0f;

tools/chatgui/src/soundsettingspage.h

@@ -28,5 +28,5 @@ private:
     QCheckBox*   m_enabledCheck;
     QSlider*     m_volumeSlider;
     QLabel*      m_volumeLabel;
-    EventRow     m_events[5];
+    EventRow     m_events[7];
 };

tools/chatgui/transport/gui_bridge.h

@@ -47,6 +47,7 @@ struct UTUN_INSTANCE;
 #define GUI_EVT_CALL_ENDED         37  /* data: [call_id:8][reason:1] */
 #define GUI_EVT_CALL_DECLINED      38  /* data: [call_id:8][reason:1] */
 #define GUI_EVT_CALL_STATS         39  /* data: [call_id:8][rtt_ms:2][buffer_ms:2][tempo_x100:2] */
+#define GUI_EVT_CALL_ERROR         40  /* data: [call_id:8][err:1][text:var] */
 #define GUI_EVT_DM_MESSAGES        41  /* data: [conv_id_len:1][conv_id:var][count:2]([dir:1][seq:8][ts:8][author:8][ct_len:1][ct:var][data_len:2][data:var])* */
 #define GUI_EVT_CALL_PATH          42  /* data: [call_id:8][text:var] — BGP-маршрут до пира звонка */
 #define GUI_EVT_RADIO_TALK         43  /* data: [group_id:8][src_node_id:8][stream_id:2][on:1] — кто-то начал/закончил говорить */
@@ -190,6 +191,10 @@ typedef void (*gui_call_ended_fn)(uint64_t call_id, uint8_t reason);
 void gui_bridge_set_call_ended_cb(gui_call_ended_fn cb);
 void gui_bridge_set_call_declined_cb(gui_call_ended_fn cb);
 
+/* Callback для ошибки звонка (пир офлайн/нет маршрута). text может быть пустым. */
+typedef void (*gui_call_error_fn)(uint64_t call_id, uint8_t err, const char* text, int len);
+void gui_bridge_set_call_error_cb(gui_call_error_fn cb);
+
 /* Callback для BGP-маршрута звонка (вызывается из GUI-потока) */
 typedef void (*gui_call_path_fn)(uint64_t call_id, const char* text, int len);
 void gui_bridge_set_call_path_cb(gui_call_path_fn cb);

tools/chatgui/transport/gui_bridge_impl.cpp

@@ -53,6 +53,7 @@ static gui_call_id_fn                g_call_ringing_cb         = nullptr;
 static gui_call_id_fn                g_call_accepted_cb        = nullptr;
 static gui_call_ended_fn             g_call_ended_cb           = nullptr;
 static gui_call_ended_fn             g_call_declined_cb        = nullptr;
+static gui_call_error_fn             g_call_error_cb           = nullptr;
 static gui_call_path_fn              g_call_path_cb            = nullptr;
 static gui_radio_talk_fn             g_radio_talk_cb           = nullptr;
 static gui_dm_msg_received_fn        g_dm_msg_received_cb      = nullptr;
@@ -307,6 +308,15 @@ void GuiBridgeReceiver::processPost(int eventType, QByteArray data) {
             if (g_call_declined_cb) g_call_declined_cb(callId, d[8]);
         }
         break;
+    case GUI_EVT_CALL_ERROR:
+        if (dlen >= 9) {
+            uint64_t callId; memcpy(&callId, d, 8);
+            uint8_t err = d[8];
+            DEBUG_INFO(DEBUG_CATEGORY_CHAT_SYNC, "gui_bridge: CALL_ERROR id=0x%016llx err=%u text=%.*s",
+                       (unsigned long long)callId, (unsigned)err, dlen - 9, (const char*)d + 9);
+            if (g_call_error_cb) g_call_error_cb(callId, err, (const char*)d + 9, dlen - 9);
+        }
+        break;
     case GUI_EVT_CALL_PATH:
         if (dlen >= 9) {
             uint64_t callId; memcpy(&callId, d, 8);
@@ -503,6 +513,10 @@ void gui_bridge_set_call_declined_cb(gui_call_ended_fn cb) {
     g_call_declined_cb = cb;
 }
 
+void gui_bridge_set_call_error_cb(gui_call_error_fn cb) {
+    g_call_error_cb = cb;
+}
+
 void gui_bridge_set_call_path_cb(gui_call_path_fn cb) {
     g_call_path_cb = cb;
 }