on master help sign in
35 files changed+1264−625
since splitsnapshots
unifiedsplit
.gitignore+3 .gitmodules−15 .travis.yml+12−58 ChangeLog.md+60 README.md+114−28 build.sh−3 default.nix+21 deps/http-api-data−1 deps/reflex−1 deps/reflex-dom−1 deps/servant−1 deps/servant-snap−1 exec/API.hs+29−4 exec/Example.hs+69−19 nix/nix.conf+3 nix/reflex-platform.nix+7 nix/servant-snap.nix+7 nix/testresults.nix+17 nix/testserver.nix+9 overrides-ghc.nix−18 overrides.nix−14 servant-reflex.cabal+36−19 shell.nix+1 src/Servant/Common/BaseUrl.hs+8−8 src/Servant/Common/Req.hs+204−131 src/Servant/Reflex.hs+216−107 src/Servant/Reflex/Multi.hs+195−127 stack.yaml+56 testdriver/test/Servant/ReflexSpec.hs+2−1 testserver/API.hs+69−1 testserver/Main.hs+39−14 testserver/run-wd-tests.sh−5 testserver/testserver.cabal+17−16 testserver/tr.nix−32 travis.nix+70
.gitignore+3
@@ -6,3 +6,6 @@ log
66*.webapp
77*.stats
88out
9+/.stack-work/
10+TAGS
11+dist-newstyle
.gitmodules−15
@@ -1,15 +0,0 @@
1−[submodule "deps/reflex-dom"]
2− path = deps/reflex-dom
3− url = https://github.com/reflex-frp/reflex-dom.git
4−[submodule "deps/reflex"]
5− path = deps/reflex
6− url = https://github.com/reflex-frp/reflex.git
7−[submodule "deps/http-api-data"]
8− path = deps/http-api-data
9− url = https://github.com/fizruk/http-api-data
10−[submodule "deps/servant"]
11− path = deps/servant
12− url = https://github.com/haskell-servant/servant
13−[submodule "deps/servant-snap"]
14− path = deps/servant-snap
15− url = https://github.com/haskell-servant/servant-snap
.travis.yml+12−58
@@ -1,63 +1,17 @@
1−sudo: required
2−
3−before_cache:
4− - rm -fv $HOME/.cabal/packages/hackage.haskell.org/build-reports.log
5− - rm -fv $HOME/.cabal/packages/hackage.haskell.org/00-index.tar
6−
7−addons:
8− apt:
9− - phantomjs
10−
11−matrix:
12− include:
13− - env: CABALVER=1.24 GHCVER=7.10.3
14− compiler: ": #GHC 7.10.3"
15− addons: {apt: {packages: [cabal-install-1.24,ghc-7.10.3], sources: [hvr-ghc]}}
16− - env: CABALVER=1.24 GHCVER=8.0.1
17− compiler: ": #GHC 8.0.1"
18− addons: {apt: {packages: [cabal-install-1.24,ghc-8.0.1], sources: [hvr-ghc]}}
19−
20−
1+language: nix
2+nix: 2.3.6
3+sudo: require
214
225before_install:
23− - openssl aes-256-cbc -K $encrypted_3c89d919c82e_key -iv $encrypted_3c89d919c82e_iv -in deploy_key.enc -out deploy_key -d
24− - unset CC
25− - export PATH=/opt/ghc/$GHCVER/bin:/opt/cabal/$CABALVER/bin:$PATH
26− - git submodule update --init --recursive
6+ - sudo cp -rT $TRAVIS_BUILD_DIR/nix /etc/nix
277
28−install:
29− - cabal --version
30− - BENCH=${BENCH---enable-benchmarks}
31− - TEST=${TEST---enable-tests}
32− - echo "$(ghc --version) [$(ghc --print-project-git-commit-id 2> /dev/null || echo '?')]"
33− - if [ -f $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz ];
34− then
35− zcat $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz >
36− $HOME/.cabal/packages/hackage.haskell.org/00-index.tar;
37− fi
38− - travis_retry cabal update -v
39− - git clone https://github.com/reflex-frp/reflex-platform
40− - sed -i 's/^jobs:/-- jobs:/' ${HOME}/.cabal/config
41− - reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal configure && cabal build"
42− - reflex-platform/work-on ghc ./testdriver --command "cd testdriver && cabal configure && cabal build"
43− - cd testserver && dist/build/back/back -p 8000 &
44− - sleep 3
45− - phantomjs --webdriver=127.0.0.1:4444 &
46− - sleep 3
8+before_script:
9+ - sudo systemctl restart nix-daemon.service
10+ - git config --global user.email "travis-ci@example.com"
11+ - git config --global user.name "Travis-CI"
4712
4813script:
49− - git config --global user.email "travis-ci@example.com"
50− - git config --global user.name "Travis-CI"
51− - ./build.sh
52− - testdriver/dist/build/spec/spec
53−
54−cache:
55− directories:
56− - /nix
57− - $HOME/.cabal/packages
58− - $HOME/.cabal/store
59−
60−env:
61− global:
62− - ENCRYPTION_LABEL: "3c89d919c82e"
63− - COMMIT_AUTHOR_EMAIL: "imalsogreg@gmail.com"
14+ - nix-build travis.nix -A build
15+ - nix-build travis.nix -A buildGhc
16+ - nix-build travis.nix -A testserver
17+ - nix-build travis.nix -A testresults
ChangeLog.mdnew file+60
@@ -0,0 +1,60 @@
1+0.3.5
2+-----
3+
4+ - Require reflex-dom-core >= 0.6 (for internal handling of case-insensitive headers)
5+ - Require servant >= 0.16
6+ - Eliminate use of deprecated widgets from reflex-dom-core
7+ - Bump the version of reflex-platform used in nix-shell and test suite
8+
9+0.3.4
10+-----
11+
12+Add selenium-based test suite
13+
14+0.3.3
15+-----
16+
17+- Fix encoding issue: Explicitly escape reserved characters from path pieces and query parameters
18+
19+
20+0.3.2
21+-----
22+
23+- **Addition of 'Servant.Reflex.Common.Req.ClientOpts'** which
24+allows the users to apply a final adjustment to Requests before
25+thery are sent, such as setting the 'withCredentials' flag
26+or print the Request to the console for debugging
27+[PR #47](https://github.com/imalsogreg/servant-reflex/pull/47)
28+
29+0.3
30+---
31+
32+- **Addition of the 'Servant.Reflex.Multi' module** which allows the user
33+to choose some '(Applicative f, Traversable f) => f' for collecting
34+endpoint parameters. The traversable instance is used for passing
35+multiple 'XhrRequest's in response to a single event trigger. The
36+Applicative instance is used to combine parameters. For example,
37+'Capture "id" Name :> QueryParam "greeting" Text :> Get '[JSON] Text'
38+will generate a client function:
39+`Dynamic t (f Name) -> Dynamic t (f greeting) -> Event t tag ->
40+ m (Event t (f (ReqResult tag Text)))`
41+Calling that function with 'f' chosen to be list ('[]'), this call
42+`clientFun
43+(constDyn ["Greg", "Bernie"])
44+(constDyn ["Greetings", "Hey"])
45+trigger`
46+would produce four XhrRequests per 'trigger' event, one for each
47+combination of possible parameters, and one response event
48+would carry a list of the four responses.
49+A 'zip-wise' combination of the parameters can be chosen with
50+a different applicative wrapper: 'ZipList'
51+
52+- **Event tags**. A new type parameter lets users choose a payload
53+value to attach to outgoing requests at the point of triggering,
54+and which is embedded in the response, allowing individual
55+request-response pairs to be followed. The response's tag has been
56+added to each constructor `ReqResult tag a` type.
57+
58+- **Improved Unicode support** Thanks to Schell Scivally
59+(https://github.com/schell) for identifying and fixing a UTF-8
60+encoding bug!
README.md+114−28
@@ -2,16 +2,21 @@
22
33[![Build Status](https://travis-ci.org/imalsogreg/servant-reflex.svg?branch=master)](https://travis-ci.org/imalsogreg/servant-reflex)
44
5−## The problem `servant-reflex` solves
6−
7−Keeping your frontend in sync with your API server can be difficult - when the API changes its input parameters or return type, XHR requests from the frontend will fail at runtime. If your API is defined by [servant](haskell-servant.readthedocs.io) combinators, you can use `servant-reflex` to share the API between the server and frontend.
8−Syncronization between is checked at compile time, and rather than building XHR requests by hand, API endpoints are available behind `reflex`'s FRP semantics.
5+## `servant-reflex` lets you share your `servant` APIs with the frontend
96
7+Keeping your frontend in sync with your API server can be difficult - when the
8+API changes its input parameters or return type, XHR requests from the
9+frontend will fail at runtime. If your API is defined by
10+[servant](https://haskell-servant.readthedocs.io) combinators, you can use
11+`servant-reflex` to share the API between the server and frontend.
12+Syncronization between is checked at compile time, and rather than building XHR
13+requests by hand, API endpoints are available behind `reflex`'s FRP semantics.
1014
1115
1216## Example
1317
14−We have a webservice API defined in a module where both the server (compiled with ghc) and the frontend (compiled with ghcjs) can see it:
18+We have a webservice API defined in a module where both the server (compiled
19+with ghc) and the frontend (compiled with ghcjs) can see it:
1520
1621```haskell
1722type API = "getint" :> Get '[JSON] Int
@@ -24,7 +29,8 @@ type API = "getint" :> Get '[JSON] Int
2429 :<|> Raw
2530```
2631
27−`servant-reflex` then computes client functions that can query the API through an `XhrRequest`.
32+`servant-reflex` then computes client functions that can query the API through
33+an `XhrRequest`.
2834
2935```haskell
3036
@@ -33,16 +39,26 @@ type API = "getint" :> Get '[JSON] Int
3339 -- servant-reflex computes FRP functions for each API endpoint
3440 let (getint :<|> sayhi :<|> doubleit :<|> _) = client (Proxy :: Proxy API)
3541 (Proxy :: Proxy m)
42+ (Proxy :: Proxy ())
3643 (constDyn (BasePath "/"))
3744```
3845
39−These client functions are computed from your API type. They manage serialization, XhrRequest generation, and deserialization for you. `a` parameters used in URL captures become `Dynamic t (Either Text a)` parameters in the client functions. 'QueryFlag', 'QueryParams' and 'QueryParam' API parameters map to 'Dynamic t Bool', 'Dynamic t [a]' and 'Dynamic t (QParam a)' respectively. These parameters to the client function are wrapped with failure possibility to allow you to indicate at any time whether input validation for that parameter has failed and no valid XHR request can be generated. The final parameter is a trigger event for the XHR request. The return value `Event t (ReqResult a)` contains responses from the API server.
46+These client functions are computed from your API type. They manage
47+serialization, `XhrRequest` generation, and deserialization for you. `a`
48+parameters used in URL captures become `Dynamic t (Either Text a)` parameters
49+in the client functions. `QueryFlag`, `QueryParams` and `QueryParam` API
50+parameters map to `Dynamic t Bool`, `Dynamic t [a]` and `Dynamic t (QParam a)`
51+respectively. These parameters to the client function are wrapped with failure
52+possibility to allow you to indicate at any time whether input validation for
53+that parameter has failed and no valid XHR request can be generated. The final
54+parameter is a trigger event for the XHR request. The return value
55+`Event t (ReqResult a)` contains responses from the API server.
4056
4157```haskell
4258 -- No need to write these functions. servant-reflex creates them for you!
4359 getint :: MonadWidget t m
4460 => Event t () -- ^ Trigger the XHR Request
45− -> m (Event t (ReqResult Int)) -- ^ Consume the answer
61+ -> m (Event t (ReqResult () Int)) -- ^ Consume the answer
4662
4763 sayhi :: MonadWidget t m
4864 => Dynamic t (QParam Text)
@@ -53,15 +69,21 @@ These client functions are computed from your API type. They manage serializatio
5369 -- ^ Flag for capitalizing the response
5470 -> Event t ()
5571 -- ^ Trigger the XHR Request
56− -> m (Event t (ReqResult Text))
72+ -> m (Event t (ReqResult () Text))
5773
5874 doubleit :: MonadWidget t m
5975 => Dynamic t (Either Text Double)
6076 -> Event t ()
61− -> m (Event t (ReqResult Double))
77+ -> m (Event t (ReqResult () Double))
6278```
6379
64−`ReqResult a` is defined in [`Servant.Common.Req`](https://github.com/imalsogreg/servant-reflex/blob/6d866e338edb9bf6fd8f8d5083ff0187b4d8c0d2/src/Servant/Common/Req.hs#L40-L42) and reports whether or not your request was sent (if validation fails, the request won't be sent), and how decoding of the response went. You can pattern match on these explicitly, but usually you'll want to use `fmapMaybe :: (a -> Maybe b) -> Event t a -> Event t b` and one of the elimination functions to filter the result type you care about, like this:
80+`ReqResult tag a` is defined in
81+[`Servant.Common.Req`](https://github.com/imalsogreg/servant-reflex/blob/6d866e338edb9bf6fd8f8d5083ff0187b4d8c0d2/src/Servant/Common/Req.hs#L40-L42)
82+and reports whether or not your request was sent (if validation fails, the
83+request won't be sent), and how decoding of the response went. You can pattern
84+match on these explicitly, but usually you'll want to use
85+`fmapMaybe :: (a -> Maybe b) -> Event t a -> Event t b` and one of the
86+elimination functions to filter the result type you care about, like this:
6587
6688```haskell
6789 -- ... continued ...
@@ -79,7 +101,8 @@ These client functions are computed from your API type. They manage serializatio
79101 dynText =<< holdDyn "" (leftmost [errs, const "" <$> ys])
80102```
81103
82−This example builds some input fields to enter API parameters, buttons to trigger the API calls, and text elements to show the results:
104+This example builds some input fields to enter API parameters, buttons to
105+trigger the API calls, and text elements to show the results:
83106
84107```haskell
85108 elClass "div" "int-demo" $ do
@@ -102,37 +125,100 @@ This example builds some input fields to enter API parameters, buttons to trigge
102125 display =<< holdDyn Nothing outputDouble
103126```
104127
105−For a great introduction to recative DOM building, see the [README](https://github.com/reflex-frp/reflex-platform) for the `reflex-platform`. For more information about servant, see their [documentation](http://haskell-servant.readthedocs.io/en/stable/). Thanks to the respective authors of these fabulous libraries.
128+For a great introduction to recative DOM building, see the
129+[README](https://github.com/reflex-frp/reflex-platform) for the
130+`reflex-platform`. For more information about servant, see their
131+[documentation](http://haskell-servant.readthedocs.io/en/stable/). Thanks to
132+the respective authors of these fabulous libraries.
106133
107134
108135## Building the library and test server
109136
110−This repository comes with a small example of an API shared between a ghcjs-compiled frontend ([exec/](https://github.com/imalsogreg/servant-reflex/tree/master/exec)) and a ghc-compiled backend ([testserver/](https://github.com/imalsogreg/servant-reflex/tree/master/testserver). To build these components:
111−
112−
113−First build the library:
137+This repository comes with a small example of an API shared between a
138+ghcjs-compiled frontend
139+([exec/](https://github.com/imalsogreg/servant-reflex/tree/master/exec)) and a
140+ghc-compiled backend
141+([testserver/](https://github.com/imalsogreg/servant-reflex/tree/master/testserver).
142+To build these components, we will use the nix packages for the testserver. It
143+manages the frontend build as a dependency.
114144
115145```
116−git submodule update --init --recursive
117−./build.sh
146+nix build -f travis.nix testserver -o server
118147```
119148
120−Then build the test server:
149+Point it at the static directory and run it:
121150
122151```
123−deps/reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal build"
152+STATIC_DIR=server/static server/back -p 8000
124153```
125154
155+Browse to [http://localhost:8000](http://localhost:8000) and click around.
156+Open the firefox or chrome developer tools and examine the XHR activity
157+under the Network tab.
126158
127−## Running the example site
159+**For a larger example of a project that shares types between backend and
160+frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
128161
129−The server must be run from the directory where static assets live:
130162
163+## Tagging requests
164+
165+The input and the return type of a client function like `getDouble` are both
166+event streams. The individual input events and responses occur at different
167+times and aren't automatically paired up, but you can recover the
168+relationship by tagging the requests.
169+
170+So far we have used an `Event t ()` to trigger sending a request. If we choose
171+e.g. `Double` for the third `Proxy` argument to `client`, then `Event t Double`
172+will be used to trigger requests, and each `ReqResult` will carry the tag of
173+its request. Imagine we wanted to display not just the last "double" from
174+`doubleIt`, but a whole table of valid inputs and their doubled responses:
175+
176+```haskell
177+ ...
178+ inp <- textInput def
179+
180+ -- Convert the raw text into an `Either Text Double`
181+ let inpNum = maybe (Left "No Parse") Right . readMaybe . T.unpack <$> value inp
182+ go <- button "Double It"
183+
184+ -- Call 'doubleIt' with triggers that coincide with good input parses
185+ rs <- doubleIt inpNum (fforMaybe (tagPromptlyDyn inpNum go) $ \case
186+ Left _ -> Nothing
187+ Right a -> Just a
188+ )
189+
190+ -- Accumulate good responses in a map
191+ doubleTable <- foldDyn (<>) mempty $ ffor rs $ \case
192+ ResponseSuccess tag v _ -> tag =: v
193+ _ -> mempty
194+
195+ el "table" $ do
196+ listWithKey doubleTable $ \k dv -> el "tr" $ do
197+ el "td" $ text (T.pack $ show k)
198+ el "td" $ dynText (T.pack . show <$> dv)
199+ ...
131200```
132−cd testserver
133−dist/build/back/back -p 8001
134−```
135201
136−And simply browse to `localhost:8001`
202+## Simultaneous requests
203+
204+`Servant.Reflex.Multi` provides an alternative client-generation function
205+called `clientA` (client applicative). Choose a container type that has both
206+`Applicative` and `Traversable` instances, and pass it to `clientA` through
207+another `Proxy`. Our `sayHi` client function will then have this type:
208+
209+```haskell
210+sayHi
211+ :: Dynamic t (f (QParam Text))
212+ -> Dynamic t (f [Text])
213+ -> Dynamic t (f Bool)
214+ -> Event t tag
215+ -> m (Event t (f (ReqResult tag Text)))
216+```
137217
138−**For a larger example of a project that shares types between backend and frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
218+The dynamic params are each wrapped in `f`. For every firing of the trigger
219+event `tag`, all of these parameters will be combined according to `f`'s
220+`Applicative` instance (when `f` is `[]`, you will get all combinations of
221+all parameters taken together as a request; when `f` is `ZipList`, the Nth
222+elemens of each parameters list will be taken together as a request). Using
223+this interface, you can trigger many XHR's from a single event occurence, and
224+expect the responses to be structured the same way as the requests.
build.shdeleted−3
@@ -1,3 +0,0 @@
1−#!/usr/bin/env bash
2−
3−reflex-platform/work-on ./overrides.nix ./. --run "cabal configure --ghcjs && cabal build && exec/toSite.sh"
default.nixnew file+21
@@ -0,0 +1,21 @@
1+{ mkDerivation, base, bytestring, case-insensitive, containers
2+, data-default, exceptions, ghcjs-dom, http-api-data, http-media
3+, jsaddle, mtl, network-uri, reflex, reflex-dom, reflex-dom-core
4+, safe, servant, servant-auth, stdenv, string-conversions, text
5+, transformers
6+}:
7+mkDerivation {
8+ pname = "servant-reflex";
9+ version = "0.3.6";
10+ src = ./.;
11+ isLibrary = true;
12+ isExecutable = true;
13+ libraryHaskellDepends = [
14+ base bytestring case-insensitive containers data-default exceptions
15+ ghcjs-dom http-api-data http-media jsaddle mtl network-uri reflex
16+ reflex-dom reflex-dom-core safe servant servant-auth string-conversions
17+ text transformers
18+ ];
19+ description = "servant API generator for reflex apps";
20+ license = stdenv.lib.licenses.bsd3;
21+}
deps/http-api-datadeleted−1

Submodule changed.

deps/reflexdeleted−1

Submodule changed.

deps/reflex-domdeleted−1

Submodule changed.

deps/servantdeleted−1

Submodule changed.

deps/servant-snapdeleted−1

Submodule changed.

exec/API.hs+29−4
@@ -1,10 +1,32 @@
1−{-# LANGUAGE DataKinds #-}
2−{-# LANGUAGE TypeOperators #-}
1+{-# LANGUAGE DataKinds #-}
2+{-# LANGUAGE OverloadedStrings #-}
3+{-# LANGUAGE TypeOperators #-}
34
45module API where
56
6−import Data.Text (Text)
7−import Servant.API
7+import Data.Aeson
8+import Data.Aeson.Types (typeMismatch)
9+import Data.Text (Text)
10+import Servant.API
11+
12+newtype Question = Question { unQuestion :: Text } deriving (Show)
13+
14+instance ToJSON Question where
15+ toJSON (Question txt) = object ["question" .= txt]
16+
17+instance FromJSON Question where
18+ parseJSON (Object v) = Question <$> v .: "question"
19+ parseJSON x = typeMismatch "Couldn't find key 'question'" x
20+
21+newtype Answer = Answer { unAnswer :: Text } deriving (Show)
22+
23+instance ToJSON Answer where
24+ toJSON (Answer txt) = object ["answer" .= txt]
25+
26+instance FromJSON Answer where
27+ parseJSON (Object v) = Answer <$> v .: "answer"
28+ parseJSON x = typeMismatch "Couldn't find key 'answer'" x
29+
830
931-- | API spec for server, client, and docs
1032type API = "getunit" :> Get '[JSON] ()
@@ -16,6 +38,9 @@ type API = "getunit" :> Get '[JSON] ()
1638 :<|> "double" :> ReqBody '[JSON] Double
1739 :> Post '[JSON] Double
1840 :<|> "a" :> "b" :> QueryFlag "gusto" :> Get '[JSON] Text
41+ :<|> "qna" :> ReqBody '[JSON] Question
42+ :> Post '[JSON] Answer
43+ :<|> "secret" :> BasicAuth "realm" () :> Get '[JSON] Int
1944 :<|> Raw
2045
2146type GET = Get '[JSON] ()
exec/Example.hs+69−19
@@ -1,3 +1,4 @@
1+{-# LANGUAGE DataKinds #-}
12{-# LANGUAGE FlexibleContexts #-}
23{-# LANGUAGE GADTs #-}
34{-# LANGUAGE OverloadedStrings #-}
@@ -14,11 +15,14 @@ import Control.Monad.Fix (MonadFix)
1415import Data.Monoid (First(..), (<>))
1516import Data.Text (Text)
1617import qualified Data.Text as T
18+import qualified Data.Text.Encoding as T
19+import GHC.TypeLits
1720import Servant.API
1821import API
1922import Data.Proxy
2023import Text.Read (readMaybe)
21−import Reflex.Dom
24+import Reflex.Dom.Core hiding (run, mainWidget)
25+import Reflex.Dom (mainWidget)
2226------------------------------------------------------------------------------
2327import Servant.Reflex
2428import Servant.Reflex.Multi
@@ -42,18 +46,36 @@ runMulti :: forall t m. (SupportsServantReflex t m,
4246runMulti = do
4347 url <- baseUrlWidget
4448 el "br" blank
45− let (_ :<|> _ :<|> _ :<|> dbl :<|> _ :<|> _ ) =
49+ let (_ :<|> _ :<|> sayHi :<|> dbl :<|> _ :<|> _ :<|> _ :<|> _ ) =
4650 clientA api (Proxy :: Proxy m) (Proxy :: Proxy []) (Proxy :: Proxy Int) url
51+
4752 num :: Dynamic t (Either Text Double) <- fmap (note "No read" . readMaybe . T.unpack) . value <$> textInput def
4853 num2 :: Dynamic t (Either Text Double) <- fmap (note "No read" . readMaybe . T.unpack) . value <$> textInput def
49− -- dynText =<< holdDyn "waiting" (T.pack . show <$> num)
50− -- numLabeled :: Event t (First Int, Double) <- zipListWithEvent (,) (First . Just <$> [0..]) num
54+
5155 b <- button "Run dbl multi"
52− reqCount <- count b
53− r <- dbl [num,num2] (tag (current reqCount) b)
54− dynText =<< holdDyn "Waiting" (T.pack . show . fmapMaybe reqSuccess .snd <$> r)
55− lastInd <- holdDyn Nothing (Just . fst <$> r)
56+ reqCount :: Dynamic t Int <- count b
57+ r <- dbl ((\x y -> [x,y]) <$> num <*> num2) (tag (current reqCount) b)
58+ dynText =<< holdDyn "Waiting" (T.pack . show . fmap reqSuccess <$> r)
59+
60+ lastInd <- holdDyn [] $ fmap reqTag <$> r
5661 display lastInd
62+
63+ divClass "demo-group" $ do
64+ nms <- fmap (fmap T.words . value) $ divClass "" $ do
65+ text "Names"
66+ textInput def
67+ grts <- fmap (fmap T.words . value) $ divClass "" $ do
68+ text "Greetings"
69+ textInput def
70+ gust <- fmap (value) $ divClass "gusto-input" $ checkbox False def
71+ b <- button "Go"
72+ r' <- sayHi (fmap QParamSome <$> nms) (fmap (:[]) $ grts)
73+ (constDyn [True, False]) (1 <$ b)
74+
75+ dynText =<< holdDyn "Waiting" (T.pack . show . catMaybes .
76+ fmap reqSuccess <$> r')
77+
78+
5779 return ()
5880
5981run :: forall t m. (SupportsServantReflex t m,
@@ -75,21 +97,26 @@ run = mdo
7597 el "br" (return ())
7698
7799 -- Name the computed API client functions
78− let (getUnit :<|> getInt :<|> sayhi :<|> dbl :<|> multi :<|> doRaw) =
79− client api (Proxy :: Proxy m) (Proxy :: Proxy Int) url
100+ let tweakRequest = ClientOptions $ \r -> do
101+ return $ r & withCredentials .~ True
102+ let (getUnit :<|> getInt :<|> sayhi :<|> dbl
103+ :<|> multi :<|> qna :<|> secret :<|> doRaw) =
104+ clientWithOpts api (Proxy :: Proxy m) (Proxy :: Proxy Int) url tweakRequest
105+
106+ c2 = client (Proxy :: Proxy ComprehensiveAPI) (Proxy :: Proxy m) (Proxy :: Proxy ()) url -- Just make sure this compiles for now
80107
81108 (unitBtn, intBtn) <- elClass "div" "demo-group" $ do
82109 unitBtn <- divClass "unit-button" $ button "Get unit"
83110 intBtn <- divClass "int-button" $ button "Get int"
84111
85112 unitResponse <- getUnit $ tag (current reqCount) unitBtn
86− intResponse :: Event t (Int, ReqResult Int) <- getInt $ tag (current reqCount) intBtn
113+ intResponse :: Event t (ReqResult Int Int) <- getInt $ tag (current reqCount) intBtn
87114
88− score <- foldDyn (+) 0 (fmapMaybe reqSuccess (snd <$> intResponse))
115+ score <- foldDyn (+) 0 (fmapMaybe reqSuccess (intResponse))
89116
90117 r <- holdDyn "Waiting" $ fmap showXhrResponse $
91− leftmost [fmapMaybe response (snd <$> unitResponse)
92− ,fmapMaybe response (snd <$> intResponse)
118+ leftmost [fmapMaybe response (unitResponse)
119+ ,fmapMaybe response (intResponse)
93120 ]
94121 divClass "unit-int-response" $ el "p" $ dynText r >> el "br" (return ()) >> text "Total: " >> display score
95122 return (unitBtn, intBtn)
@@ -117,8 +144,8 @@ run = mdo
117144
118145 resp <- sayhi checkedName greetings gusto (tag (current reqCount) triggers)
119146 divClass "greeting-response" $ dynText =<<
120− holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (snd <$> resp)
121− , fmapMaybe reqFailure (snd <$> resp)])
147+ holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (resp)
148+ , fmapMaybe reqFailure (resp)])
122149 return sayHiClicks
123150
124151 dblBtn <- elClass "div" "demo-group" $ do
@@ -129,11 +156,11 @@ run = mdo
129156 dblResp <- dbl (fmap (note "read failure" . readMaybe . T.unpack) $
130157 dblinp) (tag (current reqCount) dblBtn)
131158 divClass "double-errors" $ dynText =<<
132− holdDyn "(no errors)" (fmapMaybe reqFailure (snd <$> dblResp))
159+ holdDyn "(no errors)" (fmapMaybe reqFailure (dblResp))
133160 el "br" (return ())
134161 divClass "double-result" $ el "p" $ dynText =<<
135162 holdDyn "No number yet" (fmap tShow $
136− fmapMaybe reqSuccess (snd <$> dblResp))
163+ fmapMaybe reqSuccess (dblResp))
137164 return dblBtn
138165
139166 mpGo <- elClass "div" "demo-group" $ do
@@ -143,11 +170,34 @@ run = mdo
143170 multiResp <- multi b (tag (current reqCount) mpGo)
144171 dynText =<< holdDyn "No res yet" (fmap tShow $
145172 fmapMaybe reqSuccess $
146− (snd <$> multiResp))
173+ (multiResp))
147174 return mpGo
148175
149176 return ()
150177
178+ el "br" $ return ()
179+
180+ elClass "div" "demo-group" $ do
181+ text "JSON Unicode encoding test"
182+ txt <- value <$> textInput def
183+ ev <- fmap (1 <$) $ button "Question"
184+ let dQ = Right . Question <$> traceDyn "will send: " txt
185+ rr <- qna dQ ev
186+ el "p" $
187+ dynText =<< holdDyn "No Answer" (unAnswer <$> fmapMaybe reqSuccess rr)
188+
189+ divClass "demo-group" $ do
190+ un <- fmap value $ text "Username" >> textArea def
191+ pw <- fmap value $ text "Unhidden PW" >> textArea def
192+ let ba :: Dynamic t (BasicAuthData ) = BasicAuthData
193+ <$> fmap T.encodeUtf8 un
194+ <*> fmap T.encodeUtf8 pw
195+ b <- button "Get secret"
196+ r <- secret (Just <$> ba) (0 <$ b)
197+ res <- holdDyn Nothing (reqSuccess <$> r)
198+ display res
199+
200+
151201showXhrResponse :: XhrResponse -> Text
152202showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
153203 T.unlines ["stat: " <> tShow stat
nix/nix.confnew file+3
@@ -0,0 +1,3 @@
1+substituters = https://cache.nixos.org/ https://nixcache.reflex-frp.org/
2+trusted-public-keys = cache.nixos.org-1:6NCHdD59X431o0gWypbMrAURkbJ16ZPMQFGspcDShjY= ryantrinkle.com-1:JJiAKaRv9mWgpVAz8dwewnZe0AzzEAzPkagE9SP5NWI=
3+trusted-users = travis
nix/reflex-platform.nixnew file+7
@@ -0,0 +1,7 @@
1+let
2+ rev = "1aba6f367982bd6dd78ec2fda75ab246a62d32c5" ;
3+in import (builtins.fetchTarball
4+ {
5+ url = "https://github.com/reflex-frp/reflex-platform/archive/${rev}.tar.gz";
6+ sha256 = "137vg6i8yy4lp6rz4wbvvhfcc9d9qf7j1b3fnng3r7sj63k7j664" ;
7+ }) {}
nix/servant-snap.nixnew file+7
@@ -0,0 +1,7 @@
1+# Servant-snap is marked broken in nixpkgs
2+{ nixpkgs ? import <nixpkgs> {}}: self: super:
3+self.callCabal2nix "servant-snap" (nixpkgs.fetchgit {
4+ url = "https://github.com/haskell-servant/servant-snap.git";
5+ rev = "af5172a6de5bb2a07eb1bf4c85952075ec6ecdf3";
6+ sha256 = "sha256-fzzQGwG8Ko72OO/kwLMG52eNZSt3F2dxhNgM9gaO4yQ=";
7+}) {}
nix/testresults.nixnew file+17
@@ -0,0 +1,17 @@
1+{ curl, reflexPlatform, testdriver, testserver, phantomjs }:
2+
3+reflexPlatform.nixpkgs.pkgs.runCommand "runWebdriveTest.sh" {} ''
4+ echo About to phantom
5+ ${phantomjs}/bin/phantomjs --webdriver=127.0.0.1:4444 &
6+ sleep 3
7+ echo About to Server
8+ STATIC_DIR=${testserver}/static ${testserver}/back -q --no-access-log --no-error-log -p 8000 &
9+ sleep 3
10+ ${curl}/bin/curl localhost:8000
11+ ${curl}/bin/curl localhost:8000/runmain.js
12+ echo About to testdrive
13+ ${testdriver}/bin/spec > $out 2>&1
14+ echo Done
15+ trap "exit" INT TERM
16+ trap "kill 0" EXIT
17+ ''
nix/testserver.nixnew file+9
@@ -0,0 +1,9 @@
1+servant-reflex: self: super:
2+
3+(self.callCabal2nix "testserver" ../testserver {}).overrideDerivation (drv: {
4+ postInstall = ''
5+ cp dist/build/back/back $out/back
6+ mkdir $out/static
7+ cp ${servant-reflex}/bin/example.jsexe/* $out/static/
8+ '';
9+})
overrides-ghc.nixdeleted−18
@@ -1,18 +0,0 @@
1−{ reflex-platform, ... }:
2−let
3− pkgs = import <nixpkgs> {};
4− c2n = reflex-platform.cabal2nixResult;
5−in reflex-platform.ghc.override {
6− overrides = self: super: {
7− servant-snap = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap) {});
8− snap = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap) {});
9− snap-server = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/snap-server) {});
10− io-streams = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/io-streams) {});
11− io-streams-haproxy = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/io-streams-haproxy) {});
12− heist = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/heist) {});
13− xmlhtml = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/xmlhtml) {});
14− snap-core = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/snap-core) {});
15− servant = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant/servant) {});
16− http-api-data = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/http-api-data) {});
17− };
18−}
overrides.nixdeleted−14
@@ -1,14 +0,0 @@
1−{ reflex-platform, ... }:
2−let
3−
4− nixpkgs = (import <nixpkgs> {});
5− dontCheck = nixpkgs.pkgs.haskell.lib.dontCheck;
6− cabal2nixResult = reflex-platform.cabal2nixResult;
7−
8−in
9−reflex-platform.ghcjs.override {
10− overrides = self: super: {
11− servant = dontCheck (self.callPackage (cabal2nixResult deps/servant/servant) {});
12− http-api-data = dontCheck (self.callPackage (cabal2nixResult deps/http-api-data) {});
13− };
14−}
servant-reflex.cabal+36−19
@@ -1,8 +1,8 @@
11Name: servant-reflex
2−Version: 0.3
3−Synopsis: Servant reflex API generator
4−Description: Servant reflex API generator
5−License: AllRightsReserved
2+Version: 0.3.6
3+Synopsis: servant API generator for reflex apps
4+Description: Generate reflex-compatible client functions from servant API descriptions
5+License: BSD3
66License-file: LICENSE.md
77Author: Greg Hale, Doug Beardsley
88Maintainer: imalsogreg@gmail.com
@@ -11,42 +11,59 @@ Category: Web
1111Build-type: Simple
1212Cabal-version: >=1.10
1313
14+Flag Example
15+ description: Enable example
16+ default: False
17+
1418library
1519 exposed-modules:
16− Servant.Reflex
17− Servant.Reflex.Multi
18−
19− other-modules:
2020 Servant.Common.BaseUrl
2121 Servant.Common.Req
22+ Servant.Reflex
23+ Servant.Reflex.Multi
2224
2325 hs-source-dirs: src
2426 build-depends:
25− base >= 4.8 && < 4.10,
27+ base >= 4.8 && < 5,
2628 bytestring >= 0.10 && < 0.11,
2729 case-insensitive >= 1.2.0.4 && < 1.3,
28− containers >= 0.5.6 && < 0.6,
30+ containers >= 0.5.6 && < 0.7,
2931 data-default >= 0.5 && < 0.8,
30− exceptions >= 0.8 && < 0.9,
31− ghcjs-dom >= 0.2 && < 0.3,
32− http-api-data >= 0.2 && < 0.4,
33− http-media >= 0.6 && < 0.7,
32+ exceptions >= 0.8 && < 0.11,
33+ ghcjs-dom >= 0.2 && < 0.10,
34+ http-api-data >= 0.3.6 && < 0.5,
35+ http-media >= 0.6 && < 0.9,
36+ jsaddle >= 0.8 && < 0.10,
3437 mtl >= 2.2.1 && < 2.3,
3538 network-uri >= 2.6 && < 2.7,
36− reflex >= 0.5 && < 0.6,
37− reflex-dom == 0.4 && < 0.5,
39+ reflex >= 0.5 && < 0.9,
40+ reflex-dom-core >= 0.6 && < 0.7,
3841 safe >= 0.3.9 && < 0.4,
39− servant >= 0.5 && < 0.9,
42+ servant >= 0.16 && < 0.18,
43+ servant-auth >= 0.2.1 && < 0.4,
4044 string-conversions >= 0.4 && < 0.5,
4145 text >= 1.2 && < 1.3,
4246 transformers >= 0.4 && < 0.6
4347
44− ghc-options: -Wall -fwarn-tabs -funbox-strict-fields -O2
48+ ghc-options: -Wall -fwarn-tabs -funbox-strict-fields
4549
4650 default-language: Haskell2010
4751
4852executable example
49− build-depends: reflex, servant-reflex, base, scientific, servant, reflex-dom, text
53+ if flag(Example)
54+ buildable: True
55+ else
56+ buildable: False
57+ build-depends:
58+ aeson,
59+ reflex,
60+ servant-reflex,
61+ base,
62+ scientific,
63+ servant,
64+ reflex-dom,
65+ reflex-dom-core,
66+ text
5067 default-language: Haskell2010
5168 main-is: Example.hs
5269 other-modules: API
shell.nixnew file+1
@@ -0,0 +1 @@
1+(import ./travis.nix {nativeCompiler = "ghc";}).ghcPkgs.servant-reflex.env
src/Servant/Common/BaseUrl.hs+8−8
@@ -20,18 +20,19 @@ module Servant.Common.BaseUrl (
2020) where
2121
2222import Control.Monad (join)
23−import Control.Monad.IO.Class (MonadIO)
23+-- import Control.Monad.IO.Class (MonadIO)
2424import Control.Monad.Fix (MonadFix)
2525import Data.Monoid ((<>))
2626import Data.Text (Text)
2727import qualified Data.Text as T
2828import GHC.Generics
29+import Language.Javascript.JSaddle.Monad (MonadJSM)
2930import Reflex
30−import Reflex.Dom
31+import Reflex.Dom.Core
3132import Text.Read
3233
3334
34−type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadIO (Performable m))
35+type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadJSM (Performable m))
3536
3637-- | URI scheme to use
3738data Scheme =
@@ -84,15 +85,14 @@ baseUrlWidget = elClass "div" "base-url" $ do
8485 where pathWidget :: m (Dynamic t BaseUrl)
8586 pathWidget = do
8687 text "Url base path"
87− t <- textInput (def {_textInputConfig_attributes =
88− constDyn ("placeholder" =: "/a/b")})
88+ t <- inputElement def
8989 return $ BasePath <$> value t
9090 fullUrlWidget :: m (Dynamic t BaseUrl)
9191 fullUrlWidget = do
9292 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
93− srv <- textInput def {_textInputConfig_attributes = constDyn $ "placeholder" =: "example.com"}
93+ srv <- inputElement def
9494 text ":"
95− prt <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "80"}
95+ prt <- inputElement def
9696 port :: Dynamic t Int <- holdDyn 80 (fmapMaybe (readMaybe . T.unpack) $ updated (value prt))
97− path <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "a/b" }
97+ path <- inputElement def
9898 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
src/Servant/Common/Req.hs+204−131
@@ -1,63 +1,119 @@
1−{-# LANGUAGE AllowAmbiguousTypes #-}
2−{-# LANGUAGE DeriveDataTypeable #-}
31{-# LANGUAGE CPP #-}
2+{-# LANGUAGE DeriveFunctor #-}
43{-# LANGUAGE FlexibleContexts #-}
54{-# LANGUAGE GADTs #-}
65{-# LANGUAGE OverloadedStrings #-}
76{-# LANGUAGE LambdaCase #-}
7+{-# LANGUAGE RankNTypes #-}
88{-# LANGUAGE ScopedTypeVariables #-}
99{-# LANGUAGE TupleSections #-}
1010
11−{-# LANGUAGE EmptyCase #-}
1211module Servant.Common.Req where
1312
1413-------------------------------------------------------------------------------
15−import Control.Concurrent
1614import Control.Applicative (liftA2, liftA3)
17−import Control.Arrow (second)
15+import Control.Arrow ((&&&))
16+import Control.Concurrent
17+import Control.Monad (join)
1818import Control.Monad.IO.Class (MonadIO, liftIO)
19+import Data.Bifunctor (first)
20+import qualified Data.ByteString.Builder as Builder
1921import qualified Data.ByteString.Lazy.Char8 as BL
22+import Data.ByteString (ByteString)
2023import qualified Data.Map as Map
21−import Data.Maybe (catMaybes)
24+import Data.Maybe (catMaybes, fromMaybe)
2225import Data.Functor.Compose
2326import Data.Monoid ((<>))
2427import Data.Proxy (Proxy(..))
2528import Data.Text (Text)
2629import qualified Data.Text as T
2730import qualified Data.Text.Encoding as TE
28−import Data.Traversable
29−import Reflex.Dom
30−import Servant.Common.BaseUrl (BaseUrl, showBaseUrl, SupportsServantReflex)
31+import Data.Traversable (forM)
32+import Language.Javascript.JSaddle.Monad (JSM, MonadJSM, liftJSM)
33+import qualified Network.URI as N
34+import Reflex.Dom.Core hiding (tag)
35+import Servant.Common.BaseUrl (BaseUrl, showBaseUrl,
36+ SupportsServantReflex)
3137import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
3238import Web.HttpApiData (ToHttpApiData(..))
3339-------------------------------------------------------------------------------
3440import Servant.API.BasicAuth
3541
3642
43+------------------------------------------------------------------------------
44+-- | The result of a request event
45+data ReqResult tag a
46+ = ResponseSuccess tag a XhrResponse
47+ -- ^ The succesfully decoded response from a request tagged with 'tag'
48+ | ResponseFailure tag Text XhrResponse
49+ -- ^ The failure response, which may have failed decoding or had
50+ -- a non-successful response code
51+ | RequestFailure tag Text
52+ -- ^ A failure to construct the request tagged with 'tag' at trigger time
53+ deriving (Functor)
54+
55+data ClientOptions = ClientOptions
56+ { optsRequestFixup :: forall a. Show a => XhrRequest a -> JSM (XhrRequest a)
57+ -- ^ Aribtrarily modify requests just before they are sent.
58+ -- Warning: This escape hatch opens the possibility for your
59+ -- requests to diverge from what the server expects, when the
60+ -- server is also derived from a servant API
61+ }
62+
63+defaultClientOptions :: ClientOptions
64+defaultClientOptions = ClientOptions { optsRequestFixup = return }
65+
66+-- withCredentials :: Lens' (XhrRequest a) Bool
67+withCredentials :: (Show a, Functor f) => (Bool -> f Bool) -> XhrRequest a -> f (XhrRequest a)
68+withCredentials inj r@(XhrRequest _ _ cfg) =
69+ let cfg' = (\b -> cfg { _xhrRequestConfig_withCredentials = b}) <$>
70+ inj (_xhrRequestConfig_withCredentials cfg)
71+ in (\c' -> r {_xhrRequest_config = c' }) <$> cfg'
3772
38−data ReqResult a = ResponseSuccess a XhrResponse
39− | ResponseFailure Text XhrResponse
40− | RequestFailure Text
73+------------------------------------------------------------------------------
74+-- | Simple filter/accessor for successful responses, when you want to
75+-- ignore the error case. For example:
76+-- >> goodResponses <- fmapMaybe reqSuccess <$> clientFun triggers
77+reqSuccess :: ReqResult tag a -> Maybe a
78+reqSuccess (ResponseSuccess _ x _) = Just x
79+reqSuccess _ = Nothing
4180
42−instance Functor ReqResult where
43− fmap f (ResponseSuccess a xhr) = ResponseSuccess (f a) xhr
44− fmap _ (ResponseFailure r x) = ResponseFailure r x
45− fmap _ (RequestFailure r) = RequestFailure r
4681
47−reqSuccess :: ReqResult a -> Maybe a
48−reqSuccess (ResponseSuccess x _) = Just x
49−reqSuccess _ = Nothing
82+------------------------------------------------------------------------------
83+-- | Simple filter/accessor like 'reqSuccess', but keeping the request tag
84+reqSuccess' :: ReqResult tag a -> Maybe (tag,a)
85+reqSuccess' (ResponseSuccess tag x _) = Just (tag,x)
86+reqSuccess' _ = Nothing
5087
51−reqFailure :: ReqResult a -> Maybe Text
52−reqFailure (ResponseFailure s _) = Just s
53−reqFailure (RequestFailure s) = Just s
54−reqFailure _ = Nothing
5588
56−response :: ReqResult a -> Maybe XhrResponse
57−response (ResponseSuccess _ x) = Just x
58−response (ResponseFailure _ x) = Just x
59−response _ = Nothing
89+------------------------------------------------------------------------------
90+-- | Simple filter/accessor for any failure case
91+reqFailure :: ReqResult tag a -> Maybe Text
92+reqFailure (ResponseFailure _ s _) = Just s
93+reqFailure (RequestFailure _ s) = Just s
94+reqFailure _ = Nothing
95+
96+------------------------------------------------------------------------------
97+-- | Simple filter/accessor like 'reqFailure', but keeping the request tag
98+reqFailure' :: ReqResult tag a -> Maybe (tag,Text)
99+reqFailure' (ResponseFailure tag s _) = Just (tag,s)
100+reqFailure' (RequestFailure tag s) = Just (tag,s)
101+reqFailure' _ = Nothing
102+
103+
104+------------------------------------------------------------------------------
105+-- | Simple filter/accessor for the raw XHR response
106+response :: ReqResult tag a -> Maybe XhrResponse
107+response (ResponseSuccess _ _ x) = Just x
108+response (ResponseFailure _ _ x) = Just x
109+response _ = Nothing
60110
111+------------------------------------------------------------------------------
112+-- | Retrieve response tag
113+reqTag :: ReqResult tag a -> tag
114+reqTag (ResponseSuccess tag _ _) = tag
115+reqTag (ResponseFailure tag _ _) = tag
116+reqTag (RequestFailure tag _ ) = tag
61117
62118-------------------------------------------------------------------------------
63119-- | You must wrap the parameter of a QueryParam endpoint with 'QParam' to
@@ -70,11 +126,13 @@ data QParam a = QParamSome a
70126 | QParamInvalid Text
71127 -- ^ Indication that your validation failed (the request isn't valid)
72128
129+
73130qParamToQueryPart :: ToHttpApiData a => QParam a -> Either Text (Maybe Text)
74131qParamToQueryPart (QParamSome a) = Right (Just $ toQueryParam a)
75132qParamToQueryPart QNone = Right Nothing
76133qParamToQueryPart (QParamInvalid e) = Left e
77134
135+
78136data QueryPart t = QueryPartParam (Dynamic t (Either Text (Maybe Text)))
79137 | QueryPartParams (Dynamic t [Text])
80138 | QueryPartFlag (Dynamic t Bool)
@@ -107,10 +165,10 @@ addHeader name val req = req { headers = (name, (fmap . fmap) (TE.decodeUtf8 . t
107165reqToReflexRequest
108166 :: forall t. Reflex t
109167 => Text
110− -> Req t
111168 -> Dynamic t BaseUrl
112− -> (Dynamic t (Either Text (XhrRequest XhrPayload)))
113−reqToReflexRequest reqMeth req reqHost =
169+ -> Req t
170+ -> Dynamic t (Either Text (XhrRequest XhrPayload))
171+reqToReflexRequest reqMeth reqHost req =
114172 let t :: Dynamic t [Either Text Text]
115173 t = sequence $ reverse $ reqPathParts req
116174
@@ -121,18 +179,22 @@ reqToReflexRequest reqMeth req reqHost =
121179 urlParts = fmap sequence t
122180
123181 urlPath :: Dynamic t (Either Text Text)
124− urlPath = (fmap.fmap) (T.intercalate "/") urlParts
182+ urlPath = (fmap.fmap)
183+ (T.intercalate "/" . fmap escape)
184+ urlParts
125185
126186 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
127187 queryPartString (pName, qp) = case qp of
128188 QueryPartParam p -> ffor p $ \case
129189 Left e -> Just (Left e)
130− Right (Just a) -> Just (Right $ pName <> "=" <> a)
190+ Right (Just a) -> Just (Right $ pName <> "=" <> escape a)
131191 Right Nothing -> Nothing
132192 QueryPartParams ps -> ffor ps $ \pStrings ->
133193 if null pStrings
134194 then Nothing
135− else Just $ Right (T.intercalate "&" (fmap (\p -> pName <> "=" <> p) pStrings))
195+ else Just . Right
196+ . T.intercalate "&"
197+ $ fmap (\p -> pName <> "=" <> escape p) pStrings
136198 QueryPartFlag fl -> ffor fl $ \case
137199 True -> Just $ Right pName
138200 False -> Nothing
@@ -167,10 +229,10 @@ reqToReflexRequest reqMeth req reqHost =
167229 Right $ XhrRequestConfig
168230 { _xhrRequestConfig_sendData = bytesToPayload bBytes
169231 , _xhrRequestConfig_headers =
170− Map.insert "Content-Type" bCT (Map.fromList hs)
232+ Map.insert "Content-Type" bCT (Map.fromList hs)
171233 , _xhrRequestConfig_user = Nothing
172234 , _xhrRequestConfig_password = Nothing
173− , _xhrRequestConfig_responseType = Nothing
235+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
174236 , _xhrRequestConfig_withCredentials = False
175237 , _xhrRequestConfig_responseHeaders = def
176238 }
@@ -182,8 +244,8 @@ reqToReflexRequest reqMeth req reqHost =
182244 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
183245 , _xhrRequestConfig_user = Nothing
184246 , _xhrRequestConfig_password = Nothing
185− , _xhrRequestConfig_responseType = Nothing
186− , _xhrRequestConfig_sendData = ""
247+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
248+ , _xhrRequestConfig_sendData = mempty
187249 , _xhrRequestConfig_withCredentials = False
188250 }
189251 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
@@ -210,40 +272,55 @@ reqToReflexRequest reqMeth req reqHost =
210272displayHttpRequest :: Text -> Text
211273displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
212274
213−-- | This function actually performs the request.
275+-- | This function performs the request
214276performRequests :: forall t m f tag.(SupportsServantReflex t m, Traversable f)
215277 => Text
216− -> f (Req t)
278+ -> Dynamic t (f (Req t))
217279 -> Dynamic t BaseUrl
280+ -> ClientOptions
218281 -> Event t tag
219282 -> m (Event t (tag, f (Either Text XhrResponse)))
220−performRequests reqMeth rs reqHost trigger = do
221− let xhrReqs = sequence $ (\r -> reqToReflexRequest reqMeth r reqHost) <$> rs :: Dynamic t (f (Either Text (XhrRequest XhrPayload)))
222− let reqs = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) xhrReqs trigger
223− resps <- performSomeRequestsAsync reqs
283+performRequests reqMeth rs reqHost opts trigger = do
284+ let xhrReqs =
285+ join $ (\(fxhr :: f (Req t)) -> sequence $
286+ reqToReflexRequest reqMeth reqHost <$> fxhr) <$> rs
287+
288+ -- xhrReqs = fmap snd <$> xhrReqsAndDebugs
289+ reqs = attachPromptlyDynWith
290+ (\fxhr t -> Compose (t, fxhr)) xhrReqs trigger
291+
292+ resps <- performSomeRequestsAsync opts reqs
224293 return $ getCompose <$> resps
225294
226−-- | Issues a collection of requests when the supplied Event fires. When ALL requests from a given firing complete, the results are collected and returned via the return Event.
295+-- | Issues a collection of requests when the supplied Event fires.
296+-- When ALL requests from a given firing complete, the results are
297+-- collected and returned via the return Event.
227298performSomeRequestsAsync
228299 :: (MonadIO (Performable m),
300+ MonadJSM (Performable m),
229301 HasWebView (Performable m),
230302 PerformEvent t m,
231303 TriggerEvent t m,
232304 Traversable f,
233− IsXhrPayload a)
234− => Event t (f (Either Text (XhrRequest a)))
305+ IsXhrPayload a,
306+ Show a
307+ )
308+ => ClientOptions
309+ -> Event t (f (Either Text (XhrRequest a)))
235310 -> m (Event t (f (Either Text XhrResponse)))
236−performSomeRequestsAsync = performSomeRequestsAsync' newXMLHttpRequest . fmap return
311+performSomeRequestsAsync opts =
312+ performSomeRequestsAsync' opts newXMLHttpRequest . fmap return
237313
238314
239315------------------------------------------------------------------------------
240316-- | A modified version or Reflex.Dom.Xhr.performRequestsAsync
241317-- that accepts 'f (Either e (XhrRequestb))' events
242318performSomeRequestsAsync'
243− :: (MonadIO (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f)
244− => (XhrRequest b -> (a -> IO ()) -> Performable m XMLHttpRequest)
319+ :: (MonadJSM (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f, Show b)
320+ => ClientOptions
321+ -> (XhrRequest b -> (a -> JSM ()) -> Performable m XMLHttpRequest)
245322 -> Event t (Performable m (f (Either Text (XhrRequest b)))) -> m (Event t (f (Either Text a)))
246−performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
323+performSomeRequestsAsync' opts newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
247324 rs <- hrs
248325 resps <- forM rs $ \r -> case r of
249326 Left e -> do
@@ -251,103 +328,92 @@ performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb ->
251328 return resp
252329 Right r' -> do
253330 resp <- liftIO newEmptyMVar
254− _ <- newXhr r' $ liftIO . putMVar resp . Right
331+ r'' <- liftJSM $ (optsRequestFixup opts) r'
332+ _ <- newXhr r'' $ liftIO . putMVar resp . Right
255333 return resp
256334 _ <- liftIO $ forkIO $ cb =<< forM resps takeMVar
257335 return ()
258336
259337
260338
261−-- | This function actually performs the request.
262−performRequest :: forall t m tag .(SupportsServantReflex t m)
263− => Text
264− -> (Req t)
265− -> Dynamic t BaseUrl
266− -> Event t tag
267− -> m (Event t (tag, XhrResponse), Event t (tag, Text))
268−performRequest reqMeth req reqHost trigger = do
269−
270− let xhrReq = reqToReflexRequest reqMeth req reqHost
271− let reqs = attachPromptlyDynWith (flip (,)) xhrReq trigger
272− okReqs = fmapMaybe (\(t,e) -> either (const Nothing) (Just . (t,)) e) reqs
273− badReqs = fmapMaybe (\(t,e) -> either (Just . (t,)) (const Nothing) e) reqs
274−
275− resps <- performRequestsAsync okReqs
276−
277− return (resps, badReqs)
339+type XhrPayload = ByteString
340+bytesToPayload :: BL.ByteString -> XhrPayload
341+bytesToPayload = BL.toStrict
278342
279343
280−#ifdef ghcjs_HOST_OS
281−type XhrPayload = String
282−bytesToPayload :: BL.ByteString -> XhrPayload
283−bytesToPayload = BL.unpack
284−#else
285−type XhrPayload = T.Text
286−bytesToPayload :: BL.ByteString -> XhrPayload
287−bytesToPayload = T.pack . BL.unpack
288−#endif
289−
290−performRequestNoBody :: forall t m tag.(SupportsServantReflex t m)
291− => Text
292− -> Req t
293− -> Dynamic t BaseUrl
294− -> Event t tag -> m (Event t (tag, ReqResult NoContent))
295−performRequestNoBody reqMeth req reqHost trigger = do
296− (resp, badReq) <- performRequest reqMeth req reqHost trigger
297− return $ leftmost [ fmap (ResponseSuccess NoContent) <$> resp, fmap RequestFailure <$> badReq]
298−
299−performRequestsNoBody :: forall t m f tag. (SupportsServantReflex t m, Traversable f)
300− => Text
301− -> f (Req t)
302− -> Dynamic t BaseUrl
303− -> Event t tag -> m (Event t (tag, f (ReqResult NoContent)))
304−performRequestsNoBody reqMeth reqs reqHost trigger = do
305− resp <- performRequests reqMeth reqs reqHost trigger
306− return $ (fmap . fmap) aux <$> resp
307− where
308− aux (Right x) = ResponseSuccess NoContent x
309− aux (Left e) = RequestFailure e
310− -- return $ leftmost [ fmap (ResponseSuccess NoContent) resp, fmap RequestFailure badReq]
311−
312−
313−performRequestCT
344+performRequestsCT
314345 :: (SupportsServantReflex t m,
315− MimeUnrender ct a)
346+ MimeUnrender ct a, Traversable f)
316347 => Proxy ct
317348 -> Text
318− -> Req t
349+ -> Dynamic t (f (Req t))
319350 -> Dynamic t BaseUrl
351+ -> ClientOptions
320352 -> Event t tag
321− -> m (Event t (tag, ReqResult a))
322−performRequestCT ct reqMeth req reqHost trigger = do
323− (resp, badReq) <- performRequest reqMeth req reqHost trigger
324− let decodes = ffor resp $ fmap (\xhr ->
325− ((mimeUnrender ct . BL.fromStrict . TE.encodeUtf8)
326− =<< note "No body text" (_xhrResponse_responseText xhr), xhr))
327− reqs = ffor decodes $ fmap (\case
328− (Right a, r) -> ResponseSuccess a r
329− (Left e, r) -> ResponseFailure (T.pack e) r)
330− return $ leftmost [reqs, fmap RequestFailure <$> badReq]
331−
332−performRequestsCT
353+ -> m (Event t (f (ReqResult tag a)))
354+performRequestsCT ct reqMeth reqs reqHost opts trigger = do
355+ resps <- performRequests reqMeth reqs reqHost opts trigger
356+ let decodeResp (Just (XhrResponseBody_ArrayBuffer x)) =
357+ first T.pack .
358+ mimeUnrender ct $
359+ BL.fromStrict x
360+ decodeResp _ = Left "No body"
361+ return $ fmap
362+ (\(t,rs) -> ffor rs $ \r -> case r of
363+ Left e -> RequestFailure t e
364+ Right g -> evalResponse (decodeResp . _xhrResponse_response) (t,g)
365+ )
366+ resps
367+
368+
369+performRequestsNoBody
333370 :: (SupportsServantReflex t m,
334− MimeUnrender ct a, Traversable f)
335− => Proxy ct
336− -> Text
337− -> f (Req t)
371+ Traversable f)
372+ => Text
373+ -> Dynamic t (f (Req t))
338374 -> Dynamic t BaseUrl
375+ -> ClientOptions
339376 -> Event t tag
340− -> m (Event t (tag, f (ReqResult a)))
341−performRequestsCT ct reqMeth reqs reqHost trigger = do
342− resps <- performRequests reqMeth reqs reqHost trigger
343− return $ fmap (second (fmap reqToResult)) resps
344− where
345− reqToResult (Left e) = RequestFailure e
346− reqToResult (Right x) = case _xhrResponse_responseText x of
347− Nothing -> ResponseFailure "No request body" x
348− Just bod -> case mimeUnrender ct . BL.fromStrict . TE.encodeUtf8 $ bod of
349− Left e -> ResponseFailure (T.pack e) x
350− Right v -> ResponseSuccess v x
377+ -> m (Event t (f (ReqResult tag NoContent)))
378+performRequestsNoBody reqMeth reqs reqHost opts trigger = do
379+ resps <- performRequests reqMeth reqs reqHost opts trigger
380+ let decodeResp = const $ Right NoContent
381+ return $ ffor resps $ \(tag,rs) -> ffor rs $ \r -> case r of
382+ Left e -> RequestFailure tag e
383+ Right g -> evalResponse decodeResp (tag,g)
384+
385+
386+------------------------------------------------------------------------------
387+evalResponse
388+ :: (XhrResponse -> Either Text a)
389+ -> (tag, XhrResponse)
390+ -> ReqResult tag a
391+evalResponse decode (tag, xhr) =
392+ let status = _xhrResponse_status xhr
393+ okStatus = status >= 200 && status < 400
394+ errMsg = fromMaybe
395+ ("Empty response with error code " <>
396+ T.pack (show $ _xhrResponse_status xhr))
397+ (_xhrResponse_responseText xhr)
398+ respPayld = if okStatus
399+ then either
400+ (\e -> ResponseFailure tag e xhr)
401+ (\v -> ResponseSuccess tag v xhr)
402+ (decode xhr)
403+ else ResponseFailure tag errMsg xhr
404+ in respPayld
405+
406+------------------------------------------------------------------------------
407+-- | Utility for simultaneously accessing/filtering Success and Failure
408+-- response 'Event's,
409+fanReqResult :: Reflex t => Event t (ReqResult tag a) -> (Event t Text, Event t a)
410+fanReqResult = fmapMaybe reqFailure &&& fmapMaybe reqSuccess
411+
412+------------------------------------------------------------------------------
413+-- | Utility for simultaneously accessing/filtering Success and Failure
414+-- response 'Event's, but keeping the request tag
415+fanReqResult' :: Reflex t => Event t (ReqResult tag a) -> (Event t (tag, Text), Event t (tag, a))
416+fanReqResult' = fmapMaybe reqFailure' &&& fmapMaybe reqSuccess'
351417
352418
353419note :: e -> Maybe a -> Either e a
@@ -356,3 +422,10 @@ note e = maybe (Left e) Right
356422fmapL :: (e -> e') -> Either e a -> Either e' a
357423fmapL _ (Right a) = Right a
358424fmapL f (Left e) = Left (f e)
425+
426+builderToText :: Builder.Builder -> T.Text
427+builderToText = TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString
428+
429+escape :: T.Text -> T.Text
430+escape = T.pack . N.escapeURIString (not . N.isReserved) . T.unpack . TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString . toEncodedUrlPiece
431+
src/Servant/Reflex.hs+216−107
@@ -1,17 +1,23 @@
1−{-# LANGUAGE AllowAmbiguousTypes #-}
2−{-# LANGUAGE CPP #-}
3−{-# LANGUAGE DataKinds #-}
4−{-# LANGUAGE FlexibleContexts #-}
5−{-# LANGUAGE FlexibleInstances #-}
6−{-# LANGUAGE InstanceSigs #-}
7−{-# LANGUAGE OverloadedStrings #-}
8−{-# LANGUAGE PolyKinds #-}
9−{-# LANGUAGE ScopedTypeVariables #-}
10−{-# LANGUAGE TupleSections #-}
11−{-# LANGUAGE TypeFamilies #-}
12−{-# LANGUAGE TypeOperators #-}
13−{-# LANGUAGE UndecidableInstances #-}
14−{-# LANGUAGE MultiParamTypeClasses #-}
1+{-# LANGUAGE AllowAmbiguousTypes #-}
2+{-# LANGUAGE CPP #-}
3+{-# LANGUAGE DataKinds #-}
4+{-# LANGUAGE FlexibleContexts #-}
5+{-# LANGUAGE FlexibleInstances #-}
6+{-# LANGUAGE GeneralizedNewtypeDeriving #-}
7+{-# LANGUAGE InstanceSigs #-}
8+{-# LANGUAGE MultiParamTypeClasses #-}
9+{-# LANGUAGE OverloadedStrings #-}
10+{-# LANGUAGE PolyKinds #-}
11+{-# LANGUAGE Rank2Types #-}
12+{-# LANGUAGE ScopedTypeVariables #-}
13+{-# LANGUAGE TupleSections #-}
14+{-# LANGUAGE TypeFamilies #-}
15+{-# LANGUAGE TypeOperators #-}
16+{-# LANGUAGE UndecidableInstances #-}
17+
18+#if MIN_VERSION_base(4,9,0)
19+{-# OPTIONS_GHC -fno-warn-redundant-constraints #-}
20+#endif
1521
1622-- #include "overlapping-compat.h"
1723-- | This module provides 'client' which can automatically generate
@@ -19,56 +25,71 @@
1925-- API.
2026module Servant.Reflex
2127 ( client
28+ , clientWithOpts
29+ , clientWithOptsAndResultHandler
30+ , clientWithRoute
31+ , clientWithRouteAndResultHandler
2232 , BuildHeaderKeysTo(..)
2333 , toHeaders
24− , HasClient(..)
34+ , HasClient
35+ , Client
2536 , module Servant.Common.Req
2637 , module Servant.Common.BaseUrl
2738 ) where
2839
2940------------------------------------------------------------------------------
3041import Control.Applicative
42+import qualified Data.CaseInsensitive as CI
43+import Data.Functor.Identity
44+import qualified Data.Map as Map
3145import Data.Monoid ((<>))
32−import qualified Data.Set as Set
33−import qualified Data.Text.Encoding as E
34−import Data.CaseInsensitive (mk)
3546import Data.Proxy (Proxy (..))
36−import qualified Data.Map as Map
47+import qualified Data.Set as Set
3748import Data.Text (Text)
3849import qualified Data.Text as T
50+import qualified Data.Text.Encoding as E
51+import GHC.Exts (Constraint)
3952import GHC.TypeLits (KnownSymbol, symbolVal)
40−import Servant.API ((:<|>)(..),(:>), BasicAuth,
41− BasicAuthData, BuildHeadersTo(..),
42− Capture, contentType, Header,
43− Headers(..), HttpVersion, IsSecure,
44− MimeRender(..), MimeUnrender,
53+import Servant.API ((:<|>) (..), (:>), BasicAuth,
54+ BasicAuthData, BuildHeadersTo (..),
55+ Capture, Header, Headers (..),
56+ HttpVersion, IsSecure,
57+ MimeRender (..), MimeUnrender,
4558 NoContent, QueryFlag, QueryParam,
46− QueryParams, Raw, ReflectMethod(..),
59+ QueryParams, Raw, ReflectMethod (..),
4760 RemoteHost, ReqBody,
48− ToHttpApiData(..), Vault, Verb)
49−
50−import Reflex.Dom (Dynamic, Event, Reflex,
51− XhrRequest(..),
52− XhrResponseHeaders(..),
53− XhrResponse(..), attachPromptlyDynWith, ffor, fmapMaybe,
54− leftmost, performRequestsAsync,
55− )
61+ ToHttpApiData (..), Vault, Verb,
62+ contentType)
63+import Servant.API.Description (Summary)
64+import qualified Servant.Auth as Auth
65+
66+import Reflex.Dom.Core (Dynamic, Event, Reflex,
67+ XhrRequest (..), XhrResponse (..),
68+ XhrResponseHeaders (..),
69+ attachPromptlyDynWith, constDyn, ffor,
70+ fmapMaybe, leftmost,
71+ performRequestsAsync)
5672------------------------------------------------------------------------------
5773import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
5874 showBaseUrl,
5975 SupportsServantReflex)
60−import Servant.Common.Req (Req, ReqResult(..), QParam(..),
76+import Servant.Common.Req (ClientOptions(..),
77+ defaultClientOptions,
78+ Req, ReqResult(..), QParam(..),
6179 QueryPart(..), addHeader, authData,
62− defReq, prependToPathParts,
63− performRequestCT,
80+ defReq, evalResponse, prependToPathParts,
81+ -- performRequestCT,
6482 performRequestsCT,
65− performRequestNoBody,
83+ -- performRequestNoBody,
6684 performRequestsNoBody,
6785 performSomeRequestsAsync,
6886 qParamToQueryPart, reqBody,
6987 reqSuccess, reqFailure,
70− reqMethod, respHeaders, response,
71− qParams)
88+ reqMethod, respHeaders,
89+ response,
90+ reqTag,
91+ qParams, withCredentials)
92+
7293
7394-- * Accessing APIs as a Client
7495
@@ -82,28 +103,75 @@ import Servant.Common.Req (Req, ReqResult(..), QParam(..),
82103-- >
83104-- > getAllBooks :: Event t l -> m (Event t (l, ReqResult [Book]))
84105-- > postNewBook :: Dynamic t (Maybe Book) -> Event t l
85−-- -> m (Event t (l, ReqResult Book)))
106+-- > -> m (Event t (l, ReqResult Book)))
86107-- > (getAllBooks :<|> postNewBook) = client myApi host
87108-- > where host = constDyn $ BaseUrl Http "localhost" 8080
88−client :: (HasClient t m layout tag)
89− => Proxy layout -> Proxy m -> Proxy tag -> Dynamic t BaseUrl -> Client t m layout tag
90−client p q t baseurl = clientWithRoute p q t defReq baseurl
109+client
110+ :: (HasClient t m layout tag)
111+ => Proxy layout
112+ -> Proxy m
113+ -> Proxy tag
114+ -> Dynamic t BaseUrl
115+ -> Client t m layout tag
116+client p q t baseurl = clientWithRoute p q t defReq baseurl defaultClientOptions
117+
118+clientWithOpts
119+ :: (HasClient t m layout tag)
120+ => Proxy layout
121+ -> Proxy m
122+ -> Proxy tag
123+ -> Dynamic t BaseUrl
124+ -> ClientOptions
125+ -> Client t m layout tag
126+clientWithOpts p q t baseurl = clientWithRoute p q t defReq baseurl
127+
128+-- | Like 'clientWithOpts' but allows passing a function which will process the
129+-- result event in some way. This can be used to handle errors in a uniform way
130+-- across call sites.
131+clientWithOptsAndResultHandler
132+ :: (HasClient t m layout tag)
133+ => Proxy layout
134+ -> Proxy m
135+ -> Proxy tag
136+ -> Dynamic t BaseUrl
137+ -> ClientOptions
138+ -> (forall a. Event t (ReqResult tag a) -> m (Event t (ReqResult tag a)))
139+ -> Client t m layout tag
140+clientWithOptsAndResultHandler p q t = clientWithRouteAndResultHandler p q t defReq
91141
92142
93143-- | This class lets us define how each API combinator
94144-- influences the creation of an HTTP request. It's mostly
95145-- an internal class, you can just use 'client'.
96−class HasClient t m layout (tag :: *) where
146+class Monad m => HasClient t m layout (tag :: *) where
97147 type Client t m layout tag :: *
98− clientWithRoute :: Proxy layout -> Proxy m -> Proxy tag -> Req t -> Dynamic t BaseUrl -> Client t m layout tag
148+ clientWithRoute
149+ :: Proxy layout
150+ -> Proxy m
151+ -> Proxy tag
152+ -> Req t
153+ -> Dynamic t BaseUrl
154+ -> ClientOptions
155+ -> Client t m layout tag
156+ clientWithRoute l m t r b o = clientWithRouteAndResultHandler l m t r b o return
157+
158+ clientWithRouteAndResultHandler
159+ :: Proxy layout
160+ -> Proxy m
161+ -> Proxy tag
162+ -> Req t
163+ -> Dynamic t BaseUrl
164+ -> ClientOptions
165+ -> (forall a. Event t (ReqResult tag a) -> m (Event t (ReqResult tag a)))
166+ -> Client t m layout tag
99167
100168
101169instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b) tag where
102170 type Client t m (a :<|> b) tag = Client t m a tag :<|> Client t m b tag
103171
104− clientWithRoute Proxy q pTag req baseurl =
105− clientWithRoute (Proxy :: Proxy a) q pTag req baseurl :<|>
106− clientWithRoute (Proxy :: Proxy b) q pTag req baseurl
172+ clientWithRouteAndResultHandler Proxy q pTag req baseurl opts wrap =
173+ clientWithRouteAndResultHandler (Proxy :: Proxy a) q pTag req baseurl opts wrap :<|>
174+ clientWithRouteAndResultHandler (Proxy :: Proxy b) q pTag req baseurl opts wrap
107175
108176
109177-- Capture. Example:
@@ -124,11 +192,9 @@ instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout ta
124192 type Client t m (Capture capture a :> sublayout) tag =
125193 Dynamic t (Either Text a) -> Client t m sublayout tag
126194
127− clientWithRoute Proxy q t req baseurl val =
128− clientWithRoute (Proxy :: Proxy sublayout)
129− q t
130− (prependToPathParts p req)
131− baseurl
195+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap val =
196+ clientWithRouteAndResultHandler
197+ (Proxy :: Proxy sublayout) q t (prependToPathParts p req) baseurl opts wrap
132198 where p = (fmap . fmap) (toUrlPiece) val
133199
134200
@@ -138,11 +204,11 @@ instance {-# OVERLAPPABLE #-}
138204 (MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
139205 ) => HasClient t m (Verb method status cts' a) tag where
140206 type Client t m (Verb method status cts' a) tag =
141− Event t tag -> m (Event t (tag, ReqResult a))
207+ Event t tag -> m (Event t (ReqResult tag a))
142208 -- TODO how to access input types here?
143209 -- ExceptT ServantError IO a
144− clientWithRoute Proxy _ _ req baseurl trigs =
145− performRequestCT (Proxy :: Proxy ct) method req' baseurl trigs
210+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
211+ wrap =<< fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity $ req') baseurl opts trigs
146212 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
147213 req' = req { reqMethod = method }
148214
@@ -152,32 +218,36 @@ instance {-# OVERLAPPING #-}
152218 (ReflectMethod method, SupportsServantReflex t m) =>
153219 HasClient t m (Verb method status cts NoContent) tag where
154220 type Client t m (Verb method status cts NoContent) tag =
155− Event t tag -> m (Event t (tag, ReqResult NoContent))
221+ Event t tag -> m (Event t (ReqResult tag NoContent))
156222 -- TODO: how to access input types here?
157223 -- ExceptT ServantError IO NoContent
158− clientWithRoute Proxy _ _ req baseurl =
159− performRequestNoBody method req baseurl
224+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
225+ wrap =<< fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req) baseurl opts trigs
160226 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
161227
162228
163−toHeaders :: BuildHeadersTo ls => ReqResult a -> ReqResult (Headers ls a)
229+toHeaders :: BuildHeadersTo ls => ReqResult tag a -> ReqResult tag (Headers ls a)
164230toHeaders r =
165− let toBS = E.encodeUtf8
166− hdrs = maybe []
167− (\xhr -> fmap (\(h,v) -> (mk (toBS h), toBS v))
231+ let hdrs = maybe []
232+ (\xhr -> fmap (\(h,v) -> (CI.map E.encodeUtf8 h, E.encodeUtf8 v))
168233 (Map.toList $ _xhrResponse_headers xhr))
169234 (response r)
170235 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
171236
237+
172238class BuildHeaderKeysTo hs where
173− buildHeaderKeysTo :: Proxy hs -> [T.Text]
239+ buildHeaderKeysTo :: Proxy hs -> [CI.CI T.Text]
174240
175241instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
176242 where buildHeaderKeysTo _ = []
177243
178244instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
179− => BuildHeaderKeysTo '[(Header h v) ': xs] where
180− buildHeaderKeysTo _ = (T.pack $ symbolVal (Proxy :: Proxy h)) : buildHeaderKeysTo (Proxy :: Proxy xs)
245+ => BuildHeaderKeysTo ((Header h v) ': xs) where
246+ buildHeaderKeysTo _ =
247+ let
248+ thisKey = CI.mk $ T.pack (symbolVal (Proxy :: Proxy h))
249+ in thisKey : buildHeaderKeysTo (Proxy :: Proxy xs)
250+
181251
182252-- HEADERS Verb (Content) --
183253-- Headers combinator not treated in fully general case,
@@ -191,11 +261,11 @@ instance {-# OVERLAPPABLE #-}
191261 SupportsServantReflex t m
192262 ) => HasClient t m (Verb method status cts' (Headers ls a)) tag where
193263 type Client t m (Verb method status cts' (Headers ls a)) tag =
194− Event t tag -> m (Event t (tag, ReqResult (Headers ls a)))
195− clientWithRoute Proxy _ _ req baseurl = do
264+ Event t tag -> m (Event t (ReqResult tag (Headers ls a)))
265+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
196266 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
197− resp <- performRequestCT (Proxy :: Proxy ct) method req' baseurl
198− return $ (fmap . fmap) toHeaders <$> resp
267+ resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl opts trigs
268+ wrap $ toHeaders <$> resp
199269 where req' = req { respHeaders =
200270 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
201271 }
@@ -207,11 +277,11 @@ instance {-# OVERLAPPABLE #-}
207277 SupportsServantReflex t m
208278 ) => HasClient t m (Verb method status cts (Headers ls NoContent)) tag where
209279 type Client t m (Verb method status cts (Headers ls NoContent)) tag
210− = Event t tag -> m (Event t (tag, ReqResult (Headers ls NoContent)))
211− clientWithRoute Proxy _ _ req baseurl = do
280+ = Event t tag -> m (Event t (ReqResult tag (Headers ls NoContent)))
281+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
212282 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
213− resp <- performRequestNoBody method req' baseurl
214− return $ (fmap . fmap) toHeaders <$> resp
283+ resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl opts trigs
284+ wrap $ toHeaders <$> resp
215285 where req' = req {respHeaders =
216286 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
217287 }
@@ -238,11 +308,11 @@ instance (KnownSymbol sym, ToHttpApiData a,
238308 type Client t m (Header sym a :> sublayout) tag =
239309 Dynamic t (Either Text a) -> Client t m sublayout tag
240310
241− clientWithRoute Proxy q t req baseurl eVal =
242− clientWithRoute (Proxy :: Proxy sublayout)
243− q t
244− (Servant.Common.Req.addHeader hname eVal req)
245− baseurl
311+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap eVal =
312+ clientWithRouteAndResultHandler
313+ (Proxy :: Proxy sublayout) q t
314+ (Servant.Common.Req.addHeader hname eVal req)
315+ baseurl opts wrap
246316 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
247317
248318
@@ -256,8 +326,20 @@ instance HasClient t m sublayout tag
256326 type Client t m (HttpVersion :> sublayout) tag =
257327 Client t m sublayout tag
258328
259− clientWithRoute Proxy q t =
260− clientWithRoute (Proxy :: Proxy sublayout) q t
329+ clientWithRouteAndResultHandler Proxy =
330+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout)
331+
332+-- | Using a 'Summary' combinator in your API doesn't affect the client
333+-- functions.
334+instance (HasClient t m sublayout tag, KnownSymbol sym)
335+ => HasClient t m (Summary sym :> sublayout) tag where
336+
337+ type Client t m (Summary sym :> sublayout) tag =
338+ Client t m sublayout tag
339+
340+ clientWithRouteAndResultHandler Proxy =
341+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout)
342+
261343
262344
263345
@@ -294,9 +376,9 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
294376 Dynamic t (QParam a) -> Client t m sublayout tag
295377
296378 -- if mparam = Nothing, we don't add it to the query string
297− clientWithRoute Proxy q t req baseurl mparam =
298− clientWithRoute (Proxy :: Proxy sublayout) q t
299− (req {qParams = paramPair : qParams req}) baseurl
379+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap mparam =
380+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t
381+ (req {qParams = paramPair : qParams req}) baseurl opts wrap
300382
301383 where pname = symbolVal (Proxy :: Proxy sym)
302384 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
@@ -340,12 +422,12 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
340422 type Client t m (QueryParams sym a :> sublayout) tag =
341423 Dynamic t [a] -> Client t m sublayout tag
342424
343− clientWithRoute Proxy q t req baseurl paramlist =
344− clientWithRoute (Proxy :: Proxy sublayout) q t req' baseurl
425+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap paramlist =
426+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
345427
346428 where req' = req { qParams = (T.pack pname, params') : qParams req }
347429 pname = symbolVal (Proxy :: Proxy sym)
348− params' = QueryPartParams $ (fmap . fmap) (toQueryParam)
430+ params' = QueryPartParams $ (fmap . fmap) toQueryParam
349431 paramlist
350432
351433
@@ -380,8 +462,8 @@ instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
380462 type Client t m (QueryFlag sym :> sublayout) tag =
381463 Dynamic t Bool -> Client t m sublayout tag
382464
383− clientWithRoute Proxy q t req baseurl flag =
384− clientWithRoute (Proxy :: Proxy sublayout) q t req' baseurl
465+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap flag =
466+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
385467
386468 where req' = req { qParams = thisPair : qParams req }
387469 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
@@ -393,9 +475,9 @@ instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
393475instance SupportsServantReflex t m => HasClient t m Raw tag where
394476 type Client t m Raw tag = Dynamic t (Either Text (XhrRequest ()))
395477 -> Event t tag
396− -> m (Event t (tag, ReqResult ()))
478+ -> m (Event t (ReqResult tag ()))
397479
398− clientWithRoute _ _ _ _ baseurl xhrs triggers = do
480+ clientWithRouteAndResultHandler _ _ _ _ baseurl _ wrap xhrs triggers = do
399481
400482 let xhrs' = liftA2 (\x path -> case x of
401483 Left e -> Left e
@@ -406,8 +488,9 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
406488 okReq = fmapMaybe (\(t,x) -> either (const Nothing) (Just . (t,)) x) xhrs'' :: Event t (tag, XhrRequest ())
407489
408490 resps <- performRequestsAsync okReq
409− return $ leftmost [ fmap (ResponseSuccess ()) <$> resps
410− , fmap (RequestFailure) <$> badReq ]
491+ wrap $ leftmost [ uncurry RequestFailure <$> badReq
492+ , evalResponse (const $ Right ()) <$> resps
493+ ]
411494
412495
413496-- | If you use a 'ReqBody' in one of your endpoints in your API,
@@ -436,8 +519,8 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
436519 type Client t m (ReqBody (ct ': cts) a :> sublayout) tag =
437520 Dynamic t (Either Text a) -> Client t m sublayout tag
438521
439− clientWithRoute Proxy q t req baseurl body =
440− clientWithRoute (Proxy :: Proxy sublayout) q t req' baseurl
522+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap body =
523+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
441524 where req' = req { reqBody = bodyBytesCT }
442525 ctProxy = Proxy :: Proxy ct
443526 ctString = T.pack $ show $ contentType ctProxy
@@ -451,10 +534,9 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
451534instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient t m (path :> sublayout) tag where
452535 type Client t m (path :> sublayout) tag = Client t m sublayout tag
453536
454− clientWithRoute Proxy q t req baseurl =
455− clientWithRoute (Proxy :: Proxy sublayout) q t
456− (prependToPathParts (pure (Right $ T.pack p)) req)
457− baseurl
537+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap =
538+ clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t
539+ (prependToPathParts (pure (Right $ T.pack p)) req) baseurl opts wrap
458540
459541 where p = symbolVal (Proxy :: Proxy path)
460542
@@ -462,23 +544,23 @@ instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient
462544instance HasClient t m api tag => HasClient t m (Vault :> api) tag where
463545 type Client t m (Vault :> api) tag = Client t m api tag
464546
465− clientWithRoute Proxy q t req baseurl =
466− clientWithRoute (Proxy :: Proxy api) q t req baseurl
547+ clientWithRouteAndResultHandler Proxy =
548+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
467549
468550
469551instance HasClient t m api tag => HasClient t m (RemoteHost :> api) tag where
470552 type Client t m (RemoteHost :> api) tag = Client t m api tag
471553
472− clientWithRoute Proxy q t req baseurl =
473− clientWithRoute (Proxy :: Proxy api) q t req baseurl
554+ clientWithRouteAndResultHandler Proxy =
555+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
474556
475557
476558
477559instance HasClient t m api tag => HasClient t m (IsSecure :> api) tag where
478560 type Client t m (IsSecure :> api) tag = Client t m api tag
479561
480− clientWithRoute Proxy q t req baseurl =
481− clientWithRoute (Proxy :: Proxy api) q t req baseurl
562+ clientWithRouteAndResultHandler Proxy =
563+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
482564
483565
484566instance (HasClient t m api tag, Reflex t)
@@ -487,8 +569,8 @@ instance (HasClient t m api tag, Reflex t)
487569 type Client t m (BasicAuth realm usr :> api) tag = Dynamic t (Maybe BasicAuthData)
488570 -> Client t m api tag
489571
490− clientWithRoute Proxy q t req baseurl authdata =
491− clientWithRoute (Proxy :: Proxy api) q t req' baseurl
572+ clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap authdata =
573+ clientWithRouteAndResultHandler (Proxy :: Proxy api) q t req' baseurl opts wrap
492574 where
493575 req' = req { authData = Just authdata }
494576
@@ -514,3 +596,30 @@ non-empty lists, but is otherwise more specific, no instance will be overall
514596more specific. This in turn generally means adding yet another instance (one
515597for empty and one for non-empty lists).
516598-}
599+
600+
601+-- SUPPORT FOR servant-auth --
602+
603+-- For JavaScript clients we should be sending/storing JSON web tokens in a
604+-- way that is inaccessible to JavaScript.
605+--
606+-- For @servant-auth@ this is done with HTTP-only cookies. In a Reflex-DOM
607+-- app this means the @servant-auth@ client should only verify that the API
608+-- supports Cookie-based authentication but do nothing with the token
609+-- directly.
610+
611+-- @HasCookieAuth auths@ is nominally a redundant constraint, but ensures
612+-- we're not trying to rely on cookies when the API does not use them.
613+instance (HasCookieAuth auths, HasClient t m api tag) => HasClient t m (Auth.Auth auths a :> api) tag where
614+
615+ type Client t m (Auth.Auth auths a :> api) tag = Client t m api tag
616+ clientWithRouteAndResultHandler Proxy = clientWithRouteAndResultHandler (Proxy :: Proxy api)
617+
618+
619+type family HasCookieAuth xs :: Constraint where
620+ HasCookieAuth (Auth.Cookie ': xs) = ()
621+ HasCookieAuth (x ': xs) = HasCookieAuth xs
622+ HasCookieAuth '[] = CookieAuthNotEnabled
623+
624+class CookieAuthNotEnabled
625+
src/Servant/Reflex/Multi.hs+195−127
@@ -1,96 +1,138 @@
1−{-# LANGUAGE AllowAmbiguousTypes #-}
2−{-# LANGUAGE CPP #-}
3−{-# LANGUAGE DataKinds #-}
4−{-# LANGUAGE FlexibleContexts #-}
5−{-# LANGUAGE FlexibleInstances #-}
6−{-# LANGUAGE InstanceSigs #-}
7−{-# LANGUAGE OverloadedStrings #-}
8−{-# LANGUAGE PolyKinds #-}
9−{-# LANGUAGE ScopedTypeVariables #-}
10−{-# LANGUAGE TupleSections #-}
11−{-# LANGUAGE TypeFamilies #-}
12−{-# LANGUAGE TypeOperators #-}
13−{-# LANGUAGE UndecidableInstances #-}
1+{-# LANGUAGE AllowAmbiguousTypes #-}
2+{-# LANGUAGE CPP #-}
3+{-# LANGUAGE DataKinds #-}
4+{-# LANGUAGE FlexibleContexts #-}
5+{-# LANGUAGE FlexibleInstances #-}
6+{-# LANGUAGE InstanceSigs #-}
147{-# LANGUAGE MultiParamTypeClasses #-}
8+{-# LANGUAGE OverloadedStrings #-}
9+{-# LANGUAGE PolyKinds #-}
10+{-# LANGUAGE ScopedTypeVariables #-}
11+{-# LANGUAGE TupleSections #-}
12+{-# LANGUAGE TypeFamilies #-}
13+{-# LANGUAGE TypeOperators #-}
14+{-# LANGUAGE UndecidableInstances #-}
15+
16+module Servant.Reflex.Multi (
17+ -- * Compute servant client functions
18+ clientA
19+ , clientWithOptsA
20+ , BaseUrl(..)
21+ , Scheme(..)
22+
23+ -- * Build QueryParam arguments
24+ , QParam(..)
25+
26+ -- * Access response data
27+ , withCredentials
28+
29+ -- * Access response data
30+ , ReqResult(..)
31+ , reqSuccess
32+ , reqSuccess'
33+ , reqFailure
34+ , response
1535
16−module Servant.Reflex.Multi
17− ( clientA
1836 , HasClientMulti(..)
1937 ) where
2038
2139------------------------------------------------------------------------------
22−import Control.Applicative
23−import Control.Arrow (second)
24−import Data.Functor.Compose
25−import Data.Monoid ((<>))
26−import qualified Data.Set as Set
27−import qualified Data.Text.Encoding as E
28−import Data.CaseInsensitive (mk)
40+import Control.Applicative (liftA2)
41+import Data.Functor.Compose (Compose (..), getCompose)
2942import Data.Proxy (Proxy (..))
30−import qualified Data.Map as Map
43+import qualified Data.Set as Set
3144import Data.Text (Text)
3245import qualified Data.Text as T
46+import qualified Data.Text.Encoding as E
3347import GHC.TypeLits (KnownSymbol, symbolVal)
34−import Servant.API ((:<|>)(..),(:>), BasicAuth,
35− BasicAuthData, BuildHeadersTo(..),
36− Capture, contentType, Header,
37− Headers(..), HttpVersion, IsSecure,
38− MimeRender(..), MimeUnrender,
48+import Servant.API ((:<|>) (..), (:>), BasicAuth,
49+ BasicAuthData, BuildHeadersTo (..),
50+ Capture, Header, Headers (..),
51+ HttpVersion, IsSecure,
52+ MimeRender (..), MimeUnrender,
3953 NoContent, QueryFlag, QueryParam,
40− QueryParams, Raw, ReflectMethod(..),
54+ QueryParams, Raw, ReflectMethod (..),
4155 RemoteHost, ReqBody,
42− ToHttpApiData(..), Vault, Verb)
43−
44−import Reflex.Dom (Dynamic, Event, Reflex,
45− XhrRequest(..),
46− XhrResponseHeaders(..),
47− XhrResponse(..), ffor, fmapMaybe,
48− leftmost, performRequestAsync, attachPromptlyDynWith,
49− tagPromptlyDyn )
56+ ToHttpApiData (..), Vault, Verb,
57+ contentType)
58+import Servant.API.Description (Summary)
59+
60+import Reflex.Dom.Core (Dynamic, Event, Reflex,
61+ XhrRequest (..),
62+ XhrResponseHeaders (..),
63+ attachPromptlyDynWith, constDyn)
5064------------------------------------------------------------------------------
51−import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
52− showBaseUrl,
53− SupportsServantReflex)
54−import Servant.Common.Req (Req, ReqResult(..), QParam(..),
55− QueryPart(..), addHeader, authData,
56− defReq, prependToPathParts,
57− performRequestCT,
58− performRequestsCT,
59− performRequestNoBody,
60− performRequestsNoBody,
61− performSomeRequestsAsync,
62− qParamToQueryPart, reqBody,
63− reqSuccess, reqFailure,
64− reqMethod, respHeaders, response,
65− qParams)
66−import Servant.Reflex (BuildHeaderKeysTo(..), toHeaders)
67−
68−clientA :: (HasClientMulti t m layout f tag, Applicative f)
69− => Proxy layout -> Proxy m -> Proxy f -> Proxy tag -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
70−clientA p q f tag baseurl = clientWithRouteMulti p q f tag (pure defReq) baseurl
65+import Servant.Common.BaseUrl (BaseUrl (..), Scheme (..),
66+ SupportsServantReflex)
67+import Servant.Common.Req (ClientOptions,
68+ QParam (..), QueryPart (..), Req,
69+ ReqResult (..), addHeader, authData,
70+ defReq,
71+ defaultClientOptions,
72+ performRequestsCT,
73+ performRequestsNoBody,
74+ performSomeRequestsAsync,
75+ prependToPathParts, qParamToQueryPart,
76+ qParams, reqBody, reqFailure,
77+ reqMethod, reqSuccess, reqSuccess',
78+ respHeaders, response, withCredentials)
79+import Servant.Reflex (BuildHeaderKeysTo (..), toHeaders)
80+
7181
82+------------------------------------------------------------------------------
83+clientA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
84+ => Proxy layout -> Proxy m -> Proxy f -> Proxy tag
85+ -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
86+clientA p q f tag baseurl =
87+ clientWithRouteMulti p q f tag (constDyn (pure defReq)) baseurl
88+ defaultClientOptions
89+
90+
91+-- | A version of @client@ that sets the withCredentials flag
92+-- on requests. Use this function for clients of CORS API's
93+clientWithOptsA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
94+ => Proxy layout -> Proxy m -> Proxy f -> Proxy tag
95+ -> Dynamic t BaseUrl -> ClientOptions -> ClientMulti t m layout f tag
96+clientWithOptsA p q f tag baseurl opts =
97+ clientWithRouteMulti p q f tag
98+ (constDyn (pure defReq)) baseurl opts
99+
100+------------------------------------------------------------------------------
72101class HasClientMulti t m layout f (tag :: *) where
73102 type ClientMulti t m layout f tag :: *
74− clientWithRouteMulti :: Proxy layout -> Proxy m -> Proxy f -> Proxy tag -> f (Req t) -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
103+ clientWithRouteMulti :: Proxy layout -> Proxy m -> Proxy f -> Proxy tag
104+ -> Dynamic t (f (Req t)) -> Dynamic t BaseUrl
105+ -> ClientOptions -> ClientMulti t m layout f tag
75106
76−instance (HasClientMulti t m a f tag, HasClientMulti t m b f tag) => HasClientMulti t m (a :<|> b) f tag where
77− type ClientMulti t m (a :<|> b) f tag = ClientMulti t m a f tag :<|> ClientMulti t m b f tag
78− clientWithRouteMulti Proxy q f tag reqs baseurl =
79− clientWithRouteMulti (Proxy :: Proxy a) q f tag reqs baseurl :<|>
80− clientWithRouteMulti (Proxy :: Proxy b) q f tag reqs baseurl
107+
108+------------------------------------------------------------------------------
109+instance (HasClientMulti t m a f tag, HasClientMulti t m b f tag) =>
110+ HasClientMulti t m (a :<|> b) f tag where
111+ type ClientMulti t m (a :<|> b) f tag = ClientMulti t m a f tag :<|>
112+ ClientMulti t m b f tag
113+ clientWithRouteMulti Proxy q f tag reqs baseurl opts =
114+ clientWithRouteMulti (Proxy :: Proxy a) q f tag reqs baseurl opts :<|>
115+ clientWithRouteMulti (Proxy :: Proxy b) q f tag reqs baseurl opts
81116
82117
83−instance (SupportsServantReflex t m, ToHttpApiData a, HasClientMulti t m sublayout f tag, Applicative f)
118+------------------------------------------------------------------------------
119+instance (SupportsServantReflex t m,
120+ ToHttpApiData a,
121+ HasClientMulti t m sublayout f tag,
122+ Applicative f)
84123 => HasClientMulti t m (Capture capture a :> sublayout) f tag where
85124
86125 type ClientMulti t m (Capture capture a :> sublayout) f tag =
87126 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
88127
89− clientWithRouteMulti l q f tag reqs baseurl vals = clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl
128+ clientWithRouteMulti _ q f tag reqs baseurl opts vals =
129+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
90130 where
91− reqs' = prependToPathParts <$> ps <*> reqs
131+ reqs' = (prependToPathParts <$> ps <*>) <$> reqs
92132 ps = (fmap . fmap . fmap) toUrlPiece vals
93133
134+
135+------------------------------------------------------------------------------
94136-- VERB (Returning content) --
95137instance {-# OVERLAPPABLE #-}
96138 -- Note [Non-Empty Content Types]
@@ -102,25 +144,29 @@ instance {-# OVERLAPPABLE #-}
102144 ) => HasClientMulti t m (Verb method status cts' a) f tag where
103145
104146 type ClientMulti t m (Verb method status cts' a) f tag =
105− Event t tag -> m (Event t (tag, f (ReqResult a)))
147+ Event t tag -> m (Event t (f (ReqResult tag a)))
106148
107− clientWithRouteMulti _ _ f tag reqs baseurl =
108− performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl
149+ clientWithRouteMulti _ _ _ _ reqs baseurl opts =
150+ performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts
109151 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
110− reqs' = (\r -> r { reqMethod = method }) <$> reqs
152+ reqs' = fmap (\r -> r { reqMethod = method }) <$> reqs
153+
111154
155+------------------------------------------------------------------------------
112156-- -- VERB (No content) --
113157instance {-# OVERLAPPING #-}
114158 (ReflectMethod method, SupportsServantReflex t m, Traversable f) =>
115159 HasClientMulti t m (Verb method status cts NoContent) f tag where
116160 type ClientMulti t m (Verb method status cts NoContent) f tag =
117− Event t tag -> m (Event t (tag, f (ReqResult NoContent)))
161+ Event t tag -> m (Event t (f (ReqResult tag NoContent)))
118162 -- TODO: how to access input types here?
119163 -- ExceptT ServantError IO NoContent
120− clientWithRouteMulti Proxy _ _ tag req baseurl =
121− performRequestsNoBody method req baseurl
164+ clientWithRouteMulti Proxy _ _ _ req baseurl opts =
165+ performRequestsNoBody method req baseurl opts
122166 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
123167
168+
169+------------------------------------------------------------------------------
124170instance {-# OVERLAPPABLE #-}
125171 -- Note [Non-Empty Content Types]
126172 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
@@ -129,35 +175,41 @@ instance {-# OVERLAPPABLE #-}
129175 Traversable f
130176 ) => HasClientMulti t m (Verb method status cts' (Headers ls a)) f tag where
131177 type ClientMulti t m (Verb method status cts' (Headers ls a)) f tag =
132− Event t tag -> m (Event t (tag, f (ReqResult (Headers ls a))))
133− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
178+ Event t tag -> m (Event t (f (ReqResult tag (Headers ls a))))
179+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
134180 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
135− resp <- performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl triggers :: m (Event t (tag, f (ReqResult a)))
136− return $ (fmap . fmap) toHeaders <$> resp
137− where reqs' = ffor reqs $ \r -> r { respHeaders =
138− OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
139− }
181+ resp <- performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts triggers :: m (Event t (f (ReqResult tag a)))
182+ return $ fmap toHeaders <$> resp
183+ where
184+ reqs' = fmap (\r ->
185+ r { respHeaders =
186+ OnlyHeaders (Set.fromList
187+ (buildHeaderKeysTo (Proxy :: Proxy ls)))
188+ }) <$> reqs
140189
141190
191+------------------------------------------------------------------------------
142192instance {-# OVERLAPPABLE #-}
143193 ( BuildHeadersTo ls,
144194 BuildHeaderKeysTo ls,
145195 ReflectMethod method,
146196 SupportsServantReflex t m,
147197 Traversable f
148− ) => HasClientMulti t m (Verb method status cts (Headers ls NoContent)) f tag where
198+ ) => HasClientMulti t m (Verb method status
199+ cts (Headers ls NoContent)) f tag where
149200 type ClientMulti t m (Verb method status cts (Headers ls NoContent)) f tag
150− = Event t tag -> m (Event t (tag, f (ReqResult (Headers ls NoContent))))
151− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
201+ = Event t tag -> m (Event t (f (ReqResult tag (Headers ls NoContent))))
202+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
152203 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
153− resp <- performRequestsNoBody method reqs' baseurl triggers
154− return $ (fmap . fmap) toHeaders <$> resp
155− where reqs' = ffor reqs $ \req ->
204+ resp <- performRequestsNoBody method reqs' baseurl opts triggers
205+ return $ fmap toHeaders <$> resp
206+ where reqs' = fmap (\req ->
156207 req {respHeaders = OnlyHeaders (Set.fromList
157208 (buildHeaderKeysTo (Proxy :: Proxy ls)))
158− }
209+ }) <$> reqs
159210
160211
212+------------------------------------------------------------------------------
161213instance (KnownSymbol sym,
162214 ToHttpApiData a,
163215 HasClientMulti t m sublayout f tag,
@@ -169,16 +221,17 @@ instance (KnownSymbol sym,
169221 type ClientMulti t m (Header sym a :> sublayout) f tag =
170222 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
171223
172− clientWithRouteMulti Proxy f q tag reqs baseurl eVals =
224+ clientWithRouteMulti Proxy f q tag reqs baseurl opts eVals =
173225 clientWithRouteMulti (Proxy :: Proxy sublayout) f
174226 q tag
175227 reqs'
176− baseurl
228+ baseurl opts
177229 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
178− reqs' = (\eVal req -> Servant.Common.Req.addHeader hname eVal req)
179− <$> eVals <*> reqs
230+ reqs' = ((\eVal req -> Servant.Common.Req.addHeader hname eVal req)
231+ <$> eVals <*>) <$> reqs
180232
181233
234+------------------------------------------------------------------------------
182235instance HasClientMulti t m sublayout f tag
183236 => HasClientMulti t m (HttpVersion :> sublayout) f tag where
184237
@@ -189,22 +242,40 @@ instance HasClientMulti t m sublayout f tag
189242 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
190243
191244
192−instance (KnownSymbol sym, ToHttpApiData a, HasClientMulti t m sublayout f tag, Reflex t, Traversable f, Applicative f)
245+------------------------------------------------------------------------------
246+instance (HasClientMulti t m sublayout f tag, KnownSymbol sym)
247+ => HasClientMulti t m (Summary sym :> sublayout) f tag where
248+
249+ type ClientMulti t m (Summary sym :> sublayout) f tag =
250+ ClientMulti t m sublayout f tag
251+
252+ clientWithRouteMulti Proxy q f tag =
253+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
254+
255+
256+------------------------------------------------------------------------------
257+instance (KnownSymbol sym,
258+ ToHttpApiData a,
259+ HasClientMulti t m sublayout f tag,
260+ Reflex t,
261+ Applicative f)
193262 => HasClientMulti t m (QueryParam sym a :> sublayout) f tag where
194263
195264 type ClientMulti t m (QueryParam sym a :> sublayout) f tag =
196− f (Dynamic t (QParam a)) -> ClientMulti t m sublayout f tag
265+ Dynamic t (f (QParam a)) -> ClientMulti t m sublayout f tag
197266
198267 -- if mparam = Nothing, we don't add it to the query string
199268 -- TODO: Check the above comment
200− clientWithRouteMulti Proxy q f tag reqs baseurl mparams =
269+ clientWithRouteMulti Proxy q f tag reqs baseurl opts mparams =
201270 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
202− reqs' baseurl
271+ reqs' baseurl opts
203272
204273 where pname = symbolVal (Proxy :: Proxy sym)
205274 p prm = QueryPartParam $ fmap qParamToQueryPart prm
206275 paramPair mp = (T.pack pname, p mp)
207− reqs' = (\param req -> req {qParams = paramPair param : qParams req})
276+ -- reqs' = (\params reqs -> (\req param -> req {qParams = paramPair param : qParams req}) <$> reqs <*> params)
277+ -- <$> mparams <*> reqs
278+ reqs' = liftA2 (\(pr :: QParam a) (r :: Req t) -> r { qParams = paramPair (constDyn pr) : qParams r })
208279 <$> mparams <*> reqs
209280
210281
@@ -212,77 +283,74 @@ instance (KnownSymbol sym,
212283 ToHttpApiData a,
213284 HasClientMulti t m sublayout f tag,
214285 Reflex t,
215− Traversable f,
216286 Applicative f)
217287 => HasClientMulti t m (QueryParams sym a :> sublayout) f tag where
218288
219289 type ClientMulti t m (QueryParams sym a :> sublayout) f tag =
220− f (Dynamic t [a]) -> ClientMulti t m sublayout f tag
290+ Dynamic t (f [a]) -> ClientMulti t m sublayout f tag
221291
222− clientWithRouteMulti Proxy q f tag reqs baseurl paramlists =
223− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl
292+ clientWithRouteMulti Proxy q f tag reqs baseurl opts paramlists =
293+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
224294
225− where req' l r = r { qParams = (T.pack pname, params' l) : qParams r }
295+ where req' l r = r { qParams = (T.pack pname, params' (constDyn l)) : qParams r }
226296 pname = symbolVal (Proxy :: Proxy sym)
227297 params' l = QueryPartParams $ (fmap . fmap) (toQueryParam)
228298 l
229− reqs' = req' <$> paramlists <*> reqs
299+ reqs' = liftA2 req' <$> paramlists <*> reqs
230300
231301
232302instance (KnownSymbol sym,
233303 HasClientMulti t m sublayout f tag,
234304 Reflex t,
235− Traversable f,
236305 Applicative f)
237306 => HasClientMulti t m (QueryFlag sym :> sublayout) f tag where
238307
239308 type ClientMulti t m (QueryFlag sym :> sublayout) f tag =
240− f (Dynamic t Bool) -> ClientMulti t m sublayout f tag
309+ Dynamic t (f Bool) -> ClientMulti t m sublayout f tag
241310
242− clientWithRouteMulti Proxy q f tag reqs baseurl flags =
243− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl
311+ clientWithRouteMulti Proxy q f' tag reqs baseurl opts flags =
312+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f' tag reqs' baseurl opts
244313
245− where req' f req = req { qParams = thisPair f : qParams req }
314+ where req' f req = req { qParams = thisPair (constDyn f) : qParams req }
246315 thisPair f = (T.pack pName, QueryPartFlag f) :: (Text, QueryPart t)
247316 pName = symbolVal (Proxy :: Proxy sym)
248− reqs' = req' <$> flags <*> reqs
317+ reqs' = liftA2 req' <$> flags <*> reqs
249318
250319
251320instance (SupportsServantReflex t m,
252− Traversable f) => HasClientMulti t m Raw f tag where
321+ Traversable f, Applicative f) => HasClientMulti t m Raw f tag where
253322 type ClientMulti t m Raw f tag = f (Dynamic t (Either Text (XhrRequest ())))
254323 -> Event t tag
255− -> m (Event t (tag, f (ReqResult ())))
324+ -> m (Event t (f (ReqResult tag ())))
256325
257− clientWithRouteMulti _ _ _ _ oldReqs baseurl rawReqs triggers = do
326+ clientWithRouteMulti _ _ _ _ _ _ opts rawReqs triggers = do
258327 let rawReqs' = sequence rawReqs :: Dynamic t (f (Either Text (XhrRequest ())))
259328 rawReqs'' = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) rawReqs' triggers
260− resps <- fmap (second (fmap aux) . getCompose) <$> performSomeRequestsAsync rawReqs''
329+ resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync opts rawReqs''
261330 return resps
262331 where
263− aux (Right r) = ResponseSuccess () r
264− aux (Left e) = RequestFailure e
332+ aux (tag, Right r) = ResponseSuccess tag () r
333+ aux (tag, Left e) = RequestFailure tag e
265334
266335
267336instance (MimeRender ct a,
268337 HasClientMulti t m sublayout f tag,
269338 Reflex t,
270− Traversable f,
271339 Applicative f)
272340 => HasClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag where
273341
274342 type ClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag =
275− f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
343+ Dynamic t (f (Either Text a)) -> ClientMulti t m sublayout f tag
276344
277− clientWithRouteMulti Proxy q f tag reqs baseurl bodies =
278− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl
279− where req' b r = r { reqBody = bodyBytesCT b }
345+ clientWithRouteMulti Proxy q f tag reqs baseurl opts bodies =
346+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
347+ where req' b r = r { reqBody = bodyBytesCT (constDyn b) }
280348 ctProxy = Proxy :: Proxy ct
281349 ctString = T.pack $ show $ contentType ctProxy
282350 bodyBytesCT b = Just $ (fmap . fmap)
283351 (\b' -> (mimeRender ctProxy b', ctString))
284352 b
285− reqs' = req' <$> bodies <*> reqs
353+ reqs' = liftA2 req' <$> bodies <*> reqs
286354
287355
288356instance (KnownSymbol path,
@@ -293,7 +361,7 @@ instance (KnownSymbol path,
293361
294362 clientWithRouteMulti Proxy q f tag reqs baseurl =
295363 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
296− (prependToPathParts (pure (Right $ T.pack p)) <$> reqs)
364+ (fmap (prependToPathParts (pure (Right $ T.pack p))) <$> reqs)
297365 baseurl
298366
299367 where p = symbolVal (Proxy :: Proxy path)
@@ -320,14 +388,14 @@ instance HasClientMulti t m api f tag => HasClientMulti t m (IsSecure :> api) f
320388 clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs baseurl
321389
322390
323−instance (HasClientMulti t m api f tag, Reflex t, Traversable f, Applicative f)
391+instance (HasClientMulti t m api f tag, Reflex t, Applicative f)
324392 => HasClientMulti t m (BasicAuth realm usr :> api) f tag where
325393
326− type ClientMulti t m (BasicAuth realm usr :> api) f tag = f (Dynamic t (Maybe BasicAuthData))
394+ type ClientMulti t m (BasicAuth realm usr :> api) f tag = Dynamic t (f (Maybe BasicAuthData))
327395 -> ClientMulti t m api f tag
328396
329− clientWithRouteMulti Proxy q f tag reqs baseurl authdatas =
330− clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs' baseurl
397+ clientWithRouteMulti Proxy q f tag reqs baseurl opts authdatas =
398+ clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs' baseurl opts
331399 where
332− req' a r = r { authData = Just a }
333− reqs' = req' <$> authdatas <*> reqs
400+ req' a r = r { authData = Just (constDyn a) }
401+ reqs' = liftA2 req' <$> authdatas <*> reqs
stack.yamlnew file+56
@@ -0,0 +1,56 @@
1+flags: {}
2+extra-package-dbs: []
3+packages:
4+- '.'
5+
6+- location:
7+ git: https://github.com/reflex-frp/reflex
8+ commit: d78ba4318c425ca9b942dc387d7c5c7ab2d2e095
9+ extra-dep: true
10+
11+- location:
12+ git: https://github.com/mokus0/dependent-sum.git
13+ commit: bbc8ad3a81ea7f2b07ce7d036efd56f2e0f7c6ff
14+ extra-dep: true
15+
16+- location:
17+ git: https://github.com/gtk2hs/gtk2hs.git
18+ commit: 21d3a12a82756d04066e5e4198b35097012ee65b
19+ subdirs:
20+ - cairo
21+ - gio
22+ - glib
23+ - gtk
24+ - pango
25+ - tools
26+ extra-dep: true
27+
28+- location:
29+ git: https://github.com/byorgey/hashtables.git
30+ commit: 47d9ed261a5aba66a13d3c4da0e391d338b57fc5
31+ extra-dep: true
32+
33+- location:
34+ git: https://github.com/afcady/reflex-dom.git
35+ commit: 39b5ff23f3ae95d77c909ab3ed4bc4bd9e61f600
36+ extra-dep: true
37+
38+- location:
39+ git: https://github.com/afcady/dependent-sum-template.git
40+ commit: 68fc1a90580ea8f20775491cf651eefea422212a
41+ extra-dep: true
42+
43+extra-deps:
44+- cpphs-1.20.4
45+- directory-1.2.7.1
46+- ghcjs-dom-0.2.4.0
47+- haskell-src-exts-1.17.1
48+- haskell-src-meta-0.6.0.14
49+- hlint-1.9.35
50+- prim-uniq-0.1.0.1
51+- primitive-0.6.2.0
52+- ref-tf-0.4.0.1
53+- vector-0.12.0.0
54+- webkitgtk3-javascriptcore-0.13.2.0
55+- zenc-0.1.1
56+resolver: lts-8.3
testdriver/test/Servant/ReflexSpec.hs+2−1
@@ -9,6 +9,7 @@ import qualified Data.Text as T
99import Data.Foldable
1010import Test.WebDriver.Commands.Wait
1111import Test.Hspec.WebDriver
12+import Test.Hspec.WebDriver (chromeCaps)
1213
1314
1415clickingShouldCause :: Selector -> Selector -> Double -> (Element -> Element -> WD Bool) -> WD ()
@@ -28,7 +29,7 @@ spec :: Spec
2829spec = do
2930 describe "servant-reflex tests" $ do
3031
31− session "test page" $ using Chrome $ do
32+ session "test page" $ using [chromeCaps] $ do
3233
3334 it "opens the page" $ runWD $
3435 openPage "http://localhost:8000"
testserver/API.hsmode 120000 → 100644+69−1
@@ -1 +0,0 @@
1−../exec/API.hs
@@ -0,0 +1,69 @@
1+{-# LANGUAGE DataKinds #-}
2+{-# LANGUAGE OverloadedStrings #-}
3+{-# LANGUAGE TypeOperators #-}
4+
5+module API where
6+
7+import Data.Aeson
8+import Data.Aeson.Types (typeMismatch)
9+import Data.Text (Text)
10+import Servant.API
11+
12+newtype Question = Question { unQuestion :: Text } deriving (Show)
13+
14+instance ToJSON Question where
15+ toJSON (Question txt) = object ["question" .= txt]
16+
17+instance FromJSON Question where
18+ parseJSON (Object v) = Question <$> v .: "question"
19+ parseJSON x = typeMismatch "Couldn't find key 'question'" x
20+
21+newtype Answer = Answer { unAnswer :: Text } deriving (Show)
22+
23+instance ToJSON Answer where
24+ toJSON (Answer txt) = object ["answer" .= txt]
25+
26+instance FromJSON Answer where
27+ parseJSON (Object v) = Answer <$> v .: "answer"
28+ parseJSON x = typeMismatch "Couldn't find key 'answer'" x
29+
30+
31+-- | API spec for server, client, and docs
32+type API = "getunit" :> Get '[JSON] ()
33+ :<|> "getint" :> Get '[JSON] Int
34+ :<|> "sayhi" :> QueryParam "username" Text
35+ :> QueryParams "greetings" Text
36+ :> QueryFlag "gusto"
37+ :> Get '[JSON] Text
38+ :<|> "double" :> ReqBody '[JSON] Double
39+ :> Post '[JSON] Double
40+ :<|> "a" :> "b" :> QueryFlag "gusto" :> Get '[JSON] Text
41+ :<|> "qna" :> ReqBody '[JSON] Question
42+ :> Post '[JSON] Answer
43+ :<|> "secret" :> BasicAuth "realm" () :> Get '[JSON] Int
44+ :<|> Raw
45+
46+type GET = Get '[JSON] ()
47+
48+-- Imported the comprehensive API example for testing.
49+-- https://github.com/haskell-servant/servant/blob/master/servant/src/Servant/API/Internal/Test/ComprehensiveAPI.hs
50+type ComprehensiveAPI =
51+ GET :<|>
52+ Get '[JSON] Int :<|>
53+ Capture "foo" Int :> GET :<|>
54+ Header "foo" Int :> GET :<|>
55+ HttpVersion :> GET :<|>
56+ IsSecure :> GET :<|>
57+ QueryParam "foo" Int :> GET :<|>
58+ QueryParams "foo" Int :> GET :<|>
59+ QueryFlag "foo" :> GET :<|>
60+-- Raw :<|>
61+ RemoteHost :> GET :<|>
62+ ReqBody '[JSON] Int :> GET :<|>
63+ Get '[JSON] (Headers '[Header "foo" Int] ()) :<|>
64+ "foo" :> GET :<|>
65+ Vault :> GET :<|>
66+ Verb 'POST 204 '[JSON] () :<|>
67+ Verb 'POST 204 '[JSON] Int
68+-- This one isn't in scope
69+-- :<|> WithNamedContext "foo" '[] GET
testserver/Main.hs+39−14
@@ -2,27 +2,34 @@
22{-# LANGUAGE DeriveGeneric #-}
33{-# LANGUAGE OverloadedStrings #-}
44{-# LANGUAGE PolyKinds #-}
5+{-# LANGUAGE TypeApplications #-}
56{-# LANGUAGE TypeFamilies #-}
67{-# LANGUAGE TypeOperators #-}
78
9+import Control.Monad.IO.Class (liftIO)
10+import Control.Monad.Reader (reader)
811import Data.Aeson
912import Data.Bool
10−import Data.Char (toUpper)
11−import qualified Data.List as L
13+import Data.Char (toUpper)
14+import qualified Data.List as L
15+import Data.Maybe (fromMaybe)
1216import Data.Monoid
1317import Data.Proxy
14−import Data.Text hiding (length, null, map, head, toUpper)
15−import qualified Data.Text as T
18+import Data.Text hiding (head, length, map,
19+ null, toUpper)
20+import qualified Data.Text as T
21+import qualified Data.Text.IO as T
1622import GHC.Generics
17−import Snap.Http.Server
18−import Snap.Core
1923import Servant.Server.Internal.SnapShims
24+import Snap.Core
25+import Snap.Http.Server
2026
21−import Servant -- hiding (serveDirectory)
27+import Servant
2228import Servant.Server
2329-- import Snap.Util.FileServe
30+import System.Environment (lookupEnv)
2431import API
25−import Snap
32+import Snap
2633
2734-- * Example
2835
@@ -36,7 +43,7 @@ instance ToJSON Greet
3643testApi :: Proxy API
3744testApi = Proxy
3845
39−data App = App
46+data App = App { appStaticDir :: String }
4047
4148-- Server-side handlers.
4249--
@@ -44,8 +51,10 @@ data App = App
4451-- that represents the API, are glued together using :<|>.
4552--
4653-- Each handler runs in the 'ExceptT ServantErr IO' monad.
47−server :: Server API (Handler App App)
48−server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> serveDirectory "static"
54+server :: Server API '[BasicAuthCheck (Handler App App) ()] (Handler App App)
55+server = return () :<|> return 100 :<|> sayhi :<|> dbl
56+ :<|> multi :<|> qna :<|> serveSecret
57+ :<|> statics
4958 where sayhi :: Maybe Text -> [Text] -> Bool -> Handler App App Text
5059 sayhi nm greetings withGusto = case nm of
5160 Nothing -> return ("Sorry, who are you?" :: Text)
@@ -57,20 +66,36 @@ server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> serveDire
5766 | otherwise = T.intercalate ", " (L.init greetings)
5867 <> ", and " <> L.last greetings <> ", "
5968 return . modifier $ greetPart <> n
60− dbl x = return $ x * 2
69+ dbl x = if x `elem` [4,13]
70+ then throwError $ err500 { errBody = "No unlucky numbers please" }
71+ else return $ x * 2
6172 multi = return . bool "Box unchecked" "Box Checked"
73+ qna q = do
74+ liftIO $ do
75+ putStrLn $ "qna got: " ++ show q
76+ T.putStrLn $ unQuestion q
77+ return $ Answer $ unQuestion q
78+ serveSecret _ = do
79+ req <- getRequest
80+ liftIO $ putStrLn (show req)
81+ return 101
82+ statics = do
83+ staticDir <- reader appStaticDir
84+ serveDirectory staticDir
6285
6386-- Turn the server into a WAI app. 'serve' is provided by servant,
6487-- more precisely by the Servant.Server module.
6588test :: Handler App App ()
66−test = serveSnap testApi server
89+test = serveSnapWithContext testApi
90+ (BasicAuthCheck (\_ -> return @(Handler App App) (Authorized ())) :. EmptyContext) server
6791
6892initApp :: SnapletInit App App
6993initApp = makeSnaplet "myapp" "example" Nothing $ do
94+ staticDir <- fromMaybe "static" <$> liftIO (lookupEnv "STATIC_DIR")
7095 addRoutes [("", test)
7196 ,("", serveDirectory "static")
7297 ]
73− return App
98+ return (App staticDir)
7499
75100-- Put this all to work!
76101main :: IO ()
testserver/run-wd-tests.shdeleted−5
@@ -1,5 +0,0 @@
1−#!/usr/bin/env bash
2−
3−dist/build/back/back -p 8000 &
4−phantomjs --webdriver=127.0.0.1:4444 &
5−dist/build/spec/spec
testserver/testserver.cabal+17−16
@@ -1,31 +1,32 @@
1−-- Initial back.cabal generated by cabal init. For further documentation,
1+-- Initial back.cabal generated by cabal init. For further documentation,
22-- see http://haskell.org/cabal/users-guide/
33
44name: testserver
55version: 0.1.0.0
6−-- synopsis:
7−-- description:
6+-- synopsis:
7+-- description:
88license: BSD3
99license-file: LICENSE
1010author: Greg Hale
1111maintainer: imalsogreg@gmail.com
12−-- copyright:
13−-- category:
12+-- copyright:
13+-- category:
1414build-type: Simple
15−-- extra-source-files:
15+-- extra-source-files:
1616cabal-version: >=1.10
1717
1818executable back
1919 main-is: Main.hs
20− -- other-modules:
21− -- other-extensions:
22− build-depends: aeson >= 0.9 && < 1.1
23− , base >=4.8 && <4.10
24− , snap >= 1.0 && < 1.1
25− , snap-server >= 1.0 && < 1.1
20+ -- other-modules:
21+ -- other-extensions:
22+ build-depends: aeson >= 0.9 && < 1.5
23+ , base >=4.8 && < 5
24+ , mtl
25+ , snap >= 1.0 && < 1.2
26+ , snap-server >= 1.0 && < 1.2
2627 , snap-core >= 1.0 && < 1.1
27− , servant >= 0.7.1 && < 0.9
28− , servant-snap >= 0.7 && < 0.8
29− , text >= 1.2 && < 1.3
30− -- hs-source-dirs:
28+ , servant >= 0.16 && < 0.18
29+ , servant-snap >= 0.8 && < 0.9
30+ , text >= 1.0 && < 1.3
31+ -- hs-source-dirs:
3132 default-language: Haskell2010
testserver/tr.nixdeleted−32
@@ -1,32 +0,0 @@
1−{ reflex-platform, ... }:
2−let
3−
4− dontCheck = (import <nixpkgs> {}).pkgs.haskell.lib.dontCheck;
5− cabal2nixResult = reflex-platform.cabal2nixResult;
6− nixpkgs = (import <nixpkgs> {});
7−in
8−reflex-platform.ghc.override {
9− overrides = self: super: {
10− servant-snap = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap) {});
11− snap = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap) {});
12− io-streams = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/io-streams) {});
13− io-streams-haproxy = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/io-streams-haproxy) {});
14− heist = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/heist) {});
15− xmlhtml = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/xmlhtml) {});
16− snap-core = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/snap-core) {});
17− snap-server = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap/deps/snap-server) {});
18− snap-loader-static = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap-loader-static) {});
19− snap-loader-dynamic = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/snap-loader-dynamic) {});
20− hspec-snap = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/hspec-snap) {});
21−
22− # servant-foreign = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-foreign) {});
23− # servant-js = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-js) {});
24− # servant-docs = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-docs) {});
25− # servant-client = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-client) {});
26− # servant-blaze = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-blaze) {});
27− # servant-lucid = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-lucid) {});
28− # servant-server = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant-server) {});
29− # servant = dontCheck (self.callPackage (cabal2nixResult ../deps/servant-snap/deps/servant/servant) {});
30−
31− };
32−}
travis.nixnew file+70
@@ -0,0 +1,70 @@
1+{
2+ nativeCompiler ? "ghc",
3+ # ^ Choose a GHC for compiling backend components (web server, selenium)
4+ # (ghc, ghc8_0, ghc8_2, ghc8_4 or ghcHEAD)
5+
6+ jsCompiler ? "ghcjs"
7+ # ^ Choose a GHCJS for compiling the frontend
8+ # (ghcjs, ghcjs8_0, ghcjs8_2 or ghcjs8_4)
9+
10+}:
11+
12+let
13+
14+ reflexPlatform = import ./nix/reflex-platform.nix;
15+
16+ lib = reflexPlatform.nixpkgs.haskell.lib;
17+ do = funs: pkg: builtins.foldl' (a: b: b a) pkg funs;
18+
19+ ghcjsPkgs = with lib; reflexPlatform.${jsCompiler}.override {
20+ overrides = self: super: {
21+ http-media = dontCheck super.http-media;
22+ servant = dontCheck super.servant;
23+ lens-aeson = dontCheck super.lens-aeson;
24+ servant-reflex = lib.appendConfigureFlag
25+ (self.callPackage ./default.nix {}) "-fExample";
26+ };
27+ };
28+
29+ ghcPkgs = with lib; reflexPlatform.${nativeCompiler}.override {
30+ overrides = self: super: {
31+ servant-snap = dontCheck ((import ./nix/servant-snap.nix {}) self super);
32+ testdriver = self.callCabal2nix "testdriver" ./testdriver {};
33+ testserver = import nix/testserver.nix ghcjsPkgs.servant-reflex self super;
34+ servant-reflex = self.callPackage ./default.nix {};
35+ };
36+ };
37+
38+ testresults = import ./nix/testresults.nix
39+ { inherit reflexPlatform;
40+ inherit (ghcPkgs) testserver testdriver;
41+ inherit (reflexPlatform.nixpkgs) curl;
42+ phantomjs = reflexPlatform.nixpkgs.phantomjs2;
43+ };
44+
45+in
46+ rec {
47+
48+ inherit reflexPlatform ghcPkgs ghcjsPkgs;
49+
50+ build = ghcjsPkgs.servant-reflex;
51+ buildGhc = ghcPkgs.servant-reflex;
52+ testserver = ghcPkgs.testserver;
53+ testdriver = ghcPkgs.testdriver;
54+ inherit testresults;
55+
56+ cabalBuild = reflexPlatform.${jsCompiler}.shellFor {
57+ name = "servant-reflex-cabal-builder";
58+
59+ packages = p: [
60+ build
61+ ];
62+
63+ shellHook = ''
64+ cabal configure --ghcjs -f Example
65+ cabal build
66+ exec/toSite.sh
67+ exit $?
68+ '';
69+ };
70+ }