/* fpont 12/99 */
/* pont.net    */
/* tcpClient.c */

#include <iostream.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h> /* close */
#include <sys/uio.h>
#include <signal.h>

#include "Port.cpp"

int SERVER_PORT = 10100;  //where to send stimulus
int RECV_PORT = 20200;  //where report data is coming from

#define MAX_MSG 100

static void sig_pipe( int );

int main (int argc, char *argv[]) {
    FILE *fp;
    int j, nread;
    int sd, rc, i;
    int port = 10100;
    int done = 0;
    char buffer[1024];
    char finalBuffer[4096];
    int n;

    sd = -1;
    
    if(argc < 3) {
        printf("usage: %s <server> <port>\n",argv[0]);
        exit(1);
    }

    if( signal( SIGPIPE, sig_pipe ) == SIG_ERR )
      cerr<<"failed to set up signal catcher\n";
    
    port = atoi( argv[2] );
    if( port <= 0 )
    {
        cerr<<"Error: invalid port "<<port<<endl;
        exit( 0 );
    }

    //set up coonection
    char command[128] = "request\n";
    char mode[128] = "writer\n";
    char format[128] = "ascii\n";

    char brainType[128] = "AutoPortTest";   //These three will combined into
    char brainJob[128] = "j_07072004";      //one, so only add a '\n' after
    char stimulusName[128] = "reward\n";    //the stimulusName

    sd = OpenPort( argv[1], port );
    if( sd < 0 )
    {
      cerr<<"Error\n";
      exit(0);
    }

    //write parameters to port so that server can forward me correctly
    sprintf( finalBuffer, "%s%s%s%s%s%s", command, mode, format, brainType, brainJob, stimulusName );
    write( sd, finalBuffer, strlen( finalBuffer ) );
  
    //for many fake timesteps - 
    while (!done )
    {
        cerr<<"waiting for input ( type 'exit' to quit )\n";
        cin.getline( buffer, 1024 );

        if( strncmp( buffer, "exit", 5 ) == 0 )
            done = 1;
        else
        {
            //add null to buffer end
            if( strlen( buffer ) < 1024 )
              buffer[strlen(buffer)] = 0;
            else
              buffer[1023] = 0;

            //data format:
	    //X X_characters
	    //12 hello world\n
            sprintf( finalBuffer, "%d %s", strlen( buffer ), buffer );

            write( sd, finalBuffer, strlen( finalBuffer ) );
        }
    }

    close( sd );

return 0;
}

void sig_pipe( int signo )
{
  cerr<<"caught Broken Pipe signal\n";
}