magnusandClaude Opus 4.6
f64aa98b04
Split from btcprice monolith. Owns DB, migrations, Binance WebSocket, Kraken OHLC pollers, and exposes a JSON API with SSE price stream. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
51 lines
1.3 KiB
Clojure
51 lines
1.3 KiB
Clojure
(ns user
|
|
(:require
|
|
[clojure.tools.logging :as log]
|
|
[integrant.core :as ig]
|
|
[integrant.repl :refer [go halt reset reset-all set-prep!]]
|
|
[integrant.repl.state :as state]
|
|
[pmagnus.btcdata.config :as config]
|
|
[pmagnus.btcdata.core]))
|
|
|
|
(defn dev-prep! []
|
|
(set-prep!
|
|
(fn []
|
|
(-> (config/system-config {:profile :dev})
|
|
(ig/expand)))))
|
|
|
|
(defn test-prep! []
|
|
(set-prep!
|
|
(fn []
|
|
(-> (config/system-config {:profile :test})
|
|
(ig/expand)))))
|
|
|
|
(defn reset-db []
|
|
(let [sys (or @pmagnus.btcdata.core/system
|
|
integrant.repl.state/system)]
|
|
(when-let [mig (:db.sql/migrations sys)]
|
|
(migratus.core/reset mig)
|
|
(log/info "Database reset complete"))))
|
|
|
|
(defn rollback []
|
|
(let [sys (or @pmagnus.btcdata.core/system
|
|
integrant.repl.state/system)]
|
|
(when-let [mig (:db.sql/migrations sys)]
|
|
(migratus.core/rollback mig))))
|
|
|
|
(defn migrate []
|
|
(let [sys (or @pmagnus.btcdata.core/system
|
|
integrant.repl.state/system)]
|
|
(when-let [mig (:db.sql/migrations sys)]
|
|
(migratus.core/migrate mig))))
|
|
|
|
(defn query-fn []
|
|
(let [sys (or @pmagnus.btcdata.core/system
|
|
integrant.repl.state/system)]
|
|
(:db.sql/query-fn sys)))
|
|
|
|
(comment
|
|
(dev-prep!)
|
|
(go)
|
|
(reset)
|
|
(halt))
|