Sha256: 78fa48f60ec13925a26a866abc0587ea3ef8ce9a8226737aec117aff85ea3abd
Contents?: true
Size: 1.16 KB
Versions: 27
Compression:
Stored size: 1.16 KB
Contents
module Extface
class Job < ActiveRecord::Base
belongs_to :device, inverse_of: :jobs
scope :active, ->{ where(arel_table[:completed_at].eq(nil).and(arel_table[:failed_at].eq(nil))) }
scope :completed, ->{ where(arel_table[:completed_at].not_eq(nil)) }
scope :failed, ->{ where(arel_table[:failed_at].not_eq(nil)) }
def complete!
self.completed_at = Time.now
save!
notify("Job #{self.id} completed!")
end
def completed?
!!completed_at
end
def connected!
unless connected?
self.connected_at = Time.now
save!
notify("Job #{self.id} device connected!")
end
end
def connected?
!!connected_at?
end
def failed!(message)
self.error = message
self.failed_at = Time.now
save!
notify(message)
notify("Job #{self.id} failed!")
end
def failed?
!!failed_at
end
def notify(message)
Extface.redis_block do |r|
r.publish(self.id, message)
end
end
def rpush(buffer)
Extface.redis_block do |r|
r.rpush self.id, buffer
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems