ActivityDB.h

Go to the documentation of this file.

#pragma once
 
#include <QDateTime>
#include <QList>
#include <QString>

 
struct sqlite3;
struct sqlite3_stmt;
 
class ActivityDB {
public:
    struct CallRecord {
        QString   callsign;
        QString   through;
        int       snr = 0;
        QString   grid;
        quint64   dial = 0;
        int       offset = 0;
        int       bits = 0;
        float     tdrift = 0.0f;
        QDateTime cqTimestamp;
        QDateTime ackTimestamp;
        QDateTime utcTimestamp;
        int       submode = 0;
    };
 
    explicit ActivityDB(const QString &path);
    ~ActivityDB();
 
    ActivityDB(const ActivityDB &) = delete;
    ActivityDB &operator=(const ActivityDB &) = delete;
 
    bool open();
    void close();

    bool isOpen() const;

    QString error() const;

    bool begin();

    bool commit();

    void rollback();

    bool inTransaction() const { return inTransaction_; }
 
    // Call activity
    bool upsertCall(const QString &config, const QString &band,
                    const CallRecord &record);
    bool deleteCall(const QString &config, const QString &band,
                    const QString &callsign);
    bool deleteCalls(const QString &config, const QString &band);

    QList<CallRecord> loadCalls(const QString &config, const QString &band,
                                bool *ok = nullptr);
 
    // RX text history (one HTML document per configuration + band)
    bool saveRxText(const QString &config, const QString &band,
                    const QString &html);
    QString loadRxText(const QString &config, const QString &band,
                       bool *ok = nullptr);
    bool clearRxText(const QString &config, const QString &band);

    bool hasImported(const QString &config, bool *ok = nullptr);

    bool markImported(const QString &config);

    bool clearConfig(const QString &config);

    bool copyConfig(const QString &from, const QString &to);
 
private:
    void captureError();
    bool noteResult(bool ok);
    void noteFailureCaptured();
 
    QString       path_;
    sqlite3      *db_;
    QString       lastError_;
    bool          inTransaction_;
    bool          pendingClose_; // third strike landed mid-transaction
    int           consecutiveFailures_;
    sqlite3_stmt *upsertCallStmt_;
    sqlite3_stmt *saveRxTextStmt_;
};