#include <lib.h>
#include <dirs.h>
#include <daemons.h>
#include <network.h>
#include <message_class.h>

inherit LIB_SOCKET;
inherit LIB_CLIENT;

string *file_chunks = ({});
string file = "";
mapping FilesMap = ([]);
string mud,whoami;
mixed globalvar;
int global_lock = 0;
string mcolor = "magenta";
int client = 0;
int counter = 0;
string *forbidden_prefixes = ({ "/secure/save/players", "/secure/save/creators" });
string *forbidden_suffixes = ({ ".o" });
string *forbidden_files = ({ "/secure/sefun/native_version.c" });
mixed *begin_packet = ({});
mapping TranslatedFiles = ([]);

int eventDumpFiles();

static private void validate() {
    if( !((int)master()->valid_apply(({ "SECURE" }))) )
	error("Illegal attempt to access LIB_OOB: "+get_stack()+" "+identify(previous_object(-1)));
}

void eventID(string str){
    //add security stuff here
    mud = str;
}

static void create(mixed alpha, mixed beta, mixed gamma, mixed delta){
    //if(alpha) trr("LIB_OOB.create alpha: "+identify(alpha),"green",MSG_OOB);
    //if(beta) trr("LIB_OOB.create beta: "+identify(beta),"green",MSG_OOB);
    //if(gamma) trr("LIB_OOB.create gamma: "+identify(gamma),"green",MSG_OOB);
    //if(delta) trr("LIB_OOB.create delta: "+identify(delta),"green",MSG_OOB);
    trr("LIB_OOB.create: I am a new OOB object, name: "+file_name(),mcolor,MSG_OOB);
    set_heart_beat(1);
    //SetDestructOnClose(0);
    if(clonep()){
	if(intp(alpha)){
	    socket::create(alpha, beta);
	}

	else if(beta && intp(beta)){
	    client = 1;
	    begin_packet = ({ "oob-begin", mud_name(), 1, beta });
	    if( eventCreateSocket(alpha, gamma) < 0 ){
		trr("LIB_OOB.create: Couldn't create outbound socket.",mcolor,MSG_OOB);
		client::eventDestruct();
		return;
	    }
	    else {
		trr("LIB_OOB.create: Apparently I opened an outbound socket.",mcolor,MSG_OOB);
		client::eventWrite( begin_packet );
		if( delta && arrayp(delta)) {
		    //trr("LIB_OOB.create Setting globalvar.",mcolor,MSG_OOB);
		    globalvar = delta;
		    trr("payload type: "+identify(globalvar[0]),"white",MSG_OOB);
		}
		else {
		    //trr("LIB_OOB.create Sending the oob-begin.",mcolor,MSG_OOB);
		    trr("no payload","white",MSG_OOB);
		}
	    }
	}
    }
    if(client) {
	whoami = "CLIENT";
	trr("LIB_OOB "+file_name()+": I think I am a "
	  "%^YELLOW%^%^BOLD%^client%^RESET%^",mcolor,MSG_OOB);
    }
    else {
	whoami = "SOCKET";
	trr("LIB_OOB "+file_name()+": I think I am a "
	  "%^CYAN%^%^BOLD%^server%^RESET%^",mcolor,MSG_OOB);
    }
}

void heart_beat(){
    //if nothing resets the counter for 10 minutes, we die
    counter++;
    if(counter == 600){
	//tc("i am "+(client ? "client " : "socket ") +identify(this_object())+" and i'm trying to self destruct.","white");
	//tc("socket_close("+this_object()->GetDescriptor()+"): "+
	//socket_close(this_object()->GetDescriptor()), "white");
	if(client) client::eventDestruct();
	else {
	    socket_close(this_object()->GetDescriptor());
	    eventDestruct();
	}
    }
    if(counter == 601){
	//tc("i am "+(client ? "client " : "socket ") +identify(this_object())+" and i'm trying to self destruct.","yellow");
	socket::eventDestruct();
	socket_close(this_object()->GetDescriptor());
	eventCloseSocket();
    }
    if(counter == 602){
	//tc("i am "+(client ? "client " : "socket ") +identify(this_object())+" and i'm trying to self destruct.","red");
	destruct();
	socket_close(this_object()->GetDescriptor());
	eventSocketClosed();
    }
}

