/*
 * Copyright 2006 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

/*
 * Copyright (c) 1983 Regents of the University of California.
 * All rights reserved.  The Berkeley software License Agreement
 * specifies the terms and conditions for redistribution.
 */

#include "tip.h"
#include <limits.h>

/*
 * tip
 *
 * lower fork of tip -- handles passive side
 *  reading from the remote host
 */

FILE	*fscript;
static	sigjmp_buf sigbuf;

/*
 * TIPOUT wait state routine --
 *   sent by TIPIN when it wants to posses the remote host
 */
void
intIOT(void)
{

	(void) write(repdes[1], &ccc, 1);
	(void) read(fildes[0], &ccc, 1);
	siglongjmp(sigbuf, 1);
}

/*
 * Scripting command interpreter --
 *  accepts script file name over the pipe and acts accordingly
 */
void
intEMT(void)
{
	char c, line[PATH_MAX];
	char *pline = line;
	char reply;

	(void) read(fildes[0], &c, 1);
	while (c != '\n' && line + sizeof (line) - pline > 1) {
		*pline++ = c;
		(void) read(fildes[0], &c, 1);
	}
	*pline = '\0';
	if (boolean(value(SCRIPT)) && fscript != NULL)
		(void) fclose(fscript);
	if (pline == line) {
		boolean(value(SCRIPT)) = FALSE;
		reply = 'y';
	} else {
		if ((fscript = fopen(line, "a")) == NULL)
			reply = 'n';
		else {
			reply = 'y';
			boolean(value(SCRIPT)) = TRUE;
		}
	}
	(void) write(repdes[1], &reply, 1);
	siglongjmp(sigbuf, 1);
}

void
intTERM(void)
{

	if (boolean(value(SCRIPT)) && fscript != NULL)
		(void) fclose(fscript);
	exit(0);
}

void
intSYS(void)
{

	boolean(value(BEAUTIFY)) = !boolean(value(BEAUTIFY));
	siglongjmp(sigbuf, 1);
}

/*
 * ****TIPOUT   TIPOUT****
 */
void
tipout(void)
{
	char buf[BUFSIZ];
	char *cp;
	int cnt;
	sigset_t omask, bmask, tmask;

	(void) signal(SIGINT, SIG_IGN);
	(void) signal(SIGQUIT, SIG_IGN);
	/* attention from TIPIN */
	(void) signal(SIGEMT, (sig_handler_t)intEMT);
	/* time to go signal */
	(void) signal(SIGTERM, (sig_handler_t)intTERM);
	/* scripting going on signal */
	(void) signal(SIGIOT, (sig_handler_t)intIOT);
	/* for dial-ups */
	(void) signal(SIGHUP, (sig_handler_t)intTERM);
	/* beautify toggle */
	(void) signal(SIGSYS, (sig_handler_t)intSYS);
	(void) sigsetjmp(sigbuf, 1);

	(void) sigemptyset(&omask);
	(void) sigemptyset(&bmask);
	(void) sigaddset(&bmask, SIGEMT);
	(void) sigaddset(&bmask, SIGTERM);
	(void) sigaddset(&bmask, SIGIOT);
	(void) sigaddset(&bmask, SIGSYS);
	(void) sigemptyset(&tmask);
	(void) sigaddset(&tmask, SIGTERM);
	for (;;) {
		cnt = read(FD, buf, BUFSIZ);
		if (cnt <= 0) {
			/*
			 * If dialback is specified, ignore the hangup
			 * and clear the hangup condition on the device.
			 */
			if (cnt == 0 && DB) {
				int fd;

				DB = 0;
				if ((fd = open(DV, O_RDWR)) >= 0) {
					if (fd != FD)
						(void) close(fd);
				}
				continue;
			}
			/* lost carrier */
			if ((cnt < 0 && errno == EIO) ||
			    (cnt == 0)) {
				(void) sigprocmask(SIG_BLOCK, &tmask, NULL);
				intTERM();
				/*NOTREACHED*/
			}
		} else {
			(void) sigprocmask(SIG_BLOCK, &bmask, &omask);
			if (!noparity)
				for (cp = buf; cp < buf + cnt; cp++)
					*cp &= 0177;

			(void) write(1, buf, cnt);
			if (boolean(value(SCRIPT)) && fscript != NULL) {
				if (!boolean(value(BEAUTIFY))) {
					(void) fwrite(buf, 1, cnt, fscript);
				} else {
					for (cp = buf; cp < buf + cnt; cp++)
						if ((*cp >= ' ' && *cp <= '~')||
						    any(*cp, value(EXCEPTIONS)))
							(void) putc(*cp,
							    fscript);
				}
			}
		}
		(void) sigprocmask(SIG_SETMASK, &omask, NULL);
	}
}