/*
 * Progetto ESP32: Costruisci un dispositivo di chat LoRa sicuro e a lungo raggio Heltec WiFi LoRa 32
 * 
 * File: Heltec_ESP32_LoRa_V3_chat_TX_RX.ino
 * scritto il 29 giugno 2025 da Ahmad Shamshiri www.Roboajx.com
 * Si prega di guardare il video tutorial su: https://youtu.be/IsOSvrF60J4
 * Pagina delle risorse per questo video: https://robojax.com/RJT642
 * 
 * =====================================================================
 * DESCRIZIONE DEL CODICE ARDUINO: TRASCEIVER SICURO LoRa (sistema di chat)
 * =====================================================================
 * 
 * COMPONENTI HARDWARE:
 * -------------------
 * - Microcontrollore principale: Heltec WiFi LoRa 32 V3
 * - Involucro: case Meshnology N33 con batteria da 3000mAh
 * - Input: encoder rotativo con pulsante
 * - Feedback: display OLED integrato
 * 
 * FUNZIONALITÀ DEL SISTEMA:
 * -------------------
 * NUOVI CONTROLLI:
 * - Manopola di Rotazione: Seleziona carattere.
 * - Pressione Breve (Click): Aggiungi carattere selezionato.
 * - Pressione Lunga (Hold): Inserisci uno spazio (come una barra spaziatrice).
 * - Doppio Click: Backspace.
 * 
 * [2] TRASMISSIONE WIRELESS SICURA:
 * - Tutti i messaggi sono crittografati prima della trasmissione LoRa
 * - Il comando di posizione iniziale viene trasmesso come pacchetto sicuro speciale
 * - Utilizza la banda LoRa 433MHz/915MHz per comunicazioni affidabili
 * 
 * [3] GESTIONE DELL'ENERGIA:
 * - Ottimizzato per funzionamento a batteria (3000mAh)
 * - Modalità a basso consumo tra le trasmissioni
 * 
 * PER ISTRUZIONI COMPLETE DI CONFIGURAZIONE:
 * Si prega di guardare il video tutorial su: https://youtu.be/IsOSvrF60J4
 * Pagina delle risorse per questo video: https://robojax.com/RJT642
 * =====================================================================
 * 
 * DISCLAIMER:
 * Questo codice è fornito "COSÌ COM'È" senza alcuna garanzia. L'autore
 * non sarà ritenuto responsabile per eventuali danni derivanti dall'uso di questo codice.
 * 
 * LICENZA:
 * Quest'opera è sotto licenza GNU General Public License v3.0
 * Permessi al di fuori dell'ambito di questa licenza potrebbero essere disponibili su Robojax.com
 * 
 * TERMINI DI CONDIVISIONE:
 * Sei libero di condividere, copiare e modificare questo codice per scopi non commerciali
 * FAI SALVO che:
 * 1. Mantieni intatto questo intero blocco di commento con il codice originale
 * 2. Includi il link originale di Robojax.com
 * 3. Mantieni il link del tutorial di YouTube (se applicabile)
 * 4. Indica chiaramente eventuali modifiche apportate
 * 
 * /
 * // Librerie core Heltec e display
 */
#include <Wire.h>
#include "HT_SSD1306Wire.h"
#include "WiFi.h"

 // LoRa e librerie di sicurezza
#include "LoRaWan_APP.h"
#include "mbedtls/aes.h"
#include <cstring>

 // La libreria Rotary Encoder approvata dagli utenti
#include "AiEsp32RotaryEncoder.h"

 // --- DEFINIZIONI E CONFIGURAZIONE DEL PIN ---
static SSD1306Wire  display(0x3c, 500000, SDA_OLED, SCL_OLED, GEOMETRY_128_64, RST_OLED);

#define ROTARY_ENCODER_A_PIN 5 // pina A dell'encoder rotativo
#define ROTARY_ENCODER_B_PIN 6 // pin B dell'encoder rotativo
#define ROTARY_ENCODER_BUTTON_PIN 4 // pin di commutazione dell'encoder rotativo

