aws-dynamodb-streams (empty) → 0.1.0.0

raw patch · 10 files changed

+3392/−0 lines, 10 filesdep +aesondep +attoparsecdep +awssetup-changed

Dependencies added: aeson, attoparsec, aws, aws-general, base, base-unicode-symbols, base16-bytestring, base64-bytestring, byteable, bytestring, case-insensitive, conduit, conduit-extra, containers, cryptohash, http-conduit, http-types, mtl, old-locale, parsers, profunctors, resourcet, scientific, text, time

Files

• LICENSE +202/−0
• Setup.hs +2/−0
• aws-dynamodb-streams.cabal +50/−0
• src/Aws/DynamoDb/Streams.hs +37/−0
• src/Aws/DynamoDb/Streams/Commands/DescribeStream.hs +209/−0
• src/Aws/DynamoDb/Streams/Commands/GetRecords.hs +195/−0
• src/Aws/DynamoDb/Streams/Commands/GetShardIterator.hs +225/−0
• src/Aws/DynamoDb/Streams/Commands/ListStreams.hs +242/−0
• src/Aws/DynamoDb/Streams/Core.hs +593/−0
• src/Aws/DynamoDb/Streams/Types.hs +1637/−0

@@ -0,0 +1,202 @@++                                 Apache License+                           Version 2.0, January 2004+                        http://www.apache.org/licenses/++   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION++   1. Definitions.++      "License" shall mean the terms and conditions for use, reproduction,+      and distribution as defined by Sections 1 through 9 of this document.++      "Licensor" shall mean the copyright owner or entity authorized by+      the copyright owner that is granting the License.++      "Legal Entity" shall mean the union of the acting entity and all+      other entities that control, are controlled by, or are under common+      control with that entity. For the purposes of this definition,+      "control" means (i) the power, direct or indirect, to cause the+      direction or management of such entity, whether by contract or+      otherwise, or (ii) ownership of fifty percent (50%) or more of the+      outstanding shares, or (iii) beneficial ownership of such entity.++      "You" (or "Your") shall mean an individual or Legal Entity+      exercising permissions granted by this License.++      "Source" form shall mean the preferred form for making modifications,+      including but not limited to software source code, documentation+      source, and configuration files.++      "Object" form shall mean any form resulting from mechanical+      transformation or translation of a Source form, including but+      not limited to compiled object code, generated documentation,+      and conversions to other media types.++      "Work" shall mean the work of authorship, whether in Source or+      Object form, made available under the License, as indicated by a+      copyright notice that is included in or attached to the work+      (an example is provided in the Appendix below).++      "Derivative Works" shall mean any work, whether in Source or Object+      form, that is based on (or derived from) the Work and for which the+      editorial revisions, annotations, elaborations, or other modifications+      represent, as a whole, an original work of authorship. For the purposes+      of this License, Derivative Works shall not include works that remain+      separable from, or merely link (or bind by name) to the interfaces of,+      the Work and Derivative Works thereof.++      "Contribution" shall mean any work of authorship, including+      the original version of the Work and any modifications or additions+      to that Work or Derivative Works thereof, that is intentionally+      submitted to Licensor for inclusion in the Work by the copyright owner+      or by an individual or Legal Entity authorized to submit on behalf of+      the copyright owner. For the purposes of this definition, "submitted"+      means any form of electronic, verbal, or written communication sent+      to the Licensor or its representatives, including but not limited to+      communication on electronic mailing lists, source code control systems,+      and issue tracking systems that are managed by, or on behalf of, the+      Licensor for the purpose of discussing and improving the Work, but+      excluding communication that is conspicuously marked or otherwise+      designated in writing by the copyright owner as "Not a Contribution."++      "Contributor" shall mean Licensor and any individual or Legal Entity+      on behalf of whom a Contribution has been received by Licensor and+      subsequently incorporated within the Work.++   2. Grant of Copyright License. Subject to the terms and conditions of+      this License, each Contributor hereby grants to You a perpetual,+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable+      copyright license to reproduce, prepare Derivative Works of,+      publicly display, publicly perform, sublicense, and distribute the+      Work and such Derivative Works in Source or Object form.++   3. Grant of Patent License. Subject to the terms and conditions of+      this License, each Contributor hereby grants to You a perpetual,+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable+      (except as stated in this section) patent license to make, have made,+      use, offer to sell, sell, import, and otherwise transfer the Work,+      where such license applies only to those patent claims licensable+      by such Contributor that are necessarily infringed by their+      Contribution(s) alone or by combination of their Contribution(s)+      with the Work to which such Contribution(s) was submitted. If You+      institute patent litigation against any entity (including a+      cross-claim or counterclaim in a lawsuit) alleging that the Work+      or a Contribution incorporated within the Work constitutes direct+      or contributory patent infringement, then any patent licenses+      granted to You under this License for that Work shall terminate+      as of the date such litigation is filed.++   4. Redistribution. You may reproduce and distribute copies of the+      Work or Derivative Works thereof in any medium, with or without+      modifications, and in Source or Object form, provided that You+      meet the following conditions:++      (a) You must give any other recipients of the Work or+          Derivative Works a copy of this License; and++      (b) You must cause any modified files to carry prominent notices+          stating that You changed the files; and++      (c) You must retain, in the Source form of any Derivative Works+          that You distribute, all copyright, patent, trademark, and+          attribution notices from the Source form of the Work,+          excluding those notices that do not pertain to any part of+          the Derivative Works; and++      (d) If the Work includes a "NOTICE" text file as part of its+          distribution, then any Derivative Works that You distribute must+          include a readable copy of the attribution notices contained+          within such NOTICE file, excluding those notices that do not+          pertain to any part of the Derivative Works, in at least one+          of the following places: within a NOTICE text file distributed+          as part of the Derivative Works; within the Source form or+          documentation, if provided along with the Derivative Works; or,+          within a display generated by the Derivative Works, if and+          wherever such third-party notices normally appear. The contents+          of the NOTICE file are for informational purposes only and+          do not modify the License. You may add Your own attribution+          notices within Derivative Works that You distribute, alongside+          or as an addendum to the NOTICE text from the Work, provided+          that such additional attribution notices cannot be construed+          as modifying the License.++      You may add Your own copyright statement to Your modifications and+      may provide additional or different license terms and conditions+      for use, reproduction, or distribution of Your modifications, or+      for any such Derivative Works as a whole, provided Your use,+      reproduction, and distribution of the Work otherwise complies with+      the conditions stated in this License.++   5. Submission of Contributions. Unless You explicitly state otherwise,+      any Contribution intentionally submitted for inclusion in the Work+      by You to the Licensor shall be under the terms and conditions of+      this License, without any additional terms or conditions.+      Notwithstanding the above, nothing herein shall supersede or modify+      the terms of any separate license agreement you may have executed+      with Licensor regarding such Contributions.++   6. Trademarks. This License does not grant permission to use the trade+      names, trademarks, service marks, or product names of the Licensor,+      except as required for reasonable and customary use in describing the+      origin of the Work and reproducing the content of the NOTICE file.++   7. Disclaimer of Warranty. Unless required by applicable law or+      agreed to in writing, Licensor provides the Work (and each+      Contributor provides its Contributions) on an "AS IS" BASIS,+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or+      implied, including, without limitation, any warranties or conditions+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A+      PARTICULAR PURPOSE. You are solely responsible for determining the+      appropriateness of using or redistributing the Work and assume any+      risks associated with Your exercise of permissions under this License.++   8. Limitation of Liability. In no event and under no legal theory,+      whether in tort (including negligence), contract, or otherwise,+      unless required by applicable law (such as deliberate and grossly+      negligent acts) or agreed to in writing, shall any Contributor be+      liable to You for damages, including any direct, indirect, special,+      incidental, or consequential damages of any character arising as a+      result of this License or out of the use or inability to use the+      Work (including but not limited to damages for loss of goodwill,+      work stoppage, computer failure or malfunction, or any and all+      other commercial damages or losses), even if such Contributor+      has been advised of the possibility of such damages.++   9. Accepting Warranty or Additional Liability. While redistributing+      the Work or Derivative Works thereof, You may choose to offer,+      and charge a fee for, acceptance of support, warranty, indemnity,+      or other liability obligations and/or rights consistent with this+      License. However, in accepting such obligations, You may act only+      on Your own behalf and on Your sole responsibility, not on behalf+      of any other Contributor, and only if You agree to indemnify,+      defend, and hold each Contributor harmless for any liability+      incurred by, or claims asserted against, such Contributor by reason+      of your accepting any such warranty or additional liability.++   END OF TERMS AND CONDITIONS++   APPENDIX: How to apply the Apache License to your work.++      To apply the Apache License to your work, attach the following+      boilerplate notice, with the fields enclosed by brackets "[]"+      replaced with your own identifying information. (Don't include+      the brackets!)  The text should be enclosed in the appropriate+      comment syntax for the file format. We also recommend that a+      file or class name and description of purpose be included on the+      same "printed page" as the copyright notice for easier+      identification within third-party archives.++   Copyright [yyyy] [name of copyright owner]++   Licensed under the Apache License, Version 2.0 (the "License");+   you may not use this file except in compliance with the License.+   You may obtain a copy of the License at++       http://www.apache.org/licenses/LICENSE-2.0++   Unless required by applicable law or agreed to in writing, software+   distributed under the License is distributed on an "AS IS" BASIS,+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.+   See the License for the specific language governing permissions and+   limitations under the License.

@@ -0,0 +1,2 @@+import Distribution.Simple+main = defaultMain

@@ -0,0 +1,50 @@+name:                aws-dynamodb-streams+version:             0.1.0.0+synopsis:            Haskell bindings for Amazon DynamoDB Streams+-- description:+license:             Apache-2.0+license-file:        LICENSE+author:              Jon Sterling & Lars Kuhtz+maintainer:          jon@jonmsterling.com+copyright:           Copyright (c) 2013-2014 PivotCloud, Inc.+category:            Network+build-type:          Simple+-- extra-source-files:+cabal-version:       >=1.10++library+  exposed-modules:     Aws.DynamoDb.Streams,+                       Aws.DynamoDb.Streams.Core,+                       Aws.DynamoDb.Streams.Types+                       Aws.DynamoDb.Streams.Commands.ListStreams+                       Aws.DynamoDb.Streams.Commands.DescribeStream+                       Aws.DynamoDb.Streams.Commands.GetShardIterator+                       Aws.DynamoDb.Streams.Commands.GetRecords+  build-depends:       base >=4.7 && <4.8,+                       base-unicode-symbols,+                       attoparsec >=0.12.0.0,+                       aeson >=0.8.0.0,+                       aws >=0.10.5,+                       aws-general >=0.1,+                       base16-bytestring >=0.1.1.6,+                       base64-bytestring >=1.0.0.0,+                       byteable >=0.1.1,+                       bytestring >=0.10.4.0,+                       cryptohash >=0.11.6,+                       containers >=0.5.5.0,+                       case-insensitive >=1.2.0.0,+                       conduit >=1.2.0,+                       conduit-extra >=1.1.4,+                       http-types >=0.0.8.5,+                       http-conduit >=2.1.5,+                       old-locale >=1.0.0.0,+                       mtl >=2.1,+                       parsers >=0.11,+                       profunctors >=4.2,+                       resourcet >=1.1.3,+                       scientific >=0.3.3.2,+                       text >=1.2.0.0,+                       time >=1.4.2+  hs-source-dirs:      src+  ghc-options:         -Wall+  default-language:    Haskell2010

@@ -0,0 +1,37 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams+( module Aws.DynamoDb.Streams.Core+, module Aws.DynamoDb.Streams.Types+, module Aws.DynamoDb.Streams.Commands.ListStreams+, module Aws.DynamoDb.Streams.Commands.DescribeStream+, module Aws.DynamoDb.Streams.Commands.GetShardIterator+, module Aws.DynamoDb.Streams.Commands.GetRecords+) where++import Aws.DynamoDb.Streams.Core+import Aws.DynamoDb.Streams.Types+import Aws.DynamoDb.Streams.Commands.ListStreams+import Aws.DynamoDb.Streams.Commands.DescribeStream+import Aws.DynamoDb.Streams.Commands.GetShardIterator+import Aws.DynamoDb.Streams.Commands.GetRecords

