<?PHP
/******************************************************
    news class

- news class
******************************************************/

class news{
    
    var $recent = array();
    
    function news(){}
    
    function recent($count = 10, $publish = 1){
        if(count($this->recent) == 0){
            $sql = "SELECT `news`.*, `user`.`user_email`, `user`.`user_display` FROM `news`, `user` WHERE user_f = user_p AND `_publish` >= {$publish} ORDER BY `_added` DESC LIMIT 0,{$count}";
            $results= mysql_query($sql) or die(mysql_error());
            while($row = mysql_fetch_assoc($results)){
                $this->recent[] = $row;
            }
        }
        
        return $this->recent;
    }
    
    function get_news_item($id){
        $sql = "SELECT `news`.*, `user`.`user_email`, `user`.`user_display` FROM `news`, `user` WHERE user_p = user_f AND `news_p` = ".intval($id);
        $results= mysql_query($sql) or die(mysql_error());
        if($row = mysql_fetch_assoc($results))
            return $row;
    }
    
    function get_news_item_comments($id){
        $data = array();
        
        $sql = "SELECT `news_comment`.*, `user`.`user_email`, `user`.`user_display` FROM `news_comment`, `user` WHERE user_p = user_f AND `news_f` = ".intval($id) . "  ORDER BY `_added` ";
        $results= mysql_query($sql) or die(mysql_error());
        while($row = mysql_fetch_assoc($results)){
            $data[] = $row;
        }
        
        if(count($data) > 0)
            return $data;
            
        return false;
    }
    
    function comment_news_item($id, $user, $comment){
        // check for dupe
        $sql = "SELECT news_comment_p FROM news_comment WHERE news_f = ".intval($id)." AND user_f = ".intval($user)." AND comment_text =  '".mysqlclean($comment)."' ";
        $result = mysql_query($sql) or die(mysql_error());
        if(mysql_fetch_assoc($result))
            return false;
        
        $sql = "INSERT INTO news_comment (`news_f`, `user_f`, `comment_text`, `_added`) VALUES (".intval($id).", ".intval($user).", '".mysqlclean($comment)."', NOW())";
        mysql_query($sql) or die(mysql_error());
        if(mysql_insert_id()){
            $sql = "UPDATE `news` SET comment_count = comment_count + 1 WHERE news_p = ".intval($id);
            mysql_query($sql) or die(mysql_error());
        }
    }
    
    function update_news($data){
        $_publish = 0;
        if (isset($data['_publish'])) $_publish = 1;
        
        $data_sql = "
            user_f            = '".$_SESSION['user']->id."',
            news_title         = '".mysqlclean($data['news_title'])."',
            news_content     = '".mysqlclean($data['news_content'])."',
            _publish         = '{$_publish}'
        ";
        
        if($data['news_p'] == 0 || trim($data['news_p']) == ''){
            $sql = "INSERT INTO `news` SET _added = NOW(), " . $data_sql;
        }else{
            $sql = "UPDATE `news` SET " . $data_sql . " WHERE news_p = " . intval($data['news_p']);
        }
        
        mysql_query($sql) or die(mysql_error());
    }
    
}

?>