modules/chanserv/chanserv.c File Reference

#include <eggdrop/eggdrop.h>
#include "chanserv.h"

Go to the source code of this file.

Functions
static int	chanserv_timer (void *client_data)
EXPORT_SCOPE int	chanserv_LTX_start (egg_module_t *modinfo)
static int	chanserv_close (int why)
static int	on_chanset (const char *chan, const char *setting, const char *oldvalue, const char *newvalue)
static int	chanserv_init ()
static int	chanserv_shutdown ()
int	chanserv_refresh_channel_config (void *client_data)
chanserv_channel_stats_t *	chanserv_probe_chan (const char *chan, int create)
chanserv_member_stats_t *	chanserv_probe_member (chanserv_channel_stats_t *chan, const char *nick, const char *uhost, int create)
int	chanserv_lookup_config (const char *chan, int stat, int *limit, int *period)
int	chanserv_update_stats (int stat, const char *chan, const char *nick, const char *uhost)
static int	cleanup_old_members (chanserv_channel_stats_t *chan)
static int	free_channel (chanserv_channel_stats_t *chan)
Variables
static const char	rcsid [] = "$Id: chanserv.c,v 1.6 2005-12-28 17:27:31 sven Exp $"
chanserv_config_t	chanserv_config
egg_server_api_t *	server = NULL
static chanserv_channel_stats_t	global_chan
static int	timer_id
static event_owner_t	chanserv_owner
static const char *	channel_config_names []
static config_var_t	chanserv_config_vars []
static chanserv_channel_stats_t *	chanstats_head = NULL
static bind_table_t *	BT_chanflood = NULL
static bind_table_t *	BT_memflood = NULL

---

Function Documentation

static int chanserv_close

(

int

why

)

[static]

Definition at line 344 of file chanserv.c.

References chanserv_shutdown(), config_get_root(), config_root, config_unlink_table(), and NULL.

Referenced by chanserv_LTX_start().

{
  void *config_root;

  chanserv_shutdown();
  config_root = config_get_root("eggdrop");
  config_unlink_table(chanserv_config_vars, config_root, "chanserv", 0, NULL);
  return(0);
}

static int chanserv_init

(

)

[static]

Definition at line 90 of file chanserv.c.

References bind_add_simple(), BIND_STACKABLE, bind_table_add(), CHANSERV_CLEANUP_TIMER, chanserv_timer(), events_init, MATCH_MASK, module_get_api(), NULL, on_chanset(), egg_timeval::sec, timer_create_complex(), timer_id, TIMER_REPEAT, and egg_timeval::usec.

Referenced by chanserv_LTX_start().

{
  egg_timeval_t howlong;

  memset(&global_chan, 0, sizeof(global_chan));
  BT_chanflood = bind_table_add("chanflood", 5, "ssiii", MATCH_MASK, BIND_STACKABLE);
  BT_memflood = bind_table_add("memflood", 7, "ssssiii", MATCH_MASK, BIND_STACKABLE);
  server = module_get_api("server", 1, 0);
  bind_add_simple("chanset", NULL, "settings.chanserv.*", on_chanset);
  events_init();
  howlong.sec = CHANSERV_CLEANUP_TIMER;
  howlong.usec = 0;
  timer_id = timer_create_complex(&howlong, "chanserv stats cleanup", chanserv_timer, NULL, TIMER_REPEAT, &chanserv_owner);
  return(0);
}

int chanserv_lookup_config	(	const char *	chan,
		int	stat,
		int *	limit,
		int *	period
	)

Definition at line 195 of file chanserv.c.

References chanserv_config_t::channel_limits, chanserv_config_t::channel_periods, chanserv_probe_chan, chanserv_channel_stats::limits, and chanserv_channel_stats::periods.

{
  chanserv_channel_stats_t *chanstats;

  chanstats = chanserv_probe_chan(chan, 1);
  if (limit) {
    *limit = chanstats->limits[stat];
    if (*limit < 0) *limit = chanserv_config.channel_limits[stat];
  }
  if (period) {
    *period = chanstats->periods[stat];
    if (*period < 0) *period = chanserv_config.channel_periods[stat];
  }
  return(0);
}

int chanserv_LTX_start

