/*
 *  Hunt
 *  Copyright (c) 1985 Conrad C. Huang, Gregory S. Couch, Kenneth C.R.C. Arnold
 *  San Francisco, California
 *
 *  Copyright (c) 1985 Regents of the University of California.
 *  All rights reserved.  The Berkeley software License Agreement
 *  specifies the terms and conditions for redistribution.
 */

# include	<errno.h>
# include	<curses.h>
# include	"hunt.h"
# include	<signal.h>
# include	<ctype.h>
# include	<sys/stat.h>

FLAG	Last_player = FALSE;
# ifdef MONITOR
FLAG	Am_monitor = FALSE;
# endif MONITOR
FLAG	Query_driver = FALSE;

char	Buf[BUFSIZ];

int	Master_pid;
int	Socket;
# ifdef INTERNET
char	*Sock_host;
# endif INTERNET

SOCKET	Daemon;
# ifdef	INTERNET
# define	DAEMON_SIZE	(sizeof Daemon)
# else	INTERNET
# define	DAEMON_SIZE	(sizeof Daemon - 1)
# endif	INTERNET

char	map_key[256];			/* what to map keys to */

static char	name[NAMELEN];

extern int	cur_row, cur_col, _putchar();
extern char	*tgoto();

/*
 * main:
 *	Main program for local process
 */
main(ac, av)
int	ac;
char	**av;
{
	char		*term;
	extern int	errno;
	extern int	Otto_mode;
	int		dumpit(), intr(), sigterm(), sigemt(), tstp();

	for (ac--, av++; ac > 0 && av[0][0] == '-'; ac--, av++) {
		switch (av[0][1]) {

		case 'l':	/* rsh compatibility */
		case 'n':
			if (ac <= 1)
				goto usage;
			ac--, av++;
			(void) strcpy(name, av[0]);
			break;
		case 'o':
# ifndef OTTO
			fputs("The -o flag is reserved for future use.\n",
				stderr);
			goto usage;
# else OTTO
			Otto_mode = TRUE;
			break;
# endif OTTO
# ifdef MONITOR
		case 'm':
			Am_monitor = TRUE;
			break;
# endif MONITOR
# ifdef INTERNET
		case 'q':	/* query whether hunt is running */
			Query_driver = TRUE;
			break;
		case 'h':
			if (ac <= 1)
				goto usage;
			ac--, av++;
			Sock_host = av[0];
			break;
# endif INTERNET
		default:
		usage:
# ifdef INTERNET
#  ifdef MONITOR
#   define	USAGE	"usage: hunt [-q] [-n name] [-h host] [-m]\n"
#  else MONITOR
#   define	USAGE	"usage: hunt [-q] [-n name] [-h host]\n"
#  endif MONITOR
# else INTERNET
#  ifdef MONITOR
#   define	USAGE	"usage: hunt [-n name] [-m]\n"
#  else MONITOR
#   define	USAGE	"usage: hunt [-n name]\n"
#  endif MONITOR
# endif INTERNET
			fputs(USAGE, stderr);
# undef USAGE
			exit(1);
		}
	}
# ifdef INTERNET
	if (ac > 1)
		goto usage;
	else if (ac > 0)
		Sock_host = av[0];
# else INTERNET
	if (ac > 0)
		goto usage;
# endif INTERNET	

# ifdef INTERNET
	if (Query_driver) {
		find_driver(FALSE);
		if (Daemon.sin_port != 0) {
			struct	hostent	*hp;

			hp = gethostbyaddr(&Daemon.sin_addr,
				sizeof Daemon.sin_addr, AF_INET);
			fprintf(stderr, "HUNT!! found on %s\n", hp != NULL
				? hp->h_name : inet_ntoa(Daemon.sin_addr));
		}
		exit(Daemon.sin_port == 0);
	}
# endif INTERNET
# ifdef OTTO
	if (Otto_mode)
		(void) strcpy(name, "otto");
	else
# endif OTTO
	env_init();

	(void) fflush(stdout);
	if (!isatty(0) || (term = getenv("TERM")) == NULL) {
		fprintf(stderr, "no terminal type\n");
		exit(1);
	}
	_tty_ch = 0;
	gettmode();
	setterm(term);
	noecho();
	cbreak();
	_puts(TI);
	_puts(VS);
	clear_screen();
	(void) signal(SIGINT, intr);
	(void) signal(SIGTERM, sigterm);
	(void) signal(SIGEMT, sigemt);
	(void) signal(SIGQUIT, dumpit);
	(void) signal(SIGPIPE, SIG_IGN);
	(void) signal(SIGTSTP, tstp);

	do {
# ifdef	INTERNET
		find_driver(TRUE);

		do {
			int	msg;

# ifndef OLDIPC
			Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0);
# else OLDIPC
			Socket = socket(SOCK_STREAM, 0, 0, 0);
# endif OLDIPC
			if (Socket < 0) {
				perror("socket");
				exit(1);
			}
# ifndef OLDIPC
			msg = 1;
			if (setsockopt(Socket, SOL_SOCKET, SO_USELOOPBACK,
			    &msg, sizeof msg) < 0)
				perror("setsockopt loopback");
# endif OLDIPC
			errno = 0;
			if (connect(Socket, (struct sockaddr *) &Daemon,
			    DAEMON_SIZE) < 0) {
				if (errno != ECONNREFUSED) {
					perror("connect");
					leave(1, "connect");
				}
			}
			else
				break;
			sleep(1);
		} while (close(Socket) == 0);
# else	INTERNET
		/*
		 * set up a socket
		 */

		if ((Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0)) < 0) {
			perror("socket");
			exit(1);
		}

		/*
		 * attempt to connect the socket to a name; if it fails that
		 * usually means that the driver isn't running, so we start
		 * up the driver.
		 */

		Daemon.sun_family = SOCK_FAMILY;
		(void) strcpy(Daemon.sun_path, Sock_name);
		if (connect(Socket, &Daemon, DAEMON_SIZE) < 0) {
			if (errno != ENOENT) {
				perror("connect");
				leave(1, "connect2");
			}
			start_driver();

			do {
				(void) close(Socket);
				if ((Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0)) < 0) {
					perror("socket");
					exit(1);
				}
				sleep(2);
			} while (connect(Socket, &Daemon, DAEMON_SIZE) < 0);
		}
