From fa87a2c1f748521abf549a22136e35e13d677a50 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C4=B0smail?= Date: Wed, 13 Nov 2024 15:57:04 +0300 Subject: [PATCH] Revert "Update event.go" --- management/server/event.go | 37 +++++++++++++++---------------------- 1 file changed, 15 insertions(+), 22 deletions(-) diff --git a/management/server/event.go b/management/server/event.go index b455cf785..93b809226 100644 --- a/management/server/event.go +++ b/management/server/event.go @@ -3,7 +3,6 @@ package server import ( "context" "fmt" - "os" "time" log "github.com/sirupsen/logrus" @@ -12,11 +11,6 @@ import ( "github.com/netbirdio/netbird/management/server/status" ) -func isEnabled() bool { - response := os.Getenv("NB_EVENT_ACTIVITY_LOG_ENABLED") - return response == "" || response == "true" -} - // GetEvents returns a list of activity events of an account func (am *DefaultAccountManager) GetEvents(ctx context.Context, accountID, userID string) ([]*activity.Event, error) { unlock := am.Store.AcquireWriteLockByUID(ctx, accountID) @@ -63,20 +57,19 @@ func (am *DefaultAccountManager) GetEvents(ctx context.Context, accountID, userI func (am *DefaultAccountManager) StoreEvent(ctx context.Context, initiatorID, targetID, accountID string, activityID activity.ActivityDescriber, meta map[string]any) { - if isEnabled() { - go func() { - _, err := am.eventStore.Save(ctx, &activity.Event{ - Timestamp: time.Now().UTC(), - Activity: activityID, - InitiatorID: initiatorID, - TargetID: targetID, - AccountID: accountID, - Meta: meta, - }) - if err != nil { - // todo add metric - log.WithContext(ctx).Errorf("received an error while storing an activity event, error: %s", err) - } - }() - } + go func() { + _, err := am.eventStore.Save(ctx, &activity.Event{ + Timestamp: time.Now().UTC(), + Activity: activityID, + InitiatorID: initiatorID, + TargetID: targetID, + AccountID: accountID, + Meta: meta, + }) + if err != nil { + // todo add metric + log.WithContext(ctx).Errorf("received an error while storing an activity event, error: %s", err) + } + }() + }