module Database.CouchDB.Conduit.DB (
couchPutDB,
couchPutDB_,
couchDeleteDB,
couchSecureDB,
couchReplicateDB
) where
import Control.Monad (void)
import qualified Data.ByteString as B
import qualified Data.Aeson as A
import Data.Conduit (ResourceT)
import qualified Network.HTTP.Conduit as H
import qualified Network.HTTP.Types as HT
import Database.CouchDB.Conduit.Internal.Connection
(MonadCouch(..), Path, mkPath)
import Database.CouchDB.Conduit.LowLevel (couch, protect, protect')
couchPutDB :: MonadCouch m =>
Path
-> ResourceT m ()
couchPutDB db = void $ couch HT.methodPut
(mkPath [db]) [] []
(H.RequestBodyBS B.empty)
protect'
couchPutDB_ :: MonadCouch m =>
Path
-> ResourceT m ()
couchPutDB_ db = void $ couch HT.methodPut
(mkPath [db]) [] []
(H.RequestBodyBS B.empty)
(protect [200, 201, 202, 304, 412] return)
couchDeleteDB :: MonadCouch m =>
Path
-> ResourceT m ()
couchDeleteDB db = void $ couch HT.methodDelete
(mkPath [db]) [] []
(H.RequestBodyBS B.empty) protect'
couchSecureDB :: MonadCouch m =>
Path
-> [B.ByteString]
-> [B.ByteString]
-> [B.ByteString]
-> [B.ByteString]
-> ResourceT m ()
couchSecureDB db adminRoles adminNames readersRoles readersNames =
void $ couch HT.methodPut
(mkPath [db, "_security"]) [] []
reqBody protect'
where
reqBody = H.RequestBodyLBS $ A.encode $ A.object [
"admins" A..= A.object [ "roles" A..= adminRoles,
"names" A..= adminNames ],
"readers" A..= A.object [ "roles" A..= readersRoles,
"names" A..= readersNames ] ]
couchReplicateDB :: MonadCouch m =>
B.ByteString
-> B.ByteString
-> Bool
-> Bool
-> Bool
-> ResourceT m ()
couchReplicateDB source target createTarget continuous cancel =
void $ couch HT.methodPost "_replicate" [] []
reqBody protect'
where
reqBody = H.RequestBodyLBS $ A.encode $ A.object [
"source" A..= source,
"target" A..= target,
"create_target" A..= createTarget,
"continuous" A..= continuous,
"cancel" A..= cancel ]