# endif INTERNET

		do_connect(name);
		playit();
	} while (!quit());
	leave(0, NULL);
	/* NOTREACHED */
}

# ifdef INTERNET
# ifdef BROADCAST
broadcast_vec(s, vector)
	int			s;		/* socket */
	struct	sockaddr	**vector;
{
	char			if_buf[BUFSIZ];
	struct	ifconf		ifc;
	struct	ifreq		*ifr;
	int			n;
	int			vec_cnt;

	*vector = NULL;
	ifc.ifc_len = sizeof if_buf;
	ifc.ifc_buf = if_buf;
	if (ioctl(s, SIOCGIFCONF, (char *) &ifc) < 0)
		return 0;
	vec_cnt = 0;
	n = ifc.ifc_len / sizeof (struct ifreq);
	*vector = (struct sockaddr *) malloc(n * sizeof (struct sockaddr));
	for (ifr = ifc.ifc_req; n > 0; n--, ifr++)
		if (ioctl(s, SIOCGIFBRDADDR, ifr) >= 0)
			bcopy(&ifr->ifr_addr, &(*vector)[vec_cnt++],
						sizeof (struct sockaddr));
	return vec_cnt;
}
# endif BROADCAST

find_driver(do_startup)
FLAG	do_startup;
{
	int			msg;
	static SOCKET		test;
	int			test_socket;
	int			namelen;
	char			local_name[80];
	static			initial = TRUE;
	static struct in_addr	local_address;
	register struct hostent	*hp;
	int			(*oldsigalrm)(), sigalrm();
	extern int		errno;
# ifdef BROADCAST
	static	int		brdc;
	static	SOCKET		*brdv;
	int			i;
# endif BROADCAST

	if (Sock_host != NULL) {
		if (!initial)
			return;		/* Daemon address already valid */
		initial = FALSE;
		if ((hp = gethostbyname(Sock_host)) == NULL) {
			leave(1, "Unknown host");
			/* NOTREACHED */
		}
		Daemon.sin_family = SOCK_FAMILY;
		Daemon.sin_port = htons(Sock_port);
		Daemon.sin_addr = *((struct in_addr *) hp->h_addr);
		if (!Query_driver)
			return;
	}


	if (initial) {			/* do one time initialization */
# ifndef BROADCAST
		sethostent(1);		/* don't bother to close host file */
# endif BROADCAST
		if (gethostname(local_name, sizeof local_name) < 0) {
			leave(1, "Sorry, I have no name.");
			/* NOTREACHED */
		}
		if ((hp = gethostbyname(local_name)) == NULL) {
			leave(1, "Can't find myself.");
			/* NOTREACHED */
		}
		local_address = * ((struct in_addr *) hp->h_addr);

		test.sin_family = SOCK_FAMILY;
		test.sin_addr = local_address;
		test.sin_port = htons(Test_port);
	}

# ifndef OLDIPC
	test_socket = socket(SOCK_FAMILY, SOCK_DGRAM, 0);
# else OLDIPC
	test_socket = socket(SOCK_DGRAM, 0, 0, 0);
# endif OLCIPC
	if (test_socket < 0) {
		perror("socket");
		leave(1, "socket system call failed");
		/* NOTREACHED */
	}

	msg = 1;
	if (Query_driver && Sock_host != NULL) {
		test.sin_family = SOCK_FAMILY;
		test.sin_addr = Daemon.sin_addr;
		test.sin_port = htons(Test_port);
# ifndef OLDIPC
		(void) sendto(test_socket, (char *) &msg, sizeof msg, 0,
		    (struct sockaddr *) &test, DAEMON_SIZE);
# else OLDIPC
		(void) send(test_socket, (struct sockaddr *) &test,
			(char *) &msg, sizeof msg);
# endif OLDIPC
		goto get_response;
	}

	if (!initial) {
		/* favor host of previous session by broadcasting to it first */
		test.sin_addr = Daemon.sin_addr;
		test.sin_port = htons(Test_port);
		(void) sendto(test_socket, (char *) &msg, sizeof msg, 0,
		    (struct sockaddr *) &test, DAEMON_SIZE);
	}


# ifdef BROADCAST
	if (initial)
		brdc = broadcast_vec(test_socket, &brdv);

	if (brdc <= 0) {
		Daemon.sin_family = SOCK_FAMILY;
		Daemon.sin_addr = local_address;
		Daemon.sin_port = htons(Sock_port);
		initial = FALSE;
		return;
	}

	if (setsockopt(test_socket, SOL_SOCKET, SO_BROADCAST,
	    (int) &msg, sizeof msg) < 0) {
		perror("setsockopt broadcast");
		leave(1, "setsockopt broadcast");
		/* NOTREACHED */
	}

	/* send broadcast packets on all interfaces */
	for (i = 0; i < brdc; i++) {
		bcopy(&brdv[i], &test, sizeof (SOCKET));
		test.sin_port = htons(Test_port);
		if (sendto(test_socket, (char *) &msg, sizeof msg, 0,
		    (struct sockaddr *) &test, DAEMON_SIZE) < 0) {
			perror("sendto");
			leave(1, "sendto");
			/* NOTREACHED */
		}
	}
# else BROADCAST
	/* loop thru all hosts on local net and send msg to them. */
	sethostent(0);		/* rewind host file */
	while (hp = gethostent()) {
		if (inet_netof(test.sin_addr)
		== inet_netof(* ((struct in_addr *) hp->h_addr))) {
			test.sin_addr = * ((struct in_addr *) hp->h_addr);
# ifndef OLDIPC
			(void) sendto(test_socket, (char *) &msg, sizeof msg, 0,
			    (struct sockaddr *) &test, DAEMON_SIZE);
# else OLDIPC
			(void) send(test_socket, (struct sockaddr *) &test,
				(char *) &msg, sizeof msg);
# endif OLDIPC
		}
	}
# endif BROADCAST

get_response:
	namelen = DAEMON_SIZE;
	oldsigalrm = signal(SIGALRM, sigalrm);
	errno = 0;
	(void) alarm(1);
# ifndef OLDIPC
	if (recvfrom(test_socket, (char *) &msg, sizeof msg, 0,
	    (struct sockaddr *) &Daemon, &namelen) < 0)
# else OLDIPC
	if (receive(test_socket, (struct sockaddr *) &Daemon, &msg,
	    sizeof msg) < 0)
# endif OLDIPC
	{
		if (errno != EINTR) {
			perror("recvfrom");
			leave(1, "recvfrom");
			/* NOTREACHED */
		}
		(void) alarm(0);
		(void) signal(SIGALRM, oldsigalrm);
		Daemon.sin_family = SOCK_FAMILY;
		Daemon.sin_port = htons(Sock_port);
		Daemon.sin_addr = local_address;
		if (!do_startup)
			Daemon.sin_port = 0;
		else
			start_driver();
	}
	else {
		(void) alarm(0);
		(void) signal(SIGALRM, oldsigalrm);
		Daemon.sin_port = htons(Sock_port);
	}
	(void) close(test_socket);
	initial = FALSE;
}
# endif INTERNET

