require 'redis'
require 'legion/cache/pool'

module Legion
  module Cache
    module Redis
      include Legion::Cache::Pool
      extend self

      def client(pool_size: 20, timeout: 5, **)
        return @client unless @client.nil?

        @pool_size = pool_size
        @timeout = timeout

        @client = ConnectionPool.new(size: pool_size, timeout: timeout) do
          ::Redis.new
        end
        @connected = true
        @client
      end

      def get(key)
        client.with { |conn| conn.get(key) }
      end
      alias fetch get

      def set(key, value, ttl: nil)
        args = {}
        args[:ex] = ttl unless ttl.nil?
        client.with { |conn| conn.set(key, value, **args) == 'OK' }
      end

      def delete(key)
        client.with { |conn| conn.del(key) == 1 }
      end

      def flush
        client.with { |conn| conn.flushdb == 'OK' }
      end
    end
  end
end