on develop help sign in
Make names clearer for tests for RequesterT and EventWriterT; add QueryT tests
commit6185f41d28c14d348b53d569261abefc70cdece7 authorDan Haraj <dan@obsidian.systems> dateTue 6 Jun 2017, 16:08 (9 years ago) parent04ed6ac
3 files changed+132−70
test/EventWriterT.hs+6−13 test/QueryT.hs+83−17 test/RequesterT.hs+43−40
test/EventWriterT.hs+6−13
@@ -9,21 +9,14 @@ import Reflex
99import Reflex.EventWriter
1010import Test.Run
1111
12−import System.Exit (exitFailure)
13−
14−import Data.IORef
15−import Control.Monad.Ref
16−import Reflex.Host.Class
17−import Data.List
18−
1912main :: IO ()
2013main = do
21− os1@[[Just [10,9,8,7,6,5,4,3,2,1]]] <- runApp' (unwrapApp app1) $
14+ os1@[[Just [10,9,8,7,6,5,4,3,2,1]]] <- runApp' (unwrapApp testOrdering) $
2215 [ Just ()
2316 ]
2417 print os1
2518 os2@[[Just [1,3,5,7,9]],[Nothing,Nothing],[Just [2,4,6,8,10]],[Just [2,4,6,8,10],Nothing]]
26− <- runApp' (unwrapApp app2) $ map Just $
19+ <- runApp' (unwrapApp testSimultaneous) $ map Just $
2720 [ This ()
2821 , That ()
2922 , This ()
@@ -37,13 +30,13 @@ unwrapApp x appIn = do
3730 ((), e) <- runEventWriterT $ x appIn
3831 return e
3932
40−app1 :: (Reflex t, Monad m) => Event t () -> EventWriterT t [Int] m ()
41−app1 pulse = do
33+testOrdering :: (Reflex t, Monad m) => Event t () -> EventWriterT t [Int] m ()
34+testOrdering pulse = do
4235 forM_ [10,9..1] $ \i -> tellEvent ([i] <$ pulse)
4336 return ()
4437
45−app2 :: (Reflex t, MonadAdjust t m, MonadHold t m) => Event t (These () ()) -> EventWriterT t [Int] m ()
46−app2 pulse = do
38+testSimultaneous :: (Reflex t, MonadAdjust t m, MonadHold t m) => Event t (These () ()) -> EventWriterT t [Int] m ()
39+testSimultaneous pulse = do
4740 let e0 = fmapMaybe (^? here) pulse
4841 e1 = fmapMaybe (^? there) pulse
4942 forM_ [1,3..9] $ \i -> runWithReplace (tellEvent ([i] <$ e0)) $ ffor e1 $ \_ -> tellEvent ([i+1] <$ e0)
test/QueryT.hs+83−17
@@ -4,15 +4,21 @@
44{-# LANGUAGE GeneralizedNewtypeDeriving #-}
55{-# LANGUAGE LambdaCase #-}
66{-# LANGUAGE OverloadedStrings #-}
7+{-# LANGUAGE RankNTypes #-}
78
89import Control.Lens
910import Control.Monad.Fix
1011import Data.Align
11−import qualified Data.AppendMap as Map
12+import Data.AppendMap (AppendMap)
13+import qualified Data.AppendMap as AMap
14+import Data.Functor.Misc
15+import Data.Map (Map)
16+import qualified Data.Map as Map
1217import Data.Semigroup
1318import Data.These
1419
1520import Reflex
21+import Reflex.Patch.MapWithMove
1622import Test.Run
1723
1824newtype MyQuery = MyQuery SelectedCount
@@ -26,7 +32,7 @@ instance (Ord k, Query a, Eq (QueryResult a)) => Query (Selector k a) where
2632 type QueryResult (Selector k a) = Selector k (QueryResult a)
2733 crop q r = undefined
2834
29−newtype Selector k a = Selector { unSelector :: Map.AppendMap k a }
35+newtype Selector k a = Selector { unSelector :: AppendMap k a }
3036 deriving (Show, Read, Eq, Ord, Functor)
3137
3238instance (Ord k, Eq a, Monoid a) => Semigroup (Selector k a) where
@@ -40,7 +46,7 @@ instance (Ord k, Eq a, Monoid a) => Semigroup (Selector k a) where
4046 in if z == mempty then Nothing else Just z
4147
4248instance (Ord k, Eq a, Monoid a) => Monoid (Selector k a) where
43− mempty = Selector Map.empty
49+ mempty = Selector AMap.empty
4450 mappend = (<>)
4551
4652instance (Eq a, Ord k, Group a) => Group (Selector k a) where
@@ -50,25 +56,85 @@ instance (Eq a, Ord k, Group a) => Additive (Selector k a)
5056
5157main :: IO ()
5258main = do
53− [0, 1, 1, 0] <- fmap (map fst . concat) $ runApp app () $ map (Just . That) $
54− [ That ()
55− , This ()
56− , That ()
57− ]
59+ [0, 1, 1, 0] <- fmap (map fst . concat) $
60+ runApp (testQueryT testRunWithReplace) () $ map (Just . That) $
61+ [ That (), This (), That () ]
62+ [0, 1, 1, 0] <- fmap (map fst . concat) $
63+ runApp (testQueryT testSequenceDMapWithAdjust) () $ map (Just . That) $
64+ [ That (), This (), That () ]
65+ [0, 1, 1, 0] <- fmap (map fst . concat) $
66+ runApp (testQueryT testSequenceDMapWithAdjustWithMove) () $ map (Just . That) $
67+ [ That (), This (), That () ]
5868 return ()
5969
60−app :: (Reflex t, MonadHold t m, MonadAdjust t m, MonadFix m)
61− => AppIn t () (These () ())
62− -> m (AppOut t Int Int)
63−app (AppIn _ pulse) = do
70+testQueryT :: (Reflex t, MonadFix m)
71+ => (Event t () -> Event t () -> QueryT t (Selector Int MyQuery) m ())
72+ -> AppIn t () (These () ())
73+ -> m (AppOut t Int Int)
74+testQueryT w (AppIn _ pulse) = do
6475 let replace = fmapMaybe (^? here) pulse
6576 increment = fmapMaybe (^? there) pulse
66− w = do
67− n <- count increment
68− queryDyn $ zipDynWith (\x y -> Selector (Map.singleton (x :: Int) y)) n $ pure $ MyQuery $ SelectedCount 1
69− (_, q) <- runQueryT (runWithReplace w $ w <$ replace) $ pure mempty
70− let qDyn = fmap (head . Map.keys . unSelector) $ incrementalToDynamic q
77+ (_, q) <- runQueryT (w replace increment) $ pure mempty
78+ let qDyn = head . AMap.keys . unSelector <$> incrementalToDynamic q
7179 return $ AppOut
7280 { _appOut_behavior = current qDyn
7381 , _appOut_event = updated qDyn
7482 }
83+
84+testRunWithReplace :: ( Reflex t
85+ , MonadAdjust t m
86+ , MonadHold t m
87+ , MonadFix m
88+ , MonadQuery t (Selector Int MyQuery) m)
89+ => Event t ()
90+ -> Event t ()
91+ -> m ()
92+testRunWithReplace replace increment = do
93+ let w = do
94+ n <- count increment
95+ queryDyn $ zipDynWith (\x y -> Selector (AMap.singleton (x :: Int) y)) n $ pure $ MyQuery $ SelectedCount 1
96+ _ <- runWithReplace w $ w <$ replace
97+ return ()
98+
99+testSequenceDMapWithAdjust :: ( Reflex t
100+ , MonadAdjust t m
101+ , MonadHold t m
102+ , MonadFix m
103+ , MonadQuery t (Selector Int MyQuery) m)
104+ => Event t ()
105+ -> Event t ()
106+ -> m ()
107+testSequenceDMapWithAdjust replace increment = do
108+ _ <- listHoldWithKey (Map.singleton () ()) (Map.singleton () (Just ()) <$ replace) $ \_ _ -> do
109+ n <- count increment
110+ queryDyn $ zipDynWith (\x y -> Selector (AMap.singleton (x :: Int) y)) n $ pure $ MyQuery $ SelectedCount 1
111+ return ()
112+
113+testSequenceDMapWithAdjustWithMove :: ( Reflex t
114+ , MonadAdjust t m
115+ , MonadHold t m
116+ , MonadFix m
117+ , MonadQuery t (Selector Int MyQuery) m)
118+ => Event t ()
119+ -> Event t ()
120+ -> m ()
121+testSequenceDMapWithAdjustWithMove replace increment = do
122+ _ <- listHoldWithKeyWithMove (Map.singleton () ()) (Map.singleton () (Just ()) <$ replace) $ \_ _ -> do
123+ n <- count increment
124+ queryDyn $ zipDynWith (\x y -> Selector (AMap.singleton (x :: Int) y)) n $ pure $ MyQuery $ SelectedCount 1
125+ return ()
126+
127+listHoldWithKey :: forall t m k v a. (Ord k, MonadHold t m, MonadAdjust t m) => Map k v -> Event t (Map k (Maybe v)) -> (k -> v -> m a) -> m (Dynamic t (Map k a))
128+listHoldWithKey m0 m' f = do
129+ let dm0 = mapWithFunctorToDMap $ Map.mapWithKey f m0
130+ dm' = fmap (PatchDMap . mapWithFunctorToDMap . Map.mapWithKey (\k v -> ComposeMaybe $ fmap (f k) v)) m'
131+ (a0, a') <- sequenceDMapWithAdjust dm0 dm'
132+ fmap dmapToMap . incrementalToDynamic <$> holdIncremental a0 a'
133+
134+
135+-- scam it out to test traverseDMapWithAdjustWithMove
136+listHoldWithKeyWithMove :: forall t m k v a. (Ord k, MonadHold t m, MonadAdjust t m) => Map k v -> Event t (Map k (Maybe v)) -> (k -> v -> m a) -> m (Dynamic t (Map k a))
137+listHoldWithKeyWithMove m0 m' f = do
138+ (n0, n') <- mapMapWithAdjustWithMove f m0 $ ffor m' $ PatchMapWithMove . Map.map (\v -> NodeInfo (maybe From_Delete From_Insert v) Nothing)
139+ incrementalToDynamic <$> holdIncremental n0 n'
140+-- -}
test/RequesterT.hs+43−40
@@ -1,62 +1,65 @@
11{-# LANGUAGE FlexibleContexts, GADTs, RankNTypes, ScopedTypeVariables #-}
22module Main where
33
4+import Control.Lens
45import Control.Monad
5−import Control.Monad.IO.Class
6−import Control.Monad.Ref
76import qualified Data.Dependent.Map as DMap
87import Data.Dependent.Sum
9−import Data.IORef
10−import Data.List
11−import Data.Functor.Identity
8+import Data.These
129
1310import Reflex
14−import Reflex.Host.Class
15−import Reflex.PerformEvent.Base
1611import Reflex.Requester.Base
1712import Reflex.Requester.Class
1813import Test.Run
1914
20−import System.Exit (exitFailure, exitSuccess)
21−
2215data RequestInt a where
2316 RequestInt :: Int -> RequestInt Int
2417
2518main :: IO ()
2619main = do
20+ os1@[[Just [10,9,8,7,6,5,4,3,2,1]]] <- runApp' (unwrapApp testOrdering) $
21+ [ Just ()
22+ ]
23+ print os1
24+ os2@[[Just [1,3,5,7,9]],[Nothing,Nothing],[Just [2,4,6,8,10]],[Just [2,4,6,8,10],Nothing]]
25+ <- runApp' (unwrapApp testSimultaneous) $ map Just $
26+ [ This ()
27+ , That ()
28+ , This ()
29+ , These () ()
30+ ]
31+ print os2
2732 return ()
2833
29−{-
30−
31−main :: IO ()
32−main = do
33− (Just out1, Nothing) <- runApp $ unwrapApp app1
34− print out1
35− (Just out2, Just (out3, out4)) <- runApp $ unwrapApp app2
36− print out2
37− print out3
38− print out4
39− when (sort out1 /= out1 || map (+1) out2 /= out3 || out3 /= out4) exitFailure
40−
4134unwrapRequest :: DSum tag RequestInt -> Int
4235unwrapRequest (_ :=> RequestInt i) = i
4336
44−unwrapApp :: forall x t a response. (Reflex t, ReflexHost t)
45− => (x -> RequesterT t RequestInt response (PerformEventT t (SpiderHost Global)) a)
46− -> x -> PerformEventT t (SpiderHost Global) (a, Event t [Int])
47−unwrapApp x e = do
48− (a, b) <- runRequesterT (x e) never
49− return (a, fmap (map unwrapRequest . DMap.toList) b)
50−
51−app1 :: (Reflex t, Ref m ~ IORef, Requester t m, Response m ~ Identity, Request m ~ RequestInt) => Event t () -> m (Maybe (Ref m (Maybe (EventTrigger t ()))))
52−app1 e = do
53− forM_ [1..10] $ \i -> requestingIdentity (RequestInt i <$ e)
54− return Nothing
55−
56−app2 :: (Reflex t, Ref m ~ IORef, Requester t m, Response m ~ Identity, Request m ~ RequestInt, MonadAdjust t m, MonadReflexCreateTrigger t m, MonadRef m) => Event t () -> m (Maybe (Ref m (Maybe (EventTrigger t ()))))
57−app2 e = do
58− (pulse, pulseTriggerRef) <- newEventWithTriggerRef
59− forM_ [1,3..9] $ \i -> runWithReplace (requestingIdentity (RequestInt i <$ e)) $ ffor pulse $ \_ -> requestingIdentity (RequestInt (i+1) <$ e)
60− return (Just pulseTriggerRef)
61−
62−-}
37+unwrapApp :: ( Reflex t, Monad m )
38+ => (a -> RequesterT t RequestInt Identity m ())
39+ -> a
40+ -> m (Event t [Int])
41+unwrapApp x appIn = do
42+ ((), e) <- runRequesterT (x appIn) never
43+ return $ fmap (map unwrapRequest . DMap.toList) e
44+
45+testOrdering :: ( Response m ~ Identity
46+ , Request m ~ RequestInt
47+ , Requester t m
48+ , MonadAdjust t m)
49+ => Event t ()
50+ -> m ()
51+testOrdering pulse = do
52+ forM_ [10,9..1] $ \i -> requestingIdentity (RequestInt i <$ pulse)
53+ return ()
54+
55+testSimultaneous :: ( Response m ~ Identity
56+ , Request m ~ RequestInt
57+ , Requester t m
58+ , MonadAdjust t m)
59+ => Event t (These () ())
60+ -> m ()
61+testSimultaneous pulse = do
62+ let tellE = fmapMaybe (^? here) pulse
63+ switchE = fmapMaybe (^? there) pulse
64+ forM_ [1,3..9] $ \i -> runWithReplace (requestingIdentity (RequestInt i <$ tellE)) $ ffor switchE $ \_ ->
65+ requestingIdentity (RequestInt (i+1) <$ tellE)