Handle magento events (#1)

* Handle new account without password event.

* Handle forgot password, reset password events.

Author: sai-krishna-kota

Oracle/Contact/Observer/AfterCustomerSaveObserver.php

@@ -7,13 +7,24 @@
 
 namespace Oracle\Contact\Observer;
 
-class AfterCustomerSaveObserver extends ObserverAbstract
+class AfterCustomerSaveObserver extends CustomerObserverAbstract
 {
     /**
      * @see parent
      */
     public function execute(\Magento\Framework\Event\Observer $observer)
     {
+        if($this->_request != null && $this->_request->getModuleName() == "customer"){
+            if($this->_request->getActionName() == "resetpasswordpost"){
+                return;
+            }
+            if($this->_request->getActionName() == "resetPassword"){
+                $observer->setData("resetPassword", true);
+            }
+            if($this->_request->getActionName() == "forgotpasswordpost"){
+                $observer->setData("forgotPassword", true);
+            }
+        }
         $this->_observer->pushChanges($observer);
     }
 }

Oracle/Contact/Observer/CustomerObserverAbstract.php

@@ -0,0 +1,25 @@
+<?php
+/*
+ * Copyright © 2021, 2022 Oracle and/or its affiliates.
+ *
+ * Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
+ */
+
+namespace Bronto\Contact\Observer;
+
+abstract class CustomerObserverAbstract implements \Magento\Framework\Event\ObserverInterface
+{
+    protected $_observer;
+    protected $_request;
+
+    /**
+     * @param \Bronto\Contact\Model\Observer
+     */
+    public function __construct(
+        \Bronto\Contact\Model\Observer $observer,
+        \Magento\Framework\App\RequestInterface $req
+    ) {
+        $this->_observer = $observer;
+        $this->_request = $req;
+    }
+}

Oracle/M2/Advanced/ExtensionAbstract.php

@@ -245,7 +245,7 @@ protected function _validateMessage($dataType, $dataAction, $objectType)
             return true;
         if($dataType=='order' && $dataAction=='delete' && in_array("order_cancellation",$objectType))
             return true;
-        if($dataType=='contact' && $dataAction=='add' && in_array("customer_account_welcome",$objectType))
+        if($dataType=='contact' && $dataAction=='add' && in_array("customer_account_welcome",$objectType) || in_array("new_account_without_password", $objectType)))
             return true;
         if($dataType=='cart' && in_array("cart_event",$objectType))
             return true;

Oracle/M2/Connector/Discovery/ExtensionPushEventAbstract.php

@@ -69,6 +69,12 @@ public function pushChanges($observer)
         if (is_null($storeId) || $storeId === false) {
             $storeId = true;
         }
+        if($observer->hasData("resetPassword")) {
+            $object->setData("resetPassword", $observer->getData("resetPassword"));
+        }
+        if($observer->hasData("forgotPassword")) {
+            $object->setData("forgotPassword", $observer->getData("forgotPassword"));
+        }
         $this->_pushLogic->pushEvent($object, $storeId);
     }
 

Oracle/M2/Contact/Event/Source.php

@@ -33,7 +33,9 @@ public function create($customer)
               $this->getEventType(),
               $this->action($customer),
               $customer->getId()
-          ])
+          ]),
+          'resetPassword' => $customer->hasData("resetPassword"),
+          'forgotPassword' => $customer->hasData("forgotPassword")
         ];
     }
 
@@ -71,4 +73,13 @@ public function transform($customer)
             ];
         }
     }
+
+    public function transformForEvent($customer, $eventName) {
+        return [
+            'email' => $customer->getEmail(),
+            'status' => 'transactional',
+            'fields' => $this->_helper->getFieldsForModel($customer, $customer->getStore(), 'contact', $eventName)
+        ];
+    }
+
 }

Oracle/M2/Contact/ExtensionAbstract.php

@@ -279,7 +279,13 @@ public function transformEvent($observer)
         } else {
             $customer = $this->_customerRepo->getById($event['id']);
             if ($customer) {
-                $data = $this->_source->transform($customer);
+                if($event['resetPassword']) {
+                    $data = $this->_source->transformForEvent($customer, "resetPassword");
+                } elseif ($event['forgotPassword']) {
+                    $data = $this->_source->transformForEvent($customer, "forgotPassword");
+                } else {
+                    $data = $this->_source->transform($customer);
+                }
             }
         }
         $transform->setContact($data);

Oracle/M2/Contact/SettingsAbstract.php

@@ -102,10 +102,18 @@ public function getAttributeFilters()
         return array_combine(self::$_attributeKeys, $attributes);
     }
 
+    private function buildNewAccountResetPasswordURL($object, $storeId) {
+        return $this->_storeManager->getStore($storeId)->getBaseUrl().'customer/account/createPassword/?id='.$object->getId().'&token='.$object->getData('rp_token');
+    }
+
+    private function buildResetPasswordURL($object, $storeId) {
+        return $this->_storeManager->getStore($storeId)->getBaseUrl().'customer/account/createPassword/?token='.$object->getData('rp_token');
+    }
+
     /**
      * @see parent
      */
-    public function getFieldsForModel($object, $storeId, $type = 'contact')
+    public function getFieldsForModel($object, $storeId, $type = 'contact', $eventName = '')
     {
         $fields = [];
 
@@ -125,6 +133,22 @@ public function getFieldsForModel($object, $storeId, $type = 'contact')
                 'fieldId' => 'entityId',
                 'content' => $object->getEntityId()
             ];
+            if($object->getPasswordHash() == null) {
+                $fields[] = [
+                    'fieldId' => 'newAccountResetPasswordURL',
+                    'content' => $this->buildNewAccountResetPasswordURL($object, $storeId)
+                ];
+            } elseif($eventName == "resetPassword") {
+                $fields[] = [
+                    'fieldId' => 'resetPasswordURL',
+                    'content' => $this->buildResetPasswordURL($object, $storeId)
+                ];
+            } elseif($eventName == "forgotPassword") {
+                $fields[] = [
+                    'fieldId' => 'forgotPasswordURL',
+                    'content' => $this->buildResetPasswordURL($object, $storeId)
+                ];
+            }
         }
 
         $store = $this->_storeManager->getStore($storeId);