cost-model/pkg/cloud/gcp/provider_test.go

package gcp

import (
	"bytes"
	"encoding/json"
	"fmt"
	"net/http"
	"net/http/httptest"
	"net/url"
	"os"
	"reflect"
	"strings"
	"testing"
	"time"

	"github.com/google/martian/log"
	"github.com/opencost/opencost/core/pkg/clustercache"
	"github.com/opencost/opencost/pkg/cloud/httputil"
	"github.com/opencost/opencost/pkg/cloud/models"
	"github.com/opencost/opencost/pkg/config"
	"github.com/stretchr/testify/assert"
	"google.golang.org/api/compute/v1"
	v1 "k8s.io/api/core/v1"
)

func TestParseGCPInstanceTypeLabel(t *testing.T) {
	cases := []struct {
		input    string
		expected string
	}{
		{
			input:    "n1-standard-2",
			expected: "n1standard",
		},
		{
			input:    "e2-medium",
			expected: "e2medium",
		},
		{
			input:    "k3s",
			expected: "unknown",
		},
		{
			input:    "custom-n1-standard-2",
			expected: "custom",
		},
		{
			input:    "n2d-highmem-8",
			expected: "n2dstandard",
		},
		{
			input:    "n4-standard-4",
			expected: "n4standard",
		},
		{
			input:    "n4-highcpu-8",
			expected: "n4standard",
		},
		{
			input:    "n4-highmem-16",
			expected: "n4standard",
		},
	}

	for _, test := range cases {
		result := parseGCPInstanceTypeLabel(test.input)
		if result != test.expected {
			t.Errorf("Input: %s, Expected: %s, Actual: %s", test.input, test.expected, result)
		}
	}
}

func TestParseGCPProjectID(t *testing.T) {
	cases := []struct {
		input    string
		expected string
	}{
		{
			input:    "gce://guestbook-12345/...",
			expected: "guestbook-12345",
		},
		{
			input:    "gce:/guestbook-12345/...",
			expected: "",
		},
		{
			input:    "asdfa",
			expected: "",
		},
		{
			input:    "",
			expected: "",
		},
	}

	for _, test := range cases {
		result := ParseGCPProjectID(test.input)
		if result != test.expected {
			t.Errorf("Input: %s, Expected: %s, Actual: %s", test.input, test.expected, result)
		}
	}
}

func TestGetUsageType(t *testing.T) {
	cases := []struct {
		input    map[string]string
		expected string
	}{
		{
			input: map[string]string{
				GKEPreemptibleLabel: "true",
			},
			expected: "preemptible",
		},
		{
			input: map[string]string{
				GKESpotLabel: "true",
			},
			expected: "preemptible",
		},
		{
			input: map[string]string{
				models.KarpenterCapacityTypeLabel: models.KarpenterCapacitySpotTypeValue,
			},
			expected: "preemptible",
		},
		{
			input: map[string]string{
				"someotherlabel": "true",
			},
			expected: "ondemand",
		},
		{
			input:    map[string]string{},
			expected: "ondemand",
		},
	}

	for _, test := range cases {
		result := getUsageType(test.input)
		if result != test.expected {
			t.Errorf("Input: %v, Expected: %s, Actual: %s", test.input, test.expected, result)
		}
	}
}

func TestKeyFeatures(t *testing.T) {
	type testCase struct {
		key *gcpKey
		exp string
	}

	testCases := []testCase{
		{
			key: &gcpKey{
				Labels: map[string]string{
					"node.kubernetes.io/instance-type": "n2-standard-4",
					"topology.kubernetes.io/region":    "us-east1",
				},
			},
			exp: "us-east1,n2standard,ondemand",
		},
		{
			key: &gcpKey{
				Labels: map[string]string{
					"node.kubernetes.io/instance-type": "e2-standard-8",
					"topology.kubernetes.io/region":    "us-west1",
					"cloud.google.com/gke-preemptible": "true",
				},
			},
			exp: "us-west1,e2standard,preemptible",
		},
		{
			key: &gcpKey{
				Labels: map[string]string{
					"node.kubernetes.io/instance-type": "a2-highgpu-1g",
					"cloud.google.com/gke-gpu":         "true",
					"cloud.google.com/gke-accelerator": "nvidia-tesla-a100",
					"topology.kubernetes.io/region":    "us-central1",
				},
			},
			exp: "us-central1,a2highgpu,ondemand,gpu",
		},
		{
			key: &gcpKey{
				Labels: map[string]string{
					"node.kubernetes.io/instance-type": "t2d-standard-1",
					"topology.kubernetes.io/region":    "asia-southeast1",
				},
			},
			exp: "asia-southeast1,t2dstandard,ondemand",
		},
	}

	for _, tc := range testCases {
		t.Run(tc.exp, func(t *testing.T) {
			act := tc.key.Features()
			if act != tc.exp {
				t.Errorf("expected '%s'; got '%s'", tc.exp, act)
			}
		})
	}
}

