<?
/**
 * This file was developed as part of the Concerto digital signage project
 * at RPI.
 *
 * Copyright (C) 2009 Rensselaer Polytechnic Institute
 * (Student Senate Web Technolgies Group)
 *
 * This program is free software; you can redistribute it and/or modify it 
 * under the terms of the GNU General Public License as published by the Free
 * Software Foundation; either version 2 of the License, or (at your option)
 * any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * General Public License for more details.  You should have received a copy
 * of the GNU General Public License along with this program.
 *
 * @package      Concerto
 * @author       Web Technologies Group, $Author$
 * @copyright    Rensselaer Polytechnic Institute
 * @license      GPLv2, see www.gnu.org/licenses/gpl-2.0.html
 * @version      $Revision$
 */
/*
Class: Feed
Status: Done maybe
Functionality:  
        create_feed             Creates a new feed
        set_properties	Sets any properties back to the db
        content_add		Adds content to the feed, based on the content_id and an optional moderation flag
        content_remove	Removes a piece of content from a feed
        coontent_count	Counts all the content in a feed that match an optional mod flag
        content_list		Lists all the content in a feed, again with the mod flag junk
        content_get		Gets all the content in a feed, again with the mod junk
        content_list_by_type   Lists all the content in a feed based on the type of content, with the mod flag junk
        content_mod		Moderates content in a feed, requires content ID and mod flag
        list_all		Lists all the feeds in the system, optional WHERE syntax
        list_by_type   Lists all feeds based on the type of their content
        get_all		Gets all the feeds in the system, optional WHERE syntax
        priv_get		Gets all the feeds that an object (usr/scr) can access on a per action basis
        priv_test		Test if a user can see a specific feed
        get_feeds    Get all Screens (arr of objects) currently subscribing to feed
        destroy		Deletes a feed, all content mapped to the feed, and scales all the fields up appropriately
Comments:
	Added the ability to list feeds based on a type, for content listing
	Cleaned
*/
class Feed{
    var $id;
    var $name;
    var $group_id;
	
	var $type; //Stores the type of the feed, basic or advanced
	var $dyn_id; //Stores the id of the feed if has a reference in the dynamic feed table (for type == advanced)
	var $dyn;	//Holds a Dynamic object if the feed is dynamic

   var $description; //description of feed for human consumption
	var $status;
	var $set;

    function __construct($id = '', $dyn_allowed = true){
		if($id != '' && is_numeric($id)){
			$sql = "SELECT * FROM feed WHERE id = $id LIMIT 1";
            $res = sql_query($sql);
            if($res){
                $data = (sql_row_keyed($res,0));
                $this->id = $data['id'];
                $this->name = $data['name'];
				$this->group_id = $data['group_id'];
				$this->type = $data['type'];
            $this->description = $data['description'];
				if($this->type != 0){
					$this->dyn_id = $data['dynamic_id'];
					if($dyn_allowed){ //We do this to prevent a loop of feeds ->dynamic ->feeds->...
						$this->dyn = new Dynamic($this->dyn_id, $this->id);
					}
				}

				$this->set = true;
                return true;
            } else {
                return false;
            }

        } else {
            $this->set = false;
            return true;
        }

	}

