js8call/JS8_Main/Inbox.h

#ifndef INBOX_H
#define INBOX_H

/**
 * (C) 2018 Jordan Sherer <kn4crd@gmail.com> - All Rights Reserved
 **/

#include "Message.h"

#include <QObject>
#include <QPair>
#include <QString>
#include <QVariant>

struct sqlite3;
struct sqlite3_stmt;

class Inbox {
  public:
    explicit Inbox(QString path);
    ~Inbox();

    // Low-Level Interface
    bool isOpen();
    bool open();
    void close();
    QString error();
    int count(QString type, QString query, QString match);
    QList<QPair<int, Message>> values(QString type, QString query,
                                      QString match, int offset, int limit);
    Message value(int key);
    int append(Message value);
    bool set(int key, Message value);
    bool del(int key);

    // High-Level Interface
    QList<QPair<int, Message>> fetchForCall(const QString& callPattern);
    int countUnreadFrom(QString from);
    int countUnreadForCallsign(const QString &callsign);
    int countGroupUnreadForCallsign(const QString &group_name,
                                    const QString &callsign);

    QPair<int, Message> firstUnreadFrom(QString from);
    int getLookaheadMessageIdForCallsign(const QString &callsign,
                                         int afterMsgId);

    QMap<QString, int> getGroupMessageCounts();
    int getNextGroupMessageIdForCallsign(const QString &group_name,
                                         const QString &callsign);
    int getLookaheadGroupMessageIdForCallsign(const QString &group_name,
                                              const QString &callsign,
                                              int afterMsgId);
    bool markGroupMsgDeliveredForCallsign(int msgId, QString callsign);

  signals:

  public slots:

  private:
    QString path_;
    sqlite3 *db_;
};

#endif // INBOX_H