logos-delivery-interop-tests/src/test_data.py

import os
from time import time
from datetime import datetime, timedelta

NOW = datetime.now()

SAMPLE_INPUTS = [
    {"description": "A simple string", "value": "Hello World!"},
    {"description": "An integer", "value": "1234567890"},
    {"description": "A dictionary", "value": '{"key": "value"}'},
    {"description": "Chinese characters", "value": "这是一些中文"},
    {"description": "Emojis", "value": "🚀🌟✨"},
    {"description": "Lorem ipsum text", "value": "Lorem ipsum dolor sit amet"},
    {"description": "HTML content", "value": "<html><body>Hello</body></html>"},
    {"description": "Cyrillic characters", "value": "\u041f\u0440\u0438\u0432\u0435\u0442"},
    {"description": "Base64 encoded string", "value": "Base64==dGVzdA=="},
    {"description": "Binary data", "value": "d29ya2luZyB3aXRoIGJpbmFyeSBkYXRh: \x50\x51"},
    {"description": "Special characters with whitespace", "value": "\t\nSpecial\tCharacters\n"},
    {"description": "Boolean false as a string", "value": "False"},
    {"description": "A float number", "value": "3.1415926535"},
    {"description": "A list", "value": "[1, 2, 3, 4, 5]"},
    {"description": "Hexadecimal number as a string", "value": "0xDEADBEEF"},
    {"description": "Email format", "value": "user@example.com"},
    {"description": "URL format", "value": "http://example.com"},
    {"description": "Date and time in ISO format", "value": "2023-11-01T12:00:00Z"},
    {"description": "String with escaped quotes", "value": '"Escaped" \\"quotes\\"'},
    {"description": "A regular expression", "value": "Regular expression: ^[a-z0-9_-]{3,16}$"},
    {"description": "A very long string", "value": "x" * 1000},
    {"description": "A JSON string", "value": '{"name": "John", "age": 30, "city": "New York"}'},
    {"description": "A Unix path", "value": "/usr/local/bin"},
    {"description": "A Windows path", "value": "C:\\Windows\\System32"},
    {"description": "An SQL query", "value": "SELECT * FROM users WHERE id = 1;"},
    {"description": "JavaScript code snippet", "value": "function test() { console.log('Hello World'); }"},
    {"description": "A CSS snippet", "value": "body { background-color: #fff; }"},
    {"description": "A Python one-liner", "value": "print('Hello World')"},
    {"description": "An IP address", "value": "192.168.1.1"},
    {"description": "A domain name", "value": "www.example.com"},
    {"description": "A user agent string", "value": "Mozilla/5.0 (Windows NT 10.0; Win64; x64)"},
    {"description": "A credit card number", "value": "1234-5678-9012-3456"},
    {"description": "A phone number", "value": "+1234567890"},
    {"description": "A UUID", "value": "123e4567-e89b-12d3-a456-426614174000"},
    {"description": "A hashtag", "value": "#helloWorld"},
    {"description": "A Twitter handle", "value": "@username"},
    {"description": "A password", "value": "P@ssw0rd!"},
    {"description": "A date in common format", "value": "01/11/2023"},
    {"description": "A time string", "value": "12:00:00"},
    {"description": "A mathematical equation", "value": "E = mc^2"},
]

INVALID_PAYLOADS = [
    {"description": "Empty string", "value": ""},
    {"description": "Unecoded text", "value": "Hello World!"},
    {"description": "A dictionary", "value": {"key": "YWFh"}},
    {"description": "An integer", "value": 1234567890},
    {"description": "A list", "value": ["YWFh"]},
    {"description": "A bool", "value": True},
]

INVALID_CONTENT_TOPICS = [
    {"description": "Empty string", "value": ""},
    {"description": "A dictionary", "value": {"key": "YWFh"}},
    {"description": "An integer", "value": 1234567890},
    {"description": "A list", "value": ["YWFh"]},
    {"description": "A bool", "value": True},
]

CONTENT_TOPICS_DIFFERENT_SHARDS = [
    "/myapp/1/latest/proto",  # resolves to shard 0
    "/waku/2/content/test.js",  # resolves to shard 1
    "/app/22/sometopic/someencoding",  # resolves to shard 2
    "/toychat/2/huilong/proto",  # resolves to shard 3
    "/statusim/1/community/cbor",  # resolves to shard 4
    "/app/27/sometopic/someencoding",  # resolves to shard 5
    "/app/29/sometopic/someencoding",  # resolves to shard 6
    "/app/20/sometopic/someencoding",  # resolves to shard 7
]

CONTENT_TOPICS_SHARD_0 = [
    "/newsService/1.0/weekly/protobuf",
    "/newsService/1.0/alerts/xml",
    "/newsService/1.0/updates/json",
    "/newsService/2.0/alerts/json",
    "/newsService/2.0/summaries/xml",
    "/newsService/2.0/highlights/yaml",
    "/newsService/3.0/weekly/json",
    "/newsService/3.0/summaries/xml",
]

CONTENT_TOPICS_SHARD_7 = [
    "/newsService/2.0/alerts/yaml",
    "/newsService/2.0/highlights/xml",
    "/newsService/3.0/daily/protobuf",
    "/newsService/3.0/alerts/xml",
    "/newsService/3.0/updates/protobuf",
    "/newsService/3.0/reviews/xml",
    "/newsService/4.0/alerts/yaml",
    "/newsService/4.0/updates/yaml",
]

DEFAULT_CLUSTER_ID = "198"
VALID_PUBSUB_TOPICS = [
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/9",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/25",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1000",
]

FLEET_CLUSTER_ID = "1"
FLEET_PUBSUB_TOPICS = [f"/waku/2/rs/{FLEET_CLUSTER_ID}/{i}" for i in range(8)]

PUBSUB_TOPICS_STORE = [
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/2",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/3",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/4",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/5",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/6",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/7",
    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/8",
]

INVALID_PUBSUB_TOPICS = ["/test/2/rs/0/1", "/waku/3/rs/0/1", "/waku/2/test/0/1", "/waku/2/rs/3/b", "/waku/2/rs/0"]

PUBSUB_TOPICS_DIFFERENT_CLUSTERS = [
    "/waku/2/rs/2/0",
    "/waku/2/rs/2/1",
    "/waku/2/rs/5/0",
    "/waku/2/rs/5/1",
    "/waku/2/rs/5/999",
    "/waku/2/rs/8/0",
    "/waku/2/rs/999/999",
]

PUBSUB_TOPICS_SAME_CLUSTER = [
    "/waku/2/rs/199/0",
    "/waku/2/rs/199/1",
    "/waku/2/rs/199/2",
    "/waku/2/rs/199/3",
    "/waku/2/rs/199/4",
    "/waku/2/rs/199/5",
    "/waku/2/rs/199/6",
    "/waku/2/rs/199/7",
]

PUBSUB_TOPICS_WRONG_FORMAT = [
    {"description": "A dictionary", "value": {"key": "YWFh"}},
    {"description": "An integer", "value": 1234567890},
    {"description": "A list", "value": ["YWFh"]},
    {"description": "A bool", "value": True},
]


