{-# LANGUAGE DeriveGeneric #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE RecordWildCards #-}
{-# LANGUAGE TemplateHaskell #-}
module AWSLambda.Events.SNSEvent where
import Control.Lens
import Data.Aeson (FromJSON (..), genericParseJSON)
import Data.Aeson.Casing (aesonDrop, pascalCase)
import Data.Aeson.Embedded
import Data.Aeson.TextValue
import Data.Aeson.TH (deriveFromJSON)
import Data.ByteString (ByteString)
import Data.HashMap.Strict (HashMap)
import Data.Text (Text)
import Data.Time.Clock (UTCTime)
import GHC.Generics (Generic)
import Network.AWS.Data.Base64
import Network.AWS.Data.Text (FromText)
import AWSLambda.Events.Records
data MessageAttribute = MessageAttribute
{ _maType :: !Text
, _maValue :: !Text
} deriving (Eq, Show)
$(deriveFromJSON (aesonDrop 3 pascalCase) ''MessageAttribute)
$(makeLenses ''MessageAttribute)
data SNSMessage message = SNSMessage
{ _smMessage :: !(TextValue message )
, _smMessageAttributes :: !(HashMap Text MessageAttribute)
, _smMessageId :: !Text
, _smSignature :: !Text
, _smSignatureVersion :: !Text
, _smSigningCertUrl :: !Text
, _smSubject :: !Text
, _smTimestamp :: !UTCTime
, _smTopicArn :: !Text
, _smType :: !Text
, _smUnsubscribeUrl :: !Text
} deriving (Eq, Show, Generic)
instance FromText message => FromJSON (SNSMessage message) where
parseJSON = genericParseJSON $ aesonDrop 3 pascalCase
$(makeLenses ''SNSMessage)
data SNSRecord message = SNSRecord
{ _srEventVersion :: !Text
, _srEventSubscriptionArn :: !Text
, _srEventSource :: !Text
, _srSns :: !(SNSMessage message)
} deriving (Eq, Show, Generic)
instance FromText message => FromJSON (SNSRecord message) where
parseJSON = genericParseJSON $ aesonDrop 3 pascalCase
$(makeLenses ''SNSRecord)
type SNSEvent message = RecordsEvent (SNSRecord message)
messages :: Traversal (SNSEvent message) (SNSEvent message') message message'
messages = reRecords . traverse . srSns . smMessage . unTextValue
embedded :: Traversal (SNSEvent (Embedded v)) (SNSEvent (Embedded v')) v v'
embedded = messages . unEmbed
binary :: Traversal' (SNSEvent Base64) ByteString
binary = messages . _Base64