/*    /daemon/postal/localpost.c
 *    from Foundation II
 *    filter for mails coming in from outside and inside
 *    created by Descartes of Borg 940503
 */

#include <lib.h>
#include <cfg.h>
#include <objects.h>
#include <daemons.h>
#include "localpost.h"

inherit LIB_DAEMON;

static private mapping __MudGroups;

void create() {
    daemon::create();
    SetNoClean(1);
    load_groups();
}

void load_groups() {
    mapping tmp;
    string *lines, *parts;
    string a, b;
    int i, maxi, x, j;

    maxi = sizeof(lines = filter(explode(read_file(CFG_ALIASES), "\n"),
	(: $1 && $1 != "" && $1[0] != '#' :)));
    for(i=0, tmp = ([]); i<maxi; i++) {
	if(sscanf(lines[i], "%s: %s", a, b) != 2) continue;
	if(b[0..0] == "|") {
	    x = sizeof(parts = explode(b[1..strlen(b)-1], ";"));
	    if(a == "include") {
		switch(sizeof(parts)) {
		case 2:
		    tmp += (mapping)call_other(parts[0],parts[1]);
		    break;
		case 3:
		    tmp+=(mapping)call_other(parts[0],parts[1],
		      parts[2]);
		    break;
		default:
		    tmp += (mapping)call_other(parts[0], parts[1],
		      parts[2], parts[3]);
		    break;
		}
	    }
	    else switch(sizeof(parts)) {
	    case 2: 
		tmp[a] = (string *)call_other(parts[0],parts[1]);
		break;
	    case 3:
		tmp[a] = (string *)call_other(parts[0],parts[1],
		  parts[2]);
		break;
	    default:
		tmp[a] = (string *)call_other(parts[0],parts[1],
		  parts[2], parts[3]);
	    }
	}
	else {
	    x = sizeof(parts = explode(b, " "));
	    if(a != "exclude") tmp[a] = ({});
	    for(j=0; j<x; j++) {
		if(a == "exclude" && tmp[parts[j]])
		    map_delete(tmp, parts[j]);
		else if(a == "exclude") continue;
		else if(tmp[parts[j]]) tmp[a]+=tmp[parts[j]];
		else tmp[a] += ({ parts[j] });
	    }
	}
    }
    i = sizeof(parts = keys(tmp));
    __MudGroups = ([]);
    while(i--) __MudGroups[lower_case(parts[i])] = tmp[parts[i]];
}

varargs string *send_post(mapping borg, mixed who) {
    mapping remote_mail, grps;
    string *rejects, *tmp, *tmpwho, *cles;
    string msg, a, b, tmpstr;
    int i, j, x;

    if(!who) who = distinct_array(borg["to"] + borg["cc"]);
    tmpstr = base_name(previous_object(0));
    if(tmpstr != OBJ_POST && tmpstr != REMOTEPOST_D && tmpstr != FOLDERS_D)
	return (pointerp(who) ? who : ({ who }));
    rejects = ({});
    grps = (mapping)OPTIONS_D->query_groups(borg["from"]);
    borg["id"] = (string)LETTERS_D->create_letter(borg["message"]);
    msg = borg["message"];
    map_delete(borg, "message");
    remote_mail = ([]);
    if(pointerp(who)) {
	i = sizeof(who);
	tmpwho = ({});
	x = (int)OPTIONS_D->query_option(borg["from"], "metoo");
	while(i--) {
	    if(pointerp(who[i] = map_groups(who[i], grps, borg["from"], x))) 
		tmpwho += who[i];
	    else tmpwho += ({ who[i] });
	}
	i = sizeof(who = tmpwho);
	while(i--) {
	    if(sscanf(who[i], "%s@%s", a, b) == 2) {
		if(!remote_mail[b]) remote_mail[b] = ({ a });
		remote_mail[b] += ({ a });
	    }
	    else if(!user_exists(who[i])) rejects += ({ who[i] });
	    else FOLDERS_D->add_post(who[i], "new", borg);
	}
	j = sizeof(cles = keys(remote_mail));
	while(j--) 
	    if(!((int)REMOTEPOST_D->send_post(borg+(["message":msg]), cles[j]))){
		rejects += remote_mail[cles[j]];
	    }
	return rejects;
    }
    else if(pointerp(tmp = __MudGroups[who]) && (i = sizeof(tmp))) {
	while(i--) {
	    if(sscanf(tmp[i], "%s@%s", a, b) == 2) {
		if(!remote_mail[b]) remote_mail[b] = ({});
		remote_mail[b] += ({ tmp[i] });
	    }
	    else if(!user_exists(tmp[i])) rejects += ({ tmp[i] });
	    else FOLDERS_D->add_post(tmp[i], "new", borg);
	}
	i = sizeof(cles = keys(remote_mail));
	while(i--) 
	    if(!((int)REMOTEPOST_D->send_post(borg+(["message":msg]), cles[i])))
		rejects += remote_mail[cles[i]];
	return rejects;
    }
    else if(pointerp(tmp = (string *)OPTIONS_D->query_group(who)) &&
      (i = sizeof(tmp))) {
	while(i--) {
	    if(sscanf(tmp[i], "%s@%s", a, b) == 2) {
		if(!remote_mail[b]) remote_mail[b] = ({});
		remote_mail[b] += ({ tmp[i] });
	    }
	    else if(!user_exists(tmp[i])) rejects += ({ tmp[i] });
	    else FOLDERS_D->add_post(tmp[i], "new", borg);
	}
	i = sizeof(cles = keys(remote_mail));
	while(i--)
	    if(!((int)REMOTEPOST_D->send_post(borg+(["message":msg]),cles[i])))
		rejects += remote_mail[cles[i]];
	return rejects;
    }
    else {
	if(sscanf(who, "%s@%s", a, b) == 2) {
	    if(!((int)REMOTEPOST_D->send_post(borg+(["message":msg]),b)))
		return ({ who });
	}
	else if(!user_exists(who)) return ({ who });
	else FOLDERS_D->add_post(who, "new", borg);
	return ({});
    }
}

static private mixed map_groups(string str, mapping grps, string who, int x) {
    if(__MudGroups[str]) return (string *)__MudGroups[str] - ({ who });
    else if(grps[str] && sizeof(grps[str]))
	return (string *)grps[str] - ({ who });
    else return str;
}

string *query_mud_group(string str) { return copy(__MudGroups[str]); }

mapping query_mud_groups() { return copy(__MudGroups); }