Twitter branch

config/install/taxonomy.vocabulary.usernames.yml

@@ -0,0 +1,10 @@
+uuid: 44e7a317-5088-4f55-8b09-e4ea2d6f9024
+langcode: en
+status: true
+dependencies: {  }
+name: Usernames
+vid: usernames
+description: 'Names of users on other social media platforms'
+hierarchy: 0
+weight: 0
+

src/Entity/Status.php

@@ -57,6 +57,8 @@ use Drupal\user\UserInterface;
  *   field_ui_base_route = "entity.status_type.edit_form"
  * )
  */
+const TWEET_NODE_TYPE = 'tweet';
+
 class Status extends ContentEntityBase implements StatusInterface {
   use EntityChangedTrait;
   /**

src/Form/StatusForm.php

@@ -9,7 +9,7 @@ use Drupal\statusmessage\ClientGeneratorService;
 use Drupal\statusmessage\StatusService;
 use Drupal\statusmessage\StatusTypeService;
 use Drupal\statusmessage\Ajax\ClientCommand;
-use Drupal\heartbeat\HeartbeatStreamServices;
+use Drupal\statusmessage\StatusTwitter;
 use Drupal\Core\Ajax\AjaxResponse;
 use Drupal\heartbeat\Ajax\SelectFeedCommand;
 use Symfony\Component\DependencyInjection\ContainerInterface;
@@ -198,8 +198,14 @@ $stophere = null;
   }
   public function statusAjaxSubmit(array &$form, FormStateInterface $form_state) {
 
-
-
+    if (strpos($form_state->getValue('message'), 'twitter')) {
+      preg_match_all('#\bhttps?://[^,\s()<>]+(?:\([\w\d]+\)|([^,[:punct:]\s]|/))#', $message, $match);
+      if ($this->previewGenerator !== null && !empty($match) && array_values($match)[0] !== null) {
+        $url = array_values($match)[0];
+        $statusTwitter = new StatusTwitter($url);
+        $nid = $statusTwitter->sendRequest();
+      }
+    }
 
     if (!empty($this->statusTypeService)) {
       foreach ($this->statusTypeService->loadAll() as $type) {

src/StatusTwitter.php

@@ -8,6 +8,13 @@
 
 namespace Drupal\statusmessage;
 
+require_once(DRUPAL_ROOT .'/vendor/autoload.php');
+
+use TwitterAPIExchange;
+use Drupal\statusmessage\Entity;
+use Drupal\node\Entity\Node;
+use Drupal\file\Entity\File;
+
 
 class StatusTwitter {
 
@@ -15,14 +22,15 @@ class StatusTwitter {
   protected $oauthAccessTokenSecret;
   protected $consumerKey;
   protected $consumerSecret;
+  protected $parameter;
 
-  private $instagramConfig;
+  private $twitterConfig;
 
-  public function __construct() {
-    $this->instagramConfig = \Drupal::config('twitter_api.settings');
+  public function __construct($parameter) {
+    $this->twitterConfig = \Drupal::config('twitter_api.settings');
+    $this->parameter = $parameter;
   }
 
-
   /**
    * @return mixed
    */
@@ -50,8 +58,7 @@ class StatusTwitter {
   /**
    * @param mixed $consumerKey
    */
-  public function setConsumerKey($consumerKey)
-  {
+  public function setConsumerKey($consumerKey) {
     $this->consumerKey = $consumerKey;
   }
 
@@ -84,28 +91,149 @@ class StatusTwitter {
     $this->oauthAccessToken = $oauthAccessToken;
   }
 
+  private function getApiStatusParameter() {
+    return 'https://api.twitter.com/1.1/statuses/show.json';
+  }
+
+
+  private function generateRequest($url) {
+
+    $twid = $this->parseUrl($url);
 
-  public function generateRequest($url) {
+    $settings = [
+      'oauth_access_token' => $this->twitterConfig->get('oauth_access_token'),
+      'oauth_access_token_secret' => $this->twitterConfig->get('oauth_access_token_secret'),
+      'consumer_key' => $this->twitterConfig->get('consumer_key'),
+      'consumer_secret' => $this->twitterConfig->get('consumer_secret'),
+    ];
 
+    $twitterApi = new TwitterAPIExchange($settings);
+    $getField = '?id=' . $twid . '&tweet_mode=extended';
+    return $twitterApi
+      ->setGetfield($getField)
+      ->buildOauth($this->getApiStatusParameter(), 'GET');
   }
 
-  public function sendRequest($twid) {
+  public function sendRequest() {
 
-    //TODO Instantiating an Http Client
+    if ($response = $this->generateRequest($this->parameter)->performRequest()) {
 
-    $twitterConfig = \Drupal::config('twitter_api.settings');
+      $data = json_decode($response);
+      $tweetNode = $this->setNodeData($data);
 
+      $media = $this->getTweetMedia($data);
 
+      if ($media->images) {
+        $tweetNode->set('field_tweet_images', $media->images);
+      }
+
+      if ($media->video) {
+        $tweetNode->set('field_tweet_video', $media->video);
+      }
+
+      if ($tweetNode->save()) {
+        return $tweetNode->id();
+      }
+      return null;
     }
+  }
 
   private function parseUrl ($text) {
-
+    return explode('status/', $text)[1];
   }
 
 
-  public function setNodeData() {
+  private function setNodeData($data) {
+
+    //Create datetime object for title, media file path and content date field
+    $nowTime = new \DateTime();
+    $user = \Drupal::currentUser();
+    $ip =  \Drupal::request()->getClientIp();//get user's IP
+
+    $tags = [];
+    $users = [];
+    $links = [];
+
+    foreach($data->entities->hashtags as $key => $h) {
+      $tags[] = $h->text;
+    }
+    foreach($data->entities->user_mentions as $u) {
+      $users[] = $u->screen_name;
+    }
+
+    if (!empty($data->entities->urls)) {
+      foreach ($data->entities->urls as $url)  {
+        $links[] = $url->display_url;
+      }
+    }
+    //Check for attached media and create a directory for saving
+    if (isset($data->extended_entities->media)) {
+      $media = $this->getTweetMedia($data);
+    }
+
+    if ($data->user->profile_image_url_https) {
+      //TODO get profile image
+    }
+
+    $node = Node::create([
+      'type' => 'tweet',
+      'title' => $data->user->screen_name . '_' . $nowTime->format('Y.m.d.Hi'),
+      'uid' => $user->id(),
+      'field_tags' => $tags,
+      'field_tweet_url' => $this->parameter,
+      'field_twit_id' => $data->id,
+      'field_post_date' => strtok($data->created_at, ' +'),
+      'field_username' => $data->username,
+      'field_users' => $users,
+      'field_links' => $links,
+      'status' => 1,
+    ]);
+
+    $node->set('body', $data->full_text);
+    return $node;
 
   }
 
 
+  private function getTweetMedia($data) {
+    $media = new \stdClass();
+
+    foreach($data->extended_entities->media as $media)  {
+      $image = file_get_contents($media->media_url);
+      $file = file_save_data($image);
+      $images[] = $file->id();
+    }
+    if(!empty($data->extended_entities->media[0]->video_info->variants)) {
+      $z = null;
+      $vidUrl = null;
+      $bitrate = new stdClass();
+      $bitrate->value = null;
+      $bitrate->index = null;
+
+      for ($z = 0; $z < $data->extended_entities->media[0]->video_info->variants; $z++) {
+        if (!empty($data->extended_entities->media[0]->video_info->variants[$z]->bitrate) &&
+          $data->extended_entities->media[0]->video_info->variants[$z]->content_type === 'video/mp4') {
+          if ($data->extended_entities->media[0]->video_info->variants[$z]->bitrate > $bitrate->value) {
+            $bitrate->value = $data->extended_entities->media[0]->video_info->variants[$z]->bitrate;
+            $bitrate->index = $z;
+          }
+        }
+      }
+
+      if ($bitrate->index !== null) {
+        $data->extended_entities->media[0]->video_info->variants[$bitrate->index]->url;
+        $video = system_retrieve_file($vidUrl, null, TRUE);
+        $file = File::create([
+          'id' => 'id',
+        ])->save();
+      }
+    }
+
+    $media->images = $images;
+    $media->video = $video;
+
+    return $media;
+  }
+
 }
+