Add @upsert directive and nested mutation operations to create or update a model regardless whether it exists

src/Schema/Directives/CreateDirective.php

@@ -5,36 +5,14 @@
 use Illuminate\Support\Collection;
 use Illuminate\Database\Eloquent\Model;
 use Nuwave\Lighthouse\Execution\MutationExecutor;
-use Illuminate\Database\Eloquent\Relations\Relation;
 
 class CreateDirective extends MutationExecutorDirective
 {
-    /**
-     * Name of the directive.
-     *
-     * @return string
-     */
     public function name(): string
     {
         return 'create';
     }
 
-    /**
-     * Execute a create mutation.
-     *
-     * @param  \Illuminate\Database\Eloquent\Model  $model
-     *         An empty instance of the model that should be created
-     * @param  \Illuminate\Support\Collection  $args
-     *         The corresponding slice of the input arguments for creating this model
-     * @param  \Illuminate\Database\Eloquent\Relations\Relation|null  $parentRelation
-     *         If we are in a nested create, we can use this to associate the new model to its parent
-     * @return \Illuminate\Database\Eloquent\Model
-     */
-    protected function executeMutation(Model $model, Collection $args, ?Relation $parentRelation = null): Model
-    {
-        return MutationExecutor::executeCreate($model, $args, $parentRelation);
-    }
-
     public static function definition(): string
     {
         return /* @lang GraphQL */ <<<'SDL'
@@ -50,4 +28,9 @@ public static function definition(): string
 ) on FIELD_DEFINITION
 SDL;
     }
+
+    protected function executeMutation(Model $model, Collection $args): Model
+    {
+        return MutationExecutor::executeCreate($model, $args);
+    }
 }

src/Schema/Directives/MutationExecutorDirective.php

@@ -8,14 +8,15 @@
 use Illuminate\Database\DatabaseManager;
 use Nuwave\Lighthouse\Schema\Values\FieldValue;
 use Nuwave\Lighthouse\Support\Contracts\GlobalId;
-use Illuminate\Database\Eloquent\Relations\Relation;
 use Nuwave\Lighthouse\Support\Contracts\FieldResolver;
 use Nuwave\Lighthouse\Support\Contracts\GraphQLContext;
 use Nuwave\Lighthouse\Support\Contracts\DefinedDirective;
 
 abstract class MutationExecutorDirective extends BaseDirective implements FieldResolver, DefinedDirective
 {
     /**
+     * The database manager.
+     *
      * @var \Illuminate\Database\DatabaseManager
      */
     protected $databaseManager;
@@ -50,20 +51,38 @@ public function resolveField(FieldValue $fieldValue): FieldValue
     {
         return $fieldValue->setResolver(
             function ($root, array $args, GraphQLContext $context, ResolveInfo $resolveInfo): Model {
-                $modelClass = $this->getModelClass();
                 /** @var \Illuminate\Database\Eloquent\Model $model */
-                $model = new $modelClass;
+                $model = new ($this->getModelClass());
 
                 $executeMutation = function () use ($model, $args): Model {
-                    return $this->executeMutation($model, new Collection($args))->refresh();
+                    return $this
+                        ->executeMutation(
+                            $model,
+                            new Collection($args)
+                        )
+                        ->refresh();
                 };
 
                 return config('lighthouse.transactional_mutations', true)
-                    ? $this->databaseManager->connection($model->getConnectionName())->transaction($executeMutation)
+                    ? $this
+                        ->databaseManager
+                        ->connection(
+                            $model->getConnectionName()
+                        )
+                        ->transaction($executeMutation)
                     : $executeMutation();
             }
         );
     }
 
-    abstract protected function executeMutation(Model $model, Collection $args, ?Relation $parentRelation = null): Model;
+    /**
+     * Execute a mutation on a model.
+     *
+     * @param  \Illuminate\Database\Eloquent\Model  $model
+     *         An empty instance of the model that should be mutated.
+     * @param  \Illuminate\Support\Collection  $args
+     *         The corresponding slice of the input arguments for mutating this model.
+     * @return \Illuminate\Database\Eloquent\Model
+     */
+    abstract protected function executeMutation(Model $model, Collection $args): Model;
 }

src/Schema/Directives/UpdateDirective.php

@@ -5,36 +5,14 @@
 use Illuminate\Support\Collection;
 use Illuminate\Database\Eloquent\Model;
 use Nuwave\Lighthouse\Execution\MutationExecutor;
-use Illuminate\Database\Eloquent\Relations\Relation;
 
 class UpdateDirective extends MutationExecutorDirective
 {
-    /**
-     * Name of the directive.
-     *
-     * @return string
-     */
     public function name(): string
     {
         return 'update';
     }
 
-    /**
-     * Execute an update mutation.
-     *
-     * @param  \Illuminate\Database\Eloquent\Model $modelInstance
-     *         An empty instance of the model that should be updated
-     * @param  \Illuminate\Support\Collection  $args
-     *         The corresponding slice of the input arguments for updating this model
-     * @param  \Illuminate\Database\Eloquent\Relations\Relation|null  $parentRelation
-     *         If we are in a nested update, we can use this to associate the new model to its parent
-     * @return \Illuminate\Database\Eloquent\Model
-     */
-    protected function executeMutation(Model $model, Collection $args, ?Relation $parentRelation = null): Model
-    {
-        return MutationExecutor::executeUpdate($model, new Collection($args))->refresh();
-    }
-
     public static function definition(): string
     {
         return /* @lang GraphQL */ <<<'SDL'
@@ -56,4 +34,9 @@ public static function definition(): string
 ) on FIELD_DEFINITION
 SDL;
     }
+
+    protected function executeMutation(Model $model, Collection $args): Model
+    {
+        return MutationExecutor::executeUpdate($model, $args);
+    }
 }

src/Schema/Directives/UpsertDirective.php

@@ -5,37 +5,14 @@
 use Illuminate\Support\Collection;
 use Illuminate\Database\Eloquent\Model;
 use Nuwave\Lighthouse\Execution\MutationExecutor;
-use Illuminate\Database\Eloquent\Relations\Relation;
 
 class UpsertDirective extends MutationExecutorDirective
 {
-    /**
-     * Name of the directive.
-     *
-     * @return string
-     */
     public function name(): string
     {
         return 'upsert';
     }
 
-    /**
-     * Execute an upsert mutation.
-     *
-     * @param \Illuminate\Database\Eloquent\Model $model
-     *         An empty instance of the model that should be created or updated
-     * @param \Illuminate\Support\Collection $args
-     *         The corresponding slice of the input arguments for creating or updating this model
-     * @param \Illuminate\Database\Eloquent\Relations\Relation|null $parentRelation
-     *         If we are in a nested upsert, we can use this to associate the new model to its parent
-     *
-     * @return \Illuminate\Database\Eloquent\Model
-     */
-    protected function executeMutation(Model $model, Collection $args, ?Relation $parentRelation = null): Model
-    {
-        return MutationExecutor::executeUpsert($model, new Collection($args))->refresh();
-    }
-
     public static function definition(): string
     {
         return /* @lang GraphQL */ <<<'SDL'
@@ -57,4 +34,9 @@ public static function definition(): string
 ) on FIELD_DEFINITION
 SDL;
     }
+
+    protected function executeMutation(Model $model, Collection $args): Model
+    {
+        return MutationExecutor::executeUpsert($model, $args);
+    }
 }