Expedience/Expedience.Infrastructure/ExpedienceRepository.cs

using System;

using Enyim.Caching;
using Expedience.Infrastructure.Models;
using Microsoft.EntityFrameworkCore;

namespace Expedience.Infrastructure
{
    public interface IExpedienceRepository : IDisposable
    {
        Task<List<DutyCompletionRecord>> GetDutyCompletionRecords(string expac, CancellationToken cancellationToken);
    }

    public class ExpedienceRepository : IExpedienceRepository
    {
        private readonly ExpedienceContext _dbContext;
        private readonly IMemcachedClient _memcachedClient;

        public ExpedienceRepository(ExpedienceContext dbContext, IMemcachedClient memcachedClient)
        {
            _dbContext = dbContext;
            _memcachedClient = memcachedClient;
        }

        public async Task<List<DutyCompletionRecord>> GetDutyCompletionRecords(string expac, CancellationToken cancellationToken)
        {
            var cacheKey = $"xpd-dcr-{expac}";
            if (_memcachedClient.TryGet<List<DutyCompletionRecord>>(cacheKey, out var cachedValue))
            {
                return cachedValue;
            }
            else
            {
                var records = await _dbContext.DutyCompletionRecords.FromSqlInterpolated($"SELECT * FROM public.get_dutycompletionrecords({expac})")
                    .ToListAsync();
                await _memcachedClient.AddAsync(cacheKey, records, TimeSpan.FromMinutes(10));
                
                return records;
            }
        }

        public void Dispose()
        {
            _memcachedClient.Dispose();
        }
    }
}