<?php

namespace Spiral\RoadRunner\KeyValue;

use Spiral\Goridge\RPC\Codec\ProtobufCodec;
use Spiral\Goridge\RPC\Exception\ServiceException;
use Spiral\Goridge\RPC\RPCInterface;
use Spiral\RoadRunner\KeyValue\DTO\V1\Item;
use Spiral\RoadRunner\KeyValue\DTO\V1\Request;
use Spiral\RoadRunner\KeyValue\DTO\V1\Response;
use Spiral\RoadRunner\KeyValue\Exception\InvalidArgumentException;
use Spiral\RoadRunner\KeyValue\Exception\KeyValueException;
use Spiral\RoadRunner\KeyValue\Exception\NotImplementedException;
use Spiral\RoadRunner\KeyValue\Exception\SerializationException;
use Spiral\RoadRunner\KeyValue\Exception\StorageException;
use Spiral\RoadRunner\KeyValue\Serializer\SerializerAwareTrait;
use Spiral\RoadRunner\KeyValue\Serializer\SerializerInterface;
use Spiral\RoadRunner\KeyValue\Serializer\DefaultSerializer;

/**
 * @psalm-suppress PropertyNotSetInConstructor
 */
class Cache implements StorageInterface
{
    use SerializerAwareTrait;

    const ERROR_INVALID_STORAGE =
        'Storage "%s" has not been defined. Please make sure your '.
        'RoadRunner "kv" configuration contains a storage key named "%1$s"';

    const ERROR_TTL_NOT_AVAILABLE =
        'Storage "%s" does not support kv.TTL RPC method execution. Please '.
        'use another driver for the storage if you require this functionality';

    const ERROR_CLEAR_NOT_AVAILABLE =
        'RoadRunner does not support kv.Clear RPC method. Please '.
        'make sure you are using RoadRunner v2.3.1 or higher.';

    const ERROR_INVALID_KEY = 'Cache key must be a string, but %s passed';

    const ERROR_INVALID_KEYS = 'Cache keys must be an array<string>, but %s passed';

    const ERROR_INVALID_VALUES = 'Cache values must be an array<string, mixed>, but %s passed';

    const ERROR_INVALID_INTERVAL_ARGUMENT =
        'Cache item ttl (expiration) must be of type int or \DateInterval, but %s passed';

    /**
     * @var \Spiral\Goridge\RPC\RPCInterface
     */
    protected $rpc;
    /**
     * @var string
     */
    private $name;
    /**
     * @var \DateTimeZone
     */
    protected $zone;

    /**
     * @param \Spiral\Goridge\RPC\RPCInterface $rpc
     * @param string $name
     * @param \Spiral\RoadRunner\KeyValue\Serializer\SerializerInterface|null $serializer
     */
    public function __construct($rpc, $name, $serializer = null)
    {
        $this->name = $name;
        $this->rpc = $rpc->withCodec(new ProtobufCodec());
        $this->zone = new \DateTimeZone('UTC');

        $this->setSerializer($serializer ?? new DefaultSerializer());
    }

    public function getName()
    {
        return $this->name;
    }

    /**
     * @throws KeyValueException
     * @param string $key
     * @return \DateTimeInterface|null
     */
    public function getTtl($key)
    {
        foreach ($this->getMultipleTtl([$key]) as $ttl) {
            assert($ttl instanceof \DateTimeInterface || $ttl === null);

            return $ttl;
        }

        // @codeCoverageIgnoreStart
        // This stmt MUST NOT be executed and is present in the code
        // only for static analysis.
        return null;
        // @codeCoverageIgnoreEnd
    }

    /**
     * @throws KeyValueException
     * @param mixed[] $keys
     * @return mixed[]
     */
    public function getMultipleTtl($keys = [])
    {
        try {
            $response = $this->createIndex(
                $this->call('kv.TTL', $this->requestKeys($keys))
            );
        } catch (KeyValueException $e) {
            if (strpos($e->getMessage(), '_plugin_ttl') !== false) {
                $message = \sprintf(self::ERROR_TTL_NOT_AVAILABLE, $this->name);
                throw new NotImplementedException($message, (int)$e->getCode(), $e);
            }

            throw $e;
        }

        foreach ($keys as $key) {
            yield $key => isset($response[$key]) && $response[$key]->getTimeout() !== ''
                ? $this->dateFromRfc3339String($response[$key]->getTimeout())
                : null;
        }
    }

    /**
     * @return array<string, Item>
     * @param \Spiral\RoadRunner\KeyValue\DTO\V1\Response $response
     */
    private function createIndex($response)
    {
        $result = [];

        /** @var Item $item */
        foreach ($response->getItems() as $item) {
            $result[$item->getKey()] = $item;
        }

        return $result;
    }

    /**
     * @psalm-suppress MixedReturnStatement
     * @psalm-suppress MixedInferredReturnType
     *
     * @throws KeyValueException
     * @param string $method
     * @param \Spiral\RoadRunner\KeyValue\DTO\V1\Request $request
     */
    private function call($method, $request)
    {
        try {
            return $this->rpc->call($method, $request, Response::class);
        } catch (ServiceException $e) {
            $message = \str_replace(["\t", "\n"], ' ', $e->getMessage());

            if (strpos($message, 'no such storage') !== false) {
                throw new StorageException(\sprintf(self::ERROR_INVALID_STORAGE, $this->name));
            }

            throw new KeyValueException($message, (int)$e->getCode(), $e);
        }
    }

    /**
     * @param iterable<string> $keys
     * @throws InvalidArgumentException
     */
    private function requestKeys($keys)
    {
        $items = [];

        foreach ($keys as $key) {
            $this->assertValidKey($key);
            $items[] = new Item(['key' => $key]);
        }

        return $this->request($items);
    }

