First commit BLE

README.md

@@ -73,14 +73,21 @@ Example two serial ports:
       "port": 1,
       "samplingSeconds": 1,
       "description": "AGP",
-      "interface": "bluetooth"
+      "interface": "bluetooth-gps"
     },
     {
       "address": "E8:31:CD:5C:AC:B2",
       "port": 1,
       "samplingSeconds": 1,
       "description": "DBG",
-      "interface": "bluetooth"
+      "interface": "bluetooth-gps"
+    },
+    {
+      "address": "E8:31:CD:5C:AC:B2",
+      "port": 1,
+      "samplingSeconds": 1,
+      "description": "Logs from BLE",
+      "interface": "bluetooth-BLE"
     }
   ]
 }

examples/esp32-BLE/src/main.cpp

@@ -39,6 +39,8 @@ void setup() {
     pService->start();
     BLEAdvertising *pAdvertising = pServer->getAdvertising();
     pAdvertising->start();
+
+    Serial.println("START BLE SAMPLE");
 }
 
 void loop() {

requirements.txt

@@ -5,3 +5,5 @@ setuptools==57.5.0
 PyBluez==0.22
 RPi.GPIO==0.7.1
 keyboard==0.13.5
+bluepy
+pyserial

src/BLEConnector.py

@@ -0,0 +1,35 @@
+import threading
+from bluepy.btle import Scanner, DefaultDelegate
+
+class BLEConnector(threading.Thread):
+    def __init__(self, device_name):
+        self.device_name = device_name
+        self.service_uuid = None
+        self.characteristic_uuid = None
+    def run(self, service_uuid, characteristic_uuid):
+        self.service_uuid = service_uuid
+        self.characteristic_uuid = characteristic_uuid
+        self._process = p = threading.Thread(target=self._process)
+        p.daemon = True
+        p.start()
+
+    def _process(self):
+
+        while True:
+            try:
+                device = self.scan_devices()
+                if not device:
+                    continue
+                try:
+                    device.connect()
+                    services = device.getServices()
+                    for service in services:
+                        if service.uuid == self.service_uuid:
+                            characteristics = service.getCharacteristics()
+                            for char in characteristics:
+                                if char.uuid == self.characteristic_uuid:
+                                    data = char.read()
+                                    print(data)
+                    continue
+                except Exception as e:
+                    return None, str(e)

src/main.py

@@ -6,6 +6,7 @@
 
 from SerialLogger import logger
 from BluetoothGpsAgrinavi import BluetoothGpsAgrinavi
+from BLEConnector import BLEConnector
 
 sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 script_path = os.path.dirname(os.path.abspath(__file__))
@@ -58,7 +59,7 @@ def init_data_instances(datajson):
                     timeout=devices[index]['timeout'])
 
             # Bluetooth interface
-            elif "bluetooth" in devices[index]['interface']:
+            elif "bluetooth-gps" in devices[index]['interface']:
                 devs.append(
                     BluetoothGpsAgrinavi(
                         description=devices[index]['description'],
@@ -67,6 +68,19 @@ def init_data_instances(datajson):
                     port=devices[index]['port'],
                     address=devices[index]['address']
                 )
+
+            # Bluetooth BLE interface
+            elif "bluetooth-BLE" in devices[index]['interface']:
+
+                devs.append(
+                    BLEConnector(
+                        device_name=devices[index]['description']
+                    )
+                )
+                devs[index].run(
+                    service_uuid = devices[index]['service_uuid'],
+                    characteristic_uuid = devices[index]['characteristic_uuid'],
+                )
             else:
                 Exception("Invalid device")
         a = 1