feat : realtime with laravel websocket

.env.sample

@@ -48,9 +48,6 @@ AWS_USE_PATH_STYLE_ENDPOINT=false
 PUSHER_APP_ID=
 PUSHER_APP_KEY=
 PUSHER_APP_SECRET=
-PUSHER_HOST=
-PUSHER_PORT=443
-PUSHER_SCHEME=https
 PUSHER_APP_CLUSTER=mt1
 
 VITE_PUSHER_APP_KEY="${PUSHER_APP_KEY}"

README.md

@@ -34,6 +34,12 @@ example for get route list:
 docker container exec php php artisan route:list
 ```
 
+# Running websocket
+
+```
+docker container exec php php artisan websockets:serve
+```
+
 # ++ Feature
 
 - Hot Reload NextJs. you dont need rebuild container in development
@@ -46,6 +52,8 @@ docker container exec php php artisan route:list
 
 - For documentaion,  open 127.0.0.1:8000/api/documentation or http://localhost:8000/api/documentation
 
+- For realtime socket dashboard, open 127.0.0.1/laravel-websockets
+
 
 # Contributing
 

api/app/Events/NewMessageEvent.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class NewMessageEvent implements ShouldBroadcast
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     *
+     * @return void
+     */
+    protected $user;
+    public $id, $room;
+    public function __construct($user, $id, $room)
+    {
+        $this->user = $user;
+        $this->id = $id;
+        $this->room = $room;
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return \Illuminate\Broadcasting\Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new Channel('Cetan-'.$this->user);
+    }
+    public function broadcastAs()
+    {
+        return 'NewMessage';
+    }
+}

api/app/Http/Controllers/MessageController.php

@@ -5,6 +5,7 @@
 use App\Models\Room;
 use App\Models\Message;
 use Illuminate\Http\Request;
+use App\Events\NewMessageEvent;
 use App\Http\Resources\MessageResource;
 
 class MessageController extends Controller
@@ -31,6 +32,8 @@ public function store(Request $request)
             ]);
             $room->updated_at = now();
             $room->save();
+            $op = $room->user_1_id == $request->user()->id ? $room->user_2_id : $room->user_1_id;
+            broadcast(new NewMessageEvent($op, $message->id, $room->id));
             return (new MessageResource($message))
                     ->response()
                     ->setStatusCode(201);
@@ -67,7 +70,7 @@ public function getMessageById(Request $request, Message $message)
     {
         try {
             $room = Room::find($message->room_id);
-            if(($room->user_1_id != $request->user()->id && $room->user_2_id != $request->user()->id) || $message->user_id == $request->user()->id)
+            if(($room->user_1_id != $request->user()->id && $room->user_2_id != $request->user()->id))
             {
                 return response()->json([
                     'status'=>'No Content'

api/composer.json

@@ -6,11 +6,13 @@
     "license": "MIT",
     "require": {
         "php": "^8.0.2",
+        "beyondcode/laravel-websockets": "^1.13",
         "darkaonline/l5-swagger": "^8.3",
         "guzzlehttp/guzzle": "^7.2",
         "laravel/framework": "^9.19",
         "laravel/sanctum": "^2.15",
-        "laravel/tinker": "^2.7"
+        "laravel/tinker": "^2.7",
+        "pusher/pusher-php-server": "^7.0"
     },
     "require-dev": {
         "fakerphp/faker": "^1.9.1",