/* This daemon is not intended to be monolithic. It should
* be cloned, with each cloned version handling a single
* connection and transfer.
*/
#include <lib.h>
#include <network.h>
#include <socket_err.h>
#include <message_class.h>
#include <daemons.h>
#define _DEBUG
inherit LIB_DAEMON;
int socket;
int status;
object Owner;
mapping PendingResolves = ([]);
string path, host, address, port, results, s;
void sendHTTPGet();
int http_file_found;
private string args_list;
varargs void create(object owner){
daemon::create();
Owner = owner;
if(!PendingResolves) PendingResolves = ([]);
}
mixed ProcessHTTPResult()
{
if(Owner){
Owner->eventReceiveWebData(results,path);
}
return 1;
}
void read_callback( int fd, mixed message )
{
results += message;
}
void write_callback( int fd )
{
http_file_found = 0;
sendHTTPGet();
}
void close_callback( int fd )
{
ProcessHTTPResult();
socket_close( fd ) ;
::eventDestruct();
}
void sendHTTPGet()
{
string str ="GET "+path+" HTTP/1.0"+CARRIAGE_RETURN+"\n"+
"Host: "+host+CARRIAGE_RETURN"\n" +
"User-Agent: WGET_D@" + mud_name() + " " +
mudlib()+ "/" + mudlib_version() +" ("+ query_os_type()+";) "+
version() + CARRIAGE_RETURN+"\n"+CARRIAGE_RETURN+"\n";
int result = 0;
results = "";
result = socket_write( socket, (string)str );
}
int openHTTPConnection()
{
int sock, sc_result;
string error;
sock = socket_create( STREAM, "read_callback", "close_callback" ) ;
if (sock < 0) {
switch( sock )
{
case EEMODENOTSUPP :
error = "Socket mode not supported.\n" ;
break ;
case EESOCKET :
error = "Problem creating socket.\n" ;
break ;
case EESETSOCKOPT :
error = "Problem with setsockopt.\n" ;
break ;
case EENONBLOCK :
error = "Problem with setting non-blocking mode.\n" ;
break ;
case EENOSOCKS :
error = "No more available efun sockets.\n" ;
break ;
case EESECURITY :
error = "Security violation attempted.\n" ;
break ;
default :
error = "Unknown error code: " + sock + ".\n" ;
break ;
}
notify_fail( "Unable to connect, problem with socket_create.\n"
"Reason: " + error ) ;
return 0 ;
}
#ifdef _DEBUG
write("Attempting to connect to "+host+ " on port "+ port + "\n");
#endif
sc_result = socket_connect( sock, address + " " + port,
"read_callback", "write_callback" ) ;
if( sc_result != EESUCCESS )
{
notify_fail( "Failed to connect.\n" ) ;
return 0 ;
}
else{
}
socket = sock;
return 1;
}
void hostResolved( string address, string resolved, int key )
{
if( !resolved ){
return;
}
openHTTPConnection();
}
void resolveHost()
{
resolve( host, "hostResolved" );
}
mixed eventGet(string args) {
string foo, bar;
int baz, key, a, b, c, d;
if(!strsrch(args,"http://")){
args = replace_string(args,"http://","",1);
}
address = first_string_element(args,"/");
args = replace_string(args,address,"");
if(sscanf(args, "%s -n %s", foo, bar) == 2){
host = bar;
args = foo;
}
else host = address;
path = args;
if(sscanf(address,"%s:%d",foo, baz) == 2){
address = foo;
port = ""+baz;
}
else port = "80";
if(args) args_list = args;
else args_list = "";
if(sscanf(address,"%d.%d.%d.%d",a,b,c,d) != 4){
if(!RESOLV_D->GetResolving()){
return "Mud is not resolving. Try again with a numerical address.";
}
PendingResolves[key] = ([ "port" : port, "path" : path ]);
key = RESOLV_D->eventResolve(address,"resolve_callback");
return key;
}
openHTTPConnection();
return 1;
}
void resolve_callback(string name, string ip, int key){
string ret = ip+":"+port + path+" -n "+name;
eventGet(ret);
}
string GetErorMessage() {
return "There was a problem";
}
string GetHelp() {
return ("Syntax: dsversion [version]\n\n" +
"Shows the latest version of Dead Souls and release notes.\n"+
"e.g. dsversion, dsversion r1, dsversion 2.0r1");
}
