RbComment\Model\CommentTable

Complexity

Total Complexity

11

Size/Duplication

Total Lines	159
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	fetchAll()	0	4	1
A	fetchAllForThread()	0	20	1
A	fetchAllPendingForThread()	0	20	1
A	fetchAllUsingSelect()	0	4	1
A	getComment()	0	8	1
B	saveComment()	0	24	3
A	deleteComment()	0	4	1
A	deleteSpam()	0	4	1

<?php
namespace RbComment\Model;

use Zend\Db\Sql\Select;
use Zend\Db\Sql\Expression;
use Zend\Db\TableGateway\TableGateway;

class CommentTable
{
    /**
     * @var TableGateway
     */
    protected $tableGateway;

    public function __construct(TableGateway $tableGateway)
    {
        $this->tableGateway = $tableGateway;
    }

    /**
     * Returns all the comments.
     *
     * @return ResultSet
     */
    public function fetchAll()
    {
        return $this->tableGateway->select();
    }

    /**
     * Returns all the comments of a thread.
     *
     * @param  string $thread
     *
     * @return ResultSet
     */
    public function fetchAllForThread($thread)
    {
        $columns = [
            'id',
            'author',
            'content',
            'contact',
            'published_on_raw' => 'published_on',
            'published_on'     => new Expression("DATE_FORMAT(published_on, '%M %d, %Y %H:%i')"),
        ];

        $select = new Select($this->tableGateway->getTable());
        $select->columns($columns)
               ->where(['thread' => $thread, 'visible' => 1])
               ->order('published_on_raw ASC');

        $resultSet = $this->tableGateway->selectWith($select);

        return $resultSet;
    }

    /**
     * Returns all the comments pending approval for a thread.
     *
     * @param string $thread
     *
     * @return ResultSet
     */
    public function fetchAllPendingForThread($thread)
    {
        $columns = [
            'id',
            'author',
            'content',
            'contact',
            'published_on_raw' => 'published_on',
            'published_on'     => new Expression("DATE_FORMAT(published_on, '%M %d, %Y %H:%i')"),
        ];

        $select = new Select($this->tableGateway->getTable());
        $select->columns($columns)
               ->where(['thread' => $thread, 'visible' => 0])
               ->order('published_on_raw ASC');

        $resultSet = $this->tableGateway->selectWith($select);

        return $resultSet;
    }

    /**
     * Allow custom comments selection.
     *
     * @param Select $select
     *
     * @return ResultSet
     */
    public function fetchAllUsingSelect(Select $select)
    {
        return $this->tableGateway->selectWith($select);
    }

    /**
     * Returns a comment by id.
     *
     * @param  int $id
     *
     * @return Comment
     */
    public function getComment($id)
    {
        $id     = (int)$id;
        $rowset = $this->tableGateway->select(['id' => $id]);
        $row    = $rowset->current();

        return $row;
    }

    /**
     * Saves a comment into the database.
     *
     * @param  Comment $comment
     *
     * @return int The id of the inserted/updated comment
     */
    public function saveComment(Comment $comment)
    {
        $data = [
            'thread'  => $comment->thread,
            'uri'     => $comment->uri,
            'author'  => $comment->author,
            'contact' => $comment->contact,
            'content' => $comment->content,
            'visible' => $comment->visible,
            'spam'    => $comment->spam,
        ];

        $id = (int)$comment->id;
        if ($id === 0) {
            $this->tableGateway->insert($data);
            $id = $this->tableGateway->lastInsertValue;
        } else {
            if ($this->getComment($id)) {
                $this->tableGateway->update($data, ['id' => $id]);
            }
        }

        return $id;
    }

    /**
     * Removes a comment from the database.
     *
     * @param int $id
     */
    public function deleteComment($id)
    {
        $this->tableGateway->delete(['id' => $id]);
    }


    /**
     * Deletes all comments maked as spam from the database.
     *
     * @return int - number of rows affected.
     */
    public function deleteSpam()
    {
        return $this->tableGateway->delete(['spam' => 1]);
    }
}