04 - Usage.md

Now, send notifications!

Here's a sample example of an e-commerce app which will notify both the customer and the related category managers when an order has been placed.

namespace App\Services;

use App\Entity\Employee;
use App\Entity\Order;
use App\Events\OrderEvent;
use App\Events\OrderEvents;
use BenTools\WebPushBundle\Model\Message\PushNotification;
use BenTools\WebPushBundle\Model\Subscription\UserSubscriptionManagerRegistry;
use BenTools\WebPushBundle\Sender\PushMessageSender;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class NotificationSenderListener implements EventSubscriberInterface
{
    /**
     * @var UserSubscriptionManagerRegistry
     */
    private $userSubscriptionManager;

    /**
     * @var PushMessageSender
     */
    private $sender;

    /**
     * NotificationSender constructor.
     * @param UserSubscriptionManagerRegistry $userSubscriptionManager
     * @param PushMessageSender               $sender
     */
    public function __construct(
        UserSubscriptionManagerRegistry $userSubscriptionManager,
        PushMessageSender $sender
    ) {
        $this->userSubscriptionManager = $userSubscriptionManager;
        $this->sender = $sender;
    }

    public static function getSubscribedEvents()
    {
        return [
            OrderEvents::PLACED => 'onOrderPlaced',
        ];
    }

    /**
     * @param OrderEvent $event
     */
    public function onOrderPlaced(OrderEvent $event): void
    {
        $order = $event->getOrder();
        $this->notifyCustomer($order);
        $this->notifyCategoryManagers($order);
    }

    /**
     * @param Order $order
     */
    private function notifyCustomer(Order $order): void
    {
        $customer = $order->getCustomer();
        $subscriptions = $this->userSubscriptionManager->findByUser($customer);
        $notification = new PushNotification('Congratulations!', [
            PushNotification::BODY => 'Your order has been placed.',
            PushNotification::ICON => '/assets/icon_success.png',
        ]);
        $responses = $this->sender->push($notification->createMessage(), $subscriptions);

        foreach ($responses as $response) {
            if ($response->isExpired()) {
                $this->userSubscriptionManager->delete($response->getSubscription());
            }
        }
    }

    /**
     * @param Order $order
     */
    private function notifyCategoryManagers(Order $order): void
    {
        $products = $order->getProducts();
        $employees = [];
        foreach ($products as $product) {
            $employees[] = $product->getCategoryManager();
        }

        $employees = array_unique($employees);

        $subscriptions = [];
        foreach ($employees as $employee) {
            foreach ($this->userSubscriptionManager->findByUser($employee) as $subscription) {
                $subscriptions[] = $subscription;
            }
        }

        $notification = new PushNotification('A new order has been placed!', [
            PushNotification::BODY => 'A customer just bought some of your products.',
            PushNotification::ICON => '/assets/icon_success.png',
        ]);

        $responses = $this->sender->push($notification->createMessage(), $subscriptions);

        foreach ($responses as $response) {
            if ($response->isExpired()) {
                $this->userSubscriptionManager->delete($response->getSubscription());
            }
        }
    }
}

Previous: Configuration

Next: F.A.Q.