juplo.de Git - facebook-errors/blob - src/main/java/de/juplo/facebook/errors/GraphApiExchangeFilterFunction.java

   1 package de.juplo.facebook.errors;
   2
   3
   4 import org.slf4j.Logger;
   5 import org.slf4j.LoggerFactory;
   6 import org.springframework.http.HttpStatus;
   7 import org.springframework.web.reactive.function.client.ClientRequest;
   8 import org.springframework.web.reactive.function.client.ClientResponse;
   9 import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
  10 import org.springframework.web.reactive.function.client.ExchangeFunction;
  11 import reactor.core.publisher.Mono;
  12
  13
  14 /**
  15  * An {@link ExchangeFilterFunction}
  16  * @author Kai Moritz
  17  */
  18 public class GraphApiExchangeFilterFunction implements ExchangeFilterFunction
  19 {
  20   private static final Logger LOG =
  21       LoggerFactory.getLogger(GraphApiExchangeFilterFunction.class);
  22
  23   public static GraphApiExchangeFilterFunction INSTANCE =
  24       new GraphApiExchangeFilterFunction();
  25
  26
  27   @Override
  28   public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next)
  29   {
  30     return
  31         next
  32             .exchange(request)
  33             .doOnError(e -> LOG.debug("ERROR: {}", e))
  34             .flatMap(response ->
  35             {
  36               return
  37                   HttpStatus.Series.CLIENT_ERROR.equals(response.statusCode().series())
  38                       ? Mono.error(GraphApiException.create(response))
  39                       : Mono.just(response);
  40             });
  41   }
  42 }