feat: publish more modules

argo-application-field-validation/kcl.mod

@@ -1,5 +1,5 @@
 [package]
 name = "argo-application-field-validation"
-version = "0.1.1"
+version = "0.1.2"
 description = "`argo-application-field-validation` is a kcl validation module, which can be used to perform some validation on Argo `Application` fields."
 

argo-application-field-validation/main.k

@@ -1,34 +1,13 @@
-import yaml
-
 # Define the validation function
 validate = lambda item {
     if item.kind == "Application" and item.apiVersion.startswith("argoproj.io"):
         path = item?.spec?.source?.path
         chart = item?.spec?.source?.chart
-        server = item?.destination?.server
+        server = item?.spec.destination?.server
         name = item?.spec?.destination?.name
         assert (path or chart) and not (path and chart), "`spec.source.path` OR `spec.source.chart` should be specified but never both."
         assert (server or name) and not (server and name), "`spec.destination.server` OR `spec.destination.name` should be specified but never both."
     item
 }
 # Validate All resource
 items = [validate(i) for i in option("items") or []]
-
-if option("__test__"):
-    validate(yaml.decode("""\
-apiVersion: argoproj.io/v1alpha1
-kind: Application
-metadata:
-  name: badapp01
-  namespace: default
-spec:
-  project: foo
-  source:
-    repoURL: https://github.com/argoproj/argocd-example-apps.git
-    targetRevision: HEAD
-    path: guestbook
-    # chart: foo
-  destination:
-    server: https://kubernetes.default.svc
-    namespace: guestbook
-    """))

argo-application-field-validation/main_test.k

@@ -0,0 +1,21 @@
+import yaml
+
+test_validate = lambda {
+    validate(yaml.decode("""\
+apiVersion: argoproj.io/v1alpha1
+kind: Application
+metadata:
+  name: badapp01
+  namespace: default
+spec:
+  project: foo
+  source:
+    repoURL: https://github.com/argoproj/argocd-example-apps.git
+    targetRevision: HEAD
+    path: guestbook
+    # chart: foo
+  destination:
+    server: https://kubernetes.default.svc
+    namespace: guestbook
+    """))
+}

argo-application-prevent-default-project/kcl.mod

@@ -1,5 +1,4 @@
 [package]
 name = "argo-application-prevent-default-project"
-edition = "0.0.1"
-version = "0.0.1"
+version = "0.0.2"
 

argo-application-prevent-default-project/main_test.k

@@ -0,0 +1,20 @@
+import yaml
+
+test_validate = lambda {
+    validate(yaml.decode("""\
+apiVersion: argoproj.io/v1alpha1
+kind: Application
+metadata:
+  name: goodapp
+  namespace: default
+spec:
+  project: biz
+  source:
+    repoURL: https://github.com/argoproj/argocd-example-apps.git
+    targetRevision: HEAD
+    path: guestbook
+  destination:
+    server: https://kubernetes.default.svc
+    namespace: guestbook
+    """))
+}

result/README.md

