Notification Handler

src/Fident.php

@@ -70,7 +70,7 @@ public function decodeNotification($requestBody): ?FidentNotification
     $sig = self::urlsafeB64Decode(Objects::property($notification, 'Signature', ''));
     if(openssl_verify($data, $sig, $this->getConfig()->getPublicKey(), OPENSSL_ALGO_SHA256))
     {
-      return FidentNotification::fromString($data);
+      return FidentNotification::generate(Objects::property($notification, 'DataType', 1), $data);
     }
     return null;
   }

src/Notifications/FidentNotification.php

@@ -1,79 +1,20 @@
 <?php
 namespace Fident\Web\Notifications;
 
-use Fident\Web\UserData\UserAttribute;
-use Packaged\Helpers\Objects;
-
 class FidentNotification
 {
-  protected $_id;
-  protected $_created;
-  protected $_username;
-  protected $_attributes;
-  protected $_type;
-
   const SUCCESS_RESPONSE = 'con';
 
-  public static function fromString($rawNotificationData)
+  const DT_USER_UPDATE = 1;
+
+  public static function generate($dataType, $jsonString)
   {
-    $notification = new static();
-    $notificationData = json_decode($rawNotificationData);
-    $notification->_id = Objects::property($notificationData, 'ID');
-    $notification->_created = Objects::property($notificationData, 'Created');
-    $notification->_username = Objects::property($notificationData, 'Username');
-    $notification->_type = Objects::property($notificationData, 'Type');
-    $notification->_attributes = [];
-    foreach(Objects::property($notificationData, 'Attributes', []) as $attr)
+    switch($dataType)
     {
-      $notification->addAttribute(Objects::property($attr, 'Key'), Objects::property($attr, 'Value'));
+      case self::DT_USER_UPDATE:
+        return UserUpdateNotification::fromString($jsonString);
     }
-    return $notification;
-  }
-
-  public function addAttribute($key, $value)
-  {
-    $this->_attributes[$key] = new UserAttribute($key, $value);
-    return $this;
-  }
-
-  /**
-   * @return mixed
-   */
-  public function getId()
-  {
-    return $this->_id;
-  }
-
-  /**
-   * @return mixed
-   */
-  public function getCreated()
-  {
-    return $this->_created;
-  }
-
-  /**
-   * @return mixed
-   */
-  public function getUsername()
-  {
-    return $this->_username;
-  }
-
-  /**
-   * @return UserAttribute[]
-   */
-  public function getAttributes()
-  {
-    return $this->_attributes;
-  }
-
-  /**
-   * @return mixed
-   */
-  public function getType()
-  {
-    return $this->_type;
+    return null;
   }
 
 }

src/Notifications/UserUpdateNotification.php

@@ -0,0 +1,68 @@
+<?php
+namespace Fident\Web\Notifications;
+
+use Fident\Web\UserData\UserAttribute;
+use Packaged\Helpers\Objects;
+
+class UserUpdateNotification extends FidentNotification
+{
+  protected $_id;
+  protected $_created;
+  protected $_username;
+  protected $_attributes;
+
+  const SUCCESS_RESPONSE = 'con';
+
+  public static function fromString($rawNotificationData)
+  {
+    $notification = new static();
+    $notificationData = json_decode($rawNotificationData);
+    $notification->_id = Objects::property($notificationData, 'ID');
+    $notification->_created = Objects::property($notificationData, 'Created');
+    $notification->_username = Objects::property($notificationData, 'Username');
+    $notification->_attributes = [];
+    foreach(Objects::property($notificationData, 'Attributes', []) as $attr)
+    {
+      $notification->addAttribute(Objects::property($attr, 'Key'), Objects::property($attr, 'Value'));
+    }
+    return $notification;
+  }
+
+  public function addAttribute($key, $value)
+  {
+    $this->_attributes[$key] = new UserAttribute($key, $value);
+    return $this;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getId()
+  {
+    return $this->_id;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getCreated()
+  {
+    return $this->_created;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getUsername()
+  {
+    return $this->_username;
+  }
+
+  /**
+   * @return UserAttribute[]
+   */
+  public function getAttributes()
+  {
+    return $this->_attributes;
+  }
+}