feat: introduce advancedHTTP for expose field & change podLabels to selector

src/grafana/chart/templates/uds-package.yaml

@@ -7,7 +7,7 @@ spec:
   network:
     expose:
       - service: grafana
-        podLabels:
+        selector:
           app.kubernetes.io/name: grafana
         host: grafana
         gateway: admin
@@ -16,22 +16,22 @@ spec:
 
     allow:
       - direction: Ingress
-        podLabels:
+        selector:
           app.kubernetes.io/name: grafana
         remoteNamespace: tempo
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: tempo
         port: 9090
         description: "Tempo Datasource"
 
       - direction: Egress
-        podLabels:
+        selector:
           app.kubernetes.io/name: grafana
         remoteGenerated: Anywhere
 
       - direction: Egress
         remoteNamespace: tempo
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: tempo
         port: 9411
         description: "Tempo"

src/loki/chart/templates/uds-package.yaml

@@ -14,45 +14,45 @@ spec:
         remoteGenerated: IntraNamespace
 
       - direction: Ingress
-        podLabels:
+        selector:
           app.kubernetes.io/name: loki
         remoteNamespace: grafana
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: grafana
         ports:
           - 8080
         description: "Grafana Log Queries"
 
       - direction: Ingress
-        podLabels:
+        selector:
           app.kubernetes.io/name: loki
         remoteNamespace: monitoring
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: prometheus
         ports:
           - 3100
           - 8080
         description: "Prometheus Metrics"
 
       - direction: Ingress
-        podLabels:
+        selector:
           app.kubernetes.io/name: loki
         remoteNamespace: promtail
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: promtail
         ports:
           - 8080
         description: "Promtail Log Storage"
 
       # Todo: wide open for now for pushing to s3
       - direction: Egress
-        podLabels:
+        selector:
           app.kubernetes.io/name: loki
         remoteGenerated: Anywhere
 
       - direction: Egress
         remoteNamespace: tempo
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: tempo
         port: 9411
         description: "Tempo"

src/metrics-server/chart/templates/uds-package.yaml

@@ -7,17 +7,17 @@ spec:
   network:
     allow:
       - direction: Egress
-        podLabels:
+        selector:
           app.kubernetes.io/name: metrics-server
         # todo: evaluate an "all nodes" generated rule
         remoteGenerated: Anywhere
         port: 10250
       - direction: Egress
-        podLabels:
+        selector:
           app.kubernetes.io/name: metrics-server
         remoteGenerated: KubeAPI
       - direction: Ingress
-        podLabels:
+        selector:
           app.kubernetes.io/name: metrics-server
         # todo: evaluate a "KubeAPI" _ingress_ generated rule
         remoteGenerated: Anywhere

src/neuvector/chart/templates/uds-package.yaml

@@ -7,7 +7,7 @@ spec:
   network:
     expose:
       - service: neuvector-service-webui
-        podLabels:
+        selector:
           app: neuvector-manager-pod
         gateway: admin
         host: neuvector
@@ -23,26 +23,26 @@ spec:
 
       - direction: Egress
         remoteGenerated: KubeAPI
-        podLabels:
+        selector:
           app: neuvector-controller-pod
 
       - direction: Egress
         remoteGenerated: KubeAPI
-        podLabels:
+        selector:
           app: neuvector-updater-pod
 
       - direction: Ingress
         remoteNamespace: monitoring
-        remotePodLabels:
+        remoteSelector:
           app: prometheus
-        podLabels:
+        selector:
           app: neuvector-prometheus-exporter-pod
         port: 8068
         description: "Prometheus Metrics"
 
       - direction: Egress
         remoteNamespace: tempo
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: tempo
         port: 9411
         description: "Tempo"

src/pepr/config.ts

@@ -1,8 +1,14 @@
-const isZarfEnv = process.env.UDS_DOMAIN !== "###ZARF_VAR_DOMAIN###";
+import { Log } from "pepr";
+
+// We need to handle `npx pepr <>` commands that will not template the env vars
+const domain = process.env.UDS_DOMAIN;
+const isZarfEnv = domain ? domain !== "###ZARF_VAR_DOMAIN###" : false;
 
 export const UDSConfig = {
   // Ignore the UDS_DOMAIN if not deployed by Zarf
-  domain: (isZarfEnv && process.env.UDS_DOMAIN) || "uds.dev",
+  domain: (isZarfEnv && domain) || "uds.dev",
   // Assume Istio is installed if not deployed by Zarf
   istioInstalled: !isZarfEnv || process.env.UDS_WITH_ISTIO === "true",
 };
+
+Log.info(UDSConfig, "Loaded UDS Config");

src/pepr/operator/README.md

@@ -20,7 +20,7 @@ spec:
   network:
     expose:
       - service: grafana
-        podLabels:
+        selector:
           app.kubernetes.io/name: grafana
         host: grafana
         gateway: admin
@@ -29,13 +29,13 @@ spec:
 
     allow:
       - direction: Egress
-        podLabels:
+        selector:
           app.kubernetes.io/name: grafana
         remoteGenerated: Anywhere
 
       - direction: Egress
         remoteNamespace: tempo
-        remotePodLabels:
+        remoteSelector:
           app.kubernetes.io/name: tempo
         port: 9411
         description: "Tempo"

src/pepr/operator/controllers/istio/virtual-service.ts