start_driver()
{
	register int	procid;

# ifdef MONITOR
	if (Am_monitor) {
		leave(1, "No one playing.");
		/* NOTREACHED */
	}
# endif MONITOR

# ifdef INTERNET
	if (Sock_host != NULL) {
		sleep(3);
		return 0;
	}
# endif INTERNET

	mvcur(cur_row, cur_col, 23, 0);
	cur_row = 23;
	cur_col = 0;
	put_str("Starting...");
	fflush(stdout);
	procid = vfork();
	if (procid == -1) {
		perror("fork");
		leave(1, "fork failed.");
	}
	if (procid == 0) {
		(void) signal(SIGINT, SIG_IGN);
		(void) close(Socket);
		execl(Driver, "HUNT", NULL);
		/* only get here if exec failed */
		kill(getppid(), SIGEMT);	/* tell mom */
		_exit(1);
	}
	mvcur(cur_row, cur_col, 23, 0);
	cur_row = 23;
	cur_col = 0;
	put_str("Connecting...");
	fflush(stdout);
	return 0;
}

/*
 * bad_con:
 *	We had a bad connection.  For the moment we assume that this
 *	means the game is full.
 */
bad_con()
{
	leave(1, "The game is full.  Sorry.");
	/* NOTREACHED */
}

/*
 * dumpit:
 *	Handle a core dump signal by not dumping core, just leaving,
 *	so we end up with a core dump from the driver
 */
