// Copyright 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License"). You may not
// use this file except in compliance with the License. A copy of the
// License is located at
//
// http://aws.amazon.com/apache2.0/
//
// or in the "license" file accompanying this file. This file 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.

// package parser contains utilities for parsing and encoding MDS/SSM messages.
package docparser

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"path"
	"path/filepath"
	"testing"

	"github.com/aws/amazon-ssm-agent/agent/appconfig"
	"github.com/aws/amazon-ssm-agent/agent/contracts"
	"github.com/aws/amazon-ssm-agent/agent/fileutil"
	"github.com/aws/amazon-ssm-agent/agent/jsonutil"
	"github.com/aws/amazon-ssm-agent/agent/mocks/context"
	"github.com/stretchr/testify/assert"
)

const (
	testOrchDir         = "test-orchestrationDir"
	testS3Bucket        = "test-s3Bucket"
	testS3Prefix        = "test-s3KeyPrefix"
	testMessageID       = "test-messageID"
	testDocumentID      = "test-documentID"
	testWorkingDir      = "test-defaultWorkingDirectory"
	testLogGroupName    = "test-logGroupName"
	testLogStreamPrefix = "test-logStreamName"
	testSessionId       = "test-sessionId"
	testClientId        = "test-clientId"
	testKmsKeyId        = "test-kmskeyid"
	testProperties      = "properties"
	testWindowsCmd      = "date"
	testLinuxCmd        = "ls"
)
const parameterdocument = `{"schemaVersion":"1.2","description":"","parameters":{"commands":{"type":"StringList"}},"runtimeConfig":{"aws:runPowerShellScript":{"properties":[{"id":"0.aws:runPowerShellScript","runCommand":"{{ commands }}"}]}}}`
const invaliddocument = `{"schemaVersion":"1.2","description":"PowerShell.","FOO":"bar"}`
const testparameters = `{"commands":["date"]}`

var sampleMessageFiles = []string{
	"testdata/sampleMessageVersion2_0.json",
	"testdata/sampleMessage.json",
	"testdata/sampleMessageVersion2_2.json",
}

var sampleMessageWithPreconditionFiles = []string{
	"testdata/sampleMessageWithInvalidParamPrecondition.json",
	"testdata/sampleMessageWithMixedPrecondition.json",
	"testdata/sampleMessageWithParamPrecondition.json",
	"testdata/sampleMessageWithPlatformPrecondition.json",
	"testdata/sampleMessageWithSecureSsmParamPrecondition.json",
	"testdata/sampleMessageWithSsmParamPrecondition.json",
	"testdata/sampleMessageWithTwoParamsPrecondition.json",
}

func TestParseDocument_ValidRuntimeConfig(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	validdocumentruntimeconfig := loadFile(t, filepath.Join("..", "..", "runcommand", "mds", "testdata", "validcommand12.json"))
	var testDocContent DocContent
	err := json.Unmarshal(validdocumentruntimeconfig, &testDocContent)
	if err != nil {
		assert.Error(t, err, "Error occurred when trying to unmarshal valid document")
	}
	pluginsInfo, err := testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.Nil(t, err)
	assert.Equal(t, 1, len(pluginsInfo))

	pluginInfoTest := pluginsInfo[0]
	assert.Equal(t, "", pluginInfoTest.Result.Error)
	assert.Equal(t, filepath.Join(testOrchDir, "awsrunShellScript"), pluginInfoTest.Configuration.OrchestrationDirectory)
	assert.Equal(t, testS3Bucket, pluginInfoTest.Configuration.OutputS3BucketName)
	assert.Equal(t, path.Join(testS3Prefix, "awsrunShellScript"), pluginInfoTest.Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testMessageID, pluginInfoTest.Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfoTest.Configuration.BookKeepingFileName)
	assert.Equal(t, testWorkingDir, pluginInfoTest.Configuration.DefaultWorkingDirectory)
}

