File Source for LibertyComment.php

<?php
/**
* Management of Liberty Content
*
* @package liberty
* @version $Header$
* @author spider <spider@steelsun.com>
*/
/**
* required setup
*/
require_once( LIBERTY_PKG_PATH.'LibertyMime.php' );
define( 'BITCOMMENT_CONTENT_TYPE_GUID', 'bitcomment' );
/**
* Handles all comments which are actual content objects
*
* @package liberty
*/
class LibertyComment extends LibertyMime {
var $mCommentId;
function LibertyComment($pCommentId = NULL, $pContentId = NULL, $pInfo = NULL) {
parent::__construct();
$this->registerContentType( BITCOMMENT_CONTENT_TYPE_GUID, array(
'content_type_guid' => BITCOMMENT_CONTENT_TYPE_GUID,
'content_name' => 'Comment',
'handler_class' => 'LibertyComment',
'handler_package' => 'liberty',
'handler_file' => 'LibertyComment.php',
'maintainer_url' => 'http://www.bitweaver.org'
) );
$this->mCommentId = $pCommentId;
$this->mContentId = $pContentId;
$this->mInfo = $pInfo;
$this->mContentTypeGuid = BITCOMMENT_CONTENT_TYPE_GUID;
$this->mAdminContentPerm = 'p_liberty_admin_comments';
$this->mRootObj = NULL;
if ($this->mCommentId || $this->mContentId) {
$this->loadComment();
}
}
function loadComment() {
global $gBitSystem, $gBitUser;
if (!$this->verifyId($this->mCommentId) && !$this->verifyId($this->mContentId)) {
return NULL;
}
if ($this->mCommentId) {
$mid = 'WHERE lcom.`comment_id` = ?';
$bindVars = array($this->mCommentId);
} else {
$mid = 'WHERE lc.`content_id` = ?';
$bindVars = array($this->mContentId);
}
$joinSql = $selectSql = $whereSql = '';
$this->getServicesSql( 'content_load_sql_function', $selectSql, $joinSql, $whereSql, $bindVars, $this );
$sql = "SELECT lcom.*, lc.*, uu.`email`, uu.`real_name`, uu.`login` $selectSql
FROM `".BIT_DB_PREFIX."liberty_comments` lcom
LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON (lcom.`content_id` = lc.`content_id`)
LEFT OUTER JOIN `".BIT_DB_PREFIX."users_users` uu ON (lc.`user_id` = uu.`user_id`) $joinSql
$mid $whereSql";
if( $row = $this->mDb->getRow( $sql, $bindVars ) ) {
$this->mInfo = $row;
$this->mContentId = $row['content_id'];
$this->mCommentId = $row['comment_id'];
// call parent load for attachment data like other Mime derived classes, only need it if feature is active or admin
if( $gBitSystem->isFeatureActive( 'comments_allow_attachments' ) || $gBitUser->isAdmin() ){
LibertyMime::load();
}
}
return count($this->mInfo);
}
function verifyComment(&$pParamHash) {
global $gBitUser, $gBitSystem;
/* should be unnecessary
if( !empty( $_REQUEST['format_guid'] )) {
$storeRow['format_guid'] = $_REQUEST['format_guid'];
}
*/
$pParamHash['content_id'] = (@BitBase::verifyId($this->mContentId) ? $this->mContentId : NULL);
if( empty( $pParamHash['root_id'] ) && !empty( $pParamHash['comments_parent_id'] ) ) {
$pParamHash['root_id'] = $pParamHash['comments_parent_id'];
}
if (!$pParamHash['root_id']) {
$this->mErrors['root_id'] = "Missing root id for comment";
}
if( empty( $pParamHash['parent_id'] ) ){
$pParamHash['parent_id'] = (@BitBase::verifyId($this->mInfo['parent_id']) ? $this->mInfo['parent_id'] : (!@BitBase::verifyId($pParamHash['post_comment_reply_id']) ? $pParamHash['comments_parent_id'] : $pParamHash['post_comment_reply_id']));
}
if (!$pParamHash['parent_id']) {
$this->mErrors['parent_id'] = "Missing parent id for comment";
}
if (empty($pParamHash['anon_name'])) {
$pParamHash['anon_name']=null;
}
if( !@$gBitUser->verifyCaptcha( $pParamHash['captcha'] ) ) {
$this->mErrors['store'] = tra( 'Incorrect validation code' );
}
if( !empty( $pParamHash['comment_title'] ) ){
$pParamHash['title'] = $pParamHash['comment_title'];
}
if( !empty( $pParamHash['comment_data'] ) ){
$pParamHash['edit'] = $pParamHash['comment_data'];
}
if( empty( $pParamHash['edit'] ) ) {
$this->mErrors['store'] = tra( 'Your comment was empty.' );
} elseif( !$gBitUser->hasPermission( 'p_liberty_trusted_editor' ) && ($linkCount = preg_match_all( '/http\:\/\//', $pParamHash['edit'], $links )) > $gBitSystem->getConfig( 'liberty_unstrusted_max_http_in_content', 0 ) ) {
$this->mErrors['store'] = tra( 'Links are not allowed.' );
} else {
$dupeQuery = "SELECT `data` FROM `".BIT_DB_PREFIX."liberty_content` lc INNER JOIN `".BIT_DB_PREFIX."liberty_comments` lcom ON (lc.`content_id`=lcom.`content_id`) WHERE `user_id`=? AND `content_type_guid`='".BITCOMMENT_CONTENT_TYPE_GUID."' AND `ip`=? AND lcom.`root_id`=? ORDER BY `created` DESC";
if( $lastPostData = $this->mDb->getOne( $dupeQuery, array( $gBitUser->mUserId, $_SERVER['REMOTE_ADDR'], $pParamHash['root_id'] ) ) ) {
if( empty( $this->mCommentId ) && trim( $lastPostData ) == trim( $pParamHash['edit'] ) ) {
$this->mErrors['store'] = tra( 'Duplicate comment.' );
}
}
}
// verify attachments are allowed on comments
if( ( isset( $pParamHash['_files_override'] ) || !empty( $_FILES ) ) && !$gBitSystem->isFeatureActive( 'comments_allow_attachments' ) ) {
$this->mErrors['comment_attachments'] = tra( 'Files can not be uploaded with comments.' );
}
// if we have an error we get them all by checking parent classes for additional errors
if( count( $this->mErrors ) > 0 ){
parent::verify( $pParamHash );
}
return (count($this->mErrors) == 0);
}
function storeComment( &$pParamHash ) {
$this->mDb->StartTrans();
if( $this->verifyComment($pParamHash) && LibertyMime::store( $pParamHash ) ) {
if (!$this->mCommentId) {
$this->mCommentId = $this->mDb->GenID( 'liberty_comment_id_seq');
if (!empty($pParamHash['parent_id'])) {
$parentComment = new LibertyComment(NULL,$pParamHash['parent_id']);
}
$parent_sequence_forward = '';
$parent_sequence_reverse = '';
if (!empty($parentComment->mInfo['thread_forward_sequence'])) {
$parent_sequence_forward = $parentComment->mInfo['thread_forward_sequence'];
$parent_sequence_reverse = $parentComment->mInfo['thread_reverse_sequence'];
}
// if nesting level > 25 deep, put it on level 25
if (strlen($parent_sequence_forward) > 10*24) {
$parent_sequence_forward = substr($parent_sequence_forward,0,10*24);
}
$this->mInfo['thread_forward_sequence'] = $parent_sequence_forward . sprintf("%09d.",$this->mCommentId);
$this->mInfo['thread_reverse_sequence'] = strtr($parent_sequence_forward . sprintf("%09d.",$this->mCommentId),
'0123456789', '9876543210');
$sql = "INSERT INTO `".BIT_DB_PREFIX."liberty_comments` (`comment_id`, `content_id`, `parent_id`, `root_id`, `anon_name`, `thread_forward_sequence`, `thread_reverse_sequence`) VALUES (?,?,?,?,?,?,?)";
$this->mDb->query($sql, array($this->mCommentId, $pParamHash['content_id'], $pParamHash['parent_id'],
$pParamHash['root_id'], $pParamHash['anon_name'],
$this->mInfo['thread_forward_sequence'], $this->mInfo['thread_reverse_sequence']));
$this->mInfo['parent_id'] = $pParamHash['parent_id'];
$this->mInfo['content_id'] = $pParamHash['content_id'];
$this->mInfo['root_id'] = $pParamHash['root_id'];
$this->mContentId = $pParamHash['content_id'];
} else {
$sql = "UPDATE `".BIT_DB_PREFIX."liberty_comments` SET `parent_id` = ?, `content_id`= ? WHERE `comment_id` = ?";
$this->mDb->query($sql, array($pParamHash['parent_id'], $pParamHash['content_id'], $this->mCommentId));
$this->mInfo['parent_id'] = $pParamHash['parent_id'];
$this->mInfo['content_id'] = $pParamHash['content_id'];
$this->mContentId = $pParamHash['content_id'];
}
$this->invokeServices( 'comment_store_function', $pParamHash );
}
$this->mDb->CompleteTrans();
return (count($this->mErrors) == 0);
}
// This is a highly specialized method only used for emailing list synchronization. If you don't know anything about this, just move along and live in bliss
// (Hint: see mailing list integreation in boards)
function storeMessageId( $pMessageId ) {
if( $this->isValid() ) {
$this->mDb->query( "UPDATE `".BIT_DB_PREFIX."liberty_comments` SET `message_guid`=? WHERE `content_id`=?", array( $pMessageId, $this->mContentId ) );
}
}
// delete a single comment
function deleteComment() {
global $gBitSystem;
$ret = FALSE;
if( $this->isValid() ) {
$this->mDb->StartTrans();
if( $gBitSystem->isPackageActive( 'boards' ) ) {
// due to foreign key constraints, this has to go in the base class of BitBoardPost
$sql = "DELETE FROM `".BIT_DB_PREFIX."boards_posts` WHERE `comment_id` = ?";
$rs = $this->mDb->query($sql, array($this->mCommentId ) );
// $query = "DELETE FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?";
// $result = $this->mDb->query( $query, array( $this->getField( 'content_id' ) ) );
}
$sql = "DELETE FROM `".BIT_DB_PREFIX."liberty_comments` WHERE `comment_id` = ?";
$rs = $this->mDb->query($sql, array($this->mCommentId));
/*
* TODO: figureout why this is even here. Mime should handle this and it needs to pass in mandatory attachmentId
* Slated to delete for now - wjames5
*/
/*
if (method_exists($this,'expungeMetaData')) {
$this->expungeMetaData();
}
*/
if( LibertyMime::expunge() ) {
$ret = TRUE;
$this->mDb->CompleteTrans();
} else {
$this->mDb->RollbackTrans();
}
}
return $ret;
}
//delete the comment and all of its children
//it should be possible to do this in a single query using the materialized path
//this is the code from the old function which needs to be revised
// 1) change name
// 2) use materialized path to cut query count and eliminate recursion
function expunge() {
global $gBitSystem;
$ret = FALSE;
if( $this->isValid() ) {
$this->mDb->StartTrans();
$sql = "SELECT `comment_id` FROM `".BIT_DB_PREFIX."liberty_comments` WHERE `parent_id` = ?";
$rows = $this->mDb->getAll($sql, array($this->mContentId));
foreach ($rows as $row) {
$comment = new LibertyComment($row['comment_id']);
$comment->expunge();
}
if( $gBitSystem->isPackageActive( 'boards' ) ) {
// due to foreign key constraints, this has to go in the base class of BitBoardPost
$sql = "DELETE FROM `".BIT_DB_PREFIX."boards_posts` WHERE `comment_id` = ?";
$rs = $this->mDb->query($sql, array($this->mCommentId ) );
$query = "DELETE FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?";
$result = $this->mDb->query( $query, array( $this->getField( 'content_id' ) ) );
}
$sql = "DELETE FROM `".BIT_DB_PREFIX."liberty_comments` WHERE `comment_id` = ?";
$rs = $this->mDb->query($sql, array($this->mCommentId));
/*
* TODO: figureout why this is even here. Mime should handle this and it needs to pass in mandatory attachmentId
* Slated to delete for now - wjames5
*/
/*
if (method_exists($this,'expungeMetaData')) {
$this->expungeMetaData();
}
*/
if( LibertyMime::expunge() ) {
$ret = TRUE;
$this->mDb->CompleteTrans();
} else {
$this->mDb->RollbackTrans();
}
}
return $ret;
}
function userCanEdit() {
global $gBitUser, $gBitSystem;
$ret = FALSE;
// check the allowed edit time limit - we'll use it later
$withinEditTime = FALSE;
if ( $gBitSystem->getConfig( 'comments_edit_minutes', 60 ) * 60 + $this->getField( 'created' ) > time() ) {
$withinEditTime = TRUE;
}
if( $gBitUser->isRegistered() ) {
/* get the hash of the users perms rather than call hasUserPermission which
* always returns true for owner which interferes with trying to time limit editing
*/
$checkPerms = $this->getUserPermissions();
$ret = ( !empty( $checkPerms['p_liberty_edit_comments'] ) ||
!empty( $checkPerms['p_liberty_admin_comments'] ) ||
$gBitUser->hasPermission( 'p_liberty_admin_comments' ) ||
( $gBitUser->mUserId == $this->mInfo['user_id'] && $withinEditTime )
);
} elseif( $this->mInfo['user_id'] == ANONYMOUS_USER_ID ) {
$ret = (($_SERVER['REMOTE_ADDR']==$this->mInfo['ip']) && $withinEditTime );
}
return $ret;
}
function userCanUpdate( $pRootContent=NULL ) {
return( $this->userCanEdit() || ($pRootContent && ($pRootContent->hasUserPermission( 'p_liberty_edit_comments' ) || $pRootContent->hasUserPermission( 'p_liberty_admin_comments' ))) );
}
/**
* @param pLinkText name of
* @param pParamHash different possibilities depending on derived class
* @return the link to display the page.
*/
public static function getDisplayUrlFromHash( &$pParamHash ) {
$ret = NULL;
if( @BitBase::verifyId( $pParamHash['root_id'] ) && $viewContent = LibertyBase::getLibertyObject( $pParamHash['root_id'] ) ) {
// pass in cooment hash to the url func incase the root package needs to do something fancy
$viewContent->mInfo['comment'] = $pParamHash;
$ret = $viewContent->getDisplayUrl().( @static::verifyId( $pParamHash['content_id'] ) ? "#comment_".$pParamHash['content_id'] : '' );
} elseif( @BitBase::verifyId( $pParamHash['content_id'] ) ) {
$ret = parent::getDisplayUrlFromHash( $pParamHash );
$ret .= "#comment_{$pParamHash['content_id']}";
}
return( $ret );
}
//generate a URL to directly access and display a single comment and the associated root content
public static function getDirectUrlFromHash( $pParamHash=NULL ) {
if( empty( $pParamHash ) ) {
$pParamHash = &$this->mInfo;
}
$ret = NULL;
if( !empty( $pParamHash['root_id'] ) && $viewContent = LibertyBase::getLibertyObject( $pParamHash['root_id'] ) ) {
$ret = $viewContent->getDisplayUrl();
if ( strstr($ret, '?') ) {
$ret .= "&";
}
else {
$ret .= "?";
}
$ret .= "view_comment_id=" . $pParamHash['content_id'] . "#comment_".$pParamHash['content_id'];
}
return ( $ret );
}
function getDisplayLink( $pLinkText=NULL, $pMixed=NULL, $pAnchor=NULL ) {
$anchor = '';
// Override default title with something comment centric
if( empty( $pLinkText ) ) {
$pLinkText = tra( 'Comment' );
}
if( @BitBase::verifyId( $pMixed['content_id'] )) {
$anchor = "&view_comment_id=".$pMixed['content_id']."#comment_{$pMixed['content_id']}";
}
return parent::getDisplayLink( $pLinkText, $pMixed, $anchor );
}
function getList( &$pParamHash ) {
global $gBitSystem, $gLibertySystem;
if ( !isset( $pParamHash['sort_mode']) or $pParamHash['sort_mode'] == '' ){
$pParamHash['sort_mode'] = 'created_desc';
}
if( empty( $pParamHash['max_records'] ) ) {
$pParamHash['max_records'] = $gBitSystem->getConfig( 'max_records' );
}
LibertyContent::prepGetList( $pParamHash );
$sort_mode = $this->mDb->convertSortmode($pParamHash['sort_mode']);
$joinSql = $whereSql = $selectSql = '';
$bindVars = $ret = array();
$pParamHash['include_comments'] = TRUE;
$this->getServicesSql( 'content_list_sql_function', $selectSql, $joinSql, $whereSql, $bindVars, NULL, $pParamHash );
if ( !empty( $pParamHash['root_content_type_guid'] ) ) {
if( is_string( $pParamHash['root_content_type_guid'] ) ) {
$pParamHash['root_content_type_guid'] = array( $pParamHash['root_content_type_guid'] );
} elseif( is_array( $pParamHash['root_content_type_guid'] ) ) {
$contentTypes = array_keys( $gLibertySystem->mContentTypes );
$max = count( $pParamHash['root_content_type_guid'] );
$guidSql = '';
for( $i = 0; $i < $max; $i++ ) {
if( in_array( $pParamHash['root_content_type_guid'][$i], $contentTypes ) ) {
if( strlen( $guidSql ) ) {
$guidSql .= ' OR ';
}
$guidSql .= " rlc.`content_type_guid`=? ";
$bindVars[] = $pParamHash['root_content_type_guid'][$i];
}
}
$whereSql .= " AND ( $guidSql )";
}
}
if ( !empty( $pParamHash['content_type_guid'] ) ) {
$whereSql .= " AND rlc.`content_type_guid`=? ";
$bindVars[] = $pParamHash['content_type_guid'];
}
if ( !empty( $pParamHash['user_id'] ) ) {
$whereSql .= " AND ptc.`user_id`=? ";
$bindVars[] = $pParamHash['user_id'];
}
if ( !empty( $pParamHash['created_ge'] ) ) {
$whereSql .= " AND lc.`created`>=? ";
$bindVars[] = $pParamHash['created_ge'];
}
// left outer join on root so updater works
$query = "SELECT
lcom.`comment_id`,
lc.`content_id`,
lcom.`parent_id`,
lcom.`anon_name`,
lcom.`root_id`,
lc.`title` AS `content_title`,
rlc.`title` AS `root_content_title`,
lc.`created`,
lc.`data`,
lc.`last_modified` as `last_modified`,
lc.`title` as `title`,
ptc.`content_type_guid` as `parent_content_type_guid`,
rlc.`content_type_guid` as `root_content_type_guid`,
lc.`content_type_guid`,
uu.`login` AS `creator_user`,
uu.`login`,
uu.`real_name`,
uu.`user_id`
$selectSql
FROM `".BIT_DB_PREFIX."liberty_comments` lcom
INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON( lcom.`content_id`=lc.`content_id` )
INNER JOIN `".BIT_DB_PREFIX."users_users` uu ON( uu.`user_id`=lc.`user_id`)
LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content` rlc ON( rlc.`content_id`=lcom.`root_id` )
$joinSql, `".BIT_DB_PREFIX."liberty_content` ptc
WHERE lcom.`parent_id`=ptc.`content_id` $whereSql
ORDER BY $sort_mode";
if( $result = $this->mDb->query( $query, $bindVars, $pParamHash['max_records'], $pParamHash['offset'] )) {
while( $row = $result->FetchRow() ) {
$row['display_link'] = $this->getDisplayLink( $row['content_title'], $row );
$row['display_url'] = static::getDisplayUrlFromHash( $row );
$row['direct_url'] = static::getDirectUrlFromHash( $row );
if (!empty($pParamHash['parse'])) {
$row['parsed_data'] = $this->parseData($row);
}
$ret[] = $row;
}
}
return $ret;
}
/**
* Fill title with date if available
*
* This will normally be overwriten by extended classes to provide
* an appropriate title title string
* @param array mInfo type hash of data to be used to provide base data
* @return string Descriptive title for the object
*/
public static function getTitleFromHash( $pHash, $pDefault=TRUE ) {
global $gBitSmarty;
$ret = NULL;
if( !empty( $pHash['title'] ) ) {
$ret = $pHash['title'];
} elseif( !empty( $pHash['created'] ) ) {
$gBitSmarty->loadPlugin( 'smarty_modifier_bit_short_date' );
$ret = smarty_modifier_bit_short_date( $pHash['created'] );
} elseif( !empty( $pHash['content_name'] ) ) {
$ret = $pHash['content_name'];
}
return $ret;
}
function getNumComments($pContentId = NULL) {
$bindVars = NULL;
if (!$pContentId && $this->mContentId) {
$mid = '=?';
$bindVars = array($this->mContentId);
} elseif (is_array($pContentId)) {
$mid = 'in ('.implode(',', array_fill(0, count( $pContentId ), '?')).')';
$bindVars = $pContentId;
} elseif ($pContentId) {
$mid = '=?';
$bindVars = array($pContentId);
}
$commentCount = 0;
$joinSql = $selectSql = $whereSql = '';
/* brute force call to liberty_content_list_sql
* for status enforcement
*
* here we call liberty_content_list_sql which has a
* restriction to enforce content_status_id. we could
* have called the full list_sql service, but that
* would be overkill for just getting a count.
*/
if ( !is_array($pContentId) ){
$sqlHash = liberty_content_list_sql( $this, NULL );
if( !empty( $sqlHash['select_sql'] ) ) {
$selectSql .= $sqlHash['select_sql'];
}
if( !empty( $sqlHash['join_sql'] ) ) {
$joinSql .= $sqlHash['join_sql'];
}
if( !empty( $sqlHash['where_sql'] ) ) {
$whereSql .= $sqlHash['where_sql'];
}
if( !empty( $sqlHash['bind_vars'] ) ) {
if ( is_array( $bindVars ) ) {
$bindVars = array_merge( $bindVars, $sqlHash['bind_vars'] );
} else {
$bindVars = $sqlHash['bind_vars'];
}
}
}
if ($bindVars) {
$sql = "SELECT count(*) as comment_count $selectSql
FROM `".BIT_DB_PREFIX."liberty_comments` lcom
INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON (lcom.`content_id` = lc.`content_id`) $joinSql
WHERE lcom.`root_id` $mid $whereSql";
$commentCount = $this->mDb->getOne($sql, $bindVars);
}
return $commentCount;
}
// used for direct access to view a single comment
// see usage in: liberty/comments_inc.php
// there ought to be a better way to do this...
function getNumComments_upto($pCommentId = NULL, $pContentId = NULL) {
$comment = new LibertyComment($pCommentId, $pContentId);
#assume flat mode
$comment_fields = $comment->mInfo;
$created = $comment_fields['created'];
$contentId = $comment_fields['root_id'];
$commentCount = 0;
if ($contentId) {
$sql = "SELECT count(*)
FROM `".BIT_DB_PREFIX."liberty_comments` tc LEFT OUTER JOIN
`".BIT_DB_PREFIX."liberty_content` tcn
ON (tc.`content_id` = tcn.`content_id`)
where tc.`root_id` =? and `created` < ?";
$commentCount = $this->mDb->getOne($sql, array($contentId, $created));
}
return $commentCount;
}
// Returns a hash containing the comment tree of comments related to this content
function getComments( $pContentId = NULL, $pMaxComments = NULL, $pOffset = NULL, $pSortOrder = NULL, $pDisplayMode = NULL ) {
if( $pDisplayMode != "flat" ) {
if ($pSortOrder == "commentDate_asc") {
$pSortOrder = 'thread_asc';
} else {
$pSortOrder = 'thread_desc';
}
}
$contentId = NULL;
$ret = array();
if (!$pContentId && $this->mContentId) {
$contentId = $this->mContentId;
} elseif ($pContentId) {
$contentId = $pContentId;
}
$mid = "";
$sort_order = "ASC";
$mid = 'created ASC';
if (!empty($pSortOrder)) {
if ($pSortOrder == 'commentDate_desc') {
$mid = 'created DESC';
} else if ($pSortOrder == 'commentDate_asc') {
$mid = 'created ASC';
} elseif ($pSortOrder == 'thread_asc') {
$mid = 'thread_forward_sequence ASC';
// thread newest first is harder...
} elseif ($pSortOrder == 'thread_desc') {
$mid = 'thread_reverse_sequence ASC';
} else {
$mid = $this->mDb->convertSortmode( $pSortOrder );
}
}
$mid = 'order by ' . $mid;
$bindVars = array();
if (is_array( $pContentId ) ) {
$mid2 = 'in ('.implode(',', array_fill(0, count( $pContentId ), '?')).')';
$bindVars = $pContentId;
$select1 = ', lcp.`content_type_guid` as parent_content_type_guid, lcp.`title` as parent_title ';
$join1 = " LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content` lcp ON (lcp.`content_id` = lcom.`parent_id`) ";
} elseif ($pContentId) {
$mid2 = '=?';
$bindVars = array( $pContentId );
$select1 = '';
$join1 = '';
}
$joinSql = $selectSql = $whereSql = '';
$pListHash = array( 'content_id' => $contentId, 'max_records' => $pMaxComments, 'offset'=>$pOffset, 'sort_mode'=> $pSortOrder, 'display_mode' => $pDisplayMode, 'has_comment_view_perm' => TRUE );
$this->getServicesSql( 'content_list_sql_function', $selectSql, $joinSql, $whereSql, $bindVars, $this, $pListHash );
if ($pContentId) {
$sql = "SELECT lcom.`comment_id`, lcom.`parent_id`, lcom.`root_id`, lcom.`thread_forward_sequence`, lcom.`thread_reverse_sequence`, lcom.`anon_name`, lc.*, uu.`email`, uu.`real_name`, uu.`login` $selectSql $select1
FROM `".BIT_DB_PREFIX."liberty_comments` lcom
LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON (lcom.`content_id` = lc.`content_id`)
LEFT OUTER JOIN `".BIT_DB_PREFIX."users_users` uu ON (lc.`user_id` = uu.`user_id`) $joinSql $join1
WHERE lcom.root_id $mid2 $whereSql $mid";
$flat_comments = array();
if( $result = $this->mDb->query( $sql, $bindVars, $pMaxComments, $pOffset ) ) {
while( $row = $result->FetchRow() ) {
$row['parsed_data'] = $this->parseData( $row );
$row['level'] = substr_count ( $row['thread_forward_sequence'], '.' ) - 1;
$c = new LibertyComment();
$c->mInfo=$row;
$c->mRootObj = $this->getRootObj();
$row['is_editable'] = $c->userCanUpdate( $c->mRootObj );
global $gBitSystem;
if( $gBitSystem->isFeatureActive( 'comments_allow_attachments' ) ){
// get attachments for each comment
global $gLibertySystem;
$query = "SELECT * FROM `".BIT_DB_PREFIX."liberty_attachments` la WHERE la.`content_id`=? ORDER BY la.`pos` ASC, la.`attachment_id` ASC";
if( $result2 = $this->mDb->query( $query,array( (int)$row['content_id'] ))) {
while( $row2 = $result2->fetchRow() ) {
if( $func = $gLibertySystem->getPluginFunction( $row2['attachment_plugin_guid'], 'load_function', 'mime' )) {
// we will pass the preferences by reference that the plugin can easily update them
if( empty( $row['storage'][$row2['attachment_id']] )) {
$row['storage'][$row2['attachment_id']] = array();
}
$row['storage'][$row2['attachment_id']] = $func( $row2, $row['storage'][$row2['attachment_id']] );
} else {
print "No load_function for ".$row2['attachment_plugin_guid'];
}
}
}
// end get attachements for each comment
}
$flat_comments[$row['content_id']] = $row;
}
}
# now select comments wanted
$ret = $flat_comments;
}
return $ret;
}
function getQuoted() {
$data = $this->mInfo['data'];
$pattern = '/\{quote .*\}(.*)\{\/quote\}/i';
$replacement = '';
$data = preg_replace($pattern, $replacement, $data);
return '{quote format_guid="'.$this->mInfo['format_guid'].'" comment_id="'.$this->mCommentId.'" user="'.$this->mInfo['login'].'"}'.trim($data).'{/quote}';
}
// Basic formatting for quoting comments
function quoteComment($commentData) {
$ret = '> '.$commentData;
$ret = eregi_replace("\n", "\n>", $ret);
return $ret;
}
function getRootObj(){
if ( !is_object( $this->mRootObj ) && !empty( $this->mInfo['root_id'] ) ){
if ( $obj = LibertyBase::getLibertyObject( $this->mInfo['root_id'] ) ) {
$this->mRootObj = $obj;
}
}
return $this->mRootObj;
}
}
?>

Source for file LibertyComment.php