#include <lib.h>
#include <network.h>
#include <socket_err.h>
inherit LIB_ITEM;

int attempting, connected, socket ;
object person ;
object player;

static void create()
{
    item::create();
    SetKeyName( "client" ) ;
    SetShort( "a telnet client" ) ;
    SetId(({ "telnet","terminal" })) ;
    SetLong( "It's a small pocket sized telnet terminal.\n"
      "Use 'telnet' or 'connect' to begin.\n\nCommands:\n"
      "[connect|telnet] : start telnet session.\nreset [client]"
      " : reset the telnet client.\nreconnect : reconnect to session"
      " (if you go netdead)\n");
    SetMass( 5 ) ;
    attempting = 0 ;
    connected = 0 ;
    socket = 0 ;
    person = 0 ;
}

void init()
{  
    add_action( "do_connect", ({ "connect", "telnet" }) ) ;
    add_action( "do_reset", "reset" ) ;
    add_action( "do_reconnect", "reconnect" ) ;
}

int do_reconnect()
{
    if( !connected )
    {
	notify_fail( "The telnet client is not connected!\n" ) ;
	return 0 ;
    }
    write("Reconnecting into telnet session.\n");
    person = this_player() ;
    input_to( "parse_comm", 0 ) ;
    return 1 ;
}

int do_reset( string args )
{
    notify_fail( "Usage: reset client\n" ) ;
    if( !args || args == "" )
    {
	return 0 ;
    }
    if( args != "client" )
    {
	return 0 ;
    }
    write("Resetting telnet client ...\n");
    if( connected )
    {
	if( socket )
	{
	    socket_close( socket ) ;
	}
    }
    attempting = 0 ;
    connected = 0 ;
    socket = 0 ;
    person = 0 ;
    write("Done!\n");
    return 1 ;
}

string help()
{
    return "=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\n"
    "  Usage : connect [ip_address] [port]\n"
    "=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\n"
    "Note: use telnet port number 23 if you \n"
    "      are connecting to a normal site. \n"
    "=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\n" ;
}

int do_connect(string args)
{
    int new_socket, sc_result, port ;
    string error, ip_address ;

    if( !args || args == "" )
    {
	notify_fail( help() ) ;
	return 0 ;
    }
    if( sscanf( args, "%s %d", ip_address, port ) != 2 )
    {
	notify_fail( help() ) ;
	return 0 ;
    }
    if( attempting )
    {
	notify_fail( "Telnet connection attempt already in progress.\n" ) ;
	return 0 ;
    }
    if( connected )
    {
	notify_fail( "Already connected...\n" ) ;
	return 0 ;
    }
    new_socket = socket_create( STREAM, "read_callback", "close_callback" ) ;
    if( new_socket < 0 )
    {
	switch( new_socket )
	{
	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: " + new_socket + ".\n" ;
	    break ;
	}
	notify_fail( "Unable to connect, problem with socket_create.\n"
	  "Reason: " + error ) ;
	return 0 ;
    }
    sc_result = socket_connect( new_socket, ip_address + " " + port,
      "read_callback", "write_callback" ) ;
    if( sc_result != EESUCCESS )
    {
	notify_fail( "Failed to connect.\n" ) ;
	return 0 ;
    }
    attempting = 1 ;
    socket = new_socket ;
    person = (object)previous_object() ;
    player=this_player();
    write("Telnet Client Version 1.2\n");
    write("Attempting connection to: " + ip_address + " " + port + "...\nEnter 'dcon' at any time to abort.\n");
    input_to( "parse_comm", 0 ) ;
    return 1 ;
}

void read_callback( int fd, mixed message )
{
    player->eventPrint(message);
}

void close_callback( int fd )
{
    if( connected )
    {
	write("Connection closed by foreign host.\n");
    }
    if( attempting )
    {       
	write("Attempt failed.\n");
    }
    write("Type 'dcon' to finalize exit.\n");
    socket_close( fd ) ;
    attempting = 0 ;
    connected = 0 ;
    socket = 0 ;
}

void write_callback( int fd )
{
    write("Connected...\n");
    attempting = 0 ;
    connected = 1 ;
}

int parse_comm( string str )
{
    if( str == "dcon" )
    {
	write("Disconnecting...\n");
	socket_close( socket ) ;
	attempting = 0 ;
	connected = 0 ;
	socket = 0 ;
	person = 0 ;
	return 1 ;
    } else {
	if( !connected )
	{
	    write("You are not connected. Type \"dcon\" to stop using the client.\n");
	    input_to( "parse_comm", 0 ) ;
	    return 1 ;
	}
	if( attempting )
	{
	    write("Please wait, still attempting connection, "
	      "type 'dcon' to exit.\n");
	    input_to( "parse_comm", 0 ) ;
	    return 1 ;
	}
	socket_write( socket, str + "\n" ) ;
	input_to( "parse_comm", 0 ) ;
	return 1 ;
    }
}