torcrpcrequest.h

Go to the documentation of this file.

#ifndef TORCRPCREQUEST_H
#define TORCRPCREQUEST_H

// Qt
#include <QList>
#include <QMutex>
#include <QVariant>
#include <QJsonObject>

// Torc
#include "http/torcwebsocket.h"
#include "torcreferencecounted.h"

class TorcRPCRequest : public TorcReferenceCounter
{
  public:
    enum State
    {
        None          = (0 << 0),
        RequestSent   = (1 << 0),
        ReplyReceived = (1 << 1),
        Cancelled     = (1 << 2),
        TimedOut      = (1 << 3),
        Errored       = (1 << 4),
        Result        = (1 << 5)
    };

  public:
    TorcRPCRequest(const QString &Method, QObject *Parent);
    explicit TorcRPCRequest(const QString &Method);
    TorcRPCRequest(TorcWebSocketReader::WSSubProtocol Protocol, const QByteArray &Data, QObject *Parent, bool Authenticated);

    bool                IsNotification         (void) const;
    void                NotifyParent           (void);
    void                SetParent              (QObject *Parent);
    QByteArray&         SerialiseRequest       (TorcWebSocketReader::WSSubProtocol Protocol);

    void                AddState               (int State);
    void                SetID                  (int ID);
    void                AddParameter           (const QString &Name, const QVariant &Value);
    void                AddPositionalParameter (const QVariant &Value);
    void                SetReply               (const QVariant &Reply);

    int                 GetState               (void) const;
    int                 GetID                  (void) const;
    QString             GetMethod              (void) const;
    QObject*            GetParent              (void) const;
    const QVariant&     GetReply               (void) const;
    const QList<QPair<QString,QVariant> >&
                        GetParameters          (void) const;
    const QList<QVariant>&
                        GetPositionalParameters(void) const;
    QByteArray&         GetData                (void);

  private:
    explicit TorcRPCRequest(const QJsonObject &Object, QObject *Parent, bool Authenticated);
    ~TorcRPCRequest();
    Q_DISABLE_COPY(TorcRPCRequest)

    void                ParseJSONObject        (const QJsonObject &Object);
    void                ProcessNullContent     (bool HasMethod);
    void                ProcessBatchCall       (const QJsonArray &Array);


  private:
    bool                m_authenticated;
    bool                m_notification;
    int                 m_state;
    int                 m_id;
    QString             m_method;
    QObject            *m_parent;
    QMutex             *m_parentLock;
    bool                m_validParent;
    QList<QPair<QString,QVariant> > m_parameters;
    QList<QVariant>     m_positionalParameters;
    QByteArray          m_serialisedData;
    QVariant            m_reply;
};

Q_DECLARE_METATYPE(TorcRPCRequest*)

#endif // TORCRPCREQUEST_H