Beiträge von skyrock

/////////////// KONFIGURATION ////////////////
var ACTIVE_SCAN = false;                    // Aktives Scannen (mehr Stromverbrauch, bessere Reichweite)
var allowedMacAddresses = [
 "08:b9:23:43:db:23"                       // MAC-Adresse des BRESSER WS90 Wetterstations-Sensors (nur dieser wird ausgewertet)
];
var DEBUG_LEVEL = 2;                        // 0 = keine Ausgaben, 1 = Fehler, 2 = Infos, 3+ = sehr viel Debug
var WIND_SPEED_LIMIT_MS = 1.0;              // Durchschnittswindgeschwindigkeit in m/s, ab der Schutz greift
var WIND_GUST_LIMIT_MS  = 1.5;              // Böengeschwindigkeit in m/s, ab der Schutz greift
var DEBOUNCE_SECONDS = 60;                  // Mindestabstand zwischen zwei Schutzauslösungen in Sekunden (0 = deaktiviert)

// ------------------- MARKISE / ROLLLADEN STEUERUNG -------------------
var COVER_IP        = "192.168.150.55";     // IP-Adresse des Shelly-Geräts, das die Markise/Rollladen steuert
var COVER_ID        = 0;                    // ID des Covers am Shelly (meist 0)
var TARGET_POSITION = 100;                   // Zielposition in % bei Windalarm: 0 = ganz zu, 100 = ganz offen
// ------------------------------------------------------------

//////////////// HILFSFUNKTIONEN //////////////////
/**
* Entfernt Doppelpunkte aus MAC-Adresse und wandelt in Kleinbuchstaben um
*/
function macNoColonLower(m) { 
 return (m || "").toLowerCase().split(":").join(""); 
}

/**
* Debug-Ausgabe mit einstellbarem Level
* Wird nur angezeigt, wenn DEBUG_LEVEL hoch genug ist
*/
function debug(lvl, msg) {
 if (DEBUG_LEVEL >= lvl) {
   print("[DEBUG " + lvl + "] " + msg);
 }
}

// ------------------- HTTP-FUNKTIONEN (funktioniert mit allen Shelly-Firmwares) -------------------
/**
* Führt einen HTTP-GET-Request aus und liefert das geparste JSON zurück
*/
function httpGet(url, callback) {
 Shelly.call("http.request", {
   method: "GET",
   url: url,
   timeout: 8
 }, function(res, error_code, error_msg) {
   if (error_code !== 0 || !res || !res.body) {
     debug(1, "HTTP GET fehlgeschlagen: " + (error_msg || "keine Antwort"));
     callback(null);
     return;
   }
   var json;
   try {
     json = JSON.parse(res.body);
   } catch (e) {
     debug(1, "JSON-Parsen fehlgeschlagen: " + res.body);
     callback(null);
     return;
   }
   callback(json);
 });
}

/**
* Fragt den aktuellen Öffnungsgrad der Markise/Rollladen ab
* Ruft callback mit der Position in Prozent auf (0-100) oder null bei Fehler
*/
function queryCoverPosition(cb) {
 var url = "http://" + COVER_IP + "/rpc/Cover.GetStatus?id=" + COVER_ID;
 debug(2, "Frage Markisen-Position ab: " + url);
 httpGet(url, function(data) {
   if (data && typeof data.current_pos === "number") {
     cb(data.current_pos);
   } else {
     cb(null);
   }
 });
}

/**
* Fährt die Markise auf die gewünschte Position (0-100%)
* Wird bei Windalarm aufgerufen → meist teilweise öffnen, damit sie nicht flattern kann
*/
function setCoverPosition(pos) {
 pos = Math.max(0, Math.min(100, pos | 0)); // Sicherstellen, dass pos zwischen 0 und 100 liegt
 var payload = {
   id: 1,
   method: "Cover.GoToPosition",
   params: { id: COVER_ID, pos: pos }
 };
 
 Shelly.call("http.request", {
   method: "POST",
   url: "http://" + COVER_IP + "/rpc",
   body: JSON.stringify(payload),
   timeout: 10
 }, function(res, error_code, error_msg) {
   if (error_code !== 0 || !res || res.code !== 200) {
     print("Markisen-Befehl FEHLGESCHLAGEN: " + (error_msg || JSON.stringify(res)));
   }
 });
 
 print("Windschutz aktiv → Markise fährt auf " + pos + " %");
}

