/*
 * Copyright © 2005-2006 William Pitcock, et al.
 * Rights to this code are documented in doc/pod/license.pod.
 *
 * This file contains protocol support for P10 ircd's.
 * Some sources used: Run's documentation, beware's description,
 * raw data sent by nefarious.
 *
 * $Id: nefarious.C,v 1.6 2007/09/09 20:05:52 pippijn Exp $
 */

#include "atheme.h"
#include "servers.h"
#include <account/myuser.h>
#include "uplink.h"
#include "pmodule.h"
#include "protocol/nefarious.h"

static char const rcsid[] = "$Id: nefarious.C,v 1.6 2007/09/09 20:05:52 pippijn Exp $";

/* *INDENT-OFF* */

namespace protocol
{
  static ircd_t Nefarious = {
    "Nefarious IRCU 0.4.0 or later",              /* IRCd name */
    "$",                                          /* TLD Prefix, used by Global. */
    true,                                         /* Whether or not we use IRCNet/TS6 UID */
    false,                                        /* Whether or not we use RCOMMAND */
    false,                                        /* Whether or not we support channel owners. */
    false,                                        /* Whether or not we support channel protection. */
    true,                                         /* Whether or not we support halfops. */
    true,                                         /* Whether or not we use P10 */
    true,                                         /* Whether or not we use vhosts. */
    CMODE_PERM|CMODE_OPERONLY|CMODE_ADMONLY,      /* Oper-only cmodes */
    0,                                            /* Integer flag for owner channel flag. */
    0,                                            /* Integer flag for protect channel flag. */
    CMODE_HALFOP,                                 /* Integer flag for halfops. */
    "+",                                          /* Mode we set for owner. */
    "+",                                          /* Mode we set for protect. */
    "+",                                          /* Mode we set for halfops. */
    PROTOCOL_NEFARIOUS,                           /* Protocol type */
    CMODE_PERM,                                   /* Permanent cmodes */
    "be",                                         /* Ban-like cmodes */
    'e',                                          /* Except mchar */
    'e',                                          /* Invex mchar (+e also exempts from +i in Nefarious) */
    IRCD_CIDR_BANS                                /* Flags */
  };
  
  struct nefarious_handler : handler
  {
    nefarious_handler ();
    virtual ~nefarious_handler ();
  
    virtual unsigned int server_login (void);
    virtual void introduce_nick (user_t *u);
    virtual void invite_sts (user_t *source, user_t *target, channel_t *channel);
    virtual void quit_sts (user_t *u, char const * const reason);
    virtual void wallops_sts (char const * const text);
    virtual void join_sts (channel_t *c, user_t *u, bool isnew, char const * const modes);
    virtual void kick (char const * const from, char const * const channel, char const * const to, char const * const reason);
    virtual void privmsg (char const * const from, char const * const target, char const * const fmt, ...);
    virtual void notice_user_sts (user_t *from, user_t *target, char const * const text);
    virtual void notice_global_sts (user_t *from, char const * const mask, char const * const text);
    virtual void notice_channel_sts (user_t *from, channel_t *target, char const * const text);
    virtual void wallchops (user_t *sender, channel_t *channel, char const * const message);
    virtual void numeric_sts (char const * const from, int numeric, char const * const target, char const * const fmt, ...);
    virtual void skill (char const * const from, char const * const nick, char const * const fmt, ...);
    virtual void part_sts (channel_t *c, user_t *u);
    virtual void kline_sts (char const * const server, char const * const user, char const * const host, long duration, char const * const reason);
    virtual void unkline_sts (char const * const server, char const * const user, char const * const host);
    virtual void topic_sts (channel_t *c, char const * const setter, time_t ts, time_t prevts, char const * const topic);
    virtual void mode_sts (char const * const sender, channel_t *target, char const * const modes);
    virtual void ping_sts (void);
    virtual void ircd_on_login (char const * const origin, char const * const user, char const * const wantedhost);
    virtual bool ircd_on_logout (char const * const origin, char const * const user, char const * const wantedhost);
    virtual void jupe (char const * const server, char const * const reason);
  };
  
  static cmode_t nefarious_mode_list[] = {
    { 'a', CMODE_ADMONLY },
    { 'i', CMODE_INVITE },
    { 'm', CMODE_MOD    },
    { 'n', CMODE_NOEXT  },
    { 'p', CMODE_PRIV   },
    { 'r', CMODE_REGONLY },
    { 's', CMODE_SEC    },
    { 't', CMODE_TOPIC  },
    { 'z', CMODE_PERM   },
    { 'c', CMODE_NOCOLOR },
    { 'C', CMODE_NOCTCP },
    { 'D', CMODE_DELAYED },
    { 'Q', CMODE_NOQUIT },
    { 'N', CMODE_NONOTICE },
    { 'M', CMODE_SOFTMOD },
    { 'C', CMODE_NOCTCP },
    { 'S', CMODE_STRIP },
    { 'T', CMODE_NOAMSG },
    { 'O', CMODE_OPERONLY },
    { 'L', CMODE_SOFTPRIV },
    { 'Z', CMODE_SSLONLY },
    { '\0', 0 }
  };
  
