fix undefined key with queue

Author: Shadow243

services/Core/Jobs/Hm_BaseJob.php

@@ -9,5 +9,6 @@ abstract class Hm_BaseJob extends Hm_Queueable implements Hm_Job
 {
     public function __construct(protected array $data = []) {
         $this->data = $data;
+        $this->driver = env('QUEUE_DRIVER');
     }
 }

services/Core/Notifications/Hm_Notification.php

@@ -29,6 +29,7 @@ class Hm_Notification extends Hm_Queueable implements Hm_Dispatcher
     public function __construct($content = '')
     {
         $this->content = $content;
+        $this->driver = env('QUEUE_DRIVER');
     }
     /**
      * Notifcations can be sent through multiple channels.
@@ -43,7 +44,7 @@ public function via(): array
     public function handle(): void
     {
         dump("Processing ".self::class);
-        
+
         $this->sendNow();
     }
     public function failed(): void

services/Core/Notifications/Hm_NotificationDispatcher.php

@@ -32,26 +32,12 @@ class Hm_NotificationDispatcher implements Hm_Factory
      */
     public static function send(Hm_Notification $notification): void
     {
-        $channels = $notification->via();
-        foreach ($channels as $channelName) {
-            if (isset(self::$channelClasses[$channelName])) {
-                $channelClass = self::channel($channelName);
-                $channel = new $channelClass();
-                if (is_subclass_of($notification, Hm_ShouldQueue::class)) {
-                    $driver = $notification->driver;
-                    $queueDriver = Hm_Container::getContainer()->get('queue.manager')->getDriver($driver);
-                    if ($queueDriver) {
-                        $queueDriver->push($notification);
-                    } else {
-                        throw new \Exception("Queue driver {$driver} not found.");
-                    }
-                } else {
-                    // Send notification immediately if not queued
-                    $channel->send($notification);
-                }
-            } else {
-                throw new \Exception("Channel {$channelName} is not registered or implemented.");
-            }
+        $driver = $notification->driver;
+        $queueDriver = Hm_Container::getContainer()->get('queue.manager')->getDriver($driver);
+        if ($queueDriver) {
+            $queueDriver->push($notification);
+        } else {
+            throw new \Exception("Queue driver {$driver} not found.");
         }
     }
 

services/Notifications/Hm_NewMailNotification.php

@@ -11,15 +11,10 @@ class Hm_NewMailNotification extends Hm_Notification implements Hm_ShouldQueue
 {
     use Hm_Dispatchable, Hm_InteractsWithQueue;
 
-    public string $driver = 'redis';
-
-    // public function __construct(array $config = [])
-    // {
-    //     parent::__construct($config);
-    // }
+    public string $driver = 'database';
 
     public function via(): array
     {
-        return ['telegram'];//, 'slack', 'telegram','broadcast'
+        return ['telegram','slack'];//, 'slack', 'telegram','broadcast'
     }
 }