Sheldan/abstracto
1
0
Fork 0
mirror of https://github.com/Sheldan/abstracto.git synced 2026-03-02 23:17:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

[AB-xxx] adding metrics for http requests

Browse Source
This commit is contained in:
Sheldan
2026-01-08 00:07:16 +01:00
parent 5e908f6837
commit 4dc92fe49b
1 changed files with 29 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/metric/JDAMetrics.java
View File

@@ -5,7 +5,9 @@ import dev.sheldan.abstracto.core.metric.service.MetricService;
import dev.sheldan.abstracto.core.metric.service.MetricTag;
import lombok.extern.slf4j.Slf4j;
import net.dv8tion.jda.api.events.GenericEvent;
import net.dv8tion.jda.api.events.http.HttpRequestEvent;
import net.dv8tion.jda.api.hooks.ListenerAdapter;
import net.dv8tion.jda.api.requests.Route;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -19,8 +21,13 @@ public class JDAMetrics extends ListenerAdapter {
private MetricService metricService;
public static final String JDA_EVENT_METRIC = "jda.event";
public static final String JDA_REQUEST_METRIC = "jda.request";
public static final String EVENT_CLASS = "event.class";
private final HashMap<Class, CounterMetric> coveredEvents = new HashMap<>();
public static final String HTTP_METHOD = "http.method";
public static final String HTTP_URL = "http.url";
public static final String HTTP_KEY = "http.key";
private final HashMap<Class<?>, CounterMetric> coveredEvents = new HashMap<>();
private final HashMap<String, CounterMetric> coveredRoutes = new HashMap<>();
@Override
public void onGenericEvent(GenericEvent event) {
@@ -39,4 +46,25 @@ public class JDAMetrics extends ListenerAdapter {
metricService.incrementCounter(coveredEvents.get(event.getClass()));
}
@Override
public void onHttpRequest(HttpRequestEvent event) {
Route baseRoute = event.getRequest().getRoute().getBaseRoute();
String urlKey = baseRoute.toString();
if(!coveredRoutes.containsKey(urlKey)) {
CounterMetric metric =
CounterMetric
.builder()
.tagList(Arrays.asList(
MetricTag.getTag(HTTP_METHOD, baseRoute.getMethod().name()),
MetricTag.getTag(HTTP_URL, baseRoute.getRoute()),
MetricTag.getTag(HTTP_KEY, baseRoute.toString())))
.name(JDA_REQUEST_METRIC)
.build();
metricService.registerCounter(metric, "Requests towards URL " + urlKey);
coveredRoutes.put(urlKey, metric);
log.info("Registering new metric for URL {}. There are now {} metrics.", urlKey, coveredRoutes.size());
}
metricService.incrementCounter(coveredRoutes.get(urlKey));
}
}