/* /secure/cmds/creators/dsversion.c
* Created by Brodbane of Eve
* Date Created: 4/1/06
*/
#include <lib.h>
#include <network.h>
#include <socket_err.h>
#include <message_class.h>
inherit LIB_DAEMON;
#define HTTP_ADDRESS "204.209.44.12"
#define HTTP_HOST "lpmuds.net"
#define HTTP_PORT 80
#define HTTP_PATH "/RELEASE_NOTES"
#define NOTES_DELIM "----"
#define SAVE_FILE "/doc/RELEASE_NOTES_HTTP"
#define SOCK_FIND 0
#define SOCK_CONNECTING 1
#define SOCK_CONNECTED 2
#define SOCK_DISCONNECTED 3
#define SOC_ERROR 4
int socket;
int status;
object player;
object person;
string results, s;
void sendHTTPGet();
int http_file_found;
private string args_list;
mixed ProcessHTTPResult()
{
string * parts;
string * arg_array;
string * temp;
parts = explode( results, NOTES_DELIM );
temp = explode( parts[0], "---" );
player->eventPrint( "Current Version of "+mud_name()+": " + mudlib_version() );
player->eventPrint( "Latest Version of Dead Souls: %^RED%^"+trim(temp[0])+ "%^RESET%^" );
write_file( SAVE_FILE, results, 1 );
arg_array = explode( args_list, " " );
foreach( string str in arg_array ){
temp = regexp( parts, args_list+" +" );
if( sizeof( temp ) > 1 ) temp = regexp( parts, args_list+" " );
if( sizeof( temp ) > 3 ){
player->eventPrint( "Too many results, truncating..." );
return print_long_string(player, temp[0]+temp[1]+temp[2],1 );
}
else{
s = implode(temp,"\n%^CYAN%^----%^RESET%^ ");
write_file( SAVE_FILE, results, 1 );
s += "\nFor complete release notes refer to "+SAVE_FILE;
print_long_string(player, "%^CYAN%^----%^RESET%^ "+s,1 );
}
}
return 1;
}
void read_callback( int fd, mixed message )
{
if( !http_file_found ){
if( message[9..11] != "200" ){
player->eventPrint( "Error, unable to locate page requested." );
http_file_found = 3;
}
else
{
http_file_found = 1;
}
}
else if( http_file_found == 1 ){
results += message;
}
else{
}
}
void write_callback( int fd )
{
#ifdef _DEBUG
player->eventPrint("Connected!");
#endif
status = SOCK_CONNECTED;
http_file_found = 0;
sendHTTPGet();
}
void close_callback( int fd )
{
if( status == SOCK_CONNECTED )
{
// Process HTML here
#ifdef _DEBUG
player->eventPrint("Connection closed by host.");
#endif
ProcessHTTPResult();
}
if( status == SOCK_CONNECTING )
{
player->eventPrint("Connection attempt failed.");
}
socket_close( fd ) ;
status = SOCK_DISCONNECTED;
}
void sendHTTPGet()
{
string str ="GET "+HTTP_PATH+" HTTP/1.0"+CARRIAGE_RETURN+"\n"+
"Host: "+HTTP_HOST+CARRIAGE_RETURN"\n" +
"User-Agent: "+ player->GetName() + "@" + mud_name() + " " +
mudlib()+ "/" + mudlib_version() +" ("+ query_os_type()+";) "+
version() + CARRIAGE_RETURN+"\n"+CARRIAGE_RETURN+"\n";
int result = 0;
results = "";
#ifdef _DEBUG
player->eventPrint("Sending HTTP get request..." );
#endif
if( status == SOCK_CONNECTED )
{
result = socket_write( socket, (string)str );
#ifdef _DEBUG
player->eventPrint( "HTTP request sent to " + socket + " result = "+result );
#endif
}
}
int openHTTPConnection()
{
int sock, sc_result;
string error;
status = SOCK_FIND;
status = SOCK_CONNECTING;
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 "+HTTP_HOST+ " on port "+ HTTP_PORT + "\n");
#endif
sc_result = socket_connect( sock, HTTP_ADDRESS + " " + HTTP_PORT,
"read_callback", "write_callback" ) ;
if( sc_result != EESUCCESS )
{
status = SOCK_DISCONNECTED;
notify_fail( "Failed to connect.\n" ) ;
return 0 ;
}
else{
#ifdef _DEBUG
player->eventPrint( "Socket connecting..." );
#endif
}
socket = sock;
return 1;
}
void hostResolved( string address, string resolved, int key )
{
if( !resolved ){
#ifdef _DEBUG
player->eventPrint( "Unable to resolve "+address );
#endif
return;
}
#ifdef _DEBUG
player->eventPrint( "Resolved "+address+" to "+ resolved );
#endif
player->eventPrint( "Retrieving updated release notes from: http://www.dead-souls.net\n" );
openHTTPConnection();
}
void resolveHost()
{
resolve( HTTP_HOST, "hostResolved" );
}
mixed cmd(string args) {
player = previous_object();
if(args) args_list = args;
else args_list = "";
openHTTPConnection();
return 1;
}
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");
}
