Method wireSpotSubsystem

src/gui/MainWindow_Spots.cpp:46–529

namespace AetherSDR {

void MainWindow::wireSpotSubsystem()
{
    // ── DX Cluster — forward parsed spots to radio ──────────────────────
    // ── Spot clients on worker thread ─────────────────────────────────────
    m_dxCluster = new DxClusterClient;
    m_rbnClient = new DxClusterClient;
    m_rbnClient->setLogFileName("rbn.log");
    m_rbnClient->setStartupCommandsKey("RbnStartupCommands");
    m_wsjtxClient = new WsjtxClient;
    m_spotCollectorClient = new SpotCollectorClient;
    m_potaClient = new PotaClient;
#ifdef HAVE_WEBSOCKETS
    m_freedvClient = new FreeDvClient;
#endif
#ifdef HAVE_MQTT
    m_mqttClient = new MqttClient(this);
    m_appletPanel->mqttApplet()->setMqttClient(m_mqttClient);

    connect(m_appletPanel->mqttApplet(), &MqttApplet::connectRequested,
            this, [this](const QString& host, quint16 port,
                         const QString& user, const QString& pass,
                         const QStringList& topics,
                         bool useTls, const QString& caFile) {
        m_mqttClient->setSubscriptions(mqttSubscriptionTopics(topics));
        m_mqttClient->connectToBroker(host, port, user, pass, useTls, caFile);
    });
    connect(m_appletPanel->mqttApplet(), &MqttApplet::disconnectRequested,
            this, [this] { m_mqttClient->disconnect(); });
    connect(m_appletPanel->mqttApplet(), &MqttApplet::settingsRequested,
            this, &MainWindow::showMqttSettingsDialog);
    m_appletPanel->mqttApplet()->restoreConnectionState();

    // CW decode → MQTT topic "aethersdr/cw/decode".
    // Publishes {"text":"K","freq":14.025,"rx":true} per decoded character.
    // RX decoder uses rx:true; TX sidetone decoder uses rx:false.
    // Any MQTT subscriber (e.g. a contest logger) receives the stream
    // without additional AetherSDR interfaces.
    connect(&m_cwDecoder,   &CwDecoder::textDecoded, this,
            [this](const QString& t, float cost) { publishCwDecodeMqtt(t, cost, true);  });
    connect(&m_cwDecoderTx, &CwDecoder::textDecoded, this,
            [this](const QString& t, float cost) { publishCwDecodeMqtt(t, cost, false); });

    // aethersdr/radio/state — publish on PTT transitions.
    // Slice freq/mode changes are wired per-slice in setActiveSliceInternal().
    m_radioStateCoalesceTimer.setSingleShot(true);
    m_radioStateCoalesceTimer.setInterval(150);
    connect(&m_radioStateCoalesceTimer, &QTimer::timeout,
            this, &MainWindow::publishRadioStateMqtt);
    connect(&m_radioModel, &RadioModel::radioTransmittingChanged,
            this, [this](bool) { publishRadioStateMqtt(); });
    // Debounce timer for end-of-CWX detection (queueEmpty unreliable with sync_cwx=0).
    // Fires 1 s after the last tx:false with no intervening tx:true = transmission done.
    m_cwxTxEndTimer.setSingleShot(true);
    connect(&m_cwxTxEndTimer, &QTimer::timeout, this, [this]() {
        if (m_cwxSavedWpm > 0 && m_radioModel.cwxModel().speed() == m_cwxSentWpm)
            m_radioModel.cwxModel().setSpeed(m_cwxSavedWpm);
        if (m_cwxSavedHz  > 0 && m_radioModel.transmitModel().cwPitch() == m_cwxSentHz)
            m_radioModel.transmitModel().setCwPitch(m_cwxSavedHz);