Merge pull request #76 from mohammad-rj/master

sendDirectMessage to userId without thread

Author: NicklasWallgren

src/Client/Features/DirectFeaturesTrait.php

@@ -74,6 +74,27 @@ public function sendThreadMessage(string $text, string $threadId): PromiseInterf
         });
     }
 
+    /**
+     * Sends a thread message.
+     *
+     * @param string $text
+     * @param string $userId
+     * @return PromiseInterface<DirectSendItemResponse>
+     */
+    public function sendDirectMessage(string $text, string $userId): PromiseInterface
+    {
+        return $this->authenticated(function () use ($text, $userId): PromiseInterface {
+            $request = $this->buildRequest('direct_v2/threads/broadcast/text/', new DirectSendItemResponse())
+                ->addPayloadParam('text', $text)
+                ->addPayloadParam('thread_ids', "[0]")
+                ->addPayloadParam('recipient_users', "[[$userId]]")
+                ->addUniqueContext()
+                ->addCSRFTokenAndUserId($this->session);
+
+            return $this->call($request);
+        });
+    }
+
     /**
      * Set thread id as seen.
      *

src/Traits/MakeDirectRequestAccessible.php

@@ -93,6 +93,31 @@ public function sendThreadMessagePromise(string $text, string $threadId): Promis
         return $this->getClient()->sendThreadMessage($text, $threadId);
     }
 
+    /**
+     * Sends a message to a thread.
+     *
+     * @param string $text
+     * @param string $userId
+     * @return DirectSendItemResponse
+     * @throws InstagramException in case of an error
+     */
+    public function sendDirectMessage(string $text, string $userId): DirectSendItemResponse
+    {
+        return PromiseUtils::wait($this->sendDirectMessagePromise($text, $userId));
+    }
+
+    /**
+     * Sends a message to a thread.
+     *
+     * @param string $text
+     * @param string $userId
+     * @return PromiseInterface<DirectSendItemResponse|InstagramException>
+     */
+    public function sendDirectMessagePromise(string $text, string $userId): PromiseInterface
+    {
+        return $this->getClient()->sendDirectMessage($text, $userId);
+    }
+
     /**
      * Sets thread item as seen.
      *