git.iko.soy/typeable/servant-reflex
on master help sign in
35 files changed+948−542
since splitsnapshots
unifiedsplit
.gitignore+3−1 .gitmodules−15 .travis.yml+12−57 changelog.md → ChangeLog.md+28 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+1 exec/Example.hs+48−21 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−40 overrides.nix−35 servant-reflex.cabal+36−19 shell.nix+1 src/Servant/Common/BaseUrl.hs+13−9 src/Servant/Common/Req.hs+115−98 src/Servant/Reflex.hs+206−107 src/Servant/Reflex/Multi.hs+82−53 stack.yaml+56 testdriver/test/Servant/ReflexSpec.hs+2−1 testserver/API.hs+69−1 testserver/Main.hs+20−5 testserver/run-wd-tests.sh−5 testserver/testserver.cabal+8−7 testserver/tr.nix−32 travis.nix+70
.gitignore+3−1
@@ -6,4 +6,6 @@ log
66*.webapp
77*.stats
88out
9−reflex-platform
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−57
@@ -1,62 +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− - unset CC
24− - export PATH=/opt/ghc/$GHCVER/bin:/opt/cabal/$CABALVER/bin:$PATH
25− - git submodule update --init --recursive
6+ - sudo cp -rT $TRAVIS_BUILD_DIR/nix /etc/nix
267
27−install:
28− - cabal --version
29− - BENCH=${BENCH---enable-benchmarks}
30− - TEST=${TEST---enable-tests}
31− - echo "$(ghc --version) [$(ghc --print-project-git-commit-id 2> /dev/null || echo '?')]"
32− - if [ -f $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz ];
33− then
34− zcat $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz >
35− $HOME/.cabal/packages/hackage.haskell.org/00-index.tar;
36− fi
37− - travis_retry cabal update -v
38− - git clone https://github.com/reflex-frp/reflex-platform
39− - sed -i 's/^jobs:/-- jobs:/' ${HOME}/.cabal/config
40− - reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal configure && cabal build"
41− - reflex-platform/work-on ghc ./testdriver --command "cd testdriver && cabal configure && cabal build"
42− - cd testserver && dist/build/back/back -p 8000 &
43− - sleep 3
44− - phantomjs --webdriver=127.0.0.1:4444 &
45− - 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"
4612
4713script:
48− - git config --global user.email "travis-ci@example.com"
49− - git config --global user.name "Travis-CI"
50− - ./build.sh
51− - testdriver/dist/build/spec/spec
52−
53−cache:
54− directories:
55− - /nix
56− - $HOME/.cabal/packages
57− - $HOME/.cabal/store
58−
59−env:
60− global:
61− - ENCRYPTION_LABEL: "3c89d919c82e"
62− - 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.md → ChangeLog.mdrenamed+28
@@ -1,3 +1,31 @@
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+
1290.3
230---
331
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+1
@@ -40,6 +40,7 @@ type API = "getunit" :> Get '[JSON] ()
4040 :<|> "a" :> "b" :> QueryFlag "gusto" :> Get '[JSON] Text
4141 :<|> "qna" :> ReqBody '[JSON] Question
4242 :> Post '[JSON] Answer
43+ :<|> "secret" :> BasicAuth "realm" () :> Get '[JSON] Int
4344 :<|> Raw
4445
4546type GET = Get '[JSON] ()
exec/Example.hs+48−21
@@ -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,17 +46,18 @@ runMulti :: forall t m. (SupportsServantReflex t m,
4246runMulti = do
4347 url <- baseUrlWidget
4448 el "br" blank
45− let (_ :<|> _ :<|> sayHi :<|> 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
56+ reqCount :: Dynamic t Int <- count b
5357 r <- dbl ((\x y -> [x,y]) <$> num <*> num2) (tag (current reqCount) b)
54− dynText =<< holdDyn "Waiting" (T.pack . show . fmapMaybe reqSuccess .snd <$> r)
55− lastInd <- holdDyn Nothing (Just . fst <$> r)
58+ dynText =<< holdDyn "Waiting" (T.pack . show . fmap reqSuccess <$> r)
59+
60+ lastInd <- holdDyn [] $ fmap reqTag <$> r
5661 display lastInd
5762
5863 divClass "demo-group" $ do
@@ -64,8 +69,13 @@ runMulti = do
6469 textInput def
6570 gust <- fmap (value) $ divClass "gusto-input" $ checkbox False def
6671 b <- button "Go"
67− r' <- sayHi (fmap QParamSome <$> nms) (fmap (:[]) $ grts) (constDyn [True, False]) (1 <$ b)
68− dynText =<< holdDyn "Waiting" (T.pack . show . fmap (fmapMaybe reqSuccess) <$> r')
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+
6979 return ()
7080
7181run :: forall t m. (SupportsServantReflex t m,
@@ -87,21 +97,26 @@ run = mdo
8797 el "br" (return ())
8898
8999 -- Name the computed API client functions
90− let (getUnit :<|> getInt :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|> doRaw) =
91− client api (Proxy :: Proxy m) 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
92107
93108 (unitBtn, intBtn) <- elClass "div" "demo-group" $ do
94109 unitBtn <- divClass "unit-button" $ button "Get unit"
95110 intBtn <- divClass "int-button" $ button "Get int"
96111
97112 unitResponse <- getUnit $ tag (current reqCount) unitBtn
98− intResponse :: Event t (Int, ReqResult Int) <- getInt $ tag (current reqCount) intBtn
113+ intResponse :: Event t (ReqResult Int Int) <- getInt $ tag (current reqCount) intBtn
99114
100− score <- foldDyn (+) 0 (fmapMaybe reqSuccess (snd <$> intResponse))
115+ score <- foldDyn (+) 0 (fmapMaybe reqSuccess (intResponse))
101116
102117 r <- holdDyn "Waiting" $ fmap showXhrResponse $
103− leftmost [fmapMaybe response (snd <$> unitResponse)
104− ,fmapMaybe response (snd <$> intResponse)
118+ leftmost [fmapMaybe response (unitResponse)
119+ ,fmapMaybe response (intResponse)
105120 ]
106121 divClass "unit-int-response" $ el "p" $ dynText r >> el "br" (return ()) >> text "Total: " >> display score
107122 return (unitBtn, intBtn)
@@ -129,8 +144,8 @@ run = mdo
129144
130145 resp <- sayhi checkedName greetings gusto (tag (current reqCount) triggers)
131146 divClass "greeting-response" $ dynText =<<
132− holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (snd <$> resp)
133− , fmapMaybe reqFailure (snd <$> resp)])
147+ holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (resp)
148+ , fmapMaybe reqFailure (resp)])
134149 return sayHiClicks
135150
136151 dblBtn <- elClass "div" "demo-group" $ do
@@ -141,11 +156,11 @@ run = mdo
141156 dblResp <- dbl (fmap (note "read failure" . readMaybe . T.unpack) $
142157 dblinp) (tag (current reqCount) dblBtn)
143158 divClass "double-errors" $ dynText =<<
144− holdDyn "(no errors)" (fmapMaybe reqFailure (snd <$> dblResp))
159+ holdDyn "(no errors)" (fmapMaybe reqFailure (dblResp))
145160 el "br" (return ())
146161 divClass "double-result" $ el "p" $ dynText =<<
147162 holdDyn "No number yet" (fmap tShow $
148− fmapMaybe reqSuccess (snd <$> dblResp))
163+ fmapMaybe reqSuccess (dblResp))
149164 return dblBtn
150165
151166 mpGo <- elClass "div" "demo-group" $ do
@@ -155,7 +170,7 @@ run = mdo
155170 multiResp <- multi b (tag (current reqCount) mpGo)
156171 dynText =<< holdDyn "No res yet" (fmap tShow $
157172 fmapMaybe reqSuccess $
158− (snd <$> multiResp))
173+ (multiResp))
159174 return mpGo
160175
161176 return ()
@@ -165,12 +180,24 @@ run = mdo
165180 elClass "div" "demo-group" $ do
166181 text "JSON Unicode encoding test"
167182 txt <- value <$> textInput def
168− ev <- button "Question"
183+ ev <- fmap (1 <$) $ button "Question"
169184 let dQ = Right . Question <$> traceDyn "will send: " txt
170185 rr <- qna dQ ev
171186 el "p" $
172187 dynText =<< holdDyn "No Answer" (unAnswer <$> fmapMaybe reqSuccess rr)
173188
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+
174201showXhrResponse :: XhrResponse -> Text
175202showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
176203 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−40
@@ -1,40 +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− Glob = pkgs.haskell.lib.dontCheck super.Glob;
17− natural-transformation = self.callPackage (
18− { mkDerivation, base, containers, fetchgit, quickcheck-instances
19− , stdenv, tasty, tasty-quickcheck
20− }:
21− mkDerivation {
22− pname = "natural-transformation";
23− version = "0.4";
24− src = fetchgit {
25− url = "https://github.com/ku-fpg/natural-transformation";
26− sha256 = "0xbnnxbf5ydszbhf7h5ra3mrqy4mcyqc3zb2k8bwm1zyqrz6v0fs";
27− rev = "b1200c09dcafd034e32846413913b74735c8ba56";
28− };
29− libraryHaskellDepends = [ base ];
30− testHaskellDepends = [
31− base containers quickcheck-instances tasty tasty-quickcheck
32− ];
33− homepage = "https://github.com/ku-fpg/natural-transformation";
34− description = "A natural transformation package";
35− license = stdenv.lib.licenses.bsd3;
36− }
37− ) {};
38− http-api-data = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/http-api-data) {});
39− };
40−}
overrides.nixdeleted−35
@@ -1,35 +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− natural-transformation = self.callPackage (
14− { mkDerivation, base, containers, fetchgit, quickcheck-instances
15− , stdenv, tasty, tasty-quickcheck
16− }:
17− mkDerivation {
18− pname = "natural-transformation";
19− version = "0.4";
20− src = fetchgit {
21− url = "https://github.com/ku-fpg/natural-transformation";
22− sha256 = "0xbnnxbf5ydszbhf7h5ra3mrqy4mcyqc3zb2k8bwm1zyqrz6v0fs";
23− rev = "b1200c09dcafd034e32846413913b74735c8ba56";
24− };
25− libraryHaskellDepends = [ base ];
26− testHaskellDepends = [
27− base containers quickcheck-instances tasty tasty-quickcheck
28− ];
29− homepage = "https://github.com/ku-fpg/natural-transformation";
30− description = "A natural transformation package";
31− license = stdenv.lib.licenses.bsd3;
32− }
33− ) {};
34− };
35−}
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.8,
3841 safe >= 0.3.9 && < 0.4,
39− servant >= 0.8 && < 0.11,
42+ servant >= 0.16 && < 0.19,
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: aeson, 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+13−9
@@ -1,4 +1,5 @@
11{-# LANGUAGE ConstraintKinds #-}
2+{-# LANGUAGE CPP #-}
23{-# LANGUAGE DeriveDataTypeable #-}
34{-# LANGUAGE DeriveGeneric #-}
45{-# LANGUAGE FlexibleContexts #-}
@@ -20,18 +21,22 @@ module Servant.Common.BaseUrl (
2021) where
2122
2223import Control.Monad (join)
23−import Control.Monad.IO.Class (MonadIO)
24+-- import Control.Monad.IO.Class (MonadIO)
2425import Control.Monad.Fix (MonadFix)
2526import Data.Monoid ((<>))
2627import Data.Text (Text)
2728import qualified Data.Text as T
2829import GHC.Generics
30+import Language.Javascript.JSaddle.Monad (MonadJSM)
2931import Reflex
30−import Reflex.Dom
32+import Reflex.Dom.Core
3133import Text.Read
3234
33−
34−type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadIO (Performable m))
35+#if !MIN_VERSION_reflex_dom_core(0,7,0)
36+type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadJSM (Performable m))
37+#else
38+type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, MonadJSM (Performable m))
39+#endif
3540
3641-- | URI scheme to use
3742data Scheme =
@@ -84,15 +89,14 @@ baseUrlWidget = elClass "div" "base-url" $ do
8489 where pathWidget :: m (Dynamic t BaseUrl)
8590 pathWidget = do
8691 text "Url base path"
87− t <- textInput (def {_textInputConfig_attributes =
88− constDyn ("placeholder" =: "/a/b")})
92+ t <- inputElement def
8993 return $ BasePath <$> value t
9094 fullUrlWidget :: m (Dynamic t BaseUrl)
9195 fullUrlWidget = do
9296 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
93− srv <- textInput def {_textInputConfig_attributes = constDyn $ "placeholder" =: "example.com"}
97+ srv <- inputElement def
9498 text ":"
95− prt <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "80"}
99+ prt <- inputElement def
96100 port :: Dynamic t Int <- holdDyn 80 (fmapMaybe (readMaybe . T.unpack) $ updated (value prt))
97− path <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "a/b" }
101+ path <- inputElement def
98102 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
src/Servant/Common/Req.hs+115−98
@@ -1,20 +1,25 @@
11{-# LANGUAGE CPP #-}
2+{-# LANGUAGE DeriveFunctor #-}
23{-# LANGUAGE FlexibleContexts #-}
34{-# LANGUAGE GADTs #-}
45{-# LANGUAGE OverloadedStrings #-}
56{-# LANGUAGE LambdaCase #-}
7+{-# LANGUAGE RankNTypes #-}
68{-# LANGUAGE ScopedTypeVariables #-}
79{-# LANGUAGE TupleSections #-}
810
911module Servant.Common.Req where
1012
1113-------------------------------------------------------------------------------
12−import Control.Concurrent
1314import Control.Applicative (liftA2, liftA3)
15+import Control.Arrow ((&&&))
16+import Control.Concurrent
1417import Control.Monad (join)
1518import Control.Monad.IO.Class (MonadIO, liftIO)
1619import Data.Bifunctor (first)
20+import qualified Data.ByteString.Builder as Builder
1721import qualified Data.ByteString.Lazy.Char8 as BL
22+import Data.ByteString (ByteString)
1823import qualified Data.Map as Map
1924import Data.Maybe (catMaybes, fromMaybe)
2025import Data.Functor.Compose
@@ -24,7 +29,9 @@ import Data.Text (Text)
2429import qualified Data.Text as T
2530import qualified Data.Text.Encoding as TE
2631import Data.Traversable (forM)
27−import Reflex.Dom hiding (tag)
32+import Language.Javascript.JSaddle.Monad (JSM, MonadJSM, liftJSM)
33+import qualified Network.URI as N
34+import Reflex.Dom.Core hiding (tag)
2835import Servant.Common.BaseUrl (BaseUrl, showBaseUrl,
2936 SupportsServantReflex)
3037import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
@@ -43,7 +50,25 @@ data ReqResult tag a
4350 -- a non-successful response code
4451 | RequestFailure tag Text
4552 -- ^ A failure to construct the request tagged with 'tag' at trigger time
46−
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'
4772
4873------------------------------------------------------------------------------
4974-- | Simple filter/accessor for successful responses, when you want to
@@ -68,6 +93,13 @@ reqFailure (ResponseFailure _ s _) = Just s
6893reqFailure (RequestFailure _ s) = Just s
6994reqFailure _ = Nothing
7095
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+
71103
72104------------------------------------------------------------------------------
73105-- | Simple filter/accessor for the raw XHR response
@@ -76,13 +108,12 @@ response (ResponseSuccess _ _ x) = Just x
76108response (ResponseFailure _ _ x) = Just x
77109response _ = Nothing
78110
79−
80111------------------------------------------------------------------------------
81−instance Functor (ReqResult tag) where
82− fmap f (ResponseSuccess tag a xhr) = ResponseSuccess tag (f a) xhr
83− fmap _ (ResponseFailure tag r x) = ResponseFailure tag r x
84− fmap _ (RequestFailure tag r) = RequestFailure tag r
85−
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
86117
87118-------------------------------------------------------------------------------
88119-- | You must wrap the parameter of a QueryParam endpoint with 'QParam' to
@@ -136,7 +167,7 @@ reqToReflexRequest
136167 => Text
137168 -> Dynamic t BaseUrl
138169 -> Req t
139− -> (Dynamic t (Either Text (XhrRequest XhrPayload)))
170+ -> Dynamic t (Either Text (XhrRequest XhrPayload))
140171reqToReflexRequest reqMeth reqHost req =
141172 let t :: Dynamic t [Either Text Text]
142173 t = sequence $ reverse $ reqPathParts req
@@ -148,18 +179,22 @@ reqToReflexRequest reqMeth reqHost req =
148179 urlParts = fmap sequence t
149180
150181 urlPath :: Dynamic t (Either Text Text)
151− urlPath = (fmap.fmap) (T.intercalate "/") urlParts
182+ urlPath = (fmap.fmap)
183+ (T.intercalate "/" . fmap escape)
184+ urlParts
152185
153186 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
154187 queryPartString (pName, qp) = case qp of
155188 QueryPartParam p -> ffor p $ \case
156189 Left e -> Just (Left e)
157− Right (Just a) -> Just (Right $ pName <> "=" <> a)
190+ Right (Just a) -> Just (Right $ pName <> "=" <> escape a)
158191 Right Nothing -> Nothing
159192 QueryPartParams ps -> ffor ps $ \pStrings ->
160193 if null pStrings
161194 then Nothing
162− else Just $ Right (T.intercalate "&" (fmap (\p -> pName <> "=" <> p) pStrings))
195+ else Just . Right
196+ . T.intercalate "&"
197+ $ fmap (\p -> pName <> "=" <> escape p) pStrings
163198 QueryPartFlag fl -> ffor fl $ \case
164199 True -> Just $ Right pName
165200 False -> Nothing
@@ -194,10 +229,10 @@ reqToReflexRequest reqMeth reqHost req =
194229 Right $ XhrRequestConfig
195230 { _xhrRequestConfig_sendData = bytesToPayload bBytes
196231 , _xhrRequestConfig_headers =
197− Map.insert "Content-Type" bCT (Map.fromList hs)
232+ Map.insert "Content-Type" bCT (Map.fromList hs)
198233 , _xhrRequestConfig_user = Nothing
199234 , _xhrRequestConfig_password = Nothing
200− , _xhrRequestConfig_responseType = Nothing
235+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
201236 , _xhrRequestConfig_withCredentials = False
202237 , _xhrRequestConfig_responseHeaders = def
203238 }
@@ -209,8 +244,8 @@ reqToReflexRequest reqMeth reqHost req =
209244 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
210245 , _xhrRequestConfig_user = Nothing
211246 , _xhrRequestConfig_password = Nothing
212− , _xhrRequestConfig_responseType = Nothing
213− , _xhrRequestConfig_sendData = ""
247+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
248+ , _xhrRequestConfig_sendData = mempty
214249 , _xhrRequestConfig_withCredentials = False
215250 }
216251 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
@@ -237,41 +272,57 @@ reqToReflexRequest reqMeth reqHost req =
237272displayHttpRequest :: Text -> Text
238273displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
239274
240−-- | This function actually performs the request.
275+-- | This function performs the request
241276performRequests :: forall t m f tag.(SupportsServantReflex t m, Traversable f)
242277 => Text
243278 -> Dynamic t (f (Req t))
244279 -> Dynamic t BaseUrl
280+ -> ClientOptions
245281 -> Event t tag
246282 -> m (Event t (tag, f (Either Text XhrResponse)))
247−performRequests reqMeth rs reqHost trigger = do
248− -- let xhrReqs = sequence $ (\r -> reqToReflexRequest reqMeth r reqHost) <$> rs :: Dynamic t (f (Either Text (XhrRequest XhrPayload)))
249− let xhrReqs = join $ (\(fxhr :: f (Req t)) -> sequence $ reqToReflexRequest reqMeth reqHost <$> fxhr) <$> rs
250− let reqs = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) xhrReqs trigger
251− 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
252293 return $ getCompose <$> resps
253294
254−-- | 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.
255298performSomeRequestsAsync
256299 :: (MonadIO (Performable m),
300+ MonadJSM (Performable m),
301+#if !MIN_VERSION_reflex_dom_core(0,7,0)
257302 HasWebView (Performable m),
303+#endif
258304 PerformEvent t m,
259305 TriggerEvent t m,
260306 Traversable f,
261− IsXhrPayload a)
262− => Event t (f (Either Text (XhrRequest a)))
307+ IsXhrPayload a,
308+ Show a
309+ )
310+ => ClientOptions
311+ -> Event t (f (Either Text (XhrRequest a)))
263312 -> m (Event t (f (Either Text XhrResponse)))
264−performSomeRequestsAsync = performSomeRequestsAsync' newXMLHttpRequest . fmap return
313+performSomeRequestsAsync opts =
314+ performSomeRequestsAsync' opts newXMLHttpRequest . fmap return
265315
266316
267317------------------------------------------------------------------------------
268318-- | A modified version or Reflex.Dom.Xhr.performRequestsAsync
269319-- that accepts 'f (Either e (XhrRequestb))' events
270320performSomeRequestsAsync'
271− :: (MonadIO (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f)
272− => (XhrRequest b -> (a -> IO ()) -> Performable m XMLHttpRequest)
321+ :: (MonadJSM (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f, Show b)
322+ => ClientOptions
323+ -> (XhrRequest b -> (a -> JSM ()) -> Performable m XMLHttpRequest)
273324 -> Event t (Performable m (f (Either Text (XhrRequest b)))) -> m (Event t (f (Either Text a)))
274−performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
325+performSomeRequestsAsync' opts newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
275326 rs <- hrs
276327 resps <- forM rs $ \r -> case r of
277328 Left e -> do
@@ -279,70 +330,17 @@ performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb ->
279330 return resp
280331 Right r' -> do
281332 resp <- liftIO newEmptyMVar
282− _ <- newXhr r' $ liftIO . putMVar resp . Right
333+ r'' <- liftJSM $ (optsRequestFixup opts) r'
334+ _ <- newXhr r'' $ liftIO . putMVar resp . Right
283335 return resp
284336 _ <- liftIO $ forkIO $ cb =<< forM resps takeMVar
285337 return ()
286338
287339
288340
289−-- | This function actually performs the request.
290−performRequest :: forall t m tag .(SupportsServantReflex t m)
291− => Text
292− -> (Req t)
293− -> Dynamic t BaseUrl
294− -> Event t tag
295− -> m (Event t (tag, XhrResponse), Event t (tag, Text))
296−performRequest reqMeth req reqHost trigger = do
297−
298− let xhrReq = reqToReflexRequest reqMeth reqHost req
299− let reqs = attachPromptlyDynWith (flip (,)) xhrReq trigger
300− okReqs = fmapMaybe (\(t,e) -> either (const Nothing) (Just . (t,)) e) reqs
301− badReqs = fmapMaybe (\(t,e) -> either (Just . (t,)) (const Nothing) e) reqs
302−
303− resps <- performRequestsAsync okReqs
304−
305− return (resps, badReqs)
306−
307−
308−type XhrPayload = T.Text
341+type XhrPayload = ByteString
309342bytesToPayload :: BL.ByteString -> XhrPayload
310−bytesToPayload = TE.decodeUtf8 . BL.toStrict
311−
312−
313−-- performRequestNoBody :: forall t m tag.(SupportsServantReflex t m)
314−-- => Text
315−-- -> Req t
316−-- -> Dynamic t BaseUrl
317−-- -> Event t tag -> m (Event t (ReqResult tag NoContent))
318−-- performRequestNoBody reqMeth req reqHost trigger = do
319−-- (resp, badReq) <- performRequest reqMeth req reqHost trigger
320−-- let decodeResp = const $ Right NoContent
321−-- return $ leftmost [ fmap (evalResponse decodeResp) resp
322−-- , fmap (uncurry RequestFailure) badReq
323−-- ]
324−
325−
326−-- performRequestCT
327−-- :: (SupportsServantReflex t m,
328−-- MimeUnrender ct a)
329−-- => Proxy ct
330−-- -> Text
331−-- -> Req t
332−-- -> Dynamic t BaseUrl
333−-- -> Event t tag
334−-- -> m (Event t (ReqResult tag a))
335−-- performRequestCT ct reqMeth req reqHost trigger = do
336−-- (resp, badReq) <- performRequest reqMeth req reqHost trigger
337−-- let decodeResp x = first T.pack .
338−-- mimeUnrender ct .
339−-- BL.fromStrict .
340−-- TE.encodeUtf8 =<< note "No body text"
341−-- (_xhrResponse_responseText x)
342−
343−-- return $ leftmost [fmap (evalResponse decodeResp) resp
344−-- , fmap (uncurry RequestFailure) badReq
345−-- ]
343+bytesToPayload = BL.toStrict
346344
347345
348346performRequestsCT
@@ -352,19 +350,20 @@ performRequestsCT
352350 -> Text
353351 -> Dynamic t (f (Req t))
354352 -> Dynamic t BaseUrl
353+ -> ClientOptions
355354 -> Event t tag
356355 -> m (Event t (f (ReqResult tag a)))
357−performRequestsCT ct reqMeth reqs reqHost trigger = do
358− resps <- performRequests reqMeth reqs reqHost trigger
359− let decodeResp x = first T.pack .
360− mimeUnrender ct .
361− BL.fromStrict .
362− TE.encodeUtf8 =<< note "No body text"
363− (_xhrResponse_responseText x)
356+performRequestsCT ct reqMeth reqs reqHost opts trigger = do
357+ resps <- performRequests reqMeth reqs reqHost opts trigger
358+ let decodeResp (Just (XhrResponseBody_ArrayBuffer x)) =
359+ first T.pack .
360+ mimeUnrender ct $
361+ BL.fromStrict x
362+ decodeResp _ = Left "No body"
364363 return $ fmap
365364 (\(t,rs) -> ffor rs $ \r -> case r of
366365 Left e -> RequestFailure t e
367− Right g -> evalResponse decodeResp (t,g)
366+ Right g -> evalResponse (decodeResp . _xhrResponse_response) (t,g)
368367 )
369368 resps
370369
@@ -375,10 +374,11 @@ performRequestsNoBody
375374 => Text
376375 -> Dynamic t (f (Req t))
377376 -> Dynamic t BaseUrl
377+ -> ClientOptions
378378 -> Event t tag
379379 -> m (Event t (f (ReqResult tag NoContent)))
380−performRequestsNoBody reqMeth reqs reqHost trigger = do
381− resps <- performRequests reqMeth reqs reqHost trigger
380+performRequestsNoBody reqMeth reqs reqHost opts trigger = do
381+ resps <- performRequests reqMeth reqs reqHost opts trigger
382382 let decodeResp = const $ Right NoContent
383383 return $ ffor resps $ \(tag,rs) -> ffor rs $ \r -> case r of
384384 Left e -> RequestFailure tag e
@@ -391,7 +391,8 @@ evalResponse
391391 -> (tag, XhrResponse)
392392 -> ReqResult tag a
393393evalResponse decode (tag, xhr) =
394− let okStatus = _xhrResponse_status xhr < 400
394+ let status = _xhrResponse_status xhr
395+ okStatus = status >= 200 && status < 400
395396 errMsg = fromMaybe
396397 ("Empty response with error code " <>
397398 T.pack (show $ _xhrResponse_status xhr))
@@ -404,7 +405,17 @@ evalResponse decode (tag, xhr) =
404405 else ResponseFailure tag errMsg xhr
405406 in respPayld
406407
408+------------------------------------------------------------------------------
409+-- | Utility for simultaneously accessing/filtering Success and Failure
410+-- response 'Event's,
411+fanReqResult :: Reflex t => Event t (ReqResult tag a) -> (Event t Text, Event t a)
412+fanReqResult = fmapMaybe reqFailure &&& fmapMaybe reqSuccess
407413
414+------------------------------------------------------------------------------
415+-- | Utility for simultaneously accessing/filtering Success and Failure
416+-- response 'Event's, but keeping the request tag
417+fanReqResult' :: Reflex t => Event t (ReqResult tag a) -> (Event t (tag, Text), Event t (tag, a))
418+fanReqResult' = fmapMaybe reqFailure' &&& fmapMaybe reqSuccess'
408419
409420
410421note :: e -> Maybe a -> Either e a
@@ -413,3 +424,9 @@ note e = maybe (Left e) Right
413424fmapL :: (e -> e') -> Either e a -> Either e' a
414425fmapL _ (Right a) = Right a
415426fmapL f (Left e) = Left (f e)
427+
428+builderToText :: Builder.Builder -> T.Text
429+builderToText = TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString
430+
431+escape :: T.Text -> T.Text
432+escape = T.pack . N.escapeURIString (not . N.isReserved) . T.unpack . TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString . toEncodedUrlPiece
src/Servant/Reflex.hs+206−107
@@ -1,24 +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 #-}
15−{-# LANGUAGE OverloadedStrings #-}
16−{-# LANGUAGE PolyKinds #-}
17−{-# LANGUAGE ScopedTypeVariables #-}
18−{-# LANGUAGE TupleSections #-}
19−{-# LANGUAGE TypeFamilies #-}
20−{-# LANGUAGE TypeOperators #-}
21−{-# LANGUAGE UndecidableInstances #-}
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
2221
2322-- #include "overlapping-compat.h"
2423-- | This module provides 'client' which can automatically generate
@@ -26,46 +25,57 @@
2625-- API.
2726module Servant.Reflex
2827 ( client
28+ , clientWithOpts
29+ , clientWithOptsAndResultHandler
30+ , clientWithRoute
31+ , clientWithRouteAndResultHandler
2932 , BuildHeaderKeysTo(..)
3033 , toHeaders
31− , HasClient(..)
34+ , HasClient
35+ , Client
3236 , module Servant.Common.Req
3337 , module Servant.Common.BaseUrl
3438 ) where
3539
3640------------------------------------------------------------------------------
3741import Control.Applicative
38−import Data.Monoid ((<>))
39−import qualified Data.Set as Set
40−import qualified Data.Text.Encoding as E
41−import Data.CaseInsensitive (mk)
42+import qualified Data.CaseInsensitive as CI
4243import Data.Functor.Identity
43−import Data.Proxy (Proxy (..))
4444import qualified Data.Map as Map
45+import Data.Monoid ((<>))
46+import Data.Proxy (Proxy (..))
47+import qualified Data.Set as Set
4548import Data.Text (Text)
4649import qualified Data.Text as T
50+import qualified Data.Text.Encoding as E
51+import GHC.Exts (Constraint)
4752import GHC.TypeLits (KnownSymbol, symbolVal)
48−import Servant.API ((:<|>)(..),(:>), BasicAuth,
49− BasicAuthData, BuildHeadersTo(..),
50− Capture, contentType, Header,
51− Headers(..), HttpVersion, IsSecure,
52− MimeRender(..), MimeUnrender,
53− NoContent, QueryFlag, QueryParam,
54− QueryParams, Raw, ReflectMethod(..),
53+import Servant.API ((:<|>) (..), (:>), BasicAuth,
54+ BasicAuthData, BuildHeadersTo (..),
55+ Capture, Header, Headers (..),
56+ HttpVersion, IsSecure,
57+ MimeRender (..), MimeUnrender,
58+ NoContent, QueryFlag, QueryParam',
59+ QueryParams, Raw, ReflectMethod (..),
5560 RemoteHost, ReqBody,
56− ToHttpApiData(..), Vault, Verb)
57−
58−import Reflex.Dom (Dynamic, Event, Reflex,
59− XhrRequest(..),
60− XhrResponseHeaders(..),
61− XhrResponse(..), attachPromptlyDynWith, constDyn, ffor, fmapMaybe,
62− leftmost, performRequestsAsync,
63− )
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)
6472------------------------------------------------------------------------------
6573import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
6674 showBaseUrl,
6775 SupportsServantReflex)
68−import Servant.Common.Req (Req, ReqResult(..), QParam(..),
76+import Servant.Common.Req (ClientOptions(..),
77+ defaultClientOptions,
78+ Req, ReqResult(..), QParam(..),
6979 QueryPart(..), addHeader, authData,
7080 defReq, evalResponse, prependToPathParts,
7181 -- performRequestCT,
@@ -75,8 +85,10 @@ import Servant.Common.Req (Req, ReqResult(..), QParam(..),
7585 performSomeRequestsAsync,
7686 qParamToQueryPart, reqBody,
7787 reqSuccess, reqFailure,
78− reqMethod, respHeaders, response,
79− qParams)
88+ reqMethod, respHeaders,
89+ response,
90+ reqTag,
91+ qParams, withCredentials)
8092
8193
8294-- * Accessing APIs as a Client
@@ -91,28 +103,75 @@ import Servant.Common.Req (Req, ReqResult(..), QParam(..),
91103-- >
92104-- > getAllBooks :: Event t l -> m (Event t (l, ReqResult [Book]))
93105-- > postNewBook :: Dynamic t (Maybe Book) -> Event t l
94−-- -> m (Event t (l, ReqResult Book)))
106+-- > -> m (Event t (l, ReqResult Book)))
95107-- > (getAllBooks :<|> postNewBook) = client myApi host
96108-- > where host = constDyn $ BaseUrl Http "localhost" 8080
97−client :: (HasClient t m layout tag)
98− => Proxy layout -> Proxy m -> Proxy tag -> Dynamic t BaseUrl -> Client t m layout tag
99−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
100141
101142
102143-- | This class lets us define how each API combinator
103144-- influences the creation of an HTTP request. It's mostly
104145-- an internal class, you can just use 'client'.
105−class HasClient t m layout (tag :: *) where
146+class Monad m => HasClient t m layout (tag :: *) where
106147 type Client t m layout tag :: *
107− 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
108167
109168
110169instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b) tag where
111170 type Client t m (a :<|> b) tag = Client t m a tag :<|> Client t m b tag
112171
113− clientWithRoute Proxy q pTag req baseurl =
114− clientWithRoute (Proxy :: Proxy a) q pTag req baseurl :<|>
115− 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
116175
117176
118177-- Capture. Example:
@@ -133,11 +192,9 @@ instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout ta
133192 type Client t m (Capture capture a :> sublayout) tag =
134193 Dynamic t (Either Text a) -> Client t m sublayout tag
135194
136− clientWithRoute Proxy q t req baseurl val =
137− clientWithRoute (Proxy :: Proxy sublayout)
138− q t
139− (prependToPathParts p req)
140− 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
141198 where p = (fmap . fmap) (toUrlPiece) val
142199
143200
@@ -150,9 +207,8 @@ instance {-# OVERLAPPABLE #-}
150207 Event t tag -> m (Event t (ReqResult tag a))
151208 -- TODO how to access input types here?
152209 -- ExceptT ServantError IO a
153− clientWithRoute Proxy _ _ req baseurl trigs =
154− -- performRequestCT (Proxy :: Proxy ct) method req' baseurl trigs
155− fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity $ 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
156212 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
157213 req' = req { reqMethod = method }
158214
@@ -165,29 +221,33 @@ instance {-# OVERLAPPING #-}
165221 Event t tag -> m (Event t (ReqResult tag NoContent))
166222 -- TODO: how to access input types here?
167223 -- ExceptT ServantError IO NoContent
168− clientWithRoute Proxy _ _ req baseurl =
169− (fmap . fmap) runIdentity . performRequestsNoBody method (constDyn $ Identity req) baseurl
224+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
225+ wrap =<< fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req) baseurl opts trigs
170226 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
171227
172228
173229toHeaders :: BuildHeadersTo ls => ReqResult tag a -> ReqResult tag (Headers ls a)
174230toHeaders r =
175− let toBS = E.encodeUtf8
176− hdrs = maybe []
177− (\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))
178233 (Map.toList $ _xhrResponse_headers xhr))
179234 (response r)
180235 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
181236
237+
182238class BuildHeaderKeysTo hs where
183− buildHeaderKeysTo :: Proxy hs -> [T.Text]
239+ buildHeaderKeysTo :: Proxy hs -> [CI.CI T.Text]
184240
185241instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
186242 where buildHeaderKeysTo _ = []
187243
188244instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
189− => BuildHeaderKeysTo '[(Header h v) ': xs] where
190− 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+
191251
192252-- HEADERS Verb (Content) --
193253-- Headers combinator not treated in fully general case,
@@ -202,10 +262,10 @@ instance {-# OVERLAPPABLE #-}
202262 ) => HasClient t m (Verb method status cts' (Headers ls a)) tag where
203263 type Client t m (Verb method status cts' (Headers ls a)) tag =
204264 Event t tag -> m (Event t (ReqResult tag (Headers ls a)))
205− clientWithRoute Proxy _ _ req baseurl trigs = do
265+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
206266 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
207− resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl trigs
208− return $ toHeaders <$> resp
267+ resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl opts trigs
268+ wrap $ toHeaders <$> resp
209269 where req' = req { respHeaders =
210270 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
211271 }
@@ -218,10 +278,10 @@ instance {-# OVERLAPPABLE #-}
218278 ) => HasClient t m (Verb method status cts (Headers ls NoContent)) tag where
219279 type Client t m (Verb method status cts (Headers ls NoContent)) tag
220280 = Event t tag -> m (Event t (ReqResult tag (Headers ls NoContent)))
221− clientWithRoute Proxy _ _ req baseurl trigs = do
281+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
222282 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
223− resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl trigs
224− return $ toHeaders <$> resp
283+ resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl opts trigs
284+ wrap $ toHeaders <$> resp
225285 where req' = req {respHeaders =
226286 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
227287 }
@@ -248,11 +308,11 @@ instance (KnownSymbol sym, ToHttpApiData a,
248308 type Client t m (Header sym a :> sublayout) tag =
249309 Dynamic t (Either Text a) -> Client t m sublayout tag
250310
251− clientWithRoute Proxy q t req baseurl eVal =
252− clientWithRoute (Proxy :: Proxy sublayout)
253− q t
254− (Servant.Common.Req.addHeader hname eVal req)
255− 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
256316 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
257317
258318
@@ -266,8 +326,21 @@ instance HasClient t m sublayout tag
266326 type Client t m (HttpVersion :> sublayout) tag =
267327 Client t m sublayout tag
268328
269− clientWithRoute Proxy q t =
270− 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+
343+
271344
272345
273346-- | If you use a 'QueryParam' in one of your endpoints in your API,
@@ -297,15 +370,15 @@ instance HasClient t m sublayout tag
297370-- > -- 'getBooksBy Nothing' for all books
298371-- > -- 'getBooksBy (Just "Isaac Asimov")' to get all books by Isaac Asimov
299372instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex t)
300− => HasClient t m (QueryParam sym a :> sublayout) tag where
373+ => HasClient t m (QueryParam' mods sym a :> sublayout) tag where
301374
302− type Client t m (QueryParam sym a :> sublayout) tag =
375+ type Client t m (QueryParam' mods sym a :> sublayout) tag =
303376 Dynamic t (QParam a) -> Client t m sublayout tag
304377
305378 -- if mparam = Nothing, we don't add it to the query string
306− clientWithRoute Proxy q t req baseurl mparam =
307− clientWithRoute (Proxy :: Proxy sublayout) q t
308− (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
309382
310383 where pname = symbolVal (Proxy :: Proxy sym)
311384 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
@@ -349,8 +422,8 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
349422 type Client t m (QueryParams sym a :> sublayout) tag =
350423 Dynamic t [a] -> Client t m sublayout tag
351424
352− clientWithRoute Proxy q t req baseurl paramlist =
353− 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
354427
355428 where req' = req { qParams = (T.pack pname, params') : qParams req }
356429 pname = symbolVal (Proxy :: Proxy sym)
@@ -389,8 +462,8 @@ instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
389462 type Client t m (QueryFlag sym :> sublayout) tag =
390463 Dynamic t Bool -> Client t m sublayout tag
391464
392− clientWithRoute Proxy q t req baseurl flag =
393− 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
394467
395468 where req' = req { qParams = thisPair : qParams req }
396469 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
@@ -404,7 +477,7 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
404477 -> Event t tag
405478 -> m (Event t (ReqResult tag ()))
406479
407− clientWithRoute _ _ _ _ baseurl xhrs triggers = do
480+ clientWithRouteAndResultHandler _ _ _ _ baseurl _ wrap xhrs triggers = do
408481
409482 let xhrs' = liftA2 (\x path -> case x of
410483 Left e -> Left e
@@ -415,7 +488,7 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
415488 okReq = fmapMaybe (\(t,x) -> either (const Nothing) (Just . (t,)) x) xhrs'' :: Event t (tag, XhrRequest ())
416489
417490 resps <- performRequestsAsync okReq
418− return $ leftmost [ uncurry RequestFailure <$> badReq
491+ wrap $ leftmost [ uncurry RequestFailure <$> badReq
419492 , evalResponse (const $ Right ()) <$> resps
420493 ]
421494
@@ -446,8 +519,8 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
446519 type Client t m (ReqBody (ct ': cts) a :> sublayout) tag =
447520 Dynamic t (Either Text a) -> Client t m sublayout tag
448521
449− clientWithRoute Proxy q t req baseurl body =
450− 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
451524 where req' = req { reqBody = bodyBytesCT }
452525 ctProxy = Proxy :: Proxy ct
453526 ctString = T.pack $ show $ contentType ctProxy
@@ -461,9 +534,9 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
461534instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient t m (path :> sublayout) tag where
462535 type Client t m (path :> sublayout) tag = Client t m sublayout tag
463536
464− clientWithRoute Proxy q t req baseurl =
465− clientWithRoute (Proxy :: Proxy sublayout) q t
466− (prependToPathParts (pure (Right $ T.pack p)) req) 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
467540
468541 where p = symbolVal (Proxy :: Proxy path)
469542
@@ -471,23 +544,23 @@ instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient
471544instance HasClient t m api tag => HasClient t m (Vault :> api) tag where
472545 type Client t m (Vault :> api) tag = Client t m api tag
473546
474− clientWithRoute Proxy q t req baseurl =
475− clientWithRoute (Proxy :: Proxy api) q t req baseurl
547+ clientWithRouteAndResultHandler Proxy =
548+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
476549
477550
478551instance HasClient t m api tag => HasClient t m (RemoteHost :> api) tag where
479552 type Client t m (RemoteHost :> api) tag = Client t m api tag
480553
481− clientWithRoute Proxy q t req baseurl =
482− clientWithRoute (Proxy :: Proxy api) q t req baseurl
554+ clientWithRouteAndResultHandler Proxy =
555+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
483556
484557
485558
486559instance HasClient t m api tag => HasClient t m (IsSecure :> api) tag where
487560 type Client t m (IsSecure :> api) tag = Client t m api tag
488561
489− clientWithRoute Proxy q t req baseurl =
490− clientWithRoute (Proxy :: Proxy api) q t req baseurl
562+ clientWithRouteAndResultHandler Proxy =
563+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
491564
492565
493566instance (HasClient t m api tag, Reflex t)
@@ -496,8 +569,8 @@ instance (HasClient t m api tag, Reflex t)
496569 type Client t m (BasicAuth realm usr :> api) tag = Dynamic t (Maybe BasicAuthData)
497570 -> Client t m api tag
498571
499− clientWithRoute Proxy q t req baseurl authdata =
500− 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
501574 where
502575 req' = req { authData = Just authdata }
503576
@@ -523,3 +596,29 @@ non-empty lists, but is otherwise more specific, no instance will be overall
523596more specific. This in turn generally means adding yet another instance (one
524597for empty and one for non-empty lists).
525598-}
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
src/Servant/Reflex/Multi.hs+82−53
@@ -16,12 +16,15 @@
1616module Servant.Reflex.Multi (
1717 -- * Compute servant client functions
1818 clientA
19+ , clientWithOptsA
1920 , BaseUrl(..)
2021 , Scheme(..)
2122
2223 -- * Build QueryParam arguments
2324 , QParam(..)
2425
26+ -- * Access response data
27+ , withCredentials
2528
2629 -- * Access response data
2730 , ReqResult(..)
@@ -34,40 +37,45 @@ module Servant.Reflex.Multi (
3437 ) where
3538
3639------------------------------------------------------------------------------
37−import Control.Applicative (liftA2)
38−import Data.Functor.Compose (Compose (..), getCompose)
39−import Data.Proxy (Proxy (..))
40−import qualified Data.Set as Set
41−import Data.Text (Text)
42−import qualified Data.Text as T
43−import qualified Data.Text.Encoding as E
44−import GHC.TypeLits (KnownSymbol, symbolVal)
45−import Servant.API ((:<|>) (..), (:>), BasicAuth,
46− BasicAuthData, BuildHeadersTo (..),
47− Capture, Header, Headers (..),
48− HttpVersion, IsSecure, MimeRender (..),
49− MimeUnrender, NoContent, QueryFlag,
50− QueryParam, QueryParams, Raw,
51− ReflectMethod (..), RemoteHost,
52− ReqBody, ToHttpApiData (..), Vault,
53− Verb, contentType)
54−
55−import Reflex.Dom (Dynamic, Event, Reflex,
56− XhrRequest (..),
57− XhrResponseHeaders (..),
58− attachPromptlyDynWith, constDyn)
40+import Control.Applicative (liftA2)
41+import Data.Functor.Compose (Compose (..), getCompose)
42+import Data.Proxy (Proxy (..))
43+import qualified Data.Set as Set
44+import Data.Text (Text)
45+import qualified Data.Text as T
46+import qualified Data.Text.Encoding as E
47+import GHC.TypeLits (KnownSymbol, symbolVal)
48+import Servant.API ((:<|>) (..), (:>), BasicAuth,
49+ BasicAuthData, BuildHeadersTo (..),
50+ Capture, Header, Headers (..),
51+ HttpVersion, IsSecure,
52+ MimeRender (..), MimeUnrender,
53+ NoContent, QueryFlag, QueryParam,
54+ QueryParams, Raw, ReflectMethod (..),
55+ RemoteHost, ReqBody,
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)
5964------------------------------------------------------------------------------
6065import Servant.Common.BaseUrl (BaseUrl (..), Scheme (..),
6166 SupportsServantReflex)
62−import Servant.Common.Req (QParam (..), QueryPart (..), Req,
67+import Servant.Common.Req (ClientOptions,
68+ QParam (..), QueryPart (..), Req,
6369 ReqResult (..), addHeader, authData,
64− defReq, performRequestsCT,
70+ defReq,
71+ defaultClientOptions,
72+ performRequestsCT,
6573 performRequestsNoBody,
6674 performSomeRequestsAsync,
6775 prependToPathParts, qParamToQueryPart,
6876 qParams, reqBody, reqFailure,
6977 reqMethod, reqSuccess, reqSuccess',
70− respHeaders, response)
78+ respHeaders, response, withCredentials)
7179import Servant.Reflex (BuildHeaderKeysTo (..), toHeaders)
7280
7381
@@ -77,14 +85,24 @@ clientA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
7785 -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
7886clientA p q f tag baseurl =
7987 clientWithRouteMulti p q f tag (constDyn (pure defReq)) baseurl
88+ defaultClientOptions
89+
8090
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
8199
82100------------------------------------------------------------------------------
83101class HasClientMulti t m layout f (tag :: *) where
84102 type ClientMulti t m layout f tag :: *
85103 clientWithRouteMulti :: Proxy layout -> Proxy m -> Proxy f -> Proxy tag
86104 -> Dynamic t (f (Req t)) -> Dynamic t BaseUrl
87− -> ClientMulti t m layout f tag
105+ -> ClientOptions -> ClientMulti t m layout f tag
88106
89107
90108------------------------------------------------------------------------------
@@ -92,9 +110,9 @@ instance (HasClientMulti t m a f tag, HasClientMulti t m b f tag) =>
92110 HasClientMulti t m (a :<|> b) f tag where
93111 type ClientMulti t m (a :<|> b) f tag = ClientMulti t m a f tag :<|>
94112 ClientMulti t m b f tag
95− clientWithRouteMulti Proxy q f tag reqs baseurl =
96− clientWithRouteMulti (Proxy :: Proxy a) q f tag reqs baseurl :<|>
97− clientWithRouteMulti (Proxy :: Proxy b) q f tag reqs baseurl
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
98116
99117
100118------------------------------------------------------------------------------
@@ -107,8 +125,8 @@ instance (SupportsServantReflex t m,
107125 type ClientMulti t m (Capture capture a :> sublayout) f tag =
108126 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
109127
110− clientWithRouteMulti _ q f tag reqs baseurl vals =
111− 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
112130 where
113131 reqs' = (prependToPathParts <$> ps <*>) <$> reqs
114132 ps = (fmap . fmap . fmap) toUrlPiece vals
@@ -128,8 +146,8 @@ instance {-# OVERLAPPABLE #-}
128146 type ClientMulti t m (Verb method status cts' a) f tag =
129147 Event t tag -> m (Event t (f (ReqResult tag a)))
130148
131− clientWithRouteMulti _ _ _ _ reqs baseurl =
132− performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl
149+ clientWithRouteMulti _ _ _ _ reqs baseurl opts =
150+ performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts
133151 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
134152 reqs' = fmap (\r -> r { reqMethod = method }) <$> reqs
135153
@@ -143,8 +161,8 @@ instance {-# OVERLAPPING #-}
143161 Event t tag -> m (Event t (f (ReqResult tag NoContent)))
144162 -- TODO: how to access input types here?
145163 -- ExceptT ServantError IO NoContent
146− clientWithRouteMulti Proxy _ _ _ req baseurl =
147− performRequestsNoBody method req baseurl
164+ clientWithRouteMulti Proxy _ _ _ req baseurl opts =
165+ performRequestsNoBody method req baseurl opts
148166 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
149167
150168
@@ -158,9 +176,9 @@ instance {-# OVERLAPPABLE #-}
158176 ) => HasClientMulti t m (Verb method status cts' (Headers ls a)) f tag where
159177 type ClientMulti t m (Verb method status cts' (Headers ls a)) f tag =
160178 Event t tag -> m (Event t (f (ReqResult tag (Headers ls a))))
161− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
179+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
162180 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
163− resp <- performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl triggers :: m (Event t (f (ReqResult tag a)))
181+ resp <- performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts triggers :: m (Event t (f (ReqResult tag a)))
164182 return $ fmap toHeaders <$> resp
165183 where
166184 reqs' = fmap (\r ->
@@ -181,9 +199,9 @@ instance {-# OVERLAPPABLE #-}
181199 cts (Headers ls NoContent)) f tag where
182200 type ClientMulti t m (Verb method status cts (Headers ls NoContent)) f tag
183201 = Event t tag -> m (Event t (f (ReqResult tag (Headers ls NoContent))))
184− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
202+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
185203 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
186− resp <- performRequestsNoBody method reqs' baseurl triggers
204+ resp <- performRequestsNoBody method reqs' baseurl opts triggers
187205 return $ fmap toHeaders <$> resp
188206 where reqs' = fmap (\req ->
189207 req {respHeaders = OnlyHeaders (Set.fromList
@@ -203,11 +221,11 @@ instance (KnownSymbol sym,
203221 type ClientMulti t m (Header sym a :> sublayout) f tag =
204222 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
205223
206− clientWithRouteMulti Proxy f q tag reqs baseurl eVals =
224+ clientWithRouteMulti Proxy f q tag reqs baseurl opts eVals =
207225 clientWithRouteMulti (Proxy :: Proxy sublayout) f
208226 q tag
209227 reqs'
210− baseurl
228+ baseurl opts
211229 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
212230 reqs' = ((\eVal req -> Servant.Common.Req.addHeader hname eVal req)
213231 <$> eVals <*>) <$> reqs
@@ -224,6 +242,17 @@ instance HasClientMulti t m sublayout f tag
224242 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
225243
226244
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+
227256------------------------------------------------------------------------------
228257instance (KnownSymbol sym,
229258 ToHttpApiData a,
@@ -237,9 +266,9 @@ instance (KnownSymbol sym,
237266
238267 -- if mparam = Nothing, we don't add it to the query string
239268 -- TODO: Check the above comment
240− clientWithRouteMulti Proxy q f tag reqs baseurl mparams =
269+ clientWithRouteMulti Proxy q f tag reqs baseurl opts mparams =
241270 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
242− reqs' baseurl
271+ reqs' baseurl opts
243272
244273 where pname = symbolVal (Proxy :: Proxy sym)
245274 p prm = QueryPartParam $ fmap qParamToQueryPart prm
@@ -260,8 +289,8 @@ instance (KnownSymbol sym,
260289 type ClientMulti t m (QueryParams sym a :> sublayout) f tag =
261290 Dynamic t (f [a]) -> ClientMulti t m sublayout f tag
262291
263− clientWithRouteMulti Proxy q f tag reqs baseurl paramlists =
264− 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
265294
266295 where req' l r = r { qParams = (T.pack pname, params' (constDyn l)) : qParams r }
267296 pname = symbolVal (Proxy :: Proxy sym)
@@ -279,8 +308,8 @@ instance (KnownSymbol sym,
279308 type ClientMulti t m (QueryFlag sym :> sublayout) f tag =
280309 Dynamic t (f Bool) -> ClientMulti t m sublayout f tag
281310
282− clientWithRouteMulti Proxy q f' tag reqs baseurl flags =
283− 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
284313
285314 where req' f req = req { qParams = thisPair (constDyn f) : qParams req }
286315 thisPair f = (T.pack pName, QueryPartFlag f) :: (Text, QueryPart t)
@@ -294,10 +323,10 @@ instance (SupportsServantReflex t m,
294323 -> Event t tag
295324 -> m (Event t (f (ReqResult tag ())))
296325
297− clientWithRouteMulti _ _ _ _ _ _ rawReqs triggers = do
326+ clientWithRouteMulti _ _ _ _ _ _ opts rawReqs triggers = do
298327 let rawReqs' = sequence rawReqs :: Dynamic t (f (Either Text (XhrRequest ())))
299328 rawReqs'' = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) rawReqs' triggers
300− resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync rawReqs''
329+ resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync opts rawReqs''
301330 return resps
302331 where
303332 aux (tag, Right r) = ResponseSuccess tag () r
@@ -313,8 +342,8 @@ instance (MimeRender ct a,
313342 type ClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag =
314343 Dynamic t (f (Either Text a)) -> ClientMulti t m sublayout f tag
315344
316− clientWithRouteMulti Proxy q f tag reqs baseurl bodies =
317− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl
345+ clientWithRouteMulti Proxy q f tag reqs baseurl opts bodies =
346+ clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
318347 where req' b r = r { reqBody = bodyBytesCT (constDyn b) }
319348 ctProxy = Proxy :: Proxy ct
320349 ctString = T.pack $ show $ contentType ctProxy
@@ -365,8 +394,8 @@ instance (HasClientMulti t m api f tag, Reflex t, Applicative f)
365394 type ClientMulti t m (BasicAuth realm usr :> api) f tag = Dynamic t (f (Maybe BasicAuthData))
366395 -> ClientMulti t m api f tag
367396
368− clientWithRouteMulti Proxy q f tag reqs baseurl authdatas =
369− 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
370399 where
371400 req' a r = r { authData = Just (constDyn a) }
372401 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+20−5
@@ -2,14 +2,17 @@
22{-# LANGUAGE DeriveGeneric #-}
33{-# LANGUAGE OverloadedStrings #-}
44{-# LANGUAGE PolyKinds #-}
5+{-# LANGUAGE TypeApplications #-}
56{-# LANGUAGE TypeFamilies #-}
67{-# LANGUAGE TypeOperators #-}
78
89import Control.Monad.IO.Class (liftIO)
10+import Control.Monad.Reader (reader)
911import Data.Aeson
1012import Data.Bool
1113import Data.Char (toUpper)
1214import qualified Data.List as L
15+import Data.Maybe (fromMaybe)
1316import Data.Monoid
1417import Data.Proxy
1518import Data.Text hiding (head, length, map,
@@ -24,6 +27,7 @@ import Snap.Http.Server
2427import Servant
2528import Servant.Server
2629-- import Snap.Util.FileServe
30+import System.Environment (lookupEnv)
2731import API
2832import Snap
2933
@@ -39,7 +43,7 @@ instance ToJSON Greet
3943testApi :: Proxy API
4044testApi = Proxy
4145
42−data App = App
46+data App = App { appStaticDir :: String }
4347
4448-- Server-side handlers.
4549--
@@ -47,8 +51,10 @@ data App = App
4751-- that represents the API, are glued together using :<|>.
4852--
4953-- Each handler runs in the 'ExceptT ServantErr IO' monad.
50−server :: Server API (Handler App App)
51−server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|> 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
5258 where sayhi :: Maybe Text -> [Text] -> Bool -> Handler App App Text
5359 sayhi nm greetings withGusto = case nm of
5460 Nothing -> return ("Sorry, who are you?" :: Text)
@@ -69,18 +75,27 @@ server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|>
6975 putStrLn $ "qna got: " ++ show q
7076 T.putStrLn $ unQuestion q
7177 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
7285
7386-- Turn the server into a WAI app. 'serve' is provided by servant,
7487-- more precisely by the Servant.Server module.
7588test :: Handler App App ()
76−test = serveSnap testApi server
89+test = serveSnapWithContext testApi
90+ (BasicAuthCheck (\_ -> return @(Handler App App) (Authorized ())) :. EmptyContext) server
7791
7892initApp :: SnapletInit App App
7993initApp = makeSnaplet "myapp" "example" Nothing $ do
94+ staticDir <- fromMaybe "static" <$> liftIO (lookupEnv "STATIC_DIR")
8095 addRoutes [("", test)
8196 ,("", serveDirectory "static")
8297 ]
83− return App
98+ return (App staticDir)
8499
85100-- Put this all to work!
86101main :: 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+8−7
@@ -19,13 +19,14 @@ executable back
1919 main-is: Main.hs
2020 -- other-modules:
2121 -- 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
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.8 && < 0.11
28− , servant-snap >= 0.7.2 && < 0.8
29− , text >= 1.2 && < 1.3
28+ , servant >= 0.16 && < 0.18
29+ , servant-snap >= 0.8 && < 0.9
30+ , text >= 1.0 && < 1.3
3031 -- 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+ }