src/core/coresessioneventprocessor.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 "coresessioneventprocessor.h"
  22
  23 #include "coreirclisthelper.h"
  24 #include "corenetwork.h"
  25 #include "coresession.h"
  26 #include "coretransfer.h"
  27 #include "coretransfermanager.h"
  28 #include "ctcpevent.h"
  29 #include "ircevent.h"
  30 #include "ircuser.h"
  31 #include "logger.h"
  32 #include "messageevent.h"
  33 #include "netsplit.h"
  34 #include "quassel.h"
  35
  36 #ifdef HAVE_QCA2
  37 #  include "keyevent.h"
  38 #endif
  39
  40 // IRCv3 capabilities
  41 #include "irccap.h"
  42
  43 CoreSessionEventProcessor::CoreSessionEventProcessor(CoreSession *session)
  44     : BasicHandler("handleCtcp", session),
  45     _coreSession(session)
  46 {
  47     connect(coreSession(), SIGNAL(networkDisconnected(NetworkId)), this, SLOT(destroyNetsplits(NetworkId)));
  48     connect(this, SIGNAL(newEvent(Event *)), coreSession()->eventManager(), SLOT(postEvent(Event *)));
  49 }
  50
  51
  52 bool CoreSessionEventProcessor::checkParamCount(IrcEvent *e, int minParams)
  53 {
  54     if (e->params().count() < minParams) {
  55         if (e->type() == EventManager::IrcEventNumeric) {
  56             qWarning() << "Command " << static_cast<IrcEventNumeric *>(e)->number() << " requires " << minParams << "params, got: " << e->params();
  57         }
  58         else {
  59             QString name = coreSession()->eventManager()->enumName(e->type());
  60             qWarning() << qPrintable(name) << "requires" << minParams << "params, got:" << e->params();
  61         }
  62         e->stop();
  63         return false;
  64     }
  65     return true;
  66 }
  67
  68
  69 void CoreSessionEventProcessor::tryNextNick(NetworkEvent *e, const QString &errnick, bool erroneus)
  70 {
  71     QStringList desiredNicks = coreSession()->identity(e->network()->identity())->nicks();
  72     int nextNickIdx = desiredNicks.indexOf(errnick) + 1;
  73     QString nextNick;
  74     if (nextNickIdx > 0 && desiredNicks.size() > nextNickIdx) {
  75         nextNick = desiredNicks[nextNickIdx];
  76     }
  77     else {
  78         if (erroneus) {
  79             // FIXME Make this an ErrorEvent or something like that, so it's translated in the client
  80             MessageEvent *msgEvent = new MessageEvent(Message::Error, e->network(),
  81                 tr("No free and valid nicks in nicklist found. use: /nick <othernick> to continue"),
  82                 QString(), QString(), Message::None, e->timestamp());
  83             emit newEvent(msgEvent);
  84             return;
  85         }
  86         else {
  87             nextNick = errnick + "_";
  88         }
  89     }
  90     // FIXME Use a proper output event for this
  91     coreNetwork(e)->putRawLine("NICK " + coreNetwork(e)->encodeServerString(nextNick));
  92 }
  93
  94
  95 void CoreSessionEventProcessor::processIrcEventNumeric(IrcEventNumeric *e)
  96 {
  97     switch (e->number()) {
  98     // SASL authentication replies
  99     // See: http://ircv3.net/specs/extensions/sasl-3.1.html
 100
 101     //case 900:  // RPL_LOGGEDIN
 102     //case 901:  // RPL_LOGGEDOUT
 103     // Don't use 900 or 901 for updating the local hostmask.  Unreal 3.2 gives it as the IP address
 104     // even when cloaked.
 105     // Every other reply should result in moving on
 106     // TODO Handle errors to stop connection if appropriate
 107     case 902:  // ERR_NICKLOCKED
 108     case 903:  // RPL_SASLSUCCESS
 109     case 904:  // ERR_SASLFAIL
 110     case 905:  // ERR_SASLTOOLONG
 111     case 906:  // ERR_SASLABORTED
 112     case 907:  // ERR_SASLALREADY
 113         // Move on to the next capability
 114         coreNetwork(e)->sendNextCap();
 115         break;
 116
 117     default:
 118         break;
 119     }
 120 }
 121
 122
 123 void CoreSessionEventProcessor::processIrcEventAuthenticate(IrcEvent *e)
 124 {
 125     if (!checkParamCount(e, 1))
 126         return;
 127
 128     if (e->params().at(0) != "+") {
 129         qWarning() << "Invalid AUTHENTICATE" << e;
 130         return;
 131     }
 132
 133     CoreNetwork *net = coreNetwork(e);
 134
 135 #ifdef HAVE_SSL
 136     if (net->identityPtr()->sslCert().isNull()) {
 137 #endif
 138         QString construct = net->saslAccount();
 139         construct.append(QChar(QChar::Null));
 140         construct.append(net->saslAccount());
 141         construct.append(QChar(QChar::Null));
 142         construct.append(net->saslPassword());
 143         QByteArray saslData = QByteArray(construct.toLatin1().toBase64());
 144         saslData.prepend("AUTHENTICATE ");
 145         net->putRawLine(saslData);
 146 #ifdef HAVE_SSL
 147     } else {
 148         net->putRawLine("AUTHENTICATE +");
 149     }
 150 #endif
 151 }
 152
 153 void CoreSessionEventProcessor::processIrcEventCap(IrcEvent *e)
 154 {
 155     // Handle capability negotiation
 156     // See: http://ircv3.net/specs/core/capability-negotiation-3.2.html
 157     // And: http://ircv3.net/specs/core/capability-negotiation-3.1.html
 158
 159     // All commands require at least 2 parameters
 160     if (!checkParamCount(e, 2))
 161         return;
 162
 163     CoreNetwork *coreNet = coreNetwork(e);
 164     QString capCommand = e->params().at(1).trimmed().toUpper();
 165     if (capCommand == "LS" || capCommand == "NEW") {
 166         // Either we've gotten a list of capabilities, or new capabilities we may want
 167         // Server: CAP * LS * :multi-prefix extended-join account-notify batch invite-notify tls
 168         // Server: CAP * LS * :cap-notify server-time example.org/dummy-cap=dummyvalue example.org/second-dummy-cap
 169         // Server: CAP * LS :userhost-in-names sasl=EXTERNAL,DH-AES,DH-BLOWFISH,ECDSA-NIST256P-CHALLENGE,PLAIN
 170         bool capListFinished;
 171         QStringList availableCaps;
 172         if (e->params().count() == 4) {
 173             // Middle of multi-line reply, ignore the asterisk
 174             capListFinished = false;
 175             availableCaps = e->params().at(3).split(' ');
 176         } else {
 177             // Single line reply
 178             capListFinished = true;
 179             if (e->params().count() >= 3) {
 180                 // Some capabilities are specified, add them
 181                 availableCaps = e->params().at(2).split(' ');
 182             } else {
 183                 // No capabilities available, add an empty list
 184                 availableCaps = QStringList();
 185             }
 186         }
 187         // Sort capabilities before requesting for consistency among networks.  This may avoid
 188         // unexpected cases when some networks offer capabilities in a different order than
 189         // others.  It also looks nicer in logs.  Not required.
 190         availableCaps.sort();
 191         // Store what capabilities are available
 192         QString availableCapName, availableCapValue;
 193         for (int i = 0; i < availableCaps.count(); ++i) {
 194             // Capability may include values, e.g. CAP * LS :multi-prefix sasl=EXTERNAL
 195             // Capability name comes before the first '='.  If no '=' exists, this gets the
 196             // whole string instead.
 197             availableCapName = availableCaps[i].section('=', 0, 0).trimmed();
 198             // Some capabilities include multiple key=value pairs in the listing,
 199             // e.g. "sts=duration=31536000,port=6697"
 200             // Include everything after the first equal sign as part of the value.  If no '='
 201             // exists, this gets an empty string.
 202             availableCapValue = availableCaps[i].section('=', 1).trimmed();
 203             // Only add the capability if it's non-empty
 204             if (!availableCapName.isEmpty()) {
 205                 coreNet->addCap(availableCapName, availableCapValue);
 206             }
 207         }
 208
 209         // Begin capability requests when capability listing complete
 210         if (capListFinished)
 211             coreNet->beginCapNegotiation();
 212     } else if (capCommand == "ACK") {
 213         // CAP ACK requires at least 3 parameters (no empty response allowed)
 214         if (!checkParamCount(e, 3)) {
 215             // If an invalid reply is sent, try to continue rather than getting stuck.
 216             coreNet->sendNextCap();
 217             return;
 218         }
 219
 220         // Server: CAP * ACK :multi-prefix sasl
 221         // Got the capabilities we want, handle as needed.
 222         QStringList acceptedCaps;
 223         acceptedCaps = e->params().at(2).split(' ');
 224
 225         // Store what capability was acknowledged
 226         QString acceptedCap;
 227
 228         // Keep track of whether or not a capability requires further configuration.  Due to queuing
 229         // logic in CoreNetwork::queueCap(), this shouldn't ever happen when more than one
 230         // capability is requested, but it's better to handle edge cases or faulty servers.
 231         bool capsRequireConfiguration = false;
 232
 233         for (int i = 0; i < acceptedCaps.count(); ++i) {
 234             acceptedCap = acceptedCaps[i].trimmed().toLower();
 235             // Mark this cap as accepted
 236             coreNet->acknowledgeCap(acceptedCap);
 237             if (!capsRequireConfiguration &&
 238                     coreNet->capsRequiringConfiguration.contains(acceptedCap)) {
 239                 capsRequireConfiguration = true;
 240                 // Some capabilities (e.g. SASL) require further messages to finish.  If so, do NOT
 241                 // send the next capability; it will be handled elsewhere in CoreNetwork.
 242                 // Otherwise, allow moving on to the next capability.
 243             }
 244         }
 245
 246         if (!capsRequireConfiguration) {
 247             // No additional configuration required, move on to the next capability
 248             coreNet->sendNextCap();
 249         }
 250     } else if (capCommand == "NAK" || capCommand == "DEL") {
 251         // CAP NAK/DEL require at least 3 parameters (no empty response allowed)
 252         if (!checkParamCount(e, 3)) {
 253             if (capCommand == "NAK") {
 254                 // If an invalid reply is sent, try to continue rather than getting stuck.  This
 255                 // only matters for denied caps, not removed caps.
 256                 coreNet->sendNextCap();
 257             }
 258             return;
 259         }
 260
 261         // Either something went wrong with the capabilities, or they are no longer supported
 262         // > For CAP NAK
 263         // Server: CAP * NAK :multi-prefix sasl
 264         // > For CAP DEL
 265         // Server: :irc.example.com CAP modernclient DEL :multi-prefix sasl
 266         // CAP NAK and CAP DEL replies are always single-line
 267
 268         QStringList removedCaps;
 269         removedCaps = e->params().at(2).split(' ');
 270
 271         // Store the capabilities that were denied or removed
 272         QString removedCap;
 273         for (int i = 0; i < removedCaps.count(); ++i) {
 274             removedCap = removedCaps[i].trimmed().toLower();
 275             // Mark this cap as removed.
 276             // For CAP DEL, removes it from use.
 277             // For CAP NAK when received before negotiation enabled these capabilities, removeCap()
 278             // should do nothing.  This merely guards against non-spec servers sending an
 279             // unsolicited CAP ACK then later removing that capability.
 280             coreNet->removeCap(removedCap);
 281         }
 282
 283         if (capCommand == "NAK") {
 284             // Continue negotiation only if this is the result of denied caps, not removed caps
 285             if (removedCaps.count() > 1) {
 286                 // We've received a CAP NAK reply to multiple capabilities at once.  Unfortunately,
 287                 // we don't know which capability failed and which ones are valid to re-request, so
 288                 // individually retry each capability from the failed bundle.
 289                 // See CoreNetwork::retryCapsIndividually() for more details.
 290                 coreNet->retryCapsIndividually();
 291                 // Still need to call sendNextCap() to carry on.
 292             }
 293             // Carry on with negotiation
 294             coreNet->sendNextCap();
 295         }
 296     }
 297 }
 298
 299 /* IRCv3 account-notify
 300  * Log in:  ":nick!user@host ACCOUNT accountname"
 301  * Log out: ":nick!user@host ACCOUNT *" */
 302 void CoreSessionEventProcessor::processIrcEventAccount(IrcEvent *e)
 303 {
 304     if (!checkParamCount(e, 1))
 305         return;
 306
 307     IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 308     if (ircuser) {
 309         // WHOX uses '0' to indicate logged-out, account-notify and extended-join uses '*'.
 310         // As '*' is used internally to represent logged-out, no need to handle that differently.
 311         ircuser->setAccount(e->params().at(0));
 312     } else {
 313         qDebug() << "Received account-notify data for unknown user" << e->prefix();
 314     }
 315 }
 316
 317 /* IRCv3 away-notify - ":nick!user@host AWAY [:message]" */
 318 void CoreSessionEventProcessor::processIrcEventAway(IrcEvent *e)
 319 {
 320     if (!checkParamCount(e, 1))
 321         return;
 322     // Don't use checkParamCount(e, 2) since the message is optional.  Some servers respond in a way
 323     // that it counts as two parameters, but we shouldn't rely on that.
 324
 325     // Nick is sent as part of parameters in order to split user/server decoding
 326     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 327     if (ircuser) {
 328         // If two parameters are sent -and- the second parameter isn't empty, then user is away.
 329         // Otherwise, mark them as not away.
 330         if (e->params().count() >= 2 && !e->params().at(1).isEmpty()) {
 331             ircuser->setAway(true);
 332             ircuser->setAwayMessage(e->params().at(1));
 333         } else {
 334             ircuser->setAway(false);
 335         }
 336     } else {
 337         qDebug() << "Received away-notify data for unknown user" << e->params().at(0);
 338     }
 339 }
 340
 341 /* IRCv3 chghost - ":nick!user@host CHGHOST newuser new.host.goes.here" */
 342 void CoreSessionEventProcessor::processIrcEventChghost(IrcEvent *e)
 343 {
 344     if (!checkParamCount(e, 2))
 345         return;
 346
 347     IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 348     if (ircuser) {
 349         // Update with new user/hostname information.  setUser/setHost handles checking what
 350         // actually changed.
 351         ircuser->setUser(e->params().at(0));
 352         ircuser->setHost(e->params().at(1));
 353     } else {
 354         qDebug() << "Received chghost data for unknown user" << e->prefix();
 355     }
 356 }
 357
 358 void CoreSessionEventProcessor::processIrcEventInvite(IrcEvent *e)
 359 {
 360     if (checkParamCount(e, 2)) {
 361         e->network()->updateNickFromMask(e->prefix());
 362     }
 363 }
 364
 365 /*  JOIN: ":<nick!user@host> JOIN <channel>" */
 366 void CoreSessionEventProcessor::processIrcEventJoin(IrcEvent *e)
 367 {
 368     if (e->testFlag(EventManager::Fake)) // generated by handleEarlyNetsplitJoin
 369         return;
 370
 371     if (!checkParamCount(e, 1))
 372         return;
 373
 374     CoreNetwork *net = coreNetwork(e);
 375     QString channel = e->params()[0];
 376     IrcUser *ircuser = net->updateNickFromMask(e->prefix());
 377
 378     if (net->capEnabled(IrcCap::EXTENDED_JOIN)) {
 379         if (e->params().count() < 3) {
 380             // Some IRC servers don't send extended-join events in all situations.  Rather than
 381             // ignore the join entirely, treat it as a regular join with a debug-level log entry.
 382             // See:  https://github.com/inspircd/inspircd/issues/821
 383             qDebug() << "extended-join requires 3 params, got:" << e->params() << ", handling as a "
 384                         "regular join";
 385         } else {
 386             // If logged in, :nick!user@host JOIN #channelname accountname :Real Name
 387             // If logged out, :nick!user@host JOIN #channelname * :Real Name
 388             // See:  http://ircv3.net/specs/extensions/extended-join-3.1.html
 389             // WHOX uses '0' to indicate logged-out, account-notify and extended-join uses '*'.
 390             // As '*' is used internally to represent logged-out, no need to handle that differently.
 391             ircuser->setAccount(e->params()[1]);
 392             // Update the user's real name, too
 393             ircuser->setRealName(e->params()[2]);
 394         }
 395     }
 396     // Else :nick!user@host JOIN #channelname
 397
 398     bool handledByNetsplit = false;
 399     foreach(Netsplit* n, _netsplits.value(e->network())) {
 400         handledByNetsplit = n->userJoined(e->prefix(), channel);
 401         if (handledByNetsplit)
 402             break;
 403     }
 404
 405     // If using away-notify, check new users.  Works around buggy IRC servers
 406     // forgetting to send :away messages for users who join channels when away.
 407     if (net->capEnabled(IrcCap::AWAY_NOTIFY)) {
 408         net->queueAutoWhoOneshot(ircuser->nick());
 409     }
 410
 411     if (!handledByNetsplit)
 412         ircuser->joinChannel(channel);
 413     else
 414         e->setFlag(EventManager::Netsplit);
 415
 416     if (net->isMe(ircuser)) {
 417         net->setChannelJoined(channel);
 418         // Mark the message as Self
 419         e->setFlag(EventManager::Self);
 420         // FIXME use event
 421         net->putRawLine(net->serverEncode("MODE " + channel)); // we want to know the modes of the channel we just joined, so we ask politely
 422     }
 423 }
 424
 425
 426 void CoreSessionEventProcessor::lateProcessIrcEventKick(IrcEvent *e)
 427 {
 428     if (checkParamCount(e, 2)) {
 429         e->network()->updateNickFromMask(e->prefix());
 430         IrcUser *victim = e->network()->ircUser(e->params().at(1));
 431         if (victim) {
 432             victim->partChannel(e->params().at(0));
 433             //if(e->network()->isMe(victim)) e->network()->setKickedFromChannel(channel);
 434         }
 435     }
 436 }
 437
 438
 439 void CoreSessionEventProcessor::processIrcEventMode(IrcEvent *e)
 440 {
 441     if (!checkParamCount(e, 2))
 442         return;
 443
 444     if (e->network()->isChannelName(e->params().first())) {
 445         // Channel Modes
 446
 447         IrcChannel *channel = e->network()->ircChannel(e->params()[0]);
 448         if (!channel) {
 449             // we received mode information for a channel we're not in. that means probably we've just been kicked out or something like that
 450             // anyways: we don't have a place to store the data --> discard the info.
 451             return;
 452         }
 453
 454         QString modes = e->params()[1];
 455         bool add = true;
 456         int paramOffset = 2;
 457         for (int c = 0; c < modes.length(); c++) {
 458             if (modes[c] == '+') {
 459                 add = true;
 460                 continue;
 461             }
 462             if (modes[c] == '-') {
 463                 add = false;
 464                 continue;
 465             }
 466
 467             if (e->network()->prefixModes().contains(modes[c])) {
 468                 // user channel modes (op, voice, etc...)
 469                 if (paramOffset < e->params().count()) {
 470                     IrcUser *ircUser = e->network()->ircUser(e->params()[paramOffset]);
 471                     if (!ircUser) {
 472                         qWarning() << Q_FUNC_INFO << "Unknown IrcUser:" << e->params()[paramOffset];
 473                     }
 474                     else {
 475                         if (add) {
 476                             bool handledByNetsplit = false;
 477                             QHash<QString, Netsplit *> splits = _netsplits.value(e->network());
 478                             foreach(Netsplit* n, _netsplits.value(e->network())) {
 479                                 handledByNetsplit = n->userAlreadyJoined(ircUser->hostmask(), channel->name());
 480                                 if (handledByNetsplit) {
 481                                     n->addMode(ircUser->hostmask(), channel->name(), QString(modes[c]));
 482                                     break;
 483                                 }
 484                             }
 485                             if (!handledByNetsplit)
 486                                 channel->addUserMode(ircUser, QString(modes[c]));
 487                         }
 488                         else
 489                             channel->removeUserMode(ircUser, QString(modes[c]));
 490                     }
 491                 }
 492                 else {
 493                     qWarning() << "Received MODE with too few parameters:" << e->params();
 494                 }
 495                 ++paramOffset;
 496             }
 497             else {
 498                 // regular channel modes
 499                 QString value;
 500                 Network::ChannelModeType modeType = e->network()->channelModeType(modes[c]);
 501                 if (modeType == Network::A_CHANMODE || modeType == Network::B_CHANMODE || (modeType == Network::C_CHANMODE && add)) {
 502                     if (paramOffset < e->params().count()) {
 503                         value = e->params()[paramOffset];
 504                     }
 505                     else {
 506                         qWarning() << "Received MODE with too few parameters:" << e->params();
 507                     }
 508                     ++paramOffset;
 509                 }
 510
 511                 if (add)
 512                     channel->addChannelMode(modes[c], value);
 513                 else
 514                     channel->removeChannelMode(modes[c], value);
 515             }
 516         }
 517     }
 518     else {
 519         // pure User Modes
 520         IrcUser *ircUser = e->network()->newIrcUser(e->params().first());
 521         QString modeString(e->params()[1]);
 522         QString addModes;
 523         QString removeModes;
 524         bool add = false;
 525         for (int c = 0; c < modeString.count(); c++) {
 526             if (modeString[c] == '+') {
 527                 add = true;
 528                 continue;
 529             }
 530             if (modeString[c] == '-') {
 531                 add = false;
 532                 continue;
 533             }
 534             if (add)
 535                 addModes += modeString[c];
 536             else
 537                 removeModes += modeString[c];
 538         }
 539         if (!addModes.isEmpty())
 540             ircUser->addUserModes(addModes);
 541         if (!removeModes.isEmpty())
 542             ircUser->removeUserModes(removeModes);
 543
 544         if (e->network()->isMe(ircUser)) {
 545             // Mark the message as Self
 546             e->setFlag(EventManager::Self);
 547             coreNetwork(e)->updatePersistentModes(addModes, removeModes);
 548         }
 549     }
 550 }
 551
 552
 553 void CoreSessionEventProcessor::processIrcEventNick(IrcEvent *e)
 554 {
 555     if (checkParamCount(e, 1)) {
 556         IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 557         if (!ircuser) {
 558             qWarning() << Q_FUNC_INFO << "Unknown IrcUser!";
 559             return;
 560         }
 561
 562         if (e->network()->isMe(ircuser)) {
 563             // Mark the message as Self
 564             e->setFlag(EventManager::Self);
 565         }
 566
 567         // Actual processing is handled in lateProcessIrcEventNick(), this just sets the event flag
 568     }
 569 }
 570
 571
 572 void CoreSessionEventProcessor::lateProcessIrcEventNick(IrcEvent *e)
 573 {
 574     if (checkParamCount(e, 1)) {
 575         IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 576         if (!ircuser) {
 577             qWarning() << Q_FUNC_INFO << "Unknown IrcUser!";
 578             return;
 579         }
 580         QString newnick = e->params().at(0);
 581         QString oldnick = ircuser->nick();
 582
 583         // the order is cruicial
 584         // otherwise the client would rename the buffer, see that the assigned ircuser doesn't match anymore
 585         // and remove the ircuser from the querybuffer leading to a wrong on/offline state
 586         ircuser->setNick(newnick);
 587         coreSession()->renameBuffer(e->networkId(), newnick, oldnick);
 588     }
 589 }
 590
 591
 592 void CoreSessionEventProcessor::processIrcEventPart(IrcEvent *e)
 593 {
 594     if (checkParamCount(e, 1)) {
 595         IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 596         if (!ircuser) {
 597             qWarning() << Q_FUNC_INFO<< "Unknown IrcUser!";
 598             return;
 599         }
 600
 601         if (e->network()->isMe(ircuser)) {
 602             // Mark the message as Self
 603             e->setFlag(EventManager::Self);
 604         }
 605
 606         // Actual processing is handled in lateProcessIrcEventNick(), this just sets the event flag
 607     }
 608 }
 609
 610
 611 void CoreSessionEventProcessor::lateProcessIrcEventPart(IrcEvent *e)
 612 {
 613     if (checkParamCount(e, 1)) {
 614         IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 615         if (!ircuser) {
 616             qWarning() << Q_FUNC_INFO<< "Unknown IrcUser!";
 617             return;
 618         }
 619         QString channel = e->params().at(0);
 620         ircuser->partChannel(channel);
 621         if (e->network()->isMe(ircuser)) {
 622             qobject_cast<CoreNetwork *>(e->network())->setChannelParted(channel);
 623         }
 624     }
 625 }
 626
 627
 628 void CoreSessionEventProcessor::processIrcEventPing(IrcEvent *e)
 629 {
 630     QString param = e->params().count() ? e->params().first() : QString();
 631     // FIXME use events
 632     // Take priority so this won't get stuck behind other queued messages.
 633     coreNetwork(e)->putRawLine("PONG " + coreNetwork(e)->serverEncode(param), true);
 634 }
 635
 636
 637 void CoreSessionEventProcessor::processIrcEventPong(IrcEvent *e)
 638 {
 639     // Ensure we get at least one parameter
 640     if (!checkParamCount(e, 1))
 641         return;
 642
 643     // Some IRC servers respond with only one parameter, others respond with two, with the latter
 644     // being the text sent.  Handle both situations.
 645     QString timestamp;
 646     if (e->params().count() < 2) {
 647         // Only one parameter received
 648         // :localhost PONG 02:43:49.565
 649         timestamp = e->params().at(0);
 650     } else {
 651         // Two parameters received, pick the second
 652         // :localhost PONG localhost :02:43:49.565
 653         timestamp = e->params().at(1);
 654     }
 655
 656     // The server is supposed to send back what we passed as parameter, and we send a timestamp.
 657     // However, using quote and whatnot, one can send arbitrary pings, and IRC servers may decide to
 658     // ignore our requests entirely and send whatever they want, so we have to do some sanity
 659     // checks.
 660     //
 661     // Attempt to parse the timestamp
 662     QTime sendTime = QTime::fromString(timestamp, "hh:mm:ss.zzz");
 663     if (sendTime.isValid()) {
 664         // Mark IRC server as sending valid ping replies
 665         if (!coreNetwork(e)->isPongTimestampValid()) {
 666             coreNetwork(e)->setPongTimestampValid(true);
 667             // Add a message the first time it happens
 668             qDebug().nospace() << "Received PONG with valid timestamp, marking pong replies on "
 669                                   "network "
 670                                << "\"" << qPrintable(e->network()->networkName()) << "\" (ID: "
 671                                << qPrintable(QString::number(e->network()->networkId().toInt()))
 672                                << ") as usable for latency measurement";
 673         }
 674         // Remove pending flag
 675         coreNetwork(e)->resetPongReplyPending();
 676
 677         // Don't show this in the UI
 678         e->setFlag(EventManager::Silent);
 679         // TODO:  To allow for a user-sent /ping (without arguments, so default timestamp is used),
 680         // this could track how many automated PINGs have been sent by the core and subtract one
 681         // each time, only marking the PING as silent if there's pending automated pong replies.
 682         // However, that's a behavior change which warrants further testing.  For now, take the
 683         // simpler, previous approach that errs on the side of silencing too much.
 684
 685         // Calculate latency from time difference, divided by 2 to account for round-trip time
 686         e->network()->setLatency(sendTime.msecsTo(QTime::currentTime()) / 2);
 687     } else if (coreNetwork(e)->isPongReplyPending() && !coreNetwork(e)->isPongTimestampValid()) {
 688         // There's an auto-PING reply pending and we've not yet received a PONG reply with a valid
 689         // timestamp.  It's possible this server will never respond with a valid timestamp, and thus
 690         // any automated PINGs will result in unwanted spamming of the server buffer.
 691
 692         // Don't show this in the UI
 693         e->setFlag(EventManager::Silent);
 694         // Remove pending flag
 695         coreNetwork(e)->resetPongReplyPending();
 696
 697         // Log a message
 698         qDebug().nospace() << "Received PONG with invalid timestamp from network "
 699                            << "\"" << qPrintable(e->network()->networkName()) << "\" (ID: "
 700                            << qPrintable(QString::number(e->network()->networkId().toInt()))
 701                            << "), silencing, parameters are " << e->params();
 702     }
 703     // else: We're not expecting a PONG reply and timestamp is not valid, assume it's from the user
 704 }
 705
 706
 707 void CoreSessionEventProcessor::processIrcEventQuit(IrcEvent *e)
 708 {
 709     IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 710     if (!ircuser)
 711         return;
 712
 713     if (e->network()->isMe(ircuser)) {
 714         // Mark the message as Self
 715         e->setFlag(EventManager::Self);
 716     }
 717
 718     QString msg;
 719     if (e->params().count() > 0)
 720         msg = e->params()[0];
 721
 722     // check if netsplit
 723     if (Netsplit::isNetsplit(msg)) {
 724         Netsplit *n;
 725         if (!_netsplits[e->network()].contains(msg)) {
 726             n = new Netsplit(e->network(), this);
 727             connect(n, SIGNAL(finished()), this, SLOT(handleNetsplitFinished()));
 728             connect(n, SIGNAL(netsplitJoin(Network*, QString, QStringList, QStringList, QString)),
 729                 this, SLOT(handleNetsplitJoin(Network*, QString, QStringList, QStringList, QString)));
 730             connect(n, SIGNAL(netsplitQuit(Network*, QString, QStringList, QString)),
 731                 this, SLOT(handleNetsplitQuit(Network*, QString, QStringList, QString)));
 732             connect(n, SIGNAL(earlyJoin(Network*, QString, QStringList, QStringList)),
 733                 this, SLOT(handleEarlyNetsplitJoin(Network*, QString, QStringList, QStringList)));
 734             _netsplits[e->network()].insert(msg, n);
 735         }
 736         else {
 737             n = _netsplits[e->network()][msg];
 738         }
 739         // add this user to the netsplit
 740         n->userQuit(e->prefix(), ircuser->channels(), msg);
 741         e->setFlag(EventManager::Netsplit);
 742     }
 743     // normal quit is handled in lateProcessIrcEventQuit()
 744 }
 745
 746
 747 void CoreSessionEventProcessor::lateProcessIrcEventQuit(IrcEvent *e)
 748 {
 749     if (e->testFlag(EventManager::Netsplit))
 750         return;
 751
 752     IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 753     if (!ircuser)
 754         return;
 755
 756     ircuser->quit();
 757 }
 758
 759
 760 void CoreSessionEventProcessor::processIrcEventTopic(IrcEvent *e)
 761 {
 762     if (checkParamCount(e, 2)) {
 763         IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix());
 764
 765         if (e->network()->isMe(ircuser)) {
 766             // Mark the message as Self
 767             e->setFlag(EventManager::Self);
 768         }
 769
 770         IrcChannel *channel = e->network()->ircChannel(e->params().at(0));
 771         if (channel)
 772             channel->setTopic(e->params().at(1));
 773     }
 774 }
 775
 776 /* ERROR - "ERROR :reason"
 777 Example:  ERROR :Closing Link: nickname[xxx.xxx.xxx.xxx] (Large base64 image paste.)
 778 See https://tools.ietf.org/html/rfc2812#section-3.7.4 */
 779 void CoreSessionEventProcessor::processIrcEventError(IrcEvent *e)
 780 {
 781     if (!checkParamCount(e, 1))
 782         return;
 783
 784     if (coreNetwork(e)->disconnectExpected()) {
 785         // During QUIT, the server should send an error (often, but not always, "Closing Link"). As
 786         // we're expecting it, don't show this to the user.
 787         e->setFlag(EventManager::Silent);
 788     }
 789 }
 790
 791
 792 #ifdef HAVE_QCA2
 793 void CoreSessionEventProcessor::processKeyEvent(KeyEvent *e)
 794 {
 795     if (!Cipher::neededFeaturesAvailable()) {
 796         emit newEvent(new MessageEvent(Message::Error, e->network(), tr("Unable to perform key exchange, missing qca-ossl plugin."), e->prefix(), e->target(), Message::None, e->timestamp()));
 797         return;
 798     }
 799     CoreNetwork *net = qobject_cast<CoreNetwork*>(e->network());
 800     Cipher *c = net->cipher(e->target());
 801     if (!c) // happens when there is no CoreIrcChannel for the target (i.e. never?)
 802         return;
 803
 804     if (e->exchangeType() == KeyEvent::Init) {
 805         QByteArray pubKey = c->parseInitKeyX(e->key());
 806         if (pubKey.isEmpty()) {
 807             emit newEvent(new MessageEvent(Message::Error, e->network(), tr("Unable to parse the DH1080_INIT. Key exchange failed."), e->prefix(), e->target(), Message::None, e->timestamp()));
 808             return;
 809         } else {
 810             net->setCipherKey(e->target(), c->key());
 811             emit newEvent(new MessageEvent(Message::Info, e->network(), tr("Your key is set and messages will be encrypted."), e->prefix(), e->target(), Message::None, e->timestamp()));
 812             QList<QByteArray> p;
 813             p << net->serverEncode(e->target()) << net->serverEncode("DH1080_FINISH ")+pubKey;
 814             net->putCmd("NOTICE", p);
 815         }
 816     } else {
 817         if (c->parseFinishKeyX(e->key())) {
 818             net->setCipherKey(e->target(), c->key());
 819             emit newEvent(new MessageEvent(Message::Info, e->network(), tr("Your key is set and messages will be encrypted."), e->prefix(), e->target(), Message::None, e->timestamp()));
 820         } else {
 821             emit newEvent(new MessageEvent(Message::Info, e->network(), tr("Failed to parse DH1080_FINISH. Key exchange failed."), e->prefix(), e->target(), Message::None, e->timestamp()));
 822         }
 823     }
 824 }
 825 #endif
 826
 827
 828 /* RPL_WELCOME */
 829 void CoreSessionEventProcessor::processIrcEvent001(IrcEventNumeric *e)
 830 {
 831     e->network()->setCurrentServer(e->prefix());
 832     e->network()->setMyNick(e->target());
 833 }
 834
 835
 836 /* RPL_ISUPPORT */
 837 // TODO Complete 005 handling, also use sensible defaults for non-sent stuff
 838 void CoreSessionEventProcessor::processIrcEvent005(IrcEvent *e)
 839 {
 840     if (!checkParamCount(e, 1))
 841         return;
 842
 843     QString key, value;
 844     for (int i = 0; i < e->params().count() - 1; i++) {
 845         QString key = e->params()[i].section("=", 0, 0);
 846         QString value = e->params()[i].section("=", 1);
 847         e->network()->addSupport(key, value);
 848     }
 849
 850     /* determine our prefixes here to get an accurate result */
 851     e->network()->determinePrefixes();
 852 }
 853
 854
 855 /* RPL_UMODEIS - "<user_modes> [<user_mode_params>]" */
 856 void CoreSessionEventProcessor::processIrcEvent221(IrcEvent *)
 857 {
 858     // TODO: save information in network object
 859 }
 860
 861
 862 /* RPL_STATSCONN - "Highest connection cout: 8000 (7999 clients)" */
 863 void CoreSessionEventProcessor::processIrcEvent250(IrcEvent *)
 864 {
 865     // TODO: save information in network object
 866 }
 867
 868
 869 /* RPL_LOCALUSERS - "Current local user: 5024  Max: 7999 */
 870 void CoreSessionEventProcessor::processIrcEvent265(IrcEvent *)
 871 {
 872     // TODO: save information in network object
 873 }
 874
 875
 876 /* RPL_GLOBALUSERS - "Current global users: 46093  Max: 47650" */
 877 void CoreSessionEventProcessor::processIrcEvent266(IrcEvent *)
 878 {
 879     // TODO: save information in network object
 880 }
 881
 882
 883 /*
 884 WHOIS-Message:
 885    Replies 311 - 313, 317 - 319 are all replies generated in response to a WHOIS message.
 886   and 301 (RPL_AWAY)
 887               "<nick> :<away message>"
 888 WHO-Message:
 889    Replies 352 and 315 paired are used to answer a WHO message.
 890
 891 WHOWAS-Message:
 892    Replies 314 and 369 are responses to a WHOWAS message.
 893
 894 */
 895
 896 /* RPL_AWAY - "<nick> :<away message>" */
 897 void CoreSessionEventProcessor::processIrcEvent301(IrcEvent *e)
 898 {
 899     if (!checkParamCount(e, 2))
 900         return;
 901
 902     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 903     if (ircuser) {
 904         ircuser->setAway(true);
 905         ircuser->setAwayMessage(e->params().at(1));
 906         // lastAwayMessageTime is set in EventStringifier::processIrcEvent301(), no need to set it
 907         // here too
 908         //ircuser->setLastAwayMessageTime(now);
 909     }
 910 }
 911
 912
 913 /* RPL_UNAWAY - ":You are no longer marked as being away" */
 914 void CoreSessionEventProcessor::processIrcEvent305(IrcEvent *e)
 915 {
 916     IrcUser *me = e->network()->me();
 917     if (me)
 918         me->setAway(false);
 919
 920     if (e->network()->autoAwayActive()) {
 921         e->network()->setAutoAwayActive(false);
 922         e->setFlag(EventManager::Silent);
 923     }
 924 }
 925
 926
 927 /* RPL_NOWAWAY - ":You have been marked as being away" */
 928 void CoreSessionEventProcessor::processIrcEvent306(IrcEvent *e)
 929 {
 930     IrcUser *me = e->network()->me();
 931     if (me)
 932         me->setAway(true);
 933 }
 934
 935
 936 /* RPL_WHOISSERVICE - "<user> is registered nick" */
 937 void CoreSessionEventProcessor::processIrcEvent307(IrcEvent *e)
 938 {
 939     if (!checkParamCount(e, 1))
 940         return;
 941
 942     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 943     if (ircuser)
 944         ircuser->setWhoisServiceReply(e->params().join(" "));
 945 }
 946
 947
 948 /* RPL_SUSERHOST - "<user> is available for help." */
 949 void CoreSessionEventProcessor::processIrcEvent310(IrcEvent *e)
 950 {
 951     if (!checkParamCount(e, 1))
 952         return;
 953
 954     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 955     if (ircuser)
 956         ircuser->setSuserHost(e->params().join(" "));
 957 }
 958
 959
 960 /*  RPL_WHOISUSER - "<nick> <user> <host> * :<real name>" */
 961 void CoreSessionEventProcessor::processIrcEvent311(IrcEvent *e)
 962 {
 963     if (!checkParamCount(e, 3))
 964         return;
 965
 966     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 967     if (ircuser) {
 968         ircuser->setUser(e->params().at(1));
 969         ircuser->setHost(e->params().at(2));
 970         ircuser->setRealName(e->params().last());
 971     }
 972 }
 973
 974
 975 /*  RPL_WHOISSERVER -  "<nick> <server> :<server info>" */
 976 void CoreSessionEventProcessor::processIrcEvent312(IrcEvent *e)
 977 {
 978     if (!checkParamCount(e, 2))
 979         return;
 980
 981     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 982     if (ircuser)
 983         ircuser->setServer(e->params().at(1));
 984 }
 985
 986
 987 /*  RPL_WHOISOPERATOR - "<nick> :is an IRC operator" */
 988 void CoreSessionEventProcessor::processIrcEvent313(IrcEvent *e)
 989 {
 990     if (!checkParamCount(e, 1))
 991         return;
 992
 993     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
 994     if (ircuser)
 995         ircuser->setIrcOperator(e->params().last());
 996 }
 997
 998
 999 /*  RPL_ENDOFWHO: "<name> :End of WHO list" */