dumpit()
{
	(void) kill(Master_pid, SIGQUIT);
	(void) chdir("coredump");
	abort();
}

/*
 * sigterm:
 *	Handle a terminate signal
 */
sigterm()
{
	leave(0, NULL);
	/* NOTREACHED */
}


/*
 * sigemt:
 *	Handle a emt signal - shouldn't happen on vaxes(?)
 */
sigemt()
{
	leave(1, "Unable to start driver.  Try again.");
	/* NOTREACHED */
}

# ifdef INTERNET
/*
 * sigalrm:
 *	Handle an alarm signal
 */
sigalrm()
{
	return;
}
# endif INTERNET

/*
 * rmnl:
 *	Remove a '\n' at the end of a string if there is one
 */
rmnl(s)
char	*s;
{
	register char	*cp;
	char		*rindex();

	cp = rindex(s, '\n');
	if (cp != NULL)
		*cp = '\0';
}

/*
 * intr:
 *	Handle a interrupt signal
 */
intr()
{
	register int	ch;
	register int	explained;
	register int	y, x;

	(void) signal(SIGINT, SIG_IGN);
	y = cur_row;
	x = cur_col;
	mvcur(cur_row, cur_col, 23, 0);
	cur_row = 23;
	cur_col = 0;
	put_str("Really quit? ");
	clear_eol();
	fflush(stdout);
	explained = FALSE;
	for (;;) {
		ch = getchar();
		if (isupper(ch))
			ch = tolower(ch);
		if (ch == 'y') {
			(void) write(Socket, "q", 1);
			(void) close(Socket);
			leave(0, NULL);
		}
		else if (ch == 'n') {
			(void) signal(SIGINT, intr);
			mvcur(cur_row, cur_col, y, x);
			cur_row = y;
			cur_col = x;
			fflush(stdout);
			return;
		}
		if (!explained) {
			put_str("(Y or N) ");
			fflush(stdout);
			explained = TRUE;
		}
		(void) putchar(CTRL(G));
		(void) fflush(stdout);
	}
}

