X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcoresession.h;h=ed9b5fea781f389e6396baefd5235d9dd7ae280f;hp=a52e03993ba5468e49c2fe7353047bb843c68568;hb=3a3e844f9fcfd12235a0086af75ecd503b621ef4;hpb=bd1a18355495899b5ce3003599a67e1ea7ca01cc;ds=sidebyside diff --git a/src/core/coresession.h b/src/core/coresession.h index a52e0399..ed9b5fea 100644 --- a/src/core/coresession.h +++ b/src/core/coresession.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-08 by the Quassel Project * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -15,174 +15,282 @@ * You should have received a copy of the GNU General Public License * * along with this program; if not, write to the * * Free Software Foundation, Inc., * - * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ -#ifndef _CORESESSION_H_ -#define _CORESESSION_H_ +#pragma once +#include +#include #include #include - +#include + +#include "coreinfo.h" +#include "corealiasmanager.h" +#include "corehighlightrulemanager.h" +#include "coreignorelistmanager.h" +#include "peer.h" +#include "protocol.h" #include "message.h" - -class BufferSyncer; -class Identity; +#include "storage.h" + +class CoreBacklogManager; +class CoreBufferSyncer; +class CoreBufferViewManager; +class CoreDccConfig; +class CoreIdentity; +class CoreIrcListHelper; +class CoreNetwork; +class CoreNetworkConfig; +class CoreSessionEventProcessor; +class CoreTransferManager; +class CtcpParser; +class EventManager; +class EventStringifier; +class InternalPeer; +class IrcParser; +class MessageEvent; class NetworkConnection; -class Network; -struct NetworkInfo; +class RemotePeer; class SignalProxy; +struct NetworkInfo; + class QScriptEngine; -class CoreSession : public QObject { - Q_OBJECT +class CoreSession : public QObject +{ + Q_OBJECT public: - CoreSession(UserId, bool restoreState, QObject *parent = 0); - ~CoreSession(); + CoreSession(UserId, bool restoreState, bool strictIdentEnabled, QObject *parent = nullptr); + + QList buffers() const; + inline UserId user() const { return _user; } + CoreNetwork *network(NetworkId) const; + CoreIdentity *identity(IdentityId) const; + + /** + * Returns the optionally strict-compliant ident for the given user identity + * + * If strict mode is enabled, this will return the user's Quassel username for any identity, + * otherwise this will return the given identity's ident, whatever it may be. + * + * @return The user's ident, compliant with strict mode (when enabled) + */ + const QString strictCompliantIdent(const CoreIdentity *identity); - QList buffers() const; - UserId user() const; - Network *network(NetworkId) const; - NetworkConnection *networkConnection(NetworkId) const; - Identity *identity(IdentityId) const; + inline CoreNetworkConfig *networkConfig() const { return _networkConfig; } + NetworkConnection *networkConnection(NetworkId) const; - QVariant sessionState(); + Protocol::SessionState sessionState() const; - SignalProxy *signalProxy() const; + inline SignalProxy *signalProxy() const { return _signalProxy; } - void attachNetworkConnection(NetworkConnection *conn); + const AliasManager &aliasManager() const { return _aliasManager; } + AliasManager &aliasManager() { return _aliasManager; } - //! Return necessary data for restoring the session after restarting the core - void saveSessionState() const; - void restoreSessionState(); + inline EventManager *eventManager() const { return _eventManager; } + inline EventStringifier *eventStringifier() const { return _eventStringifier; } + inline CoreSessionEventProcessor *sessionEventProcessor() const { return _sessionEventProcessor; } + inline CtcpParser *ctcpParser() const { return _ctcpParser; } + inline IrcParser *ircParser() const { return _ircParser; } + + inline CoreIrcListHelper *ircListHelper() const { return _ircListHelper; } + + inline CoreIgnoreListManager *ignoreListManager() { return &_ignoreListManager; } + inline HighlightRuleManager *highlightRuleManager() { return &_highlightRuleManager; } + inline CoreTransferManager *transferManager() const { return _transferManager; } + inline CoreDccConfig *dccConfig() const { return _dccConfig; } + +// void attachNetworkConnection(NetworkConnection *conn); + + //! Return necessary data for restoring the session after restarting the core + void restoreSessionState(); public slots: - void networkStateRequested(); - - void addClient(QObject *socket); - - void connectToNetwork(QString, const QVariant &previousState = QVariant()); - void connectToNetwork(NetworkId, const QVariant &previousState = QVariant()); - void disconnectFromNetwork(NetworkId id); - - //void processSignal(ClientSignal, QVariant, QVariant, QVariant); - void sendBacklog(BufferInfo, QVariant, QVariant); - void msgFromClient(BufferInfo, QString message); - - //! Create an identity and propagate the changes to the clients. - /** \param identity The identity to be created. - */ - void createIdentity(const Identity &identity); - - //! Update an identity and propagate the changes to the clients. - /** \param identity The identity to be updated. - */ - void updateIdentity(const Identity &identity); - - //! Remove identity and propagate that fact to the clients. - /** \param identity The identity to be removed. - */ - void removeIdentity(IdentityId identity); - - //! Create a network and propagate the changes to the clients. - /** \param info The network's settings. - */ - void createNetwork(const NetworkInfo &info); - - //! Update a network and propagate the changes to the clients. - /** \param info The updated network settings. - */ - void updateNetwork(const NetworkInfo &info); - - //! Remove identity and propagate that fact to the clients. - /** \param identity The identity to be removed. - */ - void removeNetwork(NetworkId network); - - //! Remove a buffer and it's backlog permanently - /** \param bufferId The id of the buffer to be removed. - * emits bufferRemoved(bufferId) on success. - */ - void removeBufferRequested(BufferId bufferId); - - //! Rename a Buffer for a given network - /* \param networkId The id of the network the buffer belongs to - * \param newName The new name of the buffer - * \param oldName The old name of the buffer - * emits bufferRenamed(bufferId, newName) on success. - */ - void renameBuffer(const NetworkId &networkId, const QString &newName, const QString &oldName); - + void addClient(RemotePeer *peer); + void addClient(InternalPeer *peer); + + /** + * Shuts down the session and deletes itself afterwards. + */ + void shutdown(); + + void msgFromClient(BufferInfo, QString message); + + //! Create an identity and propagate the changes to the clients. + /** \param identity The identity to be created. + */ + void createIdentity(const Identity &identity, const QVariantMap &additional); + void createIdentity(const CoreIdentity &identity); + + //! Remove identity and propagate that fact to the clients. + /** \param identity The identity to be removed. + */ + void removeIdentity(IdentityId identity); + + //! Create a network and propagate the changes to the clients. + /** \param info The network's settings. + */ + void createNetwork(const NetworkInfo &info, const QStringList &persistentChannels = QStringList()); + + //! Remove network and propagate that fact to the clients. + /** \param network The id of the network to be removed. + */ + void removeNetwork(NetworkId network); + + //! Rename a Buffer for a given network + /* \param networkId The id of the network the buffer belongs to + * \param newName The new name of the buffer + * \param oldName The old name of the buffer + */ + void renameBuffer(const NetworkId &networkId, const QString &newName, const QString &oldName); + + void changePassword(PeerPtr peer, const QString &userName, const QString &oldPassword, const QString &newPassword); + + void kickClient(int peerId); + + QHash persistentChannels(NetworkId) const; + + QHash bufferCiphers(NetworkId id) const; + void setBufferCipher(NetworkId id, const QString &bufferName, const QByteArray &cipher) const; + + /** + * Marks us away (or unaway) on all networks + * + * @param[in] msg Away message, or blank to set unaway + * @param[in] skipFormatting If true, skip timestamp formatting codes (e.g. if already done) + */ + void globalAway(const QString &msg = QString(), const bool skipFormatting = false); + signals: - void initialized(); + void initialized(); + void sessionState(const Protocol::SessionState &sessionState); - //void msgFromGui(uint netid, QString buf, QString message); - void displayMsg(Message message); - void displayStatusMsg(QString, QString); + //void msgFromGui(uint netid, QString buf, QString message); + void displayMsg(Message message); + void displayStatusMsg(QString, QString); - //void connectToIrc(QString net); - //void disconnectFromIrc(QString net); + void scriptResult(QString result); - void backlogData(BufferInfo, QVariantList, bool done); + //! Identity has been created. + /** This signal is propagated to the clients to tell them that the given identity has been created. + * \param identity The new identity. + */ + void identityCreated(const Identity &identity); - void bufferInfoUpdated(BufferInfo); + //! Identity has been removed. + /** This signal is propagated to the clients to inform them about the removal of the given identity. + * \param identity The identity that has been removed. + */ + void identityRemoved(IdentityId identity); - void scriptResult(QString result); + void networkCreated(NetworkId); + void networkRemoved(NetworkId); + void networkDisconnected(NetworkId); - //! Identity has been created. - /** This signal is propagated to the clients to tell them that the given identity has been created. - * \param identity The new identity. - */ - void identityCreated(const Identity &identity); + void passwordChanged(PeerPtr peer, bool success); - //! Identity has been removed. - /** This signal is propagated to the clients to inform them about the removal of the given identity. - * \param identity The identity that has been removed. - */ - void identityRemoved(IdentityId identity); + void disconnectFromCore(); - void networkCreated(NetworkId); - void networkRemoved(NetworkId); - void bufferRemoved(BufferId); - void bufferRenamed(BufferId, QString); +protected: + void customEvent(QEvent *event) override; private slots: - void recvStatusMsgFromServer(QString msg); - void recvMessageFromServer(Message::Type, BufferInfo::Type, QString target, QString text, QString sender = "", quint8 flags = Message::None); - void networkConnected(NetworkId networkid); - void networkDisconnected(NetworkId networkid); + void removeClient(Peer *peer); - void destroyNetwork(NetworkId); + void recvStatusMsgFromServer(QString msg); + void recvMessageFromServer(NetworkId networkId, Message::Type, BufferInfo::Type, const QString &target, const QString &text, const QString &sender = "", Message::Flags flags = Message::None); - //! Called when storage updated a BufferInfo. - /** This emits bufferInfoUpdated() via SignalProxy, iff it's one of our buffers. - * \param user The buffer's owner (not necessarily us) - * \param bufferInfo The updated BufferInfo - */ - void updateBufferInfo(UserId user, const BufferInfo &bufferInfo); + void destroyNetwork(NetworkId); - void storeBufferLastSeen(BufferId buffer, const QDateTime &lastSeen); + void scriptRequest(QString script); - void scriptRequest(QString script); + void clientsConnected(); + void clientsDisconnected(); -private: - void loadSettings(); - void initScriptEngine(); + void updateIdentityBySender(); - UserId _user; + void saveSessionState() const; - SignalProxy *_signalProxy; - QHash _connections; - QHash _networks; - QHash _networksToRemove; - QHash _identities; + void onNetworkDisconnected(NetworkId networkId); - BufferSyncer *_bufferSyncer; +private: + void processMessages(); + + void loadSettings(); + void initScriptEngine(); + + /// Hook for converting events to the old displayMsg() handlers + Q_INVOKABLE void processMessageEvent(MessageEvent *event); + + UserId _user; + + /// Whether or not strict ident mode is enabled, locking users' idents to Quassel username + bool _strictIdentEnabled; + + SignalProxy *_signalProxy; + CoreAliasManager _aliasManager; + + QHash _identities; + QHash _networks; + QSet _networksPendingDisconnect; + + CoreBufferSyncer *_bufferSyncer; + CoreBacklogManager *_backlogManager; + CoreBufferViewManager *_bufferViewManager; + CoreDccConfig *_dccConfig; + CoreIrcListHelper *_ircListHelper; + CoreNetworkConfig *_networkConfig; + CoreInfo *_coreInfo; + CoreTransferManager *_transferManager; + + EventManager *_eventManager; + EventStringifier *_eventStringifier; // should eventually move into client + CoreSessionEventProcessor *_sessionEventProcessor; + CtcpParser *_ctcpParser; + IrcParser *_ircParser; + + QScriptEngine *scriptEngine; + + /** + * This method obtains the prefixes of the message's sender within a channel, by looking up their channelmodes, and + * processing them to prefixes based on the network's settings. + * @param sender The hostmask of the sender + * @param bufferInfo The BufferInfo object of the buffer + */ + QString senderPrefixes(const QString &sender, const BufferInfo &bufferInfo) const; + + /** + * This method obtains the realname of the message's sender. + * @param sender The hostmask of the sender + * @param networkId The network the user is on + */ + QString realName(const QString &sender, NetworkId networkId) const; + + /** + * This method obtains the avatar of the message's sender. + * @param sender The hostmask of the sender + * @param networkId The network the user is on + */ + QString avatarUrl(const QString &sender, NetworkId networkId) const; + QList _messageQueue; + bool _processMessages; + CoreIgnoreListManager _ignoreListManager; + CoreHighlightRuleManager _highlightRuleManager; +}; - QScriptEngine *scriptEngine; +struct RawMessage { + NetworkId networkId; + Message::Type type; + BufferInfo::Type bufferType; + QString target; + QString text; + QString sender; + Message::Flags flags; + RawMessage(NetworkId networkId, Message::Type type, BufferInfo::Type bufferType, QString target, QString text, QString sender, Message::Flags flags) + : networkId(networkId), type(type), bufferType(bufferType), target(std::move(target)), text(std::move(text)), sender(std::move(sender)), flags(flags) {} }; - -#endif