#define RF_FREQUENCY 915432000 // frequenza operativa di LoRa
#define TX_OUTPUT_POWER 20 // La potenza di uscita dovrebbe essere compresa tra 2 e 21 in dBm.
const char *userKey = "wahJ8uy$gt~_3r"; // chiave di sicurezza per comunicazioni private

#define ROTARY_ENCODER_VCC_PIN -1
#define ROTARY_ENCODER_STEPS 4

 // --- PARAMETRI LORA ---
#define LORA_BANDWIDTH 0
#define LORA_SPREADING_FACTOR 7
#define LORA_CODINGRATE 1
#define LORA_PREAMBLE_LENGTH 8
#define LORA_SYMBOL_TIMEOUT 0
#define LORA_FIX_LENGTH_PAYLOAD_ON false
#define LORA_IQ_INVERSION_ON false
#define BUFFER_SIZE 256

#define USER_BUTTON_PIN 0
 // --- VARIABILI GLOBALI E STATO ---
enum AppState { COMPOSING, READING };
AppState currentState = COMPOSING;
String messageToCompose = "";
String lastReceivedMessage = "No messages yet.";
bool hasUnreadMessage = false;
volatile bool newPacketAvailable = false;
char rxpacket[BUFFER_SIZE];
AiEsp32RotaryEncoder rotaryEncoder = AiEsp32RotaryEncoder(ROTARY_ENCODER_A_PIN, ROTARY_ENCODER_B_PIN, ROTARY_ENCODER_BUTTON_PIN, ROTARY_ENCODER_VCC_PIN, ROTARY_ENCODER_STEPS);
const char* charset = " ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789.,!?>";
char selectedChar;
static RadioEvents_t RadioEvents;
bool lora_idle = true;

mbedtls_aes_context aes;
unsigned long shortPressAfterMiliseconds = 50;
unsigned long longPressAfterMiliseconds = 1000;
unsigned long doubleClickTimeout = 400;
static unsigned long buttonDownTime = 0;
static unsigned long buttonUpTime = 0;
static bool buttonWasDown = false;
static bool doubleClickWaiting = false;

 // --- PROTOTIPI DELLA FUNZIONE ---
void OnTxDone(void);
void OnTxTimeout(void);
void OnRxDone(uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr);
void encryptAES(uint8_t *data, const char *key);
void decryptAES(uint8_t *data, const char *key);
void processKey(const char *userKey, uint8_t *processedKey, size_t keySize);
void updateDisplay();
void sendData();
void VextON(void);
void processButton();

 // --- ROUTINE DI SERVIZIO D'INTERRUZIONE ---
void IRAM_ATTR readEncoderISR() {
  rotaryEncoder.readEncoder_ISR();
}

 // --- AZIONI DEL GESTORE DEL PULSANTE ---
void on_button_short_click() {
  if (currentState != COMPOSING) return;
  if (selectedChar == '>') {
      sendData();
  } else {
    messageToCompose += selectedChar;
  }
  updateDisplay();
}
void on_button_long_click() {
  if (currentState != COMPOSING) return;
  messageToCompose += " ";
  updateDisplay();
}
void on_button_double_click() {
  if (currentState != COMPOSING) return;
  if (messageToCompose.length() > 0) {
    messageToCompose.remove(messageToCompose.length() - 1);
  }
  updateDisplay();
}

 // --- IMPOSTAZIONE ---
