Initial commit

2026-02-19 20:25:56 +01:00
57 changed files with 0 additions and 2932 deletions
@@ -1,23 +0,0 @@
-kit.git-config.edn
-.DS_Store
-.nrepl-port
-hs_err_pid*.log
-.cpcache/
-target
-log/
-.shadow-cljs/
-node_modules/
-modules/
-resources/public/css/output.css
-
-# IntelliJ
-*.iml
-.idea/
-*.bak
-
-# clj-kondo
-.clj-kondo/.cache/
-.calva/output-window/
-.lsp/.cache/
-.token
-.env
@@ -1,92 +0,0 @@
-# CLAUDE.md
-
-This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.
-
-## Build & Development Commands
-
-```bash
-# Development
-make run                    # Start dev server (port 3000)
-make repl                   # Start nREPL
-npm run css:watch           # Watch/rebuild Tailwind CSS
-
-# Testing
-make test                   # Run all tests
-clj -M:test                 # Alternative
-
-# Build
-make uberjar                # Build production JAR (target/elprice-standalone.jar)
-make clean                  # Remove target/
-
-# Formatting
-bb format                   # Format source with cljstyle
-
-# Docker
-docker compose up -d        # Start PostgreSQL (port 5432)
-```
-
-### REPL Commands
-
-```clojure
-(dev-prep!) (go)            ;; Start system in REPL
-(reset)                     ;; Reload code and restart system
-(halt)                      ;; Stop system
-(migrate)                   ;; Run database migrations
-(rollback)                  ;; Rollback last migration
-(reset-db)                  ;; Drop and re-migrate database
-;; Testing in REPL:
-(test-prep!) (go) (run-tests)
-```
-
-## Architecture
-
-**Kit framework** web application: Clojure, PostgreSQL, HTMX, Hiccup, Tailwind CSS.
-
-### System Initialization
-
-Integrant manages the component lifecycle. Configuration is in `resources/system.edn`, which defines components for the HTTP server (Undertow), database connection pool, migrations, routes, and middleware. The entry point is `pmagnus.elprice.core`, which loads the system config via `pmagnus.elprice.config`.
-
-### Routing
-
-Two separate route groups registered as Integrant components:
-
- **API routes** (`web/routes/api.clj`) — mounted at `/api`, returns JSON, has Swagger docs at `/api/swagger.json`
- **UI routes** (`web/routes/ui.clj`) — mounted at `/`, returns HTML via HTMX + Hiccup
-
-Routes are combined in `web/handler.clj` which builds the Ring handler with the full middleware stack.
-
-### Frontend Pattern
-
-Server-side rendered HTML using Hiccup data structures. Interactive behavior via HTMX (no client-side JS framework). Two macros in `web/htmx.clj`:
-
- `page` — renders a full HTML5 document (includes Tailwind CSS and HTMX script tags)
- `fragment` — renders an HTML fragment for HTMX partial responses
-
-Tailwind CSS v4 scans `.clj` and `.html` files for utility classes. Source: `resources/css/input.css` → Output: `resources/public/css/output.css`.
-
-### Database
-
-PostgreSQL via kit-postgres and conman (connection pooling). SQL queries defined with HugSQL in `resources/queries.sql`. Migrations via Migratus in `resources/migrations/`. Migrations run automatically on system startup (`migrate-on-init? true`).
-
- Dev/Test DB: `jdbc:postgresql://localhost:5432/elprice?user=elprice&password=elprice`
- Prod DB: via `JDBC_URL` environment variable
-
-### Middleware
-
-Defined in `web/middleware/core.clj`. Cookie-based sessions (http-only, same-site strict). CSRF is disabled. Static assets served from `resources/public/`.
-
-### Source Layout
-
-```
-src/clj/pmagnus/elprice/
-├── core.clj                 # App entry point, system lifecycle
-├── config.clj               # Integrant config loader
-└── web/
-    ├── handler.clj          # Ring handler + route composition
-    ├── htmx.clj             # page/fragment Hiccup macros
-    ├── controllers/         # Request handlers (business logic)
-    ├── middleware/           # Ring middleware (core, exception, formats)
-    └── routes/              # Reitit route definitions (api, ui)
-```
-
-Environment-specific code lives in `env/{dev,prod,test}/`. Dev REPL utilities are in `env/dev/clj/pmagnus/elprice/user.clj`.
@@ -1,22 +0,0 @@
-FROM node:22-alpine AS css
-WORKDIR /app
-COPY package.json package-lock.json ./
-RUN npm ci
-COPY resources/css resources/css
-COPY src src
-RUN npx @tailwindcss/cli -i resources/css/input.css -o resources/public/css/output.css --minify
-
-FROM clojure:temurin-21-tools-deps-alpine AS build
-WORKDIR /app
-COPY deps.edn build.clj ./
-RUN clojure -P && clojure -P -T:build
-COPY . .
-COPY --from=css /app/resources/public/css/output.css resources/public/css/output.css
-RUN clojure -T:build all
-
-FROM eclipse-temurin:21-jre-alpine
-WORKDIR /app
-COPY --from=build /app/target/elprice-standalone.jar app.jar
-EXPOSE 3030
-ENV PORT=3030
-ENTRYPOINT ["java", "-jar", "app.jar"]
@@ -1,20 +0,0 @@
-include .env
-export
-
-clean:
-	rm -rf target
-
-run:
-	clj -M:dev -e "(dev-prep!) (go)" -r
-
-repl:
-	clj -M:dev:nrepl
-
-tailwind:
-	npm run css:watch
-
-test:
-	clj -M:test
-
-uberjar:
-	clj -T:build all
@@ -1,37 +1,2 @@
 # elprice

