#122

Committed 30 Sep 2025 08:22PM UTC coverage: 90.896% (-0.02%) from 90.912%

Build # #122

Build Type

push

Committed by

Commit Message

[maven-release-plugin] prepare for next development iteration

Run Details

5841 of 6426 relevant lines covered (90.9%)

0.91 hits per line

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

80.0

/logevents-servlets-demo/src/main/java/org/logeventsdemo/servlets/DemoServer.java

package org.logeventsdemo.servlets;

import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.util.resource.Resource;
import org.eclipse.jetty.webapp.WebAppContext;
import org.logevents.optional.servlets.LogEventsServlet;
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
import org.slf4j.Marker;
import org.slf4j.MarkerFactory;
import org.slf4j.event.Level;
import org.slf4j.spi.LocationAwareLogger;

import javax.servlet.DispatcherType;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import java.io.File;
import java.io.IOException;
import java.net.URI;
import java.net.URL;
import java.util.EnumSet;
import java.util.Random;

public class DemoServer {

    private static final Marker OPS = MarkerFactory.getMarker("OPS");
    private static final Marker LIFECYCLE = MarkerFactory.getMarker("LIFECYCLE");
    private static final Marker SECRET = MarkerFactory.getMarker("SECRET");
    private static final Marker HTTP = MarkerFactory.getMarker("HTTP");
    static {
        OPS.add(LIFECYCLE); OPS.add(HTTP);
    }

    private static final LocationAwareLogger logger = (LocationAwareLogger) LoggerFactory.getLogger(DemoServer.class);
    private final Server server;

    public DemoServer(int httpPort) {
        server = new Server(httpPort);
        server.setHandler(demoContext());
        server.setRequestLog(new Slf4RequestLog());
    }

    public static void main(String[] args) throws Exception {
        DemoServer server = new DemoServer(Integer.parseInt(System.getProperty("httpPort", "4000")));
        server.start();
        logger.warn(LIFECYCLE, "Started server {}", server.getURI());
    }

    public URI getURI() {
        return server.getURI();
    }

    void start() throws Exception {
        new Thread(DemoServer::makeNoise).start();
        server.start();
    }

    private static WebAppContext demoContext() {
        WebAppContext context = new WebAppContext();
        context.setContextPath("/");

        URL webAppResource = DemoServer.class.getResource("/webapp-logevents");
        File webAppSource = new File(webAppResource.getPath().replaceAll("/target/classes/", "/src/main/resources/"));
        if (webAppSource.isDirectory()) {
            context.setBaseResource(Resource.newResource(webAppSource));
            context.getInitParams().put("org.eclipse.jetty.servlet.Default.useFileMappedBuffer", "false");
        } else {
            context.setBaseResource(Resource.newResource(webAppResource));
        }

        context.addEventListener(new ApplicationContext());
        return context;
    }

    private static final Random random = new Random();

    @SafeVarargs
    private static <T> T pickOne(T... options) {
        return options[random.nextInt(options.length)];
    }

    private static void makeNoise() {
        try {
            while (true) {
                try {
                    if (random.nextInt(100) < 80) {
                        MDC.put("clientIp", pickOne("127.0.0.1", "10.10.0." + random.nextInt(255)));
                    }
                    if (random.nextInt(100) < 50) {
                        MDC.put("request", pickOne("/api/operation", "/api/resources", "/orders", "/customer/orders"));
                    }
                    if (random.nextInt(100) < 30) {
                        MDC.put("user", pickOne("alice", "bob", "charlie", "diana") + "@example." + pickOne("com", "org", "net"));
                    }
                    logger.log(
                            pickOne(OPS, SECRET, HTTP, null),
                            null,
                            pickOne(Level.ERROR, Level.WARN, Level.INFO).toInt(),
                            pickOne("Test message {}", "Other {} test message", "Even more", "Message with <a href='#'>Embedded HTML</a>"),
                            new Object[] { random.nextBoolean() ? random.nextInt(100) : "<a href='#'>A link</a>"},
                            random.nextInt(100) < 20 ? new IOException("Some error") : null);
                } finally {
                    MDC.clear();
                }
                Thread.sleep(random.nextInt(10000));
            }
        } catch (InterruptedException ignore) {

        }
    }

    private static class ApplicationContext implements ServletContextListener {
        @Override
        public void contextInitialized(ServletContextEvent sce) {
            sce.getServletContext().addFilter("logFilter", new LogEventServletFilter())
                    .addMappingForUrlPatterns(EnumSet.of(DispatcherType.REQUEST), false, "/*");
            sce.getServletContext().addServlet("test", new TestServlet()).addMapping("/test/*");
            sce.getServletContext().addServlet("logs", new LogEventsServlet()).addMapping("/logs/*");

            sce.getServletContext().addServlet("swagger", new WebJarServlet("swagger-ui"))
                    .addMapping("/swagger/*");
        }

        @Override
        public void contextDestroyed(ServletContextEvent sce) {

        }
    }
}