    /**
     * @param array<Item> $items
     */
    private function request($items)
    {
        return new Request([
            'storage' => $this->name,
            'items' => $items,
        ]);
    }

    /**
     * @return \DateTimeImmutable
     *
     * @psalm-suppress InvalidFalsableReturnType
     * @psalm-suppress FalsableReturnStatement
     * @param string $time
     */
    private function dateFromRfc3339String($time)
    {
        return \DateTimeImmutable::createFromFormat(\DateTimeInterface::RFC3339, $time, $this->zone);
    }

    /**
     * @throws KeyValueException
     * @param mixed $default
     * @return mixed
     * @param string $key
     */
    public function get($key, $default = null)
    {
        /** @psalm-suppress MixedAssignment */
        foreach ($this->getMultiple([$key], $default) as $value) {
            return $value;
        }

        // @codeCoverageIgnoreStart
        // This stmt MUST NOT be executed and is present in the code
        // only for static analysis.
        return $default;
        // @codeCoverageIgnoreEnd
    }

    /**
     * @psalm-param iterable<string> $keys
     * @return iterable<string, mixed>
     * @throws KeyValueException
     * @param mixed $default
     * @param mixed[] $keys
     */
    public function getMultiple($keys, $default = null)
    {
        /** @psalm-suppress MixedArgumentTypeCoercion */
        $items = $this->createIndex(
            $this->call('kv.MGet', $this->requestKeys($keys))
        );

        $serializer = $this->getSerializer();

        foreach ($keys as $key) {
            if (isset($items[$key])) {
                yield $key => $serializer->unserialize($items[$key]->getValue());

                continue;
            }

            yield $key => $default;
        }
    }

    /**
     * @psalm-param positive-int|\DateInterval|null $ttl
     * @psalm-suppress MoreSpecificImplementedParamType
     * @throws KeyValueException
     * @param null|int|\DateInterval $ttl
     * @param mixed $value
     * @param string $key
     */
    public function set($key, $value, $ttl = null)
    {
        return $this->setMultiple([$key => $value], $ttl);
    }

    /**
     * @param mixed|string $key
     * @throws InvalidArgumentException
     * @return void
     */
    private function assertValidKey($key)
    {
        if (! \is_string($key)) {
            throw new InvalidArgumentException(\sprintf(self::ERROR_INVALID_KEY, \get_debug_type($key)));
        }
    }

    /**
     * @psalm-param iterable<string, mixed> $values
     * @psalm-param positive-int|\DateInterval|null $ttl
     * @psalm-suppress MoreSpecificImplementedParamType
     * @throws KeyValueException
     * @param null|int|\DateInterval $ttl
     * @param mixed[] $values
     */
    public function setMultiple($values, $ttl = null)
    {
        $this->call('kv.Set', $this->requestValues($values, $this->ttlToRfc3339String($ttl)));

        return true;
    }

    /**
     * @param iterable<string, mixed> $values
     * @throws SerializationException
     * @param string $ttl
     */
    private function requestValues($values, $ttl)
    {
        $items = [];
        $serializer = $this->getSerializer();

        /** @psalm-suppress MixedAssignment */
        foreach ($values as $key => $value) {
            $this->assertValidKey($key);

            $items[] = new Item([
                'key' => $key,
                'value' => $serializer->serialize($value),
                'timeout' => $ttl,
            ]);
        }

        return $this->request($items);
    }

    /**
     * @throws InvalidArgumentException
     * @param null|int|\DateInterval $ttl
     */
    private function ttlToRfc3339String($ttl)
    {
        if ($ttl === null) {
            return '';
        }

        if ($ttl instanceof \DateInterval) {
            return $this->now()
                ->add($ttl)
                ->format(\DateTimeInterface::RFC3339);
        }

        $now = $this->now();

        return $now->setTimestamp($ttl + $now->getTimestamp())->format(\DateTimeInterface::RFC3339);
    }

    /**
     * Please note that this interface currently emulates the behavior of the
     * PSR-20 implementation and may be replaced by the `psr/clock`
     * implementation in future versions.
     *
     * Returns the current time as a DateTimeImmutable instance.
     *
     * @codeCoverageIgnore Ignore time-aware-mutable value.
     *                     Must be covered with a stub.
     * @throws \Exception
     */
    protected function now()
    {
        return new \DateTimeImmutable('NOW', $this->zone);
    }

    /**
     * Note: The current PSR-16 implementation always returns true or
     * exception on error.
     *
     * @throws KeyValueException
     * @param string $key
     */
    public function delete($key)
    {
        return $this->deleteMultiple([$key]);
    }

    /**
     * Note: The current PSR-16 implementation always returns true or
     * exception on error.
     *
     * {@inheritDoc}
     *
     * @psalm-param iterable<string> $keys
     *
     * @throws KeyValueException
     * @param mixed[] $keys
     */
    public function deleteMultiple($keys)
    {
        $this->call('kv.Delete', $this->requestKeys($keys));

        return true;
    }

    /**
     * @throws KeyValueException
     */
    public function clear()
    {
        try {
            $this->call('kv.Clear', $this->request([]));
        } catch (KeyValueException $e) {
            if (strpos($e->getMessage(), 'can\'t find method kv.Clear') !== false) {
                throw new KeyValueException(self::ERROR_CLEAR_NOT_AVAILABLE, (int)$e->getCode(), $e);
            }

            throw $e;
        }

        return true;
    }

    /**
     * @throws KeyValueException
     * @param string $key
     */
    public function has($key)
    {
        /** @var array<Item> $items */
        $items = $this->call('kv.Has', $this->requestKeys([$key]))
            ->getItems();

        foreach ($items as $item) {
            if ($item->getKey() === $key) {
                return true;
            }
        }

        return false;
    }
}
