--- parser3/src/targets/cgi/parser3.C	2001/03/13 18:32:48	1.3
+++ parser3/src/targets/cgi/parser3.C	2001/03/23 08:47:49	1.35
@@ -1,91 +1,249 @@
-/*
-	Parser
+/** @file
+	Parser: scripting and CGI main.
+
 	Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
+
 	Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
 
-	$Id: parser3.C,v 1.3 2001/03/13 18:32:48 paf Exp $
+	$Id: parser3.C,v 1.35 2001/03/23 08:47:49 paf Exp $
 */
 
-#include "pa_config.h"
+#ifdef HAVE_CONFIG_H
+#	include "pa_config.h"
+#endif
+
 
 #ifdef WIN32
 #	include <windows.h>
 #	include <io.h>
+#else
+#	include <unistd.h>
 #endif
+
+//\ifwin32
+#include <io.h>
+//#include <fcntl.h>
+//\endifwin32
+
 #include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <fcntl.h>
 
-#include "core.h"
-#include "pa_request.h"
 #include "pa_common.h"
+#include "pa_globals.h"
+#include "pa_request.h"
+
+Pool pool; // global pool
+bool cgi; ///< we were started as CGI?
 
 #ifdef WIN32
-// TODO:  LONG WINAPI TopLevelExceptionFilter (
+#	if _MSC_VER
+// intercept global system errors
+static LONG WINAPI TopLevelExceptionFilter (
+									 struct _EXCEPTION_POINTERS *ExceptionInfo
+									 ) {
+	char buf[MAX_STRING];
+	if(ExceptionInfo && ExceptionInfo->ExceptionRecord) {
+		struct _EXCEPTION_RECORD *rr=ExceptionInfo->ExceptionRecord;
+		snprintf(buf, MAX_STRING, "Exception %#X at %p", 
+			er->ExceptionCode, 
+			er->ExceptionAddress);
+	} else 
+		strcpy(buf, "Exception <unknown>");
+	
+	PTHROW(0, 0,
+		0,
+		buf);
+
+	return EXCEPTION_EXECUTE_HANDLER; // never reached
+}
+#	endif
+
 #endif
 
