/*
 * Created on Dec 31, 2004
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package cc.glsn;

import java.net.Socket;
import java.net.ServerSocket;
import java.io.IOException;


/**
 * @author fireduck
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class TCPWatch
{
    SyncCounter DoneCnt;
    PCMonitor LogQ;

    public static void main(String[] args) throws IOException
    {
        int AnswerPort=new Integer(args[0]).intValue();
        String TargetHost=args[1];
        int TargetPort=new Integer(args[2]).intValue();
        
        new TCPWatch(AnswerPort,TargetHost,TargetPort);
    }
    
    public TCPWatch(int AnswerPort, String TargetHost, int TargetPort) throws IOException
    {
        LogQ=new PCMonitor();
        
        ServerSocket SS=new ServerSocket(AnswerPort);
        Socket SockClient=SS.accept();
        
        Socket SockServer=new Socket(TargetHost,TargetPort);
        
        new Loggo().start();
        new Reado("client",SockClient,SockServer).start();
        new Reado("server",SockServer,SockClient).start();
    }
    
    
    private class Reado extends Thread
    {
        String Label;
        Socket InputSock;
        Socket OutputSock;
        
        
        
        
            /**
         * @param label
         * @param inputSock
         * @param outputSock
         */
        public Reado(String label, Socket inputSock, Socket outputSock)
        {
            super();
            this.setDaemon(false);
            
            Label = label;
            InputSock = inputSock;
            OutputSock = outputSock;
            
        }
        
        public void run()
        {
            try
            {
                byte Buff[]=new byte[4096];
	            while((!InputSock.isInputShutdown()) && (!OutputSock.isOutputShutdown()))
	            {
	                
	                int len=InputSock.getInputStream().read(Buff,0,4096);
	                if (len>0)
	                {
	                    byte Buff2[]=new byte[len];
	                    for(int i=0; i<len; i++)
	                    {
	                        Buff2[i]=Buff[i];
	                    }
	                    
	                    LogQ.Produce(new LogEntry(Label,Buff2));
	                    
	                    OutputSock.getOutputStream().write(Buff2);
	                    
	                }
	            }
	            
	            if (InputSock.isInputShutdown())
	            {
	                OutputSock.shutdownOutput();
	            }
            }
            catch(IOException e)
            {
                e.printStackTrace();
            }
        }
    }

    
    private class Loggo extends Thread
    {
        public Loggo()
        {
            super();
            this.setDaemon(true);
        }
        
        public void run()
        {
            while(true)
            {
                LogEntry E=(LogEntry)LogQ.Consume();
                System.out.println(E.toString());
                
            }
        }
    }
    
    private class LogEntry
    {
        String Label;
        byte[] Bytes;
        
        
        
        /**
         * @param label
         * @param bytes
         */
        public LogEntry(String label, byte[] bytes)
        {
            super();
            Label = label;
            Bytes = bytes;
        }
        
        public String toString()
        {
            StringBuffer SB=new StringBuffer(100+Bytes.length*2);
            SB.append("Log{ ");
            SB.append("From: ");
            SB.append(Label);
            SB.append(" Bytes: ");
            SB.append(Bytes.length);
            SB.append("\n");
            SB.append("    ");
            
            
            //SB.append(Bytes);
            //SB.append(" ");
            
            for(int i=0; i<Bytes.length; i++)
            {
                //SB.append(" ");
                int z=Bytes[i];
                if (z<0) z+=128;
                //if (z<16) SB.append("0");
              
                
                SB.append((char)z);
                
                if (z==10) SB.append("    ");
                
                //SB.append(Integer.toHexString(z));
            }
            SB.append("}");
            
            
            return SB.toString();
        }
    }
}