*/
    var markdownDomPurifyInitialized = false;
    var markdownSanitizeConfig = {
        ALLOWED_TAGS: ['h1','h2','h3','h4','h5','h6',
                       'p','br','hr',
                       'strong','em','b','i','u','s','del',
                       'ul','ol','li',
                       'code','pre',
                       'blockquote',
                       'table','thead','tbody','tr','th','td',

        List<Map<String, Object>> page1 = JsonPath.from(response).getList("response.logs");

        logger.info("Page 1: {}", page1);

        // Get second page
        searchBody.put("page", 2);
        response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();
        List<Map<String, Object>> page2 = JsonPath.from(response).getList("response.logs");

        // Note: Set-based O(1) lookup should be much faster than O(n) array iteration
        assertTrue("Set-based lookup should complete quickly (duration: " + duration / 1_000_000 + "ms)", duration < 1_000_000_000); // 1 second (relaxed from 100ms for CI)
    }

    /**
     * Test convertWithFieldCheck() with DEFAULT_FIELD.
     */
    @Test
    public void test_convertWithFieldCheck_withDefaultField() {

        updateItem2.setNewInputs(new String[] { "p", "q" });
        updateItem2.setNewOutput("r");

        // First update should succeed
        charMappingFile.update(updateItem1);

        // Second update should fail due to mismatch
        try {
            charMappingFile.update(updateItem2);
            fail("Should throw DictionaryException");
        } catch (DictionaryException e) {

        } catch (Exception e) {
            // Expected
        }
        long duration = System.currentTimeMillis() - startTime;

        // Test should complete in under 1 second (much less than the original 25+ seconds)
        assertTrue("Test should complete quickly (duration: " + duration + "ms)", duration < 1000);
    }

    // Fast mock implementations to minimize overhead

        String result = pythonJob.execute();

        assertNotNull(result);
        assertTrue(result.contains("Session Id:"));
        assertTrue(result.contains("Process is terminated due to 60 second exceeded") || result.contains("Process terminated"));
    }

    // Test executePython with blank filename
    @Test
    public void test_executePython_blankFilename() {
        pythonJob.filename("");

     *
     * @param zos the ZIP output stream to write to
     * @param id the diagnostic ID for organizing files in the ZIP
     * @param v1 the first part of the API path (e.g., "cluster", "nodes")
     * @param v2 the second part of the API path (e.g., "health", "stats")
     */
    protected void writeElastisearchJsonApi(final ZipOutputStream zos, final String id, final String v1, final String v2) {

        assertEquals(0, session.getMessageCount());

        session.addUserMessage("First");
        assertEquals(1, session.getMessageCount());

        session.addAssistantMessage("Second");
        assertEquals(2, session.getMessageCount());
    }

    @Test
    public void test_getMessageCountWithNullMessages() {
        final ChatSession session = new ChatSession();

        RankFusionProcessor processor = new RankFusionProcessor();
        processor.setSearcher(new TestSearcher(100));
        processor.init();

        // First close
        processor.close();
        // Second close - should not throw exception
        processor.close();
    }

    /**
     * Test searcher that returns configurable number of documents.
     */

        final Map<String, Object> doc = new HashMap<>();
        doc.put("title", "Test");
        doc.put("url", "http://example.com");
        doc.put("content", "<p>HTML <strong>content</strong></p>");
        documents.add(doc);

        final List<LlmMessage> history = Collections.emptyList();
        final StringBuilder captured = new StringBuilder();