/* /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, "");
}
