Forum Topic Subscription System

app/Http/Controllers/ForumController.php

@@ -12,17 +12,14 @@
 
 namespace App\Http\Controllers;
 
-use App\Events\MessageSent;
-use App\Repositories\ChatRepository;
-use App\Repositories\TaggedUserRepository;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\Mail;
 use App\Forum;
 use App\Post;
 use App\Topic;
 use App\User;
-use App\Message;
 use App\Like;
+use App\TopicSubscription;
 use App\Achievements\UserMadeFirstPost;
 use App\Achievements\UserMade25Posts;
 use App\Achievements\UserMade50Posts;
@@ -35,7 +32,8 @@
 use App\Achievements\UserMade700Posts;
 use App\Achievements\UserMade800Posts;
 use App\Achievements\UserMade900Posts;
-use App\Mail\NewReply;
+use App\Repositories\ChatRepository;
+use App\Repositories\TaggedUserRepository;
 use Decoda\Decoda;
 use \Toastr;
 
@@ -288,20 +286,14 @@ public function reply(Request $request, $slug, $id)
             // Save
             $forum->save();
 
-            // Find the user who initated the topic
-            $topicCreator = User::findOrFail($topic->first_post_user_id);
-
             // Post To Chatbox
             $appurl = config('app.url');
             $postUrl = "{$appurl}/forums/topic/{$topic->slug}.{$topic->id}?page={$post->getPageNumber()}#post-{$post->id}";
             $profileUrl = "{$appurl}/{$user->username}.{$user->id}";
-
             $this->chat->systemMessage("[url=$profileUrl]{$user->username}[/url] has left a reply on topic [url={$postUrl}]{$topic->name}[/url]");
 
-            // Mail Topic Creator Of New Reply
-            if ($post->user_id != $topic->first_post_user_id) {
-                Mail::to($topicCreator->email)->send(new NewReply($user, $topic));
-            }
+            // Notify All Subscribers Of New Reply
+            $topic->notifySubscribers($post);
 
             //Achievements
             $user->unlock(new UserMadeFirstPost(), 1);

app/Http/Controllers/SubscriptionController.php

@@ -0,0 +1,64 @@
+<?php
+/**
+ * NOTICE OF LICENSE
+ *
+ * UNIT3D is open-sourced software licensed under the GNU General Public License v3.0
+ * The details is bundled with this project in the file LICENSE.txt.
+ *
+ * @project    UNIT3D
+ * @license    https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
+ * @author     HDVinnie
+ */
+
+namespace App\Http\Controllers;
+
+use App\Topic;
+use App\TopicSubscription;
+use \Toastr;
+
+class SubscriptionController extends Controller
+{
+    /**
+     * Subscribe To A Topic
+     *
+     * @param Topic $topic
+     * @return Illuminate\Http\RedirectResponse
+     */
+    public function subscribe(Topic $topic)
+    {
+        if (!auth()->user()->isSubscribed($topic->id)) {
+
+            $subscription = new TopicSubscription();
+            $subscription->user_id = auth()->user()->id;
+            $subscription->topic_id = $topic->id;
+            $subscription->save();
+
+            return redirect()->route('forum_topic', ['slug' => $topic->slug, 'id' => $topic->id])
+                ->with(Toastr::success('You are now subscribed to topic, ' . $topic->name . '. You will now receive site notifications when a reply is left.', 'Yay!', ['options']));
+        } else {
+            return redirect()->route('forum_topic', ['slug' => $topic->slug, 'id' => $topic->id])
+                ->with(Toastr::error('You are already subscribed to this topic', 'Whoops!', ['options']));
+        }
+    }
+
+    /**
+     * Unsubscribe To A Topic
+     *
+     * @param Topic $topic
+     * @return Illuminate\Http\RedirectResponse
+     */
+    public function unsubscribe(Topic $topic)
+    {
+        if (auth()->user()->isSubscribed($topic->id)) {
+
+            $subscription = auth()->user()->subscriptions()->where('topic_id', $topic->id)->first();
+            $subscription->delete();
+
+            return redirect()->route('forum_topic', ['slug' => $topic->slug, 'id' => $topic->id])
+                ->with(Toastr::info('You are no longer subscribed to topic, ' . $topic->name. '. You will no longer receive site notifications when a reply is left.', 'Yay!', ['options']));
+        } else {
+            return redirect()->route('forum_topic', ['slug' => $topic->slug, 'id' => $topic->id])
+                ->with(Toastr::error('You are not subscribed this topic to begin with...', 'Whoops!', ['options']));
+        }
+    }
+}

app/Notifications/NewTopicPost.php

