dirname = rtrim($dirname, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR; } /** * {@inheritdoc} */ public function save($id, $data) { if (!file_exists($this->dirname)) { mkdir($this->dirname, 0777, true); } file_put_contents($this->makeFilename($id), json_encode($data)); } /** * {@inheritdoc} */ public function get($id) { return json_decode(file_get_contents($this->makeFilename($id)), true); } /** * {@inheritdoc} */ public function find(array $filters = array(), $max = 20, $offset = 0) { //Loop through all .json files and remember the modified time and id. $files = array(); foreach (new \DirectoryIterator($this->dirname) as $file) { if ($file->getExtension() == 'json') { $files[] = array( 'time' => $file->getMTime(), 'id' => $file->getBasename('.json') ); } } //Sort the files, newest first usort($files, function ($a, $b) { return $a['time'] < $b['time']; }); //Load the metadata and filter the results. $results = array(); $i = 0; foreach ($files as $file) { //When filter is empty, skip loading the offset if ($i++ < $offset && empty($filters)) { $results[] = null; continue; } $data = $this->get($file['id']); $meta = $data['__meta']; unset($data); if ($this->filter($meta, $filters)) { $results[] = $meta; } if (count($results) >= ($max + $offset)) { break; } } return array_slice($results, $offset, $max); } /** * Filter the metadata for matches. * * @param array $meta * @param array $filters * @return bool */ protected function filter($meta, $filters) { foreach ($filters as $key => $value) { if (!isset($meta[$key]) || fnmatch($value, $meta[$key]) === false) { return false; } } return true; } /** * {@inheritdoc} */ public function clear() { foreach (new \DirectoryIterator($this->dirname) as $file) { if (substr($file->getFilename(), 0, 1) !== '.') { unlink($file->getPathname()); } } } /** * @param string $id * @return string */ public function makeFilename($id) { return $this->dirname . basename($id). ".json"; } }