ftp file maneger

2023-04-05 22:23:14 +02:00
parent 838b59217c
commit 5085befb22
4 changed files with 188 additions and 6 deletions
--- a/Moonlight/App/Helpers/Files/FtpFileAccess.cs
+++ b/Moonlight/App/Helpers/Files/FtpFileAccess.cs
@@ -0,0 +1,184 @@
+using System.Net;
+using System.Text;
+using FluentFTP;
+
+namespace Moonlight.App.Helpers.Files;
+
+public class FtpFileAccess : FileAccess
+{
+    private string FtpHost, FtpUser, FtpPassword;
+    private int FtpPort;
+
+    private AsyncFtpClient Client;
+    
+    public FtpFileAccess(string ftpHost, int ftpPort, string ftpUser, string ftpPassword)
+    {
+        FtpHost = ftpHost;
+        FtpPort = ftpPort;
+        FtpUser = ftpUser;
+        FtpPassword = ftpPassword;
+
+        Client = new AsyncFtpClient(FtpHost, FtpUser, FtpPassword, FtpPort);
+    }
+
+    private async Task EnsureConnect()
+    {
+        if (!Client.IsConnected)
+            await Client.AutoConnect();
+    }
+    
+    public override async Task<FileData[]> Ls()
+    {
+        await EnsureConnect();
+        
+        var x = new List<FileData>();
+        
+        foreach (FtpListItem item in await Client.GetListing(CurrentPath))
+        {
+            long size = 0;
+            
+            if (item.Type == FtpObjectType.File)
+            {
+                size = await Client.GetFileSize(item.FullName);
+            }
+
+            x.Add(new()
+            {
+                Name = item.Name,
+                Size = size,
+                IsFile = item.Type == FtpObjectType.File,
+            });
+        }
+
+        return x.ToArray();
+    }
+
+    public override Task Cd(string dir)
+    {
+        var x = Path.Combine(CurrentPath, dir).Replace("\\", "/") + "/";
+        x = x.Replace("//", "/");
+        CurrentPath = x;
+
+        return Task.CompletedTask;
+    }
+
+    public override Task Up()
+    {
+        CurrentPath = Path.GetFullPath(Path.Combine(CurrentPath, "..")).Replace("\\", "/").Replace("C:", "");
+        return Task.CompletedTask;
+    }
+
+    public override Task SetDir(string dir)
+    {
+        CurrentPath = dir;
+        return Task.CompletedTask;
+    }
+
+    public override async Task<string> Read(FileData fileData)
+    {
+        await EnsureConnect();
+
+        var s = new MemoryStream();
+        await Client.DownloadStream(s, CurrentPath.TrimEnd('/') + "/" + fileData.Name);
+        var data = s.ToArray();
+        s.Dispose();
+        var str = Encoding.UTF8.GetString(data);
+        return str;
+    }
+
+    public override async Task Write(FileData fileData, string content)
+    {
+        await EnsureConnect();
+
+        var s = new MemoryStream();
+        s.Write(Encoding.UTF8.GetBytes(content));
+        s.Position = 0;
+        await Client.UploadStream(s, CurrentPath.TrimEnd('/') + "/" + fileData.Name, FtpRemoteExists.Overwrite);
+        s.Dispose();
+    }
+
+    public override async Task Upload(string name, Stream dataStream, Action<int>? progressUpdated = null)
+    {
+        await EnsureConnect();
+
+        IProgress<FtpProgress> progress = new Progress<FtpProgress>(x =>
+        {
+            progressUpdated((int) x.Progress);
+        });
+        await Client.UploadStream(dataStream, CurrentPath.TrimEnd('/') + "/" + name, FtpRemoteExists.Overwrite, false, progress);
+        dataStream.Dispose();
+    }
+
+    public override async Task MkDir(string name)
+    {
+        await EnsureConnect();
+
+        await Client.CreateDirectory(CurrentPath.TrimEnd('/') + "/" + name + "/");
+    }
+
+    public override Task<string> Pwd()
+    {
+        return Task.FromResult(CurrentPath);
+    }
+
+    public override async Task<string> DownloadUrl(FileData fileData)
+    {
+        await EnsureConnect();
+
+        throw new NotImplementedException();
+    }
+
+    public override async Task<Stream> DownloadStream(FileData fileData)
+    {
+        await EnsureConnect();
+
+        var s = new MemoryStream();
+        await Client.DownloadStream(s, CurrentPath.TrimEnd('/') + "/" + fileData.Name);
+        return s;
+    }
+
+    public override async Task Delete(FileData fileData)
+    {
+        await EnsureConnect();
+
+        if (fileData.IsFile)
+            await Client.DeleteFile(CurrentPath.TrimEnd('/') + "/" + fileData.Name);
+        else
+            await Client.DeleteDirectory(CurrentPath.TrimEnd('/') + "/" + fileData.Name);
+    }
+
+    public override async Task Move(FileData fileData, string newPath)
+    {
+        await EnsureConnect();
+
+        if (fileData.IsFile)
+            await Client.MoveFile(CurrentPath.TrimEnd('/') + "/" + fileData.Name, newPath);
+        else
+            await Client.MoveDirectory(CurrentPath.TrimEnd('/') + "/" + fileData.Name, newPath);
+    }
+
+    public override async Task Compress(params FileData[] files)
+    {
+        await EnsureConnect();
+
+        throw new NotImplementedException();
+    }
+
+    public override async Task Decompress(FileData fileData)
+    {
+        await EnsureConnect();
+
+        throw new NotImplementedException();
+    }
+
+    public override Task<string> GetLaunchUrl()
+    {
+        return Task.FromResult(
+                    $"ftp://{FtpUser}:{FtpPassword}@{FtpHost}:{FtpPort}/");
+    }
+
+    public override object Clone()
+    {
+        return new FtpFileAccess(FtpHost, FtpPort, FtpUser, FtpPassword);
+    }
+}