deb-mbse/mbtask/taskibc.c

/*****************************************************************************
 *
 * $Id$
 * Purpose ...............: mbtask - Internet BBS Chat (but it looks like...)
 *
 *****************************************************************************
 * Copyright (C) 1997-2006
 *   
 * Michiel Broek		FIDO:	2:280/2802
 * Beekmansbos 10
 * 1971 BV IJmuiden
 * the Netherlands
 *
 * This file is part of MBSE BBS.
 *
 * This BBS 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, or (at your option) any
 * later version.
 *
 * MBSE BBS is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with MBSE BBS; see the file COPYING.  If not, write to the Free
 * Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
 *****************************************************************************/

#include "../config.h"
#include "../lib/mbselib.h"
#include "taskstat.h"
#include "taskutil.h"
#include "taskchat.h"
#include "taskibc.h"




extern int		    internet;		    /* Internet status		*/
time_t			    scfg_time = (time_t)0;  /* Servers config time	*/
time_t			    now;		    /* Current time		*/
ban_list		    *banned = NULL;	    /* Banned users		*/
nick_list		    *nicknames = NULL;	    /* Known nicknames		*/
int			    callchg = FALSE;	    /* Is call state changed	*/
int			    srvchg = FALSE;	    /* Is serverlist changed	*/
int			    usrchg = FALSE;	    /* Is userlist changed	*/
int			    chnchg = FALSE;	    /* Is channellist changed	*/
int			    banchg = FALSE;	    /* Is banned users changed	*/
int			    nickchg = FALSE;	    /* Is nicknames changed	*/
time_t			    resettime;		    /* Time to reset all	*/
int			    do_reset = FALSE;	    /* Reset init		*/
int			    link_reset = FALSE;	    /* Reset one link		*/
extern struct sockaddr_in   clientaddr_in;          /* IBC remote socket	*/


#define	PING_PONG_LOG	1

typedef enum {NCS_INIT, NCS_CALL, NCS_WAITPWD, NCS_CONNECT, NCS_HANGUP, NCS_FAIL, NCS_DEAD} NCSTYPE;


static char *ncsstate[] = {
    (char *)"init", (char *)"call", (char *)"waitpwd", (char *)"connect", 
    (char *)"hangup", (char *)"fail", (char *)"dead"
};


static char *mon[] = {
    (char *)"Jan",(char *)"Feb",(char *)"Mar",
    (char *)"Apr",(char *)"May",(char *)"Jun",
    (char *)"Jul",(char *)"Aug",(char *)"Sep",
    (char *)"Oct",(char *)"Nov",(char *)"Dec"
};



/*
 * Internal prototypes
 */
void fill_ncslist(char *, char *, char *, int, unsigned int);
void dump_ncslist(void);
int  add_server(char *, int, char *, char *, char *, char *);
void del_server(char *);
void del_router(char *);
int  send_msg(int, char *);
void broadcast(char *, char *);
void check_servers(void);
int  command_pass(int, char *, char *);
int  command_server(char *, char *);
int  command_squit(int, char *, char *);
int  command_user(int, char *, char *);
int  command_quit(int, char *, char *);
int  command_nick(int, char *, char *);
int  command_join(int, char *, char *);
int  command_part(int, char *, char *);
int  command_topic(int, char *, char *);
int  command_privmsg(int, char *, char *);



/*
 * Add a server to the neighbour serverlist
 */
void fill_ncslist(char *server, char *myname, char *passwd, int dyndns, unsigned int crc)
{
    int	    i;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) == 0) {
	    strncpy(ncs_list[i].server, server, 63);
	    strncpy(ncs_list[i].resolved, server, 63);
	    strncpy(ncs_list[i].myname, myname, 63);
	    strncpy(ncs_list[i].passwd, passwd, 15);
	    ncs_list[i].state = NCS_INIT;
	    ncs_list[i].action = now;
	    ncs_list[i].last = (time_t)0;
	    ncs_list[i].version = 0;
	    ncs_list[i].remove = FALSE;
	    ncs_list[i].socket = -1;
	    ncs_list[i].token = 0;
	    ncs_list[i].gotpass = FALSE;
	    ncs_list[i].gotserver = FALSE;
	    ncs_list[i].dyndns = dyndns;
	    ncs_list[i].halfdead = 0;
	    ncs_list[i].crc = crc;
	    return;
	}
    }

    WriteError("IBC: ncs_list is full");
}



void dump_ncslist(void)
{   
    char	temp1[128], temp2[128], buf[21];
    struct tm	ptm;
    time_t	tnow;
    int		i, first;

    if (!callchg && !srvchg && !usrchg && !chnchg && !banchg && !nickchg)
	return;

    if (callchg) {
	first = FALSE;
	for (i = 0; i < MAXIBC_NCS; i++) {
	    if (strlen(ncs_list[i].server)) {
		if (! first) {
		    Syslog('r', "IBC: Idx Server                         State   Del Pwd Srv Dyn 1/2 Next action");
		    Syslog('r', "IBC: --- ------------------------------ ------- --- --- --- --- --- -----------");
		    first = TRUE;
		}
		snprintf(temp1, 30, "%s", ncs_list[i].server);
		Syslog('r', "IBC: %3d %-30s %-7s %s %s %s %s %3d %d", i, temp1, ncsstate[ncs_list[i].state], 
		    ncs_list[i].remove ? "yes":"no ", ncs_list[i].gotpass ? "yes":"no ", 
		    ncs_list[i].gotserver ? "yes":"no ", ncs_list[i].dyndns ? "yes":"no ",
		    ncs_list[i].halfdead, (int)ncs_list[i].action - (int)now);
	    }
	} 
	if (! first) {
	    Syslog('r', "IBC: No servers configured");
	}
    }

    if (srvchg) {
	first = FALSE;
	for (i = 0; i < MAXIBC_SRV; i++) {
	    if (strlen(srv_list[i].server)) {
		if (! first) {
		    Syslog('+', "IBC: Idx Server                    Router                     Hops Users Connect time");
		    Syslog('+', "IBC: --- ------------------------- ------------------------- ----- ----- --------------------");
		    first = TRUE;
		}
		snprintf(temp1, 25, "%s", srv_list[i].server);
		snprintf(temp2, 25, "%s", srv_list[i].router);
		tnow = (time_t)srv_list[i].connected;
		localtime_r(&tnow, &ptm);
		snprintf(buf, 21, "%02d-%s-%04d %02d:%02d:%02d", ptm.tm_mday, mon[ptm.tm_mon], ptm.tm_year+1900,
			ptm.tm_hour, ptm.tm_min, ptm.tm_sec);
		Syslog('+', "IBC: %3d %-25s %-25s %5d %5d %s", i, temp1, temp2, srv_list[i].hops, srv_list[i].users, buf);
	    }
	} 
	if (! first) {
	    Syslog('+', "IBC: Servers list is empty");
	}
    }
    
    if (usrchg) {
	first = FALSE;
	for (i = 0; i < MAXIBC_USR; i++) {
	    if (strlen(usr_list[i].server)) {
		if (! first) {
		    Syslog('+', "IBC: Idx Server               User             Name/Nick Channel       Sys Connect time");
		    Syslog('+', "IBC: --- -------------------- ---------------- --------- ------------- --- --------------------");
		    first = TRUE;
		}
		snprintf(temp1, 20, "%s", usr_list[i].server);
		snprintf(temp2, 16, "%s", usr_list[i].realname);
		tnow = (time_t)usr_list[i].connected;
		localtime_r(&tnow, &ptm);
		snprintf(buf, 21, "%02d-%s-%04d %02d:%02d:%02d", ptm.tm_mday, mon[ptm.tm_mon], ptm.tm_year+1900,
			ptm.tm_hour, ptm.tm_min, ptm.tm_sec);
		Syslog('+', "IBC: %3d %-20s %-16s %-9s %-13s %s %s", i, temp1, temp2, usr_list[i].nick, usr_list[i].channel,
		    usr_list[i].sysop ? "yes":"no ", buf);
	    }
	} 
	if (! first) {
	    Syslog('+', "IBC: Users list is empty");
	}
    }

    if (chnchg) {
	first = FALSE;
	for (i = 0; i < MAXIBC_CHN; i++) {
	    if (strlen(chn_list[i].server)) {
		if (! first) {
		    Syslog('+', "IBC: Idx Channel              Owner     Topic                           Usr Created");
		    Syslog('+', "IBC: --- -------------------- --------- ------------------------------- --- --------------------");
		    first = TRUE;
		}
		tnow = (time_t)chn_list[i].created;
		localtime_r(&tnow, &ptm);
		snprintf(buf, 21, "%02d-%s-%04d %02d:%02d:%02d", ptm.tm_mday, mon[ptm.tm_mon], ptm.tm_year+1900,
			ptm.tm_hour, ptm.tm_min, ptm.tm_sec);
		Syslog('+', "IBC: %3d %-20s %-9s %-31s %3d %s", i, chn_list[i].name, 
			chn_list[i].owner, chn_list[i].topic, chn_list[i].users, buf);
	    }
	} 
	if (! first) {
	    Syslog('+', "IBC: Channels list is empty");
	}
    }

    callchg = FALSE;
    srvchg = FALSE;
    usrchg = FALSE;
    chnchg = FALSE;
    banchg = FALSE;
    nickchg = FALSE;
}



