/* /secure/daemon/remote.c
* from the Foundation II LPC Library
* Remote Creator Protocol daemon
* created by Descartes of Borg 950504
* modified by Dyraen@Rod for Rod.
*/
#define PORT_RCP 4020
#include "remote.h"
inherit "/secure/crerem/server";
private string password;
private static mapping Connections;
static void create() {
server::create();
seteuid("Root");
Connections = ([]);
call_out("Setup", 1);
}
static void Setup() {
if( eventCreateSocket(PORT_RCP) < 0 ) {
if( this_object() ) server::dest_me();
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, pass;
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, pass) != 2 ) {
eventWrite(fd, "50 Login failed.\n", 1);
map_delete(Connections, fd);
return;
}
if( !user_exists(username) ) {
eventWrite(fd, "50 Login failed.\n", 1);
map_delete(Connections, fd);
return;
}
restore_object("/players/"+username[0..0]+"/"+username);
if( password != crypt(pass, 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("/w/"+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");
log_file("remote", capitalize(username)+" logged in. ("+
ctime(time())+")\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 == "" && (string)Connections[fd]["object"]->
eventWriteFile(arg,"")[0..1] == "50") {
eventWrite(fd, "50 " +cmd+ " " +arg+ ": Permission denied.\n");
break;
}
if( file == "" ) file += "\n";
if( file[<1] != '\n' ) file += "\n";
eventWrite(fd, "100 " + strlen(file) + " " + arg + "\n" + 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, "");
}