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