Add Pagination ability to the Command

#114

Author: ziagham

src/FlowCtl/Commands/Config/ConfigCommand.cs

@@ -10,13 +10,21 @@ internal class ConfigCommand : BaseCommand<ConfigCommandOptions, ConfigCommandOp
 {
     public ConfigCommand() : base("config", Resources.Commands_Config_Description)
     {
+        var pageOption = new Option<int?>(new[] { "-p", "--page" },
+            description: Resources.Commands_FlowSynxPage);
+
+        var pageSizeOption = new Option<int?>(new[] { "-s", "--page-size" },
+            description: Resources.Commands_FlowSynxPageSize);
+
         var addressOption = new Option<string?>(new[] { "-a", "--address" },
             description: Resources.Commands_FlowSynxAddress);
 
         var outputOption = new Option<OutputType>(new[] { "-o", "--output" },
             getDefaultValue: () => OutputType.Json,
             description: Resources.Commands_Output_Format);
 
+        AddOption(pageOption);
+        AddOption(pageSizeOption);
         AddOption(addressOption);
         AddOption(outputOption);
 

src/FlowCtl/Commands/Config/ConfigCommandOptions.cs

@@ -4,6 +4,8 @@ namespace FlowCtl.Commands.Config;
 
 internal class ConfigCommandOptions : ICommandOptions
 {
+    public int? Page { get; set; }
+    public int? PageSize { get; set; }
     public string? Address { get; set; } = string.Empty;
     public OutputType Output { get; set; } = OutputType.Json;
 }

src/FlowCtl/Commands/Config/ConfigCommandOptionsHandler.cs

@@ -2,6 +2,7 @@
 using FlowCtl.Core.Services.Logger;
 using FlowCtl.Extensions;
 using FlowSynx.Client;
+using FlowSynx.Client.Messages.Requests.Workflows;
 
 namespace FlowCtl.Commands.Config;
 
@@ -40,7 +41,13 @@ private async Task Execute(ConfigCommandOptions options, CancellationToken cance
                 _flowSynxClient.SetConnection(connection);
             }
 
-            var result = await _flowSynxClient.PluginConfig.ListAsync(cancellationToken);
+            var request = new PluginConfigListRequest
+            {
+                Page = options.Page,
+                PageSize = options.PageSize
+            };
+
+            var result = await _flowSynxClient.PluginConfig.ListAsync(request, cancellationToken);
 
             if (result.StatusCode != 200)
                 throw new Exception(Resources.Commands_Error_DuringProcessingRequest);

src/FlowCtl/Commands/Logs/LogsCommand.cs

@@ -22,6 +22,12 @@ public LogsCommand() : base("logs", Resources.Commands_Logs_Description)
         var exportPathOption = new Option<string?>(new[] { "-e", "--export-to" },
             description: Resources.Commands_Logs_ExportToOption);
 
+        var pageOption = new Option<int?>(new[] { "-p", "--page" },
+            description: Resources.Commands_FlowSynxPage);
+
+        var pageSizeOption = new Option<int?>(new[] { "-s", "--page-size" },
+            description: Resources.Commands_FlowSynxPageSize);
+
         var addressOption = new Option<string?>(new[] { "-a", "--address" },
             description: Resources.Commands_FlowSynxAddress);
 
@@ -34,6 +40,8 @@ public LogsCommand() : base("logs", Resources.Commands_Logs_Description)
         AddOption(toDateOption);
         AddOption(messageDateOption);
         AddOption(exportPathOption);
+        AddOption(pageOption);
+        AddOption(pageSizeOption);
         AddOption(addressOption);
         AddOption(outputOption);
     }

src/FlowCtl/Commands/Logs/LogsCommandOptions.cs

@@ -9,6 +9,8 @@ internal class LogsCommandOptions : ICommandOptions
     public DateTime? ToDate { get; set; }
     public string? Message { get; set; }
     public string? ExportTo { get; set; }
+    public int? Page { get; set; }
+    public int? PageSize { get; set; }
     public string? Address { get; set; }
     public OutputType Output { get; set; } = OutputType.Json;
 }

src/FlowCtl/Commands/Logs/LogsCommandOptionsHandler.cs

@@ -43,7 +43,9 @@ private async Task Execute(LogsCommandOptions options, CancellationToken cancell
                 Level = options.Level, 
                 FromDate = options.FromDate, 
                 ToDate = options.ToDate, 
-                Message = options.Message
+                Message = options.Message,
+                Page = options.Page,
+                PageSize = options.PageSize
             };
             var result = await _flowSynxClient.Logs.ListAsync(request, cancellationToken);
 

src/FlowCtl/Commands/Plugins/PluginsCommand.cs

@@ -11,13 +11,21 @@ internal class PluginsCommand : BaseCommand<PluginsCommandOptions, PluginsComman
 {
     public PluginsCommand() : base("plugins", Resources.Commands_Plugins_Description)
     {
+        var pageOption = new Option<int?>(new[] { "-p", "--page" },
+            description: Resources.Commands_FlowSynxPage);
+
+        var pageSizeOption = new Option<int?>(new[] { "-s", "--page-size" },
+            description: Resources.Commands_FlowSynxPageSize);
+
         var addressOption = new Option<string?>(new[] { "-a", "--address" },
             description: Resources.Commands_FlowSynxAddress);
 
         var outputOption = new Option<OutputType>(new[] { "-o", "--output" },
             getDefaultValue: () => OutputType.Json,
             description: Resources.Commands_Output_Format);
 
+        AddOption(pageOption);
+        AddOption(pageSizeOption);
         AddOption(addressOption);
         AddOption(outputOption);
 

src/FlowCtl/Commands/Plugins/PluginsCommandOptions.cs

@@ -4,6 +4,8 @@ namespace FlowCtl.Commands.Plugins;
 
 internal class PluginsCommandOptions : ICommandOptions
 {
+    public int? Page { get; set; }
+    public int? PageSize { get; set; }
     public string? Address { get; set; } = string.Empty;
     public OutputType Output { get; set; } = OutputType.Json;
 }

src/FlowCtl/Commands/Plugins/PluginsCommandOptionsHandler.cs

@@ -2,6 +2,7 @@
 using FlowCtl.Core.Services.Logger;
 using FlowCtl.Extensions;
 using FlowSynx.Client;
+using FlowSynx.Client.Messages.Requests.Workflows;
 
 namespace FlowCtl.Commands.Plugins;
 
@@ -40,7 +41,13 @@ private async Task Execute(PluginsCommandOptions options, CancellationToken canc
                 _flowSynxClient.SetConnection(connection);
             }
 
-            var result = await _flowSynxClient.Plugins.ListAsync(cancellationToken);
+            var request = new PluginsListRequest
+            {
+                Page = options.Page,
+                PageSize = options.PageSize
+            };
+
+            var result = await _flowSynxClient.Plugins.ListAsync(request, cancellationToken);
 
             if (result.StatusCode != 200)
                 throw new Exception(Resources.Commands_Error_DuringProcessingRequest);

src/FlowCtl/Commands/Workflows/Executions/Approvals/WorkflowExecutionLogsCommandOptions.cs

@@ -6,6 +6,8 @@ internal class WorkflowExecutionPendingApprovalsCommandOptions : ICommandOptions
 {
     public required string WorkflowId { get; set; }
     public required string ExecutionId { get; set; }
+    public int? Page { get; set; }
+    public int? PageSize { get; set; }
     public string? Address { get; set; } = string.Empty;
     public OutputType Output { get; set; } = OutputType.Json;
 }