Add sync functionality to re-queue until the Status is Active (#65)

Re-queue when function `State` is not `Active`

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.

Author: Vandita2020

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2022-11-04T23:25:04Z"
+  build_date: "2022-11-16T21:25:40Z"
   build_hash: 7cd74c3a855e38ea3fb5e1cf40b26fbe96283870
   go_version: go1.19
   version: v0.19.3-15-g7cd74c3-dirty
 api_directory_checksum: f01a03847a7bb58e935fdca90ecfb910f645ea61
 api_version: v1alpha1
 aws_sdk_go_version: v1.44.93
 generator_config_info:
-  file_checksum: 8c3d1a125902512d09de13f6ff4337e07a5518f0
+  file_checksum: ea74be1ffb53a2cc383f2a741d46c8facad26df0
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

apis/v1alpha1/generator.yaml

@@ -7,6 +7,10 @@ ignore:
     # FunctionUrlConfig
 resources:
   Function:
+    synced:
+      when:
+        - path: Status.State
+          in: [ "Active" ]
     fields:
       Code.S3Bucket:
         references:

generator.yaml

@@ -7,6 +7,10 @@ ignore:
     # FunctionUrlConfig
 resources:
   Function:
+    synced:
+      when:
+        - path: Status.State
+          in: [ "Active" ]
     fields:
       Code.S3Bucket:
         references:

pkg/resource/function/manager.go

@@ -420,3 +420,59 @@ def test_function_package_type_image_with_signing_config(self, lambda_client):
 
         # Check Lambda function doesn't exist
         assert not lambda_validator.function_exists(resource_name)
+
+    def test_function_is_synced(self, lambda_client):
+        resource_name = random_suffix_name("lambda-function", 24)
+
+        resources = get_bootstrap_resources()
+        logging.debug(resources)
+
+        replacements = REPLACEMENT_VALUES.copy()
+        replacements["FUNCTION_NAME"] = resource_name
+        replacements["BUCKET_NAME"] = resources.FunctionsBucket.name
+        replacements["LAMBDA_ROLE"] = resources.BasicRole.arn
+        replacements["LAMBDA_FILE_NAME"] = LAMBDA_FUNCTION_FILE_ZIP
+        replacements["RESERVED_CONCURRENT_EXECUTIONS"] = "0"
+        replacements["CODE_SIGNING_CONFIG_ARN"] = ""
+        replacements["AWS_REGION"] = get_region()
+
+        # Load Lambda CR
+        resource_data = load_lambda_resource(
+            "function",
+            additional_replacements=replacements,
+        )
+        logging.debug(resource_data)
+
+        # Create k8s resource
+        ref = k8s.CustomResourceReference(
+            CRD_GROUP, CRD_VERSION, RESOURCE_PLURAL,
+            resource_name, namespace="default",
+        )
+        k8s.create_custom_resource(ref, resource_data)
+        cr = k8s.wait_resource_consumed_by_controller(ref)
+
+        assert cr is not None
+        assert k8s.get_resource_exists(ref)
+
+        time.sleep(CREATE_WAIT_AFTER_SECONDS*3)
+
+        cr = k8s.wait_resource_consumed_by_controller(ref)
+
+        lambda_validator = LambdaValidator(lambda_client)
+        # Check Lambda function exists
+        assert lambda_validator.function_exists(resource_name)
+
+        assert cr["status"]["state"] == "Active"
+
+        function = lambda_validator.get_function(resource_name)
+        assert function is not None
+        assert function["Configuration"]["State"] == "Active"
+
+        # Delete k8s resource
+        _, deleted = k8s.delete_custom_resource(ref)
+        assert deleted is True
+
+        time.sleep(DELETE_WAIT_AFTER_SECONDS)
+
+        # Check Lambda function doesn't exist
+        assert not lambda_validator.function_exists(resource_name)