|
|
| version 1.34, 2001/08/06 16:18:26 | version 1.43, 2001/10/31 14:01:44 |
|---|---|
| Line 2 | Line 2 |
| Parser: @b mail parser class. | Parser: @b mail parser class. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) |
| $Id$ | $Id$ |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include "pa_config_includes.h" | #include "pa_config_includes.h" |
| Line 129 static const String& attach_hash_to_stri | Line 127 static const String& attach_hash_to_stri |
| Value *vtype=static_cast<Value *>(attach_hash.get(*new(pool) String(pool, "type"))); | Value *vtype=static_cast<Value *>(attach_hash.get(*new(pool) String(pool, "type"))); |
| if(!vtype) | if(!vtype) |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &origin_string, | &origin_string, |
| "has no $type"); | "has no $type"); |
| Line 137 static const String& attach_hash_to_stri | Line 135 static const String& attach_hash_to_stri |
| if(Value *value=static_cast<Value *>(attach_hash.get(*value_name))) | if(Value *value=static_cast<Value *>(attach_hash.get(*value_name))) |
| vfile=value->as_vfile(String::UL_AS_IS); // bad with html attaches. todo: solve | vfile=value->as_vfile(String::UL_AS_IS); // bad with html attaches. todo: solve |
| else | else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &origin_string, | &origin_string, |
| "has no $value"); | "has no $value"); |
| Line 147 static const String& attach_hash_to_stri | Line 145 static const String& attach_hash_to_stri |
| file_name=&vfile_name->as_string(); | file_name=&vfile_name->as_string(); |
| else // no $file-name, VFile surely knows name | else // no $file-name, VFile surely knows name |
| file_name=&static_cast<Value *>(vfile->fields().get(*name_name))->as_string(); | file_name=&static_cast<Value *>(vfile->fields().get(*name_name))->as_string(); |
| const char *file_name_cstr=file_name->cstr(String::UL_FILE_NAME); | const char *file_name_cstr=file_name->cstr(String::UL_FILE_SPEC); |
| String& result=*new(pool) String(pool); | String& result=*new(pool) String(pool); |
| Line 160 static const String& attach_hash_to_stri | Line 158 static const String& attach_hash_to_stri |
| if(type=="uue") { | if(type=="uue") { |
| uuencode(result, file_name_cstr, *vfile); | uuencode(result, file_name_cstr, *vfile); |
| } else | } else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &type, | &type, |
| "unknown encode type"); | "unknown encode type"); |
| Line 177 static void *find_content_type_charset(c | Line 175 static void *find_content_type_charset(c |
| return StrEqNc(aattribute.cstr(), "charset")?ameaning:0; | return StrEqNc(aattribute.cstr(), "charset")?ameaning:0; |
| } | } |
| /// used by mail: _send / letter_hash_to_string / add_header_attribute | #ifndef DOXYGEN |
| struct Mail_info { | struct Mail_info { |
| String *attribute_to_exclude; | String *attribute_to_exclude; |
| const char *charset; | const char *charset; |
| String *header; | String *header; |
| const String **from, **to; | const String **from, **to; |
| }; | }; |
| #endif | |
| static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, | static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, |
| void *info) { | void *info) { |
| Line 208 static void add_header_attribute(const H | Line 207 static void add_header_attribute(const H |
| "\n"; | "\n"; |
| } | } |
| /// used in mail: _send / letter_hash_to_string / add_part | #ifndef DOXYGEN |
| struct Mail_seq_item { | struct Mail_seq_item { |
| const String *part_name; | const String *part_name; |
| Value *part_value; | Value *part_value; |
| }; | }; |
| #endif | |
| static void add_part(const Hash::Key& part_name, Hash::Val *part_value, | static void add_part(const Hash::Key& part_name, Hash::Val *part_value, |
| void *info) { | void *info) { |
| Mail_seq_item **seq_ref=static_cast<Mail_seq_item **>(info); | Mail_seq_item **seq_ref=static_cast<Mail_seq_item **>(info); |
| Line 253 static const String& letter_hash_to_stri | Line 253 static const String& letter_hash_to_stri |
| const char *charset=0; | const char *charset=0; |
| if(Value *content_type= | if(Value *content_type= |
| static_cast<Value *>(letter_hash.first_that(find_content_type))) | static_cast<Value *>(letter_hash.first_that(find_content_type))) |
| if(Hash *hash=content_type->get_hash()) | if(Hash *hash=content_type->get_hash(&method_name)) |
| if(Value *content_type_charset= | if(Value *content_type_charset= |
| static_cast<Value *>(hash->first_that(find_content_type_charset))) | static_cast<Value *>(hash->first_that(find_content_type_charset))) |
| charset=content_type_charset->as_string().cstr(); | charset=content_type_charset->as_string().cstr(); |
| Line 268 static const String& letter_hash_to_stri | Line 268 static const String& letter_hash_to_stri |
| letter_hash.for_each(add_header_attribute, &mail_info); | letter_hash.for_each(add_header_attribute, &mail_info); |
| if(Value *body_element=static_cast<Value *>(letter_hash.get(*body_name))) { | if(Value *body_element=static_cast<Value *>(letter_hash.get(*body_name))) { |
| if(Hash *body_hash=body_element->get_hash()) { | if(Hash *body_hash=body_element->get_hash(&method_name)) { |
| char *boundary=(char *)pool.malloc(MAX_NUMBER); | char *boundary=(char *)pool.malloc(MAX_NUMBER); |
| snprintf(boundary, MAX_NUMBER-5/*lEvEl*/, "lEvEl%d", level); | snprintf(boundary, MAX_NUMBER-5/*lEvEl*/, "lEvEl%d", level); |
| // multi-part | // multi-part |
| Line 278 static const String& letter_hash_to_stri | Line 278 static const String& letter_hash_to_stri |
| // body parts.. | // body parts.. |
| // ..collect | // ..collect |
| Mail_seq_item *seq=(Mail_seq_item *)malloc(sizeof(Mail_seq_item)*body_hash->size()); | Mail_seq_item *seq=(Mail_seq_item *)pool.malloc(sizeof(Mail_seq_item)*body_hash->size()); |
| Mail_seq_item *seq_ref=seq; body_hash->for_each(add_part, &seq_ref); | Mail_seq_item *seq_ref=seq; body_hash->for_each(add_part, &seq_ref); |
| // ..sort | // ..sort |
| _qsort(seq, body_hash->size(), sizeof(Mail_seq_item), | _qsort(seq, body_hash->size(), sizeof(Mail_seq_item), |
| Line 288 static const String& letter_hash_to_stri | Line 288 static const String& letter_hash_to_stri |
| // intermediate boundary | // intermediate boundary |
| result << "\n--" << boundary << "\n"; | result << "\n--" << boundary << "\n"; |
| if(Hash *part_hash=seq[i].part_value->get_hash()) | if(Hash *part_hash=seq[i].part_value->get_hash(&method_name)) |
| if(seq[i].part_name->mid(0, 6/*attach*/)=="attach") | if(seq[i].part_name->mid(0, 6/*attach*/)=="attach") |
| result << attach_hash_to_string(r, *seq[i].part_name, *part_hash); | result << attach_hash_to_string(r, *seq[i].part_name, *part_hash); |
| else | else |
| result << letter_hash_to_string(r, method_name, *part_hash, | result << letter_hash_to_string(r, method_name, *part_hash, |
| level+1, 0, 0); | level+1, 0, 0); |
| else | else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| seq[i].part_name, | seq[i].part_name, |
| "part is not hash"); | "part is not hash"); |
| } | } |
| Line 305 static const String& letter_hash_to_stri | Line 305 static const String& letter_hash_to_stri |
| } else { | } else { |
| result << | result << |
| "\n" << // header|body separator | "\n" << // header|body separator |
| body_element->as_string(); // body | body_element->as_string().cstr(); // body |
| } | } |
| } else | } else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "has no $body"); | "has no $body"); |
| Line 325 static void sendmail(Request& r, const S | Line 325 static void sendmail(Request& r, const S |
| #ifdef _MSC_VER | #ifdef _MSC_VER |
| if(!from) | if(!from) |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "has no 'from' header specified"); | "has no 'from' header specified"); |
| if(!to) | if(!to) |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "has no 'to' header specified"); | "has no 'to' header specified"); |
| Line 346 static void sendmail(Request& r, const S | Line 346 static void sendmail(Request& r, const S |
| smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr()); | smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr()); |
| } else | } else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "$"MAIN_CLASS_NAME":"MAIL_NAME".SMTP not defined"); | "$"MAIN_CLASS_NAME":"MAIL_NAME".SMTP not defined"); |
| #else | #else |
| // unix | // unix |
| // $MAIN:MAIL.prog1["/usr/sbin/sendmail -t"] default | // $MAIN:MAIL.prog1["/usr/sbin/sendmail -t"] default |
| // $MAIN:MAIL.prog2["/usr/lib/sendmail -t"] default | // $MAIN:MAIL.prog2["/usr/lib/sendmail -t"] default |
| if(mail_conf) { | char no_cstr[MAX_NUMBER]; |
| char no_cstr[MAX_NUMBER]; | for(int no=-2; ; no++) { |
| for(int no=-2; ; no++) { | const String *prog_string; |
| const String *prog_string; | switch(no) { |
| switch(no) { | case -2: prog_string=new(pool) String(pool, "/usr/sbin/sendmail -t"); break; |
| case -2: prog_string=new(pool) String(pool, "/usr/sbin/sendmail -t"); break; | case -1: prog_string=new(pool) String(pool, "/usr/lib/sendmail -t"); break; |
| case -1: prog_string=new(pool) String(pool, "/usr/lib/sendmail -t"); break; | default: |
| default: | { |
| { | String prog_key(pool, "prog"); |
| String prog_key(pool, "prog"); | snprintf(no_cstr, MAX_NUMBER, "%d", no); |
| snprintf(no_cstr, MAX_NUMBER, "%d", no); | prog_key << no_cstr; |
| prog_key << no_cstr; | if(mail_conf) { |
| if(Value *prog_value=static_cast<Value *>(mail_conf->get(prog_key))) | if(Value *prog_value=static_cast<Value *>(mail_conf->get(prog_key))) |
| prog_string=&prog_value->as_string(); | prog_string=&prog_value->as_string(); |
| else | else |
| if(no==0) | if(no==0) |
| continue; | continue; |
| else | else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "$"MAIN_CLASS_NAME":"MAIL_NAME".%s not defined", | "$"MAIN_CLASS_NAME":"MAIL_NAME".%s not defined", |
| prog_key.cstr()); | prog_key.cstr()); |
| } | } else |
| throw Exception(0, 0, | |
| &method_name, | |
| "$" MAIN_CLASS_NAME ":" MAIL_NAME " not defined"); | |
| } | } |
| // we know prog_string here | |
| Array argv(pool); | |
| const String *file_spec; | |
| int after_file_spec=prog_string->pos(" ", 1); | |
| if(after_file_spec<=0) | |
| file_spec=prog_string; | |
| else { | |
| size_t pos_after=after_file_spec; | |
| file_spec=&prog_string->mid(0, pos_after); | |
| prog_string->split(argv, &pos_after, " ", 1, String::UL_CLEAN); | |
| } | |
| // skip unavailable default programs | |
| if(no<0 && !file_executable(*file_spec)) | |
| continue; | |
| String in(pool, letter_cstr); String out(pool); String err(pool); | |
| int exit_status=pa_exec(*file_spec, | |
| 0/*default env*/, | |
| &argv, | |
| in, out, err); | |
| if(exit_status || err.size()) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "'%s' reported problem: %s (%d)", | |
| file_spec->cstr(), | |
| err.size()?err.cstr():"UNKNOWN", | |
| exit_status); | |
| break; | |
| } | } |
| } else | // we know prog_string here |
| PTHROW(0, 0, | Array argv(pool); |
| &method_name, | const String *file_spec; |
| "$" MAIN_CLASS_NAME ":" MAIL_NAME " not defined"); | int after_file_spec=prog_string->pos(" ", 1); |
| if(after_file_spec<=0) | |
| file_spec=prog_string; | |
| else { | |
| size_t pos_after=after_file_spec; | |
| file_spec=&prog_string->mid(0, pos_after); | |
| prog_string->split(argv, &pos_after, " ", 1, String::UL_CLEAN); | |
| } | |
| // skip unavailable default programs | |
| if(no<0 && !file_executable(*file_spec)) | |
| continue; | |
| String in(pool, letter_cstr); String out(pool); String err(pool); | |
| int exit_status=pa_exec(*file_spec, | |
| 0/*default env*/, | |
| &argv, | |
| in, out, err); | |
| if(exit_status || err.size()) | |
| throw Exception(0, 0, | |
| &method_name, | |
| "'%s' reported problem: %s (%d)", | |
| file_spec->cstr(), | |
| err.size()?err.cstr():"UNKNOWN", | |
| exit_status); | |
| break; | |
| } | |
| #endif | #endif |
| } | } |
| Line 421 static void _send(Request& r, const Stri | Line 421 static void _send(Request& r, const Stri |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& vhash=params->as_no_junction(0, "message must not be code"); | Value& vhash=params->as_no_junction(0, "message must not be code"); |
| Hash *hash=vhash.get_hash(); | Hash *hash=vhash.get_hash(&method_name); |
| if(!hash) | if(!hash) |
| PTHROW(0, 0, | throw Exception(0, 0, |
| &method_name, | &method_name, |
| "message must be hash"); | "message must be hash"); |
| Line 452 void MMail::configure_user(Request& r) { | Line 452 void MMail::configure_user(Request& r) { |
| // $MAIN:MAIL[$SMTP[mail.design.ru]] | // $MAIN:MAIL[$SMTP[mail.design.ru]] |
| if(Value *mail_element=r.main_class->get_element(mail_name)) | if(Value *mail_element=r.main_class->get_element(mail_name)) |
| if(Hash *mail_conf=mail_element->get_hash()) | if(Hash *mail_conf=mail_element->get_hash(0)) |
| r.classes_conf.put(name(), mail_conf); | r.classes_conf.put(name(), mail_conf); |
| else | else |
| PTHROW(0, 0, | throw Exception(0, 0, |
| 0, | 0, |
| "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash"); | "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash"); |
| } | } |