temporal_test.go

/*
 * SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 * SPDX-License-Identifier: Apache-2.0
 *
 * Licensed 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 config

import (
	"crypto/tls"
	"fmt"
	"os"
	"testing"

	"github.com/stretchr/testify/assert"

	cconfig "github.com/NVIDIA/ncx-infra-controller-rest/common/pkg/config"
)

func TestNewTemporalConfig(t *testing.T) {
	type args struct {
		host          string
		port          int
		serverName    string
		namespace     string
		queue         string
		encryptionKey string
	}

	keyPath, certPath := SetupTestCerts(t)
	defer os.Remove(keyPath)
	defer os.Remove(certPath)

	tcfg := cconfig.TemporalConfig{
		Host:          "localhost",
		Port:          7233,
		ServerName:    "temporal.local",
		Namespace:     "cloud",
		Queue:         "cloud",
		EncryptionKey: "test",
		ClientTLSCfg: &tls.Config{
			ServerName:         fmt.Sprintf("%s.%s", "cloud", "temporal.local"),
			MinVersion:         tls.VersionTLS12,
			InsecureSkipVerify: false,
		},
	}

	tests := []struct {
		name string
		args args
		want *cconfig.TemporalConfig
	}{
		{
			name: "initialize Temporal config",
			args: args{
				host:          tcfg.Host,
				port:          tcfg.Port,
				serverName:    tcfg.ServerName,
				namespace:     tcfg.Namespace,
				queue:         tcfg.Queue,
				encryptionKey: tcfg.EncryptionKey,
			},
			want: &tcfg,
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			got, err := cconfig.NewTemporalConfig(tt.args.host, tt.args.port, tt.args.serverName, tt.args.namespace, tt.args.queue, tt.args.encryptionKey, true, certPath, keyPath, certPath)
			assert.NoError(t, err)
			defer got.Close()

			if sn := got.ServerName; sn != tt.want.ServerName {
				t.Errorf("got.ServerName = %v, want %v", sn, tt.want.ServerName)
			}
			if got := got.GetHostPort(); got != tt.want.GetHostPort() {
				t.Errorf("GetHostPort() = %v, want %v", got, tt.want.GetHostPort())
			}
		})
	}
}