openstack/zaqar
Code Issues Proposed changes

Switch to decorators.idempotent_id

Browse Source 
test.idempotent_id is being kept temporary to migrate
to new lib interface. Now idempotent_id is available as Tempest stable
interface decorators and all plugins tests using the old decorator
should be switched to new interface.

In future, Once all plugins are switched to new decorator Tempest
will remove the test.idempotent_id

Change-Id: I90bc676111c023c8c682765412534eb1fba84db5
Related-Bug: 1616913
This commit is contained in:
ghanshyam 2017-01-27 05:41:01 +00:00
parent cdb3c044da
commit a7dfeaf1a7
5 changed files with 117 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
zaqar/tests/tempest_plugin/tests/v2/test_claims_negative.py
View File

@ -17,6 +17,7 @@ import uuid
from tempest import config from tempest import config
from tempest.lib.common.utils import data_utils from tempest.lib.common.utils import data_utils
from tempest.lib import decorators
from tempest.lib import exceptions as lib_exc from tempest.lib import exceptions as lib_exc
from tempest import test from tempest import test
@ -53,7 +54,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
# Claim Messages # Claim Messages
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('bd524990-7dff-4950-a82b-554ef1d644b6') @decorators.idempotent_id('bd524990-7dff-4950-a82b-554ef1d644b6')
def test_request_claim_message_with_no_request_body(self): def test_request_claim_message_with_no_request_body(self):
# Claim a message with no request body # Claim a message with no request body
body = self.generate_message_body() body = self.generate_message_body()
@ -65,7 +66,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('21de9b01-00a7-406a-a2e7-86ecfea2f21a') @decorators.idempotent_id('21de9b01-00a7-406a-a2e7-86ecfea2f21a')
def test_request_claim_message_with_invalid_character_request_body(self): def test_request_claim_message_with_invalid_character_request_body(self):
# Claim a message with invalid characters as request body # Claim a message with invalid characters as request body
body = self.generate_message_body() body = self.generate_message_body()
@ -77,7 +78,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
claim_body) claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('5149cf66-0273-438c-b9de-f8c4af56f382') @decorators.idempotent_id('5149cf66-0273-438c-b9de-f8c4af56f382')
def test_request_claim_message_with_invalid_request_body(self): def test_request_claim_message_with_invalid_request_body(self):
# Claim a message with invalid request body # Claim a message with invalid request body
body = self.generate_message_body() body = self.generate_message_body()
@ -89,7 +90,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
claim_body) claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('9537b022-659e-4220-a05d-eabc10661772') @decorators.idempotent_id('9537b022-659e-4220-a05d-eabc10661772')
def test_request_claim_message_with_greater_value_for_limit(self): def test_request_claim_message_with_greater_value_for_limit(self):
# Claim messages with a greater limit value # Claim messages with a greater limit value
message_body = self.generate_message_body(repeat=1) message_body = self.generate_message_body(repeat=1)
@ -106,7 +107,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
claim_body, url_params=params) claim_body, url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('b9160f04-31f0-4246-b879-329b806a0d8a') @decorators.idempotent_id('b9160f04-31f0-4246-b879-329b806a0d8a')
def test_request_claim_message_with_lesser_value_for_limit(self): def test_request_claim_message_with_lesser_value_for_limit(self):
# Claim messages with an invalid lesser value # Claim messages with an invalid lesser value
message_body = self.generate_message_body(repeat=1) message_body = self.generate_message_body(repeat=1)
@ -123,7 +124,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
claim_body, url_params=params) claim_body, url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('5dfa2fa4-ca17-46f3-9a28-8e70fbbd7f9e') @decorators.idempotent_id('5dfa2fa4-ca17-46f3-9a28-8e70fbbd7f9e')
def test_request_claim_message_with_negative_value_for_limit(self): def test_request_claim_message_with_negative_value_for_limit(self):
# Claim messages with a negative value of limit # Claim messages with a negative value of limit
message_body = self.generate_message_body(repeat=1) message_body = self.generate_message_body(repeat=1)
@ -141,7 +142,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
claim_body, url_params=params) claim_body, url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('eb8025bb-0f42-42fd-9905-6376bdc74cf4') @decorators.idempotent_id('eb8025bb-0f42-42fd-9905-6376bdc74cf4')
def test_request_claim_message_with_no_TTL_field(self): def test_request_claim_message_with_no_TTL_field(self):
# Claim a message with no TTL field # Claim a message with no TTL field
body = self.generate_message_body() body = self.generate_message_body()
@ -155,7 +156,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6b99cab8-17f0-4ec5-bb6a-9ad490a0eb7a') @decorators.idempotent_id('6b99cab8-17f0-4ec5-bb6a-9ad490a0eb7a')
def test_request_claim_message_with_greater_invalid_TTL_value(self): def test_request_claim_message_with_greater_invalid_TTL_value(self):
# TTL for a claim may not exceed 1209600 seconds, # TTL for a claim may not exceed 1209600 seconds,
# and must be at least 60 seconds long , configurable # and must be at least 60 seconds long , configurable
@ -170,7 +171,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.post_claims, self.queue_name, claim_body) self.client.post_claims, self.queue_name, claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('3d65af6e-b104-40a6-a15c-1cf65358e687') @decorators.idempotent_id('3d65af6e-b104-40a6-a15c-1cf65358e687')
def test_request_claim_message_with_lesser_invalid_TTL_value(self): def test_request_claim_message_with_lesser_invalid_TTL_value(self):
# TTL for a claim may not exceed 1209600 seconds, # TTL for a claim may not exceed 1209600 seconds,
# and must be at least 60 seconds long , configurable # and must be at least 60 seconds long , configurable
@ -185,7 +186,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.post_claims, self.queue_name, claim_body) self.client.post_claims, self.queue_name, claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('86978d35-65be-44bb-aba4-0610728b5399') @decorators.idempotent_id('86978d35-65be-44bb-aba4-0610728b5399')
def test_request_claim_message_with_no_grace_field(self): def test_request_claim_message_with_no_grace_field(self):
# Grace for a claim may not exceed 1209600 seconds, # Grace for a claim may not exceed 1209600 seconds,
# and must be at least 60 seconds long , configurable # and must be at least 60 seconds long , configurable
@ -199,7 +200,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('812d9092-2d59-4dae-b67d-ce00da3f74f9') @decorators.idempotent_id('812d9092-2d59-4dae-b67d-ce00da3f74f9')
def test_request_claim_message_with_invalid_greater_grace_value(self): def test_request_claim_message_with_invalid_greater_grace_value(self):
# Grace for a claim may not exceed 1209600 seconds, # Grace for a claim may not exceed 1209600 seconds,
# and must be at least 60 seconds long , configurable # and must be at least 60 seconds long , configurable
@ -214,7 +215,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.post_claims, self.queue_name, claim_body) self.client.post_claims, self.queue_name, claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('bf10b08c-e254-49e4-a751-a0e128dce618') @decorators.idempotent_id('bf10b08c-e254-49e4-a751-a0e128dce618')
def test_request_claim_message_with_invalid_lesser_grace_value(self): def test_request_claim_message_with_invalid_lesser_grace_value(self):
# Grace for a claim may not exceed 1209600 seconds, # Grace for a claim may not exceed 1209600 seconds,
# and must be at least 60 seconds long , configurable # and must be at least 60 seconds long , configurable
@ -229,7 +230,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.post_claims, self.queue_name, claim_body) self.client.post_claims, self.queue_name, claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('69b0d11a-40f5-4f35-847f-05f92ffadeb3') @decorators.idempotent_id('69b0d11a-40f5-4f35-847f-05f92ffadeb3')
def test_request_claim_message_with_non_JSON_request_body(self): def test_request_claim_message_with_non_JSON_request_body(self):
# Claim a messsage with an invalid JSON # Claim a messsage with an invalid JSON
body = self.generate_message_body() body = self.generate_message_body()
@ -239,7 +240,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.post_claims, self.queue_name, claim_body) self.client.post_claims, self.queue_name, claim_body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('d145ea04-203d-41f9-a893-f6e5716005b6') @decorators.idempotent_id('d145ea04-203d-41f9-a893-f6e5716005b6')
def test_request_claim_message_with_invalid_url_params(self): def test_request_claim_message_with_invalid_url_params(self):
# Post Messages # Post Messages
message_body = self.generate_message_body(repeat=1) message_body = self.generate_message_body(repeat=1)
@ -256,7 +257,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('dbdf17ce-879f-4688-b71c-260cb9e4c4ab') @decorators.idempotent_id('dbdf17ce-879f-4688-b71c-260cb9e4c4ab')
def test_claim_message_with_invalid_token(self): def test_claim_message_with_invalid_token(self):
# Claim a message without a valid token # Claim a message without a valid token
body = self.generate_message_body() body = self.generate_message_body()
@ -277,7 +278,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
# Query Claim # Query Claim
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a1844a12-62d6-435e-906b-6b6ae538834f') @decorators.idempotent_id('a1844a12-62d6-435e-906b-6b6ae538834f')
def test_query_from_a_nonexistent_queue(self): def test_query_from_a_nonexistent_queue(self):
# Query claim a non existent queue # Query claim a non existent queue
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -288,7 +289,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.query_claim, uri) self.client.query_claim, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a2af8e9b-08fb-4079-a77a-28c0390a614a') @decorators.idempotent_id('a2af8e9b-08fb-4079-a77a-28c0390a614a')
def test_query_claim_with_non_existing_claim_id(self): def test_query_claim_with_non_existing_claim_id(self):
# Query claim using a non existing claim id # Query claim using a non existing claim id
non_existent_id = str(uuid.uuid4()) non_existent_id = str(uuid.uuid4())
@ -298,7 +299,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.query_claim, uri) self.client.query_claim, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a58c5214-68b9-47d6-a036-de73e7b2cdad') @decorators.idempotent_id('a58c5214-68b9-47d6-a036-de73e7b2cdad')
def test_query_claim_with_invalid_token(self): def test_query_claim_with_invalid_token(self):
# Query claim with an invalid token # Query claim with an invalid token
resp, body = self._post_and_claim_messages(queue_name=self.queue_name) resp, body = self._post_and_claim_messages(queue_name=self.queue_name)
@ -313,7 +314,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
# Update Claim # Update Claim
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('28915079-8b20-487d-ab01-64218572c543') @decorators.idempotent_id('28915079-8b20-487d-ab01-64218572c543')
def test_update_claim_on_non_existing_queue(self): def test_update_claim_on_non_existing_queue(self):
# Update claim on a non existing queue # Update claim on a non existing queue
resp, body = self._post_and_claim_messages(queue_name=self.queue_name) resp, body = self._post_and_claim_messages(queue_name=self.queue_name)
@ -326,7 +327,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.update_claim, claim_uri, update_rbody) self.client.update_claim, claim_uri, update_rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('732e9ca6-6e4f-4d66-9e78-200c3d6aca88') @decorators.idempotent_id('732e9ca6-6e4f-4d66-9e78-200c3d6aca88')
def test_update_a_non_existing_claim(self): def test_update_a_non_existing_claim(self):
# Update a non existing claim # Update a non existing claim
claim_ttl = data_utils.rand_int_id(start=60, claim_ttl = data_utils.rand_int_id(start=60,
@ -339,7 +340,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.update_claim, claim_uri, update_rbody) self.client.update_claim, claim_uri, update_rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('925514e9-57f0-4209-a64e-8b0a72bb8f0f') @decorators.idempotent_id('925514e9-57f0-4209-a64e-8b0a72bb8f0f')
def test_update_claim_with_no_request_body(self): def test_update_claim_with_no_request_body(self):
# Update claim with no request body # Update claim with no request body
resp, body = self._post_and_claim_messages(self.queue_name) resp, body = self._post_and_claim_messages(self.queue_name)
@ -349,7 +350,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('c17793da-112a-4e90-b2fd-a5acbfdcddc5') @decorators.idempotent_id('c17793da-112a-4e90-b2fd-a5acbfdcddc5')
def test_update_claim_with_invalid_json_in_request_body(self): def test_update_claim_with_invalid_json_in_request_body(self):
# Update claim with an invalid JSON # Update claim with an invalid JSON
resp, body = self._post_and_claim_messages(self.queue_name) resp, body = self._post_and_claim_messages(self.queue_name)
@ -359,7 +360,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.client.update_claim, claim_uri, update_rbody) self.client.update_claim, claim_uri, update_rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('1cd2fed7-6840-49cd-9b7a-1d80c01300fb') @decorators.idempotent_id('1cd2fed7-6840-49cd-9b7a-1d80c01300fb')
def test_update_claim_with_invalid_token(self): def test_update_claim_with_invalid_token(self):
# Update claim without a valid token # Update claim without a valid token
resp, body = self._post_and_claim_messages(self.queue_name) resp, body = self._post_and_claim_messages(self.queue_name)
@ -377,7 +378,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
# Release Claim # Release Claim
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('b61a0d09-bc47-4b33-aa6d-7f20cbbe9bd2') @decorators.idempotent_id('b61a0d09-bc47-4b33-aa6d-7f20cbbe9bd2')
def test_release_claim_from_a_non_existing_queue(self): def test_release_claim_from_a_non_existing_queue(self):
# Release claim from a non existing queue # Release claim from a non existing queue
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -388,7 +389,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('20a6e6ed-0f53-484d-aa78-717cdaa25e50') @decorators.idempotent_id('20a6e6ed-0f53-484d-aa78-717cdaa25e50')
def test_release_a_nonexisting_claim_id(self): def test_release_a_nonexisting_claim_id(self):
# Release a non existing claim # Release a non existing claim
non_existent_id = str(uuid.uuid4()) non_existent_id = str(uuid.uuid4())
@ -398,7 +399,7 @@ class TestClaimsNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('082d50ca-bd3e-4d66-a92b-6ff917ab3b21') @decorators.idempotent_id('082d50ca-bd3e-4d66-a92b-6ff917ab3b21')
def test_release_claim_with_invalid_token(self): def test_release_claim_with_invalid_token(self):
# Release claim without a valid token # Release claim without a valid token
resp, body = self._post_and_claim_messages(queue_name=self.queue_name) resp, body = self._post_and_claim_messages(queue_name=self.queue_name)

