* governing permissions and limitations under the License.
 */
package org.codelibs.fess.entity;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;

import org.codelibs.fess.unit.UnitFessTestCase;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

public class ChatSessionTest extends UnitFessTestCase {

    @Override

 */
package org.codelibs.fess.crawler.service.impl;

import static org.codelibs.opensearch.runner.OpenSearchRunner.newConfigs;

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;

import org.codelibs.fess.crawler.client.FesenClient;

        logger.info("[BEGIN] bulkCreateEmptyListTest");

        // Test with empty document list - should return error status
        final Map<String, Object> requestBody = new HashMap<>();
        final List<Map<String, Object>> documents = new ArrayList<>();
        requestBody.put("documents", documents);

        // Execute bulk create with empty list - expect error status (1)

    List<T> list = Arrays.asList(inputs);
    doExpectCollects(expectedResult, list);
    if (collector.characteristics().contains(Collector.Characteristics.UNORDERED)) {
      Collections.reverse(list);
      doExpectCollects(expectedResult, list);
    }
    return this;
  }

  private void doExpectCollects(R expectedResult, List<T> inputs) {

    val dispatcher: Dispatcher = client.dispatcher()
    val proxy: Proxy? = client.proxy()
    val protocols: List<Protocol> = client.protocols()
    val connectionSpecs: List<ConnectionSpec> = client.connectionSpecs()
    val interceptors: List<Interceptor> = client.interceptors()
    val networkInterceptors: List<Interceptor> = client.networkInterceptors()
    val eventListenerFactory: EventListener.Factory = client.eventListenerFactory()

- view:
    name: "Elasticsearch %BRANCH%"
    view-type: list
    regex: '^elastic[-+]elasticsearch\+%BRANCH%\+((?!multijob).)*$'
- view:
    name: "Elasticsearch Pull Requests"
    view-type: list

                size.decrementAndGet();
            }
        }
    }

    /**
     * Drains all events from the buffer and returns them as a list.
     *
     * @return a list of all buffered events
     */
    public List<LogNotificationEvent> drainAll() {
        final List<LogNotificationEvent> events = new ArrayList<>();
        LogNotificationEvent event;
        while ((event = queue.poll()) != null) {

     */
    protected void addHistoryWithBudget(final LlmChatRequest request, final List<LlmMessage> history, final int budgetChars) {
        if (history.isEmpty()) {
            return;
        }

        // Build turn list: group adjacent user-assistant pairs as turns, standalone messages as single-message turns
        final List<int[]> turns = new ArrayList<>();
        int idx = 0;
        while (idx < history.size()) {

         * @param p The process to monitor.
         * @param ist The input stream thread.
         * @param timeout The destruction timeout.
         */
        public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) {
            this.p = p;
            this.ist = ist;
            this.timeout = timeout;
        }

        /**

    /**
     * The Fess configuration.
     */
    @Resource
    protected FessConfig fessConfig;

    /**
     * Get the list of access tokens.
     * @param accessTokenPager The pager for access token.
     * @return The list of access tokens.
     */
    public List<AccessToken> getAccessTokenList(final AccessTokenPager accessTokenPager) {