|
|
| version 1.199, 2009/08/08 13:30:20 | version 1.216, 2012/02/27 11:08:28 |
|---|---|
| Line 25 static const char * const IDENT_FILE_C=" | Line 25 static const char * const IDENT_FILE_C=" |
| #include "pa_sql_connection.h" | #include "pa_sql_connection.h" |
| #include "pa_md5.h" | #include "pa_md5.h" |
| #include "pa_vregex.h" | #include "pa_vregex.h" |
| #include "pa_version.h" | |
| // defines | // defines |
| Line 42 extern String sql_offset_name; | Line 43 extern String sql_offset_name; |
| class MFile: public Methoded { | class MFile: public Methoded { |
| public: // VStateless_class | public: // VStateless_class |
| Value* create_new_value(Pool&) { return new VFile(); } | Value* create_new_value(Pool&) { return new VFile(); } |
| public: // Methoded | |
| bool used_directly() { return true; } | |
| public: | public: |
| MFile(); | MFile(); |
| }; | }; |
| // global variable | // global variable |
| Line 111 static const String::Body cdate_name("cd | Line 106 static const String::Body cdate_name("cd |
| // methods | // methods |
| static bool is_valid_mode (const String& mode) { | |
| return (mode==text_mode_name || mode==binary_mode_name); | |
| } | |
| static bool is_text_mode(const String& mode) { | |
| if(mode==text_mode_name) | |
| return true; | |
| if(mode==binary_mode_name) | |
| return false; | |
| throw Exception(PARSER_RUNTIME, | |
| &mode, | |
| "is invalid mode, must be either '"TEXT_MODE_NAME"' or '"BINARY_MODE_NAME"'"); | |
| } | |
| static void _save(Request& r, MethodParams& params) { | static void _save(Request& r, MethodParams& params) { |
| Value& vmode_name=params.as_no_junction(0, MODE_MUST_NOT_BE_CODE); | bool is_text=VFile::is_text_mode(params.as_string(0, MODE_MUST_NOT_BE_CODE)); |
| Value& vfile_name=params.as_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE); | Value& vfile_name=params.as_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE); |
| Charset* asked_charset=0; | |
| if(params.count()>2) | |
| if(HashStringValue* options=params.as_hash(2)){ | |
| int valid_options=0; | |
| if(Value* vcharset_name=options->get(PA_CHARSET_NAME)){ | |
| asked_charset=&::charsets.get(vcharset_name->as_string().change_case(r.charsets.source(), String::CC_UPPER)); | |
| valid_options++; | |
| } | |
| if(valid_options != options->count()) | |
| throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION); | |
| } | |
| // save | // save |
| GET_SELF(r, VFile).save(r.absolute(vfile_name.as_string()), | GET_SELF(r, VFile).save(r.charsets, r.absolute(vfile_name.as_string()), is_text, asked_charset); |
| is_text_mode(vmode_name.as_string())); | |
| } | } |
| static void _delete(Request& r, MethodParams& params) { | static void _delete(Request& r, MethodParams& params) { |
| Value& vfile_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE); | const String& file_name=params.as_string(0, FILE_NAME_MUST_NOT_BE_CODE); |
| // unlink | // unlink |
| file_delete(r.absolute(vfile_name.as_string())); | file_delete(r.absolute(file_name)); |
| } | } |
| static void _move(Request& r, MethodParams& params) { | static void _move(Request& r, MethodParams& params) { |
| Line 198 static void _load_pass_param( | Line 190 static void _load_pass_param( |
| } | } |
| static void _load(Request& r, MethodParams& params) { | static void _load(Request& r, MethodParams& params) { |
| bool as_text=is_text_mode(params.as_no_junction(0, MODE_MUST_NOT_BE_CODE).as_string()); | bool as_text=VFile::is_text_mode(params.as_string(0, MODE_MUST_NOT_BE_CODE)); |
| const String& lfile_name=r.absolute(params.as_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE).as_string()); | const String& lfile_name=r.absolute(params.as_string(1, FILE_NAME_MUST_NOT_BE_CODE)); |
| size_t param_index=params.count()-1; | size_t param_index=params.count()-1; |
| Value* param_value=param_index>1?¶ms.as_no_junction(param_index, "filename or options must not be code"):0; | Value* param_value=param_index>1?¶ms.as_no_junction(param_index, "file name or options must not be code"):0; |
| HashStringValue* options=0; | HashStringValue* options=0; |
| const char *user_file_name=0; | const String* user_file_name=0; |
| if(param_value){ | if(param_value){ |
| options=param_value->get_hash(); | options=param_value->get_hash(); |
| Line 214 static void _load(Request& r, MethodPara | Line 206 static void _load(Request& r, MethodPara |
| if(param_index>1){ | if(param_index>1){ |
| const String& luser_file_name=params.as_string(param_index, FILE_NAME_MUST_BE_STRING); | const String& luser_file_name=params.as_string(param_index, FILE_NAME_MUST_BE_STRING); |
| if(!luser_file_name.is_empty()) | if(!luser_file_name.is_empty()) |
| user_file_name=luser_file_name.taint_cstr(String::L_FILE_SPEC); | user_file_name=&luser_file_name; |
| } | } |
| } | } |
| if(!user_file_name) | if(!user_file_name) |
| user_file_name=lfile_name.taint_cstr(String::L_FILE_SPEC); | user_file_name=&lfile_name; |
| size_t offset=0; | size_t offset=0; |
| size_t limit=0; | size_t limit=0; |
| Line 242 static void _load(Request& r, MethodPara | Line 234 static void _load(Request& r, MethodPara |
| if(Value* remote_content_type=file.headers->get(HTTP_CONTENT_TYPE_UPPER)) | if(Value* remote_content_type=file.headers->get(HTTP_CONTENT_TYPE_UPPER)) |
| vcontent_type=new VString(*new String(remote_content_type->as_string().cstr())); | vcontent_type=new VString(*new String(remote_content_type->as_string().cstr())); |
| } | } |
| if(!vcontent_type) | |
| vcontent_type=new VString(r.mime_type_of(user_file_name)); | |
| VFile& self=GET_SELF(r, VFile); | VFile& self=GET_SELF(r, VFile); |
| self.set(true/*tainted*/, file.str, file.length, user_file_name, vcontent_type); | self.set(true/*tainted*/, file.str, file.length, user_file_name, vcontent_type, &r); |
| self.set_mode(as_text); | self.set_mode(as_text); |
| Line 266 static void _load(Request& r, MethodPara | Line 256 static void _load(Request& r, MethodPara |
| } | } |
| static void _create(Request& r, MethodParams& params) { | static void _create(Request& r, MethodParams& params) { |
| const String& mode_name=params.as_no_junction(0, MODE_MUST_NOT_BE_CODE).as_string(); | const String* mode=0; |
| if(!is_text_mode(mode_name)) | const String* file_name=0; |
| throw Exception(PARSER_RUNTIME, | bool is_text=true; |
| 0, | |
| "only text mode is currently supported"); | // new format: ^file::create[string-or-file-content[;$.mode[text|binary] $.name[...] $.content-type[...] $.charset[...] ]] |
| size_t content_index=0; | |
| const char* user_file_name_cstr=r.absolute( | size_t options_index=1; |
| params.as_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE).as_string()).taint_cstr(String::L_FILE_SPEC); | bool extended_options=true; |
| if(params.count()>=3){ | |
| // old format: ^file::create[text|binary;file-name;string-or-file-content[;options]] | |
| mode=¶ms.as_string(0, MODE_MUST_NOT_BE_CODE); | |
| is_text=VFile::is_text_mode(*mode); | |
| file_name=¶ms.as_string(1, FILE_NAME_MUST_NOT_BE_CODE); | |
| content_index=2; | |
| options_index=3; | |
| extended_options=false; | |
| } | |
| VString* vcontent_type=0; | |
| Charset* asked_charset=0; | |
| if(params.count()>options_index) | |
| if(HashStringValue* options=params.as_hash(options_index)) { | |
| int valid_options=0; | |
| if(extended_options) { | |
| if(Value* vmode=options->get(MODE_NAME)) { | |
| mode=&vmode->as_string(); | |
| is_text=VFile::is_text_mode(*mode); | |
| valid_options++; | |
| } | |
| if(Value* vfile_name=options->get(NAME_NAME)) { | |
| file_name=&vfile_name->as_string(); | |
| valid_options++; | |
| } | |
| } | |
| if(Value* vcharset_name=options->get(PA_CHARSET_NAME)) { | |
| asked_charset=&::charsets.get(vcharset_name->as_string().change_case(r.charsets.source(), String::CC_UPPER)); | |
| valid_options++; | |
| } | |
| if(Value* value=options->get(CONTENT_TYPE_NAME)) { | |
| vcontent_type=new VString(value->as_string()); | |
| valid_options++; | |
| } | |
| if(valid_options != options->count()) | |
| throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION); | |
| } | |
| const String& content=params.as_string(2, "content must be string"); | Value& vcontent=params.as_no_junction(content_index, "content must be string or file"); |
| const String::Body content_body=content.cstr_to_string_body_untaint(String::L_AS_IS); // explode content, honor tainting changes | |
| VString* vcontent_type=new VString(r.mime_type_of(user_file_name_cstr)); | |
| VFile& self=GET_SELF(r, VFile); | VFile& self=GET_SELF(r, VFile); |
| self.set(true/*tainted*/, content_body.cstr(), content_body.length(), user_file_name_cstr, vcontent_type); | |
| self.set_mode(true/*as_text*/); | if(const String* content_str=vcontent.get_string()){ |
| String::Body body=content_str->cstr_to_string_body_untaint(String::L_AS_IS); // explode content, honor tainting changes | |
| if(asked_charset && is_text) | |
| body=Charset::transcode(body, r.charsets.source(), *asked_charset); | |
| self.set(true/*tainted*/, body.cstr(), body.length()); | |
| self.set_mode(is_text); | |
| } else { | |
| if(asked_charset) | |
| throw Exception(PARSER_RUNTIME, 0, "charset option can not be used with file-content"); | |
| self.set(*vcontent.as_vfile(String::L_AS_IS)); | |
| if(mode) | |
| self.set_mode(is_text); | |
| } | |
| self.set_name(file_name); | |
| self.set_content_type(vcontent_type, file_name, &r); | |
| } | } |
| static void _stat(Request& r, MethodParams& params) { | static void _stat(Request& r, MethodParams& params) { |
| Value& vfile_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE); | const String& lfile_name=params.as_string(0, FILE_NAME_MUST_NOT_BE_CODE); |
| const String& lfile_name=vfile_name.as_string(); | |
| size_t size; | size_t size; |
| time_t atime, mtime, ctime; | time_t atime, mtime, ctime; |
| Line 297 static void _stat(Request& r, MethodPara | Line 335 static void _stat(Request& r, MethodPara |
| size, | size, |
| atime, mtime, ctime); | atime, mtime, ctime); |
| const char* user_file_name=lfile_name.taint_cstr(String::L_FILE_SPEC); | |
| VFile& self=GET_SELF(r, VFile); | VFile& self=GET_SELF(r, VFile); |
| self.set(true/*tainted*/, 0/*no bytes*/, size, user_file_name, new VString(r.mime_type_of(user_file_name))); | self.set(true/*tainted*/, 0/*no bytes*/, size, &lfile_name, 0, &r); |
| HashStringValue& ff=self.fields(); | HashStringValue& ff=self.fields(); |
| ff.put(adate_name, new VDate(atime)); | ff.put(adate_name, new VDate(atime)); |
| ff.put(mdate_name, new VDate(mtime)); | ff.put(mdate_name, new VDate(mtime)); |
| Line 314 static bool is_safe_env_key(const char* | Line 350 static bool is_safe_env_key(const char* |
| if(!(c>='A' && c<='Z' || c>='0' && c<='9' || c=='_' || c=='-')) | if(!(c>='A' && c<='Z' || c>='0' && c<='9' || c=='_' || c=='-')) |
| return false; | return false; |
| } | } |
| #ifdef PA_SAFE_MODE | |
| if(strncasecmp(key, "HTTP_", 5)==0) | if(strncasecmp(key, "HTTP_", 5)==0) |
| return true; | return true; |
| if(strncasecmp(key, "CGI_", 4)==0) | if(strncasecmp(key, "CGI_", 4)==0) |
| Line 323 static bool is_safe_env_key(const char* | Line 360 static bool is_safe_env_key(const char* |
| return true; | return true; |
| } | } |
| return false; | return false; |
| #else | |
| return true; | |
| #endif | |
| } | } |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| struct Append_env_pair_info { | struct Append_env_pair_info { |
| Line 375 static void append_to_argv(Request& r, A | Line 415 static void append_to_argv(Request& r, A |
| /// @todo fix `` in perl - they produced flipping consoles and no output to perl | /// @todo fix `` in perl - they produced flipping consoles and no output to perl |
| static void _exec_cgi(Request& r, MethodParams& params, bool cgi) { | static void _exec_cgi(Request& r, MethodParams& params, bool cgi) { |
| bool as_text=true; | bool is_text=true; |
| size_t param_index=0; | size_t param_index=0; |
| const String& mode_name=params.as_no_junction(0, FIRST_ARG_MUST_NOT_BE_CODE).as_string(); | const String& mode=params.as_string(0, FIRST_ARG_MUST_NOT_BE_CODE); |
| if(is_valid_mode(mode_name)){ | if(VFile::is_valid_mode(mode)) { |
| as_text=is_text_mode(mode_name); | is_text=VFile::is_text_mode(mode); |
| param_index++; | param_index++; |
| } | } |
| if(param_index>=params.count()) | if(param_index>=params.count()) |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, FILE_NAME_MUST_BE_SPECIFIED); |
| 0, | |
| "file name must be specified"); | |
| Value& vfile_name=params.as_no_junction(param_index++, FILE_NAME_MUST_NOT_BE_CODE); | const String& script_name=r.absolute(params.as_string(param_index++, FILE_NAME_MUST_NOT_BE_CODE)); |
| const String& script_name=r.absolute(vfile_name.as_string()); | |
| HashStringString env; | HashStringString env; |
| #define ECSTR(name, value_cstr) \ | #define ECSTR(name, value_cstr) \ |
| Line 411 static void _exec_cgi(Request& r, Method | Line 446 static void _exec_cgi(Request& r, Method |
| // const | // const |
| ECSTR(GATEWAY_INTERFACE, "CGI/1.1"); | ECSTR(GATEWAY_INTERFACE, "CGI/1.1"); |
| ECSTR("PARSER_VERSION", PARSER_VERSION); | |
| // from Request.info | // from Request.info |
| ECSTR(DOCUMENT_ROOT, r.request_info.document_root); | ECSTR(DOCUMENT_ROOT, r.request_info.document_root); |
| ECSTR(PATH_TRANSLATED, r.request_info.path_translated); | ECSTR(PATH_TRANSLATED, r.request_info.path_translated); |
| Line 418 static void _exec_cgi(Request& r, Method | Line 454 static void _exec_cgi(Request& r, Method |
| ECSTR(QUERY_STRING, r.request_info.query_string); | ECSTR(QUERY_STRING, r.request_info.query_string); |
| ECSTR(REQUEST_URI, r.request_info.uri); | ECSTR(REQUEST_URI, r.request_info.uri); |
| ECSTR(CONTENT_TYPE, r.request_info.content_type); | ECSTR(CONTENT_TYPE, r.request_info.content_type); |
| char content_length_cstr[MAX_NUMBER]; | ECSTR(CONTENT_LENGTH, format(r.request_info.content_length, "%u")); |
| snprintf(content_length_cstr, MAX_NUMBER, "%u", r.request_info.content_length); | |
| //String content_length(content_length_cstr); | |
| ECSTR(CONTENT_LENGTH, content_length_cstr); | |
| // SCRIPT_* | // SCRIPT_* |
| env.put(String::Body("SCRIPT_NAME"), script_name); | env.put(String::Body("SCRIPT_NAME"), script_name); |
| //env.put(String::Body("SCRIPT_FILENAME"), ??&script_name); | //env.put(String::Body("SCRIPT_FILENAME"), ??&script_name); |
| bool stdin_specified=false; | |
| // environment & stdin from param | // environment & stdin from param |
| String *in=new String(); | String *in=new String(); |
| Charset *charset=0; // default script works raw_in 'source' charset = no transcoding needed | Charset *charset=0; // default script works raw_in 'source' charset = no transcoding needed |
| Line 448 static void _exec_cgi(Request& r, Method | Line 480 static void _exec_cgi(Request& r, Method |
| } | } |
| // $.stdin | // $.stdin |
| if(info.vstdin) { | if(info.vstdin) { |
| stdin_specified=true; | |
| if(const String* sstdin=info.vstdin->get_string()) { | if(const String* sstdin=info.vstdin->get_string()) { |
| in->append(*sstdin, String::L_CLEAN, true); | // untaint stdin |
| in = new String(sstdin->cstr_to_string_body_untaint(String::L_AS_IS), String::L_AS_IS); | |
| } else | } else |
| if(VFile* vfile=static_cast<VFile *>(info.vstdin->as("file"))) | if(VFile* vfile=static_cast<VFile *>(info.vstdin->as("file"))) |
| in->append_know_length((const char* )vfile->value_ptr(), vfile->value_size(), String::L_TAINTED); | in->append_know_length((const char* )vfile->value_ptr(), vfile->value_size(), String::L_TAINTED); |
| Line 509 static void _exec_cgi(Request& r, Method | Line 541 static void _exec_cgi(Request& r, Method |
| if(charset) | if(charset) |
| real_err=&Charset::transcode(*real_err, *charset, r.charsets.source()); | real_err=&Charset::transcode(*real_err, *charset, r.charsets.source()); |
| if(file_out->length && as_text){ | if(file_out->length && is_text){ |
| fix_line_breaks(file_out->str, file_out->length); | fix_line_breaks(file_out->str, file_out->length); |
| // treat output as string | // treat output as string |
| String *real_out = new String(file_out->str); | String *real_out = new String(file_out->str); |
| Line 593 static void _exec_cgi(Request& r, Method | Line 625 static void _exec_cgi(Request& r, Method |
| self.set(false/*not tainted*/, file_out->str, file_out->length); | self.set(false/*not tainted*/, file_out->str, file_out->length); |
| } | } |
| self.set_mode(as_text); | self.set_mode(is_text); |
| // $status | // $status |
| self.fields().put(file_status_name, new VInt(execution.status)); | self.fields().put(file_status_name, new VInt(execution.status)); |
| Line 678 static void _lock(Request& r, MethodPara | Line 710 static void _lock(Request& r, MethodPara |
| &info); | &info); |
| } | } |
| static int lastposafter(const String& s, size_t after, const char* substr, size_t substr_size, bool beforelast=false) { | |
| size_t size=0; // just to calm down compiler | |
| if(beforelast) | |
| size=s.length(); | |
| size_t at; | |
| while((at=s.pos(String::Body(substr), after))!=STRING_NOT_FOUND) { | |
| size_t newafter=at+substr_size/*skip substr*/; | |
| if(beforelast && newafter==size) | |
| break; | |
| after=newafter; | |
| } | |
| return after; | |
| } | |
| static void _find(Request& r, MethodParams& params) { | static void _find(Request& r, MethodParams& params) { |
| const String& file_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE).as_string(); | const String& file_name=params.as_string(0, FILE_NAME_MUST_NOT_BE_CODE); |
| Value* not_found_code=(params.count()==2)?¶ms.as_junction(1, "not-found param must be code"):0; | |
| const String* file_spec; | const String* file_spec; |
| if(file_name.first_char()=='/') | if(file_name.first_char()=='/') |
| file_spec=&file_name; | file_spec=&file_name; |
| Line 724 static void _find(Request& r, MethodPara | Line 743 static void _find(Request& r, MethodPara |
| } | } |
| // no way, not found | // no way, not found |
| if(params.count()==2) { | if(not_found_code) |
| Value& not_found_code=params.as_junction(1, "not-found param must be code"); | r.write_pass_lang(r.process(*not_found_code)); |
| r.write_pass_lang(r.process(not_found_code)); | |
| } | |
| } | } |
| static void _dirname(Request& r, MethodParams& params) { | static void _dirname(Request& r, MethodParams& params) { |
| Line 832 public: | Line 849 public: |
| user_content_type=new String(str, String::L_TAINTED); | user_content_type=new String(str, String::L_TAINTED); |
| break; | break; |
| default: | default: |
| error=SQL_Error(PARSER_RUNTIME, "result must not contain more then one row, three rows"); | error=SQL_Error(PARSER_RUNTIME, "result must not contain more then one row, three columns"); |
| return true; | return true; |
| } | } |
| return false; | return false; |
| Line 856 static void _sql(Request& r, MethodParam | Line 873 static void _sql(Request& r, MethodParam |
| ulong offset=0; | ulong offset=0; |
| if(params.count()>1) | if(params.count()>1) |
| if(HashStringValue* options=params.as_no_junction(1, PARAM_MUST_NOT_BE_CODE).get_hash()){ | if(HashStringValue* options=params.as_hash(1)){ |
| int valid_options=0; | int valid_options=0; |
| if(Value* vfilename=options->get(NAME_NAME)) { | if(Value* vfilename=options->get(NAME_NAME)) { |
| valid_options++; | valid_options++; |
| Line 875 static void _sql(Request& r, MethodParam | Line 892 static void _sql(Request& r, MethodParam |
| offset=(ulong)r.process_to_value(*voffset).as_double(); | offset=(ulong)r.process_to_value(*voffset).as_double(); |
| } | } |
| if(valid_options!=options->count()) | if(valid_options!=options->count()) |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION); |
| 0, | |
| "called with invalid option"); | |
| } | } |
| Line 893 static void _sql(Request& r, MethodParam | Line 908 static void _sql(Request& r, MethodParam |
| 0, | 0, |
| "produced no result"); | "produced no result"); |
| const char* user_file_name_cstr=handlers.user_file_name? handlers.user_file_name->cstr(): 0; | |
| VString* vcontent_type=handlers.user_content_type? | |
| new VString(*handlers.user_content_type) | |
| : user_file_name_cstr? | |
| new VString(r.mime_type_of(user_file_name_cstr)) | |
| : 0; | |
| VFile& self=GET_SELF(r, VFile); | VFile& self=GET_SELF(r, VFile); |
| self.set(true/*tainted*/, handlers.value.str, handlers.value.length, user_file_name_cstr, vcontent_type); | |
| self.set(true/*tainted*/, handlers.value.str, handlers.value.length, handlers.user_file_name | |
| , handlers.user_content_type ? new VString(*handlers.user_content_type) : 0 | |
| , &r); | |
| self.set_mode(false/*binary*/); | self.set_mode(false/*binary*/); |
| } | } |
| static void _base64(Request& r, MethodParams& params) { | static void _base64(Request& r, MethodParams& params) { |
| bool dynamic = !(&r.get_self() == file_class); | bool dynamic=!(&r.get_self() == file_class); |
| if(dynamic){ | if(dynamic) { |
| VFile& self=GET_SELF(r, VFile); | VFile& self=GET_SELF(r, VFile); |
| if(params.count()) { | if(params.count()) { |
| // decode: ^file::base64[encoded] | // decode: |
| const char* cstr=params.as_string(0, PARAMETER_MUST_BE_STRING).cstr(); | // ^file::base64[encoded] // backward |
| // ^file::base64[mode;user-file-name;encoded[;$.content-type[...]]] | |
| bool is_text=false; | |
| VString* vcontent_type=0; | |
| const String* user_file_name=0; | |
| size_t param_index=0; | |
| if(params.count() > 1) { | |
| if(params.count() < 3) | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "constructor can not have less then 3 parameters (has %d parameters)", | |
| params.count()); // actually it accepts 1 parameter (backward) | |
| is_text=VFile::is_text_mode(params.as_string(0, MODE_MUST_NOT_BE_CODE)); | |
| user_file_name=¶ms.as_string(1, FILE_NAME_MUST_BE_STRING); | |
| if(params.count() == 4) | |
| if(HashStringValue* options=params.as_hash(3)) { | |
| int valid_options=0; | |
| if(Value* value=options->get(CONTENT_TYPE_NAME)) { | |
| vcontent_type=new VString(value->as_string()); | |
| valid_options++; | |
| } | |
| if(valid_options!=options->count()) | |
| throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION); | |
| } | |
| param_index=2; | |
| } | |
| const char* encoded=params.as_string(param_index, PARAMETER_MUST_BE_STRING).cstr(); | |
| char* decoded=0; | char* decoded=0; |
| size_t length=0; | size_t length=0; |
| pa_base64_decode(cstr, strlen(cstr), decoded, length); | pa_base64_decode(encoded, strlen(encoded), decoded, length); |
| if(decoded && length) | |
| self.set(true/*tainted*/, decoded, length); | if(length && is_text) |
| fix_line_breaks(decoded, length); | |
| self.set(true/*tainted*/, decoded, length, user_file_name, vcontent_type, &r); | |
| if(params.count() > 1) | |
| self.set_mode(is_text); | |
| } else { | } else { |
| // encode: ^f.base64[] | // encode: ^f.base64[] |
| const char* encoded=pa_base64_encode(self.value_ptr(), self.value_size()); | const char* encoded=pa_base64_encode(self.value_ptr(), self.value_size()); |
| Line 938 static void _crc32(Request& r, MethodPar | Line 987 static void _crc32(Request& r, MethodPar |
| const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); | const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); |
| crc32=pa_crc32(r.absolute(file_spec)); | crc32=pa_crc32(r.absolute(file_spec)); |
| } else { | } else { |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, FILE_NAME_MUST_BE_SPECIFIED); |
| 0, | |
| "file name must be defined"); | |
| } | } |
| } else { | } else { |
| // ^file.crc32[] | // ^file.crc32[] |
| Line 1000 static void _md5(Request& r, MethodParam | Line 1047 static void _md5(Request& r, MethodParam |
| const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); | const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); |
| md5=pa_md5(r.absolute(file_spec)); | md5=pa_md5(r.absolute(file_spec)); |
| } else { | } else { |
| throw Exception(PARSER_RUNTIME, | throw Exception(PARSER_RUNTIME, 0, FILE_NAME_MUST_BE_SPECIFIED); |
| 0, | |
| "file name must be defined"); | |
| } | } |
| } else { | } else { |
| // ^file.md5[] | // ^file.md5[] |
| Line 1016 static void _md5(Request& r, MethodParam | Line 1061 static void _md5(Request& r, MethodParam |
| // constructor | // constructor |
| MFile::MFile(): Methoded("file") { | MFile::MFile(): Methoded("file") { |
| // ^file::create[text;user-name;string] | // ^file::create[text|binary;file-name;string-or-file[;options hash]] |
| // ^file::create[binary;user-name;SOMEDAY SOMETHING] | // ^file::create[string-or-file[;options hash]] |
| add_native_method("create", Method::CT_DYNAMIC, _create, 3, 3); | add_native_method("create", Method::CT_DYNAMIC, _create, 1, 4); |
| // ^file.save[mode;file-name] | // ^file.save[mode;file-name] |
| add_native_method("save", Method::CT_DYNAMIC, _save, 2, 2); | // ^file.save[mode;file-name;$.charset[...]] |
| add_native_method("save", Method::CT_DYNAMIC, _save, 2, 3); | |
| // ^file:delete[file-name] | // ^file:delete[file-name] |
| add_native_method("delete", Method::CT_STATIC, _delete, 1, 1); | add_native_method("delete", Method::CT_STATIC, _delete, 1, 1); |
| Line 1031 MFile::MFile(): Methoded("file") { | Line 1077 MFile::MFile(): Methoded("file") { |
| // ^file::load[mode;disk-name] | // ^file::load[mode;disk-name] |
| // ^file::load[mode;disk-name;user-name] | // ^file::load[mode;disk-name;user-name] |
| // ^file::load[mode;disk-name;user-name;options hash] | |
| // ^file::load[mode;disk-name;options hash] | |
| add_native_method("load", Method::CT_DYNAMIC, _load, 2, 4); | add_native_method("load", Method::CT_DYNAMIC, _load, 2, 4); |
| // ^file::stat[disk-name] | // ^file::stat[disk-name] |
| Line 1057 MFile::MFile(): Methoded("file") { | Line 1105 MFile::MFile(): Methoded("file") { |
| // ^file:find[file-name]{when-not-found} | // ^file:find[file-name]{when-not-found} |
| add_native_method("find", Method::CT_STATIC, _find, 1, 2); | add_native_method("find", Method::CT_STATIC, _find, 1, 2); |
| // ^file:dirname[/a/some.tar.gz]=/a | // ^file:dirname[/a/some.tar.gz]=/a |
| // ^file:dirname[/a/b/]=/a | // ^file:dirname[/a/b/]=/a |
| add_native_method("dirname", Method::CT_STATIC, _dirname, 1, 1); | add_native_method("dirname", Method::CT_STATIC, _dirname, 1, 1); |
| // ^file:basename[/a/some.tar.gz]=some.tar.gz | // ^file:basename[/a/some.tar.gz]=some.tar.gz |
| add_native_method("basename", Method::CT_STATIC, _basename, 1, 1); | add_native_method("basename", Method::CT_STATIC, _basename, 1, 1); |
| // ^file:justname[/a/some.tar.gz]=some.tar | // ^file:justname[/a/some.tar.gz]=some.tar |
| add_native_method("justname", Method::CT_STATIC, _justname, 1, 1); | add_native_method("justname", Method::CT_STATIC, _justname, 1, 1); |
| // ^file:justext[/a/some.tar.gz]=gz | // ^file:justext[/a/some.tar.gz]=gz |
| add_native_method("justext", Method::CT_STATIC, _justext, 1, 1); | add_native_method("justext", Method::CT_STATIC, _justext, 1, 1); |
| // /some/page.html: ^file:fullpath[a.gif] => /some/a.gif | // /some/page.html: ^file:fullpath[a.gif] => /some/a.gif |
| add_native_method("fullpath", Method::CT_STATIC, _fullpath, 1, 1); | add_native_method("fullpath", Method::CT_STATIC, _fullpath, 1, 1); |
| // ^file.sql-string[] | // ^file.sql-string[] |
| add_native_method("sql-string", Method::CT_DYNAMIC, _sql_string, 0, 0); | add_native_method("sql-string", Method::CT_DYNAMIC, _sql_string, 0, 0); |
| // ^file::sql[[alt_name]]{} | // ^file::sql{} |
| // ^file::sql{}[options hash] | |
| add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 2); | add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 2); |
| // ^file::base64[string] << decode | // encode: |
| // ^file.base64[] << encode | // ^file.base64[] |
| // ^file:base64[file-name] << encode | // ^file:base64[file-name] |
| add_native_method("base64", Method::CT_ANY, _base64, 0, 1); | // decode: |
| // ^file::base64[encoded] // backward | |
| // ^file::base64[mode;user-file-name;encoded] | |
| // ^file::base64[mode;user-file-name;encoded;$.content-type[...]] | |
| add_native_method("base64", Method::CT_ANY, _base64, 0, 4); | |
| // ^file.crc32[] | // ^file.crc32[] |
| // ^file:crc32[file-name] | // ^file:crc32[file-name] |