using FrameworkDAL.DTO.DataSync;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.ResponseStandard;

namespace FrameworkDAL.CustomCode.DataSync
{
    public interface IDataSyncJobDAL
    {
        Task<string> GetSyncJob(int syncJobId, LoginDTO login, CancellationToken ct);
        Task<string> GetSyncJobList(int offset, int pageSize, LoginDTO login, CancellationToken ct);
        Task<string> GetSelectListSyncJob(int firstNumber, int maxResult, LoginDTO login, CancellationToken ct);
        Task<int> SaveSyncJob(SyncJobDTO dto, LoginDTO login, CancellationToken ct);
        Task<int> UpdateSyncJob(SyncJobDTO dto, LoginDTO login, CancellationToken ct);
        Task<Result<string>> DeleteSyncJob(int syncJobId, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<SyncJobDTO>> GetEnabledJobsForScheduler(LoginDTO login, CancellationToken ct);

        // Returns rows affected: 0 = job already running (caller skips), 1 = lock acquired.
        Task<int> LockSyncJobForRun(int syncJobId, LoginDTO login, CancellationToken ct);
        Task UpdateLastRun(int syncJobId, int runId, byte status, DateTime ranAt, LoginDTO login, CancellationToken ct);
        Task UpdateWatermarks(int syncJobId, DateTime insertedTill, DateTime updatedTill, DateTime deletedTill, LoginDTO login, CancellationToken ct);
    }
}