Send push notifications about user's orders

Author: simonesestito

src/controller/ShoppingListController.php

@@ -20,10 +20,12 @@
 class ShoppingListController extends BaseController {
     private $shoppingListDao;
     private $productDao;
+    private $fcmService;
 
-    public function __construct(ShoppingListDao $shoppingListDao, ProductDao $productDao) {
+    public function __construct(ShoppingListDao $shoppingListDao, ProductDao $productDao, FcmService $fcmService) {
         $this->shoppingListDao = $shoppingListDao;
         $this->productDao = $productDao;
+        $this->fcmService = $fcmService;
         $this->registerRoute('/users/me/lists', 'GET', 'USER', 'getMyLists');
         $this->registerRoute('/shops/me/lists', 'GET', 'OWNER', 'getMyShopLists');
         $this->registerRoute('/lists', 'POST', 'USER', 'addList');
@@ -91,15 +93,21 @@ public function deleteList(int $listId) {
         $userRole = $authContext['role'];
         $userShopId = $authContext['shopId'];
 
-        $shoppingList = $this->shoppingListDao->getListById($listId);
-        if ($shoppingList == null)
+        $entity = $this->shoppingListDao->getListById($listId);
+        if ($entity == null)
             throw new AppHttpException(HTTP_NOT_FOUND);
+        $shoppingList = new ShoppingList($entity);
 
-        if ($shoppingList[0]['userId'] == $userId) {
+        if ($shoppingList->userId == $userId) {
             $this->shoppingListDao->deleteShoppingList($listId);
-        } elseif ($userRole == 'OWNER' && $shoppingList[0]['shopId'] == $userShopId) {
-            if (!$shoppingList[0]['isReady']) {
-                // TODO: push notification
+        } elseif ($userRole == 'OWNER' && $shoppingList->shop->id == $userShopId) {
+            if (!$shoppingList->isReady) {
+                // Send push notification
+                $this->fcmService->sendPayloadToUser(
+                    $shoppingList->userId,
+                    FCM_TYPE_ORDER_CANCELLED,
+                    $shoppingList
+                );
             }
             $this->shoppingListDao->deleteShoppingList($listId);
         } else {
@@ -120,7 +128,16 @@ public function prepareList(int $listId) {
         if ($entity == null)
             throw new AppHttpException(HTTP_NOT_FOUND);
 
-        // TODO: Push notification
+        $shoppingList = new ShoppingList($entity);
+        if ($shoppingList->shop->id != AuthService::getAuthContext()['shopId'])
+            throw new AppHttpException(HTTP_NOT_AUTHORIZED);
+
+        // Send push notification
+        $this->fcmService->sendPayloadToUser(
+            $shoppingList->userId,
+            FCM_TYPE_ORDER_READY,
+            $shoppingList
+        );
 
         return new ShoppingList($entity);
     }

src/service/FcmService.php

@@ -19,6 +19,8 @@
 
 define('FCM_TYPE_BOOKING_CANCELLED', 'booking-cancelled');
 define('FCM_TYPE_QUEUE_NOTICE', 'queue-notice');
+define('FCM_TYPE_ORDER_READY', 'order-ready');
+define('FCM_TYPE_ORDER_CANCELLED', 'order-cancelled');
 
 class FcmService {
     private $fcmDao;
@@ -48,13 +50,13 @@ public function sendPayloadToUser(int $userId, string $messageType, $messageData
      * @param string $messageType The type of the message (e.g.: booking-cancelled)
      * @param mixed $messageData Data to send
      */
-    public function sendPayloadOrDeleteToken(string $token, string $messageType, $messageData) {
+    private function sendPayloadOrDeleteToken(string $token, string $messageType, $messageData) {
         if (FCM_SERVER_KEY === '') {
             throw new RuntimeException('FCM server key not found in env variables');
         }
 
         $url = 'https://fcm.googleapis.com/fcm/send';
-        $headers = [ 'Authorization: key=' . FCM_SERVER_KEY ];
+        $headers = ['Authorization: key=' . FCM_SERVER_KEY];
         $body = [
             'to' => $token,
             'data' => [