@@ -0,0 +1,209 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Commands.DescribeStream+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE FlexibleInstances #-}+{-# LANGUAGE MultiParamTypeClasses #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Commands.DescribeStream+( -- * Request+  DescribeStream(..)+, describeStream+  -- ** Lenses+, dstExclusiveStartShardId+, dstLimit+, dstStreamId++  -- * Response+, DescribeStreamResponse(..)+  -- ** Lenses+, dstrStreamDescription+) where++import Aws.Core+import Aws.DynamoDb.Streams.Core+import Aws.DynamoDb.Streams.Types+import Control.Applicative+import Control.Applicative.Unicode+import Data.Aeson+import Data.Typeable+import Prelude.Unicode++data DescribeStream+  = DescribeStream+  { _dstExclusiveStartShardId ∷ !(Maybe ShardId)+    -- ^ The shard id of the first item this operation will evalute; see also+    -- '_sdLastEvaluatedShardId'.++  , _dstLimit ∷ !(Maybe Int)+    -- ^ The maximum number of shard objects to return.++  , _dstStreamId ∷ !StreamId+    -- ^ The unique ID of the stream to be described.++  } deriving (Eq, Ord, Show, Read, Typeable)++-- | A basic 'DescribeStream' request for a given stream id.+--+-- @+-- myRequest =+--   'describeStream' myStream+--     & 'dstLimit' ?~ 3+-- @+--+describeStream+  ∷ StreamId+  → DescribeStream+describeStream streamId = DescribeStream+  { _dstExclusiveStartShardId = Nothing+  , _dstLimit = Nothing+  , _dstStreamId = streamId+  }++instance ToJSON DescribeStream where+  toJSON DescribeStream{..} = object+    [ "ExclusiveStartShardId" .= _dstExclusiveStartShardId+    , "Limit" .= _dstLimit+    , "StreamId".= _dstStreamId+    ]++instance FromJSON DescribeStream where+  parseJSON =+    withObject "DescribeStream" $ \o →+      pure DescribeStream+        ⊛ o .:? "ExclusiveStartShardId"+        ⊛ o .:? "Limit"+        ⊛ o .: "StreamId"++-- | A lens for '_dstExclusiveStartShardId'.+--+-- @+-- 'dstExclusiveStartShardId' ∷ Lens' 'DescribeStream' ('Maybe' 'ShardId')+-- @+--+dstExclusiveStartShardId+  ∷ Functor f+  ⇒ (Maybe ShardId → f (Maybe ShardId))+  → DescribeStream+  → f DescribeStream+dstExclusiveStartShardId i DescribeStream{..} =+  (\_dstExclusiveStartShardId → DescribeStream{..})+    <$> i _dstExclusiveStartShardId+{-# INLINE dstExclusiveStartShardId #-}++-- | A lens for '_dstLimit'.+--+-- @+-- 'dstLimit' ∷ Lens' 'DescribeStream' ('Maybe' 'Int')+-- @+--+dstLimit+  ∷ Functor f+  ⇒ (Maybe Int → f (Maybe Int))+  → DescribeStream+  → f DescribeStream+dstLimit i DescribeStream{..} =+  (\_dstLimit → DescribeStream{..})+    <$> i _dstLimit+{-# INLINE dstLimit #-}++-- | A lens for '_dstStreamId'.+--+-- @+-- 'dstStreamId' ∷ Lens' 'DescribeStream' 'StreamId'+-- @+--+dstStreamId+  ∷ Functor f+  ⇒ (StreamId → f StreamId)+  → DescribeStream+  → f DescribeStream+dstStreamId i DescribeStream{..} =+  (\_dstStreamId → DescribeStream{..})+    <$> i _dstStreamId+{-# INLINE dstStreamId #-}++data DescribeStreamResponse+  = DescribeStreamResponse+  { _dstrStreamDescription ∷ !StreamDescription+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON DescribeStreamResponse where+  toJSON DescribeStreamResponse{..} = object+    [ "StreamDescription" .= _dstrStreamDescription+    ]++instance FromJSON DescribeStreamResponse where+  parseJSON =+    withObject "DescribeStreamResponse" $ \o →+      DescribeStreamResponse+        <$> o .: "StreamDescription"+++-- | A lens for '_dstrStreamDescription'.+--+-- @+-- 'dstrStreamDescription' ∷ Lens' 'DescribeStreamResponse' 'StreamDescription'+-- @+--+dstrStreamDescription+  ∷ Functor f+  ⇒ (StreamDescription → f StreamDescription)+  → DescribeStreamResponse+  → f DescribeStreamResponse+dstrStreamDescription i DescribeStreamResponse{..} =+  (\_dstrStreamDescription → DescribeStreamResponse{..})+    <$> i _dstrStreamDescription+{-# INLINE dstrStreamDescription #-}++instance ResponseConsumer r DescribeStreamResponse where+  type ResponseMetadata DescribeStreamResponse = StreamsMetadata+  responseConsumer _ = streamsResponseConsumer++instance SignQuery DescribeStream where+  type ServiceConfiguration DescribeStream = StreamsConfiguration+  signQuery cmd = streamsSignQuery StreamsQuery+    { _stqAction = ActionDescribeStream+    , _stqBody = encode cmd+    }++instance Transaction DescribeStream DescribeStreamResponse++instance AsMemoryResponse DescribeStreamResponse where+  type MemoryResponse DescribeStreamResponse = DescribeStreamResponse+  loadToMemory = return++instance ListResponse DescribeStreamResponse Shard where+  listResponse = _sdShards ∘ _dstrStreamDescription++instance IteratedTransaction DescribeStream DescribeStreamResponse where+  nextIteratedRequest req@DescribeStream{..} DescribeStreamResponse{..} = do+    let StreamDescription{..} = _dstrStreamDescription+    lastEvaluatedShardId ← _sdLastEvaluatedShardId+    return req+      { _dstExclusiveStartShardId = Just lastEvaluatedShardId+      }+

@@ -0,0 +1,195 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Commands.GetRecords+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE FlexibleInstances #-}+{-# LANGUAGE MultiParamTypeClasses #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Commands.GetRecords+( -- * Request+  GetRecords(..)+, getRecords+  -- ** Lenses+, grShardIterator+, grLimit++  -- * Response+, GetRecordsResponse(..)+  -- ** Lenses+, grrRecords+, grrNextShardIterator+) where++import Aws.Core+import Aws.DynamoDb.Streams.Core+import Aws.DynamoDb.Streams.Types+import Control.Applicative+import Control.Applicative.Unicode+import Data.Aeson+import Data.Typeable++data GetRecords+  = GetRecords+  { _grShardIterator ∷ !ShardIterator+  , _grLimit ∷ !(Maybe Int)+  } deriving (Eq, Ord, Show, Read, Typeable)++-- | A basic 'GetRecords' request for a given shard iterator.+--+-- @+-- myRequest = getRecords it & grLimit ?~ 42+-- @+--+getRecords+  ∷ ShardIterator+  → GetRecords+getRecords it = GetRecords+  { _grShardIterator = it+  , _grLimit = Nothing+  }++instance ToJSON GetRecords where+  toJSON GetRecords{..} = object+    [ "ShardIterator" .= _grShardIterator+    , "Limit" .= _grLimit+    ]++instance FromJSON GetRecords where+  parseJSON =+    withObject "GetRecords" $ \o →+      pure GetRecords+        ⊛ o .: "ShardIterator"+        ⊛ o .:? "Limit"++-- | A lens for '_grShardIterator'.+--+-- @+-- grShardIterator ∷ Lens' 'GetRecords' 'ShardIterator'+-- @+--+grShardIterator+  ∷ Functor f+  ⇒ (ShardIterator → f ShardIterator)+  → GetRecords+  → f GetRecords+grShardIterator i GetRecords{..} =+  (\_grShardIterator → GetRecords{..})+    <$> i _grShardIterator+{-# INLINE grShardIterator #-}++-- | A lens for '_grLimit'.+--+-- @+-- grLimit ∷ Lens' 'GetRecords' ('Maybe' 'Int')+-- @+--+grLimit+  ∷ Functor f+  ⇒ (Maybe Int → f (Maybe Int))+  → GetRecords+  → f GetRecords+grLimit i GetRecords{..} =+  (\_grLimit → GetRecords{..})+    <$> i _grLimit+{-# INLINE grLimit #-}++data GetRecordsResponse+  = GetRecordsResponse+  { _grrNextShardIterator ∷ !(Maybe ShardIterator)+  , _grrRecords ∷ ![Record]+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON GetRecordsResponse where+  toJSON GetRecordsResponse{..} = object+    [ "NextShardIterator" .= _grrNextShardIterator+    , "Records" .= _grrRecords+    ]++instance FromJSON GetRecordsResponse where+  parseJSON =+    withObject "GetRecordsResponse" $ \o →+      pure GetRecordsResponse+        ⊛ o .:? "NextShardIterator"+        ⊛ o .: "Records"++-- | A lens for '_grrRecords'.+--+-- @+-- grrRecords ∷ Lens' 'GetRecordsResponse' ['Record']+-- @+--+grrRecords+  ∷ Functor f+  ⇒ ([Record] → f [Record])+  → GetRecordsResponse+  → f GetRecordsResponse+grrRecords i GetRecordsResponse{..} =+  (\_grrRecords → GetRecordsResponse{..})+    <$> i _grrRecords+{-# INLINE grrRecords #-}++-- | A lens for '_grrNextShardIterator'.+--+-- @+-- grrNextShardIterator ∷ Lens' 'GetRecordsResponse' ('Maybe' 'ShardIterator')+-- @+--+grrNextShardIterator+  ∷ Functor f+  ⇒ (Maybe ShardIterator → f (Maybe ShardIterator))+  → GetRecordsResponse+  → f GetRecordsResponse+grrNextShardIterator i GetRecordsResponse{..} =+  (\_grrNextShardIterator → GetRecordsResponse{..})+    <$> i _grrNextShardIterator+{-# INLINE grrNextShardIterator #-}++instance ResponseConsumer r GetRecordsResponse where+  type ResponseMetadata GetRecordsResponse = StreamsMetadata+  responseConsumer _ = streamsResponseConsumer++instance SignQuery GetRecords where+  type ServiceConfiguration GetRecords = StreamsConfiguration+  signQuery cmd = streamsSignQuery StreamsQuery+    { _stqAction = ActionGetRecords+    , _stqBody = encode cmd+    }++instance Transaction GetRecords GetRecordsResponse++instance AsMemoryResponse GetRecordsResponse where+  type MemoryResponse GetRecordsResponse = GetRecordsResponse+  loadToMemory = return++instance ListResponse GetRecordsResponse Record where+  listResponse = _grrRecords++instance IteratedTransaction GetRecords GetRecordsResponse where+  nextIteratedRequest req@GetRecords{..} GetRecordsResponse{..} = do+    nextShardIterator ← _grrNextShardIterator+    return req+      { _grShardIterator = nextShardIterator+      }

