feat: implemented dryrun method

Author: kekcleader

gateway/resolver/arguments.go

@@ -2,10 +2,11 @@ package resolver
 
 import (
 	"errors"
-	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"maps"
 	"strings"
 
+	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+
 	"github.com/graphql-go/graphql"
 	"github.com/rs/zerolog/log"
 	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
@@ -18,6 +19,7 @@ const (
 	ObjectArg         = "object"
 	SubscribeToAllArg = "subscribeToAll"
 	SortByArg         = "sortBy"
+	DryRunArg         = "dryRun"
 )
 
 // FieldConfigArgumentsBuilder helps construct GraphQL field config arguments
@@ -65,6 +67,14 @@ func (b *FieldConfigArgumentsBuilder) WithObject(resourceInputType *graphql.Inpu
 	return b
 }
 
+func (b *FieldConfigArgumentsBuilder) WithDryRun() *FieldConfigArgumentsBuilder {
+	b.arguments[DryRunArg] = &graphql.ArgumentConfig{
+		Type:        graphql.NewList(graphql.String),
+		Description: "If true, the object will not be persisted",
+	}
+	return b
+}
+
 func (b *FieldConfigArgumentsBuilder) WithSubscribeToAll() *FieldConfigArgumentsBuilder {
 	b.arguments[SubscribeToAllArg] = &graphql.ArgumentConfig{
 		Type:         graphql.Boolean,
@@ -160,3 +170,36 @@ func validateSortBy(items []unstructured.Unstructured, fieldPath string) error {
 
 	return nil
 }
+
+func getDryRunArg(args map[string]interface{}, key string, required bool) ([]string, error) {
+	val, exists := args[key]
+	if !exists {
+		if required {
+			err := errors.New("missing required argument: " + key)
+			log.Error().Err(err).Msg(key + " argument is required")
+			return nil, err
+		}
+		return nil, nil
+	}
+
+	switch v := val.(type) {
+	case []interface{}:
+		result := make([]string, len(v))
+		for i, item := range v {
+			str, ok := item.(string)
+			if !ok {
+				err := errors.New("invalid type in dryRun list: expected string")
+				log.Error().Err(err).Msg("dryRun argument must be a list of strings")
+				return nil, err
+			}
+			result[i] = str
+		}
+		return result, nil
+	case nil:
+		return nil, nil
+	default:
+		err := errors.New("invalid type for dryRun argument: expected list of strings")
+		log.Error().Err(err).Msg("dryRun argument must be a list of strings")
+		return nil, err
+	}
+}

gateway/resolver/resolver.go

@@ -5,12 +5,13 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"gopkg.in/yaml.v3"
-	v1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	"regexp"
 	"sort"
 	"strings"
 
+	"gopkg.in/yaml.v3"
+	v1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
+
 	"github.com/graphql-go/graphql"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
@@ -236,7 +237,12 @@ func (r *Service) CreateItem(gvk schema.GroupVersionKind, scope v1.ResourceScope
 			return nil, errors.New("object metadata.name is required")
 		}
 
-		if err := r.runtimeClient.Create(ctx, obj); err != nil {
+		dryRun, err := getDryRunArg(p.Args, DryRunArg, false)
+		if err != nil {
+			return nil, err
+		}
+
+		if err := r.runtimeClient.Create(ctx, obj, &client.CreateOptions{DryRun: dryRun}); err != nil {
 			log.Error().Err(err).Msg("Failed to create object")
 			return nil, err
 		}

gateway/schema/schema.go

@@ -201,7 +201,7 @@ func (g *Gateway) processSingleResource(
 
 	itemArgsBuilder := resolver.NewFieldConfigArguments().WithName()
 
-	creationMutationArgsBuilder := resolver.NewFieldConfigArguments().WithObject(resourceInputType)
+	creationMutationArgsBuilder := resolver.NewFieldConfigArguments().WithObject(resourceInputType).WithDryRun()
 
 	if resourceScope == apiextensionsv1.NamespaceScoped {
 		listArgsBuilder.WithNamespace()