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

#include "modem.h"

int
faxsend(Modem *m, int argc, char *argv[])
{
	int c, count, r, flow;
	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;
		
	}

	xonoff(m, 1);
	verbose("sending");
	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;

		verbose("sending geometry");
		sprint(buf, "AT+FDT=%ld,%ld,%ld,%ld", 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;
		}

		/*
		 * 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...).
		 */
		verbose("sending data");
		for(;;){
			flow = 0;
			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;
			}
			verbose("sending %d bytes", count);
			if(count && write(m->fd, buf, count) < 0){
				verbose("write failed: %r");
				r = seterror(m, Esys);
				goto buggery;
			}
			/*
			 *  this does really rough flow control since the
			 *  avanstar is even worse
			 */
			verbose("flow control");
			while((r = rawmchar(m, buf)) == Eok || flow){
				if(r != Eok){
					if(flow-- == 0)
						break;
					sleep(250);
					continue;
				}
				switch(buf[0]){
				case '\030':
					verbose("%c", buf[0]);
					if(write(m->fd, "\020\003", 2) < 0){
						r = seterror(m, Esys);
						goto buggery;
					}
					goto okexit;
				case '\021':
					flow = 0;
					break;
				case '\023':
					flow = 4;
					break;
				case '\n':
					break;
				default:
					verbose("%c", buf[0]);
					r = seterror(m, Eproto);
					goto buggery;
				
				}
			}
			if(c < 0)
				break;
		}


		/*
		 * End of page, send DLE+ETX,
		 * get OK in response.
		 */
		verbose("sending end of page");
		if(write(m->fd, "\020\003", 2) < 0){
			r = seterror(m, Esys);
			goto buggery;
		}
		verbose("waiting for OK");
		if(response(m, 120) != 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:
	xonoff(m, 0);
	return Eok;

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