Live Elpris – Svenska

let CONFIG = {
  api_endpoint_template: "https://www.elprisetjustnu.se/api/v1/prices/{YEAR}/{DATE}_{PRICE_AREA}.json",
  // Ex på slutgenereret URL:
  // https://www.elprisetjustnu.se/api/v1/prices/2025/01-08_SE1.json

  // ********Inställningar nedan***********
  // Välj prisområde:
  // SE1 = Luleå / Norra Sverige
  // SE2 = Sundsvall / Norra centrala Sverige
  // SE3 = Stockholm / Södra centrala Sverige
  // SE4 = Malmö / Södra Sverige
  price_area: "SE1",

  
  include_vat: true, // Sätt till true för att inkludera moms (25%) i priset, eller false för att exkludera moms.

 
  include_elafgift: true,  // Sätt till true för att inkludera elskatt i priset, eller false för att exkludera elskatt.
  elafgift: 0.72, // Elskatt i kr/kWh (utan moms). Om include_vat är true, läggs moms även till på denna avgift.
  additional_cost: 0.164, // Extra kostnad i kr/kWh. Lägger till detta i det slutliga priset.
  include_tariffs: false, // Är inte aktuellt i Sverige, så inställt på false
  // Endast för orter där det tillkommer en extra avgift på timpriset under vissa perioder på dygnet
  tariff_periods: [
    { start: "00:01", end: "06:00", tariff: 0.0 }
  ],

  // URL för POST (Skicka det beräknade priset hit)
  post_url: "https://shelly-t1-eu.shelly.cloud/v2/user/pp-ltu/eyJpZCI6MzQ4NzQ4LCJzbiI6MjQwMzU5MjY0NH0.MisIm5ns_TV5_LuC4-XhvQ",
 
  // Styrning av uppdateringsfrekvens:
  // För att inte belasta servern bör det vara false. 
  // 1-minutskontroll endast för test.
  check_every_minute: false,
  check_delay_seconds: 10,   // Sekunder efter skifte när uppdateringen körs
  vc_id: 200,                // ID på virtuell numerisk enhet
};

let current_price = null;
let loggingIntervalTimer = null;
let nextUpdateInMs = 0;

/**
 * Hjälpfunktion:
 * Omvandlar millisekunder till "0h 5m 10s"-format
 */
function formatDelay(delayMs) {
  try {
    let totalSeconds = Math.floor(delayMs / 1000);
    let hours = Math.floor(totalSeconds / 3600);
    let minutes = Math.floor((totalSeconds % 3600) / 60);
    let seconds = totalSeconds % 60;
    return hours + "h " + minutes + "m " + seconds + "s";
  } catch (err) {
    print("Error in formatDelay:", err);
    return "";
  }
}

/**
 * Hämtar den fullständiga URL-slutpunkten för vårt pris-API,
 * baserat på dagens datum.
 */
function getApiEndpoint() {
  try {
    let now = new Date();
    let year = now.getFullYear();
    let month = now.getMonth() + 1;
    let day = now.getDate();
    let formattedMonth = (month < 10 ? "0" : "") + month;
    let formattedDay   = (day   < 10 ? "0" : "") + day;
    return CONFIG.api_endpoint_template
      .replace("{YEAR}", year)
      .replace("{DATE}", formattedMonth + "-" + formattedDay)
      .replace("{PRICE_AREA}", CONFIG.price_area);
  } catch (err) {
    print("Error building API URL:", err);
    return null;
  }
}

/**
 * Hittar den aktuella nätariffen (utifrån den aktuella tiden).
 */
function getCurrentTariff() {
  try {
    if (!CONFIG.include_tariffs) return 0;
    let now = new Date();
    let h = now.getHours(), m = now.getMinutes();
    for (let p of CONFIG.tariff_periods) {
      let [sh, sm] = p.start.split(":").map(Number);
      let [eh, em] = p.end.split(":").map(Number);
      if ((h > sh || (h === sh && m >= sm)) &&
          (h < eh || (h === eh && m <= em))) {
        return p.tariff;
      }
    }
    return 0;
  } catch (err) {
    print("Error in getCurrentTariff:", err);
    return 0;
  }
}

/**
 * Hämtar aktuellt pris från API, beräknar slutligt pris,
 * och skickar det via POST.
 */
