/*    /secure/daemon/remote.c
 *    from the Foundation II LPC Library
 *    Remote Creator Protocol daemon
 *    created by Descartes of Borg 950504
 */

#include <lib.h>
#include <network.h>

inherit LIB_SOCKET;

private string Password;
private static mapping Connections;
private static int FD = -1;

static void Setup();

void eventRead(int fd, string str);
static void eventProcess(int fd, string str);

static void create(int fd, object owner){
    socket::create(fd, owner);
    FD = fd;
    Connections = ([]);
}

static void eventSocketClosed(int fd) {
    map_delete(Connections, fd);
}

void eventRead(string str) {
    if( !str ) {
	eventWrite("50 Invalid command.\n", 1);
	if( Connections[FD] ) map_delete(Connections, FD);
	return;
    }
    eventProcess(FD, str);
}

static private void eventProcess(int fd, string str) {
    string tmp, cmd, arg, file, val;
    int x;
    if( Connections[fd] && Connections[fd]["in edit"] > 0 ) {
	int len;

	if( !Connections[fd]["object"] ) {
	    eventWrite("50 Object destructed.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	Connections[fd]["buffer"] += str;
	if( !(len = strlen(Connections[fd]["buffer"])) ) return;
	if( len == Connections[fd]["in edit"] ) {
	    tmp =  Connections[fd]["object"]->eventWriteFile(Connections[fd]["file"],
	      Connections[fd]["buffer"]);
	    eventWrite(tmp + "\n");
	    Connections[fd]["in edit"] = 0;
	    Connections[fd]["file"] = "";
	    Connections[fd]["buffer"] = "";
	    return;
	}
	else if( len > Connections[fd]["in edit"] ) {
	    string tmp1, tmp2;

	    tmp1 =Connections[fd]["buffer"][0..(Connections[fd]["in edit"]-1)];
	    tmp2 =Connections[fd]["buffer"][Connections[fd]["in edit"]..];
	    Connections[fd]["buffer"] = "";
	    eventProcess(fd, tmp1);
	    eventProcess(fd, tmp2);
	    return;
	}
	return;
    }
    if( !Connections[fd] ) Connections[fd] = ([ "buffer" : "" ]);
    if( (Connections[fd]["buffer"] += str) == "" ) return;
    if( (x = strsrch(Connections[fd]["buffer"], "\n")) == -1 ) return;
    str = Connections[fd]["buffer"][0..(x-1)];
    if( x != strlen(Connections[fd]["buffer"]) - 1 ) 
	Connections[fd]["buffer"] = Connections[fd]["buffer"][(x+1)..];
    else Connections[fd]["buffer"] = "";
    if( sscanf(str, "%s %s", cmd, arg) != 2) {
	cmd = replace_string(str, CARRIAGE_RETURN, "");
	arg = "";
    }
    else arg = replace_string(arg, CARRIAGE_RETURN, "");
    if( !Connections[fd]["object"] ) {
	string username, password;
	if( cmd != "login" ) {
	    eventWrite("50 Must login with user name and password.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	if( sscanf(arg, "%s %s", username, password) != 2 ) {
	    eventWrite("50 Login failed.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	username = convert_name(username);
	if( !user_exists(username) ) {
	    eventWrite("50 Login failed.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	unguarded( (: restore_object, DIR_CRES "/" + username[0..0] + "/" +
	    username :) );
	if( Password != crypt(password, Password) ) {
	    log_file("remote", "Failed attempt to login as " + username 
	      + "\n");
	    eventWrite("50 Login failed.\n", 1);
	    map_delete(Connections, fd);	     
	    return;
	}
	if( !(Connections[fd]["object"] = 
	    load_object(user_path(username) + "adm/remote")) ) {
	    eventWrite("50 Failed to load remote object.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	eventWrite("60 Connection to " + mud_name() + ".\n");
    }
    else if( cmd == "100" ) {
	int sz;

	if( sscanf(arg, "%d %s", sz, Connections[fd]["file"]) != 2 ) 
	    eventWrite("50 Bad file send command.\n");
	else {
	    if( !sz ) eventWrite("110 No changes sent orwritten.\n");
	    else Connections[fd]["in edit"] = sz;
	}
    }
    else switch( cmd ) {
    case "edit":
	file = (string)Connections[fd]["object"]->eventReadFile(arg);
	if( file[<1] != '\n' ) file += "\n";
	tmp = sprintf( "%-14s\n", "100 " + strlen(file));
	eventWrite(tmp[0..15]);
	eventWrite(file);
	break;
    case "ls":
	val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
	if( val ) eventWrite("500 " + val + "\n");
	else eventWrite("50 " +cmd+ " " +arg+ ": Permission denied.\n");
	break;
    case "update":
	val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
	if( val ) eventWrite("510 " + val + "\n");
	else eventWrite("50 Update attempt went off into nowhere.\n");
	break;
    default:
	val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
	if( val ) eventWrite("400 " + val + "\n");
	else eventWrite("50 "+cmd+" "+arg+": Command not supported.\n");
	break;
    }
    eventProcess(fd, "");
}