/**
 * 網(wǎng)關(guān)過(guò)濾鏈表接口
 * 用于過(guò)濾器的鏈?zhǔn)秸{(diào)用
 * Contract to allow a {@link WebFilter} to delegate to the next in the chain.
 *
 * @author Rossen Stoyanchev
 * @since 5.0
 */
public interface GatewayFilterChain {

  /**
   * 鏈表啟動(dòng)調(diào)用入口方法
   * Delegate to the next {@code WebFilter} in the chain.
   * @param exchange the current server exchange
   * @return {@code Mono<Void>} to indicate when request handling is complete
   */
  Mono<Void> filter(ServerWebExchange exchange);

}

  /**
   * 網(wǎng)關(guān)過(guò)濾的鏈表，用于過(guò)濾器的鏈?zhǔn)秸{(diào)用
   * 過(guò)濾器鏈表接口的默認(rèn)實(shí)現(xiàn)，
   * 包含2個(gè)構(gòu)建函數(shù)：
   * 1.集合參數(shù)構(gòu)建用于初始化吧構(gòu)建鏈表
   * 2. index，parent參數(shù)用于構(gòu)建當(dāng)前執(zhí)行過(guò)濾對(duì)應(yīng)的下次執(zhí)行的鏈表 
   */
  private static class DefaultGatewayFilterChain implements GatewayFilterChain {

    /**
     * 當(dāng)前過(guò)濾執(zhí)行過(guò)濾器在集合中索引
     */
    private final int index;
    /**
     * 過(guò)濾器集合
     */
    private final List<GatewayFilter> filters;

    public DefaultGatewayFilterChain(List<GatewayFilter> filters) {
      this.filters = filters;
      this.index = 0;
    }

    /**
     * 構(gòu)建
     * @param parent 上一個(gè)執(zhí)行過(guò)濾器對(duì)應(yīng)的FilterChain
     * @param index 當(dāng)前要執(zhí)行過(guò)濾器的索引
     */
    private DefaultGatewayFilterChain(DefaultGatewayFilterChain parent, int index) {
      this.filters = parent.getFilters();
      this.index = index;
    }

    public List<GatewayFilter> getFilters() {
      return filters;
    }

    /**
     * @param exchange the current server exchange
     * @return
     */
    @Override
    public Mono<Void> filter(ServerWebExchange exchange) {
      return Mono.defer(() -> {
        if (this.index < filters.size()) {
          //獲取當(dāng)前索引的過(guò)濾器
          GatewayFilter filter = filters.get(this.index);
          //構(gòu)建當(dāng)前索引的下一個(gè)過(guò)濾器的FilterChain
          DefaultGatewayFilterChain chain = new DefaultGatewayFilterChain(this, this.index + 1);
          //調(diào)用過(guò)濾器的filter方法執(zhí)行過(guò)濾器
          return filter.filter(exchange, chain);
        } else {
          //當(dāng)前索引大于等于過(guò)濾集合大小，標(biāo)識(shí)所有鏈表都已執(zhí)行完畢，返回空
          return Mono.empty(); // complete
        }
      });
    }
  }

/**
 * 網(wǎng)關(guān)路由過(guò)濾器，
 * Contract for interception-style, chained processing of Web requests that may
 * be used to implement cross-cutting, application-agnostic requirements such
 * as security, timeouts, and others. Specific to a Gateway
 *
 * Copied from WebFilter
 *
 * @author Rossen Stoyanchev
 * @since 5.0
 */
public interface GatewayFilter extends ShortcutConfigurable {

  String NAME_KEY = "name";
  String VALUE_KEY = "value";

  /**
   * 過(guò)濾器執(zhí)行方法
   * Process the Web request and (optionally) delegate to the next
   * {@code WebFilter} through the given {@link GatewayFilterChain}.
   * @param exchange the current server exchange
   * @param chain provides a way to delegate to the next filter
   * @return {@code Mono<Void>} to indicate when request processing is complete
   */
  Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);

}

/**
 * 排序的網(wǎng)關(guān)路由過(guò)濾器，用于包裝真實(shí)的網(wǎng)關(guān)過(guò)濾器，已達(dá)到過(guò)濾器可排序
 * @author Spencer Gibb
 */