/*
 * Add one user to the userlist. Returns:
 *  0 = Ok
 *  1 = User already registered.
 *  2 = Too many users.
 */
int add_user(char *server, char *name, char *realname)
{
    int	    i, j, Found = FALSE;

    Syslog('r', "IBC: add_user (%s, %s, %s)", server, name, realname);

    for (j = 0; j < MAXIBC_USR; j++) {
	if ((strcmp(usr_list[j].server, server) == 0) && (strcmp(usr_list[j].realname, realname) == 0)) {
	    Syslog('-', "IBC: add_user(%s, %s, %s), already registered", server, name, realname);
	    return 1;
	}
    }

    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strcmp(srv_list[i].server, server) == 0) {
	    Found = TRUE;
	    break;
	}
    }
    if (!Found) {
	Syslog('-', "IBC: add_user(%s, %s, %s), unknown server", server, name, realname);
	return 1;
    }

    for (j = 0; j < MAXIBC_USR; j++) {
	if (strlen(usr_list[j].server) == 0) {
	    strncpy(usr_list[j].server, server, 63);
	    strncpy(usr_list[j].name, name, 9);
	    strncpy(usr_list[j].nick, name, 9);
	    strncpy(usr_list[j].realname, realname, 36);
	    usr_list[j].connected = now;
	    srv_list[i].users++;
	    srvchg = TRUE;
	    usrchg = TRUE;
	    return 0;
	}
    }

    Syslog('-', "IBC: add_user(%s, %s, %s), user list is full", server, name, realname);
    return 2;
}



/*
 * Delete one user. If name == NULL then delete all users of a server.
 */
void del_user(char *server, char *name)
{
    int	    i, count = 0;

    Syslog('r', "IBC: deluser (%s, %s)", server, printable(name, 0));

    for (i = 0; i < MAXIBC_USR; i++) {
	if (name && (strcmp(usr_list[i].server, server) == 0) && (strcmp(usr_list[i].name, name) == 0)) {
	    Syslog('r', "IBC: removed user %s from %s slot %d", name, server, i);
	    memset(&usr_list[i], 0, sizeof(_usr_list));
	    usrchg = TRUE;
	    count++;
	} else if ((name == NULL) && (strcmp(usr_list[i].server, server) == 0)) {
	    Syslog('r', "IBC: removed user %s from %s slot %d", usr_list[i].name, usr_list[i].server, i);
	    memset(&usr_list[i], 0, sizeof(_usr_list));
	    usrchg = TRUE;
	    count++;
	}
    }

    for (i = 0; i < MAXIBC_SRV; i++) {
	if ((strcmp(srv_list[i].server, server) == 0) && srv_list[i].users) {
	    srv_list[i].users -= count;
	    if (srv_list[i].users < 0)
		srv_list[i].users = 0;	/* Just in case, nothing is perfect */
	    srvchg = TRUE;
	}
    }
}



/*
 * Add channel with owner, returns:
 *   0 = Success
 *   1 = Already registered
 *   2 = Too many channels
 */
int add_channel(char *name, char *owner, char *server)
{
    int	    i;

    Syslog('r', "IBC: add_channel (%s, %s, %s)", name, owner, server);

    for (i = 0; i < MAXIBC_CHN; i++) {
	if ((strcmp(chn_list[i].name, name) == 0) && (strcmp(chn_list[i].owner, owner) == 0) && 
		(strcmp(chn_list[i].server, server) == 0)) {
	    Syslog('-', "IBC: add_channel(%s, %s, %s), already registered", name, owner, server);
	    return 1;
	}
    }

    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strlen(chn_list[i].server) == 0) {
	    strncpy(chn_list[i].name, name, 20);
	    strncpy(chn_list[i].owner, owner, 9);
	    strncpy(chn_list[i].server, server, 63);
	    chn_list[i].users = 1;
	    chn_list[i].created = now;
	    chnchg = TRUE;
	    return 0;
	}
    }

    Syslog('-', "IBC: add_channel(%s, %s, %s), too many channels", name, owner, server);
    return 2;
}



void del_channel(char *name)
{
    int	    i;
	        
    Syslog('r', "IBC: del_channel %s", name);

    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strcmp(chn_list[i].name, name) == 0) {
	    memset(&chn_list[i], 0, sizeof(_chn_list));
	}
    }
}



int add_server(char *name, int hops, char *prod, char *vers, char *fullname, char *router)
{
    int	    i, haverouter = FALSE;

    Syslog('r', "IBC: add_server %s %d %s %s \"%s\" %s", name, hops, prod, vers, fullname, router);
 
    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strlen(srv_list[i].server) && (strcmp(srv_list[i].server, name) == 0)) {
	    Syslog('r', "IBC: duplicate, ignore");
	    return 0;
	}
    }

    /*
     * If name <> router it's a remote server, then check if we have a router in our list.
     */
    if (strcmp(name, router) && hops) {
	for (i = 0; i < MAXIBC_SRV; i++) {
	    if (strcmp(srv_list[i].server, router) == 0) {
		haverouter = TRUE;
		break;
	    }
	}
	if (! haverouter) {
	    Syslog('-', "IBC: no router for server %s, ignore", name);
	    return 0;
	}
    }

    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strlen(srv_list[i].server) == 0) {
	    strncpy(srv_list[i].server, name, 63);
	    strncpy(srv_list[i].router, router, 63);
	    strncpy(srv_list[i].prod, prod, 20);
	    strncpy(srv_list[i].vers, vers, 20);
	    strncpy(srv_list[i].fullname, fullname, 35);
	    srv_list[i].connected = now;
	    srv_list[i].users = 0;
	    srv_list[i].hops = hops;
	    srvchg = TRUE;
	    return 1;
	}
    }

    Syslog('!', "IBC: Can't add server, no free slot");
    return 0;
}



/*
 * Delete server.
 */
void del_server(char *name)
{
    int	    i;

    Syslog('r', "IBC: delserver %s", name);

    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strcmp(srv_list[i].server, name) == 0) {
	    memset(&srv_list[i], 0, sizeof(_srv_list));
	    srvchg = TRUE;
	}
    }
}