89
zaqar/tests/tempest_plugin/tests/v2/test_messages_negative.py
View File

@ -19,6 +19,7 @@ import uuid
from six import moves from six import moves
from tempest import config from tempest import config
from tempest.lib.common.utils import data_utils from tempest.lib.common.utils import data_utils
from tempest.lib import decorators
from tempest.lib import exceptions as lib_exc from tempest.lib import exceptions as lib_exc
from tempest import test from tempest import test
@ -42,7 +43,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
# Get specific Message # Get specific Message
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('8246ee51-651c-4e2a-9a07-91848ca5e1e4') @decorators.idempotent_id('8246ee51-651c-4e2a-9a07-91848ca5e1e4')
def test_request_single_message_from_a_nonexistent_queue(self): def test_request_single_message_from_a_nonexistent_queue(self):
# List a message from a nonexistent queue # List a message from a nonexistent queue
id = str(uuid.uuid4()) id = str(uuid.uuid4())
@ -52,7 +53,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_single_message, uri) self.client.show_single_message, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('767fdad1-37df-485a-8063-5036e8d16a12') @decorators.idempotent_id('767fdad1-37df-485a-8063-5036e8d16a12')
def test_request_a_non_existing_message(self): def test_request_a_non_existing_message(self):
# List a message with an invalid id # List a message with an invalid id
invalid_id = str(uuid.uuid4()) invalid_id = str(uuid.uuid4())
@ -63,7 +64,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_single_message, uri) self.client.show_single_message, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('ac2d1a88-5721-4bef-8dfa-53d936630e84') @decorators.idempotent_id('ac2d1a88-5721-4bef-8dfa-53d936630e84')
def test_request_a_message_with_negative_message_id(self): def test_request_a_message_with_negative_message_id(self):
# List a message with an invalid id, negative # List a message with an invalid id, negative
negative_id = '-1' negative_id = '-1'
@ -75,7 +76,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_single_message, uri) self.client.show_single_message, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('ac083d78-67bb-4515-b553-2fc76499e2bd') @decorators.idempotent_id('ac083d78-67bb-4515-b553-2fc76499e2bd')
def test_request_a_message_without_a_token(self): def test_request_a_message_without_a_token(self):
# List a message without a valid token # List a message without a valid token
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -92,7 +93,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
# Get a Set of Messages by ID # Get a Set of Messages by ID
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('f544e745-f3da-451d-8621-c3711cd37453') @decorators.idempotent_id('f544e745-f3da-451d-8621-c3711cd37453')
def test_request_multiple_messages_from_a_nonexistent_queue(self): def test_request_multiple_messages_from_a_nonexistent_queue(self):
# List multiple messages from a non existent queue # List multiple messages from a non existent queue
id1 = str(uuid.uuid4()) id1 = str(uuid.uuid4())
@ -104,7 +105,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('654e64f8-01df-40a0-a09e-d5ec17a3e187') @decorators.idempotent_id('654e64f8-01df-40a0-a09e-d5ec17a3e187')
def test_request_multiple_messages_with_invalid_message_id(self): def test_request_multiple_messages_with_invalid_message_id(self):
# List multiple messages by passing invalid id # List multiple messages by passing invalid id
invalid_id = str(uuid.uuid4()) invalid_id = str(uuid.uuid4())
@ -117,7 +118,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('295a37a6-5c93-43e3-a316-3f3dffd4b242') @decorators.idempotent_id('295a37a6-5c93-43e3-a316-3f3dffd4b242')
def test_request_multiple_messages_by_exceeding_the_default_limit(self): def test_request_multiple_messages_by_exceeding_the_default_limit(self):
# Default limit value is 20 , configurable # Default limit value is 20 , configurable
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -128,7 +129,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('f96eb4a0-8930-4d5e-b8bf-11080628c761') @decorators.idempotent_id('f96eb4a0-8930-4d5e-b8bf-11080628c761')
def test_request_message_by_passing_invalid_echo_param(self): def test_request_message_by_passing_invalid_echo_param(self):
# Value of the echo parameter must be either true or false # Value of the echo parameter must be either true or false
echo = None echo = None
@ -139,7 +140,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6f668242-6a45-48bc-8ef2-fb581e57d471') @decorators.idempotent_id('6f668242-6a45-48bc-8ef2-fb581e57d471')
def test_request_messages_by_passing_invalid_include_claimed_param(self): def test_request_messages_by_passing_invalid_include_claimed_param(self):
# Value of include_claimed param must be either true or false # Value of include_claimed param must be either true or false
value = None value = None
@ -151,7 +152,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('dd267387-76f6-47bd-849b-b1640051aff4') @decorators.idempotent_id('dd267387-76f6-47bd-849b-b1640051aff4')
def test_request_messages_limit_greater_than_configured_value(self): def test_request_messages_limit_greater_than_configured_value(self):
# Default limit value is 20 , configurable # Default limit value is 20 , configurable
invalid_limit = data_utils.rand_int_id(21, 10000) invalid_limit = data_utils.rand_int_id(21, 10000)
@ -163,7 +164,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('d199f64e-0f22-4129-9bc4-ff709c01592b') @decorators.idempotent_id('d199f64e-0f22-4129-9bc4-ff709c01592b')
def test_request_messages_with_limit_less_than_configured_value(self): def test_request_messages_with_limit_less_than_configured_value(self):
# Default limit value is 20 , configurable # Default limit value is 20 , configurable
invalid_limit = data_utils.rand_int_id(-1000, 0) invalid_limit = data_utils.rand_int_id(-1000, 0)
@ -175,7 +176,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.show_multiple_messages, uri) self.client.show_multiple_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('0b2e803c-7cb9-4c11-bed6-f976f5247b27') @decorators.idempotent_id('0b2e803c-7cb9-4c11-bed6-f976f5247b27')
def test_request_multiple_messages_request_without_a_token(self): def test_request_multiple_messages_request_without_a_token(self):
# List messages without a valid token # List messages without a valid token
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -192,7 +193,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
# Get Messages # Get Messages
@test.idempotent_id('125632c4-c7ce-47fb-93fe-c446d14396f9') @decorators.idempotent_id('125632c4-c7ce-47fb-93fe-c446d14396f9')
def test_list_messages_with_invalid_token(self): def test_list_messages_with_invalid_token(self):
# List messages without a valid token # List messages without a valid token
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -207,7 +208,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
# Post Messages # Post Messages
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('5a0ba3e6-e6ca-4952-be50-fb6be7834ab7') @decorators.idempotent_id('5a0ba3e6-e6ca-4952-be50-fb6be7834ab7')
def test_post_messages_with_no_request_body(self): def test_post_messages_with_no_request_body(self):
# Post message with empty body # Post message with empty body
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -217,7 +218,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('af5ffb4d-c0b4-41db-aea3-bcfc8a232bd6') @decorators.idempotent_id('af5ffb4d-c0b4-41db-aea3-bcfc8a232bd6')
def test_post_messages_with_a_bad_message(self): def test_post_messages_with_a_bad_message(self):
# Post message with invalid message format # Post message with invalid message format
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -227,7 +228,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('10bc153c-97d2-4a19-9795-e0f6993bad4f') @decorators.idempotent_id('10bc153c-97d2-4a19-9795-e0f6993bad4f')
def test_post_messages_to_a_nonexistent_queue(self): def test_post_messages_to_a_nonexistent_queue(self):
# Post message to a non existent queue # Post message to a non existent queue
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -236,7 +237,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('263d6361-4759-4f2c-be9c-12559f064135') @decorators.idempotent_id('263d6361-4759-4f2c-be9c-12559f064135')
def test_post_messages_to_a_non_ascii_queue(self): def test_post_messages_to_a_non_ascii_queue(self):
# Post message to a queue with non ascii queue name # Post message to a queue with non ascii queue name
queue_name = data_utils.rand_name('\u6c49\u5b57\u6f22\u5b57') queue_name = data_utils.rand_name('\u6c49\u5b57\u6f22\u5b57')
@ -245,7 +246,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('04c1b220-1e22-4e38-9db2-a76e8b5e2f3f') @decorators.idempotent_id('04c1b220-1e22-4e38-9db2-a76e8b5e2f3f')
def test_post_messages_to_a_queue_with_invalid_name(self): def test_post_messages_to_a_queue_with_invalid_name(self):
# Post messages to a queue with invalid characters for queue name # Post messages to a queue with invalid characters for queue name
queue_name = '@$@^qw@' queue_name = '@$@^qw@'
@ -254,7 +255,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('72290766-cb01-425e-856b-a57877015336') @decorators.idempotent_id('72290766-cb01-425e-856b-a57877015336')
def test_post_messages_to_a_queue_with_invalid_length_for_queue_name(self): def test_post_messages_to_a_queue_with_invalid_length_for_queue_name(self):
# Post messages to a queue with a long queue name # Post messages to a queue with a long queue name
queue_name = 'q' * 65 queue_name = 'q' * 65
@ -263,7 +264,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('774e8bc8-9b20-40fb-9eed-c5368de368c5') @decorators.idempotent_id('774e8bc8-9b20-40fb-9eed-c5368de368c5')
def test_post_messages_with_invalid_json_request_body(self): def test_post_messages_with_invalid_json_request_body(self):
# Post messages to a queue with non-JSON request body # Post messages to a queue with non-JSON request body
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -273,7 +274,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, body) self.client.post_messages, queue_name, body)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('ebbe257a-9f1e-498a-bba8-f5c71230365a') @decorators.idempotent_id('ebbe257a-9f1e-498a-bba8-f5c71230365a')
def test_post_messages_with_TTL_less_than_60(self): def test_post_messages_with_TTL_less_than_60(self):
# TTL for a message may not exceed 1209600 seconds, # TTL for a message may not exceed 1209600 seconds,
# and must be at least 60 seconds long. # and must be at least 60 seconds long.
@ -293,7 +294,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6d64de03-fd57-4f07-b6f1-8563200a4b4d') @decorators.idempotent_id('6d64de03-fd57-4f07-b6f1-8563200a4b4d')
def test_post_messages_with_TTL_greater_than_1209600(self): def test_post_messages_with_TTL_greater_than_1209600(self):
# TTL for a message may not exceed 1209600 seconds, and # TTL for a message may not exceed 1209600 seconds, and
# must be at least 60 seconds long. # must be at least 60 seconds long.
@ -313,7 +314,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('c48802d7-7e91-4d5f-9c23-32cd4edc41ff') @decorators.idempotent_id('c48802d7-7e91-4d5f-9c23-32cd4edc41ff')
def test_post_messages_with_non_int_value_of_TTL(self): def test_post_messages_with_non_int_value_of_TTL(self):
# TTL for a message may not exceed 1209600 seconds, and # TTL for a message may not exceed 1209600 seconds, and
# must be at least 60 seconds long. # must be at least 60 seconds long.
@ -332,7 +333,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('203fed96-0df3-43c0-9956-723b34b8a23b') @decorators.idempotent_id('203fed96-0df3-43c0-9956-723b34b8a23b')
def test_post_messages_with_negative_value_of_TTL(self): def test_post_messages_with_negative_value_of_TTL(self):
# TTL for a message may not exceed 1209600 seconds, and # TTL for a message may not exceed 1209600 seconds, and
# must be at least 60 seconds long. # must be at least 60 seconds long.
@ -352,7 +353,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('d3ad28e7-0c84-43cf-bb87-1574da28a10d') @decorators.idempotent_id('d3ad28e7-0c84-43cf-bb87-1574da28a10d')
def test_post_messages_without_TTL(self): def test_post_messages_without_TTL(self):
# TTL for a message may not exceed 1209600 seconds, and # TTL for a message may not exceed 1209600 seconds, and
# must be at least 60 seconds long. # must be at least 60 seconds long.
@ -369,7 +370,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('662428d4-302f-4000-8ac6-1a53fb8818b8') @decorators.idempotent_id('662428d4-302f-4000-8ac6-1a53fb8818b8')
def test_post_messages_exceeding_message_post_size(self): def test_post_messages_exceeding_message_post_size(self):
# Post messages with greater message size # Post messages with greater message size
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -387,7 +388,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('ba4f7334-1a4d-4bc8-acd3-040a1310fe62') @decorators.idempotent_id('ba4f7334-1a4d-4bc8-acd3-040a1310fe62')
def test_post_messages_with_invalid_body_size(self): def test_post_messages_with_invalid_body_size(self):
# Maximum number of queue message per page # Maximum number of queue message per page
# while posting messages is 20 # while posting messages is 20
@ -405,7 +406,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('855d36a2-e583-4355-af33-fcec0f71842c') @decorators.idempotent_id('855d36a2-e583-4355-af33-fcec0f71842c')
def test_post_messages_without_body_in_request_body(self): def test_post_messages_without_body_in_request_body(self):
# TTL for a message may not exceed 1209600 seconds, and # TTL for a message may not exceed 1209600 seconds, and
# must be at least 60 seconds long. # must be at least 60 seconds long.
@ -420,7 +421,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.post_messages, queue_name, rbody) self.client.post_messages, queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('074fe312-0077-41ba-8aa9-e6d6a586a685') @decorators.idempotent_id('074fe312-0077-41ba-8aa9-e6d6a586a685')
def test_post_messages_with_invalid_auth_token(self): def test_post_messages_with_invalid_auth_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -436,7 +437,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
# Delete Messages # Delete Messages
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('8552d5b3-7c16-4eaf-a8de-a7b178823458') @decorators.idempotent_id('8552d5b3-7c16-4eaf-a8de-a7b178823458')
def test_delete_message_from_a_nonexistent_queue(self): def test_delete_message_from_a_nonexistent_queue(self):
# Delete is an idempotent operation # Delete is an idempotent operation
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -447,7 +448,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a5d581f0-0403-4c2d-9ea4-048cc6cc85f0') @decorators.idempotent_id('a5d581f0-0403-4c2d-9ea4-048cc6cc85f0')
def test_delete_a_non_existing_message(self): def test_delete_a_non_existing_message(self):
# Delete is an idempotent operation # Delete is an idempotent operation
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -459,7 +460,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('f792f462-0ad9-41b1-9bae-636957364ca0') @decorators.idempotent_id('f792f462-0ad9-41b1-9bae-636957364ca0')
def test_delete_message_with_non_existent_message_id(self): def test_delete_message_with_non_existent_message_id(self):
# Delete is an idempotent operation # Delete is an idempotent operation
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -471,7 +472,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6b8f14b3-2307-49e2-aa53-75d4d4b82754') @decorators.idempotent_id('6b8f14b3-2307-49e2-aa53-75d4d4b82754')
def test_delete_multiple_non_existing_messages(self): def test_delete_multiple_non_existing_messages(self):
# Delete is an idempotent operation # Delete is an idempotent operation
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -485,7 +486,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('805f75fd-6447-4c8a-860c-2659d8a5b0b5') @decorators.idempotent_id('805f75fd-6447-4c8a-860c-2659d8a5b0b5')
def test_delete_message_without_id(self): def test_delete_message_without_id(self):
# Delete all the message from a queue # Delete all the message from a queue
# without passing any id # without passing any id
@ -498,7 +499,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('85eed2fb-fa72-4886-8cfc-44c7fb58ffea') @decorators.idempotent_id('85eed2fb-fa72-4886-8cfc-44c7fb58ffea')
def test_delete_message_with_invalid_message_id(self): def test_delete_message_with_invalid_message_id(self):
# Delete is an idempotent operation # Delete is an idempotent operation
# Delete a message with negative id # Delete a message with negative id
@ -511,7 +512,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('374265e7-1146-4da4-a265-38c8698e4144') @decorators.idempotent_id('374265e7-1146-4da4-a265-38c8698e4144')
def test_delete_the_deleted_message(self): def test_delete_the_deleted_message(self):
# Delete is an idempotent operation # Delete is an idempotent operation
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -525,7 +526,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a130d499-cd41-42dd-b1f0-e859f73b00e0') @decorators.idempotent_id('a130d499-cd41-42dd-b1f0-e859f73b00e0')
def test_delete_multiple_messages_by_exceeding_the_default_limit(self): def test_delete_multiple_messages_by_exceeding_the_default_limit(self):
# Default limit value is 20 # Default limit value is 20
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -536,7 +537,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('51a2f5ca-e358-4ef6-9f33-73d3e01f07b9') @decorators.idempotent_id('51a2f5ca-e358-4ef6-9f33-73d3e01f07b9')
def test_delete_message_without_providing_claim_id(self): def test_delete_message_without_providing_claim_id(self):
# When message is claimed; # When message is claimed;
# it cannot be deleted without a valid claim ID. # it cannot be deleted without a valid claim ID.
@ -562,7 +563,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
uri) uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('18fa5f43-20e6-47bd-a751-ef33e62a4315') @decorators.idempotent_id('18fa5f43-20e6-47bd-a751-ef33e62a4315')
def test_delete_message_with_invalid_claim_id(self): def test_delete_message_with_invalid_claim_id(self):
# Delete with a non existent claim id # Delete with a non existent claim id
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -576,7 +577,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('b82e5dee-5470-4408-9dca-d4a7536ff25f') @decorators.idempotent_id('b82e5dee-5470-4408-9dca-d4a7536ff25f')
def test_delete_message_with_no_pop_value(self): def test_delete_message_with_no_pop_value(self):
# Pop value must be at least 1 and may not be greater than 20 # Pop value must be at least 1 and may not be greater than 20
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -587,7 +588,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6454103d-9cfd-48da-bd8c-061e61a7e634') @decorators.idempotent_id('6454103d-9cfd-48da-bd8c-061e61a7e634')
def test_delete_message_with_invalid_pop_value(self): def test_delete_message_with_invalid_pop_value(self):
# Pop value must be at least 1 and may not be greater than 20 # Pop value must be at least 1 and may not be greater than 20
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -598,7 +599,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('9874b696-352b-47d7-a338-d149d4096c28') @decorators.idempotent_id('9874b696-352b-47d7-a338-d149d4096c28')
def test_delete_message_with_negative_pop_value(self): def test_delete_message_with_negative_pop_value(self):
# Pop value must be at least 1 and may not be greater than 20 # Pop value must be at least 1 and may not be greater than 20
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -609,7 +610,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('4044f38a-0a70-4c86-ab1b-ca369e5b443a') @decorators.idempotent_id('4044f38a-0a70-4c86-ab1b-ca369e5b443a')
def test_delete_message_with_invalid_params_with_pop(self): def test_delete_message_with_invalid_params_with_pop(self):
# Pop & ids parameters are mutually exclusive # Pop & ids parameters are mutually exclusive
# Anyone of which needs to be used with delete # Anyone of which needs to be used with delete
@ -624,7 +625,7 @@ class TestMessagesNegative(base.BaseV2MessagingTest):
self.client.delete_messages, uri) self.client.delete_messages, uri)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('ea609ee5-a7a2-41a0-a9fb-73e8c7ed8c59') @decorators.idempotent_id('ea609ee5-a7a2-41a0-a9fb-73e8c7ed8c59')
def test_delete_messages_with_invalid_auth_token(self): def test_delete_messages_with_invalid_auth_token(self):
# Delete message with an invalid token # Delete message with an invalid token
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,

