|
|
| version 1.88.2.16, 2003/03/08 16:41:30 | version 1.128, 2016/04/01 16:27:31 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b mail parser class. | Parser: @b mail parser class. |
| Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2015 Art. Lebedev Studio (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| */ | */ |
| static const char* IDENT_MAIL_C="$Date$"; | |
| #include "pa_config_includes.h" | #include "pa_config_includes.h" |
| #include "pa_vmethod_frame.h" | #include "pa_vmethod_frame.h" |
| Line 19 static const char* IDENT_MAIL_C="$Date$" | Line 17 static const char* IDENT_MAIL_C="$Date$" |
| #include "pa_uue.h" | #include "pa_uue.h" |
| #include "pa_vmail.h" | #include "pa_vmail.h" |
| #ifdef _MSC_VER | #include "smtp.h" |
| # include "smtp/smtp.h" | |
| #endif | volatile const char * IDENT_MAIL_C="$Id$"; |
| // defines | // defines |
| #define MAIL_CLASS_NAME "mail" | #define MAIL_CLASS_NAME "mail" |
| #define MAIL_SENDMAIL_NAME "sendmail" | #define SENDMAIL_NAME "sendmail" |
| // consts | // consts |
| Line 45 public: | Line 43 public: |
| // global variable | // global variable |
| DECLARE_CLASS_VAR(mail, 0/*fictive*/, new MMail); | DECLARE_CLASS_VAR(mail, new MMail); |
| // defines for statics | // defines for statics |
| Line 53 DECLARE_CLASS_VAR(mail, 0/*fictive*/, ne | Line 51 DECLARE_CLASS_VAR(mail, 0/*fictive*/, ne |
| // statics | // statics |
| static StringPtr mail_name(new String(MAIL_NAME)); | static const String mail_name(MAIL_NAME); |
| static StringPtr mail_sendmail_name(new String(MAIL_SENDMAIL_NAME)); | static const String mail_sendmail_name(SENDMAIL_NAME); |
| // helpers | // helpers |
| static void sendmail(Request& r, StringPtr method_name, | static void sendmail( |
| StringPtr message, | Value* |
| StringPtr from, StringPtr to) { | #ifndef WIN32 |
| Pool& pool=r.pool(); | vmail_conf |
| #endif | |
| CharPtr message_cstr=message->cstr(String::UL_UNSPECIFIED); | , Value* smtp_server_port, |
| Value* vmail_conf=static_cast<Value*>(r.classes_conf.get(mail_base_class->name()).get()); | const String& message, |
| const String* from, | |
| const char *exception_type="email.format"; | 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} | if(!from) // we use in sendmail -f {from} && SMTP MAIL from: {from} |
| throw Exception(exception_type, | throw Exception(exception_type, |
| method_name, | 0, |
| "parameter does not specify 'from' header field"); | "parameter does not specify 'from' header field"); |
| #ifdef _MSC_VER | const char* message_cstr=message.untaint_cstr(String::L_AS_IS); |
| if(!to) // we use only in SMTP RCPT to: {to} | |
| throw Exception(exception_type, | |
| method_name, | |
| "parameter does not specify 'to' header field"); | |
| SMTPPtr smtp(new SMTP(method_name)); | if(smtp_server_port) { |
| ValuePtr server_port; | if(!to) // we use only in SMTP RCPT to: {to} |
| // $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]] | throw Exception(exception_type, |
| if(vmail_conf && | 0, |
| (server_port=vmail_conf->get_hash(method_name)->get(StringPtr(new String("SMTP"))))) { | "parameter does not specify 'to' header field"); |
| CharPtr server=server_port->as_string(&pool)->cstr(); | |
| const char *port=rsplit(server, ':'); | SMTP smtp; |
| char* server=smtp_server_port->as_string().cstrm(); | |
| const char* port=rsplit(server, ':'); | |
| if(!port) | if(!port) |
| port="25"; | port="25"; |
| smtp->Send(server, port, message_cstr, from->cstr(), to->cstr()); | smtp.Send(server, port, message_cstr, from->cstrm(), to->cstrm()); |
| } else | return; |
| throw Exception("parser.runtime", | } |
| method_name, | |
| "$"MAIN_CLASS_NAME":"MAIL_NAME".SMTP not defined"); | #ifdef WIN32 |
| // win32 without SMTP server configured | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "$"MAIN_CLASS_NAME":"MAIL_NAME".SMTP not defined"); | |
| #else | #else |
| // unix | // unix |
| // $MAIN:MAIL.sendmail["/usr/sbin/sendmail -t -i -f postmaster"] default | // $MAIN:MAIL.sendmail["/usr/sbin/sendmail -t -i -f postmaster"] default |
| // $MAIN:MAIL.sendmail["/usr/lib/sendmail -t -i -f postmaster"] default | // $MAIN:MAIL.sendmail["/usr/lib/sendmail -t -i -f postmaster"] default |
| StringPtr sendmail_command; | String* sendmail_command=new String; |
| if(vmail_conf) { | if(vmail_conf) { |
| #ifdef PA_FORCED_SENDMAIL | #ifdef PA_FORCED_SENDMAIL |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| method_name, | 0, |
| "Parser was configured with --with-sendmail="PA_FORCED_SENDMAIL | "Parser was configured with --with-sendmail=" PA_FORCED_SENDMAIL |
| " key, to change sendmail you should reconfigure and recompie it"); | " key, to change sendmail you should reconfigure and recompie it"); |
| #else | #else |
| if(ValuePtr sendmail_value=vmail_conf->get_hash(method_name)->get(mail_sendmail_name)) | if(Value* sendmail_value=vmail_conf->get_hash()->get(mail_sendmail_name)) |
| sendmail_command=sendmail_value->as_string(&pool); | *sendmail_command<<sendmail_value->as_string(); |
| else | else |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| method_name, | 0, |
| "$"MAIN_CLASS_NAME":"MAIL_NAME"."MAIL_SENDMAIL_NAME" not defined"); | "$" MAIN_CLASS_NAME ":" MAIL_NAME "." SENDMAIL_NAME " not defined"); |
| #endif | #endif |
| } else { | } else { |
| #ifdef PA_FORCED_SENDMAIL | #ifdef PA_FORCED_SENDMAIL |
| sendmail_command=StringPtr(new String(PA_FORCED_SENDMAIL)); | *sendmail_command<<PA_FORCED_SENDMAIL; |
| #else | #else |
| StringPtr test(new String("/usr/sbin/sendmail")); | String* test=new String("/usr/sbin/sendmail"); |
| if(!file_executable(test)) | if(!file_executable(*test)) |
| test=StringPtr(new String("/usr/lib/sendmail")); | test=new String("/usr/lib/sendmail"); |
| test->APPEND_CONST(" -t -i -f postmaster"); | *sendmail_command<<*test; |
| sendmail_command=test; | *sendmail_command<<" -t -i -f postmaster"; |
| #endif | #endif |
| } | } |
| if(options) | |
| *sendmail_command<<" "<<*options; | |
| // we know sendmail_command here, should replace "postmaster" with "$from" from message | // we know sendmail_command here, should replace "postmaster" with "$from" from message |
| int at_postmaster=sendmail_command->pos("postmaster"); | size_t at_postmaster=sendmail_command->pos("postmaster"); |
| if(at_postmaster>0) { | if(at_postmaster!=STRING_NOT_FOUND) { |
| StringPtr reconstructed=sendmail_command->mid(0, at_postmaster); | String& reconstructed=sendmail_command->mid(0, at_postmaster); |
| *reconstructed << *from; | reconstructed << *from; |
| *reconstructed << sendmail_command->mid(at_postmaster+10/*postmaster*/, sendmail_command->size()); | reconstructed << sendmail_command->mid(at_postmaster+10/*postmaster*/, sendmail_command->length()); |
| sendmail_command=reconstructed; | sendmail_command=&reconstructed; |
| } | } |
| // execute it | // execute it |
| ArrayString argv; | ArrayString argv; |
| StringPtr file_spec; | const String* file_spec; |
| int after_file_spec=sendmail_command->pos(" ", 1); | size_t after_file_spec=sendmail_command->pos(' '); |
| if(after_file_spec<=0) | if(after_file_spec==STRING_NOT_FOUND || after_file_spec==0) |
| file_spec=sendmail_command; | file_spec=sendmail_command; |
| else { | else { |
| size_t pos_after=after_file_spec; | size_t pos_after=after_file_spec; |
| file_spec=sendmail_command->mid(0, pos_after++); | file_spec=&sendmail_command->mid(0, pos_after++); |
| sendmail_command->split(argv, &pos_after, " ", 1, String::UL_AS_IS); | sendmail_command->split(argv, pos_after, " ", String::L_AS_IS); |
| } | } |
| if(!file_executable(file_spec)) | if(!file_executable(*file_spec)) |
| throw Exception("email.send", | throw Exception("email.send", |
| file_spec, | file_spec, |
| "is not executable." | "is not executable." |
| #ifdef PA_FORCED_SENDMAIL | #ifdef PA_FORCED_SENDMAIL |
| " Use configure key \"--with-sendmail=appropriate sendmail command\"" | " Use configure key \"--with-sendmail=appropriate sendmail command\"" |
| #else | #else |
| " Set $"MAIN_CLASS_NAME":"MAIL_NAME"."MAIL_SENDMAIL_NAME" to appropriate sendmail command" | " Set $" MAIN_CLASS_NAME ":" MAIL_NAME "." SENDMAIL_NAME " to appropriate sendmail command" |
| #endif | #endif |
| ); | ); |
| String in(message_cstr); String out; String err; | String in(message_cstr); |
| PA_exec_result exec=pa_exec(pool, | PA_exec_result exec=pa_exec( |
| // forced_allow | // forced_allow |
| #ifdef PA_FORCED_SENDMAIL | #ifdef PA_FORCED_SENDMAIL |
| true | true |
| #else | #else |
| false | false |
| #endif | #endif |
| , file_spec, | , *file_spec, |
| 0 /* pass env */, | 0 /* pass env */, |
| argv, | argv, |
| in); | in); |
| if(exec.status || exec.err->size()) | if(exec.status || exec.err.length()) |
| throw Exception("email.send", | throw Exception("email.send", |
| method_name, | 0, |
| "'%s' reported problem: %s (%d)", | "'%s' reported problem: %s (%d)", |
| file_spec->cstr().get(), | file_spec->cstr(), |
| exec.err->size()?exec.err->cstr().get():"UNKNOWN", | exec.err.length()?exec.err.cstr():"UNKNOWN", |
| exec.status); | exec.status); |
| #endif | #endif //WIN32 |
| } | } |
| // methods | // methods |
| static void _send(Request& r, StringPtr method_name, MethodParams* params) { | static void _send(Request& r, MethodParams& params) { |
| Pool& pool=r.pool(); | 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* 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(); | |
| ValuePtr vhash=params->as_no_junction(0, "message must not be code"); | Value* vmail_conf=static_cast<Value*>(r.classes_conf.get(mail_class->type())); |
| HashStringValue* hash=vhash->get_hash(method_name); | Value* smtp_server_port=0; |
| if(!hash) | if(vmail_conf) { |
| throw Exception("parser.runtime", | // $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]] |
| method_name, | smtp_server_port=vmail_conf->get_hash()->get("SMTP"); |
| "message must be hash"); | } |
| StringPtr from(0); | |
| StringPtr to(0); | |
| StringPtr message= | |
| GET_SELF(r, VMail).message_hash_to_string(r, method_name, hash, 0, from, | |
| #ifdef WIN32 | |
| true | |
| #else | |
| false | |
| #endif | |
| , to); | |
| //r.write_pass_lang(message); | |
| sendmail(r, method_name, message, from, to); | 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); | |
| if(print_debug) | |
| r.write_pass_lang(message); | |
| else | |
| sendmail(vmail_conf, smtp_server_port, message, from, to, soptions); | |
| } | } |
| // constructor & configurator | // constructor & configurator |
| Line 215 MMail::MMail(): Methoded(MAIL_CLASS_NAME | Line 233 MMail::MMail(): Methoded(MAIL_CLASS_NAME |
| } | } |
| void MMail::configure_user(Request& r) { | void MMail::configure_user(Request& r) { |
| Pool& pool=r.pool(); | |
| // $MAIN:MAIL[$SMTP[mail.design.ru]] | // $MAIN:MAIL[$SMTP[mail.design.ru]] |
| if(ValuePtr mail_element=r.main_class->get_element(mail_name, *r.main_class, false)) | if(Value* mail_element=r.main_class.get_element(mail_name)) { |
| if(mail_element->get_hash(Exception::undefined_source)) | if(mail_element->get_hash()) |
| r.classes_conf.put(name(), mail_element); | r.classes_conf.put(type(), mail_element); |
| else | else |
| if( !mail_element->is_string() ) | if( !mail_element->is_string() ) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| Exception::undefined_source, | 0, |
| "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash"); | "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash"); |
| } | |
| } | } |