X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcoresessioneventprocessor.cpp;h=8acae81cb9f842ea75a138031d45393f140d22f1;hp=82da78174a0ebd4fb6a9eb629793c7b12030f0b5;hb=cbbf4720fc10f0cb78eca71fe6a3f859cbe7a3c7;hpb=46fba5edfabcb55103cd3fdbfc5ce85c9b592dd6 diff --git a/src/core/coresessioneventprocessor.cpp b/src/core/coresessioneventprocessor.cpp index 82da7817..8acae81c 100644 --- a/src/core/coresessioneventprocessor.cpp +++ b/src/core/coresessioneventprocessor.cpp @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2015 by the Quassel Project * + * Copyright (C) 2005-2016 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -37,6 +37,9 @@ # include "keyevent.h" #endif +// IRCv3 capabilities +#include "irccap.h" + CoreSessionEventProcessor::CoreSessionEventProcessor(CoreSession *session) : BasicHandler("handleCtcp", session), _coreSession(session) @@ -94,14 +97,21 @@ void CoreSessionEventProcessor::processIrcEventNumeric(IrcEventNumeric *e) switch (e->number()) { // SASL authentication replies // See: http://ircv3.net/specs/extensions/sasl-3.1.html + + //case 900: // RPL_LOGGEDIN + //case 901: // RPL_LOGGEDOUT + // Don't use 900 or 901 for updating the local hostmask. Unreal 3.2 gives it as the IP address + // even when cloaked. + // Every other reply should result in moving on // TODO Handle errors to stop connection if appropriate + case 902: // ERR_NICKLOCKED case 903: // RPL_SASLSUCCESS case 904: // ERR_SASLFAIL case 905: // ERR_SASLTOOLONG case 906: // ERR_SASLABORTED case 907: // ERR_SASLALREADY // Move on to the next capability - sendNextCap(e->network()); + coreNetwork(e)->sendNextCap(); break; default: @@ -140,24 +150,6 @@ void CoreSessionEventProcessor::processIrcEventAuthenticate(IrcEvent *e) #endif } -void CoreSessionEventProcessor::sendNextCap(Network *net) -{ - CoreNetwork *coreNet = qobject_cast(net); - if (coreNet->capNegotiationInProgress()) { - // Request the next capability and remove it from the list - // Handle one at a time so one capability failing won't NAK all of 'em - coreNet->putRawLine(coreNet->serverEncode(QString("CAP REQ :%1").arg(coreNet->takeQueuedCap()))); - } else { - // If SASL requested but not available, print a warning - if (coreNet->networkInfo().useSasl && !coreNet->useCapSASL()) - emit newEvent(new MessageEvent(Message::Error, net, tr("SASL authentication not supported by server, continuing without"), QString(), QString(), Message::None, QDateTime::currentDateTimeUtc())); - - // No pending desired capabilities, end negotiation - coreNet->putRawLine(coreNet->serverEncode(QString("CAP END"))); - emit newEvent(new MessageEvent(Message::Server, net, tr("Capability negotiation finished"), QString(), QString(), Message::None, QDateTime::currentDateTimeUtc())); - } -} - void CoreSessionEventProcessor::processIrcEventCap(IrcEvent *e) { // Handle capability negotiation @@ -165,7 +157,9 @@ void CoreSessionEventProcessor::processIrcEventCap(IrcEvent *e) // And: http://ircv3.net/specs/core/capability-negotiation-3.1.html if (e->params().count() >= 3) { CoreNetwork *coreNet = coreNetwork(e); - if (e->params().at(1).compare("LS", Qt::CaseInsensitive) == 0) { + QString capCommand = e->params().at(1).trimmed().toUpper(); + if (capCommand == "LS" || capCommand == "NEW") { + // Either we've gotten a list of capabilities, or new capabilities we may want // Server: CAP * LS * :multi-prefix extended-join account-notify batch invite-notify tls // Server: CAP * LS * :cap-notify server-time example.org/dummy-cap=dummyvalue example.org/second-dummy-cap // Server: CAP * LS :userhost-in-names sasl=EXTERNAL,DH-AES,DH-BLOWFISH,ECDSA-NIST256P-CHALLENGE,PLAIN @@ -180,78 +174,60 @@ void CoreSessionEventProcessor::processIrcEventCap(IrcEvent *e) capListFinished = true; availableCaps = e->params().at(2).split(' '); } - // We know what capabilities are available, request what we want. + // Store what capabilities are available QStringList availableCapPair; - bool queueCurrentCap; for (int i = 0; i < availableCaps.count(); ++i) { // Capability may include values, e.g. CAP * LS :multi-prefix sasl=EXTERNAL availableCapPair = availableCaps[i].trimmed().split('='); - queueCurrentCap = false; - if (availableCapPair.at(0).startsWith("sasl")) { - // Only request SASL if it's enabled - if (coreNet->networkInfo().useSasl) - queueCurrentCap = true; - } else if (availableCapPair.at(0).startsWith("away-notify") || - availableCapPair.at(0).startsWith("account-notify") || - availableCapPair.at(0).startsWith("extended-join") || - availableCapPair.at(0).startsWith("userhost-in-names") || - availableCapPair.at(0).startsWith("multi-prefix")) { - // Always request these capabilities if available - queueCurrentCap = true; - } - if (queueCurrentCap) { - if(availableCapPair.count() >= 2) - coreNet->queuePendingCap(availableCapPair.at(0).trimmed(), availableCapPair.at(1).trimmed()); - else - coreNet->queuePendingCap(availableCapPair.at(0).trimmed()); + if(availableCapPair.count() >= 2) { + coreNet->addCap(availableCapPair.at(0).trimmed().toLower(), availableCapPair.at(1).trimmed()); + } else { + coreNet->addCap(availableCapPair.at(0).trimmed().toLower()); } } + // Begin capability requests when capability listing complete - if (capListFinished) { - emit newEvent(new MessageEvent(Message::Server, e->network(), tr("Negotiating capabilities..."), QString(), QString(), Message::None, e->timestamp())); - sendNextCap(coreNet); - } - } else if (e->params().at(1).compare("ACK", Qt::CaseInsensitive) == 0) { + if (capListFinished) + coreNet->beginCapNegotiation(); + } else if (capCommand == "ACK") { // Server: CAP * ACK :multi-prefix sasl - // Got the capability we want, enable, handle as needed. + // Got the capability we want, handle as needed. // As only one capability is requested at a time, no need to split - // Lower-case the list to make later comparisons easier - // Capability may include values, e.g. CAP * LS :multi-prefix sasl=EXTERNAL - QStringList acceptedCap = e->params().at(2).trimmed().split('='); + QString acceptedCap = e->params().at(2).trimmed().toLower(); // Mark this cap as accepted - if(acceptedCap.count() >= 2) - coreNet->addCap(acceptedCap.at(0), acceptedCap.at(1)); - else - coreNet->addCap(acceptedCap.at(0)); - - // Handle special cases - if (acceptedCap.at(0).startsWith("sasl")) { - // Freenode (at least) sends "sasl " with a trailing space for some reason! - // if the current identity has a cert set, use SASL EXTERNAL - // FIXME use event - // TODO If value of sasl capability is not empty, limit to accepted -#ifdef HAVE_SSL - if (!coreNet->identityPtr()->sslCert().isNull()) { - coreNet->putRawLine(coreNet->serverEncode("AUTHENTICATE EXTERNAL")); - } else { -#endif - // Only working with PLAIN atm, blowfish later - coreNet->putRawLine(coreNet->serverEncode("AUTHENTICATE PLAIN")); -#ifdef HAVE_SSL - } -#endif - } else { - // Special handling not needed, move on to next cap - sendNextCap(coreNet); + coreNet->acknowledgeCap(acceptedCap); + + if (!coreNet->capsRequiringConfiguration.contains(acceptedCap)) { + // Some capabilities (e.g. SASL) require further messages to finish. If so, do NOT + // send the next capability; it will be handled elsewhere in CoreNetwork. + // Otherwise, move on to the next capability + coreNet->sendNextCap(); + } + } else if (capCommand == "NAK" || capCommand == "DEL") { + // Either something went wrong with this capability, or it is no longer supported + // > For CAP NAK + // Server: CAP * NAK :multi-prefix sasl + // > For CAP DEL + // Server: :irc.example.com CAP modernclient DEL :multi-prefix sasl + // CAP NAK and CAP DEL replies are always single-line + + QStringList removedCaps; + removedCaps = e->params().at(2).split(' '); + + // Store what capability was denied or removed + QString removedCap; + for (int i = 0; i < removedCaps.count(); ++i) { + removedCap = removedCaps[i].trimmed().toLower(); + // Mark this cap as removed + coreNet->removeCap(removedCap); + } + + if (capCommand == "NAK") { + // Continue negotiation when capability listing complete only if this is the result + // of a denied cap, not a removed cap + coreNet->sendNextCap(); } - } else if (e->params().at(1).compare("NAK", Qt::CaseInsensitive) == 0) { - // Something went wrong with this capability, disable, go to next cap - // As only one capability is requested at a time, no need to split - // Lower-case the list to make later comparisons easier - QString deniedCap = e->params().at(2).trimmed(); - coreNet->removeCap(deniedCap); - sendNextCap(coreNet); } } } @@ -266,16 +242,15 @@ void CoreSessionEventProcessor::processIrcEventAccount(IrcEvent *e) IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix()); if (ircuser) { - // FIXME Keep track of authed user account, requires adding support to ircuser.h/cpp - /* - if (e->params().at(0) != "*") { - // Account logged in - qDebug() << "account-notify:" << ircuser->nick() << "logged in to" << e->params().at(0); + QString newAccount = e->params().at(0); + // WHOX uses '0' to indicate logged-out, account-notify uses '*' + if (newAccount != "*") { + // Account logged in, set account name + ircuser->setAccount(newAccount); } else { - // Account logged out - qDebug() << "account-notify:" << ircuser->nick() << "logged out"; + // Account logged out, set account name to logged-out + ircuser->setAccount("*"); } - */ } else { qDebug() << "Received account-notify data for unknown user" << e->prefix(); } @@ -301,6 +276,23 @@ void CoreSessionEventProcessor::processIrcEventAway(IrcEvent *e) } } +/* IRCv3 chghost - ":nick!user@host CHGHOST newuser new.host.goes.here" */ +void CoreSessionEventProcessor::processIrcEventChghost(IrcEvent *e) +{ + if (!checkParamCount(e, 2)) + return; + + IrcUser *ircuser = e->network()->updateNickFromMask(e->prefix()); + if (ircuser) { + // Update with new user/hostname information. setUser/setHost handles checking what + // actually changed. + ircuser->setUser(e->params().at(0)); + ircuser->setHost(e->params().at(1)); + } else { + qDebug() << "Received chghost data for unknown user" << e->prefix(); + } +} + void CoreSessionEventProcessor::processIrcEventInvite(IrcEvent *e) { if (checkParamCount(e, 2)) { @@ -321,7 +313,7 @@ void CoreSessionEventProcessor::processIrcEventJoin(IrcEvent *e) QString channel = e->params()[0]; IrcUser *ircuser = net->updateNickFromMask(e->prefix()); - if (net->useCapExtendedJoin()) { + if (net->capEnabled(IrcCap::EXTENDED_JOIN)) { if (!checkParamCount(e, 3)) return; // If logged in, :nick!user@host JOIN #channelname accountname :Real Name @@ -341,8 +333,8 @@ void CoreSessionEventProcessor::processIrcEventJoin(IrcEvent *e) // If using away-notify, check new users. Works around buggy IRC servers // forgetting to send :away messages for users who join channels when away. - if (coreNetwork(e)->useCapAwayNotify()) { - coreNetwork(e)->queueAutoWhoOneshot(ircuser->nick()); + if (net->capEnabled(IrcCap::AWAY_NOTIFY)) { + net->queueAutoWhoOneshot(ircuser->nick()); } if (!handledByNetsplit) @@ -882,6 +874,19 @@ void CoreSessionEventProcessor::processIrcEvent324(IrcEvent *e) } +/* RPL_WHOISACCOUNT: " :is authed as */ +void CoreSessionEventProcessor::processIrcEvent330(IrcEvent *e) +{ + if (!checkParamCount(e, 3)) + return; + + IrcUser *ircuser = e->network()->ircUser(e->params().at(0)); + if (ircuser) { + ircuser->setAccount(e->params().at(1)); + } +} + + /* RPL_NOTOPIC */ void CoreSessionEventProcessor::processIrcEvent331(IrcEvent *e) { @@ -916,49 +921,8 @@ void CoreSessionEventProcessor::processIrcEvent352(IrcEvent *e) QString channel = e->params()[0]; IrcUser *ircuser = e->network()->ircUser(e->params()[4]); if (ircuser) { - ircuser->setUser(e->params()[1]); - ircuser->setHost(e->params()[2]); - - bool away = e->params()[5].contains("G", Qt::CaseInsensitive); - ircuser->setAway(away); - ircuser->setServer(e->params()[3]); - ircuser->setRealName(e->params().last().section(" ", 1)); - - if (coreNetwork(e)->useCapMultiPrefix()) { - // If multi-prefix is enabled, all modes will be sent in WHO replies. - // :kenny.chatspike.net 352 guest #test grawity broken.symlink *.chatspike.net grawity H@%+ :0 Mantas M. - // See: http://ircv3.net/specs/extensions/multi-prefix-3.1.html - QString uncheckedModes = e->params()[5]; - QString validModes = QString(); - while (!uncheckedModes.isEmpty()) { - // Mode found in 1 left-most character, add it to the list - if (e->network()->prefixes().contains(uncheckedModes[0])) { - validModes.append(e->network()->prefixToMode(uncheckedModes[0])); - } - // Remove this mode from the list of unchecked modes - uncheckedModes = uncheckedModes.remove(0, 1); - } - - // Some IRC servers decide to not follow the spec, returning only -some- of the user - // modes in WHO despite listing them all in NAMES. For now, assume it can only add - // and not take away. *sigh* - if (!validModes.isEmpty()) { - if (channel != "*") { - // Channel-specific modes received, apply to given channel only - IrcChannel *ircChan = e->network()->ircChannel(channel); - if (ircChan) { - // Do one mode at a time - // TODO Better way of syncing this without breaking protocol? - for (int i = 0; i < validModes.count(); ++i) { - ircChan->addUserMode(ircuser, validModes.at(i)); - } - } - } else { - // Modes apply to the user everywhere - ircuser->addUserModes(validModes); - } - } - } + processWhoInformation(e->network(), channel, ircuser, e->params()[3], e->params()[1], + e->params()[2], e->params()[5], e->params().last().section(" ", 1)); } // Check if channel name has a who in progress. @@ -990,7 +954,7 @@ void CoreSessionEventProcessor::processIrcEvent353(IrcEvent *e) QStringList modes; // Cache result of multi-prefix to avoid unneeded casts and lookups with each iteration. - bool _useCapMultiPrefix = coreNetwork(e)->useCapMultiPrefix(); + bool _useCapMultiPrefix = coreNetwork(e)->capEnabled(IrcCap::MULTI_PREFIX); foreach(QString nick, e->params()[2].split(' ', QString::SkipEmptyParts)) { QString mode; @@ -1026,6 +990,124 @@ void CoreSessionEventProcessor::processIrcEvent353(IrcEvent *e) } +/* RPL_WHOSPCRPL: " 152 # ~ + ("H"/ "G") :" + is * if not specific to any channel + is * if not logged in +Follows HexChat's usage of 'whox' +See https://github.com/hexchat/hexchat/blob/c874a9525c9b66f1d5ddcf6c4107d046eba7e2c5/src/common/proto-irc.c#L750 +And http://faerion.sourceforge.net/doc/irc/whox.var*/ +void CoreSessionEventProcessor::processIrcEvent354(IrcEvent *e) +{ + // First only check if at least one parameter exists. Otherwise, it'll stop the result from + // being shown if the user chooses different parameters. + if (!checkParamCount(e, 1)) + return; + + if (e->params()[0].toUInt() != IrcCap::ACCOUNT_NOTIFY_WHOX_NUM) { + // Ignore WHOX replies without expected number for we have no idea what fields are specified + return; + } + + // Now we're fairly certain this is supposed to be an automated WHOX. Bail out if it doesn't + // match what we require - 9 parameters. + if (!checkParamCount(e, 9)) + return; + + QString channel = e->params()[1]; + IrcUser *ircuser = e->network()->ircUser(e->params()[5]); + if (ircuser) { + processWhoInformation(e->network(), channel, ircuser, e->params()[4], e->params()[2], + e->params()[3], e->params()[6], e->params().last()); + // Don't use .section(" ", 1) with WHOX replies, for there's no hopcount to trim out + + // As part of IRCv3 account-notify, check account name + // WHOX uses '0' to indicate logged-out, account-notify uses '*' + QString newAccount = e->params()[7]; + if (newAccount != "0") { + // Account logged in, set account name + ircuser->setAccount(newAccount); + } else { + // Account logged out, set account name to logged-out + ircuser->setAccount("*"); + } + } + + // Check if channel name has a who in progress. + // If not, then check if user nick exists and has a who in progress. + if (coreNetwork(e)->isAutoWhoInProgress(channel) || + (ircuser && coreNetwork(e)->isAutoWhoInProgress(ircuser->nick()))) { + e->setFlag(EventManager::Silent); + } +} + + +void CoreSessionEventProcessor::processWhoInformation (Network *net, const QString &targetChannel, IrcUser *ircUser, + const QString &server, const QString &user, const QString &host, + const QString &awayStateAndModes, const QString &realname) +{ + ircUser->setUser(user); + ircUser->setHost(host); + ircUser->setServer(server); + ircUser->setRealName(realname); + + bool away = awayStateAndModes.contains("G", Qt::CaseInsensitive); + ircUser->setAway(away); + + if (net->capEnabled(IrcCap::MULTI_PREFIX)) { + // If multi-prefix is enabled, all modes will be sent in WHO replies. + // :kenny.chatspike.net 352 guest #test grawity broken.symlink *.chatspike.net grawity H@%+ :0 Mantas M. + // See: http://ircv3.net/specs/extensions/multi-prefix-3.1.html + QString uncheckedModes = awayStateAndModes; + QString validModes = QString(); + while (!uncheckedModes.isEmpty()) { + // Mode found in 1 left-most character, add it to the list + if (net->prefixes().contains(uncheckedModes[0])) { + validModes.append(net->prefixToMode(uncheckedModes[0])); + } + // Remove this mode from the list of unchecked modes + uncheckedModes = uncheckedModes.remove(0, 1); + } + + // Some IRC servers decide to not follow the spec, returning only -some- of the user + // modes in WHO despite listing them all in NAMES. For now, assume it can only add + // and not take away. *sigh* + if (!validModes.isEmpty()) { + if (targetChannel != "*") { + // Channel-specific modes received, apply to given channel only + IrcChannel *ircChan = net->ircChannel(targetChannel); + if (ircChan) { + // Do one mode at a time + // TODO Better way of syncing this without breaking protocol? + for (int i = 0; i < validModes.count(); ++i) { + ircChan->addUserMode(ircUser, validModes.at(i)); + } + } + } else { + // Modes apply to the user everywhere + ircUser->addUserModes(validModes); + } + } + } +} + + +/* ERR_NOSUCHCHANNEL - " :No such channel" */ +void CoreSessionEventProcessor::processIrcEvent403(IrcEventNumeric *e) +{ + // If this is the result of an AutoWho, hide it. It's confusing to show to the user. + if (!checkParamCount(e, 2)) + return; + + QString channelOrNick = e->params()[0]; + // Check if channel name has a who in progress. + // If not, then check if user nick exists and has a who in progress. + if (coreNetwork(e)->isAutoWhoInProgress(channelOrNick)) { + qDebug() << "Channel/nick" << channelOrNick << "no longer exists during AutoWho, ignoring"; + e->setFlag(EventManager::Silent); + } +} + /* ERR_ERRONEUSNICKNAME */ void CoreSessionEventProcessor::processIrcEvent432(IrcEventNumeric *e) { @@ -1306,5 +1388,5 @@ void CoreSessionEventProcessor::handleCtcpTime(CtcpEvent *e) void CoreSessionEventProcessor::handleCtcpVersion(CtcpEvent *e) { e->setReply(QString("Quassel IRC %1 (built on %2) -- http://www.quassel-irc.org") - .arg(Quassel::buildInfo().plainVersionString).arg(Quassel::buildInfo().buildDate)); + .arg(Quassel::buildInfo().plainVersionString).arg(Quassel::buildInfo().commitDate)); }