FM / Cache

/home/techb158/ileadtechnology.com/vendor/ankitpokhrel/tus-php/src/Cache/

/home/techb158/ileadtechnology.com/vendor/ankitpokhrel/tus-php/src/Cache

Name	Size	Mode	Actions
AbstractCache.php	1321	0644	edit dl rm
ApcuStore.php	1694	0644	edit dl rm
Cacheable.php	1401	0644	edit dl rm
CacheFactory.php	455	0644	edit dl rm
FileStore.php	6692	0644	edit dl rm
RedisStore.php	2106	0644	edit dl rm

Edit: /home/techb158/ileadtechnology.com/vendor/ankitpokhrel/tus-php/src/Cache/RedisStore.php (2106B)

<?php

namespace TusPhp\Cache;

use Carbon\Carbon;
use TusPhp\Config;
use Predis\Client as RedisClient;

class RedisStore extends AbstractCache
{
    /** @var RedisClient */
    protected $redis;

/**
     * RedisStore constructor.
     *
     * @param array $options
     */
    public function __construct(array $options = [])
    {
        $options = empty($options) ? Config::get('redis') : $options;

$this->redis = new RedisClient($options);
    }

/**
     * Get redis.
     *
     * @return RedisClient
     */
    public function getRedis(): RedisClient
    {
        return $this->redis;
    }

/**
     * {@inheritDoc}
     */
    public function get(string $key, bool $withExpired = false)
    {
        $prefix = $this->getPrefix();

if (false === strpos($key, $prefix)) {
            $key = $prefix . $key;
        }

$contents = $this->redis->get($key);
        if (null !== $contents) {
            $contents = json_decode($contents, true);
        }

if ($withExpired) {
            return $contents;
        }

if ( ! $contents) {
            return null;
        }

$isExpired = Carbon::parse($contents['expires_at'])->lt(Carbon::now());

return $isExpired ? null : $contents;
    }

/**
     * {@inheritDoc}
     */
    public function set(string $key, $value)
    {
        $contents = $this->get($key) ?? [];

if (\is_array($value)) {
            $contents = $value + $contents;
        } else {
            $contents[] = $value;
        }

$status = $this->redis->set($this->getPrefix() . $key, json_encode($contents));

return 'OK' === $status->getPayload();
    }

/**
     * {@inheritDoc}
     */
    public function delete(string $key): bool
    {
        $prefix = $this->getPrefix();

if (false === strpos($key, $prefix)) {
            $key = $prefix . $key;
        }

return $this->redis->del([$key]) > 0;
    }

/**
     * {@inheritDoc}
     */
    public function keys(): array
    {
        return $this->redis->keys($this->getPrefix() . '*');
    }
}

redis = new RedisClient($options); } /** * Get redis. * * @return RedisClient */ public function getRedis(): RedisClient { return $this->redis; } /** * {@inheritDoc} */ public function get(string $key, bool $withExpired = false) { $prefix = $this->getPrefix(); if (false === strpos($key, $prefix)) { $key = $prefix . $key; } $contents = $this->redis->get($key); if (null !== $contents) { $contents = json_decode($contents, true); } if ($withExpired) { return $contents; } if ( ! $contents) { return null; } $isExpired = Carbon::parse($contents['expires_at'])->lt(Carbon::now()); return $isExpired ? null : $contents; } /** * {@inheritDoc} */ public function set(string $key, $value) { $contents = $this->get($key) ?? []; if (\is_array($value)) { $contents = $value + $contents; } else { $contents[] = $value; } $status = $this->redis->set($this->getPrefix() . $key, json_encode($contents)); return 'OK' === $status->getPayload(); } /** * {@inheritDoc} */ public function delete(string $key): bool { $prefix = $this->getPrefix(); if (false === strpos($key, $prefix)) { $key = $prefix . $key; } return $this->redis->del([$key]) > 0; } /** * {@inheritDoc} */ public function keys(): array { return $this->redis->keys($this->getPrefix() . '*'); } }