def get_sample_timestamps():
    """Return timestamp test-cases with values evaluated fresh at call time.

    This factory function MUST be called from inside each test (never at module
    import time) so that the "Now" value reflects the actual time when the
    message is published.

    Valid_for semantics:
    ``["nwaku"]`` – accepted by nwaku in the current run mode.
    ``[]``        – rejected by nwaku in the current run mode (either
                    structurally invalid type, or out-of-epoch in fleet/RLN
                    mode).
    """
    now_ns = int(time() * 1e9)
    now_dt = datetime.now()
    fleet_mode = os.getenv("FLEET_BOOTSTRAP", "false").lower() == "true"
    standalone_valid = [] if fleet_mode else ["nwaku"]
    return [
        {"description": "Now", "value": now_ns, "valid_for": ["nwaku"]},
        # 10 years from now
        {"description": "Far future", "value": int((now_dt + timedelta(days=365 * 10)).timestamp() * 1e9), "valid_for": standalone_valid},
        # 1 hour ago
        {"description": "Recent past", "value": int((now_dt - timedelta(hours=1)).timestamp() * 1e9), "valid_for": standalone_valid},
        # 1 hour ahead
        {"description": "Near future", "value": int((now_dt + timedelta(hours=1)).timestamp() * 1e9), "valid_for": standalone_valid},
        {"description": "Positive number", "value": 1, "valid_for": standalone_valid},
        {"description": "Negative number", "value": -1, "valid_for": standalone_valid},
        # DST starts
        {"description": "DST change", "value": int(datetime(2020, 3, 8, 2, 0, 0).timestamp() * 1e9), "valid_for": standalone_valid},
        {"description": "Timestamp as string number", "value": str(now_ns), "valid_for": []},
        {"description": "Invalid large number", "value": 2**63, "valid_for": []},
        {"description": "Float number", "value": float(now_ns), "valid_for": []},
        {"description": "Array instead of timestamp", "value": [now_ns], "valid_for": []},
        {"description": "Object instead of timestamp", "value": {"time": now_ns}, "valid_for": []},
        {"description": "ISO 8601 timestamp", "value": "2023-12-26T10:58:51", "valid_for": []},
        {"description": "Missing", "value": None, "valid_for": []},
    ]


