Not Found


#include "httpd.h"
#include "../rtl837x_common.h"
#include "../rtl837x_flash.h"
#include "uip.h"
#include "../html_data.h"

#define CMARK_S 6

#pragma codeseg BANK1

extern __code struct f_data f_data[];
extern __code fcall_ptr f_calls[];

__xdata uint8_t entry;
__xdata uint16_t mpos;
__xdata uint16_t len_left;

#define TSTATE_NONE	0
#define TSTATE_TX	1
#define TSTATE_ACKED 	2
#define TSTATE_CLOSED 	3


inline uint8_t is_space(uint8_t c)
{
	return c == ' ' || c == '\t';
}


void httpd_init(void) __banked
{
	__xdata struct httpd_state *s = &(uip_conn->appstate);
	// Start listening to port 80
	uip_listen(HTONS(80));
	s->tstate = TSTATE_CLOSED;
}


uint8_t find_entry(uint8_t *e)
{
	register uint8_t i, j;

	for (i = 0; f_data[i].len; i++) {
		j = 0;
		while (f_data[i].file[j] && (f_data[i].file[j] == e[j])) {
			j++;
		}
		if ((!f_data[i].file[j]) && (!e[j])) {
			return i;
		}
	}
	return 0xff;
}


void httpd_appcall(void)
{
	__xdata struct httpd_state *s = &(uip_conn->appstate);
	__xdata uint8_t *outbuf = s->outbuf;

	write_char('P');
	if(uip_connected() && s->tstate == TSTATE_CLOSED) {
		print_string("Connected...\n");
		s->tstate = TSTATE_NONE;
	} else if (uip_closed()) {
		print_string("Connection closed\n");
		s->tstate = TSTATE_CLOSED;
	} else if (uip_poll()) {
		uip_len = 0;
		if (s->tstate == TSTATE_ACKED) {
			print_string("Closing because everything has been transmitted\n");
			uip_close();
		}
//		write_char('p');
	} else if (uip_acked() && s->tstate == TSTATE_TX) {
		print_string("ACK\n");
		if (s->slen > uip_mss()) {
			s->slen -= uip_mss();
			s->o_idx += uip_mss();
		} else {
			s->slen = 0;
			s->o_idx += s->slen;
		}

		s->tstate = TSTATE_ACKED;

		if (s->slen > uip_mss()) {
			print_string("Sending A: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, uip_mss());
			print_string("Sending A done\n");
			s->tstate = TSTATE_TX;
		} else if (s->slen > 0) {
			print_string("Sending B: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, s->slen);
			print_string("Sending B done\n");
			s->tstate = TSTATE_TX;
		}
	} else if (uip_newdata() && s->tstate != TSTATE_TX) {
		write_char('<'); print_short(uip_len); write_char('\n');
		__xdata uint8_t *p = uip_appdata;
		p[uip_len] = 0;
		while (*p)
			write_char(*p++);
		write_char('\n');
		p = uip_appdata;
		if (p[0] == 'G' && p[1] == 'E' && p[2] == 'T' && p[3] == ' ')
			print_string("GET request ");
		p += 4;
		__xdata uint8_t *q = p;
		while (!is_space(*p))
			p++;
		*p = '\0';
		print_string_x(q);
		write_char('\n');

		s->tstate = TSTATE_NONE;
		entry = find_entry(q);
		print_string("Entry is: "); print_byte(entry); write_char('\n');
		if (entry == 0xff) {
			print_string("Not found\n");
			s->slen = strtox(outbuf, "HTTP/1.1 404 Not found\r\nContent-Type: text/html\r\n\r\n");
			print_string("slen: "); print_short(s->slen); write_char('\n');
			s->slen += strtox(outbuf + s->slen, "<!DOCTYPE HTML PUBLIC>\n<title>404 Not Found</title>\n<h1>Not Found</h1>\n");
		} else {
			print_string("Have entry\n");
			s->slen = strtox(outbuf, "HTTP/1.1 200 OK\r\nContent-Type: ");
			s->slen += strtox(outbuf + s->slen, f_data[entry].mime);
			s->slen += strtox(outbuf + s->slen, "\r\n\r\n");
			len_left = f_data[entry].len;
			if (f_data[entry].mime[0] == 't' && f_data[entry].mime[5] == 'h') {
				print_string("MIME is html len is "); print_short(len_left); write_char('\n');
				mpos = 0;
				flash_find_mark(f_data[entry].start, len_left, "#{");
				print_string("mpos: "); print_short(mpos); write_char('\n');
				while (mpos != 0xffff) {
					print_string("Entry-len:"); print_short(len_left); write_char('\n');
					mpos = len_left - mpos;
					print_string("l/pos: "); print_short(mpos); write_char('\n');
					flash_read_bulk(outbuf + s->slen, f_data[entry].start + f_data[entry].len - len_left, mpos + CMARK_S);  // call marker is e.g. #{001}
					s->slen += mpos;
					write_char('@'); write_char(outbuf[s->slen + 2]); write_char(outbuf[s->slen + 3]); write_char(outbuf[s->slen + 4]);
					fcall_ptr ptr = f_calls[(outbuf[s->slen + 2] - '0') * 100 + (outbuf[s->slen + 3]-'0') * 10 + outbuf[s->slen + 4] - '0'];
					s->slen -= CMARK_S; // Overwrite marker with generated html
					print_string("Call location is: "); print_short((uint16_t)ptr); write_char('\n');
//					f_calls[outbuf[s->slen + 2] * 100 + outbuf[s->slen + 3] * 10 + outbuf[s->slen + 4]]();
					ptr(outbuf);
					print_string("call done\n");
					mpos += CMARK_S;
					len_left -= mpos;
					flash_find_mark(f_data[entry].start + mpos, len_left, "#{");
				}
				print_string("At end mpos: "); print_short(mpos); write_char('\n');
				flash_read_bulk(outbuf + s->slen, f_data[entry].start + f_data[entry].len - len_left, len_left);
				s->slen += len_left;
			} else {
				print_string("MIME: "); print_string(f_data[entry].mime); write_char('\n');
				flash_read_bulk(outbuf + s->slen, f_data[entry].start, len_left);
				s->slen += len_left;
			}
		}
		print_string("slen: "); print_short(s->slen); write_char('\n');
		s->o_idx = 0;
		if (s->slen > uip_mss()) {
			print_string("Sending a: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, uip_mss());
			print_string("Sending a done\n");
		} else {
			print_string("Sending b: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, s->slen);
			print_string("Sending b done\n");
		}
		s->tstate = TSTATE_TX;
	} else if (uip_rexmit()) { // Connection established, need to rexmit?
		print_string("RETRANSMIT requested\n");
		if (s->slen > uip_mss()) {
			print_string("Sending C: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, uip_mss());
			print_string("Sending C done\n");
		} else if (s->slen > 0) {
			print_string("Sending D: "); print_short(s->slen); write_char('\n');
			uip_send(outbuf + s->o_idx, s->slen);
			print_string("Sending D done\n");
		}
		s->tstate = TSTATE_TX;
		uip_len = 0;
	} else {
		uip_len = 0;
	}
}