1 /***************************************************************************
2 * Copyright (C) 2005-2013 by the Quassel Project *
3 * devel@quassel-irc.org *
5 * This program is free software; you can redistribute it and/or modify *
6 * it under the terms of the GNU General Public License as published by *
7 * the Free Software Foundation; either version 2 of the License, or *
8 * (at your option) version 3. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the *
17 * Free Software Foundation, Inc., *
18 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
19 ***************************************************************************/
21 #ifndef CORECONNECTION_H_
22 #define CORECONNECTION_H_
24 // TODO: support system application proxy (new in Qt 4.6)
30 # include <QSslSocket>
32 # include <QTcpSocket>
36 # include <Solid/Networking>
39 #include "coreaccount.h"
40 #include "remotepeer.h"
43 class CoreAccountModel;
48 class CoreConnection : public QObject
53 enum ConnectionState {
61 CoreConnection(CoreAccountModel *model, QObject *parent = 0);
65 bool isConnected() const;
66 ConnectionState state() const;
67 CoreAccount currentAccount() const;
69 bool isEncrypted() const;
70 bool isLocalConnection() const;
72 int progressMinimum() const;
73 int progressMaximum() const;
74 int progressValue() const;
75 QString progressText() const;
77 //! Check if we consider the last connect as reconnect
78 bool wasReconnect() const { return _wasReconnect; }
81 const QSslSocket *sslSocket() const;
85 bool connectToCore(AccountId = 0);
86 void reconnectToCore();
87 void disconnectFromCore();
90 void stateChanged(CoreConnection::ConnectionState);
91 void encrypted(bool isEncrypted = true);
93 void lagUpdated(int msecs);
95 void connectionError(const QString &errorMsg);
96 void connectionErrorPopup(const QString &errorMsg);
97 void connectionWarnings(const QStringList &warnings);
98 void connectionMsg(const QString &msg);
101 void progressRangeChanged(int minimum, int maximum);
102 void progressValueChanged(int value);
103 void progressTextChanged(const QString &);
105 void startCoreSetup(const QVariantList &);
106 void coreSetupSuccess();
107 void coreSetupFailed(const QString &error);
109 void startInternalCore();
110 void connectToInternalCore(InternalPeer *connection);
112 // These signals MUST be handled synchronously!
113 void userAuthenticationRequired(CoreAccount *, bool *valid, const QString &errorMessage = QString());
114 void handleNoSslInClient(bool *accepted);
115 void handleNoSslInCore(bool *accepted);
117 void handleSslErrors(const QSslSocket *socket, bool *accepted, bool *permanently);
121 void connectToCurrentAccount();
122 void disconnectFromCore(const QString &errorString, bool wantReconnect = true);
124 void socketStateChanged(QAbstractSocket::SocketState);
125 void coreSocketError(QAbstractSocket::SocketError);
126 void coreHasData(const QVariant &item);
127 void coreSocketConnected();
128 void coreSocketDisconnected();
130 void clientInitAck(const QVariantMap &msg);
133 void networkInitDone();
134 void checkSyncState();
136 void syncToCore(const QVariantMap &sessionState);
137 void internalSessionStateReceived(const QVariant &packedState);
138 void sessionStateReceived(const QVariantMap &state);
140 void resetConnection(bool wantReconnect = false);
141 void connectionReady();
143 void loginToCore(const QString &user, const QString &password, bool remember); // for config wizard
144 void loginToCore(const QString &previousError = QString());
146 void loginFailed(const QString &errorMessage);
148 void doCoreSetup(const QVariant &setupData);
150 void updateProgress(int value, int maximum);
151 void setProgressText(const QString &text);
152 void setProgressValue(int value);
153 void setProgressMinimum(int minimum);
154 void setProgressMaximum(int maximum);
156 void setState(QAbstractSocket::SocketState socketState);
157 void setState(ConnectionState state);
160 void sslSocketEncrypted();
164 void networkDetectionModeChanged(const QVariant &mode);
165 void pingTimeoutIntervalChanged(const QVariant &interval);
166 void reconnectIntervalChanged(const QVariant &interval);
167 void reconnectTimeout();
170 void solidNetworkStatusChanged(Solid::Networking::Status status);
174 CoreAccountModel *_model;
175 CoreAccount _account;
176 QVariantMap _coreMsgBuffer;
178 QPointer<QTcpSocket> _socket;
179 QPointer<SignalProxy::AbstractPeer> _peer;
180 ConnectionState _state;
182 QTimer _reconnectTimer;
185 QSet<QObject *> _netsToSync;
187 int _progressMinimum, _progressMaximum, _progressValue;
188 QString _progressText;
190 QString _coreInfoString(const QVariantMap &);
192 bool _requestedDisconnect;
195 inline CoreAccountModel *accountModel() const;
197 friend class CoreConfigWizard;
201 Q_DECLARE_METATYPE(CoreConnection::ConnectionState)
204 inline int CoreConnection::progressMinimum() const { return _progressMinimum; }
205 inline int CoreConnection::progressMaximum() const { return _progressMaximum; }
206 inline int CoreConnection::progressValue() const { return _progressValue; }
207 inline QString CoreConnection::progressText() const { return _progressText; }
209 inline CoreConnection::ConnectionState CoreConnection::state() const { return _state; }
210 inline bool CoreConnection::isConnected() const { return state() >= Connected; }
211 inline CoreAccount CoreConnection::currentAccount() const { return _account; }
212 inline CoreAccountModel *CoreConnection::accountModel() const { return _model; }
215 inline const QSslSocket *CoreConnection::sslSocket() const { return qobject_cast<QSslSocket *>(_socket); }