client.go

package statsig

import (
	"errors"
	"net/http"
	"strings"
	"time"
)

// An instance of a StatsigClient for interfacing with Statsig Feature Gates, Dynamic Configs, Experiments, and Event Logging
type Client struct {
	sdkKey        string
	evaluator     *evaluator
	logger        *logger
	transport     *transport
	errorBoundary *errorBoundary
	options       *Options
	diagnostics   *diagnostics
}

// Initializes a Statsig Client with the given sdkKey
func NewClient(sdkKey string) *Client {
	return NewClientWithOptions(sdkKey, &Options{})
}

// Initializes a Statsig Client with the given sdkKey and options
func NewClientWithOptions(sdkKey string, options *Options) *Client {
	client, _ := newClientImpl(sdkKey, options)
	return client
}

// Initializes a Statsig Client with the given sdkKey and options
// returning the initialized client and details of initialization
func NewClientWithDetails(sdkKey string, options *Options) (*Client, InitializeDetails) {
	client, context := newClientImpl(sdkKey, options)
	return client, InitializeDetails{
		Duration: time.Since(context.Start),
		Success:  context.Success,
		Error:    context.Error,
		Source:   context.Source,
	}
}

func newClientImpl(sdkKey string, options *Options) (*Client, *initContext) {
	context := newInitContext()
	diagnostics := newDiagnostics(options)
	diagnostics.initialize().overall().start().mark()
	errorBoundary := newErrorBoundary(sdkKey, options, diagnostics)
	if !options.LocalMode && !strings.HasPrefix(sdkKey, "secret") {
		err := errors.New(InvalidSDKKeyError)
		panic(err)
	}
	sdkConfigs := newSDKConfigs()
	transport := newTransport(sdkKey, options)
	logger := newLogger(transport, options, diagnostics, errorBoundary, sdkConfigs)
	evaluator := newEvaluator(transport, errorBoundary, options, diagnostics, sdkKey, sdkConfigs)

	client := &Client{
		sdkKey:        sdkKey,
		evaluator:     evaluator,
		logger:        logger,
		transport:     transport,
		errorBoundary: errorBoundary,
		options:       options,
		diagnostics:   diagnostics,
	}

	if options.InitTimeout > 0 {
		channel := make(chan *Client, 1)
		go func() {
			client.init(context)
			channel <- client
		}()

		select {
		case res := <-channel:
			diagnostics.initialize().overall().end().success(true).mark()
			return res, context
		case <-time.After(options.InitTimeout):
			Logger().LogStep(StatsigProcessInitialize, "Timed out")
			diagnostics.initialize().overall().end().success(false).reason("timeout").mark()
			client.initInBackground()
			ctx := context.copy() // Goroutines are not terminated upon timeout. Clone context to avoid race condition on setting Error
			ctx.setError(errors.New("timed out"))
			return client, ctx
		}
	} else {
		client.init(context)
	}

	diagnostics.initialize().overall().end().success(true).mark()
	return client, context
}

func (c *Client) init(context *initContext) {
	c.evaluator.initialize(context)
	c.evaluator.store.mu.RLock()
	defer c.evaluator.store.mu.RUnlock()
	c.logger.samplingKeySet.StartResetThread()
	context.setSuccess(c.evaluator.store.source != SourceUninitialized)
	context.setSource(c.evaluator.store.source)
}

func (c *Client) initInBackground() {
	c.evaluator.store.startPolling()
	c.logger.samplingKeySet.StartResetThread()
}

// Checks the value of a Feature Gate for the given user
func (c *Client) CheckGate(user User, gate string) bool {
	return c.errorBoundary.captureCheckGate(func(context *evalContext) FeatureGate {
		return c.checkGateImpl(user, gate, context)
	}, &evalContext{Caller: "checkGate", ConfigName: gate}).Value
}

// Checks the value of a Feature Gate for the given user without logging an exposure event
func (c *Client) CheckGateWithExposureLoggingDisabled(user User, gate string) bool {
	return c.errorBoundary.captureCheckGate(func(context *evalContext) FeatureGate {
		return c.checkGateImpl(user, gate, context)
	}, &evalContext{Caller: "checkGateWithExposureLoggingDisabled", ConfigName: gate, DisableLogExposures: true}).Value
}

// Get the Feature Gate for the given user
func (c *Client) GetGate(user User, gate string) FeatureGate {
	return c.errorBoundary.captureCheckGate(func(context *evalContext) FeatureGate {
		return c.checkGateImpl(user, gate, context)
	}, &evalContext{Caller: "getGate", ConfigName: gate})
}

// Checks the value of a Feature Gate for the given user without logging an exposure event
func (c *Client) GetGateWithExposureLoggingDisabled(user User, gate string) FeatureGate {
	return c.errorBoundary.captureCheckGate(func(context *evalContext) FeatureGate {
		return c.checkGateImpl(user, gate, context)
	}, &evalContext{Caller: "getGateWithExposureLoggingDisabled", ConfigName: gate, DisableLogExposures: true})
}

