<?php namespace la\core\db;

[0] Fix | Delete

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

[1] Fix | Delete

[2] Fix | Delete

use Exception;

[3] Fix | Delete

use la\core\settings\LASettingsUtils;

[4] Fix | Delete

[5] Fix | Delete

/**

[6] Fix | Delete

* Flow-Flow.

[7] Fix | Delete

*

[8] Fix | Delete

* @package FlowFlow

[9] Fix | Delete

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

[10] Fix | Delete

[11] Fix | Delete

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

[12] Fix | Delete

* @copyright Looks Awesome

[13] Fix | Delete

*/

[14] Fix | Delete

class LADB {

[15] Fix | Delete

public static function create(){

[16] Fix | Delete

try{

[17] Fix | Delete

return new LASafeMySQL( [ 'host' => DB_HOST, 'user' => DB_USER, 'pass' => DB_PASSWORD, 'db' => DB_NAME, 'charset' => FF_DB_CHARSET, 'errmode' => 'exception' ] );

[18] Fix | Delete

// @codeCoverageIgnoreStart

[19] Fix | Delete

} catch( Exception $e){

[20] Fix | Delete

echo '<b>Flow-Flow</b> plugin encountered database connection error. Please contact for support via item\'s comments section and provide info below:<br>';

[21] Fix | Delete

echo $e->getMessage();

[22] Fix | Delete

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

[23] Fix | Delete

var_dump($e);

[24] Fix | Delete

}

[25] Fix | Delete

error_log($e->getMessage());

[26] Fix | Delete

error_log($e->getTraceAsString());

[27] Fix | Delete

die();

[28] Fix | Delete

}

[29] Fix | Delete

// @codeCoverageIgnoreEnd

[30] Fix | Delete

}

[31] Fix | Delete

[32] Fix | Delete

private static $cache = [];

[33] Fix | Delete

[34] Fix | Delete

public static function getOption($conn, $table_name, $option_name, $serialized = false, $lock_row = false, $without_cache = false){

[35] Fix | Delete

if ($lock_row || $without_cache || !isset(self::$cache[$option_name])){

[36] Fix | Delete

$q = 'select `value` from ?n where `id`=?s';

[37] Fix | Delete

if ($lock_row) $q .= ' for update';

[38] Fix | Delete

$options = $conn->getOne($q, $table_name, $option_name);

[39] Fix | Delete

if ($options == false || $options == null ) return false;

[40] Fix | Delete

if ($without_cache){

[41] Fix | Delete

return $serialized ? unserialize($options) : $options;

[42] Fix | Delete

}

[43] Fix | Delete

self::$cache[$option_name] = $serialized ? unserialize($options) : $options;

[44] Fix | Delete

}

[45] Fix | Delete

return self::$cache[$option_name];

[46] Fix | Delete

}

[47] Fix | Delete

[48] Fix | Delete

/**

[49] Fix | Delete

* @param $conn

[50] Fix | Delete

* @param $table_name

[51] Fix | Delete

* @param $optionName

[52] Fix | Delete

* @param $optionValue

[53] Fix | Delete

* @param false $serialized

[54] Fix | Delete

* @param bool $cached

[55] Fix | Delete

*

[56] Fix | Delete

* @throws Exception

[57] Fix | Delete

*/

[58] Fix | Delete

public static function setOption($conn, $table_name, $optionName, $optionValue, $serialized = false, $cached = true){

[59] Fix | Delete

if ($cached) self::$cache[$optionName] = is_object($optionValue) ? clone $optionValue : $optionValue;

[60] Fix | Delete

if ($serialized) $optionValue = serialize($optionValue);

[61] Fix | Delete

if ( false === $conn->query( 'INSERT INTO ?n SET `id`=?s, `value`=?s ON DUPLICATE KEY UPDATE `value`=?s',

[62] Fix | Delete

$table_name, $optionName, $optionValue, $optionValue ) ) {

[63] Fix | Delete

throw new Exception(); // @codeCoverageIgnore

[64] Fix | Delete

}

[65] Fix | Delete

}

[66] Fix | Delete

[67] Fix | Delete

/**

[68] Fix | Delete

* @param $conn

[69] Fix | Delete

* @param $table_name

[70] Fix | Delete

* @param $optionName

[71] Fix | Delete

*

[72] Fix | Delete

* @throws Exception

[73] Fix | Delete

*/

