<?php

namespace Nette\Caching\Storages;

use Nette;
use Nette\Caching\Cache;

/**
 * SQLite storage.
 */
class SQLiteStorage implements Nette\Caching\Storage, Nette\Caching\BulkReader
{
    use Nette\SmartObject;

    private \PDO $pdo;

    public function __construct(string $path)
    {
        if ($path !== ':memory:' && !is_file($path)) {
            touch($path); // ensures ordinary file permissions
        }

        $this->pdo = new \PDO('sqlite:' . $path);
        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
        $this->pdo->exec("\n\t\t\tPRAGMA foreign_keys = ON;\n\t\t\tCREATE TABLE IF NOT EXISTS cache (\n\t\t\t\tkey BLOB NOT NULL PRIMARY KEY,\n\t\t\t\tdata BLOB NOT NULL,\n\t\t\t\texpire INTEGER,\n\t\t\t\tslide INTEGER\n\t\t\t);\n\t\t\tCREATE TABLE IF NOT EXISTS tags (\n\t\t\t\tkey BLOB NOT NULL REFERENCES cache ON DELETE CASCADE,\n\t\t\t\ttag BLOB NOT NULL\n\t\t\t);\n\t\t\tCREATE INDEX IF NOT EXISTS cache_expire ON cache(expire);\n\t\t\tCREATE INDEX IF NOT EXISTS tags_key ON tags(key);\n\t\t\tCREATE INDEX IF NOT EXISTS tags_tag ON tags(tag);\n\t\t\tPRAGMA synchronous = OFF;\n\t\t");
    }

    public function read(string $key): mixed
    {
        $stmt = $this->pdo->prepare('SELECT data, slide FROM cache WHERE key=? AND (expire IS NULL OR expire >= ?)');
        $stmt->execute([$key, time()]);
        if (!$row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
            return null;
        }

        if ($row['slide'] !== null) {
            $this->pdo->prepare('UPDATE cache SET expire = ? + slide WHERE key=?')->execute([time(), $key]);
        }

        return unserialize($row['data']);
    }

    public function bulkRead(array $keys): array
    {
        $stmt = $this->pdo->prepare('SELECT key, data, slide FROM cache WHERE key IN (?' . str_repeat(',?', count($keys) - 1) . ') AND (expire IS NULL OR expire >= ?)');
        $stmt->execute(array_merge($keys, [time()]));
        $result = [];
        $updateSlide = [];
        foreach ($stmt->fetchAll(\PDO::FETCH_ASSOC) as $row) {
            if ($row['slide'] !== null) {
                $updateSlide[] = $row['key'];
            }

            $result[$row['key']] = unserialize($row['data']);
        }

        if (!empty($updateSlide)) {
            $stmt = $this->pdo->prepare('UPDATE cache SET expire = ? + slide WHERE key IN(?' . str_repeat(',?', count($updateSlide) - 1) . ')');
            $stmt->execute(array_merge([time()], $updateSlide));
        }

        return $result;
    }

    public function lock(string $key): void
    {
    }

    public function write(string $key, $data, array $dependencies): void
    {
        $expire = isset($dependencies[Cache::Expire])
            ? $dependencies[Cache::Expire] + time()
            : null;
        $slide = isset($dependencies[Cache::Sliding])
            ? $dependencies[Cache::Expire]
            : null;

        $this->pdo->exec('BEGIN TRANSACTION');
        $this->pdo->prepare('REPLACE INTO cache (key, data, expire, slide) VALUES (?, ?, ?, ?)')
            ->execute([$key, serialize($data), $expire, $slide]);

        if (!empty($dependencies[Cache::Tags])) {
            foreach ($dependencies[Cache::Tags] as $tag) {
                $arr[] = $key;
                $arr[] = $tag;
            }

            $this->pdo->prepare('INSERT INTO tags (key, tag) SELECT ?, ?' . str_repeat('UNION SELECT ?, ?', count($arr) / 2 - 1))
                ->execute($arr);
        }

        $this->pdo->exec('COMMIT');
    }

    public function remove(string $key): void
    {
        $this->pdo->prepare('DELETE FROM cache WHERE key=?')
            ->execute([$key]);
    }

    public function clean(array $conditions): void
    {
        if (!empty($conditions[Cache::All])) {
            $this->pdo->prepare('DELETE FROM cache')->execute();

        } else {
            $sql = 'DELETE FROM cache WHERE expire < ?';
            $args = [time()];

            if (!empty($conditions[Cache::Tags])) {
                $tags = $conditions[Cache::Tags];
                $sql .= ' OR key IN (SELECT key FROM tags WHERE tag IN (?' . str_repeat(',?', count($tags) - 1) . '))';
                $args = array_merge($args, $tags);
            }

            $this->pdo->prepare($sql)->execute($args);
        }
    }
}
__halt_compiler();----SIGNATURE:----BQAXU67ZQNku1vioQEhhtXat97V5kvztpsdjjxpaK90Di+UT2QgjP2nAq4100KviX74kmq7ttgQEffT3z1H3zi7rYTvRBEBEsyqSJ7oIfDrsiPpqR96iHHidEmhPPjgFmljBhyHIx2oqgNaEGi8cJNgBMehXGhApOzcvlupi0CpO+joFHWVshvsZcuxfkLwPS9nlFCO3GlZxsRvHQAuEoUY4wLl+osbJYRqVhrAFkx4zvcmAZeO8qfaIAyNSEGS+6mw1+LCziwiuQIu1XNPM2loDHtEgMX2OCEgTrGXmRHv0PYjmFXzNl9v1bGseXICZwHTAhtBaylV8Hh1dmD8Np4kofzkP+Fvkj3Rkv1smZU8TDFEygqpcMGgN32qBdZl9bJ65l4EjB+YDrwKlUtompoG5Ld6ObMZB5AhewZ6HiGXoICZumDQ5spW2XeA/q21pezWHCZPusJ8yYaDCtmdZRMAXiK4nCku0XyYwdFKoTcV8P6DxndYguY1PL4iZqOZCQBA0Vdf0jTDjDNTlZu07umsnayRz3bBIDm/AXDlLUL+w/qzOV0AXzNKIj7JuHA5Z2JQhfx239akSJXvT8TSDkZWuuJ528g/qc87kgrzfmIK9KJ97RmGrSV0hItqQeSWKWY5zvHlxbl4n9Ub1B0RRonkzZSsCVlERZx2TrslP2Gk=----ATTACHMENT:----NDY2MDA1MDI5MDgwMTgzMiA2MTg3ODgwMTgyOTA3NTk5IDYzNjIzODU5MzI4NTI2Mjc=