Rello / analytics

lib/Flow/FlowOperation.php

<?php
declare(strict_types=1);
/**
 * Analytics
 *
 * SPDX-FileCopyrightText: 2019-2022 Marcel Scherello
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

namespace OCA\Analytics\Flow;

use OCA\Analytics\Controller\DataloadController;
use OCP\EventDispatcher\Event;

The type OCP\EventDispatcher\Event was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\EventDispatcher\IEventDispatcher;

The type OCP\EventDispatcher\IEventDispatcher was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\Files\Folder;

The type OCP\Files\Folder was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\Files\Node;

The type OCP\Files\Node was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\Files\NotFoundException;

The type OCP\Files\NotFoundException was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\IL10N;

The type OCP\IL10N was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\IURLGenerator;

The type OCP\IURLGenerator was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\Util;

The type OCP\Util was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\WorkflowEngine\IManager;

The type OCP\WorkflowEngine\IManager was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\WorkflowEngine\IOperation;

The type OCP\WorkflowEngine\IOperation was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\WorkflowEngine\IRuleMatcher;

The type OCP\WorkflowEngine\IRuleMatcher was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Log\LoggerInterface;

The type Psr\Log\LoggerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\WorkflowEngine\Events\RegisterOperationsEvent;

The type OCP\WorkflowEngine\Events\RegisterOperationsEvent was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Container\ContainerInterface;

The type Psr\Container\ContainerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

class FlowOperation implements IOperation
{

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

    public function __construct(
        IL10N $l,
        IURLGenerator $urlGenerator,
        LoggerInterface $logger,
        DataloadController $DataloadController,
        IEventDispatcher $eventDispatcher,
        ContainerInterface $container
    )
    {
        $this->l = $l;
        $this->urlGenerator = $urlGenerator;
        $this->logger = $logger;
        $this->DataloadController = $DataloadController;
        $this->eventDispatcher = $eventDispatcher;
        $this->container = $container;
    }

    public function handle(Event $event): void {
        if (!$event instanceof RegisterOperationsEvent) {
            return;
        }
        $event->registerOperation($this->container->get(FlowOperation::class));
        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 dataset');
    }

    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;

        try {
            $this->DataloadController->importFile($datasetId, $file, true);
        } catch (NotFoundException $e) {
            return;
        } catch (\Exception $e) {
            return;
        }
    }
}