//go:build linux && unit
// +build linux,unit

// Copyright 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 stats

import (
	"fmt"
	"net"
	"net/http"
	"net/http/httptest"
	"sort"
	"testing"

	"github.com/aws/amazon-ecs-agent/agent/api/serviceconnect"
	"github.com/aws/amazon-ecs-agent/ecs-agent/api/appnet"

	apicontainer "github.com/aws/amazon-ecs-agent/agent/api/container"
	apitask "github.com/aws/amazon-ecs-agent/agent/api/task"
	apitaskstatus "github.com/aws/amazon-ecs-agent/agent/api/task/status"
	apieni "github.com/aws/amazon-ecs-agent/ecs-agent/api/eni"
	"github.com/aws/amazon-ecs-agent/ecs-agent/tcs/model/ecstcs"
	"github.com/aws/aws-sdk-go/aws"
	"github.com/gorilla/mux"
	"github.com/stretchr/testify/assert"
)

func TestRetrieveServiceConnectMetrics(t *testing.T) {
	t1 := &apitask.Task{
		Arn:               "t1",
		Family:            "f1",
		ENIs:              []*apieni.ENI{{ID: "ec2Id"}},
		KnownStatusUnsafe: apitaskstatus.TaskRunning,
		Containers: []*apicontainer.Container{
			{Name: "test"},
		},
		LocalIPAddressUnsafe: "127.0.0.1",
		ServiceConnectConfig: &serviceconnect.Config{
			RuntimeConfig: serviceconnect.RuntimeConfig{
				AdminSocketPath: "/tmp/appnet_admin.sock",
				StatsRequest:    "http://myhost/get/them/stats",
			},
		},
	}

	var tests = []struct {
		stats         string
		expectedStats []*ecstcs.GeneralMetricsWrapper
	}{
		{
			stats: `# TYPE MetricFamily1 counter
				MetricFamily1{DimensionA="value1", DimensionB="value2", Direction="ingress"} 1
				# TYPE MetricFamily2 counter
				MetricFamily2{DimensionB="value2", DimensionA="value1", Direction="ingress"} 1
				`,
			expectedStats: []*ecstcs.GeneralMetricsWrapper{
				{
					MetricType: aws.String("1"),
					Dimensions: []*ecstcs.Dimension{
						{
							Key:   aws.String("DimensionA"),
							Value: aws.String("value1"),
						}, {
							Key:   aws.String("DimensionB"),
							Value: aws.String("value2"),
						}},
					GeneralMetrics: []*ecstcs.GeneralMetric{
						{
							MetricCounts: []*int64{aws.Int64(1)},
							MetricName:   aws.String("MetricFamily1"),
							MetricValues: []*float64{aws.Float64(1)},
						},
						{
							MetricCounts: []*int64{aws.Int64(1)},
							MetricName:   aws.String("MetricFamily2"),
							MetricValues: []*float64{aws.Float64(1)},
						},
					},
				},
			},
		},
		{
			stats: `# TYPE MetricFamily3 histogram
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="0.5"} 1
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="1"} 1
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="5"} 3
				`,
			expectedStats: []*ecstcs.GeneralMetricsWrapper{
				{
					MetricType: aws.String("2"),
					Dimensions: []*ecstcs.Dimension{
						{
							Key:   aws.String("DimensionX"),
							Value: aws.String("value1"),
						}, {
							Key:   aws.String("DimensionY"),
							Value: aws.String("value2"),
						}},
					GeneralMetrics: []*ecstcs.GeneralMetric{
						{
							MetricCounts: []*int64{aws.Int64(1), aws.Int64(2)},
							MetricName:   aws.String("MetricFamily3"),
							MetricValues: []*float64{aws.Float64(0.5), aws.Float64(5)},
						},
					},
				},
			},
		},
		{
			stats: `# TYPE MetricFamily3 histogram
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="0.5"} 0
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="1"} 0
				MetricFamily3{DimensionX="value1", DimensionY="value2", Direction="egress", le="5"} 0
				`,
			expectedStats: []*ecstcs.GeneralMetricsWrapper{},
		},
	}

	for _, test := range tests {
		func() {
			// Set up a mock http sever on the statsUrlpath
			mockUDSPath := "/tmp/appnet_admin.sock"
			r := mux.NewRouter()
			r.HandleFunc("/get/them/stats", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
				fmt.Fprintf(w, "%v", test.stats)
			}))

			ts := httptest.NewUnstartedServer(r)
			defer ts.Close()

			l, err := net.Listen("unix", mockUDSPath)
			assert.NoError(t, err)

			ts.Listener.Close()
			ts.Listener = l
			ts.Start()

			serviceConnectStats := &ServiceConnectStats{
				appnetClient: appnet.Client(),
			}
			serviceConnectStats.retrieveServiceConnectStats(t1)

			sortMetrics(serviceConnectStats.GetStats())
			sortMetrics(test.expectedStats)
			assert.Equal(t, test.expectedStats, serviceConnectStats.GetStats())
		}()
	}
}

func sortMetrics(metricList []*ecstcs.GeneralMetricsWrapper) {
	for _, metric := range metricList {
		sort.Slice(metric.GeneralMetrics, func(i, j int) bool {
			return *metric.GeneralMetrics[i].MetricName < *metric.GeneralMetrics[j].MetricName
		})
	}
}