LoRa_APRS_iGate/src/query_utils.cpp

#include "configuration.h"
#include "battery_utils.h"
#include "station_utils.h"
#include "query_utils.h"
#include "lora_utils.h"


extern Configuration                    Config;
extern std::vector<LastHeardStation>    lastHeardStations;
extern String                           versionDate;
extern int                              rssi;
extern float                            snr;
extern int                              freqError;
extern bool                             shouldSleepLowVoltage;
extern bool                             saveNewDigiEcoModeConfig;


namespace QUERY_Utils {

    String process(const String& query, const String& station, bool queryFromAPRSIS, bool thirdParty) {
        String answer;
        String queryQuestion = query;
        queryQuestion.toUpperCase();
        if (queryQuestion == "?APRS?" || queryQuestion == "H" || queryQuestion == "HELP" || queryQuestion=="?") {
            answer.concat("?APRSV ?APRSP ?APRSL ?APRSSSR ?EM=? ?TX=? "); // ?APRSH ?WHERE callsign
        } else if (queryQuestion == "?APRSV") {
            answer.concat("CA2RXU_LoRa_iGate 2.3 v");
            answer.concat(versionDate);
        } else if (queryQuestion == "?APRSP") {
            answer.concat("iGate QTH: ");
            answer.concat(String(Config.beacon.latitude,3));
            answer.concat(" ");
            answer.concat(String(Config.beacon.longitude,3));
        } else if (queryQuestion == "?APRSL") {
            if (lastHeardStations.size() == 0) {
                char answerArray[50];
                snprintf(answerArray, sizeof(answerArray), "No Station Listened in the last %d min.", Config.rememberStationTime);
                answer.concat(answerArray);
            } else {
                for (int i=0; i<lastHeardStations.size(); i++) {
                    answer += lastHeardStations[i].station + " ";
                }
                answer.trim();
            }
        } else if (queryQuestion == "?APRSSR") {
            char signalData[35];
            snprintf(signalData, sizeof(signalData), " %ddBm / %.2fdB / %dHz", rssi, snr, freqError);
            answer.concat(signalData);        
        } /*else if (queryQuestion.indexOf("?APRSH") == 0) {
            // sacar callsign despues de ?APRSH
            Serial.println("escuchaste a X estacion? en las ultimas 24 o 8 horas?");
            answer.concat("?APRSH on development 73!");
        } *//*else if (queryQuestion.indexOf("?WHERE") == 0) { 
            // agregar callsign para completar donde esta X callsign --> posicion
            Serial.println("estaciones escuchadas directo (ultimos 30 min)");
            answer.concat("?WHERE on development 73!");
        } */
        else if (STATION_Utils::isManager(station) && (!queryFromAPRSIS || !Config.remoteManagement.rfOnly)) {
            if (queryQuestion.indexOf("?EM=OFF") == 0) {
                if ((Config.digi.mode == 2 || Config.digi.mode == 3) && Config.loramodule.txActive && Config.loramodule.rxActive && !Config.aprs_is.active) {
                    if (Config.digi.ecoMode) {    // Exit Digipeater EcoMode
                        answer = "DigiEcoMode:OFF";
                        Config.digi.ecoMode         = false;
                        Config.display.alwaysOn     = true;
                        Config.display.timeout      = 10;
                        shouldSleepLowVoltage       = true;     // to make sure all packets in outputPacketBuffer are sended before restart.
                        saveNewDigiEcoModeConfig    = true;
                    } else {
                        answer = "DigiEcoMode was OFF";
                    }
                } else {
                    answer = "DigiEcoMode control not possible";
                }
            } else if (queryQuestion.indexOf("?EM=ON") == 0) {
                if ((Config.digi.mode == 2 || Config.digi.mode == 3) && Config.loramodule.txActive && Config.loramodule.rxActive && !Config.aprs_is.active) {
                    if (!Config.digi.ecoMode) {     // Start Digipeater EcoMode
                        answer = "DigiEcoMode:ON";
                        Config.digi.ecoMode         = true;
                        shouldSleepLowVoltage       = true;     // to make sure all packets in outputPacketBuffer are sended before restart.
                        saveNewDigiEcoModeConfig    = true;
                    } else {
                        answer = "DigiEcoMode was ON";
                    }
                } else {
                    answer = "DigiEcoMode control not possible";
                }
            } else if (queryQuestion.indexOf("?EM=?") == 0) {    // Digipeater EcoMode Status
                answer = (Config.digi.ecoMode) ? "DigiEcoMode:ON" : "DigiEcoMode:OFF";
            } else  if (queryQuestion.indexOf("?TX=ON") == 0) {
                if (Config.loramodule.txActive) {
                    answer = "TX was ON";
                } else {
                    Config.loramodule.txActive = true;
                    answer = "TX=ON";
                }
            } else if (queryQuestion.indexOf("?TX=OFF") == 0) {
                if (!Config.loramodule.txActive) {
                    answer = "TX was OFF";
                } else {
                    Config.loramodule.txActive = false;
                    answer = "TX=OFF";
                } 
            } else if (queryQuestion.indexOf("?TX=?") == 0) {
                answer = (Config.loramodule.txActive) ? "TX=ON" : "TX=OFF";
            } else if (queryQuestion.indexOf("?COMMIT") == 0) {     // saving for next reboot
                answer = "New Config Saved";
                Config.writeFile();
            }
        }
        
        if (answer == "") return "";

        String queryAnswer = Config.callsign;
        queryAnswer += ">APLRG1";
        if (queryFromAPRSIS) {
            queryAnswer += ",TCPIP,qAC";
        } else {
            if (!thirdParty) queryAnswer += ",RFONLY";
            if (Config.beacon.path != "") {
                queryAnswer += ",";
                queryAnswer += Config.beacon.path;
            }
        }
        queryAnswer += "::";

        String processedStation = station;
        for (int i = station.length(); i < 9; i++) {
            processedStation += ' ';
        }
        queryAnswer += processedStation;
        queryAnswer += ":";
        queryAnswer += answer;

        queryAnswer += " *";
        queryAnswer += char(random(97, 123));
        queryAnswer += char(random(97, 123));
        queryAnswer += "*";
        return queryAnswer;
    }

}