deb-mbse/mbmon/mbmon.c

/*****************************************************************************
 *
 * $Id$
 * Purpose ...............: Monitor Program 
 *
 *****************************************************************************
 * Copyright (C) 1997-2007
 *   
 * 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.
 *
 * MB 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 MB BBS; see the file COPYING.  If not, write to the Free
 * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
 *****************************************************************************/

#include "../config.h"
#include "../lib/mbselib.h"
#include "../lib/users.h"
#include "../lib/mbsedb.h"
#include "proglock.h"
#include "mutil.h"


int		cols = 80;
int		rows = 24;

extern int	bbs_free;
extern int	ttyfd;
extern pid_t	mypid;

struct sysconfig    CFG;


char  	rbuf[50][81];	    /* Chat receive buffer	*/ /* FIXME: must be a dynamic buffer */
int	rpointer = 0;	    /* Chat receive pointer	*/
int	rsize = 5;	    /* Chat receive size	*/


static void die(int onsig)
{
    char    buf[128];
    
    signal(onsig, SIG_IGN);

    /*
     * Prevent clear screen when the program was locked
     */
    if (onsig != MBERR_NO_PROGLOCK)
	screen_stop(); 
    
    if (onsig && (onsig <= NSIG))
	Syslog('?', "MBMON Finished on signal %s", SigName[onsig]);
    else
	Syslog(' ', "MBMON Normally finished");
    
    snprintf(buf, 128, "CSYS:2,%d,0;", mypid);
    if (socket_send(buf) == 0)
	snprintf(buf, 128, "%s", socket_receive());
    ulockprogram((char *)"mbmon");
    ExitClient(0);
}



void ShowSysinfo(void)
{
    int	    ch;
    char    buf[128], *cnt, *lc;

    clr_index();
    set_color(WHITE, BLACK);
    mbse_mvprintw( 5, 6, "4.   SHOW BBS SYSTEM INFO");
    set_color(CYAN, BLACK);
    mbse_mvprintw( 7, 6, "1.   Total calls");
    mbse_mvprintw( 8, 6, "2.   Pots calls");
    mbse_mvprintw( 9, 6, "3.   ISDN calls");
    mbse_mvprintw(10, 6, "4.   Network calls");
    mbse_mvprintw(11, 6, "5.   Local calls");
    mbse_mvprintw(12, 6, "6.   Date started");
    mbse_mvprintw(13, 6, "7.   Last caller");
    center_addstr(rows - 3, (char *)"Press any key");
    IsDoing("View System Info");

    do {
	show_date(LIGHTGRAY, BLACK, 0, 0);
	set_color(LIGHTGRAY, BLACK);
	snprintf(buf, 128, "GSYS:1,%d;", getpid());
	if (socket_send(buf) == 0) {
	    snprintf(buf, 128, "%s", socket_receive());
	    if (strncmp(buf, "100:7,", 6) == 0) {
		cnt = strtok(buf, ",");
		mbse_mvprintw( 7,26, "%s", strtok(NULL, ","));
		mbse_mvprintw( 8,26, "%s", strtok(NULL, ","));
		mbse_mvprintw( 9,26, "%s", strtok(NULL, ","));
		mbse_mvprintw(10,26, "%s", strtok(NULL, ","));
		mbse_mvprintw(11,26, "%s", strtok(NULL, ","));
		mbse_mvprintw(12,26, "%s", strtok(NULL, ","));
		lc = xstrcpy(cldecode(strtok(NULL, ";")));
		mbse_mvprintw(13,26, "%s", lc);
		free(lc);
		fflush(stdout);
	    }
	}
	ch = testkey(rows - 3, cols / 2 + 8);
    } while (ch == '\0');
}