  static extmode_t nefarious_ignore_mode_list[] = {
    { '\0', 0 }
  };
  
  static cmode_t nefarious_status_mode_list[] = {
    { 'o', CMODE_OP     },
    { 'h', CMODE_HALFOP },
    { 'v', CMODE_VOICE  },
    { '\0', 0 }
  };
  
  static cmode_t nefarious_prefix_mode_list[] = {
    { '@', CMODE_OP     },
    { '%', CMODE_HALFOP },
    { '+', CMODE_VOICE  },
    { '\0', 0 }
  };
  
  static void check_hidehost(user_t *u);
  
  /* *INDENT-ON* */
  
  /* login to our uplink */
  unsigned int
  nefarious_handler::server_login (void)
  {
    int ret;
  
    ret = sts ("PASS :%s", curr_uplink->pass);
    if (ret == 1)
      return 1;
  
    me.bursting = true;
  
    /* SERVER irc.undernet.org 1 933022556 947908144 J10 AA]]] :[127.0.0.1] A Undernet Server */
    sts ("SERVER %s 1 %ld %ld J10 %s]]] +s :%s", me.name, me.start, NOW, me.numeric, me.desc);
  
    services_init ();
  
    sts ("%s EB", me.numeric);
  
    return 0;
  }
  
  /* introduce a client */
  void
  nefarious_handler::introduce_nick (user_t *u)
  {
    sts ("%s N %s 1 %ld %s %s +%s%sk ]]]]]] %s :%s", me.numeric, u->nick, u->ts, u->user, u->host, "io", chansvs.fantasy ? "" : "d", u->uid, u->gecos);
  }
  
  /* invite a user to a channel */
  void
  nefarious_handler::invite_sts (user_t *sender, user_t *target, channel_t *channel)
  {
    /* target is a nick, weird eh? -- jilles */
    sts ("%s I %s %s", sender->uid, target->nick, channel->name);
  }
  
  void
  nefarious_handler::quit_sts (user_t *u, char const * const reason)
  {
    if (!me.connected)
      return;
  
    sts ("%s Q :%s", u->uid, reason);
  }
  
  /* WALLOPS wrapper */
  void
  nefarious_handler::wallops_sts (char const * const text)
  {
    sts ("%s WA :%s", me.numeric, text);
  }
  
  /* join a channel */
  void
  nefarious_handler::join_sts (channel_t *c, user_t *u, bool isnew, char const * const modes)
  {
    /* If the channel doesn't exist, we need to create it. */
    if (isnew)
      {
        sts ("%s C %s %ld", u->uid, c->name, c->ts);
        if (modes[0] && modes[1])
          sts ("%s M %s %s", u->uid, c->name, modes);
      }
    else
      {
        sts ("%s J %s %ld", u->uid, c->name, c->ts);
        sts ("%s M %s +o %s", me.numeric, c->name, u->uid);
      }
  }
  
  /* kicks a user from a channel */
  void
  nefarious_handler::kick (char const * const from, char const * const channel, char const * const to, char const * const reason)
  {
    channel_t *chan = channel_find (channel);
    user_t *fptr = user_find_named (from);
    user_t *user = user_find_named (to);
  
    if (!chan || !user || !fptr)
      return;
  
    sts ("%s K %s %s :%s", fptr->uid, channel, user->uid, reason);
  
    chanuser_delete (chan, user);
  }
  
  /* PRIVMSG wrapper */
  void
  nefarious_handler::privmsg (char const * const from, char const * const target, char const * const fmt, ...)
  {
    va_list ap;
    user_t *u = user_find_named (from);
    char buf[BUFSIZE];
  
    if (!u)
      return;
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts ("%s P %s :%s", u->uid, target, buf);
  }
  
  /* NOTICE wrapper */
  void
  nefarious_handler::notice_user_sts (user_t *from, user_t *target, char const * const text)
  {
    sts ("%s O %s :%s", from ? from->uid : me.numeric, target->uid, text);
  }
  
  void
  nefarious_handler::notice_global_sts (user_t *from, char const * const mask, char const * const text)
  {
    node_t *n;
    tld_t *tld;
  
    if (!strcmp (mask, "*"))
      {
        LIST_FOREACH (n, tldlist.head)
        {
          tld = static_cast<tld_t *> (n->data);
          sts ("%s O %s*%s :%s", from ? from->uid : me.numeric, ircd->tldprefix, tld->name, text);
        }
      }
    else
      sts ("%s O %s%s :%s", from ? from->uid : me.numeric, ircd->tldprefix, mask, text);
  }
  
