--- parser3/src/classes/mail.C 2001/04/07 15:34:56 1.7 +++ parser3/src/classes/mail.C 2016/09/08 20:41:47 1.129 @@ -1,264 +1,246 @@ /** @file Parser: @b mail parser class. - Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) - - Author: Alexander Petrosyan (http://design.ru/paf) - - $Id: mail.C,v 1.7 2001/04/07 15:34:56 paf Exp $ + Copyright (c) 2001-2015 Art. Lebedev Studio (http://www.artlebedev.com) + Author: Alexandr Petrosian (http://paf.design.ru) */ #include "pa_config_includes.h" +#include "pa_vmethod_frame.h" -#ifdef WIN32 -# include "smtp/smtp.h" -#endif - -#include "_mail.h" #include "pa_common.h" #include "pa_request.h" #include "pa_vfile.h" +#include "pa_exec.h" +#include "pa_charsets.h" +#include "pa_charset.h" +#include "pa_uue.h" +#include "pa_vmail.h" -// global var +#include "smtp.h" -VStateless_class *mail_class; +volatile const char * IDENT_MAIL_C="$Id: mail.C,v 1.129 2016/09/08 20:41:47 moko Exp $"; -// helpers +// defines -/// ^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"); +#define MAIL_CLASS_NAME "mail" +#define SENDMAIL_NAME "sendmail" - String& result=*new(pool) String(pool); +// consts - // 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; -} +const int ATTACHMENT_WEIGHT=100; +// class -struct Mail_info { - String *attribute_to_exclude; - String *header; - const String **from, **to; +class MMail: public Methoded { +public: // Methoded + bool used_directly() { return false; } + void configure_user(Request& r); + +public: + MMail(); }; -static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, - void *info) { +// global variable - Value& lmeaning=*static_cast(ameaning); - Mail_info& mi=*static_cast(info); +DECLARE_CLASS_VAR(mail, new MMail); - // exclude one attribute [body] - if(aattribute==*mi.attribute_to_exclude) - return; +// defines for statics - // 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"); +#define MAIL_NAME "MAIL" - return result; -} +// statics + +static const String mail_name(MAIL_NAME); +static const String mail_sendmail_name(SENDMAIL_NAME); -/// @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(); +// helpers -#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, ':'); +static void sendmail( + Value* +#ifndef WIN32 + vmail_conf +#endif + , Value* smtp_server_port, + const String& message, + const String* from, + const String* to, + const String* +#ifndef WIN32 + options +#endif + ) { + const char* exception_type="email.format"; + if(!from) // we use in sendmail -f {from} && SMTP MAIL from: {from} + throw Exception(exception_type, + 0, + "parameter does not specify 'from' header field"); + + const char* message_cstr=message.untaint_cstr(String::L_AS_IS); + + if(smtp_server_port) { + if(!to) // we use only in SMTP RCPT to: {to} + throw Exception(exception_type, + 0, + "parameter does not specify 'to' header field"); + + SMTP smtp; + char* server=smtp_server_port->as_string().cstrm(); + const char* port=rsplit(server, ':'); if(!port) - port=const_cast("25"); + port="25"; + + smtp.Send(server, port, message_cstr, from->cstrm(), to->cstrm()); + return; + } - smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr()); - } else - PTHROW(0, 0, - &method_name, - "$MAIN:MAIL.SMTP not defined"); +#ifdef WIN32 + // win32 without SMTP server configured + throw Exception(PARSER_RUNTIME, + 0, + "$"MAIN_CLASS_NAME":"MAIL_NAME".SMTP not defined"); +#else + // unix + // $MAIN:MAIL.sendmail["/usr/sbin/sendmail -t -i -f postmaster"] default + // $MAIN:MAIL.sendmail["/usr/lib/sendmail -t -i -f postmaster"] default + + String* sendmail_command=new String; + if(vmail_conf) { +#ifdef PA_FORCED_SENDMAIL + throw Exception(PARSER_RUNTIME, + 0, + "Parser was configured with --with-sendmail=" PA_FORCED_SENDMAIL + " key, to change sendmail you should reconfigure and recompie it"); #else - PTHROW(0, 0, - &method_name, - "todo"); + if(Value* sendmail_value=vmail_conf->get_hash()->get(mail_sendmail_name)) + *sendmail_command<as_string(); + else + throw Exception(PARSER_RUNTIME, + 0, + "$" MAIN_CLASS_NAME ":" MAIL_NAME "." SENDMAIL_NAME " not defined"); #endif -} + } else { +#ifdef PA_FORCED_SENDMAIL + *sendmail_command<pos("postmaster"); + if(at_postmaster!=STRING_NOT_FOUND) { + String& reconstructed=sendmail_command->mid(0, at_postmaster); + reconstructed << *from; + reconstructed << sendmail_command->mid(at_postmaster+10/*postmaster*/, sendmail_command->length()); + sendmail_command=&reconstructed; + } + + // execute it + ArrayString argv; + const String* file_spec; + size_t after_file_spec=sendmail_command->pos(' '); + if(after_file_spec==STRING_NOT_FOUND || after_file_spec==0) + file_spec=sendmail_command; + else { + file_spec=&sendmail_command->mid(0, after_file_spec); + sendmail_command->split(argv, after_file_spec+1, " ", String::L_AS_IS); + } + + if(!file_executable(*file_spec)) + throw Exception("email.send", + file_spec, + "is not executable." +#ifdef PA_FORCED_SENDMAIL + " Use configure key \"--with-sendmail=appropriate sendmail command\"" +#else + " Set $" MAIN_CLASS_NAME ":" MAIL_NAME "." SENDMAIL_NAME " to appropriate sendmail command" +#endif + ); -// methods + String in(message_cstr); + PA_exec_result exec=pa_exec( + // forced_allow +#ifdef PA_FORCED_SENDMAIL + true +#else + false +#endif + , *file_spec, + 0 /* pass env */, + argv, + in); + if(exec.status || exec.err.length()) + throw Exception("email.send", + 0, + "'%s' reported problem: %s (%d)", + file_spec->cstr(), + exec.err.length()?exec.err.cstr():"UNKNOWN", + exec.status); +#endif //WIN32 +} -static void _send(Request& r, const String& method_name, Array *params) { - Pool& pool=r.pool(); +// methods - Value& vhash=*static_cast(params->get(0)); - // forcing [this body type] - r.fail_if_junction_(true, vhash, method_name, "message must not be code"); - - Hash *hash=vhash.get_hash(); - if(!hash) - PTHROW(0, 0, - &method_name, - "message must be hash"); +static void _send(Request& r, MethodParams& params) { + HashStringValue* hash=params.as_hash(0, "message"); + if(!hash || !hash->count()) + return; + // todo@ check if enough options are specified. + // now ^mail:send[^hash::create[]] and ^mail:send[$.print-debug(1)] "work". - const String *from, *to; - const String& letter=letter_hash_to_string(r, method_name, *hash, 0, &from, &to); + const String* soptions=0; + if(Value* voptions=hash->get(MAIL_OPTIONS_NAME)) + soptions=&voptions->as_string(); + + bool print_debug=false; + if(Value* vdebug=hash->get(MAIL_DEBUG_NAME)) + print_debug=vdebug->as_bool(); + + Value* vmail_conf=static_cast(r.classes_conf.get(mail_class->type())); + Value* smtp_server_port=0; + if(vmail_conf) { + // $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]] + smtp_server_port=vmail_conf->get_hash()->get("SMTP"); + } + + + const String* from=0; + String* to=0; + const String& message= + GET_SELF(r, VMail).message_hash_to_string(r, hash, 0, from, + smtp_server_port?true:false /*send by SMTP=strip to?*/, to); - r.write_assign_lang(*new(pool) VString(letter)); - //sendmail(r, method_name, letter, from, to); + if(print_debug) + r.write_pass_lang(message); + else + sendmail(vmail_conf, smtp_server_port, message, from, to, soptions); } -// initialize -void initialize_mail_class(Pool& pool, VStateless_class& vclass) { +// constructor & configurator + +MMail::MMail(): Methoded(MAIL_CLASS_NAME) { // ^mail:send{hash} - vclass.add_native_method("send", Method::CT_STATIC, _send, 1, 1); + add_native_method("send", Method::CT_STATIC, _send, 1, 1); +} + +void MMail::configure_user(Request& r) { + + // $MAIN:MAIL[$SMTP[mail.design.ru]] + if(Value* mail_element=r.main_class.get_element(mail_name)) { + if(mail_element->get_hash()) + r.classes_conf.put(type(), mail_element); + else + if( !mail_element->is_string() ) + throw Exception(PARSER_RUNTIME, + 0, + "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash"); + } }