mirror of
https://github.com/metosin/reitit.git
synced 2026-02-10 21:35:17 +00:00
Update sieppari, fix tests
This commit is contained in:
parent
6777cb8620
commit
b1c8dbdaa4
3 changed files with 9 additions and 9 deletions
|
|
@ -32,7 +32,7 @@
|
||||||
[metosin/schema-tools "0.12.2"]
|
[metosin/schema-tools "0.12.2"]
|
||||||
[metosin/muuntaja "0.6.7"]
|
[metosin/muuntaja "0.6.7"]
|
||||||
[metosin/jsonista "0.2.6"]
|
[metosin/jsonista "0.2.6"]
|
||||||
[metosin/sieppari "0.0.0-alpha9"]
|
[metosin/sieppari "0.0.0-alpha10"]
|
||||||
[metosin/malli "0.0.1-20200404.091302-14"]
|
[metosin/malli "0.0.1-20200404.091302-14"]
|
||||||
|
|
||||||
;; https://clojureverse.org/t/depending-on-the-right-versions-of-jackson-libraries/5111
|
;; https://clojureverse.org/t/depending-on-the-right-versions-of-jackson-libraries/5111
|
||||||
|
|
|
||||||
|
|
@ -294,24 +294,24 @@
|
||||||
{:executor sieppari/executor})]
|
{:executor sieppari/executor})]
|
||||||
(let [respond (promise)]
|
(let [respond (promise)]
|
||||||
(app {:request-method :get, :uri "/ping"} respond ::irrelevant)
|
(app {:request-method :get, :uri "/ping"} respond ::irrelevant)
|
||||||
(is (= response @respond))))))
|
(is (= response (deref respond 100 ::timeout)))))))
|
||||||
|
|
||||||
(defrecord MyAsyncContext [])
|
(defrecord MyAsyncContext [])
|
||||||
|
|
||||||
(deftest unknown-async-test
|
(deftest unknown-async-test
|
||||||
(testing "works if registered"
|
(testing "works if registered"
|
||||||
(require '[sieppari.async.core-async])
|
|
||||||
(let [response {:status 200, :body "ok"}
|
(let [response {:status 200, :body "ok"}
|
||||||
app (http/ring-handler
|
app (http/ring-handler
|
||||||
(http/router
|
(http/router
|
||||||
["/ping" {:get {:interceptors [{:enter map->MyAsyncContext}]
|
["/ping" {:get {:interceptors [{:enter map->MyAsyncContext}]
|
||||||
:handler (fn [_] response)}}])
|
:handler (fn [_] response)}}])
|
||||||
(ring/create-default-handler)
|
(ring/create-default-handler)
|
||||||
{:executor sieppari/executor})]
|
{:executor sieppari/executor})
|
||||||
(let [raise (promise)]
|
respond (promise)
|
||||||
(app {:request-method :get, :uri "/ping"} ::irrelevant raise)
|
raise (promise)]
|
||||||
(let [response' @raise]
|
(app {:request-method :get, :uri "/ping"} respond raise)
|
||||||
(is (instance? ExceptionInfo response')))))))
|
(let [raised (deref raise 100 ::timeout)]
|
||||||
|
(is (instance? ExceptionInfo raised))))))
|
||||||
|
|
||||||
(deftest interceptor-transform-test
|
(deftest interceptor-transform-test
|
||||||
(let [interceptor (fn [name] {:name name
|
(let [interceptor (fn [name] {:name name
|
||||||
|
|
|
||||||
|
|
@ -148,7 +148,7 @@
|
||||||
500 {:description "fail"}}
|
500 {:description "fail"}}
|
||||||
:summary "plus"}
|
:summary "plus"}
|
||||||
:post {:parameters [{:in "body",
|
:post {:parameters [{:in "body",
|
||||||
:name "",
|
:name "body",
|
||||||
:description "",
|
:description "",
|
||||||
:required false,
|
:required false,
|
||||||
:schema {:type "array",
|
:schema {:type "array",
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue