/*
 * Copyright © 2005-2006 Atheme Development Group
 * Rights to this code are documented in doc/pod/license.pod.
 *
 * This file contains protocol support for spanning tree 1.2 branch inspircd.
 *
 * $Id: inspircd12.C,v 1.7 2007/09/09 20:05:52 pippijn Exp $
 */

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

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

/* *INDENT-OFF* */

namespace protocol
{
  static ircd_t InspIRCd = {
    "InspIRCd 1.2.x",             /* 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. */
    false,                        /* Whether or not we use P10 */
    true,                         /* Whether or not we use vHosts. */
    CMODE_OPERONLY,               /* Oper-only cmodes */
    CMODE_OWNER,                  /* Integer flag for owner channel flag. */
    CMODE_PROTECT,                /* Integer flag for protect channel flag. */
    CMODE_HALFOP,                 /* Integer flag for halfops. */
    "+q",                         /* Mode we set for owner. */
    "+a",                         /* Mode we set for protect. */
    "+h",                         /* Mode we set for halfops. */
    PROTOCOL_INSPIRCD,            /* Protocol type */
    0,                            /* Permanent cmodes */
    "beIg",                       /* Ban-like cmodes */
    'e',                          /* Except mchar */
    'I',                          /* Invex mchar */
    IRCD_CIDR_BANS                /* Flags */
  };
  
