Tests: Refactoring functional tests

src/test/groovy/org/prebid/server/functional/model/config/AdminConfig.groovy

@@ -3,7 +3,6 @@ package org.prebid.server.functional.model.config
 import com.fasterxml.jackson.databind.PropertyNamingStrategies
 import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
 
 @ToString(includeNames = true, ignoreNulls = true)
 @JsonNaming(PropertyNamingStrategies.KebabCaseStrategy)

src/test/groovy/org/prebid/server/functional/model/config/EndpointExecutionPlan.groovy

@@ -1,16 +1,16 @@
 package org.prebid.server.functional.model.config
 
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
 
 @ToString(includeNames = true, ignoreNulls = true)
 class EndpointExecutionPlan {
 
     Map<Stage, StageExecutionPlan> stages
 
     static EndpointExecutionPlan getModuleEndpointExecutionPlan(ModuleName name, List<Stage> stages) {
-        new EndpointExecutionPlan(stages:  stages.collectEntries {
-            it -> [(it): StageExecutionPlan.getModuleStageExecutionPlan(name, it)] } as Map<Stage, StageExecutionPlan>)
+        new EndpointExecutionPlan(stages: stages.collectEntries {
+            it -> [(it): StageExecutionPlan.getModuleStageExecutionPlan(name, it)]
+        } as Map<Stage, StageExecutionPlan>)
     }
 
     static EndpointExecutionPlan getModulesEndpointExecutionPlan(Map<Stage, List<ModuleName>> modulesStages) {
@@ -24,4 +24,17 @@ class EndpointExecutionPlan {
                 } as Map<Stage, StageExecutionPlan>
         )
     }
+
+    static EndpointExecutionPlan getModuleEndpointExecutionPlan(List<ModuleHookImplementation> modulesHooks) {
+        Map<Stage, StageExecutionPlan> stages = [:]
+        modulesHooks.each { moduleHook ->
+            def stage = Stage.forValue(moduleHook)
+            if (!stages.containsKey(stage)) {
+                stages[stage] = StageExecutionPlan.getModuleStageExecutionPlan([moduleHook])
+            } else {
+                stages[stage].addGroup(moduleHook)
+            }
+        }
+        new EndpointExecutionPlan(stages: stages)
+    }
 }

src/test/groovy/org/prebid/server/functional/model/config/ExecutionGroup.groovy

@@ -4,7 +4,6 @@ import com.fasterxml.jackson.annotation.JsonProperty
 import com.fasterxml.jackson.databind.PropertyNamingStrategies
 import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
 
 @ToString(includeNames = true, ignoreNulls = true)
 @JsonNaming(PropertyNamingStrategies.KebabCaseStrategy)
