module Shaker.Listener(
listen
,initializeListener
,schedule
,updateFileStat
,ListenState(..)
)
where
import Control.Monad
import Control.Monad.Reader
import Control.Concurrent.MVar
import Control.Concurrent
import Shaker.Type
import Shaker.Io
type CurrentFiles = MVar [FileInfo]
type MvModifiedFiles = MVar [FileInfo]
type Job = MVar [FileListenInfo]
data ListenState = ListenState {
currentFiles :: CurrentFiles
,mvModifiedFiles :: MvModifiedFiles
,threadIds :: [ThreadId]
}
initializeListener :: Shaker IO ListenState
initializeListener =do
lstInput <- asks listenerInput
lift $ initialize lstInput
initialize :: ListenerInput -> IO ListenState
initialize lstInput = do
mC <- newMVar []
mM <- newEmptyMVar
mJ <- newEmptyMVar
idLst <- forkIO $ forever $ listen mC mM mJ
idSch <- forkIO $ forever $ schedule lstInput mJ
return $ ListenState mC mM [idLst,idSch]
schedule :: ListenerInput -> Job -> IO()
schedule lstInput mJ = do
putMVar mJ $ fileListenInfo lstInput
threadDelay $ delay lstInput
return ()
listen :: CurrentFiles -> MvModifiedFiles -> Job -> IO ()
listen mC mM mJ = do
job <- takeMVar mJ
curFiles <- readMVar mC
(newFiles,modFiles) <- listModifiedAndCreatedFiles job curFiles
updateFileStat mC mM newFiles modFiles
return ()
updateFileStat :: CurrentFiles -> MvModifiedFiles -> [FileInfo] -> [FileInfo] -> IO ()
updateFileStat _ _ _ [] = return ()
updateFileStat mC mM curFiles curMod = do
_ <- swapMVar mC curFiles
_ <- tryPutMVar mM curMod
return()