}

    @Test
    public void test_loginPaths() throws Exception {
        // Test login-related paths
        assertEquals("/login/index.jsp", FessHtmlPath.path_Login_IndexJsp.getRoutingPath());
        assertEquals("/login/newpassword.jsp", FessHtmlPath.path_Login_NewpasswordJsp.getRoutingPath());
    }

    @Test
    public void test_configPaths() throws Exception {
        // Test configuration paths

    void resolve(RepositoryMetadata repositoryMetadata, RepositoryRequest repositoryRequest)
            throws RepositoryMetadataResolutionException;

    void resolve(
            RepositoryMetadata repositoryMetadata,
            List<ArtifactRepository> repositories,
            ArtifactRepository localRepository)
            throws RepositoryMetadataResolutionException;

    void resolveAlways(

  }

  public void testOpenBufferedStream() throws IOException {
    Writer writer = sink.openBufferedStream();
    assertTrue(sink.wasStreamOpened());
    assertFalse(sink.wasStreamClosed());

    writer.write(STRING);
    writer.close();

    assertTrue(sink.wasStreamClosed());
    assertThat(sink.getString()).isEqualTo(STRING);
  }

  public void testWrite_string() throws IOException {

        void acceptWithNullThrows() {
            SmbFileFilter throwOnNull = new SmbFileFilter() {
                @Override
                public boolean accept(SmbFile file) throws SmbException {
                    if (file == null) {
                        throw new SmbException("null file");
                    }
                    return true;
                }
            };

    }

    @Test
    @DisplayName("Filter throws CIFSException: entry is skipped and iteration continues")
    void filterThrows_skipsAndContinues() throws Exception {
        SmbFile parent = newParent();
        List<FileEntry> entries = Arrays.asList(entry("bad", SmbConstants.TYPE_SHARE), entry("good", SmbConstants.TYPE_SHARE));

        // First call throws, second accepts

  public void testSuccessful() throws Exception {
    TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
    assertFalse(task.isDone());
    task.run();
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
    assertEquals(2, getDone(task).intValue());
  }

  public void testCancelled() throws Exception {

     *            methods.
     * @throws CIFSException if there is an error resolving the SIDs
     */
    void resolveSids(CIFSContext tc, String authorityServerName, SID[] sids) throws CIFSException;

    /**
     * Resolve part of an array of SIDs using a cache and at most one MSRPC request.
     *

     *
     * @return the available LLM client
     * @throws LlmException if LLM client is not available
     */
    protected LlmClient getAvailableClient() {
        final String llmType = getLlmType();
        if (Constants.NONE.equals(llmType)) {
            throw new LlmException("LLM client is not available");
        }
        if (!isRagChatEnabled()) {
            throw new LlmException("LLM client is not available");
        }

public class RankFusionProcessorErrorHandlingTest extends UnitFessTestCase {

    private static final String ID_FIELD = "_id";

    /**
     * Test handling of searcher that throws RuntimeException.
     */
    @Test
    public void test_searcherThrowsRuntimeException() throws Exception {
        try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));

            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;
          });

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    exec = newCachedThreadPool();

    task.addListener(listenerLatch::countDown, directExecutor());
  }

  @Override
  protected void tearDown() throws Exception {
    if (exec != null) {