Lab Pull Request (Muravets)

.github/dependabot.yml

@@ -0,0 +1,6 @@
+version: 2
+updates:
+  - package-ecosystem: "nuget"
+    directory: "/"
+    schedule:
+      interval: "weekly"

.github/workflows/sonarcloud.yml

@@ -56,8 +56,8 @@ jobs:
           dotnet tool install --global dotnet-sonarscanner
           echo "$env:USERPROFILE\.dotnet\tools" >> $env:GITHUB_PATH
           dotnet sonarscanner begin `
-          /k:"ppanchen_NetSdrClient" `
-          /o:"ppanchen" `
+          /k:"euviola_NetSdrClient" `
+          /o:"euviola"  `
           /d:sonar.token="${{ secrets.SONAR_TOKEN }}" `
           /d:sonar.cs.opencover.reportsPaths="**/coverage.xml" `
           /d:sonar.cpd.cs.minimumTokens=40 `
@@ -70,14 +70,14 @@ jobs:
         run: dotnet restore NetSdrClient.sln
       - name: Build
         run: dotnet build NetSdrClient.sln -c Release --no-restore
-      #- name: Tests with coverage (OpenCover)
-      #  run: |
-      #    dotnet test NetSdrClientAppTests/NetSdrClientAppTests.csproj -c Release --no-build `
-      #      /p:CollectCoverage=true `
-      #      /p:CoverletOutput=TestResults/coverage.xml `
-      #      /p:CoverletOutputFormat=opencover
-      #  shell: pwsh
+      - name: Tests with coverage (OpenCover)
+        run: |
+          dotnet test NetSdrClientAppTests/NetSdrClientAppTests.csproj -c Release --no-build `
+            /p:CollectCoverage=true `
+            /p:CoverletOutput=TestResults/coverage.xml `
+            /p:CoverletOutputFormat=opencover
+        shell: pwsh
       # 3) END: SonarScanner
       - name: SonarScanner End
         run: dotnet sonarscanner end /d:sonar.token="${{ secrets.SONAR_TOKEN }}"
-        shell: pwsh
+        shell: pwsh

EchoTcpServer/EchoClientHandler.cs

@@ -0,0 +1,17 @@
+using System.Net.Sockets;
+
+public class EchoClientHandler : IClientHandler
+{
+    public async Task HandleAsync(TcpClient client, CancellationToken token)
+    {
+        using var stream = client.GetStream();
+        byte[] buffer = new byte[8192];
+
+        int bytesRead;
+        while (!token.IsCancellationRequested &&
+               (bytesRead = await stream.ReadAsync(buffer, token)) > 0)
+        {
+            await stream.WriteAsync(buffer.AsMemory(0, bytesRead), token);
+        }
+    }
+}

EchoTcpServer/EchoServer.cs

@@ -0,0 +1,49 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace EchoServer
+{
+    public class EchoServer
+    {
+        private readonly ITcpListener _listener;
+        private readonly IClientHandler _handler;
+        private readonly CancellationTokenSource _cancellationTokenSource;
+
+        public EchoServer(ITcpListener listener, IClientHandler handler)
+        {
+            _listener = listener;
+            _handler = handler;
+            _cancellationTokenSource = new CancellationTokenSource();
+        }
+
+        public async Task StartAsync()
+        {
+            _listener.Start();
+
+            while (!_cancellationTokenSource.Token.IsCancellationRequested)
+            {
+                TcpClient client;
+                try
+                {
+                    client = await _listener.AcceptTcpClientAsync();
+                }
+                catch (ObjectDisposedException)
+                {
+                    break;
+                }
+
+                _ = Task.Run(() => _handler.HandleAsync(client, _cancellationTokenSource.Token));
+            }
+        }
+
+        public void Stop()
+        {
+            _cancellationTokenSource.Cancel();
+            _listener.Stop();
+        }
+    }
+}

EchoTcpServer/EchoServer.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.10.0" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
+    <PackageReference Include="NUnit" Version="3.14.0" />
+    <PackageReference Include="NUnit3TestAdapter" Version="4.5.0" />
+    <PackageReference Include="NSubstitute" Version="5.0.0" />
+    <PackageReference Include="SharpZipLib" Version="1.3.3" />
+  </ItemGroup>
+
+</Project>

EchoTcpServer/EchoServerTests.cs

@@ -0,0 +1,52 @@
+using System.Net.Sockets;
+using System.Threading;
+using System.Threading.Tasks;
+using NSubstitute;
+using NUnit.Framework;
+
+namespace EchoServerTests
+{
+    public class EchoServerTests
+    {
+        [Test]
+        public async Task StartAsync_StartsListener_AndStopsAfterCancel()
+        {
+            var listener = Substitute.For<ITcpListener>();
+
+            listener.AcceptTcpClientAsync().Returns(async _ =>
+            {
+                await Task.Delay(Timeout.Infinite);
+                return new TcpClient();
+            });
+
+            var handler = Substitute.For<IClientHandler>();
+
+            var server = new EchoServer.EchoServer(listener, handler);
+
+            var runTask = server.StartAsync();
+
+            await Task.Delay(50);
+
+            listener.Received(1).Start();
+
+            server.Stop();
+
+            await Task.Delay(50);
+
+            listener.Received(1).Stop();
+        }
+
+        [Test]
+        public void Stop_Should_Stop_Listener_Immediately()
+        {
+            var listener = Substitute.For<ITcpListener>();
+            var handler = Substitute.For<IClientHandler>();
+
+            var server = new EchoServer.EchoServer(listener, handler);
+
+            server.Stop();
+
+            listener.Received(1).Stop();
+        }
+    }
+}

EchoTcpServer/IClientHandler.cs

@@ -0,0 +1,6 @@
+using System.Net.Sockets;
+
+public interface IClientHandler
+{
+    Task HandleAsync(TcpClient client, CancellationToken token);
+}

EchoTcpServer/ITcpListener.cs

@@ -0,0 +1,9 @@
+using System.Net.Sockets;
+using System.Net;
+
+public interface ITcpListener
+{
+    void Start();
+    void Stop();
+    Task<TcpClient> AcceptTcpClientAsync();
+}

EchoTcpServer/Program.cs

@@ -0,0 +1,20 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using EchoServer;
+
+public static class Program
+{
+    public static async Task Main(string[] args)
+    {
+        var listener = new TcpListenerWrapper(IPAddress.Any, 5000);
+        var handler = new EchoClientHandler();
+
+        var server = new EchoServer.EchoServer(listener, handler);
+
+        await server.StartAsync();
+    }
+}

EchoTcpServer/TcpListenerWrapper.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+
+public class TcpListenerWrapper : ITcpListener
+{
+    private readonly TcpListener _listener;
+
+    public TcpListenerWrapper(IPAddress address, int port)
+    {
+        _listener = new TcpListener(address, port);
+    }
+
+    public void Start() => _listener.Start();
+    public void Stop() => _listener.Stop();
+    public Task<TcpClient> AcceptTcpClientAsync() => _listener.AcceptTcpClientAsync();
+}