assertEquals("192.168.1.100", rateLimitHelper.getClientIp(request));
    }

    @Test
    public void test_blockIp() {
        rateLimitHelper.blockIp("192.168.1.100", 1000L);
        assertEquals(1, rateLimitHelper.getBlockedIpCount());

        rateLimitHelper.unblockIp("192.168.1.100");
        assertEquals(0, rateLimitHelper.getBlockedIpCount());
    }

    @Test

{"name":"Thumbnail Purger","target":"all","cronExpression":"0 0 * * *","scriptType":"groovy","scriptData":"return container.getComponent(\"purgeThumbnailJob\").expiry(30 * 24 * 60 * 60 * 1000L).execute();","jobLogging":true,"crawler":false,"available":true,"sortOrder":7,"createdBy":"system","createdTime":0,"updatedBy":"system","updatedTime":0}
{"index":{"_index":"fess_config.scheduled_job","_id":"reload_config"}}

        PurgeThumbnailJob job = new PurgeThumbnailJob();
        assertNotNull(job);
        assertEquals(30L * 24 * 60 * 60 * 1000L, job.getExpiry());
    }

    // Test getExpiry with default value
    @Test
    public void test_getExpiry_default() {
        assertEquals(30L * 24 * 60 * 60 * 1000L, purgeThumbnailJob.getExpiry());
    }

    // Test expiry setter with valid value
    @Test

        // Default buffer size is 1000; offer more than that
        for (int i = 0; i < 1100; i++) {
            helper.offer(new LogNotificationEvent(i, "ERROR", "org.test", "msg" + i, null));
        }
        List<LogNotificationEvent> events = helper.drainAll();
        // Should be capped at buffer size (1000)
        assertTrue(events.size() <= 1000);
        assertTrue(events.size() > 0);
    }

     */
    @Test
    public void test_delayMillisAfterProcessing() {
        FessIntervalController controller = new FessIntervalController();

        controller.setDelayMillisAfterProcessing(1000L);
        assertEquals(1000L, controller.getDelayMillisAfterProcessing());

        controller.setDelayMillisAfterProcessing(5000L);
        assertEquals(5000L, controller.getDelayMillisAfterProcessing());

    @Resource
    protected FessConfig fessConfig;

    /**
     * Time interval in milliseconds after which jobs are considered expired.
     * Default is 2 hours (2 * 60 * 60 * 1000L).
     */
    protected long expiredJobInterval = 2 * 60 * 60 * 1000L; // 2hours

    /**
     * Retrieves a paginated list of job logs based on the provided pager configuration.
     *

    /**
     * Default constructor.
     */
    public AbstractConfigHelper() {
        // Default constructor
    }

    /**
     * The interval for reloading.
     */
    protected long reloadInterval = 1000L;

    /**
     * Update the configuration.
     */
    public void update() {
        CommonPoolUtil.execute(this::load);
    }

    /**
     * Wait for the next reloading.
     */

     */
    public PurgeThumbnailJob() {
        // Default constructor
    }

    /** Expiration time for thumbnails in milliseconds (default: 30 days) */
    private long expiry = 30 * 24 * 60 * 60 * 1000L;

    /**
     * Executes the thumbnail purging job.
     * Removes thumbnail files that have exceeded the configured expiration time.
     *

        super.setUp(testInfo);
        configHelper = new TestConfigHelper();
    }

    @Test
    public void test_setReloadInterval() {
        assertEquals(1000L, configHelper.reloadInterval);

        configHelper.setReloadInterval(5000L);
        assertEquals(5000L, configHelper.reloadInterval);

        configHelper.setReloadInterval(0L);

     * This is a required field with a maximum length of 1000 characters.
     */
    @Required
    @Size(max = 1000)
    public String name;

    /**
     * The actual access token string.
     * This is the token value that will be used for authentication.
     * Maximum length is 10000 characters.
     */
    @Size(max = 10000)
    public String token;

    /**