Added feature to save local user settings + first setting FullyQualifiedNamespaces

wenzzzel · wenzzzel · commit 9ef92ff76362 · 2025-10-01T17:05:41.000+02:00
diff --git a/servicebus-cli/Models/UserSettings.cs b/servicebus-cli/Models/UserSettings.cs
@@ -0,0 +1,6 @@
+namespace servicebus_cli.Models;
+
+public class UserSettings
+{
+    public List<string> FullyQualifiedNamespaces { get; set; } = new List<string>();
+}
diff --git a/servicebus-cli/Program.cs b/servicebus-cli/Program.cs
@@ -12,8 +12,11 @@ public static async Task Main(string[] args)
         var serviceProvider = new ServiceCollection()
             .AddSingleton<IServiceBusCli, ServiceBusCli>()
             .AddSingleton<IDeadletter, Deadletter>()
+            .AddSingleton<ISettings, Settings>()
             .AddSingleton<IQueue, Queue>()
             .AddSingleton<IServiceBusService, ServiceBusService>()
+            .AddSingleton<IFileService, FileService>()
+            .AddSingleton<IUserSettingsService, UserSettingsService>()
             .AddSingleton<IServiceBusRepository, ServiceBusRepository>()
             .AddSingleton<IHelp, Help>()
             .BuildServiceProvider();
diff --git a/servicebus-cli/ServiceBusCli.cs b/servicebus-cli/ServiceBusCli.cs
@@ -13,11 +13,13 @@ public class ServiceBusCli : IServiceBusCli
     private IDeadletter _deadletter;
     private IQueue queue;
     private IHelp _help;
+    private ISettings _settings;
 
-    public ServiceBusCli(IDeadletter deadletter, IHelp help, IQueue queue)
+    public ServiceBusCli(IDeadletter deadletter, IHelp help, IQueue queue, ISettings settings)
     {
         _help = help;
         _deadletter = deadletter;
+        _settings = settings;
         this.queue = queue;
     }
 
@@ -34,6 +36,7 @@ public async Task Run(string[] args)
                     .AddChoices(
                         "deadletter",
                         "queue",
+                        "settings",
                         "help"
                     )
             );
@@ -53,6 +56,9 @@ public async Task Run(string[] args)
             case "queue":
                 await queue.Run(args.Skip(1).ToArray());
                 break;
+            case "settings":
+                await _settings.Run(args.Skip(1).ToArray());
+                break;
             default:
                 _help.Run();
                 break;
