Refactored project with .net core based controller.

Author: winromulus

.dockerignore

@@ -0,0 +1,25 @@
+**/.classpath
+**/.dockerignore
+**/.env
+**/.git
+**/.gitignore
+**/.project
+**/.settings
+**/.toolstarget
+**/.vs
+**/.vscode
+**/*.*proj.user
+**/*.dbmdl
+**/*.jfm
+**/azds.yaml
+**/bin
+**/charts
+**/docker-compose*
+**/Dockerfile*
+**/node_modules
+**/npm-debug.log
+**/obj
+**/secrets.dev.yaml
+**/values.dev.yaml
+LICENSE
+README.md

ES.SFTP.Host/Business/Configuration/ChrootDefinition.cs

@@ -0,0 +1,8 @@
+namespace ES.SFTP.Host.Business.Configuration
+{
+    public class ChrootDefinition
+    {
+        public string Directory { get; set; }
+        public string StartPath { get; set; }
+    }
+}

ES.SFTP.Host/Business/Configuration/GlobalConfiguration.cs

@@ -0,0 +1,11 @@
+using System.Collections.Generic;
+
+namespace ES.SFTP.Host.Business.Configuration
+{
+    public class GlobalConfiguration
+    {
+        public string HomeDirectory { get; set; }
+        public ChrootDefinition Chroot { get; set; }
+        public List<string> Directories { get; set; } = new List<string>();
+    }
+}

ES.SFTP.Host/Business/Configuration/SftpConfiguration.cs

@@ -0,0 +1,10 @@
+using System.Collections.Generic;
+
+namespace ES.SFTP.Host.Business.Configuration
+{
+    public class SftpConfiguration
+    {
+        public GlobalConfiguration Global { get; set; }
+        public List<UserDefinition> Users { get; set; }
+    }
+}

ES.SFTP.Host/Business/Configuration/UserDefinition.cs

@@ -0,0 +1,15 @@
+using System.Collections.Generic;
+
+namespace ES.SFTP.Host.Business.Configuration
+{
+    public class UserDefinition
+    {
+        public string Username { get; set; }
+        public string Password { get; set; }
+        public bool PasswordIsEncrypted { get; set; }
+        public int? UID { get; set; }
+        public int? GID { get; set; }
+        public ChrootDefinition Chroot { get; set; }
+        public List<string> Directories { get; set; } = new List<string>();
+    }
+}

ES.SFTP.Host/Business/Interop/ProcessRunOutput.cs

@@ -0,0 +1,8 @@
+namespace ES.SFTP.Host.Business.Interop
+{
+    public class ProcessRunOutput
+    {
+        public string Output { get; set; }
+        public int ExitCode { get; set; }
+    }
+}

ES.SFTP.Host/Business/Interop/ProcessUtil.cs

@@ -0,0 +1,51 @@
+using System;
+using System.Diagnostics;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ES.SFTP.Host.Business.Interop
+{
+    public class ProcessUtil
+    {
+        public static Task<ProcessRunOutput> QuickRun(string filename, string arguments = null,
+            bool throwOnError = true)
+        {
+            var outputStringBuilder = new StringBuilder();
+            var process = new Process
+            {
+                StartInfo =
+                {
+                    FileName = filename,
+                    Arguments = arguments ?? string.Empty,
+                    UseShellExecute = false,
+                    RedirectStandardOutput = true,
+                    RedirectStandardError = true,
+                    CreateNoWindow = true
+                }
+            };
+            process.OutputDataReceived += (_, e) => outputStringBuilder.Append(e.Data);
+            process.ErrorDataReceived += (_, e) => outputStringBuilder.Append(e.Data);
+            try
+            {
+                process.Start();
+                process.BeginOutputReadLine();
+                process.BeginErrorReadLine();
+                process.WaitForExit();
+            }
+            catch (Exception)
+            {
+                if (throwOnError) throw;
+            }
+
+            var output = outputStringBuilder.ToString();
+            if (process.ExitCode != 0 && throwOnError)
+                throw new Exception(
+                    $"Process failed with exit code '{process.ExitCode}.{Environment.NewLine}{output}'");
+            return Task.FromResult(new ProcessRunOutput
+            {
+                ExitCode = process.ExitCode,
+                Output = output
+            });
+        }
+    }
+}