[74] Fix | Delete

public static function deleteOption($conn, $table_name, $optionName){

[75] Fix | Delete

if (false === $conn->query('DELETE FROM ?n WHERE `id`=?s', $table_name, $optionName)){

[76] Fix | Delete

throw new Exception(); // @codeCoverageIgnore

[77] Fix | Delete

}

[78] Fix | Delete

unset(self::$cache[$optionName]);

[79] Fix | Delete

}

[80] Fix | Delete

[81] Fix | Delete

/**

[82] Fix | Delete

* @param LASafeMySQL $conn

[83] Fix | Delete

* @param string $table_name

[84] Fix | Delete

*

[85] Fix | Delete

* @return array

[86] Fix | Delete

*/

[87] Fix | Delete

public static function streams($conn, $table_name){

[88] Fix | Delete

if (false !== ($result = $conn->getIndCol('id', 'SELECT `id`, `name`, `value` FROM ?n ORDER BY `id`', $table_name))){

[89] Fix | Delete

return $result;

[90] Fix | Delete

}

[91] Fix | Delete

return [];

[92] Fix | Delete

}

[93] Fix | Delete

[94] Fix | Delete

/**

[95] Fix | Delete

* @param LASafeMySQL $conn

[96] Fix | Delete

* @param $cache_table_name

[97] Fix | Delete

* @param $streams_sources_table_name

[98] Fix | Delete

* @param string $stream

[99] Fix | Delete

* @param bool $only_enable

[100] Fix | Delete

*

[101] Fix | Delete

* @return array

[102] Fix | Delete

*/

[103] Fix | Delete

public static function sources($conn, $cache_table_name, $streams_sources_table_name, $stream = null, $only_enable = false){

[104] Fix | Delete

$sql_part = '';

[105] Fix | Delete

if ($only_enable && $stream == null) $sql_part = $conn->parse('WHERE `enabled` = 1');

[106] Fix | Delete

if ($stream != null) $sql_part = $conn->parse('inner join ?n `conn` on `cach`.`feed_id` = `conn`.`feed_id` WHERE `enabled` = 1 and `conn`.`stream_id` = ?s', $streams_sources_table_name, $stream);

[107] Fix | Delete

$sql = $conn->parse('SELECT `cach`.`feed_id` as `id`, `settings`, `errors`, `status`, `enabled`, `last_update`, `cach`.cache_lifetime, `cach`.system_enabled, `cach`.boosted FROM ?n `cach` ?p ORDER BY `changed_time` DESC', $cache_table_name, $sql_part);

[108] Fix | Delete

if (false !== ($result = $conn->getInd('id', $sql))){

[109] Fix | Delete

foreach ( $result as &$source ) {

[110] Fix | Delete

self::prepareSource($source);

[111] Fix | Delete

}

[112] Fix | Delete

return $result;

[113] Fix | Delete

}

[114] Fix | Delete

return [];

[115] Fix | Delete

}

[116] Fix | Delete

[117] Fix | Delete

