fix: add ut for backend runtime.

pkg/controller_helper/backendruntime/backendruntime_test.go

@@ -20,6 +20,13 @@ import (
 	"testing"
 
 	"github.com/google/go-cmp/cmp"
+	coreapi "github.com/inftyai/llmaz/api/core/v1alpha1"
+	"github.com/inftyai/llmaz/test/util/wrapper"
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	inferenceapi "github.com/inftyai/llmaz/api/inference/v1alpha1"
 )
 
 func TestRenderFlags(t *testing.T) {
@@ -89,3 +96,154 @@ func TestRenderFlags(t *testing.T) {
 		})
 	}
 }
+
+func TestBackendRuntimeParser_BasicFields(t *testing.T) {
+	type want struct {
+		cmd       []string
+		args      []string
+		envs      []corev1.EnvVar
+		lifecycle *corev1.Lifecycle
+		image     string
+		version   string
+		resources *inferenceapi.ResourceRequirements
+		shm       *resource.Quantity
+	}
+
+	testCases := []struct {
+		name   string
+		parser *BackendRuntimeParser
+		want   want
+	}{
+		{
+			name: "normal case has recommendConfig",
+			parser: func() *BackendRuntimeParser {
+				cmd := []string{"python", "serve.py"}
+				args := []string{"--port=8080"}
+				envs := []corev1.EnvVar{{Name: "MODE", Value: "release"}}
+				lc := &corev1.Lifecycle{
+					PostStart: &corev1.LifecycleHandler{
+						Exec: &corev1.ExecAction{Command: []string{"echo", "started"}},
+					},
+				}
+				shm := resource.NewQuantity(1*1024*1024*1024, resource.BinarySI)
+				res := &inferenceapi.ResourceRequirements{}
+
+				backend := &inferenceapi.BackendRuntime{
+					ObjectMeta: metav1.ObjectMeta{Name: "default"},
+					Spec: inferenceapi.BackendRuntimeSpec{
+						Command:   cmd,
+						Envs:      envs,
+						Lifecycle: lc,
+						Image:     "inftyai/llama",
+						Version:   "v0.1.0",
+						RecommendedConfigs: []inferenceapi.RecommendedConfig{
+							{
+								Name:             "default",
+								Args:             args,
+								Resources:        res,
+								SharedMemorySize: shm,
+							},
+						},
+					},
+				}
+
+				models := []*coreapi.OpenModel{}
+				qwenModel := wrapper.MakeModel("qwen2-0--5b").FamilyName("qwen2").ModelSourceWithURI("ollama://qwen2:0.5b").Obj()
+				models = append(models, qwenModel)
+
+				playground := wrapper.MakePlayground("qwen2-0--5b", corev1.NamespaceDefault).ModelClaim("qwen2-0--5b").BackendRuntime("llmaz-ollama").BackendRuntimeEnv("OLLAMA_HOST", "0.0.0.0:8080").Replicas(1).Obj()
+
+				return NewBackendRuntimeParser(backend, models, playground)
+			}(),
+			want: want{
+				cmd:  []string{"python", "serve.py"},
+				args: []string{"--port=8080"},
+				envs: []corev1.EnvVar{{Name: "MODE", Value: "release"}},
+				lifecycle: &corev1.Lifecycle{
+					PostStart: &corev1.LifecycleHandler{
+						Exec: &corev1.ExecAction{Command: []string{"echo", "started"}},
+					},
+				},
+				image:     "inftyai/llama:v0.1.0",
+				version:   "v0.1.0",
+				resources: &inferenceapi.ResourceRequirements{},
+				shm:       resource.NewQuantity(1*1024*1024*1024, resource.BinarySI),
+			},
+		},
+		{
+			name: "recommendConfigName not found and resources and SharedMemorySize return nil",
+			parser: func() *BackendRuntimeParser {
+				backend := &inferenceapi.BackendRuntime{
+					ObjectMeta: metav1.ObjectMeta{Name: "default"},
+					Spec: inferenceapi.BackendRuntimeSpec{
+						Command: []string{"some"},
+						Image:   "repo/img",
+						Version: "latest",
+						RecommendedConfigs: []inferenceapi.RecommendedConfig{
+							{
+								Name: "default",
+							},
+						},
+					},
+				}
+
+				models := []*coreapi.OpenModel{}
+				qwenModel := wrapper.MakeModel("qwen2-0--5b").FamilyName("qwen2").ModelSourceWithURI("ollama://qwen2:0.5b").Obj()
+				models = append(models, qwenModel)
+
+				playground := wrapper.MakePlayground("qwen2-0--5b", corev1.NamespaceDefault).ModelClaim("qwen2-0--5b").BackendRuntime("llmaz-ollama").BackendRuntimeEnv("OLLAMA_HOST", "0.0.0.0:8080").Replicas(1).Obj()
+
+				return NewBackendRuntimeParser(backend, models, playground)
+			}(),
+			want: want{
+				cmd:       []string{"some"},
+				image:     "repo/img:latest",
+				version:   "latest",
+				args:      []string{},
+				resources: nil,
+				shm:       nil,
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		tc := tc // capture range variable
+		t.Run(tc.name, func(t *testing.T) {
+			p := tc.parser
+			if diff := cmp.Diff(tc.want.cmd, p.Command()); diff != "" {
+				t.Fatalf("Command() mismatch (-want +got):\n%s", diff)
+			}
+			args, err := p.Args()
+			if err != nil {
+				t.Fatal(err)
+			}
+			if diff := cmp.Diff(tc.want.args, args); diff != "" {
+				t.Fatalf("Args() mismatch (-want +got):\n%s", diff)
+			}
+
+			if diff := cmp.Diff(tc.want.envs, p.Envs()); diff != "" {
+				t.Fatalf("Envs() mismatch (-want +got):\n%s", diff)
+			}
+
+			if diff := cmp.Diff(tc.want.lifecycle, p.Lifecycle()); diff != "" {
+				t.Fatalf("Lifecycle() mismatch (-want +got):\n%s", diff)
+			}
+
+			if got := p.Image(p.Version()); got != tc.want.image {
+				t.Fatalf("Image() = %s, want %s", got, tc.want.image)
+			}
+
+			if got := p.Version(); got != tc.want.version {
+				t.Fatalf("Version() = %s, want %s", got, tc.want.version)
+			}
+
+			if diff := cmp.Diff(tc.want.resources, p.Resources()); diff != "" {
+				t.Fatalf("Resources() mismatch (-want +got):\n%s", diff)
+			}
+
+			if diff := cmp.Diff(tc.want.shm, p.SharedMemorySize()); diff != "" {
+				t.Fatalf("SharedMemorySize() mismatch (-want +got):\n%s", diff)
+			}
+		})
+	}
+}