Add batch patch endpoint to web project

Hexastore.Web/Controllers/StoreController.cs

@@ -1,4 +1,6 @@
 using System;
+using System.Collections.Generic;
+using System.Linq;
 using System.Net.Http;
 using System.Runtime.InteropServices;
 using System.Threading.Tasks;
@@ -169,6 +171,27 @@ public async Task<IActionResult> PatchJson(string storeId, [FromBody]JToken data
             }
         }
 
+        [HttpPatch("{storeId}/batch/json")]
+        public async Task<IActionResult> BatchPatchJson(string storeId, [FromBody]IEnumerable<JToken> dataPatches)
+        {
+            _logger.LogInformation(LoggingEvents.ControllerPatchJson, "BATCH PATCH JSON: store {storeId}", storeId);
+            try
+            {
+                var payloads = dataPatches.Select(patch => new StoreEvent
+                {
+                    Operation = EventType.PATCH_JSON,
+                    Data = patch.ToString(Formatting.None)
+                });
+
+                await SendEvents(storeId, payloads);
+                return Accepted();
+            }
+            catch (Exception e)
+            {
+                return HandleException(e);
+            }
+        }
+
         [HttpPatch("{storeId}/triple")]
         public async Task<IActionResult> PatchTriple(string storeId, [FromBody]JObject data)
         {

Hexastore.Web/Controllers/StoreControllerBase.cs

@@ -76,6 +76,23 @@ protected Task SendEvent(string storeId, StoreEvent payload)
             return tc.Task;
         }
 
+        protected Task SendEvents(string storeId, IEnumerable<StoreEvent> payloads)
+        {
+            var tc = new TaskCompletionSource<bool>();
+            var storeEvents = payloads.ToList();
+            foreach (var payload in storeEvents)
+            {
+                var guid = Guid.NewGuid().ToString();
+                payload.OperationId = guid;
+                payload.StoreId = storeId;
+                _receiver.SetCompletion(guid, tc);
+            }
+
+            _ = _eventProcessor.SendMessages(storeEvents);
+            return tc.Task;
+        }
+
+
         protected IActionResult HandleException(Exception e)
         {
             _logger.LogError(LoggingEvents.ControllerError, e, e.Message);

Hexastore.Web/EventHubs/EventSender.cs

@@ -59,6 +59,39 @@ public async Task SendMessage(StoreEvent storeEvent)
             }
         }
 
+        public async Task SendMessages(IEnumerable<StoreEvent> storeEvents)
+        {
+            if (!_active)
+            {
+                // pass through
+                foreach(var storeEvent in storeEvents)
+                {
+                    await _storeReceiver.ProcessEventsAsync(storeEvent);
+                }
+                return;
+            }
+
+            try
+            {
+                var partitionKey = string.Empty;
+                var eventDatas = new List<EventData>();
+                foreach (var storeEvent in storeEvents)
+                {
+                    storeEvent.PartitionId = storeEvent.StoreId.GetHashCode() % _storeConfig.EventHubPartitionCount;
+                    if(partitionKey == string.Empty) partitionKey = storeEvent.PartitionId.ToString();
+                    var content = JsonConvert.SerializeObject(storeEvent, Formatting.None);
+                    var bytes = Encoding.UTF8.GetBytes(content);
+                    eventDatas.Add(new EventData(bytes));
+                }
+
+                await _eventHubClient.SendAsync(eventDatas, partitionKey);
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e);
+            }
+        }
+
         public void Dispose()
         {
             if (_eventHubClient != null) {