/*    /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>
#include "remote.h"

inherit LIB_SERVER;

private string Password;
private static mapping Connections;

static void create() {
    server::create();
    Connections = ([]);
    SetNoClean(1);
    call_out( (: Setup :), 1);
}

static void Setup() {
    if( eventCreateSocket(PORT_RCP) < 0 ) {
        if( this_object() ) Destruct();
        return;
    }
}

static void eventSocketClosed(int fd) {
    map_delete(Connections, fd);
}
    
static void eventRead(int fd, string str) {
    if( !str ) {
	eventWrite(fd, "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(fd, "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(fd, 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, "\r", "");
	arg = "";
    }
    else arg = replace_string(arg, "\r", "");
    if( !Connections[fd]["object"] ) {
	string username, password;

	if( cmd != "login" ) {
	    eventWrite(fd, "50 Must login with user name and password.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	if( sscanf(arg, "%s %s", username, password) != 2 ) {
	    eventWrite(fd, "50 Login failed.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
        username = convert_name(username);
	if( !user_exists(username) ) {
	    eventWrite(fd, "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(fd, "50 Login failed.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	if( !(Connections[fd]["object"] = 
	      load_object(user_path(username) + "adm/remote")) ) {
	    eventWrite(fd, "50 Failed to load remote object.\n", 1);
	    map_delete(Connections, fd);
	    return;
	}
	eventWrite(fd, "60 Connection to " + mud_name() + ".\n");
    }
    else if( cmd == "100" ) {
	int sz;

	if( sscanf(arg, "%d %s", sz, Connections[fd]["file"]) != 2 ) 
	  eventWrite(fd, "50 Bad file send command.\n");
	else {
	    if( !sz ) eventWrite(fd, "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(fd, tmp[0..15]);
          eventWrite(fd, file);
	  break;
        case "ls":
	  val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
	  if( val ) eventWrite(fd, "500 " + val + "\n");
	  else eventWrite(fd, "50 " +cmd+ " " +arg+ ": Permission denied.\n");
	  break;
        case "update":
          val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
          if( val ) eventWrite(fd, "510 " + val + "\n");
          else eventWrite(fd, "50 Update attempt went off into nowhere.\n");
          break;
        default:
	  val = (string)Connections[fd]["object"]->eventCommand(cmd, arg);
	  if( val ) eventWrite(fd, "400 " + val + "\n");
	  else eventWrite(fd, "50 "+cmd+" "+arg+": Command not supported.\n");
	  break;
    }
    eventProcess(fd, "");
}