server_protocolhandler.h

Go to the documentation of this file.

#ifndef SERVER_PROTOCOLHANDLER_H
#define SERVER_PROTOCOLHANDLER_H
 
#include "server.h"
#include "server_abstractuserinterface.h"
 
#include <QByteArray>
#include <QDateTime>
#include <QList>
#include <QMap>
#include <QObject>
#include <QString>
#include <libcockatrice/protocol/pb/response.pb.h>
#include <qtmetamacros.h>
 
class Server_DatabaseInterface;
class Server_Room;
class ServerMessage;
class ResponseContainer;
class CommandContainer;
class SessionCommand;
class ModeratorCommand;
class AdminCommand;
class DeveloperCommand;
class Command_Ping;
class Command_Login;
class Command_Message;
class Command_ListUsers;
class Command_GetGamesOfUser;
class Command_GetUserInfo;
class Command_ListRooms;
class Command_JoinRoom;
class Command_LeaveRoom;
class Command_RoomSay;
class Command_RoomChannelSay;
class Command_CreateGame;
class Command_JoinGame;
 
class Server_ProtocolHandler : public QObject, public Server_AbstractUserInterface
{
    Q_OBJECT
protected:
    QMap<int, Server_Room *> rooms;
 
    bool deleted;
    Server_DatabaseInterface *databaseInterface;
    AuthenticationResult authState;
    bool usingRealPassword;
    bool acceptsUserListChanges;
    bool acceptsRoomListChanges;
    bool idleClientWarningSent;
    QByteArray authNonce;
    QString authNonceUser;
    QDateTime authNonceCreated;
    virtual void logDebugMessage(const QString & /* message */)
    {
    }
 
private:
    QList<int> messageSizeOverTime, messageCountOverTime, commandCountOverTime;
    int timeRunning, lastDataReceived, lastActionReceived;
 
    virtual void transmitProtocolItem(const ServerMessage &item) = 0;
 
    Response::ResponseCode cmdPing(const Command_Ping &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdLogin(const Command_Login &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdMessage(const Command_Message &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdGetGamesOfUser(const Command_GetGamesOfUser &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdGetUserInfo(const Command_GetUserInfo &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdListRooms(const Command_ListRooms &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdJoinRoom(const Command_JoinRoom &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdListUsers(const Command_ListUsers &cmd, ResponseContainer &rc);
    Response::ResponseCode cmdLeaveRoom(const Command_LeaveRoom &cmd, Server_Room *room, ResponseContainer &rc);
    Response::ResponseCode cmdRoomSay(const Command_RoomSay &cmd, Server_Room *room, ResponseContainer &rc);
    Response::ResponseCode
    cmdRoomChannelSay(const Command_RoomChannelSay &cmd, Server_Room *room, ResponseContainer &rc);
    Response::ResponseCode cmdCreateGame(const Command_CreateGame &cmd, Server_Room *room, ResponseContainer &rc);
    Response::ResponseCode cmdJoinGame(const Command_JoinGame &cmd, Server_Room *room, ResponseContainer &rc);
 
    Response::ResponseCode processSessionCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    virtual Response::ResponseCode
    processExtendedSessionCommand(int /* cmdType */, const SessionCommand & /* cmd */, ResponseContainer & /* rc */)
    {
        return Response::RespFunctionNotAllowed;
    }
    Response::ResponseCode processRoomCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    Response::ResponseCode processGameCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    Response::ResponseCode processModeratorCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    virtual Response::ResponseCode
    processExtendedModeratorCommand(int /* cmdType */, const ModeratorCommand & /* cmd */, ResponseContainer & /* rc */)
    {
        return Response::RespFunctionNotAllowed;
    }
    Response::ResponseCode processAdminCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    virtual Response::ResponseCode
    processExtendedAdminCommand(int /* cmdType */, const AdminCommand & /* cmd */, ResponseContainer & /* rc */)
    {
        return Response::RespFunctionNotAllowed;
    }
    Response::ResponseCode processDeveloperCommandContainer(const CommandContainer &cont, ResponseContainer &rc);
    virtual Response::ResponseCode
    processExtendedDeveloperCommand(int /* cmdType */, const DeveloperCommand & /* cmd */, ResponseContainer & /* rc */)
    {
        return Response::RespFunctionNotAllowed;
    }
 
    void resetIdleTimer();
private slots:
    void pingClockTimeout();
public slots:
    void prepareDestroy();
 
public:
    Server_ProtocolHandler(Server *_server, Server_DatabaseInterface *_databaseInterface, QObject *parent = 0);
    ~Server_ProtocolHandler();
 
    bool getAcceptsUserListChanges() const
    {
        return acceptsUserListChanges;
    }
    bool getAcceptsRoomListChanges() const
    {
        return acceptsRoomListChanges;
    }
    virtual QString getAddress() const = 0;
    virtual QString getConnectionType() const = 0;
    Server_DatabaseInterface *getDatabaseInterface() const
    {
        return databaseInterface;
    }

    void setAuthNonce(const QByteArray &nonce, const QString &userName);
    bool isAuthNonceValid(const QByteArray &nonce, const QString &userName) const;
    void clearAuthNonce();
 
    int getLastCommandTime() const
    {
        return timeRunning - lastDataReceived;
    }
    bool addSaidMessageSize(int size);
    virtual void processCommandContainer(const CommandContainer &cont);
 
    void sendProtocolItem(const Response &item);
    void sendProtocolItem(const SessionEvent &item);
    void sendProtocolItem(const GameEventContainer &item);
    void sendProtocolItem(const RoomEvent &item);
};
 
#endif