Rework Crossplane v2 handling

Author: iciclespider

.gitignore

@@ -215,3 +215,4 @@ crossplane/pythonic/__version__.py
 pocs/
 pythonic-packages/
 tests/protobuf/pytest_pb2*
+scripts/.aws-credentials

crossplane/pythonic/auto_ready.py

@@ -0,0 +1,148 @@
+
+
+def process(composite):
+    for name, resource in composite.resources:
+        if resource.observed:
+            if resource.autoReady or (resource.autoReady is None and composite.autoReady):
+                if resource.ready is None:
+                    check = _checks.get((resource.apiVersion, resource.kind))
+                    if check:
+                        if check.ready(resource):
+                            resource.ready = True
+                    else:
+                        if resource.conditions.Ready.status:
+                            resource.ready = True
+
+
+_checks = {}
+
+
+class Check:
+    apiVersion = None
+
+    @classmethod
+    def __init_subclass__(cls, **kwargs):
+        super().__init_subclass__(**kwargs)
+        _checks[(cls.apiVersion, cls.__name__)] = cls()
+
+    def ready(self, resource):
+        return True
+
+
+class ConfigMap(Check):
+    apiVersion = 'v1'
+
+class CronJob(Check):
+    apiVersion = 'batch/v1'
+
+    def ready(self, resource):
+        if resource.observed.spec.suspend:
+            return True
+        if not resource.status.lastScheduleTime:
+            return False
+        if resource.status.active:
+            return True
+        if not resource.status.lastSuccessfulTime:
+            return False
+        return resource.status.lastSuccessfulTime >= resource.status.lastScheduleTime
+
+class DaemonSet(Check):
+    apiVersion = 'apps/v1'
+    
+    def ready(self, resource):
+        if not resource.status.desiredNumberScheduled:
+            return False
+        scheduled = resource.status.desiredNumberScheduled
+        return (scheduled == resource.status.numberReady and
+                scheduled == resource.status.updatedNumberScheduled and
+                scheduled == resource.status.numberAvailable
+                )
+
+class Deployment(Check):
+    apiVersion = 'apps/v1'
+
+    def ready(self, resource):
+        replicas = resource.observed.spec.replicas or 1
+        if replicas != resource.status.updatedReplicas or replicas != resource.status.availableReplicas:
+            return False
+        return bool(resource.conditions.Available.status)
+
+class HorizontalPodAutoscaler(Check):
+    apiVersion = 'autoscaling/v2'
+
+    def ready(self, resource):
+        for type in ('FailedGetScale', 'FailedUpdateScale', 'FailedGetResourceMetric', 'InvalidSelector'):
+            if resource.conditions[type].status:
+                return False
+        for type in ('ScalingActive', 'ScalingLimited'):
+            if resource.conditions[type].status:
+                return True
+        return False
+
+class Ingress(Check):
+    apiVersion = 'networking.k8s.io/v1'
+
+    def ready(self, resource):
+        return len(resource.status.loadBalancer.ingress) > 0
+
+class Job(Check):
+    apiVersion = 'batch/v1'
+
+    def ready(self, resource):
+        return bool(resource.conditions.JobComplete.status)
+
+class Namespace(Check):
+    apiVersion = 'v1'
+
+class PersistentVolumeClaim(Check):
+    apiVersion = 'v1'
+
+    def ready(self, resource):
+        return resource.status.phase == 'Bound'
+
+class Pod(Check):
+    apiVersion = 'v1'
+
+    def ready(self, resource):
+        if resource.status.phase == 'Succeeded':
+            return True
+        if resource.status.phase == 'Running':
+            if resource.observed.spec.restartPolicy == 'Always':
+                if resource.conditions.Ready.status:
+                    return True
+        return False
+
+class ReplicaSet(Check):
+    apiVersion = 'v1'
+
+    def ready(self, resource):
+        if int(resource.status.observedGeneration) < int(resource.observed.spec.generation):
+            return False
+        if resource.conditions.ReplicaFailure.status:
+            return False
+        replicas = resource.observed.spec.replicas or 1
+        return resource.status.AvailableReplicas >= replicas
+
+class Secret(Check):
+    apiVersion = 'v1'
+
+class Service(Check):
+    apiVersion = 'v1'
+
+    def ready(self, resource):
+        if resource.observed.spec.type != 'LoadBalancer':
+            return True
+        return len(resource.status.loadBalancer.ingress) > 0
+
+class ServiceAccount(Check):
+    apiVersion = 'v1'
+
+class StatefulSet(Check):
+    apiVersion = 'apps/v1'
+    
+    def ready(self, resource):
+        replicas = resource.observed.spec.replicas or 1
+        return (replicas == resource.status.readyReplicas and
+                replicas == resource.status.currentReplicas and
+                resource.status.currentRevision == resource.status.updateRevision
+                )

crossplane/pythonic/command.py

@@ -50,6 +50,11 @@ def add_function_arguments(cls, parser):
             action='store_true',
             help='Allow oversized protobuf messages',
         )
+        parser.add_argument(
+            '--crossplane-v1',
+            action='store_true',
+            help='Enable Crossplane V1 compatibility mode',
+        )
 
     def __init__(self, args):
         self.args = args