', methods=['POST'])
+def delete_choice(choice_id):
+ choice = Choice.query.get_or_404(choice_id)
+ db.session.delete(choice)
+ db.session.commit()
+ return redirect(url_for('admin.edit_question', question_id=choice.question_id))
diff --git a/delfland/po-quest/routes/main.py b/delfland/po-quest/routes/main.py
new file mode 100644
index 0000000..4d145db
--- /dev/null
+++ b/delfland/po-quest/routes/main.py
@@ -0,0 +1,10 @@
+from flask import Blueprint, render_template
+from models import Question
+
+main_bp = Blueprint("main", __name__)
+
+
+@main_bp.route("/")
+def index():
+ first_question = Question.query.first()
+ return render_template("index.html", question=first_question)
diff --git a/delfland/po-quest/templates/admin.html b/delfland/po-quest/templates/admin.html
new file mode 100644
index 0000000..1a21b42
--- /dev/null
+++ b/delfland/po-quest/templates/admin.html
@@ -0,0 +1,27 @@
+{% extends "base.html" %}
+
+{% block content %}
+ Beheer Vragenlijst
+ Nieuwe Vraag Toevoegen
+
+{% endblock %}
diff --git a/delfland/po-quest/templates/base.html b/delfland/po-quest/templates/base.html
new file mode 100644
index 0000000..538b382
--- /dev/null
+++ b/delfland/po-quest/templates/base.html
@@ -0,0 +1,26 @@
+
+
+
+
+
+ Vragenlijst
+
+
+
+
+
+
+ {% block content %}{% endblock %}
+
+
+
+
+
diff --git a/delfland/po-quest/templates/edit_choice.html b/delfland/po-quest/templates/edit_choice.html
new file mode 100644
index 0000000..68da7e0
--- /dev/null
+++ b/delfland/po-quest/templates/edit_choice.html
@@ -0,0 +1,13 @@
+{% extends "base.html" %}
+
+{% block content %}
+ Keuze Bewerken
+
+{% endblock %}
diff --git a/delfland/po-quest/templates/edit_question.html b/delfland/po-quest/templates/edit_question.html
new file mode 100644
index 0000000..312a51f
--- /dev/null
+++ b/delfland/po-quest/templates/edit_question.html
@@ -0,0 +1,13 @@
+{% extends "base.html" %}
+
+{% block content %}
+ Vraag Bewerken
+
+{% endblock %}
diff --git a/delfland/po-quest/templates/index.html b/delfland/po-quest/templates/index.html
new file mode 100644
index 0000000..003501d
--- /dev/null
+++ b/delfland/po-quest/templates/index.html
@@ -0,0 +1,13 @@
+{% extends "base.html" %}
+
+{% block content %}
+ {{ question.text }}
+
+{% endblock %}
diff --git a/delfland/webhooktest/Dockerfile b/delfland/webhooktest/Dockerfile
new file mode 100644
index 0000000..f22491f
--- /dev/null
+++ b/delfland/webhooktest/Dockerfile
@@ -0,0 +1,10 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY app/ app/
+
+CMD ["uvicorn", "app.main:app", "--host", "0.0.0.0", "--port", "8000"]
diff --git a/delfland/webhooktest/README.md b/delfland/webhooktest/README.md
new file mode 100644
index 0000000..e69de29
diff --git a/delfland/webhooktest/app/__init__.py b/delfland/webhooktest/app/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/delfland/webhooktest/app/logger.py b/delfland/webhooktest/app/logger.py
new file mode 100644
index 0000000..1066cdc
--- /dev/null
+++ b/delfland/webhooktest/app/logger.py
@@ -0,0 +1,8 @@
+import logging
+
+
+def setup_logging():
+ logging.basicConfig(
+ level=logging.INFO,
+ format="%(asctime)s [%(levelname)s] %(message)s",
+ )
diff --git a/delfland/webhooktest/app/main.py b/delfland/webhooktest/app/main.py
new file mode 100644
index 0000000..db852ac
--- /dev/null
+++ b/delfland/webhooktest/app/main.py
@@ -0,0 +1,7 @@
+from fastapi import FastAPI
+from .routes import router
+from .logger import setup_logging
+
+app = FastAPI()
+setup_logging()
+app.include_router(router)
diff --git a/delfland/webhooktest/app/routes.py b/delfland/webhooktest/app/routes.py
new file mode 100644
index 0000000..5ec0d17
--- /dev/null
+++ b/delfland/webhooktest/app/routes.py
@@ -0,0 +1,85 @@
+from fastapi import APIRouter, Request, Form, WebSocket, WebSocketDisconnect
+from fastapi.responses import HTMLResponse
+from fastapi.templating import Jinja2Templates
+from fastapi.security import APIKeyHeader
+from dotenv import load_dotenv
+import os
+import logging
+from .storage import store_message, get_all_messages
+
+load_dotenv()
+
+API_KEY = os.getenv("API_KEY")
+api_key_header = APIKeyHeader(name="x-api-key", auto_error=False)
+
+router = APIRouter()
+templates = Jinja2Templates(directory="app/templates")
+
+# Live WebSocket connecties
+active_connections = []
+
+
+async def validate_api_key(api_key: str = None):
+ if api_key != API_KEY:
+ raise Exception("Unauthorized")
+
+
+async def broadcast(msg: str):
+ for connection in active_connections:
+ try:
+ await connection.send_text(msg)
+ except:
+ continue
+
+
+@router.api_route("/webhook", methods=["GET", "POST"])
+async def webhook(request: Request, api_key: str = api_key_header):
+ await validate_api_key(api_key)
+ body = await request.body()
+ log_entry = {
+ "method": request.method,
+ "headers": dict(request.headers),
+ "body": body.decode()
+ }
+ logging.info(f"Webhook received: {log_entry}")
+ store_message(log_entry)
+ await broadcast(str(log_entry)) # stuur live update via websocket
+ return {"status": "ok"}
+
+
+@router.get("/trace", response_class=HTMLResponse)
+async def trace_page(request: Request):
+ return templates.TemplateResponse("trace.html", {
+ "request": request,
+ "messages": get_all_messages()
+ })
+
+
+@router.websocket("/ws/trace")
+async def websocket_endpoint(websocket: WebSocket):
+ await websocket.accept()
+ active_connections.append(websocket)
+ try:
+ while True:
+ await websocket.receive_text() # optioneel: keep-alive ping
+ except WebSocketDisconnect:
+ active_connections.remove(websocket)
+
+
+@router.get("/send", response_class=HTMLResponse)
+async def send_form(request: Request):
+ return templates.TemplateResponse("send.html", {"request": request})
+
+
+@router.post("/send")
+async def send_post(request: Request, url: str = Form(...), body: str = Form(...), key: str = Form(...)):
+ import httpx
+ headers = {"x-api-key": key}
+ try:
+ response = httpx.post(url, content=body, headers=headers)
+ return {
+ "status_code": response.status_code,
+ "response": response.text
+ }
+ except Exception as e:
+ return {"error": str(e)}
diff --git a/delfland/webhooktest/app/storage.py b/delfland/webhooktest/app/storage.py
new file mode 100644
index 0000000..bb94a35
--- /dev/null
+++ b/delfland/webhooktest/app/storage.py
@@ -0,0 +1,9 @@
+messages = []
+
+
+def store_message(msg: dict):
+ messages.append(msg)
+
+
+def get_all_messages():
+ return list(messages)
diff --git a/delfland/webhooktest/app/templates/send.html b/delfland/webhooktest/app/templates/send.html
new file mode 100644
index 0000000..416dff2
--- /dev/null
+++ b/delfland/webhooktest/app/templates/send.html
@@ -0,0 +1,10 @@
+
+
+Webhookbericht versturen
+
+
diff --git a/delfland/webhooktest/app/templates/trace.html b/delfland/webhooktest/app/templates/trace.html
new file mode 100644
index 0000000..5a4d274
--- /dev/null
+++ b/delfland/webhooktest/app/templates/trace.html
@@ -0,0 +1,28 @@
+
+
+
+ Live Webhook Trace
+
+
+
+ Ontvangen Webhookberichten (live)
+
+ {% for msg in messages %}
+ {{ msg }}
+
+
+
+
diff --git a/delfland/webhooktest/docker-compose.yml b/delfland/webhooktest/docker-compose.yml
new file mode 100644
index 0000000..576863d
--- /dev/null
+++ b/delfland/webhooktest/docker-compose.yml
@@ -0,0 +1,19 @@
+# docker compose -f docker-compose.yml up -d --build
+
+version: "3.3"
+services:
+ webhooktest:
+ restart: always
+ container_name: webhooktest
+ environment:
+ - PUID=1000
+ - PGID=1000
+ - TZ=Europe/Amsterdam
+ ports:
+ - target: 8000
+ published: 5905
+ protocol: tcp
+ build:
+ dockerfile: ./Dockerfile
+ env_file:
+ - .env
diff --git a/delfland/webhooktest/init.sh b/delfland/webhooktest/init.sh
new file mode 100644
index 0000000..781e388
--- /dev/null
+++ b/delfland/webhooktest/init.sh
@@ -0,0 +1,19 @@
+# Maak hoofddirectory aan
+mkdir -p app/templates
+
+# Ga naar projectmap
+
+# Maak lege bestanden aan in de root
+touch .env Dockerfile requirements.txt README.md
+
+# Ga naar de app-map
+cd app
+
+# Maak Python-bestanden aan
+touch __init__.py main.py logger.py routes.py storage.py
+
+# Ga naar templates-map
+cd templates
+
+# Maak de HTML-templates aan
+touch trace.html send.html
diff --git a/delfland/webhooktest/requirements.txt b/delfland/webhooktest/requirements.txt
new file mode 100644
index 0000000..15d538f
--- /dev/null
+++ b/delfland/webhooktest/requirements.txt
@@ -0,0 +1,5 @@
+fastapi
+uvicorn
+python-dotenv
+jinja2
+python-multipart
\ No newline at end of file
diff --git a/solarforecast/README.md b/solarforecast/README.md
new file mode 100644
index 0000000..e69de29
diff --git a/solarforecast/backend/db.py b/solarforecast/backend/db.py
new file mode 100644
index 0000000..0e9ee6a
--- /dev/null
+++ b/solarforecast/backend/db.py
@@ -0,0 +1,97 @@
+import os
+import mysql.connector
+from dotenv import load_dotenv
+from datetime import datetime
+
+load_dotenv(dotenv_path="../.env")
+
+db_config = {
+ "host": os.getenv("MYSQL_HOST"),
+ "port": int(os.getenv("MYSQL_PORT")),
+ "user": os.getenv("MYSQL_USER"),
+ "password": os.getenv("MYSQL_PASSWORD"),
+ "database": os.getenv("MYSQL_DATABASE"),
+}
+
+
+def parse_datetime_safe(dt_string):
+ try:
+ return datetime.fromisoformat(dt_string.replace("Z", "").replace("+00:00", ""))
+ except Exception:
+ return None
+
+
+def parse_float_safe(value):
+ try:
+ return float(value)
+ except Exception:
+ return None
+
+
+def init_db():
+ """Creëer ruwe datatabel met unieke forecast_time."""
+ conn = mysql.connector.connect(**db_config)
+ cursor = conn.cursor()
+ cursor.execute("""
+ CREATE TABLE IF NOT EXISTS solar_raw_data (
+ id INT AUTO_INCREMENT PRIMARY KEY,
+ forecast_time DATETIME NOT NULL UNIQUE,
+ valid_to DATETIME,
+ capacity FLOAT,
+ volume FLOAT,
+ percentage FLOAT,
+ emission FLOAT,
+ emission_factor FLOAT,
+ last_update DATETIME
+ )
+ """)
+ conn.commit()
+ cursor.close()
+ conn.close()
+
+
+def insert_forecast_records(records):
+ """Voegt ruwe forecast records toe, met veilige parsing en validatie."""
+ conn = mysql.connector.connect(**db_config)
+ cursor = conn.cursor()
+
+ # Haal reeds bekende timestamps op
+ cursor.execute("SELECT forecast_time FROM solar_raw_data")
+ existing_timestamps = set(row[0] for row in cursor.fetchall())
+
+ new_rows = 0
+ for record in records:
+ forecast_time = parse_datetime_safe(record.get("validfrom", ""))
+ if not forecast_time or forecast_time in existing_timestamps:
+ continue
+
+ try:
+ cursor.execute("""
+ INSERT INTO solar_raw_data (
+ forecast_time,
+ valid_to,
+ capacity,
+ volume,
+ percentage,
+ emission,
+ emission_factor,
+ last_update
+ ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s)
+ """, (
+ forecast_time,
+ parse_datetime_safe(record.get("validto")),
+ parse_float_safe(record.get("capacity")),
+ parse_float_safe(record.get("volume")),
+ parse_float_safe(record.get("percentage")),
+ parse_float_safe(record.get("emission")),
+ parse_float_safe(record.get("emissionfactor")),
+ parse_datetime_safe(record.get("lastupdate"))
+ ))
+ new_rows += 1
+ except Exception as e:
+ print(f"❌ Fout bij record: {e}\nRecord: {record}")
+
+ conn.commit()
+ cursor.close()
+ conn.close()
+ print(f"✅ {new_rows} nieuwe records opgeslagen.")
diff --git a/solarforecast/backend/fetch_ned_data.py b/solarforecast/backend/fetch_ned_data.py
new file mode 100644
index 0000000..8454923
--- /dev/null
+++ b/solarforecast/backend/fetch_ned_data.py
@@ -0,0 +1,52 @@
+import os
+import requests
+from dotenv import load_dotenv
+from datetime import datetime, timedelta
+from db import init_db, insert_forecast_records
+
+load_dotenv(dotenv_path="../.env")
+
+NED_API_KEY = os.getenv("NED_API_KEY")
+
+
+def fetch_forecast():
+ url = "https://api.ned.nl/v1/utilizations"
+ headers = {
+ "X-AUTH-TOKEN": NED_API_KEY,
+ "Accept": "application/ld+json"
+ }
+
+ today = datetime.utcnow().date()
+ tomorrow = today + timedelta(days=1)
+
+ params = {
+ "point": 9,
+ "type": 2,
+ "granularity": 3,
+ "granularitytimezone": 1,
+ "classification": 2,
+ "activity": 1,
+ "validfrom[after]": today.strftime("%Y-%m-%d"),
+ "validfrom[strictly_before]": tomorrow.strftime("%Y-%m-%d")
+ }
+
+ response = requests.get(url, headers=headers, params=params)
+ response.raise_for_status()
+ return response.json()
+
+
+def main():
+ print("📡 Ophalen zonneproductievoorspelling van NED.nl")
+ data = fetch_forecast()
+ records = data.get("hydra:member", [])
+ print(records)
+ print(f"Gevonden records: {len(records)}")
+
+ init_db()
+ insert_forecast_records(records)
+
+ print("✅ Data opgeslagen in database")
+
+
+if __name__ == "__main__":
+ main()
diff --git a/solarforecast/requirements.txt b/solarforecast/requirements.txt
new file mode 100644
index 0000000..09f2bbe
--- /dev/null
+++ b/solarforecast/requirements.txt
@@ -0,0 +1,3 @@
+requests
+python-dotenv
+mysql-connector-python