6eaae75e-8582-4162-bf7f-32b0a072fade

Committed 31 Dec 2024 06:09PM UTC coverage: 90.366% (-1.5%) from 91.859%

Build # 6eaae75e-8582-4162-bf7f-32b0a072fade

Build Type

push

circleci

Committed by

sandbergja

Commit Message

Bundle update rails

Add mutex_m
Don't require marc cleanup

Co-authored-by: Jane Sandberg <sandbergja@users.noreply.github.com>

Run Details

3330 of 3685 relevant lines covered (90.37%)

376.89 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✔
29	solr = rsolr_connection(solr_url)	×
30	return if solr.nil?	×
31
32	dumps.each do \|dump\|	×
33	dump.dump_files.each do \|df\|	×
34	next unless df.recap_record_type?	×
35
36	DumpFileIndexJob.perform_async(df.id, solr_url)	×
37	end
38	solr.delete_by_id(dump.delete_ids) if dump.delete_ids.present?	×
39	end
40	end
41	end

pulibrary / bibdata / 6eaae75e-8582-4162-bf7f-32b0a072fade

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