ES.SFTP.Host/Business/Security/GroupUtil.cs

@@ -0,0 +1,38 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using ES.SFTP.Host.Business.Interop;
+
+namespace ES.SFTP.Host.Business.Security
+{
+    public class GroupUtil
+    {
+        public static async Task<bool> GroupExists(string groupNameOrId)
+        {
+            var command = await ProcessUtil.QuickRun("getent", $"group {groupNameOrId}", false);
+            return command.ExitCode == 0 && !string.IsNullOrWhiteSpace(command.Output);
+        }
+
+        public static async Task GroupCreate(string name, bool force = false, int? groupId = null,
+            bool nonUniqueGroupId = true)
+        {
+            await ProcessUtil.QuickRun("groupadd",
+                $"{(force ? "-f" : string.Empty)} {(groupId != null ? $"-g {groupId} {(nonUniqueGroupId ? "-o" : string.Empty)}" : string.Empty)} {name}");
+        }
+
+        public static async Task GroupAddUser(string group, string username)
+        {
+            await ProcessUtil.QuickRun("usermod", $"-a -G {group} {username}");
+        }
+
+        public static async Task<IReadOnlyList<string>> GroupListUsers(string group)
+        {
+            var command = await ProcessUtil.QuickRun("members", group, false);
+            if (command.ExitCode != 0 && command.ExitCode != 1 && !string.IsNullOrWhiteSpace(command.Output))
+                throw new Exception($"Get group members command failed with exit code {command.ExitCode} and message:" +
+                                    $"{Environment.NewLine}{command.Output}");
+            return command.Output.Split(' ', StringSplitOptions.RemoveEmptyEntries).OrderBy(s => s).ToList();
+        }
+    }
+}

ES.SFTP.Host/Business/Security/UserUtil.cs

@@ -0,0 +1,47 @@
+using System.Threading.Tasks;
+using ES.SFTP.Host.Business.Interop;
+
+namespace ES.SFTP.Host.Business.Security
+{
+    public class UserUtil
+    {
+        public static async Task<bool> UserExists(string username)
+        {
+            var command = await ProcessUtil.QuickRun("getent", $"passwd {username}", false);
+            return command.ExitCode == 0 && !string.IsNullOrWhiteSpace(command.Output);
+        }
+
+        public static async Task UserCreate(string username, bool noLoginShell = false)
+        {
+            await ProcessUtil.QuickRun("useradd",
+                $"--comment {username} {(noLoginShell ? "-s /usr/sbin/nologin" : string.Empty)} {username}");
+        }
+
+        public static async Task UserDelete(string username)
+        {
+            await ProcessUtil.QuickRun("userdel", username);
+        }
+
+        public static async Task UserSetId(string username, int id, bool nonUnique = true)
+        {
+            await ProcessUtil.QuickRun("pkill", $"-U {await UserGetId(username)}", false);
+            await ProcessUtil.QuickRun("usermod",
+                $"{(nonUnique ? "--non-unique" : string.Empty)} --uid {id} {username}");
+        }
+
+        public static async Task UserSetPassword(string username, string password, bool passwordIsEncrypted)
+        {
+            if (string.IsNullOrEmpty(password))
+                await ProcessUtil.QuickRun("usermod", $"-p \"*\" {username}");
+            else
+                await ProcessUtil.QuickRun("bash",
+                    $"-c \"echo \\\"{username}:{password}\\\" | chpasswd {(passwordIsEncrypted ? "-e" : string.Empty)} \"");
+        }
+
+        public static async Task<int> UserGetId(string username)
+        {
+            var command = await ProcessUtil.QuickRun("id", $"-u {username}");
+            return int.Parse(command.Output);
+        }
+    }
+}