public async Task ProcessEventsAsync()

in RobotOrchestrator.OrderManager/JobEventProcessor.cs [45:66]

• 16 lines of code
• 3 McCabe index (conditional complexity)

        public async Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
        {
            var jobMessages = new List<Job>();

            foreach (var eventData in messages)
            {
                var data = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);

                logger.LogDebug($"Message received. Partition: '{context.PartitionId}', Data: '{data}'");

                var job = ConvertToJob(data);

                if (job != null)
                {
                    jobMessages.Add(job);
                }
            }

            await jobMessageHandler.UpdateOrdersAsync(jobMessages);

            await context.CheckpointAsync();
        }