<?php namespace la\core;

[0] Fix | Delete

[1] Fix | Delete

use Exception;

[2] Fix | Delete

use flow\social\cache\LAFacebookCacheManager;

[3] Fix | Delete

use flow\social\FFFeed;

[4] Fix | Delete

use flow\social\FFRemoteFeed;

[5] Fix | Delete

use flow\social\LAFeedWithComments;

[6] Fix | Delete

use la\core\cache\LACacheAdapter;

[7] Fix | Delete

use la\core\cache\LAImageSizeCacheManager;

[8] Fix | Delete

use la\core\db\LADB;

[9] Fix | Delete

use la\core\settings\LAGeneralSettings;

[10] Fix | Delete

use la\core\settings\LASettingsUtils;

[11] Fix | Delete

use la\core\settings\LAStreamSettings;

[12] Fix | Delete

use ReflectionClass;

[13] Fix | Delete

use ReflectionException;

[14] Fix | Delete

[15] Fix | Delete

if ( ! defined('FF_BY_DATE_ORDER')) define('FF_BY_DATE_ORDER', 'compareByTime');

[16] Fix | Delete

if ( ! defined('FF_RANDOM_ORDER')) define('FF_RANDOM_ORDER', 'randomCompare');

[17] Fix | Delete

if ( ! defined('FF_SMART_ORDER')) define('FF_SMART_ORDER', 'smartCompare');

[18] Fix | Delete

[19] Fix | Delete