diff --git a/servicebus-cli/Services/FileService.cs b/servicebus-cli/Services/FileService.cs
@@ -0,0 +1,43 @@
+using Azure.Messaging.ServiceBus;
+using Azure.Messaging.ServiceBus.Administration;
+using servicebus_cli.Models;
+using servicebus_cli.Repositories;
+using System.Text.RegularExpressions;
+
+namespace servicebus_cli.Services;
+
+public interface IFileService
+{
+    string GetConfigFileContent();
+    void SetConfigFileContent(string content);
+}
+
+public class FileService() : IFileService
+{
+    public string GetConfigFileContent()
+    {
+        var homePath = Environment.GetFolderPath(Environment.SpecialFolder.UserProfile);
+        var configFilePath = Path.Combine(homePath, ".servicebus-cli", "config.json"); //TODO: Is this working on Windows?
+
+        if (!File.Exists(configFilePath))
+        {
+            return string.Empty;
+        }
+
+        return File.ReadAllText(configFilePath);
+    }
+
+    public void SetConfigFileContent(string content)
+    {
+        var homePath = Environment.GetFolderPath(Environment.SpecialFolder.UserProfile);
+        var configDirectoryPath = Path.Combine(homePath, ".servicebus-cli");
+        var configFilePath = Path.Combine(configDirectoryPath, "config.json"); //TODO: Is this working on Windows?
+
+        if (!Directory.Exists(configDirectoryPath))
+        {
+            Directory.CreateDirectory(configDirectoryPath);
+        }
+
+        File.WriteAllText(configFilePath, content);
+    }
+}
diff --git a/servicebus-cli/Services/UserSettingsService.cs b/servicebus-cli/Services/UserSettingsService.cs
@@ -0,0 +1,29 @@
+using servicebus_cli.Models;
+
+namespace servicebus_cli.Services;
+
+public interface IUserSettingsService
+{
+    string Serialize(UserSettings settings);
+    UserSettings Deserialize(string content);
+}
+
+public class UserSettingsService() : IUserSettingsService
+{
+    public string Serialize(UserSettings settings)
+    {
+        return System.Text.Json.JsonSerializer.Serialize(
+            settings,
+            new System.Text.Json.JsonSerializerOptions { WriteIndented = true });
+    }
+
+    public UserSettings Deserialize(string content)
+    {
+        if (string.IsNullOrWhiteSpace(content))
+        {
+            return new UserSettings();
+        }
+
+        return System.Text.Json.JsonSerializer.Deserialize<UserSettings>(content) ?? new UserSettings();
+    }
+}
diff --git a/servicebus-cli/Subjects/Deadletter.cs b/servicebus-cli/Subjects/Deadletter.cs
@@ -13,11 +13,16 @@ public class Deadletter : IDeadletter
 {
     private readonly IHelp _helpService;
     private readonly IServiceBusService _serviceBusService;
+    private readonly IFileService _fileService;
+    private readonly IUserSettingsService _userSettingsService;
 
-    public Deadletter(IHelp helpService, IServiceBusService serviceBusRepostitory)
+
+    public Deadletter(IHelp helpService, IServiceBusService serviceBusRepostitory, IFileService fileService, IUserSettingsService userSettingsService)
     {
         _helpService = helpService;
         _serviceBusService = serviceBusRepostitory;
+        _fileService = fileService;
+        _userSettingsService = userSettingsService;
     }
 
     public async Task Run(string[] args)
@@ -60,6 +65,8 @@ private async Task Resend(List<string> args)
     {
         var fullyQualifiedNamespace = "";
         var entityPath = "";
+        var settingsFileContent = _fileService.GetConfigFileContent();
+        var savedNamespaces = _userSettingsService.Deserialize(settingsFileContent);
 
         switch (args.Count)
         {
@@ -68,9 +75,22 @@ private async Task Resend(List<string> args)
                 entityPath = args[1];
                 break;
             default:
-                fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
-                    new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:")
-                );
+                if (!savedNamespaces.FullyQualifiedNamespaces.Any())
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:")
+                    );
+                }
+                else
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new SelectionPrompt<string>()
+                            .Title("Select a fully qualified namespace:")
+                            .PageSize(10)
+                            .AddChoices(savedNamespaces.FullyQualifiedNamespaces)
+                    );
+                    AnsiConsole.MarkupLine($"[grey]Selected fully qualified namespace: {fullyQualifiedNamespace}[/]");
+                }
 
                 var queues = await AnsiConsole.Status()
                     .StartAsync($"Fetching queues on {fullyQualifiedNamespace}...", async ctx =>
@@ -90,7 +110,9 @@ private async Task Resend(List<string> args)
                         .AddChoices(queues.Select(q => $"{q.QueueProperties.Name} ([green]{q.QueueRuntimeProperties.ActiveMessageCount}[/], [red]{q.QueueRuntimeProperties.DeadLetterMessageCount}[/], [blue]{q.QueueRuntimeProperties.ScheduledMessageCount}[/])").ToList())
                 );
                 entityPath = selectedQueue.Split(' ')[0];
-                    
+
+                AnsiConsole.MarkupLine($"[grey]Selected queue: {entityPath}[/]");
+
                 break;
         }
 
@@ -144,6 +166,8 @@ private async Task Purge(List<string> args)
     {
         var fullyQualifiedNamespace = "";
         var entityPath = "";
+        var settingsFileContent = _fileService.GetConfigFileContent();
+        var savedNamespaces = _userSettingsService.Deserialize(settingsFileContent);
 
         switch (args.Count)
         {
@@ -152,9 +176,22 @@ private async Task Purge(List<string> args)
                 entityPath = args[1];
                 break;
             default:
-                fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
-                    new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:")
-                );
+                if (!savedNamespaces.FullyQualifiedNamespaces.Any())
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:") //Here
+                    );
+                }
+                else
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new SelectionPrompt<string>()
+                            .Title("Select a fully qualified namespace:")
+                            .PageSize(10)
+                            .AddChoices(savedNamespaces.FullyQualifiedNamespaces)
+                    );
+                    AnsiConsole.MarkupLine($"[grey]Selected fully qualified namespace: {fullyQualifiedNamespace}[/]");
+                }
 
                 var queues = await AnsiConsole.Status()
                     .StartAsync($"Fetching queues on {fullyQualifiedNamespace}...", async ctx =>
@@ -164,7 +201,7 @@ private async Task Purge(List<string> args)
 
                         return await _serviceBusService.GetInformationAboutAllQueues(fullyQualifiedNamespace).ConfigureAwait(false);
                     });