// Logs an exposure event for the dynamic config
func (c *Client) ManuallyLogGateExposure(user User, gate string) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		if !c.verifyUser(user) {
			return
		}
		user = normalizeUser(user, *c.options)
		res := c.evaluator.evalGate(user, gate, context)
		c.logger.logGateExposure(user, gate, res, context)
	}, &evalContext{Caller: "logGateExposure", ConfigName: gate, IsManualExposure: true})
}

// Gets the DynamicConfig value for the given user
func (c *Client) GetConfig(user User, config string) DynamicConfig {
	return c.errorBoundary.captureGetConfig(func(context *evalContext) DynamicConfig {
		return c.getConfigImpl(user, config, context)
	}, &evalContext{Caller: "getConfig", ConfigName: config})
}

// Gets the DynamicConfig value for the given user without logging an exposure event
func (c *Client) GetConfigWithExposureLoggingDisabled(user User, config string) DynamicConfig {
	return c.errorBoundary.captureGetConfig(func(context *evalContext) DynamicConfig {
		return c.getConfigImpl(user, config, context)
	}, &evalContext{Caller: "getConfigWithExposureLoggingDisabled", ConfigName: config, DisableLogExposures: true})
}

// Logs an exposure event for the config
func (c *Client) ManuallyLogConfigExposure(user User, config string) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		if !c.verifyUser(user) {
			return
		}
		user = normalizeUser(user, *c.options)
		res := c.evaluator.evalConfig(user, config, context)
		c.logger.logConfigExposure(user, config, res, context)
	}, &evalContext{Caller: "logConfigExposure", ConfigName: config, IsManualExposure: true})
}

// Gets the layer name of an Experiment
func (c *Client) GetExperimentLayer(experiment string) (string, bool) {
	return c.errorBoundary.captureGetExperimentLayer(func(context *evalContext) (string, bool) {
		return c.evaluator.store.getExperimentLayer(experiment)
	}, &evalContext{Caller: "getExperimentLayer", ConfigName: experiment})
}

// Gets the DynamicConfig value of an Experiment for the given user
func (c *Client) GetExperiment(user User, experiment string) DynamicConfig {
	return c.errorBoundary.captureGetConfig(func(context *evalContext) DynamicConfig {
		return c.getConfigImpl(user, experiment, context)
	}, &evalContext{Caller: "getExperiment", ConfigName: experiment, IsExperiment: true})
}

// Gets the DynamicConfig value of an Experiment for the given user without logging an exposure event
func (c *Client) GetExperimentWithExposureLoggingDisabled(user User, experiment string) DynamicConfig {
	return c.errorBoundary.captureGetConfig(func(context *evalContext) DynamicConfig {
		return c.getConfigImpl(user, experiment, context)
	}, &evalContext{Caller: "getExperimentWithExposureLoggingDisabled", ConfigName: experiment, IsExperiment: true, DisableLogExposures: true})
}

// Gets the DynamicConfig value of an Experiment for the given user with configurable options
func (c *Client) GetExperimentWithOptions(user User, experiment string, options *GetExperimentOptions) DynamicConfig {
	return c.errorBoundary.captureGetConfig(func(context *evalContext) DynamicConfig {
		return c.getConfigImpl(user, experiment, context)
	}, &evalContext{
		Caller:              "getExperimentWithOptions",
		ConfigName:          experiment,
		IsExperiment:        true,
		DisableLogExposures: options.DisableLogExposures,
		PersistedValues:     options.PersistedValues,
	})
}

// Logs an exposure event for the experiment
func (c *Client) ManuallyLogExperimentExposure(user User, experiment string) {
	c.ManuallyLogConfigExposure(user, experiment)
}

func (c *Client) GetUserPersistedValues(user User, idType string) UserPersistedValues {
	return c.errorBoundary.captureGetUserPersistedValues(func(context *errorContext) UserPersistedValues {
		persistedValues := c.evaluator.persistentStorageUtils.load(user, idType)
		if persistedValues == nil {
			return make(UserPersistedValues)
		} else {
			return persistedValues
		}
	}, &errorContext{Caller: "GetUserPersistedValues"})
}

// Gets the Layer object for the given user
func (c *Client) GetLayer(user User, layer string) Layer {
	return c.errorBoundary.captureGetLayer(func(context *evalContext) Layer {
		return c.getLayerImpl(user, layer, context)
	}, &evalContext{Caller: "getLayer", ConfigName: layer})
}

