View source
<?php
namespace Drupal\statusmessage;
require_once __DIR__ . './../includes/TwitterAPIExchange.php';
use TwitterAPIExchange;
use Drupal\statusmessage\Entity;
use Drupal\taxonomy\Entity\Term;
use Drupal\node\Entity\Node;
use Drupal\file\Entity\File;
class StatusTwitter {
protected $oauthAccessToken;
protected $oauthAccessTokenSecret;
protected $consumerKey;
protected $consumerSecret;
protected $parameter;
private $twitterConfig;
public function __construct($parameter) {
$this->twitterConfig = \Drupal::config('twitter_api.settings');
$this->parameter = $parameter;
}
public function getConsumerSecret() {
return $this->consumerSecret;
}
public function setConsumerSecret($consumerSecret) {
$this->consumerSecret = $consumerSecret;
}
public function getConsumerKey() {
return $this->consumerKey;
}
public function setConsumerKey($consumerKey) {
$this->consumerKey = $consumerKey;
}
public function getOauthAccessTokenSecret() {
return $this->oauthAccessTokenSecret;
}
public function setOauthAccessTokenSecret($oauthAccessTokenSecret) {
$this->oauthAccessTokenSecret = $oauthAccessTokenSecret;
}
public function getOauthAccessToken() {
return $this->oauthAccessToken;
}
public function setOauthAccessToken($oauthAccessToken) {
$this->oauthAccessToken = $oauthAccessToken;
}
private static function getApiStatusParameter() {
return 'https://api.twitter.com/1.1/statuses/show.json';
}
private function generateRequest($url) {
$twid = $this
->parseUrl($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(self::getApiStatusParameter(), 'GET');
}
public function sendRequest() {
if ($response = $this
->generateRequest($this->parameter)
->performRequest()) {
$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_video', $media->video);
}
if ($media->userImage) {
$tweetNode
->set('field_user_image', $media->userImage);
}
if ($tweetNode
->save()) {
return $tweetNode
->id();
}
return null;
}
}
private function parseUrl($text) {
return explode('status/', $text)[1];
}
private function setNodeData($data) {
$nowTime = new \DateTime();
$posted = date('Y-m-d\\TH:i:s', strtotime($data->created_at));
$user = \Drupal::currentUser();
$ip = \Drupal::request()
->getClientIp();
$links = [];
$terms = $this
->processTerms($data);
if (!empty($data->entities->urls)) {
foreach ($data->entities->urls as $url) {
$links[] = !strpos($url->display_url, 'http') ? 'http://' . $url->display_url : $url->display_url;
}
}
if (isset($data->extended_entities->media)) {
$media = $this
->getTweetMedia($data);
}
if ($data->user->profile_image_url_https) {
}
$node = Node::create([
'type' => 'tweet',
'title' => $data->user->screen_name . '_' . $nowTime
->format('Y.m.d.Hi'),
'uid' => $user
->id(),
'field_tags' => $terms->tags,
'field_tweet_url' => $this->parameter,
'field_twit_id' => $data->id,
'field_post_date' => [
$posted,
],
'field_username' => $terms->username,
'field_users' => $terms->users,
'field_links' => $links,
'status' => 1,
]);
$node
->set('body', [
'value' => '<div class="created-date"> ' . $data->created_at . '</div>' . $data->full_text,
'format' => 'full_html',
]);
return $node;
}
private function getTweetMedia($data) {
$media = new \stdClass();
$images = [];
$video = null;
$userImage = null;
if ($data->user->profile_image_url_https) {
$userImage = file_get_contents($data->user->profile_image_url_https);
$file = file_save_data($userImage, 'public://' . substr($data->user->profile_image_url_https, strrpos($data->user->profile_image_url_https, '/') + 1), FILE_EXISTS_REPLACE);
$userImage = $file
->id();
}
foreach ($data->extended_entities->media as $media) {
$image = file_get_contents($media->media_url);
$file = file_save_data($image, 'public://' . substr($media->media_url, strrpos($media->media_url, '/') + 1), FILE_EXISTS_REPLACE);
$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;
$variantCount = count($data->extended_entities->media[0]->video_info->variants);
if ($variantCount > 1) {
for ($z = 0; $z < $variantCount; $z++) {
if ($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;
}
}
}
}
else {
$bitrate->index = 0;
}
if ($bitrate->index !== null) {
$data->extended_entities->media[0]->video_info->variants[$bitrate->index]->url;
$video = file_get_contents($data->extended_entities->media[0]->video_info->variants[$bitrate->index]->url);
$file = file_save_data($video, 'public://' . substr($data->extended_entities->media[0]->video_info->variants[$bitrate->index]->url, strrpos($data->extended_entities->media[0]->video_info->variants[$bitrate->index]->url, '/') + 1), FILE_EXISTS_REPLACE);
$video = $file
->id();
}
}
$media->images = $images;
$media->video = $video;
$media->userImage = $userImage;
return $media;
}
private function processTerms($data) {
$terms = new \stdClass();
$terms->tags = [];
$terms->users = [];
$terms->username = -1;
if ($data->user->screen_name) {
$term = \Drupal::entityQuery('taxonomy_term')
->condition('name', $data->user->screen_name)
->condition('vid', 'twitter_user')
->execute();
if (count($term) < 1) {
$term = Term::create([
'name' => $data->user->screen_name,
'vid' => 'twitter_user',
'field_count' => 1,
]);
if ($term
->save()) {
$terms->username = $term
->id();
if (\Drupal::moduleHandler()
->moduleExists('heartbeat')) {
\Drupal\heartbeat\Entity\Heartbeat::newTermUsage($term
->id());
}
}
else {
\Drupal::logger('StatusTwitter')
->warning('Could not save term with name %name', array(
'%name' => $data->user->screen_name,
));
}
}
else {
$terms->username = array_values($term)[0];
if (\Drupal::moduleHandler()
->moduleExists('heartbeat')) {
\Drupal\heartbeat\Entity\Heartbeat::updateTermUsage(array_values($term)[0], 'twitter_user');
}
}
$term = NULL;
foreach ($data->entities->hashtags as $key => $h) {
$term = \Drupal::entityQuery('taxonomy_term')
->condition('name', $h->text)
->condition('vid', 'twitter')
->execute();
if (count($term) < 1) {
$term = Term::create([
'name' => $h->text,
'vid' => 'twitter',
'field_count' => 1,
]);
if ($term
->save()) {
$terms->tags[] = $term
->id();
if (\Drupal::moduleHandler()
->moduleExists('heartbeat')) {
\Drupal\heartbeat\Entity\Heartbeat::newTermUsage($term
->id());
}
}
else {
\Drupal::logger('StatusTwitter')
->warning('Could not save term with name %name', array(
'%name' => $h->text,
));
}
}
else {
$terms->tags[] = array_values($term)[0];
if (\Drupal::moduleHandler()
->moduleExists('heartbeat')) {
\Drupal\heartbeat\Entity\Heartbeat::updateTermUsage(array_values($term)[0], 'twitter');
}
}
}
$term = NULL;
foreach ($data->entities->user_mentions as $u) {
$term = \Drupal::entityQuery('taxonomy_term')
->condition('name', $u->screen_name)
->condition('vid', 'twitter_user')
->execute();
if (count($term) < 1) {
$term = Term::create([
'name' => $u->screen_name,
'vid' => 'twitter_user',
]);
if ($term
->save()) {
$terms->users[] = $term
->id();
}
else {
\Drupal::logger('StatusTwitter')
->warning('Could not save term with name %name', array(
'%name' => $u->screen_name,
));
}
}
else {
$terms->users[] = array_values($term)[0];
}
}
}
return $terms;
}
}
