blob: 0b17230626099c94cb568db55054296f0d641a99 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
{ pkgs, lib, ...}:
let
genTopic_zigbee = name: tags: {
servers = [ "tcp://localhost:1883" ];
username = "stats";
password = lib.removeSuffix "\n" (builtins.readFile <secrets/mqtt/stats>);
qos = 0;
connection_timeout = "30s";
topics = [ "/ham/zigbee/${name}" ];
inherit tags;
persistent_session = false;
name_override = "zigbee ${tags.room} ${name}";
data_format = "json";
json_string_fields = [ "linkquality" "temperature" "humidity" "pressure" "battery" "contact" ];
# json_name_key = <filed which defines the name>
};
genTopic_plain = name: topic: tags: {
servers = [ "tcp://localhost:1883" ];
username = "stats";
password = lib.removeSuffix "\n" (builtins.readFile <secrets/mqtt/stats>);
qos = 0;
connection_timeout = "30s";
topics = [ topic ];
inherit tags;
persistent_session = false;
name_override = tags.sensor;
data_type = "float";
data_format = "value";
# json_query = tags.sensor; #TODO?
};
esensor = room: name: sensor:
(genTopic_plain sensor ''/ham/${room}/${name}/sensor/${sensor}/state''
{ inherit room sensor name;
"scope" = "ham";
} );
zsensor = room: name:
(genTopic_zigbee name
{ inherit room name;
"scope" = "ham";
} );
zigbee_temphum = room: name: [
(zsensor room name)
];
esphome_temphum = room: name: [
(esensor room name ''${room}_${name}_temperature'')
(esensor room name ''${room}_${name}_humidity'')
(esensor room name ''${room}_${name}_pressure'')
];
in {
services.telegraf.extraConfig.inputs.mqtt_consumer =
(zigbee_temphum "Wohnzimmer" "temp1")
++ (zigbee_temphum "Badezimmer" "temp2")
++ (zigbee_temphum "Kinderzimmer" "temp3")
++ (esphome_temphum "arbeitszimmer" "box")
++ (esphome_temphum "schlafzimmer" "plug")
++ (esphome_temphum "wohnzimmer" "plug")
++ (esphome_temphum "terrasse" "plug");
}
|
