feat: update operation should create resource if it doesn't exist

Signed-off-by: Daniel Helfand <helfand.4@gmail.com>

pkg/kube/unstructured/unstructured.go

@@ -86,7 +86,18 @@ func ResourceOperationInNamespace(dynamicClient dynamic.Interface, resource unst
 	case common.OperationUpdate:
 		currentResourceVersion, err := dynamicClient.Resource(gvr.Resource).Namespace(namespace).Get(context.Background(), unstruct.GetName(), metav1.GetOptions{})
 		if err != nil {
-			return err
+			if kerrors.IsNotFound(err) {
+				_, err = dynamicClient.Resource(gvr.Resource).Namespace(namespace).Create(context.Background(), unstruct, metav1.CreateOptions{})
+				if err != nil {
+					return err
+				}
+
+				log.Infof("%s %s has been created in namespace %s", unstruct.GetKind(), unstruct.GetName(), namespace)
+
+				return nil
+			} else {
+				return err
+			}
 		}
 
 		unstruct.SetResourceVersion(currentResourceVersion.DeepCopy().GetResourceVersion())

pkg/kube/unstructured/unstructured_test.go

@@ -372,6 +372,25 @@ func TestResourceOperationInNamespace(t *testing.T) {
 	}
 }
 
+func TestResourceOperationInNamespaceCreatesResourceWithUpdateOperation(t *testing.T) {
+	dynScheme := runtime.NewScheme()
+	fakeDynamicClient := fakeDynamic.NewSimpleDynamicClient(dynScheme)
+
+	deploymentFromYaml, err := resourceFromYaml("../../test/templates/resource-without-namespace.yaml")
+	if err != nil {
+		t.Errorf(err.Error())
+	}
+
+	deploymentUnstructured := unstructuredResource{
+		GVR:      &meta.RESTMapping{},
+		Resource: deploymentFromYaml,
+	}
+
+	if err := ResourceOperationInNamespace(fakeDynamicClient, deploymentUnstructured, "update", "test-namespace"); err != nil {
+		t.Errorf("ResourceOperationInNamespace() error = %v", err)
+	}
+}
+
 func resourcePath(resourceFileName string) string {
 	return filepath.Join("../../../test/templates", resourceFileName)
 }