App\Modules\Posts\Domain\Logic\PostsRemover

Complexity

Total Complexity

3

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	fromDeleteCommand()	0	3	1
A	deletePost()	0	12	1

<?php

namespace App\Modules\Posts\Domain\Logic;

use App\Infrastructure\Events\Api\ApplicationEventPublisherInterface;
use App\Modules\Posts\Api\Command\DeletePostCommand;
use App\Modules\Posts\Domain\Dto\DeleteExistingPostDto;
use App\Modules\Posts\Domain\Event\Outbound\PostDeletedOEvent;
use App\Modules\Posts\Domain\Repository\PostsDeletionRepositoryInterface;
use App\Modules\Posts\Domain\Transactions\PostTransactionFactoryInterface;

trait PostsRemover
{
    /**
     * @param ApplicationEventPublisherInterface $eventPublisher
     * @param PostsDeletionRepositoryInterface $deletionRepository
     * @param PostTransactionFactoryInterface $transactionFactory
     * @param PostsValidator $validator
     */
    public function __construct(
        private ApplicationEventPublisherInterface $eventPublisher,
        private PostsDeletionRepositoryInterface   $deletionRepository,
        private PostTransactionFactoryInterface    $transactionFactory,
        private PostsValidator                     $validator
    )
    {
    }

    /**
     * @param DeletePostCommand $command
     */
   public function deletePost(DeletePostCommand $command): void
    {
        $this->validator->preDelete($command);
        $deletedPost = $this->fromDeleteCommand($command);
        $this->transactionFactory
            ->createTransaction(function () use ($deletedPost) {
                $this->deletionRepository->deletePost($deletedPost);
            })
            ->afterCommit(function () use ($deletedPost) {
                $this->publisher->publish(new PostDeletedOEvent($deletedPost));
            })
            ->execute();
    }

    /**
     * @param DeletePostCommand $command
     * @return DeleteExistingPostDto
     */
    private function fromDeleteCommand(DeletePostCommand $command): DeleteExistingPostDto
    {
        return new DeleteExistingPostDto($command->getId());
    }
}