/**
     * Generates a summary of the specified documents.
     *
     * @param userMessage the user's message
     * @param documents the documents to summarize
     * @param history the conversation history
     * @param callback the streaming callback
     */
    void generateSummaryResponse(String userMessage, List<Map<String, Object>> documents, List<LlmMessage> history,
            LlmStreamCallback callback);

            doc.put("role", "Rguest");
            documents.add(doc);
        }

        requestBody.put("documents", documents);

        // Execute bulk create
        checkMethodBase(requestBody).put(API_PATH + "/" + BULK_ENDPOINT).then().body("response.status", equalTo(0));
        refresh();

        // Verify documents were created
        final Map<String, Object> searchBody = new HashMap<>();

     *
     * @param userMessage the user's message
     * @param documents the documents with content
     * @param history the conversation history
     * @return the chat response
     * @throws LlmException if LLM is not available
     */
    public LlmChatResponse generateAnswer(final String userMessage, final List<Map<String, Object>> documents,
            final List<LlmMessage> history) {

            final List<LlmMessage> history) {
        if (logger.isDebugEnabled()) {
            logger.debug("[RAG:ANSWER] generateAnswer. userMessage={}, documentCount={}, historySize={}", userMessage, documents.size(),
                    history.size());
        }
        final String context = buildContext(documents, "answer");

    @Test
    public void test_execute_success() {
        String result = updateLabelJob.execute();
        assertNotNull(result);
        assertTrue(result.contains("3 documents")); // 3 documents processed
        assertFalse(result.contains("exception"));
    }

    // Test execute() method with query builder
    @Test
    public void test_execute_withQueryBuilder() {

        public ChatSearchResult(final List<Map<String, Object>> documents, final String queryId, final long requestedTime) {
            this.documents = documents;
            this.queryId = queryId;
            this.requestedTime = requestedTime;
        }

        /**
         * Gets the search result documents.
         *
         * @return the list of documents
         */

     * Creates a new IndexExportJob instance.
     */
    public IndexExportJob() {
        // default constructor
    }

    /**
     * Sets the query to filter which documents to export.
     *
     * @param queryBuilder the query to use for filtering documents
     * @return this instance for method chaining
     */
    public IndexExportJob query(final QueryBuilder queryBuilder) {
        this.queryBuilder = queryBuilder;

    /**
     * Creates a result with no relevant documents found.
     *
     * @return evaluation result with no relevant documents
     */
    public static RelevanceEvaluationResult noRelevantResults() {
        return new RelevanceEvaluationResult(Collections.emptyList(), Collections.emptyList(), false);
    }

    /**
     * Creates a fallback result that includes all documents as relevant.

        final List<Map<String, Object>> documents = new ArrayList<>();
        final Map<String, Object> doc = new HashMap<>();
        doc.put("title", "Test Doc");
        doc.put("url", "http://example.com");
        doc.put("content", "Plain text content without any HTML");
        documents.add(doc);

        final String result = client.testBuildContext(documents);

            final CountDownLatch latch = new CountDownLatch(1);

            logger.info("Parsing words from indexed documents.");
            suggestHelper.indexFromDocuments(ret -> {
                logger.info("Success indexing from documents.");
                latch.countDown();
            }, t -> {
                logger.error("Failed to update suggest index.", t);