wip

Author: driesvints

app/Events/ReplyWasCreated.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Events;
+
+use App\Models\Reply;
+use Illuminate\Queue\SerializesModels;
+
+class ReplyWasCreated
+{
+    use SerializesModels;
+
+    /**
+     * @var \App\Models\Reply
+     */
+    public $reply;
+
+    public function __construct(Reply $reply)
+    {
+        $this->reply = $reply;
+    }
+}

app/Helpers/ReceivesReplies.php

@@ -3,6 +3,7 @@
 namespace App\Helpers;
 
 use App\Models\Reply;
+use App\Models\Subscription;
 use Illuminate\Database\Eloquent\Relations\MorphMany;
 
 trait ReceivesReplies
@@ -32,4 +33,17 @@ public function repliesRelation(): MorphMany
     {
         return $this->morphMany(Reply::class, 'replyable');
     }
+
+    /**
+     * @return \App\Models\Subscription[]
+     */
+    public function subscriptions()
+    {
+        return $this->subscriptionsRelation;
+    }
+
+    public function subscriptionsRelation(): MorphMany
+    {
+        return $this->morphMany(Subscription::class, 'subscriptionable');
+    }
 }

app/Jobs/CreateReply.php

@@ -2,6 +2,7 @@
 
 namespace App\Jobs;
 
+use App\Events\ReplyWasCreated;
 use App\User;
 use App\Models\Reply;
 use App\Models\ReplyAble;
@@ -49,6 +50,8 @@ public function handle(): Reply
         $reply->to($this->replyAble);
         $reply->save();
 
+        event(new ReplyWasCreated($reply));
+
         return $reply;
     }
 }

app/Listeners/SendNewReplyNotification.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\ReplyWasCreated;
+use App\Models\Subscription;
+use App\Notifications\NewReply;
+
+class SendNewReplyNotification
+{
+    public function handle(ReplyWasCreated $event)
+    {
+        collect($event->reply->replyAble()->subscriptions())
+            ->each(function (Subscription $subscription) {
+                $subscription->user()->notify(new NewReply());
+            });
+    }
+}

app/Models/ReplyAble.php

@@ -22,4 +22,11 @@ public function latestReplies(int $amount = 5);
     public function deleteReplies();
 
     public function repliesRelation(): MorphMany;
+
+    /**
+     * @return \App\Models\Subscription[]
+     */
+    public function subscriptions();
+
+    public function subscriptionsRelation(): MorphMany;
 }

app/Models/Subscription.php

@@ -2,7 +2,9 @@
 
 namespace App\Models;
 
+use App\User;
 use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
 
 class Subscription extends Model
 {
@@ -18,4 +20,14 @@ class Subscription extends Model
         'subscriptionable_id',
         'subscriptionable_type',
     ];
+
+    public function user(): User
+    {
+        return $this->userRelation;
+    }
+
+    public function userRelation(): BelongsTo
+    {
+        return $this->belongsTo(User::class);
+    }
 }

app/Notifications/NewReply.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\Notifications;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Notifications\Notification;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+
+class NewReply extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Get the notification's delivery channels.
+     *
+     * @param  mixed  $notifiable
+     * @return array
+     */
+    public function via($notifiable)
+    {
+        return ['mail'];
+    }
+
+    /**
+     * Get the mail representation of the notification.
+     *
+     * @param  mixed  $notifiable
+     * @return \Illuminate\Notifications\Messages\MailMessage
+     */
+    public function toMail($notifiable)
+    {
+        return (new MailMessage)
+                    ->line('The introduction to the notification.')
+                    ->action('Notification Action', url('/'))
+                    ->line('Thank you for using our application!');
+    }
+
+    /**
+     * Get the array representation of the notification.
+     *
+     * @param  mixed  $notifiable
+     * @return array
+     */
+    public function toArray($notifiable)
+    {
+        return [
+            //
+        ];
+    }
+}

app/Providers/EventServiceProvider.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace App\Providers;
+
+use App\Events\ReplyWasCreated;
+use App\Listeners\SendNewReplyNotification;
+use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
+
+class EventServiceProvider extends ServiceProvider
+{
+    /**
+     * The event listener mappings for the application.
+     *
+     * @var array
+     */
+    protected $listen = [
+        ReplyWasCreated::class => [
+            SendNewReplyNotification::class,
+        ],
+    ];
+
+    /**
+     * Register any events for your application.
+     */
+    public function boot()
+    {
+        parent::boot();
+
+        //
+    }
+}

config/app.php

@@ -173,6 +173,7 @@
          */
         App\Providers\AppServiceProvider::class,
         App\Providers\AuthServiceProvider::class,
+        App\Providers\EventServiceProvider::class,
         App\Providers\RouteServiceProvider::class,
         App\Markdown\MarkdownServiceProvider::class,
         App\Spam\SpamServiceProvider::class,

tests/Components/Jobs/BanUserTest.php

@@ -2,10 +2,11 @@
 
 namespace Tests\Components\Jobs;
 
+use Tests\TestCase;
 use App\Jobs\BanUser;
 use Illuminate\Foundation\Testing\DatabaseMigrations;
 
-class BanUserTest extends JobTestCase
+class BanUserTest extends TestCase
 {
     use DatabaseMigrations;