Inbox.h

#ifndef INBOX_H
#define INBOX_H

 
#include "Message.h"
#include "vendor/sqlite3/sqlite3.h"
 
#include <QObject>
#include <QPair>
#include <QString>
#include <QVariant>
 
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