Hier mal ein Simpel_Webhooks Script.
Das Script löst folgende Aufgabenstellung:
Nachfolgend die Szene, um die es geht.
---Wenn
Shelly 2.5 - 192.168.178.XXX - Kanal 1 - Licht Wohnzimmer Aus ist
---und
Shelly Plug S 192.168.178. XXX - Licht Schrank Aus ist
---und
Shelly 2.5 - 192.168.178. XXX - Kanal 0 - Licht Kranz An ist
---und
Shelly Color Bulb - 192.168.178. XXX - Licht Schlafzimmer Wand Aus ist
---Dann (Machen)
Shelly 2.5 - 192.168.178. XXX - Kanal 0 - Licht Kranz Aus
- Die Option "update_interval", gibt an wie oft, das Script, aktiv den Status einholen soll.
(Bei jedem Script-Start wird der aktuelle Status einmal aktiv eingeholt.)
- Der "endpoint_Name", so wie die Namen der Shellys, sind frei wählbar.
(Ohne Leerzeichen, Sonderzeichen und keine doppelten Namen!)
- Unter den Optionen "debounced_shellys" und "debounce_delay" kann man für Shellys eine Status Entprellung einstellen.
(Achtung mehrere debounced_shellys teilen sich einen Timer Handler!)
- Die max. Anzahl der nutzbaren Shellys hängt vom verfügbaren Speicher des Shelly ab auf dem das Script läuft,
(Generell, gilt gen2 kann weniger als gen3 und bei "out of Memory" Errors ist Schluss,)
Die Einstellungen können wie folgt im Script aussehen:
Bei Script-Start erhält man eine Ausgabe mit sämtlichen Action-URLs, die auf den jeweiligen Shellys in einer passenden Action angelegt werden müssen, für passive Status Updates:
Und in diesem Bereich der Funktion "Logic()" kann man seine Logik/Bedingungen über das "saved_states" Object festlegen und durch Call() ausführen:
Ich helfe gerne beim Formulieren von korrekten If-Bedingungen, bzw. der Logik, aus. Bitte postet eure Anfrage, ähnlich dem oberen Beispiel "wenn, und, dann", direkt hier im Thread und ich werde mich bemühen, dieser nachzukommen.
Status: getestet
Shelly Script:
Simpel_Webhooks v0.4.5
//____Simpel_Webhooks_v0.4.5____
//Config
var shelly_Password= "", //'shelly_Password' is only required if a device passwort has been set, local and remote pw needs to be the same.
update_interval= 1, //Forced state update inverval, in hours, 0 to switch it off
endpoint_Name= "Kranzautomatic", //Just some name, can be anythink, as string
debug= false, //Create some Debug log outputs.
debounce_delay= 1, //Passiv Update Delay, in seconds
debounced_shellys= ["Licht_Kranz"], //Debounced shellys, has to be part of shellys
no_relay= [], //Shellys or states which are treated as inputs without relays, has to be part of shellys
shellys= {
"Licht_Wohnzimmer": {"on": true,"off": false, ip: "192.168.178.14/relay/1"},
"Licht_Schrank": {"on": true,"off": false, ip: "192.168.178.23/relay/0"},
"Licht_Schlafzimmer": {"on": true,"off": false, ip: "192.168.178.27/light/0"},
"Licht_Kranz": {"on": true,"off": false, ip: "192.168.178.14/relay/0"},
};
function Save_state(res,key){
try{
if(!res || res.code !== 200) return; //Abbruch bei nem Fehler
let val= shellys[key].value || 'ison';
if(res.body) saved_states[key]= JSON.parse(res.body)[val]; //Antwort in brauchbares umwandeln und speichern
Logic(); //Call some Logic
}catch(e){ErrorMsg(e,'Save_state()',debug);}
}
var tH1= 0;
function Forced_state_update(start){
try{
if(!tH1 && update_interval > 0) tH1= Timer.set(1000*60*60*update_interval,true,Forced_state_update);
Object.keys(shellys).forEach(function(key){
if(start) shelly_Password.length > 0 ? shellys[key].ip= 'http://admin:'+shelly_Password+'@'+shellys[key].ip: shellys[key].ip= 'http://'+shellys[key].ip; //Create Link
var skip= false;
no_relay.forEach(function(e_key){if(e_key === key) skip= true;}); //no_relay skip check
if(!skip) Call('http.get',{url: shellys[key].ip},Save_state,key,debug); //Get states
skip= false;
if(start) output_array.push('\nHeadline: The Aktion Links for your Shelly _['+key+']_ are:'); //print('\nHeadline: The Aktion Links for your Shelly _[',key,']_ are:');
Object.keys(shellys[key]).forEach(function(value_key){
if(start && value_key !== 'ip' && value_key !== 'value') output_array.push('--> '+url+'?'+key+'='+value_key); //print('--> ',url+'?'+key+'='+value_key);
});
if(start) output_array.push('Endline: You need to configure an action for each Link on the _['+key+']_ Shelly!'); //print('Endline: You need to configure an action for each Link on the _[',key,']_ Shelly!');
});
}catch(e){ErrorMsg(e,'Forced_state_update()',debug);}
}
function Logic(){
try{
if(debug) print('Debug: saved_states -->', saved_states);
if(Object.keys(saved_states).length < Object.keys(shellys).length) return; //Exit if mising states
//if x and y and z do k --- > logic
if(!saved_states.Licht_Wohnzimmer&& !saved_states.Licht_Schrank && !saved_states.Licht_Schlafzimmer && saved_states.Licht_Kranz) {
Call("http.get",{url:shellys.Licht_Kranz.ip+"?turn=off"},null,null,debug); //Turn Kranz off
}
}catch(e){ErrorMsg(e,'Logic()',debug);} //Error Handling
}
var saved_states= {}; //object to save some remote states, global
function State_update(remote_state_key,remote_state_value) {
try{
//Advance query managment
Object.keys(shellys).forEach(function(key){
if(key === remote_state_key){
remote_state_key= 'valid';
Object.keys(shellys[key]).forEach(function(value_key){
if(value_key === remote_state_value){
saved_states[key]= shellys[key][remote_state_value]; //save remote state
remote_state_value= 'valid';
}
});
}
});
//Error Handling
if(remote_state_key !== 'valid') throw new Error('--> _[ '+remote_state_key+' ]_ is a invalid key!');
if(remote_state_value !== 'valid') throw new Error('--> _[ '+remote_state_value+' ]_ is a invalid value!');
//Call some logic to work with the saved states.
Logic();
}catch(e){ErrorMsg(e,'State_update()',debug);} //Error Handling
}
tH2= 0;//Timer Entprell Handler
function Endpoint_Loop(request, response){
try{
response.code= 200; //Response Code "ok", Shelly Actions cant handel other response
response.body= 'ok';
response.send(); //Send response to connected Client
if(!request.query || request.query.indexOf('=') === -1) return; //Exit if there is no query or invalid query
var found= null;
debounced_shellys.forEach(function(key){if(Cut(request.query,key))found= key;}); //Search for debounced shellys
if(found){
if(debug) print('Debug: debounced shelly _[',found,']_ delayed for',debounce_delay,'seconds..');
if(tH2) Timer.clear(tH2); tH2= 0; //Clear Timer
tH2= Timer.set(1000*debounce_delay,0,function(){State_update(Cut(request.query,'=',0,1),Cut(request.query,'=',1));}); //Delayed passiv update
}else{
State_update(Cut(request.query,'=',0,1),Cut(request.query,'=',1)); //Passiv update
}
}catch(e){ErrorMsg(e,'Endpoint_Loop()',debug);} //Error Handling
}
var output_array= [];
function FW_Print_Bug_Fix(){ //Workaround for a Shelly FW 1.2.0 print() bug
print(output_array.pop());
if(!output_array.length) Timer.clear(tH5);
}
function Reverse(arr){ //Reverse Array order
let rArr= [];
for(i in arr){rArr[(arr.length-1)-i]= arr[i];}
return rArr;
}
var url= 0, tH5= 0;
function Main(){
url= 'http://admin:'+shelly_Password+'@'+Shelly.getComponentStatus('wifi').sta_ip+HTTPServer.registerEndpoint(endpoint_Name, Endpoint_Loop);
print('Info: Your HTTP Endpoint URL is:\n',url,"\n");
Forced_state_update(true); //Start inverval forced state updates
if(!tH5) tH5= Timer.set(1000, true, FW_Print_Bug_Fix);
output_array= Reverse(output_array);
}
//Toolbox v1.0(base), a universal Toolbox for Shelly scripts
function ErrorChk(r,e,m,d){ //Shelly.call error check
try{
aC--; if(aC<0) aC= 0;
if(d.CB && d.uD) d.CB(r,d.uD); if(d.CB && !d.uD) d.CB(r);
if(!d.CB && d.uD) print('Debug: ',d.uD); if(e) throw new Error(Str(m));
if(Str(r) && Str(r.code) && r.code !== 200) throw new Error(Str(r));
}catch(e){ErrorMsg(e,'ErrorChk(), call Answer');}}
function Cqueue(){ //Shelly.call queue
try{
if(!cCache[0] && !nCall[0]) return;
while(cCache[0] && aC < callLimit){if(cCache[0] && !nCall[0]){nCall= cCache[0]; cCache.splice(0,1);}
if(nCall[0] && aC < callLimit){Call(nCall[0],nCall[1],nCall[2],nCall[3],nCall[4]); nCall= [];}} if(tH9){Timer.clear(tH9); tH9= 0;}
if(nCall[0] || cCache[0])if(cSp <= 0) cSp= 0.1; tH9= Timer.set(1000*cSp,0,function(){tH9= 0; Cqueue();});}catch(e){ErrorMsg(e,'Cqueue()');}}
function Call(m,p,CB,uD,deBug){ //Upgrade Shelly.call
try{
let d= {};
if(deBug) print('Debug: calling:',m,p); if(CB) d.CB= CB; if(Str(uD)) d.uD= uD; if(!m && CB){CB(uD); return;}
if(aC < callLimit){aC++; Shelly.call(m,p,ErrorChk,d);}else if(cCache.length < cacheLimit){
cCache.push([m,p,CB,uD,deBug]); if(deBug) print('Debug: save call:',m,p,', call queue now:',cCache.length); Cqueue();
}else{throw new Error('to many Calls in use, droping call: '+Str(m)+', '+Str(p));}}catch(e){ErrorMsg(e,'Call()');}}
function Str(d){ //Upgrade JSON.stringify
try{
if(d === null || d === undefined) return null; if(typeof d === 'string')return d;
return JSON.stringify(d);}catch(e){ErrorMsg(e,'Str()');}}
function Cut(f,k,o,i){ //Upgrade slice f=fullData, k=key-> where to cut, o=offset->offset behind key, i=invertCut
try{
let s= f.indexOf(k); if(s === -1) return null; if(o) s= s+o.length || s+o; if(i) return f.slice(0,s);
return f.slice(s);}catch(e){ErrorMsg(e,'Cut()');}}
function Setup(){ //Wating 2sek, to avoid a Shelly FW Bug
try{
if(Main && !tH9){tH9= Timer.set(2000,0,function(){print('\nStatus: started Script _[', scriptN,']_');
if(callLimit > 4){callLimit= 4;} try{Main();}catch(e){ErrorMsg(e,'Main()'); tH9= 0; Setup();}});}}catch(e){ErrorMsg(e,'Setup()');}}
function ErrorMsg(e,s,deBug){ //Toolbox formatted Error Msg
try{
let i=0; if(Cut(e.message, '-104: Timed out')) i= 'wrong URL or device may be offline';
if(Cut(e.message, 'calls in progress')) i= 'reduce _[ callLimit ]_ by 1 and try again, its a global variabel at the end of the toolbox';
if(s === 'Main()' || deBug) i= e.stack; if(Cut(e.message, '"Main" is not')) i= 'define a Main() function before using Setup()';
print('Error:',s || "",'---> ',e.type,e.message); if(i) print('Info: maybe -->',i);}catch(e){print('Error: ErrorMsg() --->',JSON.stringify(e));}}
var tH8= 0, tH9= 0, aC= 0, cCache= [], nCall= [], callLimit= 4, cacheLimit= 40, cSp= 0.1; //Toolbox global variable
var Status= Shelly.getComponentStatus, Config= Shelly.getComponentConfig; //Renamed native function
var info= Shelly.getDeviceInfo(), scriptID= Shelly.getCurrentScriptId(), scriptN= Config('script',scriptID).name; //Pseudo const, variabel
//Toolbox v1.0(base), Shelly FW >1.0.8
Setup();Falls jemand zusätzliche Querys benötigt, oder intresse an dem Script Aufbau hat, hier ist ein Beispiel für Einsteiger. Viel Spaß mit dem Script.
