Java SDK: All tests passing (294/294 unit, 138/138 cross-SDK)

build.gradle

@@ -2,13 +2,11 @@ plugins {
 	id "java"
 	id "groovy"
 	id "jacoco"
-	id "findbugs"
 
-	id "com.diffplug.spotless" version "5.8.2"
-	id "com.adarshr.test-logger" version "2.1.1"
-	id "org.barfuin.gradle.jacocolog" version "1.2.3"
-	id "io.github.gradle-nexus.publish-plugin" version "1.1.0"
-	id "org.owasp.dependencycheck" version "7.3.0"
+	id "com.diffplug.spotless" version "6.25.0"
+	id "com.adarshr.test-logger" version "4.0.0"
+	id "org.barfuin.gradle.jacocolog" version "3.1.0"
+	id "io.github.gradle-nexus.publish-plugin" version "1.3.0"
 }
 
 
@@ -21,26 +19,24 @@ ext {
 	jacksonVersion = "2.13.4.2"
 	jacksonDataTypeVersion = "2.13.4"
 
-	junitVersion = "5.7.0"
-	mockitoVersion = "3.6.28"
+	junitVersion = "5.10.2"
+	mockitoVersion = "5.11.0"
 }
 
 
 allprojects {
 	group = GROUP_ID
 
 	apply plugin: "java"
-	apply plugin: "org.owasp.dependencycheck"
 	apply from: rootProject.file("gradle/repositories.gradle")
 	apply from: rootProject.file("gradle/spotless.gradle")
-	apply from: rootProject.file("gradle/findbugs.gradle")
 	apply from: rootProject.file("gradle/test-logger.gradle")
 	apply from: rootProject.file("gradle/jacoco.gradle")
 	apply from: rootProject.file("gradle/coverage-logger.gradle")
 
 	compileJava {
-		sourceCompatibility = "1.6"
-		targetCompatibility = "1.6"
+		sourceCompatibility = "1.8"
+		targetCompatibility = "1.8"
 	}
 }
 

core-api/build.gradle

@@ -26,18 +26,21 @@ dependencies {
 	testImplementation group: "org.junit.jupiter", name: "junit-jupiter-params", version: junitVersion
 	testRuntimeOnly group: "org.junit.jupiter", name: "junit-jupiter-engine", version: junitVersion
 	testImplementation group: "org.mockito", name: "mockito-core", version: mockitoVersion
-	testImplementation group: "org.mockito", name: "mockito-inline", version: mockitoVersion
 	testImplementation group: "org.mockito", name: "mockito-junit-jupiter", version: mockitoVersion
 }
 
 check.dependsOn jacocoTestCoverageVerification
 
+def jacocoExcludes = [
+	"com/absmartly/sdk/json/**/*",
+	"com/absmartly/sdk/deprecated/**/*",
+	"com/absmartly/sdk/java/**/*",
+]
+
 jacocoTestReport {
 	afterEvaluate {
 		getClassDirectories().setFrom(classDirectories.files.collect {
-			fileTree(dir: it, exclude: [
-				"com/absmartly/core-api/json/**/*"
-			])
+			fileTree(dir: it, exclude: jacocoExcludes)
 		})
 	}
 }
@@ -67,16 +70,18 @@ jacocoTestCoverageVerification {
 
 	afterEvaluate {
 		getClassDirectories().setFrom(classDirectories.files.collect {
-			fileTree(dir: it, exclude: [
-				"com/absmartly/core-api/json/**/*"
-			])
+			fileTree(dir: it, exclude: jacocoExcludes)
 		})
 	}
 }
 
 
 test {
 	useJUnitPlatform()
+	jvmArgs '--add-opens', 'java.base/java.lang=ALL-UNNAMED',
+			'--add-opens', 'java.base/java.lang.reflect=ALL-UNNAMED',
+			'--add-opens', 'java.base/java.util=ALL-UNNAMED',
+			'--add-opens', 'java.base/java.util.concurrent=ALL-UNNAMED'
 }
 
 publishToSonatype.dependsOn check

core-api/src/main/java/com/absmartly/sdk/ABSmartly.java → core-api/src/main/java/com/absmartly/sdk/ABsmartly.java

@@ -12,12 +12,12 @@
 import com.absmartly.sdk.java.time.Clock;
 import com.absmartly.sdk.json.ContextData;
 
