FFM-3677: making posting analytics configurable depending on the boolean passed

Author: akiraqb

client/client.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"log"
 	"net/http"
 	"strings"
 	"sync"
@@ -101,6 +102,7 @@ func NewCfClient(sdkKey string, options ...ConfigOption) (*CfClient, error) {
 }
 
 func (c *CfClient) start() {
+
 	ctx, cancel := context.WithCancel(context.Background())
 	go func() {
 		<-c.stop
@@ -110,6 +112,7 @@ func (c *CfClient) start() {
 	go c.initAuthentication(ctx)
 	go c.setAnalyticsServiceClient(ctx)
 	go c.pullCronJob(ctx)
+	go c.pullCronJob(ctx)
 }
 
 // PostEvaluateProcessor push the data to the analytics service
@@ -389,7 +392,13 @@ func (c *CfClient) retrieveSegments(ctx context.Context) error {
 }
 
 func (c *CfClient) setAnalyticsServiceClient(ctx context.Context) {
+
 	<-c.authenticated
+	if !c.config.enableAnalytics {
+		log.Println(time.Now().Format("2006-01-02 15:04:05") + " Posting analytics data disabled.")
+		return
+	}
+	log.Println(time.Now().Format("2006-01-02 15:04:05") + " Posting analytics data enabled.")
 	c.analyticsService.Start(ctx, &c.metricsapi, c.environmentID)
 }
 

client/config.go

@@ -25,28 +25,30 @@ type config struct {
 	enableStore         bool
 	target              evaluation.Target
 	eventStreamListener stream.EventStreamListener
+	enableAnalytics     bool
 }
 
 func newDefaultConfig() *config {
 	defaultLogger, err := logger.NewZapLogger(false)
 	if err != nil {
 		log.Printf("Error creating zap logger instance, %v", err)
 	}
-	defaultCache, _ := cache.NewLruCache(10000, defaultLogger) // size of cache
+	defaultCache, _ := cache.NewLruCache(10000, defaultLogger) // size of cache∂
 	defaultStore := storage.NewFileStore("defaultProject", storage.GetHarnessDir(), defaultLogger)
 
 	retryClient := retryablehttp.NewClient()
 	retryClient.RetryMax = 10
 
 	return &config{
-		url:          "https://config.ff.harness.io/api/1.0",
-		eventsURL:    "https://events.ff.harness.io/api/1.0",
-		pullInterval: 60,
-		Cache:        defaultCache,
-		Store:        defaultStore,
-		Logger:       defaultLogger,
-		httpClient:   retryClient.StandardClient(),
-		enableStream: true,
-		enableStore:  true,
+		url:             "https://config.ff.harness.io/api/1.0",
+		eventsURL:       "https://events.ff.harness.io/api/1.0",
+		pullInterval:    60,
+		Cache:           defaultCache,
+		Store:           defaultStore,
+		Logger:          defaultLogger,
+		httpClient:      retryClient.StandardClient(),
+		enableStream:    true,
+		enableStore:     true,
+		enableAnalytics: true,
 	}
 }

client/options.go

@@ -14,6 +14,13 @@ import (
 // using options pattern
 type ConfigOption func(config *config)
 
+// WithAnalyticsEnabled en/disable cache and analytics data being sent.
+func WithAnalyticsEnabled(val bool) ConfigOption {
+	return func(config *config) {
+		config.enableAnalytics = val
+	}
+}
+
 // WithURL set baseUrl for communicating with ff server
 func WithURL(url string) ConfigOption {
 	return func(config *config) {