on b2e334f help sign in
35 files changed+568−1638
since splitsnapshots
unifiedsplit
.gitignore+1−3 .gitmodules+15 .travis.yml+58−12 ChangeLog.md−60 README.md+28−114 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+30−108 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+18−36 shell.nix−1 src/Servant/Common/BaseUrl.hs+8−8 src/Servant/Common/Req.hs+82−271 src/Servant/Reflex.hs+193−331 src/Servant/Reflex/Multi.hs−401 stack.yaml−56 testdriver/test/Servant/ReflexSpec.hs+1−2 testserver/API.hs+1−69 testserver/Main.hs+6−23 testserver/run-wd-tests.sh+5 testserver/testserver.cabal+7−8 testserver/tr.nix+32 travis.nix−70
.gitignore+1−3
@@ -6,6 +6,4 @@ log
66*.webapp
77*.stats
88out
9−/.stack-work/
10−TAGS
11−dist-newstyle
9+reflex-platform
.gitmodules+15
@@ -0,0 +1,15 @@
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+58−12
@@ -1,17 +1,63 @@
1−language: nix
2−nix: 2.3.6
3−sudo: require
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+
421
522before_install:
6− - sudo cp -rT $TRAVIS_BUILD_DIR/nix /etc/nix
23+ - openssl aes-256-cbc -K $encrypted_3c89d919c82e_key -iv $encrypted_3c89d919c82e_iv -in deploy_key.enc -out deploy_key -d
24+ - unset CC
25+ - export PATH=/opt/ghc/$GHCVER/bin:/opt/cabal/$CABALVER/bin:$PATH
26+ - git submodule update --init --recursive
727
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"
28+install:
29+ - cabal --version
30+ - BENCH=${BENCH---enable-benchmarks}
31+ - TEST=${TEST---enable-tests}
32+ - echo "$(ghc --version) [$(ghc --print-project-git-commit-id 2> /dev/null || echo '?')]"
33+ - if [ -f $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz ];
34+ then
35+ zcat $HOME/.cabal/packages/hackage.haskell.org/00-index.tar.gz >
36+ $HOME/.cabal/packages/hackage.haskell.org/00-index.tar;
37+ fi
38+ - travis_retry cabal update -v
39+ - git clone https://github.com/reflex-frp/reflex-platform
40+ - sed -i 's/^jobs:/-- jobs:/' ${HOME}/.cabal/config
41+ - reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal configure && cabal build"
42+ - reflex-platform/work-on ghc ./testdriver --command "cd testdriver && cabal configure && cabal build"
43+ - cd testserver && dist/build/back/back -p 8000 &
44+ - sleep 3
45+ - phantomjs --webdriver=127.0.0.1:4444 &
46+ - sleep 3
1247
1348script:
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
49+ - git config --global user.email "travis-ci@example.com"
50+ - git config --global user.name "Travis-CI"
51+ - ./build.sh
52+ - testdriver/dist/build/spec/spec
53+
54+cache:
55+ directories:
56+ - /nix
57+ - $HOME/.cabal/packages
58+ - $HOME/.cabal/store
59+
60+env:
61+ global:
62+ - ENCRYPTION_LABEL: "3c89d919c82e"
63+ - COMMIT_AUTHOR_EMAIL: "imalsogreg@gmail.com"
ChangeLog.mddeleted−60
@@ -1,60 +0,0 @@
1−0.3.5
2−-----
3−
4− - Require reflex-dom-core >= 0.6 (for internal handling of case-insensitive headers)
5− - Require servant >= 0.16
6− - Eliminate use of deprecated widgets from reflex-dom-core
7− - Bump the version of reflex-platform used in nix-shell and test suite
8−
9−0.3.4
10−-----
11−
12−Add selenium-based test suite
13−
14−0.3.3
15−-----
16−
17−- Fix encoding issue: Explicitly escape reserved characters from path pieces and query parameters
18−
19−
20−0.3.2
21−-----
22−
23−- **Addition of 'Servant.Reflex.Common.Req.ClientOpts'** which
24−allows the users to apply a final adjustment to Requests before
25−thery are sent, such as setting the 'withCredentials' flag
26−or print the Request to the console for debugging
27−[PR #47](https://github.com/imalsogreg/servant-reflex/pull/47)
28−
29−0.3
30−---
31−
32−- **Addition of the 'Servant.Reflex.Multi' module** which allows the user
33−to choose some '(Applicative f, Traversable f) => f' for collecting
34−endpoint parameters. The traversable instance is used for passing
35−multiple 'XhrRequest's in response to a single event trigger. The
36−Applicative instance is used to combine parameters. For example,
37−'Capture "id" Name :> QueryParam "greeting" Text :> Get '[JSON] Text'
38−will generate a client function:
39−`Dynamic t (f Name) -> Dynamic t (f greeting) -> Event t tag ->
40− m (Event t (f (ReqResult tag Text)))`
41−Calling that function with 'f' chosen to be list ('[]'), this call
42−`clientFun
43−(constDyn ["Greg", "Bernie"])
44−(constDyn ["Greetings", "Hey"])
45−trigger`
46−would produce four XhrRequests per 'trigger' event, one for each
47−combination of possible parameters, and one response event
48−would carry a list of the four responses.
49−A 'zip-wise' combination of the parameters can be chosen with
50−a different applicative wrapper: 'ZipList'
51−
52−- **Event tags**. A new type parameter lets users choose a payload
53−value to attach to outgoing requests at the point of triggering,
54−and which is embedded in the response, allowing individual
55−request-response pairs to be followed. The response's tag has been
56−added to each constructor `ReqResult tag a` type.
57−
58−- **Improved Unicode support** Thanks to Schell Scivally
59−(https://github.com/schell) for identifying and fixing a UTF-8
60−encoding bug!
README.md+28−114
@@ -2,21 +2,16 @@
22
33[![Build Status](https://travis-ci.org/imalsogreg/servant-reflex.svg?branch=master)](https://travis-ci.org/imalsogreg/servant-reflex)
44
5−## `servant-reflex` lets you share your `servant` APIs with the frontend
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.
69
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.
1410
1511
1612## Example
1713
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:
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:
2015
2116```haskell
2217type API = "getint" :> Get '[JSON] Int
@@ -29,8 +24,7 @@ type API = "getint" :> Get '[JSON] Int
2924 :<|> Raw
3025```
3126
32−`servant-reflex` then computes client functions that can query the API through
33−an `XhrRequest`.
27+`servant-reflex` then computes client functions that can query the API through an `XhrRequest`.
3428
3529```haskell
3630
@@ -39,26 +33,16 @@ an `XhrRequest`.
3933 -- servant-reflex computes FRP functions for each API endpoint
4034 let (getint :<|> sayhi :<|> doubleit :<|> _) = client (Proxy :: Proxy API)
4135 (Proxy :: Proxy m)
42− (Proxy :: Proxy ())
4336 (constDyn (BasePath "/"))
4437```
4538
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.
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.
5640
5741```haskell
5842 -- No need to write these functions. servant-reflex creates them for you!
5943 getint :: MonadWidget t m
6044 => Event t () -- ^ Trigger the XHR Request
61− -> m (Event t (ReqResult () Int)) -- ^ Consume the answer
45+ -> m (Event t (ReqResult Int)) -- ^ Consume the answer
6246
6347 sayhi :: MonadWidget t m
6448 => Dynamic t (QParam Text)
@@ -69,21 +53,15 @@ parameter is a trigger event for the XHR request. The return value
6953 -- ^ Flag for capitalizing the response
7054 -> Event t ()
7155 -- ^ Trigger the XHR Request
72− -> m (Event t (ReqResult () Text))
56+ -> m (Event t (ReqResult Text))
7357
7458 doubleit :: MonadWidget t m
7559 => Dynamic t (Either Text Double)
7660 -> Event t ()
77− -> m (Event t (ReqResult () Double))
61+ -> m (Event t (ReqResult Double))
7862```
7963
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:
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:
8765
8866```haskell
8967 -- ... continued ...
@@ -101,8 +79,7 @@ elimination functions to filter the result type you care about, like this:
10179 dynText =<< holdDyn "" (leftmost [errs, const "" <$> ys])
10280```
10381
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:
82+This example builds some input fields to enter API parameters, buttons to trigger the API calls, and text elements to show the results:
10683
10784```haskell
10885 elClass "div" "int-demo" $ do
@@ -125,100 +102,37 @@ trigger the API calls, and text elements to show the results:
125102 display =<< holdDyn Nothing outputDouble
126103```
127104
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.
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.
133106
134107
135108## Building the library and test server
136109
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.
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:
144111
145−```
146−nix build -f travis.nix testserver -o server
147−```
148112
149−Point it at the static directory and run it:
113+First build the library:
150114
151115```
152−STATIC_DIR=server/static server/back -p 8000
116+git submodule update --init --recursive
117+./build.sh
153118```
154119
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.
158−
159−**For a larger example of a project that shares types between backend and
160−frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
120+Then build the test server:
161121
122+```
123+deps/reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal build"
124+```
162125
163−## Tagging requests
164126
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.
127+## Running the example site
169128
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:
129+The server must be run from the directory where static assets live:
175130
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− ...
200131```
201−
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)))
132+cd testserver
133+dist/build/back/back -p 8001
216134```
217135
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.
136+And simply browse to `localhost:8001`
137+
138+**For a larger example of a project that shares types between backend and frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
build.shnew file+3
@@ -0,0 +1,3 @@
1+#!/usr/bin/env bash
2+
3+reflex-platform/work-on ./overrides.nix ./. --run "cabal configure --ghcjs && cabal build && exec/toSite.sh"
default.nixdeleted−21
@@ -1,21 +0,0 @@
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-datanew file+1

Submodule changed.

deps/reflexnew file+1

Submodule changed.

deps/reflex-domnew file+1

Submodule changed.

deps/servantnew file+1

Submodule changed.

deps/servant-snapnew file+1

Submodule changed.

exec/API.hs−1
@@ -40,7 +40,6 @@ 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
4443 :<|> Raw
4544
4645type GET = Get '[JSON] ()
exec/Example.hs+30−108
@@ -1,82 +1,30 @@
1−{-# LANGUAGE DataKinds #-}
21{-# LANGUAGE FlexibleContexts #-}
32{-# LANGUAGE GADTs #-}
43{-# LANGUAGE OverloadedStrings #-}
54{-# LANGUAGE RankNTypes #-}
6−{-# LANGUAGE RecursiveDo #-}
75{-# LANGUAGE ScopedTypeVariables #-}
86
97module Main where
108
11−------------------------------------------------------------------------------
129import Data.Bool
1310import Data.Maybe
1411import Control.Monad.Fix (MonadFix)
15−import Data.Monoid (First(..), (<>))
12+import Data.Monoid ((<>))
1613import Data.Text (Text)
1714import qualified Data.Text as T
18−import qualified Data.Text.Encoding as T
19−import GHC.TypeLits
2015import Servant.API
16+import Servant.Reflex
2117import API
2218import Data.Proxy
2319import Text.Read (readMaybe)
24−import Reflex.Dom.Core hiding (run, mainWidget)
25−import Reflex.Dom (mainWidget)
26−------------------------------------------------------------------------------
27−import Servant.Reflex
28−import Servant.Reflex.Multi
29−
20+import Reflex.Dom
3021
3122api :: Proxy API
3223api = Proxy
3324
3425main :: IO ()
35−main = mainWidget $ do
36− divClass "example-base" run
37− divClass "example-multi" runMulti
38−
39−
40−runMulti :: forall t m. (SupportsServantReflex t m,
41− DomBuilder t m,
42− DomBuilderSpace m ~ GhcjsDomSpace,
43− MonadFix m,
44− PostBuild t m,
45− MonadHold t m) => m ()
46−runMulti = do
47− url <- baseUrlWidget
48− el "br" blank
49− let (_ :<|> _ :<|> sayHi :<|> dbl :<|> _ :<|> _ :<|> _ :<|> _ ) =
50− clientA api (Proxy :: Proxy m) (Proxy :: Proxy []) (Proxy :: Proxy Int) url
51−
52− num :: Dynamic t (Either Text Double) <- fmap (note "No read" . readMaybe . T.unpack) . value <$> textInput def
53− num2 :: Dynamic t (Either Text Double) <- fmap (note "No read" . readMaybe . T.unpack) . value <$> textInput def
54−
55− b <- button "Run dbl multi"
56− reqCount :: Dynamic t Int <- count b
57− r <- dbl ((\x y -> [x,y]) <$> num <*> num2) (tag (current reqCount) b)
58− dynText =<< holdDyn "Waiting" (T.pack . show . fmap reqSuccess <$> r)
59−
60− lastInd <- holdDyn [] $ fmap reqTag <$> r
61− display lastInd
62−
63− divClass "demo-group" $ do
64− nms <- fmap (fmap T.words . value) $ divClass "" $ do
65− text "Names"
66− textInput def
67− grts <- fmap (fmap T.words . value) $ divClass "" $ do
68− text "Greetings"
69− textInput def
70− gust <- fmap (value) $ divClass "gusto-input" $ checkbox False def
71− b <- button "Go"
72− r' <- sayHi (fmap QParamSome <$> nms) (fmap (:[]) $ grts)
73− (constDyn [True, False]) (1 <$ b)
74−
75− dynText =<< holdDyn "Waiting" (T.pack . show . catMaybes .
76− fmap reqSuccess <$> r')
77−
78−
79− return ()
26+main = mainWidget run
27+
8028
8129run :: forall t m. (SupportsServantReflex t m,
8230 DomBuilder t m,
@@ -84,44 +32,35 @@ run :: forall t m. (SupportsServantReflex t m,
8432 MonadFix m,
8533 PostBuild t m,
8634 MonadHold t m) => m ()
87−run = mdo
35+run = do
8836
89− reqCount <- count $ leftmost
90− [() <$ unitBtn, () <$ intBtn, () <$ sayHiClicks, () <$ dblBtn, () <$ mpGo]
9137 -- Allow user to choose the url target for the request
9238 -- (alternatively we could just `let url = constDyn (BasePath "/")`)
9339 url <- baseUrlWidget
9440 el "br" (return ())
9541 dynText $ showBaseUrl <$> url
96−
9742 el "br" (return ())
9843
9944 -- Name the computed API client functions
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
45+ let (getUnit :<|> getInt :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|> doRaw) =
46+ client api (Proxy :: Proxy m) url
10747
108− (unitBtn, intBtn) <- elClass "div" "demo-group" $ do
48+ elClass "div" "demo-group" $ do
10949 unitBtn <- divClass "unit-button" $ button "Get unit"
11050 intBtn <- divClass "int-button" $ button "Get int"
11151
112− unitResponse <- getUnit $ tag (current reqCount) unitBtn
113− intResponse :: Event t (ReqResult Int Int) <- getInt $ tag (current reqCount) intBtn
52+ unitResponse <- getUnit unitBtn
53+ intResponse :: Event t (ReqResult Int) <- getInt intBtn
11454
115− score <- foldDyn (+) 0 (fmapMaybe reqSuccess (intResponse))
55+ score <- foldDyn (+) 0 (fmapMaybe reqSuccess intResponse)
11656
11757 r <- holdDyn "Waiting" $ fmap showXhrResponse $
118− leftmost [fmapMaybe response (unitResponse)
119− ,fmapMaybe response (intResponse)
58+ leftmost [fmapMaybe response unitResponse
59+ ,fmapMaybe response intResponse
12060 ]
12161 divClass "unit-int-response" $ el "p" $ dynText r >> el "br" (return ()) >> text "Total: " >> display score
122− return (unitBtn, intBtn)
12362
124− sayHiClicks <- elClass "div" "demo-group" $ do
63+ elClass "div" "demo-group" $ do
12564
12665 text "Name"
12766 el "br" $ return ()
@@ -139,65 +78,48 @@ run = mdo
13978 gusto <- fmap value $ divClass "gusto-input" $ checkbox False def
14079
14180 el "br" $ return ()
142− sayHiClicks :: Event t () <- divClass "hi-button" $ button "Say hi"
143− let triggers = leftmost [sayHiClicks, () <$ updated inp]
81+ sayhiClicks :: Event t () <- divClass "hi-button" $ button "Say hi"
82+ let triggers = leftmost [sayhiClicks, () <$ updated inp]
14483
145− resp <- sayhi checkedName greetings gusto (tag (current reqCount) triggers)
84+ resp <- sayhi checkedName greetings gusto triggers
14685 divClass "greeting-response" $ dynText =<<
147− holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (resp)
148− , fmapMaybe reqFailure (resp)])
149− return sayHiClicks
86+ holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess resp
87+ , fmapMaybe reqFailure resp])
15088
151− dblBtn <- elClass "div" "demo-group" $ do
89+ elClass "div" "demo-group" $ do
15290 text "A Double to double"
15391 el "br" $ return ()
154− dblinp <- fmap value $ divClass "double-input" $ textInput def
155− (dblBtn) <- divClass "double-button" $ button "Double it"
92+ dblinp <- fmap value $ divClass "double-input" $ textInput def
93+ dblBtn <- divClass "double-button" $ button "Double it"
15694 dblResp <- dbl (fmap (note "read failure" . readMaybe . T.unpack) $
157− dblinp) (tag (current reqCount) dblBtn)
95+ dblinp) dblBtn
15896 divClass "double-errors" $ dynText =<<
159− holdDyn "(no errors)" (fmapMaybe reqFailure (dblResp))
97+ holdDyn "(no errors)" (fmapMaybe reqFailure dblResp)
16098 el "br" (return ())
16199 divClass "double-result" $ el "p" $ dynText =<<
162100 holdDyn "No number yet" (fmap tShow $
163− fmapMaybe reqSuccess (dblResp))
164− return dblBtn
101+ fmapMaybe reqSuccess dblResp)
165102
166− mpGo <- elClass "div" "demo-group" $ do
103+ elClass "div" "demo-group" $ do
167104 text "Multi-part path"
168105 b <- value <$> checkbox False def
169106 mpGo <- button "Test"
170− multiResp <- multi b (tag (current reqCount) mpGo)
107+ multiResp <- multi b mpGo
171108 dynText =<< holdDyn "No res yet" (fmap tShow $
172109 fmapMaybe reqSuccess $
173− (multiResp))
174− return mpGo
175−
176− return ()
110+ multiResp)
177111
178112 el "br" $ return ()
179113
180114 elClass "div" "demo-group" $ do
181115 text "JSON Unicode encoding test"
182116 txt <- value <$> textInput def
183− ev <- fmap (1 <$) $ button "Question"
117+ ev <- button "Question"
184118 let dQ = Right . Question <$> traceDyn "will send: " txt
185119 rr <- qna dQ ev
186120 el "p" $
187121 dynText =<< holdDyn "No Answer" (unAnswer <$> fmapMaybe reqSuccess rr)
188122
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−
201123showXhrResponse :: XhrResponse -> Text
202124showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
203125 T.unlines ["stat: " <> tShow stat
nix/nix.confdeleted−3
@@ -1,3 +0,0 @@
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.nixdeleted−7
@@ -1,7 +0,0 @@
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.nixdeleted−7
@@ -1,7 +0,0 @@
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.nixdeleted−17
@@ -1,17 +0,0 @@
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.nixdeleted−9
@@ -1,9 +0,0 @@
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.nixnew file+40
@@ -0,0 +1,40 @@
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.nixnew file+35
@@ -0,0 +1,35 @@
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+18−36
@@ -1,8 +1,8 @@
11Name: servant-reflex
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
2+Version: 0.2.1
3+Synopsis: Servant reflex API generator
4+Description: Servant reflex API generator
5+License: AllRightsReserved
66License-file: LICENSE.md
77Author: Greg Hale, Doug Beardsley
88Maintainer: imalsogreg@gmail.com
@@ -11,59 +11,41 @@ Category: Web
1111Build-type: Simple
1212Cabal-version: >=1.10
1313
14−Flag Example
15− description: Enable example
16− default: False
17−
1814library
1915 exposed-modules:
16+ Servant.Reflex
17+
18+ other-modules:
2019 Servant.Common.BaseUrl
2120 Servant.Common.Req
22− Servant.Reflex
23− Servant.Reflex.Multi
2421
2522 hs-source-dirs: src
2623 build-depends:
27− base >= 4.8 && < 5,
24+ base >= 4.8 && < 4.10,
2825 bytestring >= 0.10 && < 0.11,
2926 case-insensitive >= 1.2.0.4 && < 1.3,
30− containers >= 0.5.6 && < 0.7,
27+ containers >= 0.5.6 && < 0.6,
3128 data-default >= 0.5 && < 0.8,
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,
29+ exceptions >= 0.8 && < 0.9,
30+ ghcjs-dom >= 0.2 && < 0.3,
31+ http-api-data >= 0.2 && < 0.4,
32+ http-media >= 0.6 && < 0.7,
3733 mtl >= 2.2.1 && < 2.3,
3834 network-uri >= 2.6 && < 2.7,
39− reflex >= 0.5 && < 0.9,
40− reflex-dom-core >= 0.6 && < 0.7,
35+ reflex >= 0.5 && < 0.6,
36+ reflex-dom == 0.4 && < 0.5,
4137 safe >= 0.3.9 && < 0.4,
42− servant >= 0.16 && < 0.18,
43− servant-auth >= 0.2.1 && < 0.4,
38+ servant >= 0.8 && < 0.11,
4439 string-conversions >= 0.4 && < 0.5,
4540 text >= 1.2 && < 1.3,
4641 transformers >= 0.4 && < 0.6
4742
48− ghc-options: -Wall -fwarn-tabs -funbox-strict-fields
43+ ghc-options: -Wall -fwarn-tabs -funbox-strict-fields -O2
4944
5045 default-language: Haskell2010
5146
5247executable example
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
48+ build-depends: aeson, reflex, servant-reflex, base, scientific, servant, reflex-dom, text
6749 default-language: Haskell2010
6850 main-is: Example.hs
6951 other-modules: API
shell.nixdeleted−1
@@ -1 +0,0 @@
1−(import ./travis.nix {nativeCompiler = "ghc";}).ghcPkgs.servant-reflex.env
src/Servant/Common/BaseUrl.hs+8−8
@@ -20,19 +20,18 @@ module Servant.Common.BaseUrl (
2020) where
2121
2222import Control.Monad (join)
23−-- import Control.Monad.IO.Class (MonadIO)
23+import Control.Monad.IO.Class (MonadIO)
2424import Control.Monad.Fix (MonadFix)
2525import Data.Monoid ((<>))
2626import Data.Text (Text)
2727import qualified Data.Text as T
2828import GHC.Generics
29−import Language.Javascript.JSaddle.Monad (MonadJSM)
3029import Reflex
31−import Reflex.Dom.Core
30+import Reflex.Dom
3231import Text.Read
3332
3433
35−type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadJSM (Performable m))
34+type SupportsServantReflex t m = (Reflex t, TriggerEvent t m, PerformEvent t m, HasWebView (Performable m), MonadIO (Performable m))
3635
3736-- | URI scheme to use
3837data Scheme =
@@ -85,14 +84,15 @@ baseUrlWidget = elClass "div" "base-url" $ do
8584 where pathWidget :: m (Dynamic t BaseUrl)
8685 pathWidget = do
8786 text "Url base path"
88− t <- inputElement def
87+ t <- textInput (def {_textInputConfig_attributes =
88+ constDyn ("placeholder" =: "/a/b")})
8989 return $ BasePath <$> value t
9090 fullUrlWidget :: m (Dynamic t BaseUrl)
9191 fullUrlWidget = do
9292 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
93− srv <- inputElement def
93+ srv <- textInput def {_textInputConfig_attributes = constDyn $ "placeholder" =: "example.com"}
9494 text ":"
95− prt <- inputElement def
95+ prt <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "80"}
9696 port :: Dynamic t Int <- holdDyn 80 (fmapMaybe (readMaybe . T.unpack) $ updated (value prt))
97− path <- inputElement def
97+ path <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "a/b" }
9898 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
src/Servant/Common/Req.hs+82−271
@@ -1,119 +1,55 @@
1+{-# LANGUAGE DeriveDataTypeable #-}
12{-# LANGUAGE CPP #-}
2−{-# LANGUAGE DeriveFunctor #-}
33{-# LANGUAGE FlexibleContexts #-}
44{-# LANGUAGE GADTs #-}
55{-# LANGUAGE OverloadedStrings #-}
66{-# LANGUAGE LambdaCase #-}
7−{-# LANGUAGE RankNTypes #-}
87{-# LANGUAGE ScopedTypeVariables #-}
98{-# LANGUAGE TupleSections #-}
10−
119module Servant.Common.Req where
1210
1311-------------------------------------------------------------------------------
1412import Control.Applicative (liftA2, liftA3)
15−import Control.Arrow ((&&&))
16−import Control.Concurrent
17−import Control.Monad (join)
18−import Control.Monad.IO.Class (MonadIO, liftIO)
19−import Data.Bifunctor (first)
20−import qualified Data.ByteString.Builder as Builder
2113import qualified Data.ByteString.Lazy.Char8 as BL
22−import Data.ByteString (ByteString)
2314import qualified Data.Map as Map
24−import Data.Maybe (catMaybes, fromMaybe)
25−import Data.Functor.Compose
15+import Data.Maybe (catMaybes)
2616import Data.Monoid ((<>))
2717import Data.Proxy (Proxy(..))
2818import Data.Text (Text)
2919import qualified Data.Text as T
3020import qualified Data.Text.Encoding as TE
31−import Data.Traversable (forM)
32−import Language.Javascript.JSaddle.Monad (JSM, MonadJSM, liftJSM)
33−import qualified Network.URI as N
34−import Reflex.Dom.Core hiding (tag)
35−import Servant.Common.BaseUrl (BaseUrl, showBaseUrl,
36− SupportsServantReflex)
21+import Reflex.Dom
22+import Servant.Common.BaseUrl (BaseUrl, showBaseUrl, SupportsServantReflex)
3723import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
3824import Web.HttpApiData (ToHttpApiData(..))
3925-------------------------------------------------------------------------------
4026import Servant.API.BasicAuth
4127
4228
43−------------------------------------------------------------------------------
44−-- | The result of a request event
45−data ReqResult tag a
46− = ResponseSuccess tag a XhrResponse
47− -- ^ The succesfully decoded response from a request tagged with 'tag'
48− | ResponseFailure tag Text XhrResponse
49− -- ^ The failure response, which may have failed decoding or had
50− -- a non-successful response code
51− | RequestFailure tag Text
52− -- ^ A failure to construct the request tagged with 'tag' at trigger time
53− deriving (Functor)
54−
55−data ClientOptions = ClientOptions
56− { optsRequestFixup :: forall a. Show a => XhrRequest a -> JSM (XhrRequest a)
57− -- ^ Aribtrarily modify requests just before they are sent.
58− -- Warning: This escape hatch opens the possibility for your
59− -- requests to diverge from what the server expects, when the
60− -- server is also derived from a servant API
61− }
62−
63−defaultClientOptions :: ClientOptions
64−defaultClientOptions = ClientOptions { optsRequestFixup = return }
65−
66−-- withCredentials :: Lens' (XhrRequest a) Bool
67−withCredentials :: (Show a, Functor f) => (Bool -> f Bool) -> XhrRequest a -> f (XhrRequest a)
68−withCredentials inj r@(XhrRequest _ _ cfg) =
69− let cfg' = (\b -> cfg { _xhrRequestConfig_withCredentials = b}) <$>
70− inj (_xhrRequestConfig_withCredentials cfg)
71− in (\c' -> r {_xhrRequest_config = c' }) <$> cfg'
72−
73−------------------------------------------------------------------------------
74−-- | Simple filter/accessor for successful responses, when you want to
75−-- ignore the error case. For example:
76−-- >> goodResponses <- fmapMaybe reqSuccess <$> clientFun triggers
77−reqSuccess :: ReqResult tag a -> Maybe a
78−reqSuccess (ResponseSuccess _ x _) = Just x
79−reqSuccess _ = Nothing
80−
81−
82−------------------------------------------------------------------------------
83−-- | Simple filter/accessor like 'reqSuccess', but keeping the request tag
84−reqSuccess' :: ReqResult tag a -> Maybe (tag,a)
85−reqSuccess' (ResponseSuccess tag x _) = Just (tag,x)
86−reqSuccess' _ = Nothing
87−
88−
89−------------------------------------------------------------------------------
90−-- | Simple filter/accessor for any failure case
91−reqFailure :: ReqResult tag a -> Maybe Text
92−reqFailure (ResponseFailure _ s _) = Just s
93−reqFailure (RequestFailure _ s) = Just s
94−reqFailure _ = Nothing
95−
96−------------------------------------------------------------------------------
97−-- | Simple filter/accessor like 'reqFailure', but keeping the request tag
98−reqFailure' :: ReqResult tag a -> Maybe (tag,Text)
99−reqFailure' (ResponseFailure tag s _) = Just (tag,s)
100−reqFailure' (RequestFailure tag s) = Just (tag,s)
101−reqFailure' _ = Nothing
102−
103−
104−------------------------------------------------------------------------------
105−-- | Simple filter/accessor for the raw XHR response
106−response :: ReqResult tag a -> Maybe XhrResponse
107−response (ResponseSuccess _ _ x) = Just x
108−response (ResponseFailure _ _ x) = Just x
109−response _ = Nothing
110−
111−------------------------------------------------------------------------------
112−-- | Retrieve response tag
113−reqTag :: ReqResult tag a -> tag
114−reqTag (ResponseSuccess tag _ _) = tag
115−reqTag (ResponseFailure tag _ _) = tag
116−reqTag (RequestFailure tag _ ) = tag
29+
30+data ReqResult a = ResponseSuccess a XhrResponse
31+ | ResponseFailure Text XhrResponse
32+ | RequestFailure Text
33+
34+instance Functor ReqResult where
35+ fmap f (ResponseSuccess a xhr) = ResponseSuccess (f a) xhr
36+ fmap _ (ResponseFailure r x) = ResponseFailure r x
37+ fmap _ (RequestFailure r) = RequestFailure r
38+
39+reqSuccess :: ReqResult a -> Maybe a
40+reqSuccess (ResponseSuccess x _) = Just x
41+reqSuccess _ = Nothing
42+
43+reqFailure :: ReqResult a -> Maybe Text
44+reqFailure (ResponseFailure s _) = Just s
45+reqFailure (RequestFailure s) = Just s
46+reqFailure _ = Nothing
47+
48+response :: ReqResult a -> Maybe XhrResponse
49+response (ResponseSuccess _ x) = Just x
50+response (ResponseFailure _ x) = Just x
51+response _ = Nothing
52+
11753
11854-------------------------------------------------------------------------------
11955-- | You must wrap the parameter of a QueryParam endpoint with 'QParam' to
@@ -126,13 +62,11 @@ data QParam a = QParamSome a
12662 | QParamInvalid Text
12763 -- ^ Indication that your validation failed (the request isn't valid)
12864
129−
13065qParamToQueryPart :: ToHttpApiData a => QParam a -> Either Text (Maybe Text)
13166qParamToQueryPart (QParamSome a) = Right (Just $ toQueryParam a)
13267qParamToQueryPart QNone = Right Nothing
13368qParamToQueryPart (QParamInvalid e) = Left e
13469
135−
13670data QueryPart t = QueryPartParam (Dynamic t (Either Text (Maybe Text)))
13771 | QueryPartParams (Dynamic t [Text])
13872 | QueryPartFlag (Dynamic t Bool)
@@ -162,13 +96,20 @@ addHeader :: (ToHttpApiData a, Reflex t) => Text -> Dynamic t (Either Text a) ->
16296addHeader name val req = req { headers = (name, (fmap . fmap) (TE.decodeUtf8 . toHeader) val) : headers req }
16397
16498
165−reqToReflexRequest
166− :: forall t. Reflex t
167− => Text
168− -> Dynamic t BaseUrl
169− -> Req t
170− -> Dynamic t (Either Text (XhrRequest XhrPayload))
171−reqToReflexRequest reqMeth reqHost req =
99+-- * performing requests
100+
101+displayHttpRequest :: Text -> Text
102+displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
103+
104+-- | This function actually performs the request.
105+performRequest :: forall t m.(SupportsServantReflex t m)
106+ => Text
107+ -> Req t
108+ -> Dynamic t BaseUrl
109+ -> Event t ()
110+ -> m (Event t XhrResponse, Event t Text)
111+performRequest reqMeth req reqHost trigger = do
112+
172113 let t :: Dynamic t [Either Text Text]
173114 t = sequence $ reverse $ reqPathParts req
174115
@@ -179,22 +120,18 @@ reqToReflexRequest reqMeth reqHost req =
179120 urlParts = fmap sequence t
180121
181122 urlPath :: Dynamic t (Either Text Text)
182− urlPath = (fmap.fmap)
183− (T.intercalate "/" . fmap escape)
184− urlParts
123+ urlPath = (fmap.fmap) (T.intercalate "/") urlParts
185124
186125 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
187126 queryPartString (pName, qp) = case qp of
188127 QueryPartParam p -> ffor p $ \case
189128 Left e -> Just (Left e)
190− Right (Just a) -> Just (Right $ pName <> "=" <> escape a)
129+ Right (Just a) -> Just (Right $ pName <> "=" <> a)
191130 Right Nothing -> Nothing
192131 QueryPartParams ps -> ffor ps $ \pStrings ->
193132 if null pStrings
194133 then Nothing
195− else Just . Right
196− . T.intercalate "&"
197− $ fmap (\p -> pName <> "=" <> escape p) pStrings
134+ else Just $ Right (T.intercalate "&" (fmap (\p -> pName <> "=" <> p) pStrings))
198135 QueryPartFlag fl -> ffor fl $ \case
199136 True -> Just $ Right pName
200137 False -> Nothing
@@ -205,8 +142,8 @@ reqToReflexRequest reqMeth reqHost req =
205142 queryPartStrings' = fmap (sequence . catMaybes) $ sequence queryPartStrings :: Dynamic t (Either Text [Text])
206143 queryString :: Dynamic t (Either Text Text) =
207144 ffor queryPartStrings' $ \qs -> fmap (T.intercalate "&") qs
208− xhrUrl = (liftA3 . liftA3) (\a p q -> a </> if T.null q then p else p <> "?" <> q)
209− baseUrl urlPath queryString
145+-- ffor queryPartStrings' $ \qs -> fmap (T.intercalate "&") (sequence qs)
146+ xhrUrl = (liftA3 . liftA3) (\a p q -> a </> if T.null q then p else p <> "?" <> q) baseUrl urlPath queryString
210147 where
211148 (</>) :: Text -> Text -> Text
212149 x </> y | ("/" `T.isSuffixOf` x) || ("/" `T.isPrefixOf` y) = x <> y
@@ -229,10 +166,10 @@ reqToReflexRequest reqMeth reqHost req =
229166 Right $ XhrRequestConfig
230167 { _xhrRequestConfig_sendData = bytesToPayload bBytes
231168 , _xhrRequestConfig_headers =
232− Map.insert "Content-Type" bCT (Map.fromList hs)
169+ Map.insert "Content-Type" bCT (Map.fromList hs)
233170 , _xhrRequestConfig_user = Nothing
234171 , _xhrRequestConfig_password = Nothing
235− , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
172+ , _xhrRequestConfig_responseType = Nothing
236173 , _xhrRequestConfig_withCredentials = False
237174 , _xhrRequestConfig_responseHeaders = def
238175 }
@@ -244,8 +181,8 @@ reqToReflexRequest reqMeth reqHost req =
244181 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
245182 , _xhrRequestConfig_user = Nothing
246183 , _xhrRequestConfig_password = Nothing
247− , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
248− , _xhrRequestConfig_sendData = mempty
184+ , _xhrRequestConfig_responseType = Nothing
185+ , _xhrRequestConfig_sendData = ""
249186 , _xhrRequestConfig_withCredentials = False
250187 }
251188 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
@@ -265,167 +202,41 @@ reqToReflexRequest reqMeth reqHost req =
265202
266203 xhrReq = (liftA2 . liftA2) (\p opt -> XhrRequest reqMeth p opt) xhrUrl (addAuth xhrOpts)
267204
268− in xhrReq
205+ let reqs = tagPromptlyDyn xhrReq trigger
206+ okReqs = fmapMaybe (either (const Nothing) Just) reqs
207+ badReqs = fmapMaybe (either Just (const Nothing)) reqs
269208
270−-- * performing requests
209+ resps <- performRequestAsync okReqs
271210
272−displayHttpRequest :: Text -> Text
273−displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
211+ return (resps, badReqs)
274212
275−-- | This function performs the request
276−performRequests :: forall t m f tag.(SupportsServantReflex t m, Traversable f)
277− => Text
278− -> Dynamic t (f (Req t))
279− -> Dynamic t BaseUrl
280− -> ClientOptions
281− -> Event t tag
282− -> m (Event t (tag, f (Either Text XhrResponse)))
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
293− return $ getCompose <$> resps
294−
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.
298−performSomeRequestsAsync
299− :: (MonadIO (Performable m),
300− MonadJSM (Performable m),
301− HasWebView (Performable m),
302− PerformEvent t m,
303− TriggerEvent t m,
304− Traversable f,
305− IsXhrPayload a,
306− Show a
307− )
308− => ClientOptions
309− -> Event t (f (Either Text (XhrRequest a)))
310− -> m (Event t (f (Either Text XhrResponse)))
311−performSomeRequestsAsync opts =
312− performSomeRequestsAsync' opts newXMLHttpRequest . fmap return
313−
314−
315−------------------------------------------------------------------------------
316−-- | A modified version or Reflex.Dom.Xhr.performRequestsAsync
317−-- that accepts 'f (Either e (XhrRequestb))' events
318−performSomeRequestsAsync'
319− :: (MonadJSM (Performable m), PerformEvent t m, TriggerEvent t m, Traversable f, Show b)
320− => ClientOptions
321− -> (XhrRequest b -> (a -> JSM ()) -> Performable m XMLHttpRequest)
322− -> Event t (Performable m (f (Either Text (XhrRequest b)))) -> m (Event t (f (Either Text a)))
323−performSomeRequestsAsync' opts newXhr req = performEventAsync $ ffor req $ \hrs cb -> do
324− rs <- hrs
325− resps <- forM rs $ \r -> case r of
326− Left e -> do
327− resp <- liftIO $ newMVar (Left e)
328− return resp
329− Right r' -> do
330− resp <- liftIO newEmptyMVar
331− r'' <- liftJSM $ (optsRequestFixup opts) r'
332− _ <- newXhr r'' $ liftIO . putMVar resp . Right
333− return resp
334− _ <- liftIO $ forkIO $ cb =<< forM resps takeMVar
335− return ()
336−
337−
338−
339−type XhrPayload = ByteString
213+type XhrPayload = T.Text
340214bytesToPayload :: BL.ByteString -> XhrPayload
341−bytesToPayload = BL.toStrict
342−
343−
344−performRequestsCT
345− :: (SupportsServantReflex t m,
346− MimeUnrender ct a, Traversable f)
347− => Proxy ct
348− -> Text
349− -> Dynamic t (f (Req t))
350− -> Dynamic t BaseUrl
351− -> ClientOptions
352− -> Event t tag
353− -> m (Event t (f (ReqResult tag a)))
354−performRequestsCT ct reqMeth reqs reqHost opts trigger = do
355− resps <- performRequests reqMeth reqs reqHost opts trigger
356− let decodeResp (Just (XhrResponseBody_ArrayBuffer x)) =
357− first T.pack .
358− mimeUnrender ct $
359− BL.fromStrict x
360− decodeResp _ = Left "No body"
361− return $ fmap
362− (\(t,rs) -> ffor rs $ \r -> case r of
363− Left e -> RequestFailure t e
364− Right g -> evalResponse (decodeResp . _xhrResponse_response) (t,g)
365− )
366− resps
367−
368−
369−performRequestsNoBody
370− :: (SupportsServantReflex t m,
371− Traversable f)
372− => Text
373− -> Dynamic t (f (Req t))
374− -> Dynamic t BaseUrl
375− -> ClientOptions
376− -> Event t tag
377− -> m (Event t (f (ReqResult tag NoContent)))
378−performRequestsNoBody reqMeth reqs reqHost opts trigger = do
379− resps <- performRequests reqMeth reqs reqHost opts trigger
380− let decodeResp = const $ Right NoContent
381− return $ ffor resps $ \(tag,rs) -> ffor rs $ \r -> case r of
382− Left e -> RequestFailure tag e
383− Right g -> evalResponse decodeResp (tag,g)
384−
385−
386−------------------------------------------------------------------------------
387−evalResponse
388− :: (XhrResponse -> Either Text a)
389− -> (tag, XhrResponse)
390− -> ReqResult tag a
391−evalResponse decode (tag, xhr) =
392− let status = _xhrResponse_status xhr
393− okStatus = status >= 200 && status < 400
394− errMsg = fromMaybe
395− ("Empty response with error code " <>
396− T.pack (show $ _xhrResponse_status xhr))
397− (_xhrResponse_responseText xhr)
398− respPayld = if okStatus
399− then either
400− (\e -> ResponseFailure tag e xhr)
401− (\v -> ResponseSuccess tag v xhr)
402− (decode xhr)
403− else ResponseFailure tag errMsg xhr
404− in respPayld
405−
406−------------------------------------------------------------------------------
407−-- | Utility for simultaneously accessing/filtering Success and Failure
408−-- response 'Event's,
409−fanReqResult :: Reflex t => Event t (ReqResult tag a) -> (Event t Text, Event t a)
410−fanReqResult = fmapMaybe reqFailure &&& fmapMaybe reqSuccess
411−
412−------------------------------------------------------------------------------
413−-- | Utility for simultaneously accessing/filtering Success and Failure
414−-- response 'Event's, but keeping the request tag
415−fanReqResult' :: Reflex t => Event t (ReqResult tag a) -> (Event t (tag, Text), Event t (tag, a))
416−fanReqResult' = fmapMaybe reqFailure' &&& fmapMaybe reqSuccess'
417−
215+bytesToPayload = TE.decodeUtf8 . BL.toStrict
216+
217+performRequestNoBody :: forall t m .(SupportsServantReflex t m)
218+ => Text
219+ -> Req t
220+ -> Dynamic t BaseUrl
221+ -> Event t () -> m (Event t (ReqResult NoContent))
222+performRequestNoBody reqMeth req reqHost trigger = do
223+ (resp, badReq) <- performRequest reqMeth req reqHost trigger
224+ return $ leftmost [ fmap (ResponseSuccess NoContent) resp, fmap RequestFailure badReq]
225+
226+
227+performRequestCT :: (SupportsServantReflex t m,
228+ MimeUnrender ct a)
229+ => Proxy ct -> Text -> Req t -> Dynamic t BaseUrl
230+ -> Event t () -> m (Event t (ReqResult a))
231+performRequestCT ct reqMeth req reqHost trigger = do
232+ (resp, badReq) <- performRequest reqMeth req reqHost trigger
233+ let decodes = ffor resp $ \xhr ->
234+ ((mimeUnrender ct . BL.fromStrict . TE.encodeUtf8)
235+ =<< note "No body text" (_xhrResponse_responseText xhr), xhr)
236+ reqs = ffor decodes $ \case
237+ (Right a, r) -> ResponseSuccess a r
238+ (Left e, r) -> ResponseFailure (T.pack e) r
239+ return $ leftmost [reqs, fmap RequestFailure badReq]
418240
419241note :: e -> Maybe a -> Either e a
420242note e = maybe (Left e) Right
421−
422−fmapL :: (e -> e') -> Either e a -> Either e' a
423−fmapL _ (Right a) = Right a
424−fmapL 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+193−331
@@ -1,23 +1,16 @@
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
1+{-# LANGUAGE CPP #-}
2+{-# LANGUAGE DataKinds #-}
3+{-# LANGUAGE FlexibleContexts #-}
4+{-# LANGUAGE FlexibleInstances #-}
5+{-# LANGUAGE InstanceSigs #-}
6+{-# LANGUAGE MultiParamTypeClasses #-}
7+{-# LANGUAGE OverloadedStrings #-}
8+{-# LANGUAGE PolyKinds #-}
9+{-# LANGUAGE ScopedTypeVariables #-}
10+{-# LANGUAGE TupleSections #-}
11+{-# LANGUAGE TypeFamilies #-}
12+{-# LANGUAGE TypeOperators #-}
13+{-# LANGUAGE UndecidableInstances #-}
2114
2215-- #include "overlapping-compat.h"
2316-- | This module provides 'client' which can automatically generate
@@ -25,71 +18,47 @@
2518-- API.
2619module Servant.Reflex
2720 ( client
28− , clientWithOpts
29− , clientWithOptsAndResultHandler
30− , clientWithRoute
31− , clientWithRouteAndResultHandler
32− , BuildHeaderKeysTo(..)
33− , toHeaders
34− , HasClient
35− , Client
21+ , HasClient(..)
3622 , module Servant.Common.Req
3723 , module Servant.Common.BaseUrl
3824 ) where
3925
40−------------------------------------------------------------------------------
26+-------------------------------------------------------------------------------
4127import Control.Applicative
42−import qualified Data.CaseInsensitive as CI
43−import Data.Functor.Identity
44−import qualified Data.Map as Map
45−import Data.Monoid ((<>))
46−import Data.Proxy (Proxy (..))
47−import qualified Data.Set as Set
48−import Data.Text (Text)
49−import qualified Data.Text as T
50−import qualified Data.Text.Encoding as E
51−import GHC.Exts (Constraint)
52−import GHC.TypeLits (KnownSymbol, symbolVal)
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 (..),
60− RemoteHost, ReqBody,
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)
72−------------------------------------------------------------------------------
73−import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
74− showBaseUrl,
75− SupportsServantReflex)
76−import Servant.Common.Req (ClientOptions(..),
77− defaultClientOptions,
78− Req, ReqResult(..), QParam(..),
79− QueryPart(..), addHeader, authData,
80− defReq, evalResponse, prependToPathParts,
81− -- performRequestCT,
82− performRequestsCT,
83− -- performRequestNoBody,
84− performRequestsNoBody,
85− performSomeRequestsAsync,
86− qParamToQueryPart, reqBody,
87− reqSuccess, reqFailure,
88− reqMethod, respHeaders,
89− response,
90− reqTag,
91− qParams, withCredentials)
92−
28+import Data.CaseInsensitive (mk)
29+import qualified Data.Map as Map
30+import Data.Monoid ((<>))
31+import Data.Proxy (Proxy (..))
32+import qualified Data.Set as Set
33+import Data.Text (Text)
34+import qualified Data.Text as T
35+import qualified Data.Text.Encoding as E
36+import GHC.TypeLits (KnownSymbol, symbolVal)
37+import Reflex.Dom (Dynamic, Event, Reflex,
38+ XhrRequest (..), XhrResponse (..),
39+ XhrResponseHeaders (..), ffor,
40+ fmapMaybe, leftmost,
41+ performRequestAsync, tagPromptlyDyn)
42+import Servant.API ((:<|>) (..), (:>), BasicAuth,
43+ BasicAuthData, BuildHeadersTo (..),
44+ Capture, Header, Headers (..),
45+ HttpVersion, IsSecure, MimeRender (..),
46+ MimeUnrender, NoContent, QueryFlag,
47+ QueryParam, QueryParams, Raw,
48+ ReflectMethod (..), RemoteHost,
49+ ReqBody, ToHttpApiData (..), Vault,
50+ Verb, contentType)
51+import Servant.Common.BaseUrl (BaseUrl (..), Scheme (..),
52+ SupportsServantReflex, baseUrlWidget,
53+ showBaseUrl)
54+import Servant.Common.Req (QParam (..), QueryPart (..), Req,
55+ ReqResult (..), addHeader, authData,
56+ defReq, performRequestCT,
57+ performRequestNoBody,
58+ prependToPathParts, qParamToQueryPart,
59+ qParams, reqBody, reqFailure,
60+ reqMethod, reqSuccess, respHeaders,
61+ response)
9362
9463-- * Accessing APIs as a Client
9564
@@ -101,78 +70,28 @@ import Servant.Common.Req (ClientOptions(..),
10170-- > myApi :: Proxy MyApi
10271-- > myApi = Proxy
10372-- >
104−-- > getAllBooks :: Event t l -> m (Event t (l, ReqResult [Book]))
105−-- > postNewBook :: Dynamic t (Maybe Book) -> Event t l
106−-- > -> m (Event t (l, ReqResult Book)))
73+-- > getAllBooks :: Event t () -> m (Event t (Either XhrError ((),[Book])))
74+-- > postNewBook :: Dynamic t (Maybe Book) -> Event t ()
75+-- -> m (Event t (Either XhrError (Book,Book)))
10776-- > (getAllBooks :<|> postNewBook) = client myApi host
10877-- > where host = constDyn $ BaseUrl Http "localhost" 8080
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
141−
78+client :: (HasClient t m layout)
79+ => Proxy layout -> Proxy m -> Dynamic t BaseUrl -> Client t m layout
80+client p q = clientWithRoute p q defReq
14281
14382-- | This class lets us define how each API combinator
14483-- influences the creation of an HTTP request. It's mostly
14584-- an internal class, you can just use 'client'.
146−class Monad m => HasClient t m layout (tag :: *) where
147− type 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
167−
168−
169−instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b) tag where
170− type Client t m (a :<|> b) tag = Client t m a tag :<|> Client t m b tag
171−
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
85+class HasClient t m layout where
86+ type Client t m layout :: *
87+ clientWithRoute :: Proxy layout -> Proxy m -> Req t -> Dynamic t BaseUrl -> Client t m layout
88+
17589
90+instance (HasClient t m a, HasClient t m b) => HasClient t m (a :<|> b) where
91+ type Client t m (a :<|> b) = Client t m a :<|> Client t m b
92+ clientWithRoute Proxy q req baseurl =
93+ clientWithRoute (Proxy :: Proxy a) q req baseurl :<|>
94+ clientWithRoute (Proxy :: Proxy b) q req baseurl
17695
17796-- Capture. Example:
17897-- > type MyApi = "books" :> Capture "isbn" Text :> Get '[JSON] Book
@@ -182,72 +101,67 @@ instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b)
182101-- > getBook :: SupportsServantReflex t m
183102-- => Dynamic t BaseUrl
184103-- -> Dynamic t (Maybe Text)
185−-- -> Event t l
186−-- -> m (Event t (l, ReqResult Book))
104+-- -> Event t ()
105+-- -> m (Event t (Either XhrError (Text, Book)))
187106-- > getBook = client myApi (constDyn host)
107+instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout)
108+ => HasClient t m (Capture capture a :> sublayout) where
188109
189−instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout tag)
190− => HasClient t m (Capture capture a :> sublayout) tag where
110+ type Client t m (Capture capture a :> sublayout) =
111+ Dynamic t (Either Text a) -> Client t m sublayout
191112
192− type Client t m (Capture capture a :> sublayout) tag =
193− Dynamic t (Either Text a) -> Client t m sublayout tag
194−
195− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap val =
196− clientWithRouteAndResultHandler
197− (Proxy :: Proxy sublayout) q t (prependToPathParts p req) baseurl opts wrap
198− where p = (fmap . fmap) (toUrlPiece) val
113+ clientWithRoute Proxy q req baseurl val =
114+ clientWithRoute (Proxy :: Proxy sublayout)
115+ q
116+ (prependToPathParts p req)
117+ baseurl
199118
119+ where p = (fmap . fmap) toUrlPiece val
200120
201121-- VERB (Returning content) --
202122instance {-# OVERLAPPABLE #-}
203123 -- Note [Non-Empty Content Types]
204124 (MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
205− ) => HasClient t m (Verb method status cts' a) tag where
206− type Client t m (Verb method status cts' a) tag =
207− Event t tag -> m (Event t (ReqResult tag a))
125+ ) => HasClient t m (Verb method status cts' a) where
126+ type Client t m (Verb method status cts' a) =
127+ Event t () -> m (Event t (ReqResult a))
208128 -- TODO how to access input types here?
209129 -- ExceptT ServantError IO a
210− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
211− wrap =<< fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity $ req') baseurl opts trigs
130+ clientWithRoute Proxy _ req =
131+ performRequestCT (Proxy :: Proxy ct) method req'
212132 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
213133 req' = req { reqMethod = method }
214134
215−
216135-- -- VERB (No content) --
217136instance {-# OVERLAPPING #-}
218137 (ReflectMethod method, SupportsServantReflex t m) =>
219− HasClient t m (Verb method status cts NoContent) tag where
220− type Client t m (Verb method status cts NoContent) tag =
221− Event t tag -> m (Event t (ReqResult tag NoContent))
138+ HasClient t m (Verb method status cts NoContent) where
139+ type Client t m (Verb method status cts NoContent) =
140+ Event t () -> m (Event t (ReqResult NoContent))
222141 -- TODO: how to access input types here?
223142 -- ExceptT ServantError IO NoContent
224− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
225− wrap =<< fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req) baseurl opts trigs
143+ clientWithRoute Proxy _ =
144+ performRequestNoBody method
226145 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
227146
228−
229−toHeaders :: BuildHeadersTo ls => ReqResult tag a -> ReqResult tag (Headers ls a)
147+toHeaders :: BuildHeadersTo ls => ReqResult a -> ReqResult (Headers ls a)
230148toHeaders r =
231− let hdrs = maybe []
232− (\xhr -> fmap (\(h,v) -> (CI.map E.encodeUtf8 h, E.encodeUtf8 v))
149+ let toBS = E.encodeUtf8
150+ hdrs = maybe []
151+ (\xhr -> fmap (\(h,v) -> (mk (toBS h), toBS v))
233152 (Map.toList $ _xhrResponse_headers xhr))
234153 (response r)
235154 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
236155
237−
238156class BuildHeaderKeysTo hs where
239− buildHeaderKeysTo :: Proxy hs -> [CI.CI T.Text]
157+ buildHeaderKeysTo :: Proxy hs -> [T.Text]
240158
241159instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
242160 where buildHeaderKeysTo _ = []
243161
244162instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
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−
163+ => BuildHeaderKeysTo '[(Header h v) ': xs] where
164+ buildHeaderKeysTo _ = T.pack (symbolVal (Proxy :: Proxy h)) : buildHeaderKeysTo (Proxy :: Proxy xs)
251165
252166-- HEADERS Verb (Content) --
253167-- Headers combinator not treated in fully general case,
@@ -259,35 +173,33 @@ instance {-# OVERLAPPABLE #-}
259173 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
260174 ReflectMethod method, cts' ~ (ct ': cts),
261175 SupportsServantReflex t m
262− ) => HasClient t m (Verb method status cts' (Headers ls a)) tag where
263− type Client t m (Verb method status cts' (Headers ls a)) tag =
264− Event t tag -> m (Event t (ReqResult tag (Headers ls a)))
265− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
176+ ) => HasClient t m (Verb method status cts' (Headers ls a)) where
177+ type Client t m (Verb method status cts' (Headers ls a)) =
178+ Event t () -> m (Event t (ReqResult (Headers ls a)))
179+ clientWithRoute Proxy _ req baseurl = do
266180 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
267− resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl opts trigs
268− wrap $ toHeaders <$> resp
181+ resp <- performRequestCT (Proxy :: Proxy ct) method req' baseurl
182+ return $ (fmap . fmap) toHeaders resp
269183 where req' = req { respHeaders =
270184 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
271185 }
272186
273−
274187-- HEADERS Verb (No content) --
275188instance {-# OVERLAPPABLE #-}
276189 ( BuildHeadersTo ls, BuildHeaderKeysTo ls, ReflectMethod method,
277190 SupportsServantReflex t m
278− ) => HasClient t m (Verb method status cts (Headers ls NoContent)) tag where
279− type Client t m (Verb method status cts (Headers ls NoContent)) tag
280− = Event t tag -> m (Event t (ReqResult tag (Headers ls NoContent)))
281− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
191+ ) => HasClient t m (Verb method status cts (Headers ls NoContent)) where
192+ type Client t m (Verb method status cts (Headers ls NoContent))
193+ = Event t () -> m (Event t (ReqResult (Headers ls NoContent)))
194+ clientWithRoute Proxy _ req baseurl = do
282195 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
283− resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl opts trigs
284− wrap $ toHeaders <$> resp
196+ resp <- performRequestNoBody method req' baseurl
197+ return $ (fmap . fmap) toHeaders resp
285198 where req' = req {respHeaders =
286199 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
287200 }
288201
289202
290−
291203-- HEADER
292204-- > newtype Referer = Referer { referrer :: Text }
293205-- > deriving (Eq, Show, Generic, FromText, ToHttpApiData)
@@ -302,45 +214,28 @@ instance {-# OVERLAPPABLE #-}
302214-- > -- then you can just use "viewRefer" to query that endpoint
303215-- > -- specifying Nothing or e.g Just "http://haskell.org/" as arguments
304216instance (KnownSymbol sym, ToHttpApiData a,
305− HasClient t m sublayout tag, SupportsServantReflex t m)
306− => HasClient t m (Header sym a :> sublayout) tag where
217+ HasClient t m sublayout, SupportsServantReflex t m)
218+ => HasClient t m (Header sym a :> sublayout) where
307219
308− type Client t m (Header sym a :> sublayout) tag =
309− Dynamic t (Either Text a) -> Client t m sublayout tag
220+ type Client t m (Header sym a :> sublayout) =
221+ Dynamic t (Either Text a) -> Client t m sublayout
310222
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
223+ clientWithRoute Proxy q req baseurl eVal =
224+ clientWithRoute (Proxy :: Proxy sublayout)
225+ q
226+ (Servant.Common.Req.addHeader hname eVal req)
227+ baseurl
316228 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
317229
318−
319−
320−
321230-- | Using a 'HttpVersion' combinator in your API doesn't affect the client
322231-- functions.
323−instance HasClient t m sublayout tag
324− => HasClient t m (HttpVersion :> sublayout) tag where
325−
326− type Client t m (HttpVersion :> sublayout) tag =
327− Client t m sublayout tag
328−
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)
232+instance HasClient t m sublayout
233+ => HasClient t m (HttpVersion :> sublayout) where
342234
235+ type Client t m (HttpVersion :> sublayout) =
236+ Client t m sublayout
343237
238+ clientWithRoute Proxy = clientWithRoute (Proxy :: Proxy sublayout)
344239
345240
346241-- | If you use a 'QueryParam' in one of your endpoints in your API,
@@ -369,16 +264,16 @@ instance (HasClient t m sublayout tag, KnownSymbol sym)
369264-- > -- then you can just use "getBooksBy" to query that endpoint.
370265-- > -- 'getBooksBy Nothing' for all books
371266-- > -- 'getBooksBy (Just "Isaac Asimov")' to get all books by Isaac Asimov
372−instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex t)
373− => HasClient t m (QueryParam sym a :> sublayout) tag where
267+instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout, Reflex t)
268+ => HasClient t m (QueryParam sym a :> sublayout) where
374269
375− type Client t m (QueryParam sym a :> sublayout) tag =
376− Dynamic t (QParam a) -> Client t m sublayout tag
270+ type Client t m (QueryParam sym a :> sublayout) =
271+ Dynamic t (QParam a) -> Client t m sublayout
377272
378273 -- if mparam = Nothing, we don't add it to the query string
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
274+ clientWithRoute Proxy q req baseurl mparam =
275+ clientWithRoute (Proxy :: Proxy sublayout) q
276+ (req {qParams = paramPair : qParams req}) baseurl
382277
383278 where pname = symbolVal (Proxy :: Proxy sym)
384279 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
@@ -386,8 +281,6 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
386281 p prm = QueryPartParam $ fmap qParamToQueryPart prm -- (fmap . fmap) (unpack . toQueryParam) prm
387282 paramPair = (T.pack pname, p mparam)
388283
389−
390−
391284-- | If you use a 'QueryParams' in one of your endpoints in your API,
392285-- the corresponding querying function will automatically take
393286-- an additional argument, a list of values of the type specified
@@ -416,14 +309,14 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
416309-- > -- 'getBooksBy []' for all books
417310-- > -- 'getBooksBy ["Isaac Asimov", "Robert A. Heinlein"]'
418311-- > -- to get all books by Asimov and Heinlein
419−instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex t)
420− => HasClient t m (QueryParams sym a :> sublayout) tag where
312+instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout, Reflex t)
313+ => HasClient t m (QueryParams sym a :> sublayout) where
421314
422− type Client t m (QueryParams sym a :> sublayout) tag =
423− Dynamic t [a] -> Client t m sublayout tag
315+ type Client t m (QueryParams sym a :> sublayout) =
316+ Dynamic t [a] -> Client t m sublayout
424317
425− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap paramlist =
426− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
318+ clientWithRoute Proxy q req baseurl paramlist =
319+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
427320
428321 where req' = req { qParams = (T.pack pname, params') : qParams req }
429322 pname = symbolVal (Proxy :: Proxy sym)
@@ -431,7 +324,6 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
431324 paramlist
432325
433326
434−
435327-- | If you use a 'QueryFlag' in one of your endpoints in your API,
436328-- the corresponding querying function will automatically take
437329-- an additional 'Bool' argument.
@@ -456,42 +348,49 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
456348-- > -- 'getBooksBy True' to only get _already published_ books
457349
458350-- TODO Bring back
459−instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
460− => HasClient t m (QueryFlag sym :> sublayout) tag where
351+instance (KnownSymbol sym, HasClient t m sublayout, Reflex t)
352+ => HasClient t m (QueryFlag sym :> sublayout) where
461353
462− type Client t m (QueryFlag sym :> sublayout) tag =
463− Dynamic t Bool -> Client t m sublayout tag
354+ type Client t m (QueryFlag sym :> sublayout) =
355+ Dynamic t Bool -> Client t m sublayout
464356
465− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap flag =
466− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
357+ clientWithRoute Proxy q req baseurl flag =
358+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
467359
468360 where req' = req { qParams = thisPair : qParams req }
469361 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
470362 pName = symbolVal (Proxy :: Proxy sym)
471363
472364
473−
474−-- | Send a raw 'XhrRequest ()' directly to 'baseurl'
475−instance SupportsServantReflex t m => HasClient t m Raw tag where
476− type Client t m Raw tag = Dynamic t (Either Text (XhrRequest ()))
477− -> Event t tag
478− -> m (Event t (ReqResult tag ()))
479−
480− clientWithRouteAndResultHandler _ _ _ _ baseurl _ wrap xhrs triggers = do
481−
482− let xhrs' = liftA2 (\x path -> case x of
483− Left e -> Left e
484− Right jx -> Right $ jx { _xhrRequest_url = path <> _xhrRequest_url jx }
485− ) xhrs (showBaseUrl <$> baseurl)
486− xhrs'' = attachPromptlyDynWith (flip (,)) xhrs' triggers :: Event t (tag, Either Text (XhrRequest ()))
487− badReq = fmapMaybe (\(t,x) -> either (Just . (t,)) (const Nothing) x) xhrs'' :: Event t (tag, Text)
488− okReq = fmapMaybe (\(t,x) -> either (const Nothing) (Just . (t,)) x) xhrs'' :: Event t (tag, XhrRequest ())
489−
490− resps <- performRequestsAsync okReq
491− wrap $ leftmost [ uncurry RequestFailure <$> badReq
492− , evalResponse (const $ Right ()) <$> resps
493− ]
494−
365+-- | Pick a 'Method' and specify where the server you want to query is. You get
366+-- back the full `Response`.
367+-- TODO redo
368+instance SupportsServantReflex t m => HasClient t m Raw where
369+ type Client t m Raw = Dynamic t (Either Text (XhrRequest ()))
370+ -> Event t ()
371+ -> m (Event t (ReqResult ()))
372+
373+ -- clientWithRoute :: Proxy Raw -> Proxy m -> Req -> BaseUrl -> Client t m Raw
374+ clientWithRoute _ _ _ baseurl xhrs triggers = do
375+ let xhrs' = liftA2 (\x path -> case x of
376+ Left e -> Left e
377+ Right jx -> Right $ jx {_xhrRequest_url = path
378+ <> _xhrRequest_url jx})
379+ xhrs
380+ (showBaseUrl <$> baseurl)
381+ reqs = tagPromptlyDyn xhrs' triggers
382+ okReq = fmapMaybe hush reqs
383+ badReq = fmapMaybe tattle reqs
384+ resps <- performRequestAsync okReq
385+ return $ leftmost [fmap (ResponseSuccess () ) resps
386+ ,fmap RequestFailure badReq]
387+
388+
389+hush :: Either e a -> Maybe a
390+hush = either (const Nothing) Just
391+
392+tattle :: Either e a -> Maybe e
393+tattle = either Just (const Nothing)
495394
496395-- | If you use a 'ReqBody' in one of your endpoints in your API,
497396-- the corresponding querying function will automatically take
@@ -513,14 +412,14 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
513412-- > where host = BaseUrl Http "localhost" 8080
514413-- > -- then you can just use "addBook" to query that endpoint
515414
516−instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
517− => HasClient t m (ReqBody (ct ': cts) a :> sublayout) tag where
415+instance (MimeRender ct a, HasClient t m sublayout, Reflex t)
416+ => HasClient t m (ReqBody (ct ': cts) a :> sublayout) where
518417
519− type Client t m (ReqBody (ct ': cts) a :> sublayout) tag =
520− Dynamic t (Either Text a) -> Client t m sublayout tag
418+ type Client t m (ReqBody (ct ': cts) a :> sublayout) =
419+ Dynamic t (Either Text a) -> Client t m sublayout
521420
522− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap body =
523− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
421+ clientWithRoute Proxy q req baseurl body =
422+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
524423 where req' = req { reqBody = bodyBytesCT }
525424 ctProxy = Proxy :: Proxy ct
526425 ctString = T.pack $ show $ contentType ctProxy
@@ -528,49 +427,39 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
528427 (\b -> (mimeRender ctProxy b, ctString))
529428 body
530429
531−
532−
533430-- | Make the querying function append @path@ to the request path.
534−instance (KnownSymbol path, HasClient t m sublayout tag, Reflex t) => HasClient t m (path :> sublayout) tag where
535− type Client t m (path :> sublayout) tag = Client t m sublayout tag
431+instance (KnownSymbol path, HasClient t m sublayout, Reflex t) => HasClient t m (path :> sublayout) where
432+ type Client t m (path :> sublayout) = Client t m sublayout
536433
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
434+ clientWithRoute Proxy q req =
435+ clientWithRoute (Proxy :: Proxy sublayout) q
436+ (prependToPathParts (pure (Right $ T.pack p)) req)
540437
541438 where p = symbolVal (Proxy :: Proxy path)
542439
440+instance HasClient t m api => HasClient t m (Vault :> api) where
441+ type Client t m (Vault :> api) = Client t m api
543442
544−instance HasClient t m api tag => HasClient t m (Vault :> api) tag where
545− type Client t m (Vault :> api) tag = Client t m api tag
546−
547− clientWithRouteAndResultHandler Proxy =
548− clientWithRouteAndResultHandler (Proxy :: Proxy api)
549−
550−
551−instance HasClient t m api tag => HasClient t m (RemoteHost :> api) tag where
552− type Client t m (RemoteHost :> api) tag = Client t m api tag
553−
554− clientWithRouteAndResultHandler Proxy =
555− clientWithRouteAndResultHandler (Proxy :: Proxy api)
443+ clientWithRoute Proxy = clientWithRoute (Proxy :: Proxy api)
556444
445+instance HasClient t m api => HasClient t m (RemoteHost :> api) where
446+ type Client t m (RemoteHost :> api) = Client t m api
557447
448+ clientWithRoute Proxy = clientWithRoute (Proxy :: Proxy api)
558449
559−instance HasClient t m api tag => HasClient t m (IsSecure :> api) tag where
560− type Client t m (IsSecure :> api) tag = Client t m api tag
450+instance HasClient t m api => HasClient t m (IsSecure :> api) where
451+ type Client t m (IsSecure :> api) = Client t m api
561452
562− clientWithRouteAndResultHandler Proxy =
563− clientWithRouteAndResultHandler (Proxy :: Proxy api)
453+ clientWithRoute Proxy = clientWithRoute (Proxy :: Proxy api)
564454
455+instance (HasClient t m api, Reflex t)
456+ => HasClient t m (BasicAuth realm usr :> api) where
565457
566−instance (HasClient t m api tag, Reflex t)
567− => HasClient t m (BasicAuth realm usr :> api) tag where
458+ type Client t m (BasicAuth realm usr :> api) = Dynamic t (Maybe BasicAuthData)
459+ -> Client t m api
568460
569− type Client t m (BasicAuth realm usr :> api) tag = Dynamic t (Maybe BasicAuthData)
570− -> Client t m api tag
571−
572− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap authdata =
573− clientWithRouteAndResultHandler (Proxy :: Proxy api) q t req' baseurl opts wrap
461+ clientWithRoute Proxy q req baseurl authdata =
462+ clientWithRoute (Proxy :: Proxy api) q req' baseurl
574463 where
575464 req' = req { authData = Just authdata }
576465
@@ -596,30 +485,3 @@ non-empty lists, but is otherwise more specific, no instance will be overall
596485more specific. This in turn generally means adding yet another instance (one
597486for empty and one for non-empty lists).
598487-}
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.hsdeleted−401
@@ -1,401 +0,0 @@
1−{-# LANGUAGE AllowAmbiguousTypes #-}
2−{-# LANGUAGE CPP #-}
3−{-# LANGUAGE DataKinds #-}
4−{-# LANGUAGE FlexibleContexts #-}
5−{-# LANGUAGE FlexibleInstances #-}
6−{-# LANGUAGE InstanceSigs #-}
7−{-# LANGUAGE MultiParamTypeClasses #-}
8−{-# LANGUAGE OverloadedStrings #-}
9−{-# LANGUAGE PolyKinds #-}
10−{-# LANGUAGE ScopedTypeVariables #-}
11−{-# LANGUAGE TupleSections #-}
12−{-# LANGUAGE TypeFamilies #-}
13−{-# LANGUAGE TypeOperators #-}
14−{-# LANGUAGE UndecidableInstances #-}
15−
16−module Servant.Reflex.Multi (
17− -- * Compute servant client functions
18− clientA
19− , clientWithOptsA
20− , BaseUrl(..)
21− , Scheme(..)
22−
23− -- * Build QueryParam arguments
24− , QParam(..)
25−
26− -- * Access response data
27− , withCredentials
28−
29− -- * Access response data
30− , ReqResult(..)
31− , reqSuccess
32− , reqSuccess'
33− , reqFailure
34− , response
35−
36− , HasClientMulti(..)
37− ) where
38−
39−------------------------------------------------------------------------------
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)
64−------------------------------------------------------------------------------
65−import Servant.Common.BaseUrl (BaseUrl (..), Scheme (..),
66− SupportsServantReflex)
67−import Servant.Common.Req (ClientOptions,
68− QParam (..), QueryPart (..), Req,
69− ReqResult (..), addHeader, authData,
70− defReq,
71− defaultClientOptions,
72− performRequestsCT,
73− performRequestsNoBody,
74− performSomeRequestsAsync,
75− prependToPathParts, qParamToQueryPart,
76− qParams, reqBody, reqFailure,
77− reqMethod, reqSuccess, reqSuccess',
78− respHeaders, response, withCredentials)
79−import Servant.Reflex (BuildHeaderKeysTo (..), toHeaders)
80−
81−
82−------------------------------------------------------------------------------
83−clientA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
84− => Proxy layout -> Proxy m -> Proxy f -> Proxy tag
85− -> Dynamic t BaseUrl -> ClientMulti t m layout f tag
86−clientA p q f tag baseurl =
87− clientWithRouteMulti p q f tag (constDyn (pure defReq)) baseurl
88− defaultClientOptions
89−
90−
91−-- | A version of @client@ that sets the withCredentials flag
92−-- on requests. Use this function for clients of CORS API's
93−clientWithOptsA :: (HasClientMulti t m layout f tag, Applicative f, Reflex t)
94− => Proxy layout -> Proxy m -> Proxy f -> Proxy tag
95− -> Dynamic t BaseUrl -> ClientOptions -> ClientMulti t m layout f tag
96−clientWithOptsA p q f tag baseurl opts =
97− clientWithRouteMulti p q f tag
98− (constDyn (pure defReq)) baseurl opts
99−
100−------------------------------------------------------------------------------
101−class HasClientMulti t m layout f (tag :: *) where
102− type ClientMulti t m layout f tag :: *
103− clientWithRouteMulti :: Proxy layout -> Proxy m -> Proxy f -> Proxy tag
104− -> Dynamic t (f (Req t)) -> Dynamic t BaseUrl
105− -> ClientOptions -> ClientMulti t m layout f tag
106−
107−
108−------------------------------------------------------------------------------
109−instance (HasClientMulti t m a f tag, HasClientMulti t m b f tag) =>
110− HasClientMulti t m (a :<|> b) f tag where
111− type ClientMulti t m (a :<|> b) f tag = ClientMulti t m a f tag :<|>
112− ClientMulti t m b f tag
113− clientWithRouteMulti Proxy q f tag reqs baseurl opts =
114− clientWithRouteMulti (Proxy :: Proxy a) q f tag reqs baseurl opts :<|>
115− clientWithRouteMulti (Proxy :: Proxy b) q f tag reqs baseurl opts
116−
117−
118−------------------------------------------------------------------------------
119−instance (SupportsServantReflex t m,
120− ToHttpApiData a,
121− HasClientMulti t m sublayout f tag,
122− Applicative f)
123− => HasClientMulti t m (Capture capture a :> sublayout) f tag where
124−
125− type ClientMulti t m (Capture capture a :> sublayout) f tag =
126− f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
127−
128− clientWithRouteMulti _ q f tag reqs baseurl opts vals =
129− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
130− where
131− reqs' = (prependToPathParts <$> ps <*>) <$> reqs
132− ps = (fmap . fmap . fmap) toUrlPiece vals
133−
134−
135−------------------------------------------------------------------------------
136−-- VERB (Returning content) --
137−instance {-# OVERLAPPABLE #-}
138− -- Note [Non-Empty Content Types]
139− (MimeUnrender ct a,
140− ReflectMethod method, cts' ~ (ct ': cts),
141− SupportsServantReflex t m,
142− Applicative f,
143− Traversable f
144− ) => HasClientMulti t m (Verb method status cts' a) f tag where
145−
146− type ClientMulti t m (Verb method status cts' a) f tag =
147− Event t tag -> m (Event t (f (ReqResult tag a)))
148−
149− clientWithRouteMulti _ _ _ _ reqs baseurl opts =
150− performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts
151− where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
152− reqs' = fmap (\r -> r { reqMethod = method }) <$> reqs
153−
154−
155−------------------------------------------------------------------------------
156−-- -- VERB (No content) --
157−instance {-# OVERLAPPING #-}
158− (ReflectMethod method, SupportsServantReflex t m, Traversable f) =>
159− HasClientMulti t m (Verb method status cts NoContent) f tag where
160− type ClientMulti t m (Verb method status cts NoContent) f tag =
161− Event t tag -> m (Event t (f (ReqResult tag NoContent)))
162− -- TODO: how to access input types here?
163− -- ExceptT ServantError IO NoContent
164− clientWithRouteMulti Proxy _ _ _ req baseurl opts =
165− performRequestsNoBody method req baseurl opts
166− where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
167−
168−
169−------------------------------------------------------------------------------
170−instance {-# OVERLAPPABLE #-}
171− -- Note [Non-Empty Content Types]
172− ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
173− ReflectMethod method, cts' ~ (ct ': cts),
174− SupportsServantReflex t m,
175− Traversable f
176− ) => HasClientMulti t m (Verb method status cts' (Headers ls a)) f tag where
177− type ClientMulti t m (Verb method status cts' (Headers ls a)) f tag =
178− Event t tag -> m (Event t (f (ReqResult tag (Headers ls a))))
179− clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
180− let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
181− resp <- performRequestsCT (Proxy :: Proxy ct) method reqs' baseurl opts triggers :: m (Event t (f (ReqResult tag a)))
182− return $ fmap toHeaders <$> resp
183− where
184− reqs' = fmap (\r ->
185− r { respHeaders =
186− OnlyHeaders (Set.fromList
187− (buildHeaderKeysTo (Proxy :: Proxy ls)))
188− }) <$> reqs
189−
190−
191−------------------------------------------------------------------------------
192−instance {-# OVERLAPPABLE #-}
193− ( BuildHeadersTo ls,
194− BuildHeaderKeysTo ls,
195− ReflectMethod method,
196− SupportsServantReflex t m,
197− Traversable f
198− ) => HasClientMulti t m (Verb method status
199− cts (Headers ls NoContent)) f tag where
200− type ClientMulti t m (Verb method status cts (Headers ls NoContent)) f tag
201− = Event t tag -> m (Event t (f (ReqResult tag (Headers ls NoContent))))
202− clientWithRouteMulti Proxy _ _ _ reqs baseurl opts triggers = do
203− let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
204− resp <- performRequestsNoBody method reqs' baseurl opts triggers
205− return $ fmap toHeaders <$> resp
206− where reqs' = fmap (\req ->
207− req {respHeaders = OnlyHeaders (Set.fromList
208− (buildHeaderKeysTo (Proxy :: Proxy ls)))
209− }) <$> reqs
210−
211−
212−------------------------------------------------------------------------------
213−instance (KnownSymbol sym,
214− ToHttpApiData a,
215− HasClientMulti t m sublayout f tag,
216− SupportsServantReflex t m,
217− Traversable f,
218− Applicative f)
219− => HasClientMulti t m (Header sym a :> sublayout) f tag where
220−
221− type ClientMulti t m (Header sym a :> sublayout) f tag =
222− f (Dynamic t (Either Text a)) -> ClientMulti t m sublayout f tag
223−
224− clientWithRouteMulti Proxy f q tag reqs baseurl opts eVals =
225− clientWithRouteMulti (Proxy :: Proxy sublayout) f
226− q tag
227− reqs'
228− baseurl opts
229− where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
230− reqs' = ((\eVal req -> Servant.Common.Req.addHeader hname eVal req)
231− <$> eVals <*>) <$> reqs
232−
233−
234−------------------------------------------------------------------------------
235−instance HasClientMulti t m sublayout f tag
236− => HasClientMulti t m (HttpVersion :> sublayout) f tag where
237−
238− type ClientMulti t m (HttpVersion :> sublayout) f tag =
239− ClientMulti t m sublayout f tag
240−
241− clientWithRouteMulti Proxy q f tag =
242− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
243−
244−
245−------------------------------------------------------------------------------
246−instance (HasClientMulti t m sublayout f tag, KnownSymbol sym)
247− => HasClientMulti t m (Summary sym :> sublayout) f tag where
248−
249− type ClientMulti t m (Summary sym :> sublayout) f tag =
250− ClientMulti t m sublayout f tag
251−
252− clientWithRouteMulti Proxy q f tag =
253− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
254−
255−
256−------------------------------------------------------------------------------
257−instance (KnownSymbol sym,
258− ToHttpApiData a,
259− HasClientMulti t m sublayout f tag,
260− Reflex t,
261− Applicative f)
262− => HasClientMulti t m (QueryParam sym a :> sublayout) f tag where
263−
264− type ClientMulti t m (QueryParam sym a :> sublayout) f tag =
265− Dynamic t (f (QParam a)) -> ClientMulti t m sublayout f tag
266−
267− -- if mparam = Nothing, we don't add it to the query string
268− -- TODO: Check the above comment
269− clientWithRouteMulti Proxy q f tag reqs baseurl opts mparams =
270− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
271− reqs' baseurl opts
272−
273− where pname = symbolVal (Proxy :: Proxy sym)
274− p prm = QueryPartParam $ fmap qParamToQueryPart prm
275− paramPair mp = (T.pack pname, p mp)
276− -- reqs' = (\params reqs -> (\req param -> req {qParams = paramPair param : qParams req}) <$> reqs <*> params)
277− -- <$> mparams <*> reqs
278− reqs' = liftA2 (\(pr :: QParam a) (r :: Req t) -> r { qParams = paramPair (constDyn pr) : qParams r })
279− <$> mparams <*> reqs
280−
281−
282−instance (KnownSymbol sym,
283− ToHttpApiData a,
284− HasClientMulti t m sublayout f tag,
285− Reflex t,
286− Applicative f)
287− => HasClientMulti t m (QueryParams sym a :> sublayout) f tag where
288−
289− type ClientMulti t m (QueryParams sym a :> sublayout) f tag =
290− Dynamic t (f [a]) -> ClientMulti t m sublayout f tag
291−
292− clientWithRouteMulti Proxy q f tag reqs baseurl opts paramlists =
293− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
294−
295− where req' l r = r { qParams = (T.pack pname, params' (constDyn l)) : qParams r }
296− pname = symbolVal (Proxy :: Proxy sym)
297− params' l = QueryPartParams $ (fmap . fmap) (toQueryParam)
298− l
299− reqs' = liftA2 req' <$> paramlists <*> reqs
300−
301−
302−instance (KnownSymbol sym,
303− HasClientMulti t m sublayout f tag,
304− Reflex t,
305− Applicative f)
306− => HasClientMulti t m (QueryFlag sym :> sublayout) f tag where
307−
308− type ClientMulti t m (QueryFlag sym :> sublayout) f tag =
309− Dynamic t (f Bool) -> ClientMulti t m sublayout f tag
310−
311− clientWithRouteMulti Proxy q f' tag reqs baseurl opts flags =
312− clientWithRouteMulti (Proxy :: Proxy sublayout) q f' tag reqs' baseurl opts
313−
314− where req' f req = req { qParams = thisPair (constDyn f) : qParams req }
315− thisPair f = (T.pack pName, QueryPartFlag f) :: (Text, QueryPart t)
316− pName = symbolVal (Proxy :: Proxy sym)
317− reqs' = liftA2 req' <$> flags <*> reqs
318−
319−
320−instance (SupportsServantReflex t m,
321− Traversable f, Applicative f) => HasClientMulti t m Raw f tag where
322− type ClientMulti t m Raw f tag = f (Dynamic t (Either Text (XhrRequest ())))
323− -> Event t tag
324− -> m (Event t (f (ReqResult tag ())))
325−
326− clientWithRouteMulti _ _ _ _ _ _ opts rawReqs triggers = do
327− let rawReqs' = sequence rawReqs :: Dynamic t (f (Either Text (XhrRequest ())))
328− rawReqs'' = attachPromptlyDynWith (\fxhr t -> Compose (t, fxhr)) rawReqs' triggers
329− resps <- fmap (fmap aux . sequenceA . getCompose) <$> performSomeRequestsAsync opts rawReqs''
330− return resps
331− where
332− aux (tag, Right r) = ResponseSuccess tag () r
333− aux (tag, Left e) = RequestFailure tag e
334−
335−
336−instance (MimeRender ct a,
337− HasClientMulti t m sublayout f tag,
338− Reflex t,
339− Applicative f)
340− => HasClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag where
341−
342− type ClientMulti t m (ReqBody (ct ': cts) a :> sublayout) f tag =
343− Dynamic t (f (Either Text a)) -> ClientMulti t m sublayout f tag
344−
345− clientWithRouteMulti Proxy q f tag reqs baseurl opts bodies =
346− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag reqs' baseurl opts
347− where req' b r = r { reqBody = bodyBytesCT (constDyn b) }
348− ctProxy = Proxy :: Proxy ct
349− ctString = T.pack $ show $ contentType ctProxy
350− bodyBytesCT b = Just $ (fmap . fmap)
351− (\b' -> (mimeRender ctProxy b', ctString))
352− b
353− reqs' = liftA2 req' <$> bodies <*> reqs
354−
355−
356−instance (KnownSymbol path,
357− HasClientMulti t m sublayout f tag,
358− Reflex t,
359− Functor f) => HasClientMulti t m (path :> sublayout) f tag where
360− type ClientMulti t m (path :> sublayout) f tag = ClientMulti t m sublayout f tag
361−
362− clientWithRouteMulti Proxy q f tag reqs baseurl =
363− clientWithRouteMulti (Proxy :: Proxy sublayout) q f tag
364− (fmap (prependToPathParts (pure (Right $ T.pack p))) <$> reqs)
365− baseurl
366−
367− where p = symbolVal (Proxy :: Proxy path)
368−
369−
370−instance HasClientMulti t m api f tag => HasClientMulti t m (Vault :> api) f tag where
371− type ClientMulti t m (Vault :> api) f tag = ClientMulti t m api f tag
372−
373− clientWithRouteMulti Proxy q f tag reqs baseurl =
374− clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs baseurl
375−
376−
377−instance HasClientMulti t m api f tag => HasClientMulti t m (RemoteHost :> api) f tag where
378− type ClientMulti t m (RemoteHost :> api) f tag = ClientMulti t m api f tag
379−
380− clientWithRouteMulti Proxy q f tag reqs baseurl =
381− clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs baseurl
382−
383−
384−instance HasClientMulti t m api f tag => HasClientMulti t m (IsSecure :> api) f tag where
385− type ClientMulti t m (IsSecure :> api) f tag = ClientMulti t m api f tag
386−
387− clientWithRouteMulti Proxy q f tag reqs baseurl =
388− clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs baseurl
389−
390−
391−instance (HasClientMulti t m api f tag, Reflex t, Applicative f)
392− => HasClientMulti t m (BasicAuth realm usr :> api) f tag where
393−
394− type ClientMulti t m (BasicAuth realm usr :> api) f tag = Dynamic t (f (Maybe BasicAuthData))
395− -> ClientMulti t m api f tag
396−
397− clientWithRouteMulti Proxy q f tag reqs baseurl opts authdatas =
398− clientWithRouteMulti (Proxy :: Proxy api) q f tag reqs' baseurl opts
399− where
400− req' a r = r { authData = Just (constDyn a) }
401− reqs' = liftA2 req' <$> authdatas <*> reqs
stack.yamldeleted−56
@@ -1,56 +0,0 @@
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+1−2
@@ -9,7 +9,6 @@ import qualified Data.Text as T
99import Data.Foldable
1010import Test.WebDriver.Commands.Wait
1111import Test.Hspec.WebDriver
12−import Test.Hspec.WebDriver (chromeCaps)
1312
1413
1514clickingShouldCause :: Selector -> Selector -> Double -> (Element -> Element -> WD Bool) -> WD ()
@@ -29,7 +28,7 @@ spec :: Spec
2928spec = do
3029 describe "servant-reflex tests" $ do
3130
32− session "test page" $ using [chromeCaps] $ do
31+ session "test page" $ using Chrome $ do
3332
3433 it "opens the page" $ runWD $
3534 openPage "http://localhost:8000"
testserver/API.hsmode 100644 → 120000+1−69
@@ -1,69 +0,0 @@
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
@@ -0,0 +1 @@
1+../exec/API.hs
testserver/Main.hs+6−23
@@ -2,17 +2,14 @@
22{-# LANGUAGE DeriveGeneric #-}
33{-# LANGUAGE OverloadedStrings #-}
44{-# LANGUAGE PolyKinds #-}
5−{-# LANGUAGE TypeApplications #-}
65{-# LANGUAGE TypeFamilies #-}
76{-# LANGUAGE TypeOperators #-}
87
98import Control.Monad.IO.Class (liftIO)
10−import Control.Monad.Reader (reader)
119import Data.Aeson
1210import Data.Bool
1311import Data.Char (toUpper)
1412import qualified Data.List as L
15−import Data.Maybe (fromMaybe)
1613import Data.Monoid
1714import Data.Proxy
1815import Data.Text hiding (head, length, map,
@@ -27,7 +24,6 @@ import Snap.Http.Server
2724import Servant
2825import Servant.Server
2926-- import Snap.Util.FileServe
30−import System.Environment (lookupEnv)
3127import API
3228import Snap
3329
@@ -43,7 +39,7 @@ instance ToJSON Greet
4339testApi :: Proxy API
4440testApi = Proxy
4541
46−data App = App { appStaticDir :: String }
42+data App = App
4743
4844-- Server-side handlers.
4945--
@@ -51,10 +47,8 @@ data App = App { appStaticDir :: String }
5147-- that represents the API, are glued together using :<|>.
5248--
5349-- Each handler runs in the 'ExceptT ServantErr IO' monad.
54−server :: Server API '[BasicAuthCheck (Handler App App) ()] (Handler App App)
55−server = return () :<|> return 100 :<|> sayhi :<|> dbl
56− :<|> multi :<|> qna :<|> serveSecret
57− :<|> statics
50+server :: Server API (Handler App App)
51+server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> qna :<|> serveDirectory "static"
5852 where sayhi :: Maybe Text -> [Text] -> Bool -> Handler App App Text
5953 sayhi nm greetings withGusto = case nm of
6054 Nothing -> return ("Sorry, who are you?" :: Text)
@@ -66,36 +60,25 @@ server = return () :<|> return 100 :<|> sayhi :<|> dbl
6660 | otherwise = T.intercalate ", " (L.init greetings)
6761 <> ", and " <> L.last greetings <> ", "
6862 return . modifier $ greetPart <> n
69− dbl x = if x `elem` [4,13]
70− then throwError $ err500 { errBody = "No unlucky numbers please" }
71− else return $ x * 2
63+ dbl x = return $ x * 2
7264 multi = return . bool "Box unchecked" "Box Checked"
7365 qna q = do
7466 liftIO $ do
7567 putStrLn $ "qna got: " ++ show q
7668 T.putStrLn $ unQuestion q
7769 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
8570
8671-- Turn the server into a WAI app. 'serve' is provided by servant,
8772-- more precisely by the Servant.Server module.
8873test :: Handler App App ()
89−test = serveSnapWithContext testApi
90− (BasicAuthCheck (\_ -> return @(Handler App App) (Authorized ())) :. EmptyContext) server
74+test = serveSnap testApi server
9175
9276initApp :: SnapletInit App App
9377initApp = makeSnaplet "myapp" "example" Nothing $ do
94− staticDir <- fromMaybe "static" <$> liftIO (lookupEnv "STATIC_DIR")
9578 addRoutes [("", test)
9679 ,("", serveDirectory "static")
9780 ]
98− return (App staticDir)
81+ return App
9982
10083-- Put this all to work!
10184main :: IO ()
testserver/run-wd-tests.shnew file+5
@@ -0,0 +1,5 @@
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+7−8
@@ -19,14 +19,13 @@ executable back
1919 main-is: Main.hs
2020 -- other-modules:
2121 -- other-extensions:
22− build-depends: aeson >= 0.9 && < 1.5
23− , base >=4.8 && < 5
24− , mtl
25− , snap >= 1.0 && < 1.2
26− , snap-server >= 1.0 && < 1.2
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
2726 , snap-core >= 1.0 && < 1.1
28− , servant >= 0.16 && < 0.18
29− , servant-snap >= 0.8 && < 0.9
30− , text >= 1.0 && < 1.3
27+ , servant >= 0.8 && < 0.11
28+ , servant-snap >= 0.7.2 && < 0.8
29+ , text >= 1.2 && < 1.3
3130 -- hs-source-dirs:
3231 default-language: Haskell2010
testserver/tr.nixnew file+32
@@ -0,0 +1,32 @@
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.nixdeleted−70
@@ -1,70 +0,0 @@
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− }