Skip to content

Commit 5c27474

Browse files
SerhiiNahornyiSerhiiNahornyi
authored
Update deprecated Vert.x setHandler with onComplete (prebid#1620)
1 parent af8b657 commit 5c27474

36 files changed

+122
-122
lines changed

‎src/main/java/org/prebid/server/analytics/AnalyticsReporterDelegator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public <T> void processEvent(T event) {
7676

7777
public <T> void processEvent(T event, TcfContext tcfContext) {
7878
privacyEnforcementService.resultForVendorIds(reporterVendorIds, tcfContext)
79-
.setHandler(privacyEnforcementMap -> delegateEvent(event, tcfContext, privacyEnforcementMap));
79+
.onComplete(privacyEnforcementMap -> delegateEvent(event, tcfContext, privacyEnforcementMap));
8080
}
8181

8282
private <T> void delegateEvent(T event,

‎src/main/java/org/prebid/server/analytics/pubstack/PubstackAnalyticsReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ private void fetchRemoteConfig() {
126126
logger.info("[pubstack] Updating config: {0}", pubstackConfig);
127127
httpClient.get(makeEventEndpointUrl(pubstackConfig.getEndpoint(), pubstackConfig.getScopeId()), timeout)
128128
.map(this::processRemoteConfigurationResponse)
129-
.setHandler(this::updateConfigsOnChange);
129+
.onComplete(this::updateConfigsOnChange);
130130
}
131131

132132
private PubstackConfig processRemoteConfigurationResponse(HttpClientResponse response) {

‎src/main/java/org/prebid/server/analytics/pubstack/PubstackEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ private void sendEvents(AtomicReference<Queue<String>> events) {
134134
resetReportEventsConditions();
135135

136136
httpClient.request(HttpMethod.POST, url, headers, toGzippedBytes(copyToSend), timeoutMs)
137-
.setHandler(this::handleReportResponse);
137+
.onComplete(this::handleReportResponse);
138138
}
139139

140140
private void resetReportEventsConditions() {

‎src/main/java/org/prebid/server/auction/categorymapping/BasicCategoryMappingService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ private Future<List<CategoryBidContext>> makeBidderToBidCategory(List<BidderResp
158158
bidderResponse, primaryAdServer, publisher, timeout, withCategory, translateCategories))
159159
.collect(Collectors.toList()));
160160

161-
compositeFuture.setHandler(ignored ->
161+
compositeFuture.onComplete(ignored ->
162162
collectCategoryFetchResults(compositeFuture, categoryBidContextsPromise, rejectedBids));
163163

164164
return categoryBidContextsPromise.future();

‎src/main/java/org/prebid/server/deals/AlertHttpService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public void alert(String name, AlertPriority alertPriority, String message) {
109109
try {
110110
httpClient.post(alertProxyProperties.getUrl(), headers(),
111111
mapper.encodeToString(Collections.singletonList(alertEvent)), timeoutMillis)
112-
.setHandler(this::handleResponse);
112+
.onComplete(this::handleResponse);
113113
} catch (EncodeException e) {
114114
logger.warn("Can't parse alert proxy payload: {0}", e.getMessage());
115115
}

‎src/main/java/org/prebid/server/deals/DealsProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ public Future<AuctionContext> populateDealsInfo(AuctionContext context) {
127127
// So, in handler it is ignored and original CompositeFuture used to process obtained results
128128
// to avoid explicit casting to CompositeFuture implementation.
129129
final Promise<Tuple3<DeviceInfo, GeoInfo, UserDetails>> promise = Promise.promise();
130-
compositeFuture.setHandler(ignored -> handleDealsInfo(compositeFuture, promise, context.getAccount().getId()));
130+
compositeFuture.onComplete(ignored -> handleDealsInfo(compositeFuture, promise, context.getAccount().getId()));
131131
return promise.future()
132132
.map((Tuple3<DeviceInfo, GeoInfo, UserDetails> tuple) ->
133133
enrichAuctionContext(context, tuple.getLeft(), tuple.getMiddle(), tuple.getRight()))

‎src/main/java/org/prebid/server/deals/DeliveryStatsService.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public void sendDeliveryProgressReports(ZonedDateTime now) {
118118
: Future.succeededFuture())),
119119
// combiner does not do any useful operations, just required for this type of reduce operation
120120
(a, b) -> Promise.<Void>promise().future())
121-
.setHandler(result -> handleDeliveryResult(result, batchesCount, sentBatches));
121+
.onComplete(result -> handleDeliveryResult(result, batchesCount, sentBatches));
122122
}
123123

124124
protected Future<Void> sendBatch(DeliveryProgressReportBatch deliveryProgressReportBatch, ZonedDateTime now) {
@@ -136,7 +136,7 @@ protected Future<Void> sendBatch(DeliveryProgressReportBatch deliveryProgressRep
136136
? setInterval(reportIntervalMs)
137137
: Future.succeededFuture()),
138138
(a, b) -> Promise.<Void>promise().future())
139-
.setHandler(result -> handleBatchDelivery(result, deliveryProgressReportBatch, sentReports, promise));
139+
.onComplete(result -> handleBatchDelivery(result, deliveryProgressReportBatch, sentReports, promise));
140140
return promise.future();
141141
}
142142

@@ -160,12 +160,12 @@ protected Future<Void> sendReport(DeliveryProgressReport deliveryProgressReport,
160160
headers.add(HttpHeaders.CONTENT_ENCODING, GZIP);
161161
httpClient.request(HttpMethod.POST, deliveryStatsProperties.getEndpoint(), headers, gzipBody(body),
162162
deliveryStatsProperties.getTimeoutMs())
163-
.setHandler(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
163+
.onComplete(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
164164
startTime));
165165
} else {
166166
httpClient.post(deliveryStatsProperties.getEndpoint(), headers, body,
167167
deliveryStatsProperties.getTimeoutMs())
168-
.setHandler(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
168+
.onComplete(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
169169
startTime));
170170
}
171171

‎src/main/java/org/prebid/server/deals/PlannerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ public void updateLineItemMetaData() {
186186
final MultiMap headers = headers();
187187
fetchLineItemMetaData(planEndpoint, headers)
188188
.recover(ignored -> startRecoveryProcess(planEndpoint, headers))
189-
.setHandler(this::handleInitializationResult);
189+
.onComplete(this::handleInitializationResult);
190190
}
191191

192192
private Future<List<LineItemMetaData>> startRecoveryProcess(String planEndpoint, MultiMap headers) {

‎src/main/java/org/prebid/server/deals/RegisterService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ protected void register(MultiMap headers) {
139139
logger.debug("Register request payload: {0}", body);
140140

141141
httpClient.post(plannerProperties.getRegisterEndpoint(), headers, body, registerTimeout)
142-
.setHandler(this::handleRegister);
142+
.onComplete(this::handleRegister);
143143
}
144144

145145
protected MultiMap headers() {

‎src/main/java/org/prebid/server/deals/UserService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ public void processWinEvent(String lineItemId, String bidId, UidsCookie uids) {
247247
metrics.updateWinNotificationMetric();
248248
final long startTime = clock.millis();
249249
httpClient.post(winEventUrl, body, timeout)
250-
.setHandler(result -> handleWinResponse(result, startTime));
250+
.onComplete(result -> handleWinResponse(result, startTime));
251251
}
252252

253253
/**

‎src/main/java/org/prebid/server/deals/simulation/SimulationAwarePlannerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public void advancePlans(ZonedDateTime now) {
7373

7474
public void initiateLineItemsFetching(ZonedDateTime now) {
7575
fetchLineItemMetaData(planEndpoint, headers(now))
76-
.setHandler(this::handleInitializationResult);
76+
.onComplete(this::handleInitializationResult);
7777
}
7878

7979
/**

‎src/main/java/org/prebid/server/execution/RemoteFileSyncer.java

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -97,12 +97,12 @@ private static void createAndCheckWritePermissionsFor(FileSystem fileSystem, Str
9797
* Fetches remote file and executes given callback with filepath on finish.
9898
*/
9999
public void syncForFilepath(RemoteFileProcessor remoteFileProcessor) {
100-
downloadIfNotExist(remoteFileProcessor).setHandler(syncResult -> handleSync(remoteFileProcessor, syncResult));
100+
downloadIfNotExist(remoteFileProcessor).onComplete(syncResult -> handleSync(remoteFileProcessor, syncResult));
101101
}
102102

103103
private Future<Boolean> downloadIfNotExist(RemoteFileProcessor fileProcessor) {
104104
final Promise<Boolean> promise = Promise.promise();
105-
checkFileExist(saveFilePath).setHandler(existResult ->
105+
checkFileExist(saveFilePath).onComplete(existResult ->
106106
handleFileExistingWithSync(existResult, fileProcessor, promise));
107107
return promise.future();
108108
}
@@ -124,9 +124,9 @@ private void handleFileExistingWithSync(AsyncResult<Boolean> existResult, Remote
124124
if (existResult.succeeded()) {
125125
if (existResult.result()) {
126126
fileProcessor.setDataPath(saveFilePath)
127-
.setHandler(serviceRespond -> handleServiceRespond(serviceRespond, promise));
127+
.onComplete(serviceRespond -> handleServiceRespond(serviceRespond, promise));
128128
} else {
129-
syncRemoteFiles().setHandler(promise);
129+
syncRemoteFiles().onComplete(promise);
130130
}
131131
} else {
132132
promise.fail(existResult.cause());
@@ -136,7 +136,7 @@ private void handleFileExistingWithSync(AsyncResult<Boolean> existResult, Remote
136136
private void handleServiceRespond(AsyncResult<?> processResult, Promise<Boolean> promise) {
137137
if (processResult.failed()) {
138138
final Throwable cause = processResult.cause();
139-
cleanUp(saveFilePath).setHandler(removalResult -> handleCorruptedFileRemoval(removalResult, promise,
139+
cleanUp(saveFilePath).onComplete(removalResult -> handleCorruptedFileRemoval(removalResult, promise,
140140
cause));
141141
} else {
142142
promise.complete(false);
@@ -146,7 +146,7 @@ private void handleServiceRespond(AsyncResult<?> processResult, Promise<Boolean>
146146

147147
private Future<Void> cleanUp(String filePath) {
148148
final Promise<Void> promise = Promise.promise();
149-
checkFileExist(filePath).setHandler(existResult -> handleFileExistsWithDelete(filePath, existResult, promise));
149+
checkFileExist(filePath).onComplete(existResult -> handleFileExistsWithDelete(filePath, existResult, promise));
150150
return promise.future();
151151
}
152152

@@ -173,7 +173,7 @@ private void handleCorruptedFileRemoval(
173173
logger.info("Existing file {0} cant be processed by service, try to download after removal",
174174
serviceCause, saveFilePath);
175175

176-
syncRemoteFiles().setHandler(promise);
176+
syncRemoteFiles().onComplete(promise);
177177
}
178178
}
179179

@@ -185,15 +185,15 @@ private Future<Boolean> syncRemoteFiles() {
185185

186186
private Future<Void> tryDownload() {
187187
final Promise<Void> promise = Promise.promise();
188-
cleanUp(tmpFilePath).setHandler(event -> handleTmpDelete(event, promise));
188+
cleanUp(tmpFilePath).onComplete(event -> handleTmpDelete(event, promise));
189189
return promise.future();
190190
}
191191

192192
private void handleTmpDelete(AsyncResult<Void> tmpDeleteResult, Promise<Void> promise) {
193193
if (tmpDeleteResult.failed()) {
194194
promise.fail(tmpDeleteResult.cause());
195195
} else {
196-
download().setHandler(downloadResult -> handleDownload(downloadResult, promise));
196+
download().onComplete(downloadResult -> handleDownload(downloadResult, promise));
197197
}
198198
}
199199

@@ -265,9 +265,9 @@ private void handleRetry(Promise<Void> receivedPromise, long retryInterval, long
265265
if (retryCount > 0) {
266266
final long next = retryCount - 1;
267267
cleanUp(tmpFilePath).compose(ignore -> download())
268-
.setHandler(retryResult -> handleRetryResult(retryInterval, next, retryResult, receivedPromise));
268+
.onComplete(retryResult -> handleRetryResult(retryInterval, next, retryResult, receivedPromise));
269269
} else {
270-
cleanUp(tmpFilePath).setHandler(ignore -> receivedPromise.fail(new PreBidException(
270+
cleanUp(tmpFilePath).onComplete(ignore -> receivedPromise.fail(new PreBidException(
271271
String.format("File sync failed after %s retries", this.retryCount - retryCount))));
272272
}
273273
}
@@ -295,7 +295,7 @@ private void handleSync(RemoteFileProcessor remoteFileProcessor, AsyncResult<Boo
295295
if (syncResult.result()) {
296296
logger.info("Sync service for {0}", saveFilePath);
297297
remoteFileProcessor.setDataPath(saveFilePath)
298-
.setHandler(this::logFileProcessStatus);
298+
.onComplete(this::logFileProcessStatus);
299299
} else {
300300
logger.info("Sync is not required for {0}", saveFilePath);
301301
}
@@ -319,7 +319,7 @@ private void logFileProcessStatus(AsyncResult<?> serviceRespond) {
319319

320320
private void configureAutoUpdates(RemoteFileProcessor remoteFileProcessor) {
321321
logger.info("Check for updated for {0}", saveFilePath);
322-
tryUpdate().setHandler(asyncUpdate -> {
322+
tryUpdate().onComplete(asyncUpdate -> {
323323
if (asyncUpdate.failed()) {
324324
logger.warn("File {0} update failed", asyncUpdate.cause(), saveFilePath);
325325
}

‎src/main/java/org/prebid/server/geolocation/CircuitBreakerSecuredGeoLocationService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public CircuitBreakerSecuredGeoLocationService(Vertx vertx,
4949

5050
@Override
5151
public Future<GeoInfo> lookup(String ip, Timeout timeout) {
52-
return breaker.execute(promise -> geoLocationService.lookup(ip, timeout).setHandler(promise));
52+
return breaker.execute(promise -> geoLocationService.lookup(ip, timeout).onComplete(promise));
5353
}
5454

5555
private void circuitOpened() {

‎src/main/java/org/prebid/server/handler/CookieSyncHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ public void handle(RoutingContext routingContext) {
150150
metrics.updateCookieSyncRequestMetric();
151151

152152
toCookieSyncContext(routingContext)
153-
.setHandler(cookieSyncContextResult -> handleCookieSyncContextResult(cookieSyncContextResult,
153+
.onComplete(cookieSyncContextResult -> handleCookieSyncContextResult(cookieSyncContextResult,
154154
routingContext));
155155
}
156156

@@ -218,7 +218,7 @@ private void handleCookieSyncContextResult(AsyncResult<CookieSyncContext> cookie
218218
}
219219

220220
isAllowedForHostVendorId(tcfContext)
221-
.setHandler(hostTcfResponseResult -> respondByTcfResponse(
221+
.onComplete(hostTcfResponseResult -> respondByTcfResponse(
222222
hostTcfResponseResult,
223223
biddersToSync(cookieSyncContext),
224224
cookieSyncContext));
@@ -365,7 +365,7 @@ private void respondByTcfResponse(AsyncResult<HostVendorTcfResponse> hostTcfResp
365365
final AccountGdprConfig accountGdprConfig =
366366
accountPrivacyConfig != null ? accountPrivacyConfig.getGdpr() : null;
367367
tcfDefinerService.resultForBidderNames(biddersToSync, tcfContext, accountGdprConfig)
368-
.setHandler(tcfResponseResult -> respondByTcfResultForBidders(tcfResponseResult,
368+
.onComplete(tcfResponseResult -> respondByTcfResultForBidders(tcfResponseResult,
369369
biddersToSync, cookieSyncContext));
370370
} else {
371371
// Reject all bidders when Host TCF response has blocked pixel

‎src/main/java/org/prebid/server/handler/NotificationEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public void handle(RoutingContext routingContext) {
110110

111111
final EventRequest eventRequest = EventUtil.from(routingContext);
112112
getAccountById(eventRequest.getAccountId())
113-
.setHandler(async -> handleEvent(async, eventRequest, routingContext));
113+
.onComplete(async -> handleEvent(async, eventRequest, routingContext));
114114
}
115115

116116
/**

‎src/main/java/org/prebid/server/handler/OptoutHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public void handle(RoutingContext routingContext) {
5050
}
5151

5252
googleRecaptchaVerifier.verify(recaptcha)
53-
.setHandler(result -> handleVerification(routingContext, result));
53+
.onComplete(result -> handleVerification(routingContext, result));
5454
}
5555

5656
private void handleVerification(RoutingContext routingContext, AsyncResult<RecaptchaResponse> result) {

‎src/main/java/org/prebid/server/handler/SetuidHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ private static String preferredUserSyncType(Usersyncer usersyncer) {
107107
@Override
108108
public void handle(RoutingContext routingContext) {
109109
toSetuidContext(routingContext)
110-
.setHandler(setuidContextResult -> handleSetuidContextResult(setuidContextResult, routingContext));
110+
.onComplete(setuidContextResult -> handleSetuidContextResult(setuidContextResult, routingContext));
111111
}
112112

113113
private Future<SetuidContext> toSetuidContext(RoutingContext routingContext) {
@@ -152,7 +152,7 @@ private void handleSetuidContextResult(AsyncResult<SetuidContext> setuidContextR
152152
}
153153

154154
isAllowedForHostVendorId(tcfContext)
155-
.setHandler(hostTcfResponseResult -> respondByTcfResponse(hostTcfResponseResult, setuidContext));
155+
.onComplete(hostTcfResponseResult -> respondByTcfResponse(hostTcfResponseResult, setuidContext));
156156
} else {
157157
final Throwable error = setuidContextResult.cause();
158158
handleErrors(error, routingContext, null);

‎src/main/java/org/prebid/server/handler/VtrackHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public void handle(RoutingContext routingContext) {
8989

9090
applicationSettings.getAccountById(accountId, timeout)
9191
.recover(exception -> handleAccountExceptionOrFallback(exception, accountId))
92-
.setHandler(async -> handleAccountResult(async, routingContext, vtrackPuts, accountId, integration,
92+
.onComplete(async -> handleAccountResult(async, routingContext, vtrackPuts, accountId, integration,
9393
timeout));
9494
}
9595

@@ -176,7 +176,7 @@ private void handleAccountResult(AsyncResult<Account> asyncAccount,
176176
final Boolean isEventEnabled = accountEventsEnabled(asyncAccount.result());
177177
final Set<String> allowedBidders = biddersAllowingVastUpdate(vtrackPuts);
178178
cacheService.cachePutObjects(vtrackPuts, isEventEnabled, allowedBidders, accountId, integration, timeout)
179-
.setHandler(asyncCache -> handleCacheResult(asyncCache, routingContext));
179+
.onComplete(asyncCache -> handleCacheResult(asyncCache, routingContext));
180180
}
181181
}
182182

‎src/main/java/org/prebid/server/handler/openrtb2/AmpHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ public void handle(RoutingContext routingContext) {
132132
.map(context -> addToEvent(context.getBidResponse(), ampEventBuilder::bidResponse, context))
133133
.compose(context -> prepareAmpResponse(context, routingContext))
134134
.map(result -> addToEvent(result.getLeft().getTargeting(), ampEventBuilder::targeting, result))
135-
.setHandler(responseResult -> handleResult(responseResult, ampEventBuilder, routingContext, startTime));
135+
.onComplete(responseResult -> handleResult(responseResult, ampEventBuilder, routingContext, startTime));
136136
}
137137

138138
private static <T, R> R addToEvent(T field, Consumer<T> consumer, R result) {

‎src/main/java/org/prebid/server/handler/openrtb2/AuctionHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ public void handle(RoutingContext routingContext) {
9494
// populate event with updated context
9595
.map(context -> addToEvent(context, auctionEventBuilder::auctionContext, context))
9696
.map(context -> addToEvent(context.getBidResponse(), auctionEventBuilder::bidResponse, context))
97-
.setHandler(context -> handleResult(context, auctionEventBuilder, routingContext, startTime));
97+
.onComplete(context -> handleResult(context, auctionEventBuilder, routingContext, startTime));
9898
}
9999

100100
private static <T, R> R addToEvent(T field, Consumer<T> consumer, R result) {

‎src/main/java/org/prebid/server/handler/openrtb2/VideoHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public void handle(RoutingContext routingContext) {
102102
result.getPodErrors()))
103103

104104
.map(videoResponse -> addToEvent(videoResponse, videoEventBuilder::bidResponse, videoResponse))
105-
.setHandler(responseResult -> handleResult(responseResult, videoEventBuilder, routingContext,
105+
.onComplete(responseResult -> handleResult(responseResult, videoEventBuilder, routingContext,
106106
startTime));
107107
}
108108

‎src/main/java/org/prebid/server/health/DatabaseHealthChecker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public String name() {
3838
void updateStatus() {
3939
final Promise<SQLConnection> connectionPromise = Promise.promise();
4040
jdbcClient.getConnection(connectionPromise);
41-
connectionPromise.future().setHandler(result ->
41+
connectionPromise.future().onComplete(result ->
4242
status = StatusResponse.of(
4343
result.succeeded() ? Status.UP.name() : Status.DOWN.name(),
4444
ZonedDateTime.now(Clock.systemUTC())));

0 commit comments

Comments
 (0)