Update notifications with socket

Author: fadymondy

Config/config.php

@@ -51,6 +51,10 @@
             "name" => __('Database'),
             "id" => "database"
         ],
+        [
+            "name" => "Socket",
+            "id" => "socket"
+        ],
         [
             "name" => __('Email'),
             "id" => "email"

Events/FireEvent.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace Modules\Notifications\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class FireEvent implements ShouldBroadcast
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     *
+     * @return void
+     */
+    public function __construct(
+        public ?string $title,
+        public ?string $message,
+        public ?string $icon,
+        public ?string $image,
+        public ?string $url,
+        public ?string $type,
+        public ?string $privacy,
+        public ?string $provider,
+        public ?string $model,
+        public ?string $model_id
+    ){}
+
+    public function broadcastAs(): string
+    {
+        return 'notification';
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return Channel
+     */
+    public function broadcastOn() :Channel
+    {
+        return new Channel('private.' . $this->model_id);
+    }
+}

Routes/web.php

@@ -1,5 +1,6 @@
 <?php
 
+use Illuminate\Support\Facades\Broadcast;
 use Illuminate\Support\Facades\Route;
 use Modules\Notifications\Http\Controllers\NotificationsController;
 
@@ -14,6 +15,9 @@
 |
 */
 
+Broadcast::channel('private.{userId}', function ($user, $userId) {
+    return true;
+});
 
  Route::middleware([
      'auth:sanctum',

Services/Actions/SendToJob.php

@@ -36,13 +36,62 @@ public function sendToJob():void
                 }
                 if (count($collectRoles)) {
                     if ($this->user->hasRole($collectRoles)) {
-                        NotificationJop::dispatch($arrgs);
+                        if($provider === 'socket'){
+                            \Modules\Notifications\Events\FireEvent::dispatch(
+                                $this->title,
+                                $this->message,
+                                $this->icon,
+                                $this->image,
+                                $this->url,
+                                $this->type,
+                                $this->privacy,
+                                $provider,
+                                $this->model,
+                                $this->user->id
+                            );
+                        }
+                        else {
+                            NotificationJop::dispatch($arrgs);
+                        }
+
                     }
                 } else {
-                    NotificationJop::dispatch($arrgs);
+                    if($provider === 'socket'){
+                        \Modules\Notifications\Events\FireEvent::dispatch(
+                            $this->title,
+                            $this->message,
+                            $this->icon,
+                            $this->image,
+                            $this->url,
+                            $this->type,
+                            $this->privacy,
+                            $provider,
+                            $this->model,
+                            $this->user->id
+                        );
+                    }
+                    else {
+                        NotificationJop::dispatch($arrgs);
+                    }
                 }
             } else {
-                NotificationJop::dispatch($arrgs);
+                if($provider === 'socket'){
+                    \Modules\Notifications\Events\FireEvent::dispatch(
+                        $this->title,
+                        $this->message,
+                        $this->icon,
+                        $this->image,
+                        $this->url,
+                        $this->type,
+                        $this->privacy,
+                        $provider,
+                        $this->model,
+                        $this->user->id
+                    );
+                }
+                else {
+                    NotificationJop::dispatch($arrgs);
+                }
             }
         }
     }