using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using DMSDAL.DTO.BulkIngestion;
using GB5Shared.DTO.Framework.Login;

namespace DMSDAL.CustomCode.BulkIngestion
{
    public interface IBulkIngestionDAL
    {
        Task<int> InsertJobAsync(BulkIngestionJobDTO job, LoginDTO login, CancellationToken ct = default);

        Task UpdateJobStatusAsync(
            int jobId, byte status, int totalFiles, int processedFiles, int failedFiles,
            LoginDTO login, CancellationToken ct = default);

        Task<BulkIngestionStatusDTO?> GetJobStatusAsync(
            int jobId, LoginDTO login, CancellationToken ct = default);

        Task InsertLogAsync(
            int jobId, string filePath, int objectTypeId, int objectId,
            int documentSetDetailId, string? displayName, int? attachmentId,
            byte status, string? errorMessage,
            LoginDTO login, CancellationToken ct = default);

        Task<int?> GetObjectTypeIdByCodeAsync(
            string entityCode, LoginDTO login, CancellationToken ct = default);
    }
}