SPMS_API/SPMS.Application/Interfaces/IBulkJobStore.cs

using SPMS.Application.DTOs.Push;

namespace SPMS.Application.Interfaces;

public interface IBulkJobStore
{
    Task<string> CreateJobAsync(long serviceId, int totalCount, CancellationToken ct = default);
    Task<BulkJobInfo?> GetJobAsync(string jobId, CancellationToken ct = default);
    Task SetProcessingAsync(string jobId, CancellationToken ct = default);
    Task IncrementSentAsync(string jobId, CancellationToken ct = default);
    Task IncrementFailedAsync(string jobId, CancellationToken ct = default);
    Task TryCompleteAsync(string jobId, CancellationToken ct = default);
    Task<bool> IsCancelledAsync(string jobId, CancellationToken ct = default);
    Task<int> CancelAsync(string jobId, CancellationToken ct = default);
}