$message\n";
return;
}
if (!isset($GLOBALS['rss'])) {
rss_require('cls/rss.php');
}
$GLOBALS['rss'] -> error($message, $severity);
}
/** this functions checks whether a URI exists */
function getHttpResponseCode($forUri) {
return getUrl($forUri, 255);
}
function getContentType($link, & $contentType) {
$url_parts = @ parse_url($link);
if (empty ($url_parts["host"])) {
return (false);
}
if (!empty ($url_parts["path"])) {
$documentpath = $url_parts["path"];
} else {
$documentpath = "/";
}
if (!empty ($url_parts["query"])) {
$documentpath .= "?".$url_parts["query"];
}
$host = $url_parts["host"];
$port = (array_key_exists('port', $url_parts) ? $url_parts["port"] : "80");
$socket = @ fsockopen($host, $port, $errno, $errstr, 30);
if (!$socket) {
return (false);
}
$ret = false;
fwrite($socket, "GET ".$documentpath." HTTP/1.0\r\nHost: $host\r\n\r\n");
while (!feof($socket)) {
$line = fgets($socket, 100);
if (preg_match("/Content-Type: (.*)/i", $line, $matches)) {
$contentType = $matches[1];
$ret = true;
break;
}
}
return $ret;
}
// basically strips folder resources from URIs.
// http://pear.php.net/package/HTTP_Client/ --> http://pear.php.net/
function get_host($url, & $host) {
$ret = preg_match("/^(http:\/\/)?([^\/]+)/i", $url, $matches);
$host = $matches[2];
//ensure we have a slash
if (substr($host, -1) != "/") {
$host .= "/";
}
return $ret;
}
/**
* Builds a title out of an already encoded strings.
*/
function makeTitle($title) {
$ret = ""._TITLE_."";
if ($title != "") {
$ret .= " ".TITLE_SEP." ".$title;
}
return $ret;
}
/*** update the given feed(s) **/
function update($id) {
$kses_allowed = getConfig('rss.input.allowed'); //getAllowedTags();
$updatedIds = array ();
$sql = "select id, url, title, mode from ".getTable("channels");
if ($id != "" && is_numeric($id)) {
$sql .= " where id=$id";
$sql .= " and not(mode & ".FEED_MODE_DELETED_STATE.") ";
} else{
$sql .= " where not(mode & ".FEED_MODE_DELETED_STATE.") ";
}
if (getConfig('rss.config.absoluteordering')) {
$sql .= " order by parent, position";
} else {
$sql .= " order by parent, title";
}
$res = rss_query($sql);
while (list ($cid, $url, $title, $mode) = rss_fetch_row($res)) {
// suppress warnings because Magpie is rather noisy
$old_level = error_reporting(E_ERROR);
$rss = fetch_rss($url);
//reset
error_reporting($old_level);
if (!$rss && $id != "" && is_numeric($id)) {
return array (magpie_error(), array ());
}
elseif (!$rss) {
continue;
}
// base URL for items in this feed.
if (array_key_exists('link', $rss->channel)) {
$baseUrl = $rss->channel['link'];
} else {
$baseUrl = "";
}
foreach ($rss->items as $item) {
$item = rss_plugin_hook('rss.plugins.rssitem', $item);
// a plugin might delete this item
if(!isset($item)) continue;
// item title: strip out html tags, shouldn't supposed
// to have any, should it?
//$title = strip_tags($item['title']);
$title = array_key_exists('title', $item) ? strip_tags($item['title']) : "";
//$title = str_replace('& ', '& ', $title);
// item content, if any
if (array_key_exists('content', $item) && is_array($item['content']) && array_key_exists('encoded', $item['content'])) {
$description = kses($item['content']['encoded'], $kses_allowed);
} elseif (array_key_exists('description', $item)) {
$description = kses($item['description'], $kses_allowed);
} elseif (array_key_exists('atom_content', $item)) {
$description = kses($item['atom_content'], $kses_allowed);
} elseif (array_key_exists('summary', $item)) {
$description = kses($item['summary'], $kses_allowed);
} else {
$description = "";
}
if ($description != "" && $baseUrl != "") {
//$description = make_abs($description, $baseUrl);
$description = relative_to_absolute($description, $baseUrl);
}
if ($description != "") {
$description = rss_plugin_hook('rss.plugins.import.description', $description);
}
// link
if (array_key_exists('link', $item) && $item['link'] != "") {
$url = $item['link'];
} elseif (array_key_exists('guid', $item) && $item['guid'] != "") {
$url = $item['guid'];
} elseif (array_key_exists('link_', $item) && $item['link_'] != "") {
$url = $item['link_'];
} else {
// fall back to something basic
$url = md5($title);
}
// make sure the url is properly escaped
$url = htmlentities(str_replace("'", "\\'", $url));
// author
if (array_key_exists('dc', $item) && array_key_exists('creator', $item['dc'])) {
// RSS 1.0
$author = $item['dc']['creator'];
} else if (array_key_exists('author_name', $item)) {
// Atom 0.3
$author = $item['author_name'];
} else {
$author = "";
}
$author = strip_tags($author);
// pubdate
$cDate = -1;
if (array_key_exists('dc', $item) && array_key_exists('date', $item['dc'])) {
// RSS 1.0
$cDate = parse_w3cdtf($item['dc']['date']);
} elseif (array_key_exists('pubdate', $item)) {
// RSS 2.0 (?)
$cDate = strtotime($item['pubdate']);
} elseif (array_key_exists('created', $item)) {
// atom
$cDate = parse_iso8601($item['created']);
} elseif (array_key_exists('issued', $item)) {
//Atom, alternative
$cDate = parse_iso8601($item['issued']);
}
// drop items with an url exceeding our column length: we couldn't provide a
// valid link back anyway.
if (strlen($url) >= 255) {
continue;
}
$dbtitle = rss_real_escape_string($title);
// check wether we already have this item
$sql = "select id,length(description),unread from ".getTable("item")." where cid=$cid and url='$url' and title='$dbtitle'";
$subres = rss_query($sql);
list ($indb, $dbdesc_len, $state) = rss_fetch_row($subres);
if ($cDate > 0) {
$sec = "FROM_UNIXTIME($cDate)";
} else {
$sec = "null";
}
if ($indb == "") {
list ($cid, $dbtitle, $url, $description)
= rss_plugin_hook('rss.plugins.items.new', array ($cid, $dbtitle, $url, $description));
$sql = "insert into ".getTable("item")
." (cid, added, title, url, "." description, author, unread, pubdate) "
." values ("."$cid, now(), '$dbtitle', "
." '$url', '".rss_real_escape_string($description)."', '"
.rss_real_escape_string($author)."', "
."$mode, $sec)";
rss_query($sql);
$newIid = rss_insert_id();
$updatedIds[] = $newIid;
/*
* Ticket #26: Add hook to modify the item just after it
* has been inserted into the database
*/
rss_plugin_hook('rss.plugins.items.newiid',array($newIid,$item));
}
elseif (!($state & FEED_MODE_DELETED_STATE) &&
getConfig('rss.input.allowupdates') &&
strlen($description) > $dbdesc_len) {
list ($cid, $indb, $description) =
rss_plugin_hook('rss.plugins.items.updated', array ($cid, $indb, $description));
$sql = "update ".getTable("item")
." set "." description='".rss_real_escape_string($description)."', "
." unread = unread | ".FEED_MODE_UNREAD_STATE." where cid=$cid and id=$indb";
rss_query($sql);
$updatedIds[] = $indb;
}
}
}
if ($id != "" && is_numeric($id)) {
if ($rss) {
// when everything went well, return the error code
// and numer of new items
return array ($rss->rss_origin, $updatedIds);
} else {
return array (-1, array ());
}
} else {
return array (-1, $updatedIds);
}
}
function getRootFolder(){
$sql = "select id from ".getTable("folders")."where name = '' order by position asc limit 1";
list($root) = rss_fetch_row(rss_query($sql));
if (!$root) {
$root = 0;
}
return $root;
}
function add_channel($url, $folderid = 0, $title_=null,$descr_=null) {
if (!$url || strlen($url) <= 7) {
return array (-2, "Invalid URL $url");
}
if (!is_numeric($folderid)) {
return array (-2, "Invalid folderid $folderid");
}
$url = str_replace('&','&',$url);
$urlDB = $url; //htmlentities($url);
$res = rss_query("select count(*) as channel_exists from ".getTable("channels")." where url='$urlDB'");
list ($channel_exists) = rss_fetch_row($res);
if ($channel_exists > 0) {
// fatal
return array (-2, "Looks like you are already subscribed to this channel");
}
$res = rss_query("select 1+max(position) as np from ".getTable("channels"));
list ($np) = rss_fetch_row($res);
if (!$np) {
$np = "0";
}
// Here we go!
//error_reporting(E_ALL);
$old_level = error_reporting(E_ERROR);
$rss = fetch_rss($url);
error_reporting($old_level);
if ($rss) {
if ($title_) {
$title = rss_real_escape_string($title_);
} elseif (is_object($rss) && array_key_exists('title', $rss->channel)) {
$title = rss_real_escape_string($rss->channel['title']);
} else {
$title = "";
}
if (is_object($rss) && array_key_exists('link', $rss->channel)) {
$siteurl = rss_real_escape_string(htmlentities($rss->channel['link']));
} else {
$siteurl = "";
}
if ($descr_) {
$descr = rss_real_escape_string($descr_);
} elseif (is_object($rss) && array_key_exists('description', $rss->channel)) {
$descr = rss_real_escape_string($rss->channel['description']);
} else {
$descr = "";
}
//lets see if this server has a favicon
$icon = "";
if (getConfig('rss.output.showfavicons')) {
// if we got nothing so far, lets try to fall back to
// favicons
if ($icon == "" && $siteurl != "") {
$match = get_host($siteurl, $host);
$uri = "http://".$host."favicon.ico";
if ($match && getContentType($uri, $contentType)) {
if (preg_match("/image\/x-icon/", $contentType)) {
$icon = $uri;
}
}
}
}
$private = preg_match('|(https?://)([^:]+:[^@]+@)(.+)$|',$url);
if ($title != "") {
$title = strip_tags($title);
$descr = strip_tags($descr);
// add channel to root folder by default
if(!$folderid){ $folderid = getRootFolder(); }
list($title,$urlDB,$siteurl,$folderid,$descr,$icon) =
rss_plugin_hook('rss.plugins.feed.new',
array ($title,$urlDB,$siteurl,$folderid,$descr,$icon));
$mode = FEED_MODE_UNREAD_STATE;
if ($private) {
$mode |= FEED_MODE_PRIVATE_STATE;
}
$sql = "insert into ".getTable("channels")
." (title, url, siteurl, parent, descr, dateadded, icon, position, mode)"
." values ('$title', '$urlDB', '$siteurl', $folderid, '$descr', now(), '$icon', $np, $mode)";
rss_query($sql);
$newid = rss_insert_id();
return array ($newid, "");
} else {
// non-fatal, will look further
return array (-1, "I'm sorry, I couldn't extract a valid RSS feed from $url.");
}
} else {
global $MAGPIE_ERROR;
$retError = "I'm sorry, I couldn't retrieve $url.";
if ($MAGPIE_ERROR) {
$retError .= "\n
$MAGPIE_ERROR\n";
}
// non-fatal, will look further
return array (-1, $retError);
}
}
/**
* Replaces relative urls with absolute ones for anchors and images
* Credits: Julien Mudry
*/
function relative_to_absolute($content, $feed_url) {
preg_match('/(http|https|ftp):\/\//', $feed_url, $protocol);
$server_url = preg_replace("/(http|https|ftp|news):\/\//", "", $feed_url);
$server_url = preg_replace("/\/.*/", "", $server_url);
if ($server_url == '') {
return $content;
}
if (isset($protocol[0])) {
$new_content = preg_replace('/href="\//', 'href="'.$protocol[0].$server_url.'/', $content);
$new_content = preg_replace('/src="\//', 'src="'.$protocol[0].$server_url.'/', $new_content);
} else {
$new_content = $content;
}
return $new_content;
}
/**
* parse an ISO 8601 date, losely based on parse_w3cdtf from MagpieRSS
*/
function parse_iso8601($date_str) {
# regex to match wc3dtf
$pat = "/(\d{4})-?(\d{2})-?(\d{2})T?(\d{2}):?(\d{2})(:?(\d{2}))?(?:([-+])(\d{2}):?(\d{2})|(Z))?/";
if (preg_match($pat, $date_str, $match)) {
list ($year, $month, $day, $hours, $minutes, $seconds)
= array ($match[1], $match[2], $match[3], $match[4], $match[5], $match[6]);
# calc epoch for current date assuming GMT
$epoch = gmmktime($hours, $minutes, $seconds, $month, $day, $year);
$offset = 0;
if ($match[10] == 'Z') {
# zulu time, aka GMT
} else {
list ($tz_mod, $tz_hour, $tz_min) = array ($match[8], $match[9], $match[10]);
# zero out the variables
if (!$tz_hour) {
$tz_hour = 0;
}
if (!$tz_min) {
$tz_min = 0;
}
$offset_secs = (($tz_hour * 60) + $tz_min) * 60;
# is timezone ahead of GMT? then subtract offset
#
if ($tz_mod == '+') {
$offset_secs = $offset_secs * -1;
}
$offset = $offset_secs;
}
$epoch = $epoch + $offset;
return $epoch;
} else {
return -1;
}
}
/**
* Returns the relative path of the install dir, e.g:
* http://host.com/thing/ -> "/thing/"
* http://host.com/ -> "/"
*/
function getPath() {
static $ret;
$ret = dirname($_SERVER['PHP_SELF']);
if (defined('RSS_FILE_LOCATION') && eregi(RSS_FILE_LOCATION."\$", $ret)) {
$ret = substr($ret, 0, strlen($ret) - strlen(RSS_FILE_LOCATION));
}
if (substr($ret, -1) != "/") {
$ret .= "/";
}
return $ret;
}
/**
* builds an url for an archive link
*/
function makeArchiveUrl($ts, $channel, $cid, $dayView) {
if (getConfig('rss.output.usemodrewrite')) {
return (getPath()."$channel/".rss_date(($dayView ? 'Y/m/d/' : 'Y/m/'), $ts, false));
} else {
return (getPath()."feed.php?channel=$cid&y=".rss_date('Y', $ts, false)
."&m=".rss_date('m', $ts, false). ($dayView ? ("&d=".rss_date('d', $ts, false)) : ""));
}
}
/**
* Fetches a remote URL and returns the content
*/
function getUrl($url, $maxlen = 0) {
//Bug: in windows, scheme returned by parse_url contains the drive letter
//of the file so a test like !isset(scheme) does not work
//maybe it would be better to only use is_file() which only detect
//local files?
$urlParts = parse_url($url);
if (is_file($url) || (!isset($urlParts['scheme']) && !isset($urlParts['host'])) ) {
//local file!
$c = "";
$h = @fopen($url, "r");
while (!feof($h)) {
$c .= @fread($h, 8192);
}
@fclose($h);
return $c;
}
rss_require('extlib/Snoopy.class.inc');
$client = new Snoopy();
$client->agent = MAGPIE_USER_AGENT;
$client->use_gzip = getConfig('rss.output.compression');
if ($maxlen) {
$client->maxlength = $maxlen;
}
@ $client->fetch($url);
return $client->results;
}
/**
* returns an array of all (hopefully) rss/atom/rdf feeds in the document,
* pointed by $url
*/
function extractFeeds($url) {
$cnt = getUrl($url);
$ret = array ();
//find all link tags
if (preg_match_all('|]*>|Ui', $cnt, $res)) {
while (list ($id, $match) = each($res[0])) {
// we only want ' attr_value
while (list ($id2, $match2) = each($res2)) {
$attr = strtolower(trim($match2[1]));
$val = trim($match2[2]);
// make sure we have absolute URI's
if (($attr == "href") && strcasecmp(substr($val, 0, 4), "http") != 0) {
// Check to see if the relative url starts with "//"
if(substr($val,0,2) == "//") {
$val = preg_replace('/\/\/.*/', $val, $url);
} else {
$val = ($url.$val);
}
}
$tmp[$attr] = $val;
}
$ret[] = $tmp;
}
}
}
return $ret;
}
function real_strip_slashes($string) {
if (stripslashes($string) == $string) {
return $string;
}
return real_strip_slashes(stripslashes($string));
}
function rss_htmlspecialchars($in) {
return htmlspecialchars($in, ENT_NOQUOTES,
(getConfig('rss.output.encoding') ? getConfig('rss.output.encoding') : DEFAULT_OUTPUT_ENCODING));
}
function firstNwords($text, $count=7) {
$new = "";
$expr = '/(.+?\s+){1,' . $count . '}/';
if ( preg_match($expr, $text, $matches) ) {
$result = $matches[0] . '...';
$new = preg_replace('/(\r\n|\r|\n)/', ' ', $result);
$new = strip_tags($new);
}
return $new;
}
function showViewForm($curValue) {
//default: read and unread!
$readAndUndredaSelected = " selected=\"selected\"";
$unreadOnlySelected = "";
if ($curValue == SHOW_UNREAD_ONLY) {
$readAndUndredaSelected = "";
$unreadOnlySelected = " selected=\"selected\"";
}
// post back to self, we should be able to handle the request, shouldn't we.
echo "\n\n";
}
define('PRIVATE_COOKIE', 'prv');
function getPrivateCookieVal($prefix = DBUNAME) {
$val = $prefix.$_SERVER["SERVER_NAME"];
if (defined('ADMIN_USERNAME') && defined('ADMIN_PASSWORD')) {
$val .= ADMIN_USERNAME.ADMIN_PASSWORD;
} elseif (defined('ADMIN_USERNAME')) {
$val .= ADMIN_USERNAME;
}
return md5($val);
}
function logoutPrivateCookie() {
if (array_key_exists(PRIVATE_COOKIE, $_COOKIE)) {
unset($_COOKIE[PRIVATE_COOKIE]);
setcookie(PRIVATE_COOKIE, "", -1, getPath());
}
}
function hidePrivate() {
static $ret;
if ($ret == null) {
if (!array_key_exists(PRIVATE_COOKIE, $_COOKIE)) {
$ret = true;
} else {
$ret = !($_COOKIE[PRIVATE_COOKIE] == getPrivateCookieVal());
}
}
return $ret;
}
function getThemePath() {
$ret = getPath().RSS_THEME_DIR."/";
if (($theme = getConfig('rss.output.theme')) != null) {
$ret .= $theme."/";
} else {
$ret .= "default/";
}
return $ret;
}
function getUnreadCount($cid, $fid) {
static $_uccache = array();
$key_ = "key $cid $fid key";
if (isset($_uccache[$key_])) {
return $_uccache[$key_];
}
$sql = "select count(*) from "
.getTable("item") ."i, ".getTable('channels')."c "
." where i.unread & ".FEED_MODE_UNREAD_STATE. " and not(i.unread & " .
FEED_MODE_DELETED_STATE .") and i.cid=c.id "
." and not(c.mode & ".FEED_MODE_DELETED_STATE.") ";
if (hidePrivate()) {
$sql .= " and not(i.unread & ".FEED_MODE_PRIVATE_STATE.")";
}
if ($cid) {
$sql .= " and c.id=$cid ";
}
elseif ($fid) {
$sql .= " and c.parent=$fid ";
}
$res = rss_query($sql);
list ($_uccache[$key_]) = rss_fetch_row($res);
return $_uccache[$key_];
}
function rss_locale_date ($fmt, $ts, $addTZOffset = true) {
if (isset($_SERVER["WINDIR"])) {
//%e doesnt' exists under windows!
$fmt=str_replace("%e","%#d",$fmt);
}
if ($addTZOffset) {
return utf8_encode(strftime($fmt, $ts +3600 * getConfig('rss.config.tzoffset')));
}
return utf8_encode(strftime($fmt, $ts));
}
function rss_date($fmt, $ts, $addTZOffset = true) {
if ($addTZOffset) {
return date($fmt, $ts +3600 * getConfig('rss.config.tzoffset'));
}
return date($fmt, $ts);
}
function _pf($msg) {
if (defined('PROFILING') && PROFILING) {
$GLOBALS['rss'] -> _pf($msg);
}
}
function guessTransportProto() {
if (defined ('RSS_SERVER_PROTO')) {
return RSS_SERVER_PROTO;
}
if (array_key_exists("SERVER_PORT",$_SERVER)) {
if ($_SERVER["SERVER_PORT"] == 443) {
$proto = "https://";
} else {
$proto = "http://";
}
} else {
// best effort
$proto = "http://";
}
return $proto;
}
function rss_redirect($url = "") {
header("Location: " .
(guessTransportProto() . $_SERVER['HTTP_HOST'] . getPath() . $url));
}
/*
fixes #117.
http://www.php.net/manual/en/function.getallheaders.php
*/
function rss_getallheaders() {
$headers = array();
foreach($_SERVER as $h=>$v) {
if(ereg('HTTP_(.+)',$h,$hp)) {
$headers[$hp[1]]=$v;
}
}
return $headers;
}
// moved from ajax.php
function __exp__submitTag($id,$tags,$type = "'item'") {
$ftags = preg_replace(ALLOWED_TAGS_REGEXP,'', trim($tags));
$tarr = array_slice(explode(" ",$ftags),0,MAX_TAGS_PER_ITEM);
$ftags = implode(" ",__priv__updateTags($id,$tarr,$type));
return "$id,". $ftags;
}
function __priv__updateTags($fid,$tags,$type) {
rss_query("delete from " .getTable('metatag')
. " where fid=$fid and ttype=$type");
$ret = array();
foreach($tags as $tag) {
$ttag = trim($tag);
if ($ttag == "" || in_array($ttag,$ret)) {
continue;
}
rss_query( "insert into ". getTable('tag')
. " (tag) values ('$ttag')", false );
$tid = 0;
if(rss_is_sql_error(RSS_SQL_ERROR_DUPLICATE_ROW)) {
list($tid)=rss_fetch_row(rss_query("select id from "
.getTable('tag') . " where tag='$ttag'"));
} else {
$tid = rss_insert_id();
}
if ($tid) {
rss_query( "insert into ". getTable('metatag')
. " (fid,tid,ttype,tdate) values ($fid,$tid,$type,now())" );
if (rss_is_sql_error(RSS_SQL_ERROR_NO_ERROR)) {
$ret[] = $ttag;
}
}
}
sort($ret);
return $ret;
}
/**
* this was taken straight from WordPress
*/
function utf8_uri_encode( $utf8_string ) {
$unicode = '';
$values = array();
$num_octets = 1;
for ($i = 0; $i < strlen( $utf8_string ); $i++ ) {
$value = ord( $utf8_string[ $i ] );
if ( $value < 128 ) {
$unicode .= chr($value);
} else {
if ( count( $values ) == 0 ) $num_octets = ( $value < 224 ) ? 2 : 3;
$values[] = $value;
if ( count( $values ) == $num_octets ) {
if ($num_octets == 3) {
$unicode .= '%' . dechex($values[0]) . '%' . dechex($values[1]) . '%' . dechex($values[2]);
} else {
$unicode .= '%' . dechex($values[0]) . '%' . dechex($values[1]);
}
$values = array();
$num_octets = 1;
}
}
}
return $unicode;
}
function ETagHandler($key) {
if (array_key_exists('HTTP_IF_NONE_MATCH',$_SERVER) &&
$_SERVER['HTTP_IF_NONE_MATCH'] == $key) {
header("HTTP/1.1 304 Not Modified");
flush();
exit();
} else {
header("ETag: $key");
// ob_start('ob_gzhandler');
}
}
//these two eval_ functions taken from the comments at http://us3.php.net/eval
function eval_mixed_helper($arr){
return ("echo stripslashes(\"".addslashes($arr[1])."\");");
}
function eval_mixed($string){
$string = "".$string."";
$string = preg_replace("/<\?=\s+(.*?)\s+\?>/", "", $string);
$string = str_replace('?>', '', str_replace( array('((.|\n)*?)<\?(php)?/","eval_mixed_helper",$string) ) );
return $string;
}
?>