kreta / Kreta

use Symfony\Component\HttpFoundation\Request;

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

class AddMemberToOrganization

{

    private $commandBus;

    private $currentUser;

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

    {

        $this->commandBus = $commandBus;

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

    }

    public function __invoke(Request $request) : JsonResponse

    {

        $userId = $request->get('userId');

        $organizationId = $request->get('organizationId');

        $this->commandBus->handle(

            new AddOrganizationMemberToOrganizationCommand($userId, $organizationId, $this->currentUser->getUserName())

        );

        return new JsonResponse();

    }

}

use Symfony\Component\HttpFoundation\Request;

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

class RemoveMemberFromOrganization

{

    private $commandBus;

    private $currentUser;

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

    {

        $this->commandBus = $commandBus;

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

    }

    public function __invoke(Request $request) : JsonResponse

    {

        $userId = $request->get('userId');

        $organizationId = $request->get('organizationId');

        $this->commandBus->handle(

            new RemoveOrganizationMemberToOrganizationCommand($userId, $organizationId, $this->currentUser->getUserName())

        );

        return new JsonResponse();

    }

}