Enever_tarieven.py

#!/usr/bin/python3.11
import sqlite3
import requests
from logger_setup import get_logger
from config import ENERGY_DB, ENEVER_TOKEN

logger = get_logger("tarieven")


def priceData() -> str | None:
   try:
      if not ENEVER_TOKEN:
         logger.error("Enever_token ontbreekt in omgeving (.env)")
         return None

      url = f"https://enever.nl/apiv3/stroomprijs_morgen.php?token={ENEVER_TOKEN}"

      try:
         r = requests.get(url, timeout=10)
         r.raise_for_status()
         respons = r.json()
      except requests.RequestException as e:
         logger.error(f"priceData netwerkfout: {e}")
         return None
      except ValueError as e:
         logger.error(f"priceData ongeldige JSON: {e}")
         return None

      logger.info(f"priceData response ontvangen: {respons}")

      if not respons or respons.get("code") == "6":
         logger.error(f"Fout in JSON: {respons}")
         return None

      data = respons.get("data")
      if not data:
         logger.warning("Enever-stroom-morgen geen data")
         return None

      datum = data[0]["datum"].split("T")[0]

      set_parts = []
      kale_prijs = []
      for row in data:
         try:
            uur = row["datum"][11:13]
            prijs = row["prijs"]
         except (KeyError, IndexError) as e:
            logger.error(f"priceData: onvolledig record overgeslagen ({e}): {row}")
            continue

         if not uur.isdigit() or len(uur) != 2:
            logger.error(f"Onverwacht uur-formaat: {uur!r}, sla record over")
            continue

         set_parts.append(f'"{uur}" = ?')
         kale_prijs.append(prijs)

      if not set_parts:
         logger.error("priceData: geen bruikbare records na validatie")
         return None

      kale_prijs.append(datum)

      with sqlite3.connect(ENERGY_DB) as db:
         cur = db.cursor()
         cur.execute("INSERT OR IGNORE INTO kaleprijs_1 (datum) VALUES (?)", (datum,))
         sql = f'UPDATE kaleprijs_1 SET {", ".join(set_parts)} WHERE datum = ?'
         cur.execute(sql, kale_prijs)
         db.commit()

      return datum

   except Exception as e:
      logger.error(f"priceData crash: {e}")
      return None


if __name__ == "__main__":
   priceData()