// Unless explicitly stated otherwise all files in this repository are licensed
// under the Apache License Version 2.0.
// This product includes software developed at Datadog (https://www.datadoghq.com/).
// Copyright 2016 Datadog, Inc.

package stableconfig

import (
	"os"
	"testing"

	"github.com/stretchr/testify/assert"

	"github.com/DataDog/dd-trace-go/v2/internal/telemetry"
	"github.com/DataDog/dd-trace-go/v2/internal/telemetry/telemetrytest"
)

func TestBool(t *testing.T) {
	// Test typical operation with valid files
	t.Run("valid configurations", func(t *testing.T) {
		// Setup mock telemetry client
		telemetryClient := new(telemetrytest.MockClient)
		telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "UNKNOWN_KEY", Value: true, Origin: telemetry.OriginDefault, ID: telemetry.EmptyID}}).Return()
		telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: true, Origin: telemetry.OriginLocalStableConfig, ID: "100"}}).Return()
		telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: false, Origin: telemetry.OriginEnvVar, ID: telemetry.EmptyID}}).Return()
		telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: false, Origin: telemetry.OriginManagedStableConfig, ID: "200"}}).Return()
		defer telemetry.MockClient(telemetryClient)()

		tests := []struct {
			name           string
			localYaml      string           // YAML content for local config file
			managedYaml    string           // YAML content for managed config file
			envValue       string           // Environment variable value
			key            string           // Configuration key to test
			defaultValue   bool             // Default value to use
			expectedValue  bool             // Expected result value
			expectedOrigin telemetry.Origin // Expected origin of the value
			expectedID     string           // Expected Config ID of the value
			expectedErr    error            // Expected error, if any
		}{
			// When no config exists, return default value
			{
				name:           "default value",
				key:            "UNKNOWN_KEY",
				defaultValue:   true,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginDefault,
				expectedID:     telemetry.EmptyID,
			},
			//  Local config overrides default
			{
				name:           "local config only",
				localYaml:      "config_id: 100\napm_configuration_default:\n    DD_KEY: true",
				key:            "DD_KEY",
				defaultValue:   false,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginLocalStableConfig,
				expectedID:     "100",
			},
			// Env var overrides local config
			{
				name:           "env overrides local",
				localYaml:      "config_id: 100\napm_configuration_default:\n    DD_KEY: true",
				envValue:       "false",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  false,
				expectedOrigin: telemetry.OriginEnvVar,
				expectedID:     telemetry.EmptyID,
			},
			// Managed config overrides env var
			{
				name:           "managed overrides env",
				localYaml:      "config_id: 100\napm_configuration_default:\n    DD_KEY: true",
				managedYaml:    "config_id: 200\napm_configuration_default:\n    DD_KEY: false",
				envValue:       "true",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  false,
				expectedOrigin: telemetry.OriginManagedStableConfig,
				expectedID:     "200",
			},
		}

		for _, tt := range tests {
			t.Run(tt.name, func(t *testing.T) {
				// Setup test environment
				if tt.localYaml != "" {
					tempLocalPath := "local.yml"
					err := os.WriteFile(tempLocalPath, []byte(tt.localYaml), 0644)
					assert.NoError(t, err)
					defer os.Remove(tempLocalPath)
					LocalConfig = newStableConfigSource(tempLocalPath, telemetry.OriginLocalStableConfig)
					defer func() { LocalConfig = newStableConfigSource(localFilePath, telemetry.OriginLocalStableConfig) }()
				}

				if tt.managedYaml != "" {
					tempManagedPath := "managed.yml"
					err := os.WriteFile(tempManagedPath, []byte(tt.managedYaml), 0644)
					assert.NoError(t, err)
					defer os.Remove(tempManagedPath)
					ManagedConfig = newStableConfigSource(tempManagedPath, telemetry.OriginManagedStableConfig)
					defer func() { ManagedConfig = newStableConfigSource(managedFilePath, telemetry.OriginManagedStableConfig) }()
				}

				if tt.envValue != "" {
					t.Setenv(tt.key, tt.envValue)
				}

				val, origin, err := Bool(tt.key, tt.defaultValue)
				assert.Equal(t, tt.expectedValue, val)
				assert.Equal(t, tt.expectedOrigin, origin)
				assert.Equal(t, tt.expectedErr, err)

				telemetryClient.AssertCalled(t, "RegisterAppConfigs", []telemetry.Configuration{{Name: tt.key, Value: tt.expectedValue, Origin: tt.expectedOrigin, ID: tt.expectedID}})
			})
		}
	})

	// Test error handling with invalid configurations
	t.Run("error handling", func(t *testing.T) {
		tests := []struct {
			name           string
			localYaml      string
			managedYaml    string
			envValue       string
			key            string
			defaultValue   bool
			expectedValue  bool
			expectedOrigin telemetry.Origin
			expectedErr    string
		}{
			// Invalid boolean in managed config
			{
				name:           "invalid managed config value",
				managedYaml:    "apm_configuration_default:\n    DD_KEY: not-a-bool",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginDefault,
				expectedErr:    "non-boolean value for DD_KEY: 'not-a-bool' in fleet_stable_config configuration, dropping",
			},
			// Invalid boolean in environment variable
			{
				name:           "invalid env value",
				envValue:       "not-a-bool",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginDefault,
				expectedErr:    "non-boolean value for DD_KEY: 'not-a-bool' in env_var configuration, dropping",
			},
			// Invalid boolean in local config
			{
				name:           "invalid local config value",
				localYaml:      "apm_configuration_default:\n    DD_KEY: not-a-bool",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginDefault,
				expectedErr:    "non-boolean value for DD_KEY: 'not-a-bool' in local_stable_config configuration, dropping",
			},
			// Empty string in config; no error expected
			{
				name:           "empty string in config",
				localYaml:      "apm_configuration_default:\n    DD_KEY: ''",
				key:            "DD_KEY",
				defaultValue:   true,
				expectedValue:  true,
				expectedOrigin: telemetry.OriginDefault,
				expectedErr:    "",
			},
		}

		for _, tt := range tests {
			t.Run(tt.name, func(t *testing.T) {
				// Setup test environment
				if tt.localYaml != "" {
					tempLocalPath := "local.yml"
					err := os.WriteFile(tempLocalPath, []byte(tt.localYaml), 0644)
					assert.NoError(t, err)
					defer os.Remove(tempLocalPath)
					LocalConfig = newStableConfigSource(tempLocalPath, telemetry.OriginLocalStableConfig)
					defer func() { LocalConfig = newStableConfigSource(localFilePath, telemetry.OriginLocalStableConfig) }()
				}

				if tt.managedYaml != "" {
					tempManagedPath := "managed.yml"
					err := os.WriteFile(tempManagedPath, []byte(tt.managedYaml), 0644)
					assert.NoError(t, err)
					defer os.Remove(tempManagedPath)
					ManagedConfig = newStableConfigSource(tempManagedPath, telemetry.OriginManagedStableConfig)
					defer func() { ManagedConfig = newStableConfigSource(managedFilePath, telemetry.OriginManagedStableConfig) }()
				}

				if tt.envValue != "" {
					t.Setenv(tt.key, tt.envValue)
				}

				val, origin, err := Bool(tt.key, tt.defaultValue)
				assert.Equal(t, tt.expectedValue, val)
				assert.Equal(t, tt.expectedOrigin, origin)
				if tt.expectedErr != "" {
					assert.ErrorContains(t, err, tt.expectedErr)
				} else {
					assert.NoError(t, err)
				}
			})
		}
	})
}

