Send Message to User

src/TwitterChannel.php

@@ -35,9 +35,15 @@ public function __construct(Client $client, Twitter $twitter)
     public function send($notifiable, Notification $notification)
     {
         $twitterMessage = $notification->toTwitter($notifiable);
-
-        $response = $this->twitter->connection->post(
-            'statuses/update', ['status' => $twitterMessage->getContent()]);
+        if ($twitterMessage->getReceiver() != null) {
+            $response = $this->twitter->connection->post('direct_messages/new', [
+                    'text' => $twitterMessage->getContent(),
+                    'screen_name' => $twitterMessage->getReceiver(),
+                ]);
+        } else {
+            $response = $this->twitter->connection->post(
+                'statuses/update', ['status' => $twitterMessage->getContent()]);
+        }
 
         if (isset($response->errors)) {
             throw CouldNotSendNotification::serviceRespondedWithAnError($response);

src/TwitterMessage.php

@@ -6,23 +6,35 @@ class TwitterMessage
 {
     /** @var string */
     protected $content;
+    protected $to;
 
     /**
      * @param string $content
      *
      * @return static
      */
-    public static function create($content = '')
+    public static function create()
     {
-        return new static($content);
+        $args = func_get_args();
+        if (count($args) == 2) {
+            return new static($args[0], $args[1]);
+        } else {
+            return new static($args[0]);
+        }
     }
 
     /*
      * @param string $content
      */
-    public function __construct($content = '')
+    public function __construct()
     {
-        $this->content = $content;
+        $args = func_get_args();
+        if (count($args) == 2) {
+            $this->to = $args[0];
+            $this->content = $args[1];
+        } else {
+            $this->content = $args[0];
+        }
     }
 
     /**
@@ -34,4 +46,14 @@ public function getContent()
     {
         return $this->content;
     }
+
+    /**
+     * Get Twitter message receiver.
+     *
+     * @return string
+     */
+    public function getReceiver()
+    {
+        return $this->to;
+    }
 }

tests/TwitterMessageTest.php

@@ -24,4 +24,13 @@ public function it_accepts_a_message_when_constructing_a_message()
 
         $this->assertEquals('myMessage', $message->getContent());
     }
+
+    /** @test */
+    public function it_accepts_a_message_to_user_when_constructing_a_user_with_message()
+    {
+        $message = new TwitterMessage('twitterUser', 'myMessage');
+
+        $this->assertEquals('myMessage', $message->getContent());
+        $this->assertEquals('twitterUser', $message->getReceiver());
+    }
 }