Add S3BatchJobEvent (#210)

* Add S3BatchJobEvent and related structs, tests, test json, and README

* Update README_S3_Batch_Job.md

Arn -> ARN

* Update s3_batch_job.go

S3BucketArn -> S3BucketARN

Author: jbonzo

events/README_S3_Batch_Job.md

@@ -0,0 +1,39 @@
+# Sample Function
+
+The following is a sample class and Lambda function that receives Amazon S3 event record data as an input and writes some of the record data to CloudWatch Logs. (Note that by default anything written to Console will be logged as CloudWatch Logs events.)
+
+```go
+
+import (
+    "fmt"
+    "context"
+    "github.com/aws/aws-lambda-go/events"
+)
+
+func handler(ctx context.Context, e events.S3BatchJobEvent) (response events.S3BatchJobResponse, err error) {
+    fmt.Printf("InvocationSchemaVersion: %s\n", e.InvocationSchemaVersion)
+	fmt.Printf("InvocationID: %s\n", e.InvocationID)
+	fmt.Printf("Job.ID: %s\n", e.Job.ID)
+
+	for _, task := range e.Tasks {
+		fmt.Printf("TaskID: %s\n", task.TaskID)
+		fmt.Printf("S3Key: %s\n", task.S3Key)
+		fmt.Printf("S3VersionID: %s\n", task.S3VersionID)
+		fmt.Printf("S3BucketARN: %s\n", task.S3BucketARN)
+
+	}
+
+	fmt.Printf("InvocationSchemaVersion: %s\n", response.InvocationSchemaVersion)
+	fmt.Printf("TreatMissingKeysAs: %s\n", response.TreatMissingKeysAs)
+	fmt.Printf("InvocationID: %s\n", response.InvocationID)
+
+	for _, result := range response.Results {
+		fmt.Printf("TaskID: %s\n", result.TaskID)
+		fmt.Printf("ResultCode: %s\n", result.ResultCode)
+		fmt.Printf("ResultString: %s\n", result.ResultString)
+	}
+
+	return
+}
+
+```

events/s3_batch_job.go

@@ -0,0 +1,34 @@
+// Copyright 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+
+package events
+
+type S3BatchJobEvent struct {
+	InvocationSchemaVersion string           `json:"invocationSchemaVersion"`
+	InvocationID            string           `json:"invocationId"`
+	Job                     S3BatchJob       `json:"job"`
+	Tasks                   []S3BatchJobTask `json:"tasks"`
+}
+
+type S3BatchJob struct {
+	ID string `json:"id"`
+}
+
+type S3BatchJobTask struct {
+	TaskID      string `json:"taskId"`
+	S3Key       string `json:"s3Key"`
+	S3VersionID string `json:"s3VersionId"`
+	S3BucketARN string `json:"s3BucketArn"`
+}
+
+type S3BatchJobResponse struct {
+	InvocationSchemaVersion string             `json:"invocationSchemaVersion"`
+	TreatMissingKeysAs      string             `json:"treatMissingKeysAs"`
+	InvocationID            string             `json:"invocationId"`
+	Results                 []S3BatchJobResult `json:"results"`
+}
+
+type S3BatchJobResult struct {
+	TaskID       string `json:"taskId"`
+	ResultCode   string `json:"resultCode"`
+	ResultString string `json:"resultString"`
+}

events/s3_batch_job_test.go

@@ -0,0 +1,53 @@
+// Copyright 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+
+package events
+
+import (
+	"encoding/json"
+	"testing"
+
+	"github.com/aws/aws-lambda-go/events/test"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestS3BatchJobEventMarshaling(t *testing.T) {
+
+	// 1. read JSON from file
+	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-batch-job-event-request.json")
+
+	// 2. de-serialize into Go object
+	var inputEvent S3BatchJobEvent
+	if err := json.Unmarshal(inputJSON, &inputEvent); err != nil {
+		t.Errorf("could not unmarshal event. details: %v", err)
+	}
+
+	// 3. serialize to JSON
+	outputJSON, err := json.Marshal(inputEvent)
+	if err != nil {
+		t.Errorf("could not marshal event. details: %v", err)
+	}
+
+	// 4. check result
+	assert.JSONEq(t, string(inputJSON), string(outputJSON))
+}
+
+func TestS3BatchJobResponseMarshaling(t *testing.T) {
+
+	// 1. read JSON from file
+	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-batch-job-event-response.json")
+
+	// 2. de-serialize into Go object
+	var inputEvent S3BatchJobResponse
+	if err := json.Unmarshal(inputJSON, &inputEvent); err != nil {
+		t.Errorf("could not unmarshal event. details: %v", err)
+	}
+
+	// 3. serialize to JSON
+	outputJSON, err := json.Marshal(inputEvent)
+	if err != nil {
+		t.Errorf("could not marshal event. details: %v", err)
+	}
+
+	// 4. check result
+	assert.JSONEq(t, string(inputJSON), string(outputJSON))
+}

events/testdata/s3-batch-job-event-request.json

@@ -0,0 +1,15 @@
+{
+  "invocationSchemaVersion": "1.0",
+  "invocationId": "YXNkbGZqYWRmaiBhc2RmdW9hZHNmZGpmaGFzbGtkaGZza2RmaAo",
+  "job": {
+    "id": "f3cc4f60-61f6-4a2b-8a21-d07600c373ce"
+  },
+  "tasks": [
+    {
+      "taskId": "dGFza2lkZ29lc2hlcmUK",
+      "s3Key": "customerImage1.jpg",
+      "s3VersionId": "1",
+      "s3BucketArn": "arn:aws:s3:us-east-1:0123456788:awsexamplebucket"
+    }
+  ]
+}

events/testdata/s3-batch-job-event-response.json

@@ -0,0 +1,12 @@
+{
+  "invocationSchemaVersion": "1.0",
+  "treatMissingKeysAs" : "PermanentFailure",
+  "invocationId" : "YXNkbGZqYWRmaiBhc2RmdW9hZHNmZGpmaGFzbGtkaGZza2RmaAo",
+  "results": [
+    {
+      "taskId": "dGFza2lkZ29lc2hlcmUK",
+      "resultCode": "Succeeded",
+      "resultString": "[\"Mary Major\", \"John Stiles\"]"
+    }
+  ]
+}