<?php

class rss
{

	function rss (){
	}
	// BEGIN of functions.
	function getContent($param){
		$daurl=$param['url'];
		if (preg_match('/http(s)?:\/\//i',$daurl,$matches) == 0)
			$daurl = 'http://'.$daurl;

		// Set your return content type
		header('Content-type: application/xml');

		// Get that website's content
		$handle = fopen($daurl, "r");

		// If there is something, read and return
		if ($handle) {
			$buffer = fgets($handle, 4096);
			$pattern = '/<\?xml version=".\.0"( encoding="[A-Z\-0-9]+")?\ *\?>/i';
			if (preg_match($pattern,$buffer,$matches) == 0)
				exit;
			echo $buffer;
			while (!feof($handle)) {
				$buffer = fgets($handle, 4096);
				echo $buffer;
			}
			fclose($handle);
		}
		exit;
	}

	private function createTableRSS()
	{
		$query = 'CREATE TABLE phpgw_userrss( uid INT NOT NULL,rss_url VARCHAR(1000),name varchar(50), PRIMARY KEY (uid,rss_url) );';
		
		$GLOBALS['phpgw']->db->query($query);
		
		if ( $GLOBALS['phpgw']->db->Error )
			return false;
		else
			return true;
	}
	
	function getChannels()
	{
		include('../header.inc.php');
		
		$flag 		= false;
		$tableQuery = "select relname from pg_stat_user_tables order by relname;";
		
		if( $GLOBALS['phpgw']->db->query( $tableQuery ) )
		{
			while( $GLOBALS['phpgw']->db->next_record() )
			{
				$tables[] = $GLOBALS['phpgw']->db->row();
			}
			
			foreach( $tables as $tableName )
			{
				if( strtolower( $tableName['relname'] ) === 'phpgw_userrss' )
				{
					$flag = true;
				}
			}
		}
		
		if( !$flag )
		{
			$flag = $this->createTableRSS();
		}
		
		$query = 'SELECT rss_url,name FROM phpgw_userrss WHERE uid = '.$_SESSION['phpgw_session']['account_id'];		
		
		if( $GLOBALS['phpgw']->db->query($query) ) 
		{
			while( $GLOBALS['phpgw']->db->next_record() )
			{
				$return[] = $GLOBALS['phpgw']->db->row();
			}
		}

		if( count($return) > 0 )
			return $return;
		else
			return "";
	}
	
	function addChannel($param)
	{
		include('../header.inc.php');
		$name = $GLOBALS['phpgw']->db->db_addslashes(htmlentities($param['name']));
		$url = $GLOBALS['phpgw']->db->db_addslashes($param['url']);
		$GLOBALS['phpgw']->db->query('INSERT INTO phpgw_userrss values('.$_SESSION['phpgw_session']['account_id'].',\''.$url.'\',\''.$name.'\');',__LINE__,__FILE__);
		if ($GLOBALS['phpgw']->db->Error)
			    return "Error";
		else
			    return "Success";

	}

	function removeChannel($param)
	{
		include('../header.inc.php');
		$url = $GLOBALS['phpgw']->db->db_addslashes($param['url']);
		$GLOBALS['phpgw']->db->query('DELETE FROM phpgw_userrss where rss_url = \''.$url.'\';',__LINE__,__FILE__);
		if ($GLOBALS['phpgw']->db->Error)
			    return "Error";
		else
			    return "Success";
	}

}
?>