// ============================================================================
//
// = PACKAGE
//    tests.SOCK_SAP
// 
// = FILENAME
//    SOCKConnectorTest.java
//
// = AUTHOR
//    Prashant Jain
// 
// ============================================================================
package tests.SOCK_SAP;

import java.io.*;
import java.net.*;
import ACE.OS.*;
import ACE.SOCK_SAP.*;

public class SOCKConnectorTest
{
  void print_usage_and_die ()
    {
      System.out.println ("Usage: SOCKConnectorTest <hostname> [<port>]");
      System.exit (0);
    }

  void processRequests (SOCKStream stream) throws IOException
    {
      DataInputStream in = new DataInputStream (System.in);
      String msg;
      int ack_len;

      while (true)
	{
	  StringBuffer ack = new StringBuffer ();
	  ACE.DEBUG ("Enter input: ");
	  ACE.FLUSH ();
	  msg = in.readLine ();
	  if (msg == null)
	    break;
	  stream.send (msg);
	  ACE.DEBUG ("Waiting for ack...");
	  ack_len = stream.recv (ack);
	  if (ack_len == 0)
	    break;
	  else
	    ACE.DEBUG (ack.toString ());
	}
    }

  public void init (String host, int port)
    {
      SOCKStream stream = new SOCKStream ();
      SOCKConnector connector = new SOCKConnector ();
      try
	{
	  connector.connect (stream,
			     host,
			     port);
	  processRequests (stream);
	}
      catch (IOException e)
	{
	  ACE.ERROR (e);
	}
    }

  public static void main (String [] args)
    {
      int port = ACE.DEFAULT_SERVER_PORT;
      SOCKConnectorTest client = new SOCKConnectorTest ();
      if (args.length == 2)
	{
	  try
	    {
	      port = Integer.parseInt (args[1]);
	    }
	  catch (NumberFormatException e)
	    {
	      client.print_usage_and_die ();
	    }
	}
      client.init (args[0], port);
    }
}