#include <u.h>
#include <libc.h>
#include <bio.h>

#include "modem.h"

int
faxsend(Modem *m, int argc, char *argv[])
{
	int c, count, r;
	char buf[128];

	verbose("faxsend");
	if((r = initfaxmodem(m)) != Eok)
		return r;

	/* telco just does the dialing */
	r = response(m, 120);
	switch(r){
	case Rok:
		break;
	default:
		r = seterror(m, Enoanswer);
		return r;
		
	}

	m->pageno = 1;
	while(argc--){
		if(m->pageno != 1)
			sleep(1000);	/* let the paper catch up */

		m->valid &= ~(Vfhng|Vfet|Vfpts|Vftsi|Vfdcs);
		if((r = openfaxfile(m, *argv)) != Eok)
			return r;

		sprint(buf, "AT+FDT=%d,%d,%d,%d", m->df, m->vr, m->wd, m->ln);
		if(command(m, buf) != Eok)
			goto buggery;
		if(response(m, 20) != Rconnect){
			r = seterror(m, Eincompatible);
			goto buggery;
		}

		/* wait for first ^S */
		getmchar(m, buf, 5);

		/*
		 * Write the data, stuffing DLE's.
		 * After each bufferfull check if the remote
		 * sent us anything, e.g. CAN to abort.
		 * This also flushes out the ^S/^Q characters
		 * which the driver insists on sending us.
		 * (Could fix the driver, of course...).
		 */
		for(;;){
			count = 0;
			c = 0;
			while(count < sizeof(buf)-1){
				if((c = BGETC(m->bp)) < 0)
					break;
				buf[count++] = c;
				if(c == '\020')
					buf[count++] = c;
			}
			if(count && write(m->fd, buf, count) < 0){
				r = seterror(m, Esys);
				goto buggery;
			}
			if(c < 0)
				break;

			while((r = rawmchar(m, buf)) == Eok){
				if(buf[0] == '\030'){
					verbose("%c", buf[0]);
					if(write(m->fd, "\020\003", 2) < 0){
						r = seterror(m, Esys);
						goto buggery;
					}
					goto okexit;
				}
				if(buf[0] != '\021' && buf[0] != '\023' && buf[0] != '\n'){
					verbose("%c", buf[0]);
					r = seterror(m, Eproto);
					goto buggery;
				}
			}
		}

		/*
		 * End of page, send DLE+ETX,
		 * get OK in response.
		 */
		if(write(m->fd, "\020\003", 2) < 0){
			r = seterror(m, Esys);
			goto buggery;
		}
		if(response(m, 20) != Rok){
			r = seterror(m, Enoresponse);
			goto buggery;
		}

		/*
		 * Did you hear me? - IT'S THE END OF THE PAGE.
		 * Argument is 0 if more pages to follow.
		 * Should get back an FPTS with an indication
		 * as to whether the page was successfully
		 * transmitted or not.
		 */
		sprint(buf, "AT+FET=%d", argc == 0? 2: 0);
		if(command(m, buf) != Eok)
			goto buggery;
		switch(response(m, 20)){
		case Rok:
			break;
		case Rhangup:
			if(m->fhng == 0 && argc == 0)
				break;
			r = seterror(m, Eproto);
			goto buggery;
		default:
			r = seterror(m, Enoresponse);
			goto buggery;
		}

		if((m->valid & Vfpts) == 0 || m->fpts[0] != 1){
			r = seterror(m, Eproto);
			goto buggery;
		}

		Bterm(m->bp);
		m->pageno++;
		argv++;
	}
okexit:
	return Eok;

buggery:
	Bterm(m->bp);
	command(m, "AT+FK");
	response(m, 5);
	return r;
}