  struct inspircd12_handler : handler
  {
    inspircd12_handler ();
    virtual ~inspircd12_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 chan_lowerts (channel_t *c, user_t *u);
    virtual void kick (char const * const from, char const * const channel, char const * const to, char const * const reason);
    virtual void mdchange (char const * const target, char const * const key, char const * const value);
    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 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);
    virtual void sethost_sts (char const * const source, char const * const target, char const * const host);
    virtual void fnc_sts (user_t *source, user_t *u, char const * const newnick, int type);
    virtual void holdnick_sts (user_t *source, int duration, char const * const nick, myuser_t *account);
  };
  
  static cmode_t inspircd12_mode_list[] = {
    { 'i', CMODE_INVITE   },
    { 'm', CMODE_MOD      },
    { 'n', CMODE_NOEXT    },
    { 'p', CMODE_PRIV     },
    { 's', CMODE_SEC      },
    { 't', CMODE_TOPIC    },
    { 'c', CMODE_NOCOLOR  },
    { 'M', CMODE_MODREG   },
    { 'R', CMODE_REGONLY  },
    { 'O', CMODE_OPERONLY },
    { 'S', CMODE_STRIP    },
    { 'K', CMODE_NOKNOCK  },
    { 'V', CMODE_NOINVITE },
    { 'C', CMODE_NOCTCP   },
    { 'N', CMODE_STICKY   },
    { 'G', CMODE_CENSOR   },
    { 'P', CMODE_NOCAPS   },
    { 'z', CMODE_SSLONLY  },
    { 'T', CMODE_NONOTICE },
    { 'u', CMODE_HIDING   },
    { 'Q', CMODE_PEACE   },
    { '\0', 0 }
  };
  
  static bool check_flood(char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
  static bool check_nickflood (char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
  static bool check_jointhrottle(char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
  static bool check_forward(char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
  static bool check_rejoindelay(char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
  
  static extmode_t inspircd12_ignore_mode_list[] = {
    { 'f', check_flood        },
    { 'F', check_nickflood    },
    { 'j', check_jointhrottle },
    { 'L', check_forward      },
    { 'J', check_rejoindelay  },
    { '\0', 0 }
  };
  
  static cmode_t inspircd12_status_mode_list[] = {
    { 'q', CMODE_OWNER   },
    { 'a', CMODE_PROTECT },
    { 'o', CMODE_OP      },
    { 'h', CMODE_HALFOP  },
    { 'v', CMODE_VOICE   },
    { '\0', 0 }
  };
  
  static cmode_t inspircd12_prefix_mode_list[] = {
    { '~', CMODE_OWNER   },
    { '&', CMODE_PROTECT },
    { '@', CMODE_OP      },
    { '%', CMODE_HALFOP  },
    { '+', CMODE_VOICE   },
    { '\0', 0 }
  };
  
  /* CAPABilities */
  static bool has_servicesmod = false;
  static bool has_globopsmod = false;
  static bool has_svshold = false;
  static int has_protocol = 0;
  
  #define PROTOCOL_SNONOTICE 1102 /* has SNONOTICE and OPERNOTICE commands */
  #define PROTOCOL_NEWTS 1104 /* does not send "confirming" FMODEs on TS changes and uses clear/ignore semantics also for FMODE */
  
  /* *INDENT-ON* */
  
  static bool
  check_flood (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
  {
    /* +F doesn't support *, so don't bother checking for it -- w00t */
    return check_jointhrottle (value, c, mc, u, mu);
  }
  
  static bool
  check_nickflood (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
  {
    return *value == '*' ? check_jointhrottle(value + 1, c, mc, u, mu) : check_jointhrottle(value, c, mc, u, mu);
  }
  
  static bool
  check_jointhrottle (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
  {
    char const *p;
    char const *arg2;
  
    p = value, arg2 = NULL;
    while (*p != '\0')
      {
        if (*p == ':')
          {
            if (arg2 != NULL)
              return false;
            arg2 = p + 1;
          }
        else if (!isdigit (*p))
          return false;
        p++;
      }
    if (arg2 == NULL)
      return false;
    if (p - arg2 > 10 || arg2 - value - 1 > 10 || !atoi (value) || !atoi (arg2))
      return false;
    return true;
  }
  
  static bool
  check_forward (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
  {
    channel_t *target_c;
    mychan_t *target_mc;
  
    if (*value != '#' || strlen (value) > 50)
      return false;
    if (u == NULL && mu == NULL)
      return true;
    target_c = channel_find (value);
    target_mc = mychan_t::find (value);
    if (target_c == NULL && target_mc == NULL)
      return false;
    return true;
  }
  
  static bool
  check_rejoindelay (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
  {
    char const *ch = value;
  
    while (*ch)
      {
        if (!isdigit (*ch))
          return false;
        ch++;
      }
  
    if (atoi (value) <= 0)
      {
        return false;
      }
    else
      {
        return true;
      }
  }
  
  
  /* login to our uplink */
  unsigned int
  inspircd12_handler::server_login (void)
  {
    int ret;
    
    /* Check if we have a numeric set. InspIRCd 1.2 protocol 
     * requires it. -nenolod
     */
    if (me.numeric == NULL)
      {
        slog (LG_ERROR, "inspircd12_handler::server_login(): inspircd 1.2 requires a unique identifier. set serverinfo::numeric.");
        exit (EXIT_FAILURE);
      }
    
    ret = sts ("SERVER %s %s 0 %s :%s", me.name, curr_uplink->pass, me.numeric, me.desc);
    if (ret == 1)
      return 1;
  
    me.bursting = true;
    sts ("BURST");
    /* XXX: Being able to get this data as a char* would be nice - Brain */
    sts (":%s VERSION :atheme-%s. %s %s%s%s%s%s%s%s%s%s%s",
         me.name,
         version,
         me.numeric,
         match_mapping ? "A" : "",
         log_debug_enabled () ? "d" : "",
         me.auth ? "e" : "",
         config_options.flood_msgs ? "F" : "",
         config_options.leave_chans ? "l" : "",
         config_options.join_chans ? "j" : "",
         chansvs.changets ? "t" : "",
         !match_mapping ? "R" : "",
         config_options.raw ? "r" : "",
         runflags & RF_LIVE ? "n" : "");
    services_init ();
    return 0;
  }
  
  /* introduce a client */
  void
  inspircd12_handler::introduce_nick (user_t *u)
  {
    /* :penguin.omega.org.za UID 497AAAAAB 1188302517 OperServ 127.0.0.1 127.0.0.1 OperServ +s 127.0.0.1 :Operator Server */
    sts (":%s UID %s %ld %s %s %s %s +%s 0.0.0.0 %ld :%s", me.numeric, u->uid, u->ts, u->nick, u->host, u->host, u->user, "io", u->ts, u->gecos);
    sts (":%s OPERTYPE Services", u->uid);
  }
  
  void
  inspircd12_handler::quit_sts (user_t *u, char const * const reason)
  {
    if (!me.connected)
      return;
  
    sts (":%s QUIT :%s", u->uid, reason);
  }
  
  /* WALLOPS wrapper */
  void
  inspircd12_handler::wallops_sts (char const * const text)
  {
    char *sendernick = NULL;
    user_t *u;
    node_t *n;
  
    if (has_protocol >= PROTOCOL_SNONOTICE)
      {
        /* XXX */
        if (has_globopsmod)
          sts (":%s SNONOTICE g :%s", me.numeric, text);
        else
          sts (":%s OPERNOTICE :%s", me.numeric, text);
        return;
      }
  
    if (me.me == NULL)
      return;
  
    if (is_internal_client (user_find_named (opersvs.nick)))
      {
        sendernick = opersvs.nick;
      }
    else
      {
        LIST_FOREACH (n, me.me->userlist.head)
        {
          u = (user_t *) n->data;
  
          sendernick = u->uid;
          break;
        }
      }
  
    if (sendernick == NULL)
      {
        /*
         * this means we have no pseudoclients -- under present inspircd, servers cannot globops, and
         * thus, we will need to bail -- slog, and let them know. --w00t
         */
        slog (LG_ERROR, "wallops_sts(): InspIRCD requires at least one pseudoclient module to be loaded to send wallops.");
        return;
      }
  
    sts (":%s GLOBOPS :%s", sendernick, text);
  }
  
  /* join a channel */
  void
  inspircd12_handler::join_sts (channel_t *c, user_t *u, bool isnew, char const * const modes)
  {
    if (isnew)
      {
        sts (":%s FJOIN %s %ld :@,%s", me.numeric, c->name, c->ts, u->uid);
        if (modes[0] && modes[1])
          sts (":%s FMODE %s %ld %s", me.numeric, c->name, c->ts, modes);
      }
    else
      {
        sts (":%s FJOIN %s %ld :@,%s", me.numeric, c->name, c->ts, u->uid);
      }
  }
  
  void
  inspircd12_handler::chan_lowerts (channel_t *c, user_t *u)
  {
    slog (LG_DEBUG, "inspircd12_handler::chan_lowerts(): lowering TS for %s to %ld", c->name, (long) c->ts);
  
    sts (":%s FJOIN %s %ld :@,%s", me.numeric, c->name, c->ts, u->uid);
    sts (":%s FMODE %s %ld %s", me.numeric, c->name, c->ts, channel_modes (c, true));
  }
  
  /* kicks a user from a channel */
  void
  inspircd12_handler::kick (char const * const from, char const * const channel, char const * const to, char const * const reason)
  {
    channel_t *c = channel_find (channel);
    user_t *u = user_find (to);
    user_t *su = user_find (from);
  
    if (!c || !u)
      return;
  
    sts (":%s KICK %s %s :%s", su->uid, channel, u->uid, reason);
  
    chanuser_delete (c, u);
  }
  
  // changes ircd metadata
  void
  inspircd12_handler::mdchange (char const * const target, char const * const key, char const * const value)
  {
    sts (":%s METADATA %s %s :%s", me.numeric, target, key, value);
  }
  
  /* PRIVMSG wrapper */
  void
  inspircd12_handler::privmsg (char const * const from, char const * const target, char const * const fmt, ...)
  {
    va_list ap;
    char buf[BUFSIZE];
    user_t *u = user_find (from);
    user_t *su = user_find (from);
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts (":%s PRIVMSG %s :%s", su->uid, *target != '#' ? u->uid : target, buf);
  }
  
  /* NOTICE wrapper */
  void
  inspircd12_handler::notice_user_sts (user_t *from, user_t *target, char const * const text)
  {
    sts (":%s NOTICE %s :%s", from ? from->uid : me.numeric, target->nick, text);
  }
  
  void
  inspircd12_handler::notice_global_sts (user_t *from, char const * const mask, char const * const text)
  {
    sts (":%s NOTICE %s%s :%s", from ? from->uid : me.numeric, ircd->tldprefix, mask, text);
  }
  
  void
  inspircd12_handler::notice_channel_sts (user_t *from, channel_t *target, char const * const text)
  {
    sts (":%s NOTICE %s :%s", from ? from->uid : me.numeric, target->name, text);
  }
  
  void
  inspircd12_handler::numeric_sts (char const * const from, int numeric, char const * const target, char const * const fmt, ...)
  {
    va_list ap;
    char buf[BUFSIZE];
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts (":%s PUSH %s ::%s %d %s %s", me.numeric, target, from, numeric, target, buf);
  }
  
  /* KILL wrapper */
  void
  inspircd12_handler::skill (char const * const from, char const * const nick, char const * const fmt, ...)
  {
    va_list ap;
    char buf[BUFSIZE];
  
    va_start (ap, fmt);
    vsnprintf (buf, BUFSIZE, fmt, ap);
    va_end (ap);
  
    sts (":%s KILL %s :[%s] Killed (%s (%s))", from, nick, me.name, from, buf);
  }
  
  /* PART wrapper */
  void
  inspircd12_handler::part_sts (channel_t *c, user_t *u)
  {
    sts (":%s PART %s :Leaving", u->uid, c->name);
  }
  
  /* server-to-server KLINE wrapper */
  void
  inspircd12_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;
  
    /* :services-dev.chatspike.net ADDLINE G test@test.com Brain 1133994664 0 :You are banned from this network */
    sts (":%s ADDLINE G %s@%s %s %ld %ld :%s", me.numeric, user, host, opersvs.nick, NOW, duration, reason);
  }
  
  /* server-to-server UNKLINE wrapper */
  void
  inspircd12_handler::unkline_sts (char const * const server, char const * const user, char const * const host)
  {
    if (!me.connected)
      return;
  
    /* I know this looks wrong, but it's really not. Trust me. --w00t */
    sts (":%s GLINE %s@%s", opersvs.nick, user, host);
  }
  
  /* topic wrapper */
  void
  inspircd12_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;
  
    /* If possible, try to use FTOPIC
     * Note that because TOPIC does not contain topicTS, it may be
     * off a few seconds on other servers, hence the 60 seconds here.
     * -- jilles */
    /* Restoring old topic */
    if (ts > prevts + 60 || prevts == 0)
      {
        sts (":%s FTOPIC %s %ld %s :%s", chansvs.me->me->uid, c->name, ts, setter, topic);
        return;
      }
    /* Tweaking a topic */
    else if (ts == prevts)
      {
        ts += 60;
        sts (":%s FTOPIC %s %ld %s :%s", chansvs.me->me->uid, c->name, ts, setter, topic);
        c->topicts = ts;
        return;
      }
    sts (":%s TOPIC %s :%s", chansvs.me->me->uid, c->name, topic);
    c->topicts = NOW;
  }
  
  /* mode wrapper */
  void
  inspircd12_handler::mode_sts (char const * const sender, channel_t *target, char const * const modes)
  {
    user_t *su = user_find (sender);
  
    if (!me.connected)
      return;
  
    if (has_protocol >= PROTOCOL_NEWTS)
      /* FMODE from user is ok, use it */
      sts (":%s FMODE %s %ld %s", su->uid, target->name, target->ts, modes);
    else
      sts (":%s MODE %s %s", su->uid, target->name, modes);
  }
  
  /* ping wrapper */
  void
  inspircd12_handler::ping_sts (void)
  {
    if (!me.connected)
      return;
  
    sts (":%s PING %s", me.numeric, curr_uplink->name);
  }
  
  /* protocol-specific stuff to do on login */
  void
  inspircd12_handler::ircd_on_login (char const * const origin, char const * const user, char const * const wantedhost)
  {
    if (!me.connected)
      return;
  
    sts (":%s METADATA %s accountname :%s", me.numeric, origin, user);
  }
  
  /* protocol-specific stuff to do on logout */
  bool
  inspircd12_handler::ircd_on_logout (char const * const origin, char const * const user, char const * const wantedhost)
  {
    if (!me.connected)
      return false;
  
    sts (":%s METADATA %s accountname :", me.numeric, origin);
    return false;
  }
  
  void
  inspircd12_handler::jupe (char const * const server, char const * const reason)
  {
    server_t *s;
    if (!me.connected)
      return;
  
    s = server_find (server);
    if (s != NULL)
      {
        /* We need to wait for the RSQUIT to be processed -- jilles */
        sts (":%s RSQUIT :%s", opersvs.nick, server);
        s->flags |= SF_JUPE_PENDING;
      }
    else
      {
        /* Remove any previous jupe first */
        sts (":%s SQUIT %s :%s", me.numeric, server, reason);
        sts (":%s SERVER %s * 1 :%s", me.numeric, server, reason);
      }
  }
  
  void
  inspircd12_handler::sethost_sts (char const * const source, char const * const target, char const * const host)
  {
    if (!me.connected)
      return;
  
    notice (source, target, "Setting your host to \2%s\2.", host);
    sts (":%s CHGHOST %s %s", source, target, host);
  }
  
  void
  inspircd12_handler::fnc_sts (user_t *source, user_t *u, char const * const newnick, int type)
  {
    /* svsnick can only be sent by a server */
    sts (":%s SVSNICK %s %s %lu", me.numeric, u->uid, newnick, NOW - 60);
  }
  
  
  /* invite a user to a channel */
  void
  inspircd12_handler::invite_sts (user_t *sender, user_t *target, channel_t *channel)
  {
    sts (":%s INVITE %s %s", sender->nick, target->nick, channel->name);
  }
  
  void
  inspircd12_handler::holdnick_sts (user_t *source, int duration, char const * const nick, myuser_t *account)
  {
    if (duration == 0)
      /* remove SVSHOLD */
      sts (":%s SVSHOLD %s", source->nick, nick);
    else
      sts (":%s SVSHOLD %s %ds :Registered nickname.", source->nick, nick, duration);
  }
  
  static void
  m_topic (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c = channel_find (parv[0]);
  
    if (!c)
      return;
  
    handle_topic_from (si, c, si->su->nick, NOW, parv[1]);
  }
  
  static void
  m_ftopic (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c = channel_find (parv[0]);
    time_t ts = atol (parv[1]);
  
    if (!c)
      return;
  
    if (c->topic != NULL && c->topicts >= ts)
      {
        slog (LG_DEBUG, "m_ftopic(): ignoring older topic on %s", c->name);
        return;
      }
  
    handle_topic_from (si, c, parv[2], ts, parv[3]);
  }
  
  static void
  m_ping (sourceinfo_t *si, int parc, char *parv[])
  {
    /* reply to PING's */
    sts (":%s PONG %s", me.numeric, parv[0]);
  }
  
  static void
  m_pong (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_eob (si->s);
  
    if (irccasecmp (me.actual, si->s->name))
      return;
    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_fjoin (sourceinfo_t *si, int parc, char *parv[])
  {
    /* FJOIN #flaps 1234 :@,fanny +%,arse ,tits ,breasts &~,poontang */
    channel_t *c;
    unsigned int userc;
    unsigned int i;
    unsigned int j;
    unsigned int nlen;
    bool prefix = true;
    bool keep_new_modes = true;
    char *userv[256];
    char prefixandnick[51];
    time_t ts;
  
    c = channel_find (parv[0]);
    ts = atol (parv[1]);
  
    if (!c)
      {
        slog (LG_DEBUG, "m_fjoin(): new channel: %s", parv[0]);
        c = channel_add (parv[0], ts, si->s);
        return_if_fail (c != NULL);
        /* Tell the core to check mode locks now,
         * otherwise it may only happen after the next
         * mode change.
         * Inspircd does not allow any redundant modes
         * so this will not look ugly. -- jilles */
        /* As discussed with Brain, if this is in a burst,
         * an FMODE with the simple modes will follow so we
         * can skip this. -- jilles */
        if (!me.bursting)
          channel_mode (NULL, c, "+");
      }
  
    if (ts < c->ts)
      {
        chanuser_t *cu;
        node_t *n;
  
        /* the TS changed.  a TS change requires us to do
         * bugger all except update the TS, because in InspIRCd
         * remote servers enforce the TS change - Brain
         *
         * This is no longer the case with 1.1, we need to bounce their modes
         * as well as lowering the channel ts. Do both. -- w00t
         */
  
        if (has_protocol >= PROTOCOL_NEWTS)
          {
            clear_simple_modes (c);
            chanban_clear (c);
          }
        LIST_FOREACH (n, c->members.head)
        {
          cu = (chanuser_t *) n->data;
          if (cu->user->server == me.me)
            {
              /* it's a service, reop */
              sts (":%s FMODE %s %ld +o %s", me.numeric, c->name, ts, cu->user->nick);
              cu->modes = CMODE_OP;
            }
          else
            cu->modes = 0;
        }
  
        c->ts = ts;
        c->callback.tschange (c);
      }
    else if (ts > c->ts)
      {
        keep_new_modes = false;        /* ignore statuses */
      }
  
    /*
     * ok, here's the difference from 1.0 -> 1.1:
     * 1.0 sent p[3] and up as individual users, prefixed with their 'highest' prefix, @, % or +
     * in 1.1, this is more complex. All prefixes are sent, with the additional caveat that modules
     * can add their own prefixes (dangerous!) - therefore, don't just chanuser_add(), split the prefix
     * out and ignore unknown prefixes (probably the safest option). --w00t
     */
    userc = sjtoken (parv[parc - 1], ' ', userv);
  
    /* loop over all the users in this fjoin */
    for (i = 0; i < userc; i++)
      {
        nlen = 0;
        prefix = true;
  
        slog (LG_DEBUG, "m_fjoin(): processing user: %s", userv[i]);
  
        /*
         * ok, now look at the chars in the nick.. we have something like "@%,w00t", but need @%w00t.. and
         * we also want to ignore unknown prefixes.. loop through the chars
         */
        for (; *userv[i]; userv[i]++)
          {
            /* does this char match a known prefix? */
            for (j = 0; prefix_mode_list[j].mode; j++)
              {
                /* yup. add it to the 'final' combination (@%w00t) */
                if (*userv[i] == prefix_mode_list[j].mode)
                  {
                    prefixandnick[nlen++] = *userv[i];
                    continue;
                  }
              }
  
            /* it's not a known prefix char, have we reached the end of the prefixes? */
            if (*userv[i] == ',')
              {
                /* yup, skip over the comma */
                userv[i]++;
  
                /* if we're ignoring status (keep_new_modes is false) then just add them to chan here.. */
                if (keep_new_modes == false)
                  {
                    /* This ignores the @%, and just adds 'w00t' to the chan */
                    chanuser_add (c, userv[i]);
                  }
                else
                  {
                    /* else, we do care about their prefixes.. add '@%w00t' to the chan */
                    strlcpy (prefixandnick + nlen, userv[i], sizeof (prefixandnick) - nlen);
                    chanuser_add (c, prefixandnick);
                  }
  
                /* added them.. break out of this loop, which will move us to the next user */
                break;
              }
            else
              {
                /* unknown prefix char */
              }
          }
  
        /* go to the next user */
      }
  
    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_uid (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u;
  
    /* :3ZZ UID 3ZZAAAAAB 1133994664 nenolod petrie.ipv6.nenolod.net petrie.ipv6.nenolod.net nenolod +i 0.0.0.0 1351531513 :William Pitcock */
    if (parc == 10)
      {
        slog (LG_DEBUG, "m_uid(): new user on `%s': %s", si->s->name, parv[2]);
        
        /* char *nick, char *user, char *host, char *vhost, char *ip, char *uid, char *gecos, server_t *server, unsigned int ts */ 
        u = user_add (parv[2], parv[5], parv[3], parv[4], parv[7], parv[0], parv[9], si->s, atol (parv[9]));
        user_mode (u, parv[5]);
        
        /* If server is not yet EOB we will do this later.
         * This avoids useless "please identify" -- jilles */
        if (si->s->flags & SF_EOB)
          handle_nickchange (u);
      }
    else
      {
        int i;
        slog (LG_DEBUG, "m_uid(): got UID with wrong number of params");
        
        for (i = 0; i < parc; i++)
          slog (LG_DEBUG, "m_uid(): parv[%d] = %s", i, parv[i]);
      }
  }
  
  static void
  m_nick (sourceinfo_t *si, int parc, char *parv[])
  {
    /* if it's only 1 then it's a nickname change, if it's 2, it's a nickname change with a TS */
    if (parc == 1 || 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]);
        
        /* No TS here for some reason, hmm */
        user_changenick (si->su, parv[0], si->su->ts);
        
        /* It could happen that our PING arrived late and the
         * server didn't acknowledge EOB yet even though it is
         * EOB; don't send double notices in that case -- jilles */
        if (si->su->server->flags & SF_EOB)
          handle_nickchange (si->su);
      }
    else
      {
        int i;
        slog (LG_DEBUG, "m_nick(): got NICK with wrong number of params");
        
        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_saquit (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u = user_find (parv[0]);
  
    slog (LG_DEBUG, "m_saquit(): user leaving: %s", parv[0]);
  
    /* user_delete() takes care of removing channels and so forth */
    user_delete (u);
  }
  
  static void
  m_mode (sourceinfo_t *si, int parc, char *parv[])
  {
    if (*parv[0] == '#')
      channel_mode (NULL, channel_find (parv[0]), parc - 1, &parv[1]);
    else
      user_mode (user_find (parv[0]), parv[1]);
  }
  
  static void
  m_fmode (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c;
    bool onlydeop;
    time_t ts;
    char const *p;
  
    /* :server.moo FMODE #blarp tshere +ntsklLg keymoo 1337 secks */
    if (*parv[0] == '#')
      {
        c = channel_find (parv[0]);
        if (c == NULL)
          {
            slog (LG_DEBUG, "m_fmode(): nonexistant channel: %s", parv[0]);
            return;
          }
        ts = atoi (parv[1]);
        if (ts == c->ts && has_protocol < PROTOCOL_NEWTS)
          {
            onlydeop = true;
            p = parv[2];
            while (*p != '\0')
              {
                if (!strchr ("-qaohv", *p))
                  onlydeop = false;
                p++;
              }
            if (onlydeop && si->s != NULL)
              {
                /* ignore redundant deops generated
                 * if we lower the TS of a channel
                 * scenario: user with autoop privs recreates
                 * channel
                 * XXX could this ignore other stuff too?
                 * -- jilles */
                slog (LG_DEBUG, "m_fmode(): ignoring %s %s: incoming TS %ld is equal to our TS %ld, and only deops", parv[0], parv[2], ts, c->ts);
                return;
              }
          }
        else if (ts > c->ts)
          {
            if (has_protocol < PROTOCOL_NEWTS)
              slog (LG_DEBUG, "m_fmode(): accepting but should bounce %s %s: incoming TS %ld is newer than our TS %ld", parv[0], parv[2], ts, c->ts);
            else
              return;
          }
        else if (ts < c->ts)
          slog (LG_DEBUG, "m_fmode(): %s %s: incoming TS %ld is older than our TS %ld, possible desync", parv[0], parv[2], ts, c->ts);
        channel_mode (NULL, c, parc - 2, &parv[2]);
      }
    else
      user_mode (user_find (parv[0]), parv[2]);
  }
  
  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->uid, 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->uid);
      }
  }
  
  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", parv[0]);
    server_delete (parv[0]);
  }
  
  static void
  m_server (sourceinfo_t *si, int parc, char *parv[])
  {
    server_t *s;
  
    slog (LG_DEBUG, "m_server(): new server: %s", parv[0]);
    s = handle_server (si, parv[0], parv[3], atoi(parv[2]), parv[4]);
  
    if (s != NULL && s->uplink != me.me)
      /* elicit PONG for EOB detection; pinging uplink is
       * already done elsewhere -- jilles
       */
      sts (":%s PING %s %s", me.numeric, me.numeric, s->name);
  }
  
  static void
  m_stats (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_stats (si->su, parv[0][0]);
  }
  
  static void
  m_motd (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_motd (si->su);
  }
  
  static void
  m_admin (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_admin (si->su);
  }
  
  static void
  m_away (sourceinfo_t *si, int parc, char *parv[])
  {
    handle_away (si->su, parc >= 1 ? parv[0] : NULL);
  }
  
  static void
  m_join (sourceinfo_t *si, int parc, char *parv[])
  {
    channel_t *c;
  
    c = channel_find (parv[0]);
    if (!c)
      {
        slog (LG_DEBUG, "m_join(): new channel: %s (modes lost)", parv[0]);
        c = channel_add (parv[0], parc > 1 ? atol (parv[1]) : NOW, si->su->server);
        return_if_fail (c != NULL);
        channel_mode (NULL, c, "+");
      }
    chanuser_add (c, si->su->nick);
  }
  
  static void
  m_sajoin (sourceinfo_t *si, int parc, char *parv[])
  {
    si->su = user_find (parv[0]);
    if (si->su == NULL)
      return;
    m_join (si, 1, &parv[1]);
  }
  
  static void
  m_sapart (sourceinfo_t *si, int parc, char *parv[])
  {
    si->su = user_find (parv[0]);
    if (si->su == NULL)
      return;
    m_part (si, 1, &parv[1]);
  }
  
  static void
  m_sanick (sourceinfo_t *si, int parc, char *parv[])
  {
    si->su = user_find (parv[0]);
    if (si->su == NULL)
      return;
    m_nick (si, 1, &parv[1]);
  }
  
  static void
  m_samode (sourceinfo_t *si, int parc, char *parv[])
  {
    /* note that SAMODE is not checked in any way before propagation,
     * and only works on channels, not users */
    channel_mode (NULL, channel_find (parv[0]), parc - 1, &parv[1]);
  }
  
  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_idle (sourceinfo_t *si, int parc, char *parv[])
  {
    if (parc == 1 && si->su != NULL)
      {
        sts (":%s IDLE %s %ld 0", parv[0], si->su->nick, NOW);
      }
    else
      {
        slog (LG_INFO, "m_idle(): Received an IDLE response but we didn't WHOIS anybody!");
      }
  }
  
  static void
  m_opertype (sourceinfo_t *si, int parc, char *parv[])
  {
    /*
     * Hope this works.. InspIRCd OPERTYPE means user is an oper, mark them so
     * Later, we may want to look at saving their OPERTYPE for informational
     * purposes, or not. --w00t
     */
    user_mode (si->su, "+o");
  }
  
  static void
  m_fhost (sourceinfo_t *si, int parc, char *parv[])
  {
    strlcpy (si->su->vhost, parv[0], HOSTLEN);
  }
  
  /*
   * :<source server> METADATA <channel|user> <key> :<value>
   * The sole piece of metadata we're interested in is 'accountname', set by Services,
   * and kept by ircd.
   *
   * :services.barafranca METADATA w00t accountname :w00t
   */
  
  static void
  m_metadata (sourceinfo_t *si, int parc, char *parv[])
  {
    user_t *u;
  
    if (!irccasecmp (parv[1], "accountname"))
      {
        /* find user */
        u = user_find (parv[0]);
  
        if (u == NULL)
          return;
  
        handle_burstlogin (u, parv[2]);
      }
  }
  
  /*
   * rsquit:
   *  remote/request squit
   *  when squitting a remote server, inspircd sends RSQUIT along the tree until it reaches the server that has
   *  the server to be squit as a local connection, which should then close it's connection and send SQUIT back
   *  to the rest of the network.
   */
  static void
  m_rsquit (sourceinfo_t *si, int parc, char *parv[])
  {
    sts (":%s SQUIT %s :Jupe removed by %s", me.numeric, parv[0], si->su->nick);
  }
  
  static void
  m_capab (sourceinfo_t *si, int parc, char *parv[])
  {
    int i, varc;
    char *varv[256];
  
    if (strcasecmp (parv[0], "START") == 0)
      {
        /* reset all our previously recieved CAPAB stuff */
        has_servicesmod = false;
        has_globopsmod = false;
        has_svshold = false;
        has_protocol = 0;
      }
    else if (strcasecmp (parv[0], "CAPABILITIES") == 0 && parc > 1)
      {
        varc = sjtoken (parv[1], ' ', varv);
        for (i = 0; i < varc; i++)
          {
            if (!strncmp (varv[i], "PROTOCOL=", 9))
              has_protocol = atoi (varv[i] + 9);
            /* XXX check/store HALFOP/CHANMAX/IDENTMAX */
          }
      }
    else if (strcasecmp (parv[0], "MODULES") == 0 && parc > 1)
      {
        if (strstr (parv[1], "m_services_account.so"))
          has_servicesmod = true;
        if (strstr (parv[1], "m_globops.so"))
          has_globopsmod = true;
        if (strstr (parv[1], "m_svshold.so"))
          has_svshold = true;
        if (strstr (parv[1], "m_chanprotect.so"))
          {
            ircd->uses_owner = true;
            ircd->uses_protect = true;
          }
      }
    else if (strcasecmp (parv[0], "END") == 0)
      {
        if (has_globopsmod == false && has_protocol < PROTOCOL_SNONOTICE)
          {
            slog (LG_ERROR, "m_capab(): you didn't load m_globops into inspircd. " PACKAGE_NAME " support requires this module. exiting.");
            exit (EXIT_FAILURE);
          }
  
        if (has_servicesmod == false)
          {
            slog (LG_ERROR, "m_capab(): you didn't load m_services_account into inspircd. " PACKAGE_NAME " support requires this module. exiting.");
            exit (EXIT_FAILURE);
          }
  
        if (has_svshold == false)
          {
            slog (LG_INFO, "m_capab(): you didn't load m_svshold into inspircd. nickname enforcers will not work.");
          }
      }
    else
      {
        slog (LG_DEBUG, "m_capab(): unknown CAPAB type %s - out of date protocol module?", parv[0]);
      }
  }
  
  /* Server ended their burst: warn all their users if necessary -- jilles */
  static void
  server_eob (server_t *s)
  {
    node_t *n;
  
    LIST_FOREACH (n, s->userlist.head)
    {
      handle_nickchange ((user_t *) n->data);
    }
  }
  
  static pcommand_t const pcommands[] = {
    { "PING", m_ping, 1, MSRC_USER | MSRC_SERVER },
    { "PONG", m_pong, 1, MSRC_SERVER },
    { "PRIVMSG", m_privmsg, 2, MSRC_USER },
    { "NOTICE", m_notice, 2, MSRC_USER | MSRC_SERVER },
    { "FJOIN", m_fjoin, 3, MSRC_SERVER },
    { "PART", m_part, 1, MSRC_USER },
    { "NICK", m_nick, 1, MSRC_USER | MSRC_SERVER },
    { "UID", m_uid, 9, MSRC_USER | MSRC_SERVER },
    { "QUIT", m_quit, 1, MSRC_USER },
    { "MODE", m_mode, 2, MSRC_USER | MSRC_SERVER },
    { "FMODE", m_fmode, 3, MSRC_USER | MSRC_SERVER },
    { "SAMODE", m_samode, 2, MSRC_USER },
    { "SAJOIN", m_sajoin, 2, MSRC_USER },
    { "SAPART", m_sapart, 2, MSRC_USER },
    { "SANICK", m_sanick, 2, MSRC_USER },
    { "SAQUIT", m_saquit, 1, MSRC_USER },
    { "KICK", m_kick, 2, MSRC_USER | MSRC_SERVER },
    { "KILL", m_kill, 1, MSRC_USER | MSRC_SERVER },
    { "SQUIT", m_squit, 1, MSRC_USER | MSRC_SERVER },
    { "RSQUIT", m_rsquit, 1, MSRC_USER },
    { "SERVER", m_server, 4, MSRC_UNREG | MSRC_SERVER },
    { "STATS", m_stats, 2, MSRC_USER },
    { "MOTD", m_motd, 1, MSRC_USER },
    { "ADMIN", m_admin, 1, MSRC_USER },
    { "FTOPIC", m_ftopic, 4, MSRC_SERVER },
    { "JOIN", m_join, 1, MSRC_USER },
    { "ERROR", m_error, 1, MSRC_UNREG | MSRC_SERVER },
    { "TOPIC", m_topic, 2, MSRC_USER },
    { "FHOST", m_fhost, 1, MSRC_USER },
    { "IDLE", m_idle, 1, MSRC_USER },
    { "AWAY", m_away, 0, MSRC_USER },
    { "OPERTYPE", m_opertype, 1, MSRC_USER },
    { "METADATA", m_metadata, 3, MSRC_SERVER },
    { "CAPAB", m_capab, 1, MSRC_UNREG | MSRC_SERVER },
  };
  
  inspircd12_handler::inspircd12_handler ()
  {
    mode_list = inspircd12_mode_list;
    ignore_mode_list = inspircd12_ignore_mode_list;
    status_mode_list = inspircd12_status_mode_list;
    prefix_mode_list = inspircd12_prefix_mode_list;
  
    ircd = &InspIRCd;
  
    pcommand_add (&pcommands);
  
    server_t::callback.eob.attach (server_eob);
  }
  
  inspircd12_handler::~inspircd12_handler ()
  {
    server_t::callback.eob.detach (server_eob);
  
    pcommand_delete (&pcommands);
  
    ircd = NULL;
  
    prefix_mode_list = NULL;
    status_mode_list = NULL;
    ignore_mode_list = NULL;
    mode_list = NULL;
  }
} // namespace protocol
  
#define FACREG_TYPE protocol::inspircd12_handler
#define FACREG_TYPE_NAME "inspircd12"
#define FACREG_INTERFACE_TYPE protocol::handler
#include <ermyth/factory_reg.h>