App\Modules\Comments\Domain\Logic\PostEventsHandler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	onPostCreated()	0	11	1
A	onPostUpdated()	0	12	1
A	onPostDeleted()	0	8	1
A	onPostBaselined()	0	24	2
A	__construct()	0	7	1

<?php

namespace App\Modules\Comments\Domain\Logic;

use App\Modules\Comments\Api\Event\Inbound\PostBaselinedCommentsIEvent;
use App\Modules\Comments\Api\Event\Inbound\PostCreatedCommentsIEvent;
use App\Modules\Comments\Api\Event\Inbound\PostDeletedCommentsIEvent;
use App\Modules\Comments\Api\Event\Inbound\PostUpdatedCommentsIEvent;
use App\Modules\Comments\Domain\Dto\CreateNewCommentsPostHeaderDto;
use App\Modules\Comments\Domain\Dto\DeleteExistingCommentsPostHeaderDto;
use App\Modules\Comments\Domain\Dto\UpdateExistingCommentsPostHeaderDto;
use App\Modules\Comments\Domain\Repository\CommentsDeletionRepositoryInterface;
use App\Modules\Comments\Domain\Repository\CommentsPostHeadersFindingRepositoryInterface;
use App\Modules\Comments\Domain\Repository\CommentsPostsEventsHandlingRepositoryInterface;
use App\Modules\Comments\Domain\Transactions\CommentsTransactionFactoryInterface;

trait PostEventsHandler
{
    /**
     * @param CommentsTransactionFactoryInterface $transactionFactory
     * @param CommentsPostsEventsHandlingRepositoryInterface $postEventsCommentsRepository
     * @param CommentsDeletionRepositoryInterface $commentsDeletionRepository
     */
    public function __construct(
        private CommentsTransactionFactoryInterface            $transactionFactory,
        private CommentsPostsEventsHandlingRepositoryInterface $postEventsCommentsRepository,
        private CommentsDeletionRepositoryInterface            $commentsDeletionRepository,
        private CommentsPostHeadersFindingRepositoryInterface  $postHeadersFindingRepository
    )
    {
    }

    /**
     * @param PostBaselinedCommentsIEvent $event
     */
    public function onPostBaselined(PostBaselinedCommentsIEvent $event): void
    {
        $this->transactionFactory->createTransaction(function () use ($event) {
            if ($this->postHeadersFindingRepository->postExists($event->getId())) {
                $this->postEventsCommentsRepository->updatePostHeader(
                    new UpdateExistingCommentsPostHeaderDto(
                        $event->getId(),
                        $event->getTitle(),
                        $event->getTags(),
                        $event->getVersion()
                    )
                );
            } else {
                $this->postEventsCommentsRepository->createPostHeader(
                    new CreateNewCommentsPostHeaderDto(
                        $event->getId(),
                        $event->getTitle(),
                        $event->getTags(),
                        $event->getVersion()
                    )
                );
            }

        })->execute();

    }

    /**
     * @param PostCreatedCommentsIEvent $event
     */
    public function onPostCreated(PostCreatedCommentsIEvent $event): void
    {
        $this->transactionFactory->createTransaction(function () use ($event) {
            $this->postEventsCommentsRepository->createPostHeader(
                new CreateNewCommentsPostHeaderDto(
                    $event->getId(),
                    $event->getTitle(),
                    $event->getTags()
                )
            );
        })->execute();

    }

    /**
     * @param PostUpdatedCommentsIEvent $event
     */
    public function onPostUpdated(PostUpdatedCommentsIEvent $event): void
    {
        $this->transactionFactory->createTransaction(function () use ($event) {
            $this->postEventsCommentsRepository->updatePostHeader(
                new UpdateExistingCommentsPostHeaderDto(
                    $event->getId(),
                    $event->getTitle(),
                    $event->getTags(),
                    $event->getLastVersion()
                )
            );
        })->execute();

    }

    /**
     * @param PostDeletedCommentsIEvent $event
     */
    public function onPostDeleted(PostDeletedCommentsIEvent $event): void
    {
        $this->transactionFactory->createTransaction(function () use ($event) {
            $this->commentsDeletionRepository->deleteCommentsForPost($event->getId());
            $this->postEventsCommentsRepository->deletePostHeader(
                new DeleteExistingCommentsPostHeaderDto($event->getId())
            );
        })->execute();

    }
}