public class OrderedGatewayFilter implements GatewayFilter, Ordered {

  //目標(biāo)過(guò)濾器
  private final GatewayFilter delegate;
  //排序字段
  private final int order;

  public OrderedGatewayFilter(GatewayFilter delegate, int order) {
    this.delegate = delegate;
    this.order = order;
  }

  @Override
  public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    return this.delegate.filter(exchange, chain);
  }
}  

  /**
   * 全局過(guò)濾器的包裝類(lèi)，將全局路由包裝成統(tǒng)一的網(wǎng)關(guān)過(guò)濾器
   */
  private static class GatewayFilterAdapter implements GatewayFilter {

    /**
     * 全局過(guò)濾器
     */
    private final GlobalFilter delegate;

    public GatewayFilterAdapter(GlobalFilter delegate) {
      this.delegate = delegate;
    }

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
      return this.delegate.filter(exchange, chain);
    }
  }

    /**
     * 全局過(guò)濾器，用戶(hù)通過(guò)HttpClient轉(zhuǎn)發(fā)請(qǐng)求
     * @param httpClient
     * @param headersFilters
     * @return
     */
    @Bean
    public NettyRoutingFilter routingFilter(HttpClient httpClient,
                        ObjectProvider<List<HttpHeadersFilter>> headersFilters) {
      return new NettyRoutingFilter(httpClient, headersFilters);
    }

    /**
     * 全局的過(guò)濾器，用戶(hù)將HttpClient客戶(hù)端轉(zhuǎn)發(fā)請(qǐng)求的響應(yīng)寫(xiě)入到原始的請(qǐng)求響應(yīng)中
     * @param properties
     * @return
     */
    @Bean
    public NettyWriteResponseFilter nettyWriteResponseFilter(GatewayProperties properties) {
      return new NettyWriteResponseFilter(properties.getStreamingMediaTypes());
    }

  /**
   * 全局過(guò)濾器，用于在通過(guò)負(fù)載均衡客戶(hù)端選擇服務(wù)實(shí)例信息
   * @param client
   * @return
   */
  @Bean
  @ConditionalOnBean(LoadBalancerClient.class)
  public LoadBalancerClientFilter loadBalancerClientFilter(LoadBalancerClient client) {
    return new LoadBalancerClientFilter(client);
  }

  /**
   * 包裝加載全局的過(guò)濾器，將全局過(guò)濾器包裝成GatewayFilter
   * @param filters
   * @return
   */
  private static List<GatewayFilter> loadFilters(List<GlobalFilter> filters) {
    return filters.stream()
        .map(filter -> {
          //將所有的全局過(guò)濾器包裝成網(wǎng)關(guān)過(guò)濾器
          GatewayFilterAdapter gatewayFilter = new GatewayFilterAdapter(filter);
          //判斷全局過(guò)濾器是否實(shí)現(xiàn)了可排序接口
          if (filter instanceof Ordered) {
            int order = ((Ordered) filter).getOrder();
            //包裝成可排序的網(wǎng)關(guān)過(guò)濾器
            return new OrderedGatewayFilter(gatewayFilter, order);
          }
          return gatewayFilter;
        }).collect(Collectors.toList());
  }
  @Override
  public Mono<Void> handle(ServerWebExchange exchange) {
    //獲取請(qǐng)求上下文設(shè)置的路由實(shí)例
    Route route = exchange.getRequiredAttribute(GATEWAY_ROUTE_ATTR);
    //獲取路由定義下的網(wǎng)關(guān)過(guò)濾器集合
    List<GatewayFilter> gatewayFilters = route.getFilters();

    //組合全局的過(guò)濾器與路由配置的過(guò)濾器
    List<GatewayFilter> combined = new ArrayList<>(this.globalFilters);
    //添加路由配置過(guò)濾器到集合尾部
    combined.addAll(gatewayFilters);
    //對(duì)過(guò)濾器進(jìn)行排序
    //TODO: needed or cached?
    AnnotationAwareOrderComparator.sort(combined);

    logger.debug("Sorted gatewayFilterFactories: "+ combined);
    //創(chuàng)建過(guò)濾器鏈表對(duì)其進(jìn)行鏈?zhǔn)秸{(diào)用
    return new DefaultGatewayFilterChain(combined).filter(exchange);
  }