package jp.ac.u_ryukyu.treevnc.client;

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


public class GetDataClient implements Runnable {
	private ServerSocket server = null;
	private BufferedReader is;
	private int port = 8182;
	private boolean stopFlag;
	private TextBoxClient text = new TextBoxClient();
		
	
	public String textAddress() {
		return text.getAddress();
	}
	
	public String  textPort() {
		return text.getPort();
	}
	
	void socketClose() {
		try {
			text.unVisible();
			//server.close(); after the modify
			is.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
/*	
	private int castInt(byte[] a) {
		int value = 0;
		ByteArrayInputStream bais = new ByteArrayInputStream(a);
		DataInputStream dis = new DataInputStream(bais);
		try {
			value = dis.readInt();
		} catch (IOException e) {
		}
		System.out.println(value);
		return value;
	}

	private String castString(byte[] a) {
		String recover = new String(a);
		recover = recover.replace("¥n", "");
		recover = recover.trim();
		System.out.println(recover);
		return recover;
	}
*/
	@Override
	public void run() {
		try {
			//TODO create selectPort();
			server = new ServerSocket(port);
			while(!stopFlag) {
				Socket socket = server.accept();  
				is = new BufferedReader(new InputStreamReader(
						socket.getInputStream()));
				String line = is.readLine();
//				text = new TextBoxClient();
				if(line!=null)
					text.checkBox(line);
				// TextBoxClient text = new TextBoxClient();
				text.setButton();
				text.visible();
			}
			System.out.println("stop");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	public void setStopFlag(boolean stopFlag) {
		this.stopFlag = stopFlag;
		
	}
	
	public void interrupt() {
		Thread.currentThread().interrupt();
	}

	public boolean isStopFlag() {
		return stopFlag;
	}
	
	public void ipRegister() {
		text.ipRegister();
	}

}