<?php

namespace FootyRoom\Repositories;

use FootyRoom\Support\AutoMapper;
use FootyRoom\Core\Comment\Author;
use FootyRoom\Core\Comment\Comment;
use Illuminate\Database\Connection;
use FootyRoom\Core\Comment\Revision;
use FootyRoom\Core\Comment\CommentChange;

class CommentRepository
{
    /**
     * @var \Illuminate\Database\Connection
     */
    protected $mysql;

    /**
     * Constructor.
     *
     * @param \Illuminate\Database\Connection $mysql
     */
    public function __construct(Connection $mysql)
    {
        $this->mysql = $mysql;
    }

    /**
     * Finds comment by id.
     *
     * @param int $id
     *
     * @return \FootyRoom\Core\Comment\Comment|null
     */
    public function findById($id)
    {
        $commentDto = $this->mysql

        ->table('comments as c')
        ->select([
            'c.id as id',
            'c.discussion_id as discussionId',
            'c.user_id as userId',
            'c.author as name',
            'c.content',
            'c.html',
            'c.parent as parentId',
            'c.datetime as date',
            'c.status',
            'cm_guest_id.meta_value as guestId',
            'cx_teamname.teamname as teamName',
        ])
        ->leftJoin('wp_commentmeta as cm_guest_id', function ($join) {
            $join->on('cm_guest_id.comment_id', '=', 'c.id')
                 ->where('meta_key', '=', 'guest_id');
        })
        ->leftJoin('wp_comments_extra as cx_teamname', function ($join) {
            $join->on('cx_teamname.comment_id', '=', 'c.id');
        })
        ->where('c.id', '=', $id)
        ->first();

        if (!$commentDto){
            return null;
        }

        $comment = AutoMapper::map($commentDto, Comment::class);

        AutoMapper::setValue($comment, 'isApproved', (bool) $commentDto->status);
        AutoMapper::setValue($comment, 'author', AutoMapper::map($commentDto, Author::class));

        return $comment;
    }

    /**
     * Saves new comment.
     *
     * @param \FootyRoom\Core\Comment\Comment $comment
     *
     * @return int Id of new comment.
     */
    public function create(Comment $comment)
    {
        $commentId = $this->mysql

        ->table('comments')
        ->insertGetId([
            'discussion_id' => $comment->getDiscussionId(),
            'user_id'       => $comment->getAuthor()->getUserId(),
            'author'        => $comment->getAuthor()->getName() ?: '',
            'content'       => $comment->getContent(),
            'html'          => $comment->getHtml(),
            'parent'        => $comment->getParentId(),
            'datetime'      => $comment->getDate()->format('c'),
            'status'        => $comment->isApproved() ? '1' : '0',
        ]);

        AutoMapper::setValue($comment, 'id', $commentId);

        return $commentId;
    }

    /*
     * Updates content of a specified comment.
     *
     * @param int $commentId
     * @param string $content
     * @param string $html
     */
    public function updateContent($commentId, $content, $html)
    {
        $this->mysql

        ->table('comments')
        ->where('id', '=', $commentId)
        ->update([
            'content' => $content,
            'html' => $html,
        ]);
    }

    /*
     * Updates approval comment.
     *
     * @param int $commentId
     * @param string $content
     */
    public function updateApproval($commentId, $approved)
    {
        $this->mysql

        ->table('comments')
        ->where('id', '=', $commentId)
        ->update([
            'status' => $approved,
        ]);
    }

    /**
     * Saves comment revision.
     *
     * @param \FootyRoom\Core\Comment\Revision $revision
     */
    public function createRevision(Revision $revision)
    {
        $json = json_encode([
            'date' => $revision->getDate()->format('c'),
            'content' => $revision->getContent(),
        ]);

        $this->createMeta($revision->getCommentId(), 'revision', $json);
    }

    /**
     * Creates comment change.
     *
     * @param \FootyRoom\Core\Comment\CommentChange $change
     */
    public function createChange(CommentChange $change)
    {
        $this->mysql

        ->table('wp_commentmeta')
        ->insert([
            'comment_id' => $change->getCommentId(),
            'meta_key' => 'edited',
            'meta_value' => json_encode([
                'user_id' => $change->getUserId(),
                'username' => $change->getUsername(),
                'action' => $change->getAction(),
                'reason' => $change->getReason(),
                'created_at' => $change->getDate()->format('c'),
            ]),
        ]);
    }

    /**
     * Create meta for specified comment.
     *
     * @param int $commentId
     * @param string $key
     * @param string $value
     */
    protected function createMeta($commentId, $key, $value)
    {
        $this->mysql

        ->table('wp_commentmeta')
        ->insert([
            'comment_id' => $commentId,
            'meta_key' => $key,
            'meta_value' => $value,
        ]);
    }

    /**
     * Increments comment karma.
     *
     * @param int $commentId
     */
    public function incrementKarma($commentId)
    {
        $this->mysql->update(
            'UPDATE comments SET karma = karma + 1 WHERE id = ?',
            [$commentId]
        );
    }

    /**
     * Decrements comment karma.
     *
     * @param int $commentId
     */
    public function decrementKarma($commentId)
    {
        $this->mysql->update(
            'UPDATE comments SET karma = karma - 1 WHERE id = ?',
            [$commentId]
        );
    }
}