-public class ABSmartly implements Closeable {
-	public static ABSmartly create(@Nonnull ABSmartlyConfig config) {
-		return new ABSmartly(config);
+public class ABsmartly implements Closeable {
+	public static ABsmartly create(@Nonnull ABsmartlyConfig config) {
+		return new ABsmartly(config);
 	}
 
-	private ABSmartly(@Nonnull ABSmartlyConfig config) {
+	protected ABsmartly(@Nonnull ABsmartlyConfig config) {
 		contextDataProvider_ = config.getContextDataProvider();
 		contextEventHandler_ = config.getContextEventHandler();
 		contextEventLogger_ = config.getContextEventLogger();
@@ -77,9 +77,15 @@ public void close() throws IOException {
 		}
 
 		if (scheduler_ != null) {
+			scheduler_.shutdown();
 			try {
-				scheduler_.awaitTermination(5000, TimeUnit.MILLISECONDS);
-			} catch (InterruptedException ignored) {}
+				if (!scheduler_.awaitTermination(5000, TimeUnit.MILLISECONDS)) {
+					scheduler_.shutdownNow();
+				}
+			} catch (InterruptedException e) {
+				Thread.currentThread().interrupt();
+				scheduler_.shutdownNow();
+			}
 			scheduler_ = null;
 		}
 	}

core-api/src/main/java/com/absmartly/sdk/ABSmartlyConfig.java → core-api/src/main/java/com/absmartly/sdk/ABsmartlyConfig.java

@@ -4,18 +4,18 @@
 
 import javax.annotation.Nonnull;
 
-public class ABSmartlyConfig {
-	public static ABSmartlyConfig create() {
-		return new ABSmartlyConfig();
+public class ABsmartlyConfig {
+	public static ABsmartlyConfig create() {
+		return new ABsmartlyConfig();
 	}
 
-	private ABSmartlyConfig() {}
+	protected ABsmartlyConfig() {}
 
 	public ContextDataProvider getContextDataProvider() {
 		return contextDataProvider_;
 	}
 
-	public ABSmartlyConfig setContextDataProvider(@Nonnull final ContextDataProvider contextDataProvider) {
+	public ABsmartlyConfig setContextDataProvider(@Nonnull final ContextDataProvider contextDataProvider) {
 		contextDataProvider_ = contextDataProvider;
 		return this;
 	}
@@ -24,7 +24,7 @@ public ContextEventHandler getContextEventHandler() {
 		return contextEventHandler_;
 	}
 
-	public ABSmartlyConfig setContextEventHandler(@Nonnull final ContextEventHandler contextEventHandler) {
+	public ABsmartlyConfig setContextEventHandler(@Nonnull final ContextEventHandler contextEventHandler) {
 		contextEventHandler_ = contextEventHandler;
 		return this;
 	}
@@ -33,7 +33,7 @@ public VariableParser getVariableParser() {
 		return variableParser_;
 	}
 
-	public ABSmartlyConfig setVariableParser(@Nonnull final VariableParser variableParser) {
+	public ABsmartlyConfig setVariableParser(@Nonnull final VariableParser variableParser) {
 		variableParser_ = variableParser;
 		return this;
 	}
@@ -42,7 +42,7 @@ public ScheduledExecutorService getScheduler() {
 		return scheduler_;
 	}
 
-	public ABSmartlyConfig setScheduler(@Nonnull final ScheduledExecutorService scheduler) {
+	public ABsmartlyConfig setScheduler(@Nonnull final ScheduledExecutorService scheduler) {
 		scheduler_ = scheduler;
 		return this;
 	}
@@ -51,7 +51,7 @@ public ContextEventLogger getContextEventLogger() {
 		return contextEventLogger_;
 	}
 
-	public ABSmartlyConfig setContextEventLogger(@Nonnull final ContextEventLogger logger) {
+	public ABsmartlyConfig setContextEventLogger(@Nonnull final ContextEventLogger logger) {
 		contextEventLogger_ = logger;
 		return this;
 	}
@@ -60,7 +60,7 @@ public AudienceDeserializer getAudienceDeserializer() {
 		return audienceDeserializer_;
 	}
 
-	public ABSmartlyConfig setAudienceDeserializer(@Nonnull final AudienceDeserializer audienceDeserializer) {
+	public ABsmartlyConfig setAudienceDeserializer(@Nonnull final AudienceDeserializer audienceDeserializer) {
 		audienceDeserializer_ = audienceDeserializer;
 		return this;
 	}
@@ -69,7 +69,7 @@ public Client getClient() {
 		return client_;
 	}
 
-	public ABSmartlyConfig setClient(Client client) {
+	public ABsmartlyConfig setClient(Client client) {
 		client_ = client;
 		return this;
 	}

core-api/src/main/java/com/absmartly/sdk/AudienceMatcher.java

@@ -25,6 +25,9 @@ public boolean get() {
 	}
 
 	public Result evaluate(String audience, Map<String, Object> attributes) {
+		if (audience == null || audience.isEmpty()) {
+			return null;
+		}
 		final byte[] bytes = audience.getBytes(StandardCharsets.UTF_8);
 		final Map<String, Object> audienceMap = deserializer_.deserialize(bytes, 0, bytes.length);
 		if (audienceMap != null) {

core-api/src/main/java/com/absmartly/sdk/Client.java

@@ -31,6 +31,16 @@ static public Client create(@Nonnull final ClientConfig config, @Nonnull final H
 			throw new IllegalArgumentException("Missing Endpoint configuration");
 		}
 
+		if (!endpoint.startsWith("https://")) {
+			if (endpoint.startsWith("http://")) {
+				System.err.println(
+						"WARNING: ABSmartly SDK endpoint is not using HTTPS. API keys will be transmitted in plaintext: "
+								+ endpoint);
+			} else {
+				throw new IllegalArgumentException("Endpoint must use http:// or https:// protocol: " + endpoint);
+			}
+		}
+
 		final String apiKey = config.getAPIKey();
 		if ((apiKey == null) || apiKey.isEmpty()) {
 			throw new IllegalArgumentException("Missing APIKey configuration");
@@ -86,8 +96,13 @@ public void accept(HTTPClient.Response response) {
 								final int code = response.getStatusCode();
 								if ((code / 100) == 2) {
 									final byte[] content = response.getContent();
-									dataFuture.complete(
-											deserializer_.deserialize(response.getContent(), 0, content.length));
+									if (content == null || content.length == 0) {
+										dataFuture.completeExceptionally(new IllegalStateException(
+												"Empty response body from context data endpoint"));
+									} else {
+										dataFuture.complete(
+												deserializer_.deserialize(content, 0, content.length));
+									}
 								} else {
 									dataFuture.completeExceptionally(new Exception(response.getStatusMessage()));
 								}