  void
  nefarious_handler::notice_channel_sts (user_t *from, channel_t *target, char const * const text)
  {
    sts ("%s O %s :%s", from ? from->uid : me.numeric, target->name, text);
  }
  
  void
  nefarious_handler::wallchops (user_t *sender, channel_t *channel, char const * const message)
  {
    sts ("%s WC %s :%s", sender->uid, channel->name, message);
  }
  
  void
  nefarious_handler::numeric_sts (char const * const from, int numeric, char const * const target, char const * const fmt, ...)
  {
    va_list ap;
    char buf[BUFSIZE];
    user_t *source_p, *target_p;
  
    source_p = user_find_named (from);
    target_p = user_find_named (target);
  
    if (!target_p)
      return;
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts ("%s %d %s %s", source_p ? source_p->uid : me.numeric, numeric, target_p->uid, buf);
  }
  
  /* KILL wrapper */
  void
  nefarious_handler::skill (char const * const from, char const * const nick, char const * const fmt, ...)
  {
    va_list ap;
    char buf[BUFSIZE];
    user_t *fptr = user_find_named (from);
    user_t *tptr = user_find_named (nick);
  
    if (!tptr)
      return;
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts ("%s D %s :%s!%s!%s (%s)", fptr ? fptr->uid : me.numeric, tptr->uid, from, from, from, buf);
  }
  
  /* PART wrapper */
  void
  nefarious_handler::part_sts (channel_t *c, user_t *u)
  {
    sts ("%s L %s", u->uid, c->name);
  }
  
  /* server-to-server KLINE wrapper */
  void
  nefarious_handler::kline_sts (char const * const server, char const * const user, char const * const host, long duration, char const * const reason)
  {
    if (!me.connected)
      return;
  
    /* hold permanent akills for four weeks -- jilles */
    sts ("%s GL * +%s@%s %ld :%s", me.numeric, user, host, duration > 0 ? duration : 2419200, reason);
  }
  
  /* server-to-server UNKLINE wrapper */
  void
  nefarious_handler::unkline_sts (char const * const server, char const * const user, char const * const host)
  {
    if (!me.connected)
      return;
  
    sts ("%s GL * -%s@%s", me.numeric, user, host);
  }
  
  /* topic wrapper */
  void
  nefarious_handler::topic_sts (channel_t *c, char const * const setter, time_t ts, time_t prevts, char const * const topic)
  {
    if (!me.connected || !c)
      return;
  
    /* for nefarious, set topicsetter iff we can set the proper topicTS */
    if (ts > prevts || prevts == 0)
      sts ("%s T %s %s %ld %ld :%s", chansvs.me->me->uid, c->name, setter, c->ts, ts, topic);
    else
      {
        ts = NOW;
        if (ts < prevts)
          ts = prevts + 1;
        sts ("%s T %s %ld %ld :%s", chansvs.me->me->uid, c->name, c->ts, NOW, topic);
        c->topicts = ts;
      }
  }
  
  /* mode wrapper */
  void
  nefarious_handler::mode_sts (char const * const sender, channel_t *target, char const * const modes)
  {
    user_t *fptr = user_find_named (sender);
  
    if (!fptr)
      return;
  
    sts ("%s M %s %s", fptr->uid, target->name, modes);
  }
  
  /* ping wrapper */
  void
  nefarious_handler::ping_sts (void)
  {
    if (!me.connected)
      return;
  
    sts ("%s G !%ld %s %ld", me.numeric, NOW, me.name, NOW);
  }
  
  /* protocol-specific stuff to do on login */
  void
  nefarious_handler::ircd_on_login (char const * const origin, char const * const user, char const * const wantedhost)
  {
    user_t *u = user_find_named (origin);
  
    if (!u)
      return;
  
    sts ("%s AC %s R %s", me.numeric, u->uid, u->myuser->name);
    check_hidehost (u);
  }
  
  /* P10 does not support logout, so kill the user
   * we can't keep track of which logins are stale and which aren't -- jilles 
   * Except we can in Nefarious --nenolod
   */
  bool
  nefarious_handler::ircd_on_logout (char const * const origin, char const * const user, char const * const wantedhost)
  {
    user_t *u = user_find_named (origin);
  
    if (!me.connected)
      return false;
  
    if (!u)
      return false;
  
    sts ("%s AC %s U", me.numeric, u->uid);
    if (u->flags & UF_HIDEHOSTREQ && me.hidehostsuffix != NULL && !strcmp (u->vhost + strlen (u->vhost) - strlen (me.hidehostsuffix), me.hidehostsuffix))
      {
        slog (LG_DEBUG, "nefarious_ircd_on_logout(): removing +x vhost for %s: %s -> %s", u->nick, u->vhost, u->host);
        strlcpy (u->vhost, u->host, sizeof u->vhost);
      }
  
    return false;
  }
  
