* we change the rate.
   */
  public void testWeNeverGetABurstMoreThanOneSec() {
    RateLimiter limiter = RateLimiter.create(1.0, stopwatch);
    int[] rates = {1000, 1, 10, 1000000, 10, 1};
    for (int rate : rates) {
      int oneSecWorthOfWork = rate;
      stopwatch.sleepMillis(rate * 1000);
      limiter.setRate(rate);

   * we change the rate.
   */
  public void testWeNeverGetABurstMoreThanOneSec() {
    RateLimiter limiter = RateLimiter.create(1.0, stopwatch);
    int[] rates = {1000, 1, 10, 1000000, 10, 1};
    for (int rate : rates) {
      int oneSecWorthOfWork = rate;
      stopwatch.sleepMillis(rate * 1000);
      limiter.setRate(rate);

    }

    @Test
    public void test_constructorWithMessageAndErrorCode() {
        final LlmException exception = new LlmException("Rate limit exceeded", LlmException.ERROR_RATE_LIMIT);
        assertEquals("Rate limit exceeded", exception.getMessage());
        assertEquals(LlmException.ERROR_RATE_LIMIT, exception.getErrorCode());
        assertNull(exception.getCause());
    }

    @Test

        now = datetime.now(tz=timezone.utc)

        # Handle primary rate limits
        primary_limit_wait_time = 0.0
        if self.remaining_points <= self.last_query_cost:
            primary_limit_wait_time = (self.reset_at - now).total_seconds() + 2
            logging.warning(
                f"Approaching GitHub API rate limit, remaining points: {self.remaining_points}, "

 *
 * @author FessProject
 */
public class LlmException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /** Error code for rate limit (HTTP 429). */
    public static final String ERROR_RATE_LIMIT = "rate_limit";

    /** Error code for authentication failure (HTTP 401/403). */
    public static final String ERROR_AUTH = "auth_error";

#                                                                           Rate Limiting
#                                                                           ==============
# Whether rate limiting is enabled.
rate.limit.enabled=false
# Maximum number of requests allowed per window.
rate.limit.requests.per.window=100
# Window size in milliseconds.
rate.limit.window.ms=60000
# Duration in milliseconds to block IP when limit exceeded.

- Role-based query filtering via `RoleQueryHelper`
- Authentication: Local (UserService), LDAP, OIDC, SAML, SPNEGO, Entra ID
- Security features: AES encryption, SHA256 digest, LDAP injection prevention, password policy, rate limiting

## Naming Conventions

| Element | Convention | Example |
|---------|------------|---------|
| Classes | PascalCase | `UserService`, `FessBaseAction` |

     */
    public static AccessTokenHelper getAccessTokenHelper() {
        return getComponent(ACCESS_TOKEN_HELPER);
    }

    /**
     * Gets the rate limit helper component.
     * @return The rate limit helper.
     */
    public static RateLimitHelper getRateLimitHelper() {
        return getComponent(RATE_LIMIT_HELPER);
    }

    /**

    /** The key of the configuration. e.g. 60 */
    String RATE_LIMIT_RETRY_AFTER_SECONDS = "rate.limit.retry.after.seconds";

    /** The key of the configuration. e.g. 127.0.0.1,::1 */
    String RATE_LIMIT_WHITELIST_IPS = "rate.limit.whitelist.ips";

    /** The key of the configuration. e.g.  */
    String RATE_LIMIT_BLOCKED_IPS = "rate.limit.blocked.ips";

    double actualReportedFpp = bf.expectedFpp();
    assertThat(actualReportedFpp).isWithin(0.00033).of(expectedReportedFpp);
  }

  /** Sanity checking with many combinations of false positive rates and expected insertions */
  public void testBasic() {
    for (double fpr = 0.0000001; fpr < 0.1; fpr *= 10) {
      for (int expectedInsertions = 1; expectedInsertions <= 10000; expectedInsertions *= 10) {