activity_stream.rb 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142
  1. # Copyright (C) 2012-2016 Zammad Foundation, http://zammad-foundation.org/
  2. class ActivityStream < ApplicationModel
  3. load 'activity_stream/assets.rb'
  4. include ActivityStream::Assets
  5. self.table_name = 'activity_streams'
  6. # rubocop:disable Rails/InverseOf
  7. belongs_to :object, class_name: 'ObjectLookup', foreign_key: 'activity_stream_object_id'
  8. belongs_to :type, class_name: 'TypeLookup', foreign_key: 'activity_stream_type_id'
  9. # rubocop:enable Rails/InverseOf
  10. # the noop is needed since Layout/EmptyLines detects
  11. # the block commend below wrongly as the measurement of
  12. # the wanted indentation of the rubocop re-enabling above
  13. def noop; end
  14. =begin
  15. add a new activity entry for an object
  16. ActivityStream.add(
  17. type: 'update',
  18. object: 'Ticket',
  19. permission: 'admin.user',
  20. o_id: ticket.id,
  21. created_by_id: 1,
  22. created_at: '2013-06-04 10:00:00',
  23. )
  24. =end
  25. def self.add(data)
  26. # lookups
  27. if data[:type]
  28. type_id = TypeLookup.by_name(data[:type])
  29. end
  30. if data[:object]
  31. object_id = ObjectLookup.by_name(data[:object])
  32. end
  33. permission_id = nil
  34. if data[:permission]
  35. permission = Permission.lookup(name: data[:permission])
  36. if !permission
  37. raise "No such Permission #{data[:permission]}"
  38. end
  39. permission_id = permission.id
  40. end
  41. # check newest entry - is needed
  42. result = ActivityStream.where(
  43. o_id: data[:o_id],
  44. #:activity_stream_type_id => type_id,
  45. permission_id: permission_id,
  46. activity_stream_object_id: object_id,
  47. created_by_id: data[:created_by_id]
  48. ).order('created_at DESC, id DESC').first
  49. # resturn if old entry is really fresh
  50. if result
  51. activity_record_delay = 90.seconds
  52. return result if result.created_at.to_i >= ( data[:created_at].to_i - activity_record_delay )
  53. end
  54. # create history
  55. record = {
  56. o_id: data[:o_id],
  57. activity_stream_type_id: type_id,
  58. activity_stream_object_id: object_id,
  59. permission_id: permission_id,
  60. group_id: data[:group_id],
  61. created_at: data[:created_at],
  62. created_by_id: data[:created_by_id]
  63. }
  64. ActivityStream.create(record)
  65. end
  66. =begin
  67. remove whole activity entries of an object
  68. ActivityStream.remove('Ticket', 123)
  69. =end
  70. def self.remove(object_name, o_id)
  71. object_id = ObjectLookup.by_name(object_name)
  72. ActivityStream.where(
  73. activity_stream_object_id: object_id,
  74. o_id: o_id,
  75. ).destroy_all
  76. end
  77. =begin
  78. return all activity entries of an user
  79. activity_stream = ActivityStream.list(user, limit)
  80. =end
  81. def self.list(user, limit)
  82. # do not return an activity stream for customers
  83. return [] if !user.permissions?('ticket.agent') && !user.permissions?('admin')
  84. permission_ids = user.permissions_with_child_ids
  85. group_ids = user.group_ids_access('read')
  86. stream = if group_ids.blank?
  87. ActivityStream.where('(permission_id IN (?) AND group_id is NULL)', permission_ids)
  88. .order('created_at DESC, id DESC')
  89. .limit(limit)
  90. else
  91. 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)
  92. .order('created_at DESC, id DESC')
  93. .limit(limit)
  94. end
  95. stream
  96. end
  97. =begin
  98. cleanup old stream messages
  99. ActivityStream.cleanup
  100. optional you can put the max oldest stream entries as argument
  101. ActivityStream.cleanup(3.months)
  102. =end
  103. def self.cleanup(diff = 3.months)
  104. ActivityStream.where('created_at < ?', Time.zone.now - diff).delete_all
  105. true
  106. end
  107. end