// tests basic parsing of GCP pricing API responses
// Load a reader object on a portion of a GCP api response
// Confirm that the resting *GCP object contains the correctly parsed pricing info
func TestParsePage(t *testing.T) {

	testCases := map[string]struct {
		inputFile      string
		inputKeys      map[string]models.Key
		pvKeys         map[string]models.PVKey
		expectedPrices map[string]*GCPPricing
		expectedToken  string
		expectError    bool
	}{
		"Error Response": {
			inputFile:      "./test/error.json",
			inputKeys:      nil,
			pvKeys:         nil,
			expectedPrices: nil,
			expectError:    true,
		},
		"SKU file": {
			// NOTE: SKUs here are copied directly from GCP Billing API. Some of them
			// are in currency IDR, which relates directly to ticket GTM-52, for which
			// some of this work was done. So if the prices look huge... don't panic.
			// The only thing we're testing here is that, given these instance types
			// and regions and prices, those same prices get set appropriately into
			// the returned pricing map.
			inputFile: "./test/skus.json",
			inputKeys: map[string]models.Key{
				"us-central1,a2highgpu,ondemand,gpu": &gcpKey{
					Labels: map[string]string{
						"node.kubernetes.io/instance-type": "a2-highgpu-1g",
						"cloud.google.com/gke-gpu":         "true",
						"cloud.google.com/gke-accelerator": "nvidia-tesla-a100",
						"topology.kubernetes.io/region":    "us-central1",
					},
				},
				"us-central1,e2medium,ondemand": &gcpKey{
					Labels: map[string]string{
						"node.kubernetes.io/instance-type": "e2-medium",
						"topology.kubernetes.io/region":    "us-central1",
					},
				},
				"us-central1,e2standard,ondemand": &gcpKey{
					Labels: map[string]string{
						"node.kubernetes.io/instance-type": "e2-standard",
						"topology.kubernetes.io/region":    "us-central1",
					},
				},
				"asia-southeast1,t2dstandard,ondemand": &gcpKey{
					Labels: map[string]string{
						"node.kubernetes.io/instance-type": "t2d-standard-1",
						"topology.kubernetes.io/region":    "asia-southeast1",
					},
				},
			},
			pvKeys: map[string]models.PVKey{},
			expectedPrices: map[string]*GCPPricing{
				"us-central1,a2highgpu,ondemand,gpu": {
					Name:        "services/6F81-5844-456A/skus/039F-D0DA-4055",
					SKUID:       "039F-D0DA-4055",
					Description: "Nvidia Tesla A100 GPU running in Americas",
					Category: &GCPResourceInfo{
						ServiceDisplayName: "Compute Engine",
						ResourceFamily:     "Compute",
						ResourceGroup:      "GPU",
						UsageType:          "OnDemand",
					},
					ServiceRegions: []string{"us-central1", "us-east1", "us-west1"},
					PricingInfo: []*PricingInfo{
						{
							Summary: "",
							PricingExpression: &PricingExpression{
								UsageUnit:                "h",
								UsageUnitDescription:     "hour",
								BaseUnit:                 "s",
								BaseUnitConversionFactor: 0,
								DisplayQuantity:          1,
								TieredRates: []*TieredRates{
									{
										StartUsageAmount: 0,
										UnitPrice: &UnitPriceInfo{
											CurrencyCode: "USD",
											Units:        "2",
											Nanos:        933908000,
										},
									},
								},
							},
							CurrencyConversionRate: 1,
							EffectiveTime:          "2023-03-24T10:52:50.681Z",
						},
					},
					ServiceProviderName: "Google",
					Node: &models.Node{
						VCPUCost:         "0.031611",
						RAMCost:          "0.004237",
						UsesBaseCPUPrice: false,
						GPU:              "1",
						GPUName:          "nvidia-tesla-a100",
						GPUCost:          "2.933908",
					},
				},
				"us-central1,a2highgpu,ondemand": {
					Node: &models.Node{
						VCPUCost:         "0.031611",
						RAMCost:          "0.004237",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"us-central1,e2medium,ondemand": {
					Node: &models.Node{
						VCPU:             "1.000000",
						VCPUCost:         "327.173848364",
						RAMCost:          "43.85294978",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"us-central1,e2medium,ondemand,gpu": {
					Node: &models.Node{
						VCPU:             "1.000000",
						VCPUCost:         "327.173848364",
						RAMCost:          "43.85294978",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"us-central1,e2standard,ondemand": {
					Node: &models.Node{
						VCPUCost:         "327.173848364",
						RAMCost:          "43.85294978",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"us-central1,e2standard,ondemand,gpu": {
					Node: &models.Node{
						VCPUCost:         "327.173848364",
						RAMCost:          "43.85294978",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"asia-southeast1,t2dstandard,ondemand": {
					Node: &models.Node{
						VCPUCost:         "508.934997455",
						RAMCost:          "68.204999658",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
				"asia-southeast1,t2dstandard,ondemand,gpu": {
					Node: &models.Node{
						VCPUCost:         "508.934997455",
						RAMCost:          "68.204999658",
						UsesBaseCPUPrice: false,
						UsageType:        "ondemand",
					},
				},
			},
			expectedToken: "APKCS1HVa0YpwgyTFbqbJ1eGwzKZmsPwLqzMZPTSNia5ck1Hc54Tx_Kz3oBxwSnRIdGVxXoSPdf-XlDpyNBf4QuxKcIEgtrQ1LDLWAgZowI0ns7HjrGta2s=",
			expectError:   false,
		},
	}

	for name, tc := range testCases {
		t.Run(name, func(t *testing.T) {
			fileBytes, err := os.ReadFile(tc.inputFile)
			if err != nil {
				t.Fatalf("failed to open file '%s': %s", tc.inputFile, err)
			}
			reader := bytes.NewReader(fileBytes)

			testGcp := &GCP{}
			actualPrices, token, err := testGcp.parsePage(reader, tc.inputKeys, tc.pvKeys)
			if err != nil {
				log.Errorf("got error parsing page: %v", err)
			}
			if tc.expectError != (err != nil) {
				t.Fatalf("Error from result was not as expected. Expected: %v, Actual: %v", tc.expectError, err != nil)
			}

			if token != tc.expectedToken {
				t.Fatalf("error parsing GCP next page token, parsed %s but expected %s", token, tc.expectedToken)
			}

			if !reflect.DeepEqual(actualPrices, tc.expectedPrices) {
				act, _ := json.Marshal(actualPrices)
				exp, _ := json.Marshal(tc.expectedPrices)
				t.Errorf("error parsing GCP prices: parsed \n%s\n expected \n%s\n", string(act), string(exp))
			}
		})
	}

}
func TestGCP_GetConfig(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	config, err := gcp.GetConfig()
	assert.NoError(t, err)
	assert.NotNil(t, config)
	assert.Equal(t, "30%", config.Discount)
	assert.Equal(t, "0%", config.NegotiatedDiscount)
	assert.Equal(t, "USD", config.CurrencyCode)
}

func TestGCP_GetManagementPlatform(t *testing.T) {
	tests := []struct {
		name           string
		nodes          []*clustercache.Node
		expectedResult string
		expectedError  bool
	}{
		{
			name: "GKE cluster",
			nodes: []*clustercache.Node{
				{
					Status: v1.NodeStatus{
						NodeInfo: v1.NodeSystemInfo{
							KubeletVersion: "v1.20.0-gke.1000",
						},
					},
				},
			},
			expectedResult: "gke",
			expectedError:  false,
		},
		{
			name: "Non-GKE cluster",
			nodes: []*clustercache.Node{
				{
					Status: v1.NodeStatus{
						NodeInfo: v1.NodeSystemInfo{
							KubeletVersion: "v1.20.0",
						},
					},
				},
			},
			expectedResult: "",
			expectedError:  false,
		},
		{
			name:           "No nodes",
			nodes:          []*clustercache.Node{},
			expectedResult: "",
			expectedError:  false,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{
				Clientset: &clustercache.MockClusterCache{Nodes: tt.nodes},
			}

			result, err := gcp.GetManagementPlatform()
			if tt.expectedError {
				assert.Error(t, err)
			} else {
				assert.NoError(t, err)
			}
			assert.Equal(t, tt.expectedResult, result)
		})
	}
}

func TestGCP_UpdateConfig(t *testing.T) {
	tests := []struct {
		name        string
		updateType  string
		input       string
		expectError bool
	}{
		{
			name:        "BigQuery update type",
			updateType:  BigqueryUpdateType,
			input:       `{"projectID":"test","billingDataDataset":"test.dataset","key":{"type":"service_account"}}`,
			expectError: true, // Will fail due to missing key file
		},
		{
			name:        "Generic update type",
			updateType:  "generic",
			input:       `{"discount":"25%"}`,
			expectError: false,
		},
		{
			name:        "Invalid JSON",
			updateType:  "generic",
			input:       `invalid json`,
			expectError: true,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{
				Config: &mockConfig{},
			}

			reader := strings.NewReader(tt.input)
			config, err := gcp.UpdateConfig(reader, tt.updateType)

			if tt.expectError {
				assert.Error(t, err)
			} else {
				assert.NoError(t, err)
				assert.NotNil(t, config)
			}
		})
	}
}

func TestGCP_ClusterInfo(t *testing.T) {
	gcp := &GCP{
		Config:             &mockConfig{},
		ClusterRegion:      "us-central1",
		ClusterAccountID:   "test-account",
		ClusterProjectID:   "test-project",
		clusterProvisioner: "gke",
	}

	// The function will panic due to nil metadata client, so we need to handle this
	defer func() {
		if r := recover(); r != nil {
			// Expected panic due to nil metadata client
			assert.Contains(t, fmt.Sprintf("%v", r), "invalid memory address")
		}
	}()

	info, err := gcp.ClusterInfo()
	// This line should not be reached due to panic
	assert.Error(t, err)
	assert.Nil(t, info)
}

func TestGCP_ClusterManagementPricing(t *testing.T) {
	gcp := &GCP{
		clusterProvisioner:     "gke",
		clusterManagementPrice: 0.10,
	}

	provisioner, price, err := gcp.ClusterManagementPricing()
	assert.NoError(t, err)
	assert.Equal(t, "gke", provisioner)
	assert.Equal(t, 0.10, price)
}

func TestGCP_GetAddresses(t *testing.T) {
	gcp := &GCP{
		// Don't set MetadataClient - let it be nil and handle the error
	}

	// This will fail due to nil metadata client, but we can test the function structure
	// Use defer to catch the panic and convert it to an error
	defer func() {
		if r := recover(); r != nil {
			// Expected panic due to nil metadata client
			assert.Contains(t, fmt.Sprintf("%v", r), "invalid memory address")
		}
	}()

	_, err := gcp.GetAddresses()
	// This line should not be reached due to panic, but if it is, we expect an error
	if err == nil {
		t.Error("Expected error due to nil metadata client")
	}
}

func TestGCP_GetDisks(t *testing.T) {
	gcp := &GCP{
		// Don't set MetadataClient - let it be nil and handle the error
	}

	// This will fail due to nil metadata client, but we can test the function structure
	// Use defer to catch the panic and convert it to an error
	defer func() {
		if r := recover(); r != nil {
			// Expected panic due to nil metadata client
			assert.Contains(t, fmt.Sprintf("%v", r), "invalid memory address")
		}
	}()

	_, err := gcp.GetDisks()
	// This line should not be reached due to panic, but if it is, we expect an error
	if err == nil {
		t.Error("Expected error due to nil metadata client")
	}
}

func TestGCP_isAddressOrphaned(t *testing.T) {
	tests := []struct {
		name     string
		address  *compute.Address
		expected bool
	}{
		{
			name: "Orphaned address",
			address: &compute.Address{
				Users: []string{},
			},
			expected: true,
		},
		{
			name: "Used address",
			address: &compute.Address{
				Users: []string{"user1"},
			},
			expected: false,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{}
			result := gcp.isAddressOrphaned(tt.address)
			assert.Equal(t, tt.expected, result)
		})
	}
}

func TestGCP_isDiskOrphaned(t *testing.T) {
	tests := []struct {
		name     string
		disk     *compute.Disk
		expected bool
	}{
		{
			name: "Used disk",
			disk: &compute.Disk{
				Users: []string{"user1"},
			},
			expected: false,
		},
		{
			name: "Recently detached disk",
			disk: &compute.Disk{
				Users:               []string{},
				LastDetachTimestamp: "2023-01-01T12:00:00Z",
			},
			expected: true, // The function considers this orphaned because it's more than 1 hour old
		},
		{
			name: "Orphaned disk",
			disk: &compute.Disk{
				Users:               []string{},
				LastDetachTimestamp: "2022-01-01T12:00:00Z",
			},
			expected: true,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{}
			result, err := gcp.isDiskOrphaned(tt.disk)
			assert.NoError(t, err)
			assert.Equal(t, tt.expected, result)
		})
	}
}

func TestGCP_findCostForDisk(t *testing.T) {
	tests := []struct {
		name     string
		disk     *compute.Disk
		expected float64
	}{
		{
			name: "SSD disk",
			disk: &compute.Disk{
				Type:   "pd-ssd",
				SizeGb: 100,
			},
			expected: GCPMonthlySSDDiskCost * 100,
		},
		{
			name: "Standard disk",
			disk: &compute.Disk{
				Type:   "pd-standard",
				SizeGb: 50,
			},
			expected: GCPMonthlyBasicDiskCost * 50,
		},
		{
			name: "GP2 disk",
			disk: &compute.Disk{
				Type:   "pd-gp2",
				SizeGb: 200,
			},
			expected: GCPMonthlyGP2DiskCost * 200,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{}
			cost, err := gcp.findCostForDisk(tt.disk)
			assert.NoError(t, err)
			assert.NotNil(t, cost)
			assert.Equal(t, tt.expected, *cost)
		})
	}
}

func TestGCP_getBillingAPIURL(t *testing.T) {
	tests := []struct {
		name           string
		apiKey         string
		currency       string
		expectedParams map[string]string
		absentParams   []string
	}{
		{
			name:           "with API key and currency",
			apiKey:         "test-key",
			currency:       "USD",
			expectedParams: map[string]string{"key": "test-key", "currencyCode": "USD"},
		},
		{
			name:           "empty API key omits key param",
			apiKey:         "",
			currency:       "USD",
			expectedParams: map[string]string{"currencyCode": "USD"},
			absentParams:   []string{"key"},
		},
		{
			name:           "non-USD currency",
			apiKey:         "my-key",
			currency:       "EUR",
			expectedParams: map[string]string{"key": "my-key", "currencyCode": "EUR"},
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcp := &GCP{}
			query := gcp.buildBillingAPIURL(tt.apiKey, tt.currency).Query()

			for param, expected := range tt.expectedParams {
				assert.Equal(t, expected, query.Get(param), "query param %q", param)
			}
			for _, param := range tt.absentParams {
				assert.False(t, query.Has(param), "query param %q should be absent", param)
			}
		})
	}
}

func TestGCP_getBillingAPIClientAndURL(t *testing.T) {
	gcp := &GCP{}

	client, rawURL, err := gcp.getBillingAPIClientAndURL("test-key", "USD")

	assert.NoError(t, err)
	assert.NotNil(t, client)
	assert.Equal(t, httputil.PricingTimeout, client.Timeout)

	parsedURL, err := url.Parse(rawURL)
	assert.NoError(t, err)
	query := parsedURL.Query()
	assert.Equal(t, "test-key", query.Get("key"))
	assert.Equal(t, "USD", query.Get("currencyCode"))
}

func TestGCP_GpuPricing(t *testing.T) {
	gcp := &GCP{
		Pricing: map[string]*GCPPricing{
			"us-central1,nvidia-tesla-t4,ondemand": {
				Node: &models.Node{
					GPU:     "1",
					GPUName: "nvidia-tesla-t4",
					GPUCost: "0.35",
				},
			},
		},
	}

	labels := map[string]string{
		GKE_GPU_TAG: "nvidia-tesla-t4",
	}

	result, err := gcp.GpuPricing(labels)
	assert.NoError(t, err)
	assert.Equal(t, "", result) // The method is a stub that returns empty string
}

func TestGCP_PVPricing(t *testing.T) {
	gcp := &GCP{}

	pvKey := &pvKey{
		ProviderID:    "test-pv",
		StorageClass:  "pd-ssd",
		DefaultRegion: "us-central1",
	}

	result, err := gcp.PVPricing(pvKey)
	assert.NoError(t, err)
	assert.NotNil(t, result)
}

func TestGCP_NetworkPricing(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	result, err := gcp.NetworkPricing()
	assert.NoError(t, err)
	assert.NotNil(t, result)
}

func TestGCP_LoadBalancerPricing(t *testing.T) {
	gcp := &GCP{}

	result, err := gcp.LoadBalancerPricing()
	assert.NoError(t, err)
	assert.NotNil(t, result)
}

func TestGCP_GetPVKey(t *testing.T) {
	gcp := &GCP{}

	pv := &clustercache.PersistentVolume{
		Spec: v1.PersistentVolumeSpec{
			PersistentVolumeSource: v1.PersistentVolumeSource{
				GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{
					PDName: "test-disk",
				},
			},
			StorageClassName: "pd-ssd",
		},
		Labels: map[string]string{
			"region": "us-central1",
		},
	}

	parameters := map[string]string{
		"type": "pd-ssd",
	}

	result := gcp.GetPVKey(pv, parameters, "us-central1")
	assert.NotNil(t, result)

	pvKey, ok := result.(*pvKey)
	assert.True(t, ok)
	assert.Equal(t, "test-disk", pvKey.ProviderID)
	assert.Equal(t, "pd-ssd", pvKey.StorageClass)
}

func TestGCP_GetKey(t *testing.T) {
	gcp := &GCP{}

	labels := map[string]string{
		"node.kubernetes.io/instance-type": "n1-standard-2",
		"topology.kubernetes.io/region":    "us-central1",
	}

	result := gcp.GetKey(labels, nil)
	assert.NotNil(t, result)

	gcpKey, ok := result.(*gcpKey)
	assert.True(t, ok)
	assert.Equal(t, labels, gcpKey.Labels)
}

func TestGCP_AllNodePricing(t *testing.T) {
	gcp := &GCP{
		Pricing: map[string]*GCPPricing{
			"us-central1,n1standard,ondemand": {
				Node: &models.Node{},
			},
		},
	}

	result, err := gcp.AllNodePricing()
	assert.NoError(t, err)
	assert.NotNil(t, result)
}

func TestGCP_getPricing(t *testing.T) {
	gcp := &GCP{
		Pricing: map[string]*GCPPricing{
			"us-central1,n1standard,ondemand": {
				Node: &models.Node{},
			},
		},
	}

	key := &gcpKey{
		Labels: map[string]string{
			"node.kubernetes.io/instance-type": "n1-standard-2",
			"topology.kubernetes.io/region":    "us-central1",
		},
	}

	result, found := gcp.getPricing(key)
	assert.True(t, found)
	assert.NotNil(t, result)
}

func TestGCP_isValidPricingKey(t *testing.T) {
	gcp := &GCP{
		ValidPricingKeys: map[string]bool{
			"us-central1,n1standard,ondemand": true,
		},
	}

	key := &gcpKey{
		Labels: map[string]string{
			"node.kubernetes.io/instance-type": "n1-standard-2",
			"topology.kubernetes.io/region":    "us-central1",
		},
	}

	result := gcp.isValidPricingKey(key)
	assert.True(t, result)
}

func TestGCP_ServiceAccountStatus(t *testing.T) {
	gcp := &GCP{}

	result := gcp.ServiceAccountStatus()
	assert.NotNil(t, result)
	assert.NotNil(t, result.Checks)
}

func TestGCP_PricingSourceStatus(t *testing.T) {
	gcp := &GCP{}

	result := gcp.PricingSourceStatus()
	assert.NotNil(t, result)
}

func TestGCP_CombinedDiscountForNode(t *testing.T) {
	gcp := &GCP{}

	tests := []struct {
		name               string
		instanceType       string
		isPreemptible      bool
		defaultDiscount    float64
		negotiatedDiscount float64
		expectedDiscount   float64
	}{
		{
			name:               "Standard instance with discounts",
			instanceType:       "n1-standard-2",
			isPreemptible:      false,
			defaultDiscount:    0.30,
			negotiatedDiscount: 0.20,
			expectedDiscount:   0.44, // 1 - (1-0.30) * (1-0.20)
		},
		{
			name:               "Preemptible instance",
			instanceType:       "n1-standard-2",
			isPreemptible:      true,
			defaultDiscount:    0.30,
			negotiatedDiscount: 0.20,
			expectedDiscount:   0.20, // Only negotiated discount applies
		},
		{
			name:               "E2 instance",
			instanceType:       "e2-standard-2",
			isPreemptible:      false,
			defaultDiscount:    0.30,
			negotiatedDiscount: 0.20,
			expectedDiscount:   0.20, // E2 has no sustained use discount
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			result := gcp.CombinedDiscountForNode(tt.instanceType, tt.isPreemptible, tt.defaultDiscount, tt.negotiatedDiscount)
			assert.InDelta(t, tt.expectedDiscount, result, 0.01)
		})
	}
}

func TestGCP_Regions(t *testing.T) {
	gcp := &GCP{}

	result := gcp.Regions()
	assert.NotNil(t, result)
	assert.Greater(t, len(result), 0)

	// Check that common regions are included
	regions := make(map[string]bool)
	for _, region := range result {
		regions[region] = true
	}

	assert.True(t, regions["us-central1"])
	assert.True(t, regions["us-east1"])
	assert.True(t, regions["europe-west1"])
}

func TestSustainedUseDiscount(t *testing.T) {
	tests := []struct {
		name            string
		class           string
		defaultDiscount float64
		isPreemptible   bool
		expected        float64
	}{
		{
			name:            "Preemptible instance",
			class:           "n1",
			defaultDiscount: 0.30,
			isPreemptible:   true,
			expected:        0.0,
		},
		{
			name:            "E2 instance",
			class:           "e2",
			defaultDiscount: 0.30,
			isPreemptible:   false,
			expected:        0.0,
		},
		{
			name:            "N2 instance",
			class:           "n2",
			defaultDiscount: 0.30,
			isPreemptible:   false,
			expected:        0.2,
		},
		{
			name:            "N1 instance",
			class:           "n1",
			defaultDiscount: 0.30,
			isPreemptible:   false,
			expected:        0.30,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			result := sustainedUseDiscount(tt.class, tt.defaultDiscount, tt.isPreemptible)
			assert.Equal(t, tt.expected, result)
		})
	}
}

func TestGCP_PricingSourceSummary(t *testing.T) {
	gcp := &GCP{
		Pricing: map[string]*GCPPricing{
			"us-central1,n1standard,ondemand": {
				Node: &models.Node{},
			},
		},
	}

	result := gcp.PricingSourceSummary()
	assert.NotNil(t, result)

	pricing, ok := result.(map[string]*GCPPricing)
	assert.True(t, ok)
	assert.Equal(t, gcp.Pricing, pricing)
}

func TestGCP_GetOrphanedResources(t *testing.T) {
	gcp := &GCP{
		// Don't set MetadataClient - let it be nil and handle the error
	}

	// This will fail due to nil metadata client, but we can test the function structure
	defer func() {
		if r := recover(); r != nil {
			// Expected panic due to nil metadata client
			assert.Contains(t, fmt.Sprintf("%v", r), "invalid memory address")
		}
	}()

	_, err := gcp.GetOrphanedResources()
	// This line should not be reached due to panic, but if it is, we expect an error
	if err == nil {
		t.Error("Expected error due to nil metadata client")
	}
}

func TestGCP_parsePages(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	// Test with empty keys
	keys := map[string]models.Key{}
	pvKeys := map[string]models.PVKey{}

	// This will fail due to missing API key, but we can test the function structure
	_, err := gcp.parsePages(keys, pvKeys)
	assert.Error(t, err) // Expect error due to missing API key
}

// TestGCP_parsePagesWithClient_Pagination verifies that multi-page traversal
// sends exactly one pageToken param per request rather than accumulating
// tokens from earlier pages.
func TestGCP_parsePagesWithClient_Pagination(t *testing.T) {
	var pageTokens [][]string
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		tokens := r.URL.Query()["pageToken"]
		pageTokens = append(pageTokens, tokens)
		w.Header().Set("Content-Type", "application/json")
		if len(tokens) > 0 && tokens[0] == "tok2" {
			fmt.Fprint(w, `{"skus": [], "nextPageToken": ""}`)
		} else {
			fmt.Fprint(w, `{"skus": [], "nextPageToken": "tok2"}`)
		}
	}))
	defer srv.Close()

	gcp := &GCP{}
	_, err := gcp.parsePagesWithClient(srv.Client(), srv.URL+"?currencyCode=USD", map[string]models.Key{}, map[string]models.PVKey{})
	if err != nil {
		t.Fatalf("parsePagesWithClient: %v", err)
	}

	if len(pageTokens) != 2 {
		t.Fatalf("expected 2 page requests, got %d", len(pageTokens))
	}
	if len(pageTokens[0]) != 0 {
		t.Errorf("first request should have no pageToken, got %v", pageTokens[0])
	}
	if len(pageTokens[1]) != 1 || pageTokens[1][0] != "tok2" {
		t.Errorf("second request should have exactly one pageToken (tok2), got %v", pageTokens[1])
	}
}

func TestGCP_DownloadPricingData(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
		Clientset: &clustercache.MockClusterCache{
			Nodes:             []*clustercache.Node{},
			PersistentVolumes: []*clustercache.PersistentVolume{},
			StorageClasses:    []*clustercache.StorageClass{},
		},
	}

	// This will fail due to missing API key, but we can test the function structure
	err := gcp.DownloadPricingData()
	assert.Error(t, err) // Expect error due to missing API key
}

