LoRa_APRS_iGate/src/station_utils.cpp

#include "station_utils.h"
#include "aprs_is_utils.h"
#include "configuration.h"
#include "lora_utils.h"
#include "utils.h"
#include <vector>

extern Configuration        Config;
extern uint32_t             lastTxTime;
extern uint32_t             lastRxTime;
extern String               fourthLine;

std::vector<String>             lastHeardStation;
std::vector<String>             outputPacketBuffer;
std::vector<String>             packet25SegBuffer;
std::vector<uint32_t>           packet25SegTimeBuffer;


namespace STATION_Utils {

    void deleteNotHeard() {
        std::vector<String>  lastHeardStation_temp;
        for (int i = 0; i < lastHeardStation.size(); i++) {
            String deltaTimeString = lastHeardStation[i].substring(lastHeardStation[i].indexOf(",") + 1);
            uint32_t deltaTime = deltaTimeString.toInt();
            if ((millis() - deltaTime) < Config.rememberStationTime * 60 * 1000) {
                lastHeardStation_temp.push_back(lastHeardStation[i]);
            }
        }
        lastHeardStation.clear();
        for (int j = 0; j < lastHeardStation_temp.size(); j++) {
            lastHeardStation.push_back(lastHeardStation_temp[j]);
        }
        lastHeardStation_temp.clear();
    }

    void updateLastHeard(String station) {
        deleteNotHeard();
        bool stationHeard = false;
        for (int i = 0; i < lastHeardStation.size(); i++) {
            if (lastHeardStation[i].substring(0, lastHeardStation[i].indexOf(",")) == station) {
                lastHeardStation[i] = station + "," + String(millis());
                stationHeard = true;
            }
        }
        if (!stationHeard) {
            lastHeardStation.push_back(station + "," + String(millis()));
        }

        fourthLine = "Stations (" + String(Config.rememberStationTime) + "min) = ";
        if (lastHeardStation.size() < 10) {
            fourthLine += " ";
        }
        fourthLine += String(lastHeardStation.size());
    }

    bool wasHeard(String station) {
        deleteNotHeard();
        for (int i = 0; i < lastHeardStation.size(); i++) {
            if (lastHeardStation[i].substring(0, lastHeardStation[i].indexOf(",")) == station) {
                Utils::println(" ---> Listened Station");
                return true;
            }
        }
        Utils::println(" ---> Station not Heard for last 30 min (Not Tx)\n");
        return false;
    }

    void clean25SegBuffer() {
        if (!packet25SegTimeBuffer.empty()) {
            if (millis() - packet25SegTimeBuffer[0] > 25 * 1000) {
                Serial.print("Borrando : "); Serial.println(packet25SegBuffer[0]);
                packet25SegTimeBuffer.erase(packet25SegTimeBuffer.begin());
                packet25SegBuffer.erase(packet25SegBuffer.begin());
            }
        }
    }

    bool check25SegBuffer(String station, String textMessage) {
        if (!packet25SegBuffer.empty()) {
            bool shouldBeIgnored = false;
            for (int i = 0; i < packet25SegBuffer.size(); i++) {
                if (packet25SegBuffer[i].substring(0, packet25SegBuffer[i].indexOf(",")) == station && packet25SegBuffer[i].substring(packet25SegBuffer[i].indexOf(",") + 1) == textMessage) {
                    shouldBeIgnored = true;
                }
            }
            if (shouldBeIgnored) {
                return false;
            } else {
                packet25SegBuffer.push_back(station + "," + textMessage);
                packet25SegTimeBuffer.push_back(millis());
                return true;
            }
        } else {
            packet25SegBuffer.push_back(station + "," + textMessage);
            packet25SegTimeBuffer.push_back(millis());
            return true;
        }    
    }

    void processOutputPacketBuffer() {
        int timeToWait = 3 * 1000;      // 3 segs between packet Tx and also Rx ???
        uint32_t lastRx = millis() - lastRxTime;
        uint32_t lastTx = millis() - lastTxTime;
        if (outputPacketBuffer.size() > 0 && lastTx > timeToWait && lastRx > timeToWait) {
            LoRa_Utils::sendNewPacket(outputPacketBuffer[0]);
            outputPacketBuffer.erase(outputPacketBuffer.begin());
            lastTxTime = millis();
        }
    }

    void addToOutputPacketBuffer(String packet) {
        outputPacketBuffer.push_back(packet);
    }

}