src/core/coreirclisthelper.cpp

   1 /***************************************************************************
   2  *   Copyright (C) 2005-2018 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 "coreirclisthelper.h"
  22
  23 #include "corenetwork.h"
  24 #include "coreuserinputhandler.h"
  25
  26 constexpr auto kTimeoutMs = 5000;
  27
  28 QVariantList CoreIrcListHelper::requestChannelList(const NetworkId& netId, const QStringList& channelFilters)
  29 {
  30     if (_finishedChannelLists.contains(netId))
  31         return _finishedChannelLists.take(netId);
  32
  33     if (_channelLists.contains(netId)) {
  34         _queuedQuery[netId] = channelFilters.join(",");
  35     }
  36     else {
  37         dispatchQuery(netId, channelFilters.join(","));
  38     }
  39     return QVariantList();
  40 }
  41
  42 bool CoreIrcListHelper::addChannel(const NetworkId& netId, const QString& channelName, quint32 userCount, const QString& topic)
  43 {
  44     if (!_channelLists.contains(netId))
  45         return false;
  46
  47     _channelLists[netId] << ChannelDescription(channelName, userCount, topic);
  48     if (_queryTimeoutByNetId.contains(netId))
  49         _queryTimeoutByNetId[netId]->start(kTimeoutMs, this);
  50
  51     return true;
  52 }
  53
  54 bool CoreIrcListHelper::dispatchQuery(const NetworkId& netId, const QString& query)
  55 {
  56     CoreNetwork* network = coreSession()->network(netId);
  57     if (network) {
  58         _channelLists[netId] = QList<ChannelDescription>();
  59         network->userInputHandler()->handleList(BufferInfo(), query);
  60
  61         auto timer = std::make_shared<QBasicTimer>();
  62         timer->start(kTimeoutMs, this);
  63         _queryTimeoutByNetId[netId] = timer;
  64         _queryTimeoutByTimerId[timer->timerId()] = netId;
  65
  66         return true;
  67     }
  68     else {
  69         return false;
  70     }
  71 }
  72
  73 bool CoreIrcListHelper::endOfChannelList(const NetworkId& netId)
  74 {
  75     if (_queryTimeoutByNetId.contains(netId)) {
  76         // If we recieved an actual RPL_LISTEND, remove the timer
  77         int timerId = _queryTimeoutByNetId.take(netId)->timerId();
  78         _queryTimeoutByTimerId.remove(timerId);
  79     }
  80
  81     if (_queuedQuery.contains(netId)) {
  82         // we're no longer interessted in the current data. drop it and issue a new request.
  83         return dispatchQuery(netId, _queuedQuery.take(netId));
  84     }
  85     else if (_channelLists.contains(netId)) {
  86         QVariantList channelList;
  87         foreach (ChannelDescription channel, _channelLists[netId]) {
  88             QVariantList channelVariant;
  89             channelVariant << channel.channelName << channel.userCount << channel.topic;
  90             channelList << qVariantFromValue<QVariant>(channelVariant);
  91         }
  92         _finishedChannelLists[netId] = channelList;
  93         _channelLists.remove(netId);
  94         reportFinishedList(netId);
  95         return true;
  96     }
  97     else {
  98         return false;
  99     }
 100 }
 101
 102 void CoreIrcListHelper::timerEvent(QTimerEvent* event)
 103 {
 104     if (!_queryTimeoutByTimerId.contains(event->timerId())) {
 105         IrcListHelper::timerEvent(event);
 106         return;
 107     }
 108
 109     NetworkId netId = _queryTimeoutByTimerId.take(event->timerId());
 110     _queryTimeoutByNetId.remove(netId);
 111
 112     event->accept();
 113     endOfChannelList(netId);
 114 }