#define	CONSOLE		"/dev/console"
#define	dprcons		if (debug) prcons
/*
 * vpd.c						updated 11/18/82
 * Varian or Versatec printer daemon
 */
char vpdSCCSid[] = "@(#)vpd.c	1.4\t11/18/82";

#include <stdio.h>
#include <sys/param.h>
#include <dir.h>
#include <signal.h>
#include <stat.h>
#include <sgtty.h>
#include <errno.h>
#include <sys/vcmd.h>
#include <wait.h>

int	debug;
extern	int errno;

#define VRAST		"/usr/local/lib/vrast"
#define VDMP		"/usr/lib/vdmp"
#define VPLTDMP		"/usr/lib/vpltdmp"

#ifdef VARIAN
#define DEVICE		"/dev/va0"
#define DFNAME		"/usr/spool/vad/"
#define SPOOLDIR	"/usr/spool/vad"
#define NAME		"Varian"
#endif

#ifdef VERSATEC
#define DEVICE		"/dev/vp0"
#define DFNAME		"/usr/spool/vpd/"
#define SPOOLDIR	"/usr/spool/vpd"
#define NAME		"Versatec"
#endif

int	prtmode[] =	{VPRINT, 0, 0};

char	line[128];
char    linep[127];
char	banbuf[64];
char	banner[512];
char	printflag;
int	linel;
FILE	*dfb;
char	dfname[33] = DFNAME;
int	waittm = 6;
int	onalrm ();
char	tmplock[] = "lockXXXXXX";
char	fonts[4][50] = {
	"/usr/lib/vfont/R",
	"/usr/lib/vfont/I",
	"/usr/lib/vfont/B",
	"/usr/lib/vfont/S"
};

main(argc, argv)
	int argc;
	char **argv;
{
	char n;
	register char *p1, *p2;
	register int df;
	register struct direct *dirp;
	DIR *dp;
	struct stat stb;
	int offline = 0;
	int i, okreque = 1;

	while (argc > 1) {
		argc--;
		argv++;
		if (argv[0][0] != '-')
			continue;
		switch (argv[0][1]) {
		case 'n':
			if (argc < 2)
				break;
			argv++;
			argc--;
			nice(atol(argv[0]));
			break;
		}
	}
	setuid(getuid());
	signal(SIGHUP, SIG_IGN);
	signal(SIGINT, SIG_IGN);
	signal(SIGQUIT, SIG_IGN);
	signal(SIGTERM, SIG_IGN);
begin:
/*
 * Close all files, open root as 0, 1, 2
 * to assure standard environment
 */
	for (df = 0; df <= 15; df++)
		close(df);
	open("/", 0);
	dup(0);
	dup(0);
	if (chdir(SPOOLDIR) < 0 || (df = creat(mktemp(tmplock), 0)) < 0) {
		close(1);
		prcons("%s: error accessing %s\n", NAME, SPOOLDIR);
		exit(1);
	}
	if (link(tmplock, "lock") < 0) {
		unlink(tmplock);
		exit(0);
	}
	unlink(tmplock);
	close(df);
floop:
	dprcons("floop\n");
	i = fork();
	if (i < 0) {
		sleep(5);
		goto floop;
	}
	if (i != 0)
		exit(0);
reopen:
	dprcons("reopen\n");
	for (;;) {
		if (open(DEVICE, 1) == 3)
			break;
		if (errno != EIO) {
			extern char *sys_errlist[];
			prcons("%s: %s: %s\n", NAME, DEVICE, sys_errlist[errno]);
			unlink("lock");
			exit(1);
		}
		if (offline == 0) {
			int f = open("/dev/tty", 1);

			offline++;
			if (f > 0) {
				write(f, NAME, strlen(NAME));
				write(f, " is offline\n", 12);
				close(f);
			}
			dprcons("offline\n");
		}
		sleep(10);
	}
	dp = opendir(".");
search:
	dprcons("search\n");
	if (okreque == 1) {
		rewinddir(dp);
		do {
			dirp = readdir(dp);
			if (dirp == NULL) {
				if (printflag)
					lastpage();
				unlink("lock");
				dprcons("nomore\n");
				if (printflag==0) {
					dprcons("bye\n");
					exit(0);
				}
				dprcons("one last time\n");
				printflag = 0;
				close(3);
				closedir(dp);
				sleep(30);
				goto begin;
			}
		} while (dirp->d_name[0] != 'd' || dirp->d_name[1] != 'f');
		strcpy(&dfname[15], dirp->d_name);
		dprcons("found %s\n", dirp->d_name);
	}
	dprcons("trying %s\n", dfname);
	printflag = 1;
	if (okreque == 0)
		feedpage();
	if (trysend(dfname, okreque)) {
		okreque = 0;
		closedir(dp);
		printf("reque %s\n", dfname);
		close(3);
		goto reopen;
	}
	dprcons("ok\n");
	okreque = 1;
	goto search;
}

