Expedience/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs

using System;
using Expedience.Infrastructure;
using Expedience.Infrastructure.Models;
using MassTransit;

namespace Expedience.Api.Consumers
{
    public class DutyCompletionResultConsumer : IConsumer<Models.DutyCompletionResult>
    {
        private readonly ILogger<DutyCompletionResultConsumer> _logger;
        private readonly IServiceScopeFactory _serviceScopeFactory;

        public DutyCompletionResultConsumer(ILogger<DutyCompletionResultConsumer> logger,
            IServiceScopeFactory serviceScopeFactory)
        {
            _logger = logger;
            _serviceScopeFactory = serviceScopeFactory;
        }

        public async Task Consume(ConsumeContext<Models.DutyCompletionResult> context)
        {
            var message = context.Message;
            
            if (message == null || message.UserInfo == null || message.PlayerInfo == null || 
                message.DutyInfo == null || message.ClientInfo == null || message.CompletionTimeInfo == null) 
            {
                _logger.LogError("Required message fields were not populated on Message with Id {messageId}", context.MessageId);
                return;
            }

            var userHash = message.UserInfo.UserId;
            var worldId = message.UserInfo.WorldId;

            using var scope = _serviceScopeFactory.CreateScope();
            using var dbContext = scope.ServiceProvider.GetRequiredService<ExpedienceContext>();
            var user = dbContext.Users.FirstOrDefault(x => x.UserHash == userHash && x.WorldId == worldId);
            if (user == null)
            {
                _logger.LogError("No user found for World {worldId} and Hash {userHash}", worldId, userHash);
                return;
            }

            var completionResult = new DutyCompletionResult
            {
                Id = message.UploadId,
                TerritoryId = message.DutyInfo.TerritoryId,
                ContentId = message.DutyInfo.ContentId,
                UserId = user.UserId,
                HasEcho = message.DutyInfo.HasEcho,
                IsUnrestricted = message.DutyInfo.IsUnrestricted,
                IsMinILevel = message.DutyInfo.IsMinILevel,
                HasNpcMembers = message.DutyInfo.IsNpcSupported,
                StartTime = message.DutyStartDateUtc,
                EndTime = message.DutyCompletionDateUtc,
                Hours = message.CompletionTimeInfo.Hours,
                Minutes = message.CompletionTimeInfo.Minutes,
                Seconds = message.CompletionTimeInfo.Seconds,
                Milliseconds = message.CompletionTimeInfo.Milliseconds,
                GameVersion = message.ClientInfo.GameVersion,
                PluginVersion = message.ClientInfo.PluginVersion,
                Lang = message.ClientInfo.GameLanguage,
                DataCenter = message.DataCenter,
                UploadedAt = message.UploadDateUtc,
            };

            dbContext.DutyCompletionResults.Add(completionResult);

            var memberNumber = 0;
            var dutyMembers = new List<DutyMember>();
            foreach (var member in message.GroupMembers)
            {
                var dutyMember = new DutyMember
                {
                    UploadId = message.UploadId,
                    GroupNumber = member.GroupNumber,
                    MemberNumber = memberNumber++,
                    ClassJob = member.ClassJob,
                    Level = member.Level,
                    IsNpc = member.IsNpc,
                    IsPlayer = member.IsPlayer,
                };
                
                dutyMembers.Add(dutyMember);
            }

            dbContext.DutyMembers.AddRange(dutyMembers);

            await dbContext.SaveChangesAsync();

            _logger.LogInformation("Consumed message {uploadId} from user {userHash}", message.UploadId, userHash);
        }
    }
}