namespace ZymonicServices;

public interface IZymonicGatewayQueueStore
{
    void InitialiseDatabase();
    Task<int> RequeueInProgressRequestsAsync(CancellationToken ct = default);
    Task<Guid> QueueRequestAsync(ZymonicGatewayQueuedRequest request, CancellationToken ct = default);
    Task<Guid> QueueFailedRequestAsync(ZymonicGatewayQueuedRequest request, string error, CancellationToken ct = default);
    Task<ZymonicGatewayQueuedRequest?> GetQueuedRequestAsync(Guid requestId, CancellationToken ct = default);
    Task<IReadOnlyList<ZymonicGatewayQueuedRequest>> GetQueuedRequestsAsync(string? status = null, int limit = 100, CancellationToken ct = default);
    Task<ZymonicGatewayQueuedRequest?> ClaimNextQueuedRequestAsync(int maxAttempts, TimeSpan retryDelay, CancellationToken ct = default);
    Task<bool> UpdateQueuedRequestAsync(Guid requestId, ZymonicGatewayQueuedRequest update, CancellationToken ct = default);
    Task<bool> RetryRequestAsync(Guid requestId, int maxAttempts, bool debugMode, CancellationToken ct = default);
    Task CompleteRequestAsync(Guid requestId, CancellationToken ct = default);
    Task FailRequestAsync(Guid requestId, string error, int maxAttempts, CancellationToken ct = default);
    Task<ZymonicGatewayQueueStatusSnapshot> GetStatusSnapshotAsync(CancellationToken ct = default);
}