func TestParseDocument_ValidMainSteps(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	var testDocContent DocContent
	validdocumentmainsteps := loadFile(t, filepath.Join("..", "..", "runcommand", "mds", "testdata", "validcommand20.json"))
	err := json.Unmarshal(validdocumentmainsteps, &testDocContent)
	if err != nil {
		assert.Error(t, err, "Error occurred when trying to unmarshal valid document")
	}
	pluginsInfo, err := testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.Nil(t, err)
	assert.Equal(t, 1, len(pluginsInfo))

	pluginInfoTest := pluginsInfo[0]
	assert.Equal(t, "", pluginInfoTest.Result.Error)
	assert.Equal(t, filepath.Join(testOrchDir, "test"), pluginInfoTest.Configuration.OrchestrationDirectory)
	assert.Equal(t, testS3Bucket, pluginInfoTest.Configuration.OutputS3BucketName)
	assert.Equal(t, path.Join(testS3Prefix, "awsrunShellScript"), pluginInfoTest.Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testMessageID, pluginInfoTest.Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfoTest.Configuration.BookKeepingFileName)
	assert.Equal(t, testWorkingDir, pluginInfoTest.Configuration.DefaultWorkingDirectory)
}

func TestInitializeDocState_Valid(t *testing.T) {
	context := context.NewMockDefault()

	cloudWatchConfig := contracts.CloudWatchConfiguration{
		LogGroupName:    testLogGroupName,
		LogStreamPrefix: testLogStreamPrefix,
	}

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
		CloudWatchConfig:  cloudWatchConfig,
	}

	var testDocContent DocContent
	validdocumentruntimeconfig := loadFile(t, filepath.Join("..", "..", "runcommand", "mds", "testdata", "validcommand12.json"))
	err := json.Unmarshal(validdocumentruntimeconfig, &testDocContent)
	if err != nil {
		assert.Error(t, err, "Error occurred when trying to unmarshal valid document")
	}

	docState, err := InitializeDocState(context, contracts.SendCommand, &testDocContent, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.Nil(t, err)

	pluginInfo := docState.InstancePluginsInformation
	assert.Equal(t, contracts.SendCommand, docState.DocumentType)
	assert.Equal(t, "1.2", docState.SchemaVersion)
	assert.Equal(t, 1, len(pluginInfo))
	assert.Equal(t, filepath.Join(testOrchDir, "awsrunShellScript"), pluginInfo[0].Configuration.OrchestrationDirectory)
	assert.Equal(t, testS3Bucket, pluginInfo[0].Configuration.OutputS3BucketName)
	assert.Equal(t, path.Join(testS3Prefix, "awsrunShellScript"), pluginInfo[0].Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testMessageID, pluginInfo[0].Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfo[0].Configuration.BookKeepingFileName)
	assert.Equal(t, testWorkingDir, pluginInfo[0].Configuration.DefaultWorkingDirectory)
	assert.Equal(t, testLogGroupName, docState.IOConfig.CloudWatchConfig.LogGroupName)
	assert.Equal(t, testLogStreamPrefix, docState.IOConfig.CloudWatchConfig.LogStreamPrefix)
}

