feat: integrate the notification channel

bowphp · Jan 18, 2025 · ba182ad · ba182ad
1 parent 71da8ba
commit ba182ad
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 12 deletions.
diff --git a/src/Notification/Channel/ChannelInterface.php b/src/Notification/Channel/ChannelInterface.php
@@ -7,8 +7,7 @@ interface ChannelInterface
     /**
      * Send the notification
      *
-     * @param mixed $message
      * @return void
      */
-    public function send(mixed $message): void;
+    public function send(): void;
 }
diff --git a/src/Notification/Channel/DatabaseChannel.php b/src/Notification/Channel/DatabaseChannel.php
@@ -2,17 +2,22 @@
 
 namespace Bow\Notification\Channel;
 
-use Bow\Notification\Channel\ChannelInterface;
+use Bow\Database\Database;
 
 class DatabaseChannel implements ChannelInterface
 {
+    public function __construct(
+        private readonly array $database
+    ) {
+    }
+
     /**
      * Send the notification to database
      *
-     * @param mixed $message
      * @return void
      */
-    public function send(mixed $message): void
+    public function send(): void
     {
+        Database::table('notifications')->insert($this->database);
     }
 }
diff --git a/src/Notification/Channel/MailChannel.php b/src/Notification/Channel/MailChannel.php
@@ -7,16 +7,24 @@
 
 class MailChannel implements ChannelInterface
 {
+    /**
+     * Set the configured message
+     *
+     * @param Message $message
+     * @return void
+     */
+    public function __construct(
+        private readonly Message $message
+    ) {
+    }
+
     /**
      * Send the notification to mail
      *
-     * @param mixed $message
      * @return void
      */
-    public function send(mixed $message): void
+    public function send(): void
     {
-        if ($message instanceof Message) {
-            Mail::getInstance()->send($message);
-        }
+        Mail::getInstance()->send($this->message);
     }
 }
diff --git a/src/Notification/Notification.php b/src/Notification/Notification.php
@@ -61,8 +61,8 @@ final function process(Model $notifiable): void
         foreach ($channels as $channel) {
             if (array_key_exists($channel, $this->channels)) {
                 $result = $this->{"to" . ucfirst($channel)}($notifiable);
-                $target_channel = new $this->channels[$channel]();
-                $target_channel->send($result);
+                $target_channel = new $this->channels[$channel]($result);
+                $target_channel->send();
             }
         }
     }