Merge pull request #9 from Andry925/fix/move-network-adapter-to-sdk-client

Moved network adapter code into sdk client module

Author: samson0v

network_adapter.py

@@ -21,10 +21,9 @@
 """
 
 import gc
+import sys
 from json import dumps, loads
 
-from network_adapter import NetworkAdapterFactory
-
 __version__ = "0.0.1"
 __repo__ = "https://github.com/samson0v/CircuitPython_thingsboard-client-sdk.git"
 
@@ -36,6 +35,54 @@
 CLAIMING_TOPIC = "v1/devices/me/claim"
 
 
+class NetworkAdapter:
+    def get_socket_pool(self):
+        pass
+
+    def get_ssl_context(self):
+        pass
+
+
+class CircuitPythonNetworkAdapter(NetworkAdapter):
+    def __init__(self):
+        import socketpool
+        import wifi
+
+        self._pool = socketpool.SocketPool(wifi.radio)
+
+    def get_socket_pool(self):
+        return self._pool
+
+    def get_ssl_context(self):
+        return None
+
+
+class CPythonNetworkAdapter(NetworkAdapter):
+    def __init__(self):
+        import adafruit_connection_manager
+        from adafruit_connection_manager import CPythonNetwork
+
+        radio = CPythonNetwork()
+        self._pool = adafruit_connection_manager.get_radio_socketpool(radio)
+        self._ssl_context = adafruit_connection_manager.get_radio_ssl_context(radio)
+
+    def get_socket_pool(self):
+        return self._pool
+
+    def get_ssl_context(self):
+        return self._ssl_context
+
+
+class NetworkAdapterFactory:
+    @staticmethod
+    def create():
+        if sys.implementation.name == "circuitpython":
+            print("Using CircuitPython network adapter")
+            return CircuitPythonNetworkAdapter()
+        print("Using CPython network adapter")
+        return CPythonNetworkAdapter()
+
+
 class TBDeviceMqttClient:
     def __init__(
         self,