From 2c3ee68f08fed7c344b6bce90c0bd1cf10622756 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=B6rn=20Friedrich=20Dreyer?= Date: Wed, 20 Aug 2025 14:15:05 +0200 Subject: [PATCH] ack tag events MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Jörn Friedrich Dreyer --- services/search/pkg/search/events.go | 2 ++ services/search/pkg/search/events_test.go | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/services/search/pkg/search/events.go b/services/search/pkg/search/events.go index 15da2efb0f..b3eca1140c 100644 --- a/services/search/pkg/search/events.go +++ b/services/search/pkg/search/events.go @@ -90,8 +90,10 @@ func HandleEvents(s Searcher, stream raw.Stream, cfg *config.Config, m *metrics. indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), e.Ack) case events.TagsAdded: s.UpsertItem(ev.Ref) + indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), e.Ack) case events.TagsRemoved: s.UpsertItem(ev.Ref) + indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), e.Ack) case events.FileUploaded: indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), e.Ack) case events.UploadReady: diff --git a/services/search/pkg/search/events_test.go b/services/search/pkg/search/events_test.go index 6640785818..3eeb499245 100644 --- a/services/search/pkg/search/events_test.go +++ b/services/search/pkg/search/events_test.go @@ -53,8 +53,8 @@ var _ = DescribeTable("events", Entry("ContainerCreated", []string{"IndexSpace"}, events.ContainerCreated{}, false), Entry("FileTouched", []string{"IndexSpace"}, events.FileTouched{}, false), Entry("FileVersionRestored", []string{"IndexSpace"}, events.FileVersionRestored{}, false), - Entry("TagsAdded", []string{"UpsertItem"}, events.TagsAdded{}, false), - Entry("TagsRemoved", []string{"UpsertItem"}, events.TagsRemoved{}, false), + Entry("TagsAdded", []string{"UpsertItem", "IndexSpace"}, events.TagsAdded{}, false), + Entry("TagsRemoved", []string{"UpsertItem", "IndexSpace"}, events.TagsRemoved{}, false), Entry("FileUploaded", []string{"IndexSpace"}, events.FileUploaded{}, false), Entry("UploadReady", []string{"IndexSpace"}, events.UploadReady{ExecutingUser: &userv1beta1.User{}}, true), )