Connector.cs

using System;
using System.Collections.Generic;
using System.IO.Ports;

namespace SerialToNetDotnet
{
    public enum TerminalType
    {
        raw,
        telnet,
        unknown
    }

    public class NetServerConfig
    {
        public TerminalType terminalType { get; set; }
        public EchoType echoType { get; set; }
        public List<char> skipChars { get; set; }
        public int tcpPort { get; set; }
    }

    class Connector
    {
        public class Config
        {
            public NetServerConfig netCfg { get; set; }
            public int baudRate { get; set; }
            public string portName { get; set; }
            public int databits { get; set; }
            public int stopbits { get; set; }
            public Parity parity { get; set; }
        }

        public readonly Config m_config;
        private readonly Server m_server;
        private readonly SerialPort m_serial;
        public bool IsStarted { get; private set; }

        public Connector(Config config)
        {
            m_config = config;
            m_server = new Server(m_config.netCfg, m_config.portName);
            m_server.DataReceived += NetDataReceivedHandler;
            m_server.OnFirstClientConnected += FirstClientConnectedHandler;
            m_server.OnLastClientDisconnected += LastClientDisconnectedHandler;

            m_serial = new SerialPort(m_config.portName,
                                      m_config.baudRate,
                                      m_config.parity,
                                      m_config.databits,
                                      stopBitsIntToEnum(m_config.stopbits));
            IsStarted = false;
            m_serial.Handshake = Handshake.None;
            m_serial.DataReceived += SerialDataReceivedHandler;
        }


        public void Start()
        {
            try
            {
                m_server.Start();
            }
            catch
            {
                throw new Exception("Server cannot be started");
            }

            IsStarted = true;
        }

        private void NetDataReceivedHandler(byte[] buffer, int numBytes)
        {
            m_serial.Write(buffer, 0, numBytes);
        }

        private void SerialDataReceivedHandler(object sender, SerialDataReceivedEventArgs e)
        {
            SerialPort sp = (SerialPort)sender;
            int numRx = sp.BytesToRead;
            byte[] rxBuf = new byte[numRx];
            sp.Read(rxBuf, 0, numRx);

            m_server.SendBytesToAll(rxBuf);
        }

        private void FirstClientConnectedHandler()
        {
            try
            {
                m_serial.Open();
            }
            catch (Exception e)
            {
                Console.WriteLine("Failed to open port: {0}, {1}", m_config.portName, e.ToString());
                throw;
            }

            Console.WriteLine("Serial port " + m_config.portName + " opened");
        }

        private void LastClientDisconnectedHandler()
        {
            if (m_serial.IsOpen)
            {
                m_serial.Close();
                Console.WriteLine("Serial port " + m_config.portName + " closed");
            }
        }


        public override string ToString()
        {
            string res = string.Format(
                "Serial {0}, is opened: {1}, type: {2}. Server on port {3}, clients:\r\n",
                m_config.portName,
                m_serial.IsOpen,
                m_config.netCfg.terminalType.ToString(),
                m_config.netCfg.tcpPort);

            res += m_server.getClientsString();

            return res;
        }


        internal static StopBits stopBitsIntToEnum(int num)
        {
            switch (num)
            {
                case 0:
                    return StopBits.None;
                case 1:
                    return StopBits.One;
                case 2:
                    return StopBits.Two;
                default:
                    throw new ArgumentException(String.Format("Cannot convert {0} to enum StopBits", num));
            }
        }
    }
}