#24: Fixed logic error

handler_utils/sqs.go

@@ -37,8 +37,7 @@ func GetRecord(s3Session *s3.SessionWithHelpers, bucket string, message events.S
 	recordValuePtr := reflect.New(recordType)
 
 	// Check if message body should be retrieved from S3
-	if messageAttribute, ok := message.MessageAttributes[sqs.SQSMessageOnS3Key]; ok {
-		if messageAttribute.StringValue != nil && *messageAttribute.StringValue == "true" {
+	if messageAttribute, ok := message.MessageAttributes[sqs.SQSMessageOnS3Key]; ok && messageAttribute.StringValue != nil && *messageAttribute.StringValue == "true" {
 		messageBytes, err := sqs.RetrieveMessageFromS3(s3Session, bucket, message.Body)
 		if err != nil {
 			return nil, errors.Wrapf(err, "failed to get sqs message body from s3")
@@ -48,7 +47,6 @@ func GetRecord(s3Session *s3.SessionWithHelpers, bucket string, message events.S
 		if err != nil {
 			return nil, errors.Wrapf(err, "failed to JSON decode message body")
 		}
-		}
 	} else {
 		// Message was small enough, it is contained in the message body
 		err := json.Unmarshal([]byte(message.Body), recordValuePtr.Interface())