namespace BlueprintBaseName._1.Tests


open Xunit
open Amazon.Lambda.TestUtilities

open Amazon.Lambda.DynamoDBEvents
open Amazon.DynamoDBv2
open Amazon.DynamoDBv2.Model

open System
open System.Collections.Generic

open BlueprintBaseName._1


module FunctionTest =
    [<Fact>]
    let ``Test Reading DynamoDB Stream Event``() =
        let keys = dict [ ("id", AttributeValue(S = "MyId")) ]

        let newImage = dict [
                            ("field1", AttributeValue(S = "NewValue"))
                            ("field2", AttributeValue(S = "AnotherNewValue"))
                        ]

        let oldImages = dict [
                            ("field1", AttributeValue(S = "OldValue"))
                            ("field2", AttributeValue(S = "AnotherOldValue"))
                        ]

        let streamRecord =
            StreamRecord(
                ApproximateCreationDateTime = DateTime.Now,
                StreamViewType = StreamViewType.NEW_AND_OLD_IMAGES,
                Keys = Dictionary(keys),
                NewImage = Dictionary(newImage),
                OldImage = Dictionary(oldImages)
            )

        let ddbStreamRecords = [
            DynamoDBEvent.DynamodbStreamRecord(
                EventID = "id-foo",
                EventName = OperationType.INSERT,
                AwsRegion = "us-west-2",
                Dynamodb = streamRecord
            )
        ]

        let ddbEvent = DynamoDBEvent(Records = List(ddbStreamRecords))
        let lambdaFunction = Function()
        let testLogger = TestLambdaLogger()
        let context = TestLambdaContext(Logger = testLogger)
        lambdaFunction.FunctionHandler ddbEvent context

        Assert.Contains("id-foo", testLogger.Buffer.ToString())
        Assert.Contains("Stream processing complete", testLogger.Buffer.ToString())

    [<EntryPoint>]
    let main _ = 0