func TestGCP_String(t *testing.T) {
	ri := &GCPReservedInstance{
		ReservedRAM: 8192,
		ReservedCPU: 4,
		Region:      "us-central1",
		StartDate:   time.Date(2023, 1, 1, 0, 0, 0, 0, time.UTC),
		EndDate:     time.Date(2024, 1, 1, 0, 0, 0, 0, time.UTC),
	}

	result := ri.String()
	assert.Contains(t, result, "CPU: 4")
	assert.Contains(t, result, "RAM: 8192")
	assert.Contains(t, result, "Region: us-central1")
}

func TestGCP_newReservedCounter(t *testing.T) {
	ri := &GCPReservedInstance{
		ReservedRAM: 8192,
		ReservedCPU: 4,
	}

	counter := newReservedCounter(ri)
	assert.Equal(t, int64(8192), counter.RemainingRAM)
	assert.Equal(t, int64(4), counter.RemainingCPU)
	assert.Equal(t, ri, counter.Instance)
}

func TestGCP_ApplyReservedInstancePricing(t *testing.T) {
	gcp := &GCP{
		ReservedInstances: []*GCPReservedInstance{
			{
				ReservedRAM: 8192,
				ReservedCPU: 4,
				Region:      "us-central1",
				StartDate:   time.Now().Add(-24 * time.Hour),      // Started yesterday
				EndDate:     time.Now().Add(365 * 24 * time.Hour), // Ends in a year
				Plan: &GCPReservedInstancePlan{
					Name:    GCPReservedInstancePlanOneYear,
					CPUCost: 0.019915,
					RAMCost: 0.002669,
				},
			},
		},
		Clientset: &clustercache.MockClusterCache{
			Nodes: []*clustercache.Node{
				{
					Name: "test-node",
					Labels: map[string]string{
						"topology.kubernetes.io/region": "us-central1",
					},
				},
			},
		},
	}

	nodes := map[string]*models.Node{
		"test-node": {
			VCPU: "4",
			RAM:  "8192",
		},
	}

	// This should apply reserved instance pricing
	gcp.ApplyReservedInstancePricing(nodes)

	// Verify that the node has reserved instance data
	node := nodes["test-node"]
	assert.NotNil(t, node.Reserved)
}

