Merge pull request #20 from statsig-io/release_1.6.2

Release 1.6.2

Author: xinlili-statsig

.github/workflows/kong.yml

@@ -2,6 +2,11 @@ name: KONG
 
 on:
   workflow_dispatch:
+    inputs:
+      kong-branch:
+        description: "Kong branch name"
+        type: string
+        required: false
   pull_request:
     branches: [main]
   push:
@@ -19,7 +24,12 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Get KONG
-        run: git clone https://oauth2:[email protected]/statsig-io/kong.git .
+        run: |
+          if [[ ${{ github.event_name }} == "workflow_dispatch" ]]; then
+            git clone -b ${{ inputs.kong-branch }} https://oauth2:[email protected]/statsig-io/kong.git .
+          else
+            git clone https://oauth2:[email protected]/statsig-io/kong.git .
+          fi
 
       - name: Install Deps
         run: npm install

build.gradle.kts

@@ -21,6 +21,7 @@ repositories {
 
 configure<org.jlleitschuh.gradle.ktlint.KtlintExtension> {
     verbose.set(true)
+    disabledRules.set(setOf("no-wildcard-imports"))
 }
 
 dependencies {

gradle.properties

@@ -6,7 +6,7 @@ RELEASE_SIGNING_ENABLED=true
 
 GROUP=com.statsig.serversdk
 POM_ARTIFACT_ID=serversdk
-VERSION_NAME=1.6.1
+VERSION_NAME=1.6.2
 
 POM_NAME=Statsig Server SDK
 POM_DESCRIPTION=A feature gating and a/b testing library for statsig

src/main/kotlin/com/statsig/sdk/ClientInitializeFormatter.kt

@@ -18,11 +18,7 @@ internal data class ClientInitializeResponse(
     fun toMap(): Map<String, Any> {
         val gson = Gson()
         val json = gson.toJson(this)
-        return try {
-            return gson.fromJson(json, object : TypeToken<Map<String, Any>>() {}.type)
-        } catch (e: Exception) {
-            emptyMap()
-        }
+        return gson.fromJson(json, object : TypeToken<Map<String, Any>>() {}.type)
     }
 }
 

src/main/kotlin/com/statsig/sdk/ErrorBoundary.kt

@@ -8,7 +8,7 @@ import java.net.URI
 import java.net.URLEncoder
 import java.nio.charset.StandardCharsets
 
-internal class ErrorBoundary(private val apiKey: String, private val options: StatsigOptions) {
+internal class ErrorBoundary(private val apiKey: String, private val options: StatsigOptions, private val statsigMetadata: StatsigMetadata) {
     internal var uri = URI("https://statsigapi.net/v1/sdk_exception")
     private val seen = HashSet<String>()
     private val maxInfoLength = 3000
@@ -68,7 +68,7 @@ internal class ErrorBoundary(private val apiKey: String, private val options: St
                 "tag": "$tag",
                 "exception": "${ex.javaClass.name}",
                 "info": "$safeInfo",
-                "statsigMetadata": ${StatsigMetadata.asJson()}
+                "statsigMetadata": ${statsigMetadata.asJson()}
             }
             """.trimIndent()
             val req =

src/main/kotlin/com/statsig/sdk/Evaluator.kt

@@ -36,6 +36,7 @@ internal class Evaluator(
     private val statsigScope: CoroutineScope,
     private val errorBoundary: ErrorBoundary,
     private val diagnostics: Diagnostics,
+    private val statsigMetadata: StatsigMetadata,
 ) {
     private var specStore: SpecStore
     private val uaParser: Parser by lazy {
@@ -55,7 +56,7 @@ internal class Evaluator(
 
     init {
         CountryLookup.initialize()
-        specStore = SpecStore(this.network, this.options, StatsigMetadata(), statsigScope, errorBoundary, diagnostics)
+        specStore = SpecStore(this.network, this.options, statsigMetadata, statsigScope, errorBoundary, diagnostics)
         network.setDiagnostics(diagnostics)
 
         statsigScope.launch {

src/main/kotlin/com/statsig/sdk/SpecStore.kt

@@ -263,9 +263,8 @@ internal class SpecStore constructor(
         this.layerConfigs = newLayerConfigs
         this.experimentToLayer = newExperimentToLayer
         this.lastUpdateTime = downloadedConfig.time
-        if (downloadedConfig.sdkKeysToAppIDs != null) {
-            this.sdkKeysToAppIDs = downloadedConfig.sdkKeysToAppIDs
-        }
+        this.sdkKeysToAppIDs = downloadedConfig.sdkKeysToAppIDs ?: mapOf()
+
         if (downloadedConfig.diagnostics != null) {
             diagnostics.setSamplingRate(downloadedConfig.diagnostics)
         }
@@ -329,7 +328,7 @@ internal class SpecStore constructor(
     }
 
     fun getAppIDFromKey(clientSDKKey: String): String? {
-        return this.sdkKeysToAppIDs.get(clientSDKKey)
+        return this.sdkKeysToAppIDs[clientSDKKey]
     }
 
     private suspend fun initializeSpecs() {

src/main/kotlin/com/statsig/sdk/Statsig.kt

@@ -18,14 +18,14 @@ class Statsig {
             serverSecret: String,
             options: StatsigOptions,
         ) {
-            if (!::statsigServer.isInitialized) { // Quick check without synchronization
+            if (!isInitialized()) { // Quick check without synchronization
                 synchronized(this) {
-                    if (!::statsigServer.isInitialized
+                    if (!isInitialized()
                     ) { // Secondary check in case another thread already created the default server
-                        statsigServer = StatsigServer.create(serverSecret, options)
+                        statsigServer = StatsigServer.create()
                     }
                 }
-                statsigServer.initialize()
+                statsigServer.initialize(serverSecret, options)
             }
         }
 
@@ -241,7 +241,7 @@ class Statsig {
         /**
          * Sets a value to be returned for the given dynamic config/experiment instead of the actual evaluated value.
          *
-         * @param configName The name of the dynamic config or experiment to be overriden
+         * @param configName The name of the dynamic config or experiment to be overridden
          * @param configValue The value that will be returned
          */
         @JvmStatic
@@ -359,14 +359,14 @@ class Statsig {
             serverSecret: String,
             options: StatsigOptions = StatsigOptions(),
         ): CompletableFuture<Void?> {
-            if (!::statsigServer.isInitialized) { // Quick check without synchronization
+            if (!isInitialized()) { // Quick check without synchronization
                 synchronized(this) {
-                    if (!::statsigServer.isInitialized
+                    if (!isInitialized()
                     ) { // Secondary check in case another thread already created the default server
-                        statsigServer = StatsigServer.create(serverSecret, options)
+                        statsigServer = StatsigServer.create()
                     }
                 }
-                return statsigServer.initializeAsync()
+                return statsigServer.initializeAsync(serverSecret, options)
             }
             return CompletableFuture.completedFuture(null)
         }
@@ -631,12 +631,17 @@ class Statsig {
             runBlocking { statsigServer.shutdown() }
         }
 
+        @JvmStatic
+        fun isInitialized(): Boolean {
+            return ::statsigServer.isInitialized && statsigServer.initialized
+        }
+
         private fun checkInitialized(): Boolean {
-            if (!::statsigServer.isInitialized) {
+            val initialized = isInitialized()
+            if (!initialized) {
                 println("Call and wait for initialize to complete before calling SDK methods.")
-                return false
             }
-            return true
+            return initialized
         }
     }
 }

src/main/kotlin/com/statsig/sdk/StatsigEvent.kt

@@ -8,7 +8,7 @@ internal data class StatsigEvent(
     @SerializedName("value") val eventValue: Any? = null,
     @SerializedName("metadata") var eventMetadata: Map<String, String>? = null,
     @SerializedName("user") var user: StatsigUser? = null,
-    @SerializedName("statsigMetadata") val statsigMetadata: Map<String, String>? = null,
+    @SerializedName("statsigMetadata") val statsigMetadata: StatsigMetadata? = null,
     @SerializedName("secondaryExposures") val secondaryExposures: ArrayList<Map<String, String>>? = arrayListOf(),
     @SerializedName("time") val time: Long? = Utils.getTimeInMillis(),
 ) {

src/main/kotlin/com/statsig/sdk/StatsigLogger.kt

@@ -33,7 +33,7 @@ internal fun safeAddEvaluationToEvent(evaluationDetails: EvaluationDetails?, met
 internal class StatsigLogger(
     private val coroutineScope: CoroutineScope,
     private val network: StatsigNetwork,
-    private val statsigMetadata: Map<String, String>,
+    private val statsigMetadata: StatsigMetadata,
 ) {
 
     private val executor = Executors.newSingleThreadExecutor()