Core: Add Greenbids Analytics Adapter (#3096)

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/CommonMessage.java

@@ -0,0 +1,38 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Builder;
+import lombok.Value;
+
+import java.util.List;
+
+@Builder(toBuilder = true)
+@Value
+public class CommonMessage {
+
+    private final String version;
+
+    @JsonProperty("auctionId")
+    private final String auctionId;
+
+    private final String referrer;
+
+    private final double sampling;
+
+    @JsonProperty("prebidServer")
+    private final String prebidServer;
+
+    @JsonProperty("greenbidsId")
+    private final String greenbidsId;
+
+    private final String pbuid;
+
+    @JsonProperty("billingId")
+    private final String billingId;
+
+    @JsonProperty("adUnits")
+    private final List<GreenbidsAdUnit> adUnits;
+
+    @JsonProperty("auctionElapsed")
+    private final Long auctionElapsed;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/ExtBanner.java

@@ -0,0 +1,17 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import lombok.Builder;
+import lombok.Value;
+
+import java.util.List;
+
+@Builder(toBuilder = true)
+@Value
+public class ExtBanner {
+
+    List<List<Integer>> sizes;
+
+    Integer pos;
+
+    String name;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsAdUnit.java

@@ -0,0 +1,22 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Builder;
+import lombok.Value;
+
+import java.util.List;
+
+@Builder(toBuilder = true)
+@Value
+public class GreenbidsAdUnit {
+
+    String code;
+
+    @JsonProperty("unifiedCode")
+    GreenbidsUnifiedCode unifiedCode;
+
+    @JsonProperty("mediaTypes")
+    MediaTypes mediaTypes;
+
+    List<GreenbidsBids> bids;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsAnalyticsProperties.java

@@ -0,0 +1,19 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import lombok.Builder;
+import lombok.Value;
+
+@Builder(toBuilder = true)
+@Value
+public class GreenbidsAnalyticsProperties {
+
+    Double exploratorySamplingSplit;
+
+    String analyticsServerVersion;
+
+    String analyticsServerUrl;
+
+    Long configurationRefreshDelayMs;
+
+    Long timeoutMs;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsBids.java

@@ -0,0 +1,37 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.iab.openrtb.response.Bid;
+import lombok.Builder;
+import lombok.Value;
+import org.prebid.server.auction.model.BidRejectionReason;
+import org.prebid.server.proto.openrtb.ext.response.seatnonbid.NonBid;
+
+@Builder(toBuilder = true)
+@Value
+public class GreenbidsBids {
+
+    String bidder;
+
+    @JsonProperty("isTimeout")
+    Boolean isTimeout;
+
+    @JsonProperty("hasBid")
+    Boolean hasBid;
+
+    public static GreenbidsBids ofBid(String seat, Bid bid) {
+        return GreenbidsBids.builder()
+                .bidder(seat)
+                .isTimeout(false)
+                .hasBid(bid != null)
+                .build();
+    }
+
+    public static GreenbidsBids ofNonBid(String seat, NonBid nonBid) {
+        return GreenbidsBids.builder()
+                .bidder(seat)
+                .isTimeout(nonBid.getStatusCode() == BidRejectionReason.TIMED_OUT)
+                .hasBid(false)
+                .build();
+    }
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsPrebidExt.java

@@ -0,0 +1,13 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Value;
+
+@Value(staticConstructor = "of")
+public class GreenbidsPrebidExt {
+
+    String pbuid;
+
+    @JsonProperty("greenbidsSampling")
+    Double greenbidsSampling;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsSource.java

@@ -0,0 +1,18 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+public enum GreenbidsSource {
+
+    GPID_SOURCE("gpidSource"),
+    STORED_REQUEST_ID_SOURCE("storedRequestIdSource"),
+    AD_UNIT_CODE_SOURCE("adUnitCodeSource");
+
+    private final String value;
+
+    GreenbidsSource(String value) {
+        this.value = value;
+    }
+
+    public String getValue() {
+        return value;
+    }
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/GreenbidsUnifiedCode.java

@@ -0,0 +1,11 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import lombok.Value;
+
+@Value(staticConstructor = "of")
+public class GreenbidsUnifiedCode {
+
+    String value;
+
+    String source;
+}

src/main/java/org/prebid/server/analytics/reporter/greenbids/model/MediaTypes.java

@@ -0,0 +1,17 @@
+package org.prebid.server.analytics.reporter.greenbids.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.iab.openrtb.request.Native;
+import com.iab.openrtb.request.Video;
+import lombok.Value;
+
+@Value(staticConstructor = "of")
+public class MediaTypes {
+
+    ExtBanner banner;
+
+    Video video;
+
+    @JsonProperty("native")
+    Native nativeObject;
+}

src/main/java/org/prebid/server/spring/config/AnalyticsConfiguration.java

@@ -6,13 +6,16 @@
 import org.apache.commons.collections4.ListUtils;
 import org.prebid.server.analytics.AnalyticsReporter;
 import org.prebid.server.analytics.reporter.AnalyticsReporterDelegator;
+import org.prebid.server.analytics.reporter.greenbids.GreenbidsAnalyticsReporter;
+import org.prebid.server.analytics.reporter.greenbids.model.GreenbidsAnalyticsProperties;
 import org.prebid.server.analytics.reporter.log.LogAnalyticsReporter;
 import org.prebid.server.analytics.reporter.pubstack.PubstackAnalyticsReporter;
 import org.prebid.server.analytics.reporter.pubstack.model.PubstackAnalyticsProperties;
 import org.prebid.server.auction.privacy.enforcement.TcfEnforcement;
 import org.prebid.server.auction.privacy.enforcement.mask.UserFpdActivityMask;
 import org.prebid.server.json.JacksonMapper;
 import org.prebid.server.metric.Metrics;
+import org.prebid.server.version.PrebidVersionProvider;
 import org.prebid.server.vertx.httpclient.HttpClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -23,6 +26,7 @@
 import org.springframework.validation.annotation.Validated;
 
 import jakarta.validation.constraints.NotNull;
+import java.time.Clock;
 import java.util.List;
 
 @Configuration
@@ -52,6 +56,54 @@ LogAnalyticsReporter logAnalyticsReporter(JacksonMapper mapper) {
         return new LogAnalyticsReporter(mapper);
     }
 
+    @Configuration
+    @ConditionalOnProperty(prefix = "analytics.greenbids", name = "enabled", havingValue = "true")
+    public static class GreenbidsAnalyticsConfiguration {
+
+        @Bean
+        GreenbidsAnalyticsReporter greenbidsAnalyticsReporter(
+                GreenbidsAnalyticsConfigurationProperties greenbidsAnalyticsConfigurationProperties,
+                JacksonMapper jacksonMapper,
+                HttpClient httpClient,
+                Clock clock,
+                PrebidVersionProvider prebidVersionProvider) {
+            return new GreenbidsAnalyticsReporter(
+                    greenbidsAnalyticsConfigurationProperties.toComponentProperties(),
+                    jacksonMapper,
+                    httpClient,
+                    clock,
+                    prebidVersionProvider);
+        }
+
+        @Bean
+        @ConfigurationProperties(prefix = "analytics.greenbids")
+        GreenbidsAnalyticsConfigurationProperties greenbidsAnalyticsConfigurationProperties() {
+            return new GreenbidsAnalyticsConfigurationProperties();
+        }
+
+        @Validated
+        @NoArgsConstructor
+        @Data
+        private static class GreenbidsAnalyticsConfigurationProperties {
+            String analyticsServerVersion;
+
+            String analyticsServer;
+
+            Double exploratorySamplingSplit;
+
+            Long timeoutMs;
+
+            public GreenbidsAnalyticsProperties toComponentProperties() {
+                return GreenbidsAnalyticsProperties.builder()
+                        .exploratorySamplingSplit(getExploratorySamplingSplit())
+                        .analyticsServerVersion(getAnalyticsServerVersion())
+                        .analyticsServerUrl(getAnalyticsServer())
+                        .timeoutMs(getTimeoutMs())
+                        .build();
+            }
+        }
+    }
+
     @Configuration
     @ConditionalOnProperty(prefix = "analytics.pubstack", name = "enabled", havingValue = "true")
     public static class PubstackAnalyticsConfiguration {

src/main/resources/application.yaml

@@ -293,5 +293,10 @@ analytics:
       size-bytes: 2097152
       count: 100
       report-ttl-ms: 900000
+  greenbids:
+    analytics-server-version: "2.2.0"
+    analytics-server: http://localhost:8090
+    exploratory-sampling-split: 0.9
+    timeout-ms: 10000
 price-floors:
   enabled: false