Nessuna descrizione http://j1x-huginn.herokuapp.com

event.rb 2.1KB

    require 'json_serialized_field' # Events are how Huginn Agents communicate and log information about the world. Events can be emitted and received by # Agents. They contain a serialized `payload` of arbitrary JSON data, as well as optional `lat`, `lng`, and `expires_at` # fields. class Event < ActiveRecord::Base include JSONSerializedField include LiquidDroppable attr_accessible :lat, :lng, :payload, :user_id, :user, :expires_at acts_as_mappable json_serialize :payload belongs_to :user belongs_to :agent, :counter_cache => true, :touch => :last_event_at scope :recent, lambda { |timespan = 12.hours.ago| where("events.created_at > ?", timespan) } after_create :possibly_propagate # Emit this event again, as a new Event. def reemit! agent.create_event :payload => payload, :lat => lat, :lng => lng end # Look for Events whose `expires_at` is present and in the past. Remove those events and then update affected Agents' # `events_counts` cache columns. This method is called by bin/schedule.rb periodically. def self.cleanup_expired! affected_agents = Event.where("expires_at IS NOT NULL AND expires_at < ?", Time.now).group("agent_id").pluck(:agent_id) Event.where("expires_at IS NOT NULL AND expires_at < ?", Time.now).delete_all Agent.where(:id => affected_agents).update_all "events_count = (select count(*) from events where agent_id = agents.id)" end protected def possibly_propagate #immediately schedule agents that want immediate updates propagate_ids = agent.receivers.where(:propagate_immediately => true).pluck(:id) Agent.receive!(:only_receivers => propagate_ids) unless propagate_ids.empty? end end class EventDrop def initialize(event, payload = event.payload) super(event) @payload = payload end def before_method(key) if @payload.key?(key) @payload[key] else case key when 'agent' @object.agent when 'created_at' @object.created_at end end end def each(&block) return to_enum(__method__) unless block @payload.each(&block) end end