X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcoresessioneventprocessor.h;h=1e743bbb48b5f212aef3623518351cc0414dc6fd;hp=0fd0c9e27b5145d4c37f962f6408f8f8241f4906;hb=b134e777b822b929a78455fd92146bf7443e9aa1;hpb=d3dcda30c8cbee75c0c8f500f4ab552bde513036 diff --git a/src/core/coresessioneventprocessor.h b/src/core/coresessioneventprocessor.h index 0fd0c9e2..1e743bbb 100644 --- a/src/core/coresessioneventprocessor.h +++ b/src/core/coresessioneventprocessor.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2015 by the Quassel Project * + * Copyright (C) 2005-2020 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,8 +18,7 @@ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ -#ifndef CORESESSIONEVENTPROCESSOR_H -#define CORESESSIONEVENTPROCESSOR_H +#pragma once #include "basichandler.h" #include "corenetwork.h" @@ -40,132 +39,149 @@ class CoreSessionEventProcessor : public BasicHandler Q_OBJECT public: - CoreSessionEventProcessor(CoreSession *session); - - inline CoreSession *coreSession() const { return _coreSession; } - - Q_INVOKABLE void processIrcEventNumeric(IrcEventNumeric *event); - - Q_INVOKABLE void processIrcEventAuthenticate(IrcEvent *event); /// SASL authentication - Q_INVOKABLE void processIrcEventCap(IrcEvent *event); /// CAP framework negotiation - Q_INVOKABLE void processIrcEventAccount(IrcEvent *event); /// account-notify received - Q_INVOKABLE void processIrcEventAway(IrcEvent *event); /// away-notify received - Q_INVOKABLE void processIrcEventInvite(IrcEvent *event); - Q_INVOKABLE void processIrcEventJoin(IrcEvent *event); - Q_INVOKABLE void lateProcessIrcEventKick(IrcEvent *event); - Q_INVOKABLE void processIrcEventMode(IrcEvent *event); - Q_INVOKABLE void lateProcessIrcEventNick(IrcEvent *event); - Q_INVOKABLE void lateProcessIrcEventPart(IrcEvent *event); - Q_INVOKABLE void processIrcEventPing(IrcEvent *event); - Q_INVOKABLE void processIrcEventPong(IrcEvent *event); - Q_INVOKABLE void processIrcEventQuit(IrcEvent *event); - Q_INVOKABLE void lateProcessIrcEventQuit(IrcEvent *event); - Q_INVOKABLE void processIrcEventTopic(IrcEvent *event); + explicit CoreSessionEventProcessor(CoreSession* session); + + inline CoreSession* coreSession() const { return _coreSession; } + + Q_INVOKABLE void processIrcEventNumeric(IrcEventNumeric* event); + + Q_INVOKABLE void processIrcEventAuthenticate(IrcEvent* event); /// SASL authentication + Q_INVOKABLE void processIrcEventCap(IrcEvent* event); /// CAP framework negotiation + Q_INVOKABLE void processIrcEventAccount(IrcEvent* event); /// account-notify received + Q_INVOKABLE void processIrcEventAway(IrcEvent* event); /// away-notify received + Q_INVOKABLE void processIrcEventChghost(IrcEvent* event); /// chghost received + Q_INVOKABLE void processIrcEventInvite(IrcEvent* event); + Q_INVOKABLE void processIrcEventJoin(IrcEvent* event); + Q_INVOKABLE void lateProcessIrcEventKick(IrcEvent* event); + Q_INVOKABLE void processIrcEventMode(IrcEvent* event); + Q_INVOKABLE void processIrcEventNick(IrcEvent* event); /// Nickname changes + Q_INVOKABLE void lateProcessIrcEventNick(IrcEvent* event); + Q_INVOKABLE void processIrcEventPart(IrcEvent* event); /// Leaving a channel + Q_INVOKABLE void lateProcessIrcEventPart(IrcEvent* event); + Q_INVOKABLE void processIrcEventPing(IrcEvent* event); + Q_INVOKABLE void processIrcEventPong(IrcEvent* event); + Q_INVOKABLE void processIrcEventQuit(IrcEvent* event); + Q_INVOKABLE void lateProcessIrcEventQuit(IrcEvent* event); + Q_INVOKABLE void processIrcEventTopic(IrcEvent* event); + Q_INVOKABLE void processIrcEventError(IrcEvent* event); /// ERROR message from server #ifdef HAVE_QCA2 - Q_INVOKABLE void processKeyEvent(KeyEvent *event); + Q_INVOKABLE void processKeyEvent(KeyEvent* event); #endif - Q_INVOKABLE void processIrcEvent001(IrcEventNumeric *event); // RPL_WELCOME - Q_INVOKABLE void processIrcEvent005(IrcEvent *event); // RPL_ISUPPORT - Q_INVOKABLE void processIrcEvent221(IrcEvent *event); // RPL_UMODEIS - Q_INVOKABLE void processIrcEvent250(IrcEvent *event); // RPL_STATSCONN - Q_INVOKABLE void processIrcEvent265(IrcEvent *event); // RPL_LOCALUSERS - Q_INVOKABLE void processIrcEvent266(IrcEvent *event); // RPL_GLOBALUSERS - Q_INVOKABLE void processIrcEvent301(IrcEvent *event); // RPL_AWAY - Q_INVOKABLE void processIrcEvent305(IrcEvent *event); // RPL_UNAWAY - Q_INVOKABLE void processIrcEvent306(IrcEvent *event); // RPL_NOWAWAY - Q_INVOKABLE void processIrcEvent307(IrcEvent *event); // RPL_WHOISSERVICE - Q_INVOKABLE void processIrcEvent310(IrcEvent *event); // RPL_SUSERHOST - Q_INVOKABLE void processIrcEvent311(IrcEvent *event); // RPL_WHOISUSER - Q_INVOKABLE void processIrcEvent312(IrcEvent *event); // RPL_WHOISSERVER - Q_INVOKABLE void processIrcEvent313(IrcEvent *event); // RPL_WHOISOPERATOR - Q_INVOKABLE void processIrcEvent315(IrcEvent *event); // RPL_ENDOFWHO - Q_INVOKABLE void processIrcEvent317(IrcEvent *event); // RPL_WHOISIDLE - Q_INVOKABLE void processIrcEvent322(IrcEvent *event); // RPL_LIST - Q_INVOKABLE void processIrcEvent323(IrcEvent *event); // RPL_LISTEND - Q_INVOKABLE void processIrcEvent324(IrcEvent *event); // RPL_CHANNELMODEIS - Q_INVOKABLE void processIrcEvent331(IrcEvent *event); // RPL_NOTOPIC - Q_INVOKABLE void processIrcEvent332(IrcEvent *event); // RPL_TOPIC - Q_INVOKABLE void processIrcEvent352(IrcEvent *event); // RPL_WHOREPLY - Q_INVOKABLE void processIrcEvent353(IrcEvent *event); // RPL_NAMREPLY - Q_INVOKABLE void processIrcEvent432(IrcEventNumeric *event); // ERR_ERRONEUSNICKNAME - Q_INVOKABLE void processIrcEvent433(IrcEventNumeric *event); // ERR_NICKNAMEINUSE - Q_INVOKABLE void processIrcEvent437(IrcEventNumeric *event); // ERR_UNAVAILRESOURCE + Q_INVOKABLE void processIrcEvent001(IrcEventNumeric* event); // RPL_WELCOME + Q_INVOKABLE void processIrcEvent005(IrcEvent* event); // RPL_ISUPPORT + Q_INVOKABLE void processIrcEvent221(IrcEvent* event); // RPL_UMODEIS + Q_INVOKABLE void processIrcEvent250(IrcEvent* event); // RPL_STATSCONN + Q_INVOKABLE void processIrcEvent265(IrcEvent* event); // RPL_LOCALUSERS + Q_INVOKABLE void processIrcEvent266(IrcEvent* event); // RPL_GLOBALUSERS + Q_INVOKABLE void processIrcEvent301(IrcEvent* event); // RPL_AWAY + Q_INVOKABLE void processIrcEvent305(IrcEvent* event); // RPL_UNAWAY + Q_INVOKABLE void processIrcEvent306(IrcEvent* event); // RPL_NOWAWAY + Q_INVOKABLE void processIrcEvent307(IrcEvent* event); // RPL_WHOISSERVICE + Q_INVOKABLE void processIrcEvent310(IrcEvent* event); // RPL_SUSERHOST + Q_INVOKABLE void processIrcEvent311(IrcEvent* event); // RPL_WHOISUSER + Q_INVOKABLE void processIrcEvent312(IrcEvent* event); // RPL_WHOISSERVER + Q_INVOKABLE void processIrcEvent313(IrcEvent* event); // RPL_WHOISOPERATOR + Q_INVOKABLE void processIrcEvent315(IrcEvent* event); // RPL_ENDOFWHO + Q_INVOKABLE void processIrcEvent317(IrcEvent* event); // RPL_WHOISIDLE + Q_INVOKABLE void processIrcEvent322(IrcEvent* event); // RPL_LIST + Q_INVOKABLE void processIrcEvent323(IrcEvent* event); // RPL_LISTEND + Q_INVOKABLE void processIrcEvent324(IrcEvent* event); // RPL_CHANNELMODEIS + Q_INVOKABLE void processIrcEvent330(IrcEvent* event); // RPL_WHOISACCOUNT (quakenet/snircd/undernet) + Q_INVOKABLE void processIrcEvent331(IrcEvent* event); // RPL_NOTOPIC + Q_INVOKABLE void processIrcEvent332(IrcEvent* event); // RPL_TOPIC + Q_INVOKABLE void processIrcEvent352(IrcEvent* event); // RPL_WHOREPLY + Q_INVOKABLE void processIrcEvent353(IrcEvent* event); // RPL_NAMREPLY + Q_INVOKABLE void processIrcEvent354(IrcEvent* event); // RPL_WHOSPCRPL + Q_INVOKABLE void processIrcEvent403(IrcEventNumeric* event); // ERR_NOSUCHCHANNEL + Q_INVOKABLE void processIrcEvent432(IrcEventNumeric* event); // ERR_ERRONEUSNICKNAME + Q_INVOKABLE void processIrcEvent433(IrcEventNumeric* event); // ERR_NICKNAMEINUSE + Q_INVOKABLE void processIrcEvent437(IrcEventNumeric* event); // ERR_UNAVAILRESOURCE // Q_INVOKABLE void processIrcEvent(IrcEvent *event); /* CTCP handlers */ - Q_INVOKABLE void processCtcpEvent(CtcpEvent *event); + Q_INVOKABLE void processCtcpEvent(CtcpEvent* event); - Q_INVOKABLE void handleCtcpAction(CtcpEvent *event); - Q_INVOKABLE void handleCtcpClientinfo(CtcpEvent *event); - Q_INVOKABLE void handleCtcpDcc(CtcpEvent *event); - Q_INVOKABLE void handleCtcpPing(CtcpEvent *event); - Q_INVOKABLE void handleCtcpTime(CtcpEvent *event); - Q_INVOKABLE void handleCtcpVersion(CtcpEvent *event); - Q_INVOKABLE void defaultHandler(const QString &ctcpCmd, CtcpEvent *event); + Q_INVOKABLE void handleCtcpAction(CtcpEvent* event); + Q_INVOKABLE void handleCtcpClientinfo(CtcpEvent* event); + Q_INVOKABLE void handleCtcpDcc(CtcpEvent* event); + Q_INVOKABLE void handleCtcpPing(CtcpEvent* event); + Q_INVOKABLE void handleCtcpTime(CtcpEvent* event); + Q_INVOKABLE void handleCtcpVersion(CtcpEvent* event); + Q_INVOKABLE void defaultHandler(const QString& ctcpCmd, CtcpEvent* event); signals: - void newEvent(Event *event); + void newEvent(Event* event); protected: - bool checkParamCount(IrcEvent *event, int minParams); - inline CoreNetwork *coreNetwork(NetworkEvent *e) const { return qobject_cast(e->network()); } - void tryNextNick(NetworkEvent *e, const QString &errnick, bool erroneous = false); + bool checkParamCount(IrcEvent* event, int minParams); + inline CoreNetwork* coreNetwork(NetworkEvent* e) const { return qobject_cast(e->network()); } + void tryNextNick(NetworkEvent* e, const QString& errnick, bool erroneous = false); private slots: //! Joins after a netsplit /** This slot handles a bulk-join after a netsplit is over - * \param net The network - * \param channel The channel the users joined - * \param users The list of users that joind the channel - * \param modes The list of modes the users get set - * \param quitMessage The message we received when the netsplit occured - */ - void handleNetsplitJoin(Network *net, const QString &channel, const QStringList &users, const QStringList &modes, const QString &quitMessage); + * \param net The network + * \param channel The channel the users joined + * \param users The list of users that joind the channel + * \param modes The list of modes the users get set + * \param quitMessage The message we received when the netsplit occured + */ + void handleNetsplitJoin(Network* net, const QString& channel, const QStringList& users, const QStringList& modes, const QString& quitMessage); //! Quits after a netsplit /** This slot handles a bulk-quit after a netsplit occured - * \param net The network - * \param channel The channel the users quitted - * \param users The list of users that got split - * \param quitMessage The message we received when the netsplit occured - */ - void handleNetsplitQuit(Network *net, const QString &channel, const QStringList &users, const QString &quitMessage); + * \param net The network + * \param channel The channel the users quitted + * \param users The list of users that got split + * \param quitMessage The message we received when the netsplit occured + */ + void handleNetsplitQuit(Network* net, const QString& channel, const QStringList& users, const QString& quitMessage); //! Netsplit finished /** This slot deletes the netsplit object that sent the finished() signal - */ + */ void handleNetsplitFinished(); - void handleEarlyNetsplitJoin(Network *net, const QString &channel, const QStringList &users, const QStringList &modes); + void handleEarlyNetsplitJoin(Network* net, const QString& channel, const QStringList& users, const QStringList& modes); //! Destroy any existing netsplits /** This slot deletes all netsplit objects - * Used to get rid of existing netsplits on network reconnect - * \param network The network we want to clear - */ + * Used to get rid of existing netsplits on network reconnect + * \param network The network we want to clear + */ void destroyNetsplits(NetworkId network); private: - CoreSession *_coreSession; + CoreSession* _coreSession; // structure to organize netsplits // key: quit message // value: the corresponding netsplit object - QHash > _netsplits; + QHash> _netsplits; - // IRCv3 capability negotiation /** - * Sends the next capability from the queue. + * Process given WHO reply information, updating user data, channel modes, etc as needed * - * During nick registration if any capabilities remain queued, this will take the next and - * request it. When no capabilities remain, capability negotiation is ended. + * This takes information from WHO and WHOX replies, processing information that's common + * between them. * - * @param[in,out] A network currently undergoing capability negotiation + * @param[in] net Network object for the IRC server + * @param[in] targetChannel Target channel, or * if unspecified + * @param[in] ircUser IrcUser representing the desired nick + * @param[in] server Nick server name + * @param[in] user Nick username + * @param[in] host Nick hostname + * @param[in] awayStateAndModes Nick away-state and modes (e.g. G@) + * @param[in] realname Nick realname */ - void sendNextCap(Network *net); + void processWhoInformation(Network* net, + const QString& targetChannel, + IrcUser* ircUser, + const QString& server, + const QString& user, + const QString& host, + const QString& awayStateAndModes, + const QString& realname); }; - - -#endif