|
|
| version 1.95, 2001/09/18 16:05:42 | version 1.120, 2002/02/08 07:27:44 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: request class decl. | Parser: request class decl. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://paf.design.ru) | |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | |
| $Id$ | $Id$ |
| */ | */ |
| Line 11 | Line 10 |
| #ifndef PA_REQUEST_H | #ifndef PA_REQUEST_H |
| #define PA_REQUEST_H | #define PA_REQUEST_H |
| #include "pa_config_includes.h" | |
| #include "pa_pool.h" | #include "pa_pool.h" |
| #include "pa_hash.h" | #include "pa_hash.h" |
| #include "pa_wcontext.h" | #include "pa_wcontext.h" |
| Line 20 | Line 18 |
| #include "pa_vclass.h" | #include "pa_vclass.h" |
| #include "pa_vobject.h" | #include "pa_vobject.h" |
| #include "pa_venv.h" | #include "pa_venv.h" |
| #include "pa_vstatus.h" | |
| #include "pa_vform.h" | #include "pa_vform.h" |
| #include "pa_vmath.h" | #include "pa_vmath.h" |
| #include "pa_vrequest.h" | #include "pa_vrequest.h" |
| Line 27 | Line 26 |
| #include "pa_vcookie.h" | #include "pa_vcookie.h" |
| #include "pa_sql_driver_manager.h" | #include "pa_sql_driver_manager.h" |
| #ifdef RESOURCES_DEBUG | |
| #include <sys/resource.h> | |
| #endif | |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| # define COMPILE_PARAMS \ | # define COMPILE_PARAMS \ |
| const char *source, \ | const char *source, \ |
| Line 46 | Line 49 |
| class Temp_lang; | class Temp_lang; |
| class Methoded; | class Methoded; |
| class VMethodFrame; | |
| /// Main workhorse. | /// Main workhorse. |
| class Request : public Pooled { | class Request : public Pooled { |
| friend Temp_lang; | friend class Temp_lang; |
| friend class Temp_connection; | |
| public: | public: |
| #ifdef RESOURCES_DEBUG | |
| /// measures | |
| double sql_connect_time; | |
| double sql_request_time; | |
| #endif | |
| /// some information from web server | /// some information from web server |
| class Info { | class Info { |
| public: | public: |
| Line 68 public: | Line 79 public: |
| Request(Pool& apool, | Request(Pool& apool, |
| Info& ainfo, | Info& ainfo, |
| String::Untaint_lang adefault_lang ///< all tainted data default untainting lang | uchar adefault_lang, ///< all tainted data default untainting lang |
| bool status_allowed ///< status class allowed | |
| ); | ); |
| ~Request() {} | ~Request(); |
| /// global classes | /// global classes |
| Hash& classes() { return fclasses; } | Hash& classes() { return fclasses; } |
| Line 109 public: | Line 121 public: |
| /// appending, sure of clean string inside | /// appending, sure of clean string inside |
| void write_no_lang(const String& astring) { | void write_no_lang(const String& astring) { |
| wcontext->write(astring, String::UL_CLEAN); | wcontext->write(astring, |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); | |
| } | } |
| /// appending string, passing language built into string being written | /// appending string, passing language built into string being written |
| void write_pass_lang(const String& astring) { | void write_pass_lang(const String& astring) { |
| Line 119 public: | Line 132 public: |
| void write_assign_lang(Value& avalue) { | void write_assign_lang(Value& avalue) { |
| wcontext->write(avalue, flang); | wcontext->write(avalue, flang); |
| } | } |
| /// appending string, assigning untaint language | |
| void write_assign_lang(const String& astring) { | |
| wcontext->write(astring, flang); | |
| } | |
| /// appending possible string, passing language built into string being written | /// appending possible string, passing language built into string being written |
| void write_pass_lang(Value& avalue) { | void write_pass_lang(Value& avalue) { |
| wcontext->write(avalue, String::UL_PASS_APPENDED); | wcontext->write(avalue, String::UL_PASS_APPENDED); |
| } | } |
| /// appending sure value, that would be converted to clean string | /// appending sure value, that would be converted to clean string |
| void write_no_lang(Value& avalue) { | void write_no_lang(Value& avalue) { |
| wcontext->write(avalue, String::UL_CLEAN); | wcontext->write(avalue, |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); | |
| } | } |
| /// appending sure value, not VString | /// appending sure value, not VString |
| void write_expr_result(Value& avalue) { | void write_expr_result(Value& avalue) { |
| Line 141 public: | Line 159 public: |
| /// returns the mime type of 'user_file_name_cstr' | /// returns the mime type of 'user_file_name_cstr' |
| const String& mime_type_of(const char *user_file_name_cstr); | const String& mime_type_of(const char *user_file_name_cstr); |
| /// returns current SQL connection if any | |
| SQL_Connection *connection(const String *source) { | |
| if(!fconnection && source) | |
| throw Exception(0, 0, | |
| source, | |
| "outside of 'connect' operator"); | |
| return fconnection; | |
| } | |
| public: | public: |
| /// info from web server | /// info from web server |
| Line 152 public: | Line 180 public: |
| Methoded& OP; | Methoded& OP; |
| /// $env:fields | /// $env:fields |
| VEnv env; | VEnv env; |
| /// $status:fields | |
| VStatus status; | |
| /// $form:elements | /// $form:elements |
| VForm form; | VForm form; |
| /// $math:constants | /// $math:constants |
| Line 171 public: | Line 201 public: |
| /// 'MAIN' class conglomerat | /// 'MAIN' class conglomerat |
| VStateless_class *main_class; | VStateless_class *main_class; |
| /// connection | |
| SQL_Connection *connection; | |
| /// PCRE character tables | |
| unsigned char *pcre_tables; | |
| /// classes configured data | /// classes configured data |
| Hash classes_conf; | Hash classes_conf; |
| private: // core data | private: // core data |
| /// classes | /// classes |
| Line 196 private: // core data | Line 220 private: // core data |
| */ | */ |
| uint anti_endless_execute_recoursion; | uint anti_endless_execute_recoursion; |
| /// stack trace | |
| Stack trace; | |
| private: // compile.C | private: // compile.C |
| VStateless_class& real_compile(COMPILE_PARAMS); | VStateless_class& real_compile(COMPILE_PARAMS); |
| private: // execute.C | private: // execute.C |
| const String *execute_method(Value& aself, | const String *execute_method(Value& aself, const Method& method, |
| const Method& method, bool return_cstr=true); | bool return_cstr); |
| const String *execute_virtual_method(Value& aself, | const String& execute_method(VMethodFrame& amethodFrame, const Method& method); |
| const String& method_name, bool return_cstr=true); | const String *execute_virtual_method(Value& aself, const String& method_name); |
| const String *execute_nonvirtual_method(VStateless_class& aclass, | const String *execute_nonvirtual_method(VStateless_class& aclass, |
| const String& method_name, bool return_cstr=true); | const String& method_name, |
| bool return_cstr); | |
| Value *get_element(); | |
| private: // lang&raw | Value *get_element(bool can_call_operator); |
| String::Untaint_lang flang; | |
| private: // defaults | private: // defaults |
| const String::Untaint_lang fdefault_lang; | const uchar fdefault_lang; |
| Value *default_content_type; | Value *default_content_type; |
| private: // mime types | private: // mime types |
| Line 227 private: // mime types | Line 251 private: // mime types |
| private: // lang manipulation | private: // lang manipulation |
| String::Untaint_lang set_lang(String::Untaint_lang alang) { | uchar set_lang(uchar alang) { |
| String::Untaint_lang result=flang; | uchar result=flang; |
| flang=alang; | flang=alang; |
| return result; | return result; |
| } | } |
| void restore_lang(String::Untaint_lang alang) { | void restore_lang(uchar alang) { |
| flang=alang; | flang=alang; |
| } | } |
| private: // lang&raw | |
| uchar flang; | |
| private: // connection manipulation | |
| SQL_Connection *set_connection(SQL_Connection *aconnection) { | |
| SQL_Connection *result=fconnection; | |
| fconnection=aconnection; | |
| return result; | |
| } | |
| void restore_connection(SQL_Connection *aconnection) { | |
| fconnection=aconnection; | |
| } | |
| private: | |
| /// connection | |
| SQL_Connection *fconnection; | |
| private: | private: |
| void output_result(const VFile& body_file, bool header_only); | void output_result(const VFile& body_file, bool header_only); |
| Line 244 private: | Line 290 private: |
| /// Auto-object used for temporary changing Request::flang. | /// Auto-object used for temporary changing Request::flang. |
| class Temp_lang { | class Temp_lang { |
| Request& frequest; | Request& frequest; |
| String::Untaint_lang saved_lang; | uchar saved_lang; |
| public: | public: |
| Temp_lang(Request& arequest, String::Untaint_lang alang) : | Temp_lang(Request& arequest, uchar alang) : |
| frequest(arequest), | frequest(arequest), |
| saved_lang(arequest.set_lang(alang)) { | saved_lang(arequest.set_lang(alang)) { |
| } | } |
| Line 255 public: | Line 301 public: |
| } | } |
| }; | }; |
| /// Auto-object used for temporary changing Request::fconnection. | |
| class Temp_connection { | |
| Request& frequest; | |
| SQL_Connection *saved_connection; | |
| public: | |
| Temp_connection(Request& arequest, SQL_Connection *aconnection) : | |
| frequest(arequest), | |
| saved_connection(arequest.set_connection(aconnection)) { | |
| } | |
| ~Temp_connection() { | |
| frequest.restore_connection(saved_connection); | |
| } | |
| }; | |
| /** | /** |
| @b method parameters passed in this array. | @b method parameters passed in this array. |
| contains handy typecast ad junction/not junction ensurers | contains handy typecast ad junction/not junction ensurers |
| Line 279 public: | Line 339 public: |
| return get_as(index, false, msg); | return get_as(index, false, msg); |
| } | } |
| /// handy expression auto-processing to double | /// handy expression auto-processing to double |
| double as_double(int index, Request& r) { | double as_double(int index, const char *msg, Request& r) { |
| return get_processed(index, r).as_double(); | return get_processed(index, msg, r).as_double(); |
| } | } |
| /// handy expression auto-processing to int | /// handy expression auto-processing to int |
| int as_int(int index, Request& r) { | int as_int(int index, const char *msg, Request& r) { |
| return get_processed(index, r).as_int(); | return get_processed(index, msg, r).as_int(); |
| } | |
| /// handy expression auto-processing to bool | |
| bool as_bool(int index, const char *msg, Request& r) { | |
| return get_processed(index, msg, r).as_bool(); | |
| } | } |
| /// handy string ensurer | /// handy string ensurer |
| const String& as_string(int index, const char *msg) { | const String& as_string(int index, const char *msg) { |
| Line 297 private: | Line 361 private: |
| Value& get_as(int index, bool as_junction, const char *msg) { | Value& get_as(int index, bool as_junction, const char *msg) { |
| Value& result=get(index); | Value& result=get(index); |
| if((result.get_junction()!=0) ^ as_junction) | if((result.get_junction()!=0) ^ as_junction) |
| THROW(0, 0, | throw Exception(0, 0, |
| &fmethod_name, | &fmethod_name, |
| "%s (parameter #%d)", msg, 1+index); | "%s (parameter #%d)", msg, 1+index); |
| return result; | return result; |
| } | } |
| Value& get_processed(int index, Request& r) { | Value& get_processed(int index, const char *msg, Request& r) { |
| return r.process(get(index), | return r.process(as_junction(index, msg), |
| 0/*no name*/, | 0/*no name*/, |
| false/*don't intercept string*/); | false/*don't intercept string*/); |
| } | } |