GRPC Websocket retry more aggresively (#362)

We don't want pod to be outofsync
Test passed

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

@@ -54,7 +54,7 @@ data class StatsigUser private constructor(
     var privateAttributes: Map<String, Any>? = null,
 
     @SerializedName("statsigEnvironment")
-    internal var statsigEnvironment: Map<String, String>? = null
+    internal var statsigEnvironment: Map<String, String>? = null,
 ) {
     constructor(userID: String) : this(userID = userID, null)
 
@@ -73,7 +73,7 @@ data class StatsigUser private constructor(
             locale = this.locale,
             appVersion = this.appVersion,
             custom = this.custom,
-            statsigEnvironment = this.statsigEnvironment
+            statsigEnvironment = this.statsigEnvironment,
             // DO NOT copy privateAttributes to the logging copy!
         )
     }

src/main/kotlin/com/statsig/sdk/network/GRPCWebsocketWorker.kt

@@ -6,8 +6,6 @@ import grpc.generated.statsig_forward_proxy.StatsigForwardProxyOuterClass.Config
 import grpc.generated.statsig_forward_proxy.StatsigForwardProxyOuterClass.ConfigSpecResponse
 import io.grpc.Channel
 import io.grpc.ManagedChannelBuilder
-import io.grpc.Status
-import io.grpc.StatusException
 import io.grpc.stub.StreamObserver
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.BufferOverflow
@@ -21,11 +19,6 @@ private const val INITIAL_RETRY_BACKOFF_MS: Long = 10 * 1000
 private const val RETRY_BACKOFF_MULTIPLIER = 5
 private const val FAILOVER_THRESHOLD = 4
 
-private val badRetryCodes: Set<Status.Code> = setOf(
-    Status.Code.PERMISSION_DENIED,
-    Status.Code.UNAUTHENTICATED,
-)
-
 internal class GRPCWebsocketWorker(
     private val sdkKey: String,
     private val options: StatsigOptions,
@@ -128,7 +121,7 @@ internal class GRPCWebsocketWorker(
     }
 
     private fun processStreamErrorOrClose(throwable: Throwable? = null) {
-        shouldRetry = !(throwable is StatusException && throwable.status.code in badRetryCodes) && remainingRetries > 0
+        shouldRetry = remainingRetries > 0
         if ((retryLimit - remainingRetries) == failoverThreshold) {
             streamingFallback?.startBackup(dcsFlowBacker)
         }