class.ilGlobalCacheSetupAgent.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

use ILIAS\Setup\Agent;
use ILIAS\Refinery\Factory;
use ILIAS\Refinery\Transformation;
use ILIAS\Setup\Objective;
use ILIAS\Setup\UnachievableException;
use ILIAS\Setup\Objective\NullObjective;
use ILIAS\Setup\Metrics\Storage;
use ILIAS\Setup\Config;
use ILIAS\Setup\ObjectiveConstructor;
use ILIAS\Cache\Nodes\Node;

class ilGlobalCacheSetupAgent implements Agent
{
    public function __construct(protected Factory $refinery)
    {
    }

    public function hasConfig(): bool
    {
        return true;
    }

    public function getArrayToConfigTransformation(): Transformation
    {
        return $this->refinery->custom()->transformation(function ($data): \ilGlobalCacheSettingsAdapter {
            $settings = new \ilGlobalCacheSettingsAdapter();
            if (
                $data === null ||
                !isset($data["components"]) ||
                !$data["components"] ||
                !isset($data["service"]) ||
                $data["service"] === "none" ||
                (
                    $data["service"] === "memcached" &&
                    (!isset($data["memcached_nodes"]) || count($data["memcached_nodes"]) === 0)
                )
            ) {
                $settings->setActive(false);
            } else {
                $settings->setActive(true);
                switch ($data["service"]) {
                    case "xcache": // xcache has been removed in ILIAS 8, we switch to static cache then
                    case "static":
                        $settings->setService(\ILIAS\Cache\Config::PHPSTATIC);
                        break;
                    case "memcached":
                        array_walk($data["memcached_nodes"], function (array $node) use ($settings): void {
                            $settings->addMemcachedNode($this->convertNode($node));
                        });
                        $settings->setService(\ILIAS\Cache\Config::MEMCACHED);
                        break;
                    case "apc":
                        $settings->setService(\ILIAS\Cache\Config::APCU);
                        break;
                    default:
                        throw new \InvalidArgumentException(
                            sprintf("Unknown caching service: '%s'", $data["service"])
                        );
                }
                $settings->resetActivatedComponents();
                if ($data["components"] === "all") {
                    $settings->activateAll();
                } else {
                    foreach ($data["components"] as $cmp => $active) {
                        if ($active) {
                            $settings->addActivatedComponent($cmp);
                        }
                    }
                }
            }

            return $settings;
        });
    }

    protected function convertNode(array $node): Node
    {
        return new Node(
            (string) $node["host"],
            (int) $node["port"],
            (int) $node["weight"]
        );
    }

    public function getInstallObjective(?Config $config = null): Objective
    {
        if (!$config instanceof ilGlobalCacheSettingsAdapter) {
            throw new UnachievableException('wrong config type, expected ilGlobalCacheSettings');
        }
        return new ilGlobalCacheConfigStoredObjective($config);
    }

    public function getUpdateObjective(?Config $config = null): Objective
    {
        if ($config instanceof ilGlobalCacheSettingsAdapter) {
            return new ilGlobalCacheConfigStoredObjective($config);
        }
        return new NullObjective();
    }

    public function getBuildObjective(): Objective
    {
        return new NullObjective();
    }

    public function getStatusObjective(Storage $storage): Objective
    {
        return new ilGlobalCacheMetricsCollectedObjective($storage);
    }

    public function getMigrations(): array
    {
        return [];
    }

    public function getNamedObjectives(?Config $config = null): array
    {
        $config ??= new ilGlobalCacheSettingsAdapter();
        return [
            'flushAll' => new ObjectiveConstructor(
                'flushes all GlobalCaches.',
                fn(): \ilGlobalCacheAllFlushedObjective => new ilGlobalCacheAllFlushedObjective($config)
            )
        ];
    }
}