package com.example.chat;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.EditText;

import java.net.*;
import java.io.*;


public class MyChatCientAppActivity extends Activity {
    /** Called when the activity is first created. */
    String ip = "0";
    ChatClient client = null;
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        
         
         
         
    }
    
    public void onSendClick(View v)
    {
        EditText nachricht = (EditText) this.findViewById(R.id.EditText01);
        String msg = nachricht.getText().toString();
        client.send(msg);
        
    }
    
    public void onConnectClick(View v)
    {
        EditText AdressEditText = (EditText) this.findViewById(R.id.EditText02);
        ip = AdressEditText.getText().toString();
        int port = 4000;
        client =  new ChatClient(ip, port);
    }
}

class ChatClient
{ 
   private Socket socket              = null;
   private DataInputStream  console   = null;
   private DataOutputStream streamOut = null;

   public ChatClient(String serverName, int serverPort)
   {  System.out.println("Establishing connection. Please wait ...");
      try
      {  socket = new Socket(serverName, serverPort);
         Log.d("DEBUG","Connected: " + socket);
         start();
      }
      catch(UnknownHostException uhe)
      {  Log.d("DEBUG","Host unknown: " + uhe.getMessage());
      }
      catch(IOException ioe)
      {  Log.d("DEBUG","Unexpected exception: " + ioe.getMessage());
      }
      
     
   }
   
   public void start() throws IOException
   {  
      console   = new DataInputStream(System.in);
      streamOut = new DataOutputStream(socket.getOutputStream());
   }
   
   public void stop()
   {  try
      {  if (console   != null)  console.close();
         if (streamOut != null)  streamOut.close();
         if (socket    != null)  socket.close();
      }
      catch(IOException ioe)
      {  System.out.println("Error closing ...");
      }
   }
   
   public void send(String msg)
   {
       try
       {  
          streamOut.writeUTF(msg);
          streamOut.flush();
       }
       catch(IOException ioe)
       {  
           Log.d("DEBUG","Sending error: " + ioe.getMessage());
       }
   }
  
}