<?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
 */
namespace Bitweaver\Boards;

use Bitweaver\BitBase;
use Bitweaver\KernelTools;
use Bitweaver\Liberty\LibertyBase;
use Bitweaver\Liberty\LibertyComment;
use Bitweaver\Liberty\LibertyMime;
use function sprintf;

/**
* 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;
	public $mRootObj;

	/**
	 * 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 array 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 = [];
			$selectSql = $joinSql = $whereSql = '';
			array_push( $bindVars, $lookupId = BitBase::verifyId( $this->mRootId ) ? $this->mRootId : $this->mContentId );
			$paramHash = [ [ '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 ) );
	}

	public static 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`=?", [ $pMigratePostId ] );
			if( $path ) {
				$ret = boards_get_topic_comment( $path  );
			}
		}
		return $ret;
	}

	public static 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`=?", [ $pMigrateTopicId ] );
		}
		return $ret;
	}

	public function verify( array &$pParamHash ): bool {
		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
	 */
	public function store( array &$pParamHash ): bool {
		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, [ $this->mCommentContentId ] );
			if( $isStored ) {
				$result = $this->mDb->associateUpdate( 'boards_topics', $pParamHash['topic_store'], [ '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, [ $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, [ $this->mCommentContentId, $state ] );
			} else {
				$query_up = "UPDATE `".BIT_DB_PREFIX."boards_topics` SET `is_locked` = ? WHERE `parent_id` = ?";
				$result = $this->mDb->query( $query_up, [ $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, [ $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, [ $this->mCommentContentId, $state ] );
			} else {
				$query_up = "UPDATE `".BIT_DB_PREFIX."boards_topics` SET `is_sticky` = ? WHERE `parent_id` = ?";
				$result = $this->mDb->query( $query_up, [ $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 = [];
		$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, [ $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, [ $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 = [];
		$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();

		$substrSql = $this->mDb->mType == 'firebird' || $this->mDb->mType == 'pdo'
			? "SUBSTRING(s_lcom.`thread_forward_sequence` FROM 1 FOR 10) LIKE SUBSTRING(lcom.`thread_forward_sequence` FROM 1 FOR 10)"
			: "$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 = [];
		while( $res = $result->fetchRow() ) {
			if (empty($res['anon_name'])) $res['anon_name'] = "Anonymous";
			$res['url'] = ( $res['th_is_moved'] > 0 ) ? BOARDS_PKG_URL . "index.php?t=" . $res['th_is_moved'] : 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;
		$substrSql = $this->mDb->mType == 'firebird' || $this->mDb->mType == 'pdo'
			? "SUBSTRING(lcom.`thread_forward_sequence` FROM 1 FOR 10)"
			: "".$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 string 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 isThreadLocked( $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` = ?", [ (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::isThreadLocked($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;
			}
*/
			$topicId = ( is_numeric( $pThreadId ) ) ? sprintf( "%09d.", $pThreadId ) : 0;

			return $gBitSystem->mDb->getOne("SELECT SUM(`notify`) FROM `".BIT_DB_PREFIX."boards_tracking` WHERE topic_id=?", [ (int) $topicId ] );
		}
		return false;
	}

	public function getNotification($pThreadId) {
		global $gBitSystem;
		if ($gBitSystem->isPackageActive('boards') && $gBitSystem->isFeatureActive('boards_thread_track')) {
			if (!$pThreadId) {
				$pThreadId = $this->mRootId;
			}
			BitBoardTopic::getNotificationData($pThreadId);
		}
	}
	public static function getNotificationData($pThreadId) {
		global $gBitSystem, $gBitUser;
		if ($gBitSystem->isPackageActive('boards') && $gBitSystem->isFeatureActive('boards_thread_track')) {
			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, [ $topicId ] );
			$ret = [];
			$ret['users']=[];
			while( $res = $result->fetchRow() ) {
				$res['user'] =( $res['real_name'] ?? $res['login'] );
				$ret['users'][$res['login']] = $res;
			}
			$ret['topic'] = new BitBoardTopic((int) $topicId);
			$ret['topic']->load();
			return $ret;
		}

		return [];
	}

	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 = [
			'notify_date'=>time(),
		];

		$key = [
			'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']= KernelTools::tra('Thread Locked');
		$flip['is_locked']['down']='icon-unlock';
		$flip['is_locked']['downname']= KernelTools::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']= KernelTools::tra('Sticky Thread');
		$flip['is_sticky']['down']='icon-list';
		$flip['is_sticky']['downname']= KernelTools::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']= KernelTools::tra('Reply Notification');
			$flip['notify']['down']='icon-bell';
			$flip['notify']['downname']= KernelTools::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']= KernelTools::tra('New Posts');
//			$flip['new']['down']='icon-comment-alt';
//			$flip['new']['downname']= KernelTools::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'",[$gBitUser->mUserId]);

			$data = [
			'user_id' =>$gBitUser->mUserId,
			'topic_id' =>$topicId,
			'track_date'=>time(),
			];

			if ($c == 0) {
				$this->mDb->associateInsert(BIT_DB_PREFIX."boards_tracking",$data);
			} else {
				$key = [
				'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 = [
				'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 = [
					'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;
			}
			$res['track']['mod'] = ( $res['llc_last_modified'] > $res['track_date'] ) ? true : 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;
	}
}