script

/*
Created by Heikki Visnapuu, 2026
Licensed under the MIT License
https://github.com/hv-tec/Shelly_PV_off

This Shelly script retrieves 15 min energy market prices from Elering and
activates shelly NO relay to cut off solar panels production.
Events are logged to Supabase. Telegram notifications are handled by
a Supabase Edge Function that batches events from all plants per user.

Taastuvenergia toetusega tootjad: jätke tasakaalustus ja marginaal 0-ks.
Börsilepinguga tootjad: seadistage tasakaalustus ja marginaal vastavalt lepingule.
*/

let CFG = {
  relay_id: 0,
  threshold_eur_kwh: 0,
  check_interval: 120,
  api_timeout: 15,
  tasakaalustus_eur_kwh: 0,
  marginaal_eur_kwh: 0,
  plant_id: "assaku",                  // ← unikaalne id SB jaoks
  plant_name: "Assaku Solar",          // ← inimloetav nimi teavitustes
  supabase_url: "YOUR_SUPABASE_URL",
  supabase_key: "YOUR_SUPABASE_KEY"
};

let state = { relay_on: false, last_price: null };

function nowISO() {
  return new Date(Shelly.getComponentStatus("sys").unixtime * 1000).toISOString();
}

function logEvent(np_price, eff_price, relay_on) {
  Shelly.call("HTTP.POST", {
    url: CFG.supabase_url + "/rest/v1/cutoff_events",
    headers: {
      "apikey": CFG.supabase_key,
      "Authorization": "Bearer " + CFG.supabase_key,
      "Content-Type": "application/json"
    },
    body: JSON.stringify({
      plant_id: CFG.plant_id,
      plant_name: CFG.plant_name,
      timestamp: nowISO(),
      np_price: np_price,
      eff_price: eff_price,
      relay_on: relay_on
    }),
    ssl_ca: "*",
    timeout: CFG.api_timeout
  }, function(res, err) {
    if (err) { print("Supabase log error:", err); return; }
    print("Event logged. relay_on:", relay_on);
  });
}

function setRelay(on, np_price, eff_price) {
  if (state.relay_on === on) return;

  Shelly.call("Switch.Set", { id: CFG.relay_id, on: on }, function(r, e) {
    if (e) { print("Relay error:", e); return; }
    state.relay_on = on;
    if (on) {
      print(">>> RELAY ON - PV Off (" + eff_price + " EUR/kWh)");
    } else {
      print("<<< RELAY OFF - PV On (" + eff_price + " EUR/kWh)");
    }
    logEvent(np_price, eff_price, on);
  });
}

function checkPrice() {
  let unixtime = Shelly.getComponentStatus("sys").unixtime;
  let periodStart = Math.floor(unixtime / 900) * 900;
  let periodEnd = periodStart + 900;

  function toISO(s) {
    return new Date(s * 1000).toISOString().split(".")[0] + "Z";
  }

  let url = "https://dashboard.elering.ee/api/nps/price"
          + "?fields=ee"
          + "&start=" + toISO(periodStart)
          + "&end="   + toISO(periodEnd);

  Shelly.call("HTTP.GET", { url: url, ssl_ca: "*", timeout: CFG.api_timeout }, function(res, err) {
    if (err || !res || res.code !== 200) {
      print("Elering API error:", err || (res ? res.code : "no response"));
      return;
    }
    try {
      let data = JSON.parse(res.body);
      if (!data.success || !data.data || !data.data.ee || !data.data.ee.length) {
        print("Empty response from Elering API");
        return;
      }
      // Elering returns EUR/MWh -> convert to EUR/kWh
      let np_price  = Math.round(data.data.ee[0].price / 10) / 100;
      let eff_price = Math.round((np_price - CFG.tasakaalustus_eur_kwh - CFG.marginaal_eur_kwh) * 10000) / 10000;
      state.last_price = eff_price;
      print("NP:", np_price, "EUR/kWh | Efektiivne:", eff_price, "EUR/kWh");

      if (eff_price < CFG.threshold_eur_kwh) {
        setRelay(true, np_price, eff_price);
      } else {
        setRelay(false, np_price, eff_price);
      }
    } catch(e) {
      print("JSON parse error:", e);
    }
  });
}

checkPrice();
Timer.set(CFG.check_interval * 1000, true, checkPrice);
print("Script started. Plant:", CFG.plant_name, "| Threshold:", CFG.threshold_eur_kwh, "EUR/kWh");

Shelly.addStatusHandler(function(e) {
  if (e.component === "switch:0" && e.delta && e.delta.output !== undefined) {
    print("Manual relay switch:", e.delta.output ? "ON" : "OFF");
  }
});