--- parser3/src/classes/mail.C	2001/04/07 15:16:26	1.6
+++ parser3/src/classes/mail.C	2003/11/21 12:44:41	1.97
@@ -1,268 +1,239 @@
 /** @file
 	Parser: @b mail parser class.
 
-	Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
-
-	Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
-
-	$Id: mail.C,v 1.6 2001/04/07 15:16:26 paf Exp $
+	Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com)
+	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
 */
 
-#include "pa_config_includes.h"
+static const char * const IDENT_MAIL_C="$Date: 2003/11/21 12:44:41 $";
 
-#ifdef WIN32
-#	include "smtp/smtp.h"
-#endif
+#include "pa_config_includes.h"
+#include "pa_vmethod_frame.h"
 
-#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
+#ifdef _MSC_VER
+#	include "smtp.h"
+#endif
 
-VStateless_class *mail_class;
+// defines
 
-// methods
+#define MAIL_CLASS_NAME "mail"
+#define SENDMAIL_NAME "sendmail"
 
-struct Mail_info {
-	String *attribute_to_exclude;
-	String *header;
-	const String **from, **to;
-};
+// consts
 
-static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, 
-								 void *info) {
+const int ATTACHMENT_WEIGHT=100;
 
-	Value& lmeaning=*static_cast<Value *>(ameaning);
-	Mail_info& mi=*static_cast<Mail_info *>(info);
+// class
 
-	// exclude one attribute [body]
-	if(aattribute==*mi.attribute_to_exclude)
-		return;
-
-	// 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_number;
-	Value *part_value;
+class MMail: public Methoded {
+public: // Methoded
+	bool used_directly() { return false; }
+	void configure_user(Request& r);
+
+public:
+	MMail();
 };
-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;
-}
+// global variable
 
+DECLARE_CLASS_VAR(mail, 0/*fictive*/, new MMail);
 
-/// @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();
+// defines for statics
 
-#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<Value *>(r.mail->get(
-			*new(pool) String(pool, "SMTP"))))) {
-		char *server=server_port->as_string().cstr();
-		char *port=rsplit(server, ':');
+#define MAIL_NAME "MAIL"
+
+// statics
+	
+static const String mail_name(MAIL_NAME);
+static const String mail_sendmail_name(SENDMAIL_NAME);
+
+// helpers
+
+static void sendmail(Request& r, 
+		     const String& message, 
+		     const String* from, const String* 
+#ifdef _MSC_VER
+			 to
+#endif
+			 ,
+			 const String* 
+#ifndef _MSC_VER
+			 options
+#endif
+			 ) {
+	const char* message_cstr=message.cstr(String::L_UNSPECIFIED);
+	Value* vmail_conf=static_cast<Value*>(r.classes_conf.get(mail_base_class->name()));
+
+	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");
+
+#ifdef _MSC_VER
+	if(!to) // we use only in SMTP RCPT to: {to}
+		throw Exception(exception_type,
+			0,
+			"parameter does not specify 'to' header field");
+
+	SMTP smtp;
+	Value* server_port;
+	// $MAIN:MAIL.SMTP[mail.yourdomain.ru[:port]]
+	if(vmail_conf && 
+		(server_port=vmail_conf->get_hash()->get(String::Body("SMTP")))) {
+		char* server=server_port->as_string().cstrm();
+		const char* port=rsplit(server, ':');
 		if(!port)
-			port=const_cast<char *>("25");
+			port="25";
 
-		smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr());
+		smtp.Send(server, port, message_cstr, from->cstrm(), to->cstrm());
 	} else
-		PTHROW(0, 0,
-			&method_name,
-			"$MAIN:MAIL.SMTP not defined");
+		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<<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;
 
-static void _send(Request& r, const String& method_name, Array *params) {
-	Pool& pool=r.pool();
+	// 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;
+	}
 
-	Value& vhash=*static_cast<Value *>(params->get(0));
-	// forcing [this body type]
-	r.fail_if_junction_(true, vhash, method_name, "message must not be code");
+	// 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 {
+		size_t pos_after=after_file_spec;
+		file_spec=&sendmail_command->mid(0, pos_after++);
+		sendmail_command->split(argv, pos_after, " ", String::L_AS_IS);
+	}
 