/*  
 * Delete router.
 */ 
void del_router(char *name)
{   
    int	    i;
    
    Syslog('r', "IBC: delrouter %s", name);

    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strcmp(srv_list[i].router, name) == 0) {
	    del_user(srv_list[i].server, NULL);
	    memset(&srv_list[i], 0, sizeof(_srv_list));
	    srvchg = TRUE;
	}
    }
}



/*
 * Send a message to all servers
 */
void send_all(char *msg)
{
    int	    i;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) && (ncs_list[i].state == NCS_CONNECT)) {
	    send_msg(i, msg);
	}
    }
}



/*
 * Send command message to each connected neighbour server and use the correct own fqdn.
 */
void send_at(char *cmd, char *nick, char *param)
{   
    int	    i;
    char    *p;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) && (ncs_list[i].state == NCS_CONNECT)) {
	    p = xstrcpy(cmd);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, nick);
	    p = xstrcat(p, (char *)"@");
	    p = xstrcat(p, ncs_list[i].myname);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, param);
	    p = xstrcat(p, (char *)"\r\n");
	    send_msg(i, p);
	    free(p);
	}
    }
}



void send_nick(char *nick, char *name, char *realname)
{
    int	    i;
    char    *p;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) && (ncs_list[i].state == NCS_CONNECT)) {
	    p = xstrcpy((char *)"NICK ");
	    p = xstrcat(p, nick);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, name);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, ncs_list[i].myname);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, realname);
	    p = xstrcat(p, (char *)"\r\n");
	    send_msg(i, p);
	    free(p);
	}
    }
}



/*
 * Broadcast a message to all servers except the originating server
 */
void broadcast(char *origin, char *msg)
{
    int	    i;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) && (ncs_list[i].state == NCS_CONNECT) && (strcmp(origin, ncs_list[i].server))) {
	    send_msg(i, msg);
	}
    }
}



/*
 * Send message to a server
 */
int send_msg(int slot, char *msg)
{
    char	*p;
	
#ifndef	PING_PONG_LOG
    if (strcmp(msg, "PING\r\n") && strcmp(msg, "PONG\r\n")) {
#endif
	p = xstrcpy((char *)"IBC: > ");
	p = xstrcat(p, ncs_list[slot].server);
	p = xstrcat(p, (char *)": ");
	p = xstrcat(p, printable(msg, 0));
	Syslogp('r', p);
	free(p);
#ifndef PING_PONG_LOG
    }
#endif

    if (sendto(ncs_list[slot].socket, msg, strlen(msg), 0, 
		(struct sockaddr *)&ncs_list[slot].servaddr_in, sizeof(struct sockaddr_in)) == -1) {
	Syslog('!', "$IBC: can't send message");
	return -1;
    }
    return 0;
}