int eventRead(mixed data) {
    mixed tmp = 0;
    string liblevel = "";
    string mud = OOB_D->FindMud(this_object());
    validate();
    if(sizeof(mud) && (tmp = INTERMUD_D->GetMudList()[mud])){
	if(sscanf(INTERMUD_D->GetMudList()[mud][5],"Dead Souls %s",liblevel) != 1)
	    liblevel = tmp[5];
    }
    //tc("liblevel: "+liblevel,"white");
    //if(tmp) tc("tmp: "+identify(tmp),"white");    
    trr("--\nOOB "+whoami+" READ i am: "+identify(this_object()),mcolor,MSG_OOB);
    trr("OOB "+whoami+" READ i read: "+identify(data)+"\n--",mcolor,MSG_OOB);
    //tc("it is a: "+typeof(data),"yellow");
    //every time we read something, the inactivity  counter resets
    counter = 0;
    if(data[0] == "oob-begin"){
	//check for token here?
	//socket::eventWrite( ({ "oob-reply","Welcome to oob object "+identify(this_object()) }));
	socket::eventWrite( ({ "oob-reply","Welcome to the OOB service on "+mud_name() }));
	OOB_D->RequestToken(data[1]);
	OOB_D->RegisterNewIncoming(data[1]);
    }

    if(data[0] == "oob-end"){
	//tc("hmmmmmmmmmm");
	if(sizeof(FilesMap)) eventDumpFiles();
	OOB_D->RemoveIncoming( OOB_D->FindMud(this_object()) );
	if(client) this_object()->eventDestruct();
	else socket::eventCloseSocket();
    }

    //if(sizeof(globalvar)) tc("i'd like to write this: "+identify(globalvar),"white");

    if((data[0] == "oob-file-end" || data[0] == "oob-reply" || data[0] == "oob-file-error") 
      && globalvar && arrayp(globalvar)){
	if(globalvar[0] == "oob-file-req"){
	    if(stringp(globalvar[1])) {
		client::eventWrite(globalvar);
		globalvar = ({ "oob-file-req", 0 });
	    }
	    else if(sizeof(globalvar[1])){ 
		client::eventWrite(({"oob-file-req", globalvar[1][0] }));
		globalvar[1] -= ({ globalvar[1][0] });
	    }
	    else {
		if(sizeof(FilesMap)) eventDumpFiles();
		OOB_D->RemoveIncoming( OOB_D->FindMud(this_object()) );
		if(client) this_object()->eventDestruct();
		else socket::eventCloseSocket();
	    }
	}
	else {
	    client::eventWrite(globalvar);
	}
    }

    if(data[0] == "oob-test"){
	socket::eventWrite( ({ "oob-reply","This is a test" }));
    }

    if(data[0] == "oob-file"){
	//tc("me: "+identify(OOB_D->FindMud(this_object()))+" "+data[1],"green");
	if(!OOB_D->AuthenticateFile(OOB_D->FindMud(this_object()), data[1])){
	    client::eventWrite( ({ "oob-file-error","CLIENT I have not asked for this file from you." }) );
	    socket::eventWrite( ({ "oob-file-error","SOCKET I have not asked for this file from you." }) );
	    return 0;
	}
	if(!FilesMap[data[1]]) FilesMap[data[1]] = ([]);
	if(data[3]) FilesMap[data[1]][data[2]] = data[3];
    }

    if(data[0] == "oob-file-req"){
	string *ok_files = explode(read_file("/secure/upgrades/txt/upgrades.txt"),"\n");
	string sendfile;

	if(file_exists("/secure/upgrades/txt/upgrades."+liblevel)){
	    ok_files = explode(read_file("/secure/upgrades/txt/upgrades."+liblevel),"\n");
	    if(data[1] == "/secure/upgrades/txt/upgrades.txt") 
		sendfile = "/secure/upgrades/txt/upgrades."+liblevel;
	    else sendfile = data[1];
	    ok_files += ({ "/secure/upgrades/txt/upgrades."+liblevel });
	    ok_files += ({ "/secure/upgrades/txt/mud_info."+liblevel });
	}
	else {
	    sendfile = data[1];
	    ok_files += ({ "/secure/upgrades/txt/upgrades.txt" });
	}
	if(sendfile == "/secure/sefun/mud_info.c"){
	    if(file_exists("/secure/upgrades/txt/mud_info."+liblevel))
		sendfile = "/secure/upgrades/txt/mud_info."+liblevel;
	}
	//tc("oob-file-req: "+identify(sendfile,"white");
	if(member_array(sendfile,ok_files) == -1 ){
	    socket::eventWrite( ({ "oob-file-error","File access denied." }) );
	    return 0;
	}
	if(directory_exists(sendfile)){
	    socket::eventWrite( ({ "oob-file-error","That's a directory.",sendfile}) );
	    return 0;
	}
	if(!OOB_D->AuthenticateReceivedToken(OOB_D->FindMud(this_object()))){
	    socket::eventWrite( ({ "oob-file-error","No token found for your mud." }) );
	    return 0;
	}
	OOB_D->send_file(sendfile,this_object());
	if(liblevel == "2.3a5")
	    socket::eventWrite(({"oob-end", "oob-file send complete." }) );
	else socket::eventWrite(({"oob-file-end", "oob-file send complete." }) );
    }

    if(data[0] == "oob-file-error"){
	if(data[1] == "No token found for your mud."){
	    call_out( (: eventWrite(begin_packet) :), 2);
	    trr(file_name()+": No auth token yet. Retrying in 2 seconds.",mcolor,MSG_OOB);
	} 
	if(data[1] == "That's a directory."){
	    mkdir(data[2]);
	    if(mudlib_version() == "2.3a5") client::eventDestruct();
	}
    }    
    if(data[0] == "mail"){
	string *ret = ({ OOB_D->FindMud(this_object()) }) + ( data - ({ data[0] }) );
	REMOTEPOST_D->incoming_post(ret);
	socket::eventWrite( ({ "mail-ack", ([ data[1] : ({}) ]) }) );
    }

    if(data[0] == "mail-ack"){
	foreach(mixed key, mixed val in data[1]){
	    REMOTEPOST_D->outgoing_sent(OOB_D->FindMud(this_object()), key);
	}
    }
    return 1;
}

