diff --git a/pkg/query-service/app/server.go b/pkg/query-service/app/server.go index 1d9bdd92c8..d1772f6c36 100644 --- a/pkg/query-service/app/server.go +++ b/pkg/query-service/app/server.go @@ -315,11 +315,11 @@ func (s *Server) analyticsMiddleware(next http.Handler) http.Handler { } } - if telemetry.GetInstance().IsSampled() { - if _, ok := telemetry.IgnoredPaths()[path]; !ok { - telemetry.GetInstance().SendEvent(telemetry.TELEMETRY_EVENT_PATH, data) - } + // if telemetry.GetInstance().IsSampled() { + if _, ok := telemetry.IgnoredPaths()[path]; !ok { + telemetry.GetInstance().SendEvent(telemetry.TELEMETRY_EVENT_PATH, data) } + // } }) } diff --git a/pkg/query-service/dao/sqlite/rbac.go b/pkg/query-service/dao/sqlite/rbac.go index 9bb8a51ebb..11bed020a2 100644 --- a/pkg/query-service/dao/sqlite/rbac.go +++ b/pkg/query-service/dao/sqlite/rbac.go @@ -164,6 +164,8 @@ func (mds *ModelDaoSqlite) EditOrg(ctx context.Context, org *model.Organization) } telemetry.GetInstance().SetTelemetryAnonymous(org.IsAnonymous) + telemetry.GetInstance().SetDistinctId(org.Id) + return nil } diff --git a/pkg/query-service/telemetry/telemetry.go b/pkg/query-service/telemetry/telemetry.go index cef25431d4..8f85591c91 100644 --- a/pkg/query-service/telemetry/telemetry.go +++ b/pkg/query-service/telemetry/telemetry.go @@ -228,10 +228,10 @@ func getOutboundIP() string { } func (a *Telemetry) IdentifyUser(user *model.User) { + a.SetCompanyDomain(user.Email) if !a.isTelemetryEnabled() || a.isTelemetryAnonymous() { return } - a.SetCompanyDomain(user.Email) a.operator.Enqueue(analytics.Identify{ UserId: a.ipAddress,