|
1 | 1 | (ns cider.nrepl.middleware.inspect
|
2 | 2 | (:require
|
3 | 3 | [cider.nrepl.middleware.util.cljs :as cljs]
|
4 |
| - [cider.nrepl.middleware.util.error-handling :refer [base-error-response]] |
| 4 | + [cider.nrepl.middleware.util.error-handling :refer [base-error-response |
| 5 | + with-safe-transport]] |
5 | 6 | [orchard.inspect :as inspect]))
|
6 | 7 |
|
7 | 8 | ;; Compatibility with the legacy tools.nrepl and the new nREPL 0.4.x.
|
|
41 | 42 | (response-for msg :value (:rendered inspector))))))
|
42 | 43 |
|
43 | 44 | (defn inspector-transport
|
44 |
| - [{:keys [^Transport transport] :as msg}] |
| 45 | + [{:keys [^Transport transport, session] :as msg}] |
45 | 46 | (reify Transport
|
46 | 47 | (recv [this] (.recv transport))
|
47 | 48 | (recv [this timeout] (.recv transport timeout))
|
48 | 49 | (send [this response]
|
49 |
| - (if (contains? response :value) |
50 |
| - (inspect-reply msg response) |
51 |
| - (.send transport response)) |
| 50 | + (cond (contains? response :value) |
| 51 | + (inspect-reply msg response) |
| 52 | + |
| 53 | + ;; If the eval errored, propagate the exception as error in the |
| 54 | + ;; inspector middleware, so that the client CIDER code properly |
| 55 | + ;; renders it instead of silently ignoring it. |
| 56 | + (contains? (:status response) :eval-error) |
| 57 | + (let [e (or (@session #'*e) |
| 58 | + (Exception. (or (:ex response) ""))) |
| 59 | + resp (base-error-response msg e :inspect-eval-error :done)] |
| 60 | + (.send transport resp)) |
| 61 | + |
| 62 | + :else (.send transport response)) |
52 | 63 | this)))
|
53 | 64 |
|
54 | 65 | (defn eval-msg
|
|
61 | 72 | [handler msg]
|
62 | 73 | (handler (eval-msg msg)))
|
63 | 74 |
|
64 |
| -(defn- success [{:keys [transport] :as msg} inspector] |
65 |
| - (transport/send transport (response-for msg :value (:rendered inspector) :status :done))) |
66 |
| - |
67 |
| -(defn- failure [{:keys [transport] :as msg} err err-kw] |
68 |
| - (transport/send transport (base-error-response msg err err-kw :done))) |
| 75 | +(defn- inspector-response [msg inspector] |
| 76 | + (response-for msg :value (:rendered inspector) :status :done)) |
69 | 77 |
|
70 | 78 | (defn pop-reply [msg]
|
71 |
| - (try (success msg (swap-inspector! msg inspect/up)) |
72 |
| - (catch Exception e (failure msg e :inspect-pop-error)))) |
| 79 | + (inspector-response msg (swap-inspector! msg inspect/up))) |
73 | 80 |
|
74 | 81 | (defn push-reply [msg]
|
75 |
| - (try (success msg (swap-inspector! msg inspect/down (:idx msg))) |
76 |
| - (catch Exception e (failure msg e :inspect-push-error)))) |
| 82 | + (inspector-response msg (swap-inspector! msg inspect/down (:idx msg)))) |
77 | 83 |
|
78 | 84 | (defn refresh-reply [msg]
|
79 |
| - (try (success msg (swap-inspector! msg #(or % (inspect/fresh)))) |
80 |
| - (catch Exception e (failure msg e :inspect-refresh-error)))) |
| 85 | + (inspector-response msg (swap-inspector! msg #(or % (inspect/fresh))))) |
81 | 86 |
|
82 | 87 | (defn get-path-reply [{:keys [session] :as msg}]
|
83 |
| - (try (success msg (:path (get session #'*inspector*))) |
84 |
| - (catch Exception e (failure msg e :inspect-get-path-error)))) |
| 88 | + (:path (get session #'*inspector*))) |
85 | 89 |
|
86 | 90 | (defn next-page-reply [msg]
|
87 |
| - (try (success msg (swap-inspector! msg inspect/next-page)) |
88 |
| - (catch Exception e (failure msg e :inspect-next-page-error)))) |
| 91 | + (inspector-response msg (swap-inspector! msg inspect/next-page))) |
89 | 92 |
|
90 | 93 | (defn prev-page-reply [msg]
|
91 |
| - (try (success msg (swap-inspector! msg inspect/prev-page)) |
92 |
| - (catch Exception e (failure msg e :inspect-prev-page-error)))) |
| 94 | + (inspector-response msg (swap-inspector! msg inspect/prev-page))) |
93 | 95 |
|
94 | 96 | (defn set-page-size-reply [msg]
|
95 |
| - (try (success msg (swap-inspector! msg inspect/set-page-size (:page-size msg))) |
96 |
| - (catch Exception e (failure msg e :inspect-set-page-size-error)))) |
| 97 | + (inspector-response msg (swap-inspector! msg inspect/set-page-size (:page-size msg)))) |
97 | 98 |
|
98 | 99 | (defn handle-inspect [handler msg]
|
99 |
| - (case (:op msg) |
100 |
| - "eval" (eval-reply handler msg) |
101 |
| - "inspect-pop" (pop-reply msg) |
102 |
| - "inspect-push" (push-reply msg) |
103 |
| - "inspect-refresh" (refresh-reply msg) |
104 |
| - "inspect-get-path" (get-path-reply msg) |
105 |
| - "inspect-next-page" (next-page-reply msg) |
106 |
| - "inspect-prev-page" (prev-page-reply msg) |
107 |
| - "inspect-set-page-size" (set-page-size-reply msg) |
108 |
| - (handler msg))) |
| 100 | + (if (= (:op msg) "eval") |
| 101 | + (eval-reply handler msg) |
| 102 | + |
| 103 | + (with-safe-transport handler msg |
| 104 | + "inspect-pop" pop-reply |
| 105 | + "inspect-push" push-reply |
| 106 | + "inspect-refresh" refresh-reply |
| 107 | + "inspect-get-path" get-path-reply |
| 108 | + "inspect-next-page" next-page-reply |
| 109 | + "inspect-prev-page" prev-page-reply |
| 110 | + "inspect-set-page-size" set-page-size-reply))) |
0 commit comments