simple-stream-tube-handler.h

#ifndef _TelepathyQt4_simple_stream_tube_handler_h_HEADER_GUARD_
#define _TelepathyQt4_simple_stream_tube_handler_h_HEADER_GUARD_

#include <TelepathyQt4/AbstractClientHandler>
#include <TelepathyQt4/ChannelRequestHints>
#include <TelepathyQt4/RefCounted>
#include <TelepathyQt4/Types>

#include <QDateTime>
#include <QLinkedList>
#include <QHash>
#include <QQueue>
#include <QSet>

namespace Tp
{

class PendingOperation;

class TELEPATHY_QT4_NO_EXPORT SimpleStreamTubeHandler : public QObject,
                public AbstractClientHandler
{
    Q_OBJECT
    Q_DISABLE_COPY(SimpleStreamTubeHandler)

public:
    static SharedPtr<SimpleStreamTubeHandler> create(
            const QStringList &p2pServices,
            const QStringList &roomServices,
            bool requested,
            bool monitorConnections,
            bool bypassApproval = false);
    ~SimpleStreamTubeHandler();

    bool monitorsConnections() const
    {
        return mMonitorConnections;
    }

    bool bypassApproval() const
    {
        return mBypassApproval;
    }

    void handleChannels(const MethodInvocationContextPtr<> &context,
            const AccountPtr &account,
            const ConnectionPtr &connection,
            const QList<ChannelPtr> &channels,
            const QList<ChannelRequestPtr> &requestsSatisfied,
            const QDateTime &userActionTime,
            const HandlerInfo &handlerInfo);

Q_SIGNALS:
    void invokedForTube(
            const Tp::AccountPtr &account,
            const Tp::StreamTubeChannelPtr &tube,
            const QDateTime &userActionTime,
            const Tp::ChannelRequestHints &requestHints);
    void tubeInvalidated(
            const Tp::AccountPtr &account,
            const Tp::StreamTubeChannelPtr &tube,
            const QString &errorName,
            const QString &errorMessage);

private Q_SLOTS:
    void onReadyOpFinished(Tp::PendingOperation *);
    void onTubeInvalidated(Tp::DBusProxy *, const QString &, const QString &);

private:
    SimpleStreamTubeHandler(
            const QStringList &p2pServices,
            const QStringList &roomServices,
            bool requested,
            bool monitorConnections,
            bool bypassApproval);

    bool mMonitorConnections;

    struct InvocationData : RefCounted {
        InvocationData() : readyOp(0) {}

        PendingOperation *readyOp;
        QString error, message;

        MethodInvocationContextPtr<> ctx;
        AccountPtr acc;
        QList<StreamTubeChannelPtr> tubes;
        QDateTime time;
        ChannelRequestHints hints;
    };
    QLinkedList<SharedPtr<InvocationData> > mInvocations;
    QHash<StreamTubeChannelPtr, AccountPtr> mTubes;
    bool mBypassApproval;
};

} // Tp

#endif