Skip to content

Commit d643b8c

Browse files
przemkaczmarekprzemkaczmarek
committed
New Adapter: Alliance Gravity
1 parent 6460b38 commit d643b8c

12 files changed

Lines changed: 719 additions & 0 deletions

File tree

‎src/main/java/org/prebid/server/bidder/alliancegravity/AllianceGravityBidder.java‎

Lines changed: 143 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,143 @@
1+
package org.prebid.server.bidder.alliancegravity;
2+
3+
import com.fasterxml.jackson.core.type.TypeReference;
4+
import com.iab.openrtb.request.BidRequest;
5+
import com.iab.openrtb.request.Imp;
6+
import com.iab.openrtb.response.Bid;
7+
import com.iab.openrtb.response.BidResponse;
8+
import com.iab.openrtb.response.SeatBid;
9+
import org.apache.commons.collections4.CollectionUtils;
10+
import org.prebid.server.bidder.Bidder;
11+
import org.prebid.server.bidder.model.BidderBid;
12+
import org.prebid.server.bidder.model.BidderCall;
13+
import org.prebid.server.bidder.model.BidderError;
14+
import org.prebid.server.bidder.model.HttpRequest;
15+
import org.prebid.server.bidder.model.Result;
16+
import org.prebid.server.exception.PreBidException;
17+
import org.prebid.server.json.DecodeException;
18+
import org.prebid.server.json.JacksonMapper;
19+
import org.prebid.server.proto.openrtb.ext.ExtPrebid;
20+
import org.prebid.server.proto.openrtb.ext.request.ExtImpPrebid;
21+
import org.prebid.server.proto.openrtb.ext.request.ExtStoredRequest;
22+
import org.prebid.server.proto.openrtb.ext.request.alliancegravity.ExtImpAllianceGravity;
23+
import org.prebid.server.proto.openrtb.ext.response.BidType;
24+
import org.prebid.server.util.BidderUtil;
25+
import org.prebid.server.util.HttpUtil;
26+
27+
import java.util.ArrayList;
28+
import java.util.Collection;
29+
import java.util.Collections;
30+
import java.util.List;
31+
import java.util.Objects;
32+
33+
public class AllianceGravityBidder implements Bidder<BidRequest> {
34+
35+
private static final TypeReference<ExtPrebid<?, ExtImpAllianceGravity>> TYPE_REFERENCE =
36+
new TypeReference<>() {
37+
};
38+
39+
private final String endpointUrl;
40+
private final JacksonMapper mapper;
41+
42+
public AllianceGravityBidder(String endpointUrl, JacksonMapper mapper) {
43+
this.endpointUrl = HttpUtil.validateUrl(Objects.requireNonNull(endpointUrl));
44+
this.mapper = Objects.requireNonNull(mapper);
45+
}
46+
47+
@Override
48+
public Result<List<HttpRequest<BidRequest>>> makeHttpRequests(BidRequest request) {
49+
final List<Imp> modifiedImps = new ArrayList<>();
50+
final List<BidderError> errors = new ArrayList<>();
51+
52+
for (Imp imp : request.getImp()) {
53+
try {
54+
final ExtImpAllianceGravity extImp = parseImpExt(imp);
55+
modifiedImps.add(modifyImp(imp, extImp));
56+
} catch (PreBidException e) {
57+
errors.add(BidderError.badInput(e.getMessage()));
58+
}
59+
}
60+
61+
if (modifiedImps.isEmpty()) {
62+
return Result.withErrors(errors);
63+
}
64+
65+
final BidRequest modifiedRequest = request.toBuilder().imp(modifiedImps).build();
66+
return Result.of(
67+
Collections.singletonList(BidderUtil.defaultRequest(modifiedRequest, endpointUrl, mapper)),
68+
errors);
69+
}
70+
71+
private ExtImpAllianceGravity parseImpExt(Imp imp) {
72+
try {
73+
return mapper.mapper().convertValue(imp.getExt(), TYPE_REFERENCE).getBidder();
74+
} catch (IllegalArgumentException e) {
75+
throw new PreBidException(e.getMessage());
76+
}
77+
}
78+
79+
private Imp modifyImp(Imp imp, ExtImpAllianceGravity extImp) {
80+
final ExtImpPrebid extImpPrebid = ExtImpPrebid.builder()
81+
.storedrequest(ExtStoredRequest.of(extImp.getSrId()))
82+
.build();
83+
84+
return imp.toBuilder()
85+
.ext(mapper.mapper().valueToTree(ExtPrebid.of(extImpPrebid, null)))
86+
.build();
87+
}
88+
89+
@Override
90+
public Result<List<BidderBid>> makeBids(BidderCall<BidRequest> httpCall, BidRequest bidRequest) {
91+
try {
92+
final BidResponse bidResponse = mapper.decodeValue(httpCall.getResponse().getBody(), BidResponse.class);
93+
final List<BidderError> errors = new ArrayList<>();
94+
return Result.of(extractBids(bidResponse, errors), errors);
95+
} catch (DecodeException e) {
96+
return Result.withError(BidderError.badServerResponse(e.getMessage()));
97+
}
98+
}
99+
100+
private static List<BidderBid> extractBids(BidResponse bidResponse, List<BidderError> errors) {
101+
if (bidResponse == null || CollectionUtils.isEmpty(bidResponse.getSeatbid())) {
102+
return Collections.emptyList();
103+
}
104+
105+
return bidResponse.getSeatbid().stream()
106+
.filter(Objects::nonNull)
107+
.map(SeatBid::getBid)
108+
.filter(Objects::nonNull)
109+
.flatMap(Collection::stream)
110+
.filter(Objects::nonNull)
111+
.map(bid -> resolveBidderBid(bid, bidResponse.getCur(), errors))
112+
.filter(Objects::nonNull)
113+
.toList();
114+
}
115+
116+
private static BidderBid resolveBidderBid(Bid bid, String currency, List<BidderError> errors) {
117+
final BidType bidType = getBidType(bid, errors);
118+
if (bidType == null) {
119+
return null;
120+
}
121+
return BidderBid.of(bid, bidType, currency);
122+
}
123+
124+
private static BidType getBidType(Bid bid, List<BidderError> errors) {
125+
final Integer mtype = bid.getMtype();
126+
if (mtype == null) {
127+
errors.add(BidderError.badServerResponse(
128+
"Missing MType for bid: " + bid.getId()));
129+
return null;
130+
}
131+
return switch (mtype) {
132+
case 1 -> BidType.banner;
133+
case 2 -> BidType.video;
134+
case 3 -> BidType.audio;
135+
case 4 -> BidType.xNative;
136+
default -> {
137+
errors.add(BidderError.badServerResponse(
138+
"Unsupported MType %d for bid: %s".formatted(mtype, bid.getId())));
139+
yield null;
140+
}
141+
};
142+
}
143+
}

