parser3/src/targets/cgi/parser3.C - diff

Return to parser3.C CVS log

Up to [parser3project] / parser3 / src / targets / cgi

Diff for /parser3/src/targets/cgi/parser3.C between versions 1.302 and 1.363

version 1.302, 2020/10/14 00:14:45	version 1.363, 2024/12/03 23:48:43
Line 1	Line 1
/** @file	/** @file
Parser: scripting and CGI main.	Parser: scripting and CGI main.

Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com)	Copyright (c) 2001-2024 Art. Lebedev Studio (http://www.artlebedev.com)
Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)	Authors: Konstantin Morshnev <moko@design.ru>, Alexandr Petrosian <paf@design.ru>
*/	*/

volatile const char * IDENT_PARSER3_C="$Id$";	volatile const char * IDENT_PARSER3_C="$Id$";
Line 14 volatile const char * IDENT_PARSER3_C="$	Line 14 volatile const char * IDENT_PARSER3_C="$
#include "pa_common.h"	#include "pa_common.h"
#include "pa_request.h"	#include "pa_request.h"
#include "pa_version.h"	#include "pa_version.h"
	#include "pa_threads.h"
#include "pa_vconsole.h"	#include "pa_vconsole.h"
#include "pa_sapi_info.h"	#include "pa_sapi_info.h"

Line 21 volatile const char * IDENT_PARSER3_C="$	Line 22 volatile const char * IDENT_PARSER3_C="$
#include <crtdbg.h>	#include <crtdbg.h>
#include <windows.h>	#include <windows.h>
#include <direct.h>	#include <direct.h>

	extern "C" HANDLE WINAPI GC_CreateThread(LPSECURITY_ATTRIBUTES, DWORD, LPTHREAD_START_ROUTINE, LPVOID, DWORD, LPDWORD);

	#else

	extern "C" int GC_pthread_create(pthread_t , const pthread_attr_t , void ()(void ), void /* arg */);

#endif	#endif

// defines	// defines

// comment remove me after debugging	// comment remove me after debugging
//#define PA_DEBUG_CGI_ENTRY_EXIT "parser3-debug.log"	//#define PA_DEBUG_CGI_ENTRY_EXIT

#if defined(_MSC_VER) && !defined(_DEBUG)	#if defined(_MSC_VER) && !defined(_DEBUG)
# define PA_SUPPRESS_SYSTEM_EXCEPTION	# define PA_SUPPRESS_SYSTEM_EXCEPTION
Line 38 volatile const char * IDENT_PARSER3_C="$	Line 46 volatile const char * IDENT_PARSER3_C="$
#define PARSER_CONFIG_ENV_NAME "CGI_PARSER_CONFIG"	#define PARSER_CONFIG_ENV_NAME "CGI_PARSER_CONFIG"
#define PARSER_LOG_ENV_NAME "CGI_PARSER_LOG"	#define PARSER_LOG_ENV_NAME "CGI_PARSER_LOG"

static const char* config_filespec_cstr=0; // -f option	SAPI_Info sapi_console;
static const char* httpd_host_port=0; // -p option	SAPI_Info_CGI sapi_cgi;
static bool mail_received=false; // -m option? [asked to parse incoming message to $mail:received]
	static SAPI_Info *sapi_info = &sapi_cgi;
static int args_skip=1;	static THREAD_LOCAL SAPI_Info *sapi_info_4log = NULL; // global for correct send error in die()
static char** argv_all = NULL;
	static const char* filespec_to_process = 0; // [file]
static bool cgi; ///< we were started as CGI?	static const char* httpd_host_port = 0; // -p option
	static const char* config_filespec = 0; // -f option or from env or next to the executable if exists
// for signal handlers	static const char* log_filespec = 0; // -l option
Request *request=0;	static bool mail_received = false; // -m option? [asked to parse incoming message to $mail:received]
bool execution_canceled=false;	static const char* parser3_filespec = 0; // argv[0]
// for die error logging	static char** argv_extra = NULL;
Request_info request_info;
	// for error logging
	static THREAD_LOCAL Request_info *request_info_4log = NULL; // global for correct log() reporting
	static const char* filespec_4log = NULL; // null only if system-wide auto.p used

	template <typename T> static T dir_pos(T fname){
	T *result=NULL;
	while (fname=strpbrk(fname, "/\\")){
	result=fname;
	fname++;
	}
	return result;
	}

// SAPI	// SAPI

