ENGCOM-3139: My Account > Change account information and Newsletter s…

…ubscription #162

 - Merge Pull Request magento/graphql-ce#162 from comwrap/graphql-ce:55-56-account-mutations
 - Merged commits:
   1. 09dc09c
   2. ef7f579
   3. 8963811
   4. d0dd90f
   5. b691d84
   6. d759867
   7. a1dd683
   8. cc8d328
   9. 9200a16
   10. 2057ddf
   11. 20e3393
   12. 661988b
   13. 706af91
   14. a1c4d33
   15. 0cb378b
   16. 6e6b5c3
   17. 6f73325
   18. 7ca6097

app/code/Magento/CustomerGraphQl/Model/Customer/ChangeSubscriptionStatus.php

@@ -0,0 +1,48 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\CustomerGraphQl\Model\Customer;
+
+use Magento\Newsletter\Model\SubscriberFactory;
+
+/**
+ * Change subscription status. Subscribe OR unsubscribe if required
+ */
+class ChangeSubscriptionStatus
+{
+    /**
+     * @var SubscriberFactory
+     */
+    private $subscriberFactory;
+
+    /**
+     * @param SubscriberFactory $subscriberFactory
+     */
+    public function __construct(
+        SubscriberFactory $subscriberFactory
+    ) {
+        $this->subscriberFactory = $subscriberFactory;
+    }
+
+    /**
+     * Change subscription status. Subscribe OR unsubscribe if required
+     *
+     * @param int $customerId
+     * @param bool $subscriptionStatus
+     * @return void
+     */
+    public function execute(int $customerId, bool $subscriptionStatus): void
+    {
+        $subscriber = $this->subscriberFactory->create()->loadByCustomerId($customerId);
+
+        if ($subscriptionStatus === true && !$subscriber->isSubscribed()) {
+            $this->subscriberFactory->create()->subscribeCustomerById($customerId);
+        } elseif ($subscriptionStatus === false && $subscriber->isSubscribed()) {
+            $this->subscriberFactory->create()->unsubscribeCustomerById($customerId);
+        }
+    }
+}

app/code/Magento/CustomerGraphQl/Model/Customer/CheckCustomerAccount.php

@@ -0,0 +1,103 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\CustomerGraphQl\Model\Customer;
+
+use Magento\Authorization\Model\UserContextInterface;
+use Magento\Customer\Api\AccountManagementInterface;
+use Magento\Customer\Api\CustomerRepositoryInterface;
+use Magento\Customer\Model\AuthenticationInterface;
+use Magento\Framework\Exception\NoSuchEntityException;
+use Magento\Framework\GraphQl\Exception\GraphQlAuthenticationException;
+use Magento\Framework\GraphQl\Exception\GraphQlAuthorizationException;
+use Magento\Framework\GraphQl\Exception\GraphQlNoSuchEntityException;
+
+/**
+ * Check customer account
+ */
+class CheckCustomerAccount
+{
+    /**
+     * @var AuthenticationInterface
+     */
+    private $authentication;
+
+    /**
+     * @var CustomerRepositoryInterface
+     */
+    private $customerRepository;
+
+    /**
+     * @var AccountManagementInterface
+     */
+    private $accountManagement;
+
+    /**
+     * @param AuthenticationInterface $authentication
+     * @param CustomerRepositoryInterface $customerRepository
+     * @param AccountManagementInterface $accountManagement
+     */
+    public function __construct(
+        AuthenticationInterface $authentication,
+        CustomerRepositoryInterface $customerRepository,
+        AccountManagementInterface $accountManagement
+    ) {
+        $this->authentication = $authentication;
+        $this->customerRepository = $customerRepository;
+        $this->accountManagement = $accountManagement;
+    }
+
+    /**
+     * Check customer account
+     *
+     * @param int|null $customerId
+     * @param int|null $customerType
+     * @return void
+     * @throws GraphQlAuthorizationException
+     * @throws GraphQlNoSuchEntityException
+     * @throws GraphQlAuthenticationException
+     */
+    public function execute(?int $customerId, ?int $customerType): void
+    {
+        if (true === $this->isCustomerGuest($customerId, $customerType)) {
+            throw new GraphQlAuthorizationException(__('The current customer isn\'t authorized.'));
+        }
+
+        try {
+            $this->customerRepository->getById($customerId);
+        } catch (NoSuchEntityException $e) {
+            throw new GraphQlNoSuchEntityException(
+                __('Customer with id "%customer_id" does not exist.', ['customer_id' => $customerId]),
+                $e
+            );
+        }
+
+        if (true === $this->authentication->isLocked($customerId)) {
+            throw new GraphQlAuthenticationException(__('The account is locked.'));
+        }
+
+        $confirmationStatus = $this->accountManagement->getConfirmationStatus($customerId);
+        if ($confirmationStatus === AccountManagementInterface::ACCOUNT_CONFIRMATION_REQUIRED) {
+            throw new GraphQlAuthenticationException(__("This account isn't confirmed. Verify and try again."));
+        }
+    }
+
+    /**
+     * Checking if current customer is guest
+     *
+     * @param int|null $customerId
+     * @param int|null $customerType
+     * @return bool
+     */
+    private function isCustomerGuest(?int $customerId, ?int $customerType): bool
+    {
+        if (null === $customerId || null === $customerType) {
+            return true;
+        }
+        return 0 === (int)$customerId || (int)$customerType === UserContextInterface::USER_TYPE_GUEST;
+    }
+}

app/code/Magento/CustomerGraphQl/Model/Customer/CheckCustomerPassword.php

