FlashCommunicationServer.java

package edu.stanford.hci.r3.flash;

import java.awt.Desktop;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;

import edu.stanford.hci.r3.config.Constants;
import edu.stanford.hci.r3.util.DebugUtils;

public class FlashCommunicationServer {

        public static final int DEFAULT_PORT = Constants.Ports.FLASH_COMMUNICATION_SERVER;

        private int clientID = 0;

        private List<FlashClient> flashClients = new ArrayList<FlashClient>();

        private List<FlashListener> listeners = new ArrayList<FlashListener>();

        private int serverPort;

        private Thread serverThread;

        private ServerSocket socket;

        public FlashCommunicationServer() {
                this(DEFAULT_PORT);
        }

        public FlashCommunicationServer(int port) {
                serverPort = port;
                serverThread = new Thread(getServer());
                serverThread.start();
        }

        public void addFlashClientListener(FlashListener flashListener) {
                listeners.add(flashListener);
        }

        public void exitServer() {
                for (FlashClient client : flashClients) {
                        client.exitClient();
                }
                try {
                        socket.close();
                } catch (IOException e) {
                        e.printStackTrace();
                }
                DebugUtils.println("Exiting Flash Communications Server.... If this is the last thread, the program should exit.");
        }

        private Runnable getServer() {
                return new Runnable() {
                        public void run() {
                                log("Starting Flash Communications Server at port: " + serverPort);
                                try {
                                        socket = new ServerSocket(serverPort);
                                        while (true) {
                                                log("Waiting for a Client...");
                                                final Socket incoming = socket.accept();
                                                log("Flash Client connected.");
                                                final BufferedReader readerIn = new BufferedReader(new InputStreamReader(incoming
                                                                .getInputStream()));
                                                final PrintStream writerOut = new PrintStream(incoming.getOutputStream());

                                                // pass this to a handler thread that will service this client!
                                                flashClients.add(new FlashClient(FlashCommunicationServer.this, clientID++, incoming,
                                                                readerIn, writerOut));
                                        }
                                } catch (SocketException e) {
                                        log("Server Socket was Closed");
                                        // e.printStackTrace();
                                } catch (IOException e) {
                                        e.printStackTrace();
                                }
                                log("Closing Flash Communications Server");
                        }

                };
        }

        private void log(String string) {
                DebugUtils.println(string);
        }

        public void handleCommand(int clientID, String command) {
                DebugUtils.println("Server got command [" + command + "] from client " + clientID);
                for (FlashListener listener : listeners) {
                        listener.messageReceived(command);
                }
        }

        public void openFlashGUI(File flashGUIFile) {
                // browse to the flash GUI file, and pass over our port as a query parameter
                // TODO: pass the port
                try {
                        Desktop.getDesktop().browse(flashGUIFile.toURI());
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }

        public void openFlashApolloGUI(File apolloGUIFile) {
                try {
                        ProcessBuilder processBuilder = new ProcessBuilder(apolloGUIFile.getAbsolutePath(), "port:"
                                        + serverPort);
                        processBuilder.start();
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }

        public void removeAllFlashClientListeners() {
                listeners.clear();
        }

        public void sendMessage(String msg) {
                DebugUtils.println("Sending message: " + msg + " to all " + flashClients.size() + " clients");
                for (FlashClient client : flashClients) {
                        client.sendMessage(msg);
                }
        }
}

---