feat: add array contains matcher

samples/OrdersApi/Consumer.Tests/OrdersClientTests.cs

@@ -84,6 +84,58 @@ await this.pact.VerifyAsync(async ctx =>
             });
         }
 
+        [Fact]
+        public async Task GetOrdersAsync_WhenCalled_ReturnsMultipleOrders()
+        {
+            var expected1 = new OrderDto(1, OrderStatus.Pending, new DateTimeOffset(2023, 6, 28, 12, 13, 14, TimeSpan.FromHours(1)));
+            var expected2 = new OrderDto(2, OrderStatus.Pending, new DateTimeOffset(2023, 6, 29, 12, 13, 14, TimeSpan.FromHours(1)));
+
+            this.pact
+                .UponReceiving("a request for multiple orders by id")
+                .Given("orders with ids {ids} exist", new Dictionary<string, string> { ["ids"] = "1,2" })
+                .WithRequest(HttpMethod.Get, "/api/orders/many/1,2")
+                .WithHeader("Accept", "application/json")
+                .WillRespond()
+                .WithStatus(HttpStatusCode.OK)
+                .WithJsonBody(Match.ArrayContains(new dynamic[]
+                {
+                    new
+                    {
+                        Id = Match.Integer(expected1.Id),
+                        Status = Match.Regex(expected1.Status.ToString(), string.Join("|", Enum.GetNames<OrderStatus>())),
+                        Date = Match.Type(expected1.Date.ToString("O"))
+                    },
+                    new
+                    {
+                        Id = Match.Integer(expected2.Id),
+                        Status = expected2.Status,
+                        Date = Match.Regex("2023-06-29T12:13:14.000000+01:00", @"\d\d\d\d-\d\d-\d\dT\d\d:\d\d:\d\d\.\d\d\d\d\d\d+\d\d:\d\d")
+                    },
+                }));
+
+            await this.pact.VerifyAsync(async ctx =>
+            {
+                this.mockFactory
+                    .Setup(f => f.CreateClient("Orders"))
+                    .Returns(() => new HttpClient
+                    {
+                        BaseAddress = ctx.MockServerUri,
+                        DefaultRequestHeaders =
+                        {
+                            Accept = { MediaTypeWithQualityHeaderValue.Parse("application/json") }
+                        }
+                    });
+
+                var client = new OrdersClient(this.mockFactory.Object);
+
+                OrderDto[] orders = await client.GetOrdersAsync(new[] { 1, 2 });
+
+                orders.Should().HaveCount(2);
+                orders[0].Should().Be(expected1);
+                orders[1].Should().Be(expected2);
+            });
+        }
+
         [Fact]
         public async Task GetOrderAsync_UnknownOrder_ReturnsNotFound()
         {

samples/OrdersApi/Consumer.Tests/pacts/Fulfilment API-Orders API.json

@@ -88,6 +88,118 @@
       },
       "type": "Synchronous/HTTP"
     },
