[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.19 and 1.43

version 1.19, 2001/04/17 19:00:27 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$
Line 14 Line 13
 #       include "smtp/smtp.h"  #       include "smtp/smtp.h"
 #endif  #endif
   
 #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_vfile.h"
 #include "pa_exec.h"  #include "pa_exec.h"
   
 // global var  // defines
   
   #define MAIL_CLASS_NAME "mail"
   
   #define MAIL_NAME "MAIL"
   
   // global variable
   
 VStateless_class *mail_class;  Methoded *mail_class;
   
   // class
   
   class MMail : public Methoded {
   public:
           MMail(Pool& pool);
   public: // Methoded
           bool used_directly() { return true; }
           void configure_user(Request& r);
   private:
           String mail_name;
           String content_disposition_name;
           String content_disposition_filename_name;
   };
   
 // helpers  // helpers
   
Line 96  static void uuencode(String& result, con Line 114  static void uuencode(String& result, con
         }          }
                   
         //footer          //footer
         result.APPEND_CLEAN((const char *)uue_table, 1/* one char */, 0, 0) << "\n"          result.APPEND_AS_IS((const char *)uue_table, 1/* one char */, 0, 0) << "\n"
                 "end\n";                  "end\n";
 }  }
   
 /// ^mail:send[$attach[$type[uue|mime64] $value[DATA]]]   /** ^mail:send[$attach[$type[uue|mime64] $value[DATA]]] 
           @todo solve - bad with html attaches
   */
 static const String& attach_hash_to_string(Request& r, const String& origin_string,   static const String& attach_hash_to_string(Request& r, const String& origin_string, 
                                                                                    Hash& attach_hash) {                                                                                     Hash& attach_hash) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         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 115  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 125  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 138  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 146  static const String& attach_hash_to_stri Line 166  static const String& attach_hash_to_stri
 }  }
   
   
   static void *find_content_type(const Hash::Key& aattribute, Hash::Val *ameaning, 
                                                             void *) {
           return StrEqNc(aattribute.cstr(), CONTENT_TYPE_NAME)?ameaning:0;
   }
   static void *find_content_type_charset(const Hash::Key& aattribute, Hash::Val *ameaning, 
                                                                             void *) {
           return StrEqNc(aattribute.cstr(), "charset")?ameaning:0;
   }
   
   #ifndef DOXYGEN
 struct Mail_info {  struct Mail_info {
         String *attribute_to_exclude;          String *attribute_to_exclude;
           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 170  static void add_header_attribute(const H Line 202  static void add_header_attribute(const H
         // append header line          // append header line
         *mi.header <<           *mi.header << 
                 aattribute << ":" <<                   aattribute << ":" << 
                 attributed_meaning_to_string(lmeaning, String::UL_MAIL_HEADER) <<                   attributed_meaning_to_string(lmeaning, String::UL_MAIL_HEADER).
                           cstr(String::UL_UNSPECIFIED, 0, mi.charset) << 
                 "\n";                  "\n";
 }  }
 struct Seq_item {  
   #ifndef DOXYGEN
   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) {
         Seq_item **seq_ref=static_cast<Seq_item **>(info);          Mail_seq_item **seq_ref=static_cast<Mail_seq_item **>(info);
         (**seq_ref).part_name=&part_name;          (**seq_ref).part_name=&part_name;
         (**seq_ref).part_value=static_cast<Value *>(part_value);          (**seq_ref).part_value=static_cast<Value *>(part_value);
         (*seq_ref)++;          (*seq_ref)++;
 }  }
 static double key_of_part(const void *item) {  static double key_of_part(const void *item) {
         const char *cstr=static_cast<const Seq_item *>(item)->part_name->cstr();          const char *cstr=static_cast<const Mail_seq_item *>(item)->part_name->cstr();
         char *error_pos;          char *error_pos;
         return strtod(cstr, &error_pos);          return strtod(cstr, &error_pos);
 }  }
Line 213  static const String& letter_hash_to_stri Line 249  static const String& letter_hash_to_stri
   
         // prepare header: 'hash' without "body"          // prepare header: 'hash' without "body"
         String& result=*new(pool) String(pool);          String& result=*new(pool) String(pool);
   
           const char *charset=0;
           if(Value *content_type=
                   static_cast<Value *>(letter_hash.first_that(find_content_type)))
                   if(Hash *hash=content_type->get_hash(&method_name))
                           if(Value *content_type_charset=
                                   static_cast<Value *>(hash->first_that(find_content_type_charset)))
                                   charset=content_type_charset->as_string().cstr();
   
         *from=*to=0;          *from=*to=0;
         Mail_info mail_info={          Mail_info mail_info={
                 /*excluding*/ body_name,                  /*excluding*/ body_name,
                   charset,
                 &result,                  &result,
                 from, to                  from, to
         };          };
         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 232  static const String& letter_hash_to_stri Line 278  static const String& letter_hash_to_stri
   
                         // body parts..                          // body parts..
                         // ..collect                          // ..collect
                         Seq_item *seq=(Seq_item *)malloc(sizeof(Seq_item)*body_hash->size());                          Mail_seq_item *seq=(Mail_seq_item *)pool.malloc(sizeof(Mail_seq_item)*body_hash->size());
                         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(Seq_item),                           _qsort(seq, body_hash->size(), sizeof(Mail_seq_item), 
                                 sort_cmp_string_double_value);                                  sort_cmp_string_double_value);
                         // ..insert in 'seq' order                          // ..insert in 'seq' order
                         for(int i=0; i<body_hash->size(); i++) {                          for(int i=0; i<body_hash->size(); i++) {
                                 // 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 259  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 275  static void sendmail(Request& r, const S Line 321  static void sendmail(Request& r, const S
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         char *letter_cstr=letter.cstr();          char *letter_cstr=letter.cstr();
           Hash *mail_conf=static_cast<Hash *>(r.classes_conf.get(mail_class->name()));
   
 #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");
   
         SMTP& smtp=*new(pool) SMTP(pool, method_name);          SMTP& smtp=*new(pool) SMTP(pool, method_name);
         Value *server_port;          Value *server_port;
         // $MAIN:MAIL.SMTP[mail.design.ru]          // $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]]
         if(r.mail &&           if(mail_conf && 
                 (server_port=static_cast<Value *>(r.mail->get(                  (server_port=static_cast<Value *>(mail_conf->get(
                         *new(pool) String(pool, "SMTP"))))) {                          *new(pool) String(pool, "SMTP"))))) {
                 char *server=server_port->as_string().cstr();                  char *server=server_port->as_string().cstr();
                 const char *port=rsplit(server, ':');                  const char *port=rsplit(server, ':');
Line 299  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(r.mail) {          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 *>(r.mail->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 373  static void sendmail(Request& r, const S Line 420  static void sendmail(Request& r, const S
 static void _send(Request& r, const String& method_name, MethodParams *params) {  static void _send(Request& r, const String& method_name, MethodParams *params) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         Value& vhash=params->get_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");
   
         const String *from, *to;          const String *from, *to;
         const String& letter=letter_hash_to_string(r, method_name, *hash, 0, &from, &to);          const String& letter=letter_hash_to_string(r, method_name, *hash, 0, &from, &to);
   
         //r.write_assign_lang(*new(pool) VString(letter));  //      r.write_assign_lang(*new(pool) VString(letter));
         sendmail(r, method_name, letter, from, to);          sendmail(r, method_name, letter, from, to);
 }  }
   
 // initialize  // constructor & configurator
 void initialize_mail_class(Pool& pool, VStateless_class& vclass) {  
   MMail::MMail(Pool& apool) : Methoded(apool),
           mail_name(apool, MAIL_NAME),
           content_disposition_name(apool, CONTENT_DISPOSITION_NAME),
           content_disposition_filename_name(apool, CONTENT_DISPOSITION_FILENAME_NAME)
   {
           set_name(*NEW String(pool(), 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) {
           Pool& pool=r.pool();
   
           // $MAIN:MAIL[$SMTP[mail.design.ru]]
           if(Value *mail_element=r.main_class->get_element(mail_name))
                   if(Hash *mail_conf=mail_element->get_hash(0))
                           r.classes_conf.put(name(), mail_conf);
                   else
                           throw Exception(0, 0,
                                   0,
                                   "$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash");
   }
   
   // creator
   
   Methoded *MMail_create(Pool& pool) {
           return mail_class=new(pool) MMail(pool);
 }  }
Removed from v.1.19  
changed lines
  Added in v.1.43

E-mail: