Contents

require 'activity_engine/exceptions'
module ActivityEngine
  class Activity < ActiveRecord::Base
    def self.call(data)
      create! do |activity|
        activity.subject = data.subject
        activity.user = data.current_user
        activity.message = data.message
        activity.activity_type = data.activity_type
      end
    end
    default_scope { order("created_at DESC") }

    scope :for_user, lambda {|user| where(user: user)}
    scope :for_subject, lambda {|subject|
      where(subject_id: ActivityEngine.extract_subject_id(subject), subject_type: subject.class.to_s)
    }
    scope :for_activity_type, lambda {|activity_type|
      where(activity_type: activity_type)
    }
    scope :ascending_date, lambda { order("created_at ASC") }
    scope :descending_date, lambda { order("created_at DESC") }

    scope :for_stats, lambda {
      group("#{quoted_table_name}.activity_type").
      select("#{quoted_table_name}.activity_type,
        MAX(#{quoted_table_name}.created_at) AS last_activity_date,
        COUNT(#{quoted_table_name}.id) AS count"
      )
    }

    def self.statistics_for_subject(subject)
      for_subject(subject).for_stats.each_with_object([]) {|stat, collector|
        collector << ActivityEngine::Statistic.new(subject,stat.attributes)
      }
    end

    belongs_to :user

    def subject
      subject_type.constantize.find(subject_id)
    end

    def subject=(object)
      if object.persisted?
        write_attribute(:subject_type, object.class.to_s)
        write_attribute(:subject_id, ActivityEngine.extract_subject_id(object))
      else
        raise UnpersistedSubjectError.new(object)
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
activity_engine-0.0.9	app/models/activity_engine/activity.rb
activity_engine-0.0.8	app/models/activity_engine/activity.rb
activity_engine-0.0.7	app/models/activity_engine/activity.rb
activity_engine-0.0.6	app/models/activity_engine/activity.rb