Skip to content

Commit ecaebbc

Browse files
committed
Drop kube wrapper
Signed-off-by: jose.vazquez <[email protected]>
1 parent f83e53a commit ecaebbc

File tree

2 files changed

+5
-68
lines changed

2 files changed

+5
-68
lines changed

internal/generated/controller/flexcluster/handler_v20250312_test.go

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,8 @@ import (
4545
)
4646

4747
func TestHandleInitial(t *testing.T) {
48-
tr, err := translatorFromEnbeddedCRD("FlexCluster", "v1", "v20250312")
48+
scheme := createTestScheme(t)
49+
tr, err := translatorFromEnbeddedCRD(scheme, "FlexCluster", "v1", "v20250312")
4950
require.NoError(t, err)
5051

5152
deletionProtection := false
@@ -98,14 +99,12 @@ func TestHandleInitial(t *testing.T) {
9899
},
99100
} {
100101
t.Run(tc.title, func(t *testing.T) {
101-
scheme := createTestScheme(t)
102102
allObjects := append([]client.Object{tc.flexCluster}, tc.kubeObjects...)
103103
fakeClient := fake.NewClientBuilder().
104104
WithScheme(scheme).
105105
WithObjects(allObjects...).
106106
WithStatusSubresource(tc.flexCluster).
107107
Build()
108-
kubeClient := newFakeClientWithGVK(fakeClient, scheme)
109108

110109
flexAPI := mockadmin.NewFlexClustersApi(t)
111110
if tc.atlasCreateFlexClusterFunc != nil {
@@ -119,7 +118,7 @@ func TestHandleInitial(t *testing.T) {
119118
FlexClustersApi: flexAPI,
120119
}
121120

122-
handler := flexcluster.NewHandlerv20250312(kubeClient, atlasClient, tr, deletionProtection)
121+
handler := flexcluster.NewHandlerv20250312(fakeClient, atlasClient, tr, deletionProtection)
123122

124123
ctx := context.Background()
125124
got, err := handler.HandleInitial(ctx, tc.flexCluster)
@@ -138,12 +137,12 @@ func setGroupRef(flexCluster *akov2generated.FlexCluster, groupRef string) *akov
138137
return flexCluster
139138
}
140139

141-
func translatorFromEnbeddedCRD(kind, apiVersion, majorVersion string) (crapi.Translator, error) {
140+
func translatorFromEnbeddedCRD(scheme *runtime.Scheme, kind, apiVersion, majorVersion string) (crapi.Translator, error) {
142141
crd, err := crds.EmbeddedCRD(kind)
143142
if err != nil {
144143
return nil, fmt.Errorf("failed to get embedded CRD for %s: %w", kind, err)
145144
}
146-
tr, err := crapi.NewTranslator(crd, apiVersion, majorVersion)
145+
tr, err := crapi.NewTranslator(scheme, crd, apiVersion, majorVersion)
147146
if err != nil {
148147
return nil, fmt.Errorf("failed to get translator for %s: %w", kind, err)
149148
}

internal/generated/controller/flexcluster/kube_test.go

Lines changed: 0 additions & 62 deletions
This file was deleted.

0 commit comments

Comments
 (0)