Colony

/*

*        ColonetServerInterface.java

*        Gregory Tress

*/

import java.net.*;

import java.io.*;

import javax.swing.JOptionPane;

import javax.swing.JTextArea;

public class ColonetServerInterface 

{

        /* STATIC FIELDS

         * Eugene Marinelli, Fan

         * 10/27/06

         *

         * Colonet Definitions - common definitions and structs used in all colonet 

         * applications

  COMMAND PACKET STRUCTURE

        1:  SEND_TO_ROBOT

        2:  # of robot, or GLOBAL_DEST

        3:  COLONET_COMMMAND

        4:  message code (i.e. ORB_SET)

        5:  any data, as many that fit in the packet

        REQUEST PACKET STRUCTURE

        1:  REQUEST_FROM_ROBOT

        2:  # of robot

        3:  COLONET_REQUEST

        4:  ???

  9/12/07 New server interface structure

    Client will no longer send full robot packets to the server.

    Commands will be defined as necessary.

        */

        public static final String SEND_TO_ROBOT = "0";

        public static final String REQUEST_FROM_ROBOT = "1";

        public static final String RESPONSE_TO_CLIENT_REQUEST = "2";

        public static final String GLOBAL_DEST = "200";

        //Message types

        public static final String COLONET_COMMAND = "13"; //0x0D

        public static final String COLONET_REQUEST = "14"; //0x0E

        public static final String CORONET_RESPONSE = "15"; //0x0F

        //Use BATTERY to request battery level

        public static final String BATTERY = "56"; //0x38

        //MOTORS

        public static final String MOTORS_INIT = "23"; //0x17

        public static final String MOTOR1_SET = "24"; //0x18

        public static final String MOTOR2_SET = "25"; //0x19

        public static final String MOTORS_OFF = "26"; //0x1A

        public static final String MOVE = "27"; //0x1B

        public static final String MOVE_AVOID = "28"; //0x1C

        //BUZZER

        public static final String BUZZER_INIT = "0"; //0x00

        public static final String BUZZER_SET_VAL = "1"; //0x01

        public static final String BUZZER_SET_FREQ = "2"; //0x02

        public static final String BUZZER_CHIRP = "3"; //0x03

        public static final String BUZZER_OFF = "4"; //0x04

        //ORB

        public static final String ORB_INIT = "12"; //0x0C

        public static final String ORB_SET = "13"; //0x0D

        public static final String ORB_SET_COLOR = "14"; //0x0E

        public static final String ORB_DISABLE = "15"; //0x0F

        public static final String ORB_ENABLE = "16"; //0x10

        public static final String ORB_SET_DIO = "17"; //0x11

        public static final String LED_INIT = "18"; //0x12

        public static final String LED_USER = "19"; //0x13

        public static final String ORB_SET_NUM_NS = "20"; //0x14

        public static final String ORB_SET_NUM = "21"; //0x15

        public static final String ORB_SEND = "22"; //0x16

        Socket socket;

        OutputStreamWriter out;

        BufferedReader reader;

        JTextArea log;

        /*

        *        FUNCTION IMPLEMENTATIONS

        */

        public ColonetServerInterface (JTextArea log) {

                this.log = log;

        }

        public Socket getSocket () {

                return socket;

        }

        public OutputStreamWriter getOutputStreamWriter () {

                return out;

        }

        public BufferedReader getBufferedReader () {

                return reader;

        }

        public boolean isReady () {

                if (socket == null || out == null || reader == null) return false;

                if (!socket.isConnected() || socket.isClosed() || socket.isInputShutdown() || socket.isOutputShutdown()) return false;

                return true;

        }

        public boolean isInputReady () {

                try {

                        if (reader.ready()) return true;

                } catch (Exception e) {

                        return false;

                }

                return false;

        }

        public String getLine () {

                if (this.isReady()) {

                        try {

                                return reader.readLine();

                        } catch (IOException e) {

                                return null;

                        }

                } else {

                  return null;

                }

        }

        /**

         * Create socket connection to Colonet server.

         * If successful, start threads for loading the webcam image and listening for incoming data.

         */

