Bachelorarbeit-Rover/src/network.cpp

/**
 * @file network.cpp
 * @author Alexander Klein (alex@kleiax.de)
 * @brief Contains the implementation of the ststic class Network
 * @version 0.1
 * @date 2021-12-14
 * 
 * @copyright Copyright (c) 2021
 * 
 */

#include "network.h"

IPAddress Network::local_IP;
IPAddress Network::gateway;
IPAddress Network::subnet;
IPAddress Network::mqtt_server;
IPAddress Network::dnsServer;

WiFiClient Network::wifi_client;
PubSubClient* Network::mqtt_client;

esp_now_peer_info_t Network::peerInfo;
uint8_t Network::broadcastAddress[6] = ESP_NOW_CONTROLER_MAC;

void Network::setIps() {
    local_IP.fromString(WLAN_IP);
    gateway.fromString(WLAN_GATEWAY);
    subnet.fromString(WLAN_SUBNETMASK);
    mqtt_server.fromString(MQTT_SERVER);
    dnsServer.fromString(WLAN_DNS_SERVER);
}

void Network::setupMQTT() {
    Network::mqtt_client = new PubSubClient(wifi_client);
    Network::mqtt_client->setServer(MQTT_SERVER, MQTT_PORT);
    Network::mqtt_client->setSocketTimeout(1);
}

bool Network::connectMQTT() {
    #ifndef MQTT
        return false;
    #endif

    // Create a random client ID
    String clientId = "ESP32Rover-";
    clientId += String(random(0xffff), HEX);

    #ifdef MQTT_AUTH
        if (mqtt_client->connect(clientId.c_str(), MQTT_USER, MQTT_PASSWORD)) {
    #endif //MQTT_AUTH

    #ifndef MQTT_AUTH
        if (mqtt_client->connect(clientId.c_str())) {
    #endif //MQTT_AUTH

        // Once connected, publish an announcement...
        mqtt_client->publish("Rover/Info", "Connected to Mqtt-Broker");
    }
    return mqtt_client->connected();
}
bool Network::connectWifi() {
   // Configures static IP address
   
    if (!WiFi.mode(WIFI_AP_STA))
        std::cout << "Network::connectWiFi failed WiFi.mode" << std::endl;

    if (!WiFi.config(local_IP, gateway, subnet, dnsServer))
        std::cout << "STA Failed to configure" << std::endl;

    // Connect to Wi-Fi network with SSID and password
    std::cout << "Connecting to " << WLAN_SSID << std::endl;
    WiFi.begin(WLAN_SSID, WLAN_PASSWORD);
    uint8_t timeout = WLAN_CONNECT_TIMEOUT;
    while (WiFi.status() != WL_CONNECTED) {
        delay(WLAN_CONNECT_LOOP_TIME);
        std::cout << "." << std::flush;
        timeout--;
        if (timeout == 0) {
            std::cout << std::endl;
            std::cout << "WiFi NOT connected." << std::endl;
            return false;
        }
    }

    // Print local IP address and start web server
    std::cout << std::endl;
    std::cout << "WiFi connected." << std::endl;
    std::cout << "IP address: " << std::endl;
    std::cout << WLAN_IP << std::endl;
    // std::cout << "WiFi MAC Address: " << WiFi.macAddress() << std::endl << std::endl;
    return true;
}

bool Network::connectEspNow(recieveCallbackPtr reci, sendCallbackPtr send) {
    if (esp_now_init() != ESP_OK) {
        std::cout << "Network::connectEspNow - Error initializing ESP-NOW" << std::endl;
        return false;
    }

    esp_now_register_send_cb(send);

    memcpy(peerInfo.peer_addr, broadcastAddress, 6);
    peerInfo.channel = 0;  
    peerInfo.encrypt = false;

    if (esp_now_add_peer(&peerInfo) != ESP_OK) {
        std::cout << "Network::connectEspNow - Failed to add peer" << std::endl;
        return false;
    }

    esp_now_register_recv_cb(reci);
    return true;
}

bool Network::checkMQTT() {
    static uint64_t lastReconnectAttempt = 0;
    if (!mqtt_client->connected()) {
        long now = millis();
        if (now - lastReconnectAttempt > MQTT_TIME_RECONNECT) {
            lastReconnectAttempt = now;
            // Attempt to reconnect
            if (connectMQTT())
                lastReconnectAttempt = 0;
        }
        return false;
    }
    mqtt_client->loop();
    return true;
}

int32_t Network::getWiFiChannel(const char *ssid) {
    if (int32_t n = WiFi.scanNetworks())
        for (uint8_t i=0; i<n; i++)
            if (!strcmp(ssid, WiFi.SSID(i).c_str()))
                return WiFi.channel(i);
    return 0;
}

void Network::checkWiFi() {
    static uint64_t previousMillis = 0;
    static uint16_t delay = 5000;
    uint64_t currentMillis = millis();
    if ((WiFi.status() != WL_CONNECTED) && (currentMillis - previousMillis >= delay)) {
        std::cout << "Reconnecting to WiFi..." << std::endl;
        WiFi.disconnect();
        WiFi.reconnect();
        previousMillis = currentMillis;
    }

}

PubSubClient* Network::getMqttClient() {
    return mqtt_client;
}