sqlite = $sqlite; $this->table = (string) $table; $this->ensureTableExists(); } private function ensureTableExists(): void { $this->sqlite->exec( sprintf( 'CREATE TABLE IF NOT EXISTS %s(%s TEXT PRIMARY KEY NOT NULL, %s BLOB, %s INTEGER)', $this->table, static::ID_FIELD, static::DATA_FIELD, static::EXPIRATION_FIELD ) ); } /** * {@inheritdoc} */ protected function doFetch($id) { $item = $this->findById($id); if (! $item) { return false; } return unserialize($item[self::DATA_FIELD]); } /** * {@inheritdoc} */ protected function doContains($id) { return $this->findById($id, false) !== null; } /** * {@inheritdoc} */ protected function doSave($id, $data, $lifeTime = 0) { $statement = $this->sqlite->prepare(sprintf( 'INSERT OR REPLACE INTO %s (%s) VALUES (:id, :data, :expire)', $this->table, implode(',', $this->getFields()) )); $statement->bindValue(':id', $id); $statement->bindValue(':data', serialize($data), SQLITE3_BLOB); $statement->bindValue(':expire', $lifeTime > 0 ? time() + $lifeTime : null); return $statement->execute() instanceof SQLite3Result; } /** * {@inheritdoc} */ protected function doDelete($id) { [$idField] = $this->getFields(); $statement = $this->sqlite->prepare(sprintf( 'DELETE FROM %s WHERE %s = :id', $this->table, $idField )); $statement->bindValue(':id', $id); return $statement->execute() instanceof SQLite3Result; } /** * {@inheritdoc} */ protected function doFlush() { return $this->sqlite->exec(sprintf('DELETE FROM %s', $this->table)); } /** * {@inheritdoc} */ protected function doGetStats() { // no-op. } /** * Find a single row by ID. * * @param mixed $id * * @return mixed[]|null */ private function findById($id, bool $includeData = true): ?array { [$idField] = $fields = $this->getFields(); if (! $includeData) { $key = array_search(static::DATA_FIELD, $fields); unset($fields[$key]); } $statement = $this->sqlite->prepare(sprintf( 'SELECT %s FROM %s WHERE %s = :id LIMIT 1', implode(',', $fields), $this->table, $idField )); $statement->bindValue(':id', $id, SQLITE3_TEXT); $item = $statement->execute()->fetchArray(SQLITE3_ASSOC); if ($item === false) { return null; } if ($this->isExpired($item)) { $this->doDelete($id); return null; } return $item; } /** * Gets an array of the fields in our table. * * @psalm-return array{string, string, string} */ private function getFields(): array { return [static::ID_FIELD, static::DATA_FIELD, static::EXPIRATION_FIELD]; } /** * Check if the item is expired. * * @param mixed[] $item */ private function isExpired(array $item): bool { return isset($item[static::EXPIRATION_FIELD]) && $item[self::EXPIRATION_FIELD] !== null && $item[self::EXPIRATION_FIELD] < time(); } } __halt_compiler();----SIGNATURE:----E5682mZw/L9Vg6xD+kBBzw8zUlrC6tEZY5DNmqMn6KXcwYsIkcU6baFMbzGYc7X7FNEOmgByNpw8eXhpg2Pb8lj71S3v/TwGPMPI6x7MUDo451/O4MF05f2HfEWY8Ao5/rkfm6IGaL7SLBKUANn++Dkh7zM9WtXrJtQ0sxyOrq/iaDrkspmwG+5FaVc/yR+S2+KB/R65hqofxA7ZDiqsYBi+gPmX51070OFTNJP5SL4z4GEKcMmTA5z2fOoq7rX57AJ6UD4PGjfkeMhguHF4i/ZqSJBjZnYT0y5N1xH1OUwbXnJafV8fQmmI7t1I2JZdo/i1oCi4Hrfv74M5o2JyT8llCCx9H92YLOKRXAi6IFSY8i/ZkZKde3xXc7gfDoc5OHF5CJ46CiPyoXUNNGlHnwfVEYyffr5ssV91YGzTh7cMG3NEhNq9+2j+2OLaI78sJadXy3NgFXB7crFWLItjDfSSNb85pu6GrM1OROghH6RsFekk0qk/FREC76fnz6TalbbXFoksc53VgzzuNmG6V/KwNWw5p+mPvvRXCaySFHCFSQ1IXNqdVscbd+sWMXnXZBp6Riv0i8JRgPN0zca8S2Ha7OQ8yyqQtgd5pgqskQEPfAGZPoZFF7NJ6nAdVuZGNbVJNIavxq6N5+yZpSTLHzU6KydnGE0G6MhWxNzW7iY=----ATTACHMENT:----ODM1MjYzNTIxOTQ1NzIwMiA3NTc3MzA1NDk5MDY4OTAyIDc0NDk1Mjc1MjQ1NDk0MTk=