‎src/main/java/org/prebid/server/proto/openrtb/ext/request/alliancegravity/ExtImpAllianceGravity.java‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
package org.prebid.server.proto.openrtb.ext.request.alliancegravity;
2+
3+
import com.fasterxml.jackson.annotation.JsonProperty;
4+
import lombok.Value;
5+
6+
@Value(staticConstructor = "of")
7+
public class ExtImpAllianceGravity {
8+
9+
@JsonProperty("srid")
10+
String srId;
11+
}

‎src/main/java/org/prebid/server/spring/config/bidder/AllianceGravityConfiguration.java‎

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
package org.prebid.server.spring.config.bidder;
2+
3+
import org.prebid.server.bidder.BidderDeps;
4+
import org.prebid.server.bidder.alliancegravity.AllianceGravityBidder;
5+
import org.prebid.server.json.JacksonMapper;
6+
import org.prebid.server.spring.config.bidder.model.BidderConfigurationProperties;
7+
import org.prebid.server.spring.config.bidder.util.BidderDepsAssembler;
8+
import org.prebid.server.spring.config.bidder.util.UsersyncerCreator;
9+
import org.prebid.server.spring.env.YamlPropertySourceFactory;
10+
import org.springframework.beans.factory.annotation.Value;
11+
import org.springframework.boot.context.properties.ConfigurationProperties;
12+
import org.springframework.context.annotation.Bean;
13+
import org.springframework.context.annotation.Configuration;
14+
import org.springframework.context.annotation.PropertySource;
15+
16+
import jakarta.validation.constraints.NotBlank;
17+
18+
@Configuration
19+
@PropertySource(value = "classpath:/bidder-config/alliancegravity.yaml", factory = YamlPropertySourceFactory.class)
20+
public class AllianceGravityConfiguration {
21+
22+
private static final String BIDDER_NAME = "alliance_gravity";
23+
24+
@Bean("alliancegravityConfigurationProperties")
25+
@ConfigurationProperties("adapters.alliancegravity")
26+
BidderConfigurationProperties configurationProperties() {
27+
return new BidderConfigurationProperties();
28+
}
29+
30+
@Bean
31+
BidderDeps alliancegravityBidderDeps(BidderConfigurationProperties alliancegravityConfigurationProperties,
32+
@NotBlank @Value("${external-url}") String externalUrl,
33+
JacksonMapper mapper) {
34+
35+
return BidderDepsAssembler.forBidder(BIDDER_NAME)
36+
.withConfig(alliancegravityConfigurationProperties)
37+
.usersyncerCreator(UsersyncerCreator.create(externalUrl))
38+
.bidderCreator(config -> new AllianceGravityBidder(config.getEndpoint(), mapper))
39+
.assemble();
40+
}
41+
}

‎src/main/resources/bidder-config/alliancegravity.yaml‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
adapters:
2+
alliancegravity:
3+
endpoint: https://pbs.production.agrvt.com/openrtb2/auction
4+
modifying-vast-xml-allowed: true
5+
meta-info:
6+
maintainer-email: produit@alliancegravity.com
7+
app-media-types:
8+
- banner
9+
- video
10+
- audio
11+
- native
12+
site-media-types:
13+
- banner
14+
- video
15+
- audio
16+
- native
17+
supported-vendors:
18+
vendor-id: 501
19+
usersync:
20+
cookie-family-name: alliancegravity
21+
iframe:
22+
url: https://pbs.production.agrvt.com/static/cookie_sync.html?gdpr={{gdpr}}&gdpr_consent={{gdpr_consent}}&us_privacy={{us_privacy}}&redirect_url={{redirect_url}}
23+
support-cors: false

‎src/main/resources/static/bidder-params/alliance_gravity.json‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
{
2+
"$schema": "http://json-schema.org/draft-04/schema#",
3+
"title": "Alliance Gravity Adapter Params",
4+
"description": "A schema which validates params accepted by the Alliance Gravity adapter",
5+
"type": "object",
6+
"properties": {
7+
"srid": {
8+
"type": "string",
9+
"description": "Stored request ID",
10+
"minLength": 1
11+
}
12+
},
13+
"required": ["srid"]
14+
}

0 commit comments

Comments
 (0)