From 718261c1bedb5f376da886eaad45ec590346dc14 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=85=B0=E6=9E=97?= <lanlin1987@gmail.com>
Date: Tue, 18 Dec 2018 17:46:58 +0800
Subject: [PATCH] STAM-2514

---
 src/Threads/Smart.php | 346 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 346 insertions(+)
 create mode 100644 src/Threads/Smart.php

diff --git a/src/Threads/Smart.php b/src/Threads/Smart.php
new file mode 100644
index 0000000..8dc98ec
--- /dev/null
+++ b/src/Threads/Smart.php
@@ -0,0 +1,346 @@
+<?php namespace Nylas\Threads;
+
+use Nylas\Labels\Label;
+use Nylas\Folders\Folder;
+use Nylas\Utilities\API;
+use Nylas\Utilities\Helper;
+use Nylas\Utilities\Options;
+use Nylas\Utilities\Validate as V;
+
+/**
+ * ----------------------------------------------------------------------------------
+ * Nylas Threads Start Update
+ * ----------------------------------------------------------------------------------
+ *
+ * @author lanlin
+ * @change 2018/12/18
+ */
+class Smart
+{
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * @var \Nylas\Utilities\Options
+     */
+    private $options;
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * Search constructor.
+     *
+     * @param \Nylas\Utilities\Options $options
+     */
+    public function __construct(Options $options)
+    {
+        $this->options = $options;
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * add labels to thread
+     *
+     * @param string $threadId
+     * @param string|array $labels
+     * @return array
+     */
+    public function addLabels(string $threadId, $labels)
+    {
+        return $this->updateLabels($threadId, $labels);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * remove labels from thread
+     *
+     * @param string $threadId
+     * @param string|array $labels
+     * @return array
+     */
+    public function removeLabels(string $threadId, $labels)
+    {
+        return $this->updateLabels($threadId, null, $labels);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * archive thread
+     *
+     * @param string $threadId
+     * @return array
+     */
+    public function archive(string $threadId)
+    {
+        return Helper::isLabel($this->options) ?
+        $this->updateLabels($threadId, null, ['inbox']) :
+        $this->updateFolder($threadId, 'archive');
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * unarchive thread
+     *
+     * @param string $threadId
+     * @return array
+     */
+    public function unarchive(string $threadId)
+    {
+        return Helper::isLabel($this->options) ?
+        $this->updateLabels($threadId, ['inbox'], ['archive']) :
+        $this->updateFolder($threadId, 'inbox');
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * move thread to trash
+     *
+     * @param string $threadId
+     * @return array
+     */
+    public function trash(string $threadId)
+    {
+        return Helper::isLabel($this->options) ?
+        $this->updateLabels($threadId, ['trash'], ['inbox']) :
+        $this->updateFolder($threadId, 'trash');
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * move from "label|folder" to other "label|folder" by name
+     *
+     * @param string $threadId
+     * @param string $from
+     * @param string $goto
+     * @return array
+     */
+    public function move(string $threadId, string $from, string $goto)
+    {
+        return Helper::isLabel($this->options) ?
+        $this->updateLabels($threadId, [$goto], [$from]) :
+        $this->updateFolder($threadId, $goto);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * set thread to start
+     *
+     * @param string|array $threadId
+     * @return array
+     */
+    public function star($threadId)
+    {
+        $params = ['starred' => true];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * set thread to un-star
+     *
+     * @param string|array $threadId
+     * @return array
+     */
+    public function unstar($threadId)
+    {
+        $params = ['starred' => false];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * mark thread as read
+     *
+     * @param string|array $threadId
+     * @return array
+     */
+    public function markAsRead($threadId)
+    {
+        $params = ['unread' => false];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * mark thread as unread
+     *
+     * @param string|array $threadId
+     * @return array
+     */
+    public function markAsUnread($threadId)
+    {
+        $params = ['unread' => true];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * move thread to folder by id
+     *
+     * @param string|array $threadId
+     * @param string $folderId
+     * @return array
+     */
+    public function moveToFolder($threadId, string $folderId)
+    {
+        Helper::checkProviderUnit($this->options, false);
+
+        V::doValidate(V::stringType()->notEmpty(), $folderId);
+
+        $params = ['folder_id' => $folderId];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * move thread to labels by id
+     *
+     * @param string|array $threadId
+     * @param array $labelIds
+     * @return array
+     */
+    public function moveToLabel($threadId, array $labelIds)
+    {
+        Helper::checkProviderUnit($this->options, true);
+
+        V::doValidate(V::each(V::stringType()->notEmpty()), $labelIds);
+
+        $params = ['label_ids' => $labelIds];
+
+        return $this->updateOneField($threadId, $params);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * update thread folder
+     *
+     * @param string $threadId
+     * @param string $folder
+     * @return array
+     */
+    private function updateFolder(string $threadId, string $folder)
+    {
+        $folderId   = null;
+        $allFolders = (new Folder($this->options))->getFoldersList();
+
+        foreach ($allFolders as $row)
+        {
+            if ($row['name'] === $folder)
+            {
+                $folderId = $row['id'];
+                break;
+            }
+        }
+
+        return $this->moveToLabel($threadId, $folderId);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * update thread labels (update with name or display name)
+     *
+     * @param string $threadId
+     * @param string|array $add
+     * @param string|array $del
+     * @return array
+     */
+    private function updateLabels(string $threadId, $add = [], $del = [])
+    {
+        $tmpLabels = [];
+        $allLabels = (new Label($this->options))->getLabelsList();
+        $threadMsg = (new Thread($this->options))->getThread($threadId);
+        $nowLabels = $threadMsg[$threadId]['labels'] ?? [];
+
+        $add = Helper::fooToArray($add);
+        $del = Helper::fooToArray($del);
+
+        // check all labels
+        foreach($allLabels as $label)
+        {
+            $secA = !empty($label['name']) && in_array($label['name'], $add);
+            $secB = empty($label['name']) && in_array($label['display_name'], $add);
+
+            if ($secA || $secB)
+            {
+                array_push($tmpLabels, $label['id']);
+            }
+        }
+
+        // check current thread labels
+        foreach($nowLabels as $index => $label)
+        {
+            $secA = !empty($label['name']) && in_array($label['name'], $del);
+            $secB = empty($label['name']) && in_array($label['display_name'], $del);
+
+            if ($secA || $secB) { continue; }
+
+            array_push($tmpLabels, $label['id']);
+        }
+
+        return $this->moveToLabel($threadId, $tmpLabels);
+    }
+
+    // ------------------------------------------------------------------------------
+
+    /**
+     * update the specific field of thread
+     *
+     * @param string|array $threadId
+     * @param array $params
+     * @return array
+     */
+    private function updateOneField($threadId, array $params)
+    {
+        $threadId    = Helper::fooToArray($threadId);
+        $accessToken = $this->options->getAccessToken();
+
+        $rule = V::each(V::stringType()->notEmpty(), V::intType());
+
+        V::doValidate($rule, $threadId);
+        V::doValidate(V::stringType()->notEmpty(), $accessToken);
+
+        $queues = [];
+        $target = API::LIST['oneThread'];
+        $header = ['Authorization' => $accessToken];
+
+        foreach ($threadId as $id)
+        {
+            $request = $this->options
+            ->getAsync()
+            ->setPath($id)
+            ->setFormParams($params)
+            ->setHeaderParams($header);
+
+            $queues[] = function () use ($request, $target)
+            {
+                return $request->put($target);
+            };
+        }
+
+        $pools = $this->options->getAsync()->pool($queues, false);
+
+        return Helper::concatPoolInfos($threadId, $pools);
+    }
+
+    // ------------------------------------------------------------------------------
+
+}