/*    /daemon/remotepost.c
 *    from Foundation II
 *    daemon to handle the network to local mail interface
 *    created by Descartes of Borg 940130
 *    modified for IIPS 3.1 940513
 */

#include <lib.h> 
#include <save.h> 
#include <daemons.h> 
#include "remotepost.h"

inherit LIB_DAEMON;

private mapping __MailQueue; 
static private mapping __IncomingMail; 

void create() {
    string *muds; 
    int i; 

    daemon::create();
    SetNoClean(1);
    __MailQueue = ([]); 
    __IncomingMail = ([]); 
    if(file_exists(sprintf("%s%s", SAVE_MAILQUEUE, __SAVE_EXTENSION__))) 
	restore_mailqueue(); 
    i = sizeof(muds = keys(__MailQueue)); 
    while(i--) __MailQueue[muds[i]][0]["in transit"] = 0; 
} 

string postal_check(string mud) { 
    if(file_name(previous_object()) != SERVICES_D) return 0;
    if(!__MailQueue[mud = replace_string(lower_case(mud), " ", ".")]) return 0;
    if(__MailQueue[mud][0]["in transit"]) return 0; 
    __MailQueue[mud][0]["in transit"] = 1; 
    return __MailQueue[mud][0]["post"][0]; 
} 

string next_post(string mud) { 
    int x; 
    if(file_name(previous_object(0)) != SERVICES_D) return 0;

    if(!__MailQueue[mud = replace_string(lower_case(mud), " ", ".")]) return 0;
    x = __MailQueue[mud][0]["in transit"]++; 
    if(sizeof(__MailQueue[mud][0]["post"]) == x) { 
	if( !sizeof(__MailQueue[mud] = __MailQueue[mud][1..]) )
	    map_delete(__MailQueue, mud); 
	save_mailqueue(); 
	return 0; 
    } 
    return __MailQueue[mud][0]["post"][x]; 
} 

string resend_post(string mud) { 
    if(file_name(previous_object(0)) != SERVICES_D) return 0;
    if(!__MailQueue[mud = replace_string(lower_case(mud), " ", ".")]) return 0;
    __MailQueue[mud][0]["in transit"] = 1; 
    return __MailQueue[mud][0]["post"][0]; 
} 

void send_post(mapping borg, string mud) {
    string *msg, *tmp; 
    int i, maxi, x, y; 

    borg["to"] = convert_names(borg["to"]); 
    borg["cc"] = convert_names(borg["cc"]); 
    borg["from"] = sprintf("%s@%s", convert_name(borg["from"]),
      mud_name());
    tmp = ({ sprintf("||WIZTO:%s||WIZFROM:%s%s||SUBJECT:%s||DATE:%d||MSG:", 
	implode(borg["to"], ","), borg["from"],  
	(sizeof(borg["cc"]) ? implode(borg["cc"], ",") : ""), borg["subject"], 
	time()) }); 
    msg = explode(borg["message"], "\n"); 
    for(i=0, maxi = sizeof(msg); i<maxi; i++) { 
	if((y=strlen(tmp[x])) > 200) { 
	    x++; 
	    tmp += ({ "||MSG:" }); 
	} 
	tmp[x] += sprintf("%s\n", msg[i]); 
    } 
    tmp[x] += "||ENDMSG:1"; 
    if(!__MailQueue[mud]) 
	__MailQueue[mud] = ({ ([ "in transit": 0, "post": tmp ]) }); 
    else __MailQueue[mud] += ({ ([ "in transit": 0, "post": tmp ]) }); 
    SERVICES_D->new_mail(mud);
    save_mailqueue(); 
} 

int incoming_post(mapping info) { 
    mapping borg; 

    if(file_name(previous_object(0)) != SERVICES_D) return 0;
    info["NAME"] = replace_string(lower_case(info["NAME"]), " ", ".");
    if(info["WIZTO"]) __IncomingMail[info["NAME"]] = info; 
    else { 
	if(!__IncomingMail[info["NAME"]]) return 0; 
	else __IncomingMail[info["NAME"]]["MSG"] += info["MSG"]; 
    } 
    borg = ([]);
    if(info["ENDMSG"]) { 
	borg["to"] = __IncomingMail[info["NAME"]]["WIZTO"]; 
	borg["cc"] = __IncomingMail[info["NAME"]]["CC"]; 
	borg["from"] = __IncomingMail[info["NAME"]]["WIZFROM"]; 
	borg["subject"] = __IncomingMail[info["NAME"]]["SUBJECT"]; 
	borg["message"] = __IncomingMail[info["NAME"]]["MSG"]; 
	borg["date"] = __IncomingMail[info["NAME"]]["DATE"]; 
	LOCALPOST_D->send_post(copy(borg), 
	  local_targets(distinct_array(borg["to"] + borg["cc"])));
	map_delete(__IncomingMail, info["NAME"]); 
    } 
    return 1; 
} 

static private string *local_targets(string *str) {
    string a, b; 
    int i;

    i = sizeof(str);
    while(i--) {
	sscanf(str[i], "%s@%s", a, b);
	if(replace_string(lower_case(b), " ", ".") == 
	  replace_string(lower_case(mud_name()), " ", ".")) str[i] = a;
    }
    return str;
} 

static private void save_mailqueue() { 
    unguarded((: save_object, SAVE_MAILQUEUE :));
} 

static private void restore_mailqueue() { 
    unguarded((: restore_object, SAVE_MAILQUEUE :));
} 

static private string *convert_names(string *noms) {
    string a, b;
    int i;

    i = sizeof(noms);
    while(i--) {
	if(sscanf(noms[i], "%s@%s", a, b) != 2)
	    noms[i] = sprintf("%s@%s", noms[i], mud_name());
    }
    return noms;
}

mapping query_mail_queue() { return copy(__MailQueue); }