Added MultiPrecolate

Author: Gabriel Moskovicz

src/Nest/DSL/MultiPercolateDescriptor.cs

@@ -50,7 +50,18 @@ public MultiPercolateDescriptor Percolate<T>(Func<PercolateDescriptor<T>, Percol
 			var descriptor = getSelector(new PercolateDescriptor<T>().Index<T>().Type<T>());
 			Self.Percolations.Add(descriptor);
 			return this;
+		}
 
+		public MultiPercolateDescriptor PercolateMany<T>(IEnumerable<T> sources, Func<PercolateDescriptor<T>, T, PercolateDescriptor<T>> getSelector)
+			where T : class
+		{
+			foreach (var source in sources)
+			{
+				getSelector.ThrowIfNull("getSelector");
+				var descriptor = getSelector(new PercolateDescriptor<T>().Index<T>().Type<T>(), source);
+				Self.Percolations.Add(descriptor);
+			}
+			return this;
 		}
 
 		public MultiPercolateDescriptor Count<T>(Func<PercolateCountDescriptor<T>, PercolateCountDescriptor<T>> getSelector) 
@@ -60,8 +71,8 @@ public MultiPercolateDescriptor Count<T>(Func<PercolateCountDescriptor<T>, Perco
 			var descriptor = getSelector(new PercolateCountDescriptor<T>().Index<T>().Type<T>());
 			Self.Percolations.Add(descriptor);
 			return this;
-
 		}
+
 		protected override void UpdatePathInfo(IConnectionSettingsValues settings, ElasticsearchPathInfo<MultiPercolateRequestParameters> pathInfo)
 		{
 			MultiPercolatePathInfo.Update(pathInfo, this);

src/Tests/Nest.Tests.Integration/Core/MultiPercolate/MultiPercolateTests.cs

@@ -103,5 +103,76 @@ public void MultiPercolate_ReturnsExpectedResults()
 			errorResponse.ServerError.Error.Should().NotBeNullOrWhiteSpace();
 
 		}
+
+
+		[Test]
+		public void MultiPercolate_PrecolateMany_ReturnsExpectedResults()
+		{
+
+			//lets start fresh using a new index
+			var indexName = ElasticsearchConfiguration.NewUniqueIndexName();
+			IntegrationSetup.CreateTestIndex(this.Client, indexName);
+
+			// lets register several percolators in our new index that do a term match
+			// on document name == indexname
+			// we associate some metadata with the percolator so that we can later filter
+			// the ones we want to execute easier
+			foreach (var i in Enumerable.Range(0, 10))
+			{
+				var registerPercolator = this.Client.RegisterPercolator(new RegisterPercolatorRequest(indexName, "my-percolator-" + i)
+				{
+					Query = new TermQuery
+					{
+						Field = Property.Path<ElasticsearchProject>(p => p.Name.Suffix("sort")),
+						Value = indexName
+					},
+					MetaData = new Dictionary<string, object>
+					{
+						{ "order", i}
+					}
+				});
+				registerPercolator.IsValid.Should().BeTrue();
+			}
+
+
+			// Set up 2 projects to index both with indexName as Name
+			var projects = Enumerable.Range(0, 2)
+				.Select(i => new ElasticsearchProject { Id = 1337 + i, Name = indexName })
+				.ToList();
+			this.Client.IndexMany(projects, indexName);
+
+			this.Client.Refresh(r => r.Index(indexName));
+
+
+			//Now we kick of multiple percolations
+			var multiPercolateResponse = this.Client.MultiPercolate(mp => mp
+				//provding document in the percolate request 
+				.PercolateMany(projects, (perc, proj) =>
+					perc.Index(indexName).Document(proj)
+				)
+			);
+
+			multiPercolateResponse.IsValid.Should().BeTrue();
+
+			var percolateResponses = multiPercolateResponse.Responses.ToList();
+			percolateResponses.Should().NotBeEmpty().And.HaveCount(4);
+
+			var percolateResponse = percolateResponses[0];
+			percolateResponse.Total.Should().Be(10);
+			percolateResponse.Matches.Should().HaveCount(10);
+
+			var existingResponse = percolateResponses[1];
+			existingResponse.Total.Should().Be(10);
+			existingResponse.Matches.Should().HaveCount(10);
+
+			var countResponse = percolateResponses[2];
+			countResponse.Total.Should().Be(2);
+			countResponse.Matches.Should().BeNull();
+
+			var errorResponse = percolateResponses[3];
+			errorResponse.Total.Should().Be(0);
+			errorResponse.ServerError.Error.Should().NotBeNullOrWhiteSpace();
+
+		}
 	}
 }