import webserver

class SensorHandler : Driver
  var counter1_value  # Zähler für gesendete Nachrichten

  def init()
    self.counter1_value = 0  # Initialer Zählerwert für LoRa gesendet
    
    # Timer einrichten, um alle 5 Sekunden eine LoRa-Nachricht zu senden
    tasmota.add_cron("*/5 * * * * *", /-> self.send_lora_message(), "LoRaTimer")
  end

  def send_lora_message()
    self.counter1_value += 1  # Zähler für gesendete Nachrichten erhöhen
    var message = "Nachricht Nr.: " + str(self.counter1_value)  # Nachricht mit Zählerwert erstellen
    tasmota.cmd("Lorasend2 " + message)  # LoRa-Nachricht senden
  end

  def web_sensor()
    # Überschrift
    webserver.content_send("<div style='text-align:center;font-size:32px;margin:10px 0;'>LoRa Sender</div>")

    # Erste horizontale Trennlinie
    webserver.content_send("<hr>")

    # Tabelle für LoRa gesendet
    webserver.content_send("<table style='width:100%;'>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}<span style='color:red;'>LoRa gesendet:{m}%d</span>{e}", self.counter1_value))
    webserver.content_send("</td></tr>")
    webserver.content_send("</table>")

    # Zweite horizontale Trennlinie
    webserver.content_send("<hr>")
  end
end

# Instanziierung des Treibers und Entfernen der alten Instanz
global.sensor_handler_instance = SensorHandler()
tasmota.remove_driver(global.sensor_handler_instance)

# Neue Treiberinstanz hinzufügen
tasmota.add_driver(global.sensor_handler_instance)

import webserver

class SensorHandler : Driver
  var counter1_value
  var rssi_value
  var snr_value
  var last_received_timestamp
  var NachrichtTxt  # Variable für die bereinigte Nachricht

  def init()
    self.counter1_value = 0
    self.rssi_value = 0
    self.snr_value = 0
    self.last_received_timestamp = "00:00:00"
    self.NachrichtTxt = ""  # Initialisiere die Variable
    
    tasmota.cmd("Rule1 ON LoRaReceived DO Backlog Var1 1; Var2 %timestamp%; Var4 %value% ENDON")
    tasmota.cmd("Rule1 1")
  end

  def update_counter1(value)
    self.counter1_value = self.counter1_value + 1
  end

  def update_rssi(value)
    self.rssi_value = format("%.1f", value)
  end

  def update_snr(value)
    self.snr_value = format("%.1f", value)
  end

  def update_timestamp(value)
    var time_dump = tasmota.time_dump(value)
    if time_dump != nil
      self.last_received_timestamp = format("%02d:%02d:%02d", time_dump["hour"], time_dump["min"], time_dump["sec"])
    else
      self.last_received_timestamp = "N/A"
    end
  end

  def update_message(value)
    # Konvertiere den Wert in einen String, falls es sich um ein map-Objekt handelt
    var message = str(value)
    
    # Manuelle Extraktion der Nachricht aus dem JSON-Format
    var prefix = "'State': '"
    var suffix = "'}"
    var prefix_len = size(prefix)
    var suffix_len = size(suffix)
    
    var prefix_pos = -1
    var suffix_pos = -1
    
    # Finde die Position des Präfix
    for i : 0 .. size(message) - prefix_len
      if message[i..i+prefix_len-1] == prefix
        prefix_pos = i + prefix_len
        break
      end
    end
    
    # Finde die Position des Suffix
    if prefix_pos >= 0
      for i : prefix_pos .. size(message) - suffix_len
        if message[i..i+suffix_len-1] == suffix
          suffix_pos = i
          break
        end
      end
    end
    
    # Extrahiere die Nachricht
    if prefix_pos >= 0 && suffix_pos >= 0
      self.NachrichtTxt = message[prefix_pos..suffix_pos-1]
    else
      self.NachrichtTxt = message  # Falls kein JSON-Format, speichere die Nachricht direkt
    end
    
    print("Empfangene Nachricht:", self.NachrichtTxt)
  end

  def web_sensor()
    # Verwende die bereinigte Nachricht in der Web-UI
    webserver.content_send("<div style='text-align:center;font-size:32px;margin:10px 0;'>LoRa Empfänger</div>")
    webserver.content_send("<hr>")
    webserver.content_send("<table style='width:100%;'>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}<span style='color:green;'>LoRa empfangen:{m}%d</span>{e}", self.counter1_value))
    webserver.content_send("</td></tr>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}RSSI ist:{m}%s{e}", self.rssi_value))
    webserver.content_send("</td></tr>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}SNR ist:{m}%s{e}", self.snr_value))
    webserver.content_send("</td></tr>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}Letzter Empfangszeitstempel: {m}%s{e}", self.last_received_timestamp))
    webserver.content_send("</td></tr>")
    webserver.content_send("<tr><td>")
    webserver.content_send(format("{s}Empfangene Nachricht: {m}%s{e}", self.NachrichtTxt))  # Verwende die bereinigte Nachricht
    webserver.content_send("</td></tr>")
    webserver.content_send("</table>")
    webserver.content_send("<hr>")
  end
end

global.sensor_handler_instance = SensorHandler()
tasmota.remove_driver(global.sensor_handler_instance)
tasmota.add_driver(global.sensor_handler_instance)

tasmota.add_rule('Var1#State', /value, trigger, data -> global.sensor_handler_instance.update_counter1(value))
tasmota.add_rule('Var2', /value, trigger, data -> global.sensor_handler_instance.update_timestamp(tasmota.rtc()["local"]))
tasmota.add_rule('Var4#State', /value, trigger, data -> global.sensor_handler_instance.update_message(value))tasmota.add_rule('RSSI', /value, trigger, data -> global.sensor_handler_instance.update_rssi(value))
tasmota.add_rule('SNR', /value, trigger, data -> global.sensor_handler_instance.update_snr(value))