4f01b5ec-96e4-40e5-bb74-6da450726a2e

Build # 4f01b5ec-96e4-40e5-bb74-6da450726a2e

Build Type

circleci

Committed by Jane Sandberg

Commit Message

explicitly require redis gem

Pull Request Pull Request #2143: Bump sidekiq and sidekiq-pro

Run Details

3555 of 3942 relevant lines covered (90.18%)

307.23 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

70.83

/app/services/index_functions.rb

module IndexFunctions
  def self.update_records(dump)
    file_paths = []
    dump['files']['updated_records'].each_with_index do |update, i|
      File.binwrite("/tmp/update_#{i}.gz", Faraday.get(update['dump_file']).body)
      file_paths << "/tmp/update_#{i}"
    end
    file_paths
  end

  def self.delete_ids(dump)
    dump['ids']['delete_ids']
  end

  def self.logger
    return Rails.logger if defined?(Rails)

    @logger ||= Logger.new(STDOUT)
  end

  def self.rsolr_connection(solr_url)
    RSolr.connect(url: solr_url, timeout: 300, open_timeout: 300)
  rescue StandardError => error
    logger.error "Failed to connect to Solr: #{error.message}"
    nil
  end

  def self.process_scsb_dumps(dumps, solr_url)
    solr = rsolr_connection(solr_url)
    return if solr.nil?

    dumps.each do |dump|
      dump.dump_files.each do |df|
        next unless df.recap_record_type?
        DumpFileIndexJob.perform_async(df.id, solr_url)
      end
      solr.delete_by_id(dump.delete_ids) if dump.delete_ids.present?
    end
  end
end

1	module IndexFunctions	1✔
2	def self.update_records(dump)	1✔
3	file_paths = []	×
4	dump['files']['updated_records'].each_with_index do \|update, i\|	×
5	File.binwrite("/tmp/update_#{i}.gz", Faraday.get(update['dump_file']).body)	×
6	file_paths << "/tmp/update_#{i}"	×
7	end
8	file_paths	×
9	end
10
11	def self.delete_ids(dump)	1✔
12	dump['ids']['delete_ids']	1✔
13	end
14
15	def self.logger	1✔
16	return Rails.logger if defined?(Rails)	4✔
17
18	@logger \|\|= Logger.new(STDOUT)	×
19	end
20
21	def self.rsolr_connection(solr_url)	1✔
22	RSolr.connect(url: solr_url, timeout: 300, open_timeout: 300)	4✔
23	rescue StandardError => error
24	logger.error "Failed to connect to Solr: #{error.message}"	1✔
25	nil	1✔
26	end
27
28	def self.process_scsb_dumps(dumps, solr_url)	1✔
29	solr = rsolr_connection(solr_url)	1✔
30	return if solr.nil?	1✔
31
32	dumps.each do \|dump\|	1✔
33	dump.dump_files.each do \|df\|	1✔
34	next unless df.recap_record_type?	1✔
35	DumpFileIndexJob.perform_async(df.id, solr_url)	1✔
36	end
37	solr.delete_by_id(dump.delete_ids) if dump.delete_ids.present?	×
38	end
39	end
40	end

pulibrary / bibdata / 4f01b5ec-96e4-40e5-bb74-6da450726a2e

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous