]> git.wh0rd.org - tt-rss.git/blobdiff - functions.php
better fatal error handling by frontend (remove error.php)
[tt-rss.git] / functions.php
index aececd8d9ad8116d6cbfebecc1039fb37cc2d4cf..d4feaf5d686efd8e3d9dec63dd67e8ba1f2ce38f 100644 (file)
@@ -1,37 +1,88 @@
 <?
 
-       if ($_GET["debug"]) {
+/*     if ($_GET["debug"]) {
                define('DEFAULT_ERROR_LEVEL', E_ALL);
        } else {
                define('DEFAULT_ERROR_LEVEL', E_ERROR | E_WARNING | E_PARSE);
-       }
+       } */
 
        require_once 'config.php';
        require_once 'db-prefs.php';
+       require_once 'compat.php';
+       require_once 'errors.php';
 
        require_once 'magpierss/rss_utils.inc';
 
        define('MAGPIE_OUTPUT_ENCODING', 'UTF-8');
 
-       function purge_feed($link, $feed_id, $purge_interval) {
+       function purge_feed($link, $feed_id, $purge_interval, $debug = false) {
+
+               $rows = -1;
 
                if (DB_TYPE == "pgsql") {
-                       db_query($link, "DELETE FROM ttrss_user_entries WHERE
+/*                     $result = db_query($link, "DELETE FROM ttrss_user_entries WHERE
                                marked = false AND feed_id = '$feed_id' AND
                                (SELECT date_entered FROM ttrss_entries WHERE
-                                       id = ref_id) < NOW() - INTERVAL '$purge_interval days'");
+                                       id = ref_id) < NOW() - INTERVAL '$purge_interval days'"); */
+
+                       $pg_version = get_pgsql_version($link);
+
+                       if (preg_match("/^7\./", $pg_version) || preg_match("/^8\.0/", $pg_version)) {
+
+                               $result = db_query($link, "DELETE FROM ttrss_user_entries WHERE 
+                                       ttrss_entries.id = ref_id AND 
+                                       marked = false AND 
+                                       feed_id = '$feed_id' AND 
+                                       ttrss_entries.date_entered < NOW() - INTERVAL '$purge_interval days'");
+
+                       } else {
+
+                               $result = db_query($link, "DELETE FROM ttrss_user_entries 
+                                       USING ttrss_entries 
+                                       WHERE ttrss_entries.id = ref_id AND 
+                                       marked = false AND 
+                                       feed_id = '$feed_id' AND 
+                                       ttrss_entries.date_entered < NOW() - INTERVAL '$purge_interval days'");
+                       }
+
+                       $rows = pg_affected_rows($result);
+                       
                } else {
-                       db_query($link, "DELETE FROM ttrss_user_entries WHERE
+               
+/*                     $result = db_query($link, "DELETE FROM ttrss_user_entries WHERE
                                marked = false AND feed_id = '$feed_id' AND
                                (SELECT date_entered FROM ttrss_entries WHERE 
-                                       id = ref_id) < DATE_SUB(NOW(), INTERVAL $purge_interval DAY)");
+                                       id = ref_id) < DATE_SUB(NOW(), INTERVAL $purge_interval DAY)"); */
+
+                       $result = db_query($link, "DELETE FROM ttrss_user_entries 
+                               USING ttrss_user_entries, ttrss_entries 
+                               WHERE ttrss_entries.id = ref_id AND 
+                               marked = false AND 
+                               feed_id = '$feed_id' AND 
+                               ttrss_entries.date_entered < DATE_SUB(NOW(), INTERVAL $purge_interval DAY)");
+                                       
+                       $rows = mysql_affected_rows($link);
+
+               }
+
+               if ($debug) {
+                       print "Purged feed $feed_id ($purge_interval): deleted $rows articles\n";
                }
        }
 
-       function global_purge_old_posts($link, $do_output = false) {
+       function global_purge_old_posts($link, $do_output = false, $limit = false) {
+
+               $random_qpart = sql_random_function();
 
+               if ($limit) {
+                       $limit_qpart = "LIMIT $limit";
+               } else {
+                       $limit_qpart = "";
+               }
+               
                $result = db_query($link, 
-                       "SELECT id,purge_interval,owner_uid FROM ttrss_feeds");
+                       "SELECT id,purge_interval,owner_uid FROM ttrss_feeds 
+                               ORDER BY $random_qpart $limit_qpart");
 
                while ($line = db_fetch_assoc($result)) {
 
                        }
 
                        if ($do_output) {
-                               print "<feed id='$feed_id' p_intl='$purge_interval'/>";
+//                             print "Feed $feed_id: purge interval = $purge_interval\n";
                        }
 
                        if ($purge_interval > 0) {
-                               purge_feed($link, $feed_id, $purge_interval);
+                               purge_feed($link, $feed_id, $purge_interval, $do_output);
                        }
                }       
 
 
 //             db_query($link, "BEGIN");
 
+               if (MAX_UPDATE_TIME > 0) {
+                       if (DB_TYPE == "mysql") {
+                               $q_order = "RAND()";
+                       } else {
+                               $q_order = "RANDOM()";
+                       }
+               } else {
+                       $q_order = "last_updated DESC";
+               }
+
                $result = db_query($link, "SELECT feed_url,id,
-                       substring(last_updated,1,19) as last_updated,
+                       SUBSTRING(last_updated,1,19) AS last_updated,
                        update_interval FROM ttrss_feeds WHERE owner_uid = '$user_id'
-                       ORDER BY last_updated DESC");
+                       ORDER BY $q_order");
+
+               $upd_start = time();
 
                while ($line = db_fetch_assoc($result)) {
                        $upd_intl = $line["update_interval"];
                                $upd_intl = get_pref($link, 'DEFAULT_UPDATE_INTERVAL', $user_id);
                        }
 
+                       if ($upd_intl < 0) { 
+                               // Updates for this feed are disabled
+                               continue; 
+                       }
+
                        if ($fetch || (!$line["last_updated"] || 
                                time() - strtotime($line["last_updated"]) > ($upd_intl * 60))) {
 
+//                             print "<!-- feed: ".$line["feed_url"]." -->";
+
                                update_rss_feed($link, $line["feed_url"], $line["id"], $force_daemon);
+
+                               $upd_elapsed = time() - $upd_start;
+
+                               if (MAX_UPDATE_TIME > 0 && $upd_elapsed > MAX_UPDATE_TIME) {
+                                       return;
+                               }
                        }
                }
 
                        error_reporting (DEFAULT_ERROR_LEVEL);
 
                        if ($r) {
-                               $tmpfname = tempnam("/tmp", "ttrssicon");
+                               $tmpfname = tempnam(TMP_DIRECTORY, "ttrssicon");
                        
                                $t = fopen($tmpfname, "w");
                                
 
                if ($rss) {
 
-                       db_query($link, "BEGIN");
+//                     db_query($link, "BEGIN");
 
                        $result = db_query($link, "SELECT title,icon_url,site_url,owner_uid
                                FROM ttrss_feeds WHERE id = '$feed'");
                        $filters = array();
 
                        $result = db_query($link, "SELECT reg_exp,
-                               (SELECT name FROM ttrss_filter_types
-                                       WHERE id = filter_type) as name,
-                               (SELECT name FROM ttrss_filter_actions
-                                       WHERE id = action_id) as action
-                               FROM ttrss_filters WHERE 
-                               owner_uid = $owner_uid AND
+                               ttrss_filter_types.name AS name,
+                               ttrss_filter_actions.name AS action
+                               FROM ttrss_filters,ttrss_filter_types,ttrss_filter_actions WHERE                                        
+                                       owner_uid = $owner_uid AND
+                                       ttrss_filter_types.id = filter_type AND
+                                       ttrss_filter_actions.id = action_id AND
                                (feed_id IS NULL OR feed_id = '$feed')");
 
                        while ($line = db_fetch_assoc($result)) {
 
                        $iterator = $rss->items;
 
-                       if (!$iterator) $iterator = $rss->entries;
-                       if (!$iterator) $iterator = $rss;                       
+                       if (!$iterator || !is_array($iterator)) $iterator = $rss->entries;
+                       if (!$iterator || !is_array($iterator)) $iterator = $rss;
+
+                       if (!is_array($iterator)) {
+                               db_query($link, "UPDATE ttrss_feeds 
+                                       SET last_error = 'Parse error: can\'t find any articles.'
+                                               WHERE id = '$feed'");
+                               return; // WTF?
+                       }
 
                        foreach ($iterator as $item) {
        
 
                                $entry_comments = $item["comments"];
 
+                               $entry_author = db_escape_string($item['dc']['creator']);
+
                                $entry_guid = db_escape_string($entry_guid);
 
                                $result = db_query($link, "SELECT id FROM       ttrss_entries 
 
                                if (!$num_comments) $num_comments = 0;
 
+                               db_query($link, "BEGIN");
+
                                if (db_num_rows($result) == 0) {
 
                                        // base post entry does not exist, create it
                                                        no_orig_date,
                                                        date_entered,
                                                        comments,
-                                                       num_comments)
+                                                       num_comments,
+                                                       author)
                                                VALUES
                                                        ('$entry_title', 
                                                        '$entry_guid', 
                                                        $no_orig_date, 
                                                        NOW(), 
                                                        '$entry_comments',
-                                                       '$num_comments')");
+                                                       '$num_comments',
+                                                       '$entry_author')");
+                               } else {
+                                       // we keep encountering the entry in feeds, so we need to
+                                       // update date_entered column so that we don't get horrible
+                                       // dupes when the entry gets purged and reinserted again e.g.
+                                       // in the case of SLOW SLOW OMG SLOW updating feeds
+
+                                       $base_entry_id = db_fetch_result($result, 0, "id");
+
+                                       db_query($link, "UPDATE ttrss_entries SET date_entered = NOW()
+                                               WHERE id = '$base_entry_id'");
                                }
 
                                // now it should exist, if not - bad luck then
 
                                $result = db_query($link, "SELECT 
                                                id,content_hash,no_orig_date,title,
+                                               substring(date_entered,1,19) as date_entered,
                                                substring(updated,1,19) as updated,
                                                num_comments
                                        FROM 
                                        $orig_content_hash = db_fetch_result($result, 0, "content_hash");
                                        $orig_title = db_fetch_result($result, 0, "title");
                                        $orig_num_comments = db_fetch_result($result, 0, "num_comments");
+                                       $orig_date_entered = strtotime(db_fetch_result($result, 
+                                               0, "date_entered"));
 
                                        $ref_id = db_fetch_result($result, 0, "id");
 
                                        }
                                }
 
+                               db_query($link, "COMMIT");
+
                                /* taaaags */
                                // <a href="http://technorati.com/tag/Xorg" rel="tag">Xorg</a>, //
 
 
                                if (count($entry_tags) > 0) {
                                
+                                       db_query($link, "BEGIN");
+                       
                                        $result = db_query($link, "SELECT id,int_id 
                                                FROM ttrss_entries,ttrss_user_entries 
                                                WHERE guid = '$entry_guid' 
                                                        }                                                       
                                                }
                                        }
+                                       db_query($link, "COMMIT");
                                } 
                        } 
 
                        db_query($link, "UPDATE ttrss_feeds 
                                SET last_updated = NOW(), last_error = '' WHERE id = '$feed'");
 
-                       db_query($link, "COMMIT");
+//                     db_query($link, "COMMIT");
 
                } else {
                        $error_msg = db_escape_string(magpie_error());
                return false;
        }
 
-       function printFeedEntry($feed_id, $class, $feed_title, $unread, $icon_file, $link) {
+       function printFeedEntry($feed_id, $class, $feed_title, $unread, $icon_file, $link,
+               $rtl_content = false, $last_updated = false, $last_error = false) {
 
                if (file_exists($icon_file) && filesize($icon_file) > 0) {
                                $feed_icon = "<img id=\"FIMG-$feed_id\" src=\"$icon_file\">";
                        $feed_icon = "<img id=\"FIMG-$feed_id\" src=\"images/blank_icon.gif\">";
                }
 
-               $feed = "<a href=\"javascript:viewfeed('$feed_id', 0);\">$feed_title</a>";
+               if ($rtl_content) {
+                       $rtl_tag = "dir=\"rtl\"";
+               } else {
+                       $rtl_tag = "dir=\"ltr\"";
+               }
+
+               if ($last_error) {
+                       $link_title = "Error: $last_error ($last_updated)";
+               } else if ($last_updated) {
+                       $link_title = "Updated: $last_updated";
+               }
+
+               $feed = "<a title=\"$link_title\" id=\"FEEDL-$feed_id\" href=\"javascript:viewfeed('$feed_id', 0);\">$feed_title</a>";
 
                print "<li id=\"FEEDR-$feed_id\" class=\"$class\">";
                if (get_pref($link, 'ENABLE_FEED_ICONS')) {
                        print "$feed_icon";
                }
 
-               print "<span id=\"FEEDN-$feed_id\">$feed</span>";
+               print "<span $rtl_tag id=\"FEEDN-$feed_id\">$feed</span>";
 
                if ($unread != 0) {
                        $fctr_class = "";
                        $fctr_class = "class=\"invisible\"";
                }
 
-               print "<span $fctr_class id=\"FEEDCTR-$feed_id\">
+               print " <span $rtl_tag $fctr_class id=\"FEEDCTR-$feed_id\">
                         (<span id=\"FEEDU-$feed_id\">$unread</span>)</span>";
                
                print "</li>";
                                $sel .= " value=\"0\"";
                        }
                        
-                       print "<input type=\"radio\" $sel $attributes name=\"$id\">&nbsp;$v&nbsp;";
+                       print "<input class=\"noborder\" 
+                               type=\"radio\" $sel $attributes name=\"$id\">&nbsp;$v&nbsp;";
 
                }
        }
                $pwd_hash = 'SHA1:' . sha1($password);
 
                $result = db_query($link, "SELECT id,login,access_level FROM ttrss_users WHERE 
-                       login = '$login' AND ((pwd_hash = '$password' AND '$password' = 'password')
-                               OR pwd_hash = '$pwd_hash')");
+                       login = '$login' AND pwd_hash = '$pwd_hash'");
 
                if (db_num_rows($result) == 1) {
                        $_SESSION["uid"] = db_fetch_result($result, 0, "id");
                        $user_theme = get_user_theme_path($link);
 
                        $_SESSION["theme"] = $user_theme;
+                       $_SESSION["ip_address"] = $_SERVER["REMOTE_ADDR"];
 
                        initialize_user_prefs($link, $_SESSION["uid"]);
 
        function make_password($length = 8) {
 
                $password = "";
-               $possible = "0123456789bcdfghjkmnpqrstvwxyz"; 
-    
-               $i = 0; 
+               $possible = "0123456789abcdfghjkmnpqrstvwxyzABCDFGHJKMNPQRSTVWXYZ"; 
+               
+       $i = 0; 
     
                while ($i < $length) { 
                        $char = substr($possible, mt_rand(0, strlen($possible)-1), 1);
        }
 
        function logout_user() {
-               session_destroy();              
+               session_destroy();
+               if (isset($_COOKIE[session_name()])) {
+                  setcookie(session_name(), '', time()-42000, '/');
+               }
        }
 
        function get_script_urlpath() {
                return $redirect_uri;
        }
 
+       function validate_session($link) {
+               if (SESSION_CHECK_ADDRESS && $_SESSION["uid"]) {
+                       if ($_SESSION["ip_address"]) {
+                               if ($_SESSION["ip_address"] != $_SERVER["REMOTE_ADDR"]) {
+                                       return false;
+                               }
+                       }
+               }
+               return true;
+       }
+
+       function basic_nosid_redirect_check() {
+               if (!SINGLE_USER_MODE) {
+                       if (!$_COOKIE["ttrss_sid"]) {
+                               $redirect_uri = get_login_redirect();
+                               $return_to = preg_replace('/.*?\//', '', $_SERVER["REQUEST_URI"]);
+                               header("Location: $redirect_uri?rt=$return_to");
+                               exit;
+                       }
+               }
+       }
+
        function login_sequence($link) {
                if (!SINGLE_USER_MODE) {
 
+                       if (!validate_session($link)) {
+                               logout_user();
+                               $redirect_uri = get_login_redirect();
+                               $return_to = preg_replace('/.*?\//', '', $_SERVER["REQUEST_URI"]);
+                               header("Location: $redirect_uri?rt=$return_to");
+                               exit;
+                       }
+
                        if (!USE_HTTP_AUTH) {
                                if (!$_SESSION["uid"]) {
                                        $redirect_uri = get_login_redirect();
        }
 
        function truncate_string($str, $max_len) {
-               if (strlen($str) > $max_len) {
-                       return substr($str, 0, $max_len) . "...";
+               if (mb_strlen($str, "utf-8") > $max_len - 3) {
+                       return mb_substr($str, 0, $max_len, "utf-8") . "...";
                } else {
                        return $str;
                }
        }
 
        function get_user_theme_path($link) {
-               $result = db_query($link, "SELECT theme_path FROM ttrss_themes
-                       WHERE id = (SELECT theme_id FROM ttrss_users 
-                               WHERE id = " . $_SESSION["uid"] . ")");
+               $result = db_query($link, "SELECT theme_path 
+                       FROM 
+                               ttrss_themes,ttrss_users
+                       WHERE ttrss_themes.id = theme_id AND ttrss_users.id = " . $_SESSION["uid"]);
                if (db_num_rows($result) != 0) {
                        return db_fetch_result($result, 0, "theme_path");
                } else {
                } else if (date("Y", $timestamp) == date("Y")) {
                        return date("M d, G:i", $timestamp);
                } else {
-                       return date("Y/m/d G:i");
+                       return date("Y/m/d G:i", $timestamp);
                }
        }
 
                } else if (date("Y", $timestamp) == date("Y")) {
                        return date("D m", $timestamp);
                } else {
-                       return date("Y/m/d");
+                       return date("Y/m/d", $timestamp);
                }
        }
 
                        return "false";
                }
        }
+
+       function sql_bool_to_bool($s) {
+               if ($s == "t" || $s == "1") {
+                       return true;
+               } else {
+                       return false;
+               }
+       }
        
+
        function toggleEvenOdd($a) {
                if ($a == "even") 
                        return "odd";
                } 
        }
 
+       function file_is_locked($filename) {
+               error_reporting(0);
+               $fp = fopen($filename, "r");
+               error_reporting(DEFAULT_ERROR_LEVEL);
+               if ($fp) {
+                       if (flock($fp, LOCK_EX | LOCK_NB)) {
+                               flock($fp, LOCK_UN);
+                               fclose($fp);
+                               return false;
+                       }
+                       fclose($fp);
+                       return true;
+               }
+               return false;
+       }
+
+       function make_lockfile($filename) {
+               $fp = fopen($filename, "w");
+
+               if (flock($fp, LOCK_EX | LOCK_NB)) {            
+                       return $fp;
+               } else {
+                       return false;
+               }
+       }
+
+       function sql_random_function() {
+               if (DB_TYPE == "mysql") {
+                       return "RAND()";
+               } else {
+                       return "RANDOM()";
+               }
+       }
+
+       function catchup_feed($link, $feed, $cat_view) {
+                       if (preg_match("/^[0-9][0-9]*$/", $feed) != false && $feed >= 0) {
+                       
+                               if ($cat_view) {
+
+                                       if ($feed > 0) {
+                                               $cat_qpart = "cat_id = '$feed'";
+                                       } else {
+                                               $cat_qpart = "cat_id IS NULL";
+                                       }
+                                       
+                                       $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)) {
+
+                                               $tmp_feed = $tmp_line["id"];
+
+                                               db_query($link, "UPDATE ttrss_user_entries 
+                                                       SET unread = false,last_read = NOW() 
+                                                       WHERE feed_id = '$tmp_feed' AND owner_uid = " . $_SESSION["uid"]);
+                                       }
+
+                               } else if ($feed > 0) {
+
+                                       $tmp_result = db_query($link, "SELECT id 
+                                               FROM ttrss_feeds WHERE parent_feed = '$feed'
+                                               ORDER BY cat_id,title");
+
+                                       $parent_ids = array();
+
+                                       if (db_num_rows($tmp_result) > 0) {
+                                               while ($p = db_fetch_assoc($tmp_result)) {
+                                                       array_push($parent_ids, "feed_id = " . $p["id"]);
+                                               }
+
+                                               $children_qpart = implode(" OR ", $parent_ids);
+                                               
+                                               db_query($link, "UPDATE ttrss_user_entries 
+                                                       SET unread = false,last_read = NOW() 
+                                                       WHERE (feed_id = '$feed' OR $children_qpart) 
+                                                       AND owner_uid = " . $_SESSION["uid"]);
+
+                                       } else {                                                
+                                               db_query($link, "UPDATE ttrss_user_entries 
+                                                       SET unread = false,last_read = NOW() 
+                                                       WHERE feed_id = '$feed' AND owner_uid = " . $_SESSION["uid"]);
+                                       }
+                                               
+                               } else if ($feed < 0 && $feed > -10) { // special, like starred
+
+                                       if ($feed == -1) {
+                                               db_query($link, "UPDATE ttrss_user_entries 
+                                                       SET unread = false,last_read = NOW()
+                                                       WHERE marked = true AND owner_uid = ".$_SESSION["uid"]);
+                                       }
+                       
+                               } else if ($feed < -10) { // label
+
+                                       // TODO make this more efficient
+
+                                       $label_id = -$feed - 11;
+
+                                       $tmp_result = db_query($link, "SELECT sql_exp FROM ttrss_labels
+                                               WHERE id = '$label_id'");                                       
+
+                                       if ($tmp_result) {
+                                               $sql_exp = db_fetch_result($tmp_result, 0, "sql_exp");
+
+                                               db_query($link, "BEGIN");
+
+                                               $tmp2_result = db_query($link,
+                                                       "SELECT 
+                                                               int_id 
+                                                       FROM 
+                                                               ttrss_user_entries,ttrss_entries 
+                                                       WHERE
+                                                               ref_id = id AND 
+                                                               $sql_exp AND
+                                                               owner_uid = " . $_SESSION["uid"]);
+
+                                               while ($tmp_line = db_fetch_assoc($tmp2_result)) {
+                                                       db_query($link, "UPDATE 
+                                                               ttrss_user_entries 
+                                                       SET 
+                                                               unread = false, last_read = NOW()
+                                                       WHERE
+                                                               int_id = " . $tmp_line["int_id"]);
+                                               }
+                                                               
+                                               db_query($link, "COMMIT");
+
+/*                                             db_query($link, "UPDATE ttrss_user_entries,ttrss_entries 
+                                                       SET unread = false,last_read = NOW()
+                                                       WHERE $sql_exp
+                                                       AND ref_id = id
+                                                       AND owner_uid = ".$_SESSION["uid"]); */
+                                       }
+                               }
+                       } else { // tag
+                               db_query($link, "BEGIN");
+
+                               $tag_name = db_escape_string($feed);
+
+                               $result = db_query($link, "SELECT post_int_id FROM ttrss_tags
+                                       WHERE tag_name = '$tag_name' AND owner_uid = " . $_SESSION["uid"]);
+
+                               while ($line = db_fetch_assoc($result)) {
+                                       db_query($link, "UPDATE ttrss_user_entries SET
+                                               unread = false, last_read = NOW() 
+                                               WHERE int_id = " . $line["post_int_id"]);
+                               }
+                               db_query($link, "COMMIT");
+                       }
+       }
+
+       function update_generic_feed($link, $feed, $cat_view) {
+                       if ($cat_view) {
+
+                               if ($feed > 0) {
+                                       $cat_qpart = "cat_id = '$feed'";
+                               } else {
+                                       $cat_qpart = "cat_id IS NULL";
+                               }
+                               
+                               $tmp_result = db_query($link, "SELECT feed_url 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"];
+                                       update_rss_feed($link, $feed_url, $feed, ENABLE_UPDATE_DAEMON);
+                               }
+
+                       } 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, ENABLE_UPDATE_DAEMON);
+                       }
+       }
+
+       function getAllCounters($link) {
+               getLabelCounters($link);
+               getFeedCounters($link);
+               getTagCounters($link);
+               getGlobalCounters($link);
+               if (get_pref($link, 'ENABLE_FEED_CATS')) {
+                       getCategoryCounters($link);
+               }
+       }       
+
+       function getCategoryCounters($link) {
+               $result = db_query($link, "SELECT cat_id,SUM((SELECT COUNT(int_id) 
+                               FROM ttrss_user_entries WHERE feed_id = ttrss_feeds.id 
+                                       AND unread = true)) AS unread FROM ttrss_feeds 
+                       WHERE 
+                               owner_uid = ".$_SESSION["uid"]." GROUP BY cat_id");
+
+               while ($line = db_fetch_assoc($result)) {
+                       $line["cat_id"] = sprintf("%d", $line["cat_id"]);
+                       print "<counter type=\"category\" id=\"".$line["cat_id"]."\" counter=\"".
+                               $line["unread"]."\"/>";
+               }
+       }
+
+       function getFeedUnread($link, $feed) {
+               $n_feed = sprintf("%d", $feed);
+       
+               if ($n_feed == -1) {
+                       $match_part = "marked = true";
+               } else if ($feed > 0) {
+                       $match_part = "feed_id = '$n_feed'";
+               } else if ($feed < -10) {
+                       $label_id = -$feed - 11;
+
+                       $result = db_query($link, "SELECT sql_exp FROM ttrss_labels WHERE
+                               id = '$label_id' AND owner_uid = " . $_SESSION["uid"]);
+
+                       $match_part = db_fetch_result($result, 0, "sql_exp");
+               }
+
+               if ($match_part) {
+               
+                       $result = db_query($link, "SELECT count(int_id) AS unread 
+                               FROM ttrss_user_entries 
+                               WHERE   unread = true AND $match_part AND owner_uid = " . $_SESSION["uid"]);
+                               
+               } else {
+               
+                       $result = db_query($link, "SELECT COUNT(post_int_id) AS unread
+                               FROM ttrss_tags,ttrss_user_entries 
+                               WHERE tag_name = '$feed' AND post_int_id = int_id AND unread = true AND
+                                       ttrss_tags.owner_uid = " . $_SESSION["uid"]);
+               }
+               
+               $unread = db_fetch_result($result, 0, "unread");
+               return $unread;
+       }
+
+       /* FIXME this needs reworking */
+
+       function getGlobalUnread($link) {
+               $result = db_query($link, "SELECT count(id) as c_id FROM ttrss_entries,ttrss_user_entries
+                       WHERE unread = true AND 
+                       ttrss_user_entries.ref_id = ttrss_entries.id AND 
+                       owner_uid = " . $_SESSION["uid"]);
+               $c_id = db_fetch_result($result, 0, "c_id");
+               return $c_id;
+       }
+
+       function getGlobalCounters($link, $global_unread = -1) {
+               if ($global_unread == -1) {     
+                       $global_unread = getGlobalUnread($link);
+               }
+               print "<counter type=\"global\" id='global-unread' counter='$global_unread'/>";
+       }
+
+       function getTagCounters($link, $smart_mode = SMART_RPC_COUNTERS) {
+
+               if ($smart_mode) {
+                       if (!$_SESSION["tctr_last_value"]) {
+                               $_SESSION["tctr_last_value"] = array();
+                       }
+               }
+
+               $old_counters = $_SESSION["tctr_last_value"];
+
+               $tctrs_modified = false;
+
+/*             $result = db_query($link, "SELECT tag_name,count(ttrss_entries.id) AS count
+                       FROM ttrss_tags,ttrss_entries,ttrss_user_entries WHERE
+                       ttrss_user_entries.ref_id = ttrss_entries.id AND 
+                       ttrss_tags.owner_uid = ".$_SESSION["uid"]." AND
+                       post_int_id = ttrss_user_entries.int_id AND unread = true GROUP BY tag_name 
+               UNION
+                       select tag_name,0 as count FROM ttrss_tags
+                       WHERE ttrss_tags.owner_uid = ".$_SESSION["uid"]); */
+
+               $result = db_query($link, "SELECT tag_name,SUM((SELECT COUNT(int_id) 
+                       FROM ttrss_user_entries WHERE int_id = post_int_id 
+                               AND unread = true)) AS count FROM ttrss_tags 
+                       WHERE owner_uid = 2 GROUP BY tag_name ORDER BY tag_name");
+                       
+               $tags = array();
+
+               while ($line = db_fetch_assoc($result)) {
+                       $tags[$line["tag_name"]] += $line["count"];
+               }
+
+               foreach (array_keys($tags) as $tag) {
+                       $unread = $tags[$tag];                  
+
+                       $tag = htmlspecialchars($tag);
+
+                       if (!$smart_mode || $old_counters[$tag] != $unread) {                   
+                               $old_counters[$tag] = $unread;
+                               $tctrs_modified = true;
+                               print "<counter type=\"tag\" id=\"$tag\" counter=\"$unread\"/>";
+                       }
+
+               } 
+
+               if ($smart_mode && $tctrs_modified) {
+                       $_SESSION["tctr_last_value"] = $old_counters;
+               }
+
+       }
+
+       function getLabelCounters($link, $smart_mode = SMART_RPC_COUNTERS) {
+
+               if ($smart_mode) {
+                       if (!$_SESSION["lctr_last_value"]) {
+                               $_SESSION["lctr_last_value"] = array();
+                       }
+               }
+
+               $old_counters = $_SESSION["lctr_last_value"];
+               $lctrs_modified = false;
+
+               $result = db_query($link, "SELECT count(id) as count FROM ttrss_entries,ttrss_user_entries
+                       WHERE marked = true AND ttrss_user_entries.ref_id = ttrss_entries.id AND 
+                       unread = true AND owner_uid = ".$_SESSION["uid"]);
+
+               $count = db_fetch_result($result, 0, "count");
+
+               print "<counter type=\"label\" id=\"-1\" counter=\"$count\"/>";
+
+               $result = db_query($link, "SELECT owner_uid,id,sql_exp,description FROM
+                       ttrss_labels WHERE owner_uid = ".$_SESSION["uid"]." ORDER by description");
+       
+               while ($line = db_fetch_assoc($result)) {
+
+                       $id = -$line["id"] - 11;
+
+                       error_reporting (0);
+
+                       $tmp_result = db_query($link, "SELECT count(id) as count FROM ttrss_user_entries,ttrss_entries
+                               WHERE (" . $line["sql_exp"] . ") AND unread = true AND 
+                               ttrss_user_entries.ref_id = ttrss_entries.id AND 
+                               owner_uid = ".$_SESSION["uid"]);
+
+                       $count = db_fetch_result($tmp_result, 0, "count");
+
+                       if (!$smart_mode || $old_counters[$id] != $count) {     
+                               $old_counters[$id] = $count;
+                               $lctrs_modified = true;
+                               print "<counter type=\"label\" id=\"$id\" counter=\"$count\"/>";
+                       }
+
+                       error_reporting (DEFAULT_ERROR_LEVEL);
+               }
+
+               if ($smart_mode && $lctrs_modified) {
+                       $_SESSION["lctr_last_value"] = $old_counters;
+               }
+       }
+
+/*     function getFeedCounter($link, $id) {
+       
+               $result = db_query($link, "SELECT 
+                               count(id) as count,last_error
+                       FROM ttrss_entries,ttrss_user_entries,ttrss_feeds
+                       WHERE feed_id = '$id' AND unread = true
+                       AND ttrss_user_entries.feed_id = ttrss_feeds.id
+                       AND ttrss_user_entries.ref_id = ttrss_entries.id");
+       
+                       $count = db_fetch_result($result, 0, "count");
+                       $last_error = htmlspecialchars(db_fetch_result($result, 0, "last_error"));
+                       
+                       print "<counter type=\"feed\" id=\"$id\" counter=\"$count\" error=\"$last_error\"/>";           
+       } */
+
+       function getFeedCounters($link, $smart_mode = SMART_RPC_COUNTERS) {
+
+               if ($smart_mode) {
+                       if (!$_SESSION["fctr_last_value"]) {
+                               $_SESSION["fctr_last_value"] = array();
+                       }
+               }
+
+               $old_counters = $_SESSION["fctr_last_value"];
+
+               $result = db_query($link, "SELECT id,last_error,parent_feed,
+                       SUBSTRING(last_updated,1,19) AS last_updated,
+                       (SELECT count(id) 
+                               FROM ttrss_entries,ttrss_user_entries 
+                               WHERE feed_id = ttrss_feeds.id AND 
+                                       ttrss_user_entries.ref_id = ttrss_entries.id
+                               AND unread = true AND owner_uid = ".$_SESSION["uid"].") as count
+                       FROM ttrss_feeds WHERE owner_uid = ".$_SESSION["uid"] . "
+                               AND parent_feed IS NULL");
+
+               $fctrs_modified = false;
+
+               $short_date = get_pref($link, 'SHORT_DATE_FORMAT');
+
+               while ($line = db_fetch_assoc($result)) {
+               
+                       $id = $line["id"];
+                       $count = $line["count"];
+                       $last_error = htmlspecialchars($line["last_error"]);
+
+                       if (get_pref($link, 'HEADLINES_SMART_DATE')) {
+                               $last_updated = smart_date_time(strtotime($line["last_updated"]));
+                       } else {
+                               $last_updated = date($short_date, strtotime($line["last_updated"]));
+                       }                               
+
+                       $has_img = is_file(ICONS_DIR . "/$id.ico");
+
+                       $tmp_result = db_query($link,
+                               "SELECT id,COUNT(unread) AS unread
+                               FROM ttrss_feeds LEFT JOIN ttrss_user_entries 
+                                       ON (ttrss_feeds.id = ttrss_user_entries.feed_id) 
+                               WHERE parent_feed = '$id' AND unread = true GROUP BY ttrss_feeds.id");
+                       
+                       if (db_num_rows($tmp_result) > 0) {                             
+                               while ($l = db_fetch_assoc($tmp_result)) {
+                                       $count += $l["unread"];
+                               }
+                       }
+
+                       if (!$smart_mode || $old_counters[$id] != $count) {
+                               $old_counters[$id] = $count;
+                               $fctrs_modified = true;
+
+                               if ($last_error) {
+                                       $error_part = "error=\"$last_error\"";
+                               } else {
+                                       $error_part = "";
+                               }
+
+                               if ($has_img) {
+                                       $has_img_part = "hi=\"$has_img\"";
+                               } else {
+                                       $has_img_part = "";
+                               }                               
+
+                               print "<counter type=\"feed\" id=\"$id\" counter=\"$count\" $has_img_part $error_part updated=\"$last_updated\"/>";
+                       }
+               }
+
+               if ($smart_mode && $fctrs_modified) {
+                       $_SESSION["fctr_last_value"] = $old_counters;
+               }
+       }
+
+       function get_script_dt_add() {
+               if (strpos(VERSION, "99") === false) {
+                       return VERSION;
+               } else {
+                       return time();
+               }
+       }
+
+       function get_pgsql_version($link) {
+               $result = db_query($link, "SELECT version() AS version");
+               $version = split(" ", db_fetch_result($result, 0, "version"));
+               return $version[1];
+       }
+
+       function print_error_xml($code, $add_msg = "") {
+               global $ERRORS;
+
+               $error_msg = $ERRORS[$code];
+               
+               if ($add_msg) {
+                       $error_msg = "$error_msg; $add_msg";
+               }
+               
+               print "<error error-code=\"$code\" error-msg=\"$error_msg\"/>";
+       }
 ?>