Add create claim completed (#30)

src/Events/CreateBeamClaimsCompleted.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace Enjin\Platform\Beam\Events;
+
+use Enjin\Platform\Beam\Channels\PlatformBeamChannel;
+use Enjin\Platform\Channels\PlatformAppChannel;
+use Enjin\Platform\Events\PlatformBroadcastEvent;
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Support\Arr;
+
+class CreateBeamClaimsCompleted extends PlatformBroadcastEvent
+{
+    /**
+     * Creates a new event instance.
+     */
+    public function __construct(array $data)
+    {
+        parent::__construct();
+
+        $this->broadcastData = $data;
+
+        $this->broadcastChannels = [
+            new Channel('beam;' . Arr::get($data, 'code')),
+            new PlatformAppChannel(),
+            new PlatformBeamChannel(),
+        ];
+    }
+}

src/Jobs/CreateBeamClaims.php

@@ -2,6 +2,8 @@
 
 namespace Enjin\Platform\Beam\Jobs;
 
+use Enjin\Platform\Beam\Events\CreateBeamClaimsCompleted;
+use Enjin\Platform\Beam\Models\Beam;
 use Enjin\Platform\Beam\Models\BeamClaim;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -32,6 +34,15 @@ public function handle(): void
         if ($this->chunk) {
             $timestamp = ['created_at' => $now = now(), 'updated_at' => $now];
             BeamClaim::insert($this->chunk->map(fn ($claim) => array_merge($claim, $timestamp))->toArray());
+
+            $this->chunk
+                ->pluck('beam_id', 'beam_id')
+                ->each(
+                    fn ($beamId) => event(
+                        new CreateBeamClaimsCompleted(Beam::select('id', 'code')->find($beamId)->toArray())
+                    )
+                );
+
             unset($this->chunk);
         }
     }