sessionContexts.put(sessionId, context);

        log.debug("Initialized preauth integrity context for session {}", sessionId);
        return context;
    }

    /**
     * Updates the preauth integrity hash with a new message.
     *
     * @param sessionId the session identifier
     * @param messageData the message data to include in hash

     */
    @Override
    public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException {
        builder.startObject();
        if (sessionId != null) {
            builder.field(SESSION_ID, sessionId);
        }
        if (method != null) {
            builder.field(METHOD, method);
        }
        if (url != null) {
            builder.field(URL, url);
        }

     *
     * @param sessionId the ID of the session for which the URL filter is being added
     * @param url the URL to be included in the filter list
     */
    void addIncludeUrlFilter(String sessionId, String url);

    /**
     * Adds a list of URLs to the include filter for a given session.
     *
     * @param sessionId the ID of the session for which the URLs should be included

     */
    public static class ChannelGroup {
        private final String sessionId;
        private final List<ChannelInfo> channels = new CopyOnWriteArrayList<>();
        private final AtomicInteger roundRobinIndex = new AtomicInteger(0);
        private volatile ChannelInfo primaryChannel;

        public ChannelGroup(String sessionId) {
            this.sessionId = sessionId;
        }

        public String getSessionId() {

            crawler.crawlerContext.setNumOfThread(numOfThread);
            crawler.urlFilter.addInclude(url + ".*");
            final String sessionId = crawler.execute();
            assertEquals(maxCount, dataService.getCount(sessionId));
            dataService.delete(sessionId);
        } finally {
            server.stop();
        }
    }

    public void test_execute_xmlSitemaps() throws Exception {

     * @return The session ID.
     */
    public String getSessionId() {
        return sessionId;
    }

    /**
     * Sets the session ID.
     * @param sessionId The session ID.
     */
    public void setSessionId(final String sessionId) {
        this.sessionId = sessionId;
    }

    /**
     * Returns the active thread count.
     * @return The active thread count.
     */

     *
     * @param sessionId The session ID of the document.
     * @param url The URL of the document.
     * @return true if the document exists, false otherwise.
     * @throws OpenSearchAccessException if the existence check fails.
     */
    protected boolean exists(final String sessionId, final String url) {
        final String id = getId(sessionId, url);
        try {

        // Get the sessionId field using reflection
        Field sessionIdField = NtlmPasswordAuthenticator.class.getDeclaredField("sessionId");
        sessionIdField.setAccessible(true);

        // Initially sessionId should be null
        String initialSessionId = (String) sessionIdField.get(authenticator);
        assertNull(initialSessionId, "SessionId should initially be null");
    }

    @Test

    }

    public CrawlingInfo(final String sessionId) {
        setSessionId(sessionId);
    }

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {
        asDocMeta().version(version);
    }

     * @param sessionId The session ID.
     */
    @Override
    public void delete(final String sessionId) {
        deleteBySessionId(sessionId);
    }

    /**
     * Gets an access result by session ID and URL.
     *
     * @param sessionId The session ID.
     * @param url The URL.
     * @return The access result, or null if not found.
     */
    @Override