Zemit\Modules\Cli\Tasks\DataLifeCycleTask

Complexity

Total Complexity

12

Size/Duplication

Total Lines	110
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	mainAction()	0	8	1
A	initialize()	0	9	1
A	addModelsPermissions()	0	14	3
B	modelsAction()	0	53	7

<?php

/**
 * This file is part of the Zemit Framework.
 *
 * (c) Zemit Team <contact@zemit.com>
 *
 * For the full copyright and license information, please view the LICENSE.txt
 * file that was distributed with this source code.
 */

namespace Zemit\Modules\Cli\Tasks;

use Phalcon\Mvc\Model\ResultsetInterface;
use Phalcon\Mvc\ModelInterface;
use Zemit\Exception\CliException;
use Zemit\Models\Lang;
use Zemit\Models\Site;
use Zemit\Modules\Cli\Task;
use Zemit\Models\Role;
use Zemit\Models\Setting;
use Zemit\Models\Template;
use Zemit\Mvc\Model;
use Zemit\Utils;

class DataLifeCycleTask extends Task
{
    public string $cliDoc = <<<DOC
Usage:
  php zemit cli data-life-cycle <action> [<params> ...]

Options:
  task: cache
  action: clear


DOC;
    
    public ?array $models = null;
    
    public ?array $policies = null;
    
    public function initialize(): void
    {
        Utils::setUnlimitedRuntime();
        
        $dataLifeCycleConfig = $this->config->pathToArray('dataLifeCycle');
        $this->models ??= $dataLifeCycleConfig['models'] ?? [];
        $this->policies ??= $dataLifeCycleConfig['policies'] ?? [];
        
        $this->addModelsPermissions();
    }
    
    /**
     * Default action
     */
    public function mainAction(string ...$tables): ?array
    {
        $response = [];

//        $response ['backup'] = $this->backupAction();
        $response ['models'] = $this->modelsAction(...$tables);
        
        return $response;
    }
    
    public function modelsAction(string ...$tables): array
    {
        $response = [];
        
        foreach ($tables as &$table) {
            $table = array_map('trim', explode(',', $table));
        }
        $tables = array_flip(array_merge_recursive(...$tables));

$tables of type string is incompatible with the type array expected by parameter $arrays of array_merge_recursive().

        
        foreach ($this->models as $modelClass => $policyName) {
            
            // retrieve configured model the policy
            $policy = $this->policies[$policyName] ?? null;
            
            // load an instance of the model class
            $model = $this->modelsManager->load($modelClass);
            assert($model instanceof Model);
            $source = $model->getSource();
            
            // whitelisted tables
            if (!empty($tables) && !isset($tables[$source])) {
                continue;
            }
            
            if (!isset($response[$source])) {
                $response[$source] = [];
            }
            
            // find all record matching the defined retention policy
            $records = $model::findLifeCycle($policy['query'] ?? null);
            assert($records instanceof ResultsetInterface);
            
            // temporarily disable soft-delete
            $model->disableSoftDelete();
            
            foreach ($records as $record) {
                assert($record instanceof Model);
                
                // disable soft delete
                $record->disableSoftDelete();
                
                // delete record
                $response[$source] []= [
                    'primaryKeys' => $record->getPrimaryKeysValues(),
                    'deleted' => $record->delete(),
                ];
            }
            
            // re-enable soft-delete
            $model->enableSoftDelete();
        }
        
        return $response;
    }
    
    public function addModelsPermissions(?array $models = null): void
    {
        $permissions = [];
        $models ??= $this->models;
        if ($models) {
            foreach ($models as $model => $entity) {
                $permissions[$model] = ['*'];
            }
        }
        $this->config->merge([
            'permissions' => [
                'roles' => [
                    'cli' => [
                        'models' => $permissions,
                    ],
                ],
            ],
        ]);
    }
}