Sha256: c1c92b766e2c282ec2f4ee061702428999d245bac56da99b64949c948df55c7a
Contents?: true
Size: 1.24 KB
Versions: 10
Compression:
Stored size: 1.24 KB
Contents
module Extface
class Job < ActiveRecord::Base
attr_accessor :thread
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?
p "device connected at #{Time.now}"
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
10 entries across 10 versions & 1 rubygems