/*
 * packet.C: IRC packet handling.
 * Rights to this code are documented in doc/LICENSE.
 *
 * Copyright © 2005-2007 Atheme Project (http://www.atheme.org)
 */

static char const rcsid[] = "$Id";

#include "atheme.h"
#include "uplink.h"
#include "datastream.h"

/* bursting timer */
#if HAVE_GETTIMEOFDAY
struct timeval burstime;
#endif

static void
irc_recvq_handler (connection_t *cptr)
{
  bool wasnonl;
  char parsebuf[BUFSIZE + 1];
  int count;

  wasnonl = cptr->flags & CF_NONEWLINE ? true : false;
  count = recvq_getline (cptr, parsebuf, sizeof parsebuf - 1);
  if (count <= 0)
    return;
  cnt.bin += count;
  /* ignore the excessive part of a too long line */
  if (wasnonl)
    return;
  me.uplinkpong = NOW;
  if (parsebuf[count - 1] == '\n')
    count--;
  if (count > 0 && parsebuf[count - 1] == '\r')
    count--;
  parsebuf[count] = '\0';
  parse (parsebuf);
}

static void
ping_uplink (void *arg)
{
  unsigned int diff;

  if (me.connected)
    {
      ping_sts ();

      diff = NOW - me.uplinkpong;

      if (diff >= 600)
	{
	  slog (LG_INFO, "ping_uplink(): uplink appears to be dead, disconnecting");
	  sts ("ERROR :Closing Link: 127.0.0.1 (Ping timeout: %d seconds)", diff);
	  sendq_flush (curr_uplink->conn);
	  if (me.connected)
	    {
	      errno = 0;
	      connection_close (curr_uplink->conn);
	    }
	}
    }

  if (!me.connected)
    event_delete (ping_uplink, NULL);
}

static void
irc_handle_connect (void *vptr)
{
  connection_t *cptr = static_cast<connection_t *> (vptr);

  /* add our server */

  if (cptr == curr_uplink->conn)
    {
      cptr->flags = CF_UPLINK;
      cptr->recvq_handler = irc_recvq_handler;
      me.connected = true;
      /* no SERVER message received */
      me.recvsvr = false;

      slog (LG_INFO, "irc_handle_connect(): connection to uplink established");

      server_login ();

#ifdef HAVE_GETTIMEOFDAY
      /* start our burst timer */
      s_time (&burstime);
#endif

      /* done bursting by this time... */
      ping_sts ();

      /* ping our uplink every 5 minutes */
      event_delete (ping_uplink, NULL);
      event_add ("ping_uplink", ping_uplink, NULL, 300);
      me.uplinkpong = time (NULL);
    }
}

void
init_ircpacket (void)
{
  hook_add_event ("connected");
  hook_add_hook ("connected", irc_handle_connect);
}

/* vim:cinoptions=>s,e0,n0,f0,{0,}0,^0,=s,ps,t0,c3,+s,(2s,us,)20,*30,gs,hs
 * vim:ts=8
 * vim:sw=8
 * vim:noexpandtab
 */