X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fprotocols%2Flegacy%2Flegacypeer.h;h=8d91c6b63d6cabd31290ea53954e526b8f10b392;hp=a3aa178b8b8f99e8986e9aee562e09781d2f2112;hb=cf8ba1e2fc36cba287e74e06223060cdfd2cc538;hpb=9fc57dc2c000e80fb8bd746a090e2e8210e1278e diff --git a/src/common/protocols/legacy/legacypeer.h b/src/common/protocols/legacy/legacypeer.h index a3aa178b..8d91c6b6 100644 --- a/src/common/protocols/legacy/legacypeer.h +++ b/src/common/protocols/legacy/legacypeer.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2013 by the Quassel Project * + * Copyright (C) 2005-2014 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -41,11 +41,22 @@ public: HeartBeatReply }; - LegacyPeer(QTcpSocket *socket, QObject *parent = 0); + LegacyPeer(AuthHandler *authHandler, QTcpSocket *socket, QObject *parent = 0); ~LegacyPeer() {} void setSignalProxy(SignalProxy *proxy); + void dispatch(const Protocol::RegisterClient &msg); + void dispatch(const Protocol::ClientDenied &msg); + void dispatch(const Protocol::ClientRegistered &msg); + void dispatch(const Protocol::SetupData &msg); + void dispatch(const Protocol::SetupFailed &msg); + void dispatch(const Protocol::SetupDone &msg); + void dispatch(const Protocol::Login &msg); + void dispatch(const Protocol::LoginFailed &msg); + void dispatch(const Protocol::LoginSuccess &msg); + void dispatch(const Protocol::SessionState &msg); + void dispatch(const Protocol::SyncMessage &msg); void dispatch(const Protocol::RpcCall &msg); void dispatch(const Protocol::InitRequest &msg); @@ -57,16 +68,23 @@ public: // FIXME: this is only used for the auth phase and should be replaced by something more generic void writeSocketData(const QVariant &item); +signals: + void protocolError(const QString &errorString); + + // only used in compat mode + void protocolVersionMismatch(int actual, int expected); + private slots: void socketDataAvailable(); private: bool readSocketData(QVariant &item); + void handleHandshakeMessage(const QVariant &msg); void handlePackedFunc(const QVariant &packedFunc); void dispatchPackedFunc(const QVariantList &packedFunc); QDataStream _stream; - qint32 _blockSize; + quint32 _blockSize; bool _useCompression; };