Blame view

src/test/java/org/legrog/entities/AccountSearchRepositorySolrjTest.java 3.17 KB
Jean-Francois Leveque authored
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87
package org.legrog.entities;

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.beans.BindingException;
import org.apache.solr.common.params.SolrParams;
import org.junit.jupiter.api.*;
import org.junit.jupiter.api.extension.ExtendWith;
import org.junit.platform.runner.JUnitPlatform;
import org.junit.runner.RunWith;
import org.legrog.test.MockitoExtension;
import org.mockito.ArgumentCaptor;
import org.mockito.Captor;
import org.mockito.Mock;
import org.mockito.Mockito;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;

import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

/**
 * Classe testant AccountSearchRepositorySolrj
 */
@RunWith(JUnitPlatform.class)
@ExtendWith(MockitoExtension.class)
@DisplayName("Indexes and searches with SearchRepository")

public class AccountSearchRepositorySolrjTest {
    Logger logger = LoggerFactory.getLogger(getClass());

    private AccountSearchRepository accountSearchRepository;
    private SolrClient solrClient;

    @Captor
    ArgumentCaptor<SolrParams> solrParamsArgumentCaptor;

    @BeforeEach
    public void setup(@Mock SolrClient solrClient) {
        accountSearchRepository = new AccountSearchRepositorySolrj(solrClient);
        this.solrClient = solrClient;
    }

    @Nested
    @DisplayName("search method")
    class SearchTests {

        @DisplayName("when repository in IO error, should throw a SearchingException")
        @Test
        public void searchIOETest() throws IOException, SolrServerException{
            when(solrClient.query(Mockito.anyString(), Mockito.any())).thenThrow(new IOException());
            Assertions.assertThrows(SearchingException.class, () -> accountSearchRepository.search("a"));
        }

        @DisplayName("when repository in SolrServerException, should throw an SearchingException with its root cause")
        @Test
        public void searchSSETest() throws SolrServerException, IOException {
            when(solrClient.query(Mockito.any())).thenThrow(new SolrServerException(new BindingException("BE test 2")));
            try {
                accountSearchRepository.search("b");
            } catch (SearchingException se) {
                logger.error("SearchingException {}", se);
                assertThat(se.getRootCause().getClass()).isEqualTo(BindingException.class);
            }
        }

        @DisplayName("when called, it parameter should be embedded in a query sent through SolrClient")
        @Test
        public void searchParameterTest() throws IOException, SolrServerException {
            try {
                accountSearchRepository.search("c");
                Mockito.verify(solrClient).query(Mockito.anyString(), solrParamsArgumentCaptor.capture());
            } catch (SearchingException se) {
                logger.error("SearchingException {}", se);
            }
            SolrQuery solrQuery = (SolrQuery) solrParamsArgumentCaptor.getValue();
            assertThat(solrQuery.getQuery()).isEqualTo("c");
        }

    }


}