Real time chat pusher

.env.example

@@ -13,7 +13,7 @@ DB_DATABASE=your_database_name
 DB_USERNAME=homestead
 DB_PASSWORD=secret
 
-BROADCAST_DRIVER=log
+BROADCAST_DRIVER=pushser
 CACHE_DRIVER=file
 QUEUE_CONNECTION=sync
 SESSION_DRIVER=file
@@ -39,6 +39,3 @@ PUSHER_APP_ID=
 PUSHER_APP_KEY=
 PUSHER_APP_SECRET=
 PUSHER_APP_CLUSTER=mt1
-
-MIX_PUSHER_APP_KEY="${PUSHER_APP_KEY}"
-MIX_PUSHER_APP_CLUSTER="${PUSHER_APP_CLUSTER}"

.env.example.develop

@@ -0,0 +1,40 @@
+APP_NAME=Laravel
+APP_ENV=local
+APP_KEY=
+APP_DEBUG=true
+APP_URL=http://localhost
+
+LOG_CHANNEL=stack
+
+DB_CONNECTION=sqlite
+DB_DATABASE=database.sqlite
+
+BROADCAST_DRIVER=pusher
+CACHE_DRIVER=file
+QUEUE_CONNECTION=sync
+SESSION_DRIVER=file
+SESSION_LIFETIME=120
+
+REDIS_HOST=127.0.0.1
+REDIS_PASSWORD=null
+REDIS_PORT=6379
+
+MAIL_DRIVER=smtp
+MAIL_HOST=smtp.mailtrap.io
+MAIL_PORT=2525
+MAIL_USERNAME=null
+MAIL_PASSWORD=null
+MAIL_ENCRYPTION=null
+
+AWS_ACCESS_KEY_ID=
+AWS_SECRET_ACCESS_KEY=
+AWS_DEFAULT_REGION=us-east-1
+AWS_BUCKET=
+
+PUSHER_APP_ID=
+PUSHER_APP_KEY=
+PUSHER_APP_SECRET=
+PUSHER_HOST=
+PUSHER_PORT=
+PUSHER_SCHEME=
+PUSHER_APP_CLUSTER=

.gitignore

@@ -9,3 +9,7 @@ Homestead.json
 Homestead.yaml
 npm-debug.log
 yarn-error.log
+
+
+#JetBrainIDE
+.idea/

app/Events/GotMessage.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace App\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class GotMessage implements ShouldBroadcast
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    // コンストラクタにfriend_idを追加
+    public function __construct(public array $message, public string $channelName) {
+
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array {
+        return [
+            new Channel($this->channelName),  // チャネル名を引数から動的に作成
+        ];
+    }
+}

app/Friendship.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App;
+
+use Illuminate\Database\Eloquent\Model;
+
+class Friendship extends Model
+{
+    protected $fillable = [
+        'user_id',
+        'friend_id',
+        'status'
+    ];
+
+    public function user()
+    {
+        return $this->belongsTo(User::class, 'user_id');
+    }
+
+    public function friend()
+    {
+        return $this->belongsTo(User::class, 'friend_id');
+    }
+}

app/Http/Controllers/AuthController.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\User;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Hash;
+
+class AuthController extends Controller
+{
+    public function register(Request $request){ 
+        $validatedData = $request->validate([
+            'name' => 'required|string|max:255',
+            'email' => 'required|string|email|max:255|unique:users',
+            'password' => 'required|string|min:6|confirmed',
+        ]);
+
+        $validatedData['password'] = hash::make($validatedData['password']);
+        $user = User::create($validatedData);
+        $token = $user->createToken($user->name)->plainTextToken;
+        return ['user' => $user, 'token' => $token];
+    }
+
+    public function login(Request $request){
+        $validatedData = $request->validate([
+            'email' => 'required|string|email|exists:users',
+            'password' => 'required|string|min:6',
+        ]);
+
+        $user = User::where('email', $validatedData['email'])->first();
+        if(!$user || !Hash::check($validatedData['password'], $user->password)){
+            return response()->json(['errors' => ['email' => 'The provided credentials are incorrect.']], 401);
+        }
+
+        $token = $user->createToken($user->name)->plainTextToken;
+        return ['user' => $user, 'token' => $token];
+    }
+
+    public function logout(Request $request){
+        $request->user()->tokens()->delete();
+        return ["message" => "logout"];
+    }
+}

app/Http/Controllers/FriendshipController.php

