mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
Just use structlog on Command classes
This commit is contained in:
parent
1917ec077d
commit
6877e950ad
2 changed files with 4 additions and 3 deletions
|
@ -1,12 +1,13 @@
|
||||||
from data_frame_factory import DataFrameFactory
|
from data_frame_factory import DataFrameFactory
|
||||||
import queue
|
import queue
|
||||||
from codec2 import FREEDV_MODE
|
from codec2 import FREEDV_MODE
|
||||||
|
import structlog
|
||||||
|
|
||||||
class TxCommand():
|
class TxCommand():
|
||||||
|
|
||||||
def __init__(self, config, logger, state_manager, modem_events, apiParams = {}):
|
def __init__(self, config, state_manager, modem_events, apiParams = {}):
|
||||||
self.config = config
|
self.config = config
|
||||||
self.logger = logger
|
self.logger = structlog.get_logger("Command")
|
||||||
self.state_manager = state_manager
|
self.state_manager = state_manager
|
||||||
self.modem_events = modem_events
|
self.modem_events = modem_events
|
||||||
self.set_params_from_api(apiParams)
|
self.set_params_from_api(apiParams)
|
||||||
|
|
|
@ -82,7 +82,7 @@ def validate(req, param, validator, isRequired = True):
|
||||||
|
|
||||||
# Takes a transmit command and puts it in the transmit command queue
|
# Takes a transmit command and puts it in the transmit command queue
|
||||||
def enqueue_tx_command(cmd_class, params = {}):
|
def enqueue_tx_command(cmd_class, params = {}):
|
||||||
command = cmd_class(app.config_manager.read(), app.logger, app.state_manager, app.modem_events, params)
|
command = cmd_class(app.config_manager.read(), app.state_manager, app.modem_events, params)
|
||||||
command.run(app.modem_events, app.service_manager.modem.modem_transmit_queue)
|
command.run(app.modem_events, app.service_manager.modem.modem_transmit_queue)
|
||||||
app.logger.info(f"Command {command.get_name()} enqueued.")
|
app.logger.info(f"Command {command.get_name()} enqueued.")
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue