]> git.wh0rd.org - tt-rss.git/blobdiff - functions.php
add multiprocess update daemon
[tt-rss.git] / functions.php
index cf5d421c9ccd074f1a9e00e247256a03388675ca..9bd98795b646009b0126868ee3efd06ecf7218ab 100644 (file)
@@ -13,7 +13,9 @@
                                        "auto"  => "Detect automatically",
                                        "en_US" => "English",
                                        "fr_FR" => "Français",
+                                       "nb_NO" => "Norsk Bokmål",
                                        "ru_RU" => "Русский",
+                                       "pt_BR" => "Portuguese/Brazil",
                                        "zh_CN" => "Simplified Chinese");
 
                return $tr;
@@ -61,6 +63,8 @@
        require_once 'errors.php';
        require_once 'version.php';
 
+       require_once 'phpmailer/class.phpmailer.php';
+
        define('MAGPIE_USER_AGENT_EXT', ' (Tiny Tiny RSS/' . VERSION . ')');
        define('MAGPIE_OUTPUT_ENCODING', 'UTF-8');
 
                require_once 'magpierss/rss_utils.inc';
        }
 
-       include_once "tw/tw-config.php";
-       include_once "tw/tw.php";
-       include_once TW_SETUP . "paranoya.php";
-
-       $tw_parser = new twParser();
-
        function _debug($msg) {
                $ts = strftime("%H:%M:%S", time());
                print "[$ts] $msg\n";
 
        function purge_feed($link, $feed_id, $purge_interval, $debug = false) {
 
+               if (!$purge_interval) $purge_interval = feed_purge_interval($link, $feed_id);
+
                $rows = -1;
 
+               $result = db_query($link, 
+                       "SELECT owner_uid FROM ttrss_feeds WHERE id = '$feed_id'");
+
+               $owner_uid = false;
+
+               if (db_num_rows($result) == 1) {
+                       $owner_uid = db_fetch_result($result, 0, "owner_uid");
+               }
+
+               if (!$owner_uid) return;
+
+               $purge_unread = get_pref($link, "PURGE_UNREAD_ARTICLES",
+                       $owner_uid, false);
+
+               if (!$purge_unread) $query_limit = " unread = false AND ";
+
                if (DB_TYPE == "pgsql") {
 /*                     $result = db_query($link, "DELETE FROM ttrss_user_entries WHERE
                                marked = false AND feed_id = '$feed_id' AND
                                        ttrss_entries.id = ref_id AND 
                                        marked = false AND 
                                        feed_id = '$feed_id' AND 
+                                       $query_limit
                                        ttrss_entries.date_entered < NOW() - INTERVAL '$purge_interval days'");
 
                        } else {
                                        WHERE ttrss_entries.id = ref_id AND 
                                        marked = false AND 
                                        feed_id = '$feed_id' AND 
+                                       $query_limit
                                        ttrss_entries.date_entered < NOW() - INTERVAL '$purge_interval days'");
                        }
 
                                WHERE ttrss_entries.id = ref_id AND 
                                marked = false AND 
                                feed_id = '$feed_id' AND 
+                               $query_limit
                                ttrss_entries.date_entered < DATE_SUB(NOW(), INTERVAL $purge_interval DAY)");
                                        
                        $rows = mysql_affected_rows($link);
 
        }
 
+       function feed_purge_interval($link, $feed_id) {
+
+               $result = db_query($link, "SELECT purge_interval, owner_uid FROM ttrss_feeds 
+                       WHERE id = '$feed_id'");
+
+               if (db_num_rows($result) == 1) {
+                       $purge_interval = db_fetch_result($result, 0, "purge_interval");
+                       $owner_uid = db_fetch_result($result, 0, "owner_uid");
+
+                       if ($purge_interval == 0) $purge_interval = get_pref($link, 
+                               'PURGE_OLD_DAYS', $user_id);
+
+                       return $purge_interval;
+
+               } else {
+                       return -1;
+               }
+       }
+
        function purge_old_posts($link) {
 
                $user_id = $_SESSION["uid"];
 
        function update_rss_feed($link, $feed_url, $feed, $ignore_daemon = false) {
 
-               if (DAEMON_REFRESH_ONLY && !$_GET["daemon"] && !$ignore_daemon) {
+               if (!$_GET["daemon"] && !$ignore_daemon) {
                        return;                 
                }
 
                        _debug("update_rss_feed: start");
                }
 
-               $result = db_query($link, "SELECT update_interval,auth_login,auth_pass,cache_images
-                       FROM ttrss_feeds WHERE id = '$feed'");
+               if (DB_TYPE == "pgsql") {
+                               $updstart_thresh_qpart = "(ttrss_feeds.last_update_started IS NULL OR ttrss_feeds.last_update_started >= NOW() - INTERVAL '120 seconds')";
+                       } else {
+                               $updstart_thresh_qpart = "(ttrss_feeds.last_update_started IS NULL OR ttrss_feeds.last_update_started >= DATE_SUB(NOW(), INTERVAL 120 SECOND))";
+                       }                       
+
+               $result = db_query($link, "SELECT id,update_interval,auth_login,
+                       auth_pass,cache_images
+                       FROM ttrss_feeds WHERE id = '$feed' AND $updstart_thresh_qpart");
+
+               if (db_num_rows($result) == 0) {
+                       if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
+                               _debug("update_rss_feed: feed $feed [$feed_url] NOT FOUND/SKIPPED");
+                       }               
+                       return;
+               }
+
+               db_query($link, "UPDATE ttrss_feeds SET last_update_started = NOW()
+                       WHERE id = '$feed'");
 
                $auth_login = db_fetch_result($result, 0, "auth_login");
                $auth_pass = db_fetch_result($result, 0, "auth_pass");
 
+               if (!ENABLE_SIMPLEPIE) {
+                       $auth_login = urlencode($auth_login);
+                       $auth_pass = urlencode($auth_pass);
+               }
+
                $update_interval = db_fetch_result($result, 0, "update_interval");
                $cache_images = sql_bool_to_bool(db_fetch_result($result, 0, "cache_images"));
 
 
                        $rss = new SimplePie();
                        $rss->set_useragent(SIMPLEPIE_USERAGENT . MAGPIE_USER_AGENT_EXT);
-                       $rss->set_timeout(MAGPIE_FETCH_TIME_OUT);
+//                     $rss->set_timeout(MAGPIE_FETCH_TIME_OUT);
                        $rss->set_feed_url($fetch_url);
                        $rss->set_output_encoding('UTF-8');
 
 
                        foreach ($iterator as $item) {
 
+                               if ($_GET['xdebug']) {
+                                       print_r($item);
+
+                               }
+
                                if (ENABLE_SIMPLEPIE) {
                                        $entry_guid = $item->get_id();
                                        if (!$entry_guid) $entry_guid = $item->get_link();
 
                                        if (!$entry_content) $entry_content = $item["content:encoded"];
                                        if (!$entry_content) $entry_content = $item["content"];
+
+                                       // Magpie bugs are getting ridiculous
+                                       if (trim($entry_content) == "Array") $entry_content = false;
+
                                        if (!$entry_content) $entry_content = $item["atom_content"];
                                        if (!$entry_content) $entry_content = $item["summary"];
                                        if (!$entry_content) $entry_content = $item["description"];
                                        if (is_array($entry_content)) {
                                                $entry_content = $entry_content["encoded"];
                                                if (!$entry_content) $entry_content = $entry_content["escaped"];
-                                       }
+                                       } 
                                }
 
-//                             print_r($item);
-//                             print_r(htmlspecialchars($entry_content));
-//                             print "<br>";
+                               if ($_GET["xdebug"]) {
+                                       print "update_rss_feed: content: ";
+                                       print_r(htmlspecialchars($entry_content));
+                               }
 
                                $entry_content_unescaped = $entry_content;
 
                                if (ENABLE_SIMPLEPIE) {
                                        $entry_comments = strip_tags($item->data["comments"]);
                                        if ($item->get_author()) {
-                                               $entry_author = $item->get_author()->get_name();
+                                               $entry_author_item = $item->get_author();
+                                               $entry_author = $entry_author_item->get_name();                                                 
                                        }
                                } else {
                                        $entry_comments = strip_tags($item["comments"]);
                                if (preg_match('/^[\t\n\r ]*$/', $entry_author)) $entry_author = '';
 
                                $entry_guid = db_escape_string(strip_tags($entry_guid));
+                               $entry_guid = mb_substr($entry_guid, 0, 250);
 
                                $result = db_query($link, "SELECT id FROM       ttrss_entries 
                                        WHERE guid = '$entry_guid'");
 
                                        $additional_tags = array();
                                        $additional_tags_src = $item->get_categories();
-
+                                       
                                        if (is_array($additional_tags_src)) {
                                                foreach ($additional_tags_src as $tobj) {
                                                        array_push($additional_tags, $tobj->get_term());
        
                                        if ($t_ctr == 0) {
                                                $additional_tags = false;
-                                       } else if ($t_ctr == 1) {
+                                       } else if ($t_ctr > 0) {
                                                $additional_tags = array($item['category']);
-                                       } else {
-                                               $additional_tags = array();
+
+                                               if ($item['category@term']) {
+                                                       array_push($additional_tags, $item['category@term']);
+                                               }
+
                                                for ($i = 0; $i <= $t_ctr; $i++ ) {
                                                        if ($item["category#$i"]) {
                                                                array_push($additional_tags, $item["category#$i"]);
                                                        }
+
+                                                       if ($item["category#$i@term"]) {
+                                                               array_push($additional_tags, $item["category#$i@term"]);
+                                                       }
                                                }
                                        }
        
        
                                        $t_ctr = $item['dc']['subject#'];
        
-                                       if ($t_ctr == 1) {
+                                       if ($t_ctr > 0) {
                                                $additional_tags = array($item['dc']['subject']);
-                                       } else if ($t_ctr > 1) {
-                                               $additional_tags = array();
+
                                                for ($i = 0; $i <= $t_ctr; $i++ ) {
                                                        if ($item['dc']["subject#$i"]) {
                                                                array_push($additional_tags, $item['dc']["subject#$i"]);
                                        }
                                }
 
+                               // enclosures
+
+                               $enclosures = array();
+
+                               if (ENABLE_SIMPLEPIE) {
+                                       $encs = $item->get_enclosures();
+
+                                       if (is_array($encs)) {
+                                               foreach ($encs as $e) {
+                                                       $e_item = array(
+                                                               $e->link, $e->type, $e->length);
+       
+                                                       array_push($enclosures, $e_item);
+                                               }
+                                       }
+
+                               } else {
+                                       $e_ctr = $item['enclosure#'];
+
+                                       if ($e_ctr > 0) {
+                                               $e_item = array($item['enclosure@url'],
+                                                       $item['enclosure@type'],
+                                                       $item['enclosure@length']);
+
+                                               array_push($enclosures, $e_item);
+
+                                               for ($i = 0; $i <= $e_ctr; $i++ ) {
+
+                                                       if ($item["enclosure#$i@url"]) {
+                                                               $e_item = array($item["enclosure#$i@url"],
+                                                                       $item["enclosure#$i@type"],
+                                                                       $item["enclosure#$i@length"]);
+                                                               array_push($enclosures, $e_item);
+                                                       }
+                                               }
+                                       }
+
+                               }
+
                                # sanitize content
                                
 //                             $entry_content = sanitize_rss($entry_content);
                                                ttrss_entries 
                                        WHERE guid = '$entry_guid'");
 
+                               $entry_ref_id = 0;
+                               $entry_int_id = 0;
+
                                if (db_num_rows($result) == 1) {
 
                                        if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
                                                0, "date_entered"));
 
                                        $ref_id = db_fetch_result($result, 0, "id");
+                                       $entry_ref_id = $ref_id;
 
                                        // check for user post link to main table
 
 //                                     error_reporting (DEFAULT_ERROR_LEVEL);
 
                                        $result = db_query($link,
-                                               "SELECT ref_id FROM ttrss_user_entries WHERE
+                                               "SELECT ref_id, int_id FROM ttrss_user_entries WHERE
                                                        ref_id = '$ref_id' AND owner_uid = '$owner_uid'
                                                        $dupcheck_qpart");
 
                                                                (ref_id, owner_uid, feed_id, unread, last_read, marked, published) 
                                                        VALUES ('$ref_id', '$owner_uid', '$feed', $unread,
                                                                $last_read_qpart, $marked, $published)");
+
+                                               $result = db_query($link, 
+                                                       "SELECT int_id FROM ttrss_user_entries WHERE
+                                                               ref_id = '$ref_id' AND owner_uid = '$owner_uid' AND
+                                                               feed_id = '$feed' LIMIT 1");
+
+                                               if (db_num_rows($result) == 1) {
+                                                       $entry_int_id = db_fetch_result($result, 0, "int_id");
+                                               }
+                                       } else {
+                                               $entry_ref_id = db_fetch_result($result, 0, "ref_id");
+                                               $entry_int_id = db_fetch_result($result, 0, "int_id");
                                        }
-                                       
+
+                                       if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
+                                               _debug("update_rss_feed: RID: $entry_ref_id, IID: $entry_int_id");
+                                       }
+
                                        $post_needs_update = false;
 
                                        if (get_pref($link, "UPDATE_POST_ON_CHECKSUM_CHANGE", $owner_uid, false) &&
 
                                db_query($link, "COMMIT");
 
+                               if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
+                                       _debug("update_rss_feed: looking for enclosures...");
+                               }
+
+                               if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
+                                       print_r($enclosures);
+                               }
+
+                               db_query($link, "BEGIN");
+
+                               foreach ($enclosures as $enc) {
+                                       $enc_url = db_escape_string($enc[0]);
+                                       $enc_type = db_escape_string($enc[1]);
+                                       $enc_dur = db_escape_string($enc[2]);
+
+                                       $result = db_query($link, "SELECT id FROM ttrss_enclosures
+                                               WHERE content_url = '$enc_url' AND post_id = '$entry_ref_id'");
+
+                                       if (db_num_rows($result) == 0) {
+                                               db_query($link, "INSERT INTO ttrss_enclosures
+                                                       (content_url, content_type, title, duration, post_id) VALUES
+                                                       ('$enc_url', '$enc_type', '', '$enc_dur', '$entry_ref_id')");
+                                       }
+                               }
+
+                               db_query($link, "COMMIT");
+
                                if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
                                        _debug("update_rss_feed: looking for tags...");
                                }
                                
                                        db_query($link, "BEGIN");
                        
-                                       $result = db_query($link, "SELECT id,int_id 
-                                               FROM ttrss_entries,ttrss_user_entries 
-                                               WHERE guid = '$entry_guid' 
-                                               AND feed_id = '$feed' AND ref_id = id
-                                               AND owner_uid = '$owner_uid'");
-
-                                       if (db_num_rows($result) == 1) {
-
-                                               $entry_id = db_fetch_result($result, 0, "id");
-                                               $entry_int_id = db_fetch_result($result, 0, "int_id");
-                                               
                                                foreach ($entry_tags as $tag) {
 
                                                        $tag = sanitize_tag($tag);
                                                                        VALUES ('$owner_uid','$tag', '$entry_int_id')");
                                                        }                                                       
                                                }
-                                       }
+
                                        db_query($link, "COMMIT");
                                } 
 
                                        last_updated = NOW() WHERE id = '$feed'");
                }
 
+               if (ENABLE_SIMPLEPIE) {
+                       unset($rss);
+               }
+
                if (defined('DAEMON_EXTENDED_DEBUG') || $_GET['xdebug']) {
                        _debug("update_rss_feed: done");
                }
 
                if (!SINGLE_USER_MODE) {
 
-                       $pwd_hash = 'SHA1:' . sha1($password);
+                       $pwd_hash1 = encrypt_password($password);
+                       $pwd_hash2 = encrypt_password($password, $login);
+
+                       if (defined('ALLOW_REMOTE_USER_AUTH') && ALLOW_REMOTE_USER_AUTH 
+                                       && $_SERVER["REMOTE_USER"]) {
+
+                               $login = db_escape_string($_SERVER["REMOTE_USER"]);
 
-                       if ($force_auth && defined('_DEBUG_USER_SWITCH')) {
                                $query = "SELECT id,login,access_level
                    FROM ttrss_users WHERE
-                        login = '$login'";
+                                       login = '$login'";
+
                        } else {
-                               $query = "SELECT id,login,access_level
+                               $query = "SELECT id,login,access_level,pwd_hash
                    FROM ttrss_users WHERE
-                        login = '$login' AND pwd_hash = '$pwd_hash'";
+                                       login = '$login' AND (pwd_hash = '$pwd_hash1' OR
+                                               pwd_hash = '$pwd_hash2')";
                        }
 
                        $result = db_query($link, $query);
        
                                $_SESSION["theme"] = $user_theme;
                                $_SESSION["ip_address"] = $_SERVER["REMOTE_ADDR"];
+                               $_SESSION["pwd_hash"] = db_fetch_result($result, 0, "pwd_hash");
        
                                initialize_user_prefs($link, $_SESSION["uid"]);
        
 
                db_query($link, "insert into ttrss_labels (owner_uid,sql_exp,description) 
                        values ('$uid','last_read is null and unread = false', 'Updated articles')");
-               
+
                db_query($link, "insert into ttrss_feeds (owner_uid,title,feed_url)
                        values ('$uid', 'Tiny Tiny RSS: New Releases',
                        'http://tt-rss.spb.ru/releases.rss')");
        }
 
        function validate_session($link) {
+               if (SINGLE_USER_MODE) { 
+                       return true;
+               }
+
                if (SESSION_CHECK_ADDRESS && $_SESSION["uid"]) {
                        if ($_SESSION["ip_address"]) {
                                if ($_SESSION["ip_address"] != $_SERVER["REMOTE_ADDR"]) {
                        }
                }
 
+               if ($_SESSION["uid"]) {
+
+                       $result = db_query($link, 
+                               "SELECT pwd_hash FROM ttrss_users WHERE id = '".$_SESSION["uid"]."'");
+
+                       $pwd_hash = db_fetch_result($result, 0, "pwd_hash");
+
+                       if ($pwd_hash != $_SESSION["pwd_hash"]) {
+                               return false;
+                       }
+               }
+
 /*             if ($_SESSION["cookie_lifetime"] && $_SESSION["uid"]) {
 
                        //print_r($_SESSION);
 
        function truncate_string($str, $max_len) {
                if (mb_strlen($str, "utf-8") > $max_len - 3) {
-                       return mb_substr($str, 0, $max_len, "utf-8") . "...";
+                       return mb_substr($str, 0, $max_len, "utf-8") . "&hellip;";
                } else {
                        return $str;
                }
        }
 
        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);
+               if (function_exists('flock')) {
+                       error_reporting(0);
+                       $fp = fopen(LOCK_DIRECTORY . "/$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 false;
+                               return true;
                        }
-                       fclose($fp);
-                       return true;
                }
                return false;
        }
 
        function make_lockfile($filename) {
-               $fp = fopen($filename, "w");
+               $fp = fopen(LOCK_DIRECTORY . "/$filename", "w");
 
                if (flock($fp, LOCK_EX | LOCK_NB)) {            
                        return $fp;
        }
 
        function make_stampfile($filename) {
-               $fp = fopen($filename, "w");
+               $fp = fopen(LOCK_DIRECTORY . "/$filename", "w");
 
                if (flock($fp, LOCK_EX | LOCK_NB)) {
                        fwrite($fp, time() . "\n");
        function read_stampfile($filename) {
 
                error_reporting(0);
-               $fp = fopen($filename, "r");
+               $fp = fopen(LOCK_DIRECTORY . "/$filename", "r");
                error_reporting (DEFAULT_ERROR_LEVEL);
 
                if (flock($fp, LOCK_EX)) {
                                                $intl = get_pref($link, "FRESH_ARTICLE_MAX_AGE");
 
                                                if (DB_TYPE == "pgsql") {
-                                                       $match_part .= " AND date_entered > NOW() - INTERVAL '$intl hour' "; 
+                                                       $match_part = "date_entered > NOW() - INTERVAL '$intl hour' "; 
                                                } else {
-                                                       $match_part .= " AND date_entered > DATE_SUB(NOW(), 
+                                                       $match_part = "date_entered > DATE_SUB(NOW(), 
                                                                INTERVAL $intl HOUR) ";
                                                }
 
-                                               db_query($link, "UPDATE ttrss_user_entries 
-                                                       SET unread = false,last_read = NOW()
-                                                       WHERE $match_part AND owner_uid = ".$_SESSION["uid"]);
+                                               $result = db_query($link, "SELECT id FROM ttrss_entries, 
+                                                       ttrss_user_entries WHERE $match_part AND
+                                                       unread = true AND
+                                                       ttrss_user_entries.ref_id = ttrss_entries.id AND        
+                                                       owner_uid = ".$_SESSION["uid"]);
+
+                                               $affected_ids = array();
+
+                                               while ($line = db_fetch_assoc($result)) {
+                                                       array_push($affected_ids, $line["id"]);
+                                               }
+
+                                               catchupArticlesById($link, $affected_ids, 0);
                                        }
 
                                } else if ($feed < -10) { // label
                        }
        }
 
-       function update_generic_feed($link, $feed, $cat_view) {
+       function update_generic_feed($link, $feed, $cat_view, $force_update = false) {
                        if ($cat_view) {
 
                                if ($feed > 0) {
                                        $cat_qpart = "cat_id IS NULL";
                                }
                                
-                               $tmp_result = db_query($link, "SELECT feed_url FROM ttrss_feeds
+                               $tmp_result = db_query($link, "SELECT id,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);
+                                       $feed_id = $tmp_line["id"];
+                                       update_rss_feed($link, $feed_url, $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, ENABLE_UPDATE_DAEMON);
+                               update_rss_feed($link, $feed_url, $feed, $force_update);
                        }
        }
 
                
                        $result = db_query($link, "SELECT COUNT(post_int_id) AS unread
                                FROM ttrss_tags,ttrss_user_entries,ttrss_entries 
-                               WHERE tag_name = '$feed' AND post_int_id = int_id AND ref_id = id 
+                               WHERE tag_name = '$feed' AND post_int_id = int_id AND ref_id = ttrss_entries.id 
                                AND unread = true AND $age_qpart AND
                                        ttrss_tags.owner_uid = " . $_SESSION["uid"]);
                }
                        }
                }
 
+               print "<param key=\"theme\" value=\"".$_SESSION["theme"]."\"/>";
                print "<param key=\"daemon_enabled\" value=\"" . ENABLE_UPDATE_DAEMON . "\"/>";
                print "<param key=\"feeds_frame_refresh\" value=\"" . FEEDS_FRAME_REFRESH . "\"/>";
-               print "<param key=\"daemon_refresh_only\" value=\"" . DAEMON_REFRESH_ONLY . "\"/>";
+               print "<param key=\"daemon_refresh_only\" value=\"true\"/>";
 
                print "<param key=\"on_catchup_show_next_feed\" value=\"" . 
                        get_pref($link, "ON_CATCHUP_SHOW_NEXT_FEED") . "\"/>";
                print "<param key=\"icons_location\" value=\"" . 
                        ICONS_URL . "\"/>";
 
+               print "<param key=\"hide_read_shows_special\" value=\"" . 
+                       (int) get_pref($link, "HIDE_READ_SHOWS_SPECIAL") . "\"/>";
+
                print "</init-params>";
        }
 
        function print_runtime_info($link) {
                print "<runtime-info>";
+
                if (ENABLE_UPDATE_DAEMON) {
                        print "<param key=\"daemon_is_running\" value=\"".
                                sprintf("%d", file_is_locked("update_daemon.lock")) . "\"/>";
 
-                       if ($_SESSION["daemon_stamp_check"] + 600 < time()) {
+                       if (time() - $_SESSION["daemon_stamp_check"] > 30) {
 
                                $stamp = (int)read_stampfile("update_daemon.stamp");
 
+//                             print "<param key=\"daemon_stamp_delta\" value=\"$stamp_delta\"/>";
+
                                if ($stamp) {
-                                       if ($stamp + 86400*3 < time()) {
-                                               print "<param key=\"daemon_stamp_ok\" value=\"0\"/>";
+                                       $stamp_delta = time() - $stamp;
+
+                                       if ($stamp_delta > 1800) {
+                                               $stamp_check = 0;
                                        } else {
-                                               print "<param key=\"daemon_stamp_ok\" value=\"1\"/>";
+                                               $stamp_check = 1;
+                                               $_SESSION["daemon_stamp_check"] = time();
                                        }
 
+                                       print "<param key=\"daemon_stamp_ok\" value=\"$stamp_check\"/>";
+
                                        $stamp_fmt = date("Y.m.d, G:i", $stamp);
 
                                        print "<param key=\"daemon_stamp\" value=\"$stamp_fmt\"/>";
                                }
-
-                               $_SESSION["daemon_stamp_check"] = time();
                        }
                }
 
 
                        if ($feed < -10) error_reporting (0);
 
+                       $content_query_part = "content as content_preview,";
+
                        if (preg_match("/^-?[0-9][0-9]*$/", $feed) != false) {
        
                                if ($feed >= 0) {
                                        $feed_kind = "Labels";
                                }
        
-                               $content_query_part = "content as content_preview,";
-
                                if ($limit_query_part) {
                                        $offset_query_part = "OFFSET $offset";
                                }
                $res = $str;
 
                if (get_pref($link, "STRIP_UNSAFE_TAGS") || $force_strip_tags) {
-                       global $tw_parser;
-                       global $tw_paranoya_setup;
 
-                       $res = $tw_parser->strip_tags($res, $tw_paranoya_setup);
+                       $res = strip_tags_long($res, 
+                               "<p><a><i><em><b><strong><blockquote><br><img><div><span><ul><ol><li>");
 
 //                     $res = preg_replace("/\r\n|\n|\r/", "", $res);
 //                     $res = strip_tags_long($res, "<p><a><i><em><b><strong><blockquote><br><img><div><span>");                       
                                WHERE email != '' AND (last_digest_sent IS NULL OR $interval_query)");
 
                while ($line = db_fetch_assoc($result)) {
+
                        if (get_pref($link, 'DIGEST_ENABLE', $line['id'], false)) {
                                print "Sending digest for UID:" . $line['id'] . " - " . $line["email"] . " ... ";
 
+                               $do_catchup = get_pref($link, 'DIGEST_CATCHUP', $line['id'], false);
+
                                $tuple = prepare_headlines_digest($link, $line["id"], $days, $limit);
                                $digest = $tuple[0];
                                $headlines_count = $tuple[1];
+                               $affected_ids = $tuple[2];
+                               $digest_text = $tuple[3];
 
                                if ($headlines_count > 0) {
-                                       $rc = mail($line["login"] . " <" . $line["email"] . ">",
-                                               "[tt-rss] New headlines for last 24 hours", $digest,
-                                               "From: " . MAIL_FROM . "\n".
-                                               "Content-Type: text/plain; charset=\"utf-8\"\n".
-                                               "Content-Transfer-Encoding: 8bit\n");
+
+                                       $mail = new PHPMailer();
+
+                                       $mail->PluginDir = "phpmailer/";
+                                       $mail->SetLanguage("en", "phpmailer/language/");
+
+                                       $mail->CharSet = "UTF-8";
+
+                                       $mail->From = DIGEST_FROM_ADDRESS;
+                                       $mail->FromName = DIGEST_FROM_NAME;
+                                       $mail->AddAddress($line["email"], $line["login"]);
+
+                                       if (DIGEST_SMTP_HOST) {
+                                               $mail->Host = DIGEST_SMTP_HOST;
+                                               $mail->Mailer = "smtp";
+                                               $mail->Username = DIGEST_SMTP_LOGIN;
+                                               $mail->Password = DIGEST_SMTP_PASSWORD;
+                                       }
+
+                                       $mail->IsHTML(true);
+                                       $mail->Subject = DIGEST_SUBJECT;
+                                       $mail->Body = $digest;
+                                       $mail->AltBody = $digest_text;
+
+                                       $rc = $mail->Send();
+
+                                       if (!$rc) print "ERROR: " . $mail->ErrorInfo;
+
                                        print "RC=$rc\n";
+
+                                       if ($rc && $do_catchup) {
+                                               print "Marking affected articles as read...\n";
+                                               catchupArticlesById($link, $affected_ids, 0, $line["id"]);
+                                       }
+
                                        db_query($link, "UPDATE ttrss_users SET last_digest_sent = NOW() 
                                                        WHERE id = " . $line["id"]);
                                } else {
                        }
                }
 
-//             $digest = prepare_headlines_digest($link, $user_id, $days, $limit);
+               print "All done.\n";
 
        }
 
        function prepare_headlines_digest($link, $user_id, $days = 1, $limit = 100) {
-               $tmp =  __("New headlines for last 24 hours, as of ") . date("Y/m/d H:m") . "\n";       
-               $tmp .= "=======================================================\n\n";
+
+               require_once "MiniTemplator.class.php";
+
+               $tpl = new MiniTemplator;
+               $tpl_t = new MiniTemplator;
+
+               $tpl->readTemplateFromFile("templates/digest_template_html.txt");
+               $tpl_t->readTemplateFromFile("templates/digest_template.txt");
+
+               $tpl->setVariable('CUR_DATE', date('Y/m/d'));
+               $tpl->setVariable('CUR_TIME', date('G:i'));
+
+               $tpl_t->setVariable('CUR_DATE', date('Y/m/d'));
+               $tpl_t->setVariable('CUR_TIME', date('G:i'));
+
+               $affected_ids = array();
 
                if (DB_TYPE == "pgsql") {
                        $interval_query = "ttrss_entries.date_entered > NOW() - INTERVAL '$days days'";
                $result = db_query($link, "SELECT ttrss_entries.title,
                                ttrss_feeds.title AS feed_title,
                                date_entered,
+                               ttrss_user_entries.ref_id,
                                link,
+                               SUBSTRING(content, 1, 120) AS excerpt,
                                SUBSTRING(last_updated,1,19) AS last_updated
                        FROM 
                                ttrss_user_entries,ttrss_entries,ttrss_feeds 
                                ref_id = ttrss_entries.id AND feed_id = ttrss_feeds.id 
                                AND include_in_digest = true
                                AND $interval_query
+                               AND hidden = false
                                AND ttrss_user_entries.owner_uid = $user_id
-                               AND unread = true ORDER BY ttrss_feeds.title, date_entered DESC
+                               AND unread = true 
+                       ORDER BY ttrss_feeds.title, date_entered DESC
                        LIMIT $limit");
 
                $cur_feed_title = "";
 
                $headlines_count = db_num_rows($result);
 
+               $headlines = array();
+
                while ($line = db_fetch_assoc($result)) {
+                       array_push($headlines, $line);
+               }
+
+               for ($i = 0; $i < sizeof($headlines); $i++) {   
+
+                       $line = $headlines[$i];
+
+                       array_push($affected_ids, $line["ref_id"]);
+
                        $updated = smart_date_time(strtotime($line["last_updated"]));
-                       $feed_title = $line["feed_title"];
 
-                       if ($cur_feed_title != $feed_title) {
-                               $cur_feed_title = $feed_title;
+                       $tpl->setVariable('FEED_TITLE', $line["feed_title"]);
+                       $tpl->setVariable('ARTICLE_TITLE', $line["title"]);
+                       $tpl->setVariable('ARTICLE_LINK', $line["link"]);
+                       $tpl->setVariable('ARTICLE_UPDATED', $updated);
+                       $tpl->setVariable('ARTICLE_EXCERPT', 
+                               truncate_string(strip_tags($line["excerpt"]), 100));
+
+                       $tpl->addBlock('article');
 
-                               $tmp .= "$feed_title\n\n";
+                       $tpl_t->setVariable('FEED_TITLE', $line["feed_title"]);
+                       $tpl_t->setVariable('ARTICLE_TITLE', $line["title"]);
+                       $tpl_t->setVariable('ARTICLE_LINK', $line["link"]);
+                       $tpl_t->setVariable('ARTICLE_UPDATED', $updated);
+//                     $tpl_t->setVariable('ARTICLE_EXCERPT', 
+//                             truncate_string(strip_tags($line["excerpt"]), 100));
+
+                       $tpl_t->addBlock('article');
+
+                       if ($headlines[$i]['feed_title'] != $headlines[$i+1]['feed_title']) {
+                               $tpl->addBlock('feed');
+                               $tpl_t->addBlock('feed');
                        }
 
-                       $tmp .= " * " . trim($line["title"]) . " - $updated\n";
-                       $tmp .= "   " . trim($line["link"]) . "\n";
-                       $tmp .= "\n";
                }
 
-               $tmp .= "--- \n";
-               $tmp .= __("You have been sent this email because you have enabled daily digests in Tiny Tiny RSS at ") . 
-                       DIGEST_HOSTNAME . "\n".
-                       __("To unsubscribe, visit your configuration options or contact instance owner.\n");
-                       
+               $tpl->addBlock('digest');
+               $tpl->generateOutputToString($tmp);
+
+               $tpl_t->addBlock('digest');
+               $tpl_t->generateOutputToString($tmp_t);
 
-               return array($tmp, $headlines_count);
+               return array($tmp, $headlines_count, $affected_ids, $tmp_t);
        }
 
        function check_for_update($link, $brief_fmt = true) {
                if (ENABLE_SIMPLEPIE) {
                        $rss = new SimplePie();
                        $rss->set_useragent(SIMPLEPIE_USERAGENT . MAGPIE_USER_AGENT_EXT);
-                       $rss->set_timeout(MAGPIE_FETCH_TIME_OUT);
+//                     $rss->set_timeout(MAGPIE_FETCH_TIME_OUT);
                        $rss->set_feed_url($fetch_url);
                        $rss->set_output_encoding('UTF-8');
                        $rss->init();
                }
        }
 
-       function catchupArticlesById($link, $ids, $cmode) {
+       function catchupArticlesById($link, $ids, $cmode, $owner_uid = false) {
+
+               if (!$owner_uid) $owner_uid = $_SESSION["uid"];
 
                $tmp_ids = array();
 
                if ($cmode == 0) {
                        db_query($link, "UPDATE ttrss_user_entries SET 
                        unread = false,last_read = NOW()
-                       WHERE ($ids_qpart) AND owner_uid = " . $_SESSION["uid"]);
+                       WHERE ($ids_qpart) AND owner_uid = $owner_uid");
                } else if ($cmode == 1) {
                        db_query($link, "UPDATE ttrss_user_entries SET 
                        unread = true
-                       WHERE ($ids_qpart) AND owner_uid = " . $_SESSION["uid"]);
+                       WHERE ($ids_qpart) AND owner_uid = $owner_uid");
                } else {
                        db_query($link, "UPDATE ttrss_user_entries SET 
                        unread = NOT unread,last_read = NOW()
-                       WHERE ($ids_qpart) AND owner_uid = " . $_SESSION["uid"]);
+                       WHERE ($ids_qpart) AND owner_uid = $owner_uid");
                }
        }
 
                                                <li onclick=\"$tog_published_link\">".__('Published')."</li>
                                                </ul></li>
                                        <li class=\"vsep\">&nbsp;</li>
-                                       <li class=\"top\"><a href=\"$catchup_page_link\">".__('Mark as read')."</a><ul>
+                                       <li class=\"top\">".__('Mark as read')."<ul>
                                                <li onclick=\"$catchup_sel_link\">".__('Selection')."</li>
                                                <!-- <li onclick=\"$catchup_page_link\">".__('This page')."</li> -->
                                                <li><span class=\"insensitive\">--------</span></li>
 } */
 
                        print "<td class=\"headlineTitle$rtl_cpart\">";
-               
+
+                       print "<span class=\"headlineInnerTitle\">";
+
                        if ($feed_site_url) {
                                if (!$bottom) {
                                        $target = "target=\"_new\"";
                                print " [$user_page_offset] ";
                        }
 
+                       print "</span>";
+
                        if (!$bottom) {
                                print "
                                        <a target=\"_new\" 
 
                        if ($hidden) {
                                $holder_style = "display:none;";
-                               $ellipsis = "...";
+                               $ellipsis = "";
                        } else {
                                $holder_style = "";
                                $ellipsis = "";
                                print "<span id=\"FCAP-$cat_id\">";
                        }
 
-                       print " <span id=\"FCATCTR-$cat_id\" title=\"Click to browse category\" 
+                       print " <span id=\"FCATCTR-$cat_id\" 
                                class=\"$catctr_class\">($cat_unread)</span> $ellipsis";
 
                        if ($can_browse) {
                                        if ($collapsed == "t" || $collapsed == "1") {
                                                $holder_class = "feedCatHolder";
                                                $holder_style = "display:none;";
-                                               $ellipsis = "...";
+                                               $ellipsis = "";
                                        } else {
                                                $holder_class = "feedCatHolder";
                                                $holder_style = "";
                                        print "<li class=\"feedCat\" id=\"FCAT-$cat_id\">
                                                <a id=\"FCATN-$cat_id\" href=\"javascript:toggleCollapseCat($cat_id)\">$tmp_category</a>
                                                        <a href=\"#\" onclick=\"javascript:viewCategory($cat_id)\" id=\"FCAP-$cat_id\">
-                                                       <span id=\"FCATCTR-$cat_id\" title=\"Click to browse category\" 
+                                                       <span id=\"FCATCTR-$cat_id\" 
                                                        class=\"$catctr_class\">($cat_unread)</span> $ellipsis
                                                        </a></li>";
 
 
                        $num_tags = 0;
 
+                       if ($_SESSION["theme"] == "3pane") {
+                               $tag_limit = 3;
+                       } else {
+                               $tag_limit = 6;
+                       }
+
                        foreach ($tags as $tag) {
                                $num_tags++;
                                $tag_escaped = str_replace("'", "\\'", $tag);
 
                                $tag_str = "<a href=\"javascript:viewfeed('$tag_escaped')\">$tag</a>, ";
                                
-                               if ($num_tags == 6) {
-                                       $tags_str .= "...";
+                               if ($num_tags == $tag_limit) {
+                                       $tags_str .= "&hellip;";
 
-                               } else if ($num_tags < 6) {
+                               } else if ($num_tags < $tag_limit) {
                                        $tags_str .= $tag_str;
                                }
                                $f_tags_str .= $tag_str;
                        $tags_str = preg_replace("/, $/", "", $tags_str);
                        $f_tags_str = preg_replace("/, $/", "", $f_tags_str);
 
-                       $all_tags_div = "<span class='cdmAllTagsCtr'>...<div class='cdmAllTags'>All Tags: $f_tags_str</div></span>";
+                       $all_tags_div = "<span class='cdmAllTagsCtr'>&hellip;<div class='cdmAllTags'>All Tags: $f_tags_str</div></span>";
                        $tags_str = preg_replace("/\.\.\.$/", "$all_tags_div", $tags_str);
 
                        if (!$entry_comments) $entry_comments = "&nbsp;"; # placeholder
                                $line["content"] = preg_replace("/href=/i", "target=\"_new\" href=", $line["content"]);
                        }
 
-                       print $line["content"] . "</div>";
+                       print $line["content"];
+
+                       $result = db_query($link, "SELECT * FROM ttrss_enclosures WHERE
+                               post_id = '$id'");
+
+                       if (db_num_rows($result) > 0) {
+                               print "<div class=\"postEnclosures\">";
+
+                               if (db_num_rows($result) == 1) {
+                                       print __("Attachment:") . " ";
+                               } else {
+                                       print __("Attachments:") . " ";
+                               }
+
+                               $entries = array();
+
+                               while ($line = db_fetch_assoc($result)) {
+
+                                       $url = $line["content_url"];
+
+                                       $filename = substr($url, strrpos($url, "/")+1);
+
+                                       $entry = "<a target=\"_blank\" href=\"" . htmlspecialchars($url) . "\">" .
+                                               $filename . " (" . $line["content_type"] . ")" . "</a>";
+
+                                       array_push($entries, $entry);
+                               }
+
+                               print join(", ", $entries);
+
+                               print "</div>";
+                       }
+               
+                       print "</div>";
                        
                        print "</div>";
 
        function outputHeadlinesList($link, $feed, $subop, $view_mode, $limit, $cat_view,
                                        $next_unread_feed, $offset) {
 
+               $disable_cache = false;
+
                $timing_info = getmicrotime();
 
                $topmost_article_ids = array();
                }
 
                if ($subop == "ForceUpdate" && sprintf("%d", $feed) > 0) {
-                       update_generic_feed($link, $feed, $cat_view);
+                       update_generic_feed($link, $feed, $cat_view, true);
                }
 
                if ($subop == "MarkAllRead")  {
                /// START /////////////////////////////////////////////////////////////////////////////////
 
                $search = db_escape_string($_GET["query"]);
+
+               if ($search) { 
+                       $disable_cache = true;
+               }
+
                $search_mode = db_escape_string($_GET["search_mode"]);
                $match_on = db_escape_string($_GET["match_on"]);
 
                                        } else {
                                                $add_class = "";
                                        }       
-                                       
+
+                                       $expand_cdm = get_pref($link, 'CDM_EXPANDED');
+
+                                       if ($expand_cdm) {
+                                               $cdm_cstyle = "";
+                                       } else {
+                                               $cdm_cstyle = "style=\"display : none\"";
+                                       }
+
                                        print "<div class=\"cdmArticle$add_class\" 
                                                id=\"RROW-$id\" onmouseover='cdmMouseIn(this)' 
                                                onmouseout='cdmMouseOut(this)'>";
 
                                        print $entry_author;
 
+                                       if (!$expand_cdm) {
+                                               print "&nbsp;<a id=\"CICH-$id\" 
+                                                       href=\"javascript:cdmExpandArticle($id)\">
+                                                       (".__('Show article').")</a>";
+                                       } 
+
+
                                        if ($line["feed_title"]) {      
                                                print "&nbsp;(<a href='javascript:viewfeed($feed_id)'>".$line["feed_title"]."</a>)";
                                        }
                                                        "target=\"_new\" href=", $line["content_preview"]);
                                        }
 
-                                       print "<div class=\"cdmContent\">" . $line["content_preview"] . "</div><br clear=\"all\">";
+                                       print "<div class=\"cdmContent\" id=\"CICD-$id\" $cdm_cstyle>";
+
+//                                     print "<div class=\"cdmInnerContent\" id=\"CICD-$id\" $cdm_cstyle>";
+                                       print $line["content_preview"];
+
+                                       $e_result = db_query($link, "SELECT * FROM ttrss_enclosures WHERE
+                                               post_id = '$id'");
+
+                                       if (db_num_rows($e_result) > 0) {
+                               print "<div class=\"cdmEnclosures\">";
+
+                               if (db_num_rows($e_result) == 1) {
+                                       print __("Attachment:") . " ";
+                               } else {
+                                       print __("Attachments:") . " ";
+                               }
+
+                               $entries = array();
+
+                               while ($e_line = db_fetch_assoc($e_result)) {
+
+                                       $url = $e_line["content_url"];
+
+                                       $filename = substr($url, strrpos($url, "/")+1);
+
+                                       $entry = "<a target=\"_blank\" href=\"" . htmlspecialchars($url) . "\">" .
+                                               $filename . " (" . $e_line["content_type"] . ")" . "</a>";
+
+                                       array_push($entries, $entry);
+                               }
+
+                               print join(", ", $entries);
+
+                               print "</div>";
+                       }
+
+                                       print "<br clear='both'>";
+//                                     print "</div>";
+
+/*                                     if (!$expand_cdm) {
+                                               print "<a id=\"CICH-$id\" 
+                                                       href=\"javascript:cdmExpandArticle($id)\">
+                                                       Show article</a>";
+                                       } */
+
+                                       print "</div>";
 
                                        print "<div class=\"cdmFooter\"><span class='s0'>";
 
                                                if ($num_tags < 5) {
                                                        $tags_str .= "<a href=\"javascript:viewfeed('$tag')\">$tag</a>, "; 
                                                } else if ($num_tags == 5) {
-                                                       $tags_str .= "...";
+                                                       $tags_str .= "&hellip;";
                                                }
                                        }
 
                                        $tags_str = preg_replace("/, $/", "", $tags_str);
                                        $full_tags_str = preg_replace("/, $/", "", $full_tags_str);
 
-                                       $all_tags_div = "<span class='cdmAllTagsCtr'>...<div class='cdmAllTags'>All Tags: $full_tags_str</div></span>";
+                                       $all_tags_div = "<span class='cdmAllTagsCtr'>&hellip;<div class='cdmAllTags'>All Tags: $full_tags_str</div></span>";
 
                                        $tags_str = preg_replace("/\.\.\.$/", "$all_tags_div", $tags_str);
 
                        print "</div>";
                }
 
-               return array($topmost_article_ids, $headlines_count);
+               return array($topmost_article_ids, $headlines_count, $feed, $disable_cache);
        }
 
 // from here: http://www.roscripts.com/Create_tag_cloud-71.html
 
        function clear_feed_articles($link, $id) {
                $result = db_query($link, "DELETE FROM ttrss_user_entries
-                       WHERE feed_id = '$id' AND marked = false");
+                       WHERE feed_id = '$id' AND marked = false AND owner_uid = " . $_SESSION["uid"]);
 
                $result = db_query($link, "DELETE FROM ttrss_entries WHERE 
                        (SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");
        }
 
+        function add_feed_url() {
+               $url_path = 'http://' . $_SERVER["HTTP_HOST"] . parse_url($_SERVER["REQUEST_URI"], PHP_URL_PATH);
+               $url_path .= "?op=pref-feeds&quiet=1&subop=add&feed_url=%s";
+               return $url_path;
+        }
+
+       function encrypt_password($pass, $login = '') {
+               if ($login) {
+                       return "SHA1X:" . sha1("$login:$pass");
+               } else {
+                       return "SHA1:" . sha1($pass);
+               }
+       }
+
 ?>