[PLA-1975] Add custom queue (#285)

enjin · Nov 7, 2024 · fb7a777 · fb7a777
1 parent 18009e1
commit fb7a777
Show file tree

Hide file tree

Showing 60 changed files with 210 additions and 7 deletions.
diff --git a/config/enjin-platform.php b/config/enjin-platform.php
@@ -305,4 +305,14 @@
         'refresh_max_attempts' => env('REFRESH_METADATA_MAX_ATTEMPTS', 10),
         'refresh_decay_seconds' => env('REFRESH_METADATA_DECAY_SECONDS', 60),
     ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Queue
+    |--------------------------------------------------------------------------
+    |
+    | Here you may set the dedicated queue for this package
+    |
+    */
+    'queue' => env('PLATFORM_CORE_QUEUE', 'default'),
 ];
diff --git a/src/Events/Global/TransactionCreated.php b/src/Events/Global/TransactionCreated.php
@@ -4,11 +4,14 @@
 
 use Enjin\Platform\Events\PlatformBroadcastEvent;
 use Enjin\Platform\Support\Account;
+use Enjin\Platform\Traits\HasCustomQueue;
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 
 class TransactionCreated extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Global/TransactionUpdated.php b/src/Events/Global/TransactionUpdated.php
@@ -4,11 +4,14 @@
 
 use Enjin\Platform\Events\PlatformBroadcastEvent;
 use Enjin\Platform\Support\Account;
+use Enjin\Platform\Traits\HasCustomQueue;
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 
 class TransactionUpdated extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      *

diff --git a/src/Events/PlatformBroadcastEvent.php b/src/Events/PlatformBroadcastEvent.php
@@ -7,6 +7,7 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Broadcasting\InteractsWithSockets;
 use Illuminate\Broadcasting\PendingBroadcast;
