status-im
/
status-cli-tests
mirror of https://github.com/status-im/status-cli-tests.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

alternate who creates nodes

This commit is contained in:
Florin Barbu 2024-06-14 16:27:19 +03:00
parent 37c0d98e49
commit 16b64825e6
No known key found for this signature in database
GPG Key ID: 593D6DBC6D9E5095
2 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/node/status_node.py
View File

@ -93,7 +93,7 @@ class StatusNode:
assert pubkey is not None, f"{self.name}'s public key was not found."
return pubkey
@retry(stop=stop_after_delay(10), wait=wait_fixed(0.1), reraise=True)
@retry(stop=stop_after_delay(20), wait=wait_fixed(0.1), reraise=True)
def wait_fully_started(self):
assert self.search_logs(string="retrieve messages...")

32
tests/test_private_group.py
View File

@ -6,7 +6,7 @@ from src.steps.common import StepsCommon
@pytest.mark.usefixtures("start_2_nodes")
class TestPrivateGroup(StepsCommon):
def test_create_group_chat(self):
def test_create_group_chat_baseline(self):
num_private_groups = NUM_MESSAGES # Set the number of private groups to create
private_groups = []
@ -15,20 +15,32 @@ class TestPrivateGroup(StepsCommon):
for i in range(num_private_groups):
private_group_name = f"private_group_{i}"
timestamp, message_id = self.create_group_chat_with_timestamp(self.second_node, [self.first_node_pubkey], private_group_name)
private_groups.append((timestamp, private_group_name, message_id))
# alernating which node creates the private group
if i % 2 == 0:
node = self.second_node
other_node_pubkey = self.first_node_pubkey
else:
node = self.first_node
other_node_pubkey = self.second_node_pubkey
timestamp, message_id = self.create_group_chat_with_timestamp(node, [other_node_pubkey], private_group_name)
private_groups.append((timestamp, private_group_name, message_id, node.name))
delay(DELAY_BETWEEN_MESSAGES)
delay(10)
missing_private_groups = []
for timestamp, private_group_name, message_id in private_groups:
if not self.first_node.search_logs(f"created the group {private_group_name}"):
missing_private_groups.append((timestamp, private_group_name, message_id))
for timestamp, private_group_name, message_id, node_name in private_groups:
search_node = self.first_node if node_name == self.second_node.name else self.second_node
if not search_node.search_logs(f"created the group {private_group_name}"):
missing_private_groups.append((timestamp, private_group_name, message_id, node_name))
if missing_private_groups:
formatted_missing_requests = [f"Timestamp: {ts}, GroupName: {msg}, ID: {mid}" for ts, msg, mid in missing_private_groups]
formatted_missing_requests = [
f"Timestamp: {ts}, GroupName: {msg}, ID: {mid}, Node: {node}" for ts, msg, mid, node in missing_private_groups
]
raise AssertionError(
f"{len(missing_private_groups)} private groups out of {num_private_groups} were not created: " + "\n".join(formatted_missing_requests)
)
@ -37,14 +49,14 @@ class TestPrivateGroup(StepsCommon):
self.accept_contact_request()
# we want to set latency only on the group creation requests
with self.add_latency():
self.test_create_group_chat()
self.test_create_group_chat_baseline()
def test_create_group_chat_with_packet_loss(self):
self.accept_contact_request()
with self.add_packet_loss():
self.test_create_group_chat()
self.test_create_group_chat_baseline()
def test_create_group_chat_with_low_bandwith(self):
self.accept_contact_request()
with self.add_low_bandwith():
self.test_create_group_chat()
self.test_create_group_chat_baseline()