// Licensed to the Apache Software Foundation (ASF) under one or more
// contributor license agreements.  See the NOTICE file distributed with
// this work for additional information regarding copyright ownership.
// The ASF licenses this file to You 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 environment

import (
	"fmt"
	"reflect"
	"testing"
	"time"
)

func TestNetworkEnvs_Address(t *testing.T) {
	type fields struct {
		ip   string
		port int
	}
	tests := []struct {
		name   string
		fields fields
		want   string
	}{
		{
			name:   "ip and port concatenated through ':'",
			fields: fields{ip: defaultIp, port: defaultPort},
			want:   fmt.Sprintf("%s:%d", defaultIp, defaultPort),
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			serverEnvs := NetworkEnvs{
				ip:   tt.fields.ip,
				port: tt.fields.port,
			}
			if got := serverEnvs.Address(); got != tt.want {
				t.Errorf("Address() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestCacheEnvs_CacheType(t *testing.T) {
	type fields struct {
		cacheType         string
		address           string
		keyExpirationTime time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   string
	}{
		{
			name: "all success",
			fields: fields{
				cacheType:         "MOCK_CACHE_TYPE",
				address:           "MOCK_ADDRESS",
				keyExpirationTime: 0,
			},
			want: "MOCK_CACHE_TYPE",
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ce := &CacheEnvs{
				cacheType:         tt.fields.cacheType,
				address:           tt.fields.address,
				keyExpirationTime: tt.fields.keyExpirationTime,
			}
			if got := ce.CacheType(); got != tt.want {
				t.Errorf("CacheType() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestCacheEnvs_Address(t *testing.T) {
	type fields struct {
		cacheType         string
		address           string
		keyExpirationTime time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   string
	}{
		{
			name: "all success",
			fields: fields{
				cacheType:         "MOCK_CACHE_TYPE",
				address:           "MOCK_ADDRESS",
				keyExpirationTime: 0,
			},
			want: "MOCK_ADDRESS",
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ce := &CacheEnvs{
				cacheType:         tt.fields.cacheType,
				address:           tt.fields.address,
				keyExpirationTime: tt.fields.keyExpirationTime,
			}
			if got := ce.Address(); got != tt.want {
				t.Errorf("Address() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestCacheEnvs_KeyExpirationTime(t *testing.T) {
	type fields struct {
		cacheType         string
		address           string
		keyExpirationTime time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   time.Duration
	}{
		{
			name: "all success",
			fields: fields{
				cacheType:         "MOCK_CACHE_TYPE",
				address:           "MOCK_ADDRESS",
				keyExpirationTime: 0,
			},
			want: 0,
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ce := &CacheEnvs{
				cacheType:         tt.fields.cacheType,
				address:           tt.fields.address,
				keyExpirationTime: tt.fields.keyExpirationTime,
			}
			if got := ce.KeyExpirationTime(); got != tt.want {
				t.Errorf("KeyExpirationTime() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestApplicationEnvs_WorkingDir(t *testing.T) {
	type fields struct {
		workingDir             string
		cacheEnvs              *CacheEnvs
		pipelineExecuteTimeout time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   string
	}{
		{
			name: "all success",
			fields: fields{
				workingDir:             "MOCK_WORKING_DIR",
				cacheEnvs:              &CacheEnvs{},
				pipelineExecuteTimeout: 0,
			},
			want: "MOCK_WORKING_DIR",
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ae := &ApplicationEnvs{
				workingDir:             tt.fields.workingDir,
				cacheEnvs:              tt.fields.cacheEnvs,
				pipelineExecuteTimeout: tt.fields.pipelineExecuteTimeout,
			}
			if got := ae.WorkingDir(); got != tt.want {
				t.Errorf("WorkingDir() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestApplicationEnvs_CacheEnvs(t *testing.T) {
	type fields struct {
		workingDir             string
		cacheEnvs              *CacheEnvs
		pipelineExecuteTimeout time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   *CacheEnvs
	}{
		{
			name: "all success",
			fields: fields{
				workingDir:             "MOCK_WORKING_DIR",
				cacheEnvs:              &CacheEnvs{},
				pipelineExecuteTimeout: 0,
			},
			want: &CacheEnvs{},
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ae := &ApplicationEnvs{
				workingDir:             tt.fields.workingDir,
				cacheEnvs:              tt.fields.cacheEnvs,
				pipelineExecuteTimeout: tt.fields.pipelineExecuteTimeout,
			}
			if got := ae.CacheEnvs(); !reflect.DeepEqual(got, tt.want) {
				t.Errorf("CacheEnvs() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestApplicationEnvs_PipelineExecuteTimeout(t *testing.T) {
	type fields struct {
		workingDir             string
		cacheEnvs              *CacheEnvs
		pipelineExecuteTimeout time.Duration
	}
	tests := []struct {
		name   string
		fields fields
		want   time.Duration
	}{
		{
			name: "all success",
			fields: fields{
				workingDir:             "MOCK_WORKING_DIR",
				cacheEnvs:              &CacheEnvs{},
				pipelineExecuteTimeout: 0,
			},
			want: 0,
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			ae := &ApplicationEnvs{
				workingDir:             tt.fields.workingDir,
				cacheEnvs:              tt.fields.cacheEnvs,
				pipelineExecuteTimeout: tt.fields.pipelineExecuteTimeout,
			}
			if got := ae.PipelineExecuteTimeout(); got != tt.want {
				t.Errorf("PipelineExecuteTimeout() = %v, want %v", got, tt.want)
			}
		})
	}
}
