cache

gistfile1.cs

//Install-Package Newtonsoft.Json -ProjectName Ksnsi.Queries
//Install-Package MemoryCache -ProjectName Ksnsi.Queries

using System;
using MemoryCache;
using Newtonsoft.Json;

namespace Ksnsi.Queries
{
    public interface IQueryProcessor
    {
        TResponse Process<TResponse, TContext>(TContext queryContext)
            where TContext : IQueryContext<TResponse>;
    }

    public class QueryProcessor : IQueryProcessor
    {
        private readonly Func<Type, Type, object> _func;

        public QueryProcessor(Func<Type, Type, object> func)
        {
            _func = func;
        }

        #region IQueryProcessor Members

        public TResponse Process<TResponse, TQueryContext>(TQueryContext queryContext)
            where TQueryContext : IQueryContext<TResponse>
        {
            string key = queryContext.GetType() + JsonConvert.SerializeObject(queryContext);

            if (Cache.Exists(key))
            {
                var obj = Cache.Get(key);
                return (TResponse)obj;
            }

            var q = (IQuery<TQueryContext, TResponse>)_func(typeof(TQueryContext), typeof(TResponse));
            var response = q.Execute(queryContext);
            if (!(response == null))
            {
                Cache.Store(key, response);
            }
            return response;
        }

        #endregion
    }
}