# frozen_string_literal: true

require 'json'
require 'yajl'

# Sharable methods
module Utils
  include Logging

  def true?(obj)
    obj.to_s.casecmp('true').zero?
  end

  def json_parse(string)
    JSON.parse(string)
  rescue JSON::ParserError => e
    log.fatal "json parse err: '''#{e.message}'''\n\t#{e.backtrace.join("\n\t")}"
    exit 1
  end

  def fail_and_exit(text)
    log.fatal text
    exit 1
  end

  def make_index_name(index)
    index.split('-')[0..-2].join('-')
  end

  def skip_index?(index, state)
    index_name = make_index_name(index)

    if @config['settings']['indices'][index_name] &&
       @config['settings']['indices'][index_name]['skip'] &&
       @config['settings']['indices'][index_name]['skip'][state]

      if true?(@config['settings']['indices'][index_name]['skip'][state])
        log.warn "#{index_name} index #{state} skiped due settings"
        return true
      end
    end

    false
  end

  def delete_without_snapshot?(index)
    index_name = make_index_name(index)

    if @config['settings']['indices'][index_name] &&
       @config['settings']['indices'][index_name]['delete_without_snapshot']

      if true?(@config['settings']['indices'][index_name]['delete_without_snapshot'])
        log.warn "#{index_name} index can be deleted without snapshot"
        return true
      end
    end

    false
  end

  def prepare_vars
    indices   = @config['indices'].split(',').map(&:strip)
    daysago   = @config['daysago']
    date_from = @config['from']
    date_to   = @config['to']

    [indices, date_from, date_to, daysago]
  end

  def prechecks(date_from, date_to)
    unless date_from.nil?
      if date_from > date_to
        log.fatal "wrong dates: date to is behind date from. from: #{date_from}, to: #{date_to}"
        exit 1
      end
    end

    return if true?(@config['force'])
    return if @elastic.green?

    fail_and_exit("elasticsearch on #{@config['es']['url']} is not green")
  end

  def already?(response, state)
    if %w[open close].include?(state)
      index = json_parse(response).first
      if index['status'] == state
        log.warn "#{index['index']} index status already #{state}"
        return true
      end
    elsif %w[hot warm].include?(state)
      index    = json_parse(response).first['index']
      box_type = @elastic.index_box_type(index)

      if box_type.nil?
        log.info "can't get box_type, look at the previous error for info, will skip #{index}"
        return true
      end

      if box_type == state
        log.warn "#{index['index']} index already #{state}"
        return true
      end
    else
      log.fatal "wrong state for check #{state}, bad coder"
      exit 1
    end

    false
  end

  def elastic_action_with_log(action, index, *params)
    if @elastic.send(action, index, *params)
      log.info "#{index} #{action} succes"
    else
      log.error "#{index} #{action} fail"
      return false
    end

    true
  end

  def index_exist?(response)
    if response.code == 200
      true
    elsif response.code == 404
      false
    else
      log.fatal "wtf in index_exist? response was: #{response.code} - #{response}"
      exit 1
    end
  end
end