    function create_feed($name_in, $group_in, $type_in = 0, $desc_in = ''){
		if($this->set == true){
			return false; //We already have a feed established here
		} else {
			//Begin testing/cleaning block
			$name_in = escape($name_in);
         $desc_in = escape($desc_in);
			if(!is_numeric($group_in) || !is_numeric($type_in)){
				$this->status = "Unknown Error"; //Aka they are playing with the post data!
				return false;
			}
			//End testing/cleaning block
			$sql = "INSERT INTO feed (name, group_id, type, description) VALUES ('$name_in', $group_in, $type_in, '$desc_in')";
            		$res = sql_query($sql);
                	if($res){
                    		$sql_id = sql_insert_id();

                    		$this->id = $sql_id;
                    		$this->name = stripslashes($name_in);
                        $this->description = stripslashes($desc_in);
                    		$this->group_id = $group_in;
				$this->type = $type_in;
							
                    		$this->set = true;

				$notify = new Notification();
	                        $notify->notify('feed', $this->id, 'group', $this->group_id, 'new');

                    		return true;
                	} else {
                    		return false;
                	}
        	}
    	}
	//Sets the properties back to the database
	function set_properties(){
		$name_clean = escape($this->name);
		$desc_clean = escape($this->description);
		if(!is_numeric($this->group_id)){
				$this->status = "Unknown Error"; //Aka they are playing with the post data!
				return false;
		}
		if(!is_numeric($this->type)){
				$this->status = "Unknown Error"; //Aka they are playing with the post data!
				return false;
		}
		$sql = "UPDATE feed SET name = '$name_clean', group_id = '$this->group_id', type = '$this->type', description = '$desc_clean' WHERE id = $this->id LIMIT 1";
		$res = sql_query($sql);
        if($res){
	    $notify = new Notification();
            $notify->notify('feed', $this->id, 'user', $_SESSION['user']->id, 'update');
            return true;
        } else {
            return false;
        }
    }
	//Add a content to a feed
	function content_add($content_in, $mod_in = 'NULL', $moderator_id = 'NULL', $duration_in = DEFAULT_DURATION){
		if(!is_numeric($content_in)){
				$this->status = "Please send the content id"; //Aka they are playing with the post data!
				return false;
		}
		if($mod_in != 0 && $mod_in != 1 && $mod_in != 'NULL'){ //Don't let a stupid value in
			$mod_in = 'NULL';
		}
		if(!is_numeric($moderator_id) && !is_null($moderator_id) && $moderator_id != 'NULL' || !is_numeric($duration_in)){
		  echo "Moderator_id: $moderator_id Duration: $duration_in END";
		  return false;
		}
		$sql = "INSERT INTO feed_content (feed_id, content_id, moderation_flag, moderator_id, duration) ";
		$sql = $sql . "VALUES ($this->id, $content_in, $mod_in, $moderator_id, $duration_in)";
		$res = sql_query($sql);
		if($res){
			if($this->type == 0){  //Dont log dynamic feeds
				$notify = new Notification();
                        	$notify->notify('feed', $this->id, 'content', $content_in, 'add');
           		}
			return true;
        	} else {
            		return false;
        	}
    }
	
	//Remove content from a feed
	function content_remove($content_in){
	   if(!is_numeric($content_in)){
	     return false;
	   }
		$sql = "DELETE FROM feed_content WHERE feed_id = $this->id AND content_id = $content_in LIMIT 1";
		sql_query($sql);
		if($this->type == 0){  //Dont log dynamic feeds
                        $notify = new Notification();
                	$notify->notify('feed', $this->id, 'content', $content_in, 'remove');
                }
		return true;
	}