        public void connect (String strHost, String strPort) {

                //make sure hostname and port are valid

                if (strHost.equals("") || strPort.equals("")) {

                        err("Please enter a hostname and port.");

                        return;

                }

                int port = 0;

                try {

                        port = Integer.parseInt(strPort);

                } catch (Exception e) {

                        err("Invalid port");

                        return;

                }

                //make sure we aren't already connected. if so, disconnect first.

                if (socket != null && socket.isConnected()) {

                        try {

                                out.close();

                                socket.close();

                        } catch (IOException e) {

                                log.append("Error closing socket. Reconnecting...\n");

                        }

                }

                try {

                        log.append("Attempting to connect to " + strHost + "\n");

                        socket = new Socket(strHost, port);

                } catch (UnknownHostException e) {

                        log.append("Unknown host exception.\n");

                        err("Unknown Host Exception");

                        return;

                } catch (IOException e) {

                        log.append("IO Exception.\n");

                        err("IO Exception");

                        return;

                } catch (java.security.AccessControlException e) {

                        log.append("Access Control Exception.\n");

                        err("Permission denied by java.security.AccessControlException.\n\nYou may only connect to the server from which this applet was loaded.");

                        return;

                }

                if (socket == null || !socket.isConnected()) {

                        log.append("Connection is not ready. Try connecting again.");

                        return;

                }

                log.append("Connected to " + strPort + " on port " + port + "\n");

                try {

                        out = new OutputStreamWriter(socket.getOutputStream());

                        reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                } catch (IOException e) {

                        warn("Could not get transfer streams from socket connection.");

                }

        }

        /**

         * Sends a command code to the colonet server so that it can be redirected to one or more robots.

         * Assembles the given string into a packet and sends a full command string to the colonet server.

         * The string sent from here should be the correct form for sending directly to the robot.

         */

        public void sendData (String s, String robotNumber) {

                //make sure we can send

                if (!this.isReady()) {

                        warn("There was a problem with the connection. Data could not be sent.\nMake sure you are connected and try sending the command again.");

                        return;

                }

                //create packet

                String packet;

                packet = ColonetServerInterface.SEND_TO_ROBOT;

                packet += " " + robotNumber;

                packet += " " + ColonetServerInterface.COLONET_COMMAND;

                packet += " " + s;  //add  the command code here

                packet += "\n";

                //send packet

                try {

      log.append("Sending: " + packet);

                        out.write(packet);

                        out.flush();

                } catch (IOException e) {

                        log.append("Could not send data.\n");

    }

        }

        /**

         * Sends a request to the colonet server so that it can be redirected to one or more robots.

         * Assembles the given string into a packet and sends a full command string to the colonet server.

         * The string sent from here should be the correct form for sending directly to the robot.

         * @param s The request code to be sent

         * @see #sendData(String)

         */

        public void sendRequest (String s, String robotNumber) {

                //make sure we can send

                if (!this.isReady()) {

                        warn("There was a problem with the connection. Data could not be sent.\nMake sure you are connected and try sending the command again.");

                        return;

                }

                //get robot code to send to.

                /*

                if (cmbRobotNumber.getSelectedIndex() == 0)

                        robotNumber = ColonetServerInterface.GLOBAL_DEST;

                else

                        robotNumber = ( cmbRobotNumber.getSelectedIndex() - 1 ) + "";

                */

                //create packet

                String packet;

                packet = ColonetServerInterface.REQUEST_FROM_ROBOT;

                packet += " " + robotNumber;

                packet += " " + ColonetServerInterface.COLONET_REQUEST;

                packet += " " + s;  //add  the command code here

                packet += "\n";

                //send packet

                try {

                        Thread.sleep(200);  //paue to be safe

                        out.write(packet);

                        out.flush();

                        log.append("Sent: " + packet);

                } catch (IOException e) {

                        log.append("Could not send data.\n");

                } catch (InterruptedException e) {

                        log.append("Thread InterruptedException in sendData\n");

                }

        }

        /**

         * Display informational message box on the screen. Used for casual communicaton to the user.

         * @param text Text to display

         */

        public void msg (String text) {

                JOptionPane.showMessageDialog(null, text, "Colonet", JOptionPane.INFORMATION_MESSAGE);

        }

        /**

         * Display warning message box on the screen. Used for minor alerts or exceptions.

         * @param text Text to display

         */

        public void warn (String text) {

                JOptionPane.showMessageDialog(null, text, "Colonet", JOptionPane.WARNING_MESSAGE);

        }

        /**

         * Display error message box on the screen. Used for major errors or exceptions in the program.

         * @param text Text to display

         */

        public void err (String text) {

                JOptionPane.showMessageDialog(null, text, "Colonet", JOptionPane.ERROR_MESSAGE);

        }

}