source: branches/2.2/expressoMail1_2/inc/class.rss.inc.php @ 4688

<?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";
        }

}
?>