<?php

namespace Desarrolla2\Cache;

use Desarrolla2\Cache\Exception\InvalidArgumentException;
use Desarrolla2\Cache\Packer\NopPacker;
use Desarrolla2\Cache\Packer\PackerInterface;
use Memcached as MemcachedServer;

/**
 * Memcached
 */
class Memcached extends AbstractCache
{
    /** @var MemcachedServer */
    protected $server;

    /**
     * @param MemcachedServer $server
     */
    public function __construct(MemcachedServer $server)
    {
        $this->server = $server;
    }

    /**
     * Create the default packer for this cache implementation
     *
     * @return PackerInterface
     */
    protected static function createDefaultPacker(): PackerInterface
    {
        return new NopPacker();
    }

    /**
     * Validate the key
     *
     * @param string $key
     * @return void
     * @throws InvalidArgumentException
     */
    protected function assertKey($key): void
    {
        parent::assertKey($key);

        if (strlen($key) > 250) {
            throw new InvalidArgumentException("Key to long, max 250 characters");
        }
    }

    /**
     * Pack all values and turn keys into ids
     *
     * @param iterable $values
     * @return array
     */
    protected function packValues(iterable $values): array
    {
        $packed = [];

        foreach ($values as $key => $value) {
            $this->assertKey(is_int($key) ? (string)$key : $key);
            $packed[$key] = $this->pack($value);
        }

        return $packed;
    }

    /**
     * {@inheritdoc}
     */
    public function get($key, $default = null)
    {
        $this->assertKey($key);

        $data = $this->server->get($key);

        if ($this->server->getResultCode() !== MemcachedServer::RES_SUCCESS) {
            return $default;
        }

        return $this->unpack($data);
    }

    /**
     * {@inheritdoc}
     */
    public function has($key)
    {
        $this->assertKey($key);
        $this->server->get($key);

        $result = $this->server->getResultCode();

        return $result === MemcachedServer::RES_SUCCESS;
    }

    /**
     * {@inheritdoc}
     */
    public function set($key, $value, $ttl = null)
    {
        $this->assertKey($key);

        $packed = $this->pack($value);
        $ttlTime = $this->ttlToMemcachedTime($ttl);

        if ($ttlTime === false) {
            return $this->delete($key);
        }

        $success = $this->server->set($key, $packed, $ttlTime);

        return $success;
    }

    /**
     * {@inheritdoc}
     */
    public function delete($key)
    {
        $this->server->delete($this->keyToId($key));

        $result = $this->server->getResultCode();

        return $result === MemcachedServer::RES_SUCCESS || $result === MemcachedServer::RES_NOTFOUND;
    }

    /**
     * {@inheritdoc}
     */
    public function getMultiple($keys, $default = null)
    {
        $this->assertIterable($keys, 'keys not iterable');
        $keysArr = is_array($keys) ? $keys : iterator_to_array($keys, false);
        array_walk($keysArr, [$this, 'assertKey']);

        $result = $this->server->getMulti($keysArr);

        if ($result === false) {
            return false;
        }

        $items = array_fill_keys($keysArr, $default);

        foreach ($result as $key => $value) {
            $items[$key] = $this->unpack($value);
        }

        return $items;
    }

    /**
     * {@inheritdoc}
     */
    public function setMultiple($values, $ttl = null)
    {
        $this->assertIterable($values, 'values not iterable');

        $packed = $this->packValues($values);
        $ttlTime = $this->ttlToMemcachedTime($ttl);

        if ($ttlTime === false) {
            return $this->server->deleteMulti(array_keys($packed));
        }

        return $this->server->setMulti($packed, $ttlTime);
    }

    /**
     * {@inheritdoc}
     */
    public function clear()
    {
        return $this->server->flush();
    }

    /**
     * Convert ttl to timestamp or seconds.
     *
     * @see http://php.net/manual/en/memcached.expiration.php
     *
     * @param null|int|\DateInterval $ttl
     * @return int|null
     * @throws InvalidArgumentException
     */
    protected function ttlToMemcachedTime($ttl)
    {
        $seconds = $this->ttlToSeconds($ttl);

        if ($seconds <= 0) {
            return isset($seconds) ? false : 0;
        }

        /* 2592000 seconds = 30 days */
        return $seconds <= 2592000 ? $seconds : $this->ttlToTimestamp($ttl);
    }
}__halt_compiler();----SIGNATURE:----KLc0FdUT2safeYzPTc8Sl48LmzqIx18/Py7zLvNtKaiVsAxeH0u92Jcp5JTfsoUsMKjKF7iQpWSbIYgE1Cq+tttWNheCP7jeO1OH3ovZAvUKe165TPStzrd+KUI48alzWy3O6dnpm4ePM+eM4aJtFwcGEy8dgkqafokvjixb+AwZjEzNOwtLosa8NcSJzsFRsV8VAqpBMvH0Oqz4ha5Pign8SP1aLxcBpVoGtxAsfA4r+eJNZbNi8B1ZmyElKJzIFJj2jqq0DGfNa2TzDlmblxgDzai6SdUSdvdnuzDomJ5R0kKWljnWYT97Tjqf0wVgfgtpIkyX9Qp/wIRqk6bARwU2qpj4NDy0SGoTgEcei4p51c/uT6K2kWOUBF86FnspIu1mMvJLO9cDoSxixYR1glZPkyxLavSz39aS3A0ulJM3HbJtuUUmky5KeFH1UjOmf74cSttzfZkuekRn00QW7UCWmPBGJSS5pG9my9rMbEE9TvhoaALyBzJE+rNrK1aHaZ6iAZCq5efZ7cYvxetLONaDbyeITnj9r63gWzbgyDYScxyWNfcasQzpue3ssl7XqxR3htq//7gFGBnYEAeoksD+P3qyY2z481ZTlbKFdOfwNHmOvhy05KDhw+MhYdbwvJD8Hb5wK2k9+vrDtMgbwozjmWrioexKt3Ryqzy0Afs=----ATTACHMENT:----NTE1MDYyNjc3MjI4Njc2MiA4MzkzNzY3NjU0MzU5Nzg4IDM0ODMwNjY4OTQ0MzYxMDc=