include/ccache.php

   1 <?php
   2         /* function ccache_zero($feed_id, $owner_uid) {
   3                 db_query("UPDATE ttrss_counters_cache SET
   4                         value = 0, updated = NOW() WHERE
   5                         feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
   6         } */
   7
   8         function ccache_zero_all($owner_uid) {
   9                 db_query("UPDATE ttrss_counters_cache SET
  10                         value = 0 WHERE owner_uid = '$owner_uid'");
  11
  12                 db_query("UPDATE ttrss_cat_counters_cache SET
  13                         value = 0 WHERE owner_uid = '$owner_uid'");
  14         }
  15
  16         function ccache_remove($feed_id, $owner_uid, $is_cat = false) {
  17
  18                 if (!$is_cat) {
  19                         $table = "ttrss_counters_cache";
  20                 } else {
  21                         $table = "ttrss_cat_counters_cache";
  22                 }
  23
  24                 db_query("DELETE FROM $table WHERE
  25                         feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
  26
  27         }
  28
  29         function ccache_update_all($owner_uid) {
  30
  31                 if (get_pref('ENABLE_FEED_CATS', $owner_uid)) {
  32
  33                         $result = db_query("SELECT feed_id FROM ttrss_cat_counters_cache
  34                                 WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
  35
  36                         while ($line = db_fetch_assoc($result)) {
  37                                 ccache_update($line["feed_id"], $owner_uid, true);
  38                         }
  39
  40                         /* We have to manually include category 0 */
  41
  42                         ccache_update(0, $owner_uid, true);
  43
  44                 } else {
  45                         $result = db_query("SELECT feed_id FROM ttrss_counters_cache
  46                                 WHERE feed_id > 0 AND owner_uid = '$owner_uid'");
  47
  48                         while ($line = db_fetch_assoc($result)) {
  49                                 print ccache_update($line["feed_id"], $owner_uid);
  50
  51                         }
  52
  53                 }
  54         }
  55
  56         function ccache_find($feed_id, $owner_uid, $is_cat = false,
  57                 $no_update = false) {
  58
  59                 if (!is_numeric($feed_id)) return;
  60
  61                 if (!$is_cat) {
  62                         $table = "ttrss_counters_cache";
  63                         /* if ($feed_id > 0) {
  64                                 $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
  65                                         WHERE id = '$feed_id'");
  66                                 $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
  67                         } */
  68                 } else {
  69                         $table = "ttrss_cat_counters_cache";
  70                 }
  71
  72                 if (DB_TYPE == "pgsql") {
  73                         $date_qpart = "updated > NOW() - INTERVAL '15 minutes'";
  74                 } else if (DB_TYPE == "mysql") {
  75                         $date_qpart = "updated > DATE_SUB(NOW(), INTERVAL 15 MINUTE)";
  76                 }
  77
  78                 $result = db_query("SELECT value FROM $table
  79                         WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id'
  80                         LIMIT 1");
  81
  82                 if (db_num_rows($result) == 1) {
  83                         return db_fetch_result($result, 0, "value");
  84                 } else {
  85                         if ($no_update) {
  86                                 return -1;
  87                         } else {
  88                                 return ccache_update($feed_id, $owner_uid, $is_cat);
  89                         }
  90                 }
  91
  92         }
  93
  94         function ccache_update($feed_id, $owner_uid, $is_cat = false,
  95                 $update_pcat = true, $pcat_fast = false) {
  96
  97                 if (!is_numeric($feed_id)) return;
  98
  99                 /* if (!$is_cat && $feed_id > 0) {
 100                         $tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
 101                                 WHERE id = '$feed_id'");
 102                         $owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
 103                 } */
 104
 105                 $prev_unread = ccache_find($feed_id, $owner_uid, $is_cat, true);
 106
 107                 /* When updating a label, all we need to do is recalculate feed counters
 108                  * because labels are not cached */
 109
 110                 if ($feed_id < 0) {
 111                         ccache_update_all($owner_uid);
 112                         return;
 113                 }
 114
 115                 if (!$is_cat) {
 116                         $table = "ttrss_counters_cache";
 117                 } else {
 118                         $table = "ttrss_cat_counters_cache";
 119                 }
 120
 121                 if ($is_cat && $feed_id >= 0) {
 122                         if ($feed_id != 0) {
 123                                 $cat_qpart = "cat_id = '$feed_id'";
 124                         } else {
 125                                 $cat_qpart = "cat_id IS NULL";
 126                         }
 127
 128                         /* Recalculate counters for child feeds */
 129
 130                         if (!$pcat_fast) {
 131                                 $result = db_query("SELECT id FROM ttrss_feeds
 132                                                 WHERE owner_uid = '$owner_uid' AND $cat_qpart");
 133
 134                                 while ($line = db_fetch_assoc($result)) {
 135                                         ccache_update($line["id"], $owner_uid, false, false);
 136                                 }
 137                         }
 138
 139                         $result = db_query("SELECT SUM(value) AS sv
 140                                 FROM ttrss_counters_cache, ttrss_feeds
 141                                 WHERE id = feed_id AND $cat_qpart AND
 142                                 ttrss_counters_cache.owner_uid = $owner_uid AND
 143                                 ttrss_feeds.owner_uid = '$owner_uid'");
 144
 145                         $unread = (int) db_fetch_result($result, 0, "sv");
 146
 147                 } else {
 148                         $unread = (int) getFeedArticles($feed_id, $is_cat, true, $owner_uid);
 149                 }
 150
 151                 db_query("BEGIN");
 152
 153                 $result = db_query("SELECT feed_id FROM $table
 154                         WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id' LIMIT 1");
 155
 156                 if (db_num_rows($result) == 1) {
 157                         db_query("UPDATE $table SET
 158                                 value = '$unread', updated = NOW() WHERE
 159                                 feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
 160
 161                 } else {
 162                         db_query("INSERT INTO $table
 163                                 (feed_id, value, owner_uid, updated)
 164                                 VALUES
 165                                 ($feed_id, $unread, $owner_uid, NOW())");
 166                 }
 167
 168                 db_query("COMMIT");
 169
 170                 if ($feed_id > 0 && $prev_unread != $unread) {
 171
 172                         if (!$is_cat) {
 173
 174                                 /* Update parent category */
 175
 176                                 if ($update_pcat) {
 177
 178                                         $result = db_query("SELECT cat_id FROM ttrss_feeds
 179                                                 WHERE owner_uid = '$owner_uid' AND id = '$feed_id'");
 180
 181                                         $cat_id = (int) db_fetch_result($result, 0, "cat_id");
 182
 183                                         ccache_update($cat_id, $owner_uid, true, true, true);
 184
 185                                 }
 186                         }
 187                 } else if ($feed_id < 0) {
 188                         ccache_update_all($owner_uid);
 189                 }
 190
 191                 return $unread;
 192         }
 193
 194         /* function ccache_cleanup($owner_uid) {
 195
 196                 if (DB_TYPE == "pgsql") {
 197                         db_query("DELETE FROM ttrss_counters_cache AS c1 WHERE
 198                                 (SELECT count(*) FROM ttrss_counters_cache AS c2
 199                                         WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
 200                                         AND owner_uid = '$owner_uid'");
 201
 202                         db_query("DELETE FROM ttrss_cat_counters_cache AS c1 WHERE
 203                                 (SELECT count(*) FROM ttrss_cat_counters_cache AS c2
 204                                         WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
 205                                         AND owner_uid = '$owner_uid'");
 206                 } else {
 207                         db_query("DELETE c1 FROM
 208                                         ttrss_counters_cache AS c1,
 209                                         ttrss_counters_cache AS c2
 210                                 WHERE
 211                                         c1.owner_uid = '$owner_uid' AND
 212                                         c1.owner_uid = c2.owner_uid AND
 213                                         c1.feed_id = c2.feed_id");
 214
 215                         db_query("DELETE c1 FROM
 216                                         ttrss_cat_counters_cache AS c1,
 217                                         ttrss_cat_counters_cache AS c2
 218                                 WHERE
 219                                         c1.owner_uid = '$owner_uid' AND
 220                                         c1.owner_uid = c2.owner_uid AND
 221                                         c1.feed_id = c2.feed_id");
 222
 223                 }
 224         } */
 225