void setup() {
  Serial.begin(115200);
  Serial.println("LoRa Keyboard Transceiver - Definitive Version");

  VextON();
  delay(100);
  Mcu.begin(HELTEC_BOARD,SLOW_CLK_TPYE);
  WiFi.mode(WIFI_OFF);
  btStop();

  display.init();
  display.setFont(ArialMT_Plain_10);

  rotaryEncoder.begin();
  rotaryEncoder.setup(readEncoderISR);
  rotaryEncoder.setBoundaries(0, strlen(charset) - 1, true);
  rotaryEncoder.disableAcceleration();

  pinMode(USER_BUTTON_PIN, INPUT_PULLUP);

  RadioEvents.TxDone = OnTxDone;
  RadioEvents.TxTimeout = OnTxTimeout;
  RadioEvents.RxDone = OnRxDone;
  Radio.Init(&RadioEvents);
  Radio.SetChannel(RF_FREQUENCY);

  Radio.SetRxConfig(MODEM_LORA, LORA_BANDWIDTH, LORA_SPREADING_FACTOR,
                   LORA_CODINGRATE, 0, LORA_PREAMBLE_LENGTH,
                   LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON,
                   0, true, 0, 0, LORA_IQ_INVERSION_ON, true);

  updateDisplay();
}

 // --- CICLO PRINCIPALE ---
void loop() {
  if(lora_idle) {
    lora_idle = false;
    Serial.println("Entering RX mode...");
    Radio.Rx(0);
  }
  Radio.IrqProcess();

  if (newPacketAvailable) {
    newPacketAvailable = false;
    hasUnreadMessage = true;
    lastReceivedMessage = String(rxpacket);
    Serial.print("Received Decrypted Message: ");
    Serial.println(lastReceivedMessage);
    updateDisplay();
  }

  if (currentState == COMPOSING) {
    if (rotaryEncoder.encoderChanged()) {
      updateDisplay();
    }
    processButton();
  }

  if (digitalRead(USER_BUTTON_PIN) == LOW) {
    delay(50);
    if (digitalRead(USER_BUTTON_PIN) == LOW) {
      if (currentState == COMPOSING) {
        if (lastReceivedMessage != "No messages yet.") {
          currentState = READING;
          hasUnreadMessage = false;
          updateDisplay();
        }
      } else {
        currentState = COMPOSING;
        updateDisplay();
      }
      while (digitalRead(USER_BUTTON_PIN) == LOW);
    }
  }

  delay(10);
}

 // --- GESTORI E AIUTI EVENTO LORA ---
void OnTxDone(void) {
  Serial.println("TX done.");
  Radio.Sleep();
  lora_idle = true;
}
void OnTxTimeout(void) {
  Serial.println("TX Timeout.");
  Radio.Sleep();
  lora_idle = true;
}
void OnRxDone(uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr) {
    Radio.Sleep();
    memset(rxpacket, 0, sizeof(rxpacket));
    memcpy(rxpacket, payload, size > BUFFER_SIZE ? BUFFER_SIZE : size);
    decryptAES((uint8_t*)rxpacket, userKey);
    newPacketAvailable = true;
    lora_idle = true;
}

void sendData() {
  if (messageToCompose.length() > 0) {
    lora_idle = false;

    Radio.SetTxConfig(MODEM_LORA, TX_OUTPUT_POWER, 0, LORA_BANDWIDTH,
                   LORA_SPREADING_FACTOR, LORA_CODINGRATE,
                   LORA_PREAMBLE_LENGTH, LORA_FIX_LENGTH_PAYLOAD_ON,
                   true, 0, 0, LORA_IQ_INVERSION_ON, 3000);

    uint8_t data[BUFFER_SIZE];
    memset(data, 0, BUFFER_SIZE);
    strncpy((char*)data, messageToCompose.c_str(), BUFFER_SIZE - 1);

    encryptAES(data, userKey);

    Serial.print("Sending message: ");
    Serial.println(messageToCompose);

    Radio.Send(data, 16);

    messageToCompose = "";
  }
}

 // --- LOGICA DI VISUALIZZAZIONE E PULSANTI ---
