TheArchive/zitadel
1
0
Fork 0
mirror of https://github.com/zitadel/zitadel.git synced 2025-08-14 01:17:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

pass reducers

Browse Source
This commit is contained in:
Elio Bischof
2023-07-05 16:50:44 +02:00
parent 80de44491a
commit ab61fb8c2b
2 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/notification/handlers/telemetry_pusher.go
View File

@@ -54,7 +54,7 @@ func NewTelemetryPusher(
) *telemetryPusher { ) *telemetryPusher {
p := new(telemetryPusher) p := new(telemetryPusher)
handlerCfg.ProjectionName = TelemetryProjectionTable handlerCfg.ProjectionName = TelemetryProjectionTable
handlerCfg.Reducers = []handler.AggregateReducer{{}} handlerCfg.Reducers = p.reducers()
p.cfg = telemetryCfg p.cfg = telemetryCfg
p.StatementHandler = crdb.NewStatementHandler(ctx, handlerCfg) p.StatementHandler = crdb.NewStatementHandler(ctx, handlerCfg)
p.commands = commands p.commands = commands

5
internal/query/projection/milestones.go
View File

@@ -184,9 +184,6 @@ func (p *milestoneProjection) reduceUserTokenAdded(event eventstore.Event) (*han
if err != nil { if err != nil {
return nil, err return nil, err
} }
if p.isSystemEvent(event) {
return crdb.NewNoOpStatement(event), nil
}
statements := []func(eventstore.Event) crdb.Exec{ statements := []func(eventstore.Event) crdb.Exec{
crdb.AddUpdateStatement( crdb.AddUpdateStatement(
[]handler.Column{ []handler.Column{
@@ -288,7 +285,7 @@ func (p *milestoneProjection) reduceAppConfigAdded(event eventstore.Event, clien
} }
func (p *milestoneProjection) isSystemEvent(event eventstore.Event) bool { 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 return false
} }
lowerEditorService := strings.ToLower(event.EditorService()) lowerEditorService := strings.ToLower(event.EditorService())