/*
Copyright The Helm 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 plugin

import (
	"bytes"
	"fmt"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

func TestPeekAPIVersion(t *testing.T) {
	testCases := map[string]struct {
		data     []byte
		expected string
	}{
		"legacy": { // No apiVersion field
			data: []byte(`---
name: "test-plugin"
`),
			expected: "",
		},
	}

	for name, tc := range testCases {
		t.Run(name, func(t *testing.T) {
			version, err := peekAPIVersion(bytes.NewReader(tc.data))
			require.NoError(t, err)
			assert.Equal(t, tc.expected, version)
		})
	}

	// invalid yaml
	{
		data := []byte(`bad yaml`)
		_, err := peekAPIVersion(bytes.NewReader(data))
		assert.Error(t, err)
	}
}

func TestLoadDir(t *testing.T) {

	makeMetadata := func(apiVersion string) Metadata {
		usage := "hello [params]..."
		if apiVersion == "legacy" {
			usage = "" // Legacy plugins don't have Usage field for command syntax
		}
		return Metadata{
			APIVersion: apiVersion,
			Name:       fmt.Sprintf("hello-%s", apiVersion),
			Version:    "0.1.0",
			Type:       "cli/v1",
			Runtime:    "subprocess",
			Config: &ConfigCLI{
				Usage:       usage,
				ShortHelp:   "echo hello message",
				LongHelp:    "description",
				IgnoreFlags: true,
			},
			RuntimeConfig: &RuntimeConfigSubprocess{
				PlatformCommands: []PlatformCommand{
					{OperatingSystem: "linux", Architecture: "", Command: "sh", Args: []string{"-c", "${HELM_PLUGIN_DIR}/hello.sh"}},
					{OperatingSystem: "windows", Architecture: "", Command: "pwsh", Args: []string{"-c", "${HELM_PLUGIN_DIR}/hello.ps1"}},
				},
				PlatformHooks: map[string][]PlatformCommand{
					Install: {
						{OperatingSystem: "linux", Architecture: "", Command: "sh", Args: []string{"-c", "echo \"installing...\""}},
						{OperatingSystem: "windows", Architecture: "", Command: "pwsh", Args: []string{"-c", "echo \"installing...\""}},
					},
				},
			},
		}
	}

	testCases := map[string]struct {
		dirname    string
		apiVersion string
		expect     Metadata
	}{
		"legacy": {
			dirname:    "testdata/plugdir/good/hello-legacy",
			apiVersion: "legacy",
			expect:     makeMetadata("legacy"),
		},
	}

	for name, tc := range testCases {
		t.Run(name, func(t *testing.T) {
			plug, err := LoadDir(tc.dirname)
			require.NoError(t, err, "error loading plugin from %s", tc.dirname)

			assert.Equal(t, tc.dirname, plug.Dir())
			assert.EqualValues(t, tc.expect, plug.Metadata())
		})
	}
}

func TestLoadDirDuplicateEntries(t *testing.T) {
	testCases := map[string]string{
		"legacy": "testdata/plugdir/bad/duplicate-entries-legacy",
	}
	for name, dirname := range testCases {
		t.Run(name, func(t *testing.T) {
			_, err := LoadDir(dirname)
			assert.Error(t, err)
		})
	}
}

func TestDetectDuplicates(t *testing.T) {
	plugs := []Plugin{
		mockSubprocessCLIPlugin(t, "foo"),
		mockSubprocessCLIPlugin(t, "bar"),
	}
	if err := detectDuplicates(plugs); err != nil {
		t.Error("no duplicates in the first set")
	}
	plugs = append(plugs, mockSubprocessCLIPlugin(t, "foo"))
	if err := detectDuplicates(plugs); err == nil {
		t.Error("duplicates in the second set")
	}
}

func TestLoadAll(t *testing.T) {
	// Verify that empty dir loads:
	{
		plugs, err := LoadAll("testdata")
		require.NoError(t, err)
		assert.Len(t, plugs, 0)
	}

	basedir := "testdata/plugdir/good"
	plugs, err := LoadAll(basedir)
	require.NoError(t, err)
	require.NotEmpty(t, plugs, "expected plugins to be loaded from %s", basedir)

	plugsMap := map[string]Plugin{}
	for _, p := range plugs {
		plugsMap[p.Metadata().Name] = p
	}

	assert.Len(t, plugsMap, 3)
	assert.Contains(t, plugsMap, "downloader")
	assert.Contains(t, plugsMap, "echo-legacy")
	assert.Contains(t, plugsMap, "hello-legacy")
}

func TestFindPlugins(t *testing.T) {
	cases := []struct {
		name     string
		plugdirs string
		expected int
	}{
		{
			name:     "plugdirs is empty",
			plugdirs: "",
			expected: 0,
		},
		{
			name:     "plugdirs isn't dir",
			plugdirs: "./plugin_test.go",
			expected: 0,
		},
		{
			name:     "plugdirs doesn't have plugin",
			plugdirs: ".",
			expected: 0,
		},
		{
			name:     "normal",
			plugdirs: "./testdata/plugdir/good",
			expected: 3,
		},
	}
	for _, c := range cases {
		t.Run(t.Name(), func(t *testing.T) {
			plugin, err := LoadAll(c.plugdirs)
			require.NoError(t, err)
			assert.Len(t, plugin, c.expected, "expected %d plugins, got %d", c.expected, len(plugin))
		})
	}
}