--- parser3/src/classes/mail.C 2001/04/07 10:34:39 1.1 +++ parser3/src/classes/mail.C 2001/04/07 15:34:56 1.7 @@ -5,24 +5,76 @@ Author: Alexander Petrosyan (http://design.ru/paf) - $Id: mail.C,v 1.1 2001/04/07 10:34:39 paf Exp $ + $Id: mail.C,v 1.7 2001/04/07 15:34:56 paf Exp $ */ #include "pa_config_includes.h" +#ifdef WIN32 +# include "smtp/smtp.h" +#endif + #include "_mail.h" #include "pa_common.h" #include "pa_request.h" +#include "pa_vfile.h" // global var VStateless_class *mail_class; -// methods +// helpers + +/// ^mail:send[$attach[$type[uue|mime64] $value[DATA]]] +static const String& attach_hash_to_string(Request& r, const String& origin_string, + Hash& attach_hash) { + Pool& pool=r.pool(); + + Value *vtype=static_cast(attach_hash.get(*new(pool) String(pool, "type"))); + if(!vtype) + PTHROW(0, 0, + &origin_string, + "has no $type"); + + Value *value=static_cast(attach_hash.get(*value_name)); + if(!value) + PTHROW(0, 0, + &origin_string, + "has no $value"); + + const String *file_name; + if(Value *vfile_name=static_cast(attach_hash.get( + *new(pool) String(pool, "file-name")))) + file_name=&vfile_name->as_string(); + else + file_name=new(pool) String(pool, "noname.dat"); + + String& result=*new(pool) String(pool); + + // content-disposition: attachment; filename="user_file_name" + result+="content-disposition: attachment; filename=\""; + result+=file_name->cstr(String::UL_FILE_NAME); + result+="\"\n"; + + const String& type=vtype->as_string(); + if(type=="uue") { + // content-transfer-encoding: x-uuencode + result+="content-transfer-encoding: x-uuencode\n"; + result+="\n"; + result+="todo"; + } else + PTHROW(0, 0, + &type, + "unknown encode type"); + + return result; +} + struct Mail_info { String *attribute_to_exclude; String *header; + const String **from, **to; }; static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, @@ -30,16 +82,161 @@ static void add_header_attribute(const H Value& lmeaning=*static_cast(ameaning); Mail_info& mi=*static_cast(info); + + // exclude one attribute [body] if(aattribute==*mi.attribute_to_exclude) return; - mi.header->append(aattribute, String::UL_PASS_APPENDED); - mi.header->APPEND_CONST(":"); - mi.header->append( - attributed_meaning_to_string(lmeaning, String::UL_MAIL_HEADER), - String::UL_PASS_APPENDED); - mi.header->APPEND_CONST("\n"); + // fetch from & to from header for SMTP + if(mi.from && aattribute=="from") + *mi.from=&lmeaning.as_string(); + if(mi.to && aattribute=="to") + *mi.to=&lmeaning.as_string(); + + // append header line + *mi.header+=aattribute; + *mi.header+=":"; + *mi.header+=attributed_meaning_to_string(lmeaning, String::UL_MAIL_HEADER); + *mi.header+="\n"; } +struct Seq_item { + const String *part_name; + Value *part_value; +}; +static void add_part(const Hash::Key& part_name, Hash::Val *part_value, + void *info) { + Seq_item **seq_ref=static_cast(info); + (**seq_ref).part_name=&part_name; + (**seq_ref).part_value=static_cast(part_value); + (*seq_ref)++; +} +static double key_of_part(const void *item) { + const char *cstr=static_cast(item)->part_name->cstr(); + char *error_pos; + return strtod(cstr, &error_pos); +} +static int sort_cmp_string_double_value(const void *a, const void *b) { + double va=key_of_part(a); + double vb=key_of_part(b); + + // 0 logically equals infinity. so that attachments would go last + if(va==0) + return +1; + if(vb==0) + return -1; + + if(vavb) + return +1; + else + return 0; +} +static const String& letter_hash_to_string(Request& r, const String& method_name, + Hash& letter_hash, int level, + const String **from, const String **to) { + Pool& pool=r.pool(); + + // prepare header: 'hash' without "body" + String& result=*new(pool) String(pool); + Mail_info mail_info={ + /*excluding*/ body_name, + &result, + from, to + }; + letter_hash.for_each(add_header_attribute, &mail_info); + + if(Value *body_element=static_cast(letter_hash.get(*body_name))) { + if(Hash *body_hash=body_element->get_hash()) { + char *boundary=(char *)pool.malloc(MAX_NUMBER); + snprintf(boundary, MAX_NUMBER, "%d", level); + // multi-part + ((result+= + "content-type: multipart/mixed; boundary=\"")+=boundary)+="\"\n" + "\n" + "This is a multi-part message in MIME format."; + + // body parts.. + // ..collect + Seq_item *seq=(Seq_item *)malloc(sizeof(Seq_item)*body_hash->size()); + Seq_item *seq_ref=seq; body_hash->for_each(add_part, &seq_ref); + // ..sort + _qsort(seq, body_hash->size(), sizeof(Seq_item), + sort_cmp_string_double_value); + // ..insert in 'seq' order + for(int i=0; isize(); i++) { + // intermediate boundary + ((result+="\n--")+=boundary)+="\n"; + + if(Hash *part_hash=seq[i].part_value->get_hash()) + if(seq[i].part_name->mid(0, 6/*attach*/)=="attach") + result+=attach_hash_to_string(r, *seq[i].part_name, *part_hash); + else + result+=letter_hash_to_string(r, method_name, *part_hash, + level+1, 0, 0); + else + PTHROW(0, 0, + seq[i].part_name, + "part is not hash"); + } + + // finish boundary + ((result+="\n--")+=boundary)+="--\n"; + } else { + result+="\n"; // header|body separator + result+=body_element->as_string(); // body + } + } else + PTHROW(0, 0, + &method_name, + "has no $body"); + + return result; +} + +/// @test unix ver +static void sendmail(Request& r, const String& method_name, + const String& letter, + const String *from, const String *to) { + Pool& pool=r.pool(); + +#ifdef WIN32 + if(!from) + PTHROW(0, 0, + &method_name, + "not specified 'from'"); + if(!to) + PTHROW(0, 0, + &method_name, + "not specified 'to'"); + + char *letter_cstr=letter.cstr(); + SMTP& smtp=*new(pool) SMTP(pool, method_name); + Value *server_port; + // $MAIN:MAIL.SMTP[mail.design.ru] + if(r.mail && + (server_port=static_cast(r.mail->get( + *new(pool) String(pool, "SMTP"))))) { + char *server=server_port->as_string().cstr(); + char *port=rsplit(server, ':'); + if(!port) + port=const_cast("25"); + + smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr()); + } else + PTHROW(0, 0, + &method_name, + "$MAIN:MAIL.SMTP not defined"); +#else + PTHROW(0, 0, + &method_name, + "todo"); +#endif +} + + +// methods + static void _send(Request& r, const String& method_name, Array *params) { Pool& pool=r.pool(); @@ -53,16 +250,11 @@ static void _send(Request& r, const Stri &method_name, "message must be hash"); - // prepare header: 'hash' without "body" - String& header=*new(pool) String(pool); - Mail_info mail_info={ - /*excluding*/ body_name, - &header - }; - hash->for_each(add_header_attribute, &mail_info); - + const String *from, *to; + const String& letter=letter_hash_to_string(r, method_name, *hash, 0, &from, &to); - r.write_assign_lang(*new(pool) VString(*mail_info.header)); + r.write_assign_lang(*new(pool) VString(letter)); + //sendmail(r, method_name, letter, from, to); } // initialize