Update deprecated Vert.x setHandler with onComplete (#1620)

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

@@ -76,7 +76,7 @@ public <T> void processEvent(T event) {
 
     public <T> void processEvent(T event, TcfContext tcfContext) {
         privacyEnforcementService.resultForVendorIds(reporterVendorIds, tcfContext)
-                .setHandler(privacyEnforcementMap -> delegateEvent(event, tcfContext, privacyEnforcementMap));
+                .onComplete(privacyEnforcementMap -> delegateEvent(event, tcfContext, privacyEnforcementMap));
     }
 
     private <T> void delegateEvent(T event,

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

@@ -126,7 +126,7 @@ private void fetchRemoteConfig() {
         logger.info("[pubstack] Updating config: {0}", pubstackConfig);
         httpClient.get(makeEventEndpointUrl(pubstackConfig.getEndpoint(), pubstackConfig.getScopeId()), timeout)
                 .map(this::processRemoteConfigurationResponse)
-                .setHandler(this::updateConfigsOnChange);
+                .onComplete(this::updateConfigsOnChange);
     }
 
     private PubstackConfig processRemoteConfigurationResponse(HttpClientResponse response) {

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

@@ -134,7 +134,7 @@ private void sendEvents(AtomicReference<Queue<String>> events) {
         resetReportEventsConditions();
 
         httpClient.request(HttpMethod.POST, url, headers, toGzippedBytes(copyToSend), timeoutMs)
-                .setHandler(this::handleReportResponse);
+                .onComplete(this::handleReportResponse);
     }
 
     private void resetReportEventsConditions() {

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

@@ -158,7 +158,7 @@ private Future<List<CategoryBidContext>> makeBidderToBidCategory(List<BidderResp
                         bidderResponse, primaryAdServer, publisher, timeout, withCategory, translateCategories))
                 .collect(Collectors.toList()));
 
-        compositeFuture.setHandler(ignored ->
+        compositeFuture.onComplete(ignored ->
                 collectCategoryFetchResults(compositeFuture, categoryBidContextsPromise, rejectedBids));
 
         return categoryBidContextsPromise.future();

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

@@ -109,7 +109,7 @@ public void alert(String name, AlertPriority alertPriority, String message) {
         try {
             httpClient.post(alertProxyProperties.getUrl(), headers(),
                             mapper.encodeToString(Collections.singletonList(alertEvent)), timeoutMillis)
-                    .setHandler(this::handleResponse);
+                    .onComplete(this::handleResponse);
         } catch (EncodeException e) {
             logger.warn("Can't parse alert proxy payload: {0}", e.getMessage());
         }

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

@@ -127,7 +127,7 @@ public Future<AuctionContext> populateDealsInfo(AuctionContext context) {
         // So, in handler it is ignored and original CompositeFuture used to process obtained results
         // to avoid explicit casting to CompositeFuture implementation.
         final Promise<Tuple3<DeviceInfo, GeoInfo, UserDetails>> promise = Promise.promise();
-        compositeFuture.setHandler(ignored -> handleDealsInfo(compositeFuture, promise, context.getAccount().getId()));
+        compositeFuture.onComplete(ignored -> handleDealsInfo(compositeFuture, promise, context.getAccount().getId()));
         return promise.future()
                 .map((Tuple3<DeviceInfo, GeoInfo, UserDetails> tuple) ->
                         enrichAuctionContext(context, tuple.getLeft(), tuple.getMiddle(), tuple.getRight()))

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

@@ -118,7 +118,7 @@ public void sendDeliveryProgressReports(ZonedDateTime now) {
                                         : Future.succeededFuture())),
                         // combiner does not do any useful operations, just required for this type of reduce operation
                         (a, b) -> Promise.<Void>promise().future())
-                .setHandler(result -> handleDeliveryResult(result, batchesCount, sentBatches));
+                .onComplete(result -> handleDeliveryResult(result, batchesCount, sentBatches));
     }
 
     protected Future<Void> sendBatch(DeliveryProgressReportBatch deliveryProgressReportBatch, ZonedDateTime now) {
@@ -136,7 +136,7 @@ protected Future<Void> sendBatch(DeliveryProgressReportBatch deliveryProgressRep
                                         ? setInterval(reportIntervalMs)
                                         : Future.succeededFuture()),
                         (a, b) -> Promise.<Void>promise().future())
-                .setHandler(result -> handleBatchDelivery(result, deliveryProgressReportBatch, sentReports, promise));
+                .onComplete(result -> handleBatchDelivery(result, deliveryProgressReportBatch, sentReports, promise));
         return promise.future();
     }
 
@@ -160,12 +160,12 @@ protected Future<Void> sendReport(DeliveryProgressReport deliveryProgressReport,
             headers.add(HttpHeaders.CONTENT_ENCODING, GZIP);
             httpClient.request(HttpMethod.POST, deliveryStatsProperties.getEndpoint(), headers, gzipBody(body),
                     deliveryStatsProperties.getTimeoutMs())
-                    .setHandler(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
+                    .onComplete(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
                             startTime));
         } else {
             httpClient.post(deliveryStatsProperties.getEndpoint(), headers, body,
                     deliveryStatsProperties.getTimeoutMs())
-                    .setHandler(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
+                    .onComplete(result -> handleDeliveryProgressReport(result, deliveryProgressReport, promise,
                             startTime));
         }
 

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

@@ -186,7 +186,7 @@ public void updateLineItemMetaData() {
         final MultiMap headers = headers();
         fetchLineItemMetaData(planEndpoint, headers)
                 .recover(ignored -> startRecoveryProcess(planEndpoint, headers))
-                .setHandler(this::handleInitializationResult);
+                .onComplete(this::handleInitializationResult);
     }
 
     private Future<List<LineItemMetaData>> startRecoveryProcess(String planEndpoint, MultiMap headers) {

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

@@ -139,7 +139,7 @@ protected void register(MultiMap headers) {
         logger.debug("Register request payload: {0}", body);
 
         httpClient.post(plannerProperties.getRegisterEndpoint(), headers, body, registerTimeout)
-                .setHandler(this::handleRegister);
+                .onComplete(this::handleRegister);
     }
 
     protected MultiMap headers() {

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

@@ -247,7 +247,7 @@ public void processWinEvent(String lineItemId, String bidId, UidsCookie uids) {
         metrics.updateWinNotificationMetric();
         final long startTime = clock.millis();
         httpClient.post(winEventUrl, body, timeout)
-                .setHandler(result -> handleWinResponse(result, startTime));
+                .onComplete(result -> handleWinResponse(result, startTime));
     }
 
     /**

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

@@ -73,7 +73,7 @@ public void advancePlans(ZonedDateTime now) {
 
     public void initiateLineItemsFetching(ZonedDateTime now) {
         fetchLineItemMetaData(planEndpoint, headers(now))
-                .setHandler(this::handleInitializationResult);
+                .onComplete(this::handleInitializationResult);
     }
 
     /**

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

@@ -97,12 +97,12 @@ private static void createAndCheckWritePermissionsFor(FileSystem fileSystem, Str
      * Fetches remote file and executes given callback with filepath on finish.
      */
     public void syncForFilepath(RemoteFileProcessor remoteFileProcessor) {
-        downloadIfNotExist(remoteFileProcessor).setHandler(syncResult -> handleSync(remoteFileProcessor, syncResult));
+        downloadIfNotExist(remoteFileProcessor).onComplete(syncResult -> handleSync(remoteFileProcessor, syncResult));
     }
 
     private Future<Boolean> downloadIfNotExist(RemoteFileProcessor fileProcessor) {
         final Promise<Boolean> promise = Promise.promise();
-        checkFileExist(saveFilePath).setHandler(existResult ->
+        checkFileExist(saveFilePath).onComplete(existResult ->
                 handleFileExistingWithSync(existResult, fileProcessor, promise));
         return promise.future();
     }
@@ -124,9 +124,9 @@ private void handleFileExistingWithSync(AsyncResult<Boolean> existResult, Remote
         if (existResult.succeeded()) {
             if (existResult.result()) {
                 fileProcessor.setDataPath(saveFilePath)
-                        .setHandler(serviceRespond -> handleServiceRespond(serviceRespond, promise));
+                        .onComplete(serviceRespond -> handleServiceRespond(serviceRespond, promise));
             } else {
-                syncRemoteFiles().setHandler(promise);
+                syncRemoteFiles().onComplete(promise);
             }
         } else {
             promise.fail(existResult.cause());
@@ -136,7 +136,7 @@ private void handleFileExistingWithSync(AsyncResult<Boolean> existResult, Remote
     private void handleServiceRespond(AsyncResult<?> processResult, Promise<Boolean> promise) {
         if (processResult.failed()) {
             final Throwable cause = processResult.cause();
-            cleanUp(saveFilePath).setHandler(removalResult -> handleCorruptedFileRemoval(removalResult, promise,
+            cleanUp(saveFilePath).onComplete(removalResult -> handleCorruptedFileRemoval(removalResult, promise,
                     cause));
         } else {
             promise.complete(false);
@@ -146,7 +146,7 @@ private void handleServiceRespond(AsyncResult<?> processResult, Promise<Boolean>
 
     private Future<Void> cleanUp(String filePath) {
         final Promise<Void> promise = Promise.promise();
-        checkFileExist(filePath).setHandler(existResult -> handleFileExistsWithDelete(filePath, existResult, promise));
+        checkFileExist(filePath).onComplete(existResult -> handleFileExistsWithDelete(filePath, existResult, promise));
         return promise.future();
     }
 
@@ -173,7 +173,7 @@ private void handleCorruptedFileRemoval(
             logger.info("Existing file {0} cant be processed by service, try to download after removal",
                     serviceCause, saveFilePath);
 
-            syncRemoteFiles().setHandler(promise);
+            syncRemoteFiles().onComplete(promise);
         }
     }
 
@@ -185,15 +185,15 @@ private Future<Boolean> syncRemoteFiles() {
 
     private Future<Void> tryDownload() {
         final Promise<Void> promise = Promise.promise();
-        cleanUp(tmpFilePath).setHandler(event -> handleTmpDelete(event, promise));
+        cleanUp(tmpFilePath).onComplete(event -> handleTmpDelete(event, promise));
         return promise.future();
     }
 
     private void handleTmpDelete(AsyncResult<Void> tmpDeleteResult, Promise<Void> promise) {
         if (tmpDeleteResult.failed()) {
             promise.fail(tmpDeleteResult.cause());
         } else {
-            download().setHandler(downloadResult -> handleDownload(downloadResult, promise));
+            download().onComplete(downloadResult -> handleDownload(downloadResult, promise));
         }
     }
 
@@ -265,9 +265,9 @@ private void handleRetry(Promise<Void> receivedPromise, long retryInterval, long
         if (retryCount > 0) {
             final long next = retryCount - 1;
             cleanUp(tmpFilePath).compose(ignore -> download())
-                    .setHandler(retryResult -> handleRetryResult(retryInterval, next, retryResult, receivedPromise));
+                    .onComplete(retryResult -> handleRetryResult(retryInterval, next, retryResult, receivedPromise));
         } else {
-            cleanUp(tmpFilePath).setHandler(ignore -> receivedPromise.fail(new PreBidException(
+            cleanUp(tmpFilePath).onComplete(ignore -> receivedPromise.fail(new PreBidException(
                     String.format("File sync failed after %s retries", this.retryCount - retryCount))));
         }
     }
@@ -295,7 +295,7 @@ private void handleSync(RemoteFileProcessor remoteFileProcessor, AsyncResult<Boo
             if (syncResult.result()) {
                 logger.info("Sync service for {0}", saveFilePath);
                 remoteFileProcessor.setDataPath(saveFilePath)
-                        .setHandler(this::logFileProcessStatus);
+                        .onComplete(this::logFileProcessStatus);
             } else {
                 logger.info("Sync is not required for {0}", saveFilePath);
             }
@@ -319,7 +319,7 @@ private void logFileProcessStatus(AsyncResult<?> serviceRespond) {
 
     private void configureAutoUpdates(RemoteFileProcessor remoteFileProcessor) {
         logger.info("Check for updated for {0}", saveFilePath);
-        tryUpdate().setHandler(asyncUpdate -> {
+        tryUpdate().onComplete(asyncUpdate -> {
             if (asyncUpdate.failed()) {
                 logger.warn("File {0} update failed", asyncUpdate.cause(), saveFilePath);
             }

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

@@ -49,7 +49,7 @@ public CircuitBreakerSecuredGeoLocationService(Vertx vertx,
 
     @Override
     public Future<GeoInfo> lookup(String ip, Timeout timeout) {
-        return breaker.execute(promise -> geoLocationService.lookup(ip, timeout).setHandler(promise));
+        return breaker.execute(promise -> geoLocationService.lookup(ip, timeout).onComplete(promise));
     }
 
     private void circuitOpened() {

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

@@ -150,7 +150,7 @@ public void handle(RoutingContext routingContext) {
         metrics.updateCookieSyncRequestMetric();
 
         toCookieSyncContext(routingContext)
-                .setHandler(cookieSyncContextResult -> handleCookieSyncContextResult(cookieSyncContextResult,
+                .onComplete(cookieSyncContextResult -> handleCookieSyncContextResult(cookieSyncContextResult,
                         routingContext));
     }
 
@@ -218,7 +218,7 @@ private void handleCookieSyncContextResult(AsyncResult<CookieSyncContext> cookie
             }
 
             isAllowedForHostVendorId(tcfContext)
-                    .setHandler(hostTcfResponseResult -> respondByTcfResponse(
+                    .onComplete(hostTcfResponseResult -> respondByTcfResponse(
                             hostTcfResponseResult,
                             biddersToSync(cookieSyncContext),
                             cookieSyncContext));
@@ -365,7 +365,7 @@ private void respondByTcfResponse(AsyncResult<HostVendorTcfResponse> hostTcfResp
                 final AccountGdprConfig accountGdprConfig =
                         accountPrivacyConfig != null ? accountPrivacyConfig.getGdpr() : null;
                 tcfDefinerService.resultForBidderNames(biddersToSync, tcfContext, accountGdprConfig)
-                        .setHandler(tcfResponseResult -> respondByTcfResultForBidders(tcfResponseResult,
+                        .onComplete(tcfResponseResult -> respondByTcfResultForBidders(tcfResponseResult,
                                 biddersToSync, cookieSyncContext));
             } else {
                 // Reject all bidders when Host TCF response has blocked pixel

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

@@ -110,7 +110,7 @@ public void handle(RoutingContext routingContext) {
 
         final EventRequest eventRequest = EventUtil.from(routingContext);
         getAccountById(eventRequest.getAccountId())
-                .setHandler(async -> handleEvent(async, eventRequest, routingContext));
+                .onComplete(async -> handleEvent(async, eventRequest, routingContext));
     }
 
     /**

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

@@ -50,7 +50,7 @@ public void handle(RoutingContext routingContext) {
         }
 
         googleRecaptchaVerifier.verify(recaptcha)
-                .setHandler(result -> handleVerification(routingContext, result));
+                .onComplete(result -> handleVerification(routingContext, result));
     }
 
     private void handleVerification(RoutingContext routingContext, AsyncResult<RecaptchaResponse> result) {

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

@@ -107,7 +107,7 @@ private static String preferredUserSyncType(Usersyncer usersyncer) {
     @Override
     public void handle(RoutingContext routingContext) {
         toSetuidContext(routingContext)
-                .setHandler(setuidContextResult -> handleSetuidContextResult(setuidContextResult, routingContext));
+                .onComplete(setuidContextResult -> handleSetuidContextResult(setuidContextResult, routingContext));
     }
 
     private Future<SetuidContext> toSetuidContext(RoutingContext routingContext) {
@@ -152,7 +152,7 @@ private void handleSetuidContextResult(AsyncResult<SetuidContext> setuidContextR
             }
 
             isAllowedForHostVendorId(tcfContext)
-                    .setHandler(hostTcfResponseResult -> respondByTcfResponse(hostTcfResponseResult, setuidContext));
+                    .onComplete(hostTcfResponseResult -> respondByTcfResponse(hostTcfResponseResult, setuidContext));
         } else {
             final Throwable error = setuidContextResult.cause();
             handleErrors(error, routingContext, null);

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

@@ -89,7 +89,7 @@ public void handle(RoutingContext routingContext) {
 
         applicationSettings.getAccountById(accountId, timeout)
                 .recover(exception -> handleAccountExceptionOrFallback(exception, accountId))
-                .setHandler(async -> handleAccountResult(async, routingContext, vtrackPuts, accountId, integration,
+                .onComplete(async -> handleAccountResult(async, routingContext, vtrackPuts, accountId, integration,
                         timeout));
     }
 
@@ -176,7 +176,7 @@ private void handleAccountResult(AsyncResult<Account> asyncAccount,
             final Boolean isEventEnabled = accountEventsEnabled(asyncAccount.result());
             final Set<String> allowedBidders = biddersAllowingVastUpdate(vtrackPuts);
             cacheService.cachePutObjects(vtrackPuts, isEventEnabled, allowedBidders, accountId, integration, timeout)
-                    .setHandler(asyncCache -> handleCacheResult(asyncCache, routingContext));
+                    .onComplete(asyncCache -> handleCacheResult(asyncCache, routingContext));
         }
     }
 

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

@@ -132,7 +132,7 @@ public void handle(RoutingContext routingContext) {
                 .map(context -> addToEvent(context.getBidResponse(), ampEventBuilder::bidResponse, context))
                 .compose(context -> prepareAmpResponse(context, routingContext))
                 .map(result -> addToEvent(result.getLeft().getTargeting(), ampEventBuilder::targeting, result))
-                .setHandler(responseResult -> handleResult(responseResult, ampEventBuilder, routingContext, startTime));
+                .onComplete(responseResult -> handleResult(responseResult, ampEventBuilder, routingContext, startTime));
     }
 
     private static <T, R> R addToEvent(T field, Consumer<T> consumer, R result) {

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

@@ -94,7 +94,7 @@ public void handle(RoutingContext routingContext) {
                 // populate event with updated context
                 .map(context -> addToEvent(context, auctionEventBuilder::auctionContext, context))
                 .map(context -> addToEvent(context.getBidResponse(), auctionEventBuilder::bidResponse, context))
-                .setHandler(context -> handleResult(context, auctionEventBuilder, routingContext, startTime));
+                .onComplete(context -> handleResult(context, auctionEventBuilder, routingContext, startTime));
     }
 
     private static <T, R> R addToEvent(T field, Consumer<T> consumer, R result) {

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

@@ -102,7 +102,7 @@ public void handle(RoutingContext routingContext) {
                         result.getPodErrors()))
 
                 .map(videoResponse -> addToEvent(videoResponse, videoEventBuilder::bidResponse, videoResponse))
-                .setHandler(responseResult -> handleResult(responseResult, videoEventBuilder, routingContext,
+                .onComplete(responseResult -> handleResult(responseResult, videoEventBuilder, routingContext,
                         startTime));
     }
 

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

@@ -38,7 +38,7 @@ public String name() {
     void updateStatus() {
         final Promise<SQLConnection> connectionPromise = Promise.promise();
         jdbcClient.getConnection(connectionPromise);
-        connectionPromise.future().setHandler(result ->
+        connectionPromise.future().onComplete(result ->
                 status = StatusResponse.of(
                         result.succeeded() ? Status.UP.name() : Status.DOWN.name(),
                         ZonedDateTime.now(Clock.systemUTC())));