FindManyAsync

Author: borigas

src/CouchDB.Driver/CouchDatabase.cs

@@ -236,6 +236,20 @@ public async Task<TSource> FindAsync(string docId, bool withConflicts = false)
             }
         }
 
+        public async Task<List<TSource>> FindManyAsync(string[] docIds)
+        {
+            var bulkGetResult = await NewRequest()
+                .AppendPathSegment("_bulk_get")
+                .PostJsonAsync(new
+                {
+                    docs = docIds.Select(id => new { id })
+                }).ReceiveJson<BulkGetResult<TSource>>()
+                .SendRequestAsync()
+                .ConfigureAwait(false);
+
+            return bulkGetResult.Results.SelectMany(r => r.Docs).Select(d => d.Item).ToList();
+        }
+
         #endregion
 
         #region Writing
@@ -345,7 +359,7 @@ public async Task<IEnumerable<TSource>> CreateOrUpdateRangeAsync(IEnumerable<TSo
                 .SendRequestAsync()
                 .ConfigureAwait(false);
 
-            IEnumerable<(TSource Document, DocumentSaveResponse SaveResponse)> zipped = 
+            IEnumerable<(TSource Document, DocumentSaveResponse SaveResponse)> zipped =
                 documents.Zip(response, (doc, saveResponse) => (Document: doc, SaveResponse: saveResponse));
 
             foreach ((TSource document, DocumentSaveResponse saveResponse) in zipped)

src/CouchDB.Driver/DTOs/BulkGetResult.cs

@@ -0,0 +1,30 @@
+using CouchDB.Driver.Types;
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CouchDB.Driver.DTOs
+{
+#pragma warning disable CA1812 // Avoid uninstantiated internal classes
+    internal class BulkGetResult<TSource> where TSource : CouchDocument
+    {
+        [JsonProperty("results")]
+        public List<BulkGetResultDoc<TSource>> Results { get; set; }
+    }
+
+    internal class BulkGetResultDoc<TSource> where TSource : CouchDocument
+    {
+        [JsonProperty("docs")]
+        public List<BulkGetResultItem<TSource>> Docs { get; set; }
+    }
+
+    internal class BulkGetResultItem<TSource> where TSource : CouchDocument
+    {
+        [JsonProperty("ok")]
+        public TSource Item { get; set; }
+    }
+#pragma warning restore CA1812 // Avoid uninstantiated internal classes
+}