Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › kernel › test_event_bus_extended

Tests reference — tests/kernel/test_event_bus_extended.py

Module of tests/kernel, split out because the directory page would be too large.

Prose pending.

tests/kernel/test_event_bus_extended.py

source · 18 tests · 436 lines

Covers: kernel.event_bus, core.interfaces/ (package)

Kind Name Line Description
function test_close_with_active_redis 99 close acloses the Redis client and clears the reference.
function test_subscriber_count_all_with_active_subs 111 subscriber_count with no pattern counts all active subscribers.
function test_find_matching_handlers_skips_expired 127 Expired subscriptions are skipped during matching.
function test_find_matching_handlers_skips_non_matching_topic 138 Subscriptions with non-matching topic patterns are skipped.
function test_emit_mixed_handlers_event_count 154 Only successful handlers increment event_count; failures are logged.
function test_publish_to_redis_success 182 _publish_to_redis publishes to channel and stream when Redis is up.
function test_emit_publishes_to_redis 195 emit delivers in-process and also publishes to Redis.
function test_replay_success 219 replay reads stream entries and delivers matching events.
function test_replay_with_count 247 replay respects the count limit.
function test_replay_since_future_returns_nothing 274 replay with since in the future returns no events.
function test_replay_skips_non_matching_topic 301 replay only delivers events whose type matches the topic pattern.
function test_subscribe_with_explicit_subscriber_id 332 subscribe accepts an explicit subscriber_id.
function test_subscribe_with_positive_ttl 342 subscribe with ttl_seconds sets expires_at in the future.
function test_deserialize_stream_entry_missing_payload_key 358 _deserialize_stream_entry handles missing payload key.
function test_deserialize_stream_entry_none_payload 372 _deserialize_stream_entry handles None payload (TypeError path).
function test_deserialize_stream_entry_missing_correlation_id_defaults_none 387 Missing correlation_id defaults to None instead of empty string.
function test_deserialize_stream_entry_defaults_for_missing_fields 401 _deserialize_stream_entry supplies defaults for missing id/type/source/severity.
function test_emit_multiple_subscribers_partial_match 419 Only subscribers with matching patterns receive the event.