From ab61fb8c2b95b9ca13e8c94d7f873d65115b9af0 Mon Sep 17 00:00:00 2001 From: Elio Bischof Date: Wed, 5 Jul 2023 16:50:44 +0200 Subject: [PATCH] pass reducers --- internal/notification/handlers/telemetry_pusher.go | 2 +- internal/query/projection/milestones.go | 5 +---- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/internal/notification/handlers/telemetry_pusher.go b/internal/notification/handlers/telemetry_pusher.go index b368f2ed6c..8a0de424f1 100644 --- a/internal/notification/handlers/telemetry_pusher.go +++ b/internal/notification/handlers/telemetry_pusher.go @@ -54,7 +54,7 @@ func NewTelemetryPusher( ) *telemetryPusher { p := new(telemetryPusher) handlerCfg.ProjectionName = TelemetryProjectionTable - handlerCfg.Reducers = []handler.AggregateReducer{{}} + handlerCfg.Reducers = p.reducers() p.cfg = telemetryCfg p.StatementHandler = crdb.NewStatementHandler(ctx, handlerCfg) p.commands = commands diff --git a/internal/query/projection/milestones.go b/internal/query/projection/milestones.go index eed288c7ac..dbbf22a603 100644 --- a/internal/query/projection/milestones.go +++ b/internal/query/projection/milestones.go @@ -184,9 +184,6 @@ func (p *milestoneProjection) reduceUserTokenAdded(event eventstore.Event) (*han if err != nil { return nil, err } - if p.isSystemEvent(event) { - return crdb.NewNoOpStatement(event), nil - } statements := []func(eventstore.Event) crdb.Exec{ crdb.AddUpdateStatement( []handler.Column{ @@ -288,7 +285,7 @@ func (p *milestoneProjection) reduceAppConfigAdded(event eventstore.Event, clien } func (p *milestoneProjection) isSystemEvent(event eventstore.Event) bool { - if _, err := strconv.Atoi(event.EditorUser()); err == nil { + if userId, err := strconv.Atoi(event.EditorUser()); err == nil && userId > 0 { return false } lowerEditorService := strings.ToLower(event.EditorService())