// Copyright 2023 Google LLC.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package internal

import (
	"encoding/json"
	"fmt"
	"testing"
	"time"
)

const testS2AAddr = "testS2AAddress:port"

var validConfigResp = func() (string, error) {
	validConfig := mtlsConfig{
		S2A: &s2aAddresses{
			PlaintextAddress: testS2AAddr,
			MTLSAddress:      "",
		},
	}
	configStr, err := json.Marshal(validConfig)
	if err != nil {
		return "", err
	}
	return string(configStr), nil
}

var errorConfigResp = func() (string, error) {
	return "", fmt.Errorf("error getting config")
}

var invalidConfigResp = func() (string, error) {
	return "{}", nil
}

var invalidJSONResp = func() (string, error) {
	return "test", nil
}

func TestGetS2AAddress(t *testing.T) {
	testCases := []struct {
		Desc     string
		RespFunc func() (string, error)
		Want     string
	}{
		{
			Desc:     "test valid config",
			RespFunc: validConfigResp,
			Want:     testS2AAddr,
		},
		{
			Desc:     "test error when getting config",
			RespFunc: errorConfigResp,
			Want:     "",
		},
		{
			Desc:     "test invalid config",
			RespFunc: invalidConfigResp,
			Want:     "",
		},
		{
			Desc:     "test invalid JSON response",
			RespFunc: invalidJSONResp,
			Want:     "",
		},
	}

	oldHTTPGet := httpGetMetadataMTLSConfig
	oldExpiry := configExpiry
	configExpiry = time.Millisecond
	defer func() {
		httpGetMetadataMTLSConfig = oldHTTPGet
		configExpiry = oldExpiry
	}()
	for _, tc := range testCases {
		httpGetMetadataMTLSConfig = tc.RespFunc
		if want, got := tc.Want, GetS2AAddress(); got != want {
			t.Errorf("%s: want address [%s], got address [%s]", tc.Desc, want, got)
		}
		// Let the MTLS config expire at the end of each test case.
		time.Sleep(2 * time.Millisecond)
	}
}

func TestMTLSConfigExpiry(t *testing.T) {
	oldHTTPGet := httpGetMetadataMTLSConfig
	oldExpiry := configExpiry
	configExpiry = 1 * time.Second
	defer func() {
		httpGetMetadataMTLSConfig = oldHTTPGet
		configExpiry = oldExpiry
	}()
	httpGetMetadataMTLSConfig = validConfigResp
	if got, want := GetS2AAddress(), testS2AAddr; got != want {
		t.Errorf("expected address: [%s], got [%s]", want, got)
	}
	httpGetMetadataMTLSConfig = invalidConfigResp
	if got, want := GetS2AAddress(), testS2AAddr; got != want {
		t.Errorf("cached config should still be valid, expected address: [%s], got [%s]", want, got)
	}
	time.Sleep(1 * time.Second)
	if got, want := GetS2AAddress(), ""; got != want {
		t.Errorf("config should be refreshed, expected address: [%s], got [%s]", want, got)
	}
	// Let the MTLS config expire before running other tests.
	time.Sleep(1 * time.Second)
}