+    {
+      "description": "a request for multiple orders by id",
+      "pending": false,
+      "providerStates": [
+        {
+          "name": "orders with ids {ids} exist",
+          "params": {
+            "ids": "1,2"
+          }
+        }
+      ],
+      "request": {
+        "headers": {
+          "Accept": [
+            "application/json"
+          ]
+        },
+        "method": "GET",
+        "path": "/api/orders/many/1,2"
+      },
+      "response": {
+        "body": {
+          "content": [
+            {
+              "date": "2023-06-28T12:13:14.0000000+01:00",
+              "id": 1,
+              "status": "Pending"
+            },
+            {
+              "date": "2023-06-29T12:13:14.000000+01:00",
+              "id": 2,
+              "status": "Pending"
+            }
+          ],
+          "contentType": "application/json",
+          "encoded": false
+        },
+        "headers": {
+          "Content-Type": [
+            "application/json"
+          ]
+        },
+        "matchingRules": {
+          "body": {
+            "$": {
+              "combine": "AND",
+              "matchers": [
+                {
+                  "match": "arrayContains",
+                  "variants": [
+                    {
+                      "index": 0,
+                      "rules": {
+                        "$.date": {
+                          "combine": "AND",
+                          "matchers": [
+                            {
+                              "match": "type"
+                            }
+                          ]
+                        },
+                        "$.id": {
+                          "combine": "AND",
+                          "matchers": [
+                            {
+                              "match": "integer"
+                            }
+                          ]
+                        },
+                        "$.status": {
+                          "combine": "AND",
+                          "matchers": [
+                            {
+                              "match": "regex",
+                              "regex": "Pending|Fulfilling|Shipped"
+                            }
+                          ]
+                        }
+                      }
+                    },
+                    {
+                      "index": 1,
+                      "rules": {
+                        "$.date": {
+                          "combine": "AND",
+                          "matchers": [
+                            {
+                              "match": "regex",
+                              "regex": "\\d\\d\\d\\d-\\d\\d-\\d\\dT\\d\\d:\\d\\d:\\d\\d\\.\\d\\d\\d\\d\\d\\d+\\d\\d:\\d\\d"
+                            }
+                          ]
+                        },
+                        "$.id": {
+                          "combine": "AND",
+                          "matchers": [
+                            {
+                              "match": "integer"
+                            }
+                          ]
+                        }
+                      }
+                    }
+                  ]
+                }
+              ]
+            }
+          }
+        },
+        "status": 200
+      },
+      "type": "Synchronous/HTTP"
+    },
     {
       "description": "a request to update the status of an order",
       "pending": false,

samples/OrdersApi/Consumer/OrdersClient.cs

@@ -1,4 +1,5 @@
-using System.Net.Http;
+using System.Collections.Generic;
+using System.Net.Http;
 using System.Net.Http.Json;
 using System.Text.Json;
 using System.Text.Json.Serialization;
@@ -40,6 +41,19 @@ public async Task<OrderDto> GetOrderAsync(int orderId)
             return order;
         }
 
+        /// <summary>
+        /// Get a orders by ID
+        /// </summary>
+        /// <param name="orderIds">Order IDs</param>
+        /// <returns>Order</returns>
+        public async Task<OrderDto[]> GetOrdersAsync(IEnumerable<int> orderIds)
+        {
+            using HttpClient client = this.factory.CreateClient("Orders");
+
+            OrderDto[] orders = await client.GetFromJsonAsync<OrderDto[]>($"/api/orders/many/{string.Join(',', orderIds)}", Options);
+            return orders;
+        }
+
         /// <summary>
         /// Update the status of an order
         /// </summary>

samples/OrdersApi/Provider.Tests/ProviderStateMiddleware.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.IO;
+using System.Linq;
 using System.Net.Http;
 using System.Text;
 using System.Text.Json;
@@ -36,7 +37,8 @@ public ProviderStateMiddleware(RequestDelegate next, IOrderRepository orders)
 
             this.providerStates = new Dictionary<string, Func<IDictionary<string, object>, Task>>
             {
-                ["an order with ID {id} exists"] = this.EnsureEventExistsAsync
+                ["an order with ID {id} exists"] = this.EnsureEventExistsAsync,
+                ["orders with ids {ids} exist"] = this.EnsureEventsExistAsync
             };
         }
 
@@ -52,6 +54,20 @@ private async Task EnsureEventExistsAsync(IDictionary<string, object> parameters
             await this.orders.InsertAsync(new OrderDto(id.GetInt32(), OrderStatus.Fulfilling, DateTimeOffset.Now));
         }
 
+        /// <summary>
+        /// Ensure a series of events exist
+        /// </summary>
+        /// <param name="parameters">Event parameters</param>
+        /// <returns>Awaitable</returns>
+        private async Task EnsureEventsExistAsync(IDictionary<string, object> parameters)
+        {
+            var ids = (JsonElement)parameters["ids"];
+            foreach (var id in ids.GetString()!.Split(',').Select(int.Parse))
+            {
+                await this.orders.InsertAsync(new OrderDto(id, OrderStatus.Fulfilling, DateTimeOffset.Now));
+            }
+        }
+
         /// <summary>
         /// Handle the request
         /// </summary>
