X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcore%2Fircparser.cpp;h=605dd2e81d876e1f037cd1b6acc3302dbb1592ff;hb=88b350153eb364853e75d237d3eed2dfaf839d59;hp=34e693d6aab0dae0bba8fbd58dd0317e5c539451;hpb=96cd8441f9ab217b1d3c2ba0f2899ef64ca781e4;p=quassel.git diff --git a/src/core/ircparser.cpp b/src/core/ircparser.cpp index 34e693d6..605dd2e8 100644 --- a/src/core/ircparser.cpp +++ b/src/core/ircparser.cpp @@ -34,7 +34,7 @@ IrcParser::IrcParser(CoreSession *session) : QObject(session), _coreSession(session) { - + connect(this, SIGNAL(newEvent(Event *)), coreSession()->eventManager(), SLOT(postEvent(Event *))); } bool IrcParser::checkParamCount(const QString &cmd, const QList ¶ms, int minParams) { @@ -50,12 +50,18 @@ QByteArray IrcParser::decrypt(Network *network, const QString &bufferName, const if(message.isEmpty()) return message; + if(!Cipher::neededFeaturesAvailable()) + return message; + Cipher *cipher = qobject_cast(network)->cipher(bufferName); if(!cipher) return message; return isTopic? cipher->decryptTopic(message) : cipher->decrypt(message); #else + Q_UNUSED(network); + Q_UNUSED(bufferName); + Q_UNUSED(isTopic); return message; #endif } @@ -130,16 +136,18 @@ void IrcParser::processNetworkIncoming(NetworkDataEvent *e) { QList events; EventManager::EventType type = EventManager::Invalid; - // numeric replies have the target as first param (RFC 2812 - 2.4). this is usually our own nick. Remove this! uint num = cmd.toUInt(); if(num > 0) { + // numeric reply if(params.count() == 0) { qWarning() << "Message received from server violates RFC and is ignored!" << msg; return; } + // numeric replies have the target as first param (RFC 2812 - 2.4). this is usually our own nick. Remove this! target = net->serverDecode(params.takeFirst()); type = EventManager::IrcEventNumeric; } else { + // any other irc command QString typeName = QLatin1String("IrcEvent") + cmd.at(0).toUpper() + cmd.mid(1).toLower(); type = eventManager()->eventTypeByName(typeName); if(type == EventManager::Invalid) { @@ -174,8 +182,7 @@ void IrcParser::processNetworkIncoming(NetworkDataEvent *e) { msg = decrypt(net, target, msg); - events << new IrcEventRawMessage(EventManager::IrcEventRawPrivmsg, net, prefix, target, msg); - //events << new MessageEvent(Message::Plain, net, net->channelDecode(target, msg), target, prefix); + events << new IrcEventRawMessage(EventManager::IrcEventRawPrivmsg, net, msg, prefix, target, e->timestamp()); } } break; @@ -200,7 +207,7 @@ void IrcParser::processNetworkIncoming(NetworkDataEvent *e) { CoreIrcChannel *chan = static_cast(net->ircChannel(channelname)); // we only have CoreIrcChannels in the core, so this cast is safe if(chan && !chan->receivedWelcomeMsg()) { chan->setReceivedWelcomeMsg(); - events << new MessageEvent(Message::Notice, net, decMsg, channelname, prefix); + events << new MessageEvent(Message::Notice, net, decMsg, prefix, channelname, Message::None, e->timestamp()); continue; } } @@ -214,7 +221,7 @@ void IrcParser::processNetworkIncoming(NetworkDataEvent *e) { if(!net->isChannelName(target)) target = nickFromMask(prefix); } - events << new IrcEventRawMessage(EventManager::IrcEventRawNotice, net, prefix, target, msg); + events << new IrcEventRawMessage(EventManager::IrcEventRawNotice, net, params[1], prefix, target, e->timestamp()); } } break; @@ -290,10 +297,11 @@ void IrcParser::processNetworkIncoming(NetworkDataEvent *e) { else event = new IrcEvent(type, net, prefix); event->setParams(decParams); + event->setTimestamp(e->timestamp()); events << event; } foreach(Event *event, events) { - coreSession()->eventManager()->sendEvent(event); + emit newEvent(event); } }