using Data.SeaHavenIndustries;

namespace SeaHaven.DataServices.Interfaces
{
    public interface IWorkOrderIngestDataService
    {
        Task<int> GetMaxWorkOrderIdAsync(CancellationToken cancellationToken);
        Task<WorkOrder?> GetTrackedByExternalIdAsync(string externalWorkOrderId, CancellationToken cancellationToken);
        void TrackWorkOrder(WorkOrder workOrder);
        Task<Locations?> FindLocationAsync(string name, CancellationToken cancellationToken);
        Task AddAndSaveLocationAsync(Locations location, CancellationToken cancellationToken);
        // Stages (does not save) the sync-attributed cancellation of the work order's pending
        // uplifts, each with its own audit row. See PendingUpliftCancellation.
        Task<int> StageCancelPendingUpliftsAsync(int workOrderId, CancellationToken cancellationToken);
        Task<IReadOnlyList<int>> GetWorkOrderIdsByExternalIdsAsync(
            IReadOnlyCollection<string> externalWorkOrderIds,
            CancellationToken cancellationToken);
        // Runs the batch in one transaction, holding the per-work-order lock on
        // lockedWorkOrderIds (see WorkOrderMutationLock) until it commits or rolls back.
        Task ExecuteTransactionalAsync(
            IReadOnlyCollection<int> lockedWorkOrderIds,
            Func<CancellationToken, Task> work,
            CancellationToken cancellationToken);
        Task SaveAsync(CancellationToken cancellationToken);
    }
}