abstract class LABase {

[20] Fix | Delete

protected static $instance = [];

[21] Fix | Delete

[22] Fix | Delete

/**

[23] Fix | Delete

* @param $context

[24] Fix | Delete

*

[25] Fix | Delete

* @return LABase|null

[26] Fix | Delete

*/

[27] Fix | Delete

public static function get_instance($context = null) {

[28] Fix | Delete

$slug = is_null($context) ? 'flow-flow' : LAUtils::slug($context);

[29] Fix | Delete

if (!array_key_exists($slug, self::$instance)) {

[30] Fix | Delete

$slug_down = is_null($context) ? 'flow_flow' : LAUtils::slug_down($context);

[31] Fix | Delete

$class = get_called_class();

[32] Fix | Delete

self::$instance[$slug] = new $class($context, $slug, $slug_down);

[33] Fix | Delete

}

[34] Fix | Delete

return self::$instance[$slug];

[35] Fix | Delete

}

[36] Fix | Delete

[37] Fix | Delete

public static function get_instance_by_slug($slug) {

[38] Fix | Delete

return (array_key_exists($slug, self::$instance)) ? self::$instance[$slug] : null;

[39] Fix | Delete

}

[40] Fix | Delete

[41] Fix | Delete

// public static function registry($slug, $instance){

[42] Fix | Delete

// if (!array_key_exists($slug, self::$instance)) {

[43] Fix | Delete

// self::$instance[$slug] = $instance;

[44] Fix | Delete

// }

[45] Fix | Delete

// }

[46] Fix | Delete

[47] Fix | Delete

/**

[48] Fix | Delete

* @deprecated

[49] Fix | Delete

* @var LAGeneralSettings

[50] Fix | Delete

*/

[51] Fix | Delete

protected $generalSettings;

[52] Fix | Delete

[53] Fix | Delete

/** @var array */

[54] Fix | Delete

protected $context;

[55] Fix | Delete

protected $slug;

[56] Fix | Delete

protected $slug_down;

[57] Fix | Delete

[58] Fix | Delete

/**

[59] Fix | Delete

* Initialize the plugin by setting localization and loading public scripts

[60] Fix | Delete

* and styles.

[61] Fix | Delete

*

[62] Fix | Delete

* @since 1.0.0

[63] Fix | Delete

*

[64] Fix | Delete

* @param array $context

[65] Fix | Delete

* @param $slug

[66] Fix | Delete

* @param $slug_down

[67] Fix | Delete

*/

[68] Fix | Delete

protected function __construct($context, $slug, $slug_down) {

[69] Fix | Delete

$this->context = $context;

[70] Fix | Delete

$this->slug = $slug;

[71] Fix | Delete

$this->slug_down = $slug_down;

[72] Fix | Delete

[73] Fix | Delete

/**

[74] Fix | Delete

* Default filter for result before send response.

[75] Fix | Delete

* Use wp filter engine because need to customize result from addons.

[76] Fix | Delete

*/

[77] Fix | Delete

add_filter('ff_build_public_response', [ $this, 'buildResponse' ], 1, 8);

[78] Fix | Delete

}

[79] Fix | Delete

[80] Fix | Delete

public final function register_shortcodes()

[81] Fix | Delete

{

[82] Fix | Delete

add_shortcode($this->getShortcodePrefix(), [ $this, 'renderShortCode' ] );

[83] Fix | Delete

}

[84] Fix | Delete

[85] Fix | Delete

/**

[86] Fix | Delete

* Load the plugin text domain for translation.

[87] Fix | Delete

*

[88] Fix | Delete

* @since 1.0.0

[89] Fix | Delete

*/

[90] Fix | Delete

public final function load_plugin_textdomain() {

[91] Fix | Delete

$domain = $this->slug;

[92] Fix | Delete

$locale = apply_filters( 'plugin_locale', get_locale(), $domain );

[93] Fix | Delete

$path = LAUtils::root($this->context) . 'languages/';

[94] Fix | Delete

load_textdomain( $domain, $path . $domain . '-' . $locale . '.mo' );

[95] Fix | Delete

load_plugin_textdomain( $domain, false, $path );

[96] Fix | Delete

}

[97] Fix | Delete

[98] Fix | Delete

/**

[99] Fix | Delete

* Fired when a new site is activated with a WPMU environment.

[100] Fix | Delete

*

[101] Fix | Delete

* @since 1.0.0

[102] Fix | Delete

*

[103] Fix | Delete

* @param int $blog_id ID of the new blog.

[104] Fix | Delete

*

[105] Fix | Delete

* @noinspection PhpUnused

[106] Fix | Delete

*/

[107] Fix | Delete

public final function activate_new_site( $blog_id ) {

[108] Fix | Delete

if ( 1 !== did_action( 'wpmu_new_blog' ) ) return;

[109] Fix | Delete

switch_to_blog( $blog_id );

[110] Fix | Delete

restore_current_blog();

[111] Fix | Delete

}

[112] Fix | Delete

[113] Fix | Delete

/**

[114] Fix | Delete

* Register and enqueue public-facing style sheet.

[115] Fix | Delete

*

[116] Fix | Delete

* @since 1.0.0

[117] Fix | Delete

*/

[118] Fix | Delete

public final function enqueue_styles() {

[119] Fix | Delete

$this->enqueueStyles();

[120] Fix | Delete

}

[121] Fix | Delete

[122] Fix | Delete

/**

[123] Fix | Delete

* Register and enqueues public-facing JavaScript files.

[124] Fix | Delete

*

[125] Fix | Delete

* @since 1.0.0

[126] Fix | Delete

*/

[127] Fix | Delete

public final function enqueue_scripts() {

[128] Fix | Delete

// Customization 16.08.18, JS opts added in public.php instead

[129] Fix | Delete

// $this->enqueueScripts();

[130] Fix | Delete

// make sure jQuery is always on page

[131] Fix | Delete

wp_enqueue_script('jquery');

[132] Fix | Delete

}

[133] Fix | Delete

[134] Fix | Delete

/**

[135] Fix | Delete

* @throws Exception

[136] Fix | Delete

*/

[137] Fix | Delete

public final function processAjaxRequest() {

[138] Fix | Delete

if (isset($_REQUEST['stream-id']) && $this->prepareProcess()) {

[139] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[140] Fix | Delete

$boosted = (bool)(isset($_REQUEST['boosted']) && (int)$_REQUEST['boosted']);

[141] Fix | Delete

$dbm->dataInit(true, false, $boosted);

[142] Fix | Delete

$stream = $dbm->getStream($_REQUEST['stream-id']);

[143] Fix | Delete

if (isset($stream)) {

[144] Fix | Delete

$disableCache = isset($_REQUEST['disable-cache']) ? (bool)$_REQUEST['disable-cache'] : false;

[145] Fix | Delete

header('Content-Type: application/json');

[146] Fix | Delete

echo $this->process( [ $stream ], $disableCache);

[147] Fix | Delete

}

[148] Fix | Delete

}

[149] Fix | Delete

die();

[150] Fix | Delete

}

[151] Fix | Delete

[152] Fix | Delete

/**

[153] Fix | Delete

* @throws Exception

[154] Fix | Delete

*/

[155] Fix | Delete

public final function moderation_apply( ){

[156] Fix | Delete

if (isset($_REQUEST['stream']) && $this->prepareProcess()) {

[157] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[158] Fix | Delete

$dbm->dataInit();

[159] Fix | Delete

$stream = $dbm->getStream($_REQUEST['stream']);

[160] Fix | Delete

if (isset($stream)) {

[161] Fix | Delete

$cache = new LACacheAdapter($this->context, false);

[162] Fix | Delete

$cache->setStream(new LAStreamSettings($stream), true);

[163] Fix | Delete

$cache->moderate();

[164] Fix | Delete

}

[165] Fix | Delete

}

[166] Fix | Delete

}

[167] Fix | Delete

[168] Fix | Delete

/**

[169] Fix | Delete

* @param bool $only_enable

[170] Fix | Delete

* @param bool $remote

[171] Fix | Delete

* @throws Exception

[172] Fix | Delete

*/

[173] Fix | Delete

public final function processAjaxRequestBackground($only_enable = true, $remote = true) {

[174] Fix | Delete

if ($this->prepareProcess()) {

[175] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[176] Fix | Delete

$dbm->dataInit($only_enable, false, $remote);

[177] Fix | Delete

[178] Fix | Delete

if (isset($_REQUEST['feed_id'])){

[179] Fix | Delete

$sources = $dbm->sources();

[180] Fix | Delete

if (isset($sources[$_REQUEST['feed_id']])){

[181] Fix | Delete

$this->process4feeds( [ $sources[$_REQUEST['feed_id']] ], false, true);

[182] Fix | Delete

}

[183] Fix | Delete

}

[184] Fix | Delete

if (isset($_REQUEST['stream_id'])){

[185] Fix | Delete

$stream = $dbm->getStream($_REQUEST['stream_id']);

[186] Fix | Delete

if (isset($stream)) {

[187] Fix | Delete

$this->process4feeds( [ $stream ], false, true);

[188] Fix | Delete

}

[189] Fix | Delete

}

[190] Fix | Delete

}

[191] Fix | Delete

}

[192] Fix | Delete

[193] Fix | Delete

[194] Fix | Delete

/**

[195] Fix | Delete

* @return array|false|string

[196] Fix | Delete

* @throws Exception

[197] Fix | Delete

*/

[198] Fix | Delete

public final function processRequest(){

[199] Fix | Delete

if (isset($_REQUEST['stream-id']) && $this->prepareProcess()) {

[200] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[201] Fix | Delete

$dbm->dataInit(true);

[202] Fix | Delete

$stream = $dbm->getStream($_REQUEST['stream-id']);

[203] Fix | Delete

if (isset($stream)) {

[204] Fix | Delete

return $this->process( [ $stream ], isset($_REQUEST['disable-cache']));

[205] Fix | Delete

}

[206] Fix | Delete

}

[207] Fix | Delete

return '';

[208] Fix | Delete

}

[209] Fix | Delete

[210] Fix | Delete

public final function refreshCache($streamId = null, $force = false, $withDisabled = false) {

[211] Fix | Delete

if ($this->prepareProcess()) {

[212] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[213] Fix | Delete

$conn = $dbm->conn();

[214] Fix | Delete

$enabled = $withDisabled ? $conn->parse('`cach`.system_enabled = 0 AND `cach`.boosted != "yep"') : $conn->parse('`cach`.enabled = 1 AND `cach`.system_enabled = 1 AND `cach`.boosted != "yep"');

[215] Fix | Delete

if (empty($streamId)){

[216] Fix | Delete

$sql = $conn->parse('SELECT `cach`.`feed_id` FROM ?n `cach` WHERE ?p AND (`cach`.last_update + `cach`.cache_lifetime * 60) < UNIX_TIMESTAMP() ORDER BY `cach`.last_update', $dbm->cache_table_name, $enabled);

[217] Fix | Delete

}

[218] Fix | Delete

else{

[219] Fix | Delete

$sql = $conn->parse('SELECT `cach`.`feed_id` FROM ?n `cach` INNER JOIN ?n `ss` ON `ss`.feed_id = `cach`.feed_id WHERE ?p AND `ss`.stream_id = ?s AND (`cach`.last_update + `cach`.cache_lifetime * 60) < UNIX_TIMESTAMP() ORDER BY `cach`.last_update',

[220] Fix | Delete

$dbm->cache_table_name, $dbm->streams_sources_table_name, $enabled, $streamId);

[221] Fix | Delete

}

[222] Fix | Delete

try {

[223] Fix | Delete

if (false !== ($feeds = $conn->getCol($sql))){

[224] Fix | Delete

$useIpv4 = $dbm->getGeneralSettings()->useIPv4();

[225] Fix | Delete

$use = $dbm->getGeneralSettings()->useCurlFollowLocation();

[226] Fix | Delete

if (sizeof($feeds) < 4){

[227] Fix | Delete

for ( $i = 0; $i < sizeof($feeds); $i ++ ) {

[228] Fix | Delete

$feed_id = $feeds[$i];

[229] Fix | Delete

$_REQUEST['feed_id'] = $feed_id;

[230] Fix | Delete

$this->processAjaxRequestBackground(!$withDisabled, false);

[231] Fix | Delete

}

[232] Fix | Delete

}

[233] Fix | Delete

else {

[234] Fix | Delete

for ( $i = 0; $i < 8; $i ++ ) {

[235] Fix | Delete

if (isset($feeds[$i])){

[236] Fix | Delete

$feed_id = $feeds[$i];

[237] Fix | Delete

if (FF_USE_DIRECT_WP_CRON){

[238] Fix | Delete

$_REQUEST['feed_id'] = $feed_id;

[239] Fix | Delete

$this->processAjaxRequestBackground(!$withDisabled, false);

[240] Fix | Delete

}

[241] Fix | Delete

else {

[242] Fix | Delete

//$_COOKIE['XDEBUG_SESSION'] = 'PHPSTORM';

[243] Fix | Delete

$url = $dbm->getLoadCacheUrl( $feed_id, $force );

[244] Fix | Delete

LASettingsUtils::get( $url, 1, false, false, $use, $useIpv4);

[245] Fix | Delete

}

[246] Fix | Delete

}

[247] Fix | Delete

}

[248] Fix | Delete

}

[249] Fix | Delete

}

[250] Fix | Delete

}

[251] Fix | Delete

catch( Exception $e){

[252] Fix | Delete

error_log($e->getMessage());

[253] Fix | Delete

error_log($e->getTraceAsString());

[254] Fix | Delete

}

[255] Fix | Delete

}

[256] Fix | Delete

}

[257] Fix | Delete

[258] Fix | Delete

public final function refreshCache4Disabled() {

[259] Fix | Delete

$this->refreshCache(null, false, true);

[260] Fix | Delete

}

[261] Fix | Delete

[262] Fix | Delete

public final function emailNotification () {

[263] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[264] Fix | Delete

$settings = $dbm->getGeneralSettings();

[265] Fix | Delete

if ($settings->enabledEmailNotification()){

[266] Fix | Delete

$dbm->email_notification();

[267] Fix | Delete

}

[268] Fix | Delete

}

[269] Fix | Delete

[270] Fix | Delete

public final function checkFacebookToken() {

[271] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[272] Fix | Delete

if ($dbm->getOption('boosts_email') != false){

[273] Fix | Delete

/** @var LAFacebookCacheManager $facebookCache */

[274] Fix | Delete

$facebookCache = $this->context['facebook_cache'];

[275] Fix | Delete

$facebookCache->getAccessToken();

[276] Fix | Delete

}

[277] Fix | Delete

}

[278] Fix | Delete

[279] Fix | Delete

/**

[280] Fix | Delete

* @param $attr

[281] Fix | Delete

*

[282] Fix | Delete

* @return false|string|string[]

[283] Fix | Delete

* @throws Exception

[284] Fix | Delete

*/

[285] Fix | Delete

public function renderShortCode ($attr) {

[286] Fix | Delete

if (isset($attr['id'])){

[287] Fix | Delete

if ($this->prepareProcess()) {

[288] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[289] Fix | Delete

$dbm->dataInit(false, false, false);

[290] Fix | Delete

$stream = (object)$dbm->getStream($attr['id']);

[291] Fix | Delete

if (isset($stream)) {

[292] Fix | Delete

$stream->preview = (isset($attr['preview']) && $attr['preview']);

[293] Fix | Delete

$stream->gallery = $stream->preview ? LASettingsUtils::NOPE : ( isset($stream->gallery) ? $stream->gallery : LASettingsUtils::NOPE );

[294] Fix | Delete

$output = $this->renderStream($stream, $this->getPublicContext($stream, $this->context));

[295] Fix | Delete

[296] Fix | Delete

/* workaround for extra P tags issue and possibly &&, set to true */

[297] Fix | Delete

if (LASettingsUtils::notYepNope2ClassicStyleSafe(LAGeneralSettings::get()->original(), 'general-render-alt')){

[298] Fix | Delete

/* added 8.06.20 */

[299] Fix | Delete

remove_filter('the_content', 'wptexturize');

[300] Fix | Delete

remove_filter('the_content', 'wpautop');

[301] Fix | Delete

/* */

[302] Fix | Delete

return $output;

[303] Fix | Delete

}

[304] Fix | Delete

else {

[305] Fix | Delete

echo $output;

[306] Fix | Delete

}

[307] Fix | Delete

}

[308] Fix | Delete

} else {

[309] Fix | Delete

echo '<p>Flow-Flow message: Stream with specified ID not found or no feeds were added to stream</p>';

[310] Fix | Delete

}

[311] Fix | Delete

}

[312] Fix | Delete

return '';

[313] Fix | Delete

}

[314] Fix | Delete

[315] Fix | Delete

/**

[316] Fix | Delete

* @param $result

[317] Fix | Delete

* @param $all

[318] Fix | Delete

* @param $context

[319] Fix | Delete

* @param $errors

[320] Fix | Delete

* @param $oldHash

[321] Fix | Delete

* @param $page

[322] Fix | Delete

* @param $status

[323] Fix | Delete

* @param LAStreamSettings $stream

[324] Fix | Delete

*

[325] Fix | Delete

* @return array

[326] Fix | Delete

* @noinspection PhpUnusedParameterInspection

[327] Fix | Delete

*/

[328] Fix | Delete

public function buildResponse ($result, $all, $context, $errors, $oldHash, $page, $status, $stream) {

[329] Fix | Delete

$streamId = (int) $stream->getId();

[330] Fix | Delete

$countOfPages = isset($_REQUEST['countOfPages']) ? $_REQUEST['countOfPages'] : 0;

[331] Fix | Delete

$result = [

[332] Fix | Delete

'id' => $streamId, 'items' => $all, 'errors' => $errors,

[333] Fix | Delete

'hash' => $oldHash, 'page' => $page, 'countOfPages' => $countOfPages, 'status' => $status

[334] Fix | Delete

];

[335] Fix | Delete

return $result;

[336] Fix | Delete

}

[337] Fix | Delete

[338] Fix | Delete

/**

[339] Fix | Delete

* @throws ReflectionException

[340] Fix | Delete

* @throws Exception

[341] Fix | Delete

*/

[342] Fix | Delete

public function loadCommentsAndCarousel(){

[343] Fix | Delete

$result = [];

[344] Fix | Delete

[345] Fix | Delete

$post_id = $_REQUEST['post_id'];

[346] Fix | Delete

$feed_id = $_REQUEST['feed_id4post'];

[347] Fix | Delete

[348] Fix | Delete

if ($this->prepareProcess()) {

[349] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[350] Fix | Delete

$dbm->dataInit(true);

[351] Fix | Delete

[352] Fix | Delete

$result['comments'] = $this->process4comments($post_id, $feed_id);

[353] Fix | Delete

$result['carousel'] = $dbm->getCarousel($feed_id, $post_id);

[354] Fix | Delete

[355] Fix | Delete

wp_send_json($result);

[356] Fix | Delete

}

[357] Fix | Delete

}

[358] Fix | Delete

[359] Fix | Delete

protected function enqueueStyles() {}

[360] Fix | Delete

protected function enqueueScripts() {}

[361] Fix | Delete

protected abstract function getShortcodePrefix();

[362] Fix | Delete

protected abstract function getNameJSOptions();

[363] Fix | Delete

[364] Fix | Delete

protected function getPublicContext($stream, $context){

[365] Fix | Delete

$context['moderation'] = false;

[366] Fix | Delete

if (isset($stream->feeds) && !empty($stream->feeds)){

[367] Fix | Delete

foreach ( $stream->feeds as $source ) {

[368] Fix | Delete

if (LASettingsUtils::YepNope2ClassicStyleSafe($source, 'mod', false)){

[369] Fix | Delete

$context['moderation'] = true;

[370] Fix | Delete

}

[371] Fix | Delete

}

[372] Fix | Delete

}

[373] Fix | Delete

[374] Fix | Delete

$cache = new LACacheAdapter($context);

[375] Fix | Delete

$cache->setStream(new LAStreamSettings($stream), $context['moderation']);

[376] Fix | Delete

$context['stream'] = $stream;

[377] Fix | Delete

$context['hashOfStream'] = $cache->transientHash($stream->id);

[378] Fix | Delete

$context['seo'] = false;////$this->generalSettings->isSEOMode();

[379] Fix | Delete

$context['can_moderate'] = FF_USE_WP ? $this->generalSettings->canModerate() : ff_user_can_moderate();

[380] Fix | Delete

return $context;

[381] Fix | Delete

}

[382] Fix | Delete

[383] Fix | Delete

protected function prepareProcess() {

[384] Fix | Delete

if (isset($_REQUEST['stream-id'])) $_REQUEST['stream-id'] = @filter_var( trim( $_REQUEST['stream-id'] ), FILTER_SANITIZE_NUMBER_INT);

[385] Fix | Delete

if (isset($_REQUEST['feed_id'])) $_REQUEST['feed_id'] = @filter_var( trim( $_REQUEST['feed_id'] ), FILTER_SANITIZE_STRING );

[386] Fix | Delete

if (isset($_REQUEST['action'])) $_REQUEST['action'] = @filter_var( trim( $_REQUEST['action'] ), FILTER_SANITIZE_STRING );

[387] Fix | Delete

if (isset($_REQUEST['page'])) $_REQUEST['page'] = filter_var( trim( $_REQUEST['page'] ), FILTER_SANITIZE_NUMBER_INT);

[388] Fix | Delete

if (isset($_REQUEST['countOfPages'])) $_REQUEST['countOfPages'] = filter_var( trim( $_REQUEST['countOfPages'] ), FILTER_SANITIZE_NUMBER_INT);

[389] Fix | Delete

if (isset($_REQUEST['hash']) && !empty($_REQUEST['hash'])){

[390] Fix | Delete

$hash = filter_var( $_REQUEST['hash'], FILTER_VALIDATE_REGEXP, [ "options" => [ 'regexp' => '/^\d{10}[.]\w{96}$/' ] ] );

[391] Fix | Delete

if (false === $hash){

[392] Fix | Delete

status_header(400);

[393] Fix | Delete

exit;

[394] Fix | Delete

}

[395] Fix | Delete

}

[396] Fix | Delete

if (isset($_REQUEST['disable-cache']) && !empty($_REQUEST['disable-cache'])){

[397] Fix | Delete

$_REQUEST['disable-cache'] = filter_var( trim( $_REQUEST['disable-cache'] ), FILTER_SANITIZE_NUMBER_INT);

[398] Fix | Delete

}

[399] Fix | Delete

if (isset($_REQUEST['preview']) && !empty($_REQUEST['preview'])){

[400] Fix | Delete

$_REQUEST['preview'] = filter_var( trim( $_REQUEST['preview'] ), FILTER_SANITIZE_NUMBER_INT);

[401] Fix | Delete

}

[402] Fix | Delete

[403] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[404] Fix | Delete

if ($dbm->countFeeds() > 0) {

[405] Fix | Delete

$this->generalSettings = $dbm->getGeneralSettings();

[406] Fix | Delete

return true;

[407] Fix | Delete

}

[408] Fix | Delete

return false;

[409] Fix | Delete

}

[410] Fix | Delete

[411] Fix | Delete

protected function renderStream($stream, $context){

[412] Fix | Delete

$settings = new LAStreamSettings($stream);

[413] Fix | Delete

if ($settings->isPossibleToShow()){

[414] Fix | Delete

if ( ! in_array( 'curl', get_loaded_extensions() ) ) {

[415] Fix | Delete

echo "<p style='background: indianred;padding: 15px;color: white;'>Flow-Flow admin info: Your server doesn't have cURL module installed. Please ask your hosting to check this.</p>";

[416] Fix | Delete

return '';

[417] Fix | Delete

}

[418] Fix | Delete

[419] Fix | Delete

if (!isset($stream->layout) || empty($stream->layout)) {

[420] Fix | Delete

echo "<p style='background: indianred;padding: 15px;color: white;'>Flow-Flow admin info: Please choose stream layout on options page.</p>";

[421] Fix | Delete

return '';

[422] Fix | Delete

}

[423] Fix | Delete

[424] Fix | Delete

ob_start();

[425] Fix | Delete

$css_version = isset($stream->last_changes) ? $stream->last_changes : '1.0';

[426] Fix | Delete

$url = content_url() . '/resources/' . LAUtils::slug($context) . '/css/stream-id' . $stream->id . '.css';

[427] Fix | Delete

if (!is_main_site()){

[428] Fix | Delete

$url = content_url() . '/resources/' . LAUtils::slug($context) . '/css/stream-id' . $stream->id . '-'. get_current_blog_id() . '.css';

[429] Fix | Delete

}

[430] Fix | Delete

echo "<link rel='stylesheet' id='ff-dynamic-css" . $stream->id . "' type='text/css' href='{$url}?ver={$css_version}'/>";

[431] Fix | Delete

[432] Fix | Delete

/** @noinspection PhpIncludeInspection */

[433] Fix | Delete

include(LAUtils::root($context) . 'views/public.php');

[434] Fix | Delete

$output = ob_get_clean();

[435] Fix | Delete

$output = str_replace("\r\n", '', $output);

[436] Fix | Delete

[437] Fix | Delete

return $output;

[438] Fix | Delete

}

[439] Fix | Delete

else

[440] Fix | Delete

return '';

[441] Fix | Delete

}

[442] Fix | Delete

[443] Fix | Delete

protected function process($streams, $disableCache = false, $background = false) {

[444] Fix | Delete

foreach ($streams as $stream) {

[445] Fix | Delete

try {

[446] Fix | Delete

$moderation = false;

[447] Fix | Delete

foreach ( LAUtils::dbm($this->context)->sources() as $source ) {

[448] Fix | Delete

$moderation = LASettingsUtils::YepNope2ClassicStyleSafe($source, 'mod', false);

[449] Fix | Delete

if ($moderation){

[450] Fix | Delete

break;

[451] Fix | Delete

}

[452] Fix | Delete

}

[453] Fix | Delete

[454] Fix | Delete

$settings = new LAStreamSettings($stream);

[455] Fix | Delete

$cache = new LACacheAdapter($this->context);

[456] Fix | Delete

$cache->setStream($settings, $moderation);

[457] Fix | Delete

$instances = $this->createFeedInstances($settings->getAllFeeds());

[458] Fix | Delete

$result = $cache->posts($instances, $disableCache);

[459] Fix | Delete

unset($instances);

[460] Fix | Delete

if ($background) return $result;

[461] Fix | Delete

$errors = $cache->errors();

[462] Fix | Delete

$hash = $cache->hash();

[463] Fix | Delete

return $this->prepareResult($result, $errors, $hash, $settings);

[464] Fix | Delete

} catch ( Exception $e) {

[465] Fix | Delete

error_log($e->getMessage());

[466] Fix | Delete

error_log($e->getTraceAsString());

[467] Fix | Delete

}

[468] Fix | Delete

}

[469] Fix | Delete

return '';

[470] Fix | Delete

}

[471] Fix | Delete

[472] Fix | Delete

protected function initContextBeforeCreateFeedInstances(){

[473] Fix | Delete

$this->context['image_size_cache'] = new LAImageSizeCacheManager($this->context);

[474] Fix | Delete

}

[475] Fix | Delete

[476] Fix | Delete

private function process4feeds($feeds, $disableCache = false, $background = false) {

[477] Fix | Delete

try {

[478] Fix | Delete

$instances = $this->createFeedInstances($feeds);

[479] Fix | Delete

$cache = new LACacheAdapter($this->context, true);

[480] Fix | Delete

$result = $cache->posts($instances, $disableCache);

[481] Fix | Delete

unset($instances);

[482] Fix | Delete

if ($background) return $result;

[483] Fix | Delete

$errors = $cache->errors();

[484] Fix | Delete

$hash = $cache->hash();

[485] Fix | Delete

return $this->prepareResult($result, $errors, $hash);

[486] Fix | Delete

} catch ( Exception $e) {

[487] Fix | Delete

error_log($e->getMessage());

[488] Fix | Delete

error_log($e->getTraceAsString());

[489] Fix | Delete

}

[490] Fix | Delete

return '';

[491] Fix | Delete

}

[492] Fix | Delete

[493] Fix | Delete

/**

[494] Fix | Delete

* Rework code, delete the reference to the database and the logic of expiration life time

[495] Fix | Delete

*

[496] Fix | Delete

* @param $post_id

[497] Fix | Delete

* @param $feed_id

[498] Fix | Delete

*

[499] Fix | Delete