fess_doc = {
            "url": doc.get("url", ""),
            "title": doc.get("title", ""),
            "content": doc.get("content", ""),
            "mimetype": doc.get("mimetype", "text/html"),
            "filetype": doc.get("filetype", "html"),
            "created": doc.get("@timestamp", ""),
            "timestamp": doc.get("@timestamp", ""),
            # Add custom fields as needed
        }

    synchronized (lock) {
      return cachingHashMap.isEmpty();
    }
  }

  @Override
  public @Nullable V get(@Nullable Object key) {
    Timestamped<V> value;
    synchronized (lock) {
      checkNotNull(key);
      value = cachingHashMap.get(key);

      if (value == null) {
        statsCounter.recordMisses(1);
        return null;
      }
      if (!isExpired(value)) {

    }
  }

  /** get returns the last value set at index */
  public void testGetSet() {
    AtomicDoubleArray aa = new AtomicDoubleArray(VALUES.length);
    for (int i = 0; i < VALUES.length; i++) {
      assertBitEquals(0.0, aa.get(i));
      aa.set(i, VALUES[i]);
      assertBitEquals(VALUES[i], aa.get(i));
      aa.set(i, -3.0);
      assertBitEquals(-3.0, aa.get(i));
    }
  }

        }

        CurlRequest request = new CurlRequest(Method.GET, longUrl.toString());
        assertNotNull(request);
        assertEquals(Method.GET, request.method());
    }

    @Test
    public void testManyParams() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");

        // Add many parameters
        for (int i = 0; i < 100; i++) {

    assertEquals(2, factory.count);
    assertThat(multimap.get(Color.BLUE).toString()).isEqualTo("[3, 1, 4]");

    Multimap<Color, Integer> ummodifiable = Multimaps.unmodifiableMultimap(multimap);
    assertThat(ummodifiable.get(Color.BLUE).toString()).isEqualTo("[3, 1, 4]");

    Collection<Integer> collection = multimap.get(Color.BLUE);
    // Explicitly call `equals`; `assertEquals` might return fast

 */
public interface FessUser extends Serializable {

    /**
     * Gets the user's display name.
     * @return The user's name.
     */
    String getName();

    /**
     * Gets the user's assigned role names.
     * @return Array of role names.
     */
    String[] getRoleNames();

    /**
     * Gets the user's assigned group names.
     * @return Array of group names.
     */

        activityHelper.login(createUser("testuser", new String[0]));
        assertEquals("action:LOGIN\tuser:testuser\tpermissions:-", localLogMsg.get());

        activityHelper.login(createUser("testuser", new String[] { "111", "222" }));
        assertEquals("action:LOGIN\tuser:testuser\tpermissions:111|222", localLogMsg.get());
    }

    @Test

    AtomicInteger runCalled = new AtomicInteger();
    list.add(runCalled::getAndIncrement, directExecutor());
    list.execute();
    assertEquals(1, runCalled.get());
    list.execute();
    assertEquals(1, runCalled.get());
  }

  public void testExecute_idempotentConcurrently() throws InterruptedException {
    CountDownLatch okayToRun = new CountDownLatch(1);
    AtomicInteger runCalled = new AtomicInteger();

        assertEquals(ChatMessage.ROLE_USER, messages.get(0).getRole());
        assertEquals("User 2", messages.get(0).getContent());
        assertEquals(ChatMessage.ROLE_ASSISTANT, messages.get(1).getRole());
        assertEquals("Assistant 2", messages.get(1).getContent());
        assertEquals(ChatMessage.ROLE_USER, messages.get(2).getRole());
        assertEquals("User 3", messages.get(2).getContent());

    }

    // Test put and get operations
    @Test
    public void test_putAndGet() {
        dataStoreParams.put("key1", "value1");
        assertEquals("value1", dataStoreParams.get("key1"));

        dataStoreParams.put("key2", 123);
        assertEquals(123, dataStoreParams.get("key2"));

        dataStoreParams.put("key3", null);
        assertNull(dataStoreParams.get("key3"));
    }