package jnpf.dmsService.search;

import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
import jnpf.dmsEntity.search.model.DmsSearchIndexSource;
import jnpf.dmsMapper.DmsDocumentMapper;
import jnpf.dmsMapper.DmsSearchIndexSourceMapper;
import jnpf.dmsService.search.meili.*;
import org.junit.jupiter.api.Test;
import org.mockito.InOrder;
import java.util.UUID;
import static org.mockito.Mockito.*;

class DmsSearchIndexWriterTest {
    @Test void lateExtractionCannotPublishAfterExpiryAndLockPrecedesFinalRead() throws Exception {
        DmsDocumentMapper documents = mock(DmsDocumentMapper.class);
        DmsSearchIndexSourceMapper sources = mock(DmsSearchIndexSourceMapper.class);
        DmsMeilisearchClient client = mock(DmsMeilisearchClient.class);
        DmsSearchIndexWriter writer = new DmsSearchIndexWriter(documents, sources, client);
        UUID doc = UUID.randomUUID(), version = UUID.randomUUID();
        DmsSearchIndexDocument value = new DmsSearchIndexDocument();
        value.setTenantId("t"); value.setDocumentId(doc.toString()); value.setFileVersionId(version.toString());
        when(documents.selectByTenantAndIdForUpdate("t", doc)).thenReturn(new DmsDocumentEntity());
        writer.publish(value);
        verifyNoInteractions(client);
        clearInvocations(documents, sources);
        when(sources.selectSource("t", doc, version)).thenReturn(new DmsSearchIndexSource());
        writer.publish(value);
        InOrder order = inOrder(documents, sources, client);
        order.verify(documents).selectByTenantAndIdForUpdate("t", doc);
        order.verify(sources).selectSource("t", doc, version);
        order.verify(client).upsert(value);
    }
}