OT-Therm Werte in Datenpunkte / Open Therm / JSON

[sissiwup]

Hallo,

ich habe ein kleines Skript geschrieben, was Werte aus dem openTherm MQTT in Datenpunkte überführt.
(https://www.seegel-systeme.de) - Diesen nutze ich ...
Es wird als Status nur ein JSON geliefert.

Das Skript kann eigentlich beliebige JSON in Datenpunkte überführen(inkl. Unterstrukturen/Arrays):

Einmal muss die instanz - Variable angepasst werden. (Ich habe hier historisch immer noch javascript und nicht user stehen ...)

Und natürlich der Datenpunkt auf das es hört (2. Zeile). Und in der Funktion countAll der state, der Gelesen werden soll.

Die Werte werden nur geschrieben, wenn sie sich ändern (um die Datenbank zu entlatsen :-))
Ein paar Werte, die zu oft kommen, werden rausgefiltert.

Viel Spaß damit und gerne Verbesserungsvorschläge ...

var instanz = 'javascript.0.ottherm.';
on('mqtt.0.otthing.31F3A0.state',function(dp) {
    countAll();
});

function flattenJSON(obj, prefix = '') {
    let result = {};
    for (let key in obj) {
        if (obj.hasOwnProperty(key)) {
            let newKey = prefix ? `${prefix}.${key}` : key;
            if (typeof obj[key] === 'object' && obj[key] !== null) {
                Object.assign(result, flattenJSON(obj[key], newKey));
            } else {
                result[newKey] = { value: obj[key], art: typeof obj[key] };
            }
        }
    }
    return result;
}

function setKeyValuePairs(json) {
    const flattened = flattenJSON(json);
    for (const [key, { value, art }] of Object.entries(flattened)) {
        if (!key.includes("txCount") && !key.includes("rxCount") && !key.includes("runtime") && !key.includes("freeHeap") && !key.includes("rssi")) {
            createState(instanz+key, 0, { name: key , desc: key , type: art });
//          log(String(key+"->"+getState(instanz+key).val)+"?"+value)
            if (String(getState(instanz+key).val)!=String(value)) {
//                console.log(`${key} -> ${value} (Type: ${art})`);
                if (art=="number") setState(instanz+key,Number(value));
                if (art=="boolean") setState(instanz+key,Boolean(value));
                if (art=="string") setState(instanz+key,String(value));
            }
        }
    }
}

function countAll() {
  let ottherm = JSON.parse(getState('mqtt.0.otthing.31F3A0.state').val);
  // log(JSON.stringify(ottherm));
  setKeyValuePairs(ottherm);
}

schedule("*/15 * * * *", function () {
    countAll();
});

countAll();