From cf72017a5bf9fd01a690aaf9962bc219a42e7277 Mon Sep 17 00:00:00 2001 From: Peter Taoussanis Date: Thu, 9 May 2024 16:55:01 +0200 Subject: [PATCH] [fix] `pr-signal-fn`: wasn't realizing delayed messages Thanks to @DenisMc for the report! --- src/taoensso/telemere/utils.cljc | 1 + test/taoensso/telemere_tests.cljc | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/taoensso/telemere/utils.cljc b/src/taoensso/telemere/utils.cljc index 2f8edbc..74dfdce 100644 --- a/src/taoensso/telemere/utils.cljc +++ b/src/taoensso/telemere/utils.cljc @@ -614,6 +614,7 @@ (let [not-map? (not (map? signal)) signal (if (or incl-kvs? not-map?) signal (dissoc signal :kvs)) signal (if (or incl-thread? not-map?) signal (dissoc signal :thread)) + signal (if not-map? signal (force-signal-msg signal)) signal (if prep-fn (prep-fn signal) signal) output (pr-fn signal)] diff --git a/test/taoensso/telemere_tests.cljc b/test/taoensso/telemere_tests.cljc index a15133f..fd7e209 100644 --- a/test/taoensso/telemere_tests.cljc +++ b/test/taoensso/telemere_tests.cljc @@ -690,7 +690,7 @@ (is (string? (re-find #"taoensso.telemere-tests\(\d+,\d+\)" preamble)))])) (testing "pr-signal-fn" - (let [sig (with-sig (tel/event! ::ev-id {:inst t0}))] + (let [sig (with-sig :raw :trap (tel/event! ::ev-id {:inst t0, :msg ["a" "b"]}))] [(testing ":edn" (let [sig (update sig :inst enc/inst->udt) @@ -702,6 +702,7 @@ (enc/submap? sig*1 {:schema 1, :kind :event, :id ::ev-id, :level :info, :ns "taoensso.telemere-tests" + :msg_ "a b" :inst udt0 :line pnat-int? :column pnat-int?}))])) @@ -713,6 +714,7 @@ (enc/submap? sig* {"schema" 1, "kind" "event", "id" "taoensso.telemere-tests/ev-id", "level" "info", "ns" "taoensso.telemere-tests" + "msg_" "a b" "inst" t0s "line" pnat-int? "column" pnat-int?})))))