CL_comments.php

<?
//************************************************************************
// Leonardo XC Server, http://www.leonardoxc.net
//
// Copyright (c) 2004-2010 by Andreadakis Manolis
//
// 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.
//
// $Id: CL_comments.php,v 1.10 2010/11/25 12:36:16 manolis Exp $                                                                 
//
//************************************************************************


class flightComments {
	var $flightID;
	var $commentsNum;
	var $comments;
	var $threads;
	

	var $valuesArray;
	var $gotValues;

	function flightComments($flightID="") {
		if ($flightID!="") {
			$this->flightID=$flightID;
		}

	    //$this->valuesArray=array("flightID","path","name","description");

		$this->gotValues=0;
		$this->commentsNum=0;
		$this->comments=array();
	}
	
	
	function setCommentsStatus($enable) {
		global $db,$commentsTable,$flightsTable;
		$query="UPDATE $flightsTable SET commentsEnabled=$enable WHERE ID=".$this->flightID;
		$res= $db->sql_query($query );
		if($res <= 0){   
			 echo "Error in setCommentsStatusfor flight ".$this->flightID." : $query<BR>";
			 return 0;
		}
		return 1;	
	}
	
	
	function addComment($params,$updateFlightsTable=1) {
		global $db,$commentsTable,$flightsTable;
		

		$now=gmdate("Y-m-d H:i:s");

		$query="INSERT INTO $commentsTable (flightID,parentID,userID,userServerID,guestName,guestPass,guestEmail,
											`text`,languageCode,dateAdded,dateUpdated) 
			VALUES (".
			$this->flightID.",'".prep_for_DB($params['parentID'])."','".
								 prep_for_DB($params['userID'])."','".
								 prep_for_DB($params['userServerID'])."','".
								 prep_for_DB($params['guestName'])."','".
								 prep_for_DB($params['guestPass'])."','".
								 prep_for_DB($params['guestEmail'])."','".
								 prep_for_DB($params['text'])."','".
								 prep_for_DB($params['languageCode'])."','".
								 $now."','".
								 $now."' ) ";
	
		// echo $query;
		$res= $db->sql_query($query);
		if($res <= 0){
		  echo "Error putting comment for flight ".$this->flightID." to DB: $query<BR>";
		  return 0;
		}		

		$newID=$db->sql_nextid();
		
		if ($updateFlightsTable) {
			$query="UPDATE $flightsTable SET commentsNum=commentsNum+1 WHERE ID=".$this->flightID;
			$res= $db->sql_query($query );
			if($res <= 0){   
				 echo "Error updating commentsNum for flight ".$this->flightID." : $query<BR>";
			}
		}	

		return $newID;	
	}
	
	function changeComment($params) {
		global $db,$commentsTable;
		

		$now=gmdate("Y-m-d H:i:s");

		$query="UPDATE $commentsTable SET `text`='".prep_for_DB($params['text'])."' , dateUpdated ='$now' 
					 WHERE  commentID=".$params['commentID']." ";	
		// echo $query;
		$res= $db->sql_query($query);
		if($res <= 0){
		  echo "Error putting comment for flight ".$this->flightID." to DB: $query<BR>";
		  return 0;
		}		

		return $newID;	
	}

	function deleteComment($commentID,$parentID,$updateFlightsTable=1) {
		//if (!$this->gotValues) $this->getFromDB();		
	
		global $db,$commentsTable,$flightsTable;
		
		$result=0;
		if ($updateFlightsTable) {
			$res= $db->sql_query("UPDATE $flightsTable SET commentsNum=commentsNum-1 WHERE ID=".$this->flightID );
			if($res <= 0){   
				 echo "Error updating commentsNum for flight".$this->flightID."<BR>";
				 $result++;
			}
		}		
		
		// echo "###".$this->comments[$commentNum]['ID'];
		$res= $db->sql_query("DELETE FROM $commentsTable WHERE commentID=$commentID");
  		if($res <= 0){   
			 echo "Error deleting comment $commentID for flight".$this->flightID."<BR>";
			 $result++;
	    }
		
		// make all childs of this comment to have the parent of the deleted comment
		
		$res= $db->sql_query("UPDATE $commentsTable SET parentID=$parentID WHERE parentID=$commentID");
		if($res <= 0){   
				 echo "Error updating orphaned childen of deleted comment<BR>";
				 $result++;
		}
		return $result;	

	}

