on fcf908e help sign in
.gitignore−3
since splitsnapshots
unifiedsplit
@@ -6,6 +6,3 @@ log
6*.webapp
6*.webapp
7*.stats
7*.stats
8out
8out
9−/.stack-work/
10−TAGS
11−dist-newstyle
.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
1+sudo: required
2−nix: 2.3.6
2+
3−sudo: require
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+
4
21
5before_install:
22before_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
7
27
8−before_script:
28+install:
9− - sudo systemctl restart nix-daemon.service
29+ - cabal --version
10− - git config --global user.email "travis-ci@example.com"
30+ - BENCH=${BENCH---enable-benchmarks}
11− - git config --global user.name "Travis-CI"
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
12
47
13script:
48script:
14− - nix-build travis.nix -A build
49+ - git config --global user.email "travis-ci@example.com"
15− - nix-build travis.nix -A buildGhc
50+ - git config --global user.name "Travis-CI"
16− - nix-build travis.nix -A testserver
51+ - ./build.sh
17− - nix-build travis.nix -A testresults
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 @@
2
2
3[![Build Status](https://travis-ci.org/imalsogreg/servant-reflex.svg?branch=master)](https://travis-ci.org/imalsogreg/servant-reflex)
3[![Build Status](https://travis-ci.org/imalsogreg/servant-reflex.svg?branch=master)](https://travis-ci.org/imalsogreg/servant-reflex)
4
4
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.
6
9
7−Keeping your frontend in sync with your API server can be difficult - when the
8−API changes its input parameters or return type, XHR requests from the
9−frontend will fail at runtime. If your API is defined by
10−[servant](https://haskell-servant.readthedocs.io) combinators, you can use
11−`servant-reflex` to share the API between the server and frontend.
12−Syncronization between is checked at compile time, and rather than building XHR
13−requests by hand, API endpoints are available behind `reflex`'s FRP semantics.
14
10
15
11
16## Example
12## Example
17
13
18−We have a webservice API defined in a module where both the server (compiled
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:
19−with ghc) and the frontend (compiled with ghcjs) can see it:
20
15
21```haskell
16```haskell
22type API = "getint" :> Get '[JSON] Int
17type API = "getint" :> Get '[JSON] Int
@@ -29,8 +24,7 @@ type API = "getint" :> Get '[JSON] Int
29 :<|> Raw
24 :<|> Raw
30```
25```
31
26
32−`servant-reflex` then computes client functions that can query the API through
27+`servant-reflex` then computes client functions that can query the API through an `XhrRequest`.
33−an `XhrRequest`.
34
28
35```haskell
29```haskell
36
30
@@ -39,26 +33,16 @@ an `XhrRequest`.
39 -- servant-reflex computes FRP functions for each API endpoint
33 -- servant-reflex computes FRP functions for each API endpoint
40 let (getint :<|> sayhi :<|> doubleit :<|> _) = client (Proxy :: Proxy API)
34 let (getint :<|> sayhi :<|> doubleit :<|> _) = client (Proxy :: Proxy API)
41 (Proxy :: Proxy m)
35 (Proxy :: Proxy m)
42− (Proxy :: Proxy ())
43 (constDyn (BasePath "/"))
36 (constDyn (BasePath "/"))
44```
37```
45
38
46−These client functions are computed from your API type. They manage
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.
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.
56
40
57```haskell
41```haskell
58 -- No need to write these functions. servant-reflex creates them for you!
42 -- No need to write these functions. servant-reflex creates them for you!
59 getint :: MonadWidget t m
43 getint :: MonadWidget t m
60 => Event t () -- ^ Trigger the XHR Request
44 => Event t () -- ^ Trigger the XHR Request
61− -> m (Event t (ReqResult () Int)) -- ^ Consume the answer
45+ -> m (Event t (ReqResult Int)) -- ^ Consume the answer
62
46
63 sayhi :: MonadWidget t m
47 sayhi :: MonadWidget t m
64 => Dynamic t (QParam Text)
48 => Dynamic t (QParam Text)
@@ -69,21 +53,15 @@ parameter is a trigger event for the XHR request. The return value
69 -- ^ Flag for capitalizing the response
53 -- ^ Flag for capitalizing the response
70 -> Event t ()
54 -> Event t ()
71 -- ^ Trigger the XHR Request
55 -- ^ Trigger the XHR Request
72− -> m (Event t (ReqResult () Text))
56+ -> m (Event t (ReqResult Text))
73
57
74 doubleit :: MonadWidget t m
58 doubleit :: MonadWidget t m
75 => Dynamic t (Either Text Double)
59 => Dynamic t (Either Text Double)
76 -> Event t ()
60 -> Event t ()
77− -> m (Event t (ReqResult () Double))
61+ -> m (Event t (ReqResult Double))
78```
62```
79
63
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)
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:
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:
87
65
88```haskell
66```haskell
89 -- ... continued ...
67 -- ... continued ...
@@ -101,8 +79,7 @@ elimination functions to filter the result type you care about, like this:
101 dynText =<< holdDyn "" (leftmost [errs, const "" <$> ys])
79 dynText =<< holdDyn "" (leftmost [errs, const "" <$> ys])
102```
80```
103
81
104−This example builds some input fields to enter API parameters, buttons to
82+This example builds some input fields to enter API parameters, buttons to trigger the API calls, and text elements to show the results:
105−trigger the API calls, and text elements to show the results:
106
83
107```haskell
84```haskell
108 elClass "div" "int-demo" $ do
85 elClass "div" "int-demo" $ do
@@ -125,100 +102,37 @@ trigger the API calls, and text elements to show the results:
125 display =<< holdDyn Nothing outputDouble
102 display =<< holdDyn Nothing outputDouble
126```
103```
127
104
128−For a great introduction to recative DOM building, see the
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.
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.
133
106
134
107
135## Building the library and test server
108## Building the library and test server
136
109
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).
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:
142−To build these components, we will use the nix packages for the testserver. It
143−manages the frontend build as a dependency.
144
111
145−```
146−nix build -f travis.nix testserver -o server
147−```
148
112
149−Point it at the static directory and run it:
113+First build the library:
150
114
151```
115```
152−STATIC_DIR=server/static server/back -p 8000
116+git submodule update --init --recursive
117+./build.sh
153```
118```
154
119
155−Browse to [http://localhost:8000](http://localhost:8000) and click around.
120+Then build the test server:
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).**
161
121
122+```
123+deps/reflex-platform/work-on ./overrides-ghc.nix ./testserver --command "cd testserver && cabal build"
124+```
162
125
163−## Tagging requests
164
126
165−The input and the return type of a client function like `getDouble` are both
127+## Running the example site
166−event streams. The individual input events and responses occur at different
167−times and aren't automatically paired up, but you can recover the
168−relationship by tagging the requests.
169
128
170−So far we have used an `Event t ()` to trigger sending a request. If we choose
129+The server must be run from the directory where static assets live:
171−e.g. `Double` for the third `Proxy` argument to `client`, then `Event t Double`
172−will be used to trigger requests, and each `ReqResult` will carry the tag of
173−its request. Imagine we wanted to display not just the last "double" from
174−`doubleIt`, but a whole table of valid inputs and their doubled responses:
175
130
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− ...
200```
131```
201−
132+cd testserver
202−## Simultaneous requests
133+dist/build/back/back -p 8001
203−
204−`Servant.Reflex.Multi` provides an alternative client-generation function
205−called `clientA` (client applicative). Choose a container type that has both
206−`Applicative` and `Traversable` instances, and pass it to `clientA` through
207−another `Proxy`. Our `sayHi` client function will then have this type:
208−
209−```haskell
210−sayHi
211− :: Dynamic t (f (QParam Text))
212− -> Dynamic t (f [Text])
213− -> Dynamic t (f Bool)
214− -> Event t tag
215− -> m (Event t (f (ReqResult tag Text)))
216```
134```
217
135
218−The dynamic params are each wrapped in `f`. For every firing of the trigger
136+And simply browse to `localhost:8001`
219−event `tag`, all of these parameters will be combined according to `f`'s
137+
220−`Applicative` instance (when `f` is `[]`, you will get all combinations of
138+**For a larger example of a project that shares types between backend and frontend, see [hsnippet](https://github.com/mightybyte/hsnippet).**
221−all parameters taken together as a request; when `f` is `ZipList`, the Nth
222−elemens of each parameters list will be taken together as a request). Using
223−this interface, you can trigger many XHR's from a single event occurence, and
224−expect the responses to be structured the same way as the requests.
build.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+4−29
@@ -1,32 +1,10 @@
1−{-# LANGUAGE DataKinds #-}
1+{-# LANGUAGE DataKinds #-}
2−{-# LANGUAGE OverloadedStrings #-}
3−{-# LANGUAGE TypeOperators #-}
2+{-# LANGUAGE TypeOperators #-}
4
3
5module API where
4module API where
6
5
7−import Data.Aeson
8−import Data.Aeson.Types (typeMismatch)
9−import Data.Text (Text)
6+import Data.Text (Text)
10−import Servant.API
7+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
8
31-- | API spec for server, client, and docs
9-- | API spec for server, client, and docs
32type API = "getunit" :> Get '[JSON] ()
10type API = "getunit" :> Get '[JSON] ()
@@ -38,9 +16,6 @@ type API = "getunit" :> Get '[JSON] ()
38 :<|> "double" :> ReqBody '[JSON] Double
16 :<|> "double" :> ReqBody '[JSON] Double
39 :> Post '[JSON] Double
17 :> Post '[JSON] Double
40 :<|> "a" :> "b" :> QueryFlag "gusto" :> Get '[JSON] Text
18 :<|> "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
19 :<|> Raw
45
20
46type GET = Get '[JSON] ()
21type GET = Get '[JSON] ()
exec/Example.hs+29−118
@@ -1,82 +1,30 @@
1−{-# LANGUAGE DataKinds #-}
2{-# LANGUAGE FlexibleContexts #-}
1{-# LANGUAGE FlexibleContexts #-}
3{-# LANGUAGE GADTs #-}
2{-# LANGUAGE GADTs #-}
4{-# LANGUAGE OverloadedStrings #-}
3{-# LANGUAGE OverloadedStrings #-}
5{-# LANGUAGE RankNTypes #-}
4{-# LANGUAGE RankNTypes #-}
6−{-# LANGUAGE RecursiveDo #-}
7{-# LANGUAGE ScopedTypeVariables #-}
5{-# LANGUAGE ScopedTypeVariables #-}
8
6
9module Main where
7module Main where
10
8
11−------------------------------------------------------------------------------
12import Data.Bool
9import Data.Bool
13import Data.Maybe
10import Data.Maybe
14import Control.Monad.Fix (MonadFix)
11import Control.Monad.Fix (MonadFix)
15−import Data.Monoid (First(..), (<>))
12+import Data.Monoid ((<>))
16import Data.Text (Text)
13import Data.Text (Text)
17import qualified Data.Text as T
14import qualified Data.Text as T
18−import qualified Data.Text.Encoding as T
19−import GHC.TypeLits
20import Servant.API
15import Servant.API
16+import Servant.Reflex
21import API
17import API
22import Data.Proxy
18import Data.Proxy
23import Text.Read (readMaybe)
19import Text.Read (readMaybe)
24−import Reflex.Dom.Core hiding (run, mainWidget)
20+import Reflex.Dom
25−import Reflex.Dom (mainWidget)
26−------------------------------------------------------------------------------
27−import Servant.Reflex
28−import Servant.Reflex.Multi
29−
30
21
31api :: Proxy API
22api :: Proxy API
32api = Proxy
23api = Proxy
33
24
34main :: IO ()
25main :: IO ()
35−main = mainWidget $ do
26+main = mainWidget run
36− divClass "example-base" run
27+
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 ()
80
28
81run :: forall t m. (SupportsServantReflex t m,
29run :: forall t m. (SupportsServantReflex t m,
82 DomBuilder t m,
30 DomBuilder t m,
@@ -84,44 +32,35 @@ run :: forall t m. (SupportsServantReflex t m,
84 MonadFix m,
32 MonadFix m,
85 PostBuild t m,
33 PostBuild t m,
86 MonadHold t m) => m ()
34 MonadHold t m) => m ()
87−run = mdo
35+run = do
88
36
89− reqCount <- count $ leftmost
90− [() <$ unitBtn, () <$ intBtn, () <$ sayHiClicks, () <$ dblBtn, () <$ mpGo]
91 -- Allow user to choose the url target for the request
37 -- Allow user to choose the url target for the request
92 -- (alternatively we could just `let url = constDyn (BasePath "/")`)
38 -- (alternatively we could just `let url = constDyn (BasePath "/")`)
93 url <- baseUrlWidget
39 url <- baseUrlWidget
94 el "br" (return ())
40 el "br" (return ())
95 dynText $ showBaseUrl <$> url
41 dynText $ showBaseUrl <$> url
96−
97 el "br" (return ())
42 el "br" (return ())
98
43
99 -- Name the computed API client functions
44 -- Name the computed API client functions
100− let tweakRequest = ClientOptions $ \r -> do
101− return $ r & withCredentials .~ True
102− let (getUnit :<|> getInt :<|> sayhi :<|> dbl
45+ let (getUnit :<|> getInt :<|> sayhi :<|> dbl :<|> multi :<|> doRaw) =
103− :<|> multi :<|> qna :<|> secret :<|> doRaw) =
46+ client api (Proxy :: Proxy m) url
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
107
47
108− (unitBtn, intBtn) <- elClass "div" "demo-group" $ do
48+ elClass "div" "demo-group" $ do
109 unitBtn <- divClass "unit-button" $ button "Get unit"
49 unitBtn <- divClass "unit-button" $ button "Get unit"
110 intBtn <- divClass "int-button" $ button "Get int"
50 intBtn <- divClass "int-button" $ button "Get int"
111
51
112− unitResponse <- getUnit $ tag (current reqCount) unitBtn
52+ unitResponse <- getUnit unitBtn
113− intResponse :: Event t (ReqResult Int Int) <- getInt $ tag (current reqCount) intBtn
53+ intResponse :: Event t (ReqResult Int) <- getInt intBtn
114
54
115− score <- foldDyn (+) 0 (fmapMaybe reqSuccess (intResponse))
55+ score <- foldDyn (+) 0 (fmapMaybe reqSuccess intResponse)
116
56
117 r <- holdDyn "Waiting" $ fmap showXhrResponse $
57 r <- holdDyn "Waiting" $ fmap showXhrResponse $
118− leftmost [fmapMaybe response (unitResponse)
58+ leftmost [fmapMaybe response unitResponse
119− ,fmapMaybe response (intResponse)
59+ ,fmapMaybe response intResponse
120 ]
60 ]
121 divClass "unit-int-response" $ el "p" $ dynText r >> el "br" (return ()) >> text "Total: " >> display score
61 divClass "unit-int-response" $ el "p" $ dynText r >> el "br" (return ()) >> text "Total: " >> display score
122− return (unitBtn, intBtn)
123
62
124− sayHiClicks <- elClass "div" "demo-group" $ do
63+ elClass "div" "demo-group" $ do
125
64
126 text "Name"
65 text "Name"
127 el "br" $ return ()
66 el "br" $ return ()
@@ -139,64 +78,36 @@ run = mdo
139 gusto <- fmap value $ divClass "gusto-input" $ checkbox False def
78 gusto <- fmap value $ divClass "gusto-input" $ checkbox False def
140
79
141 el "br" $ return ()
80 el "br" $ return ()
142− sayHiClicks :: Event t () <- divClass "hi-button" $ button "Say hi"
81+ sayhiClicks :: Event t () <- divClass "hi-button" $ button "Say hi"
143− let triggers = leftmost [sayHiClicks, () <$ updated inp]
82+ let triggers = leftmost [sayhiClicks, () <$ updated inp]
144
83
145− resp <- sayhi checkedName greetings gusto (tag (current reqCount) triggers)
84+ resp <- sayhi checkedName greetings gusto triggers
146 divClass "greeting-response" $ dynText =<<
85 divClass "greeting-response" $ dynText =<<
147− holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess (resp)
86+ holdDyn "No hi yet" (leftmost [ fmapMaybe reqSuccess resp
148− , fmapMaybe reqFailure (resp)])
87+ , fmapMaybe reqFailure resp])
149− return sayHiClicks
150
88
151− dblBtn <- elClass "div" "demo-group" $ do
89+ elClass "div" "demo-group" $ do
152 text "A Double to double"
90 text "A Double to double"
153 el "br" $ return ()
91 el "br" $ return ()
154 dblinp <- fmap value $ divClass "double-input" $ textInput def
92 dblinp <- fmap value $ divClass "double-input" $ textInput def
155− (dblBtn) <- divClass "double-button" $ button "Double it"
93+ dblBtn <- divClass "double-button" $ button "Double it"
156 dblResp <- dbl (fmap (note "read failure" . readMaybe . T.unpack) $
94 dblResp <- dbl (fmap (note "read failure" . readMaybe . T.unpack) $
157− dblinp) (tag (current reqCount) dblBtn)
95+ dblinp) dblBtn
158− divClass "double-errors" $ dynText =<<
96+ divClass "double-errors" $ dynText =<<
159− holdDyn "(no errors)" (fmapMaybe reqFailure (dblResp))
97+ holdDyn "(no errors)" (fmapMaybe reqFailure dblResp)
160 el "br" (return ())
98 el "br" (return ())
161 divClass "double-result" $ el "p" $ dynText =<<
99 divClass "double-result" $ el "p" $ dynText =<<
162 holdDyn "No number yet" (fmap tShow $
100 holdDyn "No number yet" (fmap tShow $
163− fmapMaybe reqSuccess (dblResp))
101+ fmapMaybe reqSuccess dblResp)
164− return dblBtn
165
102
166− mpGo <- elClass "div" "demo-group" $ do
103+ elClass "div" "demo-group" $ do
167 text "Multi-part path"
104 text "Multi-part path"
168 b <- value <$> checkbox False def
105 b <- value <$> checkbox False def
169 mpGo <- button "Test"
106 mpGo <- button "Test"
170− multiResp <- multi b (tag (current reqCount) mpGo)
107+ multiResp <- multi b mpGo
171 dynText =<< holdDyn "No res yet" (fmap tShow $
108 dynText =<< holdDyn "No res yet" (fmap tShow $
172 fmapMaybe reqSuccess $
109 fmapMaybe reqSuccess $
173− (multiResp))
110+ multiResp)
174− return mpGo
175−
176− return ()
177−
178− el "br" $ return ()
179−
180− elClass "div" "demo-group" $ do
181− text "JSON Unicode encoding test"
182− txt <- value <$> textInput def
183− ev <- fmap (1 <$) $ button "Question"
184− let dQ = Right . Question <$> traceDyn "will send: " txt
185− rr <- qna dQ ev
186− el "p" $
187− dynText =<< holdDyn "No Answer" (unAnswer <$> fmapMaybe reqSuccess rr)
188−
189− divClass "demo-group" $ do
190− un <- fmap value $ text "Username" >> textArea def
191− pw <- fmap value $ text "Unhidden PW" >> textArea def
192− let ba :: Dynamic t (BasicAuthData ) = BasicAuthData
193− <$> fmap T.encodeUtf8 un
194− <*> fmap T.encodeUtf8 pw
195− b <- button "Get secret"
196− r <- secret (Just <$> ba) (0 <$ b)
197− res <- holdDyn Nothing (reqSuccess <$> r)
198− display res
199−
200
111
201showXhrResponse :: XhrResponse -> Text
112showXhrResponse :: XhrResponse -> Text
202showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
113showXhrResponse (XhrResponse stat stattxt rbmay rtmay respHeaders) =
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+19
@@ -0,0 +1,19 @@
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+ reflex-dom = pkgs.haskell.lib.dontCheck (self.callPackage deps/reflex-dom {});
8+ servant-snap = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap) {});
9+ snap = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap) {});
10+ snap-server = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/snap-server) {});
11+ io-streams = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/io-streams) {});
12+ io-streams-haproxy = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/io-streams-haproxy) {});
13+ heist = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/heist) {});
14+ xmlhtml = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/xmlhtml) {});
15+ snap-core = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant-snap/deps/snap/deps/snap-core) {});
16+ servant = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/servant/servant) {});
17+ http-api-data = pkgs.haskell.lib.dontCheck (self.callPackage (c2n deps/http-api-data) {});
18+ };
19+}
overrides.nixnew file+14
@@ -0,0 +1,14 @@
1+{ reflex-platform, ... }:
2+let
3+
4+ nixpkgs = (import <nixpkgs> {});
5+ dontCheck = nixpkgs.pkgs.haskell.lib.dontCheck;
6+ cabal2nixResult = reflex-platform.cabal2nixResult;
7+
8+in
9+reflex-platform.ghcjs.override {
10+ overrides = self: super: {
11+ servant = dontCheck (self.callPackage (cabal2nixResult deps/servant/servant) {});
12+ http-api-data = dontCheck (self.callPackage (cabal2nixResult deps/http-api-data) {});
13+ };
14+}
servant-reflex.cabal+18−36
@@ -1,8 +1,8 @@
1Name: servant-reflex
1Name: servant-reflex
2−Version: 0.3.6
2+Version: 0.2
3−Synopsis: servant API generator for reflex apps
3+Synopsis: Servant reflex API generator
4−Description: Generate reflex-compatible client functions from servant API descriptions
4+Description: Servant reflex API generator
5−License: BSD3
5+License: AllRightsReserved
6License-file: LICENSE.md
6License-file: LICENSE.md
7Author: Greg Hale, Doug Beardsley
7Author: Greg Hale, Doug Beardsley
8Maintainer: imalsogreg@gmail.com
8Maintainer: imalsogreg@gmail.com
@@ -11,59 +11,41 @@ Category: Web
11Build-type: Simple
11Build-type: Simple
12Cabal-version: >=1.10
12Cabal-version: >=1.10
13
13
14−Flag Example
15− description: Enable example
16− default: False
17−
18library
14library
19 exposed-modules:
15 exposed-modules:
16+ Servant.Reflex
17+
18+ other-modules:
20 Servant.Common.BaseUrl
19 Servant.Common.BaseUrl
21 Servant.Common.Req
20 Servant.Common.Req
22− Servant.Reflex
23− Servant.Reflex.Multi
24
21
25 hs-source-dirs: src
22 hs-source-dirs: src
26 build-depends:
23 build-depends:
27− base >= 4.8 && < 5,
24+ base >= 4.8 && < 4.10,
28 bytestring >= 0.10 && < 0.11,
25 bytestring >= 0.10 && < 0.11,
29 case-insensitive >= 1.2.0.4 && < 1.3,
26 case-insensitive >= 1.2.0.4 && < 1.3,
30− containers >= 0.5.6 && < 0.7,
27+ containers >= 0.5.6 && < 0.6,
31 data-default >= 0.5 && < 0.8,
28 data-default >= 0.5 && < 0.8,
32− exceptions >= 0.8 && < 0.11,
29+ exceptions >= 0.8 && < 0.9,
33− ghcjs-dom >= 0.2 && < 0.10,
30+ ghcjs-dom >= 0.2 && < 0.3,
34− http-api-data >= 0.3.6 && < 0.5,
31+ http-api-data >= 0.2 && < 0.4,
35− http-media >= 0.6 && < 0.9,
32+ http-media >= 0.6 && < 0.7,
36− jsaddle >= 0.8 && < 0.10,
37 mtl >= 2.2.1 && < 2.3,
33 mtl >= 2.2.1 && < 2.3,
38 network-uri >= 2.6 && < 2.7,
34 network-uri >= 2.6 && < 2.7,
39− reflex >= 0.5 && < 0.9,
35+ reflex >= 0.5 && < 0.6,
40− reflex-dom-core >= 0.6 && < 0.7,
36+ reflex-dom == 0.4 && < 0.5,
41 safe >= 0.3.9 && < 0.4,
37 safe >= 0.3.9 && < 0.4,
42− servant >= 0.16 && < 0.18,
38+ servant >= 0.5 && < 0.9,
43− servant-auth >= 0.2.1 && < 0.4,
44 string-conversions >= 0.4 && < 0.5,
39 string-conversions >= 0.4 && < 0.5,
45 text >= 1.2 && < 1.3,
40 text >= 1.2 && < 1.3,
46 transformers >= 0.4 && < 0.6
41 transformers >= 0.4 && < 0.6
47
42
48− ghc-options: -Wall -fwarn-tabs -funbox-strict-fields
43+ ghc-options: -Wall -fwarn-tabs -funbox-strict-fields -O2
49
44
50 default-language: Haskell2010
45 default-language: Haskell2010
51
46
52executable example
47executable example
53− if flag(Example)
48+ build-depends: reflex, servant-reflex, base, scientific, servant, reflex-dom, text
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
67 default-language: Haskell2010
49 default-language: Haskell2010
68 main-is: Example.hs
50 main-is: Example.hs
69 other-modules: API
51 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 (
20) where
20) where
21
21
22import Control.Monad (join)
22import Control.Monad (join)
23−-- import Control.Monad.IO.Class (MonadIO)
23+import Control.Monad.IO.Class (MonadIO)
24import Control.Monad.Fix (MonadFix)
24import Control.Monad.Fix (MonadFix)
25import Data.Monoid ((<>))
25import Data.Monoid ((<>))
26import Data.Text (Text)
26import Data.Text (Text)
27import qualified Data.Text as T
27import qualified Data.Text as T
28import GHC.Generics
28import GHC.Generics
29−import Language.Javascript.JSaddle.Monad (MonadJSM)
30import Reflex
29import Reflex
31−import Reflex.Dom.Core
30+import Reflex.Dom
32import Text.Read
31import Text.Read
33
32
34
33
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))
36
35
37-- | URI scheme to use
36-- | URI scheme to use
38data Scheme =
37data Scheme =
@@ -85,14 +84,15 @@ baseUrlWidget = elClass "div" "base-url" $ do
85 where pathWidget :: m (Dynamic t BaseUrl)
84 where pathWidget :: m (Dynamic t BaseUrl)
86 pathWidget = do
85 pathWidget = do
87 text "Url base path"
86 text "Url base path"
88− t <- inputElement def
87+ t <- textInput (def {_textInputConfig_attributes =
88+ constDyn ("placeholder" =: "/a/b")})
89 return $ BasePath <$> value t
89 return $ BasePath <$> value t
90 fullUrlWidget :: m (Dynamic t BaseUrl)
90 fullUrlWidget :: m (Dynamic t BaseUrl)
91 fullUrlWidget = do
91 fullUrlWidget = do
92 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
92 schm <- dropdown Https (constDyn $ Https =: "https" <> Http =: "http") def
93− srv <- inputElement def
93+ srv <- textInput def {_textInputConfig_attributes = constDyn $ "placeholder" =: "example.com"}
94 text ":"
94 text ":"
95− prt <- inputElement def
95+ prt <- textInput def { _textInputConfig_attributes = constDyn $ "placeholder" =: "80"}
96 port :: Dynamic t Int <- holdDyn 80 (fmapMaybe (readMaybe . T.unpack) $ updated (value prt))
96 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" }
98 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
98 return $ BaseFullUrl <$> value schm <*> value srv <*> port <*> value path
src/Servant/Common/Req.hs+88−271
@@ -1,119 +1,55 @@
1+{-# LANGUAGE DeriveDataTypeable #-}
1{-# LANGUAGE CPP #-}
2{-# LANGUAGE CPP #-}
2−{-# LANGUAGE DeriveFunctor #-}
3{-# LANGUAGE FlexibleContexts #-}
3{-# LANGUAGE FlexibleContexts #-}
4{-# LANGUAGE GADTs #-}
4{-# LANGUAGE GADTs #-}
5{-# LANGUAGE OverloadedStrings #-}
5{-# LANGUAGE OverloadedStrings #-}
6{-# LANGUAGE LambdaCase #-}
6{-# LANGUAGE LambdaCase #-}
7−{-# LANGUAGE RankNTypes #-}
8{-# LANGUAGE ScopedTypeVariables #-}
7{-# LANGUAGE ScopedTypeVariables #-}
9{-# LANGUAGE TupleSections #-}
8{-# LANGUAGE TupleSections #-}
10−
11module Servant.Common.Req where
9module Servant.Common.Req where
12
10
13-------------------------------------------------------------------------------
11-------------------------------------------------------------------------------
14import Control.Applicative (liftA2, liftA3)
12import 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
21import qualified Data.ByteString.Lazy.Char8 as BL
13import qualified Data.ByteString.Lazy.Char8 as BL
22−import Data.ByteString (ByteString)
23import qualified Data.Map as Map
14import qualified Data.Map as Map
24−import Data.Maybe (catMaybes, fromMaybe)
15+import Data.Maybe (catMaybes)
25−import Data.Functor.Compose
26import Data.Monoid ((<>))
16import Data.Monoid ((<>))
27import Data.Proxy (Proxy(..))
17import Data.Proxy (Proxy(..))
28import Data.Text (Text)
18import Data.Text (Text)
29import qualified Data.Text as T
19import qualified Data.Text as T
30import qualified Data.Text.Encoding as TE
20import 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)
21+import Reflex.Dom
35−import Servant.Common.BaseUrl (BaseUrl, showBaseUrl,
22+import Servant.Common.BaseUrl (BaseUrl, showBaseUrl, SupportsServantReflex)
36− SupportsServantReflex)
37import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
23import Servant.API.ContentTypes (MimeUnrender(..), NoContent(..))
38import Web.HttpApiData (ToHttpApiData(..))
24import Web.HttpApiData (ToHttpApiData(..))
39-------------------------------------------------------------------------------
25-------------------------------------------------------------------------------
40import Servant.API.BasicAuth
26import Servant.API.BasicAuth
41
27
42
28
43−------------------------------------------------------------------------------
29+
44−-- | The result of a request event
45−data ReqResult tag a
46− = ResponseSuccess tag a XhrResponse
30+data ReqResult a = ResponseSuccess a XhrResponse
47− -- ^ The succesfully decoded response from a request tagged with 'tag'
48− | ResponseFailure tag Text XhrResponse
31+ | ResponseFailure Text XhrResponse
49− -- ^ The failure response, which may have failed decoding or had
50− -- a non-successful response code
51− | RequestFailure tag Text
32+ | RequestFailure Text
52− -- ^ A failure to construct the request tagged with 'tag' at trigger time
33+
53− deriving (Functor)
34+instance Functor ReqResult where
54−
35+ fmap f (ResponseSuccess a xhr) = ResponseSuccess (f a) xhr
55−data ClientOptions = ClientOptions
36+ fmap _ (ResponseFailure r x) = ResponseFailure r x
56− { optsRequestFixup :: forall a. Show a => XhrRequest a -> JSM (XhrRequest a)
37+ fmap _ (RequestFailure r) = RequestFailure r
57− -- ^ Aribtrarily modify requests just before they are sent.
38+
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
39+reqSuccess :: ReqResult a -> Maybe a
92−reqFailure (ResponseFailure _ s _) = Just s
40+reqSuccess (ResponseSuccess x _) = Just x
93−reqFailure (RequestFailure _ s) = Just s
94−reqFailure _ = Nothing
41+reqSuccess _ = Nothing
95−
42+
96−------------------------------------------------------------------------------
97−-- | Simple filter/accessor like 'reqFailure', but keeping the request tag
98−reqFailure' :: ReqResult tag a -> Maybe (tag,Text)
43+reqFailure :: ReqResult a -> Maybe Text
99−reqFailure' (ResponseFailure tag s _) = Just (tag,s)
44+reqFailure (ResponseFailure s _) = Just s
100−reqFailure' (RequestFailure tag s) = Just (tag,s)
45+reqFailure (RequestFailure s) = Just s
101−reqFailure' _ = Nothing
46+reqFailure _ = Nothing
102−
47+
103−
104−------------------------------------------------------------------------------
105−-- | Simple filter/accessor for the raw XHR response
106−response :: ReqResult tag a -> Maybe XhrResponse
48+response :: ReqResult a -> Maybe XhrResponse
107−response (ResponseSuccess _ _ x) = Just x
49+response (ResponseSuccess _ x) = Just x
108−response (ResponseFailure _ _ x) = Just x
50+response (ResponseFailure _ x) = Just x
109−response _ = Nothing
51+response _ = Nothing
110−
52+
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
117
53
118-------------------------------------------------------------------------------
54-------------------------------------------------------------------------------
119-- | You must wrap the parameter of a QueryParam endpoint with 'QParam' to
55-- | You must wrap the parameter of a QueryParam endpoint with 'QParam' to
@@ -126,13 +62,11 @@ data QParam a = QParamSome a
126 | QParamInvalid Text
62 | QParamInvalid Text
127 -- ^ Indication that your validation failed (the request isn't valid)
63 -- ^ Indication that your validation failed (the request isn't valid)
128
64
129−
130qParamToQueryPart :: ToHttpApiData a => QParam a -> Either Text (Maybe Text)
65qParamToQueryPart :: ToHttpApiData a => QParam a -> Either Text (Maybe Text)
131qParamToQueryPart (QParamSome a) = Right (Just $ toQueryParam a)
66qParamToQueryPart (QParamSome a) = Right (Just $ toQueryParam a)
132qParamToQueryPart QNone = Right Nothing
67qParamToQueryPart QNone = Right Nothing
133qParamToQueryPart (QParamInvalid e) = Left e
68qParamToQueryPart (QParamInvalid e) = Left e
134
69
135−
136data QueryPart t = QueryPartParam (Dynamic t (Either Text (Maybe Text)))
70data QueryPart t = QueryPartParam (Dynamic t (Either Text (Maybe Text)))
137 | QueryPartParams (Dynamic t [Text])
71 | QueryPartParams (Dynamic t [Text])
138 | QueryPartFlag (Dynamic t Bool)
72 | QueryPartFlag (Dynamic t Bool)
@@ -162,13 +96,20 @@ addHeader :: (ToHttpApiData a, Reflex t) => Text -> Dynamic t (Either Text a) ->
162addHeader name val req = req { headers = (name, (fmap . fmap) (TE.decodeUtf8 . toHeader) val) : headers req }
96addHeader name val req = req { headers = (name, (fmap . fmap) (TE.decodeUtf8 . toHeader) val) : headers req }
163
97
164
98
165−reqToReflexRequest
99+-- * performing requests
166− :: forall t. Reflex t
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)
167− => Text
106+ => Text
168− -> Dynamic t BaseUrl
169− -> Req t
107+ -> Req t
170− -> Dynamic t (Either Text (XhrRequest XhrPayload))
108+ -> Dynamic t BaseUrl
171−reqToReflexRequest reqMeth reqHost req =
109+ -> Event t ()
110+ -> m (Event t XhrResponse, Event t Text)
111+performRequest reqMeth req reqHost trigger = do
112+
172 let t :: Dynamic t [Either Text Text]
113 let t :: Dynamic t [Either Text Text]
173 t = sequence $ reverse $ reqPathParts req
114 t = sequence $ reverse $ reqPathParts req
174
115
@@ -179,22 +120,18 @@ reqToReflexRequest reqMeth reqHost req =
179 urlParts = fmap sequence t
120 urlParts = fmap sequence t
180
121
181 urlPath :: Dynamic t (Either Text Text)
122 urlPath :: Dynamic t (Either Text Text)
182− urlPath = (fmap.fmap)
123+ urlPath = (fmap.fmap) (T.intercalate "/") urlParts
183− (T.intercalate "/" . fmap escape)
184− urlParts
185
124
186 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
125 queryPartString :: (Text, QueryPart t) -> Dynamic t (Maybe (Either Text Text))
187 queryPartString (pName, qp) = case qp of
126 queryPartString (pName, qp) = case qp of
188 QueryPartParam p -> ffor p $ \case
127 QueryPartParam p -> ffor p $ \case
189 Left e -> Just (Left e)
128 Left e -> Just (Left e)
190− Right (Just a) -> Just (Right $ pName <> "=" <> escape a)
129+ Right (Just a) -> Just (Right $ pName <> "=" <> a)
191 Right Nothing -> Nothing
130 Right Nothing -> Nothing
192 QueryPartParams ps -> ffor ps $ \pStrings ->
131 QueryPartParams ps -> ffor ps $ \pStrings ->
193 if null pStrings
132 if null pStrings
194 then Nothing
133 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))
198 QueryPartFlag fl -> ffor fl $ \case
135 QueryPartFlag fl -> ffor fl $ \case
199 True -> Just $ Right pName
136 True -> Just $ Right pName
200 False -> Nothing
137 False -> Nothing
@@ -205,8 +142,8 @@ reqToReflexRequest reqMeth reqHost req =
205 queryPartStrings' = fmap (sequence . catMaybes) $ sequence queryPartStrings :: Dynamic t (Either Text [Text])
142 queryPartStrings' = fmap (sequence . catMaybes) $ sequence queryPartStrings :: Dynamic t (Either Text [Text])
206 queryString :: Dynamic t (Either Text Text) =
143 queryString :: Dynamic t (Either Text Text) =
207 ffor queryPartStrings' $ \qs -> fmap (T.intercalate "&") qs
144 ffor queryPartStrings' $ \qs -> fmap (T.intercalate "&") qs
145+-- ffor queryPartStrings' $ \qs -> fmap (T.intercalate "&") (sequence qs)
208− xhrUrl = (liftA3 . liftA3) (\a p q -> a </> if T.null q then p else p <> "?" <> q)
146+ xhrUrl = (liftA3 . liftA3) (\a p q -> a </> if T.null q then p else p <> "?" <> q) baseUrl urlPath queryString
209− baseUrl urlPath queryString
210 where
147 where
211 (</>) :: Text -> Text -> Text
148 (</>) :: Text -> Text -> Text
212 x </> y | ("/" `T.isSuffixOf` x) || ("/" `T.isPrefixOf` y) = x <> y
149 x </> y | ("/" `T.isSuffixOf` x) || ("/" `T.isPrefixOf` y) = x <> y
@@ -229,10 +166,10 @@ reqToReflexRequest reqMeth reqHost req =
229 Right $ XhrRequestConfig
166 Right $ XhrRequestConfig
230 { _xhrRequestConfig_sendData = bytesToPayload bBytes
167 { _xhrRequestConfig_sendData = bytesToPayload bBytes
231 , _xhrRequestConfig_headers =
168 , _xhrRequestConfig_headers =
232− Map.insert "Content-Type" bCT (Map.fromList hs)
169+ Map.insert "Content-Type" bCT (Map.fromList hs)
233 , _xhrRequestConfig_user = Nothing
170 , _xhrRequestConfig_user = Nothing
234 , _xhrRequestConfig_password = Nothing
171 , _xhrRequestConfig_password = Nothing
235− , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
172+ , _xhrRequestConfig_responseType = Nothing
236 , _xhrRequestConfig_withCredentials = False
173 , _xhrRequestConfig_withCredentials = False
237 , _xhrRequestConfig_responseHeaders = def
174 , _xhrRequestConfig_responseHeaders = def
238 }
175 }
@@ -244,8 +181,8 @@ reqToReflexRequest reqMeth reqHost req =
244 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
181 Right hs -> Right $ def { _xhrRequestConfig_headers = Map.fromList hs
245 , _xhrRequestConfig_user = Nothing
182 , _xhrRequestConfig_user = Nothing
246 , _xhrRequestConfig_password = Nothing
183 , _xhrRequestConfig_password = Nothing
247− , _xhrRequestConfig_responseType = Just XhrResponseType_ArrayBuffer
184+ , _xhrRequestConfig_responseType = Nothing
248− , _xhrRequestConfig_sendData = mempty
185+ , _xhrRequestConfig_sendData = ""
249 , _xhrRequestConfig_withCredentials = False
186 , _xhrRequestConfig_withCredentials = False
250 }
187 }
251 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
188 Just rBody -> liftA2 mkConfigBody xhrHeaders rBody
@@ -265,167 +202,47 @@ reqToReflexRequest reqMeth reqHost req =
265
202
266 xhrReq = (liftA2 . liftA2) (\p opt -> XhrRequest reqMeth p opt) xhrUrl (addAuth xhrOpts)
203 xhrReq = (liftA2 . liftA2) (\p opt -> XhrRequest reqMeth p opt) xhrUrl (addAuth xhrOpts)
267
204
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
269
208
270−-- * performing requests
209+ resps <- performRequestAsync okReqs
271
210
272−displayHttpRequest :: Text -> Text
211+ return (resps, badReqs)
273−displayHttpRequest httpmethod = "HTTP " <> httpmethod <> " request"
274
212
275−-- | This function performs the request
213+#ifdef ghcjs_HOST_OS
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
214+type XhrPayload = String
340bytesToPayload :: BL.ByteString -> XhrPayload
215bytesToPayload :: BL.ByteString -> XhrPayload
341−bytesToPayload = BL.toStrict
216+bytesToPayload = BL.unpack
342−
217+#else
343−
218+type XhrPayload = T.Text
344−performRequestsCT
219+bytesToPayload :: BL.ByteString -> XhrPayload
220+bytesToPayload = T.pack . BL.unpack
221+#endif
222+
345− :: (SupportsServantReflex t m,
223+performRequestNoBody :: forall t m .(SupportsServantReflex t m)
224+ => Text
225+ -> Req t
226+ -> Dynamic t BaseUrl
227+ -> Event t () -> m (Event t (ReqResult NoContent))
228+performRequestNoBody reqMeth req reqHost trigger = do
229+ (resp, badReq) <- performRequest reqMeth req reqHost trigger
230+ return $ leftmost [ fmap (ResponseSuccess NoContent) resp, fmap RequestFailure badReq]
231+
232+
233+performRequestCT :: (SupportsServantReflex t m,
346− MimeUnrender ct a, Traversable f)
234+ MimeUnrender ct a)
347− => Proxy ct
348− -> Text
349− -> Dynamic t (f (Req t))
350− -> Dynamic t BaseUrl
235+ => Proxy ct -> Text -> Req t -> Dynamic t BaseUrl
351− -> ClientOptions
352− -> Event t tag
353− -> m (Event t (f (ReqResult tag a)))
236+ -> Event t () -> m (Event t (ReqResult a))
354−performRequestsCT ct reqMeth reqs reqHost opts trigger = do
237+performRequestCT ct reqMeth req reqHost trigger = do
355− resps <- performRequests reqMeth reqs reqHost opts trigger
238+ (resp, badReq) <- performRequest reqMeth req reqHost trigger
356− let decodeResp (Just (XhrResponseBody_ArrayBuffer x)) =
239+ let decodes = ffor resp $ \xhr ->
357− first T.pack .
358− mimeUnrender ct $
240+ ((mimeUnrender ct . BL.fromStrict . TE.encodeUtf8)
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)
241+ =<< note "No body text" (_xhrResponse_responseText xhr), xhr)
398− respPayld = if okStatus
242+ reqs = ffor decodes $ \case
399− then either
243+ (Right a, r) -> ResponseSuccess a r
400− (\e -> ResponseFailure tag e xhr)
244+ (Left e, r) -> ResponseFailure (T.pack e) r
401− (\v -> ResponseSuccess tag v xhr)
245+ return $ leftmost [reqs, fmap RequestFailure badReq]
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−
418
246
419note :: e -> Maybe a -> Either e a
247note :: e -> Maybe a -> Either e a
420note e = maybe (Left e) Right
248note 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+187−318
@@ -1,23 +1,16 @@
1−{-# LANGUAGE AllowAmbiguousTypes #-}
1+{-# LANGUAGE CPP #-}
2−{-# LANGUAGE CPP #-}
3−{-# LANGUAGE DataKinds #-}
2+{-# LANGUAGE DataKinds #-}
4−{-# LANGUAGE FlexibleContexts #-}
3+{-# LANGUAGE FlexibleContexts #-}
5−{-# LANGUAGE FlexibleInstances #-}
4+{-# LANGUAGE FlexibleInstances #-}
6−{-# LANGUAGE GeneralizedNewtypeDeriving #-}
7−{-# LANGUAGE InstanceSigs #-}
5+{-# LANGUAGE InstanceSigs #-}
8−{-# LANGUAGE MultiParamTypeClasses #-}
9−{-# LANGUAGE OverloadedStrings #-}
6+{-# LANGUAGE OverloadedStrings #-}
10−{-# LANGUAGE PolyKinds #-}
7+{-# LANGUAGE PolyKinds #-}
11−{-# LANGUAGE Rank2Types #-}
12−{-# LANGUAGE ScopedTypeVariables #-}
8+{-# LANGUAGE ScopedTypeVariables #-}
13−{-# LANGUAGE TupleSections #-}
9+{-# LANGUAGE TupleSections #-}
14−{-# LANGUAGE TypeFamilies #-}
10+{-# LANGUAGE TypeFamilies #-}
15−{-# LANGUAGE TypeOperators #-}
11+{-# LANGUAGE TypeOperators #-}
16−{-# LANGUAGE UndecidableInstances #-}
12+{-# LANGUAGE UndecidableInstances #-}
17−
13+{-# LANGUAGE MultiParamTypeClasses #-}
18−#if MIN_VERSION_base(4,9,0)
19−{-# OPTIONS_GHC -fno-warn-redundant-constraints #-}
20−#endif
21
14
22-- #include "overlapping-compat.h"
15-- #include "overlapping-compat.h"
23-- | This module provides 'client' which can automatically generate
16-- | This module provides 'client' which can automatically generate
@@ -25,71 +18,49 @@
25-- API.
18-- API.
26module Servant.Reflex
19module Servant.Reflex
27 ( client
20 ( client
28− , clientWithOpts
21+ , HasClient(..)
29− , clientWithOptsAndResultHandler
30− , clientWithRoute
31− , clientWithRouteAndResultHandler
32− , BuildHeaderKeysTo(..)
33− , toHeaders
34− , HasClient
35− , Client
36 , module Servant.Common.Req
22 , module Servant.Common.Req
37 , module Servant.Common.BaseUrl
23 , module Servant.Common.BaseUrl
38 ) where
24 ) where
39
25
40−------------------------------------------------------------------------------
26+-------------------------------------------------------------------------------
41import Control.Applicative
27import Control.Applicative
42−import qualified Data.CaseInsensitive as CI
43−import Data.Functor.Identity
44−import qualified Data.Map as Map
45import Data.Monoid ((<>))
28import Data.Monoid ((<>))
46−import Data.Proxy (Proxy (..))
47import qualified Data.Set as Set
29import qualified Data.Set as Set
30+import qualified Data.Text.Encoding as E
31+import Data.CaseInsensitive (mk)
32+import Data.Proxy (Proxy (..))
33+import qualified Data.Map as Map
48import Data.Text (Text)
34import Data.Text (Text)
49import qualified Data.Text as T
35import qualified Data.Text as T
50−import qualified Data.Text.Encoding as E
51−import GHC.Exts (Constraint)
52import GHC.TypeLits (KnownSymbol, symbolVal)
36import GHC.TypeLits (KnownSymbol, symbolVal)
53−import Servant.API ((:<|>) (..), (:>), BasicAuth,
37+import Servant.API ((:<|>)(..),(:>), BasicAuth,
54− BasicAuthData, BuildHeadersTo (..),
38+ BasicAuthData, BuildHeadersTo(..),
55− Capture, Header, Headers (..),
39+ Capture, contentType, Header,
56− HttpVersion, IsSecure,
40+ Headers(..), HttpVersion, IsSecure,
57− MimeRender (..), MimeUnrender,
41+ MimeRender(..), MimeUnrender,
58 NoContent, QueryFlag, QueryParam,
42 NoContent, QueryFlag, QueryParam,
59− QueryParams, Raw, ReflectMethod (..),
43+ QueryParams, Raw, ReflectMethod(..),
60 RemoteHost, ReqBody,
44 RemoteHost, ReqBody,
61− ToHttpApiData (..), Vault, Verb,
45+ 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−------------------------------------------------------------------------------
73import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
46import Servant.Common.BaseUrl (BaseUrl(..), Scheme(..), baseUrlWidget,
74 showBaseUrl,
47 showBaseUrl,
75 SupportsServantReflex)
48 SupportsServantReflex)
76−import Servant.Common.Req (ClientOptions(..),
77− defaultClientOptions,
78− Req, ReqResult(..), QParam(..),
49+import Servant.Common.Req (Req, ReqResult(..), QParam(..),
79 QueryPart(..), addHeader, authData,
50 QueryPart(..), addHeader, authData,
80− defReq, evalResponse, prependToPathParts,
51+ defReq, prependToPathParts,
81− -- performRequestCT,
52+ performRequestCT,
82− performRequestsCT,
83− -- performRequestNoBody,
53+ performRequestNoBody,
84− performRequestsNoBody,
85− performSomeRequestsAsync,
86 qParamToQueryPart, reqBody,
54 qParamToQueryPart, reqBody,
87 reqSuccess, reqFailure,
55 reqSuccess, reqFailure,
88− reqMethod, respHeaders,
56+ reqMethod, respHeaders, response,
89− response,
90− reqTag,
91− qParams, withCredentials)
57+ qParams)
92−
58+import Reflex.Dom (Dynamic, Event, Reflex,
59+ XhrRequest(..),
60+ XhrResponseHeaders(..),
61+ XhrResponse(..), ffor, fmapMaybe,
62+ leftmost, performRequestAsync,
63+ tagPromptlyDyn )
93
64
94-- * Accessing APIs as a Client
65-- * Accessing APIs as a Client
95
66
@@ -101,78 +72,28 @@ import Servant.Common.Req (ClientOptions(..),
101-- > myApi :: Proxy MyApi
72-- > myApi :: Proxy MyApi
102-- > myApi = Proxy
73-- > myApi = Proxy
103-- >
74-- >
104−-- > getAllBooks :: Event t l -> m (Event t (l, ReqResult [Book]))
75+-- > getAllBooks :: Event t () -> m (Event t (Either XhrError ((),[Book])))
105−-- > postNewBook :: Dynamic t (Maybe Book) -> Event t l
76+-- > postNewBook :: Dynamic t (Maybe Book) -> Event t ()
106−-- > -> m (Event t (l, ReqResult Book)))
77+-- -> m (Event t (Either XhrError (Book,Book)))
107-- > (getAllBooks :<|> postNewBook) = client myApi host
78-- > (getAllBooks :<|> postNewBook) = client myApi host
108-- > where host = constDyn $ BaseUrl Http "localhost" 8080
79-- > where host = constDyn $ BaseUrl Http "localhost" 8080
109−client
110− :: (HasClient t m layout tag)
80+client :: (HasClient t m layout)
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
81+ => Proxy layout -> Proxy m -> Dynamic t BaseUrl -> Client t m layout
124− -> ClientOptions
125− -> Client t m layout tag
126−clientWithOpts p q t baseurl = clientWithRoute p q t defReq baseurl
82+client p q baseurl = clientWithRoute p q 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−
142
83
143-- | This class lets us define how each API combinator
84-- | This class lets us define how each API combinator
144-- influences the creation of an HTTP request. It's mostly
85-- influences the creation of an HTTP request. It's mostly
145-- an internal class, you can just use 'client'.
86-- an internal class, you can just use 'client'.
146−class Monad m => HasClient t m layout (tag :: *) where
87+class HasClient t m layout where
147− type Client t m layout tag :: *
88+ type Client t m layout :: *
148− clientWithRoute
89+ clientWithRoute :: Proxy layout -> Proxy m -> Req t -> Dynamic t BaseUrl -> Client t m layout
149− :: Proxy layout
90+
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
175
91
92+instance (HasClient t m a, HasClient t m b) => HasClient t m (a :<|> b) where
93+ type Client t m (a :<|> b) = Client t m a :<|> Client t m b
94+ clientWithRoute Proxy q req baseurl =
95+ clientWithRoute (Proxy :: Proxy a) q req baseurl :<|>
96+ clientWithRoute (Proxy :: Proxy b) q req baseurl
176
97
177-- Capture. Example:
98-- Capture. Example:
178-- > type MyApi = "books" :> Capture "isbn" Text :> Get '[JSON] Book
99-- > type MyApi = "books" :> Capture "isbn" Text :> Get '[JSON] Book
@@ -182,72 +103,67 @@ instance (HasClient t m a tag, HasClient t m b tag) => HasClient t m (a :<|> b)
182-- > getBook :: SupportsServantReflex t m
103-- > getBook :: SupportsServantReflex t m
183-- => Dynamic t BaseUrl
104-- => Dynamic t BaseUrl
184-- -> Dynamic t (Maybe Text)
105-- -> Dynamic t (Maybe Text)
185−-- -> Event t l
106+-- -> Event t ()
186−-- -> m (Event t (l, ReqResult Book))
107+-- -> m (Event t (Either XhrError (Text, Book)))
187-- > getBook = client myApi (constDyn host)
108-- > getBook = client myApi (constDyn host)
109+instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout)
110+ => HasClient t m (Capture capture a :> sublayout) where
188
111
189−instance (SupportsServantReflex t m, ToHttpApiData a, HasClient t m sublayout tag)
190− => HasClient t m (Capture capture a :> sublayout) tag where
112+ type Client t m (Capture capture a :> sublayout) =
113+ Dynamic t (Either Text a) -> Client t m sublayout
191
114
192− type Client t m (Capture capture a :> sublayout) tag =
115+ clientWithRoute Proxy q req baseurl val =
193− Dynamic t (Either Text a) -> Client t m sublayout tag
116+ clientWithRoute (Proxy :: Proxy sublayout)
117+ q
118+ (prependToPathParts p req)
119+ baseurl
194
120
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
121 where p = (fmap . fmap) (toUrlPiece) val
199
122
200−
201-- VERB (Returning content) --
123-- VERB (Returning content) --
202instance {-# OVERLAPPABLE #-}
124instance {-# OVERLAPPABLE #-}
203 -- Note [Non-Empty Content Types]
125 -- Note [Non-Empty Content Types]
204 (MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
126 (MimeUnrender ct a, ReflectMethod method, cts' ~ (ct ': cts), SupportsServantReflex t m
205− ) => HasClient t m (Verb method status cts' a) tag where
127+ ) => HasClient t m (Verb method status cts' a) where
206− type Client t m (Verb method status cts' a) tag =
128+ type Client t m (Verb method status cts' a) =
207− Event t tag -> m (Event t (ReqResult tag a))
129+ Event t () -> m (Event t (ReqResult a))
208 -- TODO how to access input types here?
130 -- TODO how to access input types here?
209 -- ExceptT ServantError IO a
131 -- ExceptT ServantError IO a
210− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
132+ clientWithRoute Proxy _ req baseurl =
211− wrap =<< fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity $ req') baseurl opts trigs
133+ performRequestCT (Proxy :: Proxy ct) method req' baseurl
212 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
134 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
213 req' = req { reqMethod = method }
135 req' = req { reqMethod = method }
214
136
215−
216-- -- VERB (No content) --
137-- -- VERB (No content) --
217instance {-# OVERLAPPING #-}
138instance {-# OVERLAPPING #-}
218 (ReflectMethod method, SupportsServantReflex t m) =>
139 (ReflectMethod method, SupportsServantReflex t m) =>
219− HasClient t m (Verb method status cts NoContent) tag where
140+ HasClient t m (Verb method status cts NoContent) where
220− type Client t m (Verb method status cts NoContent) tag =
141+ type Client t m (Verb method status cts NoContent) =
221− Event t tag -> m (Event t (ReqResult tag NoContent))
142+ Event t () -> m (Event t (ReqResult NoContent))
222 -- TODO: how to access input types here?
143 -- TODO: how to access input types here?
223 -- ExceptT ServantError IO NoContent
144 -- ExceptT ServantError IO NoContent
224− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs =
145+ clientWithRoute Proxy _ req baseurl =
225− wrap =<< fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req) baseurl opts trigs
146+ performRequestNoBody method req baseurl
226 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
147 where method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
227
148
228−
229−toHeaders :: BuildHeadersTo ls => ReqResult tag a -> ReqResult tag (Headers ls a)
149+toHeaders :: BuildHeadersTo ls => ReqResult a -> ReqResult (Headers ls a)
230toHeaders r =
150toHeaders r =
151+ let toBS = E.encodeUtf8
231− let hdrs = maybe []
152+ hdrs = maybe []
232− (\xhr -> fmap (\(h,v) -> (CI.map E.encodeUtf8 h, E.encodeUtf8 v))
153+ (\xhr -> fmap (\(h,v) -> (mk (toBS h), toBS v))
233 (Map.toList $ _xhrResponse_headers xhr))
154 (Map.toList $ _xhrResponse_headers xhr))
234 (response r)
155 (response r)
235 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
156 in ffor r $ \a -> Headers {getResponse = a ,getHeadersHList = buildHeadersTo hdrs}
236
157
237−
238class BuildHeaderKeysTo hs where
158class BuildHeaderKeysTo hs where
239− buildHeaderKeysTo :: Proxy hs -> [CI.CI T.Text]
159+ buildHeaderKeysTo :: Proxy hs -> [T.Text]
240
160
241instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
161instance {-# OVERLAPPABLE #-} BuildHeaderKeysTo '[]
242 where buildHeaderKeysTo _ = []
162 where buildHeaderKeysTo _ = []
243
163
244instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
164instance {-# OVERLAPPABLE #-} (BuildHeaderKeysTo xs, KnownSymbol h)
245− => BuildHeaderKeysTo ((Header h v) ': xs) where
165+ => 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)
166+ buildHeaderKeysTo _ = (T.pack $ symbolVal (Proxy :: Proxy h)) : buildHeaderKeysTo (Proxy :: Proxy xs)
250−
251
167
252-- HEADERS Verb (Content) --
168-- HEADERS Verb (Content) --
253-- Headers combinator not treated in fully general case,
169-- Headers combinator not treated in fully general case,
@@ -259,35 +175,33 @@ instance {-# OVERLAPPABLE #-}
259 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
175 ( MimeUnrender ct a, BuildHeadersTo ls, BuildHeaderKeysTo ls,
260 ReflectMethod method, cts' ~ (ct ': cts),
176 ReflectMethod method, cts' ~ (ct ': cts),
261 SupportsServantReflex t m
177 SupportsServantReflex t m
262− ) => HasClient t m (Verb method status cts' (Headers ls a)) tag where
178+ ) => HasClient t m (Verb method status cts' (Headers ls a)) where
263− type Client t m (Verb method status cts' (Headers ls a)) tag =
179+ type Client t m (Verb method status cts' (Headers ls a)) =
264− Event t tag -> m (Event t (ReqResult tag (Headers ls a)))
180+ Event t () -> m (Event t (ReqResult (Headers ls a)))
265− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
181+ clientWithRoute Proxy _ req baseurl = do
266 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
182 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
267− resp <- fmap runIdentity <$> performRequestsCT (Proxy :: Proxy ct) method (constDyn $ Identity req') baseurl opts trigs
183+ resp <- performRequestCT (Proxy :: Proxy ct) method req' baseurl
268− wrap $ toHeaders <$> resp
184+ return $ (fmap . fmap) toHeaders resp
269 where req' = req { respHeaders =
185 where req' = req { respHeaders =
270 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
186 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
271 }
187 }
272
188
273−
274-- HEADERS Verb (No content) --
189-- HEADERS Verb (No content) --
275instance {-# OVERLAPPABLE #-}
190instance {-# OVERLAPPABLE #-}
276 ( BuildHeadersTo ls, BuildHeaderKeysTo ls, ReflectMethod method,
191 ( BuildHeadersTo ls, BuildHeaderKeysTo ls, ReflectMethod method,
277 SupportsServantReflex t m
192 SupportsServantReflex t m
278− ) => HasClient t m (Verb method status cts (Headers ls NoContent)) tag where
193+ ) => HasClient t m (Verb method status cts (Headers ls NoContent)) where
279− type Client t m (Verb method status cts (Headers ls NoContent)) tag
194+ type Client t m (Verb method status cts (Headers ls NoContent))
280− = Event t tag -> m (Event t (ReqResult tag (Headers ls NoContent)))
195+ = Event t () -> m (Event t (ReqResult (Headers ls NoContent)))
281− clientWithRouteAndResultHandler Proxy _ _ req baseurl opts wrap trigs = do
196+ clientWithRoute Proxy _ req baseurl = do
282 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
197 let method = E.decodeUtf8 $ reflectMethod (Proxy :: Proxy method)
283− resp <- fmap runIdentity <$> performRequestsNoBody method (constDyn $ Identity req') baseurl opts trigs
198+ resp <- performRequestNoBody method req' baseurl
284− wrap $ toHeaders <$> resp
199+ return $ (fmap . fmap) toHeaders resp
285 where req' = req {respHeaders =
200 where req' = req {respHeaders =
286 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
201 OnlyHeaders (Set.fromList (buildHeaderKeysTo (Proxy :: Proxy ls)))
287 }
202 }
288
203
289
204
290−
291-- HEADER
205-- HEADER
292-- > newtype Referer = Referer { referrer :: Text }
206-- > newtype Referer = Referer { referrer :: Text }
293-- > deriving (Eq, Show, Generic, FromText, ToHttpApiData)
207-- > deriving (Eq, Show, Generic, FromText, ToHttpApiData)
@@ -302,45 +216,29 @@ instance {-# OVERLAPPABLE #-}
302-- > -- then you can just use "viewRefer" to query that endpoint
216-- > -- then you can just use "viewRefer" to query that endpoint
303-- > -- specifying Nothing or e.g Just "http://haskell.org/" as arguments
217-- > -- specifying Nothing or e.g Just "http://haskell.org/" as arguments
304instance (KnownSymbol sym, ToHttpApiData a,
218instance (KnownSymbol sym, ToHttpApiData a,
305− HasClient t m sublayout tag, SupportsServantReflex t m)
219+ HasClient t m sublayout, SupportsServantReflex t m)
306− => HasClient t m (Header sym a :> sublayout) tag where
220+ => HasClient t m (Header sym a :> sublayout) where
307
221
308− type Client t m (Header sym a :> sublayout) tag =
222+ type Client t m (Header sym a :> sublayout) =
309− Dynamic t (Either Text a) -> Client t m sublayout tag
223+ Dynamic t (Either Text a) -> Client t m sublayout
310
224
311− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap eVal =
225+ clientWithRoute Proxy q req baseurl eVal =
312− clientWithRouteAndResultHandler
313− (Proxy :: Proxy sublayout) q t
226+ clientWithRoute (Proxy :: Proxy sublayout)
227+ q
314− (Servant.Common.Req.addHeader hname eVal req)
228+ (Servant.Common.Req.addHeader hname eVal req)
315− baseurl opts wrap
229+ baseurl
316 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
230 where hname = T.pack $ symbolVal (Proxy :: Proxy sym)
317
231
318−
319−
320−
321-- | Using a 'HttpVersion' combinator in your API doesn't affect the client
232-- | Using a 'HttpVersion' combinator in your API doesn't affect the client
322-- functions.
233-- functions.
323−instance HasClient t m sublayout tag
234+instance HasClient t m sublayout
324− => HasClient t m (HttpVersion :> sublayout) tag where
235+ => HasClient t m (HttpVersion :> sublayout) 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)
342
236
237+ type Client t m (HttpVersion :> sublayout) =
238+ Client t m sublayout
343
239
240+ clientWithRoute Proxy q =
241+ clientWithRoute (Proxy :: Proxy sublayout) q
344
242
345
243
346-- | If you use a 'QueryParam' in one of your endpoints in your API,
244-- | If you use a 'QueryParam' in one of your endpoints in your API,
@@ -369,16 +267,16 @@ instance (HasClient t m sublayout tag, KnownSymbol sym)
369-- > -- then you can just use "getBooksBy" to query that endpoint.
267-- > -- then you can just use "getBooksBy" to query that endpoint.
370-- > -- 'getBooksBy Nothing' for all books
268-- > -- 'getBooksBy Nothing' for all books
371-- > -- 'getBooksBy (Just "Isaac Asimov")' to get all books by Isaac Asimov
269-- > -- 'getBooksBy (Just "Isaac Asimov")' to get all books by Isaac Asimov
372−instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex t)
270+instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout, Reflex t)
373− => HasClient t m (QueryParam sym a :> sublayout) tag where
271+ => HasClient t m (QueryParam sym a :> sublayout) where
374
272
375− type Client t m (QueryParam sym a :> sublayout) tag =
273+ type Client t m (QueryParam sym a :> sublayout) =
376− Dynamic t (QParam a) -> Client t m sublayout tag
274+ Dynamic t (QParam a) -> Client t m sublayout
377
275
378 -- if mparam = Nothing, we don't add it to the query string
276 -- if mparam = Nothing, we don't add it to the query string
379− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap mparam =
277+ clientWithRoute Proxy q req baseurl mparam =
380− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t
278+ clientWithRoute (Proxy :: Proxy sublayout) q
381− (req {qParams = paramPair : qParams req}) baseurl opts wrap
279+ (req {qParams = paramPair : qParams req}) baseurl
382
280
383 where pname = symbolVal (Proxy :: Proxy sym)
281 where pname = symbolVal (Proxy :: Proxy sym)
384 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
282 --p prm = QueryPartParam $ (fmap . fmap) (toQueryParam) prm
@@ -386,8 +284,6 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
386 p prm = QueryPartParam $ fmap qParamToQueryPart prm -- (fmap . fmap) (unpack . toQueryParam) prm
284 p prm = QueryPartParam $ fmap qParamToQueryPart prm -- (fmap . fmap) (unpack . toQueryParam) prm
387 paramPair = (T.pack pname, p mparam)
285 paramPair = (T.pack pname, p mparam)
388
286
389−
390−
391-- | If you use a 'QueryParams' in one of your endpoints in your API,
287-- | If you use a 'QueryParams' in one of your endpoints in your API,
392-- the corresponding querying function will automatically take
288-- the corresponding querying function will automatically take
393-- an additional argument, a list of values of the type specified
289-- an additional argument, a list of values of the type specified
@@ -416,22 +312,21 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
416-- > -- 'getBooksBy []' for all books
312-- > -- 'getBooksBy []' for all books
417-- > -- 'getBooksBy ["Isaac Asimov", "Robert A. Heinlein"]'
313-- > -- 'getBooksBy ["Isaac Asimov", "Robert A. Heinlein"]'
418-- > -- to get all books by Asimov and Heinlein
314-- > -- to get all books by Asimov and Heinlein
419−instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex t)
315+instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout, Reflex t)
420− => HasClient t m (QueryParams sym a :> sublayout) tag where
316+ => HasClient t m (QueryParams sym a :> sublayout) where
421
317
422− type Client t m (QueryParams sym a :> sublayout) tag =
318+ type Client t m (QueryParams sym a :> sublayout) =
423− Dynamic t [a] -> Client t m sublayout tag
319+ Dynamic t [a] -> Client t m sublayout
424
320
425− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap paramlist =
321+ clientWithRoute Proxy q req baseurl paramlist =
426− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
322+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
427
323
428 where req' = req { qParams = (T.pack pname, params') : qParams req }
324 where req' = req { qParams = (T.pack pname, params') : qParams req }
429 pname = symbolVal (Proxy :: Proxy sym)
325 pname = symbolVal (Proxy :: Proxy sym)
430− params' = QueryPartParams $ (fmap . fmap) toQueryParam
326+ params' = QueryPartParams $ (fmap . fmap) (toQueryParam)
431 paramlist
327 paramlist
432
328
433
329
434−
435-- | If you use a 'QueryFlag' in one of your endpoints in your API,
330-- | If you use a 'QueryFlag' in one of your endpoints in your API,
436-- the corresponding querying function will automatically take
331-- the corresponding querying function will automatically take
437-- an additional 'Bool' argument.
332-- an additional 'Bool' argument.
@@ -456,42 +351,49 @@ instance (KnownSymbol sym, ToHttpApiData a, HasClient t m sublayout tag, Reflex
456-- > -- 'getBooksBy True' to only get _already published_ books
351-- > -- 'getBooksBy True' to only get _already published_ books
457
352
458-- TODO Bring back
353-- TODO Bring back
459−instance (KnownSymbol sym, HasClient t m sublayout tag, Reflex t)
354+instance (KnownSymbol sym, HasClient t m sublayout, Reflex t)
460− => HasClient t m (QueryFlag sym :> sublayout) tag where
355+ => HasClient t m (QueryFlag sym :> sublayout) where
461
356
462− type Client t m (QueryFlag sym :> sublayout) tag =
357+ type Client t m (QueryFlag sym :> sublayout) =
463− Dynamic t Bool -> Client t m sublayout tag
358+ Dynamic t Bool -> Client t m sublayout
464
359
465− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap flag =
360+ clientWithRoute Proxy q req baseurl flag =
466− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
361+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
467
362
468 where req' = req { qParams = thisPair : qParams req }
363 where req' = req { qParams = thisPair : qParams req }
469 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
364 thisPair = (T.pack pName, QueryPartFlag flag) :: (Text, QueryPart t)
470 pName = symbolVal (Proxy :: Proxy sym)
365 pName = symbolVal (Proxy :: Proxy sym)
471
366
472
367
473−
368+-- | Pick a 'Method' and specify where the server you want to query is. You get
474−-- | Send a raw 'XhrRequest ()' directly to 'baseurl'
369+-- back the full `Response`.
370+-- TODO redo
475−instance SupportsServantReflex t m => HasClient t m Raw tag where
371+instance SupportsServantReflex t m => HasClient t m Raw where
476− type Client t m Raw tag = Dynamic t (Either Text (XhrRequest ()))
372+ type Client t m Raw = Dynamic t (Either Text (XhrRequest ()))
477− -> Event t tag
373+ -> Event t ()
478− -> m (Event t (ReqResult tag ()))
374+ -> m (Event t (ReqResult ()))
479−
375+
480− clientWithRouteAndResultHandler _ _ _ _ baseurl _ wrap xhrs triggers = do
376+ -- clientWithRoute :: Proxy Raw -> Proxy m -> Req -> BaseUrl -> Client t m Raw
481−
377+ clientWithRoute _ _ _ baseurl xhrs triggers = do
482− let xhrs' = liftA2 (\x path -> case x of
378+ let xhrs' = liftA2 (\x path -> case x of
483− Left e -> Left e
379+ Left e -> Left e
484− Right jx -> Right $ jx { _xhrRequest_url = path <> _xhrRequest_url jx }
380+ Right jx -> Right $ jx {_xhrRequest_url = path
381+ <> _xhrRequest_url jx})
382+ xhrs
485− ) xhrs (showBaseUrl <$> baseurl)
383+ (showBaseUrl <$> baseurl)
486− xhrs'' = attachPromptlyDynWith (flip (,)) xhrs' triggers :: Event t (tag, Either Text (XhrRequest ()))
384+ reqs = tagPromptlyDyn xhrs' triggers
487− badReq = fmapMaybe (\(t,x) -> either (Just . (t,)) (const Nothing) x) xhrs'' :: Event t (tag, Text)
385+ okReq = fmapMaybe hush reqs
488− okReq = fmapMaybe (\(t,x) -> either (const Nothing) (Just . (t,)) x) xhrs'' :: Event t (tag, XhrRequest ())
386+ badReq = fmapMaybe tattle reqs
489−
387+ resps <- performRequestAsync okReq
490− resps <- performRequestsAsync okReq
388+ return $ leftmost [fmap (ResponseSuccess () ) resps
491− wrap $ leftmost [ uncurry RequestFailure <$> badReq
389+ ,fmap RequestFailure badReq]
492− , evalResponse (const $ Right ()) <$> resps
390+
493− ]
391+
494−
392+hush :: Either e a -> Maybe a
393+hush = either (const Nothing) Just
394+
395+tattle :: Either e a -> Maybe e
396+tattle = either Just (const Nothing)
495
397
496-- | If you use a 'ReqBody' in one of your endpoints in your API,
398-- | If you use a 'ReqBody' in one of your endpoints in your API,
497-- the corresponding querying function will automatically take
399-- the corresponding querying function will automatically take
@@ -513,14 +415,14 @@ instance SupportsServantReflex t m => HasClient t m Raw tag where
513-- > where host = BaseUrl Http "localhost" 8080
415-- > where host = BaseUrl Http "localhost" 8080
514-- > -- then you can just use "addBook" to query that endpoint
416-- > -- then you can just use "addBook" to query that endpoint
515
417
516−instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
418+instance (MimeRender ct a, HasClient t m sublayout, Reflex t)
517− => HasClient t m (ReqBody (ct ': cts) a :> sublayout) tag where
419+ => HasClient t m (ReqBody (ct ': cts) a :> sublayout) where
518
420
519− type Client t m (ReqBody (ct ': cts) a :> sublayout) tag =
421+ type Client t m (ReqBody (ct ': cts) a :> sublayout) =
520− Dynamic t (Either Text a) -> Client t m sublayout tag
422+ Dynamic t (Either Text a) -> Client t m sublayout
521
423
522− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap body =
424+ clientWithRoute Proxy q req baseurl body =
523− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t req' baseurl opts wrap
425+ clientWithRoute (Proxy :: Proxy sublayout) q req' baseurl
524 where req' = req { reqBody = bodyBytesCT }
426 where req' = req { reqBody = bodyBytesCT }
525 ctProxy = Proxy :: Proxy ct
427 ctProxy = Proxy :: Proxy ct
526 ctString = T.pack $ show $ contentType ctProxy
428 ctString = T.pack $ show $ contentType ctProxy
@@ -528,49 +430,43 @@ instance (MimeRender ct a, HasClient t m sublayout tag, Reflex t)
528 (\b -> (mimeRender ctProxy b, ctString))
430 (\b -> (mimeRender ctProxy b, ctString))
529 body
431 body
530
432
531−
532−
533-- | Make the querying function append @path@ to the request path.
433-- | 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
434+instance (KnownSymbol path, HasClient t m sublayout, Reflex t) => HasClient t m (path :> sublayout) where
535− type Client t m (path :> sublayout) tag = Client t m sublayout tag
435+ type Client t m (path :> sublayout) = Client t m sublayout
536
436
537− clientWithRouteAndResultHandler Proxy q t req baseurl opts wrap =
437+ clientWithRoute Proxy q req baseurl =
538− clientWithRouteAndResultHandler (Proxy :: Proxy sublayout) q t
438+ clientWithRoute (Proxy :: Proxy sublayout) q
539− (prependToPathParts (pure (Right $ T.pack p)) req) baseurl opts wrap
439+ (prependToPathParts (pure (Right $ T.pack p)) req)
440+ baseurl
540
441
541 where p = symbolVal (Proxy :: Proxy path)
442 where p = symbolVal (Proxy :: Proxy path)
542
443
444+instance HasClient t m api => HasClient t m (Vault :> api) where
445+ type Client t m (Vault :> api) = Client t m api
543
446
544−instance HasClient t m api tag => HasClient t m (Vault :> api) tag where
447+ clientWithRoute Proxy q req baseurl =
545− type Client t m (Vault :> api) tag = Client t m api tag
448+ clientWithRoute (Proxy :: Proxy api) q req baseurl
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
449
554− clientWithRouteAndResultHandler Proxy =
450+instance HasClient t m api => HasClient t m (RemoteHost :> api) where
555− clientWithRouteAndResultHandler (Proxy :: Proxy api)
451+ type Client t m (RemoteHost :> api) = Client t m api
556
452
453+ clientWithRoute Proxy q req baseurl =
454+ clientWithRoute (Proxy :: Proxy api) q req baseurl
557
455
456+instance HasClient t m api => HasClient t m (IsSecure :> api) where
457+ type Client t m (IsSecure :> api) = Client t m api
558
458
559−instance HasClient t m api tag => HasClient t m (IsSecure :> api) tag where
459+ clientWithRoute Proxy q req baseurl =
560− type Client t m (IsSecure :> api) tag = Client t m api tag
460+ clientWithRoute (Proxy :: Proxy api) q req baseurl
561
461
562− clientWithRouteAndResultHandler Proxy =
462+instance (HasClient t m api, Reflex t)
563− clientWithRouteAndResultHandler (Proxy :: Proxy api)
463+ => HasClient t m (BasicAuth realm usr :> api) where
564
464
465+ type Client t m (BasicAuth realm usr :> api) = Dynamic t (Maybe BasicAuthData)
466+ -> Client t m api
565
467
566−instance (HasClient t m api tag, Reflex t)
567− => HasClient t m (BasicAuth realm usr :> api) tag where
568−
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 =
468+ clientWithRoute Proxy q req baseurl authdata =
573− clientWithRouteAndResultHandler (Proxy :: Proxy api) q t req' baseurl opts wrap
469+ clientWithRoute (Proxy :: Proxy api) q req' baseurl
574 where
470 where
575 req' = req { authData = Just authdata }
471 req' = req { authData = Just authdata }
576
472
@@ -596,30 +492,3 @@ non-empty lists, but is otherwise more specific, no instance will be overall
596more specific. This in turn generally means adding yet another instance (one
492more specific. This in turn generally means adding yet another instance (one
597for empty and one for non-empty lists).
493for empty and one for non-empty lists).
598-}
494-}
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
9import Data.Foldable
9import Data.Foldable
10import Test.WebDriver.Commands.Wait
10import Test.WebDriver.Commands.Wait
11import Test.Hspec.WebDriver
11import Test.Hspec.WebDriver
12−import Test.Hspec.WebDriver (chromeCaps)
13
12
14
13
15clickingShouldCause :: Selector -> Selector -> Double -> (Element -> Element -> WD Bool) -> WD ()
14clickingShouldCause :: Selector -> Selector -> Double -> (Element -> Element -> WD Bool) -> WD ()
@@ -29,7 +28,7 @@ spec :: Spec
29spec = do
28spec = do
30 describe "servant-reflex tests" $ do
29 describe "servant-reflex tests" $ do
31
30
32− session "test page" $ using [chromeCaps] $ do
31+ session "test page" $ using Chrome $ do
33
32
34 it "opens the page" $ runWD $
33 it "opens the page" $ runWD $
35 openPage "http://localhost:8000"
34 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+14−39
@@ -2,34 +2,27 @@
2{-# LANGUAGE DeriveGeneric #-}
2{-# LANGUAGE DeriveGeneric #-}
3{-# LANGUAGE OverloadedStrings #-}
3{-# LANGUAGE OverloadedStrings #-}
4{-# LANGUAGE PolyKinds #-}
4{-# LANGUAGE PolyKinds #-}
5−{-# LANGUAGE TypeApplications #-}
6{-# LANGUAGE TypeFamilies #-}
5{-# LANGUAGE TypeFamilies #-}
7{-# LANGUAGE TypeOperators #-}
6{-# LANGUAGE TypeOperators #-}
8
7
9−import Control.Monad.IO.Class (liftIO)
10−import Control.Monad.Reader (reader)
11import Data.Aeson
8import Data.Aeson
12import Data.Bool
9import Data.Bool
13−import Data.Char (toUpper)
10+import Data.Char (toUpper)
14−import qualified Data.List as L
11+import qualified Data.List as L
15−import Data.Maybe (fromMaybe)
16import Data.Monoid
12import Data.Monoid
17import Data.Proxy
13import Data.Proxy
18−import Data.Text hiding (head, length, map,
14+import Data.Text hiding (length, null, map, head, toUpper)
19− null, toUpper)
20−import qualified Data.Text as T
15+import qualified Data.Text as T
21−import qualified Data.Text.IO as T
22import GHC.Generics
16import GHC.Generics
23−import Servant.Server.Internal.SnapShims
24−import Snap.Core
25import Snap.Http.Server
17import Snap.Http.Server
18+import Snap.Core
19+import Servant.Server.Internal.SnapShims
26
20
27−import Servant
21+import Servant -- hiding (serveDirectory)
28import Servant.Server
22import Servant.Server
29-- import Snap.Util.FileServe
23-- import Snap.Util.FileServe
30−import System.Environment (lookupEnv)
31import API
24import API
32−import Snap
25+import Snap
33
26
34-- * Example
27-- * Example
35
28
@@ -43,7 +36,7 @@ instance ToJSON Greet
43testApi :: Proxy API
36testApi :: Proxy API
44testApi = Proxy
37testApi = Proxy
45
38
46−data App = App { appStaticDir :: String }
39+data App = App
47
40
48-- Server-side handlers.
41-- Server-side handlers.
49--
42--
@@ -51,10 +44,8 @@ data App = App { appStaticDir :: String }
51-- that represents the API, are glued together using :<|>.
44-- that represents the API, are glued together using :<|>.
52--
45--
53-- Each handler runs in the 'ExceptT ServantErr IO' monad.
46-- Each handler runs in the 'ExceptT ServantErr IO' monad.
54−server :: Server API '[BasicAuthCheck (Handler App App) ()] (Handler App App)
47+server :: Server API (Handler App App)
55−server = return () :<|> return 100 :<|> sayhi :<|> dbl
48+server = return () :<|> return 100 :<|> sayhi :<|> dbl :<|> multi :<|> serveDirectory "static"
56− :<|> multi :<|> qna :<|> serveSecret
57− :<|> statics
58 where sayhi :: Maybe Text -> [Text] -> Bool -> Handler App App Text
49 where sayhi :: Maybe Text -> [Text] -> Bool -> Handler App App Text
59 sayhi nm greetings withGusto = case nm of
50 sayhi nm greetings withGusto = case nm of
60 Nothing -> return ("Sorry, who are you?" :: Text)
51 Nothing -> return ("Sorry, who are you?" :: Text)
@@ -66,36 +57,20 @@ server = return () :<|> return 100 :<|> sayhi :<|> dbl
66 | otherwise = T.intercalate ", " (L.init greetings)
57 | otherwise = T.intercalate ", " (L.init greetings)
67 <> ", and " <> L.last greetings <> ", "
58 <> ", and " <> L.last greetings <> ", "
68 return . modifier $ greetPart <> n
59 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
60+ dbl x = return $ x * 2
72 multi = return . bool "Box unchecked" "Box Checked"
61 multi = return . bool "Box unchecked" "Box Checked"
73− qna q = do
74− liftIO $ do
75− putStrLn $ "qna got: " ++ show q
76− T.putStrLn $ unQuestion q
77− return $ Answer $ unQuestion q
78− serveSecret _ = do
79− req <- getRequest
80− liftIO $ putStrLn (show req)
81− return 101
82− statics = do
83− staticDir <- reader appStaticDir
84− serveDirectory staticDir
85
62
86-- Turn the server into a WAI app. 'serve' is provided by servant,
63-- Turn the server into a WAI app. 'serve' is provided by servant,
87-- more precisely by the Servant.Server module.
64-- more precisely by the Servant.Server module.
88test :: Handler App App ()
65test :: Handler App App ()
89−test = serveSnapWithContext testApi
66+test = serveSnap testApi server
90− (BasicAuthCheck (\_ -> return @(Handler App App) (Authorized ())) :. EmptyContext) server
91
67
92initApp :: SnapletInit App App
68initApp :: SnapletInit App App
93initApp = makeSnaplet "myapp" "example" Nothing $ do
69initApp = makeSnaplet "myapp" "example" Nothing $ do
94− staticDir <- fromMaybe "static" <$> liftIO (lookupEnv "STATIC_DIR")
95 addRoutes [("", test)
70 addRoutes [("", test)
96 ,("", serveDirectory "static")
71 ,("", serveDirectory "static")
97 ]
72 ]
98− return (App staticDir)
73+ return App
99
74
100-- Put this all to work!
75-- Put this all to work!
101main :: IO ()
76main :: 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+16−17
@@ -1,32 +1,31 @@
1−-- Initial back.cabal generated by cabal init. For further documentation,
1+-- Initial back.cabal generated by cabal init. For further documentation,
2-- see http://haskell.org/cabal/users-guide/
2-- see http://haskell.org/cabal/users-guide/
3
3
4name: testserver
4name: testserver
5version: 0.1.0.0
5version: 0.1.0.0
6−-- synopsis:
6+-- synopsis:
7−-- description:
7+-- description:
8license: BSD3
8license: BSD3
9license-file: LICENSE
9license-file: LICENSE
10author: Greg Hale
10author: Greg Hale
11maintainer: imalsogreg@gmail.com
11maintainer: imalsogreg@gmail.com
12−-- copyright:
12+-- copyright:
13−-- category:
13+-- category:
14build-type: Simple
14build-type: Simple
15−-- extra-source-files:
15+-- extra-source-files:
16cabal-version: >=1.10
16cabal-version: >=1.10
17
17
18executable back
18executable back
19 main-is: Main.hs
19 main-is: Main.hs
20− -- other-modules:
20+ -- other-modules:
21− -- other-extensions:
21+ -- other-extensions:
22− build-depends: aeson >= 0.9 && < 1.5
22+ build-depends: aeson >= 0.9 && < 1.1
23− , base >=4.8 && < 5
23+ , base >=4.8 && <4.10
24− , mtl
25− , snap >= 1.0 && < 1.2
24+ , snap >= 1.0 && < 1.1
26− , snap-server >= 1.0 && < 1.2
25+ , snap-server >= 1.0 && < 1.1
27 , snap-core >= 1.0 && < 1.1
26 , snap-core >= 1.0 && < 1.1
28− , servant >= 0.16 && < 0.18
27+ , servant >= 0.7.1 && < 0.9
29− , servant-snap >= 0.8 && < 0.9
28+ , servant-snap >= 0.7 && < 0.8
30− , text >= 1.0 && < 1.3
29+ , text >= 1.2 && < 1.3
31− -- hs-source-dirs:
30+ -- hs-source-dirs:
32 default-language: Haskell2010
31 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− }