--- parser3/src/targets/isapi/parser3isapi.C 2001/03/23 10:27:34 1.9 +++ parser3/src/targets/isapi/parser3isapi.C 2026/04/25 13:38:46 1.136 @@ -1,70 +1,200 @@ +/** @file + Parser: IIS extension. + + Copyright (c) 2000-2026 Art. Lebedev Studio (https://www.artlebedev.com) + Authors: Konstantin Morshnev , Alexandr Petrosian +*/ + +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 +# error compile ISAPI module with MSVC [no urge for now to make it autoconf-ed (PAF)] #endif -#include -#include - -#include +#include "pa_config_includes.h" #include "pa_sapi.h" #include "pa_globals.h" #include "pa_request.h" #include "pa_version.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") -//@{ -/// SAPI funcs decl -struct sapi_func_context { +// consts + +const char* IIS51vars[]={ + "APPL_MD_PATH", "APPL_PHYSICAL_PATH", + "AUTH_PASSWORD", "AUTH_TYPE", "AUTH_USER", + "CERT_COOKIE", "CERT_FLAGS", "CERT_ISSUER", "CERT_KEYSIZE", "CERT_SECRETKEYSIZE", + "CERT_SERIALNUMBER", "CERT_SERVER_ISSUER", "CERT_SERVER_SUBJECT", "CERT_SUBJECT", + "CONTENT_LENGTH", "CONTENT_TYPE", + "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_PORT", "REMOTE_USER", "REQUEST_METHOD", + "SCRIPT_NAME", + "SERVER_NAME", "SERVER_PORT", "SERVER_PORT_SECURE", "SERVER_PROTOCOL", "SERVER_SOFTWARE", + "URL", +}; +const int IIS51var_count=sizeof(IIS51vars)/sizeof(*IIS51vars); + +// globals + +char argv0[MAX_STRING]=""; +const char* parser3_mode="isapi"; // $status:mode +const char *parser3_log_filespec(){ return ""; } // $status:log-filename + +// SAPI + +#ifndef DOXYGEN +/* + ISAPI SAPI functions receive this context information. + see Pool::set_context +*/ +class SAPI_Info { +public: LPEXTENSION_CONTROL_BLOCK lpECB; String *header; DWORD http_response_code; }; +#endif -const char *SAPI::get_env(Pool& pool, const char *name) { - sapi_func_context& ctx=*static_cast(pool.context()); +// goes to 'cs-uri-query' log file field. webmaster: switch it ON[default OFF]. +void SAPI::log(SAPI_Info& SAPI_info, const char* fmt, ...) { + va_list args; + va_start(args,fmt); + char buf[MAX_LOG_STRING]; + const char* prefix="PARSER_ERROR:"; + strcpy(buf, prefix); + char *start=buf+strlen(prefix); + DWORD size=vsnprintf(start, MAX_LOG_STRING-strlen(prefix), fmt, args); + size=remove_crlf(start, start+size); - char *variable_buf=(char *)pool.malloc(MAX_STRING); + SAPI_info.lpECB->ServerSupportFunction(SAPI_info.lpECB->ConnID, HSE_APPEND_LOG_PARAMETER, buf, &size, 0); +} + +/// @todo event log +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); + } + // abnormal exit + abort(); +// 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::Env::get(SAPI_Info& SAPI_info, const char* name) { + char *variable_buf=new(PointerFreeGC) char[MAX_STRING]; DWORD variable_len = MAX_STRING-1; - if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast(name), + if(SAPI_info.lpECB->GetServerVariable(SAPI_info.lpECB->ConnID, const_cast(name), variable_buf, &variable_len)) { - variable_buf[variable_len]=0; - return variable_buf; + if(*variable_buf) { // saw returning len=1 && *buf=0 :( + variable_buf[variable_len]=0; + return variable_buf; + } } else if (GetLastError()==ERROR_INSUFFICIENT_BUFFER) { - variable_buf=(char *)pool.malloc(variable_len+1); + variable_buf=new(PointerFreeGC) char[variable_len+1]; - if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast(name), + if(SAPI_info.lpECB->GetServerVariable(SAPI_info.lpECB->ConnID, const_cast(name), variable_buf, &variable_len)) { - variable_buf[variable_len]=0; - return variable_buf; + if(*variable_buf) { + variable_buf[variable_len]=0; + return variable_buf; + } } } return 0; } -uint SAPI::read_post(Pool& pool, char *buf, uint max_bytes) { - sapi_func_context& ctx=*static_cast(pool.context()); +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) { + while(s=strchr(s, c)) { + s++; // skip found c + result++; + } + } + return result; +} + +const char* const *SAPI::Env::get(SAPI_Info& info) { + // we know this buf is writable + 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(PointerFreeGC) const char*[IIS51var_count+http_var_count+1/*0*/]; + const char* *cur=result; + + // IIS5.1 vars + for(int i=0; icbAvailable, max_bytes); - memcpy(buf, ctx.lpECB->lpbData, read_from_buf); + read_from_buf=min(SAPI_info.lpECB->cbAvailable, max_bytes); + memcpy(buf, SAPI_info.lpECB->lpbData, read_from_buf); total_read+=read_from_buf; if(read_from_bufcbTotalBytes) { + read_from_bufcbTotalBytes) { DWORD cbRead=0, cbSize; read_from_input=min(max_bytes-read_from_buf, - ctx.lpECB->cbTotalBytes-read_from_buf); + SAPI_info.lpECB->cbTotalBytes-read_from_buf); while(cbRead < read_from_input) { cbSize=read_from_input - cbRead; - if(!ctx.lpECB->ReadClient(ctx.lpECB->ConnID, + if(!SAPI_info.lpECB->ReadClient(SAPI_info.lpECB->ConnID, buf+read_from_buf+cbRead, &cbSize) || cbSize==0) break; @@ -75,33 +205,22 @@ uint SAPI::read_post(Pool& pool, char *b return total_read; } -void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) { - sapi_func_context& ctx=*static_cast(pool.context()); - - if(strcasecmp(key, "location")==0) - ctx.http_response_code=302; - - if(strcasecmp(key, "status")==0) - ctx.http_response_code=atoi(value); - else { - ctx.header->APPEND_CONST(key); - ctx.header->APPEND_CONST(": "); - ctx.header->APPEND_CONST(value); - ctx.header->APPEND_CONST("\n"); - } +void SAPI::add_header_attribute(SAPI_Info& SAPI_info, const char* dont_store_key, const char* dont_store_value) { + if(strcasecmp(dont_store_key, "location")==0) + SAPI_info.http_response_code=302; + + if(strcasecmp(dont_store_key, HTTP_STATUS)==0) + SAPI_info.http_response_code=atoi(dont_store_value); + else + (*SAPI_info.header) << capitalize(dont_store_key) << ": " << pa_strdup(dont_store_value) << "\r\n"; } /// @todo intelligent cache-control -void SAPI::send_header(Pool& pool) { - sapi_func_context& ctx=*static_cast(pool.context()); - - ctx.header->APPEND_CONST( - "Expires: Fri, 23 Mar 2001 09:32:23 GMT\n" - "\n"); +void SAPI::send_headers(SAPI_Info& SAPI_info) { HSE_SEND_HEADER_EX_INFO header_info; char status_buf[MAX_STATUS_LENGTH]; - switch(ctx.http_response_code) { + switch(SAPI_info.http_response_code) { case 200: header_info.pszStatus="200 OK"; break; @@ -113,55 +232,70 @@ void SAPI::send_header(Pool& pool) { break; default: snprintf(status_buf, MAX_STATUS_LENGTH, - "%d Undescribed", ctx.http_response_code); + "%d Undescribed", SAPI_info.http_response_code); header_info.pszStatus=status_buf; break; } header_info.cchStatus=strlen(header_info.pszStatus); - header_info.pszHeader=ctx.header->cstr(); - header_info.cchHeader=ctx.header->size(); + *SAPI_info.header << "\r\n"; // ISAPI v<5 did quite well without it + header_info.pszHeader=SAPI_info.header->cstr(); + header_info.cchHeader=SAPI_info.header->length(); header_info.fKeepConn=true; - ctx.lpECB->dwHttpStatusCode=ctx.http_response_code; + SAPI_info.lpECB->dwHttpStatusCode=SAPI_info.http_response_code; - ctx.lpECB->ServerSupportFunction(ctx.lpECB->ConnID, + SAPI_info.lpECB->ServerSupportFunction(SAPI_info.lpECB->ConnID, HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); } -void SAPI::send_body(Pool& pool, const char *buf, size_t size) { - sapi_func_context& ctx=*static_cast(pool.context()); +void SAPI::clear_headers(SAPI_Info& SAPI_info) { + SAPI_info.header=new String; +} +size_t SAPI::send_body(SAPI_Info& SAPI_info, const void *buf, size_t size) { DWORD num_bytes=size; - ctx.lpECB->WriteClient(ctx.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; } -//@} -// -static void parser_init() { +static bool parser_init() { static bool globals_inited=false; if(globals_inited) - return; + return true; globals_inited=true; - static Pool pool; // global pool - PTRY { - // init global variables - pa_globals_init(pool); - - //... - } PCATCH(e) { // global problem - const char *body=e.comment(); - // TODO: somehow report that error + try { + // init libraries + pa_globals_init(); + // successful finish + return true; + } catch(.../*const Exception& e*/) { // global problem + // unsuccessful finish + return false; } - PEND_CATCH +} + +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); + 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; } @@ -169,111 +303,147 @@ BOOL WINAPI GetExtensionVersion(HSE_VERS ISAPI // main workhorse @todo - think of a better way than @c APPL_PHYSICAL_PATH - of obtaining the @c DOCUMENT_ROOT - because this only gets "the place where last IIS Application was set" - and if someone would redefine Application settings below the / - all ^table:load[/test] would open not /test but /below/test + IIS: remove trailing default-document[index.html] from $request.uri. + to do that we need to consult metabase, + wich is tested&works but seems slow runtime + and not could-be-quickly-implemented if prepared. + @test + PARSER_VERSION from outside */ -DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { - Pool pool; +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)); + + char *filespec_to_process=pa_strdup(lpECB->lpszPathTranslated); +#ifdef WIN32 + back_slashes_to_slashes(filespec_to_process); +#endif + + 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]; + 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)"); + + request_info.path_translated=filespec_to_process; + request_info.method=lpECB->lpszMethod; + request_info.query_string=lpECB->lpszQueryString; + 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::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)); + + // beside by binary + static char beside_binary_path[MAX_STRING]; + 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); + + // process the request + 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(); +} + +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 { + 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("system", 0, "0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); + else + throw Exception("system", 0, ""); + else + throw Exception("system", 0, ""); + } + + if(parser_exception) + throw Exception(parser_exception); +} +#endif + +DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { + //_asm int 3; + SAPI_Info SAPI_info={ + lpECB, + 0, // filling later: so that if there would be error pool would have SAPI_info + 200 // default http_response_code [lpECB->dwHttpStatusCode seems to be always 0, even on 404 redirect to /404.html] + }; + bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; - PTRY { // global try - sapi_func_context ctx={ - lpECB, - new(pool) String(pool), - 200 - }; - pool.set_context(&ctx); - - // Request info - Request::Info request_info; - - if(!(request_info.document_root=SAPI::get_env(pool, "APPL_PHYSICAL_PATH"))) - PTHROW(0, 0, - 0, - "can not get server variable APPL_PHYSICAL_PATH (error #%lu)", - GetLastError()); // never - - request_info.path_translated=lpECB->lpszPathTranslated; - request_info.method=lpECB->lpszMethod; - request_info.query_string=lpECB->lpszQueryString; - if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { - char *reconstructed_uri=(char *)malloc( - 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.content_type=lpECB->lpszContentType; - request_info.content_length=lpECB->cbTotalBytes; - request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); - - // prepare to process request - Request request(pool, - request_info, - String::UL_HTML_TYPO - ); - - // some root-controlled location - // c:\windows - // must be dynamic: rethrowing from request.core - // may return 'source' which can be inside of 'root auto.p@exeception' - char *root_auto_path=(char *)pool.malloc(MAX_STRING); - GetWindowsDirectory(root_auto_path, MAX_STRING); - - // process the request - request.core( - root_auto_path, false/*may be abcent*/, // /path/to/admin/auto.p - 0/*parser_site_auto_path*/, false, // /path/to/site/auto.p - header_only); - + try { // global try +#ifdef PA_SUPPRESS_SYSTEM_EXCEPTION + call_real_parser_handler__supress_system_exception( +#else + real_parser_handler( +#endif + SAPI_info, header_only); // successful finish - } PCATCH(e) { // global problem - const char *body=e.comment(); - int content_length=strlen(body); - - // prepare header - SAPI::add_header_attribute(pool, "content-type", "text/plain"); - char content_length_cstr[MAX_NUMBER]; - snprintf(content_length_cstr, MAX_NUMBER, "%lu", content_length); - SAPI::add_header_attribute(pool, "content-length", content_length_cstr); - + } catch(const Exception& e) { // just in case + // log it + SAPI::log(SAPI_info, "%s", e.comment()); + + HSE_SEND_HEADER_EX_INFO header_info; + header_info.pszStatus="500 Internal Server Error"; + header_info.cchStatus=strlen(header_info.pszStatus); + 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 - SAPI::send_header(pool); + 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(pool, body, content_length); + SAPI::send_body(SAPI_info, e.comment(), strlen(e.comment())); // unsuccessful finish - _endthread(); } - PEND_CATCH - return HSE_STATUS_SUCCESS_AND_KEEP_CONN; } +BOOL WINAPI DllMain( + HINSTANCE hinstDLL, // handle to the DLL module + DWORD /*fdwReason*/, // reason for calling function + LPVOID /*lpvReserved*/ // reserved + ) { + + GetModuleFileName( + hinstDLL, // handle to module + argv0, // file name of module + sizeof(argv0) // size of buffer + ); -BOOL APIENTRY DllMain(HANDLE hModule, - DWORD ul_reason_for_call, - LPVOID lpReserved - ) { - switch (ul_reason_for_call) { - case DLL_PROCESS_ATTACH: - parser_init(); - break; - case DLL_THREAD_ATTACH: - break; - case DLL_THREAD_DETACH: - break; - case DLL_PROCESS_DETACH: - break; - } - return TRUE; -} + return TRUE; +} \ No newline at end of file