1	package org.logeventsdemo.servlets;
2
3	import org.eclipse.jetty.server.Server;
4	import org.eclipse.jetty.util.resource.Resource;
5	import org.eclipse.jetty.webapp.WebAppContext;
6	import org.logevents.optional.servlets.LogEventsServlet;
7	import org.slf4j.LoggerFactory;
8	import org.slf4j.MDC;
9	import org.slf4j.Marker;
10	import org.slf4j.MarkerFactory;
11	import org.slf4j.event.Level;
12	import org.slf4j.spi.LocationAwareLogger;
13
14	import javax.servlet.DispatcherType;
15	import javax.servlet.ServletContextEvent;
16	import javax.servlet.ServletContextListener;
17	import java.io.File;
18	import java.io.IOException;
19	import java.net.URI;
20	import java.net.URL;
21	import java.util.EnumSet;
22	import java.util.Random;
23
24	public class DemoServer {
25
26	private static final Marker OPS = MarkerFactory.getMarker("OPS");	1✔
27	private static final Marker LIFECYCLE = MarkerFactory.getMarker("LIFECYCLE");	1✔
28	private static final Marker SECRET = MarkerFactory.getMarker("SECRET");	1✔
29	private static final Marker HTTP = MarkerFactory.getMarker("HTTP");	1✔
30	static {
31	OPS.add(LIFECYCLE); OPS.add(HTTP);	1✔
32	}
33
34	private static final LocationAwareLogger logger = (LocationAwareLogger) LoggerFactory.getLogger(DemoServer.class);	1✔
35	private final Server server;
36
37	public DemoServer(int httpPort) {	1✔
38	server = new Server(httpPort);	1✔
39	server.setHandler(demoContext());	1✔
40	server.setRequestLog(new Slf4RequestLog());	1✔
41	}	1✔
42
43	public static void main(String[] args) throws Exception {
44	DemoServer server = new DemoServer(Integer.parseInt(System.getProperty("httpPort", "4000")));	×
45	server.start();	×
46	logger.warn(LIFECYCLE, "Started server {}", server.getURI());	×
47	}	×
48
49	public URI getURI() {
50	return server.getURI();	1✔
51	}
52
53	void start() throws Exception {
54	new Thread(DemoServer::makeNoise).start();	1✔
55	server.start();	1✔
56	}	1✔
57
58	private static WebAppContext demoContext() {
59	WebAppContext context = new WebAppContext();	1✔
60	context.setContextPath("/");	1✔
61
62	URL webAppResource = DemoServer.class.getResource("/webapp-logevents");	1✔
63	File webAppSource = new File(webAppResource.getPath().replaceAll("/target/classes/", "/src/main/resources/"));	1✔
64	if (webAppSource.isDirectory()) {	1✔
65	context.setBaseResource(Resource.newResource(webAppSource));	1✔
66	context.getInitParams().put("org.eclipse.jetty.servlet.Default.useFileMappedBuffer", "false");	1✔
67	} else {
68	context.setBaseResource(Resource.newResource(webAppResource));	×
69	}
70
71	context.addEventListener(new ApplicationContext());	1✔
72	return context;	1✔
73	}
74
75	private static final Random random = new Random();	1✔
76
77	@SafeVarargs
78	private static <T> T pickOne(T... options) {
79	return options[random.nextInt(options.length)];	1✔
80	}
81
82	private static void makeNoise() {
83	try {
84	while (true) {
85	try {
86	if (random.nextInt(100) < 80) {	1✔
87	MDC.put("clientIp", pickOne("127.0.0.1", "10.10.0." + random.nextInt(255)));	1✔
88	}
89	if (random.nextInt(100) < 50) {	1✔
90	MDC.put("request", pickOne("/api/operation", "/api/resources", "/orders", "/customer/orders"));	×
91	}
92	if (random.nextInt(100) < 30) {	1✔
93	MDC.put("user", pickOne("alice", "bob", "charlie", "diana") + "@example." + pickOne("com", "org", "net"));	1✔
94	}
95	logger.log(	1✔
96	pickOne(OPS, SECRET, HTTP, null),	1✔
97	null,
98	pickOne(Level.ERROR, Level.WARN, Level.INFO).toInt(),	1✔
99	pickOne("Test message {}", "Other {} test message", "Even more", "Message with <a href='#'>Embedded HTML</a>"),	1✔
100	new Object[] { random.nextBoolean() ? random.nextInt(100) : "<a href='#'>A link</a>"},	1✔
101	random.nextInt(100) < 20 ? new IOException("Some error") : null);	1✔
102	} finally {
103	MDC.clear();	×
104	}
105	Thread.sleep(random.nextInt(10000));	×
106	}
107	} catch (InterruptedException ignore) {	×
108
109	}
110	}	×
111
112	private static class ApplicationContext implements ServletContextListener {
113	@Override
114	public void contextInitialized(ServletContextEvent sce) {
115	sce.getServletContext().addFilter("logFilter", new LogEventServletFilter())	1✔
116	.addMappingForUrlPatterns(EnumSet.of(DispatcherType.REQUEST), false, "/*");	1✔
117	sce.getServletContext().addServlet("test", new TestServlet()).addMapping("/test/*");	1✔
118	sce.getServletContext().addServlet("logs", new LogEventsServlet()).addMapping("/logs/*");	1✔
119
120	sce.getServletContext().addServlet("swagger", new WebJarServlet("swagger-ui"))	1✔
121	.addMapping("/swagger/*");	1✔
122	}	1✔
123
124	@Override
125	public void contextDestroyed(ServletContextEvent sce) {
126
127	}	×
128	}
129	}

jhannes / logevents / #122

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