xref: /plugin/bez/mdl/Thread_commentFactory.php (revision e8827d732aaeeee6f7b703c5654f86ca97056383)

<?php

namespace dokuwiki\plugin\bez\mdl;

class Thread_commentFactory extends Factory {

    protected function select_query() {
        return "SELECT thread_comment.*, thread.coordinator
                FROM thread_comment JOIN thread ON thread_comment.thread_id=thread.id";
    }

    public function get_from_thread(Thread $thread, $filters=array(), $orderby='', $desc=true, $limit=false) {
        $filters['thread_id'] = $thread->id;
        return $this->get_all($filters, $orderby, $desc, array('thread' => $thread), $limit);
    }

    /**
     * @param Thread_comment $thread_comment
     * @param                $data
     * @throws \Exception
     */
    public function initial_save(Entity $thread_comment, $data) {
        parent::initial_save($thread_comment, $data);

        try {
            $this->beginTransaction();

            if ($data['fn'] == 'comment_add' ||
                $data['content'] != '') {
                $thread_comment->set_data($data);
                $this->save($thread_comment);
                $thread_comment->thread->set_participant_flags($thread_comment->author, array('subscribent', 'commentator'));
            }

            if ($data['fn'] == 'thread_close') {
                $thread_comment->thread->set_state('closed');
            } elseif ($data['fn'] == 'thread_reject') {
                $thread_comment->thread->set_state('rejected');
            } elseif ($data['fn'] == 'thread_reopen') {
                $thread_comment->thread->set_state('opened');
            }

            $thread_comment->thread->update_last_activity();

            $this->commitTransaction();
        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }

        $thread_comment->mail_notify_add();
    }

    public function update_save(Entity $thread_comment, $data) {
        parent::update_save($thread_comment, $data);

        $thread_comment->set_data($data);
        try {
            $this->beginTransaction();
            $this->save($thread_comment);

            $thread_comment->thread->update_last_activity();

            $this->commitTransaction();
        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }
    }

    public function delete(Entity $obj) {
        try {
            $this->beginTransaction();

            parent::delete($obj);
            $obj->thread->update_last_activity();

            $this->commitTransaction();
        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }
    }
}