// ------------------- BTHOME PARSER (für BRESSER WS90) -------------------
/**
* Definition der vom WS90 gesendeten Datenfelder (BTHome v2 Format)
* Wichtig sind besonders:
* 0x44 = Windgeschwindigkeit Durchschnitt (m/s mit Faktor 0.01)
* 0x44 (zweiter Wert im Array) = Windböe (m/s)
*/
var T = {
 0x00:{n:"pid",len:1,s:false,f:1},
 0x01:{n:"battery_pct",len:1,s:false,f:1},
 0x45:{n:"temperature_c",len:2,s:true,f:0.1},
 0x2E:{n:"humidity_pct",len:1,s:false,f:1},
 0x04:{n:"pressure_hpa",len:3,s:false,f:0.01},
 0x05:{n:"illuminance_lux",len:3,s:false,f:0.01},
 0x08:{n:"dew_point_c",len:2,s:true,f:0.01},
 0x0C:{n:"capacitor_voltage_v",len:2,s:false,f:0.001},
 0x20:{n:"moisture",len:1,s:false,f:1},
 0x44:{n:"wind_speed_ms",len:2,s:false,f:0.01},     // <--- wichtig für uns
 0x46:{n:"uv_index",len:1,s:false,f:0.1},
 0x5E:{n:"wind_direction_deg",len:2,s:false,f:0.01},
 0x5F:{n:"precip_mm",len:2,s:false,f:0.1}
};

/**
* Wandelt String oder anderes Format sicher in Byte-Array um
*/
function ensureBytes(x) {
 if (!x) return null;
 if (typeof x === "string") {
   var b = [];
   for (var i = 0; i < x.length; i++) b.push(x.charCodeAt(i));
   return b;
 }
 return x;
}

/**
* Parsed die BTHome v2 Daten des WS90
* Liefert ein Objekt mit den ausgelesenen Werten zurück
*/
function parseBTHome(buf) {
 if (!buf || !buf.length) return null;
 var di = buf[0], enc = (di & 1) === 1, ver = (di >> 5) & 7;
 if (ver !== 2 || enc) return null;                // Nur unverschlüsselte BTHome v2 Pakete
 var i = 1, out = {};
 while (i < buf.length) {
   var id = buf[i++], def = T[id];
   if (!def) break;                                // Unbekannte ID → Ende
   if (i + def.len > buf.length) break;            // Zu wenig Daten → Abbrechen
   var v = 0;
   for (var j = 0; j < def.len; j++) v |= (buf[i + j] << (8 * j));
   i += def.len;
   if (def.s) {                                    // Vorzeichenbit prüfen bei signed Werten
     var bits = 8 * def.len, sign = 1 << (bits - 1);
     if (v & sign) v -= (1 << bits);
   }
   var val = v * def.f;
   // Falls derselbe Typ mehrfach vorkommt (z.B. Wind Durchschnitt + Böe) → Array
   if (out[def.n] !== undefined) {
     if (Array.isArray(out[def.n])) out[def.n].push(val);
     else out[def.n] = [out[def.n], val];
   } else {
     out[def.n] = val;
   }
 }
 return out;
}

// ------------------- LAUFZEIT-LOGIK -------------------
var allowedSet = {};
// MAC-Adressen ohne Doppelpunkt in Set für schnellen Lookup
for (var i = 0; i < allowedMacAddresses.length; i++) {
 allowedSet[macNoColonLower(allowedMacAddresses[i])] = true;
}

var cache = {};                    // Letzte empfangene Werte pro MAC zwischenspeichern
var lastWarningTs = {};            // Zeitstempel der letzten Wind-Warnung pro Sensor (für Debouncing)

print("WS90 Windschutz-Script gestartet");
debug(1, "Markisen-IP: " + COVER_IP + " | Zielposition bei Wind: " + TARGET_POSITION + " %");

