* governing permissions and limitations under the License.
 */
package org.codelibs.fess.suggest.index.writer;

import org.codelibs.fess.suggest.entity.SuggestItem;
import org.codelibs.fess.suggest.exception.SuggestIndexException;
import org.codelibs.fess.suggest.settings.SuggestSettings;
import org.codelibs.fess.suggest.util.SuggestUtil;
import org.opensearch.action.bulk.BulkItemResponse;

            assertFalse(result.isPresent());
        } catch (Exception e) {
            // Expected in test environment
            assertTrue(true);
        }
    }

    public void test_getUserInfo_nullUserCode() {
        try {
            var result = searchLogHelper.getUserInfo(null);
            assertFalse(result.isPresent());
        } catch (Exception e) {
            // Expected in test environment

ECL0014=argument[{0}] which is null the index of array is negative integer.
ECL0015=argument[{0}] which is null the index of array exceed the size of array[{1}].
ECL0016=key[{0}] is not included in this BeanMap : {1}.
ECL0017=Exception occurred, because {0}
ECL0041={0}''s creation failure, because {1}
ECL0040=IOException occurred, because {0}
ECL0042=An illegal access was generated by {0}, because {1}

  };

  private final OkHttpClient client;

  public RewriteResponseCacheControl(File cacheDirectory) throws Exception {
    Cache cache = new Cache(cacheDirectory, 1024 * 1024);
    cache.evictAll();

    client = new OkHttpClient.Builder()
        .cache(cache)
        .build();
  }

  public void run() throws Exception {
    for (int i = 0; i < 5; i++) {
      System.out.println("    Request: " + i);

        assertTrue(notification.getOldIPAddresses().isEmpty());
        assertEquals(WitnessNotification.WITNESS_RESOURCE_STATE_UNKNOWN, notification.getFlags());
    }

    @Test
    void testAddIPAddresses() throws Exception {
        InetAddress ipv4 = InetAddress.getByName("192.168.1.100");
        InetAddress ipv6 = InetAddress.getByName("2001:db8::1");

        notification.addNewIPAddress(ipv4);
        notification.addNewIPAddress(ipv6);

    @MethodSource("intErrorCodes")
    @DisplayName("int ctor: sets message and NT status as expected")
    void intConstructor_populatesMessageAndStatus(int errCode, int expectedStatus) {
        // Arrange & Act: create exception with error code
        SmbAuthException ex = new SmbAuthException(errCode);

        // Assert: type, message derived from code, status mapping, and no cause
        assertNotNull(ex);

import org.codelibs.fess.app.web.api.ApiResult.ApiUpdateResponse;
import org.codelibs.fess.app.web.api.ApiResult.Status;
import org.codelibs.fess.app.web.api.admin.FessApiAdminAction;
import org.codelibs.fess.exception.FessSystemException;
import org.codelibs.fess.helper.PermissionHelper;
import org.codelibs.fess.helper.SuggestHelper;
import org.codelibs.fess.opensearch.config.exentity.ElevateWord;
import org.codelibs.fess.util.ComponentUtil;

            numCalls.incrementAndGet();
            throw new RuntimeException("FAKE EXCEPTION!");
          }
        };

    e.execute(runMe);
    e.execute(runMe);
    fakePool.runAll();

    assertEquals(2, numCalls.get());
  }

  public void testInterrupt_beforeRunRestoresInterruption() throws Exception {
    // Run a task on the composed Executor that interrupts its thread (i.e. this thread).

        when(servletConfig.getInitParameter(anyString())).thenAnswer(invocation -> validParams.get(invocation.getArgument(0)));

        // This should not throw an exception
        assertDoesNotThrow(() -> ntlmServlet.init(servletConfig));
    }

    /**
     * Test the service method when no Authorization header is present and no session exists.

            this.rpcHandle.bind();
            this.connected = true;

            log.debug("Connected to witness service at {}", serverAddress.getHostAddress());
        } catch (Exception e) {
            throw new IOException("Failed to connect to witness service", e);
        }
    }

    /**
     * Builds the RPC URL for the witness service.
     *
     * @param serverAddress the server address