/*
 * leave:
 *	Leave the game somewhat gracefully, restoring all current
 *	tty stats.
 */
leave(eval, mesg)
int	eval;
char	*mesg;
{
	mvcur(cur_row, cur_col, 23, 0);
	if (mesg == NULL)
		clear_eol();
	else {
		put_str(mesg);
		clear_eol();
		putchar('\n');
		fflush(stdout);		/* flush in case VE changes pages */
	} 
	resetty();
	_puts(VE);
	_puts(TE);
	exit(eval);
}

/*
 * tstp:
 *	Handle stop and start signals
 */
tstp()
{
	static struct sgttyb	tty;
	int	y, x;

	tty = _tty;
	y = cur_row;
	x = cur_col;
	mvcur(cur_row, cur_col, 23, 0);
	cur_row = 23;
	cur_col = 0;
	_puts(VE);
	_puts(TE);
	(void) fflush(stdout);
	resetty();
	(void) kill(getpid(), SIGSTOP);
	(void) signal(SIGTSTP, tstp);
	_tty = tty;
	(void) stty(_tty_ch, &_tty);
	_puts(TI);
	_puts(VS);
	cur_row = y;
	cur_col = x;
	_puts(tgoto(CM, cur_row, cur_col));
	redraw_screen();
	fflush(stdout);
}

env_init()
{
	register int	i;
	char	*envp, *envname, *s, *index();

	for (i = 0; i < 256; i++)
		map_key[i] = (char) i;

	envname = NULL;
	if ((envp = getenv("HUNT")) != NULL) {
		while ((s = index(envp, '=')) != NULL) {
			if (strncmp(envp, "name=", s - envp + 1) == 0) {
				envname = s + 1;
				if ((s = index(envp, ',')) == NULL) {
					*envp = '\0';
					break;
				}
				*s = '\0';
				envp = s + 1;
			}			/* must be last option */
			else if (strncmp(envp, "mapkey=", s - envp + 1) == 0) {
				for (s = s + 1; *s != '\0'; s += 2) {
					map_key[(unsigned int) *s] = *(s + 1);
					if (*(s + 1) == '\0') {
						break;
					}
				}
				*envp = '\0';
				break;
			} else {
				*s = '\0';
				printf("unknown option %s\n", envp);
				if ((s = index(envp, ',')) == NULL) {
					*envp = '\0';
					break;
				}
				envp = s + 1;
			}
		}
		if (*envp != '\0')
			if (envname == NULL)
				envname = envp;
			else
				printf("unknown option %s\n", envp);
	}
	if (envname != NULL) {
		(void) strcpy(name, envname);
		printf("Entering as '%s'\n", envname);
	}
	else if (name[0] == '\0') {
		printf("Enter your code name: ");
		if (fgets(name, sizeof name, stdin) == NULL)
			exit(1);
	}
	rmnl(name);
}