@@ -0,0 +1,66 @@
+<?php
+/**
+ * NOTICE OF LICENSE
+ *
+ * UNIT3D is open-sourced software licensed under the GNU General Public License v3.0
+ * The details is bundled with this project in the file LICENSE.txt.
+ *
+ * @project    UNIT3D
+ * @license    https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
+ * @author     HDVinnie
+ */
+
+namespace App\Notifications;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Notifications\Notification;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Support\Facades\Request;
+
+use App\Post;
+
+class NewTopicPost extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public $post;
+
+    /**
+     * Create a new notification instance.
+     *
+     * @param Post $post
+     * @return void
+     */
+    public function __construct(Post $post)
+    {
+        $this->post = $post;
+    }
+
+    /**
+     * Get the notification's delivery channels.
+     *
+     * @param  mixed $notifiable
+     * @return array
+     */
+    public function via($notifiable)
+    {
+        return ['database'];
+    }
+
+    /**
+     * Get the array representation of the notification.
+     *
+     * @param  mixed $notifiable
+     * @return array
+     */
+    public function toArray($notifiable)
+    {
+        $appurl = config('app.url');
+        return [
+            'title' => "Subscribed Topic Has A New Post",
+            'body' => $this->post->user->username . " has left a new post on " . $this->post->topic->name,
+            'url' => "{$appurl}/forums/topic/{$this->post->topic->slug}.{$this->post->topic->id}?page={$this->post->getPageNumber()}#post-{$this->post->id}"
+        ];
+    }
+}

app/Topic.php

@@ -36,6 +36,26 @@ public function posts()
         return $this->hasMany(Post::class);
     }
 
+    /**
+     * Has Many Subscriptions
+     *
+     * @return \Illuminate\Database\Eloquent\Relations\HasMany
+     */
+    public function subscriptions()
+    {
+        return $this->hasMany(TopicSubscription::class);
+    }
+
+    /**
+     * Notify Subscribers Of A Topic When New Post Is Made
+     *
+     * @return string
+     */
+    public function notifySubscribers($post)
+    {
+        $this->subscriptions->where('user_id', '!=', $post->user_id)->each->notify($post);
+    }
+
     /**
      * Does User Have Permission To View Topic
      *

app/TopicSubscription.php

@@ -0,0 +1,53 @@
+<?php
+/**
+ * NOTICE OF LICENSE
+ *
+ * UNIT3D is open-sourced software licensed under the GNU General Public License v3.0
+ * The details is bundled with this project in the file LICENSE.txt.
+ *
+ * @project    UNIT3D
+ * @license    https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
+ * @author     HDVinnie
+ */
+
+namespace App;
+
+use Illuminate\Database\Eloquent\Model;
+use App\Notifications\NewTopicPost;
+
+
+class TopicSubscription extends Model
+{
+    /**
+     * Belongs To A User
+     *
+     * @return \Illuminate\Database\Eloquent\Relations\BelongsTo
+     */
+    public function user()
+    {
+        return $this->belongsTo(User::class)->withDefault([
+            'username' => 'System',
+            'id' => '1'
+        ]);
+    }
+
+    /**
+     * Belongs To A Topic
+     *
+     * @return \Illuminate\Database\Eloquent\Relations\BelongsTo
+     */
+    public function topic()
+    {
+        return $this->belongsTo(Topic::class);
+    }
+
+    /**
+     * Notify Subscribers Of A Topic When New Post Is Made
+     *
+     * @return string
+     */
+    public function notify($post)
+    {
+        $this->user->notify(new NewTopicPost($post));
+    }
+}

app/User.php

@@ -397,6 +397,27 @@ public function likes()
         return $this->hasMany(Like::class);
     }
 
+    /**
+     * Has Many Subscriptions
+     *
+     * @return \Illuminate\Database\Eloquent\Relations\HasMany
+     */
+    public function subscriptions()
+    {
+        return $this->hasMany(TopicSubscription::class);
+    }
+
+    /**
+     * Does Subscription Exist
+     *
+     * @param $topic_id
+     * @return string
+     */
+    public function isSubscribed($topic_id)
+    {
+        return (bool)$this->subscriptions()->where('topic_id', $topic_id)->first(['id']);
+    }
+
     /**
      * Get All Followers Of A User
      *

database/migrations/2018_06_11_110000_create_topic_subscriptions_table.php

@@ -0,0 +1,44 @@
+<?php
+/**
+ * NOTICE OF LICENSE
+ *
+ * UNIT3D is open-sourced software licensed under the GNU General Public License v3.0
+ * The details is bundled with this project in the file LICENSE.txt.
+ *
+ * @project    UNIT3D
+ * @license    https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
+ * @author     HDVinnie
+ */
+
+use Illuminate\Support\Facades\Schema;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Database\Migrations\Migration;
+
+class CreateTopicSubscriptionsTable extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('topic_subscriptions', function (Blueprint $table) {
+            $table->increments('id');
+            $table->unsignedInteger('user_id');
+            $table->unsignedInteger('topic_id');
+            $table->timestamps();
+            $table->unique(['user_id', 'topic_id']);
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('topic_subscriptions');
+    }
+}