import java.util.stream.Collectors;
import java.util.stream.StreamSupport;

import org.apache.hc.client5.http.config.ConnectionConfig;
import org.apache.hc.client5.http.config.RequestConfig;
import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
import org.apache.hc.client5.http.impl.classic.HttpClients;
import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManagerBuilder;
import org.apache.hc.core5.util.Timeout;

		</dependency>
		<dependency>
			<groupId>com.google.oauth-client</groupId>
			<artifactId>google-oauth-client</artifactId>
			<version>${google.oauth.client.version}</version>
		</dependency>
		<dependency>
			<groupId>com.google.http-client</groupId>
			<artifactId>google-http-client</artifactId>
			<version>${google.http.client.version}</version>
			<exclusions>
				<exclusion>

    }

    // Test multiple instances
    @Test
    public void test_multipleInstances() {
        // Test that multiple instances can be created independently
        CrawlerEngineClient client1 = new CrawlerEngineClient();
        CrawlerEngineClient client2 = new CrawlerEngineClient();

        assertNotNull(client1);
        assertNotNull(client2);

                        client.isAvailable());
            }
            return client;
        }
        // Fallback: search registered clients
        for (final LlmClient client : clientList) {
            if (llmType.equals(client.getName())) {
                if (logger.isTraceEnabled()) {
                    logger.trace("[LLM] LlmClient found via registration. name={}", client.getName());
                }

    /**
     * Returns the name of this LLM client.
     *
     * @return the client name (e.g., "ollama", "openai", "gemini")
     */
    String getName();

    /**
     * Checks if this LLM client is available and properly configured.
     *
     * @return true if the client is available, false otherwise
     */
    boolean isAvailable();

    // RAG workflow methods

    }

    @Test
    public void test_generateSummaryResponse_singleDocWithinLimit() {
        client.setTestContextMaxChars(10000);
        client.setTestSystemPrompt("system");
        client.setTestSummarySystemPrompt("{{systemPrompt}}\n{{documentContent}}\n{{languageInstruction}}");

        final List<Map<String, Object>> documents = new ArrayList<>();

     *
     * @return the thread pool
     */
    @Override
    public ThreadPool threadPool() {
        return client.threadPool();
    }

    /**
     * Gets the admin client for cluster and index administration.
     *
     * @return the admin client
     */
    @Override
    public AdminClient admin() {
        return client.admin();
    }

    /**

                return Collections.emptyList();
            }
        };
        ComponentUtil.register(client, "searchEngineClient");
        final DocList docList = new DocList();
        indexingHelper.sendDocuments(client, docList);
        assertEquals(0, docList.size());
        assertEquals(0, sentDocList.size());
        assertNull(sentIndex.get());

            // If it succeeds, check that lastUpdated is set
            assertNotNull(jobLog.getLastUpdated());
        } catch (Exception e) {
            // Expected in test environment due to missing client
            assertTrue(e.getMessage().contains("client"));
        }
    }

    @Test
    public void test_monitorTarget_expired_withEndTime() {
        JobLog jobLog = new JobLog();
        jobLog.setId("test-log-2");

        return ComponentUtil.getFessConfig().getIndexLogIndex() + ".notification_queue";
    }

    private void ensureIndexExists(final SearchEngineClient client, final String indexName) {
        if (!indexChecked) {
            if (!client.existsIndex(indexName)) {
                client.createIndex(NOTIFICATION_QUEUE_INDEX, indexName);
            }
            indexChecked = true;
        }
    }