trysend(file, okreque)
char *file;
int okreque;
{
	register int i;
	char plot;
	union wait status;
	int bomb = 0;

	resfonts();
	dfb = fopen(file, "r");
	if (dfb == NULL) {
		unlink(file);
		return (0);
	}
	banner[0] = '\0';
	for(*banbuf= plot= 0; getline();) switch(line[0]) {

	case 'L':
		strcpy(banbuf, line + 1);
		continue;

	case 'B':	/* banner */
		if(banner[0] == '\0')
		    strcat(banner, line + 1);
		  else {
		    strcat(banner,"\n");
		    strcat(banner, line+1);
		    }
		continue;

	case '1':
	case '2':
	case '3':
	case '4':
		strcpy(fonts[line[0]-'1'], line + 1);
		continue;

	case 'C':	/* called by cifplot */
	case 'V':	/* called by vplot */
	case 'F':
	case 'G':	/* Like f, but invoke vpf with -l flag. */
	case 'T':
		status.w_status = send(line[0]);
		break;

	case 'P':
		if (plot) {
			plot = 0;
			status.w_status = send(line[0]);
			break;
		}
		strcpy(linep, line + 1);
		plot++;
		continue;

	case 'U':
		continue;

	case 'M':
		continue;
	}
	/*
	 * If the process that did the work did an exit(1),
	 * we should requeue the file.
	 */
	if (!WIFEXITED(status) || status.w_retcode > 1) {
		ioctl(3, VSETSTATE, prtmode);
		write(3, "\nDAEMON MALFUNCTION\n", 20);
		feedpage();
		bomb++;
	} else if (status.w_retcode == 1 && okreque)
		return (1);
	/*
	 * All done, for better or for worse.
	 */
	fseek(dfb, 0, 0);
	while (getline()) switch (*line) {

	default:
		continue;

	case 'U':
		unlink(line + 1);
		continue;

	case 'M':
		sendmail(bomb);
		continue;
	}
remret:
	fclose(dfb);
	unlink(file);
	return (0);
}

static char ifonts[4][50] = {
	"/usr/lib/vfont/R",
	"/usr/lib/vfont/I",
	"/usr/lib/vfont/B",
	"/usr/lib/vfont/S"
};

resfonts()
{
	int i;
	for (i = 0; i < 4; i++)
		strcpy(fonts[i], ifonts[i]);
}

sendmail(bomb)
	int bomb;
{
	static int p[2];
	register i;
	int stat;

	pipe(p);
	if (fork() == 0) {
		alarm(0);
		close(0);
		dup(p[0]);
		for (i = 3; i <= 15; i++)
			close(i);
		execl("/bin/mail", "mail", &line[1], 0);
		exit(0);
	}
	close(1);
	dup(p[1]);
	printf("Your %s job %s\n", NAME, bomb ? "screwed up" : "is done");
	close(1);
	close(p[0]);
	close(p[1]);
	open("/", 0);
	wait(&stat);
}

getline()
{
	register char *lp;
	register int c;

	lp = line;
	linel = 0;
	while ((c = getc (dfb)) != '\n') {
		if (c < 0)
			return (0);
		if (c == '\t') {
			do {
				*lp++ = ' ';
				linel++;
			} while ((linel & 07) != 0);
			continue;
		}
		*lp++ = c;
		linel++;
	}
	*lp++ = 0;
	return (1);
}

