119 lines
3.2 KiB
C++
119 lines
3.2 KiB
C++
/**
|
|
* @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;
|
|
|
|
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.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;
|
|
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;
|
|
}
|
|
|
|
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;
|
|
}
|