function getCurrentPrice() {
  let apiUrl = getApiEndpoint();
  if (!apiUrl) {
    scheduleNextPriceCheck();
    return;
  }

  try {
    print("Fetching price from URL:", apiUrl);
    Shelly.call("http.get", { url: apiUrl, timeout: 5000 }, function (response, error_code, error_message) {
      try {
        if (error_code !== 0) {
          print("Error fetching price:", error_message);
          scheduleNextPriceCheck();
          return;
        }

        let data;
        try {
          data = JSON.parse(response.body);
        } catch (parseErr) {
          print("Error parsing JSON:", parseErr);
          scheduleNextPriceCheck();
          return;
        }

        let now = new Date();
        let year = now.getFullYear();
        let month = now.getMonth() + 1;
        let day = now.getDate();
        let hour = now.getHours();
        let fm = (month < 10 ? "0" : "") + month;
        let fd = (day   < 10 ? "0" : "") + day;
        let fh = (hour  < 10 ? "0" : "") + hour;

        // Bygg en sträng utan tidszonsdelen
        let currentHourStr = year + "-" + fm + "-" + fd + "T" + fh + ":00:00";

        let currentData = null;
        for (let i = 0; i < data.length; i++) {
          if (typeof data[i].time_start === "string" &&
              data[i].time_start.indexOf(currentHourStr) === 0) {
            currentData = data[i];
            break;
          }
        }

        if (!currentData) {
          print("No data found for current hour prefix:", currentHourStr);
          scheduleNextPriceCheck();
          return;
        }

        // Beräkna priset
        let sekPerKwh = currentData["SEK_per_kWh"];
        if (CONFIG.include_vat)      sekPerKwh *= 1.25;
        sekPerKwh += getCurrentTariff();
        if (CONFIG.include_elafgift) {
          let tax = CONFIG.elafgift;
          if (CONFIG.include_vat) tax *= 1.25;
          sekPerKwh += tax;
        }
        sekPerKwh += CONFIG.additional_cost;

        current_price = sekPerKwh.toFixed(2);
        print("Current price in SEK:", current_price);

        // Skriv till virtuell enhet
        Shelly.call("Number.Set", { id: CONFIG.vc_id, value: current_price });

        // POST till angiven URL
        print("Posting price:", current_price);
        Shelly.call("http.request", {
          method: "POST",
          url: CONFIG.post_url,
          headers: { "Content-Type": "application/json" },
          body: JSON.stringify({ price: current_price }),
          timeout: 5000
        }, function (pr, pe, pm) {
          try {
            if (pe !== 0) print("Error posting price:", pm);
            else        print("Price posted successfully:", current_price);
          } catch(postErr) {
            print("Error in POST callback:", postErr);
          }
        });

      } catch (cbErr) {
        print("Error in http.get callback:", cbErr);
      } finally {
        scheduleNextPriceCheck();
      }
    });

  } catch (err) {
    print("Error initiating getCurrentPrice:", err);
    scheduleNextPriceCheck();
  }
}

/**
 * Startar en återkommande timer som var 10:e minut loggar
 * "Tid kvar till nästa uppdatering".
 */
function startUpdateLogging() {
  try {
    if (loggingIntervalTimer) {
      Timer.clear(loggingIntervalTimer);
      loggingIntervalTimer = null;
    }
    let tenMin = 10 * 60 * 1000;
    loggingIntervalTimer = Timer.set(tenMin, true, function () {
      try {
        nextUpdateInMs -= tenMin;
        if (nextUpdateInMs <= 0) {
          print("No time left to next update (it should happen now).");
          Timer.clear(loggingIntervalTimer);
          loggingIntervalTimer = null;
        } else {
          print("Time left to next update:", formatDelay(nextUpdateInMs));
        }
      } catch (tickErr) {
        print("Error in logging timer:", tickErr);
      }
    });
  } catch (err) {
    print("Error setting up logging timer:", err);
  }
}

/**
 * Planerar nästa uppdatering (antingen varje minut eller en gång i timmen),
 * men använder endast EN gemensam fördröjning, 'check_delay_seconds'.
 */
function scheduleNextPriceCheck() {
  try {
    let now = new Date();
    let delay = 0;
    if (CONFIG.check_every_minute) {
      let secs = 60 - now.getSeconds();
      delay = secs * 1000 - now.getMilliseconds() + CONFIG.check_delay_seconds * 1000;
      print("Scheduling next price check (minute-mode) in", formatDelay(delay));
    } else {
      let total = now.getMinutes() * 60 + now.getSeconds();
      delay = (3600 - total) * 1000 - now.getMilliseconds() + CONFIG.check_delay_seconds * 1000;
      print("Scheduling next price check (hour-mode) in", formatDelay(delay));
    }
    nextUpdateInMs = delay;
    Timer.set(delay, false, getCurrentPrice);
    startUpdateLogging();
  } catch (err) {
    print("Error scheduling next price check:", err);
  }
}

// Hämta priset omedelbart vid start, sedan enligt schema
getCurrentPrice();