Feat: add new providers

.github/workflows/unit-test.yaml

@@ -66,7 +66,7 @@ jobs:
         with:
           version: 3.1.0
           kubebuilderOnly: false
-          kubernetesVersion: v1.21.2
+          kubernetesVersion: v1.28.0
 
       - name: Run Make test
         run: make test

charts/vela-workflow/crds/cue.oam.dev_packages.yaml

@@ -0,0 +1,81 @@
+---
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  annotations:
+    controller-gen.kubebuilder.io/version: v0.11.3
+  creationTimestamp: null
+  name: packages.cue.oam.dev
+spec:
+  group: cue.oam.dev
+  names:
+    kind: Package
+    listKind: PackageList
+    plural: packages
+    shortNames:
+    - pkg
+    - cpkg
+    - cuepkg
+    - cuepackage
+    singular: package
+  scope: Namespaced
+  versions:
+  - additionalPrinterColumns:
+    - jsonPath: .spec.path
+      name: PATH
+      type: string
+    - jsonPath: .spec.provider.protocol
+      name: PROTO
+      type: string
+    - jsonPath: .spec.provider.endpoint
+      name: ENDPOINT
+      type: string
+    name: v1alpha1
+    schema:
+      openAPIV3Schema:
+        description: Package is an extension for cuex engine
+        properties:
+          apiVersion:
+            description: 'APIVersion defines the versioned schema of this representation
+              of an object. Servers should convert recognized schemas to the latest
+              internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources'
+            type: string
+          kind:
+            description: 'Kind is a string value representing the REST resource this
+              object represents. Servers may infer this from the endpoint the client
+              submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+            type: string
+          metadata:
+            type: object
+          spec:
+            description: PackageSpec the spec for Package
+            properties:
+              path:
+                type: string
+              provider:
+                description: Provider the external Provider in Package for cuex to
+                  run functions
+                properties:
+                  endpoint:
+                    type: string
+                  protocol:
+                    description: ProviderProtocol the protocol type for external Provider
+                    type: string
+                required:
+                - endpoint
+                - protocol
+                type: object
+              templates:
+                additionalProperties:
+                  type: string
+                type: object
+            required:
+            - path
+            - templates
+            type: object
+        required:
+        - spec
+        type: object
+    served: true
+    storage: true
+    subresources: {}

controllers/suite_test.go

