File Source for rss

<?php
/**
* @version $Header: /cvsroot/bitweaver/_bit_rss/rss_lib.php,v 1.11 2007/01/06 09:46:24 squareing Exp $
* @package rss
*
* Copyright (c) 2004 bitweaver.org
* Copyright (c) 2003 tikwiki.org
* Copyright (c) 2002-2003, Luis Argerich, Garland Foster, Eduardo Polidor, et. al.
* All Rights Reserved. See copyright.txt for details and a complete list of authors.
* Licensed under the GNU LESSER GENERAL PUBLIC LICENSE. See license.txt for details
*
* $Id: rss_lib.php,v 1.11 2007/01/06 09:46:24 squareing Exp $
*/
/**
* @package rss
*/
class RSSLib extends BitBase {
function RSSLib() {
BitBase::BitBase();
}
function list_rss_modules($offset, $max_records, $sort_mode, $find) {
if ($find) {
$findesc="%" . $find . "%";
$mid = " where (`name` like ? or `description` like ?)";
$bindvars=array($findesc,$findesc);
} else {
$mid = "";
$bindvars=array();
}
$query = "select * from `".BIT_DB_PREFIX."rss_modules` $mid order by ".$this->mDb->convertSortmode($sort_mode);
$query_cant = "select count(*) from `".BIT_DB_PREFIX."rss_modules` $mid";
$result = $this->mDb->query($query,$bindvars,$max_records,$offset);
$cant = $this->mDb->getOne($query_cant,$bindvars);
$ret = array();
while ($res = $result->fetchRow()) {
$res["minutes"] = $res["refresh"] / 60;
$ret[] = $res;
}
$retval = array();
$retval["data"] = $ret;
$retval["cant"] = $cant;
return $retval;
}
function replace_rss_module($rss_id, $name, $description, $url, $refresh, $show_title, $show_pub_date) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
//if($this->rss_module_name_exists($name)) return false; // TODO: Check the name
$refresh = 60 * $refresh;
if ($rss_id) {
$query = "update `".BIT_DB_PREFIX."rss_modules` set `name`=?,`description`=?,`refresh`=?,`url`=?,`show_title`=?,`show_pub_date`=? where `rss_id`=?";
$bindvars=array($name,$description,$refresh,$url,$show_title,$show_pub_date,$rss_id);
} else {
// was: replace into, no clue why.
$query = "insert into `".BIT_DB_PREFIX."rss_modules`(`name`,`description`,`url`,`refresh`,`content`,`last_updated`,`show_title`,`show_pub_date`)
values(?,?,?,?,?,?,?,?)";
$bindvars=array($name,$description,$url,$refresh,'',1000000,$show_title,$show_pub_date);
}
$result = $this->mDb->query($query,$bindvars);
$ret = true;
}
return $ret;
}
function remove_rss_module($rss_id) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
$query = "delete from `".BIT_DB_PREFIX."rss_modules` where `rss_id`=?";
$result = $this->mDb->query($query,array($rss_id));
$ret = true;
}
return $ret;
}
function get_rss_module($rss_id) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
$query = "select * from `".BIT_DB_PREFIX."rss_modules` where `rss_id`=?";
$result = $this->mDb->query($query,array($rss_id));
if (!$result->numRows())
return false;
$ret = $result->fetchRow();
}
return $ret;
}
function startElementHandler($parser, $name, $attribs) {
if ($this->flag) {
$this->buffer .= '<' . $name . '>';
}
if ($name == 'item' || $name == 'items') {
$this->flag = 1;
}
}
function endElementHandler($parser, $name) {
if ($name == 'item' || $name == 'items') {
$this->flag = 0;
}
if ($this->flag) {
$this->buffer .= '</' . $name . '>';
}
}
function characterDataHandler($parser, $data) {
if ($this->flag) {
$this->buffer .= $data;
}
}
function NewsFeed($data, $rss_id) {
$news = array();
if( is_numeric( $rss_id ) ) {
$show_pub_date = $this->get_rss_show_pub_date($rss_id);
$this->buffer = '';
$this->flag = 0;
$this->parser = xml_parser_create("UTF-8");
xml_parser_set_option($this->parser, XML_OPTION_CASE_FOLDING, false);
xml_set_object($this->parser, $this);
xml_set_element_handler($this->parser, "startElementHandler", "endElementHandler");
xml_set_character_data_handler($this->parser, "characterDataHandler");
if (!xml_parse($this->parser, $data, 1)) {
# print ("<!-- XML Parse error at " . xml_get_current_line_number($this->parser) . ": "
# . xml_error_string(xml_get_error_code($this->parser)) . " -->\n");
$news[] = array('title'=>
"XML Parse error at " . xml_get_current_line_number($this->parser) . ": "
. xml_error_string(xml_get_error_code($this->parser)) . "",
'link'=>'',
'pubdate'=>'',
);
return $news;
}
xml_parser_free ($this->parser);
preg_match_all("/<title>(.*?)<\/title>/i", $this->buffer, $titles);
preg_match_all("/<link>(.*?)<\/link>/i", $this->buffer, $links);
$pubdate = array();
preg_match_all("/<dc:date>(.*?)<\/dc:date>/i", $this->buffer, $pubdate);
if (count($pubdate[1])<1)
preg_match_all("/<pubDate>(.*?)<\/pubDate>/i", $this->buffer, $pubdate);
for ($i = 0; $i < count($titles[1]); $i++) {
$anew["title"] = $titles[1][$i];
if (isset($links[1][$i])) {
$anew["link"] = $links[1][$i];
} else {
$anew["link"] = '';
}
if ( isset($pubdate[1][$i]) && ($show_pub_date == 'y') )
{
$anew["pubdate"] = $pubdate[1][$i];
} else {
$anew["pubdate"] = '';
}
$news[] = $anew;
}
}
return $news;
}
function parse_rss_data($rssdata, $rss_id) {
return $this->NewsFeed($rssdata, $rss_id);
}
function refresh_rss_module($rss_id) {
$info = $this->get_rss_module($rss_id);
if ($info) {
global $gBitSystem;
$data = $this->rss_iconv( tp_http_request($info['url']));
$now = $gBitSystem->getUTCTime();
$query = "update `".BIT_DB_PREFIX."rss_modules` set `content`=?, `last_updated`=? where `rss_id`=?";
$result = $this->mDb->query($query,array((string)$data,(int) $now, (int) $rss_id));
return $data;
} else {
return false;
}
}
function rss_module_name_exists($name) {
$query = "select `name` from `".BIT_DB_PREFIX."rss_modules` where `name`=?";
$result = $this->mDb->query($query,array($name));
return $result->numRows();
}
function get_rss_module_id($name) {
$query = "select `rss_id` from `".BIT_DB_PREFIX."rss_modules` where `name`=?";
$id = $this->mDb->getOne($query,array($name));
return $id;
}
function get_rss_show_title($rss_id) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
$query = "select `show_title` from `".BIT_DB_PREFIX."rss_modules` where `rss_id`=?";
$ret = $this->mDb->getOne($query,array($rss_id));
}
return $ret;
}
function get_rss_show_pub_date($rss_id) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
$query = "select `show_pub_date` from `".BIT_DB_PREFIX."rss_modules` where `rss_id`=?";
$show_pub_date = $this->mDb->getOne($query,array($rss_id));
$ret = $show_pub_date;
}
return $ret;
}
function get_rss_module_content($rss_id) {
$ret = FALSE;
if( is_numeric( $rss_id ) ) {
if( $info = $this->get_rss_module($rss_id) ) {
global $gBitSystem;
$now = $gBitSystem->getUTCTime();
// if ($info["last_updated"] + $info["refresh"] < $now) {
$data = $this->refresh_rss_module($rss_id);
// }
$info = $this->get_rss_module($rss_id);
$ret = $info["content"];
}
}
return $ret;
}
function rss_iconv($xmlstr, $tencod = "UTF-8") {
if (preg_match("/<\?xml.*encoding=\"(.*)\".*\?>/", $xmlstr, $xml_head)) {
$sencod = strtoupper($xml_head[1]);
switch ($sencod) {
case "ISO-8859-1":
// Use utf8_encode a more standard function
$xmlstr = utf8_encode($xmlstr);
break;
case "UTF-8":
case "US-ASCII":
// UTF-8 and US-ASCII don't need convertion
break;
default:
// Not supported encoding, we must use iconv() or recode()
if (function_exists('iconv')) {
// We have iconv use it
$new_xmlstr = @iconv($sencod, $tencod, $xmlstr);
if ($new_xmlstr === FALSE) {
// in_encod -> out_encod not supported, may be misspelled encoding
$sencod = strtr($sencod, array(
"-" => "",
"_" => "",
" " => ""
));
$new_xmlstr = @iconv($sencod, $tencod, $xmlstr);
if ($new_xmlstr === FALSE) {
// in_encod -> out_encod not supported, leave it
$tencod = $sencod;
break;
}
}
$xmlstr = $new_xmlstr;
// Fix an iconv bug, a few garbage chars beyound xml...
$xmlstr = preg_replace("/(.*<\/rdf:RDF>).*/s", "\$1", $xmlstr);
} elseif (function_exists('recode_string')) {
// I don't have recode support could somebody test it?
$xmlstr = @recode_string("$sencod..$tencod", $xmlstr);
} else {
// This PHP intallation don't have any EncodConvFunc...
// somebody could create bit_iconv(...)?
}
}
// Replace header, put the new encoding
$xmlstr = preg_replace("/(<\?xml.*)encoding=\".*\"(.*\?>)/", "\$1 encoding=\"$tencod\"\$2", $xmlstr);
}
return $xmlstr;
}
}
global $rsslib;
$rsslib = new RSSLib();
?>

Source for file rss_lib.php