  void
  nefarious_handler::jupe (char const * const server, char const * const reason)
  {
    server_t *s;
  
    if (!me.connected)
      return;
  
    /* hold it for a day (arbitrary) -- jilles */
    /* get rid of local deactivation too */
    s = server_find (server);
    if (s != NULL && s->uplink != NULL)
      sts ("%s JU %s +%s %d %ld :%s", me.numeric, s->uplink->sid, server, 86400, NOW, reason);
    sts ("%s JU * +%s %d %ld :%s", me.numeric, server, 86400, NOW, reason);
  }
  
  static void
  m_topic (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c = channel_find (parv[0]);
    char *source;
    time_t ts = 0;
  
    if (!c)
      return;
  
    if (si->s != NULL)
      source = si->s->name;
    else
      source = si->su->nick;
  
    if (parc > 2)
      ts = atoi (parv[parc - 2]);
    if (ts == 0)
      ts = NOW;
    else if (c->topic != NULL && ts < c->topicts)
      return;
    handle_topic_from (si, c, parc > 4 ? parv[parc - 4] : source, ts, parv[parc - 1]);
  }
  
  /* AB G !1119920789.573932 services.atheme.org 1119920789.573932 */
  static void
  m_ping (sourceinfo_t *si, int parc, char *parv[])
  {
    /* reply to PING's */
    sts ("%s Z %s %s %s", me.numeric, parv[0], parv[1], parv[2]);
  }
  
  static void
  m_pong (sourceinfo_t *si, int parc, char *parv[])
  {
    me.uplinkpong = NOW;
  
    /* -> :test.projectxero.net PONG test.projectxero.net :shrike.malkier.net */
    if (me.bursting)
      {
  #ifdef HAVE_GETTIMEOFDAY
        e_time (burstime, &burstime);
  
        slog (LG_INFO, "m_pong(): finished synching with uplink (%d %s)", (tv2ms (&burstime) > 1000) ? (tv2ms (&burstime) / 1000) : tv2ms (&burstime), (tv2ms (&burstime) > 1000) ? "s" : "ms");
  
        wallops ("Finished synching to network in %d %s.", (tv2ms (&burstime) > 1000) ? (tv2ms (&burstime) / 1000) : tv2ms (&burstime), (tv2ms (&burstime) > 1000) ? "s" : "ms");
  #else
        slog (LG_INFO, "m_pong(): finished synching with uplink");
        wallops ("Finished synching to network.");
  #endif
  
        me.bursting = false;
      }
  }
  
  static void
  m_privmsg (sourceinfo_t *si, int parc, char *parv[])
  {
    if (parc != 2)
      return;
  
    handle_message (si, parv[0], false, parv[1]);
  }
  
  static void
  m_notice (sourceinfo_t *si, int parc, char *parv[])
  {
    if (parc != 2)
      return;
  
    handle_message (si, parv[0], true, parv[1]);
  }
  
  static void
  m_create (sourceinfo_t *si, int parc, char *parv[])
  {
    char buf[BUFSIZE];
    int chanc;
    char *chanv[256];
    int i;
  
    chanc = sjtoken (parv[0], ',', chanv);
  
    for (i = 0; i < chanc; i++)
      {
        channel_t *c = channel_add (chanv[i], atoi (parv[1]), si->su->server);
  
        /* Tell the core to check mode locks now,
         * otherwise it may only happen after the next
         * mode change.
         * P10 does not allow any redundant modes
         * so this will not look ugly. -- jilles */
        channel_mode (NULL, c, "+");
  
        buf[0] = '@';
        buf[1] = '\0';
  
        strlcat (buf, si->su->uid, BUFSIZE);
  
        chanuser_add (c, buf);
      }
  }
  
  static void
  m_join (sourceinfo_t *si, int parc, char *parv[])
  {
    int chanc;
    char *chanv[256];
    int i;
    node_t *n, *tn;
    chanuser_t *cu;
  
    /* JOIN 0 is really a part from all channels */
    if (!strcmp (parv[0], "0"))
      {
        LIST_FOREACH_SAFE (n, tn, si->su->channels.head)
        {
          cu = (chanuser_t *) n->data;
          chanuser_delete (cu->chan, si->su);
        }
        return;
      }
    if (parc < 2)
      return;
  
    chanc = sjtoken (parv[0], ',', chanv);
  
    for (i = 0; i < chanc; i++)
      {
        channel_t *c = channel_find (chanv[i]);
  
        if (!c)
          {
            c = channel_add (chanv[i], atoi (parv[1]), si->su->server);
            channel_mode (NULL, c, "+");
          }
  
        chanuser_add (c, si->su->uid);
      }
  }
  
