<?php namespace flow\social;

[0] Fix | Delete

use SimpleXMLElement;

[1] Fix | Delete

use stdClass;

[2] Fix | Delete

[3] Fix | Delete

if ( ! defined( 'WPINC' ) ) die;

[4] Fix | Delete

/**

[5] Fix | Delete

* Flow-Flow.

[6] Fix | Delete

*

[7] Fix | Delete

* @package FlowFlow

[8] Fix | Delete

* @author Looks Awesome <email@looks-awesome.com>

[9] Fix | Delete

[10] Fix | Delete

* @link http://looks-awesome.com

[11] Fix | Delete

* @copyright 2014-2016 Looks Awesome

[12] Fix | Delete

*/

[13] Fix | Delete

class FFYoutube extends FFHttpRequestFeed implements LAFeedWithComments {

[14] Fix | Delete

private $profile = null;

[15] Fix | Delete

private $profiles = array();

[16] Fix | Delete

private $userlink = null;

[17] Fix | Delete

private $apiKeyPart = '';

[18] Fix | Delete

private $image;

[19] Fix | Delete

private $media;

[20] Fix | Delete

private $videoId;

[21] Fix | Delete

private $isSearch = false;

[22] Fix | Delete

private $isPlaylist = false;

[23] Fix | Delete

private $statistics;

[24] Fix | Delete

private $pagination = true;

[25] Fix | Delete

private $nextPageToken = '';

[26] Fix | Delete

private $pageIndex = 0;

[27] Fix | Delete

private $order = false;

[28] Fix | Delete

[29] Fix | Delete

public function __construct() {

[30] Fix | Delete

parent::__construct( 'youtube' );

[31] Fix | Delete

}

[32] Fix | Delete

[33] Fix | Delete

public function deferredInit($feed) {

[34] Fix | Delete

$this->apiKeyPart = '&key=' . $feed->google_api_key;

[35] Fix | Delete

[36] Fix | Delete

if (isset($feed->{'timeline-type'})) {

[37] Fix | Delete

$content = urlencode($feed->content);

[38] Fix | Delete

switch ( $feed->{'timeline-type'} ) {

[39] Fix | Delete

case 'user_timeline':

[40] Fix | Delete

$this->userlink = "https://www.youtube.com/user/{$content}";

[41] Fix | Delete

$profileUrl = "https://www.googleapis.com/youtube/v3/channels?part=snippet%2CcontentDetails&forUsername={$content}" . $this->apiKeyPart;

[42] Fix | Delete

$this->profile = $this->getProfile($profileUrl);

[43] Fix | Delete

$this->url = "https://www.googleapis.com/youtube/v3/playlistItems?part=id%2Csnippet&playlistId={$this->profile->uploads}&maxResults=50" . $this->apiKeyPart;

[44] Fix | Delete

break;

[45] Fix | Delete

case 'channel':

[46] Fix | Delete

$this->profile = $this->getProfile4Search($content);

[47] Fix | Delete

$this->userlink = $this->getUserlink4Search($content);

[48] Fix | Delete

$this->url = "https://www.googleapis.com/youtube/v3/playlistItems?part=id%2Csnippet&playlistId={$this->profile->uploads}&maxResults=50" . $this->apiKeyPart;

[49] Fix | Delete

break;

[50] Fix | Delete

case 'playlist':

[51] Fix | Delete

$this->isSearch = true;

[52] Fix | Delete

$this->isPlaylist = true;

[53] Fix | Delete

$this->url = "https://www.googleapis.com/youtube/v3/playlistItems?part=id%2Csnippet&playlistId={$content}&maxResults=50" . $this->apiKeyPart;

[54] Fix | Delete

$this->order = $feed->{'playlist-order'};

[55] Fix | Delete

break;

[56] Fix | Delete

case 'search':

[57] Fix | Delete

$this->isSearch = true;

[58] Fix | Delete

$this->url = "https://www.googleapis.com/youtube/v3/search?part=id%2Csnippet&q={$content}&type=video&order=date&maxResults=50" . $this->apiKeyPart;

[59] Fix | Delete

break;

[60] Fix | Delete

}

[61] Fix | Delete

}

[62] Fix | Delete

}

[63] Fix | Delete

[64] Fix | Delete

protected function getUrl() {

[65] Fix | Delete

return parent::getUrl() . $this->nextPageToken;

[66] Fix | Delete

}

[67] Fix | Delete

[68] Fix | Delete

protected function items($request){

[69] Fix | Delete

$items = array();

[70] Fix | Delete

$pxml = json_decode($request);

[71] Fix | Delete

if ($this->isSuitablePage($pxml)) {

[72] Fix | Delete

$videoResults = array();

[73] Fix | Delete

$this->statistics = array();

[74] Fix | Delete

foreach ($pxml->items as $item) {

[75] Fix | Delete

if ((!isset($item->id->videoId) && !isset($item->snippet->resourceId->videoId)) || !isset($item->snippet->thumbnails)) {

[76] Fix | Delete

continue;//TODO fix this case

[77] Fix | Delete

}

[78] Fix | Delete

$videoId = is_object($item->id) ? $item->id->videoId : $item->snippet->resourceId->videoId;

[79] Fix | Delete

array_push($videoResults, $videoId);

[80] Fix | Delete

}

[81] Fix | Delete

$videoIds = join('%2C', $videoResults);

[82] Fix | Delete

$url = "https://www.googleapis.com/youtube/v3/videos?part=id%2Cstatistics&id={$videoIds}" . $this->apiKeyPart;

[83] Fix | Delete

$data = $this->getFeedData($url);

[84] Fix | Delete

if ( sizeof( $data['errors'] ) > 0 ) {

[85] Fix | Delete

$this->errors[] = array(

[86] Fix | Delete

'type' => $this->getType(),

[87] Fix | Delete

'message' => $this->filterErrorMessage($data['errors']),

[88] Fix | Delete

'url' => $url

[89] Fix | Delete

);

[90] Fix | Delete

}

[91] Fix | Delete

else {

[92] Fix | Delete

$statistics = json_decode($data['response']);

[93] Fix | Delete

foreach ( $statistics->items as $stat ) {

[94] Fix | Delete

$this->statistics[$stat->id] = $stat->statistics;

[95] Fix | Delete

}

[96] Fix | Delete

}

[97] Fix | Delete

$items = $pxml->items;

[98] Fix | Delete

}

[99] Fix | Delete

$this->pageIndex++;

[100] Fix | Delete

return $items;

[101] Fix | Delete

}

[102] Fix | Delete

[103] Fix | Delete

protected function isSuitableOriginalPost( $post ) {

[104] Fix | Delete

if ((!isset($post->id->videoId) && !isset($post->snippet->resourceId->videoId)) || !isset($post->snippet->thumbnails)) {

[105] Fix | Delete

return false;//TODO fix this case

[106] Fix | Delete

}

[107] Fix | Delete

if ($post->snippet->title === 'Private video' || $post->snippet->title === 'Deleted video'){

[108] Fix | Delete

return false;

[109] Fix | Delete

}

[110] Fix | Delete

return parent::isSuitableOriginalPost( $post );

[111] Fix | Delete

}

[112] Fix | Delete

[113] Fix | Delete

protected function prepare( $item ) {

[114] Fix | Delete

$this->image = null;

[115] Fix | Delete

$this->media = null;

[116] Fix | Delete

[117] Fix | Delete

$this->videoId = is_object($item->id) ? $item->id->videoId : $item->snippet->resourceId->videoId;

[118] Fix | Delete

if ($this->isSearch) {

[119] Fix | Delete

$channelId = $item->snippet->channelId;

[120] Fix | Delete

$this->userlink = $this->getUserlink4Search( $channelId );

[121] Fix | Delete

$this->profile = $this->getProfile4Search( $channelId );

[122] Fix | Delete

}

[123] Fix | Delete

return parent::prepare( $item );

[124] Fix | Delete

}

[125] Fix | Delete

[126] Fix | Delete

/**

[127] Fix | Delete

* @param SimpleXMLElement $item

[128] Fix | Delete

* @return string

[129] Fix | Delete

*/

[130] Fix | Delete

protected function getId( $item ) {

[131] Fix | Delete

return $this->videoId;

[132] Fix | Delete

}

[133] Fix | Delete

[134] Fix | Delete

/**

[135] Fix | Delete

* @param SimpleXMLElement $item

[136] Fix | Delete

* @return string

[137] Fix | Delete

*/

[138] Fix | Delete

protected function getScreenName($item){

[139] Fix | Delete

return $this->profile->nickname;

[140] Fix | Delete

}

[141] Fix | Delete

[142] Fix | Delete

/**

[143] Fix | Delete

* @param SimpleXMLElement $item

[144] Fix | Delete

* @return string

[145] Fix | Delete

*/

[146] Fix | Delete

protected function getHeader($item){

[147] Fix | Delete

return FFFeedUtils::wrapLinks(strip_tags((string)$item->snippet->title));

[148] Fix | Delete

}

[149] Fix | Delete

[150] Fix | Delete

/**

[151] Fix | Delete

* @param SimpleXMLElement $item

[152] Fix | Delete

* @return string

[153] Fix | Delete

*/

[154] Fix | Delete

protected function getContent( $item ) {

[155] Fix | Delete

return FFFeedUtils::wrapLinks(strip_tags( (string) $item->snippet->description ) );

[156] Fix | Delete

}

[157] Fix | Delete

[158] Fix | Delete

/**

[159] Fix | Delete

* @param SimpleXMLElement $item

[160] Fix | Delete

* @return bool

[161] Fix | Delete

*/

[162] Fix | Delete

protected function showImage($item){

[163] Fix | Delete

$thumbnail = null;

[164] Fix | Delete

$thumbnails = $item->snippet->thumbnails;

[165] Fix | Delete

if (property_exists($thumbnails, 'maxres')){

[166] Fix | Delete

$thumbnail = $this->isSuitableThumbnail( $thumbnails->maxres);

[167] Fix | Delete

}

[168] Fix | Delete

[169] Fix | Delete

if (is_null($this->image) && isset( $thumbnails->standard)) {

[170] Fix | Delete

$thumbnail = $this->isSuitableThumbnail( $thumbnails->standard, $thumbnail);

[171] Fix | Delete

}

[172] Fix | Delete

[173] Fix | Delete

if (is_null($this->image) && isset( $thumbnails->high)) {

[174] Fix | Delete

$thumbnail = $this->isSuitableThumbnail( $thumbnails->high, $thumbnail);

[175] Fix | Delete

}

[176] Fix | Delete

[177] Fix | Delete

if (is_null($this->image) && isset( $thumbnails->medium)) {

[178] Fix | Delete

$thumbnail = $this->isSuitableThumbnail( $thumbnails->medium, $thumbnail);

[179] Fix | Delete

}

[180] Fix | Delete

[181] Fix | Delete

if (is_null($this->image) && isset( $thumbnails->default)) {

[182] Fix | Delete

$thumbnail = $this->isSuitableThumbnail( $thumbnails->default, $thumbnail);

[183] Fix | Delete

}

[184] Fix | Delete

[185] Fix | Delete

if (is_null($this->image)){

[186] Fix | Delete

$this->image = $this->createImage($thumbnail->url, $thumbnail->width, $thumbnail->height);

[187] Fix | Delete

}

[188] Fix | Delete

[189] Fix | Delete

$height = FFFeedUtils::getScaleHeight(600, $thumbnail->width, $thumbnail->height);

[190] Fix | Delete

$this->media = $this->createMedia("http://www.youtube.com/v/{$this->videoId}?version=3&f=videos&autoplay=0", 600, $height, "application/x-shockwave-flash");

[191] Fix | Delete

[192] Fix | Delete

return true;

[193] Fix | Delete

}

[194] Fix | Delete

[195] Fix | Delete

/**

[196] Fix | Delete

* @param SimpleXMLElement $item

[197] Fix | Delete

* @return array

[198] Fix | Delete

*/

[199] Fix | Delete

protected function getImage( $item ) {

[200] Fix | Delete

return $this->image;

[201] Fix | Delete

}

[202] Fix | Delete

[203] Fix | Delete

/**

[204] Fix | Delete

* @param SimpleXMLElement $item

[205] Fix | Delete

* @return array

[206] Fix | Delete

*/

[207] Fix | Delete

protected function getMedia( $item ) {

[208] Fix | Delete

return $this->media;

[209] Fix | Delete

}

[210] Fix | Delete

[211] Fix | Delete

/**

[212] Fix | Delete

* @param SimpleXMLElement $item

[213] Fix | Delete

* @return string

[214] Fix | Delete

*/

[215] Fix | Delete

protected function getProfileImage( $item ) {

[216] Fix | Delete

return $this->profile->profileImage;

[217] Fix | Delete

}

[218] Fix | Delete

[219] Fix | Delete

protected function getSystemDate( $item ) {

[220] Fix | Delete

return strtotime($item->snippet->publishedAt);

[221] Fix | Delete

}

[222] Fix | Delete

[223] Fix | Delete

protected function getUserlink( $item ) {

[224] Fix | Delete

return $this->userlink;

[225] Fix | Delete

}

[226] Fix | Delete

[227] Fix | Delete

protected function getPermalink( $item ) {

[228] Fix | Delete

return "https://www.youtube.com/watch?v={$this->videoId}";

[229] Fix | Delete

}

[230] Fix | Delete

[231] Fix | Delete

protected function getAdditionalInfo( $item ) {

[232] Fix | Delete

$additional = parent::getAdditionalInfo( $item );

[233] Fix | Delete

if (array_key_exists($this->videoId, $this->statistics)){

[234] Fix | Delete

$stat = $this->statistics[$this->videoId];

[235] Fix | Delete

$additional['views'] = isset($stat->viewCount) ? (string)$stat->viewCount : '';

[236] Fix | Delete

$additional['likes'] = isset($stat->likeCount) ? (string)$stat->likeCount : '';

[237] Fix | Delete

$additional['dislikes'] = isset($stat->dislikeCount) ? (string)$stat->dislikeCount : '';

[238] Fix | Delete

$additional['comments'] = isset($stat->commentCount) ? (string)$stat->commentCount : '';

[239] Fix | Delete

}

[240] Fix | Delete

return $additional;

[241] Fix | Delete

}

[242] Fix | Delete

[243] Fix | Delete

protected function nextPage( $result ) {

[244] Fix | Delete

return $this->pagination;

[245] Fix | Delete

}

[246] Fix | Delete

[247] Fix | Delete

private function getProfile4Search($channelId){

[248] Fix | Delete

if (!array_key_exists($channelId, $this->profiles)){

[249] Fix | Delete

$profileUrl = "https://www.googleapis.com/youtube/v3/channels?part=snippet%2CcontentDetails&id={$channelId}" . $this->apiKeyPart;

[250] Fix | Delete

$profile = $this->getProfile($profileUrl);

[251] Fix | Delete

$this->profiles[$channelId] = $profile;

[252] Fix | Delete

return $profile;

[253] Fix | Delete

}

[254] Fix | Delete

return $this->profiles[$channelId];

[255] Fix | Delete

}

[256] Fix | Delete

[257] Fix | Delete

/**

[258] Fix | Delete

* @param $profileUrl

[259] Fix | Delete

*

[260] Fix | Delete

* @return stdClass

[261] Fix | Delete

* @throws LASocialException

[262] Fix | Delete

* @throws LASocialRequestException

[263] Fix | Delete

*/

[264] Fix | Delete

private function getProfile($profileUrl){

[265] Fix | Delete

$profile = new stdClass();

[266] Fix | Delete

$data = FFFeedUtils::getFeedDataWithThrowException($profileUrl, 60, false, true, $this->feed->use_curl_follow_location, $this->feed->use_ipv4);

[267] Fix | Delete

$pxml = json_decode($data['response']);

[268] Fix | Delete

if (isset($pxml->items[0])){

[269] Fix | Delete

$item = $pxml->items[0];

[270] Fix | Delete

$profile->nickname = $item->snippet->title;

[271] Fix | Delete

$profile->profileImage = $item->snippet->thumbnails->high->url;

[272] Fix | Delete

$profile->uploads = $item->contentDetails->relatedPlaylists->uploads;

[273] Fix | Delete

return $profile;

[274] Fix | Delete

}

[275] Fix | Delete

throw new LASocialException('Please use channel feed type, user feed is not supported for this channel');

[276] Fix | Delete

}

[277] Fix | Delete

[278] Fix | Delete

private function getUserlink4Search($channelId){

[279] Fix | Delete

return "https://www.youtube.com/channel/{$channelId}";

[280] Fix | Delete

}

[281] Fix | Delete

[282] Fix | Delete

private function isSuitablePage($pxml){

[283] Fix | Delete

$needCountPage = ceil($this->getCount() / 50);

[284] Fix | Delete

if ($this->isPlaylist && $this->order){

[285] Fix | Delete

$totalResult = intval($pxml->pageInfo->totalResults);

[286] Fix | Delete

$countPage = ceil($totalResult / 50);

[287] Fix | Delete

$additionalPage = fmod($totalResult, 50) > fmod($this->getCount(),50) ? 0 : 1;

[288] Fix | Delete

if (fmod($this->getCount(),50) == 0) $additionalPage = 1;

[289] Fix | Delete

$needCountPage = $needCountPage + $additionalPage;

[290] Fix | Delete

$isSuitablePage = $this->pageIndex >= ($countPage - $needCountPage);

[291] Fix | Delete

}

[292] Fix | Delete

else {

[293] Fix | Delete

$this->pagination = $needCountPage > $this->pageIndex + 1;

[294] Fix | Delete

$isSuitablePage = $needCountPage > $this->pageIndex;

[295] Fix | Delete

}

[296] Fix | Delete

[297] Fix | Delete

if (isset($pxml->nextPageToken))

[298] Fix | Delete

$this->nextPageToken = "&pageToken=" . $pxml->nextPageToken;

[299] Fix | Delete

else

[300] Fix | Delete

$this->pagination = false;

[301] Fix | Delete

[302] Fix | Delete

return $isSuitablePage && isset($pxml->items);

[303] Fix | Delete

}

[304] Fix | Delete

[305] Fix | Delete

private function isSuitableThumbnail($thumbnail, $current_thumbnail = null){

[306] Fix | Delete

if ( round( $thumbnail->width / $thumbnail->height, 2) == 1.78) {

[307] Fix | Delete

$this->image = $this->createImage($thumbnail->url, $thumbnail->width, $thumbnail->height);

[308] Fix | Delete

}

[309] Fix | Delete

if (is_null($current_thumbnail)){

[310] Fix | Delete

return $thumbnail;

[311] Fix | Delete

}

[312] Fix | Delete

return $current_thumbnail;

[313] Fix | Delete

}

[314] Fix | Delete

[315] Fix | Delete

public function getComments($item) {

[316] Fix | Delete

if (is_object($item)){

[317] Fix | Delete

return array();

[318] Fix | Delete

}

[319] Fix | Delete

[320] Fix | Delete

$objectId = $item;

[321] Fix | Delete

$accessToken = $this->feed->google_api_key;

[322] Fix | Delete

$url = "https://www.googleapis.com/youtube/v3/commentThreads?videoId={$objectId}&maxResults={$this->getCount()}&part=snippet&key={$accessToken}";

[323] Fix | Delete

$request = $this->getFeedData($url);

[324] Fix | Delete

$json = json_decode($request['response']);

[325] Fix | Delete

[326] Fix | Delete

if (!is_object($json) || (is_object($json) && sizeof($json->items) == 0)) {

[327] Fix | Delete

if (isset($request['errors']) && is_array($request['errors'])){

[328] Fix | Delete

if (!empty($request['errors'])){

[329] Fix | Delete

foreach ( $request['errors'] as $error ) {

[330] Fix | Delete

$error['type'] = 'youtube';

[331] Fix | Delete

//TODO $this->filterErrorMessage

[332] Fix | Delete

$this->errors[] = $error;

[333] Fix | Delete

throw new \Exception();

[334] Fix | Delete

}

[335] Fix | Delete

}

[336] Fix | Delete

}

[337] Fix | Delete

else {

[338] Fix | Delete

$this->errors[] = array('type'=>'youtube', 'message' => 'Bad request, access token issue. <a href="http://docs.social-streams.com/article/55-400-bad-request" target="_blank">Troubleshooting</a>.', 'url' => $url);

[339] Fix | Delete

throw new \Exception();

[340] Fix | Delete

}

[341] Fix | Delete

return array();

[342] Fix | Delete

}

[343] Fix | Delete

else {

[344] Fix | Delete

if($json->items){

[345] Fix | Delete

// return first 5 comments

[346] Fix | Delete

$data = array_slice($json->items, 0, 5);

[347] Fix | Delete

$result = array();

[348] Fix | Delete

foreach ($data as $item){

[349] Fix | Delete

$obj = new stdClass();

[350] Fix | Delete

$obj->id = $item->snippet->topLevelComment->id;

[351] Fix | Delete

$obj->from = array(

[352] Fix | Delete

'id' => $item->snippet->topLevelComment->snippet->authorChannelId->value,

[353] Fix | Delete

'full_name' => $item->snippet->topLevelComment->snippet->authorDisplayName

[354] Fix | Delete

);

[355] Fix | Delete

$obj->text = $item->snippet->topLevelComment->snippet->textDisplay;

[356] Fix | Delete

$obj->created_time = $item->snippet->topLevelComment->snippet->publishedAt;

[357] Fix | Delete

$result[] = $obj;

[358] Fix | Delete

}

[359] Fix | Delete

return $result;

[360] Fix | Delete

}else{

[361] Fix | Delete

$this->errors[] = array(

[362] Fix | Delete

'type' => 'instagram',

[363] Fix | Delete

'message' => 'User not found',

[364] Fix | Delete

'url' => $url

[365] Fix | Delete

);

[366] Fix | Delete

throw new \Exception();

[367] Fix | Delete

}

[368] Fix | Delete

}

[369] Fix | Delete

}

[370] Fix | Delete

}

[371] Fix | Delete