func TestInitializeDocStateForStartSessionDocument_Valid(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		MessageId:        testMessageID,
		DocumentId:       testDocumentID,
		OrchestrationDir: testOrchDir,
	}

	shellProfile := contracts.ShellProfileConfig{
		Windows: testWindowsCmd,
		Linux:   testLinuxCmd,
	}

	sessionInputs := contracts.SessionInputs{
		S3BucketName:           testS3Bucket,
		S3KeyPrefix:            testS3Prefix,
		KmsKeyId:               testKmsKeyId,
		CloudWatchLogGroupName: testLogGroupName,
		ShellProfile:           shellProfile,
	}

	sessionDocContent := &SessionDocContent{
		SchemaVersion: "1.0",
		Properties:    testProperties,
		Inputs:        sessionInputs,
		SessionType:   appconfig.PluginNameStandardStream,
	}

	docState, err := InitializeDocState(context,
		contracts.StartSession,
		sessionDocContent,
		contracts.DocumentInfo{DocumentID: testSessionId, ClientId: testClientId},
		testParserInfo,
		nil)

	assert.Nil(t, err)

	pluginInfo := docState.InstancePluginsInformation
	assert.Equal(t, contracts.StartSession, docState.DocumentType)
	assert.Equal(t, "1.0", docState.SchemaVersion)
	assert.Equal(t, testOrchDir, docState.IOConfig.OrchestrationDirectory)
	assert.Equal(t, testS3Prefix, pluginInfo[0].Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testS3Bucket, pluginInfo[0].Configuration.OutputS3BucketName)
	assert.Equal(t, 1, len(pluginInfo))
	assert.Equal(t, testMessageID, pluginInfo[0].Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfo[0].Configuration.BookKeepingFileName)
	assert.Equal(t, "", pluginInfo[0].Configuration.DefaultWorkingDirectory)
	assert.Equal(t, testSessionId, pluginInfo[0].Configuration.SessionId)
	assert.Equal(t, testClientId, pluginInfo[0].Configuration.ClientId)
	assert.Equal(t, testLogGroupName, pluginInfo[0].Configuration.CloudWatchLogGroup)
	assert.Equal(t, fileutil.BuildPath(testOrchDir, appconfig.PluginNameStandardStream), pluginInfo[0].Configuration.OrchestrationDirectory)
	assert.Equal(t, testProperties, pluginInfo[0].Configuration.Properties)
	assert.Equal(t, testKmsKeyId, pluginInfo[0].Configuration.KmsKeyId)
	assert.Equal(t, testWindowsCmd, pluginInfo[0].Configuration.ShellProfile.Windows)
	assert.Equal(t, testLinuxCmd, pluginInfo[0].Configuration.ShellProfile.Linux)
}

func TestInitializeDocStateForStartSessionDocumentWithoutSessionCommands_Valid(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		MessageId:        testMessageID,
		DocumentId:       testDocumentID,
		OrchestrationDir: testOrchDir,
	}

	sessionInputs := contracts.SessionInputs{
		S3BucketName:           testS3Bucket,
		S3KeyPrefix:            testS3Prefix,
		KmsKeyId:               testKmsKeyId,
		CloudWatchLogGroupName: testLogGroupName,
	}

	sessionDocContent := &SessionDocContent{
		SchemaVersion: "1.0",
		Inputs:        sessionInputs,
		SessionType:   appconfig.PluginNameStandardStream,
	}

	docState, err := InitializeDocState(context,
		contracts.StartSession,
		sessionDocContent,
		contracts.DocumentInfo{DocumentID: testSessionId, ClientId: testClientId},
		testParserInfo,
		nil)

	assert.Nil(t, err)

	pluginInfo := docState.InstancePluginsInformation
	assert.Equal(t, contracts.StartSession, docState.DocumentType)
	assert.Equal(t, "1.0", docState.SchemaVersion)
	assert.Equal(t, testOrchDir, docState.IOConfig.OrchestrationDirectory)
	assert.Equal(t, testS3Prefix, pluginInfo[0].Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testS3Bucket, pluginInfo[0].Configuration.OutputS3BucketName)
	assert.Equal(t, 1, len(pluginInfo))
	assert.Equal(t, testMessageID, pluginInfo[0].Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfo[0].Configuration.BookKeepingFileName)
	assert.Equal(t, "", pluginInfo[0].Configuration.DefaultWorkingDirectory)
	assert.Equal(t, testSessionId, pluginInfo[0].Configuration.SessionId)
	assert.Equal(t, testClientId, pluginInfo[0].Configuration.ClientId)
	assert.Equal(t, testLogGroupName, pluginInfo[0].Configuration.CloudWatchLogGroup)
	assert.Equal(t, fileutil.BuildPath(testOrchDir, appconfig.PluginNameStandardStream), pluginInfo[0].Configuration.OrchestrationDirectory)
	assert.Empty(t, pluginInfo[0].Configuration.Properties)
	assert.Equal(t, testKmsKeyId, pluginInfo[0].Configuration.KmsKeyId)
}