void updateDisplay() {
  display.clear();
  display.setTextAlignment(TEXT_ALIGN_LEFT);

  if (currentState == COMPOSING) {
    selectedChar = charset[rotaryEncoder.readEncoder()];
    display.setFont(ArialMT_Plain_10);

 // --- QUESTA È LA SOLUZIONE per la notifica ---
    String msgLabel;
    if (hasUnreadMessage) {
        msgLabel = ">> NEW MSG <<"; // Rendi la notifica molto evidente
    } else {
        msgLabel = "Msg:";
    }
    display.drawStringMaxWidth(0, 0, 128, msgLabel + " " + messageToCompose);

    display.setFont(ArialMT_Plain_16);
    int16_t labelWidth = display.getStringWidth("Select: ");
    display.drawString(0, 35, "Select: ");
    display.setFont(ArialMT_Plain_24);
    display.drawString(labelWidth, 32, String(selectedChar));
  } else { // currentState == LEGGENDO
    display.setFont(ArialMT_Plain_16);
    display.drawString(0, 0, "Received:");
    display.setFont(ArialMT_Plain_10);
    display.drawStringMaxWidth(0, 18, 128, lastReceivedMessage);
  }

  display.display();
}

void processButton() {
    if (doubleClickWaiting && (millis() - buttonUpTime > doubleClickTimeout)) {
        doubleClickWaiting = false;
        on_button_short_click();
    }
    bool isButtonDown = rotaryEncoder.isEncoderButtonDown();
    if (isButtonDown && !buttonWasDown) {
        buttonDownTime = millis();
        buttonWasDown = true;
    }
    else if (!isButtonDown && buttonWasDown) {
        unsigned long pressDuration = millis() - buttonDownTime;
        if (pressDuration >= longPressAfterMiliseconds) {
            on_button_long_click();
            doubleClickWaiting = false;
        }
        else if (pressDuration >= shortPressAfterMiliseconds) {
            if (doubleClickWaiting) {
                on_button_double_click();
                doubleClickWaiting = false;
            } else {
                doubleClickWaiting = true;
                buttonUpTime = millis();
            }
        }
        buttonWasDown = false;
    }
}

 // --- UTENZE ---
void VextON(void) {
  pinMode(Vext,OUTPUT);
  digitalWrite(Vext, LOW);
}
void processKey(const char *userKey, uint8_t *processedKey, size_t keySize) {
    memset(processedKey, 0, keySize);
    size_t len = strlen(userKey);
    if (len > keySize) len = keySize;
    memcpy(processedKey, userKey, len);
}
void encryptAES(uint8_t *data, const char *key) {
    uint8_t processedKey[16];
    processKey(key, processedKey, 16);
    mbedtls_aes_init(&aes);
    mbedtls_aes_setkey_enc(&aes, processedKey, 128);
    mbedtls_aes_crypt_ecb(&aes, MBEDTLS_AES_ENCRYPT, data, data);
    mbedtls_aes_free(&aes);
}
void decryptAES(uint8_t *data, const char *key) {
    uint8_t processedKey[16];
    processKey(key, processedKey, 16);
    mbedtls_aes_init(&aes);
    mbedtls_aes_setkey_dec(&aes, processedKey, 128);
    mbedtls_aes_crypt_ecb(&aes, MBEDTLS_AES_DECRYPT, data, data);
    mbedtls_aes_free(&aes);
}

