/*
 *
 * Copyright (C) Cyclades Corporation, 1999-1999. All rights reserved.
 *
 *
 * tsrsock.c
 * cyclades-ser-cli main code
 *
 * History
 * 08/17/1999 V.1.0.0 Initial revision
 *
 * 17/12/1999 V.1.0.1 Version was changed to 1.0.1
 *
 * Oct-27-2001 V.1.0.2
 *	Program version has changed to 1.2.0
 *	Retry message now is of Warning type 
 */

#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>

# define _TSR_TSRSOCK_

#include "inc/cyclades-ser-cli.h"
#include "inc/system.h"
#include "inc/tsrio.h"
#include "inc/sock.h"
#include "inc/dev.h"
#include "inc/misc.h"
#include "inc/telnet.h"
#include <sys/socket.h>
#include <sys/un.h>
#include <signal.h>

int P_contr[MAX_CONTROL_SOCKS], P_contr_listen;

/*
 * Internal Variables
 */

static const char *const Version="cyclades-ser-cli " TSRDEV_VERSION " " TSRDEV_DATE;

/*
 * Internal Functions
 */

#ifndef HAVE_DAEMON
#include "inc/daemon.h"
#endif

static void		helpmsg (void);
static void		mkidmsg(char *pgname, char *device);

int main (int argc, char **argv)
{
	int			i;
	char *			device;
	char *			rasname;
	int			physport;
	int			ptyiosize;
	int			netiosize;
	int			retrydelay;
	int			retry, nretries;
	int			opt;
	int			retst;
	int			devmodem;
	int			closemode;
	int			baseport;
	struct sockaddr_un	control_addr;
	struct sigaction	act;
	struct stat		stat_buf;

	act.sa_handler = SIG_IGN;
	if(sigaction(SIGPIPE, &act, NULL))
		sysmessage(MSG_ERR, "Can't block SIGPIPE.\n");

	ptyiosize = DEV_DEFIOSZ;
	netiosize = SOCK_DEFIOSZ;
	retrydelay = RETRY_DELAY ;
	nretries = NUM_RETRIES;
	Nvt.servertype = SRV_RTELNET;
	devmodem = DEV_MODEM;
	closemode = CLOSE_HANG;
	baseport = 0;

	Console = FALSE;
	Foreground = FALSE;

	Pgname = argv[0];
	Debug = 0;

	while ((opt = getopt(argc,argv, "u:n:r:fi:st:m:c:p:d:xvhH")) != EOF) {
		switch (opt) {
		case 'u' :
			ptyiosize = atoi(optarg);
			if (ptyiosize > DEV_MAXIOSZ) {
				ptyiosize = DEV_MAXIOSZ;
			}
			break;
		case 'n' :
			netiosize = atoi(optarg);
			if (netiosize > SOCK_MAXIOSZ) {
				netiosize = SOCK_MAXIOSZ;
			}
			break;
		case 'r' :
			nretries = atoi(optarg);
			break;
		case 'f' :
			Foreground = TRUE;
			break;
		case 'i' :
			retrydelay = atoi(optarg) * 1000;
			break;
		case 's' :
			Nvt.servertype = SRV_SOCKET;
			if(!baseport)
				baseport = SOCKET_BASE;
			break;
		case 'm' :
			devmodem = atoi (optarg);
			break;
		case 'c' :
			closemode = atoi (optarg);
			break;
		case 'p' :
			baseport = atoi (optarg);
			break;
		case 'd' :
			Debug = atoi (optarg);
			break;
		case 'x' :
			Console = TRUE;
			Foreground = TRUE;
			break;
		case 'v' :
			printf("%s\n", Version);
			exit (E_NORMAL);
		case 'h':
		case 'H':
		default :
			helpmsg();
			exit(E_PARMINVAL);
		}
	}
	if(!baseport)
		baseport = RTELNET_BASE;

	argc -= optind;
	argv += optind;

	if (argc != 3 ) {
		helpmsg();
		exit (E_PARMINVAL);
	}

	device = argv[0];

	mkidmsg(Pgname, device);

	if(strncmp(device, "/dev/", 5) != 0)
		fprintf(stderr, "%s: Warning, device does not have a \"/dev\" prefix\n", Idmsg); 

	rasname = argv[1];

	physport = atoi (argv[2]);
		
	if (physport == 0) {
		if (Nvt.servertype == SRV_RTELNET) {
			baseport = RTELNET_STD;
		} else {
			fprintf(stderr,
		"%s: Physical port must be > 0 for socket service\n", Idmsg);
			exit (E_PARMINVAL);
		}
	}

	init_system();

/* Get socket and device addresses */

	if ((retst = dev_getaddr(device)) != E_NORMAL) {
		exit (retst);
	}

	if(Nvt.servertype == SRV_RTELNET)
	{
		P_contr_listen = socket(PF_UNIX, SOCK_STREAM, 0);
		if(P_contr_listen == -1)
		{
			sysmessage(MSG_ERR, "Can't create Unix socket.\n");
			exit(1);
		}
		control_addr.sun_family = AF_UNIX;
		snprintf(P_contrname, sizeof(P_contrname), "%s.control", device);
		P_contrname[sizeof(P_contrname) - 1] = '\0';
		if(!stat(P_contrname, &stat_buf))
		{
			sysmessage(MSG_WARNING, "Removing old control socket \"%s\".\n", P_contrname);
			unlink(P_contrname);
		}
		strcpy(control_addr.sun_path, P_contrname);
		if(bind(P_contr_listen, (struct sockaddr *)&control_addr
	  	, sizeof(control_addr)) || listen(P_contr_listen, 8))
		{
			sysmessage(MSG_ERR, "Can't bind Unix socket.\n");
			exit(1);
		}
		for(i = 0; i < MAX_CONTROL_SOCKS; i++)
			P_contr[i] = -1;
	}

	if ((retst = sock_getaddr(rasname, baseport, physport)) != E_NORMAL)
		exit (retst);


	retry = 0;

	if(!Foreground)
		daemon(0, 0);

	while (retry < nretries) {

		if (retry) {
			if (retrydelay) {
				sysdelay(retrydelay);
			}
			sysmessage(MSG_WARNING, "Trying again ... \n");
		}


		if ((retst = sock_link(netiosize)) != E_NORMAL) {
			if (retst != E_CONNECT) {
				doexit(retst);
			}
			retry++;
			continue;
		}

		retry = 0;

		tsr_init(netiosize, ptyiosize, devmodem, closemode);

/* Main scheduler */

		tsr_io();

		retry++;
	} 

	sysmessage (MSG_ERR, "Exiting ...\n");

	doexit (E_RETRYEND);

	/* Not Reached */
	return 0; /* gcc gives a warning otherwise */
}

static void
helpmsg (void)
{
	fprintf(stderr, "Usage: cyclades-ser-cli [options] devname rasname physport\n");
	fprintf(stderr, "\toptions:\n");
	fprintf(stderr, "\t\t[-h] [-v] [-x]\n");
	fprintf(stderr, "\t\t[-u ptyiosize]  [-n netiosize] [-i retrydelay]\n");
	fprintf(stderr, "\t\t[-r numretries] [-t devtype]   [-s servertype]\n");
	fprintf(stderr, "\t\t[-m devmodem]   [-c closemode] [-p startport]\n");
	fprintf(stderr, "\t\t[-d deblevel]\n");
}


static void
mkidmsg(char *pgname, char *device)
{	
	char *cp;
	if ((cp = strrchr (pgname, '/')) != (char *) NULL) {
		cp++;
	} else {
		cp = pgname;
	}
	Pgname = cp;
	sprintf(Idmsg, "%7s %s", cp, device);
}