#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( !(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){
trr("LIB_OOB.create: I am a new OOB object, name: "+file_name(),mcolor,MSG_OOB);
set_heart_beat(1);
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)) {
globalvar = delta;
trr("payload type: "+identify(globalvar[0]),"white",MSG_OOB);
}
else {
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){
if(client) client::eventDestruct();
else {
socket_close(this_object()->GetDescriptor());
eventDestruct();
}
}
if(counter == 601){
socket::eventDestruct();
socket_close(this_object()->GetDescriptor());
eventCloseSocket();
}
if(counter == 602){
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];
}
trr("--\nOOB "+whoami+" READ i am: "+identify(this_object()),mcolor,MSG_OOB);
trr("OOB "+whoami+" READ i read: "+identify(data)+"\n--",mcolor,MSG_OOB);
//every time we read something, the inactivity counter resets
counter = 0;
if(data[0] == "oob-begin"){
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"){
if(sizeof(FilesMap)) eventDumpFiles();
OOB_D->RemoveIncoming( OOB_D->FindMud(this_object()) );
if(client) this_object()->eventDestruct();
else socket::eventCloseSocket();
}
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"){
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;
}
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();
if(base_name(previous_object()) == OOB_D){
socket::eventWrite(arg);
}
else {
}
if(arg && arg[0] && arg[0] == "oob-end"){
client::eventDestruct();
return;
}
}
int eventDumpFiles(){
validate();
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);
for(int i = 1;i < sizeof(FilesMap[key])+1; i++){
if(FilesMap[key][i]) write_file(fname,FilesMap[key][i]+"\n");
}
}
}