/*
 * Progetto ESP32: Costruire un dispositivo di chat LoRa sicuro e a lungo raggio Heltec WiFi LoRa 32
 * 
 * File: Heltec_ESP32_LoRa_V3_chat_TX_RX_buzzer.ino
 * scritto il 29 giugno 2025 da Ahmad Shamshiri www.Roboajx.com
 * Si prega di guardare il video tutorial su: https://youtu.be/IsOSvrF60J4
 * Pagina delle risorse per questo video: https://robojax.com/RJT642
 * 
 * =====================================================================
 * DESCRIZIONE DEL CODICE ARDUINO: TRASCEIVER TASTIERA LoRa SICURO (sistema di chat)
 * =====================================================================
 * 
 * COMPONENTI HARDWARE:
 * -------------------
 * - Controller principale: Heltec WiFi LoRa 32 V3
 * - Involucro: Custodia Meshnology N33 con batteria da 3000mAh
 * - Input: Encoder rotativo con pulsante
 * - Udibile: Buzzer attivo (collegato al pin 40)
 * - Feedback: Display OLED integrato
 * 
 * FUNZIONALITÀ DEL SISTEMA:
 * -------------------
 * NUOVI CONTROLLI:
 * - Manopola di rotazione: Seleziona carattere.
 * - Pressione breve (Clic): Aggiungi carattere selezionato.
 * - Pressione prolungata (Tieni premuto): Inserisci uno spazio (come un tasto barra spaziatrice).
 * - Doppio clic: Cancella.
 * 
 * [2] TRASMISSIONE WIRELESS SICURA:
 * - Tutti i messaggi crittografati prima della trasmissione LoRa
 * - Comando di posizione home trasmesso come pacchetto speciale sicuro
 * - Utilizza la banda LoRa 433MHz/915MHz per comunicazioni affidabili
 * 
 * [3] GESTIONE DELL'ENERGIA:
 * - Ottimizzato per funzionamento a batteria (3000mAh)
 * - Modalità a basso consumo tra le trasmissioni
 * 
 * PER ISTRUZIONI COMPLETE DI CONFIGURAZIONE:
 * Si prega di guardare il video tutorial su: https://youtu.be/IsOSvrF60J4
 * Pagina delle risorse per questo video: https://robojax.com/RJT642
 * =====================================================================
 * 
 * DICHIARAZIONE DI NON RESPONSABILITÀ:
 * Questo codice è fornito "COSÌ COM'È" senza alcuna garanzia di alcun tipo. L'autore
 * non sarà ritenuto responsabile per eventuali danni derivanti dall'uso di questo codice.
 * 
 * LICENZA:
 * Questo lavoro è concesso in licenza secondo la GNU General Public License v3.0
 * Permessi al di fuori dell'ambito di questa licenza potrebbero essere disponibili su Robojax.com
 * 
 * TERMINI DI CONDIVISIONE:
 * Sei libero di condividere, copiare e modificare questo codice per scopi non commerciali
 * PURCHÉ tu:
 * 1. Mantenga questo intero blocco di commento intatto con il codice originale
 * 2. Includa il link originale di Robojax.com
 * 3. Mantenga il link del tutorial di YouTube (se applicabile)
 * 4. Indichi chiaramente eventuali modifiche apportate
 * 
 * /
 * 
 *  // Librerie principali Heltec e di visualizzazione
 */
#include <Wire.h>
#include "HT_SSD1306Wire.h"
#include "WiFi.h"

 // Librerie LoRa e di sicurezza
#include "LoRaWan_APP.h"
#include "mbedtls/aes.h"
#include <cstring>

 // La libreria Rotary Encoder approvata dagli utenti
#include "AiEsp32RotaryEncoder.h"

 // --- DEFINIZIONI E CONFIGURAZIONE DEL PIN ---
static SSD1306Wire  display(0x3c, 500000, SDA_OLED, SCL_OLED, GEOMETRY_128_64, RST_OLED);

#define ROTARY_ENCODER_A_PIN 5 // pinn A dell'encoder rotativo
#define ROTARY_ENCODER_B_PIN 6 // pin B dell'encoder rotativo
#define ROTARY_ENCODER_BUTTON_PIN 4 // pulsante del codice rotativo

#define BUZZER_PIN 40 // il pin del buzzer o il relè da attivare
const bool DEBUG = false;

#define RF_FREQUENCY 915432000 // frequenza operativa di LoRa
#define TX_OUTPUT_POWER 2 // La potenza in uscita dovrebbe essere compresa tra 2 e 21 in dBm.
const char *userKey = "wahJ8uy$gt~_3r"; // chiave di sicurezza per comunicazioni private

#define ROTARY_ENCODER_VCC_PIN -1
#define ROTARY_ENCODER_STEPS 4

 // --- PARAMETRI LORA ---
#define LORA_BANDWIDTH 0
#define LORA_SPREADING_FACTOR 7
#define LORA_CODINGRATE 1
#define LORA_PREAMBLE_LENGTH 8
#define LORA_SYMBOL_TIMEOUT 0
#define LORA_FIX_LENGTH_PAYLOAD_ON false
#define LORA_IQ_INVERSION_ON false
#define BUFFER_SIZE 256