void ShowLastcaller(void)
{
    int	    records, maxrows, ch, i, y, o;
    char    buf[128], *cnt;
	
    clr_index();
    set_color(WHITE, BLACK);
    mbse_mvprintw( 4, 6, "5.    SHOW BBS LASTCALLERS");
    set_color(YELLOW, RED);
    mbse_mvprintw( 6, 1, "Nr Username       Location     Level Device Time  Mins Calls Speed     Actions ");
    set_color(CYAN, BLACK);
    center_addstr(rows - 1, (char *)"Press any key");
    IsDoing("View Lastcallers");
    maxrows = rows - 10;

    do {
	show_date(LIGHTGRAY, BLACK, 0, 0);
	records = 0;
	snprintf(buf, 128, "GLCC:0;");
	if (socket_send(buf) == 0) {
	    snprintf(buf, 128, "%s", socket_receive());
	    if (strncmp(buf, "100:1,", 6) == 0) {
		cnt = strtok(buf, ",");
		records = atoi(strtok(NULL, ";"));
	    }
	}

	if (records) {
	    y = 7;
	    if (records > maxrows)
		o = records - maxrows;
	    else
		o = 1;
	    set_color(CYAN, BLACK);
	    for (i = o; i <= records; i++) {
		snprintf(buf, 128, "GLCR:1,%d;", i);
		if (socket_send(buf) == 0) {
		    snprintf(buf, 128, "%s", socket_receive());
		    if (strncmp(buf, "100:9,", 6) == 0) {
			cnt = strtok(buf, ",");
			mbse_mvprintw(y, 1, "%2d", i);
			mbse_mvprintw(y, 4, "%s", cldecode(strtok(NULL, ",")));
			mbse_mvprintw(y,19, "%s", cldecode(strtok(NULL, ",")));
			mbse_mvprintw(y,32, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,38, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,45, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,51, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,56, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,62, "%s", strtok(NULL, ","));
			mbse_mvprintw(y,72, "%s", strtok(NULL, ";"));
			y++;
		    }
		}
	    }
	}
	ch = testkey(rows - 1, cols / 2 + 8);
    } while (ch == '\0');
}



void system_moni(void)
{
    int	    ch, y, eof;
    char    *cnt, buf[128];
    time_t  start, now;

    clr_index();
    set_color(WHITE, BLACK);
    mbse_mvprintw( 5, 6, "1.    SERVER CLIENTS");
    set_color(YELLOW, RED);
    mbse_mvprintw( 7, 1, "Pid   tty    user     program  city            doing                      time ");
    set_color(CYAN, BLACK);
    center_addstr(rows - 1, (char *)"Press any key");
    IsDoing("System Monitor");

    do {
	show_date(LIGHTGRAY, BLACK, 0, 0);

	eof = 0;
	set_color(LIGHTGRAY, BLACK);

	for (y = 8; y <= rows - 2; y++) { 
	    if (y == 8)
		snprintf(buf, 128, "GMON:1,1;");
	    else
		snprintf(buf, 128, "GMON:1,0;");
	    if (eof == 0) {
		if (socket_send(buf) == 0) {
		    strncpy(buf, socket_receive(), 128);
		    mbse_locate(y, 1);
		    clrtoeol();
		    if (strncmp(buf, "100:0;", 6) == 0) {
			/*
			 * There's no more information 
			 */
			eof = 1;
		    } else {
			cnt = strtok(buf, ",");
			mbse_mvprintw(y, 1, (char *)"%.5s", strtok(NULL, ","));
			mbse_mvprintw(y, 7, (char *)"%.6s", strtok(NULL, ","));
			mbse_mvprintw(y,14, (char *)"%.8s", cldecode(strtok(NULL, ",")));
			mbse_mvprintw(y,23, (char *)"%.8s", cldecode(strtok(NULL, ",")));
			mbse_mvprintw(y,32, (char *)"%.15s", cldecode(strtok(NULL, ",")));
			mbse_mvprintw(y,48, (char *)"%.26s", cldecode(strtok(NULL, ",")));
			start = atoi(strtok(NULL, ";"));
			now = time(NULL);
			mbse_mvprintw(y,75, (char *)"%s", t_elapsed(start, now));
		    }
		}
	    } else {
		/*
		 *  If no valid data, clear line
		 */
		mbse_locate(y, 1);
		clrtoeol();
	    }
	} /* for () */

	ch = testkey(rows - 1, cols / 2 + 8);
    } while (ch == '\0');
}



