package com.example.usbaccessory;

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.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Toast;

public class SocketProgrammingActivity extends Activity implements
  OnClickListener {
 private Socket socket;
 private static final int SERVERPORT = 25;
 private static final String SERVER_IP = "indition.cc";
 private Button myButton;
 EditText et;
 BufferedReader input;

 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_socket_programming);
   myButt findViewById(R.id.myButton);
  myButton.setOnClickListener(this);
  et = (EditText) findViewById(R.id.EditText01);
  new Thread(new ClientThread()).start();

 }

 // ***************************************************************************************************//
 class ClientThread implements Runnable {
  @Override
  public void run() {
   try {
    InetAddress serverAddr = InetAddress.getByName(SERVER_IP);
    socket = new Socket(serverAddr, SERVERPORT);
    System.out.println("socket is" + socket);
    input = new BufferedReader(new InputStreamReader(
      socket.getInputStream()));
    String read = input.readLine();
    System.out.println("response is" + read);
     String upT
      Math.min(read.length(), 3));
    System.out.println("data is" + upToNCharacters);
    if (upToNCharacters.equalsIgnoreCase("220")) {
     // Toast.makeText(getApplicationContext(),
     // "Connected to Indition.cc", Toast.LENGTH_LONG).show();
     try {
      PrintWriter out = new PrintWriter(
        new BufferedWriter(new OutputStreamWriter(
          socket.getOutputStream())), true);
      out.println("EHLO\r\n");
     } catch (UnknownHostException e) {
      e.printStackTrace();
     } catch (IOException e) {
      e.printStackTrace();
     } catch (Exception e) {
      e.printStackTrace();
     }
     // Reading Response of command here
     System.out.println("new response iss" + input.readLine());
     thread.start();
     
    } else {
     Toast.makeText(getApplicationContext(), "Greetings failed",
       Toast.LENGTH_LONG).show();
    }
   } catch (UnknownHostException e1) {
    e1.printStackTrace();
   } catch (IOException e1) {
    e1.printStackTrace();
   }
  }
 }

 public void readStream(){
  
  StringBuilder total = new StringBuilder();
  String line;
  try {
   while ((line = input.readLine()) != null) {
       total.append(line);
   }
   System.out.println("*** readStream: " + total.toString()+" ***");
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 
 // ************************************************************************************************//
 public void onClick(View view) {
  switch (view.getId()) {
  case R.id.myButton:

   break;

  default:
   break;
  }

 }

 Thread thread = new Thread() {
     @Override
     public void run() {
         try {
             while(true) {
                 sleep(1000);
                 readStream();
             }
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
     }
 };

 
}