mirror of
https://github.com/penpot/penpot.git
synced 2025-05-11 09:16:37 +02:00
💄 Minor cosmetic change on database logger processor
This commit is contained in:
parent
8babb59f75
commit
d358185a04
1 changed files with 6 additions and 3 deletions
|
@ -69,12 +69,15 @@
|
||||||
(defmethod ig/pre-init-spec ::reporter [_]
|
(defmethod ig/pre-init-spec ::reporter [_]
|
||||||
(s/keys :req-un [::wrk/executor ::db/pool ::receiver]))
|
(s/keys :req-un [::wrk/executor ::db/pool ::receiver]))
|
||||||
|
|
||||||
|
(defn error-event?
|
||||||
|
[event]
|
||||||
|
(= "error" (:logger/level event)))
|
||||||
|
|
||||||
(defmethod ig/init-key ::reporter
|
(defmethod ig/init-key ::reporter
|
||||||
[_ {:keys [receiver] :as cfg}]
|
[_ {:keys [receiver] :as cfg}]
|
||||||
(l/info :msg "initializing database error persistence")
|
(l/info :msg "initializing database error persistence")
|
||||||
(let [output (a/chan (a/sliding-buffer 128)
|
(let [output (a/chan (a/sliding-buffer 5)
|
||||||
(filter (fn [event]
|
(filter error-event?))]
|
||||||
(= (:logger/level event) "error"))))]
|
|
||||||
(receiver :sub output)
|
(receiver :sub output)
|
||||||
(a/go-loop []
|
(a/go-loop []
|
||||||
(let [msg (a/<! output)]
|
(let [msg (a/<! output)]
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue