--- parser3/src/targets/isapi/parser3isapi.C 2001/03/22 16:38:23 1.2 +++ parser3/src/targets/isapi/parser3isapi.C 2001/03/23 14:03:29 1.12 @@ -1,14 +1,13 @@ #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 -#include +#include "pa_sapi.h" #include "pa_globals.h" #include "pa_request.h" #include "pa_version.h" @@ -16,49 +15,57 @@ #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION") //@{ -/// service func decl -static const char *get_env(Pool& pool, const char *name) { - LPEXTENSION_CONTROL_BLOCK lpECB=static_cast(pool.context()); +/// SAPI funcs decl +struct sapi_func_context { + LPEXTENSION_CONTROL_BLOCK lpECB; + String *header; + DWORD http_response_code; +}; + +const char *SAPI::get_env(Pool& pool, const char *name) { + sapi_func_context& ctx=*static_cast(pool.context()); char *variable_buf=(char *)pool.malloc(MAX_STRING); DWORD variable_len = MAX_STRING-1; - if(lpECB->GetServerVariable(lpECB->ConnID, const_cast(name), - variable_buf, &variable_len)) { - variable_buf[variable_len]=0; - return variable_buf; - } - - variable_buf=(char *)pool.malloc(variable_len+1); - - if(lpECB->GetServerVariable(lpECB->ConnID, const_cast(name), + if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast(name), variable_buf, &variable_len)) { variable_buf[variable_len]=0; return variable_buf; + } else if (GetLastError()==ERROR_INSUFFICIENT_BUFFER) { + variable_buf=(char *)pool.malloc(variable_len+1); + + if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast(name), + variable_buf, &variable_len)) { + variable_buf[variable_len]=0; + return variable_buf; + } } - + return 0; } -static uint read_post(Pool& pool, char *buf, uint max_bytes) { - LPEXTENSION_CONTROL_BLOCK lpECB=static_cast(pool.context()); +uint SAPI::read_post(Pool& pool, char *buf, uint max_bytes) { + sapi_func_context& ctx=*static_cast(pool.context()); DWORD read_from_buf=0; DWORD read_from_input=0; DWORD total_read=0; - read_from_buf=min(lpECB->cbAvailable, max_bytes); - memcpy(buf, lpECB->lpbData, read_from_buf); + read_from_buf=min(ctx.lpECB->cbAvailable, max_bytes); + memcpy(buf, ctx.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, lpECB->cbTotalBytes-read_from_buf); + read_from_input=min(max_bytes-read_from_buf, + ctx.lpECB->cbTotalBytes-read_from_buf); while(cbRead < read_from_input) { cbSize=read_from_input - cbRead; - if(!lpECB->ReadClient(lpECB->ConnID, buf+read_from_buf+cbRead, &cbSize) || + if(!ctx.lpECB->ReadClient(ctx.lpECB->ConnID, + buf+read_from_buf+cbRead, &cbSize) || cbSize==0) break; cbRead+=cbSize; @@ -68,72 +75,68 @@ static uint read_post(Pool& pool, char * return total_read; } -static void add_header_attribute(Pool& pool, const char *key, const char *value) { - LPEXTENSION_CONTROL_BLOCK lpECB=static_cast(pool.context()); - String *header=static_cast(pool.tag()); - if(!header) - pool.set_tag(header=new(pool) String(pool)); - - header->APPEND_CONST(key); - header->APPEND_CONST(": "); - header->APPEND_CONST(value); - header->APPEND_CONST("\r\n"); -} +void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) { + sapi_func_context& ctx=*static_cast(pool.context()); -static void send_header(Pool& pool) { - LPEXTENSION_CONTROL_BLOCK lpECB=static_cast(pool.context()); - String *header=static_cast(pool.tag()); - if(!header) // never - return; + if(strcasecmp(key, "location")==0) + ctx.http_response_code=302; - header->APPEND_CONST("\r\n"); - HSE_SEND_HEADER_EX_INFO header_info; + 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"); + } +} - int http_response_code=200; // todo: dig from headers +/// @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"); + HSE_SEND_HEADER_EX_INFO header_info; char status_buf[MAX_STATUS_LENGTH]; - switch(http_response_code) { + switch(ctx.http_response_code) { case 200: header_info.pszStatus="200 OK"; break; case 302: header_info.pszStatus="302 Moved Temporarily"; break; - case 401: + case 401:// useless untill parser auth mech header_info.pszStatus="401 Authorization Required"; break; default: - snprintf(status_buf, MAX_STATUS_LENGTH, "%d Undescribed", http_response_code); + snprintf(status_buf, MAX_STATUS_LENGTH, + "%d Undescribed", ctx.http_response_code); header_info.pszStatus=status_buf; break; } header_info.cchStatus=strlen(header_info.pszStatus); - header_info.pszHeader=header->cstr(); - header_info.cchHeader=header->size(); + header_info.pszHeader=ctx.header->cstr(); + header_info.cchHeader=ctx.header->size(); + header_info.fKeepConn=true; - lpECB->dwHttpStatusCode=http_response_code; + ctx.lpECB->dwHttpStatusCode=ctx.http_response_code; - lpECB->ServerSupportFunction(lpECB->ConnID, HSE_REQ_SEND_RESPONSE_HEADER_EX, - &header_info, NULL, NULL); + ctx.lpECB->ServerSupportFunction(ctx.lpECB->ConnID, + HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); } -static void send_body(Pool& pool, const char *buf, size_t size) { - LPEXTENSION_CONTROL_BLOCK lpECB=static_cast(pool.context()); +void SAPI::send_body(Pool& pool, const char *buf, size_t size) { + sapi_func_context& ctx=*static_cast(pool.context()); DWORD num_bytes=size; - lpECB->WriteClient(lpECB->ConnID, const_cast(buf), &num_bytes, HSE_IO_SYNC); + ctx.lpECB->WriteClient(ctx.lpECB->ConnID, + const_cast(buf), &num_bytes, HSE_IO_SYNC); } //@} -/// Service funcs -Service_funcs service_funcs={ - get_env, - read_post, - add_header_attribute, - send_header, - send_body -}; - // static void parser_init() { @@ -145,7 +148,7 @@ static void parser_init() { static Pool pool; // global pool PTRY { // init global variables - globals_init(pool); + pa_globals_init(pool); //... } PCATCH(e) { // global problem @@ -162,64 +165,61 @@ BOOL WINAPI GetExtensionVersion(HSE_VERS return TRUE; } -/// ISAPI // main workhorse +/** + ISAPI // main workhorse + + @todo + 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. +*/ DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { Pool pool; - pool.set_context(lpECB); - - // TODO r->no_cache=1; bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; PTRY { // global try - // must be first in PTRY{}PCATCH - - const char *filespec_to_process=lpECB->lpszPathTranslated; + sapi_func_context ctx={ + lpECB, + 0, // filling later: so that if there would be error pool would have ctx + 200 + }; + pool.set_context(&ctx); + ctx.header=new(pool) String(pool); // Request info Request::Info request_info; - const char *document_root=0; // todo: get from somewhere? - 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; + const char *filespec_to_process=lpECB->lpszPathTranslated; + if(const char *path_info=SAPI::get_env(pool, "PATH_INFO")) { + // IIS + size_t len=strlen(filespec_to_process)-strlen(path_info); + char *buf=(char *)pool.malloc(len+1); + strncpy(buf, filespec_to_process, len); + buf[len]=0; + request_info.document_root=buf; + } else + PTHROW(0, 0, + 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; - char reconstructed_uri[MAX_STRING]; if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { - strncpy(reconstructed_uri, lpECB->lpszPathInfo, - MAX_STRING-1/*'?'*/-strlen(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->lpszPathInfo); + 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; - // cookie - char cookie_buf[MAX_STRING]; - { - DWORD cookie_len = MAX_STRING-1; - - if (lpECB->GetServerVariable(lpECB->ConnID, "HTTP_COOKIE", cookie_buf, &cookie_len)) { - cookie_buf[cookie_len]=0; - request_info.cookie=cookie_buf; - } else if (GetLastError()==ERROR_INSUFFICIENT_BUFFER) { - char *tmp_cookie_buf=(char *)pool.malloc(cookie_len+1); - - if (lpECB->GetServerVariable(lpECB->ConnID, "HTTP_COOKIE", tmp_cookie_buf, &cookie_len)) { - tmp_cookie_buf[cookie_len]=0; - request_info.cookie=tmp_cookie_buf; - } else { - request_info.cookie=0; - } - } - } + request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); // prepare to process request Request request(pool, @@ -228,16 +228,12 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI ); // some root-controlled location - char *root_auto_path; - // c:\windows - root_auto_path=(char *)pool.malloc(MAX_STRING); + // 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); -/* - char *fuck_it="fff"; - DWORD num_bytes=strlen(fuck_it);; - lpECB->WriteClient(lpECB->ConnID, fuck_it, &num_bytes, HSE_IO_SYNC); - return HSE_STATUS_SUCCESS; -*/ + // process the request request.core( root_auto_path, false/*may be abcent*/, // /path/to/admin/auto.p @@ -245,30 +241,43 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI header_only); // successful finish - } PCATCH(e) { // global problem + } PCATCH(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(); int content_length=strlen(body); - // prepare header - (*service_funcs.add_header_attribute)(pool, "content-type", "text/plain"); - char content_length_cstr[MAX_NUMBER]; - snprintf(content_length_cstr, MAX_NUMBER, "%d", content_length); - (*service_funcs.add_header_attribute)(pool, "content-length", - content_length_cstr); - + // 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\n" + "content-length: %ul\n" + "expires: Fri, 23 Mar 2001 09:32:23 GMT\n" + "\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 - (*service_funcs.send_header)(pool); + lpECB->dwHttpStatusCode=200; + lpECB->ServerSupportFunction(lpECB->ConnID, + HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); // send body if(!header_only) - (*service_funcs.send_body)(pool, body, content_length); + SAPI::send_body(pool, body, content_length); // unsuccessful finish - _endthread(); } PEND_CATCH - return HSE_STATUS_SUCCESS; + return HSE_STATUS_SUCCESS_AND_KEEP_CONN; }