Revert "Implemented unread threads as a relationship on Messagable Trait"

Author: cmgmyr

src/Cmgmyr/Messenger/Traits/Messagable.php

@@ -44,35 +44,47 @@ public function threads()
         );
     }
 
-    /**
-     * Unread threads as a relationship
-     *
-     * @return \Illuminate\Database\Eloquent\Relations\belongsToMany
-     */
-    public function unreadThreads()
-    {
-        return $this->threads()
-            ->whereRaw(Models::table('threads') . '.updated_at > '
-                    . Models::table('participants') . '.last_read');
-    }
-
     /**
      * Returns the new messages count for user.
      *
      * @return int
      */
     public function newThreadsCount()
     {
-        return $this->unreadThreads()->count();
+        return count($this->threadsWithNewMessages());
     }
 
     /**
-     * Returns the id of all threads with new messages.
+     * Returns all threads with new messages.
      *
      * @return array
      */
     public function threadsWithNewMessages()
     {
-        return $this->unreadThreads()->lists(Models::table('threads') . '.id');
+        $threadsWithNewMessages = [];
+
+        $participants = Models::participant()->where('user_id', $this->id)->lists('last_read', 'thread_id');
+
+        /**
+         * @todo: see if we can fix this more in the future.
+         * Illuminate\Foundation is not available through composer, only in laravel/framework which
+         * I don't want to include as a dependency for this package...it's overkill. So let's
+         * exclude this check in the testing environment.
+         */
+        if (getenv('APP_ENV') == 'testing' || !str_contains(\Illuminate\Foundation\Application::VERSION, '5.0')) {
+            $participants = $participants->all();
+        }
+
+        if ($participants) {
+            $threads = Models::thread()->whereIn('id', array_keys($participants))->get();
+
+            foreach ($threads as $thread) {
+                if ($thread->updated_at > $participants[$thread->id]) {
+                    $threadsWithNewMessages[] = $thread->id;
+                }
+            }
+        }
+
+        return $threadsWithNewMessages;
     }
 }