sdk configs (#251)

Author: kat-statsig

evaluator.go

@@ -823,27 +823,6 @@ func removeEmptyStrings(s []string) []string {
 	return r
 }
 
-func getNumericValue(a interface{}) (float64, bool) {
-	if a == nil {
-		return 0, false
-	}
-	aVal := reflect.ValueOf(a)
-	switch reflect.TypeOf(a).Kind() {
-	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
-		return float64(aVal.Int()), true
-	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return float64(aVal.Uint()), true
-	case reflect.Float32, reflect.Float64:
-		return float64(aVal.Float()), true
-	case reflect.String:
-		f, err := strconv.ParseFloat(aVal.String(), 64)
-		if err == nil {
-			return f, true
-		}
-	}
-	return 0, false
-}
-
 func castToString(a interface{}) string {
 	asString, ok := a.(string)
 	if !ok {

global_state.go

@@ -10,6 +10,7 @@ import (
 // Instead, define an accessor below using the Mutex lock
 type GlobalState struct {
 	logger    *OutputLogger
+	sdkConfig *SDKConfigs
 	sessionID string
 	mu        sync.RWMutex
 }
@@ -41,3 +42,15 @@ func InitializeGlobalSessionID() {
 	defer global.mu.Unlock()
 	global.sessionID = uuid.NewString()
 }
+
+func SDKConfig() *SDKConfigs {
+	global.mu.RLock()
+	defer global.mu.RUnlock()
+	return global.sdkConfig
+}
+
+func InitializeGlobalSDKConfig() {
+	global.mu.Lock()
+	defer global.mu.Unlock()
+	global.sdkConfig = &SDKConfigs{}
+}

sdk_configs.go

@@ -0,0 +1,80 @@
+package statsig
+
+import (
+	"strconv"
+	"sync"
+)
+
+type SDKConfigs struct {
+	flags   map[string]bool
+	configs map[string]interface{}
+	mu      sync.RWMutex
+}
+
+func (s *SDKConfigs) SetFlags(newFlags map[string]bool) {
+	s.mu.Lock()
+	s.flags = newFlags
+	s.mu.Unlock()
+}
+
+func (s *SDKConfigs) SetConfigs(newConfigs map[string]interface{}) {
+	s.mu.Lock()
+	s.configs = newConfigs
+	s.mu.Unlock()
+}
+
+func (s *SDKConfigs) On(key string) (bool, bool) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	val, exists := s.flags[key]
+	return val, exists
+}
+
+func (s *SDKConfigs) GetConfigNumValue(config string) (float64, bool) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	value, exists := s.configs[config]
+	if !exists {
+		return 0, false
+	}
+
+	return getNumericValue(value)
+}
+
+func (s *SDKConfigs) GetConfigIntValue(config string) (int, bool) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	value, exists := s.configs[config]
+	if !exists {
+		return 0, false
+	}
+
+	switch v := value.(type) {
+	case int:
+		return v, true
+	case float64:
+		return int(v), true
+	default:
+		return 0, false
+	}
+}
+
+func (s *SDKConfigs) GetConfigStrValue(config string) (string, bool) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	value, exists := s.configs[config]
+	if !exists {
+		return "", false
+	}
+
+	switch v := value.(type) {
+	case string:
+		return v, true
+	case int:
+		return strconv.Itoa(v), true
+	case float64:
+		return strconv.FormatFloat(v, 'f', -1, 64), true
+	default:
+		return "", false
+	}
+}

statsig.go

@@ -110,6 +110,7 @@ func Initialize(sdkKey string) InitializeDetails {
 func InitializeWithOptions(sdkKey string, options *Options) InitializeDetails {
 	InitializeGlobalOutputLogger(options.OutputLoggerOptions)
 	InitializeGlobalSessionID()
+	InitializeGlobalSDKConfig()
 	if IsInitialized() {
 		Logger().Log("Statsig is already initialized.", nil)
 		return InitializeDetails{Success: true, Source: instance.evaluator.store.source}

store.go

@@ -82,6 +82,7 @@ type downloadConfigSpecResponse struct {
 	HashedSDKKeysToEntities map[string]configEntities `json:"hashed_sdk_keys_to_entities,omitempty"`
 	HashedSDKKeyUsed        string                    `json:"hashed_sdk_key_used,omitempty"`
 	SDKFlags                map[string]bool           `json:"sdk_flags,omitempty"`
+	SDKConfigs              map[string]interface{}    `json:"sdk_configs,omitempty"`
 }
 
 type configEntities struct {
@@ -468,6 +469,8 @@ func (s *store) setConfigSpecs(specs downloadConfigSpecResponse) (bool, bool) {
 			}
 		}
 
+		SDKConfig().SetConfigs(specs.SDKConfigs)
+		SDKConfig().SetFlags(specs.SDKFlags)
 		s.mu.Lock()
 		s.featureGates = newGates
 		s.dynamicConfigs = newConfigs

util.go

@@ -6,6 +6,7 @@ import (
 	"encoding/binary"
 	"encoding/json"
 	"errors"
+	"reflect"
 	"strconv"
 	"testing"
 	"time"
@@ -126,3 +127,24 @@ func hashName(hashAlgorithm string, name string) string {
 		return name
 	}
 }
+
+func getNumericValue(a interface{}) (float64, bool) {
+	if a == nil {
+		return 0, false
+	}
+	aVal := reflect.ValueOf(a)
+	switch reflect.TypeOf(a).Kind() {
+	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
+		return float64(aVal.Int()), true
+	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return float64(aVal.Uint()), true
+	case reflect.Float32, reflect.Float64:
+		return float64(aVal.Float()), true
+	case reflect.String:
+		f, err := strconv.ParseFloat(aVal.String(), 64)
+		if err == nil {
+			return f, true
+		}
+	}
+	return 0, false
+}