void check_servers(void)
{
    char	    *errmsg, *p, scfgfn[PATH_MAX];
    FILE	    *fp;
    int		    i, j, inlist, Remove, local_reset, conf_changed;
    int		    a1, a2, a3, a4, users = 0, channels = 0;
    unsigned int    crc;
    struct servent  *se;
    struct hostent  *he;

    now = time(NULL);
    snprintf(scfgfn, PATH_MAX, "%s/etc/ibcsrv.data", getenv("MBSE_ROOT"));
    
    /*
     * Check if we reached the global reset time
     */
    if (((int)now > (int)resettime) && !do_reset) {
	resettime = time(NULL) + (time_t)86400;
	do_reset = TRUE;
	Syslog('+', "IBC: global reset time reached, preparing reset");
    }

    local_reset = conf_changed = FALSE;
    for (i = 0; i < MAXIBC_USR; i++)
	if (strlen(usr_list[i].server))
	    users++;
    for (i = 0; i < MAXIBC_CHN; i++)
	if (strlen(chn_list[i].server))
	    channels++;
    if (!users && !channels && do_reset) {
	Syslog('+', "IBC: no channels and users, performing reset");
	local_reset = TRUE;
	do_reset = FALSE;
    }

    if (file_time(scfgfn) != scfg_time) {
	conf_changed = TRUE;
	Syslog('+', "IBC: %s filetime changed, rereading configuration", scfgfn);
    }

    /*
     * Check if configuration is changed, if so then apply the changes.
     */
    if (conf_changed || local_reset || link_reset) {

	if (strlen(srv_list[0].server) == 0) {
	    /*
	     * First add this server name to the servers database.
	     */
	    add_server(CFG.myfqdn, 0, (char *)"mbsebbs", (char *)VERSION, CFG.bbs_name, (char *)"none");
	}

	/*
	 * Local reset, make all crc's invalid so the connections will restart.
	 */
	if (local_reset) {
	    for (i = 0; i < MAXIBC_NCS; i++)
		if (strlen(ncs_list[i].server))
		    ncs_list[i].crc--;
	}
	
	if (link_reset) {
	    Syslog('r', "IBC: link_reset starting");
	    link_reset = FALSE;
	}

	if ((fp = fopen(scfgfn, "r"))) {
	    fread(&ibcsrvhdr, sizeof(ibcsrvhdr), 1, fp);

            /*
	     * Check for neighbour servers to delete
	     */
	    for (i = 0; i < MAXIBC_NCS; i++) {
		if (strlen(ncs_list[i].server)) {
		    fseek(fp, ibcsrvhdr.hdrsize, SEEK_SET);
		    inlist = FALSE;
		    while (fread(&ibcsrv, ibcsrvhdr.recsize, 1, fp)) {
			crc = 0xffffffff;
			crc = upd_crc32((char *)&ibcsrv, crc, sizeof(ibcsrv));
			if ((strcmp(ncs_list[i].server, ibcsrv.server) == 0) && ibcsrv.Active && (ncs_list[i].crc == crc)) {
			    inlist = TRUE;
			}
		    }
		    if (!inlist) {
			if (local_reset || link_reset)
			    Syslog('+', "IBC: server %s connection reset", ncs_list[i].server);
			else
			    Syslog('+', "IBC: server %s configuration changed or removed", ncs_list[i].server);
			ncs_list[i].remove = TRUE;
			ncs_list[i].action = now;
			srvchg = TRUE;
			callchg = TRUE;
		    }
		}
	    }

	    /*
	     * Start removing servers
	     */
	    Remove = FALSE;
	    for (i = 0; i < MAXIBC_NCS; i++) {
		if (ncs_list[i].remove) {
		    Remove = TRUE;
		    Syslog('r', "IBC: Remove server %s", ncs_list[i].server);
		    if (ncs_list[i].state == NCS_CONNECT) {
			p = calloc(512, sizeof(char));
			if (local_reset) {
			    snprintf(p, 512, "SQUIT %s Reset connection\r\n", ncs_list[i].server);
			    broadcast(ncs_list[i].server, p);
			    snprintf(p, 512, "SQUIT %s Your system connection is reset\r\n", ncs_list[i].myname);
			    send_msg(i, p);
			} else {
			    snprintf(p, 512, "SQUIT %s Removed from configuration\r\n", ncs_list[i].server);
			    broadcast(ncs_list[i].server, p);
			    snprintf(p, 512, "SQUIT %s Your system is removed from configuration\r\n", ncs_list[i].myname);
			    send_msg(i, p);
			}
			free(p);
			del_router(ncs_list[i].server);
		    }
		    if (ncs_list[i].socket != -1) {
			Syslog('r', "IBC: Closing socket %d", ncs_list[i].socket);
			shutdown(ncs_list[i].socket, SHUT_WR);
			ncs_list[i].socket = -1;
			ncs_list[i].state = NCS_HANGUP;
		    }
		    callchg = TRUE;
		    srvchg = TRUE;
		}
	    }
	    dump_ncslist();

	    if (link_reset) {
		link_reset = FALSE;
	    }

	    /*
	     * If a neighbour is removed by configuration, remove it from the list.
	     */
	    if (Remove) {
		Syslog('r', "IBC: Starting remove list");
		for (i = 0; i < MAXIBC_NCS; i++) {
		    if (ncs_list[i].remove) {
		        Syslog('r', "do %s", ncs_list[i].server);
			memset(&ncs_list[i], 0, sizeof(_ncs_list));
		        callchg = TRUE;
		    }
		}
	    }
	    dump_ncslist();
	    
	    /*
	     * Changed or deleted servers are now removed, add new
	     * configured servers or changed servers.
	     */
	    fseek(fp, ibcsrvhdr.hdrsize, SEEK_SET);
	    while (fread(&ibcsrv, ibcsrvhdr.recsize, 1, fp)) {

		/*
		 * Check for new configured servers
		 */
		if (ibcsrv.Active && strlen(ibcsrv.myname) && strlen(ibcsrv.server) && strlen(ibcsrv.passwd)) {
		    inlist = FALSE;
		    for (i = 0; i < MAXIBC_NCS; i++) {
			if (strcmp(ncs_list[i].server, ibcsrv.server) == 0) {
			    inlist = TRUE;
			}
		    }
		    for (j = 0; j < MAXIBC_SRV; j++) {
			if ((strcmp(srv_list[j].server, ibcsrv.server) == 0) && (strcmp(srv_list[j].router, ibcsrv.server))) {
			    inlist = TRUE;
			    Syslog('+', "IBC: can't add new configured server %s: already connected via %s", 
				    ibcsrv.server, srv_list[j].router);
			}
		    }
		    if (!inlist ) {
			crc = 0xffffffff;
			crc = upd_crc32((char *)&ibcsrv, crc, sizeof(ibcsrv));
			fill_ncslist(ibcsrv.server, ibcsrv.myname, ibcsrv.passwd, ibcsrv.Dyndns, crc);
			srvchg = TRUE;
			callchg = TRUE;
			Syslog('+', "IBC: new configured Internet BBS Chatserver: %s", ibcsrv.server);
		    }
		}
	    }
	    fclose(fp);
	}
	scfg_time = file_time(scfgfn);
    }
    dump_ncslist();

    /*
     * Check if we need to make state changes
     */
    for (i = 0; i < MAXIBC_NCS; i++) {

	if (strlen(ncs_list[i].server) == 0)
	    continue;

	if (((int)ncs_list[i].action - (int)now) <= 0) {
	    switch (ncs_list[i].state) {
		case NCS_INIT:	    Syslog('r', "IBC: %s init", ncs_list[i].server);

				    /*
				     * If Internet is available, setup the connection.
				     */
				    if (internet) {
					/*
					 * Get IP address for the hostname, set default next action
					 * to 60 seconds.
					 */
					ncs_list[i].action = now + (time_t)60;
					memset(&ncs_list[i].servaddr_in, 0, sizeof(struct sockaddr_in));
					se = getservbyname("fido", "udp");
					ncs_list[i].servaddr_in.sin_family = AF_INET;
					ncs_list[i].servaddr_in.sin_port = se->s_port;
					
					if (sscanf(ncs_list[i].server,"%d.%d.%d.%d",&a1,&a2,&a3,&a4) == 4)
					    ncs_list[i].servaddr_in.sin_addr.s_addr = inet_addr(ncs_list[i].server);
					else if ((he = gethostbyname(ncs_list[i].server)))
					    memcpy(&ncs_list[i].servaddr_in.sin_addr, he->h_addr, he->h_length);
					else {
					    switch (h_errno) {
						case HOST_NOT_FOUND:    errmsg = (char *)"Authoritative: Host not found"; break;
						case TRY_AGAIN:         errmsg = (char *)"Non-Authoritive: Host not found"; break;
						case NO_RECOVERY:       errmsg = (char *)"Non recoverable errors"; break;
						default:                errmsg = (char *)"Unknown error"; break;
					    }
					    Syslog('!', "IBC: no IP address for %s: %s", ncs_list[i].server, errmsg);
					    ncs_list[i].action = now + (time_t)120;
					    ncs_list[i].state = NCS_FAIL;
					    callchg = TRUE;
					    break;
					}
					
					if (ncs_list[i].socket == -1) {
					    ncs_list[i].socket = socket(AF_INET, SOCK_DGRAM, 0);
					    if (ncs_list[i].socket == -1) {
						Syslog('!', "$IBC: can't create socket for %s", ncs_list[i].server);
						ncs_list[i].state = NCS_FAIL;
						ncs_list[i].action = now + (time_t)120;
						callchg = TRUE;
						break;
					    }
					    Syslog('r', "IBC: socket created");
					} else {
					    Syslog('r', "IBC: socket reused");
					}

					Syslog('r', "IBC: socket %d", ncs_list[i].socket);
					ncs_list[i].state = NCS_CALL;
					ncs_list[i].action = now + (time_t)1;
					callchg = TRUE;
				    } else {
					ncs_list[i].action = now + (time_t)10;
				    }
				    break;
				    
		case NCS_CALL:	    /*
				     * In this state we accept PASS and SERVER commands from
				     * the remote with the same token as we have sent.
				     */
				    Syslog('r', "IBC: %s call", ncs_list[i].server);
				    if (strlen(ncs_list[i].passwd) == 0) {
					Syslog('!', "IBC: no password configured for %s", ncs_list[i].server);
					ncs_list[i].state = NCS_FAIL;
					ncs_list[i].action = now + (time_t)300;
					callchg = TRUE;
					break;
				    }
				    ncs_list[i].token = gettoken();
				    p = calloc(512, sizeof(char));
				    snprintf(p, 512, "PASS %s 0100 %s\r\n", ncs_list[i].passwd, ncs_list[i].compress ? "Z":"");
				    send_msg(i, p);
				    snprintf(p, 512, "SERVER %s 0 %d mbsebbs %s %s\r\n",  ncs_list[i].myname, ncs_list[i].token, 
					    VERSION, CFG.bbs_name);
				    send_msg(i, p);
				    free(p);
				    ncs_list[i].action = now + (time_t)10;
				    ncs_list[i].state = NCS_WAITPWD;
				    callchg = TRUE;
				    break;
				    
		case NCS_WAITPWD:   /*
				     * This state can be left by before the timeout is reached
				     * by a reply from the remote if the connection is accepted.
				     */
				    Syslog('r', "IBC: %s waitpwd", ncs_list[i].server);
				    ncs_list[i].token = 0;
				    ncs_list[i].state = NCS_CALL;
				    while (TRUE) {
					j = 1+(int) (1.0 * CFG.dialdelay * rand() / (RAND_MAX + 1.0));
					if ((j > (CFG.dialdelay / 10)) && (j > 9))
					    break;
				    }
				    Syslog('r', "IBC: next call in %d %d seconds", CFG.dialdelay, j);
				    ncs_list[i].action = now + (time_t)j;
				    callchg = TRUE;
				    break;

		case NCS_CONNECT:   /*
				     * In this state we check if the connection is still alive
				     */
				    j = (int)now - (int)ncs_list[i].last;
				    if (ncs_list[i].halfdead > 5) {
					/*
					 * Halfdead means 5 times received a PASS while we are in
					 * connected state. This means the other side "thinks" it's
					 * not connected and tries to connect. This can be caused by
					 * temporary internet problems. 
					 * Reset our side of the connection.
					 */
					Syslog('+', "IBC: server %s connection is half dead", ncs_list[i].server);
					ncs_list[i].state = NCS_DEAD;
					ncs_list[i].action = now + (time_t)60;    // 1 minute delay before calling again.
					ncs_list[i].gotpass = FALSE;
					ncs_list[i].gotserver = FALSE;
					ncs_list[i].token = 0;
					ncs_list[i].halfdead = 0;
					p = calloc(81, sizeof(char));
					snprintf(p, 81, "SQUIT %s Connection died\r\n", ncs_list[i].server);
					broadcast(ncs_list[i].server, p);
					free(p);
					callchg = TRUE;
					srvchg = TRUE;
					system_shout("*** NETWORK SPLIT, lost connection with server %s", ncs_list[i].server);
					del_router(ncs_list[i].server);
					break;
				    }
				    if (((int)now - (int)ncs_list[i].last) > 130) {
					/*
					 * Missed 3 PING replies
					 */
					Syslog('+', "IBC: server %s connection is dead", ncs_list[i].server);
					ncs_list[i].state = NCS_DEAD;
					ncs_list[i].action = now + (time_t)120;    // 2 minutes delay before calling again.
					ncs_list[i].gotpass = FALSE;
					ncs_list[i].gotserver = FALSE;
					ncs_list[i].token = 0;
					ncs_list[i].halfdead = 0;
					p = calloc(81, sizeof(char));
					snprintf(p, 81, "SQUIT %s Connection died\r\n", ncs_list[i].server);
					broadcast(ncs_list[i].server, p);
					free(p);
					callchg = TRUE;
					srvchg = TRUE;
					system_shout("*** NETWORK SPLIT, lost connection with server %s", ncs_list[i].server);
					del_router(ncs_list[i].server);
					break;
				    }
				    /*
				     * Ping at 60, 90 and 120 seconds
				     */
				    if (((int)now - (int)ncs_list[i].last) > 120) {
					Syslog('r', "IBC: sending 3rd PING at 120 seconds");
					send_msg(i, (char *)"PING\r\n");
				    } else if (((int)now - (int)ncs_list[i].last) > 90) {
					Syslog('r', "IBC: sending 2nd PING at 90 seconds");
					send_msg(i, (char *)"PING\r\n");
				    } else if (((int)now - (int)ncs_list[i].last) > 60) {
					send_msg(i, (char *)"PING\r\n");
				    }
				    ncs_list[i].action = now + (time_t)10;
				    break;

		case NCS_HANGUP:    Syslog('r', "IBC: %s hangup => call", ncs_list[i].server);
				    ncs_list[i].action = now + (time_t)1;
				    ncs_list[i].state = NCS_CALL;
				    callchg = TRUE;
				    srvchg = TRUE;
				    break;

		case NCS_DEAD:	    Syslog('r', "IBC: %s dead -> call", ncs_list[i].server);
				    ncs_list[i].action = now + (time_t)1;
				    ncs_list[i].state = NCS_CALL;
				    callchg = TRUE;
				    srvchg = TRUE;
				    break;

		case NCS_FAIL:	    Syslog('r', "IBC: %s fail => init", ncs_list[i].server);
				    ncs_list[i].action = now + (time_t)1;
				    ncs_list[i].state = NCS_INIT;
				    callchg = TRUE;
				    srvchg = TRUE;
				    break;
	    }
	}
    }

    dump_ncslist();
}



