public async static Task ProcessAsync()

in src/Azure.Deployments.Extensibility.Providers.Kubernetes/Extensions/ExtensibilityOperationRequestExtensions.cs [15:64]
40 lines of code
6 McCabe index (conditional complexity)

        public async static Task<KubernetesResource> ProcessAsync(this ExtensibilityOperationRequest request, CancellationToken cancellationToken)
        {
            var (import, resource) = Validate(request);
            var resourceType = KubernetesResourceType.Parse(resource.Type);

            var properties = resource.Properties
                .PatchProperty("apiVersion", resourceType.ApiVersion)
                .PatchProperty("kind", resourceType.Kind);

            var clientConfiguration = await CreateClientConfigurationAsync(import);

            IKubernetes? kubernetes = null;

            try
            {
                kubernetes = new k8s.Kubernetes(clientConfiguration);
                var client = new GenericClient(kubernetes, resourceType.Group, resourceType.Version, plural: "");

                var apiResouceList = await client.ListAsync<V1APIResourceList>(cancellationToken);
                var apiResource = apiResouceList.Resources.FirstOrDefault(x => x.Kind.Equals(resourceType.Kind, StringComparison.Ordinal));

                if (apiResource is null)
                {
                    throw new ExtensibilityException(
                        "UnknownResourceKind",
                        resource.GetJsonPointer(x => x.Type),
                        @$"Unknown resource kind ""{resourceType.Kind}"" in resource type ""{resource.Type}"".");
                }

                if (!apiResource.Namespaced && properties.Metadata.Namespace is not null)
                {
                    throw new ExtensibilityException(
                        "NamespaceSpecifiedForClusterResource",
                        resource.GetJsonPointer(x => x.Properties.Metadata.Namespace!),
                        "A namespace should not be specified for a cluster-scoped resource.");
                }

                var @namespace = apiResource.Namespaced
                    ? resource.Properties.Metadata.Namespace ?? import.Config.Namespace
                    : null;

                return new(kubernetes, resourceType.Group, resourceType.Version, @namespace, apiResource.Name, properties);
            }
            catch
            {
                kubernetes?.Dispose();

                throw;
            }
        }