func TestInitializeDocStateForStartSessionDocumentWithParameters_Valid(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		MessageId:        testMessageID,
		DocumentId:       testDocumentID,
		OrchestrationDir: testOrchDir,
	}

	s3BucketName := contracts.Parameter{
		DefaultVal: testS3Bucket,
		ParamType:  "String",
	}

	parameters := map[string]*contracts.Parameter{
		"s3BucketName": &s3BucketName,
	}

	sessionInputs := contracts.SessionInputs{
		S3BucketName:           "{{s3BucketName}}",
		S3KeyPrefix:            testS3Prefix,
		KmsKeyId:               testKmsKeyId,
		CloudWatchLogGroupName: testLogGroupName,
	}

	sessionDocContent := &SessionDocContent{
		SchemaVersion: "1.0",
		Inputs:        sessionInputs,
		Parameters:    parameters,
		SessionType:   appconfig.PluginNameStandardStream,
		Properties:    testProperties,
	}

	docState, err := InitializeDocState(context,
		contracts.StartSession,
		sessionDocContent,
		contracts.DocumentInfo{DocumentID: testSessionId, ClientId: testClientId},
		testParserInfo,
		nil)

	assert.Nil(t, err)

	pluginInfo := docState.InstancePluginsInformation
	assert.Equal(t, contracts.StartSession, docState.DocumentType)
	assert.Equal(t, "1.0", docState.SchemaVersion)
	assert.Equal(t, testOrchDir, docState.IOConfig.OrchestrationDirectory)
	assert.Equal(t, testS3Prefix, pluginInfo[0].Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testS3Bucket, pluginInfo[0].Configuration.OutputS3BucketName)
	assert.Equal(t, false, pluginInfo[0].Configuration.S3EncryptionEnabled)
	assert.Equal(t, 1, len(pluginInfo))
	assert.Equal(t, testMessageID, pluginInfo[0].Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfo[0].Configuration.BookKeepingFileName)
	assert.Equal(t, "", pluginInfo[0].Configuration.DefaultWorkingDirectory)
	assert.Equal(t, testSessionId, pluginInfo[0].Configuration.SessionId)
	assert.Equal(t, testClientId, pluginInfo[0].Configuration.ClientId)
	assert.Equal(t, testLogGroupName, pluginInfo[0].Configuration.CloudWatchLogGroup)
	assert.Equal(t, fileutil.BuildPath(testOrchDir, appconfig.PluginNameStandardStream), pluginInfo[0].Configuration.OrchestrationDirectory)
	assert.Equal(t, testProperties, pluginInfo[0].Configuration.Properties)
	assert.Equal(t, testKmsKeyId, pluginInfo[0].Configuration.KmsKeyId)
}

func TestInitializeDocStateForStartSessionDocumentWithBooleanParameters_Valid(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		MessageId:        testMessageID,
		DocumentId:       testDocumentID,
		OrchestrationDir: testOrchDir,
	}

	s3BucketName := contracts.Parameter{
		DefaultVal: testS3Bucket,
		ParamType:  "String",
	}

	s3BucketEnable := contracts.Parameter{
		DefaultVal: "true",
		ParamType:  "String",
	}

	parameters := map[string]*contracts.Parameter{
		"s3BucketName":   &s3BucketName,
		"s3BucketEnable": &s3BucketEnable,
	}

	sessionInputs := contracts.SessionInputs{
		S3BucketName:           "{{s3BucketName}}",
		S3KeyPrefix:            testS3Prefix,
		S3EncryptionEnabled:    "{{s3BucketEnable}}",
		KmsKeyId:               testKmsKeyId,
		CloudWatchLogGroupName: testLogGroupName,
	}

	sessionDocContent := &SessionDocContent{
		SchemaVersion: "1.0",
		Inputs:        sessionInputs,
		Parameters:    parameters,
		SessionType:   appconfig.PluginNameStandardStream,
		Properties:    testProperties,
	}

	docState, err := InitializeDocState(context,
		contracts.StartSession,
		sessionDocContent,
		contracts.DocumentInfo{DocumentID: testSessionId, ClientId: testClientId},
		testParserInfo,
		nil)

	assert.Nil(t, err)

	pluginInfo := docState.InstancePluginsInformation
	assert.Equal(t, contracts.StartSession, docState.DocumentType)
	assert.Equal(t, "1.0", docState.SchemaVersion)
	assert.Equal(t, testOrchDir, docState.IOConfig.OrchestrationDirectory)
	assert.Equal(t, testS3Prefix, pluginInfo[0].Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testS3Bucket, pluginInfo[0].Configuration.OutputS3BucketName)
	assert.Equal(t, true, pluginInfo[0].Configuration.S3EncryptionEnabled)
	assert.Equal(t, 1, len(pluginInfo))
	assert.Equal(t, testMessageID, pluginInfo[0].Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfo[0].Configuration.BookKeepingFileName)
	assert.Equal(t, "", pluginInfo[0].Configuration.DefaultWorkingDirectory)
	assert.Equal(t, testSessionId, pluginInfo[0].Configuration.SessionId)
	assert.Equal(t, testClientId, pluginInfo[0].Configuration.ClientId)
	assert.Equal(t, testLogGroupName, pluginInfo[0].Configuration.CloudWatchLogGroup)
	assert.Equal(t, fileutil.BuildPath(testOrchDir, appconfig.PluginNameStandardStream), pluginInfo[0].Configuration.OrchestrationDirectory)
	assert.Equal(t, testProperties, pluginInfo[0].Configuration.Properties)
	assert.Equal(t, testKmsKeyId, pluginInfo[0].Configuration.KmsKeyId)
}

