implemented add/remove participant

src/Http/Controllers/ConversationController.php

@@ -5,6 +5,7 @@
 use Illuminate\Http\Request;
 use Myckhel\ChatSystem\Http\Requests\PaginableRequest;
 use DB;
+use Myckhel\ChatSystem\Traits\Config;
 
 class ConversationController extends Controller
 {
@@ -99,7 +100,7 @@ public function store(Request $request)
      */
     public function show(Request $request, $conversation)
     {
-      $conversation = config('chat-system.models.conversation')::findOrFail($conversation);
+      $conversation = Config::config('models.conversation')::findOrFail($conversation);
       $this->authorize('view', $conversation);
       $user = $request->user();
 
@@ -129,7 +130,7 @@ public function show(Request $request, $conversation)
      */
     public function update(Request $request, $conversation)
     {
-      $conversation = config('chat-system.models.conversation')::findOrFail($conversation);
+      $conversation = Config::config('models.conversation')::findOrFail($conversation);
       $this->authorize('update', $conversation);
 
       @[
@@ -158,7 +159,7 @@ public function update(Request $request, $conversation)
      */
     public function destroy(Request $request, $conversation)
     {
-      $conversation = config('chat-system.models.conversation')::findOrFail($conversation);
+      $conversation = Config::config('models.conversation')::findOrFail($conversation);
       $this->authorize('delete', $conversation);
       $user = $request->user();
       return ['status' => $conversation->makeDelete($user)];
@@ -178,4 +179,18 @@ function count(PaginableRequest $request) {
       ->when($type, fn ($q) => $q->whereHas('unread'))
       ->count();
     }
+
+    function join(Request $request, $conversation) {
+      $conversation = Config::config('models.conversation')::findOrFail($conversation);
+      $this->authorize('join', $conversation);
+      $user = $request->user();
+      return $conversation->addParticipant($user);
+    }
+
+    function leave(Request $request, $conversation) {
+      $conversation = Config::config('models.conversation')::findOrFail($conversation);
+      $this->authorize('join', $conversation);
+      $user = $request->user();
+      return $conversation->removeParticipant($user);
+    }
 }

src/Models/Conversation.php

@@ -13,6 +13,7 @@
 use Myckhel\ChatSystem\Contracts\IConversation;
 use Illuminate\Database\Eloquent\Relations\HasMany;
 use Illuminate\Database\Eloquent\Relations\HasOne;
+use Myckhel\ChatSystem\Contracts\ChatEventMaker;
 
 class Conversation extends Model implements IConversation
 {
@@ -21,6 +22,32 @@ class Conversation extends Model implements IConversation
   protected $casts    = ['user_id' => 'int'];
   protected $hidden   = ['pivot'];
 
+  function addParticipant(ChatEventMaker $user, String $message = 'Someone joined the conversation') {
+    $participant = ['user_id' => $user->getKey()];
+    $participant = $this->participants()->firstOrCreate($participant, $participant);
+
+    $participant->wasRecentlyCreated && $this->createMessageActivity([
+        'user_id' => $user->getKey(),
+        'message' => $message,
+      ]);
+
+    return $participant;
+  }
+
+  function removeParticipant(ChatEventMaker $user, String $message = 'Someone left the conversation') {
+    $participant = ['user_id' => $user->getKey()];
+    $participant = $this->participants()->whereUserId($user->getKey())->first();
+    $participant && $this->createMessageActivity([
+        'user_id' => $user->getKey(),
+        'message' => $message,
+      ]);
+    return $participant?->delete();
+  }
+
+  protected function createMessageActivity(Array $create) {
+    return $this->messages()->create($create + ['type'    => 'activity']);
+  }
+
   protected static function newFactory(){
     return ConversationFactory::new();
   }

src/Policies/ConversationPolicy.php

@@ -91,4 +91,8 @@ public function forceDelete(ChatEventMaker $user, IConversation $conversation)
     {
         //
     }
+
+    function join(ChatEventMaker $user, IConversation $conversation) {
+      return $conversation->type != 'private';
+    }
 }

src/routes/api.php

@@ -22,8 +22,13 @@
 $prefix       = Config::config('route.prefix');
 
 Route::group(['prefix' => $prefix, 'middleware' => $middlewares], function(){
-  Route::get('conversations/count', [ConversationController::class, 'count']);
+  // conversations
+  Route::get('conversations/count',                   [ConversationController::class, 'count']);
+  Route::post('conversations/{conversation}/join',    [ConversationController::class, 'join']);
+  Route::delete('conversations/{conversation}/join',  [ConversationController::class, 'leave']);
+  // messages
   Route::delete('messages',         [MessageController::class, 'delete']);
+  // apiResources
   Route::apiResources([
     'conversations'         =>  ConversationController::class,
     'messages'              =>  MessageController::class,