fix: use latest transpire conventions

Author: nikhiljha

apps/arcanum.py

@@ -1,12 +1,10 @@
-from transpire import emit
 from apps.versions import versions
 
 name = "arcanum"
 
-def objects() -> None:
+def objects():
     # NOTE: arcanum-secret is manually created, as it has a secret key that we need for bootstrap.
-    emit(
-        [
+    manifests = [
             {
                 "apiVersion": "v1",
                 "kind": "ServiceAccount",
@@ -159,10 +157,11 @@ def objects() -> None:
                 },
             },
         ]
-    )
+    
+    for manifest in manifests:
+        yield manifest
 
-    emit(
-        [
+    manifests = [
             {
                 "apiVersion": "apiextensions.k8s.io/v1",
                 "kind": "CustomResourceDefinition",
@@ -228,4 +227,7 @@ def objects() -> None:
                 },
             }
         ]
-    )
+    
+    for manifest in manifests:
+        yield manifest
+

apps/argocd.py

@@ -1,6 +1,6 @@
 import requests
 import yaml
-from transpire import emit, surgery
+from transpire import surgery
 from transpire.resources.ingress import Ingress
 
 from apps.versions import versions
@@ -22,12 +22,12 @@
 }
 
 
-def objects() -> None:
+def objects():
     contents = requests.get(
         f"https://raw.githubusercontent.com/argoproj/argo-cd/v{versions['argocd']['version']}/manifests/ha/install.yaml",
     )
     contents.raise_for_status()
-    emit(
+    yield from (
         surgery.edit_manifests(
             {
                 ("ConfigMap", "argocd-cm"): lambda m: surgery.shelve(
@@ -91,7 +91,6 @@ def objects() -> None:
         )
     )
 
-    ingress = Ingress.simple(
+    yield Ingress.simple(
         "argo.ocf.berkeley.edu", "argocd-server", "https", "argocd-server"
     )
-    emit(ingress)

apps/argoci.py

@@ -1,25 +1,25 @@
 from __future__ import annotations
+from typing import Generator
 
 import requests
 import yaml
-from transpire import emit
 
 from apps.versions import versions
 
 
 name = "argoci"
 
-def objects() -> None:
+def objects() -> Generator[dict, None, None]:
     # TODO: Create argo-events namespace.
 
     argo_workflows = requests.get(
         f"https://github.com/argoproj/argo-workflows/releases/download/v{versions['argo-workflows']['version']}/namespace-install.yaml",
     )
     argo_workflows.raise_for_status()
-    emit(yaml.safe_load_all(argo_workflows.text))
+    yield from yaml.safe_load_all(argo_workflows.text)
 
     argo_events = requests.get(
         f"https://raw.githubusercontent.com/argoproj/argo-events/v{versions['argo-events']['version']}/manifests/install.yaml",
     )
     argo_events.raise_for_status()
-    emit(yaml.safe_load_all(argo_events.text))
+    yield from yaml.safe_load_all(argo_events.text)

apps/cert_manager.py

@@ -1,4 +1,4 @@
-from transpire import emit, helm
+from transpire import helm
 
 from apps.versions import versions
 
@@ -22,11 +22,11 @@
 
 name = "cert-manager"
 
-def objects() -> None:
-    helm_contents = helm.build_chart_from_versions(
+def objects():
+    yield from helm.build_chart_from_versions(
         name="cert-manager",
         versions=versions,
         values=values,
     )
-    emit(helm_contents)
-    emit(cluster_issuer)
+    yield cluster_issuer
+

apps/cilium.py

@@ -1,10 +1,10 @@
-from transpire import emit, helm
+from transpire import helm
 
 from apps.versions import versions
 
 values = {
     "kubeProxyReplacement": "strict",
-    "k8sServiceHost": "127.0.0.1",
+    "k8sServiceHost": "k8s0.ocf.io",
     "k8sServicePort": "6443",
     "nativeRoutingCIDR": "10.0.0.0/8",
     "containerRuntime": {
@@ -16,14 +16,16 @@
         "relay": {"enabled": True},
         "ui": {"enabled": True},
     },
+    "bpf": {
+        "masquerade": True,
+    },
 }
 
 name = "cilium"
-def objects() -> None:
-    emit(
-        helm.build_chart_from_versions(
-            name="cilium",
-            versions=versions,
-            values=values,
-        )
+
+def objects():
+    yield from helm.build_chart_from_versions(
+        name="cilium",
+        versions=versions,
+        values=values,
     )

apps/contour.py

@@ -1,4 +1,4 @@
-from transpire import emit, helm
+from transpire import helm
 
 from apps.versions import versions
 
@@ -12,11 +12,9 @@
 
 name = "contour"
 
-def objects() -> None:
-    emit(
-        helm.build_chart_from_versions(
-            name="contour",
-            versions=versions,
-            values=values,
-        )
+def objects():
+    yield from helm.build_chart_from_versions(
+        name="contour",
+        versions=versions,
+        values=values,
     )

apps/coredns.py

@@ -1,4 +1,4 @@
-from transpire import emit, helm
+from transpire import helm
 
 from apps.versions import versions
 
@@ -7,17 +7,16 @@
     # TODO: This is a hardcoded variable from the kubelet configuration.
     # Consider automatically grabbing this value.
     "service": {
-        "clusterIP": "10.32.0.10",
+        "clusterIP": "10.96.0.10",
     },
 }
 
 name = "coredns"
+namespace = "kube-system"
 
-def objects() -> None:
-    emit(
-        helm.build_chart_from_versions(
-            name="coredns",
-            versions=versions,
-            values=values,
-        )
+def objects():
+    yield from helm.build_chart_from_versions(
+        name="coredns",
+        versions=versions,
+        values=values,
     )

apps/elastic.py

@@ -1,4 +1,4 @@
-from transpire import emit, helm, surgery
+from transpire import helm, surgery
 
 from apps.versions import versions
 
@@ -46,14 +46,12 @@ def strip_secret_checksum(m):
     return m
 
 
-def objects() -> None:
-    emit(
-        [
+def objects():
+        yield from [
             strip_secret_checksum(m)
             for m in helm.build_chart_from_versions(
                 name="harbor",
                 versions=versions,
                 values=values,
             )
         ]
-    )

apps/harbor.py

@@ -1,6 +1,5 @@
 import requests
 import yaml
-from transpire import emit
 
 name = "keycloak"
 base_url = (
@@ -31,7 +30,7 @@
 }
 
 
-def objects() -> None:
+def objects():
     for path in paths:
-        emit(yaml.safe_load_all(requests.get(base_url.format(path)).text))
-    emit(settings)
+        yield from yaml.safe_load_all(requests.get(base_url.format(path)).text)
+    yield settings