From 52e0d1ff5a80d75f62692edfb7a57069ee148f3c Mon Sep 17 00:00:00 2001
From: konradoboza <konrad.oboza@ibexa.co>
Date: Tue, 25 Jun 2024 15:16:54 +0200
Subject: [PATCH] restored mutation and moved authorization elsewhere

---
 .../graphql/PlatformMutation.types.yaml       |  18 +++
 .../Resources/config/services/resolvers.yaml  |   4 +
 .../Resources/config/services/services.yaml   |   9 --
 src/lib/Mutation/AuthenticationMutation.php   |  54 +++++++
 src/lib/Security/JWTAuthenticator.php         | 149 ------------------
 .../JWTTokenMutationFormatEventSubscriber.php |  56 -------
 6 files changed, 76 insertions(+), 214 deletions(-)
 create mode 100644 src/lib/Mutation/AuthenticationMutation.php
 delete mode 100644 src/lib/Security/JWTAuthenticator.php
 delete mode 100644 src/lib/Security/JWTTokenMutationFormatEventSubscriber.php

diff --git a/src/bundle/Resources/config/graphql/PlatformMutation.types.yaml b/src/bundle/Resources/config/graphql/PlatformMutation.types.yaml
index 45a023f..a9ee319 100644
--- a/src/bundle/Resources/config/graphql/PlatformMutation.types.yaml
+++ b/src/bundle/Resources/config/graphql/PlatformMutation.types.yaml
@@ -24,6 +24,14 @@ PlatformMutation:
                     language:
                         type: RepositoryLanguage!
                         description: "The language the content items must be created in"
+            createToken:
+                type: CreatedTokenPayload
+                resolve: '@=mutation("CreateToken", args)'
+                args:
+                    username:
+                        type: String!
+                    password:
+                        type: String!
 
 UploadedFilesPayload:
     type: object
@@ -44,3 +52,13 @@ DeleteContentPayload:
             id:
                 type: ID
                 description: "Global ID"
+
+CreatedTokenPayload:
+    type: object
+    config:
+        fields:
+            token:
+                type: String
+            message:
+                type: String
+                description: "The reason why authentication has failed, if it has"
diff --git a/src/bundle/Resources/config/services/resolvers.yaml b/src/bundle/Resources/config/services/resolvers.yaml
index fde4e23..d25fffc 100644
--- a/src/bundle/Resources/config/services/resolvers.yaml
+++ b/src/bundle/Resources/config/services/resolvers.yaml
@@ -62,6 +62,10 @@ services:
         tags:
             - { name: overblog_graphql.resolver, alias: "Thumbnail", method: "resolveThumbnail" }
 
+    Ibexa\GraphQL\Mutation\AuthenticationMutation:
+        tags:
+            - { name: overblog_graphql.mutation, alias: "CreateToken", method: "createToken" }
+
     Ibexa\GraphQL\Mutation\UploadFiles:
         arguments:
             $repository: '@ibexa.siteaccessaware.repository'
diff --git a/src/bundle/Resources/config/services/services.yaml b/src/bundle/Resources/config/services/services.yaml
index 048c9bb..5e2dd63 100644
--- a/src/bundle/Resources/config/services/services.yaml
+++ b/src/bundle/Resources/config/services/services.yaml
@@ -50,12 +50,3 @@ services:
             $contentLoader: '@Ibexa\GraphQL\DataLoader\ContentLoader'
         tags:
             - { name: ibexa.field_type.image_asset.mapper.strategy, priority: 0 }