(

egg_module_t *

modinfo

)

Definition at line 354 of file chanserv.c.

References egg_module::author, chanserv_close(), chanserv_init(), egg_module::close_func, config_get_root(), config_link_table(), config_root, config_update_table(), egg_module::description, event_owner_b::module, egg_module::name, NULL, and egg_module::version.

{
  void *config_root;

  chanserv_owner.module = modinfo;

  modinfo->name = "chanserv";
  modinfo->author = "eggdev";
  modinfo->version = "1.0.0";
  modinfo->description = "channel services";
  modinfo->close_func = chanserv_close;

  /* Set defaults. */
  memset(&chanserv_config, 0, sizeof(chanserv_config));

  /* Link our vars in. */
  config_root = config_get_root("eggdrop");
  config_link_table(chanserv_config_vars, config_root, "chanserv", 0, NULL);
  config_update_table(chanserv_config_vars, config_root, "chanserv", 0, NULL);

  chanserv_init();
  return(0);
}

chanserv_channel_stats_t* chanserv_probe_chan	(	const char *	chan,
		int	create
	)

Definition at line 147 of file chanserv.c.

References chanserv_refresh_channel_config, chanserv_channel_stats::name, chanserv_channel_stats::next, NULL, and chanserv_channel_stats::prev.

{
  chanserv_channel_stats_t *chanstats, *prev;

  prev = NULL;
  for (chanstats = chanstats_head; chanstats; chanstats = chanstats->next) {
    if (!strcasecmp(chanstats->name, chan)) return(chanstats);
    prev = chanstats;
  }
  if (!create) return(NULL);

  /* Create new channel. */
  chanstats = calloc(1, sizeof(*chanstats));
  chanstats->name = strdup(chan);
  chanserv_refresh_channel_config(chanstats);

  if (prev) prev->next = chanstats;
  else chanstats_head = chanstats;
  chanstats->prev = prev;
  return(chanstats);
}

chanserv_member_stats_t* chanserv_probe_member	(	chanserv_channel_stats_t *	chan,
		const char *	nick,
		const char *	uhost,
		int	create
	)

Definition at line 169 of file chanserv.c.

References egg_msprintf(), ircmask_create(), chanserv_channel_stats::members, chanserv_channel_stats::nmembers, NULL, chanserv_member_stats_t::who, and wild_match().

{
  char *who, buf[256];
  int i;

  if (!chan) chan = &global_chan;

  who = egg_msprintf(buf, sizeof(buf), NULL, "%s!%s", nick, uhost);

  for (i = 0; i < chan->nmembers; i++) {
    if (wild_match(chan->members[i].who, who)) {
      if (who != buf) free(who);
      return(chan->members+i);
    }
  }
  if (who != buf) free(who);
  if (!create) return(NULL);

  /* Add new member. */
  chan->members = realloc(chan->members, sizeof(*chan->members) * (chan->nmembers+1));
  chan->nmembers++;
  memset(chan->members+i, 0, sizeof(*chan->members));
  chan->members[i].who = ircmask_create(5, nick, uhost);
  return(chan->members+i);
}

int chanserv_refresh_channel_config

(

void *

client_data

)

Definition at line 114 of file chanserv.c.

References channel_config_names, egg_server_api_t::channel_get_int, egg_server_api_t::channel_lookup, CHANSERV_STAT_LEN, chanserv_channel_stats::limits, chanserv_channel_stats::name, NULL, chanserv_channel_stats::periods, and chanserv_channel_stats::stats.

{
  chanserv_channel_stats_t *chanstats = client_data;
  channel_t *chan = server->channel_lookup(chanstats->name);
  int i, setting;

  if (!chan) return(0);
  for (i = 0; i < CHANSERV_STAT_LEN; i++) {
    /* If the setting isn't found, default to -1, which means
     * we use the global default. This happens when a channel
     * is created. */
    if (server->channel_get_int(chan, &setting, "chanserv", 0, channel_config_names[i], 0, "period", 0, NULL)) setting = -1;

    /* If the period changes, we clear the stats. */
    if (setting != chanstats->periods[i]) {
      chanstats->periods[i] = setting;
      chanstats->stats[i] = 0;
    }

    if (server->channel_get_int(chan, &setting, "chanserv", 0, channel_config_names[i], 0, "limit", 0, NULL)) setting = -1;
    chanstats->limits[i] = setting;
  }

  return(0);
}