static void log(const char* fmt, va_list args) {	static void pa_log(const char* fmt, va_list args) {
bool opened=false;
FILE *f=0;	FILE *f=0;
	const char* slog=log_filespec;

const char* log_by_env=getenv(PARSER_LOG_ENV_NAME);	if(!slog)
if(!log_by_env)	slog=getenv(PARSER_LOG_ENV_NAME);
log_by_env=getenv(REDIRECT_PREFIX PARSER_LOG_ENV_NAME);	if(!slog)
if(log_by_env) {	slog=getenv(REDIRECT_PREFIX PARSER_LOG_ENV_NAME);
f=fopen(log_by_env, "at");
opened=f!=0;	if(slog) {
}	f=strcmp(slog,"-") ? fopen(slog, "at") : stderr;
#ifdef PA_DEBUG_CGI_ENTRY_EXIT	} else if(filespec_4log) {
f=fopen(PA_DEBUG_CGI_ENTRY_EXIT, "at");	char log_spec[MAX_STRING + 12 /* '/parser3.log' */];
opened=f!=0;	pa_strncpy(log_spec, filespec_4log, MAX_STRING);
#endif

if(!opened && config_filespec_cstr) {	if(char* log_dir_pos=dir_pos(log_spec)){
char beside_config_path[MAX_STRING];	strcpy(log_dir_pos, "/parser3.log");
strncpy(beside_config_path, config_filespec_cstr, MAX_STRING-1); beside_config_path[MAX_STRING-1]=0;	} else {
if(!(rsplit(beside_config_path, '/') \|\| rsplit(beside_config_path, '\\'))) { // strip filename
// no path, just filename	// no path, just filename
beside_config_path[0]='.'; beside_config_path[1]=0;	strcpy(log_spec, "./parser3.log");
}	}
	f=fopen(log_spec, "at");
char file_spec[MAX_STRING];
snprintf(file_spec, MAX_STRING, "%s/parser3.log", beside_config_path);
f=fopen(file_spec, "at");
opened=f!=0;
}	}

// fallback to stderr	// fallback to stderr
if(!opened)	if(!f)
f=stderr;	f=stderr;

// use no memory [so that we could log out-of-memory error]	// use no memory [so that we could log out-of-memory error]
Line 95 static void log(const char* fmt, va_list	Line 110 static void log(const char* fmt, va_list
time_t t=time(0);	time_t t=time(0);
if(const char* stamp=ctime(&t)) { // never saw that	if(const char* stamp=ctime(&t)) { // never saw that
if(size_t len=strlen(stamp)) // saw once stamp being =""	if(size_t len=strlen(stamp)) // saw once stamp being =""
fprintf(f, "[%.*s] [%u] ", (int)len-1, stamp, (unsigned int)getpid() );	fprintf(f, "[%.*s] [%u] ", (int)len-1, stamp, (unsigned int)pa_get_thread_id() );
}	}
// message	// message

Line 104 static void log(const char* fmt, va_list	Line 119 static void log(const char* fmt, va_list
size=remove_crlf(buf, buf+size);	size=remove_crlf(buf, buf+size);
fwrite(buf, size, 1, f);	fwrite(buf, size, 1, f);

if(request_info.method) {	if(request_info_4log && request_info_4log->method) {
fprintf(f, " [uri=%s, method=%s, cl=%lu]\n", request_info.uri ? request_info.uri : "<unknown>", request_info.method, (unsigned long)request_info.content_length);	fprintf(f, " [uri=%s, method=%s, cl=%lu]\n", request_info_4log->uri ? request_info_4log->uri : "<unknown>", request_info_4log->method, (unsigned long)request_info_4log->content_length);
} else	} else
fputs(" [no request info]\n", f);	fputs(" [no request info]\n", f);

if(opened)	if(f!=stderr)
fclose(f);	fclose(f);
else	else
fflush(f);	fflush(f);
}	}

#ifdef PA_DEBUG_CGI_ENTRY_EXIT	void pa_log(const char* fmt, ...) {
static void log(const char* fmt, ...) {
va_list args;	va_list args;
va_start(args,fmt);	va_start(args,fmt);
log(fmt, args);	pa_log(fmt, args);
va_end(args);	va_end(args);
}	}
#endif

// appends to parser3.log located beside my binary if openable, to stderr otherwize	// appends to parser3.log located next to the config file if openable, to stderr otherwize
void SAPI::log(SAPI_Info&, const char* fmt, ...) {	void SAPI::log(SAPI_Info&, const char* fmt, ...) {
va_list args;	va_list args;
va_start(args,fmt);	va_start(args,fmt);
::log(fmt, args);	pa_log(fmt, args);
va_end(args);	va_end(args);
}	}

Line 137 void SAPI::die(const char* fmt, ...) {	Line 150 void SAPI::die(const char* fmt, ...) {

// logging first, first vsnprintf	// logging first, first vsnprintf
va_start(args,fmt);	va_start(args,fmt);
::log(fmt, args);	pa_log(fmt, args);
va_end(args);	va_end(args);

// inform user, second vsnprintf	// inform user, second vsnprintf
Line 145 void SAPI::die(const char* fmt, ...) {	Line 158 void SAPI::die(const char* fmt, ...) {
char message[MAX_STRING];	char message[MAX_STRING];
vsnprintf(message, MAX_STRING, fmt, args);	vsnprintf(message, MAX_STRING, fmt, args);

SAPI::send_error(*sapiInfo, message);	SAPI::send_error(sapi_info_4log ? sapi_info_4log : sapi_info, message);
exit(1);	exit(1);
// va_end(args);	// va_end(args);
}	}

	void SAPI::send_error(SAPI_Info& info, const char exception_cstr, const char status){
	info.send_error(exception_cstr, status);
	}

char* SAPI::Env::get(SAPI_Info& info, const char* name) {	char* SAPI::Env::get(SAPI_Info& info, const char* name) {
return info.get_env(name);	return info.get_env(name);
}	}

	bool SAPI::Env::set(SAPI_Info& info, const char* name, const char* value) {
	return info.set_env(name, value);
	}

const char* const *SAPI::Env::get(SAPI_Info& info) {	const char* const *SAPI::Env::get(SAPI_Info& info) {
return info.get_env();	return info.get_env();
}	}

size_t SAPI::read_post(SAPI_Info& info, char *buf, size_t max_bytes) {	size_t SAPI::read_post(SAPI_Info& info, char* buf, size_t max_bytes) {
return info.read_post(buf, max_bytes);	return info.read_post(buf, max_bytes);
}	}

void SAPI::add_header_attribute(SAPI_Info& info, const char* dont_store_key, const char* dont_store_value) {	void SAPI::add_header_attribute(SAPI_Info& info, const char* dont_store_key, const char* dont_store_value) {
info.add_header_attribute(dont_store_key, dont_store_value);	info.add_header(dont_store_key, dont_store_value);
}	}

void SAPI::send_header(SAPI_Info& info) {	void SAPI::send_headers(SAPI_Info& info) {
info.send_header();	info.send_headers();
	}

	void SAPI::clear_headers(SAPI_Info& info) {
	info.clear_headers();
}	}

size_t SAPI::send_body(SAPI_Info& info, const void *buf, size_t size) {	size_t SAPI::send_body(SAPI_Info& info, const void *buf, size_t size) {
return info.send_body(buf, size);	return info.send_body(buf, size);
}	}

static void full_file_spec(const char* file_name, char *buf, size_t buf_size) {	static const char* full_disk_path(const char* file_name = "") {
if(file_name)	char* result;
if(file_name[0]=='/'	if(file_name[0]=='/'
#ifdef WIN32	#ifdef WIN32
\|\| file_name[0] && file_name[1]==':'	\|\| file_name[0] && file_name[1]==':'
#endif	#endif
){	){
strncpy(buf, file_name, buf_size-1); buf[buf_size-1]=0;	result=pa_strdup(file_name);
} else {	} else {
char cwd[MAX_STRING];	char cwd[MAX_STRING];
snprintf(buf, buf_size, "%s/%s", getcwd(cwd, MAX_STRING) ? cwd : "", file_name);	result=pa_strcat(getcwd(cwd, MAX_STRING) ? cwd : "", "/", file_name);
}	}
else
buf[0]=0;
#ifdef WIN32	#ifdef WIN32
back_slashes_to_slashes(buf);	back_slashes_to_slashes(result);
#endif	#endif
	return result;
}	}

static void log_signal(const char* signal_name) {	static void log_signal(const char* signal_name) {
SAPI::log(*sapiInfo, "%s received %s processing request", signal_name, request ? "while" : "before or after");	pa_log("%s received %s processing request", signal_name, request ? "while" : "before or after");
}

#ifdef SIGUSR1
static void SIGUSR1_handler(int /sig/){
log_signal("SIGUSR1");
}	}
#endif

#ifdef SIGPIPE	#ifdef SIGPIPE
#define SIGPIPE_NAME "SIGPIPE"	#define SIGPIPE_NAME "SIGPIPE"
Line 213 static void SIGPIPE_handler(int /sig/)	Line 231 static void SIGPIPE_handler(int /sig/)
if(sigpipe && sigpipe->as_bool())	if(sigpipe && sigpipe->as_bool())
log_signal(SIGPIPE_NAME);	log_signal(SIGPIPE_NAME);

execution_canceled=true;
if(request)	if(request)
request->set_skip(Request::SKIP_INTERRUPTED);	request->set_skip(Request::SKIP_INTERRUPTED);
}	}
#endif	#endif

	// requires pa_thread_request() in entry_exists() under Windows
	static const char* locate_config(const char* config_filespec_option, const char* executable_path){
	filespec_4log=config_filespec_option;
	if(!filespec_4log)
	filespec_4log=getenv(PARSER_CONFIG_ENV_NAME);
	if(!filespec_4log)
	filespec_4log=getenv(REDIRECT_PREFIX PARSER_CONFIG_ENV_NAME);
	if(!filespec_4log){
	const char* exec_dir_pos = dir_pos(executable_path);
	#ifdef SYSTEM_CONFIG_FILE
	if(exec_dir_pos){
	#endif
	// next to the executable
	if(!exec_dir_pos \|\| (exec_dir_pos==executable_path+1 && *executable_path=='.')){
	// when just parser3 or ./parser3 full path should be used to avoid "parser already configured"
	filespec_4log=full_disk_path(AUTO_FILE_NAME);
	} else {
	filespec_4log=pa_strcat(pa_strdup(executable_path, exec_dir_pos - executable_path), "/" AUTO_FILE_NAME);
	}
	if(entry_exists(filespec_4log))
	return filespec_4log;
	#ifdef SYSTEM_CONFIG_FILE
	}
	if(entry_exists(SYSTEM_CONFIG_FILE)){
	filespec_4log=NULL;
	return SYSTEM_CONFIG_FILE;
	}
	#endif
	return NULL;
	}
	return filespec_4log;
	}

#ifdef WIN32	#ifdef WIN32
const char* maybe_reconstruct_IIS_status_in_qs(const char* original) {	static const char* maybe_reconstruct_IIS_status_in_qs(const char* original) {
// 404;http://servername/page[?param=value...]	// 404;http://servername/page[?param=value...]
// ';' should be urlencoded by HTTP standard, so we shouldn't get it from browser	// ';' should be urlencoded by HTTP standard, so we shouldn't get it from browser
// and can consider that as an indication that this is IIS way to report errors	// and can consider that as an indication that this is IIS way to report errors
Line 252 const char* maybe_reconstruct_IIS_status	Line 302 const char* maybe_reconstruct_IIS_status
return original;	return original;
}	}

	static const char* maybe_back_slashes_to_slashes(const char* original){
	char *result=pa_strdup(original);
	back_slashes_to_slashes(result);
	return result;
	}

#define MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(s) maybe_reconstruct_IIS_status_in_qs(s)	#define MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(s) maybe_reconstruct_IIS_status_in_qs(s)
#else	#define MAYBE_BACK_SLASHES_TO_SLASHES(s) maybe_back_slashes_to_slashes(s)

	#else

#define MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(s) s	#define MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(s) s
#endif	#define MAYBE_BACK_SLASHES_TO_SLASHES(s) s

	#endif

class RequestController {	class RequestController {
public:	public:
RequestController(Request* r){	RequestController(Request* r){
::request=r;	request=r;
}	}
~RequestController(){	~RequestController(){
::request=0;	request=0;
}	}
};	};

static bool locate_config(){	class RequestInfoController {
if(!config_filespec_cstr) {	public:
config_filespec_cstr=getenv(PARSER_CONFIG_ENV_NAME);	RequestInfoController(Request_info* rinfo, SAPI_Info* sinfo){
if(!config_filespec_cstr)	request_info_4log=rinfo;
config_filespec_cstr=getenv(REDIRECT_PREFIX PARSER_CONFIG_ENV_NAME);	sapi_info_4log=sinfo;
if(!config_filespec_cstr){	}
// beside by binary	~RequestInfoController(){
char beside_binary_path[MAX_STRING];	request_info_4log=0;
strncpy(beside_binary_path, argv_all[0], MAX_STRING-1); beside_binary_path[MAX_STRING-1]=0; // filespec of my binary	sapi_info_4log=0;
if(!(rsplit(beside_binary_path, '/') \|\| rsplit(beside_binary_path, '\\'))) { // strip filename
// no path, just filename
// @todo full path, not ./!
beside_binary_path[0]='.'; beside_binary_path[1]=0;
}
char config_filespec_buf[MAX_STRING];
snprintf(config_filespec_buf, MAX_STRING, "%s/%s", beside_binary_path, AUTO_FILE_NAME);
config_filespec_cstr=pa_strdup(config_filespec_buf);
return entry_exists(config_filespec_cstr);
}
}	}
return true;	};
}

static void connection_handler(SAPI_Info_HTTPD &info, HTTPD_Connection &connection, const char* filespec_to_process){
connection.read_header();
info.populate_env();

// connection request info, still global for correct log() reporting	/** httpd support */
memset(&request_info, 0, sizeof(request_info));	static const String httpd_class_name("httpd");

char document_root_buf[MAX_STRING];	static void config_handler(SAPI_Info &info) {
full_file_spec("", document_root_buf, sizeof(document_root_buf));	Request_info request_info;
request_info.document_root = document_root_buf;	RequestInfoController ric(&request_info, &info);
request_info.path_translated = filespec_to_process;
request_info.method = connection.method();	request_info.document_root = full_disk_path();
request_info.query_string = connection.query();	request_info.uri = "";
request_info.uri = request_info.strip_absolute_uri(connection.uri());	request_info.argv = argv_extra;
request_info.content_type = connection.content_type();
request_info.content_length = connection.content_length();
request_info.cookie = info.get_env("HTTP_COOKIE");
request_info.mail_received = false;
request_info.argv = argv_all + args_skip;

// prepare to process request	// prepare to process request
Request request(info, request_info, String::Language(String::L_HTML\|String::L_OPTIMIZE_BIT));	Request r(info, request_info, String::Language(String::L_HTML\|String::L_OPTIMIZE_BIT));
{	// only once
// initing ::request ptr for signal handlers	config_filespec = locate_config(config_filespec, parser3_filespec);
RequestController rc(&request);	// process main auto.p only
bool fail_on_config_read_problem=locate_config();	r.core(config_filespec, false, String::Empty);
	}

	static void connection_handler(SAPI_Info_HTTPD &info, HTTPD_Connection &connection) {
	Request_info request_info;
	RequestInfoController ric(&request_info, &info);

	try {
	if(!connection.read_header())
	return; // ignore "void" connections
	info.populate_env();

	request_info.document_root = full_disk_path();
	request_info.path_translated = filespec_to_process;
	request_info.method = connection.method();
	request_info.query_string = connection.query();
	request_info.uri = request_info.strip_absolute_uri(connection.uri());
	request_info.content_type = connection.content_type();
	request_info.content_length = (size_t)connection.content_length();
	request_info.cookie = info.get_env("HTTP_COOKIE");
	request_info.mail_received = false;
	request_info.argv = argv_extra;

	// prepare to process request
	Request r(info, request_info, String::Language(String::L_HTML\|String::L_OPTIMIZE_BIT));
// process the request	// process the request
request.core(config_filespec_cstr, fail_on_config_read_problem, strcasecmp(request_info.method, "HEAD")==0);	r.core(config_filespec, strcasecmp(request_info.method, "HEAD")==0, main_method_name, &httpd_class_name);
// clearing ::request in RequestController desctructor to prevent signal handlers from accessing invalid memory	} catch(const Exception& e) { // exception in connection handling
	SAPI::log(info, "%s", e.comment());
	const char* status = info.exception_http_status(e.type());
	if(*status)
	SAPI::send_error(info, e.comment(), status);
}	}
}	}

static void httpd_mode(const char* filespec_to_process){	#ifdef _MSC_VER
int sock = HTTPD_Server::bind(httpd_host_port);	DWORD WINAPI connection_thread(void *arg){
	#else
	static void connection_thread(void arg){
	#endif
	HTTPD_Connection &connection=(HTTPD_Connection)arg;
	SAPI_Info_HTTPD info(connection);

	try {
	connection_handler(info, connection);
	} catch(const Exception& e) { // exception in send_error
	pa_log("%s", e.comment());
	}

	delete(&connection);
	return 0;
	}

	static void httpd_mode() {
	config_handler(*sapi_info);

	SOCKET sock = HTTPD_Server::bind(httpd_host_port);

	#ifdef SIGPIPE
	signal(SIGPIPE, SIG_IGN);
	#endif

while(1){	while(1){
HTTPD_Connection *connection = HTTPD_Server::accept(sock, 5);	#ifndef _MSC_VER
if(!connection)	pid_t pid=1;
continue;	if(HTTPD_Server::mode == HTTPD_Server::PARALLEL)
	while (waitpid((pid_t)(-1), 0, WNOHANG) > 0);
SAPI_Info_HTTPD info(*connection);	#endif
	try {
try { // connection try	HTTPD_Connection connection;
connection_handler(info, *connection, filespec_to_process);	if(!connection.accept(sock, 500))
} catch(const Exception& e) { // exception in connection handling or unhandled exception	continue;
SAPI::log(info, "%s", e.comment());
SAPI::send_error(info, e.comment(), info.exception_http_status(e.type()));	switch (HTTPD_Server::mode) {
	case HTTPD_Server::MULTITHREADED:
	#ifdef _MSC_VER
	if (!GC_CreateThread(0, 0, connection_thread, new HTTPD_Connection(connection), 0, 0))
	throw Exception("httpd.fork", 0, "thread creation failed");
	connection.sock=INVALID_SOCKET;
	break;
	#else
	#ifdef HAVE_TLS
	pthread_t thread;
	pthread_attr_t attr;
	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

	if(int result=GC_pthread_create(&thread, &attr, connection_thread, new HTTPD_Connection(connection)))
	throw Exception("httpd.fork", 0, "thread creation failed (%d)", result);
	connection.sock=INVALID_SOCKET;
	break;
	#endif
	case HTTPD_Server::PARALLEL:
	pid=fork();
	if(pid<0)
	throw Exception("httpd.fork", 0, "fork failed: %s (%d)", strerror(errno), errno);
	if(pid>0)
	continue; // parent should close connection.sock as well
	#endif
	case HTTPD_Server::SEQUENTIAL: // and fork child

	SAPI_Info_HTTPD info(connection);
	connection_handler(info, connection);
	}
	// closing connection socket in HTTPD_Connection destructor
	} catch(const Exception& e) { // exception in accept or send_error
	pa_log("%s", e.comment());
}	}
connection->close();
	#ifndef _MSC_VER
	if(pid==0) // fork child
	exit(0);
	#endif
}	}
}	}

/** main workhorse */	/** main workhorse */

static void real_parser_handler(const char* filespec_to_process) {	static void real_parser_handler(bool cgi) {
// init libraries	// init libraries
pa_globals_init();	pa_globals_init();

if(httpd_host_port){	if(httpd_host_port){
httpd_mode(filespec_to_process);	httpd_mode();
}	}

const char* request_method=getenv("REQUEST_METHOD");	const char* request_method=getenv("REQUEST_METHOD");

if(!filespec_to_process \|\| !*filespec_to_process)	if(!filespec_to_process)
SAPI::die("Parser/%s", PARSER_VERSION);	SAPI::die("Parser/%s", PARSER_VERSION);

char document_root_buf[MAX_STRING];

// global request info	// global request info
	Request_info request_info;
	RequestInfoController ric(&request_info, sapi_info);

request_info.path_translated = filespec_to_process;	request_info.path_translated = filespec_to_process;
request_info.method = request_method ? request_method : "GET";	request_info.method = request_method ? request_method : "GET";
request_info.query_string = MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(getenv("QUERY_STRING"));	request_info.query_string = MAYBE_RECONSTRUCT_IIS_STATUS_IN_QS(getenv("QUERY_STRING"));
Line 369 static void real_parser_handler(const ch	Line 499 static void real_parser_handler(const ch
// obligatory	// obligatory
const char* path_info=getenv("PATH_INFO");	const char* path_info=getenv("PATH_INFO");
if(!path_info)	if(!path_info)
SAPI::die("CGI: illegal call (missing PATH_INFO)");	SAPI::die("parser3: illegal CGI call (missing PATH_INFO)");

request_info.document_root = getenv("DOCUMENT_ROOT");	request_info.document_root = getenv("DOCUMENT_ROOT");
if(!request_info.document_root) {	if(!request_info.document_root) {
// IIS or fcgiwrap minimalistic setup	// IIS or fcgiwrap minimalistic setup
ssize_t prefix_len = strlen(filespec_to_process) - strlen(path_info);	ssize_t prefix_len = strlen(filespec_to_process) - strlen(path_info);
if(prefix_len < 0 \|\| strcmp(filespec_to_process + prefix_len, path_info) != 0)	if(prefix_len < 0 \|\| strcmp(filespec_to_process + prefix_len, path_info) != 0)
SAPI::die("CGI: illegal call (invalid PATH_INFO in reinventing DOCUMENT_ROOT)");	SAPI::die("parser3: illegal CGI call (invalid PATH_INFO in reinventing DOCUMENT_ROOT)");

char* document_root = new(PointerFreeGC) char[prefix_len + 1/0/];	char* document_root = new(PointerFreeGC) char[prefix_len + 1/0/];
memcpy(document_root, filespec_to_process, prefix_len); document_root[prefix_len] = 0;	memcpy(document_root, filespec_to_process, prefix_len); document_root[prefix_len] = 0;
Line 388 static void real_parser_handler(const ch	Line 518 static void real_parser_handler(const ch
// another obligatory	// another obligatory
const char* script_name = getenv("SCRIPT_NAME");	const char* script_name = getenv("SCRIPT_NAME");
if(!script_name)	if(!script_name)
SAPI::die("CGI: illegal call (missing SCRIPT_NAME)");	SAPI::die("parser3: illegal CGI call (missing SCRIPT_NAME)");
/*	/*
http://parser3/env.html?123 =OK	http://parser3/env.html?123 =OK
$request:uri=/env.html?123	$request:uri=/env.html?123
Line 405 static void real_parser_handler(const ch	Line 535 static void real_parser_handler(const ch
size_t script_name_len = strlen(script_name);	size_t script_name_len = strlen(script_name);
size_t uri_len = strlen(request_info.uri);	size_t uri_len = strlen(request_info.uri);
if(strncmp(request_info.uri, script_name, script_name_len)==0 && script_name_len != uri_len) // under IIS they are the same	if(strncmp(request_info.uri, script_name, script_name_len)==0 && script_name_len != uri_len) // under IIS they are the same
SAPI::die("CGI: illegal call (1)");	SAPI::die("parser3: illegal CGI call (REQUEST_URI starts with SCRIPT_NAME)");
} else { // fcgiwrap minimalistic setup	} else { // fcgiwrap minimalistic setup
	request_info.uri = request_info.query_string && *request_info.query_string ? pa_strcat(path_info, "?", request_info.query_string) : path_info;
if(request_info.query_string && *request_info.query_string) {
char* reconstructed_uri = new(PointerFreeGC) char[strlen(path_info) + 1/'?'/+ strlen(request_info.query_string) + 1/0/];
strcpy(reconstructed_uri, path_info);
strcat(reconstructed_uri, "?");
strcat(reconstructed_uri, request_info.query_string);
request_info.uri = reconstructed_uri;
} else
request_info.uri = path_info;
}	}
} else{	} else{
full_file_spec("", document_root_buf, sizeof(document_root_buf));	request_info.document_root = full_disk_path();
request_info.document_root = document_root_buf;
request_info.uri = "";	request_info.uri = "";
}	}

request_info.content_type = getenv("CONTENT_TYPE");	request_info.content_type = getenv("CONTENT_TYPE");
request_info.content_length = pa_atoui(getenv("CONTENT_LENGTH"), 10);	request_info.content_length = cgi ? (size_t)pa_atoul(getenv("CONTENT_LENGTH")) : 0; // only SAPI_Info_CGI can read POST
request_info.cookie = getenv("HTTP_COOKIE");	request_info.cookie = getenv("HTTP_COOKIE");
request_info.mail_received = mail_received;	request_info.mail_received = mail_received;

request_info.argv = argv_all + args_skip;	request_info.argv = argv_extra;

if(execution_canceled)
SAPI::die("Execution canceled");

#ifdef PA_DEBUG_CGI_ENTRY_EXIT	#ifdef PA_DEBUG_CGI_ENTRY_EXIT
log("request_info: method=%s, uri=%s, q=%s, dr=%s, pt=%s, cookies=%s, cl=%u",	pa_log("request_info: method=%s, uri=%s, q=%s, dr=%s, pt=%s", request_info.method, request_info.uri, request_info.query_string, request_info.document_root, request_info.path_translated);
request_info.method,
request_info.uri,
request_info.query_string,
request_info.document_root,
request_info.path_translated,
request_info.cookie,
request_info.content_length);
#endif	#endif

// prepare to process request	// prepare to process request
Request request(*sapiInfo, request_info, cgi ? String::Language(String::L_HTML\|String::L_OPTIMIZE_BIT) : String::L_AS_IS);	Request r(*sapi_info, request_info, cgi ? String::Language(String::L_HTML\|String::L_OPTIMIZE_BIT) : String::L_AS_IS);
{	{
// initing ::request ptr for signal handlers	// initing ::request ptr for signal handlers
RequestController rc(&request);	RequestController rc(&r);
bool fail_on_config_read_problem=locate_config();
// process the request	// process the request
request.core(config_filespec_cstr, fail_on_config_read_problem, strcasecmp(request_info.method, "HEAD")==0);	r.core(locate_config(config_filespec, parser3_filespec), strcasecmp(request_info.method, "HEAD")==0);
// clearing ::request in RequestController desctructor to prevent signal handlers from accessing invalid memory	// clearing ::request in RequestController destructor to prevent signal handlers from accessing invalid memory
}	}

// finalize libraries	// finalize libraries
Line 460 static void real_parser_handler(const ch	Line 570 static void real_parser_handler(const ch
}	}

#ifdef PA_SUPPRESS_SYSTEM_EXCEPTION	#ifdef PA_SUPPRESS_SYSTEM_EXCEPTION
static const Exception call_real_parser_handler__do_PEH_return_it(const char* filespec_to_process) {	static const Exception call_real_parser_handler__do_PEH_return_it(bool cgi) {
try {	try {
real_parser_handler(filespec_to_process);	real_parser_handler(cgi);
} catch(const Exception& e) {	} catch(const Exception& e) {
return e;	return e;
}	}
Line 470 static const Exception call_real_parser_	Line 580 static const Exception call_real_parser_
return Exception();	return Exception();
}	}

static void call_real_parser_handler__supress_system_exception(const char* filespec_to_process) {	static void call_real_parser_handler__supress_system_exception(bool cgi) {
Exception parser_exception;	Exception parser_exception;
LPEXCEPTION_POINTERS system_exception=0;	LPEXCEPTION_POINTERS system_exception=0;

__try {	__try {
parser_exception=call_real_parser_handler__do_PEH_return_it(filespec_to_process);	parser_exception=call_real_parser_handler__do_PEH_return_it(cgi);
} __except ( (system_exception=GetExceptionInformation()), EXCEPTION_EXECUTE_HANDLER) {	} __except ( (system_exception=GetExceptionInformation()), EXCEPTION_EXECUTE_HANDLER) {
if(system_exception)	if(system_exception)
if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord)	if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord)
Line 498 static void call_real_parser_handler__su	Line 608 static void call_real_parser_handler__su
static void usage(const char* program) {	static void usage(const char* program) {
printf(	printf(
"Parser/%s\n"	"Parser/%s\n"
"Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com)\n"	"Copyright (c) 2001-2024 Art. Lebedev Studio (http://www.artlebedev.com)\n"
"Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)\n"	"Authors: Konstantin Morshnev <moko@design.ru>, Alexandr Petrosian <paf@design.ru>\n"
"\n"	"\n"
"Usage: %s [options] file\n"	"Usage: %s [options] [file]\n"
"Options are:\n"	"Options are:\n"
#ifdef WITH_MAILRECEIVE	#ifdef WITH_MAILRECEIVE
" -m Parse mail, put received letter to $mail:received\n"	" -m Parse mail, put received letter to $mail:received\n"
Line 517 static void usage(const char* program) {	Line 627 static void usage(const char* program) {

int main(int argc, char *argv[]) {	int main(int argc, char *argv[]) {
#ifdef PA_DEBUG_CGI_ENTRY_EXIT	#ifdef PA_DEBUG_CGI_ENTRY_EXIT
log("main: entry");	pa_log("main: entry");
#endif	#endif

argv_all=argv;	parser3_filespec = argc && argv[0] ? MAYBE_BACK_SLASHES_TO_SLASHES(argv[0]) : "parser3";
umask(2);	umask(2);

// were we started as CGI?	// were we started as CGI?
cgi=(getenv("SERVER_SOFTWARE") \|\| getenv("SERVER_NAME") \|\| getenv("GATEWAY_INTERFACE") \|\| getenv("REQUEST_METHOD")) && !getenv("PARSER_VERSION");	bool cgi=(getenv("SERVER_SOFTWARE") \|\| getenv("SERVER_NAME") \|\| getenv("GATEWAY_INTERFACE") \|\| getenv("REQUEST_METHOD")) && !getenv("PARSER_VERSION");
sapiInfo = cgi ? new SAPI_Info_CGI() : new SAPI_Info();	if(!cgi)
	sapi_info = &sapi_console;

#ifdef SIGUSR1
if(signal(SIGUSR1, SIGUSR1_handler)==SIG_ERR)
SAPI::die("Can not set handler for SIGUSR1");
#endif
#ifdef SIGPIPE	#ifdef SIGPIPE
if(signal(SIGPIPE, SIGPIPE_handler)==SIG_ERR)	signal(SIGPIPE, SIGPIPE_handler);
SAPI::die("Can not set handler for SIGPIPE");
#endif	#endif

char *raw_filespec_to_process = NULL;	char* raw_filespec_to_process = NULL;
if(cgi) {	if(cgi) {
raw_filespec_to_process=getenv("PATH_TRANSLATED");	raw_filespec_to_process=getenv("PATH_TRANSLATED");
if(raw_filespec_to_process && !*raw_filespec_to_process)	argv_extra=argv + 1;
raw_filespec_to_process=0;
} else {	} else {
int optind=1;	int optind=1;
while(optind < argc){	while(optind < argc){
char *carg = argv[optind];	char* carg = argv[optind];
if(carg[0] != '-')	if(carg[0] != '-')
break;	break;

Line 552 int main(int argc, char *argv[]) {	Line 657 int main(int argc, char *argv[]) {
char c = carg[k];	char c = carg[k];
switch (c) {	switch (c) {
case 'h':	case 'h':
usage(argv[0]);	usage(parser3_filespec);
break;	break;
case 'f':	case 'f':
if(optind < argc - 1){	if(optind < argc - 1){
optind++;	optind++;
config_filespec_cstr=argv[optind];	config_filespec=argv[optind];
	}
	break;
	case 'l':
	if(optind < argc - 1){
	optind++;
	log_filespec=argv[optind];
}	}
break;	break;
case 'p':	case 'p':
Line 572 int main(int argc, char *argv[]) {	Line 683 int main(int argc, char *argv[]) {
break;	break;
#endif	#endif
default:	default:
fprintf(stderr, "%s: invalid option '%c'\n", argv[0], c);	fprintf(stderr, "%s: invalid option '%c'\n", parser3_filespec, c);
usage(argv[0]);	usage(parser3_filespec);
break;	break;
}	}
}	}
Line 582 int main(int argc, char *argv[]) {	Line 693 int main(int argc, char *argv[]) {

if (optind > argc - 1) {	if (optind > argc - 1) {
if(!httpd_host_port) {	if(!httpd_host_port) {
fprintf(stderr, "%s: file not specified\n", argv[0]);	fprintf(stderr, "%s: file not specified\n", parser3_filespec);
usage(argv[0]);	usage(parser3_filespec);
}	}
} else {	} else {
raw_filespec_to_process=argv[optind];	raw_filespec_to_process=argv[optind];
}	}
args_skip=optind;

if (httpd_host_port && mail_received) {	if (httpd_host_port && mail_received) {
fprintf(stderr, "%s: -p and -m options should not be used together\n", argv[0]);	fprintf(stderr, "%s: -p and -m options should not be used together\n", parser3_filespec);
usage(argv[0]);	usage(parser3_filespec);
}	}

	argv_extra=argv + optind;
}	}

#ifdef _MSC_VER	#ifdef _MSC_VER
Line 616 int main(int argc, char *argv[]) {	Line 728 int main(int argc, char *argv[]) {
_CrtSetReportFile( _CRT_WARN, _CRTDBG_FILE_STDERR );	_CrtSetReportFile( _CRT_WARN, _CRTDBG_FILE_STDERR );
#endif	#endif

char filespec_to_process[MAX_STRING];
full_file_spec(raw_filespec_to_process, filespec_to_process, sizeof(filespec_to_process));

try { // global try	try { // global try
REAL_PARSER_HANDLER(filespec_to_process);	if(raw_filespec_to_process && *raw_filespec_to_process){
} catch(const Exception& e) { // exception in unhandled exception	filespec_to_process=full_disk_path(raw_filespec_to_process);
SAPI::die("%s", e.comment());	}

	REAL_PARSER_HANDLER(cgi);
	} catch(const Exception& e) { // exception in config_handler
	SAPI::log(*sapi_info, "%s", e.comment());
	SAPI::send_error(*sapi_info, e.comment(), strcmp(e.type(), "file.missing") ? "500" : "404");
}	}

#ifdef PA_DEBUG_CGI_ENTRY_EXIT	#ifdef PA_DEBUG_CGI_ENTRY_EXIT
log("main: successful return");	pa_log("main: successful return");
#endif	#endif
return sapiInfo->http_response_code < 100 ? sapiInfo->http_response_code : 0;	return sapi_info->http_response_code < 100 ? sapi_info->http_response_code : 0;
}	}

E-mail:

Removed from v.1.302
changed lines
	Added in v.1.363