Add ODG controller

Reconciles ODG resources in mODG-root cluster and creates ODG-Extension
resources (via gardener-resource-manager).

Author: zkdev

ocm_util.py

@@ -1,6 +1,8 @@
 import collections.abc
 import logging
+import urllib.parse
 
+import ci.util
 import cnudie.iter
 import cnudie.retrieve_async
 import dso.model
@@ -64,7 +66,7 @@ def iter_local_blob_content(
     )
 
 
-async def find_artefact_node(
+async def find_artefact_node_async(
     component_descriptor_lookup: cnudie.retrieve_async.ComponentDescriptorLookupById,
     artefact: dso.model.ComponentArtefactId,
     absent_ok: bool=False,
@@ -119,3 +121,57 @@ async def find_artefact_node(
 
     if not absent_ok:
         raise ValueError(f'could not find OCM node for {artefact=}')
+
+
+def to_absolute_access(
+    access: ocm.OciAccess | ocm.RelativeOciAccess,
+    ocm_repo: ocm.OciOcmRepository=None,
+) -> ocm.OciAccess:
+    if access.type is ocm.AccessType.OCI_REGISTRY:
+        return access
+
+    if access.type is ocm.AccessType.RELATIVE_OCI_REFERENCE:
+        if not '://' in ocm_repo.baseUrl:
+            base_url = urllib.parse.urlparse(f'x://{ocm_repo.baseUrl}').netloc
+        else:
+            base_url = urllib.parse.urlparse(ocm_repo.baseUrl).netloc
+
+        return ocm.OciAccess(
+            imageReference=ci.util.urljoin(base_url, access.reference),
+        )
+
+    raise NotImplementedError(access.type)
+
+
+def find_artefact_node(
+    component: ocm.Component,
+    component_descriptor_lookup,
+    artefact_name: str,
+    artefact_version: str,
+    artefact_type: str,
+    node_filter: collections.abc.Callable | None,
+    absent_ok: bool=False,
+    recursion_depth: int=-1,
+) -> cnudie.iter.ArtefactNode | None:
+    for rnode in cnudie.iter.iter(
+        component=component,
+        lookup=component_descriptor_lookup,
+        node_filter=node_filter,
+        recursion_depth=recursion_depth,
+    ):
+        rnode: cnudie.iter.ResourceNode
+        if not (
+            rnode.resource.name == artefact_name
+            and rnode.resource.version == artefact_version
+            and rnode.resource.type == artefact_type
+        ):
+            continue
+
+        return rnode
+
+    else:
+        if absent_ok:
+            return None
+
+        raise ValueError(f'no ocm node found for {artefact_name=} {artefact_version=} \
+                         {artefact_type=}')