WHERE ref_id IN ($article_ids)");
while ($line = $this->dbh->fetch_assoc($result)) {
- ccache_update($line["feed_id"], $_SESSION["uid"]);
+ CCache::update($line["feed_id"], $_SESSION["uid"]);
}
}
}
$feed_id = $this->getArticleFeed($id);
- ccache_update($feed_id, $_SESSION["uid"]);
+ CCache::update($feed_id, $_SESSION["uid"]);
}
static function create_published_article($title, $url, $content, $labels_str,
SET unread = false,last_read = NOW()
WHERE ref_id = '$id' AND owner_uid = $owner_uid");
- ccache_update($feed_id, $owner_uid);
+ CCache::update($feed_id, $owner_uid);
}
$result = db_query("SELECT id,title,link,content,feed_id,comments,int_id,lang,
WHERE ($ids_qpart) AND owner_uid = $owner_uid");
while ($line = db_fetch_assoc($result)) {
- ccache_update($line["feed_id"], $owner_uid);
+ CCache::update($line["feed_id"], $owner_uid);
}
}
--- /dev/null
+<?php
+class CCache {
+ /* function ccache_zero($feed_id, $owner_uid) {
+ db_query("UPDATE ttrss_counters_cache SET
+ value = 0, updated = NOW() WHERE
+ feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
+ } */
+
+ static function zero_all($owner_uid) {
+ db_query("UPDATE ttrss_counters_cache SET
+ value = 0 WHERE owner_uid = '$owner_uid'");
+
+ db_query("UPDATE ttrss_cat_counters_cache SET
+ value = 0 WHERE owner_uid = '$owner_uid'");
+ }
+
+ static function remove($feed_id, $owner_uid, $is_cat = false) {
+
+ if (!$is_cat) {
+ $table = "ttrss_counters_cache";
+ } else {
+ $table = "ttrss_cat_counters_cache";
+ }
+
+ db_query("DELETE FROM $table WHERE
+ feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
+
+ }
+
+ static function update_all($owner_uid) {
+
+ if (get_pref('ENABLE_FEED_CATS', $owner_uid)) {
+
+ $result = db_query("SELECT feed_id FROM ttrss_cat_counters_cache
+ WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
+
+ while ($line = db_fetch_assoc($result)) {
+ CCache::update($line["feed_id"], $owner_uid, true);
+ }
+
+ /* We have to manually include category 0 */
+
+ CCache::update(0, $owner_uid, true);
+
+ } else {
+ $result = db_query("SELECT feed_id FROM ttrss_counters_cache
+ WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
+
+ while ($line = db_fetch_assoc($result)) {
+ print CCache::update($line["feed_id"], $owner_uid);
+
+ }
+
+ }
+ }
+
+ static function find($feed_id, $owner_uid, $is_cat = false,
+ $no_update = false) {
+
+ if (!is_numeric($feed_id)) return;
+
+ if (!$is_cat) {
+ $table = "ttrss_counters_cache";
+ /* if ($feed_id > 0) {
+ $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
+ WHERE id = '$feed_id'");
+ $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
+ } */
+ } else {
+ $table = "ttrss_cat_counters_cache";
+ }
+
+ if (DB_TYPE == "pgsql") {
+ $date_qpart = "updated > NOW() - INTERVAL '15 minutes'";
+ } else if (DB_TYPE == "mysql") {
+ $date_qpart = "updated > DATE_SUB(NOW(), INTERVAL 15 MINUTE)";
+ }
+
+ $result = db_query("SELECT value FROM $table
+ WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id'
+ LIMIT 1");
+
+ if (db_num_rows($result) == 1) {
+ return db_fetch_result($result, 0, "value");
+ } else {
+ if ($no_update) {
+ return -1;
+ } else {
+ return CCache::update($feed_id, $owner_uid, $is_cat);
+ }
+ }
+
+ }
+
+ static function update($feed_id, $owner_uid, $is_cat = false,
+ $update_pcat = true, $pcat_fast = false) {
+
+ if (!is_numeric($feed_id)) return;
+
+ /* if (!$is_cat && $feed_id > 0) {
+ $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
+ WHERE id = '$feed_id'");
+ $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
+ } */
+
+ $prev_unread = CCache::find($feed_id, $owner_uid, $is_cat, true);
+
+ /* When updating a label, all we need to do is recalculate feed counters
+ * because labels are not cached */
+
+ if ($feed_id < 0) {
+ CCache::update_all($owner_uid);
+ return;
+ }
+
+ if (!$is_cat) {
+ $table = "ttrss_counters_cache";
+ } else {
+ $table = "ttrss_cat_counters_cache";
+ }
+
+ if ($is_cat && $feed_id >= 0) {
+ if ($feed_id != 0) {
+ $cat_qpart = "cat_id = '$feed_id'";
+ } else {
+ $cat_qpart = "cat_id IS NULL";
+ }
+
+ /* Recalculate counters for child feeds */
+
+ if (!$pcat_fast) {
+ $result = db_query("SELECT id FROM ttrss_feeds
+ WHERE owner_uid = '$owner_uid' AND $cat_qpart");
+
+ while ($line = db_fetch_assoc($result)) {
+ CCache::update($line["id"], $owner_uid, false, false);
+ }
+ }
+
+ $result = db_query("SELECT SUM(value) AS sv
+ FROM ttrss_counters_cache, ttrss_feeds
+ WHERE id = feed_id AND $cat_qpart AND
+ ttrss_counters_cache.owner_uid = $owner_uid AND
+ ttrss_feeds.owner_uid = '$owner_uid'");
+
+ $unread = (int) db_fetch_result($result, 0, "sv");
+
+ } else {
+ $unread = (int) Feeds::getFeedArticles($feed_id, $is_cat, true, $owner_uid);
+ }
+
+ db_query("BEGIN");
+
+ $result = db_query("SELECT feed_id FROM $table
+ WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id' LIMIT 1");
+
+ if (db_num_rows($result) == 1) {
+ db_query("UPDATE $table SET
+ value = '$unread', updated = NOW() WHERE
+ feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
+
+ } else {
+ db_query("INSERT INTO $table
+ (feed_id, value, owner_uid, updated)
+ VALUES
+ ($feed_id, $unread, $owner_uid, NOW())");
+ }
+
+ db_query("COMMIT");
+
+ if ($feed_id > 0 && $prev_unread != $unread) {
+
+ if (!$is_cat) {
+
+ /* Update parent category */
+
+ if ($update_pcat) {
+
+ $result = db_query("SELECT cat_id FROM ttrss_feeds
+ WHERE owner_uid = '$owner_uid' AND id = '$feed_id'");
+
+ $cat_id = (int) db_fetch_result($result, 0, "cat_id");
+
+ CCache::update($cat_id, $owner_uid, true, true, true);
+
+ }
+ }
+ } else if ($feed_id < 0) {
+ CCache::update_all($owner_uid);
+ }
+
+ return $unread;
+ }
+
+ /* function ccache_cleanup($owner_uid) {
+
+ if (DB_TYPE == "pgsql") {
+ db_query("DELETE FROM ttrss_counters_cache AS c1 WHERE
+ (SELECT count(*) FROM ttrss_counters_cache AS c2
+ WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
+ AND owner_uid = '$owner_uid'");
+
+ db_query("DELETE FROM ttrss_cat_counters_cache AS c1 WHERE
+ (SELECT count(*) FROM ttrss_cat_counters_cache AS c2
+ WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
+ AND owner_uid = '$owner_uid'");
+ } else {
+ db_query("DELETE c1 FROM
+ ttrss_counters_cache AS c1,
+ ttrss_counters_cache AS c2
+ WHERE
+ c1.owner_uid = '$owner_uid' AND
+ c1.owner_uid = c2.owner_uid AND
+ c1.feed_id = c2.feed_id");
+
+ db_query("DELETE c1 FROM
+ ttrss_cat_counters_cache AS c1,
+ ttrss_cat_counters_cache AS c2
+ WHERE
+ c1.owner_uid = '$owner_uid' AND
+ c1.owner_uid = c2.owner_uid AND
+ c1.feed_id = c2.feed_id");
+
+ }
+ } */
+
+
+}
\ No newline at end of file
function catchupAll() {
$this->dbh->query("UPDATE ttrss_user_entries SET
last_read = NOW(), unread = false WHERE unread = true AND owner_uid = " . $_SESSION["uid"]);
- ccache_zero_all($_SESSION["uid"]);
+ CCache::zero_all($_SESSION["uid"]);
}
function view() {
* so for performance reasons we don't do that here */
if ($feed >= 0) {
- ccache_update($feed, $_SESSION["uid"], $cat_view);
+ CCache::update($feed, $_SESSION["uid"], $cat_view);
}
set_pref("_DEFAULT_VIEW_MODE", $view_mode);
}
- ccache_update($feed, $owner_uid, $cat_view);
+ CCache::update($feed, $owner_uid, $cat_view);
} else { // tag
db_query("UPDATE ttrss_user_entries
if ($line['note']) $article['note'] = $line['note'];
if ($article['author']) $article['author'] = $line['author'];
- $tags = get_article_tags($line["id"], $owner_uid);
+ $tags = Article::get_article_tags($line["id"], $owner_uid);
if (count($tags) > 0) {
$article['tags'] = array();
while ($line = $this->dbh->fetch_assoc($result)) {
- $tags = get_article_tags($line["ref_id"]);
+ $tags = Article::get_article_tags($line["ref_id"]);
$article_filters = get_article_filters($filters, $line['title'],
$line['content'], $line['link'], strtotime($line['updated']),
while ($line = $this->dbh->fetch_assoc($tmp_result)) {
- $tags = get_article_tags($line["ref_id"]);
+ $tags = Article::get_article_tags($line["ref_id"]);
$article_filters = get_article_filters($filters, $line['title'],
$line['content'], $line['link'], strtotime($line['updated']),
$cat_id = (int) $cat_id;
if ($cat_id > 0) {
- $cat_unread = ccache_find($cat_id, $_SESSION["uid"], true);
+ $cat_unread = CCache::find($cat_id, $_SESSION["uid"], true);
} else if ($cat_id == 0 || $cat_id == -2) {
$cat_unread = Feeds::getCategoryUnread($cat_id);
}
$result = $this->dbh->query("DELETE FROM ttrss_entries WHERE
(SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");
- ccache_update($id, $_SESSION['uid']);
+ CCache::update($id, $_SESSION['uid']);
} // function clear_feed_articles
private function remove_feed_category($id, $owner_uid) {
$this->dbh->query("DELETE FROM ttrss_feed_categories
WHERE id = '$id' AND owner_uid = $owner_uid");
- ccache_remove($id, $owner_uid, true);
+ CCache::remove($id, $owner_uid, true);
}
static function remove_feed($id, $owner_uid) {
unlink(ICONS_DIR . "/$id.ico");
}
- ccache_remove($id, $owner_uid);
+ CCache::remove($id, $owner_uid);
} else {
label_remove(feed_to_label_id($id), $owner_uid);
- //ccache_remove($id, $owner_uid); don't think labels are cached
+ //CCache::remove($id, $owner_uid); don't think labels are cached
}
}
+++ /dev/null
-<?php
- /* function ccache_zero($feed_id, $owner_uid) {
- db_query("UPDATE ttrss_counters_cache SET
- value = 0, updated = NOW() WHERE
- feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
- } */
-
- function ccache_zero_all($owner_uid) {
- db_query("UPDATE ttrss_counters_cache SET
- value = 0 WHERE owner_uid = '$owner_uid'");
-
- db_query("UPDATE ttrss_cat_counters_cache SET
- value = 0 WHERE owner_uid = '$owner_uid'");
- }
-
- function ccache_remove($feed_id, $owner_uid, $is_cat = false) {
-
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- } else {
- $table = "ttrss_cat_counters_cache";
- }
-
- db_query("DELETE FROM $table WHERE
- feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
-
- }
-
- function ccache_update_all($owner_uid) {
-
- if (get_pref('ENABLE_FEED_CATS', $owner_uid)) {
-
- $result = db_query("SELECT feed_id FROM ttrss_cat_counters_cache
- WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
-
- while ($line = db_fetch_assoc($result)) {
- ccache_update($line["feed_id"], $owner_uid, true);
- }
-
- /* We have to manually include category 0 */
-
- ccache_update(0, $owner_uid, true);
-
- } else {
- $result = db_query("SELECT feed_id FROM ttrss_counters_cache
- WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
-
- while ($line = db_fetch_assoc($result)) {
- print ccache_update($line["feed_id"], $owner_uid);
-
- }
-
- }
- }
-
- function ccache_find($feed_id, $owner_uid, $is_cat = false,
- $no_update = false) {
-
- if (!is_numeric($feed_id)) return;
-
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- /* if ($feed_id > 0) {
- $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
- WHERE id = '$feed_id'");
- $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
- } */
- } else {
- $table = "ttrss_cat_counters_cache";
- }
-
- if (DB_TYPE == "pgsql") {
- $date_qpart = "updated > NOW() - INTERVAL '15 minutes'";
- } else if (DB_TYPE == "mysql") {
- $date_qpart = "updated > DATE_SUB(NOW(), INTERVAL 15 MINUTE)";
- }
-
- $result = db_query("SELECT value FROM $table
- WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id'
- LIMIT 1");
-
- if (db_num_rows($result) == 1) {
- return db_fetch_result($result, 0, "value");
- } else {
- if ($no_update) {
- return -1;
- } else {
- return ccache_update($feed_id, $owner_uid, $is_cat);
- }
- }
-
- }
-
- function ccache_update($feed_id, $owner_uid, $is_cat = false,
- $update_pcat = true, $pcat_fast = false) {
-
- if (!is_numeric($feed_id)) return;
-
- /* if (!$is_cat && $feed_id > 0) {
- $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
- WHERE id = '$feed_id'");
- $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
- } */
-
- $prev_unread = ccache_find($feed_id, $owner_uid, $is_cat, true);
-
- /* When updating a label, all we need to do is recalculate feed counters
- * because labels are not cached */
-
- if ($feed_id < 0) {
- ccache_update_all($owner_uid);
- return;
- }
-
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- } else {
- $table = "ttrss_cat_counters_cache";
- }
-
- if ($is_cat && $feed_id >= 0) {
- if ($feed_id != 0) {
- $cat_qpart = "cat_id = '$feed_id'";
- } else {
- $cat_qpart = "cat_id IS NULL";
- }
-
- /* Recalculate counters for child feeds */
-
- if (!$pcat_fast) {
- $result = db_query("SELECT id FROM ttrss_feeds
- WHERE owner_uid = '$owner_uid' AND $cat_qpart");
-
- while ($line = db_fetch_assoc($result)) {
- ccache_update($line["id"], $owner_uid, false, false);
- }
- }
-
- $result = db_query("SELECT SUM(value) AS sv
- FROM ttrss_counters_cache, ttrss_feeds
- WHERE id = feed_id AND $cat_qpart AND
- ttrss_counters_cache.owner_uid = $owner_uid AND
- ttrss_feeds.owner_uid = '$owner_uid'");
-
- $unread = (int) db_fetch_result($result, 0, "sv");
-
- } else {
- $unread = (int) Feeds::getFeedArticles($feed_id, $is_cat, true, $owner_uid);
- }
-
- db_query("BEGIN");
-
- $result = db_query("SELECT feed_id FROM $table
- WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id' LIMIT 1");
-
- if (db_num_rows($result) == 1) {
- db_query("UPDATE $table SET
- value = '$unread', updated = NOW() WHERE
- feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
-
- } else {
- db_query("INSERT INTO $table
- (feed_id, value, owner_uid, updated)
- VALUES
- ($feed_id, $unread, $owner_uid, NOW())");
- }
-
- db_query("COMMIT");
-
- if ($feed_id > 0 && $prev_unread != $unread) {
-
- if (!$is_cat) {
-
- /* Update parent category */
-
- if ($update_pcat) {
-
- $result = db_query("SELECT cat_id FROM ttrss_feeds
- WHERE owner_uid = '$owner_uid' AND id = '$feed_id'");
-
- $cat_id = (int) db_fetch_result($result, 0, "cat_id");
-
- ccache_update($cat_id, $owner_uid, true, true, true);
-
- }
- }
- } else if ($feed_id < 0) {
- ccache_update_all($owner_uid);
- }
-
- return $unread;
- }
-
- /* function ccache_cleanup($owner_uid) {
-
- if (DB_TYPE == "pgsql") {
- db_query("DELETE FROM ttrss_counters_cache AS c1 WHERE
- (SELECT count(*) FROM ttrss_counters_cache AS c2
- WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
- AND owner_uid = '$owner_uid'");
-
- db_query("DELETE FROM ttrss_cat_counters_cache AS c1 WHERE
- (SELECT count(*) FROM ttrss_cat_counters_cache AS c2
- WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
- AND owner_uid = '$owner_uid'");
- } else {
- db_query("DELETE c1 FROM
- ttrss_counters_cache AS c1,
- ttrss_counters_cache AS c2
- WHERE
- c1.owner_uid = '$owner_uid' AND
- c1.owner_uid = c2.owner_uid AND
- c1.feed_id = c2.feed_id");
-
- db_query("DELETE c1 FROM
- ttrss_cat_counters_cache AS c1,
- ttrss_cat_counters_cache AS c2
- WHERE
- c1.owner_uid = '$owner_uid' AND
- c1.owner_uid = c2.owner_uid AND
- c1.feed_id = c2.feed_id");
-
- }
- } */
-
require_once 'db-prefs.php';
require_once 'version.php';
- require_once 'ccache.php';
require_once 'labels.php';
require_once 'controls.php';
if ($purge_interval == -1 || !$purge_interval) {
if ($owner_uid) {
- ccache_update($feed_id, $owner_uid);
+ CCache::update($feed_id, $owner_uid);
}
return;
}
$rows = db_affected_rows($result);
- ccache_update($feed_id, $owner_uid);
+ CCache::update($feed_id, $owner_uid);
if ($debug) {
_debug("Purged feed $feed_id ($purge_interval): deleted $rows articles");
/* Special case: NULL category doesn't actually exist in the DB */
$cv = array("id" => 0, "kind" => "cat",
- "counter" => (int) ccache_find(0, $_SESSION["uid"], true));
+ "counter" => (int) CCache::find(0, $_SESSION["uid"], true));
array_push($ret_arr, $cv);
$article_labels = get_article_labels($base_entry_id, $owner_uid);
$entry_language = db_fetch_result($result, 0, "lang");
- $existing_tags = get_article_tags($base_entry_id, $owner_uid);
+ $existing_tags = Article::get_article_tags($base_entry_id, $owner_uid);
$entry_tags = array_unique(array_merge($entry_tags, $existing_tags));
} else {
projects / tt-rss.git / commitdiff