# Telemetrie-Ingestion -> InfluxDB 'sensors' (Telegraf, additiv).
# Raum-Satelliten (+/temp) + Heizraum (Temp + digitale io-Signale) + Ölknoten.
# Routing: dieser Output nimmt NUR temperature/io_state/power/node_status; openwb.conf-Output dropt sie.
[[outputs.influxdb]]
  urls = ["http://127.0.0.1:8086"]
  database = "sensors"
  namepass = ["temperature", "io_state", "power", "node_status"]

# --- Raum-Satelliten: <raum>/temp ---
[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = ["+/temp"]
  data_format = "value"
  data_type = "float"
  name_override = "temperature"
  topic_tag = ""
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "+/temp"
    measurement = "_/_"
    tags = "node/_"

# --- Heizraum: DS18B20-Temperatur(en) heizraum/<ROM> ---
[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = ["heizraum/+"]
  data_format = "value"
  data_type = "float"
  name_override = "temperature"
  topic_tag = ""
  [inputs.mqtt_consumer.tags]
    node = "heizraum"
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "heizraum/+"
    measurement = "_/_"
    tags = "_/sensor"

# --- Ölknoten: DS18B20-Temperatur(en) oelknoten/<rolle> ---
[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = ["oelknoten/raum","oelknoten/hk_vorlauf","oelknoten/vl_erd_an","oelknoten/rl_erd_ab"]
  data_format = "value"
  data_type = "float"
  name_override = "temperature"
  topic_tag = ""
  [inputs.mqtt_consumer.tags]
    node = "oelknoten"
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "oelknoten/+"
    measurement = "_/_"
    tags = "_/sensor"

# --- Heizraum: digitale Signale (Pumpen/Brenner/Kessel) 0/1 ---
[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = ["heizraum/io/+", "heizraum/state/kessel"]
  data_format = "value"
  data_type = "integer"
  name_override = "io_state"
  topic_tag = ""
  [inputs.mqtt_consumer.tags]
    node = "heizraum"
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "heizraum/io/+"
    measurement = "_/_/_"
    tags = "_/_/signal"
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "heizraum/state/+"
    measurement = "_/_/_"
    tags = "_/_/signal"

# --- Ölknoten: LWT-Status (online/offline -> 1/0) ---
[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = ["oelknoten/status"]
  data_format = "value"
  data_type = "string"
  name_override = "node_status"
  topic_tag = ""
  [inputs.mqtt_consumer.tags]
    node = "oelknoten"

[[processors.enum]]
  namepass = ["node_status"]
  [[processors.enum.mapping]]
    field = "value"
    [processors.enum.mapping.value_mappings]
      online = 1
      offline = 0