420 lines
9.9 KiB
PHP
420 lines
9.9 KiB
PHP
<?php
|
|
/**
|
|
* Holds the thread object class.
|
|
*
|
|
* @package Sakura
|
|
*/
|
|
|
|
namespace Sakura\Forum;
|
|
|
|
use Sakura\DB;
|
|
|
|
/**
|
|
* Used to serve, create and update threads.
|
|
*
|
|
* @package Sakura
|
|
* @author Julian van de Groep <me@flash.moe>
|
|
*/
|
|
class Thread
|
|
{
|
|
/**
|
|
* The ID of this thread.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $id = 0;
|
|
|
|
/**
|
|
* The ID of the forum this thread is a part of.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $forum = 0;
|
|
|
|
/**
|
|
* Is this forum hidden from the listing?
|
|
*
|
|
* @var bool
|
|
*/
|
|
public $hidden = false;
|
|
|
|
/**
|
|
* The title of the thread.
|
|
*
|
|
* @var string
|
|
*/
|
|
public $title = "";
|
|
|
|
/**
|
|
* The UNIX timestamp of when this thread was created.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $time = 0;
|
|
|
|
/**
|
|
* The UNIX timestamp of when this thread should be autolocked (currently unused).
|
|
*
|
|
* @var int
|
|
*/
|
|
public $timeLimit = 0;
|
|
|
|
/**
|
|
* The amount of times this thread has been viewed.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $views = 0;
|
|
|
|
/**
|
|
* The status of this thread.
|
|
* 0 - Unlocked
|
|
* 1 - Locked
|
|
*
|
|
* @var int
|
|
*/
|
|
public $status = 0;
|
|
|
|
/**
|
|
* The UNIX timestamp of when the status was last changed.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $statusChange = 0;
|
|
|
|
/**
|
|
* The thread type
|
|
* 0 - Normal thread
|
|
* 1 - Sticky thread
|
|
* 2 - Announcement
|
|
*
|
|
* @var int
|
|
*/
|
|
public $type = 0;
|
|
|
|
/**
|
|
* The ID of the forum this thread was a part of before the last move.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $oldForum = 0;
|
|
|
|
/**
|
|
* The post object cache.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $_posts = [];
|
|
|
|
/**
|
|
* A cached instance of opening post.
|
|
*
|
|
* @var Post
|
|
*/
|
|
private $_firstPost = null;
|
|
|
|
/**
|
|
* A cached instance of the last reply.
|
|
*
|
|
* @var Post
|
|
*/
|
|
private $_lastPost = null;
|
|
|
|
/**
|
|
* Constructor.
|
|
*
|
|
* @param mixed $threadId ID of the thread that should be constructed.
|
|
*/
|
|
public function __construct($threadId)
|
|
{
|
|
// Attempt to get the database row
|
|
$threadRow = DB::table('topics')
|
|
->where('topic_id', $threadId)
|
|
->get();
|
|
|
|
// Assign data if a row was returned
|
|
if ($threadRow) {
|
|
$threadRow = $threadRow[0];
|
|
$this->id = $threadRow->topic_id;
|
|
$this->forum = $threadRow->forum_id;
|
|
$this->hidden = (bool) $threadRow->topic_hidden;
|
|
$this->title = $threadRow->topic_title;
|
|
$this->time = $threadRow->topic_time;
|
|
$this->timeLimit = $threadRow->topic_time_limit;
|
|
$this->views = $threadRow->topic_views;
|
|
$this->status = $threadRow->topic_status;
|
|
$this->statusChange = $threadRow->topic_status_change;
|
|
$this->type = $threadRow->topic_type;
|
|
$this->oldForum = $threadRow->topic_old_forum;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create a new thread.
|
|
*
|
|
* @param mixed $forum ID of the forum this thread is part of.
|
|
* @param mixed $title Title of the thread.
|
|
* @param mixed $status Status of the thread.
|
|
* @param mixed $type Type of thread.
|
|
*
|
|
* @return self The new thread instance.
|
|
*/
|
|
public static function create($forum, $title, $status = 0, $type = 0)
|
|
{
|
|
// Create the database entry
|
|
$id = DB::table('topics')
|
|
->insertGetId([
|
|
'forum_id' => $forum,
|
|
'topic_title' => $title,
|
|
'topic_time' => time(),
|
|
'topic_status' => $status,
|
|
'topic_type' => $type,
|
|
]);
|
|
|
|
// Return the thread object
|
|
return new Thread($id);
|
|
}
|
|
|
|
/**
|
|
* Delete the current thread.
|
|
*/
|
|
public function delete()
|
|
{
|
|
// Delete all posts
|
|
DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->delete();
|
|
|
|
// Delete thread meta
|
|
DB::table('topics')
|
|
->where('topic_id', $this->id)
|
|
->delete();
|
|
}
|
|
|
|
/**
|
|
* Move the thread.
|
|
*
|
|
* @param mixed $forum The new forum ID.
|
|
* @param mixed $setOld Remember the forum ID prior to the move for restoration.
|
|
*/
|
|
public function move($forum, $setOld = true)
|
|
{
|
|
// Update all posts
|
|
DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->update(['forum_id' => $forum]);
|
|
|
|
// Update thread meta
|
|
DB::table('topics')
|
|
->where('topic_id', $this->id)
|
|
->update([
|
|
'forum_id' => $forum,
|
|
'topic_old_forum' => ($setOld ? $this->forum : 0),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Update the thread data.
|
|
*
|
|
* @return self The updated thread.
|
|
*/
|
|
public function update()
|
|
{
|
|
// Update row
|
|
DB::table('topics')
|
|
->where('topic_id', $this->id)
|
|
->update([
|
|
'topic_hidden' => $this->hidden,
|
|
'topic_title' => $this->title,
|
|
'topic_time_limit' => $this->timeLimit,
|
|
'topic_status' => $this->status,
|
|
'topic_status_change' => $this->statusChange,
|
|
'topic_type' => $this->type,
|
|
'topic_old_forum' => $this->oldForum,
|
|
]);
|
|
|
|
// Return new object
|
|
return new Thread($this->id);
|
|
}
|
|
|
|
/**
|
|
* Get the replies to this thread.
|
|
*
|
|
* @return array Array containing Post instances.
|
|
*/
|
|
public function posts()
|
|
{
|
|
// Check if _posts is something
|
|
if (!count($this->_posts)) {
|
|
// Get all rows with the thread id
|
|
$postRows = DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->get(['post_id']);
|
|
|
|
// Create a storage array
|
|
$posts = [];
|
|
|
|
// Create new post objects for each post
|
|
foreach ($postRows as $post) {
|
|
$posts[$post->post_id] = new Post($post->post_id);
|
|
}
|
|
|
|
$this->_posts = $posts;
|
|
} else {
|
|
$posts = $this->_posts;
|
|
}
|
|
|
|
// Return the post objects
|
|
return $posts;
|
|
}
|
|
|
|
/**
|
|
* Get the opening post.
|
|
*
|
|
* @return Post A Post instance of the opening post.
|
|
*/
|
|
public function firstPost()
|
|
{
|
|
// Check if the cache var is set
|
|
if ($this->_firstPost !== null) {
|
|
return $this->_firstPost;
|
|
}
|
|
|
|
// Get the row from the database
|
|
$post = DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->orderBy('post_id')
|
|
->limit(1)
|
|
->get(['post_id']);
|
|
|
|
// Create the post class
|
|
$post = new Post($post ? $post[0]->post_id : 0);
|
|
|
|
// Assign it to the cache var
|
|
$this->_firstPost = $post;
|
|
|
|
// Return
|
|
return $post;
|
|
}
|
|
|
|
/**
|
|
* Get the latest reply.
|
|
*
|
|
* @return Post A Post instance of the latest reply.
|
|
*/
|
|
public function lastPost()
|
|
{
|
|
// Check if the cache var is set
|
|
if ($this->_lastPost !== null) {
|
|
return $this->_lastPost;
|
|
}
|
|
|
|
// Get the row from the database
|
|
$post = DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->orderBy('post_id', 'desc')
|
|
->limit(1)
|
|
->get(['post_id']);
|
|
|
|
// Create the post class
|
|
$post = new Post($post ? $post[0]->post_id : 0);
|
|
|
|
// Assign it to the cache var
|
|
$this->_lastPost = $post;
|
|
|
|
// Return
|
|
return $post;
|
|
}
|
|
|
|
/**
|
|
* Get the amount of replies.
|
|
*
|
|
* @return int The number of replies to this thread.
|
|
*/
|
|
public function replyCount()
|
|
{
|
|
return DB::table('posts')
|
|
->where('topic_id', $this->id)
|
|
->count();
|
|
}
|
|
|
|
/**
|
|
* Check if a user has read this thread before.
|
|
*
|
|
* @param mixed $user The id of the user in question.
|
|
*
|
|
* @return bool A boolean indicating the read status.
|
|
*/
|
|
public function unread($user)
|
|
{
|
|
// Attempt to get track row from the database
|
|
$track = DB::table('topics_track')
|
|
->where('user_id', $user)
|
|
->where('topic_id', $this->id)
|
|
->where('mark_time', '>', $this->lastPost()->time)
|
|
->count();
|
|
|
|
// If nothing was returned it's obvious that the status is unread
|
|
if (!$track) {
|
|
return true;
|
|
}
|
|
|
|
// Else just return false meaning everything is read
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Update the read status.
|
|
*
|
|
* @param mixed $user The id of the user in question.
|
|
*/
|
|
public function trackUpdate($user)
|
|
{
|
|
// Check if we already have a track record
|
|
$track = DB::table('topics_track')
|
|
->where('user_id', $user)
|
|
->where('topic_id', $this->id)
|
|
->where('forum_id', $this->forum)
|
|
->count();
|
|
|
|
// Adding a second to this to avoid own posts getting marked unread
|
|
$time = time() + 1;
|
|
|
|
// If so update it
|
|
if ($track) {
|
|
DB::table('topics_track')
|
|
->where('user_id', $user)
|
|
->where('topic_id', $this->id)
|
|
->update(['mark_time' => $time]);
|
|
} else {
|
|
// If not create a new record
|
|
DB::table('topics_track')
|
|
->insert([
|
|
'user_id' => $user,
|
|
'topic_id' => $this->id,
|
|
'forum_id' => $this->forum,
|
|
'mark_time' => $time,
|
|
]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Update the view count.
|
|
*/
|
|
public function viewsUpdate()
|
|
{
|
|
DB::table('topics')
|
|
->where('topic_id', $this->id)
|
|
->increment('topic_views');
|
|
}
|
|
|
|
/**
|
|
* Update the timestamp of when this thread was last replied to.
|
|
*/
|
|
public function lastUpdate()
|
|
{
|
|
DB::table('topics')
|
|
->where('topic_id', $this->id)
|
|
->update(['topic_last_reply' => time()]);
|
|
}
|
|
}
|