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
  43 bool CoreIrcListHelper::addChannel(const NetworkId &netId, const QString &channelName, quint32 userCount, const QString &topic)
  44 {
  45     if (!_channelLists.contains(netId))
  46         return false;
  47
  48     _channelLists[netId] << ChannelDescription(channelName, userCount, topic);
  49     if (_queryTimeoutByNetId.contains(netId))
  50         _queryTimeoutByNetId[netId]->start(kTimeoutMs, this);
  51
  52     return true;
  53 }
  54
  55
  56 bool CoreIrcListHelper::dispatchQuery(const NetworkId &netId, const QString &query)
  57 {
  58     CoreNetwork *network = coreSession()->network(netId);
  59     if (network) {
  60         _channelLists[netId] = QList<ChannelDescription>();
  61         network->userInputHandler()->handleList(BufferInfo(), query);
  62
  63         auto timer = std::make_shared<QBasicTimer>();
  64         timer->start(kTimeoutMs, this);
  65         _queryTimeoutByNetId[netId] = timer;
  66         _queryTimeoutByTimerId[timer->timerId()] = netId;
  67
  68         return true;
  69     }
  70     else {
  71         return false;
  72     }
  73 }
  74
  75
  76 bool CoreIrcListHelper::endOfChannelList(const NetworkId &netId)
  77 {
  78     if (_queryTimeoutByNetId.contains(netId)) {
  79         // If we recieved an actual RPL_LISTEND, remove the timer
  80         int timerId = _queryTimeoutByNetId.take(netId)->timerId();
  81         _queryTimeoutByTimerId.remove(timerId);
  82     }
  83
  84     if (_queuedQuery.contains(netId)) {
  85         // we're no longer interessted in the current data. drop it and issue a new request.
  86         return dispatchQuery(netId, _queuedQuery.take(netId));
  87     }
  88     else if (_channelLists.contains(netId)) {
  89         QVariantList channelList;
  90         foreach(ChannelDescription channel, _channelLists[netId]) {
  91             QVariantList channelVariant;
  92             channelVariant << channel.channelName
  93                            << channel.userCount
  94                            << channel.topic;
  95             channelList << qVariantFromValue<QVariant>(channelVariant);
  96         }
  97         _finishedChannelLists[netId] = channelList;
  98         _channelLists.remove(netId);
  99         reportFinishedList(netId);
 100         return true;
 101     }
 102     else {
 103         return false;
 104     }
 105 }
 106
 107
 108 void CoreIrcListHelper::timerEvent(QTimerEvent *event)
 109 {
 110     if (!_queryTimeoutByTimerId.contains(event->timerId())) {
 111         IrcListHelper::timerEvent(event);
 112         return;
 113     }
 114
 115     NetworkId netId = _queryTimeoutByTimerId.take(event->timerId());
 116     _queryTimeoutByNetId.remove(netId);
 117
 118     event->accept();
 119     endOfChannelList(netId);
 120 }