#134

Committed 17 Oct 2025 10:48AM UTC coverage: 96.979% (-3.0%) from 100.0%

Build # #134

Build Type

push

Committed by

Commit Message

Merge 2394146f4 into a76567e00

Run Details

9 of 19 new or added lines in 2 files covered. (47.37%)

321 of 331 relevant lines covered (96.98%)

16.52 hits per line

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

44.44

/app/models/queueable.rb

# frozen_string_literal: true

module Queueable
  extend ActiveSupport::Concern

  require "aws-sdk-sqs"

  class_methods do
    def send_events_other_doi_job_message(data)
      send_message(data, shoryuken_class: "OtherDoiJobWorker", queue_name: "events_other_doi_job")
    end

    private

    def send_message(body, options = {})
      sqs = create_sqs_client
      queue_name_prefix = ENV["SQS_PREFIX"].presence || Rails.env
      queue_url = sqs.get_queue_url(queue_name: "#{queue_name_prefix}_#{options[:queue_name]}").queue_url

      options = {
        queue_url: queue_url,
        message_attributes: {
          "shoryuken_class" => {
            string_value: options[:shoryuken_class],
            data_type: "String",
          },
        },
        message_body: body.to_json,
      }

      sqs.send_message(options)
    rescue => error
      Rails.logger.error("Failed to send message to #{queue_url}. #{error.inspect}.")
    end

    def create_sqs_client
      if Rails.env.development?
        Aws::SQS::Client.new(endpoint: ENV["AWS_ENDPOINT"])
      else
        Aws::SQS::Client.new
      end
    end
  end
end

1	# frozen_string_literal: true
2
3	module Queueable	1✔
4	extend ActiveSupport::Concern	1✔
5
6	require "aws-sdk-sqs"	1✔
7
8	class_methods do	1✔
9	def send_events_other_doi_job_message(data)	1✔
NEW 10	send_message(data, shoryuken_class: "OtherDoiJobWorker", queue_name: "events_other_doi_job")	×
11	end
12
13	private	1✔
14
15	def send_message(body, options = {})	1✔
NEW 16	sqs = create_sqs_client	×
NEW 17	queue_name_prefix = ENV["SQS_PREFIX"].presence \|\| Rails.env	×
NEW 18	queue_url = sqs.get_queue_url(queue_name: "#{queue_name_prefix}_#{options[:queue_name]}").queue_url	×
19
20	options = {
NEW 21	queue_url: queue_url,	×
22	message_attributes: {
23	"shoryuken_class" => {
24	string_value: options[:shoryuken_class],
25	data_type: "String",
26	},
27	},
28	message_body: body.to_json,
29	}
30
NEW 31	sqs.send_message(options)	×
32	rescue => error
NEW 33	Rails.logger.error("Failed to send message to #{queue_url}. #{error.inspect}.")	×
34	end
35
36	def create_sqs_client	1✔
NEW 37	if Rails.env.development?	×
NEW 38	Aws::SQS::Client.new(endpoint: ENV["AWS_ENDPOINT"])	×
39	else
NEW 40	Aws::SQS::Client.new	×
41	end
42	end
43	end
44	end

datacite / events / #134

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