class.ilMemcacheNodesRepository.php

Go to the documentation of this file.

<?php

use ILIAS\Cache\Nodes\NodeRepository;
use ILIAS\Cache\Nodes\Node;

class ilMemcacheNodesRepository implements NodeRepository
{
    public const TABLE_NAME = "il_gc_memcache_server";

    public function __construct(private ?ilDBInterface $db = null)
    {
    }

    public function deleteAll(): void
    {
        if ($this->db === null) {
            return;
        }
        $this->db->manipulate("TRUNCATE TABLE " . self::TABLE_NAME);
    }

    public function store(Node $node): Node
    {
        if ($this->db === null) {
            return $node;
        }
        $this->create(
            $node->getHost(),
            $node->getPort(),
            $node->getWeight()
        );
        return $node;
    }

    public function create(
        string $host,
        int $port,
        int $weight
    ): Node {
        $node = new Node($host, $port, $weight);
        if ($this->db != null) {
            $next_id = $this->db->nextId(self::TABLE_NAME);
            $this->db->insert(self::TABLE_NAME, [
                "id" => ["integer", $next_id],
                "status" => ["integer", true],
                "host" => ["text", $node->getHost()],
                "port" => ["integer", $node->getPort()],
                "weight" => ["integer", $node->getWeight()],
                "flush_needed" => ["integer", false]
            ]);
        }
        return $node;
    }

    public function getNodes(): array
    {
        if ($this->db === null) {
            return [];
        }
        $set = $this->db->query("SELECT * FROM " . self::TABLE_NAME);
        $nodes = [];
        while ($rec = $this->db->fetchAssoc($set)) {
            $nodes[] = new Node(
                $rec["host"],
                (int) $rec["port"],
                (int) $rec["weight"]
            );
        }
        return $nodes;
    }
}