@@ -22,7 +22,7 @@ export async function virtualService(pkg: UDSPackage, namespace: string) {
 
   // Iterate over each exposed service
   for (const expose of exposeList) {
-    const { gateway = Gateway.Tenant, host, port, service, match } = expose;
+    const { gateway = Gateway.Tenant, host, port, service, advancedHTTP = {} } = expose;
 
     const name = generateVSName(pkg, expose);
 
@@ -32,6 +32,8 @@ export async function virtualService(pkg: UDSPackage, namespace: string) {
     // Append the domain to the host
     const fqdn = `${host}.${domain}`;
 
+    const http: Istio.HTTP = { ...advancedHTTP };
+
     // Create the route to the service
     const route: Istio.HTTPRoute[] = [
       {
@@ -44,6 +46,11 @@ export async function virtualService(pkg: UDSPackage, namespace: string) {
       },
     ];
 
+    if (!advancedHTTP.directResponse) {
+      // Create the route to the service if not using advancedHTTP.directResponse
+      http.route = route;
+    }
+
     const payload: Istio.VirtualService = {
       metadata: {
         name,
@@ -61,7 +68,7 @@ export async function virtualService(pkg: UDSPackage, namespace: string) {
         // Map the gateway (admin, passthrough or tenant) to the VirtualService
         gateways: [`istio-${gateway}-gateway/${gateway}-gateway`],
         // Apply the route to the VirtualService
-        http: [{ route, match }],
+        http: [http],
       },
     };
 
@@ -105,10 +112,10 @@ export async function virtualService(pkg: UDSPackage, namespace: string) {
 }
 
 export function generateVSName(pkg: UDSPackage, expose: Expose) {
-  const { gateway = Gateway.Tenant, host, port, service, match, description } = expose;
+  const { gateway = Gateway.Tenant, host, port, service, description, advancedHTTP } = expose;
 
   // Ensure the resource name is valid
-  const matchHash = match?.flatMap(m => m.name).join("-") || "";
+  const matchHash = advancedHTTP?.match?.flatMap(m => m.name).join("-") || "";
   const nameSuffix = description || `${host}-${port}-${service}-${matchHash}`;
   const name = sanitizeResourceName(`${pkg.metadata!.name}-${gateway}-${nameSuffix}`);
 

src/pepr/operator/controllers/network/defaults/allow-egress-dns.ts

@@ -6,7 +6,7 @@ export const allowEgressDNS = (namespace: string) => {
     direction: Direction.Egress,
     description: "DNS lookup via CoreDNS",
     remoteNamespace: "kube-system",
-    remotePodLabels: {
+    remoteSelector: {
       "k8s-app": "kube-dns",
     },
     port: 53,

src/pepr/operator/controllers/network/defaults/allow-egress-istiod.ts

@@ -6,7 +6,7 @@ export const allowEgressIstiod = (namespace: string) =>
     direction: Direction.Egress,
     description: "Istiod communication",
     remoteNamespace: "istio-system",
-    remotePodLabels: {
+    remoteSelector: {
       istio: "pilot",
     },
     port: 15012,

src/pepr/operator/controllers/network/defaults/allow-ingress-sidecar-monitoring.ts

@@ -6,7 +6,7 @@ export const allowIngressSidecarMonitoring = (namespace: string) =>
     direction: Direction.Ingress,
     description: "Sidecar monitoring",
     remoteNamespace: "monitoring",
-    remotePodLabels: {
+    remoteSelector: {
       app: "prometheus",
     },
     port: 15020,

src/pepr/operator/controllers/network/generate.ts

@@ -23,7 +23,7 @@ export function generate(namespace: string, policy: Allow): kind.NetworkPolicy {
     spec: {
       policyTypes: [policy.direction],
       podSelector: {
-        matchLabels: policy.podLabels,
+        matchLabels: policy.selector,
       },
     },
   };
@@ -53,11 +53,11 @@ export function generate(namespace: string, policy: Allow): kind.NetworkPolicy {
     peers.push({ namespaceSelector });
   }
 
-  // Add the remotePodLabels if they exist
-  if (policy.remotePodLabels) {
+  // Add the remoteSelector if they exist
+  if (policy.remoteSelector) {
     peers.push({
       podSelector: {
-        matchLabels: policy.remotePodLabels,
+        matchLabels: policy.remoteSelector,
       },
     });
   }
@@ -122,10 +122,10 @@ export function generateName(policy: Allow) {
     policy.description ||
     // Otherwise use the direction, and combination of remote properties
     [
-      Object.values(policy.podLabels || ["all pods"]),
+      Object.values(policy.selector || ["all pods"]),
       policy.remoteGenerated || [
         policy.remoteNamespace,
-        Object.values(policy.remotePodLabels || ["all pods"]),
+        Object.values(policy.remoteSelector || ["all pods"]),
       ],
     ]
       // Flatten the array

src/pepr/operator/controllers/network/policies.ts

@@ -35,20 +35,21 @@ export async function networkPolicies(pkg: UDSPackage, namespace: string) {
 
   // Generate NetworkPolicies for any VirtualServices that are generated
   const exposeList = pkg.spec?.network?.expose ?? [];
-  for (const expose of exposeList) {
-    const { gateway = Gateway.Tenant, port, podLabels, targetPort } = expose;
+  // Iterate over each exposed service, excluding directResponse services
+  for (const expose of exposeList.filter(exp => !exp.advancedHTTP?.directResponse)) {
+    const { gateway = Gateway.Tenant, port, selector = {}, targetPort } = expose;
 
     // Create the NetworkPolicy for the VirtualService
     const policy: Allow = {
       direction: Direction.Ingress,
-      podLabels,
+      selector,
       remoteNamespace: `istio-${gateway}-gateway`,
-      remotePodLabels: {
+      remoteSelector: {
         app: `${gateway}-ingressgateway`,
       },
       // Use the same port as the VirtualService if targetPort is not set
       port: targetPort ?? port,
-      description: `${Object.values(podLabels)} Istio ${gateway} gateway`,
+      description: `${Object.values(selector)} Istio ${gateway} gateway`,
     };
 
     // Generate the policy