int command_pass(int slot, char *hostname, char *parameters)
{
    char    *passwd, *version, *lnk;

    ncs_list[slot].gotpass = FALSE;
    passwd = strtok(parameters, " \0");
    version = strtok(NULL, " \0");
    lnk = strtok(NULL, " \0");

    if (strcmp(passwd, "0100") == 0) {
	send_msg(slot, (char *)"414 PASS: Got empty password\r\n");
	return 414;
    }

    if (version == NULL) {
	send_msg(slot, (char *)"400 PASS: Not enough parameters\r\n");
	return 400;
    }

    if (strcmp(passwd, ncs_list[slot].passwd)) {
	Syslog('!', "IBC: got bad password %s from %s", passwd, hostname);
	return 0;
    }

    if (ncs_list[slot].state == NCS_CONNECT) {
	send_msg(slot, (char *)"401: PASS: Already registered\r\n");
	ncs_list[slot].halfdead++;   /* Count them   */
	srvchg = TRUE;
	return 401;
    }

    ncs_list[slot].gotpass = TRUE;
    ncs_list[slot].version = atoi(version);
    if (lnk && strchr(lnk, 'Z'))
	ncs_list[slot].compress = TRUE;
    return 0;
}



int command_server(char *hostname, char *parameters)
{
    char	    *p, *name, *hops, *id, *prod, *vers, *fullname;
    unsigned int    token;
    int		    i, j, ihops, found = FALSE;

    name = strtok(parameters, " \0");
    hops = strtok(NULL, " \0");
    id = strtok(NULL, " \0");
    prod = strtok(NULL, " \0");
    vers = strtok(NULL, " \0");
    fullname = strtok(NULL, "\0");
    ihops = atoi(hops) + 1;

    for (i = 0; i < MAXIBC_SRV; i++) {
	if (strcmp(ncs_list[i].server, name) == 0) {
	    found = TRUE;
	    break;
	}
    }

    if (found && fullname == NULL) {
	send_msg(i, (char *)"400 SERVER: Not enough parameters\r\n");
	return 400;
    }

    token = atoi(id);

    if (found && ncs_list[i].token) {
	/*
	 * We are in calling state, so we expect the token from the
	 * remote is the same as the token we sent.
	 * In that case, the session is authorized.
	 */
	if (ncs_list[i].token == token) {
	    p = calloc(512, sizeof(char));
	    snprintf(p, 512, "SERVER %s %d %s %s %s %s\r\n", name, ihops, id, prod, vers, fullname);
	    broadcast(ncs_list[i].server, p);
	    free(p);
	    system_shout("* New server: %s, %s", name, fullname);
	    ncs_list[i].gotserver = TRUE;
	    callchg = TRUE;
	    srvchg = TRUE;
	    ncs_list[i].state = NCS_CONNECT;
	    ncs_list[i].action = now + (time_t)10;
	    Syslog('+', "IBC: connected with neighbour server: %s", ncs_list[i].server);
	    /*
	     * Send all already known servers
	     */
	    for (j = 0; j < MAXIBC_SRV; j++) {
		if (strlen(srv_list[j].server) && srv_list[j].hops) {
		    p = calloc(512, sizeof(char));
		    snprintf(p, 512, "SERVER %s %d 0 %s %s %s\r\n", srv_list[j].server, 
			    srv_list[j].hops, srv_list[j].prod, srv_list[j].vers, srv_list[j].fullname);
		    send_msg(i, p);
		    free(p);
		}
	    }
	    /*
	     * Send all known users, nicknames and join channels
	     */
	    for (j = 0; j < MAXIBC_USR; j++) {
		if (strlen(usr_list[j].server)) {
		    p = calloc(512, sizeof(char));
		    snprintf(p, 512, "USER %s@%s %s\r\n", usr_list[j].name, usr_list[j].server, usr_list[j].realname);
		    send_msg(i, p);
		    if (strcmp(usr_list[j].name, usr_list[j].nick)) {
			snprintf(p, 512, "NICK %s %s %s %s\r\n", usr_list[j].nick, 
				usr_list[j].name, usr_list[j].server, usr_list[j].realname);
			send_msg(i, p);
		    }
		    if (strlen(usr_list[j].channel)) {
			snprintf(p, 512, "JOIN %s@%s %s\r\n", usr_list[j].name, usr_list[j].server, usr_list[j].channel);
			send_msg(i, p);
		    }
		    free(p);
		}
	    }
	    /*
	     * Send all known channel topics
	     */
	    for (j = 0; j < MAXIBC_CHN; j++) {
		if (strlen(chn_list[j].topic) && (strcmp(chn_list[j].server, CFG.myfqdn) == 0)) {
		    p = xstrcpy((char *)"TOPIC ");
		    p = xstrcat(p, chn_list[j].name);
		    p = xstrcat(p, (char *)" ");
		    p = xstrcat(p, chn_list[j].topic);
		    p = xstrcat(p, (char *)"\r\n");
		    send_msg(i, p);
		    free(p);
		}
	    }
	    add_server(ncs_list[i].server, ihops, prod, vers, fullname, hostname);
	    return 0;
	}
	Syslog('r', "IBC: call collision with %s", ncs_list[i].server);
	ncs_list[i].state = NCS_WAITPWD; /* Experimental, should fix state when state was connect while it wasn't. */
	return 0;
    }

    /*
     * We are in waiting state, so we sent our PASS and SERVER
     * messages and set the session to connected if we got a
     * valid PASS command.
     */
    if (found && ncs_list[i].gotpass) {
	p = calloc(512, sizeof(char));
	snprintf(p, 512, "PASS %s 0100 %s\r\n", ncs_list[i].passwd, ncs_list[i].compress ? "Z":"");
	send_msg(i, p);
	snprintf(p, 512, "SERVER %s 0 %d mbsebbs %s %s\r\n",  ncs_list[i].myname, token, VERSION, CFG.bbs_name);
	send_msg(i, p);
	snprintf(p, 512, "SERVER %s %d %s %s %s %s\r\n", name, ihops, id, prod, vers, fullname);
	broadcast(ncs_list[i].server, p);
	system_shout("* New server: %s, %s", name, fullname);
	ncs_list[i].gotserver = TRUE;
	ncs_list[i].state = NCS_CONNECT;
	ncs_list[i].action = now + (time_t)10;
	Syslog('+', "IBC: connected with neighbour server: %s", ncs_list[i].server);
	/*
	 * Send all already known servers
	 */
	for (j = 0; j < MAXIBC_SRV; j++) {
	    if (strlen(srv_list[j].server) && srv_list[j].hops) {
		snprintf(p, 512, "SERVER %s %d 0 %s %s %s\r\n", srv_list[j].server, 
			srv_list[j].hops, srv_list[j].prod, srv_list[j].vers, srv_list[j].fullname);
		send_msg(i, p);
	    }
	}
	/*
	 * Send all known users. If a user is in a channel, send a JOIN.
	 * If the user is one of our own and has set a channel topic, send it.
	 */
	for (j = 0; j < MAXIBC_USR; j++) {
	    snprintf(p, 512, "USER %s@%s %s\r\n", usr_list[j].name, usr_list[j].server, usr_list[j].realname);
	    send_msg(i, p);
	    if (strcmp(usr_list[j].name, usr_list[j].nick)) {
		snprintf(p, 512, "NICK %s %s %s %s\r\n", usr_list[j].nick, 
			usr_list[j].name, usr_list[j].server, usr_list[j].realname);
		send_msg(i, p);
	    }
	    if (strlen(usr_list[j].channel)) {
		snprintf(p, 512, "JOIN %s@%s %s\r\n", usr_list[j].name, usr_list[j].server, usr_list[j].channel);
		send_msg(i, p);
	    }
	}
	free(p);
	for (j = 0; j < MAXIBC_CHN; j++) {
	    if (strlen(chn_list[j].topic) && (strcmp(chn_list[j].server, CFG.myfqdn) == 0)) {
		p = xstrcpy((char *)"TOPIC ");
		p = xstrcat(p, chn_list[j].name);
		p = xstrcat(p, (char *)" ");
		p = xstrcat(p, chn_list[j].topic);
		p = xstrcat(p, (char *)"\r\n");
		send_msg(i, p);
		free(p);
	    }
	}
	add_server(ncs_list[i].server, ihops, prod, vers, fullname, hostname);
	srvchg = TRUE;
	callchg = TRUE;
	return 0;
    }

    if (! found) {
       /*
	* Got a message about a server that is not our neighbour, could be a relayed server.
	*/
	if (add_server(name, ihops, prod, vers, fullname, hostname)) {
	    p = calloc(512, sizeof(char));
	    snprintf(p, 512, "SERVER %s %d %s %s %s %s\r\n", name, ihops, id, prod, vers, fullname);
	    broadcast(hostname, p);
	    free(p);
	    srvchg = TRUE;
	    Syslog('+', "IBC: new relay server %s: %s", name, fullname);
	    system_shout("* New server: %s, %s", name, fullname);
	}
	return 0;
    }

    Syslog('r', "IBC: got SERVER command without PASS command from %s", hostname);
    return 0;
}



