GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-12 02:29:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: minor changes

Browse Source
This commit is contained in:
Ankit Nayan 2023-01-07 02:21:44 +05:30
parent 1fd819b806
commit 16a49a8b04
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/query-service/app/server.go
View File

@ -315,11 +315,11 @@ func (s *Server) analyticsMiddleware(next http.Handler) http.Handler {
} }
} }
if telemetry.GetInstance().IsSampled() { // if telemetry.GetInstance().IsSampled() {
if _, ok := telemetry.IgnoredPaths()[path]; !ok { if _, ok := telemetry.IgnoredPaths()[path]; !ok {
telemetry.GetInstance().SendEvent(telemetry.TELEMETRY_EVENT_PATH, data) telemetry.GetInstance().SendEvent(telemetry.TELEMETRY_EVENT_PATH, data)
}
} }
// }
}) })
} }

2
pkg/query-service/dao/sqlite/rbac.go
View File

@ -164,6 +164,8 @@ func (mds *ModelDaoSqlite) EditOrg(ctx context.Context, org *model.Organization)
} }
telemetry.GetInstance().SetTelemetryAnonymous(org.IsAnonymous) telemetry.GetInstance().SetTelemetryAnonymous(org.IsAnonymous)
telemetry.GetInstance().SetDistinctId(org.Id)
return nil return nil
} }

2
pkg/query-service/telemetry/telemetry.go
View File

@ -228,10 +228,10 @@ func getOutboundIP() string {
} }
func (a *Telemetry) IdentifyUser(user *model.User) { func (a *Telemetry) IdentifyUser(user *model.User) {
a.SetCompanyDomain(user.Email)
if !a.isTelemetryEnabled() || a.isTelemetryAnonymous() { if !a.isTelemetryEnabled() || a.isTelemetryAnonymous() {
return return
} }
a.SetCompanyDomain(user.Email)
a.operator.Enqueue(analytics.Identify{ a.operator.Enqueue(analytics.Identify{
UserId: a.ipAddress, UserId: a.ipAddress,