}

                        break;
                    default:
                        throw new SmbException("Unexpected session setup state: " + state);
                    }
                } while (state != 0);
            } catch (final SmbException se) {
                logoff(true);
                connectionState = 0;
                throw se;
            } finally {

            assertEquals(address, connection.getRemoteAddress(), "Remote address should match");
            assertNotNull(connection.getState(), "Connection state should not be null");

            System.out.println("RDMA connection created to: " + address);
            System.out.println("Connection state: " + connection.getState());
        }
    }

    @Test
    public void testRdmaTransportCreationWithMockDelegate() throws Exception {

**Endpoint**: `PUT /api/admin/documents/bulk`

**Format**: NDJSON (Newline-Delimited JSON)

**Example**:
```bash
# Create NDJSON file
cat > documents.ndjson << 'EOF'
{"url":"http://example.com/page1","title":"Page 1","content":"Content here..."}
{"url":"http://example.com/page2","title":"Page 2","content":"More content..."}
EOF

# Import via API
curl -X PUT "http://localhost:8080/api/admin/documents/bulk" \

        this.leaseKey = leaseKey;
    }

    /**
     * Gets the current lease state flags for this directory
     * @return the lease state
     */
    public int getLeaseState() {
        return leaseState;
    }

    /**
     * Sets the lease state flags for this directory
     * @param leaseState the lease state to set
     */
    public void setLeaseState(int leaseState) {

            assertEquals(0, result);
        }
    }

    @Nested
    @DisplayName("Response State Tests")
    class ResponseStateTests {

        @Test
        @DisplayName("Should track received state")
        void testReceivedState() {
            assertFalse(echoResponse.isReceived());

            echoResponse.received();

        rule.clearConditions();

        // Should match after clearing conditions
        assertTrue(rule.match(responseData));
    }

    /**
     * Test rule matching with various ResponseData states
     */
    public void test_matchWithVariousResponseDataStates() {
        ConfigurableRule rule = new ConfigurableRule();
        rule.setRuleId("stateRule");

  public HttpUrl authorizeUrl(String scopes, HttpUrl redirectUrl, ByteString state, String team) {
    HttpUrl.Builder builder = baseUrl.newBuilder("/oauth/authorize")
        .addQueryParameter("client_id", clientId)
        .addQueryParameter("scope", scopes)
        .addQueryParameter("redirect_uri", redirectUrl.toString())
        .addQueryParameter("state", state.base64());

    if (team != null) {

    private Response mockResponse;

    @BeforeEach
    void setUp() {
        // Reset mock before each test to ensure clean state
        // MockitoExtension handles this automatically for @Mock fields, but good to be aware.
    }

    @Test
    void testIsReceived() {
        // Test initial state (should be false by default for a fresh mock)
        assertFalse(mockResponse.isReceived());

        // Simulate received status

    int ERROR_SUCCESS = 0;
    /** Access is denied */
    int ERROR_ACCESS_DENIED = 5;
    /** No more connections can be made to this remote computer */
    int ERROR_REQ_NOT_ACCEP = 71;
    /** The pipe state is invalid */
    int ERROR_BAD_PIPE = 230;
    /** All pipe instances are busy */
    int ERROR_PIPE_BUSY = 231;
    /** The pipe is being closed */
    int ERROR_NO_DATA = 232;

    int ERROR_SUCCESS = 0;
    /** Access is denied */
    int ERROR_ACCESS_DENIED = 5;
    /** No more connections can be made to this remote computer */
    int ERROR_REQ_NOT_ACCEP = 71;
    /** The pipe state is invalid */
    int ERROR_BAD_PIPE = 230;
    /** All pipe instances are busy */
    int ERROR_PIPE_BUSY = 231;
    /** The pipe is being closed */
    int ERROR_NO_DATA = 232;