|
|
| version 1.1, 2001/10/22 12:30:24 | version 1.33.14.2, 2005/08/08 09:23:24 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b hashfile parser class. | Parser: @b hashfile parser class. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2005 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| $Id$ | |
| */ | */ |
| #include "pa_config_includes.h" | |
| #ifdef HAVE_LIBDB | static const char * const IDENT="$Id$"; |
| #include "classes.h" | #include "classes.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_vmethod_frame.h" | |
| #include "pa_vhashfile.h" | #include "pa_vhashfile.h" |
| #include "pa_vhash.h" | #include "pa_vhash.h" |
| // defines | |
| #define HASH_CLASS_NAME "hashfile" | |
| // class | // class |
| class MHashfile : public Methoded { | class MHashfile : public Methoded { |
| public: // VStateless_class | public: // VStateless_class |
| Value *create_new_value(Pool& pool) { return new(pool) VHashfile(pool); } | Value *create_new_value(Pool& apool) { return new VHashfile(apool); } |
| public: | public: |
| MHashfile(Pool& pool); | MHashfile(); |
| public: // Methoded | public: // Methoded |
| bool used_directly() { return true; } | bool used_directly() { return true; } |
| }; | }; |
| // global variable | |
| DECLARE_CLASS_VAR(hashfile, new MHashfile, 0); | |
| // defines for statics | |
| #define OPEN_DATA_NAME "HASHFILE-OPEN-DATA" | |
| // methods | // methods |
| static void _assign(Request& r, const String& method_name, MethodParams *params) { | typedef Hash<const String::Body, bool> HashStringBool; |
| Pool& pool=r.pool(); | |
| VHashfile& self=*static_cast<VHashfile *>(r.self); | static void _open(Request& r, MethodParams& params) { |
| HashStringBool* file_list=static_cast<HashStringBool*>(r.classes_conf.get(OPEN_DATA_NAME)); | |
| const String &sfile_spec=params->as_string(0, "filename must be string"); | if(!file_list) { |
| file_list=new HashStringBool(); | |
| r.classes_conf.put(OPEN_DATA_NAME, file_list); | |
| } | |
| const String& file_spec=r.absolute(params.as_string(0, "filename must be string")); | |
| if(file_list->get(file_spec)) | |
| throw Exception("parser.runtime", | |
| 0, | |
| "this hashfile is already opened, use existing variable"); | |
| file_list->put(file_spec, true); | |
| self.set_file_spec(r.absolute(sfile_spec)); | VHashfile& self=GET_SELF(r, VHashfile); |
| self.open(file_spec); | |
| } | } |
| //static_cast<VHashfile *>(r.self) const String& file_spec=->file_spec(); | |
| // constructor | static void _hash(Request& r, MethodParams&) { |
| VHashfile& self=GET_SELF(r, VHashfile); | |
| // write out result | |
| VHash& result=*new VHash(*self.get_hash()); | |
| r.write_no_lang(result); | |
| } | |
| MHashfile::MHashfile(Pool& apool) : Methoded(apool) { | static void _delete(Request& r, MethodParams& params) { |
| set_name(*NEW String(pool(), HASH_CLASS_NAME)); | VHashfile& self=GET_SELF(r, VHashfile); |
| if(!params.count()) { | |
| // ^hashfile.delete[] asked to delete hashfile itself | |
| self.delete_files(); | |
| return; | |
| } | |
| // key | |
| const String &key=params.as_string(0, "key must be string"); | |
| // remove | |
| self.remove(key); | |
| } | |
| // ^hashfile::assign[filename] | static void _clear(Request& r, MethodParams&) { |
| add_native_method("assign", Method::CT_DYNAMIC, _assign, 1, 1); | VHashfile& self=GET_SELF(r, VHashfile); |
| /* | self.clear(); |
| // ^hashfile.delete[key] | |
| add_native_method("delete", Method::CT_DYNAMIC, _delete, 1, 1); | |
| // ^hashfile.clear[] | |
| add_native_method("clear", Method::CT_DYNAMIC, _clear, 0, 0); | |
| // ^cache[key](seconds){code} | |
| add_native_method("cache", Method::CT_DYNAMIC, _cache, 3, 3); | |
| // ^cancel[] | |
| add_native_method("cancel", Method::CT_DYNAMIC, _cancel, 0, 0); | |
| // ^lock{code} | |
| add_native_method("lock", Method::CT_DYNAMIC, _lock, 1, 1); | |
| // ^pack[] | |
| add_native_method("pack", Method::CT_DYNAMIC, _pack, 0, 0); | |
| */ | |
| } | } |
| // global variable | #ifndef DOXYGEN |
| struct Foreach_info { | |
| Request* r; | |
| const String* key_var_name; | |
| const String* value_var_name; | |
| Value* body_code; | |
| Value* delim_maybe_code; | |
| Value* var_context; | |
| VString* vkey; | |
| VString* vvalue; | |
| bool need_delim; | |
| }; | |
| #endif | |
| static void one_foreach_cycle(const String::Body key, const String& value, void* ainfo) { | |
| Foreach_info& info=*static_cast<Foreach_info*>(ainfo); | |
| info.vkey->set_string(*new String(key, String::L_TAINTED)); | |
| info.vvalue->set_string(value); | |
| info.var_context->put_element(*info.key_var_name, info.vkey, false); | |
| info.var_context->put_element(*info.value_var_name, info.vvalue, false); | |
| StringOrValue sv_processed=info.r->process(*info.body_code); | |
| const String* s_processed=sv_processed.get_string(); | |
| if(info.delim_maybe_code && s_processed && s_processed->length()) { // delimiter set and we have body | |
| if(info.need_delim) // need delim & iteration produced string? | |
| info.r->write_pass_lang(info.r->process(*info.delim_maybe_code)); | |
| info.need_delim=true; | |
| } | |
| info.r->write_pass_lang(sv_processed); | |
| } | |
| static void _foreach(Request& r, MethodParams& params) { | |
| VHashfile& self=GET_SELF(r, VHashfile); | |
| Methoded *hashfile_base_class; | Foreach_info info; |
| info.r=&r; | |
| info.key_var_name=¶ms.as_string(0, "key-var name must be string"); | |
| info.value_var_name=¶ms.as_string(1, "value-var name must be string"); | |
| info.body_code=¶ms.as_junction(2, "body must be code"); | |
| info.delim_maybe_code=params.count()>3?params.get(3):0; | |
| info.var_context=info.body_code->get_junction()->wcontext; | |
| info.vkey=new VString; | |
| info.vvalue=new VString; | |
| // creator | info.need_delim=false; |
| Methoded *MHashfile_create(Pool& pool) { | self.for_each(one_foreach_cycle, &info); |
| return hashfile_base_class=new(pool) MHashfile(pool); | |
| } | } |
| #endif | // constructor |
| MHashfile::MHashfile(): Methoded("hashfile") { | |
| // ^hashfile::open[db_home;filename] | |
| add_native_method("open", Method::CT_DYNAMIC, _open, 1, 1); | |
| // ^hash[] | |
| add_native_method("hash", Method::CT_DYNAMIC, _hash, 0, 0); | |
| // ^hashfile.delete[key] | |
| add_native_method("delete", Method::CT_DYNAMIC, _delete, 0, 1); | |
| // ^hashfile.clear[] | |
| add_native_method("clear", Method::CT_DYNAMIC, _clear, 0, 0); | |
| // ^hashfile.foreach[key;value]{code}[delim] | |
| add_native_method("foreach", Method::CT_DYNAMIC, _foreach, 2+1, 2+1+1); | |
| } |