int	pid;

send (c)
char c;
{
	int p, i, rm;

	if (pid = fork ()) {
		if (pid == -1)
			return (1);
		setexit();
		signal(SIGALRM, onalrm);
		alarm(30);
		wait(&p);
		alarm(0);
		return(p);
	}
	ioctl (3, VSETSTATE, prtmode);
	switch (c) {

	case 'F':
		if (banbuf[0]) {
			execl ("/usr/lib/vpf", "vpf",
#ifdef VERSATEC
				"-W",
#endif
				"-b", banbuf, line+1, 0);
			break;
		}
		execl ("/usr/lib/vpf", "vpf",
#ifdef VERSATEC
			"-W",
#endif
			line, 0);
		break;

	case 'G':	/* Like F (vpf), but passes through -l
			   flag to vpf (print control chars). */
		if (banbuf[0]) {
			execl ("/usr/lib/vpf", "vpf", "-l",
#ifdef VERSATEC
				"-W",
#endif
				"-b", banbuf, line+1, 0);
			break;
		}
		execl ("/usr/lib/vpf", "vpf", "-l",
#ifdef VERSATEC
			"-W",
#endif
			line, 0);
		break;

	case 'T':
		unlink(".railmag");
		rm = creat(".railmag", 0666);
		for (i = 0; i < 4; i++) {
			if (fonts[i][0] != '/')
				write(rm, "/usr/lib/vfont/", 15);
			write(rm, fonts[i], strlen (fonts[i]));
			write(rm, "\n", 1);
		}
		close(rm);
		if (banbuf[0]) {
#ifdef VARIAN
			execl("/usr/lib/rvcat", "rvcat",
#endif
#ifdef VERSATEC
			execl("/usr/lib/vcat", "rvcat",
				"-W",
#endif
				"-3", "-b", banbuf, line+1, 0);
			break;
		}
#ifdef VARIAN
		execl("/usr/lib/rvcat", "rvcat",
#endif
#ifdef VERSATEC
		execl("/usr/lib/vcat", "rvcat",
			"-W",
#endif
			"-3", line+1, 0);
		break;

	case 'P':
		close(1);
		dup(3);
		if (banbuf[0]) {
			execl(VRAST, "vrast",
#ifdef VERSATEC
				"-W",
#endif
				"-v", "-b", banbuf, line+1, linep, 0);
			break;
		}
		execl(VRAST, "vrast",
#ifdef VERSATEC
			"-W",
#endif
			"-v", line+1, linep, 0);
		break;
	case 'C':
		execl(VDMP,"vdmp","-n",banbuf,"-b",banner,
#ifdef VERSATEC
			"-W",
#endif
			line+1,0);
		break;
	case 'V':
		execl(VPLTDMP,"vpltdmp","-n",banbuf,"-b",banner,
#ifdef VERSATEC
			"-W",
#endif
			line+1,0);
		break;
	}
	exit(2);	/* execl failed or not one of above cases. */
}

onalrm()
{
	struct stat stb;

	signal(SIGALRM, onalrm);
	if (stat(dfname, &stb) < 0)
		kill(pid, SIGEMT);
	reset();
}

/*
 * skip 16 inches or do two formfeeds.
 */
lastpage()
{
	register int i;

	ioctl(3, VSETSTATE, prtmode);
#ifdef VARIAN
	write(3, "\014\014", 2);
#endif
#ifdef VERSATEC
	for (i = 0; i < 18; i++)
		write(3, "\n\n\n\n\n\n\n\n", 8);
#endif
}

feedpage()
{

	ioctl(3, VSETSTATE, prtmode);
#ifdef VARIAN
	write(3, "\014\0", 2);
#endif
#ifdef VERSATEC
	write(3, "\n\n\n", 8);
#endif
}

prcons(cp, a1, a2, a3, a4, a5)
	char *cp;
{
	char buf[BUFSIZ];
	int f = open(CONSOLE, 1);

	sprintf(buf, cp, a1, a2, a3, a4, a5);
	write(f, buf, strlen(buf));
	close(f);
}