|
|
| version 1.117, 2002/01/16 10:28:34 | version 1.134, 2002/05/07 07:39:18 |
|---|---|
| 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: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| $Id$ | $Id$ |
| */ | */ |
| Line 30 | Line 30 |
| #include <sys/resource.h> | #include <sys/resource.h> |
| #endif | #endif |
| // consts | |
| #define MAIN_METHOD_NAME "main" | |
| const uint ANTI_ENDLESS_EXECUTE_RECOURSION=500; | |
| // defines | |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| # define COMPILE_PARAMS \ | # define COMPILE_PARAMS \ |
| const char *source, \ | const char *source, \ |
| Line 82 public: | Line 89 public: |
| uchar adefault_lang, ///< all tainted data default untainting lang | uchar adefault_lang, ///< all tainted data default untainting lang |
| bool status_allowed ///< status class allowed | bool status_allowed ///< status class allowed |
| ); | ); |
| ~Request() {} | ~Request(); |
| /// global classes | /// global classes |
| Hash& classes() { return fclasses; } | Hash& classes() { return fclasses; } |
| Line 101 public: | Line 108 public: |
| /// executes ops | /// executes ops |
| void execute(const Array& ops); // execute.C | void execute(const Array& ops); // execute.C |
| /// execute ops with anti-recoursion check | |
| void recoursion_checked_execute(const String *name, const Array& ops) { | |
| // anti_endless_execute_recoursion | |
| if(++anti_endless_execute_recoursion==ANTI_ENDLESS_EXECUTE_RECOURSION) { | |
| anti_endless_execute_recoursion=0; // give @exception a chance | |
| throw Exception("parser.runtime", | |
| name, | |
| "call canceled - endless recursion detected"); | |
| } | |
| execute(ops); // execute it | |
| anti_endless_execute_recoursion--; | |
| } | |
| /// compiles the file, maybe forcing it's class @a name and @a base_class. | /// compiles the file, maybe forcing it's class @a name and @a base_class. |
| VStateless_class *use_file( | VStateless_class *use_file( |
| Line 113 public: | Line 132 public: |
| const char *source, const char *file, | const char *source, const char *file, |
| VStateless_class *aclass=0, const String *name=0, | VStateless_class *aclass=0, const String *name=0, |
| VStateless_class *base_class=0); // core.C | VStateless_class *base_class=0); // core.C |
| /// processes any code-junction there may be inside of @a value | /// processes any code-junction there may be inside of @a value |
| Value& process( | StringOrValue process(Value& input_value, bool intercept_string=true); // execute.C |
| Value& value, | //@{ convinient helpers |
| const String *name=0, | const String& process_to_string(Value& input_value) { |
| bool intercept_string=true); // execute.C | return process(input_value, true/*intercept_string*/).as_string(); |
| } | |
| Value& process_to_value(Value& input_value, bool intercept_string=true) { | |
| return process(input_value, intercept_string).as_value(); | |
| } | |
| //@} | |
| #define DEFINE_DUAL(modification) \ | |
| void write_##modification##_lang(StringOrValue dual) { \ | |
| if(const String *string=dual.get_string()) \ | |
| write_##modification##_lang(*string); \ | |
| else \ | |
| write_##modification##_lang(*dual.get_value()); \ | |
| } | |
| #define DEFINE_DUAL_CHECKED(modification) \ | |
| void write_##modification##_lang(StringOrValue dual, const String *origin) { \ | |
| if(const String *string=dual.get_string()) \ | |
| write_##modification##_lang(*string); \ | |
| else \ | |
| write_##modification##_lang(*dual.get_value(), origin); \ | |
| } | |
| /// 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, | wcontext->write(astring, |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); | String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); |
| } | } |
| /// appending sure value, that would be converted to clean string | |
| void write_no_lang(Value& avalue) { | |
| if(wcontext->get_in_expression()) | |
| wcontext->write(avalue); | |
| else | |
| wcontext->write(avalue, | |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); | |
| } | |
| //DEFINE_DUAL(no) | |
| /// 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) { |
| wcontext->write(astring, String::UL_PASS_APPENDED); | wcontext->write(astring, String::UL_PASS_APPENDED); |
| } | } |
| /// appending possible string, passing language built into string being written | |
| void write_pass_lang(Value& avalue) { | |
| wcontext->write(avalue, String::UL_PASS_APPENDED); | |
| } | |
| DEFINE_DUAL(pass) | |
| /// appending possible string, assigning untaint language | /// appending possible string, assigning untaint language |
| void write_assign_lang(Value& avalue) { | void write_assign_lang(Value& avalue) { |
| wcontext->write(avalue, flang); | wcontext->write(avalue, flang); |
| } | } |
| /// appending possible string, assigning untaint language | |
| void write_assign_lang(Value& avalue, const String *origin) { | |
| wcontext->write(avalue, flang, origin); | |
| } | |
| /// appending string, assigning untaint language | /// appending string, assigning untaint language |
| void write_assign_lang(const String& astring) { | void write_assign_lang(const String& astring) { |
| wcontext->write(astring, flang); | wcontext->write(astring, flang); |
| } | } |
| /// appending possible string, passing language built into string being written | DEFINE_DUAL(assign) |
| void write_pass_lang(Value& avalue) { | DEFINE_DUAL_CHECKED(assign) |
| wcontext->write(avalue, String::UL_PASS_APPENDED); | |
| } | |
| /// appending sure value, that would be converted to clean string | |
| void write_no_lang(Value& avalue) { | |
| wcontext->write(avalue, | |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); | |
| } | |
| /// appending sure value, not VString | |
| void write_expr_result(Value& avalue) { | |
| wcontext->write(avalue); | |
| } | |
| /// returns relative to @a path path to @a file | /// returns relative to @a path path to @a file |
| const String& relative(const char *apath, const String& relative_name); | const String& relative(const char *apath, const String& relative_name); |
| Line 162 public: | Line 212 public: |
| /// returns current SQL connection if any | /// returns current SQL connection if any |
| SQL_Connection *connection(const String *source) { | SQL_Connection *connection(const String *source) { |
| if(!fconnection && source) | if(!fconnection && source) |
| throw Exception(0, 0, | throw Exception("parser.runtime", |
| source, | source, |
| "outside of 'connect' operator"); | "outside of 'connect' operator"); |
| return fconnection; | return fconnection; |
| } | } |
| bool origins_mode() { | |
| return main_class->get_element(*origins_mode_name)!=0; // $ORIGINS mode | |
| } | |
| public: | public: |
| /// info from web server | /// info from web server |
| Line 176 public: | Line 230 public: |
| /// user's post data | /// user's post data |
| char *post_data; size_t post_size; | char *post_data; size_t post_size; |
| /// name of 'main' method | |
| const String main_method_name; | |
| /// operators are methods of this class | /// operators are methods of this class |
| Methoded& OP; | Methoded& OP; |
| /// $env:fields | /// $env:fields |
| Line 193 public: | Line 250 public: |
| /// $cookie:elements | /// $cookie:elements |
| VCookie cookie; | VCookie cookie; |
| //@{ request processing status | |
| /// execution stack | |
| Stack stack; | |
| /// contexts | /// contexts |
| Value *self, *root, *rcontext; | Value *self, *root, *rcontext; |
| /// contexts | /// contexts |
| WContext *wcontext; | WContext *wcontext; |
| /// exception stack trace | |
| Stack exception_trace; | |
| //@} | |
| /// 'MAIN' class conglomerat | /// 'MAIN' class conglomerat |
| VStateless_class *main_class; | VStateless_class *main_class; |
| Line 212 private: // core data | Line 275 private: // core data |
| /// already used files to avoid cyclic uses | /// already used files to avoid cyclic uses |
| Hash used_files; | Hash used_files; |
| /// execution stack | |
| Stack stack; | |
| /** endless execute(execute(... preventing counter | /** endless execute(execute(... preventing counter |
| @see ANTI_ENDLESS_EXECUTE_RECOURSION | @see ANTI_ENDLESS_EXECUTE_RECOURSION |
| */ | */ |
| 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); |
| Line 237 private: // execute.C | Line 294 private: // execute.C |
| const String& method_name, | const String& method_name, |
| bool return_cstr); | bool return_cstr); |
| Value *get_element(); | Value *get_element(const String *& remember_name, bool can_call_operator); |
| private: // defaults | private: // defaults |
| Line 281 private: | Line 338 private: |
| /// connection | /// connection |
| SQL_Connection *fconnection; | SQL_Connection *fconnection; |
| private: | |
| void output_result(const VFile& body_file, bool header_only); | void output_result(const VFile& body_file, bool header_only); |
| }; | }; |
| Line 361 private: | Line 415 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 Exception(0, 0, | throw Exception("parser.runtime", |
| &fmethod_name, | &fmethod_name, |
| "%s (parameter #%d)", msg, 1+index); | "%s (parameter #%d)", msg, 1+index); |
| Line 369 private: | Line 423 private: |
| } | } |
| Value& get_processed(int index, const char *msg, Request& r) { | Value& get_processed(int index, const char *msg, Request& r) { |
| return r.process(as_junction(index, msg), | return r.process_to_value(as_junction(index, msg), 0/*no name*/); |
| 0/*no name*/, | |
| false/*don't intercept string*/); | |
| } | } |
| private: | private: |