18 import Control.Arrow.ArrowIO
19 import Control.Concurrent.STM
21 import Control.Monad.Trans
24 import Rakka.Storage.Impl
25 import Rakka.Storage.Types
26 import Subversion.Types
28 import Subversion.Repository
29 import Text.HyperEstraier hiding (WriteLock)
32 mkStorage :: FilePath -> Repository -> (Page -> IO Document) -> IO Storage
33 mkStorage lsdir repos mkDraft
34 = do chan <- startIndexManager lsdir repos mkDraft
43 getPage :: MonadIO m => Storage -> PageName -> Maybe RevNum -> m (Maybe Page)
44 getPage = ((liftIO .) .) . getPage' . stoRepository
47 putPage :: MonadIO m => Storage -> Page -> RevNum -> m ()
48 putPage _sto _page _oldRev
49 = error "FIXME: not implemented"
52 getPageA :: ArrowIO a => Storage -> a (PageName, Maybe RevNum) (Maybe Page)
53 getPageA = arrIO2 . getPage
56 putPageA :: ArrowIO a => Storage -> a (Page, RevNum) ()
57 putPageA = arrIO2 . putPage
60 searchPages :: MonadIO m => Storage -> Condition -> m [(PageName, RevNum)]
63 do var <- newEmptyTMVarIO
64 atomically $ writeTChan (stoIndexChan sto) (SearchIndex cond var)
65 atomically $ takeTMVar var
68 rebuildIndex :: MonadIO m => Storage -> m ()
70 = liftIO $ atomically $ writeTChan (stoIndexChan sto) RebuildIndex
73 syncIndex :: Storage -> IO ()
75 = atomically $ writeTChan (stoIndexChan sto) SyncIndex