OpenGems/redis_web_manager

# frozen_string_literal: true

module RedisWebManager
  class KeysController < ApplicationController

    # GET /keys
    def index
      @status = info.status
      @url = connection.id
      @pagy, @keys = pagy_array(keys)
    end

    # GET /key/:key
    def show
      key = params[:key].presence
      redirect_to keys_url if key.nil?
      @key = format_key(key)
    end

    # GET /key/:key
    def edit
      key = params[:key].presence
      redirect_to keys_url if key.nil?
      @key = format_key(key)
    end

    # PUT /key/:key
    def update
      old_key = params[:old_name].presence
      new_name = params[:new_name].presence
      redirect_to keys_url if old_key.nil? || new_name.nil?
      action.rename(old_key, new_name)
      redirect_to keys_url
    end

    # DELETE /key/:key
    def destroy
      key = params[:key].presence
      redirect_to keys_url if key.nil?
      action.del(key)
      redirect_to keys_url
    end

    private

    # FIXME: - Refactoring
    #        - Move this part
    def item_type(value)
      ['json', JSON.parse(value)]
    rescue JSON::ParserError
      ['string', value]
    end

    def get_list(key)
      start = 0
      stop  = 99

      length = info.llen(key)
      values = info.lrange(key, start, stop).map.with_index do |e, i|
        type, value = item_type(e)
        { type: type, value: value, index: start + i }
      end

      { length: length, values: values }
    end

    def get_set(key)
      values = info.smembers(key).map do |e|
        type, value = item_type(e)
        { type: type, value: value }
      end

      { values: values }
    end

    def get_zset(key)
      values = info.zrange(key, 0, -1, withscores: true).map do |e, score|
        type, value = item_type(e)
        { type: type, value: value, score: score }
      end

      { values: values }
    end

    def get_hash(key)
      value = Hash[info.hgetall(key).map do |k, v|
        type, value = item_type(v)
        [k, { type: type, value: value }]
      end]

      { value: value }
    end

    def get_value(key)
      case info.type(key)
      when 'string'
        { value: info.get(key) }
      when 'list'
        get_list(key)
      when 'set'
        get_set(key)
      when 'zset'
        get_zset(key)
      when 'hash'
        get_hash(key)
      else
        { value: 'Not found' }
      end
    end

    def format_key(key)
      {
        key: key,
        expiry: info.expiry(key),
        node: get_value(key),
        type: info.type(key),
        memory: info.memory_usage(key)
      }
    end

    def keys
      keys = info.search(params[:query].presence).map { |key| format_key(key) }
      keys = filter_by_type(keys, params[:type].presence)
      keys = filter_by_expiry(keys, params[:expiry].presence)
      filter_by_memory(keys, params[:expiry].presence)
    end

    def filter_by_type(keys, type)
      return keys if invalid_option(type)
      keys.select { |key| key[:type] == type }
    end

    def filter_by_expiry(keys, expiry)
      return keys if invalid_option(expiry)
      duration = expiry.to_i
      return keys.select { |key| key[:expiry] == -1 } if duration == -1
      keys.select { |key| key[:expiry] != -1 && key[:expiry] < duration }
    end

    def filter_by_memory(keys, memory)
      return keys if invalid_option(memory)
      keys.select { |key| key[:memory] < memory.to_i }
    end

    def invalid_option(option)
      option.nil? || option == 'all'
    end
  end
end