mirror of
https://github.com/lora-aprs/LoRa_APRS_iGate.git
synced 2025-12-06 07:42:00 +01:00
103 lines
3.5 KiB
C++
103 lines
3.5 KiB
C++
#include <logger.h>
|
|
|
|
#include <TimeLib.h>
|
|
|
|
#include "Task.h"
|
|
#include "TaskRouter.h"
|
|
#include "project_configuration.h"
|
|
|
|
String create_lat_aprs(double lat);
|
|
String create_long_aprs(double lng);
|
|
|
|
RouterTask::RouterTask(TaskQueue<std::shared_ptr<APRSMessage>> &fromModem, TaskQueue<std::shared_ptr<APRSMessage>> &toModem, TaskQueue<std::shared_ptr<APRSMessage>> &toAprsIs) : Task(TASK_ROUTER, TaskRouter), _fromModem(fromModem), _toModem(toModem), _toAprsIs(toAprsIs) {
|
|
}
|
|
|
|
RouterTask::~RouterTask() {
|
|
}
|
|
|
|
bool RouterTask::setup(System &system) {
|
|
// setup beacon
|
|
_beacon_timer.setTimeout(system.getUserConfig()->beacon.timeout * 60 * 1000);
|
|
|
|
_beaconMsg = std::shared_ptr<APRSMessage>(new APRSMessage());
|
|
_beaconMsg->setSource(system.getUserConfig()->callsign);
|
|
_beaconMsg->setDestination("APLG01");
|
|
String lat = create_lat_aprs(system.getUserConfig()->beacon.positionLatitude);
|
|
String lng = create_long_aprs(system.getUserConfig()->beacon.positionLongitude);
|
|
_beaconMsg->getBody()->setData(String("=") + lat + "L" + lng + "&" + system.getUserConfig()->beacon.message);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool RouterTask::loop(System &system) {
|
|
// do routing
|
|
if (!_fromModem.empty()) {
|
|
std::shared_ptr<APRSMessage> modemMsg = _fromModem.getElement();
|
|
|
|
if (system.getUserConfig()->aprs_is.active && modemMsg->getSource() != system.getUserConfig()->callsign) {
|
|
std::shared_ptr<APRSMessage> aprsIsMsg = std::make_shared<APRSMessage>(*modemMsg);
|
|
String path = aprsIsMsg->getPath();
|
|
|
|
if (!(path.indexOf("RFONLY") != -1 || path.indexOf("NOGATE") != -1 || path.indexOf("TCPIP") != -1)) {
|
|
if (!path.isEmpty()) {
|
|
path += ",";
|
|
}
|
|
|
|
aprsIsMsg->setPath(path + "qAR," + system.getUserConfig()->callsign);
|
|
|
|
logPrintD("APRS-IS: ");
|
|
logPrintlnD(aprsIsMsg->toString());
|
|
_toAprsIs.addElement(aprsIsMsg);
|
|
} else {
|
|
logPrintlnD("APRS-IS: no forward => RFonly");
|
|
}
|
|
} else {
|
|
if (!system.getUserConfig()->aprs_is.active)
|
|
logPrintlnD("APRS-IS: disabled");
|
|
|
|
if (modemMsg->getSource() == system.getUserConfig()->callsign)
|
|
logPrintlnD("APRS-IS: no forward => own packet received");
|
|
}
|
|
|
|
if (system.getUserConfig()->digi.active && modemMsg->getSource() != system.getUserConfig()->callsign) {
|
|
std::shared_ptr<APRSMessage> digiMsg = std::make_shared<APRSMessage>(*modemMsg);
|
|
String path = digiMsg->getPath();
|
|
|
|
// simple loop check
|
|
if (path.indexOf("WIDE1-1") >= 0 || path.indexOf(system.getUserConfig()->callsign) == -1) {
|
|
// fixme
|
|
digiMsg->setPath(system.getUserConfig()->callsign + "*");
|
|
|
|
logPrintD("DIGI: ");
|
|
logPrintlnD(digiMsg->toString());
|
|
|
|
_toModem.addElement(digiMsg);
|
|
}
|
|
}
|
|
}
|
|
|
|
// check for beacon
|
|
if (_beacon_timer.check()) {
|
|
logPrintD("[" + timeString() + "] ");
|
|
logPrintlnD(_beaconMsg->encode());
|
|
|
|
if (system.getUserConfig()->aprs_is.active)
|
|
_toAprsIs.addElement(_beaconMsg);
|
|
|
|
if (system.getUserConfig()->digi.beacon) {
|
|
std::shared_ptr<APRSMessage> digiBeaconMsg = std::make_shared<APRSMessage>(*_beaconMsg);
|
|
//digiBeaconMsg->setPath("WIDE1-1");
|
|
_toModem.addElement(digiBeaconMsg);
|
|
}
|
|
|
|
system.getDisplay().addFrame(std::shared_ptr<DisplayFrame>(new TextFrame("BEACON", _beaconMsg->toString())));
|
|
|
|
_beacon_timer.start();
|
|
}
|
|
|
|
uint32_t diff = _beacon_timer.getTriggerTimeInSec();
|
|
_stateInfo = "beacon " + String(uint32_t(diff / 60)) + ":" + String(uint32_t(diff % 60));
|
|
|
|
return true;
|
|
}
|