package ua.radian.wifi;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.Enumeration;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.util.Log;


public class MainActivity extends Activity {


 
    // DEFAULT IP
    public static String SERVERIP = "10.0.2.1";
 
    // DESIGNATE A PORT
    public static final int SERVERPORT = 17000;
    public static final String  LOG = "MyLog";
    private Handler handler = new Handler();
    public BufferedReader in;
    public PrintWriter out;
    public int MyCount = 0;
    public  String line = null;
    
    private ServerSocket serverSocket;
 
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
 
        Thread fst = new Thread(new ServerThread());
        fst.start();
    }

    public class ServerThread implements Runnable {
 
        public void run() {
            try {
            	Log.d(LOG, "start");	
                if (SERVERIP != null) {
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                        	Log.d(LOG, "Listening on IP: " + SERVERIP);	
                        }
                    });
                    serverSocket = new ServerSocket(SERVERPORT);
                    Socket client = null;
                    while (true) {
                        // LISTEN FOR INCOMING CLIENTS
                    	 Log.d(LOG,"wait you...");
                    	client = serverSocket.accept();
                    	client.setTcpNoDelay(true);
                    	
                        Log.d(LOG,"client IP : "+client.getLocalAddress().toString());
                        Log.d(LOG,"client Port : " + Integer.toString(client.getPort()));
                        handler.post(new Runnable() {
                            @Override
                            public void run() {
                            	Log.d(LOG, "Connected.");	
                        
                            }
                        });
 
                        	client.setSendBufferSize(255);
         
                            in = new BufferedReader(new InputStreamReader(client.getInputStream()));
                            out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(client.getOutputStream())), true);
                            out.println("|I found You");      
                            
                            new Thread(new Runnable() {
								
								@Override
								public void run() {
									// TODO Auto-generated method stub
									 try {
										while ((line = in.readLine()) != null) {
		                            		
			                            	Log.d(LOG, line);
			                                MyCount++;	
			                                Log.d(LOG, "Count receive: "+Integer.toString(MyCount));
			                                out.println("|I readed You");
			                                out.flush();
			                               
			                                handler.post(new Runnable() {
			                                    @Override
			                                    public void run() {
			                                    	//Log.d(LOG, "was write");	
			                                        // DO WHATEVER YOU WANT TO THE FRONT END
			                                        // THIS IS WHERE YOU CAN BE CREATIVE
			                                    }
			                                });
		                                
										}
									 } catch (Exception e) {
				                            handler.post(new Runnable() {
				                                @Override
				                                public void run() {
				                                	Log.e(LOG, "Oops. Connection interrupted. Please reconnect your phones.");	
				                                   
				                                }
				                            });
				                            e.printStackTrace();
				                        }
	                            	                           	
								}
							}).start();
                            
                            break;
                    }
                } else {
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                        	Log.e(LOG, "Couldn't detect internet connection.");	
                        }
                    });
                }
            } catch (Exception e) {
                handler.post(new Runnable() {
                    @Override
                    public void run() {
                    	Log.e(LOG, "Error");	
                      
                    }
                });
                e.printStackTrace();
            }
        }
    }
 
    @Override
    protected void onStop() {
        super.onStop();
        try {
             // MAKE SURE YOU CLOSE THE SOCKET UPON EXITING
             serverSocket.close();
         } catch (IOException e) {
             e.printStackTrace();
         }
    }


}