LoRa_APRS_iGate/src/utils.cpp

#include <ESPAsyncWebServer.h>
#include <AsyncElegantOTA.h>
#include <AsyncTCP.h>
#include <SPIFFS.h>
#include <WiFi.h>
#include "configuration.h"
#include "syslog_utils.h"
#include "pins_config.h"
#include "wifi_utils.h"
#include "lora_utils.h"
#include "display.h"
#include "utils.h"


AsyncWebServer  server(80);

extern WiFiClient           espClient;
extern Configuration        Config;
extern String               versionDate;
extern bool                 statusAfterBoot;
extern String               firstLine;
extern String               secondLine;
extern String               thirdLine;
extern String               fourthLine;
extern String               fifthLine;
extern String               sixthLine;
extern String               seventhLine;
extern String               eigthLine;
extern uint32_t             lastBeaconTx;
extern uint32_t             lastScreenOn;
extern bool                 beacon_update;
extern int                  stationMode;
extern String               iGateBeaconPacket;
extern std::vector<String>  lastHeardStation;

namespace Utils {

void processStatus() {
    String status = Config.callsign + ">APLRG1";
    if (stationMode==1 || stationMode==2) {
        delay(1000);
        status += ",qAC:>https://github.com/richonguzman/LoRa_APRS_iGate";
        espClient.write((status + "\n").c_str());
        SYSLOG_Utils::log("APRSIS Tx", status,0,0,0);
    } else {
        delay(5000);
        status += ":>https://github.com/richonguzman/LoRa_APRS_iGate";
        if (stationMode == 4) {
            LoRa_Utils::changeFreqTx();
        }
        LoRa_Utils::sendNewPacket("APRS", status);
        if (stationMode == 4) {
            LoRa_Utils::changeFreqRx();
        }        
    }
    statusAfterBoot = false;
}

String getLocalIP() {
    return "IP :  " + String(WiFi.localIP()[0]) + "." + String(WiFi.localIP()[1]) + "." + String(WiFi.localIP()[2]) + "." + String(WiFi.localIP()[3]);
}

void setupDiplay() {
    setup_display();
    digitalWrite(greenLed,HIGH);
    Serial.println("\nStarting iGate: " + Config.callsign + "   Version: " + versionDate);
    show_display("", "   LoRa APRS iGate", "", "    Richonguzman", "", "    -- CD2RXU --", "", "     " + versionDate, 4000);
    digitalWrite(greenLed,LOW);
    firstLine   = "LoRa iGate: " + Config.callsign;
    if (stationMode==3 || stationMode==4) {
        secondLine = "<DigiRepeater Active>";
    } else {
        secondLine  = "";
    }
    seventhLine = "";
    eigthLine  = "     listening...";
}

void checkBeaconInterval() {
    uint32_t lastTx = millis() - lastBeaconTx;
    if (lastTx >= Config.beaconInterval*60*1000) {
        beacon_update = true;    
    }
    if (beacon_update) {
        display_toggle(true);
        Serial.println("---- Sending iGate Beacon ----");
        if (stationMode==1 || stationMode==2) {
            thirdLine = getLocalIP();
            if (lastHeardStation.size() < 10) {
                fifthLine = "Stations (30min) =  " + String(lastHeardStation.size());
            } else {
                fifthLine = "Stations (30min) = " + String(lastHeardStation.size());
            }
            //fifthLine = "";
            sixthLine = "";
            seventhLine = "";
            show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine, "SENDING iGate BEACON", 1000);         
            eigthLine = "     listening...";
            espClient.write((iGateBeaconPacket + "\n").c_str());
            show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine, eigthLine, 0);
        } else if (stationMode==3 || stationMode==4) {
            fifthLine = "";
            sixthLine = "";
            seventhLine = "";
            show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine, "SENDING iGate BEACON", 0);
            eigthLine = "     listening...";
            if (stationMode == 4) {
                LoRa_Utils::changeFreqTx();
            }
            LoRa_Utils::sendNewPacket("APRS",iGateBeaconPacket);
            if (stationMode == 4) {
                LoRa_Utils::changeFreqRx();
            }           
        }
        lastBeaconTx = millis();
        lastScreenOn = millis();
        beacon_update = false;
    }
    if (statusAfterBoot) {
        processStatus();
    }
}

void checkDisplayInterval() {
    uint32_t lastDisplayTime = millis() - lastScreenOn;
    if (!Config.display.alwaysOn) {
        if (lastDisplayTime >= Config.display.timeout*1000) {
            display_toggle(false);
        }
    }
}

void validateDigiFreqs() {
    if (stationMode == 4) {
        if (abs(Config.loramodule.digirepeaterTxFreq - Config.loramodule.digirepeaterRxFreq) < 125000) {
            Serial.println("Tx Freq less than 125kHz from Rx Freq ---> NOT VALID, check 'data/igate_conf.json'");
            show_display("Tx Freq is less than ", "125kHz from Rx Freq", "change it on : /data/", "igate_conf.json", 0);
            while (1);
        }
    }
}

void typeOfPacket(String packet, String packetType) {
    String sender;
    if (stationMode==1 || stationMode==2) {
        if (packetType == "LoRa-APRS") {
            sixthLine = "LoRa Rx ----> APRS-IS";
        } else if (packetType == "APRS-LoRa") {
            sixthLine = "APRS-IS ----> LoRa Tx";
        }
        sender = packet.substring(0,packet.indexOf(">"));
    } else {
        sixthLine = "LoRa Rx ----> LoRa Tx";
        sender = packet.substring(3,packet.indexOf(">"));
    }
    for (int i=sender.length();i<9;i++) {
        sender += " ";
    }
    if (packet.indexOf("::") >= 10) {
        if (packetType == "APRS-LoRa") {
            String addresseeAndMessage = packet.substring(packet.indexOf("::")+2);
            String addressee = addresseeAndMessage.substring(0, addresseeAndMessage.indexOf(":"));
            addressee.trim();
            seventhLine = sender + " > " + addressee;
            Serial.println("mensaje desde " + seventhLine);
        } else {
            seventhLine = sender + "> MESSAGE";
        }
        eigthLine = "RSSI: 38dBm SNR: 6dBm";
    } else if (packet.indexOf(":>") >= 10) {
        seventhLine = sender + "> NEW STATUS";
        eigthLine = "RSSI: 38dBm SNR: 6dBm";
    } else if (packet.indexOf(":!") >= 10 || packet.indexOf(":=") >= 10) {
        seventhLine = sender + "> GPS BEACON";
        eigthLine = "RSSI:38dBm  D: 25.6km";
    } else {
        seventhLine = sender + "> ??????????";
        eigthLine = "RSSI: 38dBm SNR: 6dBm";
    }
}

void startOTAServer() {
    if (stationMode==1 || stationMode==2) {
        server.on("/", HTTP_GET, [](AsyncWebServerRequest *request) {
        request->send(200, "text/plain", "Hi " + Config.callsign + ", this is your (Richonguzman/CD2RXU) LoRa iGate.\n\nTo update your firmware or filesystem go to: http://" + getLocalIP().substring(getLocalIP().indexOf(":")+2) + "/update\n\n\n73!");
        });
        AsyncElegantOTA.begin(&server);
        server.begin();
        Serial.println("HTTP server started (OTA Firmware Updates)!\n");
    }
}

}