-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
4 changed files
with
106 additions
and
102 deletions.
There are no files selected for viewing
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,105 @@ | ||
| package composite | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
|
|
||
| "github.com/crossplane/crossplane-runtime/pkg/errors" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" | ||
| ) | ||
|
|
||
| // ToUnstructured is a helper function that creates an unstructured object from any object | ||
| // that contains metadata, spec and optionally status. | ||
| func ToUnstructured(apiVersion, kind, object any) (objectSpec *unstructured.Unstructured, err error) { | ||
| objectSpec = &unstructured.Unstructured{} | ||
| type objS struct { | ||
| Metadata map[string]interface{} | ||
| Spec map[string]interface{} | ||
| Status map[string]interface{} | ||
| } | ||
| var o objS | ||
| if err = To(object, &o); err != nil { | ||
| return | ||
| } | ||
|
|
||
| if len(o.Metadata) == 0 { | ||
| err = &InvalidMetadata{} | ||
| return | ||
| } | ||
|
|
||
| if len(o.Spec) == 0 { | ||
| err = &InvalidSpec{} | ||
| return | ||
| } | ||
|
|
||
| objectSpec.Object = map[string]interface{}{ | ||
| "apiVersion": apiVersion, | ||
| "kind": kind, | ||
| "metadata": o.Metadata, | ||
| "spec": o.Spec, | ||
| } | ||
| if len(o.Status) > 0 { | ||
| objectSpec.Object["status"] = o.Status | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // ToUnstructuredKubernetesObject is a helper function that wraps a given CR resource in | ||
| // a `crossplane-contrib/provider-kubernetes.Object` structure and returns this as an unstructured.Unstructured object | ||
| func ToUnstructuredKubernetesObject(mp any, providerConfigRef string) (objectSpec *unstructured.Unstructured, err error) { | ||
| objectSpec = &unstructured.Unstructured{} | ||
| var unstructuredData map[string]interface{} | ||
| if err = To(mp, &unstructuredData); err != nil { | ||
| return | ||
| } | ||
|
|
||
| if _, ok := unstructuredData["metadata"]; !ok { | ||
| err = errors.Wrap(&MissingMetadata{}, "unable to create kubernetes object. object missing metadata") | ||
| return | ||
| } | ||
|
|
||
| var meta metav1.ObjectMeta | ||
| if err = To(unstructuredData["metadata"], &meta); err != nil { | ||
| err = errors.Wrap(err, fmt.Sprintf("unable to create kubernetes object : %+v", unstructuredData["metadata"])) | ||
| return | ||
| } | ||
|
|
||
| var labels map[string]interface{} = make(map[string]interface{}) | ||
| for k, v := range meta.Labels { | ||
| labels[k] = v | ||
| } | ||
|
|
||
| objectSpec.Object = map[string]interface{}{ | ||
| "apiVersion": "kubernetes.crossplane.io/v1alpha1", | ||
| "kind": "Object", | ||
| "metadata": map[string]interface{}{ | ||
| "name": meta.Name, | ||
| "labels": labels, | ||
| }, | ||
| "spec": map[string]interface{}{ | ||
| "forProvider": map[string]interface{}{ | ||
| "manifest": unstructuredData, | ||
| }, | ||
| "writeConnectionSecretToRef": map[string]interface{}{ | ||
| "name": meta.Name, | ||
| "namespace": meta.Namespace, | ||
| }, | ||
| "providerConfigRef": map[string]interface{}{ | ||
| "name": providerConfigRef, | ||
| }, | ||
| }, | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // To is a helper function that converts any object to any object by sending it round-robin through `json.Marshal` | ||
| func To(resource any, jsonObject any) (err error) { | ||
| var b []byte | ||
| if b, err = json.Marshal(resource); err != nil { | ||
| return | ||
| } | ||
|
|
||
| err = json.Unmarshal(b, jsonObject) | ||
| return | ||
| } |
This file was deleted.
Oops, something went wrong.