// Generate unique session ID for key management
        this.sessionId = String.format("smb-enc-%d-%d", System.currentTimeMillis(), secureRandom.nextLong());

        if (keyManager != null) {
            // Store keys securely
            String encKeyId = sessionId + "-enc";
            String decKeyId = sessionId + "-dec";
            keyManager.storeSessionKey(encKeyId, encryptionKey, "AES");

     * @param sessionId the session ID
     * @return the URL queue for the session
     */
    public synchronized Queue<UrlQueueImpl<Long>> getUrlQueueList(final String sessionId) {
        Queue<UrlQueueImpl<Long>> urlQueueList = urlQueueMap.get(sessionId);
        if (urlQueueList == null) {
            urlQueueList = new LinkedList<>();
            urlQueueMap.put(sessionId, urlQueueList);
        }

        assertArrayEquals(testKey, rawKey2, "Should still match original");
    }

    @Test
    public void testRemoveSessionKey() {
        String sessionId = "test-session-3";
        keyManager.storeSessionKey(sessionId, testKey, "AES");

        assertTrue(keyManager.hasSessionKey(sessionId), "Key should exist");

        keyManager.removeSessionKey(sessionId);

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

    /**
     * Gets the list of include URL patterns for the specified session.
     *
     * @param sessionId The session ID.

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

        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

    public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
        setSessionId_Terms("sessionId", opLambda, null);
    }

    public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsCrawlingInfoCA> aggsLambda) {
        setSessionId_Terms("sessionId", opLambda, aggsLambda);
    }

// Print implement Logger
func (log *minioLogger) Print(sessionID string, message any) {
	if serverDebugLog {
		fmt.Printf("%s %s\n", sessionID, message)
	}
}

// Printf implement Logger
func (log *minioLogger) Printf(sessionID string, format string, v ...any) {
	if serverDebugLog {
		if sessionID != "" {
			fmt.Printf("%s %s\n", sessionID, fmt.Sprintf(format, v...))
		} else {
			fmt.Printf(format+"\n", v...)

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

     *
     * @param sessionId the session ID whose data should be deleted
     */
    private void deleteBySessionId(final String sessionId) {
        try {
            urlFilterService.delete(sessionId);
        } catch (final Exception e) {
            logger.warn("Failed to delete UrlFilter: sessionId={}", sessionId, e);
        }
        try {