|
|
| version 1.142, 2001/07/13 10:58:03 | version 1.355, 2016/07/20 16:36:49 |
|---|---|
| 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 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2015 Art. Lebedev Studio (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include "pa_config_includes.h" | |
| #include "pcre.h" | |
| #include "internal.h" | |
| extern "C" unsigned char pcre_default_tables[]; // pcre/chartables.c | |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_common.h" | #include "pa_common.h" |
| Line 22 extern "C" unsigned char pcre_default_ta | Line 14 extern "C" unsigned char pcre_default_ta |
| #include "pa_vint.h" | #include "pa_vint.h" |
| #include "pa_vmethod_frame.h" | #include "pa_vmethod_frame.h" |
| #include "pa_types.h" | #include "pa_types.h" |
| #include "pa_venv.h" | |
| #include "pa_vmath.h" | |
| #include "pa_vstatus.h" | |
| #include "pa_vrequest.h" | |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| #include "pa_vfile.h" | #include "pa_vfile.h" |
| #include "pa_dictionary.h" | |
| #include "pa_charset.h" | |
| #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" | |
| #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 | |
| #define UNHANDLED_EXCEPTION_METHOD_NAME "unhandled_exception" | |
| /// content type of exception response, when no @MAIN:exception handler defined | /// content type of exception response, when no @MAIN:exception handler defined |
| const char *UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; | const char* UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; |
| /// 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"; |
| // defines for globals | |
| #define MAIN_METHOD_NAME "main" | |
| #define AUTO_METHOD_NAME "auto" | |
| #define AUTOUSE_METHOD_NAME "autouse" | |
| #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 autouse_method_name(AUTOUSE_METHOD_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 | |
| Methoded *MOP_create(Pool&); | #define CHARSETS_NAME "CHARSETS" |
| #define MIME_TYPES_NAME "MIME-TYPES" | |
| #define STRICT_VARS_NAME "STRICT-VARS" | |
| #define CONF_METHOD_NAME "conf" | |
| #define POST_PROCESS_METHOD_NAME "postprocess" | |
| #define CLASS_PATH_NAME "CLASS_PATH" | |
| #define RESPONSE_BODY_FILE_NAME "file" | |
| #define DOWNLOAD_NAME_UPPER "DOWNLOAD" | |
| #define BODY_NAME_UPPER "BODY" | |
| // 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 strict_vars_name(STRICT_VARS_NAME); | |
| static const String conf_method_name(CONF_METHOD_NAME); | |
| static const String post_process_method_name(POST_PROCESS_METHOD_NAME); | |
| static const String class_path_name(CLASS_PATH_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 | |
| #define CHARSET_NAME_UPPER "CHARSET" | |
| #define LAST_MODIFIED_NAME_UPPER "LAST-MODIFIED" | |
| // op.C | |
| VStateless_class& VClassMAIN_create(); | |
| // | // |
| Request::Request(Pool& apool, | Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info, |
| Info& ainfo, | String::Language adefault_lang): |
| String::Untaint_lang adefault_lang) : Pooled(apool), | // private |
| stack(apool), | anti_endless_execute_recoursion(0), |
| OP(*MOP_create(apool)), | |
| env(apool), | // public |
| form(apool), | allow_class_replace(false), |
| math(apool), | method_frame(0), |
| request(apool, *this), | rcontext(0), |
| response(apool), | wcontext(0), |
| cookie(apool), | flang(adefault_lang), |
| fclasses(apool), | fconnection(0), |
| fdefault_lang(adefault_lang), flang(adefault_lang), | finterrupted(false), |
| info(ainfo), | fskip(SKIP_NOTHING), |
| post_data(0), post_size(0), | fin_cycle(0), |
| used_files(apool), | |
| default_content_type(0), | // public |
| mime_types(0), | request_info(arequest_info), |
| main_class(0), | sapi_info(asapi_info), |
| connection(0), | charsets(UTF8_charset, UTF8_charset, UTF8_charset), // default charsets |
| pcre_tables(0), | |
| classes_conf(apool), | main_class(VClassMAIN_create()), |
| anti_endless_execute_recoursion(0) | form(*new VForm(charsets, arequest_info)), |
| mail(*new VMail), | |
| response(*new VResponse(arequest_info, charsets)), | |
| cookie(*new VCookie(charsets, arequest_info)), | |
| console(*new VConsole), | |
| // private | |
| configure_admin_done(false), | |
| // private defaults | |
| fdefault_lang(adefault_lang), | |
| // private mime types | |
| mime_types(0) | |
| { | { |
| pa_register_thread_request(*this); | |
| // file_no=0 => unknown | |
| file_list+="UNKNOWN"; | |
| file_list+="-body of process-"; // pseudo_file_no__process | |
| // maybe expire old caches | |
| cache_managers->maybe_expire(); | |
| /// directly used | /// directly used |
| // operators | // MAIN class, operators |
| OP.register_directly_used(*this); | 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(*NEW String(pool(), ENV_CLASS_NAME), &env); | put_class(new VEnv(asapi_info)); |
| // status class | |
| put_class(new VStatus()); | |
| // request class | // request class |
| classes().put(*NEW String(pool(), REQUEST_CLASS_NAME), &request); | put_class(new VRequest(arequest_info, charsets, form, asapi_info)); |
| // cookie class | // cookie class |
| classes().put(*NEW String(pool(), COOKIE_CLASS_NAME), &cookie); | put_class(&cookie); |
| // console class | |
| 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()->name(), &form); | put_class(&form); |
| // mail class | |
| put_class(&mail); | |
| // math class | // math class |
| classes().put(math.get_class()->base()->name(), &math); | put_class(new VMath); |
| // memory class | |
| put_class(new VMemory); | |
| } | } |
| static void element2ctypes(unsigned char *tables, | Request::~Request() { |
| Value& ctype, const String& name, | #ifdef XML |
| unsigned char bit, | // if for some strange reason xml generic errors failed to be reported, free them up |
| int group_offset=-1, | if(const char* xml_generic_errors=xmlGenericErrors()) { |
| bool skip_ws=true) { | SAPI::log(sapi_info, "warning: unreported xmlGenericErrors: %s", xml_generic_errors); |
| Value *value=ctype.get_element(name); | pa_free((void *)xml_generic_errors); |
| if(!value) | } |
| return; | #endif |
| } | |
| unsigned char *ctypes_table=tables+ctypes_offset; | Value& Request::get_self() { return method_frame/*always have!*/->self(); } |
| const unsigned char *cstr= | |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | VStateless_class* Request::get_class(const String& name){ |
| for(; *cstr; cstr++) { | VStateless_class* result=classes().get(name); |
| unsigned char c=*cstr; | if(!result) |
| if(skip_ws && (c=='\n' || c=='\t' || c==' ')) | if(Value* value=main_class.get_element(autouse_method_name)) |
| continue; | if(Junction* junction=value->get_junction()) |
| ctypes_table[c]|=bit; | if(const Method *method=junction->method) { |
| Value *vname=new VString(name); | |
| if(group_offset>=0) | VMethodFrame frame(*method, 0 /*no parent*/, main_class); |
| tables[cbits_offset+group_offset+c/8] |= 1 << (c%8); | |
| } | frame.store_params(&vname, 1); |
| } | // we don't need the result |
| static void cstr2ctypes(unsigned char *tables, const unsigned char *cstr, | execute_method(frame); |
| unsigned char bit) { | |
| unsigned char *ctypes_table=tables+ctypes_offset; | result=classes().get(name); |
| ctypes_table[0]=bit; | } |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | return result; |
| ctypes_table[c]|=bit; | } |
| } | |
| } | static void load_charset(HashStringValue::key_type akey, |
| static void prepare_case_tables(unsigned char *tables) { | HashStringValue::value_type avalue, |
| unsigned char *lcc_table=tables+lcc_offset; | Request_charsets* charsets) { |
| unsigned char *fcc_table=tables+fcc_offset; | const String::Body NAME=String(akey, String::L_CLEAN).change_case(charsets->source(), String::CC_UPPER); |
| for(int i=0; i<0x100; i++) | ::charsets.load_charset(*charsets, NAME, avalue->as_string()); |
| lcc_table[i]=fcc_table[i]=i; | } |
| } | void Request::configure_admin(VStateless_class& conf_class) { |
| static void element2case(unsigned char *tables, Value& ctype, const String& name) { | if(configure_admin_done) |
| Value *value=ctype.get_element(name); | throw Exception(PARSER_RUNTIME, |
| if(!value) | 0, |
| return; | "parser already configured"); |
| configure_admin_done=true; | |
| // charsets must only be specified in method_frame config | |
| // so that users would not interfere | |
| /* $MAIN:CHARSETS[ | |
| $.charsetname1[/full/path/to/charset/file.cfg] | |
| ... | |
| ] | |
| */ | |
| if(Value* vcharsets=conf_class.get_element(charsets_name)) { | |
| if(!vcharsets->is_string()) { | |
| if(HashStringValue* charsets=vcharsets->get_hash()) | |
| charsets->for_each<Request_charsets*>(load_charset, &this->charsets); | |
| else | |
| throw Exception(PARSER_RUNTIME, | |
| 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 | |
| unsigned char *lcc_table=tables+lcc_offset; | // configure method_frame options |
| unsigned char *fcc_table=tables+fcc_offset; | // until someone with less privileges have overriden them |
| const unsigned char *cstr= | methoded_array().configure_admin(*this); |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | } |
| unsigned char from=0; | |
| for(; *cstr; cstr++) { | const char* Request::get_exception_cstr(const Exception& e, Request::Exception_details& details) { |
| unsigned char c=*cstr; | |
| if(c=='\n' || c=='\t' || c==' ') | #define PA_URI_FORMAT "%s: " |
| continue; | #define PA_COMMENT_TYPE_FORMAT "%s [%s]" |
| if(from) { | |
| lcc_table[from]=c; | #define PA_ORIGIN_FILE_POS_FORMAT "%s(%d:%d): " |
| fcc_table[from]=c; fcc_table[c]=from; | #define PA_SOURCE_FORMAT "'%s' " |
| from=0; | |
| } else | #define PA_ORIGIN_FILE_POS_VALUE file_list[details.origin.file_no].cstr(), 1+details.origin.line, 1+details.origin.col, |
| from=c; | #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]; | |
| if(details.problem_source) { // do we know the guy? | |
| if(details.origin.file_no) // do whe know where he came from? | |
| EXCEPTION_CSTR(PA_ORIGIN_FILE_POS_FORMAT, PA_ORIGIN_FILE_POS_VALUE, PA_SOURCE_FORMAT, PA_SOURCE_VALUE) | |
| else | |
| EXCEPTION_CSTR(PA_SOURCE_FORMAT, PA_SOURCE_VALUE,,) | |
| } else { | |
| if(details.origin.file_no) // do whe know where he came from? | |
| EXCEPTION_CSTR(PA_ORIGIN_FILE_POS_FORMAT, PA_ORIGIN_FILE_POS_VALUE,,) | |
| else | |
| EXCEPTION_CSTR(,,,) | |
| } | } |
| return result; | |
| } | |
| void Request::configure() { | |
| // configure admin options if not configured yet | |
| if(!configure_admin_done) | |
| configure_admin(main_class); | |
| // configure not-admin=user options | |
| methoded_array().configure_user(*this); | |
| // $MAIN:MIME-TYPES | |
| if(Value* element=main_class.get_element(mime_types_name)) | |
| if(Table *table=element->get_table()) | |
| mime_types=table; | |
| } | } |
| /** | /** |
| load MAIN class, execute @main. | load MAIN class, execute @main. |
| Line 150 static void element2case(unsigned char * | Line 324 static void element2case(unsigned char * |
| the file user requested us to process | the file user requested us to process |
| all located classes become children of one another, | all located classes become children of one another, |
| composing class we name 'MAIN' | composing class we name 'MAIN' |
| @test log stack trace | |
| */ | */ |
| void Request::core(const char *root_auto_path, bool root_auto_fail, | void Request::core(const char* config_filespec, bool config_fail_on_read_problem, bool header_only) { |
| const char *site_auto_path, bool site_auto_fail, | try { |
| bool header_only) { | // loading config |
| //_asm { int 3 } | if(config_filespec) { |
| bool need_rethrow=false; Exception rethrow_me; | const String& filespec=*new String(config_filespec); |
| TRY { | use_file_directly(main_class, |
| char *auto_filespec=(char *)malloc(MAX_STRING); | filespec, |
| config_fail_on_read_problem, | |
| // loading root auto.p | true /*file must exist if 'fail on read problem' not set*/); |
| if(root_auto_path) { | |
| String& filespec=*NEW String(pool()); | |
| filespec.APPEND_CLEAN(root_auto_path, 0, "root_auto", 0); | |
| filespec.APPEND_CONST("/" AUTO_FILE_NAME); | |
| main_class=use_file( | |
| filespec, root_auto_fail, | |
| main_class_name, main_class); | |
| } | |
| // configure root options | |
| // until someone with less privileges have overriden them | |
| OP.configure_admin(*this); | |
| methoded_array->configure_admin(*this); | |
| // loading site auto.p | |
| if(site_auto_path) { | |
| String& filespec=*NEW String(pool()); | |
| filespec.APPEND_CLEAN(site_auto_path, 0, "site_auto", 0); | |
| filespec.APPEND_CONST("/" AUTO_FILE_NAME); | |
| main_class=use_file( | |
| filespec, site_auto_fail, | |
| main_class_name, main_class); | |
| } | } |
| // 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 |
| { | { |
| Array ladder(pool()); | const char* after=request_info.path_translated; |
| const char *after=info.path_translated; | size_t drlen=strlen(request_info.document_root); |
| size_t drlen=strlen(info.document_root); | if(memcmp(after, request_info.document_root, drlen)==0) { |
| if(memcmp(after, info.document_root, drlen)==0) { | |
| after+=drlen; | after+=drlen; |
| if(after[-1]=='/') | if(after[-1]=='/') |
| --after; | --after; |
| } | } |
| while(const char *before=strchr(after, '/')) { | while(const char* before=strchr(after, '/')) { |
| String& step=*NEW String(pool()); | String& sfile_spec=*new String; |
| if(after!=info.path_translated) { | if(after!=request_info.path_translated) { |
| step.APPEND_CLEAN( | sfile_spec.append_strdup( |
| info.path_translated, before+1/* / */-info.path_translated, | request_info.path_translated, before-request_info.path_translated, |
| "path-translated-scanned", ladder.size()); | String::L_CLEAN); |
| step << AUTO_FILE_NAME; | sfile_spec << "/" AUTO_FILE_NAME; |
| ladder+=&step; | |
| use_file_directly(main_class, | |
| sfile_spec, | |
| true /*fail on read problem*/, | |
| false /*but ignore absence, sole user*/); | |
| } | } |
| after=before+1; | for(after=before+1;*after=='/';after++); |
| } | |
| for(int i=0; i<ladder.size(); i++) { | |
| const String& sfile_spec=*ladder.get_string(i); | |
| main_class=use_file(sfile_spec, false/*ignore read problem*/, | |
| main_class_name, main_class); | |
| } | } |
| } | } |
| // compile requested file | try { |
| String& spath_translated=*NEW String(pool()); | // compile requested file |
| spath_translated.APPEND_TAINTED(info.path_translated, 0, "user-request", 0); | String& spath_translated=*new String; |
| main_class=use_file(spath_translated, true/*don't ignore read problem*/, | spath_translated.append_help_length(request_info.path_translated, 0, String::L_TAINTED); |
| main_class_name, main_class); | use_file_directly(main_class, spath_translated); |
| // configure not-root=user options | configure(); |
| OP.configure_user(*this); | } catch(...) { |
| methoded_array->configure_user(*this); | configure(); // configure anyway, useful in @unhandled_exception [say, if they would want to mail by SMTP something] |
| rethrow; | |
| // $MAIN:DEFAULTS | } |
| Value *defaults=main_class->get_element(*defaults_name); | |
| // value must be allocated on request's pool for that pool used on | |
| // meaning constructing @see attributed_meaning_to_string | |
| default_content_type=defaults?defaults->get_element(*content_type_name):0; | |
| if(Value *element=main_class->get_element(*user_html_name)) | |
| if(Table *table=element->get_table()) | |
| pool().set_tag(table); | |
| // $MAIN:MIME-TYPES | |
| if(Value *element=main_class->get_element(*mime_types_name)) | |
| if(Table *table=element->get_table()) | |
| mime_types=table; | |
| /* | |
| $MAIN:CTYPE[ | |
| $white-space[ | |
| ^#09^#0A^#0B^#0C^#0D^#20] | |
| $digit[ | |
| 0123456789] | |
| $hex-digit[ | |
| 0123456789ABCDEFabcdef] | |
| $letter[ | |
| ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz] | |
| $word[ | |
| 0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz] | |
| $lowercase[ | |
| AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz] | |
| ] | |
| */ | |
| if(Value *ctype=main_class->get_element(*ctype_name)) { | |
| // lowcase, flipcase, bits digit+word+whitespace, masks | |
| pcre_tables=(unsigned char *)calloc(tables_length); | |
| prepare_case_tables(pcre_tables); | |
| element2ctypes(pcre_tables, *ctype, *ctype_white_space_name, ctype_space, cbit_space, false); | |
| element2ctypes(pcre_tables, *ctype, *ctype_digit_name, ctype_digit, cbit_digit); | |
| element2ctypes(pcre_tables, *ctype, *ctype_hex_digit_name, ctype_xdigit); | |
| element2ctypes(pcre_tables, *ctype, *ctype_letter_name, ctype_letter); | |
| element2ctypes(pcre_tables, *ctype, *ctype_word_name, ctype_word, cbit_word); | |
| cstr2ctypes(pcre_tables, (const unsigned char *)"*+?{^.$|()[", ctype_meta); | |
| element2case(pcre_tables, *ctype, *ctype_lowercase_name); | |
| } else | |
| pcre_tables=pcre_default_tables; | |
| // filling form fields | |
| form.fill_fields(*this); | |
| // filling cookies | |
| cookie.fill_fields(*this); | |
| // execute @main[] | // execute @main[] |
| const String *body_string=execute_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(0,0, | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "'"MAIN_METHOD_NAME"' method not found"); | "'" MAIN_METHOD_NAME "' method not found"); |
| // extract response body | |
| Value* body_value=response.fields().get(download_name_upper); // $response:download? | |
| bool as_attachment=body_value!=0; | |
| if(!body_value) | |
| body_value=response.fields().get(body_name_upper); // $response:body | |
| if(!body_value) | |
| body_value=new VString(*body_string); // just result of ^main[] | |
| VString body_vstring_before_post_process(*body_string); | |
| VString *body_vstring_after_post_process=&body_vstring_before_post_process; | |
| // @postprocess | // @postprocess |
| if(Value *value=main_class->get_element(*post_process_method_name)) | 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] |
| VMethodFrame frame(pool(), value->name(), *junction, false); | VMethodFrame frame(*method, 0 /*no parent*/, main_class); |
| frame.set_self(*main_class); | |
| frame.store_param(method->name, | frame.store_params(&body_value, 1); |
| &body_vstring_before_post_process); | execute_method(frame); |
| body_vstring_after_post_process= | |
| NEW VString(*execute_method(frame, *method)); | |
| } | |
| const VFile *body_file=body_vstring_after_post_process->as_vfile(); | body_value=&frame.result().as_value(); |
| } | |
| // extract response body | VFile* body_file=body_value->as_vfile(flang, &charsets); |
| Value *body_value=static_cast<Value *>( | |
| response.fields().get(*body_name)); | |
| if(body_value) // there is some $response.body | |
| body_file=body_value->as_vfile(); | |
| // OK. write out the result | // OK. write out the result |
| output_result(*body_file, header_only); | output_result(body_file, header_only, as_attachment); |
| } | |
| CATCH(e) { // request handling problem | } catch(const Exception& e) { // request handling problem |
| try { | |
| // we're returning not result, but error explanation | // we're returning not result, but error explanation |
| TRY { | |
| // log the beast | |
| const String *problem_source=e.problem_source(); | |
| if(problem_source && problem_source->size()) | |
| SAPI::log(pool(), | |
| #ifndef NO_STRING_ORIGIN | |
| "%s(%d): " | |
| #endif | |
| "'%s' %s [%s %s]", | |
| #ifndef NO_STRING_ORIGIN | |
| problem_source->origin().file?problem_source->origin().file:"global", | |
| problem_source->origin().line, | |
| #endif | |
| problem_source->cstr(String::UL_AS_IS), | |
| e.comment(), | |
| e.type()?e.type()->cstr(String::UL_AS_IS):"-", | |
| e.code()?e.code()->cstr(String::UL_AS_IS):"-" | |
| ); | |
| else | |
| SAPI::log(pool(), | |
| "%s [%s %s]", | |
| e.comment(), | |
| e.type()?e.type()->cstr(String::UL_AS_IS):"-", | |
| e.code()?e.code()->cstr(String::UL_AS_IS):"-" | |
| ); | |
| // reset language to default | |
| flang=fdefault_lang; | |
| if(flang==String::UL_USER_HTML) | |
| flang=String::UL_HTML; // no _ & Co conversions in @exception[params] | |
| // reset response | |
| response.fields().clear(); | |
| // this is what we'd return in $response:body | Request::Exception_details details=get_details(e); |
| const String *body_string=0; | const char* exception_cstr=get_exception_cstr(e, details); |
| if(main_class) { // we've managed to end up with some main_class | // reset language to default |
| // maybe we'd be lucky enough as to report an error | flang=fdefault_lang; |
| // in a gracefull way... | |
| if(Value *value=main_class->get_element(*exception_method_name)) | // reset response |
| if(Junction *junction=value->get_junction()) | response.fields().clear(); |
| if(const Method *method=junction->method) { | |
| // preparing to pass parameters to | |
| // @exception[origin;source;comment;type;code] | |
| VMethodFrame frame(pool(), value->name(), *junction, false); | |
| frame.set_self(*main_class); | |
| const String *problem_source=e.problem_source(); | |
| // origin | |
| Value *origin_value=0; | |
| #ifndef NO_STRING_ORIGIN | |
| if(problem_source && problem_source->size()) { | |
| const Origin& origin=problem_source->origin(); | |
| if(origin.file) { | |
| char *buf=(char *)malloc(MAX_STRING); | |
| size_t buf_size=snprintf(buf, MAX_STRING, "%s(%d):", | |
| origin.file, 1+origin.line); | |
| String *origin_file_line=NEW String(pool(), | |
| buf, buf_size, true); | |
| origin_value=NEW VString(*origin_file_line); | |
| } | |
| } | |
| #endif | |
| frame.store_param(method->name, | |
| origin_value?origin_value:NEW VVoid(pool())); | |
| // source | // this is what we'd return in $response:body |
| Value *source_value=0; | const String* body_string=0; |
| if(problem_source && problem_source->size()) { | |
| String& problem_source_copy=*NEW String(pool()); | |
| problem_source_copy.append(*problem_source, | |
| flang, true); | |
| source_value=NEW VString(problem_source_copy); | |
| } | |
| frame.store_param(method->name, | |
| source_value?source_value:NEW VVoid(pool())); | |
| // comment | // maybe we'd be lucky enough as to report an error |
| String *comment_value=NEW String(pool(), | // in a gracefull way... |
| e.comment(), 0, true); | if(Value* value=main_class.get_element(*new String(UNHANDLED_EXCEPTION_METHOD_NAME))) { |
| frame.store_param(method->name, | if(Junction* junction=value->get_junction()) { |
| NEW VString(*comment_value)); | if(const Method *method=junction->method) { |
| // preparing to pass parameters to | |
| // type | // @unhandled_exception[exception;stack] |
| Value *type_value; | |
| if(e.type()) { | // $stack[^table::create{name file lineno colno}] |
| String& type_copy=*NEW String(pool()); | Table::columns_type stack_trace_columns(new ArrayString); |
| type_value=NEW VString(type_copy.append(*e.type(), | *stack_trace_columns+=new String("name"); |
| flang, true)); | *stack_trace_columns+=new String("file"); |
| } else | *stack_trace_columns+=new String("lineno"); |
| type_value=NEW VVoid(pool()); | *stack_trace_columns+=new String("colno"); |
| frame.store_param(method->name, type_value); | Table& stack_trace=*new Table(stack_trace_columns); |
| if(!exception_trace.is_empty()/*signed!*/) | |
| // code | for(size_t i=exception_trace.bottom_index(); i<exception_trace.top_index(); i++) { |
| Value *code_value; | Trace trace=exception_trace.get(i); |
| if(e.code()) { | Table::element_type row(new ArrayString); |
| String& code_copy=*NEW String(pool()); | |
| code_value=NEW VString(code_copy.append(*e.code(), | *row+=trace.name(); // name column |
| flang, true)); | Operation::Origin origin=trace.origin(); |
| } else | if(origin.file_no) { |
| code_value=NEW VVoid(pool()); | *row+=new String(file_list[origin.file_no], String::L_TAINTED); // 'file' column |
| frame.store_param(method->name, code_value); | *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 | |
| // future $response:body= | } |
| // execute ^exception[origin;source;comment;type;code] | stack_trace+=row; |
| body_string=execute_method(frame, *method); | |
| } | } |
| } | |
| if(!body_string) { // couldn't report an error beautifully? | |
| // doing that ugly | |
| // make up result: $origin $source $comment $type $code | // future $response:body= |
| char *buf=(char *)malloc(MAX_STRING); | // execute ^unhandled_exception[exception;stack] |
| size_t printed=0; | 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) |
| const String *problem_source=e.problem_source(); | |
| if(problem_source) { | |
| #ifndef NO_STRING_ORIGIN | |
| const Origin& origin=problem_source->origin(); | |
| if(origin.file) | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s(%d): ", | |
| origin.file, 1+origin.line); | |
| #endif | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", | |
| problem_source->cstr(String::UL_AS_IS)); | |
| } | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", | |
| e.comment()); | |
| const String *type=e.type(); | |
| if(type) { | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, " type: %s", | |
| type->cstr(String::UL_AS_IS)); | |
| const String *code=e.code(); | |
| if(code) | |
| printed+=snprintf(buf+printed, MAX_STRING-printed, ", code: %s", | |
| code->cstr(String::UL_AS_IS)); | |
| } | |
| // future $response:content-type | VMethodFrame frame(*method, 0 /*no caller*/, main_class); |
| response.fields().put(*content_type_name, | Value *params[]={&details.vhash, new VTable(&stack_trace)}; |
| NEW VString(*NEW String(pool(), UNHANDLED_EXCEPTION_CONTENT_TYPE))); | |
| // future $response:body | frame.store_params(params, 2); |
| body_string=NEW String(pool(), buf); | execute_method(frame); |
| body_string=&frame.result().as_string(); | |
| } | |
| } | } |
| } | |
| if(!body_string) { // couldn't report an error beautifully? | |
| // doing that ugly | |
| // future $response:content-type | |
| response.fields().put(content_type_name_upper, new VString(*new String(UNHANDLED_EXCEPTION_CONTENT_TYPE))); | |
| // future $response:body | |
| body_string=new String(exception_cstr); | |
| } | |
| const VString body_vstring(*body_string); | VString body_vstring(*body_string); |
| const VFile *body_file=body_vstring.as_vfile(); | VFile* body_file=body_vstring.as_vfile(flang, &charsets); |
| // ERROR. write it out | // conditionally log it |
| output_result(*body_file, header_only); | Value* vhandled=details.vhash.hash().get(exception_handled_part_name); |
| if(!vhandled || !vhandled->as_bool()) { | |
| SAPI::log(sapi_info, "%s", exception_cstr); | |
| } | } |
| CATCH(e) { | |
| // exception in request exception handler | // ERROR. write it out |
| // remember to rethrow it | output_result(body_file, header_only, false); |
| rethrow_me=e; need_rethrow=true; | |
| } catch(const Exception& e) { // exception in unhandled exception | |
| Request::Exception_details details=get_details(e); | |
| const char* exception_cstr=get_exception_cstr(e, details); | |
| // unconditionally log the beast | |
| SAPI::log(sapi_info, "%s", exception_cstr); | |
| throw Exception(0, | |
| 0, | |
| "in %s", | |
| exception_cstr); | |
| } | } |
| END_CATCH | |
| } | } |
| END_CATCH // do not use pool() after this point - no exception handler set | } |
| // any throw() would try to use zero exception() pointer | |
| if(need_rethrow) // were there an exception for us to rethrow? | uint Request::register_file(String::Body file_spec) { |
| THROW(rethrow_me.type(), rethrow_me.code(), | file_list+=file_spec; |
| rethrow_me.problem_source(), | return file_list.count()-1; |
| rethrow_me.comment()); | |
| } | } |
| VStateless_class *Request::use_file(const String& file_spec, bool fail_on_read_problem, | void Request::use_file_directly(VStateless_class& aclass, |
| const String *name, | const String& file_spec, |
| VStateless_class *base_class) { | bool fail_on_read_problem, |
| bool fail_on_file_absence) { | |
| // cyclic dependence check | // cyclic dependence check |
| if(used_files.get(file_spec)) | if(used_files.get(file_spec)) |
| return base_class; | return; |
| used_files.put(file_spec, (Hash::Val *)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; | |
| if(const char* source=file_read_text(charsets, file_spec, fail_on_read_problem)) | |
| use_buf(aclass, source, 0, register_file(file_spec)); | |
| } | |
| void Request::use_file(VStateless_class& aclass, const String& file_name, const String* use_filespec/*absolute*/) { | |
| if(file_name.is_empty()) | |
| 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()) { | |
| filespec=file_exist(absolute(element->as_string()), file_name); // found at class_path? | |
| } else if(Table *table=element->get_table()) { | |
| for(size_t i=table->count(); i--; ) { | |
| const String& path=*(*table->get(i))[0]; | |
| if(filespec=file_exist(absolute(path), file_name)) | |
| break; // found along class_path | |
| } | |
| } else | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "$" CLASS_PATH_NAME " must be string or table"); | |
| if(!filespec) | |
| throw Exception(PARSER_RUNTIME, | |
| &file_name, | |
| "not found along " MAIN_CLASS_NAME ":" CLASS_PATH_NAME); | |
| } else | |
| throw Exception(PARSER_RUNTIME, | |
| &file_name, | |
| "usage failed - no $" MAIN_CLASS_NAME ":" CLASS_PATH_NAME " were specified"); | |
| } | |
| char *source=file_read_text(pool(), file_spec, fail_on_read_problem); | use_file_directly(aclass, *filespec); |
| if(!source) | } |
| return base_class; | |
| return use_buf(source, file_spec.cstr(), 0/*new class*/, name, base_class); | void Request::use_file(VStateless_class& aclass, const String& file_name, const String* use_filespec/*absolute*/, Operation::Origin origin) { |
| static String use("USE"); | |
| try { | |
| use_file(aclass, file_name, use_filespec); | |
| } catch (...) { | |
| exception_trace.push(Trace(&use, origin)); | |
| rethrow; | |
| } | |
| } | } |
| VStateless_class *Request::use_buf(const char *source, const char *file, | void Request::use_buf(VStateless_class& aclass, |
| VStateless_class *aclass, const String *name, | const char* source, const String* main_alias, |
| VStateless_class *base_class) { | uint file_no, |
| // compile loaded class | int line_no_offset) { |
| VStateless_class& cclass=COMPILE(source, aclass, name, base_class, file); | // temporary zero @conf so to maybe-replace it in compiled code |
| Temp_method temp_method_conf(aclass, conf_method_name, 0); | |
| // temporary zero @auto so to maybe-replace it in compiled code | |
| Temp_method temp_method_auto(aclass, auto_method_name, 0); | |
| // compile loaded classes | |
| ArrayClass& cclasses=compile(&aclass, source, main_alias, file_no, line_no_offset); | |
| VString* vfilespec= | |
| new VString(*new String(file_list[file_no], String::L_TAINTED)); | |
| for(size_t i=0; i<cclasses.count(); i++){ | |
| VStateless_class& cclass=*cclasses.get(i); | |
| // locate and execute possible @conf[] static | |
| 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*/); | |
| // locate and execute possible @auto[] static method | cclass.enable_default_setter(); |
| execute_method(cclass, *auto_method_name, false /*no result needed*/); | } |
| return &cclass; | |
| } | } |
| const String& Request::relative(const char *apath, const String& relative_name) { | const String& Request::relative(const char* apath, const String& relative_name) { |
| int lpath_buf_size=strlen(apath)+1; | char *hpath=pa_strdup(apath); |
| char *lpath=(char *)malloc(lpath_buf_size); | String& result=*new String; |
| memcpy(lpath, apath, lpath_buf_size); | if(rsplit(hpath, '/')) // if something/splitted |
| if(!rsplit(lpath, '/')) | result << hpath << "/"; |
| strcpy(lpath, "."); | result << relative_name; |
| String& result=*NEW String(pool(), lpath); | return result; |
| result << "/" << relative_name; | |
| return result; | |
| } | } |
| const String& Request::absolute(const String& relative_name) { | const String& Request::absolute(const String& relative_name) { |
| char *relative_name_cstr=relative_name.cstr(); | if(relative_name.first_char()=='/') { |
| if(relative_name_cstr[0]=='/') { | String& result=*new String(pa_strdup(request_info.document_root)); |
| String& result=*NEW String(pool(), info.document_root); | |
| result << relative_name; | result << relative_name; |
| return result; | return result; |
| } else | } else |
| return relative(info.path_translated, relative_name); | 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(const Hash::Key& aattribute, Hash::Val *ameaning, | #ifndef DOXYGEN |
| void *info) { | class Add_header_attribute_info |
| String *attribute_to_exclude=static_cast<String *>(info); | { |
| if(aattribute==*attribute_to_exclude) | public: |
| Add_header_attribute_info(Request& ar) : r(ar), add_last_modified(true) {} | |
| Request& r; | |
| bool add_last_modified; | |
| }; | |
| #endif | |
| static void add_header_attribute(HashStringValue::key_type name, HashStringValue::value_type value, Add_header_attribute_info* info) { | |
| if(name==BODY_NAME_UPPER || name==DOWNLOAD_NAME_UPPER || name==CHARSET_NAME_UPPER) | |
| return; | return; |
| if(name==LAST_MODIFIED_NAME_UPPER) | |
| info->add_last_modified=false; | |
| const char* aname=String(name, String::L_URI).untaint_and_transcode_cstr(String::L_URI, &info->r.charsets); | |
| SAPI::add_header_attribute(info->r.sapi_info, | |
| 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, | |
| bool header_only, | |
| VFile& body_file, | |
| Value* body_file_content_type) { | |
| // transcode text body when "text/*" or simple result | |
| 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, | |
| r.charsets.source(), | |
| r.charsets.client()); | |
| // prepare header: Content-Length | |
| SAPI::add_header_attribute(r.sapi_info, HTTP_CONTENT_LENGTH, format(output.length, "%u")); | |
| Value& lmeaning=*static_cast<Value *>(ameaning); | // send header |
| Pool& pool=lmeaning.pool(); | SAPI::send_header(r.sapi_info); |
| // send body | |
| if(!header_only) | |
| SAPI::send_body(r.sapi_info, output.str, output.length); | |
| } | |
| SAPI::add_header_attribute(pool, | #ifndef DOXYGEN |
| aattribute.cstr(String::UL_AS_IS), | struct Range |
| attributed_meaning_to_string(lmeaning, String::UL_HTTP_HEADER).cstr()); | { |
| size_t start; | |
| size_t end; | |
| }; | |
| #endif | |
| static void parse_range(const String* s, Array<Range> &ar) { | |
| const char *p = s->cstr(); | |
| if(s->starts_with("bytes=")) | |
| p += 6; | |
| Range r; | |
| while(*p){ | |
| r.start = (size_t)-1; | |
| r.end = (size_t)-1; | |
| if(*p >= '0' && *p <= '9'){ | |
| r.start = atol(p); | |
| while(*p>='0' && *p<='9') ++p; | |
| } | |
| if(*p++ != '-') break; | |
| if(*p >= '0' && *p <= '9'){ | |
| r.end = atol(p); | |
| while(*p>='0' && *p<='9') ++p; | |
| } | |
| if(*p == ',') ++p; | |
| ar += r; | |
| } | |
| } | } |
| void Request::output_result(const VFile& body_file, bool header_only) { | |
| static void output_pieces(Request& r, | |
| bool header_only, | |
| 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; | |
| char buf[BUFSIZE]; | |
| const char *range = SAPI::Env::get(r.sapi_info, "HTTP_RANGE"); | |
| size_t offset=0; | |
| size_t part_length=content_length; | |
| if(range){ | |
| Array<Range> ar; | |
| parse_range(new String(range), ar); | |
| size_t count = ar.count(); | |
| if(count == 1){ | |
| Range &rg = ar.get_ref(0); | |
| if(rg.start == (size_t)-1 && rg.end == (size_t)-1){ | |
| SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "416 Requested Range Not Satisfiable"); | |
| return; | |
| } | |
| if(rg.start == (size_t)-1 && rg.end != (size_t)-1){ | |
| rg.start = content_length - rg.end; | |
| rg.end = content_length; | |
| offset += rg.start; | |
| part_length = rg.end-rg.start; | |
| }else if(rg.start != (size_t)-1 && rg.end == (size_t)-1){ | |
| rg.end = content_length-1; | |
| offset += rg.start; | |
| part_length -= rg.start; | |
| } | |
| if(part_length == 0){ | |
| SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "204 No Content"); | |
| return; | |
| } | |
| 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); | |
| SAPI::add_header_attribute(r.sapi_info, "content-range", buf); | |
| }else if(count != 0){ | |
| SAPI::add_header_attribute(r.sapi_info, HTTP_STATUS, "501 Not Implemented"); | |
| return; | |
| } | |
| } | |
| SAPI::add_header_attribute(r.sapi_info, HTTP_CONTENT_LENGTH, format(part_length, "%u")); | |
| if(add_last_modified) | |
| SAPI::add_header_attribute(r.sapi_info, "last-modified", attributed_meaning_to_string(date, String::L_AS_IS, true).cstr()); | |
| SAPI::send_header(r.sapi_info); | |
| const String& filespec=r.absolute(filename); | |
| size_t sent = 0; | |
| if(!header_only){ | |
| size_t to_read = 0; | |
| size_t size = 0; | |
| do{ | |
| to_read = part_length<BUFSIZE?part_length:BUFSIZE; | |
| File_read_result read_result=file_read(r.charsets, filespec, | |
| false /*as text*/, 0/*params*/, true/*fail on problem*/, | |
| buf, offset, to_read); | |
| to_read=read_result.length; | |
| if(to_read == 0) | |
| break; | |
| offset += to_read; | |
| size = SAPI::send_body(r.sapi_info, read_result.str, to_read); | |
| sent += size; | |
| if(size != to_read) | |
| break; | |
| part_length -= to_read; | |
| }while(part_length); | |
| } | |
| } | |
| void Request::output_result(VFile* body_file, bool header_only, bool as_attachment) { | |
| // header: cookies | // header: cookies |
| cookie.output_result(); | cookie.output_result(sapi_info); |
| // set content-type | // _file_ content-type might be specified |
| if(String *body_file_content_type=static_cast<String *>( | Value* body_file_content_type=body_file->fields().get(content_type_name); |
| body_file.fields().get(*vfile_mime_type_name))) { | |
| // Content-Disposition | |
| Value* vfile_name=body_file->fields().get(name_name); | |
| if(!vfile_name) { | |
| vfile_name=body_file->fields().get(response_body_file_name); | |
| if(vfile_name) { | |
| char* name_cstr=vfile_name->as_string().cstrm(); | |
| if(char *after_slash=rsplit(name_cstr, '\\')) | |
| name_cstr=after_slash; | |
| if(char *after_slash=rsplit(name_cstr, '/')) | |
| name_cstr=after_slash; | |
| vfile_name=new VString(*new String(name_cstr)); | |
| } | |
| } | |
| if(vfile_name) { | |
| const String& sfile_name=vfile_name->as_string(); | |
| if(sfile_name!=NONAME_DAT) { | |
| VHash& hash=*new VHash(); | |
| HashStringValue &h=hash.hash(); | |
| 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))); | |
| response.fields().put(content_disposition_name_upper, &hash); | |
| if(!body_file_content_type) | |
| body_file_content_type=new VString(mime_type_of(sfile_name.cstr())); | |
| } | |
| } | |
| // set 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))); |
| default_content_type?default_content_type | |
| :NEW VString(*NEW String(pool(), DEFAULT_CONTENT_TYPE))); | |
| } | |
| // content-disposition | |
| if(VString *vfile_name=static_cast<VString *>(body_file.fields().get(*name_name))) | |
| if(vfile_name->string()!=NONAME_DAT) { | |
| VHash& vhash=*NEW VHash(pool()); | |
| vhash.hash().put(*content_disposition_filename_name, vfile_name); | |
| response.fields().put(*content_disposition_name, &vhash); | |
| } | |
| // prepare header: $response:fields without :body | |
| response.fields().for_each(add_header_attribute, /*excluding*/ body_name); | |
| // prepare... | |
| const void *body=body_file.value_ptr(); | |
| size_t content_length=body_file.value_size(); | |
| // prepare header: content-length | |
| if(content_length) { // useful for redirecting [header "location: http://..."] | |
| char content_length_cstr[MAX_NUMBER]; | |
| snprintf(content_length_cstr, MAX_NUMBER, "%u", content_length); | |
| SAPI::add_header_attribute(pool(), "content-length", content_length_cstr); | |
| } | } |
| // send header | // prepare header: $response:fields without :body, :download and :charset |
| SAPI::send_header(pool()); | Add_header_attribute_info info(*this); |
| response.fields().for_each<Add_header_attribute_info*>(add_header_attribute, &info); | |
| // send body | |
| if(!header_only) | if(Value* vresponse_body_file=body_file->fields().get(response_body_file_name)) { |
| SAPI::send_body(pool(), body, content_length); | // $response:[download|body][$.file[filespec]] -- optput specified file |
| const String& sresponse_body_file=vresponse_body_file->as_string(); | |
| size_t content_length=0; | |
| time_t atime=0, mtime=0, ctime=0; | |
| file_stat(absolute(sresponse_body_file), | |
| content_length, | |
| atime, mtime, ctime); | |
| VDate* vdate=0; | |
| if(Value* v=body_file->fields().get("mdate")) { | |
| if(Value* vdatep=v->as(VDATE_TYPE)) | |
| vdate=static_cast<VDate*>(vdatep); | |
| else | |
| throw Exception(PARSER_RUNTIME, 0, "mdate must be a date"); | |
| } | |
| if(!vdate) | |
| vdate=new VDate((pa_time_t)mtime); | |
| output_pieces(*this, header_only, | |
| sresponse_body_file, | |
| content_length, | |
| *vdate, | |
| info.add_last_modified); | |
| } else { | |
| if(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(pool(), ++cext); | String sext(++cext); |
| if(mime_types->locate(0, sext)) | Table::Action_options options; |
| if(const String *result=mime_types->item(1)) | if(mime_types->locate(0, sext.change_case(charsets.source(), String::CC_LOWER), options)) { |
| if(const String* result=mime_types->item(1)) | |
| return *result; | return *result; |
| else | else |
| THROW(0, 0, | throw Exception(PARSER_RUNTIME, |
| mime_types->origin_string(), | 0, |
| "MIME-TYPE table column elements must not be empty"); | MIME_TYPES_NAME " table column elements must not be empty"); |
| } | |
| } | } |
| return *NEW String(pool(), "application/octet-stream"); | |
| return *new String("application/octet-stream"); | |
| } | |
| const String* Request::get_used_filename(uint file_no){ | |
| if(file_no < file_list.count()) | |
| return new String(file_list[file_no], String::L_TAINTED); | |
| return 0; | |
| } | |
| #ifdef XML | |
| xmlChar* Request::transcode(const String& s) { | |
| return charsets.source().transcode(s); | |
| } | |
| xmlChar* Request::transcode(const String::Body s) { | |
| return charsets.source().transcode(s); | |
| } | |
| const String& Request::transcode(const xmlChar* s) { | |
| return charsets.source().transcode(s); | |
| } | |
| #endif | |
| Request::Exception_details Request::get_details(const Exception& e) { | |
| const String* problem_source=e.problem_source(); | |
| 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 | |
| if(const char* type=e.type(true)) | |
| hash.put(exception_type_part_name, new VString(*new String(type))); | |
| // $.source | |
| if(problem_source) | |
| hash.put(exception_source_part_name, new VString(*new String(*problem_source, String::L_TAINTED))); | |
| // $.file $.lineno $.colno | |
| if(origin.file_no){ | |
| hash.put("file", new VString(*new String(file_list[origin.file_no], String::L_TAINTED))); | |
| hash.put("lineno", new VInt(1+origin.line)); | |
| hash.put("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, String::L_TAINTED))); | |
| // $.handled(0) | |
| 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); | |
| } | |
| Temp_value_element::~Temp_value_element() { | |
| frequest.put_element(fwhere, fname, saved ? saved : VVoid::get()); | |
| } | } |