fix dispatchBatch not injecting attributes + add unit test

Author: matthewgoslett

src/EventManager.php

@@ -176,6 +176,7 @@ public function dispatch($channel, EventInterface $event)
     public function dispatchBatch($channel, array $events)
     {
         $messages = array_map(function (EventInterface $event) {
+            $event = $this->prepEventForDispatch($event);
             return $event->toMessage();
         }, $events);
         $this->adapter->publishBatch($channel, $messages);

tests/EventManagerTest.php

@@ -188,4 +188,51 @@ public function testDispatchBatch()
         ];
         $manager->dispatchBatch('channel', $events);
     }
+
+    public function testDispatchBatchWithInjections()
+    {
+        $adapter = Mockery::mock(PubSubAdapterInterface::class);
+        $adapter->shouldReceive('publishBatch')
+            ->withArgs([
+                'channel',
+                [
+                    [
+                        'event' => 'user.created',
+                        'user' => [
+                            'id' => 1234,
+                        ],
+                        'service' => 'user-api',
+                        'cluster' => 'api',
+                    ],
+                    [
+                        'event' => 'user.created',
+                        'user' => [
+                            'id' => 7812,
+                        ],
+                        'service' => 'user-api',
+                        'cluster' => 'api',
+                    ],
+                ],
+            ]);
+
+        $translator = Mockery::mock(MessageTranslatorInterface::class);
+
+        $injectors = [
+            new GenericAttributeInjector('service', 'user-api'),
+            function () {
+                return [
+                    'key' => 'cluster',
+                    'value' => 'api',
+                ];
+            },
+        ];
+
+        $manager = new EventManager($adapter, $translator, null, $injectors);
+
+        $events = [
+            new SimpleEvent('user.created', ['user' => ['id' => 1234]]),
+            new SimpleEvent('user.created', ['user' => ['id' => 7812]]),
+        ];
+        $manager->dispatchBatch('channel', $events);
+    }
 }