|
|
| version 1.32, 2001/03/14 09:02:52 | version 1.152, 2001/08/27 13:27:26 |
|---|---|
| Line 1 | Line 1 |
| /* | /** @file |
| Parser | Parser: request class main part. @see compile.C and execute.C. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | |
| $Id$ | Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include <string.h> | #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_common.h" | |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_wwrapper.h" | #include "pa_wwrapper.h" |
| #include "pa_common.h" | |
| #include "pa_vclass.h" | #include "pa_vclass.h" |
| #include "_root.h" | |
| #include "_env.h" | |
| #include "_table.h" | |
| #include "pa_globals.h" | #include "pa_globals.h" |
| #include "pa_vint.h" | #include "pa_vint.h" |
| #include "pa_vmframe.h" | #include "pa_vmethod_frame.h" |
| #include "pa_types.h" | #include "pa_types.h" |
| #include "pa_vtable.h" | |
| #include "pa_vfile.h" | |
| #include "pa_dictionary.h" | |
| /// content type of exception response, when no @MAIN:exception handler defined | |
| const char *UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; | |
| #define NEW_STRING(name, value) name=NEW String(pool()); name->APPEND_CONST(value) | /// content type of response when no $MAIN:defaults.content-type defined |
| #define LOCAL_STRING(name, value) String name(pool()); name.APPEND_CONST(value) | const char *DEFAULT_CONTENT_TYPE="text/html"; |
| const char *ORIGINS_CONTENT_TYPE="text/plain"; | |
| Methoded *MOP_create(Pool&); | |
| // | |
| Request::Request(Pool& apool, | Request::Request(Pool& apool, |
| String::Untaint_lang alang, | Info& ainfo, |
| const char *adocument_root, | String::Untaint_lang adefault_lang) : Pooled(apool), |
| const char *apage_filespec) : Pooled(apool), | |
| stack(apool), | stack(apool), |
| root_class(apool), | OP(*MOP_create(apool)), |
| env_class(apool), | env(apool), |
| form_class(apool), | form(apool), |
| math(apool), | |
| request(apool, *this), | |
| response(apool), | |
| cookie(apool), | |
| fclasses(apool), | fclasses(apool), |
| flang(alang), | fdefault_lang(adefault_lang), flang(adefault_lang), |
| fdocument_root(adocument_root), | info(ainfo), |
| fpage_filespec(apage_filespec) | post_data(0), post_size(0), |
| used_files(apool), | |
| default_content_type(0), | |
| mime_types(0), | |
| main_class(0), | |
| connection(0), | |
| pcre_tables(0), | |
| classes_conf(apool), | |
| anti_endless_execute_recoursion(0) | |
| { | { |
| // root superclass, | /// directly used |
| // parent of all classes, | // operators |
| // operators holder | OP.register_directly_used(*this); |
| initialize_root_class(pool(), root_class); | // classes: |
| classes().put(*root_class_name, &root_class); | // table, file, random, mail, image, ... |
| // table class | methoded_array->register_directly_used(*this); |
| classes().put(*table_class_name, table_class); | |
| // table_class->set_name(*table_class_name); | |
| /// methodless | |
| // env class | // env class |
| classes().put(*env_class_name, &env_class); | classes().put(*NEW String(pool(), ENV_CLASS_NAME), &env); |
| // request class | |
| classes().put(*NEW String(pool(), REQUEST_CLASS_NAME), &request); | |
| // cookie class | |
| classes().put(*NEW String(pool(), COOKIE_CLASS_NAME), &cookie); | |
| /// methoded | |
| // response class | |
| classes().put(response.get_class()->name(), &response); | |
| /// bases used | |
| // form class | // form class |
| classes().put(*form_class_name, &form_class); | classes().put(form.get_class()->base()->name(), &form); |
| // math class | |
| classes().put(math.get_class()->base()->name(), &math); | |
| } | } |
| char *Request::core(const char *sys_auto_path1, | static void element2ctypes(unsigned char *tables, |
| const char *sys_auto_path2) { | Value& ctype, const String& name, |
| char *result; | unsigned char bit, |
| VStateless_class *main_class=0; | int group_offset=-1, |
| bool skip_ws=true) { | |
| Value *value=ctype.get_element(name); | |
| if(!value) | |
| return; | |
| unsigned char *ctypes_table=tables+ctypes_offset; | |
| const unsigned char *cstr= | |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| if(skip_ws && (c=='\n' || c=='\t' || c==' ')) | |
| continue; | |
| ctypes_table[c]|=bit; | |
| if(group_offset>=0) | |
| tables[cbits_offset+group_offset+c/8] |= 1 << (c%8); | |
| } | |
| } | |
| static void cstr2ctypes(unsigned char *tables, const unsigned char *cstr, | |
| unsigned char bit) { | |
| unsigned char *ctypes_table=tables+ctypes_offset; | |
| ctypes_table[0]=bit; | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| ctypes_table[c]|=bit; | |
| } | |
| } | |
| static void prepare_case_tables(unsigned char *tables) { | |
| unsigned char *lcc_table=tables+lcc_offset; | |
| unsigned char *fcc_table=tables+fcc_offset; | |
| for(int i=0; i<0x100; i++) | |
| lcc_table[i]=fcc_table[i]=i; | |
| } | |
| static void element2case(unsigned char *tables, Value& ctype, const String& name) { | |
| Value *value=ctype.get_element(name); | |
| if(!value) | |
| return; | |
| unsigned char *lcc_table=tables+lcc_offset; | |
| unsigned char *fcc_table=tables+fcc_offset; | |
| const unsigned char *cstr= | |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | |
| unsigned char from=0; | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| if(c=='\n' || c=='\t' || c==' ') | |
| continue; | |
| if(from) { | |
| lcc_table[from]=c; | |
| fcc_table[from]=c; fcc_table[c]=from; | |
| from=0; | |
| } else | |
| from=c; | |
| } | |
| } | |
| /** | |
| load MAIN class, execute @main. | |
| MAIN class consists of all the auto.p files we'd manage to find | |
| plus | |
| the file user requested us to process | |
| all located classes become children of one another, | |
| composing class we name 'MAIN' | |
| */ | |
| void Request::core(const char *root_auto_path, bool root_auto_fail, | |
| const char *site_auto_path, bool site_auto_fail, | |
| bool header_only) { | |
| //_asm { int 3 } | |
| bool need_rethrow=false; Exception rethrow_me; | |
| TRY { | TRY { |
| char *auto_filespec=(char *)malloc(MAX_STRING); | char *auto_filespec=(char *)malloc(MAX_STRING); |
| // load MAIN class, | // loading root auto.p |
| // it consists of all the auto.p files we'd manage to find | if(root_auto_path) { |
| // plus | String& filespec=*NEW String(pool()); |
| // the file user requested us to process | filespec.APPEND_CLEAN(root_auto_path, 0, "root_auto", 0); |
| // all located classes become children of one another, | filespec << "/" AUTO_FILE_NAME; |
| // composing class we name 'MAIN' | |
| // loading system auto.p 1 | |
| if(sys_auto_path1) { | |
| strncpy(auto_filespec, sys_auto_path1, MAX_STRING-strlen(AUTO_FILE_NAME)); | |
| strcat(auto_filespec, AUTO_FILE_NAME); | |
| main_class=use_file( | main_class=use_file( |
| auto_filespec, false/*ignore possible read problem*/, | filespec, |
| main_class_name); | true/*ignore class_path*/, root_auto_fail, |
| main_class_name, main_class); | |
| } | } |
| // loading system auto.p 2 | // configure root options |
| if(sys_auto_path2) { | // until someone with less privileges have overriden them |
| strncpy(auto_filespec, sys_auto_path2, MAX_STRING-strlen(AUTO_FILE_NAME)); | OP.configure_admin(*this); |
| strcat(auto_filespec, AUTO_FILE_NAME); | methoded_array->configure_admin(*this); |
| VStateless_class *main_class=use_file( | |
| auto_filespec, false/*ignore possible read problem*/, | // loading site auto.p |
| main_class_name); | if(site_auto_path) { |
| String& filespec=*NEW String(pool()); | |
| filespec.APPEND_CLEAN(site_auto_path, 0, "site_auto", 0); | |
| filespec << "/" AUTO_FILE_NAME; | |
| main_class=use_file( | |
| filespec, | |
| true/*ignore class_path*/, site_auto_fail, | |
| main_class_name, main_class); | |
| } | } |
| // TODO: использовать $MAIN:limits здесь, пока их не сломали враги | // loading auto.p files from document_root/.. |
| // to the one beside requested file. | |
| // all assigned bases from upper dir | |
| { | |
| const char *after=info.path_translated; | |
| size_t drlen=strlen(info.document_root); | |
| if(memcmp(after, info.document_root, drlen)==0) { | |
| after+=drlen; | |
| if(after[-1]=='/') | |
| --after; | |
| } | |
| int step=0; | |
| while(const char *before=strchr(after, '/')) { | |
| String& sfile_spec=*NEW String(pool()); | |
| if(after!=info.path_translated) { | |
| sfile_spec.APPEND_CLEAN( | |
| info.path_translated, before-info.path_translated, | |
| "path-translated-scanned", step++); | |
| sfile_spec << "/" AUTO_FILE_NAME; | |
| main_class=use_file(sfile_spec, | |
| true/*ignore class_path*/, false/*ignore read problem*/, | |
| main_class_name, main_class); | |
| } | |
| after=before+1; | |
| } | |
| } | |
| // TODO: load site auto.p files, all assigned bases from upper dir | // compile requested file |
| char *site_auto_file="Y:\\parser3\\src\\auto.p"; | String& spath_translated=*NEW String(pool()); |
| main_class=use_file( | spath_translated.APPEND_TAINTED(info.path_translated, 0, "user-request", 0); |
| site_auto_file, false/*ignore possible read problem*/, | main_class=use_file(spath_translated, |
| true/*ignore class_path*/, true/*don't ignore read problem*/, | |
| main_class_name, main_class); | main_class_name, main_class); |
| // there must be some auto.p | // configure not-root=user options |
| if(!main_class) | OP.configure_user(*this); |
| THROW(0,0, | methoded_array->configure_user(*this); |
| 0, | |
| "no 'auto.p' found (nither system nor any site's)"); | // $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(NEW Dictionary(*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; | |
| // compiling requested file | // filling form fields |
| main_class=use_file(fpage_filespec, true/*don't ignore read problem*/, | form.fill_fields(*this); |
| main_class_name, main_class); | |
| // filling cookies | |
| cookie.fill_fields(*this); | |
| // execute @main[] | // execute @main[] |
| result=execute_method(*main_class, *main_method_name); | const String *body_string=execute_virtual_method( |
| if(!result) | *main_class, *main_method_name); |
| if(!body_string) | |
| THROW(0,0, | THROW(0,0, |
| 0, | 0, |
| "'"MAIN_METHOD_NAME"' method not found"); | "'"MAIN_METHOD_NAME"' method not found"); |
| VString body_vstring_before_post_process(*body_string); | |
| VString *body_vstring_after_post_process=&body_vstring_before_post_process; | |
| // @postprocess | |
| if(Value *value=main_class->get_element(*post_process_method_name)) | |
| if(Junction *junction=value->get_junction()) | |
| if(const Method *method=junction->method) { | |
| // preparing to pass parameters to | |
| // @postprocess[data] | |
| VMethodFrame frame(pool(), value->name(), *junction); | |
| frame.set_self(*main_class); | |
| frame.store_param(method->name, | |
| &body_vstring_before_post_process); | |
| body_vstring_after_post_process= | |
| NEW VString(*execute_method(frame, *method)); | |
| } | |
| bool origins_mode=main_class->get_element(*origins_mode_name)!=0; | |
| const VFile *body_file=body_vstring_after_post_process->as_vfile( | |
| String::UL_UNSPECIFIED, origins_mode); | |
| // extract response body | |
| 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(); | |
| else if(origins_mode) | |
| response.fields().put(*content_type_name, | |
| NEW VString(*NEW String(pool(), ORIGINS_CONTENT_TYPE))); | |
| // OK. write out the result | |
| output_result(*body_file, header_only); | |
| } | } |
| CATCH(e) { | CATCH(e) { // request handling problem |
| // we're returning not result, but error explanation | |
| TRY { | TRY { |
| // we're returning not result, but error explanation | // log the beast |
| result=0; | 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 | |
| const String *body_string=0; | |
| if(main_class) { // we've managed to end up with some main_class | if(main_class) { // we've managed to end up with some main_class |
| // 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... |
| Line 121 char *Request::core(const char *sys_auto | Line 372 char *Request::core(const char *sys_auto |
| if(const Method *method=junction->method) { | if(const Method *method=junction->method) { |
| // preparing to pass parameters to | // preparing to pass parameters to |
| // @exception[origin;source;comment;type;code] | // @exception[origin;source;comment;type;code] |
| VMethodFrame *frame=NEW VMethodFrame(pool(), *junction); | VMethodFrame frame(pool(), value->name(), *junction); |
| frame.set_self(*main_class); | |
| const String *problem_source=e.problem_source(); | const String *problem_source=e.problem_source(); |
| // origin | // origin |
| LOCAL_STRING(origin_name, "origin"); | Value *origin_value=0; |
| VString *origin_value=0; | |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| const Origin& origin=problem_source->origin(); | if(problem_source && problem_source->size()) { |
| if(origin.file) { | const Origin& origin=problem_source->origin(); |
| char *buf=(char *)malloc(MAX_STRING); | if(origin.file) { |
| snprintf(buf, MAX_STRING, "%s(%d): ", | char *buf=(char *)malloc(MAX_STRING); |
| origin.file, 1+origin.line); | size_t buf_size=snprintf(buf, MAX_STRING, "%s(%d):", |
| String *NEW_STRING(origin_file_line, buf); | origin.file, 1+origin.line); |
| origin_value=NEW VString(*origin_file_line); | String *origin_file_line=NEW String(pool(), |
| buf, buf_size, true); | |
| origin_value=NEW VString(*origin_file_line); | |
| } | |
| } | } |
| #endif | #endif |
| frame->store_param(origin_name, origin_value); | frame.store_param(method->name, |
| origin_value?origin_value:NEW VVoid(pool())); | |
| // source | // source |
| LOCAL_STRING(source_name, "source"); | Value *source_value=0; |
| frame->store_param(source_name, | if(problem_source && problem_source->size()) { |
| NEW VString(*problem_source)); | 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 | // comment |
| LOCAL_STRING(comment_name, "comment"); | String *comment_value=NEW String(pool(), |
| String *NEW_STRING(comment_value, e.comment()); | e.comment(), 0, true); |
| frame->store_param(comment_name, | frame.store_param(method->name, |
| NEW VString(*comment_value)); | NEW VString(*comment_value)); |
| // type | // type |
| LOCAL_STRING(type_name, "type"); | |
| Value *type_value; | Value *type_value; |
| if(e.type()) | if(e.type()) { |
| type_value=NEW VString(*e.type()); | String& type_copy=*NEW String(pool()); |
| else | type_value=NEW VString(type_copy.append(*e.type(), |
| type_value=NEW VUnknown(pool()); | flang, true)); |
| frame->store_param(type_name, type_value); | } else |
| type_value=NEW VVoid(pool()); | |
| frame.store_param(method->name, type_value); | |
| // code | // code |
| LOCAL_STRING(code_name, "code"); | |
| Value *code_value; | Value *code_value; |
| if(e.code()) | if(e.code()) { |
| code_value=NEW VString(*e.code()); | String& code_copy=*NEW String(pool()); |
| else | code_value=NEW VString(code_copy.append(*e.code(), |
| code_value=NEW VUnknown(pool()); | flang, true)); |
| frame->store_param(code_name, code_value); | } else |
| code_value=NEW VVoid(pool()); | |
| result=execute_method(*frame, *method); | frame.store_param(method->name, code_value); |
| // future $response:body= | |
| // execute ^exception[origin;source;comment;type;code] | |
| body_string=execute_method(frame, *method); | |
| } | } |
| } | } |
| // couldn't report an error beautifully, doing that ugly | if(!body_string) { // couldn't report an error beautifully? |
| if(!result) { | // doing that ugly |
| result=(char *)malloc(MAX_STRING); | |
| result[0]=0; | // make up result: $origin $source $comment $type $code |
| char *buf=(char *)malloc(MAX_STRING); | |
| size_t printed=0; | size_t printed=0; |
| const String *problem_source=e.problem_source(); | const String *problem_source=e.problem_source(); |
| if(problem_source) { | if(problem_source) { |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| const Origin& origin=problem_source->origin(); | const Origin& origin=problem_source->origin(); |
| if(origin.file) | if(origin.file) |
| printed+=snprintf(result+printed, MAX_STRING-printed, "%s(%d): ", | printed+=snprintf(buf+printed, MAX_STRING-printed, "%s(%d): ", |
| origin.file, 1+origin.line); | origin.file, 1+origin.line); |
| #endif | #endif |
| printed+=snprintf(result+printed, MAX_STRING-printed, "'%s' ", | printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", |
| problem_source->cstr()); | problem_source->cstr(String::UL_AS_IS)); |
| } | } |
| printed+=snprintf(result+printed, MAX_STRING-printed, "%s", | printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", |
| e.comment()); | e.comment()); |
| const String *type=e.type(); | const String *type=e.type(); |
| if(type) { | if(type) { |
| printed+=snprintf(result+printed, MAX_STRING-printed, " type: %s", | printed+=snprintf(buf+printed, MAX_STRING-printed, " type: %s", |
| type->cstr()); | type->cstr(String::UL_AS_IS)); |
| const String *code=e.code(); | const String *code=e.code(); |
| if(code) | if(code) |
| printed+=snprintf(result+printed, MAX_STRING-printed, ", code: %s", | printed+=snprintf(buf+printed, MAX_STRING-printed, ", code: %s", |
| code->cstr()); | code->cstr(String::UL_AS_IS)); |
| } | } |
| // future $response:content-type | |
| response.fields().put(*content_type_name, | |
| NEW VString(*NEW String(pool(), UNHANDLED_EXCEPTION_CONTENT_TYPE))); | |
| // future $response:body | |
| body_string=NEW String(pool(), buf); | |
| } | } |
| VString body_vstring(*body_string); | |
| const VFile *body_file=body_vstring.as_vfile(); | |
| // ERROR. write it out | |
| output_result(*body_file, header_only); | |
| } | } |
| CATCH(e) { | CATCH(e) { |
| // exception in exception handler occured | // exception in request exception handler |
| // probably totally out of memory | // remember to rethrow it |
| // can't say anything about such sad story | rethrow_me=e; need_rethrow=true; |
| // would just return 0 | |
| result=0; | |
| } | } |
| END_CATCH | END_CATCH |
| } | } |
| END_CATCH | END_CATCH // do not use pool() after this point - no exception handler set |
| // any throw() would try to use zero exception() pointer | |
| return result; | if(need_rethrow) // were there an exception for us to rethrow? |
| THROW(rethrow_me.type(), rethrow_me.code(), | |
| rethrow_me.problem_source(), | |
| rethrow_me.comment()); | |
| } | } |
| VStateless_class *Request::use_file( | VStateless_class *Request::use_file(const String& file_name, |
| const char *file, bool fail_on_read_problem, | bool ignore_class_path, bool fail_on_read_problem, |
| const String *name, | const String *name, |
| VStateless_class *base_class) { | VStateless_class *base_class) { |
| // TODO: обнаружить|решить cyclic dependences | // cyclic dependence check |
| char *source=file_read(pool(), file, fail_on_read_problem); | if(used_files.get(file_name)) |
| return base_class; | |
| used_files.put(file_name, (Hash::Val *)true); | |
| const String *file_spec; | |
| if(ignore_class_path || file_name.first_char()=='/') { | |
| // ignore_class_path | absolute path, no need to scan MAIN:class_path | |
| file_spec=&file_name; | |
| } else { | |
| file_spec=0; | |
| if(main_class) | |
| if(Value *element=main_class->get_element(*class_path_name)) | |
| if(Table *table=element->get_table()) { | |
| int size=table->size(); | |
| for(int i=size; i--; ) { | |
| const String& path=*static_cast<Array *>(table->get(i))->get_string(0); | |
| String *test_file_spec=NEW String(path); | |
| *test_file_spec << "/"; | |
| *test_file_spec << file_name; | |
| if(file_readable(*test_file_spec)) { | |
| file_spec=test_file_spec; // found along class_path | |
| break; | |
| } | |
| } | |
| if(!file_spec) | |
| THROW(0, 0, | |
| &file_name, | |
| "not found along " CLASS_PATH_NAME); | |
| } | |
| if(!file_spec) | |
| THROW(0, 0, | |
| &file_name, | |
| "can not be found because no " CLASS_PATH_NAME " were specified"); | |
| } | |
| char *source=file_read_text(pool(), *file_spec, fail_on_read_problem); | |
| if(!source) | if(!source) |
| return base_class; | return base_class; |
| return use_buf(source, file, 0/*new class*/, name, base_class); | return use_buf(source, file_spec->cstr(), 0/*new class*/, name, base_class); |
| } | } |
| VStateless_class *Request::use_buf( | VStateless_class *Request::use_buf(const char *source, const char *file, |
| const char *source, const char *file, | |
| VStateless_class *aclass, const String *name, | VStateless_class *aclass, const String *name, |
| VStateless_class *base_class) { | VStateless_class *base_class) { |
| // compile loaded class | // compile loaded class |
| VStateless_class& cclass=COMPILE(source, aclass, name, base_class, file); | VStateless_class& cclass=COMPILE(source, aclass, name, base_class, file); |
| // locate and execute possible @auto[] static method | // locate and execute possible @auto[] static method |
| execute_method(cclass, *auto_method_name, false /*no result needed*/); | execute_nonvirtual_method(cclass, *auto_method_name, false /*no result needed*/); |
| return &cclass; | return &cclass; |
| } | } |
| void Request::fail_if_junction_(bool is, | const String& Request::relative(const char *apath, const String& relative_name) { |
| Value& value, const String& method_name, char *msg) { | int lpath_buf_size=strlen(apath)+1; |
| char *lpath=(char *)malloc(lpath_buf_size); | |
| // fail_if_junction(true, junction = fail | memcpy(lpath, apath, lpath_buf_size); |
| // fail_if_junction(false, not junction = fail | if(!rsplit(lpath, '/')) |
| if((value.get_junction()!=0) ^ !is) | strcpy(lpath, "."); |
| THROW(0, 0, | String& result=*NEW String(pool(), lpath); |
| &method_name, | result << "/" << relative_name; |
| msg); | |
| } | |
| char *Request::relative(const char *path, const char *file) { | |
| char *result=(char *)malloc(strlen(path)+strlen(file)+1); | |
| strcpy(result, path); | |
| rsplit(result, PATH_DELIMITER_CHAR); | |
| strcat(result, PATH_DELIMITER_STRING); | |
| strcat(result, file); | |
| return result; | return result; |
| } | } |
| char *Request::absolute(const char *name) { | const String& Request::absolute(const String& relative_name) { |
| if(name[0]=='/') { | char *relative_name_cstr=relative_name.cstr(); |
| char *result=(char *)malloc(strlen(fdocument_root)+strlen(name)+1); | if(relative_name_cstr[0]=='/') { |
| strcpy(result, fdocument_root); | String& result=*NEW String(pool(), info.document_root); |
| strcat(result, name); | result << relative_name; |
| return result; | return result; |
| } else | } else |
| return relative(fpage_filespec, name); | return relative(info.path_translated, relative_name); |
| } | |
| static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, | |
| void *info) { | |
| String *attribute_to_exclude=static_cast<String *>(info); | |
| if(aattribute==*attribute_to_exclude) | |
| return; | |
| Value& lmeaning=*static_cast<Value *>(ameaning); | |
| Pool& pool=lmeaning.pool(); | |
| SAPI::add_header_attribute(pool, | |
| aattribute.cstr(String::UL_AS_IS), | |
| attributed_meaning_to_string(lmeaning, String::UL_HTTP_HEADER).cstr()); | |
| } | |
| void Request::output_result(const VFile& body_file, bool header_only) { | |
| // header: cookies | |
| cookie.output_result(); | |
| // set content-type | |
| if(String *body_file_content_type=static_cast<String *>( | |
| body_file.fields().get(*vfile_mime_type_name))) { | |
| // body file content type | |
| response.fields().put(*content_type_name, body_file_content_type); | |
| } else { | |
| // default content type | |
| response.fields().put_dont_replace(*content_type_name, | |
| 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 | |
| SAPI::send_header(pool()); | |
| // send body | |
| if(!header_only) | |
| SAPI::send_body(pool(), body, content_length); | |
| } | |
| const String& Request::mime_type_of(const char *user_file_name_cstr) { | |
| if(mime_types) | |
| if(const char *cext=strrchr(user_file_name_cstr, '.')) { | |
| String sext(pool(), ++cext); | |
| if(mime_types->locate(0, sext)) | |
| if(const String *result=mime_types->item(1)) | |
| return *result; | |
| else | |
| THROW(0, 0, | |
| mime_types->origin_string(), | |
| "MIME-TYPE table column elements must not be empty"); | |
| } | |
| return *NEW String(pool(), "application/octet-stream"); | |
| } | } |