MyFTP

MyFTP/MyFTP.Test/MyFTP.Test.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <TargetFramework>net6.0</TargetFramework>
+
+        <IsPackable>false</IsPackable>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.0.0" />
+        <PackageReference Include="NUnit" Version="3.13.1" />
+        <PackageReference Include="NUnit3TestAdapter" Version="3.17.0" />
+        <PackageReference Include="coverlet.collector" Version="3.0.2" />
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\MyFTPClient\MyFTPClient.csproj" />
+      <ProjectReference Include="..\MyFTPServer\MyFTPServer.csproj" />
+    </ItemGroup>
+
+</Project>

MyFTP/MyFTP.Test/MyFTPTest.cs

@@ -0,0 +1,91 @@
+namespace MyFTP.Test;
+
+using System;
+using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
+using MyFTPClient;
+using MyFTPServer;
+using NUnit.Framework;
+
+public class Tests
+{
+    private Server _server;
+    private Client _client;
+    private Stream _fileStream;
+    private CancellationToken _cancellationToken;
+
+    [SetUp]
+    public void Setup()
+    {
+        _server = new Server("127.0.0.1", 80);
+        _client = new Client("127.0.0.1", 80);
+        _fileStream = new MemoryStream();
+        _cancellationToken = new ();
+        _server.StartServer();
+        Thread.Sleep(5000);
+    }
+
+    [TearDown]
+    public void TearDown()
+    {
+        _server.StopServer();
+    }
+
+    [Test]
+    public void GetInvalidFileNameTest()
+    {
+        Assert.ThrowsAsync<FileNotFoundException>(() => _client.Get("Text.txt", _fileStream, _cancellationToken));
+    }
+
+    [Test]
+    public void ListInvalidFileNameTest()
+    {
+        Assert.ThrowsAsync<FileNotFoundException>(() => _client.Get("Text.txt", _fileStream, _cancellationToken));
+    }
+
+    [Test]
+    public async Task ListTest()
+    {
+        var data = await _client.List("../../../TestData", _cancellationToken);
+        Assert.AreEqual("../../../TestData\\Data.txt", data[0].name);
+        Assert.AreEqual(false, data[0].isDir);
+    }
+
+    [Test]
+    public async Task GetTest()
+    {
+        var destination = "../../../TestData/Data1.txt";
+        var pathForFile = "../../../TestData/Data.txt";
+        var result = File.ReadAllBytes(pathForFile);
+        using (var fstream = new FileStream(destination, FileMode.OpenOrCreate))
+        { 
+            var data = await _client.Get(pathForFile, fstream, _cancellationToken);
+            Assert.AreEqual(result.Length, data);
+        }
+
+        var result2 = File.ReadAllBytes(destination);
+        Assert.AreEqual(result, result2);
+        File.Delete(destination);
+    }
+
+    [Test]
+    public void ParallelClientConnection()
+    {
+        var clients = new Task[2];
+        for (var i = 0; i < 2; i++)
+        {
+            clients[i] = Task.Run(() =>
+            {
+                var localClient = new Client("127.0.0.1", 80);
+                var answer = localClient.List("../../../TestData", _cancellationToken).Result;
+                Assert.AreEqual("../../../TestData\\Data.txt", answer[0].name);
+            });
+        }
+
+        foreach (var request in clients)
+        {
+            request.Wait();
+        }
+    }
+}

MyFTP/MyFTP.Test/TestData/Data.txt

@@ -0,0 +1 @@
+qwerty

MyFTP/MyFTP.sln

@@ -0,0 +1,28 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyFTPClient", "MyFTPClient\MyFTPClient.csproj", "{97AFB503-9655-404C-9CE3-DB6CF51BD205}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyFTP.Test", "MyFTP.Test\MyFTP.Test.csproj", "{D4A4CBB3-3517-431E-8B0D-A71D6389E3B8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyFTPServer", "MyFTPServer\MyFTPServer.csproj", "{D6B47A97-BA0C-4B6C-9A22-3A3BB8AF6F1E}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{97AFB503-9655-404C-9CE3-DB6CF51BD205}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{97AFB503-9655-404C-9CE3-DB6CF51BD205}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{97AFB503-9655-404C-9CE3-DB6CF51BD205}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{97AFB503-9655-404C-9CE3-DB6CF51BD205}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D4A4CBB3-3517-431E-8B0D-A71D6389E3B8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D4A4CBB3-3517-431E-8B0D-A71D6389E3B8}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D4A4CBB3-3517-431E-8B0D-A71D6389E3B8}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D4A4CBB3-3517-431E-8B0D-A71D6389E3B8}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D6B47A97-BA0C-4B6C-9A22-3A3BB8AF6F1E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D6B47A97-BA0C-4B6C-9A22-3A3BB8AF6F1E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D6B47A97-BA0C-4B6C-9A22-3A3BB8AF6F1E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D6B47A97-BA0C-4B6C-9A22-3A3BB8AF6F1E}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal

MyFTP/MyFTPClient/Client.cs

