kreta / Kreta

use Kreta\TaskManager\Application\Query\Organization\OrganizationOfIdQuery;

use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;

class CreateOrganizationMutation implements Mutation

{

    private $commandBus;

    private $queryBus;

    private $currentUser;

    public function __construct(TokenStorageInterface $tokenStorage, CommandBus $commandBus, QueryBus $queryBus)

    {

        $this->queryBus = $queryBus;

        $this->commandBus = $commandBus;

        $this->currentUser = $tokenStorage->getToken()->getUser()->getUsername();

    }

    public function execute(array $values) : array

    {

        $command = new CreateOrganizationCommand(

            $this->currentUser,

            $values['name']

        );

        $this->commandBus->handle($command);

        $this->queryBus->handle(

            new OrganizationOfIdQuery(

                $command->id(),

                $this->currentUser

            ),

            $organization

        );

        return [

            'organization' => $organization,

        ];

    }

}

use Kreta\TaskManager\Application\Query\Project\Task\TaskOfIdQuery;

use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;

class TaskResolver implements Resolver

{

    private $queryBus;

    private $currentUser;

    private $taskBuilderResolver;

    public function __construct(

        TokenStorageInterface $tokenStorage,

        QueryBus $queryBus,

        TaskBuilderResolver $taskBuilderResolver

    ) {

        $this->queryBus = $queryBus;

        $this->currentUser = $tokenStorage->getToken()->getUser()->getUsername();

        $this->taskBuilderResolver = $taskBuilderResolver;

    }

    public function resolve($args)

    {

        $this->queryBus->handle(

            new TaskOfIdQuery(

                $args['id'],

                $this->currentUser

            ),

            $result

        );

        $result = $this->taskBuilderResolver->resolve($result);

        return $result;

    }

    public function resolveByParent($parentId)

    {

        return $this->resolve(['id' => $parentId]);

    }

}