Add ThreadModel

Author: gnello

README.md

@@ -208,6 +208,7 @@ $result = $driver->getPreferenceModel('user_id')->getUserPreference();
 - [Status](https://api.mattermost.com/#tag/status)
 - [System](https://api.mattermost.com/#tag/system)
 - [Teams](https://api.mattermost.com/#tag/teams)
+- [Threads](https://api.mattermost.com/#tag/threads)
 - [Users](https://api.mattermost.com/#tag/users)
 - [Webhooks](https://api.mattermost.com/#tag/webhooks)
 

src/Driver.php

@@ -35,6 +35,7 @@
 use Gnello\Mattermost\Models\SchemeModel;
 use Gnello\Mattermost\Models\SystemModel;
 use Gnello\Mattermost\Models\TeamModel;
+use Gnello\Mattermost\Models\ThreadModel;
 use Gnello\Mattermost\Models\UserModel;
 use Gnello\Mattermost\Models\WebhookModel;
 use GuzzleHttp\Psr7\Response;
@@ -354,4 +355,12 @@ public function getIntegrationActionsModel()
     {
         return $this->getModel(IntegrationActionsModel::class);
     }
+
+    /**
+     * @return ThreadModel
+     */
+    public function getThreadModel()
+    {
+        return $this->getModel(ThreadModel::class);
+    }
 }

src/Models/ThreadModel.php

@@ -0,0 +1,114 @@
+<?php
+/**
+ * This Driver is based entirely on official documentation of the Mattermost Web
+ * Services API and you can extend it by following the directives of the documentation.
+ *
+ * For the full copyright and license information, please read the LICENSE.txt
+ * file that was distributed with this source code. For the full list of
+ * contributors, visit https://github.com/gnello/php-mattermost-driver/contributors
+ *
+ * God bless this mess.
+ *
+ * @author Luca Agnello <[email protected]>
+ * @link https://api.mattermost.com/
+ */
+
+namespace Gnello\Mattermost\Models;
+
+use Psr\Http\Message\ResponseInterface;
+
+/**
+ * Class ThreadsModel
+ *
+ * @package Gnello\Mattermost
+ */
+class ThreadModel extends AbstractModel
+{
+    /**
+     * @var string
+     */
+    public static $endpoint = '/threads';
+
+    /**
+     * @param       $userId
+     * @param       $teamId
+     * @param array $requestOptions
+     * @return ResponseInterface
+     */
+    public function getThreadsThatUserIsFollowing($userId, $teamId, array $requestOptions)
+    {
+        return $this->client->get(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint , $requestOptions);
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @return ResponseInterface
+     */
+    public function getUnreadMentionCounts($userId, $teamId)
+    {
+        return $this->client->get(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint . '/mention_counts');
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @return ResponseInterface
+     */
+    public function markThreadsAsRead($userId, $teamId)
+    {
+        return $this->client->put(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint . '/read');
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @param $threadId
+     * @param $timestamp
+     * @return ResponseInterface
+     */
+    public function markThreadToTimestamp($userId, $teamId, $threadId, $timestamp)
+    {
+        return $this->client->put(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint . '/' . $threadId . '/read/' . $timestamp);
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @param $threadId
+     * @return ResponseInterface
+     */
+    public function startFollowingThread($userId, $teamId, $threadId)
+    {
+        return $this->client->put(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint . '/' . $threadId . '/following');
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @param $threadId
+     * @return ResponseInterface
+     */
+    public function stopFollowingThread($userId, $teamId, $threadId)
+    {
+        return $this->client->delete(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/'
+            . $teamId . '/' . self::$endpoint . '/' . $threadId . '/following');
+    }
+
+    /**
+     * @param $userId
+     * @param $teamId
+     * @param $threadId
+     * @return ResponseInterface
+     */
+    public function getThreadFollowedByUser($userId, $teamId, $threadId)
+    {
+        return $this->client->get(UserModel::$endpoint . '/' . $userId . '/' . TeamModel::$endpoint . '/' . $teamId
+            . '/' . self::$endpoint . '/' . $threadId);
+    }
+}