FIWARE / contract-management / #90

Committed 21 Apr 2026 02:35PM UTC coverage: 1.781%. First build

Build # #90

Build Type

push

Committed by

Commit Message

add status code to request errors

Coverage Stats

2 of 5 new or added lines in 2 files covered. (40.0%)

623 of 34976 relevant lines covered (1.78%)

0.02 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/org/fiware/iam/http/AccessLogServerFilter.java

package org.fiware.iam.http;

import io.micronaut.context.annotation.ConfigurationProperties;
import io.micronaut.http.HttpRequest;
import io.micronaut.http.MutableHttpResponse;
import io.micronaut.http.annotation.Filter;
import io.micronaut.http.exceptions.HttpStatusException;
import io.micronaut.http.filter.HttpServerFilter;
import io.micronaut.http.filter.ServerFilterChain;
import jakarta.inject.Singleton;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux;

import java.util.List;

@Slf4j
@Filter("/**")
@RequiredArgsConstructor
public class AccessLogServerFilter implements HttpServerFilter {

    private final AccessLogConfiguration accessLogConfiguration;

    @Override
    public Publisher<MutableHttpResponse<?>> doFilter(HttpRequest<?> request, ServerFilterChain chain) {
        if (accessLogConfiguration.getExcludePaths().stream().anyMatch(request.getUri().getPath()::startsWith)) {
            return chain.proceed(request);
        }

        long start = System.currentTimeMillis();

        return Flux.from(chain.proceed(request))
                .doOnNext(res -> {
                    long duration = System.currentTimeMillis() - start;
                    String remoteIp = request.getRemoteAddress().getAddress().getHostAddress();
                    String protocol = request.getHttpVersion().toString();
                    String method = request.getMethod().name();
                    String uri = request.getUri().toString();
                    int status = res.getStatus().getCode();
                    String forwardedFor = request.getHeaders().get("X-Forwarded-For");

                    if (forwardedFor != null) {
                        log.info("{} [{}] - {} - {} {} {} - {}ms", forwardedFor, remoteIp, protocol, method, uri, status, duration);
                    } else {
                        log.info("{} - {} - {} {} {} - {}ms", remoteIp, protocol, method, uri, status, duration);
                    }
                })
                .doOnError(e -> {
                    long duration = System.currentTimeMillis() - start;
                    String remoteIp = request.getRemoteAddress().getAddress().getHostAddress();
                    String forwardedFor = request.getHeaders().get("X-Forwarded-For");
                    String status = e instanceof HttpStatusException hse ? Integer.toString(hse.getStatus().getCode()) : "ERROR";

                    if (forwardedFor != null) {
                        log.error("{} [{}] - {} - {} {} {} - {}ms", forwardedFor, remoteIp, request.getHttpVersion(), request.getMethod(), request.getUri(), status, duration, e);
                    } else {
                        log.error("{} - {} - {} {} {} - {}ms", remoteIp, request.getHttpVersion(), request.getMethod(), request.getUri(), status, duration, e);
                    }
                });
    }

    @Data
    @Singleton
    @ConfigurationProperties("http.server.log")
    public static class AccessLogConfiguration {
        private List<String> excludePaths = List.of();
    }
}

1	package org.fiware.iam.http;
2
3	import io.micronaut.context.annotation.ConfigurationProperties;
4	import io.micronaut.http.HttpRequest;
5	import io.micronaut.http.MutableHttpResponse;
6	import io.micronaut.http.annotation.Filter;
7	import io.micronaut.http.exceptions.HttpStatusException;
8	import io.micronaut.http.filter.HttpServerFilter;
9	import io.micronaut.http.filter.ServerFilterChain;
10	import jakarta.inject.Singleton;
11	import lombok.Data;
12	import lombok.RequiredArgsConstructor;
13	import lombok.extern.slf4j.Slf4j;
14	import org.reactivestreams.Publisher;
15	import reactor.core.publisher.Flux;
16
17	import java.util.List;
18
19	@Slf4j	×
20	@Filter("/**")
21	@RequiredArgsConstructor
22	public class AccessLogServerFilter implements HttpServerFilter {
23
24	private final AccessLogConfiguration accessLogConfiguration;
25
26	@Override
27	public Publisher<MutableHttpResponse<?>> doFilter(HttpRequest<?> request, ServerFilterChain chain) {
28	if (accessLogConfiguration.getExcludePaths().stream().anyMatch(request.getUri().getPath()::startsWith)) {	×
29	return chain.proceed(request);	×
30	}
31
32	long start = System.currentTimeMillis();	×
33
34	return Flux.from(chain.proceed(request))	×
35	.doOnNext(res -> {	×
36	long duration = System.currentTimeMillis() - start;	×
37	String remoteIp = request.getRemoteAddress().getAddress().getHostAddress();	×
38	String protocol = request.getHttpVersion().toString();	×
39	String method = request.getMethod().name();	×
40	String uri = request.getUri().toString();	×
41	int status = res.getStatus().getCode();	×
42	String forwardedFor = request.getHeaders().get("X-Forwarded-For");	×
43
44	if (forwardedFor != null) {	×
45	log.info("{} [{}] - {} - {} {} {} - {}ms", forwardedFor, remoteIp, protocol, method, uri, status, duration);	×
46	} else {
47	log.info("{} - {} - {} {} {} - {}ms", remoteIp, protocol, method, uri, status, duration);	×
48	}
49	})	×
50	.doOnError(e -> {	×
51	long duration = System.currentTimeMillis() - start;	×
52	String remoteIp = request.getRemoteAddress().getAddress().getHostAddress();	×
53	String forwardedFor = request.getHeaders().get("X-Forwarded-For");	×
NEW 54	String status = e instanceof HttpStatusException hse ? Integer.toString(hse.getStatus().getCode()) : "ERROR";	×
55
56	if (forwardedFor != null) {	×
NEW 57	log.error("{} [{}] - {} - {} {} {} - {}ms", forwardedFor, remoteIp, request.getHttpVersion(), request.getMethod(), request.getUri(), status, duration, e);	×
58	} else {
NEW 59	log.error("{} - {} - {} {} {} - {}ms", remoteIp, request.getHttpVersion(), request.getMethod(), request.getUri(), status, duration, e);	×
60	}
61	});	×
62	}
63
64	@Data
65	@Singleton
66	@ConfigurationProperties("http.server.log")
67	public static class AccessLogConfiguration {
68	private List<String> excludePaths = List.of();
69	}
70	}

FIWARE / contract-management / #90

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous