TcpClientOsdpConnection.cs

using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;
 
namespace OSDP.Net.Connections
{
    public class TcpClientOsdpConnection : OsdpConnection
    {
        private readonly int _portNumber;
        private readonly string _server;
        private TcpClient _tcpClient;

        public TcpClientOsdpConnection(string server, int portNumber, int baudRate) : base(baudRate)
        {
            _tcpClient = new TcpClient();
            _server = server;
            _portNumber = portNumber;
        }

        public override bool IsOpen
        {
            get
            {
                var tcpClient = _tcpClient;
                return tcpClient?.Connected ?? false;
            }
        }

        public override async Task Open()
        {
            await Close();
 
            _tcpClient = new TcpClient {NoDelay = true};
            await _tcpClient.ConnectAsync(_server, _portNumber);
        }

        public override Task Close()
        {
            var tcpClient = _tcpClient;
            _tcpClient = null;
            if (_tcpClient?.Connected ?? false) tcpClient?.GetStream().Close();
            tcpClient?.Close();
            return Task.CompletedTask;
        }

        public override async Task WriteAsync(byte[] buffer)
        {
            if (!IsOpen) await Open();
 
            var tcpClient = _tcpClient;
 
            if (tcpClient != null)
            {
                await tcpClient.GetStream().WriteAsync(buffer, 0, buffer.Length).ConfigureAwait(false);
            }
        }

        public override async Task<int> ReadAsync(byte[] buffer, CancellationToken token)
        {
            var tcpClient = _tcpClient;
            if (tcpClient != null)
            {
                return await tcpClient.GetStream().ReadAsync(buffer, 0, buffer.Length, token).ConfigureAwait(false);
            }
 
            return 0;
        }

        public override string ToString()
        {
            return $"{_server}:{_portNumber}";
        }
    }
}