on master help sign in
33 files changed+801−479
since splitsnapshots
unifiedsplit
.gitignore+2 .gitmodules−12 .travis.yml+12−56 changelog.md → ChangeLog.md+28 README.md+70−33 build.sh−3 default.nix+21 deps/http-api-data−1 deps/reflex-platform−1 deps/servant−1 deps/servant-snap−1 exec/API.hs+1 exec/Example.hs+27−6 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−11 overrides.nix−9 servant-reflex.cabal+26−19 shell.nix+1 src/Servant/Common/BaseUrl.hs+5−6 src/Servant/Common/Req.hs+110−106 src/Servant/Reflex.hs+204−107 src/Servant/Reflex/Multi.hs+82−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+2
@@ -7,3 +7,5 @@ log
77*.stats
88out
99/.stack-work/
10+TAGS
11+dist-newstyle
.gitmodules−12
@@ -1,12 +0,0 @@
1−[submodule "deps/http-api-data"]
2− path = deps/http-api-data
3− url = https://github.com/fizruk/http-api-data
4−[submodule "deps/servant"]
5− path = deps/servant
6− url = https://github.com/haskell-servant/servant
7−[submodule "deps/servant-snap"]
8− path = deps/servant-snap
9− url = https://github.com/haskell-servant/servant-snap
10−[submodule "deps/reflex-platform"]
11− path = deps/reflex-platform
12− url = https://github.com/reflex-frp/reflex-platform
.travis.yml+12−56
@@ -1,61 +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− - sed -i 's/^jobs:/-- jobs:/' ${HOME}/.cabal/config
39− - deps/reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal configure -fExample && cabal build"
40− - deps/reflex-platform/work-on ghc ./testdriver --command "cd testdriver && cabal configure && cabal build"
41− - cd testserver && dist/build/back/back -p 8000 &
42− - sleep 3
43− - phantomjs --webdriver=127.0.0.1:4444 &
44− - 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"
4512
4613script:
47− - git config --global user.email "travis-ci@example.com"
48− - git config --global user.name "Travis-CI"
49− - ./build.sh
50− # - testdriver/dist/build/spec/spec
51−
52−cache:
53− directories:
54− - /nix
55− - $HOME/.cabal/packages
56− - $HOME/.cabal/store
57−
58−env:
59− global:
60− - ENCRYPTION_LABEL: "3c89d919c82e"
61− - 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+70−33
@@ -4,14 +4,19 @@
44
55## `servant-reflex` lets you share your `servant` APIs with the frontend
66
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.
9−
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
@@ -37,7 +43,16 @@ type API = "getint" :> Get '[JSON] Int
3743 (constDyn (BasePath "/"))
3844```
3945
40−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.
4156
4257```haskell
4358 -- No need to write these functions. servant-reflex creates them for you!
@@ -62,7 +77,13 @@ These client functions are computed from your API type. They manage serializatio
6277 -> m (Event t (ReqResult () Double))
6378```
6479
65−`ReqResult tag 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:
6687
6788```haskell
6889 -- ... continued ...
@@ -80,7 +101,8 @@ These client functions are computed from your API type. They manage serializatio
80101 dynText =<< holdDyn "" (leftmost [errs, const "" <$> ys])
81102```
82103
83−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:
84106
85107```haskell
86108 elClass "div" "int-demo" $ do
@@ -103,47 +125,53 @@ This example builds some input fields to enter API parameters, buttons to trigge
103125 display =<< holdDyn Nothing outputDouble
104126```
105127
106−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.
107133
108134
109135## Building the library and test server
110136
111−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:
112−
113−
114−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.
115144
116145```
117−git submodule update --init --recursive
118−./build.sh
146+nix build -f travis.nix testserver -o server
119147```
120148
121−Then build the test server:
122−
123−```
124−deps/reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal build"
125−```
126−
127−
128−## Running the example site
129−
130−The server must be run from the directory where static assets live:
149+Point it at the static directory and run it:
131150
132151```
133−cd testserver
134−dist/build/back/back -p 8001
152+STATIC_DIR=server/static server/back -p 8000
135153```
136154
137−And simply browse to `localhost:8001`
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.
138158
139−**For a larger example of a project that shares types between backend and frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
159+**For a larger example of a project that shares types between backend and
160+frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
140161
141162
142163## Tagging requests
143164
144−The input and the return type of a client function like `getDouble` are both event streams. The individual input events and responses occur at different times and aren't automatically paired up, but you can recover the relationship by tagging the requests.
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.
145169
146−So far we have used an `Event t ()` to trigger sending a request. If we choose e.g. `Double` for the third `Proxy` argument to `client`, then `Event t Double` will be used to trigger requests, and each `ReqResult` will carry the tag of its request. Imagine we wanted to display not just the last "double" from `doubleIt`, but a whole table of valid inputs and their doubled responses:
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:
147175
148176```haskell
149177 ...
@@ -173,7 +201,10 @@ So far we have used an `Event t ()` to trigger sending a request. If we choose e
173201
174202## Simultaneous requests
175203
176−'Servant.Reflex.Multi' provides an alternative client-generation function called 'clientA' (client applicative). Choose a container type that has both `Applicative` and `Traversable` instances, and pass it to `clientA` through another 'Proxy'. Our `sayHi` client function will then have this type:
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:
177208
178209```haskell
179210sayHi
@@ -184,4 +215,10 @@ sayHi
184215 -> m (Event t (f (ReqResult tag Text)))
185216```
186217
187−The dynamic params are each wrapped in `f`. For every firing of the trigger event `tag`, all of these parameters will be combined according to `f`'s applicative instance (when `f` is `[]`, you will get all combinations of all parameters taken together as a request; when `f` is 'ZipList', the Nth elemens of each parameters list will be taken together as a request). Using this interface, you can trigger many XHR's from a single event occurence, and expect the responses to be structured the same way as the requests.
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−deps/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/reflex-platformdeleted−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+27−6
@@ -1,3 +1,4 @@
1+{-# LANGUAGE DataKinds #-}
12{-# LANGUAGE FlexibleContexts #-}
23{-# LANGUAGE GADTs #-}
34{-# LANGUAGE OverloadedStrings #-}
@@ -14,12 +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
1719import GHC.TypeLits
1820import Servant.API
1921import API
2022import Data.Proxy
2123import Text.Read (readMaybe)
22−import Reflex.Dom hiding (run)
24+import Reflex.Dom.Core hiding (run, mainWidget)
25+import Reflex.Dom (mainWidget)
2326------------------------------------------------------------------------------
2427import Servant.Reflex
2528import Servant.Reflex.Multi
@@ -43,7 +46,7 @@ runMulti :: forall t m. (SupportsServantReflex t m,
4346runMulti = do
4447 url <- baseUrlWidget
4548 el "br" blank
46− let (_ :<|> _ :<|> sayHi :<|> dbl :<|> _ :<|> _ ) =
49+ let (_ :<|> _ :<|> sayHi :<|> dbl :<|> _ :<|> _ :<|> _ :<|> _ ) =
4750 clientA api (Proxy :: Proxy m) (Proxy :: Proxy []) (Proxy :: Proxy Int) url
4851
4952 num :: Dynamic t (Either Text Double) <- fmap (note "No read" . readMaybe . T.unpack) . value <$> textInput def
@@ -66,9 +69,12 @@ runMulti = do
6669 textInput def
6770 gust <- fmap (value) $ divClass "gusto-input" $ checkbox False def
6871 b <- button "Go"
69− r' <- sayHi (fmap QParamSome <$> nms) (fmap (:[]) $ grts) (constDyn [True, False]) (1 <$ b)
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')
7077
71− dynText =<< holdDyn "Waiting" (T.pack . show . catMaybes . fmap reqSuccess <$> r')
7278
7379 return ()
7480
@@ -91,8 +97,11 @@ run = mdo
9197 el "br" (return ())
9298
9399 -- Name the computed API client functions
94− let (getUnit :<|> getInt :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|> doRaw) =
95− client api (Proxy :: Proxy m) (Proxy :: Proxy Int) url
100+ let tweakRequest = ClientOptions $ \r -> do
101+ return $ r & withCredentials .~ True
102+ let (getUnit :<|> getInt :<|> sayhi :<|> dbl
103+ :<|> multi :<|> qna :<|> secret :<|> doRaw) =
104+ clientWithOpts api (Proxy :: Proxy m) (Proxy :: Proxy Int) url tweakRequest
96105
97106 c2 = client (Proxy :: Proxy ComprehensiveAPI) (Proxy :: Proxy m) (Proxy :: Proxy ()) url -- Just make sure this compiles for now
98107
@@ -177,6 +186,18 @@ run = mdo
177186 el "p" $
178187 dynText =<< holdDyn "No Answer" (unAnswer <$> fmapMaybe reqSuccess rr)
179188
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+
180201showXhrResponse :: XhrResponse -> Text
181202showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
182203 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−11
@@ -1,11 +0,0 @@
1−{ reflex-platform, ... }:
2−let
3− c2n = reflex-platform.cabal2nixResult;
4− dc = reflex-platform.lib.dontCheck;
5−in reflex-platform.ghc.override {
6− overrides = self: super: {
7− servant-snap = dc (self.callPackage (c2n deps/servant-snap) {});
8− heist = dc (self.callPackage (c2n deps/servant-snap/deps/snap/deps/heist) {});
9− xmlhtml = dc (self.callPackage (c2n deps/servant-snap/deps/snap/deps/xmlhtml) {});
10− };
11−}
overrides.nixdeleted−9
@@ -1,9 +0,0 @@
1−{ reflex-platform, ... }:
2−let
3− dc = reflex-platform.lib.dontCheck;
4− c2n = reflex-platform.cabal2nixResult;
5−in
6−reflex-platform.ghcjs.override {
7− overrides = self: super: {
8− };
9−}
servant-reflex.cabal+26−19
@@ -1,8 +1,8 @@
11Name: servant-reflex
2−Version: 0.3.1
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
@@ -17,37 +17,35 @@ Flag Example
1717
1818library
1919 exposed-modules:
20− Servant.Reflex
21− Servant.Reflex.Multi
22−
23− other-modules:
2420 Servant.Common.BaseUrl
2521 Servant.Common.Req
22+ Servant.Reflex
23+ Servant.Reflex.Multi
2624
2725 hs-source-dirs: src
2826 build-depends:
29− base >= 4.8 && < 4.10,
30− aeson >= 0.11 && < 1.0,
27+ base >= 4.8 && < 5,
3128 bytestring >= 0.10 && < 0.11,
3229 case-insensitive >= 1.2.0.4 && < 1.3,
33− containers >= 0.5.6 && < 0.6,
30+ containers >= 0.5.6 && < 0.7,
3431 data-default >= 0.5 && < 0.8,
35− exceptions >= 0.8 && < 0.9,
32+ exceptions >= 0.8 && < 0.11,
3633 ghcjs-dom >= 0.2 && < 0.10,
37− http-api-data >= 0.2 && < 0.4,
38− http-media >= 0.6 && < 0.7,
34+ http-api-data >= 0.3.6 && < 0.5,
35+ http-media >= 0.6 && < 0.9,
3936 jsaddle >= 0.8 && < 0.10,
4037 mtl >= 2.2.1 && < 2.3,
4138 network-uri >= 2.6 && < 2.7,
42− reflex >= 0.5 && < 0.6,
43− reflex-dom == 0.4 && < 0.5,
39+ reflex >= 0.5 && < 0.9,
40+ reflex-dom-core >= 0.6 && < 0.7,
4441 safe >= 0.3.9 && < 0.4,
45− servant >= 0.8 && < 0.11,
42+ servant >= 0.16 && < 0.18,
43+ servant-auth >= 0.2.1 && < 0.4,
4644 string-conversions >= 0.4 && < 0.5,
4745 text >= 1.2 && < 1.3,
4846 transformers >= 0.4 && < 0.6
4947
50− ghc-options: -Wall -fwarn-tabs -funbox-strict-fields -O2
48+ ghc-options: -Wall -fwarn-tabs -funbox-strict-fields
5149
5250 default-language: Haskell2010
5351
@@ -56,7 +54,16 @@ executable example
5654 buildable: True
5755 else
5856 buildable: False
59− build-depends: aeson, reflex, servant-reflex, base, scientific, servant, reflex-dom, text
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
6067 default-language: Haskell2010
6168 main-is: Example.hs
6269 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+5−6
@@ -28,7 +28,7 @@ import qualified Data.Text as T
2828import GHC.Generics
2929import Language.Javascript.JSaddle.Monad (MonadJSM)
3030import Reflex
31−import Reflex.Dom
31+import Reflex.Dom.Core
3232import Text.Read
3333
3434
@@ -85,15 +85,14 @@ baseUrlWidget = elClass "div" "base-url" $ do
8585 where pathWidget :: m (Dynamic t BaseUrl)
8686 pathWidget = do
8787 text "Url base path"
88− t <- textInput (def {_textInputConfig_attributes =
89− constDyn ("placeholder" =: "/a/b")})
88+ t <- inputElement def
9089 return $ BasePath <$> value t
9190 fullUrlWidget :: m (Dynamic t BaseUrl)
9291 fullUrlWidget = do
9392 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
94− srv <- textInput def {_textInputConfig_attributes = constDyn $ "placeholder" =: "example.com"}
93+ srv <- inputElement def
9594 text ":"
96− prt <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "80"}
95+ prt <- inputElement def
9796 port :: Dynamic t Int <- holdDyn 80 (fmapMaybe (readMaybe . T.unpack) $ updated (value prt))
98− path <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "a/b" }
97+ path <- inputElement def
9998 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
src/Servant/Common/Req.hs+110−106
@@ -4,19 +4,22 @@
44{-# LANGUAGE GADTs #-}
55{-# LANGUAGE OverloadedStrings #-}
66{-# LANGUAGE LambdaCase #-}
7+{-# LANGUAGE RankNTypes #-}
78{-# LANGUAGE ScopedTypeVariables #-}
89{-# LANGUAGE TupleSections #-}
910
1011module Servant.Common.Req where
1112
1213-------------------------------------------------------------------------------
13−import Control.Concurrent
1414import Control.Applicative (liftA2, liftA3)
15+import Control.Arrow ((&&&))
16+import Control.Concurrent
1517import Control.Monad (join)
1618import Control.Monad.IO.Class (MonadIO, liftIO)
17−import Data.Aeson
1819import Data.Bifunctor (first)
20+import qualified Data.ByteString.Builder as Builder
1921import qualified Data.ByteString.Lazy.Char8 as BL
22+import Data.ByteString (ByteString)
2023import qualified Data.Map as Map
2124import Data.Maybe (catMaybes, fromMaybe)
2225import Data.Functor.Compose
@@ -26,10 +29,9 @@ import Data.Text (Text)
2629import qualified Data.Text as T
2730import qualified Data.Text.Encoding as TE
2831import Data.Traversable (forM)
29−import Language.Javascript.JSaddle.Monad (JSM, MonadJSM)
30−import qualified Language.Javascript.JSaddle as JS
31−import Language.Javascript.JSaddle.Types (JSVal)
32−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)
3335import Servant.Common.BaseUrl (BaseUrl, showBaseUrl,
3436 SupportsServantReflex)
3537import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
@@ -50,6 +52,23 @@ data ReqResult tag a
5052 -- ^ A failure to construct the request tagged with 'tag' at trigger time
5153 deriving (Functor)
5254
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'
5372
5473------------------------------------------------------------------------------
5574-- | Simple filter/accessor for successful responses, when you want to
@@ -74,6 +93,13 @@ reqFailure (ResponseFailure _ s _) = Just s
7493reqFailure (RequestFailure _ s) = Just s
7594reqFailure _ = Nothing
7695
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+
77103
78104------------------------------------------------------------------------------
79105-- | Simple filter/accessor for the raw XHR response
@@ -141,7 +167,7 @@ reqToReflexRequest
141167 => Text
142168 -> Dynamic t BaseUrl
143169 -> Req t
144− -> (Dynamic t (Either Text (XhrRequest XhrPayload)))
170+ -> Dynamic t (Either Text (XhrRequest XhrPayload))
145171reqToReflexRequest reqMeth reqHost req =
146172 let t :: Dynamic t [Either Text Text]
147173 t = sequence $ reverse $ reqPathParts req
@@ -153,18 +179,22 @@ reqToReflexRequest reqMeth reqHost req =
153179 urlParts = fmap sequence t
154180
155181 urlPath :: Dynamic t (Either Text Text)
156− urlPath = (fmap.fmap) (T.intercalate "/") urlParts
182+ urlPath = (fmap.fmap)
183+ (T.intercalate "/" . fmap escape)
184+ urlParts
157185
158186 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
159187 queryPartString (pName, qp) = case qp of
160188 QueryPartParam p -> ffor p $ \case
161189 Left e -> Just (Left e)
162− Right (Just a) -> Just (Right $ pName <> "=" <> a)
190+ Right (Just a) -> Just (Right $ pName <> "=" <> escape a)
163191 Right Nothing -> Nothing
164192 QueryPartParams ps -> ffor ps $ \pStrings ->
165193 if null pStrings
166194 then Nothing
167− else Just $ Right (T.intercalate "&" (fmap (\p -> pName <> "=" <> p) pStrings))
195+ else Just . Right
196+ . T.intercalate "&"
197+ $ fmap (\p -> pName <> "=" <> escape p) pStrings
168198 QueryPartFlag fl -> ffor fl $ \case
169199 True -> Just $ Right pName
170200 False -> Nothing
@@ -199,10 +229,10 @@ reqToReflexRequest reqMeth reqHost req =
199229 Right $ XhrRequestConfig
200230 { _xhrRequestConfig_sendData = bytesToPayload bBytes
201231 , _xhrRequestConfig_headers =
202− Map.insert "Content-Type" bCT (Map.fromList hs)
232+ Map.insert "Content-Type" bCT (Map.fromList hs)
203233 , _xhrRequestConfig_user = Nothing
204234 , _xhrRequestConfig_password = Nothing
205− , _xhrRequestConfig_responseType = Nothing
235+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
206236 , _xhrRequestConfig_withCredentials = False
207237 , _xhrRequestConfig_responseHeaders = def
208238 }
@@ -214,8 +244,8 @@ reqToReflexRequest reqMeth reqHost req =
214244 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
215245 , _xhrRequestConfig_user = Nothing
216246 , _xhrRequestConfig_password = Nothing
217− , _xhrRequestConfig_responseType = Nothing
218− , _xhrRequestConfig_sendData = ""
247+ , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
248+ , _xhrRequestConfig_sendData = mempty
219249 , _xhrRequestConfig_withCredentials = False
220250 }
221251 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
@@ -242,21 +272,29 @@ reqToReflexRequest reqMeth reqHost req =
242272displayHttpRequest :: Text -> Text
243273displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
244274
245−-- | This function actually performs the request.
275+-- | This function performs the request
246276performRequests :: forall t m f tag.(SupportsServantReflex t m, Traversable f)
247277 => Text
248278 -> Dynamic t (f (Req t))
249279 -> Dynamic t BaseUrl
280+ -> ClientOptions
250281 -> Event t tag
251282 -> m (Event t (tag, f (Either Text XhrResponse)))
252−performRequests reqMeth rs reqHost trigger = do
253− -- let xhrReqs = sequence $ (\r -> reqToReflexRequest reqMeth r reqHost) <$> rs :: Dynamic t (f (Either Text (XhrRequest XhrPayload)))
254− let xhrReqs = join $ (\(fxhr :: f (Req t)) -> sequence $ reqToReflexRequest reqMeth reqHost <$> fxhr) <$> rs
255− let reqs = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) xhrReqs trigger
256− 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
257293 return $ getCompose <$> resps
258294
259−-- | 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.
260298performSomeRequestsAsync
261299 :: (MonadIO (Performable m),
262300 MonadJSM (Performable m),
@@ -264,20 +302,25 @@ performSomeRequestsAsync
264302 PerformEvent t m,
265303 TriggerEvent t m,
266304 Traversable f,
267− IsXhrPayload a)
268− => Event t (f (Either Text (XhrRequest a)))
305+ IsXhrPayload a,
306+ Show a
307+ )
308+ => ClientOptions
309+ -> Event t (f (Either Text (XhrRequest a)))
269310 -> m (Event t (f (Either Text XhrResponse)))
270−performSomeRequestsAsync = performSomeRequestsAsync' newXMLHttpRequest . fmap return
311+performSomeRequestsAsync opts =
312+ performSomeRequestsAsync' opts newXMLHttpRequest . fmap return
271313
272314
273315------------------------------------------------------------------------------
274316-- | A modified version or Reflex.Dom.Xhr.performRequestsAsync
275317-- that accepts 'f (Either e (XhrRequestb))' events
276318performSomeRequestsAsync'
277− :: (MonadIO (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f)
278− => (XhrRequest b -> (a -> JSM ()) -> Performable m XMLHttpRequest)
319+ :: (MonadJSM (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f, Show b)
320+ => ClientOptions
321+ -> (XhrRequest b -> (a -> JSM ()) -> Performable m XMLHttpRequest)
279322 -> Event t (Performable m (f (Either Text (XhrRequest b)))) -> m (Event t (f (Either Text a)))
280−performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
323+performSomeRequestsAsync' opts newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
281324 rs <- hrs
282325 resps <- forM rs $ \r -> case r of
283326 Left e -> do
@@ -285,98 +328,40 @@ performSomeRequestsAsync' newXhr req = performEventAsync $ ffor req $ \hrs cb ->
285328 return resp
286329 Right r' -> do
287330 resp <- liftIO newEmptyMVar
288− _ <- newXhr r' $ liftIO . putMVar resp . Right
331+ r'' <- liftJSM $ (optsRequestFixup opts) r'
332+ _ <- newXhr r'' $ liftIO . putMVar resp . Right
289333 return resp
290334 _ <- liftIO $ forkIO $ cb =<< forM resps takeMVar
291335 return ()
292336
293337
294338
295−-- | This function actually performs the request.
296−performRequest :: forall t m tag .(SupportsServantReflex t m)
297− => Text
298− -> (Req t)
299− -> Dynamic t BaseUrl
300− -> Event t tag
301− -> m (Event t (tag, XhrResponse), Event t (tag, Text))
302−performRequest reqMeth req reqHost trigger = do
303−
304− let xhrReq = reqToReflexRequest reqMeth reqHost req
305− let reqs = attachPromptlyDynWith (flip (,)) xhrReq trigger
306− okReqs = fmapMaybe (\(t,e) -> either (const Nothing) (Just . (t,)) e) reqs
307− badReqs = fmapMaybe (\(t,e) -> either (Just . (t,)) (const Nothing) e) reqs
308−
309− resps <- performRequestsAsync okReqs
310−
311− return (resps, badReqs)
312−
313−
314−type XhrPayload = T.Text
339+type XhrPayload = ByteString
315340bytesToPayload :: BL.ByteString -> XhrPayload
316−bytesToPayload = TE.decodeUtf8 . BL.toStrict
317−
318−
319−-- performRequestNoBody :: forall t m tag.(SupportsServantReflex t m)
320−-- => Text
321−-- -> Req t
322−-- -> Dynamic t BaseUrl
323−-- -> Event t tag -> m (Event t (ReqResult tag NoContent))
324−-- performRequestNoBody reqMeth req reqHost trigger = do
325−-- (resp, badReq) <- performRequest reqMeth req reqHost trigger
326−-- let decodeResp = const $ Right NoContent
327−-- return $ leftmost [ fmap (evalResponse decodeResp) resp
328−-- , fmap (uncurry RequestFailure) badReq
329−-- ]
330−
331−
332−-- performRequestCT
333−-- :: (SupportsServantReflex t m,
334−-- MimeUnrender ct a)
335−-- => Proxy ct
336−-- -> Text
337−-- -> Req t
338−-- -> Dynamic t BaseUrl
339−-- -> Event t tag
340−-- -> m (Event t (ReqResult tag a))
341−-- performRequestCT ct reqMeth req reqHost trigger = do
342−-- (resp, badReq) <- performRequest reqMeth req reqHost trigger
343−-- let decodeResp x = first T.pack .
344−-- mimeUnrender ct .
345−-- BL.fromStrict .
346−-- TE.encodeUtf8 =<< note "No body text"
347−-- (_xhrResponse_responseText x)
348−
349−-- return $ leftmost [fmap (evalResponse decodeResp) resp
350−-- , fmap (uncurry RequestFailure) badReq
351−-- ]
341+bytesToPayload = BL.toStrict
342+
352343
353344performRequestsCT
354− :: ( SupportsServantReflex t m
355− -- , MimeUnrender ct a
356− , FromJSON a
357− , Traversable f
358− )
345+ :: (SupportsServantReflex t m,
346+ MimeUnrender ct a, Traversable f)
359347 => Proxy ct
360348 -> Text
361349 -> Dynamic t (f (Req t))
362350 -> Dynamic t BaseUrl
351+ -> ClientOptions
363352 -> Event t tag
364353 -> m (Event t (f (ReqResult tag a)))
365−performRequestsCT _ reqMeth reqs reqHost trigger = do
366− resps <- performRequests reqMeth reqs reqHost trigger
367− -- let decodeResp x = first T.pack .
368− -- mimeUnrender ct .
369− -- BL.fromStrict .
370− -- TE.encodeUtf8 =<< note "No body text"
371− let decodeResp x = first T.pack
372− . note "Failed to decode"
373− . jsonDecode
374− . JS.textToJSString
375− =<< note "No body text" (_xhrResponse_responseText x)
354+performRequestsCT ct reqMeth reqs reqHost opts trigger = do
355+ resps <- performRequests reqMeth reqs reqHost opts trigger
356+ let decodeResp (Just (XhrResponseBody_ArrayBuffer x)) =
357+ first T.pack .
358+ mimeUnrender ct $
359+ BL.fromStrict x
360+ decodeResp _ = Left "No body"
376361 return $ fmap
377362 (\(t,rs) -> ffor rs $ \r -> case r of
378363 Left e -> RequestFailure t e
379− Right g -> evalResponse decodeResp (t,g)
364+ Right g -> evalResponse (decodeResp . _xhrResponse_response) (t,g)
380365 )
381366 resps
382367
@@ -387,10 +372,11 @@ performRequestsNoBody
387372 => Text
388373 -> Dynamic t (f (Req t))
389374 -> Dynamic t BaseUrl
375+ -> ClientOptions
390376 -> Event t tag
391377 -> m (Event t (f (ReqResult tag NoContent)))
392−performRequestsNoBody reqMeth reqs reqHost trigger = do
393− resps <- performRequests reqMeth reqs reqHost trigger
378+performRequestsNoBody reqMeth reqs reqHost opts trigger = do
379+ resps <- performRequests reqMeth reqs reqHost opts trigger
394380 let decodeResp = const $ Right NoContent
395381 return $ ffor resps $ \(tag,rs) -> ffor rs $ \r -> case r of
396382 Left e -> RequestFailure tag e
@@ -402,8 +388,9 @@ evalResponse
402388 :: (XhrResponse -> Either Text a)
403389 -> (tag, XhrResponse)
404390 -> ReqResult tag a
405−evalResponse decodeRes (tag, xhr) =
406− let okStatus = _xhrResponse_status xhr < 400
391+evalResponse decode (tag, xhr) =
392+ let status = _xhrResponse_status xhr
393+ okStatus = status >= 200 && status < 400
407394 errMsg = fromMaybe
408395 ("Empty response with error code " <>
409396 T.pack (show $ _xhrResponse_status xhr))
@@ -412,11 +399,21 @@ evalResponse decodeRes (tag, xhr) =
412399 then either
413400 (\e -> ResponseFailure tag e xhr)
414401 (\v -> ResponseSuccess tag v xhr)
415− (decodeRes xhr)
402+ (decode xhr)
416403 else ResponseFailure tag errMsg xhr
417404 in respPayld
418405
406+------------------------------------------------------------------------------
407+-- | Utility for simultaneously accessing/filtering Success and Failure
408+-- response 'Event's,
409+fanReqResult :: Reflex t => Event t (ReqResult tag a) -> (Event t Text, Event t a)
410+fanReqResult = fmapMaybe reqFailure &&& fmapMaybe reqSuccess
419411
412+------------------------------------------------------------------------------
413+-- | Utility for simultaneously accessing/filtering Success and Failure
414+-- response 'Event's, but keeping the request tag
415+fanReqResult' :: Reflex t => Event t (ReqResult tag a) -> (Event t (tag, Text), Event t (tag, a))
416+fanReqResult' = fmapMaybe reqFailure' &&& fmapMaybe reqSuccess'
420417
421418
422419note :: e -> Maybe a -> Either e a
@@ -425,3 +422,10 @@ note e = maybe (Left e) Right
425422fmapL :: (e -> e') -> Either e a -> Either e' a
426423fmapL _ (Right a) = Right a
427424fmapL f (Left e) = Left (f e)
425+
426+builderToText :: Builder.Builder -> T.Text
427+builderToText = TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString
428+
429+escape :: T.Text -> T.Text
430+escape = T.pack . N.escapeURIString (not . N.isReserved) . T.unpack . TE.decodeUtf8 . BL.toStrict . Builder.toLazyByteString . toEncodedUrlPiece
431+
src/Servant/Reflex.hs+204−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,47 +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------------------------------------------------------------------------------
37−import Data.Aeson
3841import Control.Applicative
39−import Data.Monoid ((<>))
40−import qualified Data.Set as Set
41−import qualified Data.Text.Encoding as E
42−import Data.CaseInsensitive (mk)
42+import qualified Data.CaseInsensitive as CI
4343import Data.Functor.Identity
44−import Data.Proxy (Proxy (..))
4544import qualified Data.Map as Map
45+import Data.Monoid ((<>))
46+import Data.Proxy (Proxy (..))
47+import qualified Data.Set as Set
4648import Data.Text (Text)
4749import qualified Data.Text as T
50+import qualified Data.Text.Encoding as E
51+import GHC.Exts (Constraint)
4852import GHC.TypeLits (KnownSymbol, symbolVal)
49−import Servant.API ((:<|>)(..),(:>), BasicAuth,
50− BasicAuthData, BuildHeadersTo(..),
51− Capture, contentType, Header,
52− Headers(..), HttpVersion, IsSecure,
53− MimeRender(..), MimeUnrender,
53+import Servant.API ((:<|>) (..), (:>), BasicAuth,
54+ BasicAuthData, BuildHeadersTo (..),
55+ Capture, Header, Headers (..),
56+ HttpVersion, IsSecure,
57+ MimeRender (..), MimeUnrender,
5458 NoContent, QueryFlag, QueryParam,
55− QueryParams, Raw, ReflectMethod(..),
59+ QueryParams, Raw, ReflectMethod (..),
5660 RemoteHost, ReqBody,
57− ToHttpApiData(..), Vault, Verb)
58−
59−import Reflex.Dom (Dynamic, Event, Reflex,
60− XhrRequest(..),
61− XhrResponseHeaders(..),
62− XhrResponse(..), attachPromptlyDynWith, constDyn, ffor, fmapMaybe,
63− leftmost, performRequestsAsync,
64− )
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)
6572------------------------------------------------------------------------------
6673import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
6774 showBaseUrl,
6875 SupportsServantReflex)
69−import Servant.Common.Req (Req, ReqResult(..), QParam(..),
76+import Servant.Common.Req (ClientOptions(..),
77+ defaultClientOptions,
78+ Req, ReqResult(..), QParam(..),
7079 QueryPart(..), addHeader, authData,
7180 defReq, evalResponse, prependToPathParts,
7281 -- performRequestCT,
@@ -76,9 +85,10 @@ import Servant.Common.Req (Req, ReqResult(..), QParam(..),
7685 performSomeRequestsAsync,
7786 qParamToQueryPart, reqBody,
7887 reqSuccess, reqFailure,
79− reqMethod, respHeaders, response,
88+ reqMethod, respHeaders,
89+ response,
8090 reqTag,
81− qParams)
91+ qParams, withCredentials)
8292
8393
8494-- * Accessing APIs as a Client
@@ -93,28 +103,75 @@ import Servant.Common.Req (Req, ReqResult(..), QParam(..),
93103-- >
94104-- > getAllBooks :: Event t l -> m (Event t (l, ReqResult [Book]))
95105-- > postNewBook :: Dynamic t (Maybe Book) -> Event t l
96−-- -> m (Event t (l, ReqResult Book)))
106+-- > -> m (Event t (l, ReqResult Book)))
97107-- > (getAllBooks :<|> postNewBook) = client myApi host
98108-- > where host = constDyn $ BaseUrl Http "localhost" 8080
99−client :: (HasClient t m layout tag)
100− => Proxy layout -> Proxy m -> Proxy tag -> Dynamic t BaseUrl -> Client t m layout tag
101−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
102141
103142
104143-- | This class lets us define how each API combinator
105144-- influences the creation of an HTTP request. It's mostly
106145-- an internal class, you can just use 'client'.
107−class HasClient t m layout (tag :: *) where
146+class Monad m => HasClient t m layout (tag :: *) where
108147 type Client t m layout tag :: *
109− 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
110167
111168
112169instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b) tag where
113170 type Client t m (a :<|> b) tag = Client t m a tag :<|> Client t m b tag
114171
115− clientWithRoute Proxy q pTag req baseurl =
116− clientWithRoute (Proxy :: Proxy a) q pTag req baseurl :<|>
117− 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
118175
119176
120177-- Capture. Example:
@@ -129,32 +186,29 @@ instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b)
129186-- -> m (Event t (l, ReqResult Book))
130187-- > getBook = client myApi (constDyn host)
131188
132−instance (SupportsServantReflex t m, FromJSON a, ToHttpApiData a, HasClient t m sublayout tag)
189+instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout tag)
133190 => HasClient t m (Capture capture a :> sublayout) tag where
134191
135192 type Client t m (Capture capture a :> sublayout) tag =
136193 Dynamic t (Either Text a) -> Client t m sublayout tag
137194
138− clientWithRoute Proxy q t req baseurl val =
139− clientWithRoute (Proxy :: Proxy sublayout)
140− q t
141− (prependToPathParts p req)
142− 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
143198 where p = (fmap . fmap) (toUrlPiece) val
144199
145200
146201-- VERB (Returning content) --
147202instance {-# OVERLAPPABLE #-}
148203 -- Note [Non-Empty Content Types]
149− (FromJSON a, MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
204+ (MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
150205 ) => HasClient t m (Verb method status cts' a) tag where
151206 type Client t m (Verb method status cts' a) tag =
152207 Event t tag -> m (Event t (ReqResult tag a))
153208 -- TODO how to access input types here?
154209 -- ExceptT ServantError IO a
155− clientWithRoute Proxy _ _ req baseurl trigs =
156− -- performRequestCT (Proxy :: Proxy ct) method req' baseurl trigs
157− 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
158212 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
159213 req' = req { reqMethod = method }
160214
@@ -167,29 +221,33 @@ instance {-# OVERLAPPING #-}
167221 Event t tag -> m (Event t (ReqResult tag NoContent))
168222 -- TODO: how to access input types here?
169223 -- ExceptT ServantError IO NoContent
170− clientWithRoute Proxy _ _ req baseurl =
171− (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
172226 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
173227
174228
175229toHeaders :: BuildHeadersTo ls => ReqResult tag a -> ReqResult tag (Headers ls a)
176230toHeaders r =
177− let toBS = E.encodeUtf8
178− hdrs = maybe []
179− (\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))
180233 (Map.toList $ _xhrResponse_headers xhr))
181234 (response r)
182235 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
183236
237+
184238class BuildHeaderKeysTo hs where
185− buildHeaderKeysTo :: Proxy hs -> [T.Text]
239+ buildHeaderKeysTo :: Proxy hs -> [CI.CI T.Text]
186240
187241instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
188242 where buildHeaderKeysTo _ = []
189243
190244instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
191245 => BuildHeaderKeysTo ((Header h v) ': xs) where
192− buildHeaderKeysTo _ = T.pack (symbolVal (Proxy :: Proxy h)) : buildHeaderKeysTo (Proxy :: Proxy xs)
246+ buildHeaderKeysTo _ =
247+ let
248+ thisKey = CI.mk $ T.pack (symbolVal (Proxy :: Proxy h))
249+ in thisKey : buildHeaderKeysTo (Proxy :: Proxy xs)
250+
193251
194252-- HEADERS Verb (Content) --
195253-- Headers combinator not treated in fully general case,
@@ -199,16 +257,15 @@ instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
199257instance {-# OVERLAPPABLE #-}
200258 -- Note [Non-Empty Content Types]
201259 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
202− FromJSON a,
203260 ReflectMethod method, cts' ~ (ct ': cts),
204261 SupportsServantReflex t m
205262 ) => HasClient t m (Verb method status cts' (Headers ls a)) tag where
206263 type Client t m (Verb method status cts' (Headers ls a)) tag =
207264 Event t tag -> m (Event t (ReqResult tag (Headers ls a)))
208− clientWithRoute Proxy _ _ req baseurl trigs = do
265+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
209266 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
210− resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl trigs
211− return $ toHeaders <$> resp
267+ resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl opts trigs
268+ wrap $ toHeaders <$> resp
212269 where req' = req { respHeaders =
213270 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
214271 }
@@ -221,10 +278,10 @@ instance {-# OVERLAPPABLE #-}
221278 ) => HasClient t m (Verb method status cts (Headers ls NoContent)) tag where
222279 type Client t m (Verb method status cts (Headers ls NoContent)) tag
223280 = Event t tag -> m (Event t (ReqResult tag (Headers ls NoContent)))
224− clientWithRoute Proxy _ _ req baseurl trigs = do
281+ clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
225282 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
226− resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl trigs
227− return $ toHeaders <$> resp
283+ resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl opts trigs
284+ wrap $ toHeaders <$> resp
228285 where req' = req {respHeaders =
229286 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
230287 }
@@ -251,11 +308,11 @@ instance (KnownSymbol sym, ToHttpApiData a,
251308 type Client t m (Header sym a :> sublayout) tag =
252309 Dynamic t (Either Text a) -> Client t m sublayout tag
253310
254− clientWithRoute Proxy q t req baseurl eVal =
255− clientWithRoute (Proxy :: Proxy sublayout)
256− q t
257− (Servant.Common.Req.addHeader hname eVal req)
258− 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
259316 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
260317
261318
@@ -269,8 +326,21 @@ instance HasClient t m sublayout tag
269326 type Client t m (HttpVersion :> sublayout) tag =
270327 Client t m sublayout tag
271328
272− clientWithRoute Proxy q t =
273− 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+
274344
275345
276346-- | If you use a 'QueryParam' in one of your endpoints in your API,
@@ -306,9 +376,9 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
306376 Dynamic t (QParam a) -> Client t m sublayout tag
307377
308378 -- if mparam = Nothing, we don't add it to the query string
309− clientWithRoute Proxy q t req baseurl mparam =
310− clientWithRoute (Proxy :: Proxy sublayout) q t
311− (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
312382
313383 where pname = symbolVal (Proxy :: Proxy sym)
314384 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
@@ -352,8 +422,8 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
352422 type Client t m (QueryParams sym a :> sublayout) tag =
353423 Dynamic t [a] -> Client t m sublayout tag
354424
355− clientWithRoute Proxy q t req baseurl paramlist =
356− 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
357427
358428 where req' = req { qParams = (T.pack pname, params') : qParams req }
359429 pname = symbolVal (Proxy :: Proxy sym)
@@ -392,8 +462,8 @@ instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
392462 type Client t m (QueryFlag sym :> sublayout) tag =
393463 Dynamic t Bool -> Client t m sublayout tag
394464
395− clientWithRoute Proxy q t req baseurl flag =
396− 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
397467
398468 where req' = req { qParams = thisPair : qParams req }
399469 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
@@ -407,7 +477,7 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
407477 -> Event t tag
408478 -> m (Event t (ReqResult tag ()))
409479
410− clientWithRoute _ _ _ _ baseurl xhrs triggers = do
480+ clientWithRouteAndResultHandler _ _ _ _ baseurl _ wrap xhrs triggers = do
411481
412482 let xhrs' = liftA2 (\x path -> case x of
413483 Left e -> Left e
@@ -418,7 +488,7 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
418488 okReq = fmapMaybe (\(t,x) -> either (const Nothing) (Just . (t,)) x) xhrs'' :: Event t (tag, XhrRequest ())
419489
420490 resps <- performRequestsAsync okReq
421− return $ leftmost [ uncurry RequestFailure <$> badReq
491+ wrap $ leftmost [ uncurry RequestFailure <$> badReq
422492 , evalResponse (const $ Right ()) <$> resps
423493 ]
424494
@@ -449,8 +519,8 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
449519 type Client t m (ReqBody (ct ': cts) a :> sublayout) tag =
450520 Dynamic t (Either Text a) -> Client t m sublayout tag
451521
452− clientWithRoute Proxy q t req baseurl body =
453− 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
454524 where req' = req { reqBody = bodyBytesCT }
455525 ctProxy = Proxy :: Proxy ct
456526 ctString = T.pack $ show $ contentType ctProxy
@@ -464,9 +534,9 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
464534instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient t m (path :> sublayout) tag where
465535 type Client t m (path :> sublayout) tag = Client t m sublayout tag
466536
467− clientWithRoute Proxy q t req baseurl =
468− clientWithRoute (Proxy :: Proxy sublayout) q t
469− (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
470540
471541 where p = symbolVal (Proxy :: Proxy path)
472542
@@ -474,23 +544,23 @@ instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient
474544instance HasClient t m api tag => HasClient t m (Vault :> api) tag where
475545 type Client t m (Vault :> api) tag = Client t m api tag
476546
477− clientWithRoute Proxy q t req baseurl =
478− clientWithRoute (Proxy :: Proxy api) q t req baseurl
547+ clientWithRouteAndResultHandler Proxy =
548+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
479549
480550
481551instance HasClient t m api tag => HasClient t m (RemoteHost :> api) tag where
482552 type Client t m (RemoteHost :> api) tag = Client t m api tag
483553
484− clientWithRoute Proxy q t req baseurl =
485− clientWithRoute (Proxy :: Proxy api) q t req baseurl
554+ clientWithRouteAndResultHandler Proxy =
555+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
486556
487557
488558
489559instance HasClient t m api tag => HasClient t m (IsSecure :> api) tag where
490560 type Client t m (IsSecure :> api) tag = Client t m api tag
491561
492− clientWithRoute Proxy q t req baseurl =
493− clientWithRoute (Proxy :: Proxy api) q t req baseurl
562+ clientWithRouteAndResultHandler Proxy =
563+ clientWithRouteAndResultHandler (Proxy :: Proxy api)
494564
495565
496566instance (HasClient t m api tag, Reflex t)
@@ -499,8 +569,8 @@ instance (HasClient t m api tag, Reflex t)
499569 type Client t m (BasicAuth realm usr :> api) tag = Dynamic t (Maybe BasicAuthData)
500570 -> Client t m api tag
501571
502− clientWithRoute Proxy q t req baseurl authdata =
503− 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
504574 where
505575 req' = req { authData = Just authdata }
506576
@@ -526,3 +596,30 @@ non-empty lists, but is otherwise more specific, no instance will be overall
526596more specific. This in turn generally means adding yet another instance (one
527597for empty and one for non-empty lists).
528598-}
599+
600+
601+-- SUPPORT FOR servant-auth --
602+
603+-- For JavaScript clients we should be sending/storing JSON web tokens in a
604+-- way that is inaccessible to JavaScript.
605+--
606+-- For @servant-auth@ this is done with HTTP-only cookies. In a Reflex-DOM
607+-- app this means the @servant-auth@ client should only verify that the API
608+-- supports Cookie-based authentication but do nothing with the token
609+-- directly.
610+
611+-- @HasCookieAuth auths@ is nominally a redundant constraint, but ensures
612+-- we're not trying to rely on cookies when the API does not use them.
613+instance (HasCookieAuth auths, HasClient t m api tag) => HasClient t m (Auth.Auth auths a :> api) tag where
614+
615+ type Client t m (Auth.Auth auths a :> api) tag = Client t m api tag
616+ clientWithRouteAndResultHandler Proxy = clientWithRouteAndResultHandler (Proxy :: Proxy api)
617+
618+
619+type family HasCookieAuth xs :: Constraint where
620+ HasCookieAuth (Auth.Cookie ': xs) = ()
621+ HasCookieAuth (x ': xs) = HasCookieAuth xs
622+ HasCookieAuth '[] = CookieAuthNotEnabled
623+
624+class CookieAuthNotEnabled
625+
src/Servant/Reflex/Multi.hs+82−56
@@ -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,41 +37,45 @@ module Servant.Reflex.Multi (
3437 ) where
3538
3639------------------------------------------------------------------------------
37−import Data.Aeson
38−import Control.Applicative (liftA2)
39−import Data.Functor.Compose (Compose (..), getCompose)
40−import Data.Proxy (Proxy (..))
41−import qualified Data.Set as Set
42−import Data.Text (Text)
43−import qualified Data.Text as T
44−import qualified Data.Text.Encoding as E
45−import GHC.TypeLits (KnownSymbol, symbolVal)
46−import Servant.API ((:<|>) (..), (:>), BasicAuth,
47− BasicAuthData, BuildHeadersTo (..),
48− Capture, Header, Headers (..),
49− HttpVersion, IsSecure, MimeRender (..),
50− MimeUnrender, NoContent, QueryFlag,
51− QueryParam, QueryParams, Raw,
52− ReflectMethod (..), RemoteHost,
53− ReqBody, ToHttpApiData (..), Vault,
54− Verb, contentType)
55−
56−import Reflex.Dom (Dynamic, Event, Reflex,
57− XhrRequest (..),
58− XhrResponseHeaders (..),
59− 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)
6064------------------------------------------------------------------------------
6165import Servant.Common.BaseUrl (BaseUrl (..), Scheme (..),
6266 SupportsServantReflex)
63−import Servant.Common.Req (QParam (..), QueryPart (..), Req,
67+import Servant.Common.Req (ClientOptions,
68+ QParam (..), QueryPart (..), Req,
6469 ReqResult (..), addHeader, authData,
65− defReq, performRequestsCT,
70+ defReq,
71+ defaultClientOptions,
72+ performRequestsCT,
6673 performRequestsNoBody,
6774 performSomeRequestsAsync,
6875 prependToPathParts, qParamToQueryPart,
6976 qParams, reqBody, reqFailure,
7077 reqMethod, reqSuccess, reqSuccess',
71− respHeaders, response)
78+ respHeaders, response, withCredentials)
7279import Servant.Reflex (BuildHeaderKeysTo (..), toHeaders)
7380
7481
@@ -78,14 +85,24 @@ clientA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
7885 -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
7986clientA p q f tag baseurl =
8087 clientWithRouteMulti p q f tag (constDyn (pure defReq)) baseurl
88+ defaultClientOptions
89+
8190
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
8299
83100------------------------------------------------------------------------------
84101class HasClientMulti t m layout f (tag :: *) where
85102 type ClientMulti t m layout f tag :: *
86103 clientWithRouteMulti :: Proxy layout -> Proxy m -> Proxy f -> Proxy tag
87104 -> Dynamic t (f (Req t)) -> Dynamic t BaseUrl
88− -> ClientMulti t m layout f tag
105+ -> ClientOptions -> ClientMulti t m layout f tag
89106
90107
91108------------------------------------------------------------------------------
@@ -93,9 +110,9 @@ instance (HasClientMulti t m a f tag, HasClientMulti t m b f tag) =>
93110 HasClientMulti t m (a :<|> b) f tag where
94111 type ClientMulti t m (a :<|> b) f tag = ClientMulti t m a f tag :<|>
95112 ClientMulti t m b f tag
96− clientWithRouteMulti Proxy q f tag reqs baseurl =
97− clientWithRouteMulti (Proxy :: Proxy a) q f tag reqs baseurl :<|>
98− 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
99116
100117
101118------------------------------------------------------------------------------
@@ -108,8 +125,8 @@ instance (SupportsServantReflex t m,
108125 type ClientMulti t m (Capture capture a :> sublayout) f tag =
109126 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
110127
111− clientWithRouteMulti _ q f tag reqs baseurl vals =
112− 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
113130 where
114131 reqs' = (prependToPathParts <$> ps <*>) <$> reqs
115132 ps = (fmap . fmap . fmap) toUrlPiece vals
@@ -120,7 +137,6 @@ instance (SupportsServantReflex t m,
120137instance {-# OVERLAPPABLE #-}
121138 -- Note [Non-Empty Content Types]
122139 (MimeUnrender ct a,
123− FromJSON a,
124140 ReflectMethod method, cts' ~ (ct ': cts),
125141 SupportsServantReflex t m,
126142 Applicative f,
@@ -130,8 +146,8 @@ instance {-# OVERLAPPABLE #-}
130146 type ClientMulti t m (Verb method status cts' a) f tag =
131147 Event t tag -> m (Event t (f (ReqResult tag a)))
132148
133− clientWithRouteMulti _ _ _ _ reqs baseurl =
134− performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl
149+ clientWithRouteMulti _ _ _ _ reqs baseurl opts =
150+ performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts
135151 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
136152 reqs' = fmap (\r -> r { reqMethod = method }) <$> reqs
137153
@@ -145,8 +161,8 @@ instance {-# OVERLAPPING #-}
145161 Event t tag -> m (Event t (f (ReqResult tag NoContent)))
146162 -- TODO: how to access input types here?
147163 -- ExceptT ServantError IO NoContent
148− clientWithRouteMulti Proxy _ _ _ req baseurl =
149− performRequestsNoBody method req baseurl
164+ clientWithRouteMulti Proxy _ _ _ req baseurl opts =
165+ performRequestsNoBody method req baseurl opts
150166 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
151167
152168
@@ -154,16 +170,15 @@ instance {-# OVERLAPPING #-}
154170instance {-# OVERLAPPABLE #-}
155171 -- Note [Non-Empty Content Types]
156172 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
157− FromJSON a,
158173 ReflectMethod method, cts' ~ (ct ': cts),
159174 SupportsServantReflex t m,
160175 Traversable f
161176 ) => HasClientMulti t m (Verb method status cts' (Headers ls a)) f tag where
162177 type ClientMulti t m (Verb method status cts' (Headers ls a)) f tag =
163178 Event t tag -> m (Event t (f (ReqResult tag (Headers ls a))))
164− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
179+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
165180 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
166− 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)))
167182 return $ fmap toHeaders <$> resp
168183 where
169184 reqs' = fmap (\r ->
@@ -184,9 +199,9 @@ instance {-# OVERLAPPABLE #-}
184199 cts (Headers ls NoContent)) f tag where
185200 type ClientMulti t m (Verb method status cts (Headers ls NoContent)) f tag
186201 = Event t tag -> m (Event t (f (ReqResult tag (Headers ls NoContent))))
187− clientWithRouteMulti Proxy _ _ _ reqs baseurl triggers = do
202+ clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
188203 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
189− resp <- performRequestsNoBody method reqs' baseurl triggers
204+ resp <- performRequestsNoBody method reqs' baseurl opts triggers
190205 return $ fmap toHeaders <$> resp
191206 where reqs' = fmap (\req ->
192207 req {respHeaders = OnlyHeaders (Set.fromList
@@ -206,11 +221,11 @@ instance (KnownSymbol sym,
206221 type ClientMulti t m (Header sym a :> sublayout) f tag =
207222 f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
208223
209− clientWithRouteMulti Proxy f q tag reqs baseurl eVals =
224+ clientWithRouteMulti Proxy f q tag reqs baseurl opts eVals =
210225 clientWithRouteMulti (Proxy :: Proxy sublayout) f
211226 q tag
212227 reqs'
213− baseurl
228+ baseurl opts
214229 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
215230 reqs' = ((\eVal req -> Servant.Common.Req.addHeader hname eVal req)
216231 <$> eVals <*>) <$> reqs
@@ -227,6 +242,17 @@ instance HasClientMulti t m sublayout f tag
227242 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
228243
229244
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+
230256------------------------------------------------------------------------------
231257instance (KnownSymbol sym,
232258 ToHttpApiData a,
@@ -240,9 +266,9 @@ instance (KnownSymbol sym,
240266
241267 -- if mparam = Nothing, we don't add it to the query string
242268 -- TODO: Check the above comment
243− clientWithRouteMulti Proxy q f tag reqs baseurl mparams =
269+ clientWithRouteMulti Proxy q f tag reqs baseurl opts mparams =
244270 clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
245− reqs' baseurl
271+ reqs' baseurl opts
246272
247273 where pname = symbolVal (Proxy :: Proxy sym)
248274 p prm = QueryPartParam $ fmap qParamToQueryPart prm
@@ -263,8 +289,8 @@ instance (KnownSymbol sym,
263289 type ClientMulti t m (QueryParams sym a :> sublayout) f tag =
264290 Dynamic t (f [a]) -> ClientMulti t m sublayout f tag
265291
266− clientWithRouteMulti Proxy q f tag reqs baseurl paramlists =
267− 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
268294
269295 where req' l r = r { qParams = (T.pack pname, params' (constDyn l)) : qParams r }
270296 pname = symbolVal (Proxy :: Proxy sym)
@@ -282,8 +308,8 @@ instance (KnownSymbol sym,
282308 type ClientMulti t m (QueryFlag sym :> sublayout) f tag =
283309 Dynamic t (f Bool) -> ClientMulti t m sublayout f tag
284310
285− clientWithRouteMulti Proxy q f' tag reqs baseurl flags =
286− 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
287313
288314 where req' f req = req { qParams = thisPair (constDyn f) : qParams req }
289315 thisPair f = (T.pack pName, QueryPartFlag f) :: (Text, QueryPart t)
@@ -297,10 +323,10 @@ instance (SupportsServantReflex t m,
297323 -> Event t tag
298324 -> m (Event t (f (ReqResult tag ())))
299325
300− clientWithRouteMulti _ _ _ _ _ _ rawReqs triggers = do
326+ clientWithRouteMulti _ _ _ _ _ _ opts rawReqs triggers = do
301327 let rawReqs' = sequence rawReqs :: Dynamic t (f (Either Text (XhrRequest ())))
302328 rawReqs'' = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) rawReqs' triggers
303− resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync rawReqs''
329+ resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync opts rawReqs''
304330 return resps
305331 where
306332 aux (tag, Right r) = ResponseSuccess tag () r
@@ -316,8 +342,8 @@ instance (MimeRender ct a,
316342 type ClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag =
317343 Dynamic t (f (Either Text a)) -> ClientMulti t m sublayout f tag
318344
319− clientWithRouteMulti Proxy q f tag reqs baseurl bodies =
320− 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
321347 where req' b r = r { reqBody = bodyBytesCT (constDyn b) }
322348 ctProxy = Proxy :: Proxy ct
323349 ctString = T.pack $ show $ contentType ctProxy
@@ -368,8 +394,8 @@ instance (HasClientMulti t m api f tag, Reflex t, Applicative f)
368394 type ClientMulti t m (BasicAuth realm usr :> api) f tag = Dynamic t (f (Maybe BasicAuthData))
369395 -> ClientMulti t m api f tag
370396
371− clientWithRouteMulti Proxy q f tag reqs baseurl authdatas =
372− 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
373399 where
374400 req' a r = r { authData = Just (constDyn a) }
375401 reqs' = liftA2 req' <$> authdatas <*> reqs
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+ }