Skip to content

Commit

Permalink
fix: Add status subresource to fake client due to kubernetes-sigs/con…
Browse files Browse the repository at this point in the history
  • Loading branch information
yiannistri committed Nov 6, 2023
1 parent 839ee6c commit c7da498
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 2 deletions.
2 changes: 1 addition & 1 deletion internal/grpctesting/grpctesting.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ func BuildScheme() *runtime.Scheme {
}

func MakeFactoryWithObjects(objects ...client.Object) (client.Client, *clustersmngrfakes.FakeClustersManager) {
k8s := fake.NewClientBuilder().WithScheme(BuildScheme()).WithObjects(objects...).Build()
k8s := fake.NewClientBuilder().WithScheme(BuildScheme()).WithObjects(objects...).WithStatusSubresource(&tfctrl.Terraform{}).Build()

factory := MakeClustersManager(k8s)

Expand Down
2 changes: 2 additions & 0 deletions pkg/gitopssets/server/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -541,6 +541,7 @@ func createClient(t *testing.T, clusterState ...runtime.Object) client.Client {
c := fake.NewClientBuilder().
WithScheme(scheme).
WithRuntimeObjects(clusterState...).
WithStatusSubresource(&ctrl.GitOpsSet{}).
Build()

return c
Expand Down Expand Up @@ -589,6 +590,7 @@ func TestSyncGitOpsSet(t *testing.T) {
}()

ticker := time.NewTicker(500 * time.Millisecond)
defer ticker.Stop()
for {
select {
case <-ticker.C:
Expand Down
4 changes: 3 additions & 1 deletion pkg/helm/multiwatcher/controller/helm_watcher_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,7 @@ func TestReconcileDelete(t *testing.T) {
makeTestHelmRepo(func(hr *sourcev1beta2.HelmRepository) {
newTime := metav1.NewTime(time.Now())
hr.ObjectMeta.DeletionTimestamp = &newTime
hr.Finalizers = append(hr.Finalizers, "finalizers.fluxcd.io")
}),
&fakeValuesFetcher{nil, nil},
fakeCache,
Expand All @@ -152,6 +153,7 @@ func TestReconcileDeletingTheCacheFails(t *testing.T) {
deletedHelmRepo := makeTestHelmRepo(func(hr *sourcev1beta2.HelmRepository) {
newTime := metav1.NewTime(time.Now())
hr.ObjectMeta.DeletionTimestamp = &newTime
hr.Finalizers = append(hr.Finalizers, "finalizers.fluxcd.io")
})
fakeErroringCache := helmfakes.NewFakeChartCache(func(fc *helmfakes.FakeChartCache) {
fc.DeleteError = errors.New("nope")
Expand Down Expand Up @@ -261,7 +263,7 @@ func setupReconcileAndFakes(helmRepo client.Object, fakeFetcher *fakeValuesFetch
scheme := runtime.NewScheme()
utilruntime.Must(sourcev1beta2.AddToScheme(scheme))

fakeClient := fake.NewClientBuilder().WithScheme(scheme)
fakeClient := fake.NewClientBuilder().WithScheme(scheme).WithStatusSubresource(&sourcev1beta2.HelmRepository{})
if helmRepo != nil {
fakeClient = fakeClient.WithObjects(helmRepo)
}
Expand Down
1 change: 1 addition & 0 deletions pkg/helm/valuesfetcher_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -218,6 +218,7 @@ func createFakeClient(t *testing.T, clusterState ...runtime.Object) client.Clien
c := fake.NewClientBuilder().
WithScheme(scheme).
WithRuntimeObjects(clusterState...).
WithStatusSubresource(&sourcev1.HelmChart{}).
Build()

return c
Expand Down

0 comments on commit c7da498

Please sign in to comment.