func TestGCP_getReservedInstances(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	// This will fail due to missing API key, but we can test the function structure
	_, err := gcp.getReservedInstances()
	assert.Error(t, err) // Expect error due to missing API key
}

func TestGCP_pvKey_ID(t *testing.T) {
	pvKey := &pvKey{
		ProviderID: "test-pv-id",
	}

	result := pvKey.ID()
	assert.Equal(t, "test-pv-id", result)
}

func TestGCP_gcpKey_ID(t *testing.T) {
	gcpKey := &gcpKey{
		Labels: map[string]string{
			"node.kubernetes.io/instance-type": "n1-standard-2",
		},
	}

	result := gcpKey.ID()
	assert.Equal(t, "", result) // The actual implementation returns empty string
}

func TestGCP_gcpKey_GPUCount(t *testing.T) {
	tests := []struct {
		name     string
		labels   map[string]string
		expected int
	}{
		{
			name: "GPU count 1",
			labels: map[string]string{
				"cloud.google.com/gke-gpu-count": "1",
			},
			expected: 0, // The actual implementation returns 0
		},
		{
			name: "GPU count 4",
			labels: map[string]string{
				"cloud.google.com/gke-gpu-count": "4",
			},
			expected: 0, // The actual implementation returns 0
		},
		{
			name:     "No GPU count",
			labels:   map[string]string{},
			expected: 0,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gcpKey := &gcpKey{
				Labels: tt.labels,
			}

			result := gcpKey.GPUCount()
			assert.Equal(t, tt.expected, result)
		})
	}
}