#define LOOP_DELAY 10
 // Variabili di stato del segnale acustico
unsigned long buzzerStartTime = 0;
bool isBuzzerActive = false;
int beepPhase = 0; // 0=inattivo, 1=primo beep, 2=pausa, 3=secondo beep

#define USER_BUTTON_PIN 0
 // --- VARIABILI GLOBALI E STATO ---
enum AppState { COMPOSING, READING };
AppState currentState = COMPOSING;
String messageToCompose = "";
String lastReceivedMessage = "No messages yet.";
bool hasUnreadMessage = false;
volatile bool newPacketAvailable = false;
char rxpacket[BUFFER_SIZE];
AiEsp32RotaryEncoder rotaryEncoder = AiEsp32RotaryEncoder(ROTARY_ENCODER_A_PIN, ROTARY_ENCODER_B_PIN, ROTARY_ENCODER_BUTTON_PIN, ROTARY_ENCODER_VCC_PIN, ROTARY_ENCODER_STEPS);
const char* charset = " ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789.,!?>";
char selectedChar;
static RadioEvents_t RadioEvents;
bool lora_idle = true;

mbedtls_aes_context aes;
unsigned long shortPressAfterMiliseconds = 50;
unsigned long longPressAfterMiliseconds = 1000;
unsigned long doubleClickTimeout = 400;
static unsigned long buttonDownTime = 0;
static unsigned long buttonUpTime = 0;
static bool buttonWasDown = false;
static bool doubleClickWaiting = false;

 // --- PROTOTIPI DELLA FUNZIONE ---
void OnTxDone(void);
void OnTxTimeout(void);
void OnRxDone(uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr);
void encryptAES(uint8_t *data, const char *key);
void decryptAES(uint8_t *data, const char *key);
void processKey(const char *userKey, uint8_t *processedKey, size_t keySize);
void updateDisplay();
void sendData();
void VextON(void);
void processButton();
void buzzer();
void updateBuzzer();


 // --- ROUTINE DI SERVIZIO DI INTERRUZIONE ---
void IRAM_ATTR readEncoderISR() {
  rotaryEncoder.readEncoder_ISR();
}

 // --- AZIONI GESTORE PULSANTE ---
void on_button_short_click() {
  if (currentState != COMPOSING) return;
  if (selectedChar == '>') {
      sendData();
  } else {
    messageToCompose += selectedChar;
  }
  updateDisplay();
}
void on_button_long_click() {
  if (currentState != COMPOSING) return;
  messageToCompose += " ";
  updateDisplay();
}
void on_button_double_click() {
  if (currentState != COMPOSING) return;
  if (messageToCompose.length() > 0) {
    messageToCompose.remove(messageToCompose.length() - 1);
  }
  updateDisplay();
}

 // --- IMPOSTAZIONE ---
void setup() {
  Serial.begin(115200);
  Serial.println("LoRa Keyboard Transceiver - By Robojax");

  VextON();
  delay(100);
  Mcu.begin(HELTEC_BOARD,SLOW_CLK_TPYE);
  WiFi.mode(WIFI_OFF);
  btStop();

  display.init();
  display.setFont(ArialMT_Plain_10);

  rotaryEncoder.begin();
  rotaryEncoder.setup(readEncoderISR);
  rotaryEncoder.setBoundaries(0, strlen(charset) - 1, true);
  rotaryEncoder.disableAcceleration();

  pinMode(USER_BUTTON_PIN, INPUT_PULLUP);
  pinMode(BUZZER_PIN, OUTPUT);

  RadioEvents.TxDone = OnTxDone;
  RadioEvents.TxTimeout = OnTxTimeout;
  RadioEvents.RxDone = OnRxDone;
  Radio.Init(&RadioEvents);
  Radio.SetChannel(RF_FREQUENCY);

  Radio.SetRxConfig(MODEM_LORA, LORA_BANDWIDTH, LORA_SPREADING_FACTOR,
                   LORA_CODINGRATE, 0, LORA_PREAMBLE_LENGTH,
                   LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON,
                   0, true, 0, 0, LORA_IQ_INVERSION_ON, true);

  updateDisplay();
}

 // --- CICLO PRINCIPALE ---
