Skip to content

Commit

Permalink
Adress comments
Browse files Browse the repository at this point in the history
  • Loading branch information
klapkov committed Nov 29, 2024
1 parent 1ea629b commit 9e3760e
Show file tree
Hide file tree
Showing 7 changed files with 27 additions and 26 deletions.
2 changes: 1 addition & 1 deletion api/handlers/service_offering_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,7 @@ var _ = Describe("ServiceOffering", func() {
Expect(rr).To(HaveHTTPStatus(http.StatusNoContent))
})

When("getting the service offering fails with not found", func() {
When("deleting the service offering fails with not found", func() {
BeforeEach(func() {
serviceOfferingRepo.DeleteOfferingReturns(apierrors.NewNotFoundError(nil, repositories.ServiceOfferingResourceType))
})
Expand Down
30 changes: 21 additions & 9 deletions api/repositories/service_offering_repository_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -331,7 +331,7 @@ var _ = Describe("ServiceOfferingRepo", func() {
})
})

Describe("Delete", func() {
Describe("Delete-off", func() {
var (
plan *korifiv1alpha1.CFServicePlan
offering *korifiv1alpha1.CFServiceOffering
Expand Down Expand Up @@ -379,11 +379,20 @@ var _ = Describe("ServiceOfferingRepo", func() {
}
Expect(k8sClient.Create(ctx, plan)).To(Succeed())

instance = createServiceInstanceCR(ctx, k8sClient, uuid.NewString(), space.Name, "my-service-instance", "secret-name")
instance.Spec.PlanGUID = plan.Name
instance.Finalizers = append(instance.Finalizers, korifiv1alpha1.CFManagedServiceInstanceFinalizerName)

Expect(k8sClient.Update(ctx, instance)).To(Succeed())
instance = &korifiv1alpha1.CFServiceInstance{
ObjectMeta: metav1.ObjectMeta{
Namespace: space.Name,
Name: uuid.NewString(),
Finalizers: []string{
korifiv1alpha1.CFManagedServiceInstanceFinalizerName,
},
},
Spec: korifiv1alpha1.CFServiceInstanceSpec{
PlanGUID: plan.Name,
Type: "user-provided",
},
}
Expect(k8sClient.Create(ctx, instance)).To(Succeed())

binding = &korifiv1alpha1.CFServiceBinding{
ObjectMeta: metav1.ObjectMeta{
Expand All @@ -392,6 +401,9 @@ var _ = Describe("ServiceOfferingRepo", func() {
Labels: map[string]string{
korifiv1alpha1.PlanGUIDLabelKey: plan.Name,
},
Finalizers: []string{
korifiv1alpha1.CFServiceBindingFinalizerName,
},
},
Spec: korifiv1alpha1.CFServiceBindingSpec{
Service: corev1.ObjectReference{
Expand All @@ -404,15 +416,15 @@ var _ = Describe("ServiceOfferingRepo", func() {
},
},
}

binding.Finalizers = append(binding.Finalizers, korifiv1alpha1.CFServiceBindingFinalizerName)
Expect(k8sClient.Create(ctx, binding)).To(Succeed())

createRoleBinding(ctx, userName, spaceDeveloperRole.Name, space.Name)
createRoleBinding(ctx, userName, adminRole.Name, rootNamespace)

message = repositories.DeleteServiceOfferingMessage{GUID: offering.Name}
})

JustBeforeEach(func() {
createRoleBinding(ctx, userName, spaceDeveloperRole.Name, space.Name)
deleteErr = repo.DeleteOffering(ctx, authInfo, message)
})

Expand Down
4 changes: 2 additions & 2 deletions controllers/controllers/services/brokers/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,8 +102,8 @@ func (r *Reconciler) secretToServiceBroker(ctx context.Context, o client.Object)

//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfservicebrokers,verbs=get;list;watch;create;update;patch;delete
//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfservicebrokers/status,verbs=get;update;patch
//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfserviceofferings,verbs=get;list;watch;create;update;patch
//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfserviceplans,verbs=get;list;watch;create;update;patch
//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfserviceofferings,verbs=get;list;watch;create;update;patch;delete
//+kubebuilder:rbac:groups=korifi.cloudfoundry.org,resources=cfserviceplans,verbs=get;list;watch;create;update;patch;delete

func (r *Reconciler) ReconcileResource(ctx context.Context, cfServiceBroker *korifiv1alpha1.CFServiceBroker) (ctrl.Result, error) {
log := logr.FromContextOrDiscard(ctx).WithValues("broker-id", cfServiceBroker.Name)
Expand Down
1 change: 1 addition & 0 deletions helm/korifi/controllers/cf_roles/cf_admin.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -207,6 +207,7 @@ rules:
- list
- get
- patch
- delete

- apiGroups:
- rbac.authorization.k8s.io
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,6 @@ rules:
- cfservicebrokers
verbs:
- list
- delete

- apiGroups:
- korifi.cloudfoundry.org
Expand Down
14 changes: 2 additions & 12 deletions helm/korifi/controllers/role.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -110,6 +110,8 @@ rules:
- cfservicebindings
- cfservicebrokers
- cfserviceinstances
- cfserviceofferings
- cfserviceplans
- cfspaces
- cftasks
verbs:
Expand Down Expand Up @@ -204,18 +206,6 @@ rules:
- get
- patch
- update
- apiGroups:
- korifi.cloudfoundry.org
resources:
- cfserviceofferings
- cfserviceplans
verbs:
- create
- get
- list
- patch
- update
- watch
- apiGroups:
- kpack.io
resources:
Expand Down
1 change: 0 additions & 1 deletion tests/e2e/apps_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -420,7 +420,6 @@ var _ = Describe("Apps", func() {
It("succeeds", func() {
Expect(resp).To(HaveRestyStatusCode(http.StatusOK))
Expect(resultList.Resources[0].GUID).To(Equal(buildGUID))

})
})

Expand Down

0 comments on commit 9e3760e

Please sign in to comment.