Subversion Repositories mod_mult_exp

package webexponentiator.serialcomm;
 
import com.fazecast.jSerialComm.SerialPort;
import com.fazecast.jSerialComm.SerialPortDataListener;
import com.fazecast.jSerialComm.SerialPortEvent;
 
import java.io.InputStream;
import java.io.OutputStream;
import java.math.BigInteger;
import java.util.HashMap;
 
import org.apache.commons.lang3.ArrayUtils;
import org.eclipse.swt.graphics.Color;
 
public class Communication implements SerialPortDataListener {
 
	//passed from main GUI
    Window window = null;
    String selectedPort = "COM3";
	// 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 SerialPort[] ports = null;
	// map the port names to CommPortIdentifiers
	private HashMap<String, SerialPort> portMap = new HashMap<String, SerialPort>();
 
	// this is the object that contains the opened port
	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 = SerialPort.getCommPorts();
 
		for (SerialPort port:ports) {
			String portName = port.getDescriptivePortName();
			if (portName.contains("COM3")) {
				selectedPort = portName;
			}
			// get only serial ports
			window.combo.add(portName);
			portMap.put(portName, port);
		}
	}
 
	// 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) {
			selectedPort = (String) window.combo.getItem(window.combo.getSelectionIndex());
			serialPort = (SerialPort) portMap.get(selectedPort);
			serialPort.setBaudRate(115200);
			serialPort.setNumDataBits(8);
			serialPort.setNumStopBits(1);
			serialPort.setParity(SerialPort.ODD_PARITY);
 
				// the method below returns an object of type CommPort
				setConnected(serialPort.openPort());
				if (getConnected()) {
					// logging
					logText = selectedPort + " opened successfully.";
					window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 0, 0, 0));
					window.appendText(logText + "\n");
					window.toggleControls();
				} else {
					logText = selectedPort + " was not opened";
					window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 255, 0, 0));
					window.appendText(logText + "\n");
				}
		}
	}
	// 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;
 
		input = serialPort.getInputStream();
		output = serialPort.getOutputStream();
 
		successful = true;
		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() {
			serialPort.addDataListener(this);
	}
 
	//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.removeDataListener();
			input.close();
			output.close();
			serialPort.closePort();
			setConnected(false);
            window.toggleControls();
 
            logText = "Disconnected.";
            window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 255, 0, 0));
            window.appendText(logText + "\n");
 
			logText = "Disconnected.";
		} catch (Exception e) {
            logText = "Failed to close " + serialPort.getDescriptivePortName()
            + "(" + e.toString() + ")";
            window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 255, 0, 0));
			window.appendText(logText + "\n");
		}
    }
 
 
	@Override
	public int getListeningEvents() {
		return SerialPort.LISTENING_EVENT_DATA_AVAILABLE;
	}
 
    //what happens when data is received
    //pre style="font-size: 11px;": serial event is triggered
    //post: processing on the data it reads
	@Override
    public void serialEvent(SerialPortEvent evt) {
		if (evt.getEventType() != SerialPort.LISTENING_EVENT_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";
						//TODO Something for retrieve data
						//window.appendText(s);
					} else {
						ArrayUtils.reverse(buffer);
						BigInteger data = new BigInteger(buffer);
//						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(10) + "\n");
					}
					window.appendText("\n");
				}
			} catch (Exception e) {
                logText = "Failed to read data. (" + e.toString() + ")";
                window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 255, 0, 0));
                window.appendText(logText + "\n");
			}
		}
    }
 
	public String readData() {
		try {
			byte[] buffer = new byte[65];
			int n = input.read(buffer);
			if (n > 0) {
				if (n == 1) {
					BigInteger command = new BigInteger(new byte[] { 0,
							buffer[0] });
					String s = "Command = " + command.toString(16);
					return s;
				} else {
					buffer = ArrayUtils.subarray(buffer, 0, buffer.length - 1);
            		buffer = ArrayUtils.add(buffer, (byte)0);
            		ArrayUtils.reverse(buffer);
            		BigInteger data = new BigInteger(buffer);
					return data.toString(16);
				}
			}
		} catch (Exception e) {
			window.appendText("Failed to read data. (" + e.toString() + ")");
		}
		return null;
	}
 
    //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
        {
        	BigInteger bi = new BigInteger(str, 2);
        	byte [] b = bi.toByteArray();
        	if (b.length == 2) {
        		output.write(b[1]);
        	} else {
        		output.write(b);
        	}
        	Thread.sleep(50);
        	//ArrayUtils.reverse(b);
        	/*String [] data = str.split(" ");
        	byte [] b = new byte [data.length]; 
        	for (int i = 0; i < data.length; i++) {
        		Byte toSend = Byte.decode(data[i]);
        		b[i] = toSend;
 
        	}
        	ArrayUtils.reverse(b);
        	for (int i = 0; i < b.length; i++) {
        		output.write(b[i]);
        		Thread.sleep(1);
        	}*/
        	//b = Arrays.copyOfRange(b, 1, b.length);
        	//ArrayUtils.reverse(b);
        	//for (int i = 0; i < b.length; i++) {
        	//	output.write(b[i]);
        	//	Thread.sleep(10);
        	//}
        	//output.flush();
        }
        catch (Exception e)
        {
            logText = "Failed to write data. (" + e.toString() + ")";
            window.text.setForeground(new Color(window.shlPcExponentiator.getDisplay(), 255, 0, 0));
            window.appendText(logText + "\n");
        }
    }
 
    final public boolean getConnected()
    {
        return bConnected;
    }
 
    public void setConnected(boolean bConnected)
    {
        this.bConnected = bConnected;
    }
 
 
}