X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcoresession.h;h=3f36497bb16fc1a7a84b6cc9084225fa1376c17b;hp=0e183151d4a0c517b4a668dd655f9d1ed38dca52;hb=86837eac3346857733f3488acccca9dc2c45605e;hpb=d6b056e936ec441258d291b7a8af7b83f9f53016 diff --git a/src/core/coresession.h b/src/core/coresession.h index 0e183151..3f36497b 100644 --- a/src/core/coresession.h +++ b/src/core/coresession.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-07 by the Quassel IRC Team * + * Copyright (C) 2005-09 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,81 +18,194 @@ * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ -#ifndef _CORESESSION_H_ -#define _CORESESSION_H_ +#ifndef CORESESSION_H +#define CORESESSION_H -#include #include #include +#include "corecoreinfo.h" +#include "corealiasmanager.h" +#include "coreignorelistmanager.h" #include "message.h" +#include "storage.h" -class Server; +class CoreBacklogManager; +class CoreBufferSyncer; +class CoreBufferViewManager; +class CoreIdentity; +class CoreIrcListHelper; +class CoreNetwork; +class CoreNetworkConfig; +class CoreSessionEventProcessor; +class EventManager; +class IrcParser; +class NetworkConnection; class SignalProxy; -class Storage; + +struct NetworkInfo; + +class QScriptEngine; class CoreSession : public QObject { Q_OBJECT public: - CoreSession(UserId, Storage *, QObject *parent = 0); - virtual ~CoreSession(); + CoreSession(UserId, bool restoreState, QObject *parent = 0); + ~CoreSession(); - uint getNetworkId(const QString &network) const; QList buffers() const; - UserId userId() const; + inline UserId user() const { return _user; } + CoreNetwork *network(NetworkId) const; + CoreIdentity *identity(IdentityId) const; + inline CoreNetworkConfig *networkConfig() const { return _networkConfig; } + NetworkConnection *networkConnection(NetworkId) const; + QVariant sessionState(); - //! Retrieve a piece of session-wide data. - QVariant retrieveSessionData(const QString &key, const QVariant &def = QVariant()); - - SignalProxy *signalProxy() const; - - void attachServer(Server *server); - + inline SignalProxy *signalProxy() const { return _signalProxy; } + + const AliasManager &aliasManager() const { return _aliasManager; } + AliasManager &aliasManager() { return _aliasManager; } + + inline EventManager *eventManager() const { return _eventManager; } + inline CoreSessionEventProcessor *eventProcessor() const { return _eventProcessor; } + inline IrcParser *ircParser() const { return _ircParser; } + + inline CoreIrcListHelper *ircListHelper() const { return _ircListHelper; } + + inline CoreIgnoreListManager *ignoreListManager() { return &_ignoreListManager; } +// void attachNetworkConnection(NetworkConnection *conn); + + //! Return necessary data for restoring the session after restarting the core + void restoreSessionState(); + public slots: - //! Store a piece session-wide data and distribute it to connected clients. - void storeSessionData(const QString &key, const QVariant &data); - - void serverStateRequested(); - - void addClient(QIODevice *connection); - - void connectToNetwork(QString); - - //void processSignal(ClientSignal, QVariant, QVariant, QVariant); - void sendBacklog(BufferInfo, QVariant, QVariant); - void msgFromGui(BufferInfo, QString message); - + void addClient(QIODevice *device); + void addClient(SignalProxy *proxy); + + 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); + + QHash persistentChannels(NetworkId) const; + + //! Marks us away (or unaway) on all networks + void globalAway(const QString &msg = QString()); + signals: - void msgFromGui(uint netid, QString buf, QString message); + void initialized(); + void sessionState(const QVariant &); + + //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 backlogData(BufferInfo, QVariantList, bool done); + void scriptResult(QString result); + + //! 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); + + //! 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 bufferInfoUpdated(BufferInfo); - void sessionDataChanged(const QString &key); - void sessionDataChanged(const QString &key, const QVariant &data); + void networkCreated(NetworkId); + void networkRemoved(NetworkId); private slots: + void removeClient(QIODevice *dev); + void recvStatusMsgFromServer(QString msg); - void recvMessageFromServer(Message::Type, QString target, QString text, QString sender = "", quint8 flags = Message::None); - void serverConnected(uint networkid); - void serverDisconnected(uint networkid); + void recvMessageFromServer(NetworkId networkId, Message::Type, BufferInfo::Type, const QString &target, const QString &text, const QString &sender = "", Message::Flags flags = Message::None); + + void destroyNetwork(NetworkId); + + void scriptRequest(QString script); + + void clientsConnected(); + void clientsDisconnected(); + + void updateIdentityBySender(); + + void saveSessionState() const; + +protected: + virtual void customEvent(QEvent *event); private: - UserId user; - + void loadSettings(); + void initScriptEngine(); + void processMessages(); + + UserId _user; + SignalProxy *_signalProxy; - Storage *storage; - QHash servers; - - QVariantMap sessionData; - QMutex mutex; + CoreAliasManager _aliasManager; + // QHash _connections; + QHash _networks; + // QHash _networksToRemove; + QHash _identities; + + CoreBufferSyncer *_bufferSyncer; + CoreBacklogManager *_backlogManager; + CoreBufferViewManager *_bufferViewManager; + CoreIrcListHelper *_ircListHelper; + CoreNetworkConfig *_networkConfig; + CoreCoreInfo _coreInfo; + + EventManager *_eventManager; + CoreSessionEventProcessor *_eventProcessor; + IrcParser *_ircParser; + + QScriptEngine *scriptEngine; + + QList _messageQueue; + bool _processMessages; + CoreIgnoreListManager _ignoreListManager; +}; + +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, const QString &target, const QString &text, const QString &sender, Message::Flags flags) + : networkId(networkId), type(type), bufferType(bufferType), target(target), text(text), sender(sender), flags(flags) {} }; #endif