+use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Foundation\Events\Dispatchable;
@@ -18,6 +19,7 @@ abstract class PlatformBroadcastEvent implements ShouldBroadcast
 {
     use Dispatchable;
     use InteractsWithSockets;
+    use Queueable;
     use SerializesModels;
 
     public ?Model $model = null;
@@ -54,6 +56,7 @@ public function __construct()
     {
         $this->className = (new \ReflectionClass(static::class))->getShortName();
         $this->uuid = Str::uuid()->toString();
+        $this->setQueue();
     }
 
     /**
@@ -146,4 +149,6 @@ protected function beforeBroadcast()
 
         return $event;
     }
+
+    protected function setQueue(): void {}
 }
diff --git a/src/Events/PlatformEvent.php b/src/Events/PlatformEvent.php
@@ -3,13 +3,15 @@
 namespace Enjin\Platform\Events;
 
 use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Bus\Queueable;
 use Illuminate\Foundation\Events\Dispatchable;
 use Illuminate\Queue\SerializesModels;
 
 abstract class PlatformEvent
 {
     use Dispatchable;
     use InteractsWithSockets;
+    use Queueable;
     use SerializesModels;
 
     /**
@@ -23,10 +25,13 @@ abstract class PlatformEvent
     public function __construct()
     {
         $this->className = (new \ReflectionClass(static::class))->getShortName();
+        $this->setQueue();
     }
 
     public function getClassName()
     {
         return $this->className;
     }
+
+    protected function setQueue(): void {}
 }
diff --git a/src/Events/Substrate/Balances/BalanceSet.php b/src/Events/Substrate/Balances/BalanceSet.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\BalanceSet as BalanceSetPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class BalanceSet extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Deposit.php b/src/Events/Substrate/Balances/Deposit.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Deposit as DepositPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Deposit extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/DustLost.php b/src/Events/Substrate/Balances/DustLost.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\DustLost as DustLostPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class DustLost extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Endowed.php b/src/Events/Substrate/Balances/Endowed.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Endowed as EndowedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Endowed extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/ReserveRepatriated.php b/src/Events/Substrate/Balances/ReserveRepatriated.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\ReserveRepatriated as ReserveRepatriatedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class ReserveRepatriated extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Reserved.php b/src/Events/Substrate/Balances/Reserved.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Reserved as ReservedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Reserved extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Slashed.php b/src/Events/Substrate/Balances/Slashed.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Slashed as SlashedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Slashed extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Teleport.php b/src/Events/Substrate/Balances/Teleport.php
@@ -4,11 +4,14 @@
 
 use Enjin\Platform\Channels\PlatformAppChannel;
 use Enjin\Platform\Events\PlatformBroadcastEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 
 class Teleport extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Transfer.php b/src/Events/Substrate/Balances/Transfer.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Transfer as TransferPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Transfer extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Unreserved.php b/src/Events/Substrate/Balances/Unreserved.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Unreserved as UnreservedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Unreserved extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Balances/Withdraw.php b/src/Events/Substrate/Balances/Withdraw.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\Balances\Withdraw as WithdrawPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class Withdraw extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/Commands/PlatformBlockIngested.php b/src/Events/Substrate/Commands/PlatformBlockIngested.php
@@ -3,5 +3,9 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
-class PlatformBlockIngested extends PlatformEvent {}
+class PlatformBlockIngested extends PlatformEvent
+{
+    use HasCustomQueue;
+}
diff --git a/src/Events/Substrate/Commands/PlatformBlockIngesting.php b/src/Events/Substrate/Commands/PlatformBlockIngesting.php
@@ -3,5 +3,9 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
-class PlatformBlockIngesting extends PlatformEvent {}
+class PlatformBlockIngesting extends PlatformEvent
+{
+    use HasCustomQueue;
+}
diff --git a/src/Events/Substrate/Commands/PlatformEventCached.php b/src/Events/Substrate/Commands/PlatformEventCached.php
@@ -3,9 +3,12 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class PlatformEventCached extends PlatformEvent
 {
+    use HasCustomQueue;
+
     public function __construct(public $cachedEvent)
     {
         parent::__construct();

diff --git a/src/Events/Substrate/Commands/PlatformSyncError.php b/src/Events/Substrate/Commands/PlatformSyncError.php
@@ -3,9 +3,12 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class PlatformSyncError extends PlatformEvent
 {
+    use HasCustomQueue;
+
     public function __construct(public string $message)
     {
         parent::__construct();

diff --git a/src/Events/Substrate/Commands/PlatformSynced.php b/src/Events/Substrate/Commands/PlatformSynced.php
@@ -3,5 +3,9 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
-class PlatformSynced extends PlatformEvent {}
+class PlatformSynced extends PlatformEvent
+{
+    use HasCustomQueue;
+}
diff --git a/src/Events/Substrate/Commands/PlatformSyncing.php b/src/Events/Substrate/Commands/PlatformSyncing.php
@@ -3,5 +3,9 @@
 namespace Enjin\Platform\Events\Substrate\Commands;
 
 use Enjin\Platform\Events\PlatformEvent;
+use Enjin\Platform\Traits\HasCustomQueue;
 
-class PlatformSyncing extends PlatformEvent {}
+class PlatformSyncing extends PlatformEvent
+{
+    use HasCustomQueue;
+}
diff --git a/src/Events/Substrate/MultiTokens/CollectionAccountCreated.php b/src/Events/Substrate/MultiTokens/CollectionAccountCreated.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\CollectionAccountCreated as CollectionAccountCreatedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionAccountCreated extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/MultiTokens/CollectionAccountDestroyed.php b/src/Events/Substrate/MultiTokens/CollectionAccountDestroyed.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\CollectionAccountDestroyed as CollectionAccountDestroyedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionAccountDestroyed extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/MultiTokens/CollectionAccountFrozen.php b/src/Events/Substrate/MultiTokens/CollectionAccountFrozen.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\Frozen as CollectionAccountFrozenPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionAccountFrozen extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/MultiTokens/CollectionAccountThawed.php b/src/Events/Substrate/MultiTokens/CollectionAccountThawed.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\Thawed as CollectionAccountThawedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionAccountThawed extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/MultiTokens/CollectionApproved.php b/src/Events/Substrate/MultiTokens/CollectionApproved.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\Approved as CollectionApprovedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionApproved extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */

diff --git a/src/Events/Substrate/MultiTokens/CollectionAttributeRemoved.php b/src/Events/Substrate/MultiTokens/CollectionAttributeRemoved.php
@@ -7,9 +7,12 @@
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Database\Eloquent\Model;
 use Enjin\Platform\Services\Processor\Substrate\Codec\Polkadart\Events\MultiTokens\AttributeRemoved as CollectionAttributeRemovedPolkadart;
+use Enjin\Platform\Traits\HasCustomQueue;
 
 class CollectionAttributeRemoved extends PlatformBroadcastEvent
 {
+    use HasCustomQueue;
+
     /**
      * Create a new event instance.
      */