summaryrefslogtreecommitdiff
path: root/includes/classes/BitBoardTopic.php
diff options
context:
space:
mode:
Diffstat (limited to 'includes/classes/BitBoardTopic.php')
-rw-r--r--includes/classes/BitBoardTopic.php778
1 files changed, 778 insertions, 0 deletions
diff --git a/includes/classes/BitBoardTopic.php b/includes/classes/BitBoardTopic.php
new file mode 100644
index 0000000..1196da9
--- /dev/null
+++ b/includes/classes/BitBoardTopic.php
@@ -0,0 +1,778 @@
+<?php
+/**
+ * $Header$
+ * $Id$
+ *
+ * Messageboards class to illustrate best practices when creating a new bitweaver package that
+ * builds on core bitweaver functionality, such as the Liberty CMS engine
+ *
+ * @author spider <spider@steelsun.com>
+ * @version $Revision$
+ * @package boards
+ */
+
+/**
+ * required setup
+ */
+require_once( LIBERTY_PKG_CLASS_PATH.'LibertyComment.php' );
+require_once( BOARDS_PKG_CLASS_PATH.'BitBoardPost.php' );
+
+/**
+* This is used to uniquely identify the object
+*/
+define( 'BITBOARDTOPIC_CONTENT_TYPE_GUID', 'bitboardtopic' );
+
+/**
+ * expunge is handled explicitly in LibertyComment::expunge
+ * @package boards
+ */
+class BitBoardTopic extends LibertyMime {
+ /**
+ * Primary key for our mythical Messageboards class object & table
+ * @public
+ */
+ public $mRootId;
+
+ /**
+ * the content id of the topic comment object
+ * this is really the contentId, but mContentId houses the parent board content_id currently
+ **/
+ public $mCommentContentId;
+
+ /**
+ * During initialisation, be sure to call our base constructors
+ **/
+ function __construct( $pRootId=NULL ) {
+ parent::__construct();
+ $this->mRootId = (int)$pRootId;
+
+ // Permission setup
+ $this->mViewContentPerm = 'p_boards_read';
+ $this->mUpdateContentPerm = 'p_boards_update';
+ $this->mAdminContentPerm = 'p_boards_admin';
+
+ $this->mRootObj = NULL; //a reference to the root obj
+ }
+
+ /**
+ * Load the data from the database
+ * @param pParamHash be sure to pass by reference in case we need to make modifcations to the hash
+ **/
+ function load( $pContentId = NULL, $pPluginParams = NULL ) {
+ global $gBitUser, $gBitSystem;
+ if( $this->verifyId( $this->mRootId ) || $this->verifyId( $this->mContentId ) ) {
+ // This is a significant performance optimization
+ $lookupColumn = $this->verifyId( $this->mRootId ) ? 'lcom.`comment_id`' : 'lc.`content_id`';
+ $bindVars = array();
+ $selectSql = $joinSql = $whereSql = '';
+ array_push( $bindVars, $lookupId = @BitBase::verifyId( $this->mRootId ) ? $this->mRootId : $this->mContentId );
+ $paramHash = array( array( 'include_comments' => TRUE ) );
+ $this->getServicesSql( 'content_load_sql_function', $selectSql, $joinSql, $whereSql, $bindVars, $this, $paramHash );
+
+ if (!($gBitUser->hasPermission('p_boards_update') || $gBitUser->hasPermission('p_boards_posts_update'))) {
+ //$whereSql .= " AND ((first.`is_approved` = 1) OR (flc.`user_id` >= 0))";
+ }
+
+ BitBoardTopic::loadTrack($selectSql, $joinSql);
+
+ $BIT_DB_PREFIX = BIT_DB_PREFIX;
+ $query ="
+ SELECT
+ lc.`user_id` AS flc_user_id,
+ lc.`created` AS flc_created,
+ lc.`last_modified` AS flc_last_modified,
+ lc.`title` AS title,
+ lc.`content_id` AS flc_content_id,
+
+ COALESCE(post.`is_approved`,0) AS first_approved,
+ lcom.`anon_name`,
+
+ th.`parent_id` AS th_first_id,
+ COALESCE(th.`is_locked`,0) AS th_is_locked,
+ COALESCE(th.`is_moved`,0) AS th_is_moved,
+ COALESCE(th.`is_sticky`,0) AS th_is_sticky,
+
+ lcom.`comment_id` AS th_thread_id,
+ lcom.`root_id` AS th_root_id,
+ lcom.`root_id` AS content_id,
+ lc.`content_type_guid` AS content_type_guid,
+
+ rlc.content_id AS root_content_id, rlc.title AS root_title, rlc.content_type_guid AS `root_content_type_guid`,
+
+ map.`board_content_id` AS board_content_id, b.`board_id`
+
+ $selectSql
+ FROM `".BIT_DB_PREFIX."liberty_comments` lcom
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON( lc.`content_id` = lcom.`content_id` )
+ INNER JOIN `".BIT_DB_PREFIX."boards_map` map ON (map.`topic_content_id`=lcom.`root_id` )
+ INNER JOIN `".BIT_DB_PREFIX."boards` b ON (map.`board_content_id`=b.`content_id` )
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` rlc ON (rlc.`content_id` = lcom.`root_id`)
+ $joinSql
+ LEFT JOIN `".BIT_DB_PREFIX."boards_topics` th ON (th.`parent_id`=lcom.`content_id`)
+ LEFT JOIN `".BIT_DB_PREFIX."boards_posts` post ON(post.`comment_id`=lcom.`comment_id`)
+ WHERE
+ lcom.`root_id`=lcom.`parent_id` AND $lookupColumn=?
+ $whereSql";
+
+ $result = $this->mDb->query( $query, $bindVars );
+
+ if( $result && $result->numRows() ) {
+ $this->mInfo = $result->fields;
+ $this->mContentId = $this->getField( 'content_id' );
+ $this->mCommentContentId = $this->getField('flc_content_id');
+ $llc_data = BitBoardTopic::getLastPost($this->mInfo);
+ $this->mInfo = array_merge($this->mInfo,$llc_data);
+ $this->mRootId = $result->fields['th_thread_id'];
+ // @TODO this would make more sense if this were assigned to mRootId - but that is currently in use as top comment id
+ $this->mInfo['root_id'] = $result->fields['th_root_id'];
+ BitBoardTopic::track($this->mInfo);
+ $this->mInfo['display_url'] = $this->getDisplayUrl();
+
+ if (empty($this->mInfo['anon_name'])) {
+ $this->mInfo['anon_name'] = "Anonymous";
+ }
+
+ parent::load(); // assumes you have joined already, and will not execute any sql!
+ }
+ }
+ return( count( $this->mInfo ) );
+ }
+
+ function lookupByMigratePost( $pMigratePostId ) {
+ global $gBitDb;
+ $ret = NULL;
+ if( BitBase::verifyId( $pMigratePostId ) ) {
+ $path = $gBitDb->getOne( "SELECT lcom.`thread_forward_sequence` FROM `".BIT_DB_PREFIX."boards_posts` bp INNER JOIN `".BIT_DB_PREFIX."liberty_comments` lcom ON(bp.`comment_id`=lcom.`comment_id`) WHERE bp.`migrate_post_id`=?", array( $pMigratePostId ) );
+ if( $path ) {
+ $ret = boards_get_topic_comment( $path );
+ }
+ }
+ return $ret;
+ }
+
+ function lookupByMigrateTopic( $pMigrateTopicId ) {
+ global $gBitDb;
+ $ret = NULL;
+ if( BitBase::verifyId( $pMigrateTopicId ) ) {
+ $ret = $gBitDb->getOne( "SELECT lcom.`comment_id` FROM `".BIT_DB_PREFIX."boards_topics` bt INNER JOIN `".BIT_DB_PREFIX."liberty_comments` lcom ON(bt.`parent_id`=lcom.`content_id`) WHERE `migrate_topic_id`=?", array( $pMigrateTopicId ) );
+ }
+ return $ret;
+ }
+
+ function verify( &$pParamHash ) {
+ if( isset( $pParamHash['is_locked'] ) ) {
+ if( !is_numeric( $pParamHash['is_locked'] ) || $pParamHash['is_locked'] > 1 || $pParamHash['is_locked'] < 0 ) {
+ $this->mErrors[]=("Invalid topic state");
+ } else {
+ $pParamHash['topic_store']['is_locked'] = $pParamHash['is_locked'];
+ }
+ }
+ if( isset( $pParamHash['is_moved'] ) ) {
+ if( !is_numeric( $pParamHash['is_moved'] ) || $pParamHash['is_moved'] > 1 || $pParamHash['is_moved'] < 0 ) {
+ $this->mErrors[]=("Invalid move state");
+ } else {
+ $pParamHash['topic_store']['is_moved'] = $pParamHash['is_moved'];
+ }
+ }
+ if( !empty( $pParamHash['is_sticky'] ) ) {
+ if( !is_numeric( $pParamHash['is_sticky'] ) || $pParamHash['is_sticky'] > 1 || $pParamHash['is_sticky'] < 0 ) {
+ $this->mErrors[]=("Invalid sticky state");
+ } else {
+ $pParamHash['topic_store']['is_sticky'] = $pParamHash['is_sticky'];
+ }
+ }
+ if( !empty( $pParamHash['migrate_topic_id'] ) ) {
+ $pParamHash['topic_store']['migrate_topic_id'] = $pParamHash['migrate_topic_id'];
+ }
+
+ return( count( $this->mErrors ) == 0 && !empty( $pParamHash['topic_store'] ) );
+ }
+
+ /**
+ * This function stickies a topic
+ */
+ function store( &$pParamHash ) {
+ global $gBitSystem;
+ $ret = FALSE;
+ if( $this->mCommentContentId && $this->verify( $pParamHash ) ) {
+ //$pParamHash = (($pParamHash + 1)%2);
+ $query_sel = "SELECT * FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?";
+ $isStored = $this->mDb->getOne( $query_sel, array( $this->mCommentContentId ) );
+ if( $isStored ) {
+ $result = $this->mDb->associateUpdate( 'boards_topics', $pParamHash['topic_store'], array( 'parent_id' => $this->mCommentContentId ) );
+ } else {
+ $pParamHash['topic_store']['parent_id'] = $this->mCommentContentId;
+ $result = $this->mDb->associateInsert( 'boards_topics', $pParamHash['topic_store'] );
+ }
+ $ret = TRUE;
+ }
+ return $ret;
+ }
+
+ /**
+ * This function locks a topic
+ */
+ function lock($state) {
+ global $gBitSystem;
+ $ret = FALSE;
+ if ($state==null || !is_numeric($state) || $state > 1 || $state<0) {
+ $this->mErrors[]=("Invalid current state");
+ } else {
+ $state = (($state+1)%2);
+ $query_sel = "SELECT * FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?";
+ $result = $this->mDb->query( $query_sel, array( $this->mCommentContentId ) );
+ if($result->RowCount()==0) {
+ $query_ins = "INSERT INTO `".BIT_DB_PREFIX."boards_topics` (`parent_id`,`is_locked`) VALUES ( ?, ?)";
+ $result = $this->mDb->query( $query_ins, array( $this->mCommentContentId, $state ) );
+ } else {
+ $query_up = "UPDATE `".BIT_DB_PREFIX."boards_topics` SET `is_locked` = ? WHERE `parent_id` = ?";
+ $result = $this->mDb->query( $query_up, array( $state, $this->mCommentContentId ) );
+ }
+ $ret = true;
+ }
+ return $ret;
+ }
+
+ /**
+ * This function stickies a topic
+ */
+ function sticky($state) {
+ global $gBitSystem;
+ $ret = FALSE;
+ if ($state==null || !is_numeric($state) || $state > 1 || $state<0) {
+ $this->mErrors[]=("Invalid current state");
+ } else {
+ $state = (($state+1)%2);
+ $query_sel = "SELECT * FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?";
+ $result = $this->mDb->query( $query_sel, array( $this->mCommentContentId ) );
+ if($result->RowCount()==0) {
+ $query_ins = "INSERT INTO `".BIT_DB_PREFIX."boards_topics` (`parent_id`,`is_sticky`) VALUES ( ?, ? )";
+ $result = $this->mDb->query( $query_ins, array( $this->mCommentContentId, $state ) );
+ } else {
+ $query_up = "UPDATE `".BIT_DB_PREFIX."boards_topics` SET `is_sticky` = ? WHERE `parent_id` = ?";
+ $result = $this->mDb->query( $query_up, array( $state, $this->mCommentContentId) );
+ }
+ $ret = TRUE;
+ }
+ return $ret;
+ }
+
+ /**
+ * This function moves a topic to a new messageboard
+ */
+ function moveTo($board_id) {
+
+ // start transaction
+ $this->StartTrans();
+
+ // create a new comment letting people know it has beem moved
+ $lcom = new LibertyComment();
+ $lcom_hash['edit']="The comments from: {$this->mInfo['title']} ({$this->mRootId}) have been is_moved to $board_id";
+ $lcom_hash['title']=$this->mInfo['title'];
+ $lcom_hash['parent_id']=$this->mInfo['th_root_id'];
+ $lcom_hash['root_id']=$this->mInfo['th_root_id'];
+ $lcom_hash['created']=$this->mInfo['flc_created'];
+ $lcom_hash['last_modified']=$this->mInfo['flc_last_modified'];
+ $lcom->storeComment($lcom_hash);
+
+ // map the move to the topic table
+ $data = array();
+ $data['parent_id']=$lcom->mContentId;
+ $data['is_moved']=$this->mRootId;
+ $this->mDb->associateInsert( BIT_DB_PREFIX."boards_topics", $data );
+
+ // move the comment we want to move to the target board
+ $query = "UPDATE `".BIT_DB_PREFIX."liberty_comments` SET `root_id` = ?, `parent_id` = ?
+ WHERE `thread_forward_sequence` LIKE '".sprintf("%09d.", $this->mRootId)."%' AND `root_id`=`parent_id`";
+ $result = $this->mDb->query( $query, array( $board_id, $board_id ) );
+
+ $query = "UPDATE `".BIT_DB_PREFIX."liberty_comments` SET `root_id` = ?
+ WHERE `thread_forward_sequence` LIKE '".sprintf("%09d.", $this->mRootId)."%'";
+ $result = $this->mDb->query( $query, array( $board_id ) );
+
+ // end transaction
+ $this->CompleteTrans();
+
+ return TRUE;
+ }
+
+ /**
+ * This function generates a list of records from the liberty_content database for use in a list page
+ */
+ function getList( &$pParamHash ) {
+ global $gBitSystem, $gBitUser;
+ $BIT_DB_PREFIX = BIT_DB_PREFIX;
+ // this makes sure parameters used later on are set
+ LibertyMime::prepGetList( $pParamHash );
+
+ $selectSql = $joinSql = $whereSql = '';
+ $bindVars = array();
+ $pParamHash['include_comments'] = 'y';
+ $this->getServicesSql( 'content_list_sql_function', $selectSql, $joinSql, $whereSql, $bindVars, NULL, $pParamHash );
+
+ // this will set $find, $sort_mode, $max_records and $offset
+ extract( $pParamHash );
+
+ if(empty($find)) {
+ } elseif( is_array( $find ) ) {
+ // you can use an array of pages
+ $whereSql .= " AND flc.`title` IN( ".implode( ',',array_fill( 0,count( $find ),'?' ) )." )";
+ $bindVars = array_merge ( $bindVars, $find );
+ } elseif( is_string( $find ) ) {
+ // or a string
+ $bindVars[] = '%'. strtoupper( $find ).'%';
+ $whereSql .= " AND UPPER( lc.`title` ) LIKE ?";
+ }
+
+ // if we have the board's board_id (b) we use that, or if we have its content_id we can use that
+ if( (!empty( $pParamHash['b'] ) && $this->verifyId( $pParamHash['b'] ))
+ || (!empty( $pParamHash['content_id'] ) && $this->verifyId( $pParamHash['content_id'] )) ) {
+ $joinSql .= " INNER JOIN `${BIT_DB_PREFIX}boards_map` map ON (map.`topic_content_id` = lcom.`root_id`)";
+ $joinSql .= " INNER JOIN `${BIT_DB_PREFIX}boards` b ON (b.`content_id` = map.`board_content_id`)";
+ if(!empty($pParamHash['b'])) {
+ $whereSql .= " AND b.`board_id` = ?";
+ $bindVars[] = (int)$pParamHash['b'];
+ }else{
+ $whereSql .= " AND b.`content_id` = ?";
+ $bindVars[] = (int)$pParamHash['content_id'];
+ }
+ }
+
+ BitBoardTopic::loadTrack($selectSql,$joinSql);
+
+ // use adodb's substr property
+ $substr = $this->mDb->substr();
+
+ if ( $this->mDb->mType == 'firebird' ) {
+ $substrSql = "SUBSTRING(s_lcom.`thread_forward_sequence` FROM 1 FOR 10) LIKE SUBSTRING(lcom.`thread_forward_sequence` FROM 1 FOR 10)";
+ } else {
+ $substrSql = "$substr(s_lcom.`thread_forward_sequence`, 1, 10) LIKE $substr(lcom.`thread_forward_sequence`, 1, 10)";
+ }
+
+ if ($gBitSystem->isFeatureActive('boards_posts_anon_moderation') && !($gBitUser->hasPermission('p_boards_update') || $gBitUser->hasPermission('p_boards_post_update'))) {
+ $whereSql .= " AND ((post.`is_approved` = 1) OR (lc.`user_id` >= 0))";
+ }
+ if ($gBitSystem->isFeatureActive('boards_posts_anon_moderation') && ($gBitUser->hasPermission('p_boards_update') || $gBitUser->hasPermission('p_boards_post_update'))) {
+ $selectSql .= ", ( SELECT COUNT(*)
+ FROM `${BIT_DB_PREFIX}liberty_comments` AS s_lcom
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` s_lc ON (s_lcom.`content_id` = s_lc.`content_id`)
+ LEFT JOIN `${BIT_DB_PREFIX}boards_posts` s ON( s_lcom.`comment_id` = s.`comment_id` )
+ WHERE (".$substrSql.") AND ((s_lc.`user_id` < 0) AND (s.`is_approved` = 0 OR s.`is_approved` IS NULL))) AS unreg";
+ } else {
+ $selectSql .= ", 0 AS unreg";
+ }
+
+ $sort_sql = "flc.".$this->mDb->convertSortmode( $sort_mode );
+
+ $query = "SELECT
+ lc.`user_id` AS flc_user_id,
+ lc.`created` AS flc_created,
+ lc.`last_modified` AS flc_last_modified,
+ lc.`title` AS title,
+ lc.`content_id` AS flc_content_id,
+
+ COALESCE(post.`is_approved`,0) AS first_approved,
+ lcom.`anon_name`,
+
+ th.`parent_id` AS th_first_id,
+ COALESCE(th.`is_locked`,0) AS th_is_locked,
+ COALESCE(th.`is_moved`,0) AS th_is_moved,
+ COALESCE(th.`is_sticky`,0) AS th_is_sticky,
+
+ lcom.`comment_id` AS th_thread_id,
+ lcom.`root_id` AS th_root_id,
+
+ lcom.`root_id` AS content_id,
+ lc.`content_type_guid` AS content_type_guid,
+ lc.`content_status_id` AS content_status_id,
+
+ (
+ SELECT COUNT(*)
+ FROM `".BIT_DB_PREFIX."liberty_comments` s_lcom
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` s_lc ON (s_lcom.`content_id` = s_lc.`content_id`)
+ WHERE (".$substrSql.")
+ ) AS post_count,
+
+ (
+ SELECT MAX(s_lc.created)
+ FROM `".BIT_DB_PREFIX."liberty_comments` s_lcom
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` s_lc ON (s_lcom.`content_id` = s_lc.`content_id`)
+ WHERE (".$substrSql.")
+ ) AS last_post
+
+ $selectSql
+ FROM `${BIT_DB_PREFIX}liberty_comments` lcom
+ INNER JOIN `${BIT_DB_PREFIX}liberty_content` lc ON( lc.`content_id` = lcom.`content_id` )
+ LEFT JOIN `${BIT_DB_PREFIX}boards_topics` th ON (th.`parent_id`=lcom.`content_id`)
+ LEFT JOIN `${BIT_DB_PREFIX}boards_posts` post ON (post.`comment_id` = lcom.`comment_id`)
+ $joinSql
+ WHERE
+ lcom.`root_id`=lcom.`parent_id`
+ $whereSql
+ ORDER BY
+ 11 DESC,
+ 10 ASC,
+ last_post DESC,
+ lc.created DESC
+ ";
+
+ $query_cant = "SELECT count(*)
+ FROM `${BIT_DB_PREFIX}liberty_comments` lcom
+ INNER JOIN `${BIT_DB_PREFIX}liberty_content` lc ON( lc.`content_id` = lcom.`content_id` )
+ LEFT JOIN `${BIT_DB_PREFIX}boards_topics` th ON (th.`parent_id`=lcom.`content_id`)
+ LEFT JOIN `${BIT_DB_PREFIX}boards_posts` post ON (post.`comment_id` = lcom.`comment_id`)
+ $joinSql
+ WHERE
+ lcom.`root_id`=lcom.`parent_id`
+ $whereSql";
+
+ $result = $this->mDb->query( $query, $bindVars, $max_records, $offset );
+ $ret = array();
+ while( $res = $result->fetchRow() ) {
+ if (empty($res['anon_name'])) $res['anon_name'] = "Anonymous";
+ if ($res['th_is_moved']>0) {
+ $res['url']=BOARDS_PKG_URL."index.php?t=".$res['th_is_moved'];
+ } else {
+ $res['url']=BOARDS_PKG_URL."index.php?t=".$res['th_thread_id'];
+ }
+ $llc_data = BitBoardTopic::getLastPost($res);
+ $res = array_merge($res,$llc_data);
+ BitBoardTopic::track($res);
+ $res['flip']=BitBoardTopic::getFlipFlop($res);
+ if (empty($res['title'])) {
+ $res['title']="[Thread ".$res['th_thread_id']."]";
+ }
+ $ret[] = $res;
+ }
+ $pParamHash["cant"] = $this->mDb->getOne( $query_cant, $bindVars );
+ // add all pagination info to pParamHash
+ LibertyMime::postGetList( $pParamHash );
+ return $ret;
+ }
+
+ function getLastPost($data) {
+ global $gBitSystem;
+ if ( $this->mDb->mType == 'firebird' ) {
+ $substrSql = "SUBSTRING(lcom.`thread_forward_sequence` FROM 1 FOR 10)";
+ } else {
+ $substrSql = "".$this->mDb->substr()."(lcom.`thread_forward_sequence`, 1, 10)";
+ }
+ $whereSql = '';
+ if ($gBitSystem->isFeatureActive('boards_posts_anon_moderation')) {
+ $whereSql = " AND ((post.`is_approved` = 1) OR (lc.`user_id` >= 0))";
+ }
+ $BIT_DB_PREFIX = BIT_DB_PREFIX;
+ $query="SELECT lc.`last_modified` AS llc_last_modified, lc.`user_id` AS llc_user_id, lc.`content_id` AS llc_content_id, lcom.`anon_name` AS l_anon_name
+ FROM `".BIT_DB_PREFIX."liberty_comments` lcom
+ INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON (lcom.`content_id` = lc.`content_id`)
+ LEFT JOIN `${BIT_DB_PREFIX}boards_posts` post ON (post.`comment_id` = lcom.`comment_id`)
+ WHERE (".$substrSql.") LIKE '".sprintf("%09d.",$data['th_thread_id'])."%' $whereSql
+ ORDER BY lc.`last_modified` DESC
+ ";
+ $result = $this->mDb->getRow( $query);
+ if (empty($result['l_anon_name'])) $result['l_anon_name'] = "Anonymous";
+ return $result;
+ }
+
+ /**
+ * Generates the URL to the bitboard page
+ * @return the link to display the page.
+ */
+ public static function getDisplayUrlFromHash( &$pParamHash ) {
+ global $gBitSystem;
+ $ret = NULL;
+
+ if( !empty( $pParamHash['topic_id'] ) && static::verifyId( $pParamHash['topic_id'] ) ) {
+ $topicId = $pParamHash['topic_id'];
+ } elseif( !empty( $pParamHash['th_thread_id'] ) && static::verifyId( $pParamHash['th_thread_id'] ) ) {
+ $topicId = $pParamHash['th_thread_id'];
+ }
+
+ if( !empty( $topicId ) ) {
+ if( $gBitSystem->isFeatureActive( 'pretty_urls' ) || $gBitSystem->isFeatureActive( 'pretty_urls_extended' ) ) {
+ $rewrite_tag = $gBitSystem->isFeatureActive( 'pretty_urls_extended' ) ? 'view/' : '';
+ $ret = BOARDS_PKG_URL.$rewrite_tag."topic/".$topicId;
+ } else {
+ $ret = BOARDS_PKG_URL."index.php?t=".$topicId;
+ }
+ }
+ return $ret;
+ }
+
+ public static function isLocked( $pThreadId ) {
+ global $gBitSystem;
+/*
+ // remove mixed static / dynamic function invocation
+ if (!$pThreadId) {
+ $pThreadId = $this->mCommentContentId;
+ } else {
+ $pThreadId=intval($pThreadId);
+ }
+*/
+ $ret = $gBitSystem->mDb->getOne("SELECT `is_locked` FROM `".BIT_DB_PREFIX."boards_topics` WHERE `parent_id` = ?", array( (int)$pThreadId ) );
+ return !empty($ret);
+ }
+
+ public static function isLockedMsg( $parent_id ) {
+ // $parentComment = new LibertyComment(NULL,$parent_id);
+ // $topicId = $parentComment->mInfo['thread_forward_sequence'];
+ if (!empty($parent_id)) {
+ return BitBoardTopic::isLocked($parent_id);
+ }
+ return false;
+ }
+
+ public static function isNotificationOn( $pThreadId ) {
+ global $gBitSystem, $gBitUser;
+ if ($gBitSystem->isPackageActive('boards') && $gBitSystem->isFeatureActive('boards_thread_track')) {
+/*
+ // remove mixed static / dynamic function invocation
+ if (!$pThreadId) {
+ $pThreadId = $this->mRootId;
+ }
+ if (is_numeric($pThreadId)) {
+ $topicId = sprintf("%09d.",$pThreadId);
+ }
+*/
+ return $gBitSystem->mDb->getOne("SELECT SUM(`notify`) FROM `".BIT_DB_PREFIX."boards_tracking` WHERE topic_id=?", array( (int)$topicId ) );
+ }
+ return false;
+ }
+
+ function getNotificationData($pThreadId) {
+ global $gBitSystem, $gBitUser;
+ if ($gBitSystem->isPackageActive('boards') && $gBitSystem->isFeatureActive('boards_thread_track')) {
+ if (!$pThreadId) {
+ $pThreadId = $this->mRootId;
+ }
+ if (is_numeric($pThreadId)) {
+ $topicId = sprintf("%09d.",$pThreadId);
+ }
+ $query = "SELECT uu.user_id, uu.email, uu.login, uu.real_name, trk.`track_date`, trk.`notify` AS track_notify, trk.`notify_date` AS track_notify_date
+ FROM `".BIT_DB_PREFIX."boards_tracking` trk
+ LEFT JOIN `".BIT_DB_PREFIX."users_users` uu ON( uu.`user_id` = trk.`user_id` )
+ WHERE topic_id=?";
+
+ $result = $gBitSystem->mDb->query( $query, array( $topicId ) );
+ $ret = array();
+ $ret['users']=array();
+ while( $res = $result->fetchRow() ) {
+ $res['user'] =( isset( $res['real_name'] )? $res['real_name'] : $res['login'] );
+ $ret['users'][$res['login']] = $res;
+ }
+ $ret['topic'] = new BitBoardTopic(intval($topicId));
+ $ret['topic']->load();
+ return $ret;
+ }
+
+ return array();
+ }
+
+ function sendNotification($user) {
+ global $gBitSystem;
+ //return;
+ $mail_subject= "Topic Reply Notification - ".$this->mInfo['title'];
+ $host = 'http://'.$_SERVER['HTTP_HOST'];
+ //TODO: use a template for this
+ $mail_message = "Hello ".$user['user'].",
+
+ You are receiving this email because you are watching the topic, \"".$this->mInfo['title']."\" at ".$gBitSystem->getConfig('site_title',"[Bitweaver Site]").".
+ This topic has received a reply since your last visit.
+ You can use the following link to view the replies made, no more notifications will be sent until you visit the topic.
+
+ ".$host.$this->getDisplayUrl()."
+
+ If you no longer wish to watch this topic you can either click the \"Stop watching this topic link\" found at the topic of the topic above, or by clicking the following link after logging on:
+
+ ".$host.$this->getDisplayUrl()."&notify=1";
+
+ @mail($user['email'], $mail_subject , $mail_message, "From: ".$gBitSystem->getConfig( 'site_sender_email' )."\r\nContent-type: text/plain;charset=utf-8\r\n");
+
+ $data = array(
+ 'notify_date'=>time(),
+ );
+
+ $key = array(
+ 'user_id' =>$user['user_id'],
+ 'topic_id' =>sprintf("%09d.",$this->mRootId),
+ );
+
+ $this->mDb->associateUpdate(BIT_DB_PREFIX."boards_tracking",$data,$key);
+ }
+
+ function getFlipFlop($arr=false) {
+ if(! $arr) {
+ $arr = $this->mInfo;
+ }
+ global $gBitSmarty, $gBitSystem, $gBitUser;
+
+ $flip['is_locked']['state']=$arr['th_is_locked'];
+ $flip['is_locked']['req']=2;
+ $flip['is_locked']['id']=$arr['th_thread_id'];
+ $flip['is_locked']['idname']='t';
+ $flip['is_locked']['up']='icon-lock';
+ $flip['is_locked']['upname']=tra('Thread Locked');
+ $flip['is_locked']['down']='icon-unlock';
+ $flip['is_locked']['downname']=tra('Thread Unlocked');
+ $flip['is_locked']['perm']='p_boards_update';
+
+ $flip['is_sticky']['state']=$arr['th_is_sticky'];
+ $flip['is_sticky']['req'] = 3;
+ $flip['is_sticky']['id']=$arr['th_thread_id'];
+ $flip['is_sticky']['idname']='t';
+ $flip['is_sticky']['up']='icon-exclamation-sign';
+ $flip['is_sticky']['upname']=tra('Sticky Thread');
+ $flip['is_sticky']['down']='icon-list';
+ $flip['is_sticky']['downname']=tra('Non Sticky Thread');
+ $flip['is_sticky']['perm']='p_boards_update';
+
+ if ($gBitSystem->isFeatureActive('boards_thread_notification') && $gBitUser->isRegistered()) {
+ $flip['notify']['state']=($arr['notify']['on'])*1;
+ $flip['notify']['req']=5;
+ $flip['notify']['id']=$arr['th_thread_id'];
+ $flip['notify']['idname']='t';
+ $flip['notify']['up']='icon-bell-alt';
+ $flip['notify']['upname']=tra('Reply Notification');
+ $flip['notify']['down']='icon-bell';
+ $flip['notify']['downname']=tra('Reply Notification Disabled');
+ $flip['notify']['perm']='p_boards_read';
+ }
+ if ($gBitSystem->isFeatureActive('boards_thread_track') && $gBitUser->isRegistered()) {
+ $flip['new']['state']=($arr['track']['on']&&$arr['track']['mod'])*1;
+ $flip['new']['req']=4;
+ $flip['new']['id']=$arr['th_thread_id'];
+ $flip['new']['idname']='t';
+ $flip['new']['up']='icon-asterisk';
+ $flip['new']['upname']=tra('New Posts');
+// $flip['new']['down']='icon-comment-alt';
+// $flip['new']['downname']=tra('No new posts');
+ $flip['new']['perm']='p_boards_read';
+ }
+
+ return $flip;
+ }
+
+ function readTopic() {
+ global $gBitUser, $gBitSystem;
+ if ($gBitSystem->isFeatureActive('boards_thread_track') && $gBitUser->isRegistered()) {
+ $topicId = sprintf("%09d.",$this->mRootId);
+ $BIT_DB_PREFIX = BIT_DB_PREFIX;
+ $c = $this->mDb->getOne("SELECT COUNT(*) FROM `".BIT_DB_PREFIX."boards_tracking` WHERE user_id=? AND topic_id='$topicId'",array($gBitUser->mUserId));
+
+ $data = array(
+ 'user_id' =>$gBitUser->mUserId,
+ 'topic_id' =>$topicId,
+ 'track_date'=>time(),
+ );
+
+ if ($c == 0) {
+ $this->mDb->associateInsert(BIT_DB_PREFIX."boards_tracking",$data);
+ } else {
+ $key = array(
+ 'user_id' =>$gBitUser->mUserId,
+ 'topic_id' =>$topicId,
+ );
+ $this->mDb->associateUpdate(BIT_DB_PREFIX."boards_tracking",$data,$key);
+ }
+ $this->mInfo['track']['mod']=false;
+ }
+ }
+
+ function readTopicSet($pState) {
+ global $gBitUser, $gBitSystem;
+ if ($gBitSystem->isFeatureActive('boards_thread_track') && $gBitUser->isRegistered()) {
+ $topicId = sprintf("%09d.",$this->mRootId);
+ $ret = FALSE;
+ if ($pState==null || !is_numeric($pState) || $pState > 1 || $pState<0) {
+ $this->mErrors[]=("Invalid current state");
+ } else {
+ $pState = (($pState+1)%2);
+ if ($pState == 0) {
+ $this->readTopic();
+ } else {
+ $this->mDb->query("DELETE FROM `".BIT_DB_PREFIX."boards_tracking` WHERE user_id=$gBitUser->mUserId AND topic_id='$topicId'");
+ }
+ $ret = true;
+ }
+ return $ret;
+ }
+ }
+
+ function notify($pState) {
+ global $gBitUser, $gBitSystem;
+ if ($gBitSystem->isFeatureActive('boards_thread_track') && $gBitUser->isRegistered()) {
+ $topicId = sprintf("%09d.",$this->mRootId);
+ $ret = FALSE;
+ if ($pState==null || !is_numeric($pState) || $pState > 1 || $pState<0) {
+ $this->mErrors[]=("Invalid current state");
+ } else {
+ $pState = (($pState+1)%2);
+ $query_sel = "SELECT * FROM `".BIT_DB_PREFIX."boards_tracking` WHERE user_id=$gBitUser->mUserId AND topic_id='$topicId'";
+ $data = array(
+ 'user_id' =>$gBitUser->mUserId,
+ 'topic_id' =>$topicId,
+ 'notify'=>$pState,
+ );
+ $c = $this->mDb->getOne( $query_sel );
+ if ($c == 0) {
+ $this->mDb->associateInsert(BIT_DB_PREFIX."boards_tracking",$data);
+ } else {
+ $key = array(
+ 'user_id' =>$gBitUser->mUserId,
+ 'topic_id' =>$topicId,
+ );
+ $this->mDb->associateUpdate(BIT_DB_PREFIX."boards_tracking",$data,$key);
+ }
+ $ret = true;
+ }
+ return $ret;
+ }
+ }
+
+ function loadTrack(&$selectSql,&$joinSql) {
+ global $gBitUser, $gBitSystem;
+ if($gBitUser->isRegistered() && ($gBitSystem->isFeatureActive('boards_thread_track') || $gBitSystem->isFeatureActive('boards_thread_notify'))) {
+ $selectSql .= ", trk.`track_date`, trk.`notify` AS track_notify, trk.`notify_date` AS track_notify_date ";
+ $joinSql .= " LEFT JOIN `".BIT_DB_PREFIX."boards_tracking` trk ON (trk.`topic_id`=lcom.`thread_forward_sequence` AND ( trk.`user_id` = ".$gBitUser->mUserId." OR trk.`user_id` IS NULL ) ) ";
+ }
+ }
+
+ function track(&$res) {
+ global $gBitUser, $gBitSystem;
+ if($gBitUser->isRegistered() && $gBitSystem->isFeatureActive('boards_thread_track') && $res['th_is_moved']<=0) {
+ $res['track']['on'] = true;
+ $res['track']['date'] = $res['track_date'];
+ if (empty($res['llc_last_modified'])) {
+ $res['llc_last_modified']=0;
+ }
+ if ($res['llc_last_modified']>$res['track_date']) {
+ $res['track']['mod'] = true;
+ } else {
+ $res['track']['mod'] = false;
+ }
+ } else {
+ $res['track']['on'] = false;
+ }
+ unset($res['track_date']);
+ if($gBitUser->isRegistered() && $gBitSystem->isFeatureActive('boards_thread_notification') && $res['th_is_moved']<=0) {
+ $res['notify']['on'] = (!empty($res['track_notify']));
+ if ($res['notify']['on']) {
+ $res['notify']['date']=$res['track_notify_date'];
+ }
+ } else {
+ $res['notify']['on'] = false;
+ }
+ unset($res['track_notify_date']);
+ unset($res['track_notify']);
+ }
+
+ 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;
+ }
+}
+?>
generated by cgit v1.3 (git 2.53.0) at 2026-06-29 21:12:06 +0000