Wie bereits angekündigt stelle ich nun mal meine Lösung vor und habe noch ein Paar Fragen wie Ihr gewisse Dinge gelöst habt.
Die Übergabe der JSON an ioBroker erfolgt nun doch wieder über MQTT.
(Nachdem ich meinen ioBroker komplett neu installiert habe gab es keinen Fehler mehr 
)
Das Skript kann aktuell die folgenden Aufgaben übernehmen
- Objekt in einem bestimmten Raum schalten
- Objekt ohne den Raum schalten.
In diesem Fall wird zuerst im Raum in dem der rhasspy steht nach dem Objekt gesucht
Falls im Raum kein Objekt mit diesem Namen gefunden wurde wird global danach gesucht
Wenn es global nur ein Objekt gibt wird dieses geschalten.
sentences.ini
[changeLightRoom]
([schalte] | [mach]) ([das] | [die]) ($objects){objectName} [im] ($rooms){room} ($states){state}
[changeState]
([schalte] | [mach]) ([das] | [die] | [den]) ($objects){objectName} ($states){state}
sentences.ini
[changeLightRoom]
([schalte] | [mach]) ([das] | [die]) ($objects){objectName} [im] ($rooms){room} ($states){state}
[changeState]
([schalte] | [mach]) ([das] | [die] | [den]) ($objects){objectName} ($states){state}
slot - objects
Highboard
Stehlampe
Bett
Herd
Licht
Spiegel
Wohnwand
Indirekte Licht
Spüle
Schrank
blablabla
slot - rooms
Schlafzimmer
Küche
Klo
Büro
Esszimmer
Bad
Wohnzimmer
slot - states
ein
an
aus
Durch diese Definition sind alle Daten die später vom Skript verarbeitet werden in Slots.
Das Herzstück des ganzen ist das Javascript.
Der Code ist kommentiert, hoffe meine Kommentare sind nicht zu verwirrend.
//##########################################################################
// Rhasspy-intents via MQTT empfangen und entspr.Datenpunkte setzen/schalten
//##########################################################################
let http = require('http');
/*
Definition meiner Räume und der jeweiligen Objekte darin
Die Struktur sieht dabei wie folgt aus.
Im Intent der übermittelt wird sind sowohl der Raum Name als auch der Objektname als Slot enthalten.
Beide werden dann vom Skript verwendet um den korrekten Datenpunkt herauszufinden.
*/
const rooms = {
"Büro": {
"Licht": "sonoff.0.ShellyV1_13.POWER",
},
"Wohnzimmer": {
"Licht": "sonoff.0.ShellyV1_06.POWER",
"Stehlampe": "OwnDevices.0.433mhzPlugs.10011.PlugC",
"Wohnwand": "OwnDevices.0.433mhzPlugs.10011.PlugB",
"Rollo": ""
},
"Bad": {
"Licht": "sonoff.0.ShellyV1_05.POWER",
"Spiegel": "sonoff.0.ShellyV1_11.POWER",
"Indirekte Licht": "sonoff.0.SonoffBasic_02.POWER"
},
"Esszimmer": {
"Licht": "sonoff.0.ShellyV1_03.POWER",
"Highboard": "sonoff.0.SonoffS26_3.POWER"
},
"Küche": {
"Licht": "hm-rpc.1.000858A9960E7A.4.STATE",
"Spüle": "sonoff.0.ShellyV1_02.POWER",
"Herd": "sonoff.0.ShellyV1_01.POWER"
},
"Schlafzimmer": {
"Licht": "sonoff.0.ShellyV1_09.POWER",
"Schrank": "sonoff.0.ShellyV1_10.POWER",
"Bett": "sonoff.0.SonoffBasic_01.POWER",
"Rollo": ""
},
"Klo": {
"Licht": "sonoff.0.ShellyV1_04.POWER"
}
}
//In diesem json werden nötige Informationen zu allen rhasspys abgelget.
const rhasspySites = {
"testpi": {
room: "Büro",
host: "testpi.angl.loc",
httpPort: "12101"
}
}
//************************ Functions *********************
//Mit dieser Funktion werden Strings in einen Boolschen Wert umgewandelt
//Wenn der Wert in 'trueValues' enthalten ist wird 'true' zurückgegeben.
//Wenn nicht, wird 'false' zurückgegeben
function convertStateToBool(state) {
const trueValues = ['ein', 'an'];
return trueValues.includes(state);
}
//Reukursives durchsuchen eines JSON Objektes
//© https://gist.github.com/shakhal/3cf5402fc61484d58c8d
function findValues(obj, key) {
return findValuesHelper(obj, key, []);
}
//Reukursives durchsuchen eines JSON Objektes
//© https://gist.github.com/shakhal/3cf5402fc61484d58c8d
function findValuesHelper(obj, key, list) {
if (!obj) return list;
if (obj instanceof Array) {
for (var i in obj) {
list = list.concat(findValuesHelper(obj[i], key, []));
}
return list;
}
if (obj[key]) list.push(obj[key]);
if ((typeof obj == "object") && (obj !== null)) {
var children = Object.keys(obj);
if (children.length > 0) {
for (i = 0; i < children.length; i++) {
list = list.concat(findValuesHelper(obj[children[i]], key, []));
}
}
}
return list;
}
//Generiert ein JSON-Objekt mit allen wichtigen Informationen für die Funktionen im Skript.
//Dies dient vor allem dazu den späteren Code lesbarer zu machen.
//Beisipel Ergebnis
/*
{
"slots":{
"objectName":"Stehlampe",
"state":"aus"
},
"intentName":"changeState",
"siteId":"testpi"
}
*/
function extractIntentData(message) {
const parsedMessage = JSON.parse(message);
let extractedJSON = {};
extractedJSON.slots = {};
extractedJSON.intentName = parsedMessage.intent.intentName;
extractedJSON.siteId = parsedMessage.siteId;
parsedMessage.slots.forEach(slot => {
extractedJSON.slots[slot.slotName] = slot.value.value;
});
return extractedJSON;
}
//Damit kann jeder Rhasspy sprechen
function speakRhasspy(text, rhasspySiteId) {
console.log(rhasspySiteId);
const rhasspy = rhasspySites[rhasspySiteId];
const options = {
host: rhasspy.host,
port: rhasspy.httpPort,
path: "/api/text-to-speech",
method: 'POST',
headers: {
'User-Agent': 'ioBroker',
'Content-Type': 'text/plain',
}
}
let req = http.request(options);
req.on('error', function (e) {
console.error('ERROR: ' + e.message, "warn");
});
req.write(text);
req.end();
}
//In dieser Variablen werden alle Funktionen gepsiechert die später aufgerufen werden.
//Dies dient dazu den anfallenden Code zu minimieren.
//Die Funktionen haben immer den selben Namen wie die Intents in rhasspy und werden auch darauf basierend aufgerufen.
const callFunctions = {
//Ändert den Wert eines ioBroker Datenpunktes in einem bestimmten Raum.
changeLightRoom: function (json) {
const objectName = json.slots.objectName;
const roomName = json.slots.room;
const state = convertStateToBool(json.slots.state);
//Nur wenn alle 3 Werte vorhanden sind wird der Zustand geändert
if (typeof roomName != 'undefined' && typeof state != 'undefined' && typeof objectName != 'undefined') {
const room = rooms[roomName];
if (typeof room != 'undefined') {
const lightId = room[objectName];
if (typeof lightId != 'undefined') {
setState(lightId, state);
}
else {
speakRhasspy(`Ich konnte ${objectName} nicht finden`, json.siteId);
console.warn(`can not find object '${objectName}' in room '${roomName}'`);
}
}
else {
speakRhasspy(`Ich konnte den Raum ${roomName} nicht finden`, json.siteId);
console.warn(`can not find room '${roomName}' in list of rooms`);
}
}
else {
speakRhasspy(`Etwas ist schief gelaufen`, json.siteId);
console.warn(`rhasspy intent '${json.intentName}' from '${json.siteId}' slots not complete | room = '${roomName}' | state = '${state}' | objectName = '${objectName}'`);
}
},
//Ändert des Wert eines ioBroker Datenpunktes auf Basis des Raumes in welchem der Rhasspy sich befindet.
//Wenn in diesem Raum kein objekt mit diesem Name ist wird rekursiv in allen Räumen danach geuscht.
//Wenn dann nur ein Objekt mit diesem Namen gefunden wird, wird dieses geschalten.
changeState: function (json) {
const objectName = json.slots.objectName;
const state = convertStateToBool(json.slots.state);
const site = rhasspySites[json.siteId];
const room = rooms[site.room];
let lightId = room[objectName];
if (typeof lightId === 'undefined') {
//Prüfen ob es mehr als ein Objekt mit diesem Namen gibt
const objects = findValues(rooms, objectName);
if (objects.length === 1) {
lightId = objects[0];
}
else if (objects.length > 1) {
speakRhasspy(`Es gibt mehrere Objekte mit dem Namen ${objectName}`, json.siteId);
console.warn(`rhasspy intent '${json.intentName}' from '${json.siteId}' - more than one object found with name '${objectName}'`);
}
else {
speakRhasspy(`Ich konnte ${objectName} nicht finden`, json.siteId);
console.warn(`rhasspy intent '${json.intentName}' from '${json.siteId}' - no object found with name '${objectName}'`);
}
}
if (typeof lightId != 'undefined' && typeof state != 'undefined') {
setState(lightId, state);
}
else {
speakRhasspy(`Etwas ist schief gelaufen`, json.siteId);
console.warn(`rhasspy intent '${json.intentName}' from '${json.siteId}' slots not complete | lightId = '${lightId}' | state = '${state}'`);
}
}
}
//************************ Functions *********************
//************************ Events ************************
//Wird beim auslösen jedes Intents getriggert
on({ id: /mqtt\.0\.hermes\.intent\..*/, change: "any" }, function (obj) {
const extractedJSON = extractIntentData(obj.state.val);
const intentName = extractedJSON.intentName;
const callFunction = callFunctions[intentName];
if (typeof callFunction != 'undefined') {
callFunction(extractedJSON);
}
else {
console.error(`Rhasspy: Funktion ist nicht definiert --> Fehler bei Intent ${intentName}`);
}
});
//************************ Events ************************
Würde mich freuen wenn Ihr mal eure Meinung dazu sagt 
Außerdem habe ich noch ein paar Fragen.
- Mit welchen Wakword System arbeitet Ihr? Ich bekomme Smowboy nicht zum laufen
- Welches text-2-speach System nutzt ihr? Bei Espeak hört sich das total schlecht an und wirkt als ob es englisch ist.
- Habt Ihr Musikdienste wie Spotify und oder Radio eingebunden?
Liebe Grüße und schöne Wochenende
