Hide or disable the Change Password option when appropriate
[quassel.git] / src / client / client.cpp
1 /***************************************************************************
2  *   Copyright (C) 2005-2015 by the Quassel Project                        *
3  *   devel@quassel-irc.org                                                 *
4  *                                                                         *
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.                                           *
9  *                                                                         *
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.                          *
14  *                                                                         *
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  ***************************************************************************/
20
21 #include "client.h"
22
23 #include "abstractmessageprocessor.h"
24 #include "abstractui.h"
25 #include "bufferinfo.h"
26 #include "buffermodel.h"
27 #include "buffersettings.h"
28 #include "buffersyncer.h"
29 #include "bufferviewconfig.h"
30 #include "bufferviewoverlay.h"
31 #include "clientaliasmanager.h"
32 #include "clientbacklogmanager.h"
33 #include "clientbufferviewmanager.h"
34 #include "clientirclisthelper.h"
35 #include "clientidentity.h"
36 #include "clientignorelistmanager.h"
37 #include "clienttransfermanager.h"
38 #include "clientuserinputhandler.h"
39 #include "coreaccountmodel.h"
40 #include "coreconnection.h"
41 #include "ircchannel.h"
42 #include "ircuser.h"
43 #include "message.h"
44 #include "messagemodel.h"
45 #include "network.h"
46 #include "networkconfig.h"
47 #include "networkmodel.h"
48 #include "quassel.h"
49 #include "signalproxy.h"
50 #include "util.h"
51 #include "clientauthhandler.h"
52
53 #include <stdio.h>
54 #include <stdlib.h>
55
56 QPointer<Client> Client::instanceptr = 0;
57 Quassel::Features Client::_coreFeatures = 0;
58
59 /*** Initialization/destruction ***/
60
61 bool Client::instanceExists()
62 {
63     return instanceptr;
64 }
65
66
67 Client *Client::instance()
68 {
69     if (!instanceptr)
70         instanceptr = new Client();
71     return instanceptr;
72 }
73
74
75 void Client::destroy()
76 {
77     if (instanceptr) {
78         delete instanceptr->mainUi();
79         instanceptr->deleteLater();
80         instanceptr = 0;
81     }
82 }
83
84
85 void Client::init(AbstractUi *ui)
86 {
87     instance()->_mainUi = ui;
88     instance()->init();
89 }
90
91
92 Client::Client(QObject *parent)
93     : QObject(parent),
94     _signalProxy(new SignalProxy(SignalProxy::Client, this)),
95     _mainUi(0),
96     _networkModel(0),
97     _bufferModel(0),
98     _bufferSyncer(0),
99     _aliasManager(0),
100     _backlogManager(new ClientBacklogManager(this)),
101     _bufferViewManager(0),
102     _bufferViewOverlay(new BufferViewOverlay(this)),
103     _ircListHelper(new ClientIrcListHelper(this)),
104     _inputHandler(0),
105     _networkConfig(0),
106     _ignoreListManager(0),
107     _transferManager(0),
108     _messageModel(0),
109     _messageProcessor(0),
110     _coreAccountModel(new CoreAccountModel(this)),
111     _coreConnection(new CoreConnection(this)),
112     _connected(false),
113     _debugLog(&_debugLogBuffer)
114 {
115     _signalProxy->synchronize(_ircListHelper);
116 }
117
118
119 Client::~Client()
120 {
121     disconnectFromCore();
122 }
123
124
125 void Client::init()
126 {
127     _networkModel = new NetworkModel(this);
128
129     connect(this, SIGNAL(networkRemoved(NetworkId)),
130         _networkModel, SLOT(networkRemoved(NetworkId)));
131
132     _bufferModel = new BufferModel(_networkModel);
133     _messageModel = mainUi()->createMessageModel(this);
134     _messageProcessor = mainUi()->createMessageProcessor(this);
135     _inputHandler = new ClientUserInputHandler(this);
136
137     SignalProxy *p = signalProxy();
138
139     p->attachSlot(SIGNAL(displayMsg(const Message &)), this, SLOT(recvMessage(const Message &)));
140     p->attachSlot(SIGNAL(displayStatusMsg(QString, QString)), this, SLOT(recvStatusMsg(QString, QString)));
141
142     p->attachSlot(SIGNAL(bufferInfoUpdated(BufferInfo)), _networkModel, SLOT(bufferUpdated(BufferInfo)));
143     p->attachSignal(inputHandler(), SIGNAL(sendInput(BufferInfo, QString)));
144     p->attachSignal(this, SIGNAL(requestNetworkStates()));
145
146     p->attachSignal(this, SIGNAL(requestCreateIdentity(const Identity &, const QVariantMap &)), SIGNAL(createIdentity(const Identity &, const QVariantMap &)));
147     p->attachSignal(this, SIGNAL(requestRemoveIdentity(IdentityId)), SIGNAL(removeIdentity(IdentityId)));
148     p->attachSlot(SIGNAL(identityCreated(const Identity &)), this, SLOT(coreIdentityCreated(const Identity &)));
149     p->attachSlot(SIGNAL(identityRemoved(IdentityId)), this, SLOT(coreIdentityRemoved(IdentityId)));
150
151     p->attachSignal(this, SIGNAL(requestCreateNetwork(const NetworkInfo &, const QStringList &)), SIGNAL(createNetwork(const NetworkInfo &, const QStringList &)));
152     p->attachSignal(this, SIGNAL(requestRemoveNetwork(NetworkId)), SIGNAL(removeNetwork(NetworkId)));
153     p->attachSlot(SIGNAL(networkCreated(NetworkId)), this, SLOT(coreNetworkCreated(NetworkId)));
154     p->attachSlot(SIGNAL(networkRemoved(NetworkId)), this, SLOT(coreNetworkRemoved(NetworkId)));
155
156     //connect(mainUi(), SIGNAL(connectToCore(const QVariantMap &)), this, SLOT(connectToCore(const QVariantMap &)));
157     connect(mainUi(), SIGNAL(disconnectFromCore()), this, SLOT(disconnectFromCore()));
158     connect(this, SIGNAL(connected()), mainUi(), SLOT(connectedToCore()));
159     connect(this, SIGNAL(disconnected()), mainUi(), SLOT(disconnectedFromCore()));
160
161     // attach backlog manager
162     p->synchronize(backlogManager());
163     connect(backlogManager(), SIGNAL(messagesReceived(BufferId, int)), _messageModel, SLOT(messagesReceived(BufferId, int)));
164
165     coreAccountModel()->load();
166
167     connect(coreConnection(), SIGNAL(stateChanged(CoreConnection::ConnectionState)), SLOT(connectionStateChanged(CoreConnection::ConnectionState)));
168     coreConnection()->init();
169 }
170
171
172 /*** public static methods ***/
173
174 AbstractUi *Client::mainUi()
175 {
176     return instance()->_mainUi;
177 }
178
179
180 void Client::setCoreFeatures(Quassel::Features features)
181 {
182     _coreFeatures = features;
183 }
184
185
186 bool Client::isConnected()
187 {
188     return instance()->_connected;
189 }
190
191
192 bool Client::internalCore()
193 {
194     return currentCoreAccount().isInternal();
195 }
196
197
198 /*** Network handling ***/
199
200 QList<NetworkId> Client::networkIds()
201 {
202     return instance()->_networks.keys();
203 }
204
205
206 const Network *Client::network(NetworkId networkid)
207 {
208     if (instance()->_networks.contains(networkid)) return instance()->_networks[networkid];
209     else return 0;
210 }
211
212
213 void Client::createNetwork(const NetworkInfo &info, const QStringList &persistentChannels)
214 {
215     emit instance()->requestCreateNetwork(info, persistentChannels);
216 }
217
218
219 void Client::removeNetwork(NetworkId id)
220 {
221     emit instance()->requestRemoveNetwork(id);
222 }
223
224
225 void Client::updateNetwork(const NetworkInfo &info)
226 {
227     Network *netptr = instance()->_networks.value(info.networkId, 0);
228     if (!netptr) {
229         qWarning() << "Update for unknown network requested:" << info;
230         return;
231     }
232     netptr->requestSetNetworkInfo(info);
233 }
234
235
236 void Client::addNetwork(Network *net)
237 {
238     net->setProxy(signalProxy());
239     signalProxy()->synchronize(net);
240     networkModel()->attachNetwork(net);
241     connect(net, SIGNAL(destroyed()), instance(), SLOT(networkDestroyed()));
242     instance()->_networks[net->networkId()] = net;
243     emit instance()->networkCreated(net->networkId());
244 }
245
246
247 void Client::coreNetworkCreated(NetworkId id)
248 {
249     if (_networks.contains(id)) {
250         qWarning() << "Creation of already existing network requested!";
251         return;
252     }
253     Network *net = new Network(id, this);
254     addNetwork(net);
255 }
256
257
258 void Client::coreNetworkRemoved(NetworkId id)
259 {
260     if (!_networks.contains(id))
261         return;
262     Network *net = _networks.take(id);
263     emit networkRemoved(net->networkId());
264     net->deleteLater();
265 }
266
267
268 /*** Identity handling ***/
269
270 QList<IdentityId> Client::identityIds()
271 {
272     return instance()->_identities.keys();
273 }
274
275
276 const Identity *Client::identity(IdentityId id)
277 {
278     if (instance()->_identities.contains(id)) return instance()->_identities[id];
279     else return 0;
280 }
281
282
283 void Client::createIdentity(const CertIdentity &id)
284 {
285     QVariantMap additional;
286 #ifdef HAVE_SSL
287     additional["KeyPem"] = id.sslKey().toPem();
288     additional["CertPem"] = id.sslCert().toPem();
289 #endif
290     emit instance()->requestCreateIdentity(id, additional);
291 }
292
293
294 void Client::updateIdentity(IdentityId id, const QVariantMap &ser)
295 {
296     Identity *idptr = instance()->_identities.value(id, 0);
297     if (!idptr) {
298         qWarning() << "Update for unknown identity requested:" << id;
299         return;
300     }
301     idptr->requestUpdate(ser);
302 }
303
304
305 void Client::removeIdentity(IdentityId id)
306 {
307     emit instance()->requestRemoveIdentity(id);
308 }
309
310
311 void Client::coreIdentityCreated(const Identity &other)
312 {
313     if (!_identities.contains(other.id())) {
314         Identity *identity = new Identity(other, this);
315         _identities[other.id()] = identity;
316         identity->setInitialized();
317         signalProxy()->synchronize(identity);
318         emit identityCreated(other.id());
319     }
320     else {
321         qWarning() << tr("Identity already exists in client!");
322     }
323 }
324
325
326 void Client::coreIdentityRemoved(IdentityId id)
327 {
328     if (_identities.contains(id)) {
329         emit identityRemoved(id);
330         Identity *i = _identities.take(id);
331         i->deleteLater();
332     }
333 }
334
335
336 /*** User input handling ***/
337
338 void Client::userInput(const BufferInfo &bufferInfo, const QString &message)
339 {
340     // we need to make sure that AliasManager is ready before processing input
341     if (aliasManager() && aliasManager()->isInitialized())
342         inputHandler()->handleUserInput(bufferInfo, message);
343     else
344         instance()->_userInputBuffer.append(qMakePair(bufferInfo, message));
345 }
346
347
348 void Client::sendBufferedUserInput()
349 {
350     for (int i = 0; i < _userInputBuffer.count(); i++)
351         userInput(_userInputBuffer.at(i).first, _userInputBuffer.at(i).second);
352
353     _userInputBuffer.clear();
354 }
355
356
357 /*** core connection stuff ***/
358
359 void Client::connectionStateChanged(CoreConnection::ConnectionState state)
360 {
361     switch (state) {
362     case CoreConnection::Disconnected:
363         setDisconnectedFromCore();
364         break;
365     case CoreConnection::Synchronized:
366         setSyncedToCore();
367         break;
368     default:
369         break;
370     }
371 }
372
373
374 void Client::setSyncedToCore()
375 {
376     // create buffersyncer
377     Q_ASSERT(!_bufferSyncer);
378     _bufferSyncer = new BufferSyncer(this);
379     connect(bufferSyncer(), SIGNAL(lastSeenMsgSet(BufferId, MsgId)), _networkModel, SLOT(setLastSeenMsgId(BufferId, MsgId)));
380     connect(bufferSyncer(), SIGNAL(markerLineSet(BufferId, MsgId)), _networkModel, SLOT(setMarkerLineMsgId(BufferId, MsgId)));
381     connect(bufferSyncer(), SIGNAL(bufferRemoved(BufferId)), this, SLOT(bufferRemoved(BufferId)));
382     connect(bufferSyncer(), SIGNAL(bufferRenamed(BufferId, QString)), this, SLOT(bufferRenamed(BufferId, QString)));
383     connect(bufferSyncer(), SIGNAL(buffersPermanentlyMerged(BufferId, BufferId)), this, SLOT(buffersPermanentlyMerged(BufferId, BufferId)));
384     connect(bufferSyncer(), SIGNAL(buffersPermanentlyMerged(BufferId, BufferId)), _messageModel, SLOT(buffersPermanentlyMerged(BufferId, BufferId)));
385     connect(bufferSyncer(), SIGNAL(bufferMarkedAsRead(BufferId)), SIGNAL(bufferMarkedAsRead(BufferId)));
386     connect(networkModel(), SIGNAL(requestSetLastSeenMsg(BufferId, MsgId)), bufferSyncer(), SLOT(requestSetLastSeenMsg(BufferId, const MsgId &)));
387
388     SignalProxy *p = signalProxy();
389
390     if ((Client::coreFeatures() & Quassel::PasswordChange)) {
391         p->attachSignal(this, SIGNAL(clientChangePassword(QString)));
392     }
393
394     p->synchronize(bufferSyncer());
395
396     // create a new BufferViewManager
397     Q_ASSERT(!_bufferViewManager);
398     _bufferViewManager = new ClientBufferViewManager(p, this);
399     connect(_bufferViewManager, SIGNAL(initDone()), _bufferViewOverlay, SLOT(restore()));
400
401     // create AliasManager
402     Q_ASSERT(!_aliasManager);
403     _aliasManager = new ClientAliasManager(this);
404     connect(aliasManager(), SIGNAL(initDone()), SLOT(sendBufferedUserInput()));
405     p->synchronize(aliasManager());
406
407     // create NetworkConfig
408     Q_ASSERT(!_networkConfig);
409     _networkConfig = new NetworkConfig("GlobalNetworkConfig", this);
410     p->synchronize(networkConfig());
411
412     // create IgnoreListManager
413     Q_ASSERT(!_ignoreListManager);
414     _ignoreListManager = new ClientIgnoreListManager(this);
415     p->synchronize(ignoreListManager());
416
417     Q_ASSERT(!_transferManager);
418     _transferManager = new ClientTransferManager(this);
419     p->synchronize(transferManager());
420
421     // trigger backlog request once all active bufferviews are initialized
422     connect(bufferViewOverlay(), SIGNAL(initDone()), this, SLOT(requestInitialBacklog()));
423
424     _connected = true;
425     emit connected();
426     emit coreConnectionStateChanged(true);
427 }
428
429
430 void Client::requestInitialBacklog()
431 {
432     // usually it _should_ take longer until the bufferViews are initialized, so that's what
433     // triggers this slot. But we have to make sure that we know all buffers yet.
434     // so we check the BufferSyncer and in case it wasn't initialized we wait for that instead
435     if (!bufferSyncer()->isInitialized()) {
436         disconnect(bufferViewOverlay(), SIGNAL(initDone()), this, SLOT(requestInitialBacklog()));
437         connect(bufferSyncer(), SIGNAL(initDone()), this, SLOT(requestInitialBacklog()));
438         return;
439     }
440     disconnect(bufferViewOverlay(), SIGNAL(initDone()), this, SLOT(requestInitialBacklog()));
441     disconnect(bufferSyncer(), SIGNAL(initDone()), this, SLOT(requestInitialBacklog()));
442
443     _backlogManager->requestInitialBacklog();
444 }
445
446
447 void Client::disconnectFromCore()
448 {
449     if (!coreConnection()->isConnected())
450         return;
451
452     coreConnection()->disconnectFromCore();
453 }
454
455
456 void Client::setDisconnectedFromCore()
457 {
458     _connected = false;
459     _coreFeatures = 0;
460
461     emit disconnected();
462     emit coreConnectionStateChanged(false);
463
464     backlogManager()->reset();
465     messageProcessor()->reset();
466
467     // Clear internal data. Hopefully nothing relies on it at this point.
468
469     if (_bufferSyncer) {
470         _bufferSyncer->deleteLater();
471         _bufferSyncer = 0;
472     }
473
474     if (_bufferViewManager) {
475         _bufferViewManager->deleteLater();
476         _bufferViewManager = 0;
477     }
478
479     _bufferViewOverlay->reset();
480
481     if (_aliasManager) {
482         _aliasManager->deleteLater();
483         _aliasManager = 0;
484     }
485
486     if (_ignoreListManager) {
487         _ignoreListManager->deleteLater();
488         _ignoreListManager = 0;
489     }
490
491     if (_transferManager) {
492         _transferManager->deleteLater();
493         _transferManager = 0;
494     }
495
496     // we probably don't want to save pending input for reconnect
497     _userInputBuffer.clear();
498
499     _messageModel->clear();
500     _networkModel->clear();
501
502     QHash<NetworkId, Network *>::iterator netIter = _networks.begin();
503     while (netIter != _networks.end()) {
504         Network *net = netIter.value();
505         emit networkRemoved(net->networkId());
506         disconnect(net, SIGNAL(destroyed()), this, 0);
507         netIter = _networks.erase(netIter);
508         net->deleteLater();
509     }
510     Q_ASSERT(_networks.isEmpty());
511
512     QHash<IdentityId, Identity *>::iterator idIter = _identities.begin();
513     while (idIter != _identities.end()) {
514         emit identityRemoved(idIter.key());
515         Identity *id = idIter.value();
516         idIter = _identities.erase(idIter);
517         id->deleteLater();
518     }
519     Q_ASSERT(_identities.isEmpty());
520
521     if (_networkConfig) {
522         _networkConfig->deleteLater();
523         _networkConfig = 0;
524     }
525 }
526
527
528 /*** ***/
529
530 void Client::networkDestroyed()
531 {
532     Network *net = static_cast<Network *>(sender());
533     QHash<NetworkId, Network *>::iterator netIter = _networks.begin();
534     while (netIter != _networks.end()) {
535         if (*netIter == net) {
536             netIter = _networks.erase(netIter);
537             break;
538         }
539         else {
540             netIter++;
541         }
542     }
543 }
544
545
546 // Hmm... we never used this...
547 void Client::recvStatusMsg(QString /*net*/, QString /*msg*/)
548 {
549     //recvMessage(net, Message::server("", QString("[STATUS] %1").arg(msg)));
550 }
551
552
553 void Client::recvMessage(const Message &msg)
554 {
555     Message msg_ = msg;
556     messageProcessor()->process(msg_);
557 }
558
559
560 void Client::setBufferLastSeenMsg(BufferId id, const MsgId &msgId)
561 {
562     if (bufferSyncer())
563         bufferSyncer()->requestSetLastSeenMsg(id, msgId);
564 }
565
566
567 void Client::setMarkerLine(BufferId id, const MsgId &msgId)
568 {
569     if (bufferSyncer())
570         bufferSyncer()->requestSetMarkerLine(id, msgId);
571 }
572
573
574 MsgId Client::markerLine(BufferId id)
575 {
576     if (id.isValid() && networkModel())
577         return networkModel()->markerLineMsgId(id);
578     return MsgId();
579 }
580
581
582 void Client::removeBuffer(BufferId id)
583 {
584     if (!bufferSyncer()) return;
585     bufferSyncer()->requestRemoveBuffer(id);
586 }
587
588
589 void Client::renameBuffer(BufferId bufferId, const QString &newName)
590 {
591     if (!bufferSyncer())
592         return;
593     bufferSyncer()->requestRenameBuffer(bufferId, newName);
594 }
595
596
597 void Client::mergeBuffersPermanently(BufferId bufferId1, BufferId bufferId2)
598 {
599     if (!bufferSyncer())
600         return;
601     bufferSyncer()->requestMergeBuffersPermanently(bufferId1, bufferId2);
602 }
603
604
605 void Client::purgeKnownBufferIds()
606 {
607     if (!bufferSyncer())
608         return;
609     bufferSyncer()->requestPurgeBufferIds();
610 }
611
612
613 void Client::bufferRemoved(BufferId bufferId)
614 {
615     // select a sane buffer (status buffer)
616     /* we have to manually select a buffer because otherwise inconsitent changes
617      * to the model might occur:
618      * the result of a buffer removal triggers a change in the selection model.
619      * the newly selected buffer might be a channel that hasn't been selected yet
620      * and a new nickview would be created (which never heard of the "rowsAboutToBeRemoved").
621      * this new view (and/or) its sort filter will then only receive a "rowsRemoved" signal.
622      */
623     QModelIndex current = bufferModel()->currentIndex();
624     if (current.data(NetworkModel::BufferIdRole).value<BufferId>() == bufferId) {
625         bufferModel()->setCurrentIndex(current.sibling(0, 0));
626     }
627
628     // and remove it from the model
629     networkModel()->removeBuffer(bufferId);
630 }
631
632
633 void Client::bufferRenamed(BufferId bufferId, const QString &newName)
634 {
635     QModelIndex bufferIndex = networkModel()->bufferIndex(bufferId);
636     if (bufferIndex.isValid()) {
637         networkModel()->setData(bufferIndex, newName, Qt::DisplayRole);
638     }
639 }
640
641
642 void Client::buffersPermanentlyMerged(BufferId bufferId1, BufferId bufferId2)
643 {
644     QModelIndex idx = networkModel()->bufferIndex(bufferId1);
645     bufferModel()->setCurrentIndex(bufferModel()->mapFromSource(idx));
646     networkModel()->removeBuffer(bufferId2);
647 }
648
649
650 void Client::markBufferAsRead(BufferId id)
651 {
652     if (bufferSyncer() && id.isValid())
653         bufferSyncer()->requestMarkBufferAsRead(id);
654 }
655
656 void Client::changePassword(QString newPassword) {
657     CoreAccount account = currentCoreAccount();
658     account.setPassword(newPassword);
659     coreAccountModel()->createOrUpdateAccount(account);
660     emit clientChangePassword(newPassword);
661 }
662
663
664 #if QT_VERSION < 0x050000
665 void Client::logMessage(QtMsgType type, const char *msg)
666 {
667     fprintf(stderr, "%s\n", msg);
668     fflush(stderr);
669     if (type == QtFatalMsg) {
670         Quassel::logFatalMessage(msg);
671     }
672     else {
673         QString msgString = QString("%1\n").arg(msg);
674
675         //Check to see if there is an instance around, else we risk recursions
676         //when calling instance() and creating new ones.
677         if (!instanceExists())
678             return;
679
680         instance()->_debugLog << msgString;
681         emit instance()->logUpdated(msgString);
682     }
683 }
684 #else
685 void Client::logMessage(QtMsgType type, const QMessageLogContext &context, const QString &msg)
686 {
687     Q_UNUSED(context);
688
689     fprintf(stderr, "%s\n", msg.toLocal8Bit().constData());
690     fflush(stderr);
691     if (type == QtFatalMsg) {
692         Quassel::logFatalMessage(msg.toLocal8Bit().constData());
693     }
694     else {
695         QString msgString = QString("%1\n").arg(msg);
696
697         //Check to see if there is an instance around, else we risk recursions
698         //when calling instance() and creating new ones.
699         if (!instanceExists())
700             return;
701
702         instance()->_debugLog << msgString;
703         emit instance()->logUpdated(msgString);
704     }
705 }
706 #endif