[tt-rss.git] / functions.php

<?
	session_start();

	require_once 'config.php';
	require_once 'db-prefs.php';

	define('MAGPIE_OUTPUT_ENCODING', 'UTF-8');

	function purge_feed($link, $feed_id, $purge_interval) {

		if (DB_TYPE == "pgsql") {
			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'");
		} else {
			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)");
		}
	}

	function global_purge_old_posts($link, $do_output = false) {

		$result = db_query($link, 
			"SELECT id,purge_interval,owner_uid FROM ttrss_feeds");

		while ($line = db_fetch_assoc($result)) {

			$feed_id = $line["id"];
			$purge_interval = $line["purge_interval"];
			$owner_uid = $line["owner_uid"];

			if ($purge_interval == 0) {
			
				$tmp_result = db_query($link, 
					"SELECT value FROM ttrss_user_prefs WHERE
						pref_name = 'PURGE_OLD_DAYS' AND owner_uid = '$owner_uid'");

				if (db_num_rows($tmp_result) != 0) {			
					$purge_interval = db_fetch_result($tmp_result, 0, "value");
				}
			}

			if ($do_output) {
				print "<feed id='$feed_id' p_intl='$purge_interval'/>";
			}

			if ($purge_interval > 0) {
				purge_feed($link, $feed_id, $purge_interval);
			}
		}	

		// purge orphaned posts in main content table
		db_query($link, "DELETE FROM ttrss_entries WHERE 
			(SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");

	}

	function purge_old_posts($link) {

		$user_id = $_SESSION["uid"];
	
		$result = db_query($link, "SELECT id,purge_interval FROM ttrss_feeds 
			WHERE owner_uid = '$user_id'");

		while ($line = db_fetch_assoc($result)) {

			$feed_id = $line["id"];
			$purge_interval = $line["purge_interval"];

			if ($purge_interval == 0) $purge_interval = get_pref($link, 'PURGE_OLD_DAYS');

			if ($purge_interval > 0) {
				purge_feed($link, $feed_id, $purge_interval);
			}
		}	

		// purge orphaned posts in main content table
		db_query($link, "DELETE FROM ttrss_entries WHERE 
			(SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");
	}

	function update_all_feeds($link, $fetch) {

		if (WEB_DEMO_MODE) return;

		if (get_pref($link, 'DAEMON_REFRESH_ONLY')) {
			if (!$_GET["daemon"]) {
				return;
			}
		}

		db_query($link, "BEGIN");

		$user_id = $_SESSION["uid"];

		$result = db_query($link, "SELECT feed_url,id,
			substring(last_updated,1,19) as last_updated,
			update_interval FROM ttrss_feeds WHERE owner_uid = '$user_id'");

		while ($line = db_fetch_assoc($result)) {
			$upd_intl = $line["update_interval"];

			if (!$upd_intl || $upd_intl == 0) {
				$upd_intl = get_pref($link, 'DEFAULT_UPDATE_INTERVAL');
			}

			if ($fetch || (!$line["last_updated"] || 
				time() - strtotime($line["last_updated"]) > ($upd_intl * 60))) {

				update_rss_feed($link, $line["feed_url"], $line["id"]);
			}
		}

		purge_old_posts($link);

		db_query($link, "COMMIT");

	}

	function check_feed_favicon($feed_url, $feed, $link) {
		$feed_url = str_replace("http://", "", $feed_url);
		$feed_url = preg_replace("/\/.*$/", "", $feed_url);
		
		$icon_url = "http://$feed_url/favicon.ico";
		$icon_file = ICONS_DIR . "/$feed.ico";

		if (!file_exists($icon_file)) {
				
			error_reporting(0);
			$r = fopen($icon_url, "r");
			error_reporting (E_ERROR | E_WARNING | E_PARSE);

			if ($r) {
				$tmpfname = tempnam("/tmp", "ttrssicon");
			
				$t = fopen($tmpfname, "w");
				
				while (!feof($r)) {
					$buf = fread($r, 16384);
					fwrite($t, $buf);
				}
				
				fclose($r);
				fclose($t);

				error_reporting(0);
				if (!rename($tmpfname, $icon_file)) {
					unlink($tmpfname);
				}

				chmod($icon_file, 0644);
				
				error_reporting (E_ERROR | E_WARNING | E_PARSE);

			}	
		}
	}

	function update_rss_feed($link, $feed_url, $feed) {

		if (WEB_DEMO_MODE) return;

		$feed = db_escape_string($feed);

		error_reporting(0);
		$rss = fetch_rss($feed_url);

		error_reporting (E_ERROR | E_WARNING | E_PARSE);

		db_query($link, "BEGIN");

		$feed = db_escape_string($feed);

		if ($rss) {

			if (get_pref($link, 'ENABLE_FEED_ICONS')) {	
				check_feed_favicon($feed_url, $feed, $link);
			}
		
			$result = db_query($link, "SELECT title,icon_url FROM ttrss_feeds WHERE id = '$feed'");

			$registered_title = db_fetch_result($result, 0, "title");
			$orig_icon_url = db_fetch_result($result, 0, "icon_url");

			if (!$registered_title) {
				$feed_title = db_escape_string($rss->channel["title"]);
				db_query($link, "UPDATE ttrss_feeds SET title = '$feed_title' WHERE id = '$feed'");
			}

//			print "I: " . $rss->channel["image"]["url"];

			$icon_url = $rss->image["url"];

			if ($icon_url && !$orig_icon_url) {
				$icon_url = db_escape_string($icon_url);
				db_query($link, "UPDATE ttrss_feeds SET icon_url = '$icon_url' WHERE id = '$feed'");
			}


			$filters = array();

			$result = db_query($link, "SELECT reg_exp,
				(SELECT name FROM ttrss_filter_types
					WHERE id = filter_type) as name
				FROM ttrss_filters WHERE owner_uid = ".$_SESSION["uid"]);

			while ($line = db_fetch_assoc($result)) {
				if (!$filters[$line["name"]]) $filters[$line["name"]] = array();
				array_push($filters[$line["name"]], $line["reg_exp"]);
			}

			foreach ($rss->items as $item) {
	
				$entry_guid = $item["id"];
	
				if (!$entry_guid) $entry_guid = $item["guid"];
				if (!$entry_guid) $entry_guid = $item["link"];

				if (!$entry_guid) continue;

				$entry_timestamp = "";

				$rss_2_date = $item['pubdate'];
				$rss_1_date = $item['dc']['date'];
				$atom_date = $item['issued'];
			
				if ($atom_date != "") $entry_timestamp = parse_w3cdtf($atom_date);
				if ($rss_1_date != "") $entry_timestamp = parse_w3cdtf($rss_1_date);
				if ($rss_2_date != "") $entry_timestamp = strtotime($rss_2_date);
				
				if ($entry_timestamp == "") {
					$entry_timestamp = time();
					$no_orig_date = 'true';
				} else {
					$no_orig_date = 'false';
				}

				$entry_timestamp_fmt = strftime("%Y/%m/%d %H:%M:%S", $entry_timestamp);

				$entry_title = $item["title"];
				$entry_link = $item["link"];

				if (!$entry_title) continue;
				if (!$entry_link) continue;

				$entry_content = $item["content:escaped"];

				if (!$entry_content) $entry_content = $item["content:encoded"];
				if (!$entry_content) $entry_content = $item["content"];
				if (!$entry_content) $entry_content = $item["description"];

//				if (!$entry_content) continue;

				// WTF
				if (is_array($entry_content)) {
					$entry_content = $entry_content["encoded"];
					if (!$entry_content) $entry_content = $entry_content["escaped"];
				}

//				print_r($item);
//				print_r($entry_content);

				$content_hash = "SHA1:" . sha1(strip_tags($entry_content));

				$entry_comments = $item["comments"];

				$entry_guid = db_escape_string($entry_guid);

				$result = db_query($link, "SELECT id FROM	ttrss_entries 
					WHERE guid = '$entry_guid'");

				$owner_uid = $_SESSION["uid"];

				$entry_content = db_escape_string($entry_content);
				$entry_title = db_escape_string($entry_title);
				$entry_link = db_escape_string($entry_link);
				$entry_comments = db_escape_string($entry_comments);

				if (db_num_rows($result) == 0) {

					// base post entry does not exist, create it

					error_reporting(0);
					if (is_filtered($entry_title, $entry_content, $filters)) {
						continue;
					}
					error_reporting (E_ERROR | E_WARNING | E_PARSE);

					$result = db_query($link,
						"INSERT INTO ttrss_entries 
							(title,
							guid,
							link,
							updated,
							content,
							content_hash,
							no_orig_date,
							date_entered,
							comments)
						VALUES
							('$entry_title', 
							'$entry_guid', 
							'$entry_link',
							'$entry_timestamp_fmt', 
							'$entry_content', 
							'$content_hash',
							$no_orig_date, 
							NOW(), 
							'$entry_comments')");
				}

				// now it should exist, if not - bad luck then

				$result = db_query($link, "SELECT 
						id,content_hash,no_orig_date,title,
						substring(updated,1,19) as updated
					FROM 
						ttrss_entries 
					WHERE guid = '$entry_guid'");

				if (db_num_rows($result) == 1) {

						// this will be used below in update handler
						$orig_content_hash = db_fetch_result($result, 0, "content_hash");
//						$orig_timestamp = strtotime(db_fetch_result($result, 0, "updated"));
//						$orig_no_orig_date = db_fetch_result($result, 0, "no_orig_date");
						$orig_title = db_fetch_result($result, 0, "title");

						$ref_id = db_fetch_result($result, 0, "id");

						// check for user post link to main table

						// do we allow duplicate posts with same GUID in different feeds?
						if (get_pref($link, "ALLOW_DUPLICATE_POSTS")) {
							$dupcheck_qpart = "AND feed_id = '$feed'";
						} else { 
							$dupcheck_qpart = "";
						}

						$result = db_query($link,
							"SELECT ref_id FROM ttrss_user_entries WHERE
								ref_id = '$ref_id' AND owner_uid = '$owner_uid'
								$dupcheck_qpart");

						// okay it doesn't exist - create user entry
						if (db_num_rows($result) == 0) {
							$result = db_query($link,
								"INSERT INTO ttrss_user_entries 
									(ref_id, owner_uid, feed_id) 
								VALUES ('$ref_id', '$owner_uid', '$feed')");
						}

					$post_needs_update = false;

					if (get_pref($link, "UPDATE_POST_ON_CHECKSUM_CHANGE") &&
						($content_hash != $orig_content_hash)) {
						$post_needs_update = true;
					}

					if ($orig_title != $entry_title) {
						$post_needs_update = true;
					}

//					this doesn't seem to be very reliable
//
//					if ($orig_timestamp != $entry_timestamp && !$orig_no_orig_date) {
//						$post_needs_update = true;
//					}

					// if post needs update, update it and mark all user entries 
					// linking to this post as updated					
					if ($post_needs_update) {

//						print "<!-- post $orig_title needs update : $post_needs_update -->";

						db_query($link, "UPDATE ttrss_entries 
							SET title = '$entry_title', content = '$entry_content'
							WHERE id = '$ref_id'");

						db_query($link, "UPDATE ttrss_user_entries 
							SET last_read = null WHERE ref_id = '$ref_id' AND unread = false");

					}
				}

				/* taaaags */
				// <a href="http://technorati.com/tag/Xorg" rel="tag">Xorg</a>, //

				$entry_tags = null;

				preg_match_all("/<a.*?rel=.tag.*?>([^>]+)<\/a>/i", $entry_content,
					$entry_tags);

				$entry_tags = $entry_tags[1];

				if (count($entry_tags) > 0) {
				
					$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 = " . $_SESSION["uid"]);

					if (!$result || db_num_rows($result) != 1) {
						return;
					}

					$entry_id = db_fetch_result($result, 0, "id");
					$entry_int_id = db_fetch_result($result, 0, "int_id");
					
					foreach ($entry_tags as $tag) {
						$tag = db_escape_string(strtolower($tag));

						$tag = str_replace("technorati tag: ", "", $tag);

						$result = db_query($link, "SELECT id FROM ttrss_tags		
							WHERE tag_name = '$tag' AND post_int_id = '$entry_int_id' AND 
							owner_uid = ".$_SESSION["uid"]." LIMIT 1");

//						print db_fetch_result($result, 0, "id");

						if ($result && db_num_rows($result) == 0) {
							
//							print "tagging $entry_id as $tag<br>";

							db_query($link, "INSERT INTO ttrss_tags 
								(owner_uid,tag_name,post_int_id)
								VALUES ('".$_SESSION["uid"]."','$tag', '$entry_int_id')");
						}							
					}
				} 
			} 

			db_query($link, "UPDATE ttrss_feeds 
				SET last_updated = NOW(), last_error = '' WHERE id = '$feed'");

		} else {
			$error_msg = db_escape_string(magpie_error());
			db_query($link, 
				"UPDATE ttrss_feeds SET last_error = '$error_msg', 
					last_updated = NOW() WHERE id = '$feed'");
		}

		db_query($link, "COMMIT");

	}

	function print_select($id, $default, $values, $attributes = "") {
		print "<select id=\"$id\" $attributes>";
		foreach ($values as $v) {
			if ($v == $default)
				$sel = " selected";
			 else
			 	$sel = "";
			
			print "<option$sel>$v</option>";
		}
		print "</select>";
	}

	function is_filtered($title, $content, $filters) {

		if ($filters["title"]) {
			foreach ($filters["title"] as $title_filter) {			
				if (preg_match("/$title_filter/i", $title)) 
					return true;
			}
		}

		if ($filters["content"]) {
			foreach ($filters["content"] as $content_filter) {			
				if (preg_match("/$content_filter/i", $content)) 
					return true;
			}
		}

		if ($filters["both"]) {
			foreach ($filters["both"] as $filter) {			
				if (preg_match("/$filter/i", $title) || preg_match("/$filter/i", $content)) 
					return true;
			}
		}

		return false;
	}

	function printFeedEntry($feed_id, $class, $feed_title, $unread, $icon_file, $link) {

		if (file_exists($icon_file) && filesize($icon_file) > 0) {
				$feed_icon = "<img src=\"$icon_file\">";
		} else {
			$feed_icon = "<img src=\"images/blank_icon.gif\">";
		}

		$feed = "<a 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>";

		if ($unread != 0) {
			$fctr_class = "";
		} else {
			$fctr_class = "class=\"invisible\"";
		}

		print "<span $fctr_class id=\"FEEDCTR-$feed_id\">
			 (<span id=\"FEEDU-$feed_id\">$unread</span>)</span>";
		
		print "</li>";

	}

	function getmicrotime() {
		list($usec, $sec) = explode(" ",microtime());
		return ((float)$usec + (float)$sec);
	}

	function print_radio($id, $default, $values, $attributes = "") {
		foreach ($values as $v) {
		
			if ($v == $default)
				$sel = "checked";
			 else
			 	$sel = "";

			if ($v == "Yes") {
				$sel .= " value=\"1\"";
			} else {
				$sel .= " value=\"0\"";
			}
			
			print "<input type=\"radio\" $sel $attributes name=\"$id\">&nbsp;$v&nbsp;";

		}
	}

	function initialize_user_prefs($link, $uid) {

		$uid = db_escape_string($uid);

		db_query($link, "BEGIN");

		$result = db_query($link, "SELECT pref_name,def_value FROM ttrss_prefs");
		
		$u_result = db_query($link, "SELECT pref_name 
			FROM ttrss_user_prefs WHERE owner_uid = '$uid'");

		$active_prefs = array();

		while ($line = db_fetch_assoc($u_result)) {
			array_push($active_prefs, $line["pref_name"]);			
		}

		while ($line = db_fetch_assoc($result)) {
			if (array_search($line["pref_name"], $active_prefs) === FALSE) {
//				print "adding " . $line["pref_name"] . "<br>";

				db_query($link, "INSERT INTO ttrss_user_prefs
					(owner_uid,pref_name,value) VALUES 
					('$uid', '".$line["pref_name"]."','".$line["def_value"]."')");

			}
		}

		db_query($link, "COMMIT");

	}
	
	function authenticate_user($link, $login, $password) {

		$pwd_hash = 'SHA1:' . sha1($password);

		$result = db_query($link, "SELECT id,login,access_level FROM ttrss_users WHERE 
			login = '$login' AND (pwd_hash = '$password' OR pwd_hash = '$pwd_hash')");

		if (db_num_rows($result) == 1) {
			$_SESSION["uid"] = db_fetch_result($result, 0, "id");
			$_SESSION["name"] = db_fetch_result($result, 0, "login");
			$_SESSION["access_level"] = db_fetch_result($result, 0, "access_level");

			db_query($link, "UPDATE ttrss_users SET last_login = NOW() WHERE id = " . 
				$_SESSION["uid"]);

			return true;
		}

		return false;

	}

	function http_authenticate_user($link) {

		if (!$_SERVER['PHP_AUTH_USER']) {

			header('WWW-Authenticate: Basic realm="Tiny Tiny RSS"');
			header('HTTP/1.0 401 Unauthorized');
			print "<h1>401 Unathorized</h1>";
			exit;
			
		} else {

			$login = db_escape_string($_SERVER['PHP_AUTH_USER']);
			$password = db_escape_string($_SERVER['PHP_AUTH_PW']);

			return authenticate_user($link, $login, $password);
		}		
	}

	function make_password($length = 8) {

		$password = "";
		$possible = "0123456789bcdfghjkmnpqrstvwxyz"; 
    
		$i = 0; 
    
		while ($i < $length) { 
			$char = substr($possible, mt_rand(0, strlen($possible)-1), 1);
        
			if (!strstr($password, $char)) { 
				$password .= $char;
				$i++;
			}
		}
		return $password;
	}

	// this is called after user is created to initialize default feeds, labels
	// or whatever else
	
	// user preferences are checked on every login, not here

	function initialize_user($link, $uid) {

		db_query($link, "insert into ttrss_labels (owner_uid,sql_exp,description) 
			values ('$uid','unread = true', 'Unread articles')");

		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 Dev. Feed',
			'http://bah.spb.su/darcsweb/darcsweb.cgi?r=tt-rss;a=rss')");
		
		}

?>
Commit	Line	Data
40d13c28	1	<?
f1a80dae AD	2	session_start();
f1a80dae AD	3
40d13c28	4	require_once 'config.php';
b619ff15	5	require_once 'db-prefs.php';
40d13c28	6
a3ee2a38 AD	7	define('MAGPIE_OUTPUT_ENCODING', 'UTF-8');
a3ee2a38 AD	8
fefa6ca3	9	function purge_feed($link, $feed_id, $purge_interval) {
4c193675	10
fefa6ca3	11	if (DB_TYPE == "pgsql") {
35d8cf43	12	db_query($link, "DELETE FROM ttrss_user_entries WHERE
fefa6ca3	13	marked = false AND feed_id = '$feed_id' AND
35d8cf43 AD	14	(SELECT date_entered FROM ttrss_entries WHERE
35d8cf43 AD	15	id = ref_id) < NOW() - INTERVAL '$purge_interval days'");
fefa6ca3	16	} else {
35d8cf43	17	db_query($link, "DELETE FROM ttrss_user_entries WHERE
fefa6ca3	18	marked = false AND feed_id = '$feed_id' AND
35d8cf43 AD	19	(SELECT date_entered FROM ttrss_entries WHERE
35d8cf43 AD	20	id = ref_id) < DATE_SUB(NOW(), INTERVAL $purge_interval DAY)");
fefa6ca3 AD	21	}
	22	}
	23
	24	function global_purge_old_posts($link, $do_output = false) {
	25
	26	$result = db_query($link,
	27	"SELECT id,purge_interval,owner_uid FROM ttrss_feeds");
	28
	29	while ($line = db_fetch_assoc($result)) {
	30
	31	$feed_id = $line["id"];
	32	$purge_interval = $line["purge_interval"];
	33	$owner_uid = $line["owner_uid"];
	34
	35	if ($purge_interval == 0) {
	36
	37	$tmp_result = db_query($link,
	38	"SELECT value FROM ttrss_user_prefs WHERE
	39	pref_name = 'PURGE_OLD_DAYS' AND owner_uid = '$owner_uid'");
	40
	41	if (db_num_rows($tmp_result) != 0) {
	42	$purge_interval = db_fetch_result($tmp_result, 0, "value");
	43	}
	44	}
	45
	46	if ($do_output) {
	47	print "<feed id='$feed_id' p_intl='$purge_interval'/>";
	48	}
	49
	50	if ($purge_interval > 0) {
	51	purge_feed($link, $feed_id, $purge_interval);
	52	}
	53	}
	54
71604ca4 AD	55	// purge orphaned posts in main content table
	56	db_query($link, "DELETE FROM ttrss_entries WHERE
	57	(SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");
	58
fefa6ca3 AD	59	}
fefa6ca3 AD	60
b6eefba5	61	function purge_old_posts($link) {
5d73494a	62
f1a80dae AD	63	$user_id = $_SESSION["uid"];
	64
	65	$result = db_query($link, "SELECT id,purge_interval FROM ttrss_feeds
	66	WHERE owner_uid = '$user_id'");
5d73494a AD	67
	68	while ($line = db_fetch_assoc($result)) {
	69
	70	$feed_id = $line["id"];
	71	$purge_interval = $line["purge_interval"];
	72
b619ff15	73	if ($purge_interval == 0) $purge_interval = get_pref($link, 'PURGE_OLD_DAYS');
5d73494a	74
140aae81	75	if ($purge_interval > 0) {
fefa6ca3	76	purge_feed($link, $feed_id, $purge_interval);
5d73494a AD	77	}
5d73494a AD	78	}
71604ca4 AD	79
	80	// purge orphaned posts in main content table
	81	db_query($link, "DELETE FROM ttrss_entries WHERE
	82	(SELECT COUNT(int_id) FROM ttrss_user_entries WHERE ref_id = id) = 0");
c3a8d71a AD	83	}
c3a8d71a AD	84
9c9c7e6b	85	function update_all_feeds($link, $fetch) {
40d13c28	86
4769ddaf	87	if (WEB_DEMO_MODE) return;
b0b4abcf	88
b619ff15	89	if (get_pref($link, 'DAEMON_REFRESH_ONLY')) {
c5142cca AD	90	if (!$_GET["daemon"]) {
	91	return;
	92	}
c70d731e AD	93	}
c70d731e AD	94
b6eefba5	95	db_query($link, "BEGIN");
b82af8c3	96
f1a80dae AD	97	$user_id = $_SESSION["uid"];
f1a80dae AD	98
d148926e AD	99	$result = db_query($link, "SELECT feed_url,id,
d148926e AD	100	substring(last_updated,1,19) as last_updated,
f1a80dae	101	update_interval FROM ttrss_feeds WHERE owner_uid = '$user_id'");
40d13c28	102
b6eefba5	103	while ($line = db_fetch_assoc($result)) {
d148926e AD	104	$upd_intl = $line["update_interval"];
d148926e AD	105
b619ff15 AD	106	if (!$upd_intl \|\| $upd_intl == 0) {
	107	$upd_intl = get_pref($link, 'DEFAULT_UPDATE_INTERVAL');
	108	}
d148926e	109
93d40f50 AD	110	if ($fetch \|\| (!$line["last_updated"] \|\|
93d40f50 AD	111	time() - strtotime($line["last_updated"]) > ($upd_intl * 60))) {
c5142cca	112
8143ae1f	113	update_rss_feed($link, $line["feed_url"], $line["id"]);
d148926e	114	}
40d13c28 AD	115	}
40d13c28 AD	116
b6eefba5	117	purge_old_posts($link);
c3a8d71a	118
b6eefba5	119	db_query($link, "COMMIT");
b82af8c3	120
40d13c28 AD	121	}
40d13c28 AD	122
9e997874	123	function check_feed_favicon($feed_url, $feed, $link) {
78800912 AD	124	$feed_url = str_replace("http://", "", $feed_url);
	125	$feed_url = preg_replace("/\/.*$/", "", $feed_url);
	126
	127	$icon_url = "http://$feed_url/favicon.ico";
273a2f6b	128	$icon_file = ICONS_DIR . "/$feed.ico";
78800912 AD	129
78800912 AD	130	if (!file_exists($icon_file)) {
e695fdc8	131
78800912 AD	132	error_reporting(0);
	133	$r = fopen($icon_url, "r");
	134	error_reporting (E_ERROR \| E_WARNING \| E_PARSE);
	135
	136	if ($r) {
	137	$tmpfname = tempnam("/tmp", "ttrssicon");
	138
	139	$t = fopen($tmpfname, "w");
	140
	141	while (!feof($r)) {
	142	$buf = fread($r, 16384);
	143	fwrite($t, $buf);
	144	}
	145
	146	fclose($r);
	147	fclose($t);
	148
e695fdc8 AD	149	error_reporting(0);
	150	if (!rename($tmpfname, $icon_file)) {
	151	unlink($tmpfname);
	152	}
717f5e64 AD	153
	154	chmod($icon_file, 0644);
	155
e695fdc8	156	error_reporting (E_ERROR \| E_WARNING \| E_PARSE);
78800912 AD	157
	158	}
	159	}
	160	}
	161
40d13c28 AD	162	function update_rss_feed($link, $feed_url, $feed) {
40d13c28 AD	163
4769ddaf	164	if (WEB_DEMO_MODE) return;
b0b4abcf	165
ab3d0b99 AD	166	$feed = db_escape_string($feed);
ab3d0b99 AD	167
3ad5aa85	168	error_reporting(0);
40d13c28	169	$rss = fetch_rss($feed_url);
ab3d0b99	170
3ad5aa85	171	error_reporting (E_ERROR \| E_WARNING \| E_PARSE);
76798ff3	172
b6eefba5	173	db_query($link, "BEGIN");
b7f4bda2	174
b6eefba5	175	$feed = db_escape_string($feed);
dcee8f61	176
40d13c28	177	if ($rss) {
b82af8c3	178
b619ff15	179	if (get_pref($link, 'ENABLE_FEED_ICONS')) {
9e997874	180	check_feed_favicon($feed_url, $feed, $link);
78800912 AD	181	}
78800912 AD	182
b6eefba5	183	$result = db_query($link, "SELECT title,icon_url FROM ttrss_feeds WHERE id = '$feed'");
331900c6	184
b6eefba5 AD	185	$registered_title = db_fetch_result($result, 0, "title");
b6eefba5 AD	186	$orig_icon_url = db_fetch_result($result, 0, "icon_url");
331900c6 AD	187
331900c6 AD	188	if (!$registered_title) {
e1305a97	189	$feed_title = db_escape_string($rss->channel["title"]);
b6eefba5	190	db_query($link, "UPDATE ttrss_feeds SET title = '$feed_title' WHERE id = '$feed'");
331900c6	191	}
40d13c28	192
b7f4bda2 AD	193	// print "I: " . $rss->channel["image"]["url"];
	194
	195	$icon_url = $rss->image["url"];
	196
	197	if ($icon_url && !$orig_icon_url) {
b6eefba5 AD	198	$icon_url = db_escape_string($icon_url);
b6eefba5 AD	199	db_query($link, "UPDATE ttrss_feeds SET icon_url = '$icon_url' WHERE id = '$feed'");
b7f4bda2 AD	200	}
b7f4bda2 AD	201
e6155a06 AD	202
	203	$filters = array();
	204
4b3dff6e	205	$result = db_query($link, "SELECT reg_exp,
e6155a06 AD	206	(SELECT name FROM ttrss_filter_types
e6155a06 AD	207	WHERE id = filter_type) as name
06da450f	208	FROM ttrss_filters WHERE owner_uid = ".$_SESSION["uid"]);
e6155a06	209
b6eefba5	210	while ($line = db_fetch_assoc($result)) {
e6155a06	211	if (!$filters[$line["name"]]) $filters[$line["name"]] = array();
4b3dff6e	212	array_push($filters[$line["name"]], $line["reg_exp"]);
e6155a06 AD	213	}
e6155a06 AD	214
40d13c28 AD	215	foreach ($rss->items as $item) {
	216
	217	$entry_guid = $item["id"];
	218
	219	if (!$entry_guid) $entry_guid = $item["guid"];
	220	if (!$entry_guid) $entry_guid = $item["link"];
466001c4 AD	221
466001c4 AD	222	if (!$entry_guid) continue;
a116f569	223
9c9c7e6b	224	$entry_timestamp = "";
b82af8c3	225
9c9c7e6b AD	226	$rss_2_date = $item['pubdate'];
	227	$rss_1_date = $item['dc']['date'];
	228	$atom_date = $item['issued'];
b197f117	229
9c9c7e6b AD	230	if ($atom_date != "") $entry_timestamp = parse_w3cdtf($atom_date);
	231	if ($rss_1_date != "") $entry_timestamp = parse_w3cdtf($rss_1_date);
	232	if ($rss_2_date != "") $entry_timestamp = strtotime($rss_2_date);
b82af8c3 AD	233
	234	if ($entry_timestamp == "") {
	235	$entry_timestamp = time();
	236	$no_orig_date = 'true';
466001c4 AD	237	} else {
466001c4 AD	238	$no_orig_date = 'false';
b82af8c3	239	}
b197f117	240
466001c4	241	$entry_timestamp_fmt = strftime("%Y/%m/%d %H:%M:%S", $entry_timestamp);
71ad3959	242
40d13c28 AD	243	$entry_title = $item["title"];
40d13c28 AD	244	$entry_link = $item["link"];
71ad3959 AD	245
	246	if (!$entry_title) continue;
	247	if (!$entry_link) continue;
	248
1696229f AD	249	$entry_content = $item["content:escaped"];
	250
	251	if (!$entry_content) $entry_content = $item["content:encoded"];
40d13c28	252	if (!$entry_content) $entry_content = $item["content"];
1696229f	253	if (!$entry_content) $entry_content = $item["description"];
a2015351	254
a116f569	255	// if (!$entry_content) continue;
a2015351	256
8add756a AD	257	// WTF
	258	if (is_array($entry_content)) {
	259	$entry_content = $entry_content["encoded"];
1696229f	260	if (!$entry_content) $entry_content = $entry_content["escaped"];
8add756a AD	261	}
8add756a AD	262
1696229f AD	263	// print_r($item);
	264	// print_r($entry_content);
	265
466001c4	266	$content_hash = "SHA1:" . sha1(strip_tags($entry_content));
cb0bd8bd	267
a1ea1e12 AD	268	$entry_comments = $item["comments"];
a1ea1e12 AD	269
b6eefba5	270	$entry_guid = db_escape_string($entry_guid);
2651fc4f	271
05732aa0 AD	272	$result = db_query($link, "SELECT id FROM ttrss_entries
05732aa0 AD	273	WHERE guid = '$entry_guid'");
4c193675 AD	274
	275	$owner_uid = $_SESSION["uid"];
	276
b17fcb1a AD	277	$entry_content = db_escape_string($entry_content);
	278	$entry_title = db_escape_string($entry_title);
	279	$entry_link = db_escape_string($entry_link);
	280	$entry_comments = db_escape_string($entry_comments);
	281
4c193675 AD	282	if (db_num_rows($result) == 0) {
	283
	284	// base post entry does not exist, create it
	285
	286	error_reporting(0);
	287	if (is_filtered($entry_title, $entry_content, $filters)) {
	288	continue;
	289	}
	290	error_reporting (E_ERROR \| E_WARNING \| E_PARSE);
	291
4c193675 AD	292	$result = db_query($link,
	293	"INSERT INTO ttrss_entries
	294	(title,
	295	guid,
	296	link,
	297	updated,
	298	content,
	299	content_hash,
	300	no_orig_date,
	301	date_entered,
	302	comments)
	303	VALUES
	304	('$entry_title',
	305	'$entry_guid',
	306	'$entry_link',
	307	'$entry_timestamp_fmt',
	308	'$entry_content',
	309	'$content_hash',
	310	$no_orig_date,
	311	NOW(),
	312	'$entry_comments')");
	313	}
	314
	315	// now it should exist, if not - bad luck then
	316
6385315d AD	317	$result = db_query($link, "SELECT
	318	id,content_hash,no_orig_date,title,
	319	substring(updated,1,19) as updated
	320	FROM
	321	ttrss_entries
	322	WHERE guid = '$entry_guid'");
4c193675 AD	323
	324	if (db_num_rows($result) == 1) {
	325
6385315d AD	326	// this will be used below in update handler
	327	$orig_content_hash = db_fetch_result($result, 0, "content_hash");
	328	// $orig_timestamp = strtotime(db_fetch_result($result, 0, "updated"));
	329	// $orig_no_orig_date = db_fetch_result($result, 0, "no_orig_date");
	330	$orig_title = db_fetch_result($result, 0, "title");
	331
4c193675 AD	332	$ref_id = db_fetch_result($result, 0, "id");
	333
	334	// check for user post link to main table
	335
71604ca4 AD	336	// do we allow duplicate posts with same GUID in different feeds?
	337	if (get_pref($link, "ALLOW_DUPLICATE_POSTS")) {
	338	$dupcheck_qpart = "AND feed_id = '$feed'";
	339	} else {
	340	$dupcheck_qpart = "";
	341	}
	342
4c193675 AD	343	$result = db_query($link,
4c193675 AD	344	"SELECT ref_id FROM ttrss_user_entries WHERE
71604ca4 AD	345	ref_id = '$ref_id' AND owner_uid = '$owner_uid'
71604ca4 AD	346	$dupcheck_qpart");
4c193675 AD	347
4c193675 AD	348	// okay it doesn't exist - create user entry
4c193675	349	if (db_num_rows($result) == 0) {
4c193675 AD	350	$result = db_query($link,
	351	"INSERT INTO ttrss_user_entries
	352	(ref_id, owner_uid, feed_id)
	353	VALUES ('$ref_id', '$owner_uid', '$feed')");
4c193675	354	}
6385315d AD	355
	356	$post_needs_update = false;
	357
	358	if (get_pref($link, "UPDATE_POST_ON_CHECKSUM_CHANGE") &&
	359	($content_hash != $orig_content_hash)) {
	360	$post_needs_update = true;
	361	}
	362
	363	if ($orig_title != $entry_title) {
	364	$post_needs_update = true;
	365	}
	366
	367	// this doesn't seem to be very reliable
	368	//
	369	// if ($orig_timestamp != $entry_timestamp && !$orig_no_orig_date) {
	370	// $post_needs_update = true;
	371	// }
	372
	373	// if post needs update, update it and mark all user entries
1c73bc0c	374	// linking to this post as updated
6385315d AD	375	if ($post_needs_update) {
	376
	377	// print "<!-- post $orig_title needs update : $post_needs_update -->";
	378
6385315d AD	379	db_query($link, "UPDATE ttrss_entries
	380	SET title = '$entry_title', content = '$entry_content'
	381	WHERE id = '$ref_id'");
	382
	383	db_query($link, "UPDATE ttrss_user_entries
	384	SET last_read = null WHERE ref_id = '$ref_id' AND unread = false");
	385
	386	}
4c193675 AD	387	}
4c193675 AD	388
eb36b4eb AD	389	/* taaaags */
	390	// <a href="http://technorati.com/tag/Xorg" rel="tag">Xorg</a>, //
	391
05732aa0	392	$entry_tags = null;
eb36b4eb AD	393
	394	preg_match_all("/<a.?rel=.tag.?>([^>]+)<\/a>/i", $entry_content,
	395	$entry_tags);
	396
	397	$entry_tags = $entry_tags[1];
	398
	399	if (count($entry_tags) > 0) {
	400
05732aa0 AD	401	$result = db_query($link, "SELECT id,int_id
05732aa0 AD	402	FROM ttrss_entries,ttrss_user_entries
25da6909	403	WHERE guid = '$entry_guid'
05732aa0	404	AND feed_id = '$feed' AND ref_id = id
25da6909	405	AND owner_uid = " . $_SESSION["uid"]);
eb36b4eb AD	406
	407	if (!$result \|\| db_num_rows($result) != 1) {
	408	return;
	409	}
	410
	411	$entry_id = db_fetch_result($result, 0, "id");
05732aa0	412	$entry_int_id = db_fetch_result($result, 0, "int_id");
ab15e65d	413
eb36b4eb AD	414	foreach ($entry_tags as $tag) {
	415	$tag = db_escape_string(strtolower($tag));
	416
3b0948c4 AD	417	$tag = str_replace("technorati tag: ", "", $tag);
3b0948c4 AD	418
eb36b4eb	419	$result = db_query($link, "SELECT id FROM ttrss_tags
05732aa0	420	WHERE tag_name = '$tag' AND post_int_id = '$entry_int_id' AND
ab15e65d AD	421	owner_uid = ".$_SESSION["uid"]." LIMIT 1");
	422
	423	// print db_fetch_result($result, 0, "id");
eb36b4eb AD	424
	425	if ($result && db_num_rows($result) == 0) {
	426
	427	// print "tagging $entry_id as $tag<br>";
	428
05732aa0 AD	429	db_query($link, "INSERT INTO ttrss_tags
	430	(owner_uid,tag_name,post_int_id)
	431	VALUES ('".$_SESSION["uid"]."','$tag', '$entry_int_id')");
eb36b4eb AD	432	}
eb36b4eb AD	433	}
05732aa0	434	}
4c193675	435	}
40d13c28	436
ab3d0b99 AD	437	db_query($link, "UPDATE ttrss_feeds
ab3d0b99 AD	438	SET last_updated = NOW(), last_error = '' WHERE id = '$feed'");
eb36b4eb	439
ab3d0b99 AD	440	} else {
	441	$error_msg = db_escape_string(magpie_error());
	442	db_query($link,
aa5f9f5f AD	443	"UPDATE ttrss_feeds SET last_error = '$error_msg',
aa5f9f5f AD	444	last_updated = NOW() WHERE id = '$feed'");
40d13c28 AD	445	}
40d13c28 AD	446
b6eefba5	447	db_query($link, "COMMIT");
f48ba3c9	448
40d13c28 AD	449	}
40d13c28 AD	450
f175937c AD	451	function print_select($id, $default, $values, $attributes = "") {
f175937c AD	452	print "<select id=\"$id\" $attributes>";
a0d53889 AD	453	foreach ($values as $v) {
	454	if ($v == $default)
	455	$sel = " selected";
	456	else
	457	$sel = "";
	458
	459	print "<option$sel>$v</option>";
	460	}
	461	print "</select>";
	462	}
40d13c28	463
e6155a06 AD	464	function is_filtered($title, $content, $filters) {
	465
	466	if ($filters["title"]) {
	467	foreach ($filters["title"] as $title_filter) {
	468	if (preg_match("/$title_filter/i", $title))
	469	return true;
	470	}
	471	}
	472
	473	if ($filters["content"]) {
	474	foreach ($filters["content"] as $content_filter) {
	475	if (preg_match("/$content_filter/i", $content))
	476	return true;
	477	}
	478	}
	479
	480	if ($filters["both"]) {
	481	foreach ($filters["both"] as $filter) {
	482	if (preg_match("/$filter/i", $title) \|\| preg_match("/$filter/i", $content))
	483	return true;
	484	}
	485	}
	486
	487	return false;
	488	}
	489
4668523d	490	function printFeedEntry($feed_id, $class, $feed_title, $unread, $icon_file, $link) {
254e0e4b AD	491
	492	if (file_exists($icon_file) && filesize($icon_file) > 0) {
	493	$feed_icon = "<img src=\"$icon_file\">";
	494	} else {
	495	$feed_icon = "<img src=\"images/blank_icon.gif\">";
	496	}
	497
8143ae1f	498	$feed = "<a href=\"javascript:viewfeed('$feed_id', 0);\">$feed_title</a>";
254e0e4b AD	499
254e0e4b AD	500	print "<li id=\"FEEDR-$feed_id\" class=\"$class\">";
b619ff15	501	if (get_pref($link, 'ENABLE_FEED_ICONS')) {
254e0e4b AD	502	print "$feed_icon";
	503	}
	504
	505	print "<span id=\"FEEDN-$feed_id\">$feed</span>";
	506
	507	if ($unread != 0) {
	508	$fctr_class = "";
	509	} else {
	510	$fctr_class = "class=\"invisible\"";
	511	}
	512
	513	print "<span $fctr_class id=\"FEEDCTR-$feed_id\">
	514	(<span id=\"FEEDU-$feed_id\">$unread</span>)</span>";
	515
	516	print "</li>";
	517
	518	}
	519
406d9489 AD	520	function getmicrotime() {
	521	list($usec, $sec) = explode(" ",microtime());
	522	return ((float)$usec + (float)$sec);
	523	}
	524
77e96719 AD	525	function print_radio($id, $default, $values, $attributes = "") {
	526	foreach ($values as $v) {
	527
	528	if ($v == $default)
5da169d9	529	$sel = "checked";
77e96719	530	else
5da169d9 AD	531	$sel = "";
	532
	533	if ($v == "Yes") {
	534	$sel .= " value=\"1\"";
	535	} else {
	536	$sel .= " value=\"0\"";
	537	}
77e96719 AD	538
	539	print "<input type=\"radio\" $sel $attributes name=\"$id\"> $v ";
	540
	541	}
	542	}
	543
ff485f1d AD	544	function initialize_user_prefs($link, $uid) {
	545
	546	$uid = db_escape_string($uid);
	547
	548	db_query($link, "BEGIN");
	549
	550	$result = db_query($link, "SELECT pref_name,def_value FROM ttrss_prefs");
	551
	552	$u_result = db_query($link, "SELECT pref_name
	553	FROM ttrss_user_prefs WHERE owner_uid = '$uid'");
	554
	555	$active_prefs = array();
	556
	557	while ($line = db_fetch_assoc($u_result)) {
	558	array_push($active_prefs, $line["pref_name"]);
	559	}
	560
	561	while ($line = db_fetch_assoc($result)) {
	562	if (array_search($line["pref_name"], $active_prefs) === FALSE) {
	563	// print "adding " . $line["pref_name"] . "<br>";
	564
	565	db_query($link, "INSERT INTO ttrss_user_prefs
	566	(owner_uid,pref_name,value) VALUES
	567	('$uid', '".$line["pref_name"]."','".$line["def_value"]."')");
	568
	569	}
	570	}
	571
	572	db_query($link, "COMMIT");
	573
	574	}
c8437f35 AD	575
	576	function authenticate_user($link, $login, $password) {
	577
	578	$pwd_hash = 'SHA1:' . sha1($password);
	579
203b6d25	580	$result = db_query($link, "SELECT id,login,access_level FROM ttrss_users WHERE
c8437f35 AD	581	login = '$login' AND (pwd_hash = '$password' OR pwd_hash = '$pwd_hash')");
	582
	583	if (db_num_rows($result) == 1) {
	584	$_SESSION["uid"] = db_fetch_result($result, 0, "id");
	585	$_SESSION["name"] = db_fetch_result($result, 0, "login");
203b6d25	586	$_SESSION["access_level"] = db_fetch_result($result, 0, "access_level");
c8437f35	587
f6f32198 AD	588	db_query($link, "UPDATE ttrss_users SET last_login = NOW() WHERE id = " .
	589	$_SESSION["uid"]);
	590
c8437f35 AD	591	return true;
c8437f35 AD	592	}
ff485f1d	593
c8437f35 AD	594	return false;
	595
	596	}
	597
	598	function http_authenticate_user($link) {
1c7f75ed AD	599
	600	if (!$_SERVER['PHP_AUTH_USER']) {
	601
	602	header('WWW-Authenticate: Basic realm="Tiny Tiny RSS"');
	603	header('HTTP/1.0 401 Unauthorized');
	604	print "<h1>401 Unathorized</h1>";
	605	exit;
	606
	607	} else {
	608
	609	$login = db_escape_string($_SERVER['PHP_AUTH_USER']);
	610	$password = db_escape_string($_SERVER['PHP_AUTH_PW']);
1c7f75ed	611
c8437f35 AD	612	return authenticate_user($link, $login, $password);
c8437f35 AD	613	}
1c7f75ed AD	614	}
1c7f75ed AD	615
e6cb77a0 AD	616	function make_password($length = 8) {
	617
	618	$password = "";
	619	$possible = "0123456789bcdfghjkmnpqrstvwxyz";
	620
	621	$i = 0;
	622
	623	while ($i < $length) {
	624	$char = substr($possible, mt_rand(0, strlen($possible)-1), 1);
	625
	626	if (!strstr($password, $char)) {
	627	$password .= $char;
	628	$i++;
	629	}
	630	}
	631	return $password;
	632	}
	633
	634	// this is called after user is created to initialize default feeds, labels
	635	// or whatever else
	636
	637	// user preferences are checked on every login, not here
	638
	639	function initialize_user($link, $uid) {
	640
	641	db_query($link, "insert into ttrss_labels (owner_uid,sql_exp,description)
	642	values ('$uid','unread = true', 'Unread articles')");
	643
	644	db_query($link, "insert into ttrss_labels (owner_uid,sql_exp,description)
	645	values ('$uid','last_read is null and unread = false', 'Updated articles')");
	646
	647	db_query($link, "insert into ttrss_feeds (owner_uid,title,feed_url)
	648	values ('$uid', 'Tiny Tiny RSS Dev. Feed',
	649	'http://bah.spb.su/darcsweb/darcsweb.cgi?r=tt-rss;a=rss')");
	650
	651	}
	652
40d13c28	653	?>