int command_squit(int slot, char *hostname, char *parameters)
{
    char    *p, *name, *message;
    
    name = strtok(parameters, " \0");
    message = strtok(NULL, "\0");

    if (strcmp(name, ncs_list[slot].server) == 0) {
	Syslog('+', "IBC: disconnect neighbour server %s: %s", name, message);
	ncs_list[slot].state = NCS_HANGUP;
	ncs_list[slot].action = now + (time_t)120;	// 2 minutes delay before calling again.
	ncs_list[slot].gotpass = FALSE;
	ncs_list[slot].gotserver = FALSE;
	ncs_list[slot].token = 0;
	del_router(name);
    } else {
	Syslog('+', "IBC: disconnect relay server %s: %s", name, message);
	del_server(name);
    }

    system_shout("* Server %s disconnected: %s", name, message);
    p = calloc(512, sizeof(char));
    snprintf(p, 512, "SQUIT %s %s\r\n", name, message);
    broadcast(hostname, p);
    free(p);
    srvchg = TRUE;
    return 0;
}



int command_user(int slot, char *hostname, char *parameters)
{
    char    *p, *name, *server, *realname;

    name = strtok(parameters, "@\0");
    server = strtok(NULL, " \0");
    realname = strtok(NULL, "\0");

    if (realname == NULL) {
	send_msg(slot, (char *)"400 USER: Not enough parameters\r\n");
	return 400;
    }
    
    if (add_user(server, name, realname) == 0) {
	p = calloc(512, sizeof(char));
	snprintf(p, 512, "USER %s@%s %s\r\n", name, server, realname);
	broadcast(hostname, p);
	free(p);
	system_shout("* New user %s@%s (%s)", name, server, realname);
    }
    return 0;
}



int command_quit(int slot, char *hostname, char *parameters)
{
    char    *p, *name, *server, *message;

    name = strtok(parameters, "@\0");
    server = strtok(NULL, " \0");
    message = strtok(NULL, "\0");

    if (server == NULL) {
	send_msg(slot, (char *)"400 QUIT: Not enough parameters\r\n");
	return 400;
    }

    if (message) {
	system_shout("* User %s is leaving: %s", name, message);
    } else {
	system_shout("* User %s is leaving", name);
    }
    del_user(server, name);
    p = calloc(512, sizeof(char));
    snprintf(p, 512, "QUIT %s@%s %s\r\n", name, server, parameters);
    broadcast(hostname, p);
    free(p);
    return 0;
}



