Event backend porting

[quassel.git] / src / core / coresessioneventprocessor.cpp

diff --git a/src/core/coresessioneventprocessor.cpp b/src/core/coresessioneventprocessor.cpp
index 048913f..cb11691 100644 (file)
--- a/src/core/coresessioneventprocessor.cpp
+++ b/src/core/coresessioneventprocessor.cpp
@@ -25,6 +25,7 @@
 #include "coresession.h"
 #include "ircevent.h"
 #include "ircuser.h"
+#include "messageevent.h"
 
 CoreSessionEventProcessor::CoreSessionEventProcessor(CoreSession *session)
   : QObject(session),
@@ -47,6 +48,28 @@ bool CoreSessionEventProcessor::checkParamCount(IrcEvent *e, int minParams) {
   return true;
 }
 
+void CoreSessionEventProcessor::tryNextNick(NetworkEvent *e, const QString &errnick, bool erroneus) {
+  QStringList desiredNicks = coreSession()->identity(e->network()->identity())->nicks();
+  int nextNickIdx = desiredNicks.indexOf(errnick) + 1;
+  QString nextNick;
+  if(nextNickIdx > 0 && desiredNicks.size() > nextNickIdx) {
+    nextNick = desiredNicks[nextNickIdx];
+  } else {
+    if(erroneus) {
+      // FIXME Make this an ErrorEvent or something like that, so it's translated in the client
+      MessageEvent *msgEvent = new MessageEvent(Message::Error, e->network(),
+                                                tr("No free and valid nicks in nicklist found. use: /nick <othernick> to continue"),
+                                                QString(), QString(), Message::None, e->timestamp());
+      coreSession()->eventManager()->sendEvent(msgEvent);
+      return;
+    } else {
+      nextNick = errnick + "_";
+    }
+  }
+  // FIXME Use a proper output event for this
+  coreNetwork(e)->putRawLine("NICK " + coreNetwork(e)->encodeServerString(nextNick));
+}
+
 void CoreSessionEventProcessor::processIrcEventNumeric(IrcEventNumeric *e) {
   switch(e->number()) {
 
@@ -390,6 +413,109 @@ void CoreSessionEventProcessor::processIrcEvent332(IrcEvent *e) {
     chan->setTopic(e->params()[1]);
 }
 
+/*  RPL_WHOREPLY: "<channel> <user> <host> <server> <nick>
+              ( "H" / "G" > ["*"] [ ( "@" / "+" ) ] :<hopcount> <real name>" */
+void CoreSessionEventProcessor::processIrcEvent352(IrcEvent *e) {
+  if(!checkParamCount(e, 6))
+    return;
+
+  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].startsWith("G");
+    ircuser->setAway(away);
+    ircuser->setServer(e->params()[3]);
+    ircuser->setRealName(e->params().last().section(" ", 1));
+  }
+
+  if(coreNetwork(e)->isAutoWhoInProgress(channel))
+    e->setFlag(EventManager::Silent);
+}
+
+/* RPL_NAMREPLY */
+void CoreSessionEventProcessor::processIrcEvent353(IrcEvent *e) {
+  if(!checkParamCount(e, 3))
+    return;
+
+  // param[0] is either "=", "*" or "@" indicating a public, private or secret channel
+  // we don't use this information at the time beeing
+  QString channelname = e->params()[1];
+
+  IrcChannel *channel = e->network()->ircChannel(channelname);
+  if(!channel) {
+    qWarning() << Q_FUNC_INFO << "Received unknown target channel:" << channelname;
+    return;
+  }
+
+  QStringList nicks;
+  QStringList modes;
+
+  foreach(QString nick, e->params()[2].split(' ')) {
+    QString mode;
+
+    if(e->network()->prefixes().contains(nick[0])) {
+      mode = e->network()->prefixToMode(nick[0]);
+      nick = nick.mid(1);
+    }
+
+    nicks << nick;
+    modes << mode;
+  }
+
+  channel->joinIrcUsers(nicks, modes);
+}
+
+/* ERR_ERRONEUSNICKNAME */
+void CoreSessionEventProcessor::processIrcEvent432(IrcEventNumeric *e) {
+  QString errnick;
+  if(e->params().count() < 2) {
+    // handle unreal-ircd bug, where unreal ircd doesnt supply a TARGET in ERR_ERRONEUSNICKNAME during registration phase:
+    // nick @@@
+    // :irc.scortum.moep.net 432  @@@ :Erroneous Nickname: Illegal characters
+    // correct server reply:
+    // :irc.scortum.moep.net 432 * @@@ :Erroneous Nickname: Illegal characters
+    e->params().prepend(e->target());
+    e->setTarget("*");
+  }
+  errnick = e->params()[0];
+
+  tryNextNick(e, errnick, true /* erroneus */);
+}
+
+/* ERR_NICKNAMEINUSE */
+void CoreSessionEventProcessor::processIrcEvent433(IrcEventNumeric *e) {
+  if(!checkParamCount(e, 1))
+    return;
+
+  QString errnick = e->params().first();
+
+  // if there is a problem while connecting to the server -> we handle it
+  // but only if our connection has not been finished yet...
+  if(!e->network()->currentServer().isEmpty())
+    return;
+
+  tryNextNick(e, errnick);
+}
+
+/* ERR_UNAVAILRESOURCE */
+void CoreSessionEventProcessor::processIrcEvent437(IrcEventNumeric *e) {
+  if(!checkParamCount(e, 1))
+    return;
+
+  QString errnick = e->params().first();
+
+  // if there is a problem while connecting to the server -> we handle it
+  // but only if our connection has not been finished yet...
+  if(!e->network()->currentServer().isEmpty())
+    return;
+
+  if(!e->network()->isChannelName(errnick))
+    tryNextNick(e, errnick);
+}
+
 /* template
 void CoreSessionEventProcessor::processIrcEvent(IrcEvent *e) {
   if(!checkParamCount(e, 1))
@@ -397,3 +523,4 @@ void CoreSessionEventProcessor::processIrcEvent(IrcEvent *e) {
 
 }
 */
+