Skip to content

Commit 60c91ef

Browse files
Fix register callback
1 parent 7662a11 commit 60c91ef

File tree

2 files changed

+10
-6
lines changed

2 files changed

+10
-6
lines changed

nebula/core/engine.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -158,14 +158,10 @@ def __init__(
158158
)
159159

160160
# Register additional callbacks
161-
self._event_manager.register_event(
162-
(
163-
nebula_pb2.FederationMessage,
164-
nebula_pb2.FederationMessage.Action.REPUTATION,
165-
),
161+
self._event_manager.register_callback(
166162
self._reputation_callback,
163+
# ... add more callbacks here
167164
)
168-
# ... add more callbacks here
169165

170166
@property
171167
def cm(self):

nebula/core/eventmanager.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,14 @@ def _register_default_callbacks(self, default_callbacks):
4343
else:
4444
raise ValueError("The callback must be decorated with @event_handler.")
4545

46+
def register_callback(self, callback):
47+
"""Registers a callback for an event."""
48+
handler_info = getattr(callback, "_event_handler", None)
49+
if handler_info is not None:
50+
self.register_event(handler_info, callback)
51+
else:
52+
raise ValueError("The callback must be decorated with @event_handler.")
53+
4654
def register_event(self, handler_info, callback):
4755
"""Records a callback for a specific event."""
4856
if callable(callback):

0 commit comments

Comments
 (0)