Add SID (Sudden Ionospheric Disturbances) feature

2026-06-08 00:44:48 -04:00 · 2024-04-02 16:13:01 +01:00
parent 625513eaeb
commit 610c36004e
40 changed files with 6377 additions and 3 deletions
@@ -0,0 +1,153 @@
+///////////////////////////////////////////////////////////////////////////////////
+// Copyright (C) 2023 Jon Beniston, M7RCE                                        //
+// Copyright (C) 2020 Edouard Griffiths, F4EXB                                   //
+//                                                                               //
+// This program is free software; you can redistribute it and/or modify          //
+// it under the terms of the GNU General Public License as published by          //
+// the Free Software Foundation as version 3 of the License, or                  //
+// (at your option) any later version.                                           //
+//                                                                               //
+// This program is distributed in the hope that it will be useful,               //
+// but WITHOUT ANY WARRANTY; without even the implied warranty of                //
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the                  //
+// GNU General Public License V3 for more details.                               //
+//                                                                               //
+// You should have received a copy of the GNU General Public License             //
+// along with this program. If not, see <http://www.gnu.org/licenses/>.          //
+///////////////////////////////////////////////////////////////////////////////////
+
+#include <QDebug>
+
+#include "webapi/webapiadapterinterface.h"
+#include "webapi/webapiutils.h"
+#include "channel/channelwebapiutils.h"
+#include "device/deviceset.h"
+#include "device/deviceapi.h"
+#include "maincore.h"
+
+#include "sid.h"
+#include "sidworker.h"
+
+SIDWorker::SIDWorker(SIDMain *sid, WebAPIAdapterInterface *webAPIAdapterInterface) :
+    m_sid(sid),
+    m_webAPIAdapterInterface(webAPIAdapterInterface),
+    m_msgQueueToFeature(nullptr),
+    m_msgQueueToGUI(nullptr),
+    m_pollTimer(this)
+{
+}
+
+SIDWorker::~SIDWorker()
+{
+    stopWork();
+    m_inputMessageQueue.clear();
+}
+
+void SIDWorker::startWork()
+{
+    qDebug("SIDWorker::startWork");
+    QMutexLocker mutexLocker(&m_mutex);
+    connect(&m_pollTimer, &QTimer::timeout, this, &SIDWorker::update);
+    m_pollTimer.start(1000);
+    connect(&m_inputMessageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleInputMessages()));
+    // Handle any messages already on the queue
+    handleInputMessages();
+}
+
+void SIDWorker::stopWork()
+{
+    qDebug("SIDWorker::stopWork");
+    QMutexLocker mutexLocker(&m_mutex);
+    disconnect(&m_inputMessageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleInputMessages()));
+    m_pollTimer.stop();
+    disconnect(&m_pollTimer, &QTimer::timeout, this, &SIDWorker::update);
+}
+
+void SIDWorker::handleInputMessages()
+{
+    Message* message;
+
+    while ((message = m_inputMessageQueue.pop()) != nullptr)
+    {
+        if (handleMessage(*message)) {
+            delete message;
+        }
+    }
+}
+
+bool SIDWorker::handleMessage(const Message& cmd)
+{
+    if (SIDMain::MsgConfigureSID::match(cmd))
+    {
+        QMutexLocker mutexLocker(&m_mutex);
+        SIDMain::MsgConfigureSID& cfg = (SIDMain::MsgConfigureSID&) cmd;
+
+        applySettings(cfg.getSettings(), cfg.getSettingsKeys(), cfg.getForce());
+        return true;
+    }
+    else
+    {
+        return false;
+    }
+}
+
+void SIDWorker::applySettings(const SIDSettings& settings, const QList<QString>& settingsKeys, bool force)
+{
+    qDebug() << "SIDWorker::applySettings:" << settings.getDebugString(settingsKeys, force) << force;
+
+    if (settingsKeys.contains("period") || force)
+    {
+        m_pollTimer.stop();
+        m_pollTimer.start(settings.m_period * 1000);
+    }
+
+    if (force) {
+        m_settings = settings;
+    } else {
+        m_settings.applySettings(settingsKeys, settings);
+    }
+}
+
+void SIDWorker::update()
+{
+    // Get powers from each channel
+    QDateTime dateTime = QDateTime::currentDateTime();
+
+    for (const auto& channelSettings : m_settings.m_channelSettings)
+    {
+        if (channelSettings.m_enabled)
+        {
+            unsigned int deviceSetIndex, channelIndex;
+
+            if (MainCore::getDeviceAndChannelIndexFromId(channelSettings.m_id, deviceSetIndex, channelIndex))
+            {
+                // Check device is running
+                std::vector<DeviceSet*> deviceSets = MainCore::instance()->getDeviceSets();
+                if (deviceSetIndex < deviceSets.size())
+                {
+                    DeviceSet *deviceSet = deviceSets[deviceSetIndex];
+                    if (deviceSet && (deviceSet->m_deviceAPI->state() == DeviceAPI::StRunning))
+                    {
+                        double power;
+                        if (ChannelWebAPIUtils::getChannelReportValue(deviceSetIndex, channelIndex, "channelPowerDB", power))
+                        {
+                            if (getMessageQueueToGUI())
+                            {
+                                SIDMain::MsgMeasurement *msgToGUI = SIDMain::MsgMeasurement::create(dateTime, channelSettings.m_id, power);
+                                getMessageQueueToGUI()->push(msgToGUI);
+                            }
+                        }
+                        else
+                        {
+                            qDebug() << "SIDWorker::update: Failed to get power for channel " << channelSettings.m_id;
+                        }
+                    }
+                }
+            }
+            else
+            {
+                qDebug() << "SIDWorker::update: Malformed channel id: " << channelSettings.m_id;
+            }
+        }
+    }
+}