module Restspec::Schema::Types
  class SchemaIdType < BasicType
    attr_accessor :schema_name

    def initialize(options, options_when_name_is_present = {})
      if options.is_a?(Symbol)
        self.schema_name = options
        super(options_when_name_is_present)
      else
        super(options)
      end
    end

    def example_for(attribute)
      return sample_item.id if sample_item.present?

      if create_response.code == 201 && create_response.body.try(:id)
        create_response.body.id
      else
        example_options.fetch(:hardcoded_fallback) {
          raise "We couldn't fetch any information for this example"
        }
      end
    rescue URI::InvalidURIError, Errno::ECONNREFUSED => e
      puts "WARNING: Error calling api #{e}. Falling back to use a number."
      Faker::Number.digit
    end

    def valid?(attribute, value)
      return true unless perform_validation?
      item_ids.any? { |item| item.id == value }
    end

    private

    def find_endpoint(name)
      Restspec::EndpointStore.get(name)
    end

    def sample_item
      @sample_item ||= get_sample_item
    end

    def get_index_endpoint
      if schema_name.present?
        Restspec::EndpointStore.get_by_schema_and_name(schema_name, :index)
      else
        find_endpoint(example_options.fetch(:fetch_endpoint))
      end
    end

    def get_sample_item
      fetch_endpoint = get_index_endpoint
      fetch_endpoint.execute.body.try(:sample)
    end

    def create_response
      create_endpoint.execute(body: create_example)
    end

    def get_create_endpoint
      if schema_name.present?
        namespace = Restspec::Endpoints::Namespace.get_by_schema_name(schema_name)
        namespace.get_endpoint(:create)
      else
        find_endpoint(example_options.fetch(:create_endpoint))
      end
    end

    def create_endpoint
      @create_endpoint ||= get_create_endpoint
    end

    def create_example
      Restspec.example_for(create_schema_name)
    end

    def create_schema_name
      example_options.fetch(:create_schema, create_endpoint.schema_name)
    end

    def perform_validation?
      schema_options.fetch(:perform_validation, true)
    end

    def item_ids
      fetch_endpoint = get_index_endpoint
      fetch_endpoint.execute.body
    end
  end
end