magnus/btcdata
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Show human-readable timestamps in Kraken minute poller logs

Browse Source 
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
magnus
2026-03-13 13:14:35 +01:00
co-authored by Claude Opus 4.6
parent f27c198634
commit ae65ea3722
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/clj/pmagnus/btcdata/kraken/ohlc_minute.clj
+7 -2
View File
@@ -5,7 +5,9 @@
[integrant.core :as ig]) [integrant.core :as ig])
(:import (:import
[java.net URI] [java.net URI]
[java.net.http HttpClient HttpRequest HttpResponse$BodyHandlers])) [java.net.http HttpClient HttpRequest HttpResponse$BodyHandlers]
[java.time Instant ZoneOffset]
[java.time.format DateTimeFormatter]))
(def ^:private kraken-ohlc-url (def ^:private kraken-ohlc-url
"https://api.kraken.com/0/public/OHLC?pair=XBTUSD&interval=1") "https://api.kraken.com/0/public/OHLC?pair=XBTUSD&interval=1")
@@ -67,7 +69,10 @@
(save-candles! query-fn candles) (save-candles! query-fn candles)
(when last-ts (when last-ts
(reset! since-atom last-ts)) (reset! since-atom last-ts))
(log/info "Fetched" (count candles) "Kraken minute candles")) (let [fmt (DateTimeFormatter/ofPattern "HH:mm")
latest (:ts (last candles))
ts-str (.format (.atOffset (Instant/ofEpochSecond latest) ZoneOffset/UTC) fmt)]
(log/info "Kraken minute:" (count candles) "candles, latest" ts-str "UTC")))
(count candles))) (count candles)))
(defn- start-poll-loop! (defn- start-poll-loop!