39
zaqar/tests/tempest_plugin/tests/v2/test_queues_negative.py
View File

@ -15,6 +15,7 @@
from six import moves from six import moves
from tempest.lib.common.utils import data_utils from tempest.lib.common.utils import data_utils
from tempest.lib import decorators
from tempest.lib import exceptions as lib_exc from tempest.lib import exceptions as lib_exc
from tempest import test from tempest import test
@ -35,7 +36,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
# Create Queues # Create Queues
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('77634fd0-0a25-4cc7-a01c-b6d16304f907') @decorators.idempotent_id('77634fd0-0a25-4cc7-a01c-b6d16304f907')
def test_queue_has_a_long_name(self): def test_queue_has_a_long_name(self):
# Length of queue name should >= 1 and <=64 bytes # Length of queue name should >= 1 and <=64 bytes
queue_name = 'q' * 65 queue_name = 'q' * 65
@ -44,7 +45,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
queue_name) queue_name)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('639206ad-d74c-4f51-895d-76e2c7dff60b') @decorators.idempotent_id('639206ad-d74c-4f51-895d-76e2c7dff60b')
def test_queue_name_is_not_specified(self): def test_queue_name_is_not_specified(self):
# Length of queue name should >= 1 and <=64 bytes # Length of queue name should >= 1 and <=64 bytes
queue_name = ' ' queue_name = ' '
@ -53,7 +54,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
queue_name) queue_name)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('3ca0e180-c770-4922-8a48-9563c484aaed') @decorators.idempotent_id('3ca0e180-c770-4922-8a48-9563c484aaed')
def test_queue_name_has_a_invalid_character_set(self): def test_queue_name_has_a_invalid_character_set(self):
# Invalid name with characters # Invalid name with characters
queue_name = '@$@^qw@' queue_name = '@$@^qw@'
@ -62,7 +63,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
queue_name) queue_name)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('533c5a65-fcc9-4e07-84bc-82ac0c007dbc') @decorators.idempotent_id('533c5a65-fcc9-4e07-84bc-82ac0c007dbc')
def test_queue_name_with_non_ASCII_characters(self): def test_queue_name_with_non_ASCII_characters(self):
# Invalid name with non-ASCII characters # Invalid name with non-ASCII characters
queue_name = data_utils.rand_name('\u6c49\u5b57\u6f22\u5b57') queue_name = data_utils.rand_name('\u6c49\u5b57\u6f22\u5b57')
@ -71,7 +72,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
queue_name) queue_name)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('44775212-2b79-40c7-8604-fcf01eddba79') @decorators.idempotent_id('44775212-2b79-40c7-8604-fcf01eddba79')
def test_queue_name_with_numeric_values(self): def test_queue_name_with_numeric_values(self):
# Numeric values for queue name # Numeric values for queue name
queue_name = data_utils.rand_int_id() queue_name = data_utils.rand_int_id()
@ -79,7 +80,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('201', resp['status']) self.assertEqual('201', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('2ce4f4c1-cbaa-4c2d-b28a-f562aec037aa') @decorators.idempotent_id('2ce4f4c1-cbaa-4c2d-b28a-f562aec037aa')
def test_create_queue_with_invalid_auth_token(self): def test_create_queue_with_invalid_auth_token(self):
# Create queue with empty headers # Create queue with empty headers
# X-Auth-Token is not provided # X-Auth-Token is not provided
@ -95,7 +96,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
# List Queues # List Queues
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('d4d33596-0f06-4911-aecc-17512c00a301') @decorators.idempotent_id('d4d33596-0f06-4911-aecc-17512c00a301')
def test_request_a_nonexistent_queue(self): def test_request_a_nonexistent_queue(self):
# List a non-existent queue # List a non-existent queue
nonexistent_queuename = data_utils.rand_name('rand_queuename') nonexistent_queuename = data_utils.rand_name('rand_queuename')
@ -103,7 +104,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('0c8122a8-e28b-4320-8f1f-af97a0bfa26b') @decorators.idempotent_id('0c8122a8-e28b-4320-8f1f-af97a0bfa26b')
def test_request_after_deleting_queue(self): def test_request_after_deleting_queue(self):
# Request queue after deleting the queue # Request queue after deleting the queue
# DELETE is an idempotent operation # DELETE is an idempotent operation
@ -114,7 +115,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('b7c4521a-d0f1-4fc6-b99d-ece2131ac082') @decorators.idempotent_id('b7c4521a-d0f1-4fc6-b99d-ece2131ac082')
def test_request_with_a_greater_limit_value(self): def test_request_with_a_greater_limit_value(self):
# Limit for listing queues is 20 , configurable # Limit for listing queues is 20 , configurable
params = {'limit': '200'} params = {'limit': '200'}
@ -123,7 +124,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
url_params=params) url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('121e5171-e189-4be5-8ccf-d0b2009b3bbe') @decorators.idempotent_id('121e5171-e189-4be5-8ccf-d0b2009b3bbe')
def test_request_with_zero_limit_value(self): def test_request_with_zero_limit_value(self):
# Limit for listing queues is 20 , configurable # Limit for listing queues is 20 , configurable
params = {'limit': '0'} params = {'limit': '0'}
@ -132,7 +133,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
url_params=params) url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('6c710fa6-9447-4c2c-b8c0-7581a56b4ab5') @decorators.idempotent_id('6c710fa6-9447-4c2c-b8c0-7581a56b4ab5')
def test_request_with_negative_limit_value(self): def test_request_with_negative_limit_value(self):
# Limit for listing queues is 20 , configurable # Limit for listing queues is 20 , configurable
params = {'limit': '-1'} params = {'limit': '-1'}
@ -141,7 +142,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
url_params=params) url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('4a54b60c-0a6a-4662-9ba1-fe0b9dd4f399') @decorators.idempotent_id('4a54b60c-0a6a-4662-9ba1-fe0b9dd4f399')
def test_with_non_boolean_value_for_detailed(self): def test_with_non_boolean_value_for_detailed(self):
# Value for detailed parameter should be true or false # Value for detailed parameter should be true or false
params = {'detailed': 'None'} params = {'detailed': 'None'}
@ -149,7 +150,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.client.list_queues, url_params=params) self.client.list_queues, url_params=params)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('f66f1225-bfe8-4fe0-b8c9-35e4342e0f0e') @decorators.idempotent_id('f66f1225-bfe8-4fe0-b8c9-35e4342e0f0e')
def test_list_queues_with_invalid_auth_token(self): def test_list_queues_with_invalid_auth_token(self):
# List queue with empty headers # List queue with empty headers
# X-Auth-Token is not provided # X-Auth-Token is not provided
@ -163,7 +164,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
# Get Queue Stats # Get Queue Stats
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('16cec0df-b58a-44e8-9132-f99f0c1da29a') @decorators.idempotent_id('16cec0df-b58a-44e8-9132-f99f0c1da29a')
def test_request_stats_for_a_non_existing_queue(self): def test_request_stats_for_a_non_existing_queue(self):
# Show stats for a non-existent queue # Show stats for a non-existent queue
nonexistent_queuename = data_utils.rand_name('rand_queuename') nonexistent_queuename = data_utils.rand_name('rand_queuename')
@ -171,7 +172,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('1cad4984-3f66-48f6-82c9-9a544be78ca6') @decorators.idempotent_id('1cad4984-3f66-48f6-82c9-9a544be78ca6')
def test_request_queue_stats_after_deleting_queue(self): def test_request_queue_stats_after_deleting_queue(self):
# List queue stats after deleting the queue # List queue stats after deleting the queue
# DELETE is an idempotent operation # DELETE is an idempotent operation
@ -182,7 +183,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('2b1aeba8-a314-495b-8d45-84692354a013') @decorators.idempotent_id('2b1aeba8-a314-495b-8d45-84692354a013')
def test_request_queue_stats_with_invalid_auth_token(self): def test_request_queue_stats_with_invalid_auth_token(self):
# Get queue stats with empty headers # Get queue stats with empty headers
# X-Auth-Token is not provided # X-Auth-Token is not provided
@ -199,7 +200,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
# Delete Queues # Delete Queues
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('cf7d5cff-0e4f-4d2c-82eb-59f450ca1b7d') @decorators.idempotent_id('cf7d5cff-0e4f-4d2c-82eb-59f450ca1b7d')
def test_delete_a_non_existing_queue(self): def test_delete_a_non_existing_queue(self):
# Delete is an idempotent operation # Delete is an idempotent operation
non_existent_queue = data_utils.rand_name('Queue_name') non_existent_queue = data_utils.rand_name('Queue_name')
@ -207,7 +208,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('c5973d87-5b59-446c-8e81-a8e28de9e61d') @decorators.idempotent_id('c5973d87-5b59-446c-8e81-a8e28de9e61d')
def test_delete_the_deleted_queue(self): def test_delete_the_deleted_queue(self):
# Delete is an idempotent operation # Delete is an idempotent operation
queue_name = self.queues[data_utils.rand_int_id(0, queue_name = self.queues[data_utils.rand_int_id(0,
@ -218,7 +219,7 @@ class QueueNegativeTestJSON(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a54e2715-478a-4701-9080-a06b9364dc74') @decorators.idempotent_id('a54e2715-478a-4701-9080-a06b9364dc74')
def test_delete_queue_with_invalid_auth_token(self): def test_delete_queue_with_invalid_auth_token(self):
# Delete queue with empty headers # Delete queue with empty headers
# X-Auth-Token is not provided # X-Auth-Token is not provided

2
zaqar/tests/tempest_plugin/tests/v2/test_subscriptions.py
View File

@ -94,7 +94,7 @@ class TestSubscriptions(base.BaseV2MessagingTest):
subscription_id = result[1]["subscription_id"] subscription_id = result[1]["subscription_id"]
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.idempotent_id('fe0d8ec1-1a64-4490-8869-e821b2252e74') @decorators.idempotent_id('fe0d8ec1-1a64-4490-8869-e821b2252e74')
def test_create_subscriptions_with_duplicate_subscriber(self): def test_create_subscriptions_with_duplicate_subscriber(self):
# Adding subscriptions to the queue # Adding subscriptions to the queue
results = self._create_subscriptions() results = self._create_subscriptions()

47
zaqar/tests/tempest_plugin/tests/v2/test_subscriptions_negative.py
View File

@ -17,6 +17,7 @@ import uuid
from tempest import config from tempest import config
from tempest.lib.common.utils import data_utils from tempest.lib.common.utils import data_utils
from tempest.lib import decorators
from tempest.lib import exceptions as lib_exc from tempest.lib import exceptions as lib_exc
from tempest import test from tempest import test
@ -44,7 +45,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
return results return results
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('0bda2907-a783-4614-af16-23d7a7d53b72') @decorators.idempotent_id('0bda2907-a783-4614-af16-23d7a7d53b72')
def test_create_subscriptions_with_invalid_body(self): def test_create_subscriptions_with_invalid_body(self):
# Missing subscriber parameter in body # Missing subscriber parameter in body
message_ttl = data_utils.\ message_ttl = data_utils.\
@ -58,7 +59,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('36601d23-77d5-42b1-b234-6789acdda7ba') @decorators.idempotent_id('36601d23-77d5-42b1-b234-6789acdda7ba')
def test_create_subscriptions_with_no_body(self): def test_create_subscriptions_with_no_body(self):
# Missing parameters in body # Missing parameters in body
rbody = {} rbody = {}
@ -66,7 +67,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('1d510d93-635f-4161-b071-91f838d6907e') @decorators.idempotent_id('1d510d93-635f-4161-b071-91f838d6907e')
def test_create_subscriptions_with_invalid_subscriber(self): def test_create_subscriptions_with_invalid_subscriber(self):
# The subscriber type of subscription must be supported in the list # The subscriber type of subscription must be supported in the list
# ['http', 'https', 'mailto'] # ['http', 'https', 'mailto']
@ -83,7 +84,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('65be33a4-a063-47e1-b56b-9d7aa979bbcb') @decorators.idempotent_id('65be33a4-a063-47e1-b56b-9d7aa979bbcb')
def test_create_subscriptions_with_unsupported_subscriber(self): def test_create_subscriptions_with_unsupported_subscriber(self):
# The subscriber type of subscription must be supported in the list # The subscriber type of subscription must be supported in the list
# ['http', 'https', 'mailto'] # ['http', 'https', 'mailto']
@ -100,7 +101,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('cada6c25-0f59-4021-a4c3-961945913998') @decorators.idempotent_id('cada6c25-0f59-4021-a4c3-961945913998')
def test_create_subscriptions_with_invalid_options(self): def test_create_subscriptions_with_invalid_options(self):
# Options must be a dict # Options must be a dict
message_ttl = data_utils.\ message_ttl = data_utils.\
@ -113,7 +114,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('84c1e298-c632-4ccb-859f-afe9a390081c') @decorators.idempotent_id('84c1e298-c632-4ccb-859f-afe9a390081c')
def test_create_subscriptions_with_non_integer_value_for_ttl(self): def test_create_subscriptions_with_non_integer_value_for_ttl(self):
# The subscriber type of subscription must be supported in the list # The subscriber type of subscription must be supported in the list
# ['http', 'https', 'mailto'] # ['http', 'https', 'mailto']
@ -129,7 +130,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.create_subscription, self.queue_name, rbody) self.create_subscription, self.queue_name, rbody)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('1302e137-4db6-48ad-b779-ef2095198bc2') @decorators.idempotent_id('1302e137-4db6-48ad-b779-ef2095198bc2')
def test_create_a_subscription_without_a_token(self): def test_create_a_subscription_without_a_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
message_ttl = data_utils.\ message_ttl = data_utils.\
@ -152,7 +153,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
# List Subscriptions # List Subscriptions
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('e2109835-34ad-4f0a-8bbb-43d475d1315d') @decorators.idempotent_id('e2109835-34ad-4f0a-8bbb-43d475d1315d')
def test_list_subscriptions_from_non_existing_queue(self): def test_list_subscriptions_from_non_existing_queue(self):
# Request for listing subscriptions from a non existent queue # Request for listing subscriptions from a non existent queue
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -160,14 +161,14 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('95d7c77f-4912-49ce-9f38-cfcc6d5cd65b') @decorators.idempotent_id('95d7c77f-4912-49ce-9f38-cfcc6d5cd65b')
def test_list_subscriptions_from_queue_with_no_subsciptions(self): def test_list_subscriptions_from_queue_with_no_subsciptions(self):
# Request to list subscription # Request to list subscription
resp, _ = self.client.list_subscription(self.queue_name) resp, _ = self.client.list_subscription(self.queue_name)
self.assertEqual('200', resp['status']) self.assertEqual('200', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('72f8c0b7-23d8-40ef-ae7c-212cc0751946') @decorators.idempotent_id('72f8c0b7-23d8-40ef-ae7c-212cc0751946')
def test_list_subscription_without_a_token(self): def test_list_subscription_without_a_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
self.client.auth_provider.set_alt_auth_data( self.client.auth_provider.set_alt_auth_data(
@ -180,7 +181,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
# Show Subscriptions # Show Subscriptions
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('7ecc2cb9-a0f4-4d03-b903-ecf2917fda13') @decorators.idempotent_id('7ecc2cb9-a0f4-4d03-b903-ecf2917fda13')
def test_show_subscriptions_from_non_existing_queue(self): def test_show_subscriptions_from_non_existing_queue(self):
# Show subscription details from a non existent queue # Show subscription details from a non existent queue
non_existent_queue = data_utils.rand_name('rand_queuename') non_existent_queue = data_utils.rand_name('rand_queuename')
@ -190,7 +191,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
invalid_id) invalid_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('bb46d838-e9f9-4851-a788-c30bff41c484') @decorators.idempotent_id('bb46d838-e9f9-4851-a788-c30bff41c484')
def test_show_subscriptions_with_invalid_id(self): def test_show_subscriptions_with_invalid_id(self):
# Show subscription details with invaild id # Show subscription details with invaild id
invalid_id = '123' invalid_id = '123'
@ -198,7 +199,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.show_subscription, self.queue_name, invalid_id) self.show_subscription, self.queue_name, invalid_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('1120f006-397a-4e8b-9e79-e2dc96b37d46') @decorators.idempotent_id('1120f006-397a-4e8b-9e79-e2dc96b37d46')
def test_show_subscriptions_after_deleting_subscription(self): def test_show_subscriptions_after_deleting_subscription(self):
# Create subscription # Create subscription
results = self._create_subscriptions() results = self._create_subscriptions()
@ -213,7 +214,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
subscription_id) subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('47a3f29f-6ddb-4cf2-87ed-a2b97733f386') @decorators.idempotent_id('47a3f29f-6ddb-4cf2-87ed-a2b97733f386')
def test_show_subscription_without_a_token(self): def test_show_subscription_without_a_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
results = self._create_subscriptions() results = self._create_subscriptions()
@ -232,7 +233,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
# Update Subscriptions # Update Subscriptions
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('5c93b468-cb84-424f-af35-d4f5febc7c56') @decorators.idempotent_id('5c93b468-cb84-424f-af35-d4f5febc7c56')
def test_update_subscription_on_non_existing_queue(self): def test_update_subscription_on_non_existing_queue(self):
# Update subscription on a non existing queue # Update subscription on a non existing queue
results = self._create_subscriptions() results = self._create_subscriptions()
@ -247,7 +248,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('b383a29a-08f1-418f-8adb-c29ef080358c') @decorators.idempotent_id('b383a29a-08f1-418f-8adb-c29ef080358c')
def test_update_subscription_with_invalid_id(self): def test_update_subscription_with_invalid_id(self):
# Update subscription using invalid id # Update subscription using invalid id
results = self._create_subscriptions() results = self._create_subscriptions()
@ -261,7 +262,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('4e446118-fa90-4f67-9a91-e157fbaa5a4c') @decorators.idempotent_id('4e446118-fa90-4f67-9a91-e157fbaa5a4c')
def test_update_subscription_with_empty_body(self): def test_update_subscription_with_empty_body(self):
# Update subscription with no body # Update subscription with no body
results = self._create_subscriptions() results = self._create_subscriptions()
@ -275,7 +276,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('966f5356-9d0b-46c6-9d57-26bcd9d8e699') @decorators.idempotent_id('966f5356-9d0b-46c6-9d57-26bcd9d8e699')
def test_update_subscription_with_invalid_TTL(self): def test_update_subscription_with_invalid_TTL(self):
# Update subscription using invalid TTL # Update subscription using invalid TTL
results = self._create_subscriptions() results = self._create_subscriptions()
@ -289,7 +290,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('8838f3b2-d4c3-42e2-840c-4314e334a2f0') @decorators.idempotent_id('8838f3b2-d4c3-42e2-840c-4314e334a2f0')
def test_update_subscription_with_invalid_json_in_request_body(self): def test_update_subscription_with_invalid_json_in_request_body(self):
# Update subscription with invalid json # Update subscription with invalid json
results = self._create_subscriptions() results = self._create_subscriptions()
@ -303,7 +304,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('8bfe5638-0126-483e-b88a-2767fa6564e6') @decorators.idempotent_id('8bfe5638-0126-483e-b88a-2767fa6564e6')
def test_update_subscription_with_invalid_token(self): def test_update_subscription_with_invalid_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
results = self._create_subscriptions() results = self._create_subscriptions()
@ -323,7 +324,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
# Delete Subscriptions # Delete Subscriptions
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('bb885255-ccac-47e1-a491-2630f205df58') @decorators.idempotent_id('bb885255-ccac-47e1-a491-2630f205df58')
def test_delete_subscription_from_a_non_existing_queue(self): def test_delete_subscription_from_a_non_existing_queue(self):
# Delete subscription from a non existing queue # Delete subscription from a non existing queue
rbody = {'subscriber': 'http://fake123:8080', rbody = {'subscriber': 'http://fake123:8080',
@ -337,7 +338,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.assertEqual('204', resp['status']) self.assertEqual('204', resp['status'])
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('a7007b4b-1ab1-4121-9d59-afe5eb82d31c') @decorators.idempotent_id('a7007b4b-1ab1-4121-9d59-afe5eb82d31c')
def test_delete_subscription_using_a_nonexisting_id(self): def test_delete_subscription_using_a_nonexisting_id(self):
# Delete subscription with non existent id # Delete subscription with non existent id
results = self._create_subscriptions() results = self._create_subscriptions()
@ -350,7 +351,7 @@ class TestSubscriptionsNegative(base.BaseV2MessagingTest):
self.delete_subscription(self.queue_name, subscription_id) self.delete_subscription(self.queue_name, subscription_id)
@test.attr(type=['negative']) @test.attr(type=['negative'])
@test.idempotent_id('8faf37ee-4abe-4586-9e4b-ed896129a3e8') @decorators.idempotent_id('8faf37ee-4abe-4586-9e4b-ed896129a3e8')
def test_delete_subscription_with_invalid_token(self): def test_delete_subscription_with_invalid_token(self):
# X-Auth-Token is not provided # X-Auth-Token is not provided
results = self._create_subscriptions() results = self._create_subscriptions()