-                
+
                 var selectedQueue = await AnsiConsole.PromptAsync(
                     new SelectionPrompt<string>()
                         .Title("Select a [green]queue[/]:")
@@ -173,6 +210,9 @@ private async Task Purge(List<string> args)
                         .AddChoices(queues.Select(q => $"{q.QueueProperties.Name} ([green]{q.QueueRuntimeProperties.ActiveMessageCount}[/], [red]{q.QueueRuntimeProperties.DeadLetterMessageCount}[/], [blue]{q.QueueRuntimeProperties.ScheduledMessageCount}[/])").ToList())
                 );
                 entityPath = selectedQueue.Split(' ')[0];
+
+                AnsiConsole.MarkupLine($"[grey]Selected queue: {entityPath}[/]");
+                
                 break;
         }
 
diff --git a/servicebus-cli/Subjects/Help.cs b/servicebus-cli/Subjects/Help.cs
@@ -50,6 +50,19 @@ public void Run()
         listNode.AddNode("[dim]<FullyQualifiedNamespace>[/] - Service Bus namespace");
         listNode.AddNode("[dim]<Filter>[/] - Optional filter pattern");
 
+        // Settings branch
+        var settingsNode = tree.AddNode("[bold yellow]settings[/] - Local settings management operations");
+        
+        var getNode = settingsNode.AddNode("[green]get[/] - Get local user setting");
+        getNode.AddNode("[dim]<SettingName>[/] - Name of the setting to get. Available settings are: FullyQualifiedNamespaces");
+
+        var setNode = settingsNode.AddNode("[green]set[/] - Set local user setting");
+        setNode.AddNode("[dim]<SettingName>[/] - Name of the setting to set. Available settings are: FullyQualifiedNamespaces");
+        setNode.AddNode("[dim]<SettingValue>[/] - Value to set for the setting");
+
+        // Help branch
+        var _ = tree.AddNode("[bold yellow]help[/] - Displays the help section");
+
         // Render the tree
         AnsiConsole.Write(tree);
         AnsiConsole.WriteLine();
diff --git a/servicebus-cli/Subjects/Queue.cs b/servicebus-cli/Subjects/Queue.cs
@@ -12,11 +12,15 @@ public class Queue : IQueue
 {
     private readonly IHelp _helpService;
     private readonly IServiceBusService _serviceBusService;
+    private readonly IFileService _fileService;
+    private readonly IUserSettingsService _userSettingsService;
 
-    public Queue(IHelp helpService, IServiceBusService serviceBusRepostitory)
+    public Queue(IHelp helpService, IServiceBusService serviceBusRepostitory, IFileService fileService, IUserSettingsService settingsService)
     {
         _helpService = helpService;
+        _fileService = fileService;
         _serviceBusService = serviceBusRepostitory;
+        _userSettingsService = settingsService;
     }
 
     public async Task Run(string[] args)
@@ -55,6 +59,8 @@ private async Task List(List<string> args)
     {
         var fullyQualifiedNamespace = "";
         var filter = "";
+        var settingsFileContent = _fileService.GetConfigFileContent();
+        var savedNamespaces = _userSettingsService.Deserialize(settingsFileContent);
 
         switch (args.Count)
         {
@@ -66,9 +72,23 @@ private async Task List(List<string> args)
                 filter = args[1];
                 break;
             default:
-                fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
-                    new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:")
-                );
+                if (!savedNamespaces.FullyQualifiedNamespaces.Any())
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new TextPrompt<string>("Enter the [green]fully qualified namespace[/]:")
+                    );
+                }
+                else
+                {
+                    fullyQualifiedNamespace = await AnsiConsole.PromptAsync(
+                        new SelectionPrompt<string>()
+                            .Title("Select a fully qualified namespace:")
+                            .PageSize(10)
+                            .AddChoices(savedNamespaces.FullyQualifiedNamespaces)
+                    );
+                    AnsiConsole.MarkupLine($"[grey]Selected fully qualified namespace: {fullyQualifiedNamespace}[/]");
+                }
+
                 filter = await AnsiConsole.PromptAsync(
                     new TextPrompt<string>("Enter a [green]filter[/] (optional):")
                         .AllowEmpty()
diff --git a/servicebus-cli/Subjects/Settings.cs b/servicebus-cli/Subjects/Settings.cs
