Balloon\App\Elasticsearch\Hook

Complexity

Total Complexity

15

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	postCreateCollection()	0	7	1
A	postCreateFile()	0	7	1
A	postDeleteCollection()	0	11	2
A	postDeleteFile()	0	12	2
C	postSaveNodeAttributes()	0	23	8

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2018 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\App\Elasticsearch;

use Balloon\Filesystem\Node\Collection;
use Balloon\Filesystem\Node\File;
use Balloon\Filesystem\Node\NodeInterface;
use Balloon\Hook\AbstractHook;
use TaskScheduler\Async;

class Hook extends AbstractHook
{
    /**
     * Async.
     *
     * @var Async
     */
    protected $async;

    /**
     * Constructor.
     *
     * @param Async $async
     */
    public function __construct(Async $async)
    {
        $this->async = $async;
    }

    /**
     * {@inheritdoc}
     */
    public function postCreateCollection(Collection $parent, Collection $node, bool $clone): void
    {
        $this->async->addJob(Job::class, [
            'id' => $node->getId(),
            'action' => Job::ACTION_CREATE,
        ]);
    }

    /**
     * {@inheritdoc}
     */
    public function postCreateFile(Collection $parent, File $node, bool $clone): void
    {
        $this->async->addJob(Job::class, [
            'id' => $node->getId(),
            'action' => Job::ACTION_CREATE,
        ]);
    }

    /**
     * {@inheritdoc}
     */
    public function postDeleteCollection(Collection $node, bool $force, ?string $recursion, bool $recursion_first): void
    {
        if (false === $force) {
            return;
        }

        $this->async->addJob(Job::class, [
            'id' => $node->getId(),
            'action' => Job::ACTION_DELETE_COLLECTION,
        ]);
    }

    /**
     * {@inheritdoc}
     */
    public function postDeleteFile(File $node, bool $force, ?string $recursion, bool $recursion_first): void
    {
        if (false === $force) {
            return;
        }

        $this->async->addJob(Job::class, [
            'id' => $node->getId(),
            'action' => Job::ACTION_DELETE_FILE,
            'hash' => $node->getHash(),
        ]);
    }

    /**
     * {@inheritdoc}
     */
    public function postSaveNodeAttributes(NodeInterface $node, array $attributes, array $remove, ?string $recursion, bool $recursion_first): void
    {
        if ($node instanceof Collection) {
            $raw = $node->getRawAttributes();
            if ($node->isShared() && !isset($raw['acl'])) {
                $this->async->addJob(Job::class, [
                    'id' => $node->getId(),
                    'action' => Job::ACTION_ADD_SHARE,
                ]);
            } elseif (!$node->isShared() && isset($raw['acl']) && $raw['acl'] !== []) {
                $this->async->addJob(Job::class, [
                    'id' => $node->getId(),
                    'action' => Job::ACTION_DELETE_SHARE,
                ]);
            }
        }

        $this->async->addJob(Job::class, [
            'id' => $node->getId(),
            'action' => Job::ACTION_UPDATE,
            'hash' => ($node instanceof File) ? $node->getRawAttributes()['hash'] : null,
        ]);
    }
}