LoRa_APRS_Tracker111/src/ble_utils.cpp

#include <NimBLEDevice.h>
#include "configuration.h"
#include "ax25_utils.h"
#include "lora_utils.h"
#include "ble_utils.h"
#include "display.h"
#include "logger.h"


#define SERVICE_UUID            "00000001-ba2a-46c9-ae49-01b0961f68bb"
#define CHARACTERISTIC_UUID_TX  "00000003-ba2a-46c9-ae49-01b0961f68bb"
#define CHARACTERISTIC_UUID_RX  "00000002-ba2a-46c9-ae49-01b0961f68bb"

BLEServer *pServer;
BLECharacteristic *pCharacteristicTx;
BLECharacteristic *pCharacteristicRx;

extern Configuration    Config;
extern logging::Logger  logger;
extern bool             sendBleToLoRa;
extern bool             bluetoothConnected;
extern String           BLEToLoRaPacket;


class MyServerCallbacks : public NimBLEServerCallbacks {
    void onConnect(NimBLEServer* pServer) {
        bluetoothConnected = true;
        logger.log(logging::LoggerLevel::LOGGER_LEVEL_INFO, "BLE", "%s", "BLE Client Connected");
    }

    void onDisconnect(NimBLEServer* pServer) {
        bluetoothConnected = false;
        logger.log(logging::LoggerLevel::LOGGER_LEVEL_INFO, "BLE", "%s", "BLE client Disconnected, Started Advertising");
        pServer->startAdvertising();
    }
};

class MyCallbacks : public NimBLECharacteristicCallbacks {
    void onWrite(NimBLECharacteristic *pCharacteristic) {
        std::string receivedData = pCharacteristic->getValue();
        String receivedString = "";
        for (int i = 0; i < receivedData.length(); i++) {
            //Serial.print(receivedData[i],HEX); // delete
            //Serial.print(" ");
            receivedString += receivedData[i];
        }
        if (Config.bluetoothType == 0) {
            BLEToLoRaPacket = AX25_Utils::AX25FrameToLoRaPacket(receivedString);
        } else if (Config.bluetoothType == 2) {
            BLEToLoRaPacket = receivedString;
        }
        sendBleToLoRa = true;
    }
};


namespace BLE_Utils {

    void stop() {
        BLEDevice::deinit();
    }
  
    void setup() {
        uint8_t dmac[6];
        esp_efuse_mac_get_default(dmac);
        std::string BLEid = "LoRa Tracker " + std::to_string(dmac[4]) + std::to_string(dmac[5]);
        BLEDevice::init(BLEid);
        pServer = BLEDevice::createServer();
        pServer->setCallbacks(new MyServerCallbacks());

        BLEService *pService = pServer->createService(SERVICE_UUID);

        pCharacteristicTx = pService->createCharacteristic(
                              CHARACTERISTIC_UUID_TX,
                              NIMBLE_PROPERTY::READ | NIMBLE_PROPERTY::NOTIFY
                            );
        pCharacteristicRx = pService->createCharacteristic(
                              CHARACTERISTIC_UUID_RX,
                              NIMBLE_PROPERTY::WRITE | NIMBLE_PROPERTY::WRITE_NR
                            );

        pCharacteristicRx->setCallbacks(new MyCallbacks());

        pService->start();

        BLEAdvertising* pAdvertising = BLEDevice::getAdvertising();
        pAdvertising->addServiceUUID(SERVICE_UUID);
        pServer->getAdvertising()->setScanResponse(true);
        pServer->getAdvertising()->setMinPreferred(0x06);
        pServer->getAdvertising()->setMaxPreferred(0x0C);

        pAdvertising->start();

        logger.log(logging::LoggerLevel::LOGGER_LEVEL_DEBUG, "BLE", "%s", "Waiting for BLE central to connect...");
    }

    void sendToLoRa() {
        if (!sendBleToLoRa) {
            return;
        }
        logger.log(logging::LoggerLevel::LOGGER_LEVEL_DEBUG, "BLE Tx", "%s", BLEToLoRaPacket.c_str());
        show_display("BLE Tx >>", "", BLEToLoRaPacket, 1000);
        LoRa_Utils::sendNewPacket(BLEToLoRaPacket);
        BLEToLoRaPacket = "";
        sendBleToLoRa = false;
    }

    void txBLE(uint8_t p) {
        pCharacteristicTx->setValue(&p,1);
        pCharacteristicTx->notify();
        delay(3);
    }

    void txToPhoneOverBLE(const String& frame) {
        if (Config.bluetoothType == 0) {
            txBLE((byte)KissChar::Fend);
            txBLE((byte)KissCmd::Data);
        }        
        for(int n = 0; n < frame.length(); n++) {
            uint8_t byteCharacter = frame[n];
            if (Config.bluetoothType == 2) {
                txBLE(byteCharacter);
            } else {
                if (byteCharacter == KissChar::Fend) {
                    txBLE((byte)KissChar::Fesc);
                    txBLE((byte)KissChar::Tfend);
                } else if (byteCharacter == KissChar::Fesc) {
                    txBLE((byte)KissChar::Fesc);
                    txBLE((byte)KissChar::Tfesc);
                } else {
                    txBLE(byteCharacter);
                }
            }    
        }
        if (Config.bluetoothType == 0) {
            txBLE((byte)KissChar::Fend);
        } else if (Config.bluetoothType == 2) {
            txBLE('\n');
        }   
    }

    void sendToPhone(const String& packet) {
        if (!packet.isEmpty() && bluetoothConnected) {
            logger.log(logging::LoggerLevel::LOGGER_LEVEL_DEBUG, "BLE Rx", "%s", packet.c_str());
            String receivedPacketString = "";
            for (int i = 0; i < packet.length(); i++) {
                receivedPacketString += packet[i];
            }
            if (Config.bluetoothType == 0) {
                txToPhoneOverBLE(AX25_Utils::LoRaPacketToAX25Frame(receivedPacketString));
            } else if (Config.bluetoothType == 2) {
                txToPhoneOverBLE(receivedPacketString);                
            }
        }
    }

}