{
  'message':'init',
  'inputs':[ {
    'inputtype':0, 'usage':2, 'group':8, /* schwarz: Joker */
    'hardwarename': 'Internet-Test',
    'updateinterval': 300, 'alivesigninterval': 900
  }]
}

// Diese URL muss im Internet erreichbar sein. Das Apple-Beispiel funktioniert as-is,
// aber Sie können jede andere URL nehmen, die zuverlässig erreichbar ist und eine möglichst kleine
// Antwort liefert (aus Effizienzgründen)
var testurl = "http://www.apple.com/library/test/success.html"

// alle 5 Minuten:
on (every(0:05)) {
  var msg = {'message':'input', 'index':0 }
  try {
    // Wenn "testurl" innert 10 Sek eine fehlerfreie Antwort liefert, ist die Internetverbindung da
    var ans = geturl(testurl, 10)
    log(6, "Internet is ok")
    msg.value = 1
  }
  catch as e {
    // Fehler oder Timeout beim Zugriff auf die "testurl"
    log(4, "Kein Internet-Zugriff")
    msg.value = 0
  }
  message(msg)
}

// Wichtig: signalisiert, dass es ok ist dass das Skript hier beendet
//   Nur der Handler läuft im Hintergrund.
//   Fehlt dieses "return true", wird die Implementation 20 Sekunden nach
//   Beenden neugestartet (in der Annahme, es sei ein Fehler aufgetreten)
return true

{
  'message':'init',
  'protocol':'simple',
  'group':3, /* Blau/Klima */
  'name':'RPi CPU temp.', /* initialer Name */
  'sensors':[
    /* sensortype1 = Temperatur, updateinterval = 60 = einmal ausgelesen pro Minute */
    {'sensortype':1,'usage':1,'hardwarename':'RPiCPU','min':0,'max':100,'resolution':0.1, 'updateinterval':60}
  ]
}

// Jede Minute:
on(every(0:01)) {
  // den Wert aus dem File auslesen, als Zahl behandeln und skalieren (File liefert 1/1000 Grad)
  var t = number(readfile('/sys/class/thermal/thermal_zone0/temp'))/1000;
  // als Sensorwert melden
  message(format("S0=%.1f",t))
}

// Wichtig: signalisiert, dass es ok ist dass das Skript hier beendet
//   Nur der Handler läuft im Hintergrund.
//   Fehlt dieses "return true", wird die Implementation 20 Sekunden nach
//   Beenden neugestartet (in der Annahme, es sei ein Fehler aufgetreten)
return true

{
  'message':'init',
  'name':'dingz dimmer',
  'output':'light'
}

// Konfiguration
// - IP-Adresse des dingz
var ip='192.168.1.123'
// - welcher Dimmer?
var dimmerindex=0

// Implementation
on (message()) as m {
  if (m.message=='channel' && m.index==0) {
    var ramp = 25 // dingz default = 25*10mS
    if (isok(m.transition)) ramp = m.transition*100 // Sek -> 10mS
    var post = format(
      'http://%s/api/v1/dimmer/%d/on?value=%d&ramp=%d',
      ip, dimmerindex, m.value, ramp
    )
    log(6, "posting: %s", post)
    posturl(post, 5)
  }
}

return true

// http-Requests von Geräten (verbesserte Version 2023-01-18)
on(webrequest()) as request
{
  log(6, "webrequest = %s", request)
  try {
    // Request verarbeiten
    if (isok(request.dingz)) {
      // das ist ein Request von einem dingz
      // - weiterleiten via dignz_signal_192_168_ip_ip
      var s = ifok(globalvars()['dingz_signal_'+replace(request.peer,'.','_')], false)
      if (isok(s)) s.send(request)
    }
    // immer beantworten
    request.answer({ "status":"ok" })
  }
  catch as e {
    log(4, "Fehler bei Request-Verarbeitung: %s", e)
    // auch im Fehlerfall: Antwort, damit der Client nicht bis zum Timeout hängen bleibt
    request.answer({ "status":"error" })
  }
}

{
  'message':'init',
  'group':1, /* Gelb/Licht */
  'name':'dingz button 1', /* initialer Name */
  'buttons':[
    { "buttontype":1, "group":1 }
  ]
}

{
  "message": "init",
  "uniqueid": "dingz_twoway_1234", /* gleich für beide Teile, aber unterschiedlich für jedes Tasterpäärchen! */
  "subdeviceindex": 0, /* erste Teil des Zweiwege-Tasters */
  "group":8, /* Joker */
  "buttons": [{
    "buttontype": 0, "group":1, "combinables": 2, "hardwarename": "up"
  }]
}

