From 4eab6f7a97b3c0d65a83b4b6d8bb43205e20cb50 Mon Sep 17 00:00:00 2001 From: Tim Hogarty Date: Fri, 14 Feb 2025 16:01:29 -0800 Subject: [PATCH] Add test sweeper for stream subscriptions --- internal/resources/fabric/stream/sweeper.go | 11 +++++++++++ .../resources/fabric/stream_subscription/sweeper.go | 1 - 2 files changed, 11 insertions(+), 1 deletion(-) delete mode 100644 internal/resources/fabric/stream_subscription/sweeper.go diff --git a/internal/resources/fabric/stream/sweeper.go b/internal/resources/fabric/stream/sweeper.go index de2e40de6..96ce71cf3 100644 --- a/internal/resources/fabric/stream/sweeper.go +++ b/internal/resources/fabric/stream/sweeper.go @@ -43,6 +43,17 @@ func testSweepStreams(_ string) error { for _, stream := range streams.GetData() { if sweep.IsSweepableFabricTestResource(stream.GetName()) { + subscriptions, _, err := fabric.StreamSubscriptionsApi.GetStreamSubscriptions(ctx, stream.GetUuid()).Execute() + if err != nil { + errs = append(errs, fmt.Errorf("error getting fabric stream subscriptions on stream %s: %s", stream.GetUuid(), err)) + } + for _, subscription := range subscriptions.GetData() { + log.Printf("[DEBUG] deleting stream subscription: %s", subscription.GetName()) + _, resp, err := fabric.StreamSubscriptionsApi.DeleteStreamSubscriptionByUuid(ctx, stream.GetUuid(), subscription.GetUuid()).Execute() + if equinix_errors.IgnoreHttpResponseErrors(http.StatusForbidden, http.StatusNotFound)(resp, err) != nil { + errs = append(errs, fmt.Errorf("error deleting fabric stream subscription %s on stream %s: %s", subscription.GetUuid(), stream.GetUuid(), err)) + } + } log.Printf("[DEBUG] Deleting stream: %s", stream.GetName()) _, resp, err := fabric.StreamsApi.DeleteStreamByUuid(ctx, stream.GetUuid()).Execute() if equinix_errors.IgnoreHttpResponseErrors(http.StatusForbidden, http.StatusNotFound)(resp, err) != nil { diff --git a/internal/resources/fabric/stream_subscription/sweeper.go b/internal/resources/fabric/stream_subscription/sweeper.go deleted file mode 100644 index f95d4b4ce..000000000 --- a/internal/resources/fabric/stream_subscription/sweeper.go +++ /dev/null @@ -1 +0,0 @@ -package streamsubscription