From a62e204776aebc6e9cbcbd6e4ded700ca638799c Mon Sep 17 00:00:00 2001 From: aya Date: Sun, 20 Oct 2024 16:26:29 +0300 Subject: [PATCH] adding tests with wrong start & end time --- tests/store/test_time_filter.py | 64 ++++++++++++++++++++++++++++++++- 1 file changed, 63 insertions(+), 1 deletion(-) diff --git a/tests/store/test_time_filter.py b/tests/store/test_time_filter.py index c6539ddd..74384bd5 100644 --- a/tests/store/test_time_filter.py +++ b/tests/store/test_time_filter.py @@ -172,7 +172,7 @@ class TestTimeFilter(StepsStore): assert len(store_response.messages) == 6, "number of messages retrieved doesn't match time filter " - def test_time_filter_negative_timestamp(self): + def test_time_filter_negative_end_time(self): for timestamp in self.ts_pass: message = self.create_message(timestamp=timestamp["value"]) self.publish_message(message=message) @@ -183,3 +183,65 @@ class TestTimeFilter(StepsStore): logger.debug(f"number of messages stored for " f"end time = {end_time} is {len(store_response.messages)}") assert len(store_response.messages) == 0, "number of messages retrieved doesn't match time filter " + + def test_time_filter_zero_end_time(self): + for timestamp in self.ts_pass: + message = self.create_message(timestamp=timestamp["value"]) + self.publish_message(message=message) + end_time = 0 + logger.debug(f"inquering stored messages with end time {end_time}") + for node in self.store_nodes: + store_response = self.get_messages_from_store(node, page_size=20, end_time=end_time, include_data=True) + logger.debug(f"number of messages stored for " f"end time = {end_time} is {len(store_response.messages)}") + assert len(store_response.messages) == 0, "number of messages retrieved doesn't match time filter " + + def test_time_filter_negative_start_time(self): + for timestamp in self.ts_pass: + message = self.create_message(timestamp=timestamp["value"]) + self.publish_message(message=message) + start_time = -10000 + logger.debug(f"inquering stored messages with start time {start_time}") + for node in self.store_nodes: + store_response = self.get_messages_from_store(node, page_size=20, start_time=start_time, include_data=True) + logger.debug(f"number of messages stored for " f"start time = {start_time} is {len(store_response.messages)}") + + assert len(store_response.messages) == 0, "number of messages retrieved doesn't match time filter " + + def test_time_filter_zero_start_time(self): + for timestamp in self.ts_pass: + message = self.create_message(timestamp=timestamp["value"]) + self.publish_message(message=message) + start_time = 0 + logger.debug(f"inquering stored messages with start time {start_time}") + for node in self.store_nodes: + store_response = self.get_messages_from_store(node, page_size=20, start_time=start_time, include_data=True) + logger.debug(f"number of messages stored for " f"start time = {start_time} is {len(store_response.messages)}") + + assert len(store_response.messages) == 0, "number of messages retrieved doesn't match time filter " + + def test_time_filter_zero_start_end_time(self): + for timestamp in self.ts_pass: + message = self.create_message(timestamp=timestamp["value"]) + self.publish_message(message=message) + start_time = 0 + end_time = 0 + logger.debug(f"inquering stored messages with start time {start_time}") + for node in self.store_nodes: + store_response = self.get_messages_from_store(node, page_size=20, start_time=start_time, end_time=end_time, include_data=True) + logger.debug(f"number of messages stored for " f"start time = {start_time} is {len(store_response.messages)}") + + assert len(store_response.messages) == 0, "number of messages retrieved doesn't match time filter " + + def test_time_filter_invalid_start_time(self): + for timestamp in self.ts_pass: + message = self.create_message(timestamp=timestamp["value"]) + self.publish_message(message=message) + start_time = "abc" + logger.debug(f"inquering stored messages with start time {start_time}") + try: + for node in self.store_nodes: + store_response = self.get_messages_from_store(node, page_size=20, start_time=start_time, include_data=True) + raise Exception(f" request for stored messages with invalid start time {start_time} is successful") + except Exception as e: + logger.debug(f"invalid start_time cause error {e}") + assert e.args[0].find("Bad Request for url"), "url with wrong start_time is accepted"