static int chanserv_shutdown

(

)

[static]

Definition at line 106 of file chanserv.c.

References bind_table_del(), and events_shutdown.

Referenced by chanserv_close().

{
  bind_table_del(BT_chanflood);
  bind_table_del(BT_memflood);
  events_shutdown();
  return(0);
}

static int chanserv_timer

(

void *

client_data

)

[static]

Definition at line 331 of file chanserv.c.

References egg_server_api_t::channel_lookup, cleanup_old_members(), free_channel(), chanserv_channel_stats::name, and chanserv_channel_stats::next.

Referenced by chanserv_init().

{
  chanserv_channel_stats_t *chan, *next;

  for (chan = chanstats_head; chan; chan = next) {
    next = chan->next;
    if (!server->channel_lookup(chan->name)) free_channel(chan);
    else cleanup_old_members(chan);
  }
  cleanup_old_members(&global_chan);
  return(0);
}

int chanserv_update_stats	(	int	stat,
		const char *	chan,
		const char *	nick,
		const char *	uhost
	)

Definition at line 211 of file chanserv.c.

References bind_check(), channel_config_names, chanserv_config_t::channel_limits, chanserv_config_t::channel_periods, chanserv_probe_chan, chanserv_probe_member, CHANSERV_STAT_CYCLE, CHANSERV_STAT_JOIN, CHANSERV_STAT_LEAVE, CHANSERV_STAT_LEN, chanserv_update_stats, chanserv_config_t::cycle_time, chanserv_member_stats_t::last_event, chanserv_member_stats_t::last_event_time, chanserv_channel_stats::last_event_time, chanserv_channel_stats::limits, now, NULL, chanserv_channel_stats::periods, chanserv_member_stats_t::stats, chanserv_channel_stats::stats, and timer_get_now_sec().

{
  chanserv_channel_stats_t *chanstats = NULL;
  chanserv_member_stats_t *m = NULL;
  int period, limit;
  time_t now;
  int diff;

  if (stat < 0 || stat >= CHANSERV_STAT_LEN) return(-1);
  if (!nick || !uhost) return(-1);

  if (chan) chanstats = chanserv_probe_chan(chan, 1);
  m = chanserv_probe_member(chanstats, nick, uhost, 1);
  if (!m) return(-1);

  /* Take care of channel stats first. */

  now = timer_get_now_sec(NULL);

  if (chanstats) {
    /* Figure out the period and limit for this stat. */
    period = chanstats->periods[stat];
    if (period < 0) period = chanserv_config.channel_periods[stat];
    if (period > 0) {
      limit = chanstats->limits[stat];
      if (limit < 0) limit = chanserv_config.channel_limits[stat];

      /* Adjust stats for time difference of this event
       * relative to the last one. */
      diff = now - chanstats->last_event_time[stat];
      if (diff > period) {
        chanstats->last_event_time[stat] = now;
        chanstats->stats[stat] = 0;
        diff = 0;
      }
      chanstats->stats[stat]++;

      if (chanstats->stats[stat] > limit) {
        bind_check(BT_chanflood, NULL, channel_config_names[stat], channel_config_names[stat], chan, limit, period, diff);
        chanstats->last_event_time[stat] = now;
        chanstats->stats[stat] = 0;
      }
    }
  }

  /* Now update member stats. */
  if (m) {
    m->last_event = now;
    /* Figure out the period and limit for this stat. */
    period = global_chan.periods[stat];
    if (period > 0) {
      limit = global_chan.limits[stat];

      /* Adjust stats for time difference of this event
       * relative to the last one. */
      diff = now - m->last_event_time[stat];
      if (diff > period) {
        m->last_event_time[stat] = now;
        m->stats[stat] = 0;
        diff = 0;
      }
      m->stats[stat]++;

      if (m->stats[stat] > limit) {
        bind_check(BT_memflood, NULL, channel_config_names[stat], channel_config_names[stat], chan, nick, uhost, limit, period, diff);
        m->last_event_time[stat] = now;
        m->stats[stat] = 0;
      }
    }
    
    switch (stat) {
      case CHANSERV_STAT_LEAVE:
        if (now - m->last_event_time[CHANSERV_STAT_JOIN] < chanserv_config.cycle_time) {
          chanserv_update_stats(CHANSERV_STAT_CYCLE, chan, nick, uhost);
        }
        break;
    }
  }
  return(0);
}

