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 + ")");