@Configuration
public class GatewayConfig {
  @Bean
  public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
    return builder.routes()
      .route("user_dashboard_route", r -> r.path("/api/dashboard/{userId}")
        .filters(f -> f.filter((exchange, chain) -> {
          // Lấy userId từ đường dẫn
          String userId = exchange.getRequest().getPath().segment(2);

          // Giả lập gọi dịch vụ user và order (thực tế dùng WebClient gọi HTTP)
          Mono<String> userDetails = callUserService(userId);
          Mono<String> userOrders = callOrderService(userId);

          // Kết hợp kết quả song song
          return Mono.zip(userDetails, userOrders)
            .flatMap(tuple -> {
              String aggregatedResponse = "User: " + tuple.getT1() + ", Orders: " + tuple.getT2();
              
              return Mono.just(exchange.getResponse())
                .flatMap(response -> {
                  response.getHeaders().add("Content-Type", "application/json");
                  return response.writeWith(Mono.just(response.bufferFactory().wrap(aggregatedResponse.getBytes())));
                });
            });
        }))
        .uri("no://op")
      )
      .build();
  }

  private Mono<String> callUserService(String userId) {
    return Mono.just("Details for user " + userId);
  }

  private Mono<String> callOrderService(String userId) {
    return Mono.just("Orders for user " + userId);
  }
}