	function deleteAllComments($updateFlightsTable=1) {
		global $db,$commentsTable,$flightsTable;
		
		if ($updateFlightsTable) {
			$res= $db->sql_query("UPDATE $flightsTable SET commentsNum=0 WHERE ID=".$this->flightID );
			if($res <= 0){   
				 echo "Error updating hascomments for flight ".$this->flightID."<BR>";
			}
		}		
		
		$res= $db->sql_query("DELETE FROM  $commentsTable WHERE flightID=".$this->flightID );
  		if($res <= 0){   
			 echo "Error deleting comments for flight".$this->flightID."<BR>";
	    }


	}
	
	function getFirstFromDB() {
		global $db,$commentsTable;
		$sql="SELECT * FROM $commentsTable WHERE flightID=".$this->flightID ." ORDER BY commentID ASC LIMIT 1";
		$res= $db->sql_query($sql);
  		if($res <= 0){   
			 echo "Error getting comments from DB for flight".$this->flightID." <BR>";
		     return 0;
	    }
		$row = $db->sql_fetchrow($res);
		return $row;
	}	
		
	function getFromDB() {
		global $db,$commentsTable;
		$sql="SELECT * FROM $commentsTable WHERE flightID=".$this->flightID ." ORDER BY commentID ASC";
		$res= $db->sql_query($sql);
  		if($res <= 0){   
			 echo "Error getting comments from DB for flight".$this->flightID." <BR>";
		     return 0;
	    }


		$comments = array();
		$commentsParents= array();
		$commentsNum=0;   	  
	    while ($row = $db->sql_fetchrow($res) ) {
			// echo "got ".$row['text']."<br>";	
			$commentsParents[]=array('id'=>$row['commentID'], 'parent_id'=>$row['parentID'] );
			$comments[$row['commentID']]=$row;
			//print_r($this->comments[$this->commentsNum]);
			$this->commentsNum++;			
		}
		
		$threadedComments = new threadedComments($commentsParents);					

		$this->threads=$threadedComments->threads;
		$this->comments=$comments;		
		$this->commentsNum=$commentsNum;		
		$this->gotValues=1;
		return 1;
    }

	function getThreadsOutput() {
		$str='';
		foreach($this->threads as $thread) {		
			$commentData=$this->comments[$thread['id']];			
			$str.="<div class='comments depth".$thread['depth']."'>";
			$str.=$commentData['text'];
			$str.="</div>";
		}
		return $str;
	}
	

}

class threadedComments {
    public $parents  = array();
    public $children = array();
	public $threads=array();

    function __construct($comments) {
        foreach ($comments as $comment) {
            if (!$comment['parent_id'] ) {
                $this->parents[$comment['id']][] = $comment;
            } else {
                $this->children[$comment['parent_id']][] = $comment;
            }
        }		
		$this->makeThreads();
		
		//echo "Init Threaded_comments:<br>";
		//print_r($this->parents);
		//print_r($this->children);
		//echo "Threads are ready : <BR>";
		//print_r($this->threads); 		
    }

	public function makeThreads() {
		$this->threads=array();
	    foreach ($this->parents as $c) {
            $this->process_parent($c);
        }
	}
	
	private function process_comment($comment, $depth) {
		$this->threads[]=array('depth'=>$depth,'id'=>$comment['id']);
    }
	
    private function process_parent($comment, $depth = 0) {
        foreach ($comment as $c) {
            $this->process_comment($c, $depth);
            if (isset($this->children[$c['id']])) {
                $this->process_parent($this->children[$c['id']], $depth + 1);
            }
        }
    }
	
}

?>