forked from ashish-sharma09/micronaut-http
/
AuthenticateFilter.java
31 lines (24 loc) · 943 Bytes
/
AuthenticateFilter.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package micronaut.http;
import io.micronaut.http.HttpResponse;
import io.micronaut.http.MutableHttpRequest;
import io.micronaut.http.annotation.Filter;
import io.micronaut.http.filter.ClientFilterChain;
import io.micronaut.http.filter.HttpClientFilter;
import io.reactivex.annotations.NonNull;
import io.reactivex.functions.Function;
import org.reactivestreams.Publisher;
import javax.inject.Inject;
@Filter("/**/details/*")
public class AuthenticateFilter implements HttpClientFilter {
private final TokenIssuer tokenIssuer;
@Inject
public AuthenticateFilter(TokenIssuer tokenIssuer) {
this.tokenIssuer = tokenIssuer;
}
@Override
public Publisher<? extends HttpResponse<?>> doFilter(MutableHttpRequest<?> request, ClientFilterChain chain) {
return tokenIssuer.retrieveToken().flatMapPublisher(token ->
chain.proceed(request.bearerAuth(token.getAccessToken()))
);
}
}