// Copyright 2016-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 node

import (
	"context"
	"os"
	"strconv"
	"testing"
	"time"

	"github.com/rs/zerolog/log"

	"github.com/aws/aws-node-termination-handler/pkg/config"
	h "github.com/aws/aws-node-termination-handler/pkg/test"
	"github.com/aws/aws-node-termination-handler/pkg/uptime"
	v1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes/fake"
	"k8s.io/kubectl/pkg/drain"
)

var nodeName = "NAME"
var testFile = "test.out"

func getUptimeFromFile(filepath string) uptime.UptimeFuncType {
	return func() (int64, error) {
		return uptime.UptimeFromFile(filepath)
	}
}

func getTestDrainHelper(client *fake.Clientset) *drain.Helper {
	return &drain.Helper{
		Ctx:                 context.TODO(),
		Client:              client,
		Force:               true,
		GracePeriodSeconds:  -1,
		IgnoreAllDaemonSets: true,
		DeleteEmptyDirData:  true,
		Timeout:             time.Duration(120) * time.Second,
		Out:                 log.Logger,
		ErrOut:              log.Logger,
	}
}

func getNode(t *testing.T, drainHelper *drain.Helper, uptime uptime.UptimeFuncType) *Node {
	nthConfig := config.Config{
		NodeName: nodeName,
	}
	tNode, err := NewWithValues(nthConfig, drainHelper, uptime)
	if err != nil {
		t.Error("failed to create node")
	}
	return tNode
}

func TestUncordonIfRebootedFileReadError(t *testing.T) {
	client := fake.NewSimpleClientset()
	_, err := client.CoreV1().Nodes().Create(context.Background(),
		&v1.Node{
			ObjectMeta: metav1.ObjectMeta{
				Name: nodeName,
				Labels: map[string]string{
					"aws-node-termination-handler/action":      "UncordonAfterReboot",
					"aws-node-termination-handler/action-time": strconv.FormatInt(time.Now().Unix(), 10),
				},
			},
		},
		metav1.CreateOptions{})
	h.Ok(t, err)
	tNode := getNode(t, getTestDrainHelper(client), getUptimeFromFile("does-not-exist"))
	err = tNode.UncordonIfRebooted(nodeName)
	h.Assert(t, err != nil, "Failed to return error on UncordonIfRebooted failure to read file")
}

func TestUncordonIfRebootedSystemNotRestarted(t *testing.T) {
	d1 := []byte("350735.47 234388.90")
	err := os.WriteFile(testFile, d1, 0644)
	h.Ok(t, err)

	client := fake.NewSimpleClientset()
	_, err = client.CoreV1().Nodes().Create(context.TODO(),
		&v1.Node{
			ObjectMeta: metav1.ObjectMeta{
				Name: nodeName,
				Labels: map[string]string{
					"aws-node-termination-handler/action":      "UncordonAfterReboot",
					"aws-node-termination-handler/action-time": strconv.FormatInt(time.Now().Unix(), 10),
				},
			},
		},
		metav1.CreateOptions{})
	h.Ok(t, err)
	tNode := getNode(t, getTestDrainHelper(client), getUptimeFromFile(testFile))
	err = tNode.UncordonIfRebooted(nodeName)
	os.Remove(testFile)
	h.Ok(t, err)
}

func TestUncordonIfRebootedFailureToRemoveLabel(t *testing.T) {
	d1 := []byte("0 234388.90")
	err := os.WriteFile(testFile, d1, 0644)
	h.Ok(t, err)

	client := fake.NewSimpleClientset()
	_, err = client.CoreV1().Nodes().Create(context.Background(),
		&v1.Node{
			ObjectMeta: metav1.ObjectMeta{
				Name: nodeName,
				Labels: map[string]string{
					"aws-node-termination-handler/action":      "UncordonAfterReboot",
					"aws-node-termination-handler/action-time": strconv.FormatInt(time.Now().Unix(), 10),
				},
			},
		},
		metav1.CreateOptions{})
	h.Ok(t, err)
	tNode := getNode(t, getTestDrainHelper(client), getUptimeFromFile(testFile))
	err = tNode.UncordonIfRebooted(nodeName)
	os.Remove(testFile)
	h.Assert(t, err != nil, "Failed to return error on UncordonIfReboted failure remove NTH Label")
}

func TestUncordonIfRebootedFailureSuccess(t *testing.T) {
	d1 := []byte("0 234388.90")
	err := os.WriteFile(testFile, d1, 0644)
	h.Ok(t, err)

	client := fake.NewSimpleClientset()
	_, err = client.CoreV1().Nodes().Create(context.Background(),
		&v1.Node{
			ObjectMeta: metav1.ObjectMeta{
				Name: nodeName,
				Labels: map[string]string{
					"aws-node-termination-handler/action":      "UncordonAfterReboot",
					"aws-node-termination-handler/action-time": strconv.FormatInt(time.Now().Unix(), 10),
					"aws-node-termination-handler/event-id":    "HELLO",
				},
			},
		},
		metav1.CreateOptions{})
	h.Ok(t, err)
	tNode := getNode(t, getTestDrainHelper(client), getUptimeFromFile(testFile))
	err = tNode.UncordonIfRebooted(nodeName)
	os.Remove(testFile)
	h.Ok(t, err)
}

func TestGetUptimeFuncDefault(t *testing.T) {
	uptimeFunc := getUptimeFunc("")
	h.Assert(t, uptimeFunc != nil, "Failed to return a function.")
}

func TestGetUptimeFuncWithFile(t *testing.T) {
	uptimeFunc := getUptimeFunc(testFile)
	h.Assert(t, uptimeFunc != nil, "Failed to return a function.")
}