Basic create support

Author: dunglas

src/Bridge/Graphql/Resolver/ItemMutationResolverFactory.php

@@ -48,39 +48,18 @@ public function __construct(IdentifiersExtractorInterface $identifiersExtractor,
     public function createItemMutationResolver(string $resourceClass, string $mutationName): callable
     {
         return function ($root, $args, $context, ResolveInfo $info) use ($resourceClass, $mutationName) {
-            $identifiers = $this->identifiersExtractor->getIdentifiersFromResourceClass($resourceClass);
-            if (\count($identifiers) > 1) {
-                $identifierPairs = \array_map(function ($identifier) use ($args, $info) {
-                    if (\is_array($args['input'][$identifier])) {
-                        if (\count($args['input'][$identifier]) > 1) {
-                            throw Error::createLocatedError('Composite identifiers are not allowed for a resource already used as a composite identifier', $info->fieldNodes, $info->path);
-                        }
-
-                        return $identifier.'='.\reset($args['input'][$identifier]);
-                    }
-
-                    return "{$identifier}={$args['input'][$identifier]}";
-                }, $identifiers);
-                $id = \implode(';', $identifierPairs);
-            } else {
-                $id = $args['input'][$identifiers[0]];
-            }
+            $id = $this->getIdentifier($this->identifiersExtractor->getIdentifiersFromResourceClass($resourceClass), $args, $info);
+            $item = null;
 
             if ('update' === $mutationName || 'delete' === $mutationName) {
-                $item = $this->itemDataProvider->getItem($resourceClass, $id);
-                if (null === $item) {
-                    throw Error::createLocatedError("Item $resourceClass $id not found", $info->fieldNodes, $info->path);
-                }
+                $item = $this->getItem($resourceClass, $id, $info);
             }
 
             switch ($mutationName) {
-                case 'delete':
-                    $this->dataPersister->remove($item);
-
-                    return $args['input'];
-
+                case 'create':
                 case 'update':
-                    $item = $this->serializer->denormalize($args['input'], $resourceClass, null, ['resource_class' => $resourceClass, 'object_to_populate' => $item]);
+                    $context = null === $item ? ['resource_class' => $resourceClass] : ['resource_class' => $resourceClass, 'object_to_populate' => $item];
+                    $item = $this->serializer->denormalize($args['input'], $resourceClass, null, $context);
                     $this->dataPersister->persist($item);
 
                     return $this->serializer->normalize(
@@ -90,7 +69,46 @@ public function createItemMutationResolver(string $resourceClass, string $mutati
                             ->create($resourceClass)
                             ->getGraphqlAttribute($mutationName, 'normalization_context', [], true)
                     );
+
+                case 'delete':
+                    $this->dataPersister->remove($item);
+
+                    return $args['input'];
             }
         };
     }
+
+    private function getIdentifier(array $identifiers, $args, $info)
+    {
+        if (\count($identifiers) === 1) {
+            return $args['input'][$identifiers[0]];
+        }
+
+        $identifierPairs = [];
+        foreach ($identifiers as $key => $identifier) {
+            if (!\is_array($args['input'][$identifier])) {
+                $identifierPairs[$key] = "{$identifier}={$args['input'][$identifier]}";
+
+                continue;
+            }
+
+            if (\count($args['input'][$identifier]) > 1) {
+                throw Error::createLocatedError('Composite identifiers are not allowed for a resource already used as a composite identifier', $info->fieldNodes, $info->path);
+            }
+
+            $identifierPairs[$key] = "$identifier=".reset($args['input'][$identifier]);
+        }
+
+        return implode(';', $identifierPairs);
+    }
+
+    private function getItem(string $resourceClass, $id, $info)
+    {
+        $item = $this->itemDataProvider->getItem($resourceClass, $id);
+        if (null === $item) {
+            throw Error::createLocatedError("Item $resourceClass $id not found", $info->fieldNodes, $info->path);
+        }
+
+        return $item;
+    }
 }