viewfeed: force request counters

[tt-rss.git] / include / rssfuncs.php

diff --git a/include/rssfuncs.php b/include/rssfuncs.php
index a28cb2063077d744d5d62d558790dcde9ef17591..8500df0df718626c5e511fd5308d38600f96ba2a 100644 (file)
--- a/include/rssfuncs.php
+++ b/include/rssfuncs.php
@@ -153,6 +153,8 @@
                        sleep(1); // prevent flood (FIXME make this an option?)
                }
 
+               require_once "digest.php";
+
                // Send feed digests by email if needed.
                send_headlines_digests($link, $debug);
 
@@ -235,7 +237,7 @@
                $rss->set_timeout($no_cache ? 15 : 60);
                $rss->set_feed_url($fetch_url);
                $rss->set_output_encoding('UTF-8');
-               //$rss->force_feed(true);
+               $rss->force_feed(true);
 
                if ($debug_enabled) {
                        _debug("feed update interval (sec): " .
@@ -261,6 +263,17 @@
 
                if (!$rss->error()) {
 
+                       // We use local pluginhost here because we need to load different per-user feed plugins
+                       $user_plugins = get_pref($link, "_ENABLED_PLUGINS", $owner_uid);
+
+                       $pluginhost = new PluginHost($link);
+
+                       $pluginhost->load(PLUGINS, $pluginhost::KIND_ALL);
+                       $pluginhost->load($user_plugins, $pluginhost::KIND_USER, $owner_uid);
+                       $pluginhost->load_data();
+
+                       $pluginhost->run_hooks($pluginhost::HOOK_FEED_PARSED, "hook_feed_parsed", $rss);
+
                        if ($debug_enabled) {
                                _debug("update_rss_feed: processing feed data...");
                        }
@@ -286,7 +299,7 @@
 
                        $owner_uid = db_fetch_result($result, 0, "owner_uid");
 
-                       $site_url = db_escape_string(mb_substr(rewrite_relative_url($fetch_url, $rss->get_link()), 0, 250));
+                       $site_url = db_escape_string(mb_substr(rewrite_relative_url($fetch_url, $rss->get_link()), 0, 245));
 
                        if ($debug_enabled) {
                                _debug("update_rss_feed: checking favicon...");
@@ -317,7 +330,7 @@
                        }
 
                        $icon_url = db_escape_string(mb_substr(
-                               rewrite_relative_url($fetch_url, $rss->get_image_url()), 0, 250));
+                               rewrite_relative_url($fetch_url, $rss->get_image_url()), 0, 245));
 
                        if ($icon_url && $orig_icon_url != $icon_url) {
                                db_query($link, "UPDATE ttrss_feeds SET icon_url = '$icon_url' WHERE id = '$feed'");
@@ -398,20 +411,14 @@
                                if (!$entry_guid) $entry_guid = $item->get_link();
                                if (!$entry_guid) $entry_guid = make_guid_from_title($item->get_title());
 
-                               if ($cache_content) {
-                                       $entry_guid = "ccache:$entry_guid";
-                               }
-
-                               if ($auth_login || $auth_pass) {
-                                       $entry_guid = "auth,$owner_uid:$entry_guid";
-                               }
-
                                if ($debug_enabled) {
                                        _debug("update_rss_feed: guid $entry_guid");
                                }
 
                                if (!$entry_guid) continue;
 
+                               $entry_guid = "$owner_uid,$entry_guid";
+
                                $entry_timestamp = "";
 
                                $entry_timestamp = strtotime($item->get_date());
@@ -464,13 +471,10 @@
                                        $entry_author = db_escape_string($entry_author);
                                }
 
-                               $entry_guid = db_escape_string(mb_substr($entry_guid, 0, 250));
+                               $entry_guid = db_escape_string(mb_substr($entry_guid, 0, 245));
 
-                               $result = db_query($link, "SELECT id FROM       ttrss_entries
-                                       WHERE guid = '$entry_guid'");
-
-                               $entry_comments = db_escape_string(mb_substr($entry_comments, 0, 250));
-                               $entry_author = db_escape_string(mb_substr($entry_author, 0, 250));
+                               $entry_comments = db_escape_string(mb_substr($entry_comments, 0, 245));
+                               $entry_author = db_escape_string(mb_substr($entry_author, 0, 245));
 
                                $num_comments = $item->get_item_tags('http://purl.org/rss/1.0/modules/slash/', 'comments');
 
@@ -521,13 +525,13 @@
                                }
 
                                // TODO: less memory-hungry implementation
-                               global $pluginhost;
 
                                if ($debug_enabled) {
                                        _debug("update_rss_feed: applying plugin filters..");
                                }
 
-                               $article = array("owner_uid" => $owner_uid,
+                               $article = array("owner_uid" => $owner_uid, // read only
+                                       "guid" => $entry_guid,
                                        "title" => $entry_title,
                                        "content" => $entry_content,
                                        "link" => $entry_link,
@@ -539,22 +543,26 @@
                                }
 
                                $entry_tags = $article["tags"];
+                               $entry_guid = db_escape_string($article["guid"]);
                                $entry_content = db_escape_string($article["content"], false);
                                $entry_title = db_escape_string($article["title"]);
                                $entry_author = db_escape_string($article["author"]);
                                $entry_link = db_escape_string($article["link"]);
 
-                               $content_hash = "SHA1:" . sha1(strip_tags($entry_content));
+                               $content_hash = "SHA1:" . sha1($entry_content);
 
                                db_query($link, "BEGIN");
 
+                               $result = db_query($link, "SELECT id FROM       ttrss_entries
+                                       WHERE guid = '$entry_guid'");
+
                                if (db_num_rows($result) == 0) {
 
                                        if ($debug_enabled) {
-                                               _debug("update_rss_feed: base guid not found");
+                                               _debug("update_rss_feed: base guid [$entry_guid] not found");
                                        }
 
-                                       if ($cache_content) {
+                                       if (defined('_FEEDS_CONTENT_CACHE') && _FEEDS_CONTENT_CACHE && $cache_content) {
                                                if ($debug_enabled) {
                                                        _debug("update_rss_feed: caching content (initial)...");
                                                }
@@ -632,7 +640,7 @@
                                if (db_num_rows($result) == 1) {
 
                                        if ($debug_enabled) {
-                                               _debug("update_rss_feed: base guid found, checking for user record");
+                                               _debug("update_rss_feed: base guid [$entry_guid] found, checking for user record");
                                        }
 
                                        // this will be used below in update handler
@@ -788,7 +796,7 @@
                                                $cached_content_needs_update = true;
                                        }
 
-                                       if ($cache_content) {
+                                       if (defined('_FEEDS_CONTENT_CACHE') && _FEEDS_CONTENT_CACHE && $cache_content) {
                                                if ($debug_enabled) {
                                                        _debug("update_rss_feed: caching content because original checksum changed...");
                                                }
@@ -1014,14 +1022,12 @@
 
                } else {
 
-                       $error_msg = mb_substr($rss->error(), 0, 250);
+                       $error_msg = db_escape_string(mb_substr($rss->error(), 0, 245));
 
                        if ($debug_enabled) {
                                _debug("update_rss_feed: error fetching feed: $error_msg");
                        }
 
-                       $error_msg = db_escape_string($error_msg);
-
                        db_query($link,
                                "UPDATE ttrss_feeds SET last_error = '$error_msg',
                                        last_updated = NOW() WHERE id = '$feed'");
@@ -1281,4 +1287,11 @@
 
                return "";
        }
+
+       function make_guid_from_title($title) {
+               return preg_replace("/[ \"\',.:;]/", "-",
+                       mb_strtolower(strip_tags($title), 'utf-8'));
+       }
+
+
 ?>