// Gets the Layer object for the given user without logging an exposure event
func (c *Client) GetLayerWithExposureLoggingDisabled(user User, layer string) Layer {
	return c.errorBoundary.captureGetLayer(func(context *evalContext) Layer {
		return c.getLayerImpl(user, layer, context)
	}, &evalContext{Caller: "getLayerWithExposureLoggingDisabled", ConfigName: layer, DisableLogExposures: true})
}

// Gets the Layer object for the given user with configurable options
func (c *Client) GetLayerWithOptions(user User, layer string, options *GetLayerOptions) Layer {
	return c.errorBoundary.captureGetLayer(func(context *evalContext) Layer {
		return c.getLayerImpl(user, layer, context)
	}, &evalContext{
		Caller:              "getLayerWithOptions",
		ConfigName:          layer,
		DisableLogExposures: options.DisableLogExposures,
		PersistedValues:     options.PersistedValues,
	})
}

// Logs an exposure event for the parameter in the given layer
func (c *Client) ManuallyLogLayerParameterExposure(user User, layer string, parameter string) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		if !c.verifyUser(user) {
			return
		}
		user = normalizeUser(user, *c.options)
		res := c.evaluator.evalLayer(user, layer, context)
		config := NewLayer(layer, res.JsonValue, res.RuleID, res.IDType, res.GroupName, nil, res.ConfigDelegate)
		c.logger.logLayerExposure(user, *config, parameter, res, context)
	}, &evalContext{Caller: "logLayerParameterExposure", ConfigName: layer, IsManualExposure: true})
}

// Logs an event to Statsig for analysis in the Statsig Console
func (c *Client) LogEvent(event Event) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		event.User = normalizeUser(event.User, *c.options)
		if event.EventName == "" {
			return
		}
		c.logger.logCustom(event)
	}, &evalContext{Caller: "logEvent"})
}

// Override the value of a Feature Gate for all users
func (c *Client) OverrideGate(gate string, val bool) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		c.evaluator.OverrideGate(gate, val)
	}, &evalContext{Caller: "overrideGate", ConfigName: gate})
}

// Override the DynamicConfig value for all users
func (c *Client) OverrideConfig(config string, val map[string]interface{}) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		c.evaluator.OverrideConfig(config, val)
	}, &evalContext{Caller: "overrideConfig", ConfigName: config})
}

// Override the Layer value for all users
func (c *Client) OverrideLayer(layer string, val map[string]interface{}) {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		c.evaluator.OverrideLayer(layer, val)
	}, &evalContext{Caller: "overrideLayer", ConfigName: layer})
}

func (c *Client) LogImmediate(events []Event) (*http.Response, error) {
	if len(events) > 500 {
		err := errors.New(EventBatchSizeError)
		return nil, err
	}
	events_processed := make([]interface{}, 0)
	for _, event := range events {
		event.User = normalizeUser(event.User, *c.options)
		events_processed = append(events_processed, event)
	}
	return c.transport.log_event(events_processed, nil, RequestOptions{})
}

func (c *Client) GetClientInitializeResponse(user User, clientKey string, includeLocalOverrides bool) ClientInitializeResponse {
	options := &GCIROptions{
		IncludeLocalOverrides: includeLocalOverrides,
		ClientKey:             clientKey,
		HashAlgorithm:         "sha256",
	}
	return c.GetClientInitializeResponseImpl(user, options)
}

func (c *Client) GetClientInitializeResponseWithOptions(user User, options *GCIROptions) ClientInitializeResponse {
	return c.GetClientInitializeResponseImpl(user, options)
}

func (c *Client) GetClientInitializeResponseImpl(user User, options *GCIROptions) ClientInitializeResponse {
	return c.errorBoundary.captureGetClientInitializeResponse(func(context *evalContext) ClientInitializeResponse {
		if !c.verifyUser(user) {
			return *new(ClientInitializeResponse)
		}
		user = normalizeUser(user, *c.options)
		response := c.evaluator.getClientInitializeResponse(user, context)
		if response.Time == 0 {
			c.errorBoundary.logExceptionWithContext(
				errors.New("empty response from server"),
				errorContext{evalContext: context},
			)
		}
		return response
	}, &evalContext{
		Caller:                "getClientInitializeResponse",
		IncludeLocalOverrides: options.IncludeLocalOverrides,
		ClientKey:             options.ClientKey,
		TargetAppID:           options.TargetAppID,
		Hash:                  options.HashAlgorithm,
		IncludeConfigType:     options.IncludeConfigType,
		ConfigTypesToInclude:  options.ConfigTypesToInclude,
		UseControlForUsersNotInExperiment: options.UseControlForUsersNotInExperiment,
	})
}

func (c *Client) verifyUser(user User) bool {
	if user.UserID == "" && len(user.CustomIDs) == 0 {
		err := errors.New(EmptyUserError)
		Logger().LogError(err)
		return false
	}
	return true
}

