using JNPF.EventBus;

namespace Tnb.Common.Core.EventBus.Sources
{
    public class TaskStatusChangeSource : IEventSource
    {
        /// <summary>
        /// 构造函数.
        /// </summary>
        /// <param name="eventId">事件ID.</param>
        /// <param name="connectionConfig">数据库连接配置.</param>
        /// <param name="entity">实体.</param>
        public TaskStatusChangeSource(string eventId, object payload)
        {
            EventId = eventId;
            Payload = payload;
        }

        ///// <summary>
        ///// 数据库连接配置.
        ///// </summary>
        //public ConnectionConfigOptions ConnectionConfig { get; set; }

        /// <summary>
        /// 事件 Id.
        /// </summary>
        public string EventId { get; }

        /// <summary>
        /// 事件承载（携带）数据.
        /// </summary>
        public object Payload { get; }

        /// <summary>
        /// 取消任务 Token.
        /// </summary>
        /// <remarks>用于取消本次消息处理.</remarks>
        public CancellationToken CancellationToken { get; }

        /// <summary>
        /// 事件创建时间.
        /// </summary>
        public DateTime CreatedTime { get; } = DateTime.UtcNow;
    }
}