-
-    Ibexa\GraphQL\Security\JWTAuthenticator:
-        arguments:
-            $userProvider: '@ibexa.security.user_provider'
-
-    Ibexa\GraphQL\Security\JWTTokenMutationFormatEventSubscriber:
-        tags:
-            - name: kernel.event_subscriber
-              dispatcher: security.event_dispatcher.ibexa_jwt_graphql
diff --git a/src/lib/Mutation/AuthenticationMutation.php b/src/lib/Mutation/AuthenticationMutation.php
new file mode 100644
index 0000000..7544dc8
--- /dev/null
+++ b/src/lib/Mutation/AuthenticationMutation.php
@@ -0,0 +1,54 @@
+<?php
+
+/**
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
+ * @license For full copyright and license information view LICENSE file distributed with this source code.
+ */
+declare(strict_types=1);
+
+namespace Ibexa\GraphQL\Mutation;
+
+use Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException;
+use Ibexa\Contracts\Core\Repository\UserService;
+use Ibexa\Core\MVC\Symfony\Security\User;
+use Lexik\Bundle\JWTAuthenticationBundle\Services\JWTTokenManagerInterface;
+use Overblog\GraphQLBundle\Definition\Argument;
+
+final readonly class AuthenticationMutation
+{
+    public function __construct(
+        private JWTTokenManagerInterface $tokenManager,
+        private UserService $userService
+    ) {
+    }
+
+    /**
+     * @return array<string, ?string>
+     *
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
+     */
+    public function createToken(Argument $args): array
+    {
+        $arguments = $args->getArrayCopy();
+        if (!isset($arguments['username'], $arguments['password'])) {
+            return [
+                'message' => 'Missing username or password',
+                'token' => null,
+            ];
+        }
+
+        try {
+            $user = $this->userService->loadUserByLogin($arguments['username']);
+            $this->userService->checkUserCredentials($user, $arguments['password']);
+        } catch (NotFoundException) {
+            return [
+                'message' => 'Wrong username or password',
+                'token' => null,
+            ];
+        }
+
+        return [
+            'token' => $this->tokenManager->create(new User($user)),
+        ];
+    }
+}
diff --git a/src/lib/Security/JWTAuthenticator.php b/src/lib/Security/JWTAuthenticator.php
deleted file mode 100644
index 6714986..0000000
--- a/src/lib/Security/JWTAuthenticator.php
+++ /dev/null
@@ -1,149 +0,0 @@
-<?php
-
-/**
- * @copyright Copyright (C) Ibexa AS. All rights reserved.
- * @license For full copyright and license information view LICENSE file distributed with this source code.
- */
-declare(strict_types=1);
-
-namespace Ibexa\GraphQL\Security;
-
-use Exception;
-use GraphQL\Language\AST\ArgumentNode;
-use GraphQL\Language\AST\NodeKind;
-use GraphQL\Language\Parser;
-use GraphQL\Language\Visitor;
-use Ibexa\Contracts\Core\Repository\PermissionResolver;
-use Ibexa\Core\MVC\Symfony\Security\User\APIUserProviderInterface;
-use Ibexa\Core\MVC\Symfony\Security\UserInterface as IbexaUser;
-use Lexik\Bundle\JWTAuthenticationBundle\Services\JWTTokenManagerInterface;
-use Symfony\Component\HttpFoundation\Request;
-use Symfony\Component\HttpFoundation\Response;
-use Symfony\Component\Security\Core\Authentication\Token\TokenInterface;
-use Symfony\Component\Security\Core\Exception\AuthenticationException;
-use Symfony\Component\Security\Http\Authenticator\AbstractAuthenticator;
-use Symfony\Component\Security\Http\Authenticator\InteractiveAuthenticatorInterface;
-use Symfony\Component\Security\Http\Authenticator\Passport\Badge\UserBadge;
-use Symfony\Component\Security\Http\Authenticator\Passport\Credentials\PasswordCredentials;
-use Symfony\Component\Security\Http\Authenticator\Passport\Passport;
-
-final class JWTAuthenticator extends AbstractAuthenticator implements InteractiveAuthenticatorInterface
-{
-    private string $username;
-
-    private string $password;
-
-    public function __construct(
-        private readonly JWTTokenManagerInterface $tokenManager,
-        private readonly APIUserProviderInterface $userProvider,
-        private readonly PermissionResolver $permissionResolver,
-    ) {
-    }
-
-    public function supports(Request $request): ?bool
-    {
-        $payload = json_decode($request->getContent(), true);
-        if (!isset($payload['query'])) {
-            return false;
-        }
-
-        try {
-            $credentials = $this->extractCredentials($payload['query']);
-        } catch (Exception) {
-            return false;
-        }
-
-        if (isset($credentials['username'], $credentials['password'])) {
-            $this->username = $credentials['username'];
-            $this->password = $credentials['password'];
-
-            return true;
-        }
-
-        return false;
-    }
-
-    public function authenticate(Request $request): Passport
-    {
-        $passport = new Passport(
-            new UserBadge($this->username, [$this->userProvider, 'loadUserByUsername']),
-            new PasswordCredentials($this->password)
-        );
-
-        $user = $passport->getUser();
-        if ($user instanceof IbexaUser) {
-            $this->permissionResolver->setCurrentUserReference($user->getAPIUser());
-        }
-
-        $passport->setAttribute('token', $this->tokenManager->create($user));
-
-        return $passport;
-    }
-
-    /**
-     * @throws \JsonException
-     */
-    public function onAuthenticationSuccess(Request $request, TokenInterface $token, string $firewallName): ?Response
-    {
-        $user = $token->getUser();
-        if ($user === null) {
-            throw new AuthenticationException('No authenticated user found.', 401);
-        }
-
-        return new Response(
-            json_encode(
-                [
-                    'token' => $this->tokenManager->create($user),
-                    'message' => null,
-                ],
-                JSON_THROW_ON_ERROR
-            )
-        );
-    }
-
-    /**
-     * @throws \JsonException
-     */
-    public function onAuthenticationFailure(Request $request, AuthenticationException $exception): ?Response
-    {
-       return new Response(
-           json_encode(
-               [
-                   'token' => null,
-                   'message' => $exception->getMessageKey(),
-                ],
-               JSON_THROW_ON_ERROR
-           ),
-           Response::HTTP_FORBIDDEN
-       );
-    }
-
-    public function isInteractive(): bool
-    {
-        return true;
-    }
-
-    /**
-     * @return array<string, string>
-     *
-     * @throws \Exception
-     */
-    private function extractCredentials(string $graphqlQuery): array
-    {
-        $parsed = Parser::parse($graphqlQuery);
-        $credentials = [];
-        Visitor::visit(
-            $parsed,
-            [
-                NodeKind::ARGUMENT => static function (ArgumentNode $node) use (&$credentials): void {
-                    /** @var \GraphQL\Language\AST\StringValueNode $nodeValue */
-                    $nodeValue = $node->value;
-
-                    $credentials[$node->name->value] = $nodeValue->value;
-                },
-            ]
-        );
-
-        return $credentials;
-    }
-}
diff --git a/src/lib/Security/JWTTokenMutationFormatEventSubscriber.php b/src/lib/Security/JWTTokenMutationFormatEventSubscriber.php
deleted file mode 100644
index e55d4c4..0000000
--- a/src/lib/Security/JWTTokenMutationFormatEventSubscriber.php
+++ /dev/null
@@ -1,56 +0,0 @@
-<?php
-
-/**
- * @copyright Copyright (C) Ibexa AS. All rights reserved.
- * @license For full copyright and license information view LICENSE file distributed with this source code.
- */
-declare(strict_types=1);
-
-namespace Ibexa\GraphQL\Security;
-
-use Symfony\Component\EventDispatcher\EventSubscriberInterface;
-use Symfony\Component\Security\Http\Event\LoginFailureEvent;
-use Symfony\Component\Security\Http\Event\LoginSuccessEvent;
-
-/**
- * Needed only to properly adjust authorization (either successful or failed) response to meet former JWT Token Mutation format.
- */
-final readonly class JWTTokenMutationFormatEventSubscriber implements EventSubscriberInterface
-{
-    public static function getSubscribedEvents(): array
-    {
-        return [
-            LoginSuccessEvent::class => ['onAuthorizationFinishes', 10],
-            LoginFailureEvent::class => ['onAuthorizationFinishes', 10],
-        ];
-    }
-
-    /**
-     * @throws \JsonException
-     */
-    public function onAuthorizationFinishes(LoginSuccessEvent|LoginFailureEvent $event): void
-    {
-        $response = $event->getResponse();
-        if ($response === null) {
-            return;
-        }
-
-        $response->setContent(
-            $this->formatMutationResponseData($response->getContent())
-        );
-    }
-
-    /**
-     * @throws \JsonException
-     */
-    private function formatMutationResponseData(mixed $data): string
-    {
-        $formatted = json_encode([
-            'data' => [
-                'CreateToken' => json_decode($data, true, 512, JSON_THROW_ON_ERROR),
-            ],
-        ]);
-
-        return $formatted === false ? '' : $formatted;
-    }
-}