@@ -0,0 +1,225 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Commands.GetShardIterator+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE FlexibleInstances #-}+{-# LANGUAGE MultiParamTypeClasses #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Commands.GetShardIterator+( -- * Request+  GetShardIterator(..)+, getShardIterator+  -- ** Lenses+, gsiSequenceNumber+, gsiShardId+, gsiShardIteratorType+, gsiStreamId++  -- * Response+, GetShardIteratorResponse(..)+  -- ** Lenses+, gsirShardIterator+) where++import Aws.Core+import Aws.DynamoDb.Streams.Core+import Aws.DynamoDb.Streams.Types+import Control.Applicative+import Control.Applicative.Unicode+import Data.Aeson+import Data.Typeable++-- | A shard iterator provides information about how to retrieve stream records+-- from within a shard. Note: A shard iterator expires 15 minutes after it is+-- returned to the requester.+--+data GetShardIterator+  = GetShardIterator+  { _gsiSequenceNumber ∷ !(Maybe SequenceNumber)+    -- ^ The sequence number of a stream record in the shard from which to+    -- start reading.++  , _gsiShardId ∷ !ShardId+    -- ^ The identifier of the shard.++  , _gsiShardIteratorType ∷ !ShardIteratorType+    -- ^ Determines how the shard iterator is used to start reading stream+    -- records from the shard.++  , _gsiStreamId ∷ !StreamId+  } deriving (Eq, Ord, Read, Show, Typeable)++-- | A basic 'GetShardIterator' request for a given stream id.+--+-- @+-- myRequest =+--   'getShardIterator' myStream myShard 'ShardIteratorLatest'+--     & 'gsiSequenceNumber' ?~ sqn+-- @+--+getShardIterator+  ∷ StreamId+  → ShardId+  → ShardIteratorType+  → GetShardIterator+getShardIterator stream shard iteratorType =+  GetShardIterator+    { _gsiStreamId = stream+    , _gsiShardIteratorType = iteratorType+    , _gsiShardId = shard+    , _gsiSequenceNumber = Nothing+    }++instance ToJSON GetShardIterator where+  toJSON GetShardIterator{..} = object+    [ "SequenceNumber" .= _gsiSequenceNumber+    , "ShardId" .= _gsiShardId+    , "ShardIteratorType" .= _gsiShardIteratorType+    , "StreamId" .= _gsiStreamId+    ]++instance FromJSON GetShardIterator where+  parseJSON =+    withObject "GetShardIterator" $ \o →+      pure GetShardIterator+        ⊛ o .:? "SequenceNumber"+        ⊛ o .: "ShardId"+        ⊛ o .: "ShardIteratorType"+        ⊛ o .: "StreamId"++-- | A lens for '_gsiSequenceNumber'.+--+-- @+-- 'gsiSequenceNumber' ∷ Lens' 'GetShardIterator' ('Maybe' 'SequenceNumber')+-- @+--+gsiSequenceNumber+  ∷ Functor f+  ⇒ (Maybe SequenceNumber → f (Maybe SequenceNumber))+  → GetShardIterator+  → f GetShardIterator+gsiSequenceNumber i GetShardIterator{..} =+  (\_gsiSequenceNumber → GetShardIterator{..})+    <$> i _gsiSequenceNumber+{-# INLINE gsiSequenceNumber #-}++-- | A lens for '_gsiShardId'.+--+-- @+-- 'gsiShardId' ∷ Lens' 'GetShardIterator' 'ShardId'+-- @+--+gsiShardId+  ∷ Functor f+  ⇒ (ShardId → f ShardId)+  → GetShardIterator+  → f GetShardIterator+gsiShardId i GetShardIterator{..} =+  (\_gsiShardId → GetShardIterator{..})+    <$> i _gsiShardId+{-# INLINE gsiShardId #-}++-- | A lens for '_gsiShardIteratorType'.+--+-- @+-- 'gsiShardIteratorType' ∷ Lens' 'GetShardIterator' 'ShardIteratorType'+-- @+--+gsiShardIteratorType+  ∷ Functor f+  ⇒ (ShardIteratorType → f ShardIteratorType)+  → GetShardIterator+  → f GetShardIterator+gsiShardIteratorType i GetShardIterator{..} =+  (\_gsiShardIteratorType → GetShardIterator{..})+    <$> i _gsiShardIteratorType+{-# INLINE gsiShardIteratorType #-}++-- | A lens for '_gsiStreamId'.+--+-- @+-- 'gsiStreamId' ∷ Lens' 'GetShardIterator' 'StreamId'+-- @+--+gsiStreamId+  ∷ Functor f+  ⇒ (StreamId → f StreamId)+  → GetShardIterator+  → f GetShardIterator+gsiStreamId i GetShardIterator{..} =+  (\_gsiStreamId → GetShardIterator{..})+    <$> i _gsiStreamId+{-# INLINE gsiStreamId #-}++data GetShardIteratorResponse+  = GetShardIteratorResponse+  { _gsirShardIterator ∷ !ShardIterator+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON GetShardIteratorResponse where+  toJSON GetShardIteratorResponse{..} = object+    [ "ShardIterator" .= _gsirShardIterator+    ]++instance FromJSON GetShardIteratorResponse where+  parseJSON =+    withObject "GetShardIteratorResponse" $ \o →+      GetShardIteratorResponse+        <$> o .: "ShardIterator"++-- | A lens for '_gsirShardIterator'.+--+-- @+-- 'gsirShardIterator' ∷ Lens' 'GetShardIteratorResponse' 'ShardIterator'+-- @+--+gsirShardIterator+  ∷ Functor f+  ⇒ (ShardIterator → f ShardIterator)+  → GetShardIteratorResponse+  → f GetShardIteratorResponse+gsirShardIterator i GetShardIteratorResponse{..} =+  (\_gsirShardIterator → GetShardIteratorResponse{..})+    <$> i _gsirShardIterator+{-# INLINE gsirShardIterator #-}++instance ResponseConsumer r GetShardIteratorResponse where+  type ResponseMetadata GetShardIteratorResponse = StreamsMetadata+  responseConsumer _ = streamsResponseConsumer++instance SignQuery GetShardIterator where+  type ServiceConfiguration GetShardIterator = StreamsConfiguration+  signQuery cmd = streamsSignQuery StreamsQuery+    { _stqAction = ActionGetShardIterator+    , _stqBody = encode cmd+    }++instance Transaction GetShardIterator GetShardIteratorResponse++instance AsMemoryResponse GetShardIteratorResponse where+  type MemoryResponse GetShardIteratorResponse = GetShardIteratorResponse+  loadToMemory = return+

@@ -0,0 +1,242 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Commands.ListStreams+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE FlexibleInstances #-}+{-# LANGUAGE MultiParamTypeClasses #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Commands.ListStreams+( -- * Request+  ListStreams(..)+, listStreams+  -- ** Lenses+, lstExclusiveStartStreamId+, lstLimit+, lstTableName++  -- * Response+, ListStreamsResponse(..)++  -- ** Lenses+, lstrLastEvalutedStreamId+, lstrStreamIds+) where++import Aws.Core+import Aws.DynamoDb.Streams.Core+import Aws.DynamoDb.Streams.Types++import Control.Applicative+import Control.Applicative.Unicode+import Data.Aeson+import Data.Monoid+import Data.Typeable++import qualified Data.Text as T++data ListStreams+  = ListStreams+  { _lstExclusiveStartStreamId ∷ !(Maybe StreamId)+    -- ^ The stream ID of the first item that this operation will evaluate;+    -- also see '_lstrLastEvalutedStreamId'.++  , _lstLimit ∷ !(Maybe Int)+    -- ^ The maximum number of streams to return.++  , _lstTableName ∷ !(Maybe T.Text)+    -- ^ If this parameter is provided, then only the streams associated with+    -- this table are returned.++  } deriving (Eq, Ord, Show, Read, Typeable)+++instance ToJSON ListStreams where+  toJSON ListStreams{..} = object+    [ "ExclusiveStartStreamId" .= _lstExclusiveStartStreamId+    , "Limit" .= _lstLimit+    , "TableName" .= _lstTableName+    ]++instance FromJSON ListStreams where+  parseJSON =+    withObject "ListStreams" $ \o →+      pure ListStreams+        ⊛ o .:? "ExclusiveStartStreamId"+        ⊛ o .:? "Limit"+        ⊛ o .:? "TableName"+++instance Monoid ListStreams where+  mempty = listStreams+  ls `mappend` ls' = ListStreams+    { _lstExclusiveStartStreamId = _lstExclusiveStartStreamId ls <|> _lstExclusiveStartStreamId ls'+    , _lstLimit = _lstLimit ls <|> _lstLimit ls'+    , _lstTableName = _lstTableName ls <|> _lstTableName ls'+    }++-- | An empty 'ListStreams' request.+--+-- @+-- myRequest = 'listStreams' & 'lstTableName' ?~ "UsersTable"+-- @+--+listStreams ∷ ListStreams+listStreams = ListStreams+  { _lstExclusiveStartStreamId = Nothing+  , _lstLimit = Nothing+  , _lstTableName = Nothing+  }++-- | A lens for '_lstExclusiveStartStreamId'.+--+-- @+-- lstExclusiveStartStreamId ∷ Lens' 'ListStreams' ('Maybe' 'StreamId')+-- @+--+lstExclusiveStartStreamId+  ∷ Functor f+  ⇒ (Maybe StreamId → f (Maybe StreamId))+  → ListStreams+  → f ListStreams+lstExclusiveStartStreamId i ListStreams{..} =+  (\_lstExclusiveStartStreamId → ListStreams{..})+    <$> i _lstExclusiveStartStreamId+{-# INLINE lstExclusiveStartStreamId #-}++-- | A lens for '_lstlimit'.+--+-- @+-- lstLimit ∷ Lens' 'ListStreams' ('Maybe' 'Int')+-- @+--+lstLimit+  ∷ Functor f+  ⇒ (Maybe Int → f (Maybe Int))+  → ListStreams+  → f ListStreams+lstLimit i ListStreams{..} =+  (\_lstLimit → ListStreams{..})+    <$> i _lstLimit+{-# INLINE lstLimit #-}++-- | A lens for '_lstTableName'.+--+-- @+-- lstTableName ∷ Lens' 'ListStreams' ('Maybe' 'T.Text')+-- @+--+lstTableName+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → ListStreams+  → f ListStreams+lstTableName i ListStreams{..} =+  (\_lstTableName → ListStreams{..})+    <$> i _lstTableName+{-# INLINE lstTableName #-}+++data ListStreamsResponse+  = ListStreamsResponse+  { _lstrLastEvalutedStreamId ∷ !(Maybe StreamId)+    -- ^ When empty, this indicates that there are no more streams to be+    -- retrieved.++  , _lstrStreamIds ∷ ![StreamId]+    -- ^ A list of stream IDs associated with the current account and endpoint.+  } deriving (Eq, Ord, Read, Show, Typeable)++instance ToJSON ListStreamsResponse where+  toJSON ListStreamsResponse{..} = object+    [ "LastEvaluatedStreamId" .= _lstrLastEvalutedStreamId+    , "StreamIds" .= _lstrStreamIds+    ]++instance FromJSON ListStreamsResponse where+  parseJSON =+    withObject "ListStreamsResponse" $ \o →+      pure ListStreamsResponse+        ⊛ o .:? "LastEvaluatedStreamId"+        ⊛ o .:? "StreamIds" .!= []++-- | A lens for '_lstrLastEvalutedStreamId'.+--+-- @+-- lstrLastEvalutedStreamId ∷ Lens' 'ListStreamsResponse' ('Maybe' 'StreamId')+-- @+--+lstrLastEvalutedStreamId+  ∷ Functor f+  ⇒ (Maybe StreamId → f (Maybe StreamId))+  → ListStreamsResponse+  → f ListStreamsResponse+lstrLastEvalutedStreamId i ListStreamsResponse{..} =+  (\_lstrLastEvalutedStreamId → ListStreamsResponse{..})+    <$> i _lstrLastEvalutedStreamId+{-# INLINE lstrLastEvalutedStreamId #-}++-- | A lens for '_lstrStreamIds'.+--+-- @+-- lstrStreamIds ∷ Lens' 'ListStreamsResponse' ['StreamId']+-- @+--+lstrStreamIds+  ∷ Functor f+  ⇒ ([StreamId] → f [StreamId])+  → ListStreamsResponse+  → f ListStreamsResponse+lstrStreamIds i ListStreamsResponse{..} =+  (\_lstrStreamIds → ListStreamsResponse{..})+    <$> i _lstrStreamIds+{-# INLINE lstrStreamIds #-}++instance ResponseConsumer r ListStreamsResponse where+  type ResponseMetadata ListStreamsResponse = StreamsMetadata+  responseConsumer _ = streamsResponseConsumer++instance SignQuery ListStreams where+  type ServiceConfiguration ListStreams = StreamsConfiguration+  signQuery cmd = streamsSignQuery StreamsQuery+    { _stqAction = ActionListStreams+    , _stqBody = encode cmd+    }++instance Transaction ListStreams ListStreamsResponse++instance AsMemoryResponse ListStreamsResponse where+  type MemoryResponse ListStreamsResponse = ListStreamsResponse+  loadToMemory = return++instance ListResponse ListStreamsResponse StreamId where+  listResponse = _lstrStreamIds++instance IteratedTransaction ListStreams ListStreamsResponse where+  nextIteratedRequest req@ListStreams{..} ListStreamsResponse{..} = do+    lastEvaluatedStreamId ← _lstrLastEvalutedStreamId+    return req+      { _lstExclusiveStartStreamId = Just lastEvaluatedStreamId+      }

