wip

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/Jobs/CreateThreadTest.php

@@ -18,5 +18,6 @@ public function we_can_create_a_thread()
         $thread = $this->dispatch(new CreateThread('Subject', 'Body', '', $user));
 
         $this->assertEquals('Subject', $thread->subject());
+        $this->assertTrue($user->isSubscribedTo($thread));
     }
 }

tests/Components/Models/UserTest.php

@@ -6,6 +6,7 @@
 use Tests\TestCase;
 use App\Models\Reply;
 use App\Models\Thread;
+use App\Models\Subscription;
 use Illuminate\Foundation\Testing\DatabaseMigrations;
 
 class UserTest extends TestCase
@@ -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));
+    }
 }