feat: Add handling-error-interceptor

liquidz · Feb 23, 2024 · 012617e · 012617e
1 parent b111c36
commit 012617e
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/resources/config.edn b/resources/config.edn
@@ -4,6 +4,7 @@
                           elin.interceptor.connect/connected-interceptor
                           elin.interceptor.connect/output-channel-interceptor
                           elin.interceptor.connect/port-auto-detecting-interceptor
+                          elin.interceptor.handler/handling-error-interceptor
                           elin.interceptor.nrepl/eval-ns-interceptor
                           elin.interceptor.nrepl/normalize-path-interceptor
                           elin.interceptor.output/print-output-interceptor

diff --git a/src/elin/interceptor/handler.clj b/src/elin/interceptor/handler.clj
@@ -0,0 +1,14 @@
+(ns elin.interceptor.handler
+  (:require
+   [elin.constant.interceptor :as e.c.interceptor]
+   [elin.error :as e]
+   [elin.protocol.rpc :as e.p.rpc]
+   [exoscale.interceptor :as ix]))
+
+(def handling-error-interceptor
+  {:name ::handling-error-interceptor
+   :kind e.c.interceptor/handler
+   :leave (-> (fn [{:component/keys [host] :keys [response]}]
+                (e.p.rpc/echo-message host (ex-message response) "ErrorMsg"))
+              (ix/when (comp e/error? :response))
+              (ix/discard))})