package jnpf.dmsService;

import jnpf.dmsMapper.DmsDisableApplicationMapper;
import jnpf.dmsEntity.storage.approval.DmsDisableOccupancy;
import jnpf.exception.DataException;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import org.springframework.test.util.ReflectionTestUtils;
import java.util.*;
import static org.mockito.Mockito.*;
import static org.junit.jupiter.api.Assertions.*;

class DmsDisableApplicationGuardTest {
    final DmsDisableApplicationMapper mapper = mock(DmsDisableApplicationMapper.class);
    final WorkFlowApi workflow = mock(WorkFlowApi.class);
    final DmsDisableApplicationGuard guard = new DmsDisableApplicationGuard(mapper, workflow);

    TaskEntity legacy(int status, boolean ended) {
        DmsDisableOccupancy application = new DmsDisableOccupancy();
        application.setTaskId("task"); application.setFlowId("template");
        when(mapper.legacyApplicationsForFile("t", "f")).thenReturn(List.of(application));
        TaskEntity task = new TaskEntity();
        task.setId("task"); task.setFlowId("flow"); task.setTemplateId("template");
        task.setStatus(status); task.setEndTime(ended ? new Date() : null);
        when(workflow.getInfoSubmit("task")).thenReturn(task);
        return task;
    }

    @Test void disabledCutoverNeverQueriesAbsentOccupancyTable() {
        legacy(8, false);
        assertThrows(DataException.class, () -> guard.requireFileEditable("t", "f"));
        verify(mapper, never()).pendingForFile(any(), any());
    }
    @ParameterizedTest @ValueSource(ints={3,4,7,9})
    void legacyOnlyReleasesVerifiedUnsuccessfulEnd(int status) {
        legacy(status, false);
        assertThrows(DataException.class, () -> guard.requireFileEditable("t", "f"));
        legacy(status, true);
        assertDoesNotThrow(() -> guard.requireFileEditable("t", "f"));
    }
    @Test void successfulEndKeepsFileOccupiedUntilBusinessProjection() {
        legacy(2, true);
        assertThrows(DataException.class, () -> guard.requireFileEditable("t", "f"));
    }
    @Test void missingOrMismatchedWorkflowCannotRelease() {
        TaskEntity task = legacy(3, true); task.setId("other");
        assertThrows(DataException.class, () -> guard.requireFileEditable("t", "f"));
        when(workflow.getInfoSubmit("task")).thenReturn(null);
        assertThrows(DataException.class, () -> guard.requireFileEditable("t", "f"));
    }
    @Test void enabledGuardOnlyUsesIndexedOccupancy() {
        ReflectionTestUtils.setField(guard, "occupancyEnabled", true);
        UUID doc = UUID.randomUUID();
        when(mapper.pendingForDocument("t", doc)).thenReturn(1);
        assertThrows(DataException.class, () -> guard.requireDocumentEditable("t", doc));
        verify(mapper, never()).legacyApplicationsForDocument(any(), any());
        verifyNoInteractions(workflow);
    }
}