void write_data(mixed arg){
    validate();
    //trr("--/nLIB_OOB.write_data i am "+whoami+" "+identify(this_object()),mcolor,MSG_OOB);
    //trr("LIB_OOB.write_data i am being asked to write: "+identify(arg)+"\n--",mcolor,MSG_OOB);
    //tc("LIB_OOB.write_data prev: "+base_name(previous_object())+" "+OOB_D);
    if(base_name(previous_object()) == OOB_D){
	//trr("I will write it.",mcolor,MSG_OOB);
	socket::eventWrite(arg);
    }
    else {
	//trr("I will NOT write it.",mcolor,MSG_OOB);
    }
    if(arg && arg[0] && arg[0] == "oob-end"){
	client::eventDestruct();
	return;
    }
}

int eventDumpFiles(){
    validate();
    //trr("LIB_OOB.eventDumpFiles DUMPING FILES:",mcolor,MSG_OOB);
    foreach(mixed key, mixed val in FilesMap){
	string fname = DIR_UPGRADES_FILES+"/"+replace_string(key,"/","0^0");
	if(key == DIR_UPGRADES_TXT+"/upgrades.txt") fname = DIR_UPGRADES_TXT+"/list.txt";
	rm(fname);
	OOB_D->RemoveRequestedFile(OOB_D->FindMud(this_object()), key);
	//trr("LIB_OOB.eventDumpFiles file: "+fname,mcolor,MSG_OOB);
	for(int i = 1;i < sizeof(FilesMap[key])+1; i++){
	    if(FilesMap[key][i]) write_file(fname,FilesMap[key][i]+"\n");
	}
    }
}