	//Count # of content in a feed based on moderation status
	function content_count($mod_flag='',$type='all'){
		if($mod_flag != ''){
			$mod_where = "AND moderation_flag LIKE '$mod_flag'";
		} else {
			$mod_where = "";
		}
      
      if($type == 'expired') {
         $mod_where .= " AND end_time <= NOW()";
         $join=1;
      } elseif ($type == 'active') {
         $mod_where .= " AND end_time > NOW() AND end_time <= NOW()";
         $join=1;
      } elseif ($type == 'future') {
         $mod_where .= " AND end_time > NOW()";
         $join=1;
      }

      if($join) {
         $sql = "SELECT COUNT(content_id) FROM feed_content LEFT JOIN content ON `content_id`=`content`.`id` WHERE feed_id = $this->id $mod_where";
      } else {
         $sql = "SELECT COUNT(content_id) FROM feed_content WHERE feed_id = $this->id $mod_where";
      }

		if($res = sql_query($sql)){
			$data = (sql_row_keyed($res,0));
			return $data['COUNT(content_id)'];
		} else {
			return 0;
		}
	}
	//List all content in a feed based on moderation status
	function content_list($mod_flag=''){
		if($mod_flag == 'NULL'){
			$mod_where = "AND moderation_flag IS NULL";
		} elseif($mod_flag != ''){
			$mod_where = "AND moderation_flag LIKE '$mod_flag'";
		} else {
			$mod_where = "";
		}
		$sql = "SELECT * FROM feed_content WHERE feed_id = $this->id $mod_where";
		$res = sql_query($sql);
		$i=0;
		while($row = sql_row_keyed($res,$i)){
		    $data[$i]['content_id'] = $row['content_id'];
		    $data[$i]['moderation_flag'] = $row['moderation_flag'];
		    $i++;
		}
		if(isset($data)){
			return $data;
		} else {
			return false;
		}
	}
	//Gets all content in a feed based on moderation status
	function content_get($mod_flag=''){
		if($mod_flag == 'NULL'){
			$mod_where = "AND moderation_flag IS NULL";
		} elseif($mod_flag != ''){
			$mod_where = "AND moderation_flag LIKE '$mod_flag'";
		} else {
			$mod_where = "";
		}
		$sql = "SELECT * FROM feed_content WHERE feed_id = $this->id $mod_where";
		$res = sql_query($sql);
		$i=0;
		while($row = sql_row_keyed($res,$i)){
		    $data[$i]['content'] = new Content($row['content_id']);
		    $data[$i]['moderation_flag'] = $row['moderation_flag'];
		    $i++;
		}
		if(isset($data)){
			return $data;
		} else {
			return false;
		}
	}
	//List all content in a feed based on type and moderation status
	function content_list_by_type($type, $mod_flag=''){
		if($mod_flag == 'NULL'){
			$mod_where = "AND moderation_flag IS NULL";
		} elseif($mod_flag != ''){
			$mod_where = "AND moderation_flag LIKE '$mod_flag'";
		} else {
			$mod_where = "";
		}
		$sql = "SELECT feed_content.content_id, feed_content.moderation_flag FROM feed_content 
				LEFT JOIN content ON feed_content.content_id = content.id
				WHERE content.type_id = $type AND feed_id = $this->id $mod_where";		
		$res = sql_query($sql);
		$i=0;
		while($row = sql_row_keyed($res,$i)){
		    $data[$row['content_id']] = $row['moderation_flag'];
		    $i++;
		}
		if(isset($data)){
			return $data;
		} else {
			return false;
		}
	}
	//Get all content in a feed based on type and moderation status
	function content_get_by_type($type, $where='1'){
	  if(!is_numeric($type)){
	   return false;
	  }
		$sql = "SELECT feed_content.content_id, feed_content.moderation_flag FROM feed_content 
				LEFT JOIN content ON feed_content.content_id = content.id
				WHERE content.type_id = $type AND feed_content.feed_id = $this->id AND $where";

		$res = sql_query($sql);
		$i=0;
		while($row = sql_row_keyed($res,$i)){
		    $data[] = new Content($row['content_id']);
		    $i++;
		}
		if(isset($data)){
			return $data;
		} else {
			return false;
		}
	}
	//Moderate content: Approve or deny
	function content_mod($cid, $mod_in = NULL, $moderator = NULL, $duration = NULL, $notification = NULL){
		if($mod_in != 0 && $mod_in != 1){ //Don't let a stupid value in
			$mod_in = 'NULL';
		}
		$updates[] = "moderation_flag = $mod_in";
		if($duration != NULL && is_numeric($duration))
			$updates[] = "duration = $duration";
		if($moderator != NULL)
			$updates[] = "moderator_id = {$moderator->id}";
		$sql = "UPDATE feed_content SET ".join($updates, ", ")." WHERE feed_id = {$this->id} AND content_id = $cid LIMIT 1";
		$res = sql_query($sql);
		if($res){
			$notify = new Notification();
			if($mod_in == 1){
             $notify->notify('feed', $this->id, 'content', $cid, 'approve', $notification);
			} elseif($mod_in == 0){
             $notify->notify('feed', $this->id, 'content', $cid, 'deny', $notification);
			}
			return true;
		} else {
			return false;
		}		
	}
    //Retrieve the active types in this feed
    function get_types(){
		$sql = "SELECT type.id, type.name
				FROM feed_content
				LEFT JOIN content ON feed_content.content_id = content.id
				LEFT JOIN type ON content.type_id = type.id
			   WHERE feed_content.feed_id = {$this->id}
				GROUP BY feed_content.feed_id, type.id";
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($row = sql_row_keyed($res,$i++)){
		    $found = true;
          $data[$row['id']] = $row['name'];
		}
		if($found){
			return $data;
		} else {
			return false;
		}
    }
	//List all feeds, optional WHERE syntax
	function list_all($where = ''){
		$sql = "SELECT * FROM feed $where";
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($row = sql_row_keyed($res,$i)){
			$found = true;
		    $data[$i]['id'] = $row['id'];
			$data[$i]['name'] = $row['name'];
			$data[$i]['group_id'] = $row['group_id'];
		    $i++;
		}
		if($found){
			return $data;
		} else {
			return false;
		}
	}
	//List all feeds, based on type
	function list_all_by_type($where = 'WHERE type.id IS NOT NULL'){
		$sql = "SELECT feed.id, feed.name, type.id as t_id, type.name as t_name
				FROM feed
				LEFT JOIN feed_content ON feed_content.feed_id = feed.id
				LEFT JOIN content ON feed_content.content_id = content.id
				LEFT JOIN type ON content.type_id = type.id
				$where
				GROUP BY feed.id, type.id";
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($row = sql_row_keyed($res,$i)){
		    $found = true;
			$data[$row['id']]['name'] = $row['name'];
			$data[$row['id']]['types'][$row['t_id']] = $row['t_name'];
		    $i++;
		}
		if($found){
			return $data;
		} else {
			return false;
		}
	}
	
	//List all feeds, optional WHERE syntax
	function get_all($where = ''){
		$sql = "SELECT * FROM feed $where";
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($row = sql_row_keyed($res,$i)){
			$found = true;
		    $data[] = new Feed($row['id']);
		    $i++;
		}
		if($found){
			return $data;
		} else {
			return false;
		}
	}

