[Events] Skip message dispatch on subscriber when decoration fails (#7)

* [Exceptions] Create custom Invalid payload exception

* [Events] Add try..catch on decorate call when dispatching events

* [Changelog] Add event dispatch change to changelog 2.1 md

* Fix class name in invalid payload exception

* [Events] Add type of exception thrown in abstract function decorate

Author: renato-bylyk

CHANGELOG-2.1.md

@@ -7,6 +7,9 @@ in all versions (major and minor)
 To get the diff for a specific change, go to https://github.com/PandaPlatform/framework/commit/XXX where
 XXX is the change hash
 
+* 2.1.11
+  * [Events] Add try..catch on decorate call when dispatching events
+
 * 2.1.10
   * [Routing] Log the request not found information
 

src/Panda/Events/Event.php

@@ -15,6 +15,7 @@
 use Panda\Events\Channels\ChannelInterface;
 use Panda\Events\Messages\DecoratorInterface;
 use Panda\Events\Messages\MessageInterface;
+use Panda\Support\Exceptions\InvalidPayloadException;
 
 /**
  * Class Event
@@ -42,6 +43,7 @@ abstract public function getChannelFactory();
      * @param ChannelInterface $channel
      *
      * @return MessageInterface
+     * @throws InvalidPayloadException
      */
     abstract public function decorate(MessageInterface $message, ChannelInterface $channel = null);
 
@@ -72,8 +74,13 @@ public function dispatch()
             // Get proper message for the given channel
             $message = $this->getMessage($channel);
 
-            // Decorate message
-            $message = $this->decorate($message, $channel);
+            try {
+                // Decorate message
+                $message = $this->decorate($message, $channel);
+            } catch (InvalidPayloadException $ex) {
+                // Continue to next subscriber
+                continue;
+            }
 
             // Dispatch to all subscribers
             /** @var SubscriberInterface $subscriber */

src/Panda/Support/Exceptions/InvalidPayloadException.php

@@ -0,0 +1,22 @@
+<?php
+
+/*
+ * This file is part of the Panda framework.
+ *
+ * (c) Ioannis Papikas <papikas.ioan@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Panda\Support\Exceptions;
+
+use Exception;
+
+/**
+ * Class InvalidPayloadException
+ * @package Panda\Support\Exceptions
+ */
+class InvalidPayloadException extends Exception
+{
+}