@@ -0,0 +1,80 @@
+namespace MyFTPClient;
+
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Net.Sockets;
+using System.Threading;
+using System.Threading.Tasks;
+
+/// <summary>
+/// класс клиента для общения с сервером
+/// </summary>
+public class Client
+{
+    private readonly int _port;
+    private readonly string _host;
+
+    public Client(string host, int port )
+    {
+        _host = host;
+        _port = port;
+    }
+
+    /// <summary>
+    /// запрос на листинг файлов в папке по пути
+    /// </summary>
+    public async Task<(string name, bool isDir)[]> List(string path, CancellationToken cancellationToken)
+    {
+        using var client = new TcpClient();
+        await client.ConnectAsync(_host, _port, cancellationToken);
+        await using var stream = client.GetStream();
+        await using var writer = new StreamWriter(stream);
+        using var reader = new StreamReader(stream);
+        await writer.WriteLineAsync($"1 {path}");
+        await writer.FlushAsync();
+        var info = await reader.ReadLineAsync();
+        var infoArray = info.Split(' ');
+        var size = Convert.ToInt32(infoArray[0]);
+        if (size == -1)
+        {
+            throw new FileNotFoundException();
+        }
+
+        var data = new List<(string, bool)>();
+
+
+
+        for (int i = 1; i < infoArray.Length; i += 2)
+        {
+
+            var isDir = Convert.ToBoolean(infoArray[i + 1]);
+            data.Add((infoArray[i], isDir));
+        }
+
+        return data.ToArray();
+    }
+
+    /// <summary>
+    /// запрос на скачивание нужного файла
+    /// </summary>
+    public async Task<long> Get(string path, Stream fileStream, CancellationToken cancellationToken)
+    {
+        using var client = new TcpClient();
+        await client.ConnectAsync(_host, _port, cancellationToken);
+        await using var stream = client.GetStream();
+        await using var writer = new StreamWriter(stream);
+        using var reader = new StreamReader(stream);
+        await writer.WriteLineAsync($"2 {path}");
+        await writer.FlushAsync();
+        var size = Convert.ToInt32(await reader.ReadLineAsync());
+        if (size == -1)
+        {
+            throw new FileNotFoundException();
+        }
+
+        await stream.CopyToAsync(fileStream, cancellationToken);
+
+        return size;
+    }
+}

MyFTP/MyFTPClient/MyFTPClient.csproj

@@ -0,0 +1,8 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net6.0</TargetFramework>
+    </PropertyGroup>
+
+</Project>

MyFTP/MyFTPClient/Program.cs

@@ -0,0 +1,58 @@
+namespace MyFTPClient;
+
+using System.Threading;
+using System;
+using System.IO;
+using System.Threading.Tasks;
+
+public class Program
+{
+    public static async Task Main(string[] args)
+    {
+        var client = new Client(args[0], Convert.ToInt32(args[1]));
+        var token = new CancellationToken();
+        Console.WriteLine("1 - List — листинг файлов в директории на сервере\nНапример, 1 ./Test/Files\n");
+        Console.WriteLine("2 - Get — скачивание файла с сервера\n2 ./Test/Files/file1.txt\n");
+        Console.WriteLine("Введите !exit, чтобы остановить сервер\n");
+        Console.WriteLine("Введите команду:");
+        var request = Console.ReadLine().Split(' ');
+        while (request[0] != "!exit" || !token.IsCancellationRequested)
+        {
+            if (request[0] == "1" && request.Length == 2)
+            {
+                try
+                {
+                    var response = await client.List(request[1], token);
+                    Console.WriteLine(response.Length);
+                    foreach (var file in response)
+                    {
+                        Console.WriteLine($"{file.Item1} {file.Item2}");
+                    }
+                }
+                catch (FileNotFoundException)
+                {
+                    Console.WriteLine("-1");
+                }
+            }
+            else if (request[0] == "2" && request.Length == 2)
+            {
+                using var fstream = new FileStream(request[2], FileMode.OpenOrCreate);
+                try
+                {
+                    var response = await client.Get(request[1], fstream, token);
+                    Console.WriteLine(response);
+                }
+                catch (FileNotFoundException)
+                {
+                    Console.WriteLine("-1");
+                }
+            }
+            else
+            {
+                Console.WriteLine("Некорректная команда!");
+            }
+            Console.WriteLine("\nВведите команду:");
+            request = Console.ReadLine().Split(' ');
+        }
+    }
+}

MyFTP/MyFTPServer/MyFTPServer.csproj

@@ -0,0 +1,8 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net6.0</TargetFramework>
+    </PropertyGroup>
+
+</Project>

MyFTP/MyFTPServer/Program.cs

@@ -0,0 +1,33 @@
+namespace MyFTPServer;
+
+using System;
+using System.Threading.Tasks;
+
+public class Program
+{
+    public static async Task Main(string[] args)
+    {
+        if (args.Length != 2)
+        {
+            Console.WriteLine("Вы не передали параметры или передали неверные.");
+            return;
+        }
+        try
+        {
+            var server = new Server(args[0], Convert.ToInt32(args[1]));
+            var serverStop = server.StartServer();
+            Console.WriteLine("Введите !exit, чтобы остановить сервер");
+            var command = "";
+            while (command != "!exit")
+            {
+                command = Console.ReadLine();
+            }
+            server.StopServer();
+            await serverStop;
+        }
+        catch (ArgumentException)
+        {
+            Console.WriteLine("Ошибка!");
+        }
+    }
+}