func TestParseDocument_EmptyDocContent(t *testing.T) {
	context := context.NewMockDefault()
	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	var testDocContent DocContent
	testDocContent.SchemaVersion = "1.2"
	_, err := testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.NotNil(t, err)
	assert.Error(t, err)
	assert.Contains(t, err.Error(), "Unsupported schema format")
}

func TestParseDocument_Invalid(t *testing.T) {
	context := context.NewMockDefault()
	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	var testDocContent DocContent
	err := json.Unmarshal([]byte(invaliddocument), &testDocContent)
	assert.Nil(t, err)
	assert.NoError(t, err, "Error occurred when trying to unmarshal invalid document")
	_, err = testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.NotNil(t, err)
	assert.Error(t, err)
	assert.Contains(t, err.Error(), "Unsupported schema format")
}

func TestParseDocument_InvalidSchema(t *testing.T) {
	context := context.NewMockDefault()
	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}
	var testDocContent DocContent
	invalidschema := loadFile(t, filepath.Join("testdata", "schemaVersion9999.json"))

	err := json.Unmarshal([]byte(invalidschema), &testDocContent)
	assert.Nil(t, err)
	assert.NoError(t, err, "Error occurred when trying to unmarshal invalid schema")

	_, err = testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)

	assert.Error(t, err)
	assert.Contains(t, err.Error(), "Document with schema version 9999.0 is not supported by this version of ssm agent")
}

func TestParseDocument_ValidParameters(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	var testDocContent DocContent
	err := json.Unmarshal([]byte(parameterdocument), &testDocContent)
	assert.Nil(t, err)
	assert.NoError(t, err, "Error occurred when trying to unmarshal valid document")

	var testParams map[string]interface{}
	err = json.Unmarshal([]byte(testparameters), &testParams)
	assert.Nil(t, err)
	assert.NoError(t, err, "Error occurred when trying to unmarshal test parameters")
	originalMessage, _ := jsonutil.Marshal(testDocContent)

	pluginsInfo, err := testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, testParams)
	parsedMessage, _ := jsonutil.Marshal(testDocContent)

	assert.Nil(t, err)
	assert.Equal(t, 1, len(pluginsInfo))

	pluginInfoTest := pluginsInfo[0]
	assert.Equal(t, "", pluginInfoTest.Result.Error)
	assert.Equal(t, filepath.Join(testOrchDir, "awsrunPowerShellScript"), pluginInfoTest.Configuration.OrchestrationDirectory)
	assert.Equal(t, testS3Bucket, pluginInfoTest.Configuration.OutputS3BucketName)
	assert.Equal(t, path.Join(testS3Prefix, "awsrunPowerShellScript"), pluginInfoTest.Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testMessageID, pluginInfoTest.Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfoTest.Configuration.BookKeepingFileName)
	assert.Equal(t, testWorkingDir, pluginInfoTest.Configuration.DefaultWorkingDirectory)
	assert.NotEqual(t, parsedMessage, originalMessage)
}

