Skip to content

Commit

Permalink
Just renaming
Browse files Browse the repository at this point in the history
  • Loading branch information
akadlec committed Dec 8, 2021
1 parent a2b0aba commit edcbbd8
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 12 deletions.
12 changes: 5 additions & 7 deletions fb_bus_connector_plugin/bootstrap.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ def create_container(logger: logging.Logger = logging.getLogger("dummy")) -> Non
)
di["fb-bus-connector-plugin_api-v1-parser"] = di[V1Parser]

# BUS client
# Communication client
di[Client] = Client()
di["fb-bus-connector-plugin_data-client-proxy"] = di[Client]

Expand All @@ -85,17 +85,15 @@ def create_container(logger: logging.Logger = logging.getLogger("dummy")) -> Non
di[DevicesPairing] = DevicesPairing() # type: ignore[call-arg]
di["fb-bus-connector-plugin_devices-pairing-proxy"] = di[DevicesPairing]

# Clients receivers
# Communication receivers
di[RegisterItemReceiver] = RegisterItemReceiver(
devices_registry=di[DevicesRegistry],
registers_registry=di[RegistersRegistry],
logger=di[Logger],
)
di["fb-bus-connector-plugin_registers-receiver"] = di[RegisterItemReceiver]

di[DeviceItemReceiver] = DeviceItemReceiver(devices_registry=di[DevicesRegistry], logger=di[Logger])
di["fb-bus-connector-plugin_device-receiver"] = di[DeviceItemReceiver]

di[PairingReceiver] = PairingReceiver(
devices_registry=di[DevicesRegistry],
registers_registry=di[RegistersRegistry],
Expand All @@ -107,7 +105,7 @@ def create_container(logger: logging.Logger = logging.getLogger("dummy")) -> Non
di[Receiver] = Receiver(parser=di[V1Parser], logger=di[Logger])
di["fb-bus-connector-plugin_receiver-proxy"] = di[Receiver]

# Clients publishers
# Data publishers
di[ApiV1Publisher] = ApiV1Publisher(
devices_registry=di[DevicesRegistry],
registers_registry=di[RegistersRegistry],
Expand All @@ -119,7 +117,7 @@ def create_container(logger: logging.Logger = logging.getLogger("dummy")) -> Non
di[Publisher] = Publisher() # type: ignore[call-arg]
di["fb-bus-connector-plugin_publisher-proxy"] = di[Publisher]

# Connector clients factory
# Communication client factory
di[ClientFactory] = ClientFactory(
client=di[Client],
receiver=di[Receiver],
Expand All @@ -136,7 +134,7 @@ def create_container(logger: logging.Logger = logging.getLogger("dummy")) -> Non
registers_registry=di[RegistersRegistry],
client=di[Client],
client_factory=di[ClientFactory],
pairing_handler=di[DevicesPairing],
pairing=di[DevicesPairing],
logger=di[Logger],
)
di["fb-bus-connector-plugin_connector"] = di[FbBusConnector]
10 changes: 5 additions & 5 deletions fb_bus_connector_plugin/connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ class FbBusConnector: # pylint: disable=too-many-instance-attributes,too-many-p
__client: Client
__client_factory: ClientFactory

__pairing_helper: DevicesPairing
__pairing: DevicesPairing

__logger: Logger

Expand All @@ -90,19 +90,19 @@ def __init__( # pylint: disable=too-many-arguments
registers_registry: RegistersRegistry,
client: Client,
client_factory: ClientFactory,
pairing_handler: DevicesPairing,
pairing: DevicesPairing,
logger: Logger,
) -> None:
self.__receiver = receiver
self.__publisher = publisher
self.__consumer = consumer
self.__pairing = pairing

self.__devices_registry = devices_registry
self.__registers_registry = registers_registry

self.__client = client
self.__client_factory = client_factory
self.__pairing_helper = pairing_handler

self.__logger = logger

Expand Down Expand Up @@ -459,8 +459,8 @@ def loop(self) -> None:
return

# Check is pairing enabled...
if self.__pairing_helper.is_enabled() is True:
self.__pairing_helper.loop()
if self.__pairing.is_enabled() is True:
self.__pairing.loop()

# Pairing is not enabled...
else:
Expand Down

0 comments on commit edcbbd8

Please sign in to comment.