    //Find out if a user has permission to 'browse', 'moderate', 
    // submit content ($action='submittable'), or 'edit' this feed
    function user_priv($user, $action='browse', $ignore_admin=false){
        //Admins can always do...everything!!!
        if(!$ignore_admin && $user->admin_privileges) return true;

        //Group members get some perks...
        if($action == 'moderate' || $action == 'browse' || $action =='submittable') {
            foreach($user->groups as $group_id) {
                if($this->group_id == $group_id)
                    return true;
            }
        }

        //Everyoneone else can do stuff dependent on the feed's type.
        if($action == 'browse') {
            return $this->type != 3;
        } elseif($action == 'submittable') {
            return $this->type != 2 && $this->type != 3 && $this->type != 4;
        } else {
            return false;
        }
    }
	//Returns an array of feeds that the object has access to do an action with
	function priv_get($obj, $action='list'){
		if($action == 'subscribe'){
			$scr_group = $obj->group_id;
			$sql = "SELECT id FROM feed WHERE type = 0 OR type = 1 OR type = 2 OR type = 4 OR (type = 3 AND group_id = $scr_group)";
		}elseif($action == 'content'){
			$group_string = implode(',',$obj->groups);
			if($group_string != ""){ //We can only check for groups if they are in one!
				$group_string = "OR ((type = 2 OR type = 3) AND group_id IN ($group_string))";
			}
			$sql = "SELECT id FROM feed WHERE type = 0 $group_string";
		}elseif($action == 'list'){
			$group_string = implode(',',$obj->groups);
			if($group_string != ""){
				$group_string = "OR (type = 3 AND group_id IN ($group_string))";
			}
			$sql = "SELECT id FROM feed WHERE type = 0 OR type = 1 OR type = 2 OR type = 4 $group_string";
		}elseif($action == 'dynamic'){
			$group_string = implode(',',$obj->groups);
			$sql = "SELECT id FROM feed WHERE type = 4 AND group_id IN ($group_string)";
		}else{
			return false;
		}
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($res && $row = sql_row_keyed($res,$i)){
		    $found = true;
		    $data[] = new Feed($row['id']);
		    $i++;
		}
		if($found){
			return $data;
		} else {
			return false;
		}
	}
	//Test if a user has access to see a specific feed
	function priv_test($obj, $feed_id){
		if(!is_numeric($feed_id)){
			return false;
		}
		$group_string = implode(',',$obj->groups);
		$sql = "SELECT COUNT(id) FROM feed WHERE id = $feed_id AND (type = 0 OR type = 1 OR type = 2 OR type = 4 OR (type = 3 AND group_id IN ($group_string)))";
		if($res = sql_query1($sql)){
			return $res;
		} else {
			return false;
		}
	}

   function get_screens($type=NULL, $screen_type=0) {
      $sql = 'SELECT screen.id, field.name FROM feed '.
         'LEFT JOIN position ON position.feed_id = feed.id '.
         'LEFT JOIN screen ON position.screen_id = screen.id '.
         'LEFT JOIN field ON position.field_id = field.id '.
         'WHERE field.template_id = screen.template_id '.
         "AND feed.id = $this->id";

      if(isset($type)) {
         $sql .= " AND field.type_id = $type";
      }
      if(isset($screen_type)) {
         $sql .= " AND screen.type = $screen_type";
      }
      $sql .= ' ORDER BY screen.name';
		$res = sql_query($sql);
		$i=0;
		$found = false;
		while($row = sql_row_keyed($res,$i)) {
			$found = true;
         $scr = new Screen($row['id']);
         $scr->field_name = $row['name'];
         $objects[] = $scr;
         $i++;
		}

		if($found){
			return $objects;
		} else {
			return false;
		}
      
   }

	//Destroys a feed.  Roar
	function destroy(){
		$sql = "DELETE FROM feed_content WHERE feed_id = $this->id";
		$res = sql_query($sql);
		if(!$res){
			return false; //Error unmapping content!
		}
		$sql1 = "SELECT field_id, screen_id FROM position WHERE feed_id = $this->id";
		$res1 = sql_query($sql1);
		if(!$res1){
			return false; //Error grabbing positions/fields
		}
		$i=0;
		while($row = sql_row_keyed($res1,$i)){
		    $field = new Field($row['field_id'],$row['screen_id']);
			$field->delete_feed($this->id);
			$field->rebalance_scale();
		    $i++;
		}
		
		$sql = "DELETE FROM feed WHERE id = $this->id";
		$res = sql_query($sql);
		if(!$res){
			return false; //Error with the final delete!!!
		}
		$notify = new Notification();
		$notify->notify('feed', $this->id, 'user', $_SESSION['user']->id, 'delete');
		//Then we just clear the variables
		$this->id = '';
		$this->name = '';
      $this->description = '';
		$this->group_id='';
		$this->set = false;
		return true;
	}
}

?>