AprsInboundRelay.h

Go to the documentation of this file.

#ifndef APRSINBOUNDRELAY_H
#define APRSINBOUNDRELAY_H
 
#include <QDateTime>
#include <QHash>
#include <QObject>
#include <QString>
 
#include <functional>
 
class Configuration;

class AprsInboundRelay : public QObject {
    Q_OBJECT
 
  public:
    struct CallActivityInfo {
        bool heard = false;
        QDateTime lastHeardUtc;
    };
 
    using CallActivityLookup =
        std::function<CallActivityInfo(QString const &call)>;
    using NoticeFn =
        std::function<void(QDateTime const &utc, QString const &text)>;
    using EnqueueFn = std::function<void(QString const &message)>;
    using AckFn =
        std::function<void(QString const &fromCall, QString const &toCall,
                           QString const &messageId)>;

    AprsInboundRelay(Configuration const *config, CallActivityLookup callLookup,
                     NoticeFn noticeFn, EnqueueFn enqueueFn, AckFn ackFn,
                     QObject *parent = nullptr);
 
  public slots:
    void onMessageReceived(QString from, QString to, QString message,
                           QString messageId);
 
  private:
    Configuration const *m_config;
    CallActivityLookup m_callLookup;
    NoticeFn m_notice;
    EnqueueFn m_enqueue;
    AckFn m_ack;
    QHash<QString, QDateTime> m_ackDedupCache;
};
 
#endif