NestedOneToMany.php

<?php

namespace Nuwave\Lighthouse\Execution\Arguments;

use Closure;
use Illuminate\Database\Eloquent\Relations\HasOneOrMany;
use Illuminate\Database\Eloquent\Relations\Relation;
use Nuwave\Lighthouse\Support\Contracts\ArgResolver;

class NestedOneToMany implements ArgResolver
{
    /**
     * @var string
     */
    protected $relationName;

    public function __construct(string $relationName)
    {
        $this->relationName = $relationName;
    }

    /**
     * @param  \Illuminate\Database\Eloquent\Model  $parent
     * @param  \Nuwave\Lighthouse\Execution\Arguments\ArgumentSet  $args
     */
    public function __invoke($parent, $args): void
    {
        /** @var \Illuminate\Database\Eloquent\Relations\HasMany|\Illuminate\Database\Eloquent\Relations\MorphMany $relation */
        $relation = $parent->{$this->relationName}();

        static::createUpdateUpsert($args, $relation);
        static::connectDisconnect($args, $relation);

        if ($args->has('delete')) {
            $relation->getRelated()::destroy(
                $args->arguments['delete']->toPlain()
            );
        }
    }

    public static function createUpdateUpsert(ArgumentSet $args, Relation $relation): void
    {
        if ($args->has('create')) {
            $saveModel = new ResolveNested(new SaveModel($relation));

            foreach ($args->arguments['create']->value as $childArgs) {
                // @phpstan-ignore-next-line Relation&Builder mixin not recognized
                $saveModel($relation->make(), $childArgs);
            }
        }

        if ($args->has('update')) {
            $updateModel = new ResolveNested(new SaveModel($relation));

            // @phpstan-ignore-next-line Relation&Builder mixin not recognized
            $model = $relation->make();

            $ids = [];

            $updateArgs = $args->arguments['update']->value;

            foreach ($updateArgs as $childArgs) {
                $ids[UpdateModel::getId($childArgs, $model)] = true;
            }

            $models = $model->newModelQuery()
                ->whereIn($model->getKeyName(), array_keys($ids))
                ->get();

            foreach ($models as $instance) {
                $id = $instance->getKey();
                $ids[$id] = $instance;
            }

            foreach ($updateArgs as $childArgs) {
                $instance = $ids[UpdateModel::pullId($childArgs, $model)];
                $updateModel($instance, $childArgs);
            }
        }

        if ($args->has('upsert')) {
            $upsertModel = new ResolveNested(new UpsertModel(new SaveModel($relation)));

            foreach ($args->arguments['upsert']->value as $childArgs) {
                // @phpstan-ignore-next-line Relation&Builder mixin not recognized
                $upsertModel($relation->make(), $childArgs);
            }
        }
    }

    public static function connectDisconnect(ArgumentSet $args, HasOneOrMany $relation): void
    {
        if ($args->has('connect')) {
            // @phpstan-ignore-next-line Relation&Builder mixin not recognized
            $children = $relation
                ->make()
                ->whereIn(
                    self::getLocalKeyName($relation),
                    $args->arguments['connect']->value
                )
                ->get();

            // @phpstan-ignore-next-line Relation&Builder mixin not recognized
            $relation->saveMany($children);
        }

        if ($args->has('disconnect')) {
            // @phpstan-ignore-next-line Relation&Builder mixin not recognized
            $children = $relation
                ->make()
                ->whereIn(
                    self::getLocalKeyName($relation),
                    $args->arguments['disconnect']->value
                )
                ->get();

            /** @var \Illuminate\Database\Eloquent\Model $child */
            foreach ($children as $child) {
                $child->setAttribute($relation->getForeignKeyName(), null);
                $child->save();
            }
        }
    }

    /**
     * TODO remove this horrible hack when we no longer support Laravel 5.6.
     */
    protected static function getLocalKeyName(HasOneOrMany $relation): string
    {
        $getLocalKeyName = Closure::bind(
            function () {
                // @phpstan-ignore-next-line This is a dirty hack
                return $this->localKey;
            },
            $relation,
            get_class($relation)
        );

        return $getLocalKeyName();
    }
}