Commit 2ae4e4f83a9c804c441386bf673e8677445dc7f1 - Robin

Language.Robin.Facilities module, rename type FacilityHandler. Chris Pressey 5 years ago

4 changed file(s) with 18 addition(s) and 12 deletion(s). Raw diff Collapse all Expand all

-9

src/Language/Robin/EventLoop.hs less more

6	6	import Language.Robin.Expr
7	7	import Language.Robin.Eval
8	8	import Language.Robin.Reactor
	9	import Language.Robin.Facilities
9	10
10	11
11		type Facility = Expr -> IO [Expr]
12		type WaitForEvents = IO (Either String [Expr])
13
14
15		eventLoop :: Bool -> [Facility] -> WaitForEvents -> [Reactor] -> IO ()
	12	eventLoop :: Bool -> [FacilityHandler] -> WaitForEvents -> [Reactor] -> IO ()
16	13	eventLoop showEvents facilities waitForEvents reactors = do
17	14	let (reactors', events') = updateMany reactors (List [(Symbol "init"), (Number 0)])
18	15	e reactors' events'

30	27	e reactors (event@(List [eventType, eventPayload]):events) = do
31	28	-- An event on the queue. Allow all facilities and reactors to handle it.
32	29	showEvent event
33		newFacilityEvents <- runFacilityHandlers facilities event []
	30	newFacilityEvents <- runFacilityHandlers facilities event
34	31	let (reactors', newReactorEvents) = updateMany reactors event
35	32	e reactors' (events ++ newFacilityEvents ++ newReactorEvents)
36	33

46	43	Left err -> return ()
47	44	Right events -> e reactors events
48	45
49		runFacilityHandlers [] event acc = return acc
50		runFacilityHandlers (handler:handlers) event acc = do
	46	runFacilityHandlers [] event = return []
	47	runFacilityHandlers (handler:handlers) event = do
51	48	newEvents <- handler event
52		runFacilityHandlers handlers event (acc ++ newEvents)
	49	rest <- runFacilityHandlers handlers event
	50	return $ newEvents ++ rest
53	51
54	52	showEvent event = case showEvents of
55	53	True -> hPutStrLn stderr ("*** " ++ show event)

-2

src/Language/Robin/Facilities/LineTerminal.hs less more

3	3	import System.IO
4	4
5	5	import Language.Robin.Expr
	6	import Language.Robin.Facilities
6	7
7		type WaitForEvents = IO (Either String [Expr])
8	8
9	9	waitForLineTerminalEvent :: WaitForEvents
10	10	waitForLineTerminalEvent = do

20	20	True -> return $ Left "stop"
21	21	False -> return $ Left "stop"
22	22
23		handleLineTerminalEvent :: Expr -> IO [Expr]
	23
	24	handleLineTerminalEvent :: FacilityHandler
24	25	handleLineTerminalEvent (List [Symbol "write", payload]) = do
25	26	let List l = payload
26	27	let s = map (\(Number x) -> Char.chr $ fromIntegral $ x) l

-1

src/Language/Robin/Facilities/RandomSource.hs less more

2	2	import System.Random
3	3
4	4	import Language.Robin.Expr
	5	import Language.Robin.Facilities
5	6
6	7
7		handleRandomSourceEvent :: Expr -> IO [Expr]
	8	handleRandomSourceEvent :: FacilityHandler
8	9	handleRandomSourceEvent (List [Symbol "obtain-random-u16", payload]) = do
9	10	v <- randomRIO (0, 65535)
10	11	return $ [List [Symbol "random-u16", Number v]]

-0

src/Language/Robin/Facilities.hs less more

	0	module Language.Robin.Facilities where
	1
	2	import Language.Robin.Expr
	3
	4	type FacilityHandler = Expr -> IO [Expr]
	5	type WaitForEvents = IO (Either String [Expr])