public static function prepareSource(&$source){

[118] Fix | Delete

if (isset($source['settings'])){

[119] Fix | Delete

$settings = unserialize($source['settings']);

[120] Fix | Delete

if (is_object($settings)) {

[121] Fix | Delete

$source = array_merge($source, (array) $settings);

[122] Fix | Delete

unset($source['settings']);

[123] Fix | Delete

}

[124] Fix | Delete

}

[125] Fix | Delete

[126] Fix | Delete

$source['enabled'] = $source['system_enabled'] == 1 ? (($source['enabled'] == 1 || $source['enabled'] == LASettingsUtils::YEP) ? LASettingsUtils::YEP : LASettingsUtils::NOPE) : LASettingsUtils::NOPE;

[127] Fix | Delete

$offset = get_option('gmt_offset', 0);

[128] Fix | Delete

$date = $source['last_update'] + $offset * 3600;

[129] Fix | Delete

$source['last_update'] = $source['last_update'] == 0 ? 'N/A' : LASettingsUtils::classicStyleDate($date);

[130] Fix | Delete

if (!isset($source['errors']) || is_null($source['errors'])) {

[131] Fix | Delete

$source['errors'] = [];

[132] Fix | Delete

}

[133] Fix | Delete

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

[134] Fix | Delete

$errors = is_string($source['errors']) ? unserialize($source['errors']) : $source['errors'];

[135] Fix | Delete

if (false !== $errors){

[136] Fix | Delete

if (is_array($errors)){

[137] Fix | Delete

$escape = [ "'" ];

[138] Fix | Delete

$replacements = [ " " ];

[139] Fix | Delete

foreach ( $errors as &$error ) {

[140] Fix | Delete

if (isset($error['message'])){

[141] Fix | Delete

if (is_array($error['message'])){

[142] Fix | Delete

for ( $i = 0; $i < sizeof($error['message']); $i ++ ) {

[143] Fix | Delete

$error['message'][$i]['msg'] = str_replace($escape, $replacements, $error['message'][$i]['msg']);

[144] Fix | Delete

}

[145] Fix | Delete

}

[146] Fix | Delete

else {

[147] Fix | Delete

$error['message'] = str_replace($escape, $replacements, $error['message']);

[148] Fix | Delete

}

[149] Fix | Delete

continue;

[150] Fix | Delete

}

[151] Fix | Delete

[152] Fix | Delete

//TODO delete

[153] Fix | Delete

if (is_array($error) && isset($error[0])){

[154] Fix | Delete

$error['message'] = $error[0];

[155] Fix | Delete

unset($error[0]);

[156] Fix | Delete

}

[157] Fix | Delete

if (is_array($error) && isset($error['msg'])){

[158] Fix | Delete

$error['message'] = $error['msg'];

[159] Fix | Delete

unset($error['msg']);

[160] Fix | Delete

}

[161] Fix | Delete

}

[162] Fix | Delete

$source['errors'] = $errors;

[163] Fix | Delete

}

[164] Fix | Delete

}

[165] Fix | Delete

}

[166] Fix | Delete

if ((empty($source['errors']) || is_string($source['errors'])) && $source['status'] === '0') {

[167] Fix | Delete

$source['errors'] = [ [ 'type' => $source['type'], 'message' => 'Feed cache has not been built. Try to manually rebuild cache using three dots menu on the left.' ] ];

[168] Fix | Delete

}

[169] Fix | Delete

}

[170] Fix | Delete

[171] Fix | Delete

/**

[172] Fix | Delete

* @param LASafeMySQL $conn

[173] Fix | Delete

* @param string $table_name

[174] Fix | Delete

*

[175] Fix | Delete

* @return bool|int

[176] Fix | Delete

*/

[177] Fix | Delete

public static function countFeeds($conn, $table_name){

[178] Fix | Delete

if (LADDLUtils::existTable($conn, $table_name) && false !== ($count = $conn->getOne('select count(*) from ?n', $table_name))){

[179] Fix | Delete

return (int) $count;

[180] Fix | Delete

}

[181] Fix | Delete

return false;

[182] Fix | Delete

}

[183] Fix | Delete

[184] Fix | Delete

/**

[185] Fix | Delete

* @param LASafeMySQL $conn

[186] Fix | Delete

* @param string $table_name

[187] Fix | Delete

*

[188] Fix | Delete

* @return bool|int

[189] Fix | Delete

*/

[190] Fix | Delete

public static function maxIdOfStreams($conn, $table_name){

[191] Fix | Delete

if (false !== ($max = $conn->getOne('select max(`id`) from ?n', $table_name))){

[192] Fix | Delete

return (int) $max;

[193] Fix | Delete

}

[194] Fix | Delete

return false;

[195] Fix | Delete

}

[196] Fix | Delete

[197] Fix | Delete

public static function getStream($conn, $table_name, $id){

[198] Fix | Delete

if (!array_key_exists($id, self::$cache)){

[199] Fix | Delete

if (false !== ($row = $conn->getRow('select `value`, `feeds` from ?n where `id`=?s', $table_name, $id))) {

[200] Fix | Delete

if ($row != null){

[201] Fix | Delete

self::$cache[$id] = self::unserializeStream($row);

[202] Fix | Delete

}

[203] Fix | Delete

else return null;

[204] Fix | Delete

}

[205] Fix | Delete

}

[206] Fix | Delete

return self::$cache[$id];

[207] Fix | Delete

}

