#include <ctype.h>
#include "common.h"
#include "smtp.h"
#include "y.tab.h"

Biobuf	bout;

void
usage(void)
{
	fprint(2, "usage: to\n");
	exits("usage"); 
}
void
main(void)
{
	int i, n, eof;
	Field *f, **l;
	Node *np;
	int pfd[2];
	char *uneaten;
	char buf[16*1024];
	char *argv[1024];
	char **av = argv;
	int argc = 0;

	/*
	 *  input the first 16k bytes.  The header had better fit.
	 */
	eof = 0;
	for(n = 0; n < sizeof(buf) - 1; n += i){
		i = read(0, buf+n, sizeof(buf)-1-n);
		if(i <= 0){
			eof = 1;
			break;
		}
	}
	buf[n] = 0;

	/*
	 *  parse the header, turn all addresses into @ format
	 */
	yyinit(buf);
	yyparse();

	av[argc++] = "/bin/mail";

	/*
	 *  print out all destination addresses, take out bcc
	 */
	uneaten = buf;
	l = &firstfield;
	for(f = firstfield; f; f = f->next){
		switch(f->node->c){
		case TO:
		case BCC:
		case CC:
			break;
		default:
			for(np = f->node; np; np = np->next)
				uneaten = np->end;
			l = &f->next;
			continue;
		}
		for(np = f->node; np; np = np->next){
			uneaten = np->end;
			if(np->addr)
				av[argc++] = s_to_c(np->s);
		}
		if(f->node->c == BCC)
			*l = f->next;
		else
			l = &f->next;
	}
	av[argc] = 0;

	if(pipe(pfd) < 0){
		fprint(2, "to: %r\n");
		exits("pipe");
	}

	switch(fork()){
	case -1:
		fprint(2, "to: %r\n");
		exits("fork");
	case 0:
		dup(pfd[0], 0);
		close(pfd[0]);
		close(pfd[1]);
		exec("/bin/mail", argv);
	}

	close(pfd[0]);
	Binit(&bout, pfd[1], OWRITE);

	/*
	 *  pipe headers to command
	 */
	for(f = firstfield; f; f = f->next){
		for(np = f->node; np; np = np->next){
			if(isprint(np->c&0xff))
				Bprint(&bout, "%c", np->c);
			if(np->s)
				Bprint(&bout, "%s", s_to_c(np->s));
			if(np->white)
				Bprint(&bout, "%s", s_to_c(np->white));
		}
		Bprint(&bout, "\n");
	}

	/*
	 *  pipe rest of message to command
	 */
	if(n > uneaten-buf)
		Bwrite(&bout, uneaten, n-(uneaten-buf));

	if(eof == 0)
		while((n = read(0, buf, sizeof(buf))) > 0)
			Bwrite(&bout, buf, n);

	Bflush(&bout);
}