void loop() {
  if(lora_idle) {
    lora_idle = false;
    if(DEBUG)
    {
    Serial.println("Entering RX mode...");
    }

    Radio.Rx(0);
  }
  Radio.IrqProcess();

  if (newPacketAvailable) {
    newPacketAvailable = false;
    hasUnreadMessage = true;
    lastReceivedMessage = String(rxpacket);
    if(DEBUG)
    {
    Serial.print("Received Decrypted Message: ");
    Serial.println(lastReceivedMessage);
    }
    updateDisplay();
    buzzer();
  }

  if (currentState == COMPOSING) {
    if (rotaryEncoder.encoderChanged()) {
      updateDisplay();
    }
    processButton();
  }

  if (digitalRead(USER_BUTTON_PIN) == LOW) {
    delay(50);
    if (digitalRead(USER_BUTTON_PIN) == LOW) {
      if (currentState == COMPOSING) {
        if (lastReceivedMessage != "No messages yet.") {
          currentState = READING;
          hasUnreadMessage = false;
          updateDisplay();
        }
      } else {
        currentState = COMPOSING;
        updateDisplay();
      }
      while (digitalRead(USER_BUTTON_PIN) == LOW);
    }
  }

  updateBuzzer(); // Aggiorna lo stato del buzzer (non bloccante)
  delay(LOOP_DELAY); // Il tuo ritardo del ciclo di 10 ms
}

 // --- GESTORI E AIUTI LORA ---
void OnTxDone(void) {
    if(DEBUG)
    {
      Serial.println("TX done.");
    }
  Radio.Sleep();
  lora_idle = true;
}
void OnTxTimeout(void) {
    if(DEBUG)
    {
      Serial.println("TX Timeout.");
    }
  Radio.Sleep();
  lora_idle = true;
}
void OnRxDone(uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr) {
    Radio.Sleep();
    memset(rxpacket, 0, sizeof(rxpacket));
    memcpy(rxpacket, payload, size > BUFFER_SIZE ? BUFFER_SIZE : size);
    decryptAES((uint8_t*)rxpacket, userKey);
    newPacketAvailable = true;
    lora_idle = true;
}

void sendData() {
  if (messageToCompose.length() > 0) {
    lora_idle = false;

    Radio.SetTxConfig(MODEM_LORA, TX_OUTPUT_POWER, 0, LORA_BANDWIDTH,
                   LORA_SPREADING_FACTOR, LORA_CODINGRATE,
                   LORA_PREAMBLE_LENGTH, LORA_FIX_LENGTH_PAYLOAD_ON,
                   true, 0, 0, LORA_IQ_INVERSION_ON, 3000);

    uint8_t data[BUFFER_SIZE];
    memset(data, 0, BUFFER_SIZE);
    strncpy((char*)data, messageToCompose.c_str(), BUFFER_SIZE - 1);

    encryptAES(data, userKey);
    if(DEBUG)
    {
    Serial.print("Sending message: ");
    Serial.println(messageToCompose);
    }

    Radio.Send(data, 16);

    messageToCompose = "";
  }
}

 // --- LOGICA DI VISUALIZZAZIONE E PULSANTI ---
void updateDisplay() {
  display.clear();
  display.setTextAlignment(TEXT_ALIGN_LEFT);

  if (currentState == COMPOSING) {
    selectedChar = charset[rotaryEncoder.readEncoder()];
    display.setFont(ArialMT_Plain_10);

 // --- QUESTO È IL FIX per la notifica ---
    String msgLabel;
    if (hasUnreadMessage) {
        msgLabel = ">> NEW MSG <<"; // Rendi la notifica molto evidente
    } else {
        msgLabel = "Msg:";
    }
    display.drawStringMaxWidth(0, 0, 128, msgLabel + " " + messageToCompose);

    display.setFont(ArialMT_Plain_16);
    int16_t labelWidth = display.getStringWidth("Select: ");
    display.drawString(0, 35, "Select: ");
    display.setFont(ArialMT_Plain_24);
    display.drawString(labelWidth, 32, String(selectedChar));
  } else { // currentState == LEGGENDO
    display.setFont(ArialMT_Plain_16);
    display.drawString(0, 0, "Received:");
    display.setFont(ArialMT_Plain_10);
    display.drawStringMaxWidth(0, 18, 128, lastReceivedMessage);
  }

  display.display();
}