// BLE-Scanner Callback – wird bei jedem empfangenen Werbepaket aufgerufen
BLE.Scanner.Subscribe(function(ev, res) {
 if (ev !== BLE.Scanner.SCAN_RESULT || !res) return;

 var mac = macNoColonLower(res.addr || res.address || "");
 // Nur bekannte Sensoren verarbeiten
 if (!allowedSet[mac]) return;

 // BTHome-Daten aus Service-Data UUID FCD2 holen
 var raw = res.service_data && (res.service_data["fcd2"] || res.service_data["FCD2"]);
 if (!raw) return;

 var data = parseBTHome(ensureBytes(raw));
 if (!data) return;

 // Aktuelle Werte mit evtl. bereits gecachten Werten mergen
 var merged = cache[mac] || {};
 for (var k in data) {
   if (k !== "_ids") merged[k] = data[k];
 }

 // Bei Windgeschwindigkeit kommen oft zwei Werte: [Durchschnitt, Böe]
 if (Array.isArray(merged.wind_speed_ms)) {
   merged.wind_gust_ms = merged.wind_speed_ms[1];
   merged.wind_speed_ms = merged.wind_speed_ms[0];
 }

 merged.ts = (Date.now() / 1000) | 0;   // Unix-Timestamp in Sekunden
 cache[mac] = merged;

 // Ausgabe der aktuellen Windwerte ins Log
 print("Wind: " + (merged.wind_speed_ms || 0).toFixed(2) + " m/s | Böe: " + (merged.wind_gust_ms || 0).toFixed(2) + " m/s");

 // Prüfen, ob ein Grenzwert überschritten wurde
 var exceeded = (merged.wind_speed_ms >= WIND_SPEED_LIMIT_MS) ||
                (merged.wind_gust_ms >= WIND_GUST_LIMIT_MS);

 // Windalarm auslösen – aber nur, wenn Debouncing erlaubt oder genug Zeit vergangen ist
 if (exceeded && (DEBOUNCE_SECONDS === 0 || merged.ts - (lastWarningTs[mac] || 0) >= DEBOUNCE_SECONDS)) {
   print("WINDGRENZWERT ÜBERSCHRITTEN → prüfe Markisenposition");
   lastWarningTs[mac] = merged.ts;

   // Aktuelle Position der Markise abfragen
   queryCoverPosition(function(curr) {
     if (curr === null) {
       debug(1, "Konnte Markisenposition nicht auslesen");
       return;
     }
     if (curr < TARGET_POSITION) {
       print("Markise steht bei " + curr + " % → öffne auf " + TARGET_POSITION + " %");
       setCoverPosition(TARGET_POSITION);
     } else {
       debug(2, "Markise bereits ≥ " + TARGET_POSITION + " % (aktuell " + curr + " %) – nichts zu tun");
     }
   });
 }
});

// ------------------- SCANNER STARTEN -------------------
var DUR = (BLE.Scanner && BLE.Scanner.INFINITE_SCAN) ? BLE.Scanner.INFINITE_SCAN : -1;
BLE.Scanner.Start({ duration_ms: DUR, active: ACTIVE_SCAN });
debug(1, "BLE-Scanner gestartet (aktiv=" + ACTIVE_SCAN + ")");

