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());
                }

        assertEquals(0, result.get(ConfigName.CLIENT).size());

        // Test with client parameters
        configParameters = "client.host=localhost\nclient.port=9200";
        result = ParameterUtil.createConfigParameterMap(configParameters);
        assertEquals(2, result.get(ConfigName.CLIENT).size());
        assertEquals("localhost", result.get(ConfigName.CLIENT).get("host"));

    /**
     * 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

        assertEquals("https://accounts.google.com/o/oauth2/token", url);
    }

    @Test
    public void test_getOicClientId_default() {
        final String clientId = authenticator.getOicClientId();
        assertEquals("", clientId);
    }

    @Test
    public void test_getOicClientSecret_default() {
        final String secret = authenticator.getOicClientSecret();
        assertEquals("", secret);

    }

    @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());