Adds Checkpoint Pagination support for fetching all connections

src/Auth0.ManagementApi/Clients/ConnectionsClient.cs

@@ -15,6 +15,7 @@ namespace Auth0.ManagementApi.Clients
     public class ConnectionsClient : BaseClient, IConnectionsClient
     {
         private readonly JsonConverter[] _converters = { new PagedListConverter<Connection>("connections") };
+        readonly JsonConverter[] checkpointPaginationConverter = new JsonConverter[] { new CheckpointPagedListConverter<Connection>("connections") };
         private readonly JsonConverter[] _defaultMappingsConverter = { new ListConverter<ScimMapping>("mapping") };
 
         /// <summary>
@@ -122,6 +123,46 @@ public Task<IPagedList<Connection>> GetAllAsync(GetConnectionsRequest request, P
             return Connection.GetAsync<IPagedList<Connection>>(BuildUri("connections", queryStrings), DefaultHeaders, _converters, cancellationToken);
         }
 
+        /// <summary>
+        /// Retrieves every connection matching the specified strategy.
+        /// All connections are retrieved if no strategy is being specified.
+        /// Accepts a list of fields to include or exclude in the resulting list of connection objects.
+        /// </summary>
+        /// <param name="request"><see cref="GetConnectionsRequest"/></param>
+        /// <param name="pagination"><see cref="CheckpointPaginationInfo"/></param>
+        /// <param name="cancellationToken"><see cref="CancellationToken"/></param>
+        /// <returns>List of <see cref="Connection"/></returns>
+        public Task<ICheckpointPagedList<Connection>> GetAllAsync(GetConnectionsRequest request, CheckpointPaginationInfo pagination = null,
+            CancellationToken cancellationToken = default)
+        {
+            if (request == null)
+                throw new ArgumentNullException(nameof(request));
+
+            var queryStrings = new Dictionary<string, string>
+            {
+                {"fields", request.Fields},
+                {"include_fields", request.IncludeFields?.ToString().ToLower()},
+                {"name", request.Name},
+            };
+
+            if (pagination != null)
+            {
+                queryStrings["from"] = pagination.From?.ToString();
+                queryStrings["take"] = pagination.Take.ToString();
+            }
+
+            // Add each strategy as a separate querystring
+            if (request.Strategy != null)
+            {
+                for (var i = 0; i < request.Strategy.Length; i++)
+                {
+                    queryStrings.Add($"strategy[{i}]", request.Strategy[i]);
+                }
+            }
+
+            return Connection.GetAsync<ICheckpointPagedList<Connection>>(BuildUri("connections", queryStrings), DefaultHeaders, checkpointPaginationConverter, cancellationToken);
+        }
+
         /// <summary>
         /// Updates a connection.
         /// </summary>

src/Auth0.ManagementApi/Clients/IConnectionsClient.cs

@@ -56,6 +56,15 @@ public interface IConnectionsClient
     /// <param name="cancellationToken">The cancellation token to cancel operation.</param>
     /// <returns>An <see cref="IPagedList{Connection}"/> containing the list of connections.</returns>
     Task<IPagedList<Connection>> GetAllAsync(GetConnectionsRequest request, PaginationInfo pagination = null, CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// Retrieves every connection matching the specified strategy. All connections are retrieved if no strategy is being specified. Accepts a list of fields to include or exclude in the resulting list of connection objects.
+    /// </summary>
+    /// <param name="request">Specifies criteria to use when querying connections.</param>
+    /// <param name="pagination">Specifies the CheckPoint Pagination info <see cref="CheckpointPaginationInfo"/></param>
+    /// <param name="cancellationToken">The cancellation token to cancel operation.</param>
+    /// <returns>An <see cref="ICheckpointPagedList{Connection}"/> containing the list of connections.</returns>
+    Task<ICheckpointPagedList<Connection>> GetAllAsync(GetConnectionsRequest request, CheckpointPaginationInfo pagination = null, CancellationToken cancellationToken = default);
 
     /// <summary>
     /// Updates a connection.

tests/Auth0.IntegrationTests.Shared/CleanUp/ConnectionsCleanUpStrategy.cs

@@ -13,7 +13,6 @@ public ConnectionsCleanUpStrategy(ManagementApiClient apiClient) : base(CleanUpT
         public override async Task Run(string id)
         {
             System.Diagnostics.Debug.WriteLine("Running ConnectionsCleanUpStrategy");
-            var connections = await ApiClient.Connections.GetAllAsync(new ManagementApi.Models.GetConnectionsRequest { });
             await ApiClient.Connections.DeleteAsync(id);        
         }
     }

tests/Auth0.ManagementApi.IntegrationTests/ConnectionTests.cs

@@ -11,7 +11,7 @@
 using System.Collections.Generic;
 using Auth0.AuthenticationApi.Models;
 using Auth0.ManagementApi.Models.Connections;
 using Auth0.Tests.Shared;
 using Newtonsoft.Json;
 
 namespace Auth0.ManagementApi.IntegrationTests
@@ -195,6 +195,17 @@
             // Assert
             Assert.Null(connections.Paging);
         }
+
+        [Fact]
+        public async Task Test_get_all_with_checkpoint_pagination()
+        {
+            // Act
+            var connections = await fixture.ApiClient.Connections.GetAllAsync(
+                new GetConnectionsRequest(), new CheckpointPaginationInfo(10));
+
+            // Assert
+            connections.Count.Should().Be(10);
+        }
 
         [Fact]
         public async Task Test_paging_does_not_include_totals()