func TestString(t *testing.T) {
	// Yaml content for local and managed files
	localYaml := `
config_id: 100
apm_configuration_default:
    DD_KEY: local
`
	managedYaml := `
config_id: 200
apm_configuration_default:
    DD_KEY: managed
`
	// Modify file paths for testing
	tempLocalPath := "local.yml"
	tempManagedPath := "managed.yml"
	// Write to local file, and defer delete it
	err := os.WriteFile(tempLocalPath, []byte(localYaml), 0644)
	assert.NoError(t, err)
	defer os.Remove(tempLocalPath)
	// Write to managed file, and defer delete it
	err = os.WriteFile(tempManagedPath, []byte(managedYaml), 0644)
	assert.NoError(t, err)
	defer os.Remove(tempManagedPath)

	// Setup mock telemetry client
	telemetryClient := new(telemetrytest.MockClient)
	telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "default", Origin: telemetry.OriginDefault, ID: telemetry.EmptyID}}).Return()
	telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "local", Origin: telemetry.OriginLocalStableConfig, ID: "100"}}).Return()
	telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "env", Origin: telemetry.OriginEnvVar, ID: telemetry.EmptyID}}).Return()
	telemetryClient.On("RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "managed", Origin: telemetry.OriginManagedStableConfig, ID: "200"}}).Return()
	defer telemetry.MockClient(telemetryClient)()

	t.Run("default", func(t *testing.T) {
		val, origin := String("DD_KEY", "default")
		assert.Equal(t, "default", val)
		assert.Equal(t, telemetry.OriginDefault, origin)
		telemetryClient.AssertCalled(t, "RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "default", Origin: telemetry.OriginDefault, ID: telemetry.EmptyID}})
	})
	t.Run("localStableconfig only", func(t *testing.T) {
		LocalConfig = newStableConfigSource(tempLocalPath, telemetry.OriginLocalStableConfig)
		defer func() { LocalConfig = newStableConfigSource(localFilePath, telemetry.OriginLocalStableConfig) }()
		val, origin := String("DD_KEY", "default")
		assert.Equal(t, "local", val)
		assert.Equal(t, telemetry.OriginLocalStableConfig, origin)
		telemetryClient.AssertCalled(t, "RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "local", Origin: telemetry.OriginLocalStableConfig, ID: "100"}})
	})
	t.Run("env overrides localStableConfig", func(t *testing.T) {
		t.Setenv("DD_KEY", "env")
		LocalConfig = newStableConfigSource(tempLocalPath, telemetry.OriginLocalStableConfig)
		defer func() { LocalConfig = newStableConfigSource(localFilePath, telemetry.OriginLocalStableConfig) }()
		val, origin := String("DD_KEY", "default")
		assert.Equal(t, "env", val)
		assert.Equal(t, telemetry.OriginEnvVar, origin)
		telemetryClient.AssertCalled(t, "RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "env", Origin: telemetry.OriginEnvVar, ID: telemetry.EmptyID}})
	})
	t.Run("managedStableConfig overrides env", func(t *testing.T) {
		t.Setenv("DD_KEY", "env")

		LocalConfig = newStableConfigSource(tempLocalPath, telemetry.OriginLocalStableConfig)
		defer func() { LocalConfig = newStableConfigSource(localFilePath, telemetry.OriginLocalStableConfig) }()

		ManagedConfig = newStableConfigSource(tempManagedPath, telemetry.OriginManagedStableConfig)
		defer func() { ManagedConfig = newStableConfigSource(managedFilePath, telemetry.OriginManagedStableConfig) }()

		val, origin := String("DD_KEY", "default")
		assert.Equal(t, "managed", val)
		assert.Equal(t, telemetry.OriginManagedStableConfig, origin)

		telemetryClient.AssertCalled(t, "RegisterAppConfigs", []telemetry.Configuration{{Name: "DD_KEY", Value: "managed", Origin: telemetry.OriginManagedStableConfig, ID: "200"}})
	})
}
