166d57e5-7cd2-4a93-abb1-e0b236109bef

Committed 31 Dec 2024 08:55PM UTC coverage: 90.88% (-1.1%) from 91.93%

Build # 166d57e5-7cd2-4a93-abb1-e0b236109bef

Build Type

push

circleci

Committed by

maxkadel

Commit Message

Break on purpose to check retries

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

40 existing lines in 3 files now uncovered.

3458 of 3805 relevant lines covered (90.88%)

365.05 hits per line

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

45.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 => e
    logger.error "Failed to connect to Solr: #{e.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)	3✔
23	rescue StandardError => e
24	logger.error "Failed to connect to Solr: #{e.message}"	1✔
25	nil	1✔
26	end
27
28	def self.process_scsb_dumps(dumps, solr_url)	1✔
UNCOV 29	solr = rsolr_connection(solr_url)	×
UNCOV 30	return if solr.nil?	×
31
UNCOV 32	dumps.each do \|dump\|	×
UNCOV 33	dump.dump_files.each do \|df\|	×
UNCOV 34	next unless df.recap_record_type?	×
35
UNCOV 36	DumpFileIndexJob.perform_async(df.id, solr_url)	×
37	end
UNCOV 38	solr.delete_by_id(dump.delete_ids) if dump.delete_ids.present?	×
39	end
40	end
41	end

pulibrary / bibdata / 166d57e5-7cd2-4a93-abb1-e0b236109bef

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