public class DefaultContentsParserTest {
    static Suggester suggester;
    static OpenSearchRunner runner;
    DefaultContentsParser defaultContentsParser = new DefaultContentsParser();
    String[] supportedFields = new String[] { "content", "title" };
    String[] tagFieldNames = new String[] { "label", "virtual_host" };
    String roleFieldName = "role";

    @BeforeClass
    public static void beforeClass() throws Exception {

     * @param badWords The bad words array
     */
    public ContentIndexingContext(final String index, final String[] supportedFields, final String[] tagFieldNames,
            final String roleFieldName, final String langFieldName, final String[] badWords) {
        this.index = index;
        this.supportedFields = supportedFields;
        this.tagFieldNames = tagFieldNames;
        this.roleFieldName = roleFieldName;

     * @param supportedFields The supported fields
     * @param tagFieldNames The tag field names
     * @param roleFieldName The role field name
     * @param badWords The bad words array
     * @return The SuggestIndexResponse
     */
    public SuggestIndexResponse indexFromQueryLog(final String index, final QueryLog queryLog, final String[] supportedFields,

        this.client = client;
        this.settings = settings;
        this.indexName = indexName;
        supportedFields = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS);
        totalDocNum = getTotal();
    }

    @Override
    public synchronized Map<String, Object> read() {
        while (!isFinished.get() && queue.isEmpty()) {

    }

    @Test
    public void test_indexFromQueryString() throws Exception {
        SuggestSettings settings = suggester.settings();
        String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0];

        SuggestIndexResponse indexResponse = suggester.indexer().indexFromQueryLog(new QueryLog(field + ":検索", null));
        assertEquals(1, indexResponse.getNumberOfInputDocs());

    public void test_indexFromDocumentWithMissingField() throws Exception {
        SuggestSettings settings = suggester.settings();
        String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0];

        Map<String, Object>[] documents = new Map[1];
        documents[0] = new HashMap<>();
        // Document doesn't contain the supported field
        documents[0].put("other_field", "some content");

    }

    @Test
    public void test_indexFromSingleQueryLog() throws Exception {
        SuggestSettings settings = suggester.settings();
        String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0];

        QueryLog queryLog = new QueryLog(field + ":検索", null);
        SuggestIndexResponse response = suggester.indexer().indexFromQueryLog(queryLog);

        assertNotNull(response);

        assertEquals("settings-test.suggest", settings.getAsString(SuggestSettings.DefaultKeys.INDEX, ""));
        assertEquals("content", settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0]);
        assertEquals("label,virtual_host", settings.getAsString(SuggestSettings.DefaultKeys.TAG_FIELD_NAME, ""));
        assertEquals("role", settings.getAsString(SuggestSettings.DefaultKeys.ROLE_FIELD_NAME, ""));
    }