Class Delayed::Backend::Test::Job < Object

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 33
def self.all
  @jobs
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 51
def self.clear_locks!(worker_name)
  all.select{|j| j.locked_by == worker_name}.each {|j| j.locked_by = nil; j.locked_at = nil}
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 37
def self.count
  all.size
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 45
def self.create(attrs = {})
  new(attrs).tap(&:save)
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 49
def self.create!(*args); create(*args); end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 82
def self.db_time_now
  Time.current
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 41
def self.delete_all
  all.clear
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 56
def self.find_available(worker_name, limit = 5, max_run_time = Worker.max_run_time)
  jobs = all.select do |j|
    j.run_at <= db_time_now &&
    (j.locked_at.nil? || j.locked_at < db_time_now - max_run_time || j.locked_by == worker_name) &&
    !j.failed?
  end

  jobs = jobs.select{|j| Worker.queues.include?(j.queue)}   if Worker.queues.any?
  jobs = jobs.select{|j| j.priority >= Worker.min_priority} if Worker.min_priority
  jobs = jobs.select{|j| j.priority <= Worker.max_priority} if Worker.max_priority
  jobs.sort_by{|j| [j.priority, j.run_at]}[0..limit-1]
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 25
def initialize(hash = {})
  self.attempts = 0
  self.priority = 0
  self.id = (self.class.id += 1)
  hash.each{|k,v| send(:"#{k}=", v)}
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 91
def destroy
  self.class.all.delete(self)
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 71
def lock_exclusively!(max_run_time, worker)
  now = self.class.db_time_now
  if locked_by != worker
    # We don't own this job so we will update the locked_by name and the locked_at
    self.locked_at = now
    self.locked_by = worker
  end

  return true
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 104
def reload
  reset
  self
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 95
def save
  self.run_at ||= Time.current

  self.class.all << self unless self.class.all.include?(self)
  true
end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 102
def save!; save; end

# File activejob/test/support/delayed_job/delayed/backend/test.rb, line 86
def update_attributes(attrs = {})
  attrs.each{|k,v| send(:"#{k}=", v)}
  save
end