@@ -0,0 +1,7 @@
+## Introduction
+
+`result` is a KCL error handling library
+
+## Resource
+
+The Code source and documents are [here](https://github.com/kcl-lang/modules/tree/main/result)

result/kcl.mod

@@ -0,0 +1,4 @@
+[package]
+name = "result"
+version = "0.0.1"
+description = "`result` is a KCL error handling library"

result/main.k

@@ -0,0 +1,14 @@
+schema Result:
+    result: bool
+    error?: str
+
+    is_ok: () -> bool = lambda {
+        result
+    }
+
+    is_error: () -> bool = lambda {
+        not result
+    }
+
+    check:
+        error, if not result, "error message should not be empty when the result is False"

scale-deployment-zero/README.md

@@ -0,0 +1,7 @@
+## Introduction
+
+`scale-deployment-zero` is a KCL mutation package
+
+## Resource
+
+The Code source and document are [here](https://github.com/kcl-lang/modules/tree/main/scale-deployment-zero)

scale-deployment-zero/kcl.mod

@@ -0,0 +1,5 @@
+[package]
+name = "scale-deployment-zero"
+edition = "*"
+version = "0.1.0"
+description = "`scale-deployment-zero` is a KCL mutation package"

scale-deployment-zero/main.k

@@ -0,0 +1,7 @@
+annotations: {str:str} = option("params")?.annotations or {}
+
+items = [item | {
+    if item.kind == "Deployment":
+        spec.replicas = 0
+        metadata.annotations: annotations # Scale to zero and offer a useful annotation information
+} for item in option("items")]

spread-pods-across-topology/README.md

@@ -0,0 +1,7 @@
+## Introduction
+
+`spread-pods-across-topology` is a KCL mutation package
+
+## Resource
+
+The Code source and document are [here](https://github.com/kcl-lang/modules/tree/main/spread-pods-across-topology)

spread-pods-across-topology/kcl.mod

@@ -0,0 +1,5 @@
+[package]
+name = "spread-pods-across-topology"
+edition = "*"
+version = "0.1.0"
+description = "`spread-pods-across-topology` is a KCL mutation package"

spread-pods-across-topology/main.k

@@ -0,0 +1,10 @@
+annotations: {str:str} = option("params")?.annotations or {}
+items = [item | {
+    if item.kind == "Deployment":
+        spec.template.spec: {topologySpreadConstraints += [{
+            maxSkew: 1
+            topologyKey: "zone"
+            whenUnsatisfiable: "DoNotSchedule"
+            labelSelector.matchLabels.distributed: "required"
+        }]}
+} for item in option("items")]

topology-spread-constraints/README.md

@@ -0,0 +1,5 @@
+## Introduction
+
+## Resource
+
+The Code source and documents are [here](https://github.com/kcl-lang/modules/tree/main/topology-spread-constraints)

topology-spread-constraints/kcl.mod

@@ -0,0 +1,5 @@
+[package]
+name = "topology-spread-constraints"
+version = "0.1.0"
+description = "`topology-spread-constraints` is a kcl validation package"
+

topology-spread-constraints/main.k

@@ -0,0 +1,17 @@
+KINDS = ["Deployment", "StatefulSet"]
+
+to_str_set = lambda items: [str] {
+    [item for item in {item = None for item in items}]
+}
+
+# Define the validation function
+validate = lambda item: {str:} {
+    if item.kind in KINDS and item.spec.replicas >= 3:
+        contraints = item.spec.template.spec.topologySpreadConstraints
+        valid_contraints = to_str_set([c.topologyKey for c in contraints if c?.topologyKey in ["kubernetes.io/hostname", "topology.kubernetes.io/zone"]])
+        assert len(valid_contraints) == 2, "topologySpreadConstraint for kubernetes.io/hostname & topology.kubernetes.io/zone are required, got ${valid_contraints}"
+    item
+}
+
+# Validate All resource
+items = [validate(i) for i in option("items") or []]

topology-spread-constraints/main_test.k

@@ -0,0 +1,59 @@
+import yaml
+
+test_validate = lambda {
+    good_manifest = """\
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: pass
+  namespace: monitoring
+  labels:
+    app: thanos-memcached
+spec:
+  selector:
+    matchLabels:
+      app: thanos-memcached
+  serviceName: memcached
+  replicas: 3
+  updateStrategy:
+    type: RollingUpdate
+  template:
+    metadata:
+      labels:
+        app: thanos-memcached
+    spec:
+      containers:
+        - name: memcached
+          image: memcached:1.6.17-alpine
+          command:
+            - memcached
+            - -m 2048
+            - -o
+            - modern
+            - -v
+          ports:
+            - name: tcp-memcached
+              containerPort: 11211
+      topologySpreadConstraints:
+        - maxSkew: 1
+          topologyKey: foo.bar/test
+          whenUnsatisfiable: ScheduleAnyway
+          labelSelector:
+            matchLabels:
+              app: thanos-memcached
+        - maxSkew: 1
+          topologyKey: kubernetes.io/hostname
+          whenUnsatisfiable: ScheduleAnyway
+          labelSelector:
+            matchLabels:
+              app: thanos-memcached
+        - maxSkew: 1
+          topologyKey: topology.kubernetes.io/zone
+          whenUnsatisfiable: ScheduleAnyway
+          labelSelector:
+            matchLabels:
+              app: thanos-memcached
+"""
+    item = yaml.decode(good_manifest)
+    validate(item)
+}

unique-ingress-host-and-path/README.md

@@ -0,0 +1,5 @@
+## Introduction
+
+## Resource
+
+The Code source and documents are [here](https://github.com/kcl-lang/modules/tree/main/unique-ingress-host-and-path)

unique-ingress-host-and-path/kcl.mod

@@ -0,0 +1,5 @@
+[package]
+name = "unique-ingress-host-and-path"
+version = "0.1.0"
+description = "`unique-ingress-host-and-path` is a kcl validation package"
+

unique-ingress-host-and-path/main.k

@@ -0,0 +1,30 @@
+KINDS = ["Ingress"]
+
+schema Result:
+    result: bool
+    error?: str
+
+    check:
+        error if not result, "error message should not be empty when the result is False"
+
+validate = lambda item: {str:} -> Result {
+    result = Result {result = True}
+
+    if item.kind in KINDS:
+        paths: [str] = [p.path for r in item.spec.rules for p in r.http.paths]
+        if not isunique(paths):
+            result = Result {
+                result = False
+                error = "Ingress paths must be unique, got ${paths}"
+            }
+    result
+
+}
+# Define the validation function
+must_validate = lambda item {
+    result = validate(item)
+    assert result.result, result.error
+    item
+}
+# Validate All resource
+items = [must_validate(i) for i in option("items") or []]

unique-ingress-host-and-path/main_test.k

@@ -0,0 +1,91 @@
+import yaml
+
+test_validate = lambda {
+    assert validate(yaml.decode("""\
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: goodingress01
+  namespace: unique-ingress-paths-ns
+spec:
+  rules:
+  - host: endpoint01
+    http:
+      paths:
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8080
+        path: /foo/abc/def
+        pathType: Prefix
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8081
+        path: /bar/def/bca
+        pathType: Prefix
+  - host: endpoint02
+    http:
+      paths:
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8080
+        path: /bar/abc/bca
+        pathType: Prefix
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8081
+        path: /foo/fed/def
+        pathType: Prefix
+""")).result == True
+    assert validate(yaml.decode("""\
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: goodingress01
+  namespace: unique-ingress-paths-ns
+spec:
+  rules:
+  - host: endpoint01
+    http:
+      paths:
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8080
+        path: /foo/abc/def
+        pathType: Prefix
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8081
+        path: /bar/def/bca
+        pathType: Prefix
+  - host: endpoint02
+    http:
+      paths:
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8080
+        path: /bar/abc/bca
+        pathType: Prefix
+      - backend:
+          service:
+            name: demo-svc
+            port:
+              number: 8081
+        path: /bar/abc/bca  # Error: dup paths: /bar/abc/bca
+        pathType: Prefix
+""")).result == False
+
+}