{
  "message": "init",
  "uniqueid": "dingz_twoway_1234", /* gleich wie beim ersten Teil */
  "subdeviceindex": 1, /* anderer Teil des Zweiwege-Tasters */
  "group":8, /* Joker */
  "buttons": [{
    "buttontype": 0, "group":1, "combinables": 2, "hardwarename": "down"
  }]
}

// Konfiguration
// - IP-Adresse des dingz
var ip='192.168.1.123'
// - welcher Button?
var button="button1"

// Implementation (verbessert 2022-10-18)
var signame = 'dingz_signal_'+replace(ip,'.','_')
var sig
if (!isok(globalvars()[signame])) {
  // signal fuer diese IP existiert noch nicht: neu anlegen
  globalvars()[signame] = signal()
}
// existierendes oder neu angelegtes signal verwenden
sig = globalvars()[signame]

on (sig) as s {
  log(6, "s = %s", s)
  if (s.dingz==button) {
    // das ist der richtige button
    var msg = {'message':'button', 'index':0 }
    if (s.click==0) {
      // Button losgelassen
      msg.value = -10
    }
    else if (s.click==5) {
      // Button länger gehalten
      msg.value = -11
    }
    else {
      // 1..4-fach click, direkt einspeisen (negativer value)
      msg.value = -s.click
    }
    message(msg)
  }
}

return true;

{
  "message":"init",
  "modelname":"DingZ_Motion",
  "colorclass":6,
  "inputs": [
    {
      "inputtype":5,
      "usage":1,
      "group":6,
      "hardwarename":"motion"
    }
  ]
}

// Konfiguration
// - IP-Adresse des dingz
var ip='192.168.x.x'
// - welcher Eingang (motion_internal/motion_external)
var input="motion_internal"

// Implementierung (verbessert 2022-10-18)
var signame = 'dingz_signal_'+replace(ip,'.','_')
var sig
if (!isok(globalvars()[signame])) {
  // Signal für diese IP existiert noch nicht: neues Signal erstellen
  globalvars()[signame] = signal()
}
// vorhandenes oder neu erstelltes Signal verwenden
sig = globalvars()[signame]

on (sig) as s {
  log(6, "s = %s", s)
  if (s.dingz==input) {
    // dies ist der richtige Eingang
    var msg = {'message':'input', 'index':0 }
    if (s.state>0) {
      // Bewegung erkannt
      msg.value = 1
    }
    sonst {
      // keine Bewegung erkannt
      msg.value = 0
    }
    message(msg)
  }
}

return true;

{
  'message':'init',
  'output':'light', /* mit Ausgang vom Typ "Licht"... */
  'dimmable':false, /* ...jedoch nicht dimmbar */
  'colorclass':8, /* universell verwendbar, in Digital Strom: schwarze Joker-Klemme */
}

// hier muss die richtige IP-Adresse der Steckdose eingetragen werden
var baseurl = "http://192.168.1.42"

// Meldungen vom System (hier: Änderung des Ausgangswerts) behandeln
on (message()) as m {
  // wenn die Meldung den Kanal mit Index 0 (=Helligkeit) betrifft...
  if (m.message=="channel" && m.index==0) {
    try {
      // mySTROM API ansteuern und einschalten, falls Helligkeit > 50%, sonst aus
      geturl(baseurl + format('/relay?state=%d', if(m.value>50, 1, 0)), 5)
      message({ "message":"active","value":true }) // Gerät antwortet: auf aktiv setzen
    }
    catch as err {
      log(6,"mystrom mit url %s antwortet nicht korrekt: %s", baseurl, err)
      message({ "message":"active","value":false }) // Gerät antwortet nicht: auf inaktiv setzen
    }
  }
}

return true // es ist ok, dass das Script hier endet

{
  'message':'init',
  'output':'light', /* mit Ausgang vom Typ "Licht"... */
  'dimmable':false, /* ...jedoch nicht dimmbar */
  'colorclass':8, /* universell verwendbar, in Digital Strom: schwarze Joker-Klemme */
  /* Definition eines Leistungs-Sensor */
  'sensors':[{"sensortype":14,"usage":0,"hardwarename":"power","min":0,"max":2300,"resolution":1,"updateinterval":30,"alivesigninterval":300}]
}

function updatestate()
{
  try {
    var t = geturl(baseurl + '/report');
    log (7, "myStrom reply = %s", t)
    var state = json(t);
    log (6, "myStrom state = %s", state)
    if (isvalid(state.relay)) {
      var msg = { "message":"channel","index":0 }
      msg.value = if(state.relay, 100, 0);
      message(msg)
    }
    if (isvalid(state.power)) {
      var msg = { "message":"sensor", "index":0 }
      msg.value = state.power;
      message(msg)
    }
    message({ "message":"active","value":true }) // Gerät antwortet: auf aktiv setzen
  }
  catch as err {
    log(6,"mystrom mit url %s antwortet nicht korrekt: %s", baseurl, err)
    message({ "message":"active","value":false }) // Gerät antwortet nicht: auf inaktiv setzen
  }
}

