Subversion Repositories present

package pl.com.kgajewski.serialcomm.gui;

import gnu.io.CommPort;

import gnu.io.CommPortIdentifier;

import gnu.io.PortInUseException;

import gnu.io.SerialPort;

import gnu.io.SerialPortEvent;

import gnu.io.SerialPortEventListener;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.math.BigInteger;

import java.util.Enumeration;

import java.util.HashMap;

import java.util.TooManyListenersException;

import org.apache.commons.lang3.ArrayUtils;

import org.apache.commons.lang3.StringUtils;

import org.eclipse.swt.graphics.Color;

public class Communication implements SerialPortEventListener {

        //passed from main GUI

    Window window = null;

        // just a boolean flag that i use for enabling

        // and disabling buttons depending on whether the program

        // is connected to a serial port or not

        private boolean bConnected = false;

        // the timeout value for connecting with the port

        final static int TIMEOUT = 2000;

        // for containing the ports that will be found

        private Enumeration<CommPortIdentifier> ports = null;

        // map the port names to CommPortIdentifiers

        private HashMap<String, CommPortIdentifier> portMap = new HashMap<String, CommPortIdentifier>();

        // this is the object that contains the opened port

        private CommPortIdentifier selectedPortIdentifier = null;

        private SerialPort serialPort = null;

        // input and output streams for sending and receiving data

        private InputStream input = null;

        private OutputStream output = null;

        public Communication(Window window) {

                this.window = window;

        }

        // a string for recording what goes on in the program

        // this string is written to the GUI

        String logText = "";

        // search for all the serial ports

        // pre style="font-size: 11px;": none

        // post: adds all the found ports to a combo box on the GUI

        public void searchForPorts() {

                ports = CommPortIdentifier.getPortIdentifiers();

                while (ports.hasMoreElements()) {

                        CommPortIdentifier curPort = (CommPortIdentifier) ports

                                        .nextElement();

                        // get only serial ports

                        if (curPort.getPortType() == CommPortIdentifier.PORT_SERIAL) {

                                window.combo.add(curPort.getName());

                                portMap.put(curPort.getName(), curPort);

                        }

                }

        }

        // connect to the selected port in the combo box

        // pre style="font-size: 11px;": ports are already found by using the

        // searchForPorts

        // method

        // post: the connected comm port is stored in commPort, otherwise,

        // an exception is generated

        public void connect() {

                if (window.combo.getSelectionIndex() >= 0) {

                        String selectedPort = (String) window.combo.getItem(window.combo.getSelectionIndex());

                        selectedPortIdentifier = (CommPortIdentifier) portMap

                                        .get(selectedPort);

                        CommPort commPort = null;

                        try {

                                // the method below returns an object of type CommPort

                                commPort = selectedPortIdentifier.open("pl.com.kgajewski.cerialcomm",

                                                TIMEOUT);

                                // the CommPort object can be casted to a SerialPort object

                                serialPort = (SerialPort) commPort;

                                serialPort.setSerialPortParams(115200,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_ODD);

                                // for controlling GUI elements

                                setConnected(true);

                                // logging

                                logText = selectedPort + " opened successfully.";

                                window.text.setForeground(new Color(window.shell.getDisplay(), 0, 0, 0));

                                window.appendText(logText + "\n");

                                // CODE ON SETTING BAUD RATE ETC OMITTED

                                // XBEE PAIR ASSUMED TO HAVE SAME SETTINGS ALREADY

                                // enables the controls on the GUI if a successful connection is

                                // made

                                window.toggleControls();

                        } catch (PortInUseException e) {

                                logText = selectedPort + " is in use. (" + e.toString() + ")";

                                window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

                                window.appendText(logText + "\n");

                        } catch (Exception e) {

                                logText = "Failed to open " + selectedPort + "(" + e.toString()

                                                + ")";

                                window.appendText(logText + "\n");

                                window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

                        }

                }

        }

        // open the input and output streams

        // pre style="font-size: 11px;": an open port

        // post: initialized input and output streams for use to communicate data

        public boolean initIOStream() {

                // return value for whether opening the streams is successful or not

                boolean successful = false;

                try {

                        //

                        input = serialPort.getInputStream();

                        output = serialPort.getOutputStream();

                        successful = true;

                        return successful;

                } catch (IOException e) {

                        logText = "I/O Streams failed to open. (" + e.toString() + ")";

                        window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

                        window.appendText(logText + "\n");

                        return successful;

                }

        }

        // starts the event listener that knows whenever data is available to be

        // read

        // pre style="font-size: 11px;": an open serial port

        // post: an event listener for the serial port that knows when data is

        // received

        public void initListener() {

                try {

                        serialPort.addEventListener(this);

                        serialPort.notifyOnDataAvailable(true);

                } catch (TooManyListenersException e) {

                        logText = "Too many listeners. (" + e.toString() + ")";

                        window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

                        window.appendText(logText + "\n");

                }

        }

        //disconnect the serial port

    //pre style="font-size: 11px;": an open serial port

    //post: closed serial port

    public void disconnect()

    {

        //close the serial port

        try

        {

            serialPort.removeEventListener();

            serialPort.close();

            input.close();

            output.close();

            setConnected(false);

            window.toggleControls();

            logText = "Disconnected.";

            window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

            window.appendText(logText + "\n");

        }

        catch (Exception e)

        {

            logText = "Failed to close " + serialPort.getName()

                              + "(" + e.toString() + ")";

            window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

            window.appendText(logText + "\n");

        }

    }

    //what happens when data is received

    //pre style="font-size: 11px;": serial event is triggered

    //post: processing on the data it reads

    public void serialEvent(SerialPortEvent evt) {

        if (evt.getEventType() == SerialPortEvent.DATA_AVAILABLE)

        {

            try

            {

                byte [] buffer = new byte[10];

                int n = input.read(buffer);

                if (n > 0)

                {

                        if (n == 1) {

                                BigInteger command = new BigInteger(new byte []{0, buffer[0]});

                                final String s = "Command = " + command.toString(16) + "\n";

                                window.appendText(s);

                        } else {

                                buffer = ArrayUtils.subarray(buffer, 0, buffer.length - 2);

                                buffer = ArrayUtils.add(buffer, (byte)0);

                                ArrayUtils.reverse(buffer);

                                BigInteger data = new BigInteger(buffer);

                                window.appendText(data.toString(16) + "\n");

                        }

                }

                else

                {

                    window.appendText("\n");

                }

            }

            catch (Exception e)

            {

                logText = "Failed to read data. (" + e.toString() + ")";

                window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

                window.appendText(logText + "\n");

            }

        }

    }

    //method that can be called to send data

    //pre style="font-size: 11px;": open serial port

    //post: data sent to the other device

    public void writeData(String str)

    {

        try

        {

                for (int i = str.length()-1; i > 0; i -= 2) {

                        String s = str.substring(i-1, i+1);

                        byte b = (byte)(Integer.parseInt(s, 16) & 0xFF);

                        output.write(b);

                        Thread.sleep(1);

                }

        }

        catch (Exception e)

        {

            logText = "Failed to write data. (" + e.toString() + ")";

            window.text.setForeground(new Color(window.shell.getDisplay(), 255, 0, 0));

            window.appendText(logText + "\n");

        }

    }

    final public boolean getConnected()

    {

        return bConnected;

    }

    public void setConnected(boolean bConnected)

    {

        this.bConnected = bConnected;

    }

}