LoRa_APRS_iGate/src/aprs_is_utils.cpp

#include <WiFi.h>
#include "configuration.h"
#include "aprs_is_utils.h"
#include "station_utils.h"
#include "syslog_utils.h"
#include "query_utils.h"
#include "lora_utils.h"
#include "digi_utils.h"
#include "display.h"
#include "utils.h"

extern Configuration  Config;
extern WiFiClient     espClient;
extern int            internalLedPin;
extern uint32_t       lastScreenOn;
extern String         firstLine;
extern String         secondLine;
extern String         thirdLine;
extern String         fourthLine;
extern String         fifthLine;
extern String         sixthLine;
extern String         seventhLine;


namespace APRS_IS_Utils {

    void upload(String line) {
        espClient.print(line + "\r\n");
    }

    void connect(){
        int count = 0;
        String aprsauth;
        Serial.print("Connecting to APRS-IS ...     ");
        while (!espClient.connect(Config.aprs_is.server.c_str(), Config.aprs_is.port) && count < 20) {
            Serial.println("Didn't connect with server...");
            delay(1000);
            espClient.stop();
            espClient.flush();
            Serial.println("Run client.stop");
            Serial.println("Trying to connect with Server: " + String(Config.aprs_is.server) + " AprsServerPort: " + String(Config.aprs_is.port));
            count++;
            Serial.println("Try: " + String(count));
        }
        if (count == 20) {
            Serial.println("Tried: " + String(count) + " FAILED!");
        } else {
            Serial.println("Connected!\n(Server: " + String(Config.aprs_is.server) + " / Port: " + String(Config.aprs_is.port) +")");

            // String filter = "t/m/" + Config.callsign + "/" + (String)Config.aprs_is.reportingDistance;

            aprsauth = "user " + Config.callsign + " pass " + Config.aprs_is.passcode + " vers CA2RXU_LoRa_iGate 1.3 filter " + Config.aprs_is.filter;
            upload(aprsauth);
            delay(200);
        }
    }

    void checkStatus() {
        String wifiState, aprsisState;
        if (WiFi.status() == WL_CONNECTED) {
            wifiState = "OK"; 
        } else {
            wifiState = "AP";

            if (!Config.display.alwaysOn) {
                display_toggle(true);
            }

            lastScreenOn = millis();
        }

        if (!Config.aprs_is.active) {
            aprsisState = "OFF"; 
        } else if (espClient.connected()) {
            aprsisState = "OK"; 
        } else {
            aprsisState = "--";

            if (!Config.display.alwaysOn) {
                display_toggle(true);
            }

            lastScreenOn = millis();
        }

        secondLine = "WiFi: " + wifiState + " APRS-IS: " + aprsisState;
    }

    String createPacket(String packet) {
        if (!(Config.aprs_is.active && Config.digi.mode == 0)) { // Check if NOT only IGate
            return packet.substring(3, packet.indexOf(":")) + ",qAR," + Config.callsign + packet.substring(packet.indexOf(":"));
        } else {
            return packet.substring(3, packet.indexOf(":")) + ",qAO," + Config.callsign + packet.substring(packet.indexOf(":"));
        }
    }