func TestGCP_NodePricing(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{}, // Add mock config to prevent nil pointer dereference
		Pricing: map[string]*GCPPricing{
			"us-central1,n1standard,ondemand": {
				Node: &models.Node{
					VCPUCost: "0.031611",
					RAMCost:  "0.004237",
				},
			},
		},
		ValidPricingKeys: map[string]bool{
			"us-central1,n1standard,ondemand": true,
		},
	}

	key := &gcpKey{
		Labels: map[string]string{
			"node.kubernetes.io/instance-type": "n1-standard-2",
			"topology.kubernetes.io/region":    "us-central1",
		},
	}
	result, _, err := gcp.NodePricing(key)
	assert.NoError(t, err)
	assert.NotNil(t, result)
	assert.Equal(t, "0.031611", result.VCPUCost)
	assert.Equal(t, "0.004237", result.RAMCost)
}

func TestGCP_UpdateConfigFromConfigMap(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	configMap := map[string]string{
		"discount": "25%",
	}

	// Test the function structure - should succeed with mock config
	result, err := gcp.UpdateConfigFromConfigMap(configMap)
	assert.NoError(t, err)
	assert.NotNil(t, result)
}

func TestGCP_loadGCPAuthSecret(t *testing.T) {
	gcp := &GCP{
		Config: &mockConfig{},
	}

	// This will fail due to missing secret, but we can test the function structure
	gcp.loadGCPAuthSecret()

}

// Mock implementations for testing
type mockConfig struct{}

func (m *mockConfig) GetCustomPricingData() (*models.CustomPricing, error) {
	return &models.CustomPricing{
		Discount:              "30%",
		NegotiatedDiscount:    "0%",
		CurrencyCode:          "USD",
		ZoneNetworkEgress:     "0.12",
		RegionNetworkEgress:   "0.08",
		InternetNetworkEgress: "0.15",
		NatGatewayEgress:      "0.45",
		NatGatewayIngress:     "0.45",
	}, nil
}

func (m *mockConfig) UpdateFromMap(a map[string]string) (*models.CustomPricing, error) {
	return &models.CustomPricing{}, nil
}

func (m *mockConfig) Update(updateFn func(*models.CustomPricing) error) (*models.CustomPricing, error) {
	cp := &models.CustomPricing{}
	err := updateFn(cp)
	return cp, err
}

func (m *mockConfig) ConfigFileManager() *config.ConfigFileManager {
	return nil
}