mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
Improve frame handler event broadcast
This commit is contained in:
parent
63273b7f02
commit
32e1aa7edb
3 changed files with 4 additions and 5 deletions
|
@ -1,11 +1,14 @@
|
|||
import json
|
||||
import structlog
|
||||
|
||||
class EventManager:
|
||||
|
||||
def __init__(self, queues):
|
||||
self.queues = queues
|
||||
self.log = structlog.get_logger('Event Manager')
|
||||
|
||||
def broadcast(self, data):
|
||||
self.log.debug(f"Broadcasting event: {data}")
|
||||
for q in self.queues:
|
||||
q.put(data)
|
||||
|
||||
|
|
|
@ -44,6 +44,7 @@ class FrameHandler():
|
|||
def make_event(self):
|
||||
event = {
|
||||
"freedata": "modem-message",
|
||||
"received": self.details['frame']['frame_type'],
|
||||
"uuid": str(uuid.uuid4()),
|
||||
"timestamp": int(time.time()),
|
||||
"mycallsign": self.config['STATION']['mycall'],
|
||||
|
|
|
@ -4,11 +4,6 @@ import data_frame_factory
|
|||
|
||||
class PingFrameHandler(frame_handler.FrameHandler):
|
||||
|
||||
def make_event(self):
|
||||
event = super().make_event()
|
||||
event['ping'] = "received"
|
||||
return event
|
||||
|
||||
def follow_protocol(self):
|
||||
deconstructed_frame = self.details['frame']
|
||||
origin = deconstructed_frame["origin"]
|
||||
|
|
Loading…
Reference in a new issue