@@ -0,0 +1,50 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\CustomerGraphQl\Model\Customer;
+
+use Magento\Customer\Model\AuthenticationInterface;
+use Magento\Framework\Exception\InvalidEmailOrPasswordException;
+use Magento\Framework\GraphQl\Exception\GraphQlAuthenticationException;
+
+/**
+ * Check customer password
+ */
+class CheckCustomerPassword
+{
+    /**
+     * @var AuthenticationInterface
+     */
+    private $authentication;
+
+    /**
+     * @param AuthenticationInterface $authentication
+     */
+    public function __construct(
+        AuthenticationInterface $authentication
+    ) {
+        $this->authentication = $authentication;
+    }
+
+    /**
+     * Check customer password
+     *
+     * @param string $password
+     * @param int $customerId
+     * @throws GraphQlAuthenticationException
+     */
+    public function execute(string $password, int $customerId)
+    {
+        try {
+            $this->authentication->authenticate($customerId, $password);
+        } catch (InvalidEmailOrPasswordException $e) {
+            throw new GraphQlAuthenticationException(
+                __('The password doesn\'t match this account. Verify the password and try again.')
+            );
+        }
+    }
+}

app/code/Magento/CustomerGraphQl/Model/Resolver/Customer/CustomerDataProvider.php → app/code/Magento/CustomerGraphQl/Model/Customer/CustomerDataProvider.php

@@ -5,11 +5,12 @@
  */
 declare(strict_types=1);
 
-namespace Magento\CustomerGraphQl\Model\Resolver\Customer;
+namespace Magento\CustomerGraphQl\Model\Customer;
 
 use Magento\Customer\Api\CustomerRepositoryInterface;
 use Magento\Framework\Exception\LocalizedException;
 use Magento\Framework\Exception\NoSuchEntityException;
+use Magento\Framework\GraphQl\Exception\GraphQlNoSuchEntityException;
 use Magento\Framework\Serialize\SerializerInterface;
 use Magento\Framework\Webapi\ServiceOutputProcessor;
 use Magento\Customer\Api\Data\CustomerInterface;
@@ -32,21 +33,21 @@ class CustomerDataProvider
     /**
      * @var SerializerInterface
      */
-    private $jsonSerializer;
+    private $serializer;
 
     /**
      * @param CustomerRepositoryInterface $customerRepository
      * @param ServiceOutputProcessor $serviceOutputProcessor
-     * @param SerializerInterface $jsonSerializer
+     * @param SerializerInterface $serializer
      */
     public function __construct(
         CustomerRepositoryInterface $customerRepository,
         ServiceOutputProcessor $serviceOutputProcessor,
-        SerializerInterface $jsonSerializer
+        SerializerInterface $serializer
     ) {
         $this->customerRepository = $customerRepository;
         $this->serviceOutputProcessor = $serviceOutputProcessor;
-        $this->jsonSerializer = $jsonSerializer;
+        $this->serializer = $serializer;
     }
 
     /**
@@ -56,42 +57,44 @@ public function __construct(
      * @return array
      * @throws NoSuchEntityException|LocalizedException
      */
-    public function getCustomerById(int $customerId) : array
+    public function getCustomerById(int $customerId): array
     {
         try {
-            $customerObject = $this->customerRepository->getById($customerId);
+            $customer = $this->customerRepository->getById($customerId);
         } catch (NoSuchEntityException $e) {
-            // No error should be thrown, null result should be returned
-            return [];
+            throw new GraphQlNoSuchEntityException(
+                __('Customer id "%customer_id" does not exist.', ['customer_id' => $customerId]),
+                $e
+            );
         }
-        return $this->processCustomer($customerObject);
+        return $this->processCustomer($customer);
     }
 
     /**
      * Transform single customer data from object to in array format
      *
-     * @param CustomerInterface $customerObject
+     * @param CustomerInterface $customer
      * @return array
      */
-    private function processCustomer(CustomerInterface $customerObject) : array
+    private function processCustomer(CustomerInterface $customer): array
     {
-        $customer = $this->serviceOutputProcessor->process(
-            $customerObject,
+        $customerData = $this->serviceOutputProcessor->process(
+            $customer,
             CustomerRepositoryInterface::class,
             'get'
         );
-        if (isset($customer['extension_attributes'])) {
-            $customer = array_merge($customer, $customer['extension_attributes']);
+        if (isset($customerData['extension_attributes'])) {
+            $customerData = array_merge($customerData, $customerData['extension_attributes']);
         }
         $customAttributes = [];
-        if (isset($customer['custom_attributes'])) {
-            foreach ($customer['custom_attributes'] as $attribute) {
+        if (isset($customerData['custom_attributes'])) {
+            foreach ($customerData['custom_attributes'] as $attribute) {
                 $isArray = false;
                 if (is_array($attribute['value'])) {
                     $isArray = true;
                     foreach ($attribute['value'] as $attributeValue) {
                         if (is_array($attributeValue)) {
-                            $customAttributes[$attribute['attribute_code']] = $this->jsonSerializer->serialize(
+                            $customAttributes[$attribute['attribute_code']] = $this->serializer->serialize(
                                 $attribute['value']
                             );
                             continue;
@@ -106,8 +109,8 @@ private function processCustomer(CustomerInterface $customerObject) : array
                 $customAttributes[$attribute['attribute_code']] = $attribute['value'];
             }
         }
-        $customer = array_merge($customer, $customAttributes);
+        $customerData = array_merge($customerData, $customAttributes);
 
-        return $customer;
+        return $customerData;
     }
 }