@@ -21,11 +21,13 @@ import (
 	"testing"
 
 	"github.com/crossplane/crossplane-runtime/pkg/event"
+	cuexv1alpha1 "github.com/kubevela/pkg/apis/cue/v1alpha1"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 	"github.com/pkg/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/client-go/dynamic/fake"
 	"k8s.io/client-go/kubernetes/scheme"
 	"k8s.io/client-go/rest"
 	"sigs.k8s.io/controller-runtime/pkg/client"
@@ -72,13 +74,17 @@ var _ = BeforeSuite(func() {
 	testScheme = scheme.Scheme
 	err = v1alpha1.AddToScheme(testScheme)
 	Expect(err).NotTo(HaveOccurred())
+	err = cuexv1alpha1.AddToScheme(testScheme)
+	Expect(err).NotTo(HaveOccurred())
 
 	//+kubebuilder:scaffold:scheme
 
 	k8sClient, err = client.New(cfg, client.Options{Scheme: testScheme})
 	Expect(err).NotTo(HaveOccurred())
 	Expect(k8sClient).NotTo(BeNil())
 	singleton.KubeClient.Set(k8sClient)
+	fakeDynamicClient := fake.NewSimpleDynamicClient(testScheme)
+	singleton.DynamicClient.Set(fakeDynamicClient)
 
 	reconciler = &WorkflowRunReconciler{
 		Client:   k8sClient,

controllers/testdata/apply-object.yaml

@@ -8,16 +8,18 @@ spec:
     cue:
       template: |
         import (
-                "vela/op"
+        	"vela/kube"
         )
 
-        apply: op.#Apply & {
-                value:   parameter.value
-                cluster: parameter.cluster
+        apply: kube.#Apply & {
+        	$params: {
+        		value:   parameter.value
+        		cluster: parameter.cluster
+        	}
         }
         parameter: {
-                // +usage=Specify the value of the object
-                value: {...}
-                // +usage=Specify the cluster of the object
-                cluster: *"" | string
-        }
+        	// +usage=Specify Kubernetes native resource object to be applied
+        	value: {...}
+        	// +usage=The cluster you want to apply the resource to, default is the current control plane cluster
+        	cluster: *"" | string
+        }

controllers/testdata/suspend-and-deploy.yaml

@@ -9,43 +9,44 @@ spec:
     cue:
       template: |
         import (
-        	"strconv"
-        	"strings"
+        	"vela/kube"
         	"vela/op"
         )
+
         suspend: op.#Suspend & {duration: "1s"}
-        output: op.#Apply & {
-        	cluster: parameter.cluster
-        	value: {
-        		apiVersion: "apps/v1"
-        		kind:       "Deployment"
-        		metadata: {
-        			name:      context.stepName
-        			namespace: context.namespace
-        		}
-        		spec: {
-        			selector: matchLabels: "workflow.oam.dev/step-name": "\(context.name)-\(context.stepName)"
-        			replicas: parameter.replicas
-        			template: {
-        				metadata: labels: "workflow.oam.dev/step-name": "\(context.name)-\(context.stepName)"
-        				spec: containers: [{
-        					name:  context.stepName
-        					image: parameter.image
-        					if parameter["cmd"] != _|_ {
-        						command: parameter.cmd
-        					}
-        				}]
+        output: kube.#Apply & {
+        	$params: {
+        		cluster: parameter.cluster
+        		value: {
+        			apiVersion: "apps/v1"
+        			kind:       "Deployment"
+        			metadata: {
+        				name:      context.stepName
+        				namespace: context.namespace
+        			}
+        			spec: {
+        				selector: matchLabels: "workflow.oam.dev/step-name": "\(context.name)-\(context.stepName)"
+        				replicas: parameter.replicas
+        				template: {
+        					metadata: labels: "workflow.oam.dev/step-name": "\(context.name)-\(context.stepName)"
+        					spec: containers: [{
+        						name:  context.stepName
+        						image: parameter.image
+        						if parameter["cmd"] != _|_ {
+        							command: parameter.cmd
+        						}
+        					}]
+        				}
         			}
         		}
         	}
         }
         wait: op.#ConditionalWait & {
-        	continue: output.value.status.readyReplicas == parameter.replicas
+        	continue: output.$returns.value.status.readyReplicas == parameter.replicas
         }
         parameter: {
         	image:    string
         	replicas: *1 | int
         	cluster:  *"" | string
         	cmd?: [...string]
         }
-

controllers/testdata/test-apply.yaml

@@ -7,45 +7,48 @@ spec:
   schematic:
     cue:
       template: |
-        import ( "vela/op"
+        import (
+        	"vela/kube"
+        	"vela/op"
         )
 
-        output: op.#Apply & {
-                value: {
-                        apiVersion: "apps/v1"
-                        kind:       "Deployment"
-                        metadata: {
-                                name:      context.stepName
-                                namespace: context.namespace
-                        }
-                        spec: {
-                                selector: matchLabels: wr: context.stepName
-                                template: {
-                                        metadata: labels: wr: context.stepName
-                                        spec: containers: [{
-                                                name:  context.stepName
-                                                image: parameter.image
-                                                if parameter["cmd"] != _|_ {
-                                                        command: parameter.cmd
-                                                }
-                                                if parameter["message"] != _|_ {
-                                                        env: [{
-                                                                name:  "MESSAGE"
-                                                                value: parameter.message
-                                                        }]
-                                                }
-                                        }]
-                                }
-                        }
-                }
+        output: kube.#Apply & {
+        	$params: value: {
+        		apiVersion: "apps/v1"
+        		kind:       "Deployment"
+        		metadata: {
+        			name:      context.stepName
+        			namespace: context.namespace
+        		}
+        		spec: {
+        			selector: matchLabels: wr: context.stepName
+        			template: {
+        				metadata: labels: wr: context.stepName
+        				spec: containers: [{
+        					name:  context.stepName
+        					image: parameter.image
+        					if parameter["cmd"] != _|_ {
+        						command: parameter.cmd
+        					}
+        					if parameter["message"] != _|_ {
+        						env: [{
+        							name:  "MESSAGE"
+        							value: parameter.message
+        						}]
+        					}
+        				}]
+        			}
+        		}
+        	}
         }
         wait: op.#ConditionalWait & {
-                if len(output.value.status) > 0 if output.value.status.readyReplicas == 1 {
-                        continue: true
-                }
+        	if len(output.$returns.value.status) > 0 if output.$returns.value.status.readyReplicas == 1 {
+        		continue: true
+        	}
         }
         parameter: {
-                image: string
-                cmd?: [...string]
-                message?: string
-        }
+        	image: string
+        	cmd?: [...string]
+        	message?: string
+        }
+

controllers/workflow_test.go

@@ -336,7 +336,7 @@ var _ = Describe("Test Workflow", func() {
 					Outputs: v1alpha1.StepOutputs{
 						{
 							Name:      "message",
-							ValueFrom: `"message: " +output.value.status.conditions[0].message`,
+							ValueFrom: `"message: " +output.$returns.value.status.conditions[0].message`,
 						},
 					},
 				},
@@ -416,7 +416,7 @@ var _ = Describe("Test Workflow", func() {
 					Outputs: v1alpha1.StepOutputs{
 						{
 							Name:      "message",
-							ValueFrom: `"message: " +output.value.status.conditions[0].message`,
+							ValueFrom: `"message: " +output.$returns.value.status.conditions[0].message`,
 						},
 					},
 				},

makefiles/const.mk

@@ -4,7 +4,7 @@ IMG_TAG ?= latest
 OS      ?= linux
 ARCH    ?= amd64
 # ENVTEST_K8S_VERSION refers to the version of kubebuilder assets to be downloaded by envtest binary.
-ENVTEST_K8S_VERSION = 1.24.1
+ENVTEST_K8S_VERSION = 1.28.0
 
 # Get the currently used golang install path (in GOPATH/bin, unless GOBIN is set)
 ifeq (,$(shell go env GOBIN))

pkg/cue/model/value/value_test.go

@@ -109,45 +109,6 @@ func TestFieldPath(t *testing.T) {
 	}
 }
 
-// func TestValueFix(t *testing.T) {
-// 	testCases := []struct {
-// 		original string
-// 		expected string
-// 	}{
-// 		{
-// 			original: `
-// parameter: test: _
-// // comment
-// y: {
-// 	for k, v in parameter.test.p {
-// 		"\(k)": v
-// 	}
-// }`,
-// 			expected: `{
-// 	parameter: {
-// 		test: _
-// 	}
-// 	// comment
-// 	y: {
-// 		for k, v in *parameter.test.p | {} {
-// 			"\(k)": v
-// 		}
-// 	}
-// }`,
-// 		},
-// 	}
-// 	for i, tc := range testCases {
-// 		t.Run(fmt.Sprint(i), func(t *testing.T) {
-// 			r := require.New(t)
-// 			v, err := NewValue(tc.original, nil, "")
-// 			r.NoError(err)
-// 			b, err := format.Node(v.CueValue().Syntax(cue.Docs(true)))
-// 			r.NoError(err)
-// 			r.Equal(tc.expected, string(b))
-// 		})
-// 	}
-// }
-
 func TestSetByScript(t *testing.T) {
 	testCases := []struct {
 		name     string