+//\if
+static void fix_slashes(char *s) {
+	if(s)
+		for(; *s; s++)
+			if(*s=='\\')
+				*s='/';
+}
+//\endif
+
+// service funcs
+
+static const char *get_env(Pool& pool, const char *name) {
+ 	return getenv(name);
+}
+
+static uint read_post(char *buf, uint max_bytes) {
+	int read_size=0;
+	do {
+		int chunk_size=read
+			(fileno(stdin), buf+read_size, min(0x400*0x400, max_bytes-read_size));
+		if(chunk_size<0)
+			break;
+		read_size+=chunk_size;
+	} while(read_size<max_bytes);
+
+	return read_size;
+}
+
+static void add_header_attribute(const char *key, const char *value) {
+	if(cgi)
+		printf("%s: %s\n", key, value);
+}
+
+/// @todo intelligent cache-control
+static void send_header(const char *buf, size_t size) {
+	if(cgi) {
+		puts("Cache-Control: no-cache");
+
+		// header | body  delimiter
+		puts("");
+	}
+}
+
+static void send_body(const char *buf, size_t size) {
+	stdout_write(buf, size);
+}
+
+/// Service funcs 
+ Service_funcs service_funcs={
+		get_env,
+		read_post,
+		add_header_attribute,
+		send_header,
+		send_body
+ };
+
+
+// main
+
 int main(int argc, char *argv[]) {
-#ifdef WIN32
-	_fmode=_O_BINARY;			/*sets default for file streams to binary */
-	setmode(_fileno(stdin), O_BINARY);		/* make the stdio mode be binary */
-	setmode(_fileno(stdout), O_BINARY);		/* make the stdio mode be binary */
-	setmode(_fileno(stderr), O_BINARY);		/* make the stdio mode be binary */
+	umask(2);
 
-	//TODO:	SetUnhandledExceptionFilter(&TopLevelExceptionFilter);
-	//TODO: initSocks();
+#ifdef WIN32
+	setmode(fileno(stdin), _O_BINARY);
+	setmode(fileno(stdout), _O_BINARY);
+	setmode(fileno(stderr), _O_BINARY);
 #endif
 
-	
-	Pool pool;
-	core(pool);
-
 	// were we started as CGI?
-	bool cgi=
+	cgi=
 		getenv("SERVER_SOFTWARE") || 
 		getenv("SERVER_NAME") || 
 		getenv("GATEWAY_INTERFACE") || 
 		getenv("REQUEST_METHOD");
-
-	// TODO: ifdef WIN32 flip \\ to /
-	const char *document_root="Y:/parser3/src/";
-	const char *page_filespec="Y:/parser3/src/test.p";
-
-	// request
-	Request request(pool,
-		cgi ? String::Untaint_lang::HTML_TYPO : String::Untaint_lang::NO,
-		document_root,
-		page_filespec
-		);
 	
-	bool error;
-	// some root-controlled location
-	char *sys_auto_path1;
-#ifdef WIN32
-	sys_auto_path1=(char *)pool.malloc(MAX_STRING);
-	GetWindowsDirectory(sys_auto_path1, MAX_STRING-1/*for \*/);
-	strcat(sys_auto_path1, '\\');
+	if(!cgi) {
+		if(argc<2) {
+			char *binary=argv[0];
+			printf("Usage: %s <file>\n", binary?binary:"parser3");
+			exit(1);
+		}
+	}
+
+	char *filespec_to_process=cgi?getenv("PATH_TRANSLATED"):argv[1];
+//\#ifdef WIN32
+	fix_slashes(filespec_to_process);
+//\#endif
+
+	const char *request_method=getenv("REQUEST_METHOD");
+	bool header_only=request_method && strcasecmp(request_method, "HEAD")==0;
+	PTRY { // global try
+		// must be first in PTRY{}PCATCH
+#ifdef WIN32
+#	if _MSC_VER
+		SetUnhandledExceptionFilter(&TopLevelExceptionFilter);
+		//TODO: initSocks();
+#	endif
+#endif
+
+		// init global variables
+		globals_init(pool);
+
+		if(!filespec_to_process)
+			PTHROW(0, 0,
+				0,
+				"no file to process");
+
+		// Request info
+		Request::Info request_info;
+		const char *document_root=getenv("DOCUMENT_ROOT");
+		if(!document_root) {
+			static char fake_document_root[MAX_STRING];
+			strncpy(fake_document_root, filespec_to_process, MAX_STRING);
+			rsplit(fake_document_root, '/');  rsplit(fake_document_root, '\\');// strip filename
+			document_root=fake_document_root;
+		}
+		request_info.document_root=document_root;
+		request_info.path_translated=filespec_to_process;
+		request_info.method=request_method;
+		request_info.query_string=getenv("QUERY_STRING");
+		request_info.uri=getenv("REQUEST_URI");
+		request_info.content_type=getenv("CONTENT_TYPE");
+		const char *content_length=getenv("CONTENT_LENGTH");
+		request_info.content_length=(content_length?atoi(content_length):0);
+		request_info.cookie=getenv("HTTP_COOKIE");
+
+		// prepare to process request
+		Pool request_pool;
+		Request request(request_pool,
+			request_info,
+			cgi ? String::UL_HTML_TYPO : String::UL_NO
+			);
+		
+		// some root-controlled location
+		char *root_auto_path;
+#ifdef WIN32
+		// c:\windows
+		root_auto_path=(char *)pool.malloc(MAX_STRING);
+		GetWindowsDirectory(root_auto_path, MAX_STRING);
 #else
-	sys_auto_path1=getenv("HOME");
+		// ~nobody
+		root_auto_path=getenv("HOME");
 #endif
-	
-	// beside by binary
-	const char *sys_auto_path2=(char *)pool.malloc(MAX_STRING);
-	strncpy(sys_auto_path2, argv[0]);  // filespec of my binary
-	rsplit(sys_auto_path2, '\\');  rsplit(sys_auto_path2, '/'); // strip filename
-	
-	char *result=request.core(
-		sys_auto_path1, 
-		sys_auto_path2);
-	
-	if(cgi) {
-		const char *content_type="text/html";
-		printf(
-			"Content-type: %s\n"
-			"Content-length: %d\n"
-			"\n", 
-				content_type,
-				strlen(result));
-		stdout_write(result);
-	} else
-		printf("%s", result);
+		
+		// beside by binary
+		char *site_auto_path=(char *)pool.malloc(MAX_STRING);
+		strncpy(site_auto_path, argv[0], MAX_STRING);  // filespec of my binary
+		rsplit(site_auto_path, '/');  rsplit(site_auto_path, '\\');// strip filename
+		
+		// process the request
+		request.core(
+			root_auto_path, false,
+			site_auto_path, false,
+			header_only);
 
-	return 0;
+		// must be last in PTRY{}PCATCH
+#ifdef WIN32
+#	if _MSC_VER
+		SetUnhandledExceptionFilter(0);
+#	endif
+#endif
+		// successful finish
+		return 0;
+	} PCATCH(e) { // global problem 
+		const char *body=e.comment();
+		int content_length=strlen(body);
+
+		// prepare header
+		add_header_attribute("content-type", "text/plain");
+		char content_length_cstr[MAX_NUMBER];
+		snprintf(content_length_cstr, MAX_NUMBER, "%lu", content_length);
+		add_header_attribute("content-length", content_length_cstr);
+
+		// send header
+		send_header(pool);
+
+		// body
+		if(!header_only)
+			send_body(body, content_length);
+
+		// unsuccessful finish
+		return 1;
+	}
+	PEND_CATCH
 }