  static void
  m_burst (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c;
    unsigned int modec;
    char *modev[16];
    unsigned int userc;
    char *userv[256];
    unsigned int i;
    int j;
    char prefix[16];
    char newnick[16 + NICKLEN];
    char *p;
    time_t ts;
    int bantype;
  
    /* S BURST <channel> <ts> [parameters]
     * parameters can be:
     * +<simple mode>
     * %<bans separated with spaces>
     * <nicks>
     */
    ts = atoi (parv[1]);
  
    c = channel_find (parv[0]);
  
    if (c == NULL)
      {
        slog (LG_DEBUG, "m_burst(): new channel: %s", parv[0]);
        c = channel_add (parv[0], ts, si->s);
      }
    else if (ts < c->ts)
      {
        chanuser_t *cu;
        node_t *n;
  
        clear_simple_modes (c);
        chanban_clear (c);
        handle_topic_from (si, c, "", 0, "");
        LIST_FOREACH (n, c->members.head)
        {
          cu = (chanuser_t *) n->data;
          if (cu->user->server == me.me)
            {
              /* it's a service, reop */
              sts ("%s M %s +o %s", me.numeric, c->name, CLIENT_NAME (cu->user));
              cu->modes = CMODE_OP;
            }
          else
            cu->modes = 0;
        }
  
        slog (LG_DEBUG, "m_burst(): TS changed for %s (%ld -> %ld)", c->name, c->ts, ts);
        c->ts = ts;
        c->callback.tschange (c);
      }
    if (parc < 3 || parv[2][0] != '+')
      {
        /* Tell the core to check mode locks now,
         * otherwise it may only happen after the next
         * mode change. -- jilles */
        channel_mode (NULL, c, "+");
      }
  
    bantype = 'b';
    j = 2;
    while (j < parc)
      {
        if (parv[j][0] == '+')
          {
            modec = 0;
            modev[modec++] = parv[j++];
            if (strchr (modev[0], 'k') && j < parc)
              modev[modec++] = parv[j++];
            if (strchr (modev[0], 'l') && j < parc)
              modev[modec++] = parv[j++];
            channel_mode (NULL, c, modec, modev);
          }
        else if (parv[j][0] == '%')
          {
            userc = sjtoken (parv[j++] + 1, ' ', userv);
            for (i = 0; i < userc; i++)
              if (!strcmp (userv[i], "~"))
                /* A ban "~" means exceptions are
                 * following */
                bantype = 'e';
              else
                chanban_add (c, userv[i], bantype);
          }
        else
          {
            userc = sjtoken (parv[j++], ',', userv);
  
            prefix[0] = '\0';
            for (i = 0; i < userc; i++)
              {
                p = strchr (userv[i], ':');
                if (p != NULL)
                  {
                    *p = '\0';
                    prefix[0] = '\0';
                    prefix[1] = '\0';
                    prefix[2] = '\0';
                    p++;
                    while (*p)
                      {
                        if (*p == 'o')
                          prefix[prefix[0] ? 1 : 0] = '@';
                        else if (*p == 'h')
                          prefix[prefix[0] ? 1 : 0] = '%';
                        else if (*p == 'v')
                          prefix[prefix[0] ? 1 : 0] = '+';
                        p++;
                      }
                  }
                strlcpy (newnick, prefix, sizeof newnick);
                strlcat (newnick, userv[i], sizeof newnick);
                chanuser_add (c, newnick);
              }
          }
      }
  
    if (c->nummembers == 0 && !(c->modes & ircd->perm_mode))
      channel_delete (c);
  }
  
  static void
  m_part (sourceinfo_t *si, int parc, char *parv[])
  {
    int chanc;
    char *chanv[256];
    int i;
  
    chanc = sjtoken (parv[0], ',', chanv);
    for (i = 0; i < chanc; i++)
      {
        slog (LG_DEBUG, "m_part(): user left channel: %s -> %s", si->su->nick, chanv[i]);
  
        chanuser_delete (channel_find (chanv[i]), si->su);
      }
  }
  
