--- parser3/src/targets/isapi/parser3isapi.C 2003/11/21 09:38:14 1.85 +++ parser3/src/targets/isapi/parser3isapi.C 2026/04/25 13:38:46 1.136 @@ -1,11 +1,11 @@ /** @file Parser: IIS extension. - Copyright (c) 2000,2001-2003 ArtLebedev Group (http://www.artlebedev.com) - Author: Alexandr Petrosian (http://paf.design.ru) + Copyright (c) 2000-2026 Art. Lebedev Studio (https://www.artlebedev.com) + Authors: Konstantin Morshnev , Alexandr Petrosian */ -static const char * const IDENT_PARSER3ISAPI_C="$Date: 2003/11/21 09:38:14 $"; +volatile const char * IDENT_PARSER3ISAPI_C="$Id: parser3isapi.C,v 1.136 2026/04/25 13:38:46 moko Exp $"; #ifndef _MSC_VER # error compile ISAPI module with MSVC [no urge for now to make it autoconf-ed (PAF)] @@ -17,13 +17,19 @@ static const char * const IDENT_PARSER3I #include "pa_globals.h" #include "pa_request.h" #include "pa_version.h" -#include "pa_socks.h" #include #include #include +// defines + +#if defined(_MSC_VER) && !defined(_DEBUG) +# define PA_SUPPRESS_SYSTEM_EXCEPTION +#endif + + #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION") // consts @@ -34,12 +40,13 @@ const char* IIS51vars[]={ "CERT_COOKIE", "CERT_FLAGS", "CERT_ISSUER", "CERT_KEYSIZE", "CERT_SECRETKEYSIZE", "CERT_SERIALNUMBER", "CERT_SERVER_ISSUER", "CERT_SERVER_SUBJECT", "CERT_SUBJECT", "CONTENT_LENGTH", "CONTENT_TYPE", - "LOGON_USER", + "GATEWAY_INTERFACE", "HTTPS", "HTTPS_KEYSIZE", "HTTPS_SECRETKEYSIZE", "HTTPS_SERVER_ISSUER", "HTTPS_SERVER_SUBJECT", "INSTANCE_ID", "INSTANCE_META_PATH", + "LOCAL_ADDR", "LOGON_USER", "PATH_INFO", "PATH_TRANSLATED", "QUERY_STRING", - "REMOTE_ADDR", "REMOTE_HOST", "REMOTE_USER", "REQUEST_METHOD", + "REMOTE_ADDR", "REMOTE_HOST", "REMOTE_PORT", "REMOTE_USER", "REQUEST_METHOD", "SCRIPT_NAME", "SERVER_NAME", "SERVER_PORT", "SERVER_PORT_SECURE", "SERVER_PROTOCOL", "SERVER_SOFTWARE", "URL", @@ -49,6 +56,8 @@ const int IIS51var_count=sizeof(IIS51var // globals char argv0[MAX_STRING]=""; +const char* parser3_mode="isapi"; // $status:mode +const char *parser3_log_filespec(){ return ""; } // $status:log-filename // SAPI @@ -69,41 +78,38 @@ public: void SAPI::log(SAPI_Info& SAPI_info, const char* fmt, ...) { va_list args; va_start(args,fmt); - char buf[MAX_STRING]; + char buf[MAX_LOG_STRING]; const char* prefix="PARSER_ERROR:"; strcpy(buf, prefix); char *start=buf+strlen(prefix); - DWORD size=vsnprintf(start, MAX_STRING-strlen(prefix), fmt, args); - remove_crlf(start, start+size); + DWORD size=vsnprintf(start, MAX_LOG_STRING-strlen(prefix), fmt, args); + size=remove_crlf(start, start+size); - SAPI_info.lpECB->ServerSupportFunction(SAPI_info.lpECB->ConnID, - HSE_APPEND_LOG_PARAMETER, buf, &size, 0); + SAPI_info.lpECB->ServerSupportFunction(SAPI_info.lpECB->ConnID, HSE_APPEND_LOG_PARAMETER, buf, &size, 0); } /// @todo event log -static void abort(const char* fmt, va_list args) { +void SAPI::die(const char* fmt, ...) { + va_list args; + va_start(args, fmt); if(FILE *log=fopen("c:\\parser3die.log", "at")) { vfprintf(log, fmt, args); fclose(log); } - // exit & try to produce core dump + // abnormal exit abort(); -} -void SAPI::die(const char* fmt, ...) { - va_list args; - va_start(args, fmt); - ::abort(fmt, args); - va_end(args); +// va_end(args); } -void SAPI::abort(const char* fmt, ...) { - va_list args; - va_start(args, fmt); - ::abort(fmt, args); - va_end(args); +void SAPI::send_error(SAPI_Info& SAPI_info, const char *exception_cstr, const char *status){ + // capitalized headers passed for preventing malloc during capitalization + add_header_attribute(SAPI_info, HTTP_STATUS_CAPITALIZED, status); + add_header_attribute(SAPI_info, HTTP_CONTENT_TYPE_CAPITALIZED, "text/plain"); + send_headers(SAPI_info); + send_body(SAPI_info, exception_cstr, strlen(exception_cstr)); } -char* SAPI::get_env(SAPI_Info& SAPI_info, const char* name) { +char* SAPI::Env::get(SAPI_Info& SAPI_info, const char* name) { char *variable_buf=new(PointerFreeGC) char[MAX_STRING]; DWORD variable_len = MAX_STRING-1; @@ -128,6 +134,10 @@ char* SAPI::get_env(SAPI_Info& SAPI_info return 0; } +bool SAPI::Env::set(SAPI_Info&, const char*, const char*) { + return false; +} + static int grep_char(const char* s, char c) { int result=0; if(s) { @@ -138,35 +148,31 @@ static int grep_char(const char* s, char } return result; } -static const char* mk_env_pair(const char* key, const char* value) { - char *result=new(PointerFreeGC) char[strlen(key)+1/*=*/+strlen(value)+1/*0*/]; - strcpy(result, key); strcat(result, "="); strcat(result, value); - return result; -} -const char* const *SAPI::environment(SAPI_Info& info) { + +const char* const *SAPI::Env::get(SAPI_Info& info) { // we know this buf is writable - char* all_http_vars=SAPI::get_env(info, "ALL_HTTP"); + char* all_http_vars=SAPI::Env::get(info, "ALL_HTTP"); const int http_var_count=grep_char(all_http_vars, '\n')+1/*\n for theoretical(never saw) this \0*/; - - const char* *result=new const char*[IIS51var_count+http_var_count+1/*0*/]; + + const char* *result=new(PointerFreeGC) const char*[IIS51var_count+http_var_count+1/*0*/]; const char* *cur=result; // IIS5.1 vars for(int i=0; iWriteClient(SAPI_info.lpECB->ConnID, - const_cast(buf), &num_bytes, HSE_IO_SYNC); + if(!SAPI_info.lpECB->WriteClient(SAPI_info.lpECB->ConnID, + const_cast(buf), &num_bytes, HSE_IO_SYNC)) + return 0; + return (size_t)num_bytes; } @@ -257,28 +268,36 @@ static bool parser_init() { globals_inited=true; try { - // init socks - pa_init_socks(); - // init global variables + // init libraries pa_globals_init(); - // successful finish return true; - } catch(const Exception& e) { // global problem - //const char* body=e.comment(); - + } catch(.../*const Exception& e*/) { // global problem // unsuccessful finish return false; } } +static void parser_done() { + // finalize libraries + pa_globals_done(); +} + /// ISAPI // BOOL WINAPI GetExtensionVersion(HSE_VERSION_INFO *pVer) { pVer->dwExtensionVersion = HSE_VERSION; - strncpy(pVer->lpszExtensionDesc, "Parser "PARSER_VERSION, HSE_MAX_EXT_DLL_NAME_LEN-1); - pVer->lpszExtensionDesc[HSE_MAX_EXT_DLL_NAME_LEN-1]=0; + pa_strncpy(pVer->lpszExtensionDesc, "Parser " PARSER_VERSION, HSE_MAX_EXT_DLL_NAME_LEN); return parser_init(); } +// dwFlags & HSE_TERM_MUST_UNLOAD means we can't return false +BOOL WINAPI TerminateExtension( + DWORD /*dwFlags*/ +) +{ + parser_done(); + + return TRUE; +} /** ISAPI // main workhorse @@ -291,101 +310,87 @@ BOOL WINAPI GetExtensionVersion(HSE_VERS @test PARSER_VERSION from outside */ - void real_parser_handler(SAPI_Info& SAPI_info, bool header_only) { + // collect garbage from prev request + pa_gc_collect(); + SAPI_info.header=new String; LPEXTENSION_CONTROL_BLOCK lpECB=SAPI_info.lpECB; // Request info Request_info request_info; memset(&request_info, 0, sizeof(request_info)); - size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1; - char *filespec_to_process=pa_strdup(lpECB->lpszPathTranslated, path_translated_buf_size); + char *filespec_to_process=pa_strdup(lpECB->lpszPathTranslated); #ifdef WIN32 back_slashes_to_slashes(filespec_to_process); #endif - if(const char* path_info=SAPI::get_env(SAPI_info, "PATH_INFO")) { + if(const char* path_info=SAPI::Env::get(SAPI_info, "PATH_INFO")) { // IIS size_t len=strlen(filespec_to_process)-strlen(path_info); - char *buf=new(PointerFreeGC) char[len+1]; - strncpy(buf, filespec_to_process, len); buf[len]=0; + char *buf=new(PointerFreeGC) char[len]; + pa_strncpy(buf, filespec_to_process, len); request_info.document_root=buf; } else - throw Exception("parser.runtime", - 0, - "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)"); + throw Exception(PARSER_RUNTIME, 0, "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)"); request_info.path_translated=filespec_to_process; request_info.method=lpECB->lpszMethod; request_info.query_string=lpECB->lpszQueryString; - if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { - char *reconstructed_uri=new(PointerFreeGC) char[ - strlen(lpECB->lpszPathInfo)+1/*'?'*/+ - strlen(lpECB->lpszQueryString)+1/*0*/]; - strcpy(reconstructed_uri, lpECB->lpszPathInfo); - strcat(reconstructed_uri, "?"); - strcat(reconstructed_uri, lpECB->lpszQueryString); - request_info.uri=reconstructed_uri; - } else - request_info.uri=lpECB->lpszPathInfo; - + request_info.uri=lpECB->lpszQueryString && *lpECB->lpszQueryString ? pa_strcat(lpECB->lpszPathInfo, "?", lpECB->lpszQueryString) : lpECB->lpszPathInfo; request_info.content_type=lpECB->lpszContentType; request_info.content_length=lpECB->cbTotalBytes; - request_info.cookie=SAPI::get_env(SAPI_info, "HTTP_COOKIE"); + request_info.cookie=SAPI::Env::get(SAPI_info, "HTTP_COOKIE"); request_info.mail_received=false; // prepare to process request - Request request(SAPI_info, - request_info, - String::Language(String::L_HTML|String::L_OPTIMIZE_BIT), - true /* status_allowed */); + Request request(SAPI_info, request_info, String::Language(String::L_HTML|String::L_OPTIMIZE_BIT)); // beside by binary static char beside_binary_path[MAX_STRING]; - strncpy(beside_binary_path, argv0, MAX_STRING-1); beside_binary_path[MAX_STRING-1]=0; // filespec of my binary - if(!( - rsplit(beside_binary_path, '/') || - rsplit(beside_binary_path, '\\'))) { // strip filename + pa_strncpy(beside_binary_path, argv0, MAX_STRING); // filespec of my binary + if(!(rsplit(beside_binary_path, '/') || rsplit(beside_binary_path, '\\'))) { // strip filename // no path, just filename beside_binary_path[0]='.'; beside_binary_path[1]=0; - } + } char config_filespec[MAX_STRING]; - snprintf(config_filespec, MAX_STRING, - "%s/%s", - beside_binary_path, AUTO_FILE_NAME); - bool fail_on_config_read_problem=entry_exists(config_filespec); + snprintf(config_filespec, MAX_STRING, "%s/%s", beside_binary_path, AUTO_FILE_NAME); // process the request - request.core( - config_filespec, fail_on_config_read_problem, // /path/to/first/auto.p - header_only); + request.core(entry_exists(config_filespec) ? config_filespec : NULL, header_only); +} + +#ifdef PA_SUPPRESS_SYSTEM_EXCEPTION +static const Exception call_real_parser_handler__do_PEH_return_it(SAPI_Info& SAPI_info, bool header_only) { + try { + real_parser_handler(SAPI_info, header_only); + } catch(const Exception& e) { + return e; + } + + return Exception(); } -void call_real_parser_handler__do_SEH(SAPI_Info& SAPI_info, bool header_only) { -#if _MSC_VER & !defined(_DEBUG) +static void call_real_parser_handler__supress_system_exception(SAPI_Info& SAPI_info, bool header_only) { + Exception parser_exception; LPEXCEPTION_POINTERS system_exception=0; + __try { -#endif - real_parser_handler(SAPI_info, header_only); - -#if _MSC_VER & !defined(_DEBUG) - } __except ( - (system_exception=GetExceptionInformation()), - EXCEPTION_EXECUTE_HANDLER) { - + parser_exception=call_real_parser_handler__do_PEH_return_it(SAPI_info, header_only); + } __except ( (system_exception=GetExceptionInformation()), EXCEPTION_EXECUTE_HANDLER) { if(system_exception) if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord) - throw Exception(0, - 0, - "Exception 0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); + throw Exception("system", 0, "0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); else - throw Exception(0, 0, "Exception "); - else - throw Exception(0, 0, "Exception "); + throw Exception("system", 0, ""); + else + throw Exception("system", 0, ""); } -#endif + + if(parser_exception) + throw Exception(parser_exception); } +#endif DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { //_asm int 3; @@ -397,77 +402,34 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; try { // global try - call_real_parser_handler__do_SEH(SAPI_info, header_only); +#ifdef PA_SUPPRESS_SYSTEM_EXCEPTION + call_real_parser_handler__supress_system_exception( +#else + real_parser_handler( +#endif + SAPI_info, header_only); // successful finish - } catch(const Exception& e) { // global problem - // don't allocate anything on pool here: - // possible pool' exception not catch-ed now - // and there could be out-of-memory exception - const char* body=e.comment(); + } catch(const Exception& e) { // just in case // log it - SAPI::log(SAPI_info, "exception in request exception handler: %s", body); - - // - int content_length=strlen(body); - - // prepare header // not using SAPI func wich allocates on pool - char header_buf[MAX_STRING]; - int header_len=snprintf(header_buf, MAX_STRING, - "content-type: text/plain\r\n" - "content-length: %lu\r\n" -// "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" - "\r\n", - content_length); + SAPI::log(SAPI_info, "%s", e.comment()); HSE_SEND_HEADER_EX_INFO header_info; - header_info.pszStatus="200 OK"; + header_info.pszStatus="500 Internal Server Error"; header_info.cchStatus=strlen(header_info.pszStatus); - header_info.pszHeader=header_buf; - header_info.cchHeader=header_len; + header_info.pszHeader=HTTP_CONTENT_TYPE_CAPITALIZED ": text/plain\r\n\r\n"; + header_info.cchHeader=strlen(header_info.pszHeader); header_info.fKeepConn=true; // send header - lpECB->dwHttpStatusCode=200; - lpECB->ServerSupportFunction(lpECB->ConnID, - HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); + lpECB->dwHttpStatusCode=500; + lpECB->ServerSupportFunction(lpECB->ConnID, HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); // send body if(!header_only) - SAPI::send_body(SAPI_info, body, content_length); + SAPI::send_body(SAPI_info, e.comment(), strlen(e.comment())); // unsuccessful finish } -/* - const char* body="test"; - - // - int content_length=strlen(body); - - // prepare header // not using SAPI func wich allocates on pool - char header_buf[MAX_STRING]; - int header_len=snprintf(header_buf, MAX_STRING, - "content-type: text/plain\r\n" - "content-length: %lu\r\n" - "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" - "\r\n", - content_length); - HSE_SEND_HEADER_EX_INFO header_info; - header_info.pszStatus="200 OK"; - header_info.cchStatus=strlen(header_info.pszStatus); - header_info.pszHeader=header_buf; - header_info.cchHeader=header_len; - header_info.fKeepConn=true; - - // send header - lpECB->dwHttpStatusCode=200; - lpECB->ServerSupportFunction(lpECB->ConnID, - HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); - - // send body - DWORD num_bytes=content_length; - lpECB->WriteClient(lpECB->ConnID, - (void *)body, &num_bytes, HSE_IO_SYNC); -*/ return HSE_STATUS_SUCCESS_AND_KEEP_CONN; }