WIP: attempt of getting rid of the NormalizedDeferExecutionFactory

WIP WIP
andimarek · Jan 10, 2024 · Dec 5, 2023 · Dec 5, 2023 · Dec 12, 2023 · Dec 12, 2023
commit b9b0f5497c9efba421050e58ac65db2740009b1a
diff --git a/src/main/java/graphql/normalized/ENFMerger.java b/src/main/java/graphql/normalized/ENFMerger.java
@@ -1,11 +1,9 @@
 package graphql.normalized;
 
-import com.google.common.collect.Multimap;
 import graphql.Internal;
 import graphql.introspection.Introspection;
 import graphql.language.Argument;
 import graphql.language.AstComparator;
-import graphql.normalized.incremental.DeferDeclaration;
 import graphql.schema.GraphQLInterfaceType;
 import graphql.schema.GraphQLObjectType;
 import graphql.schema.GraphQLSchema;
@@ -25,7 +23,7 @@ public static void merge(
             ExecutableNormalizedField parent,
             List<ExecutableNormalizedField> childrenWithSameResultKey,
             GraphQLSchema schema,
-            Multimap<ExecutableNormalizedField, DeferDeclaration> normalizedFieldToDeferExecution
+            boolean deferSupport
     ) {
         // they have all the same result key
         // we can only merge the fields if they have the same field name + arguments + all children are the same
@@ -74,9 +72,20 @@ && isFieldInSharedInterface(field, fieldInGroup, schema)
                 while (iterator.hasNext()) {
                     ExecutableNormalizedField next = iterator.next();
                     // Move defer executions from removed field into the merged field's entry
-                    normalizedFieldToDeferExecution.putAll(first, normalizedFieldToDeferExecution.get(next));
+//                    normalizedFieldToDeferExecution.putAll(first, normalizedFieldToDeferExecution.get(next));
+                    if (deferSupport) {
+                        first.getDeferExecutions().forEach(deferDeclarationFirst -> {
+                            next.getDeferExecutions().forEach(deferDeclarationNext -> {
+                                if (Objects.equals(deferDeclarationFirst.getLabel(), deferDeclarationNext.getLabel())
+                                        && mergedObjects.containsAll(deferDeclarationNext.getObjectTypeNames())
+                                ) {
+                                    deferDeclarationFirst.addObjectTypes(deferDeclarationNext.getObjectTypes());
+                                }
+                            });
+                        });
+                    }
                     parent.getChildren().remove(next);
-                    normalizedFieldToDeferExecution.removeAll(next);
+//                    normalizedFieldToDeferExecution.removeAll(next);
                 }
                 first.setObjectTypeNames(mergedObjects);
             }

diff --git a/src/main/java/graphql/normalized/ExecutableNormalizedField.java b/src/main/java/graphql/normalized/ExecutableNormalizedField.java
@@ -11,6 +11,7 @@
 import graphql.collect.ImmutableKit;
 import graphql.introspection.Introspection;
 import graphql.language.Argument;
+import graphql.normalized.incremental.DeferDeclaration;
 import graphql.normalized.incremental.NormalizedDeferExecution;
 import graphql.schema.GraphQLFieldDefinition;
 import graphql.schema.GraphQLInterfaceType;
@@ -67,7 +68,7 @@ public class ExecutableNormalizedField {
     private final int level;
 
     // Mutable List on purpose: it is modified after creation
-    private final LinkedHashSet<NormalizedDeferExecution> deferExecutions;
+    private final LinkedHashSet<DeferDeclaration> deferExecutions;
 
     private ExecutableNormalizedField(Builder builder) {
         this.alias = builder.alias;
@@ -263,11 +264,16 @@ public void clearChildren() {
     }
 
     @Internal
-    public void setDeferExecutions(Collection<NormalizedDeferExecution> deferExecutions) {
+    public void setDeferExecutions(Collection<DeferDeclaration> deferExecutions) {
         this.deferExecutions.clear();
         this.deferExecutions.addAll(deferExecutions);
     }
 
+    @Internal
+    public void addDeferExecutions(Collection<DeferDeclaration> deferDeclarations) {
+        this.deferExecutions.addAll(deferDeclarations);
+    }
+
     /**
      * All merged fields have the same name so this is the name of the {@link ExecutableNormalizedField}.
      * <p>
@@ -475,7 +481,7 @@ public ExecutableNormalizedField getParent() {
 
     // TODO: Javadoc
     @ExperimentalApi
-    public LinkedHashSet<NormalizedDeferExecution> getDeferExecutions() {
+    public LinkedHashSet<DeferDeclaration> getDeferExecutions() {
         return deferExecutions;
     }
 
@@ -606,7 +612,7 @@ public static class Builder {
         private LinkedHashMap<String, Object> resolvedArguments = new LinkedHashMap<>();
         private ImmutableList<Argument> astArguments = ImmutableKit.emptyList();
 
-        private LinkedHashSet<NormalizedDeferExecution> deferExecutions = new LinkedHashSet<>();
+        private LinkedHashSet<DeferDeclaration> deferExecutions = new LinkedHashSet<>();
 
         private Builder() {
         }
@@ -677,7 +683,7 @@ public Builder parent(ExecutableNormalizedField parent) {
             return this;
         }
 
-        public Builder deferExecutions(LinkedHashSet<NormalizedDeferExecution> deferExecutions) {
+        public Builder deferExecutions(LinkedHashSet<DeferDeclaration> deferExecutions) {
             this.deferExecutions = deferExecutions;
             return this;
         }