bdfc1cff8e
commit e48c78765ca1e2e5a68fd93bac7191eaf6918352
Author: Jordan Sherer <jordan@widefido.com>
Date: Wed Jan 2 12:23:28 2019 -0500
Transition to persistent inbox for later retrieval
Fixed issue with inbox items disappearing due to aging.
commit 1df07595bf6507438c1488839f7a2075a432a1a1
Author: Jordan Sherer <jordan@widefido.com>
Date: Wed Jan 2 09:23:28 2019 -0500
Filtered value and count queries for the inbox
commit c93a93a1c43a65fae4a31ddeb40c77c53204bbdb
Author: Jordan Sherer <jordan@widefido.com>
Date: Tue Jan 1 22:58:07 2019 -0500
Initial cut of inbox storage
79 lines
2.2 KiB
C++
79 lines
2.2 KiB
C++
#ifndef MESSAGE_CLIENT_HPP__
|
|
#define MESSAGE_CLIENT_HPP__
|
|
|
|
#include <QObject>
|
|
#include <QTime>
|
|
#include <QDataStream>
|
|
#include <QDateTime>
|
|
#include <QString>
|
|
|
|
#include "Message.h"
|
|
#include "Radio.hpp"
|
|
#include "pimpl_h.hpp"
|
|
|
|
class QByteArray;
|
|
class QHostAddress;
|
|
class QColor;
|
|
|
|
//
|
|
// MessageClient - Manage messages sent and replies received from a
|
|
// matching server (MessageServer) at the other end of
|
|
// the wire
|
|
//
|
|
//
|
|
// Each outgoing message type is a Qt slot
|
|
//
|
|
class MessageClient
|
|
: public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
public:
|
|
using Frequency = Radio::Frequency;
|
|
using port_type = quint16;
|
|
|
|
// instantiate and initiate a host lookup on the server
|
|
//
|
|
// messages will be silently dropped until a server host lookup is complete
|
|
MessageClient (QString const& id, QString const& version, QString const& revision,
|
|
QString const& server, port_type server_port, QObject * parent = nullptr);
|
|
|
|
// query server details
|
|
QHostAddress server_address () const;
|
|
port_type server_port () const;
|
|
|
|
// initiate a new server host lookup or is the server name is empty
|
|
// the sending of messages is disabled
|
|
Q_SLOT void set_server (QString const& server = QString {});
|
|
|
|
// change the server port messages are sent to
|
|
Q_SLOT void set_server_port (port_type server_port = 0u);
|
|
|
|
// this slot is used to send an arbitrary message
|
|
Q_SLOT void send(Message const &message);
|
|
|
|
// this slot may be used to send arbitrary UDP datagrams to and
|
|
// destination allowing the underlying socket to be used for general
|
|
// UDP messaging if desired
|
|
Q_SLOT void send_raw_datagram (QByteArray const&, QHostAddress const& dest_address, port_type dest_port);
|
|
|
|
// disallowed message destination (does not block datagrams sent
|
|
// with send_raw_datagram() above)
|
|
Q_SLOT void add_blocked_destination (QHostAddress const&);
|
|
|
|
Q_SIGNAL void message(Message const &message);
|
|
|
|
// this signal is emitted when the a reply a message is received
|
|
Q_SIGNAL void message_received(QString const &type, QString const &message);
|
|
|
|
// this signal is emitted when network errors occur or if a host
|
|
// lookup fails
|
|
Q_SIGNAL void error (QString const&) const;
|
|
|
|
private:
|
|
class impl;
|
|
pimpl<impl> m_;
|
|
};
|
|
|
|
#endif
|