void processButton() {
    if (doubleClickWaiting && (millis() - buttonUpTime > doubleClickTimeout)) {
        doubleClickWaiting = false;
        on_button_short_click();
    }
    bool isButtonDown = rotaryEncoder.isEncoderButtonDown();
    if (isButtonDown && !buttonWasDown) {
        buttonDownTime = millis();
        buttonWasDown = true;
    }
    else if (!isButtonDown && buttonWasDown) {
        unsigned long pressDuration = millis() - buttonDownTime;
        if (pressDuration >= longPressAfterMiliseconds) {
            on_button_long_click();
            doubleClickWaiting = false;
        }
        else if (pressDuration >= shortPressAfterMiliseconds) {
            if (doubleClickWaiting) {
                on_button_double_click();
                doubleClickWaiting = false;
            } else {
                doubleClickWaiting = true;
                buttonUpTime = millis();
            }
        }
        buttonWasDown = false;
    }
}


void buzzer()
{
  if (!isBuzzerActive) {
    isBuzzerActive = true;
    buzzerStartTime = millis(); // Avviare la sequenza del buzzer
    beepPhase = 1; // Primo segnale acustico
    digitalWrite(BUZZER_PIN, HIGH);
  }
}
void updateBuzzer() {
  if (!isBuzzerActive) return;

  unsigned long currentTime = millis();
  unsigned long elapsed = currentTime - buzzerStartTime;

  switch (beepPhase) {
    case 1: // Primo beep (300ms ATTIVO)
      if (elapsed >= 300) {
        digitalWrite(BUZZER_PIN, LOW);
        buzzerStartTime = currentTime;
        beepPhase = 2; // Passa a pausa
      }
      break;

    case 2: // Pausa (200ms OFF)
      if (elapsed >= 200) {
        digitalWrite(BUZZER_PIN, HIGH);
        buzzerStartTime = currentTime;
        beepPhase = 3; // Spostati al secondo segnale acustico
      }
      break;

    case 3: // Secondo bip (300ms ATTIVO)
      if (elapsed >= 300) {
        digitalWrite(BUZZER_PIN, LOW);
        isBuzzerActive = false; // Ripristina
        beepPhase = 0;
      }
      break;
  }
}
 // --- UTENZE ---
void VextON(void) {
  pinMode(Vext,OUTPUT);
  digitalWrite(Vext, LOW);
}
void processKey(const char *userKey, uint8_t *processedKey, size_t keySize) {
    memset(processedKey, 0, keySize);
    size_t len = strlen(userKey);
    if (len > keySize) len = keySize;
    memcpy(processedKey, userKey, len);
}
void encryptAES(uint8_t *data, const char *key) {
    uint8_t processedKey[16];
    processKey(key, processedKey, 16);
    mbedtls_aes_init(&aes);
    mbedtls_aes_setkey_enc(&aes, processedKey, 128);
    mbedtls_aes_crypt_ecb(&aes, MBEDTLS_AES_ENCRYPT, data, data);
    mbedtls_aes_free(&aes);
}
void decryptAES(uint8_t *data, const char *key) {
    uint8_t processedKey[16];
    processKey(key, processedKey, 16);
    mbedtls_aes_init(&aes);
    mbedtls_aes_setkey_dec(&aes, processedKey, 128);
    mbedtls_aes_crypt_ecb(&aes, MBEDTLS_AES_DECRYPT, data, data);
    mbedtls_aes_free(&aes);
}