EnvelopeGenerator/EnvelopeGenerator.Application/Services/GTXMessagingService.cs

using AutoMapper;
using DigitalData.Core.Abstractions.Client;
using DigitalData.Core.Client;
using EnvelopeGenerator.Application.Configurations.GtxMessaging;
using EnvelopeGenerator.Application.Contracts;
using EnvelopeGenerator.Application.DTOs.Messaging;
using EnvelopeGenerator.Application.Extensions;
using EnvelopeGenerator.Domain.HttpResponse;
using Microsoft.Extensions.Caching.Distributed;
using Microsoft.Extensions.Options;

namespace EnvelopeGenerator.Application.Services
{
    public class GtxMessagingService : IMessagingService
    {
        private readonly IHttpClientService<SmsParams> _smsClient;

        private readonly SmsParams _smsParams;

        private readonly IMapper _mapper;

        private readonly ICodeGenerator _codeGen;

        private readonly IEnvelopeReceiverCache _erCache;

        public string ServiceProvider { get; }

        public GtxMessagingService(IHttpClientService<SmsParams> smsClient, IOptions<SmsParams> smsParamsOptions, IMapper mapper, ICodeGenerator codeGenerator, IEnvelopeReceiverCache envelopeReceiverCache)
        {
            _smsClient = smsClient;
            _smsParams = smsParamsOptions.Value;
            _mapper = mapper;
            ServiceProvider = GetType().Name.Replace("Service", string.Empty);
            _codeGen = codeGenerator;
            _erCache = envelopeReceiverCache;
        }

        public async Task<SmsResponse> SendSmsAsync(string recipient, string message)
        {
            return await _smsClient.FetchAsync(queryParams: new Dictionary<string, object?>()
            {
                { _smsParams.RecipientQueryParamName, recipient },
                { _smsParams.MessageQueryParamName, message }
            })
            .ThenAsync(res => res.Json<GtxMessagingResponse>())
            .ThenAsync(_mapper.Map<SmsResponse>);
        }

        public async Task<SmsResponse> SendSmsCodeAsync(string recipient, string envelopeReceiverId)
        {
            var code = await _erCache.GetSmsCodeAsync(envelopeReceiverId);

            if (code is null)
            {
                code = _codeGen.GenerateCode(_smsParams.CodeLength);                                
                var expiration = await _erCache.SetSmsCodeAsync(envelopeReceiverId, code);                
                var res = await SendSmsAsync(recipient: recipient, message: code);
                res.Expiration = expiration;
                return res;
            }
            else
            {
                var code_expiration = await _erCache.GetSmsCodeExpirationAsync(envelopeReceiverId);
                return code_expiration is null
                    ? new() { Ok = false }
                    : new() { Ok = false, AllowedAt = code_expiration };
            }
        }
    }
}