Refactor whole importing hell into a nice and clean API

lib/tfw/networking/__init__.py

@@ -1,3 +1,7 @@
 # Copyright (C) 2018 Avatao.com Innovative Learning Kft.
 # All Rights Reserved. See LICENSE file for details.
 
+from .serialization import decode_if_needed, encode_if_needed, serialize_all, deserialize_all
+from .zmq_connector_base import ZMQConnectorBase
+from .controller_connector import ControllerConnector
+from .message_sender import MessageSender

lib/tfw/networking/controller_connector.py

@@ -5,7 +5,7 @@ import zmq
 from zmq.eventloop.zmqstream import ZMQStream
 
 from tfw.config import TFWENV
-from tfw.networking.zmq_connector_base import ZMQConnectorBase
+from tfw.networking import ZMQConnectorBase
 
 
 class ControllerConnector(ZMQConnectorBase):

lib/tfw/networking/event_handlers/__init__.py

@@ -1,3 +1,4 @@
 # Copyright (C) 2018 Avatao.com Innovative Learning Kft.
 # All Rights Reserved. See LICENSE file for details.
 
+from .server_connector import ServerConnector, ServerUplinkConnector, ServerDownlinkConnector

lib/tfw/networking/event_handlers/server_connector.py

@@ -6,9 +6,9 @@ from functools import partial
 import zmq
 from zmq.eventloop.zmqstream import ZMQStream
 
-from tfw.networking.serialization import serialize_all
+from tfw.networking import serialize_all
+from tfw.networking import ZMQConnectorBase
 from tfw.config import TFWENV
-from tfw.networking.zmq_connector_base import ZMQConnectorBase
 
 
 class ServerDownlinkConnector(ZMQConnectorBase):

lib/tfw/networking/message_sender.py

@@ -0,0 +1,21 @@
+# Copyright (C) 2018 Avatao.com Innovative Learning Kft.
+# All Rights Reserved. See LICENSE file for details.
+
+from datetime import datetime
+
+from tfw.networking.event_handlers import ServerUplinkConnector
+
+
+class MessageSender:
+    def __init__(self, custom_key: str = None):
+        self.server_connector = ServerUplinkConnector()
+        self.key = custom_key or 'message'
+
+    def send(self, originator, message):
+        data = {
+            'originator': originator,
+            'timestamp': datetime.now().isoformat(),
+            'message': message
+        }
+        response = {'data': data}
+        self.server_connector.send(self.key, response)

lib/tfw/networking/server/__init__.py

@@ -1,3 +1,7 @@
 # Copyright (C) 2018 Avatao.com Innovative Learning Kft.
 # All Rights Reserved. See LICENSE file for details.
 
+from .event_handler_connector import EventHandlerConnector, EventHandlerUplinkConnector, EventHandlerDownlinkConnector
+from .tfw_server import TFWServer
+from .zmq_websocket_handler import ZMQWebSocketProxy
+from .controller_responder import ControllerResponder

lib/tfw/networking/server/controller_responder.py

@@ -1,8 +1,7 @@
 # Copyright (C) 2018 Avatao.com Innovative Learning Kft.
 # All Rights Reserved. See LICENSE file for details.
 
-from tfw.networking.controller_connector import ControllerConnector
-from tfw.networking.serialization import deserialize_all, serialize_all
+from tfw.networking import deserialize_all, serialize_all, ControllerConnector
 
 
 class ControllerResponder:

lib/tfw/networking/server/event_handler_connector.py

@@ -4,8 +4,7 @@
 import zmq
 from zmq.eventloop.zmqstream import ZMQStream
 
-from tfw.networking.zmq_connector_base import ZMQConnectorBase
-from tfw.networking.serialization import serialize_all
+from tfw.networking import ZMQConnectorBase, serialize_all
 from tfw.config import TFWENV
 from tfw.config.logs import logging
 

lib/tfw/networking/server/tfw_server.py

@@ -5,10 +5,10 @@ from collections import defaultdict
 
 from tornado.web import Application
 
-from tfw.networking.server.zmq_websocket_handler import ZMQWebSocketProxy
-from tfw.networking.event_handlers.server_connector import ServerUplinkConnector
-from tfw.message_sender import MessageSender
+from tfw.networking import MessageSender
+from tfw.networking.event_handlers import ServerUplinkConnector
 from tfw.config.logs import logging
+from .zmq_websocket_handler import ZMQWebSocketProxy
 
 LOG = logging.getLogger(__name__)
 

lib/tfw/networking/server/zmq_websocket_handler.py

@@ -6,9 +6,9 @@ from abc import ABC, abstractmethod
 
 from tornado.websocket import WebSocketHandler
 
-from tfw.networking.serialization import deserialize_all
-from tfw.networking.server.event_handler_connector import EventHandlerConnector
+from tfw.networking import deserialize_all
 from tfw.config.logs import logging
+from .event_handler_connector import EventHandlerConnector
 
 LOG = logging.getLogger(__name__)