+// ==================================================
+// AbstractPeer
+// ==================================================
+class SignalProxy::AbstractPeer : public QObject
+{
+ Q_OBJECT
+
+public:
+ AbstractPeer(QObject *parent = 0) : QObject(parent) {}
+
+ virtual QString description() const = 0;
+
+ virtual void setSignalProxy(SignalProxy *proxy) = 0;
+
+ virtual bool isOpen() const = 0;
+ virtual bool isSecure() const = 0;
+ virtual bool isLocal() const = 0;
+
+ virtual QString errorString() const { return QString(); }
+
+ virtual int lag() const = 0;
+
+public slots:
+ virtual void dispatch(const SyncMessage &msg) = 0;
+ virtual void dispatch(const RpcCall &msg) = 0;
+ virtual void dispatch(const InitRequest &msg) = 0;
+ virtual void dispatch(const InitData &msg) = 0;
+
+ virtual void close(const QString &reason = QString()) = 0;
+
+signals:
+ void disconnected();
+ void error(QAbstractSocket::SocketError);
+ void secureStateChanged(bool secure = true);
+ void lagUpdated(int msecs);
+};
+
+
+// ==================================================
+// Protocol Messages
+// ==================================================
+class SignalProxy::SyncMessage
+{
+public:
+ inline SyncMessage(const QByteArray &className, const QString &objectName, const QByteArray &slotName, const QVariantList ¶ms)
+ : _className(className), _objectName(objectName), _slotName(slotName), _params(params) {}
+
+ inline QByteArray className() const { return _className; }
+ inline QString objectName() const { return _objectName; }
+ inline QByteArray slotName() const { return _slotName; }
+
+ inline QVariantList params() const { return _params; }
+
+private:
+ QByteArray _className;
+ QString _objectName;
+ QByteArray _slotName;
+ QVariantList _params;
+};
+
+
+class SignalProxy::RpcCall
+{
+public:
+ inline RpcCall(const QByteArray &slotName, const QVariantList ¶ms)
+ : _slotName(slotName), _params(params) {}
+
+ inline QByteArray slotName() const { return _slotName; }
+ inline QVariantList params() const { return _params; }
+
+private:
+ QByteArray _slotName;
+ QVariantList _params;
+};
+
+
+class SignalProxy::InitRequest
+{
+public:
+ inline InitRequest(const QByteArray &className, const QString &objectName)
+ : _className(className), _objectName(objectName) {}
+
+ inline QByteArray className() const { return _className; }
+ inline QString objectName() const { return _objectName; }
+
+private:
+ QByteArray _className;
+ QString _objectName;
+};
+
+
+class SignalProxy::InitData
+{
+public:
+ inline InitData(const QByteArray &className, const QString &objectName, const QVariantMap &initData)
+ : _className(className), _objectName(objectName), _initData(initData) {}
+
+ inline QByteArray className() const { return _className; }
+ inline QString objectName() const { return _objectName; }
+
+ inline QVariantMap initData() const { return _initData; }
+
+private:
+ QByteArray _className;
+ QString _objectName;
+ QVariantMap _initData;
+};
+