pilotclient/src/blackcore/afv/model/afvmapreader.cpp

#include "afvmapreader.h"
#include "blackcore/application.h"
#include "blackcore/afv/dto.h"
#include "blackmisc/aviation/callsign.h"
#include <QEventLoop>
#include <QNetworkReply>
#include <QJsonDocument>
#include <QJsonObject>
#include <QJsonArray>

using namespace BlackMisc::Aviation;

namespace BlackCore
{
    namespace Afv
    {
        namespace Model
        {
            CAfvMapReader::CAfvMapReader(QObject *parent) : QObject(parent)
            {
                m_model = new CSampleAtcStationModel(this);
                m_timer = new QTimer(this);
                connect(m_timer, &QTimer::timeout, this, &CAfvMapReader::updateFromMap);
                m_timer->start(3000);
            }

            void CAfvMapReader::updateFromMap()
            {
                if (!sApp || !sApp->getNetworkAccessManager() || sApp->isShuttingDown()) { return; }

                QEventLoop loop(sApp);
                connect(sApp->getNetworkAccessManager(), &QNetworkAccessManager::finished, &loop, &QEventLoop::quit);
                connect(sApp, &CApplication::aboutToShutdown, &loop, &QEventLoop::quit);
                QNetworkReply *reply = sApp->getNetworkAccessManager()->get(QNetworkRequest(QUrl("https://voice1.vatsim.uk/api/v1/network/online/callsigns")));
                while (reply && !reply->isFinished() && sApp && !sApp->isShuttingDown())
                {
                    loop.exec();
                }
                const QByteArray jsonData = reply->readAll();
                if (reply) { reply->deleteLater(); }

                if (jsonData.isEmpty()) { return; }

                QJsonDocument jsonDoc = QJsonDocument::fromJson(jsonData);
                if (jsonDoc.isArray())
                {
                    const QJsonArray rootArray = jsonDoc.array();
                    QVector<CSampleAtcStation> transceivers;
                    QString callsign;

                    for (auto it = rootArray.begin(); it != rootArray.end(); ++it)
                    {
                        if (it->isObject())
                        {
                            const QJsonObject stationObject = it->toObject();

                            if (stationObject.contains("callsign"))
                            {
                                callsign = stationObject.value("callsign").toString();
                            }

                            if (callsign.isEmpty() || !CCallsign::looksLikeAtcCallsign(callsign)) { continue; }

                            if (stationObject.contains("transceivers"))
                            {
                                QJsonArray txArray = stationObject.value("transceivers").toArray();
                                for (auto jt = txArray.begin(); jt != txArray.end(); ++jt)
                                {
                                    const TransceiverDto transceiver = TransceiverDto::fromJson(jt->toObject());
                                    transceivers.push_back({ callsign, transceiver});
                                }
                            }
                        }
                    }

                    if (transceivers.isEmpty()) { return; }
                    transceivers.erase(std::remove_if(transceivers.begin(), transceivers.end(), [this](const CSampleAtcStation & s)
                    {
                        return s.callsign() == m_callsign;
                    }),
                    transceivers.end());
                    m_model->updateAtcStations(transceivers);
                }
            }
        } // ns
    } // ns
} // ns