  static void
  m_nick (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u;
    struct in_addr ip;
    char ipstring[64];
    char *p;
    int i;
  
    /* got the right number of args for an introduction? */
    if (parc >= 8)
      {
        /* -> AB N jilles 1 1137687480 jilles jaguar.test +oiwgrx jilles B]AAAB ABAAE :Jilles Tjoelker */
        /* -> AB N test4 1 1137690148 jilles jaguar.test +iw B]AAAB ABAAG :Jilles Tjoelker */
        slog (LG_DEBUG, "m_nick(): new user on `%s': %s", si->s->name, parv[0]);
  
        ipstring[0] = '\0';
        if (strlen (parv[parc - 3]) == 6)
          {
            ip.s_addr = ntohl (base64touint (parv[parc - 3]));
            if (!inet_ntop (AF_INET, &ip, ipstring, sizeof ipstring))
              ipstring[0] = '\0';
          }
        u = user_add (parv[0], parv[3], parv[4], NULL, ipstring, parv[parc - 2], parv[parc - 1], si->s, atoi (parv[2]));
  
        if (parv[5][0] == '+')
          {
            user_mode (u, parv[5]);
            i = 1;
            if (strchr (parv[5], 'r'))
              {
                handle_burstlogin (u, parv[5 + i]);
                /* killed to force logout? */
                if (user_find (parv[parc - 2]) == NULL)
                  return;
                i++;
              }
            if (strchr (parv[5], 'h'))
              {
                p = strchr (parv[5 + i], '@');
                if (p == NULL)
                  strlcpy (u->vhost, parv[5 + i], sizeof u->vhost);
                else
                  {
                    strlcpy (u->vhost, p + 1, sizeof u->vhost);
                    strlcpy (u->user, parv[5 + i], sizeof u->user);
                    p = strchr (u->user, '@');
                    if (p != NULL)
                      *p = '\0';
                  }
                i++;
              }
            if (strchr (parv[5], 'x'))
              {
                u->flags |= UF_HIDEHOSTREQ;
                /* this must be after setting the account name */
                check_hidehost (u);
              }
          }
  
        handle_nickchange (u);
      }
    /* if it's only 2 then it's a nickname change */
    else if (parc == 2)
      {
        if (!si->su)
          {
            slog (LG_DEBUG, "m_nick(): server trying to change nick: %s", si->s != NULL ? si->s->name : "<none>");
            return;
          }
  
        slog (LG_DEBUG, "m_nick(): nickname change from `%s': %s", si->su->nick, parv[0]);
  
        user_changenick (si->su, parv[0], atoi (parv[1]));
  
        handle_nickchange (si->su);
      }
    else
      {
        slog (LG_DEBUG, "m_nick(): got NICK with wrong (%d) number of params", parc);
  
        for (i = 0; i < parc; i++)
          slog (LG_DEBUG, "m_nick():   parv[%d] = %s", i, parv[i]);
      }
  }
  
  static void
  m_quit (sourceinfo_t *si, int parc, char *parv[])
  {
    slog (LG_DEBUG, "m_quit(): user leaving: %s", si->su->nick);
  
    /* user_delete() takes care of removing channels and so forth */
    user_delete (si->su);
  }
  
  static void
  m_mode (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u;
    char *p;
  
    if (*parv[0] == '#')
      channel_mode (NULL, channel_find (parv[0]), parc - 1, &parv[1]);
    else
      {
        /* Yes this is a nick and not a UID -- jilles */
        u = user_find_named (parv[0]);
        if (u == NULL)
          {
            slog (LG_DEBUG, "m_mode(): user mode for unknown user %s", parv[0]);
            return;
          }
        user_mode (u, parv[1]);
        if (strchr (parv[1], 'x'))
          {
            u->flags |= UF_HIDEHOSTREQ;
            check_hidehost (u);
          }
        if (strchr (parv[1], 'h'))
          {
            if (parc > 2)
              {
                /* assume +h */
                p = strchr (parv[2], '@');
                if (p == NULL)
                  strlcpy (u->vhost, parv[2], sizeof u->vhost);
                else
                  {
                    strlcpy (u->vhost, p + 1, sizeof u->vhost);
                    strlcpy (u->user, parv[2], sizeof u->user);
                    p = strchr (u->user, '@');
                    if (p != NULL)
                      *p = '\0';
                  }
                slog (LG_DEBUG, "m_mode(): user %s setting vhost %s@%s", u->nick, u->user, u->vhost);
              }
            else
              {
                /* must be -h */
                /* XXX we don't know the original ident */
                slog (LG_DEBUG, "m_mode(): user %s turning off vhost", u->nick);
                strlcpy (u->vhost, u->host, sizeof u->vhost);
                /* revert to +x vhost if applicable */
                check_hidehost (u);
              }
          }
      }
  }
  