// hier muss die richtige IP-Adresse der Steckdose eingetragen werden
var baseurl = "http://192.168.1.42"

on (message()) as m {
  if (m.message=="channel" && m.index==0) {
    try {
      // mySTROM API ansteuern und einschalten, falls Helligkeit > 50%, sonst aus
      geturl(baseurl + format('/relay?state=%d', if(m.value>50, 1, 0)), 5)
      message({ "message":"active","value":true }) // Gerät antwortet: auf aktiv setzen
    }
    catch as err {
      log(6,"mystrom mit url %s antwortet nicht korrekt: %s", baseurl, err)
      message({ "message":"active","value":false }) // Gerät antwortet nicht: auf inaktiv setzen
    }
  }
}

// Alle 30 Sekunden
on (every(30)) {
  // Status lesen
  updatestate()
}

// beim Start des Geräts aktuellen Zustand sofort lesen
updatestate()

return true // es ist ok, dass das Script hier endet

{
  'message': 'init',
  'protocol': 'simple',
  'group': 8, /* Joker */
  'name': 'OpenWeatherMap.org', /* initialer Name */
  /* Definition der Wetter-Sensoren */
  'sensors': [
    /* S0 */ { 'sensortype': 1,  'usage': 2, 'group': 0, 'hardwarename': 'temperature',   'min': 0, 'max': 100,   'resolution': 0.1, 'updateinterval': 120 },
    /* S1 */ { 'sensortype': 18, 'usage': 2, 'group': 0, 'hardwarename': 'pressure',      'min': 0, 'max': 1200,  'resolution': 1,   'updateinterval': 120 },
    /* S2 */ { 'sensortype': 2,  'usage': 2, 'group': 0, 'hardwarename': 'humidity',      'min': 0, 'max': 100,   'resolution': 1,   'updateinterval': 120 },
    /* S3 */ { 'sensortype': 29, 'usage': 2, 'group': 0, 'hardwarename': 'visibility',    'min': 0, 'max': 10000, 'resolution': 1,   'updateinterval': 120 },
    /* S4 */ { 'sensortype': 13, 'usage': 2, 'group': 0, 'hardwarename': 'wind speed',    'min': 0, 'max': 300,   'resolution': 0.1, 'updateinterval': 120 },
    /* S5 */ { 'sensortype': 19, 'usage': 2, 'group': 0, 'hardwarename': 'wind deg',      'min': 0, 'max': 360,   'resolution': 1,   'updateinterval': 120 },
    /* S6 */ { 'sensortype': 23, 'usage': 2, 'group': 0, 'hardwarename': 'wind gust',     'min': 0, 'max': 300,   'resolution': 0.1, 'updateinterval': 120 },
    /* S7 */ { 'sensortype': 21, 'usage': 2, 'group': 0, 'hardwarename': 'precipitation', 'min': 0, 'max': 1000,  'resolution': 0.1, 'updateinterval': 120 },
    /* S8 */ { 'sensortype': 0,  'usage': 2, 'group': 0, 'hardwarename': 'clouds %',      'min': 0, 'max': 100,   'resolution': 1,   'updateinterval': 120 }
  ]
}

function updateweather()
{
  try {
    var t = geturl(baseurl,30)
  }
  catch {
    return true
  }

  log (7, "OpenWeatherMap reply = %s", t)
  var weather = json(t);
  log (6, "OpenWeatherMap weather = %s", weather)

  if (isvalid(weather.main.temp)) {
    message(format("S0=%.1f",weather.main.temp))
  }
  if (isvalid(weather.main.pressure)) {
    message(format("S1=%.1f",weather.main.pressure))
  }
  if (isvalid(weather.main.humidity)) {
    message(format("S2=%.1f",weather.main.humidity))
  }
  if (isvalid(weather.visibility)) {
    message(format("S3=%.1f",weather.visibility))
  }
  if (isvalid(weather.wind.speed)) {
    message(format("S4=%.1f",weather.wind.speed))
  }
  if (isvalid(weather.wind.deg)) {
    message(format("S5=%.1f",weather.wind.deg))
  }
  /* ohne Boeninfo -> keine Boe */
  message(format("S6=%.1f", ifvalid(weather.wind.gust,0)))
  /* Niederschlag */
  var precipitation = ifvalid(
    weather.snow['1h'], // Schnee..
    ifvalid(
      weather.rain['1h'], // falls kein Schnee: Regen
      0 // weder Schnee noch Regen
    )
  )
  message(format("S7=%.1f",precipitation))
  /* Bewoelkung */
  if (isvalid(weather.clouds.all)) {
    message(format("S8=%.1f",weather.clouds.all))
  }
}

