using Hangfire.States;
using Hangfire.Storage;
using System;

namespace CoreCms.Net.Web.WebApi.Infrastructure
{
    /// <summary>
    /// 已完成的job设置过期，防止数据无限增长
    /// </summary>
    public class SucceededStateExpireHandler : IStateHandler
    {
        /// <summary>
        /// 数据过期时间
        /// </summary>
        public TimeSpan JobExpirationTimeout;

        /// <summary>
        /// 完成的项目过期状态处理
        /// </summary>
        /// <param name="jobExpirationTimeout"></param>
        public SucceededStateExpireHandler(int jobExpirationTimeout)
        {
            JobExpirationTimeout = TimeSpan.FromMinutes(jobExpirationTimeout);
        }

        /// <summary>
        /// 状态名称
        /// </summary>
        public string StateName => SucceededState.StateName;

        /// <summary>
        /// 应用状态
        /// </summary>
        /// <param name="context"></param>
        /// <param name="transaction"></param>
        public void Apply(ApplyStateContext context, IWriteOnlyTransaction transaction)
        {
            context.JobExpirationTimeout = JobExpirationTimeout;
        }

        /// <summary>
        /// 不应用状态
        /// </summary>
        /// <param name="context"></param>
        /// <param name="transaction"></param>
        public void Unapply(ApplyStateContext context, IWriteOnlyTransaction transaction)
        {
        }
    }

}