Sha256: 288e925732318fe0d2e934c79e1a27d1e4fca87bfe61022d373d6435684a15d0
Contents?: true
Size: 971 Bytes
Versions: 37
Compression:
Stored size: 971 Bytes
Contents
class TestTrack::UnsyncedAssignmentsNotifier
attr_reader :visitor_id, :assignments
def initialize(opts)
@visitor_id = opts.delete(:visitor_id)
@assignments = opts.delete(:assignments)
%w(visitor_id assignments).each do |param_name|
raise "#{param_name} must be present" if send(param_name).blank?
end
raise "unknown opts: #{opts.keys.to_sentence}" if opts.present?
end
def notify
assignments.each do |assignment|
build_notify_assignment_job(assignment).tap do |job|
begin
job.perform
rescue *TestTrack::SERVER_ERRORS => e
Rails.logger.error "TestTrack failed to notify unsynced assignments, retrying. #{e}"
Delayed::Job.enqueue(build_notify_assignment_job(assignment))
end
end
end
end
private
def build_notify_assignment_job(assignment)
TestTrack::NotifyAssignmentJob.new(
visitor_id: visitor_id,
assignment: assignment
)
end
end
Version data entries
37 entries across 37 versions & 1 rubygems