/*
Copyright 2019 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License 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 testing

import (
	"testing"

	"github.com/stretchr/testify/assert"
	"k8s.io/apimachinery/pkg/api/meta"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/runtime/schema"
)

func TestOriginalObjectCaptured(t *testing.T) {
	// this ReactionFunc sets the resources ClusterName
	const testClusterName = "some-value"
	reactors := []ReactionFunc{
		func(action Action) (bool, runtime.Object, error) {
			createAction := action.(CreateActionImpl)
			accessor, err := meta.Accessor(createAction.Object)
			if err != nil {
				return false, nil, err
			}

			// set any field on the resource
			accessor.SetClusterName(testClusterName)

			return true, createAction.Object, nil
		},
	}

	// create a new Fake with the test reactors
	f := &Fake{}
	for _, r := range reactors {
		f.AddReactor("", "", r)
	}

	// construct a test resource
	testResource := schema.GroupVersionResource{Group: "", Version: "test_version", Resource: "test_kind"}
	testObj := getArbitraryResource(testResource, "test_name", "test_namespace")

	// create a fake CreateAction
	action := CreateActionImpl{
		Object: testObj,
	}

	// execute the reaction chain
	ret, err := f.Invokes(action, nil)
	assert.NoError(t, err, "running Invokes failed")

	// obtain a metadata accessor for the returned resource
	accessor, err := meta.Accessor(ret)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}

	// validate that the returned resource was modified by the ReactionFunc
	if accessor.GetClusterName() != testClusterName {
		t.Errorf("expected resource returned by Invokes to be modified by the ReactionFunc")
	}
	// verify one action was performed
	if len(f.actions) != 1 {
		t.Errorf("expected 1 action to be executed")
		t.FailNow()
	}
	// check to ensure the recorded action has not been modified by the chain
	createAction := f.actions[0].(CreateActionImpl)
	accessor, err = meta.Accessor(createAction.Object)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if accessor.GetClusterName() != "" {
		t.Errorf("expected Action recorded to not be modified by ReactionFunc but it was")
	}
}

func TestReactorChangesPersisted(t *testing.T) {
	// this ReactionFunc sets the resources ClusterName
	const testClusterName = "some-value"
	reactors := []ReactionFunc{
		func(action Action) (bool, runtime.Object, error) {
			createAction := action.(CreateActionImpl)
			accessor, err := meta.Accessor(createAction.Object)
			if err != nil {
				return false, nil, err
			}

			// set any field on the resource
			accessor.SetClusterName(testClusterName)

			return false, createAction.Object, nil
		},
		func(action Action) (bool, runtime.Object, error) {
			createAction := action.(CreateActionImpl)
			accessor, err := meta.Accessor(createAction.Object)
			if err != nil {
				return false, nil, err
			}

			// ensure the clusterName is set to testClusterName already
			if accessor.GetClusterName() != testClusterName {
				t.Errorf("expected resource passed to second reactor to be modified by first reactor")
			}

			return true, createAction.Object, nil
		},
	}

	// create a new Fake with the test reactors
	f := &Fake{}
	for _, r := range reactors {
		f.AddReactor("", "", r)
	}

	// construct a test resource
	testResource := schema.GroupVersionResource{Group: "", Version: "test_version", Resource: "test_kind"}
	testObj := getArbitraryResource(testResource, "test_name", "test_namespace")

	// create a fake CreateAction
	action := CreateActionImpl{
		Object: testObj,
	}

	// execute the reaction chain
	ret, err := f.Invokes(action, nil)
	assert.NoError(t, err, "running Invokes failed")

	// obtain a metadata accessor for the returned resource
	accessor, err := meta.Accessor(ret)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}

	// validate that the returned resource was modified by the ReactionFunc
	if accessor.GetClusterName() != testClusterName {
		t.Errorf("expected resource returned by Invokes to be modified by the ReactionFunc")
	}
	// verify one action was performed
	if len(f.actions) != 1 {
		t.Errorf("expected 1 action to be executed")
		t.FailNow()
	}
	// check to ensure the recorded action has not been modified by the chain
	createAction := f.actions[0].(CreateActionImpl)
	accessor, err = meta.Accessor(createAction.Object)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if accessor.GetClusterName() != "" {
		t.Errorf("expected Action recorded to not be modified by ReactionFunc but it was")
	}
}