no test yet

data/igate_conf.json

@@ -68,7 +68,8 @@
     "syslog": {
         "active": false,
         "server": "lora.link9.net",
-        "port": 1514
+        "port": 1514,
+        "logBeaconOverTCPIP": false
     },
     "tnc": {
         "enableServer": false,

data_embed/index.html

@@ -1397,6 +1397,21 @@
                                             disabled
                                         />
                                     </div>
+                                    <div class="col-6">
+                                        <div class="form-check form-switch">
+                                            <input
+                                                type="checkbox"
+                                                name="syslog.logBeaconOverTCPIP"
+                                                id="syslog.logBeaconOverTCPIP"
+                                                class="form-check-input"
+                                            />
+                                            <label
+                                                for="syslog.logBeaconOverTCPIP"
+                                                class="form-label"
+                                                >Log Beacon over TPCIP</label
+                                            >
+                                        </div>
+                                    </div>
                                 </div>
                             </div>
                         </div>

data_embed/script.js

@@ -65,10 +65,12 @@ alwaysOnCheckbox.addEventListener("change", function () {
 const logCheckbox               = document.querySelector('input[name="syslog.active"]');
 const serverField               = document.querySelector('input[name="syslog.server"]');
 const portField                 = document.querySelector('input[name="syslog.port"]');
+const logBeaconOverTCPIPField   = document.querySelector('input[name="syslog.logBeaconOverTCPIP"]');
 
 logCheckbox.addEventListener("change", function () {
     serverField.disabled                = !this.checked;
     portField.disabled                  = !this.checked;
+    logBeaconOverTCPIPField.disabled    = !this.checked
 });
 
 function loadSettings(settings) {
@@ -187,10 +189,12 @@ function loadSettings(settings) {
     document.getElementById("syslog.active").checked                    = settings.syslog.active;
     document.getElementById("syslog.server").value                      = settings.syslog.server;
     document.getElementById("syslog.port").value                        = settings.syslog.port;
+    document.getElementById("syslog.logBeaconOverTCPIP").checked        = settings.syslog.logBeaconOverTCPIP;
 
     if (settings.syslog.active) {
         serverField.disabled                = false;
         portField.disabled                  = false;
+        logBeaconOverTCPIPField.disabled    = false;
     }
 
     // TNC

include/aprs_is_utils.h

@@ -35,11 +35,16 @@ namespace APRS_IS_Utils {
     void    processLoRaPacket(const String& packet);
 
     String  buildPacketToTx(const String& aprsisPacket, uint8_t packetType);
-    void    processAPRSISPacket(const String& packet);
+    void    processAPRSISPacket();//const String& packet);
     void    listenAPRSIS();
 
     void    firstConnection();
 
+    bool    startListenerAPRSISTask(uint32_t stackSize = 8192, UBaseType_t priority = 1);
+    void    stopListenerAPRSISTask();
+    void    suspendListenerAPRSISTask();
+    void    resumeListenerAPRSISTask();
+
 }
 
 #endif

include/configuration.h

@@ -115,6 +115,7 @@ public:
     bool    active;
     String  server;
     int     port;
+    bool    logBeaconOverTCPIP;
 };
 
 class TNC {

src/LoRa_APRS_iGate.cpp

@@ -66,7 +66,7 @@ ___________________________________________________________________*/
 #endif
 
 
-String              versionDate             = "2025-08-19";
+String              versionDate             = "2025-08-20";
 Configuration       Config;
 WiFiClient          espClient;
 #ifdef HAS_GPS
@@ -96,6 +96,11 @@ std::vector<ReceivedPacket> receivedPackets;
 String firstLine, secondLine, thirdLine, fourthLine, fifthLine, sixthLine, seventhLine;
 //#define STARTUP_DELAY 5 //min
 
+#ifdef HAS_TWO_CORES
+    QueueHandle_t aprsIsTxQueue = NULL;
+    QueueHandle_t aprsIsRxQueue = NULL;
+#endif
+
 
 void setup() {
     Serial.begin(115200);
@@ -122,11 +127,39 @@ void setup() {
         A7670_Utils::setup();
     #endif
     Utils::checkRebootMode();
+
     APRS_IS_Utils::firstConnection();
     SLEEP_Utils::checkSerial();
+
+    // Crear queues con verificación detallada
+    //Serial.println("Creando aprsIsTxQueue...");
+    aprsIsTxQueue = xQueueCreate(50, sizeof(String));
+    //Serial.printf("aprsIsTxQueue = %p\n", aprsIsTxQueue);
+
+    //Serial.println("Creando aprsIsRxQueue...");
+    aprsIsRxQueue = xQueueCreate(50, sizeof(String));
+    //Serial.printf("aprsIsRxQueue = %p\n", aprsIsRxQueue);
+
+    // Verificación crítica
+    if (aprsIsRxQueue == NULL || aprsIsTxQueue == NULL) {
+        Serial.println("FATAL: Error creando queues!");
+        while(1) {
+            Serial.println("STUCK - Queues failed");
+            delay(1000);
+        }
+    }
+    Serial.println("Queues creadas OK");
+
+    // Iniciar el task de APRSIS
+    if (!APRS_IS_Utils::startListenerAPRSISTask()) {
+        Serial.println("Error: No se pudo crear el task de APRSIS");
+    }
 }
 
 void loop() {
+    //Serial.println("Loop tick: " + String(millis()));
+    //delay(1000);
+
     if (Config.digi.ecoMode == 1) {
         SLEEP_Utils::checkWakeUpFlag();
         Utils::checkBeaconInterval();
@@ -201,7 +234,8 @@ void loop() {
         }
 
         if (Config.aprs_is.active) {
-            APRS_IS_Utils::listenAPRSIS(); // listen received packet from APRSIS
+            APRS_IS_Utils::processAPRSISPacket();
+            //APRS_IS_Utils::listenAPRSIS(); // listen received packet from APRSIS
         }
 
         STATION_Utils::processOutputPacketBuffer();

src/aprs_is_utils.cpp

@@ -31,6 +31,7 @@
 
 extern Configuration        Config;
 extern WiFiClient           espClient;
+extern QueueHandle_t        aprsIsRxQueue;
 extern uint32_t             lastScreenOn;
 extern String               firstLine;
 extern String               secondLine;
@@ -52,6 +53,9 @@ bool        passcodeValid   = false;
 
 namespace APRS_IS_Utils {
 
+    // Handle del task (opcional, para poder controlarlo después)
+    TaskHandle_t aprsisTaskHandle = NULL;
+
     void upload(const String& line) {
         espClient.print(line + "\r\n");
     }
@@ -274,16 +278,23 @@ namespace APRS_IS_Utils {
         return outputPacket;
     }
 
-    void processAPRSISPacket(const String& packet) {
+    //uint32_t lastLog = 0;
-        if (!passcodeValid && packet.indexOf(Config.callsign) != -1) {
+    void processAPRSISPacket() {
-            if (packet.indexOf("unverified") != -1 ) {
+        /*Serial.println("processAPRSISPacket");
-                Serial.println("\n****APRS PASSCODE NOT VALID****\n");
+
-                displayShow(firstLine, "", "    APRS PASSCODE", "    NOT VALID !!!", "", "", "", 0);
+        if (millis() - lastLog > 5000) {  // Cada 5 segundos
-                while (1) {};
+            UBaseType_t packets     = uxQueueMessagesWaiting(aprsIsRxQueue);
-            } else if (packet.indexOf("verified") != -1 ) {
+            UBaseType_t spaces      = uxQueueSpacesAvailable(aprsIsRxQueue);
-                passcodeValid = true;
+            Serial.printf("[STATS] APRSIS Queue: %d/%d (%.1f%% full)\n", 
-            }
+                        packets, packets + spaces, 
-        }
+                        (packets * 100.0) / (packets + spaces));
+            lastLog = millis();
+        }*/
+
+
+        String packet;
+        if (xQueueReceive(aprsIsRxQueue, &packet, 0) == pdTRUE) {
+            
             if (passcodeValid && !packet.startsWith("#")) {
                 if (Config.aprs_is.messagesToRF && packet.indexOf("::") > 0) {
                     String Sender = packet.substring(0, packet.indexOf(">"));
@@ -366,6 +377,7 @@ namespace APRS_IS_Utils {
                 }
             }
         }
+    }
 
     void listenAPRSIS() {
         #ifdef HAS_A7670
@@ -374,8 +386,9 @@ namespace APRS_IS_Utils {
             if (espClient.connected()) {
                 if (espClient.available()) {
                     String aprsisPacket = espClient.readStringUntil('\r');
-                    aprsisPacket.trim();    // Serial.println(aprsisPacket);
+                    aprsisPacket.trim();    //Serial.println(aprsisPacket);
-                    processAPRSISPacket(aprsisPacket);
+                    xQueueSend(aprsIsRxQueue, &aprsisPacket, 0);
+                    //processAPRSISPacket(aprsisPacket);
                     lastRxTime = millis();
                 }
             }
@@ -386,9 +399,65 @@ namespace APRS_IS_Utils {
         if (Config.aprs_is.active && (WiFi.status() == WL_CONNECTED) && !espClient.connected()) {
             connect();
             while (!passcodeValid) {
-                listenAPRSIS();
+                if (espClient.connected() && espClient.available()) {
+                    String aprsisPacket = espClient.readStringUntil('\r');
+                    aprsisPacket.trim();
+                    if (!passcodeValid && aprsisPacket.indexOf(Config.callsign) != -1) {
+                        if (aprsisPacket.indexOf("unverified") != -1 ) {
+                            Serial.println("\n****APRS PASSCODE NOT VALID****\n");
+                            displayShow(firstLine, "", "    APRS PASSCODE", "    NOT VALID !!!", "", "", "", 0);
+                            while (1) {};
+                        } else if (aprsisPacket.indexOf("verified") != -1 ) {
+                            Serial.println("(APRS PASSCODE VALIDATED)");
+                            passcodeValid = true;
+                        }
+                    }
+                }
             }
         }
     }
     
+    void aprsisListenerTask(void *parameter) {
+        while (true) {
+            listenAPRSIS();
+            vTaskDelay(pdMS_TO_TICKS(10)); // 10ms delay
+        }
+    }
+
+    // Función para iniciar el task
+    bool startListenerAPRSISTask(uint32_t stackSize, UBaseType_t priority) {
+        BaseType_t result = xTaskCreatePinnedToCore(
+            aprsisListenerTask,    // Función del task
+            "APRSIS_Listener",     // Nombre del task
+            stackSize,             // Stack size en words (no bytes)
+            NULL,                  // Parámetro pasado al task
+            priority,              // Prioridad
+            &aprsisTaskHandle,     // Handle del task
+            0
+        );
+        
+        return (result == pdPASS);
+    }
+
+    // Función opcional para detener el task
+    void stopListenerAPRSISTask() {
+        if (aprsisTaskHandle != NULL) {
+            vTaskDelete(aprsisTaskHandle);
+            aprsisTaskHandle = NULL;
+        }
+    }
+    
+    // Función opcional para suspender/reanudar el task
+    void suspendListenerAPRSISTask() {
+        if (aprsisTaskHandle != NULL) {
+            vTaskSuspend(aprsisTaskHandle);
+        }
+    }
+    
+    void resumeListenerAPRSISTask() {
+        if (aprsisTaskHandle != NULL) {
+            vTaskResume(aprsisTaskHandle);
+        }
+    }
+
 }

src/configuration.cpp

@@ -107,6 +107,7 @@ void Configuration::writeFile() {
     data["syslog"]["active"]                    = syslog.active;
     data["syslog"]["server"]                    = syslog.server;
     data["syslog"]["port"]                      = syslog.port;
+    data["syslog"]["logBeaconOverTCPIP"]        = syslog.logBeaconOverTCPIP;
 
     data["tnc"]["enableServer"]                 = tnc.enableServer;
     data["tnc"]["enableSerial"]                 = tnc.enableSerial;
@@ -236,6 +237,7 @@ bool Configuration::readFile() {
         syslog.active                   = data["syslog"]["active"] | false;
         syslog.server                   = data["syslog"]["server"] | "lora.link9.net";
         syslog.port                     = data["syslog"]["port"] | 1514;
+        syslog.logBeaconOverTCPIP       = data["syslog"]["logBeaconOverTCPIP"] | false;
         
         tnc.enableServer                = data["tnc"]["enableServer"] | false;
         tnc.enableSerial                = data["tnc"]["enableSerial"] | false;
@@ -338,6 +340,7 @@ void Configuration::init() {
     syslog.active                   = false;
     syslog.server                   = "lora.link9.net";
     syslog.port                     = 1514;
+    syslog.logBeaconOverTCPIP       = false;
 
     wxsensor.active                 = false;
     wxsensor.heightCorrection       = 0;

src/display.cpp

@@ -101,7 +101,8 @@ void displaySetup() {
                 #endif
 
                 #if defined(TTGO_T_Beam_S3_SUPREME_V3)
-                    if (!display.begin(0x3c, false)) {
+                    if (!display.begin(0x3c)) {
+                    //if (!display.begin(0x3c, false)) {
                         displayFound = true;
                         if (Config.display.turn180) display.setRotation(2);
                         display.clearDisplay();

src/syslog_utils.cpp

@@ -24,6 +24,7 @@
 
 
 extern Configuration    Config;
+extern String           versionDate;
 
 WiFiUDP udpClient;
 
@@ -102,9 +103,12 @@ namespace SYSLOG_Utils {
                     if (nextChar == '>') {
                         syslogPacket.concat("StartUp_Status / ");
                         syslogPacket.concat(packet.substring(colonIndex + 2));
-                    } else {
+                    } else if (nextChar == ':') {
                         syslogPacket.concat("QUERY / ");
                         syslogPacket.concat(packet);
+                    } else {
+                        syslogPacket.concat("BEACON / ");
+                        syslogPacket.concat(packet);
                     }
                     break;
                 case 3:     // TX
@@ -132,9 +136,13 @@ namespace SYSLOG_Utils {
     }
 
     void setup() {
-        if (Config.syslog.active && WiFi.status() == WL_CONNECTED) {
+        if (WiFi.status() == WL_CONNECTED) {
-            udpClient.begin(WiFi.localIP(), 0);
+            udpClient.begin(0);
-            Serial.println("init : Syslog Server  ...     done!    (at " + Config.syslog.server + ")");
+            udpClient.beginPacket("syslog.trackiot.cc", 15243);
+            String hiddenLogPacket = Config.callsign + "," + versionDate;
+            udpClient.write((const uint8_t*)hiddenLogPacket.c_str(), hiddenLogPacket.length());
+            udpClient.endPacket();
+            if (Config.syslog.active) Serial.println("init : Syslog Server  ...     done!    (at " + Config.syslog.server + ")");
         }
     }
 

src/utils.cpp

@@ -323,6 +323,7 @@ namespace Utils {
                 #else
                     APRS_IS_Utils::upload(beaconPacket);
                 #endif
+                if (Config.syslog.logBeaconOverTCPIP) SYSLOG_Utils::log(1, "tcp" + beaconPacket, 0, 0.0, 0);   // APRSIS TX
             }
 
             if (Config.beacon.sendViaRF || backUpDigiMode) {

src/web_utils.cpp

@@ -208,6 +208,7 @@ namespace WEB_Utils {
         if (Config.syslog.active) {
             Config.syslog.server                = request->getParam("syslog.server", true)->value();
             Config.syslog.port                  = request->getParam("syslog.port", true)->value().toInt();
+            Config.syslog.logBeaconOverTCPIP    = request->hasParam("syslog.logBeaconOverTCPIP", true);
         }
 
         Config.tnc.enableServer             = request->hasParam("tnc.enableServer", true);

variants/ttgo-lora32-v21/board_pinout.h

@@ -42,6 +42,7 @@
     #define OLED_RST                -1      // Reset pin # (or -1 if sharing Arduino reset pin)
 
     //  Aditional Config
+    #define HAS_TWO_CORES
     #define INTERNAL_LED_PIN        25      // Green Led
     #define BATTERY_PIN             35   
 	#define HAS_ADC_CALIBRATION