|
|
| version 1.8, 2001/03/10 16:21:49 | version 1.257, 2003/11/20 16:39:49 |
|---|---|
| Line 1 | Line 1 |
| /* | /** @file |
| $Id$ | Parser: request class main part. @see compile.C and execute.C. |
| Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) | |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| */ | */ |
| static const char * const IDENT_REQUEST_C="$Date$"; | |
| #include "pa_sapi.h" | |
| #include "pa_common.h" | |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_wwrapper.h" | #include "pa_wwrapper.h" |
| #include "pa_common.h" | |
| #include "pa_vclass.h" | #include "pa_vclass.h" |
| #include "classes/_root.h" | #include "pa_globals.h" |
| #include "classes/_env.h" | #include "pa_vint.h" |
| #include "core.h" | #include "pa_vmethod_frame.h" |
| #include "pa_types.h" | |
| #include <stdio.h> | #include "pa_venv.h" |
| #include "pa_vmath.h" | |
| Request::Request(Pool& apool) : Pooled(apool), | #include "pa_vstatus.h" |
| stack(apool), | #include "pa_vrequest.h" |
| root_class(apool), | #include "pa_vtable.h" |
| env_class(apool), | #include "pa_vfile.h" |
| fclasses(apool), | #include "pa_dictionary.h" |
| fclasses_array(apool), | #include "pa_charset.h" |
| lang(String::Untaint_lang::HTML_TYPO) | #include "pa_charsets.h" |
| #include "pa_cache_managers.h" | |
| #include "pa_vmail.h" | |
| #include "pa_vform.h" | |
| #include "pa_vcookie.h" | |
| #include "pa_vresponse.h" | |
| #include "pa_vmemory.h" | |
| #include "pa_vconsole.h" | |
| // consts | |
| const char* UNHANDLED_EXCEPTION_METHOD_NAME="unhandled_exception"; | |
| /// content type of exception response, when no @MAIN:exception handler defined | |
| const char* UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; | |
| /// content type of response when no $MAIN:defaults.content-type defined | |
| const char* DEFAULT_CONTENT_TYPE="text/html"; | |
| const char* ORIGINS_CONTENT_TYPE="text/plain"; | |
| // defines for globals | |
| #define MAIN_METHOD_NAME "main" | |
| #define AUTO_METHOD_NAME "auto" | |
| #define BODY_NAME "body" | |
| #define EXCEPTION_TYPE_PART_NAME "type" | |
| #define EXCEPTION_SOURCE_PART_NAME "source" | |
| #define EXCEPTION_COMMENT_PART_NAME "comment" | |
| // globals | |
| const String main_method_name(MAIN_METHOD_NAME); | |
| const String auto_method_name(AUTO_METHOD_NAME); | |
| const String content_disposition_name(CONTENT_DISPOSITION_NAME); | |
| const String content_disposition_value(CONTENT_DISPOSITION_VALUE); | |
| const String content_disposition_filename_name(CONTENT_DISPOSITION_FILENAME_NAME); | |
| const String body_name(BODY_NAME); | |
| const String exception_type_part_name(EXCEPTION_TYPE_PART_NAME); | |
| const String exception_source_part_name(EXCEPTION_SOURCE_PART_NAME); | |
| const String exception_comment_part_name(EXCEPTION_COMMENT_PART_NAME); | |
| const String exception_handled_part_name(EXCEPTION_HANDLED_PART_NAME); | |
| // defines for statics | |
| #define CHARSETS_NAME "CHARSETS" | |
| #define MIME_TYPES_NAME "MIME-TYPES" | |
| #define ORIGINS_MODE_NAME "ORIGINS" | |
| #define CONF_METHOD_NAME "conf" | |
| #define POST_PROCESS_METHOD_NAME "postprocess" | |
| #define DOWNLOAD_NAME "download" | |
| #define CLASS_PATH_NAME "CLASS_PATH" | |
| // statics | |
| static const String charsets_name(CHARSETS_NAME); | |
| static const String main_class_name(MAIN_CLASS_NAME); | |
| static const String mime_types_name(MIME_TYPES_NAME); | |
| static const String origins_mode_name(ORIGINS_MODE_NAME); | |
| static const String conf_method_name(CONF_METHOD_NAME); | |
| static const String post_process_method_name(POST_PROCESS_METHOD_NAME); | |
| static const String download_name(DOWNLOAD_NAME); | |
| static const String class_path_name(CLASS_PATH_NAME); | |
| // defines | |
| // op.C | |
| VStateless_class& VClassMAIN_create(); | |
| // | |
| Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info, | |
| String::Language adefault_lang, bool status_allowed): | |
| // private | |
| anti_endless_execute_recoursion(0), | |
| // public | |
| method_frame(0), | |
| rcontext(0), | |
| wcontext(0), | |
| flang(adefault_lang), | |
| fconnection(0), | |
| finterrupted(false), | |
| // public | |
| #ifdef RESOURCES_DEBUG | |
| sql_connect_time(0), | |
| sql_request_time(0), | |
| #endif | |
| // public | |
| request_info(arequest_info), | |
| sapi_info(asapi_info), | |
| charsets(UTF8_charset, UTF8_charset, UTF8_charset), // default charsets | |
| main_class(VClassMAIN_create()), | |
| form(*new VForm), | |
| mail(*new VMail), | |
| response(*new VResponse(arequest_info, charsets)), | |
| cookie(*new VCookie), | |
| // private | |
| configure_admin_done(false), | |
| // private defaults | |
| fdefault_lang(adefault_lang), | |
| // private mime types | |
| mime_types(0) | |
| { | { |
| // root class | // file_no=0 => unknown |
| initialize_root_class(pool(), root_class); | file_list+=String::Body("UNKNOWN"); |
| // adding root superclass, | file_list+=String::Body("-body of process-"); // pseudo_file_no__process |
| // parent of all classes, | |
| // operators holder | // maybe expire old caches |
| classes().put(*root_class_name, &root_class); | cache_managers.maybe_expire(); |
| /// directly used | |
| // MAIN class, operators | |
| classes().put(main_class.name(), &main_class); | |
| // classes: | |
| // table, file, random, mail, image, ... | |
| methoded_array().register_directly_used(*this); | |
| /// methodless | |
| // env class | // env class |
| initialize_env_class(pool(), env_class); | classes().put(String::Body(ENV_CLASS_NAME), new VEnv(asapi_info)); |
| classes().put(*env_class_name, &env_class); | // status class |
| if(status_allowed) | |
| classes().put(String::Body(STATUS_CLASS_NAME), new VStatus()); | |
| // request class | |
| classes().put(String::Body(REQUEST_CLASS_NAME), new VRequest(arequest_info, charsets)); | |
| // cookie class | |
| classes().put(String::Body(COOKIE_CLASS_NAME), &cookie); | |
| // console class | |
| classes().put(String::Body(CONSOLE_CLASS_NAME), new VConsole()); | |
| /// methoded | |
| // response class | |
| classes().put(response.get_class()->name(), &response); | |
| /// bases used | |
| // form class | |
| classes().put(form.get_class()->base_class()->name(), &form); | |
| // mail class | |
| classes().put(mail.get_class()->base_class()->name(), &mail); | |
| // math class | |
| { | |
| Value& math=*new VMath; | |
| classes().put(math.get_class()->base_class()->name(), &math); | |
| } | |
| // memory class | |
| { | |
| Value& memory=*new VMemory; | |
| classes().put(memory.get_class()->base_class()->name(), &memory); | |
| } | |
| } | |
| Request::~Request() { | |
| #ifdef XML | |
| // if for some strange reason xml generic errors failed to be reported, free them up | |
| if(const char* xml_generic_errors=xmlGenericErrors()) { | |
| SAPI::log(sapi_info, "warning: unreported xmlGenericErrors: %s", xml_generic_errors); | |
| free((void *)xml_generic_errors); | |
| } | |
| #endif | |
| } | } |
| void Request::core() { | Value& Request::get_self() { return method_frame/*always have!*/->self(); } |
| TRY { | |
| // loading system auto.p | static void load_charset(HashStringValue::key_type akey, |
| char *sys_auto_file="C:\\temp\\auto.p"; | HashStringValue::value_type avalue, |
| VClass *sys_auto_class=use( | Request_charsets* charsets) { |
| sys_auto_file, | const String::Body NAME=String(akey, String::L_CLEAN).change_case(charsets->source(), String::CC_UPPER); |
| auto_class_name, 0, | ::charsets.load_charset(*charsets, NAME, avalue->as_string()); |
| false/*ignore possible error*/); | } |
| void Request::configure_admin(VStateless_class& conf_class) { | |
| // TODO: использовать AUTO:limits здесь, пока их не сломали враги | if(configure_admin_done) |
| throw Exception("parser.runtime", | |
| // TODO: load site auto.p files, all assigned bases from upper dir | 0, |
| char *site_auto_file="Y:\\parser3\\src\\auto.p"; | "parser already configured"); |
| VClass *site_auto_class=use( | configure_admin_done=true; |
| site_auto_file, | |
| auto_class_name, sys_auto_class, | // charsets must only be specified in method_frame config |
| false/*ignore possible error*/); | // so that users would not interfere |
| // there must be some auto.p | /* $MAIN:CHARSETS[ |
| if(!sys_auto_class && !site_auto_class) | $.charsetname1[/full/path/to/charset/file.cfg] |
| THROW(0,0, | ... |
| ] | |
| */ | |
| if(Value* vcharsets=conf_class.get_element(charsets_name, conf_class, false)) { | |
| if(!vcharsets->is_string()) | |
| if(HashStringValue* charsets=vcharsets->get_hash()) | |
| charsets->for_each(load_charset, &this->charsets); | |
| else | |
| throw Exception("parser.runtime", | |
| 0, | |
| "$" MAIN_CLASS_NAME ":" CHARSETS_NAME " must be hash"); | |
| } | |
| // configure method_frame options | |
| // until someone with less privileges have overriden them | |
| methoded_array().configure_admin(*this); | |
| } | |
| /** | |
| load MAIN class, execute @main. | |
| MAIN class consists of all the auto.p files we'd manage to find | |
| plus | |
| the file user requested us to process | |
| all located classes become children of one another, | |
| composing class we name 'MAIN' | |
| @test log stack trace | |
| */ | |
| void Request::core(const char* config_filespec, bool config_fail_on_read_problem, bool header_only) { | |
| #ifdef RESOURCES_DEBUG | |
| //measures | |
| struct timeval mt[10]; | |
| //measure:before all | |
| gettimeofday(&mt[0],NULL); | |
| #endif | |
| try { | |
| // loading config | |
| if(config_filespec) { | |
| const String& filespec=*new String(config_filespec); | |
| use_file(main_class, | |
| filespec, 0 /*main_alias*/, | |
| true /*ignore class_path*/, | |
| config_fail_on_read_problem, | |
| true /*file must exist if 'fail on read problem' not set*/); | |
| } | |
| // loading auto.p files from document_root/.. | |
| // to the one beside requested file. | |
| // all assigned bases from upper dir | |
| { | |
| const char* after=request_info.path_translated; | |
| size_t drlen=strlen(request_info.document_root); | |
| if(memcmp(after, request_info.document_root, drlen)==0) { | |
| after+=drlen; | |
| if(after[-1]=='/') | |
| --after; | |
| } | |
| while(const char* before=strchr(after, '/')) { | |
| String& sfile_spec=*new String; | |
| if(after!=request_info.path_translated) { | |
| sfile_spec.append_strdup( | |
| request_info.path_translated, before-request_info.path_translated, | |
| String::L_CLEAN); | |
| sfile_spec << "/" AUTO_FILE_NAME; | |
| use_file(main_class, | |
| sfile_spec, | |
| 0 /*main_alias*/, | |
| true /*ignore class_path*/, | |
| true /*fail on read problem*/, | |
| false /*but ignore absence, sole user*/); | |
| } | |
| after=before+1; | |
| } | |
| } | |
| // compile requested file | |
| String& spath_translated=*new String; | |
| spath_translated.append_help_length(request_info.path_translated, 0, String::L_TAINTED); | |
| use_file(main_class, | |
| spath_translated, | |
| 0 /*main_alias*/, | |
| true /*ignore class_path*/); | |
| // configure method_frame options if not configured yet | |
| if(!configure_admin_done) | |
| configure_admin(main_class); | |
| // configure not-method_frame=user options | |
| methoded_array().configure_user(*this); | |
| // $MAIN:MIME-TYPES | |
| if(Value* element=main_class.get_element(mime_types_name, main_class, false)) | |
| if(Table *table=element->get_table()) | |
| mime_types=table; | |
| // filling form fields | |
| form.fill_fields_and_tables(charsets, request_info); | |
| // filling cookies | |
| cookie.fill_fields(request_info); | |
| // filling mail received | |
| mail.fill_received(*this); | |
| #ifdef RESOURCES_DEBUG | |
| //measure:after compile | |
| gettimeofday(&mt[1],NULL); | |
| #endif | |
| // execute @main[] | |
| const String* body_string=execute_virtual_method(main_class, main_method_name); | |
| if(!body_string) | |
| throw Exception("parser.runtime", | |
| 0, | 0, |
| "'auto.p' not found"); | "'"MAIN_METHOD_NAME"' method not found"); |
| #ifdef RESOURCES_DEBUG | |
| //measure:after main | |
| gettimeofday(&mt[2],NULL); | |
| #endif | |
| // extract response body | |
| Value* body_value=response.fields().get(download_name); // $response:download? | |
| bool as_attachment=body_value!=0; | |
| if(!body_value) | |
| body_value=response.fields().get(body_name); // $response:body | |
| if(!body_value) | |
| body_value=new VString(*body_string); // just result of ^main[] | |
| // @postprocess | |
| if(Value* value=main_class.get_element(post_process_method_name, main_class, false)) | |
| if(Junction* junction=value->get_junction()) | |
| if(const Method *method=junction->method) { | |
| // preparing to pass parameters to | |
| // @postprocess[data] | |
| VMethodFrame frame(/*method->name, */ *junction, 0/*no parent*/); | |
| frame.set_self(main_class); | |
| frame.store_param(*body_value); | |
| body_value=&execute_method(frame, *method).as_value(); | |
| } | |
| VFile* body_file=body_value->as_vfile( | |
| String::L_UNSPECIFIED, &charsets); | |
| #ifdef RESOURCES_DEBUG | |
| //measure:after postprocess | |
| gettimeofday(&mt[3],NULL); | |
| #endif | |
| // OK. write out the result | |
| output_result(body_file, header_only, as_attachment); | |
| #ifdef RESOURCES_DEBUG | |
| //measure:after output_result | |
| gettimeofday(&mt[9],NULL); | |
| t[9]=mt[9].tv_sec+mt[9].tv_usec/1000000.0; | |
| double t[10]; | |
| for(int i=0;i<10;i++) | |
| t[i]=mt[i].tv_sec+mt[i].tv_usec/1000000.0; | |
| //measure:log2 compile,main,postprocess,output | |
| SAPI::log("rmeasure: %s,%.2f,%.2f,%.2f %.2f,%.2f %.2f", | |
| request_info.uri, | |
| t[1]-t[0], | |
| t[2]-t[1], | |
| t[3]-t[2], | |
| sql_connect_time,sql_request_time, | |
| t[9]-t[3] | |
| ); | |
| #endif | |
| } catch(const Exception& e) { // request handling problem | |
| // we're returning not result, but error explanation | |
| // try { | |
| #define PA_URI_FORMAT "%s: " | |
| #define PA_ORIGIN_FILE_POS_FORMAT "%s(%d:%d): " | |
| #define PA_SOURCE_FORMAT "'%s' " | |
| #define PA_COMMENT_TYPE_FORMAT "%s [%s]" | |
| // log the beast | |
| Request::Exception_details details=get_details(e); | |
| if(details.problem_source) { // do we know the guy? | |
| if(details.trace) { // do whe know where he came from? | |
| Operation::Origin origin=details.trace.origin(); | |
| SAPI::log(sapi_info, | |
| PA_URI_FORMAT | |
| PA_ORIGIN_FILE_POS_FORMAT | |
| PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT, | |
| request_info.uri, | |
| file_list[origin.file_no].cstr(), 1+origin.line, 1+origin.col, | |
| details.problem_source->cstr(), | |
| e.comment(), e.type() | |
| ); | |
| } else | |
| SAPI::log(sapi_info, | |
| PA_URI_FORMAT | |
| PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT, | |
| request_info.uri, | |
| details.problem_source->cstr(), | |
| e.comment(), e.type() | |
| ); | |
| } else | |
| SAPI::log(sapi_info, | |
| PA_URI_FORMAT | |
| PA_COMMENT_TYPE_FORMAT, | |
| request_info.uri, | |
| e.comment(), e.type() | |
| ); | |
| // reset language to default | |
| flang=fdefault_lang; | |
| // reset response | |
| response.fields().clear(); | |
| // this is what we'd return in $response:body | |
| const String* body_string=0; | |
| // maybe we'd be lucky enough as to report an error | |
| // in a gracefull way... | |
| if(Value* value=main_class.get_element( | |
| *new String(UNHANDLED_EXCEPTION_METHOD_NAME), | |
| main_class, | |
| false)) { | |
| if(Junction* junction=value->get_junction()) { | |
| if(const Method *method=junction->method) { | |
| // preparing to pass parameters to | |
| // @unhandled_exception[exception;stack] | |
| VMethodFrame frame(/*method->name, */ *junction, 0/*no caller*/); | |
| frame.set_self(main_class); | |
| // $exception | |
| frame.store_param(details.vhash); | |
| // $stack[^table::set{name origin}] | |
| Table::columns_type stack_trace_columns(new ArrayString); | |
| *stack_trace_columns+=new String("name"); | |
| *stack_trace_columns+=new String("file"); | |
| *stack_trace_columns+=new String("lineno"); | |
| *stack_trace_columns+=new String("colno"); | |
| Table& stack_trace=*new Table(stack_trace_columns); | |
| if(!exception_trace.is_empty()/*signed!*/) | |
| for(size_t i=exception_trace.bottom_index(); i<exception_trace.top_index(); i++) { | |
| Trace trace=exception_trace.get(i); | |
| Table::element_type row(new ArrayString); | |
| *row+=trace.name(); // name column | |
| Operation::Origin origin=trace.origin(); | |
| if(origin.file_no) { | |
| *row+=new String(file_list[origin.file_no], String::L_TAINTED); // 'file' column | |
| *row+=new String(String::Body::Format(1+origin.line), String::L_CLEAN); // 'lineno' column | |
| *row+=new String(String::Body::Format(1+origin.col), String::L_CLEAN); // 'colno' column | |
| } | |
| stack_trace+=row; | |
| } | |
| frame.store_param(*new VTable(&stack_trace)); | |
| // future $response:body= | |
| // execute ^unhandled_exception[exception;stack] | |
| body_string=&execute_method(frame, *method).as_string(); | |
| } | |
| } | |
| } | |
| if(!body_string) { // couldn't report an error beautifully? | |
| // doing that ugly | |
| // make up result: $origin $source $comment $type $code | |
| char *buf=new(PointerFreeGC) char[MAX_STRING]; | |
| size_t printed=0; | |
| if(const String* problem_source=e.problem_source()) | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", | |
| problem_source->cstr()); | |
| if(const char* comment=e.comment(true)) | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", comment); | |
| if(const char* type=e.type(true)) | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, " type: %s", type); | |
| // future $response:content-type | |
| response.fields().put(content_type_name, | |
| new VString(*new String(UNHANDLED_EXCEPTION_CONTENT_TYPE))); | |
| // future $response:body | |
| body_string=new String(buf); | |
| } | |
| VString body_vstring(*body_string); | |
| VFile* body_file=body_vstring.as_vfile(String::L_UNSPECIFIED, &charsets); | |
| // ERROR. write it out | |
| output_result(body_file, header_only, false); | |
| // } catch(const Exception& ) { | |
| // rethrow; | |
| // } | |
| } | |
| } | |
| size_t Request::register_file(String::Body file_spec) { | |
| file_list+=file_spec; | |
| return file_list.count()-1; | |
| } | |
| void Request::use_file(VStateless_class& aclass, | |
| const String& file_name, const String* main_alias, | |
| bool ignore_class_path, | |
| bool fail_on_read_problem, | |
| bool fail_on_file_absence) { | |
| // cyclic dependence check | |
| if(used_files.get(file_name)) | |
| return; | |
| used_files.put(file_name, true); | |
| const String* file_spec; | |
| if(ignore_class_path) // ignore_class_path? | |
| file_spec=&file_name; | |
| else if(file_name.first_char()=='/') //absolute path? [no need to scan MAIN:CLASS_PATH] | |
| file_spec=&absolute(file_name); | |
| else { | |
| file_spec=0; | |
| if(Value* element=main_class.get_element(class_path_name, main_class, false)) { | |
| if(element->is_string()) { | |
| file_spec=file_readable(absolute(element->as_string()), file_name); // found at class_path? | |
| } else if(Table *table=element->get_table()) { | |
| int size=table->count(); | |
| for(int i=size; i--; ) { | |
| const String& path=*(*table->get(i))[0]; | |
| if(file_spec=file_readable(absolute(path), file_name)) | |
| break; // found along class_path | |
| } | |
| } else | |
| throw Exception("parser.runtime", | |
| 0, | |
| "$" CLASS_PATH_NAME " must be string or table"); | |
| if(!file_spec) | |
| throw Exception("parser.runtime", | |
| &file_name, | |
| "not found along " MAIN_CLASS_NAME ":" CLASS_PATH_NAME); | |
| } | |
| if(!file_spec) | |
| throw Exception("parser.runtime", | |
| &file_name, | |
| "usage failed - no $" MAIN_CLASS_NAME ":" CLASS_PATH_NAME " were specified"); | |
| } | |
| if(fail_on_read_problem && !fail_on_file_absence) // ignore file absence if asked for | |
| if(!entry_exists(*file_spec)) | |
| return; | |
| if(const char* source=file_read_text(charsets, *file_spec, fail_on_read_problem)) | |
| use_buf(aclass, source, main_alias, register_file(*file_spec)); | |
| } | |
| // compiling requested file | |
| char *test_file="Y:\\parser3\\src\\test.p"; | void Request::use_buf(VStateless_class& aclass, |
| use(test_file, run_class_name); | const char* source, const String* main_alias, |
| uint file_no) { | |
| // executing some @main[] | // temporary zero @conf so to maybe-replace it in compiled code |
| char *result=execute_MAIN(); | Temp_method temp_method_conf(aclass, conf_method_name, 0); |
| printf("result-----------------\n%sEOF----------------\n", result); | // temporary zero @auto so to maybe-replace it in compiled code |
| } | Temp_method temp_method_auto(aclass, auto_method_name, 0); |
| CATCH(e) { | |
| printf("\nERROR: "); | |
| const String *problem_source=e.problem_source(); | |
| if(problem_source) { | |
| const Origin& origin=problem_source->origin(); | |
| if(origin.file) | |
| printf("%s(%d): ", | |
| origin.file, 1+origin.line); | |
| printf("'%s' ", | |
| problem_source->cstr()); | |
| } | |
| printf("%s", e.comment()); | |
| const String *type=e.type(); | |
| if(type) { | |
| printf(" type: %s", type->cstr()); | |
| const String *code=e.code(); | |
| if(code) | |
| printf(", code: %s", code->cstr()); | |
| } | |
| printf("\n"); | |
| } | |
| END_CATCH | |
| } | |
| VClass *Request::use(char *file, String *name, VClass *base_class, bool fail_on_read_problem) { | |
| // TODO: обнаружить|решить cyclic dependences | |
| char *source=file_read(pool(), file, fail_on_read_problem); | |
| if(!source) | |
| return 0; | |
| // compile loaded class | // compile loaded class |
| VClass& vclass=COMPILE(source, name, base_class, file); | VStateless_class& cclass=compile(&aclass, source, main_alias, file_no); |
| // locate and execute possible @conf[] static | |
| VString* vfilespec= | |
| new VString(*new String(file_list[file_no], String::L_TAINTED)); | |
| Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass, | |
| conf_method_name, vfilespec, | |
| false/*no string result needed*/); | |
| if(executed.method) | |
| configure_admin(cclass/*, executed.method->name*/); | |
| // locate and execute possible @auto[] static | |
| execute_nonvirtual_method(cclass, | |
| auto_method_name, vfilespec, | |
| false/*no result needed*/); | |
| } | |
| const String& Request::relative(const char* apath, const String& relative_name) { | |
| char *hpath=strdup(apath); | |
| String& result=*new String; | |
| if(rsplit(hpath, '/')) // if something/splitted | |
| result << hpath << "/"; | |
| result << relative_name; | |
| return result; | |
| } | |
| const String& Request::absolute(const String& relative_name) { | |
| if(relative_name.first_char()=='/') { | |
| String& result=*new String(strdup(request_info.document_root)); | |
| result << relative_name; | |
| return result; | |
| } else | |
| if(relative_name.pos("://")!=STRING_NOT_FOUND // something like "http://xxx" | |
| #ifdef WIN32 | |
| || relative_name.pos(":")==1 // DRIVE: | |
| || relative_name.starts_with("\\\\") // UNC1 | |
| || relative_name.starts_with("//") // UNC2 | |
| #endif | |
| ) | |
| return relative_name; | |
| else | |
| return relative(request_info.path_translated, relative_name); | |
| } | |
| static void add_header_attribute( | |
| HashStringValue::key_type aattribute, | |
| HashStringValue::value_type ameaning, | |
| Request *r) { | |
| if(aattribute==BODY_NAME | |
| || aattribute==DOWNLOAD_NAME | |
| || aattribute==CHARSET_NAME) | |
| return; | |
| SAPI::add_header_attribute(r->sapi_info, | |
| aattribute.cstr(), | |
| attributed_meaning_to_string(*ameaning, String::L_HTTP_HEADER, false). | |
| cstr(String::L_UNSPECIFIED)); | |
| } | |
| void Request::output_result(VFile* body_file, bool header_only, bool as_attachment) { | |
| // header: cookies | |
| cookie.output_result(sapi_info); | |
| Value* body_file_content_type; | |
| // set content-type | |
| if(body_file_content_type=body_file->fields().get(content_type_name)) { | |
| // body file content type | |
| response.fields().put(content_type_name, body_file_content_type); | |
| } else { | |
| // default content type | |
| response.fields().put_dont_replace(content_type_name, | |
| new VString(*new String(DEFAULT_CONTENT_TYPE))); | |
| } | |
| // content-disposition | |
| if(Value* vfile_name=body_file->fields().get(name_name)) | |
| if(*vfile_name->get_string()!=NONAME_DAT) { | |
| VHash& hash=*new VHash(); | |
| HashStringValue &h=hash.hash(); | |
| if(as_attachment) | |
| h.put(value_name, new VString(content_disposition_value)); | |
| h.put(content_disposition_filename_name, vfile_name); | |
| response.fields().put(content_disposition_name, &hash); | |
| } | |
| // prepare header: $response:fields without :body | |
| response.fields().for_each(add_header_attribute, this); | |
| // transcode text body when "text/*" or simple result | |
| if(body_file_content_type) | |
| if(HashStringValue *hash=body_file_content_type->get_hash()) | |
| body_file_content_type=hash->get(value_name); | |
| String::C output(body_file->value_ptr(), body_file->value_size()); | |
| if(!body_file_content_type/*vstring.as_vfile*/ || body_file_content_type->as_string().pos("text/")==0) | |
| output=Charset::transcode(output, | |
| charsets.source(), | |
| charsets.client()); | |
| // prepare header: content-length | |
| char content_length_cstr[MAX_NUMBER]; | |
| snprintf(content_length_cstr, MAX_NUMBER, "%u", output.length); | |
| SAPI::add_header_attribute(sapi_info, "content-length", content_length_cstr); | |
| // send header | |
| SAPI::send_header(sapi_info); | |
| // send body | |
| if(!header_only) | |
| SAPI::send_body(sapi_info, output.str, output.length); | |
| } | |
| const String& Request::mime_type_of(const char* user_file_name_cstr) { | |
| if(mime_types) | |
| if(const char* cext=strrchr(user_file_name_cstr, '.')) { | |
| String sext(++cext); | |
| Table::Action_options options; | |
| if(mime_types->locate(0, sext.change_case(charsets.source(), String::CC_LOWER), options)) | |
| if(const String* result=mime_types->item(1)) | |
| return *result; | |
| else | |
| throw Exception("parser.runtime", | |
| 0, | |
| MIME_TYPES_NAME " table column elements must not be empty"); | |
| } | |
| // locate and execute possible @auto[] static method | return *new String("application/octet-stream"); |
| execute_static_method(vclass, *auto_method_name, false /*no result needed*/); | |
| return &vclass; | |
| } | } |
| char *Request::execute_MAIN() { | #ifdef XML |
| // locate class with @main[] & execute it | GdomeDOMString_auto_ptr Request::transcode(const String& s) { |
| for(int i=classes_array().size(); --i>=0;) { | return charsets.source().transcode(s); |
| VClass *vclass=static_cast<VClass *>(classes_array().get(i)); | } |
| char *result=execute_static_method(*vclass, *main_method_name, true /*result needed*/); | |
| if(result) | GdomeDOMString_auto_ptr Request::transcode(const String::Body s) { |
| return result; | return charsets.source().transcode(s); |
| } | |
| const String& Request::transcode(GdomeDOMString* s) { | |
| return charsets.source().transcode(s); | |
| } | |
| const String& Request::transcode(xmlChar* s) { | |
| return charsets.source().transcode(s); | |
| } | |
| #endif | |
| const Request::Trace Request::Exception_trace::extract_origin(const String*& problem_source) { | |
| Trace result; | |
| if(!is_empty()) { | |
| result=bottom_value(); | |
| if(!problem_source) { // we don't know who trigged the bug? | |
| problem_source=result.name(); // consider the stack-top-guy did that | |
| fbottom++; | |
| } else if(result.name()==problem_source) // it is that same guy? | |
| fbottom++; // throw away that trace | |
| // else stack top contains not us, | |
| // leaving result intact | |
| // it would help ^throw | |
| } | } |
| return result; | |
| } | |
| Request::Exception_details Request::get_details(const Exception& e) { | |
| const String* problem_source=e.problem_source(); | |
| Trace trace=exception_trace.extract_origin(problem_source); | |
| THROW(0,0, | VHash& vhash=*new VHash; HashStringValue& hash=vhash.hash(); |
| 0, | |
| "'"MAIN_METHOD_NAME"' method not found"); | // $.type |
| return 0; | if(const char* type=e.type(true)) |
| hash.put(exception_type_part_name, new VString(*new String(type))); | |
| // $.source | |
| if(problem_source) { | |
| String& source=*new String; | |
| source.append(*problem_source, String::L_TAINTED, true/*forced*/); | |
| hash.put(exception_source_part_name, new VString(source)); | |
| } | |
| // $.file lineno colno | |
| if(trace) { | |
| const Operation::Origin origin=trace.origin(); | |
| hash.put(String::Body("file"), | |
| new VString(*new String(file_list[origin.file_no], String::L_TAINTED))); | |
| hash.put(String::Body("lineno"), new VInt(1+origin.line)); | |
| hash.put(String::Body("colno"), new VInt(1+origin.col)); | |
| } | |
| // $.comment | |
| if(const char* comment=e.comment(true)) | |
| hash.put(exception_comment_part_name, | |
| new VString(*new String(comment, 0, true/*tainted*/))); | |
| // $.handled(0) | |
| hash.put(exception_handled_part_name, new VBool(false)); | |
| return Request::Exception_details(trace, problem_source, vhash); | |
| } | } |