123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140 |
- # Copyright (C) 2012-2016 Zammad Foundation, http://zammad-foundation.org/
- class ActivityStream < ApplicationModel
- self.table_name = 'activity_streams'
- belongs_to :activity_stream_type, class_name: 'TypeLookup'
- belongs_to :activity_stream_object, class_name: 'ObjectLookup'
- =begin
- add a new activity entry for an object
- ActivityStream.add(
- type: 'update',
- object: 'Ticket',
- permission: 'admin.user',
- o_id: ticket.id,
- created_by_id: 1,
- created_at: '2013-06-04 10:00:00',
- )
- =end
- def self.add(data)
- # lookups
- if data[:type]
- type_id = TypeLookup.by_name(data[:type])
- end
- if data[:object]
- object_id = ObjectLookup.by_name(data[:object])
- end
- permission_id = nil
- if data[:permission]
- permission = Permission.lookup(name: data[:permission])
- if !permission
- raise "No such Permission #{data[:permission]}"
- end
- permission_id = permission.id
- end
- # check newest entry - is needed
- result = ActivityStream.where(
- o_id: data[:o_id],
- #:activity_stream_type_id => type_id,
- permission_id: permission_id,
- activity_stream_object_id: object_id,
- created_by_id: data[:created_by_id]
- ).order('created_at DESC, id DESC').first
- # resturn if old entry is really fresh
- if result
- activity_record_delay = 90.seconds
- return result if result.created_at.to_i >= ( data[:created_at].to_i - activity_record_delay )
- end
- # create history
- record = {
- o_id: data[:o_id],
- activity_stream_type_id: type_id,
- activity_stream_object_id: object_id,
- permission_id: permission_id,
- group_id: data[:group_id],
- created_at: data[:created_at],
- created_by_id: data[:created_by_id]
- }
- ActivityStream.create(record)
- end
- =begin
- remove whole activity entries of an object
- ActivityStream.remove('Ticket', 123)
- =end
- def self.remove(object_name, o_id)
- object_id = ObjectLookup.by_name(object_name)
- ActivityStream.where(
- activity_stream_object_id: object_id,
- o_id: o_id,
- ).destroy_all
- end
- =begin
- return all activity entries of an user
- activity_stream = ActivityStream.list(user, limit)
- =end
- def self.list(user, limit)
- # do not return an activity stream for customers
- return [] if !user.permissions?('ticket.agent') && !user.permissions?('admin')
- permission_ids = user.permissions_with_child_ids
- group_ids = user.group_ids_access('read')
- stream = if group_ids.blank?
- ActivityStream.where('(permission_id IN (?) AND group_id is NULL)', permission_ids)
- .order('created_at DESC, id DESC')
- .limit(limit)
- else
- ActivityStream.where('(permission_id IN (?) AND group_id is NULL) OR (permission_id IN (?) AND group_id IN (?)) OR (permission_id is NULL AND group_id IN (?))', permission_ids, permission_ids, group_ids, group_ids)
- .order('created_at DESC, id DESC')
- .limit(limit)
- end
- list = []
- stream.each do |item|
- data = item.attributes
- data['object'] = ObjectLookup.by_id( data['activity_stream_object_id'] )
- data['type'] = TypeLookup.by_id( data['activity_stream_type_id'] )
- data.delete('activity_stream_object_id')
- data.delete('activity_stream_type_id')
- list.push data
- end
- list
- end
- =begin
- cleanup old stream messages
- ActivityStream.cleanup
- optional you can put the max oldest stream entries as argument
- ActivityStream.cleanup(3.months)
- =end
- def self.cleanup(diff = 3.months)
- ActivityStream.where('created_at < ?', Time.zone.now - diff).delete_all
- true
- end
- end
|