summaryrefslogtreecommitdiff
path: root/src/tesseract/objects/remote/RemoteObjectCommunicator.java
blob: 86b75cca4c87ea09a64c7548bce6c7871dcdaacd (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package tesseract.objects.remote;

import java.awt.event.KeyEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.UUID;

public class RemoteObjectCommunicator implements Runnable {

	private static final int BASE_PORT = 5551;
	
	private ServerSocket mySocket;
	
	private HashMap<UUID, Socket> mySockets;
	
	private boolean myRunning;
	
	public RemoteObjectCommunicator() {
		mySockets = new HashMap<UUID, Socket>();
		myRunning = false;
		
		int port = BASE_PORT;
		
		// Find an open port.
		while (true) {
			try {
				mySocket = new ServerSocket(port);
				myRunning = true;
				break;
			
			} catch (IOException e) {
				port++;
			
			} catch (Exception e) {
				System.err.println(e);
				return;
			}
		}
	}

	
	public void run() {
		// Listen for connections
		while (myRunning) {
			try {
				Socket s = mySocket.accept();
				
				handleNewSocket(s);
				
			} catch (IOException e) {
				System.err.println(e);
			}
		}
	}
	
	public boolean sendKeyToObject(UUID id, KeyEvent event) {
		Socket s = mySockets.get(id);
		
		if (s != null && s.isConnected()) {
			try {
				DataOutputStream out = new DataOutputStream(s.getOutputStream());
				out.writeInt(event.getKeyCode());
				out.flush();
				
				return true;
				
			} catch (IOException e) {
				mySockets.remove(id);
				return false;
			}
			
		} else {
			return false;
		}
	}
	
	private void handleNewSocket(final Socket socket) {		
		try {
			DataInputStream in = new DataInputStream(socket.getInputStream());
			
			long msb = in.readLong();
			long lsb = in.readLong();
			UUID id = new UUID(msb, lsb);
			
			mySockets.put(id, socket);
			
		} catch (Exception e) {
			System.err.println(e);
		}
	}


	public int getPort() {
		if (mySocket != null) {
			return mySocket.getLocalPort();
			
		} else {
			return 0;
		}
	}
	
}