From c9e2e6bc33ef6f3563478ce5a6e78618b976c877 Mon Sep 17 00:00:00 2001 From: Stefan Benz <46600784+stebenz@users.noreply.github.com> Date: Fri, 7 Oct 2022 10:44:28 +0100 Subject: [PATCH] fix(metadata): corrected handling of remove metadata events (#4505) * fix(metadata): corrected handling of remove metadata events * remove unnecessary method Co-authored-by: Livio Spring --- internal/command/metadata_model.go | 3 +++ internal/command/user_metadata_model.go | 4 ---- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/internal/command/metadata_model.go b/internal/command/metadata_model.go index 7151556cf..94bd89470 100644 --- a/internal/command/metadata_model.go +++ b/internal/command/metadata_model.go @@ -24,6 +24,9 @@ func (wm *MetadataWriteModel) Reduce() error { wm.Value = e.Value wm.State = domain.MetadataStateActive case *metadata.RemovedEvent: + if wm.Key != e.Key { + continue + } wm.State = domain.MetadataStateRemoved case *metadata.RemovedAllEvent: wm.State = domain.MetadataStateRemoved diff --git a/internal/command/user_metadata_model.go b/internal/command/user_metadata_model.go index f99134f00..5e3b1b5e9 100644 --- a/internal/command/user_metadata_model.go +++ b/internal/command/user_metadata_model.go @@ -35,10 +35,6 @@ func (wm *UserMetadataWriteModel) AppendEvents(events ...eventstore.Event) { } } -func (wm *UserMetadataWriteModel) Reduce() error { - return wm.MetadataWriteModel.Reduce() -} - func (wm *UserMetadataWriteModel) Query() *eventstore.SearchQueryBuilder { return eventstore.NewSearchQueryBuilder(eventstore.ColumnsEvent). ResourceOwner(wm.ResourceOwner).