|
|
| version 1.296, 2008/06/11 11:38:41 | version 1.380, 2020/10/12 20:57:08 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: request class main part. @see compile.C and execute.C. | Parser: request class main part. @see compile.C and execute.C. |
| Copyright (c) 2001-2005 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| */ | */ |
| static const char * const IDENT_REQUEST_C="$Date$"; | |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_os.h" | |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_wwrapper.h" | #include "pa_wwrapper.h" |
| #include "pa_vclass.h" | #include "pa_vclass.h" |
| #include "pa_globals.h" | #include "pa_globals.h" |
| #include "pa_vint.h" | #include "pa_vint.h" |
| #include "pa_vmethod_frame_global.h" | #include "pa_vmethod_frame.h" |
| #include "pa_types.h" | #include "pa_types.h" |
| #include "pa_venv.h" | #include "pa_venv.h" |
| #include "pa_vmath.h" | #include "pa_vmath.h" |
| Line 34 static const char * const IDENT_REQUEST_ | Line 33 static const char * const IDENT_REQUEST_ |
| #include "pa_vconsole.h" | #include "pa_vconsole.h" |
| #include "pa_vdate.h" | #include "pa_vdate.h" |
| volatile const char * IDENT_PA_REQUEST_C="$Id$" IDENT_PA_REQUEST_H IDENT_PA_REQUEST_CHARSETS_H IDENT_PA_REQUEST_INFO_H IDENT_PA_VCONSOLE_H; | |
| // consts | // consts |
| #define UNHANDLED_EXCEPTION_METHOD_NAME "unhandled_exception" | #define UNHANDLED_EXCEPTION_METHOD_NAME "unhandled_exception" |
| Line 43 const char* UNHANDLED_EXCEPTION_CONTENT_ | Line 44 const char* UNHANDLED_EXCEPTION_CONTENT_ |
| /// content type of response when no $MAIN:defaults.content-type defined | /// content type of response when no $MAIN:defaults.content-type defined |
| const char* DEFAULT_CONTENT_TYPE="text/html"; | const char* DEFAULT_CONTENT_TYPE="text/html"; |
| const char* ORIGINS_CONTENT_TYPE="text/plain"; | |
| const uint LOOP_LIMIT=20000; | |
| const uint EXECUTE_RECOURSION_LIMIT=1000; | |
| const size_t FILE_SIZE_LIMIT=512*1024*1024; | |
| // defines for globals | // defines for globals |
| #define MAIN_METHOD_NAME "main" | #define MAIN_METHOD_NAME "main" |
| #define AUTO_METHOD_NAME "auto" | #define AUTO_METHOD_NAME "auto" |
| #define BODY_NAME "body" | #define USE_METHOD_NAME "use" |
| #define AUTOUSE_METHOD_NAME "autouse" | |
| #define EXCEPTION_TYPE_PART_NAME "type" | #define EXCEPTION_TYPE_PART_NAME "type" |
| #define EXCEPTION_SOURCE_PART_NAME "source" | #define EXCEPTION_SOURCE_PART_NAME "source" |
| #define EXCEPTION_COMMENT_PART_NAME "comment" | #define EXCEPTION_COMMENT_PART_NAME "comment" |
| #define ORIGIN_KEY "origin" | |
| // globals | // globals |
| const String main_method_name(MAIN_METHOD_NAME); | const String main_method_name(MAIN_METHOD_NAME); |
| const String auto_method_name(AUTO_METHOD_NAME); | const String auto_method_name(AUTO_METHOD_NAME); |
| const String content_transfer_encoding_name(CONTENT_TRANSFER_ENCODING_NAME); | static const String use_method_name(USE_METHOD_NAME); |
| const String content_disposition_name(CONTENT_DISPOSITION_NAME); | static const String autouse_method_name(AUTOUSE_METHOD_NAME); |
| const String content_disposition_inline(CONTENT_DISPOSITION_INLINE); | |
| const String content_disposition_attachment(CONTENT_DISPOSITION_ATTACHMENT); | |
| 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_type_part_name(EXCEPTION_TYPE_PART_NAME); |
| const String exception_source_part_name(EXCEPTION_SOURCE_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_comment_part_name(EXCEPTION_COMMENT_PART_NAME); |
| const String exception_handled_part_name(EXCEPTION_HANDLED_PART_NAME); | const String exception_handled_part_name(EXCEPTION_HANDLED_PART_NAME); |
| static const String origin_key(ORIGIN_KEY); | |
| int pa_loop_limit=LOOP_LIMIT; | |
| int pa_execute_recoursion_limit=EXECUTE_RECOURSION_LIMIT; | |
| size_t pa_file_size_limit=FILE_SIZE_LIMIT; | |
| // defines for statics | // defines for statics |
| #define CHARSETS_NAME "CHARSETS" | #define CHARSETS_NAME "CHARSETS" |
| #define MIME_TYPES_NAME "MIME-TYPES" | #define MIME_TYPES_NAME "MIME-TYPES" |
| #define ORIGINS_MODE_NAME "ORIGINS" | #define STRICT_VARS_NAME "STRICT-VARS" |
| #define PROTOTYPE_NAME "OBJECT-PROTOTYPE" | |
| #define LIMITS_NAME "LIMITS" | |
| #define LOOP_LIMIT_NAME "max_loop" | |
| #define RECOURSION_LIMIT_NAME "max_recoursion" | |
| #define FILE_SIZE_LIMIT_NAME "max_file_size" | |
| #define LOCK_WAIT_TIMEOUT_NAME "lock_wait_timeout" | |
| #define CONF_METHOD_NAME "conf" | #define CONF_METHOD_NAME "conf" |
| #define POST_PROCESS_METHOD_NAME "postprocess" | #define POST_PROCESS_METHOD_NAME "postprocess" |
| #define DOWNLOAD_NAME "download" | |
| #define CLASS_PATH_NAME "CLASS_PATH" | #define CLASS_PATH_NAME "CLASS_PATH" |
| #define RESPONSE_BODY_FILE_NAME "file" | #define RESPONSE_BODY_FILE_NAME "file" |
| #define DOWNLOAD_NAME_UPPER "DOWNLOAD" | |
| #define BODY_NAME_UPPER "BODY" | |
| // statics | // statics |
| static const String charsets_name(CHARSETS_NAME); | static const String charsets_name(CHARSETS_NAME); |
| static const String main_class_name(MAIN_CLASS_NAME); | static const String main_class_name(MAIN_CLASS_NAME); |
| static const String mime_types_name(MIME_TYPES_NAME); | static const String mime_types_name(MIME_TYPES_NAME); |
| static const String origins_mode_name(ORIGINS_MODE_NAME); | static const String strict_vars_name(STRICT_VARS_NAME); |
| static const String prototype_name(PROTOTYPE_NAME); | |
| static const String limits_name(LIMITS_NAME); | |
| static const String loop_limit_name(LOOP_LIMIT_NAME); | |
| static const String recoursion_limit_name(RECOURSION_LIMIT_NAME); | |
| static const String file_size_limit_name(FILE_SIZE_LIMIT_NAME); | |
| static const String lock_wait_timeout_name(LOCK_WAIT_TIMEOUT_NAME); | |
| static const String conf_method_name(CONF_METHOD_NAME); | static const String conf_method_name(CONF_METHOD_NAME); |
| static const String post_process_method_name(POST_PROCESS_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); | static const String class_path_name(CLASS_PATH_NAME); |
| static const String response_body_file_name(RESPONSE_BODY_FILE_NAME); | static const String response_body_file_name(RESPONSE_BODY_FILE_NAME); |
| static const String download_name_upper(DOWNLOAD_NAME_UPPER); | |
| static const String body_name_upper(BODY_NAME_UPPER); | |
| // more static | |
| static const String content_type_name_upper(HTTP_CONTENT_TYPE_UPPER); | |
| static const String content_disposition_name_upper(CONTENT_DISPOSITION_UPPER); | |
| static const String content_disposition_inline(CONTENT_DISPOSITION_INLINE); | |
| static const String content_disposition_attachment(CONTENT_DISPOSITION_ATTACHMENT); | |
| // defines | // defines |
| #define CHARSET_NAME_UPPER "CHARSET" | |
| #define LAST_MODIFIED_NAME_UPPER "LAST-MODIFIED" | |
| // op.C | // op.C |
| VStateless_class& VClassMAIN_create(); | VStateless_class& VClassMAIN_create(); |
| // | // |
| Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info, | Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info, |
| String::Language adefault_lang, bool status_allowed): | String::Language adefault_lang): |
| // private | // private |
| anti_endless_execute_recoursion(0), | anti_endless_execute_recoursion(0), |
| // public | // public |
| allow_class_replace(false), | |
| method_frame(0), | method_frame(0), |
| rcontext(0), | rcontext(0), |
| wcontext(0), | wcontext(0), |
| flang(adefault_lang), | flang(adefault_lang), |
| fconnection(0), | fconnection(0), |
| finterrupted(false),fskip(SKIP_NOTHING), | fin_cycle(0), |
| fskip(SKIP_NOTHING), | |
| // public | |
| #ifdef RESOURCES_DEBUG | |
| sql_connect_time(0), | |
| sql_request_time(0), | |
| #endif | |
| // public | // public |
| request_info(arequest_info), | request_info(arequest_info), |
| sapi_info(asapi_info), | sapi_info(asapi_info), |
| charsets(UTF8_charset, UTF8_charset, UTF8_charset), // default charsets | charsets(pa_UTF8_charset, pa_UTF8_charset, pa_UTF8_charset), // default charsets |
| main_class(VClassMAIN_create()), | main_class(VClassMAIN_create()), |
| form(*new VForm(charsets, arequest_info)), | form(*new VForm(charsets, arequest_info)), |
| mail(*new VMail), | mail(*new VMail), |
| response(*new VResponse(arequest_info, charsets)), | response(*new VResponse(arequest_info, charsets)), |
| cookie(*new VCookie), | cookie(*new VCookie(charsets, arequest_info)), |
| console(*new VConsole), | console(*new VConsole), |
| // private | // private |
| Line 140 Request::Request(SAPI_Info& asapi_info, | Line 174 Request::Request(SAPI_Info& asapi_info, |
| pa_register_thread_request(*this); | pa_register_thread_request(*this); |
| // file_no=0 => unknown | // file_no=0 => unknown |
| file_list+=String::Body("UNKNOWN"); | file_list+="UNKNOWN"; |
| file_list+=String::Body("-body of process-"); // pseudo_file_no__process | file_list+="-body of process-"; // pseudo_file_no__process |
| // maybe expire old caches | // maybe expire old caches |
| cache_managers->maybe_expire(); | cache_managers->maybe_expire(); |
| /// directly used | /// directly used |
| // MAIN class, operators | // MAIN class, operators |
| classes().put(main_class.name(), &main_class); | put_class(&main_class); |
| // classes: | // classes: |
| // table, file, random, mail, image, ... | // table, file, random, mail, image, ... |
| methoded_array().register_directly_used(*this); | methoded_array().register_directly_used(*this); |
| /// methodless | /// methodless |
| // env class | // env class |
| classes().put(String::Body(ENV_CLASS_NAME), new VEnv(asapi_info)); | put_class(new VEnv(asapi_info)); |
| // status class | // status class |
| if(status_allowed) | put_class(new VStatus()); |
| classes().put(String::Body(STATUS_CLASS_NAME), new VStatus()); | |
| // request class | // request class |
| classes().put(String::Body(REQUEST_CLASS_NAME), new VRequest(arequest_info, charsets, form)); | put_class(new VRequest(arequest_info, charsets, form, asapi_info)); |
| // cookie class | // cookie class |
| classes().put(String::Body(COOKIE_CLASS_NAME), &cookie); | put_class(&cookie); |
| // console class | // console class |
| classes().put(String::Body(CONSOLE_CLASS_NAME), &console); | put_class(&console); |
| /// methoded | /// methoded |
| // response class | |
| classes().put(response.get_class()->name(), &response); | |
| /// bases used | // response class |
| put_class(&response); | |
| // form class | // form class |
| classes().put(form.get_class()->base_class()->name(), &form); | put_class(&form); |
| // mail class | // mail class |
| classes().put(mail.get_class()->base_class()->name(), &mail); | put_class(&mail); |
| // math class | // math class |
| { | put_class(new VMath); |
| Value& math=*new VMath; | |
| classes().put(math.get_class()->base_class()->name(), &math); | |
| } | |
| // memory class | // memory class |
| { | put_class(new VMemory); |
| Value& memory=*new VMemory; | |
| classes().put(memory.get_class()->base_class()->name(), &memory); | |
| } | |
| } | } |
| Request::~Request() { | Request::~Request() { |
| Line 191 Request::~Request() { | Line 219 Request::~Request() { |
| // if for some strange reason xml generic errors failed to be reported, free them up | // if for some strange reason xml generic errors failed to be reported, free them up |
| if(const char* xml_generic_errors=xmlGenericErrors()) { | if(const char* xml_generic_errors=xmlGenericErrors()) { |
| SAPI::log(sapi_info, "warning: unreported xmlGenericErrors: %s", xml_generic_errors); | SAPI::log(sapi_info, "warning: unreported xmlGenericErrors: %s", xml_generic_errors); |
| free((void *)xml_generic_errors); | pa_free((void *)xml_generic_errors); |
| } | } |
| #endif | #endif |
| } | } |
| Value& Request::get_self() { return method_frame/*always have!*/->self(); } | Value& Request::get_self() { return method_frame/*always have!*/->self(); } |
| static void load_charset(HashStringValue::key_type akey, | VStateless_class* Request::get_class(const String& name){ |
| HashStringValue::value_type avalue, | VStateless_class* result=classes().get(name); |
| Request_charsets* charsets) { | if(!result) |
| const String::Body NAME=String(akey, String::L_CLEAN).change_case(charsets->source(), String::CC_UPPER); | if(const Method *method=main_class.get_element_method(autouse_method_name)){ |
| ::charsets.load_charset(*charsets, NAME, avalue->as_string()); | Value *vname=new VString(name); |
| CONSTRUCTOR_FRAME_ACTION(*method, 0 /*no parent*/, main_class, { | |
| frame.store_params(&vname, 1); | |
| // we don't need the result | |
| call(frame); | |
| }); | |
| result=classes().get(name); | |
| } | |
| return result; | |
| } | |
| static void load_charset(HashStringValue::key_type akey, HashStringValue::value_type avalue, Request_charsets* charsets) { | |
| pa_charsets.load_charset(*charsets, akey, avalue->as_string()); | |
| } | } |
| void Request::configure_admin(VStateless_class& conf_class) { | void Request::configure_admin(VStateless_class& conf_class) { |
| if(configure_admin_done) | if(configure_admin_done) |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, "parser already configured"); |
| 0, | |
| "parser already configured"); | |
| configure_admin_done=true; | configure_admin_done=true; |
| // charsets must only be specified in method_frame config | // charsets must only be specified in method_frame config |
| Line 219 void Request::configure_admin(VStateless | Line 258 void Request::configure_admin(VStateless |
| ... | ... |
| ] | ] |
| */ | */ |
| if(Value* vcharsets=conf_class.get_element(charsets_name, conf_class, false)) { | if(Value* vcharsets=conf_class.get_element(charsets_name)) { |
| if(!vcharsets->is_string()) | if(!vcharsets->is_string()) { |
| if(HashStringValue* charsets=vcharsets->get_hash()) | if(HashStringValue* charsets=vcharsets->get_hash()) |
| charsets->for_each<Request_charsets*>(load_charset, &this->charsets); | charsets->for_each<Request_charsets*>(load_charset, &this->charsets); |
| else | else |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":" CHARSETS_NAME " must be hash"); |
| 0, | } |
| "$" MAIN_CLASS_NAME ":" CHARSETS_NAME " must be hash"); | } |
| #ifdef STRICT_VARS | |
| VVoid::strict_vars=false; | |
| if(Value* strict_vars=conf_class.get_element(strict_vars_name)) { | |
| if(strict_vars->is_bool()) | |
| VVoid::strict_vars=strict_vars->as_bool(); | |
| else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":" STRICT_VARS_NAME " must be bool"); | |
| } | } |
| #endif | |
| #ifdef OBJECT_PROTOTYPE | |
| VClass::prototype=true; | |
| if(Value* prototype=conf_class.get_element(prototype_name)) { | |
| if(prototype->is_bool()) | |
| VClass::prototype=prototype->as_bool(); | |
| else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":" PROTOTYPE_NAME " must be bool"); | |
| } | |
| #endif | |
| Value* limits=conf_class.get_element(limits_name); | |
| pa_loop_limit=LOOP_LIMIT; | |
| if(limits) | |
| if(Value* loop_limit=limits->get_element(loop_limit_name)) { | |
| if(loop_limit->is_evaluated_expr()) { | |
| pa_loop_limit=loop_limit->as_int(); | |
| if(pa_loop_limit==0) pa_loop_limit=INT_MAX; | |
| } else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." LOOP_LIMIT_NAME " must be int"); | |
| } | |
| pa_execute_recoursion_limit=EXECUTE_RECOURSION_LIMIT; | |
| if(limits) | |
| if(Value* recoursion_limit=limits->get_element(recoursion_limit_name)) { | |
| if(recoursion_limit->is_evaluated_expr()) { | |
| pa_execute_recoursion_limit=recoursion_limit->as_int(); | |
| if(pa_execute_recoursion_limit==0) pa_execute_recoursion_limit=INT_MAX; | |
| } else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." RECOURSION_LIMIT_NAME " must be int"); | |
| } | |
| pa_file_size_limit=FILE_SIZE_LIMIT; | |
| if(limits) | |
| if(Value* file_size_limit=limits->get_element(file_size_limit_name)) { | |
| if(file_size_limit->is_evaluated_expr()) { | |
| double limit=file_size_limit->as_double(); | |
| if(limit >= (double)SSIZE_MAX) | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." FILE_SIZE_LIMIT_NAME " must be less then %.15g", (double)SSIZE_MAX); | |
| pa_file_size_limit=(size_t)limit; | |
| if(pa_file_size_limit==0) pa_file_size_limit=SSIZE_MAX; | |
| } else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." FILE_SIZE_LIMIT_NAME " must be number"); | |
| } | |
| pa_lock_attempts=PA_LOCK_ATTEMPTS; | |
| if(limits) | |
| if(Value* lock_wait_timeout=limits->get_element(lock_wait_timeout_name)) { | |
| if(lock_wait_timeout->is_evaluated_expr()) { | |
| double limit=lock_wait_timeout->as_double(); | |
| if(limit >= 3600*24) | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." LOCK_WAIT_TIMEOUT_NAME " must be less then %d", 3600*24); | |
| pa_lock_attempts=(unsigned int)(limit*2)+1; | |
| } else | |
| throw Exception(PARSER_RUNTIME, 0, "$" MAIN_CLASS_NAME ":LIMITS." LOCK_WAIT_TIMEOUT_NAME " must be number"); | |
| } | |
| // configure method_frame options | // configure method_frame options |
| // until someone with less privileges have overriden them | // until someone with less privileges have overriden them |
| methoded_array().configure_admin(*this); | methoded_array().configure_admin(*this); |
| } | } |
| const char* Request::get_exception_cstr( | const char* Request::get_exception_cstr(const Exception& e, Request::Exception_details& details) { |
| const Exception& e, | |
| Request::Exception_details& details) { | |
| #define PA_URI_FORMAT "%s: " | #define PA_URI_FORMAT "%s: " |
| #define PA_COMMENT_TYPE_FORMAT "%s [%s]" | |
| #define PA_ORIGIN_FILE_POS_FORMAT "%s(%d:%d): " | #define PA_ORIGIN_FILE_POS_FORMAT "%s(%d:%d): " |
| #define PA_SOURCE_FORMAT "'%s' " | #define PA_SOURCE_FORMAT "'%s' " |
| #define PA_COMMENT_TYPE_FORMAT "%s [%s]" | |
| #define PA_ORIGIN_FILE_POS_VALUE file_list[details.origin.file_no].cstr(), 1+details.origin.line, 1+details.origin.col, | |
| #define PA_SOURCE_VALUE details.problem_source->cstr(), | |
| #define EXCEPTION_CSTR(f1,v1,f2,v2) \ | |
| snprintf(result, MAX_STRING, \ | |
| PA_URI_FORMAT \ | |
| f1 f2 \ | |
| PA_COMMENT_TYPE_FORMAT, \ | |
| request_info.uri, \ | |
| v1 v2 \ | |
| e.comment(), e.type() \ | |
| ); | |
| char* result=new(PointerFreeGC) char[MAX_STRING]; | char* result=new(PointerFreeGC) char[MAX_STRING]; |
| if(details.problem_source) { // do we know the guy? | if(details.problem_source) { // do we know the guy? |
| if(details.trace) { // do whe know where he came from? | if(details.origin.file_no) // do whe know where he came from? |
| Operation::Origin origin=details.trace.origin(); | EXCEPTION_CSTR(PA_ORIGIN_FILE_POS_FORMAT, PA_ORIGIN_FILE_POS_VALUE, PA_SOURCE_FORMAT, PA_SOURCE_VALUE) |
| snprintf(result, MAX_STRING, | else |
| PA_URI_FORMAT | EXCEPTION_CSTR(PA_SOURCE_FORMAT, PA_SOURCE_VALUE,,) |
| PA_ORIGIN_FILE_POS_FORMAT | } else { |
| PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT, | if(details.origin.file_no) // do whe know where he came from? |
| request_info.uri, | EXCEPTION_CSTR(PA_ORIGIN_FILE_POS_FORMAT, PA_ORIGIN_FILE_POS_VALUE,,) |
| file_list[origin.file_no].cstr(), 1+origin.line, 1+origin.col, | else |
| details.problem_source->cstr(), | EXCEPTION_CSTR(,,,) |
| e.comment(), e.type() | } |
| ); | |
| } else | |
| snprintf(result, MAX_STRING, | |
| PA_URI_FORMAT | |
| PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT, | |
| request_info.uri, | |
| details.problem_source->cstr(), | |
| e.comment(), e.type() | |
| ); | |
| } else | |
| snprintf(result, MAX_STRING, | |
| PA_URI_FORMAT | |
| PA_COMMENT_TYPE_FORMAT, | |
| request_info.uri, | |
| e.comment(), e.type() | |
| ); | |
| return result; | return result; |
| } | } |
| Line 283 void Request::configure() { | Line 386 void Request::configure() { |
| methoded_array().configure_user(*this); | methoded_array().configure_user(*this); |
| // $MAIN:MIME-TYPES | // $MAIN:MIME-TYPES |
| if(Value* element=main_class.get_element(mime_types_name, main_class, false)) | if(Value* element=main_class.get_element(mime_types_name)) |
| if(Table *table=element->get_table()) | if(Table *table=element->get_table()) |
| mime_types=table; | mime_types=table; |
| } | } |
| Line 299 void Request::configure() { | Line 402 void Request::configure() { |
| */ | */ |
| void Request::core(const char* config_filespec, bool config_fail_on_read_problem, bool header_only) { | 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 { | try { |
| // filling cookies | |
| cookie.fill_fields(request_info); | |
| // filling mail received | |
| mail.fill_received(*this); | |
| // loading config | // loading config |
| if(config_filespec) { | if(config_filespec) { |
| const String& filespec=*new String(config_filespec); | const String& filespec=*new String(config_filespec); |
| use_file(main_class, | use_file_directly(main_class, filespec, config_fail_on_read_problem, true /*file must exist if 'fail on read problem' not set*/); |
| filespec, 0 /*main_alias*/, | |
| true /*ignore class_path*/, | |
| config_fail_on_read_problem, | |
| true /*file must exist if 'fail on read problem' not set*/); | |
| } | } |
| // filling mail received | |
| mail.fill_received(*this); | |
| // loading auto.p files from document_root/.. | // loading auto.p files from document_root/.. |
| // to the one beside requested file. | // to the one beside requested file. |
| // all assigned bases from upper dir | // all assigned bases from upper dir |
| Line 337 gettimeofday(&mt[0],NULL); | Line 427 gettimeofday(&mt[0],NULL); |
| while(const char* before=strchr(after, '/')) { | while(const char* before=strchr(after, '/')) { |
| String& sfile_spec=*new String; | String& sfile_spec=*new String; |
| if(after!=request_info.path_translated) { | if(after!=request_info.path_translated) { |
| sfile_spec.append_strdup( | sfile_spec.append_strdup(request_info.path_translated, before-request_info.path_translated, String::L_CLEAN); |
| request_info.path_translated, before-request_info.path_translated, | |
| String::L_CLEAN); | |
| sfile_spec << "/" AUTO_FILE_NAME; | sfile_spec << "/" AUTO_FILE_NAME; |
| use_file(main_class, | use_file_directly(main_class, sfile_spec, true /*fail on read problem*/, false /*but ignore absence, sole user*/); |
| sfile_spec, | |
| 0 /*main_alias*/, | |
| true /*ignore class_path*/, | |
| true /*fail on read problem*/, | |
| false /*but ignore absence, sole user*/); | |
| } | } |
| after=before+1; | for(after=before+1;*after=='/';after++); |
| } | } |
| } | } |
| Line 357 gettimeofday(&mt[0],NULL); | Line 440 gettimeofday(&mt[0],NULL); |
| // compile requested file | // compile requested file |
| String& spath_translated=*new String; | String& spath_translated=*new String; |
| spath_translated.append_help_length(request_info.path_translated, 0, String::L_TAINTED); | spath_translated.append_help_length(request_info.path_translated, 0, String::L_TAINTED); |
| use_file(main_class, | use_file_directly(main_class, spath_translated); |
| spath_translated, | |
| 0 /*main_alias*/, | |
| true /*ignore class_path*/); | |
| configure(); | configure(); |
| } catch(...) { | } catch(...) { |
| Line 368 gettimeofday(&mt[0],NULL); | Line 448 gettimeofday(&mt[0],NULL); |
| rethrow; | rethrow; |
| } | } |
| #ifdef RESOURCES_DEBUG | |
| //measure:after compile | |
| gettimeofday(&mt[1],NULL); | |
| #endif | |
| // execute @main[] | // execute @main[] |
| const String* body_string=execute_virtual_method(main_class, main_method_name); | const String* body_string=execute_virtual_method(main_class, main_method_name); |
| if(!body_string) | if(!body_string) |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, "'" MAIN_METHOD_NAME "' method not found"); |
| 0, | |
| "'"MAIN_METHOD_NAME"' method not found"); | |
| #ifdef RESOURCES_DEBUG | |
| //measure:after main | |
| gettimeofday(&mt[2],NULL); | |
| #endif | |
| // extract response body | // extract response body |
| Value* body_value=response.fields().get(download_name); // $response:download? | Value* body_value=response.fields().get(download_name_upper); // $response:download? |
| bool as_attachment=body_value!=0; | bool as_attachment=body_value!=0; |
| if(!body_value) | if(!body_value) |
| body_value=response.fields().get(body_name); // $response:body | body_value=response.fields().get(body_name_upper); // $response:body |
| if(!body_value) | if(!body_value) |
| body_value=new VString(*body_string); // just result of ^main[] | body_value=new VString(*body_string); // just result of ^main[] |
| // ensure that body_value has no just L_TAINTED parts left | |
| if(body_value->is_string()) | |
| { | |
| String& untainted=*new String(); | |
| untainted.append(*body_value->get_string(), flang); | |
| body_value=new VString(untainted); | |
| } | |
| // @postprocess | // @postprocess |
| if(Value* value=main_class.get_element(post_process_method_name, main_class, false)) | if(Value* value=main_class.get_element(post_process_method_name)) |
| if(Junction* junction=value->get_junction()) | if(Junction* junction=value->get_junction()) |
| if(const Method *method=junction->method) { | if(const Method *method=junction->method) { |
| // preparing to pass parameters to | // preparing to pass parameters to |
| // @postprocess[data] | // @postprocess[data] |
| VMethodFrameGlobal frame(/*method->name, */ *junction, 0/*no parent*/); | METHOD_FRAME_ACTION(*method, 0 /*no parent*/, main_class, { |
| frame.set_self(main_class); | frame.store_params(&body_value, 1); |
| call(frame); | |
| frame.store_param(*body_value); | body_value=&frame.result(); |
| body_value=&execute_method(frame, *method).as_value(); | }); |
| } | } |
| VFile* body_file=body_value->as_vfile( | VFile* body_file=body_value->as_vfile(flang, &charsets); |
| String::L_UNSPECIFIED, &charsets); | |
| #ifdef RESOURCES_DEBUG | |
| //measure:after postprocess | |
| gettimeofday(&mt[3],NULL); | |
| #endif | |
| // OK. write out the result | // OK. write out the result |
| output_result(body_file, header_only, as_attachment); | 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 | } catch(const Exception& e) { // request handling problem |
| try { | try { |
| // we're returning not result, but error explanation | // we're returning not result, but error explanation |
| Line 459 t[9]-t[3] | Line 497 t[9]-t[3] |
| // maybe we'd be lucky enough as to report an error | // maybe we'd be lucky enough as to report an error |
| // in a gracefull way... | // in a gracefull way... |
| if(Value* value=main_class.get_element( | if(Value* value=main_class.get_element(*new String(UNHANDLED_EXCEPTION_METHOD_NAME))) { |
| *new String(UNHANDLED_EXCEPTION_METHOD_NAME), | |
| main_class, | |
| false)) { | |
| if(Junction* junction=value->get_junction()) { | if(Junction* junction=value->get_junction()) { |
| if(const Method *method=junction->method) { | if(const Method *method=junction->method) { |
| // preparing to pass parameters to | // preparing to pass parameters to |
| // @unhandled_exception[exception;stack] | // @unhandled_exception[exception;stack] |
| VMethodFrameGlobal frame(/*method->name, */ *junction, 0/*no caller*/); | |
| frame.set_self(main_class); | |
| // $exception | |
| frame.store_param(details.vhash); | |
| // $stack[^table::create{name file lineno colno}] | // $stack[^table::create{name file lineno colno}] |
| Table::columns_type stack_trace_columns(new ArrayString); | Table::columns_type stack_trace_columns(new ArrayString); |
| *stack_trace_columns+=new String("name"); | *stack_trace_columns+=new String("name"); |
| Line 494 t[9]-t[3] | Line 525 t[9]-t[3] |
| stack_trace+=row; | stack_trace+=row; |
| } | } |
| frame.store_param(*new VTable(&stack_trace)); | |
| // future $response:body= | // future $response:body= |
| // execute ^unhandled_exception[exception;stack] | // execute ^unhandled_exception[exception;stack] |
| exception_trace.clear(); // forget all about previous life, in case there would be error inside of this method, error handled would not be mislead by old stack contents (see extract_origin) | exception_trace.clear(); // forget all about previous life, in case there would be error inside of this method, error handled would not be mislead by old stack contents (see extract_origin) |
| body_string=&execute_method(frame, *method).as_string(); | |
| Value *params[]={&details.vhash, new VTable(&stack_trace)}; | |
| METHOD_FRAME_ACTION(*method, 0 /*no caller*/, main_class, { | |
| frame.store_params(params, 2); | |
| call(frame); | |
| body_string=&frame.result().as_string(); | |
| }); | |
| } | } |
| } | } |
| } | } |
| Line 508 t[9]-t[3] | Line 543 t[9]-t[3] |
| // doing that ugly | // doing that ugly |
| // future $response:content-type | // future $response:content-type |
| response.fields().put(content_type_name, | response.fields().put(content_type_name_upper, new VString(*new String(UNHANDLED_EXCEPTION_CONTENT_TYPE))); |
| new VString(*new String(UNHANDLED_EXCEPTION_CONTENT_TYPE))); | |
| // future $response:body | // future $response:body |
| body_string=new String(exception_cstr); | body_string=new String(exception_cstr); |
| } | } |
| VString body_vstring(*body_string); | VString body_vstring(*body_string); |
| VFile* body_file=body_vstring.as_vfile(String::L_UNSPECIFIED, &charsets); | VFile* body_file=body_vstring.as_vfile(flang, &charsets); |
| // conditionally log it | // conditionally log it |
| Value* vhandled=details.vhash.hash().get(exception_handled_part_name); | Value* vhandled=details.vhash.hash().get(exception_handled_part_name); |
| Line 529 t[9]-t[3] | Line 563 t[9]-t[3] |
| } catch(const Exception& e) { // exception in unhandled exception | } catch(const Exception& e) { // exception in unhandled exception |
| Request::Exception_details details=get_details(e); | Request::Exception_details details=get_details(e); |
| const char* exception_cstr=get_exception_cstr(e, details); | const char* exception_cstr=get_exception_cstr(e, details); |
| // unconditionally log the beast | // unconditionally log the beast in exception handler |
| SAPI::log(sapi_info, "%s", exception_cstr); | throw Exception(0, 0, "Unhandled exception in %s", exception_cstr); |
| throw Exception(0, | |
| 0, | |
| "in %s", | |
| exception_cstr); | |
| } | } |
| } | } |
| } | } |
| Line 545 uint Request::register_file(String::Body | Line 574 uint Request::register_file(String::Body |
| return file_list.count()-1; | return file_list.count()-1; |
| } | } |
| void Request::use_file(VStateless_class& aclass, | void Request::use_file_directly(VStateless_class& aclass, const String& file_spec, bool fail_on_read_problem, bool fail_on_file_absence) { |
| 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 | // cyclic dependence check |
| if(used_files.get(file_name)) | if(used_files.get(file_spec)) |
| return; | return; |
| used_files.put(file_name, true); | used_files.put(file_spec, true); |
| if(fail_on_read_problem && !fail_on_file_absence) // ignore file absence if asked for | |
| if(!entry_exists(file_spec)) | |
| return; | |
| const String* file_spec; | if(const char* source=file_read_text(charsets, file_spec, fail_on_read_problem)) |
| if(ignore_class_path) // ignore_class_path? | use_buf(aclass, source, 0, register_file(file_spec)); |
| 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 { | void Request::use_file(VStateless_class& aclass, const String& file_name, const String* use_filespec/*absolute*/) { |
| file_spec=0; | if(file_name.is_empty()) |
| if(Value* element=main_class.get_element(class_path_name, main_class, false)) { | throw Exception(PARSER_RUNTIME, 0, "usage failed - no filename was specified"); |
| const String* filespec=0; | |
| if(file_name.first_char()=='/') //absolute path? [no need to scan MAIN:CLASS_PATH] | |
| filespec=&absolute(file_name); | |
| else if(use_filespec){ // search in current dir first | |
| size_t last_slash_pos=use_filespec->strrpbrk("/"); | |
| if(last_slash_pos!=STRING_NOT_FOUND) | |
| filespec=file_exist(use_filespec->mid(0, last_slash_pos), file_name); // found in current dir? | |
| } | |
| if(!filespec){ | |
| // prevent multiple scan CLASS_PATH for searching one file | |
| if(searched_along_class_path.get(file_name)) | |
| return; | |
| searched_along_class_path.put(file_name, true); | |
| if(Value* element=main_class.get_element(class_path_name)) { | |
| if(element->is_string()) { | if(element->is_string()) { |
| file_spec=file_exist(absolute(element->as_string()), file_name); // found at class_path? | filespec=file_exist(absolute(element->as_string()), file_name); // found at class_path? |
| } else if(Table *table=element->get_table()) { | } else if(Table *table=element->get_table()) { |
| int size=table->count(); | for(size_t i=table->count(); i--; ) { |
| for(int i=size; i--; ) { | |
| const String& path=*(*table->get(i))[0]; | const String& path=*(*table->get(i))[0]; |
| if((file_spec=file_exist(absolute(path), file_name))) | if(filespec=file_exist(absolute(path), file_name)) |
| break; // found along class_path | break; // found along class_path |
| } | } |
| } else | } else |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, "$" CLASS_PATH_NAME " must be string or table"); |
| 0, | if(!filespec) |
| "$" CLASS_PATH_NAME " must be string or table"); | throw Exception(PARSER_RUNTIME, &file_name, "not found along $" MAIN_CLASS_NAME ":" CLASS_PATH_NAME); |
| if(!file_spec) | } else |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, &file_name, "usage failed - no $" MAIN_CLASS_NAME ":" CLASS_PATH_NAME " were specified"); |
| &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 | use_file_directly(aclass, *filespec); |
| 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)); | |
| } | } |
| void Request::use_file(const String& file_name, const String* use_filespec/*absolute*/, Operation::Origin origin) { | |
| static String use("USE"); | |
| try { | |
| static VHash* voptions=new VHash(); | |
| if(const Method *method=main_class.get_method(use_method_name)){ | |
| Value *params[]={new VString(file_name), voptions}; | |
| voptions->hash().put(origin_key, new VString(*use_filespec)); | |
| CONSTRUCTOR_FRAME_ACTION(*method, 0 /*no parent*/, main_class, { | |
| frame.store_params(params, 2); | |
| // we don't need the result | |
| call(frame); | |
| }); | |
| } | |
| } catch (...) { | |
| exception_trace.push(Trace(&use, origin)); | |
| rethrow; | |
| } | |
| } | |
| void Request::use_buf(VStateless_class& aclass, | void Request::use_buf(VStateless_class& aclass, const char* source, const String* main_alias, uint file_no, int line_no_offset) { |
| const char* source, const String* main_alias, | // temporary zero @conf to avoid it second execution |
| uint file_no, | |
| int line_no_offset) { | |
| // temporary zero @conf so to maybe-replace it in compiled code | |
| Temp_method temp_method_conf(aclass, conf_method_name, 0); | Temp_method temp_method_conf(aclass, conf_method_name, 0); |
| // temporary zero @auto so to maybe-replace it in compiled code | // temporary zero @auto to avoid it second execution |
| Temp_method temp_method_auto(aclass, auto_method_name, 0); | Temp_method temp_method_auto(aclass, auto_method_name, 0); |
| // compile loaded classes | // compile loaded classes |
| Line 615 void Request::use_buf(VStateless_class& | Line 664 void Request::use_buf(VStateless_class& |
| VStateless_class& cclass=*cclasses.get(i); | VStateless_class& cclass=*cclasses.get(i); |
| // locate and execute possible @conf[] static | // locate and execute possible @conf[] static |
| Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass, | Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass, conf_method_name, vfilespec, false/*no string result needed*/); |
| conf_method_name, vfilespec, | |
| false/*no string result needed*/); | |
| if(executed.method) | if(executed.method) |
| configure_admin(cclass/*, executed.method->name*/); | configure_admin(cclass/*, executed.method->name*/); |
| // locate and execute possible @auto[] static | // locate and execute possible @auto[] static |
| execute_nonvirtual_method(cclass, | execute_nonvirtual_method(cclass, auto_method_name, vfilespec, false/*no result needed*/); |
| auto_method_name, vfilespec, | |
| false/*no result needed*/); | cclass.enable_default_setter(); |
| } | } |
| } | } |
| const String& Request::relative(const char* apath, const String& relative_name) { | const String& Request::relative(const char* apath, const String& relative_name) { |
| char *hpath=strdup(apath); | char *hpath=pa_strdup(apath); |
| String& result=*new String; | String& result=*new String; |
| if(rsplit(hpath, '/')) // if something/splitted | if(rsplit(hpath, '/')) // if something/splitted |
| result << hpath << "/"; | result << hpath << "/"; |
| Line 639 const String& Request::relative(const ch | Line 686 const String& Request::relative(const ch |
| const String& Request::absolute(const String& relative_name) { | const String& Request::absolute(const String& relative_name) { |
| if(relative_name.first_char()=='/') { | if(relative_name.first_char()=='/') { |
| String& result=*new String(strdup(request_info.document_root)); | String& result=*new String(pa_strdup(request_info.document_root)); |
| result << relative_name; | result << relative_name; |
| return result; | return result; |
| } else | } else |
| Line 664 public: | Line 711 public: |
| bool add_last_modified; | bool add_last_modified; |
| }; | }; |
| #endif | #endif |
| static void add_header_attribute( | static void add_header_attribute(HashStringValue::key_type name, HashStringValue::value_type value, Add_header_attribute_info* info) { |
| HashStringValue::key_type name, | if(name==BODY_NAME_UPPER || name==DOWNLOAD_NAME_UPPER || name==CHARSET_NAME_UPPER) |
| HashStringValue::value_type value, | |
| Add_header_attribute_info* info) { | |
| if(name==BODY_NAME | |
| || name==DOWNLOAD_NAME | |
| || name==CHARSET_NAME) | |
| return; | return; |
| const char* aname=String(name, String::L_URI).cstr(String::L_UNSPECIFIED, 0, &info->r.charsets); | if(name==LAST_MODIFIED_NAME_UPPER) |
| info->add_last_modified=false; | |
| SAPI::add_header_attribute(info->r.sapi_info, | const char* aname=String(name, String::L_URI).untaint_and_transcode_cstr(String::L_URI, &info->r.charsets); |
| aname, | |
| attributed_meaning_to_string(*value, String::L_URI, false).cstr(String::L_UNSPECIFIED, 0, &info->r.charsets)); | |
| if(strcasecmp(aname, "last-modified")==0) | SAPI::add_header_attribute(info->r.sapi_info, |
| info->add_last_modified = false; | aname, |
| attributed_meaning_to_string(*value, String::L_URI, false).untaint_and_transcode_cstr(String::L_URI, &info->r.charsets) | |
| ); | |
| } | } |
| static void output_sole_piece(Request& r, | static void output_sole_piece(Request& r, bool header_only, VFile& body_file, Value* body_file_content_type) { |
| bool header_only, | |
| VFile& body_file, | |
| Value* body_file_content_type) { | |
| // transcode text body when "text/*" or simple result | // transcode text body when "text/*" or simple result |
| String::C output(body_file.value_ptr(), body_file.value_size()); | 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) | if(!body_file_content_type/*vstring.as_vfile*/ || body_file_content_type->as_string().pos("text/")==0) |
| output=Charset::transcode(output, | output=Charset::transcode(output, r.charsets.source(), r.charsets.client()); |
| r.charsets.source(), | |
| r.charsets.client()); | // prepare header: Content-Length |
| SAPI::add_header_attribute(r.sapi_info, HTTP_CONTENT_LENGTH, format(output.length, "%u")); | |
| // prepare header: content-length | |
| char content_length_cstr[MAX_NUMBER]; | |
| snprintf(content_length_cstr, MAX_NUMBER, "%u", output.length); | |
| SAPI::add_header_attribute(r.sapi_info, "content-length", content_length_cstr); | |
| // send header | // send header |
| SAPI::send_header(r.sapi_info); | SAPI::send_header(r.sapi_info); |
| Line 714 struct Range | Line 750 struct Range |
| size_t end; | size_t end; |
| }; | }; |
| #endif | #endif |
| static void parse_range(const String* s, Array<Range> &ar) | static void parse_range(const String* s, Array<Range> &ar) { |
| { | |
| const char *p = s->cstr(); | const char *p = s->cstr(); |
| if(s->starts_with("bytes=")) | if(s->starts_with("bytes=")) |
| p += 6; | p += 6; |
| Line 737 static void parse_range(const String* s, | Line 772 static void parse_range(const String* s, |
| } | } |
| } | } |
| static void output_pieces(Request& r, | static void output_pieces(Request& r, bool header_only, const String& filename, size_t content_length, Value& date, bool add_last_modified) { |
| bool header_only, | SAPI::add_header_attribute(r.sapi_info, "accept-ranges", "bytes"); |
| const String& filename, | |
| size_t content_length, | |
| Value& date, | |
| bool add_last_modified) | |
| { | |
| SAPI::add_header_attribute(r.sapi_info, "Accept-Ranges", "bytes"); | |
| const size_t BUFSIZE = 10*0x400; | const size_t BUFSIZE = 128*0x400; |
| char buf[BUFSIZE]; | char buf[BUFSIZE]; |
| const char *range = SAPI::get_env(r.sapi_info, "HTTP_RANGE"); | const char *range = SAPI::Env::get(r.sapi_info, "HTTP_RANGE"); |
| size_t offset=0; | size_t offset=0; |
| size_t part_length=content_length; | size_t part_length=content_length; |
| if(range){ | if(range){ |
| Line 758 static void output_pieces(Request& r, | Line 787 static void output_pieces(Request& r, |
| if(count == 1){ | if(count == 1){ |
| Range &rg = ar.get_ref(0); | Range &rg = ar.get_ref(0); |
| if(rg.start == (size_t)-1 && rg.end == (size_t)-1){ | if(rg.start == (size_t)-1 && rg.end == (size_t)-1){ |
| SAPI::add_header_attribute(r.sapi_info, "status", "416 Requested Range Not Satisfiable"); | SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "416 Requested Range Not Satisfiable"); |
| return; | return; |
| } | } |
| if(rg.start == (size_t)-1 && rg.end != (size_t)-1){ | if(rg.start == (size_t)-1 && rg.end != (size_t)-1){ |
| Line 772 static void output_pieces(Request& r, | Line 801 static void output_pieces(Request& r, |
| part_length -= rg.start; | part_length -= rg.start; |
| } | } |
| if(part_length == 0){ | if(part_length == 0){ |
| SAPI::add_header_attribute(r.sapi_info, "status", "204 No Content"); | SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "204 No Content"); |
| return; | return; |
| } | } |
| SAPI::add_header_attribute(r.sapi_info, "status", "206 Partial Content"); | SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "206 Partial Content"); |
| snprintf(buf, BUFSIZE, "bytes %u-%u/%u", rg.start, rg.end, content_length); | snprintf(buf, BUFSIZE, "bytes %u-%u/%u", rg.start, rg.end, content_length); |
| SAPI::add_header_attribute(r.sapi_info, "Content-Range", buf); | SAPI::add_header_attribute(r.sapi_info, "content-range", buf); |
| }else if(count != 0){ | }else if(count != 0){ |
| SAPI::add_header_attribute(r.sapi_info, "status", "501 Not Implemented"); | SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "501 Not Implemented"); |
| return; | return; |
| } | } |
| } | } |
| snprintf(buf, BUFSIZE, "%u", part_length); | SAPI::add_header_attribute(r.sapi_info, HTTP_CONTENT_LENGTH, format(part_length, "%u")); |
| SAPI::add_header_attribute(r.sapi_info, "Content-Length", buf); | |
| if(add_last_modified) | |
| SAPI::add_header_attribute(r.sapi_info, "last-modified", attributed_meaning_to_string(date, String::L_AS_IS, true).cstr()); | |
| if(add_last_modified){ | |
| const String &s = attributed_meaning_to_string(date, String::L_AS_IS, true); | |
| SAPI::add_header_attribute(r.sapi_info, "Last-Modified", s.cstr()); | |
| } | |
| SAPI::send_header(r.sapi_info); | SAPI::send_header(r.sapi_info); |
| const String& filespec=r.absolute(filename); | const String& filespec=r.absolute(filename); |
| Line 801 static void output_pieces(Request& r, | Line 828 static void output_pieces(Request& r, |
| size_t to_read = 0; | size_t to_read = 0; |
| size_t size = 0; | size_t size = 0; |
| do{ | do{ |
| to_read = part_length<BUFSIZE?part_length:BUFSIZE; | to_read = part_length < BUFSIZE ? part_length : BUFSIZE; |
| File_read_result read_result=file_read(r.charsets, filespec, | File_read_result read_result=file_read_binary(filespec, true /*fail on problem*/, buf, offset, to_read); |
| false /*as text*/, 0/*params*/, true/*fail on problem*/, | |
| buf, offset, to_read); | |
| to_read=read_result.length; | to_read=read_result.length; |
| if(to_read == 0) | if(to_read == 0) |
| break; | break; |
| Line 823 void Request::output_result(VFile* body_ | Line 848 void Request::output_result(VFile* body_ |
| // header: cookies | // header: cookies |
| cookie.output_result(sapi_info); | cookie.output_result(sapi_info); |
| // may be specified | // _file_ content-type might be specified |
| Value* body_file_content_type=body_file->fields().get(content_type_name); | Value* body_file_content_type=body_file->fields().get(content_type_name); |
| // content-disposition | // Content-Disposition |
| Value* vfile_name=body_file->fields().get(name_name); | Value* vfile_name=body_file->fields().get(name_name); |
| if(!vfile_name) { | if(!vfile_name) { |
| vfile_name=body_file->fields().get(response_body_file_name); | vfile_name=body_file->fields().get(response_body_file_name); |
| if(vfile_name) | if(vfile_name) { |
| { | char* name_cstr=vfile_name->as_string().cstrm(); |
| const String& sfile_name=vfile_name->as_string(); | |
| char* name_cstr=sfile_name.cstrm(); | |
| if(char *after_slash=rsplit(name_cstr, '\\')) | if(char *after_slash=rsplit(name_cstr, '\\')) |
| name_cstr=after_slash; | name_cstr=after_slash; |
| if(char *after_slash=rsplit(name_cstr, '/')) | if(char *after_slash=rsplit(name_cstr, '/')) |
| name_cstr=after_slash; | name_cstr=after_slash; |
| vfile_name=new VString(*new String(name_cstr)); | vfile_name=new VString(*new String(name_cstr)); |
| } | } |
| } | } |
| if(vfile_name) { | if(vfile_name) { |
| Line 848 void Request::output_result(VFile* body_ | Line 870 void Request::output_result(VFile* body_ |
| VHash& hash=*new VHash(); | VHash& hash=*new VHash(); |
| HashStringValue &h=hash.hash(); | HashStringValue &h=hash.hash(); |
| h.put(value_name, new VString( as_attachment ? content_disposition_attachment : content_disposition_inline )); | h.put(value_name, new VString( as_attachment ? content_disposition_attachment : content_disposition_inline )); |
| h.put(content_disposition_filename_name, new VString(*new String(sfile_name, String::L_HTTP_HEADER))); | |
| h.put(content_disposition_filename_name, vfile_name); | response.fields().put(content_disposition_name_upper, &hash); |
| response.fields().put(content_disposition_name, &hash); | |
| if(!body_file_content_type) | if(!body_file_content_type) |
| body_file_content_type=new VString(mime_type_of(sfile_name.cstr())); | body_file_content_type=new VString(mime_type_of(sfile_name.cstr())); |
| } | } |
| } | } |
| // set content-type | // set Content-Type |
| if(body_file_content_type) { | if(body_file_content_type) { |
| // body file content type | // body file content type |
| response.fields().put(content_type_name, body_file_content_type); | response.fields().put(content_type_name_upper, body_file_content_type); |
| } else { | } else { |
| // default content type | // default content type |
| response.fields().put_dont_replace(content_type_name, | response.fields().put_dont_replace(content_type_name_upper, new VString(*new String(DEFAULT_CONTENT_TYPE))); |
| new VString(*new String(DEFAULT_CONTENT_TYPE))); | |
| } | } |
| // prepare header: $response:fields without :body | // prepare header: $response:fields without :body, :download and :charset |
| Add_header_attribute_info info(*this); | Add_header_attribute_info info(*this); |
| response.fields().for_each<Add_header_attribute_info*>(add_header_attribute, &info); | response.fields().for_each<Add_header_attribute_info*>(add_header_attribute, &info); |
| if(body_file_content_type) | |
| if(HashStringValue *hash=body_file_content_type->get_hash()) | |
| body_file_content_type=hash->get(value_name); | |
| if(Value* vresponse_body_file=body_file->fields().get(response_body_file_name)) { | if(Value* vresponse_body_file=body_file->fields().get(response_body_file_name)) { |
| // $response:[download|body][$.file[filespec]] -- optput specified file | |
| const String& sresponse_body_file=vresponse_body_file->as_string(); | const String& sresponse_body_file=vresponse_body_file->as_string(); |
| size_t content_length=0; | uint64_t content_length=0; |
| time_t atime=0, mtime=0, ctime=0; | time_t atime=0, mtime=0, ctime=0; |
| file_stat(absolute(sresponse_body_file), | file_stat(absolute(sresponse_body_file), content_length, atime, mtime, ctime); |
| content_length, | |
| atime, mtime, ctime); | |
| VDate* vdate=0; | VDate* vdate=0; |
| if(Value* v=body_file->fields().get("mdate")) { | if(Value* v=body_file->fields().get("mdate")) { |
| if(Value* vdatep=v->as(VDATE_TYPE, false)) | if(Value* vdatep=v->as(VDATE_TYPE)) |
| vdate=static_cast<VDate*>(vdatep); | vdate=static_cast<VDate*>(vdatep); |
| else | else |
| throw Exception(PARSER_RUNTIME, 0, "mdate must be a date"); | throw Exception(PARSER_RUNTIME, 0, "mdate must be a date"); |
| } | } |
| if(!vdate) | if(!vdate) |
| vdate=new VDate(mtime); | vdate=new VDate((pa_time_t)mtime); |
| output_pieces(*this, header_only, | output_pieces(*this, header_only, sresponse_body_file, (size_t)content_length, *vdate, info.add_last_modified); |
| sresponse_body_file, | |
| content_length, | |
| *vdate, | |
| info.add_last_modified); | |
| } else { | } else { |
| output_sole_piece(*this, header_only, | if(body_file_content_type) |
| *body_file, body_file_content_type); | if(HashStringValue *hash=body_file_content_type->get_hash()) |
| body_file_content_type=hash->get(value_name); | |
| output_sole_piece(*this, header_only, *body_file, body_file_content_type); | |
| } | } |
| } | } |
| const String& Request::mime_type_of(const String* file_name) { | |
| return mime_type_of(file_name?file_name->taint_cstr(String::L_FILE_SPEC):0); | |
| } | |
| const String& Request::mime_type_of(const char* user_file_name_cstr) { | const String& Request::mime_type_of(const char* user_file_name_cstr) { |
| if(mime_types) | if(mime_types) |
| if(const char* cext=strrchr(user_file_name_cstr, '.')) { | if(const char* cext=strrchr(user_file_name_cstr, '.')) { |
| String sext(++cext); | String sext(++cext); |
| Table::Action_options options; | Table::Action_options options; |
| if(mime_types->locate(0, sext.change_case(charsets.source(), String::CC_LOWER), options)) | if(mime_types->locate(0, sext.change_case(charsets.source(), String::CC_LOWER), options)) { |
| if(const String* result=mime_types->item(1)) | if(const String* result=mime_types->item(1)) |
| return *result; | return *result; |
| else | else |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, MIME_TYPES_NAME " table column elements must not be empty"); |
| 0, | } |
| MIME_TYPES_NAME " table column elements must not be empty"); | |
| } | } |
| return *new String("application/octet-stream"); | return *new String("application/octet-stream"); |
| } | } |
| const String* Request::get_used_filespec(uint file_no){ | |
| if(file_no < file_list.count()) | |
| return new String(file_list[file_no], String::L_TAINTED); | |
| return 0; | |
| } | |
| #ifdef XML | #ifdef XML |
| xmlChar* Request::transcode(const String& s) { | xmlChar* Request::transcode(const String& s) { |
| return charsets.source().transcode(s); | return charsets.source().transcode(s); |
| Line 935 const String& Request::transcode(const x | Line 959 const String& Request::transcode(const x |
| } | } |
| #endif | #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 (we usually know source of next-from-throw-point exception) 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) { | Request::Exception_details Request::get_details(const Exception& e) { |
| const String* problem_source=e.problem_source(); | const String* problem_source=e.problem_source(); |
| Trace trace=exception_trace.extract_origin(problem_source); | |
| VHash& vhash=*new VHash; HashStringValue& hash=vhash.hash(); | VHash& vhash=*new VHash; HashStringValue& hash=vhash.hash(); |
| Operation::Origin origin={0, 0, 0}; | |
| if(!exception_trace.is_empty()) { | |
| Trace bottom=exception_trace.bottom_value(); | |
| origin=bottom.origin(); | |
| if(!problem_source) { // we don't know who trigged the bug | |
| problem_source=bottom.name(); // we usually know source of next-from-throw-point exception did that | |
| exception_trace.set_bottom_index(exception_trace.bottom_index()+1); | |
| } else if (bottom.name()==problem_source) { // it is that same guy? | |
| exception_trace.set_bottom_index(exception_trace.bottom_index()+1); // throw away that trace | |
| } else { | |
| // stack top contains not us, leaving intact to help ^throw | |
| } | |
| } | |
| // $.type | // $.type |
| if(const char* type=e.type(true)) | if(const char* type=e.type(true)) |
| hash.put(exception_type_part_name, new VString(*new String(type))); | hash.put(exception_type_part_name, new VString(*new String(type))); |
| // $.source | // $.source |
| if(problem_source) { | if(problem_source) |
| String& source=*new String; | hash.put(exception_source_part_name, new VString(*new String(*problem_source, String::L_TAINTED))); |
| source.append(*problem_source, String::L_TAINTED, true/*forced*/); | |
| hash.put(exception_source_part_name, new VString(source)); | |
| } | |
| // $.file lineno colno | // $.file $.lineno $.colno |
| if(trace) { | if(origin.file_no){ |
| const Operation::Origin origin=trace.origin(); | hash.put("file", new VString(*new String(file_list[origin.file_no], String::L_TAINTED))); |
| hash.put(String::Body("file"), | hash.put("lineno", new VInt(1+origin.line)); |
| new VString(*new String(file_list[origin.file_no], String::L_TAINTED))); | hash.put("colno", new VInt(1+origin.col)); |
| hash.put(String::Body("lineno"), new VInt(1+origin.line)); | |
| hash.put(String::Body("colno"), new VInt(1+origin.col)); | |
| } | } |
| // $.comment | // $.comment |
| if(const char* comment=e.comment(true)) | if(const char* comment=e.comment(true)) |
| hash.put(exception_comment_part_name, | hash.put(exception_comment_part_name, new VString(*new String(comment, String::L_TAINTED))); |
| new VString(*new String(comment, 0, true/*tainted*/))); | |
| // $.handled(0) | // $.handled(0) |
| hash.put(exception_handled_part_name, new VBool(false)); | hash.put(exception_handled_part_name, &VBool::get(false)); |
| return Request::Exception_details(origin, problem_source, vhash); | |
| } | |
| Temp_value_element::Temp_value_element(Request& arequest, Value& awhere, const String& aname, Value* awhat) : | |
| frequest(arequest), | |
| fwhere(awhere), | |
| fname(aname), | |
| saved(awhere.get_element(aname)) | |
| { | |
| Junction* junction; | |
| if(saved && (junction=saved->get_junction()) && junction->is_getter) | |
| saved=0; | |
| frequest.put_element(fwhere, aname, awhat); | |
| } | |
| return Request::Exception_details(trace, problem_source, vhash); | Temp_value_element::~Temp_value_element() { |
| frequest.put_element(fwhere, fname, saved ? saved : VVoid::get()); | |
| } | } |