mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-13 03:13:11 +00:00
69c8e3f4b6
* add go-waku peers via api * add go-waku peers via api * fix add_node_peer * fix add_node_peer * fix add_node_peer * fix add_node_peer * move create_message to commons
37 lines
1.4 KiB
Python
37 lines
1.4 KiB
Python
import inspect
|
|
from time import time
|
|
import allure
|
|
import pytest
|
|
from tenacity import retry, stop_after_delay, wait_fixed
|
|
from src.libs.common import to_base64
|
|
from src.libs.custom_logger import get_custom_logger
|
|
|
|
logger = get_custom_logger(__name__)
|
|
|
|
|
|
class StepsCommon:
|
|
@pytest.fixture(scope="function", autouse=True)
|
|
def common_setup(self):
|
|
logger.debug(f"Running fixture setup: {inspect.currentframe().f_code.co_name}")
|
|
if not hasattr(self, "test_payload"):
|
|
self.test_payload = "Default Payload"
|
|
if not hasattr(self, "test_content_topic"):
|
|
self.test_content_topic = "/test/1/default/proto"
|
|
|
|
@allure.step
|
|
@retry(stop=stop_after_delay(20), wait=wait_fixed(0.5), reraise=True)
|
|
def add_node_peer(self, node, multiaddr_list, shards=[0, 1, 2, 3, 4, 5, 6, 7, 8]):
|
|
if node.is_nwaku():
|
|
for multiaddr in multiaddr_list:
|
|
node.add_peers([multiaddr])
|
|
elif node.is_gowaku():
|
|
for multiaddr in multiaddr_list:
|
|
peer_info = {"multiaddr": multiaddr, "protocols": ["/vac/waku/relay/2.0.0"], "shards": shards}
|
|
node.add_peers(peer_info)
|
|
|
|
@allure.step
|
|
def create_message(self, **kwargs):
|
|
message = {"payload": to_base64(self.test_payload), "contentTopic": self.test_content_topic, "timestamp": int(time() * 1e9)}
|
|
message.update(kwargs)
|
|
return message
|