p15670423
/
monkey
1
0
Fork 5
Code Issues Pull Requests 3 Projects Releases Wiki Activity

Common: Make INTERNAL_ALL_EVENT_TYPES_TOPIC private to the module

This commit is contained in:
Mike Salvatore 2022-08-10 09:15:13 -04:00
parent 43e45e14ad
commit c26c7403a6
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
monkey/common/event_queue/pypubsub_event_queue.py
View File

@ -6,7 +6,7 @@ from common.events import AbstractEvent
from .i_event_queue import IEventQueue from .i_event_queue import IEventQueue
INTERNAL_ALL_EVENT_TYPES_TOPIC = "internal_all_event_types" _INTERNAL_ALL_EVENT_TYPES_TOPIC = "internal_all_event_types"
class PyPubSubEventQueue(IEventQueue): class PyPubSubEventQueue(IEventQueue):
@ -15,7 +15,7 @@ class PyPubSubEventQueue(IEventQueue):
def subscribe_all_events(self, subscriber: Callable[[AbstractEvent], None]): def subscribe_all_events(self, subscriber: Callable[[AbstractEvent], None]):
self._pypubsub_publisher.subscribe( self._pypubsub_publisher.subscribe(
listener=subscriber, topicName=INTERNAL_ALL_EVENT_TYPES_TOPIC listener=subscriber, topicName=_INTERNAL_ALL_EVENT_TYPES_TOPIC
) )
def subscribe_type( def subscribe_type(
@ -33,7 +33,7 @@ class PyPubSubEventQueue(IEventQueue):
self._publish_to_tags_topic(event) self._publish_to_tags_topic(event)
def _publish_to_all_events_topic(self, event: AbstractEvent): def _publish_to_all_events_topic(self, event: AbstractEvent):
self._pypubsub_publisher.sendMessage(INTERNAL_ALL_EVENT_TYPES_TOPIC, event=event) self._pypubsub_publisher.sendMessage(_INTERNAL_ALL_EVENT_TYPES_TOPIC, event=event)
def _publish_to_type_topic(self, event: AbstractEvent): def _publish_to_type_topic(self, event: AbstractEvent):
self._pypubsub_publisher.sendMessage(event.__name__, event=event) self._pypubsub_publisher.sendMessage(event.__name__, event=event)

5
monkey/tests/unit_tests/common/event_queue/test_pypubsub_event_queue.py
View File

@ -3,10 +3,7 @@ from dataclasses import dataclass
import pytest import pytest
from pubsub import pub from pubsub import pub
from common.event_queue.pypubsub_event_queue import ( from common.event_queue.pypubsub_event_queue import PyPubSubEventQueue
INTERNAL_ALL_EVENT_TYPES_TOPIC,
PyPubSubEventQueue,
)
from common.events import AbstractEvent from common.events import AbstractEvent
EVENT_TAG_1 = "event tag 1" EVENT_TAG_1 = "event tag 1"