OCA\Analytics\Flow\Operation

Complexity

Total Complexity

14

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

<?php
class Operation implements IOperation
{

    /** @var IL10N */
    private $l;
    /** @var IURLGenerator */
    private $urlGenerator;
    private $logger;
    private $DataloadController;
    private $eventDispatcher;

    public function __construct(
        IL10N $l,
        IURLGenerator $urlGenerator,
        ILogger $logger,
        DataloadController $DataloadController
        IEventDispatcher $eventDispatcher;

A parse error occurred: Syntax error, unexpected T_STRING, expecting ')' on line 46 at column 8

    )
    {
        $this->l = $l;
        $this->urlGenerator = $urlGenerator;
        $this->logger = $logger;
        $this->DataloadController = $DataloadController;
        $this->eventDispatcher;
    }

    public function register(): void
    {
        if (interface_exists(IRuleMatcher::class)) {
            $this->eventDispatcher->addListener(IManager::EVENT_NAME_REG_OPERATION, function (GenericEvent $event) {
                $operation = \OC::$server->query(Operation::class);
                $event->getSubject()->registerOperation($operation);
                Util::addScript('analytics', 'flow');
            });
        }
    }

    public function getDisplayName(): string
    {
        return $this->l->t('Analytics');
    }

    public function getDescription(): string
    {
        return $this->l->t('Read file and add its data to an existing report');
    }

    public function getIcon(): string
    {
        return $this->urlGenerator->imagePath('analytics', 'app.svg');
    }

    public function isAvailableForScope(int $scope): bool
    {
        return $scope === IManager::SCOPE_USER;
    }

    /**
     * @param $name
     * @param array $checks
     * @param $operation
     * @since 9.1
     */
    public function validateOperation($name, array $checks, $operation): void
    {
    }

    public function onEvent(string $eventName, Event $event, IRuleMatcher $ruleMatcher): void
    {
        $flow = $ruleMatcher->getFlows(true);
        $datasetId = (int)$flow['operation'];

        if ($eventName === '\OCP\Files::postRename') {
            /** @var Node $oldNode */
            list(, $node) = $event->getSubject();
        } else {
            $node = $event->getSubject();
        }

        list(, , $folder, $file) = explode('/', $node->getPath(), 4);
        if ($folder !== 'files' || $node instanceof Folder) {
            return;
        }
        $file = '/' . $file;

        $this->logger->debug("Analytics Flow Operation 115: storing file '" . $file . "' in report " . $datasetId);
        try {
            $this->DataloadController->importFile($datasetId, $file);
        } catch (NotFoundException $e) {
            return;