@@ -79,7 +95,7 @@ public async Task InvokeAsync(HttpContext context)
                 try
                 {
                     ProviderState providerState = JsonSerializer.Deserialize<ProviderState>(jsonRequestBody, Options);
-                    
+
                     if (!string.IsNullOrEmpty(providerState?.State))
                     {
                         await this.providerStates[providerState.State].Invoke(providerState.Params);

samples/OrdersApi/Provider/Orders/OrdersController.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
@@ -46,6 +47,34 @@ public async Task<IActionResult> GetByIdAsync(int id)
             }
         }
 
+        /// <summary>
+        /// Get several orders by their comma-separated IDs
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        [HttpGet("many/{ids}", Name = "getMany")]
+        [ProducesResponseType(typeof(OrderDto[]), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetManyAsync(string ids)
+        {
+            try
+            {
+                var idsAsInts = ids.Split(',').Select(int.Parse);
+
+                List<OrderDto> result = new List<OrderDto>();
+                foreach (int id in idsAsInts)
+                {
+                    var order = await this.orders.GetAsync(id);
+                    result.Add(order);
+                }
+
+                return this.Ok(result.ToArray());
+            }
+            catch (KeyNotFoundException)
+            {
+                return this.NotFound();
+            }
+        }
+
         /// <summary>
         /// Create a new pending order
         /// </summary>

src/PactNet.Abstractions/Matchers/ArrayContainsMatcher.cs

@@ -0,0 +1,31 @@
+using System.Text.Json.Serialization;
+
+namespace PactNet.Matchers
+{
+    /// <summary>
+    /// Matcher for array-contains. Checks whether an array contains the specified variations.
+    /// </summary>
+    public class ArrayContainsMatcher : IMatcher
+    {
+        /// <summary>
+        /// Type of the matcher
+        /// </summary>
+        [JsonPropertyName("pact:matcher:type")]
+        public string Type => "array-contains";
+
+        /// <summary>
+        /// The items expected to be in the array.
+        /// </summary>
+        [JsonPropertyName("variants")]
+        public dynamic Value { get; }
+
+        /// <summary>
+        /// Initialises a new instance of the <see cref="ArrayContainsMatcher"/> class.
+        /// </summary>
+        /// <param name="variants"></param>
+        public ArrayContainsMatcher(dynamic[] variants)
+        {
+            Value = variants;
+        }
+    }
+}

src/PactNet.Abstractions/Matchers/Match.cs

@@ -168,5 +168,15 @@ public static IMatcher Include(string example)
         {
             return new IncludeMatcher(example);
         }
+
+        /// <summary>
+        /// Matcher which matches an array containing the specified variations.
+        /// </summary>
+        /// <param name="variations">Variations which should be contained in the array.</param>
+        /// <returns>Matcher</returns>
+        public static IMatcher ArrayContains(dynamic[] variations)
+        {
+            return new ArrayContainsMatcher(variations);
+        }
     }
 }

src/PactNet.Abstractions/Matchers/MatcherConverter.cs

@@ -52,6 +52,9 @@ public override void Write(Utf8JsonWriter writer, IMatcher value, JsonSerializer
                 case TypeMatcher matcher:
                     JsonSerializer.Serialize(writer, matcher, options);
                     break;
+                case ArrayContainsMatcher matcher:
+                    JsonSerializer.Serialize(writer, matcher, options);
+                    break;
                 default:
                     throw new ArgumentOutOfRangeException($"Unsupported matcher: {value.GetType()}");
             }

tests/PactNet.Abstractions.Tests/Matchers/ArrayContainsMatcherTests.cs

@@ -0,0 +1,29 @@
+using System.Text.Json;
+using FluentAssertions;
+using PactNet.Matchers;
+using Xunit;
+
+namespace PactNet.Abstractions.Tests.Matchers
+{
+    public class ArrayContainsMatcherTests
+    {
+        [Fact]
+        public void Ctor_String_SerializesCorrectly()
+        {
+            // Arrange
+            var example = new[]
+            {
+                "Thing1",
+                "Thing2",
+            };
+
+            var matcher = new ArrayContainsMatcher(example);
+
+            // Act
+            var actual = JsonSerializer.Serialize(matcher);
+
+            // Assert
+            actual.Should().Be(@"{""pact:matcher:type"":""array-contains"",""variants"":[""Thing1"",""Thing2""]}");
+        }
+    }
+}