package cc.mrbird.febs.gateway.enhance.service;

import cc.mrbird.febs.gateway.enhance.entity.BlackList;
import cc.mrbird.febs.gateway.enhance.entity.RateLimitRule;
import reactor.core.publisher.Flux;

import java.util.Set;

/**
 * @author MrBird
 */
public interface RouteEnhanceCacheService {

    /**
     * 缓存所有黑名单规则
     *
     * @param blackList 黑名单列表
     */
    void saveAllBlackList(Flux<BlackList> blackList);

    /**
     * 删除黑名单规则缓存
     *
     * @param blackList 黑名单
     */
    void removeBlackList(BlackList blackList);

    /**
     * 缓存所有限流规则
     *
     * @param rateLimitRules 限流规则列表
     */
    void saveAllRateLimitRules(Flux<RateLimitRule> rateLimitRules);

    /**
     * 缓存黑名单规则
     *
     * @param blackList 黑名单规则
     */
    void saveBlackList(BlackList blackList);

    /**
     * 从缓存中获取黑名单规则
     *
     * @param ip ip
     * @return 黑名单
     */
    Set<Object> getBlackList(String ip);

    /**
     * 从缓存中获取黑名单规则
     *
     * @return 黑名单
     */
    Set<Object> getBlackList();

    /**
     * 缓存限流规则
     *
     * @param rateLimitRule 限流规则
     */
    void saveRateLimitRule(RateLimitRule rateLimitRule);

    /**
     * 从缓存中获取限流规则
     *
     * @param uri    uri
     * @param method method
     * @return 限流规则
     */
    Object getRateLimitRule(String uri, String method);

    /**
     * 获取当前请求次数
     *
     * @param uri uri
     * @param ip  ip
     * @return 次数
     */
    int getCurrentRequestCount(String uri, String ip);

    /**
     * 从缓存中删除限流规则
     *
     * @param rateLimitRule 限流规则
     */
    void removeRateLimitRule(RateLimitRule rateLimitRule);

    /**
     * 设置请求次数
     *
     * @param uri  uri
     * @param ip   ip
     * @param time time
     */
    void setCurrentRequestCount(String uri, String ip, Long time);

    /**
     * 递增请求次数
     *
     * @param uri uri
     * @param ip  ip
     */
    void incrCurrentRequestCount(String uri, String ip);
}