TcpConnectionListener.cs

using System;
using System.Net.Sockets;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
 
namespace OSDP.Net.Connections;

public class TcpConnectionListener : OsdpConnectionListener
{
    private readonly TcpListener _listener;

    public TcpConnectionListener(
        int portNumber, int baudRate, ILoggerFactory loggerFactory = null) : base(baudRate, loggerFactory)
    {
        _listener = TcpListener.Create(portNumber);
    }

    public override Task Start(Func<IOsdpConnection, Task> newConnectionHandler)
    {
        if (IsRunning) return Task.CompletedTask;
 
        IsRunning = true;
        _listener.Start();
 
        Logger?.LogInformation("TCP listener started on {Endpoint} for incoming OSDP connections", _listener.LocalEndpoint.ToString());
 
        Task.Run(async () =>
        {
            while (IsRunning)
            {
                try
                {
                    var client = await _listener.AcceptTcpClientAsync();
                    Logger?.LogDebug("Accepted TCP connection from {RemoteEndpoint}", client.Client.RemoteEndPoint?.ToString());
 
                    var connection = new TcpOsdpConnection(client, BaudRate, LoggerFactory);
                    var task = newConnectionHandler(connection);
                    RegisterConnection(connection, task);
                }
                catch (ObjectDisposedException)
                {
                    // Expected when stopping the listener
                    break;
                }
                catch (Exception ex)
                {
                    Logger?.LogError(ex, "Error accepting TCP connection");
                }
            }
        });
 
        return Task.CompletedTask;
    }

    public override Task Stop()
    {
        IsRunning = false;
        _listener.Stop();
        Logger?.LogInformation("TCP listener stopped");
        return base.Stop();
    }
}