package com.intelligt.modbus.jlibmodbus.serial;

import com.intelligt.modbus.jlibmodbus.Modbus;
import com.intelligt.modbus.jlibmodbus.net.stream.base.ModbusInputStream;
import com.intelligt.modbus.jlibmodbus.net.stream.base.ModbusOutputStream;

import java.io.IOException;

/*
 * Copyright (C) 2016 "Invertor" Factory", JSC
 * [http://www.sbp-invertor.ru]
 *
 * This file is part of JLibModbus.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *  http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * Authors: Vladislav Y. Kochedykov, software engineer.
 * email: vladislav.kochedykov@gmail.com
 */

public abstract class SerialPort {

    final private SerialParameters serialParameters;
    private int readTimeout = Modbus.MAX_RESPONSE_TIMEOUT;

    public SerialPort(SerialParameters sp) {
        this.serialParameters = sp;
    }

    public SerialParameters getSerialParameters() {
        return serialParameters;
    }

    public int getReadTimeout() {
        return readTimeout;
    }

    public void setReadTimeout(int readTimeout) {
        this.readTimeout = readTimeout;
    }

    public ModbusOutputStream getOutputStream() {
        return new ModbusOutputStream() {
            final private SerialPort serial = SerialPort.this;

            @Override
            public void flush() throws IOException {
                try {
                    if (serial.isOpened()) {
                        serial.write(toByteArray());
                    }
                } finally {
                    super.flush();
                }
            }
        };
    }

    public ModbusInputStream getInputStream() {

        return new ModbusInputStream() {

            final private SerialPort serial = SerialPort.this;

            @Override
            public int read() throws IOException {
                return serial.read() & 0xff;
            }

            @Override
            public int read(byte[] b, int off, int len) throws IOException {
                int size = 0;
                while (size < len) {
                    size += serial.read(b, off + size, len - size);
                }
                return size;
            }

            @Override
            public void setReadTimeout(int readTimeout) {
                serial.setReadTimeout(readTimeout);
            }
        };
    }

    abstract public void write(int b) throws IOException;

    abstract public void write(byte[] bytes) throws IOException;

    abstract public void open() throws SerialPortException;

    abstract public int read() throws IOException;

    abstract public int read(byte[] b, int off, int len) throws IOException;

    abstract public void close();

    abstract public boolean isOpened();

    public enum Parity {
        NONE(0),
        ODD(1),
        EVEN(2),
        MARK(3),
        SPACE(4);

        private final int value;

        Parity(int value) {
            this.value = value;
        }

        static public Parity getParity(Integer value) {
            for (Parity par : Parity.values()) {
                if (par.value == value) {
                    return par;
                }
            }
            throw new IllegalArgumentException("Illegal parity value:" + value);
        }

        public int getValue() {
            return value;
        }

        @Override
        public String toString() {
            return String.valueOf(value);
        }
    }

    public enum BaudRate {
        BAUD_RATE_4800(4800),
        BAUD_RATE_9600(9600),
        BAUD_RATE_14400(14400),
        BAUD_RATE_19200(19200),
        BAUD_RATE_38400(38400),
        BAUD_RATE_57600(57600),
        BAUD_RATE_115200(115200);

        private final int value;

        BaudRate(int value) {
            this.value = value;
        }

        static public BaudRate getBaudRate(int value) {
            for (BaudRate br : BaudRate.values()) {
                if (br.value == value) {
                    return br;
                }
            }
            throw new IllegalArgumentException("Illegal baud rate value:" + value);
        }

        public int getValue() {
            return value;
        }

        @Override
        public String toString() {
            return String.valueOf(value);
        }
    }
}