using YY.Admin.Core.Services;
using YY.Admin.Core.Sync;

namespace YY.Admin.Infrastructure.Sync;

/// <summary>
/// 用户镜像拉取入队：统一走 Outbox（断网续传），与设备同步模块同一条基础设施线路。
/// </summary>
public sealed class JeecgUserMirrorPullOutbox : IJeecgUserMirrorPullOutbox
{
    private readonly OutboxProcessor _outboxProcessor;

    public JeecgUserMirrorPullOutbox(OutboxProcessor outboxProcessor)
    {
        _outboxProcessor = outboxProcessor;
    }

    /// <inheritdoc />
    public Task EnqueuePullAsync(string eventType, string? payloadJson, CancellationToken cancellationToken = default)
    {
        var payload = string.IsNullOrWhiteSpace(payloadJson) ? "{}" : payloadJson;
        return _outboxProcessor.EnqueueAsync(
            JeecgUserMirrorOutbox.AggregateType,
            "mirror",
            eventType,
            new { source = "unified-device-channel", detail = payload },
            cancellationToken);
    }
}