const idRestzeit = 'Osmose.Restzeit';
const text_ein = ['Filter Max unterschritten, Skimmer & Osmose','\n','wurden wieder eingeschaltet'].join('');
const text_aus = ['Filter Max erreicht, Skimmer & Osmose','\n','wurden abgeschaltet'].join('');

createState(idRestzeit, 300, {type: 'number', unit: 's'});

var Osmosefreigabe = !getState('sonoff.0.Aqua_Float.POWER4').val;
var Schwimmer = getState("sonoff.0.Aqua_Float.POWER1").val;
var Restzeit, timeout_aus, timeout_ein, Magnetventil_Kontrolle;

function Magnetventil_Ein() {
  if (!Magnetventil_Kontrolle && Restzeit > 0 && Osmosefreigabe) {
    Magnetventil_Kontrolle = setInterval(function () {
      if (Restzeit > 0 && Schwimmer && Osmosefreigabe) {
        Restzeit--;
        setState(idRestzeit, 2 * Restzeit, true);
      } else {
        setState("sonoff.0.Aqua_Control.POWER1"/*Osmose_Magnetventil*/, false);
        clearInterval(Magnetventil_Kontrolle); 
        Magnetventil_Kontrolle = null;
      }
    }, 2000);
    setState("sonoff.0.Aqua_Control.POWER1"/*Osmose_Magnetventil*/, true);
  }
}

// Skripstart
setTimeout(function() {
    Restzeit = getState(idRestzeit).val / 2;
    if(Schwimmer && Osmosefreigabe) Magnetventil_Ein();
    else setState("sonoff.0.Aqua_Control.POWER1"/*Osmose_Magnetventil*/, false);
}, 200);

on({id: 'sonoff.0.Aqua_Float.POWER1', change: "ne"}, function (obj) {
  Schwimmer = obj.state.val;
  log('Schwimmer: ' + Schwimmer)
  if(Schwimmer) Magnetventil_Ein();
  else setState("sonoff.0.Aqua_Control.POWER1"/*Osmose_Magnetventil*/, false);
});

schedule("0 0 * * *", function () {
  Restzeit = 150;
  setState(idRestzeit, 300, true);
  if(Schwimmer) Magnetventil_Ein();
});

on({id: 'sonoff.0.Aqua_Float.POWER4', change: "ne"}, function (obj) {
  if (obj.state.val) {
    timeout_aus = setTimeout(function () {
      Osmosefreigabe = false;  
      setState("sonoff.0.Aqua_Power.POWER3"/*Aqua_Power_Skimmer*/, false);
      setState("sonoff.0.Aqua_Control.POWER1"/*Osmose_Magnetventil*/, false);
    }, 5000);
    if (timeout_ein) {
        clearTimeout(timeout_ein); 
        timeout_ein = null;
    }
  } else {
    timeout_ein = setTimeout(function () {
      Osmosefreigabe = true;
      if(Schwimmer) Magnetventil_Ein();           
      setStateDelayed("sonoff.0.Aqua_Power.POWER3"/*Aqua_Power_Skimmer*/, true, 10000);
    }, 10000);
    if (timeout_aus) {
        clearTimeout(timeout_aus); 
        timeout_aus = null;
    }
  }
});
 
on({id: 'sonoff.0.Aqua_Power.POWER3', change: "ne"}, function (obj) {
  var txt;  
  if (obj.state.val) txt = text_ein;   
  else txt = text_aus;   
  sendTo("telegram.0", "send", {
    text: txt
  });
  log(txt);
});