/*****************************************************************************
 *
 * $Id$
 * Purpose: Fidonet mailer
 *
 *****************************************************************************
 * Copyright (C) 1997-2001
 *   
 * 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 "../lib/libs.h"
#include "../lib/structs.h"
#include "../lib/records.h"
#include "../lib/common.h"
#include "../lib/clcomm.h"
#include "../lib/dbcfg.h"
#include "../lib/dbnode.h"
#include "../lib/dbftn.h"
#include "config.h"
#include "answer.h"
#include "portsel.h"
#include "call.h"
#include "callall.h"
#include "lutil.h"
#include "mbcico.h"
#include "session.h"



int		master = 0;
int		forcedcalls = 0;
int		immediatecall = FALSE;
char		*forcedphone = NULL;
char		*forcedline = NULL;
char		*inetaddr = NULL;
char		*envptr = NULL;
time_t		t_start;
time_t		t_end;
time_t		c_start;
time_t		c_end;
int		online = 0;
unsigned long	sentbytes = 0;
unsigned long	rcvdbytes = 0;
int		tcp_mode = TCPMODE_NONE;
int		Loaded = FALSE;


extern char	*myname;
char		*inbound;
char		*uxoutbound;
char		*name;
char		*phone;
char		*flags;
extern int	gotfiles;
extern int	mypid;



void usage(void)
{
	fprintf(stderr,"ifcico; (c) Eugene G. Crosser, 1993-1997\n");
	fprintf(stderr,"mbcico ver. %s; (c) %s\n\n", VERSION, SHORTRIGHT);
	fprintf(stderr,"-r<role> -a<inetaddr> <node> ...\n");
	fprintf(stderr,"-r 0|1		1 - master, 0 - slave	[0]\n");
	fprintf(stderr,"-n<phone>	forced phone number\n");
	fprintf(stderr,"-l<ttydevice>	forced tty device\n");
	fprintf(stderr,"-t<tcpmode>	must be one of ifc|itn|ibn, forces TCP/IP\n");
	fprintf(stderr,"-a<inetaddr>	supply internet hostname if not in nodelist\n");
	fprintf(stderr,"  <node>	should be in domain form, e.g. f11.n22.z3\n");
	fprintf(stderr,"		(this implies master mode)\n");
	fprintf(stderr,"\n or: %s tsync|yoohoo|**EMSI_INQC816|-t ibn|-t ifc|-t itn\n",myname);
	fprintf(stderr,"		(this implies slave mode)\n");
}



void free_mem(void)
{
	free(inbound);
	if (name)
		free(name);
	if (phone)
		free(phone);
	if (flags)
		free(flags);
	if (uxoutbound)
		free(uxoutbound);
}



void die(int onsig)
{
	int	total = 0;

	signal(onsig, SIG_IGN);

	if (onsig) {
		if (onsig <= NSIG)
			WriteError("$Terminated on signal %d (%s)", onsig, SigName[onsig]);
		else
			Syslog('+', "Terminated with error %d", onsig);
	}

	if (sentbytes || rcvdbytes) {
		total = (int)(c_end - c_start);
		if (!total)
			total = 1;
		Syslog('+', "Sent %lu bytes, received %lu bytes, avg %d cps", 
			    sentbytes, rcvdbytes, (sentbytes + rcvdbytes) / total);
	}

	if (online)
		Syslog('+', "Connected %s", str_time(online));

	if (gotfiles)
		CreateSema((char *)"mailin");

	time(&t_end);
	Syslog(' ', "MBCICO finished in %s", t_elapsed(t_start, t_end));
	free_mem();
	if (envptr)
		free(envptr);
	ExitClient(onsig);
}



int main(int argc, char *argv[])
{
	int		i, c, uid;
	fa_list		*callist = NULL, **tmpl;
	faddr		*tmp;
	int		rc, maxrc, callno = 0, succno = 0;
	char		*answermode = NULL, *p = NULL, *cmd = NULL;
	struct passwd	*pw;
	FILE		*fp;

#ifdef MEMWATCH
	mwInit();
#endif

	/*
	 * The next trick is to supply a fake environment variable
	 * MBSE_ROOT in case we are started from inetd or mgetty,
	 * this will setup the variable so InitConfig() will work.
	 * The /etc/passwd must point to the correct homedirectory.
	 */
	pw = getpwuid(getuid());
	if (getenv("MBSE_ROOT") == NULL) {
		envptr = xstrcpy((char *)"MBSE_ROOT=");
		envptr = xstrcat(envptr, pw->pw_dir);
		putenv(envptr);
	}

	if (argc < 2) {
		usage();
		if (envptr)
			free(envptr);
#ifdef MEMWATCH
		mwTerm();
#endif
		exit(101);
	}

	InitConfig();
	InitNode();
	InitFidonet();
	TermInit(1);
	time(&t_start);
	time(&c_start);
	time(&c_end);

	InitClient(pw->pw_name, (char *)"mbcico", CFG.location, CFG.logfile, CFG.cico_loglevel, CFG.error_log);
	Syslog(' ', " ");
	Syslog(' ', "MBCICO v%s", VERSION);

	/*
	 * Catch all signals we can, and handle the rest.
	 */
	for (i = 0; i < NSIG; i++) {
		if ((i == SIGINT) || (i == SIGBUS) ||
		    (i == SIGFPE) || (i == SIGSEGV)) {
			signal(i, (void (*))die);
		} else
			signal(i, SIG_DFL);
	}

	/*
	 *  Check if history file exists, if not create a new one.
	 */
	cmd = calloc(128, sizeof(char));
	sprintf(cmd, "%s/var/mailer.hist", getenv("MBSE_ROOT"));
	if ((fp = fopen(cmd, "r")) == NULL) {
		if ((fp = fopen(cmd, "a")) == NULL) {
			WriteError("$Can't create %s", cmd);
		} else {
			memset(&history, 0, sizeof(history));
			history.online = time(NULL);
			history.offline = time(NULL);
			fwrite(&history, sizeof(history), 1, fp);
			fclose(fp);
			Syslog('+', "Created new %s", cmd);
		}
	} else {
		fclose(fp);
	}
	free(cmd);
	memset(&history, 0, sizeof(history));

	cmd = xstrcpy((char *)"Cmd: mbcico");
	for (i = 1; i < argc; i++) {
		cmd = xstrcat(cmd, (char *)" ");
		cmd = xstrcat(cmd, argv[i]);
	}
	Syslog(' ', cmd);
	free(cmd);

	setmyname(argv[0]);

	while ((c=getopt(argc,argv,"r:n:l:t:a:I:h")) != -1)
		switch (c) {
			case 'r':	master = atoi(optarg);
					if ((master != 0) && (master != 1)) {
						usage();
						die(101);
					}
					break;

			case 'l':	forcedline = optarg; 
					break;

			case 't':	p = xstrcpy(optarg);
					if (strncmp(p, "ifc", 3) == 0)
						tcp_mode = TCPMODE_IFC;
					else if (strncmp(p, "itn", 3) == 0)
						tcp_mode = TCPMODE_ITN;
					else if (strncmp(p, "ibn", 3) == 0)
						tcp_mode = TCPMODE_IBN;
					else {
						usage();
						die(101);
					}
					free(p);
					break;

			case 'a':	inetaddr = optarg; 
					break;

			case 'n':	forcedphone = optarg; 
					break;

			default:	usage(); 
					die(101);
		}

	/*
	 * Load rest of the configuration
	 */
	inbound		= xstrcpy(CFG.inbound);
	uxoutbound	= xstrcpy(CFG.uxpath);
	name		= xstrcpy(CFG.bbs_name);
	phone		= xstrcpy(CFG.Phone);
	flags		= xstrcpy(CFG.Flags);

	tmpl = &callist;

	while (argv[optind]) {
		for (p = argv[optind]; (*p) && (*p == '*'); p++);
		if ((strcasecmp(argv[optind],"tsync") == 0) ||
		    (strcasecmp(argv[optind],"yoohoo") == 0) ||
		    (strcasecmp(argv[optind],"ibn") == 0) ||
		    (strncasecmp(p,"EMSI_",5) == 0)) {
			master = 0;
			answermode = argv[optind];
			Syslog('S', "Inbound \"%s\" mode", MBSE_SS(answermode));
		} else {
			Syslog('-', "Callist entry \"%s\"", argv[optind]);
			if ((tmp = parsefaddr(argv[optind]))) {
				*tmpl = (fa_list *)malloc(sizeof(fa_list));
				(*tmpl)->next = NULL;
				(*tmpl)->addr = tmp;
				tmpl = &((*tmpl)->next);
				immediatecall = TRUE;
			} else
				WriteError("Unrecognizable address \"%s\"", argv[optind]);
		}
		optind++;
	}

	if (callist) {
		master = 1;
		forcedcalls = 1;
	}

	/*
	   The following witchkraft about uid-s is necessary to make
	   access() work right.  Unforunately, access() checks the real
	   uid, if mbcico is invoked with supervisor real uid (as when
	   called by uugetty) it returns X_OK for the magic files that
	   even do not have `x' bit set.  Therefore, `reference' magic
	   file requests are taken for `execute' requests (and the
	   actual execution natually fails).  Here we set real uid equal
	   to effective.  If real uid is not zero, all these fails, but
	   in this case it is not necessary anyway.
	*/

	uid=geteuid();
	seteuid(0);
	setuid(uid);
	seteuid(uid);

	umask(066);	/* packets may contain confidential information */

	p = xstrcpy(inbound);
	p = xstrcat(p,(char *)"/tmp/fooinb");
	mkdirs(p);
	free(p);

	maxrc=0;
	if (master) {
		/*
		 * Don't do outbound calls if low diskspace
		 */
		if (!diskfree(CFG.freespace))
			die(101);

		if (callist == NULL) 
			callist = callall();

		for (tmpl = &callist; *tmpl; tmpl = &((*tmpl)->next)) {
			callno++;
			forcedcalls = (*tmpl)->force;
			rc = call((*tmpl)->addr);
			Syslog('+', "Call to %s %s (rc=%d)", ascfnode((*tmpl)->addr,0x1f), rc?"failed":"successful",rc);
			if (rc > maxrc) 
				maxrc=rc;
			if (rc == 0) {
				succno++;
				break;
			}
		}
		if (callist == NULL) 
			if (IsSema((char *)"scanout"))
				RemoveSema((char *)"scanout");
	} else {
		/* slave */
		if (!answermode && tcp_mode == TCPMODE_IBN)
			answermode = xstrcpy((char *)"ibn");
		maxrc = answer(answermode);
		callno = 1;
		succno = (maxrc == 0);
	}

	if (callno)
		Syslog('+', "%d of %d calls, maxrc=%d",succno,callno,maxrc);

	tidy_falist(&callist);

	if (maxrc)
		die(maxrc+100);
	else
		die(0);
	return 0;
}