    void processLoRaPacket(String packet) {
        bool queryMessage = false;
        String aprsPacket, Sender, AddresseeAndMessage, Addressee, ackMessage, receivedMessage;
        if (packet != "") {
            #ifdef TextSerialOutputForApp
            Serial.println(packet.substring(3));
            #else
            Serial.print("Received Lora Packet   : " + String(packet));
            #endif    
            if ((packet.substring(0,3) == "\x3c\xff\x01") && (packet.indexOf("TCPIP") == -1) && (packet.indexOf("NOGATE") == -1) && (packet.indexOf("RFONLY") == -1)) {
                #ifndef TextSerialOutputForApp
                Serial.print("   ---> APRS LoRa Packet!");
                #endif
                Sender = packet.substring(3,packet.indexOf(">"));
                if (Sender != Config.callsign) {   // avoid listening yourself by digirepeating
                    AddresseeAndMessage = packet.substring(packet.indexOf("::")+2);  
                    Addressee = AddresseeAndMessage.substring(0,AddresseeAndMessage.indexOf(":"));
                    Addressee.trim();
                    
                    if (packet.indexOf("::") > 10 && Addressee == Config.callsign) {      // its a message for me!
                        if (AddresseeAndMessage.indexOf("{")>0) {     // ack?
                            ackMessage = "ack" + AddresseeAndMessage.substring(AddresseeAndMessage.indexOf("{")+1);
                            ackMessage.trim();
                            delay(4000);
                            //Serial.println(ackMessage);
                            for(int i = Sender.length(); i < 9; i++) {
                                Sender += ' ';
                            }
                            LoRa_Utils::sendNewPacket("APRS", Config.callsign + ">APLRG1,RFONLY,WIDE1-1::" + Sender + ":" + ackMessage);
                            receivedMessage = AddresseeAndMessage.substring(AddresseeAndMessage.indexOf(":")+1, AddresseeAndMessage.indexOf("{"));
                        } else {
                            receivedMessage = AddresseeAndMessage.substring(AddresseeAndMessage.indexOf(":")+1);
                        }
                        if (receivedMessage.indexOf("?") == 0) {
                            queryMessage = true;
                            delay(2000);
                            if (!Config.display.alwaysOn) {
                                display_toggle(true);
                            }
                            LoRa_Utils::sendNewPacket("APRS", QUERY_Utils::process(receivedMessage, Sender, "LoRa"));
                            lastScreenOn = millis();
                            show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, "Callsign = " + Sender, "TYPE --> QUERY",  0);
                        }
                    }
                    if (!queryMessage) {
                        aprsPacket = createPacket(packet);
                        if (!Config.display.alwaysOn) {
                            display_toggle(true);
                        }
                        lastScreenOn = millis();
                        upload(aprsPacket);
                        #ifndef TextSerialOutputForApp
                        Serial.println("   ---> Uploaded to APRS-IS");
                        #endif
                        STATION_Utils::updateLastHeard(Sender);
                        Utils::typeOfPacket(aprsPacket, "LoRa-APRS");
                        show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine, 0);
                    }
                }    
            } else {
                #ifndef TextSerialOutputForApp
                Serial.println("   ---> LoRa Packet Ignored (first 3 bytes or TCPIP/NOGATE/RFONLY)\n");
                #endif
            }
        }
    }

    void processAPRSISPacket(String packet) {
        String Sender, AddresseeAndMessage, Addressee, receivedMessage;
        if (!packet.startsWith("#")){
            if (packet.indexOf("::")>0) {
                Sender = packet.substring(0,packet.indexOf(">"));
                AddresseeAndMessage = packet.substring(packet.indexOf("::")+2);
                Addressee = AddresseeAndMessage.substring(0, AddresseeAndMessage.indexOf(":"));
                Addressee.trim();
                if (Addressee == Config.callsign) {             // its for me!
                    if (AddresseeAndMessage.indexOf("{")>0) {     // ack?
                        String ackMessage = "ack" + AddresseeAndMessage.substring(AddresseeAndMessage.indexOf("{")+1);
                        ackMessage.trim();
                        delay(4000);
                        //Serial.println(ackMessage);
                        for(int i = Sender.length(); i < 9; i++) {
                            Sender += ' ';
                        }
                        String ackPacket = Config.callsign + ">APLRG1,TCPIP,qAC::" + Sender + ":" + ackMessage;// + "\n";
                        upload(ackPacket);
                        receivedMessage = AddresseeAndMessage.substring(AddresseeAndMessage.indexOf(":")+1, AddresseeAndMessage.indexOf("{"));
                    } else {
                        receivedMessage = AddresseeAndMessage.substring(AddresseeAndMessage.indexOf(":")+1);
                    }
                    if (receivedMessage.indexOf("?") == 0) {
                        #ifndef TextSerialOutputForApp
                        Serial.println("Received Query APRS-IS : " + packet);
                        #endif
                        String queryAnswer = QUERY_Utils::process(receivedMessage, Sender, "APRSIS");
                        //Serial.println("---> QUERY Answer : " + queryAnswer.substring(0,queryAnswer.indexOf("\n")));
                        if (!Config.display.alwaysOn) {
                            display_toggle(true);
                        }
                        lastScreenOn = millis();
                        delay(500);
                        upload(queryAnswer);
                        SYSLOG_Utils::log("APRSIS Tx", queryAnswer,0,0,0);
                        fifthLine = "APRS-IS ----> APRS-IS";
                        sixthLine = Config.callsign;
                        for (int j=sixthLine.length();j<9;j++) {
                            sixthLine += " ";
                        }
                        sixthLine += "> " + Sender;
                        seventhLine = "QUERY = " + receivedMessage;
                    }
                } else {
                    #ifndef TextSerialOutputForApp
                    Serial.print("Received from APRS-IS  : " + packet);
                    #endif

                    if (Config.aprs_is.toRF && STATION_Utils::wasHeard(Addressee)) {
                        LoRa_Utils::sendNewPacket("APRS", LoRa_Utils::generatePacket(packet));
                        display_toggle(true);
                        lastScreenOn = millis();
                        Utils::typeOfPacket(packet, "APRS-LoRa");
                    }
                }
                show_display(firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine, 0);
            }
        }
    }

    void loop(String packet) {
        if (espClient.connected()) {
            processLoRaPacket(packet);

            if (espClient.available()) {
                String aprsisPacket = espClient.readStringUntil('\r');

                // Serial.println(aprsisPacket);

                processAPRSISPacket(aprsisPacket);
            }
        }
    }

}