1000 void CoreSessionEventProcessor::processIrcEvent315(IrcEvent *e)
1001 {
1002     if (!checkParamCount(e, 1))
1003         return;
1004
1005     if (coreNetwork(e)->setAutoWhoDone(e->params()[0]))
1006         e->setFlag(EventManager::Silent);
1007 }
1008
1009
1010 /*  RPL_WHOISIDLE - "<nick> <integer> :seconds idle"
1011    (real life: "<nick> <integer> <integer> :seconds idle, signon time) */
1012 void CoreSessionEventProcessor::processIrcEvent317(IrcEvent *e)
1013 {
1014     if (!checkParamCount(e, 2))
1015         return;
1016
1017     QDateTime loginTime;
1018
1019     int idleSecs = e->params()[1].toInt();
1020     if (e->params().count() > 3) { // if we have more then 3 params we have the above mentioned "real life" situation
1021         // Allow for 64-bit time
1022         qint64 logintime = e->params()[2].toLongLong();
1023         // Time in IRC protocol is defined as seconds.  Convert from seconds instead.
1024         // See https://doc.qt.io/qt-5/qdatetime.html#fromSecsSinceEpoch
1025 #if QT_VERSION >= 0x050800
1026         loginTime = QDateTime::fromSecsSinceEpoch(logintime);
1027 #else
1028         // fromSecsSinceEpoch() was added in Qt 5.8.  Manually downconvert to seconds for
1029         // now.
1030         // See https://doc.qt.io/qt-5/qdatetime.html#fromMSecsSinceEpoch
1031         loginTime = QDateTime::fromMSecsSinceEpoch((qint64)(logintime * 1000));
1032 #endif
1033     }
1034
1035     IrcUser *ircuser = e->network()->ircUser(e->params()[0]);
1036     if (ircuser) {
1037         ircuser->setIdleTime(e->timestamp().addSecs(-idleSecs));
1038         if (loginTime.isValid())
1039             ircuser->setLoginTime(loginTime);
1040     }
1041 }
1042
1043
1044 /* RPL_LIST -  "<channel> <# visible> :<topic>" */
1045 void CoreSessionEventProcessor::processIrcEvent322(IrcEvent *e)
1046 {
1047     if (!checkParamCount(e, 1))
1048         return;
1049
1050     QString channelName;
1051     quint32 userCount = 0;
1052     QString topic;
1053
1054     switch (e->params().count()) {
1055     case 3:
1056         topic = e->params()[2];
1057         [[clang::fallthrough]];
1058     case 2:
1059         userCount = e->params()[1].toUInt();
1060         [[clang::fallthrough]];
1061     case 1:
1062         channelName = e->params()[0];
1063         [[clang::fallthrough]];
1064     default:
1065         break;
1066     }
1067     if (coreSession()->ircListHelper()->addChannel(e->networkId(), channelName, userCount, topic))
1068         e->stop();  // consumed by IrcListHelper, so don't further process/show this event
1069 }
1070
1071
1072 /* RPL_LISTEND ":End of LIST" */
1073 void CoreSessionEventProcessor::processIrcEvent323(IrcEvent *e)
1074 {
1075     if (!checkParamCount(e, 1))
1076         return;
1077
1078     if (coreSession()->ircListHelper()->endOfChannelList(e->networkId()))
1079         e->stop();  // consumed by IrcListHelper, so don't further process/show this event
1080 }
1081
1082
1083 /* RPL_CHANNELMODEIS - "<channel> <mode> <mode params>" */
1084 void CoreSessionEventProcessor::processIrcEvent324(IrcEvent *e)
1085 {
1086     processIrcEventMode(e);
1087 }
1088
1089
1090 /*  RPL_WHOISACCOUNT - "<nick> <account> :is authed as" */
1091 void CoreSessionEventProcessor::processIrcEvent330(IrcEvent *e)
1092 {
1093     // Though the ":is authed as" remark should always be there, we should handle cases when it's
1094     // not included, too.
1095     if (!checkParamCount(e, 2))
1096         return;
1097
1098     IrcUser *ircuser = e->network()->ircUser(e->params().at(0));
1099     if (ircuser) {
1100         ircuser->setAccount(e->params().at(1));
1101     }
1102 }
1103
1104
1105 /* RPL_NOTOPIC */
1106 void CoreSessionEventProcessor::processIrcEvent331(IrcEvent *e)
1107 {
1108     if (!checkParamCount(e, 1))
1109         return;
1110
1111     IrcChannel *chan = e->network()->ircChannel(e->params()[0]);
1112     if (chan)
1113         chan->setTopic(QString());
1114 }
1115
1116
1117 /* RPL_TOPIC */
1118 void CoreSessionEventProcessor::processIrcEvent332(IrcEvent *e)
1119 {
1120     if (!checkParamCount(e, 2))
1121         return;
1122
1123     IrcChannel *chan = e->network()->ircChannel(e->params()[0]);
1124     if (chan)
1125         chan->setTopic(e->params()[1]);
1126 }
1127
1128
1129 /*  RPL_WHOREPLY: "<channel> <user> <host> <server> <nick>
1130               ( "H" / "G" > ["*"] [ ( "@" / "+" ) ] :<hopcount> <real name>" */
1131 void CoreSessionEventProcessor::processIrcEvent352(IrcEvent *e)
1132 {
1133     if (!checkParamCount(e, 6))
1134         return;
1135
1136     QString channel = e->params()[0];
1137     // Store the nick separate from ircuser for AutoWho check below
1138     QString nick = e->params()[4];
1139     IrcUser *ircuser = e->network()->ircUser(nick);
1140     if (ircuser) {
1141         // Only process the WHO information if an IRC user exists.  Don't create an IRC user here;
1142         // there's no way to track when the user quits, which would leave a phantom IrcUser lying
1143         // around.
1144         // NOTE:  Whenever MONITOR support is introduced, the IrcUser will be created by an
1145         // RPL_MONONLINE numeric before any WHO commands are run.
1146         processWhoInformation(e->network(), channel, ircuser, e->params()[3], e->params()[1],
1147                 e->params()[2], e->params()[5], e->params().last().section(" ", 1));
1148     }
1149
1150     // Check if channel name has a who in progress.
1151     // If not, then check if user nickname has a who in progress.  Use nick directly; don't use
1152     // ircuser as that may be deleted (e.g. nick joins channel, leaves before WHO reply received).
1153     if (coreNetwork(e)->isAutoWhoInProgress(channel) ||
1154         (coreNetwork(e)->isAutoWhoInProgress(nick))) {
1155         e->setFlag(EventManager::Silent);
1156     }
1157 }
1158
1159
1160 /* RPL_NAMREPLY */
1161 void CoreSessionEventProcessor::processIrcEvent353(IrcEvent *e)
1162 {
1163     if (!checkParamCount(e, 3))
1164         return;
1165
1166     // param[0] is either "=", "*" or "@" indicating a public, private or secret channel
1167     // we don't use this information at the time beeing
1168     QString channelname = e->params()[1];
1169
1170     IrcChannel *channel = e->network()->ircChannel(channelname);
1171     if (!channel) {
1172         qWarning() << Q_FUNC_INFO << "Received unknown target channel:" << channelname;
1173         return;
1174     }
1175
1176     QStringList nicks;
1177     QStringList modes;
1178
1179     // Cache result of multi-prefix to avoid unneeded casts and lookups with each iteration.
1180     bool _useCapMultiPrefix = coreNetwork(e)->capEnabled(IrcCap::MULTI_PREFIX);
1181
1182     foreach(QString nick, e->params()[2].split(' ', QString::SkipEmptyParts)) {
1183         QString mode;
1184
1185         if (_useCapMultiPrefix) {
1186             // If multi-prefix is enabled, all modes will be sent in NAMES replies.
1187             // :hades.arpa 353 guest = #tethys :~&@%+aji &@Attila @+alyx +KindOne Argure
1188             // See: http://ircv3.net/specs/extensions/multi-prefix-3.1.html
1189             while (e->network()->prefixes().contains(nick[0])) {
1190                 // Mode found in 1 left-most character, add it to the list.
1191                 // Note: sending multiple modes may cause a warning in older clients.
1192                 // In testing, the clients still seemed to function fine.
1193                 mode.append(e->network()->prefixToMode(nick[0]));
1194                 // Remove this mode from the nick
1195                 nick = nick.remove(0, 1);
1196             }
1197         } else if (e->network()->prefixes().contains(nick[0])) {
1198             // Multi-prefix is disabled and a mode prefix was found.
1199             mode = e->network()->prefixToMode(nick[0]);
1200             nick = nick.mid(1);
1201         }
1202
1203         // If userhost-in-names capability is enabled, the following will be
1204         // in the form "nick!user@host" rather than "nick".  This works without
1205         // special handling as the following use nickFromHost() as needed.
1206         // See: http://ircv3.net/specs/extensions/userhost-in-names-3.2.html
1207
1208         nicks << nick;
1209         modes << mode;
1210     }
1211
1212     channel->joinIrcUsers(nicks, modes);
1213 }
1214
1215
1216 /*  RPL_WHOSPCRPL: "<yournick> 152 #<channel> ~<ident> <host> <servname> <nick>
1217                     ("H"/ "G") <account> :<realname>"
1218 <channel> is * if not specific to any channel
1219 <account> is * if not logged in
1220 Follows HexChat's usage of 'whox'
1221 See https://github.com/hexchat/hexchat/blob/c874a9525c9b66f1d5ddcf6c4107d046eba7e2c5/src/common/proto-irc.c#L750
1222 And http://faerion.sourceforge.net/doc/irc/whox.var*/
1223 void CoreSessionEventProcessor::processIrcEvent354(IrcEvent *e)
1224 {
1225     // First only check if at least one parameter exists.  Otherwise, it'll stop the result from
1226     // being shown if the user chooses different parameters.
1227     if (!checkParamCount(e, 1))
1228         return;
1229
1230     if (e->params()[0].toUInt() != IrcCap::ACCOUNT_NOTIFY_WHOX_NUM) {
1231         // Ignore WHOX replies without expected number for we have no idea what fields are specified
1232         return;
1233     }
1234
1235     // Now we're fairly certain this is supposed to be an automated WHOX.  Bail out if it doesn't
1236     // match what we require - 9 parameters.
1237     if (!checkParamCount(e, 9))
1238         return;
1239
1240     QString channel = e->params()[1];
1241     QString nick = e->params()[5];
1242     IrcUser *ircuser = e->network()->ircUser(nick);
1243     if (ircuser) {
1244         // Only process the WHO information if an IRC user exists.  Don't create an IRC user here;
1245         // there's no way to track when the user quits, which would leave a phantom IrcUser lying
1246         // around.
1247         // NOTE:  Whenever MONITOR support is introduced, the IrcUser will be created by an
1248         // RPL_MONONLINE numeric before any WHO commands are run.
1249         processWhoInformation(e->network(), channel, ircuser, e->params()[4], e->params()[2],
1250                 e->params()[3], e->params()[6], e->params().last());
1251         // Don't use .section(" ", 1) with WHOX replies, for there's no hopcount to trim out
1252
1253         // As part of IRCv3 account-notify, check account name
1254         // WHOX uses '0' to indicate logged-out, account-notify and extended-join uses '*'.
1255         QString newAccount = e->params()[7];
1256         if (newAccount != "0") {
1257             // Account logged in, set account name
1258             ircuser->setAccount(newAccount);
1259         } else {
1260             // Account logged out, set account name to logged-out
1261             ircuser->setAccount("*");
1262         }
1263     }
1264
1265     // Check if channel name has a who in progress.
1266     // If not, then check if user nickname has a who in progress.  Use nick directly; don't use
1267     // ircuser as that may be deleted (e.g. nick joins channel, leaves before WHO reply received).
1268     if (coreNetwork(e)->isAutoWhoInProgress(channel) ||
1269         (coreNetwork(e)->isAutoWhoInProgress(nick))) {
1270         e->setFlag(EventManager::Silent);
1271     }
1272 }
1273
1274
1275 void CoreSessionEventProcessor::processWhoInformation (Network *net, const QString &targetChannel, IrcUser *ircUser,
1276                             const QString &server, const QString &user, const QString &host,
1277                             const QString &awayStateAndModes, const QString &realname)
1278 {
1279     ircUser->setUser(user);
1280     ircUser->setHost(host);
1281     ircUser->setServer(server);
1282     ircUser->setRealName(realname);
1283
1284     bool away = awayStateAndModes.contains("G", Qt::CaseInsensitive);
1285     ircUser->setAway(away);
1286
1287     if (net->capEnabled(IrcCap::MULTI_PREFIX)) {
1288         // If multi-prefix is enabled, all modes will be sent in WHO replies.
1289         // :kenny.chatspike.net 352 guest #test grawity broken.symlink *.chatspike.net grawity H@%+ :0 Mantas M.
1290         // See: http://ircv3.net/specs/extensions/multi-prefix-3.1.html
1291         QString uncheckedModes = awayStateAndModes;
1292         QString validModes = QString();
1293         while (!uncheckedModes.isEmpty()) {
1294             // Mode found in 1 left-most character, add it to the list
1295             if (net->prefixes().contains(uncheckedModes[0])) {
1296                 validModes.append(net->prefixToMode(uncheckedModes[0]));
1297             }
1298             // Remove this mode from the list of unchecked modes
1299             uncheckedModes = uncheckedModes.remove(0, 1);
1300         }
1301
1302         // Some IRC servers decide to not follow the spec, returning only -some- of the user
1303         // modes in WHO despite listing them all in NAMES.  For now, assume it can only add
1304         // and not take away.  *sigh*
1305         if (!validModes.isEmpty()) {
1306             if (targetChannel != "*") {
1307                 // Channel-specific modes received, apply to given channel only
1308                 IrcChannel *ircChan = net->ircChannel(targetChannel);
1309                 if (ircChan) {
1310                     // Do one mode at a time
1311                     // TODO Better way of syncing this without breaking protocol?
1312                     for (int i = 0; i < validModes.count(); ++i) {
1313                         ircChan->addUserMode(ircUser, validModes.at(i));
1314                     }
1315                 }
1316             } else {
1317                 // Modes apply to the user everywhere
1318                 ircUser->addUserModes(validModes);
1319             }
1320         }
1321     }
1322 }
1323
1324
1325 /* ERR_NOSUCHCHANNEL - "<channel name> :No such channel" */
1326 void CoreSessionEventProcessor::processIrcEvent403(IrcEventNumeric *e)
1327 {
1328     // If this is the result of an AutoWho, hide it.  It's confusing to show to the user.
1329     // Though the ":No such channel" remark should always be there, we should handle cases when it's
1330     // not included, too.
1331     if (!checkParamCount(e, 1))
1332         return;
1333
1334     QString channelOrNick = e->params()[0];
1335     // Check if channel name has a who in progress.
1336     // If not, then check if user nick exists and has a who in progress.
1337     if (coreNetwork(e)->isAutoWhoInProgress(channelOrNick)) {
1338         qDebug() << "Channel/nick" << channelOrNick << "no longer exists during AutoWho, ignoring";
1339         e->setFlag(EventManager::Silent);
1340     }
1341 }
1342
1343 /* ERR_ERRONEUSNICKNAME */
1344 void CoreSessionEventProcessor::processIrcEvent432(IrcEventNumeric *e)
1345 {
1346     if (!checkParamCount(e, 1))
1347         return;
1348
1349     QString errnick;
1350     if (e->params().count() < 2) {
1351         // handle unreal-ircd bug, where unreal ircd doesnt supply a TARGET in ERR_ERRONEUSNICKNAME during registration phase:
1352         // nick @@@
1353         // :irc.scortum.moep.net 432  @@@ :Erroneous Nickname: Illegal characters
1354         // correct server reply:
1355         // :irc.scortum.moep.net 432 * @@@ :Erroneous Nickname: Illegal characters
1356         e->params().prepend(e->target());
1357         e->setTarget("*");
1358     }
1359     errnick = e->params()[0];
1360
1361     tryNextNick(e, errnick, true /* erroneus */);
1362 }
1363
1364
1365 /* ERR_NICKNAMEINUSE */
1366 void CoreSessionEventProcessor::processIrcEvent433(IrcEventNumeric *e)
1367 {
1368     if (!checkParamCount(e, 1))
1369         return;
1370
1371     QString errnick = e->params().first();
1372
1373     // if there is a problem while connecting to the server -> we handle it
1374     // but only if our connection has not been finished yet...
1375     if (!e->network()->currentServer().isEmpty())
1376         return;
1377
1378     tryNextNick(e, errnick);
1379 }
1380
1381
1382 /* ERR_UNAVAILRESOURCE */
1383 void CoreSessionEventProcessor::processIrcEvent437(IrcEventNumeric *e)
1384 {
1385     if (!checkParamCount(e, 1))
1386         return;
1387
1388     QString errnick = e->params().first();
1389
1390     // if there is a problem while connecting to the server -> we handle it
1391     // but only if our connection has not been finished yet...
1392     if (!e->network()->currentServer().isEmpty())
1393         return;
1394
1395     if (!e->network()->isChannelName(errnick))
1396         tryNextNick(e, errnick);
1397 }
1398
1399
1400 /* template
1401 void CoreSessionEventProcessor::processIrcEvent(IrcEvent *e) {
1402   if(!checkParamCount(e, 1))
1403     return;
1404
1405 }
1406 */
1407
1408 /* Handle signals from Netsplit objects  */
1409
1410 void CoreSessionEventProcessor::handleNetsplitJoin(Network *net,
1411     const QString &channel,
1412     const QStringList &users,
1413     const QStringList &modes,
1414     const QString &quitMessage)
1415 {
1416     IrcChannel *ircChannel = net->ircChannel(channel);
1417     if (!ircChannel) {
1418         return;
1419     }
1420     QList<IrcUser *> ircUsers;
1421     QStringList newModes = modes;
1422     QStringList newUsers = users;
1423
1424     foreach(const QString &user, users) {
1425         IrcUser *iu = net->ircUser(nickFromMask(user));
1426         if (iu)
1427             ircUsers.append(iu);
1428         else { // the user already quit
1429             int idx = users.indexOf(user);
1430             newUsers.removeAt(idx);
1431             newModes.removeAt(idx);
1432         }
1433     }
1434
1435     ircChannel->joinIrcUsers(ircUsers, newModes);
1436     NetworkSplitEvent *event = new NetworkSplitEvent(EventManager::NetworkSplitJoin, net, channel, newUsers, quitMessage);
1437     emit newEvent(event);
1438 }
1439
1440
1441 void CoreSessionEventProcessor::handleNetsplitQuit(Network *net, const QString &channel, const QStringList &users, const QString &quitMessage)
1442 {
1443     NetworkSplitEvent *event = new NetworkSplitEvent(EventManager::NetworkSplitQuit, net, channel, users, quitMessage);
1444     emit newEvent(event);
1445     foreach(QString user, users) {
1446         IrcUser *iu = net->ircUser(nickFromMask(user));
1447         if (iu)
1448             iu->quit();
1449     }
1450 }
1451
1452
1453 void CoreSessionEventProcessor::handleEarlyNetsplitJoin(Network *net, const QString &channel, const QStringList &users, const QStringList &modes)
1454 {
1455     IrcChannel *ircChannel = net->ircChannel(channel);
1456     if (!ircChannel) {
1457         qDebug() << "handleEarlyNetsplitJoin(): channel " << channel << " invalid";
1458         return;
1459     }
1460     QList<NetworkEvent *> events;
1461     QList<IrcUser *> ircUsers;
1462     QStringList newModes = modes;
1463
1464     foreach(QString user, users) {
1465         IrcUser *iu = net->updateNickFromMask(user);
1466         if (iu) {
1467             ircUsers.append(iu);
1468             // fake event for scripts that consume join events
1469             events << new IrcEvent(EventManager::IrcEventJoin, net, iu->hostmask(), QStringList() << channel);
1470         }
1471         else {
1472             newModes.removeAt(users.indexOf(user));
1473         }
1474     }
1475     ircChannel->joinIrcUsers(ircUsers, newModes);
1476     foreach(NetworkEvent *event, events) {
1477         event->setFlag(EventManager::Fake); // ignore this in here!
1478         emit newEvent(event);
1479     }
1480 }
1481
1482
1483 void CoreSessionEventProcessor::handleNetsplitFinished()
1484 {
1485     Netsplit *n = qobject_cast<Netsplit *>(sender());
1486     Q_ASSERT(n);
1487     QHash<QString, Netsplit *> splithash  = _netsplits.take(n->network());
1488     splithash.remove(splithash.key(n));
1489     if (splithash.count())
1490         _netsplits[n->network()] = splithash;
1491     n->deleteLater();
1492 }
1493
1494
1495 void CoreSessionEventProcessor::destroyNetsplits(NetworkId netId)
1496 {
1497     Network *net = coreSession()->network(netId);
1498     if (!net)
1499         return;
1500
1501     QHash<QString, Netsplit *> splits = _netsplits.take(net);
1502     qDeleteAll(splits);
1503 }
1504
1505
1506 /*******************************/
1507 /******** CTCP HANDLING ********/
1508 /*******************************/
1509
1510 void CoreSessionEventProcessor::processCtcpEvent(CtcpEvent *e)
1511 {
1512     if (e->testFlag(EventManager::Self))
1513         return;  // ignore ctcp events generated by user input
1514
1515     if (e->type() != EventManager::CtcpEvent || e->ctcpType() != CtcpEvent::Query)
1516         return;
1517
1518     handle(e->ctcpCmd(), Q_ARG(CtcpEvent *, e));
1519 }
1520
1521
1522 void CoreSessionEventProcessor::defaultHandler(const QString &ctcpCmd, CtcpEvent *e)
1523 {
1524     // This handler is only there to avoid warnings for unknown CTCPs
1525     Q_UNUSED(e);
1526     Q_UNUSED(ctcpCmd);
1527 }
1528
1529
1530 void CoreSessionEventProcessor::handleCtcpAction(CtcpEvent *e)
1531 {
1532     // This handler is only there to feed CLIENTINFO
1533     Q_UNUSED(e);
1534 }
1535
1536
1537 void CoreSessionEventProcessor::handleCtcpClientinfo(CtcpEvent *e)
1538 {
1539     QStringList supportedHandlers;
1540     foreach(QString handler, providesHandlers())
1541     supportedHandlers << handler.toUpper();
1542     qSort(supportedHandlers);
1543     e->setReply(supportedHandlers.join(" "));
1544 }
1545
1546
1547 // http://www.irchelp.org/irchelp/rfc/ctcpspec.html
1548 // http://en.wikipedia.org/wiki/Direct_Client-to-Client
1549 void CoreSessionEventProcessor::handleCtcpDcc(CtcpEvent *e)
1550 {
1551     // DCC support is unfinished, experimental and potentially dangerous, so make it opt-in
1552     if (!Quassel::isOptionSet("enable-experimental-dcc")) {
1553         quInfo() << "DCC disabled, start core with --enable-experimental-dcc if you really want to try it out";
1554         return;
1555     }
1556
1557     // normal:  SEND <filename> <ip> <port> [<filesize>]
1558     // reverse: SEND <filename> <ip> 0 <filesize> <token>
1559     QStringList params = e->param().split(' ');
1560     if (params.count()) {
1561         QString cmd = params[0].toUpper();
1562         if (cmd == "SEND") {
1563             if (params.count() < 4) {
1564                 qWarning() << "Invalid DCC SEND request:" << e;  // TODO emit proper error to client
1565                 return;
1566             }
1567             QString filename = params[1];
1568             QHostAddress address;
1569             quint16 port = params[3].toUShort();
1570             quint64 size = 0;
1571             QString numIp = params[2]; // this is either IPv4 as a 32 bit value, or IPv6 (which always contains a colon)
1572             if (numIp.contains(':')) { // IPv6
1573                 if (!address.setAddress(numIp)) {
1574                     qWarning() << "Invalid IPv6:" << numIp;
1575                     return;
1576                 }
1577             }
1578             else {
1579                 address.setAddress(numIp.toUInt());
1580             }
1581
1582             if (port == 0) { // Reverse DCC is indicated by a 0 port
1583                 emit newEvent(new MessageEvent(Message::Error, e->network(), tr("Reverse DCC SEND not supported"), e->prefix(), e->target(), Message::None, e->timestamp()));
1584                 return;
1585             }
1586             if (port < 1024) {
1587                 qWarning() << "Privileged port requested:" << port; // FIXME ask user if this is ok
1588             }
1589
1590
1591             if (params.count() > 4) { // filesize is optional
1592                 size = params[4].toULong();
1593             }
1594
1595             // TODO: check if target is the right thing to use for the partner
1596             CoreTransfer *transfer = new CoreTransfer(Transfer::Direction::Receive, e->target(), filename, address, port, size, this);
1597             coreSession()->signalProxy()->synchronize(transfer);
1598             coreSession()->transferManager()->addTransfer(transfer);
1599         }
1600         else {
1601             emit newEvent(new MessageEvent(Message::Error, e->network(), tr("DCC %1 not supported").arg(cmd), e->prefix(), e->target(), Message::None, e->timestamp()));
1602             return;
1603         }
1604     }
1605 }
1606
1607
1608 void CoreSessionEventProcessor::handleCtcpPing(CtcpEvent *e)
1609 {
1610     e->setReply(e->param().isNull() ? "" : e->param());
1611 }
1612
1613
1614 void CoreSessionEventProcessor::handleCtcpTime(CtcpEvent *e)
1615 {
1616     // Explicitly specify the Qt default DateTime format string to allow for modification
1617     // Qt::TextDate default roughly corresponds to...
1618     // > ddd MMM d yyyy HH:mm:ss
1619     //
1620     // See https://doc.qt.io/qt-5/qdatetime.html#toString
1621     // And https://doc.qt.io/qt-5/qt.html#DateFormat-enum
1622 #if QT_VERSION > 0x050000
1623     // Append the timezone identifier "t", so other other IRC users have a frame of reference for
1624     // the current timezone.  This could be figured out before by manually comparing to UTC, so this
1625     // is just convenience.
1626
1627     // Alas, "t" was only added in Qt 5
1628     e->setReply(QDateTime::currentDateTime().toString("ddd MMM d yyyy HH:mm:ss t"));
1629 #else
1630     e->setReply(QDateTime::currentDateTime().toString("ddd MMM d yyyy HH:mm:ss"));
1631 #endif
1632 }
1633
1634
1635 void CoreSessionEventProcessor::handleCtcpVersion(CtcpEvent *e)
1636 {
1637     // Deliberately do not translate project name
1638     e->setReply(QString("Quassel IRC %1 (version date %2) -- https://www.quassel-irc.org")
1639                 .arg(Quassel::buildInfo().plainVersionString)
1640                 .arg(Quassel::buildInfo().commitDate.isEmpty() ?
1641                       "unknown" : tryFormatUnixEpoch(Quassel::buildInfo().commitDate)));
1642 }