@@ -0,0 +1,131 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Friendship;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+
+class FriendshipController extends Controller
+{
+    public function sendRequest(Request $request){
+        $friend_id = $request->friend_id;
+        if(Friendship::where(['user_id' => $request->user()->id, 'friend_id' => $friend_id, 'status' => 'pending'])->exists() ||
+            Friendship::where(['user_id' => $request->user()->id, 'friend_id' => $friend_id, 'status' => 'accepted'])->exists()){
+            return response()->json(['message' => "requested already"]);
+        }
+        else{
+            $rejected_request = Friendship::where([
+                'user_id' => $request->user()->id,
+                'friend_id' => $friend_id,
+                'status' => 'rejected'])->first();
+            if($rejected_request){
+                $rejected_request->status = "pending";
+                $rejected_request->save();
+                return response()->json(['message' => "request sent (it was rejected previously)"]);
+            }
+        }
+        $request->user()->friends()->attach($friend_id, ['status' => 'pending']);
+        return response()->json(['message' => "request sent"]);
+    }
+
+    public function acceptRequest(Request $request){//この$user_idは現在のユーザーに対してリクエストを送ってきた相手のuserid(自分のではない)
+        $user_id = $request->user_id;
+        $friendship_request = Friendship::where([
+            'user_id' => $user_id,
+            'friend_id' => $request->user()->id,
+            'status' => 'pending'])->first();
+        if($friendship_request){
+            $friendship_request->status = 'accepted';
+            $friendship_request->save();
+
+            $friendship_request_another_side = Friendship::where([
+                'user_id' => $request->user()->id,
+                'friend_id' => $user_id])->first();
+            if($friendship_request_another_side){
+                $friendship_request_another_side->status = 'accepted';
+                $friendship_request_another_side->save();
+            }else{
+                Friendship::create([
+                    'user_id' => $request->user()->id,
+                    'friend_id' => $user_id,
+                    'status' => 'accepted'
+                ]);
+            }
+
+            return response()->json(['message' => 'Request accepted']);
+        }else{
+            return response()->json(['message' => 'request not found'], 400);
+        }
+    }
+
+    public function rejectRequest(Request $request){//この$user_idは現在のユーザーに対してリクエストを送ってきた相手のuserid(自分のではない)
+        $user_id = $request->user_id;
+        $friendship_request = Friendship::where([
+            'user_id' => $user_id,
+            'friend_id' => $request->user()->id ,
+            'status' => 'pending'])->first();
+        if($friendship_request){
+            $friendship_request->status = 'rejected';
+            $friendship_request->save();
+            return response()->json(['message' => 'Request rejected']);
+        }
+        else{
+            return response()->json(['message' => 'request not found'], 400);
+        }
+    }
+
+
+    public function unfriend(Request $request){
+        $friendship_request = Friendship::where([
+            'user_id' => $request->user()->id,
+            'friend_id' => $request->friend_id,
+            'status' => 'accepted'])->first();
+        if(!$friendship_request){
+            return response()->json(['message' => 'request not found'], 400);
+        }
+        $friendship_request->status = 'rejected';
+        $friendship_request->save();
+        $friendship_request_another_side = Friendship::where([
+            'user_id' => $request->friend_id,
+            'friend_id' => $request->user()->id,
+            'status' => 'accepted'])->first();
+        if($friendship_request_another_side){
+            $friendship_request_another_side->status = 'rejected';
+            $friendship_request_another_side->save();
+            return response()->json(['message' => 'unfriended successfully']);
+        }
+    }
+    public function getFriends(Request $request){
+        return $request->user()->friends;
+    }
+
+    public function getFriendRequestSenders(Request $request){
+        $friendship_request_senders = Friendship::where([
+            'friend_id' => $request->user()->id,
+        ])->whereIn('status', ["pending"])->with('user')->get();
+
+        return $friendship_request_senders->pluck('user');
+    }
+
+    public function getStatus(Request $request){
+        $friend_id = $request->friend_id;
+        $friendship_request_another_side = Friendship::where([
+            'user_id' => $friend_id,
+            'friend_id' => $request->user()->id,
+        ])->whereIn('status', ["pending"])->first();
+        if($friendship_request_another_side){
+            return response()->json(["status" => "accept?"]);
+        }
+
+        $friendship_request = Friendship::where([
+            'user_id' => $request->user()->id,
+            'friend_id' => $friend_id,
+        ])->whereIn('status', ["pending", "accepted", "rejected"])->first();
+        if($friendship_request){
+            return response()->json(["status" => $friendship_request->status]);
+        }else{
+            return response()->json(["status" => '']);
+        }
+    }
+}

app/Http/Controllers/MessageController.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Jobs\SendMessage;
+use App\Message;
+use App\User;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+
+class MessageController extends Controller
+{
+    public function __construct() {
+        $this->middleware('auth');
+    }
+
+    public function messages(Request $request): JsonResponse {
+        $chatId = $request->chat_id;
+        $messages = Message::where('chat_id', $chatId)
+            ->orderBy('created_at', 'asc')
+            ->get()->append("time");
+
+        return response()->json($messages);
+    }
+
+    public function message(Request $request): JsonResponse {
+        $channelName = $request->chat_id;
+        $message = Message::create([
+            'user_id' => auth()->id(),
+            'chat_id' => $channelName,
+            'text' => $request->get('text'),
+        ]);
+        SendMessage::dispatch($message, $channelName);
+
+        return response()->json([
+            'success' => true,
+            'message' => "Message created and job dispatched.",
+        ]);
+    }
+}