1
0
forked from bip/bip
bip/src/bip.c

1073 lines
23 KiB
C
Raw Normal View History

2005-04-28 10:26:44 +02:00
/*
* $Id: bip.c,v 1.39 2005/04/21 06:58:50 nohar Exp $
*
* This file is part of the bip project
* Copyright (C) 2004 Arnaud Cornet and Lo<EFBFBD>c Gomez
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
* See the file "COPYING" for the exact licensing terms.
*/
#include "config.h"
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <signal.h>
#include <stdarg.h>
#include "irc.h"
#include "conf.h"
#include "tuple.h"
#include "log.h"
#include "irc.h"
#include "bip.h"
#include "line.h"
int sighup = 0;
char *conf_log_root;
char *conf_log_format;
int conf_log_level;
char *conf_ip;
unsigned short conf_port;
int conf_css;
#ifdef HAVE_LIBSSL
char *conf_ssl_certfile;
#endif
int conf_daemonize;
char *conf_pid_file;
hash_t conf_networks;
hash_t conf_users;
char *conf_biphome;
hash_t adm_users;
/* log options, for sure the trickiest :) */
/* no backlog at all */
int conf_backlog;
int conf_memlog;
int conf_log;
2005-04-28 10:26:44 +02:00
/* number of lines in backlog */
int conf_backlog_lines = 10;
/* backlog even lines already backlogged */
int conf_always_backlog;
int conf_log_sync_interval;
int conf_blreset_on_talk = 0;
2005-04-28 10:26:44 +02:00
2005-05-26 17:36:15 +02:00
list_t *parse_conf(FILE *file);
static void conf_die(char *fmt, ...);
2005-04-28 10:26:44 +02:00
static void hash_binary(char *hex, unsigned char **password, unsigned int *seed)
{
unsigned char *md5;
unsigned int buf;
int i;
if (strlen(hex) != 40)
fatal("Incorrect password format %s\n", hex);
md5 = malloc(20);
for (i = 0; i < 20; i++) {
sscanf(hex + 2 * i, "%02x", &buf);
md5[i] = buf;
}
*seed = 0;
sscanf(hex, "%02x", &buf);
*seed |= buf << 24;
sscanf(hex + 2, "%02x", &buf);
*seed |= buf << 16;
sscanf(hex + 2 * 2, "%02x", &buf);
*seed |= buf << 8;
sscanf(hex + 2 * 3, "%02x", &buf);
*seed |= buf;
*password = md5;
}
void server_free(struct server *s)
{
free(s->host);
free(s);
}
2005-05-26 17:36:15 +02:00
static int add_server(list_t *serverl, list_t *data)
2005-04-28 10:26:44 +02:00
{
struct tuple *t;
struct server *s;
2005-05-26 17:36:15 +02:00
2005-04-28 10:26:44 +02:00
s = calloc(sizeof(struct server), 1);
s->port = 6667; /* default port */
while ((t = list_remove_first(data))) {
switch (t->type) {
case LEX_HOST:
s->host = t->pdata;
break;
case LEX_PORT:
s->port = t->ndata;
break;
default:
fatal("Config error in server block (%d)", t->type);
}
}
2005-05-26 17:36:15 +02:00
if (!s->host) {
free(s);
conf_die("Server conf: host not set");
return 0;
}
2005-04-28 10:26:44 +02:00
list_add_last(serverl, s);
2005-05-26 17:36:15 +02:00
return 1;
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
#define ERRBUFSZ 128
2005-04-28 10:26:44 +02:00
extern list_t *root_list;
int yyparse();
int conf_error;
char conf_errstr[ERRBUFSZ];
2005-05-26 17:36:15 +02:00
static void conf_start(void)
{
conf_error = 0;
}
2005-04-28 10:26:44 +02:00
2005-05-26 17:36:15 +02:00
static void conf_die(char *fmt, ...)
2005-04-28 10:26:44 +02:00
{
2005-05-26 17:36:15 +02:00
va_list ap;
va_start(ap, fmt);
vsnprintf(conf_errstr, ERRBUFSZ, fmt, ap);
conf_errstr[ERRBUFSZ - 1] = 0;
2005-07-09 14:55:01 +02:00
conf_error = 1;
2005-05-26 17:36:15 +02:00
va_end(ap);
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
2005-04-28 10:26:44 +02:00
FILE *conf_global_log_file;
static pid_t daemonize(void)
{
char buf[4096];
switch (fork()) {
case -1:
fatal("Fork failed");
break;
case 0:
break;
default:
exit(0);
}
if (setsid() < 0)
fatal("setsid() failed");
2005-05-21 16:23:05 +02:00
if (conf_log) {
snprintf(buf, 4095, "%s/bip.log", conf_log_root);
FILE *f = fopen(buf, "a");
if (!f)
fatal("Can't open %s: %s", buf, strerror(errno));
conf_global_log_file = f;
} else {
conf_global_log_file = stderr;
}
2005-04-28 10:26:44 +02:00
close(0);
close(1);
close(2);
/* This better be the very last action since fatal makes use of
* conf_global_log_file */
return getpid();
}
/* RACE CONDITION! */
int do_pid_stuff(void)
{
char hname[1024];
char longpath[1024];
FILE *f;
try_again:
f = fopen(conf_pid_file, "r");
if (f)
goto pid_is_there;
if (gethostname(hname, 1023) == -1)
fatal("%s %s", "gethostname", strerror(errno));
snprintf(longpath, 1023, "%s.%s.%ld", conf_pid_file, hname,
(long unsigned int)getpid());
int fd;
if ((fd = open(longpath, O_CREAT|O_WRONLY, S_IWUSR|S_IRUSR)) == -1)
fatal("%s %s", "open", strerror(errno));
if (link(longpath, conf_pid_file) == -1) {
struct stat buf;
if (stat(longpath, &buf) == -1) {
if (buf.st_nlink != 2) {
f = fopen(conf_pid_file, "r");
goto pid_is_there;
}
}
}
unlink(longpath);
return fd;
pid_is_there:
{
pid_t pid;
long unsigned int p;
if (f) {
int c = fscanf(f, "%ld", &p);
pid = p;
if (c != 1 || p == 0) {
mylog(LOG_INFO, "pid file found but invalid "
"data inside. Continuing...\n");
if (unlink(conf_pid_file)) {
fatal("Cannot delete pid file '%s', "
"check permissions.\n",
conf_pid_file);
}
goto try_again;
}
} else
pid = 0;
int kr = kill(pid, 0);
if (kr == -1 && (errno == ESRCH || errno == EPERM)) {
/* that's not bip! */
fclose(f);
if (unlink(conf_pid_file)) {
fatal("Cannot delete pid file '%s', check "
"permissions.\n",
conf_pid_file);
}
goto try_again;
}
if (pid)
mylog(LOG_INFO, "pid file found (pid %ld).", pid);
mylog(LOG_INFO, "Another instance of bip is certainly runing.");
mylog(LOG_INFO, "If you are sure this is not the case remove"
" %s.", conf_pid_file);
exit(2);
}
return 0;
}
#define S_CONF "/.bip/bip.conf"
static void usage(char *name)
{
printf(
"Usage: %s [-f config_file] [-h] [-n]\n"
" -f config_file: Use config_file as the configuration file\n"
" If no config file is given %s will try to open ~" S_CONF "\n"
" -n: Don't daemonize, log in stderr\n"
" -h: This help\n", name, name);
exit(1);
}
void reload_config(int i)
{
sighup = 1;
}
2005-05-27 18:50:26 +02:00
extern list_t *_connections;
2005-04-28 10:26:44 +02:00
void bad_quit(int i)
{
2005-05-27 18:50:26 +02:00
list_iterator_t it;
for (list_it_init(_connections, &it); list_it_item(&it);
list_it_next(&it)) {
connection_t *c = list_it_item(&it);
struct link_any *la = c->user_data;
if (c->connected == CONN_OK && la &&
TYPE(la) == IRC_TYPE_SERVER) {
write_line_fast(CONN(la), "QUIT :Coyote finally "
"caught me\r\n");
}
}
2005-04-28 10:26:44 +02:00
unlink(conf_pid_file);
exit(i);
}
void c_network_free(struct c_network *on)
{
struct server *s;
free(on->name);
s = list_remove_first(&on->serverl);
free(s->host);
free(on);
}
2005-05-26 17:36:15 +02:00
static int add_network(list_t *data)
2005-04-28 10:26:44 +02:00
{
struct tuple *t;
struct c_network *n;
2005-05-26 17:36:15 +02:00
struct c_network *old_n;
int r;
2005-04-28 10:26:44 +02:00
2005-05-26 17:36:15 +02:00
n = calloc(sizeof(struct c_network), 1);
2005-04-28 10:26:44 +02:00
list_init(&n->serverl, NULL);
while ((t = list_remove_first(data))) {
switch (t->type) {
case LEX_NAME:
n->name = t->pdata;
break;
#ifdef HAVE_LIBSSL
case LEX_SSL:
n->ssl = t->ndata;
break;
#endif
case LEX_SERVER:
2005-05-26 17:36:15 +02:00
r = add_server(&n->serverl, t->pdata);
free(t->pdata);
if (!r)
return 0;
2005-04-28 10:26:44 +02:00
break;
default:
conf_die("uknown keyword in network statement");
2005-05-26 17:36:15 +02:00
if (t->type == TUPLE_STR)
free(t->pdata);
return 0;
2005-04-28 10:26:44 +02:00
break;
}
2005-05-26 17:36:15 +02:00
free(t);
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
if (!n->name) {
2005-04-28 10:26:44 +02:00
conf_die("Network with no name");
2005-05-26 17:36:15 +02:00
return 0;
}
2005-04-28 10:26:44 +02:00
old_n = hash_get(&conf_networks, n->name);
if (old_n) {
hash_remove(&conf_networks, n->name);
c_network_free(old_n);
}
hash_insert(&conf_networks, n->name, n);
2005-05-26 17:36:15 +02:00
return 1;
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
static int add_channel(list_t *channell, list_t *data)
2005-04-28 10:26:44 +02:00
{
struct tuple *t;
struct c_channel *c;
2005-05-26 17:36:15 +02:00
2005-04-28 10:26:44 +02:00
c = calloc(sizeof(struct c_channel), 1);
while ((t = list_remove_first(data))) {
switch (t->type) {
case LEX_NAME:
c->name = t->pdata;
break;
case LEX_KEY:
c->key = t->pdata;
break;
default:
conf_die("uknown keyword in channel statement");
2005-05-26 17:36:15 +02:00
if (t->type == TUPLE_STR)
free(t->pdata);
return 0;
2005-04-28 10:26:44 +02:00
break;
}
2005-05-26 17:36:15 +02:00
free(t);
2005-04-28 10:26:44 +02:00
}
if (!c->name)
conf_die("channel wo a name !");
list_add_last(channell, c);
2005-05-26 17:36:15 +02:00
return 1;
2005-04-28 10:26:44 +02:00
}
void c_connection_free(struct c_connection *c)
{
/* XXX network free! */
free(c->user);
free(c->password);
free(c->vhost);
struct c_channel *chan;
while ((chan = list_remove_first(&c->channell))) {
free(chan->name);
if (chan->key)
free(chan->key);
free(chan);
}
free(c->away_nick);
free(c->on_connect_send);
}
2005-05-26 17:36:15 +02:00
static int add_connection(list_t *connectionl, list_t *data,
list_t *old_c_connl)
2005-04-28 10:26:44 +02:00
{
struct tuple *t;
struct c_connection *c, *old_c = NULL;
2005-05-26 17:36:15 +02:00
int r;
2005-04-28 10:26:44 +02:00
2005-05-26 17:36:15 +02:00
c = calloc(sizeof(struct c_connection), 1);
2005-04-28 10:26:44 +02:00
list_init(&c->channell, NULL);
while ((t = list_remove_first(data))) {
switch (t->type) {
case LEX_NAME:
c->name = t->pdata;
break;
case LEX_NETWORK:
c->network = hash_get(&conf_networks, t->pdata);
2005-05-26 17:36:15 +02:00
if (!c->network) {
free(c);
2005-04-28 10:26:44 +02:00
conf_die("networkd:%s used but not defined\n",
t->pdata);
2005-05-26 17:36:15 +02:00
return 0;
}
2005-04-28 10:26:44 +02:00
break;
case LEX_NICK:
if (!is_valid_nick(t->pdata))
conf_die("Invalid nickname (%s)", t->pdata);
c->nick = t->pdata;
break;
case LEX_USER:
c->user = t->pdata;
break;
case LEX_REALNAME:
c->realname = t->pdata;
break;
case LEX_PASSWORD:
c->password = t->pdata;
break;
case LEX_CHANNEL:
2005-05-26 17:36:15 +02:00
r = add_channel(&c->channell, t->pdata);
free(t->pdata);
if (!r)
return 0;
2005-04-28 10:26:44 +02:00
break;
case LEX_FOLLOW_NICK:
c->follow_nick = t->ndata;
break;
case LEX_IGN_FIRST_NICK:
c->ignore_first_nick = t->ndata;
break;
case LEX_AWAY_NICK:
c->away_nick = t->pdata;
break;
case LEX_ON_CONNECT_SEND:
c->on_connect_send = t->pdata;
break;
default:
conf_die("uknown keyword in connection statement");
2005-05-26 17:36:15 +02:00
if (t->type == TUPLE_STR)
free(t->pdata);
return 0;
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
free(t);
2005-04-28 10:26:44 +02:00
}
/* checks that can only be here, or must */
2005-05-26 17:36:15 +02:00
if (!c->network) {
2005-04-28 10:26:44 +02:00
conf_die("Missing network in connection block");
2005-05-26 17:36:15 +02:00
return 0;
}
2005-04-28 10:26:44 +02:00
list_add_last(connectionl, c);
if (old_c_connl) {
old_c = list_remove_first(old_c_connl);
if (old_c)
c_connection_free(old_c);
}
2005-05-26 17:36:15 +02:00
return 1;
2005-04-28 10:26:44 +02:00
}
void c_user_free(struct c_user *cu)
{
free(cu->name);
free(cu->password);
#ifdef HAVE_LIBSSL
free(cu->ssl_check_store);
#endif
2005-04-28 10:26:44 +02:00
struct c_connection *con;
while ((con = list_remove_first(&cu->connectionl)))
c_connection_free(con);
free(cu);
}
2005-05-26 17:36:15 +02:00
static int add_user(list_t *data)
2005-04-28 10:26:44 +02:00
{
2005-05-26 17:36:15 +02:00
int r;
2005-04-28 10:26:44 +02:00
struct tuple *t;
struct c_user *u;
struct c_user *old_u;
2005-05-26 17:36:15 +02:00
u = calloc(sizeof(struct c_user), 1);
2005-04-28 10:26:44 +02:00
list_init(&u->connectionl, NULL);
while ((t = list_remove_first(data))) {
switch (t->type) {
case LEX_NAME:
u->name = t->pdata;
old_u = hash_get(&conf_users, u->name);
break;
case LEX_PASSWORD:
hash_binary(t->pdata, &u->password, &u->seed);
free(t->pdata);
break;
2005-07-09 14:55:01 +02:00
case LEX_DEFAULT_NICK:
u->default_nick = t->pdata;
break;
case LEX_DEFAULT_USER:
u->default_user = t->pdata;
break;
case LEX_DEFAULT_REALNAME:
u->default_realname = t->pdata;
break;
2005-04-28 10:26:44 +02:00
case LEX_CONNECTION:
if (!u->name)
conf_die("name statement must be first in user"
"block");
if (!old_u)
2005-05-26 17:36:15 +02:00
r = add_connection(&u->connectionl, t->pdata,
NULL);
2005-04-28 10:26:44 +02:00
else
2005-05-26 17:36:15 +02:00
r = add_connection(&u->connectionl, t->pdata,
2005-04-28 10:26:44 +02:00
&old_u->connectionl);
2005-05-26 17:36:15 +02:00
free(t->pdata);
if (!r)
return 0;
2005-04-28 10:26:44 +02:00
break;
#ifdef HAVE_LIBSSL
case LEX_SSL_CHECK_MODE:
if (!strncmp(t->pdata, "basic", 5))
u->ssl_check_mode = SSL_CHECK_BASIC;
if (!strncmp(t->pdata, "ca", 2))
u->ssl_check_mode = SSL_CHECK_CA;
free(t->pdata);
break;
case LEX_SSL_CHECK_STORE:
u->ssl_check_store = t->pdata;
break;
#endif
2005-04-28 10:26:44 +02:00
default:
2005-05-26 17:36:15 +02:00
conf_die("Uknown keyword in user statement");
if (t->type == TUPLE_STR)
free(t->pdata);
2005-04-28 10:26:44 +02:00
break;
}
2005-05-26 17:36:15 +02:00
free(t);
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
if (!u->name) {
2005-04-28 10:26:44 +02:00
conf_die("User w/o a name!");
2005-05-26 17:36:15 +02:00
return 0;
}
if (!u->password) {
2005-04-28 10:26:44 +02:00
conf_die("Missing password in user block");
2005-05-26 17:36:15 +02:00
return 0;
}
2005-04-28 10:26:44 +02:00
if (old_u) {
hash_remove(&conf_users, u->name);
c_user_free(old_u);
}
hash_insert(&conf_users, u->name, u);
2005-05-26 17:36:15 +02:00
return 1;
2005-04-28 10:26:44 +02:00
}
int fireup(FILE *conf)
{
struct tuple *t;
list_t *l;
2005-05-26 17:36:15 +02:00
int r;
conf_start();
2005-04-28 10:26:44 +02:00
l = parse_conf(conf);
if (conf_error)
return 0;
2005-05-26 17:36:15 +02:00
while ((t = list_remove_first(l))) {
2005-04-28 10:26:44 +02:00
switch (t->type) {
case LEX_LOG_SYNC_INTERVAL:
conf_log_sync_interval = t->ndata;
break;
case LEX_ALWAYS_BACKLOG:
conf_always_backlog = t->ndata;
break;
case LEX_BACKLOG:
conf_backlog = t->ndata;
break;
case LEX_LOG:
conf_log = t->ndata;
2005-04-28 10:26:44 +02:00
break;
case LEX_BACKLOG_LINES:
conf_backlog_lines = t->ndata;
break;
case LEX_LOG_ROOT:
if (conf_log_root)
free(conf_log_root);
conf_log_root = t->pdata;
break;
case LEX_LOG_FORMAT:
if (conf_log_format)
free(conf_log_format);
conf_log_format = t->pdata;
break;
case LEX_LOG_LEVEL:
conf_log_level = t->ndata;
break;
case LEX_IP:
if (conf_ip)
free(conf_ip);
conf_ip = t->pdata;
break;
case LEX_PORT:
conf_port = t->ndata;
break;
case LEX_CSS:
conf_css = t->ndata;
break;
case LEX_PID_FILE:
if (conf_pid_file)
free(conf_pid_file);
conf_pid_file = t->pdata;
break;
case LEX_BLRESET_ON_TALK:
conf_blreset_on_talk = t->ndata;
break;
2005-04-28 10:26:44 +02:00
case LEX_NETWORK:
2005-05-26 17:36:15 +02:00
r = add_network(t->pdata);
list_free(t->pdata);
if (!r)
return 0;
2005-04-28 10:26:44 +02:00
break;
case LEX_USER:
2005-05-26 17:36:15 +02:00
r = add_user(t->pdata);
list_free(t->pdata);
if (!r)
return 0;
2005-04-28 10:26:44 +02:00
break;
default:
2005-05-26 17:36:15 +02:00
if (t->type == TUPLE_STR)
free(t->pdata);
conf_die("Config error in base config (%d)", t->type);
2005-05-30 01:00:30 +02:00
return 0;
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
free(t);
2005-04-28 10:26:44 +02:00
}
2005-05-26 17:36:15 +02:00
free(root_list);
root_list = NULL;
2005-04-28 10:26:44 +02:00
if (conf_backlog && !conf_log) {
if (conf_backlog_lines == 0) {
2005-05-26 17:36:15 +02:00
conf_die("You must set conf_backlog_lines if "
"conf_log = false and "
"conf_backlog = true");
2005-05-30 01:00:30 +02:00
return 0;
}
}
if (!conf_log)
conf_memlog = 1;
else
conf_memlog = 0;
2005-04-28 10:26:44 +02:00
/*
check_networks(networkl);
check_clients(userl);
*/
if (!conf_biphome) {
char *home = getenv("HOME");
if (!home)
2005-05-26 17:36:15 +02:00
conf_die("no $HOME !, do you live in a trailer ?");
2005-04-28 10:26:44 +02:00
conf_biphome = malloc(strlen(home) + strlen("/.bip") + 1);
strcpy(conf_biphome, home);
strcat(conf_biphome, "/.bip");
}
if (!conf_log_root) {
char *ap = "/logs";
conf_log_root = malloc(strlen(conf_biphome) + strlen(ap) + 1);
strcpy(conf_log_root, conf_biphome);
strcat(conf_log_root, ap);
mylog(LOG_INFO, "Default log root: %s", conf_log_root);
}
if (!conf_pid_file) {
char *pid = "/bip.pid";
conf_pid_file = malloc(strlen(conf_biphome) + strlen(pid) + 1);
strcpy(conf_pid_file, conf_biphome);
strcat(conf_pid_file, pid);
mylog(LOG_INFO, "Default pid file: %s", conf_pid_file);
}
#ifdef HAVE_LIBSSL
conf_ssl_certfile = NULL; /* Make into a config option */
if (!conf_ssl_certfile) {
char *home = getenv("HOME");
char *ap = "/.bip/bip.pem";
if (!home)
fatal("no $HOME !, do you live in a trailer ?");
2005-05-26 17:36:15 +02:00
if (conf_ssl_certfile) {
free(conf_ssl_certfile);
conf_ssl_certfile = NULL;
}
2005-04-28 10:26:44 +02:00
conf_ssl_certfile = malloc(strlen(home) + strlen(ap) + 1);
strcpy(conf_ssl_certfile, home);
strcat(conf_ssl_certfile, ap);
mylog(LOG_INFO, "Default SSL certificate file: %s",
conf_ssl_certfile);
}
#endif
if (!conf_log_format)
conf_log_format = "%u/%n/%Y-%m/%c.%d.log";
2005-04-28 10:26:44 +02:00
return 1;
}
void print_link(struct link *l)
{
printf("\n");
}
void print_sumup(void)
{
hash_iterator_t it;
for (hash_it_init(&adm_users, &it); hash_it_item(&it);
hash_it_next(&it)) {
hash_t *u = hash_it_item(&it);
char *uk = hash_it_key(&it);
printf("user: %s", uk);
hash_iterator_t sit;
for (hash_it_init(u, &sit); hash_it_item(&sit);
hash_it_next(&sit)) {
struct link *l = hash_it_item(&sit);
char *ck = hash_it_key(&sit);
printf(" connection: %s", ck);
print_link(l);
}
}
}
void ircize(list_t *ll)
{
hash_iterator_t it;
for (hash_it_init(&conf_users, &it); hash_it_item(&it);
hash_it_next(&it)) {
struct c_user *u = hash_it_item(&it);
hash_t *adm_conn = hash_get(&adm_users, u->name);
if (!adm_conn) {
adm_conn = hash_new(HASH_NOCASE);
hash_insert(&adm_users, u->name, adm_conn);
mylog(LOG_DEBUG, "new user: \"%s\"", u->name);
} else {
mylog(LOG_DEBUG, "old user: \"%s\"", u->name);
}
/*
* A user has multiple connections.
* For each connections create a irc_client and a irc_server
* instance and register them in connection structure;
*/
list_iterator_t cit;
for (list_it_init(&u->connectionl, &cit); list_it_item(&cit);
list_it_next(&cit)) {
struct c_connection *c = list_it_item(&cit);
struct link *link;
int i;
if (!c->name)
fatal("no name for a connection");
link = hash_get(adm_conn, c->name);
if (!link) {
mylog(LOG_DEBUG, "new connection: \"%s\"",
c->name);
link = irc_link_new();
hash_insert(adm_conn, c->name, link);
link->name = strmaydup(c->name);
link->log = log_new(u->name, link->name);
list_iterator_t chit;
for (list_it_init(&c->channell, &chit);
list_it_item(&chit);
list_it_next(&chit)) {
struct c_channel *chan =
list_it_item(&chit);
struct chan_info *ci = chan_info_new();
2005-05-30 20:35:49 +02:00
printf("%s\n",chan->name);
2005-04-28 10:26:44 +02:00
ci->name = strdup(chan->name);
ci->key = strmaydup(chan->key);
hash_insert(&link->chan_infos,
ci->name, ci);
2005-05-30 20:35:49 +02:00
list_add_last(&link->chan_infos_order,
ci);
2005-04-28 10:26:44 +02:00
}
list_add_last(ll, link);
} else {
mylog(LOG_DEBUG, "old connection: \"%s\"",
c->name);
#define MAYFREE(a) do { \
if (a) { \
free(a); \
(a) = NULL; \
} \
} while(0);
MAYFREE(link->away_nick);
MAYFREE(link->password);
MAYFREE(link->user);
MAYFREE(link->real_name);
MAYFREE(link->s_password);
MAYFREE(link->connect_nick);
MAYFREE(link->vhost);
for (i = 0; i < link->serverc; i++)
server_free(link->serverv[i]);
free(link->serverv);
link->serverv = NULL;
link->serverc = 0;
}
link->follow_nick = c->follow_nick;
link->ignore_first_nick = c->ignore_first_nick;
link->on_connect_send = strmaydup(c->on_connect_send);
link->away_nick = strmaydup(c->away_nick);
2005-07-09 14:55:01 +02:00
link->username = strmaydup(u->name);
2005-04-28 10:26:44 +02:00
link->password = malloc(20);
memcpy(link->password, u->password, 20);
link->seed = u->seed;
list_iterator_t seit;
for (list_it_init(&c->network->serverl, &seit);
list_it_item(&seit);
list_it_next(&seit)) {
struct server *s = list_it_item(&seit);
link->serverv = realloc(link->serverv,
(link->serverc + 1)
* sizeof(struct server *));
link->serverv[link->serverc] = server_new();
/* XXX: wrong */
link->serverv[link->serverc]->host
= strmaydup(s->host);
link->serverv[link->serverc]->port = s->port;
link->serverc++;
}
link->user = strmaydup(c->user);
2005-07-09 14:55:01 +02:00
if (!link->user)
link->user = strmaydup(u->default_user);
2005-04-28 10:26:44 +02:00
link->real_name = strmaydup(c->realname);
2005-07-09 14:55:01 +02:00
if (!link->real_name)
link->real_name =
strmaydup(u->default_realname);
2005-04-28 10:26:44 +02:00
link->s_password = strmaydup(c->password);
link->connect_nick = strmaydup(c->nick);
2005-07-09 14:55:01 +02:00
if (!link->connect_nick)
link->connect_nick = strmaydup(u->default_nick);
2005-04-28 10:26:44 +02:00
link->vhost = strmaydup(c->vhost);
link->bind_port = c->source_port;
#ifdef HAVE_LIBSSL
link->s_ssl = c->network->ssl;
link->ssl_check_mode = u->ssl_check_mode;
link->ssl_check_store = strmaydup(u->ssl_check_store);
2005-04-28 10:26:44 +02:00
#endif
if (!link->user)
link->user = strmaydup("bip");
if (!link->connect_nick)
link->connect_nick = strmaydup("bip");
if (!link->real_name)
link->real_name = strmaydup("bip");
printf("clientc: %d\n", link->l_clientc);
}
}
print_sumup();
}
int main(int argc, char **argv)
{
FILE *conf = NULL;
char *confpath = NULL;
list_t *ll = list_new(NULL);
int ch;
int r,fd;
char buf[30];
conf_ip = strdup("0.0.0.0");
conf_port = 7778;
conf_css = 0;
hash_init(&adm_users, HASH_NOCASE);
hash_init(&conf_users, HASH_NOCASE);
hash_init(&conf_networks, HASH_NOCASE);
signal(SIGPIPE, SIG_IGN);
signal(SIGHUP, reload_config);
signal(SIGINT, bad_quit);
signal(SIGQUIT, bad_quit);
signal(SIGTERM, bad_quit);
conf_log_root = NULL;
conf_log_format = NULL;
conf_log_level = LOG_ERROR;
conf_backlog = 1;
conf_log = 1;
2005-04-28 10:26:44 +02:00
conf_backlog_lines = 100;
conf_log_sync_interval = 5;
conf_daemonize = 1;
conf_global_log_file = stderr;
conf_pid_file = NULL;
while ((ch = getopt(argc, argv, "hnf:")) != -1) {
switch (ch) {
case 'f':
confpath = strdup(optarg);
break;
case 'n':
conf_daemonize = 0;
break;
default:
usage(argv[0]);
}
}
if (confpath) {
conf = fopen(confpath, "r");
if (!conf)
fatal("config file not found");
}
if (!conf) {
char *home;
home = getenv("HOME");
if (!home)
fatal("no home");
confpath = malloc(strlen(home) + 1 + strlen(S_CONF) + 1);
*confpath = 0;
strcat(confpath, home);
strcat(confpath, "/");
strcat(confpath, S_CONF);
conf = fopen(confpath, "r");
if (!conf)
fatal("%s config file not found", confpath);
}
r = fireup(conf);
fclose(conf);
if (!r) {
fatal("%s", conf_errstr);
exit(28);
}
fd = do_pid_stuff();
pid_t pid = 0;
if (conf_daemonize)
pid = daemonize();
else
pid = getpid();
snprintf(buf, 29, "%ld\n", (long unsigned int)pid);
write(fd, buf, strlen(buf));
close(fd);
connection_t *inc;
inc = listen_new(conf_ip, conf_port, conf_css);
if (!inc)
fatal("Could not create listening socket");
for (;;) {
if (r)
ircize(ll);
2005-07-09 14:55:01 +02:00
if (conf_error)
mylog(LOG_ERROR, "conf error: %s", conf_errstr);
2005-04-28 10:26:44 +02:00
irc_main(inc, ll);
sighup = 0;
conf = fopen(confpath, "r");
if (!conf)
fatal("%s config file not found", confpath);
r = fireup(conf);
fclose(conf);
}
return 1;
}
void write_user_list(connection_t *c, char *dest)
{
hash_iterator_t it;
list_iterator_t lit;
WRITE_LINE2(c, P_IRCMASK, "PRIVMSG", dest, "bip user list:");
for (hash_it_init(&conf_users, &it); hash_it_item(&it);
hash_it_next(&it)) {
struct c_user *u = hash_it_item(&it);
WRITE_LINE2(c, P_IRCMASK, "PRIVMSG", dest, u->name);
for (list_it_init(&u->connectionl, &lit); list_it_item(&lit);
list_it_next(&lit)) {
struct c_connection *con = list_it_item(&lit);
WRITE_LINE2(c, P_IRCMASK, "PRIVMSG", dest, con->name);
}
}
WRITE_LINE2(c, P_IRCMASK, "PRIVMSG", dest,
"end of bip user list");
}
extern struct link_client *reloading_client;
void adm_blreset(struct link_client *ic)
{
hash_iterator_t it;
for (hash_it_init(&LINK(ic)->log->logfgs, &it);
hash_it_item(&it);
hash_it_next(&it)) {
logfilegroup_t *lfg = hash_it_item(&it);
log_reset(lfg);
}
}
2005-04-28 10:26:44 +02:00
void adm_bip(struct link_client *ic, struct line *line)
{
char *nick;
if (LINK(ic)->l_server)
nick = LINK(ic)->l_server->nick;
else
nick = LINK(ic)->prev_nick;
if (line->elemc < 2)
return;
if (strcasecmp(line->elemv[1], "RELOAD") == 0) {
reloading_client = ic;
sighup = 1;
} else if (strcasecmp(line->elemv[1], "LIST") == 0) {
write_user_list(CONN(ic), nick);
} else if (strcasecmp(line->elemv[1], "JUMP") == 0) {
if (LINK(ic)->l_server) {
WRITE_LINE1(CONN(LINK(ic)->l_server), NULL, "QUIT",
"jumpin' jumpin'");
connection_close(CONN(LINK(ic)->l_server));
}
2005-05-30 01:00:30 +02:00
} else if (strcasecmp(line->elemv[1], "BLRESET") == 0) {
adm_blreset(ic);
2005-04-28 10:26:44 +02:00
} else if (strcasecmp(line->elemv[1], "HELP") == 0) {
WRITE_LINE2(CONN(ic), P_IRCMASK, "PRIVMSG", nick,
"/BIP (RELOAD|LIST|JUMP|BLRESET|HELP)");
2005-04-28 10:26:44 +02:00
}
}
2005-05-26 17:36:15 +02:00
void free_conf(list_t *l)
{
struct tuple *t;
list_iterator_t li;
for (list_it_init(l, &li); (t = list_it_item(&li)); list_it_next(&li)) {
switch (t->tuple_type) {
case TUPLE_STR:
free(t->pdata); /* no break, for the style */
case TUPLE_INT:
free(t);
break;
case TUPLE_LIST:
free_conf(t->pdata);
break;
default:
fatal("internal error free_conf");
break;
}
}
}