[208] Fix | Delete

[209] Fix | Delete

public static function unserializeStream($stream){

[210] Fix | Delete

//$options->feeds = $stream['feeds'];

[211] Fix | Delete

return unserialize($stream['value']);

[212] Fix | Delete

}

[213] Fix | Delete

[214] Fix | Delete

public static function getStatusInfo($conn, $cache_table_name, $streams_sources_table_name, $streamId, $format = true) {

[215] Fix | Delete

$sql_part = $conn->parse('where `src`.`stream_id` = ?s and `cach`.`enabled` = true', $streamId);

[216] Fix | Delete

$sql = $conn->parse('select `src`.`stream_id` as `id`, MIN(`cach`.`status`) as `status`, COUNT(`cach`.`feed_id`) as `feeds_count` from ?n `cach` inner join ?n `src` on `cach`.`feed_id` = `src`.`feed_id` ?p group by `src`.`stream_id`', $cache_table_name, $streams_sources_table_name, $sql_part);

[217] Fix | Delete

$status_info = $conn->getAll($sql);

[218] Fix | Delete

if (empty($status_info)){

[219] Fix | Delete

return [ 'id' => (string)$streamId, 'status' => '1', 'feeds_count' => '0' ];

[220] Fix | Delete

}

[221] Fix | Delete

$status_info = $status_info[0];

[222] Fix | Delete

if ($status_info['status'] == '0') {

[223] Fix | Delete

$status_info['error'] = self::getError($conn, $cache_table_name, $streams_sources_table_name, $streamId, $format);

[224] Fix | Delete

}

[225] Fix | Delete

return $status_info;

[226] Fix | Delete

}

[227] Fix | Delete

[228] Fix | Delete

/**

[229] Fix | Delete

* @param LASafeMySQL $conn

[230] Fix | Delete

* @param $cache_table_name

[231] Fix | Delete

* @param $streams_sources_table_name

[232] Fix | Delete

* @param $streamId

[233] Fix | Delete

* @param bool $format

[234] Fix | Delete

*

[235] Fix | Delete

* @return array|string|true

[236] Fix | Delete

*/

[237] Fix | Delete

public static function getError($conn, $cache_table_name, $streams_sources_table_name, $streamId, $format = true){

[238] Fix | Delete

$result = '';

[239] Fix | Delete

$errors = $conn->getInd('feed_id', 'select `cach`.`errors`, `cach`.`feed_id` from ?n `cach` inner join ?n `src` on `cach`.`feed_id` = `src`.`feed_id` where `src`.`stream_id` = ?s and `cach`.`enabled` = 1', $cache_table_name, $streams_sources_table_name, $streamId);

[240] Fix | Delete

foreach ( $errors as $feed => $error ) {

[241] Fix | Delete

unset($error['feed_id']);

[242] Fix | Delete

if (is_array($error)){

[243] Fix | Delete

foreach ( $error as $str ) {

[244] Fix | Delete

$value = unserialize($str);

[245] Fix | Delete

if (!empty($value)){

[246] Fix | Delete

if (is_array($value) && sizeof($value) > 0){

[247] Fix | Delete

$value = $value[0];

[248] Fix | Delete

}

[249] Fix | Delete

if (!is_array($result)) $result = [];

[250] Fix | Delete

$result[$feed] = $value;

[251] Fix | Delete

}

[252] Fix | Delete

[253] Fix | Delete

}

[254] Fix | Delete

}

[255] Fix | Delete

else if (is_string($error)){

[256] Fix | Delete

$value = unserialize($error);

[257] Fix | Delete

if (!empty($value)){

[258] Fix | Delete

$result[] = $value;

[259] Fix | Delete

}

[260] Fix | Delete

[261] Fix | Delete

}

[262] Fix | Delete

}

[263] Fix | Delete

return $format ? print_r($result, true) : $result;

[264] Fix | Delete

}

[265] Fix | Delete

[266] Fix | Delete

/**

[267] Fix | Delete

* @param LASafeMySQL $conn

[268] Fix | Delete

* @param $streams_table_name

[269] Fix | Delete

* @param $streams_sources_table_name

[270] Fix | Delete

* @param $id

[271] Fix | Delete

* @param $stream

[272] Fix | Delete

*

[273] Fix | Delete

* @throws Exception

[274] Fix | Delete

*/

