[BACK]Return to mail.C CVS log [TXT] [DIR] Up to [parser3project] / parser3 / src / classes

Diff for /parser3/src/classes/mail.C between versions 1.4 and 1.129

version 1.4, 2001/04/07 13:48:35 version 1.129, 2016/09/08 20:41:47
Line 1 Line 1
 /** @file  /** @file
         Parser: @b mail parser class.          Parser: @b mail parser class.
   
         Copyright (c) 2001 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: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)  
   
         $Id$  
 */  */
   
 #include "pa_config_includes.h"  #include "pa_config_includes.h"
   #include "pa_vmethod_frame.h"
   
 #include "_mail.h"  
 #include "pa_common.h"  #include "pa_common.h"
 #include "pa_request.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"
   
 #ifdef WIN32  #include "smtp.h"
 #       include "smtp/smtp.h"  
 #endif  volatile const char * IDENT_MAIL_C="$Id$";
   
 // global var  // defines
   
 VStateless_class *mail_class;  #define MAIL_CLASS_NAME "mail"
   #define SENDMAIL_NAME "sendmail"
   
 // consts  // consts
   
 // methods  const int ATTACHMENT_WEIGHT=100;
   
 struct Mail_info {  // class
         String *attribute_to_exclude;  
         String *header;  
         const String **from, **to;  
 };  
   
 static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning,   class MMail: public Methoded {
                                                                  void *info) {  public: // Methoded
           bool used_directly() { return false; }
           void configure_user(Request& r);
   
         Value& lmeaning=*static_cast<Value *>(ameaning);  public:
         Mail_info& mi=*static_cast<Mail_info *>(info);          MMail();
   };
   
         // exclude one attribute [body]  // global variable
         if(aattribute==*mi.attribute_to_exclude)  
                 return;  
   
         // fetch from & to from header for SMTP  DECLARE_CLASS_VAR(mail, new MMail);
         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_number;  
         Value *part_value;  
 };  
 static void add_part(const Hash::Key& part_number, Hash::Val *part_value,   
                                          void *info) {  
         Seq_item **seq_ref=static_cast<Seq_item **>(info);  
         (**seq_ref).part_number=&part_number;  
         (**seq_ref).part_value=static_cast<Value *>(part_value);  
         (*seq_ref)++;  
 }  
 static double key_of_part(const void *item) {  
         const char *cstr=static_cast<const Seq_item *>(item)->part_number->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);  
         if(va<vb)  
                 return -1;  
         else if(va>vb)  
                 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<Value *>(letter_hash.get(*body_name))) {  
                 if(Hash *body_hash=body_element->get_hash()) {  
                         char *boundary=(char *)pool.malloc(MAX_NUMBER);  
                         snprintf(boundary, MAX_NUMBER-6/*level_*/, "level_%d", level);  
                         // multi-part  
                         ((result+=  
                                 "content-type: multipart/mixed;\n"  
                                 "    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; i<body_hash->size(); i++) {  
                                 // intermediate boundary  
                                 ((result+="\n------=")+=boundary)+="\n";  
   
                                 if(Hash *part_hash=seq[i].part_value->get_hash())  
                                         result+=letter_hash_to_string(r, method_name, *part_hash,   
                                                 level+1, 0, 0);  
                                 else  
                                         PTHROW(0, 0,  
                                                 seq[i].part_number,  
                                                 "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;  // defines for statics
 }  
   
   #define MAIL_NAME "MAIL"
   
 /// @test unix ver  // statics
 static void sendmail(Request& r, const String& method_name,           
                                          const String& letter,   static const String mail_name(MAIL_NAME);
                                          const String *from, const String *to) {  static const String mail_sendmail_name(SENDMAIL_NAME);
         Pool& pool=r.pool();  
   
 #ifdef WIN32  // helpers
         if(!from)  
                 PTHROW(0, 0,  static void sendmail(
                         &method_name,                          Value* 
                         "not specified 'from'");  #ifndef WIN32
         if(!to)                          vmail_conf
                 PTHROW(0, 0,  #endif
                         &method_name,                          , Value* smtp_server_port,
                         "not specified 'to'");                          const String& message, 
                           const String* from,
         char *letter_cstr=letter.cstr();                          const String* to,
         SMTP& smtp=*new(pool) SMTP(pool, method_name);                          const String* 
         const String *server_port;  #ifndef WIN32
         // $MAIN:MAIL.SMTP[mail.design.ru]                           options
         if(r.mail && (server_port=r.mail->get_string(*new(pool) String(pool, "SMTP")))) {  #endif
                 char *server=server_port->cstr();                           ) {
                 char *port=rsplit(server, ':');          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)                  if(!port)
                         port="25";                          port="25";
   
                 smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr());                  smtp.Send(server, port, message_cstr, from->cstrm(), to->cstrm());
         } else                  return;
                 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
                   if(Value* sendmail_value=vmail_conf->get_hash()->get(mail_sendmail_name))
                           *sendmail_command<<sendmail_value->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<<PA_FORCED_SENDMAIL;
   #else
                   String* test=new String("/usr/sbin/sendmail");
                   if(!file_executable(*test))
                           test=new String("/usr/lib/sendmail");
                   *sendmail_command<<*test;
                   *sendmail_command<<" -t -i -f postmaster";
   #endif
           }
           if(options)
                   *sendmail_command<<" "<<*options;
   
           // we know sendmail_command here, should replace "postmaster" with "$from" from message
           size_t at_postmaster=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
                   );
   
   
           String in(message_cstr);
           PA_exec_result exec=pa_exec(
                   // forced_allow
   #ifdef PA_FORCED_SENDMAIL
                   true
 #else  #else
         PTHROW(0, 0,                  false
                 &method_name,  
                 "todo");  
 #endif  #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) {  // methods
         Pool& pool=r.pool();  
   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* 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& vhash=*static_cast<Value *>(params->get(0));          Value* vmail_conf=static_cast<Value*>(r.classes_conf.get(mail_class->type()));
         // forcing [this body type]          Value* smtp_server_port=0;
         r.fail_if_junction_(true, vhash, method_name, "message must not be code");          if(vmail_conf) {
                   // $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]]
         Hash *hash=vhash.get_hash();                  smtp_server_port=vmail_conf->get_hash()->get("SMTP");
         if(!hash)          }
                 PTHROW(0, 0,  
                         &method_name,  
                         "message must be hash");  
   
         const String *from, *to;  
         const String& letter=letter_hash_to_string(r, method_name, *hash, 0, &from, &to);  
   
         sendmail(r, method_name, letter, 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);
 }  }
   
 // initialize  // constructor & configurator
 void initialize_mail_class(Pool& pool, VStateless_class& vclass) {  
   MMail::MMail(): Methoded(MAIL_CLASS_NAME) {
         // ^mail:send{hash}          // ^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");
           }
 }  }
Removed from v.1.4  
changed lines
  Added in v.1.129

E-mail: