--- parser3/src/classes/mail.C	2001/04/07 10:34:39	1.1
+++ parser3/src/classes/mail.C	2001/04/07 15:16:26	1.6
@@ -5,14 +5,19 @@
 
 	Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
 
-	$Id: mail.C,v 1.1 2001/04/07 10:34:39 paf Exp $
+	$Id: mail.C,v 1.6 2001/04/07 15:16:26 paf Exp $
 */
 
 #include "pa_config_includes.h"
 
+#ifdef WIN32
+#	include "smtp/smtp.h"
+#endif
+
 #include "_mail.h"
 #include "pa_common.h"
 #include "pa_request.h"
+#include "pa_vfile.h"
 
 // global var
 
@@ -23,6 +28,7 @@ VStateless_class *mail_class;
 struct Mail_info {
 	String *attribute_to_exclude;
 	String *header;
+	const String **from, **to;
 };
 
 static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, 
@@ -30,16 +36,150 @@ static void add_header_attribute(const H
 
 	Value& lmeaning=*static_cast<Value *>(ameaning);
 	Mail_info& mi=*static_cast<Mail_info *>(info);
+
+	// exclude one attribute [body]
 	if(aattribute==*mi.attribute_to_exclude)
 		return;
 
-	mi.header->append(aattribute, String::UL_PASS_APPENDED);
-	mi.header->APPEND_CONST(":");
-	mi.header->append(
-		attributed_meaning_to_string(lmeaning, String::UL_MAIL_HEADER), 
-		String::UL_PASS_APPENDED);
-	mi.header->APPEND_CONST("\n");
+	// 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;
+};
+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;
+}
+
+
+/// @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();
+
+#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, ':');
+		if(!port)
+			port=const_cast<char *>("25");
+
+		smtp.Send(server, port, letter_cstr, from->cstr(), to->cstr());
+	} else
+		PTHROW(0, 0,
+			&method_name,
+			"$MAIN:MAIL.SMTP not defined");
+#else
+	PTHROW(0, 0,
+		&method_name,
+		"todo");
+#endif
+}
+
 static void _send(Request& r, const String& method_name, Array *params) {
 	Pool& pool=r.pool();
 
@@ -53,20 +193,76 @@ static void _send(Request& r, const Stri
 			&method_name,
 			"message must be hash");
 
-	// prepare header: 'hash' without "body"
-	String& header=*new(pool) String(pool);
-	Mail_info mail_info={
-		/*excluding*/ body_name,
-		&header
-	};
-	hash->for_each(add_header_attribute, &mail_info);
+	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);
+}
 
+/// ^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();
 
-	r.write_assign_lang(*new(pool) VString(*mail_info.header));
+	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);
+
+	{ // 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);
+	}
+
+	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");
+
+	result.set_name(*new(pool) String(pool, "100")); // so that would go last
+	r.write_no_lang(result);
 }
 
 // initialize
 void initialize_mail_class(Pool& pool, VStateless_class& vclass) {
 	// ^mail:send{hash}
 	vclass.add_native_method("send", Method::CT_STATIC, _send, 1, 1);
+
+	// ^mail:encode[uue|base64;DATA]
+	// ^mail:encode[uue|base64;DATA;user-file-name]
+	vclass.add_native_method("attach", Method::CT_ANY, _attach, 2, 3);
 }