Added pagination

bb-io · Sep 5, 2024 · 5268a86 · 5268a86
1 parent 0433760
commit 5268a86
Show file tree

Hide file tree

Showing 4 changed files with 41 additions and 34 deletions.
diff --git a/Apps.XTM/Actions/LqaActions.cs b/Apps.XTM/Actions/LqaActions.cs
@@ -17,12 +17,8 @@
 namespace Apps.XTM.Actions
 {
     [ActionList]
-    public class LqaActions : XtmInvocable
+    public class LqaActions(InvocationContext invocationContext) : XtmInvocable(invocationContext)
     {
-        public LqaActions(InvocationContext invocationContext) : base(invocationContext)
-        {
-        }
-
         [Action("Search LQA reports", Description = "Define criteria to search LQA reports")]
         public async Task<List<LqaResponse>> SearchLqa([ActionParameter] LQARequest input)
         {

diff --git a/Apps.XTM/Actions/ProjectActions.cs b/Apps.XTM/Actions/ProjectActions.cs
@@ -19,25 +19,43 @@
 namespace Apps.XTM.Actions;
 
 [ActionList]
-public class ProjectActions : XtmInvocable
+public class ProjectActions(InvocationContext invocationContext, IFileManagementClient fileManagementClient)
+    : XtmInvocable(invocationContext)
 {
-    private readonly IFileManagementClient _fileManagementClient;
-
-    public ProjectActions(InvocationContext invocationContext, IFileManagementClient fileManagementClient) 
-        : base(invocationContext)
-    {
-        _fileManagementClient = fileManagementClient;
-    }
-
+    private const int PageSize = 100;
+
     [Action("List projects", Description = "List all projects")]
     public async Task<ListProjectsResponse> ListProjects()
     {
-        var response = await Client.ExecuteXtmWithJson<List<SimpleProject>>(ApiEndpoints.Projects,
-            Method.Get,
-            null,
-            Creds);
+        var page = 1;
+        var hasMorePages = true;
+        var allProjects = new List<SimpleProject>();
+
+        while (hasMorePages)
+        {
+            var queryParams = new Dictionary<string, string>
+            {
+                { "page", page.ToString() },
+                { "pageSize", PageSize.ToString() }
+            };
+
+            var response = await Client.ExecuteXtmWithJson<List<SimpleProject>?>(ApiEndpoints.Projects,
+                Method.Get,
+                queryParams,
+                Creds);
+
+            if (response != null && response.Any())
+            {
+                allProjects.AddRange(response);
+                page++;
+            }
+            else
+            {
+                hasMorePages = false;
+            }
+        }
 
-        return new(response);
+        return new ListProjectsResponse(allProjects);
     }
 
     [Action("Get project", Description = "Get project")]
@@ -209,7 +227,7 @@ public async Task<FileResponse> DownloadMetrics(
         var response = await Client.ExecuteXtmWithJson(endpoint, Method.Get, null, Creds);
 
         using var stream = new MemoryStream(response.RawBytes);
-        var file = await _fileManagementClient.UploadAsync(stream,
+        var file = await fileManagementClient.UploadAsync(stream,
             response.ContentType ?? MediaTypeNames.Application.Octet, $"{project.ProjectId}.xlsx");
         return new(file);
     }

diff --git a/Apps.XTM/Apps.XTM.csproj b/Apps.XTM/Apps.XTM.csproj
@@ -4,7 +4,7 @@
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <Product>XTM</Product>
-        <Version>3.2.3</Version>
+        <Version>3.2.4</Version>
         <Description>Translation management system that centralizes localization assets and enables fast, accurate translation and deployment of content tailored to any audience in any territory</Description>
         <AssemblyName>Apps.XTM</AssemblyName>
         <LangVersion>12</LangVersion>

diff --git a/Apps.XTM/DataSourceHandlers/ProjectDataHandler.cs b/Apps.XTM/DataSourceHandlers/ProjectDataHandler.cs
@@ -1,26 +1,19 @@
-using Apps.XTM.Constants;
+using Apps.XTM.Actions;
 using Apps.XTM.Invocables;
-using Apps.XTM.Models.Response.Projects;
 using Blackbird.Applications.Sdk.Common.Dynamic;
 using Blackbird.Applications.Sdk.Common.Invocation;
-using RestSharp;
 
 namespace Apps.XTM.DataSourceHandlers;
 
-public class ProjectDataHandler : XtmInvocable, IAsyncDataSourceHandler
+public class ProjectDataHandler(InvocationContext invocationContext)
+    : XtmInvocable(invocationContext), IAsyncDataSourceHandler
 {
-    public ProjectDataHandler(InvocationContext invocationContext) : base(invocationContext)
-    {
-    }
-
     public async Task<Dictionary<string, string>> GetDataAsync(DataSourceContext context, CancellationToken cancellationToken)
     {
-        var response = await Client.ExecuteXtmWithJson<List<SimpleProject>>(ApiEndpoints.Projects,
-            Method.Get,
-            null,
-            Creds);
+        var actions = new ProjectActions(InvocationContext, null!);
+        var response = await actions.ListProjects();
 
-        return response
+        return response.Projects
             .Where(x => context.SearchString == null || x.Name.Contains(context.SearchString, StringComparison.OrdinalIgnoreCase))
             .Take(20)
             .ToDictionary(x => x.Id, x => x.Name);