<?php namespace flow\social;

[0] Fix | Delete

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

[1] Fix | Delete

[2] Fix | Delete

use Exception;

[3] Fix | Delete

use flow\social\cache\FFImageSizeCacheBase;

[4] Fix | Delete

use stdClass;

[5] Fix | Delete

[6] Fix | Delete

/**

[7] Fix | Delete

* Flow-Flow.

[8] Fix | Delete

*

[9] Fix | Delete

* @package FlowFlow

[10] Fix | Delete

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

[11] Fix | Delete

[12] Fix | Delete

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

[13] Fix | Delete

* @copyright 2014-2016 Looks Awesome

[14] Fix | Delete

*/

[15] Fix | Delete

abstract class FFBaseFeed implements FFFeed{

[16] Fix | Delete

/** @var stdClass */

[17] Fix | Delete

public $feed;

[18] Fix | Delete

[19] Fix | Delete

private $id;

[20] Fix | Delete

/** @var FFImageSizeCacheBase */

[21] Fix | Delete

protected $cache;

[22] Fix | Delete

private $count;

[23] Fix | Delete

private $imageWidth;

[24] Fix | Delete

private $type;

[25] Fix | Delete

/**

[26] Fix | Delete

* Exclude words

[27] Fix | Delete

* @var array $filterByWords */

[28] Fix | Delete

private $filterByWords;

[29] Fix | Delete

/**

[30] Fix | Delete

* Include words

[31] Fix | Delete

* @var array $include */

[32] Fix | Delete

private $include;

[33] Fix | Delete

private $criticalError = true;

[34] Fix | Delete

/** @var array $errors */

[35] Fix | Delete

protected $errors;

[36] Fix | Delete

protected $context;

[37] Fix | Delete

[38] Fix | Delete

function __construct( $type ) {

[39] Fix | Delete

$this->type = $type;

[40] Fix | Delete

}

[41] Fix | Delete

[42] Fix | Delete

public function getType(){

[43] Fix | Delete

return $this->type;

[44] Fix | Delete

}

[45] Fix | Delete

[46] Fix | Delete

public function id(){

[47] Fix | Delete

return $this->id;

[48] Fix | Delete

}

[49] Fix | Delete

[50] Fix | Delete

public function getCount(){

[51] Fix | Delete

return $this->count;

[52] Fix | Delete

}

[53] Fix | Delete

[54] Fix | Delete

/**

[55] Fix | Delete

* @return int

[56] Fix | Delete

*/

[57] Fix | Delete

public function getImageWidth(){

[58] Fix | Delete

return $this->imageWidth;

[59] Fix | Delete

}

[60] Fix | Delete

[61] Fix | Delete

/**

[62] Fix | Delete

* @return int

[63] Fix | Delete

*/

[64] Fix | Delete

public function getAllowableWidth(){

[65] Fix | Delete

return 200;

[66] Fix | Delete

}

[67] Fix | Delete

[68] Fix | Delete

/**

[69] Fix | Delete

* @param $context

[70] Fix | Delete

* @param $feed

[71] Fix | Delete

*

[72] Fix | Delete

* @return void

[73] Fix | Delete

*/

[74] Fix | Delete

public function init($context, $feed){

[75] Fix | Delete

$this->context = $context;

[76] Fix | Delete

$this->errors = [];

[77] Fix | Delete

$this->imageWidth = defined('FF_MAX_IMAGE_WIDTH') ? FF_MAX_IMAGE_WIDTH : 300;

[78] Fix | Delete

[79] Fix | Delete

if (!is_null($feed)){

[80] Fix | Delete

$this->cache = $context['image_size_cache'];

[81] Fix | Delete

$this->feed = $feed;

[82] Fix | Delete

$this->id = $feed->id;

[83] Fix | Delete

if ($feed->last_update === 'N/A' && isset($context['count_posts_4init'])){

[84] Fix | Delete

$this->count = $context['count_posts_4init'];

[85] Fix | Delete

}

[86] Fix | Delete

else {

[87] Fix | Delete

$this->count = isset($feed->posts) ? intval($feed->posts) : 10;

[88] Fix | Delete

}

[89] Fix | Delete

if (isset($feed->{'include'}) && strlen($feed->{'include'}) > 0) {

[90] Fix | Delete

$this->include = explode(',', $feed->{'include'});

[91] Fix | Delete

if ($this->include === false) $this->include = array();

[92] Fix | Delete

} else {

[93] Fix | Delete

$this->include = array();

[94] Fix | Delete

}

[95] Fix | Delete

if (isset($feed->{'filter-by-words'}) && strlen($feed->{'filter-by-words'}) > 0) {

[96] Fix | Delete

$this->filterByWords = explode(',', $feed->{'filter-by-words'});

[97] Fix | Delete

if ($this->filterByWords === false) $this->filterByWords = array();

[98] Fix | Delete

} else {

[99] Fix | Delete

$this->filterByWords = array();

[100] Fix | Delete

}

[101] Fix | Delete

}

[102] Fix | Delete

}

[103] Fix | Delete

[104] Fix | Delete

public final function posts($is_empty_feed) {

[105] Fix | Delete

$result = [];

[106] Fix | Delete

try {

[107] Fix | Delete

if ($is_empty_feed) {

[108] Fix | Delete

$this->count = defined('FF_FEED_INIT_COUNT_POSTS') ? FF_FEED_INIT_COUNT_POSTS : 50;

[109] Fix | Delete

}

[110] Fix | Delete

if ($this->beforeProcess()) {

[111] Fix | Delete

$this->deferredInit($this->feed);

[112] Fix | Delete

if (sizeof($this->errors) == 0){

[113] Fix | Delete

do {

[114] Fix | Delete

$result += $this->onePagePosts();

[115] Fix | Delete

} while ($this->nextPage($result));

[116] Fix | Delete

return $this->afterProcess($result);

[117] Fix | Delete

}

[118] Fix | Delete

}

[119] Fix | Delete

} catch (LASocialException $se){

[120] Fix | Delete

$error = $se->getSocialError();

[121] Fix | Delete

$error['type'] = $this->getType();

[122] Fix | Delete

$this->errors[] = $error;

[123] Fix | Delete

error_log($se->getMessage());

[124] Fix | Delete

// error_log(print_r($se, true));

[125] Fix | Delete

} catch (Exception $e){

[126] Fix | Delete

$this->errors[] = [

[127] Fix | Delete

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

[128] Fix | Delete

'message' => $e->getMessage(),

[129] Fix | Delete

];

[130] Fix | Delete

error_log($e->getMessage());

[131] Fix | Delete

// error_log(print_r($e, true));

[132] Fix | Delete

}

[133] Fix | Delete

$this->criticalError = true;

[134] Fix | Delete

return $result;

[135] Fix | Delete

}

[136] Fix | Delete

[137] Fix | Delete

/**

[138] Fix | Delete

* @param stdClass $feed

[139] Fix | Delete

* @return void

[140] Fix | Delete

*/

[141] Fix | Delete

protected abstract function deferredInit($feed);

[142] Fix | Delete

protected abstract function onePagePosts( );

[143] Fix | Delete

[144] Fix | Delete

/**

[145] Fix | Delete

* @return array

[146] Fix | Delete

*/

[147] Fix | Delete

public function errors() {

[148] Fix | Delete

return $this->errors;

[149] Fix | Delete

}

[150] Fix | Delete

[151] Fix | Delete

/**

[152] Fix | Delete

* @param $url

[153] Fix | Delete

* @param $width

[154] Fix | Delete

* @param $height

[155] Fix | Delete

* @param bool $scale

[156] Fix | Delete

*

[157] Fix | Delete

* @return array

[158] Fix | Delete

*/

[159] Fix | Delete

protected function createImage($url, $width = null, $height = null, $scale = true){

[160] Fix | Delete

if ($width != -1 && $height != -1) {

[161] Fix | Delete

if ($width == null || $height == null){

[162] Fix | Delete

$size = $this->cache->size($url);

[163] Fix | Delete

$width = $size['width'];

[164] Fix | Delete

$height = $size['height'];

[165] Fix | Delete

}

[166] Fix | Delete

if ($scale){

[167] Fix | Delete

$tWidth = $this->getImageWidth();

[168] Fix | Delete

return array('url' => $url, 'width' => $tWidth, 'height' => FFFeedUtils::getScaleHeight($tWidth, $width, $height));

[169] Fix | Delete

}

[170] Fix | Delete

}

[171] Fix | Delete

return array('url' => $url, 'width' => $width, 'height' => $height);

[172] Fix | Delete

}

[173] Fix | Delete

[174] Fix | Delete

protected function createMedia($url, $width = null, $height = null, $type = 'image', $scale = false){

[175] Fix | Delete

if ($type == 'html'){

[176] Fix | Delete

return array('type' => $type, 'html' => $url);

[177] Fix | Delete

}

[178] Fix | Delete

if ($width == null || $height == null){

[179] Fix | Delete

$size = $this->cache->size($url);

[180] Fix | Delete

$width = $size['width'];

[181] Fix | Delete

$height = $size['height'];

[182] Fix | Delete

}

[183] Fix | Delete

if ($type == 'image' && $scale == true && $width > 600){

[184] Fix | Delete

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

[185] Fix | Delete

$width = 600;

[186] Fix | Delete

}

[187] Fix | Delete

return array('type' => $type, 'url' => $url, 'width' => $width, 'height' => $height);

[188] Fix | Delete

}

[189] Fix | Delete

[190] Fix | Delete

/**

[191] Fix | Delete

* @param string $link

[192] Fix | Delete

* @param string $name

[193] Fix | Delete

* @param mixed $image

[194] Fix | Delete

* @param mixed $width

[195] Fix | Delete

* @param mixed $height

[196] Fix | Delete

* @return array

[197] Fix | Delete

*/

[198] Fix | Delete

protected function createAttachment($link, $name, $image = null, $width = null, $height = null){

[199] Fix | Delete

if ($image != null){

[200] Fix | Delete

if (is_string($image)) $image = $this->createImage($image, $width, $height);

[201] Fix | Delete

if ($image['width'] > $this->getAllowableWidth())

[202] Fix | Delete

return array( 'type' => 'article', 'url' => $link, 'displayName' => $name, 'image' => $image);

[203] Fix | Delete

}

[204] Fix | Delete

return array( 'type' => 'article', 'url' => $link, 'displayName' => $name);

[205] Fix | Delete

}

[206] Fix | Delete

[207] Fix | Delete

protected function includePost($post)

[208] Fix | Delete

{

[209] Fix | Delete

if(count($this->include) == 0) return true;

[210] Fix | Delete

[211] Fix | Delete

foreach ( $this->include as $word ) {

[212] Fix | Delete

$word = mb_strtolower($word);

[213] Fix | Delete

$firstLetter = mb_substr($word, 0, 1);

[214] Fix | Delete

[215] Fix | Delete

if ($firstLetter !== false){

[216] Fix | Delete

switch ($firstLetter) {

[217] Fix | Delete

case '@':

[218] Fix | Delete

$word = mb_substr($word, 1);

[219] Fix | Delete

if ((mb_strpos(mb_strtolower($post->screenname), $word) !== false) || (mb_strpos(mb_strtolower($post->nickname), $word) !== false)) {

[220] Fix | Delete

return true;

[221] Fix | Delete

}

[222] Fix | Delete

break;

[223] Fix | Delete

case '#':

[224] Fix | Delete

$word = mb_substr($word, 1);

[225] Fix | Delete

if (mb_strpos(mb_strtolower($post->permalink), $word) !== false) {

[226] Fix | Delete

return true;

[227] Fix | Delete

}

[228] Fix | Delete

break;

[229] Fix | Delete

case '$':

[230] Fix | Delete

$word = mb_substr($word, 1);

[231] Fix | Delete

if ( !empty($word) && ((mb_strpos( mb_strtolower( strip_tags( $post->text ) ), '#' . $word) !== false) || (isset($post->header) && mb_strpos( mb_strtolower( strip_tags( $post->header ) ), '#' . $word) !== false))) {

[232] Fix | Delete

return true;

[233] Fix | Delete

}

[234] Fix | Delete

break;

[235] Fix | Delete

default:

[236] Fix | Delete

if ( !empty($word) && ((mb_strpos( mb_strtolower( strip_tags( $post->text ) ), $word) !== false) || (isset($post->header) && mb_strpos( mb_strtolower( strip_tags( $post->header ) ), $word) !== false))) {

[237] Fix | Delete

return true;

[238] Fix | Delete

}

[239] Fix | Delete

break;

[240] Fix | Delete

}

[241] Fix | Delete

}

[242] Fix | Delete

}

[243] Fix | Delete

[244] Fix | Delete

return false;

[245] Fix | Delete

}

[246] Fix | Delete

[247] Fix | Delete

protected function excludePost($post)

[248] Fix | Delete

{

[249] Fix | Delete

if(count($this->filterByWords) == 0) return true;

[250] Fix | Delete

[251] Fix | Delete

foreach ( $this->filterByWords as $word ) {

[252] Fix | Delete

$word = mb_strtolower($word);

[253] Fix | Delete

$firstLetter = mb_substr($word, 0, 1);

[254] Fix | Delete

if ($firstLetter !== false){

[255] Fix | Delete

switch ($firstLetter) {

[256] Fix | Delete

case '@':

[257] Fix | Delete

$word = mb_substr($word, 1);

[258] Fix | Delete

if ((mb_strpos(mb_strtolower($post->screenname), $word) !== false) || (mb_strpos(mb_strtolower($post->nickname), $word) !== false)) {

[259] Fix | Delete

return false;

[260] Fix | Delete

}

[261] Fix | Delete

break;

[262] Fix | Delete

case '#':

[263] Fix | Delete

$word = mb_substr($word, 1);

[264] Fix | Delete

if (mb_strpos(mb_strtolower($post->permalink), $word) !== false) {

[265] Fix | Delete

return false;

[266] Fix | Delete

}

[267] Fix | Delete

break;

[268] Fix | Delete

default:

[269] Fix | Delete

if (!empty($word) && ((mb_strpos(mb_strtolower($post->text), $word) !== false) || (isset($post->header) && mb_strpos(mb_strtolower($post->header), $word) !== false))) {

[270] Fix | Delete

return false;

[271] Fix | Delete

}

[272] Fix | Delete

}

[273] Fix | Delete

}

[274] Fix | Delete

}

[275] Fix | Delete

[276] Fix | Delete

return true;

[277] Fix | Delete

}

[278] Fix | Delete

[279] Fix | Delete

/**

[280] Fix | Delete

* @param stdClass $post

[281] Fix | Delete

* @return bool

[282] Fix | Delete

*/

[283] Fix | Delete

protected function isSuitablePost($post){

[284] Fix | Delete

if ($post == null) return false;

[285] Fix | Delete

[286] Fix | Delete

$suitable = $this->includePost($post);

[287] Fix | Delete

if( $suitable ){

[288] Fix | Delete

$suitable = $this->excludePost($post);

[289] Fix | Delete

}

[290] Fix | Delete

[291] Fix | Delete

return $suitable;

[292] Fix | Delete

}

[293] Fix | Delete

[294] Fix | Delete

/**

[295] Fix | Delete

* @return bool

[296] Fix | Delete

*/

[297] Fix | Delete

protected function beforeProcess(){

[298] Fix | Delete

return (sizeof($this->errors) == 0);

[299] Fix | Delete

}

[300] Fix | Delete

[301] Fix | Delete

/**

[302] Fix | Delete

* @param $result array

[303] Fix | Delete

* @return array

[304] Fix | Delete

*/

[305] Fix | Delete

protected function afterProcess($result){

[306] Fix | Delete

$this->cache->save();

[307] Fix | Delete

$this->criticalError = empty($result) && sizeof($this->errors) > 0;

[308] Fix | Delete

return $result;

[309] Fix | Delete

}

[310] Fix | Delete

[311] Fix | Delete

public function hasCriticalError() {

[312] Fix | Delete

return $this->criticalError;

[313] Fix | Delete

}

[314] Fix | Delete

[315] Fix | Delete

/**

[316] Fix | Delete

* @param array $result

[317] Fix | Delete

* @return bool

[318] Fix | Delete

*/

[319] Fix | Delete

protected function nextPage($result){

[320] Fix | Delete

return false;

[321] Fix | Delete

}

[322] Fix | Delete

[323] Fix | Delete

/**

[324] Fix | Delete

* @param $url

[325] Fix | Delete

* @param int $timeout

[326] Fix | Delete

* @param bool $header

[327] Fix | Delete

* @param bool $log

[328] Fix | Delete

*

[329] Fix | Delete

* @return array

[330] Fix | Delete

* @throws LASocialRequestException

[331] Fix | Delete

* @throws Exception

[332] Fix | Delete

*

[333] Fix | Delete

* @deprecated

[334] Fix | Delete

*/

[335] Fix | Delete

protected function getFeedData($url, $timeout = 60, $header = false, $log = true){

[336] Fix | Delete

return FFFeedUtils::getFeedDataWithThrowException($url, $timeout, $header, $log, $this->feed->use_curl_follow_location, $this->feed->use_ipv4);

[337] Fix | Delete

}

[338] Fix | Delete

[339] Fix | Delete

/**

[340] Fix | Delete

* TODO Remove this method. Need to use LASocialException

[341] Fix | Delete

*

[342] Fix | Delete

* @deprecated

[343] Fix | Delete

* @param $message

[344] Fix | Delete

* @return string

[345] Fix | Delete

*/

[346] Fix | Delete

protected function filterErrorMessage($message){

[347] Fix | Delete

if (is_array($message)){

[348] Fix | Delete

if (sizeof($message) > 0 && isset($message[0]['msg'])){

[349] Fix | Delete

return stripslashes(htmlspecialchars($message[0]['msg'], ENT_QUOTES | ENT_SUBSTITUTE, 'UTF-8'));

[350] Fix | Delete

}

[351] Fix | Delete

else {

[352] Fix | Delete

return '';

[353] Fix | Delete

}

[354] Fix | Delete

}

[355] Fix | Delete

return stripslashes(htmlspecialchars($message, ENT_QUOTES | ENT_SUBSTITUTE, 'UTF-8'));

[356] Fix | Delete

}

[357] Fix | Delete

[358] Fix | Delete

protected function print2log($msg){

[359] Fix | Delete

error_log($msg);

[360] Fix | Delete

}

[361] Fix | Delete

}

[362] Fix | Delete