From a906f94b8af953f3bfc34bee8a70c77054b63bb4 Mon Sep 17 00:00:00 2001
From: Ankit Nayan <ankit@signoz.io>
Date: Sat, 11 Feb 2023 23:15:07 +0530
Subject: [PATCH] chore: reduce events

---
 .../telemetry/{ignoredPaths.go => ignored.go}     | 15 +++++++++++++++
 pkg/query-service/telemetry/telemetry.go          |  8 +++++++-
 2 files changed, 22 insertions(+), 1 deletion(-)
 rename pkg/query-service/telemetry/{ignoredPaths.go => ignored.go} (50%)

diff --git a/pkg/query-service/telemetry/ignoredPaths.go b/pkg/query-service/telemetry/ignored.go
similarity index 50%
rename from pkg/query-service/telemetry/ignoredPaths.go
rename to pkg/query-service/telemetry/ignored.go
index e564cce2a2..e0faad4461 100644
--- a/pkg/query-service/telemetry/ignoredPaths.go
+++ b/pkg/query-service/telemetry/ignored.go
@@ -11,3 +11,18 @@ func IgnoredPaths() map[string]struct{} {
 
 	return ignoredPaths
 }
+
+func ignoreEvents(event string, attributes map[string]interface{}) bool {
+
+	if event == TELEMETRY_EVENT_ACTIVE_USER || event == TELEMETRY_EVENT_ACTIVE_USER_PH {
+		for attr_key, attr_val := range attributes {
+
+			if attr_key == "any" && attr_val.(int8) == 0 {
+				return true
+			}
+
+		}
+	}
+
+	return false
+}
diff --git a/pkg/query-service/telemetry/telemetry.go b/pkg/query-service/telemetry/telemetry.go
index a2b6031fad..8d1967dbc4 100644
--- a/pkg/query-service/telemetry/telemetry.go
+++ b/pkg/query-service/telemetry/telemetry.go
@@ -46,13 +46,14 @@ const IP_NOT_FOUND_PLACEHOLDER = "NA"
 const DEFAULT_NUMBER_OF_SERVICES = 6
 
 const HEART_BEAT_DURATION = 6 * time.Hour
+
 const ACTIVE_USER_DURATION = 30 * time.Minute
 
 // const HEART_BEAT_DURATION = 30 * time.Second
 // const ACTIVE_USER_DURATION = 30 * time.Second
 
 const RATE_LIMIT_CHECK_DURATION = 1 * time.Minute
-const RATE_LIMIT_VALUE = 2
+const RATE_LIMIT_VALUE = 1
 
 // const RATE_LIMIT_CHECK_DURATION = 20 * time.Second
 // const RATE_LIMIT_VALUE = 5
@@ -301,6 +302,11 @@ func (a *Telemetry) SendEvent(event string, data map[string]interface{}, opts ..
 		return
 	}
 
+	// drop events with properties matching
+	if ignoreEvents(event, data) {
+		return
+	}
+
 	if rateLimitFlag {
 		if a.rateLimits[event] < RATE_LIMIT_VALUE {
 			a.rateLimits[event] += 1