if (messages != null && messages.size() > maxMessages) {
                int start = messages.size() - maxMessages;
                // Ensure trimmed history starts with a user message, not an assistant message
                if (start < messages.size() && ChatMessage.ROLE_ASSISTANT.equals(messages.get(start).getRole())) {
                    start = Math.max(0, start - 1);
                }

                }
            } catch (Exception e) {
                exceptions[readerCount] = e;
            }
        });

        // Start all threads
        for (Thread reader : readers) {
            reader.start();
        }
        writer.start();

        // Wait for completion
        for (Thread reader : readers) {
            reader.join();
        }
        writer.join();

    }

    /**
     * Displays the start crawling form.
     *
     * @return HTML response for the start crawling form
     */
    @Execute
    @Secured({ ROLE })
    public HtmlResponse startCrawlingForm() {
        saveToken();
        return asHtml(path_AdminWizard_AdminWizardStartJsp).useForm(StartCrawlingForm.class);
    }

    /**
     * Starts the crawling process for all configured crawlers.

    @Execute(urlPattern = "{}/@word")
    public JsonResponse<ApiResult> put$start(final String id) {
        final String[] jobLogId = { null };
        scheduledJobService.getScheduledJob(id).ifPresent(entity -> {
            if (!entity.isEnabled() || entity.isRunning()) {
                throwValidationErrorApi(messages -> {
                    messages.addErrorsFailedToStartJob(GLOBAL, entity.getName());
                });

            if (response.getBody().jsonPath().getInt("response.status") == 0) {
                logger.info("Start scheduler \"{}\"", schedulerId);
                return;
            }
            ThreadUtil.sleep(100L);
        }
        fail("could not start job.");
    }

    protected static void waitJob(final String namePrefix) {

        session.addUserMessage("User 3");
        session.addAssistantMessage("Assistant 3");
        assertEquals(6, session.getMessageCount());

        // Trimming to 3 would start at index 3 (assistant), so it should go back to index 2 (user)
        session.trimHistory(3);

        final List<ChatMessage> messages = session.getMessages();
        assertEquals(4, messages.size());

                String value = (String) field.get(null);
                assertNotNull("Field value should not be null: " + field.getName(), value);
                assertTrue("Field value should start with {labels.: " + field.getName() + " = " + value, value.startsWith("{labels."));
                assertTrue("Field value should end with }: " + field.getName() + " = " + value, value.endsWith("}"));
            }
        }

        InputStream is = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));

        InputStreamThread thread = new InputStreamThread(is, StandardCharsets.UTF_8, 5, null);
        thread.start();
        thread.join(1000);

        String output = thread.getOutput();
        assertTrue(output.contains("line1"));
        assertTrue(output.contains("line2"));
        assertTrue(output.contains("line3"));
    }

        long start = System.currentTimeMillis();
        helper.checkCrawlerStatus();
        long end = System.currentTimeMillis();
        assertTrue(end - start < 100); // Should return quickly

        // Test when crawler is not running
        helper.setCrawlerRunning(false);
        assertFalse(helper.isCrawlerRunning());

        // Start a thread to set crawler running after a delay

            pb.redirectErrorStream(true);

            if (logger.isDebugEnabled()) {
                logger.debug("Thumbnail Command: {}", cmdList);
            }

            p = pb.start();
            ist = new InputStreamThread(p.getInputStream(), Charset.defaultCharset(), 0, s -> {
                if (logger.isDebugEnabled()) {
                    logger.debug(s);
                }
            });