@@ -0,0 +1,593 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Core+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE LambdaCase #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE ScopedTypeVariables #-}+{-# LANGUAGE TupleSections #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Core+( StreamsAction(..)+, streamsActionToText+, parseStreamsAction+, streamsServiceEndpoint+, StreamsMetadata(..)+, stmAmzId2+, stmRequestId+, StreamsConfiguration(..)+, stcRegion+, StreamsQuery(..)+, stqAction+, stqBody+, streamsSignQuery+, StreamsResponseJsonErrorData(..)+, srjedMessage+, srjedJSON+, StreamsErrorResponse(..)+, _StreamsResponseJsonError+, _StreamsErrorResponse+, _StreamsOtherError+, StreamsErrorResponseData(..)+, sterdErrorCode+, sterdErrorMessage+, StreamsOtherErrorData(..)+, stoeStatus+, stoeMessage+, jsonResponseConsumer+, errorResponseConsumer+, streamsResponseConsumer+) where++import Aws.Core+import Aws.General++import Control.Applicative+import Control.Applicative.Unicode+import Control.Exception+import Control.Monad.Trans+import Crypto.Hash+import Data.Byteable+import qualified Data.ByteString as B+import qualified Data.ByteString.Base16 as B16+import qualified Data.ByteString.Char8 as B8+import qualified Data.ByteString.Lazy as LB+import Data.Aeson+import qualified Data.CaseInsensitive as CI+import Data.Conduit (($$+-))+import Data.Conduit.Binary (sinkLbs)+import Data.Function (on)+import Data.IORef+import Data.List+import Data.Maybe+import Data.Profunctor+import Data.String+import Data.Typeable+import Control.Monad.Trans.Resource (throwM)+import Data.Monoid+import Data.Monoid.Unicode+import qualified Data.Text as T+import qualified Data.Text.Encoding as T+import qualified Network.HTTP.Types as HTTP+import qualified Network.HTTP.Conduit as HTTP+import Prelude.Unicode+import qualified Text.Parser.Char as P+import qualified Text.Parser.Combinators as P+import Text.Parser.Combinators ((<?>))++streamsTargetVersion ∷ IsString a ⇒ a+streamsTargetVersion = "DynamoDBStreams_20120810"++data StreamsAction+  = ActionDescribeStream+  | ActionGetRecords+  | ActionGetShardIterator+  | ActionListStreams+  deriving (Eq, Ord, Enum, Bounded, Typeable, Read, Show)++-- | Render a 'StreamsAction' as a string for use in an AWS request.+--+streamsActionToText+  ∷ IsString s+  ⇒ StreamsAction+  → s+streamsActionToText = \case+  ActionDescribeStream → "DescribeStream"+  ActionGetRecords → "GetRecords"+  ActionGetShardIterator → "GetShardIterator"+  ActionListStreams → "ListStreams"++-- | Parse a 'StreamsAction'; this is the inverse of 'streamsActionToText'.+--+parseStreamsAction+  ∷ P.CharParsing m+  ⇒ m StreamsAction+parseStreamsAction = P.choice parsers <?> "StreamsAction"+  where+    actionToParser a =+      a <$ P.text (streamsActionToText a)++    parsers = actionToParser <$>+      [ ActionDescribeStream+      , ActionGetRecords+      , ActionGetShardIterator+      , ActionListStreams+      ]++instance AwsType StreamsAction where+  toText = streamsActionToText+  parse = parseStreamsAction++-- | Currently, only 'UsEast1' and 'EuWest1' are supported.+--+streamsServiceEndpoint+  ∷ Region+  → B8.ByteString+streamsServiceEndpoint = \case+  UsEast1 → "streams.preview-dynamodb.us-east-1.amazonaws.com"+  EuWest1 → "streams.preview-dynamodb.eu-west-1.amazonaws.com"+  region → error $ "Unsupported region: " ⊕ show region++data StreamsMetadata+  = StreamsMetadata+  { _stmAmzId2 ∷ !(Maybe T.Text)+  , _stmRequestId ∷ !(Maybe T.Text)+  } deriving (Eq, Show)++instance Loggable StreamsMetadata where+  toLogText StreamsMetadata{..} =+    "DynamoDb Streams: request ID="+      ⊕ fromMaybe "<none>" _stmRequestId+      ⊕ ", x-amz-id-2="+      ⊕ fromMaybe "<none>" _stmAmzId2++instance Monoid StreamsMetadata where+  mempty = StreamsMetadata+    { _stmAmzId2 = Nothing+    , _stmRequestId = Nothing+    }++  sm `mappend` sm' = StreamsMetadata+    { _stmAmzId2 = _stmAmzId2 sm <|> _stmAmzId2 sm'+    , _stmRequestId = _stmRequestId sm <|> _stmRequestId sm'+    }++-- | A lens for '_stmAmzId2'.+--+-- @+-- 'stmAmzId2' ∷ Lens' 'StreamsMetadata' ('Maybe' 'T.Text')+-- @+--+stmAmzId2+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → StreamsMetadata+  → f StreamsMetadata+stmAmzId2 i StreamsMetadata{..} =+  (\_stmAmzId2 → StreamsMetadata{..})+    <$> i _stmAmzId2+{-# INLINE stmAmzId2 #-}++-- | A lens for '_stmRequestId'.+--+-- @+-- 'stmRequestId' ∷ Lens' 'StreamsMetadata' ('Maybe' 'T.Text')+-- @+--+stmRequestId+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → StreamsMetadata+  → f StreamsMetadata+stmRequestId i StreamsMetadata{..} =+  (\_stmRequestId → StreamsMetadata{..})+    <$> i _stmRequestId+{-# INLINE stmRequestId #-}++data StreamsConfiguration qt+  = StreamsConfiguration+  { _stcRegion ∷ !Region+  } deriving (Eq, Show)++-- | A lens for '_stcRegion'.+--+-- @+-- 'stcRegion' ∷ Lens' 'StreamsConfiguration' 'Region'+-- @+--+stcRegion+  ∷ Functor f+  ⇒ (Region → f Region)+  → StreamsConfiguration qt+  → f (StreamsConfiguration qt)+stcRegion i StreamsConfiguration{..} =+  (\_stcRegion → StreamsConfiguration{..})+    <$> i _stcRegion+{-# INLINE stcRegion #-}++data StreamsQuery+  = StreamsQuery+  { _stqAction ∷ !StreamsAction+  , _stqBody ∷ !LB.ByteString+  } deriving (Eq, Show)++-- | A lens for '_stqAction'.+--+-- @+-- 'stqAction' ∷ Lens' 'StreamsQuery' 'StreamsAction'+-- @+--+stqAction+  ∷ Functor f+  ⇒ (StreamsAction → f StreamsAction)+  → StreamsQuery+  → f StreamsQuery+stqAction i StreamsQuery{..} =+  (\_stqAction → StreamsQuery{..})+    <$> i _stqAction+{-# INLINE stqAction #-}++-- | A lens for '_stqBody'.+--+-- @+-- 'stqBody' ∷ Lens' 'StreamsQuery' 'LB.ByteString'+-- @+--+stqBody+  ∷ Functor f+  ⇒ (LB.ByteString → f LB.ByteString)+  → StreamsQuery+  → f StreamsQuery+stqBody i StreamsQuery{..} =+  (\_stqBody → StreamsQuery{..})+    <$> i _stqBody+{-# INLINE stqBody #-}++streamsTargetHeader+  ∷ StreamsAction+  → HTTP.Header+streamsTargetHeader a =+  ( "X-Amz-Target"+  , streamsTargetVersion ⊕ "." ⊕ toText a+  )++-- | Creates a signed query.+--+-- Uses AWS Signature V4. All requests are POST requests+-- with the signature placed in an HTTP header+--+streamsSignQuery+  ∷ StreamsQuery+  → StreamsConfiguration qt+  → SignatureData+  → SignedQuery+streamsSignQuery StreamsQuery{..} StreamsConfiguration{..} sigData = SignedQuery+  { sqMethod = Post+  , sqProtocol = HTTP+  , sqHost = host+  , sqPort = 80+  , sqPath = "/"+  , sqQuery = []+  , sqDate = Just $ signatureTime sigData+  , sqAuthorization = Just auth+  , sqContentType = Just "application/x-amz-json-1.0"+  , sqContentMd5 = Nothing+  , sqAmzHeaders = amzHeaders ⊕ maybe [] pure securityTokenHeader+  , sqOtherHeaders = []+  , sqBody = Just $ HTTP.RequestBodyLBS _stqBody+  , sqStringToSign = canonicalRequest+  }+    where+      credentials = signatureCredentials sigData+      host = streamsServiceEndpoint _stcRegion+      sigTime = fmtTime "%Y%m%dT%H%M%SZ" $ signatureTime sigData++      -- for some reason AWS doesn't want the x-amz-security-token in the canonical request+      amzHeaders =+        [ ("x-amz-date", sigTime)+        , streamsTargetHeader _stqAction+        ]++      securityTokenHeader =+        ("x-amz-security-token",)+          <$> iamToken credentials++      canonicalHeaders =+        sortBy (compare `on` fst) $+          amzHeaders ⊕+            [ ("host", host)+            , ("content-type", "application/x-amz-json-1.0")+            ]++      canonicalRequest =+        let bodyHash = B16.encode $ toBytes (hashlazy _stqBody :: Digest SHA256)+            headers =+              flip fmap canonicalHeaders $ \(a,b) →+                [ CI.foldedCase a+                , ":"+                , b+                ]+        in+          B.concat ∘ intercalate ["\n"] $+            [ [ "POST" ]+            , [ "/" ]+            , [] -- query string+            ] ⊕ headers ⊕+              [ [] -- end headers+              , intersperse ";" ((CI.foldedCase ∘ fst) <$> canonicalHeaders)+              , [ bodyHash ]+              ]++      auth =+        authorizationV4+          sigData+          HmacSHA256+          (regionToText _stcRegion)+          "dynamodb"+          "content-type;host;x-amz-date;x-amz-target"+          canonicalRequest+++data StreamsErrorResponseData+  = StreamsErrorResponseData+  { _sterdErrorCode ∷ !T.Text+  , _sterdErrorMessage ∷ !T.Text+  } deriving (Eq, Show, Typeable)++-- | A lens for '_sterdErrorCode'.+--+-- @+-- 'sterdErrorCode' ∷ Lens' 'StreamsErrorResponseData' 'T.Text'+-- @+--+sterdErrorCode+  ∷ Functor f+  ⇒ (T.Text → f T.Text)+  → StreamsErrorResponseData+  → f StreamsErrorResponseData+sterdErrorCode i StreamsErrorResponseData{..} =+  (\_sterdErrorCode → StreamsErrorResponseData{..})+    <$> i _sterdErrorCode+{-# INLINE sterdErrorCode #-}++-- | A lens for '_sterdErrorMessage'.+--+-- @+-- 'sterdErrorMessage' ∷ Lens' 'StreamsErrorResponseData' 'T.Text'+-- @+--+sterdErrorMessage+  ∷ Functor f+  ⇒ (T.Text → f T.Text)+  → StreamsErrorResponseData+  → f StreamsErrorResponseData+sterdErrorMessage i StreamsErrorResponseData{..} =+  (\_sterdErrorMessage → StreamsErrorResponseData{..})+    <$> i _sterdErrorMessage+{-# INLINE sterdErrorMessage #-}++data StreamsOtherErrorData+  = StreamsOtherErrorData+  { _stoeStatus ∷ !HTTP.Status+  , _stoeMessage ∷ !T.Text+  } deriving (Eq, Show, Typeable)++-- | A lens for '_stoeStatus'+--+-- @+-- 'stoeStatus' ∷ Lens' 'StreamsOtherErrorData' 'HTTP.Status'+-- @+--+stoeStatus+  ∷ Functor f+  ⇒ (HTTP.Status → f HTTP.Status)+  → StreamsOtherErrorData+  → f StreamsOtherErrorData+stoeStatus i StreamsOtherErrorData{..} =+  (\_stoeStatus → StreamsOtherErrorData{..})+    <$> i _stoeStatus+{-# INLINE stoeStatus #-}++-- | A lens for '_stoeMessage'+--+-- @+-- 'stoeMessage' ∷ Lens' 'StreamsOtherErrorData' 'T.Text'+-- @+--+stoeMessage+  ∷ Functor f+  ⇒ (T.Text → f T.Text)+  → StreamsOtherErrorData+  → f StreamsOtherErrorData+stoeMessage i StreamsOtherErrorData{..} =+  (\_stoeMessage → StreamsOtherErrorData{..})+    <$> i _stoeMessage+{-# INLINE stoeMessage #-}++data StreamsResponseJsonErrorData+  = StreamsResponseJsonErrorData+  { _srjedMessage ∷ !T.Text+  , _srjedJSON ∷ !LB.ByteString+  } deriving (Eq, Show, Typeable)++-- | A lens for '_srjedMessage'.+--+-- @+-- 'srjedMessage' ∷ Lens' 'StreamsResponseJsonErrorData' 'T.Text'+-- @+srjedMessage+  ∷ Functor f+  ⇒ (T.Text → f T.Text)+  → StreamsResponseJsonErrorData+  → f StreamsResponseJsonErrorData+srjedMessage i StreamsResponseJsonErrorData{..} =+  (\_srjedMessage → StreamsResponseJsonErrorData{..})+    <$> i _srjedMessage++-- | A lens for '_srjedJSON'.+--+-- @+-- 'srjedJSON' ∷ Lens' 'StreamsResponseJsonErrorData' 'LB.ByteString'+-- @+srjedJSON+  ∷ Functor f+  ⇒ (LB.ByteString → f LB.ByteString)+  → StreamsResponseJsonErrorData+  → f StreamsResponseJsonErrorData+srjedJSON i StreamsResponseJsonErrorData{..} =+  (\_srjedJSON → StreamsResponseJsonErrorData{..})+    <$> i _srjedJSON++data StreamsErrorResponse+  = StreamsResponseJsonError StreamsResponseJsonErrorData+  | StreamsErrorResponse StreamsErrorResponseData+  | StreamsOtherError StreamsOtherErrorData+  deriving (Eq, Show, Typeable)++-- | A prism for 'StreamsResponseJsonError'.+--+-- @+-- '_StreamsResponseJsonError' ∷ Prism' 'StreamsErrorResponse' 'StreamsResponseJsonErrorData'+-- @+_StreamsResponseJsonError+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p StreamsResponseJsonErrorData (f StreamsResponseJsonErrorData)+  → p StreamsErrorResponse (f StreamsErrorResponse)+_StreamsResponseJsonError =+  dimap to fro ∘ right'+    where+      to = \case+        StreamsResponseJsonError e → Right e+        e → Left e+      fro = either pure (fmap StreamsResponseJsonError)+{-# INLINE _StreamsResponseJsonError #-}++-- | A prism for 'StreamsErrorResponse'.+--+-- @+-- '_StreamsErrorResponse' ∷ Prism' 'StreamsErrorResponse' 'StreamsErrorResponseData'+-- @+_StreamsErrorResponse+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p StreamsErrorResponseData (f StreamsErrorResponseData)+  → p StreamsErrorResponse (f StreamsErrorResponse)+_StreamsErrorResponse =+  dimap to fro ∘ right'+    where+      to = \case+        StreamsErrorResponse e → Right e+        e → Left e+      fro = either pure (fmap StreamsErrorResponse)+{-# INLINE _StreamsErrorResponse #-}++-- | A prism for 'StreamsOtherError'.+--+-- @+-- '_StreamsOtherError' ∷ Prism' 'StreamsErrorResponse' 'StreamsOtherErrorData'+-- @+_StreamsOtherError+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p StreamsOtherErrorData (f StreamsOtherErrorData)+  → p StreamsErrorResponse (f StreamsErrorResponse)+_StreamsOtherError =+  dimap to fro ∘ right'+    where+      to = \case+        StreamsOtherError e → Right e+        e → Left e+      fro = either pure (fmap StreamsOtherError)+{-# INLINE _StreamsOtherError #-}++instance Exception StreamsErrorResponse++-- | This instance captures only the 'StreamsErrorResponse' constructor+--+instance FromJSON StreamsErrorResponse where+  parseJSON =+    withObject "StreamsErrorResponse" $ \o →+      fmap StreamsErrorResponse $+        pure StreamsErrorResponseData+          ⊛ o .: "__type"+          ⊛ o .: "message"+++-- | Create a complete 'HTTPResponseConsumer' for response types with an+-- 'FromJSON' instance+--+jsonResponseConsumer+  ∷ FromJSON α+  ⇒ HTTPResponseConsumer α+jsonResponseConsumer res = do+  doc ← HTTP.responseBody res $$+- sinkLbs+  case eitherDecode (if doc ≡ mempty then "{}" else doc) of+    Left e → throwM $ StreamsResponseJsonError StreamsResponseJsonErrorData+      { _srjedMessage = T.pack e+      , _srjedJSON = doc+      }+    Right v → return v+++streamsResponseConsumer+  ∷ FromJSON a+  ⇒ IORef StreamsMetadata+  → HTTPResponseConsumer a+streamsResponseConsumer metadata resp = do++  let headerString = fmap T.decodeUtf8 ∘ flip lookup (HTTP.responseHeaders resp)+      amzId2 = headerString "x-amz-id-2"+      requestId = headerString "x-amz-request-id"++  liftIO $ tellMetadataRef metadata StreamsMetadata+    { _stmAmzId2 = amzId2+    , _stmRequestId = requestId+    }++  if HTTP.responseStatus resp ≥ HTTP.status400+    then errorResponseConsumer resp+    else jsonResponseConsumer resp++errorResponseConsumer ∷ HTTPResponseConsumer a+errorResponseConsumer resp = do+  doc ← HTTP.responseBody resp $$+- sinkLbs+  if HTTP.responseStatus resp ≡ HTTP.status400+    then kinesisError doc+    else throwM $ StreamsOtherError StreamsOtherErrorData+        { _stoeStatus = HTTP.responseStatus resp+        , _stoeMessage = T.decodeUtf8 $ LB.toStrict doc+        }+  where+    kinesisError doc =+      case eitherDecode doc of+        Left e → throwM $ StreamsResponseJsonError StreamsResponseJsonErrorData+          { _srjedMessage = T.pack e+          , _srjedJSON = doc+          }+        Right a → throwM (a ∷ StreamsErrorResponse)+

