import java.rmi.*;
import java.util.*;
import java.io.*;
import java.net.*;

public class ACServerTester {

  private static String ENCODING;
  private static int MAXSENDLENGTH, MAXRECVLENGTH, UDPPORT, TCPPORT;

  private static void list( Hashtable ht ) {
	Object key;
	for ( Enumeration e=ht.keys(); e.hasMoreElements(); ) {
		key=e.nextElement();
		System.out.println(key+"="+ht.get(key));
	}
	System.err.println("listed "+ht.size()+" items\n" );
  }

  public static void main(String args[]) {
    String host;
    boolean rmi=false, tcp=false, udp=false;

    try {
	if (args.length==0) {
	   System.err.println("Usage:\n\tjava ACServerTester <host> [rmi] [tcp] [udp]");
	   return;
	}

	host=args[0];
        for (int i=1; i<args.length; i++) {
	   if (args[i].equals("rmi")) {
           	rmi=true;
           }
           else if (args[i].equals("tcp")) {
           	tcp=true;
           }
           else if (args[i].equals("udp")) {
           	udp=true;
           }
        }
        
	if ( !rmi && !tcp && !udp ) {
		rmi=true;
		tcp=true;
		udp=true;
	}
	// param‚terek beolvas sa
	Properties props=new Properties();
    	try {
        	props.load( new FileInputStream( "TestACServer.properties" ) );
    	} catch (Exception e) {}

    	ENCODING = props.getProperty( "ENCODING", "UTF8" /*"8859_2"*/ );

    	try {
        	MAXSENDLENGTH = Integer.parseInt( props.getProperty( "MAXSENDLENGTH" ) );
    	} catch (Exception e) {
        	MAXSENDLENGTH = 1000;
    	}
    	try {
        	MAXRECVLENGTH = Integer.parseInt( props.getProperty( "MAXRECVLENGTH" ) );
    	} catch (Exception e) {
        	MAXRECVLENGTH = 1000;
    	}
    	try {
        	UDPPORT = Integer.parseInt( props.getProperty( "UDPPORT" ) );
    	} catch (Exception e) {
        	UDPPORT = 23456;
    	}
    	try {
        	TCPPORT = Integer.parseInt( props.getProperty( "TCPPORT" ) );
    	} catch (Exception e) {
        	TCPPORT = 23456;
    	}

        ACServerInterface as=(ACServerInterface)Naming.lookup("rmi://"+host+"/TestACServer");
	
	Hashtable params = new Hashtable(), ans;
	params.put( ACProtocol.CLIENTDATE, new Date( System.currentTimeMillis() + 3000 ) );
	params.put( "stringtest", " µ‚�¡Ö¢à”™oO£é�šuUáÁéÉíÍóÓöÖoOúÚüÜuU" );
	params.put( "longtest", new Long( 666 ) );
	params.put( "fdoubletest", new Double(Math.PI) );
	params.put( "booleantest", Boolean.TRUE );
	params.put( "datetest", new Date() );

	System.err.println("Used hashtable:");
	list( params );

	if (rmi) {
        	as.log("rmi test");	
        	System.err.println("Processes before rmi test:\n"+as.list());
		long time=System.currentTimeMillis();
		ans=as.check(params);
		System.err.println("rmi test result after "+(System.currentTimeMillis()-time)+" ms:");
		list(ans);
        }
        if (tcp) {
  		as.log("tcp test");
        	System.err.println("Processes before tcp test:\n"+as.list());
		long time=System.currentTimeMillis();
		byte buf[] = ACProtocol.encode( params, ENCODING, MAXSENDLENGTH );
		Socket s = new Socket( host, TCPPORT );
		OutputStream os = s.getOutputStream();
		InputStream is = s.getInputStream();
		os.write( buf );
		os.flush();
		buf = new byte[ MAXRECVLENGTH ];
// Berakok az elejére egy dátumot, mert a decode az ACServer oldaláról nézi a dolgot
// és ott elvárja a CLIENTDATE-t, amit a TCP nem ad vissza...
		byte[] buf1 = ACProtocol.encodeDate( (Date)params.get(ACProtocol.CLIENTDATE), ENCODING );
		System.arraycopy( buf1, 0, buf, 0, buf1.length );
		buf[ buf1.length ]=(byte)0;
		int readcount = is.read( buf, buf1.length+1, buf.length-buf1.length-1 );
		byte buff[] = new byte[ readcount+buf1.length+1 ];
		System.arraycopy( buf, 0, buff, 0, buff.length );
		s.close();
		ans = ACProtocol.decode( buff, ENCODING );
		System.err.println("tcp test result after "+(System.currentTimeMillis()-time)+" ms:");
		list(ans);
	}
        if (udp) {
        	as.log("udp test");
        	System.err.println("Processes before udp test:\n"+as.list());
		long time=System.currentTimeMillis();
		byte buf[] = ACProtocol.encode( params, ENCODING, MAXSENDLENGTH );
		DatagramPacket dp = new DatagramPacket( buf, buf.length, InetAddress.getByName(host) , UDPPORT );
		DatagramSocket ds = new DatagramSocket();
		ds.send( dp );
		buf = new byte[ MAXRECVLENGTH ];
		dp.setData( buf );
		dp.setLength( buf.length );
		ds.receive( dp );
		buf = new byte[ dp.getLength() ];
		System.arraycopy( dp.getData(), 0, buf, 0, buf.length );
		ds.close();
		ans = ACProtocol.decode( buf, ENCODING );
		System.err.println("udp test result after "+(System.currentTimeMillis()-time)+" ms:");
		list(ans);
        }
        System.err.println("Processes after:\n"+as.list());
    } catch (Exception e) {
      System.err.println("ERROR!"+e);
	e.printStackTrace();
    }
  }
}