func TestParseDocument_ReplaceDefaultParameters(t *testing.T) {
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	var testDocContent DocContent
	defaultParamatersDoc := loadFile(t, filepath.Join("testdata", "sampleReplaceDefaultParams.json"))

	err := json.Unmarshal([]byte(defaultParamatersDoc), &testDocContent)
	assert.Nil(t, err)
	assert.NoError(t, err, "Error occurred when trying to unmarshal test parameters")
	originalMessage, _ := jsonutil.Marshal(testDocContent)

	pluginsInfo, err := testDocContent.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, nil)
	parsedMessage, _ := jsonutil.Marshal(testDocContent)

	assert.Nil(t, err)
	assert.Equal(t, 1, len(pluginsInfo))

	pluginInfoTest := pluginsInfo[0]
	assert.Equal(t, "", pluginInfoTest.Result.Error)
	assert.Equal(t, filepath.Join(testOrchDir, "example"), pluginInfoTest.Configuration.OrchestrationDirectory)
	assert.Equal(t, testS3Bucket, pluginInfoTest.Configuration.OutputS3BucketName)
	assert.Equal(t, path.Join(testS3Prefix, "awsrunPowerShellScript"), pluginInfoTest.Configuration.OutputS3KeyPrefix)
	assert.Equal(t, testMessageID, pluginInfoTest.Configuration.MessageId)
	assert.Equal(t, testDocumentID, pluginInfoTest.Configuration.BookKeepingFileName)
	assert.Equal(t, testWorkingDir, pluginInfoTest.Configuration.DefaultWorkingDirectory)
	assert.NotEqual(t, parsedMessage, originalMessage)
}

func TestIsCrossPlatformEnabledForSchema20(t *testing.T) {
	var schemaVersion = "2.0"
	isCrossPlatformEnabled := isPreconditionEnabled(schemaVersion)

	// isCrossPlatformEnabled should be false for 2.0 document
	assert.False(t, isCrossPlatformEnabled)
}

func TestIsCrossPlatformEnabledForSchema22(t *testing.T) {
	var schemaVersion = "2.2"
	isCrossPlatformEnabled := isPreconditionEnabled(schemaVersion)

	// isCrossPlatformEnabled should be true for 2.2 document
	assert.True(t, isCrossPlatformEnabled)
}

func TestParseMessageWithParams(t *testing.T) {
	type testCase struct {
		Input       string
		OutputDoc   DocContent
		OutputParam map[string]interface{}
	}
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	// generate test cases
	var testCases []testCase
	for _, msgFileName := range sampleMessageFiles {
		outputDoc, outputParam := loadMessageFromFile(t, msgFileName)
		fmt.Print(msgFileName)
		testCases = append(testCases, testCase{
			Input:       string(loadFile(t, msgFileName)),
			OutputDoc:   outputDoc,
			OutputParam: outputParam,
		})
	}

	// run tests
	for _, tst := range testCases {
		// call method
		origMessage, _ := jsonutil.Marshal(tst.OutputDoc)
		pluginsInfo, err := tst.OutputDoc.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, tst.OutputParam)
		parsedMessage, _ := jsonutil.Marshal(tst.OutputDoc)

		// check results
		fmt.Print(tst.OutputDoc)
		assert.Nil(t, err)
		assert.Equal(t, testS3Bucket, pluginsInfo[0].Configuration.OutputS3BucketName)
		assert.Equal(t, testMessageID, pluginsInfo[0].Configuration.MessageId)
		assert.Equal(t, testDocumentID, pluginsInfo[0].Configuration.BookKeepingFileName)
		assert.Equal(t, testWorkingDir, pluginsInfo[0].Configuration.DefaultWorkingDirectory)
		assert.NotEqual(t, origMessage, parsedMessage)
	}
}

