Feature/revision limits

src/CouchDB.Driver/CouchDatabase.cs

@@ -717,6 +717,34 @@ public async Task<CouchDatabaseInfo> GetInfoAsync(CancellationToken cancellation
                 .ConfigureAwait(false);
         }
 
+        /// <inheritdoc />
+        public async Task<int> GetRevisionLimitAsync(CancellationToken cancellationToken = default)
+        {
+            return Convert.ToInt32(await NewRequest()
+                .AppendPathSegment("_revs_limit")
+                .GetStringAsync(cancellationToken)
+                .SendRequestAsync()
+                .ConfigureAwait(false));
+        }
+
+        /// <inheritdoc />
+        public async Task SetRevisionLimitAsync(int limit, CancellationToken cancellationToken = default)
+        {
+            using var content = new StringContent(limit.ToString());
+
+            OperationResult result = await NewRequest()
+                .AppendPathSegment("_revs_limit")
+                .PutAsync(content, cancellationToken)
+                .ReceiveJson<OperationResult>()
+                .SendRequestAsync()
+                .ConfigureAwait(false);
+
+            if (!result.Ok)
+            {
+                throw new CouchException("Something wrong happened while updating the revision limit.");
+            }
+        }
+
         #endregion
 
         #region Override

src/CouchDB.Driver/ICouchDatabase.cs

@@ -295,6 +295,21 @@ Task<string> DownloadAttachmentAsync(CouchAttachment attachment, string localFol
         /// <returns>A task that represents the asynchronous operation. The task result contains the database information.</returns>
         Task<CouchDatabaseInfo> GetInfoAsync(CancellationToken cancellationToken = default);
 
+        /// <summary>
+        /// Gets the revision limit for the specified database.
+        /// </summary>
+        /// <param name="cancellationToken">A <see cref="CancellationToken" /> to observe while waiting for the task to complete.</param>
+        /// <returns>A task that represents the asynchronous operation. The task result contains the database information.</returns>
+        Task<int> GetRevisionLimitAsync(CancellationToken cancellationToken = default);
+
+        /// <summary>
+        /// Sets the revision limit for the specified database.
+        /// </summary>
+        /// <param name="limit">The limit to set.</param>
+        /// <param name="cancellationToken">A <see cref="CancellationToken" /> to observe while waiting for the task to complete.</param>
+        /// <returns>A task that represents the asynchronous operation. The task result contains the database information.</returns>
+        Task SetRevisionLimitAsync(int limit, CancellationToken cancellationToken = default);
+
         /// <summary>
         /// Get an empty request that targets the current database.
         /// </summary>

tests/CouchDB.Driver.UnitTests/Database_Tests.cs

@@ -709,6 +709,29 @@ public async Task SecurityInfo_Put()
                 .WithRequestJson(securityInfo);
         }
 
+
+        [Fact]
+        public async Task GetRevLimit()
+        {
+            using var httpTest = new HttpTest();
+            await _rebels.GetRevisionLimitAsync();
+            httpTest
+                .ShouldHaveCalled("http://localhost/rebels/_rev_limit")
+                .WithVerb(HttpMethod.Get);
+        }
+
+        [Fact]
+        public async Task SetRevLimit()
+        {
+            using var httpTest = new HttpTest();
+            // Operation response
+            httpTest.RespondWithJson(new { ok = true });
+
+            await _rebels.SetRevisionLimitAsync(10);
+            httpTest
+                .ShouldHaveCalled("http://localhost/rebels/_rev_limit")
+                .WithVerb(HttpMethod.Put);
+        }
         #endregion
 
         public ValueTask DisposeAsync()