[
    {
        "id": "ad8515d7de42cafd",
        "type": "server-state-changed",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "outputs": 1,
        "exposeAsEntityConfig": "",
        "entityId": "binary_sensor.licht_eg_flur_input_0_input",
        "entityIdType": "exact",
        "outputInitially": false,
        "stateType": "str",
        "ifState": "",
        "ifStateType": "str",
        "ifStateOperator": "is",
        "outputOnlyOnStateChange": true,
        "for": "0",
        "forType": "num",
        "forUnits": "minutes",
        "ignorePrevStateNull": false,
        "ignorePrevStateUnknown": false,
        "ignorePrevStateUnavailable": false,
        "ignoreCurrentStateUnknown": true,
        "ignoreCurrentStateUnavailable": true,
        "outputProperties": [
            {
                "property": "payload",
                "propertyType": "msg",
                "value": "",
                "valueType": "entityState"
            },
            {
                "property": "data",
                "propertyType": "msg",
                "value": "",
                "valueType": "eventData"
            },
            {
                "property": "topic",
                "propertyType": "msg",
                "value": "",
                "valueType": "triggerId"
            }
        ],
        "x": 250,
        "y": 5960,
        "wires": [
            [
                "7d39aedc9b4540ef"
            ]
        ]
    },
    {
        "id": "4c52fbff207fe606",
        "type": "server-state-changed",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "outputs": 1,
        "exposeAsEntityConfig": "",
        "entityId": "binary_sensor.licht_eg_garderobe_input_0_input",
        "entityIdType": "exact",
        "outputInitially": false,
        "stateType": "str",
        "ifState": "",
        "ifStateType": "str",
        "ifStateOperator": "is",
        "outputOnlyOnStateChange": true,
        "for": "0",
        "forType": "num",
        "forUnits": "minutes",
        "ignorePrevStateNull": false,
        "ignorePrevStateUnknown": false,
        "ignorePrevStateUnavailable": false,
        "ignoreCurrentStateUnknown": true,
        "ignoreCurrentStateUnavailable": true,
        "outputProperties": [
            {
                "property": "payload",
                "propertyType": "msg",
                "value": "",
                "valueType": "entityState"
            },
            {
                "property": "data",
                "propertyType": "msg",
                "value": "",
                "valueType": "eventData"
            },
            {
                "property": "topic",
                "propertyType": "msg",
                "value": "",
                "valueType": "triggerId"
            }
        ],
        "x": 280,
        "y": 6020,
        "wires": [
            [
                "7d39aedc9b4540ef"
            ]
        ]
    },
    {
        "id": "8b96bcf2f99a056c",
        "type": "state-machine",
        "z": "2915acb8b995b9cf",
        "name": "",
        "triggerProperty": "payload",
        "triggerPropertyType": "msg",
        "stateProperty": "payload",
        "statePropertyType": "msg",
        "initialDelay": "0",
        "persistOnReload": true,
        "outputStateChangeOnly": true,
        "throwException": false,
        "states": [
            "off",
            "on"
        ],
        "transitions": [
            {
                "name": "toggle",
                "from": "on",
                "to": "off"
            },
            {
                "name": "toggle",
                "from": "off",
                "to": "on"
            },
            {
                "name": "on",
                "from": "off",
                "to": "on"
            },
            {
                "name": "off",
                "from": "on",
                "to": "off"
            }
        ],
        "x": 500,
        "y": 6140,
        "wires": [
            [
                "0dc92aa8db156e4b"
            ]
        ]
    },
    {
        "id": "50a3bcc8f368070d",
        "type": "inject",
        "z": "2915acb8b995b9cf",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "on",
        "payloadType": "str",
        "x": 110,
        "y": 6100,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "b563a903aaa2c89a",
        "type": "inject",
        "z": "2915acb8b995b9cf",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "off",
        "payloadType": "str",
        "x": 110,
        "y": 6140,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "3e53de8242e98ddb",
        "type": "inject",
        "z": "2915acb8b995b9cf",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "toggle",
        "payloadType": "str",
        "x": 110,
        "y": 6180,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "0dc92aa8db156e4b",
        "type": "switch",
        "z": "2915acb8b995b9cf",
        "name": "",
        "property": "payload",
        "propertyType": "msg",
        "rules": [
            {
                "t": "eq",
                "v": "on",
                "vt": "str"
            },
            {
                "t": "eq",
                "v": "off",
                "vt": "str"
            }
        ],
        "checkall": "true",
        "repair": false,
        "outputs": 2,
        "x": 650,
        "y": 6140,
        "wires": [
            [
                "0676987b9cef207e",
                "abd1d01360e618d4"
            ],
            [
                "8417e502256b43b8"
            ]
        ]
    },
    {
        "id": "48764c9766fa6b04",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "switch",
        "service": "turn_on",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "switch.licht_eg_flur"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 1220,
        "y": 6040,
        "wires": [
            []
        ]
    },
    {
        "id": "90a15ffdb0cbe246",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "switch",
        "service": "turn_on",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "switch.licht_eg_garderobe"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 1220,
        "y": 6100,
        "wires": [
            []
        ]
    },
    {
        "id": "68c54b151cc1ab57",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "switch",
        "service": "turn_off",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "switch.licht_eg_flur"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 1220,
        "y": 6180,
        "wires": [
            []
        ]
    },
    {
        "id": "2725331f92224956",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "switch",
        "service": "turn_off",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "switch.licht_eg_garderobe"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 1220,
        "y": 6240,
        "wires": [
            []
        ]
    },
    {
        "id": "7d39aedc9b4540ef",
        "type": "change",
        "z": "2915acb8b995b9cf",
        "name": "",
        "rules": [
            {
                "t": "set",
                "p": "payload",
                "pt": "msg",
                "to": "toggle",
                "tot": "str"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 630,
        "y": 5980,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "0676987b9cef207e",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "input_boolean",
        "service": "turn_on",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "input_boolean.licht_flur_gesamt"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 920,
        "y": 6080,
        "wires": [
            [
                "48764c9766fa6b04",
                "90a15ffdb0cbe246"
            ]
        ]
    },
    {
        "id": "8417e502256b43b8",
        "type": "api-call-service",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "debugenabled": false,
        "domain": "input_boolean",
        "service": "turn_off",
        "areaId": [],
        "deviceId": [],
        "entityId": [
            "input_boolean.licht_flur_gesamt"
        ],
        "data": "",
        "dataType": "jsonata",
        "mergeContext": "",
        "mustacheAltTags": false,
        "outputProperties": [],
        "queue": "none",
        "x": 920,
        "y": 6200,
        "wires": [
            [
                "68c54b151cc1ab57",
                "2725331f92224956"
            ]
        ]
    },
    {
        "id": "98ad6a70bb84df43",
        "type": "server-state-changed",
        "z": "2915acb8b995b9cf",
        "name": "",
        "server": "5a3777c7.b71588",
        "version": 5,
        "outputs": 2,
        "exposeAsEntityConfig": "",
        "entityId": "input_boolean.licht_flur_gesamt",
        "entityIdType": "exact",
        "outputInitially": false,
        "stateType": "str",
        "ifState": "on",
        "ifStateType": "str",
        "ifStateOperator": "is",
        "outputOnlyOnStateChange": true,
        "for": "0",
        "forType": "num",
        "forUnits": "minutes",
        "ignorePrevStateNull": false,
        "ignorePrevStateUnknown": false,
        "ignorePrevStateUnavailable": false,
        "ignoreCurrentStateUnknown": true,
        "ignoreCurrentStateUnavailable": true,
        "outputProperties": [
            {
                "property": "payload",
                "propertyType": "msg",
                "value": "",
                "valueType": "entityState"
            },
            {
                "property": "data",
                "propertyType": "msg",
                "value": "",
                "valueType": "eventData"
            },
            {
                "property": "topic",
                "propertyType": "msg",
                "value": "",
                "valueType": "triggerId"
            }
        ],
        "x": 220,
        "y": 6240,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ],
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "abd1d01360e618d4",
        "type": "delay",
        "z": "2915acb8b995b9cf",
        "name": "",
        "pauseType": "delay",
        "timeout": "300",
        "timeoutUnits": "seconds",
        "rate": "1",
        "nbRateUnits": "1",
        "rateUnits": "second",
        "randomFirst": "1",
        "randomLast": "5",
        "randomUnits": "seconds",
        "drop": false,
        "allowrate": false,
        "outputs": 1,
        "x": 990,
        "y": 5900,
        "wires": [
            [
                "f2dd8e3f8b5c3c13"
            ]
        ]
    },
    {
        "id": "f2dd8e3f8b5c3c13",
        "type": "change",
        "z": "2915acb8b995b9cf",
        "name": "",
        "rules": [
            {
                "t": "set",
                "p": "payload",
                "pt": "msg",
                "to": "off",
                "tot": "str"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 990,
        "y": 5960,
        "wires": [
            [
                "8b96bcf2f99a056c"
            ]
        ]
    },
    {
        "id": "5a3777c7.b71588",
        "type": "server",
        "name": "Home Assistant",
        "version": 5,
        "addon": true,
        "rejectUnauthorizedCerts": true,
        "ha_boolean": "y|yes|true|on|home|open",
        "connectionDelay": false,
        "cacheJson": true,
        "heartbeat": false,
        "heartbeatInterval": "30",
        "areaSelector": "friendlyName",
        "deviceSelector": "friendlyName",
        "entitySelector": "friendlyName",
        "statusSeparator": "at: ",
        "statusYear": "hidden",
        "statusMonth": "short",
        "statusDay": "numeric",
        "statusHourCycle": "h23",
        "statusTimeFormat": "h:m",
        "enableGlobalContextStore": true
    }
]