implement filterlist for resource policy observation

swisscom · Aug 9, 2024 · 3088e2e · 3088e2e
1 parent 6ca4224
commit 3088e2e
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/pkg/controller/cloudwatchlogs/resourcepolicy/setup.go b/pkg/controller/cloudwatchlogs/resourcepolicy/setup.go
@@ -33,6 +33,7 @@ func SetupResourcePolicy(mgr ctrl.Manager, o controller.Options) error {
 
 	opts := []option{
 		func(e *external) {
+			e.filterList = filterList
 			e.preCreate = preCreate
 			e.preUpdate = preUpdate
 			e.preDelete = preDelete
@@ -91,3 +92,15 @@ func isUpToDate(_ context.Context, cr *svcapitypes.ResourcePolicy, obj *svcsdk.D
 	}
 	return false, "", nil
 }
+
+func filterList(cr *svcapitypes.ResourcePolicy, list *svcsdk.DescribeResourcePoliciesOutput) *svcsdk.DescribeResourcePoliciesOutput {
+	resp := &svcsdk.DescribeResourcePoliciesOutput{}
+
+	for _, resourcePolicy := range list.ResourcePolicies {
+		if pointer.StringValue(resourcePolicy.PolicyName) == meta.GetExternalName(cr) {
+			resp.ResourcePolicies = append(resp.ResourcePolicies, resourcePolicy)
+			break
+		}
+	}
+	return resp
+}