From: Oguzhan Ozmen <oozmen@bloomberg.net>
Date: Wed, 28 Aug 2024 19:56:36 +0000 (-0400)
Subject: test/rgw/notifications: also verify bucket notifications are updated correctly
X-Git-Tag: v20.0.0~961^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F59441%2Fhead;p=ceph.git

test/rgw/notifications: also verify bucket notifications are updated correctly

Signed-off-by: Oguzhan Ozmen <oozmen@bloomberg.net>
---

diff --git a/src/test/rgw/bucket_notification/test_bn.py b/src/test/rgw/bucket_notification/test_bn.py
index 203f16a5c31..642ab6955a4 100644
--- a/src/test/rgw/bucket_notification/test_bn.py
+++ b/src/test/rgw/bucket_notification/test_bn.py
@@ -5571,6 +5571,7 @@ def test_topic_migration_to_an_account():
         )
         _, status = s3_notification_conf1.set_config()
         assert_equal(status / 100, 2)
+        # verify subscriptions to the account topic
         rgw_topic_entry = [
             t
             for t in list_topics(tenant=account_id)["topics"]
@@ -5581,6 +5582,11 @@ def test_topic_migration_to_an_account():
         assert_equal(len(subscribed_buckets), 1)
         assert_in(user1_bucket_name, subscribed_buckets)
         assert_not_in(user2_bucket_name, subscribed_buckets)
+        # verify bucket notifications while 2 test buckets are in the mixed mode
+        notification_list = list_notifications(user1_bucket_name, assert_len=1)
+        assert_equal(notification_list["notifications"][0]["TopicArn"], account_topic_arn)
+        notification_list = list_notifications(user2_bucket_name, assert_len=1)
+        assert_equal(notification_list["notifications"][0]["TopicArn"], topic_arn)
 
         # verify both topics are functional at the same time with no duplicate notifications
         user1_bucket.new_key("user1obj1").set_contents_from_string("object content")
@@ -5614,6 +5620,11 @@ def test_topic_migration_to_an_account():
         assert_equal(len(subscribed_buckets), 2)
         assert_in(user1_bucket_name, subscribed_buckets)
         assert_in(user2_bucket_name, subscribed_buckets)
+        # verify bucket notifications after 2 test buckets are updated to use the account topic
+        notification_list = list_notifications(user1_bucket_name, assert_len=1)
+        assert_equal(notification_list["notifications"][0]["TopicArn"], account_topic_arn)
+        notification_list = list_notifications(user2_bucket_name, assert_len=1)
+        assert_equal(notification_list["notifications"][0]["TopicArn"], account_topic_arn)
 
         # finally, make sure that notifications are going thru via the new account topic
         user1_bucket.new_key("user1obj1").set_contents_from_string("object content")