|
|
| version 1.245.2.7, 2003/01/31 16:05:59 | version 1.245.2.34, 2003/03/08 16:37:19 |
|---|---|
| Line 16 static const char* IDENT_REQUEST_C="$Dat | Line 16 static const char* IDENT_REQUEST_C="$Dat |
| #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_dictionary.h" |
| #include "pa_charset.h" | #include "pa_charset.h" |
| #include "pa_charsets.h" | #include "pa_charsets.h" |
| #include "pa_cache_managers.h" | #include "pa_cache_managers.h" |
| #include "pa_vmail.h" | |
| // consts | // consts |
| Line 37 const char* ORIGINS_CONTENT_TYPE="text/p | Line 42 const char* ORIGINS_CONTENT_TYPE="text/p |
| // defines for globals | // defines for globals |
| #define MAIN_METHOD_NAME "main" | #define MAIN_METHOD_NAME "main" |
| #define AUTO_METHOD_NAME "auto" | |
| #define BODY_NAME "body" | |
| // globals | // globals |
| StringPtr main_method_name(new String(MAIN_METHOD_NAME)); | StringPtr main_method_name(new String(MAIN_METHOD_NAME)); |
| StringPtr auto_method_name(new String(AUTO_METHOD_NAME)); | |
| StringPtr content_disposition_name(new String(CONTENT_DISPOSITION_NAME)); | |
| StringPtr content_disposition_value(new String(CONTENT_DISPOSITION_VALUE)); | |
| StringPtr content_disposition_filename_name(new String(CONTENT_DISPOSITION_FILENAME_NAME)); | |
| StringPtr body_name(new String(BODY_NAME)); | |
| // defines for statics | // defines for statics |
| #define CHARSETS_NAME "CHARSETS" | #define CHARSETS_NAME "CHARSETS" |
| #define MAIN_CLASS_NAME "MAIN" | |
| #define MIME_TYPES_NAME "MIME-TYPES" | #define MIME_TYPES_NAME "MIME-TYPES" |
| #define ORIGINS_MODE_NAME "ORIGINS" | #define ORIGINS_MODE_NAME "ORIGINS" |
| #define AUTO_FILE_NAME "auto.p" | |
| #define CONF_METHOD_NAME "conf" | #define CONF_METHOD_NAME "conf" |
| #define AUTO_METHOD_NAME "auto" | |
| #define POST_PROCESS_METHOD_NAME "postprocess" | #define POST_PROCESS_METHOD_NAME "postprocess" |
| #define BODY_NAME "body" | |
| #define DOWNLOAD_NAME "download" | #define DOWNLOAD_NAME "download" |
| #define CLASS_PATH_NAME "CLASS_PATH" | #define CLASS_PATH_NAME "CLASS_PATH" |
| Line 63 static StringPtr main_class_name(new Str | Line 71 static StringPtr main_class_name(new Str |
| static StringPtr mime_types_name(new String(MIME_TYPES_NAME)); | static StringPtr mime_types_name(new String(MIME_TYPES_NAME)); |
| static StringPtr origins_mode_name(new String(ORIGINS_MODE_NAME)); | static StringPtr origins_mode_name(new String(ORIGINS_MODE_NAME)); |
| static StringPtr conf_method_name(new String(CONF_METHOD_NAME)); | static StringPtr conf_method_name(new String(CONF_METHOD_NAME)); |
| static StringPtr auto_method_name(new String(AUTO_METHOD_NAME)); | |
| static StringPtr post_process_method_name(new String(POST_PROCESS_METHOD_NAME)); | static StringPtr post_process_method_name(new String(POST_PROCESS_METHOD_NAME)); |
| static StringPtr body_name(new String(BODY_NAME)); | |
| static StringPtr download_name(new String(DOWNLOAD_NAME)); | static StringPtr download_name(new String(DOWNLOAD_NAME)); |
| static StringPtr class_path_name(new String(CLASS_PATH_NAME)); | static StringPtr class_path_name(new String(CLASS_PATH_NAME)); |
| Line 74 static StringPtr class_path_name(new Str | Line 80 static StringPtr class_path_name(new Str |
| // op.C | // op.C |
| VStateless_classPtr VClassMAIN_create(); | VStateless_classPtr VClassMAIN_create(); |
| // op.C | // op.C |
| VHashPtr exception2vhash(const Exception& e); | VHashPtr exception2vhash(Pool& pool, const Exception& e); |
| void lock_system_class(HashStringValue::key_type key, HashStringValue::value_type value, int) { | |
| if(VStateless_class *value_class=value->get_class()) | |
| value_class->lock(); | |
| } | |
| // | // |
| Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info, | Request::Request(Pool& apool, SAPI_Info& asapi_info, Request_info& arequest_info, |
| uchar adefault_lang, bool status_allowed): | String_UL adefault_lang, bool status_allowed): |
| // private | |
| fpool(apool), | |
| anti_endless_execute_recoursion(0), | |
| // public | |
| method_frame(0), | |
| rcontext(0), | |
| wcontext(0), | |
| flang(adefault_lang), | |
| fconnection(0), | |
| finterrupted(false), | |
| // public | |
| #ifdef RESOURCES_DEBUG | |
| sql_connect_time(0), | |
| sql_request_time(0), | |
| #endif | |
| // public | |
| sapi_info(asapi_info), | sapi_info(asapi_info), |
| request_info(arequest_info), | request_info(arequest_info), |
| fdefault_lang(adefault_lang), flang(adefault_lang), | |
| main_class(VClassMAIN_create()), | |
| charsets(pool(), *UTF8_charset, *UTF8_charset, *UTF8_charset), // default charsets | charsets(pool(), *UTF8_charset, *UTF8_charset, *UTF8_charset), // default charsets |
| response(new VResponse(arequest_info, charsets)), | main_class(VClassMAIN_create()), |
| form(new VForm), | form(new VForm), |
| mail(new VMail), | mail(new VMail), |
| cookie(new VCookie) | response(new VResponse(fpool, arequest_info, charsets)), |
| cookie(new VCookie), | |
| // private | |
| configure_admin_done(false), | |
| // private defaults | |
| fdefault_lang(adefault_lang), | |
| // private mime types | |
| mime_types(0) | |
| { | { |
| // maybe expire old caches | // maybe expire old caches |
| cache_managers.maybe_expire(); | cache_managers.maybe_expire(); |
| Line 104 Request::Request(SAPI_Info& asapi_info, | Line 130 Request::Request(SAPI_Info& asapi_info, |
| classes().put(main_class->name(), main_class); | classes().put(main_class->name(), 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(StringPtr(new String(ENV_CLASS_NAME)), | classes().put(StringPtr(new String(ENV_CLASS_NAME)), |
| ValuePtr(new VEnv(asapi_info))); | ValuePtr(new VEnv(pool(), asapi_info))); |
| // status class | // status class |
| if(status_allowed) | if(status_allowed) |
| classes().put(StringPtr(new String(STATUS_CLASS_NAME)), | classes().put(StringPtr(new String(STATUS_CLASS_NAME)), |
| ValuePtr(new VStatus)); | ValuePtr(new VStatus(pool()))); |
| // request class | // request class |
| classes().put(StringPtr(new String(REQUEST_CLASS_NAME)), | classes().put(StringPtr(new String(REQUEST_CLASS_NAME)), |
| ValuePtr(new VRequest(arequest_info, charsets))); | ValuePtr(new VRequest(arequest_info, charsets))); |
| Line 131 Request::Request(SAPI_Info& asapi_info, | Line 157 Request::Request(SAPI_Info& asapi_info, |
| classes().put(mail->get_class()->base_class()->name(), mail); | classes().put(mail->get_class()->base_class()->name(), mail); |
| // math class | // math class |
| { | { |
| ValuePtr math(new VMail); | ValuePtr math(new VMath); |
| classes().put(math->get_class()->base_class()->name(), math); | classes().put(math->get_class()->base_class()->name(), math); |
| } | } |
| // prevent system classes from modification [calling add_method] | |
| // ^process[$string:CLASS]{@method} prohibited from now on... | |
| classes().for_each(lock_system_class, 0); | |
| } | } |
| Request::~Request() { | Request::~Request() { |
| #ifdef XML | #ifdef XML |
| // 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(pool(), "warning: unreported xmlGenericErrors: %s", xml_generic_errors); | SAPI::log(sapi_info, "warning: unreported xmlGenericErrors: %s", xml_generic_errors); |
| free((void *)xml_generic_errors); | free((void *)xml_generic_errors); |
| } | } |
| #endif | #endif |
| } | } |
| Value* Request::get_self() { return method_frame?&method_frame->self():0; } | ValuePtr Request::get_self() { return method_frame?method_frame->get_self():ValuePtr(0); } |
| static void load_charset(HashStringValue::key_type akey, HashStringValue::value_type avalue, int) { | static void load_charset(HashStringValue::key_type akey, HashStringValue::value_type avalue, int) { |
| ::charsets.load_charset(akey, avalue->as_string(0)); | ::charsets.load_charset(akey, avalue->as_string(0)); |
| Line 182 void Request::configure_admin(VStateless | Line 204 void Request::configure_admin(VStateless |
| // 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); |
| } | } |
| /** | /** |
| Line 207 struct timeval mt[10]; | Line 229 struct timeval mt[10]; |
| gettimeofday(&mt[0],NULL); | gettimeofday(&mt[0],NULL); |
| #endif | #endif |
| try { | try { |
| char *auto_filespec=(char *)malloc(MAX_STRING); | |
| // loading config | // loading config |
| if(config_filespec) { | if(config_filespec) { |
| StringPtr filespec(new String); | StringPtr filespec(new String); |
| Line 259 gettimeofday(&mt[0],NULL); | Line 279 gettimeofday(&mt[0],NULL); |
| configure_admin(*main_class, StringPtr(0)); | configure_admin(*main_class, StringPtr(0)); |
| // configure not-method_frame=user options | // configure not-method_frame=user options |
| methoded_array.configure_user(*this); | methoded_array().configure_user(*this); |
| // $MAIN:MIME-TYPES | // $MAIN:MIME-TYPES |
| if(ValuePtr element=main_class->get_element(mime_types_name, *main_class, false)) | if(ValuePtr element=main_class->get_element(mime_types_name, *main_class, false)) |
| Line 267 gettimeofday(&mt[0],NULL); | Line 287 gettimeofday(&mt[0],NULL); |
| mime_types=table; | mime_types=table; |
| // filling form fields | // filling form fields |
| form->fill_fields_and_tables(charsets, request_info); | form->fill_fields_and_tables(pool(), charsets, request_info); |
| // filling cookies | // filling cookies |
| cookie->fill_fields(pool(), request_info); | cookie->fill_fields(pool(), request_info); |
| Line 280 gettimeofday(&mt[0],NULL); | Line 300 gettimeofday(&mt[0],NULL); |
| gettimeofday(&mt[1],NULL); | gettimeofday(&mt[1],NULL); |
| #endif | #endif |
| // execute @main[] | // execute @main[] |
| StringPtr body_string=execute_virtual_method(*main_class, main_method_name); | StringPtr body_string=execute_virtual_method(main_class, main_method_name); |
| if(!body_string) | if(!body_string) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| Exception::undefined_source, | Exception::undefined_source, |
| Line 299 gettimeofday(&mt[2],NULL); | Line 319 gettimeofday(&mt[2],NULL); |
| 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(), method->name, *junction, 0/*no parent*/); | VMethodFrame frame(pool(), method->name, *junction, 0/*no parent*/); frame.ref(); |
| frame.set_self(*main_class); | frame.set_self(main_class); |
| frame.store_param(body_vstring_before_post_process); | frame.store_param(body_vstring_before_post_process); |
| body_vstring_after_post_process= | body_vstring_after_post_process= |
| Line 309 gettimeofday(&mt[2],NULL); | Line 329 gettimeofday(&mt[2],NULL); |
| bool lorigins_mode=origins_mode(); | bool lorigins_mode=origins_mode(); |
| VFilePtr body_file=body_vstring_after_post_process->as_vfile( | VFilePtr body_file=body_vstring_after_post_process->as_vfile(pool(), |
| String::UL_UNSPECIFIED, lorigins_mode); | String::UL_UNSPECIFIED, lorigins_mode); |
| // extract response body | // extract response body |
| Line 366 t[9]-t[3] | Line 386 t[9]-t[3] |
| problem_source->origin().file?problem_source->origin().file:"global", | problem_source->origin().file?problem_source->origin().file:"global", |
| problem_source->origin().line, | problem_source->origin().line, |
| #endif | #endif |
| problem_source->cstr(), | problem_source->cstr().get(), |
| e.comment(), | e.comment(), |
| e.type() | e.type() |
| ); | ); |
| Line 397 t[9]-t[3] | Line 417 t[9]-t[3] |
| 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] |
| VMethodFrame frame(pool(), method->name, *junction, 0/*no caller*/); | VMethodFrame frame(pool(), method->name, *junction, 0/*no caller*/); frame.ref(); |
| frame.set_self(*main_class); | frame.set_self(main_class); |
| // $exception | // $exception |
| frame.store_param(exception2vhash(e)); | frame.store_param(exception2vhash(pool(), e)); |
| // $stack[^table::set{name origin}] | // $stack[^table::set{name origin}] |
| Table::columns_type stack_trace_columns; | Table::columns_type stack_trace_columns(new ArrayString); |
| *stack_trace_columns+=StringPtr(new String("name")); | *stack_trace_columns+=StringPtr(new String("name")); |
| *stack_trace_columns+=StringPtr(new String("file")); | *stack_trace_columns+=StringPtr(new String("file")); |
| *stack_trace_columns+=StringPtr(new String("lineno")); | *stack_trace_columns+=StringPtr(new String("lineno")); |
| TablePtr stack_trace(new Table(Exception::undefined_source, stack_trace_columns)); | TablePtr stack_trace(new Table(Exception::undefined_source, stack_trace_columns)); |
| Array_iterator<StringPtr> tracei(exception_trace); | Array_iterator<StringPtr> tracei(exception_trace); |
| while(tracei.has_next()) { | while(tracei.has_next()) { |
| Table::element_type row; | Table::element_type row(new ArrayString); |
| StringPtr name=tracei.next(); | StringPtr name=tracei.next(); |
| *row+=name; // name column | *row+=name; // name column |
| Line 418 t[9]-t[3] | Line 438 t[9]-t[3] |
| const String_fragment::Origin& origin=name->origin(); | const String_fragment::Origin& origin=name->origin(); |
| if(origin.file) { | if(origin.file) { |
| *row+=StringPtr(new String(origin.file, 0, true)); // file column | *row+=StringPtr(new String(origin.file, 0, true)); // file column |
| char *buf=(char *)malloc(MAX_NUMBER); | *row+=StringPtr(new String( |
| size_t buf_size=snprintf(buf, MAX_NUMBER, "%d", 1+origin.line); | pool().format_integer(1+origin.line), |
| *row+=StringPtr(new String(buf, buf_size, true)); // line column | 0, true)); // line column |
| } | } |
| #endif | #endif |
| *stack_trace+=row; | *stack_trace+=row; |
| Line 438 t[9]-t[3] | Line 458 t[9]-t[3] |
| // doing that ugly | // doing that ugly |
| // make up result: $origin $source $comment $type $code | // make up result: $origin $source $comment $type $code |
| char *buf=(char *)malloc(MAX_STRING); | char *buf=new(pool()) char[MAX_STRING]; |
| size_t printed=0; | size_t printed=0; |
| if(StringPtr problem_source=e.problem_source()) { | if(StringPtr problem_source=e.problem_source()) { |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| Line 450 t[9]-t[3] | Line 470 t[9]-t[3] |
| ); | ); |
| #endif | #endif |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", | printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", |
| problem_source->cstr()); | problem_source->cstr().get()); |
| } | } |
| if(const char* comment=e.comment(true)) | if(const char* comment=e.comment(true)) |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", comment); | printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", comment); |
| Line 465 t[9]-t[3] | Line 485 t[9]-t[3] |
| } | } |
| VString body_vstring(body_string); | VString body_vstring(body_string); |
| VFilePtr body_file=body_vstring.as_vfile(); | VFilePtr body_file=body_vstring.as_vfile(pool()); |
| // ERROR. write it out | // ERROR. write it out |
| output_result(body_file, header_only, false); | output_result(body_file, header_only, false); |
| Line 480 VStateless_classPtr Request::use_file(VS | Line 500 VStateless_classPtr Request::use_file(VS |
| bool fail_on_read_problem, bool fail_on_file_absence) { | 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_name)) |
| return 0; | return VStateless_classPtr(0); |
| used_files.put(file_name, true); | used_files.put(file_name, true); |
| StringPtr file_spec; | StringPtr file_spec; |
| Line 492 VStateless_classPtr Request::use_file(VS | Line 512 VStateless_classPtr Request::use_file(VS |
| file_spec=StringPtr(0); | file_spec=StringPtr(0); |
| if(ValuePtr element=main_class->get_element(class_path_name, *main_class, false)) { | if(ValuePtr element=main_class->get_element(class_path_name, *main_class, false)) { |
| if(element->is_string()) { | if(element->is_string()) { |
| file_spec=file_readable(absolute(element->as_string(&pool())), file_name); // found at class_path? | file_spec=file_readable(*absolute(element->as_string(&pool())), *file_name); // found at class_path? |
| } else if(Table *table=element->get_table()) { | } else if(Table *table=element->get_table()) { |
| int size=table->count(); | int size=table->count(); |
| for(int i=size; i--; ) { | for(int i=size; i--; ) { |
| StringPtr path=(*table->get(i))[0]; | StringPtr path=(*table->get(i))[0]; |
| if(file_spec=file_readable(absolute(path), file_name)) | if(file_spec=file_readable(*absolute(path), *file_name)) |
| break; // found along class_path | break; // found along class_path |
| } | } |
| } else | } else |
| Line 517 VStateless_classPtr Request::use_file(VS | Line 537 VStateless_classPtr Request::use_file(VS |
| if(fail_on_read_problem && !fail_on_file_absence) // ignore file absence if asked for | if(fail_on_read_problem && !fail_on_file_absence) // ignore file absence if asked for |
| if(!entry_exists(file_spec)) | if(!entry_exists(file_spec)) |
| return 0; | return VStateless_classPtr(0); |
| if(const char *source=file_read_text(pool(), charsets.source(), file_spec, fail_on_read_problem)) | if(const char *source=file_read_text(pool(), charsets.source(), file_spec, fail_on_read_problem)) |
| return use_buf(aclass, source, file_spec, file_spec->cstr(pool())); | return use_buf(aclass, source, file_spec, file_spec->cstr(pool())); |
| else | else |
| return 0; | return VStateless_classPtr(0); |
| } | } |
| Line 539 VStateless_classPtr Request::use_buf(VSt | Line 559 VStateless_classPtr Request::use_buf(VSt |
| // locate and execute possible @conf[] static | // locate and execute possible @conf[] static |
| VStringPtr vfilespec(new VString(filespec)); | VStringPtr vfilespec(new VString(filespec)); |
| const Method *method_called; | Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass, |
| execute_nonvirtual_method(cclass, | |
| conf_method_name, vfilespec, | conf_method_name, vfilespec, |
| false/*no result needed*/, &method_called); | false/*no string result needed*/); |
| if(method_called) | if(executed.method) |
| configure_admin(cclass, method_called->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, | auto_method_name, vfilespec, |
| 0/*no result needed*/); | false/*no result needed*/); |
| return &cclass; | return VStateless_classPtr(&cclass); |
| } | } |
| StringPtr Request::relative(const char* apath, StringPtr relative_name) { | StringPtr Request::relative(const char* apath, StringPtr relative_name) { |
| Line 588 static void add_header_attribute( | Line 607 static void add_header_attribute( |
| } | } |
| void Request::output_result(VFilePtr body_file, bool header_only, bool as_attachment) { | void Request::output_result(VFilePtr body_file, bool header_only, bool as_attachment) { |
| // header: cookies | // header: cookies |
| cookie->output_result(sapi_info); | cookie->output_result(pool(), sapi_info); |
| ValuePtr body_file_content_type; | ValuePtr body_file_content_type; |
| // set content-type | // set content-type |
| Line 603 void Request::output_result(VFilePtr bod | Line 622 void Request::output_result(VFilePtr bod |
| // content-disposition | // content-disposition |
| if(ValuePtr vfile_name=body_file->fields().get(name_name)) | if(ValuePtr vfile_name=body_file->fields().get(name_name)) |
| if(*vfile_name->get_string(&Pool())!=NONAME_DAT) { | if(*vfile_name->get_string(&fpool)!=NONAME_DAT) { |
| VHashPtr hash(new VHash); | VHashPtr hash(new VHash); |
| HashStringValue &h=hash->hash(Exception::undefined_source); | HashStringValue &h=hash->hash(Exception::undefined_source); |
| if(as_attachment) | if(as_attachment) |
| Line 663 StringPtr Request::mime_type_of(const ch | Line 682 StringPtr Request::mime_type_of(const ch |
| bool Request::origins_mode() { | bool Request::origins_mode() { |
| return main_class->get_element(origins_mode_name, *main_class, false)!=0; // $ORIGINS mode | return main_class->get_element(origins_mode_name, *main_class, false)!=0; // $ORIGINS mode |
| } | } |
| #ifdef XML | |
| GdomeDOMString_auto_ptr Request::transcode(StringPtr s) { | |
| return charsets.source().transcode(s); | |
| } | |
| StringPtr Request::transcode(GdomeDOMString* s | |
| #ifndef NO_STRING_ORIGIN | |
| , StringPtr origin | |
| #endif | |
| ) { | |
| return charsets.source().transcode(pool(), s | |
| #ifndef NO_STRING_ORIGIN | |
| , origin | |
| #endif | |
| ); | |
| } | |
| StringPtr Request::transcode(xmlChar* s | |
| #ifndef NO_STRING_ORIGIN | |
| , StringPtr origin | |
| #endif | |
| ) { | |
| return charsets.source().transcode(pool(), s | |
| #ifndef NO_STRING_ORIGIN | |
| , origin | |
| #endif | |
| ); | |
| } | |
| #endif |