package jnpf.dmsService.search;

import org.junit.jupiter.api.Test;
import org.mockito.ArgumentCaptor;
import org.springframework.context.ApplicationEventPublisher;

import java.util.UUID;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;

class DmsSearchIndexJobServiceTest {

    @Test
    void publishesRedisTaskEventWhenSearchIsEnabled() {
        DmsSearchProperties properties = new DmsSearchProperties();
        properties.setEnabled(true);
        ApplicationEventPublisher publisher = mock(ApplicationEventPublisher.class);
        DmsSearchIndexJobService service = new DmsSearchIndexJobService(properties, publisher);
        UUID documentId = UUID.randomUUID();
        UUID versionId = UUID.randomUUID();

        service.enqueueContentUpsert("tenant-1", documentId, versionId, "A".repeat(64));

        ArgumentCaptor<DmsSearchIndexJobCreatedEvent> captor =
                ArgumentCaptor.forClass(DmsSearchIndexJobCreatedEvent.class);
        verify(publisher).publishEvent(captor.capture());
        DmsSearchIndexTask task = captor.getValue().getTask();
        assertEquals("tenant-1", task.getTenantId());
        assertEquals(documentId, task.getDocumentId());
        assertEquals(versionId, task.getFileVersionId());
        assertEquals("a".repeat(64), task.getChecksumSha256());
    }

    @Test
    void doesNothingWhenSearchIsDisabled() {
        DmsSearchProperties properties = new DmsSearchProperties();
        ApplicationEventPublisher publisher = mock(ApplicationEventPublisher.class);
        DmsSearchIndexJobService service = new DmsSearchIndexJobService(properties, publisher);

        service.enqueueContentUpsert("tenant-1", UUID.randomUUID(), UUID.randomUUID(), null);

        verify(publisher, never()).publishEvent(org.mockito.ArgumentMatchers.any());
    }
}