static int cleanup_old_members

(

chanserv_channel_stats_t *

chan

)

[static]

Definition at line 293 of file chanserv.c.

References CHANSERV_CLEANUP_TIME, chanserv_member_stats_t::last_event, chanserv_channel_stats::members, chanserv_channel_stats::nmembers, now, NULL, timer_get_now_sec(), and chanserv_member_stats_t::who.

Referenced by chanserv_timer().

{
  chanserv_member_stats_t *m;
  time_t now;
  int i;

  now = timer_get_now_sec(NULL);

  for (i = 0; i < chan->nmembers; i++) {
    m = chan->members+i;
    if (now - m->last_event > CHANSERV_CLEANUP_TIME) {
      free(m->who);
      memmove(chan->members+i, chan->members+i+1, sizeof(*chan->members)*(chan->nmembers-i-1));
      chan->nmembers--;
      i--;
    }
  }
  return(0);
}

static int free_channel

(

chanserv_channel_stats_t *

chan

)

[static]

Definition at line 313 of file chanserv.c.

References LOG_MISC, chanserv_channel_stats::members, chanserv_channel_stats::name, chanserv_channel_stats::next, chanserv_channel_stats::nmembers, chanserv_channel_stats::prev, putlog(), and chanserv_member_stats_t::who.

Referenced by chanserv_timer().

{
  int i;

  /* ###### test to make sure this gets called properly, remove later */
  putlog(LOG_MISC, "*", "chanserv: freeing channel '%s'", chan->name);
  free(chan->name);
  for (i = 0; i < chan->nmembers; i++) {
    free(chan->members[i].who);
  }
  free(chan->members);
  if (chan->prev) chan->prev->next = chan->next;
  else chanstats_head = chan->next;
  if (chan->next) chan->next->prev = chan->prev;
  free(chan);
  return(0);
}

static int on_chanset	(	const char *	chan,
		const char *	setting,
		const char *	oldvalue,
		const char *	newvalue
	)			[static]

Definition at line 140 of file chanserv.c.

References chanserv_probe_chan, chanserv_refresh_channel_config, garbage_add(), and GARBAGE_ONCE.

Referenced by chanserv_init().

{
  chanserv_channel_stats_t *chanstats = chanserv_probe_chan(chan, 1);
  garbage_add(chanserv_refresh_channel_config, chanstats, GARBAGE_ONCE);
  return(0);
}

---

Variable Documentation

bind_table_t* BT_chanflood = NULL [static]

Definition at line 83 of file chanserv.c.

bind_table_t* BT_memflood = NULL [static]

Definition at line 84 of file chanserv.c.

const char* channel_config_names[] [static]

Initial value:

 {
  "join", "part", "quit", "cycle", "leave", "ctcp", "msg",
  "notice", "line", "nick", "kick", "mode", "modefight",
  "topic"
}

Definition at line 41 of file chanserv.c.

Referenced by chanserv_refresh_channel_config(), and chanserv_update_stats().

chanserv_config_t chanserv_config

Definition at line 28 of file chanserv.c.

config_var_t chanserv_config_vars[] [static]

Definition at line 47 of file chanserv.c.

event_owner_t chanserv_owner [static]

Initial value:

 {
  "chanserv", 0,
  0, 0,
  0
}

Definition at line 32 of file chanserv.c.

chanserv_channel_stats_t* chanstats_head = NULL [static]

Definition at line 82 of file chanserv.c.

chanserv_channel_stats_t global_chan [static]

Definition at line 30 of file chanserv.c.

const char rcsid[] = "$Id: chanserv.c,v 1.6 2005-12-28 17:27:31 sven Exp $" [static]

Definition at line 21 of file chanserv.c.

egg_server_api_t* server = NULL

Definition at line 29 of file chanserv.c.

int timer_id [static]

Definition at line 31 of file chanserv.c.

Referenced by chanserv_init().