✨ ajout de la creation et l'edition d'un commentaire

Author: mckenziearts

app/Events/CommentWasAdded.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Events;
+
+use App\Models\Discussion;
+use App\Models\Reply;
+use Illuminate\Queue\SerializesModels;
+
+class CommentWasAdded
+{
+    use SerializesModels;
+
+    public function __construct(public Reply $reply, public Discussion $discussion)
+    {
+    }
+}

app/Http/Controllers/Api/ReplyController.php

@@ -2,7 +2,10 @@
 
 namespace App\Http\Controllers\Api;
 
+use App\Events\CommentWasAdded;
 use App\Http\Controllers\Controller;
+use App\Http\Requests\Api\CreateReplyRequest;
+use App\Http\Requests\Api\UpdateReplyRequest;
 use App\Http\Resources\ReplyResource;
 use App\Models\Discussion;
 use App\Models\Reaction;
@@ -11,26 +14,52 @@
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\AnonymousResourceCollection;
-use Illuminate\Support\Facades\Auth;
 
 class ReplyController extends Controller
 {
     public function all(int $target): AnonymousResourceCollection
     {
         /** @var Discussion $discussion */
         $discussion = Discussion::findOrFail($target);
+        $replies = collect();
 
-        return ReplyResource::collection($discussion->replies);
+        foreach ($discussion->replies as $reply) {
+            if ($reply->allChildReplies->isNotEmpty()) {
+                foreach ($reply->allChildReplies as $childReply) {
+                    $replies->add($childReply);
+                }
+            }
+
+            $replies->add($reply);
+        }
+
+        return ReplyResource::collection($replies);
     }
 
-    public function store()
+    public function store(CreateReplyRequest $request): ReplyResource
     {
+        // dd($request->all());
+        // if ($request->parent) {}
+        $reply = new Reply(['body' => $request->body]);
+        $author = User::find($request->user_id);
+
+        $target = Discussion::find($request->target);
+        $reply->authoredBy($author);
+        $reply->to($target);
+        $reply->save();
 
+        // On envoie un event pour une nouvelle réponse à tous les abonnés de la discussion
+        event(new CommentWasAdded($reply, $target));
+
+        return new ReplyResource($reply);
     }
 
-    public function update()
+    public function update(UpdateReplyRequest $request, int $id): ReplyResource
     {
+        $reply = Reply::find($id);
+        $reply->update(['body' => $request->body]);
 
+        return new ReplyResource($reply);
     }
 
     public function like(Request $request, int $id): ReplyResource

app/Http/Requests/Api/CreateReplyRequest.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Http\Requests\Api;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+class CreateReplyRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    public function rules(): array
+    {
+        return [
+            'body' => 'required',
+            'user_id' => 'required',
+        ];
+    }
+}

app/Http/Requests/Api/UpdateReplyRequest.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Http\Requests\Api;
+
+use App\Http\Requests\FormRequest;
+
+class UpdateReplyRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    /**
+     * Get the validation rules that apply to the request.
+     *
+     * @return array
+     */
+    public function rules(): array
+    {
+        return [
+            'body' => 'required',
+        ];
+    }
+}

app/Http/Requests/FormRequest.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace App\Http\Requests;
+
+use Illuminate\Contracts\Validation\Validator;
+use Illuminate\Foundation\Http\FormRequest as LaravelFormRequest;
+use Illuminate\Http\JsonResponse;
+
+abstract class FormRequest extends LaravelFormRequest
+{
+    /**
+     * Get the validation rules that apply to the request.
+     *
+     * @return  array
+     */
+    abstract public function rules(): array;
+
+    public function failedValidation(Validator $validator): JsonResponse
+    {
+        $transformed = [];
+
+        foreach ($validator->errors() as $field => $message) {
+            $transformed[] = [
+                'field' => $field,
+                'message' => $message[0]
+            ];
+        }
+
+        return response()->json([
+            'errors' => $transformed
+        ], JsonResponse::HTTP_UNPROCESSABLE_ENTITY);
+    }
+}

app/Http/Resources/ReplyResource.php

@@ -16,7 +16,6 @@ public function toArray($request): array
             'created_at' => $this->created_at->getTimestamp(),
             'author' => new UserResource($this->author),
             'has_replies' => $this->allChildReplies->isNotEmpty(),
-            'replies' => $this->replyable_type === 'discussion' ? self::collection($this->replies) : null,
             'likes_count' => $this->getReactionsSummary()->sum('count'),
         ];
     }

app/Listeners/SendNewCommentNotification.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\CommentWasAdded;
+use App\Models\User;
+use App\Notifications\NewCommentNotification;
+
+class SendNewCommentNotification
+{
+    public function handle(CommentWasAdded $event)
+    {
+        $discussion = $event->discussion;
+
+        foreach ($discussion->subscribes as $subscription) {
+            if ($this->replyAuthorDoesNotMatchSubscriber($event->reply->author, $subscription)) {
+                $subscription->user->notify(new NewCommentNotification($event->reply, $subscription, $discussion));
+            }
+        }
+    }
+
+    private function replyAuthorDoesNotMatchSubscriber(User $author, $subscription): bool
+    {
+        return ! $author->is($subscription->user);
+    }
+}

app/Notifications/NewCommentNotification.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Notifications;
+
+use App\Models\Discussion;
+use App\Models\Reply;
+use App\Models\Subscribe;
+use Illuminate\Bus\Queueable;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class NewCommentNotification extends Notification
+{
+    use Queueable;
+
+    public function __construct(public Reply $reply, public Subscribe $subscription, public Discussion $discussion)
+    {
+    }
+
+    public function via($notifiable): array
+    {
+        return ['mail', 'database'];
+    }
+
+    public function toMail($notifiable): MailMessage
+    {
+        return (new MailMessage)
+                    ->subject("Re: {$this->discussion->subject()}")
+                    ->line('@' . $this->reply->author->username . ' a répondu à ce sujet.')
+                    ->line($this->reply->excerpt(150))
+                    ->action('Voir la discussion', route('discussions.show', $this->discussion))
+                    ->line('Vous recevez ceci parce que vous êtes abonné à cette discussion.');
+    }
+
+    public function toArray($notifiable): array
+    {
+        return [
+            'type' => 'new_comment',
+            'reply' => $this->reply->id,
+            'replyable_id' => $this->reply->replyable_id,
+            'replyable_type' => $this->reply->replyable_type,
+            'replyable_subject' => $this->discussion->subject(),
+        ];
+    }
+}

app/Providers/EventServiceProvider.php

@@ -2,10 +2,12 @@
 
 namespace App\Providers;
 
+use App\Events\CommentWasAdded;
 use App\Events\ReplyWasCreated;
 use App\Events\ThreadWasCreated;
 use App\Listeners\NotifyMentionedUsers;
 use App\Listeners\PostNewThreadNotification;
+use App\Listeners\SendNewCommentNotification;
 use App\Listeners\SendNewReplyNotification;
 use App\Listeners\SendNewThreadNotification;
 use Illuminate\Auth\Events\Registered;
@@ -31,6 +33,9 @@ class EventServiceProvider extends ServiceProvider
             SendNewThreadNotification::class,
             PostNewThreadNotification::class,
         ],
+        CommentWasAdded::class => [
+            SendNewCommentNotification::class,
+        ],
     ];
 
     /**