Merge pull request #11 from MaxSouza/graphql-cache

Added cache on graphql schema
discorgento · Jul 30, 2023 · a6629a9 · a6629a9
2 parents 9a890da + 6d42ebf
commit a6629a9
Show file tree

Hide file tree

Showing 4 changed files with 83 additions and 42 deletions.
diff --git a/Model/Resolver/HasCustomerPurchasedProduct.php b/Model/Resolver/HasCustomerPurchasedProduct.php
@@ -9,6 +9,7 @@
 
 namespace Discorgento\ProductLastOrder\Model\Resolver;
 
+use Exception;
 use Magento\Framework\GraphQl\Query\ResolverInterface;
 use Magento\Framework\GraphQl\Config\Element\Field;
 use Magento\Framework\GraphQl\Schema\Type\ResolveInfo;
@@ -102,10 +103,23 @@ public function __construct(
      */
     public function resolve(Field $field, $context, ResolveInfo $info, array $value = null, array $args = null)
     {
-        $customerId = $args['customerId'];
-        $productId = $args['productId'];
+        $customerId = (int)$args['customerId'];
+        $productId = (int)$args['productId'];
+        $dataSkeleton = [
+            'hasPurchased' => false,
+            'orderLink' => '',
+            'orderDate' => '',
+            'customer_id' => '',
+            'product_id' => ''
+        ];
 
         try {
+
+            // Avoid request if there's no customer_id(not logged)
+            if (empty($customerId)) {
+                return $dataSkeleton;
+            }
+
             $customer = $this->customerRepository->getById($customerId);
             $customerEmail = $customer->getEmail();
 
@@ -117,29 +131,23 @@ public function resolve(Field $field, $context, ResolveInfo $info, array $value
 
             foreach ($orders as $order) {
                 foreach ($order->getAllVisibleItems() as $item) {
-                    if ($item->getProductId() == $productId) {
+                    if ((int)$item->getProductId() === $productId) {
 
                         return [
                             'hasPurchased' => true,
                             'orderLink' => $this->getOrderLink($order),
-                            'orderDate' => $this->getFormattedOrderDate($order->getCreatedAt())
+                            'orderDate' => $this->getFormattedOrderDate($order->getCreatedAt()),
+                            'customer_id' => $customerId,
+                            'product_id' => $productId
                         ];
                     }
                 }
             }
-        } catch (\Exception $e) {
-            return [
-                'hasPurchased' => false,
-                'orderLink' => '',
-                'orderDate' => ''
-            ];
+        } catch (Exception) {
+            return $dataSkeleton;
         }
 
-        return [
-            'hasPurchased' => false,
-            'orderLink' => '',
-            'orderDate' => ''
-        ];
+        return $dataSkeleton;
     }
 
     /**
@@ -169,16 +177,16 @@ private function getFormattedOrderDate($createdAt)
             $createdAtObject = new \DateTime($createdAt, new \DateTimeZone($this->timezone->getConfigTimezone()));
             $userTimezone = $this->timezone->getConfigTimezone();
             $format = \IntlDateFormatter::MEDIUM;
-        
+
             return $this->timezone->formatDateTime(
                 $createdAtObject,
                 $format,
                 \IntlDateFormatter::NONE,
                 null,
                 $userTimezone
             );
-            
-        } catch (\Exception $e) {
+
+        } catch (Exception $e) {
             return '';
         }
     }

diff --git a/Model/Resolver/ProductLastOrderIdentity.php b/Model/Resolver/ProductLastOrderIdentity.php
@@ -0,0 +1,32 @@
+<?php 
+
+/**
+ * Copyright ©  All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+declare(strict_types=1);
+
+namespace Discorgento\ProductLastOrder\Model\Resolver;
+
+use Magento\Framework\GraphQl\Query\Resolver\IdentityInterface;
+
+class ProductLastOrderIdentity implements IdentityInterface
+{
+    private string $cacheTag = 'disc_productlastorder';
+
+    /**
+     * @inheritDoc
+     */
+    public function getIdentities(array $resolvedData): array
+    {
+        $data["id"] = empty($resolvedData["customer_id"]) && empty($resolvedData["product_id"]) ? [] : [
+            'customer_id' => $resolvedData["customer_id"],
+            'product_id' => $resolvedData['product_id']];
+
+        return empty($data['id']) ?
+            [] : array_merge([$this->cacheTag], array_map(function ($item) {
+                return sprintf('%s_%s_%s', $this->cacheTag, $item['customer_id'], $item['product_id']);
+            }, $data));
+    }
+}
diff --git a/etc/schema.graphqls b/etc/schema.graphqls
@@ -6,6 +6,7 @@ type Query {
         @resolver(
             class: "Discorgento\\ProductLastOrder\\Model\\Resolver\\HasCustomerPurchasedProduct"
         )
+        @cache(cacheIdentity: "Discorgento\\ProductLastOrder\\Model\\Resolver\\ProductLastOrderIdentity" cacheable: true)
 }
 
 type HasPurchasedProduct {

diff --git a/view/frontend/web/js/component-msg-last-order.js b/view/frontend/web/js/component-msg-last-order.js
@@ -26,7 +26,7 @@ define([
          */
         initialize: function (config) {
             const { customerId, productId } = config;
-            
+
             this._super();
             this.makeGraphQLRequest();
         },
@@ -35,30 +35,30 @@ define([
          * Makes a GraphQL request to check if a customer has purchased a product.
          */
         makeGraphQLRequest: function () {
-            var self = this;
-
-            var urlGraphql = urlBuilder.build('graphql');
+            let self = this;
 
-            var requestConfig = {
-                url: urlGraphql,
-                method: 'POST',
-                dataType: 'json',
-                contentType: 'application/json',
-                data: JSON.stringify({
-                    query: `
-                        query CheckCustomerProductPurchase($customerId: String!, $productId: String!) {
-                            hasCustomerPurchasedProduct(customerId: $customerId, productId: $productId) {
-                                hasPurchased
-                                orderLink
-                                orderDate
-                            }
-                        }
-                    `,
-                    variables: {
-                        customerId: self.customerId,
-                        productId: self.productId
+            let urlGraphql = urlBuilder.build('graphql');
+            let queryGraphqlObject =  {
+                query: `
+                query CheckCustomerProductPurchase($customerId: String!, $productId: String!) {
+                    hasCustomerPurchasedProduct(customerId: $customerId, productId: $productId) {
+                        hasPurchased
+                        orderLink
+                        orderDate
                     }
-                })
+                }`
+            };
+
+            let variablesGraphql = JSON.stringify({
+                customerId: self.customerId,
+                productId: self.productId
+            });
+
+            let queryEncoded = $.param(queryGraphqlObject);
+            let queryGraphql = queryEncoded+'&variables='+ variablesGraphql;
+            let requestConfig = {
+                url: urlGraphql +'?'+queryGraphql,
+                method: 'GET'
             };
 
             $.ajax(requestConfig).done(function (response) {
@@ -68,7 +68,7 @@ define([
                 if (hasPurchased) {
                     self.isVisible(true);
                 }
-                
+
                 self.orderLink(orderLink);
                 self.orderDate(orderDate);
             }).fail(function (error) {