func TestParsingDocNameForVersion_Empty(t *testing.T) {
	docName, docVersion := ParseDocumentNameAndVersion("")

	assert.Equal(t, docVersion, "")
	assert.Equal(t, docName, "")
}

func TestParsingDocNameForVersion_NoVersion(t *testing.T) {
	docName, docVersion := ParseDocumentNameAndVersion("AWS-RunShellScript")

	assert.Equal(t, docVersion, "")
	assert.Equal(t, docName, "AWS-RunShellScript")
}

func TestParsingDocNameForVersion_Version(t *testing.T) {
	docName, docVersion := ParseDocumentNameAndVersion("AWS-RunShellScript:10")

	assert.Equal(t, docVersion, "10")
	assert.Equal(t, docName, "AWS-RunShellScript")
}

func TestParsingDocNameForVersion_InvalidVersion(t *testing.T) {
	docName, docVersion := ParseDocumentNameAndVersion("AWS-RunShellScript:version")

	assert.Equal(t, docVersion, "version")
	assert.Equal(t, docName, "AWS-RunShellScript")
}

func TestParseMessageWithPreconditions(t *testing.T) {
	type testCase struct {
		Input                 string
		OutputDoc             DocContent
		OutputParam           map[string]interface{}
		ResolvedPreconditions map[string][]contracts.PreconditionArgument
	}
	context := context.NewMockDefault()

	testParserInfo := DocumentParserInfo{
		OrchestrationDir:  testOrchDir,
		S3Bucket:          testS3Bucket,
		S3Prefix:          testS3Prefix,
		MessageId:         testMessageID,
		DocumentId:        testDocumentID,
		DefaultWorkingDir: testWorkingDir,
	}

	// generate test cases
	var testCases []testCase
	preconditions := loadPreconditionsFromFile(t)
	t.Logf("preconditions: %v", preconditions)
	for _, msgFileName := range sampleMessageWithPreconditionFiles {
		outputDoc, outputParam := loadMessageFromFile(t, msgFileName)
		fmt.Print(msgFileName)
		testCases = append(testCases, testCase{
			Input:                 string(loadFile(t, msgFileName)),
			OutputDoc:             outputDoc,
			OutputParam:           outputParam,
			ResolvedPreconditions: preconditions[msgFileName],
		})
	}

	// run tests
	for _, tst := range testCases {
		// call method
		pluginsInfo, err := tst.OutputDoc.ParseDocument(context, contracts.DocumentInfo{}, testParserInfo, tst.OutputParam)

		// check results
		assert.Nil(t, err)
		assert.Equal(t, testS3Bucket, pluginsInfo[0].Configuration.OutputS3BucketName)
		assert.Equal(t, testMessageID, pluginsInfo[0].Configuration.MessageId)
		assert.Equal(t, testDocumentID, pluginsInfo[0].Configuration.BookKeepingFileName)
		assert.Equal(t, testWorkingDir, pluginsInfo[0].Configuration.DefaultWorkingDirectory)
		assert.Equal(t, tst.ResolvedPreconditions, pluginsInfo[0].Configuration.Preconditions)
	}
}

func loadFile(t *testing.T, fileName string) (result []byte) {
	result, err := ioutil.ReadFile(fileName)
	if err != nil {
		t.Fatal(err)
	}
	return
}

func loadMessageFromFile(t *testing.T, fileName string) (testDocContent DocContent, params map[string]interface{}) {
	b := loadFile(t, fileName)
	err := json.Unmarshal(b, &testDocContent)
	if err != nil {
		t.Fatal(err)
	}
	p := loadFile(t, filepath.Join("testdata", "sampleMessageParameters.json"))
	err = json.Unmarshal(p, &params)
	if err != nil {
		t.Fatal(err)
	}
	return testDocContent, params
}

func loadPreconditionsFromFile(t *testing.T) (preconditions map[string]map[string][]contracts.PreconditionArgument) {
	b := loadFile(t, filepath.Join("testdata", "sampleResolvedMessagePreconditions.json"))

	err := json.Unmarshal(b, &preconditions)
	if err != nil {
		t.Fatal(err)
	}
	return preconditions
}