@@ -0,0 +1,1637 @@+-- Copyright (c) 2013-2014 PivotCloud, Inc.+--+-- Aws.DynamoDb.Streams.Types+--+-- Please feel free to contact us at licensing@pivotmail.com with any+-- contributions, additions, or other feedback; we would love to hear from+-- you.+--+-- Licensed under the Apache License, Version 2.0 (the "License"); you may+-- not use this file except in compliance with the License. You may obtain a+-- copy of the License at http://www.apache.org/licenses/LICENSE-2.0+--+-- Unless required by applicable law or agreed to in writing, software+-- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT+-- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the+-- License for the specific language governing permissions and limitations+-- under the License.++{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE LambdaCase #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE UnicodeSyntax #-}++-- |+-- Copyright: Copyright (c) 2013-2014 PivotCloud, Inc.+-- License: Apache-2.0+--+module Aws.DynamoDb.Streams.Types+( -- * Sequence Numbers+  SequenceNumber+, SequenceNumberRange(..)+, sqnrStartingSequenceNumber+, sqnrEndingSequenceNumber++  -- * Shards+, ShardId+, Shard(..)+  -- ** Lenses+, shShardId+, shParentShardId+, shSequenceNumberRange++  -- * Shard Iterators+, ShardIterator+, ShardIteratorType(..)+  -- ** Prisms+, _ShardIteratorTrimHorizon+, _ShardIteratorLatest+, _ShardIteratorAtSequenceNumber+, _ShardIteratorAfterSequenceNumber++  -- * Attribute Values+, AttributeValue(..)+  -- ** Prisms+, _AVBin+, _AVBool+, _AVBinSet+, _AVList+, _AVMap+, _AVNum+, _AVNumSet+, _AVNull+, _AVString+, _AVStringSet++  -- * Key Schemas+  -- ** Key Types+, KeyType(..)+, keyTypeToText+  -- *** Prisms+, _KeyTypeHash+, _KeyTypeRange+  -- ** Key Schema Elements+, KeySchemaElement(..)+  -- *** Lenses+, kseAttributeName+, kseKeyType++  -- * Records+  -- ** Stream View Types+, StreamViewType(..)++  -- *** Prisms+, _StreamViewKeysOnly+, _StreamViewNewImage+, _StreamViewOldImage+, _StreamViewNewAndOldImages++  -- ** Stream Records+, StreamRecord(..)++  -- *** Lenses+, strKeys+, strNewImage+, strOldImage+, strSequenceNumber+, strSizeBytes+, strStreamViewType++  -- ** Event Names+, EventName(..)++  -- *** Prisms+, _EventInsert+, _EventModify+, _EventRemove++  -- ** Records+, Record(..)++  -- *** Lenses+, rAwsRegion+, rStreamRecord+, rEventId+, rEventName+, rEventSource+, rEventVersion+++  -- * Stream Metadata+  -- ** Stream Statuses+, StreamStatus(..)++  --- *** Prisms+, _StatusEnabling+, _StatusEnabled+, _StatusDisabling+, _StatusDisabled++  -- ** Stream Description+, StreamId+, StreamDescription(..)+  -- *** Lenses+, sdCreationRequestDateTime+, sdKeySchema+, sdLastEvaluatedShardId+, sdShards+, sdStreamARN+, sdStreamId+, sdStreamStatus+, sdStreamViewType+, sdTableName+) where++import Aws.General+import Control.Applicative+import Control.Applicative.Unicode+import Control.Monad.Unicode+import Data.Aeson+import Data.Aeson.Types+import qualified Data.Attoparsec.Text as Atto+import qualified Data.ByteString as B+import qualified Data.ByteString.Base64 as B64+import Data.Foldable (asum)+import qualified Data.Map as M+import Data.Monoid.Unicode+import Data.Profunctor+import Data.Scientific+import qualified Data.Set as S+import Data.String+import qualified Data.Text as T+import qualified Data.Text.Encoding as T+import Data.Time+import Data.Time.Clock.POSIX+import Data.Traversable hiding (mapM)+import Data.Typeable+import Prelude.Unicode++-- | Identifier for a shard.+--+-- Length constraints: @28 ≤ n ≤ 65@.+--+newtype ShardId+  = ShardId+  { _sidText ∷ T.Text+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON ShardId where+  toJSON = toJSON ∘ _sidText++instance FromJSON ShardId where+  parseJSON =+    withText "ShardId" $+      pure ∘ ShardId++-- | Identifier for a record.+--+-- Length constraints: @21 ≤ n ≤ 40@+--+newtype SequenceNumber+  = SequenceNumber+  { _sqnText ∷ T.Text+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON SequenceNumber where+  toJSON = toJSON ∘ _sqnText++instance FromJSON SequenceNumber where+  parseJSON =+    withText "SequenceNumber" $+      pure ∘ SequenceNumber++-- | The beginning and ending sequence numbers for the stream records contained+-- within a shard.+--+data SequenceNumberRange+  = SequenceNumberRange+  { _sqnrStartingSequenceNumber ∷ !(Maybe SequenceNumber)+  , _sqnrEndingSequenceNumber ∷ !(Maybe SequenceNumber)+  } deriving (Eq, Ord, Typeable, Show, Read)++-- | A lens for '_sqnrStartingSequenceNumber'.+--+-- @+-- 'sqnrStartingSequenceNumber' ∷ Lens' 'SequenceNumberRange' ('Maybe' 'SequenceNumber')+-- @+--+sqnrStartingSequenceNumber+  ∷ Functor f+  ⇒ (Maybe SequenceNumber → f (Maybe SequenceNumber))+  → SequenceNumberRange+  → f SequenceNumberRange+sqnrStartingSequenceNumber i SequenceNumberRange{..} =+  (\_sqnrStartingSequenceNumber → SequenceNumberRange{..})+    <$> i _sqnrStartingSequenceNumber+{-# INLINE sqnrStartingSequenceNumber #-}++-- | A lens for '_sqnrEndingSequenceNumber'.+--+-- @+-- 'sqnrEndingSequenceNumber' ∷ Lens' 'SequenceNumberRange' ('Maybe' 'SequenceNumber')+-- @+--+sqnrEndingSequenceNumber+  ∷ Functor f+  ⇒ (Maybe SequenceNumber → f (Maybe SequenceNumber))+  → SequenceNumberRange+  → f SequenceNumberRange+sqnrEndingSequenceNumber i SequenceNumberRange{..} =+  (\_sqnrEndingSequenceNumber → SequenceNumberRange{..})+    <$> i _sqnrEndingSequenceNumber+{-# INLINE sqnrEndingSequenceNumber #-}++instance ToJSON SequenceNumberRange where+  toJSON SequenceNumberRange{..} = object+    [ "StartingSequenceNumber" .= _sqnrStartingSequenceNumber+    , "EndingSequenceNumber" .= _sqnrEndingSequenceNumber+    ]++instance FromJSON SequenceNumberRange where+  parseJSON =+    withObject "SequenceNumberRange" $ \o →+      pure SequenceNumberRange+        ⊛ o .:? "StartingSequenceNumber"+        ⊛ o .:? "EndingSequenceNumber"++-- | A uniquely identified group of stream records within a stream.+--+data Shard+  = Shard+  { _shShardId ∷ !(Maybe ShardId)+    -- ^ The system-generated identifier for this shard+  , _shParentShardId ∷ !(Maybe ShardId)+    -- ^ The shard ID of this shard's parent+  , _shSequenceNumberRange ∷ !(Maybe SequenceNumberRange)+  -- ^ The range of possible sequence numbers for this shard+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON Shard where+  toJSON Shard{..} = object+    [ "ShardId" .= _shShardId+    , "ParentShardId" .= _shParentShardId+    , "SequenceNumberRange" .= _shSequenceNumberRange+    ]++instance FromJSON Shard where+  parseJSON =+    withObject "Shard" $ \o →+      pure Shard+        ⊛ o .:? "ShardId"+        ⊛ o .:? "ParentShardId"+        ⊛ o .:? "SequenceNumberRange"++-- | A lens for '_shShardId'.+--+-- @+-- 'shshardId' ∷ Lens' 'Shard' ('Maybe' 'ShardId')+-- @+--+shShardId+  ∷ Functor f+  ⇒ (Maybe ShardId → f (Maybe ShardId))+  → Shard+  → f Shard+shShardId i Shard{..} =+  (\_shShardId → Shard{..})+    <$> i _shShardId+{-# INLINE shShardId #-}++-- | A lens for '_shParentShardId'.+--+-- @+-- 'shParentShardId' ∷ Lens' 'Shard' ('Maybe' 'ShardId')+-- @+--+shParentShardId+  ∷ Functor f+  ⇒ (Maybe ShardId → f (Maybe ShardId))+  → Shard+  → f Shard+shParentShardId i Shard{..} =+  (\_shParentShardId → Shard{..})+    <$> i _shParentShardId+{-# INLINE shParentShardId #-}++-- | A lens for '_shSequenceNumberRange'.+--+-- @+-- 'shSequenceNumberRange' ∷ Lens' 'Shard' ('Maybe' 'SequenceNumberRange')+-- @+--+shSequenceNumberRange+  ∷ Functor f+  ⇒ (Maybe SequenceNumberRange → f (Maybe SequenceNumberRange))+  → Shard+  → f Shard+shSequenceNumberRange i Shard{..} =+  (\_shSequenceNumberRange → Shard{..})+    <$> i _shSequenceNumberRange+{-# INLINE shSequenceNumberRange #-}++-- | Represents the data for an attribute.+--+data AttributeValue+  = AVBin !B.ByteString+    -- ^ Binary data will automatically be base64 marshalled+  | AVBool !Bool+  | AVBinSet !(S.Set B.ByteString)+    -- ^ Binary data will automatically be base64 marshalled+  | AVList ![AttributeValue]+  | AVMap !(M.Map T.Text AttributeValue)+  | AVNum !Scientific+  | AVNumSet !(S.Set Scientific)+  | AVNull !Bool -- TODO: why is this 'Bool'?+  | AVString !T.Text+  | AVStringSet !(S.Set T.Text)+  deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON AttributeValue where+  toJSON = \case+    AVBin b → object ["B" .= T.decodeUtf8 (B64.encode b)]+    AVBinSet bs → object ["BS" .= (T.decodeUtf8 ∘ B64.encode <$> S.toList bs)]+    AVBool b → object ["BOOL" .= b]+    AVList xs → object ["L" .= xs]+    AVMap xs → object ["M" .= xs]+    AVNum n → object ["N" .= T.pack (show n)]+    AVNumSet ns → object ["NS" .= (T.pack ∘ show <$> S.toList ns)]+    AVString s → object ["S" .= s]+    AVNull b → object ["NULL" .= b]+    AVStringSet ss → object ["SS" .= S.toList ss]++instance FromJSON AttributeValue where+  parseJSON =+    withObject "AttributeValue" $ \o → asum+      [ fmap AVBin ∘ parseBin =≪ o .: "B"+      , fmap (AVBinSet ∘ S.fromList) ∘ mapM parseBin =≪ o .: "BS"+      , AVBool <$> o .: "BOOL"+      , AVList <$> o .: "L"+      , AVMap <$> o .: "M"+      , fmap AVNum ∘ parseScientific =≪ o .: "N"+      , fmap (AVNumSet ∘ S.fromList) ∘ mapM parseScientific =≪ o .: "NS"+      , AVString <$> o.: "S"+      , AVStringSet ∘ S.fromList <$> o .: "SS"+      , AVNull <$> o .: "NULL"+      ]++    where+      parseBin =+        either (fail ∘ ("parseBin failed: " ⊕)) pure+          ∘ B64.decode+          ∘ T.encodeUtf8++      parseScientific (String str) =+        either (fail ∘ ("parseScientific failed: " ⊕)) pure $+          Atto.parseOnly Atto.scientific str+      parseScientific (Number n) = pure n+      parseScientific _ = fail "Unexpected JSON type in parseScientific"++++-- | A prism for 'AVBin'.+--+-- @+-- '_AVBin' ∷ Prism' 'AttributeValue' 'B.ByteString'+-- @+_AVBin+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p B.ByteString (f B.ByteString)+  → p AttributeValue (f AttributeValue)+_AVBin =+  dimap to fro ∘ right'+    where+      to = \case+        AVBin e → Right e+        e → Left e+      fro = either pure (fmap AVBin)+{-# INLINE _AVBin #-}++-- | A prism for 'AVBool'.+--+-- @+-- '_AVBool' ∷ Prism' 'AttributeValue' 'Bool'+-- @+_AVBool+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p Bool (f Bool)+  → p AttributeValue (f AttributeValue)+_AVBool =+  dimap to fro ∘ right'+    where+      to = \case+        AVBool e → Right e+        e → Left e+      fro = either pure (fmap AVBool)+{-# INLINE _AVBool #-}++-- | A prism for 'AVBinSet'.+--+-- @+-- '_AVBinSet' ∷ Prism' 'AttributeValue' ('S.Set' 'B.ByteString')+-- @+_AVBinSet+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p (S.Set B.ByteString) (f (S.Set B.ByteString))+  → p AttributeValue (f AttributeValue)+_AVBinSet =+  dimap to fro ∘ right'+    where+      to = \case+        AVBinSet e → Right e+        e → Left e+      fro = either pure (fmap AVBinSet)+{-# INLINE _AVBinSet #-}++-- | A prism for 'AVList'.+--+-- @+-- '_AVList' ∷ Prism' 'AttributeValue' ['AttributeValue']+-- @+_AVList+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p [AttributeValue] (f [AttributeValue])+  → p AttributeValue (f AttributeValue)+_AVList =+  dimap to fro ∘ right'+    where+      to = \case+        AVList e → Right e+        e → Left e+      fro = either pure (fmap AVList)+{-# INLINE _AVList #-}++-- | A prism for 'AVMap'.+--+-- @+-- '_AVMap' ∷ Prism' 'AttributeValue' ('M.Map' 'T.Text' 'AttributeValue')+-- @+_AVMap+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p (M.Map T.Text AttributeValue) (f (M.Map T.Text AttributeValue))+  → p AttributeValue (f AttributeValue)+_AVMap =+  dimap to fro ∘ right'+    where+      to = \case+        AVMap e → Right e+        e → Left e+      fro = either pure (fmap AVMap)+{-# INLINE _AVMap #-}++-- | A prism for 'AVNum'.+--+-- @+-- '_AVNum' ∷ Prism' 'AttributeValue' 'Scientific'+-- @+_AVNum+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p Scientific (f Scientific)+  → p AttributeValue (f AttributeValue)+_AVNum =+  dimap to fro ∘ right'+    where+      to = \case+        AVNum e → Right e+        e → Left e+      fro = either pure (fmap AVNum)+{-# INLINE _AVNum #-}++-- | A prism for 'AVNumSet'.+--+-- @+-- '_AVNumSet' ∷ Prism' 'AttributeValue' ('S.Set' 'Scientific')+-- @+_AVNumSet+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p (S.Set Scientific) (f (S.Set Scientific))+  → p AttributeValue (f AttributeValue)+_AVNumSet =+  dimap to fro ∘ right'+    where+      to = \case+        AVNumSet e → Right e+        e → Left e+      fro = either pure (fmap AVNumSet)+{-# INLINE _AVNumSet #-}++-- | A prism for 'AVNull'.+--+-- @+-- '_AVNull' ∷ Prism' 'AttributeValue' 'Bool'+-- @+_AVNull+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p Bool (f Bool)+  → p AttributeValue (f AttributeValue)+_AVNull =+  dimap to fro ∘ right'+    where+      to = \case+        AVNull e → Right e+        e → Left e+      fro = either pure (fmap AVNull)+{-# INLINE _AVNull #-}++-- | A prism for 'AVString'.+--+-- @+-- '_AVString' ∷ Prism' 'AttributeValue' 'T.Text'+-- @+_AVString+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p T.Text (f T.Text)+  → p AttributeValue (f AttributeValue)+_AVString =+  dimap to fro ∘ right'+    where+      to = \case+        AVString e → Right e+        e → Left e+      fro = either pure (fmap AVString)+{-# INLINE _AVString #-}++-- | A prism for 'AVStringSet'.+--+-- @+-- '_AVStringSet' ∷ Prism' 'AttributeValue' ('S.Set' 'T.Text')+-- @+_AVStringSet+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p (S.Set T.Text) (f (S.Set T.Text))+  → p AttributeValue (f AttributeValue)+_AVStringSet =+  dimap to fro ∘ right'+    where+      to = \case+        AVStringSet e → Right e+        e → Left e+      fro = either pure (fmap AVStringSet)+{-# INLINE _AVStringSet #-}++data KeyType+  = KeyTypeHash+  | KeyTypeRange+  deriving (Eq, Ord, Enum, Show, Read, Typeable)++keyTypeToText+  ∷ IsString s+  ⇒ KeyType+  → s+keyTypeToText = \case+  KeyTypeHash → "HASH"+  KeyTypeRange → "RANGE"++instance ToJSON KeyType where+  toJSON = keyTypeToText++instance FromJSON KeyType where+  parseJSON =+    parseEnum "KeyType" keyTypeToText+      [ KeyTypeHash+      , KeyTypeRange+      ]++parseEnum+  ∷ String+  → (α → T.Text)+  → [α]+  → Value+  → Parser α+parseEnum name render opts =+  withText name $ \str →+    asum $ parser str <$> opts++  where+    parser str o =+      o <$ if render o ≡ str+        then pure o+        else empty++-- | A prism for 'KeyTypeHash'.+--+-- @+-- '_KeyTypeHash' ∷ Prism' 'KeyType' ()+-- @+_KeyTypeHash+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p KeyType (f KeyType)+_KeyTypeHash =+  dimap to fro ∘ right'+    where+      to = \case+        KeyTypeHash → Right ()+        e → Left e+      fro = either pure (const $ pure KeyTypeHash)+{-# INLINE _KeyTypeHash #-}++-- | A prism for 'KeyTypeRange'.+--+-- @+-- '_KeyTypeRange' ∷ Prism' 'KeyType' ()+-- @+_KeyTypeRange+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p KeyType (f KeyType)+_KeyTypeRange =+  dimap to fro ∘ right'+    where+      to = \case+        KeyTypeRange → Right ()+        e → Left e+      fro = either pure (const $ pure KeyTypeRange)+{-# INLINE _KeyTypeRange #-}+++data KeySchemaElement+  = KeySchemaElement+  { _kseAttributeName ∷ !T.Text+  , _kseKeyType ∷ !KeyType+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON KeySchemaElement where+  toJSON KeySchemaElement{..} = object+    [ "AttributeName" .= _kseAttributeName+    , "KeyType" .= _kseKeyType+    ]++instance FromJSON KeySchemaElement where+  parseJSON =+    withObject "KeySchemaElement" $ \o →+      pure KeySchemaElement+        ⊛ o .: "AttributeName"+        ⊛ o .: "KeyType"++-- | A lens for '_kseAttributeName'.+--+-- @+-- 'kseAttributeName' ∷ Lens' 'KeySchemaElement' 'T.Text'+-- @+--+kseAttributeName+  ∷ Functor f+  ⇒ (T.Text → f T.Text)+  → KeySchemaElement+  → f KeySchemaElement+kseAttributeName i KeySchemaElement{..} =+  (\_kseAttributeName → KeySchemaElement{..})+    <$> i _kseAttributeName+{-# INLINE kseAttributeName #-}++-- | A lens for '_kseKeyType'.+--+-- @+-- 'kseKeyType' ∷ Lens' 'KeySchemaElement' 'KeyType'+-- @+--+kseKeyType+  ∷ Functor f+  ⇒ (KeyType → f KeyType)+  → KeySchemaElement+  → f KeySchemaElement+kseKeyType i KeySchemaElement{..} =+  (\_kseKeyType → KeySchemaElement{..})+    <$> i _kseKeyType+{-# INLINE kseKeyType #-}+++data StreamViewType+  = StreamViewKeysOnly+    -- ^ only the key attributes of the modified item+  | StreamViewNewImage+    -- ^ the entire item, as it appears after it was modified+  | StreamViewOldImage+    -- ^ the entire item, as it appeared before it was modified+  | StreamViewNewAndOldImages+    -- ^ both the new and the old images of the item+  deriving (Eq, Ord, Enum, Show, Read, Typeable)++streamViewTypeToText+  ∷ IsString s+  ⇒ StreamViewType+  → s+streamViewTypeToText = \case+  StreamViewKeysOnly → "KEYS_ONLY"+  StreamViewNewImage → "NEW_IMAGE"+  StreamViewOldImage → "OLD_IMAGE"+  StreamViewNewAndOldImages → "NEW_AND_OLD_IMAGES"++instance ToJSON StreamViewType where+  toJSON = streamViewTypeToText++instance FromJSON StreamViewType where+  parseJSON =+    parseEnum "StreamViewType" streamViewTypeToText+      [ StreamViewKeysOnly+      , StreamViewNewImage+      , StreamViewOldImage+      , StreamViewNewAndOldImages+      ]++-- | A prism for 'StreamViewKeysOnly'.+--+-- @+-- '_StreamViewKeysOnly' ∷ Prism' 'StreamViewType' ()+-- @+_StreamViewKeysOnly+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamViewType (f StreamViewType)+_StreamViewKeysOnly =+  dimap to fro ∘ right'+    where+      to = \case+        StreamViewKeysOnly → Right ()+        e → Left e+      fro = either pure (const $ pure StreamViewKeysOnly)+{-# INLINE _StreamViewKeysOnly #-}++-- | A prism for 'StreamViewNewImage'.+--+-- @+-- '_StreamViewNewImage' ∷ Prism' 'StreamViewType' ()+-- @+_StreamViewNewImage+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamViewType (f StreamViewType)+_StreamViewNewImage =+  dimap to fro ∘ right'+    where+      to = \case+        StreamViewNewImage → Right ()+        e → Left e+      fro = either pure (const $ pure StreamViewNewImage)+{-# INLINE _StreamViewNewImage #-}++-- | A prism for 'StreamViewOldImage'.+--+-- @+-- '_StreamViewOldImage' ∷ Prism' 'StreamViewType' ()+-- @+_StreamViewOldImage+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamViewType (f StreamViewType)+_StreamViewOldImage =+  dimap to fro ∘ right'+    where+      to = \case+        StreamViewOldImage → Right ()+        e → Left e+      fro = either pure (const $ pure StreamViewOldImage)+{-# INLINE _StreamViewOldImage #-}++-- | A prism for 'StreamViewNewAndOldImages'.+--+-- @+-- '_StreamViewNewAndOldImages' ∷ Prism' 'StreamViewType' ()+-- @+_StreamViewNewAndOldImages+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamViewType (f StreamViewType)+_StreamViewNewAndOldImages =+  dimap to fro ∘ right'+    where+      to = \case+        StreamViewNewAndOldImages → Right ()+        e → Left e+      fro = either pure (const $ pure StreamViewNewAndOldImages)+{-# INLINE _StreamViewNewAndOldImages #-}++data StreamRecord+  = StreamRecord+  { _strKeys ∷ !(Maybe (M.Map T.Text AttributeValue))+  , _strNewImage ∷ !(Maybe (M.Map T.Text AttributeValue))+  , _strOldImage ∷ !(Maybe (M.Map T.Text AttributeValue))+  , _strSequenceNumber ∷ !(Maybe SequenceNumber)+  , _strSizeBytes ∷ !(Maybe Integer)+  , _strStreamViewType ∷ !(Maybe StreamViewType)+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON StreamRecord where+  toJSON StreamRecord{..} = object+    [ "Keys" .= _strKeys+    , "NewImage" .= _strNewImage+    , "OldImage" .= _strOldImage+    , "SequenceNumber" .= _strSequenceNumber+    , "SizeBytes" .= _strSizeBytes+    , "StreamViewType" .= _strStreamViewType+    ]++instance FromJSON StreamRecord where+  parseJSON =+    withObject "StreamRecord" $ \o →+      pure StreamRecord+        ⊛ o .:? "Keys"+        ⊛ o .:? "NewImage"+        ⊛ o .:? "OldImage"+        ⊛ o .:? "SequenceNumber"+        ⊛ o .:? "SizeBytes"+        ⊛ o .:? "StreamViewType"++-- | A lens for '_strKeys'.+--+-- @+-- 'strKeys' ∷ Lens' 'StreamRecord' ('Maybe' ('M.Map' 'T.Text' 'AttributeValue'))+-- @+--+strKeys+  ∷ Functor f+  ⇒ (Maybe (M.Map T.Text AttributeValue) → f (Maybe (M.Map T.Text AttributeValue)))+  → StreamRecord+  → f StreamRecord+strKeys i StreamRecord{..} =+  (\_strKeys → StreamRecord{..})+    <$> i _strKeys+{-# INLINE strKeys #-}++-- | A lens for '_strNewImage'.+--+-- @+-- 'strNewImage' ∷ Lens' 'StreamRecord' ('Maybe' ('M.Map' 'T.Text' 'AttributeValue'))+-- @+--+strNewImage+  ∷ Functor f+  ⇒ (Maybe (M.Map T.Text AttributeValue) → f (Maybe (M.Map T.Text AttributeValue)))+  → StreamRecord+  → f StreamRecord+strNewImage i StreamRecord{..} =+  (\_strNewImage → StreamRecord{..})+    <$> i _strNewImage+{-# INLINE strNewImage #-}++-- | A lens for '_strOldImage'.+--+-- @+-- 'strOldImage' ∷ Lens' 'StreamRecord' ('Maybe' ('M.Map' 'T.Text' 'AttributeValue'))+-- @+--+strOldImage+  ∷ Functor f+  ⇒ (Maybe (M.Map T.Text AttributeValue) → f (Maybe (M.Map T.Text AttributeValue)))+  → StreamRecord+  → f StreamRecord+strOldImage i StreamRecord{..} =+  (\_strOldImage → StreamRecord{..})+    <$> i _strOldImage+{-# INLINE strOldImage #-}++-- | A lens for '_strSequenceNumber'.+--+-- @+-- 'strSequenceNumber' ∷ Lens' 'StreamRecord' ('Maybe' 'SequenceNumber')+-- @+--+strSequenceNumber+  ∷ Functor f+  ⇒ (Maybe SequenceNumber → f (Maybe SequenceNumber))+  → StreamRecord+  → f StreamRecord+strSequenceNumber i StreamRecord{..} =+  (\_strSequenceNumber → StreamRecord{..})+    <$> i _strSequenceNumber+{-# INLINE strSequenceNumber #-}++-- | A lens for '_strSizeBytes'.+--+-- @+-- 'strSizeBytes' ∷ Lens' 'StreamRecord' ('Maybe' 'Integer')+-- @+--+strSizeBytes+  ∷ Functor f+  ⇒ (Maybe Integer → f (Maybe Integer))+  → StreamRecord+  → f StreamRecord+strSizeBytes i StreamRecord{..} =+  (\_strSizeBytes → StreamRecord{..})+    <$> i _strSizeBytes+{-# INLINE strSizeBytes #-}++-- | A lens for '_strStreamViewType'.+--+-- @+-- 'strStreamViewType' ∷ Lens' 'StreamRecord' ('Maybe' 'StreamViewType')+-- @+--+strStreamViewType+  ∷ Functor f+  ⇒ (Maybe StreamViewType → f (Maybe StreamViewType))+  → StreamRecord+  → f StreamRecord+strStreamViewType i StreamRecord{..} =+  (\_strStreamViewType → StreamRecord{..})+    <$> i _strStreamViewType+{-# INLINE strStreamViewType #-}+++-- | Identifier for a stream.+--+-- Length constraints: @56 ≤ n ≤ 128@.+--+newtype StreamId+  = StreamId+  { _stidText ∷ T.Text+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON StreamId where+  toJSON = toJSON ∘ _stidText++instance FromJSON StreamId where+  parseJSON =+    withText "StreamId" $+      pure ∘ StreamId++data StreamStatus+  = StatusEnabling+    -- ^ DynamoDB Streams is currently being enabled on the table+  | StatusEnabled+    -- ^ The stream is enabled+  | StatusDisabling+    -- ^ DynamoDB Streams is currently being disabled on the table+  | StatusDisabled+    -- ^ The stream is disabled+  deriving (Eq, Ord, Enum, Show, Read, Typeable)++streamStatusToText+  ∷ IsString a+  ⇒ StreamStatus+  → a+streamStatusToText = \case+  StatusEnabling → "ENABLING"+  StatusEnabled → "ENABLED"+  StatusDisabling → "DISABLING"+  StatusDisabled → "DISABLED"++instance ToJSON StreamStatus where+  toJSON = streamStatusToText++instance FromJSON StreamStatus where+  parseJSON =+    parseEnum "StreamStatus" streamStatusToText+      [ StatusEnabling+      , StatusEnabled+      , StatusDisabling+      , StatusDisabled+      ]++-- | A prism for 'StatusEnabling'.+--+-- @+-- '_StatusEnabling' ∷ Prism' 'StreamStatus' ()+-- @+_StatusEnabling+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamStatus (f StreamStatus)+_StatusEnabling =+  dimap to fro ∘ right'+    where+      to = \case+        StatusEnabling → Right ()+        e → Left e+      fro = either pure (const $ pure StatusEnabling)+{-# INLINE _StatusEnabling #-}++-- | A prism for 'StatusEnabled'.+--+-- @+-- '_StatusEnabled' ∷ Prism' 'StreamStatus' ()+-- @+_StatusEnabled+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamStatus (f StreamStatus)+_StatusEnabled =+  dimap to fro ∘ right'+    where+      to = \case+        StatusEnabled → Right ()+        e → Left e+      fro = either pure (const $ pure StatusEnabled)+{-# INLINE _StatusEnabled #-}++-- | A prism for 'StatusDisabling'.+--+-- @+-- '_StatusDisabling' ∷ Prism' 'StreamStatus' ()+-- @+_StatusDisabling+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamStatus (f StreamStatus)+_StatusDisabling =+  dimap to fro ∘ right'+    where+      to = \case+        StatusDisabling → Right ()+        e → Left e+      fro = either pure (const $ pure StatusDisabling)+{-# INLINE _StatusDisabling #-}++-- | A prism for 'StatusDisabled'.+--+-- @+-- '_StatusDisabled' ∷ Prism' 'StreamStatus' ()+-- @+_StatusDisabled+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p StreamStatus (f StreamStatus)+_StatusDisabled =+  dimap to fro ∘ right'+    where+      to = \case+        StatusDisabled → Right ()+        e → Left e+      fro = either pure (const $ pure StatusDisabled)+{-# INLINE _StatusDisabled #-}+++data StreamDescription+  = StreamDescription+  { _sdCreationRequestDateTime ∷ !(Maybe UTCTime)+  , _sdKeySchema ∷ ![KeySchemaElement]+  , _sdLastEvaluatedShardId ∷ !(Maybe ShardId)+  , _sdShards ∷ ![Shard]+  , _sdStreamARN ∷ !(Maybe T.Text)+  , _sdStreamId ∷ !(Maybe StreamId)+  , _sdStreamStatus ∷ !(Maybe StreamStatus)+  , _sdStreamViewType ∷ !(Maybe StreamViewType)+  , _sdTableName ∷ !(Maybe T.Text)+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON StreamDescription where+  toJSON StreamDescription{..} = object+    [ "CreationRequestDateTime" .= (Number ∘ fromInteger ∘ round ∘ utcTimeToPOSIXSeconds <$> _sdCreationRequestDateTime)+    , "KeySchema" .= _sdKeySchema+    , "Shards" .= _sdShards+    , "StreamARN" .= _sdStreamARN+    , "StreamId" .= _sdStreamId+    , "StreamStatus" .= _sdStreamStatus+    , "StreamViewType" .= _sdStreamViewType+    , "TableName" .= _sdTableName+    ]++instance FromJSON StreamDescription where+  parseJSON =+    withObject "StreamDescription" $ \o →+      pure StreamDescription+        ⊛ (fmap (posixSecondsToUTCTime ∘ fromInteger) <$> o .:? "CreationRequestDateTime")+        ⊛ o .:? "KeySchema" .!= []+        ⊛ o .:? "LastEvaluatedShardId"+        ⊛ o .:? "Shards" .!= []+        ⊛ o .:? "StreamARN"+        ⊛ o .:? "StreamId"+        ⊛ o .:? "StreamStatus"+        ⊛ o .:? "StreamViewType"+        ⊛ o .:? "TableName"++-- | A lens for '_sdCreationRequestDateTime'.+--+-- @+-- 'sdCreationRequestDateTime' ∷ Lens' 'StreamDescription' ('Maybe' 'UTCTime')+-- @+--+sdCreationRequestDateTime+  ∷ Functor f+  ⇒ (Maybe UTCTime → f (Maybe UTCTime))+  → StreamDescription+  → f StreamDescription+sdCreationRequestDateTime i StreamDescription{..} =+  (\_sdCreationRequestDateTime → StreamDescription{..})+    <$> i _sdCreationRequestDateTime+{-# INLINE sdCreationRequestDateTime #-}++-- | A lens for '_sdKeySchema'.+--+-- @+-- 'sdKeySchema' ∷ Lens' 'StreamDescription' ['KeySchemaElement']+-- @+--+sdKeySchema+  ∷ Functor f+  ⇒ ([KeySchemaElement] → f [KeySchemaElement])+  → StreamDescription+  → f StreamDescription+sdKeySchema i StreamDescription{..} =+  (\_sdKeySchema → StreamDescription{..})+    <$> i _sdKeySchema+{-# INLINE sdKeySchema #-}++-- | A lens for '_sdLastEvaluatedShardId'.+--+-- @+-- 'sdLastEvaluatedShardId' ∷ Lens' 'StreamDescription' ('Maybe' 'ShardId')+-- @+--+sdLastEvaluatedShardId+  ∷ Functor f+  ⇒ (Maybe ShardId → f (Maybe ShardId))+  → StreamDescription+  → f StreamDescription+sdLastEvaluatedShardId i StreamDescription{..} =+  (\_sdLastEvaluatedShardId → StreamDescription{..})+    <$> i _sdLastEvaluatedShardId+{-# INLINE sdLastEvaluatedShardId #-}++-- | A lens for '_sdShards'.+--+-- @+-- 'sdShards' ∷ Lens' 'StreamDescription' ['Shard']+-- @+--+sdShards+  ∷ Functor f+  ⇒ ([Shard] → f [Shard])+  → StreamDescription+  → f StreamDescription+sdShards i StreamDescription{..} =+  (\_sdShards → StreamDescription{..})+    <$> i _sdShards+{-# INLINE sdShards #-}++-- | A lens for '_sdStreamARN'.+--+-- @+-- 'sdStreamARN' ∷ Lens' 'StreamDescription' ('Maybe' 'T.Text')+-- @+--+sdStreamARN+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → StreamDescription+  → f StreamDescription+sdStreamARN i StreamDescription{..} =+  (\_sdStreamARN → StreamDescription{..})+    <$> i _sdStreamARN+{-# INLINE sdStreamARN #-}++-- | A lens for '_sdStreamId'.+--+-- @+-- 'sdStreamId' ∷ Lens' 'StreamDescription' ('Maybe' 'StreamId')+-- @+--+sdStreamId+  ∷ Functor f+  ⇒ (Maybe StreamId → f (Maybe StreamId))+  → StreamDescription+  → f StreamDescription+sdStreamId i StreamDescription{..} =+  (\_sdStreamId → StreamDescription{..})+    <$> i _sdStreamId+{-# INLINE sdStreamId #-}++-- | A lens for '_sdStreamStatus'.+--+-- @+-- 'sdStreamStatus' ∷ Lens' 'StreamDescription' ('Maybe' 'StreamStatus')+-- @+--+sdStreamStatus+  ∷ Functor f+  ⇒ (Maybe StreamStatus → f (Maybe StreamStatus))+  → StreamDescription+  → f StreamDescription+sdStreamStatus i StreamDescription{..} =+  (\_sdStreamStatus → StreamDescription{..})+    <$> i _sdStreamStatus+{-# INLINE sdStreamStatus #-}++-- | A lens for '_sdStreamViewType'.+--+-- @+-- 'sdStreamViewType' ∷ Lens' 'StreamDescription' ('Maybe' 'StreamViewType')+-- @+--+sdStreamViewType+  ∷ Functor f+  ⇒ (Maybe StreamViewType → f (Maybe StreamViewType))+  → StreamDescription+  → f StreamDescription+sdStreamViewType i StreamDescription{..} =+  (\_sdStreamViewType → StreamDescription{..})+    <$> i _sdStreamViewType+{-# INLINE sdStreamViewType #-}++-- | A lens for '_sdTableName'.+--+-- @+-- 'sdTableName' ∷ Lens' 'StreamDescription' ('Maybe' 'T.Text')+-- @+--+sdTableName+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → StreamDescription+  → f StreamDescription+sdTableName i StreamDescription{..} =+  (\_sdTableName → StreamDescription{..})+    <$> i _sdTableName+{-# INLINE sdTableName #-}+++-- | A globally unique identifier for the event that was recorded.+--+newtype EventId+  = EventId+  { _eidText ∷ T.Text+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON EventId where+  toJSON = toJSON ∘ _eidText++instance FromJSON EventId where+  parseJSON =+    withText "EventId" $+      pure ∘ EventId++data EventName+  = EventInsert+  | EventModify+  | EventRemove+  deriving (Eq, Ord, Enum, Typeable, Show, Read)++eventNameToText+  ∷ IsString s+  ⇒ EventName+  → s+eventNameToText = \case+  EventInsert → "INSERT"+  EventModify → "MODIFY"+  EventRemove → "REMOVE"++instance ToJSON EventName where+  toJSON = eventNameToText++instance FromJSON EventName where+  parseJSON =+    parseEnum "EventName" eventNameToText+      [ EventInsert+      , EventModify+      , EventRemove+      ]++-- | A prism for 'EventInsert'.+--+-- @+-- '_EventInsert' ∷ Prism' 'EventName' ()+-- @+_EventInsert+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p EventName (f EventName)+_EventInsert =+  dimap to fro ∘ right'+    where+      to = \case+        EventInsert → Right ()+        e → Left e+      fro = either pure (const $ pure EventInsert)+{-# INLINE _EventInsert #-}++-- | A prism for 'EventModify'.+--+-- @+-- '_EventModify' ∷ Prism' 'EventName' ()+-- @+_EventModify+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p EventName (f EventName)+_EventModify =+  dimap to fro ∘ right'+    where+      to = \case+        EventModify → Right ()+        e → Left e+      fro = either pure (const $ pure EventModify)+{-# INLINE _EventModify #-}++-- | A prism for 'EventRemove'.+--+-- @+-- '_EventRemove' ∷ Prism' 'EventName' ()+-- @+_EventRemove+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p EventName (f EventName)+_EventRemove =+  dimap to fro ∘ right'+    where+      to = \case+        EventRemove → Right ()+        e → Left e+      fro = either pure (const $ pure EventRemove)+{-# INLINE _EventRemove #-}+++data Record+  = Record+  { _rAwsRegion ∷ !(Maybe Region)+  , _rStreamRecord ∷ !(Maybe StreamRecord)+  , _rEventId ∷ !(Maybe EventId)+  , _rEventName ∷ !(Maybe EventName)+  , _rEventSource ∷ !(Maybe T.Text)+  , _rEventVersion ∷ !(Maybe T.Text)+  } deriving (Eq, Ord, Show, Read, Typeable)++instance ToJSON Record where+  toJSON Record{..} = object+    [ "awsRegion" .= (String ∘ regionToText <$> _rAwsRegion)+    , "dynamodb" .= _rStreamRecord+    , "eventID" .= _rEventId+    , "eventName" .= _rEventName+    , "eventSource" .= _rEventSource+    , "eventVersion" .= _rEventVersion+    ]++instance FromJSON Record where+  parseJSON =+    withObject "Record" $ \o →+      pure Record+        ⊛ (traverse (either fail pure ∘ fromText) =≪ o .:? "awsRegion")+        ⊛ o .:? "dynamodb"+        ⊛ o .:? "eventID"+        ⊛ o .:? "eventName"+        ⊛ o .:? "eventSource"+        ⊛ o .:? "eventVersion"++-- | A lens for '_rAwsRegion'.+--+-- @+-- 'rAwsRegion' ∷ Lens' 'Record' ('Maybe' 'Region')+-- @+--+rAwsRegion+  ∷ Functor f+  ⇒ (Maybe Region → f (Maybe Region))+  → Record+  → f Record+rAwsRegion i Record{..} =+  (\_rAwsRegion → Record{..})+    <$> i _rAwsRegion+{-# INLINE rAwsRegion #-}++-- | A lens for '_rStreamRecord'.+--+-- @+-- 'rStreamRecord' ∷ Lens' 'Record' ('Maybe' 'StreamRecord')+-- @+--+rStreamRecord+  ∷ Functor f+  ⇒ (Maybe StreamRecord → f (Maybe StreamRecord))+  → Record+  → f Record+rStreamRecord i Record{..} =+  (\_rStreamRecord → Record{..})+    <$> i _rStreamRecord+{-# INLINE rStreamRecord #-}++-- | A lens for '_rEventId'.+--+-- @+-- 'rEventId' ∷ Lens' 'Record' ('Maybe' 'EventId')+-- @+--+rEventId+  ∷ Functor f+  ⇒ (Maybe EventId → f (Maybe EventId))+  → Record+  → f Record+rEventId i Record{..} =+  (\_rEventId → Record{..})+    <$> i _rEventId+{-# INLINE rEventId #-}++-- | A lens for '_rEventName'.+--+-- @+-- 'rEventName' ∷ Lens' 'Record' ('Maybe' 'EventName')+-- @+--+rEventName+  ∷ Functor f+  ⇒ (Maybe EventName → f (Maybe EventName))+  → Record+  → f Record+rEventName i Record{..} =+  (\_rEventName → Record{..})+    <$> i _rEventName+{-# INLINE rEventName #-}++-- | A lens for '_rEventSource'.+--+-- @+-- 'rEventSource' ∷ Lens' 'Record' ('Maybe' 'T.Text')+-- @+--+rEventSource+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → Record+  → f Record+rEventSource i Record{..} =+  (\_rEventSource → Record{..})+    <$> i _rEventSource+{-# INLINE rEventSource #-}++-- | A lens for '_rEventVersion'.+--+-- @+-- 'rEventVersion' ∷ Lens' 'Record' ('Maybe' 'T.Text')+-- @+--+rEventVersion+  ∷ Functor f+  ⇒ (Maybe T.Text → f (Maybe T.Text))+  → Record+  → f Record+rEventVersion i Record{..} =+  (\_rEventVersion → Record{..})+    <$> i _rEventVersion+{-# INLINE rEventVersion #-}+++data ShardIteratorType+  = ShardIteratorTrimHorizon+  | ShardIteratorLatest+  | ShardIteratorAtSequenceNumber+  | ShardIteratorAfterSequenceNumber+  deriving (Eq, Ord, Enum, Read, Show, Typeable)++shardIteratorTypeToText+  ∷ IsString s+  ⇒ ShardIteratorType+  → s+shardIteratorTypeToText = \case+  ShardIteratorTrimHorizon → "TRIM_HORIZON"+  ShardIteratorLatest → "LATEST"+  ShardIteratorAtSequenceNumber → "AT_SEQUENCE_NUMBER"+  ShardIteratorAfterSequenceNumber → "AFTER_SEQUENCE_NUMBER"++instance ToJSON ShardIteratorType where+  toJSON = shardIteratorTypeToText++instance FromJSON ShardIteratorType where+  parseJSON =+    parseEnum "ShardIteratorType" shardIteratorTypeToText+      [ ShardIteratorTrimHorizon+      , ShardIteratorLatest+      , ShardIteratorAtSequenceNumber+      , ShardIteratorAfterSequenceNumber+      ]++-- | A prism for 'ShardIteratorTrimHorizon'.+--+-- @+-- '_ShardIteratorTrimHorizon' ∷ Prism' 'ShardIteratorType' '()'+-- @+_ShardIteratorTrimHorizon+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p ShardIteratorType (f ShardIteratorType)+_ShardIteratorTrimHorizon =+  dimap to fro ∘ right'+    where+      to = \case+        ShardIteratorTrimHorizon → Right ()+        e → Left e+      fro = either pure (const $ pure ShardIteratorTrimHorizon)+{-# INLINE _ShardIteratorTrimHorizon #-}++-- | A prism for 'ShardIteratorLatest'.+--+-- @+-- '_ShardIteratorLatest' ∷ Prism' 'ShardIteratorType' '()'+-- @+_ShardIteratorLatest+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p ShardIteratorType (f ShardIteratorType)+_ShardIteratorLatest =+  dimap to fro ∘ right'+    where+      to = \case+        ShardIteratorLatest → Right ()+        e → Left e+      fro = either pure (const $ pure ShardIteratorLatest)+{-# INLINE _ShardIteratorLatest #-}++-- | A prism for 'ShardIteratorAtSequenceNumber'.+--+-- @+-- '_ShardIteratorAtSequenceNumber' ∷ Prism' 'ShardIteratorType' '()'+-- @+_ShardIteratorAtSequenceNumber+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p ShardIteratorType (f ShardIteratorType)+_ShardIteratorAtSequenceNumber =+  dimap to fro ∘ right'+    where+      to = \case+        ShardIteratorAtSequenceNumber → Right ()+        e → Left e+      fro = either pure (const $ pure ShardIteratorAtSequenceNumber)+{-# INLINE _ShardIteratorAtSequenceNumber #-}++-- | A prism for 'ShardIteratorAfterSequenceNumber'.+--+-- @+-- '_ShardIteratorAfterSequenceNumber' ∷ Prism' 'ShardIteratorType' '()'+-- @+_ShardIteratorAfterSequenceNumber+  ∷ ( Choice p+    , Applicative f+    )+  ⇒ p () (f ())+  → p ShardIteratorType (f ShardIteratorType)+_ShardIteratorAfterSequenceNumber =+  dimap to fro ∘ right'+    where+      to = \case+        ShardIteratorAfterSequenceNumber → Right ()+        e → Left e+      fro = either pure (const $ pure ShardIteratorAfterSequenceNumber)+{-# INLINE _ShardIteratorAfterSequenceNumber #-}+++-- | The position in the shard from which to start reading stream records+-- sequentially. A shard iterator specifies this position using the sequence+-- number of a stream record in a shard.+--+-- Length constraints: @1 ≤ n ≤ 2048@.+--+newtype ShardIterator+  = ShardIterator+  { _sitText ∷ T.Text+  } deriving (Eq, Ord, Typeable, Show, Read)++instance ToJSON ShardIterator where+  toJSON = toJSON ∘ _sitText++instance FromJSON ShardIterator where+  parseJSON =+    withText "ShardIterator" $+      pure ∘ ShardIterator