#include <stdio.h>
#include <string.h>
#include <conio.h>
#include <tcp.h>

#define TALK_PORT 23


init()
{
    puts("\7\7");
    textbackground( MAGENTA );
    textcolor( WHITE );
    clrscr();
    cputs("  messages:");
    gotoxy(1,24);
    cputs("  current line:");

    window( 2,2,79,23);
    textbackground( DARKGRAY );
    clrscr();
    window( 1,24,80,25 );
    clrscr();
    gotoxy( 1,2);
}

add_msg( char *source, char *msg )
{
    window( 2,2,79,23);
    gotoxy( 1, 1 );
    delline();
    gotoxy( 1, 21 );
    cprintf( "%8.8s : %s", source, msg );
    window( 1,24,80,25 );
    gotoxy( 1, 2 );
}
main(int argc, char *argv[])
{
    longword remoteip;
    char *host;
    char dummyuser[ 80 ], dummyruser[80], dummyhost[80];

    char buffer[ 80 ], rbuffer[80], ch;
    word position;
    word sendit, status, who_closed = 0;

    tcp_Socket s, s2;
    char *user, *remoteuser;

    sock_init();

    clrscr();
    cputs("TCPTALK : (experimental version)\n\n\r");

    user = "me";	/* default */

    if (argc < 2) {
	cputs("TCPTALK  [remote_user_id@]remote_host  [my_user_id]");
	cputs("\n\r\nWaiting for an incomming call\n\r\n");
	cprintf("(My address is [%s]\n\r", inet_ntoa( buffer, gethostid()));
	tcp_listen( &s, TALK_PORT, 0, 0, NULL, 0 );
	sock_mode( &s, TCP_MODE_ASCII );
	sock_wait_established( &s, 0, NULL, &status);
	cprintf("Connection established\r");
	sock_wait_input( &s, sock_delay, NULL, &status );
	sock_gets( &s, dummyhost, sizeof( dummyhost ));
	sock_wait_input( &s, sock_delay, NULL, &status );
	sock_gets( &s, remoteuser = dummyruser, sizeof( dummyruser ));
	sock_puts( &s, "ok" );
	sound( 1000 );
	cputs("\n\rPress any to go to TALK session.\n\r");
	getch();
	nosound();
	sock_puts( &s, "<answerring your call>" );
        init();
    } else {
	remoteuser = "other";
	if ( host = strchr( argv[1], '@')) {
	    *host++ = 0;
	    remoteuser = argv[1];
	} else
	    host = argv[1];

	if (!( remoteip = resolve( host ))) {
	    textcolor( RED );
	    cprintf("\n\rUnable to resolve '%s'\n\r", host );
	    exit( 3 );
	}

	if ( argc < 3 ) {
	    cputs("Userid to assume:");
	    user = gets( dummyuser );
	    puts("\n\r");
	} else
	    cprintf("Using '%s' as local userid\n\r", user);

	if ( !tcp_open( &s, 0, remoteip, TALK_PORT, NULL )) {
	    cputs("Unable to open connection.");
	    exit( 1 );
	}
	sock_mode( &s, TCP_MODE_ASCII );
	sock_wait_established( &s, sock_delay,NULL, &status);
	sock_puts( &s, inet_ntoa(buffer,gethostid()));
	sock_puts( &s, user );
	sock_wait_input( &s, sock_delay, NULL, &status );

	sock_gets( &s, buffer, sizeof( buffer ));
	if ( stricmp( buffer, "ok" )) {
	    sock_close( &s );
	    cputs("Remote side did not wish to connect");
	    cprintf("MSG: %s\n", buffer);
	    sock_wait_closed( &s, sock_delay, NULL, &status );
	    exit( 1 );
	}
	init();
	add_msg( remoteuser, "< remote user has not answerred yet, waiting...>");
	sock_wait_input( &s, 0, NULL, &status );
    }

    /* we are connected */

    add_msg( remoteuser, "connected");
    *buffer = position = sendit = 0;

    while ( tcp_tick( &s ) ) {
	/*
	 *
	 */
	if (kbhit()) {
	    if ((ch = getch()) == 27) {
		sock_close( &s );
		who_closed = 1;
		break;
	    }
	    switch (ch) {
	       case '\r' : sendit = 1;
			   break;
	       case '\b' : buffer[ --position ] = 0;
			   delline();
			   cputs( buffer );
			   break;
	       case '\t' : ch = ' ';
	       default   : buffer[ position++ ] = ch;
			   buffer[ position ] = 0;
			   if (position > 64 );
			   gotoxy( 1,2);
			   clreol();
			   cputs(buffer );
	    }
	    if (sendit) {
		sock_puts( &s, buffer );
		add_msg( user , buffer);
		delline();
		sendit = 0;
		position = *buffer = 0;
	    }
	}

	if (sock_dataready( &s )) {
	    sock_gets( &s, rbuffer, sizeof( rbuffer ));
	    add_msg( remoteuser, rbuffer );
	}
    }


    delline();
    textcolor( RED );
    if ( who_closed == 1 ) {
	cputs(" *** YOU CLOSED CONNECTION *** ");
	sock_wait_closed(&s, sock_delay, NULL, &status);
    } else
	cputs(" *** OTHER PERSON CLOSED CONNECTION *** ");

    sleep( 1 );
    while (kbhit()) getch();
    getch();

    exit( 0 );

sock_err:
    switch ( status ) {
       case 1 : cputs("Connection closed");
		break;
       case -1: cputs("REMOTE HOST CLOSED CONNECTION");
		break;
    }
    exit( 0 );
}