From 8cb06752547ec6f92a6f215d0b1c82b3821a362f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81d=C3=A1m=20Kov=C3=A1cs?= Date: Sat, 8 Jan 2022 11:32:52 +0100 Subject: [PATCH] Smb content provider --- .../DependencyInjection.cs | 3 + .../FileTime.App.DependencyInjection.csproj | 1 + .../FileTime.ConsoleUI.App/Application.cs | 2 +- .../UI/ConsoleInputInterface.cs | 35 ++++ .../UI/ConsoleReader.cs | 6 +- .../FileTime.ConsoleUI.App/UI/Render.cs | 6 +- src/ConsoleApp/FileTime.ConsoleUI/Program.cs | 37 +--- src/Core/FileTime.Core/Components/Tab.cs | 4 + .../Interactions/IInputInterface.cs | 7 + .../Interactions/InputElement.cs | 14 ++ .../FileTime.Core/Interactions/InputType.cs | 8 + .../Providers/IContentProvider.cs | 4 + .../FileTime.Core/Providers/TopContainer.cs | 54 ++++++ src/FileTime.sln | 23 +++ .../LocalContentProvider.cs | 13 +- .../FileTime.Providers.Smb.csproj | 13 ++ .../SmbContentProvider.cs | 82 +++++++++ .../FileTime.Providers.Smb/SmbFile.cs | 40 +++++ .../FileTime.Providers.Smb/SmbFolder.cs | 132 ++++++++++++++ .../FileTime.Providers.Smb/SmbServer.cs | 126 +++++++++++++ .../FileTime.Providers.Smb/SmbShare.cs | 165 ++++++++++++++++++ 21 files changed, 730 insertions(+), 45 deletions(-) create mode 100644 src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleInputInterface.cs create mode 100644 src/Core/FileTime.Core/Interactions/IInputInterface.cs create mode 100644 src/Core/FileTime.Core/Interactions/InputElement.cs create mode 100644 src/Core/FileTime.Core/Interactions/InputType.cs create mode 100644 src/Core/FileTime.Core/Providers/TopContainer.cs create mode 100644 src/Providers/FileTime.Providers.Smb/FileTime.Providers.Smb.csproj create mode 100644 src/Providers/FileTime.Providers.Smb/SmbContentProvider.cs create mode 100644 src/Providers/FileTime.Providers.Smb/SmbFile.cs create mode 100644 src/Providers/FileTime.Providers.Smb/SmbFolder.cs create mode 100644 src/Providers/FileTime.Providers.Smb/SmbServer.cs create mode 100644 src/Providers/FileTime.Providers.Smb/SmbShare.cs diff --git a/src/AppCommon/FileTime.App.DependencyInjection/DependencyInjection.cs b/src/AppCommon/FileTime.App.DependencyInjection/DependencyInjection.cs index 051e1f8..69f09c9 100644 --- a/src/AppCommon/FileTime.App.DependencyInjection/DependencyInjection.cs +++ b/src/AppCommon/FileTime.App.DependencyInjection/DependencyInjection.cs @@ -3,6 +3,7 @@ using FileTime.Core.Command; using FileTime.Core.Providers; using FileTime.Core.StateManagement; using FileTime.Providers.Local; +using FileTime.Providers.Smb; using Microsoft.Extensions.DependencyInjection; namespace FileTime.App.Core @@ -15,8 +16,10 @@ namespace FileTime.App.Core return serviceCollection .AddSingleton() + .AddSingleton() .AddSingleton() .AddSingleton(sp => sp.GetService() ?? throw new Exception($"No {nameof(LocalContentProvider)} instance found")) + .AddSingleton() .AddSingleton() .AddSingleton(); } diff --git a/src/AppCommon/FileTime.App.DependencyInjection/FileTime.App.DependencyInjection.csproj b/src/AppCommon/FileTime.App.DependencyInjection/FileTime.App.DependencyInjection.csproj index 09335f6..3d30e02 100644 --- a/src/AppCommon/FileTime.App.DependencyInjection/FileTime.App.DependencyInjection.csproj +++ b/src/AppCommon/FileTime.App.DependencyInjection/FileTime.App.DependencyInjection.csproj @@ -11,6 +11,7 @@ + diff --git a/src/ConsoleApp/FileTime.ConsoleUI.App/Application.cs b/src/ConsoleApp/FileTime.ConsoleUI.App/Application.cs index f0f03f9..e514b78 100644 --- a/src/ConsoleApp/FileTime.ConsoleUI.App/Application.cs +++ b/src/ConsoleApp/FileTime.ConsoleUI.App/Application.cs @@ -267,7 +267,7 @@ namespace FileTime.ConsoleUI.App private static bool AreKeysEqual(ConsoleKeyInfo keyInfo1, ConsoleKeyInfo keyInfo2) => keyInfo1.Key == keyInfo2.Key && keyInfo1.Modifiers == keyInfo2.Modifiers; - private static void MoveToIOLine(int left = 0) + public void MoveToIOLine(int left = 0) { Console.SetCursorPosition(left, Console.WindowHeight - 2); } diff --git a/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleInputInterface.cs b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleInputInterface.cs new file mode 100644 index 0000000..1bb39ac --- /dev/null +++ b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleInputInterface.cs @@ -0,0 +1,35 @@ +using FileTime.ConsoleUI.App.UI.Color; +using FileTime.Core.Interactions; + +namespace FileTime.ConsoleUI.App.UI +{ + public class ConsoleInputInterface : IInputInterface + { + private readonly Application _application; + private readonly IColoredConsoleRenderer _coloredConsoleRenderer; + private readonly ConsoleReader _consoleReader; + + public ConsoleInputInterface(Application application, IColoredConsoleRenderer coloredConsoleRenderer, ConsoleReader consoleReader) + { + _application = application; + _coloredConsoleRenderer = coloredConsoleRenderer; + _consoleReader = consoleReader; + } + public string?[] ReadInputs(IEnumerable fields) + { + var results = new List(); + + _coloredConsoleRenderer.ResetColor(); + + foreach (var input in fields) + { + _application.MoveToIOLine(); + _coloredConsoleRenderer.Write(input.Text + ": "); + + results.Add(_consoleReader.ReadText(placeHolder: input.InputType == InputType.Password ? '*' : null)); + } + + return results.ToArray(); + } + } +} \ No newline at end of file diff --git a/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleReader.cs b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleReader.cs index 46cc49c..5a8bc5e 100644 --- a/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleReader.cs +++ b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/ConsoleReader.cs @@ -10,7 +10,7 @@ namespace FileTime.ConsoleUI.App.UI { _coloredConsoleRenderer = coloredConsoleRenderer; } - public string ReadText(int? maxLength = null, Action? validator = null) + public string? ReadText(int? maxLength = null, Action? validator = null, char? placeHolder = null) { var cursorVisible = false; try @@ -76,10 +76,10 @@ namespace FileTime.ConsoleUI.App.UI validator?.Invoke(input); Console.SetCursorPosition(currentConsoleLeft, currentConsoleTop); - _coloredConsoleRenderer.Write($"{{0,-{maxLength}}}", input); + _coloredConsoleRenderer.Write($"{{0,-{maxLength}}}", placeHolder == null ? input : new string((char)placeHolder, input.Length)); Console.SetCursorPosition(currentConsoleLeft + position, currentConsoleTop); - key = Console.ReadKey(); + key = Console.ReadKey(true); } Console.CursorVisible = cursorVisible; diff --git a/src/ConsoleApp/FileTime.ConsoleUI.App/UI/Render.cs b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/Render.cs index d9048e4..9f0dbee 100644 --- a/src/ConsoleApp/FileTime.ConsoleUI.App/UI/Render.cs +++ b/src/ConsoleApp/FileTime.ConsoleUI.App/UI/Render.cs @@ -173,7 +173,6 @@ namespace FileTime.ConsoleUI.App.UI printedItemsCount = itemsToPrint.Count; foreach (var item in itemsToPrint) { - Console.SetCursorPosition(startX, startY + currentY++); var namePart = item.Name.Length > maxTextWidth ? string.Concat(item.Name.AsSpan(0, maxTextWidth - 1), "~") : item.Name; @@ -183,6 +182,8 @@ namespace FileTime.ConsoleUI.App.UI var container = item as IContainer; var element = item as IElement; + attributePart = container != null ? "" + container.Items.Count : element!.GetPrimaryAttributeText(); + IConsoleColor? backgroundColor = null; IConsoleColor? foregroundColor = null; @@ -220,11 +221,10 @@ namespace FileTime.ConsoleUI.App.UI _coloredRenderer.BackgroundColor = backgroundColor; _coloredRenderer.ForegroundColor = foregroundColor; - attributePart = container != null ? "" + container.Items.Count : element!.GetPrimaryAttributeText(); - var text = string.Format($"{{0,-{elementWidth}}}", _paddingLeft + (isSelected ? " " : "") + namePart + _paddingRight); text = string.Concat(text.AsSpan(0, text.Length - attributePart.Length - 1), " ", attributePart); + Console.SetCursorPosition(startX, startY + currentY++); _coloredRenderer.Write(text); _coloredRenderer.ResetColor(); diff --git a/src/ConsoleApp/FileTime.ConsoleUI/Program.cs b/src/ConsoleApp/FileTime.ConsoleUI/Program.cs index 7adca4d..c911dc8 100644 --- a/src/ConsoleApp/FileTime.ConsoleUI/Program.cs +++ b/src/ConsoleApp/FileTime.ConsoleUI/Program.cs @@ -1,12 +1,11 @@ using FileTime.App.Core; -using FileTime.App.Core.Clipboard; using FileTime.ConsoleUI.App; using FileTime.ConsoleUI.App.UI; using FileTime.ConsoleUI.App.UI.Color; using FileTime.Core.Command; +using FileTime.Core.Interactions; using FileTime.Core.Models; using FileTime.Core.Providers; -using FileTime.Core.StateManagement; using FileTime.Providers.Local; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; @@ -19,37 +18,6 @@ namespace FileTime.ConsoleUI public static void Main() { - /* Console.Clear(); - for (var x = 0; x < 16; x++) - { - for (var y = 0; y < 16; y++) - { - var i = x * 16 + y; - Console.Write("\u001b[48;5;{0}m{0,4}", i); - Console.ResetColor(); - Console.Write(' '); - } - Console.WriteLine("\n"); - } - return; */ - - /* var colors = new int[][] - { - new int[] {0,43,54}, - new int[] {255,0,0}, - new int[] {0,255,0}, - new int[] {0,0,255}, - }; - - foreach (var color in colors) - { - Console.Write($"\u001b[0m\u001b[48;2;{color[0]};{color[1]};{color[2]}mTESZT "); - Console.WriteLine($"\u001b[0m\u001b[38;2;{color[0]};{color[1]};{color[2]}mTESZT"); - } - - Console.WriteLine("\u001b[0m\u001b[48;5;0;38;5;14mASD"); - return; */ - var serviceProvider = CreateServiceProvider(); _logger = serviceProvider.GetService>()!; @@ -62,6 +30,7 @@ namespace FileTime.ConsoleUI if (currentPossibleDirectory is IContainer container) { + serviceProvider.GetService(); coloredConsoleRenderer.Clear(); Console.CursorVisible = false; @@ -103,10 +72,10 @@ namespace FileTime.ConsoleUI return DependencyInjection.RegisterDefaultServices() .AddLogging(/* (builder) => builder.AddConsole().AddDebug() */) .AddSingleton() - .AddSingleton(new Styles(IsAnsiColorSupported())) .AddSingleton() .AddSingleton() + .AddSingleton() .AddTransient() .RegisterCommandHandlers() diff --git a/src/Core/FileTime.Core/Components/Tab.cs b/src/Core/FileTime.Core/Components/Tab.cs index 4e0c516..929433e 100644 --- a/src/Core/FileTime.Core/Components/Tab.cs +++ b/src/Core/FileTime.Core/Components/Tab.cs @@ -55,6 +55,10 @@ namespace FileTime.Core.Components { CurrentSelectedItem = CurrentLocation.Items.FirstOrDefault(i => i.FullName == currentSelectedName) ?? currentLocation.Items.FirstOrDefault(); } + else if (CurrentLocation.Items.Count > 0) + { + CurrentSelectedItem = CurrentLocation.Items[0]; + } } public void SelectFirstItem() diff --git a/src/Core/FileTime.Core/Interactions/IInputInterface.cs b/src/Core/FileTime.Core/Interactions/IInputInterface.cs new file mode 100644 index 0000000..25df636 --- /dev/null +++ b/src/Core/FileTime.Core/Interactions/IInputInterface.cs @@ -0,0 +1,7 @@ +namespace FileTime.Core.Interactions +{ + public interface IInputInterface + { + string?[] ReadInputs(IEnumerable fields); + } +} \ No newline at end of file diff --git a/src/Core/FileTime.Core/Interactions/InputElement.cs b/src/Core/FileTime.Core/Interactions/InputElement.cs new file mode 100644 index 0000000..2ac37f5 --- /dev/null +++ b/src/Core/FileTime.Core/Interactions/InputElement.cs @@ -0,0 +1,14 @@ +namespace FileTime.Core.Interactions +{ + public class InputElement + { + public string Text { get; } + public InputType InputType { get; } + + public InputElement(string text, InputType inputType) + { + Text = text; + InputType = inputType; + } + } +} \ No newline at end of file diff --git a/src/Core/FileTime.Core/Interactions/InputType.cs b/src/Core/FileTime.Core/Interactions/InputType.cs new file mode 100644 index 0000000..bc2342b --- /dev/null +++ b/src/Core/FileTime.Core/Interactions/InputType.cs @@ -0,0 +1,8 @@ +namespace FileTime.Core.Interactions +{ + public enum InputType + { + Text, + Password + } +} \ No newline at end of file diff --git a/src/Core/FileTime.Core/Providers/IContentProvider.cs b/src/Core/FileTime.Core/Providers/IContentProvider.cs index 954ef41..2b0782e 100644 --- a/src/Core/FileTime.Core/Providers/IContentProvider.cs +++ b/src/Core/FileTime.Core/Providers/IContentProvider.cs @@ -5,5 +5,9 @@ namespace FileTime.Core.Providers public interface IContentProvider : IContainer { IReadOnlyList RootContainers { get; } + + bool CanHandlePath(string path); + + void SetParent(IContainer container); } } \ No newline at end of file diff --git a/src/Core/FileTime.Core/Providers/TopContainer.cs b/src/Core/FileTime.Core/Providers/TopContainer.cs new file mode 100644 index 0000000..3f04f9b --- /dev/null +++ b/src/Core/FileTime.Core/Providers/TopContainer.cs @@ -0,0 +1,54 @@ + +using FileTime.Core.Models; + +namespace FileTime.Core.Providers +{ + public class TopContainer : IContainer + { + private readonly List _contentProviders; + + public IReadOnlyList Items => Containers; + + public IReadOnlyList Containers { get; } + + public IReadOnlyList Elements { get; } = new List().AsReadOnly(); + + public string Name => null; + + public string? FullName => null; + + public bool IsHidden => false; + + public IContentProvider Provider => null; + + public event EventHandler? Refreshed; + + public TopContainer(IEnumerable contentProviders) + { + _contentProviders = new List(contentProviders); + Containers = _contentProviders.AsReadOnly(); + + foreach (var contentProvider in contentProviders) + { + contentProvider.SetParent(this); + } + } + + public IContainer CreateContainer(string name) => throw new NotImplementedException(); + + public IElement CreateElement(string name) => throw new NotImplementedException(); + + public void Delete() => throw new NotImplementedException(); + + public IItem? GetByPath(string path) => throw new NotImplementedException(); + + public IContainer? GetParent() => null; + + public bool IsExists(string name) => throw new NotImplementedException(); + + public void Refresh() + { + + } + } +} \ No newline at end of file diff --git a/src/FileTime.sln b/src/FileTime.sln index 49b5b70..6f8ae8e 100644 --- a/src/FileTime.sln +++ b/src/FileTime.sln @@ -27,6 +27,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Core", "Core", "{38B1B927-4 EndProject Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FileTime.App.DependencyInjection", "AppCommon\FileTime.App.DependencyInjection\FileTime.App.DependencyInjection.csproj", "{F46D6CE5-4811-45B8-9CD4-3C993318A2E6}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FileTime.Providers.Smb", "Providers\FileTime.Providers.Smb\FileTime.Providers.Smb.csproj", "{35963404-39F6-4CDA-A0FE-A91036FA8DAC}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -201,6 +203,26 @@ Global {F46D6CE5-4811-45B8-9CD4-3C993318A2E6}.Release|x64.Build.0 = Release|Any CPU {F46D6CE5-4811-45B8-9CD4-3C993318A2E6}.Release|x86.ActiveCfg = Release|Any CPU {F46D6CE5-4811-45B8-9CD4-3C993318A2E6}.Release|x86.Build.0 = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|Any CPU.Build.0 = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|ARM.ActiveCfg = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|ARM.Build.0 = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|ARM64.ActiveCfg = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|ARM64.Build.0 = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|x64.ActiveCfg = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|x64.Build.0 = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|x86.ActiveCfg = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Debug|x86.Build.0 = Debug|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|Any CPU.ActiveCfg = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|Any CPU.Build.0 = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|ARM.ActiveCfg = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|ARM.Build.0 = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|ARM64.ActiveCfg = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|ARM64.Build.0 = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|x64.ActiveCfg = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|x64.Build.0 = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|x86.ActiveCfg = Release|Any CPU + {35963404-39F6-4CDA-A0FE-A91036FA8DAC}.Release|x86.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE @@ -214,6 +236,7 @@ Global {92961CA3-ECAB-4920-95CA-F37E8F3EFDFA} = {D4C7E692-53C0-4423-9944-E25FE3D51BA2} {BEA824B0-7684-44FF-95BF-A75E92A36C9F} = {D4C7E692-53C0-4423-9944-E25FE3D51BA2} {F46D6CE5-4811-45B8-9CD4-3C993318A2E6} = {D4C7E692-53C0-4423-9944-E25FE3D51BA2} + {35963404-39F6-4CDA-A0FE-A91036FA8DAC} = {517D96CE-A956-4638-A93D-465D34DE22B1} EndGlobalSection GlobalSection(ExtensibilityGlobals) = postSolution SolutionGuid = {8D679DCE-AC84-4A91-BFED-8F8D8E1D8183} diff --git a/src/Providers/FileTime.Providers.Local/LocalContentProvider.cs b/src/Providers/FileTime.Providers.Local/LocalContentProvider.cs index 3f18629..1a4e399 100644 --- a/src/Providers/FileTime.Providers.Local/LocalContentProvider.cs +++ b/src/Providers/FileTime.Providers.Local/LocalContentProvider.cs @@ -8,6 +8,7 @@ namespace FileTime.Providers.Local public class LocalContentProvider : IContentProvider { private readonly ILogger _logger; + private IContainer _parent = null; public IReadOnlyList RootContainers { get; } @@ -61,10 +62,7 @@ namespace FileTime.Providers.Local { } - public IContainer? GetParent() - { - return null; - } + public IContainer? GetParent() => _parent; public IContainer CreateContainer(string name) => throw new NotSupportedException(); public IElement CreateElement(string name) => throw new NotSupportedException(); public bool IsExists(string name) => Items.Any(i => i.Name == name); @@ -72,5 +70,12 @@ namespace FileTime.Providers.Local public void Delete() => throw new NotSupportedException(); internal string NormalizePath(string path) => IsCaseInsensitive ? path.ToLower() : path; + + public bool CanHandlePath(string path) => RootContainers.Any(r => path.StartsWith(r.Name)); + + public void SetParent(IContainer container) + { + _parent = container; + } } } \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/FileTime.Providers.Smb.csproj b/src/Providers/FileTime.Providers.Smb/FileTime.Providers.Smb.csproj new file mode 100644 index 0000000..615895a --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/FileTime.Providers.Smb.csproj @@ -0,0 +1,13 @@ + + + net6.0 + enable + enable + + + + + + + + \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/SmbContentProvider.cs b/src/Providers/FileTime.Providers.Smb/SmbContentProvider.cs new file mode 100644 index 0000000..863fd6c --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/SmbContentProvider.cs @@ -0,0 +1,82 @@ +using FileTime.Core.Interactions; +using FileTime.Core.Models; +using FileTime.Core.Providers; + +namespace FileTime.Providers.Smb +{ + public class SmbContentProvider : IContentProvider + { + private IContainer _parent; + private readonly List _rootContainers; + private readonly IInputInterface _inputInterface; + + public IReadOnlyList RootContainers { get; } + + public IReadOnlyList Items => RootContainers; + + public IReadOnlyList Containers => RootContainers; + + public IReadOnlyList Elements { get; } = new List(); + + public string Name { get; } = "smb"; + + public string? FullName { get; } + + public bool IsHidden => false; + + public IContentProvider Provider => this; + + public event EventHandler? Refreshed; + + public SmbContentProvider(IInputInterface inputInterface) + { + _rootContainers = new List(); + RootContainers = _rootContainers.AsReadOnly(); + _inputInterface = inputInterface; + } + + public IContainer CreateContainer(string name) + { + var fullName = "\\\\" + name; + var container = _rootContainers.Find(c => c.Name == name); + + if (container == null) + { + container = new SmbServer(fullName, this, _inputInterface); + _rootContainers.Add(container); + } + + Refresh(); + + return container; + } + + public IElement CreateElement(string name) + { + throw new NotSupportedException(); + } + + public void Delete() + { + throw new NotSupportedException(); + } + + public IItem? GetByPath(string path) + { + throw new NotImplementedException(); + } + + public IContainer? GetParent() => _parent; + + public bool IsExists(string name) => Items.Any(i => i.Name == name); + + public void Refresh() + { + Refreshed?.Invoke(this, EventArgs.Empty); + } + + public bool CanHandlePath(string path) => path.StartsWith("smb://") || path.StartsWith(@"\\"); + + public void SetParent(IContainer container) => _parent = container; + } +} \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/SmbFile.cs b/src/Providers/FileTime.Providers.Smb/SmbFile.cs new file mode 100644 index 0000000..6ef1cfb --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/SmbFile.cs @@ -0,0 +1,40 @@ +using FileTime.Core.Models; +using FileTime.Core.Providers; +using SMBLibrary.Client; + +namespace FileTime.Providers.Smb +{ + public class SmbFile : IElement + { + public bool IsSpecial => false; + + public string Name { get; } + + public string? FullName { get; } + + public bool IsHidden => false; + + public IContentProvider Provider { get; } + + private readonly Func _getSmbClient; + + public SmbFile(string name, SmbContentProvider provider, IContainer parent, Func getSmbClient) + { + Name = name; + FullName = parent.FullName + Constants.SeparatorChar + Name; + + Provider = provider; + _getSmbClient = getSmbClient; + } + + public void Delete() + { + throw new NotImplementedException(); + } + + public string GetPrimaryAttributeText() + { + return ""; + } + } +} \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/SmbFolder.cs b/src/Providers/FileTime.Providers.Smb/SmbFolder.cs new file mode 100644 index 0000000..ed074c6 --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/SmbFolder.cs @@ -0,0 +1,132 @@ +using FileTime.Core.Models; +using FileTime.Core.Providers; +using SMBLibrary; +using SMBLibrary.Client; + +namespace FileTime.Providers.Smb +{ + public class SmbFolder : IContainer + { + private IReadOnlyList? _items; + private IReadOnlyList? _containers; + private IReadOnlyList? _elements; + private Func _getSmbClient; + private readonly SmbShare _smbShare; + private readonly IContainer? _parent; + + public IReadOnlyList Items + { + get + { + if (_items == null) Refresh(); + return _items!; + } + + private set => _items = value; + } + + public IReadOnlyList Containers + { + get + { + if (_containers == null) Refresh(); + return _containers!; + } + + private set => _containers = value; + } + + public IReadOnlyList Elements + { + get + { + if (_elements == null) Refresh(); + return _elements!; + } + + private set => _elements = value; + } + + public string Name { get; } + + public string? FullName { get; } + + public bool IsHidden => false; + + public SmbContentProvider Provider { get; } + IContentProvider IItem.Provider => Provider; + + public event EventHandler? Refreshed; + + public SmbFolder(string name, SmbContentProvider contentProvider, SmbShare smbShare, IContainer parent, Func getSmbClient) + { + _parent = parent; + _getSmbClient = getSmbClient; + + Name = name; + FullName = parent?.FullName == null ? Name : parent.FullName + Constants.SeparatorChar + Name; + Provider = contentProvider; + _smbShare = smbShare; + } + + public IContainer CreateContainer(string name) + { + throw new NotImplementedException(); + } + + public IElement CreateElement(string name) + { + throw new NotImplementedException(); + } + + public void Delete() + { + throw new NotImplementedException(); + } + + public IItem? GetByPath(string path) + { + var paths = path.Split(Constants.SeparatorChar); + + var item = Items.FirstOrDefault(i => i.Name == paths[0]); + + if (paths.Length == 1) + { + return item; + } + + if (item is IContainer container) + { + return container.GetByPath(string.Join(Constants.SeparatorChar, paths.Skip(1))); + } + + return null; + } + + public IContainer? GetParent() => _parent; + + public bool IsExists(string name) + { + throw new NotImplementedException(); + } + + public void Refresh() + { + var containers = new List(); + var elements = new List(); + + try + { + var path = FullName![(_smbShare.FullName!.Length + 1)..]; + (containers, elements) = _smbShare.ListFolder(this, _smbShare.Name, path); + } + catch { } + + _containers = containers.AsReadOnly(); + _elements = elements.AsReadOnly(); + + _items = _containers.Cast().Concat(_elements).ToList().AsReadOnly(); + Refreshed?.Invoke(this, EventArgs.Empty); + } + } +} \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/SmbServer.cs b/src/Providers/FileTime.Providers.Smb/SmbServer.cs new file mode 100644 index 0000000..b8e7951 --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/SmbServer.cs @@ -0,0 +1,126 @@ +using FileTime.Core.Interactions; +using FileTime.Core.Models; +using FileTime.Core.Providers; +using SMBLibrary; +using SMBLibrary.Client; + +namespace FileTime.Providers.Smb +{ + public class SmbServer : IContainer + { + private string? _username; + private string? _password; + + private IReadOnlyList? _shares; + private ISMBClient? _client; + private readonly IInputInterface _inputInterface; + + public IReadOnlyList Items + { + get + { + if (_shares == null) Refresh(); + return _shares!; + } + } + + public IReadOnlyList Containers + { + get + { + if (_shares == null) Refresh(); + return _shares!; + } + + private set => _shares = value; + } + + public IReadOnlyList Elements { get; } = new List().AsReadOnly(); + + public string Name { get; } + + public string? FullName { get; } + + public bool IsHidden => false; + + public SmbContentProvider Provider { get; } + + IContentProvider IItem.Provider => Provider; + + public event EventHandler? Refreshed; + + public SmbServer(string path, SmbContentProvider contentProvider, IInputInterface inputInterface) + { + _inputInterface = inputInterface; + + Provider = contentProvider; + FullName = Name = path; + } + + public IContainer CreateContainer(string name) + { + throw new NotSupportedException(); + } + + public IElement CreateElement(string name) + { + throw new NotSupportedException(); + } + + public void Delete() + { + } + + public IItem? GetByPath(string path) + { + throw new NotImplementedException(); + } + + public IContainer? GetParent() => Provider; + + public bool IsExists(string name) + { + throw new NotImplementedException(); + } + + public void Refresh() + { + ISMBClient client = GetSmbClient(); + + List shares = new List(); //client.ListShares(out var status); + + _shares = shares.ConvertAll(s => new SmbShare(s, Provider, this, GetSmbClient)).AsReadOnly(); + Refreshed?.Invoke(this, EventArgs.Empty); + } + + private ISMBClient GetSmbClient() + { + if (_client == null) + { + _client = new SMB2Client(); + if (_client.Connect(Name[2..], SMBTransportType.DirectTCPTransport)) + { + if (_username == null && _password == null) + { + var inputs = _inputInterface.ReadInputs( + new InputElement[] + { + new InputElement($"Username for '{Name}'", InputType.Text), + new InputElement($"Password for '{Name}'", InputType.Password) + }); + + _username = inputs[0]; + _password = inputs[1]; + } + + if (_client.Login(string.Empty, _username, _password) != NTStatus.STATUS_SUCCESS) + { + _username = null; + _password = null; + } + } + } + return _client; + } + } +} \ No newline at end of file diff --git a/src/Providers/FileTime.Providers.Smb/SmbShare.cs b/src/Providers/FileTime.Providers.Smb/SmbShare.cs new file mode 100644 index 0000000..6bb774a --- /dev/null +++ b/src/Providers/FileTime.Providers.Smb/SmbShare.cs @@ -0,0 +1,165 @@ +using FileTime.Core.Interactions; +using FileTime.Core.Models; +using FileTime.Core.Providers; +using SMBLibrary; +using SMBLibrary.Client; + +namespace FileTime.Providers.Smb +{ + public class SmbShare : IContainer + { + private IReadOnlyList? _items; + private IReadOnlyList? _containers; + private IReadOnlyList? _elements; + private Func _getSmbClient; + private readonly IContainer? _parent; + + public IReadOnlyList Items + { + get + { + if (_items == null) Refresh(); + return _items!; + } + + private set => _items = value; + } + + public IReadOnlyList Containers + { + get + { + if (_containers == null) Refresh(); + return _containers!; + } + + private set => _containers = value; + } + + public IReadOnlyList Elements + { + get + { + if (_elements == null) Refresh(); + return _elements!; + } + + private set => _elements = value; + } + + public string Name { get; } + + public string? FullName { get; } + + public bool IsHidden => false; + + public SmbContentProvider Provider { get; } + IContentProvider IItem.Provider => Provider; + + public event EventHandler? Refreshed; + + public SmbShare(string name, SmbContentProvider contentProvider, IContainer parent, Func getSmbClient) + { + _parent = parent; + _getSmbClient = getSmbClient; + + Name = name; + FullName = parent?.FullName == null ? Name : parent.FullName + Constants.SeparatorChar + Name; + Provider = contentProvider; + } + + public IContainer CreateContainer(string name) + { + throw new NotImplementedException(); + } + + public IElement CreateElement(string name) + { + throw new NotImplementedException(); + } + + public void Delete() + { + throw new NotImplementedException(); + } + + public IItem? GetByPath(string path) + { + var paths = path.Split(Constants.SeparatorChar); + + var item = Items.FirstOrDefault(i => i.Name == paths[0]); + + if (paths.Length == 1) + { + return item; + } + + if (item is IContainer container) + { + return container.GetByPath(string.Join(Constants.SeparatorChar, paths.Skip(1))); + } + + return null; + } + + public IContainer? GetParent() => _parent; + + public bool IsExists(string name) + { + throw new NotImplementedException(); + } + + public void Refresh() + { + var containers = new List(); + var elements = new List(); + + try + { + (containers, elements) = ListFolder(this, Name, string.Empty); + } + catch { } + + _containers = containers.AsReadOnly(); + _elements = elements.AsReadOnly(); + + _items = _containers.Cast().Concat(_elements).ToList().AsReadOnly(); + Refreshed?.Invoke(this, EventArgs.Empty); + } + + public (List containers, List elements) ListFolder(IContainer parent, string shareName, string folderName) + { + var containers = new List(); + var elements = new List(); + + var client = _getSmbClient(); + ISMBFileStore fileStore = client.TreeConnect(shareName, out var status); + if (status == NTStatus.STATUS_SUCCESS) + { + status = fileStore.CreateFile(out object directoryHandle, out FileStatus fileStatus, folderName, AccessMask.GENERIC_READ, SMBLibrary.FileAttributes.Directory, ShareAccess.Read | ShareAccess.Write, CreateDisposition.FILE_OPEN, CreateOptions.FILE_DIRECTORY_FILE, null); + if (status == NTStatus.STATUS_SUCCESS) + { + status = fileStore.QueryDirectory(out List fileList, directoryHandle, "*", FileInformationClass.FileDirectoryInformation); + status = fileStore.CloseFile(directoryHandle); + + foreach (var item in fileList) + { + if (item is FileDirectoryInformation fileDirectoryInformation && fileDirectoryInformation.FileName != "." && fileDirectoryInformation.FileName != "..") + { + if ((fileDirectoryInformation.FileAttributes & SMBLibrary.FileAttributes.Directory) == SMBLibrary.FileAttributes.Directory) + { + containers.Add(new SmbFolder(fileDirectoryInformation.FileName, Provider, this, parent, _getSmbClient)); + } + else + { + elements.Add(new SmbFile(fileDirectoryInformation.FileName, Provider, parent, _getSmbClient)); + } + } + } + } + } + + return (containers, elements); + } + } +} \ No newline at end of file