void system_stat(void)
{
    int	    ch;
    char    buf[256], *cnt;
    time_t  now;

    clr_index();
    set_color(WHITE, BLACK);
    mbse_mvprintw( 5, 6, "2.    SERVER STATISTICS");
    set_color(CYAN, BLACK);
    mbse_mvprintw( 7, 6, "First date started");
    mbse_mvprintw( 7,59, "BBS Open");
    mbse_mvprintw( 8, 6, "Last date started");
    mbse_mvprintw( 8,59, "ZMH");
    mbse_mvprintw( 9, 6, "Total server starts");
    mbse_mvprintw( 9,59, "Internet up");
    mbse_mvprintw(10, 6, "Connected clients");
    mbse_mvprintw(10,59, "Need inet");
    mbse_mvprintw(11,59, "Running");
    mbse_mvprintw(12,30, "Total          Today");
    mbse_mvprintw(12,59, "Load average");
    hor_lin(13,30,8);
    hor_lin(13,45,8);
    mbse_mvprintw(13,59, "Diskspace");
    mbse_mvprintw(14, 6, "Client connects");
    mbse_mvprintw(14,59, "IBC servers");
    mbse_mvprintw(15, 6, "Peak connections");
    mbse_mvprintw(15,59, "IBC channels");
    mbse_mvprintw(16, 6, "Protocol syntax errors");
    mbse_mvprintw(16,59, "IBC users");
    mbse_mvprintw(17, 6, "Communication errors");
    mbse_mvprintw(19, 6, "Next sequence number");
    mbse_mvprintw(rows -3,59, "Press any key");
    IsDoing("System Statistics");

    do {
	show_date(LIGHTGRAY, BLACK, 0, 0);

	snprintf(buf, 256, "GSTA:1,%d;", getpid());
	if (socket_send(buf) == 0) {
	    strncpy(buf, socket_receive(), 256);
	    set_color(LIGHTGRAY, BLACK);
	    cnt = strtok(buf, ",");
	    now = atoi(strtok(NULL, ","));
	    mbse_mvprintw(7, 30, "%s", ctime(&now));
	    now = atoi(strtok(NULL, ","));
	    mbse_mvprintw(8, 30, "%s", ctime(&now));
	    cnt = strtok(NULL, ",");
	    mbse_mvprintw(9, 30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(10,30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(14,30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(15,30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(16,30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(17,30, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(14,45, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(15,45, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(16,45, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(17,45, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(7,72, "%s", atoi(strtok(NULL, ",")) == 1?"Yes":"No ");
	    mbse_mvprintw(8,72, "%s", atoi(strtok(NULL, ",")) == 1?"Yes":"No ");
	    mbse_mvprintw(9,72, "%s", atoi(strtok(NULL, ",")) == 1?"Yes":"No ");
	    mbse_mvprintw(10,72,"%s", atoi(strtok(NULL, ",")) == 1?"Yes":"No ");
	    mbse_mvprintw(11,72,"%s", atoi(strtok(NULL, ",")) == 1?"Yes":"No ");
	    mbse_mvprintw(12,72, "%s ", strtok(NULL, ","));
	    mbse_mvprintw(19,30, (char *)"%s", strtok(NULL, ","));
	    mbse_mvprintw(14,72, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(15,72, (char *)"%s ", strtok(NULL, ","));
	    mbse_mvprintw(16,72, (char *)"%s ", strtok(NULL, ";"));
	}

	switch (enoughspace(CFG.freespace)) {
	    case 0: mbse_mvprintw(13, 72, "Full ");
		    break;
	    case 1: mbse_mvprintw(13, 72, "Ok   ");
		    break;
	    case 2: mbse_mvprintw(13, 72, "N/A  ");
		    break;
	    case 3: mbse_mvprintw(13, 72, "Error");
		    break;
	}

	ch = testkey(rows -3,73);
    } while (ch == '\0');
}



void disk_stat(void)
{
    int		    ch, i, ro;
    char	    buf[1024], *cnt, *type, *fs, *p, sign;
    unsigned int    last[10], size, used, perc, avail;

    clr_index();
    set_color(WHITE, BLACK);
    mbse_mvprintw( 5, 6, "3.    FILESYSTEM USAGE");
    set_color(YELLOW, RED);
    mbse_mvprintw( 7, 1, " Size MB   Free MB     Used  FS-Type   St Mountpoint                          ");
    set_color(CYAN, BLACK);
    mbse_mvprintw(rows - 2, 6, "Press any key");
    IsDoing("Filesystem Usage");
    for (i = 0; i < 10; i++)
	last[i] = 0;

    do {
	show_date(LIGHTGRAY, BLACK, 0, 0);

	snprintf(buf, 1024, "DGFS:0;");
	if (socket_send(buf) == 0) {
	    strcpy(buf, socket_receive());
	    set_color(LIGHTGRAY, BLACK);
	    cnt = strtok(buf, ":");
	    cnt = strtok(NULL, ",;");
	    if (atoi(cnt)) {
		for (i = 0; i < atoi(cnt); i++) {
		    p = strtok(NULL, " ");
		    size = atoi(p);
		    avail = atoi(strtok(NULL, " "));
		    used = size - avail;
		    perc = (used * 100) / size;
		    sign = ' ';
		    fs = strtok(NULL, " ");
		    type = strtok(NULL, " ");
		    ro = atoi(strtok(NULL, ",;"));
		    if (used > last[i])
			sign = '^';
		    if (used < last[i])
			sign = 'v';
		    if (last[i] == 0)
			sign = ' ';
		    last[i] = used;
		    set_color(CYAN, BLACK);
		    mbse_mvprintw(i+8, 1, "%8lu  %8lu  ", size, avail);
		    set_color(WHITE, BLACK);
		    printf("%c  ", sign);
		    if (ro == 0) {
			if (avail <= CFG.freespace)
			    set_color(LIGHTRED, BLACK);
			else if (avail <= (CFG.freespace * 4))
			    set_color(YELLOW, BLACK);
			else
			    set_color(CYAN, BLACK);
		    } else {
			set_color(GREEN, BLACK);
		    }
		    printf("%3u", perc);
		    putchar('%');
		    set_color(CYAN, BLACK);
		    printf("  %-8s  %s %-37s", type, ro ?"RO":"RW", fs);
		}
		mbse_locate(i+8, 1);
		clrtoeol();
	    }
	}

	ch = testkey(rows - 2, 20);
    } while (ch == '\0');
}



void soft_info(void)
{
	char	temp[81], *p;

	clr_index();
	set_color(YELLOW, BLACK);

#if defined(__linux__)
	p = xstrcpy((char *)"MBSE BBS (GNU/Linux");
#elif defined(__FreeBSD__)
	p = xstrcpy((char *)"MBSE BBS (FreeBSD");
#elif defined(__NetBSD__)
	p = xstrcpy((char *)"MBSE BBS (NetBSD");
#elif defined(__OpenBSD__)
	p = xstrcpy((char *)"MBSE BBS (OpenBSD");
#else
#error "Unknown OS"
#endif

#if defined(__i386__)
	p = xstrcat(p, (char *)" i386)");
#elif defined(__x86_64__)
	p = xstrcat(p, (char *)" x86-64");
#elif defined(__PPC__) || defined(__ppc__)
	p = xstrcat(p, (char *)" PPC)");
#elif defined(__sparc__)
	p = xstrcat(p, (char *)" Sparc)");
#elif defined(__alpha__)
	p = xstrcat(p, (char *)" Alpha)");
#elif defined(__hppa__)
	p = xstrcat(p, (char *)" HPPA)");
#elif defined(_arm__)
	p = xstrcat(p, (char *)" ARM)");
#else
#error "Unknown CPU"
#endif

	center_addstr( 6, p);
	free(p);
	set_color(WHITE, BLACK);
	center_addstr( 8, (char *)COPYRIGHT);
	set_color(YELLOW, BLACK);
	center_addstr(10, (char *)"Made in the Netherlands.");
	set_color(WHITE, BLACK);
#ifdef __GLIBC__
	snprintf(temp, 81, "Compiled on glibc v%d.%d", __GLIBC__, __GLIBC_MINOR__);
#else
#ifdef __GNU_LIBRARY__
	snprintf(temp, 81, "Compiled on libc v%d", __GNU_LIBRARY__);
#else
	snprintf(temp, 81, "Compiled on unknown library");
#endif
#endif
	center_addstr(12, temp);
	set_color(LIGHTCYAN, BLACK);
	center_addstr(14, (char *)"http://www.mbse.eu or 2:280/2802");
	set_color(LIGHTGREEN, BLACK);
	center_addstr(rows -7, (char *)"This is free software; released under the terms of the GNU General");
	center_addstr(rows -6, (char *)"Public License as published by the Free Software Foundation.");
	set_color(CYAN, BLACK);
	center_addstr(rows -4, (char *)"Press any key");
	readkey(rows - 4, cols / 2 + 8, LIGHTGRAY, BLACK);
}



/*
 * Colorize the chat window
 */
void Showline(int y, int x, char *msg)
{
    int     i, done = FALSE;

    if (strlen(msg)) {
	mbse_locate(y, x);
	if (msg[0] == '<') {
	    mbse_colour(LIGHTCYAN, BLACK);
	    putchar('<');
	    mbse_colour(LIGHTBLUE, BLACK);
	    for (i = 1; i < strlen(msg); i++) {
		if ((msg[i] == '>') && (! done)) {
		    mbse_colour(LIGHTCYAN, BLACK);
		    putchar(msg[i]);
		    mbse_colour(CYAN, BLACK);
		    done = TRUE;
		} else {
		    putchar(msg[i]);
		}
	    }
	} else if (msg[0] == '*') {
	    if (msg[1] == '*') {
		if (msg[2] == '*')
		    mbse_colour(YELLOW, BLACK);
		else
		    mbse_colour(LIGHTRED, BLACK);
	    } else {
		mbse_colour(LIGHTMAGENTA, BLACK);
	    }
	    for (i = 0; i < strlen(msg); i++)
		putchar(msg[i]);
	} else {
	    mbse_colour(GREEN, BLACK);
	    for (i = 0; i < strlen(msg); i++)
		putchar(msg[i]);
	}
    }
}



/*
 * Display received chat message
 */
void DispMsg(char *);
void DispMsg(char *msg)
{
    int	    i;

    /*
     * Beep on minor system messages
     */
    if ((msg[0] == '*') && (msg[1] != '*'))
	putchar('\007');

    strncpy(rbuf[rpointer], msg, 81);
    Showline(4+rpointer, 1, rbuf[rpointer]);
    if (rpointer == rsize) {
	/*
	 * Scroll buffer
	 */
	for (i = 0; i <= rsize; i++) {
	    mbse_locate(i+4,1);
	    clrtoeol();
	    strncpy(rbuf[i], rbuf[i+1], 81);
//	    snprintf(rbuf[i], 81, "%s", rbuf[i+1]);
	    Showline(i+4, 1, rbuf[i]);
	}
    } else {
	rpointer++;
    }

    fflush(stdout);
}



/*
 * Sysop/user chat
 */
void Chat(int sysop)
{
    int		    curpos = 0, width, stop = FALSE, data, rc;
    unsigned char   ch = 0;
    char	    *p, sbuf[81], resp[128], *sysop_name, *name;
    static char	    buf[200];

    clr_index();
    rsize = rows - 7;
    rpointer = 0;

    sysop_name = xstrcpy(clencode(CFG.sysop_name));
    name = xstrcpy(clencode(CFG.sysop));
    width = cols - (strlen(name) + 3);
    snprintf(buf, 200, "CCON,4,%d,%s,%s,%s;", mypid, sysop_name, name, sysop ? "1":"0");
    free(sysop_name);
    free(name);

    if (socket_send(buf) == 0) {
	strcpy(buf, socket_receive());
	if (strncmp(buf, "200:1,", 6) == 0) {
	    set_color(LIGHTRED, BLACK);
	    mbse_mvprintw(4, 1, (char *)"Add \"fido  60179/udp  # Chatserver\" to /etc/services");
	    mbse_mvprintw(5, 1, (char *)"Leave mbmon, then restart mbtask and come back here");
	    working(2, 0, 0);
	    working(0, 0, 0);
	    center_addstr(rows -4, (char *)"Press any key");
	    readkey(rows - 4, cols / 2 + 8, LIGHTGRAY, BLACK);
	    return;
	}
    }

    mbse_locate(rows - 2, 1);
    set_color(WHITE, BLUE);
    clrtoeol();
    mbse_mvprintw(rows - 2, 2, "Chat, type \"/EXIT\" to exit or \"/HELP\" for help");

    set_color(WHITE, BLACK);
    mbse_mvprintw(rows - 1, 1, ">");
    mbse_mvprintw(rows - 1, width + 2, "<");
    memset(&sbuf, 0, sizeof(sbuf));
    memset(&rbuf, 0, sizeof(rbuf));

    if (sysop) {
	/*
	 * Join channel #sysop automatic
	 */
	snprintf(buf, 200, "CPUT:2,%d,/JOIN #sysop;", mypid);
	if (socket_send(buf) == 0) {
	    strcpy(buf, socket_receive());
	}
    }

    while (stop == FALSE) {

	/*
	 * Check for new message, loop fast until no more data available.
	 */
	data = TRUE;
	while (data) {
	    snprintf(buf, 200, "CGET:1,%d;", mypid);
	    if (socket_send(buf) == 0) {
		memset(&buf, 0, sizeof(buf));
		strncpy(buf, socket_receive(), sizeof(buf)-1);
		if (strncmp(buf, "100:2,", 6) == 0) {
		    strncpy(resp, strtok(buf, ":"), 10);    /* Should be 100	    */
		    strncpy(resp, strtok(NULL, ","), 5);    /* Should be 2	    */
		    strncpy(resp, strtok(NULL, ","), 5);    /* 1= fatal error	    */
		    rc = atoi(resp);
		    memset(&resp, 0, sizeof(resp));
		    strncpy(resp, cldecode(strtok(NULL, ";")), 81);  /* The message	    */
		    DispMsg(resp);
		    if (rc == 1) {
			Syslog('+', "Chat server message: %s", resp);
			stop = TRUE;
			data = FALSE;
		    }
		} else {
		    data = FALSE;
		}
	    }
	}

	if (stop)
	    break;

	/*
	 * Update top bars
	 */
	show_date(LIGHTGRAY, BLACK, 0, 0);

	/*
	 * Check for a pressed key, if so then process it
	 */
	ch = testkey(rows -1, curpos + 2);
	if (isprint(ch)) {
	    set_color(CYAN, BLACK);
	    if (curpos < width) {
		putchar(ch);
		fflush(stdout);
		sbuf[curpos] = ch;
		curpos++;
	    } else {
		putchar(7);
	    }
	} else if ((ch == KEY_BACKSPACE) || (ch == KEY_RUBOUT) || (ch == KEY_DEL)) {
	    set_color(CYAN, BLACK);
	    if (curpos) {
		curpos--;
		sbuf[curpos] = '\0';
		printf("\b \b");
	    } else {
		putchar(7);
	    }
	} else if ((ch == '\r') && curpos) {
	    snprintf(buf, 12, "%d", mypid);
	    p = xstrcpy((char *)"CPUT:2,");
	    p = xstrcat(p, buf);
	    p = xstrcat(p, (char *)",");
	    p = xstrcat(p, clencode(sbuf));
	    p = xstrcat(p, (char *)";");
	    strncpy(buf, p, 200);
	    free(p);
	    if (socket_send(buf) == 0) {
		strcpy(buf, socket_receive());
		if (strncmp(buf, "100:2,", 6) == 0) {
		    strncpy(resp, strtok(buf, ":"), 10);    /* Should be 100            */
		    strncpy(resp, strtok(NULL, ","), 5);    /* Should be 2              */
		    strncpy(resp, strtok(NULL, ","), 5);    /* 1= fatal error, end chat	*/
		    rc = atoi(resp);
		    strncpy(resp, cldecode(strtok(NULL, ";")), 81);  /* The message              */
		    DispMsg(resp);
		    if (rc == 1) {
			Syslog('+', "Chat server error: %s", resp);
			stop = TRUE;
		    }
		}
	    }
	    curpos = 0;
	    memset(&sbuf, 0, sizeof(sbuf));
	    mbse_locate(rows - 1, 2);
	    clrtoeol();
	    set_color(WHITE, BLACK);
	    mbse_mvprintw(rows - 1, 1, ">");
	    mbse_mvprintw(rows - 1, width + 2, "<");
	}
    }

    /* 
     * Before sending the close command, purge all outstanding messages.
     */
    data = TRUE;
    while (data) {
	snprintf(buf, 200, "CGET:1,%d;", mypid);
	if (socket_send(buf) == 0) {
	    strncpy(buf, socket_receive(), sizeof(buf)-1);
	    if (strncmp(buf, "100:2,", 6) == 0) {
		strncpy(resp, strtok(buf, ":"), 10);    /* Should be 100        */
		strncpy(resp, strtok(NULL, ","), 5);    /* Should be 2          */
		strncpy(resp, strtok(NULL, ","), 5);	/* 1= fatal error	*/
		rc = atoi(resp);
		memset(&resp, 0, sizeof(resp));
		strncpy(resp, cldecode(strtok(NULL, ";")), 80);  /* The message          */
		DispMsg(resp);
		if (rc == 1) {
		    Syslog('+', "Chat server error: %s", resp);
		    data = FALSE;
		}
	    } else {
		data = FALSE;
	    }
	}
    }

    /*
     * Close server connection
     */
    snprintf(buf, 200, "CCLO,1,%d;", mypid);
    if (socket_send(buf) == 0) {
	strcpy(buf, socket_receive());
    }
    sleep(1);
}



int main(int argc, char *argv[])
{
    struct passwd   *pw;
    struct winsize  ws;
    char	    buf[128];

    /*
     * Find out who is on the keyboard or automated the keyboard.
     */
    pw = getpwuid(geteuid());
    if (strcmp(pw->pw_name, (char *)"mbse")) {
	printf("ERROR: only user \"mbse\" may use this program\n");
	exit(MBERR_INIT_ERROR);
    }

    /*
     * Read the global configuration data, registrate connection
     */
    InitConfig();
    InitClient(pw->pw_name, (char *)"mbmon", CFG.location, (char *)"mbmon.log", CFG.util_loglevel, CFG.error_log, CFG.mgrlog, CFG.debuglog);
    Syslog(' ', "MBMON Started by %s", pw->pw_name);
    bbs_free = FALSE;

    /*
     * Report sysop available for chat
     */
    snprintf(buf, 128, "CSYS:2,%d,1;", mypid);
    if (socket_send(buf) == 0)
	snprintf(buf, 128, "%s", socket_receive());

	
    /*
     * Setup several signals so when the program terminate's it
     * will properly close.
     */
    signal(SIGINT, (void (*))die);
    signal(SIGBUS, (void (*))die);
    signal(SIGSEGV,(void (*))die);
    signal(SIGTERM,(void (*))die);
    signal(SIGKILL,(void (*))die);

    if (ioctl(1, TIOCGWINSZ, &ws) != -1 && (ws.ws_col > 0) && (ws.ws_row > 0)) {
	rows = ws.ws_row;
	if (rows < 24) {
	    Syslog('!', "Warning, only %d screen rows, forcing to 24", rows);
	    rows = 24;
	}
    }
    Syslog('+', "Screen size set to %dx%d", cols, rows);

    if (lockprogram((char *)"mbmon")) {
	printf("\n\7Another mbmon is already running, abort.\n\n");
	die(MBERR_NO_PROGLOCK);
    }
    
    screen_start((char *)"MBmon");

    for (;;) {

	IsDoing("Browsing Menu");
	clr_index();
	set_color(WHITE, BLACK);
	mbse_mvprintw( 5, 6, "0.    MBSE BBS MONITOR");
	set_color(CYAN, BLACK);
	mbse_mvprintw( 7, 6, "1.    View Server Clients");
	mbse_mvprintw( 8, 6, "2.    View Server Statistics");
	mbse_mvprintw( 9, 6, "3.    View Filesystem Usage");
	mbse_mvprintw(10, 6, "4.    View BBS System Information");
	mbse_mvprintw(11, 6, "5.    View BBS Lastcallers List");
	mbse_mvprintw(12, 6, "6.    Chat with any user");
	mbse_mvprintw(13, 6, "7.    Respond to sysop page");
	mbse_mvprintw(14, 6, "8.    View Software Information");

	switch(select_menu(8)) {
	    case 0:
		    die(0);
		    break;
	    case 1:
		    system_moni();
		    break;
	    case 2:
		    system_stat();
		    break;
	    case 3:
		    disk_stat();
		    break;
	    case 4:
		    ShowSysinfo();
		    break;
	    case 5:
		    ShowLastcaller();
		    break;
	    case 6:
		    Chat(FALSE);
		    break;
	    case 7:
		    Chat(TRUE);
		    break;
	    case 8:
		    soft_info();
		    break;
	}
    }
}