when(request.getSession()).thenReturn(session);

            ntlmServlet.service(request, response);

            // Verify that user information is stored in the session
            verify(session).setAttribute("NtlmHttpAuth", ntlmAuth);
            verify(session).setAttribute("ntlmuser", "user");
            verify(session).setAttribute("ntlmdomain", "TEST_DOMAIN");

    }

    public void test_add() {
        // Setup
        String sessionId = "session123";
        String url = "https://example.com/page";
        Queue<UrlQueueImpl<Long>> mockQueue = new LinkedList<>();

        when(dataHelper.getUrlQueueList(sessionId)).thenReturn(mockQueue);

        // Execute
        service.add(sessionId, url);

        // Verify
        assertEquals(1, mockQueue.size());

        verify(treeConnection, times(2)).isConnected();
    }

    @Test
    @DisplayName("getSession returns underlying session from tree connection")
    void getSessionReturnsUnderlying() {
        // Verifies getSession() exposes the session provided by the connection
        assertSame(session, handle.getSession());
        verify(treeConnection).getSession();
    }

    @Test

        // Second poll should return null (queue is empty)
        final OpenSearchUrlQueue polled2 = urlQueueService.poll(sessionId);
        assertNull(polled2);

        urlQueueService.delete(sessionId);
    }

    public void test_poll_multipleItemsTx() {
        final String sessionId = "poll_session3";
        final List<OpenSearchUrlQueue> urlQueueList = new ArrayList<>();

    /** Called name not present */
    public static final int CALLED_NOT_PRESENT = 0x82;
    /** Insufficient resources to establish session */
    public static final int NO_RESOURCES = 0x83;
    /** Unspecified session service error */
    public static final int UNSPECIFIED = 0x8F;

    /** The NetBIOS error class */
    public int errorClass;
    /** The NetBIOS error code */

    /**
     *
     */
    private Smb3KeyDerivation() {
    }

    /**
     * Derives the SMB3 signing key from the session key using the appropriate KDF for the dialect.
     *
     * @param dialect the SMB dialect version
     * @param sessionKey the base session key
     * @param preauthIntegrity the pre-authentication integrity hash (for SMB 3.1.1) or null
     * @return derived signing key
     */

  <!--                                                                    Session Config -->
  <!--                                                                    ============== -->
<!--
    <session-config>
        <session-timeout>1</session-timeout>
    </session-config>
  -->

  <!-- ================================================================================= -->

        if (StringUtil.isBlank(crawlingInfoId)) {
            throw new CrawlingAccessException("sessionId is null. Cannot access document without a valid session ID.");
        }

        final CrawlerClientFactory crawlerClientFactory = crawlingConfig.initializeClientFactory(ComponentUtil::getCrawlerClientFactory);

import jcifs.internal.smb1.AndXServerMessageBlock;
import jcifs.internal.smb1.ServerMessageBlock;
import jcifs.internal.util.SMBUtil;

/**
 * SMB1 Session Setup AndX Response message.
 *
 * This response contains information about the established session,
 * including native OS, LAN manager, and primary domain information.
 */
public class SmbComSessionSetupAndXResponse extends AndXServerMessageBlock {

    private final int maxChannels;
    private final AtomicInteger channelCounter;
    
    public ChannelManager(CIFSContext context, SmbSession session) {
        this.context = context;
        this.session = session;
        this.channels = new ConcurrentHashMap<>();
        this.localInterfaces = new ArrayList<>();
        this.remoteInterfaces = new ArrayList<>();