|
|
| version 1.133.6.3, 2005/11/16 14:18:05 | version 1.157, 2007/05/03 10:40:45 |
|---|---|
| Line 25 static const char * const IDENT_FILE_C=" | Line 25 static const char * const IDENT_FILE_C=" |
| #include "pa_charset.h" | #include "pa_charset.h" |
| #include "pa_charsets.h" | #include "pa_charsets.h" |
| #include "pa_sql_connection.h" | #include "pa_sql_connection.h" |
| #include "pa_md5.h" | |
| // defines | // defines |
| Line 35 static const char * const IDENT_FILE_C=" | Line 36 static const char * const IDENT_FILE_C=" |
| #define NAME_NAME "name" | #define NAME_NAME "name" |
| #define FILE_NAME_MUST_BE_STRING "file name must be string" | |
| #define FILE_NAME_MUST_NOT_BE_CODE "file name must not be code" | |
| // externs | // externs |
| extern String sql_limit_name; | extern String sql_limit_name; |
| Line 45 extern String sql_offset_name; | Line 49 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&, HashStringValue&) { return new VFile(); } |
| public: // Methoded | public: // Methoded |
| bool used_directly() { return true; } | bool used_directly() { return true; } |
| Line 118 static bool is_text_mode(const String& m | Line 122 static bool is_text_mode(const String& m |
| return true; | return true; |
| if(mode==BINARY_MODE_NAME) | if(mode==BINARY_MODE_NAME) |
| return false; | return false; |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| &mode, | &mode, |
| "is invalid mode, must be either '"TEXT_MODE_NAME"' or '"BINARY_MODE_NAME"'"); | "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"); | Value& vmode_name=params. as_no_junction(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); |
| // save | // save |
| GET_SELF(r, VFile).save(r.absolute(vfile_name.as_string()), | GET_SELF(r, VFile).save(r.absolute(vfile_name.as_string()), |
| Line 133 static void _save(Request& r, MethodPara | Line 137 static void _save(Request& r, MethodPara |
| } | } |
| 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"); | Value& vfile_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE); |
| // unlink | // unlink |
| file_delete(r.absolute(vfile_name.as_string())); | file_delete(r.absolute(vfile_name.as_string())); |
| Line 149 static void _move(Request& r, MethodPara | Line 153 static void _move(Request& r, MethodPara |
| r.absolute(vto_file_name.as_string())); | r.absolute(vto_file_name.as_string())); |
| } | } |
| static void copy_process_source( | |
| struct stat& , | |
| int from_file, | |
| const String& , const char* /*fname*/, bool, | |
| void *context) { | |
| int& to_file=*static_cast<int *>(context); | |
| int nCount=0; | |
| do { | |
| unsigned char buffer[FILE_BUFFER_SIZE]; | |
| nCount = file_block_read(from_file, buffer, sizeof(buffer)); | |
| int written=write(to_file, buffer, nCount); | |
| if( written < 0 ) | |
| throw Exception(0, | |
| 0, | |
| "write failed: %s (%d)", strerror(errno), errno); | |
| } while(nCount > 0); | |
| } | |
| static void copy_open_target(int f, void *from_spec) { | |
| String& file_spec=*static_cast<String *>(from_spec); | |
| file_read_action_under_lock(file_spec, "copy", copy_process_source, &f); | |
| }; | |
| static void _copy(Request& r, MethodParams& params) { | |
| Value& vfrom_file_name=params.as_no_junction(0, "from file name must not be code"); | |
| Value& vto_file_name=params.as_no_junction(1, "to file name must not be code"); | |
| String from_spec = r.absolute(vfrom_file_name.as_string()); | |
| const String& to_spec = r.absolute(vto_file_name.as_string()); | |
| file_write_action_under_lock( | |
| to_spec, | |
| "copy", | |
| copy_open_target, | |
| &from_spec); | |
| } | |
| static void _load_pass_param( | static void _load_pass_param( |
| HashStringValue::key_type key, | HashStringValue::key_type key, |
| HashStringValue::value_type value, | HashStringValue::value_type value, |
| Line 157 static void _load_pass_param( | Line 200 static void _load_pass_param( |
| } | } |
| static void _load(Request& r, MethodParams& params) { | static void _load(Request& r, MethodParams& params) { |
| Value& vmode_name=params. as_no_junction(0, "mode must not be code"); | Value& vmode_name=params. as_no_junction(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_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE).as_string()); |
| Value* third_param=params.count()>2?¶ms.as_no_junction(2, "filename or options must not be code") | Value* third_param=params.count()>2?¶ms.as_no_junction(2, "filename or options must not be code") |
| :0; | :0; |
| HashStringValue* third_param_hash=third_param?third_param->get_hash():0; | HashStringValue* third_param_hash=third_param?third_param->get_hash():0; |
| Line 184 static void _load(Request& r, MethodPara | Line 227 static void _load(Request& r, MethodPara |
| ); | ); |
| const char *user_file_name=params.count()>alt_filename_param_index? | const char *user_file_name=params.count()>alt_filename_param_index? |
| params.as_string(alt_filename_param_index, "filename must be string").cstr() | params.as_string(alt_filename_param_index, FILE_NAME_MUST_BE_STRING).cstr() |
| :lfile_name.cstr(String::L_FILE_SPEC); | :lfile_name.cstr(String::L_FILE_SPEC); |
| Value* vcontent_type=0; | Value* vcontent_type=0; |
| Line 199 static void _load(Request& r, MethodPara | Line 242 static void _load(Request& r, MethodPara |
| 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); |
| if(file.headers) | if(file.headers) |
| file.headers->for_each(_load_pass_param, &self.fields()); | file.headers->for_each<HashStringValue*>(_load_pass_param, &self.fields()); |
| } | |
| static void _create(Request& r, MethodParams& params) { | |
| Value& vmode_name=params. as_no_junction(0, "mode must not be code"); | |
| if(!is_text_mode(vmode_name.as_string())) | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "only text mode is currently supported"); | |
| const char* user_file_name_cstr=r.absolute( | |
| params.as_no_junction(1, FILE_NAME_MUST_NOT_BE_CODE).as_string()).cstr(String::L_FILE_SPEC); | |
| const String& content=params.as_string(2, "content must be string"); | |
| const char* content_cstr=content.cstr(String::L_UNSPECIFIED); // explode content, honor tainting changes | |
| VString* vcontent_type=new VString(r.mime_type_of(user_file_name_cstr)); | |
| VFile& self=GET_SELF(r, VFile); | |
| self.set(true/*tainted*/, content_cstr, strlen(content_cstr), user_file_name_cstr, vcontent_type); | |
| } | } |
| 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"); | Value& vfile_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE); |
| const String& lfile_name=vfile_name.as_string(); | const String& lfile_name=vfile_name.as_string(); |
| Line 240 static bool is_safe_env_key(const char* | Line 302 static bool is_safe_env_key(const char* |
| } | } |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| struct Append_env_pair_info { | struct Append_env_pair_info { |
| Request_charsets* charsets; | |
| HashStringString* env; | HashStringString* env; |
| Value* vstdin; | Value* vstdin; |
| Value* vcharset; | |
| }; | }; |
| #endif | #endif |
| static void append_env_pair( | static void append_env_pair( |
| Line 252 static void append_env_pair( | Line 314 static void append_env_pair( |
| if(akey==STDIN_EXEC_PARAM_NAME) { | if(akey==STDIN_EXEC_PARAM_NAME) { |
| info->vstdin=avalue; | info->vstdin=avalue; |
| } else if(akey==CHARSET_EXEC_PARAM_NAME) { | } else if(akey==CHARSET_EXEC_PARAM_NAME) { |
| info->vcharset=avalue; | // ignore, already processed |
| } else { | } else { |
| if(!is_safe_env_key(akey.cstr())) | if(!is_safe_env_key(akey.cstr())) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| new String(akey, String::L_TAINTED), | new String(akey, String::L_TAINTED), |
| "not safe environment variable"); | "not safe environment variable"); |
| info->env->put(akey, avalue->as_string().cstr_to_string_body(String::L_UNSPECIFIED)); | info->env->put(akey, avalue->as_string().cstr_to_string_body(String::L_UNSPECIFIED, 0, info->charsets)); |
| } | } |
| } | } |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| Line 281 static void pass_cgi_header_attribute( | Line 343 static void pass_cgi_header_attribute( |
| info->content_type=value; | info->content_type=value; |
| } | } |
| } | } |
| static void append_to_argv(Request& r, ArrayString& argv, const String* str){ | |
| if( str->length() ){ | |
| argv+=new String(str->cstr_to_string_body(String::L_UNSPECIFIED, 0, &r.charsets), String::L_AS_IS); | |
| } | |
| } | |
| /// @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, | static void _exec_cgi(Request& r, MethodParams& params, |
| bool cgi) { | bool cgi) { |
| Value& vfile_name=params.as_no_junction(0, "file name must not be code"); | Value& vfile_name=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE); |
| const String& script_name=r.absolute(vfile_name.as_string()); | const String& script_name=r.absolute(vfile_name.as_string()); |
| Line 329 static void _exec_cgi(Request& r, Method | Line 398 static void _exec_cgi(Request& r, Method |
| if(params.count()>1) { | if(params.count()>1) { |
| Value& venv=params.as_no_junction(1, "env must not be code"); | Value& venv=params.as_no_junction(1, "env must not be code"); |
| if(HashStringValue* user_env=venv.get_hash()) { | if(HashStringValue* user_env=venv.get_hash()) { |
| Append_env_pair_info info={&env, 0, 0}; | // $.charset [previewing to handle URI pieces] |
| user_env->for_each(append_env_pair, &info); | if(Value* vcharset=user_env->get(CHARSET_EXEC_PARAM_NAME)) |
| charset=&charsets.get(vcharset->as_string() | |
| .change_case(r.charsets.source(), String::CC_UPPER)); | |
| // $.others | |
| Append_env_pair_info info={&r.charsets, &env, 0}; | |
| { | |
| // influence tainting | |
| // main target -- $.QUERY_STRING -- URLencoding of tainted pieces to String::L_URI lang | |
| Temp_client_charset temp(r.charsets, charset? *charset: r.charsets.source()); | |
| user_env->for_each<Append_env_pair_info*>(append_env_pair, &info); | |
| } | |
| // $.stdin | // $.stdin |
| if(info.vstdin) { | if(info.vstdin) { |
| stdin_specified=true; | stdin_specified=true; |
| Line 340 static void _exec_cgi(Request& r, Method | Line 420 static void _exec_cgi(Request& r, Method |
| if(VFile* vfile=static_cast<VFile *>(info.vstdin->as("file", false))) | if(VFile* vfile=static_cast<VFile *>(info.vstdin->as("file", false))) |
| 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); |
| else | else |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| STDIN_EXEC_PARAM_NAME " parameter must be string or file"); | STDIN_EXEC_PARAM_NAME " parameter must be string or file"); |
| } | } |
| // $.charset | |
| if(info.vcharset) | |
| charset=&charsets.get(info.vcharset->as_string() | |
| .change_case(r.charsets.source(), String::CC_UPPER)); | |
| } | } |
| } | } |
| // argv from params | // argv from params |
| ArrayString argv; | ArrayString argv; |
| if(params.count()>2) { | if(params.count()>2) { |
| for(size_t i=2; i<params.count(); i++) | // influence tainting |
| argv+=¶ms.as_string(i, "parameter must be string"); | // main target -- URLencoding of tainted pieces to String::L_URI lang |
| Temp_client_charset temp(r.charsets, charset? *charset: r.charsets.source()); | |
| for(size_t i=2; i<params.count(); i++) { | |
| Value& param=params.as_no_junction(i, "parameter must not be code"); | |
| if(param.is_defined()){ | |
| if(param.is_string()){ | |
| append_to_argv(r, argv, param.get_string()); | |
| } else { | |
| Table* table=param.get_table(); | |
| if(table){ | |
| for(size_t i=0; i<table->count(); i++) { | |
| append_to_argv(r, argv, table->get(i)->get(0)); | |
| } | |
| } else { | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "parameter must be string or table"); | |
| } | |
| } | |
| } | |
| } | |
| } | } |
| // transcode if necessary | // transcode if necessary |
| Line 536 static void lock_execute_body(int , void | Line 633 static void lock_execute_body(int , void |
| info.r->write_assign_lang(info.r->process(*info.body_code)); | info.r->write_assign_lang(info.r->process(*info.body_code)); |
| }; | }; |
| static void _lock(Request& r, MethodParams& params) { | static void _lock(Request& r, MethodParams& params) { |
| const String& file_spec=r.absolute(params.as_string(0, "file name must be string")); | const String& file_spec=r.absolute(params.as_string(0, FILE_NAME_MUST_BE_STRING)); |
| Lock_execute_body_info info={ | Lock_execute_body_info info={ |
| &r, | &r, |
| ¶ms.as_junction(1, "body must be code") | ¶ms.as_junction(1, "body must be code") |
| Line 561 static int lastposafter(const String& s, | Line 658 static int lastposafter(const String& s, |
| } | } |
| 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_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE).as_string(); |
| 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 569 static void _find(Request& r, MethodPara | Line 666 static void _find(Request& r, MethodPara |
| file_spec=&r.relative(r.request_info.uri, file_name); | file_spec=&r.relative(r.request_info.uri, file_name); |
| // easy way | // easy way |
| if(file_readable(r.absolute(*file_spec))) { | if(file_exist(r.absolute(*file_spec))) { |
| r.write_assign_lang(*file_spec); | r.write_assign_lang(*file_spec); |
| return; | return; |
| } | } |
| Line 584 static void _find(Request& r, MethodPara | Line 681 static void _find(Request& r, MethodPara |
| String test_name; | String test_name; |
| test_name<<*(dirname=&dirname->mid(0, after_monkey_slash)); | test_name<<*(dirname=&dirname->mid(0, after_monkey_slash)); |
| test_name<<basename; | test_name<<basename; |
| if(file_readable(r.absolute(test_name))) { | if(file_exist(r.absolute(test_name))) { |
| r.write_assign_lang(test_name); | r.write_assign_lang(test_name); |
| return; | return; |
| } | } |
| Line 598 static void _find(Request& r, MethodPara | Line 695 static void _find(Request& r, MethodPara |
| } | } |
| static void _dirname(Request& r, MethodParams& params) { | static void _dirname(Request& r, MethodParams& params) { |
| 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); |
| // /a/some.tar.gz > /a | // /a/some.tar.gz > /a |
| // /a/b/ > /a | // /a/b/ > /a |
| int afterslash=lastposafter(file_spec, 0, "/", 1, true); | int afterslash=lastposafter(file_spec, 0, "/", 1, true); |
| Line 609 static void _dirname(Request& r, MethodP | Line 706 static void _dirname(Request& r, MethodP |
| } | } |
| static void _basename(Request& r, MethodParams& params) { | static void _basename(Request& r, MethodParams& params) { |
| 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); |
| // /a/some.tar.gz > some.tar.gz | // /a/some.tar.gz > some.tar.gz |
| int afterslash=lastposafter(file_spec, 0, "/", 1); | int afterslash=lastposafter(file_spec, 0, "/", 1); |
| r.write_assign_lang(file_spec.mid(afterslash, file_spec.length())); | r.write_assign_lang(file_spec.mid(afterslash, file_spec.length())); |
| } | } |
| static void _justname(Request& r, MethodParams& params) { | static void _justname(Request& r, MethodParams& params) { |
| 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); |
| // /a/some.tar.gz > some.tar | // /a/some.tar.gz > some.tar |
| int afterslash=lastposafter(file_spec, 0, "/", 1); | int afterslash=lastposafter(file_spec, 0, "/", 1); |
| int afterdot=lastposafter(file_spec, afterslash, ".", 1); | int afterdot=lastposafter(file_spec, afterslash, ".", 1); |
| r.write_assign_lang(file_spec.mid(afterslash, afterdot!=afterslash?afterdot-1:file_spec.length())); | r.write_assign_lang(file_spec.mid(afterslash, afterdot!=afterslash?afterdot-1:file_spec.length())); |
| } | } |
| static void _justext(Request& r, MethodParams& params) { | static void _justext(Request& r, MethodParams& params) { |
| 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); |
| // /a/some.tar.gz > gz | // /a/some.tar.gz > gz |
| int afterdot=lastposafter(file_spec, 0, ".", 1); | int afterdot=lastposafter(file_spec, 0, ".", 1); |
| if(afterdot>0) | if(afterdot>0) |
| Line 631 static void _justext(Request& r, MethodP | Line 728 static void _justext(Request& r, MethodP |
| } | } |
| static void _fullpath(Request& r, MethodParams& params) { | static void _fullpath(Request& r, MethodParams& params) { |
| 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); |
| const String* result; | const String* result; |
| if(file_spec.first_char()=='/') | if(file_spec.first_char()=='/') |
| result=&file_spec; | result=&file_spec; |
| Line 677 public: | Line 774 public: |
| bool add_column(SQL_Error& error, const char* /*str*/, size_t /*length*/) { | bool add_column(SQL_Error& error, const char* /*str*/, size_t /*length*/) { |
| if(got_columns++==3) { | if(got_columns++==3) { |
| error=SQL_Error("parser.runtime", "result must contain not more then 3 columns"); | error=SQL_Error(PARSER_RUNTIME, "result must contain not more then 3 columns"); |
| return true; | return true; |
| } | } |
| return false; | return false; |
| Line 699 public: | Line 796 public: |
| user_content_type=new String(str, length, true); | user_content_type=new String(str, length, true); |
| 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 rows"); |
| return true; | return true; |
| } | } |
| return false; | return false; |
| Line 732 static void _sql(Request& r, MethodParam | Line 829 static void _sql(Request& r, MethodParam |
| handlers.user_content_type=&vcontent_type->as_string(); | handlers.user_content_type=&vcontent_type->as_string(); |
| } | } |
| if(valid_options!=options->count()) | if(valid_options!=options->count()) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "called with invalid option"); | "called with invalid option"); |
| } | } |
| Line 746 static void _sql(Request& r, MethodParam | Line 843 static void _sql(Request& r, MethodParam |
| statement_string); | statement_string); |
| if(!handlers.value) | if(!handlers.value) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "produced no result"); | "produced no result"); |
| Line 761 static void _sql(Request& r, MethodParam | Line 858 static void _sql(Request& r, MethodParam |
| 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, user_file_name_cstr, vcontent_type); |
| } | } |
| static void _base64(Request& r, MethodParams& params) { | |
| bool dynamic = !(&r.get_self() == file_class); | |
| if ( dynamic ){ | |
| VFile& self=GET_SELF(r, VFile); | |
| if(params.count()) { | |
| // decode | |
| const char* cstr=params.as_string(0, "parameter must be string").cstr(); | |
| char* decoded_cstr=0; | |
| size_t decoded_size=0; | |
| pa_base64_decode(cstr, strlen(cstr), decoded_cstr, decoded_size); | |
| if(decoded_cstr && decoded_size) | |
| self.set(true/*tainted*/, decoded_cstr, decoded_size); | |
| } else { | |
| // encode | |
| const char* encoded=pa_base64_encode(self.value_ptr(), self.value_size()); | |
| r.write_assign_lang(*new String(encoded, 0, true/*once ?param=base64(something) was needed*/)); | |
| } | |
| } else { | |
| // encode | |
| const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); | |
| const char* encoded=pa_base64_encode(r.absolute(file_spec)); | |
| r.write_assign_lang(*new String(encoded, 0, true/*once ?param=base64(something) was needed*/)); | |
| } | |
| } | |
| static void _crc32(Request& r, MethodParams& params) { | |
| unsigned long crc32 = 0; | |
| if(&r.get_self() == file_class) { | |
| // ^file:crc32[file-name] | |
| if(params.count()) { | |
| const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); | |
| crc32=pa_crc32(r.absolute(file_spec)); | |
| } else { | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "file name must be defined"); | |
| } | |
| } else { | |
| // ^file.crc32[] | |
| VFile& self=GET_SELF(r, VFile); | |
| crc32=pa_crc32(self.value_ptr(), self.value_size()); | |
| } | |
| r.write_no_lang(*new VInt(crc32)); | |
| } | |
| static void file_md5_file_action( | |
| struct stat& finfo, | |
| int f, | |
| const String& , const char* /*fname*/, bool, | |
| void *context) | |
| { | |
| PA_MD5_CTX& md5context=*static_cast<PA_MD5_CTX *>(context); | |
| if(finfo.st_size) { | |
| int nCount=0; | |
| do { | |
| unsigned char buffer[FILE_BUFFER_SIZE]; | |
| nCount = file_block_read(f, buffer, sizeof(buffer)); | |
| if ( nCount ){ | |
| pa_MD5Update(&md5context, (const unsigned char*)buffer, nCount); | |
| } | |
| } while(nCount > 0); | |
| } | |
| } | |
| const char* pa_md5(const String& file_spec) | |
| { | |
| PA_MD5_CTX context; | |
| unsigned char digest[16]; | |
| pa_MD5Init(&context); | |
| file_read_action_under_lock(file_spec, "md5", file_md5_file_action, &context); | |
| pa_MD5Final(digest, &context); | |
| return hex_string(digest, sizeof(digest), false); | |
| } | |
| const char* pa_md5(const char *in, size_t in_size) | |
| { | |
| PA_MD5_CTX context; | |
| unsigned char digest[16]; | |
| pa_MD5Init(&context); | |
| pa_MD5Update(&context, (const unsigned char*)in, in_size); | |
| pa_MD5Final(digest, &context); | |
| return hex_string(digest, sizeof(digest), false); | |
| } | |
| static void _md5(Request& r, MethodParams& params) { | |
| const char* md5; | |
| if(&r.get_self() == file_class) { | |
| // ^file:md5[file-name] | |
| if(params.count()) { | |
| const String& file_spec=params.as_string(0, FILE_NAME_MUST_BE_STRING); | |
| md5=pa_md5(r.absolute(file_spec)); | |
| } else { | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "file name must be defined"); | |
| } | |
| } else { | |
| // ^file.md5[] | |
| VFile& self=GET_SELF(r, VFile); | |
| md5=pa_md5(self.value_ptr(), self.value_size()); | |
| } | |
| r.write_no_lang(*new String(md5)); | |
| } | |
| // constructor | // constructor |
| MFile::MFile(): Methoded("file") { | MFile::MFile(): Methoded("file") { |
| // ^save[mode;file-name] | // ^file::create[text;user-name;string] |
| // ^file::create[binary;user-name;SOMEDAY SOMETHING] | |
| add_native_method("create", Method::CT_DYNAMIC, _create, 3, 3); | |
| // ^file.save[mode;file-name] | |
| add_native_method("save", Method::CT_DYNAMIC, _save, 2, 2); | add_native_method("save", Method::CT_DYNAMIC, _save, 2, 2); |
| // ^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); |
| // ^move[from-file-name;to-file-name] | // ^file:move[from-file-name;to-file-name] |
| add_native_method("move", Method::CT_STATIC, _move, 2, 2); | add_native_method("move", Method::CT_STATIC, _move, 2, 2); |
| // ^load[mode;disk-name] | // ^file::load[mode;disk-name] |
| // ^load[mode;disk-name;user-name] | // ^file::load[mode;disk-name;user-name] |
| add_native_method("load", Method::CT_DYNAMIC, _load, 2, 3); | add_native_method("load", Method::CT_DYNAMIC, _load, 2, 3); |
| // ^stat[disk-name] | // ^file::stat[disk-name] |
| add_native_method("stat", Method::CT_DYNAMIC, _stat, 1, 1); | add_native_method("stat", Method::CT_DYNAMIC, _stat, 1, 1); |
| // ^cgi[file-name] | // ^file::cgi[file-name] |
| // ^cgi[file-name;env hash] | // ^file::cgi[file-name;env hash] |
| // ^cgi[file-name;env hash;1cmd;2line;3ar;4g;5s] | // ^file::cgi[file-name;env hash;1cmd;2line;3ar;4g;5s] |
| add_native_method("cgi", Method::CT_DYNAMIC, _cgi, 1, 2+50); | add_native_method("cgi", Method::CT_DYNAMIC, _cgi, 1, 2+50); |
| // ^exec[file-name] | // ^file::exec[file-name] |
| // ^exec[file-name;env hash] | // ^file::exec[file-name;env hash] |
| // ^exec[file-name;env hash;1cmd;2line;3ar;4g;5s] | // ^file::exec[file-name;env hash;1cmd;2line;3ar;4g;5s] |
| add_native_method("exec", Method::CT_DYNAMIC, _exec, 1, 2+50); | add_native_method("exec", Method::CT_DYNAMIC, _exec, 1, 2+50); |
| // ^file:list[path] | // ^file:list[path] |
| Line 797 MFile::MFile(): Methoded("file") { | Line 1006 MFile::MFile(): Methoded("file") { |
| // ^file:lock[path]{code} | // ^file:lock[path]{code} |
| add_native_method("lock", Method::CT_STATIC, _lock, 2, 2); | add_native_method("lock", Method::CT_STATIC, _lock, 2, 2); |
| // ^find[file-name] | // ^file:find[file-name] |
| // ^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 |
| Line 818 MFile::MFile(): Methoded("file") { | Line 1027 MFile::MFile(): Methoded("file") { |
| // ^file::sql[[alt_name]]{} | // ^file::sql[[alt_name]]{} |
| add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 2); | add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 2); |
| // ^file::base64[string] << decode | |
| // ^file.base64[] << encode | |
| // ^file:base64[file-name] << encode | |
| add_native_method("base64", Method::CT_ANY, _base64, 0, 1); | |
| // ^file.crc32[] | |
| // ^file:crc32[file-name] | |
| add_native_method("crc32", Method::CT_ANY, _crc32, 0, 1); | |
| // ^file.md5[] | |
| // ^file:md5[file-name] | |
| add_native_method("md5", Method::CT_ANY, _md5, 0, 1); | |
| // ^file:copy[from-file-name;to-file-name] | |
| add_native_method("copy", Method::CT_STATIC, _copy, 2, 2); | |
| } | } |