antiope-sqs 7.5.1 → 7.5.2

raw patch · 3 files changed

+35/−6 lines, 3 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• antiope-sqs.cabal +1/−1
• src/Antiope/SQS.hs +31/−5
• src/Antiope/SQS/Types.hs +3/−0

@@ -1,7 +1,7 @@ cabal-version: 2.4  name:                   antiope-sqs-version:                7.5.1+version:                7.5.2 synopsis:               Please see the README on Github at <https://github.com/arbor/antiope#readme> description:            Please see the README on Github at <https://github.com/arbor/antiope#readme>. category:               Services

@@ -11,6 +11,7 @@   , ackMessage   , ackMessages   , queueSource+  , keepAliveMessage   , forAllMessages   , forAllMessages'   , defaultReceiveMessage@@ -26,7 +27,7 @@ import Control.Monad.Loops      (unfoldWhileM) import Control.Monad.Trans      (lift) import Data.Coerce              (coerce)-import Data.Conduit+import Data.Conduit             (ConduitT) import Data.Conduit.Combinators (yieldMany) import Data.List.Split          (chunksOf) import Data.Maybe               (catMaybes)@@ -98,6 +99,21 @@       else return $ Left DeleteMessageBatchError   pure $ sequence_ results +-- | Changes the visibility timeout of a specified message in a queue to a new value.+-- The message will be considered "In Flight" for a given amount of time.+--+-- The maximum allowed timeout value is 12 hours.+-- Thus, you can't extend the timeout of a message in an existing queue to more than a total visibility timeout of 12 hours.+-- For more information, see Visibility Timeout in the Amazon Simple Queue Service Developer Guide .+keepAliveMessage :: (MonadAWS m, HasReceiptHandle msg)+  => MessageVisibilitySeconds+  -> QueueUrl+  -> msg+  -> m ()+keepAliveMessage (MessageVisibilitySeconds t) (QueueUrl queueUrl) msg = do+  case (getReceiptHandle msg) of+    Nothing   -> pure ()+    Just rcpt -> void . AWS.send $ changeMessageVisibility queueUrl (coerce rcpt) t  -- | Reads from an SQS indefinitely, producing messages into a conduit queueSource :: MonadAWS m => QueueUrl -> ConduitT () Message m ()@@ -120,16 +136,26 @@   -> ConsumerMode   -> (Message -> m ConsumerResult)   -> m ()-forAllMessages' env recMsg mode process = go+forAllMessages' env recMsg mode process =+  forAllMessages'' env recMsg mode (const process)++forAllMessages'' :: (MonadUnliftIO m, HasEnv env)+  => env+  -> ReceiveMessage+  -> ConsumerMode+  -> (QueueUrl -> Message -> m ConsumerResult)+  -> m ()+forAllMessages'' env recMsg mode process = go   where     go = do       msgs <- runResourceT $ runAWS env (readQueue' recMsg)       case (mode, msgs) of         (Drain, []) -> pure ()         _           -> processBatch msgs >> go-    processBatch msgs =+    processBatch msgs = do+      let queueUrl = QueueUrl $ recMsg ^. rmQueueURL       forM_ msgs $ \msg -> do-        res <- process msg+        res <- process queueUrl msg         case res of-          Ack  -> void . runResourceT . runAWS env $ ackMessage (QueueUrl $ recMsg ^. rmQueueURL) msg+          Ack  -> void . runResourceT . runAWS env $ ackMessage queueUrl msg           Nack -> pure ()

@@ -20,6 +20,9 @@   | Nack   deriving (Show, Eq, Generic) +newtype MessageVisibilitySeconds = MessageVisibilitySeconds Int+  deriving (Eq, Show, Read, Ord, Generic)+ data SQSError = DeleteMessageBatchError   deriving (Eq, Show, Generic)