X-Git-Url: https://git.wh0rd.org/?a=blobdiff_plain;f=functions.php;h=86712f01bf99b2a4b1f5463b74d1ef1f53a4d133;hb=55132a454f997aef9fab29ad86e8f7bac6e0a1b6;hp=8436f2154b27e8b8f8b56d71083caa1954def85a;hpb=6e4f0519b75034144cd6b538f64c10f0759be595;p=tt-rss.git diff --git a/functions.php b/functions.php index 8436f215..86712f01 100644 --- a/functions.php +++ b/functions.php @@ -508,7 +508,26 @@ } - function update_rss_feed($link, $feed_url, $feed, $ignore_daemon = false) { + function update_rss_feed($link, $feed, $ignore_daemon = false) { + + global $memcache; + + /* Update all feeds with the same URL to utilize memcache */ + + if ($memcache) { + $result = db_query($link, "SELECT f1.id + FROM ttrss_feeds AS f1, ttrss_feeds AS f2 + WHERE f2.feed_url = f1.feed_url AND f2.id = '$feed'"); + + while ($line = db_fetch_assoc($result)) { + update_rss_feed_real($link, $line["id"], $ignore_daemon); + } + } else { + update_rss_feed_real($link, $feed, $ignore_daemon); + } + } + + function update_rss_feed_real($link, $feed, $ignore_daemon = false) { global $memcache; @@ -535,14 +554,14 @@ } else { $result = db_query($link, "SELECT id,update_interval,auth_login, - auth_pass,cache_images,update_method,last_updated + feed_url,auth_pass,cache_images,update_method,last_updated FROM ttrss_feeds WHERE id = '$feed'"); } if (db_num_rows($result) == 0) { if (defined('DAEMON_EXTENDED_DEBUG') || $_REQUEST['xdebug']) { - _debug("update_rss_feed: feed $feed [$feed_url] NOT FOUND/SKIPPED"); + _debug("update_rss_feed: feed $feed NOT FOUND/SKIPPED"); } return false; } @@ -577,13 +596,12 @@ $update_interval = db_fetch_result($result, 0, "update_interval"); $cache_images = sql_bool_to_bool(db_fetch_result($result, 0, "cache_images")); + $fetch_url = db_fetch_result($result, 0, "feed_url"); if ($update_interval < 0) { return; } $feed = db_escape_string($feed); - $fetch_url = $feed_url; - if ($auth_login && $auth_pass) { $url_parts = array(); preg_match("/(^[^:]*):\/\/(.*)/", $fetch_url, $url_parts); @@ -602,40 +620,54 @@ error_reporting(0); } - if (!$use_simplepie) { - $rss = fetch_rss($fetch_url); - } else { - if (!is_dir(SIMPLEPIE_CACHE_DIR)) { - mkdir(SIMPLEPIE_CACHE_DIR); - } - - $rss = new SimplePie(); - $rss->set_useragent(SIMPLEPIE_USERAGENT . MAGPIE_USER_AGENT_EXT); -# $rss->set_timeout(10); - $rss->set_feed_url($fetch_url); - $rss->set_output_encoding('UTF-8'); - - if (SIMPLEPIE_CACHE_IMAGES && $cache_images) { - if (defined('DAEMON_EXTENDED_DEBUG') || $_REQUEST['xdebug']) { - _debug("enabling image cache"); - } + $obj_id = md5("FDATA:$fetch_url"); - $rss->set_image_handler('./image.php', 'i'); - } + if ($memcache && $obj = $memcache->get($obj_id)) { if (defined('DAEMON_EXTENDED_DEBUG') || $_REQUEST['xdebug']) { - _debug("feed update interval (sec): " . - get_feed_update_interval($link, $feed)*60); + _debug("update_rss_feed: data found in memcache."); } - if (is_dir(SIMPLEPIE_CACHE_DIR)) { - $rss->set_cache_location(SIMPLEPIE_CACHE_DIR); - $rss->set_cache_duration(get_feed_update_interval($link, $feed) * 60); + $rss = $obj; + + } else { + + if (!$use_simplepie) { + $rss = fetch_rss($fetch_url); + } else { + if (!is_dir(SIMPLEPIE_CACHE_DIR)) { + mkdir(SIMPLEPIE_CACHE_DIR); + } + + $rss = new SimplePie(); + $rss->set_useragent(SIMPLEPIE_USERAGENT . MAGPIE_USER_AGENT_EXT); + # $rss->set_timeout(10); + $rss->set_feed_url($fetch_url); + $rss->set_output_encoding('UTF-8'); + + if (SIMPLEPIE_CACHE_IMAGES && $cache_images) { + if (defined('DAEMON_EXTENDED_DEBUG') || $_REQUEST['xdebug']) { + _debug("enabling image cache"); + } + + $rss->set_image_handler('./image.php', 'i'); + } + + if (defined('DAEMON_EXTENDED_DEBUG') || $_REQUEST['xdebug']) { + _debug("feed update interval (sec): " . + get_feed_update_interval($link, $feed)*60); + } + + if (is_dir(SIMPLEPIE_CACHE_DIR)) { + $rss->set_cache_location(SIMPLEPIE_CACHE_DIR); + $rss->set_cache_duration(get_feed_update_interval($link, $feed) * 60); + } + + $rss->init(); } - $rss->init(); + if ($memcache && $rss) $memcache->add($obj_id, $rss, 0, 300); } - // print_r($rss); @@ -1339,15 +1371,15 @@ # check for manual tags - $tag_filter = find_article_filter($article_filters, "tag"); + foreach ($article_filters as $f) { + if ($f[0] == "tag") { - if ($tag_filter) { + $manual_tags = trim_array(split(",", $f[1])); - $manual_tags = trim_array(split(",", $tag_filter[1])); - - foreach ($manual_tags as $tag) { - if (tag_is_valid($tag)) { - array_push($entry_tags, $tag); + foreach ($manual_tags as $tag) { + if (tag_is_valid($tag)) { + array_push($entry_tags, $tag); + } } } } @@ -2015,7 +2047,7 @@ function get_user_theme($link) { - if (get_schema_version($link) >= 63) { + if (get_schema_version($link) >= 63 && $_SESSION["uid"]) { $theme_name = get_pref($link, "_THEME_ID"); if (is_dir("themes/$theme_name")) { return $theme_name; @@ -2030,7 +2062,7 @@ function get_user_theme_path($link) { - if (get_schema_version($link) >= 63) { + if (get_schema_version($link) >= 63 && $_SESSION["uid"]) { $theme_name = get_pref($link, "_THEME_ID"); if ($theme_name && is_dir("themes/$theme_name")) { @@ -2398,20 +2430,16 @@ $cat_qpart = "cat_id IS NULL"; } - $tmp_result = db_query($link, "SELECT id,feed_url FROM ttrss_feeds + $tmp_result = db_query($link, "SELECT id FROM ttrss_feeds WHERE $cat_qpart AND owner_uid = " . $_SESSION["uid"]); while ($tmp_line = db_fetch_assoc($tmp_result)) { - $feed_url = $tmp_line["feed_url"]; $feed_id = $tmp_line["id"]; - update_rss_feed($link, $feed_url, $feed_id, $force_update); + update_rss_feed($link, $feed_id, $force_update); } } else { - $tmp_result = db_query($link, "SELECT feed_url FROM ttrss_feeds - WHERE id = '$feed'"); - $feed_url = db_fetch_result($tmp_result, 0, "feed_url"); - update_rss_feed($link, $feed_url, $feed, $force_update); + update_rss_feed($link, $feed, $force_update); } } @@ -2931,7 +2959,7 @@ $feed_id = db_fetch_result($result, 0, "id"); if ($feed_id) { - update_rss_feed($link, $url, $feed_id, true); + update_rss_feed($link, $feed_id, true); } return 1; @@ -3723,7 +3751,7 @@ $res = preg_replace('/]+>/is', '', $res); } - if (get_pref($link, 'OPEN_LINKS_IN_NEW_WINDOW')) { + if (get_pref($link, 'OPEN_LINKS_IN_NEW_WINDOW', $owner)) { $res = preg_replace("/href=/i", "target=\"_blank\" href=", $res); } @@ -5833,7 +5861,7 @@ // We setup a alarm to alert if the feed take more than 300s to update. // => HANG alarm. if(!$from_http && function_exists('pcntl_alarm')) pcntl_alarm(300); - update_rss_feed($link, $line["feed_url"], $line["id"], true); + update_rss_feed($link, $line["id"], true); // Cancel the alarm (the update went well) if(!$from_http && function_exists('pcntl_alarm')) pcntl_alarm(0);