Add metrics

Author: CTMBNara

src/main/java/org/prebid/server/auction/externalortb/ProfilesProcessor.java

@@ -86,7 +86,7 @@ public Future<BidRequest> process(AuctionContext auctionContext, BidRequest bidR
                 .orElse(null);
 
         return fetchProfiles(accountId, profilesIds, timeoutMillis(bidRequest))
-                .map(profiles -> emitMetrics(accountId, profiles, auctionContext))
+                .compose(profiles -> emitMetrics(accountId, profiles, auctionContext))
                 .map(profiles -> mergeResults(
                         applyRequestProfiles(profilesIds.request(), profiles.getStoredIdToRequest(), bidRequest),
                         applyImpsProfiles(profilesIds.imps(), profiles.getStoredIdToImp(), bidRequest.getImp())))
@@ -109,7 +109,7 @@ private AllProfilesIds profilesIds(BidRequest bidRequest, AuctionContext auction
 
         if (auctionContext.getDebugContext().isDebugEnabled() && !profilesIds.equals(initialProfilesIds)) {
             auctionContext.getDebugWarnings().add("Profiles exceeded the limit.");
-            metrics.updateProfileMetric(MetricName.err); // TODO
+            metrics.updateProfileMetric(MetricName.limit_exceeded);
         }
 
         return profilesIds;
@@ -171,26 +171,28 @@ private Future<StoredDataResult<Profile>> fetchProfiles(String accountId,
                 .collect(Collectors.toSet());
         final Timeout timeout = timeoutFactory.create(timeoutMillis);
 
-        return applicationSettings.getProfiles(accountId, requestProfilesIds, impProfilesIds, timeout)
-                .compose(profiles -> profiles.getErrors().isEmpty() || !failOnUnknown
-                        ? Future.succeededFuture(profiles)
-                        : Future.failedFuture(new InvalidProfileException(profiles.getErrors())));
+        return applicationSettings.getProfiles(accountId, requestProfilesIds, impProfilesIds, timeout);
     }
 
-    private StoredDataResult<Profile> emitMetrics(String accountId,
-                                                  StoredDataResult<Profile> fetchResult,
-                                                  AuctionContext auctionContext) {
+    private Future<StoredDataResult<Profile>> emitMetrics(String accountId,
+                                                          StoredDataResult<Profile> fetchResult,
+                                                          AuctionContext auctionContext) {
 
-        if (!fetchResult.getErrors().isEmpty()) {
+        final List<String> errors = fetchResult.getErrors();
+        if (!errors.isEmpty()) {
             metrics.updateProfileMetric(MetricName.missing);
 
             if (auctionContext.getDebugContext().isDebugEnabled()) {
                 metrics.updateAccountProfileMetric(accountId, MetricName.missing);
-                auctionContext.getDebugWarnings().addAll(fetchResult.getErrors());
+                auctionContext.getDebugWarnings().addAll(errors);
+            }
+
+            if (failOnUnknown) {
+                return Future.failedFuture(new InvalidProfileException(errors));
             }
         }
 
-        return fetchResult;
+        return Future.succeededFuture(fetchResult);
     }
 
     private BidRequest applyRequestProfiles(List<String> profilesIds,

src/main/java/org/prebid/server/metric/MetricName.java

@@ -156,7 +156,10 @@ public enum MetricName {
 
     // activity
     disallowed_count("disallowed.count"),
-    processed_rules_count("processedrules.count");
+    processed_rules_count("processedrules.count"),
+
+    // profiles
+    limit_exceeded;
 
     private final String name;
 

src/main/java/org/prebid/server/metric/ProfileMetrics.java

@@ -1,25 +1,28 @@
 package org.prebid.server.metric;
 
 import com.codahale.metrics.MetricRegistry;
-import org.apache.commons.lang3.StringUtils;
 
 import java.util.Objects;
 import java.util.function.Function;
 
 class ProfileMetrics extends UpdatableMetrics {
 
     ProfileMetrics(MetricRegistry metricRegistry, CounterType counterType) {
-        this(metricRegistry, counterType, StringUtils.EMPTY);
+        super(Objects.requireNonNull(metricRegistry), Objects.requireNonNull(counterType), nameCreator());
     }
 
     ProfileMetrics(MetricRegistry metricRegistry, CounterType counterType, String prefix) {
         super(
                 Objects.requireNonNull(metricRegistry),
                 Objects.requireNonNull(counterType),
-                nameCreator(Objects.requireNonNull(prefix) + "."));
+                nameCreator(Objects.requireNonNull(prefix)));
+    }
+
+    private static Function<MetricName, String> nameCreator() {
+        return "profiles.%s"::formatted;
     }
 
     private static Function<MetricName, String> nameCreator(String prefix) {
-        return metricName -> "%sprofile.%s".formatted(prefix, metricName);
+        return metricName -> "%s.profiles.%s".formatted(prefix, metricName);
     }
 }