{-# LANGUAGE AllowAmbiguousTypes #-}
{-# LANGUAGE BangPatterns #-}
{-# LANGUAGE DataKinds #-}
{-# LANGUAGE FlexibleContexts #-}
{-# LANGUAGE LambdaCase #-}
{-# LANGUAGE RecordWildCards #-}
{-# LANGUAGE ScopedTypeVariables #-}
{-# LANGUAGE TypeApplications #-}
module Network.DO.Spaces
( runSpaces
, newSpaces
, uploadObject
, multipartObject
, uploadFile
, getObject
, getObjectSinkFile
, getObjectInfo
, copyObject
, copyObjectWithin
, overwriteObject
, deleteObject
, getObjectACLs
, setObjectACLs
, createBucket
, deleteBucket
, getBucketLocation
, listAllBuckets
, listBucket
, listBucketGrouped
, listBucketRec
, getBucketCORS
, deleteBucketCORS
, setBucketCORS
, getBucketACLs
, setBucketACLs
, getBucketLifecycleRules
, setBucketLifecycleRules
, deleteBucketLifecycleRules
, Spaces
, SpacesResponse
, SpacesMetadata
, MonadSpaces
, Bucket
, mkBucket
, Object
, mkObject
, Region(..)
, AccessKey(..)
, SecretKey(..)
, CredentialSource(..)
, Profile
, CORSRule
, mkCORSRule
, Grant
, Grantee(..)
, Permission(..)
, LifecycleID
, mkLifecycleID
, SpacesException
, ClientException(..)
, APIException
) where
import Conduit
import Control.Monad ( void )
import Control.Monad.Catch ( MonadCatch(catch) )
import Data.Bool ( bool )
import qualified Data.ByteString.Char8 as C
import qualified Data.ByteString.Lazy as LB
import Data.Coerce ( coerce )
import Data.Conduit.Binary ( sinkLbs )
import Data.Conduit.List ( consume )
import Data.Foldable ( asum )
import Data.Generics.Product ( HasField(field) )
import qualified Data.Ini.Config as I
import Data.Maybe ( fromMaybe )
import Data.Sequence ( Seq )
import qualified Data.Text as T
import Data.Text ( Text )
import qualified Data.Text.Lazy as LT
import Lens.Micro ( (<&>), (^.) )
import Network.DO.Spaces.Actions
import Network.DO.Spaces.Types
import Network.DO.Spaces.Utils
import Network.HTTP.Client.Conduit ( RequestBody(RequestBodyLBS) )
import Network.HTTP.Client.TLS ( getGlobalManager )
import Network.Mime
( MimeType
, defaultMimeMap
, defaultMimeType
, mimeByExt
)
import qualified System.FilePath as F
import UnliftIO.Directory
import UnliftIO.Environment
runSpaces :: Spaces -> SpacesT m a -> m a
runSpaces :: Spaces -> SpacesT m a -> m a
runSpaces = (SpacesT m a -> Spaces -> m a) -> Spaces -> SpacesT m a -> m a
forall a b c. (a -> b -> c) -> b -> a -> c
flip SpacesT m a -> Spaces -> m a
forall (m :: * -> *) a. SpacesT m a -> Spaces -> m a
runSpacesT
newSpaces :: (MonadThrow m, MonadIO m) => CredentialSource -> m Spaces
newSpaces :: CredentialSource -> m Spaces
newSpaces CredentialSource
cs = do
Manager
manager <- IO Manager -> m Manager
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO IO Manager
getGlobalManager
(Region
region, AccessKey
accessKey, SecretKey
secretKey) <- IO (Region, AccessKey, SecretKey)
-> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO (Region, AccessKey, SecretKey)
-> m (Region, AccessKey, SecretKey))
-> IO (Region, AccessKey, SecretKey)
-> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ CredentialSource -> IO (Region, AccessKey, SecretKey)
forall (m :: * -> *).
(MonadIO m, MonadCatch m) =>
CredentialSource -> m (Region, AccessKey, SecretKey)
source CredentialSource
cs
Spaces -> m Spaces
forall (f :: * -> *) a. Applicative f => a -> f a
pure Spaces :: AccessKey -> SecretKey -> Region -> Manager -> Spaces
Spaces { Manager
SecretKey
AccessKey
Region
$sel:manager:Spaces :: Manager
$sel:region:Spaces :: Region
$sel:secretKey:Spaces :: SecretKey
$sel:accessKey:Spaces :: AccessKey
secretKey :: SecretKey
accessKey :: AccessKey
region :: Region
manager :: Manager
.. }
source :: (MonadIO m, MonadCatch m)
=> CredentialSource
-> m (Region, AccessKey, SecretKey)
source :: CredentialSource -> m (Region, AccessKey, SecretKey)
source = \case
CredentialSource
Discover -> m (Region, AccessKey, SecretKey)
-> (ClientException -> m (Region, AccessKey, SecretKey))
-> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) e a.
(MonadCatch m, Exception e) =>
m a -> (e -> m a) -> m a
catch @_ @ClientException m (Region, AccessKey, SecretKey)
tryFile ((ClientException -> m (Region, AccessKey, SecretKey))
-> m (Region, AccessKey, SecretKey))
-> (ClientException -> m (Region, AccessKey, SecretKey))
-> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ m (Region, AccessKey, SecretKey)
-> ClientException -> m (Region, AccessKey, SecretKey)
forall a b. a -> b -> a
const m (Region, AccessKey, SecretKey)
tryEnv
where
tryFile :: m (Region, AccessKey, SecretKey)
tryFile = do
FilePath
cfgDir <- XdgDirectory -> FilePath -> m FilePath
forall (m :: * -> *).
MonadIO m =>
XdgDirectory -> FilePath -> m FilePath
getXdgDirectory XdgDirectory
XdgConfig FilePath
"do-spaces"
[FilePath] -> FilePath -> m (Maybe FilePath)
forall (m :: * -> *).
MonadIO m =>
[FilePath] -> FilePath -> m (Maybe FilePath)
findFile [ FilePath
".aws", FilePath
cfgDir ] FilePath
"credentials" m (Maybe FilePath)
-> (Maybe FilePath -> m (Region, AccessKey, SecretKey))
-> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) a b. Monad m => m a -> (a -> m b) -> m b
>>= \case
Maybe FilePath
Nothing ->
ClientException -> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) e a. (MonadThrow m, Exception e) => e -> m a
throwM (ClientException -> m (Region, AccessKey, SecretKey))
-> ClientException -> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ Text -> ClientException
ConfigurationError Text
"No credentials file found"
Just FilePath
fp -> CredentialSource -> m (Region, AccessKey, SecretKey)
forall (m :: * -> *).
(MonadIO m, MonadCatch m) =>
CredentialSource -> m (Region, AccessKey, SecretKey)
source (CredentialSource -> m (Region, AccessKey, SecretKey))
-> CredentialSource -> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ FilePath -> Maybe Text -> CredentialSource
FromFile FilePath
fp Maybe Text
forall a. Maybe a
Nothing
tryEnv :: m (Region, AccessKey, SecretKey)
tryEnv = CredentialSource -> m (Region, AccessKey, SecretKey)
forall (m :: * -> *).
(MonadIO m, MonadCatch m) =>
CredentialSource -> m (Region, AccessKey, SecretKey)
source (CredentialSource -> m (Region, AccessKey, SecretKey))
-> CredentialSource -> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ Maybe (Text, Text, Text) -> CredentialSource
FromEnv Maybe (Text, Text, Text)
forall a. Maybe a
Nothing
Explicit Region
region AccessKey
ak SecretKey
sk -> (Region, AccessKey, SecretKey) -> m (Region, AccessKey, SecretKey)
forall (f :: * -> *) a. Applicative f => a -> f a
pure (Region
region, AccessKey
ak, SecretKey
sk)
FromEnv (Just (Text
region, Text
a, Text
s)) -> (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
ensureVars
((Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey))
-> m (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) a b. Monad m => (a -> m b) -> m a -> m b
=<< (,,) (Maybe FilePath
-> Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> m (Maybe FilePath)
-> m (Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> Text -> m (Maybe FilePath)
lookupVar Text
region m (Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> m (Maybe FilePath)
-> m (Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
forall (f :: * -> *) a b. Applicative f => f (a -> b) -> f a -> f b
<*> Text -> m (Maybe FilePath)
lookupVar Text
a m (Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> m (Maybe FilePath)
-> m (Maybe FilePath, Maybe FilePath, Maybe FilePath)
forall (f :: * -> *) a b. Applicative f => f (a -> b) -> f a -> f b
<*> Text -> m (Maybe FilePath)
lookupVar Text
s
FromEnv Maybe (Text, Text, Text)
Nothing -> do
Maybe FilePath
region <- [FilePath] -> m (Maybe FilePath)
forall (t :: * -> *) (f :: * -> *).
(Traversable t, MonadIO f) =>
t FilePath -> f (Maybe FilePath)
lookupVars [ FilePath
"AWS_DEFAULT_REGION", FilePath
"SPACES_DEFAULT_REGION" ]
Maybe FilePath
ak <- [FilePath] -> m (Maybe FilePath)
forall (t :: * -> *) (f :: * -> *).
(Traversable t, MonadIO f) =>
t FilePath -> f (Maybe FilePath)
lookupVars [ FilePath
"AWS_ACCESS_KEY_ID"
, FilePath
"SPACES_ACCESS_KEY_ID"
, FilePath
"SPACES_ACCESS_KEY"
]
Maybe FilePath
sk <- [FilePath] -> m (Maybe FilePath)
forall (t :: * -> *) (f :: * -> *).
(Traversable t, MonadIO f) =>
t FilePath -> f (Maybe FilePath)
lookupVars [ FilePath
"AWS_SECRET_ACCESS_KEY"
, FilePath
"SPACES_SECRET_ACCESS_KEY"
, FilePath
"SPACES_SECRET_KEY"
]
(Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
ensureVars (Maybe FilePath
region, Maybe FilePath
ak, Maybe FilePath
sk)
FromFile FilePath
fp Maybe Text
profile -> do
Text
contents <- Text -> Text
LT.toStrict
(Text -> Text) -> m Text -> m Text
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> IO Text -> m Text
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (ConduitT () Void (ResourceT IO) Text -> IO Text
forall (m :: * -> *) r.
MonadUnliftIO m =>
ConduitT () Void (ResourceT m) r -> m r
runConduitRes (FilePath -> ConduitT () ByteString (ResourceT IO) ()
forall (m :: * -> *) i.
MonadResource m =>
FilePath -> ConduitT i ByteString m ()
sourceFile FilePath
fp
ConduitT () ByteString (ResourceT IO) ()
-> ConduitM ByteString Void (ResourceT IO) Text
-> ConduitT () Void (ResourceT IO) Text
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| ConduitT ByteString Text (ResourceT IO) ()
forall (m :: * -> *). MonadThrow m => ConduitT ByteString Text m ()
decodeUtf8C
ConduitT ByteString Text (ResourceT IO) ()
-> ConduitM Text Void (ResourceT IO) Text
-> ConduitM ByteString Void (ResourceT IO) Text
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| ConduitM Text Void (ResourceT IO) Text
forall (m :: * -> *) lazy strict o.
(Monad m, LazySequence lazy strict) =>
ConduitT strict o m lazy
sinkLazy))
(FilePath -> m (Region, AccessKey, SecretKey))
-> ((Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey))
-> Either FilePath (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
forall a c b. (a -> c) -> (b -> c) -> Either a b -> c
either (ClientException -> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) e a. (MonadThrow m, Exception e) => e -> m a
throwM (ClientException -> m (Region, AccessKey, SecretKey))
-> (FilePath -> ClientException)
-> FilePath
-> m (Region, AccessKey, SecretKey)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Text -> ClientException
ConfigurationError (Text -> ClientException)
-> (FilePath -> Text) -> FilePath -> ClientException
forall b c a. (b -> c) -> (a -> b) -> a -> c
. FilePath -> Text
T.pack) (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
ensureVars
(Either FilePath (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey))
-> Either FilePath (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ Text
-> IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> Either FilePath (Maybe FilePath, Maybe FilePath, Maybe FilePath)
forall a. Text -> IniParser a -> Either FilePath a
I.parseIniFile Text
contents IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
parseConf
where
parseConf :: IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
parseConf = Text
-> SectionParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
forall a. Text -> SectionParser a -> IniParser a
I.section (Text -> Maybe Text -> Text
forall a. a -> Maybe a -> a
fromMaybe Text
"default" Maybe Text
profile)
(SectionParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> SectionParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> IniParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
forall a b. (a -> b) -> a -> b
$ (,,)
(Maybe FilePath
-> Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> SectionParser (Maybe FilePath)
-> SectionParser
(Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> ((Text -> FilePath) -> Maybe Text -> Maybe FilePath
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
fmap (Text -> FilePath
T.unpack (Text -> FilePath) -> (Text -> Text) -> Text -> FilePath
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Text -> Text
T.toLower)
(Maybe Text -> Maybe FilePath)
-> SectionParser (Maybe Text) -> SectionParser (Maybe FilePath)
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> Text -> SectionParser (Maybe Text)
I.fieldMb Text
"aws_default_region")
SectionParser
(Maybe FilePath
-> Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> SectionParser (Maybe FilePath)
-> SectionParser
(Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
forall (f :: * -> *) a b. Applicative f => f (a -> b) -> f a -> f b
<*> ((Text -> FilePath) -> Maybe Text -> Maybe FilePath
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
fmap Text -> FilePath
T.unpack (Maybe Text -> Maybe FilePath)
-> SectionParser (Maybe Text) -> SectionParser (Maybe FilePath)
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> Text -> SectionParser (Maybe Text)
I.fieldMb Text
"aws_access_key_id")
SectionParser
(Maybe FilePath
-> (Maybe FilePath, Maybe FilePath, Maybe FilePath))
-> SectionParser (Maybe FilePath)
-> SectionParser (Maybe FilePath, Maybe FilePath, Maybe FilePath)
forall (f :: * -> *) a b. Applicative f => f (a -> b) -> f a -> f b
<*> ((Text -> FilePath) -> Maybe Text -> Maybe FilePath
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
fmap Text -> FilePath
T.unpack (Maybe Text -> Maybe FilePath)
-> SectionParser (Maybe Text) -> SectionParser (Maybe FilePath)
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> Text -> SectionParser (Maybe Text)
I.fieldMb Text
"aws_secret_access_key")
where
lookupVars :: t FilePath -> f (Maybe FilePath)
lookupVars t FilePath
xs = t (Maybe FilePath) -> Maybe FilePath
forall (t :: * -> *) (f :: * -> *) a.
(Foldable t, Alternative f) =>
t (f a) -> f a
asum (t (Maybe FilePath) -> Maybe FilePath)
-> f (t (Maybe FilePath)) -> f (Maybe FilePath)
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> t (f (Maybe FilePath)) -> f (t (Maybe FilePath))
forall (t :: * -> *) (m :: * -> *) a.
(Traversable t, Monad m) =>
t (m a) -> m (t a)
sequence (FilePath -> f (Maybe FilePath)
forall (m :: * -> *). MonadIO m => FilePath -> m (Maybe FilePath)
lookupEnv (FilePath -> f (Maybe FilePath))
-> t FilePath -> t (f (Maybe FilePath))
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> t FilePath
xs)
lookupVar :: Text -> m (Maybe FilePath)
lookupVar = FilePath -> m (Maybe FilePath)
forall (m :: * -> *). MonadIO m => FilePath -> m (Maybe FilePath)
lookupEnv (FilePath -> m (Maybe FilePath))
-> (Text -> FilePath) -> Text -> m (Maybe FilePath)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Text -> FilePath
T.unpack
ensureVars :: (Maybe FilePath, Maybe FilePath, Maybe FilePath)
-> m (Region, AccessKey, SecretKey)
ensureVars = \case
(Just FilePath
r, Just FilePath
a, Just FilePath
s) -> do
Region
reg <- FilePath -> m Region
forall (m :: * -> *) a.
(MonadThrow m, IsString a, Eq a) =>
a -> m Region
slugToRegion FilePath
r
(Region, AccessKey, SecretKey) -> m (Region, AccessKey, SecretKey)
forall (f :: * -> *) a. Applicative f => a -> f a
pure (Region
reg, ByteString -> AccessKey
coerce (ByteString -> AccessKey) -> ByteString -> AccessKey
forall a b. (a -> b) -> a -> b
$ FilePath -> ByteString
C.pack FilePath
a, ByteString -> SecretKey
coerce (ByteString -> SecretKey) -> ByteString -> SecretKey
forall a b. (a -> b) -> a -> b
$ FilePath -> ByteString
C.pack FilePath
s)
(Maybe FilePath
_, Maybe FilePath
_, Maybe FilePath
_) -> ClientException -> m (Region, AccessKey, SecretKey)
forall (m :: * -> *) e a. (MonadThrow m, Exception e) => e -> m a
throwM (ClientException -> m (Region, AccessKey, SecretKey))
-> (Text -> ClientException)
-> Text
-> m (Region, AccessKey, SecretKey)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Text -> ClientException
ConfigurationError
(Text -> m (Region, AccessKey, SecretKey))
-> Text -> m (Region, AccessKey, SecretKey)
forall a b. (a -> b) -> a -> b
$ Text
"Missing acces/secret keys and/or region"
uploadObject :: MonadSpaces m
=> Maybe MimeType
-> Bucket
-> Object
-> BodyBS m
-> m (SpacesResponse UploadObject)
uploadObject :: Maybe ByteString
-> Bucket -> Object -> BodyBS m -> m (SpacesResponse UploadObject)
uploadObject Maybe ByteString
contentType Bucket
bucket Object
object BodyBS m
rbody = do
RequestBody
body <- ByteString -> RequestBody
RequestBodyLBS (ByteString -> RequestBody) -> m ByteString -> m RequestBody
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
<$> ConduitT () Void m ByteString -> m ByteString
forall (m :: * -> *) r. Monad m => ConduitT () Void m r -> m r
runConduit (BodyBS m
rbody BodyBS m
-> ConduitM ByteString Void m ByteString
-> ConduitT () Void m ByteString
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| ConduitM ByteString Void m ByteString
forall (m :: * -> *) o.
Monad m =>
ConduitT ByteString o m ByteString
sinkLbs)
WithMetadata -> UploadObject -> m (SpacesResponse UploadObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata
UploadObject :: Bucket
-> Object
-> RequestBody
-> UploadHeaders
-> Maybe ByteString
-> UploadObject
UploadObject { $sel:optionalHeaders:UploadObject :: UploadHeaders
optionalHeaders = UploadHeaders
defaultUploadHeaders, Maybe ByteString
RequestBody
Object
Bucket
$sel:contentType:UploadObject :: Maybe ByteString
$sel:body:UploadObject :: RequestBody
$sel:object:UploadObject :: Object
$sel:bucket:UploadObject :: Bucket
body :: RequestBody
object :: Object
bucket :: Bucket
contentType :: Maybe ByteString
.. }
multipartObject
:: MonadSpaces m
=> Maybe MimeType
-> Bucket
-> Object
-> Int
-> BodyBS m
-> m (SpacesResponse CompleteMultipart)
multipartObject :: Maybe ByteString
-> Bucket
-> Object
-> Int
-> BodyBS m
-> m (SpacesResponse CompleteMultipart)
multipartObject Maybe ByteString
contentType Bucket
bucket Object
object Int
size BodyBS m
body
| Int
size Int -> Int -> Bool
forall a. Ord a => a -> a -> Bool
< Int
5242880 = ClientException -> m (SpacesResponse CompleteMultipart)
forall (m :: * -> *) e a. (MonadThrow m, Exception e) => e -> m a
throwM
(ClientException -> m (SpacesResponse CompleteMultipart))
-> ClientException -> m (SpacesResponse CompleteMultipart)
forall a b. (a -> b) -> a -> b
$ Text -> ClientException
InvalidRequest Text
"multipartObject: Chunk size must be greater than/equal to 5MB"
| Bool
otherwise = do
MultipartSession
session <- m (SpacesResponse BeginMultipart)
beginMultipart m (SpacesResponse BeginMultipart)
-> (SpacesResponse BeginMultipart -> MultipartSession)
-> m MultipartSession
forall (f :: * -> *) a b. Functor f => f a -> (a -> b) -> f b
<&> (SpacesResponse BeginMultipart
-> Getting
MultipartSession (SpacesResponse BeginMultipart) MultipartSession
-> MultipartSession
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "result" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"result" ((BeginMultipartResponse
-> Const MultipartSession BeginMultipartResponse)
-> SpacesResponse BeginMultipart
-> Const MultipartSession (SpacesResponse BeginMultipart))
-> ((MultipartSession -> Const MultipartSession MultipartSession)
-> BeginMultipartResponse
-> Const MultipartSession BeginMultipartResponse)
-> Getting
MultipartSession (SpacesResponse BeginMultipart) MultipartSession
forall b c a. (b -> c) -> (a -> b) -> a -> c
. forall s t a b. HasField "session" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"session")
m (SpacesResponse CompleteMultipart)
-> (SpacesException -> m (SpacesResponse CompleteMultipart))
-> m (SpacesResponse CompleteMultipart)
forall (m :: * -> *) e a.
(MonadCatch m, Exception e) =>
m a -> (e -> m a) -> m a
catch @_ @SpacesException (MultipartSession -> m (SpacesResponse CompleteMultipart)
run MultipartSession
session) ((SpacesException -> m (SpacesResponse CompleteMultipart))
-> m (SpacesResponse CompleteMultipart))
-> (SpacesException -> m (SpacesResponse CompleteMultipart))
-> m (SpacesResponse CompleteMultipart)
forall a b. (a -> b) -> a -> b
$ \SpacesException
e -> do
m (SpacesResponse CancelMultipart) -> m ()
forall (f :: * -> *) a. Functor f => f a -> f ()
void (m (SpacesResponse CancelMultipart) -> m ())
-> (CancelMultipart -> m (SpacesResponse CancelMultipart))
-> CancelMultipart
-> m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. WithMetadata
-> CancelMultipart -> m (SpacesResponse CancelMultipart)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
NoMetadata (CancelMultipart -> m ()) -> CancelMultipart -> m ()
forall a b. (a -> b) -> a -> b
$ MultipartSession -> CancelMultipart
CancelMultipart MultipartSession
session
SpacesException -> m (SpacesResponse CompleteMultipart)
forall (m :: * -> *) e a. (MonadThrow m, Exception e) => e -> m a
throwM SpacesException
e
where
run :: MultipartSession -> m (SpacesResponse CompleteMultipart)
run MultipartSession
session = MultipartSession -> [Text] -> m (SpacesResponse CompleteMultipart)
forall (m :: * -> *).
(MonadReader Spaces m, MonadUnliftIO m, MonadCatch m) =>
MultipartSession -> [Text] -> m (SpacesResponse CompleteMultipart)
completeMultipart MultipartSession
session
([Text] -> m (SpacesResponse CompleteMultipart))
-> m [Text] -> m (SpacesResponse CompleteMultipart)
forall (m :: * -> *) a b. Monad m => (a -> m b) -> m a -> m b
=<< ConduitT () Void m [Text] -> m [Text]
forall (m :: * -> *) r. Monad m => ConduitT () Void m r -> m r
runConduit (BodyBS m
body BodyBS m
-> ConduitM ByteString Void m [Text] -> ConduitT () Void m [Text]
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| ConduitT ByteString ByteString m ()
inChunks ConduitT ByteString ByteString m ()
-> ConduitM ByteString Void m [Text]
-> ConduitM ByteString Void m [Text]
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| MultipartSession -> ConduitT ByteString Text m ()
forall (m :: * -> *).
(MonadReader Spaces m, MonadUnliftIO m, MonadCatch m) =>
MultipartSession -> ConduitT ByteString Text m ()
putPart MultipartSession
session ConduitT ByteString Text m ()
-> ConduitM Text Void m [Text] -> ConduitM ByteString Void m [Text]
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| ConduitM Text Void m [Text]
forall (m :: * -> *) a o. Monad m => ConduitT a o m [a]
consume)
beginMultipart :: m (SpacesResponse BeginMultipart)
beginMultipart = WithMetadata -> BeginMultipart -> m (SpacesResponse BeginMultipart)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
NoMetadata
BeginMultipart :: Bucket
-> Object -> UploadHeaders -> Maybe ByteString -> BeginMultipart
BeginMultipart
{ $sel:optionalHeaders:BeginMultipart :: UploadHeaders
optionalHeaders = UploadHeaders
defaultUploadHeaders, Maybe ByteString
Object
Bucket
$sel:contentType:BeginMultipart :: Maybe ByteString
$sel:object:BeginMultipart :: Object
$sel:bucket:BeginMultipart :: Bucket
object :: Object
bucket :: Bucket
contentType :: Maybe ByteString
.. }
completeMultipart :: MultipartSession -> [Text] -> m (SpacesResponse CompleteMultipart)
completeMultipart MultipartSession
session [Text]
tags = WithMetadata
-> CompleteMultipart -> m (SpacesResponse CompleteMultipart)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata
(CompleteMultipart -> m (SpacesResponse CompleteMultipart))
-> CompleteMultipart -> m (SpacesResponse CompleteMultipart)
forall a b. (a -> b) -> a -> b
$ MultipartSession -> [(Int, Text)] -> CompleteMultipart
CompleteMultipart MultipartSession
session ([Int] -> [Text] -> [(Int, Text)]
forall a b. [a] -> [b] -> [(a, b)]
zip [ Int
1 .. ] [Text]
tags)
putPart :: MultipartSession -> ConduitT ByteString Text m ()
putPart MultipartSession
session = Int -> ConduitT ByteString Text m ()
forall (m :: * -> *).
(MonadReader Spaces m, MonadUnliftIO m, MonadCatch m) =>
Int -> ConduitT ByteString Text m ()
go Int
1
where
go :: Int -> ConduitT ByteString Text m ()
go !Int
n = (ByteString -> ConduitT ByteString Text m ())
-> ConduitT ByteString Text m ()
forall (m :: * -> *) i o r.
Monad m =>
(i -> ConduitT i o m r) -> ConduitT i o m ()
awaitForever ((ByteString -> ConduitT ByteString Text m ())
-> ConduitT ByteString Text m ())
-> (ByteString -> ConduitT ByteString Text m ())
-> ConduitT ByteString Text m ()
forall a b. (a -> b) -> a -> b
$ \ByteString
v -> do
let pieceBody :: RequestBody
pieceBody = ByteString -> RequestBody
RequestBodyLBS ByteString
v
uploadPart :: m (SpacesResponse UploadPart)
uploadPart =
WithMetadata -> UploadPart -> m (SpacesResponse UploadPart)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
NoMetadata (UploadPart -> m (SpacesResponse UploadPart))
-> UploadPart -> m (SpacesResponse UploadPart)
forall a b. (a -> b) -> a -> b
$ MultipartSession -> Int -> RequestBody -> UploadPart
UploadPart MultipartSession
session Int
n RequestBody
pieceBody
Text
etag <- m Text -> ConduitT ByteString Text m Text
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift (m Text -> ConduitT ByteString Text m Text)
-> m Text -> ConduitT ByteString Text m Text
forall a b. (a -> b) -> a -> b
$ m (SpacesResponse UploadPart)
uploadPart m (SpacesResponse UploadPart)
-> (SpacesResponse UploadPart -> Text) -> m Text
forall (f :: * -> *) a b. Functor f => f a -> (a -> b) -> f b
<&> (SpacesResponse UploadPart
-> Getting Text (SpacesResponse UploadPart) Text -> Text
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "result" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"result" ((UploadPartResponse -> Const Text UploadPartResponse)
-> SpacesResponse UploadPart
-> Const Text (SpacesResponse UploadPart))
-> ((Text -> Const Text Text)
-> UploadPartResponse -> Const Text UploadPartResponse)
-> Getting Text (SpacesResponse UploadPart) Text
forall b c a. (b -> c) -> (a -> b) -> a -> c
. forall s t a b. HasField "etag" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"etag")
Text -> ConduitT ByteString Text m ()
forall (m :: * -> *) o i. Monad m => o -> ConduitT i o m ()
yield Text
etag ConduitT ByteString Text m ()
-> ConduitT ByteString Text m () -> ConduitT ByteString Text m ()
forall (m :: * -> *) a b. Monad m => m a -> m b -> m b
>> Int -> ConduitT ByteString Text m ()
go (Int
n Int -> Int -> Int
forall a. Num a => a -> a -> a
+ Int
1)
inChunks :: ConduitT ByteString ByteString m ()
inChunks = Int -> [ByteString] -> ConduitT ByteString ByteString m ()
loop Int
0 []
where
loop :: Int -> [ByteString] -> ConduitT ByteString ByteString m ()
loop !Int
n [ByteString]
chunk = ConduitT ByteString ByteString m (Maybe ByteString)
forall (m :: * -> *) i. Monad m => Consumer i m (Maybe i)
await ConduitT ByteString ByteString m (Maybe ByteString)
-> (Maybe ByteString -> ConduitT ByteString ByteString m ())
-> ConduitT ByteString ByteString m ()
forall (m :: * -> *) a b. Monad m => m a -> (a -> m b) -> m b
>>= ConduitT ByteString ByteString m ()
-> (ByteString -> ConduitT ByteString ByteString m ())
-> Maybe ByteString
-> ConduitT ByteString ByteString m ()
forall b a. b -> (a -> b) -> Maybe a -> b
maybe ([ByteString] -> ConduitT ByteString ByteString m ()
forall i. [ByteString] -> ConduitT i ByteString m ()
yieldChunk [ByteString]
chunk) ByteString -> ConduitT ByteString ByteString m ()
go
where
go :: ByteString -> ConduitT ByteString ByteString m ()
go ByteString
bs = ConduitT ByteString ByteString m ()
-> ConduitT ByteString ByteString m ()
-> Bool
-> ConduitT ByteString ByteString m ()
forall a. a -> a -> Bool -> a
bool (Int -> [ByteString] -> ConduitT ByteString ByteString m ()
loop Int
len [ByteString]
newChunk)
([ByteString] -> ConduitT ByteString ByteString m ()
forall i. [ByteString] -> ConduitT i ByteString m ()
yieldChunk [ByteString]
newChunk ConduitT ByteString ByteString m ()
-> ConduitT ByteString ByteString m ()
-> ConduitT ByteString ByteString m ()
forall (m :: * -> *) a b. Monad m => m a -> m b -> m b
>> Int -> [ByteString] -> ConduitT ByteString ByteString m ()
loop Int
0 [])
(Int
size Int -> Int -> Bool
forall a. Ord a => a -> a -> Bool
<= Int
len)
where
len :: Int
len = ByteString -> Int
C.length ByteString
bs Int -> Int -> Int
forall a. Num a => a -> a -> a
+ Int
n
newChunk :: [ByteString]
newChunk = ByteString
bs ByteString -> [ByteString] -> [ByteString]
forall a. a -> [a] -> [a]
: [ByteString]
chunk
yieldChunk :: [ByteString] -> ConduitT i ByteString m ()
yieldChunk = ByteString -> ConduitT i ByteString m ()
forall (m :: * -> *) o i. Monad m => o -> ConduitT i o m ()
yield (ByteString -> ConduitT i ByteString m ())
-> ([ByteString] -> ByteString)
-> [ByteString]
-> ConduitT i ByteString m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. [ByteString] -> ByteString
LB.fromChunks ([ByteString] -> ByteString)
-> ([ByteString] -> [ByteString]) -> [ByteString] -> ByteString
forall b c a. (b -> c) -> (a -> b) -> a -> c
. [ByteString] -> [ByteString]
forall a. [a] -> [a]
reverse
uploadFile :: forall m.
MonadSpaces m
=> Bucket
-> Object
-> FilePath
-> m (SpacesResponse UploadObject)
uploadFile :: Bucket -> Object -> FilePath -> m (SpacesResponse UploadObject)
uploadFile Bucket
bucket Object
object FilePath
fp = FilePath
-> (ConduitM () ByteString m () -> m (SpacesResponse UploadObject))
-> m (SpacesResponse UploadObject)
forall (m :: * -> *) (n :: * -> *) i a.
(MonadUnliftIO m, MonadIO n) =>
FilePath -> (ConduitM i ByteString n () -> m a) -> m a
withSourceFile @_ @m FilePath
fp ((ConduitM () ByteString m () -> m (SpacesResponse UploadObject))
-> m (SpacesResponse UploadObject))
-> (ConduitM () ByteString m () -> m (SpacesResponse UploadObject))
-> m (SpacesResponse UploadObject)
forall a b. (a -> b) -> a -> b
$ \ConduitM () ByteString m ()
body ->
Maybe ByteString
-> Bucket
-> Object
-> ConduitM () ByteString m ()
-> m (SpacesResponse UploadObject)
forall (m :: * -> *).
MonadSpaces m =>
Maybe ByteString
-> Bucket -> Object -> BodyBS m -> m (SpacesResponse UploadObject)
uploadObject (ByteString -> Maybe ByteString
forall a. a -> Maybe a
Just ByteString
mtype) Bucket
bucket Object
object ConduitM () ByteString m ()
body
where
mtype :: ByteString
mtype =
MimeMap -> ByteString -> Text -> ByteString
mimeByExt MimeMap
defaultMimeMap ByteString
defaultMimeType (Text -> ByteString)
-> (FilePath -> Text) -> FilePath -> ByteString
forall b c a. (b -> c) -> (a -> b) -> a -> c
. FilePath -> Text
T.pack (FilePath -> ByteString) -> FilePath -> ByteString
forall a b. (a -> b) -> a -> b
$ FilePath -> FilePath
F.takeFileName FilePath
fp
getObjectInfo
:: MonadSpaces m => Bucket -> Object -> m (SpacesResponse GetObjectInfo)
getObjectInfo :: Bucket -> Object -> m (SpacesResponse GetObjectInfo)
getObjectInfo Bucket
bucket Object
object = WithMetadata -> GetObjectInfo -> m (SpacesResponse GetObjectInfo)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata GetObjectInfo :: Bucket -> Object -> GetObjectInfo
GetObjectInfo { Object
Bucket
$sel:object:GetObjectInfo :: Object
$sel:bucket:GetObjectInfo :: Bucket
object :: Object
bucket :: Bucket
.. }
getObject :: MonadSpaces m => Bucket -> Object -> m (SpacesResponse GetObject)
getObject :: Bucket -> Object -> m (SpacesResponse GetObject)
getObject Bucket
bucket Object
object = WithMetadata -> GetObject -> m (SpacesResponse GetObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata GetObject :: Bucket -> Object -> GetObject
GetObject { Object
Bucket
$sel:object:GetObject :: Object
$sel:bucket:GetObject :: Bucket
object :: Object
bucket :: Bucket
.. }
getObjectSinkFile :: MonadSpaces m => Bucket -> Object -> FilePath -> m ()
getObjectSinkFile :: Bucket -> Object -> FilePath -> m ()
getObjectSinkFile Bucket
bucket Object
object FilePath
fp = do
ByteString
objectData <- Bucket -> Object -> m (SpacesResponse GetObject)
forall (m :: * -> *).
MonadSpaces m =>
Bucket -> Object -> m (SpacesResponse GetObject)
getObject Bucket
bucket Object
object
m (SpacesResponse GetObject)
-> (SpacesResponse GetObject -> ByteString) -> m ByteString
forall (f :: * -> *) a b. Functor f => f a -> (a -> b) -> f b
<&> (SpacesResponse GetObject
-> Getting ByteString (SpacesResponse GetObject) ByteString
-> ByteString
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "result" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"result" ((GetObjectResponse -> Const ByteString GetObjectResponse)
-> SpacesResponse GetObject
-> Const ByteString (SpacesResponse GetObject))
-> ((ByteString -> Const ByteString ByteString)
-> GetObjectResponse -> Const ByteString GetObjectResponse)
-> Getting ByteString (SpacesResponse GetObject) ByteString
forall b c a. (b -> c) -> (a -> b) -> a -> c
. forall s t a b. HasField "objectData" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"objectData")
ConduitT () Void (ResourceT m) () -> m ()
forall (m :: * -> *) r.
MonadUnliftIO m =>
ConduitT () Void (ResourceT m) r -> m r
runConduitRes (ConduitT () Void (ResourceT m) () -> m ())
-> ConduitT () Void (ResourceT m) () -> m ()
forall a b. (a -> b) -> a -> b
$ ByteString -> ConduitT () ByteString (ResourceT m) ()
forall (m :: * -> *) lazy strict i.
(Monad m, LazySequence lazy strict) =>
lazy -> ConduitT i strict m ()
sourceLazy ByteString
objectData ConduitT () ByteString (ResourceT m) ()
-> ConduitM ByteString Void (ResourceT m) ()
-> ConduitT () Void (ResourceT m) ()
forall (m :: * -> *) a b c r.
Monad m =>
ConduitM a b m () -> ConduitM b c m r -> ConduitM a c m r
.| FilePath -> ConduitM ByteString Void (ResourceT m) ()
forall (m :: * -> *) o.
MonadResource m =>
FilePath -> ConduitM ByteString o m ()
sinkFileCautious FilePath
fp
copyObject :: MonadSpaces m
=> Bucket
-> Bucket
-> Object
-> Object
-> m (SpacesResponse CopyObject)
copyObject :: Bucket
-> Bucket -> Object -> Object -> m (SpacesResponse CopyObject)
copyObject Bucket
srcBucket Bucket
destBucket Object
srcObject Object
destObject =
WithMetadata -> CopyObject -> m (SpacesResponse CopyObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata CopyObject :: Bucket
-> Bucket
-> Object
-> Object
-> MetadataDirective
-> Maybe CannedACL
-> CopyObject
CopyObject { Maybe CannedACL
Object
Bucket
MetadataDirective
forall a. Maybe a
$sel:acl:CopyObject :: Maybe CannedACL
$sel:metadataDirective:CopyObject :: MetadataDirective
$sel:destObject:CopyObject :: Object
$sel:srcObject:CopyObject :: Object
$sel:destBucket:CopyObject :: Bucket
$sel:srcBucket:CopyObject :: Bucket
metadataDirective :: MetadataDirective
acl :: forall a. Maybe a
destObject :: Object
srcObject :: Object
destBucket :: Bucket
srcBucket :: Bucket
.. }
where
acl :: Maybe a
acl = Maybe a
forall a. Maybe a
Nothing
metadataDirective :: MetadataDirective
metadataDirective = MetadataDirective
Copy
copyObjectWithin :: MonadSpaces m
=> Bucket
-> Object
-> Object
-> m (SpacesResponse CopyObject)
copyObjectWithin :: Bucket -> Object -> Object -> m (SpacesResponse CopyObject)
copyObjectWithin Bucket
srcBucket Object
srcObject Object
destObject =
WithMetadata -> CopyObject -> m (SpacesResponse CopyObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata CopyObject :: Bucket
-> Bucket
-> Object
-> Object
-> MetadataDirective
-> Maybe CannedACL
-> CopyObject
CopyObject { Maybe CannedACL
Object
Bucket
MetadataDirective
forall a. Maybe a
destBucket :: Bucket
metadataDirective :: MetadataDirective
acl :: forall a. Maybe a
destObject :: Object
srcObject :: Object
srcBucket :: Bucket
$sel:acl:CopyObject :: Maybe CannedACL
$sel:metadataDirective:CopyObject :: MetadataDirective
$sel:destObject:CopyObject :: Object
$sel:srcObject:CopyObject :: Object
$sel:destBucket:CopyObject :: Bucket
$sel:srcBucket:CopyObject :: Bucket
.. }
where
acl :: Maybe a
acl = Maybe a
forall a. Maybe a
Nothing
metadataDirective :: MetadataDirective
metadataDirective = MetadataDirective
Copy
destBucket :: Bucket
destBucket = Bucket
srcBucket
overwriteObject
:: MonadSpaces m => Bucket -> Object -> m (SpacesResponse CopyObject)
overwriteObject :: Bucket -> Object -> m (SpacesResponse CopyObject)
overwriteObject Bucket
srcBucket Object
srcObject = WithMetadata -> CopyObject -> m (SpacesResponse CopyObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata CopyObject :: Bucket
-> Bucket
-> Object
-> Object
-> MetadataDirective
-> Maybe CannedACL
-> CopyObject
CopyObject { Maybe CannedACL
Object
Bucket
MetadataDirective
forall a. Maybe a
destObject :: Object
destBucket :: Bucket
metadataDirective :: MetadataDirective
acl :: forall a. Maybe a
srcObject :: Object
srcBucket :: Bucket
$sel:acl:CopyObject :: Maybe CannedACL
$sel:metadataDirective:CopyObject :: MetadataDirective
$sel:destObject:CopyObject :: Object
$sel:srcObject:CopyObject :: Object
$sel:destBucket:CopyObject :: Bucket
$sel:srcBucket:CopyObject :: Bucket
.. }
where
acl :: Maybe a
acl = Maybe a
forall a. Maybe a
Nothing
metadataDirective :: MetadataDirective
metadataDirective = MetadataDirective
Copy
destBucket :: Bucket
destBucket = Bucket
srcBucket
destObject :: Object
destObject = Object
srcObject
deleteObject
:: MonadSpaces m => Bucket -> Object -> m (SpacesResponse DeleteObject)
deleteObject :: Bucket -> Object -> m (SpacesResponse DeleteObject)
deleteObject Bucket
bucket Object
object = WithMetadata -> DeleteObject -> m (SpacesResponse DeleteObject)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata DeleteObject :: Bucket -> Object -> DeleteObject
DeleteObject { Object
Bucket
$sel:object:DeleteObject :: Object
$sel:bucket:DeleteObject :: Bucket
object :: Object
bucket :: Bucket
.. }
getObjectACLs
:: MonadSpaces m => Bucket -> Object -> m (SpacesResponse GetObjectACLs)
getObjectACLs :: Bucket -> Object -> m (SpacesResponse GetObjectACLs)
getObjectACLs Bucket
bucket Object
object = WithMetadata -> GetObjectACLs -> m (SpacesResponse GetObjectACLs)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata GetObjectACLs :: Bucket -> Object -> GetObjectACLs
GetObjectACLs { Object
Bucket
$sel:object:GetObjectACLs :: Object
$sel:bucket:GetObjectACLs :: Bucket
object :: Object
bucket :: Bucket
.. }
setObjectACLs :: MonadSpaces m
=> Bucket
-> Object
-> Owner
-> [Grant]
-> m (SpacesResponse SetObjectACLs)
setObjectACLs :: Bucket
-> Object -> Owner -> [Grant] -> m (SpacesResponse SetObjectACLs)
setObjectACLs Bucket
bucket Object
object Owner
owner [Grant]
acls =
WithMetadata -> SetObjectACLs -> m (SpacesResponse SetObjectACLs)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata SetObjectACLs :: Bucket -> Object -> Owner -> [Grant] -> SetObjectACLs
SetObjectACLs { [Grant]
Owner
Object
Bucket
$sel:acls:SetObjectACLs :: [Grant]
$sel:owner:SetObjectACLs :: Owner
$sel:object:SetObjectACLs :: Object
$sel:bucket:SetObjectACLs :: Bucket
acls :: [Grant]
owner :: Owner
object :: Object
bucket :: Bucket
.. }
createBucket :: MonadSpaces m
=> Bucket
-> Maybe Region
-> Maybe CannedACL
-> m (SpacesResponse CreateBucket)
createBucket :: Bucket
-> Maybe Region
-> Maybe CannedACL
-> m (SpacesResponse CreateBucket)
createBucket Bucket
bucket Maybe Region
region Maybe CannedACL
acl = WithMetadata -> CreateBucket -> m (SpacesResponse CreateBucket)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata CreateBucket :: Bucket -> Maybe Region -> Maybe CannedACL -> CreateBucket
CreateBucket { Maybe CannedACL
Maybe Region
Bucket
acl :: Maybe CannedACL
region :: Maybe Region
bucket :: Bucket
acl :: Maybe CannedACL
region :: Maybe Region
bucket :: Bucket
.. }
deleteBucket :: MonadSpaces m => Bucket -> m (SpacesResponse DeleteBucket)
deleteBucket :: Bucket -> m (SpacesResponse DeleteBucket)
deleteBucket Bucket
bucket = WithMetadata -> DeleteBucket -> m (SpacesResponse DeleteBucket)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata DeleteBucket :: Bucket -> DeleteBucket
DeleteBucket { Bucket
$sel:bucket:DeleteBucket :: Bucket
bucket :: Bucket
.. }
getBucketLocation
:: MonadSpaces m => Bucket -> m (SpacesResponse GetBucketLocation)
getBucketLocation :: Bucket -> m (SpacesResponse GetBucketLocation)
getBucketLocation Bucket
bucket = WithMetadata
-> GetBucketLocation -> m (SpacesResponse GetBucketLocation)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata GetBucketLocation :: Bucket -> GetBucketLocation
GetBucketLocation { Bucket
$sel:bucket:GetBucketLocation :: Bucket
bucket :: Bucket
.. }
listAllBuckets :: MonadSpaces m => m (SpacesResponse ListAllBuckets)
listAllBuckets :: m (SpacesResponse ListAllBuckets)
listAllBuckets = WithMetadata -> ListAllBuckets -> m (SpacesResponse ListAllBuckets)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata ListAllBuckets
ListAllBuckets
listBucket :: MonadSpaces m => Bucket -> m (SpacesResponse ListBucket)
listBucket :: Bucket -> m (SpacesResponse ListBucket)
listBucket Bucket
bucket = WithMetadata -> ListBucket -> m (SpacesResponse ListBucket)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata ListBucket :: Bucket
-> Maybe Char
-> Maybe Object
-> Maybe Int
-> Maybe Text
-> ListBucket
ListBucket { Maybe Char
Maybe Int
Maybe Text
Maybe Object
Bucket
forall a. Maybe a
$sel:prefix:ListBucket :: Maybe Text
$sel:maxKeys:ListBucket :: Maybe Int
$sel:marker:ListBucket :: Maybe Object
$sel:delimiter:ListBucket :: Maybe Char
$sel:bucket:ListBucket :: Bucket
prefix :: forall a. Maybe a
maxKeys :: forall a. Maybe a
marker :: forall a. Maybe a
delimiter :: forall a. Maybe a
bucket :: Bucket
.. }
where
delimiter :: Maybe a
delimiter = Maybe a
forall a. Maybe a
Nothing
marker :: Maybe a
marker = Maybe a
forall a. Maybe a
Nothing
maxKeys :: Maybe a
maxKeys = Maybe a
forall a. Maybe a
Nothing
prefix :: Maybe a
prefix = Maybe a
forall a. Maybe a
Nothing
listBucketGrouped :: MonadSpaces m
=> Bucket
-> Char
-> Text
-> m (SpacesResponse ListBucket)
listBucketGrouped :: Bucket -> Char -> Text -> m (SpacesResponse ListBucket)
listBucketGrouped Bucket
bucket Char
delimiter Text
prefix =
WithMetadata -> ListBucket -> m (SpacesResponse ListBucket)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata
ListBucket :: Bucket
-> Maybe Char
-> Maybe Object
-> Maybe Int
-> Maybe Text
-> ListBucket
ListBucket
{ $sel:delimiter:ListBucket :: Maybe Char
delimiter = Char -> Maybe Char
forall a. a -> Maybe a
Just Char
delimiter, $sel:prefix:ListBucket :: Maybe Text
prefix = Text -> Maybe Text
forall a. a -> Maybe a
Just Text
prefix, Maybe Int
Maybe Object
Bucket
forall a. Maybe a
marker :: forall a. Maybe a
maxKeys :: forall a. Maybe a
bucket :: Bucket
$sel:maxKeys:ListBucket :: Maybe Int
$sel:marker:ListBucket :: Maybe Object
$sel:bucket:ListBucket :: Bucket
.. }
where
maxKeys :: Maybe a
maxKeys = Maybe a
forall a. Maybe a
Nothing
marker :: Maybe a
marker = Maybe a
forall a. Maybe a
Nothing
listBucketRec :: MonadSpaces m => Bucket -> m (Seq ObjectInfo)
listBucketRec :: Bucket -> m (Seq ObjectInfo)
listBucketRec Bucket
bucket = Seq ObjectInfo -> Maybe Object -> m (Seq ObjectInfo)
forall (m :: * -> *).
(MonadReader Spaces m, MonadUnliftIO m, MonadCatch m) =>
Seq ObjectInfo -> Maybe Object -> m (Seq ObjectInfo)
go Seq ObjectInfo
forall a. Monoid a => a
mempty Maybe Object
forall a. Maybe a
Nothing
where
go :: Seq ObjectInfo -> Maybe Object -> m (Seq ObjectInfo)
go Seq ObjectInfo
os Maybe Object
marker = do
SpacesResponse ListBucket
listed <- WithMetadata -> ListBucket -> m (SpacesResponse ListBucket)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
NoMetadata
(ListBucket -> m (SpacesResponse ListBucket))
-> ListBucket -> m (SpacesResponse ListBucket)
forall a b. (a -> b) -> a -> b
$ ListBucket :: Bucket
-> Maybe Char
-> Maybe Object
-> Maybe Int
-> Maybe Text
-> ListBucket
ListBucket
{ $sel:delimiter:ListBucket :: Maybe Char
delimiter = Maybe Char
forall a. Maybe a
Nothing, $sel:maxKeys:ListBucket :: Maybe Int
maxKeys = Maybe Int
forall a. Maybe a
Nothing, $sel:prefix:ListBucket :: Maybe Text
prefix = Maybe Text
forall a. Maybe a
Nothing, Maybe Object
Bucket
marker :: Maybe Object
bucket :: Bucket
$sel:marker:ListBucket :: Maybe Object
$sel:bucket:ListBucket :: Bucket
.. }
let r :: ListBucketResponse
r = SpacesResponse ListBucket
listed SpacesResponse ListBucket
-> Getting
ListBucketResponse (SpacesResponse ListBucket) ListBucketResponse
-> ListBucketResponse
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "result" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"result"
isTruncated :: Bool
isTruncated = ListBucketResponse
r ListBucketResponse -> Getting Bool ListBucketResponse Bool -> Bool
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "isTruncated" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"isTruncated"
objects :: Seq ObjectInfo
objects = ListBucketResponse
r ListBucketResponse
-> Getting (Seq ObjectInfo) ListBucketResponse (Seq ObjectInfo)
-> Seq ObjectInfo
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "objects" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"objects"
nextMarker :: Maybe Object
nextMarker = ListBucketResponse
r ListBucketResponse
-> Getting (Maybe Object) ListBucketResponse (Maybe Object)
-> Maybe Object
forall s a. s -> Getting a s a -> a
^. forall s t a b. HasField "nextMarker" s t a b => Lens s t a b
forall (field :: Symbol) s t a b.
HasField field s t a b =>
Lens s t a b
field @"nextMarker"
case Maybe Object
nextMarker of
Just Object
_
| Bool
isTruncated -> Seq ObjectInfo -> Maybe Object -> m (Seq ObjectInfo)
go (Seq ObjectInfo
os Seq ObjectInfo -> Seq ObjectInfo -> Seq ObjectInfo
forall a. Semigroup a => a -> a -> a
<> Seq ObjectInfo
objects) Maybe Object
nextMarker
| Bool
otherwise -> Seq ObjectInfo -> m (Seq ObjectInfo)
forall (f :: * -> *) a. Applicative f => a -> f a
pure (Seq ObjectInfo -> m (Seq ObjectInfo))
-> Seq ObjectInfo -> m (Seq ObjectInfo)
forall a b. (a -> b) -> a -> b
$ Seq ObjectInfo
os Seq ObjectInfo -> Seq ObjectInfo -> Seq ObjectInfo
forall a. Semigroup a => a -> a -> a
<> Seq ObjectInfo
objects
Maybe Object
Nothing -> Seq ObjectInfo -> m (Seq ObjectInfo)
forall (f :: * -> *) a. Applicative f => a -> f a
pure (Seq ObjectInfo -> m (Seq ObjectInfo))
-> Seq ObjectInfo -> m (Seq ObjectInfo)
forall a b. (a -> b) -> a -> b
$ Seq ObjectInfo
os Seq ObjectInfo -> Seq ObjectInfo -> Seq ObjectInfo
forall a. Semigroup a => a -> a -> a
<> Seq ObjectInfo
objects
getBucketCORS :: MonadSpaces m => Bucket -> m (SpacesResponse GetBucketCORS)
getBucketCORS :: Bucket -> m (SpacesResponse GetBucketCORS)
getBucketCORS Bucket
bucket = WithMetadata -> GetBucketCORS -> m (SpacesResponse GetBucketCORS)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (GetBucketCORS -> m (SpacesResponse GetBucketCORS))
-> GetBucketCORS -> m (SpacesResponse GetBucketCORS)
forall a b. (a -> b) -> a -> b
$ GetBucketCORS :: Bucket -> GetBucketCORS
GetBucketCORS { Bucket
$sel:bucket:GetBucketCORS :: Bucket
bucket :: Bucket
.. }
setBucketCORS :: MonadSpaces m
=> Bucket
-> [CORSRule]
-> m (SpacesResponse SetBucketCORS)
setBucketCORS :: Bucket -> [CORSRule] -> m (SpacesResponse SetBucketCORS)
setBucketCORS Bucket
bucket [CORSRule]
rules = WithMetadata -> SetBucketCORS -> m (SpacesResponse SetBucketCORS)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (SetBucketCORS -> m (SpacesResponse SetBucketCORS))
-> SetBucketCORS -> m (SpacesResponse SetBucketCORS)
forall a b. (a -> b) -> a -> b
$ SetBucketCORS :: Bucket -> [CORSRule] -> SetBucketCORS
SetBucketCORS { [CORSRule]
Bucket
$sel:rules:SetBucketCORS :: [CORSRule]
$sel:bucket:SetBucketCORS :: Bucket
rules :: [CORSRule]
bucket :: Bucket
.. }
deleteBucketCORS
:: MonadSpaces m => Bucket -> m (SpacesResponse DeleteBucketCORS)
deleteBucketCORS :: Bucket -> m (SpacesResponse DeleteBucketCORS)
deleteBucketCORS Bucket
bucket = WithMetadata
-> DeleteBucketCORS -> m (SpacesResponse DeleteBucketCORS)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (DeleteBucketCORS -> m (SpacesResponse DeleteBucketCORS))
-> DeleteBucketCORS -> m (SpacesResponse DeleteBucketCORS)
forall a b. (a -> b) -> a -> b
$ DeleteBucketCORS :: Bucket -> DeleteBucketCORS
DeleteBucketCORS { Bucket
$sel:bucket:DeleteBucketCORS :: Bucket
bucket :: Bucket
.. }
getBucketACLs :: MonadSpaces m => Bucket -> m (SpacesResponse GetBucketACLs)
getBucketACLs :: Bucket -> m (SpacesResponse GetBucketACLs)
getBucketACLs Bucket
bucket = WithMetadata -> GetBucketACLs -> m (SpacesResponse GetBucketACLs)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (GetBucketACLs -> m (SpacesResponse GetBucketACLs))
-> GetBucketACLs -> m (SpacesResponse GetBucketACLs)
forall a b. (a -> b) -> a -> b
$ GetBucketACLs :: Bucket -> GetBucketACLs
GetBucketACLs { Bucket
$sel:bucket:GetBucketACLs :: Bucket
bucket :: Bucket
.. }
setBucketACLs :: MonadSpaces m
=> Bucket
-> [Grant]
-> Owner
-> m (SpacesResponse SetBucketACLs)
setBucketACLs :: Bucket -> [Grant] -> Owner -> m (SpacesResponse SetBucketACLs)
setBucketACLs Bucket
bucket [Grant]
acls Owner
owner =
WithMetadata -> SetBucketACLs -> m (SpacesResponse SetBucketACLs)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (SetBucketACLs -> m (SpacesResponse SetBucketACLs))
-> SetBucketACLs -> m (SpacesResponse SetBucketACLs)
forall a b. (a -> b) -> a -> b
$ SetBucketACLs :: Bucket -> [Grant] -> Owner -> SetBucketACLs
SetBucketACLs { [Grant]
Owner
Bucket
$sel:owner:SetBucketACLs :: Owner
$sel:acls:SetBucketACLs :: [Grant]
$sel:bucket:SetBucketACLs :: Bucket
owner :: Owner
acls :: [Grant]
bucket :: Bucket
.. }
getBucketLifecycleRules
:: MonadSpaces m => Bucket -> m (SpacesResponse GetBucketLifecycle)
getBucketLifecycleRules :: Bucket -> m (SpacesResponse GetBucketLifecycle)
getBucketLifecycleRules Bucket
bucket =
WithMetadata
-> GetBucketLifecycle -> m (SpacesResponse GetBucketLifecycle)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (GetBucketLifecycle -> m (SpacesResponse GetBucketLifecycle))
-> GetBucketLifecycle -> m (SpacesResponse GetBucketLifecycle)
forall a b. (a -> b) -> a -> b
$ GetBucketLifecycle :: Bucket -> GetBucketLifecycle
GetBucketLifecycle { Bucket
$sel:bucket:GetBucketLifecycle :: Bucket
bucket :: Bucket
.. }
setBucketLifecycleRules :: MonadSpaces m
=> Bucket
-> [LifecycleRule]
-> m (SpacesResponse SetBucketLifecycle)
setBucketLifecycleRules :: Bucket -> [LifecycleRule] -> m (SpacesResponse SetBucketLifecycle)
setBucketLifecycleRules Bucket
bucket [LifecycleRule]
rules =
WithMetadata
-> SetBucketLifecycle -> m (SpacesResponse SetBucketLifecycle)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (SetBucketLifecycle -> m (SpacesResponse SetBucketLifecycle))
-> SetBucketLifecycle -> m (SpacesResponse SetBucketLifecycle)
forall a b. (a -> b) -> a -> b
$ SetBucketLifecycle :: Bucket -> [LifecycleRule] -> SetBucketLifecycle
SetBucketLifecycle { [LifecycleRule]
Bucket
$sel:rules:SetBucketLifecycle :: [LifecycleRule]
$sel:bucket:SetBucketLifecycle :: Bucket
rules :: [LifecycleRule]
bucket :: Bucket
.. }
deleteBucketLifecycleRules
:: MonadSpaces m => Bucket -> m (SpacesResponse DeleteBucketLifecycle)
deleteBucketLifecycleRules :: Bucket -> m (SpacesResponse DeleteBucketLifecycle)
deleteBucketLifecycleRules Bucket
bucket =
WithMetadata
-> DeleteBucketLifecycle
-> m (SpacesResponse DeleteBucketLifecycle)
forall a (m :: * -> *).
(MonadSpaces m, Action m a) =>
WithMetadata -> a -> m (SpacesResponse a)
runAction WithMetadata
KeepMetadata (DeleteBucketLifecycle -> m (SpacesResponse DeleteBucketLifecycle))
-> DeleteBucketLifecycle
-> m (SpacesResponse DeleteBucketLifecycle)
forall a b. (a -> b) -> a -> b
$ DeleteBucketLifecycle :: Bucket -> DeleteBucketLifecycle
DeleteBucketLifecycle { Bucket
$sel:bucket:DeleteBucketLifecycle :: Bucket
bucket :: Bucket
.. }