// hier muss der OpenWeatherMap API key, Ort und Land eingetragen werden
var openweathertoken = 'API_key'; // API key
var openweathercity = 'Zug'; // Ortsname
var openweathercountry = 'CH'; // Land
var baseurl = string('https://api.openweathermap.org/data/2.5/weather?q=' + openweathercity + '%2C' + openweathercountry +  '&units=metric&appid=' + openweathertoken)

// Alle 120 Sekunden
on (every(120)) {
  // Wetter einlesen
  updateweather()
}

return true // es ist ok, dass das Script hier endet

{
  'message':'init',
  'inputs':[ {
    'inputtype':0, 'usage':2, 'group':6, /* rot: Sicherheit */
    'hardwarename': 'Hagelwarnung VKG',
    'updateinterval': 120, 'alivesigninterval': 360
  }]
}

// hier muss die richtige "deviceid" (= beim VKG angemeldete MAC-Adresse) für den Standort und die
// richtige hwtypeld (so wie von VKG spezifiziert) eingegeben werden
var deviceid = "a1b2c3e4f542"
var hwtypeld = "199"

var firstpoll = "false"

// Gemäss Anleitung des VKG muss die Warnung alle 120 Sekunden abgefragt werden
on (every(120)) {
  var msg = {'message':'input', 'index':0 }
  try {
    // Anmerkung: Das Ausrufezeichen am Anfang der URL schaltet die Zertifikationsprüfung aus,
    // damit die Installation möglichst langfristig läuft, auch wenn der Server
    // später einmal wieder auf andere Root-Zertifikate setzt (wie im Sept 2022 geschehen)
    var url = "!https://meteo.netitservices.com/api/v1/devices/" + deviceid + "/poll?firstpoll=" + firstpoll + "&hwtypeId=" + hwtypeld
    var ans = json(geturl(url))
    // Eingangswert auf 1 falls Hagel (echt oder test), sonst auf 0
    msg.value = if(ans.hailState!=0, 1, 0)
  }
  catch as e {
    log(4, "Fehler bei Abfrage des Hagelservice: %s", e)
    // Sensor als ungültig markieren
    msg.value = null
  }
  message(msg)
}

return true // es ist ok, dass das Script hier endet

{ 'message':'init', 'name':'Casambi demo light', 'output':'light' }

glob casambi_api_key = "XXXXX" // Hier API-Key eintragen
glob casambi_user = "test@testhaus.ch" // Hier Casambi API Login-Email eintragen
glob casambi_password = "xxxxxx" // Hier Casambi API Passwort eintragen
var unitid = "1" // Unit-ID (Nummer) des Dimmers hier eintragen

glob casambi_network
glob casambi_websocket
glob casambi_reconnect_signal

casambi_reconnect_signal = signal()

while (true) {
  if (!isvalid(casambi_network)) {
    var req = {
      "url":"https://door.casambi.com/v1/networks/session",
      "method":"POST",
      "data":{},
      "headers":{}
    }
    req.headers['X-Casambi-Key'] = casambi_api_key
    req.data.email = casambi_user
    req.data.password = casambi_password
    var resp = json(httprequest(req))
    casambi_network=resp[resp[0]];
  }
  log("casambi_network: %s", casambi_network)

  if (!isvalid(casambi_websocket)) {
    var wsurl = "wss://developer.casambi.com/v1/bridge/"
    casambi_websocket = websocket(wsurl, casambi_api_key, 60)
    var wsopen = {
      "method":"open",
      "type":1,
      "id":"NETWORK-ID",
      "ref":"REFERENCE-ID",
      "wire":1
    }
    wsopen.session = casambi_network.sessionId
    wsopen.id = casambi_network.id
    casambi_websocket.send(wsopen)
  }


  on (casambi_websocket.message()) evaluating as msg {
    log("casambi websocket message: %s", msg)
  }

  // forward channel value changes
  on (message()) as m {
    log("device API message: %s", m)
    if (m.message=="channel" && m.index==0) {
      var wsmsg = { "wire": 20, "method":"controlUnit", "targetControls": {"Dimmer": {"value": 0}}}
      wsmsg.id = number(unitid)
      wsmsg.targetControls.Dimmer.value = m.value/100
      log("- sending websocket message: %s", wsmsg)
      try {
        casambi_websocket.send(wsmsg)
      }
      catch as e {
        if (errordomain(e)=="websocket" && errorcode(e)==6) {
          // connection problem
          casambi_websocket = null
          // reconnect
          casambi_reconnect_signal.send()
        }
      }
    }
  }

  // make sure we don't try to reconnect too often
  delay(20)
  // wait for need to reconnect
  await(casambi_reconnect_signal)
  log(4, "Needs reconnect")
}

return true;