PUBSUB_TOPICS_RLN = [f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0"]

LOG_ERROR_KEYWORDS = [
    "crash",
    "fatal",
    "panic",
    "abort",
    "segfault",
    "corrupt",
    "terminated",
    "unhandled",
    "stacktrace",
    "deadlock",
    "SIGSEGV",
    "SIGABRT",
    "stack overflow",
    "index out of bounds",
    "nil pointer dereference",
    "goroutine exit",
    "nil pointer",
    "runtime error",
    "goexit",
    "race condition",
    "double free",
]

METRICS_WITH_INITIAL_VALUE_ZERO = [
    "libp2p_peers",
    "libp2p_failed_upgrades_incoming_total",
    "libp2p_failed_upgrades_outgoing_total",
    "libp2p_total_dial_attempts_total",
    "libp2p_successful_dials_total",
    "libp2p_failed_dials_total",
    "waku_rln_messages_total_total",
    "waku_rln_spam_messages_total_total",
    "waku_rln_proof_verification_total_total",
    "waku_rln_number_registered_memberships",
    "waku_rln_proof_verification_duration_seconds",
    "waku_rln_proof_generation_duration_seconds",
    "waku_rln_instance_creation_duration_seconds",
    "waku_rln_membership_insertion_duration_seconds",
    "waku_rln_membership_credentials_import_duration_seconds",
    "waku_rln_remaining_proofs_per_epoch",
    "waku_rln_total_generated_proofs",
    "libp2p_pubsub_sig_verify_success_total",
    "libp2p_pubsub_sig_verify_failure_total",
    "libp2p_pubsub_disconnects_over_non_priority_queue_limit_total",
    "libp2p_pubsub_peers",
    "libp2p_pubsub_unsubscriptions_total",
    "libp2p_pubsub_validation_success_total",
    "libp2p_pubsub_validation_failure_total",
    "libp2p_pubsub_validation_ignore_total",
    "libp2p_pubsub_broadcast_iwant_total",
    "libp2p_pubsub_received_iwant_total",
    "libp2p_gossipsub_cache_window_size",
    'libp2p_gossipsub_peers_per_topic_mesh{topic="other"}',
    'libp2p_gossipsub_peers_per_topic_fanout{topic="other"}',
    'libp2p_gossipsub_peers_per_topic_gossipsub{topic="other"}',
    "libp2p_gossipsub_low_peers_topics",
    "libp2p_gossipsub_healthy_peers_topics",
    "libp2p_gossipsub_failed_publish_total",
    "libp2p_gossipsub_invalid_topic_subscription_total",
    "libp2p_gossipsub_duplicate_during_validation_total",
    "libp2p_gossipsub_idontwant_saved_messages_total",
    "libp2p_gossipsub_duplicate_total",
    "libp2p_gossipsub_received_total",
    "libp2p_rendezvous_register_total",
    "libp2p_rendezvous_discover_total",
    "libp2p_rendezvous_registered",
    "libp2p_rendezvous_namespaces",
    "waku_peer_store_size",
    "waku_total_unique_peers",
    "presto_server_missing_requests_count",
    "presto_server_invalid_requests_count",
    'waku_archive_messages{type="stored"}',
    "waku_archive_insert_duration_seconds_sum",
    "waku_archive_insert_duration_seconds_count",
    'waku_archive_insert_duration_seconds_bucket{le="0.005"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.01"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.025"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.05"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.075"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.1"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.25"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.5"}',
    'waku_archive_insert_duration_seconds_bucket{le="0.75"}',
    'waku_archive_insert_duration_seconds_bucket{le="1.0"}',
    'waku_archive_insert_duration_seconds_bucket{le="2.5"}',
    'waku_archive_insert_duration_seconds_bucket{le="5.0"}',
    'waku_archive_insert_duration_seconds_bucket{le="7.5"}',
    'waku_archive_insert_duration_seconds_bucket{le="10.0"}',
    'waku_archive_insert_duration_seconds_bucket{le="+Inf"}',
    "waku_archive_query_duration_seconds_sum",
    "waku_archive_query_duration_seconds_count",
    'waku_archive_query_duration_seconds_bucket{le="0.005"}',
    'waku_archive_query_duration_seconds_bucket{le="0.01"}',
    'waku_archive_query_duration_seconds_bucket{le="0.025"}',
    'waku_archive_query_duration_seconds_bucket{le="0.05"}',
    'waku_archive_query_duration_seconds_bucket{le="0.075"}',
    'waku_archive_query_duration_seconds_bucket{le="0.1"}',
    'waku_archive_query_duration_seconds_bucket{le="0.25"}',
    'waku_archive_query_duration_seconds_bucket{le="0.5"}',
    'waku_archive_query_duration_seconds_bucket{le="0.75"}',
    'waku_archive_query_duration_seconds_bucket{le="1.0"}',
    'waku_archive_query_duration_seconds_bucket{le="2.5"}',
    'waku_archive_query_duration_seconds_bucket{le="5.0"}',
    'waku_archive_query_duration_seconds_bucket{le="7.5"}',
    'waku_archive_query_duration_seconds_bucket{le="10.0"}',
    'waku_archive_query_duration_seconds_bucket{le="+Inf"}',
    "waku_filter_subscriptions",
    "waku_filter_handle_message_duration_seconds_sum",
    "waku_filter_handle_message_duration_seconds_count",
    'waku_filter_handle_message_duration_seconds_bucket{le="0.005"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.01"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.025"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.05"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.075"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.1"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.25"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.5"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="0.75"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="1.0"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="2.5"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="5.0"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="7.5"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="10.0"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="+Inf"}',
    "discovery_session_lru_cache_hits_total",
    "discovery_session_lru_cache_misses_total",
    "discovery_session_decrypt_failures_total",
    "discovery_unsolicited_messages_total",
    "discovery_enr_auto_update_total",
    "waku_px_peers_received_total",
    "waku_px_peers_received_unknown",
    "waku_px_peers_sent_total",
    "waku_px_peers",
    "waku_histogram_message_size_sum",
    "waku_histogram_message_size_count",
    'waku_histogram_message_size_bucket{le="0.0"}',
    'waku_histogram_message_size_bucket{le="1.0"}',
    'waku_histogram_message_size_bucket{le="3.0"}',
    'waku_histogram_message_size_bucket{le="5.0"}',
    'waku_histogram_message_size_bucket{le="15.0"}',
    'waku_histogram_message_size_bucket{le="50.0"}',
    'waku_histogram_message_size_bucket{le="75.0"}',
    'waku_histogram_message_size_bucket{le="100.0"}',
    'waku_histogram_message_size_bucket{le="125.0"}',
    'waku_histogram_message_size_bucket{le="150.0"}',
    'waku_histogram_message_size_bucket{le="500.0"}',
    'waku_histogram_message_size_bucket{le="700.0"}',
    'waku_histogram_message_size_bucket{le="1000.0"}',
    'waku_histogram_message_size_bucket{le="+Inf"}',
    "waku_lightpush_peers",
    "waku_filter_peers",
    "waku_store_peers",
    "waku_px_peers",
    "waku_dnsdisc_discovered",
    "rendezvousPeerFoundTotal_total",
    "reconciliation_roundtrips_sum",
    "reconciliation_roundtrips_count",
    "reconciliation_differences_sum",
    "reconciliation_differences_count",
    'reconciliation_roundtrips_bucket{le="1.0"}',
    'reconciliation_roundtrips_bucket{le="2.0"}',
    'reconciliation_roundtrips_bucket{le="3.0"}',
    'reconciliation_roundtrips_bucket{le="5.0"}',
    'reconciliation_roundtrips_bucket{le="8.0"}',
    'reconciliation_roundtrips_bucket{le="13.0"}',
    'reconciliation_roundtrips_bucket{le="+Inf"}',
    'reconciliation_differences_bucket{le="0.0"}',
    'reconciliation_differences_bucket{le="10.0"}',
    'reconciliation_differences_bucket{le="50.0"}',
    'reconciliation_differences_bucket{le="100.0"}',
    'reconciliation_differences_bucket{le="500.0"}',
    'reconciliation_differences_bucket{le="1000.0"}',
    'reconciliation_differences_bucket{le="5000.0"}',
    'reconciliation_differences_bucket{le="+Inf"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="15.0"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="20.0"}',
    'waku_filter_handle_message_duration_seconds_bucket{le="30.0"}',
    "total_messages_cached",
    "waku_store_queries_total",
    "mix_pool_size",
    "libp2p_gossipsub_imreceiving_saved_messages_total",
    "postgres_payload_size_bytes",
]
-												chore: Test waku fleet (#175)

* chore: build logos delivery lib locally

* test: soft attachment to waku.test

* chore: node1 node2 bootstrap from test fleet nodes
- selected test cases relay, store

* fix: cleanup artifacts after liblogosdelivery build

* chore: add fleet tests workflow

* fix: trigger on push and test

* fix: register markers

* test: add light_push to fleet tests

* test: add filter to fleet tests

* fix: add more store tests to fleet tests

* fix: add more relay to fleet tests

* fix: wf efficiency

* fix: wf syntax

* test: join fleet with real cluster ID shards RLN on

* fix: stop fleet tests when RLN registration fails

* fix: refactor monkeypatch

* fix: light_push tests

* fix: scoped assertion for store test in fleet mode

* fix: reduce comments

* fix: different propagation delay for fleet test

* fix: add fresh timestamp helper

* fix: reduce comments

* test: change to Waku v0.38.0 image temporarily

* fix: reduce log message

* fix: undo reduce log message

* fix: add scheduled run at 2 am.

* fix: fail fleet tests instead of skip when RLN is not working

* fix: refactor get_sample_timestamps

* fix: remove on push trigger for fleet wf
- reset back to use the latest docker image
											
										
										
											2026-05-08 14:59:20 +08:00
+								import os
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
+								from time import time
 								from datetime import datetime, timedelta
 								NOW = datetime.now()
-												relay publish tests

											
										
										
											2023-11-01 14:02:29 +02:00
+								SAMPLE_INPUTS = [
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
+								    {"description": "A simple string", "value": "Hello World!"},
 								    {"description": "An integer", "value": "1234567890"},
 								    {"description": "A dictionary", "value": '{"key": "value"}'},
 								    {"description": "Chinese characters", "value": "这是一些中文"},
 								    {"description": "Emojis", "value": "🚀🌟✨"},
 								    {"description": "Lorem ipsum text", "value": "Lorem ipsum dolor sit amet"},
 								    {"description": "HTML content", "value": "<html><body>Hello</body></html>"},
 								    {"description": "Cyrillic characters", "value": "\u041f\u0440\u0438\u0432\u0435\u0442"},
 								    {"description": "Base64 encoded string", "value": "Base64==dGVzdA=="},
 								    {"description": "Binary data", "value": "d29ya2luZyB3aXRoIGJpbmFyeSBkYXRh: \x50\x51"},
 								    {"description": "Special characters with whitespace", "value": "\t\nSpecial\tCharacters\n"},
 								    {"description": "Boolean false as a string", "value": "False"},
 								    {"description": "A float number", "value": "3.1415926535"},
 								    {"description": "A list", "value": "[1, 2, 3, 4, 5]"},
 								    {"description": "Hexadecimal number as a string", "value": "0xDEADBEEF"},
 								    {"description": "Email format", "value": "user@example.com"},
 								    {"description": "URL format", "value": "http://example.com"},
 								    {"description": "Date and time in ISO format", "value": "2023-11-01T12:00:00Z"},
-												chore: fixes and adjustments (#139)


											
										
										
											2025-10-08 13:33:24 +03:00
+								    {"description": "String with escaped quotes", "value": '"Escaped" \\"quotes\\"'},
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
+								    {"description": "A regular expression", "value": "Regular expression: ^[a-z0-9_-]{3,16}$"},
 								    {"description": "A very long string", "value": "x" * 1000},
 								    {"description": "A JSON string", "value": '{"name": "John", "age": 30, "city": "New York"}'},
 								    {"description": "A Unix path", "value": "/usr/local/bin"},
-												chore: fixes and adjustments (#139)


											
										
										
											2025-10-08 13:33:24 +03:00
+								    {"description": "A Windows path", "value": "C:\\Windows\\System32"},
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
+								    {"description": "An SQL query", "value": "SELECT * FROM users WHERE id = 1;"},
 								    {"description": "JavaScript code snippet", "value": "function test() { console.log('Hello World'); }"},
 								    {"description": "A CSS snippet", "value": "body { background-color: #fff; }"},
 								    {"description": "A Python one-liner", "value": "print('Hello World')"},
 								    {"description": "An IP address", "value": "192.168.1.1"},
 								    {"description": "A domain name", "value": "www.example.com"},
 								    {"description": "A user agent string", "value": "Mozilla/5.0 (Windows NT 10.0; Win64; x64)"},
 								    {"description": "A credit card number", "value": "1234-5678-9012-3456"},
 								    {"description": "A phone number", "value": "+1234567890"},
 								    {"description": "A UUID", "value": "123e4567-e89b-12d3-a456-426614174000"},
 								    {"description": "A hashtag", "value": "#helloWorld"},
 								    {"description": "A Twitter handle", "value": "@username"},
 								    {"description": "A password", "value": "P@ssw0rd!"},
 								    {"description": "A date in common format", "value": "01/11/2023"},
 								    {"description": "A time string", "value": "12:00:00"},
 								    {"description": "A mathematical equation", "value": "E = mc^2"},
 								]
 								INVALID_PAYLOADS = [
 								    {"description": "Empty string", "value": ""},
 								    {"description": "Unecoded text", "value": "Hello World!"},
 								    {"description": "A dictionary", "value": {"key": "YWFh"}},
 								    {"description": "An integer", "value": 1234567890},
 								    {"description": "A list", "value": ["YWFh"]},
 								    {"description": "A bool", "value": True},
 								]
 								INVALID_CONTENT_TOPICS = [
 								    {"description": "Empty string", "value": ""},
 								    {"description": "A dictionary", "value": {"key": "YWFh"}},
 								    {"description": "An integer", "value": 1234567890},
 								    {"description": "A list", "value": ["YWFh"]},
 								    {"description": "A bool", "value": True},
 								]
-												sharding tests part 1 (#24)

* sharding struct

* add peers

* running nodes tests

* cleanup sharding steps

* new sharding tests

* test_different_cluster_different_shard

* new tests

* new static sharding tests

* new auto sharding tests

* change structure

* running nodes tests

* new autosharding tests

* adjust tests

* new sharding tests

* sharding

* sharding filter

* add peers
											
										
										
											2024-04-02 09:11:56 +03:00
+								CONTENT_TOPICS_DIFFERENT_SHARDS = [
 								    "/myapp/1/latest/proto",  # resolves to shard 0
 								    "/waku/2/content/test.js",  # resolves to shard 1
 								    "/app/22/sometopic/someencoding",  # resolves to shard 2
 								    "/toychat/2/huilong/proto",  # resolves to shard 3
 								    "/statusim/1/community/cbor",  # resolves to shard 4
 								    "/app/27/sometopic/someencoding",  # resolves to shard 5
 								    "/app/29/sometopic/someencoding",  # resolves to shard 6
 								    "/app/20/sometopic/someencoding",  # resolves to shard 7
 								]
 								CONTENT_TOPICS_SHARD_0 = [
 								    "/newsService/1.0/weekly/protobuf",
 								    "/newsService/1.0/alerts/xml",
 								    "/newsService/1.0/updates/json",
 								    "/newsService/2.0/alerts/json",
 								    "/newsService/2.0/summaries/xml",
 								    "/newsService/2.0/highlights/yaml",
 								    "/newsService/3.0/weekly/json",
 								    "/newsService/3.0/summaries/xml",
 								]
 								CONTENT_TOPICS_SHARD_7 = [
 								    "/newsService/2.0/alerts/yaml",
 								    "/newsService/2.0/highlights/xml",
 								    "/newsService/3.0/daily/protobuf",
 								    "/newsService/3.0/alerts/xml",
 								    "/newsService/3.0/updates/protobuf",
 								    "/newsService/3.0/reviews/xml",
 								    "/newsService/4.0/alerts/yaml",
 								    "/newsService/4.0/updates/yaml",
 								]
-												Fix failing test cases on logos-delivery/v0.38 (#165)

* Fix auto and static sharding subscribe/unsubscribe tests - use a safe un-used cluster-id ever (cluster id 2 is now defaults to logos.dev with its settings), also adapted static sharding unsubscribe to PR#3732

* Adjust cluster_id to pubsub_topics

* Fix uncertain rate limit hit of filter subscribes - this is a planned behavior of current rate limiting, as we are trying our best to serve requests within reasonanble flexibility, thus we mint new tokens over time, so it can be seen as we are able to serve more requests as configured, those are not hard limits.

* fix test_relay_2_nodes_bandwidth_low_vs_high_drain_time flaky result, eliminate jitter and localhost test optimization can appear on docker networking.
											
										
										
											2026-03-31 04:44:37 +02:00
+								DEFAULT_CLUSTER_ID = "198"
-												chore: use another cluster id (#55)

* use another cluster id

* adjust tests
											
										
										
											2024-07-11 23:00:18 +03:00
+								VALID_PUBSUB_TOPICS = [
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/9",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/25",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1000",
 								]
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
-												chore: Test waku fleet (#175)

* chore: build logos delivery lib locally

* test: soft attachment to waku.test

* chore: node1 node2 bootstrap from test fleet nodes
- selected test cases relay, store

* fix: cleanup artifacts after liblogosdelivery build

* chore: add fleet tests workflow

* fix: trigger on push and test

* fix: register markers

* test: add light_push to fleet tests

* test: add filter to fleet tests

* fix: add more store tests to fleet tests

* fix: add more relay to fleet tests

* fix: wf efficiency

* fix: wf syntax

* test: join fleet with real cluster ID shards RLN on

* fix: stop fleet tests when RLN registration fails

* fix: refactor monkeypatch

* fix: light_push tests

* fix: scoped assertion for store test in fleet mode

* fix: reduce comments

* fix: different propagation delay for fleet test

* fix: add fresh timestamp helper

* fix: reduce comments

* test: change to Waku v0.38.0 image temporarily

* fix: reduce log message

* fix: undo reduce log message

* fix: add scheduled run at 2 am.

* fix: fail fleet tests instead of skip when RLN is not working

* fix: refactor get_sample_timestamps

* fix: remove on push trigger for fleet wf
- reset back to use the latest docker image
											
										
										
											2026-05-08 14:59:20 +08:00
+								FLEET_CLUSTER_ID = "1"
 								FLEET_PUBSUB_TOPICS = [f"/waku/2/rs/{FLEET_CLUSTER_ID}/{i}" for i in range(8)]
-												Test/store v3 (#38)

* first commit

* get message tests 1

* store tests with node restarts

* reliability tests

* store tests

* fixes

* more tests

* fixes

* new store tests

* new store tests

* adjustments

* adjust tests for go-waku

* postgress test

* postgress test

* fixes

* small fixes

* reliability updates

* postgress test

* adjsutmens for go-waku
											
										
										
											2024-05-28 16:50:14 +03:00
+								PUBSUB_TOPICS_STORE = [
-												chore: use another cluster id (#55)

* use another cluster id

* adjust tests
											
										
										
											2024-07-11 23:00:18 +03:00
+								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/1",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/2",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/3",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/4",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/5",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/6",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/7",
 								    f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/8",
-												Test/store v3 (#38)

* first commit

* get message tests 1

* store tests with node restarts

* reliability tests

* store tests

* fixes

* more tests

* fixes

* new store tests

* new store tests

* adjustments

* adjust tests for go-waku

* postgress test

* postgress test

* fixes

* small fixes

* reliability updates

* postgress test

* adjsutmens for go-waku
											
										
										
											2024-05-28 16:50:14 +03:00
+								]
-												chore: use another cluster id (#55)

* use another cluster id

* adjust tests
											
										
										
											2024-07-11 23:00:18 +03:00
+								INVALID_PUBSUB_TOPICS = ["/test/2/rs/0/1", "/waku/3/rs/0/1", "/waku/2/test/0/1", "/waku/2/rs/3/b", "/waku/2/rs/0"]
-												Relay Subscribe (#5)

* github actions report summary

* use env instead of inputs

* multiple nodes tests

* fix warm up

* fix warm up

* small fix after CI run

* small fix after CI run 2

* add new multi-node test

* self review

* relay subscribe tests

* small fix

* new tests

* fix typo
											
										
										
											2023-11-24 14:04:24 +02:00
-												sharding tests part 1 (#24)

* sharding struct

* add peers

* running nodes tests

* cleanup sharding steps

* new sharding tests

* test_different_cluster_different_shard

* new tests

* new static sharding tests

* new auto sharding tests

* change structure

* running nodes tests

* new autosharding tests

* adjust tests

* new sharding tests

* sharding

* sharding filter

* add peers
											
										
										
											2024-04-02 09:11:56 +03:00
+								PUBSUB_TOPICS_DIFFERENT_CLUSTERS = [
 								    "/waku/2/rs/2/0",
 								    "/waku/2/rs/2/1",
-												chore: use another cluster id (#55)

* use another cluster id

* adjust tests
											
										
										
											2024-07-11 23:00:18 +03:00
+								    "/waku/2/rs/5/0",
 								    "/waku/2/rs/5/1",
 								    "/waku/2/rs/5/999",
-												sharding tests part 1 (#24)

* sharding struct

* add peers

* running nodes tests

* cleanup sharding steps

* new sharding tests

* test_different_cluster_different_shard

* new tests

* new static sharding tests

* new auto sharding tests

* change structure

* running nodes tests

* new autosharding tests

* adjust tests

* new sharding tests

* sharding

* sharding filter

* add peers
											
										
										
											2024-04-02 09:11:56 +03:00
+								    "/waku/2/rs/8/0",
 								    "/waku/2/rs/999/999",
 								]
 								PUBSUB_TOPICS_SAME_CLUSTER = [
-												Fix failing test cases on logos-delivery/v0.38 (#165)

* Fix auto and static sharding subscribe/unsubscribe tests - use a safe un-used cluster-id ever (cluster id 2 is now defaults to logos.dev with its settings), also adapted static sharding unsubscribe to PR#3732

* Adjust cluster_id to pubsub_topics

* Fix uncertain rate limit hit of filter subscribes - this is a planned behavior of current rate limiting, as we are trying our best to serve requests within reasonanble flexibility, thus we mint new tokens over time, so it can be seen as we are able to serve more requests as configured, those are not hard limits.

* fix test_relay_2_nodes_bandwidth_low_vs_high_drain_time flaky result, eliminate jitter and localhost test optimization can appear on docker networking.
											
										
										
											2026-03-31 04:44:37 +02:00
+								    "/waku/2/rs/199/0",
 								    "/waku/2/rs/199/1",
 								    "/waku/2/rs/199/2",
 								    "/waku/2/rs/199/3",
 								    "/waku/2/rs/199/4",
 								    "/waku/2/rs/199/5",
 								    "/waku/2/rs/199/6",
 								    "/waku/2/rs/199/7",
-												sharding tests part 1 (#24)

* sharding struct

* add peers

* running nodes tests

* cleanup sharding steps

* new sharding tests

* test_different_cluster_different_shard

* new tests

* new static sharding tests

* new auto sharding tests

* change structure

* running nodes tests

* new autosharding tests

* adjust tests

* new sharding tests

* sharding

* sharding filter

* add peers
											
										
										
											2024-04-02 09:11:56 +03:00
+								]
-												Relay Publish: Extend coverage (#2)

* small improvements

* minor adjustments

* new tests

* try with more runners

* try with more runners2

* tweaks for parallel run

* new tests

* small tweaks

* new tests

* new tests

* test remove defaults from CI

* handle empty strings for env vars in CI

* add nodekey to main node

* add more tests

* finishing touches

* fixes based on Alex suggestions

* revert unwanted change

* add new pause test
											
										
										
											2023-11-17 08:47:22 +02:00
-												Light push tests (#27)

* first set of tests

* fix ci

* new tests

* finish publish tests

* new tests

* running nodes tests

* new tests

* finishing touches

* new test

* fixes

* fixes
											
										
										
											2024-04-11 13:00:53 +03:00
+								PUBSUB_TOPICS_WRONG_FORMAT = [
 								    {"description": "A dictionary", "value": {"key": "YWFh"}},
 								    {"description": "An integer", "value": 1234567890},
 								    {"description": "A list", "value": ["YWFh"]},
 								    {"description": "A bool", "value": True},
 								]
-												chore: Test waku fleet (#175)

* chore: build logos delivery lib locally

* test: soft attachment to waku.test

* chore: node1 node2 bootstrap from test fleet nodes
- selected test cases relay, store

* fix: cleanup artifacts after liblogosdelivery build

* chore: add fleet tests workflow

* fix: trigger on push and test

* fix: register markers

* test: add light_push to fleet tests

* test: add filter to fleet tests

* fix: add more store tests to fleet tests

* fix: add more relay to fleet tests

* fix: wf efficiency

* fix: wf syntax

* test: join fleet with real cluster ID shards RLN on

* fix: stop fleet tests when RLN registration fails

* fix: refactor monkeypatch

* fix: light_push tests

* fix: scoped assertion for store test in fleet mode

* fix: reduce comments

* fix: different propagation delay for fleet test

* fix: add fresh timestamp helper

* fix: reduce comments

* test: change to Waku v0.38.0 image temporarily

* fix: reduce log message

* fix: undo reduce log message

* fix: add scheduled run at 2 am.

* fix: fail fleet tests instead of skip when RLN is not working

* fix: refactor get_sample_timestamps

* fix: remove on push trigger for fleet wf
- reset back to use the latest docker image
											
										
										
											2026-05-08 14:59:20 +08:00
 								def get_sample_timestamps():
 								    """Return timestamp test-cases with values evaluated fresh at call time.
 								    This factory function MUST be called from inside each test (never at module
 								    import time) so that the "Now" value reflects the actual time when the
 								    message is published.
 								    Valid_for semantics:
 								    ``["nwaku"]`` – accepted by nwaku in the current run mode.
 								    ``[]``        – rejected by nwaku in the current run mode (either
 								                    structurally invalid type, or out-of-epoch in fleet/RLN
 								                    mode).
 								    """
 								    now_ns = int(time() * 1e9)
 								    now_dt = datetime.now()
 								    fleet_mode = os.getenv("FLEET_BOOTSTRAP", "false").lower() == "true"
 								    standalone_valid = [] if fleet_mode else ["nwaku"]
 								    return [
 								        {"description": "Now", "value": now_ns, "valid_for": ["nwaku"]},
 								        # 10 years from now
 								        {"description": "Far future", "value": int((now_dt + timedelta(days=365 * 10)).timestamp() * 1e9), "valid_for": standalone_valid},
 								        # 1 hour ago
 								        {"description": "Recent past", "value": int((now_dt - timedelta(hours=1)).timestamp() * 1e9), "valid_for": standalone_valid},
 								        # 1 hour ahead
 								        {"description": "Near future", "value": int((now_dt + timedelta(hours=1)).timestamp() * 1e9), "valid_for": standalone_valid},
 								        {"description": "Positive number", "value": 1, "valid_for": standalone_valid},
 								        {"description": "Negative number", "value": -1, "valid_for": standalone_valid},
 								        # DST starts
 								        {"description": "DST change", "value": int(datetime(2020, 3, 8, 2, 0, 0).timestamp() * 1e9), "valid_for": standalone_valid},
 								        {"description": "Timestamp as string number", "value": str(now_ns), "valid_for": []},
 								        {"description": "Invalid large number", "value": 2**63, "valid_for": []},
 								        {"description": "Float number", "value": float(now_ns), "valid_for": []},
 								        {"description": "Array instead of timestamp", "value": [now_ns], "valid_for": []},
 								        {"description": "Object instead of timestamp", "value": {"time": now_ns}, "valid_for": []},
 								        {"description": "ISO 8601 timestamp", "value": "2023-12-26T10:58:51", "valid_for": []},
 								        {"description": "Missing", "value": None, "valid_for": []},
 								    ]
-												chore: RLN relay tests (#30)

* fix: add get_multiaddr_with_id step
- temporarily use local docker images

* fix: discard containers used for RLN registration

* fix: switch to use cluster ID 1 for RLN

* test: publish at slow and spam rate

* fix: shorten test data set

* fix: move RLN related code into separate class

* fix: use send only publish function
- add spam and alternate rate tests

* fix: use math.trunc instead of rounding

* fix: first message without delay

* fix: add one more second to messages with delay

* fix: add methods to setup non default RLN nodes

* fix: rewrite tests using steps rather than fixtures
- prepare for non default settings for RLN

* test: random epoch with valid_payloads_at_slow_rate

* test: random user message limit with valid payloads

* fix: skip test "random user message limit with valid payloads"

* fix: mark flaky "at variable_rate with valid payloads"

* fix: rename tests for easier debugging

* fix: mark valid_payloads_dynamic_at_slow_rate to skip

* fix: forgot to add actual file

* test: valid payloads dynamic(on chain) at spam rate
- extend timeout for ensure_ready() to 600s
- add ensure_healthy() for future use
- add text content based rest call
- remove NODE1, NODE2 imports

* fix: revert env_vars to source images from Harbor

* fix: reuse setup first and second rln relay node for setup_main_rln_relay_nodes

* fix: reuse register_rln_single_node for register_main_rln_relay_nodes

* fix: start using src.steps.common
- removed RLN test class inheritance from StepsRelay

* fix: test using whole data set at test payloads_at_slow_rate

* fix: switch to send msg and check for slow rate tests

* fix: add comment for skip check at first message

* fix: refactor payloads_at_variable_rate to use only one payload pattern

* fix: remove the plural from payloads_at_variable_rate

* fix: multiple class inheritance for TestRelayRLN

* test: node1 with rln node2 without rln at spam rate

* test: mixed epoch at slow rate

* test: add lightpush methods

* test: send valid payloads lightpush at spam rate

* fix: node1 to act as light push receiving node
- add setup lightpush node to spin off node2 with lightpush support

* fix: use NODE1 NODE2 instead of DEFAULT_NWAKU

* fix: no lightpush param required for plain RLN relay

* fix: comment for lightpush

* fix: comment for lightpush - wait for implementation

* fix: comment on chain tests

* fix: add lightpush case to publish_message

* fix: remove check_light_pushed_message_reaches_receiving_peer from StepsRLN

* fix: change comment for mixed_epoch_at_slow_rate

* test: happy and common case with 5 nodes

* fix: add all required fixtures explicitly

* fix: add timeout param to ensure_ready

* fix: skip RLN tests for go-waku

* fix: reformated with pre-commit

* fix: uncomment skip for debugging

* fix: put the skip back

* fix: change comment for on chain tests

* fix: run RLN tests in serial
- add grouping of tests to runner
- use smaller dataset for spam rate tests

* test: Nim to Nim workflow

* test: check also additional nodes for go-waku

* test: all nodes are nwaku

* fix: string quotes

* fix: remove additional nodes

* fix: re-arrange skip conditions

* test: RLN only

* fix: change default additional nodes to nwaku only

* fix: change additional nodes rather at top level workflow

* fix: enable all tests

* test: problems with current workdir

* test: rln only

* test: correct typo

* test: re-enable all tests
- remove current dir debug

* fix: nwaku additional nodes for nim to nim worklfow

* fix: re-able discord notification
- delete test workflow

* fix: add get_multiaddr_with_id step
- temporarily use local docker images

* fix: discard containers used for RLN registration

* fix: switch to use cluster ID 1 for RLN

* test: publish at slow and spam rate

* fix: shorten test data set

* fix: rebase onto master

* fix: use send only publish function
- add spam and alternate rate tests

* fix: use math.trunc instead of rounding

* fix: first message without delay

* fix: add one more second to messages with delay

* fix: add methods to setup non default RLN nodes

* fix: rewrite tests using steps rather than fixtures
- prepare for non default settings for RLN

* test: random epoch with valid_payloads_at_slow_rate

* test: random user message limit with valid payloads

* fix: skip test "random user message limit with valid payloads"

* fix: mark flaky "at variable_rate with valid payloads"

* fix: rename tests for easier debugging

* fix: mark valid_payloads_dynamic_at_slow_rate to skip

* fix: forgot to add actual file

* test: valid payloads dynamic(on chain) at spam rate
- extend timeout for ensure_ready() to 600s
- add ensure_healthy() for future use
- add text content based rest call
- remove NODE1, NODE2 imports

* fix: revert env_vars to source images from Harbor

* fix: reuse setup first and second rln relay node for setup_main_rln_relay_nodes

* fix: reuse register_rln_single_node for register_main_rln_relay_nodes

* fix: start using src.steps.common
- removed RLN test class inheritance from StepsRelay

* fix: test using whole data set at test payloads_at_slow_rate

* fix: switch to send msg and check for slow rate tests

* fix: add comment for skip check at first message

* fix: refactor payloads_at_variable_rate to use only one payload pattern

* fix: remove the plural from payloads_at_variable_rate

* fix: multiple class inheritance for TestRelayRLN

* test: node1 with rln node2 without rln at spam rate

* test: mixed epoch at slow rate

* test: add lightpush methods

* test: send valid payloads lightpush at spam rate

* fix: node1 to act as light push receiving node
- add setup lightpush node to spin off node2 with lightpush support

* fix: use NODE1 NODE2 instead of DEFAULT_NWAKU

* fix: no lightpush param required for plain RLN relay

* fix: comment for lightpush

* fix: comment for lightpush - wait for implementation

* fix: comment on chain tests

* fix: add lightpush case to publish_message

* fix: remove check_light_pushed_message_reaches_receiving_peer from StepsRLN

* fix: change comment for mixed_epoch_at_slow_rate

* test: happy and common case with 5 nodes

* fix: add all required fixtures explicitly

* fix: add timeout param to ensure_ready

* fix: skip RLN tests for go-waku

* fix: uncomment skip for debugging

* fix: put the skip back

* fix: change comment for on chain tests

* fix: run RLN tests in serial
- add grouping of tests to runner
- use smaller dataset for spam rate tests

* test: Nim to Nim workflow

* test: check also additional nodes for go-waku

* test: all nodes are nwaku

* fix: string quotes

* fix: remove additional nodes

* fix: re-arrange skip conditions

* test: RLN only

* fix: change default additional nodes to nwaku only

* fix: change additional nodes rather at top level workflow

* fix: enable all tests

* test: problems with current workdir

* test: rln only

* test: correct typo

* test: re-enable all tests
- remove current dir debug

* fix: nwaku additional nodes for nim to nim worklfow

* fix: re-able discord notification
- delete test workflow

* test: re-test again after rebase

* fix: wait longer for credential store

* test: try again with Discord report off

* fix: enable Discord
- delete test workflow
											
										
										
											2024-05-07 08:31:12 +08:00
-												chore: Refactor RLN tests (#164)

* test: uncomment RLN tests

* test: single node registration

* test: demo could not generate rln-v2 proof

* fix: update env file example

* fix: update images

* fix: temp pr for testing

* fix: chain id optional and lock v0.38.0

* feat: fix automatic chain ID

* fix: uncomment on chain tests 3208 resolved

* fix: improve assertions

* fix: RLN ready guard

* fix: workaround to wait for RLN

* fix: lightpush test assertion

* fix: reuse creds for the second test

* chore: delay for removing flaky behaviuor

* WIP on chore-refactor-rln-tests

fix: revert changes to docker manager

* fix: undo chore: delay for removing flaky behaviuor

* fix: check for RLN state only when required

* chore: test workflow for RLN

* fix: open permissions

* fix: silent chmod by default

* fix: remove unnecessary code

* fix: reduce CI script to RLN only

* fix: add missing fi

* fix: sync wf with master

* fix: test wf file

* fix: undefined rln creds set

* fix: run together with other tests

* fix: remove test workflows
- reset env file

* fix: sync wrappers manager

* fix: clean up redundant debug lines

---------

Co-authored-by: Darshan <35736874+darshankabariya@users.noreply.github.com>
Co-authored-by: darshankabariya <darshan@status.im>
											
										
										
											2026-04-18 08:34:20 +08:00
+								PUBSUB_TOPICS_RLN = [f"/waku/2/rs/{DEFAULT_CLUSTER_ID}/0"]
-												chore: check logs at teardown (#67)

* check logs at teardown

* fix

* fix
											
										
										
											2024-08-27 11:56:25 +03:00
 								LOG_ERROR_KEYWORDS = [
 								    "crash",
 								    "fatal",
 								    "panic",
 								    "abort",
 								    "segfault",
 								    "corrupt",
 								    "terminated",
 								    "unhandled",
 								    "stacktrace",
 								    "deadlock",
 								    "SIGSEGV",
 								    "SIGABRT",
 								    "stack overflow",
 								    "index out of bounds",
 								    "nil pointer dereference",
 								    "goroutine exit",
 								    "nil pointer",
 								    "runtime error",
 								    "goexit",
 								    "race condition",
 								    "double free",
 								]
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
 								METRICS_WITH_INITIAL_VALUE_ZERO = [
 								    "libp2p_peers",
 								    "libp2p_failed_upgrades_incoming_total",
 								    "libp2p_failed_upgrades_outgoing_total",
 								    "libp2p_total_dial_attempts_total",
 								    "libp2p_successful_dials_total",
 								    "libp2p_failed_dials_total",
 								    "waku_rln_messages_total_total",
 								    "waku_rln_spam_messages_total_total",
 								    "waku_rln_proof_verification_total_total",
 								    "waku_rln_number_registered_memberships",
 								    "waku_rln_proof_verification_duration_seconds",
 								    "waku_rln_proof_generation_duration_seconds",
 								    "waku_rln_instance_creation_duration_seconds",
 								    "waku_rln_membership_insertion_duration_seconds",
 								    "waku_rln_membership_credentials_import_duration_seconds",
-												chore: rln metric rename (#109)


											
										
										
											2025-03-18 09:30:27 +02:00
+								    "waku_rln_remaining_proofs_per_epoch",
 								    "waku_rln_total_generated_proofs",
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
+								    "libp2p_pubsub_sig_verify_success_total",
 								    "libp2p_pubsub_sig_verify_failure_total",
 								    "libp2p_pubsub_disconnects_over_non_priority_queue_limit_total",
 								    "libp2p_pubsub_peers",
 								    "libp2p_pubsub_unsubscriptions_total",
 								    "libp2p_pubsub_validation_success_total",
 								    "libp2p_pubsub_validation_failure_total",
 								    "libp2p_pubsub_validation_ignore_total",
 								    "libp2p_pubsub_broadcast_iwant_total",
 								    "libp2p_pubsub_received_iwant_total",
 								    "libp2p_gossipsub_cache_window_size",
 								    'libp2p_gossipsub_peers_per_topic_mesh{topic="other"}',
 								    'libp2p_gossipsub_peers_per_topic_fanout{topic="other"}',
 								    'libp2p_gossipsub_peers_per_topic_gossipsub{topic="other"}',
 								    "libp2p_gossipsub_low_peers_topics",
 								    "libp2p_gossipsub_healthy_peers_topics",
 								    "libp2p_gossipsub_failed_publish_total",
 								    "libp2p_gossipsub_invalid_topic_subscription_total",
 								    "libp2p_gossipsub_duplicate_during_validation_total",
 								    "libp2p_gossipsub_idontwant_saved_messages_total",
 								    "libp2p_gossipsub_duplicate_total",
 								    "libp2p_gossipsub_received_total",
 								    "libp2p_rendezvous_register_total",
 								    "libp2p_rendezvous_discover_total",
 								    "libp2p_rendezvous_registered",
 								    "libp2p_rendezvous_namespaces",
 								    "waku_peer_store_size",
 								    "waku_total_unique_peers",
 								    "presto_server_missing_requests_count",
 								    "presto_server_invalid_requests_count",
 								    'waku_archive_messages{type="stored"}',
 								    "waku_archive_insert_duration_seconds_sum",
 								    "waku_archive_insert_duration_seconds_count",
 								    'waku_archive_insert_duration_seconds_bucket{le="0.005"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.01"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.025"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.05"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.075"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.1"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.25"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.5"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="0.75"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="1.0"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="2.5"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="5.0"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="7.5"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="10.0"}',
 								    'waku_archive_insert_duration_seconds_bucket{le="+Inf"}',
 								    "waku_archive_query_duration_seconds_sum",
 								    "waku_archive_query_duration_seconds_count",
 								    'waku_archive_query_duration_seconds_bucket{le="0.005"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.01"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.025"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.05"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.075"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.1"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.25"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.5"}',
 								    'waku_archive_query_duration_seconds_bucket{le="0.75"}',
 								    'waku_archive_query_duration_seconds_bucket{le="1.0"}',
 								    'waku_archive_query_duration_seconds_bucket{le="2.5"}',
 								    'waku_archive_query_duration_seconds_bucket{le="5.0"}',
 								    'waku_archive_query_duration_seconds_bucket{le="7.5"}',
 								    'waku_archive_query_duration_seconds_bucket{le="10.0"}',
 								    'waku_archive_query_duration_seconds_bucket{le="+Inf"}',
 								    "waku_filter_subscriptions",
 								    "waku_filter_handle_message_duration_seconds_sum",
 								    "waku_filter_handle_message_duration_seconds_count",
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.005"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.01"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.025"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.05"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.075"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.1"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.25"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.5"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="0.75"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="1.0"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="2.5"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="5.0"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="7.5"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="10.0"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="+Inf"}',
 								    "discovery_session_lru_cache_hits_total",
 								    "discovery_session_lru_cache_misses_total",
 								    "discovery_session_decrypt_failures_total",
 								    "discovery_unsolicited_messages_total",
 								    "discovery_enr_auto_update_total",
 								    "waku_px_peers_received_total",
 								    "waku_px_peers_received_unknown",
-												updated metric name (#75)


											
										
										
											2024-10-04 09:09:40 +03:00
+								    "waku_px_peers_sent_total",
-												Fix CI issue (#156)

* Fix CI issue

* rename waku_px_peers_cached to waku_px_peers to match current software

* Fix CI issues

* Fix additional failing tests

* make relay = true
											
										
										
											2026-01-29 09:24:35 +03:00
+								    "waku_px_peers",
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
+								    "waku_histogram_message_size_sum",
 								    "waku_histogram_message_size_count",
 								    'waku_histogram_message_size_bucket{le="0.0"}',
-												chore: histogram metric update (#84)


											
										
										
											2024-10-31 10:11:25 +02:00
+								    'waku_histogram_message_size_bucket{le="1.0"}',
 								    'waku_histogram_message_size_bucket{le="3.0"}',
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
+								    'waku_histogram_message_size_bucket{le="5.0"}',
 								    'waku_histogram_message_size_bucket{le="15.0"}',
 								    'waku_histogram_message_size_bucket{le="50.0"}',
 								    'waku_histogram_message_size_bucket{le="75.0"}',
 								    'waku_histogram_message_size_bucket{le="100.0"}',
 								    'waku_histogram_message_size_bucket{le="125.0"}',
 								    'waku_histogram_message_size_bucket{le="150.0"}',
-												chore: histogram metric update (#84)


											
										
										
											2024-10-31 10:11:25 +02:00
+								    'waku_histogram_message_size_bucket{le="500.0"}',
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
+								    'waku_histogram_message_size_bucket{le="700.0"}',
 								    'waku_histogram_message_size_bucket{le="1000.0"}',
 								    'waku_histogram_message_size_bucket{le="+Inf"}',
 								    "waku_lightpush_peers",
 								    "waku_filter_peers",
 								    "waku_store_peers",
 								    "waku_px_peers",
 								    "waku_dnsdisc_discovered",
-												chore: add rendezvousPeerFoundTotal_total metric (#97)


											
										
										
											2024-12-20 04:22:36 +02:00
+								    "rendezvousPeerFoundTotal_total",
-												chore: add reconciliation metrics (#100)


											
										
										
											2025-01-27 14:44:15 +02:00
+								    "reconciliation_roundtrips_sum",
 								    "reconciliation_roundtrips_count",
-												chore: add reconciliation metrics (#113)


											
										
										
											2025-04-23 18:15:59 +03:00
+								    "reconciliation_differences_sum",
 								    "reconciliation_differences_count",
-												chore: add reconciliation metrics (#100)


											
										
										
											2025-01-27 14:44:15 +02:00
+								    'reconciliation_roundtrips_bucket{le="1.0"}',
 								    'reconciliation_roundtrips_bucket{le="2.0"}',
 								    'reconciliation_roundtrips_bucket{le="3.0"}',
 								    'reconciliation_roundtrips_bucket{le="5.0"}',
-												chore: add reconciliation metrics (#113)


											
										
										
											2025-04-23 18:15:59 +03:00
+								    'reconciliation_roundtrips_bucket{le="8.0"}',
 								    'reconciliation_roundtrips_bucket{le="13.0"}',
-												chore: add reconciliation metrics (#100)


											
										
										
											2025-01-27 14:44:15 +02:00
+								    'reconciliation_roundtrips_bucket{le="+Inf"}',
-												chore: add reconciliation metrics (#113)


											
										
										
											2025-04-23 18:15:59 +03:00
+								    'reconciliation_differences_bucket{le="0.0"}',
 								    'reconciliation_differences_bucket{le="10.0"}',
 								    'reconciliation_differences_bucket{le="50.0"}',
 								    'reconciliation_differences_bucket{le="100.0"}',
 								    'reconciliation_differences_bucket{le="500.0"}',
 								    'reconciliation_differences_bucket{le="1000.0"}',
 								    'reconciliation_differences_bucket{le="5000.0"}',
 								    'reconciliation_differences_bucket{le="+Inf"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="15.0"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="20.0"}',
 								    'waku_filter_handle_message_duration_seconds_bucket{le="30.0"}',
-												chore: messasge cache metric (#114)


											
										
										
											2025-04-25 09:43:57 +03:00
+								    "total_messages_cached",
-												chore: shard cpecific metrics (#131)


											
										
										
											2025-08-05 18:16:37 +03:00
+								    "waku_store_queries_total",
-												chore: maintenance (#137)


											
										
										
											2025-09-17 11:49:01 +03:00
+								    "mix_pool_size",
 								    "libp2p_gossipsub_imreceiving_saved_messages_total",
-												Maint/postgres payload size bytes (#144)

* fix readme

* add postgres_payload_size_bytes metric
											
										
										
											2025-12-08 13:55:17 +02:00
+								    "postgres_payload_size_bytes",
-												metrics tests (#68)


											
										
										
											2024-08-30 14:15:45 +03:00
+								]