assertThat(UnsignedBytes.saturatedCast(-1L)).isEqualTo(LEAST);
    assertThat(UnsignedBytes.saturatedCast(Long.MAX_VALUE)).isEqualTo(GREATEST);
    assertThat(UnsignedBytes.saturatedCast(Long.MIN_VALUE)).isEqualTo(LEAST);
  }

  private static void assertCastFails(long value) {
    try {
      UnsignedBytes.checkedCast(value);
      fail("Cast to byte should have failed: " + value);

    @Test
    @DisplayName("Should handle different previous session IDs")
    void testDifferentPreviousSessionIds() throws Exception {
        // Given
        long[] sessionIds = { 0L, 1L, Long.MAX_VALUE, Long.MIN_VALUE, 0xFFFFFFFFFFFFFFFFL };

        for (long sessionId : sessionIds) {
            Smb2SessionSetupRequest req = new Smb2SessionSetupRequest(mockContext, TEST_SECURITY_MODE, TEST_CAPABILITIES, sessionId, null);

    public void test_constructorAndGetters() {
        final String name = "test-file.txt";
        final String path = "/documents/";
        final boolean directory = false;
        final long size = 1024L;
        final ZonedDateTime lastModified = ZonedDateTime.of(2025, 1, 15, 10, 30, 0, 0, ZoneId.systemDefault());
        final String encodedId = "dGVzdC1maWxlLnR4dA==";

        runTest(number, count)
      }
      updateReports()
    } finally {
      client.dispatcher.executorService.shutdown()
    }
  }

  private fun runTest(
    number: Long,
    count: Long,
  ) {
    val latch = CountDownLatch(1)
    val startNanos = AtomicLong()
    newWebSocket(
      "/runCase?case=$number&agent=okhttp",
      object : WebSocketListener() {
        override fun onOpen(

 */
public class User extends BsUser implements FessUser {

    private static final long serialVersionUID = 1L;

    private String originalPassword;

    private Map<String, String> attributes;

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

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

    public String getId() {

import okhttp3.HttpUrl.Companion.toHttpUrlOrNull
import okhttp3.TlsVersion
import okio.Buffer

class RecordedRequest {
  val requestLine: String
  val headers: Headers
  val chunkSizes: List<Int>
  val bodySize: Long
  val body: Buffer
  val sequenceNumber: Int
  val failure: IOException?
  val method: String?
  val path: String?
  val handshake: Handshake?
  val requestUrl: HttpUrl?

  @get:JvmName("-deprecated_utf8Body")

     *
     * @return The total number of words.
     */
    public long getAllWordsNum() {
        return suggester.getAllWordsNum();
    }

    /**
     * Gets the number of words from documents in the suggest index.
     *
     * @return The number of document words.
     */
    public long getDocumentWordsNum() {
        return suggester.getDocumentWordsNum();
    }

    /**

        assertEquals("Map contents should match", original, deserialized);
    }

    /**
     * Test serialization of Long values
     */
    @Test
    public void test_serializeDeserialize_long() {
        Long original = 9876543210L;

        byte[] serialized = serializer.fromObjectToBinary(original);
        assertNotNull(serialized, "Serialized data should not be null");

     * @param paramMap The parameters.
     * @return The read interval.
     */
    protected long getReadInterval(final DataStoreParams paramMap) {
        long readInterval = 0;
        final String value = paramMap.getAsString("readInterval");
        if (StringUtil.isNotBlank(value)) {
            try {
                readInterval = Long.parseLong(value);
            } catch (final NumberFormatException e) {

    /**
     * Timeout in milliseconds for thumbnail task queue operations.
     */
    protected long thumbnailTaskQueueTimeout = 10 * 1000L;

    /**
     * Expiration time in milliseconds for no-image placeholder files.
     */
    protected long noImageExpired = 24 * 60 * 60 * 1000L; // 24 hours

    /**
     * Hash size for splitting thumbnail storage directories.
     */