int command_nick(int slot, char *hostname, char *parameters)
{
    char    *p, *nick, *name, *server, *realname;
    int	    i, found;

    nick = strtok(parameters, " \0");
    name = strtok(NULL, " \0");
    server = strtok(NULL, " \0");
    realname = strtok(NULL, "\0");

    if (realname == NULL) {
	send_msg(slot, (char *)"400 NICK: Not enough parameters\r\n");
	return 1;
    }

    if (strlen(nick) > 9) {
	p = calloc(81, sizeof(char));
	snprintf(p, 81, "402 %s: Erroneous nickname\r\n", nick);
	send_msg(slot, p);
	free(p);
	return 402;
    }
    
    // FIXME: check 1st char is alpha, rest alpha/digit

    found = FALSE;
    for (i = 0; i < MAXIBC_USR; i++) {
	if ((strcmp(usr_list[i].name, nick) == 0) || (strcmp(usr_list[i].nick, nick) == 0)) {
	    found = TRUE;
	    break;
	}
    }
    if (found) {
	p = calloc(81, sizeof(char));
	snprintf(p, 81, "403 %s: Nickname is already in use\r\n", nick);
	send_msg(slot, p);
	free(p);
	return 403;
    }

    for (i = 0; i < MAXIBC_USR; i++) {
	if ((strcmp(usr_list[i].server, server) == 0) && 
		(strcmp(usr_list[i].realname, realname) == 0) && (strcmp(usr_list[i].name, name) == 0)) {
	    strncpy(usr_list[i].nick, nick, 9);
	    found = TRUE;
	    Syslog('+', "IBC: user %s set nick to %s", name, nick);
	    usrchg = TRUE;
	}
    }
    if (!found) {
	p = calloc(81, sizeof(char));
	snprintf(p, 81, "404 %s@%s: Can't change nick\r\n", name, server);
	send_msg(slot, p);
	free(p);
	return 404;
    }

    p = calloc(512, sizeof(char));
    snprintf(p, 512, "NICK %s %s %s %s\r\n", nick, name, server, realname);
    broadcast(hostname, p);
    free(p);
    return 0;
}



int command_join(int slot, char *hostname, char *parameters)
{
    char        *p, *nick, *server, *channel, msg[81];
    int		i, found;

    nick = strtok(parameters, "@\0");
    server = strtok(NULL, " \0");
    channel = strtok(NULL, "\0");

    if (channel == NULL) {
	send_msg(slot, (char *)"400 JOIN: Not enough parameters\r\n");
	return 400;
    }

    if (strlen(channel) > 20) {
	p = calloc(81, sizeof(char));
	snprintf(p, 81, "402 %s: Erroneous channelname\r\n", nick);
	send_msg(slot, p);
	free(p);
	return 402;
    }

    if (strcasecmp(channel, "#sysop") == 0) {
	Syslog('+', "IBC: ignored JOIN for #sysop channel");
	return 0;
    }

    found = FALSE;
    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strcmp(chn_list[i].name, channel) == 0) {
	    found = TRUE;
	    chn_list[i].users++;
	    break;
	}
    }
    if (!found) {
	Syslog('+', "IBC: create channel %s owned by %s@%s", channel, nick, server);
	add_channel(channel, nick, server);
	system_shout("* New channel %s created by %s@%s", channel, nick, server);
    }

    for (i = 0; i < MAXIBC_USR; i++) {
	if ((strcmp(usr_list[i].server, server) == 0) && 
		((strcmp(usr_list[i].nick, nick) == 0) || (strcmp(usr_list[i].name, nick) == 0))) {
	    strncpy(usr_list[i].channel, channel, 20);
	    Syslog('+', "IBC: user %s joined channel %s", nick, channel);
	    usrchg = TRUE;
	    snprintf(msg, 81, "* %s@%s has joined %s", nick, server, channel);
	    chat_msg(channel, NULL, msg);
	}
    }

    p = calloc(512, sizeof(char));
    snprintf(p, 512, "JOIN %s@%s %s\r\n", nick, server, channel);
    broadcast(hostname, p);
    free(p);
    chnchg = TRUE;
    return 0;
}



int command_part(int slot, char *hostname, char *parameters)
{
    char        *p, *nick, *server, *channel, *message, msg[81];
    int		i;

    nick = strtok(parameters, "@\0");
    server = strtok(NULL, " \0");
    channel = strtok(NULL, " \0");
    message = strtok(NULL, "\0");

    if (channel == NULL) {
	send_msg(slot, (char *)"400 PART: Not enough parameters\r\n");
	return 400;
    }

    if (strcasecmp(channel, "#sysop") == 0) {
	Syslog('+', "IBC: ignored PART from #sysop channel");
	return 0;
    }

    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strcmp(chn_list[i].name, channel) == 0) {
	    chnchg = TRUE;
	    chn_list[i].users--;
	    if (chn_list[i].users == 0) {
		Syslog('+', "IBC: deleted empty channel %s", channel);
		del_channel(channel);
	    }
	    break;
	}
    }

    for (i = 0; i < MAXIBC_USR; i++) {
	if ((strcmp(usr_list[i].server, server) == 0) && 
		((strcmp(usr_list[i].nick, nick) == 0) || (strcmp(usr_list[i].name, nick) == 0))) {
	    usr_list[i].channel[0] = '\0';
	    if (message) {
		Syslog('+', "IBC: user %s left channel %s: %s", nick, channel, message);
		snprintf(msg, 81, "* %s@%s has left channel %s: %s", nick, server, channel, message);
	    } else {
		Syslog('+', "IBC: user %s left channel %s", nick, channel);
		snprintf(msg, 81, "* %s@%s has silently left channel %s", nick, server, channel);
	    }
	    chat_msg(channel, NULL, msg);
	    usrchg = TRUE;
	}
    }

    p = xstrcpy((char *)"PART ");
    p = xstrcat(p, nick);
    p = xstrcat(p, (char *)"@");
    p = xstrcat(p, server);
    p = xstrcat(p, (char *)" ");
    p = xstrcat(p, channel);
    if (message) {
	p = xstrcat(p, (char *)" ");
	p = xstrcat(p, message);
    }
    p = xstrcat(p, (char *)"\r\n");
    broadcast(hostname, p);
    free(p);
    return 0;
}



int command_topic(int slot, char *hostname, char *parameters)
{
    char    *p, *channel, *topic, msg[81];
    int	    i;

    channel = strtok(parameters, " \0");
    topic = strtok(NULL, "\0");

    if (topic == NULL) {
	send_msg(slot, (char *)"400 TOPIC: Not enough parameters\r\n");
	return 400;
    }

    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strcmp(chn_list[i].name, channel) == 0) {
	    chnchg = TRUE;
	    strncpy(chn_list[i].topic, topic, 54);
	    Syslog('+', "IBC: channel %s topic: %s", channel, topic);
	    snprintf(msg, 81, "* Channel topic is now: %s", chn_list[i].topic);
	    chat_msg(channel, NULL, msg);
	    break;
	}
    }

    p = xstrcpy((char *)"TOPIC ");
    p = xstrcat(p, channel);
    p = xstrcat(p, (char *)" ");
    p = xstrcat(p, topic);
    p = xstrcat(p, (char *)"\r\n");
    broadcast(hostname, p);
    free(p);
    return 0;
}



int command_privmsg(int slot, char *hostname, char *parameters)
{
    char    *p, *channel, *msg;
    int	    i;
    
    channel = strtok(parameters, " \0");
    msg = strtok(NULL, "\0");

    if (msg == NULL) {
	send_msg(slot, (char *)"412 PRIVMSG: No text to send\r\n");
	return 412;
    }

    if (channel[0] != '#') {
	send_msg(slot, (char *)"499 PRIVMSG: Not for a channel\r\n"); // FIXME: also check users
	return 499;
    }

    for (i = 0; i < MAXIBC_CHN; i++) {
	if (strcmp(chn_list[i].name, channel) == 0) {
	    chn_list[i].lastmsg = now;
	    chat_msg(channel, NULL, msg);
	    p = xstrcpy((char *)"PRIVMSG ");
	    p = xstrcat(p, channel);
	    p = xstrcat(p, (char *)" ");
	    p = xstrcat(p, msg);
	    p = xstrcat(p, (char *)"\r\n");
	    broadcast(hostname, p);
	    free(p);
	    return 0;
	}
    }

    p = calloc(81, sizeof(char));
    snprintf(p, 81, "409 %s: Cannot sent to channel\r\n", channel);
    send_msg(slot, p);
    free(p);
    return 409;
}



