# frozen_string_literal: true
module PrependedLinkedData::FindTerm
  # Override Qa::Authorities::LinkedData::FindTerm#find method
  # @return [Hash] single term results in requested format
  def find(id, request_header: {}, language: nil, replacements: {}, subauth: nil, format: nil, performance_data: false) # rubocop:disable Metrics/ParameterLists, Metrics/CyclomaticComplexity
    return super if QaServer.config.suppress_performance_gathering

    start_time_s = QaServer.current_time_s
    request_header = build_request_header(language: language, replacements: replacements, subauth: subauth, format: format, performance_data: performance_data) if request_header.empty?
    saved_performance_data = performance_data || request_header[:performance_data]
    request_header[:performance_data] = true

    @phid = QaServer.config.performance_cache.new_entry(authority: authority_name, action: 'fetch')
    begin
      full_results = super
      update_performance_history_record(full_results, start_time_s)
    rescue Exception => e # rubocop:disable Lint/RescueException
      QaServer.config.performance_cache.destroy(@phid)
      raise e
    end
    saved_performance_data || !full_results.is_a?(Hash) ? full_results : full_results[:results]
  end

  private

    def update_performance_history_record(full_results, start_time_s)
      return QaServer.config.performance_cache.destroy(@phid) unless full_results.is_a?(Hash) && full_results.key?(:performance)
      updates = { action_time_ms: (QaServer.current_time_s - start_time_s) * 1000,
                  size_bytes: full_results[:performance][:fetched_bytes],
                  retrieve_plus_graph_load_time_ms: full_results[:performance][:fetch_time_s] * 1000,
                  normalization_time_ms: full_results[:performance][:normalization_time_s] * 1000 }
      QaServer.config.performance_cache.update(id: @phid, updates: updates)
      QaServer.config.performance_cache.log(id: @phid)
    end

    # Override to append performance history record id into the URL to allow access to the record in RDF::Graph
    def load_graph(url:)
      return super if QaServer.config.suppress_performance_gathering

      access_start_dt = QaServer.current_time

      url += "&phid=#{@phid}"
      @full_graph = graph_service.load_graph(url: url)

      access_end_dt = QaServer.current_time
      @access_time_s = access_end_dt - access_start_dt
      @fetched_size = full_graph.triples.to_s.size if performance_data?
      Rails.logger.info("Time to receive data from authority: #{access_time_s}s")
    end

    # Temporary override to fix bug.  Remove when QA Issue #271 is fixed and a new release is cut
    def performance_data?
      return super if QaServer.config.suppress_performance_gathering

      @performance_data == true
    end
end