-Start a [REPL](#repls) in your editor or terminal of choice.
-
-Start the server with:
-
-```clojure
-(go)
-```
-
-The default API is available under http://localhost:3000/api
-
-System configuration is available under `resources/system.edn`.
-
-To reload changes:
-
-```clojure
-(reset)
-```
-
-## REPLs
-
-### Cursive
-
-Configure a [REPL following the Cursive documentation](https://cursive-ide.com/userguide/repl.html). Using the default "Run with IntelliJ project classpath" option will let you select an alias from the ["Clojure deps" aliases selection](https://cursive-ide.com/userguide/deps.html#refreshing-deps-dependencies).
-
-### CIDER
-
-Use the `cider` alias for CIDER nREPL support (run `clj -M:dev:cider`). See the [CIDER docs](https://docs.cider.mx/cider/basics/up_and_running.html) for more help.
-
-Note that this alias runs nREPL during development. To run nREPL in production (typically when the system starts), use the kit-nrepl library through the +nrepl profile as described in [the documentation](https://kit-clj.github.io/docs/profiles.html#profiles).
-
-### Command Line
-
-Run `clj -M:dev:nrepl` or `make repl`.
-
-Note that, just like with [CIDER](#cider), this alias runs nREPL during development. To run nREPL in production (typically when the system starts), use the kit-nrepl library through the +nrepl profile as described in [the documentation](https://kit-clj.github.io/docs/profiles.html#profiles).
@@ -1,27 +0,0 @@
-{:min-bb-version "0.8.156"
- :deps  {failjure/failjure {:mvn/version "2.3.0"}}
- :tasks {:requires ([babashka.fs :as fs]
-                    [babashka.tasks :refer [shell]])
-
-         run       {:doc  "starts the app"
-                    :task (if (fs/windows?)
-                            (clojure {:dir "."} "-M:dev")
-                            (shell {:dir "."} "clj -M:dev"))}
-
-         nrepl     {:doc  "starts the nREPL"
-                    :task (clojure {:dir "."} "-M:dev:nrepl")}
-
-         cider     {:doc  "starts the cider"
-                    :task (clojure {:dir "."} "-M:dev:cider")}
-
-         test      {:doc  "runs tests"
-                    :task (clojure {:dir "."} "-M:test")}
-
-         uberjar   {:doc  "builds the uberjar"
-                    :task (clojure {:dir "."} "-T:build all")}
-
-         format    {:doc  "Formats codebase"
-                    :task (try
-                            (shell {:dir "src"} "cljstyle fix")
-                            (catch Exception _
-                              (clojure {:dir "src"} "-M:dev -m cljstyle.main fix")))}}}
@@ -1,41 +0,0 @@
-(ns build
-  (:require [clojure.string :as string]
-            [clojure.tools.build.api :as b]))
-
-(def lib 'pmagnus/elprice)
-(def main-cls (string/join "." (filter some? [(namespace lib) (name lib) "core"])))
-(def version (format "0.0.1-SNAPSHOT"))
-(def target-dir "target")
-(def class-dir (str target-dir "/" "classes"))
-(def uber-file (format "%s/%s-standalone.jar" target-dir (name lib)))
-(def basis (b/create-basis {:project "deps.edn"}))
-
-(defn clean
-  "Delete the build target directory"
-  [_]
-  (println (str "Cleaning " target-dir))
-  (b/delete {:path target-dir}))
-
-(defn prep [_]
-  (println "Writing Pom...")
-  (b/write-pom {:class-dir class-dir
-                :lib lib
-                :version version
-                :basis basis
-                :src-dirs ["src/clj"]})
-  (b/copy-dir {:src-dirs ["src/clj" "resources" "env/prod/resources" "env/prod/clj"]
-               :target-dir class-dir}))
-
-(defn uber [_]
-  (println "Compiling Clojure...")
-  (b/compile-clj {:basis basis
-                  :src-dirs ["src/clj" "resources" "env/prod/resources" "env/prod/clj"]
-                  :class-dir class-dir})
-  (println "Making uberjar...")
-  (b/uber {:class-dir class-dir
-           :uber-file uber-file
-           :main main-cls
-           :basis basis}))
-
-(defn all [_]
-  (do (clean nil) (prep nil) (uber nil)))
@@ -1,70 +0,0 @@
-{:paths   ["src/clj"
-           "resources"]
-
- :deps    {org.clojure/clojure {:mvn/version "1.12.3"}
-
-           ;; Routing
- metosin/reitit {:mvn/version "0.9.2"}
-
-           ;; Ring
- metosin/ring-http-response {:mvn/version "0.9.5"}
- ring/ring-core {:mvn/version "1.15.3"}
- ring/ring-defaults {:mvn/version "0.7.0"}
-
-           ;; Logging
- ch.qos.logback/logback-classic {:mvn/version "1.5.20"}
-
-           ;; Data coercion
- luminus-transit/luminus-transit {:mvn/version "0.1.6"
-                                  :exclusions [com.cognitect/transit-clj]}
- metosin/muuntaja {:mvn/version "0.6.11"}
-
-           ;; kit Libs
- io.github.kit-clj/kit-core {:mvn/version "1.0.9"}
- io.github.kit-clj/kit-undertow {:mvn/version "1.0.10"}
- io.github.kit-clj/kit-postgres {:mvn/version "1.0.7"}
- io.github.kit-clj/kit-sql-conman {:mvn/version "1.10.5"}
- io.github.kit-clj/kit-sql-migratus {:mvn/version "1.0.5"}
- hiccup/hiccup {:mvn/version "2.0.0"}
- org.clojure/data.json {:mvn/version "2.5.1"}}
- :aliases {:build {:deps {io.github.clojure/tools.build {:mvn/version "0.10.11"}}
-                   :ns-default build}
-
-
-           :dev  {:extra-deps  {com.lambdaisland/classpath      {:mvn/version "0.6.58"}
-                                criterium/criterium             {:mvn/version "0.4.6"}
-                                expound/expound                 {:mvn/version "0.9.0"}
-                                integrant/repl                  {:mvn/version "0.5.0"}
-                                mvxcvi/cljstyle                 {:mvn/version "0.17.642"}
-                                pjstadig/humane-test-output     {:mvn/version "0.11.0"}
-                                ring/ring-devel                 {:mvn/version "1.15.3"}
-                                ring/ring-mock                  {:mvn/version "0.6.2"}
-                                io.github.kit-clj/kit-generator {:mvn/version "0.2.5"}
-                                org.clojure/tools.namespace     {:mvn/version "1.5.0"}
-                                }
-                  :extra-paths ["env/dev/clj" "env/dev/resources" "test/clj"]}
-           :nrepl {:extra-deps {nrepl/nrepl {:mvn/version "1.5.1"}}
-                   :main-opts  ["-m" "nrepl.cmdline" "-i"]}
-           :cider {:extra-deps {nrepl/nrepl       {:mvn/version "1.5.1"}
-                                cider/cider-nrepl {:mvn/version "0.58.0"}}
-                   :main-opts  ["-m" "nrepl.cmdline" "--middleware" "[cider.nrepl/cider-middleware]" "-i"]}
-
-           :test {:extra-deps  {criterium/criterium                  {:mvn/version "0.4.6"}
-                                expound/expound                      {:mvn/version "0.9.0"}
-                                integrant/repl                       {:mvn/version "0.5.0"}
-                                io.github.cognitect-labs/test-runner {:git/url "https://github.com/cognitect-labs/test-runner.git"
-                                                                      :git/tag "v0.5.1"
-                                                                      :git/sha "dfb30dd"}
-                                pjstadig/humane-test-output          {:mvn/version "0.11.0"}
-                                ring/ring-devel                      {:mvn/version "1.15.3"}
-                                ring/ring-mock                       {:mvn/version "0.6.2"}
-                                io.github.kit-clj/kit-generator      {:mvn/version "0.2.5"}
-                                org.clojure/tools.namespace          {:mvn/version "1.5.0"}
-                                peridot/peridot                      {:mvn/version "0.5.4"}
-                                org.clj-commons/byte-streams         {:mvn/version "0.3.4"}
-                                com.lambdaisland/classpath           {:mvn/version "0.6.58"}}
-                  :exec-fn      cognitect.test-runner.api/test
-                  :extra-paths ["env/dev/clj" "env/dev/resources" "env/test/resources" "test/clj"]
-                  :main-opts   ["-e" "(require 'pjstadig.humane-test-output) (pjstadig.humane-test-output/activate!)"
-                                "-m" "cognitect.test-runner"]}}
- }
@@ -1,10 +0,0 @@
-services:
-  app:
-    build: .
-    ports:
-      - "3030:3030"
-    env_file:
-      - .env
-    volumes:
-      - ./.token:/app/.token:ro
-    restart: unless-stopped
@@ -1,5 +0,0 @@
-(ns pmagnus.elprice.dev-middleware)
-
-(defn wrap-dev [handler _opts]
-  (-> handler
-      ))
@@ -1,14 +0,0 @@
-(ns pmagnus.elprice.env
-  (:require
-    [clojure.tools.logging :as log]
-    [pmagnus.elprice.dev-middleware :refer [wrap-dev]]))
-
-(def defaults
-  {:init       (fn []
-                 (log/info "\n-=[elprice starting using the development or test profile]=-"))
-   :start      (fn []
-                 (log/info "\n-=[elprice started successfully using the development or test profile]=-"))
-   :stop       (fn []
-                 (log/info "\n-=[elprice has shut down successfully]=-"))
-   :middleware wrap-dev
-   :opts       {:profile       :dev}})
@@ -1,59 +0,0 @@
-(ns user
-  "Userspace functions you can run by default in your local REPL."
-  (:require
-    [clojure.pprint]
-    [clojure.spec.alpha :as s]
-    [clojure.tools.namespace.repl :as repl]
-    [criterium.core :as c]                                  ;; benchmarking
-    [expound.alpha :as expound]
-    [integrant.core :as ig]
-    [integrant.repl :refer [clear go halt prep init reset reset-all]]
-    [integrant.repl.state :as state]
-    [kit.api :as kit]
-    [lambdaisland.classpath.watch-deps :as watch-deps]      ;; hot loading for deps
-    [pmagnus.elprice.core :refer [start-app]]))
-
-;; uncomment to enable hot loading for deps
-(watch-deps/start! {:aliases [:dev :test]})
-
-(alter-var-root #'s/*explain-out* (constantly expound/printer))
-
-(add-tap (bound-fn* clojure.pprint/pprint))
-
-(defn dev-prep!
-  []
-  (integrant.repl/set-prep! (fn []
-                              (-> (pmagnus.elprice.config/system-config {:profile :dev})
-                                  (ig/expand)))))
-
-(defn test-prep!
-  []
-  (integrant.repl/set-prep! (fn []
-                              (-> (pmagnus.elprice.config/system-config {:profile :test})
-                                  (ig/expand)))))
-
-;; Can change this to test-prep! if want to run tests as the test profile in your repl
-;; You can run tests in the dev profile, too, but there are some differences between
-;; the two profiles.
-(dev-prep!)
-
-(repl/set-refresh-dirs "src/clj")
-
-(def refresh repl/refresh)
-
-
-(defn reset-db []
-  (migratus.core/reset (:db.sql/migrations state/system)))
-
-(defn rollback []
-  (migratus.core/rollback (:db.sql/migrations state/system)))
-
-(defn migrate []
-  (migratus.core/migrate (:db.sql/migrations state/system)))
-
-(def query-fn (:db.sql/query-fn state/system))
-
-
-(comment
-  (go)
-  (reset))
@@ -1,38 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration scan="true" scanPeriod="10 seconds">
-    <statusListener class="ch.qos.logback.core.status.NopStatusListener" />
-    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
-        <!-- encoders are assigned the type
-             ch.qos.logback.classic.encoder.PatternLayoutEncoder by default -->
-        <encoder>
-            <charset>UTF-8</charset>
-            <pattern>%date{ISO8601} [%thread] %-5level %logger{36} - %msg %n</pattern>
-        </encoder>
-    </appender>
-    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
-        <file>log/pmagnus.elprice.log</file>
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-            <fileNamePattern>log/pmagnus.elprice.%d{yyyy-MM-dd}.%i.log</fileNamePattern>
-            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
-                <maxFileSize>100MB</maxFileSize>
-            </timeBasedFileNamingAndTriggeringPolicy>
-            <!-- keep 30 days of history -->
-            <maxHistory>30</maxHistory>
-        </rollingPolicy>
-        <encoder>
-            <charset>UTF-8</charset>
-            <pattern>%date{ISO8601} [%thread] %-5level %logger{36} - %msg %n</pattern>
-        </encoder>
-    </appender>
-    <logger name="org.eclipse.aether" level="warn" />
-    <logger name="io.methvin.watcher" level="warn" />
-    <logger name="org.eclipse.jgit" level="warn" />
-    <logger name="com.zaxxer.hikari" level="warn" />
-    <logger name="org.apache.http" level="warn" />
-    <logger name="org.xnio.nio" level="warn" />
-    <logger name="io.undertow" level="warn" />
-    <root level="DEBUG">
-        <appender-ref ref="STDOUT" />
-        <appender-ref ref="FILE" />
-    </root>
-</configuration>
@@ -1,12 +0,0 @@
-(ns pmagnus.elprice.env
-  (:require [clojure.tools.logging :as log]))
-
-(def defaults
-  {:init       (fn []
-                 (log/info "\n-=[elprice starting]=-"))
-   :start      (fn []
-                 (log/info "\n-=[elprice started successfully]=-"))
-   :stop       (fn []
-                 (log/info "\n-=[elprice has shut down successfully]=-"))
-   :middleware (fn [handler _] handler)
-   :opts       {:profile :prod}})
@@ -1,16 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration>
-    <statusListener class="ch.qos.logback.core.status.NopStatusListener" />
-    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
-        <encoder>
-            <pattern>%-5relative %-5level %logger{35} - %msg%n</pattern>
-        </encoder>
-    </appender>
-    <logger name="com.zaxxer.hikari" level="error" />
-    <logger name="org.apache.http" level="error" />
-    <logger name="org.xnio.nio" level="error" />
-    <logger name="io.undertow" level="error" />
-    <root level="INFO">
-        <appender-ref ref="STDOUT" />
-    </root>
-</configuration>
@@ -1,16 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration>
-    <statusListener class="ch.qos.logback.core.status.NopStatusListener" />
-    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
-        <encoder>
-            <pattern>%-5relative %-5level %logger{35} - %msg%n</pattern>
-        </encoder>
-    </appender>
-    <logger name="com.zaxxer.hikari" level="error" />
-    <logger name="org.apache.http" level="error" />
-    <logger name="org.xnio.nio" level="error" />
-    <logger name="io.undertow" level="error" />
-    <root level="INFO">
-        <appender-ref ref="STDOUT" />
-    </root>
-</configuration>
@@ -1,13 +0,0 @@
-#!/usr/bin/env bash
-# Kill any process listening on port 3000.
-# Usage: ./kill-server.sh
-set -euo pipefail
-
-pids=$(lsof -ti:3000 2>/dev/null || true)
-
-if [ -z "$pids" ]; then
-  echo "No process on port 3000"
-else
-  echo "$pids" | xargs kill
-  echo "Killed: $pids"
-fi
@@ -1,8 +0,0 @@
-{:full-name "pmagnus/elprice"
- :ns-name   "pmagnus.elprice"
- :sanitized "pmagnus/elprice"
- :name      "elprice"
- :modules   {:root         "modules"
-             :repositories [{:url  "https://github.com/kit-clj/modules.git"
-                             :tag  "master"
-                             :name "kit-modules"}]}}
@@ -1,21 +0,0 @@
-{
-  "name": "elprice",
-  "version": "1.0.0",
-  "description": "Start a [REPL](#repls) in your editor or terminal of choice.",
-  "main": "index.js",
-  "directories": {
-    "test": "test"
-  },
-  "scripts": {
-    "css:build": "npx @tailwindcss/cli -i resources/css/input.css -o resources/public/css/output.css --minify",
-    "css:watch": "npx @tailwindcss/cli -i resources/css/input.css -o resources/public/css/output.css --watch"
-  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "type": "commonjs",
-  "devDependencies": {
-    "@tailwindcss/cli": "^4.1.18",
-    "tailwindcss": "^4.1.18"
-  }
-}
@@ -1,2 +0,0 @@
-@import "tailwindcss";
-@source "../../src/**/*.clj";
@@ -1 +0,0 @@
-DROP TABLE IF EXISTS day_ahead_prices;
@@ -1,8 +0,0 @@
-CREATE TABLE day_ahead_prices (
-  time_utc       TIMESTAMPTZ NOT NULL,
-  time_dk        TIMESTAMP   NOT NULL,
-  price_area     VARCHAR(3)  NOT NULL,
-  price_dkk      NUMERIC(10,2),
-  price_eur      NUMERIC(10,6),
-  PRIMARY KEY (time_utc, price_area)
-);
@@ -1 +0,0 @@
-DROP INDEX IF EXISTS idx_day_ahead_prices_time_dk_area;
@@ -1 +0,0 @@
-CREATE UNIQUE INDEX idx_day_ahead_prices_time_dk_area ON day_ahead_prices (time_dk, price_area);
@@ -1 +0,0 @@
-DROP TABLE IF EXISTS metering_points;
@@ -1,15 +0,0 @@
-CREATE TABLE metering_points (
-  metering_point_id  VARCHAR(18)  PRIMARY KEY,
-  type_of_mp         VARCHAR(50),
-  balance_supplier   VARCHAR(100),
-  street_name        VARCHAR(200),
-  building_number    VARCHAR(20),
-  postcode           VARCHAR(10),
-  city_name          VARCHAR(100),
-  has_relation       BOOLEAN,
-  settlement_method  VARCHAR(50),
-  reading_occurrence VARCHAR(50),
-  consumer_start_date DATE,
-  first_consumer_name VARCHAR(200),
-  fetched_at         TIMESTAMPTZ NOT NULL DEFAULT now()
-);
@@ -1 +0,0 @@
-DROP TABLE IF EXISTS meter_readings;
@@ -1,9 +0,0 @@
-CREATE TABLE meter_readings (
-  metering_point_id  VARCHAR(18) NOT NULL REFERENCES metering_points(metering_point_id),
-  time_dk            TIMESTAMP   NOT NULL,
-  quantity_kwh       NUMERIC(10,3),
-  quality            VARCHAR(50),
-  PRIMARY KEY (metering_point_id, time_dk)
-);
--;;
-CREATE INDEX idx_meter_readings_time_dk ON meter_readings(time_dk);
@@ -1 +0,0 @@
-DROP TABLE IF EXISTS charges;
@@ -1,16 +0,0 @@
-CREATE TABLE charges (
-  id                 SERIAL,
-  metering_point_id  VARCHAR(18) NOT NULL REFERENCES metering_points(metering_point_id),
-  charge_type        VARCHAR(20) NOT NULL,
-  name               VARCHAR(200) NOT NULL,
-  description        VARCHAR(500),
-  owner              VARCHAR(100) NOT NULL,
-  valid_from_date    DATE NOT NULL,
-  valid_to_date      DATE,
-  period_type        VARCHAR(50),
-  price              NUMERIC(12,6),
-  quantity           INTEGER,
-  position           INTEGER NOT NULL DEFAULT 0,
-  fetched_at         TIMESTAMPTZ NOT NULL DEFAULT now(),
-  UNIQUE (metering_point_id, charge_type, name, owner, valid_from_date, position)
-);
@@ -1 +0,0 @@
-DROP TABLE production;
@@ -1,6 +0,0 @@
-CREATE TABLE production (
-  time_start TIMESTAMPTZ NOT NULL,
-  hour       INTEGER     NOT NULL,
-  kwh        DOUBLE PRECISION,
-  PRIMARY KEY (time_start, hour)
-);
@@ -1 +0,0 @@
-DROP TABLE consumption;
@@ -1,6 +0,0 @@
-CREATE TABLE consumption (
-  time_start TIMESTAMPTZ NOT NULL,
-  hour       INTEGER     NOT NULL,
-  kwh        DOUBLE PRECISION,
-  PRIMARY KEY (time_start, hour)
-);
@@ -1 +0,0 @@
-See https://github.com/yogthos/migratus
@@ -1,67 +0,0 @@
-- :name insert-price! :! :n
-- :doc Insert a day-ahead price record, skip if already exists
-INSERT INTO day_ahead_prices (time_utc, time_dk, price_area, price_dkk, price_eur)
-VALUES (:time-utc, :time-dk, :price-area, :price-dkk, :price-eur)
-ON CONFLICT (time_dk, price_area) DO NOTHING;
-
-- :name get-prices-for-date :? :*
-- :doc Get all prices for a given date (time_dk local date) and price area
-SELECT time_utc, time_dk, price_area, price_dkk, price_eur
-FROM day_ahead_prices
-WHERE time_dk::date = :date
-  AND price_area = :price-area
-ORDER BY time_dk;
-
-- :name upsert-metering-point! :! :n
-- :doc Upsert a metering point, refreshing data on re-sync
-INSERT INTO metering_points (metering_point_id, type_of_mp, balance_supplier, street_name,
-  building_number, postcode, city_name, has_relation, settlement_method,
-  reading_occurrence, consumer_start_date, first_consumer_name)
-VALUES (:metering-point-id, :type-of-mp, :balance-supplier, :street-name,
-  :building-number, :postcode, :city-name, :has-relation, :settlement-method,
-  :reading-occurrence, :consumer-start-date, :first-consumer-name)
-ON CONFLICT (metering_point_id) DO UPDATE SET
-  type_of_mp = EXCLUDED.type_of_mp,
-  balance_supplier = EXCLUDED.balance_supplier,
-  street_name = EXCLUDED.street_name,
-  building_number = EXCLUDED.building_number,
-  postcode = EXCLUDED.postcode,
-  city_name = EXCLUDED.city_name,
-  has_relation = EXCLUDED.has_relation,
-  settlement_method = EXCLUDED.settlement_method,
-  reading_occurrence = EXCLUDED.reading_occurrence,
-  consumer_start_date = EXCLUDED.consumer_start_date,
-  first_consumer_name = EXCLUDED.first_consumer_name,
-  fetched_at = now();
-
-- :name insert-meter-reading! :! :n
-- :doc Insert a meter reading, skip if already exists
-INSERT INTO meter_readings (metering_point_id, time_dk, quantity_kwh, quality)
-VALUES (:metering-point-id, :time-dk, :quantity-kwh, :quality)
-ON CONFLICT (metering_point_id, time_dk) DO NOTHING;
-
-- :name insert-charge! :! :n
-- :doc Insert a charge record, skip if already exists
-INSERT INTO charges (metering_point_id, charge_type, name, description, owner,
-  valid_from_date, valid_to_date, period_type, price, quantity, position)
-VALUES (:metering-point-id, :charge-type, :name, :description, :owner,
-  :valid-from-date, :valid-to-date, :period-type, :price, :quantity, :position)
-ON CONFLICT (metering_point_id, charge_type, name, owner, valid_from_date, position) DO NOTHING;
-
-- :name count-consumption-for-date :? :1
-- :doc Count consumption records for a given UTC time_start
-SELECT count(*) AS cnt
-FROM consumption
-WHERE time_start = :time-start;
-
-- :name insert-production! :! :n
-- :doc Insert a production record, skip if already exists
-INSERT INTO production (time_start, hour, kwh)
-VALUES (:time-start, :hour, :kwh)
-ON CONFLICT (time_start, hour) DO NOTHING;
-
-- :name insert-consumption! :! :n
-- :doc Insert a consumption record, skip if already exists
-INSERT INTO consumption (time_start, hour, kwh)
-VALUES (:time-start, :hour, :kwh)
-ON CONFLICT (time_start, hour) DO NOTHING;
@@ -1,70 +0,0 @@
-{:system/env
- #profile {:dev :dev
-           :test :test
-           :prod :prod}
-
- :server/http
- {:port #long #or [#env PORT 3000]
-  :host #or [#env HTTP_HOST "0.0.0.0"]
-  :handler #ig/ref :handler/ring}
-
- :handler/ring
- {:router #ig/ref :router/core
-  :api-path "/api"
-  :cookie-secret #or [#env COOKIE_SECRET "JJCILTOQLMYRBFRU"]
-  ;; from ring.middleware.defaults. anti-forgery `false` by default because services may not require it
-  :site-defaults-config {:params {:urlencoded true
-                                  :multipart true
-                                  :nested true
-                                  :keywordize true}
-                         :cookies true
-                         :session {:flash true
-                                   :cookie-name "pmagnus.elprice"
-                                   :cookie-attrs {:max-age 86400
-                                                  :http-only true
-                                                  :same-site :strict}}
-                         :security {:anti-forgery false
-                                    :xss-protection {:enable? true,
-                                                     :mode :block}
-                                    :frame-options :sameorigin
-                                    :content-type-options :nosniff}
-                         :static {:resources "public"}
-                         :responses {:not-modified-responses true
-                                     :absolute-redirects true
-                                     :content-types true
-                                     :default-charset "utf-8"}}}
-
- :reitit.routes/api
- {:base-path "/api"
-  :env #ig/ref :system/env
-  :query-fn #ig/ref :db.sql/query-fn}
-
- :router/routes
- {:routes #ig/refset :reitit/routes}
-
- :router/core
- {:routes #ig/ref :router/routes
-  :env #ig/ref :system/env}
-
- :db.sql/connection
- #profile {:dev {:jdbc-url #env JDBC_URL}
-           :test {:jdbc-url #env JDBC_URL}
-           :prod {:jdbc-url #env JDBC_URL
-                  :init-size 1
-                  :min-idle 1
-                  :max-idle 8
-                  :max-active 32}}
-
- :db.sql/query-fn
- {:conn #ig/ref :db.sql/connection
-  :options {}
-  :filename "queries.sql"
-  :env #ig/ref :system/env}
-
- :db.sql/migrations
- {:store :database
-  :db {:datasource #ig/ref :db.sql/connection}
-  :migrate-on-init? true}
- :reitit.routes/ui {:base-path "",
-                    :env #ig/ref :system/env
-                    :query-fn #ig/ref :db.sql/query-fn}}
@@ -1,11 +0,0 @@
-(ns pmagnus.elprice.config
-  (:require
-    [kit.config :as config]))
-
-
-(def ^:const system-filename "system.edn")
-
-
-(defn system-config
-  [options]
-  (config/read-config system-filename options))
@@ -1,48 +0,0 @@
-(ns pmagnus.elprice.core
-  (:gen-class)
-  (:require
-    [clojure.tools.logging :as log]
-    [integrant.core :as ig]
-    [kit.edge.db.postgres]
-    ;; Edges
-    [kit.edge.db.sql.conman]
-    [kit.edge.db.sql.migratus]
-    [kit.edge.server.undertow]
-    [pmagnus.elprice.config :as config]
-    [pmagnus.elprice.env :refer [defaults]]
-    [pmagnus.elprice.web.handler]
-    ;; Routes
-    [pmagnus.elprice.web.routes.api]
-    [pmagnus.elprice.web.routes.ui]))
-
-
-;; log uncaught exceptions in threads
-(Thread/setDefaultUncaughtExceptionHandler
-  (fn [thread ex]
-    (log/error {:what :uncaught-exception
-                :exception ex
-                :where (str "Uncaught exception on" (.getName thread))})))
-
-
-(defonce system (atom nil))
-
-
-(defn stop-app
-  []
-  ((or (:stop defaults) (fn [])))
-  (some-> (deref system) (ig/halt!)))
-
-
-(defn start-app
-  [& [params]]
-  ((or (:start params) (:start defaults) (fn [])))
-  (->> (config/system-config (or (:opts params) (:opts defaults) {}))
-       (ig/expand)
-       (ig/init)
-       (reset! system)))
-
-
-(defn -main
-  [& _]
-  (start-app)
-  (.addShutdownHook (Runtime/getRuntime) (Thread. (fn [] (stop-app) (shutdown-agents)))))
@@ -1,326 +0,0 @@
-(ns pmagnus.elprice.web.controllers.eloverblik
-  (:require
-    [clojure.data.json :as json]
-    [clojure.string :as str]
-    [clojure.tools.logging :as log])
-  (:import
-    (java.net
-      URI)
-    (java.net.http
-      HttpClient
-      HttpRequest
-      HttpRequest$BodyPublishers
-      HttpResponse$BodyHandlers)
-    (java.sql
-      Date
-      Timestamp)
-    (java.time
-      LocalDate
-      LocalDateTime
-      ZoneId)
-    (java.time.format
-      DateTimeFormatter)))
-
-
-(def ^:private base-url "https://api.eloverblik.dk/customerapi")
-(def ^:private dk-zone (ZoneId/of "Europe/Copenhagen"))
-(def ^:private date-fmt (DateTimeFormatter/ofPattern "yyyy-MM-dd"))
-
-
-;; --- Auth ---
-
-(defn- read-refresh-token
-  []
-  (or (System/getenv "ELOVERBLIK_TOKEN")
-      (str/trim (slurp ".token"))))
-
-
-(defn- get-access-token
-  "Exchange refresh token for a short-lived access token."
-  [refresh-token]
-  (let [client   (HttpClient/newHttpClient)
-        request  (-> (HttpRequest/newBuilder)
-                     (.uri (URI/create (str base-url "/api/token")))
-                     (.header "Authorization" (str "Bearer " refresh-token))
-                     (.header "Accept" "application/json")
-                     (.GET)
-                     (.build))
-        response (.send client request (HttpResponse$BodyHandlers/ofString))]
-    (when (= 200 (.statusCode response))
-      (let [body (json/read-str (.body response) :key-fn keyword)]
-        (:result body)))))
-
-
-;; --- HTTP helpers ---
-
-(defn- api-get
-  "GET with Bearer access token, returns parsed JSON."
-  [access-token path]
-  (let [client   (HttpClient/newHttpClient)
-        request  (-> (HttpRequest/newBuilder)
-                     (.uri (URI/create (str base-url path)))
-                     (.header "Authorization" (str "Bearer " access-token))
-                     (.header "Accept" "application/json")
-                     (.GET)
-                     (.build))
-        response (.send client request (HttpResponse$BodyHandlers/ofString))]
-    (log/info "GET" path "->" (.statusCode response))
-    (when (= 200 (.statusCode response))
-      (json/read-str (.body response) :key-fn keyword))))
-
-
-(defn- api-post
-  "POST with Bearer access token + JSON body, returns parsed JSON."
-  [access-token path body]
-  (let [client   (HttpClient/newHttpClient)
-        json-str (json/write-str body)
-        request  (-> (HttpRequest/newBuilder)
-                     (.uri (URI/create (str base-url path)))
-                     (.header "Authorization" (str "Bearer " access-token))
-                     (.header "Content-Type" "application/json")
-                     (.header "Accept" "application/json")
-                     (.POST (HttpRequest$BodyPublishers/ofString json-str))
-                     (.build))
-        response (.send client request (HttpResponse$BodyHandlers/ofString))]
-    (log/info "POST" path "->" (.statusCode response))
-    (when (= 200 (.statusCode response))
-      (json/read-str (.body response) :key-fn keyword))))
-
-
-;; --- Metering Points ---
-
-(defn- fetch-metering-points
-  [access-token]
-  (let [data (api-get access-token "/api/meteringpoints/meteringpoints?includeAll=true")]
-    (:result data)))
-
-
-(defn- parse-date
-  [s]
-  (when (and s (not (str/blank? s)))
-    (Date/valueOf (LocalDate/parse (subs s 0 10)))))
-
-
-(defn- upsert-mp!
-  [query-fn mp]
-  (query-fn :upsert-metering-point!
-            {:metering-point-id  (:meteringPointId mp)
-             :type-of-mp         (:typeOfMP mp)
-             :balance-supplier   (:balanceSupplierName mp)
-             :street-name        (:streetName mp)
-             :building-number    (:buildingNumber mp)
-             :postcode           (:postcode mp)
-             :city-name          (:cityName mp)
-             :has-relation       (:hasRelation mp)
-             :settlement-method  (:settlementMethod mp)
-             :reading-occurrence (:meterReadingOccurrence mp)
-             :consumer-start-date (parse-date (:consumerStartDate mp))
-             :first-consumer-name (:firstConsumerPartyName mp)}))
-
-
-(defn- save-metering-points!
-  [query-fn metering-points]
-  (let [all-mps (mapcat (fn [mp]
-                          (cons mp (:childMeteringPoints mp)))
-                        metering-points)]
-    (doseq [mp all-mps]
-      (upsert-mp! query-fn mp))
-    (log/info "Saved" (count all-mps) "metering points")))
-
-
-;; --- Time Series ---
-
-(defn- fetch-time-series
-  [access-token metering-point-ids from to]
-  (api-post access-token
-            (str "/api/meterdata/gettimeseries/"
-                 (.format from date-fmt) "/"
-                 (.format to date-fmt) "/Hour")
-            {:meteringPoints {:meteringPoint metering-point-ids}}))
-
-
-(defn- parse-time-series
-  "Parse the nested time series response into flat reading maps."
-  [response metering-point-ids]
-  (let [results (:result response)]
-    (mapcat
-      (fn [result mp-id]
-        (let [doc    (:MyEnergyData_MarketDocument result)
-              series (or (:TimeSeries doc) [])]
-          (mapcat
-            (fn [ts]
-              (mapcat
-                (fn [period]
-                  (let [start-str (get-in period [:timeInterval :start])
-                        start     (LocalDateTime/parse
-                                    start-str
-                                    (DateTimeFormatter/ofPattern "yyyy-MM-dd'T'HH:mm:ss'Z'"))
-                        start-dk  (-> start
-                                      (.atZone (ZoneId/of "UTC"))
-                                      (.withZoneSameInstant dk-zone)
-                                      (.toLocalDateTime))]
-                    (map (fn [point]
-                           (let [pos      (dec (Long/parseLong (str (:position point))))
-                                 time-dk  (.plusHours start-dk pos)
-                                 raw-qty  (get point (keyword "out_Quantity.quantity"))
-                                 quantity (when raw-qty (Double/parseDouble (str raw-qty)))]
-                             {:metering-point-id mp-id
-                              :time-dk           (Timestamp/valueOf time-dk)
-                              :quantity-kwh      quantity
-                              :quality           (get point (keyword "out_Quantity.quality"))}))
-                         (:Point period))))
-                (:Period ts)))
-            series)))
-      results
-      metering-point-ids)))
-
-
-(def ^:private production-mp-id "571313113163368491")
-(def ^:private consumption-mp-id "571313113163368507")
-
-
-(defn- utc-start-for-date
-  "Compute the UTC start of a Danish date (midnight DK -> UTC)."
-  [^LocalDate date]
-  (-> date
-      (.atStartOfDay dk-zone)
-      (.toInstant)
-      (Timestamp/from)))
-
-
-(defn- save-time-series!
-  [query-fn readings from]
-  (doseq [r readings]
-    (query-fn :insert-meter-reading! r))
-  (let [time-start (utc-start-for-date from)]
-    (doseq [r (filter #(= production-mp-id (:metering-point-id %)) readings)]
-      (let [hour (.getHour (.toLocalDateTime ^Timestamp (:time-dk r)))]
-        (query-fn :insert-production!
-                  {:time-start time-start :hour hour :kwh (:quantity-kwh r)})))
-    (doseq [r (filter #(= consumption-mp-id (:metering-point-id %)) readings)]
-      (let [hour (.getHour (.toLocalDateTime ^Timestamp (:time-dk r)))]
-        (query-fn :insert-consumption!
-                  {:time-start time-start :hour hour :kwh (:quantity-kwh r)}))))
-  (log/info "Saved" (count readings) "meter readings + production/consumption"))
-
-
-;; --- Charges ---
-
-(defn- fetch-charges
-  [access-token metering-point-ids]
-  (api-post access-token
-            "/api/meteringpoints/meteringpoint/getcharges"
-            {:meteringPoints {:meteringPoint metering-point-ids}}))
-
-
-(defn- save-charges!
-  [query-fn charges-response]
-  (let [results (:result charges-response)]
-    (doseq [result results]
-      (let [mp-id  (:id result)
-            inner  (:result result)]
-        ;; Subscriptions
-        (doseq [sub (:subscriptions inner)]
-          (query-fn :insert-charge!
-                    {:metering-point-id mp-id
-                     :charge-type       "subscription"
-                     :name              (:name sub)
-                     :description       (:description sub)
-                     :owner             (:owner sub)
-                     :valid-from-date   (parse-date (:validFromDate sub))
-                     :valid-to-date     (parse-date (:validToDate sub))
-                     :period-type       (:periodType sub)
-                     :price             (:price sub)
-                     :quantity          (:quantity sub)
-                     :position          0}))
-        ;; Tariffs (one row per position/price)
-        (doseq [tar (:tariffs inner)]
-          (let [prices (or (:prices tar) [])]
-            (if (seq prices)
-              (doseq [p prices]
-                (query-fn :insert-charge!
-                          {:metering-point-id mp-id
-                           :charge-type       "tariff"
-                           :name              (:name tar)
-                           :description       (:description tar)
-                           :owner             (:owner tar)
-                           :valid-from-date   (parse-date (:validFromDate tar))
-                           :valid-to-date     (parse-date (:validToDate tar))
-                           :period-type       (:periodType tar)
-                           :price             (:price p)
-                           :quantity          (:quantity p)
-                           :position          (some-> (:position p) str Long/parseLong)}))
-              (query-fn :insert-charge!
-                        {:metering-point-id mp-id
-                         :charge-type       "tariff"
-                         :name              (:name tar)
-                         :description       (:description tar)
-                         :owner             (:owner tar)
-                         :valid-from-date   (parse-date (:validFromDate tar))
-                         :valid-to-date     (parse-date (:validToDate tar))
-                         :period-type       (:periodType tar)
-                         :price             nil
-                         :quantity          nil
-                         :position          0}))))
-        ;; Fees
-        (doseq [fee (:fees inner)]
-          (query-fn :insert-charge!
-                    {:metering-point-id mp-id
-                     :charge-type       "fee"
-                     :name              (:name fee)
-                     :description       (:description fee)
-                     :owner             (:owner fee)
-                     :valid-from-date   (parse-date (:validFromDate fee))
-                     :valid-to-date     (parse-date (:validToDate fee))
-                     :period-type       (:periodType fee)
-                     :price             (:price fee)
-                     :quantity          (:quantity fee)
-                     :position          0}))))))
-
-
-;; --- Orchestrator ---
-
-(defn fetch-and-save-all!
-  "Fetch all Eloverblik data and save to database.
-   date is a LocalDate for which to fetch time series (one day)."
-  [query-fn ^LocalDate date]
-  (let [yesterday  (.minusDays (LocalDate/now dk-zone) 1)
-        time-start (utc-start-for-date date)
-        cnt        (:cnt (query-fn :count-consumption-for-date
-                                   {:time-start time-start}))]
-    (cond
-      (not (.isBefore date yesterday))
-      (do (log/info "No data to fetch for" (.format date date-fmt) "(too recent)")
-          {:no-data true :date (.format date date-fmt)})
-
-      (and cnt (pos? cnt))
-      (do (log/info "Data already exists for" (.format date date-fmt))
-          {:exists true :date (.format date date-fmt)})
-      :else
-      (do
-        (log/info "Starting Eloverblik fetch for" (.format date date-fmt))
-        (let [refresh-token (read-refresh-token)
-              access-token  (get-access-token refresh-token)]
-          (if-not access-token
-            (do (log/error "Failed to get Eloverblik access token")
-                {:error "Failed to get access token"})
-            (let [mps       (fetch-metering-points access-token)
-                  all-ids   (->> mps
-                                 (mapcat (fn [mp]
-                                           (cons (:meteringPointId mp)
-                                                 (map :meteringPointId
-                                                      (:childMeteringPoints mp)))))
-                                 (distinct)
-                                 (vec))
-                  from      date
-                  to        (.plusDays date 1)]
-              (log/info "Found" (count all-ids) "metering points:" all-ids)
-              (save-metering-points! query-fn mps)
-              (let [ts-resp  (fetch-time-series access-token all-ids from to)
-                    readings (parse-time-series ts-resp all-ids)]
-                (save-time-series! query-fn readings from))
-              (let [ch-resp (fetch-charges access-token all-ids)]
-                (save-charges! query-fn ch-resp))
-              {:metering-points (count all-ids)
-               :from            (.format from date-fmt)
-               :to              (.format to date-fmt)})))))))
@@ -1,15 +0,0 @@
-(ns pmagnus.elprice.web.controllers.health
-  (:require
-    [ring.util.http-response :as http-response])
-  (:import
-    (java.util
-      Date)))
-
-
-(defn healthcheck!
-  [req]
-  (http-response/ok
-    {:time     (str (Date. (System/currentTimeMillis)))
-     :up-since (str (Date. (.getStartTime (java.lang.management.ManagementFactory/getRuntimeMXBean))))
-     :app      {:status  "up"
-                :message ""}}))
@@ -1,115 +0,0 @@
-(ns pmagnus.elprice.web.controllers.prices
-  (:require
-    [clojure.data.json :as json]
-    [clojure.tools.logging :as log])
-  (:import
-    (java.net
-      URI
-      URLEncoder)
-    (java.net.http
-      HttpClient
-      HttpRequest
-      HttpResponse$BodyHandlers)
-    (java.sql
-      Timestamp)
-    (java.time
-      LocalDate
-      ZoneId)
-    (java.time.format
-      DateTimeFormatter)))
-
-
-(def ^:private dk-zone (ZoneId/of "Europe/Copenhagen"))
-
-(def ^:private date-fmt (DateTimeFormatter/ofPattern "yyyy-MM-dd"))
-
-
-(defn- build-url
-  "Build the Energi Data Service API URL for day-ahead prices."
-  [start-date end-date price-area]
-  (str "https://api.energidataservice.dk/dataset/DayAheadPrices"
-       "?start=" start-date
-       "&end=" end-date
-       "&filter=" (URLEncoder/encode (json/write-str {"PriceArea" [price-area]}) "UTF-8")
-       "&sort=TimeDK%20asc"
-       "&limit=200"))
-
-
-(defn- fetch-json
-  "Fetch JSON from a URL using JDK HttpClient."
-  [url]
-  (let [client  (HttpClient/newHttpClient)
-        request (-> (HttpRequest/newBuilder)
-                    (.uri (URI/create url))
-                    (.header "Accept" "application/json")
-                    (.GET)
-                    (.build))
-        response (.send client request (HttpResponse$BodyHandlers/ofString))]
-    (when (= 200 (.statusCode response))
-      (json/read-str (.body response) :key-fn keyword))))
-
-
-(defn- fetch-area
-  "Fetch today's and tomorrow's prices for a single price area."
-  [start end price-area]
-  (let [url (build-url start end price-area)]
-    (log/info "Fetching day-ahead prices for" price-area "from" url)
-    (when-let [data (fetch-json url)]
-      (:records data))))
-
-
-(defn fetch-prices-from-api
-  "Fetch today's and tomorrow's prices from Energi Data Service for DK1 and DK2."
-  []
-  (let [today (LocalDate/now dk-zone)
-        start (.format today date-fmt)
-        end   (.format (.plusDays today 2) date-fmt)]
-    (concat (fetch-area start end "DK1")
-            (fetch-area start end "DK2"))))
-
-
-(defn- parse-timestamp
-  "Parse an ISO timestamp string to java.sql.Timestamp."
-  [s]
-  (when s
-    (Timestamp/valueOf
-      (.replace ^String s "T" " "))))
-
-
-(defn save-records!
-  "Insert price records into the database, skipping existing ones."
-  [query-fn records]
-  (doseq [rec records]
-    (query-fn :insert-price!
-              {:time-utc   (parse-timestamp (:TimeUTC rec))
-               :time-dk    (parse-timestamp (:TimeDK rec))
-               :price-area (:PriceArea rec)
-               :price-dkk  (:DayAheadPriceDKK rec)
-               :price-eur  (:DayAheadPriceEUR rec)})))
-
-
-(defn fetch-and-save!
-  "Fetch prices from API and save to database."
-  [query-fn]
-  (when-let [records (fetch-prices-from-api)]
-    (log/info "Saving" (count records) "price records")
-    (save-records! query-fn records)
-    (count records)))
-
-
-(defn get-prices-for-date
-  "Get prices for a given LocalDate and price area from the database."
-  [query-fn date price-area]
-  (query-fn :get-prices-for-date
-            {:date       (java.sql.Date/valueOf date)
-             :price-area price-area}))
-
-
-(defn get-today-prices
-  [query-fn]
-  (get-prices-for-date query-fn (LocalDate/now dk-zone) "DK1"))
-
-
-(defn get-tomorrow-prices
-  [query-fn]
-  (get-prices-for-date query-fn (.plusDays (LocalDate/now dk-zone) 1) "DK1"))
@@ -1,43 +0,0 @@
-(ns pmagnus.elprice.web.controllers.tariffs
-  (:import
-    (java.time
-      LocalDateTime)))
-
-
-(def n1-tariffs
-  "N1 network tariffs in øre/kWh (incl. VAT), effective 2026-01-01.
-   Source: https://n1.dk/elnetkunder/gaeldende-priser"
-  {:summer {:low  10.98   ; 00:00-06:00
-            :high 16.47   ; 06:00-17:00, 21:00-24:00
-            :peak 42.83}  ; 17:00-21:00
-   :winter {:low  10.98
-            :high 32.95
-            :peak 98.84}})
-
-
-(defn season
-  "Returns :summer (Apr-Sep) or :winter (Oct-Mar) for a given month (1-12)."
-  [month]
-  (if (<= 4 month 9) :summer :winter))
-
-
-(defn load-level
-  "Returns :low, :high, or :peak for a given hour (0-23).
-   Low:  00:00-06:00
-   High: 06:00-17:00, 21:00-24:00
-   Peak: 17:00-21:00"
-  [hour]
-  (cond
-    (< hour 6)                      :low
-    (and (<= 6 hour) (< hour 17))   :high
-    (and (<= 17 hour) (< hour 21))  :peak
-    :else                           :high))
-
-
-(defn tariff-for-hour
-  "Returns the applicable N1 tariff in øre/kWh.
-   Can be called with (month, hour) or a LocalDateTime."
-  ([^LocalDateTime dt]
-   (tariff-for-hour (.getMonthValue dt) (.getHour dt)))
-  ([month hour]
-   (get-in n1-tariffs [(season month) (load-level hour)])))
@@ -1,48 +0,0 @@
-(ns pmagnus.elprice.web.handler
-  (:require
-    [integrant.core :as ig]
-    [pmagnus.elprice.web.middleware.core :as middleware]
-    [reitit.ring :as ring]
-    [reitit.swagger-ui :as swagger-ui]
-    [ring.util.http-response :as http-response]))
-
-
-(defmethod ig/init-key :handler/ring
-  [_ {:keys [router api-path] :as opts}]
-  (ring/ring-handler
-    (router)
-    (ring/routes
-      ;; Handle trailing slash in routes - add it + redirect to it
-      ;; https://github.com/metosin/reitit/blob/master/doc/ring/slash_handler.md
-      (ring/redirect-trailing-slash-handler)
-      (ring/create-resource-handler {:path "/"})
-      (when (some? api-path)
-        (swagger-ui/create-swagger-ui-handler {:path api-path
-                                               :url  (str api-path "/swagger.json")}))
-      (ring/create-default-handler
-        {:not-found
-         (constantly (-> {:status 404, :body "Page not found"}
-                         (http-response/content-type "text/plain")))
-         :method-not-allowed
-         (constantly (-> {:status 405, :body "Not allowed"}
-                         (http-response/content-type "text/plain")))
-         :not-acceptable
-         (constantly (-> {:status 406, :body "Not acceptable"}
-                         (http-response/content-type "text/plain")))}))
-    {:middleware [(middleware/wrap-base opts)]}))
-
-
-(defmethod ig/init-key :router/routes
-  [_ {:keys [routes]}]
-  (mapv (fn [route]
-          (if (fn? route)
-            (route)
-            route))
-        routes))
-
-
-(defmethod ig/init-key :router/core
-  [_ {:keys [routes env] :as opts}]
-  (if (= env :dev)
-    #(ring/router ["" opts routes])
-    (constantly (ring/router ["" opts routes]))))
@@ -1,29 +0,0 @@
-(ns pmagnus.elprice.web.htmx
-  (:require
-    [hiccup.core :as h]
-    [hiccup.page :as p]
-    [ring.util.http-response :as http-response]))
-
-
-(defmacro page
-  [opts & content]
-  `(-> (p/html5 ~opts
-                [:head
-                 [:meta {:charset "UTF-8"}]
-                 [:meta {:name "viewport"
-                         :content "width=device-width, initial-scale=1, viewport-fit=cover"}]
-                 [:link {:rel "stylesheet" :href "/css/output.css"}]
-                 [:script {:src "https://unpkg.com/htmx.org@2.0.8/dist/htmx.min.js"
-                           :defer true}]]
-                [:body {:class "bg-gray-50 min-h-screen"}
-                 [:div {:class "mx-auto max-w-[390px] px-4 py-6"}
-                  ~@content]])
-       http-response/ok
-       (http-response/content-type "text/html")))
-
-
-(defmacro fragment
-  [opts & content]
-  `(-> (str (h/html ~opts ~@content))
-       http-response/ok
-       (http-response/content-type "text/html")))
@@ -1,14 +0,0 @@
-(ns pmagnus.elprice.web.middleware.core
-  (:require
-    [pmagnus.elprice.env :as env]
-    [ring.middleware.defaults :as defaults]
-    [ring.middleware.session.cookie :as cookie]))
-
-
-(defn wrap-base
-  [{:keys [metrics site-defaults-config cookie-secret] :as opts}]
-  (let [cookie-store (cookie/cookie-store {:key (.getBytes ^String cookie-secret)})]
-    (fn [handler]
-      (cond-> ((:middleware env/defaults) handler opts)
-        true (defaults/wrap-defaults
-               (assoc-in site-defaults-config [:session :store] cookie-store))))))
@@ -1,34 +0,0 @@
-(ns pmagnus.elprice.web.middleware.exception
-  (:require
-    [clojure.tools.logging :as log]
-    [reitit.ring.middleware.exception :as exception]))
-
-
-(defn handler
-  [message status exception request]
-  (when (>= status 500)
-    ;; You can optionally use this to report error to an external service
-    (log/error exception))
-  {:status status
-   :body   {:message   message
-            :exception (.getClass exception)
-            :data      (ex-data exception)
-            :uri       (:uri request)}})
-
-
-(def wrap-exception
-  (exception/create-exception-middleware
-    (merge
-      exception/default-handlers
-      {:system.exception/internal     (partial handler "internal exception" 500)
-       :system.exception/business     (partial handler "bad request" 400)
-       :system.exception/not-found    (partial handler "not found" 404)
-       :system.exception/unauthorized (partial handler "unauthorized" 401)
-       :system.exception/forbidden    (partial handler "forbidden" 403)
-
-       ;; override the default handler
-       ::exception/default            (partial handler "default" 500)
-
-       ;; print stack-traces for all exceptions
-       ::exception/wrap               (fn [handler e request]
-                                        (handler e request))})))
@@ -1,15 +0,0 @@
-(ns pmagnus.elprice.web.middleware.formats
-  (:require
-    [luminus-transit.time :as time]
-    [muuntaja.core :as m]))
-
-
-(def instance
-  (m/create
-    (-> m/default-options
-        (update-in
-          [:formats "application/transit+json" :decoder-opts]
-          (partial merge time/time-deserialization-handlers))
-        (update-in
-          [:formats "application/transit+json" :encoder-opts]
-          (partial merge time/time-serialization-handlers)))))
@@ -1,57 +0,0 @@
-(ns pmagnus.elprice.web.routes.api
-  (:require
-    [integrant.core :as ig]
-    [pmagnus.elprice.web.controllers.health :as health]
-    [pmagnus.elprice.web.middleware.exception :as exception]
-    [pmagnus.elprice.web.middleware.formats :as formats]
-    [reitit.coercion.malli :as malli]
-    [reitit.ring.coercion :as coercion]
-    [reitit.ring.middleware.muuntaja :as muuntaja]
-    [reitit.ring.middleware.parameters :as parameters]
-    [reitit.swagger :as swagger]))
-
-
-(def route-data
-  {:coercion   malli/coercion
-   :muuntaja   formats/instance
-   :swagger    {:id ::api}
-   :middleware [;; query-params & form-params
-                parameters/parameters-middleware
-                ;; content-negotiation
-                muuntaja/format-negotiate-middleware
-                ;; encoding response body
-                muuntaja/format-response-middleware
-                ;; exception handling
-                coercion/coerce-exceptions-middleware
-                ;; decoding request body
-                muuntaja/format-request-middleware
-                ;; coercing response bodys
-                coercion/coerce-response-middleware
-                ;; coercing request parameters
-                coercion/coerce-request-middleware
-                ;; exception handling
-                exception/wrap-exception]})
-
-
-;; Routes
-(defn api-routes
-  [_opts]
-  [["/swagger.json"
-    {:get {:no-doc  true
-           :swagger {:info {:title "pmagnus.elprice API"}}
-           :handler (swagger/create-swagger-handler)}}]
-   ["/health"
-    ;; note that use of the var is necessary
-    ;; for reitit to reload routes without
-    ;; restarting the system
-    {:get #'health/healthcheck!}]])
-
-
-(derive :reitit.routes/api :reitit/routes)
-
-
-(defmethod ig/init-key :reitit.routes/api
-  [_ {:keys [base-path]
-      :or   {base-path ""}
-      :as   opts}]
-  (fn [] [base-path route-data (api-routes opts)]))
@@ -1,269 +0,0 @@
-(ns pmagnus.elprice.web.routes.ui
-  (:require
-    [integrant.core :as ig]
-    [pmagnus.elprice.web.controllers.eloverblik :as eloverblik]
-    [pmagnus.elprice.web.controllers.prices :as prices]
-    [pmagnus.elprice.web.controllers.tariffs :as tariffs]
-    [pmagnus.elprice.web.htmx :refer [page fragment]]
-    [pmagnus.elprice.web.middleware.exception :as exception]
-    [pmagnus.elprice.web.middleware.formats :as formats]
-    [pmagnus.elprice.web.routes.utils :as utils]
-    [reitit.ring.middleware.muuntaja :as muuntaja]
-    [reitit.ring.middleware.parameters :as parameters])
-  (:import
-    (java.time
-      LocalDateTime
-      ZoneId)
-    (java.time.format
-      DateTimeFormatter)))
-
-
-(def ^:private dk-zone (ZoneId/of "Europe/Copenhagen"))
-(def ^:private hour-fmt (DateTimeFormatter/ofPattern "HH:00"))
-(def ^:private date-fmt (DateTimeFormatter/ofPattern "yyyy-MM-dd"))
-
-
-(defn- ->ldt
-  [time-dk]
-  (cond
-    (instance? LocalDateTime time-dk) time-dk
-    (instance? java.sql.Timestamp time-dk)
-    (.toLocalDateTime ^java.sql.Timestamp time-dk)
-    :else (LocalDateTime/parse (str time-dk))))
-
-
-(defn- format-hour
-  [time-dk]
-  (.format (->ldt time-dk) hour-fmt))
-
-
-(defn- dkk-mwh->ore-kwh
-  "Convert DKK/MWh to øre/kWh (divide by 10)."
-  [price-dkk]
-  (when price-dkk
-    (/ (double price-dkk) 10.0)))
-
-
-(defn- format-ore
-  "Format price as total(net) where total = net + tariff, or just net if no tariff."
-  ([price-dkk]
-   (if-let [ore (dkk-mwh->ore-kwh price-dkk)]
-     (format "%.1f" ore)
-     "-"))
-  ([price-dkk tariff]
-   (if-let [ore (dkk-mwh->ore-kwh price-dkk)]
-     (format "%.1f(%.1f)" (+ ore tariff) ore)
-     "-")))
-
-
-(defn- group-by-hour
-  [prices]
-  (->> prices
-       (group-by #(.getHour (->ldt (:time_dk %))))
-       (sort-by key)))
-
-
-(defn- avg-ore
-  [quarters]
-  (let [vals (keep :price_dkk quarters)]
-    (when (seq vals)
-      (/ (reduce + 0.0 (map double vals)) (count vals) 10.0))))
-
-
-(def ^:private red-gradient
-  ["bg-red-50" "bg-red-100" "bg-red-200" "bg-red-300"
-   "bg-red-400" "bg-red-500" "bg-red-600" "bg-red-700"])
-
-
-(def ^:private green-gradient
-  ["bg-green-700" "bg-green-600" "bg-green-500" "bg-green-400"
-   "bg-green-300" "bg-green-200" "bg-green-100" "bg-green-50"])
-
-
-(defn- rank-bg
-  [rank total]
-  (cond
-    (<= rank 8)               (get green-gradient (dec rank))
-    (> rank (- total 8))      (get red-gradient (- rank (- total 7)))
-    :else                     nil))
-
-
-(defn- hour-block
-  [hour quarters rank total-hours]
-  (let [sorted (sort-by #(.getMinute (->ldt (:time_dk %))) quarters)
-        avg    (avg-ore quarters)
-        month  (.getMonthValue (->ldt (:time_dk (first quarters))))
-        tariff (tariffs/tariff-for-hour month hour)
-        bg     (rank-bg rank total-hours)
-        dark?  (and bg (or (<= rank 4) (>= rank (- total-hours 3))))]
-    [:details {:class (str "border-2 border-blue-400 rounded-lg mb-2 " bg)}
-     [:summary {:class (str "flex justify-between py-2 px-3 cursor-pointer font-medium "
-                            (if dark? "text-white" "text-gray-900"))}
-      [:span (format "%02d:00" hour)]
-      [:span {:class (str "text-sm " (if dark? "text-white/80" "text-gray-500"))} (str "#" rank)]
-      [:span {:class "font-mono"}
-       (if avg (format "%.1f(%.1f)" (+ avg tariff) avg) "-")]]
-     [:div {:class (str "border-t-2 border-blue-400 px-3 pb-2 "
-                        (if dark? "text-white/80" "text-gray-500"))}
-      (for [q sorted]
-        [:div {:class "flex justify-between py-1 ml-4"}
-         [:span (format "%02d:%02d" hour (.getMinute (->ldt (:time_dk q))))]
-         [:span {:class "font-mono"} (format-ore (:price_dkk q) tariff)]])]]))
-
-
-(defn- hour-ranks
-  "Compute a map of hour -> rank (1 = cheapest) based on total price (avg + tariff)."
-  [grouped-hours]
-  (let [totals (for [[hour quarters] grouped-hours]
-                 (let [avg    (avg-ore quarters)
-                       month  (.getMonthValue (->ldt (:time_dk (first quarters))))
-                       tariff (tariffs/tariff-for-hour month hour)]
-                   [hour (if avg (+ avg tariff) Double/MAX_VALUE)]))]
-    (->> totals
-         (sort-by second)
-         (map-indexed (fn [i [hour _]] [hour (inc i)]))
-         (into {}))))
-
-
-(defn- price-table
-  [prices]
-  [:div
-   (if (seq prices)
-     (let [grouped     (group-by-hour prices)
-           ranks       (hour-ranks grouped)
-           total-hours (count grouped)]
-       [:div
-        (for [[hour quarters] grouped]
-          (hour-block hour quarters (get ranks hour) total-hours))])
-     [:p {:class "mt-2 text-sm text-gray-400"} "Not available yet"])])
-
-
-(def ^:private tab-base
-  "px-4 py-2 font-medium text-sm rounded-t-lg border-2 border-b-0 ")
-
-
-(def ^:private tab-active
-  (str tab-base "border-blue-400 bg-white text-gray-900"))
-
-
-(def ^:private tab-inactive
-  (str tab-base "border-gray-200 bg-gray-100 text-gray-500 hover:text-gray-700 cursor-pointer"))
-
-
-(defn- tabs
-  [active-tab has-tomorrow?]
-  (let [today    (java.time.LocalDate/now dk-zone)
-        tomorrow (.plusDays today 1)]
-    [:div {:class "flex gap-1 mt-4"}
-     [:button {:class (if (= active-tab :today) tab-active tab-inactive)
-               :hx-get "/prices/today"
-               :hx-target "#price-panel"
-               :hx-swap "innerHTML"}
-      (str "Today " (.format today date-fmt))]
-     (when has-tomorrow?
-       [:button {:class (if (= active-tab :tomorrow) tab-active tab-inactive)
-                 :hx-get "/prices/tomorrow"
-                 :hx-target "#price-panel"
-                 :hx-swap "innerHTML"}
-        (str "Tomorrow " (.format tomorrow date-fmt))])]))
-
-
-(defn- price-content
-  [tab prices has-tomorrow?]
-  [:div
-   (tabs tab has-tomorrow?)
-   [:div {:id "price-content"
-          :class "border-2 border-blue-400 rounded-b-lg rounded-tr-lg p-4 bg-white"}
-    (price-table prices)]])
-
-
-(defn- has-tomorrow?
-  [query-fn]
-  (seq (prices/get-tomorrow-prices query-fn)))
-
-
-(defn home
-  [query-fn request]
-  (prices/fetch-and-save! query-fn)
-  (page {:lang "en"}
-        [:h1 {:class "text-2xl font-bold text-gray-900 cursor-pointer hover:text-blue-600 transition-colors"
-              :hx-post "/prices/fetch"
-              :hx-target "#price-panel"
-              :hx-swap "innerHTML"}
-         "Electricity Prices"]
-        [:p {:class "mt-1 text-sm text-gray-500"}
-         "Day-ahead prices for DK1 — total(spot) in øre/kWh incl. N1 tariff"]
-        [:div {:id "price-panel"}
-         (price-content :today (prices/get-today-prices query-fn) (has-tomorrow? query-fn))]))
-
-
-(defn prices-today
-  [query-fn request]
-  (fragment
-    (price-content :today (prices/get-today-prices query-fn) (has-tomorrow? query-fn))))
-
-
-(defn prices-tomorrow
-  [query-fn request]
-  (fragment
-    (price-content :tomorrow (prices/get-tomorrow-prices query-fn) (has-tomorrow? query-fn))))
-
-
-(defn fetch-prices
-  [query-fn request]
-  (prices/fetch-and-save! query-fn)
-  (fragment
-    (price-content :today (prices/get-today-prices query-fn) (has-tomorrow? query-fn))))
-
-
-(defn sync-eloverblik
-  [query-fn request]
-  (let [date-str (get-in request [:params :date])
-        date     (if date-str
-                   (java.time.LocalDate/parse date-str)
-                   (java.time.LocalDate/now dk-zone))
-        result   (eloverblik/fetch-and-save-all! query-fn date)]
-    (fragment
-      (cond
-        (:error result)
-        [:p {:class "text-red-600 font-medium"} (:error result)]
-        (:no-data result)
-        [:p {:class "text-gray-400"} (str "No data to fetch for " (:date result))]
-        (:exists result)
-        [:p {:class "text-gray-500"} (str "Data exists for " (:date result))]
-        :else
-        [:p {:class "text-green-700 font-medium"}
-         (str "Synced " (:metering-points result)
-              " metering points (" (:from result) " to " (:to result) ")")]))))
-
-
-;; Routes
-(defn ui-routes
-  [{:keys [query-fn]}]
-  [["/" {:get (partial home query-fn)}]
-   ["/prices/today" {:get (partial prices-today query-fn)}]
-   ["/prices/tomorrow" {:get (partial prices-tomorrow query-fn)}]
-   ["/prices/fetch" {:post (partial fetch-prices query-fn)}]
-   ["/eloverblik/sync" {:post (partial sync-eloverblik query-fn)}]])
-
-
-(def route-data
-  {:muuntaja   formats/instance
-   :middleware
-   [;; Default middleware for ui
-    ;; query-params & form-params
-    parameters/parameters-middleware
-    ;; encoding response body
-    muuntaja/format-response-middleware
-    ;; exception handling
-    exception/wrap-exception]})
-
-
-(derive :reitit.routes/ui :reitit/routes)
-
-
-(defmethod ig/init-key :reitit.routes/ui
-  [_ {:keys [base-path]
-      :or   {base-path ""}
-      :as   opts}]
-  (fn [] [base-path route-data (ui-routes opts)]))
@@ -1,13 +0,0 @@
-(ns pmagnus.elprice.web.routes.utils)
-
-(def route-data-path [:reitit.core/match :data])
-
-
-(defn route-data
-  [req]
-  (get-in req route-data-path))
-
-
-(defn route-data-key
-  [req k]
-  (get-in req (conj route-data-path k)))
@@ -1,32 +0,0 @@
-#!/usr/bin/env bash
-# Sync Eloverblik data for a specific month.
-# Usage: ./sync-month.sh 2026-02
-set -euo pipefail
-
-if [ $# -ne 1 ]; then
-  echo "Usage: $0 YYYY-MM"
-  exit 1
-fi
-
-MONTH="$1"
-BASE_URL="${BASE_URL:-http://localhost:3030}"
-
-# Last day of the month
-days=$(date -d "${MONTH}-01 +1 month -1 day" "+%d")
-
-echo "Syncing $MONTH ($days days)"
-
-for day in $(seq 1 "$days"); do
-  d=$(printf "%s-%02d" "$MONTH" "$day")
-  resp=$(curl -s -X POST "${BASE_URL}/eloverblik/sync?date=${d}")
-  text=$(echo "$resp" | sed 's/<[^>]*>//g' | xargs)
-
-  if [ -z "$text" ]; then
-    echo "$d: no response (server down?)"
-    exit 1
-  fi
-
-  echo "$d: $text"
-done
-
-echo "Done."
@@ -1,5 +0,0 @@
-module.exports = {
-  content: ["./src/**/*.clj", "./resources/**/*.html"],
-  theme: { extend: {} },
-  plugins: []
-}
@@ -1,8 +0,0 @@
-(ns pmagnus.elprice.core-test
-  (:require
-    [pmagnus.elprice.test-utils :as utils]
-    [clojure.test :refer :all]))
-
-(deftest example-test
-  (is (= 1 2)))
-
@@ -1,32 +0,0 @@
-(ns pmagnus.elprice.test-utils
-  (:require
-    [pmagnus.elprice.core :as core]
-    [peridot.core :as p]
-    [byte-streams :as bs]
-    [integrant.repl.state :as state]))
-
-(defn system-state
-  []
-  (or @core/system state/system))
-
-(defn system-fixture
-  []
-  (fn [f]
-    (when (nil? (system-state))
-      (core/start-app {:opts {:profile :test}}))
-    (f)
-    (core/stop-app)))
-
-(defn get-response [ctx]
-  (-> ctx
-      :response
-      (update :body (fnil bs/to-string ""))))
-
-(defn GET [app path params headers]
-  (-> (p/session app)
-      (p/request path
-                 :request-method :get
-                 :content-type "application/edn"
-                 :headers headers
-                 :params params)
-      (get-response)))
@@ -1,13 +0,0 @@
-(ns pmagnus.elprice.web.request-test
-  (:require  [clojure.test :refer [deftest testing is use-fixtures]]
-             [pmagnus.elprice.test-utils :refer [system-state system-fixture GET]]))
-
-(use-fixtures :once (system-fixture))
-
-(deftest health-request-test []
-  (testing "happy path"
-    (let [handler (:handler/ring (system-state))
-          params {}
-          headers {}
-          response (GET handler "/api/health" params headers)]
-      (is (= 200 (:status response))))))
				`@@ -1 +0,0 @@`
				`DROP INDEX IF EXISTS idx_day_ahead_prices_time_dk_area;`
				`@@ -1 +0,0 @@`
				`CREATE UNIQUE INDEX idx_day_ahead_prices_time_dk_area ON day_ahead_prices (time_dk, price_area);`