Automatically subscribe users to created threads

Author: driesvints

app/Jobs/CreateThread.php

@@ -65,6 +65,12 @@ public function handle(): Thread
         $thread->syncTags($this->tags);
         $thread->save();
 
+        // Subscribe author to the thread.
+        $this->author->subscriptionAble()->create([
+            'subscriptionable_id' => $thread->id(),
+            'subscriptionable_type' => Thread::TABLE,
+        ]);
+
         return $thread;
     }
 }

app/User.php

@@ -4,6 +4,7 @@
 
 use App\Models\Reply;
 use App\Models\Thread;
+use App\Models\Subscription;
 use App\Helpers\ModelHelpers;
 use App\Helpers\HasTimestamps;
 use Illuminate\Notifications\Notifiable;
@@ -238,4 +239,17 @@ public function delete()
 
         parent::delete();
     }
+
+    public function isSubscribedTo($subscriptionAble): bool
+    {
+        return $this->subscriptionAble()
+            ->where('subscriptionable_id', $subscriptionAble->id())
+            ->where('subscriptionable_type', $subscriptionAble::TABLE)
+            ->exists();
+    }
+
+    public function subscriptionAble(): HasMany
+    {
+        return $this->hasMany(Subscription::class, 'user_id');
+    }
 }

tests/Components/Models/UserTest.php

@@ -2,6 +2,7 @@
 
 namespace Tests\Components\Models;
 
+use App\Models\Subscription;
 use App\User;
 use Tests\TestCase;
 use App\Models\Reply;
@@ -47,4 +48,14 @@ private function createTwoSolutionReplies(User $user)
         $reply = factory(Reply::class)->create(['replyable_id' => $thread->id(), 'author_id' => $user->id()]);
         $thread->markSolution($reply);
     }
+
+    /** @test */
+    public function it_can_check_if_its_subscribed_to_a_thread()
+    {
+        $user = $this->createUser();
+        $thread = factory(Thread::class)->create();
+        factory(Subscription::class)->create(['user_id' => $user->id(), 'subscriptionable_id' => $thread->id()]);
+
+        $this->assertTrue($user->isSubscribedTo($thread));
+    }
 }

tests/Feature/SubscriptionTest.php

@@ -6,6 +6,7 @@
 use Tests\TestCase;
 use App\Models\Thread;
 use App\Jobs\CreateReply;
+use App\Jobs\CreateThread;
 use App\Models\Subscription;
 use App\Notifications\NewReply;
 use Illuminate\Support\Facades\Notification;
@@ -29,4 +30,16 @@ public function users_receive_notifications_for_new_replies_to_threads_where_the
 
         Notification::assertSentTo([$userOne, $userTwo], NewReply::class);
     }
+
+    /** @test */
+    public function users_are_automatically_subscribed_to_a_thread_after_creating_it()
+    {
+        $user = $this->createUser();
+
+        $thread = $this->dispatch(
+            new CreateThread($this->faker->sentence, $this->faker->text, $this->faker->ipv4, $user)
+        );
+
+        $this->assertTrue($user->isSubscribedTo($thread));
+    }
 }