// Cleans up Statsig, persisting any Event Logs and cleanup processes
// Using any method is undefined after Shutdown() has been called
func (c *Client) Shutdown() {
	c.errorBoundary.captureVoid(func(context *evalContext) {
		c.logger.shutdown()
		c.evaluator.shutdown()
	}, &evalContext{Caller: "shutdown"})
}

type GetExperimentOptions struct {
	DisableLogExposures bool
	PersistedValues     UserPersistedValues
}

type GetLayerOptions struct {
	DisableLogExposures bool
	PersistedValues     UserPersistedValues
}

func (c *Client) checkGateImpl(user User, name string, context *evalContext) FeatureGate {
	if !c.verifyUser(user) {
		return *NewGate(name, false, "", "", "", nil)
	}
	user = normalizeUser(user, *c.options)
	res := c.evaluator.evalGate(user, name, context)
	exposure := c.logger.logGateExposure(user, name, res, context)

	if c.options.EvaluationCallbacks.GateEvaluationCallback != nil {
		if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
			c.options.EvaluationCallbacks.GateEvaluationCallback(name, res.Value, exposure)
		} else {
			c.options.EvaluationCallbacks.GateEvaluationCallback(name, res.Value, nil)
		}
	}

	if c.options.EvaluationCallbacks.ExposureCallback != nil {
		if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
			c.options.EvaluationCallbacks.ExposureCallback(name, exposure)
		} else {
			c.options.EvaluationCallbacks.ExposureCallback(name, nil)
		}
	}
	return *NewGate(name, res.Value, res.RuleID, res.GroupName, res.IDType, res.EvaluationDetails)
}

func (c *Client) getConfigImpl(user User, name string, context *evalContext) DynamicConfig {
	if !c.verifyUser(user) {
		return *NewConfig(name, nil, "", "", "", nil)
	}
	user = normalizeUser(user, *c.options)
	res := c.evaluator.evalConfig(user, name, context)
	config := *NewConfig(name, res.JsonValue, res.RuleID, res.IDType, res.GroupName, res.EvaluationDetails)
	exposure := c.logger.logConfigExposure(user, name, res, context)

	if context.IsExperiment && c.options.EvaluationCallbacks.ExperimentEvaluationCallback != nil {
		if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
			c.options.EvaluationCallbacks.ExperimentEvaluationCallback(name, config, exposure)
		} else {
			c.options.EvaluationCallbacks.ExperimentEvaluationCallback(name, config, nil)
		}
	} else if c.options.EvaluationCallbacks.ConfigEvaluationCallback != nil {
		if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
			c.options.EvaluationCallbacks.ConfigEvaluationCallback(name, config, exposure)
		} else {
			c.options.EvaluationCallbacks.ConfigEvaluationCallback(name, config, nil)
		}
	}

	if c.options.EvaluationCallbacks.ExposureCallback != nil {
		if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
			c.options.EvaluationCallbacks.ExposureCallback(name, exposure)
		} else {
			c.options.EvaluationCallbacks.ExposureCallback(name, nil)
		}
	}
	return config
}

func (c *Client) getLayerImpl(user User, name string, context *evalContext) Layer {
	if !c.verifyUser(user) {
		return *NewLayer(name, nil, "", "", "", nil, "")
	}

	user = normalizeUser(user, *c.options)
	res := c.evaluator.evalLayer(user, name, context)

	logFunc := func(layer Layer, parameterName string) {
		exposure := c.logger.logLayerExposure(user, layer, parameterName, res, context)
		if c.options.EvaluationCallbacks.LayerEvaluationCallback != nil {
			if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
				c.options.EvaluationCallbacks.LayerEvaluationCallback(name, parameterName, DynamicConfig{layer.configBase}, exposure)
			} else {
				c.options.EvaluationCallbacks.LayerEvaluationCallback(name, parameterName, DynamicConfig{layer.configBase}, nil)
			}
		}
		if c.options.EvaluationCallbacks.ExposureCallback != nil {
			if c.options.EvaluationCallbacks.IncludeDisabledExposures || !context.DisableLogExposures {
				c.options.EvaluationCallbacks.ExposureCallback(name, exposure)
			} else {
				c.options.EvaluationCallbacks.ExposureCallback(name, nil)
			}
		}
	}

	return *NewLayer(name, res.JsonValue, res.RuleID, res.IDType, res.GroupName, &logFunc, res.ConfigDelegate)
}

func normalizeUser(user User, options Options) User {
	env := make(map[string]string)
	// Copy to avoid data race. We modify the map below.
	for k, v := range options.Environment.Params {
		env[k] = v
	}
	if options.Environment.Tier != "" {
		env["tier"] = options.Environment.Tier
	}
	for k, v := range user.StatsigEnvironment {
		env[k] = v
	}
	user.StatsigEnvironment = env
	return user
}