@@ -16,6 +15,13 @@ class ExecutionGroup {
     @JsonProperty("hook_sequence")
     List<HookId> hookSequenceSnakeCase
 
+    static ExecutionGroup getModuleExecutionGroup(ModuleHookImplementation moduleHook) {
+        new ExecutionGroup().tap {
+            timeout = 100
+            hookSequence = [new HookId(moduleCode: ModuleName.forValue(moduleHook).code, hookImplCode: moduleHook.code)]
+        }
+    }
+
     static ExecutionGroup getModuleExecutionGroup(ModuleName name, Stage stage) {
         new ExecutionGroup().tap {
             timeout = 1000

src/test/groovy/org/prebid/server/functional/model/config/ExecutionPlan.groovy

@@ -3,15 +3,20 @@ package org.prebid.server.functional.model.config
 import com.fasterxml.jackson.databind.PropertyNamingStrategies
 import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
+
+import static org.prebid.server.functional.model.config.Endpoint.OPENRTB2_AUCTION
 
 @ToString(includeNames = true, ignoreNulls = true)
 @JsonNaming(PropertyNamingStrategies.LowerCaseStrategy)
 class ExecutionPlan {
 
-    List<AbTest> abTests
+    List<ModularityAbTest> abTests
     Map<Endpoint, EndpointExecutionPlan> endpoints
 
+    static ExecutionPlan getSingleEndpointExecutionPlan(List<ModuleHookImplementation> moduleHook, Endpoint endpoint = OPENRTB2_AUCTION) {
+        new ExecutionPlan(endpoints: [(endpoint): EndpointExecutionPlan.getModuleEndpointExecutionPlan(moduleHook)])
+    }
+
     static ExecutionPlan getSingleEndpointExecutionPlan(Endpoint endpoint, ModuleName moduleName, List<Stage> stage) {
         new ExecutionPlan(endpoints: [(endpoint): EndpointExecutionPlan.getModuleEndpointExecutionPlan(moduleName, stage)])
     }

src/test/groovy/org/prebid/server/functional/model/config/AbTest.groovy → src/test/groovy/org/prebid/server/functional/model/config/ModularityAbTest.groovy

@@ -7,7 +7,7 @@ import groovy.transform.ToString
 
 @ToString(includeNames = true, ignoreNulls = true)
 @JsonNaming(PropertyNamingStrategies.KebabCaseStrategy)
-class AbTest {
+class ModularityAbTest {
 
     Boolean enabled
     String moduleCode
@@ -21,8 +21,8 @@ class AbTest {
     @JsonProperty("log_analytics_tag")
     Boolean logAnalyticsTagSnakeCase
 
-    static AbTest getDefault(String moduleCode, List<Integer> accounts = null) {
-        new AbTest(enabled: true,
+    static ModularityAbTest getDefault(String moduleCode, List<Integer> accounts = null) {
+        new ModularityAbTest(enabled: true,
                 moduleCode: moduleCode,
                 accounts: accounts,
                 percentActive: 0,

src/test/groovy/org/prebid/server/functional/model/config/ModuleHookImplementation.groovy

@@ -1,7 +1,6 @@
 package org.prebid.server.functional.model.config
 
 import com.fasterxml.jackson.annotation.JsonValue
-import org.prebid.server.functional.model.ModuleName
 
 //TODO remove if module hooks implementation codes will become consistent
 enum ModuleHookImplementation {

src/test/groovy/org/prebid/server/functional/model/config/ModuleName.groovy

@@ -0,0 +1,24 @@
+package org.prebid.server.functional.model.config
+
+import com.fasterxml.jackson.annotation.JsonValue
+
+enum ModuleName {
+
+    PB_RICHMEDIA_FILTER('pb-richmedia-filter'),
+    PB_RESPONSE_CORRECTION ('pb-response-correction'),
+    ORTB2_BLOCKING('ortb2-blocking'),
+    PB_REQUEST_CORRECTION('pb-request-correction'),
+    OPTABLE_TARGETING('optable-targeting'),
+    PB_RULE_ENGINE('pb-rule-engine'),
+
+    @JsonValue
+    final String code
+
+    ModuleName(String code) {
+        this.code = code
+    }
+
+    static ModuleName forValue(ModuleHookImplementation moduleHook) {
+        values().find { moduleHook.code.contains(it.code) }
+    }
+}

src/test/groovy/org/prebid/server/functional/model/config/Stage.groovy

@@ -24,6 +24,13 @@ enum Stage {
         this.metricValue = metricValue
     }
 
+    static Stage forValue(ModuleHookImplementation moduleHook) {
+        values().collect { [stage: it, matchLength: moduleHook.code.indexOf(it.value) >= 0 ? it.value.length() : -1] }
+                .findAll { it.matchLength > 0 }
+                .max { it.matchLength }
+                ?.stage
+    }
+
     @Override
     String toString() {
         value

src/test/groovy/org/prebid/server/functional/model/config/StageExecutionPlan.groovy

@@ -1,7 +1,6 @@
 package org.prebid.server.functional.model.config
 
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
 
 @ToString(includeNames = true, ignoreNulls = true)
 class StageExecutionPlan {
@@ -11,4 +10,13 @@ class StageExecutionPlan {
     static StageExecutionPlan getModuleStageExecutionPlan(ModuleName name, Stage stage) {
         new StageExecutionPlan(groups: [ExecutionGroup.getModuleExecutionGroup(name, stage)])
     }
+
+    static StageExecutionPlan getModuleStageExecutionPlan(List<ModuleHookImplementation> modulesHooks) {
+        new StageExecutionPlan(groups: modulesHooks.collect { ExecutionGroup.getModuleExecutionGroup(it) })
+    }
+
+    StageExecutionPlan addGroup(ModuleHookImplementation moduleHook) {
+        (groups ?: (groups = [])).add(ExecutionGroup.getModuleExecutionGroup(moduleHook))
+        this
+    }
 }

src/test/groovy/org/prebid/server/functional/model/request/auction/User.groovy

@@ -1,15 +1,18 @@
 package org.prebid.server.functional.model.request.auction
 
+import com.fasterxml.jackson.databind.PropertyNamingStrategies
+import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.EqualsAndHashCode
 import groovy.transform.ToString
 import org.prebid.server.functional.util.PBSUtils
 
 @ToString(includeNames = true, ignoreNulls = true)
+@JsonNaming(PropertyNamingStrategies.LowerCaseStrategy)
 @EqualsAndHashCode
 class User {
 
     String id
-    String buyeruid
+    String buyerUid
     Integer yob
     String gender
     String keywords

src/test/groovy/org/prebid/server/functional/model/request/auction/UserExtData.groovy

@@ -1,21 +1,24 @@
 package org.prebid.server.functional.model.request.auction
 
+import com.fasterxml.jackson.databind.PropertyNamingStrategies
+import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.ToString
 import org.prebid.server.functional.util.PBSUtils
 
 @ToString(includeNames = true, ignoreNulls = true)
+@JsonNaming(PropertyNamingStrategies.LowerCaseStrategy)
 class UserExtData {
 
     List<String> keywords
-    String buyeruid
-    List<String> buyeruids
+    String buyerUid
+    List<String> buyerUids
     Geo geo
 
     static UserExtData getFPDUserExtData() {
         new UserExtData().tap {
             keywords = [PBSUtils.randomString]
-            buyeruid = PBSUtils.randomString
-            buyeruids = [PBSUtils.randomString]
+            buyerUid = PBSUtils.randomString
+            buyerUids = [PBSUtils.randomString]
         }
     }
 }

src/test/groovy/org/prebid/server/functional/model/response/auction/AnalyticResult.groovy

@@ -4,19 +4,18 @@ import com.fasterxml.jackson.databind.PropertyNamingStrategies
 import com.fasterxml.jackson.databind.annotation.JsonNaming
 import groovy.transform.EqualsAndHashCode
 import groovy.transform.ToString
-import org.prebid.server.functional.model.request.auction.FetchStatus
 import org.prebid.server.functional.model.request.auction.Imp
 
-import static org.prebid.server.functional.model.request.auction.FetchStatus.SUCCESS
-import static org.prebid.server.functional.model.request.auction.FetchStatus.SUCCESS_BLOCK
+import static org.prebid.server.functional.model.response.auction.AnalyticTagStatus.SUCCESS
+import static org.prebid.server.functional.model.response.auction.AnalyticTagStatus.SUCCESS_BLOCK
 
 @ToString(includeNames = true, ignoreNulls = true)
 @JsonNaming(PropertyNamingStrategies.LowerCaseStrategy)
 @EqualsAndHashCode
 class AnalyticResult {
 
     String name
-    FetchStatus status
+    AnalyticTagStatus status
     List<ImpResult> results
 
     static AnalyticResult buildFromImp(Imp imp) {

src/test/groovy/org/prebid/server/functional/model/response/auction/AnalyticTagStatus.groovy

@@ -0,0 +1,13 @@
+package org.prebid.server.functional.model.response.auction
+
+import com.fasterxml.jackson.annotation.JsonValue
+
+enum AnalyticTagStatus {
+
+    NONE, LOOKUP, CONTROL, SUCCESS, ERROR, SUCCESS_ALLOW, SUCCESS_BLOCK, SKIPPED, RUN
+
+    @JsonValue
+    String getValue() {
+        name().toLowerCase().replace('_', '-')
+    }
+}

src/test/groovy/org/prebid/server/functional/model/response/auction/AnalyticsTagActivity.groovy

@@ -10,6 +10,6 @@ import org.prebid.server.functional.model.request.auction.FetchStatus
 class AnalyticsTagActivity {
 
     ModuleActivityName name
-    FetchStatus status
+    AnalyticTagStatus status
     List<AnalyticsTagActivityResult> results
 }

src/test/groovy/org/prebid/server/functional/model/response/auction/AnalyticsTagActivityResult.groovy

@@ -9,7 +9,7 @@ import org.prebid.server.functional.model.request.auction.FetchStatus
 @JsonNaming(PropertyNamingStrategies.LowerCaseStrategy)
 class AnalyticsTagActivityResult {
 
-    FetchStatus status
+    AnalyticTagStatus status
     AnalyticsTagActivityValue values
     AppliedTo appliedTo
 }

src/test/groovy/org/prebid/server/functional/model/response/auction/ImpResult.groovy

@@ -11,7 +11,7 @@ import org.prebid.server.functional.model.request.auction.FetchStatus
 @EqualsAndHashCode
 class ImpResult {
 
-    FetchStatus status
+    AnalyticTagStatus status
     ModuleValue values
     AppliedTo appliedTo
 }

src/test/groovy/org/prebid/server/functional/model/response/auction/ModuleValue.groovy

@@ -3,7 +3,7 @@ package org.prebid.server.functional.model.response.auction
 import com.fasterxml.jackson.annotation.JsonProperty
 import groovy.transform.EqualsAndHashCode
 import groovy.transform.ToString
-import org.prebid.server.functional.model.ModuleName
+import org.prebid.server.functional.model.config.ModuleName
 import org.prebid.server.functional.model.bidder.BidderName
 
 @ToString(includeNames = true, ignoreNulls = true)

src/test/groovy/org/prebid/server/functional/testcontainers/scaffolding/Bidder.groovy

@@ -66,7 +66,7 @@ class Bidder extends NetworkScaffolding {
         return getLastRecordedRequestHeaders(bidRequestId)
     }
 
-    private String getBodyByRequest(HttpRequest request) {
+    private static String getBodyByRequest(HttpRequest request) {
         def requestString = request.bodyAsString
         def jsonNode = toJsonNode(requestString)
         def id = jsonNode.get("id").asText()

src/test/groovy/org/prebid/server/functional/testcontainers/scaffolding/FloorsProvider.groovy

@@ -37,7 +37,7 @@ class FloorsProvider extends NetworkScaffolding {
                                 : HttpResponse.notFoundResponse()}
     }
 
-    private String getDefaultResponse() {
+    private static String getDefaultResponse() {
         encode(PriceFloorData.priceFloorData)
     }
 }

src/test/groovy/org/prebid/server/functional/testcontainers/scaffolding/PrebidCache.groovy

@@ -115,7 +115,7 @@ class PrebidCache extends NetworkScaffolding {
                 .withBody(jsonPath("\$.puts[?(@.value =~/^.*$payload.*\$/)]"))
     }
 
-    private String getBodyByRequest(HttpRequest request) {
+    private static String getBodyByRequest(HttpRequest request) {
         def requestString = request.bodyAsString
         def jsonNode = toJsonNode(requestString)
         def putsSize = jsonNode.get("puts").size()

src/test/groovy/org/prebid/server/functional/tests/AliasSpec.groovy

@@ -79,8 +79,8 @@ class AliasSpec extends BaseSpec {
     def "PBS should apply compression type for bidder alias when adapters.BIDDER.endpoint-compression = gzip"() {
         given: "PBS with adapter configuration"
         def compressionType = GZIP.value
-        def pbsService = pbsServiceFactory.getService(
-                ["adapters.generic.endpoint-compression": compressionType])
+        def pbsConfig = ["adapters.generic.endpoint-compression": compressionType]
+        def pbsService = pbsServiceFactory.getService(pbsConfig)
 
         and: "Default bid request with alias"
         def bidRequest = BidRequest.defaultBidRequest.tap {
@@ -94,6 +94,9 @@ class AliasSpec extends BaseSpec {
         then: "Bidder request should contain header Content-Encoding = gzip"
         assert response.ext?.debug?.httpcalls?.get(ALIAS.value)?.requestHeaders?.first()
                 ?.get(CONTENT_ENCODING_HEADER)?.first() == compressionType
+
+        cleanup: "Stop and remove pbs container"
+        pbsServiceFactory.removeContainer(pbsConfig)
     }
 
     def "PBS should return an error when GVL Id alias refers to unknown bidder alias"() {