[275] Fix | Delete

public static function setStream($conn, $streams_table_name, $streams_sources_table_name, $id, $stream){

[276] Fix | Delete

self::$cache[$id] = clone $stream;

[277] Fix | Delete

$name = @$stream->name;

[278] Fix | Delete

$originalFeed = $stream->feeds;

[279] Fix | Delete

if (is_string($stream->feeds)){

[280] Fix | Delete

$feeds = stripslashes($stream->feeds);

[281] Fix | Delete

$feeds = json_decode($feeds);

[282] Fix | Delete

}

[283] Fix | Delete

else{

[284] Fix | Delete

$feeds = (array)$stream->feeds;

[285] Fix | Delete

}

[286] Fix | Delete

unset($stream->feeds);

[287] Fix | Delete

$serialized = serialize($stream);

[288] Fix | Delete

[289] Fix | Delete

$common = [

[290] Fix | Delete

'name' => $name,

[291] Fix | Delete

'value' => $serialized

[292] Fix | Delete

];

[293] Fix | Delete

if ( false === $conn->query( 'INSERT INTO ?n SET `id`=?s, ?u ON DUPLICATE KEY UPDATE ?u',

[294] Fix | Delete

$streams_table_name, $id, $common, $common ) ) {

[295] Fix | Delete

throw new Exception();

[296] Fix | Delete

}

[297] Fix | Delete

[298] Fix | Delete

$stream->feeds = $originalFeed;

[299] Fix | Delete

[300] Fix | Delete

$feed_ids = [];

[301] Fix | Delete

foreach ( $feeds as $feed ) {

[302] Fix | Delete

$fid = is_array($feed) ? $feed['id'] : $feed->id;

[303] Fix | Delete

$feed_ids[] = $fid;

[304] Fix | Delete

$connect = [

[305] Fix | Delete

'stream_id' => $id,

[306] Fix | Delete

'feed_id' => $fid

[307] Fix | Delete

];

[308] Fix | Delete

if ( false === $conn->query( 'INSERT INTO ?n SET ?u ON DUPLICATE KEY UPDATE ?u',

[309] Fix | Delete

$streams_sources_table_name, $connect, $connect ) ) {

[310] Fix | Delete

throw new Exception();

[311] Fix | Delete

}

[312] Fix | Delete

}

[313] Fix | Delete

$sql_part = '';

[314] Fix | Delete

if (!empty($feed_ids)) {

[315] Fix | Delete

$sql_part = $conn->parse(' AND `feed_id` NOT IN (?a)', $feed_ids);

[316] Fix | Delete

}

[317] Fix | Delete

if ( false === $conn->query( 'DELETE FROM ?n WHERE `stream_id`=?s ?p',

[318] Fix | Delete

$streams_sources_table_name, $id, $sql_part ) ) {

[319] Fix | Delete

throw new Exception();

[320] Fix | Delete

}

[321] Fix | Delete

$conn->commit();

[322] Fix | Delete

}

[323] Fix | Delete

[324] Fix | Delete

public static function deleteStream($conn, $streams_table_name, $streams_sources_table_name, $id){

[325] Fix | Delete

unset(self::$cache[$id]);

[326] Fix | Delete

if (false === $conn->query('DELETE FROM ?n WHERE `id`=?s', $streams_table_name, $id)){

[327] Fix | Delete

return new Exception();

[328] Fix | Delete

}

[329] Fix | Delete

if (false === $conn->query('DELETE FROM ?n WHERE `stream_id`=?s', $streams_sources_table_name, $id)){

[330] Fix | Delete

return new Exception();

[331] Fix | Delete

}

[332] Fix | Delete

return true;

[333] Fix | Delete

}

[334] Fix | Delete

[335] Fix | Delete

public static function saveFeed($conn, $cache_table_name, $feed_id, $values){

[336] Fix | Delete

$sql = $conn->parse('UPDATE ?n SET ?u WHERE `feed_id` = ?s', $cache_table_name, $values, $feed_id);

[337] Fix | Delete

return $conn->query($sql);

[338] Fix | Delete

}

[339] Fix | Delete

}

[340] Fix | Delete