mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-02 14:03:08 +00:00
adding invalid ascending test
This commit is contained in:
parent
684d14c050
commit
8deaaf9f02
@ -13,7 +13,7 @@ class TestSorting(StepsStore):
|
||||
self.publish_message(message=message)
|
||||
expected_message_hash_list.append(self.compute_message_hash(self.test_pubsub_topic, message))
|
||||
for node in self.store_nodes:
|
||||
store_response = self.get_messages_from_store(node, page_size=5, ascending=ascending)
|
||||
store_response = self.get_messages_from_store(node, page_size=5, ascending=True)
|
||||
response_message_hash_list = []
|
||||
for index in range(len(store_response.messages)):
|
||||
response_message_hash_list.append(store_response.message_hash(index))
|
||||
@ -21,3 +21,17 @@ class TestSorting(StepsStore):
|
||||
assert response_message_hash_list == expected_message_hash_list[:5], "Message hash mismatch for acending order"
|
||||
else:
|
||||
assert response_message_hash_list == expected_message_hash_list[5:], "Message hash mismatch for descending order"
|
||||
|
||||
def test_store_invalid_ascending(self):
|
||||
expected_message_hash_list = []
|
||||
ascending = ""
|
||||
for i in range(10):
|
||||
message = self.create_message(payload=to_base64(f"Message_{i}"))
|
||||
self.publish_message(message=message)
|
||||
expected_message_hash_list.append(self.compute_message_hash(self.test_pubsub_topic, message))
|
||||
for node in self.store_nodes:
|
||||
store_response = self.get_messages_from_store(node, page_size=5, ascending=ascending)
|
||||
response_message_hash_list = []
|
||||
for index in range(len(store_response.messages)):
|
||||
response_message_hash_list.append(store_response.message_hash(index))
|
||||
assert response_message_hash_list == expected_message_hash_list[:5], "Message hash mismatch for acending order"
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user