psyc-mirrors
/
psyced
mirror of git://git.psyced.org/git/psyced
1
0
Fork 0
Code Issues 2 Releases Wiki Activity

improved POST

This commit is contained in:
psyc://psyced.org/~lynX 2011-08-27 10:48:32 +02:00
parent e48996dcd7
commit 3786072189
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
world/net/http/server.c
View File

@ -26,12 +26,18 @@ devNull();
qScheme() { return "html"; } qScheme() { return "html"; }
quit() { quit() {
D2(D("««« SmallHTTP user done.\n");) D2(D("««« HTTP done.\n");)
destruct(ME); destruct(ME);
} }
timeout() {
if (method == "post" && stringp(body) && strlen(body))
body(); // try using incomplete post
else quit();
}
logon() { logon() {
D2(D("»»» New SmallHTTP user\n");) D2(D("»»» HTTP request:\n");)
// bigger buffer (for psyc logo) // bigger buffer (for psyc logo)
set_buffer_size(32768); set_buffer_size(32768);
@ -40,12 +46,12 @@ logon() {
// using heart_beat() or something like that TODO // using heart_beat() or something like that TODO
next_input_to(#'parse_url); next_input_to(#'parse_url);
call_out(#'quit, 23); call_out(#'timeout, 23);
} }
disconnected(remainder) { disconnected(remainder) {
// TODO: shouldn't ignore remainder // TODO: shouldn't ignore remainder
D2(D("««« SmallHTTP got disconnected.\n");) D2(D("««« HTTP got disconnected.\n");)
destruct(ME); destruct(ME);
return 1; // expected death of socket return 1; // expected death of socket
} }
@ -66,7 +72,7 @@ parse_wait(null) { // waiting to send my error message here
} }
parse_url(input) { parse_url(input) {
P3(("=== SmallHTTP got: %O\n", input)) P3(("=== HTTP got: %O\n", input))
unless (sscanf(input, "%s%t%s%tHTTP/%s", method, url, prot)) quit(); unless (sscanf(input, "%s%t%s%tHTTP/%s", method, url, prot)) quit();
switch (method) { switch (method) {
case "CONNECT": case "CONNECT":
@ -82,7 +88,7 @@ parse_url(input) {
prot = "HTTP/" + prot; prot = "HTTP/" + prot;
P2(("=== SmallHTTP user requested url: %O\n", url)) P2(("=== HTTP user requested url: %O\n", url))
next_input_to(#'parse_header); next_input_to(#'parse_header);
} }
@ -265,7 +271,7 @@ case "/oauth":
if (done) if (done)
quit(); quit();
else else
remove_call_out(#'quit); remove_call_out(#'timeout);
return 1; return 1;
} }
@ -275,5 +281,5 @@ emit(a) { return binary_message(a); }
devNull() { devNull() {
next_input_to(#'devNull); next_input_to(#'devNull);
D2(D("=== SmallHTTP just ignored some input\n");) D2(D("=== HTTP just ignored some input\n");)
} }