Merge pull request #30 from laravelcm/notifications

Notifications

Author: mckenziearts

app/Actions/Fortify/CreateNewUser.php

@@ -5,6 +5,7 @@
 use App\Models\User;
 use Illuminate\Support\Facades\Hash;
 use Illuminate\Support\Facades\Validator;
+use Illuminate\Support\Str;
 use Illuminate\Validation\Rule;
 use Laravel\Fortify\Contracts\CreatesNewUsers;
 
@@ -35,6 +36,7 @@ public function create(array $input): User
                 'string',
                 'min:6',
                 'max:20',
+                'alpha_dash',
                 Rule::unique(User::class, 'username'),
             ],
             'password' => $this->passwordRules(),
@@ -43,9 +45,9 @@ public function create(array $input): User
         return User::create([
             'name' => $input['name'],
             'email' => $input['email'],
-            'username' => $input['username'],
-            'opt_in' => isset($input['opt_in']),
+            'username' => Str::lower($input['username']),
             'password' => Hash::make($input['password']),
+            'opt_in' => isset($input['opt_in']),
         ]);
     }
 }

app/Http/Controllers/ReplyAbleController.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Models\Reply;
+
+class ReplyAbleController extends Controller
+{
+    public function redirect($id, $type)
+    {
+        $reply = Reply::where('replyable_id', $id)->where('replyable_type', $type)->firstOrFail();
+
+        return redirect(route_to_reply_able($reply->replyAble));
+    }
+}

app/Http/Controllers/SubscriptionController.php

@@ -17,4 +17,11 @@ public function unsubscribe(Subscribe $subscription)
 
         return redirect()->route('forum.show', $thread->slug());
     }
+
+    public function redirect($id, $type)
+    {
+        $subscribe = Subscribe::where('subscribeable_id', $id)->where('subscribeable_type', $type)->firstOrFail();
+
+        return redirect(route_to_reply_able($subscribe->subscribeAble));
+    }
 }

app/Http/Livewire/NotificationCount.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace App\Http\Livewire;
+
+use Illuminate\Support\Facades\Auth;
+use Livewire\Component;
+
+class NotificationCount extends Component
+{
+    public int $count = 0;
+
+    protected $listeners = [
+        'NotificationMarkedAsRead' => 'updateCount',
+    ];
+
+    public function updateCount(int $count): int
+    {
+        return $count;
+    }
+
+    public function render()
+    {
+        $this->count = Auth::user()->unreadNotifications()->count();
+
+        return view('livewire.notification-count', [
+            'count' => $this->count,
+        ]);
+    }
+}

app/Http/Livewire/NotificationIndicator.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace App\Http\Livewire;
+
+use Illuminate\Support\Facades\Auth;
+use Livewire\Component;
+
+class NotificationIndicator extends Component
+{
+    public bool $hasNotification = false;
+
+    protected $listeners = [
+        'NotificationMarkedAsRead' => 'setHasNotification',
+    ];
+
+    public function setHasNotification(int $count): bool
+    {
+        return $count > 0;
+    }
+
+    public function render()
+    {
+        $this->hasNotification = $this->setHasNotification(
+            Auth::user()->unreadNotifications()->count(),
+        );
+
+        return view('livewire.notification-indicator', [
+            'hasNotification' => $this->hasNotification,
+        ]);
+    }
+}

app/Http/Livewire/Notifications.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace App\Http\Livewire;
+
+use App\Policies\NotificationPolicy;
+use Carbon\Carbon;
+use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
+use Illuminate\Notifications\DatabaseNotification;
+use Illuminate\Support\Facades\Auth;
+use Livewire\Component;
+use WireUi\Traits\Actions;
+
+class Notifications extends Component
+{
+    use Actions, AuthorizesRequests;
+
+    public $notificationId;
+
+    public function mount(): void
+    {
+        abort_if(Auth::guest(), 403);
+    }
+
+    public function getNotificationProperty(): DatabaseNotification
+    {
+        return DatabaseNotification::findOrFail($this->notificationId);
+    }
+
+    public function markAsRead(string $notificationId): void
+    {
+        $this->notificationId = $notificationId;
+
+        $this->authorize(NotificationPolicy::MARK_AS_READ, $this->notification);
+
+        $this->notification->markAsRead();
+
+        $this->notification()->success('Notification', 'Cette notification a été marquée comme lue.');
+
+        $this->emit('NotificationMarkedAsRead', Auth::user()->unreadNotifications()->count());
+    }
+
+    public function render()
+    {
+        return view('livewire.notifications', [
+            'notifications' => Auth::user()
+                ->unreadNotifications()
+                ->take(10)
+                ->get()
+                ->groupBy(
+                    fn ($notification) => Carbon::parse($notification->created_at)->format('M, Y')
+                ),
+        ]);
+    }
+}

app/Http/Livewire/User/Settings/Notifications.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace App\Http\Livewire\User\Settings;
+
+use App\Models\Subscribe;
+use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
+use Illuminate\Support\Facades\Auth;
+use Livewire\Component;
+use WireUi\Traits\Actions;
+
+class Notifications extends Component
+{
+    use Actions, AuthorizesRequests;
+
+    public $subscribeId;
+
+    public function unsubscribe(string $subscribeId)
+    {
+        $this->subscribeId = $subscribeId;
+
+        $this->subscribe->delete();
+
+        $this->notification()->success('Désabonnement', 'Vous êtes maintenant désabonné de cet fil.');
+    }
+
+    public function getSubscribeProperty(): Subscribe
+    {
+        return Subscribe::where('uuid', $this->subscribeId)->firstOrFail();
+    }
+
+    public function render()
+    {
+        return view('livewire.user.settings.notifications', [
+            'subscriptions' => Auth::user()->subscriptions,
+        ]);
+    }
+}

app/Models/User.php

@@ -187,6 +187,11 @@ public function discussions(): HasMany
         return $this->hasMany(Discussion::class);
     }
 
+    public function subscriptions(): HasMany
+    {
+        return $this->hasMany(Subscribe::class);
+    }
+
     public function deleteThreads()
     {
         // We need to explicitly iterate over the threads and delete them

app/Notifications/YouWereMentioned.php

@@ -39,6 +39,7 @@ public function toArray($notifiable): array
             'author_name' => $this->reply->author->name,
             'author_username' => $this->reply->author->username,
             'author_photo' => $this->reply->author->profile_photo_url,
+            'replyable_id' => $this->reply->replyable_id,
             'replyable_type' => $this->reply->replyable_type,
             'replyable_subject' => $this->reply->replyAble->replyAbleSubject(),
         ];

app/Policies/NotificationPolicy.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Policies;
+
+use App\Models\User;
+use Illuminate\Notifications\DatabaseNotification;
+
+class NotificationPolicy
+{
+    const MARK_AS_READ = 'markAsRead';
+
+    /**
+     * Determine if the given notification can be marked as read by the user.
+     */
+    public function markAsRead(User $user, DatabaseNotification $notification): bool
+    {
+        return $notification->notifiable->is($user);
+    }
+}