serialmanager.cpp

/**
 * @file serialmanager.cpp
 * @brief Implementacja klasy SerialManager obsługującej komunikację szeregową oraz parsowanie danych.
 */

#include "serialmanager.h"
#include <QDebug>

/**
 * @brief Konstruktor klasy SerialManager.
 * Inicjalizuje obiekt QSerialPort oraz łączy sygnał `readyRead()` z metodą `readData()`.
 * @param parent Obiekt nadrzędny (domyślnie nullptr).
 */
SerialManager::SerialManager(QObject *parent)
    : QObject(parent), serial(new QSerialPort(this))
{
    connect(serial, &QSerialPort::readyRead, this, &SerialManager::readData);
}

/**
 * @brief Rozpoczyna nasłuch na wskazanym porcie szeregowym.
 * @param portName Nazwa portu szeregowego, np. "/dev/ttyUSB0".
 */
void SerialManager::start(const QString &portName)
{
    serial->setPortName(portName);
    serial->setBaudRate(QSerialPort::Baud9600);

    if (!serial->open(QIODevice::ReadOnly)) {
        emit serialError("!Nie można otworzyć portu: " + portName);
    }
}

/**
 * @brief Odczytuje dostępne linie z portu szeregowego i przekazuje je do parsera.
 *
 * Funkcja wywoływana automatycznie po odebraniu danych (readyRead).
 */
void SerialManager::readData()
{
    while (serial->canReadLine()) {
        QByteArray data = serial->readLine();
        QString line = QString::fromUtf8(data).trimmed();
        ParsedPacket packet = parseSerialLine(line);
        emit newPacketReceived(packet);
    }
}

/**
 * @brief Parsuje linię tekstu odebraną z portu szeregowego.
 *
 * Linia może zawierać:
 * - Współrzędne geograficzne (latitude;longitude)
 * - Dane sensorów
 * - Dodatkowy log tekstowy poprzedzony znakiem `!`
 *
 * Przykład:
 * ```
 * 51.107;17.038;12.5;3.14;8.9!Błąd pomiaru temperatury
 * ```
 *
 * @param line Linia danych wejściowych.
 * @return Parsowana struktura danych ParsedPacket.
 */
ParsedPacket SerialManager::parseSerialLine(const QString &line)
{
    ParsedPacket result;
    result.hasPosition = false;

    QString cleanLine = line.trimmed();
    int logIndex = cleanLine.indexOf('!');

    QString dataPart = (logIndex >= 0) ? cleanLine.left(logIndex) : cleanLine;
    QString logPart = (logIndex >= 0) ? cleanLine.mid(logIndex + 1) : "";

    QStringList items = dataPart.split(';', Qt::SkipEmptyParts);

    if (items.size() >= 2) {
        bool latOk = false, lonOk = false;

        double lat = items[0].toDouble(&latOk);
        double lon = items[1].toDouble(&lonOk);

        if (latOk && lonOk) {
            result.latitude = lat;
            result.longitude = lon;
            qDebug() << lat << " , " << lon;
            result.hasPosition = true;

            // Pozostałe elementy to sensory
            for (int i = 2; i < items.size(); ++i) {
                bool ok;
                double val = items[i].toDouble(&ok);
                if (ok) result.sensors.append(val);
            }
        } else {
            // Jeśli współrzędne niepoprawne, potraktuj wszystko jako sensory
            for (const QString &item : items) {
                bool ok;
                double val = item.toDouble(&ok);
                if (ok) result.sensors.append(val);
            }
        }
    }

    result.log = logPart;
    return result;
}