-	Hash *hash=vhash.get_hash();
-	if(!hash)
-		PTHROW(0, 0,
-			&method_name,
-			"message must be hash");
+	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
+		);
 
-	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(letter));
-	//sendmail(r, method_name, letter, from, to);
+	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
 }
 
-/// ^mail:attach[uue|base64;DATA]
-/// ^mail:attach[uue|base64;DATA;user-file-name]
-static void _attach(Request& r, const String& method_name, Array *params) {
-	Pool& pool=r.pool();
-
-	Value& vtype=*static_cast<Value *>(params->get(0));
-	// forcing [this vtype]
-	r.fail_if_junction_(true, vtype, method_name, "type must not be code");
-
-	Value& vdata=*static_cast<Value *>(params->get(1));
-	// forcing [this vtype]
-	r.fail_if_junction_(true, vdata, method_name, "data must not be code");
-	const VFile& vfile=*vdata.as_vfile();
-
-	Value *user_file_name;
-	if(params->size()>2) {
-		user_file_name=static_cast<Value *>(params->get(0));
-		// forcing [this vtype]
-		r.fail_if_junction_(true, *user_file_name, method_name, 
-			"user file name must not be code");
-	} else {
-		user_file_name=static_cast<Value *>(vfile.fields().get(*name_name));
-	}
-
-	VHash& result=*new(pool) VHash(pool);
+// methods
 
-	{ // content-disposition: attachment; filename='user_file_name'
-		VHash& content_disposition=*new(pool) VHash(pool);
-		content_disposition.hash().put(*value_name,
-			new(pool) VString(*new(pool) String(pool, "attachment")));
-		content_disposition.hash().put(
-			*new(pool) String(pool, "filename"),
-			user_file_name);
-		result.hash().put(*new(pool) String(pool, "content-disposition"),
-			&content_disposition);
-	}
+static void _send(Request& r, MethodParams& params) {
+	Value& vhash=params.as_no_junction(0, "message must not be code");
+	HashStringValue* hash=vhash.get_hash();
+	if(!hash)
+		throw Exception("parser.runtime",
+			0,
+			"message must be hash");
 
-	const String& type=vtype.as_string();
-	if(type=="uue") {
-		{ // content-transfer-encoding: x-uuencode
-			VString& content_transfer_encoding=*new(pool) VString(
-				*new(pool) String(pool, "x-uuencode"));
-			result.hash().put(*new(pool) String(pool, "content-transfer-encoding"),
-				&content_transfer_encoding);
-		}
-
-		result.hash().put(*body_name, 
-			new(pool) String(pool, "todo"));
-	} else 
-		PTHROW(0, 0,
-			&type,
-			"unknown encode type");
+	const String* soptions=0;
+	if(Value* voptions=hash->get(MAIL_OPTIONS_NAME))
+		soptions=&voptions->as_string();
+
+	const String* from=0;
+	String* to=0;
+	const String& message=
+		GET_SELF(r, VMail).message_hash_to_string(r, hash, 0, from, 
+#ifdef WIN32
+			true
+#else
+			false
+#endif
+			, to);
 
-	result.set_name(*new(pool) String(pool, "100")); // so that would go last
-	r.write_no_lang(result);
+	//r.write_pass_lang(message);
+	sendmail(r, 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) {
 
-	// ^mail:encode[uue|base64;DATA]
-	// ^mail:encode[uue|base64;DATA;user-file-name]
-	vclass.add_native_method("attach", Method::CT_ANY, _attach, 2, 3);
+	// $MAIN:MAIL[$SMTP[mail.design.ru]]
+	if(Value* mail_element=r.main_class.get_element(mail_name, r.main_class, false))
+		if(mail_element->get_hash())
+			r.classes_conf.put(name(), mail_element);
+		else
+			if( !mail_element->is_string() )
+				throw Exception("parser.runtime",
+					0,
+					"$" MAIL_CLASS_NAME ":" MAIL_NAME " is not hash");
 }