int do_command(char *hostname, char *command, char *parameters)
{
    char    *p;
    int	    i, found = FALSE;

    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strcmp(ncs_list[i].server, hostname) == 0) {
	    found = TRUE;
	    break;
	}
    }

    if (! found) {
	Syslog('!', "IBC: got a command from unknown %s", hostname);
	return 0;
    }

    /*
     * First the commands that don't have parameters
     */
    if (! strcmp(command, (char *)"PING")) {
	send_msg(i, (char *)"PONG\r\n");
	return 0;
    }

    if (! strcmp(command, (char *)"PONG")) {
	/*
	 * Just accept, but reset halfdead counter.
	 */
	if (ncs_list[i].halfdead) {
	    Syslog('r', "IBC: Reset halfdead counter");
	    ncs_list[i].halfdead = 0;
	    srvchg = TRUE;
	}
	return 0;
    }

    /*
     * Commands with parameters
     */
    if (parameters == NULL) {
	p = calloc(81, sizeof(char));
	snprintf(p, 81, "400 %s: Not enough parameters\r\n", command);
	send_msg(i, p);
	free(p);
	return 400;
    }

    if (! strcmp(command, (char *)"PASS")) {
	return command_pass(i, hostname, parameters);
    } 
    if (! strcmp(command, (char *)"SERVER")) {
	return command_server(hostname, parameters);
    } 
    if (! strcmp(command, (char *)"SQUIT")) {
	return command_squit(i, hostname, parameters);
    } 
    if (! strcmp(command, (char *)"USER")) {
	return command_user(i, hostname, parameters);
    } 
    if (! strcmp(command, (char *)"QUIT")) {
	return command_quit(i, hostname, parameters);
    } 
    if (! strcmp(command, (char *)"NICK")) {
	return command_nick(i, hostname, parameters);
    }
    if (! strcmp(command, (char *)"JOIN")) {
	return command_join(i, hostname, parameters);
    }
    if (! strcmp(command, (char *)"PART")) {
	return command_part(i, hostname, parameters);
    } 
    if (! strcmp(command, (char *)"TOPIC")) {
	return command_topic(i, hostname, parameters);
    }
    if (! strcmp(command, (char *)"PRIVMSG")) {
	return command_privmsg(i, hostname, parameters);
    }

    p = calloc(81, sizeof(char));
    snprintf(p, 81, "413 %s: Unknown command\r\n", command);
    send_msg(i, p);
    free(p);
    return 413;
}



void ibc_receiver(char *crbuf)
{
    struct hostent  *hp, *tp;
    struct in_addr  in;
    int             inlist, i;
    char            *hostname, *command, *parameters, *ipaddress;

    hp = gethostbyaddr((char *)&clientaddr_in.sin_addr, sizeof(struct in_addr), clientaddr_in.sin_family);
    if (hp == NULL)
	hostname = inet_ntoa(clientaddr_in.sin_addr);
    else
	hostname = hp->h_name;

    if ((crbuf[strlen(crbuf) -2] != '\r') && (crbuf[strlen(crbuf) -1] != '\n')) {
	Syslog('!', "IBC: got message not terminated with CR-LF, dropped");
	return;
    }

    /*
     * First check for a fixed IP address.
     */
    inlist = FALSE;
    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strcmp(ncs_list[i].server, hostname) == 0) {
	    inlist = TRUE;
	    break;
	}
    }
    if (!inlist) {
	/*
	 * Check for dynamic dns address
	 */
	ipaddress = xstrcpy(inet_ntoa(clientaddr_in.sin_addr));
	for (i = 0; i < MAXIBC_NCS; i++) {
	    if (strlen(ncs_list[i].server) && ncs_list[i].dyndns) {
		tp = gethostbyname(ncs_list[i].server);
		if (tp != NULL) {
		    memcpy(&in, tp->h_addr, tp->h_length);
		    if (strcmp(inet_ntoa(in), ipaddress) == 0) {
			/*
			 * Test if the backresolved dynamic DNS name is changed, but exclude the
			 * initial value which is the same as the real server name.
			 */
			if (strcmp(ncs_list[i].resolved, hostname) && strcmp(ncs_list[i].resolved, ncs_list[i].server)) {
			    Syslog('r', "IBC: GrepThiz old resolved %s new resolved %s state %s", 
					ncs_list[i].resolved, hostname, ncsstate[ncs_list[i].state]);
			    Syslog('+', "IBC: server %s resolved FQDN changed, restarting", ncs_list[i].server);
			    ncs_list[i].crc--;
			    link_reset = TRUE;
			    /*
			     * This would be the moment to reset this neighbour
			     * Double check state: waitpwd or call ?
			     */
			}
			/*
			 * Store the back resolved IP fqdn for reference and change the
			 * FQDN to the one from the setup, so we continue to use the
			 * dynamic FQDN.
			 */
			if (strcmp(ncs_list[i].resolved, hostname))
			    Syslog('r', "IBC: setting '%s' to dynamic dns '%s'", hostname, ncs_list[i].server);
			strncpy(ncs_list[i].resolved, hostname, 63);
			inlist = TRUE;
			hostname = ncs_list[i].server;
			break;
		    }
		}
	    }
	}
	free(ipaddress);
    }
    if (!inlist) {
	Syslog('r', "IBC: message from unknown host (%s), dropped", hostname);
	return;
    }

    if (ncs_list[i].state == NCS_INIT) {
	Syslog('r', "IBC: message received from %s while in init state, dropped", hostname);
	return;
    }

    ncs_list[i].last = now;
    crbuf[strlen(crbuf) -2] = '\0';
#ifndef PING_PONG_LOG
    if (strcmp(crbuf, (char *)"PING") && strcmp(crbuf, (char *)"PONG"))
#endif
	Syslog('r', "IBC: < %s: \"%s\"", hostname, printable(crbuf, 0));

    /*
     * Parse message
     */
    command = strtok(crbuf, " \0");
    parameters = strtok(NULL, "\0");

    if (atoi(command)) {
	Syslog('r', "IBC: Got error %d", atoi(command));
    } else {
	do_command(hostname, command, parameters);
    }
}



void ibc_init(void)
{
    memset(&ncs_list, 0, sizeof(ncs_list));
    memset(&srv_list, 0, sizeof(srv_list));
}



void ibc_shutdown(void)
{
    char    *p;
    int	    i;

    Syslog('r', "IBC: start shutdown connections");

    for (i = 0; i < MAXIBC_USR; i++) {
	if (strcmp(usr_list[i].server, CFG.myfqdn) == 0) {
	    /*
	     * Our user, still connected
	     */
	    p = calloc(512, sizeof(char));
	    if (strlen(usr_list[i].channel) && strcmp(usr_list[i].channel, "#sysop")) {
		/*
		 * In a channel
		 */
		snprintf(p, 512, "PART %s@%s %s System shutdown\r\n", usr_list[i].nick, usr_list[i].server, usr_list[i].channel);
		broadcast((char *)"foobar", p);
	    }
	    snprintf(p, 512, "QUIT %s@%s System shutdown\r\n", usr_list[i].nick, usr_list[i].server);
	    broadcast((char *)"foobar", p);
	    free(p);
	}
    }

    p = calloc(512, sizeof(char));
    for (i = 0; i < MAXIBC_NCS; i++) {
	if (strlen(ncs_list[i].server) && ncs_list[i].state == NCS_CONNECT) {
	    snprintf(p, 512, "SQUIT %s System shutdown\r\n", ncs_list[i].myname);
	    send_msg(i, p);
	}
    }
    free(p);
}