  static void
  m_clearmode (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *chan;
    char *p, c;
    node_t *n, *tn;
    chanuser_t *cu;
    int i;
  
    /* -> ABAAA CM # b */
    /* Note: this is an IRCop command, do not enforce mode locks. */
    chan = channel_find (parv[0]);
    if (chan == NULL)
      {
        slog (LG_DEBUG, "m_clearmode(): unknown channel %s", parv[0]);
        return;
      }
    p = parv[1];
    while ((c = *p++))
      {
        if (c == 'b')
          {
            LIST_FOREACH_SAFE (n, tn, chan->bans.head)
            {
              if (((chanban_t *) n->data)->type == 'b')
                chanban_delete (static_cast<chanban_t *> (n->data));
            }
          }
        else if (c == 'e')
          {
            LIST_FOREACH_SAFE (n, tn, chan->bans.head)
            {
              if (((chanban_t *) n->data)->type == 'e')
                chanban_delete (static_cast<chanban_t *> (n->data));
            }
          }
        else if (c == 'k')
          {
            if (chan->key)
              sfree (chan->key);
            chan->key = NULL;
          }
        else if (c == 'l')
          chan->limit = 0;
        else if (c == 'o')
          {
            LIST_FOREACH (n, chan->members.head)
            {
              cu = (chanuser_t *) n->data;
              if (cu->user->server == me.me)
                {
                  /* it's a service, reop */
                  sts ("%s M %s +o %s", me.numeric, chan->name, cu->user->uid);
                }
              else
                cu->modes &= ~CMODE_OP;
            }
          }
        else if (c == 'h')
          {
            LIST_FOREACH (n, chan->members.head)
            {
              cu = (chanuser_t *) n->data;
              cu->modes &= ~CMODE_HALFOP;
            }
          }
        else if (c == 'v')
          {
            LIST_FOREACH (n, chan->members.head)
            {
              cu = (chanuser_t *) n->data;
              cu->modes &= ~CMODE_VOICE;
            }
          }
        else
          for (i = 0; mode_list[i].mode != '\0'; i++)
            {
              if (c == mode_list[i].mode)
                chan->modes &= ~mode_list[i].value;
            }
      }
  }
  
  static void
  m_kick (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u = user_find (parv[1]);
    channel_t *c = channel_find (parv[0]);
  
    /* -> :rakaur KICK #shrike rintaun :test */
    slog (LG_DEBUG, "m_kick(): user was kicked: %s -> %s", parv[1], parv[0]);
  
    if (!u)
      {
        slog (LG_DEBUG, "m_kick(): got kick for nonexistant user %s", parv[1]);
        return;
      }
  
    if (!c)
      {
        slog (LG_DEBUG, "m_kick(): got kick in nonexistant channel: %s", parv[0]);
        return;
      }
  
    if (!chanuser_find (c, u))
      {
        slog (LG_DEBUG, "m_kick(): got kick for %s not in %s", u->nick, c->name);
        return;
      }
  
    chanuser_delete (c, u);
  
    /* if they kicked us, let's rejoin */
    if (is_internal_client (u))
      {
        slog (LG_DEBUG, "m_kick(): %s got kicked from %s; rejoining", u->nick, parv[0]);
        join (parv[0], u->nick);
      }
  }
  
  static void
  m_kill (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_kill (si, parv[0], parc > 1 ? parv[1] : "<No reason given>");
  }
  
  static void
  m_squit (sourceinfo_t *si, int parc, char *parv[])
  {
    slog (LG_DEBUG, "m_squit(): server leaving: %s from %s", parv[0], parv[1]);
    server_delete (parv[0]);
  }
  
  /* SERVER ircu.devel.atheme.org 1 1119902586 1119908830 J10 ABAP] + :lets lol */
  static void
  m_server (sourceinfo_t *si, int parc, char *parv[])
  {
    server_t *s;
  
    /* We dont care about the max connections. */
    parv[5][2] = '\0';
  
    slog (LG_DEBUG, "m_server(): new server: %s, id %s, %s", parv[0], parv[5], parv[4][0] == 'P' ? "eob" : "bursting");
    s = handle_server (si, parv[0], parv[5], atoi (parv[1]), parv[7]);
  
    /* SF_EOB may only be set when we have all users on the server.
     * so store the fact that they are EOB in another flag.
     * handle_eob() will set SF_EOB when the uplink has finished bursting.
     * -- jilles */
    if (s != NULL && parv[4][0] == 'P')
      s->flags |= SF_EOB2;
  }
  
  static void
  m_stats (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_stats (si->su, parv[0][0]);
  }
  
  static void
  m_admin (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_admin (si->su);
  }
  
  static void
  m_version (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_version (si->su);
  }
  
  static void
  m_info (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_info (si->su);
  }
  
  static void
  m_motd (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_motd (si->su);
  }
  
  static void
  m_whois (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_whois (si->su, parv[1]);
  }
  
  static void
  m_trace (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_trace (si->su, parv[0], parc >= 2 ? parv[1] : NULL);
  }
  
  static void
  m_away (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_away (si->su, parc >= 1 ? parv[0] : NULL);
  }
  
