From aaa0342c4401ed97e30893508a837f4eec399d07 Mon Sep 17 00:00:00 2001
From: Roman <zajic@zajic.net>
Date: Thu, 1 Feb 2024 09:51:36 +0800
Subject: [PATCH] chore: add startup test for RLN

---
 tests/relay/test_rln.py | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)
 create mode 100644 tests/relay/test_rln.py

diff --git a/tests/relay/test_rln.py b/tests/relay/test_rln.py
new file mode 100644
index 00000000..759f97e2
--- /dev/null
+++ b/tests/relay/test_rln.py
@@ -0,0 +1,25 @@
+import pytest
+from src.env_vars import NODE_1, NODE_2
+from src.libs.custom_logger import get_custom_logger
+from time import time
+from src.libs.common import delay, to_base64
+from src.steps.relay import StepsRelay
+from src.test_data import INVALID_CONTENT_TOPICS, INVALID_PAYLOADS, SAMPLE_INPUTS, SAMPLE_TIMESTAMPS, VALID_PUBSUB_TOPICS
+from src.node.waku_message import WakuMessage
+
+logger = get_custom_logger(__name__)
+
+
+@pytest.mark.usefixtures("setup_main_rln_relay_nodes", "subscribe_main_relay_nodes")
+class TestRelayRLN(StepsRelay):
+    def test_publish_with_valid_payloads(self):
+        failed_payloads = []
+        for payload in SAMPLE_INPUTS:
+            logger.debug(f'Running test with payload {payload["description"]}')
+            message = self.create_message(payload=to_base64(payload["value"]))
+            try:
+                self.check_published_message_reaches_relay_peer(message)
+            except Exception as e:
+                logger.error(f'Payload {payload["description"]} failed: {str(e)}')
+                failed_payloads.append(payload["description"])
+        assert not failed_payloads, f"Payloads failed: {failed_payloads}"