TS-42917 Ensure partition and clusterId are not null

Author: Zsofia Borbely

agent/src/main/java/com/teamscale/jacoco/agent/testimpact/CoverageToJsonStrategyBase.java

@@ -69,7 +69,7 @@ public void testStart(String uniformPath) {
 		if (availableTests.stream().noneMatch(test -> test.uniformPath.equals(uniformPath))) {
 			// ensure that we can at least generate a report for the tests that were actually run,
 			// even if the caller did not provide a list of tests up-front in testRunStart
-			availableTests.add(new ClusteredTestDetails(uniformPath, uniformPath, null, null, null));
+			availableTests.add(new ClusteredTestDetails(uniformPath, uniformPath, null, null, agentOptions.getTeamscaleServerOptions().partition));
 		}
 	}
 

impacted-test-engine/src/main/kotlin/com/teamscale/test_impacted/engine/ImpactedTestEngine.kt

@@ -2,6 +2,7 @@ package com.teamscale.test_impacted.engine
 
 import com.teamscale.test_impacted.commons.LoggerUtils.createLogger
 import com.teamscale.test_impacted.engine.options.TestEngineOptionUtils
+import jdk.internal.agent.AgentConfigurationError
 import org.junit.platform.engine.*
 import org.junit.platform.engine.support.descriptor.EngineDescriptor
 import java.util.*
@@ -21,6 +22,10 @@ class ImpactedTestEngine : TestEngine {
 		if (!engineOptions.enabled) {
 			return EngineDescriptor(uniqueId, ENGINE_NAME)
 		}
+		if (engineOptions.partition == null) {
+			throw AgentConfigurationError("Agent option partition is undefined, but it's a mandatory parameter when executing impacted tests.")
+		}
+
 		val configuration = engineOptions.testEngineConfiguration
 		val engine = InternalImpactedTestEngine(configuration, engineOptions.partition)
 

impacted-test-engine/src/main/kotlin/com/teamscale/test_impacted/engine/InternalImpactedTestEngine.kt

@@ -25,7 +25,7 @@ import org.junit.platform.engine.support.descriptor.EngineDescriptor
  */
 internal class InternalImpactedTestEngine(
 	configuration: ImpactedTestEngineConfiguration,
-	private val partition: String?
+	private val partition: String
 ) {
 	private val testEngineRegistry = configuration.testEngineRegistry
 	private val testSorter = configuration.testSorter

impacted-test-engine/src/main/kotlin/com/teamscale/test_impacted/test_descriptor/TestDescriptorUtils.kt

@@ -95,7 +95,7 @@ object TestDescriptorUtils {
 	/** Returns the [AvailableTests] contained within the root [TestDescriptor].  */
 	fun getAvailableTests(
 		rootTestDescriptor: TestDescriptor,
-		partition: String?
+		partition: String
 	): AvailableTests {
 		val availableTests = AvailableTests()
 

teamscale-client/src/main/kotlin/com/teamscale/client/ClusteredTestDetails.kt

@@ -33,6 +33,6 @@ class ClusteredTestDetails @JsonCreator constructor(
 	 */
 	@param:JsonProperty(
 		"partition"
-	) var partition: String?
+	) var partition: String
 ) : TestDetails(uniformPath, sourcePath, content)
 

teamscale-client/src/main/kotlin/com/teamscale/client/TestWithClusterId.kt

@@ -18,11 +18,11 @@ class TestWithClusterId @JsonCreator constructor(
 	/**
 	 * The partition of the test.
 	 */
-	@param:JsonProperty("partition") val partition: String?,
+	@param:JsonProperty("partition") val partition: String,
 	/**
 	 * A unique identifier for the cluster this test should be prioritized within. May not be null.
 	 */
-	@param:JsonProperty("clusterId") val clusterId: String?
+	@param:JsonProperty("clusterId") val clusterId: String
 ) {
 	companion object {
 		/**
@@ -31,7 +31,7 @@ class TestWithClusterId @JsonCreator constructor(
 		fun fromClusteredTestDetails(clusteredTestDetails: ClusteredTestDetails) =
 			TestWithClusterId(
 				clusteredTestDetails.uniformPath, clusteredTestDetails.content,
-				clusteredTestDetails.partition, clusteredTestDetails.clusterId
+				clusteredTestDetails.partition, clusteredTestDetails.clusterId ?: clusteredTestDetails.uniformPath
 			)
 	}
 }