  static void
  m_pass (sourceinfo_t *si, int parc, char *parv[])
  {
    if (strcmp (curr_uplink->pass, parv[0]))
      {
        slog (LG_INFO, "m_pass(): password mismatch from uplink; aborting");
        runflags |= RF_SHUTDOWN;
      }
  }
  
  static void
  m_error (sourceinfo_t *si, int parc, char *parv[])
  {
    slog (LG_INFO, "m_error(): error from server: %s", parv[0]);
  }
  
  static void
  m_eos (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_eob (si->s);
  
    /* acknowledge a local END_OF_BURST */
    if (si->s->uplink == me.me)
      sts ("%s EA", me.numeric);
  }
  
  static void
  check_hidehost (user_t *u)
  {
    static bool warned = false;
  
    /* do they qualify? */
    if (!(u->flags & UF_HIDEHOSTREQ) || u->myuser == NULL || (u->myuser->flags & MU_WAITAUTH))
      return;
    /* don't use this if they have some other kind of vhost */
    if (strcmp (u->host, u->vhost))
      {
        slog (LG_DEBUG, "check_hidehost(): +x overruled by other vhost for %s", u->nick);
        return;
      }
    if (me.hidehostsuffix == NULL)
      {
        if (!warned)
          {
            wallops ("Misconfiguration: serverinfo::hidehostsuffix not set");
            warned = true;
          }
        return;
      }
    snprintf (u->vhost, sizeof u->vhost, "%s.%s", u->myuser->name, me.hidehostsuffix);
    slog (LG_DEBUG, "check_hidehost(): %s -> %s", u->nick, u->vhost);
  }
  
  static pcommand_t const pcommands[] = {
    { "G", m_ping, 1, MSRC_USER | MSRC_SERVER },
    { "Z", m_pong, 1, MSRC_SERVER },
    { "P", m_privmsg, 2, MSRC_USER },
    { "O", m_notice, 2, MSRC_USER | MSRC_SERVER },
    { "NOTICE", m_notice, 2, MSRC_UNREG },
    { "C", m_create, 1, MSRC_USER },
    { "J", m_join, 1, MSRC_USER },
    { "EB", m_eos, 0, MSRC_SERVER },
    { "B", m_burst, 2, MSRC_SERVER },
    { "L", m_part, 1, MSRC_USER },
    { "N", m_nick, 2, MSRC_USER | MSRC_SERVER },
    { "Q", m_quit, 1, MSRC_USER },
    { "M", m_mode, 2, MSRC_USER | MSRC_SERVER },
    { "OM", m_mode, 2, MSRC_USER },        /* OPMODE, treat as MODE */
    { "CM", m_clearmode, 2, MSRC_USER },
    { "K", m_kick, 2, MSRC_USER | MSRC_SERVER },
    { "D", m_kill, 1, MSRC_USER | MSRC_SERVER },
    { "SQ", m_squit, 1, MSRC_USER | MSRC_SERVER },
    { "S", m_server, 8, MSRC_SERVER },
    { "SERVER", m_server, 8, MSRC_UNREG },
    { "R", m_stats, 2, MSRC_USER },
    { "AD", m_admin, 1, MSRC_USER },
    { "V", m_version, 1, MSRC_USER },
    { "F", m_info, 1, MSRC_USER },
    { "W", m_whois, 2, MSRC_USER },
    { "TR", m_trace, 1, MSRC_USER },
    { "A", m_away, 0, MSRC_USER },
    { "PASS", m_pass, 1, MSRC_UNREG },
    { "Y", m_error, 1, MSRC_UNREG | MSRC_SERVER },
    { "ERROR", m_error, 1, MSRC_UNREG | MSRC_SERVER },
    { "T", m_topic, 2, MSRC_USER | MSRC_SERVER },
    { "MO", m_motd, 1, MSRC_USER },
  };
  
  nefarious_handler::nefarious_handler ()
  {
    parse = &p10_parse;
  
    mode_list = nefarious_mode_list;
    ignore_mode_list = nefarious_ignore_mode_list;
    status_mode_list = nefarious_status_mode_list;
    prefix_mode_list = nefarious_prefix_mode_list;
  
    ircd = &Nefarious;
  
    pcommand_add (&pcommands);
  }
  
  nefarious_handler::~nefarious_handler ()
  {
    parse = NULL;
  
    mode_list = NULL;
    ignore_mode_list = NULL;
    status_mode_list = NULL;
    prefix_mode_list = NULL;
  
    ircd = NULL;
  
    pcommand_delete (&pcommands);
  }
} // namespace protocol
  
#define FACREG_TYPE protocol::nefarious_handler
#define FACREG_TYPE_NAME "nefarious"
#define FACREG_INTERFACE_TYPE protocol::handler
#include <ermyth/factory_reg.h>