feat(lambda): Set .status.atProvider during observe

Signed-off-by: Maximilian Blatt <maximilian.blatt-extern@deutschebahn.com> (external expert on behalf of DB Netz AG)
crossplane-contrib · Aug 4, 2022 · acc4826 · acc4826
1 parent f0fa1f4
commit acc4826
Showing 1 changed file with 51 additions and 0 deletions.
diff --git a/pkg/controller/lambda/function/setup.go b/pkg/controller/lambda/function/setup.go
@@ -97,6 +97,7 @@ func postObserve(_ context.Context, cr *svcapitypes.Function, resp *svcsdk.GetFu
 	if err != nil {
 		return managed.ExternalObservation{}, err
 	}
+	cr.Status.AtProvider = generateFuntionObservation(resp)
 	switch aws.StringValue(resp.Configuration.State) {
 	case string(svcapitypes.State_Active):
 		cr.SetConditions(xpv1.Available())
@@ -473,3 +474,53 @@ func GenerateUpdateFunctionConfigurationInput(cr *svcapitypes.Function) *svcsdk.
 	}
 	return res
 }
+
+func generateFuntionObservation(resp *svcsdk.GetFunctionOutput) svcapitypes.FunctionObservation {
+	if resp == nil || resp.Configuration == nil {
+		return svcapitypes.FunctionObservation{}
+	}
+
+	o := svcapitypes.FunctionObservation{
+		CodeSHA256:                 resp.Configuration.CodeSha256,
+		CodeSize:                   resp.Configuration.CodeSize,
+		FunctionARN:                resp.Configuration.FunctionArn,
+		FunctionName:               resp.Configuration.FunctionName,
+		LastModified:               resp.Configuration.LastModified,
+		LastUpdateStatus:           resp.Configuration.LastUpdateStatus,
+		LastUpdateStatusReason:     resp.Configuration.LastUpdateStatusReason,
+		LastUpdateStatusReasonCode: resp.Configuration.LastUpdateStatusReasonCode,
+		MasterARN:                  resp.Configuration.MasterArn,
+		RevisionID:                 resp.Configuration.RevisionId,
+		Role:                       resp.Configuration.Role,
+		SigningJobARN:              resp.Configuration.SigningJobArn,
+		SigningProfileVersionARN:   resp.Configuration.SigningProfileVersionArn,
+		State:                      resp.Configuration.State,
+		StateReason:                resp.Configuration.StateReason,
+		StateReasonCode:            resp.Configuration.StateReasonCode,
+		Version:                    resp.Configuration.Version,
+	}
+	if resp.Configuration.VpcConfig != nil {
+		o.VPCConfig = &svcapitypes.VPCConfigResponse{
+			SecurityGroupIDs: resp.Configuration.VpcConfig.SecurityGroupIds,
+			SubnetIDs:        resp.Configuration.VpcConfig.SubnetIds,
+			VPCID:            resp.Configuration.VpcConfig.VpcId,
+		}
+	}
+	if resp.Configuration.ImageConfigResponse != nil {
+		o.ImageConfigResponse = &svcapitypes.ImageConfigResponse{}
+		if resp.Configuration.ImageConfigResponse.Error != nil {
+			o.ImageConfigResponse.Error = &svcapitypes.ImageConfigError{
+				ErrorCode: resp.Configuration.Environment.Error.ErrorCode,
+				Message:   resp.Configuration.Environment.Error.Message,
+			}
+		}
+		if resp.Configuration.ImageConfigResponse.ImageConfig != nil {
+			o.ImageConfigResponse.ImageConfig = &svcapitypes.ImageConfig{
+				Command:          resp.Configuration.ImageConfigResponse.ImageConfig.Command,
+				EntryPoint:       resp.Configuration.ImageConfigResponse.ImageConfig.EntryPoint,
+				WorkingDirectory: resp.Configuration.ImageConfigResponse.ImageConfig.WorkingDirectory,
+			}
+		}
+	}
+	return o
+}