b3c4a532-5da0-46f8-9c20-20018605a028

Committed 21 Mar 2025 08:11PM UTC coverage: 42.257% (-49.9%) from 92.185%

Build # b3c4a532-5da0-46f8-9c20-20018605a028

Build Type

push

circleci

Committed by

sandbergja

Commit Message

Move various gems from the default Gemfile group to a more appropriate group

Run Details

1599 of 3784 relevant lines covered (42.26%)

2.56 hits per line

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

25.0

/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?

        Index::DumpFileJob.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']	×
13	end
14
15	def self.logger	1✔
16	return Rails.logger if defined?(Rails)	×
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)	×
23	rescue StandardError => e
24	logger.error "Failed to connect to Solr: #{e.message}"	×
25	nil	×
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	Index::DumpFileJob.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 / b3c4a532-5da0-46f8-9c20-20018605a028

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