<?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:----WttrPj2Ur4FhbRbXmHsaCFMBu1t7CeX2rqK9fYe2qehQfg6gjdvEK/X8jCb3FrJACEFXtyLoFKjjHbo7FG1zkCCzP5eCTCunNLXREc1VUtY0cSegplaOhUF0KvqiqvtELOh//z4OXtE5H04pf2DVo/HDNI1GPtopiN/hxWW7aQRiRTEQNVnpplm1j7p+mtAI62SpBAkcICKALgA3L73tmgV4mAwzDqIwEvWG+iXAq3mLEugO80TJjrTN2K6TRMV9CEjL1kCmKYgWkWJXtOW7oJqgdaGnKTX763X7sgY4zDMxWB4xnRwWu6QWkYcD990PXt+CRO/4mjTZ/ssHzLqLYcIk+QkVTCKdo44xBQ94uSvQXCO8/DbsTKL9xN58CN2hoG4MxO8ockDc/mjfezYCuu96WcE8TWr1gEn3JlZWsI2XE0FPIvwO7hJ/avm1e7DuL1cGH59VQZrK54hHpFu6hjONglGnX90uX+Uzq71Odvkx9ql/Yijnl6BQ0yt+wYdDKGDufm5GJcyZ43TuCfrtdkQCMmtWniNvw0Rar6jIPjLYwXmttcSLHpebqAr+hnQWn9KDwT1GANGT/Dfaw/QFtBEOe08s4cz5H/GJ2yMOQbWihlSK44hEM1qppv1aBYSIsPwo6SB3Vx6Na76bHsAnf/qy/+Nv1HsRVQrL7UnniFo=----ATTACHMENT:----NjYzMzUxNTgwODE0NzQ2MSA2NzQyMzgyMTkyODEzNzkyIDI0MTI5ODAyNDQ0NTU0NzU=