RXTXPortWrapper.java

package kernel.serial_ports;

import gnu.io.PortInUseException;
import gnu.io.RXTXPort;
import gnu.io.UnsupportedCommOperationException;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

final class RXTXPortWrapper implements SerialPort, PortCommunicator,
        PortConfiguration {

    private RXTXPort port;

    private final String portName;

    private boolean isPortOpen;

    RXTXPortWrapper(String portName){
        this.portName = portName;
    }

    @Override public PortCommunicator getCommunicator(){
        return this;
    }

    @Override public InputStream getInputStream() throws IOException {
        assertPortOpen();
        return this.port.getInputStream();
    }

    @Override public OutputStream getOutputStream() throws IOException {
        assertPortOpen();
        return this.port.getOutputStream();
    }

    @Override public PortConfiguration getConfig(){
        return this;
    }

    @Override public int getBaudRate(){
        return this.port.getBaudRate();
    }

    @Override public int getStopBits(){
        return this.port.getStopBits();
    }

    @Override public int getDataBits(){
        return this.port.getDataBits();
    }

    @Override public int getParityBits(){
        return this.port.getParity();
    }

    @Override public void setConfig(PortConfiguration newConfig) throws
            UnsupportedCommOperationException {
        this.port.setSerialPortParams(
            newConfig.getBaudRate(), newConfig.getDataBits(),
            newConfig.getStopBits(), newConfig.getParityBits()
        );
    }

    @Override public void open() throws PortInUseException {
        if (!this.isPortOpen){
            this.port = new RXTXPort(this.portName);
            this.isPortOpen = true;
        }
    }

    @Override public boolean isPortOpen(){
        return this.isPortOpen;
    }

    @Override public void close(){
        if (this.isPortOpen){
            this.port.close();
            this.isPortOpen = false;
        }
    }

    private void assertPortOpen() throws IOException {
        if(!this.isPortOpen){
            throw new IOException("Attempted to access a resource that " +
                    "requires the port to be open");
        }
    }
}