private void cleanupOldRateLimitCounters(long currentWindow) {
        // Clean up counters from previous windows to prevent memory leaks
        rateLimitCounters.entrySet().removeIf(entry -> {
            String key = entry.getKey();
            int lastUnderscore = key.lastIndexOf('_');
            if (lastUnderscore > 0) {
                try {
                    long window = Long.parseLong(key.substring(lastUnderscore + 1));

     *
     * @param days the number of days from now when the item should expire
     * @return the expiration time in milliseconds since epoch
     */
    protected long getExpiredTime(final int days) {
        final long now = ComponentUtil.getSystemHelper().getCurrentTimeAsLong();
        return now + days * Constants.ONE_DAY_IN_MILLIS;
    }

    /**

            false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnCreatedTime = cci("createdTime", "createdTime", null, null, Long.class, "createdTime", null, false,
            false, false, "Long", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnDepth = cci("depth", "depth", null, null, Integer.class, "depth", null, false, false, false,

     */
    protected long witnessHeartbeatTimeout = 120000; // 2 minutes
    /**
     * Timeout in milliseconds for witness registration
     */
    protected long witnessRegistrationTimeout = 300000; // 5 minutes
    /**
     * Delay in milliseconds before attempting witness reconnection
     */
    protected long witnessReconnectDelay = 1000; // 1 second
    /**

            throw new AssertionError("expected BytesArray but saw [" + bytesArray.getClass() + "]");
        }
        streamInput = bytesArray.streamInput();
    }

    @Benchmark
    public long readLong() throws IOException {
        long res = 0L;
        streamInput.reset();
        final int reads = bytesArray.length() / 8;
        for (int i = 0; i < reads; i++) {
            res = res ^ streamInput.readLong();
        }

        }
        this.streamInput = pagedBytes.streamInput();
    }

    @Benchmark
    public long readLong() throws IOException {
        long res = 0L;
        streamInput.reset();
        final int reads = pagedBytes.length() / 8;
        for (int i = 0; i < reads; i++) {
            res = res ^ streamInput.readLong();
        }

    @Size(max = 1000)
    public String updatedBy;

    /**
     * The timestamp when this bad word entry was last updated.
     * Stored as a long value representing milliseconds since epoch.
     * Used for audit trail and concurrency control.
     */
    @ValidateTypeFailure
    public Long updatedTime;

    /**
     * The version number of the bad word entry for optimistic locking.

    private static final long serialVersionUID = 1L;

    private Map<String, Object> fields;

    @Override
    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    @Override
    public Long getVersionNo() {
        return asDocMeta().version();
    }

    private static final long TEST_CREATE_TIME = System.currentTimeMillis() - 86400000L; // 1 day ago
    private static final long TEST_LAST_ACCESS_TIME = System.currentTimeMillis() - 43200000L; // 12 hours ago
    private static final long TEST_LAST_WRITE_TIME = System.currentTimeMillis() - 3600000L; // 1 hour ago
    private static final long TEST_CHANGE_TIME = System.currentTimeMillis(); // now

        final char[] c = new char[size];
        toHexChars(val, c, 0, size);
        return new String(c);
    }

    /**
     * Converts a long value to a hexadecimal string representation with specified padding.
     *
     * @param val the long value to convert to hexadecimal
     * @param size the desired length of the resulting hex string (will be left-padded with zeros)